lims_adapter/service/account/account.go

package account

import (
	"dashoo.cn/micro_libary/request"
	"database/sql"
	"fmt"
	"github.com/gogf/gf/os/gtime"
	dao "lims_adapter/dao/account"
	account "lims_adapter/model/account"
	"math"
	"strconv"
)

// Service 账号相关
type Service struct {
	Dao    *dao.SettleAccountMainDao
	Tenant string
}

type AccountService struct {
	Dao    *dao.BaseAccountDao
	Tenant string
}

func NewAccountSrv(tenant string) AccountService {
	return AccountService{Dao: dao.NewBaseAccountDao(tenant), Tenant: tenant}
}

// AddAccount 添加财务账号
func (s AccountService) Save(req *account.BaseAccount, user request.UserInfo) error {
	now := gtime.Now()
	if req.Id == 0 {
		req.CreateUserId = int(user.Id)
		req.CreateBy = user.RealName
		req.CreateOn = now
	}
	req.UpdateUserId = int(user.Id)
	req.UpdateBy = user.RealName
	req.UpdateOn = now

	_, err := s.Dao.Save(req)
	return err
}

// AccountList 财务账号分页查询
func (s AccountService) AccountList(req *account.AccountReq) (infos account.BaseAccountRsp, err error) {
	current := req.PageNun
	size := req.PageSize
	model := s.Dao.DB.Model("base_account a")
	if req.Account != "" {
		model = model.WhereLike("Account", "%" + req.Account + "%")
	}
	if req.RealName != "" {
		model = model.WhereLike("MainUser", "%" + req.RealName + "%")
	}
	if req.AccountName != "" {
		model = model.WhereLike("AccountName", "%" + req.AccountName + "%")
	}
	infos.Total, err = model.Count()
	if err != nil {
		return infos, err
	}
	err = model.Fields("a.*").Page(current, size).Scan(&infos.Records)
	return infos, nil
}

// DepositAccount 充值账户
func (s AccountService) DepositAccount(req *account.BaseAccountResp) error {
	_, err := s.Dao.M.Update(fmt.Sprintf("Surplus='%v',Available='%v'", req.Surplus, req.Available), "Id = "+strconv.Itoa(req.Id))
	return err
}

// 计算费用
func (s AccountService) Calculate(req *account.CalculateAmountReq) error {
	var main account.SettleAccountMain
	var detail account.SettleAccountDetail
	var baseAccount account.BaseAccount

	// 获取结算明细记录
	result, err := s.Dao.DB.Model("settle_account_main").Where(fmt.Sprintf("AppointId='%v'", req.AppointId)).FindOne()
	if err != nil {
		if err != sql.ErrNoRows {
			return err
		} else {
			// 预约没有对应的结算明细记录，返回
			return nil
		}
	}
	err = result.Struct(&main)
	if err != nil && err != sql.ErrNoRows {
		return err
	}
	if main.Id == 0 { // 预约没有对应的结算明细记录，返回
		return nil
	}

	// 获取费用明细记录
	result, err = s.Dao.DB.Model("settle_account_detail").Where(fmt.Sprintf("pid='%v' AND PaymentType='0'", main.Id)).FindOne()
	if err != nil {
		return err
	}
	err = result.Struct(&detail)
	if err != nil {
		return err
	}

	// 获取账号信息
	result, err = s.Dao.DB.Model("base_account").Where(fmt.Sprintf("MainUserId='%v'", main.MainUserId)).Order("Advance ASC").FindOne()
	if err != nil {
		return err
	}
	err = result.Struct(&baseAccount)
	if err != nil {
		return err
	}

	// 计算费用
	oldAmount := detail.PaymentAccount
	main.ActualStartDate = req.SignInTime
	main.ActualEndDate = req.SignOutTime

	span := req.SignOutTime.Sub(req.SignInTime)
	main.FeeTime = int(math.Ceil(span.Minutes()))
	main.ActualMachineHour = main.FeeTime
	detail.ActualMinutes = strconv.Itoa(main.FeeTime)
	detail.Minutes = strconv.Itoa(main.FeeTime)

	detail.PaymentAccount = float64(main.ActualMachineHour) * detail.UnitPrice / 60 // 计算实际费用
	diffValue := oldAmount - detail.PaymentAccount
	main.TotalPrice -= diffValue // 计算实际费用

	baseAccount.Available -= diffValue // 账户可用金额计算

	tx, err := s.Dao.DB.Begin()
	if err != nil {
		return err
	}

	_, err = tx.Save("settle_account_main", main)
	if err != nil {
		tx.Rollback()
		return err
	}
	_, err = tx.Save("settle_account_detail", detail)
	if err != nil {
		tx.Rollback()
		return err
	}
	_, err = tx.Save("base_account", baseAccount)
	if err != nil {
		tx.Rollback()
		return err
	}

	return tx.Commit()
}