|
@@ -4,6 +4,7 @@ import (
|
|
"context"
|
|
"context"
|
|
"encoding/json"
|
|
"encoding/json"
|
|
"fmt"
|
|
"fmt"
|
|
|
|
+ "github.com/zeromicro/go-zero/core/logx"
|
|
"wechat-api/ent/contact"
|
|
"wechat-api/ent/contact"
|
|
"wechat-api/internal/pkg/wechat_ws"
|
|
"wechat-api/internal/pkg/wechat_ws"
|
|
"wechat-api/internal/svc"
|
|
"wechat-api/internal/svc"
|
|
@@ -27,6 +28,7 @@ func (f *TalkToFriendTaskResultNoticeHandler) Handler(msg *wechat_ws.MsgJsonObje
|
|
if err != nil {
|
|
if err != nil {
|
|
return err
|
|
return err
|
|
}
|
|
}
|
|
|
|
+ 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:%d", message.MsgId)).Result()
|
|
|
|
|
|
@@ -40,7 +42,6 @@ func (f *TalkToFriendTaskResultNoticeHandler) Handler(msg *wechat_ws.MsgJsonObje
|
|
Where(contact.WxWxidEQ(message.WeChatId), contact.WxidEQ(friendId)).
|
|
Where(contact.WxWxidEQ(message.WeChatId), contact.WxidEQ(friendId)).
|
|
SetStatus(2).
|
|
SetStatus(2).
|
|
Exec(context.TODO())
|
|
Exec(context.TODO())
|
|
-
|
|
|
|
if err != nil {
|
|
if err != nil {
|
|
return err
|
|
return err
|
|
}
|
|
}
|