From e9662c954fd76c29fb00d594a8186874c20391ed Mon Sep 17 00:00:00 2001
From: YXY <932687738@qq.com>
Date: Wed, 15 Mar 2023 23:58:56 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A4=9A=E7=BB=B4=E8=A1=A8=E6=A0=BC=E4=BF=A1?=
 =?UTF-8?q?=E6=81=AF=E5=90=8C=E6=AD=A5(=E5=BE=85=E6=B5=8B=E8=AF=95)?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../consumer/LarkApplicationRunner.java       | 52 +++++++++----------
 1 file changed, 26 insertions(+), 26 deletions(-)

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<Event> 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<Event> 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();
+//                    }
+//                }
+//            }
+//        });
     }
 
 }