From 095fcf2ddecfdc21d83359bd34cb287b1edecf53 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=82=B9=E5=AE=97=E6=A5=A0?= Date: Tue, 1 Aug 2023 21:10:17 +0800 Subject: [PATCH] 1 --- business/jxcallback/orderman/order.go | 15 ++++----------- business/jxstore/misc/misc.go | 2 +- 2 files changed, 5 insertions(+), 12 deletions(-) diff --git a/business/jxcallback/orderman/order.go b/business/jxcallback/orderman/order.go index b15d26f38..6af92037f 100644 --- a/business/jxcallback/orderman/order.go +++ b/business/jxcallback/orderman/order.go @@ -2764,7 +2764,7 @@ var storeList = []int64{ //102934, //102933, 102930, - 668884, + //668884, 668878, 102903, 668757, @@ -2866,24 +2866,17 @@ var storeList = []int64{ } func UpdateTaoSkuUpdateOffShelf() { + // 标准模板店 + //skuCodeList := dao.GetStoreSkuBindList(dao.GetDB(), 100102) - taskFunc := func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { - storeId := batchItemList[0].(int64) + for _, storeId := range storeList { ddmsg.SendUserMessage(dingdingapi.MsgTyeText, "2452A93EEB9111EC9B06525400E86DC0", "开始下架:", utils.Int64ToStr(storeId)) storeSkuMap := dao.GetStoreSkuBindList(dao.GetDB(), storeId) resultErr := tao.UpdateStoreSku(storeId, storeSkuMap) if len(resultErr) > 0 { ddmsg.SendUserMessage(dingdingapi.MsgTyeText, "2452A93EEB9111EC9B06525400E86DC0", "下架商品错误消息:", utils.Format4Output(resultErr, false)) } - return retVal, err } - task := tasksch.NewParallelTask("下架门店商品", tasksch.NewParallelConfig().SetParallelCount(2), jxcontext.AdminCtx, taskFunc, storeList) - tasksch.HandleTask(task, nil, true).Run() - if _, err := task.GetResult(0); err != nil { - baseapi.SugarLogger.Debugf("LoadingStoreOrderSettleAmount :%v", err) - } - // 标准模板店 - //skuCodeList := dao.GetStoreSkuBindList(dao.GetDB(), 100102) //for _,storeId := range storeList { // resultErr := tao.UpdateStoreSkuGrounding(storeId, skuCodeList) diff --git a/business/jxstore/misc/misc.go b/business/jxstore/misc/misc.go index deddaa369..ad463aa8b 100644 --- a/business/jxstore/misc/misc.go +++ b/business/jxstore/misc/misc.go @@ -213,7 +213,7 @@ func Init() { ScheduleTimerFunc("UpdateTaoSkuUpdateOffShelf", func() { orderman.UpdateTaoSkuUpdateOffShelf() }, []string{ - "20:15:00", + "21:15:00", }) // 每分钟轮询一次,推送骑手信息