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

新接口，得到我的守价订单

Browse Source
This commit is contained in:
苏尹岚
2020-08-21 14:12:51 +08:00
parent 63fb0222d3
commit 2f5c7e0526
6 changed files with 77 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

43
business/model/dao/dao_order.go
View File

@@ -1412,38 +1412,59 @@ func GetSupplySupportStoreSkus(db *DaoDB, fromDate, toDate time.Time, fromStoreI
return getSupplySupportStoreSkusResult, err
}
func GetPriceDefendOrder(db *DaoDB, storeIDs, skuIDs, issues []int, defendPrice, isBuyNowPrice, isSuccess int) (priceDefendOrders []*model.PriceDefendOrder, err error) {
func GetPriceDefendOrder(db *DaoDB, storeIDs, skuIDs, issues []int, defendPrice, isBuyNowPrice, isSuccess int, userID string, beginAt, EndAt time.Time, isDesc bool) (priceDefendOrders []*model.PriceDefendOrder, err error) {
sql := `
SELECT *
FROM price_defend_order
SELECT a.*
FROM price_defend_order a
JOIN user_delivery_address b ON a.address_id = b.id AND b.deleted_at = ?
WHERE 1 = 1
AND a.deleted_at = ?
`
sqlParams := []interface{}{}
sqlParams := []interface{}{
utils.DefaultTimeValue,
utils.DefaultTimeValue,
}
if len(storeIDs) > 0 {
sql += " AND store_id IN (" + GenQuestionMarks(len(storeIDs)) + ")"
sql += " AND a.store_id IN (" + GenQuestionMarks(len(storeIDs)) + ")"
sqlParams = append(sqlParams, storeIDs)
}
if len(skuIDs) > 0 {
sql += " AND sku_id IN (" + GenQuestionMarks(len(skuIDs)) + ")"
sql += " AND a.sku_id IN (" + GenQuestionMarks(len(skuIDs)) + ")"
sqlParams = append(sqlParams, skuIDs)
}
if len(issues) > 0 {
sql += " AND issue IN (" + GenQuestionMarks(len(issues)) + ")"
sql += " AND a.issue IN (" + GenQuestionMarks(len(issues)) + ")"
sqlParams = append(sqlParams, issues)
}
if defendPrice != 0 {
sql += " AND defend_price = ?"
sql += " AND a.defend_price = ?"
sqlParams = append(sqlParams, defendPrice)
}
if isBuyNowPrice != -1 {
sql += " AND is_buy_now_price = ?"
sql += " AND a.is_buy_now_price = ?"
sqlParams = append(sqlParams, isBuyNowPrice)
}
if isSuccess != -1 {
sql += " AND is_success = ?"
sql += " AND a.is_success = ?"
sqlParams = append(sqlParams, isSuccess)
}
sql += " ORDER BY created_at"
if userID != "" {
sql += " AND b.user_id = ?"
sqlParams = append(sqlParams, userID)
}
if beginAt != utils.ZeroTimeValue {
sql += " AND a.created_at >= ?"
sqlParams = append(sqlParams, beginAt)
}
if EndAt != utils.ZeroTimeValue {
sql += " AND a.created_at <= ?"
sqlParams = append(sqlParams, EndAt)
}
if isDesc {
sql += " ORDER BY a.created_at DESC"
} else {
sql += " ORDER BY a.created_at"
}
err = GetRows(db, &priceDefendOrders, sql, sqlParams)
return priceDefendOrders, err
}