| | |
| | | // throw new JobExecutionException("定时任务已禁用: " + taskId); |
| | | // } |
| | | |
| | | // 2. 创建并保存巡检任务记录 - 这就是您提供的代码应该放的位置 |
| | | InspectionTask inspectionTask = createInspectionTask(timingTask); |
| | | inspectionTaskMapper.insert(inspectionTask); |
| | | // 2. 创建并保存巡检任务记录;设备已停用时跳过,不生成巡检任务 |
| | | if (!isDeviceDisabled(timingTask.getTaskId())) { |
| | | InspectionTask inspectionTask = createInspectionTask(timingTask); |
| | | inspectionTaskMapper.insert(inspectionTask); |
| | | } |
| | | |
| | | // 3. 更新定时任务的执行时间 |
| | | if (!tasks.isEmpty()) { |
| | |
| | | } |
| | | } |
| | | |
| | | /** |
| | | * 设备是否已停用(停用设备不参与巡检) |
| | | */ |
| | | private boolean isDeviceDisabled(Integer deviceId) { |
| | | if (deviceId == null || deviceId <= 0) { |
| | | return false; |
| | | } |
| | | List<Integer> enabledList = jdbcTemplate.queryForList( |
| | | "SELECT is_enabled FROM device_ledger WHERE id = ?", Integer.class, deviceId); |
| | | if (enabledList.isEmpty() || enabledList.get(0) == null) { |
| | | return false; |
| | | } |
| | | return enabledList.get(0) == 0; |
| | | } |
| | | |
| | | // 这就是您提供的代码封装成的方法 |
| | | private InspectionTask createInspectionTask(TimingTask timingTask) { |
| | | InspectionTask inspectionTask = new InspectionTask(); |