diff --git a/business/jxstore/cms/sync.go b/business/jxstore/cms/sync.go index adefdb036..b0775f60b 100644 --- a/business/jxstore/cms/sync.go +++ b/business/jxstore/cms/sync.go @@ -625,9 +625,15 @@ 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, ctx *jxcontext.Context) { - err = WirteToExcelBySyncFailed(task, ctx) - }) + if isAsync { + task.SetFinishHook(func(task tasksch.ITask, ctx *jxcontext.Context) { + if len(task.GetErrMsg()) > 10 { + err = WirteToExcelBySyncFailed(task, ctx) + } else { + err = errors.New(utils.Format4Output(task.GetErrMsg(), true)) + } + }) + } tasksch.HandleTask(task, nil, isManageIt).Run() if !isAsync { resultList, err2 := task.GetResult(0)