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