package com.gkhy.hazmat.system.service.impl; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.gkhy.hazmat.common.api.CommonPage; import com.gkhy.hazmat.common.constant.UserConstant; import com.gkhy.hazmat.common.domain.entity.SysUser; import com.gkhy.hazmat.common.enums.UserTypeEnum; import com.gkhy.hazmat.common.exception.ApiException; import com.gkhy.hazmat.common.utils.PageUtils; import com.gkhy.hazmat.common.utils.SecurityUtils; import com.gkhy.hazmat.system.domain.HzWarehouse; import com.gkhy.hazmat.system.mapper.HzWarehouseMapper; import com.gkhy.hazmat.system.service.HzWarehouseService; import org.springframework.stereotype.Service; import java.util.List; import java.util.Objects; /** *

* 仓库表 服务实现类 *

* * @author kzy * @since 2024-08-05 14:41:40 */ @Service public class HzWarehouseServiceImpl extends ServiceImpl implements HzWarehouseService { @Override public CommonPage selectWarehouseList(HzWarehouse warehouse) { SysUser currentUser= SecurityUtils.getLoginUser().getUser(); if(!currentUser.getUserType().equals(UserTypeEnum.SYSTEM_USER.getCode())){ warehouse.setCompanyId(currentUser.getCompanyId()); } PageUtils.startPage(); List warehouseList=baseMapper.selectWarehouseList(warehouse); return CommonPage.restPage(warehouseList); } @Override public HzWarehouse selectWarehouseById(Long warehouseId) { HzWarehouse warehouse= baseMapper.selectById(warehouseId); SysUser currentUser=SecurityUtils.getLoginUser().getUser(); if(currentUser.getUserType().equals(UserTypeEnum.SYSTEM_USER.getCode())){ return warehouse; }else if(!warehouse.getCompanyId().equals(currentUser.getCompanyId())){ throw new ApiException("无权限查看其它企业数据"); } return warehouse; } @Override public int insertWarehouse(HzWarehouse warehouse) { SysUser currentUser = SecurityUtils.getLoginUser().getUser(); warehouse.setCreateBy(currentUser.getUsername()); warehouse.setCompanyId(currentUser.getCompanyId()); if (!checkNameUnique(warehouse)) { throw new ApiException("仓库名称已存在"); } checkUserAllowed(null,currentUser); int row = baseMapper.insert(warehouse); if (row < 1) { throw new ApiException("新增仓库失败"); } return row; } @Override public int updateWarehouse(HzWarehouse warehouse) { if (!checkNameUnique(warehouse)) { throw new ApiException("仓库名称已存在"); } SysUser currentUser = SecurityUtils.getLoginUser().getUser(); checkUserAllowed(warehouse,currentUser); warehouse.setUpdateBy(currentUser.getUsername()); int row=baseMapper.updateById(warehouse); if(row<1){ throw new ApiException("更新仓库信息失败"); } return row; } public void checkUserAllowed(HzWarehouse warehouse, SysUser user) { if (user.getUserType().equals(UserTypeEnum.SYSTEM_USER.getCode())) { throw new ApiException("管理员不能操作"); } if(warehouse!=null){ if(!Objects.equals(user.getCompanyId(), warehouse.getCompanyId())){ throw new ApiException("无权限操作其他企业数据"); } } } @Override public int deleteWarehouseById(Long warehouseId) { HzWarehouse warehouse=baseMapper.selectById(warehouseId); if(warehouse==null){ throw new ApiException("仓库信息不存在"); } SysUser currentUser = SecurityUtils.getLoginUser().getUser(); checkUserAllowed(warehouse,currentUser); baseMapper.deleteWarehouseById(warehouseId); return 0; } @Override public boolean checkNameUnique(HzWarehouse warehouse) { Long warsehouseId=warehouse.getId()==null?-1L:warehouse.getId(); HzWarehouse wh= baseMapper.checkNameUnique(warehouse.getName(),warehouse.getCompanyId()); if(wh!=null&&wh.getId().longValue()!=warsehouseId.longValue()){ return UserConstant.NOT_UNIQUE; } return UserConstant.UNIQUE; } }