pc

application/models/Business/Message/MessageService.php

@@ -151,29 +151,29 @@ class MessageServiceModel extends \Business\AbstractModel
         return $avatar;
     }
 
-    public function __destruct()
-    {
-        $store = \DAO\StoreModel::getInstance();
-        $member = \DAO\MemberModel::getInstance();
-        $messageHistoryDao = \DAO\MessageHistoryModel::getInstance();
-        $mesageOneDao = \DAO\MessageOneModel::getInstance();
-        $store->unsetDb();
-        $member->unsetDb();
-        $messageHistoryDao->unsetDb();
-        $mesageOneDao->unsetDb();
-    }
-
-    public function unsetDb()
-    {
-        $store = \DAO\StoreModel::getInstance();
-        $member = \DAO\MemberModel::getInstance();
-        $messageHistoryDao = \DAO\MessageHistoryModel::getInstance();
-        $mesageOneDao = \DAO\MessageOneModel::getInstance();
-        $store->unsetDb();
-        $member->unsetDb();
-        $messageHistoryDao->unsetDb();
-        $mesageOneDao->unsetDb();
-    }
+//    public function __destruct()
+//    {
+//        $store = \DAO\StoreModel::getInstance();
+//        $member = \DAO\MemberModel::getInstance();
+//        $messageHistoryDao = \DAO\MessageHistoryModel::getInstance();
+//        $mesageOneDao = \DAO\MessageOneModel::getInstance();
+//        $store->unsetDb();
+//        $member->unsetDb();
+//        $messageHistoryDao->unsetDb();
+//        $mesageOneDao->unsetDb();
+//    }
+//
+//    public function unsetDb()
+//    {
+//        $store = \DAO\StoreModel::getInstance();
+//        $member = \DAO\MemberModel::getInstance();
+//        $messageHistoryDao = \DAO\MessageHistoryModel::getInstance();
+//        $mesageOneDao = \DAO\MessageOneModel::getInstance();
+//        $store->unsetDb();
+//        $member->unsetDb();
+//        $messageHistoryDao->unsetDb();
+//        $mesageOneDao->unsetDb();
+//    }
 
     /**
      * 获得全部类型消息，每种消息一条数据，以及每种消息的未读条数
@@ -341,7 +341,8 @@ class MessageServiceModel extends \Business\AbstractModel
         }
 
     }
-
+    private $messageHistoryDao;
+    private $mesageOneDao;
     public function addMessage($fromId, $selfId, $fromName, $fromType, $message, $toId, $toUserId, $toName, $toType, $messageId = false)
     {
         $messageHistoryDao = \DAO\MessageHistoryModel::getInstance();
@@ -389,6 +390,7 @@ class MessageServiceModel extends \Business\AbstractModel
         $messageHistoryDao->db->doCommit();
         unset($messageHistoryDao->db);
         unset($messageHistoryDao);
+        unset($mesageOneDao->db);
         unset($mesageOneDao);
 
         //$messageHistoryDao->sendMessage($mesageHistory,$toId);

scripts/crontab/push/news_server.php

@@ -115,6 +115,7 @@ $serv->on('Message', function($server, $frame) use($conf){
                 $redis->hSet(KEY_PRE.$memberId,'sendTime', time());
                 $server->push($frame->fd, responseJson(1,"sendMsg","success", $sendMessage));
                 $messageService->addMessage($sendMessage['fromId'],$sendMessage['fromUserId'],$sendMessage['fromUserName'],$sendMessage['fromType'],$sendMessage['message'],$sendMessage['toId'],$sendMessage['toUserId'],$sendMessage['toUserName'],$sendMessage['toType'],$sendMessage['id']);
+
                 $sendMessage['message']=serialize($sendMessage['message']);
                 $redis->rPush('push_center',serialize($sendMessage));
             }
@@ -122,6 +123,7 @@ $serv->on('Message', function($server, $frame) use($conf){
             unset($redis);
            // $messageService->unsetDb();
             unset($messageService);
+            \Mysql\LinkMySQLModel::unsetDbConecet();
         }else{
             $realKey = KEY_REDIS_PRE.$key;
             $sessData=$redis->get($realKey);