pc

application/library/JPush/ClientPush.php

@@ -66,6 +66,7 @@ class ClientPush
     {
        $title=$this->getMessageType($pushData['fromType']);
         $messageContent=$this->getMessageContent($pushData['message']);
+        echo $title.'|'.$messageContent;exit;
        // $pushObject=array('id'=>$toId,'memberName'=>'abc');
         $pushData['toId']=249;
         try {

scripts/crontab/push/news_server.php

@@ -115,10 +115,15 @@ $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']);
+                if(!empty($sendMessage['message']['content'])){
+                    $sendMessage['message']['content']=base64_encode($sendMessage['message']['content']);
+                }
+                $sendMessage['message']=serialize($sendMessage);
+                $redis->rPush('push_center',serialize($sendMessage));
             }
+            $redis->close();
             $messageService->unsetDb();
             unset($messageService);
-            unset($redis);
         }else{
             $realKey = KEY_REDIS_PRE.$key;
             $sessData=$redis->get($realKey);