<?php
declare(strict_types=1);

use Phinx\Migration\AbstractMigration;

final class Task2201061300 extends AbstractMigration
{
    public function up(): void
    {
        $this->execute("INSERT
                          INTO sistema.corretores_comercial
                             ( id_usuario_criacao
                             , dt_criacao
                             , fl_ativo
                             , fl_del
                             , id_corretor
                             , id_comercial
                             )
                        SELECT 2068             AS id_usuario_criacao
                             , NOW()            AS dt_criacao
                             , TRUE             AS fl_ativo
                             , FALSE            AS fl_del
                             , corretores.id
                             , 1037             AS id_comercial
                          FROM sistema.corretores
                         WHERE id_comercial != 1037
                           AND corretores.id NOT IN (
                                                      SELECT id_corretor
                                                        FROM sistema.corretores_comercial
                                                       WHERE id_comercial = 1037
                                                    )
                             ;
                      ");
    }

    public function down(): void
    {
        $delete = $this->getQueryBuilder();
        $delete->delete('sistema.corretores_comercial')
               ->where(['id_usuario_criacao' => 2068])
               ->where(['id_comercial' => 1037])
               ->where(['dt_criacao >' => '2022-01-28'])
               ->execute();
    }
}