matchmaking-system/internal/service/money.go

package service

import (
	"context"
	v1 "matchmaking-system/api/matchmaking/v1/money"
	"matchmaking-system/internal/pkg/flags"
	"matchmaking-system/internal/service/money"
)

// GetBotMoneyTrade
//
//	@Description: 外汇订单列表
//	@receiver s
//	@param ctx
//	@param req
//	@return *v1.GetBotMoneyTradeReply
//	@return error
func (s *ConduitService) GetBotMoneyTrade(ctx context.Context, req *v1.GetBotMoneyTradeRequest) (*v1.GetBotMoneyTradeReply, error) {
	if !money.VerificationBotMoneyTrade(req) {
		return money.BotMoneyTradeReply(false, flags.ErrIsParameter.Error(), req, nil, 0), nil
	}

	contractTradeList, totalCount, err := s.mo.BotMoneyTradeList(ctx, req.PageSize, req.PageCount, req.Status, req.Type)
	if err != nil {
		return money.BotMoneyTradeReply(false, err.Error(), req, nil, 0), nil
	}

	return money.BotMoneyTradeReply(true, flags.SetNull, req, contractTradeList, totalCount), nil
}

// MoneyPlaceOrder
//
//	@Description: 外汇下单
//	@receiver s
//	@param ctx
//	@param req
//	@return *v1.MoneyReply
//	@return error
func (s *ConduitService) MoneyPlaceOrder(ctx context.Context, req *v1.MoneyRequest) (*v1.MoneyReply, error) {
	if !money.VerificationMoneyPlaceOrder(req) {
		return money.MoneyPlaceOrderReply(false, flags.ErrIsParameter.Error(), flags.SetNull), nil
	}

	orderId, err := s.mo.MoneyPlaceOrder(ctx, money.MoneyOrderQuery(req))
	if err != nil {
		return money.MoneyPlaceOrderReply(false, err.Error(), flags.SetNull), nil
	}

	return money.MoneyPlaceOrderReply(true, flags.SetNull, orderId), nil
}

// MoneyUpdatePlaceOrder
//
//	@Description: 外汇设置止盈止损
//	@receiver s
//	@param ctx
//	@param req
//	@return *v1.MoneyReply
//	@return error
func (s *ConduitService) MoneyUpdatePlaceOrder(ctx context.Context, req *v1.UpdateMoneyRequest) (*v1.MoneyReply, error) {
	if !money.VerificationMoneyUpdatePlaceOrder(req) {
		return money.MoneyUpdatePlaceOrderReply(false, flags.ErrIsParameter.Error(), req), nil
	}

	_, err := s.mo.MoneyUpdatePlaceOrder(ctx, money.MoneyStopQuery(req))
	if err != nil {
		return money.MoneyUpdatePlaceOrderReply(false, err.Error(), req), nil
	}

	return money.MoneyUpdatePlaceOrderReply(true, flags.SetNull, req), nil
}

// MoneyPosition
//
//	@Description: 外汇平仓
//	@receiver s
//	@param ctx
//	@param req
//	@return *v1.MoneyReply
//	@return error
func (s *ConduitService) MoneyPosition(ctx context.Context, req *v1.CancelMoneyRequest) (*v1.MoneyReply, error) {
	if !money.VerificationMoneyPosition(req) {
		return money.MoneyPositionOrderReply(false, flags.ErrIsParameter.Error(), req), nil
	}

	_, err := s.mo.MoneyPosition(ctx, req.OrderId)
	if err != nil {
		return money.MoneyPositionOrderReply(false, err.Error(), req), nil
	}

	return money.MoneyPositionOrderReply(true, flags.SetNull, req), nil
}

// MoneyAllPosition
//
//	@Description: 外汇一键平仓
//	@receiver s
//	@param ctx
//	@param req
//	@return *v1.AllMoneyReply
//	@return error
func (s *ConduitService) MoneyAllPosition(ctx context.Context, req *v1.AllMoneyRequest) (*v1.AllMoneyReply, error) {
	if err := s.mo.MoneyAllPosition(ctx); err != nil {
		return money.MoneyAllPositionReply(false, err.Error()), nil
	}

	return money.MoneyAllPositionReply(true, flags.SetNull), nil
}

// MoneyCancel
//
//	@Description: 外汇撤单
//	@receiver s
//	@param ctx
//	@param req
//	@return *v1.MoneyReply
//	@return error
func (s *ConduitService) MoneyCancel(ctx context.Context, req *v1.CancelMoneyRequest) (*v1.MoneyReply, error) {
	if !money.VerificationMoneyCancel(req) {
		return money.MoneyCancelOrderReply(false, flags.ErrIsParameter.Error(), req), nil
	}

	_, err := s.mo.MoneyCancel(ctx, req.OrderId)
	if err != nil {
		return money.MoneyCancelOrderReply(false, err.Error(), req), nil
	}

	return money.MoneyCancelOrderReply(true, flags.SetNull, req), nil
}

// SpotsOneClickRedemption
//
//	@Description: 现货一键兑换
//	@receiver s
//	@param ctx
//	@param req
//	@return *v1.SpotsOrderReply
//	@return error
func (s *ConduitService) MoneyOneClickRedemption(ctx context.Context, req *v1.MoneyRequest) (*v1.MoneyReply, error) {
	if !money.VerificationMoneyPlaceOrder(req) {
		return money.MoneyPlaceOrderReply(false, flags.ErrIsParameter.Error(), flags.SetNull), nil
	}

	orderId, err := s.mo.MoneyOneClickRedemption(ctx, money.MoneyOrderQuery(req))
	if err != nil {
		return money.SharePlaceOrderReply(false, err.Error(), flags.SetNull), nil
	}

	return money.SharePlaceOrderReply(true, flags.SetNull, orderId), nil
}