From df0f832242ca2e1b678fce72d08a0c35dc313be3 Mon Sep 17 00:00:00 2001 From: suyl <770236076@qq.com> Date: Thu, 17 Jun 2021 10:14:21 +0800 Subject: [PATCH] aa --- business/jxstore/tempop/tempop.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/business/jxstore/tempop/tempop.go b/business/jxstore/tempop/tempop.go index 19080530e..bcecbf4cb 100644 --- a/business/jxstore/tempop/tempop.go +++ b/business/jxstore/tempop/tempop.go @@ -1844,7 +1844,7 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) { db = dao.GetDB() ) storeMaps, _ := dao.GetStoresMapList(db, []int{model.VendorIDJD}, nil, nil, model.StoreStatusAll, model.StoreIsSyncAll, "", "", "320406") - things, _ := dao.GetThingMapList(db, model.ThingTypeSku, []int{model.VendorIDJD}, []int{6092260, 27007, 6043692, 27008, 27009}, []string{"320406"}) + things, _ := dao.GetThingMapList(db, model.ThingTypeSku, []int{model.VendorIDJD}, nil, []string{"320406"}) thingIDmap := make(map[int64]string) thingIDmap2 := make(map[string]int) for _, v := range things { @@ -1856,7 +1856,7 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) { task := tasksch.NewParallelTask("uuuuu", tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx, func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { storeMap := batchItemList[0].(*model.StoreMap) - storeSkus, _ := dao.GetStoresSkusInfo(db, []int{storeMap.StoreID}, []int{6092260, 27007, 6043692, 27008, 27009}) + storeSkus, _ := dao.GetStoresSkusInfo(db, []int{storeMap.StoreID}, nil) FreeBatchInfo("uuuuu2", func(task tasksch.ITask, batchedStoreSkuList []*model.StoreSkuBind) (result interface{}, successCount int, err error) { api := jd.GetAPI("320406") var ids []int64