Merge branch 'master' of http://119.23.72.7/sunlong_v5/golang-asynctask

app/service/wechat_yunxin/wechat_service.go

@@ -20,10 +20,10 @@ func (t *RecvPro) Consumer(dataByte []byte) error {
 
 //消息已经消费3次 失败了 请进行处理
 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
 }
 

config/prod/config.toml

@@ -15,7 +15,7 @@ queue_name="bus_crm_com_user_to_erp"
 routing_key="maxwell_liexin_crm.lie_invoice_company "
 exchange="maxwell_crm"
 type="direct"
-dns="amqp://WmsQue:EizM9I1TAxoO0tmzoOm@172.18.137.33:5672/"
+dns="amqp://huntmouser:jy2y2900@172.18.137.23:5672/"
 
 
 

config/prod/db.toml

@@ -8,6 +8,13 @@ ShowSQL = true
     table_prefix = "lie_"
     max_conn_life_time = 100
 
+[liexin]
+    data_source_name = "huntdbuser:mLssy2@@!!@$#yy@tcp(172.18.137.21:3306)/hunt2016?charset=utf8&parseTime=true&loc=Asia%2FShanghai"
+    max_open_conn = 0
+    max_idle_conn = 0
+    table_prefix = "lie_"
+    max_conn_life_time = 100
+
 
 [scm_data]
     dns = "HgScmjzztp:Stlp0@#!02913441mt@tcp(172.18.137.35:3306)/liexin_scm_data?charset=utf8&parseTime=true&loc=Asia%2FShanghai"

go.mod

@@ -11,7 +11,7 @@ require (
 	github.com/ichunt2019/cfg v0.0.0-20210310074903-4b1bcab17717
 	github.com/ichunt2019/go-redis-pool v0.0.0-20210305064829-86b9011c57f5
 	github.com/ichunt2019/golang-rbmq-sl v0.0.0-20200515075131-59a37ab77d7d
-	github.com/ichunt2019/lxLog v0.0.0-20210226024426-781becb3c042
+	github.com/ichunt2019/lxLog v0.0.0-20210526032824-fd07e8b73ce0
 	github.com/jmoiron/sqlx v1.3.3
 	github.com/spf13/viper v1.7.1
 	github.com/syyongx/php2go v0.9.4