饿鲜达部分商品增加默认价格和分类

This commit is contained in:
苏尹岚
2020-02-18 10:57:48 +08:00
parent 649d4d78e4
commit fa28f3b30c
4 changed files with 25 additions and 15 deletions

View File

@@ -427,6 +427,8 @@ func GetSkuNames(ctx *jxcontext.Context, keyword string, isBySku bool, params ma
} else {
sql += " AND t2.exd_sku_id = ''"
}
} else {
sql += " AND t2.exd_sku_id = ''"
}
if params["categoryID"] != nil {
cat := &model.SkuCategory{}
@@ -1521,22 +1523,29 @@ func CopyEbaiSkuPriceToJx(ctx *jxcontext.Context) (err error) {
db := dao.GetDB()
skuList, err := api.EbaiAPI.PageGetSkuList(32267350915)
for _, v := range skuList {
price := int(utils.Float64TwoInt64(v["sale_price"].(float64) * 100))
var skuNameList []*model.SkuName
sku, _ := api.EbaiAPI.PageGetSku(32267350915, utils.Str2Int64(v["sku_id"].(string)))
var skuName model.SkuName
sql2 := `
SELECT * FROM sku_category WHERE exd_name like ?
`
sqlParams2 := []interface{}{
"%" + sku.CustomCatName + "%",
}
dao.GetRow(db, &skuName, sql2, sqlParams2)
price := int(utils.Float64TwoInt64(utils.Interface2Float64WithDefault(v["sale_price"], 0) * 100))
sql := `
SELECT *
FROM sku_name
WHERE upc = ?
AND exd_sku_id <> ''
UPDATE sku_name a
JOIN sku b ON a.id = b.name_id
SET a.price = ?,a.category_id = ?
WHERE a.upc = ?
AND b.exd_sku_id = ?
`
sqlParams := []interface{}{
price, skuName.ID,
v["upc"].(string),
v["sku_id"].(string),
}
err = dao.GetRows(db, &skuNameList, sql, sqlParams...)
for _, vv := range skuNameList {
vv.Price = price
dao.UpdateEntity(db, vv, "Price")
}
dao.ExecuteSQL(db, sql, sqlParams)
}
return err
}