Proyectos de Subversion LeadersLinked - Services

<?php

declare(strict_types = 1);

namespace LeadersLinked\Command;

use Symfony\Component\Console\Command\Command;

use Symfony\Component\Console\Input\InputInterface;

// use Symfony\Component\Console\Input\InputOption;

use Symfony\Component\Console\Output\OutputInterface;

use Laminas\Db\Adapter\AdapterInterface;

use Laminas\Log\LoggerInterface;

use LeadersLinked\Mapper\EmailMapper;

use PHPMailer\PHPMailer\PHPMailer;

use LeadersLinked\Model\Email;

use Laminas\Mvc\I18n\Translator;

use LeadersLinked\Cache\CacheInterface;

class ProcessScheduledContentCommand 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 configure(): void

    {

        $this->setName('leaderslinked:process-scheduled-content')

             ->setDescription('Procesa y libera el contenido programado de hábitos y habilidades')

             ->setHelp('Este comando verifica y procesa los hábitos programados para el día actual');

    }

    protected function execute(InputInterface $input, OutputInterface $output): int

    {

        $output->writeln('Iniciando proceso de liberación de contenido programado...');

        try {

            // Obtener el día de la semana actual (1 = lunes, 7 = domingo)

            $currentDayNumber = (int)date('N');

            $currentTime = date('H:i:s');

            // Mapear el número del día a la columna correspondiente

            $dayColumns = [

                1 => ['active' => 'monday_active', 'time' => 'monday_time'],

                2 => ['active' => 'tuesday_active', 'time' => 'tuesday_time'],

                3 => ['active' => 'wednesday_active', 'time' => 'wednesday_time'],

                4 => ['active' => 'thursday_active', 'time' => 'thursday_time'],

                5 => ['active' => 'friday_active', 'time' => 'friday_time'],

                6 => ['active' => 'saturday_active', 'time' => 'saturday_time'],

                7 => ['active' => 'sunday_active', 'time' => 'sunday_time']

            ];

            $currentDayColumns = $dayColumns[$currentDayNumber];

            // Obtener el mapper de hábitos

            $habitSkillMapper = \LeadersLinked\Mapper\HabitSkillMapper::getInstance($this->adapter);

            // Construir la consulta para obtener hábitos programados para hoy

            $select = $habitSkillMapper->getSql()->select(HabitSkillMapper::_TABLE);

            $select->where([

                $currentDayColumns['active'] => 1,

                $currentDayColumns['time'] . ' <= ?' => $currentTime

            ]);

            $habits = $habitSkillMapper->executeFetchAllObject($select, new \LeadersLinked\Model\HabitSkill());

            $processedCount = 0;

            foreach ($habits as $habit) {

                try {

                    // Crear un registro para el hábito

                    $register = new \LeadersLinked\Model\HabitSkillRegister();

                    $register->network_id = $habit->network_id;

                    $register->user_id = $habit->user_id;

                    $register->skill_id = $habit->id;

                    $register->date = date('Y-m-d');

                    $register->uuid = uniqid();

                    // Registrar el hábito

                    $registerMapper = \LeadersLinked\Mapper\HabitSkillRegisterMapper::getInstance($this->adapter);

                    if ($registerMapper->insert($register)) {

                        $processedCount++;

                        $this->logger->info(

                            sprintf('Hábito procesado: %s (Usuario: %d)', $habit->name, $habit->user_id),

                            ['habit_id' => $habit->id]

                        );

                    }

                } catch (\Exception $e) {

                    $this->logger->error(

                        sprintf('Error procesando hábito %d: %s', $habit->id, $e->getMessage()),

                        ['exception' => $e]

                    );

                }

            }

            $output->writeln(sprintf('Se procesaron %d hábitos programados', $processedCount));

            $output->writeln('Proceso de liberación de contenido programado completado con éxito');

            return Command::SUCCESS;

        } catch (\Exception $e) {

            $this->logger->error('Error en el proceso de contenido programado: ' . $e->getMessage());

            $output->writeln('<error>Error: ' . $e->getMessage() . '</error>');

            return Command::FAILURE;

        }

    }

}