diff --git a/business/jxstore/tempop/tempop.go b/business/jxstore/tempop/tempop.go index f89d7e932..609259463 100644 --- a/business/jxstore/tempop/tempop.go +++ b/business/jxstore/tempop/tempop.go @@ -1827,36 +1827,51 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) { // }) // } var ( - db = dao.GetDB() - idLists [][]*jdapi.SkuIdEntity + db = dao.GetDB() + idLists2 [][]int64 ) 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 + // var idList []*jdapi.SkuIdEntity + var idList2 []int64 j := i + 50 if j > len(things)-1 { j = len(things) - 1 } for _, v := range things[i:j] { if v.VendorThingID != "" { - idList = append(idList, &jdapi.SkuIdEntity{ - OutSkuId: utils.Int64ToStr(v.ThingID), - }) + // idList = append(idList, &jdapi.SkuIdEntity{ + // OutSkuId: utils.Int64ToStr(v.ThingID), + // }) + idList2 = append(idList2, utils.Str2Int64(v.VendorThingID)) } } - idLists = append(idLists, idList) + // idLists = append(idLists, idList) + idLists2 = append(idLists2, idList2) } 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 { + for _, v := range idLists2 { if v != nil && storeMap != nil { - err = api.JdAPI.DelVipPrice(utils.Int2Str(storeMap.StoreID), v) - if strings.Contains(err.Error(), "没有会员价") { - err = nil + priceInfo, _ := api.JdAPI.GetStationInfoList(storeMap.VendorStoreID, v) + var idLists []*jdapi.SkuIdEntity + for _, vv := range priceInfo { + if vv.VipPrice != 0 { + thingMap := &model.ThingMap{} + sql := ` + SELECT * FROM thing_map WHERE thing_type = 3 AND deletad_at = '1970-01-01 00:00:00' AND vendor_org_code = 320406 AND vendor_id = 0 AND vendor_thing_id = ? + ` + sqlParams := []interface{}{vv.SkuID} + dao.GetRow(db, &thingMap, sql, sqlParams) + idLists = append(idLists, &jdapi.SkuIdEntity{ + OutSkuId: utils.Int64ToStr(thingMap.ThingID), + }) + } } + err = api.JdAPI.DelVipPrice(utils.Int2Str(storeMap.StoreID), idLists) } } return retVal, err