Файловый менеджер

Файловый менеджер - Редактировать - /var/www/axolotl/data/www/axolotls.ru/www/bitrix/modules/main/classes/general/event.php

Назад
<?php /** * Bitrix Framework * @package bitrix * @subpackage main * @copyright 2001-2013 Bitrix / use Bitrix\Main\Mail; use Bitrix\Main\Mail\Internal\EventTypeTable; IncludeModuleLangFile(__FILE__); global $BX_EVENT_SITE_PARAMS; $BX_EVENT_SITE_PARAMS = array(); class CAllEvent { public static function CheckEvents() { return Mail\EventManager::checkEvents(); } public static function ExecuteEvents() { return Mail\EventManager::executeEvents(); } public static function CleanUpAgent() { return Mail\EventManager::cleanUpAgent(); } public static function SendImmediate($event, $lid, $arFields, $Duplicate = "Y", $message_id="", $files=array(), $languageId = '') { foreach(GetModuleEvents("main", "OnBeforeEventAdd", true) as $arEvent) if(ExecuteModuleEventEx($arEvent, array(&$event, &$lid, &$arFields, &$message_id, &$files, &$languageId)) === false) return false; if(!is_array($arFields)) { $arFields = array(); } $arLocalFields = array( "EVENT_NAME" => $event, "C_FIELDS" => $arFields, "LID" => (is_array($lid)? implode(",", $lid) : $lid), "DUPLICATE" => ($Duplicate != "N"? "Y" : "N"), "MESSAGE_ID" => (intval($message_id) > 0? intval($message_id): ""), "DATE_INSERT" => GetTime(time(), "FULL"), "FILE" => $files, "LANGUAGE_ID" => ($languageId == ''? LANGUAGE_ID : $languageId), "ID" => "0", ); return Mail\Event::sendImmediate($arLocalFields); } public static function Send($event, $lid, $arFields, $Duplicate = "Y", $message_id="", $files=array(), $languageId = '') { foreach(GetModuleEvents("main", "OnBeforeEventAdd", true) as $arEvent) if(ExecuteModuleEventEx($arEvent, array(&$event, &$lid, &$arFields, &$message_id, &$files, &$languageId)) === false) return false; $arLocalFields = array( "EVENT_NAME" => $event, "C_FIELDS" => $arFields, "LID" => (is_array($lid)? implode(",", $lid) : $lid), "DUPLICATE" => ($Duplicate != "N"? "Y" : "N"), "FILE" => $files, "LANGUAGE_ID" => ($languageId == ''? LANGUAGE_ID : $languageId), ); if(intval($message_id) > 0) $arLocalFields["MESSAGE_ID"] = intval($message_id); $result = Mail\Event::send($arLocalFields); $id = false; if ($result->isSuccess()) { $id = $result->getId(); } return $id; } public static function fieldencode($s) { if(is_array($s)) { $ret_val = ''; foreach($s as $v) $ret_val .= ($ret_val <> ''? ', ':'').CEvent::fieldencode($v); } else { $ret_val = str_replace("%", "%2", $s); $ret_val = str_replace("&","%1", $ret_val); $ret_val = str_replace("=", "%3", $ret_val); } return $ret_val; } public static function ExtractMailFields($str) { $ar = explode("&", $str); $newar = array(); while (list (, $val) = each ($ar)) { $val = str_replace("%1", "&", $val); $tar = explode("=", $val); $key = $tar[0]; $val = $tar[1]; $key = str_replace("%3", "=", $key); $val = str_replace("%3", "=", $val); $key = str_replace("%2", "%", $key); $val = str_replace("%2", "%", $val); if($key != "") $newar[$key] = $val; } return $newar; } public static function GetSiteFieldsArray($site_id) { global $BX_EVENT_SITE_PARAMS; if($site_id !== false && isset($BX_EVENT_SITE_PARAMS[$site_id])) return $BX_EVENT_SITE_PARAMS[$site_id]; $SITE_NAME = COption::GetOptionString("main", "site_name", $GLOBALS["SERVER_NAME"]); $SERVER_NAME = COption::GetOptionString("main", "server_name", $GLOBALS["SERVER_NAME"]); $DEFAULT_EMAIL_FROM = COption::GetOptionString("main", "email_from", "admin@".$GLOBALS["SERVER_NAME"]); if(strlen($site_id)>0) { $dbSite = CSite::GetByID($site_id); if($arSite = $dbSite->Fetch()) { $BX_EVENT_SITE_PARAMS[$site_id] = array( "SITE_NAME" => ($arSite["SITE_NAME"]<>''? $arSite["SITE_NAME"] : $SITE_NAME), "SERVER_NAME" => ($arSite["SERVER_NAME"]<>''? $arSite["SERVER_NAME"] : $SERVER_NAME), "DEFAULT_EMAIL_FROM" => ($arSite["EMAIL"]<>''? $arSite["EMAIL"] : $DEFAULT_EMAIL_FROM), "SITE_ID" => $arSite['ID'], "SITE_DIR" => $arSite['DIR'], ); return $BX_EVENT_SITE_PARAMS[$site_id]; } } return array( "SITE_NAME" => $SITE_NAME, "SERVER_NAME" => $SERVER_NAME, "DEFAULT_EMAIL_FROM" => $DEFAULT_EMAIL_FROM ); } public static function ReplaceTemplate($str, $ar, $bNewLineToBreak=false) { $str = str_replace("%", "%2", $str); foreach($ar as $key=>$val) { if($bNewLineToBreak && strpos($val, "<") === false) $val = nl2br($val); $val = str_replace("%", "%2", $val); $val = str_replace("#", "%1", $val); $str = str_replace("#".$key."#", $val, $str); } $str = str_replace("%1", "#", $str); $str = str_replace("%2", "%", $str); return $str; } /* * @deprecated See \Bitrix\Main\Mail\Mail::is8Bit() / public static function Is8Bit($str) { return Mail\Mail::is8Bit($str); } /* * @deprecated See \Bitrix\Main\Mail\Mail::encodeMimeString() / public static function EncodeMimeString($text, $charset) { return Mail\Mail::encodeMimeString($text, $charset); } /* * @deprecated See \Bitrix\Mail\Mail::encodeSubject() / public static function EncodeSubject($text, $charset) { return Mail\Mail::encodeSubject($text, $charset); } /* * @deprecated See \Bitrix\Main\Mail\Mail::encodeHeaderFrom() / public static function EncodeHeaderFrom($text, $charset) { return Mail\Mail::encodeHeaderFrom($text, $charset); } /* * @deprecated See \Bitrix\Main\Mail\Mail::getMailEol() / public static function GetMailEOL() { return Mail\Mail::getMailEol(); } /* * @deprecated See \Bitrix\Main\Mail\Event::handleEvent() / public static function HandleEvent($arEvent) { if(isset($arEvent['C_FIELDS'])) { $arEvent['FIELDS'] = $arEvent['C_FIELDS']; unset($arEvent['C_FIELDS']); } return Mail\Event::handleEvent($arEvent); } } class CAllEventMessage { var $LAST_ERROR; public function CheckFields($arFields, $ID=false) { /* @global CMain $APPLICATION / global $APPLICATION; $this->LAST_ERROR = ""; $arMsg = array(); if(is_set($arFields, "EMAIL_FROM") && strlen($arFields["EMAIL_FROM"])<3) { $this->LAST_ERROR .= GetMessage("BAD_EMAIL_FROM")."<br>"; $arMsg[] = array("id"=>"EMAIL_FROM", "text"=> GetMessage("BAD_EMAIL_FROM")); } if(is_set($arFields, "EMAIL_TO") && strlen($arFields["EMAIL_TO"])<3) { $this->LAST_ERROR .= GetMessage("BAD_EMAIL_TO")."<br>"; $arMsg[] = array("id"=>"EMAIL_TO", "text"=> GetMessage("BAD_EMAIL_TO")); } if($ID===false && !is_set($arFields, "EVENT_NAME")) { $this->LAST_ERROR .= GetMessage("MAIN_BAD_EVENT_NAME_NA")."<br>"; $arMsg[] = array("id"=>"EVENT_NAME", "text"=> GetMessage("MAIN_BAD_EVENT_NAME_NA")); } if(is_set($arFields, "EVENT_NAME")) { $r = CEventType::GetListEx(array(), array("EVENT_NAME"=>$arFields["EVENT_NAME"]), array("type"=>"none")); if(!$r->Fetch()) { $this->LAST_ERROR .= GetMessage("BAD_EVENT_TYPE")."<br>"; $arMsg[] = array("id"=>"EVENT_NAME", "text"=> GetMessage("BAD_EVENT_TYPE")); } } if( ($ID===false && !is_set($arFields, "LID")) \|\| (is_set($arFields, "LID") && ( (is_array($arFields["LID"]) && count($arFields["LID"])<=0) \|\| (!is_array($arFields["LID"]) && strlen($arFields["LID"])<=0) ) ) ) { $this->LAST_ERROR .= GetMessage("MAIN_BAD_SITE_NA")."<br>"; $arMsg[] = array("id"=>"LID", "text"=> GetMessage("MAIN_BAD_SITE_NA")); } elseif(is_set($arFields, "LID")) { if(!is_array($arFields["LID"])) $arFields["LID"] = array($arFields["LID"]); foreach($arFields["LID"] as $v) { $r = CSite::GetByID($v); if(!$r->Fetch()) { $this->LAST_ERROR .= "'".$v."' - ".GetMessage("MAIN_EVENT_BAD_SITE")."<br>"; $arMsg[] = array("id"=>"LID", "text"=> GetMessage("MAIN_EVENT_BAD_SITE")); } } } if(!empty($arMsg)) { $e = new CAdminException($arMsg); $APPLICATION->ThrowException($e); } if(strlen($this->LAST_ERROR)>0) return false; return true; } /////////////////////////////////////////////////////////////////// // New event message template /////////////////////////////////////////////////////////////////// public function Add($arFields) { unset($arFields["ID"]); if(!$this->CheckFields($arFields)) return false; if(is_set($arFields, "ACTIVE") && $arFields["ACTIVE"]!="Y") $arFields["ACTIVE"]="N"; $arLID = array(); if(is_set($arFields, "LID")) { if(is_array($arFields["LID"])) $arLID = $arFields["LID"]; else $arLID[] = $arFields["LID"]; $arFields["LID"] = false; foreach($arLID as $v) { $arFields["LID"] = $v; } } $arATTACHMENT_FILE = array(); if(is_set($arFields, "ATTACHMENT_FILE")) { if(is_array($arFields["ATTACHMENT_FILE"])) $arATTACHMENT_FILE = $arFields["ATTACHMENT_FILE"]; else $arATTACHMENT_FILE[] = $arFields["ATTACHMENT_FILE"]; $arATTACHMENT_FILE_tmp = array(); foreach($arATTACHMENT_FILE as $v) { $v = intval($v); $arATTACHMENT_FILE_tmp[] = $v; } $arATTACHMENT_FILE = $arATTACHMENT_FILE_tmp; unset($arFields['ATTACHMENT_FILE']); } $arDeleteFields = array( 'EVENT_MESSAGE_TYPE_ID', 'EVENT_MESSAGE_TYPE_ID', 'EVENT_MESSAGE_TYPE_NAME', 'EVENT_MESSAGE_TYPE_EVENT_NAME', 'SITE_ID', 'EVENT_TYPE' ); foreach($arDeleteFields as $deleteField) if(array_key_exists($deleteField, $arFields)) unset($arFields[$deleteField]); $ID = false; $result = Mail\Internal\EventMessageTable::add($arFields); if ($result->isSuccess()) { $ID = $result->getId(); if(count($arLID)>0) { Mail\Internal\EventMessageSiteTable::delete($ID); $resultDb = \Bitrix\Main\SiteTable::getList(array( 'select' => array('LID'), 'filter' => array('=LID' => $arLID), )); while($arResultSite = $resultDb->fetch()) { Mail\Internal\EventMessageSiteTable::add(array( 'EVENT_MESSAGE_ID' => $ID, 'SITE_ID' => $arResultSite['LID'], )); } } if(count($arATTACHMENT_FILE)>0) { foreach($arATTACHMENT_FILE as $file_id) { Mail\Internal\EventMessageAttachmentTable::add(array( 'EVENT_MESSAGE_ID' => $ID, 'FILE_ID' => $file_id, )); } } } return $ID; } public function Update($ID, $arFields) { global $DB; if(!$this->CheckFields($arFields, $ID)) return false; if(is_set($arFields, "ACTIVE") && $arFields["ACTIVE"]!="Y") $arFields["ACTIVE"]="N"; $arLID = array(); if(is_set($arFields, "LID")) { if(is_array($arFields["LID"])) $arLID = $arFields["LID"]; else $arLID[] = $arFields["LID"]; $arFields["LID"] = false; foreach($arLID as $v) { $arFields["LID"] = $v; } } $arATTACHMENT_FILE = array(); if(is_set($arFields, "ATTACHMENT_FILE")) { if(is_array($arFields["ATTACHMENT_FILE"])) $arATTACHMENT_FILE = $arFields["ATTACHMENT_FILE"]; else $arATTACHMENT_FILE[] = $arFields["ATTACHMENT_FILE"]; $arATTACHMENT_FILE_tmp = array(); foreach($arATTACHMENT_FILE as $v) { $v = intval($v); $arATTACHMENT_FILE_tmp[] = $v; } $arATTACHMENT_FILE = $arATTACHMENT_FILE_tmp; unset($arFields['ATTACHMENT_FILE']); } if(array_key_exists('NAME', $arFields)) unset($arFields['NAME']); $ID = intval($ID); Mail\Internal\EventMessageTable::update($ID, $arFields); if(count($arLID)>0) { Mail\Internal\EventMessageSiteTable::delete($ID); $resultDb = \Bitrix\Main\SiteTable::getList(array( 'select' => array('LID'), 'filter' => array('=LID' => $arLID), )); while($arResultSite = $resultDb->fetch()) { Mail\Internal\EventMessageSiteTable::add(array( 'EVENT_MESSAGE_ID' => $ID, 'SITE_ID' => $arResultSite['LID'], )); } } if(count($arATTACHMENT_FILE)>0) { foreach($arATTACHMENT_FILE as $file_id) { Mail\Internal\EventMessageAttachmentTable::add(array( 'EVENT_MESSAGE_ID' => $ID, 'FILE_ID' => $file_id, )); } } return true; } /////////////////////////////////////////////////////////////////// // Query /////////////////////////////////////////////////////////////////// public static function GetByID($ID) { return CEventMessage::GetList($o = "", $b = "", array("ID"=>$ID)); } public static function GetSite($event_message_id) { $event_message_id = intval($event_message_id); $resultDb = Mail\Internal\EventMessageSiteTable::getList(array( 'select' => array('', ''=> 'SITE.'), 'filter' => array('=EVENT_MESSAGE_ID' => $event_message_id), 'runtime' => array( 'SITE' => array( 'data_type' => 'Bitrix\Main\Site', 'reference' => array('=this.SITE_ID' => 'ref.LID'), ) ) )); return new CDBResult($resultDb); } public static function GetLang($event_message_id) { return CEventMessage::GetSite($event_message_id); } public static function Delete($ID) { /* * @global CMain $APPLICATION * @global CDatabase $DB / global $APPLICATION; $ID = Intval($ID); foreach(GetModuleEvents("main", "OnBeforeEventMessageDelete", true) as $arEvent) { if(ExecuteModuleEventEx($arEvent, array($ID))===false) { $err = GetMessage("MAIN_BEFORE_DEL_ERR").' '.$arEvent['TO_NAME']; if($ex = $APPLICATION->GetException()) $err .= ': '.$ex->GetString(); $APPLICATION->throwException($err); return false; } } @set_time_limit(600); //check module event for OnDelete foreach(GetModuleEvents("main", "OnEventMessageDelete", true) as $arEvent) ExecuteModuleEventEx($arEvent, array($ID)); Mail\Internal\EventMessageSiteTable::delete($ID); $result = Mail\Internal\EventMessageTable::delete($ID); if($result->isSuccess()) { $res = new CDBResultEventMultiResult(); $res->affectedRowsCount = 1; } else { $res = false; } return $res; } public static function GetListDataModifier($data) { if(!isset($data['EVENT_MESSAGE_TYPE_ID']) \|\| intval($data['EVENT_MESSAGE_TYPE_ID'])<=0) { $data['EVENT_TYPE'] = $data['EVENT_NAME']; } else { $data['EVENT_TYPE'] = '[ '.$data['EVENT_MESSAGE_TYPE_EVENT_NAME'].' ] '.$data['EVENT_MESSAGE_TYPE_NAME']; unset($data['EVENT_MESSAGE_TYPE_ID']); unset($data['EVENT_MESSAGE_TYPE_NAME']); unset($data['EVENT_MESSAGE_TYPE_EVENT_NAME']); } if (!empty($data['ADDITIONAL_FIELD']) && is_array($data['ADDITIONAL_FIELD'])) { foreach ($data['ADDITIONAL_FIELD'] as $index => $aField) { $index++; $oldKeyName = "FIELD{$index}_NAME"; $oldKeyValue = "FIELD{$index}_VALUE"; if (!array_key_exists($oldKeyName, $data)) { continue; } if (!empty($data[$oldKeyName])) { continue; } $data[$oldKeyName] = $aField['NAME']; $data[$oldKeyValue] = $aField['VALUE']; } } return $data; } public static function GetList(&$by, &$order, $arFilter=Array()) { $arSearch = Array(); $arSqlSearch = Array(); $strSqlSearch = ""; $bIsLang = false; if (is_array($arFilter)) { foreach ($arFilter as $key => $val) { if(is_array($val)) { if(count($val) <= 0) continue; } else { if( (strlen($val) <= 0) \|\| ($val === "NOT_REF") ) continue; } $match_value_set = array_key_exists($key."_EXACT_MATCH", $arFilter); $key = strtoupper($key); switch($key) { case "ID": $match = ($arFilter[$key."_EXACT_MATCH"]=="N" && $match_value_set) ? "Y" : "N"; if($match == 'Y') $val = '%'.$val.'%'; $arSearch['%='.$key] = $val; break; case "TYPE": $match = ($arFilter[$key."_EXACT_MATCH"]=="Y" && $match_value_set) ? "N" : "Y"; if($match == 'Y') $val = '%'.$val.'%'; $arSearch[] = array('LOGIC' => 'OR', 'EVENT_NAME' => $val, 'EVENT_MESSAGE_TYPE.NAME' => $val); break; case "EVENT_NAME": case "TYPE_ID": $match = ($arFilter[$key."_EXACT_MATCH"]=="N" && $match_value_set) ? "Y" : "N"; if($match == 'Y') $val = '%'.$val.'%'; $arSearch['%=EVENT_NAME'] = $val; break; case "TIMESTAMP_1": $arSqlSearch[] = "M.TIMESTAMP_X>=TO_DATE('".FmtDate($val, "D.M.Y")." 00:00:00','dd.mm.yyyy hh24:mi:ss')"; $arSearch['>=TIMESTAMP_X'] = $val." 00:00:00"; break; case "TIMESTAMP_2": $arSqlSearch[] = "M.TIMESTAMP_X<=TO_DATE('".FmtDate($val, "D.M.Y")." 23:59:59','dd.mm.yyyy hh24:mi:ss')"; $arSearch['<=TIMESTAMP_X'] = $val." 23:59:59"; break; case "LID": case "LANG": case "SITE_ID": $bIsLang = true; $arSearch["=SITE_ID"] = $val; break; case "LANGUAGE_ID": $arSearch["=LANGUAGE_ID"] = $val; break; case "ACTIVE": $arSearch['='.$key] = $val; break; case "FROM": $match = ($arFilter[$key."_EXACT_MATCH"]=="Y" && $match_value_set) ? "N" : "Y"; if($match == 'Y') $val = '%'.$val.'%'; $arSearch['%=EMAIL_FROM'] = $val; break; case "TO": $match = ($arFilter[$key."_EXACT_MATCH"]=="Y" && $match_value_set) ? "N" : "Y"; if($match == 'Y') $val = '%'.$val.'%'; $arSearch['%=EMAIL_TO'] = $val; break; case "BCC": $match = ($arFilter[$key."_EXACT_MATCH"]=="Y" && $match_value_set) ? "N" : "Y"; if($match == 'Y') $val = '%'.$val.'%'; $arSearch['%='.$key] = $val; break; case "SUBJECT": $match = ($arFilter[$key."_EXACT_MATCH"]=="Y" && $match_value_set) ? "N" : "Y"; if($match == 'Y') $val = '%'.$val.'%'; $arSearch['%='.$key] = $val; break; case "BODY_TYPE": $arSearch[$key] = ($val=="text") ? 'text' : 'html'; break; case "BODY": $match = ($arFilter[$key."_EXACT_MATCH"]=="Y" && $match_value_set) ? "N" : "Y"; if($match == 'Y') $val = '%'.$val.'%'; $arSearch['%=MESSAGE'] = $val; break; } } } if ($by == "id") $strSqlOrder = "ID"; elseif ($by == "active") $strSqlOrder = "ACTIVE"; elseif ($by == "event_name") $strSqlOrder = "EVENT_NAME"; elseif ($by == "from") $strSqlOrder = "EMAIL_FROM"; elseif ($by == "to") $strSqlOrder = "EMAIL_TO"; elseif ($by == "bcc") $strSqlOrder = "BCC"; elseif ($by == "body_type") $strSqlOrder = "BODY_TYPE"; elseif ($by == "subject") $strSqlOrder = "SUBJECT"; elseif ($by == "language_id") $strSqlOrder = "LANGUAGE_ID"; else { $strSqlOrder = "ID"; $by = "id"; } if ($order!="asc") { $strSqlOrderBy = "DESC"; $order = "desc"; } else { $strSqlOrderBy = "ASC"; $order = "asc"; } $arSelect = array( '', 'EVENT_MESSAGE_TYPE_ID' => 'EVENT_MESSAGE_TYPE.ID', 'EVENT_MESSAGE_TYPE_NAME' => 'EVENT_MESSAGE_TYPE.NAME', 'EVENT_MESSAGE_TYPE_EVENT_NAME' => 'EVENT_MESSAGE_TYPE.EVENT_NAME', ); if($bIsLang) { $arSelect['SITE_ID'] = 'EVENT_MESSAGE_SITE.SITE_ID'; } else { $arSelect['SITE_ID'] = 'LID'; } $resultDb = Mail\Internal\EventMessageTable::getList(array( 'select' => $arSelect, 'filter' => $arSearch, 'order' => array($strSqlOrder => $strSqlOrderBy), 'runtime' => array( 'EVENT_MESSAGE_TYPE' => array( 'data_type' => 'Bitrix\Main\Mail\Internal\EventType', 'reference' => array('=this.EVENT_NAME' => 'ref.EVENT_NAME', '=ref.LID' => new \Bitrix\Main\DB\SqlExpression('?', LANGUAGE_ID)), ), ) )); $resultDb->addFetchDataModifier(array('CEventMessage', 'GetListDataModifier')); $res = new CDBResult($resultDb); $strSqlSearch = GetFilterSqlSearch($arSqlSearch); $res->is_filtered = (IsFiltered($strSqlSearch)); return $res; } } class CEventType { public static function CheckFields($arFields = array(), $action = "ADD", $ID = array()) { /** @global CMain $APPLICATION */ global $APPLICATION; $arFilter = array(); $aMsg = array(); //ID, LID, EVENT_NAME, NAME, DESCRIPTION, SORT if ($action == "ADD") { if (empty($arFields["EVENT_NAME"])) $aMsg[] = array("id"=>"EVENT_NAME_EMPTY", "text"=>GetMessage("EVENT_NAME_EMPTY")); if(!is_set($arFields, "LID") && is_set($arFields, "SITE_ID")) $arFields["LID"] = $arFields["SITE_ID"]; if (is_set($arFields, "LID") && empty($arFields["LID"])) $aMsg[] = array("id"=>"LID_EMPTY", "text"=>GetMessage("LID_EMPTY")); if (empty($aMsg)) { $db_res = CEventType::GetList(array("LID" => $arFields["LID"], "EVENT_NAME" => $arFields["EVENT_NAME"])); if ($db_res && $db_res->Fetch()) { $aMsg[] = array("id"=>"EVENT_NAME_EXIST", "text"=>str_replace( array("#SITE_ID#", "#EVENT_NAME#"), array($arFields["LID"], $arFields["EVENT_NAME"]), GetMessage("EVENT_NAME_EXIST"))); } } } elseif ($action == "UPDATE") { if (empty($ID) && (empty($ID["ID"]) \|\| (empty($ID["EVENT_NAME"])))) { if (empty($ID)) $aMsg[] = array("id"=>"EVENT_ID_EMPTY", "text"=>GetMessage("EVENT_ID_EMPTY")); else $aMsg[] = array("id"=>"EVENT_NAME_LID_EMPTY", "text"=>GetMessage("EVENT_ID_EMPTY")); } if(isset($arFields["EVENT_TYPE"]) && $arFields["EVENT_TYPE"] == '') { $aMsg[] = array("id"=>"EVENT_TYPE_EMPTY", "text"=>GetMessage('EVENT_TYPE_EMPTY')); } if (empty($aMsg) && is_set($arFields, "EVENT_NAME") && (is_set($arFields, "LID"))) { if (is_set($arFields, "EVENT_NAME")) $arFilter["EVENT_NAME"] = $arFields["EVENT_NAME"]; if (is_set($arFields, "LID")) $arFilter["LID"] = $arFields["LID"]; if (!empty($arFilter) && (count($arFilter) < 2) && is_set($arFilter, "LID")) { unset($arFields["LID"]); } else { $db_res = CEventType::GetList($arFilter); if ($db_res && ($res = $db_res->Fetch())) { if (($action == "UPDATE") && ((is_set($ID, "EVENT_NAME") && is_set($ID, "LID") && (($res["EVENT_NAME"] != $ID["EVENT_NAME"]) \|\| ($res["LID"] != $ID["LID"]))) \|\| (is_set($ID, "ID") && $res["ID"] != $ID["ID"]) \|\| (is_set($ID, "EVENT_NAME") && ($res["EVENT_NAME"] != $ID["EVENT_NAME"])))) { $aMsg[] = array("id"=>"EVENT_NAME_EXIST", "text"=>str_replace( array("#SITE_ID#", "#EVENT_NAME#"), array($arFields["LID"], $arFields["EVENT_NAME"]), GetMessage("EVENT_NAME_EXIST"))); } } } } } else { $aMsg[] = array("id"=>"ACTION_EMPTY", "text"=>GetMessage("ACTION_EMPTY")); } if(!empty($aMsg)) { $e = new CAdminException($aMsg); $APPLICATION->ThrowException($e); return false; } return true; } public static function Add($arFields) { if(!is_set($arFields, "LID") && is_set($arFields, "SITE_ID")) $arFields["LID"] = $arFields["SITE_ID"]; if(!isset($arFields["EVENT_TYPE"])) { //compatibility $arFields["EVENT_TYPE"] = EventTypeTable::TYPE_EMAIL; } unset($arFields["ID"]); if (CEventType::CheckFields($arFields)) { $result = Mail\Internal\EventTypeTable::add($arFields); return $result->getId(); } return false; } public static function Update($arID = array(), $arFields = array()) { $ID = array(); // update event type by ID, or (LID+EVENT_NAME) if (is_array($arID) && !empty($arID)) { foreach ($arID as $key => $val) { if (in_array($key, array("ID", "LID", "EVENT_NAME"))) $ID[$key] = $val; } } if (!empty($ID) && CEventType::CheckFields($arFields, "UPDATE", $ID)) { unset($arFields["ID"]); $affectedRowsCount = 0; $result = false; $listDb = Mail\Internal\EventTypeTable::getList(array( 'select' => array('ID'), 'filter' => $ID )); while($arListId = $listDb->fetch()) { $result = Mail\Internal\EventTypeTable::update($arListId['ID'], $arFields); $affectedRowsCount += $result->getAffectedRowsCount(); } $res = new CDBResultEventMultiResult(); $res->affectedRowsCount = $affectedRowsCount; return $res; } return false; } public static function Delete($arID) { $ID = array(); if (!is_array($arID)) $arID = array("EVENT_NAME" => $arID); foreach ($arID as $k => $v) { if (!in_array(strToUpper($k), array("ID", "LID", "EVENT_NAME", "NAME", "SORT"))) continue; $ID[$k] = $v; } if (!empty($ID)) { $res = null; $affectedRowsCount = 0; $listDb = Mail\Internal\EventTypeTable::getList(array( 'select' => array('ID'), 'filter' => $ID )); while($arListId = $listDb->fetch()) { $result = Mail\Internal\EventTypeTable::delete($arListId['ID']); if($result->isSuccess()) { $affectedRowsCount++; } else { $res = false; break; } } if($res === null) { $res = new CDBResultEventMultiResult(); $res->affectedRowsCount = $affectedRowsCount; } return $res; } return false; } public static function GetList($arFilter=array(), $arOrder=array()) { global $DB; $arSqlSearch = $arSqlOrder = array(); foreach($arFilter as $key => $val) { $val_escaped = $DB->ForSQL($val); if($val_escaped == '') continue; $key = strtoupper($key); switch($key) { case "EVENT_NAME": case "TYPE_ID": $arSqlSearch["EVENT_NAME"] = (string) $val; break; case "EVENT_TYPE": $arSqlSearch["=EVENT_TYPE"] = (string) $val; break; case "LID": $arSqlSearch["=LID"] = (string) $val; break; case "ID": $arSqlSearch["=ID"] = intval($val); break; } } if(is_array($arOrder)) { static $arFields = array("ID"=>1, "LID"=>1, "EVENT_NAME"=>1, "NAME"=>1, "SORT"=>1); foreach($arOrder as $by => $ord) { $by = strtoupper($by); $ord = strtoupper($ord); if(array_key_exists($by, $arFields)) $arSqlOrder[$by] = ($ord == "DESC"? "DESC":"ASC"); } } if(empty($arSqlOrder)) $arSqlOrder['ID'] = 'ASC'; $result = Mail\Internal\EventTypeTable::getList(array( 'select' => array('ID', 'LID', 'EVENT_NAME', 'EVENT_TYPE', 'NAME', 'DESCRIPTION', 'SORT'), 'filter' => $arSqlSearch, 'order' => $arSqlOrder )); $res = new CDBResult($result); return $res; } public static function GetListExFetchDataModifier($data) { if(isset($data['ID1']) && !isset($data['ID'])) { $data['ID'] = $data['ID1']; unset($data['ID1']); } if(isset($data['EVENT_NAME1']) && !isset($data['EVENT_NAME'])) { $data['EVENT_NAME'] = $data['EVENT_NAME1']; unset($data['EVENT_NAME1']); } return $data; } public static function GetListEx($arOrder = array(), $arFilter = array(), $arParams = array()) { global $DB; $arSearch = $arSearch1 = $arSearch2 = array(); $arSelect = array(); $arSqlSearch = array(); $strSqlSearch = ""; $arSqlOrder = array(); foreach($arFilter as $key => $val) { if(strlen($val) <= 0) continue; $val = $DB->ForSql($val); $key_res = CEventType::GetFilterOperation($key); $key = strToUpper($key_res["FIELD"]); $strNegative = $key_res["NEGATIVE"]; $strOperation = $key_res["OPERATION"]; $strNOperation = $key_res["NOPERATION"]; $arOperationReplace = array( 'LIKE' => '=%', 'QUERY' => '', 'IN' => '', ); switch($key) { case "EVENT_NAME": case "TYPE_ID": if ($strOperation == "LIKE") $val = "%".$val."%"; $arSearch[] = array($strNOperation.'EVENT_NAME' => $val); break; case "DESCRIPTION": case "NAME": if ($strOperation == "LIKE") $val = "%".$val."%"; $arSearch1[] = array($strNOperation.'EVENT_MESSAGE_TYPE.'.$key => $val); $arSearch2[] = array($strNOperation.$key => $val); break; case "LID": $arSearch1[] = array($strNOperation.'EVENT_MESSAGE_TYPE.'.$key => $val); $arSearch2[] = array($strNOperation.$key => $val); break; case "ID": $val = intVal($val); $arSearch1[] = array($strNOperation.'EVENT_MESSAGE_TYPE.'.$key => $val); $arSearch2[] = array($strNOperation.$key => $val); break; case "MESSAGE_ID": $val = intVal($val); $arSearch1[] = array($strNOperation."ID" => $val); $arSearch2[] = array($strNOperation.'EVENT_MESSAGE.ID' => $val); break; } } if (is_array($arOrder)) { foreach($arOrder as $by=>$order) { $by = strtoupper($by); $order = strtoupper($order); $order = ($order <> "DESC"? "ASC" : "DESC"); if($by == "EVENT_NAME" \|\| $by == "ID") $arSqlOrder["EVENT_NAME"] = "EVENT_NAME1 ".$order; } } if(empty($arSqlOrder)) $arSqlOrder["EVENT_NAME"] = "EVENT_NAME1 ASC"; $strSqlOrder = " ORDER BY ".implode(", ", $arSqlOrder); $arSearch['!EVENT_NAME'] = null; $arQuerySelect = array('ID1' => 'EVENT_NAME', 'EVENT_NAME1' => 'EVENT_NAME'); $query1 = new \Bitrix\Main\Entity\Query(Mail\Internal\EventMessageTable::getEntity()); $query1->setSelect($arQuerySelect); $query1->setFilter(array_merge($arSearch, $arSearch1)); $query1->registerRuntimeField('EVENT_MESSAGE_TYPE', array( 'data_type' => 'Bitrix\Main\Mail\Internal\EventType', 'reference' => array('=this.EVENT_NAME' => 'ref.EVENT_NAME'), )); $query2 = new \Bitrix\Main\Entity\Query(Mail\Internal\EventTypeTable::getEntity()); $query2->setSelect($arQuerySelect); $query2->setFilter(array_merge($arSearch, $arSearch2)); $query2->registerRuntimeField('EVENT_MESSAGE', array( 'data_type' => 'Bitrix\Main\Mail\Internal\EventMessage', 'reference' => array('=this.EVENT_NAME' => 'ref.EVENT_NAME'), )); $connection = \Bitrix\Main\Application::getConnection(); $strSql = $query1->getQuery() . " UNION " . $query2->getQuery(). " ".$strSqlOrder; $db_res = $connection->query($strSql); $db_res->addFetchDataModifier(array('CEventType', 'GetListExFetchDataModifier')); $db_res = new _CEventTypeResult($db_res, $arParams); return $db_res; } /////////////////////////////////////////////////////////////////// // selecting type /////////////////////////////////////////////////////////////////// public static function GetByID($ID, $LID) { $result = Mail\Internal\EventTypeTable::getList(array( 'filter' => array('=LID' => $LID, '=EVENT_NAME' => $ID), )); return new CDBResult($result); } public static function GetFilterOperation($key) { $strNegative = "N"; if (substr($key, 0, 1)=="!") { $key = subStr($key, 1); $strNegative = "Y"; } $strOrNull = "N"; if (subStr($key, 0, 1)=="+") { $key = subStr($key, 1); $strOrNull = "Y"; } if (subStr($key, 0, 2)==">=") { $key = subStr($key, 2); $strOperation = ">="; $strNOperation = ($strNegative == "Y" ? '<' : $strOperation); } elseif (subStr($key, 0, 1)==">") { $key = subStr($key, 1); $strOperation = ">"; $strNOperation = ($strNegative == "Y" ? '<=' : $strOperation); } elseif (subStr($key, 0, 2)=="<=") { $key = subStr($key, 2); $strOperation = "<="; $strNOperation = ($strNegative == "Y" ? '>' : $strOperation); } elseif (subStr($key, 0, 1)=="<") { $key = subStr($key, 1); $strOperation = "<"; $strNOperation = ($strNegative == "Y" ? '>=' : $strOperation); } elseif (subStr($key, 0, 1)=="@") { $key = subStr($key, 1); $strOperation = "IN"; $strNOperation = ($strNegative == "Y" ? '' : ''); } elseif (subStr($key, 0, 1)=="~") { $key = subStr($key, 1); $strOperation = "LIKE"; $strNOperation = ($strNegative == "Y" ? '!=%' : '=%'); } elseif (subStr($key, 0, 1)=="%") { $key = subStr($key, 1); $strOperation = "QUERY"; $strNOperation = ($strNegative == "Y" ? '' : ''); } else { $strOperation = "="; $strNOperation = ($strNegative == "Y" ? '!=' : '='); } return array("FIELD" => $key, "NEGATIVE" => $strNegative, "OPERATION" => $strOperation, "NOPERATION" => $strNOperation, "OR_NULL" => $strOrNull); } } class _CEventTypeResult extends CDBResult { var $type = "type"; var $LID = LANGUAGE_ID; var $SITE_ID = SITE_ID; public function __construct($res, $arParams = array()) { $this->type = empty($arParams["type"]) ? "type" : $arParams["type"]; $this->LID = empty($arParams["LID"]) ? LANGUAGE_ID : $arParams["LID"]; $this->SITE_ID = empty($arParams["SITE_ID"]) ? SITE_ID : $arParams["SITE_ID"]; parent::__construct($res); } function Fetch() { $arr = array(); $arr_lid = array(); $arr_lids = array(); if($res = parent::Fetch()) { if ($this->type != "none") { $eventType = EventTypeTable::TYPE_EMAIL; $db_res_ = CEventType::GetList(array("EVENT_NAME" => $res["EVENT_NAME"])); if ($db_res_ && $res_ = $db_res_->Fetch()) { do { $arr[$res_["ID"]] = $res_; $arr_lid[] = $res_["LID"]; $arr_lids[$res_["LID"]] = $res_; $eventType = $res_["EVENT_TYPE"]; } while($res_ = $db_res_->Fetch()); } $res["ID"] = array_keys($arr); $res["LID"] = $arr_lid; $res["EVENT_TYPE"] = $eventType; $res["NAME"] = empty($arr_lids[$this->LID]["NAME"]) ? $arr_lids["en"]["NAME"] : $arr_lids[$this->LID]["NAME"]; $res["SORT"] = empty($arr_lids[$this->LID]["SORT"]) ? $arr_lids["en"]["SORT"] : $arr_lids[$this->LID]["SORT"]; $res["DESCRIPTION"] = empty($arr_lids[$this->LID]["DESCRIPTION"]) ? $arr_lids["en"]["DESCRIPTION"] : $arr_lids[$this->LID]["DESCRIPTION"]; $res["TYPE"] = $arr; if ($this->type != "type") { $arr = array(); $db_res_ = CEventMessage::GetList($sort = "sort", $by = "asc", array("EVENT_NAME" => $res["EVENT_NAME"])); if ($db_res_ && $res_ = $db_res_->Fetch()) { do { $arr[$res_["ID"]] = $res_; }while($res_ = $db_res_->Fetch()); } $res["TEMPLATES"] = $arr; } } } return $res; } } class CDBResultEventMultiResult extends CDBResult { public $affectedRowsCount; public function AffectedRowsCount() { if($this->affectedRowsCount !== false) return $this->affectedRowsCount; else return parent::AffectedRowsCount(); } }

| ver. 1.4 | Github | . | PHP 7.4.8 | Генерация страницы: 0 | proxy | phpinfo | Настройка