diff --git a/business/jxstore/tempop/tempop.go b/business/jxstore/tempop/tempop.go index 20c57505a..14aca52b1 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,20 +1851,22 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) { break } } - 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) + // 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 { + if v != nil { + 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 }