尝试解决商城topskus重复问题
This commit is contained in:
@@ -968,7 +968,7 @@ func GetStoreSkusByNameIDs(db *DaoDB, storeIDs []int, nameID int) (skuList []*St
|
|||||||
func GetTopSkusByStoreIDs(db *DaoDB, storeIDs []int) (storeSkuNameExt []*StoreSkuNameExt, err error) {
|
func GetTopSkusByStoreIDs(db *DaoDB, storeIDs []int) (storeSkuNameExt []*StoreSkuNameExt, err error) {
|
||||||
sql := `
|
sql := `
|
||||||
SELECT DISTINCT t1.* FROM(
|
SELECT DISTINCT t1.* FROM(
|
||||||
SELECT 1 s, t1.count, t2.id sku_id, t3.*, t1.store_id, t1.store_name
|
SELECT t1.count, t2.id sku_id, t3.*, t1.store_id, t1.store_name
|
||||||
FROM(
|
FROM(
|
||||||
SELECT SUM(b.count) count,c.id,a.store_id,d.name store_name
|
SELECT SUM(b.count) count,c.id,a.store_id,d.name store_name
|
||||||
FROM goods_order a
|
FROM goods_order a
|
||||||
@@ -997,7 +997,7 @@ func GetTopSkusByStoreIDs(db *DaoDB, storeIDs []int) (storeSkuNameExt []*StoreSk
|
|||||||
JOIN sku t2 ON t2.id = t1.id
|
JOIN sku t2 ON t2.id = t1.id
|
||||||
JOIN sku_name t3 ON t3.id = t2.name_id
|
JOIN sku_name t3 ON t3.id = t2.name_id
|
||||||
UNION
|
UNION
|
||||||
SELECT 2 s, 0 count, a.sku_id, g.*, a.store_id, e.name store_name
|
SELECT 0 count, a.sku_id, g.*, a.store_id, e.name store_name
|
||||||
FROM store_sku_bind a
|
FROM store_sku_bind a
|
||||||
LEFT JOIN act_store_sku b ON a.store_id = b.store_id AND b.sku_id = a.sku_id
|
LEFT JOIN act_store_sku b ON a.store_id = b.store_id AND b.sku_id = a.sku_id
|
||||||
LEFT JOIN act_map c ON c.act_id = b.act_id
|
LEFT JOIN act_map c ON c.act_id = b.act_id
|
||||||
@@ -1018,7 +1018,7 @@ func GetTopSkusByStoreIDs(db *DaoDB, storeIDs []int) (storeSkuNameExt []*StoreSk
|
|||||||
AND a.status = ?
|
AND a.status = ?
|
||||||
AND a.deleted_at = ?
|
AND a.deleted_at = ?
|
||||||
AND (d.type = ? OR d.type = ?)
|
AND (d.type = ? OR d.type = ?)
|
||||||
ORDER BY 1,2 DESC) t1
|
ORDER BY 1 DESC) t1
|
||||||
LIMIT ?
|
LIMIT ?
|
||||||
`
|
`
|
||||||
sqlParams = append(sqlParams, model.StoreSkuBindStatusNormal, utils.DefaultTimeValue, model.ActSkuDirectDown, model.ActSkuSecKill, 30)
|
sqlParams = append(sqlParams, model.StoreSkuBindStatusNormal, utils.DefaultTimeValue, model.ActSkuDirectDown, model.ActSkuSecKill, 30)
|
||||||
|
|||||||
Reference in New Issue
Block a user