package com.xcong.excoin.modules.okxNewPrice.okxpi.trade.impl;
|
|
import com.alibaba.fastjson.JSON;
|
import com.xcong.excoin.modules.okxNewPrice.okxpi.config.OKXAccount;
|
import com.xcong.excoin.modules.okxNewPrice.okxpi.config.enums.HttpMethod;
|
import com.xcong.excoin.modules.okxNewPrice.okxpi.config.utils.OKXContants;
|
import com.xcong.excoin.modules.okxNewPrice.okxpi.config.utils.ParameterChecker;
|
import com.xcong.excoin.modules.okxNewPrice.okxpi.trade.TradeEventEnum;
|
import com.xcong.excoin.modules.okxNewPrice.okxpi.trade.TradeService;
|
import lombok.RequiredArgsConstructor;
|
import lombok.extern.slf4j.Slf4j;
|
|
import java.util.LinkedHashMap;
|
|
@Slf4j
|
@RequiredArgsConstructor
|
public class TradeServiceBuy implements TradeService {
|
|
@Override
|
public String tradeEvent() {
|
return TradeEventEnum.TRADE_BUY.getEventPoint();
|
}
|
|
@Override
|
public String doTrade(LinkedHashMap<String, Object> tradeDto, OKXAccount okxAccount) {
|
ParameterChecker.checkParameter(tradeDto, "instId", String.class);
|
ParameterChecker.checkParameter(tradeDto, "tdMode", String.class);
|
ParameterChecker.checkParameter(tradeDto, "side", String.class);
|
ParameterChecker.checkParameter(tradeDto, "ordType", String.class);
|
ParameterChecker.checkParameter(tradeDto, "sz", Double.class);
|
String placeOrderRspOkxRestResponse = okxAccount.requestHandler.sendSignedRequest(okxAccount.baseUrl, OKXContants.ORDER, tradeDto, HttpMethod.POST, okxAccount.isSimluate());
|
log.info("开仓响应：{}",JSON.parseObject(placeOrderRspOkxRestResponse).get("data"));
|
/**
|
* todo 下单之后的日志处理
|
*/
|
return placeOrderRspOkxRestResponse;
|
}
|
}
|
