package com.thhy.materials.modules.biz.spare.service.impl; import com.alibaba.nacos.api.utils.StringUtils; import com.thhy.general.common.BasicStatus; import com.thhy.general.config.SysUserInfo; import com.thhy.general.exception.BasicException; import com.thhy.general.utils.UserInfoUtils; import com.thhy.materials.modules.biz.spare.entity.Spare; import com.thhy.materials.modules.biz.spare.entity.SpareListVo; import com.thhy.materials.modules.biz.spare.mapper.SpareMapper; import com.thhy.materials.modules.biz.spare.service.SpareService; import org.apache.tomcat.jni.User; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import java.io.Serializable; import java.util.Date; import java.util.List; /** * 服务实现类 * @author zhang_xiao_bo * @since 2023-04-11 16:07:53 */ @Service public class SpareServiceImpl implements SpareService { @Autowired private SpareMapper spareMapper; public Spare get(Serializable id){ return spareMapper.queryById(id); } public List findList(Spare spare){ SysUserInfo userInfo = UserInfoUtils.getInstance().getUserInfo(); return spareMapper.findList(spare.setCompanyId(userInfo.getCompanyId())); } @Override public List findListForExport(Spare spare,String token) { SysUserInfo userInfo = UserInfoUtils.getInstance().getUserInfo(token); return spareMapper.findList(spare.setCompanyId(userInfo.getCompanyId())); } /** * 增加和修改 * @param spare */ @Transactional public void addSpare(Spare spare){ SysUserInfo userInfo = UserInfoUtils.getInstance().getUserInfo(); if(spare.getSpareId() == null){ //增加操作 int count = spareMapper.countBySpareNum(spare.getSpareNum()); if(count>0){ throw new BasicException(BasicStatus.SPARE_NUM_IS_EXIST); } spare.setCompanyId(userInfo.getCompanyId()); spareMapper.insert(spare); }else{ //修改操作 String spareId = spareMapper.querySpareIdByNum(spare.getSpareNum()); if(!StringUtils.isEmpty(spareId)&&!spareId.equals(spare.getSpareId())){ throw new BasicException(BasicStatus.SPARE_NUM_IS_EXIST); } spare.setUpdateTime(new Date()); spareMapper.update(spare); } } /** * 修改 * @param spare */ public void update(Spare spare){ spareMapper.update(spare); } /** * 删除 * @param spareId */ public void delete(Serializable spareId){ spareMapper.deletelogic(spareId); } }