diff --git a/ruoyi-flyingbook/src/main/java/com/ruoyi/flyingbook/consumer/LarkApplicationRunner.java b/ruoyi-flyingbook/src/main/java/com/ruoyi/flyingbook/consumer/LarkApplicationRunner.java index 6263b02..14aa06d 100644 --- a/ruoyi-flyingbook/src/main/java/com/ruoyi/flyingbook/consumer/LarkApplicationRunner.java +++ b/ruoyi-flyingbook/src/main/java/com/ruoyi/flyingbook/consumer/LarkApplicationRunner.java @@ -69,32 +69,32 @@ public class LarkApplicationRunner implements ApplicationRunner { @Override public void run(ApplicationArguments args) throws Exception { //这里用线程池,后续如果出现量大的情况下可以调整 - threadPool.execute(() -> { - - while (true) { - Event query = new Event(); - query.setOperateStatus(EventOperateStatus.PENDING.getCode()); - List eventList = eventMapper.selectEventList(query); - if (CollectionUtils.isEmpty(eventList)) { - try { - // 没有订单,休息一下 - Thread.sleep(WAIT_TIME); - } catch (InterruptedException e) { - e.printStackTrace(); - } - } else { - try { - for (Event event : eventList) { - LarkRequest request = new LarkRequest(); - request.setEvent(event); - multidimensionalTableOperate.execute(request); - } - } catch (Exception e) { - e.printStackTrace(); - } - } - } - }); +// threadPool.execute(() -> { +// +// while (true) { +// Event query = new Event(); +// query.setOperateStatus(EventOperateStatus.PENDING.getCode()); +// List eventList = eventMapper.selectEventList(query); +// if (CollectionUtils.isEmpty(eventList)) { +// try { +// // 没有订单,休息一下 +// Thread.sleep(WAIT_TIME); +// } catch (InterruptedException e) { +// e.printStackTrace(); +// } +// } else { +// try { +// for (Event event : eventList) { +// LarkRequest request = new LarkRequest(); +// request.setEvent(event); +// multidimensionalTableOperate.execute(request); +// } +// } catch (Exception e) { +// e.printStackTrace(); +// } +// } +// } +// }); } }