package com.gk.hotwork.doublePrevention.service.baseService.impl; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.gk.hotwork.doublePrevention.repository.PreventTaskAndMeasureRepository; import com.gk.hotwork.Domain.Exception.E; import com.gk.hotwork.Domain.Exception.BusinessException; import com.gk.hotwork.doublePrevention.entity.PreventTaskAndMeasure; import com.gk.hotwork.doublePrevention.repository.param.PreventCheckResultParams; import com.gk.hotwork.doublePrevention.service.baseService.PreventTaskAndMeasureService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import java.util.List; @Service("PreventTaskMeasureService") public class PreventTaskAndMeasureServiceImpl extends ServiceImpl implements PreventTaskAndMeasureService { @Autowired private PreventTaskAndMeasureRepository preventTaskAndMeasureRepository; /** * 保存任务与措施的关联 * */ @Override public int saveTaskAndMeasure(PreventTaskAndMeasure taskAndMeasure) { int result = preventTaskAndMeasureRepository.insert(taskAndMeasure); return result; } /** * 以任务id为条件,重置管控措施与任务的关联 * */ @Override public void deleteTaskAndMeasureByTaskId(Long taskId) { preventTaskAndMeasureRepository.deleteTaskAndMeasureByTaskId(taskId); } /** * 以任务id为条件,查询 * */ @Override public List getListByTaskId(Long taskId) { return preventTaskAndMeasureRepository.getListByTaskId(taskId); } /** * 结果填报 * */ @Override public int updateCheckResult(PreventCheckResultParams checkResultParams) { int result = preventTaskAndMeasureRepository.updateCheckResult(checkResultParams); if (result < 1){ throw new BusinessException(E.UPDATE_FAIL, "排查结果填报失败"); } return result; } /** * 根绝任务id查找 * */ @Override public PreventTaskAndMeasure getTaskAndMeasureByTaskId(Long taskId) { return preventTaskAndMeasureRepository.getTaskAndMeasureByTaskId(taskId); } /** * 根绝任务id批量查找 * */ @Override public List getListByTaskIdByIdList(List taskIdLists) { return preventTaskAndMeasureRepository.getListByTaskIdByIdList(taskIdLists); } }