huangjiajun
3 months ago
1 changed files with 3 additions and 3 deletions
Unified View
Diff Options
+ 3
- 3
consume/canal_guide_order_for_statistics.go
View File
| @@ -29,7 +29,7 @@ func CanalGuideOrderForStatistics(queue md.MqQueue) { | |||||
| //1、将自己绑定到交换机上 | //1、将自己绑定到交换机上 | ||||
| ch.Bind(queue.Name, queue.ExchangeName, queue.RoutKey) | ch.Bind(queue.Name, queue.ExchangeName, queue.RoutKey) | ||||
| //2、取出数据进行消费 | //2、取出数据进行消费 | ||||
| ch.Qos(500) | |||||
| ch.Qos(1) | |||||
| delivery := ch.Consume(queue.Name, true) //设置自动应答 | delivery := ch.Consume(queue.Name, true) //设置自动应答 | ||||
| geoIp2db, _ := geoip2db.NewGeoipDbByStatik() | geoIp2db, _ := geoip2db.NewGeoipDbByStatik() | ||||
| @@ -93,10 +93,10 @@ func comm(sess *xorm.Session, oid, commission, types, times, pvd string) error { | |||||
| if byOid == nil { | if byOid == nil { | ||||
| return nil | return nil | ||||
| } | } | ||||
| if strings.Contains(byOid.Ext, "settle_at") && types == "settle" { | |||||
| if strings.Contains(byOid.Ext, "settle") && types == "settle" { | |||||
| return nil | return nil | ||||
| } | } | ||||
| if strings.Contains(byOid.Ext, "pvd_settle_at") && types == "pvd_settle" { | |||||
| if strings.Contains(byOid.Ext, "pvd_settle") && types == "pvd_settle" { | |||||
| return nil | return nil | ||||
| } | } | ||||
| extData := make(map[string]interface{}) | extData := make(map[string]interface{}) | ||||