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

刷新历史订单结算价

Browse Source
This commit is contained in:
苏尹岚
2019-11-06 10:20:17 +08:00
parent 89740b5451
commit bec26311fb
2 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
business/jxcallback/orderman/order.go
View File

@@ -627,7 +627,7 @@ func (c *OrderManager) RefreshHistoryOrdersEarningPrice(ctx *jxcontext.Context,
return errors.New(fmt.Sprintf("查询间隔时间不允许大于10天！时间范围：[%v] 至 [%v]", fromDate, toDate)) return errors.New(fmt.Sprintf("查询间隔时间不允许大于10天！时间范围：[%v] 至 [%v]", fromDate, toDate))
} }
orderList, _ := dao.QueryOrders(db, []int{vendorOrderId}, 0, fromDateParm, toDateParm) orderList, _ := dao.QueryOrders(db, []int{}, 0, fromDateParm, toDateParm)
if len(orderList) == 0 { if len(orderList) == 0 {
return errors.New(fmt.Sprintf("未查询到订单！时间范围：[%v] 至 [%v]", fromDate, toDate)) return errors.New(fmt.Sprintf("未查询到订单！时间范围：[%v] 至 [%v]", fromDate, toDate))
} }
@@ -642,7 +642,7 @@ func (c *OrderManager) RefreshHistoryOrdersEarningPrice(ctx *jxcontext.Context,
updateSingleOrderEarningPrice(order, db) updateSingleOrderEarningPrice(order, db)
for _, value := range order.Skus { for _, value := range order.Skus {
dao.Begin(db) dao.Begin(db)
_, err := dao.UpdateOrderSkuEariningPrice(db, value, v.StoreID, fromDateParm, toDateParm) _, err := dao.UpdateOrderSkuEariningPrice(db, value, v.StoreID, fromDateParm, toDateParm, vendorOrderId)
if err == nil { if err == nil {
dao.Commit(db) dao.Commit(db)
} }

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

@@ -590,7 +590,7 @@ func GetRiskOrderCount(db *DaoDB, dayNum int, includeToday bool) (storeOrderList
return storeOrderList, GetRows(db, &storeOrderList, sql, sqlParams) return storeOrderList, GetRows(db, &storeOrderList, sql, sqlParams)
} }
func UpdateOrderSkuEariningPrice(db *DaoDB, skus *model.OrderSku, storeID int, fromDateParm, toDateParm time.Time) (num int64, err error) { func UpdateOrderSkuEariningPrice(db *DaoDB, skus *model.OrderSku, storeID int, fromDateParm, toDateParm time.Time, vendorOrderId int) (num int64, err error) {
sql := ` sql := `
UPDATE order_sku t1 UPDATE order_sku t1
JOIN goods_order tt1 ON tt1.vendor_order_id = t1.vendor_order_id JOIN goods_order tt1 ON tt1.vendor_order_id = t1.vendor_order_id
@@ -600,6 +600,7 @@ func UpdateOrderSkuEariningPrice(db *DaoDB, skus *model.OrderSku, storeID int, f
AND tt1.order_created_at BETWEEN ? and ? AND tt1.order_created_at BETWEEN ? and ?
SET t1.earning_price = ?,t1.store_sub_id = ? SET t1.earning_price = ?,t1.store_sub_id = ?
WHERE t1.store_sub_id = 0 WHERE t1.store_sub_id = 0
AND tt1.vendor_order_id = ?
` `
sqlParams := []interface{}{ sqlParams := []interface{}{
skus.VendorID, skus.VendorID,
@@ -609,6 +610,7 @@ func UpdateOrderSkuEariningPrice(db *DaoDB, skus *model.OrderSku, storeID int, f
toDateParm, toDateParm,
skus.EarningPrice, skus.EarningPrice,
skus.StoreSubID, skus.StoreSubID,
vendorOrderId,
} }
return ExecuteSQL(db, sql, sqlParams...) return ExecuteSQL(db, sql, sqlParams...)
} }