OSSMailScanner_Bind_Cron::process()

Complexity

Conditions	15
Paths	114

Size

Total Lines	69
Code Lines	54

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	0

<?php
	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);

The method bindMail() does not exist on Vtiger_Record_Model. It seems like you code against a sub-type of Vtiger_Record_Model such as OSSMailScanner_Record_Model.

			$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();
	}