pc

application/models/Redis/Db0/MemberRedis.php

@@ -85,6 +85,9 @@ class MemberRedisModel extends \Redis\Db0\AbstractModel {
         return $res;
     }
 
+    public function tableHIncrBy($h,$key,$keysvalue){
+        return $this->hIncrBy($this->calcKey($h),$key,$keysvalue);
+    }
     public function tableHDel($mid,$key){
         $res=$this->hDel($this->calcKey($mid), $key);
         return $res;

scripts/crontab/push/news_server.php

@@ -117,7 +117,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->hDel(KEY_PRE.$rev_data['toId'],'unread_message_count');
+                $redis->hIncrBy(KEY_PRE.$rev_data['toId'],'unread_message_count',\Our\ApiConst::one);
             }
             $redis->close();
             unset($redis);