撮合交易代码提交

zainali5120

2020-09-14 74ca5bc0f40e3b91464c8972392271d24dd5f066

 src/main/java/com/xcong/excoin/quartz/job/KLineGeneratorJob.java

@@ -33,9 +33,9 @@
   @Resource
   private RedisUtils redisUtils;

   @Scheduled(cron = "0/2 * * * * *")
   @Scheduled(cron = "0/10 * * * * *")
    public void tradePlate(){
      redisUtils.set("NEKK_NEW_PRICE",new BigDecimal(Math.random()));
      redisUtils.set("NEKK_NEW_PRICE",new BigDecimal(Math.random()*20));
      Candlestick candlestick = new Candlestick();
      candlestick.setOpen(new BigDecimal("10.33"));
      candlestick.setHigh(new BigDecimal("15.23"));
@@ -46,7 +46,7 @@
      candlestick.setId(1599840000L);
      candlestick.setCount(100002);
      candlestick.setClose(new BigDecimal("12.2323"));
      redisUtils.set("NEKK/USDT",candlestick);
      //redisUtils.set("NEKK/USDT",candlestick);
      // [[10244.21, 0.000855], [10243.7, 0.008777], [10243.59, 0.14], [10243.37, 0.467663]]
      TradePlateModel tradePlateModel = new TradePlateModel();
      List<BigDecimal> buy;
@@ -61,11 +61,11 @@
         sell.add(new BigDecimal(Math.random()*i*2));
         tradePlateModel.getSell().add(sell);
      }

      plateSendWebSocket.sendMessagePlate(JSON.toJSONString(tradePlateModel),null);
      plateSendWebSocket.sendMessageKline("nekkusdt","1min","{amount: 114419.67835656216,close: 2.7261,count: 782,high: 2.7299,id: 1599632100,low: 2.723,open: 2.7288,vol: 311958.06091543}",null);
      plateSendWebSocket.sendMessageKline("nekkusdt","5min","{amount: 514419.67835656216,close: 2.7261,count: 782,high: 2.7299,id: 1599632100,low: 2.723,open: 2.7288,vol: 911958.06091543}",null);
      plateSendWebSocket.sendMessageKline("nekkusdt","15min","{amount: 514419.67835656216,close: 2.7261,count: 782,high: 2.7299,id: 1599632100,low: 2.723,open: 2.7288,vol: 911958.06091543}",null);
        log.info("准备发送消息");
      plateSendWebSocket.sendMessagePlate("NEKK/USDT",JSON.toJSONString(tradePlateModel),null);
      plateSendWebSocket.sendMessageKline("NEKK/USDT","1min","{amount: 114419.67835656216,close: 2.7261,count: 782,high: 2.7299,id: 1599632100,low: 2.723,open: 2.7288,vol: 311958.06091543}",null);
      plateSendWebSocket.sendMessageKline("NEKK/USDT","5min","{amount: 514419.67835656216,close: 2.7261,count: 782,high: 2.7299,id: 1599632100,low: 2.723,open: 2.7288,vol: 911958.06091543}",null);
      plateSendWebSocket.sendMessageKline("NEKK/USDT","15min","{amount: 514419.67835656216,close: 2.7261,count: 782,high: 2.7299,id: 1599632100,low: 2.723,open: 2.7288,vol: 911958.06091543}",null);
   }

    /**
@@ -156,4 +156,5 @@
           }
        });
    }

}