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 dca9540..6263b02 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 @@ -55,7 +55,7 @@ public class LarkApplicationRunner implements ApplicationRunner { /** * 线程睡眠时间 */ - private static final Integer WAIT_TIME = 5000; + private static final Integer WAIT_TIME = 10000; @Autowired private EventMapper eventMapper; @@ -69,33 +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 statusList = Arrays.asList(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(); + } + } + } + }); } }