- RefreshMissingDadaStores返回正确的处理数量

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
 	}