From 9684b338129cea97255a4d9783023c86290d172b Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E9=82=B9=E5=AE=97=E6=A5=A0?= <zouzongnan1995@icloud.com>
Date: Tue, 1 Aug 2023 20:10:27 +0800
Subject: [PATCH] 1

---
 business/jxcallback/orderman/order.go | 21 ++++++++++++++-------
 business/jxstore/misc/misc.go         |  2 +-
 2 files changed, 15 insertions(+), 8 deletions(-)

diff --git a/business/jxcallback/orderman/order.go b/business/jxcallback/orderman/order.go
index 59e2e56fa..b15d26f38 100644
--- a/business/jxcallback/orderman/order.go
+++ b/business/jxcallback/orderman/order.go
@@ -2759,10 +2759,10 @@ var storeList = []int64{
 	//668901,
 	//102946,
 	//102939,
-	102938,
-	668894,
-	102934,
-	102933,
+	//102938,
+	//668894,
+	//102934,
+	//102933,
 	102930,
 	668884,
 	668878,
@@ -2866,17 +2866,24 @@ var storeList = []int64{
 }
 
 func UpdateTaoSkuUpdateOffShelf() {
-	// 标准模板店
-	//skuCodeList := dao.GetStoreSkuBindList(dao.GetDB(), 100102)
 
-	for _, storeId := range storeList {
+	taskFunc := func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
+		storeId := batchItemList[0].(int64)
 		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 6d5f3d864..deddaa369 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{
-			"17:55:00",
+			"20:15:00",
 		})
 
 		// 每分钟轮询一次,推送骑手信息