liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

a

Browse Source
This commit is contained in:
苏尹岚
2020-11-27 14:31:43 +08:00
parent bae7d7f2ee
commit d031a0a265
1 changed files with 54 additions and 26 deletions
Download Patch File Download Diff File Expand all files Collapse all files

80
business/jxstore/tempop/tempop.go
View File

@@ -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
}