pc

application/models/Business/Message/MessageService.php

@@ -443,6 +443,7 @@ class MessageServiceModel extends \Business\AbstractModel
         $message['gmtCreate'] = TIMESTAMP;
         $message['isRead'] = ApiConst::unread;
         $message['type'] = (int)$message['type'];
+        $message['content'] = base64_encode($message['content']);
         $serializeMessage = serialize($message);
         //将消息添加到表messageHistory
         $mesageHistory['fromId'] = $fromId;
@@ -480,6 +481,11 @@ class MessageServiceModel extends \Business\AbstractModel
         register_shutdown_function(array($messageHistoryDao, "sendMessage"), $mesageHistory, $toId);
         //$messageHistoryDao->sendMessage($mesageHistory,$toId);
         if ($res1 && $res2) {
+            $clientPush=\JPush\ClientPush::getInstance();
+            $mesageHistory['id']=$res1;
+            $addData['message'] = unserialize($mesageHistory['message']);
+            $addData['message']['content']=base64_decode($addData['message']['content']);
+            $clientPush->push($addData);
             return $res1;
         } else {
             return false;

scripts/crontab/push/jpush.php

@@ -48,7 +48,7 @@ class cliOrderClose extends basecli
             $redis->auth($conf['password']);
         }
         $clientPush=\JPush\ClientPush::getInstance();
-        $messageService=\DAO\MessageHistoryModel::getInstance();
+        //$messageService=\DAO\MessageHistoryModel::getInstance();
         while($pushData=$redis->lPop('push_center')){
             $addData = unserialize($pushData);
             $addData['message'] = unserialize($addData['message']);