package org.jeecg.modules.eam.service.impl; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import org.apache.commons.lang3.StringUtils; import org.apache.shiro.SecurityUtils; import org.jeecg.common.constant.CommonConstant; import org.jeecg.common.constant.DataBaseConstant; import org.jeecg.common.exception.JeecgBootException; import org.jeecg.common.system.vo.LoginUser; import org.jeecg.common.util.oConvertUtils; import org.jeecg.modules.eam.constant.AssetStatusEnum; import org.jeecg.modules.eam.constant.EquipmentLeanOutStatusEnum; import org.jeecg.modules.eam.entity.EamEquipment; import org.jeecg.modules.eam.entity.EamEquipmentLeanOut; import org.jeecg.modules.eam.mapper.EamEquipmentLeanOutMapper; import org.jeecg.modules.eam.request.EamEquipmentLeanOutQuery; import org.jeecg.modules.eam.service.IEamEquipmentLeanOutService; import org.jeecg.modules.eam.service.IEamEquipmentService; import org.jeecg.modules.system.service.IMdcProductionService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import javax.annotation.Resource; import java.util.Arrays; import java.util.List; /** * @Description: 设备借出归还 * @Author: jeecg-boot * @Date: 2025-05-13 * @Version: V1.0 */ @Service public class EamEquipmentLeanOutServiceImpl extends ServiceImpl implements IEamEquipmentLeanOutService { @Resource private EamEquipmentLeanOutMapper equipmentLeanOutMapper; @Autowired private IEamEquipmentService eamEquipmentService; @Autowired private IMdcProductionService mdcProductionService; @Override public IPage queryPageList(Page page, EamEquipmentLeanOutQuery query) { QueryWrapper queryWrapper = new QueryWrapper<>(); //用户数据权限 LoginUser sysUser = (LoginUser) SecurityUtils.getSubject().getPrincipal(); if (sysUser == null) { return page; } if (StringUtils.isNotBlank(sysUser.getEquipmentIds())) { //选择了设备，根据设备id过滤设备 List equipArr = Arrays.asList(sysUser.getEquipmentIds().split(",")); queryWrapper.in("e.equipment_code", equipArr); } else { //没有选择设备，根据车间过滤设备 queryWrapper.exists("select 1 from mdc_user_production t where t.user_id={0} and t.pro_id=e.org_id ", sysUser.getId()); } //控制待提交状态的数据只能本人查看 queryWrapper.and(i -> i.ne("wmo.lean_status", EquipmentLeanOutStatusEnum.WAIT_SUBMIT).or().eq("wmo.lean_person", sysUser.getUsername())); //查询条件过滤 if (query != null) { if (StringUtils.isNotBlank(query.getEquipmentId())) { queryWrapper.eq("wmo.equipment_id", query.getEquipmentId()); } if (StringUtils.isNotBlank(query.getCode())) { queryWrapper.like("wmo.code", query.getCode()); } if (StringUtils.isNotBlank(query.getLeanStatus())) { queryWrapper.eq("wmo.lean_status", query.getLeanStatus()); } if (query.getLeanDateBegin() != null && query.getLeanDateEnd() != null) { queryWrapper.between("wmo.lean_start_time", query.getLeanDateBegin(), query.getLeanDateEnd()); } //排序 if (StringUtils.isNotBlank(query.getColumn()) && StringUtils.isNotBlank(query.getOrder())) { String column = query.getColumn(); if (column.endsWith(CommonConstant.DICT_TEXT_SUFFIX)) { column = column.substring(0, column.lastIndexOf(CommonConstant.DICT_TEXT_SUFFIX)); } if (DataBaseConstant.SQL_ASC.equalsIgnoreCase(query.getOrder())) { queryWrapper.orderByAsc("wmo." + oConvertUtils.camelToUnderline(column)); } else { queryWrapper.orderByDesc("wmo." + oConvertUtils.camelToUnderline(column)); } } else { queryWrapper.orderByDesc("wmo.create_time"); } } else { queryWrapper.orderByDesc("wmo.create_time"); } return equipmentLeanOutMapper.queryPageList(page, queryWrapper); } @Override @Transactional(rollbackFor = Exception.class) public boolean addLeanOut(EamEquipmentLeanOut request) { //检查设备 EamEquipment equipment = eamEquipmentService.getById(request.getEquipmentId()); if (equipment == null) { throw new JeecgBootException("设备不存在！"); } if (!AssetStatusEnum.NORMAL.name().equals(equipment.getAssetStatus())) { throw new JeecgBootException("此设备当前资产状态不允许借出！"); } if (StringUtils.isBlank(request.getLeanDepartId())) { throw new JeecgBootException("借入车间不允许为空！"); } if (request.getLeanDepartId().equals(equipment.getOrgId())) { throw new JeecgBootException("当前设备属于此车间，不需要借用！"); } LoginUser sysUser = (LoginUser) SecurityUtils.getSubject().getPrincipal(); if (sysUser == null) { throw new JeecgBootException("当前用户无法添加借用记录！"); } request.setLeanPerson(sysUser.getUsername()); return equipmentLeanOutMapper.insert(request) > 0; } @Override @Transactional(rollbackFor = Exception.class) public boolean editLeanOut(EamEquipmentLeanOut request) { EamEquipmentLeanOut entity = equipmentLeanOutMapper.selectById(request.getId()); if (entity == null) { throw new JeecgBootException("要编辑的数据不存在，请刷新重试！"); } if(!EquipmentLeanOutStatusEnum.WAIT_SUBMIT.name().equals(entity.getLeanStatus())) { throw new JeecgBootException("当前数据状态不允许编辑！"); } //检查设备 EamEquipment equipment = eamEquipmentService.getById(request.getEquipmentId()); if (equipment == null) { throw new JeecgBootException("设备不存在！"); } if (!AssetStatusEnum.NORMAL.name().equals(equipment.getAssetStatus())) { throw new JeecgBootException("此设备当前资产状态不允许借出！"); } if (StringUtils.isBlank(request.getLeanDepartId())) { throw new JeecgBootException("借入车间不允许为空！"); } if (request.getLeanDepartId().equals(equipment.getOrgId())) { throw new JeecgBootException("当前设备属于此车间，不需要借用！"); } LoginUser sysUser = (LoginUser) SecurityUtils.getSubject().getPrincipal(); if (sysUser == null) { throw new JeecgBootException("当前用户无法编辑借用记录！"); } UpdateWrapper updateWrapper = new UpdateWrapper<>(); updateWrapper.set("equipment_id", request.getEquipmentId()); updateWrapper.set("lean_depart_id", request.getLeanDepartId()); updateWrapper.set("remark", request.getRemark()); updateWrapper.set("lean_reason", request.getLeanReason()); updateWrapper.eq("id", request.getId()); updateWrapper.eq("lean_person", sysUser.getUsername()); return super.update(updateWrapper); } @Override @Transactional(rollbackFor = Exception.class) public boolean submit(String id) { EamEquipmentLeanOut entity = equipmentLeanOutMapper.selectById(id); if (entity == null) { throw new JeecgBootException("要提交的数据不存在，请刷新重试！"); } if(!EquipmentLeanOutStatusEnum.WAIT_SUBMIT.name().equals(entity.getLeanStatus())) { throw new JeecgBootException("当前数据状态不允许编辑！"); } //检查设备 EamEquipment equipment = eamEquipmentService.getById(entity.getEquipmentId()); if (equipment == null) { throw new JeecgBootException("设备不存在！"); } if (!AssetStatusEnum.NORMAL.name().equals(equipment.getAssetStatus())) { throw new JeecgBootException("此设备当前资产状态不允许借出！"); } LoginUser sysUser = (LoginUser) SecurityUtils.getSubject().getPrincipal(); if (sysUser == null) { throw new JeecgBootException("当前用户无法编辑借用记录！"); } UpdateWrapper updateWrapper = new UpdateWrapper<>(); updateWrapper.set("lean_status", EquipmentLeanOutStatusEnum.WAIT_APPROVAL.name()); updateWrapper.eq("id", id); updateWrapper.eq("lean_person", sysUser.getUsername()); boolean success = super.update(updateWrapper); if(success) { equipment.setAssetStatus(AssetStatusEnum.LEAN_OUT.name()); eamEquipmentService.updateById(equipment); } //启动审批流程 TODO return true; } }