Proyectos de Subversion LeadersLinked - Backend

<?php

declare(strict_types=1);

namespace LeadersLinked\Command;

use Symfony\Component\Console\Command\Command;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Output\OutputInterface;
use Laminas\Db\Adapter\AdapterInterface;

use Laminas\Log\LoggerInterface;
use GeoIp2\Database\Reader As GeoIp2Reader;
use LeadersLinked\Library\Functions;
use LeadersLinked\Mapper\CompanyServiceMapper;
use LeadersLinked\Mapper\DiscoveryContactInteractionTypeMapper;
use LeadersLinked\Model\Service;
use LeadersLinked\Model\DiscoveryContactInteractionType;
use LeadersLinked\Mapper\DiscoveryContactLogMapper;
use LeadersLinked\Mapper\DiscoveryContactMapper;
use LeadersLinked\Mapper\DiscoveryContactInteractionMapper;
use LeadersLinked\Model\DiscoveryContactLog;
use LeadersLinked\Hydrator\ObjectPropertyHydrator;

class CheckDiscoveryContactCommand extends Command
{
    /**
     *
     * @var \Laminas\Db\Adapter\AdapterInterface
     */
    private $adapter;
    
    /**
     *
     * @var \LeadersLinked\Cache\CacheInterface
     */
    private $cache;
    
    
    /**
     *
     * @var \Laminas\Log\LoggerInterface
     */
    private $logger;
    
    /**
     *
     * @var array
     */
    private $config;
    
    
    /**
     *
     * @var \Laminas\Mvc\I18n\Translator
     */
    private $translator;
    
    
    /**
     *
     * @param \Laminas\Db\Adapter\AdapterInterface $adapter
     * @param \LeadersLinked\Cache\CacheInterface $cache
     * @param \Laminas\Log\LoggerInterface
     * @param array $config
     * @param \Laminas\Mvc\I18n\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;
        
        parent::__construct();
    }

    
    protected function execute(InputInterface $input, OutputInterface $output) : int
    {
        $output->writeln('Inicio del proceso');
        
        
        $hydrator = new ObjectPropertyHydrator();
        
        $companyServiceMapper = CompanyServiceMapper::getInstance($this->adapter);
        $companiesService = $companyServiceMapper->fetchAllActiveByServiceId(Service::DISCOVERY_CONTACTS);
        
        $discoveryContactInteractionTypeMapper = DiscoveryContactInteractionTypeMapper::getInstance($this->adapter);

        $discoveryContactMapper = DiscoveryContactMapper::getInstance($this->adapter);
        $discoveryContactInteractionMapper = DiscoveryContactInteractionMapper::getInstance($this->adapter);
        $discoveryContactLogMapper = DiscoveryContactLogMapper::getInstance($this->adapter);
        
        foreach($companiesService as $companyService)
        {
            $discoveryContactInteractionTypeDefault = $discoveryContactInteractionTypeMapper->fetchOneDefaultByCompanyId($companyService->company_id);
            if(!$discoveryContactInteractionTypeDefault) {
                $discoveryContactInteractionTypeDefault = $discoveryContactInteractionTypeMapper->fetchOneFirstActiveByCompanyId($companyService->company_id);
                $discoveryContactInteractionTypeDefault->default = DiscoveryContactInteractionType::DEFAULT_YES;
                $discoveryContactInteractionTypeMapper->update($discoveryContactInteractionTypeDefault);
                
                
                
                
            }
            
            
            $discoveryContacts =  $discoveryContactMapper ->fetchAllByCompanyId($companyService->company_id);
            foreach($discoveryContacts as $discoveryContact)
            {
                $discoveryContactInteraction = $discoveryContactInteractionMapper->fetchByContactIdAndInteractionTypeId($discoveryContact->id, $discoveryContactInteractionTypeDefault->id);
                if($discoveryContactInteraction) {
                    $discoveryContactLog = $discoveryContactLogMapper->fetchOneFirstByContactId($discoveryContact->id);
                    if(!$discoveryContactLog) {
                        
                        
                        
                        $discoveryContactLog = new DiscoveryContactLog();
                        $discoveryContactLog->company_id = $discoveryContactInteraction->company_id;
                        $discoveryContactLog->contact_id = $discoveryContact->id;
                        $discoveryContactLog->user_id = $discoveryContactInteraction->user_id;
                        $discoveryContactLog->activity =  'LABEL_RECORD_CONTACT_ADDED';
                        $discoveryContactLog->details = 'LABEL_FIRST_NAME : ' . $discoveryContact->first_name  . PHP_EOL .
                        'LABEL_LAST_NAME : ' . $discoveryContact->last_name  . PHP_EOL .
                        'LABEL_CORPORATE_EMAIL : ' . $discoveryContact->corporate_email  . PHP_EOL .
                        'LABEL_COMPANY : ' . $discoveryContact->company  . PHP_EOL .
                        'LABEL_POSITION : ' . $discoveryContact->position  . PHP_EOL .
                        'LABEL_COUNTRY : ' . $discoveryContact->country  . PHP_EOL;
                        
                        
                        if ($discoveryContact->state) {
                            $discoveryContactLog->details .= 'LABEL_STATE : ' . $discoveryContact->state  . PHP_EOL;
                        }
                        if ($discoveryContact->city) {
                            $discoveryContactLog->details .= 'LABEL_CITY : ' . $discoveryContact->city  . PHP_EOL;
                        }
                        if ($discoveryContact->phone) {
                            $discoveryContactLog->details .= 'LABEL_PHONE : ' . $discoveryContact->phone  . PHP_EOL;
                        }
                        if ($discoveryContact->phone_extension) {
                            $discoveryContactLog->details .= 'LABEL_PHONE_EXTENSION : ' . $discoveryContact->phone_extension  . PHP_EOL;
                        }
                        if ($discoveryContact->personal_email) {
                            $discoveryContactLog->details .= 'LABEL_PERSONAL_EMAIL : ' . $discoveryContact->personal_email  . PHP_EOL;
                        }
                        if ($discoveryContact->celular) {
                            $discoveryContactLog->details .= 'LABEL_CELULAR : ' . $discoveryContact->celular  . PHP_EOL;
                        }
                        if ($discoveryContact->whatsapp) {
                            $discoveryContactLog->details .= 'LABEL_WHATSAPP : ' . $discoveryContact->whatsapp  . PHP_EOL;
                        }
                        if ($discoveryContact->linkedin) {
                            $discoveryContactLog->details .= 'LABEL_LINKEDIN : ' . $discoveryContact->linkedin  . PHP_EOL;
                        }
                        
                        $values = $hydrator->extract($discoveryContactLog);
                        $values['added_on'] = $discoveryContactInteraction->added_on;
                        
                        
                        $discoveryContactLogMapper->insertRaw($values);
                        
                    }
                    
                } else {
                    $discoveryContactLog = $discoveryContactLogMapper->fetchOneFirstByContactId($discoveryContact->id);
                    if($discoveryContactLog) {
                        $values = [
                            'company_id' => $discoveryContact->company_id,
                            'contact_id' => $discoveryContact->id,
                            'user_id' => $discoveryContactLog->user_id,
                            'interaction_type_id' => $discoveryContactInteractionTypeDefault->id,
                            'notes' => '',
                            'added_on' => $discoveryContactLog->added_on
                        ] ;
                        
                        
                        $discoveryContactInteractionMapper->insertRaw($values);
                    }
                    
                    
                } 
                
                
            }
            
            
            
            
            
        }
        
        



        $output->writeln('Fin del proceso');
        
        return 0;
    }
    
    
    
}