Merge branch 'feature/non_friends' into debug

* feature/non_friends:
  fixbug

internal/service/MessageHandlers/talk_to_friend_task_result_notice.go

@@ -21,6 +21,17 @@ func NewTalkToFriendTaskResultNoticeHandler(svcCtx *svc.ServiceContext) *TalkToF
 	}
 }
 
+type TalkToFriendTaskResultNoticeMessage struct {
+	Success    bool   `json:"success"`    // 是否成功
+	Code       string `json:"code"`       // 错误码 Success = true 忽略
+	ErrMsg     string `json:"errMsg"`     // 错误内容描述 Success = true 忽略
+	WeChatId   string `json:"weChatId"`   // 执行的微信
+	FriendId   string `json:"friendId"`   // 执行的用户对象
+	MsgId      string `json:"msgId"`      // 聊天Id
+	MsgSvrId   int64  `json:"msgSvrId"`   //
+	CreateTime int64  `json:"createTime"` // 消息发送时间
+}
+
 func (f *TalkToFriendTaskResultNoticeHandler) Handler(msg *wechat_ws.MsgJsonObject) error {
 	if msg.MsgType == "TalkToFriendTaskResultNotice" {
 		logx.Info("msg 的内容是：%s", msg)
@@ -31,7 +42,7 @@ func (f *TalkToFriendTaskResultNoticeHandler) Handler(msg *wechat_ws.MsgJsonObje
 		}
 		logx.Info("msg.Message 的内容是：%s", message)
 
-		friendId, _ := f.svcCtx.Rds.Get(context.TODO(), fmt.Sprintf("MsgId_FriendId:%d", message.MsgId)).Result()
+		friendId, _ := f.svcCtx.Rds.Get(context.TODO(), fmt.Sprintf("MsgId_FriendId:%s", message.MsgId)).Result()
 
 		if friendId == "" {
 			return nil