| | |
| | | import com.nanjing.water.common.util.StringUtil; |
| | | import com.nanjing.water.repository.impl.QuartzTaskErrorMapperImpl; |
| | | import com.nanjing.water.repository.impl.QuartzTaskRecordMapperImpl; |
| | | import com.nanjing.water.service.WaterFacilityParameterService; |
| | | import org.slf4j.Logger; |
| | | import org.slf4j.LoggerFactory; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | |
| | | private QuartzTaskRecordMapperImpl taskRecordsDao; |
| | | @Autowired |
| | | private QuartzTaskErrorMapperImpl taskErrorsDao; |
| | | @Autowired |
| | | private WaterFacilityParameterService waterFacilityParameterService; |
| | | |
| | | /** |
| | | * 执行job |
| | |
| | | return ExecutedResult.failed(e.toString()); |
| | | } |
| | | } |
| | | |
| | | /*** |
| | | * job执行器-查询最新启泵数据 |
| | | * @param jobParameter 执行参数 |
| | | */ |
| | | public ExecutedResult<String> getNewDataPump(String jobParameter) { |
| | | try { |
| | | waterFacilityParameterService.getNewDataPump(); |
| | | return ExecutedResult.success(); |
| | | } catch (Exception e) { |
| | | return ExecutedResult.failed(e.toString()); |
| | | } |
| | | } |
| | | /*** |
| | | * job执行器-清理任务调度日志 |
| | | * @param jobParameter 执行参数 |