pc

application/models/Business/Message/MessageService.php

@@ -146,6 +146,18 @@ 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();

application/models/Business/Order/OrderService.php

@@ -413,6 +413,12 @@ class OrderServiceModel extends \Business\AbstractModel
 
     }
 
+    public function pushRecieveOrder($order){
+        $push = Push::getInstance();
+        $push->recieveWait($order['storeId'], $order['orderId'], $order['orderSn']);
+        $push->sendTcpMessage();
+        $this->addMessageCenterToDb();
+    }
     //推送接单消息到店铺
     public function pushRecieveWaitOrder()
     {

scripts/crontab/push/news_server.php

@@ -119,7 +119,8 @@ $serv->on('Message', function($server, $frame) use($conf){
                 $redis->rPush('push_center',serialize($sendMessage));
             }
             $redis->close();
-            $messageService->unsetDb();
+            unset($redis);
+           // $messageService->unsetDb();
             unset($messageService);
         }else{
             $realKey = KEY_REDIS_PRE.$key;
@@ -251,6 +252,7 @@ $tcp_server->on('receive', function($serv, $fd, $from_id, $data) use($conf) {
     } else {
         $serv->send($fd, responseJson(1,'fromMsg',"fail", ['method' => 'receive', 'error_code' => 110,'status' => 0]));
     }
+    $redis->close();
     unset($redis);
 
 });