|
|
@@ -8,7 +8,6 @@ import (
|
|
|
"wechat-api/ent/contact"
|
|
|
"wechat-api/internal/pkg/wechat_ws"
|
|
|
"wechat-api/internal/svc"
|
|
|
- "wechat-api/workphone"
|
|
|
)
|
|
|
|
|
|
type TalkToFriendTaskResultNoticeHandler struct {
|
|
|
@@ -35,7 +34,7 @@ type TalkToFriendTaskResultNoticeMessage struct {
|
|
|
func (f *TalkToFriendTaskResultNoticeHandler) Handler(msg *wechat_ws.MsgJsonObject) error {
|
|
|
if msg.MsgType == "TalkToFriendTaskResultNotice" {
|
|
|
logx.Info("msg 的内容是：%s", msg)
|
|
|
- message := workphone.TalkToFriendTaskResultNoticeMessage{}
|
|
|
+ message := TalkToFriendTaskResultNoticeMessage{}
|
|
|
err := json.Unmarshal([]byte(msg.Message), &message)
|
|
|
if err != nil {
|
|
|
return err
|
|
|
@@ -48,7 +47,7 @@ func (f *TalkToFriendTaskResultNoticeHandler) Handler(msg *wechat_ws.MsgJsonObje
|
|
|
return nil
|
|
|
}
|
|
|
|
|
|
- if message.Code == workphone.EnumErrorCode_InternalError {
|
|
|
+ if message.Code == "InternalError" {
|
|
|
err = f.svcCtx.DB.Contact.
|
|
|
Update().
|
|
|
Where(contact.WxWxidEQ(message.WeChatId), contact.WxidEQ(friendId)).
|
