| | |
| | | } |
| | | |
| | | @Scheduled(cron = "0/3 * * * * ? ") |
| | | private void reportTaskToUplink() { |
| | | private synchronized void reportTaskToUplink() { |
| | | if (!uplinkProperties.getEnabled()) { |
| | | return; |
| | | } |
| | |
| | | |
| | | |
| | | @Scheduled(cron = "0/3 * * * * ? ") |
| | | private void reportFault() { |
| | | private synchronized void reportFault() { |
| | | String reportFaultUrl = configService.getVal("reportFaultUrl", String.class); |
| | | if (Cools.isEmpty(reportFaultUrl)) { |
| | | return; |
| | | } |
| | | List<VehFaultRec> vehFaultRecList = vehFaultRecService.list((new LambdaQueryWrapper<VehFaultRec>().eq(VehFaultRec::getState, VehFaultRecStateType.PENDING).ge(VehFaultRec::getHappenTime, Instant.now().minusSeconds(3).atZone(ZoneId.systemDefault()).toLocalDateTime()))); |
| | | List<VehFaultRec> vehFaultRecList = vehFaultRecService.list((new LambdaQueryWrapper<VehFaultRec>().eq(VehFaultRec::getState, VehFaultRecStateType.PENDING).ge(VehFaultRec::getHappenTime, Instant.now().minusSeconds(180).atZone(ZoneId.systemDefault()).toLocalDateTime()))); |
| | | if (Cools.isEmpty(vehFaultRecList)) { |
| | | return; |
| | | } |