diff --git a/business/jxstore/report/report.go b/business/jxstore/report/report.go index eb59c68a8..fb3ed46a1 100644 --- a/business/jxstore/report/report.go +++ b/business/jxstore/report/report.go @@ -444,7 +444,7 @@ func RefreshStoreManageState(ctx *jxcontext.Context) { dao.DeleteEntity(db, storeManage, "StoreID", "VendorID") return retVal, err }, deleteList) - tasksch.HandleTask(task3, task, true).Run() + tasksch.HandleTask(task3, nil, true).Run() task3.GetResult(0) case 1: task3 := tasksch.NewParallelTask("createList", tasksch.NewParallelConfig().SetParallelCount(50).SetIsContinueWhenError(true), ctx, @@ -458,7 +458,7 @@ func RefreshStoreManageState(ctx *jxcontext.Context) { dao.UpdateEntity(db, storeManage) return retVal, err }, createList) - tasksch.HandleTask(task3, task, true).Run() + tasksch.HandleTask(task3, nil, true).Run() task3.GetResult(0) case 2: task3 := tasksch.NewParallelTask("updateList", tasksch.NewParallelConfig().SetParallelCount(50).SetIsContinueWhenError(true), ctx, @@ -472,12 +472,12 @@ func RefreshStoreManageState(ctx *jxcontext.Context) { dao.CreateEntity(db, storeManage) return retVal, err }, updateList) - tasksch.HandleTask(task3, task, true).Run() + tasksch.HandleTask(task3, nil, true).Run() task3.GetResult(0) } return retVal, err }, []int{0, 1, 2}) - tasksch.HandleTask(task2, task, true).Run() + tasksch.HandleTask(task2, nil, true).Run() task2.GetResult(0) return retVal, err }, vendorIDs)