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<PreventRiskControlMeasureRepository, PreventRiskControlMeasure> implements PreventRiskControlMeasureService {
|
|
@Autowired
|
private PreventRiskControlMeasureRepository preventRiskControlMeasureRepository;
|
|
/**
|
* 管控措施-分页查询
|
*/
|
@Override
|
public IPage<PreventRiskControlMeasure> getRiskControlMeasurePage(@Param("page")Page<Object> page, @Param("queryParams")PreventRiskControlMeasureQueryParams queryParams) {
|
return preventRiskControlMeasureRepository.getRiskControlMeasurePage(page, queryParams);
|
//queryParams.getControlWay(), queryParams.getRiskEventId()
|
}
|
|
/**
|
* 管控措施-根据RiskEventId查询
|
*/
|
@Override
|
public List<PreventRiskControlMeasure> 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<PreventRiskControlMeasure> getControlMeasureByWorkId(Long workId) {
|
return preventRiskControlMeasureRepository.getControlMeasureByWorkId(workId);
|
}
|
|
/**
|
* 管控措施-根据单元id查找对应措施id列表
|
*/
|
@Override
|
public List<PreventRiskControlMeasure> 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<PreventRiskControlMeasure> listReportMeasure() {
|
return preventRiskControlMeasureRepository.listReportMeasure();
|
}
|
/**
|
* 管控措施- 管控措施列表
|
*/
|
@Override
|
public List<PreventRiskControlMeasure> 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);
|
}
|
}
|
}
|
