提交

service/messageService.go

@@ -3,6 +3,7 @@ package service
 import (
 	"app.yhyue.com/moapp/MessageCenter/entity"
 	"app.yhyue.com/moapp/MessageCenter/rpc/message"
+	"app.yhyue.com/moapp/MessageCenter/util"
 	qutil "app.yhyue.com/moapp/jybase/common"
 	"errors"
 	"log"
@@ -75,8 +76,10 @@ func (service *MessageService) LastMessage(userId string, appId string, msgType
 	lastMsg := entity.Mysql.FindOne("message", query, "", "createtime desc")
 
 	if lastMsg != nil && len(*lastMsg) > 0 {
+		_id := util.Int64All((*lastMsg)["id"])
+		id := strconv.FormatInt(_id, 10)
 		msg := message.Messages{
-			Id:            qutil.ObjToString((*lastMsg)["id"]),
+			Id:            id,
 			Appid:         qutil.ObjToString((*lastMsg)["appid"]),
 			ReceiveUserId: qutil.ObjToString((*lastMsg)["receive_userid"]),
 			ReceiveName:   qutil.ObjToString((*lastMsg)["receive_name"]),

service/sendMsg.go

@@ -100,11 +100,13 @@ func FindUserMsg(this message.FindUserMsgReq) message.FindUserMsgRes {
 		Limit(int(this.PageSize), (int(this.OffSet)-1)*int(this.PageSize)).
 		Find(&messages)*/
 		res := entity.Mysql.Find("message", cquery, "", "createtime desc", (int(this.OffSet)-1)*int(this.PageSize), int(this.PageSize))
-		//log.Println("数据：", messages)
+		log.Println("数据：", res)
 		if res != nil && len(*res) > 0 {
 			for _, v := range *res {
+				_id := util.Int64All(v["id"])
+				id := strconv.FormatInt(_id, 10)
 				data.Data = append(data.Data, &message.Messages{
-					Id:            util.ObjToString(v["id"]),
+					Id:            id,
 					Appid:         util.ObjToString(v["appId"]),
 					ReceiveUserId: util.ObjToString(v["receiveUserid"]),
 					ReceiveName:   util.ObjToString(v["receiveName"]),