pc

application/models/Business/Message/MessageService.php

@@ -367,10 +367,8 @@ class MessageServiceModel extends \Business\AbstractModel
         $isSuccess = $messageHistoryDao->updateByFromIdAndSelfTypeAndToIdAndToType($fromId, $fromType, $toId, $toType);
         $memberDb0Redis=\Redis\Db0\MemberRedisModel::getInstance();
         if($isSuccess){
-            if($fromId!=$toId){
                 $isSuccess=-1*$isSuccess;
                 $memberDb0Redis->tableHIncrBy($fromId,'unread_message_count',$isSuccess);
-            }
         }
 
         return $isSuccess;

scripts/crontab/push/news_server.php

@@ -109,7 +109,6 @@ $serv->on('Message', function($server, $frame) use($conf){
                         echo '发送fd:'.$sendFd;
                         if($sendFd!=$frame->fd){
                             $server->push($sendFd, responseJson(1,"fromMsg","success", $sendMessage));
-                            $redis->hIncrBy(KEY_PRE.$rev_data['toId'],'unread_message_count',\Our\ApiConst::one);
                         }
                     }
                     echo 'afterSendFd:'.$sendFd;
@@ -121,8 +120,7 @@ $serv->on('Message', function($server, $frame) use($conf){
                 $messageService->addMessage($sendMessage['fromId'],$sendMessage['fromUserId'],$sendMessage['fromUserName'],$sendMessage['fromType'],$sendMessage['message'],$sendMessage['toId'],$sendMessage['toUserId'],$sendMessage['toUserName'],$sendMessage['toType'],$sendMessage['id']);
                 $sendMessage['message']=serialize($sendMessage['message']);
                 $redis->rPush('push_center',serialize($sendMessage));
-
-
+                $redis->hIncrBy(KEY_PRE.$rev_data['toId'],'unread_message_count',\Our\ApiConst::one);
             }
             $redis->close();
             unset($redis);