| | |
| | | if (responseDto.getStatus() == 200) { |
| | | AlarmMsgResponseDto dto = JSON.parseObject(responseDto.getData().toString(), AlarmMsgResponseDto.class); |
| | | List<OdsAlarmMsg> list = dto.getContent(); |
| | | System.out.println(list.size()); |
| | | // System.out.println(list.size()); |
| | | list.forEach(o -> { |
| | | try { |
| | | alarmMsgService.save(o); |
| | |
| | | } |
| | | |
| | | |
| | | @Scheduled(cron = "0 0 1 * * ?") // 每天零点执行 |
| | | // @Scheduled(cron = "0/1 * * * * ?") // 每秒执行 |
| | | // @Scheduled(cron = "0 0 1 * * ?") // 每天零点执行 |
| | | @Scheduled(cron = "0 */5 * * * ?") // 每5分钟执行 |
| | | public void listDataIntime() { |
| | | try { |
| | | DataIntimeParamDto paramDto = DataIntimeParamDto.builder().build(); |
| | |
| | | List<OdsInTime> list = dataIntimeResponseDto.getContent(); |
| | | list.forEach(o -> { |
| | | try { |
| | | inTimeService.save(o); |
| | | o.setModifyTime(LocalDateTime.now()); |
| | | inTimeService.saveOrUpdate(o); |
| | | } catch (Exception ex) { |
| | | System.out.printf(ex.getMessage()); |
| | | } |