lims_adapter/handler/account.go

package handler

import (
	"context"
	"dashoo.cn/common_definition/comm_def"
	"dashoo.cn/micro_libary/micro_srv"
	"dashoo.cn/micro_libary/myerrors"
	"github.com/gogf/gf/frame/g"
	account "lims_adapter/model/account"
	service "lims_adapter/service/account"
)

// 结算
type Account struct{}

// AddAccount 添加财务账号
func (a *Account) SaveAccount(ctx context.Context, req *account.BaseAccount, rsp *comm_def.CommonMsg) error {
	tenant, err := micro_srv.GetTenant(ctx)
	if err != nil {
		return err
	}
	user, err := micro_srv.GetUserInfo(ctx)
	if err != nil {
		return err
	}
	g.Log().Info("Received Account.AddAccount request @ " + tenant)
	err = service.NewAccountSrv(tenant).Save(req, user)
	_, err, code, _ := myerrors.CheckError(err)
	if err != nil {
		rsp.Code = code
		return err
	}
	rsp.Code = code
	rsp.Msg = "添加账号成功"
	return nil
}

// AccountList 财务账号分页查询
func (a *Account) AccountList(ctx context.Context, req *account.AccountReq, rsp *comm_def.CommonMsg) error {
	tenant, err := micro_srv.GetTenant(ctx)
	if err != nil {
		return err
	}
	user, err := micro_srv.GetUserInfo(ctx)
	if err != nil {
		return err
	}
	g.Log().Info("Received Account.AccountList request @ " + tenant)
	list, err := service.NewAccountSrv(tenant).AccountList(req, user)
	_, err, code, _ := myerrors.CheckError(err)
	if err != nil {
		rsp.Code = code
		return err
	}
	rsp.Code = code
	rsp.Msg = ""
	rsp.Data = list
	return nil
}

// DepositAccount 充值账户
func (a *Account) DepositAccount(ctx context.Context, req *account.BaseAccountResp, rsp *comm_def.CommonMsg) error {
	tenant, err := micro_srv.GetTenant(ctx)
	if err != nil {
		return err
	}
	g.Log().Info("Received Account.DepositAccount request @ " + tenant)
	err = service.NewAccountSrv(tenant).DepositAccount(req)
	_, err, code, _ := myerrors.CheckError(err)
	if err != nil {
		rsp.Code = code
		return err
	}
	rsp.Code = code
	rsp.Msg = ""
	return nil
}

// 计算费用
func (a *Account) CalculateAmount(ctx context.Context, req *account.CalculateAmountReq, rsp *comm_def.CommonMsg) error {
	tenant, err := micro_srv.GetTenant(ctx)
	if err != nil {
		return err
	}
	g.Log().Info("Received Account.CalculateAmount request @ " + tenant)
	err = service.NewAccountSrv(tenant).Calculate(req)
	_, err, code, _ := myerrors.CheckError(err)
	if err != nil {
		rsp.Code = code
		return err
	}
	rsp.Code = code
	rsp.Msg = ""
	return nil
}

// 通过从账户id，查询主账户 财务账号信息
func (a *Account) GetBaseAccountById(ctx context.Context, req *account.SubAccountReq, rsp *comm_def.CommonMsg) error {
	tenant, err := micro_srv.GetTenant(ctx)
	if err != nil {
		return err
	}
	g.Log().Info("Received Account.GetBaseAccountById request @ " + tenant)
	list, err := service.NewAccountSrv(tenant).GetBaseAccountById(req)
	_, err, code, _ := myerrors.CheckError(err)
	if err != nil {
		rsp.Code = code
		return err
	}
	rsp.Code = code
	rsp.Msg = ""
	rsp.Data = list
	return nil
}