package dao

import (
	"fmt"
	"github.com/go-pg/pg"
	pgTransaction "github.com/linmadan/egglib-go/transaction/pg"
	"gitlab.fjmaimaimai.com/linmadan/mmm-worth/pkg/domain"
	"gitlab.fjmaimaimai.com/linmadan/mmm-worth/pkg/infrastructure/pg/models"
	"time"
)

type EmployeeDao struct {
	transactionContext *pgTransaction.TransactionContext
}

// 删除用户（stevechan: 删除员工为修改为禁用状态）
func (dao *EmployeeDao) BatchRemove(uids []int64) error {
	//tx := dao.transactionContext.PgTx
	//_, err := tx.QueryOne(
	//	pg.Scan(),
	//	"DELETE FROM employees WHERE uid IN (?)",
	//	pg.In(uids))
	//return err
	tx := dao.transactionContext.PgTx
	_, err := tx.QueryOne(
		pg.Scan(),
		"UPDATE employees SET status = 2 WHERE uid IN (?)",
		pg.In(uids))
	return err
}

// 设置用户状态
func (dao *EmployeeDao) BatchSetStatus(uids []int64, status int) error {
	tx := dao.transactionContext.PgTx
	_, err := tx.QueryOne(
		pg.Scan(),
		"UPDATE employees SET status=? WHERE uid IN (?)",
		status, pg.In(uids))
	return err
}

// 修改用户权限
func (dao *EmployeeDao) ChangePrincipal(companyId int64, employeeAccount string) error {
	tx := dao.transactionContext.PgTx
	if _, err := tx.Query(
		pg.Scan(),
		"UPDATE employees SET is_principal=? WHERE company_id=?",
		false, companyId); err != nil {
		return err
	}
	if _, err := tx.QueryOne(
		pg.Scan(),
		"UPDATE employees SET is_principal=? WHERE company_id=? AND employee_account=?",
		true, companyId, employeeAccount); err != nil {
		return err
	}
	return nil
}

// ChangePhone TODO 修改用户手机号
func (dao *EmployeeDao) ChangePhone(oldPhone string, newPhone string) error {
	tx := dao.transactionContext.PgTx
	if _, err := tx.QueryOne(
		pg.Scan(),
		"UPDATE employees SET employee_account=? WHERE employee_account=?",
		newPhone, oldPhone); err != nil {
		return err
	}
	return nil
}

// 更新用户素币
func (dao *EmployeeDao) TransferSuMoney(uid int64, suMoney float64) error {
	tx := dao.transactionContext.PgTx
	_, err := tx.QueryOne(
		pg.Scan(),
		"UPDATE employees SET su_money=su_money+? WHERE uid=?",
		suMoney, uid)
	return err
}

// 计算个人未读消息
func (dao *EmployeeDao) CalculatePersonUnReadNotification(uid int64) (map[string]int, error) {
	var unReadSystemNotification int
	var unReadInteractionNotification int
	tx := dao.transactionContext.PgTx
	sentNotificationModel := new(models.SentNotification)
	if count, err := tx.Model(sentNotificationModel).Relation("Notification").
		Where(`sent_notification.receiver @> '{"uid":?}'`, uid).
		Where("notification.notification_type = ?", domain.NOTIFICATION_TYPE_SYSTEM).
		Where("sent_notification.is_read = ?", false).
		Count(); err != nil {
		return nil, err
	} else {
		unReadSystemNotification = count
	}
	if count, err := tx.Model(sentNotificationModel).Relation("Notification").
		Where(`sent_notification.receiver @> '{"uid":?}'`, uid).
		Where("notification.notification_type = ?", domain.NOTIFICATION_TYPE_INTERACTION).
		Where("sent_notification.is_read = ?", false).
		Count(); err != nil {
		return nil, err
	} else {
		unReadInteractionNotification = count
	}
	return map[string]int{
		"unReadSystemNotification":      unReadSystemNotification,
		"unReadInteractionNotification": unReadInteractionNotification,
	}, nil
}

// 计算个人素币收益，昨日收益：做任务验收获得的素币+额外增加-扣除素币-兑换物资-兑换现金
func (dao *EmployeeDao) CalculatePersonSuMoney(uid int64) (map[string]interface{}, error) {
	var incomeSuMoney float64
	var incomeSuMoneyOfYesterday float64
	var expendSuMoneyOfYesterday float64
	tx := dao.transactionContext.PgTx
	suMoneyTransactionRecordModel := new(models.SuMoneyTransactionRecord)
	yesterday := time.Now().Local().AddDate(0, 0, -1)
	// 昨日收益
	if err := tx.Model(suMoneyTransactionRecordModel).
		ColumnExpr("sum(su_money_transaction_record.su_money) AS income_su_money").
		Where(`su_money_transaction_record.employee @> '{"uid":?}'`, uid).
		Where(`su_money_transaction_record.record_type IN (?)`, pg.In([]int{2, 3, 6})).
		Where(`su_money_transaction_record.create_time > ?`, time.Date(yesterday.Year(), yesterday.Month(), yesterday.Day(), 0, 0, 0, 0, time.Local)).
		Where(`su_money_transaction_record.create_time < ?`, time.Date(yesterday.Year(), yesterday.Month(), yesterday.Day(), 23, 59, 59, 0, time.Local)).
		Select(&incomeSuMoneyOfYesterday); err != nil {
		return nil, err
	}
	if err := tx.Model(suMoneyTransactionRecordModel).
		ColumnExpr("sum(su_money_transaction_record.su_money) AS income_su_money").
		Where(`su_money_transaction_record.employee @> '{"uid":?}'`, uid).
		Where(`su_money_transaction_record.record_type IN (?)`, pg.In([]int{4, 1, 5})).
		Where(`su_money_transaction_record.create_time > ?`, time.Date(yesterday.Year(), yesterday.Month(), yesterday.Day(), 0, 0, 0, 0, time.Local)).
		Where(`su_money_transaction_record.create_time < ?`, time.Date(yesterday.Year(), yesterday.Month(), yesterday.Day(), 23, 59, 59, 0, time.Local)).
		Select(&expendSuMoneyOfYesterday); err != nil {
		return nil, err
	}
	// 个人收益
	if err := tx.Model(suMoneyTransactionRecordModel).
		ColumnExpr("sum(su_money_transaction_record.su_money) AS income_su_money").
		Where(`su_money_transaction_record.employee @> '{"uid":?}'`, uid).
		Where(`su_money_transaction_record.record_type = ?`, 2).
		Select(&incomeSuMoney); err != nil {
		return nil, err
	}
	return map[string]interface{}{
		"incomeSuMoney":            incomeSuMoney,
		"incomeSuMoneyOfYesterday": incomeSuMoneyOfYesterday - expendSuMoneyOfYesterday,
	}, nil
}

// 计算系统已兑换现金素币、未兑换素币
func (dao *EmployeeDao) CalculateSystemSuMoney(companyId int64) (map[string]interface{}, error) {
	var systemUnExchangeSuMoney float64
	var systemExchangedSuMoney float64
	var systemExchangedSuMoneyRestore float64
	tx := dao.transactionContext.PgTx
	// 系统未兑换素币
	employeeModel := new(models.Employee)
	if err := tx.Model(employeeModel).
		ColumnExpr("sum(employee.su_money) AS system_unExchange_su_money").
		Where("employee.company_id = ?", companyId).
		Where("employee.status = ?", 1).
		Select(&systemUnExchangeSuMoney); err != nil {
		return nil, err
	}
	// 系统已兑换现金素币
	suMoneyTransactionRecordModel := new(models.SuMoneyTransactionRecord)
	if err := tx.Model(suMoneyTransactionRecordModel).Join("JOIN employees AS e ON e.uid = (su_money_transaction_record.employee->>'uid')::bigint").
		ColumnExpr("sum(su_money_transaction_record.su_money) AS system_exchanged_su_money").
		Where("e.company_id = ?", companyId).
		//Where("e.status = ?", 1).
		Where(`su_money_transaction_record.record_type = ?`, domain.SU_MONEY_TRANSACTION_RECORD_TYPE_EXCHANGE_CASH).
		Select(&systemExchangedSuMoney); err != nil {
		return nil, err
	}
	// 系统撤销的兑换现金素币
	if err := tx.Model(suMoneyTransactionRecordModel).Join("JOIN employees AS e ON e.uid = (su_money_transaction_record.employee->>'uid')::bigint").
		ColumnExpr("sum(su_money_transaction_record.su_money) AS system_exchanged_su_money").
		Where("e.company_id = ?", companyId).
		//Where("e.status = ?", 1).
		Where(`su_money_transaction_record.record_type = ?`, domain.SU_MONEY_TRANSACTION_RECORD_TYPE_EXCHANGE_CASH_RESTORE).
		Select(&systemExchangedSuMoneyRestore); err != nil {
		return nil, err
	}
	return map[string]interface{}{
		"systemUnExchangeSuMoney": systemUnExchangeSuMoney,
		"systemExchangedSuMoney":  systemExchangedSuMoney - systemExchangedSuMoneyRestore,
	}, nil
}

// 计算现金池已兑换现金、未兑换现金
func (dao *EmployeeDao) CalculateSystemCash(companyId int64) (map[string]interface{}, error) {
	tx := dao.transactionContext.PgTx
	var (
		systemUnExchangeCash float64
		systemExchangedCash  float64
	)
	// 系统已兑换现金
	cashPool := new(models.CashPool)
	if err := tx.Model(cashPool).
		Column("exchanged_cash").
		Where("cash_pool.company_id = ?", companyId).
		Order("id DESC").
		Limit(1).
		Select(&systemExchangedCash); err != nil {
		return nil, err
	}
	// 系统未兑换现金
	if err := tx.Model(cashPool).
		Column("un_exchange_cash").
		Where("cash_pool.company_id = ?", companyId).
		Order("id DESC").
		Limit(1).
		Select(&systemUnExchangeCash); err != nil {
		return nil, err
	}
	return map[string]interface{}{
		"systemUnExchangeCash": systemUnExchangeCash,
		"systemExchangedCash":  systemExchangedCash,
	}, nil
}

// 计算个人素币收支（素币明细收支）
func (dao *EmployeeDao) CalculateSuMoneyTransactionRecord(uid int64, transactionStartTime time.Time, transactionEndTime time.Time) (map[string]interface{}, error) {
	var (
		incomeSuMoney                float64 // 收入的素币（2：任务奖励，3：增加）
		expendSuMoney                float64 // 消耗的素币（1：兑换物资，4：扣除）
		expendSuMoneyExchange        float64 // 5: 兑换现金
		incomeSuMoneyExchangeRestore float64 // 6: 兑换素币撤回
	)
	tx := dao.transactionContext.PgTx
	suMoneyTransactionRecordModel := new(models.SuMoneyTransactionRecord)
	// 收入素币
	if err := tx.Model(suMoneyTransactionRecordModel).
		ColumnExpr("sum(su_money_transaction_record.su_money) AS income_su_money").
		Where(`su_money_transaction_record.employee @> '{"uid":?}'`, uid).
		Where(`su_money_transaction_record.record_type IN (?)`, pg.In([]int{2, 3})).
		Where(`su_money_transaction_record.create_time > ?`, transactionStartTime).
		Where(`su_money_transaction_record.create_time < ?`, transactionEndTime).
		Select(&incomeSuMoney); err != nil {
		return nil, err
	}
	// 支出素币
	if err := tx.Model(suMoneyTransactionRecordModel).
		ColumnExpr("sum(su_money_transaction_record.su_money) AS expend_su_money").
		Where(`su_money_transaction_record.employee @> '{"uid":?}'`, uid).
		Where(`su_money_transaction_record.record_type IN (?)`, pg.In([]int{1, 4})).
		Where(`su_money_transaction_record.create_time > ?`, transactionStartTime).
		Where(`su_money_transaction_record.create_time < ?`, transactionEndTime).
		Select(&expendSuMoney); err != nil {
		return nil, err
	}
	// 兑换现金的
	if err := tx.Model(suMoneyTransactionRecordModel).
		ColumnExpr("sum(su_money_transaction_record.su_money) AS expend_su_money").
		Where(`su_money_transaction_record.employee @> '{"uid":?}'`, uid).
		Where(`su_money_transaction_record.record_type = ?`, 5).
		Where(`su_money_transaction_record.create_time > ?`, transactionStartTime).
		Where(`su_money_transaction_record.create_time < ?`, transactionEndTime).
		Select(&expendSuMoneyExchange); err != nil {
		return nil, err
	}
	// 兑换现金撤回的
	if err := tx.Model(suMoneyTransactionRecordModel).
		ColumnExpr("sum(su_money_transaction_record.su_money) AS expend_su_money").
		Where(`su_money_transaction_record.employee @> '{"uid":?}'`, uid).
		Where(`su_money_transaction_record.record_type = ?`, 6).
		Where(`su_money_transaction_record.create_time > ?`, transactionStartTime).
		Where(`su_money_transaction_record.create_time < ?`, transactionEndTime).
		Select(&incomeSuMoneyExchangeRestore); err != nil {
		return nil, err
	}
	return map[string]interface{}{
		"incomeSuMoney": incomeSuMoney,                                                          // 个人素币收入
		"expendSuMoney": expendSuMoney + (expendSuMoneyExchange - incomeSuMoneyExchangeRestore), // 个人素币支出
	}, nil
}

// 计算个人贡献值收支（贡献明细收支）
func (dao *EmployeeDao) CalculateContributionsTransactionRecord(uid int64, transactionStartTime time.Time, transactionEndTime time.Time) (map[string]interface{}, error) {
	var (
		incomeContributions float64 // 收入的贡献值（2：任务奖励，3：增加）
		expendContributions float64 // 支出的贡献值 (4: 扣除)
	)
	tx := dao.transactionContext.PgTx
	suMoneyTransactionRecordModel := new(models.SuMoneyTransactionRecord)

	if transactionStartTime.IsZero() && transactionEndTime.IsZero() {
		transactionStartTime = time.Time{}
		transactionEndTime = time.Now()
	}

	// 收入的贡献值
	if err := tx.Model(suMoneyTransactionRecordModel).
		ColumnExpr("sum(su_money_transaction_record.su_money) AS income_su_money").
		Where(`su_money_transaction_record.employee @> '{"uid":?}'`, uid).
		Where(`su_money_transaction_record.record_type IN (?)`, pg.In([]int{2, 3})).
		Where(`su_money_transaction_record.create_time > ?`, transactionStartTime).
		Where(`su_money_transaction_record.create_time < ?`, transactionEndTime).
		Select(&incomeContributions); err != nil {
		return nil, err
	}
	// 支出的贡献值
	if err := tx.Model(suMoneyTransactionRecordModel).
		ColumnExpr("sum(su_money_transaction_record.su_money) AS expend_su_money").
		Where(`su_money_transaction_record.employee @> '{"uid":?}'`, uid).
		Where(`su_money_transaction_record.record_type = ?`, 4).
		Where(`su_money_transaction_record.create_time > ?`, transactionStartTime).
		Where(`su_money_transaction_record.create_time < ?`, transactionEndTime).
		Select(&expendContributions); err != nil {
		return nil, err
	}
	return map[string]interface{}{
		"incomeContributions": incomeContributions,                       // 个人贡献值收入
		"expendContributions": expendContributions,                       // 个人贡献支出
		"contributions":       incomeContributions - expendContributions, // 个人贡献值
	}, nil
}

// 贡献值、财富值总榜和年榜，
func (dao *EmployeeDao) ContributionsWealthRanking(queryOptions map[string]interface{}) (interface{}, error) {
	var retWealth []struct { // 个人财富值
		Uid             int64
		EmployeeName    string
		EmployeeSuMoney float64
		Ranking         int
	}
	var retEmployeeWealth []struct { // 个人贡献值
		Uid             int64
		EmployeeName    string
		EmployeeSuMoney float64
		Ranking         int
	}
	var retContributions []struct { // 员工贡献值
		Uid                    int64
		EmployeeName           string
		EmployeesContributions float64
		Ranking                int
	}
	var retEmployeeContributions []struct { // 员工贡献值
		Uid                    int64
		EmployeeName           string
		EmployeesContributions float64
		Ranking                int
	}

	tx := dao.transactionContext.PgTx
	suMoneyTransactionRecordModel := new(models.SuMoneyTransactionRecord)

	// 财富值排行榜
	queryWealth := tx.Model(suMoneyTransactionRecordModel)
	queryWealth = queryWealth.Join("JOIN employees AS e ON e.uid = (su_money_transaction_record.employee->>'uid')::bigint")
	queryWealth = queryWealth.ColumnExpr("su_money_transaction_record.employee->>'uid' AS uid")
	//queryWealth = queryWealth.ColumnExpr("su_money_transaction_record.employee->>'employeeName' AS employee_name")
	queryWealth = queryWealth.ColumnExpr("sum(case WHEN su_money_transaction_record.record_type IN (2, 3, 6) THEN su_money_transaction_record.su_money ELSE 0 end) - sum(case WHEN su_money_transaction_record.record_type IN (4, 1, 5) THEN su_money_transaction_record.su_money ELSE 0 end) AS employee_su_money")
	queryWealth = queryWealth.ColumnExpr("ROW_NUMBER() OVER (ORDER BY sum(case WHEN su_money_transaction_record.record_type IN (2, 3, 6) THEN su_money_transaction_record.su_money ELSE 0 end) - sum(case WHEN su_money_transaction_record.record_type IN (4, 1, 5) THEN su_money_transaction_record.su_money ELSE 0 end) DESC, e.create_time ASC) AS ranking")
	queryWealth = queryWealth.Where(`e.status = ?`, 1)
	//queryWealth = queryWealth.GroupExpr("su_money_transaction_record.employee->>'uid',su_money_transaction_record.employee->>'employeeName'")
	queryWealth = queryWealth.GroupExpr("su_money_transaction_record.employee->>'uid', e.create_time")
	if companyId, ok := queryOptions["companyId"]; ok && (companyId.(int64) != 0) {
		queryWealth = queryWealth.Where("e.company_id = ?", companyId)
	}
	if startTime, ok := queryOptions["startTime"]; ok && !startTime.(time.Time).IsZero() {
		queryWealth = queryWealth.Where(`su_money_transaction_record.create_time > ?`, startTime)
	}
	if endTime, ok := queryOptions["endTime"]; ok && !endTime.(time.Time).IsZero() {
		queryWealth = queryWealth.Where(`su_money_transaction_record.create_time < ?`, endTime)
	}
	if offset, ok := queryOptions["offset"]; ok {
		offset := offset.(int)
		if offset > -1 {
			queryWealth = queryWealth.Offset(offset)
		}
	} else {
		queryWealth = queryWealth.Offset(0)
	}
	if limit, ok := queryOptions["limit"]; ok {
		limit := limit.(int)
		if limit > -1 {
			queryWealth = queryWealth.Limit(limit)
		}
	} else {
		queryWealth = queryWealth.Limit(20)
	}
	queryWealth = queryWealth.Order("ranking ASC")
	if err := queryWealth.Select(&retWealth); err != nil {
		return nil, err
	}

	// 个人财富值排名
	queryWealthWith := tx.Model(suMoneyTransactionRecordModel)
	queryWealthWith = queryWealthWith.Join("JOIN employees AS e ON e.uid = (su_money_transaction_record.employee->>'uid')::bigint")
	queryWealthWith = queryWealthWith.ColumnExpr("su_money_transaction_record.employee->>'uid' AS uid")
	//queryWealthWith = queryWealthWith.ColumnExpr("su_money_transaction_record.employee->>'employeeName' AS employee_name")
	queryWealthWith = queryWealthWith.ColumnExpr("sum(case WHEN su_money_transaction_record.record_type IN (2, 3, 6) THEN su_money_transaction_record.su_money ELSE 0 end) - sum(case WHEN su_money_transaction_record.record_type IN (4, 1, 5) THEN su_money_transaction_record.su_money ELSE 0 end) AS employee_su_money")
	queryWealthWith = queryWealthWith.ColumnExpr("ROW_NUMBER() OVER (ORDER BY sum(case WHEN su_money_transaction_record.record_type IN (2, 3, 6) THEN su_money_transaction_record.su_money ELSE 0 end) - sum(case WHEN su_money_transaction_record.record_type IN (4, 1, 5) THEN su_money_transaction_record.su_money ELSE 0 end) DESC, e.create_time ASC) AS ranking")
	queryWealthWith = queryWealthWith.Where(`e.status = ?`, 1)
	if companyId, ok := queryOptions["companyId"]; ok && (companyId.(int64) != 0) {
		queryWealthWith = queryWealthWith.Where("e.company_id = ?", companyId)
	}
	if startTime, ok := queryOptions["startTime"]; ok && !startTime.(time.Time).IsZero() {
		queryWealthWith = queryWealthWith.Where(`su_money_transaction_record.create_time > ?`, startTime)
	}
	if endTime, ok := queryOptions["endTime"]; ok && !endTime.(time.Time).IsZero() {
		queryWealthWith = queryWealthWith.Where(`su_money_transaction_record.create_time < ?`, endTime)
	}
	//queryWealthRestoreWith := queryWealthWith.GroupExpr("su_money_transaction_record.employee->>'uid',su_money_transaction_record.employee->>'employeeName', e.create_time")
	queryWealthRestoreWith := queryWealthWith.GroupExpr("su_money_transaction_record.employee->>'uid', e.create_time")
	querySelfWealth := tx.Model()
	querySelfWealth = querySelfWealth.With("t", queryWealthRestoreWith)
	querySelfWealth = querySelfWealth.Table("t")
	querySelfWealth = querySelfWealth.ColumnExpr("t.uid AS uid")
	//querySelfWealth = querySelfWealth.ColumnExpr("t.employee_name AS employee_name")
	querySelfWealth = querySelfWealth.ColumnExpr("t.employee_su_money AS employee_su_money")
	querySelfWealth = querySelfWealth.ColumnExpr("t.ranking AS ranking")
	if uid, ok := queryOptions["uid"]; ok {
		querySelfWealth = querySelfWealth.Where("t.uid::bigint = ?", uid)
	}
	if err := querySelfWealth.Select(&retEmployeeWealth); err != nil {
		return nil, err
	}
	var retCurrentEmployeeWealth interface{}
	if len(retEmployeeWealth) == 0 {
		retCurrentEmployeeWealth = nil
	} else {
		retCurrentEmployeeWealth = retEmployeeWealth[0]
	}

	// 贡献值排行榜
	queryContributions := tx.Model(suMoneyTransactionRecordModel)
	queryContributions = queryContributions.Join("JOIN employees AS e ON e.uid = (su_money_transaction_record.employee->>'uid')::bigint")
	queryContributions = queryContributions.ColumnExpr("su_money_transaction_record.employee->>'uid' AS uid")
	//queryContributions = queryContributions.ColumnExpr("su_money_transaction_record.employee->>'employeeName' AS employee_name")
	queryContributions = queryContributions.ColumnExpr("sum(case WHEN su_money_transaction_record.record_type IN (2, 3) THEN su_money_transaction_record.su_money ELSE 0 end) - sum(case WHEN su_money_transaction_record.record_type = 4 THEN su_money_transaction_record.su_money ELSE 0 end) AS employees_contributions")
	queryContributions = queryContributions.ColumnExpr("ROW_NUMBER() OVER (ORDER BY sum(case WHEN su_money_transaction_record.record_type IN (2, 3) THEN su_money_transaction_record.su_money ELSE 0 end) - sum(case WHEN su_money_transaction_record.record_type = 4 THEN su_money_transaction_record.su_money ELSE 0 end) DESC, e.create_time ASC) AS ranking")
	queryContributions = queryContributions.Where(`e.status = ?`, 1)
	//queryContributions = queryContributions.GroupExpr("su_money_transaction_record.employee->>'uid',su_money_transaction_record.employee->>'employeeName'")
	queryContributions = queryContributions.GroupExpr("su_money_transaction_record.employee->>'uid', e.create_time")
	if companyId, ok := queryOptions["companyId"]; ok && (companyId.(int64) != 0) {
		queryContributions = queryContributions.Where("e.company_id = ?", companyId)
	}
	if startTime, ok := queryOptions["startTime"]; ok && !startTime.(time.Time).IsZero() {
		queryContributions = queryContributions.Where(`su_money_transaction_record.create_time > ?`, startTime)
	}
	if endTime, ok := queryOptions["endTime"]; ok && !endTime.(time.Time).IsZero() {
		queryContributions = queryContributions.Where(`su_money_transaction_record.create_time < ?`, endTime)
	}
	if offset, ok := queryOptions["offset"]; ok {
		offset := offset.(int)
		if offset > -1 {
			queryContributions = queryContributions.Offset(offset)
		}
	} else {
		queryContributions = queryContributions.Offset(0)
	}
	if limit, ok := queryOptions["limit"]; ok {
		limit := limit.(int)
		if limit > -1 {
			queryContributions = queryContributions.Limit(limit)
		}
	} else {
		queryContributions = queryContributions.Limit(20)
	}
	if err := queryContributions.Order("ranking ASC").Select(&retContributions); err != nil {
		return nil, err
	}

	// 个人贡献值排名
	queryContributionsWith := tx.Model(suMoneyTransactionRecordModel)
	queryContributionsWith = queryContributionsWith.Join("JOIN employees AS e ON e.uid = (su_money_transaction_record.employee->>'uid')::bigint")
	queryContributionsWith = queryContributionsWith.ColumnExpr("su_money_transaction_record.employee->>'uid' AS uid")
	//queryContributionsWith = queryContributionsWith.ColumnExpr("su_money_transaction_record.employee->>'employeeName' AS employee_name")
	queryContributionsWith = queryContributionsWith.ColumnExpr("sum(case WHEN su_money_transaction_record.record_type IN (2, 3) THEN su_money_transaction_record.su_money ELSE 0 end) - sum(case WHEN su_money_transaction_record.record_type = 4 THEN su_money_transaction_record.su_money ELSE 0 end) AS employees_contributions")
	queryContributionsWith = queryContributionsWith.ColumnExpr("ROW_NUMBER() OVER (ORDER BY sum(case WHEN su_money_transaction_record.record_type IN (2, 3) THEN su_money_transaction_record.su_money ELSE 0 end) - sum(case WHEN su_money_transaction_record.record_type = 4 THEN su_money_transaction_record.su_money ELSE 0 end) DESC, e.create_time ASC) AS ranking")
	queryContributionsWith = queryContributionsWith.Where(`e.status = ?`, 1)
	if companyId, ok := queryOptions["companyId"]; ok && (companyId.(int64) != 0) {
		queryContributionsWith = queryContributionsWith.Where("e.company_id = ?", companyId)
	}
	if startTime, ok := queryOptions["startTime"]; ok && !startTime.(time.Time).IsZero() {
		queryContributionsWith = queryContributionsWith.Where(`su_money_transaction_record.create_time > ?`, startTime)
	}
	if endTime, ok := queryOptions["endTime"]; ok && !endTime.(time.Time).IsZero() {
		queryContributionsWith = queryContributionsWith.Where(`su_money_transaction_record.create_time < ?`, endTime)
	}
	//contributionsWith := queryContributionsWith.GroupExpr("su_money_transaction_record.employee->>'uid',su_money_transaction_record.employee->>'employeeName', e.create_time")
	contributionsWith := queryContributionsWith.GroupExpr("su_money_transaction_record.employee->>'uid', e.create_time")
	querySelfContributions := tx.Model()
	querySelfContributions = querySelfContributions.With("t", contributionsWith)
	querySelfContributions = querySelfContributions.Table("t")
	querySelfContributions = querySelfContributions.ColumnExpr("t.uid AS uid")
	//querySelfContributions = querySelfContributions.ColumnExpr("t.employee_name AS employee_name")
	querySelfContributions = querySelfContributions.ColumnExpr("t.employees_contributions AS employees_contributions")
	querySelfContributions = querySelfContributions.ColumnExpr("t.ranking AS ranking")
	if uid, ok := queryOptions["uid"]; ok {
		querySelfContributions = querySelfContributions.Where("t.uid::bigint = ?", uid)
	}
	if err := querySelfContributions.Select(&retEmployeeContributions); err != nil {
		return nil, err
	}

	var retCurrentEmployeeContributions interface{}
	if len(retEmployeeContributions) == 0 {
		retCurrentEmployeeContributions = nil
	} else {
		retCurrentEmployeeContributions = retEmployeeContributions[0]
	}

	return map[string]interface{}{
		"employeesWealth":              retWealth,
		"employeesContributions":       retContributions,
		"currentEmployeeContributions": retCurrentEmployeeContributions,
		"currentEmployeeWealth":        retCurrentEmployeeWealth,
	}, nil
}

// 公司员工贡献值分组统计
func (dao *EmployeeDao) CalculateEmployeesContributions(companyId int, startTime time.Time, endTime time.Time) (map[string]interface{}, error) {
	var ret []struct { // 员工贡献值
		Uid                    int
		EmployeeName           string
		EmployeesContributions float64
	}
	var retDecrease []struct { // 员工减少的贡献值
		Uid                    int
		EmployeeName           string
		EmployeesContributions float64
	}
	tx := dao.transactionContext.PgTx
	suMoneyTransactionRecordModel := new(models.SuMoneyTransactionRecord)
	// 增加的贡献值
	if err := tx.Model(suMoneyTransactionRecordModel).Join("JOIN employees AS e ON e.uid = (su_money_transaction_record.employee->>'uid')::bigint").
		ColumnExpr("su_money_transaction_record.employee->>'uid' AS uid").
		ColumnExpr("su_money_transaction_record.employee->>'employeeName' AS employee_name").
		ColumnExpr("sum(su_money_transaction_record.su_money) AS employees_contributions").
		Where(`e.company_id = ?`, companyId).
		Where(`su_money_transaction_record.record_type IN (?)`, pg.In([]int{2, 3})).
		//Where(`e.status = ?`, 1).
		Where(`su_money_transaction_record.create_time > ?`, startTime).
		Where(`su_money_transaction_record.create_time < ?`, endTime).
		Group("su_money_transaction_record.employee").
		Order("employees_contributions DESC").
		Select(&ret); err != nil {
		return nil, err
	}
	// 减少的贡献值
	if err := tx.Model(suMoneyTransactionRecordModel).Join("JOIN employees AS e ON e.uid = (su_money_transaction_record.employee->>'uid')::bigint").
		ColumnExpr("su_money_transaction_record.employee->>'uid' AS uid").
		ColumnExpr("su_money_transaction_record.employee->>'employeeName' AS employee_name").
		ColumnExpr("sum(su_money_transaction_record.su_money) AS employees_contributions").
		Where(`e.company_id = ?`, companyId).
		Where(`su_money_transaction_record.record_type = ?`, 4).
		//Where(`e.status = ?`, 1).
		Where(`su_money_transaction_record.create_time > ?`, startTime).
		Where(`su_money_transaction_record.create_time < ?`, endTime).
		Group("su_money_transaction_record.employee").
		Order("employees_contributions DESC").
		Select(&retDecrease); err != nil {
		return nil, err
	}
	for i := 0; i < len(ret); i++ {
		for j := 0; j < len(retDecrease); j++ {
			if ret[i].Uid == retDecrease[j].Uid {
				ret[i].EmployeesContributions -= retDecrease[j].EmployeesContributions
			}
		}
	}
	return map[string]interface{}{
		"employeesContributions": ret,
	}, nil
}

// 公司员工财富值分组统计
func (dao *EmployeeDao) CalculateEmployeesSuMoney(companyId int, startTime time.Time, endTime time.Time) (map[string]interface{}, error) {
	var ret []struct {
		Uid             int
		EmployeeName    string
		EmployeeSuMoney float64
	}
	tx := dao.transactionContext.PgTx
	suMoneyTransactionRecordModel := new(models.SuMoneyTransactionRecord)
	if err := tx.Model(suMoneyTransactionRecordModel).Join("JOIN employees AS e ON e.uid = (su_money_transaction_record.employee->>'uid')::bigint").
		ColumnExpr("su_money_transaction_record.employee->>'uid' AS uid").
		ColumnExpr("su_money_transaction_record.employee->>'employeeName' AS employee_name").
		ColumnExpr("sum(su_money_transaction_record.su_money) AS employee_su_money").
		Where(`e.company_id = ?`, companyId).
		//Where(`e.status = ?`, 1).
		Where(`su_money_transaction_record.record_type IN (?)`, pg.In([]int{2, 3})). // 增加，任务奖励的
		Where(`su_money_transaction_record.create_time > ?`, startTime).
		Where(`su_money_transaction_record.create_time < ?`, endTime).
		Group("su_money_transaction_record.employee").
		Order("employee_su_money DESC").
		Select(&ret); err != nil {
		return nil, err
	}
	return map[string]interface{}{
		"employeesSuMoney": ret,
	}, nil
}

func NewEmployeeDao(transactionContext *pgTransaction.TransactionContext) (*EmployeeDao, error) {
	if transactionContext == nil {
		return nil, fmt.Errorf("transactionContext参数不能为nil")
	} else {
		return &EmployeeDao{
			transactionContext: transactionContext,
		}, nil
	}
}