matchmaking-system/internal/service/share_eur.go

package service

import (
	"context"
	"matchmaking-system/internal/pkg/flags"
	"matchmaking-system/internal/service/order"
	"matchmaking-system/internal/service/share"

	v1 "matchmaking-system/api/matchmaking/v1/share"
)

// GetBotStockEurTrade
//
//	@Description: 德国股订单列表
//	@receiver s
//	@param ctx
//	@param req
//	@return *v1.GetBotStockEurTradeReply
//	@return error
func (s *ConduitService) GetBotStockEurTrade(ctx context.Context, req *v1.GetEurBotStockTradeRequest) (*v1.GetBotStockEurTradeReply, error) {
	if !share.VerificationEurBotStockTrade(req) {
		return share.BotStockEurTradeReply(false, flags.ErrIsParameter.Error(), req, nil, 0), nil
	}

	stockTradeList, totalCount, err := s.eu.BotStockEurTradeList(ctx, req.PageSize, req.PageCount, req.Status)
	if err != nil {
		return share.BotStockEurTradeReply(false, err.Error(), req, nil, 0), nil
	}

	return share.BotStockEurTradeReply(true, flags.SetNull, req, stockTradeList, totalCount), nil
}

// ShareEurPlaceOrder
//
//	@Description: 德国股下单
//	@receiver s
//	@param ctx
//	@param req
//	@return *v1.SgdOrderReply
//	@return error
func (s *ConduitService) ShareEurPlaceOrder(ctx context.Context, req *v1.ShareEurOrderRequest) (*v1.EurOrderReply, error) {
	if !share.VerificationEurShareOrderQuery(req) {
		return share.ShareEurPlaceOrderReply(false, flags.ErrIsParameter.Error(), flags.SetNull), nil
	}

	orderId, err := s.eu.ShareEurPlaceOrder(ctx, share.ShareEurOrderQuery(req))
	if err != nil {
		return share.ShareEurPlaceOrderReply(false, order.CheckShareError(err), flags.SetNull), nil
	}

	return share.ShareEurPlaceOrderReply(true, flags.SetNull, orderId), nil
}

// ShareEurUpdateOrder
//
//	@Description: 德国股设置止盈止损
//	@receiver s
//	@param ctx
//	@param req
//	@return *v1.EurOrderReply
//	@return error
func (s *ConduitService) ShareEurUpdateOrder(ctx context.Context, req *v1.UpdateEurOrderRequest) (*v1.EurOrderReply, error) {
	if !share.VerificationEurStopOrderQuery(req) {
		return share.ShareEurUpdateOrderReply(false, flags.ErrIsParameter.Error(), req), nil
	}

	_, err := s.eu.ShareEurUpdateOrder(ctx, share.StopEurOrderQuery(req))
	if err != nil {
		return share.ShareEurUpdateOrderReply(false, order.CheckShareError(err), req), nil
	}

	return share.ShareEurUpdateOrderReply(true, flags.SetNull, req), nil
}

// ShareEurPosition
//
//	@Description: 德国股平仓
//	@receiver s
//	@param ctx
//	@param req
//	@return *v1.EurOrderReply
//	@return error
func (s *ConduitService) ShareEurPosition(ctx context.Context, req *v1.CancelEurOrderRequest) (*v1.EurOrderReply, error) {
	if !share.VerificationEurSharePosition(req) {
		return share.ShareEurPositionOrderReply(false, flags.ErrIsParameter.Error(), req), nil
	}

	_, err := s.eu.ShareEurPosition(ctx, req.OrderId)
	if err != nil {
		return share.ShareEurPositionOrderReply(false, order.CheckShareError(err), req), nil
	}

	return share.ShareEurPositionOrderReply(true, flags.SetNull, req), nil
}

// ShareEurAllPosition
//
//	@Description: 德国股一键平仓
//	@receiver s
//	@param ctx
//	@param req
//	@return *v1.AllEurOrderReply
//	@return error
func (s *ConduitService) ShareEurAllPosition(ctx context.Context, req *v1.AllEurOrderRequest) (*v1.AllEurOrderReply, error) {
	if err := s.eu.ShareEurAllPosition(ctx); err != nil {
		return share.ShareAllEurPositionRequest(false, order.CheckShareError(err)), nil
	}

	return share.ShareAllEurPositionRequest(true, flags.SetNull), nil
}

// ShareEurCancel
//
//	@Description: 德国股撤单
//	@receiver s
//	@param ctx
//	@param req
//	@return *v1.EurOrderReply
//	@return error
func (s *ConduitService) ShareEurCancel(ctx context.Context, req *v1.CancelEurOrderRequest) (*v1.EurOrderReply, error) {
	if !share.VerificationEurShareCancel(req) {
		return share.ShareEurCancelReply(false, flags.ErrIsParameter.Error(), req), nil
	}

	_, err := s.eu.ShareEurCancel(ctx, req.OrderId)
	if err != nil {
		return share.ShareEurCancelReply(false, order.CheckShareError(err), req), nil
	}

	return share.ShareEurCancelReply(true, flags.SetNull, req), nil
}