package com.ruoyi.project.tr.riskList.service.impl; import com.ruoyi.common.utils.DateUtils; import com.ruoyi.common.utils.text.Convert; import com.ruoyi.doublePrevention.vo.ResultVO; import com.ruoyi.project.tr.riskCheckPoint.mapper.RiskCheckPointMapper; import com.ruoyi.project.tr.riskEvaluationPlan.mapper.RiskEvaluationPlanMapper; import com.ruoyi.project.tr.riskList.domain.*; import com.ruoyi.project.tr.riskList.mapper.RiskListMapper; import com.ruoyi.project.tr.riskList.service.IRiskListService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import java.util.List; /** * 风险清单Service业务层处理 * * @author wm * @date 2020-05-07 */ @Service public class RiskListServiceImpl implements IRiskListService { @Autowired private RiskListMapper riskListMapper; @Autowired private RiskEvaluationPlanMapper riskEvaluationPlanMapper; @Autowired private RiskCheckPointMapper riskCheckPointMapper; /** * 查询风险清单 * * @param riskListId 风险清单ID * @return 风险清单 */ @Override public RiskList selectRiskListById(Long riskListId) { return riskListMapper.selectRiskListById(riskListId); } /** * 查询风险清单列表 * * @param riskList 风险清单 * @return 风险清单 */ @Override public List selectRiskListList(RiskList riskList) { return riskListMapper.selectRiskListList(riskList); } @Override public List selectRiskListByCrafts(RiskList riskList) { return riskListMapper.selectRiskListByCrafts(riskList); } @Override public List selectRiskListByDevice(RiskList riskList) { return riskListMapper.selectRiskListByDevice(riskList); } @Override public List selectRiskListByWork(RiskList riskList) { return riskListMapper.selectRiskListByWork(riskList); } /** * 新增风险清单 * * @param riskList 风险清单 * @return 结果 */ @Override public int insertRiskList(RiskList riskList) { riskList.setCreateTime(DateUtils.getNowDate()); return riskListMapper.insertRiskList(riskList); } /** * 修改风险清单 * * @param riskList 风险清单 * @return 结果 */ @Override public int updateRiskList(RiskList riskList) { riskList.setUpdateTime(DateUtils.getNowDate()); return riskListMapper.updateRiskList(riskList); } /** * 删除风险清单对象(删除时,连带删除,该风险清单下的评价计划,检查点) * * @param ids 需要删除的数据ID * @return 结果 */ @Transactional(rollbackFor = Exception.class) @Override public int deleteRiskListByIds(String ids) { String[] riskIds = Convert.toStrArray(ids); //确认都需要删除那些计划 List planList = riskEvaluationPlanMapper.selectRiskEvaluationPlanByRiskIds(riskIds); if (planList.size()>0){ String[] planIds = new String[planList.size()]; //批量删除计划 riskEvaluationPlanMapper.deleteRiskEvaluationPlanByIds(planList.toArray(planIds)); //根据计划id集合删除其下属的检查点 riskCheckPointMapper.deleteRiskCheckPointByPlanIds(planIds); } return riskListMapper.deleteRiskListByIds(riskIds); } /** * 删除风险清单信息 * * @param riskListId 风险清单ID * @return 结果 */ @Override public int deleteRiskListById(Long riskListId) { return riskListMapper.deleteRiskListById(riskListId); } /** * 获取风险清单信息 * * @param riskId 风险清单ID * @return 结果 */ @Override public RiskList getInfoByRiskId(String riskId) { return riskListMapper.getInfoByRiskId(riskId); } /** * 获取风险清单信息 */ @Override public RiskList getInfoByRiskListId(Long riskUnitId) { return riskListMapper.getInfoByRiskListId(riskUnitId); } @Override public List getRiskUnitLists() { return riskListMapper.getRiskUnitLists(); } @Override public RiskList getInfoByRiskListName(String riskListName) { return riskListMapper.getInfoByRiskListName(riskListName); } @Override public List getAllPlan() { int riskType =5; return riskListMapper.getAllPlan(riskType); } @Override public List listHazardSource() { return riskListMapper.listHazardSource(); } @Override public RiskList getInfoByRiskListNum(String hazardCode) { return riskListMapper.getInfoByRiskListNum(hazardCode); } }