fix:一键清空消息删除缓存数据

api/etc/message-api.yaml

@@ -3,7 +3,7 @@ Host: 0.0.0.0
 Port: 8911
 
 Gateway:
-  ServerCode: messageCenter-api
+  ServerCode: message
   Etcd:
     - 127.0.0.1:2379
 

rpc/etc/message.yaml

@@ -38,7 +38,7 @@ FileSystemConf:
     Key: message.rpc
 SurvivalTime: 86400
 SaveConcurrency: 10
-
+WebRpcPort: 8099
 mail:
   - addr: smtp.exmail.qq.com
     port: 465

rpc/internal/common/getBuoyMsg.go

@@ -4,6 +4,7 @@ import (
 	"app.yhyue.com/moapp/MessageCenter/entity"
 	"app.yhyue.com/moapp/MessageCenter/rpc/type/message"
 	"app.yhyue.com/moapp/MessageCenter/util"
+	qutil "app.yhyue.com/moapp/jybase/common"
 	"fmt"
 	"log"
 	"strconv"
@@ -77,6 +78,9 @@ func ClearUnreadMsg(in *message.ClearUnreadMsgReq) error {
 		if !entity.Mysql.Update("message", query, map[string]interface{}{"isRead": 1}) {
 			log.Println("更新服务未读数失败")
 		}
+		for _, v := range entity.MessageColumn {
+			go MsgCountZero(in.Userid, in.AppId, qutil.Int64All(v["msg_type"]))
+		}
 	}
 
 	//更新私信未读数

rpc/internal/config/config.go

@@ -8,6 +8,7 @@ type Config struct {
 	zrpc.RpcServerConf
 	DataSource      *mysqlConfig // 手动代码
 	BaseSource      *mysqlConfig // 手动代码
+	WebRpcPort      int
 	Mysql           string
 	RedisAddr       string `json:"RedisAddr"`
 	Mongodb         *mgoConf

rpc/message.go

@@ -10,6 +10,8 @@ import (
 	"app.yhyue.com/moapp/MessageCenter/rpc/internal/server"
 	"app.yhyue.com/moapp/MessageCenter/rpc/internal/svc"
 	"app.yhyue.com/moapp/MessageCenter/rpc/type/message"
+	mc "app.yhyue.com/moapp/jybase/common"
+	"app.yhyue.com/moapp/jybase/endless"
 	"app.yhyue.com/moapp/jybase/mail"
 	m "app.yhyue.com/moapp/jybase/mongodb"
 	"app.yhyue.com/moapp/jybase/mysql"
@@ -30,8 +32,13 @@ var c config.Config
 
 func main() {
 	flag.Parse()
-
 	conf.MustLoad(*configFile, &c)
+	go func() {
+		err := endless.ListenAndServe(":"+mc.InterfaceToStr(c.WebRpcPort), nil, func() {})
+		if err != nil {
+			log.Println("ListenAndServe: ", err)
+		}
+	}()
 	ctx := svc.NewServiceContext(c)
 	srv := server.NewMessageServer(ctx)