package com.ruoyi.doublePrevention.service.baseService.impl; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.ruoyi.doublePrevention.entity.CJReport.PreventCJReportRiskControlMeasure; import com.ruoyi.doublePrevention.entity.ZDReport.HandlerZDReportParam; import com.ruoyi.doublePrevention.enums.E; import com.ruoyi.doublePrevention.exception.AusinessException; import com.ruoyi.doublePrevention.repository.PreventCJReportRiskControlMeasureRepository; import com.ruoyi.doublePrevention.repository.param.HandlerCJReportParam; import com.ruoyi.doublePrevention.repository.param.HandlerReportParam; import com.ruoyi.doublePrevention.service.baseService.PreventCJReportRiskControlMeasureService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import java.util.List; @Service("PreventCJReportRiskControlMeasureService") public class PreventCJReportRiskControlMeasureServiceImpl extends ServiceImpl implements PreventCJReportRiskControlMeasureService { @Autowired private PreventCJReportRiskControlMeasureRepository preventCJReportRiskControlMeasureRepository; // /** // * 上报数据-管控措施-分页查询 // */ // @Override // public IPage getReportMeasurePage(Page objectPage, PreventReportRiskControlMeasureReqDTO queryReqDTO) { // return preventCJReportRiskControlMeasureRepository.getReportMeasurePage(objectPage, queryReqDTO); // } /** * 插入管控措施上报数据 * */ @Override public int insertMeasureList(PreventCJReportRiskControlMeasure CJMeasure) { int result = preventCJReportRiskControlMeasureRepository.insertMeasureList(CJMeasure); if (result < 1){ throw new AusinessException(E.ADD_FAIL.getCode(), "保存风险单元失败"); } return result; } /** * 管控措施-上报数据 * */ @Override public List listReportMeasureDate() { return preventCJReportRiskControlMeasureRepository.listReportMeasureDate(); } /** * 管控措施-修改上报状态 * */ @Override public void updateMeasureReportStatus(HandlerReportParam handlerReportParam) { int result = preventCJReportRiskControlMeasureRepository.updateMeasureReportStatus(handlerReportParam); if (result < 1){ throw new AusinessException(E.ADD_FAIL.getCode(), "风险单元状态更新失败"); } } /** * 管控措施-修改上报状态-通过id * */ @Override public void updateCJReportStatusById(HandlerCJReportParam handlerCJReportParam) { int result = preventCJReportRiskControlMeasureRepository.updateCJReportStatusById(handlerCJReportParam); if (result < 1){ throw new AusinessException(E.ADD_FAIL.getCode(), "风险单元状态更新失败"); } } @Override public List listReportMeasureDateHuaiDong() { return preventCJReportRiskControlMeasureRepository.listReportMeasureDateHuaiDong(); } @Override public void updateHDReportStatusById(HandlerZDReportParam handlerZDReportParam) { int result = preventCJReportRiskControlMeasureRepository.updateHDReportStatusById(handlerZDReportParam); if (result < 1){ throw new AusinessException(E.ADD_FAIL.getCode(), "风险单元状态更新失败"); } } }