package project.contract.internal;
|
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
import org.apache.commons.collections.CollectionUtils;
|
import org.apache.commons.lang3.ObjectUtils;
|
|
import kernel.exception.BusinessException;
|
import kernel.util.Arith;
|
import kernel.util.DateUtils;
|
import kernel.util.StringUtils;
|
import kernel.web.ApplicationUtil;
|
import kernel.web.Page;
|
import project.Constants;
|
import project.contract.ContractApplyOrder;
|
import project.contract.ContractApplyOrderService;
|
import project.contract.ContractOrder;
|
import project.contract.ContractOrderService;
|
import project.item.ItemService;
|
import project.item.model.Item;
|
import project.item.model.ItemLever;
|
import project.log.MoneyLog;
|
import project.log.MoneyLogService;
|
import project.syspara.Syspara;
|
import project.syspara.SysparaService;
|
import project.wallet.Wallet;
|
import project.wallet.WalletService;
|
import util.DateUtil;
|
import util.RandomUtil;
|
|
public class ContractApplyOrderServiceImpl implements ContractApplyOrderService {
|
|
private ItemService itemService;
|
|
private WalletService walletService;
|
|
private SysparaService sysparaService;
|
|
private MoneyLogService moneyLogService;
|
|
private ContractOrderService contractOrderService;
|
|
@Override
|
public void saveCreate(ContractApplyOrder order) {
|
if (order.getVolume_open() % 1 != 0) {
|
throw new BusinessException("参数错误");
|
}
|
|
if (order.getVolume_open() <= 0) {
|
throw new BusinessException("参数错误");
|
}
|
|
boolean order_open = this.sysparaService.find("order_open").getBoolean();
|
if (!order_open) {
|
throw new BusinessException("不在交易时段");
|
}
|
|
Item item = this.itemService.cacheBySymbol(order.getSymbol(), true);
|
if (item == null) {
|
throw new BusinessException("参数错误");
|
}
|
if (ContractApplyOrder.OFFSET_OPEN.equals(order.getOffset())) {
|
this.open(order);
|
} else if (ContractApplyOrder.OFFSET_CLOSE.equals(order.getOffset())) {
|
this.close(order);
|
}
|
|
}
|
|
/**
|
* 开仓委托
|
*/
|
public void open(ContractApplyOrder order) {
|
Item item = this.itemService.cacheBySymbol(order.getSymbol(), false);
|
List<ItemLever> levers = itemService.findLever(item.getId().toString());
|
|
if (order.getLever_rate() != null && order.getLever_rate() != 1) {
|
boolean findlevers = true;
|
/**
|
* 杠杆有配置
|
*/
|
for (int i = 0; i < levers.size(); i++) {
|
if (order.getLever_rate() == levers.get(i).getLever_rate()) {
|
findlevers = true;
|
}
|
}
|
if (!findlevers) {
|
throw new BusinessException("参数错误");
|
}
|
}
|
|
// List<ContractOrder> order_state0_list = contractOrderService.findSubmitted(order.getPartyId().toString(),
|
// order.getSymbol(), order.getDirection());
|
// for (int i = 0; i < order_state0_list.size(); i++) {
|
// Double source_lever_rate = order.getLever_rate();
|
// source_lever_rate = source_lever_rate == null ? 0d : source_lever_rate;
|
//
|
// Double target_lever_rate = order_state0_list.get(i).getLever_rate();
|
// target_lever_rate = target_lever_rate == null ? 0d : target_lever_rate;
|
// if (source_lever_rate.compareTo(target_lever_rate) != 0) {
|
// throw new BusinessException("存在不同杠杆的持仓单");
|
// }
|
// }
|
// List<ContractApplyOrder> applyOrder_submitted_list = this.findSubmitted(order.getPartyId().toString(),
|
// order.getSymbol(), "open", order.getDirection());
|
// for (int i = 0; i < applyOrder_submitted_list.size(); i++) {
|
// Double source_lever_rate = order.getLever_rate();
|
// source_lever_rate = source_lever_rate == null ? 0d : source_lever_rate;
|
//
|
// Double target_lever_rate = applyOrder_submitted_list.get(i).getLever_rate();
|
// target_lever_rate = target_lever_rate == null ? 0d : target_lever_rate;
|
// if (source_lever_rate.compareTo(target_lever_rate) != 0) {
|
// throw new BusinessException("存在不同杠杆的持仓单");
|
// }
|
// }
|
|
order.setOrder_no(DateUtil.getToday("yyMMddHHmmss") + RandomUtil.getRandomNum(8));
|
order.setUnit_amount(item.getUnit_amount());
|
|
order.setFee(Arith.mul(item.getUnit_fee(), order.getVolume()));
|
order.setDeposit(Arith.mul(item.getUnit_amount(), order.getVolume()));
|
if (order.getLever_rate() != null) {
|
/**
|
* 加上杠杆
|
*/
|
order.setVolume(Arith.mul(order.getVolume(), order.getLever_rate()));
|
Syspara syspara = sysparaService.find("perpetual_contracts");
|
if(ObjectUtils.isEmpty(syspara)||"0".equals(syspara.getValue())) {
|
order.setFee(Arith.mul(order.getFee(), order.getLever_rate()));
|
}
|
}
|
order.setVolume_open(order.getVolume());
|
|
order.setCreate_time(new Date());
|
|
Wallet wallet = this.walletService.saveWalletByPartyId(order.getPartyId());
|
double amount_before = wallet.getMoney();
|
if (wallet.getMoney() < Arith.add(order.getDeposit(), order.getFee())) {
|
throw new BusinessException("余额不足");
|
}
|
|
this.walletService.update(wallet.getPartyId().toString(), Arith.sub(0, order.getDeposit()));
|
/*
|
* 保存资金日志
|
*/
|
MoneyLog moneylog_deposit = new MoneyLog();
|
moneylog_deposit.setCategory(Constants.MONEYLOG_CATEGORY_CONTRACT);
|
moneylog_deposit.setAmount_before(amount_before);
|
moneylog_deposit.setAmount(Arith.sub(0, order.getDeposit()));
|
moneylog_deposit.setAmount_after(Arith.sub(wallet.getMoney(), order.getDeposit()));
|
moneylog_deposit.setLog("委托单，订单号[" + order.getOrder_no() + "]");
|
moneylog_deposit.setPartyId(order.getPartyId());
|
moneylog_deposit.setWallettype(Constants.WALLET);
|
moneylog_deposit.setContent_type(Constants.MONEYLOG_CONTENT_CONTRACT_OPEN);
|
|
moneyLogService.save(moneylog_deposit);
|
|
amount_before = wallet.getMoney();
|
|
this.walletService.update(wallet.getPartyId().toString(), Arith.sub(0, order.getFee()));
|
|
MoneyLog moneylog_fee = new MoneyLog();
|
moneylog_fee.setCategory(Constants.MONEYLOG_CATEGORY_CONTRACT);
|
moneylog_fee.setAmount_before(amount_before);
|
moneylog_fee.setAmount(Arith.sub(0, order.getFee()));
|
moneylog_fee.setAmount_after(Arith.sub(wallet.getMoney(), order.getFee()));
|
moneylog_fee.setLog("手续费，订单号[" + order.getOrder_no() + "]");
|
moneylog_fee.setPartyId(order.getPartyId());
|
moneylog_fee.setWallettype(Constants.WALLET);
|
moneylog_fee.setContent_type(Constants.MONEYLOG_CONTENT_FEE);
|
|
moneyLogService.save(moneylog_fee);
|
|
order.setId(ApplicationUtil.getCurrentTimeUUID());
|
insertContractApplyOrder(order);
|
}
|
|
/**
|
* 平仓委托
|
*/
|
public void close(ContractApplyOrder order) {
|
Item item = this.itemService.cacheBySymbol(order.getSymbol(), false);
|
|
order.setOrder_no(DateUtil.getToday("yyMMddHHmmss") + RandomUtil.getRandomNum(8));
|
order.setCreate_time(new Date());
|
order.setUnit_amount(item.getUnit_amount());
|
|
double volume = 0;
|
List<ContractOrder> order_state0_list = contractOrderService.findSubmitted(order.getPartyId().toString(),order.getSymbol(), order.getDirection());
|
for (int i = 0; i < order_state0_list.size(); i++) {
|
volume = Arith.add(volume, order_state0_list.get(i).getVolume());
|
}
|
List<ContractApplyOrder> applyOrder_submitted_list = this.findSubmitted(order.getPartyId().toString(),
|
order.getSymbol(), ContractApplyOrder.OFFSET_CLOSE, order.getDirection());
|
for (int i = 0; i < applyOrder_submitted_list.size(); i++) {
|
volume = Arith.sub(volume, applyOrder_submitted_list.get(i).getVolume());
|
}
|
if (order.getVolume() > volume) {
|
throw new BusinessException("可平仓合约张数不足");
|
}
|
|
order.setId(ApplicationUtil.getCurrentTimeUUID());
|
insertContractApplyOrder(order);
|
}
|
|
/**
|
* 根据用户批量赎回订单
|
*
|
* @param partyId
|
*/
|
public void saveCancelAllByPartyId(String partyId) {
|
List<ContractApplyOrder> findSubmittedContractApplyOrders = findSubmitted(partyId, null, null, null);
|
if (!CollectionUtils.isEmpty(findSubmittedContractApplyOrders)) {
|
for (ContractApplyOrder applyOrder : findSubmittedContractApplyOrders) {
|
saveCancel(applyOrder.getPartyId().toString(), applyOrder.getOrder_no());
|
}
|
}
|
}
|
|
@Override
|
public void saveCancel(String partyId, String order_no) {
|
|
ContractApplyOrder order = this.findByOrderNo(order_no);
|
if (order == null || !"submitted".equals(order.getState()) || !partyId.equals(order.getPartyId().toString())) {
|
return;
|
}
|
|
order.setState("canceled");
|
|
Wallet wallet = this.walletService.saveWalletByPartyId(order.getPartyId());
|
double amount_before = wallet.getMoney();
|
this.walletService.update(wallet.getPartyId().toString(), Arith.add(order.getDeposit(), order.getFee()));
|
|
MoneyLog moneylog = new MoneyLog();
|
moneylog.setCategory(Constants.MONEYLOG_CATEGORY_CONTRACT);
|
moneylog.setAmount_before(amount_before);
|
moneylog.setAmount(Arith.add(order.getDeposit(), order.getFee()));
|
moneylog.setAmount_after(Arith.add(wallet.getMoney(), Arith.add(order.getDeposit(), order.getFee())));
|
moneylog.setLog("撤单，订单号[" + order.getOrder_no() + "]");
|
moneylog.setPartyId(order.getPartyId());
|
moneylog.setWallettype(Constants.WALLET);
|
moneylog.setContent_type(Constants.MONEYLOG_CONTENT_CONTRACT_CONCEL);
|
|
moneyLogService.save(moneylog);
|
|
update(order);
|
}
|
|
public void update(ContractApplyOrder order) {
|
ApplicationUtil.executeUpdate(order);
|
}
|
|
public ContractApplyOrder findByOrderNo(String order_no) {
|
List<ContractApplyOrder> list = ApplicationUtil.executeSelect(ContractApplyOrder.class,"WHERE ORDER_NO=?",new Object[] {order_no});
|
return list.size()<=0?null:list.get(0);
|
}
|
|
@Override
|
public List<Map<String, Object>> getPaged(int pageNo, int pageSize, String partyId, String symbol, String type,String status_para,String startTime, String endTime) {
|
if (pageNo <= 0) pageNo = 1;
|
Page page = new Page(pageNo, pageSize, Integer.MAX_VALUE);
|
|
StringBuilder whereSql=new StringBuilder("WHERE PARTY_ID=? ");
|
ArrayList<Object> params=new ArrayList<Object>();
|
params.add(partyId);
|
|
if (!StringUtils.isNullOrEmpty(symbol)) {
|
whereSql.append("AND SYMBOL=? ");
|
params.add(symbol);
|
}
|
|
if ("orders".equals(type)) {
|
whereSql.append("AND STATE=? ");
|
params.add(ContractApplyOrder.STATE_SUBMITTED);
|
} else if ("hisorders".equals(type)) {
|
whereSql.append(" AND FIND_IN_SET(STATE,?) ");
|
if(StringUtils.isNotEmpty(status_para)) {
|
params.add(status_para);
|
}else {
|
params.add(ContractApplyOrder.STATE_CREATED+","+ContractApplyOrder.STATE_CANCELED);
|
}
|
}
|
|
if (!StringUtils.isNullOrEmpty(startTime)) {
|
whereSql.append("AND DATE(CREATE_TIME)>=DATE('"+startTime+" 00:00:00') ");
|
}
|
|
if (!StringUtils.isNullOrEmpty(endTime)) {
|
whereSql.append("AND DATE(CREATE_TIME)<=DATE('"+endTime+" 23:59:59') ");
|
}
|
|
whereSql.append("ORDER BY CREATE_TIME DESC LIMIT ?,?");
|
params.add(page.getFirstElementNumber());
|
params.add(pageSize);
|
|
return bulidData(ApplicationUtil.executeSelect(ContractApplyOrder.class,whereSql.toString(),params.toArray(new Object[params.size()])));
|
}
|
|
private List<Map<String, Object>> bulidData(List<ContractApplyOrder> list) {
|
List<Map<String, Object>> data = new ArrayList<Map<String, Object>>();
|
for (int i = 0; i < list.size(); i++) {
|
ContractApplyOrder order = list.get(i);
|
Map<String, Object> map = new HashMap<String, Object>();
|
map.put("order_no", order.getOrder_no());
|
map.put("name", itemService.cacheBySymbol(order.getSymbol(), false).getName());
|
map.put("symbol", order.getSymbol());
|
map.put("create_time", DateUtils.format(order.getCreate_time(), DateUtils.DF_yyyyMMddHHmmss));
|
map.put("volume", order.getVolume());
|
map.put("volume_open", order.getVolume_open());
|
map.put("direction", order.getDirection());
|
map.put("offset", order.getOffset());
|
map.put("lever_rate", order.getLever_rate());
|
map.put("price", order.getPrice());
|
map.put("stop_price_profit", order.getStop_price_profit());
|
map.put("stop_price_loss", order.getStop_price_loss());
|
map.put("order_price_type", order.getOrder_price_type());
|
map.put("state", order.getState());
|
map.put("amount", Arith.mul(order.getVolume(), order.getUnit_amount()));
|
map.put("amount_open", Arith.mul(order.getVolume_open(), order.getUnit_amount()));
|
map.put("fee", order.getFee());
|
map.put("deposit", order.getDeposit());
|
|
data.add(map);
|
}
|
return data;
|
}
|
|
@Override
|
public List<ContractApplyOrder> findSubmitted() {
|
return ApplicationUtil.executeSelect(ContractApplyOrder.class,"WHERE STATE=?",new Object[] {"submitted"});
|
}
|
|
/**
|
* 未处理状态的委托单
|
*/
|
public List<ContractApplyOrder> findSubmitted(String partyId, String symbol, String offset, String direction) {
|
Page page = new Page(1,Integer.MAX_VALUE, Integer.MAX_VALUE);
|
StringBuilder whereSql=new StringBuilder("WHERE 1=1 ");
|
ArrayList<Object> params=new ArrayList<Object>();
|
|
if (!StringUtils.isNullOrEmpty(partyId)) {
|
whereSql.append("AND PARTY_ID=? ");
|
params.add(partyId);
|
}
|
|
if (!StringUtils.isNullOrEmpty(symbol)) {
|
whereSql.append("AND SYMBOL=? ");
|
params.add(symbol);
|
}
|
|
if (!StringUtils.isNullOrEmpty(offset)) {
|
whereSql.append("AND OFFSET=? ");
|
params.add(offset);
|
}
|
|
if (!StringUtils.isNullOrEmpty(direction)) {
|
whereSql.append("AND DIRECTION=? ");
|
params.add(direction);
|
}
|
|
whereSql.append("AND STATE=? LIMIT ?,?");
|
params.add("submitted");
|
params.add(page.getFirstElementNumber());
|
params.add(page.getPageSize());
|
|
return ApplicationUtil.executeSelect(ContractApplyOrder.class,whereSql.toString(),params.toArray(new Object[params.size()]));
|
}
|
|
public void insertContractApplyOrder(ContractApplyOrder order) {
|
ApplicationUtil.executeInsert(order);
|
}
|
|
public void setSysparaService(SysparaService sysparaService) {
|
this.sysparaService = sysparaService;
|
}
|
|
public void setItemService(ItemService itemService) {
|
this.itemService = itemService;
|
}
|
|
public void setMoneyLogService(MoneyLogService moneyLogService) {
|
this.moneyLogService = moneyLogService;
|
}
|
|
public void setWalletService(WalletService walletService) {
|
this.walletService = walletService;
|
}
|
|
public void setContractOrderService(ContractOrderService contractOrderService) {
|
this.contractOrderService = contractOrderService;
|
}
|
}
|
