时间

zj

2025-07-11 7052c78ee93e552ed061c830a6bddc06acabd147

 src/main/java/project/contract/internal/ContractOrderServiceImpl.java

@@ -1,5 +1,7 @@
package project.contract.internal;

import java.math.BigDecimal;
import java.math.RoundingMode;
import java.text.DecimalFormat;
import java.text.SimpleDateFormat;
import java.util.*;
@@ -7,7 +9,6 @@
import java.util.concurrent.ConcurrentHashMap;

import org.apache.commons.collections.CollectionUtils;
import org.apache.commons.lang3.ObjectUtils;

import kernel.util.Arith;
import kernel.util.DateUtils;
@@ -15,6 +16,7 @@
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;
@@ -38,6 +40,7 @@
import project.wallet.AssetService;
import project.wallet.Wallet;
import project.wallet.WalletService;
import project.web.admin.AdminContractOrderController;
import util.DateUtil;
import util.RandomUtil;
public class ContractOrderServiceImpl implements ContractOrderService {
@@ -74,7 +77,7 @@
      order.setPips_amount(item.getPips_amount());
      order.setCreate_time(new Date());

        ApplicationUtil.executeInsert(order);
      ApplicationUtil.executeInsert(order);
      redisHandler.setSync(ContractRedisKeys.CONTRACT_ORDERNO + order.getOrder_no(), order);

      Map<String, ContractOrder> map = (Map<String, ContractOrder>) redisHandler.get(ContractRedisKeys.CONTRACT_SUBMITTED_ORDER_PARTY_ID + order.getPartyId().toString());
@@ -129,8 +132,19 @@
      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) {
@@ -202,7 +216,12 @@

      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());
@@ -223,12 +242,6 @@
      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);

      /**
       * 合约产品平仓后添加当前流水
@@ -313,7 +326,11 @@
       */
      double rate = Arith.div(volume, order.getVolume_open());

      //profit = Arith.mul(Arith.add(order.getDeposit(), order.getProfit()), rate);
      //平仓收益
//      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));
@@ -323,7 +340,7 @@
         order.setState(ContractOrder.STATE_CREATED);
         order.setClose_time(new Date());
      }

      update(order);
      return profit;

   }
@@ -461,8 +478,9 @@
   }

   public Map<String, Object> bulidOne(ContractOrder order) {
      SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd  hh:mm:ss  a", Locale.ENGLISH);
      simpleDateFormat.setTimeZone(TimeZone.getTimeZone("America/New_York"));
//      SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd  hh:mm:ss  a", Locale.ENGLISH);
      SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
      simpleDateFormat.setTimeZone(TimeZone.getTimeZone("Europe/Berlin"));
      DecimalFormat df = new DecimalFormat("#.##");
      Map<String, Object> map = new HashMap<String, Object>();
      map.put("order_no", order.getOrder_no());
@@ -497,26 +515,11 @@
      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())));
               Arith.add(Arith.add(order.getAmount_close(),Arith.mul(order.getProfit(),rate)), order.getDeposit()),
               order.getDeposit_open())));
      } else {
         map.put("profit", df.format(Arith.sub(Arith.add(order.getAmount_close(), order.getDeposit()), order.getDeposit_open())));
         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());
@@ -541,24 +544,34 @@
      double totleMoney = wallet.getMoney();
      profit = Arith.add(profit,totleMoney);


      if (map.get("direction") != null) {
      if (map.get("direction") != null && map.get("state").equals("submitted")) {
         String direction = map.get("direction").toString();
         double liquidationPrice;
         double deposit = depositOpen + profit;
         double deposit =  profit;

         if(leverRate == 1){
            liquidationPrice = 0;
         }else {
            if ("sell".equals(direction)) {
               liquidationPrice = tradeAvgPrice + (deposit / div);
               double lossPercentage = deposit / (Arith.mul(order.getVolume(), order.getUnit_amount()));
               double priceIncrease = lossPercentage * tradeAvgPrice;
               liquidationPrice = tradeAvgPrice + priceIncrease;
            } else {
               liquidationPrice = (mul * tradeAvgPrice) / (deposit + mul);
               double lossPercentage = deposit / (Arith.mul(order.getVolume(), order.getUnit_amount()));
               double priceDrop = lossPercentage * tradeAvgPrice;
               liquidationPrice = tradeAvgPrice - priceDrop;
            }
         }

         // 检查 liquidationPrice 是否为有效数字
         if (Double.isInfinite(liquidationPrice) || Double.isNaN(liquidationPrice)) {
            liquidationPrice = 0;  // 如果是无效结果，回退为 0
         }
         DecimalFormat dfs = new DecimalFormat("#.#####");
         String formattedPrice = dfs.format(liquidationPrice);
         // 检查是否为负数
         if (Double.parseDouble(formattedPrice) < 0) {
            formattedPrice = "0";
         }
         map.put("qiangPing", formattedPrice);
      }

@@ -567,48 +580,6 @@

      return map;
   }
//
//
   public static void main(String[] args) {
      Map<String, Object> 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<ContractOrder> findSubmitted() {
@@ -619,6 +590,21 @@
      return ApplicationUtil.executeSelect(ContractOrder.class,"WHERE PARTY_ID=? AND DATEDIFF(CREATE_TIME,NOW())=0",new Object[] {partyId});
   }

   @Override
   public void updateleve(String orderNo, String leve) {
      System.out.println("--------order:"+orderNo+"---------leve:"+leve);
      ContractOrder order = findByOrderNo(orderNo);
      if (order != null) {
         System.out.println("bbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbb");
         order.setLever_rate(Double.valueOf(leve));
         this.redisHandler.setSync(ContractRedisKeys.CONTRACT_ORDERNO + orderNo,order);
         System.out.println("===============================order"+order.toString());
         System.out.println("ccccccccccccccccccccccccccccccccccccccccccccccccccccccccccccc");
         ApplicationUtil.executeUpdate(ContractOrder.class,"WHERE ORDER_NO=?",new Object[] {order});
         System.out.println("ddddddddddddddddddddddddddddddddddddddddddddddddddddddddddd");
      }
   }

   public void setWalletService(WalletService walletService) {
      this.walletService = walletService;
   }