From 19c3f5bce741f0c5ed53379f17d2c70041854f0d Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=82=B9=E5=AE=97=E6=A5=A0?= Date: Wed, 1 Mar 2023 16:13:21 +0800 Subject: [PATCH] =?UTF-8?q?=E6=8A=96=E9=9F=B3=E8=87=AA=E5=8A=A8=E5=88=B7?= =?UTF-8?q?=E5=8D=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../jxcallback/auto_delivery/auto_delivery.go | 55 +++++++++++++++++++ business/jxstore/misc/misc.go | 3 +- business/partner/delivery/rider.go | 45 --------------- 3 files changed, 57 insertions(+), 46 deletions(-) create mode 100644 business/jxcallback/auto_delivery/auto_delivery.go diff --git a/business/jxcallback/auto_delivery/auto_delivery.go b/business/jxcallback/auto_delivery/auto_delivery.go new file mode 100644 index 000000000..46f094434 --- /dev/null +++ b/business/jxcallback/auto_delivery/auto_delivery.go @@ -0,0 +1,55 @@ +package auto_delivery + +import ( + "crypto/rand" + "git.rosy.net.cn/baseapi/utils" + "git.rosy.net.cn/jx-callback/business/jxcallback/scheduler/defsch" + "git.rosy.net.cn/jx-callback/business/jxutils" + "git.rosy.net.cn/jx-callback/business/jxutils/jxcontext" + "git.rosy.net.cn/jx-callback/business/model" + "git.rosy.net.cn/jx-callback/business/model/dao" + "git.rosy.net.cn/jx-callback/globals" + "math/big" + "strings" +) + +// AutoSettingFakeDelivery 抖音自动设置骑手, 推送假订单 +func AutoSettingFakeDelivery() { + db := dao.GetDB() + // 查询需要刷单的门店 + configList, err := dao.QueryConfigs(db, "storeIdList", "AutoDelivery", "") + if err != nil { + globals.SugarLogger.Errorf("抖音自动刷单获取刷单门店列表错误:%v", err) + return + } + if len(configList) != model.YES { + globals.SugarLogger.Errorf("newConfig 刷单门店设置异常") + return + } + + // 获取刷单门店订单 + orderList, err := dao.GetOrderListByStoreList(db, utils.StringSlice2Int64(strings.Split(configList[0].Value, ","))) + if err != nil { + globals.SugarLogger.Errorf("获取门店刷单记录错误") + return + } + + for _, v := range orderList { + jxutils.CallMsgHandler(func() { + // 1.根据订单客户地址获取骑手列表 + randNumber, _ := rand.Int(rand.Reader, big.NewInt(200)) + randTime := randNumber.Int64() + riderInfo, err := dao.GetAddressRiderInfo(db, strings.Split(v.ConsigneeAddress, "市")[0], randTime) + if err != nil { + globals.SugarLogger.Errorf("自动获取骑手信息错误:[%v]", err) + return + } + //自动发单 + if err := defsch.FixedScheduler.SelfDeliveringAndUpdateStatus(jxcontext.AdminCtx, v.VendorOrderID, v.VendorID, jxcontext.AdminCtx.GetUserName(), riderInfo.CourierName, riderInfo.CourierMobile); err != nil { + globals.SugarLogger.Errorf("自动发货错误:[%v]", err) + return + } + }, jxutils.ComposeUniversalOrderID(v.VendorOrderID, model.VendorIDDD)) + } + +} diff --git a/business/jxstore/misc/misc.go b/business/jxstore/misc/misc.go index f24f72715..eaaf1cb01 100644 --- a/business/jxstore/misc/misc.go +++ b/business/jxstore/misc/misc.go @@ -4,6 +4,7 @@ import ( "fmt" "git.rosy.net.cn/baseapi/platformapi/dingdingapi" "git.rosy.net.cn/jx-callback/business/bidding" + "git.rosy.net.cn/jx-callback/business/jxcallback/auto_delivery" "git.rosy.net.cn/jx-callback/business/jxutils/ddmsg" "git.rosy.net.cn/jx-callback/business/partner/delivery" "sync" @@ -207,7 +208,7 @@ func Init() { // 抖音自动刷单 ScheduleTimerFuncByInterval(func() { - delivery.AutoSettingFakeDelivery() + auto_delivery.AutoSettingFakeDelivery() }, 10*time.Second, 5*time.Second) // 定时任务更新负责人信息 diff --git a/business/partner/delivery/rider.go b/business/partner/delivery/rider.go index be90ae39d..c5f276195 100644 --- a/business/partner/delivery/rider.go +++ b/business/partner/delivery/rider.go @@ -3,11 +3,7 @@ package delivery import ( "crypto/rand" "fmt" - "git.rosy.net.cn/jx-callback/business/jxcallback/scheduler/defsch" - "git.rosy.net.cn/jx-callback/business/jxutils" - "git.rosy.net.cn/jx-callback/business/jxutils/jxcontext" "math/big" - "strings" "time" "git.rosy.net.cn/baseapi/platformapi/mtpsapi" @@ -326,44 +322,3 @@ func UpdateFakeWayBillToTiktok() { } } - -// AutoSettingFakeDelivery 自动设置骑手, 推送假订单 -func AutoSettingFakeDelivery() { - db := dao.GetDB() - // 查询需要刷单的门店 - configList, err := dao.QueryConfigs(db, "storeIdList", "AutoDelivery", "") - if err != nil { - globals.SugarLogger.Errorf("抖音自动刷单获取刷单门店列表错误:%v", err) - return - } - if len(configList) != model.YES { - globals.SugarLogger.Errorf("newConfig 刷单门店设置异常") - return - } - - // 获取刷单门店订单 - orderList, err := dao.GetOrderListByStoreList(db, utils.StringSlice2Int64(strings.Split(configList[0].Value, ","))) - if err != nil { - globals.SugarLogger.Errorf("获取门店刷单记录错误") - return - } - - for _, v := range orderList { - jxutils.CallMsgHandler(func() { - // 1.根据订单客户地址获取骑手列表 - randNumber, _ := rand.Int(rand.Reader, big.NewInt(200)) - randTime := randNumber.Int64() - riderInfo, err := dao.GetAddressRiderInfo(db, strings.Split(v.ConsigneeAddress, "市")[0], randTime) - if err != nil { - globals.SugarLogger.Errorf("自动获取骑手信息错误:[%v]", err) - return - } - // 自动发单 - if err := defsch.FixedScheduler.SelfDeliveringAndUpdateStatus(jxcontext.AdminCtx, v.VendorOrderID, v.VendorID, jxcontext.AdminCtx.GetUserName(), riderInfo.CourierName, riderInfo.CourierMobile); err != nil { - globals.SugarLogger.Errorf("自动发货错误:[%v]", err) - return - } - }, jxutils.ComposeUniversalOrderID(v.VendorOrderID, model.VendorIDDD)) - } - -}