��ѧۧݧ�ӧ�� ާ֧ߧ֧էا֧�

��ѧۧݧ�ӧ�� ާ֧ߧ֧էا֧� - ��֧էѧܧ�ڧ��ӧѧ�� - /home/alphpwcp/public_html/us/alphachat/lib/core/lhchat/lhchatstatsresque.php

��ѧ٧ѧ�
<?php #[\AllowDynamicProperties] class erLhcoreClassChatStatsResque { public function perform() { $db = ezcDbInstance::get(); $db->reconnect(); // Because it timeouts automatically, this calls to reconnect to database, this is implemented in 2.52v if (isset($this->args['inst_id']) && $this->args['inst_id'] > 0) { $cfg = \erConfigClassLhConfig::getInstance(); $db->query('USE ' . $cfg->getSetting('db', 'database')); $instance = \erLhcoreClassModelInstance::fetch($this->args['inst_id']); \erLhcoreClassInstance::$instanceChat = $instance; $db->query('USE ' . $cfg->getSetting('db', 'database_user_prefix') . $this->args['inst_id']); } if ($this->args['type'] == 'dep') { $dep = erLhcoreClassModelDepartament::fetch($this->args['id']); self::updateStats($dep); } } public static function updateStats($dep) { self::updateDepartmentStats($dep); // Update departments groups statistic $depGroups = erLhcoreClassModelDepartamentGroupMember::getList(array('filter' => array('dep_id' => $dep->id))); foreach ($depGroups as $depGroup) { $depGroupObj = erLhcoreClassModelDepartamentGroup::fetch($depGroup->dep_group_id); if ($depGroupObj instanceof erLhcoreClassModelDepartamentGroup) { self::updateDepartmentGroupStats($depGroupObj); } } } public static function getDepartmentOperatorsStatistic($dep, $soft = true) { $db = ezcDbInstance::get(); if ($soft == true) { $stmt = $db->prepare('SELECT MAX(max_chats) as max_chats, MAX(`inactive_chats`) AS `inactive_chats`, MAX(`active_chats`) AS `active_chats`, MAX(`hide_online`) AS `hide_online`, `user_id`,`ro` FROM `lh_userdep` WHERE dep_id = :dep_id AND last_activity > :last_activity AND (hide_online = 0 OR hide_online_ts > :hide_online_ts) GROUP BY `user_id`, `ro`'); $stmt->bindValue(':dep_id',$dep->id,PDO::PARAM_INT); $stmt->bindValue(':last_activity',time() - 600, PDO::PARAM_INT); $stmt->bindValue(':hide_online_ts',time() - 600, PDO::PARAM_INT); $stmt->execute(); return $stmt->fetchAll(PDO::FETCH_ASSOC); } else { $stmt = $db->prepare('SELECT MAX(`max_chats`) as `max_chats`,MAX(`inactive_chats`) AS `inactive_chats`, MAX(`active_chats`) AS `active_chats`, `user_id`,`ro`, MAX(`hide_online`) AS `hide_online` FROM `lh_userdep` WHERE dep_id = :dep_id AND hide_online = 0 AND last_activity > :last_activity GROUP BY `user_id`, `ro`'); $stmt->bindValue(':dep_id',$dep->id,PDO::PARAM_INT); $stmt->bindValue(':last_activity',time() - 600, PDO::PARAM_INT); $stmt->execute(); return $stmt->fetchAll(PDO::FETCH_ASSOC); } } public static function getDepartmentGroupOperatorsStatistic($depGroupObj, $soft = true) { $db = ezcDbInstance::get(); if ($soft == true) { $stmt = $db->prepare('SELECT MAX(`max_chats`) AS `max_chats`, MAX(`inactive_chats`) AS `inactive_chats`, MAX(`active_chats`) AS `active_chats`, `user_id`, MAX(`hide_online`) AS `hide_online` FROM `lh_userdep` WHERE `dep_id` IN (SELECT `dep_id` FROM `lh_departament_group_member` WHERE `dep_group_id` = :dep_group_id) AND last_activity > :last_activity AND (hide_online = 0 OR hide_online_ts > :hide_online_ts) GROUP BY `user_id`;'); $stmt->bindValue(':dep_group_id', $depGroupObj->id, PDO::PARAM_INT); $stmt->bindValue(':last_activity', time() - 600, PDO::PARAM_INT); $stmt->bindValue(':hide_online_ts', time() - 600, PDO::PARAM_INT); $stmt->execute(); return $stmt->fetchAll(PDO::FETCH_ASSOC); } else { $stmt = $db->prepare('SELECT MAX(`max_chats`) AS `max_chats`, MAX(`inactive_chats`) AS `inactive_chats`, MAX(`active_chats`) AS `active_chats`, `user_id`, MAX(`hide_online`) AS `hide_online` FROM `lh_userdep` WHERE `dep_id` IN (SELECT `dep_id` FROM `lh_departament_group_member` WHERE `dep_group_id` = :dep_group_id) AND hide_online = 0 AND `last_activity` > :last_activity GROUP BY `user_id`;'); $stmt->bindValue(':dep_group_id',$depGroupObj->id,PDO::PARAM_INT); $stmt->bindValue(':last_activity',time() - 600, PDO::PARAM_INT); $stmt->execute(); return $stmt->fetchAll(PDO::FETCH_ASSOC); } } public static function getDepartmentChatsOperatorsStatistic($dep) { $db = ezcDbInstance::get(); $stmt = $db->prepare('SELECT MAX(`max_chats`) AS `max_chats`, MAX(`inactive_chats`) AS `inactive_chats`, MAX(`active_chats`) AS `active_chats`, `user_id`, MAX(`hide_online`) AS `hide_online`, MAX(`hide_online_ts`) AS `hide_online_ts`, MAX(`last_activity`) AS `last_activity` FROM `lh_userdep` WHERE `user_id` IN (SELECT `user_id` FROM `lh_chat` WHERE `status` IN (1,0) AND `dep_id` = :dep_id) GROUP BY `user_id`;'); $stmt->bindValue(':dep_id',$dep->id,PDO::PARAM_INT); $stmt->execute(); return $stmt->fetchAll(PDO::FETCH_ASSOC); } public static function getUserStats($user) { $db = ezcDbInstance::get(); $stmt = $db->prepare('SELECT * FROM `lh_userdep` WHERE `user_id` = :user_id ORDER BY `type` ASC, `dep_id` ASC;'); $stmt->bindValue(':user_id',$user->id,PDO::PARAM_INT); $stmt->execute(); return $stmt->fetchAll(PDO::FETCH_ASSOC); } public static function getDepartmentChatsGroupOperatorsStatistic($depGroupObj) { $db = ezcDbInstance::get(); $stmt = $db->prepare('SELECT MAX(`max_chats`) AS `max_chats`, MAX(`inactive_chats`) AS `inactive_chats`, MAX(`active_chats`) AS `active_chats`, `user_id`, MAX(`hide_online`) AS `hide_online`, MAX(`hide_online_ts`) AS `hide_online_ts`, MAX(`last_activity`) AS `last_activity` FROM `lh_userdep` WHERE `user_id` IN (SELECT `user_id` FROM `lh_chat` WHERE `status` IN (1,0) AND `dep_id` IN (SELECT `dep_id` FROM `lh_departament_group_member` WHERE `dep_group_id` = :dep_group_id)) GROUP BY `user_id`;'); $stmt->bindValue(':dep_group_id', $depGroupObj->id, PDO::PARAM_INT); $stmt->execute(); return $stmt->fetchAll(PDO::FETCH_ASSOC); } public static function updateDepartmentStats($dep, $update = true) { $db = ezcDbInstance::get(); // Get max load for a specific department $stmt = $db->prepare('SELECT SUM(max_chats) as max_chats, COUNT(`user_id`) AS `max_load_op` FROM (SELECT MAX(max_chats) as max_chats,`user_id` FROM `lh_userdep` WHERE `ro` = 0 AND `dep_id` = :dep_id AND `last_activity` > :last_activity AND (`hide_online` = 0 OR `hide_online_ts` > :hide_online_ts) GROUP BY `user_id`) as tmp;'); $stmt->bindValue(':dep_id',$dep->id,PDO::PARAM_INT); $stmt->bindValue(':last_activity',time()-600, PDO::PARAM_INT); $stmt->bindValue(':hide_online_ts',time()-600, PDO::PARAM_INT); $stmt->execute(); $maxChats = $stmt->fetch(PDO::FETCH_ASSOC); $stmt = $db->prepare('SELECT SUM(`max_chats`) as `max_chats`, SUM(`active_chats`) AS `active_chats`, SUM(`inactive_chats`) AS `inactive_chats`, COUNT(`user_id`) AS `max_load_op_h` FROM (SELECT MAX(`max_chats`) as `max_chats`,MAX(`inactive_chats`) AS `inactive_chats`,MAX(`active_chats`) AS `active_chats`, `user_id` FROM `lh_userdep` WHERE `ro` = 0 AND `dep_id` = :dep_id AND `hide_online` = 0 AND `last_activity` > :last_activity GROUP BY `user_id`) as tmp;'); $stmt->bindValue(':dep_id',$dep->id,PDO::PARAM_INT); $stmt->bindValue(':last_activity',time()-600, PDO::PARAM_INT); $stmt->execute(); $maxChatsHard = $stmt->fetch(PDO::FETCH_ASSOC); $statsChats = erLhcoreClassModelChat::getCount(array( 'group' => '`status`, `status_sub`', 'filter' => array( 'dep_id' => $dep->id ), 'filterin' => array( 'status' => array( erLhcoreClassModelChat::STATUS_ACTIVE_CHAT, erLhcoreClassModelChat::STATUS_PENDING_CHAT, erLhcoreClassModelChat::STATUS_BOT_CHAT, ) ) ), 'count', false, 'count(`id`) as `total`, `status`, `status_sub`', false, true ); $dep->inactive_chats_cnt = $dep->bot_chats_counter = $dep->pending_chats_counter = $dep->active_chats_counter = 0; foreach ($statsChats as $statsChat) { if ($statsChat['status'] == erLhcoreClassModelChat::STATUS_ACTIVE_CHAT) { $dep->active_chats_counter += (int)$statsChat['total']; } elseif ($statsChat['status'] == erLhcoreClassModelChat::STATUS_PENDING_CHAT) { $dep->pending_chats_counter += (int)$statsChat['total']; } elseif ($statsChat['status'] == erLhcoreClassModelChat::STATUS_BOT_CHAT) { $dep->bot_chats_counter += (int)$statsChat['total']; } // Add to inactive chats if it's conditions matches if (in_array((int)$statsChat['status'],array(erLhcoreClassModelChat::STATUS_PENDING_CHAT, erLhcoreClassModelChat::STATUS_ACTIVE_CHAT)) && in_array((int)$statsChat['status_sub'],array(erLhcoreClassModelChat::STATUS_SUB_CONTACT_FORM, erLhcoreClassModelChat::STATUS_SUB_SURVEY_COMPLETED, erLhcoreClassModelChat::STATUS_SUB_USER_CLOSED_CHAT, erLhcoreClassModelChat::STATUS_SUB_SURVEY_SHOW))) { $dep->inactive_chats_cnt += $statsChat['total']; } } $dep->max_load = isset($maxChats['max_chats']) ? $maxChats['max_chats'] : 0; $dep->max_load_h = isset($maxChatsHard['max_chats']) ? $maxChatsHard['max_chats'] : 0; $dep->inop_chats_cnt = isset($maxChatsHard['inactive_chats']) ? $maxChatsHard['inactive_chats'] : 0; $dep->acop_chats_cnt = isset($maxChatsHard['active_chats']) ? $maxChatsHard['active_chats'] : 0; // Online operators stats $dep->max_load_op = isset($maxChats['max_load_op']) ? $maxChats['max_load_op'] : 0; $dep->max_load_op_h = isset($maxChatsHard['max_load_op_h']) ? $maxChatsHard['max_load_op_h'] : 0; $statsMails = erLhcoreClassModelMailconvConversation::getCount(array( 'group' => '`status`', 'filter' => array( 'dep_id' => $dep->id ), 'filterin' => array( 'status' => array( erLhcoreClassModelMailconvConversation::STATUS_PENDING, erLhcoreClassModelMailconvConversation::STATUS_ACTIVE ) ) ), 'count', false, 'count(`id`) as `total`, `status`', false, true ); $dep->active_mails_counter = $dep->pending_mails_counter = 0; foreach ($statsMails as $statsMail) { if ($statsMail['status'] == erLhcoreClassModelMailconvConversation::STATUS_ACTIVE) { $dep->active_mails_counter += (int)$statsMail['total']; } elseif ($statsMail['status'] == erLhcoreClassModelMailconvConversation::STATUS_PENDING) { $dep->pending_mails_counter += (int)$statsMail['total']; } } if ($update === true) { $dep->updateThis(array('update' => array('max_load_op','max_load_op_h','pending_mails_counter','active_mails_counter','inop_chats_cnt','acop_chats_cnt','active_chats_counter','pending_chats_counter','bot_chats_counter','inactive_chats_cnt','max_load','max_load_h'))); } } public static function updateDepartmentGroupStats($depGroupObj, $update = true) { $db = ezcDbInstance::get(); $stmt = $db->prepare('SELECT SUM(`max_chats`) AS `max_chats`, COUNT(`user_id`) AS `max_load_op` FROM (SELECT MAX(`max_chats`) AS `max_chats`, `user_id` FROM `lh_userdep` WHERE `ro` = 0 AND `dep_id` IN (SELECT `dep_id` FROM `lh_departament_group_member` WHERE `dep_group_id` = :dep_group_id) AND last_activity > :last_activity AND (hide_online = 0 OR hide_online_ts > :hide_online_ts) GROUP BY `user_id`) as `tmp`;'); $stmt->bindValue(':dep_group_id',$depGroupObj->id,PDO::PARAM_INT); $stmt->bindValue(':last_activity',time()-600, PDO::PARAM_INT); $stmt->bindValue(':hide_online_ts',time()-600, PDO::PARAM_INT); $stmt->execute(); $maxChats = $stmt->fetch(PDO::FETCH_ASSOC); $stmt = $db->prepare('SELECT SUM(`max_chats`) AS `max_chats`, SUM(`active_chats`) AS `active_chats`, SUM(`inactive_chats`) AS `inactive_chats`, COUNT(`user_id`) AS `max_load_op_h` FROM (SELECT MAX(`max_chats`) AS `max_chats`,MAX(`inactive_chats`) AS `inactive_chats`,MAX(`active_chats`) AS `active_chats`, `user_id` FROM `lh_userdep` WHERE `ro` = 0 AND `dep_id` IN (SELECT `dep_id` FROM `lh_departament_group_member` WHERE `dep_group_id` = :dep_group_id) AND hide_online = 0 AND `last_activity` > :last_activity GROUP BY `user_id`) as `tmp`;'); $stmt->bindValue(':dep_group_id',$depGroupObj->id,PDO::PARAM_INT); $stmt->bindValue(':last_activity',time()-600, PDO::PARAM_INT); $stmt->execute(); $maxChatsHard = $stmt->fetch(PDO::FETCH_ASSOC); $statsChats = erLhcoreClassModelChat::getCount(array( 'group' => '`status`, `status_sub`', 'filterin' => array( 'status' => array( erLhcoreClassModelChat::STATUS_ACTIVE_CHAT, erLhcoreClassModelChat::STATUS_PENDING_CHAT, erLhcoreClassModelChat::STATUS_BOT_CHAT, ), 'dep_id' => erLhcoreClassChat::getDepartmentsByDepGroup(array($depGroupObj->id)) ) ), 'count', false, 'count(`id`) as `total`, `status`, `status_sub`', false, true ); $depGroupObj->inachats_cnt = $depGroupObj->achats_cnt = $depGroupObj->pchats_cnt = $depGroupObj->bchats_cnt = 0; foreach ($statsChats as $statsChat) { if ($statsChat['status'] == erLhcoreClassModelChat::STATUS_ACTIVE_CHAT) { $depGroupObj->achats_cnt += (int)$statsChat['total']; } elseif ($statsChat['status'] == erLhcoreClassModelChat::STATUS_PENDING_CHAT) { $depGroupObj->pchats_cnt += (int)$statsChat['total']; } elseif ($statsChat['status'] == erLhcoreClassModelChat::STATUS_BOT_CHAT) { $depGroupObj->bchats_cnt += (int)$statsChat['total']; } // Add to inactive chats if it's conditions matches if (in_array((int)$statsChat['status'],array(erLhcoreClassModelChat::STATUS_PENDING_CHAT, erLhcoreClassModelChat::STATUS_ACTIVE_CHAT)) && in_array((int)$statsChat['status_sub'],array(erLhcoreClassModelChat::STATUS_SUB_SURVEY_COMPLETED, erLhcoreClassModelChat::STATUS_SUB_CONTACT_FORM, erLhcoreClassModelChat::STATUS_SUB_USER_CLOSED_CHAT, erLhcoreClassModelChat::STATUS_SUB_SURVEY_SHOW))) { $depGroupObj->inachats_cnt += (int)$statsChat['total']; } } $depGroupObj->max_load = isset($maxChats['max_chats']) ? $maxChats['max_chats'] : 0; ; $depGroupObj->max_load_h = isset($maxChatsHard['max_chats']) ? $maxChatsHard['max_chats'] : 0; $depGroupObj->inopchats_cnt = isset($maxChatsHard['inactive_chats']) ? $maxChatsHard['inactive_chats'] : 0; $depGroupObj->acopchats_cnt = isset($maxChatsHard['active_chats']) ? $maxChatsHard['active_chats'] : 0; $depGroupObj->max_load_op = isset($maxChats['max_load_op']) ? $maxChats['max_load_op'] : 0; $depGroupObj->max_load_op_h = isset($maxChatsHard['max_load_op_h']) ? $maxChatsHard['max_load_op_h'] : 0; if ($update === true) { $depGroupObj->updateThis(); } } } ?>

| ver. 1.4 | Github | . | PHP 8.2.30 | ��֧ߧ֧�ѧ�ڧ� ��ѧߧڧ��: 0 | proxy | phpinfo | ��ѧ��ۧܧ�