liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
邹宗楠
2023-03-06 11:54:35 +08:00
parent d566a7118e
commit a18ffd275a
1 changed files with 12 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
business/jxcallback/auto_delivery/auto_delivery.go
View File

@@ -20,7 +20,7 @@ var riderListInfo = make(map[string][]map[string]string, 0)
func Init() { func Init() {
db := dao.GetDB() db := dao.GetDB()
// 骑手列表 // 骑手列表
configRiderList, err := dao.QueryConfigs(db, "riderList", "AutoRiderList", "") configRiderList, err := dao.QueryConfigs(db, "riderList", "Sys", "")
if err != nil { if err != nil {
globals.SugarLogger.Errorf("抖音自动刷单获取骑手列表错误:%v", err) globals.SugarLogger.Errorf("抖音自动刷单获取骑手列表错误:%v", err)
return return
@@ -33,7 +33,14 @@ func Init() {
} }
} }
for _, v := range []string{"四川", "广东", "陕西", "重庆"} { // 获取刷单地址
addressList, err := dao.QueryConfigs(db, "refundAddress", "Sys", "")
if err != nil {
globals.SugarLogger.Errorf("抖音自动刷单获取刷单地址列表错误:%v", err)
return
}
for _, v := range strings.Split(addressList[0].Value, ",") {
if _, ok := list[v]; ok && len(list[v]) >= 200 { if _, ok := list[v]; ok && len(list[v]) >= 200 {
continue continue
} }
@@ -62,7 +69,7 @@ func Init() {
return return
} }
if err := dao.UpdateOperatorConfig(string(listStr), "AutoRiderList", "riderList"); err != nil { if err := dao.UpdateOperatorConfig(string(listStr), "Sys", "riderList"); err != nil {
globals.SugarLogger.Errorf("UpdateOperatorConfig 骑手配置信息错误:[%v]", err) globals.SugarLogger.Errorf("UpdateOperatorConfig 骑手配置信息错误:[%v]", err)
return return
} }
@@ -74,7 +81,7 @@ func AutoSettingFakeDelivery() {
db := dao.GetDB() db := dao.GetDB()
// 查询需要刷单的门店 // 查询需要刷单的门店
configList, err := dao.QueryConfigs(db, "storeIdList", "AutoDelivery", "") configList, err := dao.QueryConfigs(db, "storeIdList", "Sys", "")
if err != nil { if err != nil {
globals.SugarLogger.Errorf("抖音自动刷单获取刷单门店列表错误:%v", err) globals.SugarLogger.Errorf("抖音自动刷单获取刷单门店列表错误:%v", err)
return return
@@ -105,7 +112,7 @@ func AutoSettingFakeDelivery() {
} }
if len(riderListInfo[riderKey]) == model.NO { if len(riderListInfo[riderKey]) == model.NO {
// 骑手列表 // 骑手列表
configRiderList, err := dao.QueryConfigs(db, "riderList", "AutoRiderList", "") configRiderList, err := dao.QueryConfigs(db, "riderList", "Sys", "")
if err != nil { if err != nil {
globals.SugarLogger.Errorf("抖音自动刷单获取骑手列表错误:%v", err) globals.SugarLogger.Errorf("抖音自动刷单获取骑手列表错误:%v", err)
return return