1

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)

business/jxstore/misc/misc.go

@@ -213,7 +213,7 @@ func Init() {
 		ScheduleTimerFunc("UpdateTaoSkuUpdateOffShelf", func() {
 			orderman.UpdateTaoSkuUpdateOffShelf()
 		}, []string{
-			"17:55:00",
+			"20:15:00",
 		})
 
 		// 每分钟轮询一次,推送骑手信息