package doumeemes.service.ext.impl; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import doumeemes.core.constants.ResponseStatus; import doumeemes.core.exception.BusinessException; import doumeemes.core.model.LoginUserInfo; import doumeemes.core.model.PageData; import doumeemes.core.model.PageWrap; import doumeemes.core.utils.Constants; import doumeemes.core.utils.DateUtil; import doumeemes.core.utils.excel.EasyExcelUtil; import doumeemes.dao.business.WTransferDetailMapper; import doumeemes.dao.business.WarehouseLocationMapper; import doumeemes.dao.business.dto.WStockImportDTO; import doumeemes.dao.business.model.*; import doumeemes.dao.ext.*; import doumeemes.dao.ext.beanDto.QueryWStockDto; import doumeemes.dao.ext.beanDto.QueryWStockHeadNewDTO; import doumeemes.dao.ext.beanDto.QueryWStockNewDTO; import doumeemes.dao.ext.dto.*; import doumeemes.dao.ext.vo.*; import doumeemes.service.ext.ProceduresExtService; import doumeemes.service.ext.WStockExtService; import com.github.pagehelper.PageHelper; import com.github.pagehelper.PageInfo; import org.apache.commons.lang3.StringUtils; import org.apache.shiro.SecurityUtils; import org.apache.shiro.util.CollectionUtils; import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import org.springframework.web.multipart.MultipartFile; import java.math.BigDecimal; import java.util.ArrayList; import java.util.List; import java.util.Objects; /** * 物料库存余额信息Service实现 * @author 江蹄蹄 * @date 2022/04/20 10:56 */ @Service public class WStockExtServiceImpl implements WStockExtService { @Autowired private WStockExtMapper wStockExtMapper; @Autowired private MaterialDistributeExtMapper materialDistributeExtMapper; @Autowired private WarehouseExtMapper warehouseExtMapper; @Autowired private WarehouseLocationMapper warehouseLocationMapper; @Autowired private AppliancesExtMapper appliancesExtMapper; @Autowired private BomDetailExtMapper bomDetailExtMapper; @Autowired private BomExtMapper bomExtMapper; @Autowired private ProceduresExtService proceduresExtService; @Autowired private WTransferDetailExtMapper wTransferDetailExtMapper; @Override public PageData findPage(PageWrap pageWrap) { PageHelper.startPage(pageWrap.getPage(), pageWrap.getCapacity()); List result = wStockExtMapper.selectListAll(pageWrap.getModel()); return PageData.from(new PageInfo<>(result)); } @Override public List getListBynum(QueryWStockExtDTO pageWrap) { List result = wStockExtMapper.selectListAll(pageWrap); return result; } @Override public PageData findListPage(PageWrap pageWrap) { LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); if(!Constants.equalsInteger(user.getType(),Constants.USERTYPE.COM)){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "对不起，您无权限进行该操作！"); } //只能查看当前根组织的数据 pageWrap.getModel().setRootDepartId(user.getRootDepartment().getId()); // if(!Constants.equalsInteger(user.getCurComDepartment().getId(),user.getRootDepartment().getId())){ //如果当前选择的公司级组织非根组织信息，只能查看当前选择公司级组织数据 pageWrap.getModel().setDepartId(user.getCurComDepartment().getId()); // } PageHelper.startPage(pageWrap.getPage(), pageWrap.getCapacity()); List result = wStockExtMapper.selectAdminList(pageWrap.getModel()); return PageData.from(new PageInfo<>(result)); } @Override public PageData choiceStockListPage(PageWrap pageWrap) { PageHelper.startPage(pageWrap.getPage(), pageWrap.getCapacity()); if(!Objects.isNull(pageWrap.getModel().getWarehouseQualityType())){ Constants.wareHouse_QualityType w = Constants.wareHouse_QualityType.checkEnum(pageWrap.getModel().getWarehouseQualityType()); if(w.getType()==3){ pageWrap.getModel().setWarehouseQualityType(null); }else{ pageWrap.getModel().setWarehouseQualityType(w.getType().toString()); } } List result = wStockExtMapper.choiceStockList(pageWrap.getModel()); return PageData.from(new PageInfo<>(result)); } @Override public PageData choiceStockPageByTransfer(PageWrap pageWrap) { List wTransferDetailList = wTransferDetailExtMapper.wTransferDetailListById(pageWrap.getModel().getTransferId()); if(Objects.isNull(wTransferDetailList)||wTransferDetailList.size()==Constants.ZERO){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"未查询到转库单明细信息"); } List stockNewDTOList = new ArrayList<>(); for (WTransferDetail wTransferDetail:wTransferDetailList) { QueryWStockNewDTO queryWStockNewDTO = new QueryWStockNewDTO(); BeanUtils.copyProperties(wTransferDetail,queryWStockNewDTO); stockNewDTOList.add(queryWStockNewDTO); } pageWrap.getModel().setStockNewDTOList(stockNewDTOList); PageHelper.startPage(pageWrap.getPage(), pageWrap.getCapacity()); List result = wStockExtMapper.choiceStockPageByTransfer(pageWrap.getModel()); return PageData.from(new PageInfo<>(result)); } /** * 库存是否满足计划 * @param p * @return */ @Override public Integer isStockForPlan(PlansExtListVO p){ LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); QueryBomDetailExtDTO bdparam = initBomParam(user,p); ProceduresExtListVO pModel = proceduresExtService.getById(user.getCompany().getId(),p.getProcedureId()); if(pModel==null){ return 0; } //待分配(计划数量-已分配未报工数量-合格数量-不良数量) int tNum = p.getNum() - p.getDistributNum(); QueryWStockExtDTO stock = new QueryWStockExtDTO(); stock.setDeleted(Constants.ZERO); stock.setRootDepartId(p.getRootDepartId()); stock.setWarehouseId(pModel.getPickingWarehouseId()); if(bdparam==null){ //如果没有配置BOM，则投料本身 stock.setMaterialId(p.getMaterialId()); //查询库存记录 List stockList = wStockExtMapper.selectAllList( stock); if(stockList!=null && stockList.size()>0 &&Constants.formatBigdecimal(stockList.get(0).getNum()).compareTo(new BigDecimal(tNum)) >=0){ //如果库存不足 return 1; } }else{ //查询bom明细 List bomDetailList = bomDetailExtMapper.selectList(bdparam); if(!CollectionUtils.isEmpty(bomDetailList) ){ stock.setMaterialIds(getMaterialIds(bomDetailList)); } //查询库存记录 List stockList = wStockExtMapper.selectAllList( stock); boolean isFull = true; for (BomDetailExtListVO i : bomDetailList) { //遍历查询库存是否满足 BigDecimal sNum =getStockByMaterialId(i.getMaterialId(),stockList); //所需要库存量 BigDecimal needNum = Constants.formatBigdecimal(i.getNum()).multiply(new BigDecimal(tNum)); if( sNum.compareTo(needNum) <0){ //如果库存不足 isFull =false; break; } } return isFull?1:0; } return 0; } private BigDecimal getStockByMaterialId(Integer materialId, List stockList) { BigDecimal num = new BigDecimal(0); if(stockList!=null){ for(WStockExtListVO s : stockList){ if(Constants.equalsInteger(s.getMaterialId(),materialId)){ num.add(Constants.formatBigdecimal(s.getNum())); } } } return num; } private List getMaterialIds(List bomDetailList) { if(CollectionUtils.isEmpty(bomDetailList) ){ return null; } List list = new ArrayList<>(); bomDetailList. forEach(i->{ //判断当前状态，根据状态获取明细记录 若是已取消业务，查询 0 list.add(i.getMaterialId()); }); return list; } private QueryBomDetailExtDTO initBomParam(LoginUserInfo user, PlansExtListVO mp) throws BusinessException{ QueryBomExtDTO bb = new QueryBomExtDTO(); bb.setDepartId(mp.getDepartId()); bb.setDeleted(Constants.ZERO); bb.setRootDepartId(user.getRootDepartment().getId()); bb.setMaterialId(mp.getMaterialId()); bb.setProcedureId(mp.getProcedureId()); BomExtListVO versionBom = bomExtMapper.selectByModel( bb); if(versionBom == null || StringUtils.isBlank(versionBom.getVersion()) || versionBom.getBomVersionId() == null){ return null; } QueryBomDetailExtDTO bom = new QueryBomDetailExtDTO(); bom.setDeleted(Constants.ZERO); bom.setBomId(versionBom.getBomVersionId()); bom.setWorkorderId(mp.getId()); return bom; } @Transactional(rollbackFor = {BusinessException.class,Exception.class}) @Override public String importStock(MultipartFile file) { LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal(); if(!Constants.equalsInteger(user.getType(),Constants.USERTYPE.COM)){ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "对不起，您无权限进行该操作！"); } //解析excel List list = EasyExcelUtil.importExcel(file, 1, 1, WStockImportDTO.class); if(list == null || list.size()==0){ throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(), "导入数据内容有误！"); } String msg = ""; int index = 1; for(WStockImportDTO p : list){ WStock stock = new WStock(); stock.setDeleted(Constants.ZERO); stock.setRootDepartId(user.getRootDepartment().getId()); stock.setBatch(p.getBatch()); stock.setNum(p.getNum()); Appliances appliances = new Appliances(); appliances.setUpdateTime(DateUtil.getCurrentDate()); appliances.setUpdateUser(user.getId()); appliances.setNum(p.getNum()); appliances.setBatch(p.getBatch()); //检查数据有效性 String code = checkData(p,stock,appliances,index,user); if(StringUtils.isNotBlank(code)){ //如果有篮筐不为空，提示信息有修改 msg += "【"+code+"】"; } if(stock.getId()!=null){ stock.setUpdateTime(DateUtil.getCurrentDate()); stock.setUpdateUser(user.getId()); wStockExtMapper.updateById(stock); }else{ stock.setCreateTime(DateUtil.getCurrentDate()); stock.setCreateUser(user.getId()); wStockExtMapper.insert(stock); } appliancesExtMapper.updateById(appliances); index++; } if(StringUtils.isNotBlank(msg)){ msg = "你好，部分数据导入成功！其中篮筐"+msg+"非空篮筐，导入不成功！"; }else{ msg = "全部导入成功！"; } return msg; } /** * 数据有效性检查 * @param p * @param index * @param user * @throws BusinessException */ private String checkData(WStockImportDTO p, WStock stock, Appliances appliances ,int index,LoginUserInfo user) throws BusinessException{ if(Constants.formatBigdecimal(p.getNum()).compareTo(new BigDecimal(0)) != 1){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对不起，第【"+(index+2)+"】行【物料数量】数据错误！"); } if(p.getApplianceCode() == null){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对不起，第【"+(index+2)+"】行【物料编码】数据错误"); } if(StringUtils.isBlank(p.getMaterialCode())){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对不起，第【"+(index+2)+"】行【物料编码】数据错误！"); } if(StringUtils.isBlank(p.getWarehouse())){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对不起，第【"+(index+2)+"】行【仓库名称】数据错误！"); } p.setApplianceCode(p.getApplianceCode().trim()); p.setMaterialCode(p.getMaterialCode().trim()); p.setWarehouse(p.getWarehouse().trim()); Appliances a = new Appliances(); a.setDeleted(Constants.ZERO); a.setCode(p.getApplianceCode()); a.setRootDepartId(user.getRootDepartment().getId()); a.setDepartId(user.getCurComDepartment().getId()); //查询篮筐信息 a = appliancesExtMapper.selectOne(new QueryWrapper<>(a)); if(a == null){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对不起，第【"+(index+2)+"】行【篮筐编码】数据不存在！"); } if(!Constants.equalsInteger(a.getStatus(),Constants.APPLIANCES_STATUS.empty)){ return p.getApplianceCode() ; } Warehouse w = new Warehouse(); w.setDeleted(Constants.ZERO); w.setName(p.getWarehouse()); w.setRootDepartId(user.getRootDepartment().getId()); w.setDepartId(user.getCurComDepartment().getId()); //查询篮筐信息 w = warehouseExtMapper.selectOne(new QueryWrapper<>(w)); if(w == null){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对不起，第【"+(index+2)+"】行【仓库名称】数据不存在！"); } stock.setWarehouseId(w.getId()); if(StringUtils.isNotBlank(p.getLocation())){ p.setLocation(p.getLocation().trim()); WarehouseLocation l = new WarehouseLocation(); l.setDeleted(Constants.ZERO); l.setWarehouseId(w.getId()); l.setUnionName(p.getLocation()); l.setRootDepartId(user.getRootDepartment().getId()); //查询篮筐信息 l = warehouseLocationMapper.selectOne(new QueryWrapper<>(l)); if(l == null || !Constants.equalsInteger(l.getWarehouseId(),w.getId())){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对不起，第【"+(index+2)+"】行【库位名称】数据不存在!！"); } stock.setLocationId(l.getId()); appliances.setLocationId(l.getId()); } QueryMaterialDistributeExtDTO d = new QueryMaterialDistributeExtDTO(); d.setDeleted(Constants.ZERO); d.setMmodelCode(p.getMaterialCode()); d.setRootDepartId(user.getRootDepartment().getId()); d.setDepartId(user.getCurComDepartment().getId()); //查询产品信息 MaterialDistributeExtListVO mm = materialDistributeExtMapper.selectByModel(d); if(mm == null){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对不起，第【"+(index+2)+"】行【产品编码】数据不存在！"); } //存储物料分配表主键 stock.setMaterialId(mm.getId()); //单位编码 stock.setUnitId(mm.getUnitId()); appliances.setMaterialId(mm.getId()); appliances.setUnitId(mm.getUnitId()); appliances.setPositionType(Constants.APPLIANCES_POSITION.warehouse); appliances.setStatus(Constants.APPLIANCES_STATUS.full); appliances.setId(a.getId()); appliances.setWarehouseId(w.getId()); WStock s1 = new WStock(); s1.setLocationId(stock.getLocationId()); s1.setWarehouseId(stock.getWarehouseId()); s1.setDeleted(Constants.ZERO); s1.setMaterialId(stock.getMaterialId()); s1.setBatch(stock.getBatch()); s1 = wStockExtMapper.selectOne(new QueryWrapper<>(s1)); if(s1 !=null){ stock.setId(s1.getId()); stock.setNum(Constants.formatBigdecimal(s1.getNum()).add(stock.getNum())); } return null; } }