测试

cmd/queue/sync_out_store/main.go

@@ -59,7 +59,8 @@ func (t *RecvPro) Consumer(dataByte []byte) error {
 	)
 	//先去转换队列消息的json,如果失败,记录起来
 	if err = json.Unmarshal(dataByte, &message); err != nil {
-		err = errors.New(string(dataByte))
+		service.SendDingTalkRobotToApi(string(dataByte))
+		service.SendDingTalkRobotToApi(err.Error())
 		goto ERR
 	}
 	//判断操作类型

internal/service/dingding.go

@@ -51,11 +51,11 @@ type DingDingRequest struct {
 	IsAtAll bool              `json:"isAtAll"`
 }
 
-func SendDingTalkRobotToApi(content string) {
+func SendDingTalkRobotToApi1(content string) {
 	fmt.Println(content)
 }
 
-func SendDingTalkRobotToApi1(content string) {
+func SendDingTalkRobotToApi(content string) {
 	var (
 		requestData   DingDingRequest
 		apiUrl, token string