package com.gkhy.safePlatform.doublePrevention.service.baseService.impl; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.gkhy.safePlatform.commons.enums.E; import com.gkhy.safePlatform.commons.enums.ResultCodes; import com.gkhy.safePlatform.commons.exception.AusinessException; import com.gkhy.safePlatform.commons.exception.BusinessException; import com.gkhy.safePlatform.doublePrevention.entity.PreventRiskControlMeasure; import com.gkhy.safePlatform.doublePrevention.entity.dto.req.PreventHandReportConfigReqDTO; import com.gkhy.safePlatform.doublePrevention.repository.PreventRiskControlMeasureRepository; import com.gkhy.safePlatform.doublePrevention.repository.param.HandlerReportParam; import com.gkhy.safePlatform.doublePrevention.repository.param.PreventRiskControlMeasureDeleteParams; import com.gkhy.safePlatform.doublePrevention.repository.param.PreventRiskControlMeasureQueryParams; import com.gkhy.safePlatform.doublePrevention.repository.param.PreventRiskControlMeasureUpdateParams; import com.gkhy.safePlatform.doublePrevention.service.baseService.PreventRiskControlMeasureService; import org.apache.ibatis.annotations.Param; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import java.util.List; @Service("PreventRiskControlMeasureService") public class PreventRiskControlMeasureServiceImpl extends ServiceImpl implements PreventRiskControlMeasureService { @Autowired private PreventRiskControlMeasureRepository preventRiskControlMeasureRepository; /** * 管控措施-分页查询 */ @Override public IPage getRiskControlMeasurePage(@Param("page")Page page, @Param("queryParams")PreventRiskControlMeasureQueryParams queryParams) { return preventRiskControlMeasureRepository.getRiskControlMeasurePage(page, queryParams); //queryParams.getControlWay(), queryParams.getRiskEventId() } /** * 管控措施-根据RiskEventId查询 */ @Override public List getRiskControlMeasureByRiskEventId(Long riskEventId) { return preventRiskControlMeasureRepository.getRiskControlMeasureByRiskEventId(riskEventId); } /** * 管控措施-新增 */ @Override public int saveRiskControlMeasure(PreventRiskControlMeasure controlMeasure) { int insertResult = preventRiskControlMeasureRepository.insert(controlMeasure); if (insertResult == 0 ){ throw new AusinessException(E.ADD_FAIL, "新增失败"); } return insertResult; } /** * 管控措施-根据措施编码与riskEventId查询 */ @Override public PreventRiskControlMeasure getRiskControlMeasureByCodeAndEventId(Long riskEventId, String controlMeasureCode) { return preventRiskControlMeasureRepository.getRiskControlMeasureByCodeAndEventId(riskEventId, controlMeasureCode); } /** * 管控措施-修改 */ @Override public int updateRiskControlMeasure(PreventRiskControlMeasureUpdateParams updateParams) { return preventRiskControlMeasureRepository.updateRiskControlMeasure(updateParams); } /** * 管控措施-根据id查询 */ @Override public PreventRiskControlMeasure getControlMeasureById(Long id) { return preventRiskControlMeasureRepository.selectByMeasureId(id); } /** * 管控措施-删除 */ @Override public int deleteRiskControlMeasure(PreventRiskControlMeasureDeleteParams deleteParams) { return preventRiskControlMeasureRepository.deleteRiskControlMeasure(deleteParams); } /** * 任务单元、任务关联修改,设置为空 * 管控措施-修改管控措施 */ @Override public void updateControlMeasureByUnitId(Long unitId) { int result = preventRiskControlMeasureRepository.updateControlMeasureByUnitId(unitId); if (result < 0){ throw new AusinessException(E.UPDATE_FAIL, "重置管控措施与单元关联失败"); } } /** * 管控措施-根据measureCode查询 */ @Override public PreventRiskControlMeasure getControlMeasureByCode(String measureCode) { return preventRiskControlMeasureRepository.getControlMeasureByCode(measureCode); } /** * 管控措施-根据measureCode * 修改关联checkWorkId */ @Override public PreventRiskControlMeasure updateWorkIdByMeasureCode(String controlMeasureCode, Long checkWorkId) { return preventRiskControlMeasureRepository.updateWorkIdByMeasureCode(controlMeasureCode, checkWorkId); } /** * 管控措施-根据WorkId查询 */ @Override public List getControlMeasureByWorkId(Long workId) { return preventRiskControlMeasureRepository.getControlMeasureByWorkId(workId); } /** * 管控措施-根据单元id查找对应措施id列表 */ @Override public List getlistByUnitId(Long taskUnitId) { return preventRiskControlMeasureRepository.getListByUnitId(taskUnitId); } /** * 管控措施-根据measureId修改关联的任务taskId */ @Override public void updateControlMeasureByMeasureIdAndUnitId(Long measureId, Long taskUnitId) { int result = preventRiskControlMeasureRepository.updateControlMeasureByMeasureIdAndUnitId(measureId, taskUnitId); if (result == 0) { throw new BusinessException(ResultCodes.SERVER_UPDATE_ERROR); } } /** * 安全风险事件-手工上报-配置 */ @Override public int updateMeasuresReport(PreventHandReportConfigReqDTO preventHandReportConfigReqDTO) { return preventRiskControlMeasureRepository.updateRiskEventReport(preventHandReportConfigReqDTO); } /** * 措施-手工上报-配置 */ @Override public List listReportMeasure() { return preventRiskControlMeasureRepository.listReportMeasure(); } /** * 管控措施- 管控措施列表 */ @Override public List listControlMeasure() { return preventRiskControlMeasureRepository.listControlMeasure(); } /** * 管控措施- 管控措施UUid */ @Override public PreventRiskControlMeasure getControlMeasureByUuid(String measureUuid) { return preventRiskControlMeasureRepository.getControlMeasureByUuid(measureUuid); } /** * 管控措施- 上报状态更新 */ @Override public void updateMeasureReportStatus(HandlerReportParam handlerReportParam) { int result = preventRiskControlMeasureRepository.updateMeasureReportStatus(handlerReportParam); if (result == 0) { throw new BusinessException(ResultCodes.SERVER_UPDATE_ERROR); } } }