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
}

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
}

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
}

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
	tx := dao.transactionContext.PgTx
	suMoneyTransactionRecordModel := new(models.SuMoneyTransactionRecord)
	yesterday := time.Now().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 = ?`, 2).
		Where(`su_money_transaction_record.create_time > ?`, time.Date(yesterday.Year(), yesterday.Month(), yesterday.Day(), 0, 0, 0, 0, yesterday.Location())).
		Where(`su_money_transaction_record.create_time < ?`, time.Date(yesterday.Year(), yesterday.Month(), yesterday.Day(), 23, 59, 59, 0, yesterday.Location())).
		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 = ?`, 2).
		Select(&incomeSuMoney); err != nil {
		return nil, err
	}
	return map[string]interface{}{
		"incomeSuMoney":            incomeSuMoney,
		"incomeSuMoneyOfYesterday": incomeSuMoneyOfYesterday,
	}, nil
}

// 系统已兑换素币、未兑换素币
func (dao *EmployeeDao) CalculateSystemSuMoney(companyId int64) (map[string] interface{}, error) {
	var systemUnExchangeSuMoney float64
	var systemExchangedSuMoney 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_changed_su_money").
		Where("e.company_id = ?", companyId).
		Where("e.status = ?", 1).
		Where(`su_money_transaction_record.record_type = ?`, 5).
		Select(&systemExchangedSuMoney); err != nil {
		return nil, err
	}
	return  map[string] interface{} {
		"systemUnExchangeSuMoney": systemUnExchangeSuMoney,
		"systemExchangedSuMoney": systemExchangedSuMoney,
	},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：增加）
	var expendSuMoney float64  // 消耗的素币（1：兑换物资，4：扣除, 5: 兑换现金）
	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
	}
	return map[string]interface{}{
		"incomeSuMoney": incomeSuMoney,
		"expendSuMoney": expendSuMoney,
	}, 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 (dao *EmployeeDao) CalculateEmployeesSuMoney(queryOptions map[string]interface{}) (map[string]interface{}, error) {
//	var ret []struct {
//		Uid int
//		EmployeeName string
//		EmployeeSuMoney float64
//	}
//	tx := dao.transactionContext.PgTx
//	var (
//		startTime time.Time
//		endTime time.Time
//		companyId int
//	)
//	if company, ok := queryOptions["companyId"].(int); ok {
//		companyId = company
//	}
//	if start, ok := queryOptions["startTime"].(time.Time); ok {
//		startTime = start
//	} else {
//		startTime = time.Date(1971, time.Month(1), 1, 0, 0, 0, 0, time.Now().Location())
//	}
//	if end, ok := queryOptions["endTime"].(time.Time); ok {
//		endTime = end
//	} else {
//		endTime = time.Now()
//	}
//	fmt.Print(startTime, "\n")
//	fmt.Print(endTime, "\n")
//	fmt.Print(companyId, "\n")
//	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 (dao *EmployeeDao) ContributionsWealthRanking(queryOptions map[string]interface{}) (interface{}, error) {
	var retWealth []struct {
		Uid int
		EmployeeName string
		EmployeeSuMoney float64
		Ranking int
	}
	var retEmployeeWealth []struct {
		Uid int
		EmployeeName string
		EmployeeSuMoney float64
		Ranking int
	}
	var retContributions []struct {   // 员工贡献值
		Uid int
		EmployeeName string
		EmployeesContributions float64
		Ranking int
	}
	var retEmployeeContributions []struct {   // 员工贡献值
		Uid int
		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(su_money_transaction_record.su_money) AS employee_su_money")
	queryWealth = queryWealth.ColumnExpr("RANK() OVER (ORDER BY sum(su_money_transaction_record.su_money) DESC) AS ranking")
	queryWealth = queryWealth.Where(`e.status = ?`, 1)
	queryWealth = queryWealth.Where(`su_money_transaction_record.record_type IN (?)`, pg.In([]int{2, 3}))
	if companyId, ok := queryOptions["companyId"]; ok && (companyId.(int64) != 0) {
		queryWealth = queryWealth.Where("e.company_id = ?", companyId)
	}
	if startTime, ok := queryOptions["startTime"]; ok {
		queryWealth = queryWealth.Where(`su_money_transaction_record.create_time > ?`, startTime)
	}
	if endTime, ok := queryOptions["endTime"]; ok {
		queryWealth = queryWealth.Where(`su_money_transaction_record.create_time < ?`, endTime)
	}
	queryWealth = queryWealth.Group("su_money_transaction_record.employee")
	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)
	}
	if err := queryWealth.Order("employee_su_money DESC").Select(&retWealth); err != nil {
		return nil, err
	}

	// 当前员工财富值排名
	queryEmployeeWealth := tx.Model(suMoneyTransactionRecordModel)
	queryEmployeeWealth = queryEmployeeWealth.Join("JOIN employees AS e ON e.uid = (su_money_transaction_record.employee->>'uid')::bigint")
	queryEmployeeWealth = queryEmployeeWealth.ColumnExpr("su_money_transaction_record.employee->>'uid' AS uid")
	queryEmployeeWealth = queryEmployeeWealth.ColumnExpr("su_money_transaction_record.employee->>'employeeName' AS employee_name")
	queryEmployeeWealth = queryEmployeeWealth.ColumnExpr("sum(su_money_transaction_record.su_money) AS employee_su_money")
	queryEmployeeWealth = queryEmployeeWealth.ColumnExpr("RANK() OVER (ORDER BY sum(su_money_transaction_record.su_money) DESC) AS ranking")
	queryEmployeeWealth = queryEmployeeWealth.Where(`e.status = ?`, 1)
	queryEmployeeWealth = queryEmployeeWealth.Where(`su_money_transaction_record.record_type IN (?)`, pg.In([]int{2, 3}))
	if companyId, ok := queryOptions["companyId"]; ok && (companyId.(int64) != 0) {
		queryEmployeeWealth = queryEmployeeWealth.Where("e.company_id = ?", companyId)
	}
	if startTime, ok := queryOptions["startTime"]; ok {
		queryEmployeeWealth = queryEmployeeWealth.Where(`su_money_transaction_record.create_time > ?`, startTime)
	}
	if endTime, ok := queryOptions["endTime"]; ok {
		queryEmployeeWealth = queryEmployeeWealth.Where(`su_money_transaction_record.create_time < ?`, endTime)
	}
	if uid, ok := queryOptions["uid"]; ok {
		queryEmployeeWealth = queryEmployeeWealth.Where(`su_money_transaction_record.employee @> '{"uid":?}'`, uid)
	}
	queryEmployeeWealth = queryEmployeeWealth.Group("su_money_transaction_record.employee")
	if err := queryEmployeeWealth.Order("employee_su_money DESC").Select(&retEmployeeWealth); err != nil {
		return nil, err
	}
	var retCurrentEmployeeWealth interface{}
	if len(retEmployeeWealth) == 0 {
		retCurrentEmployeeWealth = nil
	} else {
		retCurrentEmployeeWealth = retEmployeeWealth[0]
	}

	// 贡献值榜单
	queryContributionsDecrease := tx.Model(suMoneyTransactionRecordModel)
	queryContributionsDecrease = queryContributionsDecrease.Join("JOIN employees AS e ON e.uid = (su_money_transaction_record.employee->>'uid')::bigint")
	queryContributionsDecrease = queryContributionsDecrease.ColumnExpr("su_money_transaction_record.employee->>'uid' AS uid")
	queryContributionsDecrease = queryContributionsDecrease.ColumnExpr("su_money_transaction_record.employee->>'employeeName' AS employee_name")
	queryContributionsDecrease = queryContributionsDecrease.ColumnExpr("sum(su_money_transaction_record.su_money) AS employee_contributions_decrease")
	queryContributionsDecrease = queryContributionsDecrease.ColumnExpr("RANK() OVER (ORDER BY sum(su_money_transaction_record.su_money) DESC) AS ranking")
	if companyId, ok := queryOptions["companyId"]; ok && (companyId.(int64) != 0) {
		queryContributionsDecrease = queryContributionsDecrease.Where("e.company_id = ?", companyId)
	}
	queryContributionsDecrease = queryContributionsDecrease.Where(`e.status = ?`, 1)
	queryContributionsDecrease = queryContributionsDecrease.Where(`su_money_transaction_record.record_type = ?`, 4)
	if startTime, ok := queryOptions["startTime"]; ok {
		queryContributionsDecrease = queryContributionsDecrease.Where(`su_money_transaction_record.create_time > ?`, startTime)
	}
	if endTime, ok := queryOptions["endTime"]; ok {
		queryContributionsDecrease = queryContributionsDecrease.Where(`su_money_transaction_record.create_time < ?`, endTime)
	}
	contributionsDecrease := queryContributionsDecrease.Group("su_money_transaction_record.employee")

	//if offset, ok := queryOptions["offset"]; ok {
	//	offset := offset.(int)
	//	if offset > -1 {
	//		queryContributionsDecrease = queryContributionsDecrease.Offset(offset)
	//	}
	//} else {
	//	queryContributionsDecrease = queryContributionsDecrease.Offset(0)
	//}
	//if limit, ok := queryOptions["limit"]; ok {
	//	limit := limit.(int)
	//	if limit > -1 {
	//		queryContributionsDecrease = queryContributionsDecrease.Limit(limit)
	//	}
	//} else {
	//	queryContributionsDecrease = queryContributionsDecrease.Limit(20)
	//}
	//contributionsDecrease := queryWealth.Order("employee_contributions_decrease DESC")

	queryContributions := tx.Model()
	queryContributions = queryContributions.With("t", contributionsDecrease)
	queryContributions = queryContributions.Table("t")
	queryContributions = queryContributions.Table("su_money_transaction_records")
	queryContributions = queryContributions.Join("JOIN employees AS e ON e.uid = (su_money_transaction_records.employee->>'uid')::bigint")
	queryContributions = queryContributions.ColumnExpr("su_money_transaction_records.employee->>'uid' AS uid")
	queryContributions = queryContributions.ColumnExpr("su_money_transaction_records.employee->>'employeeName' AS employee_name")
	queryContributions = queryContributions.ColumnExpr(`(sum(su_money_transaction_records.su_money) - t.employee_contributions_decrease) AS employees_contributions`)
	queryContributions = queryContributions.ColumnExpr("RANK() OVER (ORDER BY sum(su_money_transaction_records.su_money) - t.employee_contributions_decrease DESC) AS ranking")
	if companyId, ok := queryOptions["companyId"]; ok && (companyId.(int64) != 0) {
		queryContributions = queryContributions.Where("e.company_id = ?", companyId)
	}
	queryContributions = queryContributions.Where(`e.status = ?`, 1)
	queryContributions = queryContributions.Where(`su_money_transaction_records.record_type IN (?)`, pg.In([]int{2, 3}))
	if startTime, ok := queryOptions["startTime"]; ok {
		queryContributions = queryContributions.Where(`su_money_transaction_records.create_time > ?`, startTime)
	}
	if endTime, ok := queryOptions["endTime"]; ok {
		queryContributions = queryContributions.Where(`su_money_transaction_records.create_time < ?`, endTime)
	}
	queryContributions = queryContributions.Group("su_money_transaction_records.employee")
	queryContributions = queryContributions.Group("t.employee_contributions_decrease")
	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("employees_contributions DESC").Select(&retContributions); err != nil {
		return nil, err
	}

	// 当前员工贡献值排名
	queryEmployeeContributionsDecrease := tx.Model(suMoneyTransactionRecordModel)
	queryEmployeeContributionsDecrease = queryEmployeeContributionsDecrease.Join("JOIN employees AS e ON e.uid = (su_money_transaction_record.employee->>'uid')::bigint")
	queryEmployeeContributionsDecrease = queryEmployeeContributionsDecrease.ColumnExpr("su_money_transaction_record.employee->>'uid' AS uid")
	queryEmployeeContributionsDecrease = queryEmployeeContributionsDecrease.ColumnExpr("su_money_transaction_record.employee->>'employeeName' AS employee_name")
	queryEmployeeContributionsDecrease = queryEmployeeContributionsDecrease.ColumnExpr("sum(su_money_transaction_record.su_money) AS employee_contributions_decrease")
	queryEmployeeContributionsDecrease = queryEmployeeContributionsDecrease.ColumnExpr("RANK() OVER (ORDER BY sum(su_money_transaction_record.su_money) DESC) AS ranking")
	if companyId, ok := queryOptions["companyId"]; ok && (companyId.(int64) != 0) {
		queryEmployeeContributionsDecrease = queryEmployeeContributionsDecrease.Where("e.company_id = ?", companyId)
	}
	queryEmployeeContributionsDecrease = queryEmployeeContributionsDecrease.Where(`e.status = ?`, 1)
	queryEmployeeContributionsDecrease = queryEmployeeContributionsDecrease.Where(`su_money_transaction_record.record_type = ?`, 4)
	if startTime, ok := queryOptions["startTime"]; ok {
		queryEmployeeContributionsDecrease = queryEmployeeContributionsDecrease.Where(`su_money_transaction_record.create_time > ?`, startTime)
	}
	if endTime, ok := queryOptions["endTime"]; ok {
		queryEmployeeContributionsDecrease = queryEmployeeContributionsDecrease.Where(`su_money_transaction_record.create_time < ?`, endTime)
	}
	employeeContributionsDecrease := queryEmployeeContributionsDecrease.Group("su_money_transaction_record.employee")

	queryEmployeeContributions := tx.Model()
	queryEmployeeContributions = queryEmployeeContributions.With("t", employeeContributionsDecrease)
	queryEmployeeContributions = queryEmployeeContributions.Table("t")
	queryEmployeeContributions = queryEmployeeContributions.Table("su_money_transaction_records")
	queryEmployeeContributions = queryEmployeeContributions.Join("JOIN employees AS e ON e.uid = (su_money_transaction_records.employee->>'uid')::bigint")
	queryEmployeeContributions = queryEmployeeContributions.ColumnExpr("su_money_transaction_records.employee->>'uid' AS uid")
	queryEmployeeContributions = queryEmployeeContributions.ColumnExpr("su_money_transaction_records.employee->>'employeeName' AS employee_name")
	queryEmployeeContributions = queryEmployeeContributions.ColumnExpr(`(sum(su_money_transaction_records.su_money) - t.employee_contributions_decrease) AS employees_contributions`)
	queryEmployeeContributions = queryEmployeeContributions.ColumnExpr("RANK() OVER (ORDER BY sum(su_money_transaction_records.su_money) - t.employee_contributions_decrease DESC) AS ranking")
	if companyId, ok := queryOptions["companyId"]; ok && (companyId.(int64) != 0) {
		queryEmployeeContributions = queryContributions.Where("e.company_id = ?", companyId)
	}
	queryEmployeeContributions = queryEmployeeContributions.Where(`e.status = ?`, 1)
	queryEmployeeContributions = queryEmployeeContributions.Where(`su_money_transaction_records.record_type IN (?)`, pg.In([]int{2, 3}))
	if startTime, ok := queryOptions["startTime"]; ok {
		queryEmployeeContributions = queryEmployeeContributions.Where(`su_money_transaction_records.create_time > ?`, startTime)
	}
	if endTime, ok := queryOptions["endTime"]; ok {
		queryEmployeeContributions = queryEmployeeContributions.Where(`su_money_transaction_records.create_time < ?`, endTime)
	}
	if uid, ok := queryOptions["uid"]; ok {
		queryEmployeeContributions = queryEmployeeContributions.Where(`su_money_transaction_records.employee @> '{"uid":?}'`, uid)
	}
	queryEmployeeContributions = queryEmployeeContributions.Group("su_money_transaction_records.employee")
	queryEmployeeContributions = queryEmployeeContributions.Group("t.employee_contributions_decrease")
	if err := queryEmployeeContributions.Order("employees_contributions DESC").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) CalculateEmployeesRankingList(companyId int, startTime time.Time, endTime time.Time, offset int, limit int) (map[string]interface{}, error) {
	var retWealth []struct {
		Uid int
		EmployeeName string
		EmployeeSuMoney float64
		Ranking int
	}
	var retContributions []struct {   // 员工贡献值
		Uid int
		EmployeeName string
		EmployeesContributions float64
		Ranking int
	}
	var retContributionDecrease []struct {  // 员工减少的贡献值
		Uid int
		EmployeeName string
		EmployeesContributions float64
		Ranking int
	}
	tx := dao.transactionContext.PgTx
	suMoneyTransactionRecordModel := new(models.SuMoneyTransactionRecord)
	if limit < -1 {
		limit = 20
	}
	if offset < -1 {
		offset = 0
	}
	// 员工财富值
	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").
		Limit(limit).
		Offset(offset).
		Select(&retWealth); 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 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").
		Limit(limit).
		Offset(offset).
		Select(&retContributions); 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").
		Limit(limit).
		Offset(offset).
		Select(&retContributionDecrease); err != nil {
		return nil, err
	}
	for i := 0; i < len(retContributions); i++ {
		for j := 0; j < len(retContributionDecrease); j++ {
			if retContributions[i].Uid == retContributionDecrease[j].Uid {
				retContributions[i].EmployeesContributions -= retContributionDecrease[j].EmployeesContributions
			}
		}
	}
	return map[string]interface{}{
		"employeesContributions": retContributions,
		"employeesWealth": retWealth,
	}, 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 NewEmployeeDao(transactionContext *pgTransaction.TransactionContext) (*EmployeeDao, error) {
	if transactionContext == nil {
		return nil, fmt.Errorf("transactionContext参数不能为nil")
	} else {
		return &EmployeeDao{
			transactionContext: transactionContext,
		}, nil
	}
}