From ada4d6e023e665b270a0f2839e8737c3e78108a6 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E8=8B=8F=E5=B0=B9=E5=B2=9A?= <770236076@qq.com> Date: Wed, 17 Mar 2021 14:31:03 +0800 Subject: [PATCH] aa --- business/jxstore/report/report.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) 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)