pc

scripts/crontab/push/news_server.php

@@ -233,9 +233,9 @@ $tcp_server->on('receive', function($serv, $fd, $from_id, $data) use($conf) {
                     $value['message']=unserialize($value['message']);
                     $sendFd=$redis->hGet(KEY_PRE.$value['toId'],'fd');
                     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());
-                        $redis->hIncrBy(KEY_PRE.$data['data']['toId'],'unread_message_count',\Our\ApiConst::one);
                     }
                 }
 
@@ -247,9 +247,9 @@ $tcp_server->on('receive', function($serv, $fd, $from_id, $data) use($conf) {
                 $sendFd=$redis->hGet(KEY_PRE.$data['data']['toId'],'fd');
                 $data['data']['message']=unserialize($data['data']['message']);
                 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());
-                    $redis->hIncrBy(KEY_PRE.$data['data']['toId'],'unread_message_count',\Our\ApiConst::one);
                 }
             }
         }