|
@@ -246,14 +246,18 @@ func MultSave(this message.MultipleSaveMsgReq) (int64, string) {
|
|
|
logx.Info("执行事务是否成功:", ok)
|
|
|
if ok {
|
|
|
ok1 := MsgCountAdd(v, strconv.Itoa(int(this.MsgType)), this.Appid)
|
|
|
- log.Println("存redis:", ok1)
|
|
|
+ if !ok1{
|
|
|
+ log.Println("存redis:", ok1,v)
|
|
|
+ }
|
|
|
}
|
|
|
} else {
|
|
|
in := entity.Mysql.InsertBySql(sql3)
|
|
|
logx.Info("插入消息返回 in1 id:", in)
|
|
|
if in > -1 {
|
|
|
ok := MsgCountAdd(v, strconv.Itoa(int(this.MsgType)), this.Appid)
|
|
|
- log.Println("存redis:", ok)
|
|
|
+ if !ok{
|
|
|
+ log.Println("存redis:", ok,v)
|
|
|
+ }
|
|
|
}
|
|
|
}
|
|
|
}(userIdArr[i], name)
|