Redis

pool/publicApi.go

@@ -491,8 +491,10 @@ func GetAllList(key string) map[string]string {
 }
 
 func AppendConversationRecord(msg *SetMsgReq) {
-	Redis.HSetNX("msg:"+strconv.Itoa(msg.ConversationId), StrCut(msg.Sender)+":"+StrCut(msg.Receiver)+":"+msg.SendTime, string(SerializeJson(msg)))
-	//Redis.Set("msg:"+strconv.Itoa(msg.ConversationId),msg.SendTime,0)
+	data := *msg
+	data.Sender = StrCut(data.Sender)
+	data.Receiver = StrCut(data.Receiver)
+	Redis.HSetNX("msg:"+strconv.Itoa(msg.ConversationId), data.Sender+":"+data.Receiver+":"+data.SendTime, string(SerializeJson(data)))
 	return
 }
 

ws_server.go

@@ -46,7 +46,7 @@ func main() {
 	//ticker := time.NewTicker(time.Second * 10)
 	//go func() {
 	//	for range ticker.C {
-	//		pool.SetEnd()
+	//		pool.SetDelConversation()
 	//	}
 	//}()