2

peternameyakj

2024-08-14 9bcf85f8d8f9b503e386a67924f5943cd77bd813

 src/main/java/project/contract/job/ContractOrderCalculationServiceImpl.java

@@ -1,26 +1,45 @@
package project.contract.job;

import java.text.DecimalFormat;
import java.util.List;
import java.util.Map;

import kernel.util.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import kernel.util.Arith;
import kernel.util.ThreadUtils;
import org.springframework.beans.BeansException;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.ApplicationContext;
import org.springframework.context.ApplicationContextAware;
import org.springframework.util.ObjectUtils;
import project.contract.ContractLock;
import project.contract.ContractOrder;
import project.contract.ContractOrderService;
import project.contract.ContractRedisKeys;
import project.data.DataService;
import project.data.model.Realtime;
import project.redis.RedisHandler;
import project.syspara.SysparaService;
import project.wallet.AssetService;
import project.wallet.Wallet;
import project.wallet.WalletRedisKeys;
import project.wallet.WalletService;
import project.wallet.consumer.WalletMessage;

public class ContractOrderCalculationServiceImpl implements ContractOrderCalculationService {
public class ContractOrderCalculationServiceImpl implements ContractOrderCalculationService, ApplicationContextAware {
   private ApplicationContext applicationContext;

   private static final Logger logger = LoggerFactory.getLogger(ContractOrderCalculationServiceImpl.class);
   private ContractOrderService contractOrderService;
   private DataService dataService;
   private WalletService walletService;
//   private RedisHandler redisHandler;
   private AssetService assetService;
   public final static String STATE_SUBMITTED = "submitted";
   public final static String STATE_CREATED = "created";
   /**
    * 平仓线 110%（订金价值 /收益=110%）
    */
@@ -53,6 +72,7 @@
            /*
             * 0 买涨
             */
            logger.info("当前价格："+close+"---------价格："+Arith.add(order.getTrade_avg_price(), order.getPips()));
            if (close >= Arith.add(order.getTrade_avg_price(), order.getPips())) {
               settle(order, "profit", close);
            }
@@ -80,30 +100,72 @@

   /**
    * 盈亏计算
    * 
    *
    * @param profit_loss  profit 盈 loss亏
    * @param currentPrice 当前点位
    */
   public void settle(ContractOrder order, String profit_loss, double currentPrice) {

      /**
       * 偏差点位
       */
      double point = Arith.div(Math.abs(Arith.sub(currentPrice, order.getTrade_avg_price())), order.getPips());
		
      /*
       * 根据偏 差点数和手数算出盈亏金额
       */
      double amount = Arith.mul(Arith.mul(order.getPips_amount(), point), order.getVolume());
		
      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(currentPrice, order.getTrade_avg_price()));
      logger.info("---------盈亏金额："+amount);
      logger.info("---------盈亏："+profit_loss);
      RedisHandler redisHandler = getRedisHandler();
      if ("profit".equals(profit_loss)) {
         /**
          * 盈 正数
          */
         order.setProfit(Arith.add(0.0D, amount));
         order.setProfit(Arith.add(0.0D, Math.abs(amount)));
         redisHandler.setSync("MONEY_CONTRACT_PROFIT_"+order.getPartyId().toString(), 0);
      } else if ("loss".equals(profit_loss)) {
         order.setProfit(Arith.sub(0.0D, amount));
         order.setProfit(Arith.sub(0.0D,Math.abs(amount) ));

         //---------------------------------------------  这一段代码是新加的，服务器上面现在是注释的
         //定义一个 总浮动亏损的值
         logger.info("----------fffffffffffffff-------"+redisHandler);
         logger.info("----------ssssssssssss-------"+order.getPartyId().toString());
         Double contractAssetsProfit = (Double) redisHandler.get(ContractRedisKeys.CONTRACT_ASSETS_PROFIT_PARTY_ID + order.getPartyId().toString());
         logger.info("----------bbbbbbbbbbbbbbbbbb-------"+contractAssetsProfit);
         double contractProfit = null == contractAssetsProfit ? 0.000D : contractAssetsProfit;
         logger.info("----------contractProfit-------"+contractProfit);
         List<ContractOrder> list = contractOrderService.findSubmitted(order.getPartyId().toString(), null, null);
         double deposit = 0;
         for (int i = 0; i < list.size(); i++) {
            ContractOrder close_line = list.get(i);
            deposit = Arith.add(deposit, close_line.getDeposit());
         }
         double profitt = Arith.add(contractProfit,deposit);
         logger.info("----------盈亏除去保证金之后的值-------"+profitt);
         if(profitt <= 0){
            redisHandler.setSync("MONEY_CONTRACT_PROFIT_"+order.getPartyId().toString(), profitt);
         }else{
            redisHandler.setSync("MONEY_CONTRACT_PROFIT_"+order.getPartyId().toString(), 0);
         }
         logger.info("----------1111111111111-------");
         //修改余额,每次修改取平仓前余额减去浮动亏损
         Wallet wallet = this.walletService.saveWalletByPartyId(order.getPartyId().toString());
         logger.info("----------wallet-------"+wallet);
         Object money = redisHandler.get("PARTY_ID_MONEY_" + order.getPartyId().toString());
         Object profit = redisHandler.get("MONEY_CONTRACT_PROFIT_" + order.getPartyId().toString());
         logger.info("----------money-------"+money);
         logger.info("----------profit-------"+profit);
         if(!ObjectUtils.isEmpty(money) && !ObjectUtils.isEmpty(profit)){
            wallet.setMoney(Arith.add(Double.parseDouble(money.toString()),Double.parseDouble(profit.toString())));
         }
         logger.info("----------2222222222222-------");
         redisHandler.setSync(WalletRedisKeys.WALLET_PARTY_ID + wallet.getPartyId().toString(), wallet);
         logger.info("----------3333333333333333------");
         redisHandler.pushAsyn(WalletRedisKeys.WALLET_QUEUE_UPDATE, new WalletMessage(order.getPartyId().toString(), amount));
         logger.info("----------4444444444444-------");
         //------------------------------------------
      }

      double changeRatio;
      changeRatio = Arith.mul(Arith.div(order.getProfit(), order.getDeposit_open()), 100);
      DecimalFormat df = new DecimalFormat("#.##");
      order.setChange_ratio(Double.valueOf(df.format(changeRatio)));

      /**
       * 多次平仓价格不对，后续修
       */
@@ -156,11 +218,13 @@
            return;
         }
      }
      logger.info("order_close_line_type:"+order_close_line_type);
      if (order_close_line_type == 1) {
         /**
          * 收益
          */
         double profit = 0;

         List<ContractOrder> list = contractOrderService.findSubmitted(order.getPartyId().toString(), null, null);
         for (int i = 0; i < list.size(); i++) {
            ContractOrder close_line = list.get(i);
@@ -168,7 +232,7 @@
         }
         Wallet wallet = this.walletService.saveWalletByPartyId(order.getPartyId().toString());
         double totleMoney = wallet.getMoney();
         if (Arith.add(profit, totleMoney) <= 0) {
         if (Arith.add(profit,totleMoney) <= 0) {
            /**
             * 触发全仓强平
             */
@@ -178,6 +242,7 @@
               ContractOrder close_line = list.get(i);
               if (!order.getOrder_no().equals(close_line.getOrder_no())) {
                  try {

                     while (true) {
                        if (ContractLock.add(close_line.getOrder_no())) {
                           this.contractOrderService.saveClose(close_line.getPartyId().toString(),
@@ -188,7 +253,9 @@
                           break;
                        }
                        ThreadUtils.sleep(500);

                     }

                  } catch (Exception e) {
                     logger.error("error:", e);
                  } finally {
@@ -201,14 +268,21 @@

         }
      } else {
         logger.info("---------进入单个持仓----------------");
         logger.info("---------order.getProfit()----------------"+order.getProfit());
         logger.info("---------order.getDeposit()----------------"+order.getDeposit());
         logger.info("---------order_close_line----------------"+order_close_line);
         if (order.getProfit() < 0 && (Arith.div(order.getDeposit(), Math.abs(order.getProfit())) <= Arith
               .div(order_close_line, 100))) {
            logger.info("---------进入强平了----------------");
            /**
             * 低于系统默认平仓线，进行强平
             */
            this.contractOrderService.saveClose(order.getPartyId().toString(), order.getOrder_no());
            return;
         }
      }

   }
   public void setDataService(DataService dataService) {
      this.dataService = dataService;
@@ -234,4 +308,19 @@
      this.order_close_line_type = order_close_line_type;
   }

   public RedisHandler getRedisHandler() {
      return applicationContext.getBean(RedisHandler.class);
   }


   public void setAssetService(AssetService assetService) {
      this.assetService = assetService;
   }


   @Override
   public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
      this.applicationContext = applicationContext;
   }

}