Browse Source

增加日志

rowan.wu 1 year ago
parent
commit
0c88294678
1 changed files with 7 additions and 1 deletions
  1. 7 1
      internal/mqs/amq/handler/amq/wxhook/say_morning.go

+ 7 - 1
internal/mqs/amq/handler/amq/wxhook/say_morning.go

@@ -63,10 +63,16 @@ func (l *SayMorningHandler) ProcessTask(ctx context.Context, t *asynq.Task) erro
 	}
 
 	for _, v := range p {
-		client.R().SetBody(&SendTextMsgReq{
+		resp, err := client.R().SetBody(&SendTextMsgReq{
 			Wxid: v.Wxid,
 			Msg:  v.Msg,
 		}).Post("http://" + v.Ip + ":" + v.Port + "/SendTextMsg")
+
+		if err != nil {
+			logx.Error("failed to send text message", logx.Field("error", err))
+		} else {
+			logx.Info("send text message success", logx.Field("response", resp.String()))
+		}
 	}
 
 	finishTime := time.Now()