diff --git a/business/jxstore/tempop/tempop.go b/business/jxstore/tempop/tempop.go index e34b58c38..fb0dace30 100644 --- a/business/jxstore/tempop/tempop.go +++ b/business/jxstore/tempop/tempop.go @@ -1736,37 +1736,65 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) { // } // } // } + // var ( + // db = dao.GetDB() + // ) + // catResult, _ := api.JdShop2API.FindShopCategories() + // for _, v := range catResult { + // var skuCat *model.SkuCategory + // sql := ` + // SELECT * + // FROM sku_category + // WHERE deleted_at = ? + // AND name = ? + // AND is_exd_spec = 0 + // ` + // sqlParams := []interface{}{utils.DefaultTimeValue, v.Name} + // err = dao.GetRow(db, &skuCat, sql, sqlParams) + // if skuCat != nil { + // var storeSkuCat *model.StoreSkuCategoryMap + // sql2 := ` + // SELECT * + // FROM store_sku_category_map + // WHERE store_id = ? + // AND deleted_at = ? + // AND category_id = ? + // ` + // sqlParams2 := []interface{}{100000, utils.DefaultTimeValue, skuCat.ID} + // err = dao.GetRow(db, &storeSkuCat, sql2, sqlParams2) + // if storeSkuCat != nil { + // storeSkuCat.JdsID = v.CID + // dao.UpdateEntity(db, storeSkuCat, "JdsID") + // } + // } + // } var ( db = dao.GetDB() ) - catResult, _ := api.JdShop2API.FindShopCategories() - for _, v := range catResult { - var skuCat *model.SkuCategory - sql := ` - SELECT * - FROM sku_category - WHERE deleted_at = ? - AND name = ? - AND is_exd_spec = 0 - ` - sqlParams := []interface{}{utils.DefaultTimeValue, v.Name} - err = dao.GetRow(db, &skuCat, sql, sqlParams) - if skuCat != nil { - var storeSkuCat *model.StoreSkuCategoryMap - sql2 := ` - SELECT * - FROM store_sku_category_map - WHERE store_id = ? - AND deleted_at = ? - AND category_id = ? - ` - sqlParams2 := []interface{}{100000, utils.DefaultTimeValue, skuCat.ID} - err = dao.GetRow(db, &storeSkuCat, sql2, sqlParams2) - if storeSkuCat != nil { - storeSkuCat.JdsID = v.CID - dao.UpdateEntity(db, storeSkuCat, "JdsID") + storeSkus, _ := dao.GetStoresSkusInfo(db, []int{model.JdShopMainStoreID2}, nil) + for _, v := range storeSkus { + if v.JdsID != 0 { + if err = api.JdShop2API.StoreSkuBindStore(false, []string{utils.Int64ToStr(v.JdsID)}, []string{"1000063128"}); err == nil { + storeSkus2, _ := dao.GetStoresSkusInfo(db, []int{667281}, []int{v.SkuID}) + if len(storeSkus2) > 0 { + status := storeSkus2[0].Status + stock := storeSkus2[0].Stock + price := storeSkus2[0].Price + if status == model.StoreSkuBindStatusNormal { + api.JdShop2API.StoreWareDoUpdate(status, v.JdsID, "1000063128") + } + if stock != 0 { + api.JdShop2API.StoreUpdateStock(stock, v.JdsID, "1000063128") + } + api.JdShop2API.StoreUpdatePrice(int(jxutils.IntPrice2Standard(int64(price))), v.JdsID, "1000063128") + } else { + continue + } } + } else { + continue } + break } return err }