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.commons.utils.idService.BusinessCodeEnum; import com.gkhy.safePlatform.doublePrevention.entity.PreventDangerCheckTaskUnit; import com.gkhy.safePlatform.doublePrevention.entity.dto.req.PreventDangerCheckTaskUnitQueryReqDTO; import com.gkhy.safePlatform.doublePrevention.repository.PreventDangerCheckTaskUnitRepository; import com.gkhy.safePlatform.doublePrevention.repository.param.PreventDangerCheckTaskUnitDeleteParams; import com.gkhy.safePlatform.doublePrevention.repository.param.PreventDangerCheckTaskUnitUpdateParams; import com.gkhy.safePlatform.doublePrevention.service.baseService.PreventDangerCheckTaskUnitService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import java.util.List; @Service("PreventDangerCheckTaskUnitService") public class PreventDangerCheckTaskUnitServiceImpl extends ServiceImpl implements PreventDangerCheckTaskUnitService { @Autowired private PreventDangerCheckTaskUnitRepository preventDangerCheckTaskUnitRepository; /** * 隐患排查任务单元-分页查询 */ @Override public IPage getTaskUnitPage(Page page, PreventDangerCheckTaskUnitQueryReqDTO taskUnitQueryReqDTO) { return preventDangerCheckTaskUnitRepository.getTaskUnitPage(page, taskUnitQueryReqDTO); } /** * 隐患排查任务单元-通过名称查询单元信息 */ @Override public PreventDangerCheckTaskUnit getTaskUnitByName(String taskUnitName) { return preventDangerCheckTaskUnitRepository.getTaskUnitByName(taskUnitName); } /** * 隐患排查任务单元-新增 */ @Override public int saveTaskUnit(PreventDangerCheckTaskUnit taskUnit) { int insertResult = preventDangerCheckTaskUnitRepository.insert(taskUnit); if (insertResult == 0){ throw new BusinessException(ResultCodes.SERVER_ADD_ERROR); } return insertResult; } /** * 隐患排查任务单元-修改 */ @Override public int updateTaskUnit(PreventDangerCheckTaskUnitUpdateParams updateParams) { int i = preventDangerCheckTaskUnitRepository.updateTaskUnit(updateParams); if (i == 0) { throw new BusinessException(ResultCodes.SERVER_UPDATE_ERROR); } return i; } /** * 隐患排查任务单元-删除 */ @Override public int deleteTaskUnit(PreventDangerCheckTaskUnitDeleteParams deleteParams) { int i = preventDangerCheckTaskUnitRepository.deleteTaskUnit(deleteParams); if (i == 0) { throw new BusinessException(ResultCodes.SERVER_UPDATE_ERROR); } return i; } /** * 隐患排查任务单元- * 根据名称修改关联作业id */ @Override public PreventDangerCheckTaskUnit updateWorkIdByUnitName(String taskUnitName, Long checkWorkId) { return preventDangerCheckTaskUnitRepository.updateWorkIdByUnitName(taskUnitName, checkWorkId); } /** * 隐患排查任务单元- * 根据workId 查询 */ @Override public PreventDangerCheckTaskUnit getTaskUnitByWorkId(Long workId) { return preventDangerCheckTaskUnitRepository.getTaskUnitByWorkId(workId); } /** * 隐患排查任务单元-重置关联任务单元workId * 根据taskUnitName */ @Override public void deleteWorkIdByUnitName(String taskUnitName) { int result = preventDangerCheckTaskUnitRepository.deleteWorkIdByUnitName(taskUnitName); if (result == 0) { throw new BusinessException(ResultCodes.SERVER_UPDATE_ERROR); } } /** * 隐患排查任务单元-根据Id查询 */ @Override public PreventDangerCheckTaskUnit getTaskUnitById(Long id) { return preventDangerCheckTaskUnitRepository.getTaskUnitById(id); } /** * 隐患排查任务单元- * 根据unitId 修改 workId */ @Override public void updateWorkIdByUnitId(Long taskUnitId, Long checkWorkId , String checkWorkUuid) { preventDangerCheckTaskUnitRepository.updateWorkIdByUnitId(taskUnitId, checkWorkId ,checkWorkUuid); } /** * 隐患作业id,重置与任务单元的关联 */ @Override public void deleteByWorkId(Long workId) { int result = preventDangerCheckTaskUnitRepository.deleteByWorkId(workId); if (result == 0) { throw new BusinessException(ResultCodes.SERVER_UPDATE_ERROR); } } /** * 隐患排查任务单元-任务单元列表 */ @Override public List listTaskUnit() { return preventDangerCheckTaskUnitRepository.listTaskUnit(); } }