| | |
| | | package com.ruoyi.doublePrevention.service.baseService.impl;
|
| | |
|
| | | import com.ruoyi.doublePrevention.entity.PreventRiskJobAndMeasure;
|
| | | import com.ruoyi.doublePrevention.repository.PreventRiskJobAndMeasureRepository;
|
| | | import com.ruoyi.doublePrevention.service.baseService.PreventRiskJobAndMeasureService;
|
| | | import org.springframework.beans.factory.annotation.Autowired;
|
| | | import org.springframework.stereotype.Service;
|
| | |
|
| | | @Service("PreventRiskJobAndMeasureService")
|
| | | public class PreventRiskJobAndMeasureServiceImpl implements PreventRiskJobAndMeasureService {
|
| | |
|
| | | @Autowired
|
| | | private PreventRiskJobAndMeasureRepository preventRiskJobAndMeasureRepository;
|
| | |
|
| | | /**
|
| | | * 插入管控措施与job的对应关系
|
| | | * */
|
| | | @Override
|
| | | public int insertJobAndMeasure(PreventRiskJobAndMeasure jobAndMeasure) {
|
| | | return preventRiskJobAndMeasureRepository.insertJobAndMeasure(jobAndMeasure);
|
| | | }
|
| | |
|
| | | /**
|
| | | * 查询JobAndMeasure - By JobId
|
| | | */
|
| | | @Override
|
| | | public PreventRiskJobAndMeasure getJobAndMeasureByJobId(Long jobId) {
|
| | | return preventRiskJobAndMeasureRepository.getJobAndMeasureByJobId(jobId);
|
| | | }
|
| | | /**
|
| | | * 删除job管控措施的附属表关联信息
|
| | | */
|
| | | @Override
|
| | | public int deleteJobAndMeasure(Long jobId) {
|
| | | return preventRiskJobAndMeasureRepository.deleteJobAndMeasure(jobId);
|
| | | }
|
| | |
|
| | | }
|
| | | package com.ruoyi.doublePrevention.service.baseService.impl; |
| | | |
| | | import com.ruoyi.common.exception.BusinessException; |
| | | import com.ruoyi.doublePrevention.entity.PreventRiskJobAndMeasure; |
| | | import com.ruoyi.doublePrevention.enums.ResultCodes; |
| | | import com.ruoyi.doublePrevention.repository.PreventRiskJobAndMeasureRepository; |
| | | import com.ruoyi.doublePrevention.repository.param.HandlerReportParam; |
| | | import com.ruoyi.doublePrevention.service.baseService.PreventRiskJobAndMeasureService; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.stereotype.Service; |
| | | |
| | | import java.util.List; |
| | | |
| | | @Service("PreventRiskJobAndMeasureService") |
| | | public class PreventRiskJobAndMeasureServiceImpl implements PreventRiskJobAndMeasureService { |
| | | |
| | | @Autowired |
| | | private PreventRiskJobAndMeasureRepository preventRiskJobAndMeasureRepository; |
| | | |
| | | /** |
| | | * 插入管控措施与job的对应关系 |
| | | * */ |
| | | @Override |
| | | public int insertJobAndMeasure(PreventRiskJobAndMeasure jobAndMeasure) { |
| | | return preventRiskJobAndMeasureRepository.insertJobAndMeasure(jobAndMeasure); |
| | | } |
| | | |
| | | /** |
| | | * 查询JobAndMeasure - By JobId |
| | | */ |
| | | @Override |
| | | public PreventRiskJobAndMeasure getJobAndMeasureByJobId(Long jobId) { |
| | | return preventRiskJobAndMeasureRepository.getJobAndMeasureByJobId(jobId); |
| | | } |
| | | |
| | | @Override |
| | | public List<PreventRiskJobAndMeasure> getJobAndMeasureListByJobId(Long jobId) { |
| | | return preventRiskJobAndMeasureRepository.getJobAndMeasureListByJobId(jobId); |
| | | } |
| | | /** |
| | | * 删除job管控措施的附属表关联信息 |
| | | */ |
| | | @Override |
| | | public int deleteJobAndMeasure(Long jobId) { |
| | | return preventRiskJobAndMeasureRepository.deleteJobAndMeasure(jobId); |
| | | } |
| | | |
| | | |
| | | |
| | | /** |
| | | * 检索需要上报的隐患排查任务 |
| | | */ |
| | | @Override |
| | | public List<PreventRiskJobAndMeasure> listReportWork() { |
| | | return preventRiskJobAndMeasureRepository.listReportWork(); |
| | | } |
| | | /** |
| | | * 根据jobId查询对应的管控措施 |
| | | */ |
| | | @Override |
| | | public List<PreventRiskJobAndMeasure> getMeasureListByJobId(Long jobId) { |
| | | return preventRiskJobAndMeasureRepository.getMeasureListByJobId(jobId); |
| | | } |
| | | /** |
| | | * 修改上报状态 |
| | | */ |
| | | @Override |
| | | public int updateWorkReportStatus(HandlerReportParam handlerReportParam) { |
| | | int result = preventRiskJobAndMeasureRepository.updateWorkReportStatus(handlerReportParam); |
| | | if (result == 0) { |
| | | throw new BusinessException(ResultCodes.SERVER_UPDATE_ERROR.getCode()); |
| | | } |
| | | return result; |
| | | } |
| | | |
| | | @Override |
| | | public List<PreventRiskJobAndMeasure> listReportWorkTest() { |
| | | return preventRiskJobAndMeasureRepository.listReportWorkTest(); |
| | | } |
| | | |
| | | @Override |
| | | public List<PreventRiskJobAndMeasure> getRectifyJobData(Long jobId) { |
| | | return preventRiskJobAndMeasureRepository.getRectifyJobData(jobId); |
| | | } |
| | | |
| | | |
| | | } |