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\QueryMapper;

use LeadersLinked\Mapper\EngagementMapper;

use LeadersLinked\Mapper\EngagementRecordMapper;

use LeadersLinked\Mapper\EngagementUserMapper;

use LeadersLinked\Mapper\DailyPulseEmojiMapper;

use LeadersLinked\Mapper\DailyPulseRecordMapper;

use LeadersLinked\Mapper\UserMapper;

use LeadersLinked\Model\DailyPulseRecord;

use LeadersLinked\Model\EngagementUser;

use LeadersLinked\Model\EngagementRecord;

use Laminas\Mvc\I18n\Translator;

use LeadersLinked\Cache\CacheInterface;

class DailyPulseSimulateCommand 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('Comenzamos a generar Daily Pulse de los últimos 30 días');

        $company_id = 1;

        $engagementMapper = EngagementMapper::getInstance($this->adapter);

        $engagement = $engagementMapper->fetchOneByCompanyId($company_id);

        $engagementRecordMapper = EngagementRecordMapper::getInstance($this->adapter);

        $engagementUserMapper = EngagementUserMapper::getInstance($this->adapter);

        $dailyPulseEmojiMapper = DailyPulseEmojiMapper::getInstance($this->adapter);

        $emojis_climate = $dailyPulseEmojiMapper->fetchAllActiveTypeClimateOnYourOrganizationByCompanyId($company_id);

        $max_emojis_climate = count($emojis_climate) - 1;

        $emojis_feel = $dailyPulseEmojiMapper->fetchAllActiveTypeHowAreYouFeelByCompanyId($company_id);

        $max_emojis_feel = count($emojis_feel) - 1;

        $dailyPulseRecordMapper = DailyPulseRecordMapper::getInstance($this->adapter);

        $endDate = date('Y-m-d');

        $startDate = date('Y-m-d', strtotime('-1 MONTH'));

        $seed = (int) (floor(time() / 86400));

        srand($seed);

        $min_users = 100;

        $max_users = 300;

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

        $output->writeln('$startDate = ' . $startDate);

        $output->writeln('$endDate = ' . $endDate);

        $dt = \DateTime::createFromFormat('Y-m-d', $startDate);

        do {

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

            $limit = rand($min_users, $max_users);

            $sql = " SELECT id FROM " . UserMapper::_TABLE;

            $sql .= " ORDER BY RAND() LIMIT $limit";

            $output->writeln('$sql = ' . $sql);

            $user_ids = [];

            $records = $queryMapper->fetchAllUsingParameters($sql);

            foreach ($records as $record) {

                array_push($user_ids, $record['id']);

            }

            $max = count($user_ids);

            for ($i = 0; $i < $max; $i ++) {

                $user_id = $user_ids[$i];

                $idx = rand(0, $max_emojis_feel);

                $emoji = $emojis_feel[$idx];

                $dailyPulse = new DailyPulseRecord();

                $dailyPulse->company_id = $company_id;

                $dailyPulse->user_id = $user_id;

                $dailyPulse->emoji_id = $emoji->id;

                $dailyPulse->date = $date;

                $dailyPulse->type = DailyPulseRecord::TYPE_HOW_ARE_YOU_FEEL;

                $dailyPulse->engagement = $engagement ? $engagement->daily_pulse_how_are_you_feel : 0;

                $dailyPulse->points = $emoji->points;

                $result = $dailyPulseRecordMapper->insert($dailyPulse);

                if ($result) {

                    $engagementUserMapper = EngagementUserMapper::getInstance($this->adapter);

                    $engagementUser = $engagementUserMapper->fetchOneByCompanyIdAndUserId($company_id, $user_id);

                    if ($engagementUser) {

                        $engagementUser->points = $engagementUser->points + ($engagement ? $engagement->daily_pulse_how_are_you_feel : 0);

                        $engagementUserMapper->update($engagementUser);

                    } else {

                        $engagementUser = new EngagementUser();

                        $engagementUser->company_id = $company_id;

                        $engagementUser->user_id = $user_id;

                        $engagementUser->points = $engagement ? $engagement->daily_pulse_how_are_you_feel : 0;

                        $engagementUserMapper->insert($engagementUser);

                    }

                    $engagementRecord = new EngagementRecord();

                    $engagementRecord->company_id = $company_id;

                    $engagementRecord->user_id = $user_id;

                    $engagementRecord->date = $date;

                    $engagementRecord->points = $engagement->daily_pulse_how_are_you_feel;

                    $engagementRecord->type = EngagementRecord::TYPE_DAILY_PULSE_HOW_ARE_YOU_FEEL;

                    $engagementRecordMapper = EngagementRecordMapper::getInstance($this->adapter);

                    $engagementRecordMapper->insert($engagementRecord);

                }

            }

            $percentaje = rand(20, 80);

            $max = (int) (($percentaje * 100) / $max);

            for ($i = 0; $i < $max; $i ++) {

                $user_id = $user_ids[$i];

                $idx = rand(0, $max_emojis_climate);

                $emoji = $emojis_climate[$idx];

                $dailyPulse = new DailyPulseRecord();

                $dailyPulse->company_id = $company_id;

                $dailyPulse->user_id = $user_id;

                $dailyPulse->emoji_id = $emoji->id;

                $dailyPulse->type = DailyPulseRecord::TYPE_CLIMATE_ON_YOUR_ORGANIZATION;

                $dailyPulse->date = $date;

                $dailyPulse->engagement = $engagement ? $engagement->daily_pulse_climate_on_your_organization : 0;

                $dailyPulse->points = $emoji->points;

                $result = $dailyPulseRecordMapper->insert($dailyPulse);

                if ($result) {

                    $engagementUserMapper = EngagementUserMapper::getInstance($this->adapter);

                    $engagementUser = $engagementUserMapper->fetchOneByCompanyIdAndUserId($company_id, $user_id);

                    if ($engagementUser) {

                        $engagementUser->points = $engagementUser->points + ($engagement ? $engagement->daily_pulse_climate_on_your_organization : 0);

                        $engagementUserMapper->update($engagementUser);

                    } else {

                        $engagementUser = new EngagementUser();

                        $engagementUser->company_id = $company_id;

                        $engagementUser->user_id = $user_id;

                        $engagementUser->points = $engagement ? $engagement->daily_pulse_climate_on_your_organization : 0;

                        $engagementUserMapper->insert($engagementUser);

                    }

                    $engagementRecord = new EngagementRecord();

                    $engagementRecord->company_id = $company_id;

                    $engagementRecord->user_id = $user_id;

                    $engagementRecord->date = $date;

                    $engagementRecord->points = $engagement->daily_pulse_climate_on_your_organization;

                    $engagementRecord->type = EngagementRecord::TYPE_DAILY_PULSE_CLIMATE_ON_YOUR_ORGANIZATION;

                    $engagementRecordMapper = EngagementRecordMapper::getInstance($this->adapter);

                    $engagementRecordMapper->insert($engagementRecord);

                }

            }

            $output->writeln('$percentaje = ' . $percentaje);

            $dt->add(new \DateInterval('P1D'));

        } while ($date < $endDate);

        $output->writeln('Terminamos a generar Daily Pulse de los últimos 30 días');

        return 0;

    }

}