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

Файловый менеджер - Редактировать - /var/www/axolotl/data/www/ekb.axolotls.ru/cf5ac/messages.php.tar

Назад
var/www/axolotl/data/www/axolotls.ru/www/bitrix/modules/socialnetwork/classes/general/messages.php��0000664��00000042010�14767370307�0027761 0��ustar�00��<? IncludeModuleLangFile(__FILE__); class CAllSocNetMessages { /*************************************/ /**** DATA MODIFICATION ******/ /***********************************/ function CheckFields($ACTION, &$arFields, $ID = 0) { global $DB; if ($ACTION != "ADD" && intval($ID) <= 0) { $GLOBALS["APPLICATION"]->ThrowException("System error 870164", "ERROR"); return false; } if ((is_set($arFields, "FROM_USER_ID") \|\| $ACTION=="ADD") && intval($arFields["FROM_USER_ID"]) <= 0) { $GLOBALS["APPLICATION"]->ThrowException(GetMessage("SONET_M_EMPTY_FROM_USER_ID"), "EMPTY_FROM_USER_ID"); return false; } elseif (is_set($arFields, "FROM_USER_ID")) { $dbResult = CUser::GetByID($arFields["FROM_USER_ID"]); if (!$dbResult->Fetch()) { $GLOBALS["APPLICATION"]->ThrowException(GetMessage("SONET_M_ERROR_NO_FROM_USER_ID"), "ERROR_NO_FROM_USER_ID"); return false; } } if ((is_set($arFields, "TO_USER_ID") \|\| $ACTION=="ADD") && intval($arFields["TO_USER_ID"]) <= 0) { $GLOBALS["APPLICATION"]->ThrowException(GetMessage("SONET_M_EMPTY_TO_USER_ID"), "EMPTY_TO_USER_ID"); return false; } elseif (is_set($arFields, "TO_USER_ID")) { $dbResult = CUser::GetByID($arFields["TO_USER_ID"]); if (!$dbResult->Fetch()) { $GLOBALS["APPLICATION"]->ThrowException(GetMessage("SONET_M_ERROR_NO_TO_USER_ID"), "ERROR_NO_TO_USER_ID"); return false; } } if (is_set($arFields, "DATE_CREATE") && (!$DB->IsDate($arFields["DATE_CREATE"], false, LANG, "FULL"))) { $GLOBALS["APPLICATION"]->ThrowException(GetMessage("SONET_GB_EMPTY_DATE_CREATE"), "EMPTY_DATE_CREATE"); return false; } if (is_set($arFields, "DATE_VIEW") && $arFields["DATE_VIEW"] !== false && (!$DB->IsDate($arFields["DATE_VIEW"], false, LANG, "FULL"))) { $GLOBALS["APPLICATION"]->ThrowException(GetMessage("SONET_MM_EMPTY_DATE_VIEW"), "EMPTY_DATE_UPDATE"); return false; } if ((is_set($arFields, "MESSAGE_TYPE") \|\| $ACTION=="ADD") && $arFields["MESSAGE_TYPE"] != SONET_MESSAGE_PRIVATE && $arFields["MESSAGE_TYPE"] != SONET_MESSAGE_SYSTEM) $arFields["MESSAGE_TYPE"] = SONET_MESSAGE_PRIVATE; if ((is_set($arFields, "FROM_DELETED") \|\| $ACTION=="ADD") && $arFields["FROM_DELETED"] != "Y" && $arFields["FROM_DELETED"] != "N") $arFields["FROM_DELETED"] = "N"; if ((is_set($arFields, "TO_DELETED") \|\| $ACTION=="ADD") && $arFields["TO_DELETED"] != "Y" && $arFields["TO_DELETED"] != "N") $arFields["TO_DELETED"] = "N"; if ((is_set($arFields, "SEND_MAIL") \|\| $ACTION=="ADD") && $arFields["SEND_MAIL"] != "Y" && $arFields["SEND_MAIL"] != "N") $arFields["SEND_MAIL"] = "N"; if ((is_set($arFields, "IS_LOG") \|\| $ACTION=="ADD") && $arFields["IS_LOG"] != "Y" && $arFields["SEND_MAIL"] != "N") $arFields["SEND_MAIL"] = "N"; return True; } function Delete($ID) { global $DB; if (!CSocNetGroup::__ValidateID($ID)) return false; $ID = intval($ID); $bSuccess = True; $db_events = GetModuleEvents("socialnetwork", "OnBeforeSocNetMessagesDelete"); while ($arEvent = $db_events->Fetch()) if (ExecuteModuleEventEx($arEvent, array($ID))===false) return false; $events = GetModuleEvents("socialnetwork", "OnSocNetMessagesDelete"); while ($arEvent = $events->Fetch()) ExecuteModuleEventEx($arEvent, array($ID)); if ($bSuccess) $bSuccess = $DB->Query("DELETE FROM b_sonet_messages WHERE ID = ".$ID."", true); return $bSuccess; } function DeleteMessage($ID, $userID, $bCheckMessages = true) { global $DB; $ID = intval($ID); if ($ID <= 0) { $GLOBALS["APPLICATION"]->ThrowException(GetMessage("SONET_UR_EMPTY_MESSAGE_ID"), "ERROR_MESSAGE_ID"); return false; } $userID = intval($userID); if ($userID <= 0) { $GLOBALS["APPLICATION"]->ThrowException(GetMessage("SONET_UR_EMPTY_SENDER_USER_ID"), "ERROR_SENDER_USER_ID"); return false; } $arMessage = CSocNetMessages::GetByID($ID); if (!$arMessage \|\| !is_array($arMessage)) { $GLOBALS["APPLICATION"]->ThrowException(GetMessage("SONET_UR_NO_MESSAGE"), "ERROR_NO_MESSAGE"); return false; } if (($arMessage["FROM_USER_ID"] == $userID) && ($arMessage["TO_USER_ID"] == $userID)) { if (!CSocNetMessages::Delete($arMessage["ID"])) { $errorMessage = ""; if ($e = $GLOBALS["APPLICATION"]->GetException()) $errorMessage = $e->GetString(); if ($errorMessage == '') $errorMessage = GetMessage("SONET_M_ERROR_DELETE_MESSAGE"); $GLOBALS["APPLICATION"]->ThrowException($errorMessage, "ERROR_DELETE_MESSAGE"); return false; } } elseif ($arMessage["FROM_USER_ID"] == $userID) { if ($arMessage["TO_DELETED"] == "Y") { if (!CSocNetMessages::Delete($arMessage["ID"])) { $errorMessage = ""; if ($e = $GLOBALS["APPLICATION"]->GetException()) $errorMessage = $e->GetString(); if ($errorMessage == '') $errorMessage = GetMessage("SONET_M_ERROR_DELETE_MESSAGE"); $GLOBALS["APPLICATION"]->ThrowException($errorMessage, "ERROR_DELETE_MESSAGE"); return false; } } else { if (!CSocNetMessages::Update($arMessage["ID"], array("FROM_DELETED" => "Y"))) { $errorMessage = ""; if ($e = $GLOBALS["APPLICATION"]->GetException()) $errorMessage = $e->GetString(); if ($errorMessage == '') $errorMessage = GetMessage("SONET_UR_ERROR_UPDATE_MESSAGE"); $GLOBALS["APPLICATION"]->ThrowException($errorMessage, "ERROR_UPDATE_MESSAGE"); return false; } } } elseif ($arMessage["TO_USER_ID"] == $userID) { if ($arMessage["FROM_DELETED"] == "Y") { if (!CSocNetMessages::Delete($arMessage["ID"])) { $errorMessage = ""; if ($e = $GLOBALS["APPLICATION"]->GetException()) $errorMessage = $e->GetString(); if ($errorMessage == '') $errorMessage = GetMessage("SONET_M_ERROR_DELETE_MESSAGE"); $GLOBALS["APPLICATION"]->ThrowException($errorMessage, "ERROR_DELETE_MESSAGE"); return false; } } else { if (!CSocNetMessages::Update($arMessage["ID"], array("TO_DELETED" => "Y"))) { $errorMessage = ""; if ($e = $GLOBALS["APPLICATION"]->GetException()) $errorMessage = $e->GetString(); if ($errorMessage == '') $errorMessage = GetMessage("SONET_UR_ERROR_UPDATE_MESSAGE"); $GLOBALS["APPLICATION"]->ThrowException($errorMessage, "ERROR_UPDATE_MESSAGE"); return false; } } if ($bCheckMessages) CSocNetMessages::__SpeedFileCheckMessages($userID); } else { $GLOBALS["APPLICATION"]->ThrowException(GetMessage("SONET_UR_NO_MESSAGE"), "ERROR_NO_MESSAGE"); return false; } return true; } public static function DeleteNoDemand($userID) { global $DB; if (!CSocNetGroup::__ValidateID($userID)) return false; $userID = intval($userID); $bSuccess = True; if ($bSuccess) $bSuccess = $DB->Query("DELETE FROM b_sonet_messages WHERE FROM_USER_ID = ".$userID." OR TO_USER_ID = ".$userID."", true); CSocNetMessages::__SpeedFileDelete($userID); return $bSuccess; } /***********************************/ /****** DATA SELECTION *******/ /***********************************/ function GetByID($ID) { global $DB; if (!CSocNetGroup::__ValidateID($ID)) return false; $ID = intval($ID); $dbResult = CSocNetMessages::GetList(Array(), Array("ID" => $ID, "IS_LOG_ALL" => "Y")); if ($arResult = $dbResult->GetNext()) { return $arResult; } return False; } /***********************************/ /****** SEND EVENTS **********/ /***********************************/ function SendEvent($messageID, $mailTemplate = "SONET_NEW_MESSAGE") { $messageID = intval($messageID); if ($messageID <= 0) return false; $dbMessage = CSocNetMessages::GetList( array(), array("ID" => $messageID, "IS_LOG_ALL" => "Y"), false, false, array("ID", "FROM_USER_ID", "TO_USER_ID", "TITLE", "MESSAGE", "DATE_CREATE", "FROM_USER_NAME", "FROM_USER_LAST_NAME", "FROM_USER_LOGIN", "TO_USER_NAME", "TO_USER_LAST_NAME", "TO_USER_LOGIN", "TO_USER_EMAIL", "TO_USER_LID") ); $arMessage = $dbMessage->Fetch(); if (!$arMessage) return false; $defSiteID = (Defined("SITE_ID") ? SITE_ID : $arMessage["TO_USER_LID"]); $siteID = CSocNetUserEvents::GetEventSite($arMessage["TO_USER_ID"], $mailTemplate, $defSiteID); if ($siteID == false \|\| $siteID == '') return false; $arFields = array( "MESSAGE_ID" => $messageID, "USER_ID" => $arMessage["TO_USER_ID"], "USER_NAME" => $arMessage["TO_USER_NAME"], "USER_LAST_NAME" => $arMessage["TO_USER_LAST_NAME"], "SENDER_ID" => $arMessage["FROM_USER_ID"], "SENDER_NAME" => $arMessage["FROM_USER_NAME"], "SENDER_LAST_NAME" => $arMessage["FROM_USER_LAST_NAME"], "EMAIL_TO" => $arMessage["TO_USER_EMAIL"], "TITLE" => $arMessage["TITLE"], "MESSAGE" => $arMessage["MESSAGE"] ); $event = new CEvent; $event->Send($mailTemplate, $siteID, $arFields, "N"); return true; } /***********************************/ /******** ACTIONS ************/ /************************************/ function MarkMessageRead($senderUserID, $messageID, $bRead = true) { global $APPLICATION; $senderUserID = intval($senderUserID); if ($senderUserID <= 0) { $GLOBALS["APPLICATION"]->ThrowException(GetMessage("SONET_UR_EMPTY_SENDER_USER_ID"), "ERROR_SENDER_USER_ID"); return false; } $messageID = intval($messageID); if ($messageID <= 0) { $GLOBALS["APPLICATION"]->ThrowException(GetMessage("SONET_UR_EMPTY_MESSAGE_ID"), "ERROR_MESSAGE_ID"); return false; } $arFilter = array( "ID" => $messageID, "TO_USER_ID" => $senderUserID, "IS_LOG_ALL" => "Y" ); if ($bRead) $arFilter["DATE_VIEW"] = ""; $dbResult = CSocNetMessages::GetList( array(), $arFilter, false, false, array("ID", "DATE_CREATE") ); if ($arResult = $dbResult->Fetch()) { if ($bRead) $arFields = array("=DATE_VIEW" => $GLOBALS["DB"]->CurrentTimeFunction()); else $arFields = array("DATE_VIEW" => false); if (!CSocNetMessages::Update($arResult["ID"], $arFields)) { $errorMessage = ""; if ($e = $GLOBALS["APPLICATION"]->GetException()) $errorMessage = $e->GetString(); if ($errorMessage == '') $errorMessage = GetMessage("SONET_UR_ERROR_UPDATE_MESSAGE"); $GLOBALS["APPLICATION"]->ThrowException($errorMessage, "ERROR_UPDATE_MESSAGE"); return false; } else { CSocNetMessages::__SpeedFileCheckMessages($senderUserID); } } else { $GLOBALS["APPLICATION"]->ThrowException(GetMessage("SONET_UR_NO_MESSAGE"), "ERROR_NO_MESSAGE"); return false; } return true; } function CreateMessage($senderUserID, $targetUserID, $message, $title = false) { global $APPLICATION; $senderUserID = intval($senderUserID); if ($senderUserID <= 0) { $GLOBALS["APPLICATION"]->ThrowException(GetMessage("SONET_UR_EMPTY_SENDER_USER_ID"), "ERROR_SENDER_USER_ID"); return false; } $targetUserID = intval($targetUserID); if ($targetUserID <= 0) { $GLOBALS["APPLICATION"]->ThrowException(GetMessage("SONET_UR_EMPTY_TARGET_USER_ID"), "ERROR_TARGET_USER_ID"); return false; } $message = Trim($message); if ($message == '') { $GLOBALS["APPLICATION"]->ThrowException(GetMessage("SONET_UR_EMPTY_MESSAGE"), "ERROR_MESSAGE"); return false; } $arFields = array( "FROM_USER_ID" => $senderUserID, "TO_USER_ID" => $targetUserID, "TITLE" => $title, "MESSAGE" => $message, "=DATE_CREATE" => $GLOBALS["DB"]->CurrentTimeFunction(), "DATE_VIEW" => false, "MESSAGE_TYPE" => SONET_MESSAGE_PRIVATE, "FROM_DELETED" => "N", "TO_DELETED" => "N", "SEND_MAIL" => "N", ); if (!CSocNetMessages::Add($arFields)) { $errorMessage = ""; if ($e = $GLOBALS["APPLICATION"]->GetException()) $errorMessage = $e->GetString(); if ($errorMessage == '') $errorMessage = GetMessage("SONET_UR_ERROR_CREATE_MESSAGE"); $GLOBALS["APPLICATION"]->ThrowException($errorMessage, "ERROR_CREATE_MESSAGE"); return false; } CSocNetMessages::__SpeedFileCreate($targetUserID); return true; } function MarkMessageReadMultiple($userID, $arIDs) { global $APPLICATION, $DB; $userID = intval($userID); if ($userID <= 0) { $GLOBALS["APPLICATION"]->ThrowException(GetMessage("SONET_UR_EMPTY_SENDER_USER_ID"), "ERROR_USER_ID"); return false; } if (!is_array($arIDs)) return true; foreach ($arIDs as $ID) CSocNetMessages::MarkMessageRead($userID, $ID); return true; } function DeleteMessageMultiple($userID, $arIDs) { global $APPLICATION, $DB; $userID = intval($userID); if ($userID <= 0) { $GLOBALS["APPLICATION"]->ThrowException(GetMessage("SONET_UR_EMPTY_SENDER_USER_ID"), "ERROR_USER_ID"); return false; } if (!is_array($arIDs)) return true; foreach ($arIDs as $ID) CSocNetMessages::DeleteMessage($ID, $userID); return true; } function DeleteConversation($CurrentUserID, $PartnerUserID) { global $APPLICATION, $DB; $CurrentUserID = intval($CurrentUserID); $PartnerUserID = intval($PartnerUserID); if ($CurrentUserID <= 0) { $GLOBALS["APPLICATION"]->ThrowException(GetMessage("SONET_UR_EMPTY_SENDER_USER_ID"), "ERROR_USER_ID"); return false; } if ($PartnerUserID <= 0) { $GLOBALS["APPLICATION"]->ThrowException(GetMessage("SONET_UR_EMPTY_TARGET_USER_ID"), "ERROR_USER_ID"); return false; } $dbMessages = CSocNetMessages::GetMessagesForChat($CurrentUserID, $PartnerUserID); while ($arMessages = $dbMessages->GetNext()) { CSocNetMessages::DeleteMessage($arMessages["ID"], $CurrentUserID, false); } CSocNetMessages::__SpeedFileCheckMessages($CurrentUserID); return true; } function __SpeedFileCheckMessages($userID) { $userID = intval($userID); if ($userID <= 0) return; $cnt = 0; $dbResult = $GLOBALS["DB"]->Query( "SELECT COUNT(ID) as CNT ". "FROM b_sonet_messages ". "WHERE TO_USER_ID = ".$userID." ". " AND DATE_VIEW IS NULL ". " AND TO_DELETED = 'N' " ); if ($arResult = $dbResult->Fetch()) $cnt = intval($arResult["CNT"]); if ($cnt > 0) CSocNetMessages::__SpeedFileCreate($userID); else CSocNetMessages::__SpeedFileDelete($userID); } function __SpeedFileCreate($userID) { global $CACHE_MANAGER; $userID = intval($userID); if ($userID <= 0) return; if ($CACHE_MANAGER->Read(8640030, "socnet_cm_".$userID)) $CACHE_MANAGER->Clean("socnet_cm_".$userID); /* $filePath = $_SERVER["DOCUMENT_ROOT"].BX_PERSONAL_ROOT."/managed_flags/socnet/c/".IntVal($userID / 1000)."/"; $fileName = $userID."_m"; if (!file_exists($filePath.$fileName)) { CheckDirPath($filePath); @fclose(@fopen($filePath.$fileName, "w")); } / } function __SpeedFileDelete($userID) { global $CACHE_MANAGER; $userID = intval($userID); if ($userID <= 0) return; if (!$CACHE_MANAGER->Read(8640030, "socnet_cm_".$userID)) $CACHE_MANAGER->Set("socnet_cm_".$userID, true); /* $fileName = $_SERVER["DOCUMENT_ROOT"].BX_PERSONAL_ROOT."/managed_flags/socnet/c/".IntVal($userID / 1000)."/".$userID."_m"; if (file_exists($fileName)) @unlink($fileName); / } function SpeedFileExists($userID) { global $CACHE_MANAGER; $userID = intval($userID); if ($userID <= 0) return; return (!$CACHE_MANAGER->Read(8640030, "socnet_cm_".$userID)); /* $fileName = $_SERVER["DOCUMENT_ROOT"].BX_PERSONAL_ROOT."/managed_flags/socnet/c/".IntVal($userID / 1000)."/".$userID."_m"; return file_exists($fileName); */ } function SendEventAgent() { global $DB; if (IsModuleInstalled("im")) return "CSocNetMessages::SendEventAgent();"; $dbMessage = CSocNetMessages::GetList( array(), array( "DATE_VIEW" => "", "TO_DELETED" => "N", "SEND_MAIL" => "N", "!IS_LOG" => "Y" ), false, false, array("ID", "FROM_USER_ID", "TO_USER_ID", "TITLE", "MESSAGE", "DATE_CREATE", "FROM_USER_NAME", "FROM_USER_LAST_NAME", "FROM_USER_LOGIN", "TO_USER_NAME", "TO_USER_LAST_NAME", "TO_USER_LOGIN", "TO_USER_EMAIL", "TO_USER_LID", "EMAIL_TEMPLATE", "IS_LOG") ); while ($arMessage = $dbMessage->Fetch()) { if (isset($arMessage["EMAIL_TEMPLATE"]) && $arMessage["EMAIL_TEMPLATE"] <> '') $mailTemplate = $arMessage["EMAIL_TEMPLATE"]; else $mailTemplate = "SONET_NEW_MESSAGE"; $defSiteID = $arMessage["TO_USER_LID"]; $siteID = CSocNetUserEvents::GetEventSite($arMessage["TO_USER_ID"], $mailTemplate, $defSiteID); if ($siteID == false \|\| $siteID == '') $siteID = CSite::GetDefSite(); if ($siteID == false \|\| $siteID == '') continue; $arFields = array( "MESSAGE_ID" => $arMessage["ID"], "USER_ID" => $arMessage["TO_USER_ID"], "USER_NAME" => $arMessage["TO_USER_NAME"], "USER_LAST_NAME" => $arMessage["TO_USER_LAST_NAME"], "SENDER_ID" => $arMessage["FROM_USER_ID"], "SENDER_NAME" => $arMessage["FROM_USER_NAME"], "SENDER_LAST_NAME" => $arMessage["FROM_USER_LAST_NAME"], "EMAIL_TO" => $arMessage["TO_USER_EMAIL"], "TITLE" => $arMessage["TITLE"], "MESSAGE" => CSocNetTextParser::convert4mail($arMessage["MESSAGE"]), ); $event = new CEvent; $event->Send($mailTemplate, $siteID, $arFields, "N"); CSocNetMessages::Update($arMessage["ID"], array("SEND_MAIL" => "Y")); } return "CSocNetMessages::SendEventAgent();"; } } ?>��

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