diff --git a/business/jxstore/cms/store.go b/business/jxstore/cms/store.go index f541be960..c412de47a 100644 --- a/business/jxstore/cms/store.go +++ b/business/jxstore/cms/store.go @@ -871,18 +871,24 @@ func RefreshMissingDadaStores(ctx *jxcontext.Context, storeID int, isAsync, isCo task := tasksch.NewParallelTask("RefreshMissingDadaStores", tasksch.NewParallelConfig().SetIsContinueWhenError(isContinueWhenError), ctx, func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { storeDetail := batchItemList[0].(*dao.StoreDetail2) + var resultList []interface{} if storeDetail.DadaStoreID == "" { db := dao.GetDB() - _, err = AddStoreCourierMap(ctx, db, storeDetail.ID, model.VendorIDDada, &model.StoreCourierMap{ + if _, err = AddStoreCourierMap(ctx, db, storeDetail.ID, model.VendorIDDada, &model.StoreCourierMap{ VendorStoreID: utils.Int2Str(storeDetail.ID), Status: model.StoreStatusOpened, - }) + }); err == nil { + resultList = append(resultList, 1) + } } - return nil, err + return resultList, err }, storeList) tasksch.HandleTask(task, nil, true).Run() if !isAsync { - _, err = task.GetResult(0) + resultList, err2 := task.GetResult(0) + if err = err2; err == nil { + hint = utils.Int2Str(len(resultList)) + } } else { hint = task.ID }