会话保存修改

api/messagecenter/messagecenter.go

@@ -33,7 +33,6 @@ func main() {
 	server := rest.MustNewServer(C.RestConf)
 	defer server.Stop()
 	fsw.ReadFswDict("./baidu_fsw.dict")
-	fmt.Println(fsw.Repl("111台独"))
 	handler.RegisterHandlers(server, ctx)
 	fmt.Printf("Starting server at %s:%d...\n", C.Host, C.Port)
 	server.Start()

service/message_mail_box.go

@@ -108,7 +108,7 @@ func (b MessaggeService) SaveMessage(in *messagecenter.MessageEntity) (errorCode
 				userId = in.NewUserId
 			} else {
 				sessionId = in.SendId
-				userId = in.ReceiveId
+				userId = in.NewUserId
 			}
 			break
 		}
@@ -178,7 +178,7 @@ func (b MessaggeService) SaveMessage(in *messagecenter.MessageEntity) (errorCode
 				messageMailBox["send_user_type"] = 2
 				messageMailBox["receive_user_type"] = 1
 				messageMailBox["own_id"] = in.SendId
-				messageMailBox["send_user_id"] = in.ReceiveId
+				messageMailBox["send_user_id"] = in.NewUserId
 				messageMailBox["receive_user_id"] = in.SendId
 			}
 			receiveOk := Mysql.InsertByTx(tx, "socialize_message_mailbox", messageMailBox)