| | |
| | | |
| | | import javax.annotation.Resource; |
| | | import java.time.LocalTime; |
| | | import java.util.List; |
| | | |
| | | import static cn.lihu.jh.module.ecg.Constants.ECG_OPENING_TIME_KEY; |
| | | import static cn.lihu.jh.module.ecg.Constants.ECG_QUEUE_READY_MAX_KEY; |
| | | |
| | | @Component |
| | | public class MySpringEventListener { |
| | |
| | | public void onApplicationEvent(ApplicationStartedEvent event) { |
| | | System.out.println("应用启动完成,系统初始。。。"); |
| | | |
| | | queueService.initBedQueueAndSeqNumFromDB(); |
| | | Integer queueReadyMax = Integer.valueOf(configApi.getConfigValueByKey(ECG_QUEUE_READY_MAX_KEY)); |
| | | queueService.setQueueReadyMax( queueReadyMax ); |
| | | |
| | | String strOpeningTime = configApi.getConfigValueByKey(ECG_OPENING_TIME_KEY); |
| | | LocalTime openingTime = Utils.parseOpeningTime(strOpeningTime); |
| | | String strOpenCloseTime = configApi.getConfigValueByKey(ECG_OPENING_TIME_KEY); |
| | | List<LocalTime> list = Utils.parseOpeningTime(strOpenCloseTime); |
| | | LocalTime openingTime = list.get(0); |
| | | LocalTime closeTime = list.get(1); |
| | | |
| | | // 获取当前时间 |
| | | LocalTime currentTime = LocalTime.now(); |
| | | |
| | | // 比较时间 |
| | | if (currentTime.isBefore(openingTime)) { |
| | | // NO OP |
| | | } else if (currentTime.isAfter(openingTime)) { |
| | | queueService.startBiz(); |
| | | if (currentTime.isBefore(openingTime) || currentTime.isAfter(closeTime)) { |
| | | queueService.closeBiz(); |
| | | } else { |
| | | queueService.startBiz(); |
| | | } |