diff --git a/business/jxstore/cms/sync.go b/business/jxstore/cms/sync.go index c7d653caa..8e62ed74d 100644 --- a/business/jxstore/cms/sync.go +++ b/business/jxstore/cms/sync.go @@ -389,10 +389,6 @@ func (v *VendorSync) SyncStoresSkus2(ctx *jxcontext.Context, db *dao.DaoDB, vend return nil, partner.AddVendorInfo2Err(err, loopMapInfo.VendorID) }, isContinueWhenError) if task != nil { - task.SetFinishHook(func(task2 tasksch.ITask) { - failedList := task2.GetErrMsg() - fmt.Println(failedList) - }) err = makeSyncError(err) } return hint, err @@ -544,6 +540,11 @@ func (v *VendorSync) LoopStoresMap2(ctx *jxcontext.Context, db *dao.DaoDB, taskN taskName = fmt.Sprintf("%s,处理平台%s", taskName, model.VendorChineseNames[loopInfoList[0].VendorID]) } task = tasksch.NewParallelTask(taskName, tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx, handler, loopInfoList) + task.SetFinishHook(func(task tasksch.ITask) { + fmt.Println("test2") + failedList := task.GetErrMsg() + fmt.Println(failedList) + }) tasksch.HandleTask(task, nil, isManageIt).Run() if !isAsync { resultList, err2 := task.GetResult(0)