package virtualData

import (
	"encoding/json"
	"matchmaking-system/internal/data/socket/publicData"
	"matchmaking-system/internal/data/tradedeal/virtual"
	"matchmaking-system/internal/pkg/logging/applogger"
	"matchmaking-system/internal/pkg/logging/common"
)

// SpotOrderProcessing
//
//	@Description: 现货订单订阅处理
//	@param topIc
//	@param msg
//	@return []byte
//	@return *public.OrderSub
func SpotOrderProcessing(topIc string, msg virtual.SpotsTallyCache) ([]byte, *publicData.OrderSub) {
	price, err := publicData.CheckSymbol(topIc, msg.Symbol)
	if err != nil {
		applogger.Warn("%v SpotOrderProcessing.CheckSymbol.err:%v--%v", common.ErrSpots, msg.Symbol, err)
	}

	orderM := &publicData.OrderSub{
		OrderId:     msg.OrderId,
		Price:       price,
		Status:      msg.Status,
		Symbol:      topIc,
		Count:       0,
		OpenPrice:   msg.OpenPrice,
		Market:      msg.Symbol,
		OrderNumber: msg.Order.OrderNumber,
		TradeType:   msg.Order.TradeType,
		UserId:      msg.UserId,
	}

	orderStr, err := json.Marshal(orderM)
	if err != nil {
		return []byte{}, orderM
	}

	return orderStr, orderM
}