beta

business/jxstore/tempop/tempop.go

@@ -8,8 +8,6 @@ import (
 	"strings"
 	"time"
 
-	"git.rosy.net.cn/jx-callback/business/partner/putils"
-
 	"git.rosy.net.cn/jx-callback/business/auth2/authprovider/weixin"
 	"git.rosy.net.cn/jx-callback/business/partner/delivery"
 	"github.com/360EntSecGroup-Skylar/excelize"
@@ -1812,10 +1810,17 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
 	}
 	if len(priceList) > 0 {
 		for k, v := range priceList {
-			putils.FreeBatchStoreSkuInfo("更新门店商品价格", func(task tasksch.ITask, batchedStoreSkuList []*partner.StoreSkuInfo) (result interface{}, successCount int, err error) {
-				handler.UpdateStoreSkusPrice(ctx, vendorOrgCode, 0, k, v)
-				return nil, 0, err
-			}, ctx, nil, v, 50, true)
+			if len(v) > 50 {
+				for i := 0; i < len(v)/50+1; i++ {
+					j := i
+					if i == len(v)/50+1 {
+						handler.UpdateStoreSkusPrice(ctx, vendorOrgCode, 0, k, v[j:len(v)])
+					} else {
+						handler.UpdateStoreSkusPrice(ctx, vendorOrgCode, 0, k, v[j:50*(j+1)])
+					}
+					j += 50
+				}
+			}
 		}
 	}
 	if len(statusList1) > 0 {