up

app/service/wechat_yunxin/wechat_service.go

@@ -20,10 +20,10 @@ func (t *RecvPro) Consumer(dataByte []byte) error {
 
 
 //消息已经消费3次 失败了 请进行处理
 //消息已经消费3次 失败了 请进行处理
 func (t *RecvPro) FailAction(err error,dataByte []byte) error {
 func (t *RecvPro) FailAction(err error,dataByte []byte) error {
-	logger.Instance("crmuser_to_erp").Error("任务处理失败了，我要进入db日志库了")
-	logger.Instance("crmuser_to_erp").Error("任务处理失败了，发送钉钉消息通知主人")
-	logger.Instance("crmuser_to_erp").Error(string(dataByte))
-	logger.Instance("crmuser_to_erp").Error("错误原因：%s",err)
+	logger.Instance("wechat_yunxin").Error("任务处理失败了，我要进入db日志库了")
+	logger.Instance("wechat_yunxin").Error("任务处理失败了，发送钉钉消息通知主人")
+	logger.Instance("wechat_yunxin").Error(string(dataByte))
+	logger.Instance("wechat_yunxin").Error("错误原因：%s",err)
 	return nil
 	return nil
 }
 }