pc

scripts/crontab/push/news_server.php

@@ -235,6 +235,7 @@ $tcp_server->on('receive', function($serv, $fd, $from_id, $data) use($conf) {
                     if(!empty($sendFd)){
                         $serv->push($sendFd, responseJson(1,"fromMsg","success", $value));
                         $redis->hSet(KEY_PRE.$value['fromId'],'sendTime', time());
+                        $redis->hIncrBy(KEY_PRE.$data['data']['toId'],'unread_message_count',\Our\ApiConst::one);
                     }
                 }
 
@@ -248,6 +249,7 @@ $tcp_server->on('receive', function($serv, $fd, $from_id, $data) use($conf) {
                 if(!empty($sendFd)){
                     $serv->push($sendFd, responseJson($sendFd,"fromMsg","success", $data['data']));
                     $redis->hSet(KEY_PRE.$data['data']['fromId'],'sendTime', time());
+                    $redis->hIncrBy(KEY_PRE.$data['data']['toId'],'unread_message_count',\Our\ApiConst::one);
                 }
             }
         }