YetiForceCompany/YetiForceCRM

<?php
/**
 * Cron for scheduled import.
 *
 * @package   App
 *
 * @copyright YetiForce S.A.
 * @license   YetiForce Public License 6.5 (licenses/LicenseEN.txt or yetiforce.com)
 * @author    Tomasz Kur <t.kur@yetiforce.com>
 */

/**
 * OSSMailScanner_Bind_Cron class.
 */
class OSSMailScanner_Bind_Cron extends \App\CronHandler
{
    /** {@inheritdoc} */
    public function process()
    {
        $dbCommand = App\Db::getInstance()->createCommand();
        $scannerModel = Vtiger_Record_Model::getCleanInstance('OSSMailScanner');
        $dataReader = (new App\Db\Query())->select([
            'vtiger_ossmailview.*',
            'roundcube_users.actions',
        ])->from('vtiger_ossmailview')
            ->innerJoin('roundcube_users', 'roundcube_users.user_id = vtiger_ossmailview.rc_user')->where(['vtiger_ossmailview.verify' => 1])
            ->createCommand()->query();

        while ($row = $dataReader->read()) {
            $scannerModel->bindMail($row);
            $dbCommand->update('vtiger_ossmailview', ['verify' => 0], ['ossmailviewid' => $row['ossmailviewid']])->execute();
        }
        $dataReader->close();
        $dataReader = (new App\Db\Query())->from('s_#__mail_relation_updater')->createCommand()->query();
        $bindByEmail = ['Leads', 'Accounts', 'Partners', 'Vendors', 'Competition', 'Contacts', 'OSSEmployees'];
        $bindByPrefix = ['Campaigns', 'HelpDesk', 'Project', 'SSalesProcesses'];
        while ($relationRow = $dataReader->read()) {
            $dbCommand->delete('vtiger_ossmailview_relation', ['crmid' => $relationRow['crmid']])->execute();
            $moduleName = \App\Module::getModuleName($relationRow['tabid']);
            $bind = false;
            if (\in_array($moduleName, $bindByEmail)) {
                $bind = 'email';
            }
            if (\in_array($moduleName, $bindByPrefix)) {
                $bind = 'prefix';
            }
            if (false === $bind) {
                continue;
            }
            $recordModel = Vtiger_Record_Model::getInstanceById($relationRow['crmid'], $moduleName);
            $where = [];
            if ('prefix' == $bind) {
                $recordNumber = $recordModel->getRecordNumber();
                if (empty($recordNumber)) {
                    continue;
                }
                $where = ['like', 'vtiger_ossmailview.subject', "[{$recordNumber}]"];
            } elseif ('email' == $bind) {
                $where = ['or'];
                $fieldModels = $recordModel->getModule()->getFieldsByType('email');
                foreach ($fieldModels as $fieldName => $fieldModel) {
                    if (!$recordModel->isEmpty($fieldName)) {
                        $email = $recordModel->get($fieldName);
                        $where[] = ['from_email' => $email];
                        $where[] = ['to_email' => $email];
                        $where[] = ['cc_email' => $email];
                        $where[] = ['bcc_email' => $email];
                    }
                }
            }
            if (!empty($where) && $where !== ['or']) {
                $dataReaderMail = (new App\Db\Query())->select(['vtiger_ossmailview.*', 'roundcube_users.actions'])
                    ->from('vtiger_ossmailview')
                    ->innerJoin('roundcube_users', 'roundcube_users.user_id = vtiger_ossmailview.rc_user')
                    ->where($where)->createCommand()->query();
                while ($row = $dataReaderMail->read()) {
                    $scannerModel->bindMail($row);
                }
                $dataReaderMail->close();
            }
            $dbCommand->delete('s_#__mail_relation_updater', ['crmid' => $relationRow['crmid']])->execute();
            if ($this->checkTimeout()) {
                break;
            }
        }
        $dataReader->close();
    }
}