Merge pull request #370 from uspdev/issue_369

Sincroniza setores com replicado #369

Author: masakik

app/Listeners/LoginListener.php

@@ -31,7 +31,8 @@ public function handle(Login $event)
         // vincular a pessoa e o vinculo ao setor
         $vinculos = Pessoa::listarVinculosAtivos($user->codpes, false);
         foreach ($vinculos as $vinculo) {
-            if ($setor = Setor::where('cod_set_replicado', $vinculo['codset'])->first()) {
+            $setor = Setor::where('cod_set_replicado', $vinculo['codset'])->first();
+            if ($setor) {
                 Setor::vincularPessoa($setor, $user, mb_convert_case($vinculo['tipvin'], MB_CASE_TITLE));
                 $log .= 'update vinculo codpes=' . $user->codpes . ',setor=' . $setor->sigla . ',vínculo=' . $vinculo['tipvin'] . ';';
             }

app/Models/Setor.php

@@ -6,6 +6,7 @@
 use Illuminate\Support\Facades\Gate;
 use Illuminate\Database\Eloquent\Model;
 use Illuminate\Database\Eloquent\Factories\HasFactory;
+use Uspdev\Replicado\Estrutura;
 
 class Setor extends Model
 {
@@ -77,7 +78,7 @@ public static function allToSelect()
         $ret = [];
         foreach ($setores as $setor) {
             if (Gate::allows('setores.view', $setor)) {
-            $ret[$setor->id] = $setor->sigla . ' - ' . $setor->nome;
+                $ret[$setor->id] = $setor->sigla . ' - ' . $setor->nome;
             }
         }
         return $ret;
@@ -93,14 +94,123 @@ public static function vincularPessoa($setor, $user, $funcao)
         $u = $setor->users()->where('user_id', $user->id)->wherePivot('funcao', $funcao)->withPivot('funcao')->first();
 
         // vamos cadastrar ou atualizar o setor somente se mudou de setor
-        if(empty($u) || $u->pivot->funcao != $funcao) {
+        if (empty($u) || $u->pivot->funcao != $funcao) {
             config('app.debug') && Log::info("Atualizado setor de $user->codpes em $setor->sigla na função $funcao");
             $setor->users()->wherePivot('funcao', $funcao)->detach($user);
             $user->setores()->attach($setor, ['funcao' => $funcao]);
         }
+    }
+
+    /**
+     * Sincroniza os setores com o replicado e retorna uma mensagem com as estatísticas
+     *
+     * Adiciona, remove e renomeia os setores.
+     * Adiciona os chefes como gerentes dos setores.
+     * Não remove os antigos pois se for substituição vai remover o chefe de fato.
+     * Chamado no artisan setores:sync
+     */
+    public static function sincronizarComReplicado()
+    {
+        $estatisticas = [
+            'setores_criados' => [],
+            'setores_atualizados' => [],
+            'chefes_adicionados' => [],
+            'setores_removidos' => [],
+        ];
+
+        $setores_repl = Estrutura::listarSetores();
+        $cod_unidade = config('replicado.codundclg');
+
+        // Primeiro loop: cria ou atualiza setores
+        foreach ($setores_repl as $setor_repl) {
+            $setor = self::firstOrNew(['cod_set_replicado' => $setor_repl['codset']]);
+            $is_novo = !$setor->exists;
+
+            // Atualiza atributos
+            $setor->sigla = str_replace('-' . $cod_unidade, '', $setor_repl['nomabvset']);
+            $setor->nome = $setor_repl['nomset'];
+            $setor->cod_set_replicado = $setor_repl['codset'];
+            $setor->cod_set_pai_replicado = $setor_repl['codsetspe'];
+
+            if ($is_novo) {
+                $setor->save();
+                $estatisticas['setores_criados'][] = $setor->nome;
+            } elseif ($setor->isDirty()) {
+                $setor->save();
+                $estatisticas['setores_atualizados'][] = $setor->nome;
+            }
+        }
+
+        // Segundo loop: associa setor pai e chefes
+        foreach ($setores_repl as $setor_repl) {
+            $setor = self::where('cod_set_replicado', $setor_repl['codset'])->first();
+
+            $setor_pai = self::where('cod_set_replicado', $setor->cod_set_pai_replicado)->first();
+            if ($setor_pai) {
+                $setor->setor_id = $setor_pai->id;
+                $setor->save();
+            }
+
+            if (!empty($setor->setor_id)) {
+                $chefes = Estrutura::getChefiaSetor($setor_repl['codset']);
+                foreach ($chefes as $chefe) {
+                    $u = User::obterOuCriarPorCodpes($chefe['codpes']);
+
+                    $attached = $setor->users()
+                        ->wherePivot('user_id', $u->id)
+                        ->wherePivot('funcao', 'Gerente')
+                        ->exists();
+
+                    if (!$attached) {
+                        $setor->users()->attach($u->id, ['funcao' => 'Gerente']);
+                        $estatisticas['chefes_adicionados'][] = "{$u->name} ({$setor->nome})";
+                    }
+                }
+            }
+        }
+
+        // Terceiro loop: remove setores que não existem mais no replicado
+        $codigos_replicado = array_column($setores_repl, 'codset');
+        $setores_remover = self::whereNotIn('cod_set_replicado', $codigos_replicado)->get();
 
+        foreach ($setores_remover as $setor) {
+            $nome_antigo = $setor->nome;
+            if (stripos($setor->nome, '(removido)') === false) {
+                $setor->nome .= ' (removido)';
+                $setor->save();
+                $estatisticas['setores_removidos'][] = $nome_antigo;
+            }
+        }
+
+        // Monta a mensagem de log
+        $mensagem_log = "Sincronização de setores concluída\n";
+
+        $mensagem_log .= "\nSetores criados (" . count($estatisticas['setores_criados']) . "):";
+        foreach ($estatisticas['setores_criados'] as $nome) {
+            $mensagem_log .= "\n - $nome";
+        }
+
+        $mensagem_log .= "\n\nSetores atualizados (" . count($estatisticas['setores_atualizados']) . "):";
+        foreach ($estatisticas['setores_atualizados'] as $nome) {
+            $mensagem_log .= "\n - $nome";
+        }
+
+        $mensagem_log .= "\n\nChefes adicionados (" . count($estatisticas['chefes_adicionados']) . "):";
+        foreach ($estatisticas['chefes_adicionados'] as $chefe) {
+            $mensagem_log .= "\n - $chefe";
+        }
+
+        $mensagem_log .= "\n\nSetores marcados como removidos (" . count($estatisticas['setores_removidos']) . "):";
+        foreach ($estatisticas['setores_removidos'] as $nome) {
+            $mensagem_log .= "\n - $nome";
+        }
+
+        // Loga e retorna mensagem
+        Log::info($mensagem_log);
+        return $mensagem_log;
     }
 
+
     /**
      * Auto relacionamento
      */