测试

cmd/queue/sync_out_store/main.go

@@ -69,6 +69,7 @@ func (t *RecvPro) Consumer(dataByte []byte) error {
 		outStore.BillId = message.Data.FSourceBillID
 		messageData, err = json.Marshal(&message)
 		if err != nil {
+			service.SendDingTalkRobotToApi("message")
 			goto ERR
 		}
 		outStore.QueueMessage = string(messageData)