diff --git a/business/jxstore/tempop/tempop.go b/business/jxstore/tempop/tempop.go index ae010f805..20c57505a 100644 --- a/business/jxstore/tempop/tempop.go +++ b/business/jxstore/tempop/tempop.go @@ -1831,7 +1831,7 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) { idLists [][]*jdapi.SkuIdEntity k = 1 ) - storeMaps, _ := dao.GetStoresMapList(db, []int{model.VendorIDJD}, []int{667281}, nil, model.StoreStatusAll, model.StoreIsSyncAll, "", "", "320406") + // storeMaps, _ := dao.GetStoresMapList(db, []int{model.VendorIDJD}, []int{667281}, nil, model.StoreStatusAll, model.StoreIsSyncAll, "", "", "320406") things, _ := dao.GetThingMapList(db, model.ThingTypeSku, []int{model.VendorIDJD}, nil, []string{"320406"}) for i := 0; i < len(things); i += 50 { var idList []*jdapi.SkuIdEntity @@ -1851,19 +1851,20 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) { break } } - 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) - for _, v := range idLists { - err = api.JdAPI.DelVipPrice(utils.Int2Str(storeMap.StoreID), v, "suyl") - if strings.Contains(err.Error(), "没有会员价") { - err = nil - } - } - return retVal, err - }, storeMaps) - tasksch.HandleTask(task, nil, true).Run() - _, err = task.GetResult(0) + fmt.Println(utils.Format4Output(idLists, false)) + // 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) + // for _, v := range idLists { + // err = api.JdAPI.DelVipPrice(utils.Int2Str(storeMap.StoreID), v, "suyl") + // if strings.Contains(err.Error(), "没有会员价") { + // err = nil + // } + // } + // return retVal, err + // }, storeMaps) + // tasksch.HandleTask(task, nil, true).Run() + // _, err = task.GetResult(0) return err }