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 expendSuMoney float64
	var incomeSuMoneyOfYesterday float64
	var expendSuMoneyOfYesterday 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 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, 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 IN (?)`, pg.In([]int{1, 4, 5})).
		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(&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 IN (?)`, pg.In([]int{2, 3, 6})).
		Select(&incomeSuMoney); 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{1, 4, 5})).
		Select(&expendSuMoney); err != nil {
		return nil, err
	}
	return map[string]interface{}{
		"incomeSuMoney":            incomeSuMoney - expendSuMoney,
		"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：增加 6: 兑换素币撤回）
		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, 6})).
		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, 5})).
		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": expendSuMoney, // 个人素币支出
	}, 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 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": expendContributions,  // 个人贡献支出
	}, 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("ROW_NUMBER() OVER (ORDER BY sum(su_money_transaction_record.su_money) DESC) AS ranking")
	queryWealth = queryWealth.Where(`su_money_transaction_record.record_type IN (?)`, pg.In([]int{2, 3, 6}))
	queryWealth = queryWealth.Where(`e.status = ?`, 1)  // 离职员工过滤
	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.GroupExpr("su_money_transaction_record.employee->>'uid',su_money_transaction_record.employee->>'employeeName'")

	// 个人财富值子查询
	queryWealthWith := queryWealth.Order("employee_su_money DESC")

	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("employee_su_money DESC")
	if err := queryWealth.Select(&retWealth); err != nil {
		return nil, err
	}

	// 个人财富值排名
	queryEmployeeWealth := tx.Model()
	queryEmployeeWealth = queryEmployeeWealth.With("t", queryWealthWith)
	queryEmployeeWealth = queryEmployeeWealth.Table("t")
	queryEmployeeWealth = queryEmployeeWealth.ColumnExpr("t.uid AS uid")
	queryEmployeeWealth = queryEmployeeWealth.ColumnExpr("t.employee_name AS employee_name")
	queryEmployeeWealth = queryEmployeeWealth.ColumnExpr("t.employee_su_money AS employee_su_money")
	queryEmployeeWealth = queryEmployeeWealth.ColumnExpr("t.ranking AS ranking")
	if uid, ok := queryOptions["uid"]; ok {
		queryEmployeeWealth = queryEmployeeWealth.Where("t.uid::bigint = ?", uid)
	}
	if err := queryEmployeeWealth.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("ROW_NUMBER() 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.GroupExpr("su_money_transaction_record.employee->>'uid',su_money_transaction_record.employee->>'employeeName'")

	// 贡献值排行榜
	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("ROW_NUMBER() OVER (ORDER BY sum(su_money_transaction_records.su_money) - t.employee_contributions_decrease DESC) AS ranking")
	queryContributions = queryContributions.Where(`su_money_transaction_records.record_type IN (?)`, pg.In([]int{2, 3}))
	queryContributions = queryContributions.Where(`e.status = ?`, 1)
	queryContributions = queryContributions.Where("e.uid = t.uid::bigint")
	if companyId, ok := queryOptions["companyId"]; ok && (companyId.(int64) != 0) {
		queryContributions = queryContributions.Where("e.company_id = ?", companyId)
	}
	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.GroupExpr("su_money_transaction_records.employee->>'uid',su_money_transaction_records.employee->>'employeeName',t.employee_contributions_decrease")

	// 个人贡献值子查询
	queryContributionsWith := queryContributions.Order("employees_contributions DESC")

	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
	}

	// 个人贡献值
	queryEmployeeContributions := tx.Model()
	queryEmployeeContributions = queryEmployeeContributions.With("t", queryContributionsWith)
	queryEmployeeContributions = queryEmployeeContributions.Table("t")
	queryEmployeeContributions = queryEmployeeContributions.ColumnExpr("t.uid AS uid")
	queryEmployeeContributions = queryEmployeeContributions.ColumnExpr("t.employee_name AS employee_name")
	queryEmployeeContributions = queryEmployeeContributions.ColumnExpr("t.employees_contributions AS employees_contributions")
	queryEmployeeContributions = queryEmployeeContributions.ColumnExpr("t.ranking AS ranking")
	if uid, ok := queryOptions["uid"]; ok {
		queryEmployeeContributions = queryEmployeeContributions.Where("t.uid::bigint = ?", uid)
	}
	if err := queryEmployeeContributions.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
	}
}