aa
This commit is contained in:
@@ -381,12 +381,11 @@ func GetStoreCategories(db *DaoDB, vendorID, storeID int, skuIDs []int, level in
|
|||||||
t1.is_sys_cat, t1.vendor_org_code,
|
t1.is_sys_cat, t1.vendor_org_code,
|
||||||
t6.city_code
|
t6.city_code
|
||||||
FROM store_sku_category_map t5
|
FROM store_sku_category_map t5
|
||||||
JOIN sku_category t4 ON t5.category_id = t4.id AND t4.deleted_at = ?
|
JOIN sku_category t4 ON t5.category_id = t4.id
|
||||||
LEFT JOIN store_category_map ts ON ts.store_id = t5.store_id AND ts.category_id = t4.id AND ts.deleted_at = ?
|
LEFT JOIN store_category_map ts ON ts.store_id = t5.store_id AND ts.category_id = t4.id AND ts.deleted_at = ?
|
||||||
`
|
`
|
||||||
sqlParams := []interface{}{
|
sqlParams := []interface{}{
|
||||||
utils.DefaultTimeValue,
|
utils.DefaultTimeValue,
|
||||||
utils.DefaultTimeValue,
|
|
||||||
}
|
}
|
||||||
fieldPrefixParams := []interface{}{fieldPrefix, fieldPrefix, fieldPrefix, fieldPrefix}
|
fieldPrefixParams := []interface{}{fieldPrefix, fieldPrefix, fieldPrefix, fieldPrefix}
|
||||||
if len(skuIDs) > 0 {
|
if len(skuIDs) > 0 {
|
||||||
@@ -404,11 +403,11 @@ func GetStoreCategories(db *DaoDB, vendorID, storeID int, skuIDs []int, level in
|
|||||||
sql += `
|
sql += `
|
||||||
LEFT JOIN sku_category t4p ON t4.parent_id = t4p.id
|
LEFT JOIN sku_category t4p ON t4.parent_id = t4p.id
|
||||||
LEFT JOIN store_category_map tsp ON tsp.store_id = t5.store_id AND tsp.category_id = t4p.id AND tsp.deleted_at = ?
|
LEFT JOIN store_category_map tsp ON tsp.store_id = t5.store_id AND tsp.category_id = t4p.id AND tsp.deleted_at = ?
|
||||||
LEFT JOIN store_sku_category_map t5p ON t4p.id = t5p.category_id AND t5.store_id = t5p.store_id AND t5p.deleted_at = ?
|
LEFT JOIN store_sku_category_map t5p ON t4p.id = t5p.category_id AND t5.store_id = t5p.store_id
|
||||||
LEFT JOIN store_map t1 ON t1.store_id = t5.store_id AND t1.vendor_id = ?
|
LEFT JOIN store_map t1 ON t1.store_id = t5.store_id AND t1.vendor_id = ?
|
||||||
LEFT JOIN store t6 ON t6.id = t5.store_id
|
LEFT JOIN store t6 ON t6.id = t5.store_id
|
||||||
WHERE t5.store_id = ? AND t4.is_sync <> ?`
|
WHERE t5.store_id = ? AND t4.is_sync <> ?`
|
||||||
sqlParams = append(sqlParams, utils.DefaultTimeValue, utils.DefaultTimeValue, vendorID, storeID, model.YES)
|
sqlParams = append(sqlParams, utils.DefaultTimeValue, vendorID, storeID, model.YES)
|
||||||
if mustDirty {
|
if mustDirty {
|
||||||
sql += " AND t5.%s_sync_status <> 0"
|
sql += " AND t5.%s_sync_status <> 0"
|
||||||
fieldPrefixParams = append(fieldPrefixParams, fieldPrefix)
|
fieldPrefixParams = append(fieldPrefixParams, fieldPrefix)
|
||||||
@@ -417,8 +416,6 @@ func GetStoreCategories(db *DaoDB, vendorID, storeID int, skuIDs []int, level in
|
|||||||
sql += " AND t4.level = ?"
|
sql += " AND t4.level = ?"
|
||||||
sqlParams = append(sqlParams, level)
|
sqlParams = append(sqlParams, level)
|
||||||
}
|
}
|
||||||
fmt.Println(sql)
|
|
||||||
fmt.Println(sqlParams)
|
|
||||||
if err = GetRows(db, &cats, fmt.Sprintf(sql, fieldPrefixParams...), sqlParams...); err != nil {
|
if err = GetRows(db, &cats, fmt.Sprintf(sql, fieldPrefixParams...), sqlParams...); err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user