<?php

namespace App\Listeners\V1;

use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Contracts\Queue\ShouldQueue;
use App\Events\V1\EventPostCreateCustomer;
use App\Lib\Common\RabbitMQ;
use App\QueueLog;
use Illuminate\Support\Facades\Config;
use PhpAmqpLib\Exchange\AMQPExchangeType;


class ListenerPostCreateCustomer
{
    /**
     * Create the event listener.
     *
     * @return void
     */
    public function __construct()
    {
        //
    }

    /**
     * Handle the event.
     *
     * @param  object  $event
     * @return void
     */
    public function handle(EventPostCreateCustomer $event)
    {
        try {
            $job_handler_cmd = \Config::get('constants.rabbitmq.es_handler').'@'.
                \Config::get('constants.rabbitmq.method_run_cmd');
            if(!$event->cmdCommand || $event->cmdCommand == 'postCreateCustomer'){
                $request_data = [
                    'cmd' => 'command:postCreateCustomer',
                    'app_id' => $event->lid,
                    'cmdCommand' => $event->cmdCommand,
                ];
                $request_data['job_handler'] = $job_handler_cmd;
                $queueLog = QueueLog::create([
                    //'uid' => $event->app_id,
                    'exchange' => \Config::get('constants.rabbitmq.job_exch'),
                    'route_key' => \Config::get('constants.rabbitmq.exch_rout_key_job'),
                    'job_handler' => $job_handler_cmd,
                    'input' => json_encode($request_data),
                ]);
                $request_data['job_id'] = $queueLog->job_id;

                $rabbitMqObj = new RabbitMQ();
                $return = $rabbitMqObj->queueJob(['data' => $request_data],
                    \Config::get('constants.rabbitmq.job_exch'),
                    \Config::get('constants.rabbitmq.exch_rout_key_job'),
                    AMQPExchangeType::DIRECT,
                    \Config::get('constants.rabbitmq.q_job'),
                    $queueLog, true);
                unset($rabbitMqObj, $queueLog, $return, $request_data);
            }
            //------------------------------------------------------------------------
            // send proforma commmand
            if(!$event->cmdCommand || $event->cmdCommand == 'SendProformaCommand'){
                $request_data = [
                    'cmd' => 'command:SendProformaCommand',
                    'app_id' => $event->lid,
                    'cmdCommand' => $event->cmdCommand,
                ];
                $request_data['job_handler'] = $job_handler_cmd;
                $queueLog = QueueLog::create([
                    //'uid' => $event->app_id,
                    'exchange' => \Config::get('constants.rabbitmq.job_exch'),
                    'route_key' => \Config::get('constants.rabbitmq.exch_rout_key_job'),
                    'job_handler' => $job_handler_cmd,
                    'input' => json_encode($request_data),
                ]);
                $request_data['job_id'] = $queueLog->job_id;
                
                $rabbitMqObj = new RabbitMQ();
                $return = $rabbitMqObj->queueJob(['data' => $request_data],
                    \Config::get('constants.rabbitmq.job_exch'),
                    \Config::get('constants.rabbitmq.exch_rout_key_job'),
                    AMQPExchangeType::DIRECT,
                    \Config::get('constants.rabbitmq.q_job'),
                    $queueLog, true);
                unset($rabbitMqObj, $queueLog, $return, $request_data);
            }
            //------------------------------------------------------------------------
            // create cam report
            if(!$event->cmdCommand || $event->cmdCommand == 'createCamReportCommand'){
                $request_data = [
                    'cmd' => 'command:createCamReportCommand',
                    'app_id' => $event->lid,
                    'cmdCommand' => $event->cmdCommand,
                ];
                $request_data['job_handler'] = $job_handler_cmd;
                $queueLog = QueueLog::create([
                    //'uid' => $event->app_id,
                    'exchange' => \Config::get('constants.rabbitmq.job_exch'),
                    'route_key' => \Config::get('constants.rabbitmq.exch_rout_key_job'),
                    'job_handler' => $job_handler_cmd,
                    'input' => json_encode($request_data),
                ]);
                $request_data['job_id'] = $queueLog->job_id;

                $rabbitMqObj = new RabbitMQ();
                $return = $rabbitMqObj->queueJob(['data' => $request_data],
                    \Config::get('constants.rabbitmq.job_exch'),
                    \Config::get('constants.rabbitmq.exch_rout_key_job'),
                    AMQPExchangeType::DIRECT,
                    \Config::get('constants.rabbitmq.q_job'),
                    $queueLog, true);
                unset($rabbitMqObj, $queueLog, $return, $request_data);
            }
        } catch (\Exception $e) {
            report($e);
        }
    }
}