pc

scripts/crontab/push/news_server.php

@@ -232,8 +232,8 @@ $tcp_server->on('receive', function($serv, $fd, $from_id, $data) use($conf) {
                 if($async_data){
                     $value['message']=unserialize($value['message']);
                     $sendFd=$redis->hGet(KEY_PRE.$value['toId'],'fd');
+                    $redis->hIncrBy(KEY_PRE.$value['toId'],'unread_message_count',\Our\ApiConst::one);
                     if(!empty($sendFd)){
-                        $redis->hIncrBy(KEY_PRE.$value['toId'],'unread_message_count',\Our\ApiConst::one);
                         $serv->push($sendFd, responseJson(1,"fromMsg","success", $value));
                         $redis->hSet(KEY_PRE.$value['fromId'],'sendTime', time());
                     }
@@ -246,8 +246,8 @@ $tcp_server->on('receive', function($serv, $fd, $from_id, $data) use($conf) {
             if($async_data){
                 $sendFd=$redis->hGet(KEY_PRE.$data['data']['toId'],'fd');
                 $data['data']['message']=unserialize($data['data']['message']);
+                $redis->hIncrBy(KEY_PRE.$data['data']['toId'],'unread_message_count',\Our\ApiConst::one);
                 if(!empty($sendFd)){
-                    $redis->hIncrBy(KEY_PRE.$data['data']['toId'],'unread_message_count',\Our\ApiConst::one);
                     $serv->push($sendFd, responseJson($sendFd,"fromMsg","success", $data['data']));
                     $redis->hSet(KEY_PRE.$data['data']['fromId'],'sendTime', time());
                 }