aa

2021-02-25 10:21:13 +08:00
parent 3653a85af2
commit 578ba51f9a
4 changed files with 151 additions and 0 deletions
--- a/business/model/dao/store.go
+++ b/business/model/dao/store.go
@@ -978,3 +978,113 @@ func GetBrands(db *DaoDB, name string, brandID int) (brands []*model.Brand, err
 	err = GetRows(db, &brands, sql, sqlParams)
 	return brands, err
 }
+
+func GetStoreAcctIncome(db *DaoDB, storeID, incomeType int, fromTime, toTime time.Time) (storeAcctIncomes []*model.StoreAcctIncome, err error) {
+	sql := `
+		SELECT * 
+		  FROM store_acct_income 
+		 WHERE 1 = 1
+	`
+	sqlParams := []interface{}{}
+	if storeID != 0 {
+		sql += " AND store_id = ?"
+		sqlParams = append(sqlParams, storeID)
+	}
+	if incomeType != 0 {
+		sql += " AND type = ?"
+		sqlParams = append(sqlParams, incomeType)
+	}
+	if utils.IsTimeZero(fromTime) {
+		sql += " AND created_at >= ?"
+		sqlParams = append(sqlParams, fromTime)
+	}
+	if utils.IsTimeZero(toTime) {
+		sql += " AND created_at <= ?"
+		sqlParams = append(sqlParams, toTime)
+	}
+	err = GetRows(db, &storeAcctIncomes, sql, sqlParams)
+	return storeAcctIncomes, err
+}
+
+func GetStoreAcctIncomeTotal(db *DaoDB, storeID, incomeType int, fromTime, toTime time.Time) (incomeTotal int, err error) {
+	var income *model.StoreAcctIncome
+	sql := `
+		SELECT SUM(income_price) income_price
+		  FROM store_acct_income 
+		 WHERE 1 = 1
+	`
+	sqlParams := []interface{}{}
+	if storeID != 0 {
+		sql += " AND store_id = ?"
+		sqlParams = append(sqlParams, storeID)
+	}
+	if incomeType != 0 {
+		sql += " AND type = ?"
+		sqlParams = append(sqlParams, incomeType)
+	}
+	if utils.IsTimeZero(fromTime) {
+		sql += " AND created_at >= ?"
+		sqlParams = append(sqlParams, fromTime)
+	}
+	if utils.IsTimeZero(toTime) {
+		sql += " AND created_at <= ?"
+		sqlParams = append(sqlParams, toTime)
+	}
+	err = GetRow(db, &income, sql, sqlParams)
+	return income.IncomePrice, err
+}
+
+func GetStoreAcctExpend(db *DaoDB, storeID, expendType int, fromTime, toTime time.Time) (storeAcctExpends []*model.StoreAcctExpend, err error) {
+	sql := `
+		SELECT * 
+		  FROM store_acct_expend 
+		 WHERE 1 = 1
+	`
+	sqlParams := []interface{}{}
+	if storeID != 0 {
+		sql += " AND store_id = ?"
+		sqlParams = append(sqlParams, storeID)
+	}
+	if expendType != 0 {
+		sql += " AND type = ?"
+		sqlParams = append(sqlParams, expendType)
+	}
+	if utils.IsTimeZero(fromTime) {
+		sql += " AND created_at >= ?"
+		sqlParams = append(sqlParams, fromTime)
+	}
+	if utils.IsTimeZero(toTime) {
+		sql += " AND created_at <= ?"
+		sqlParams = append(sqlParams, toTime)
+	}
+	err = GetRows(db, &storeAcctExpends, sql, sqlParams)
+	return storeAcctExpends, err
+}
+
+func GetStoreAcctExpendTotal(db *DaoDB, storeID, expendType int, fromTime, toTime time.Time) (expendTotal int, err error) {
+	var expend *model.StoreAcctExpend
+	sql := `
+		SELECT SUM(expend_price) expend_price
+		  FROM store_acct_expend 
+		 WHERE 1 = 1
+	`
+	sqlParams := []interface{}{}
+	if storeID != 0 {
+		sql += " AND store_id = ?"
+		sqlParams = append(sqlParams, storeID)
+	}
+	if expendType != 0 {
+		sql += " AND type = ?"
+		sqlParams = append(sqlParams, expendType)
+	}
+	if utils.IsTimeZero(fromTime) {
+		sql += " AND created_at >= ?"
+		sqlParams = append(sqlParams, fromTime)
+	}
+	if utils.IsTimeZero(toTime) {
+		sql += " AND created_at <= ?"
+		sqlParams = append(sqlParams, toTime)
+	}
+	err = GetRow(db, &expend, sql, sqlParams)
+	return expend.ExpendPrice, err
+}