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

aa

Browse Source
This commit is contained in:
suyl
2021-08-18 13:46:04 +08:00
parent 22f0f3792d
commit 9846686dbe
3 changed files with 7 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
dao/sim_dao.go
View File

@@ -122,11 +122,11 @@ func GetChargeInfo(db *sqlx.DB, appID int, printNo string, iccID, beginDate, end
sqlOhter := ` sqlOhter := `
FROM pay_order a FROM pay_order a
JOIN apps b ON b.user_id = a.user_id AND b.id = ? AND b.deleted_at = ? JOIN apps b ON b.user_id = a.user_id AND b.id = ? AND b.deleted_at = ?
LEFT JOIN printer c ON c.icc_id = a.thing_id AND c.deleted_at = ? JOIN printer c ON c.icc_id = a.thing_id AND c.deleted_at = ?
LEFT JOIN sim_flow_income d ON d.order_id = a.order_id JOIN sim_flow_income d ON d.order_id = a.order_id AND d.income_type = ?
WHERE 1 = 1 WHERE 1 = 1
` `
sqlParams := []interface{}{appID, utils.DefaultTimeValue, utils.DefaultTimeValue} sqlParams := []interface{}{appID, utils.DefaultTimeValue, utils.DefaultTimeValue, model.FlowIncomeTypeUser}
if printNo != "" { if printNo != "" {
sqlOhter += " AND c.print_no = ?" sqlOhter += " AND c.print_no = ?"
sqlParams = append(sqlParams, printNo) sqlParams = append(sqlParams, printNo)

2
services/order.go
View File

@@ -89,7 +89,7 @@ var (
} }
} }
} }
err = FlowIncome(db, iccID, flow, unit, model.FlowIncomeTypeUser) err = FlowIncome(db, iccID, flow, unit, model.FlowIncomeTypeUser, order.OrderID)
//冲进去之后重新计算流量超标 //冲进去之后重新计算流量超标
sumIncome, _ := dao.GetSimFlowIncomeSum(db, iccID, monthBegin, monthEnd) sumIncome, _ := dao.GetSimFlowIncomeSum(db, iccID, monthBegin, monthEnd)
sumExpend, _ := dao.GetSimFlowExpendSum(db, iccID, monthBegin, monthEnd) sumExpend, _ := dao.GetSimFlowExpendSum(db, iccID, monthBegin, monthEnd)

5
services/sim.go
View File

@@ -95,7 +95,7 @@ func SimFlowMonthSettle() {
printers, _ := dao.GetPrinters(db, 0, "", 0, 0, 0) printers, _ := dao.GetPrinters(db, 0, "", 0, 0, 0)
for _, v := range printers { for _, v := range printers {
if v.IccID != "" { if v.IccID != "" {
if err := FlowIncome(db, v.IccID, 30, "MB", model.FlowIncomeTypeJX); err == nil { if err := FlowIncome(db, v.IccID, 30, "MB", model.FlowIncomeTypeJX, ""); err == nil {
//划转后，每个月月初打印机都应该是不缺流量的状态 //划转后，每个月月初打印机都应该是不缺流量的状态
v.FlowFlag = 0 v.FlowFlag = 0
dao.Update(db, v, "flow_flag") dao.Update(db, v, "flow_flag")
@@ -104,7 +104,7 @@ func SimFlowMonthSettle() {
} }
} }
func FlowIncome(db *sqlx.DB, iccID string, flow float64, unit string, incomeType int) (err error) { func FlowIncome(db *sqlx.DB, iccID string, flow float64, unit string, incomeType int, orderID string) (err error) {
var ( var (
now = time.Now() now = time.Now()
) )
@@ -116,6 +116,7 @@ func FlowIncome(db *sqlx.DB, iccID string, flow float64, unit string, incomeType
Flow: flow, Flow: flow,
FlowUnit: unit, FlowUnit: unit,
IncomeType: incomeType, IncomeType: incomeType,
OrderID: orderID,
} }
err = dao.Insert(db, flowIncome) err = dao.Insert(db, flowIncome)
return err return err