package com.ruoyi.project.tr.baseCheckPoint.service.impl;
|
|
import java.util.List;
|
import com.ruoyi.common.utils.DateUtils;
|
import com.ruoyi.doublePrevention.entity.PreventRiskCheckUnit;
|
import com.ruoyi.doublePrevention.enums.ErrorCodes;
|
import com.ruoyi.doublePrevention.repository.PreventRiskCheckUnitRepository;
|
import com.ruoyi.doublePrevention.service.baseService.PreventRiskCheckUnitService;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import com.ruoyi.project.tr.baseCheckPoint.mapper.BaseCheckPointMapper;
|
import com.ruoyi.project.tr.baseCheckPoint.domain.BaseCheckPoint;
|
import com.ruoyi.project.tr.baseCheckPoint.service.IBaseCheckPointService;
|
import com.ruoyi.common.utils.text.Convert;
|
import org.springframework.transaction.annotation.Transactional;
|
|
/**
|
* 基础清单检查点Service业务层处理
|
*
|
* @author wm
|
* @date 2020-07-21
|
*/
|
@Service
|
public class BaseCheckPointServiceImpl implements IBaseCheckPointService
|
{
|
@Autowired
|
private BaseCheckPointMapper baseCheckPointMapper;
|
|
@Autowired
|
private PreventRiskCheckUnitRepository riskCheckUnitRepository;
|
|
/**
|
* 查询基础清单检查点
|
*
|
* @param checkPointId 基础清单检查点ID
|
* @return 基础清单检查点
|
*/
|
@Override
|
public BaseCheckPoint selectBaseCheckPointById(Long checkPointId)
|
{
|
return baseCheckPointMapper.selectBaseCheckPointById(checkPointId);
|
}
|
|
/**
|
* 查询基础清单检查点列表
|
*
|
* @param baseCheckPoint 基础清单检查点
|
* @return 基础清单检查点
|
*/
|
@Override
|
public List<BaseCheckPoint> selectBaseCheckPointList(BaseCheckPoint baseCheckPoint)
|
{
|
return baseCheckPointMapper.selectBaseCheckPointList(baseCheckPoint);
|
}
|
|
/**
|
* 新增基础清单检查点
|
*
|
* @param baseCheckPoint 基础清单检查点
|
* @return 结果
|
*/
|
@Override
|
public int insertBaseCheckPoint(BaseCheckPoint baseCheckPoint)
|
{
|
baseCheckPoint.setCreateTime(DateUtils.getNowDate());
|
return baseCheckPointMapper.insertBaseCheckPoint(baseCheckPoint);
|
}
|
|
/**
|
* 修改基础清单检查点
|
*
|
* @param baseCheckPoint 基础清单检查点
|
* @return 结果
|
*/
|
@Override
|
@Transactional
|
public int updateBaseCheckPoint(BaseCheckPoint baseCheckPoint)
|
{
|
baseCheckPoint.setUpdateTime(DateUtils.getNowDate());
|
baseCheckPointMapper.updateBaseCheckPoint(baseCheckPoint);
|
|
//todo-2022 对措施与检查点关联的措施id进行修改
|
PreventRiskCheckUnit riskCheckUnit = riskCheckUnitRepository.getPointAndMeasureByPointId(baseCheckPoint.getCheckPointId());
|
if (riskCheckUnit == null){
|
throw new RuntimeException("查询不到对应的措施");
|
}
|
|
riskCheckUnit.setControlMeasureId(baseCheckPoint.getControlMeasureId());
|
int riskCheckUnitUpdateResult = riskCheckUnitRepository.updateRiskCheckUnitById(riskCheckUnit);
|
return riskCheckUnitUpdateResult;
|
}
|
|
/**
|
* 删除基础清单检查点对象
|
*
|
* @param ids 需要删除的数据ID
|
* @return 结果
|
*/
|
@Override
|
@Transactional
|
public int deleteBaseCheckPointByIds(String ids)
|
{
|
baseCheckPointMapper.deleteBaseCheckPointByIds(Convert.toStrArray(ids));
|
|
//todo-2022 对措施与检查点关联的表根据原检查点id进行批量删除
|
int deletePointAndMeasureResult = riskCheckUnitRepository.deleteRiskCheckUnitByCheckPointIds(Convert.toStrArray(ids));
|
return deletePointAndMeasureResult;
|
}
|
|
/**
|
* 删除基础清单检查点信息
|
*
|
* @param checkPointId 基础清单检查点ID
|
* @return 结果
|
*/
|
@Override
|
public int deleteBaseCheckPointById(Long checkPointId)
|
{
|
return baseCheckPointMapper.deleteBaseCheckPointById(checkPointId);
|
}
|
}
|
