src/main/java/com/xcong/excoin/rabbit/consumer/OtcConsumer.java | ●●●●● patch | view | raw | blame | history | |
src/test/java/com/xcong/excoin/OtcTest.java | ●●●●● patch | view | raw | blame | history |
src/main/java/com/xcong/excoin/rabbit/consumer/OtcConsumer.java
@@ -32,7 +32,8 @@ public void marketBussiness(String content) { log.info("收到市商消息:{}", content); JSONObject jsonObject = JSONObject.parseObject(content); Long entrustOrderId = (Long) jsonObject.get("entrustOrderId"); Integer entrustOrderIdInt = jsonObject.getInteger("entrustOrderId"); Long entrustOrderId = entrustOrderIdInt.longValue(); Integer status = jsonObject.getInteger("status"); OtcEntrustOrder entrustOrder = otcEntrustOrderDao.selectById(entrustOrderId); src/test/java/com/xcong/excoin/OtcTest.java
@@ -37,4 +37,9 @@ public void jobTest() { otcOrderJob.marketBussinessJob(); } @Test public void mbProducterTest() { otcProducter.sendMarketBussinessMsg(11L, 3); } }