pc

application/models/Business/Message/MessageService.php

@@ -92,9 +92,15 @@ class MessageServiceModel extends \Business\AbstractModel
 
     public function getUnreadCountByMemberIdAndType($toId)
     {
-        $messageHistoryDao = \DAO\MessageHistoryModel::getInstance();
-        $count = $messageHistoryDao->getUnreadCountByToIdAndToType($toId);
-        return $count;
+        $memberDb0Redis=\Redis\Db0\MemberRedisModel::getInstance();
+        $unredMessageCount=$memberDb0Redis->tableHGet($toId,'unreadMessageCount');
+        if($unredMessageCount!==false){
+            $messageHistoryDao = \DAO\MessageHistoryModel::getInstance();
+            $unredMessageCount = $messageHistoryDao->getUnreadCountByToIdAndToType($toId);
+            $memberDb0Redis->tableHset($toId,array('unreadMessageCount'=>$unredMessageCount));
+        }
+        return $unredMessageCount;
+
     }
 
     /**
@@ -327,6 +333,8 @@ class MessageServiceModel extends \Business\AbstractModel
         $messageOneDao->setDb(DbNameConst::masterDBConnectName);
         $messageOneDao->updateUnreadField($fromId, $fromType, $toId, $toType);
         $isSuccess = $messageHistoryDao->updateByFromIdAndSelfTypeAndToIdAndToType($fromId, $fromType, $toId, $toType);
+        $memberDb0Redis=\Redis\Db0\MemberRedisModel::getInstance();
+        $memberDb0Redis->tableHdel($toId,'unreadMessageCount');
         return $isSuccess;
     }
 

application/models/Redis/Db0/MemberRedis.php

@@ -85,6 +85,11 @@ class MemberRedisModel extends \Redis\Db0\AbstractModel {
         return $res;
     }
 
+    public function tableHDel($mid,$key){
+        $res=$this->hDel($this->calcKey($mid), $key);
+        return $res;
+    }
+
 
     /**
      * 类实例