package com.gkhy.safePlatform.specialWork.service.baseService.impl; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.gkhy.safePlatform.commons.enums.ResultCodes; import com.gkhy.safePlatform.commons.exception.BusinessException; import com.gkhy.safePlatform.commons.vo.ResultVO; import com.gkhy.safePlatform.commons.vo.SearchResultVO; import com.gkhy.safePlatform.specialWork.entity.ApprovalRuleUnit; import com.gkhy.safePlatform.specialWork.enums.RuleStatusEnum; import com.gkhy.safePlatform.specialWork.enums.RuleUnitStatusEnum; import com.gkhy.safePlatform.specialWork.model.query.db.ApprovalRuleUnitDbQuery; import com.gkhy.safePlatform.specialWork.repository.ApprovalRuleRepository; import com.gkhy.safePlatform.specialWork.repository.ApprovalRuleUnitRepository; import com.gkhy.safePlatform.specialWork.service.baseService.ApprovalRuleUnitService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import java.time.LocalDateTime; import java.util.List; @Service("ApprovalRuleUnitService") public class ApprovalRuleUnitServiceImpl extends ServiceImpl implements ApprovalRuleUnitService { @Autowired private ApprovalRuleUnitRepository approvalRuleUnitRepository; /** * 新增 * @param unit * @return */ @Override public int saveOneUnit(ApprovalRuleUnit unit) { unit.setStatus(RuleUnitStatusEnum.VALID.getCode()); unit.setGmtCreate(LocalDateTime.now()); return baseMapper.insert(unit); } /** * 修改 */ @Override public int updateOneUnit(ApprovalRuleUnit unit) { unit.setGmtModified(LocalDateTime.now()); return baseMapper.insert(unit); } /** * 批量更新 * @param unitList * @return */ @Override public int saveUnitList(List unitList) { return baseMapper.batchInsert(unitList); } @Override public List listByRuleStepId(Long stepId) { List unitList = baseMapper.listActiveByRuleStepId(stepId,RuleUnitStatusEnum.VALID.getCode()); return unitList; } /** * 根据stepIds获取 * @param stepId * @return */ @Override public List listUnitIdByStepId(Long stepId) { return baseMapper.listUnitIdByStepId(stepId,RuleUnitStatusEnum.VALID.getCode()); } @Override public int updateStatusByRuleStepId(Long stepId) { return baseMapper.updateStatusByRuleStepId(stepId,RuleUnitStatusEnum.ABANDONED.getCode()); } @Override public int updateStatusByStepIds(List stepIds) { return baseMapper.updateStatusByStepIds(stepIds,RuleUnitStatusEnum.ABANDONED.getCode()); } @Override public int updateStatusByRuleId(Long ruleId) { return baseMapper.updateStatusByRuleId(ruleId,RuleUnitStatusEnum.ABANDONED.getCode()); } /** * 根据规则ruleIds删除数据 * @param ruleIds * @return */ @Override public int updateStatusByRuleIds(List ruleIds) { return baseMapper.updateStatusByRuleIds(ruleIds,RuleUnitStatusEnum.ABANDONED.getCode()); } /** * 批量删除 * @param unitIds * @return */ @Override public int updateStatusByUnitIds(List unitIds) { return baseMapper.updateStatusByUnitIds(unitIds,RuleUnitStatusEnum.ABANDONED.getCode()); } /** * 根据规则id获取集合 * @param ruleId * @return */ @Override public List listByRuleId(Long ruleId) { return baseMapper.listActiveByRuleId(ruleId,RuleUnitStatusEnum.VALID.getCode()); } @Override public List listByConditions(ApprovalRuleUnitDbQuery query) { query.setStatus(RuleUnitStatusEnum.VALID.getCode()); return baseMapper.listByConditions(query); } @Override public List listApprovalUnitByRuleId(Long ruleId) { if (ruleId == null) { throw new BusinessException(ResultCodes.SERVER_PARAM_NULL); } return approvalRuleUnitRepository.selectList(new LambdaQueryWrapper() // 规则id .eq(ApprovalRuleUnit::getRuleId,ruleId) // 状态 .eq(ApprovalRuleUnit::getStatus,RuleUnitStatusEnum.VALID.getCode()) ); } @Override public List listByNoConditions() { return baseMapper.selectList(new LambdaQueryWrapper() .eq(ApprovalRuleUnit::getStatus,RuleUnitStatusEnum.VALID.getCode())); } }