修改列表

rpc/etc/message.yaml

@@ -2,14 +2,14 @@ Name: message.rpc
 ListenOn: 127.0.0.1:8081
 Etcd:
   Hosts:
-  - 127.0.0.1:2379
-  - 127.0.0.1:2379
+  - 172.31.31.203:2379
+  - 172.31.31.203:2379
   Key: message.rpc
 Timeout: 10000
 PushGrpcServer: 192.168.3.206:5566
 #Mysql: root:=PDT49#80Z!RVv52_z@tcp(192.168.3.217:4000)/messageCenter?charset=utf8mb4&parseTime=true&loc=Local
 Mongodb:
-  Address: 192.168.3.206:27080
+  Address: 172.20.45.129:27002
   Size: 10
   DbName: qfw
   ReplSet:
@@ -18,7 +18,7 @@ Mongodb:
   Collection:
   Collection_back:
 Bidding:
-  Address: 192.168.3.206:27002
+  Address: 172.20.45.129:27002
   Size: 10
   DbName: mixdata
   ReplSet:
@@ -28,23 +28,23 @@ Bidding:
   Collection_back: bidding_back
 DataSource:
     DbName: jianyu
-    Address: 192.168.3.217:4000
+    Address: 172.20.45.129:4000
     UserName: root
     PassWord: =PDT49#80Z!RVv52_z
     MaxOpenConns: 50
     MaxIdleConns: 50
 BaseSource:
   DbName: base_service
-  Address: 192.168.3.217:4000
+  Address: 172.20.45.129:4000
   UserName: root
   PassWord: =PDT49#80Z!RVv52_z
   MaxOpenConns: 50
   MaxIdleConns: 50
-RedisAddr: "msgCount=192.168.3.149:1713"
+RedisAddr: "msgCount=172.20.45.129:1712"
 FileSystemConf:
   Etcd:
     Hosts:
-      - 192.168.3.206:2379
+      - 172.31.31.203:2379
     Key: message.rpc
 SurvivalTime: 86400
 SaveConcurrency: 10
@@ -62,7 +62,7 @@ mail:
 #发送微信模版消息
 WxWebdomain: "https://jybx2-webtest.jydev.jianyu360.com/" #微信域名
 WxTmplConfig:
-  rpcAddr: 192.168.3.206:8201 #微信rpc地址
+  rpcAddr: 172.31.31.203:8201 #微信rpc地址
   closeNotice: "如不再接收此类信息，请在我的-设置-推送设置关闭设置。"
   limit:
     total: 300000 # 每日发送信息数量限制
@@ -72,12 +72,12 @@ WxTmplConfig:
       nums: [ 150000,250000 ] #告警数量
       toMail: [ "wangkaiyue@topnet.net.cn" ] #告警邮箱收件地址
       ccMail: [ "duxin@topnet.net.cn" ] #告警邮箱抄送地址
-Tidb: "root:=PDT49#80Z!RVv52_z@tcp(192.168.3.217:4000)/messageCenter?charset=utf8mb4&parseTime=true&loc=Local"
+Tidb: "root:=PDT49#80Z!RVv52_z@tcp(172.20.45.129:4000))/messageCenter?charset=utf8mb4&parseTime=true&loc=Local"
 ClassSearchList: # 需要按照messageClass 查询的groupId
   - 11  # 待办 group id
-Registedate: 1705556502
+Registedate: 1672502400
 Clickhouse:
-  Addr: 192.168.3.207:19000
+  Addr:  172.20.45.129:19000
   UserName: jytop
   Password: pwdTopJy123
   DbName: messageCenter

rpc/internal/common/msglistService.go

@@ -5,6 +5,7 @@ import (
 	"encoding/json"
 	"fmt"
 	"log"
+	"reflect"
 	"strconv"
 	"time"
 
@@ -405,9 +406,11 @@ func FindUserClassUnreadAndClassAllMsg(userId string) (classUnreadCountMap map[i
 			classAllMsgMap[int(v.GroupId)] = Uint32ArrToIntArr(v.ClassAll)
 		}
 	}
-	rdata, _ := redis.GetNewBytes(redisModule, fmt.Sprintf(UserClearUnread, userId))
+	rdata, err := redis.GetNewBytes(redisModule, fmt.Sprintf(UserClearUnread, userId))
+	fmt.Println("erroer", err)
 	rdataArr := []uint32{}
 	if rdata != nil {
+		log.Println(rdata, reflect.TypeOf(rdata))
 		if json.Unmarshal(*rdata, &rdataArr); err != nil {
 			fmt.Println("取出本次已读消息反序列化出错：", err)
 			return classUnreadCountMap, classUnreadMsgMap, classAllMsgMap, err