Controller.php

<?php

namespace RegistrationPayments;

use DateTime;
use League\Csv\Writer;
use MapasCulturais\App;
use MapasCulturais\Traits;
use CnabPHP\RemessaAbstract;
use RegistrationPayments\Plugin;
use RegistrationPayments\Payment;
use MapasCulturais\Entities\Opportunity;

/**
 * Payment Controller
 *
 *  @property-read \RegistrationPayments\Payment $requestedEntity The Requested Entity
 */
// class Controller extends \MapasCulturais\Controllers\EntityController {
class Controller extends \MapasCulturais\Controllers\EntityController
{

    use Traits\ControllerAPI;
    public function __construct()
    {
        parent::__construct();
        $this->entityClassName = '\RegistrationPayments\Payment';

    }

    /**
     * Busca pagamentos da oportunidade
     */
    public function GET_findPayments($opportunity_id = null)
    {
        $this->requireAuthentication();

        $opportunity_id = $this->data['opportunity'];
        $data = $this->data;
        $complement = "";

        $app = App::i();
        $conn = $app->em->getConnection();

        // $limit = isset($data['@limit']) ? $data['@limit'] : 50;
        $page = isset($data['@page']) ? (int) $data['@page'] : 1;
        $search = isset($data['search']) ? $data['search'] : "";
        $status = isset($data['status']) ? $data['status'] : null;
        // $offset = ($page - 1) * $limit;

        //Parametros basicos de pesquisa
        $params = [
            "opp" => $opportunity_id,
            "search" => "%" . $search . "%",
            "nomeCompleto" => '%"nomeCompleto":"' . $search . '%',
            "documento" => '%"documento":"' . $search . '%',
            // "limit" => $limit,
            // 'offset' => $offset,
        ];

        //incrementa parametros caso exista um filtro por status
        if (is_numeric($status)) {
            $complement .= " AND p.status = :status";
            $params['status'] = $status;
        }

        //incrementa parametros caso exista um filtro por data
        if (isset($data['from']) && !empty($data['from'])) {
            $from = new DateTime($data['from']);
            $params['from'] = $from->format('Y-m-d');
            $complement .= " AND p.payment_date >= :from";

            if (isset($data['to']) && !empty($data['to'])) {
                $to = new DateTime($data['to']);
                $params['to'] = $to->format('Y-m-d');
                $complement .= " AND p.payment_date <= :to";
            }
        }

        //Busca os ids das inscrições
        $query = " SELECT p.id, p.registration_id, r.number, p.payment_date, p.amount, p.metadata, p.status
        FROM registration r
        RIGHT JOIN payment p ON r.id = p.registration_id  WHERE p.opportunity_id = :opp AND
        (r.number like :search OR r.agents_data like :nomeCompleto OR r.agents_data like :documento) {$complement}";

        $payments = $conn->fetchAll($query, $params);

        //Remonta o retorno de pagamentos para fazer tratamentos nos valores
        $paymentsResultString = array_map(function ($payment) {
            return [
                "id" => $payment['id'],
                "registration_id" => $payment['registration_id'],
                "number" => $payment['number'],
                "payment_date" => $payment['payment_date'],
                "amount" => (float) $payment['amount'],
                "metadata" => json_decode($payment['metadata']),
                "status" => $payment['status'],
            ];
        }, $payments);

        //Pega o total de pagamentos cadastrados
        $filter = [
            "opp" => $opportunity_id,
        ];

        //incrementa parametros caso exista um filtro por status
        if (is_numeric($status)) {
            $filter['status'] = $status;
        }

        //incrementa parametros caso exista um filtro por pagamento
        if (isset($data['from']) && !empty($data['from'])) {
            $from = new DateTime($data['from']);
            $filter['from'] = $from->format('Y-m-d');
            $complement .= " AND p.payment_date >= :from";

            if (isset($data['to']) && !empty($data['to'])) {
                $to = new DateTime($data['to']);
                $filter['to'] = $to->format('Y-m-d');
                $complement .= " AND p.payment_date <= :to";
            }
        }

        //Faz a contabilização de resultados e devolve uma soma total de registros encontrados
        $query = "SELECT count(p) as total
        FROM registration r
        RIGHT JOIN payment p
        ON r.id = p.registration_id WHERE
        p.opportunity_id = :opp {$complement}";
        $total = $conn->fetchAll($query, $filter);

        //Retorna os dados
        $this->apiAddHeaderMetadata($this->data, $payments, $total[0]['total']);
        $this->apiResponse($paymentsResultString);
    }

    /**
     *
     * @apiDefine APIPatch
     * @apiDescription Atualiza parcialmente uma entidade.
     * @apiParam {Array} [data] Array com valores para popular os atributos da entidade. Use o método describe para descobrir os atributos.
     */
    public function PATCH_single($data = null)
    {

        $this->requireAuthentication();

        if (is_null($data)) {
            $data = $this->postData;
        }

        $app = App::i();

        $app->applyHookBoundTo($this, "PATCH({$this->id}.single):data", ['data' => &$data]);

        $entity = $this->requestedEntity;

        if (!$entity) {
            $app->pass();
        }

        $function = null;

        //Atribui a propriedade editada
        foreach ($data as $field => $value) {
            $entity->$field = $value;
        }

        if ($_errors = $entity->validationErrors) {
            $errors = [];
            foreach ($this->postData as $field => $value) {
                if (key_exists($field, $_errors)) {
                    $errors[$field] = $_errors[$field];
                }
            }

            if ($errors) {
                $this->errorJson($errors, 400);
            }
        }
        $this->_finishRequest($entity, true, $function);
    }

    /**
     *
     * @apiDefine APIPost
     * @apiDescription Cria uma entidade.
     * @apiParam {Array} [data] Array com valores para popular os atributos da entidade. Use o método describe para descobrir os atributos.
     */
    public function POST_createMultiple($data = null)
    {

        $this->requireAuthentication();

        $app = App::i();

        $user = $app->getUser();

        $data = $this->data;
        $ids = explode(",", $data['registration_id']);

        $ids = array_map(function ($id) {
            return trim(preg_replace('/[^0-9]/i', '', $id));
        }, $ids);

        $ids = array_filter($ids);

        $errors = [];

        $registrations = $app->repo('Registration')->findBy(['id' => $ids]);

        if (!$registrations) {
            $this->errorJson($errors, 400);
        }

        $opportunity = $app->repo('Opportunity')->find($data['opportunity']);

        foreach ($registrations as $registration) {
            $payment = new Payment();
            $payment->opportunity = $opportunity;
            $payment->createdByUser = $user;
            $payment->registration = $registration;
            $payment->paymentDate = new DateTime($data['payment_date']);
            $payment->amount = (float) $data['amount'];
            $payment->status = $data['status'] ?? 1;
            $payment->metadata = $data['metadata'] ?? (object) [];
            if ($errors = $payment->getValidationErrors()) {
                $this->errorJson($errors, 400);
            }
            $payment->save();
        }

        $app->em->flush();

        $this->finish($payment);
    }

    /**
     * 
     * @apiDefine APIPATCH
     * @apiDescription Atualiza as configurações de exibição dos pagamentos.
     * @apiParam {Array} [data] Array com valores para atualizar os atributos da entidade. Use o método describe para descobrir os atributos. 
     */
    function PATCH_savePaymentConfig() {

        $this->requireAuthentication();

        $app = App::i();
        $data = $this->data;

        $opportunity = $app->repo('Opportunity')->find($data['opportunity']);
        $opportunity->paymentsTabEnabled = $data['value'];
        $opportunity->save(true);

        $this->_finishRequest($opportunity, true);
    }

    /**
     *
     * @apiDefine APIGET
     * @apiDescription Exporta um arquivo CSV com os dados de pagamento filtraos.
     */
    public function GET_exportFilter()
    {
        $this->requireAuthentication();
        $app = App::i();
        $conn = $app->em->getConnection();
        $data = $this->data;
        $opportunity_id = $this->data["opportunity"];
        $search = isset($data["search"]) ? $data["search"] : "";
        $complement = "";
        $status = isset($data["status"]) ? $data["status"] : null;
        $params = [
            "opp" => $opportunity_id,
            "search" => "%" . $search . "%",
            "nomeCompleto" => '%"nomeCompleto":"' . $search . '%',
            "documento" => '%"documento":"' . $search . '%',
        ];
        //incrementa parametros caso exista um filtro por data
        if (isset($data["from"]) && !empty($data["from"])) {
            $from = new DateTime($data["from"]);
            $params["from"] = $from->format("Y-m-d");
            $complement .= " AND p.payment_date >= :from";
            if (isset($data["to"]) && !empty($data["to"])) {
                $to = new DateTime($data["to"]);
                $params["to"] = $to->format("Y-m-d");
                $complement .= " AND p.payment_date <= :to";
            }
        }
        //incrementa parametros caso exista um filtro por status
        if (is_numeric($status)) {
            $complement .= " AND p.status = :status";
            $params["status"] = $status;
        }
        //Busca os ids das inscrições
        $query = " SELECT p.id, p.registration_id, r.number, p.payment_date, p.amount, p.metadata, p.status
        FROM registration r
        RIGHT JOIN payment p ON r.id = p.registration_id  WHERE p.opportunity_id = :opp AND
         (r.number like :search OR r.agents_data like :nomeCompleto OR r.agents_data like :documento) {$complement}";
        $dataPayments = $conn->fetchAll($query, $params);
        $header = [
            "ID",
            "INSCRICAO",
            "PREVISAO_PAGAMENTO",
            "VALOR",
            "STATUS",
        ];
        $payments = array_map(function ($payment) {
            $date = new DateTime($payment["payment_date"]);
            switch ($payment["status"]) {
                case 0:
                    $status = "Pendente";
                    break;
                case 1:
                    $status = "Processando";
                    break;
                case 2:
                    $status = "Falha";
                    break;
                case 3:
                    $status = "Exportado";
                    break;
                case 8:
                    $status = "Disponível";
                    break;
                case 10:
                    $status = "Pago";
                    break;
                default:
                    $status = $payment["paymentDate"];
                    break;
            }
            return [
                "id" => $payment["id"],
                "inscricao" => $payment["number"],
                "previsaoPagamento" => $date->format("d/m/Y"),
                "valor" => $payment["amount"],
                "status" => $status,
            ];
        }, $dataPayments);
        $app->applyHook("opportunity.payments.reportCSV", [ & $dataPayments, &$header, &$payments]);
        $csv = Writer::createFromString();
        $csv->setDelimiter(";");
        $csv->insertOne($header);
        foreach ($payments as $payment) {
            $csv->insertOne($payment);
        }
        $dateExport = new DateTime("now");
        $fileName = "result-filter-payments-opp-" . $data["opportunity"] . md5(json_encode($payments)) . "-" . $dateExport->format("dmY");
        $csv->output($fileName . ".csv");
        return;
    }

    /**
     * 
     * @apiDefine APIGET
     * @apiDescription Retorna o historico de alterações de um pagamento.
     */
    public function GET_revision(){
       
        $app = App::i();
        
        $paymentId = $this->data['paymentId'];

        $dataRevisions = [];
        $payment = $app->repo('RegistrationPayments\\Payment')->find($paymentId);
        $entityRevisions = $app->repo("EntityRevision")->findEntityRevisions($payment);
        

        foreach($entityRevisions as $value){
            $dataRevisions[$value->id] = $value->getRevisionData();
        }
        
        $return = [
            'revisions' => $entityRevisions,
            'dataRevisions' => $dataRevisions
        ];

        $this->apiResponse($return);
    }

    public function ALL_generateCnab()
    {
        $this->requireAuthentication();

         //Seta o timeout
         ini_set('max_execution_time', 0);
         ini_set('memory_limit', '768M');

        $app = App::i();

        // Pega a instancia do plugin
        $plugin = Plugin::getInstance();

       // Varifica se o arquivo é um teste ou se é um arquivo oficial
       $test = false;
       if(isset($this->data['ts_lot']) && $this->data['ts_lot'] == 'on'){
           $test = true;
       }
   
        // Pega a oportunidade
        $opportunity = $app->repo("Opportunity")->find(['id' => $this->data['opportunity_id']]);
        $opportunity->registerRegistrationMetadata($opportunity);

        // Verifica se o usuário te controle da oportunidade para executar a exportação
        if(!$opportunity->canUser('@control')){
            echo "Não Autorizado";
            exit;
        }

        // Veirfica existe identificaçõ do lote
        if(!$test && empty($this->data['identifier'])){
            echo "Informe o número de identificação do lote Ex.: 001";
            exit;
        }

         // Pega o identificador
         $identifier = "lote-". str_pad($this->data['identifier'] , 4 , '0' , STR_PAD_LEFT);
         

        // Pega os ID's das inscrições
        $registration_ids = $this->getRegistrationsIds($opportunity,  $identifier);
        

        // Veirfica se o Lote esta informado
        if(!$registration_ids){
            echo "Nao foram encontrado inscrições";
            exit;
        }
   
        // Verifica se o CNAB esta ativo
        if(!$plugin->config['cnab240_enabled']){
            echo "Habilite o CANB240 nas configurações";
            exit;
        }

        // Veirfica se o Lote esta informado
        if(!isset($this->data['lotType'])){
            echo "Informe o tipo de lote <br> 1 Corrente BB<br> 2 Poupança BB<br> 3 Outros bancos";
            exit;
        }

             
        // Pega todos os lotes ja exportados
        $payment_lot_export = json_decode($opportunity->payment_lot_export, true);

        $typeLot = [
            1 => "Corrente BB",
            2 => "Poupança BB",
            3 => "Outros Bancos"
        ];

        // Verifica se o lote ja foi exportado anteriormente
        if(!$test && in_array($this->data['lotType'], $payment_lot_export[$identifier] ?? [])){
            echo "{$identifier} para o arquivo {$typeLot[$this->data['lotType']]} Já exportado anteriormente. Caso queira fazer uma confêrencia selecione a caixa Exportar lote de teste.";
            exit;
        }

        

        // Pega o tipo de lote a ser exportado
        $lot = $plugin->config['opportunitysCnab'][$opportunity->id]['settings']['release_type'][$this->data['lotType']];

        // Pega as configurações da entidade pagadora
        if(!($company_data = $plugin->config['cnab240_company_data'])){
            echo "A entidade pagadora nao foi configurada";
            exit;
        }

        // Veirfica a data de pagamento 
        if(!($paymentDate = $this->data['paymentDate'])){
           $paymentDate = null;
        }

       
        $get_company_data = function($field) use ($opportunity, $company_data, $plugin) {
            
            $config = $plugin->config['opportunitysCnab'][$opportunity->id];

            if(array_key_exists('company_data', $config)) {
                $exclusive_company_data = $config['company_data'];
                if(array_key_exists($field, $exclusive_company_data)) {
                    return $exclusive_company_data[$field];
                }else {
                    return $company_data[$field];
                }
            }else {
                return $company_data[$field];
            }
        };

        /** 
         * Instancia o CANB
         * @var Remessa  $arquivo
        */     
        $arquivo = $plugin->getCanbInstace('001', 'Cnab240', [
            'nome_empresa' => $get_company_data('nome_empresa'),
            'tipo_inscricao' => $get_company_data('tipo_inscricao'),
            'numero_inscricao' => $get_company_data('numero_inscricao'),
            'agencia' => $get_company_data('agencia'), 
            'agencia_dv' => $get_company_data('agencia_dv'),
            'conta' => $get_company_data('conta'), 
            'conta_dv' => $get_company_data('conta_dv'), 
            'numero_sequencial_arquivo' => 1, 
            'convenio' => $get_company_data('convenio'),
            'carteira' => '',
            'situacao_arquivo' => $test ? 'TS' : ' ', 
            'uso_bb1' => $get_company_data('convenio'),
            'uso_bb2' => '0126',
            'uso_bb4' => $test ? 'TS' : ' ',
            'operacao' => 'C',
            'tipo_lancamento' => $lot,

        ]);

     

        // Seta o tipo do lote
        $lote = $arquivo->addLote(array('tipo_servico' => '98')); // 98 = Pagamentos diversos


        foreach($registration_ids as $key => $id){
            $app = App::i();
           
            $payment = $app->repo('RegistrationPayments\\Payment')->findOneBy(['id' => $id]);
            // Pega a inscrição pelo ID
            $registration = $app->repo("Registration")->find(['id' => $payment->registration->id]);

            // Pega o pagamento

            if(!$test){
                $paymentInfo = [];
                if(!$payment->metadata){
                    $paymentInfo['identifier'][] = $identifier;
                    $payment->metadata = json_encode($paymentInfo);
                }else{
                    $paymentInfo = (array)$payment->metadata ?? [];
                    $paymentInfo['identifier'][] = $identifier;
                    $payment->metadata = json_encode($paymentInfo);
                
                }
            
                $payment->status = Payment::STATUS_EXPORTED;
                $payment->save(true);
            }
                        
            // Insere 1 lote
            $lote->inserirDetalhe(array(
               
                //Dados pessoais
                'nome_favorecido' => $this->processValues('proponent_name', $registration),
                'endereco_residencia_favorecido' => $this->processValues('address', $registration),
                'numero_residencia_favorecido' => (int) $this->processValues('number', $registration),
                'complemento_residencia_favorecido' => $this->processValues('complement', $registration),
                'cidade_residencia_favorecido' => $this->processValues('city', $registration),
                'cep_residencia_favorecido' => $this->processValues('zipcode', $registration),
                'estado_residencia_favorecido' => 'PE',
                'data_emissao' => (new DateTime('now'))->format("Y-m-d"), 


                //Dados para pagamento
                'codigo_banco_favorecido' => substr(preg_replace('/[^0-9]/', '', $this->processValues('bank', $registration)), 0, 3),
                'agencia_favorecido' => $this->processValues('branch', $registration),
                'agencia_favorecido_dv' => $this->processValues('branch_dv', $registration),
                'conta_favorecido' => preg_replace('/[^0-9]/', '', $this->processValues('account', $registration)),
                'conta_favorecido_dv' => $this->processValues('account_dv', $registration),
                'data_pagamento' => $paymentDate ?? $payment->paymentDate->format("Y-m-d"),
                'valor_pagamento' => $payment->amount, 
                'tipo_inscricao' => $this->processValues('social_type', $registration), 
                'numero_inscricao' => $this->processValues('proponent_document', $registration),
                'referencia_pagamento' => base_convert($registration->id, 10, 36)

            ));
            
            $complementDebugInfo = $test ? "para teste" : "para pagamento";
            $app->log->debug("#{$key} - CNAB240 Exportando inscrição {$id} {$complementDebugInfo}");
            $app->em->clear();
        }

        // Salva a refêrencia do lote na oportunidade
        if(!$test){
            $opportunity = $app->repo("Opportunity")->find(['id' => $this->data['opportunity_id']]);
            $payment_lot_export[$identifier][] = $this->data['lotType'];
            $opportunity->payment_lot_export = json_encode($payment_lot_export);
            $opportunity->save(true);
        }

  
        $fileType = str_replace(" ", "_", strtolower($plugin->config['file_type'][$this->data['lotType']]));
        $name = mb_strtolower(str_replace(" ", "-", mb_substr($opportunity->name, 0, 20)));
        $amount_file = preg_replace('/[^0-9]/i', '', RemessaAbstract::$sumValoesTrailer);
        $file_name = "pagamento-{$amount_file}---{$identifier}-{$name}--opp-{$opportunity->id}-{$fileType}-canb240.txt";


        $dir = BASE_PATH . '/cnab/';

        $patch = $dir . $file_name;

        if (!is_dir($dir)) {
            mkdir($dir, 0700, true);
        }

        $stream = fopen($patch, 'w');

        fwrite($stream, $arquivo->getText());

        fclose($stream);


        header('Content-Type: application/txt');
        header("Content-Disposition: attachment; filename=\"$file_name\"");
        header('Pragma: no-cache');
        readfile($patch);
    }

    /**
     * Retorna as inscrições
     *
     * @param mixed $opportunity
     * @return \MapasCulturais\Entities\Registration[]
     */
    public function getRegistrationsIds(Opportunity $opportunity, $identifier)
    {
        $this->requireAuthentication();

        $app = App::i();

        $plugin = Plugin::getInstance();       

      
        $params = [];

        $sub_query = "SELECT number FROM registration r";
        $sub_query_complement_where = "";
        $query_complement_where  = "";
        $conn = $app->em->getConnection();
        $lot = $plugin->config['opportunitysCnab'][$opportunity->id]['settings']['release_type'][$this->data['lotType']];

        $test = false;
        if(isset($this->data['ts_lot']) && $this->data['ts_lot'] == 'on'){
            $test = true;
        }

        if($this->data['registrationFilter']){

            $registrationFilter = $this->data['registrationFilter'];
            $delimiter = "\n";

            if(count(explode(",", $registrationFilter)) >1){
                $delimiter = ","; 
            }else if(count(explode(";", $registrationFilter)) >1){
                $delimiter = ";"; 
            }
            
            $ids = explode($delimiter, $registrationFilter);

            $result = array_map(function($id){
                return trim($id);
            },$ids);         
            
            $list = implode("','", array_filter($result));

            $sub_query_complement_where.= "AND r.number IN ('{$list}')";

        }
     
        $cnab_config = $plugin->config['opportunitysCnab'][$opportunity->id];
        if($lot == '01' || $lot == '05'){

            $sub_query.= " JOIN registration_meta account ON r.id = account.object_id AND account.key = :field_type_account AND account.value = :account
                            JOIN registration_meta bank ON r.id = bank.object_id AND bank.key = :field_bank AND bank.value = :bank_name";

            $params['field_type_account'] = "field_".$cnab_config['account_type'];
            $params['account'] = $cnab_config['settings']['default_lot_type'][$lot];
            $params['field_bank'] = "field_".$cnab_config['bank'];
            $params['bank_name'] = $cnab_config['canab_bb_default_value'];
            
        }else if($lot == '03'){
            $sub_query.= " JOIN registration_meta bank ON r.id = bank.object_id AND bank.key = :field_bank AND bank.value <> :bank_name";

            $params['field_bank'] = "field_".$cnab_config['bank'];
            $params['bank_name'] = $cnab_config['canab_bb_default_value'];
        }

        if(in_array('paymentDate', array_keys($this->data)) && $this->data['paymentDate']) {
            $query_complement_where .= " AND p.payment_date = :paymentDate";
            $params['paymentDate'] = $this->data['paymentDate'];
        }


        $query = "SELECT p.id
                FROM
                    payment p
                    JOIN registration reg on p.registration_id = reg.id
                WHERE
                    reg.status > :r_status
                    AND reg.opportunity_id = $opportunity->id
                    AND p.status >= :p_status 
                    AND reg.number in ({$sub_query} {$sub_query_complement_where}) {$query_complement_where}";

        $params += [
            'r_status' => 0,
            'p_status' => 0
        ];

        $registrations_ids = $conn->fetchAll($query, $params);

        
        $ids = [];
        foreach ($registrations_ids as $value) {
            $ids[] = $value['id'];
        }

        return $ids;
    }
    
    /**
     * Processa os valores devolvendo os dados que devem ser exibidos
     *
     * @param  mixed $value
     * @param  Registration $registration
     * @return string
     */
    public function processValues($value, \MapasCulturais\Entities\Registration $registration)
    {
        if(!$value){
            return "";
        }

        $plugin = Plugin::getInstance();

        $settings = $plugin->config['opportunitysCnab'][$registration->opportunity->id]['settings'];

        $field_id = $plugin->config['opportunitysCnab'][$registration->opportunity->id][$value] ?? null;
       
        $tratament = $plugin->config['treatments'][$value] ?? null;

        $metadata = $registration->getMetadata();

        $dependence = null;
        if(is_array($field_id) && isset($field_id['dependence'])){
            if($field_id['dependence'] == "category"){
                $field_id = $field_id['dependence']; 
            }else{
                $field_name = 'field_'.$plugin->config['opportunitysCnab'][$registration->opportunity->id][$field_id['dependence']];
                $dependence = $settings[$field_id['dependence']][$registration->$field_name]; 
                $field_id = $field_id[$dependence];  
            }
                      
        }
        
        return $tratament ? $tratament($registration, $field_id, $settings, $metadata, $dependence) : $value;
    }
    

    
}