作者 陈志颖

fix:素币兑换清单移除离职人员

@@ -63,6 +63,7 @@ func (dao *CashPoolDao) ExchangeCashListRanking(queryOptions map[string]interfac @@ -63,6 +63,7 @@ func (dao *CashPoolDao) ExchangeCashListRanking(queryOptions map[string]interfac
63 queryPeople = queryPeople.ColumnExpr("sum(exchange_cash_person_list.exchanged_cash) AS cash") 63 queryPeople = queryPeople.ColumnExpr("sum(exchange_cash_person_list.exchanged_cash) AS cash")
64 queryPeople = queryPeople.ColumnExpr("sum(exchange_cash_person_list.exchanged_su_money) AS su_money") 64 queryPeople = queryPeople.ColumnExpr("sum(exchange_cash_person_list.exchanged_su_money) AS su_money")
65 queryPeople = queryPeople.ColumnExpr("ROW_NUMBER() OVER (ORDER BY sum(exchange_cash_person_list.exchanged_su_money) DESC) AS ranking") 65 queryPeople = queryPeople.ColumnExpr("ROW_NUMBER() OVER (ORDER BY sum(exchange_cash_person_list.exchanged_su_money) DESC) AS ranking")
  66 + queryPeople = queryPeople.Where("e.status = ?", 1)
66 if companyId, ok := queryOptions["companyId"]; ok && (companyId.(int64) != 0) { 67 if companyId, ok := queryOptions["companyId"]; ok && (companyId.(int64) != 0) {
67 queryPeople = queryPeople.Where("e.company_id = ?", companyId) 68 queryPeople = queryPeople.Where("e.company_id = ?", companyId)
68 } 69 }
@@ -122,6 +123,7 @@ func (dao *CashPoolDao) ExchangeCashListRanking(queryOptions map[string]interfac @@ -122,6 +123,7 @@ func (dao *CashPoolDao) ExchangeCashListRanking(queryOptions map[string]interfac
122 queryListSuMoney := tx.Model(exchangeCashPersonListModels) 123 queryListSuMoney := tx.Model(exchangeCashPersonListModels)
123 queryListSuMoney = queryListSuMoney.Join("JOIN employees AS e ON e.uid = exchange_cash_person_list.uid") 124 queryListSuMoney = queryListSuMoney.Join("JOIN employees AS e ON e.uid = exchange_cash_person_list.uid")
124 queryListSuMoney = queryListSuMoney.ColumnExpr("sum(exchange_cash_person_list.exchanged_su_money) AS activity_exchanged_su_money") 125 queryListSuMoney = queryListSuMoney.ColumnExpr("sum(exchange_cash_person_list.exchanged_su_money) AS activity_exchanged_su_money")
  126 + queryListSuMoney = queryListSuMoney.Where("e.status = ?", 1)
125 if companyId, ok := queryOptions["companyId"]; ok && (companyId.(int64) != 0) { 127 if companyId, ok := queryOptions["companyId"]; ok && (companyId.(int64) != 0) {
126 queryListSuMoney = queryListSuMoney.Where("e.company_id = ?", companyId) 128 queryListSuMoney = queryListSuMoney.Where("e.company_id = ?", companyId)
127 } 129 }
@@ -137,6 +139,7 @@ func (dao *CashPoolDao) ExchangeCashListRanking(queryOptions map[string]interfac @@ -137,6 +139,7 @@ func (dao *CashPoolDao) ExchangeCashListRanking(queryOptions map[string]interfac
137 queryListCash := tx.Model(exchangeCashPersonListModels) 139 queryListCash := tx.Model(exchangeCashPersonListModels)
138 queryListCash = queryListCash.Join("JOIN employees AS e ON e.uid = exchange_cash_person_list.uid") 140 queryListCash = queryListCash.Join("JOIN employees AS e ON e.uid = exchange_cash_person_list.uid")
139 queryListCash = queryListCash.ColumnExpr("sum(exchange_cash_person_list.exchanged_cash) AS activity_exchanged_cash") 141 queryListCash = queryListCash.ColumnExpr("sum(exchange_cash_person_list.exchanged_cash) AS activity_exchanged_cash")
  142 + queryListCash = queryListCash.Where("e.status = ?", 1)
140 if companyId, ok := queryOptions["companyId"]; ok && (companyId.(int64) != 0) { 143 if companyId, ok := queryOptions["companyId"]; ok && (companyId.(int64) != 0) {
141 queryListCash = queryListCash.Where("e.company_id = ?", companyId) 144 queryListCash = queryListCash.Where("e.company_id = ?", companyId)
142 } 145 }