Proyectos de Subversion LeadersLinked - Backend

<?php

declare(strict_types=1);

namespace LeadersLinked\Controller;

use Laminas\Db\Adapter\AdapterInterface;

use Laminas\Cache\Storage\Adapter\AbstractAdapter;

use Laminas\Mvc\Controller\AbstractActionController;

use Laminas\Log\LoggerInterface;

use Laminas\View\Model\ViewModel;

use Laminas\View\Model\JsonModel;

use LeadersLinked\Library\Functions;

use Laminas\Mvc\I18n\Translator;

use LeadersLinked\Mapper\DiscoveryContactInteractionMapper;

use LeadersLinked\Mapper\DiscoveryContactInteractionTypeMapper;

use LeadersLinked\Model\DiscoveryContactLog;

use LeadersLinked\Mapper\DiscoveryContactMapper;

use LeadersLinked\Mapper\QueryMapper;

use LeadersLinked\Mapper\UserMapper;

use Laminas\Paginator\Adapter\DbSelect;

use Laminas\Paginator\Paginator;

use LeadersLinked\Form\DiscoveryContact\InteractionForm;

use LeadersLinked\Model\DiscoveryContactInteraction;

use LeadersLinked\Mapper\DiscoveryContactLogMapper;

class DiscoveryContactInteractionController extends AbstractActionController

{

    /**

     *

     * @var AdapterInterface

     */

    private $adapter;

    /**

     *

     * @var AbstractAdapter

     */

    private $cache;

    /**

     *

     * @var  LoggerInterface

     */

    private $logger;

    /**

     *

     * @var array

     */

    private $config;

    /**

     *

     * @var Translator

     */

    private $translator;

    /**

     *

     * @param AdapterInterface $adapter

     * @param AbstractAdapter $cache

     * @param LoggerInterface $logger

     * @param array $config

     * @param Translator $translator;

     */

    public function __construct($adapter, $cache , $logger, $config, $translator)

    {

        $this->adapter      = $adapter;

        $this->cache        = $cache;

        $this->logger       = $logger;

        $this->config       = $config;

        $this->translator   = $translator;

    }

    public function indexAction()

    {

        $request = $this->getRequest();

        if($request->isGet()) {

            $request = $this->getRequest();

            $uuid = $this->params()->fromRoute('id');

            if(!$uuid) {

                $data = [

                    'success'   => false,

                    'data'   => 'ERROR_INVALID_PARAMETER'

                ];

                return new JsonModel($data);

            }

            $discoveryContactMapper = DiscoveryContactMapper::getInstance($this->adapter);

            $discoveryContact = $discoveryContactMapper->fetchOneByUuid($uuid);

            if(!$discoveryContact) {

                $data = [

                    'success'   => false,

                    'data'   => 'ERROR_RECORD_NOT_FOUND'

                ];

                return new JsonModel($data);

            }

            $search = $this->params()->fromQuery('search');

            $search = empty($search) ? '' : filter_var($search, FILTER_SANITIZE_STRING);

            $page               = intval($this->params()->fromQuery('start', 1), 10);

            $records_x_page     = intval($this->params()->fromQuery('length', 10), 10);

            $queryMapper = QueryMapper::getInstance($this->adapter);

            $select = $queryMapper->getSql()->select();

            $select->from([ 'tb1' => DiscoveryContactInteractionMapper::_TABLE ]);

            $select->columns(['uuid', 'notes', 'added_on']);

            $select->join(['tb2' => DiscoveryContactInteractionTypeMapper::_TABLE], 'tb2.id = tb1.interaction_type_id', ['name']);

            $select->join(['tb3' => UserMapper::_TABLE], 'tb1.user_id = tb3.id', ['first_name' , 'last_name', 'email']);

            $select->where->equalTo('tb1.company_id', $discoveryContact->company_id);

            $select->where->equalTo('tb1.contact_id', $discoveryContact->id);

            if($search) {

                $select->where->nest()

                ->like('first_name', '%' . $search . '%')

                ->or->like('last_name', '%' . $search . '%')

                ->or->like('email', '%' . $search . '%')

                ->or->like('name', '%' . $search . '%')

                ->unnest();

            }

            $select->order('added_on DESC');

            $page               = intval($this->params()->fromQuery('start', 1), 10);

            $adapter = new DbSelect($select, $queryMapper->getSql());

            $paginator = new Paginator($adapter);

            $paginator->setItemCountPerPage($records_x_page);

            $paginator->setCurrentPageNumber($page);

            $items = [];

            $records = $paginator->getCurrentItems();

            foreach($records as $record)

            {

                $dt = \DateTime::createFromFormat('Y-m-d H:i:s', $record['added_on'] );

                $item = [

                    'first_name' => $record['first_name'],

                    'last_name' => $record['last_name'],

                    'email' => $record['email'],

                    'name' => $record['name'],

                    'notes' => $record['notes'],

                    'added_on' => $dt->format('d/m/Y H:i a'),

                    'link_delete' => $this->url()->fromRoute('discovery-contacts/interactions/delete', ['id' => $discoveryContact->uuid, 'interaction' => $record['uuid'] ]),

                ];

                array_push($items, $item);

            }

            $total_items = $paginator->getTotalItemCount();

            if($total_items <= 10) {

                $total_pages = 1;

            } else {

                $total_pages = (  $total_items / 10);

                if(($total_pages * 10) <  $total_items) {

                    $total_pages++;

                }

            }

            return new JsonModel([

                'success' => true,

                'data' => [

                    'current' => [

                        'items' => $items,

                        'page' => $paginator->getCurrentPageNumber()

                    ],

                    'total' => [

                        'items' => $total_items,

                        'pages' => $total_pages

                    ],

                ]

            ]);

        } else {

            return new JsonModel([

                'success' => false,

                'data' => 'ERROR_METHOD_NOT_ALLOWED'

            ]);;

        }

    }

    public function addAction()

    {

        $currentUserPlugin = $this->plugin('currentUserPlugin');

        $currentUser = $currentUserPlugin->getUser();

        $currentCompany = $currentUserPlugin->getCompany();

        $request = $this->getRequest();

        $uuid = $this->params()->fromRoute('id');

        if(!$uuid) {

            $data = [

                'success'   => false,

                'data'   => 'ERROR_INVALID_PARAMETER'

            ];

            return new JsonModel($data);

        }

        $discoveryContactMapper = DiscoveryContactMapper::getInstance($this->adapter);

        $discoveryContact = $discoveryContactMapper->fetchOneByUuid($uuid);

        if(!$discoveryContact) {

            $data = [

                'success'   => false,

                'data'   => 'ERROR_RECORD_NOT_FOUND'

            ];

            return new JsonModel($data);

        }

        if($discoveryContact->company_id != $currentCompany->id) {

            return new JsonModel([

                'success'   => false,

                'data'   => 'ERROR_UNAUTHORIZED'

            ]);

        }

        $request = $this->getRequest();

        if($request->isPost()) {

            $form = new InteractionForm($this->adapter, $currentCompany->id);

            $dataPost = $request->getPost()->toArray();

            $form->setData($dataPost);

            if($form->isValid()) {

                $dataPost = (array) $form->getData();

                $notes = $dataPost['notes'];

                $interaction_type_id = $dataPost['interaction_type_id'];

                $discoveryContactInteractionTypeMapper = DiscoveryContactInteractionTypeMapper::getInstance($this->adapter);

                $discoveryContactInteractionType = $discoveryContactInteractionTypeMapper->fetchOneByUuid($interaction_type_id);

                $discoveryContactInteraction = new DiscoveryContactInteraction();

                $discoveryContactInteraction->user_id = $currentUser->id;

                $discoveryContactInteraction->company_id  = $discoveryContact->company_id;

                $discoveryContactInteraction->contact_id  = $discoveryContact->id;

                $discoveryContactInteraction->interaction_type_id =  $discoveryContactInteractionType->id;

                $discoveryContactInteraction->notes = $notes;

                $discoveryContactInteractionMapper = DiscoveryContactInteractionMapper::getInstance($this->adapter);

                $result = $discoveryContactInteractionMapper->insert($discoveryContactInteraction);

                if($result) {

                    $this->logger->info('Se agrego la interacción del relevamiento de contacto : ' . $discoveryContact->first_name . ' ' . $discoveryContact->last_name . '(' . $discoveryContact->corporate_email . ')', ['user_id' => $currentUser->id, 'ip' => Functions::getUserIP()]);

                    $discoveryContactLog = new DiscoveryContactLog();

                    $discoveryContactLog->company_id    = $discoveryContact->company_id;

                    $discoveryContactLog->contact_id    = $discoveryContact->id;

                    $discoveryContactLog->user_id       = $currentUser->id;

                    $discoveryContactLog->activity      = 'LABEL_RECORD_INTERACTION_ADDED';

                    $discoveryContactLog->details       = 'LABEL_TYPE : ' . $discoveryContactInteractionType->name  . PHP_EOL .

                        'LABEL_NOTES : ' . $notes . PHP_EOL;

                    $discoveryContactLogMapper = DiscoveryContactLogMapper::getInstance($this->adapter);

                    $discoveryContactLogMapper->insert($discoveryContactLog);

                    $data = [

                        'success'   => true,

                        'data'   => 'LABEL_RECORD_ADDED'

                    ];

                } else {

                    $data = [

                        'success'   => false,

                        'data'      => $discoveryContactInteractionMapper->getError()

                    ];

                }

                return new JsonModel($data);

            } else {

                $messages = [];

                $form_messages = (array) $form->getMessages();

                foreach($form_messages  as $fieldname => $field_messages)

                {

                    $messages[$fieldname] = array_values($field_messages);

                }

                return new JsonModel([

                    'success'   => false,

                    'data'   => $messages

                ]);

            }

        } else {

            $data = [

                'success' => false,

                'data' => 'ERROR_METHOD_NOT_ALLOWED'

            ];

            return new JsonModel($data);

        }

        return new JsonModel($data);

    }

    public function deleteAction()

    {

        $currentUserPlugin = $this->plugin('currentUserPlugin');

        $currentUser = $currentUserPlugin->getUser();

        $currentCompany = $currentUserPlugin->getCompany();

        $request = $this->getRequest();

        $uuid = $this->params()->fromRoute('id');

        if(!$uuid) {

            $data = [

                'success'   => false,

                'data'   => 'ERROR_INVALID_PARAMETER'

            ];

            return new JsonModel($data);

        }

        $discoveryContactMapper = DiscoveryContactMapper::getInstance($this->adapter);

        $discoveryContact = $discoveryContactMapper->fetchOneByUuid($uuid);

        if(!$discoveryContact) {

            $data = [

                'success'   => false,

                'data'   => 'ERROR_RECORD_NOT_FOUND'

            ];

            return new JsonModel($data);

        }

        if($discoveryContact->company_id != $currentCompany->id) {

            return new JsonModel([

                'success'   => false,

                'data'   => 'ERROR_UNAUTHORIZED'

            ]);

        }

        $uuid = $this->params()->fromRoute('interaction');

        $discoveryContactInteractionMapper = DiscoveryContactInteractionMapper::getInstance($this->adapter);

        $discoveryContactInteraction = $discoveryContactInteractionMapper->fetchOneByUuid($uuid);

        if(!$discoveryContactInteraction) {

            $data = [

                'success'   => false,

                'data'   => 'ERROR_RECORD_NOT_FOUND'

            ];

            return new JsonModel($data);

        }

        if($discoveryContact->id != $discoveryContactInteraction->contact_id) {

            return new JsonModel([

                'success'   => false,

                'data'   => 'ERROR_UNAUTHORIZED'

            ]);

        }

        if($request->isPost()) {

            $discoveryContactInteractionTypeMapper = DiscoveryContactInteractionTypeMapper::getInstance($this->adapter);

            $discoveryContactInteractionType = $discoveryContactInteractionTypeMapper->fetchOne($discoveryContactInteraction->interaction_type_id);

            $result = $discoveryContactInteractionMapper->delete($discoveryContactInteraction);

            if($result) {

                $this->logger->info('Se borro la interacción del relevamiento de contacto ' . $discoveryContact->first_name . ' ' . $discoveryContact->last_name . '(' . $discoveryContact->corporate_email . ')', ['user_id' => $currentUser->id, 'ip' => Functions::getUserIP()]);

                $discoveryContactLog = new DiscoveryContactLog();

                $discoveryContactLog->company_id    = $discoveryContact->company_id;

                $discoveryContactLog->contact_id    = $discoveryContact->id;

                $discoveryContactLog->user_id       = $currentUser->id;

                $discoveryContactLog->activity      = 'LABEL_RECORD_INTERACTION_DELETED';

                $discoveryContactLog->details       = 'LABEL_TYPE : ' . $discoveryContactInteractionType->name  . PHP_EOL .

                'LABEL_NOTES : ' . $discoveryContactInteraction->notes . PHP_EOL;

                $discoveryContactLogMapper = DiscoveryContactLogMapper::getInstance($this->adapter);

                $discoveryContactLogMapper->insert($discoveryContactLog);

                $data = [

                    'success' => true,

                    'data' => 'LABEL_RECORD_DELETED'

                ];

            } else {

                $data = [

                    'success'   => false,

                    'data'      => $discoveryContactInteractionMapper->getError()

                ];

                return new JsonModel($data);

            }

        } else {

            $data = [

                'success' => false,

                'data' => 'ERROR_METHOD_NOT_ALLOWED'

            ];

            return new JsonModel($data);

        }

        return new JsonModel($data);

    }

}