debug

crontask/init.go

@@ -50,7 +50,7 @@ func ScheduleRun(c *cron.Cron, serverCtx *svc.ServiceContext) {
 	//})
 
 	contactForm := NewCronTask(context.Background(), serverCtx)
-	c.AddFunc("1 0 * * *", func() {
+	c.AddFunc("@every 5m", func() {
 		contactForm.analyze()
 	})
 

internal/service/MessageHandlers/talk_to_friend_task_result_notice.go

@@ -23,6 +23,7 @@ func NewTalkToFriendTaskResultNoticeHandler(svcCtx *svc.ServiceContext) *TalkToF
 
 func (f *TalkToFriendTaskResultNoticeHandler) Handler(msg *wechat_ws.MsgJsonObject) error {
 	if msg.MsgType == "TalkToFriendTaskResultNotice" {
+		logx.Info("msg 的内容是：%s", msg)
 		message := workphone.TalkToFriendTaskResultNoticeMessage{}
 		err := json.Unmarshal([]byte(msg.Message), &message)
 		if err != nil {

wechat.go

@@ -62,8 +62,8 @@ func main() {
 			ws.RegisterMessageHandler(MessageHandlers.NewChatroomPushNoticeHandler(ctx).Handler)
 			//ws.RegisterMessageHandler(MessageHandlers.NewFriendPushNoticeHandler(ctx).Handler)
 			//消息监听 注册中心
-			ws.RegisterMessageHandler(messageHandler.GetWrappedHandler())
 			ws.RegisterMessageHandler(MessageHandlers.NewTalkToFriendTaskResultNoticeHandler(ctx).Handler)
+			ws.RegisterMessageHandler(messageHandler.GetWrappedHandler())
 		}
 
 		logx.Info("注册个微处理通道~")