多维表格信息同步(待测试)

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<String> statusList = Arrays.asList(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();
+                    }
+                }
+            }
+        });
     }
 
 }