diff --git a/business/jxstore/tempop/tempop.go b/business/jxstore/tempop/tempop.go index 553d6afed..9d89d0efe 100644 --- a/business/jxstore/tempop/tempop.go +++ b/business/jxstore/tempop/tempop.go @@ -1763,11 +1763,11 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) { ` err = dao.GetRows(db, &storeMaps, sql, nil) storeSkus, _ := dao.GetStoresSkusInfo(db, []int{model.JdShopMainStoreID2}, nil) - task := tasksch.NewParallelTask("京东商城门店建商品1", tasksch.NewParallelConfig().SetParallelCount(1).SetIsContinueWhenError(true), ctx, + task := tasksch.NewParallelTask("京东商城门店建商品1", tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx, func(task2 *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { v := batchItemList[0].(*model.StoreSkuBind) if v.JdsID != 0 { - task := tasksch.NewParallelTask("京东商城门店建商品2", tasksch.NewParallelConfig().SetParallelCount(1).SetIsContinueWhenError(true), ctx, + task := tasksch.NewParallelTask("京东商城门店建商品2", tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx, func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { storeMap := batchItemList[0].(*model.StoreMap) if err = api.JdShop2API.StoreSkuBindStore(false, []string{utils.Int64ToStr(v.JdsID)}, []string{storeMap.VendorStoreID}); err == nil {