package project.contract.internal; import java.text.DecimalFormat; import java.text.SimpleDateFormat; import java.util.*; import java.util.Map.Entry; import java.util.concurrent.ConcurrentHashMap; import org.apache.commons.collections.CollectionUtils; import kernel.util.Arith; import kernel.util.DateUtils; import kernel.util.StringUtils; import kernel.web.ApplicationUtil; import kernel.web.Page; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.util.ObjectUtils; import project.Constants; import project.contract.ContractApplyOrder; import project.contract.ContractApplyOrderService; import project.contract.ContractLock; import project.contract.ContractOrder; import project.contract.ContractOrderService; import project.contract.ContractRedisKeys; import project.data.model.Realtime; import project.item.ItemService; import project.item.model.Item; import project.log.MoneyLog; import project.log.MoneyLogService; import project.party.PartyService; import project.party.model.Party; import project.redis.RedisHandler; import project.syspara.Syspara; import project.syspara.SysparaService; import project.tip.TipConstants; import project.tip.TipService; import project.user.UserDataService; import project.wallet.AssetService; import project.wallet.Wallet; import project.wallet.WalletService; import util.DateUtil; import util.RandomUtil; public class ContractOrderServiceImpl implements ContractOrderService { protected WalletService walletService; protected UserDataService userDataService; protected ItemService itemService; protected MoneyLogService moneyLogService; protected ContractApplyOrderService contractApplyOrderService; protected RedisHandler redisHandler; protected PartyService partyService; protected TipService tipService; protected AssetService assetService; public void saveOpen(ContractApplyOrder applyOrder, Realtime realtime) { Item item = this.itemService.cacheBySymbol(applyOrder.getSymbol(), false); ContractOrder order = new ContractOrder(); order.setId(ApplicationUtil.getCurrentTimeUUID()); order.setPartyId(applyOrder.getPartyId()); order.setSymbol(applyOrder.getSymbol()); order.setOrder_no(DateUtil.getToday("yyMMddHHmmss") + RandomUtil.getRandomNum(8)); order.setDirection(applyOrder.getDirection()); order.setLever_rate(applyOrder.getLever_rate()); order.setVolume(applyOrder.getVolume()); order.setVolume_open(applyOrder.getVolume_open()); order.setUnit_amount(applyOrder.getUnit_amount()); order.setFee(applyOrder.getFee()); order.setDeposit(applyOrder.getDeposit()); order.setDeposit_open(applyOrder.getDeposit()); order.setTrade_avg_price(realtime.getClose()); order.setStop_price_profit(applyOrder.getStop_price_profit()); order.setStop_price_loss(applyOrder.getStop_price_loss()); order.setPips(item.getPips()); order.setPips_amount(item.getPips_amount()); order.setCreate_time(new Date()); ApplicationUtil.executeInsert(order); redisHandler.setSync(ContractRedisKeys.CONTRACT_ORDERNO + order.getOrder_no(), order); Map map = (Map) redisHandler.get(ContractRedisKeys.CONTRACT_SUBMITTED_ORDER_PARTY_ID + order.getPartyId().toString()); if (map == null) map = new ConcurrentHashMap(); map.put(order.getOrder_no(), order); redisHandler.setSync(ContractRedisKeys.CONTRACT_SUBMITTED_ORDER_PARTY_ID + order.getPartyId().toString(), map); // 获取单个订单的合约总资产、总保证金、总未实现盈利 Map contractAssetsOrder = this.assetService.getMoneyContractByOrder(order); Double contractAssets = (Double) this.redisHandler.get(ContractRedisKeys.CONTRACT_ASSETS_PARTY_ID + order.getPartyId().toString()); Double contractAssetsDeposit = (Double) this.redisHandler.get(ContractRedisKeys.CONTRACT_ASSETS_DEPOSIT_PARTY_ID + order.getPartyId().toString()); Double contractAssetsProfit = (Double) this.redisHandler.get(ContractRedisKeys.CONTRACT_ASSETS_PROFIT_PARTY_ID + order.getPartyId().toString()); this.redisHandler.setSync(ContractRedisKeys.CONTRACT_ASSETS_PARTY_ID + order.getPartyId().toString(), Arith.add(null == contractAssets ? 0.000D : contractAssets, contractAssetsOrder.get("money_contract"))); this.redisHandler.setSync(ContractRedisKeys.CONTRACT_ASSETS_DEPOSIT_PARTY_ID + order.getPartyId().toString(), Arith.add(null == contractAssetsDeposit ? 0.000D : contractAssetsDeposit, contractAssetsOrder.get("money_contract_deposit"))); this.redisHandler.setSync(ContractRedisKeys.CONTRACT_ASSETS_PROFIT_PARTY_ID + order.getPartyId().toString(), Arith.add(null == contractAssetsProfit ? 0.000D : contractAssetsProfit, contractAssetsOrder.get("money_contract_profit"))); /** * 进入市场 */ applyOrder.setVolume(0D); applyOrder.setState(ContractApplyOrder.STATE_CREATED); this.contractApplyOrderService.update(applyOrder); Party party = this.partyService.cachePartyBy(order.getPartyId(), false); if (Constants.SECURITY_ROLE_MEMBER.equals(party.getRolename())) { tipService.saveTip(order.getId().toString(), TipConstants.CONTRACT_ORDER); } } public ContractApplyOrder saveClose(ContractApplyOrder applyOrder, Realtime realtime, String order_no) { ContractOrder order = this.findByOrderNo(order_no); if (order == null || !ContractOrder.STATE_SUBMITTED.equals(order.getState()) || order.getVolume() <= 0) { /** * 状态已改变，退出处理 */ return applyOrder; } double volume; if (applyOrder.getVolume() > order.getVolume()) { volume = order.getVolume(); } else { volume = applyOrder.getVolume(); } /** * 平仓退回的金额 */ double profit = this.settle(order, volume); update(order); // if (profit > 0) { Wallet wallet = this.walletService.saveWalletByPartyId(order.getPartyId()); double amount_before = wallet.getMoney(); Object money = redisHandler.get("PARTY_ID_MONEY_" + order.getPartyId().toString()); if(ObjectUtils.isEmpty(money)){ wallet.setMoney(wallet.getMoney()); }else{ wallet.setMoney(Double.parseDouble(money.toString())); } if (Arith.add(wallet.getMoney(), profit) < 0) { profit = Arith.sub(0, wallet.getMoney()); } // wallet.setMoney(Arith.add(wallet.getMoney(), profit));/ if (Arith.add(wallet.getMoney(), profit) < 0) { profit = Arith.sub(0, wallet.getMoney()); } this.walletService.update(wallet.getPartyId().toString(), profit); MoneyLog moneylog = new MoneyLog(); moneylog.setCategory(Constants.MONEYLOG_CATEGORY_CONTRACT); moneylog.setAmount_before(amount_before); moneylog.setAmount(profit); moneylog.setAmount_after(Arith.add(wallet.getMoney(), profit)); moneylog.setLog("平仓，平仓合约数[" + volume + "],订单号[" + order.getOrder_no() + "]"); moneylog.setPartyId(order.getPartyId()); moneylog.setWallettype(Constants.WALLET); moneylog.setContent_type(Constants.MONEYLOG_CONTENT_CONTRACT_CLOSE); moneyLogService.save(moneylog); // } applyOrder.setVolume(Arith.sub(applyOrder.getVolume(), volume)); if (applyOrder.getVolume() <= 0) { applyOrder.setState(ContractApplyOrder.STATE_CREATED); } contractApplyOrderService.update(applyOrder); return applyOrder; } /** * 根据用户批量赎回订单 * * @param partyId */ public void saveCloseRemoveAllByPartyId(String partyId) { List orders = ApplicationUtil.executeSelect(ContractOrder.class,"WHERE PARTY_ID=?",new Object[] {partyId}); List findSubmittedContractOrders = findSubmitted(partyId, null, null); if (!CollectionUtils.isEmpty(findSubmittedContractOrders)) { for (ContractOrder order : orders) { if (ContractOrder.STATE_SUBMITTED.equals(order.getState())) { saveClose(order.getPartyId().toString(), order.getOrder_no()); } redisHandler.remove(ContractRedisKeys.CONTRACT_ORDERNO + order.getOrder_no()); } redisHandler.remove(ContractRedisKeys.CONTRACT_SUBMITTED_ORDER_PARTY_ID + partyId); this.redisHandler.remove(ContractRedisKeys.CONTRACT_ASSETS_PARTY_ID + partyId); this.redisHandler.remove(ContractRedisKeys.CONTRACT_ASSETS_DEPOSIT_PARTY_ID + partyId); this.redisHandler.remove(ContractRedisKeys.CONTRACT_ASSETS_PROFIT_PARTY_ID + partyId); } } public ContractOrder saveClose(String partyId, String order_no) { /* * 平仓 */ ContractOrder order = this.findByOrderNo(order_no); if (order == null || !ContractOrder.STATE_SUBMITTED.equals(order.getState()) || !partyId.equals(order.getPartyId().toString()) || order.getVolume() <= 0) { return null; //状态已改变，退出处理 } /** * 收益 */ double volume = order.getVolume(); double profit = this.settle(order, order.getVolume()); Wallet wallet = this.walletService.saveWalletByPartyId(order.getPartyId()); double amount_before = wallet.getMoney(); Object money = redisHandler.get("PARTY_ID_MONEY_" + order.getPartyId().toString()); if(ObjectUtils.isEmpty(money)){ wallet.setMoney(wallet.getMoney()); }else{ wallet.setMoney(Double.parseDouble(money.toString())); } if (Arith.add(wallet.getMoney(), profit) < 0) { profit = Arith.sub(0, wallet.getMoney()); } this.walletService.update(wallet.getPartyId().toString(), profit); MoneyLog moneylog = new MoneyLog(); moneylog.setCategory(Constants.MONEYLOG_CATEGORY_CONTRACT); moneylog.setAmount_before(amount_before); moneylog.setAmount(profit); moneylog.setAmount_after(Arith.add(wallet.getMoney(), profit)); moneylog.setLog("平仓，平仓合约数[" + volume + "],订单号[" + order.getOrder_no() + "]"); moneylog.setPartyId(order.getPartyId()); moneylog.setWallettype(Constants.WALLET); moneylog.setContent_type(Constants.MONEYLOG_CONTENT_CONTRACT_CLOSE); moneyLogService.save(moneylog); order.setState(ContractOrder.STATE_CREATED); order.setVolume(0D); order.setDeposit(0); order.setClose_time(new Date()); update(order); /** * 合约产品平仓后添加当前流水 */ Party party = this.partyService.cachePartyBy(order.getPartyId(), false); party.setWithdraw_limit_now_amount(Arith.add(party.getWithdraw_limit_now_amount(), order.getDeposit_open())); partyService.update(party); return order; } public void update(ContractOrder order) { String id = null == order.getId() ? ApplicationUtil.getCurrentTimeUUID() : order.getId().toString(); ApplicationUtil.executeInsertOrUpdate(order, "WHERE UUID=?", new Object[] {id}); redisHandler.setSync(ContractRedisKeys.CONTRACT_ORDERNO + order.getOrder_no(), order); if (ContractOrder.STATE_SUBMITTED.equals(order.getState())) { Map map = (Map) redisHandler.get(ContractRedisKeys.CONTRACT_SUBMITTED_ORDER_PARTY_ID + order.getPartyId().toString()); if (null == map) map = new ConcurrentHashMap(); ContractOrder orderOld = map.get(order.getOrder_no()); map.put(order.getOrder_no(), order); redisHandler.setSync(ContractRedisKeys.CONTRACT_SUBMITTED_ORDER_PARTY_ID + order.getPartyId().toString(), map); // 获取单个订单的合约总资产、总保证金、总未实现盈利 Map contractAssetsOrder = this.assetService.getMoneyContractByOrder(order); Map contractAssetsOrderOld = this.assetService.getMoneyContractByOrder(orderOld); Double contractAssets = (Double) this.redisHandler.get(ContractRedisKeys.CONTRACT_ASSETS_PARTY_ID + order.getPartyId().toString()); Double contractAssetsDeposit = (Double) this.redisHandler.get(ContractRedisKeys.CONTRACT_ASSETS_DEPOSIT_PARTY_ID + order.getPartyId().toString()); Double contractAssetsProfit = (Double) this.redisHandler.get(ContractRedisKeys.CONTRACT_ASSETS_PROFIT_PARTY_ID + order.getPartyId().toString()); this.redisHandler.setSync(ContractRedisKeys.CONTRACT_ASSETS_PARTY_ID + order.getPartyId().toString(), Arith.add(null == contractAssets ? 0.000D : contractAssets, contractAssetsOrder.get("money_contract") - contractAssetsOrderOld.get("money_contract"))); this.redisHandler.setSync(ContractRedisKeys.CONTRACT_ASSETS_DEPOSIT_PARTY_ID + order.getPartyId().toString(), Arith.add(null == contractAssetsDeposit ? 0.000D : contractAssetsDeposit, contractAssetsOrder.get("money_contract_deposit") - contractAssetsOrderOld.get("money_contract_deposit"))); this.redisHandler.setSync(ContractRedisKeys.CONTRACT_ASSETS_PROFIT_PARTY_ID + order.getPartyId().toString(), Arith.add(null == contractAssetsProfit ? 0.000D : contractAssetsProfit, contractAssetsOrder.get("money_contract_profit") - contractAssetsOrderOld.get("money_contract_profit"))); } else if (ContractOrder.STATE_CREATED.equals(order.getState())) { // 平仓后，移除持仓列表 Map map = (Map) redisHandler.get(ContractRedisKeys.CONTRACT_SUBMITTED_ORDER_PARTY_ID + order.getPartyId().toString()); ContractOrder orderOld = null; if (map != null && !map.isEmpty()) { orderOld = map.get(order.getOrder_no()); map.remove(order.getOrder_no()); } redisHandler.setSync(ContractRedisKeys.CONTRACT_SUBMITTED_ORDER_PARTY_ID + order.getPartyId().toString(), map); // 获取单个订单的合约总资产、总保证金、总未实现盈利 Map contractAssetsOrderOld = this.assetService.getMoneyContractByOrder(orderOld); Double contractAssets = (Double) this.redisHandler.get(ContractRedisKeys.CONTRACT_ASSETS_PARTY_ID + order.getPartyId().toString()); Double contractAssetsDeposit = (Double) this.redisHandler.get(ContractRedisKeys.CONTRACT_ASSETS_DEPOSIT_PARTY_ID + order.getPartyId().toString()); Double contractAssetsProfit = (Double) this.redisHandler.get(ContractRedisKeys.CONTRACT_ASSETS_PROFIT_PARTY_ID + order.getPartyId().toString()); this.redisHandler.setSync(ContractRedisKeys.CONTRACT_ASSETS_PARTY_ID + order.getPartyId().toString(), Arith.add(null == contractAssets ? 0.000D : contractAssets, 0.000D - contractAssetsOrderOld.get("money_contract"))); this.redisHandler.setSync(ContractRedisKeys.CONTRACT_ASSETS_DEPOSIT_PARTY_ID + order.getPartyId().toString(), Arith.add(null == contractAssetsDeposit ? 0.000D : contractAssetsDeposit, 0.000D - contractAssetsOrderOld.get("money_contract_deposit"))); this.redisHandler.setSync(ContractRedisKeys.CONTRACT_ASSETS_PROFIT_PARTY_ID + order.getPartyId().toString(), Arith.add(null == contractAssetsProfit ? 0.000D : contractAssetsProfit, 0.000D - contractAssetsOrderOld.get("money_contract_profit"))); // 平仓则纪录数据（委托平仓，订单直接平仓） this.userDataService.saveClose(order); Party party = this.partyService.cachePartyBy(order.getPartyId(), false); if (Constants.SECURITY_ROLE_MEMBER.equals(party.getRolename())) { tipService.deleteTip(order.getId().toString()); } } } /** * 收益结算，平仓时计算 * * @param closevolume 平仓的张数 */ public double settle(ContractOrder order, double volume) { double profit = 0; /** * 平仓比率 */ double rate = Arith.div(volume, order.getVolume_open()); //平仓收益 double mul = Arith.mul(order.getDeposit_open(), order.getLever_rate());//仓位 double div = Arith.div(mul, order.getTrade_avg_price());//持有币的数量 double amount = Arith.mul(div, Arith.sub(order.getClose_avg_price(), order.getTrade_avg_price())); profit = Arith.add(Arith.mul(order.getDeposit_open(),rate),Arith.mul(order.getProfit(),rate)); order.setAmount_close(Arith.add(order.getAmount_close(), profit)); order.setVolume(Arith.sub(order.getVolume(), volume)); order.setDeposit(Arith.sub(order.getDeposit(), Arith.mul(order.getDeposit_open(), rate))); if (order.getVolume() <= 0) { order.setState(ContractOrder.STATE_CREATED); order.setClose_time(new Date()); } return profit; } public ContractOrder findByOrderNo(String order_no) { ContractOrder order = (ContractOrder) this.redisHandler.get(ContractRedisKeys.CONTRACT_ORDERNO + order_no); if (null != order) return order; List list = ApplicationUtil.executeSelect(ContractOrder.class,"WHERE ORDER_NO=?",new Object[] {order_no}); return list.size()<=0?null:list.get(0); } public List findSubmitted(String partyId, String symbol, String direction) { if (!StringUtils.isNullOrEmpty(partyId)) {// 如果有partyId，走缓存查询 Map map = (Map) redisHandler.get(ContractRedisKeys.CONTRACT_SUBMITTED_ORDER_PARTY_ID + partyId); List list = new ArrayList(); if (map != null && !map.isEmpty()) { for (ContractOrder order : map.values()) { boolean valify = true;// 验证 if (valify && !StringUtils.isNullOrEmpty(symbol)) {// 币种是否相同 valify = symbol.equals(order.getSymbol()); } if (valify && !StringUtils.isNullOrEmpty(direction)) { valify = direction.equals(order.getDirection()); } if (valify) {// 条件全部满足，添加 list.add(order); } } } return list; } Page page = new Page(1,Integer.MAX_VALUE,Integer.MAX_VALUE); StringBuilder whereSql=new StringBuilder("WHERE 1=1 "); ArrayList params=new ArrayList(); 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(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(ContractOrder.class,whereSql.toString(),params.toArray(new Object[params.size()])); } public List> getPaged(int pageNo, int pageSize, String partyId, String symbol, String type,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 params=new ArrayList(); params.add(partyId); if (!StringUtils.isNullOrEmpty(symbol)) { whereSql.append("AND SYMBOL=? "); params.add(symbol); } if ("orders".equals(type)) { whereSql.append("AND STATE=? "); params.add("submitted"); } else if ("hisorders".equals(type)) { whereSql.append("AND STATE=? "); params.add("created"); } 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(ContractOrder.class,whereSql.toString(),params.toArray(new Object[params.size()]))); } public List> findSubmittedRedis(String partyId, String symbol) { List ordersList = new ArrayList(); Map ordersMap = (Map) this.redisHandler.get(ContractRedisKeys.CONTRACT_SUBMITTED_ORDER_PARTY_ID + partyId); if (null != ordersMap && 0 != ordersMap.size()) { for (Entry entry : ordersMap.entrySet()) { if (StringUtils.isNotEmpty(symbol)) { if (symbol.equals(entry.getValue().getSymbol())) { ordersList.add(entry.getValue()); } } else { ordersList.add(entry.getValue()); } } // 创建时间 降序排列 if (ordersList.size() > 0) { Collections.sort(ordersList, new Comparator() { @Override public int compare(ContractOrder o1, ContractOrder o2) { Date date1 = o1.getCreate_time(); Date date2 = o2.getCreate_time(); return -date1.compareTo(date2); } }); } } return this.bulidData(ordersList); } private List> bulidData(List list) { List> data = new ArrayList>(); for (int i = 0; i < list.size(); i++) { ContractOrder order = list.get(i); Map map = bulidOne(order); data.add(map); } return data; } public Map bulidOne(ContractOrder order) { SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss a", Locale.ENGLISH); simpleDateFormat.setTimeZone(TimeZone.getTimeZone("America/New_York")); DecimalFormat df = new DecimalFormat("#.##"); Map map = new HashMap(); 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", simpleDateFormat.format(order.getCreate_time())); if (order.getClose_time() != null) { map.put("close_time", simpleDateFormat.format(order.getClose_time())); } else { map.put("close_time", ""); } map.put("direction", order.getDirection()); map.put("lever_rate", order.getLever_rate()); map.put("trade_avg_price", order.getTrade_avg_price()); map.put("close_avg_price", order.getClose_avg_price()); map.put("stop_price_profit", order.getStop_price_profit()); map.put("stop_price_loss", order.getStop_price_loss()); 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()); map.put("deposit_open", order.getDeposit_open()); map.put("change_ratio", order.getChange_ratio()); if(order.getAmount_close() < 0) { order.setAmount_close(0); } /** * 收益 */ if (ContractOrder.STATE_SUBMITTED.equals(order.getState())) { double rate = Arith.div(order.getVolume(), order.getVolume_open()); map.put("profit",df.format(Arith.sub( Arith.add(Arith.add(order.getAmount_close(),Arith.mul(order.getProfit(),rate)), order.getDeposit()), order.getDeposit_open()))); } else { map.put("profit", df.format(order.getProfit())); } // double currentPrice = Double.parseDouble(map.get("trade_avg_price").toString()); // // double leve = Double.parseDouble(map.get("lever_rate").toString()); // //得到强平价格 // if(null != map.get("direction")){ // double liquidationPrice; // if(map.get("direction").equals("sell")){ // liquidationPrice = currentPrice * (1 + (1 / leve)); // }else{ // liquidationPrice = currentPrice * (1 - 1 / leve); // } // DecimalFormat dfs = new DecimalFormat("#.#####"); // String formattedPrice = dfs.format(liquidationPrice); // map.put("qiangPing",formattedPrice); // } double depositOpen = Double.parseDouble(map.get("deposit_open").toString()); double leverRate = Double.parseDouble(map.get("lever_rate").toString()); double tradeAvgPrice = Double.parseDouble(map.get("trade_avg_price").toString()); double mul = Arith.mul(depositOpen, leverRate);//仓位 double div = Arith.div(mul, tradeAvgPrice);//持有币的数量 /** * 计算全仓收益 保证金 */ double profit = 0; List list = findSubmitted(order.getPartyId().toString(), null, null); for (int f = 0; f < list.size(); f++) { ContractOrder close_line = list.get(f); if(close_line.getProfit() > 0){ profit = Arith.add(profit, Arith.add(close_line.getProfit(), close_line.getDeposit())); }else{ profit = Arith.add(profit, close_line.getDeposit()); } } Wallet wallet = this.walletService.saveWalletByPartyId(order.getPartyId().toString()); double totleMoney = wallet.getMoney(); profit = Arith.add(profit,totleMoney); if (map.get("direction") != null) { String direction = map.get("direction").toString(); double liquidationPrice; double deposit = depositOpen + profit; if(leverRate == 1){ liquidationPrice = 0; }else { if ("sell".equals(direction)) { liquidationPrice = tradeAvgPrice + (deposit / div); } else { liquidationPrice = (mul * tradeAvgPrice) / (deposit + mul); } } DecimalFormat dfs = new DecimalFormat("#.#####"); String formattedPrice = dfs.format(liquidationPrice); map.put("qiangPing", formattedPrice); } map.put("volume", order.getVolume()); map.put("volume_open", order.getVolume_open()); return map; } // // public static void main(String[] args) { Map map = new HashMap<>(); map.put("direction", "buy"); // "buy" 或 "sell" double currentPrice = 59649.7; // 开仓价格 double leve = 10; // 杠杆倍数 double bzj = 500; // 保证金 double zjbzj = 500; // 资金账户 double xj = 70781.28; // 现价 double mul = Arith.mul(bzj, leve);//仓位 double div = Arith.div(mul, currentPrice);//持有币的数量 double amount = Arith.mul(div, Arith.sub(xj, currentPrice)); System.out.println(amount); if (map.get("direction") != null) { String direction = map.get("direction").toString(); double liquidationPrice; double bcbzj = bzj + zjbzj; if(leve == 1){ liquidationPrice = 0; }else{ if ("sell".equals(direction)) { liquidationPrice = currentPrice + (bcbzj / div); } else { liquidationPrice = (mul * currentPrice) / (bcbzj + mul); } } DecimalFormat dfs = new DecimalFormat("#.#####"); String formattedPrice = dfs.format(liquidationPrice); map.put("qiangPing", formattedPrice); } // 打印结果以验证 System.out.println("Calculated Liquidation Price: " + map.get("qiangPing")); } // @Override public List findSubmitted() { return ApplicationUtil.executeSelect(ContractOrder.class,"WHERE STATE=?",new Object[] {ContractOrder.STATE_SUBMITTED}); } public List findByPartyIdAndToday(String partyId) { return ApplicationUtil.executeSelect(ContractOrder.class,"WHERE PARTY_ID=? AND DATEDIFF(CREATE_TIME,NOW())=0",new Object[] {partyId}); } public void setWalletService(WalletService walletService) { this.walletService = walletService; } public void setUserDataService(UserDataService userDataService) { this.userDataService = userDataService; } public void setItemService(ItemService itemService) { this.itemService = itemService; } public void setMoneyLogService(MoneyLogService moneyLogService) { this.moneyLogService = moneyLogService; } public void setContractApplyOrderService(ContractApplyOrderService contractApplyOrderService) { this.contractApplyOrderService = contractApplyOrderService; } @Override public boolean lock(String order_no) { return ContractLock.add(order_no); } @Override public void unlock(String order_no) { ContractLock.remove(order_no); } public void setRedisHandler(RedisHandler redisHandler) { this.redisHandler = redisHandler; } public void setPartyService(PartyService partyService) { this.partyService = partyService; } public void setTipService(TipService tipService) { this.tipService = tipService; } public void setAssetService(AssetService assetService) { this.assetService = assetService; } }