OSSMailScanner_Verification_Cron

Complexity

Total Complexity

13

Size/Duplication

Total Lines	47
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

1 Method

Rating	Name	Duplication	Size	Complexity
C	process()	0	44	13

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

/**
 * OSSMailScanner_Verification_Cron class.
 */
class OSSMailScanner_Verification_Cron extends \App\CronHandler
{
	/** {@inheritdoc} */
	public function process()
	{
		$config = OSSMailScanner_Record_Model::getConfig('cron');
		$duration = $config['time'] ?? 0;
		$email = $config['email'] ?? '';
		$dbCommand = App\Db::getInstance()->createCommand();
		$dataReader = (new App\Db\Query())->from('vtiger_ossmails_logs')->where(['status' => 1])->createCommand()->query();
		while ($row = $dataReader->read()) {
			$startTime = strtotime($row['start_time']);
			if ($duration && $email
			&& strtotime('now') > $startTime + ($duration * 60)
			&& !(new \App\Db\Query())->from('vtiger_ossmailscanner_log_cron')->where(['laststart' => $startTime])->exists()) {
				$dbCommand->insert('vtiger_ossmailscanner_log_cron', ['laststart' => $startTime, 'status' => 0, 'created_time' => date('Y-m-d H:i:s')])->execute();
				$url = \App\Config::main('site_URL');
				$mailStatus = \App\Mailer::addMail([
					'to' => $email,
					'subject' => App\Language::translate('Email_FromName', 'OSSMailScanner'),
					'content' => App\Language::translate('Email_Body', 'OSSMailScanner') . "\r\n<br><a href='{$url}'>{$url}</a>",
				]);
				$dbCommand->update('vtiger_ossmailscanner_log_cron', ['status' => (int) $mailStatus], ['laststart' => $startTime])->execute();
			}
		}
		$dataReader->close();

		$hours = OSSMailScanner_Record_Model::getConfig('cron')['blockCheckHours'] ?? '';
		$hours = $hours ? explode(',', $hours) : [];
		$query = (new \App\Db\Query())->from('roundcube_users')->where(['crm_status' => \OSSMail_Record_Model::MAIL_BOX_STATUS_BLOCKED_TEMP]);
		$dataReader = $query->createCommand()->query();
		while ($account = $dataReader->read()) {
			if (empty($account['actions'])) {
				continue;
			}
			$check = true;
			if (!empty($account['failed_login'])) {
				$check = date('Y-m-d G', strtotime($account['failed_login'])) !== date('Y-m-d G');
				if ($hours && $check) {
					$check = \in_array(date('G'), $hours);
				}
			}
			if ($check) {
				\OSSMail_Record_Model::imapConnect($account['username'], \App\Encryption::getInstance()->decrypt($account['password']), $account['mail_host'], '', false, [], $account);
			}
		}
		$dataReader->close();
	}
}