This commit is contained in:
苏尹岚
2021-03-10 14:08:32 +08:00
parent 88ff46c0ee
commit c7dbd7405d

View File

@@ -434,6 +434,7 @@ func GetStoreManageState(ctx *jxcontext.Context, storeIDs []int, vendorID int, f
storeIDs = storeIDs2
}
}
fmt.Println("storeIDs1111111111111111111111111111111111", storeIDs)
task := tasksch.NewParallelTask("GetStoreManageState", tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx,
func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
v := batchItemList[0].(int)