1

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)

business/jxstore/misc/misc.go

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