elkers
2025-04-12 60041d6ee9bd2fcd8b6bcb827bf46e0727941665
src/main/java/com/nanjing/water/service/quartz/QuartzExecutor.java
@@ -10,6 +10,7 @@
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;
@@ -27,6 +28,8 @@
    private QuartzTaskRecordMapperImpl taskRecordsDao;
    @Autowired
    private QuartzTaskErrorMapperImpl taskErrorsDao;
    @Autowired
    private WaterFacilityParameterService waterFacilityParameterService;
    /**
     * 执行job
@@ -42,7 +45,18 @@
            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 执行参数