/*
|
* Copyright (c) 2018-2025, ztt All rights reserved.
|
*
|
* Redistribution and use in source and binary forms, with or without
|
* modification, are permitted provided that the following conditions are met:
|
*
|
* Redistributions of source code must retain the above copyright notice,
|
* this list of conditions and the following disclaimer.
|
* Redistributions in binary form must reproduce the above copyright
|
* notice, this list of conditions and the following disclaimer in the
|
* documentation and/or other materials provided with the distribution.
|
* Neither the name of the pig4cloud.com developer nor the names of its
|
* contributors may be used to endorse or promote products derived from
|
* this software without specific prior written permission.
|
* Author: ztt
|
*/
|
package com.chinaztt.mes.warehouse.service.impl;
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.chinaztt.mes.warehouse.dto.PrepareDetailDTO;
|
import com.chinaztt.mes.warehouse.dto.ReserveMainDTO;
|
import com.chinaztt.mes.warehouse.entity.*;
|
import com.chinaztt.mes.warehouse.mapper.*;
|
import com.chinaztt.mes.warehouse.service.PrepareDetailService;
|
import com.chinaztt.mes.warehouse.util.StockUtils;
|
import com.chinaztt.ztt.common.core.util.R;
|
import lombok.AllArgsConstructor;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.math.BigDecimal;
|
import java.time.LocalDateTime;
|
import java.util.List;
|
|
/**
|
* 备料明细表
|
*
|
* @author sunxl
|
* @date 2020-10-16 09:44:10
|
*/
|
@AllArgsConstructor
|
@Transactional(rollbackFor = Exception.class)
|
@Service
|
public class PrepareDetailServiceImpl extends ServiceImpl<PrepareDetailMapper, PrepareDetail> implements PrepareDetailService {
|
private ReserveDetailMapper reserveDetailMapper;
|
private StockMapper stockMapper;
|
private StockUtils stockUtils;
|
private PrepareDetailMapper prepareDetailMapper;
|
private ReserveMainMapper reserveMainMapper;
|
private StockInCodeMapper stockInCodeMapper;
|
|
@Override
|
public boolean fullDelete(Long id) {
|
//将删除的数据先拿出来
|
PrepareDetail prepareDetail = baseMapper.selectById(id);
|
//获取对应实时库存的数据
|
Stock stock = stockMapper.selectOne(Wrappers.<Stock>lambdaQuery().eq(Stock::getPartId, prepareDetail.getPartId())
|
.eq(Stock::getLocationId, prepareDetail.getLocationId()).eq(Stock::getPartBatchNo, prepareDetail.getPartBatchNo()).eq(Stock::getSystemNo,prepareDetail.getSystemNo()));
|
//关于id删除
|
baseMapper.deleteById(id);
|
//从数据库取出与这个备料关联的申请零件明细的数据
|
ReserveDetail reserveDetail = reserveDetailMapper.selectOne(Wrappers.<ReserveDetail>lambdaQuery()
|
.eq(ReserveDetail::getId, prepareDetail.getWarehouseReserveDetailId()).eq(ReserveDetail::getPartId, prepareDetail.getPartId()));
|
//将删除的备料数量减掉
|
reserveDetail.setPpoQty(reserveDetail.getPpoQty().subtract(prepareDetail.getPrepareQty()));
|
if (reserveDetail.getPpoQty().compareTo(BigDecimal.ZERO) == 0) {
|
reserveDetail.setStatus("已下发");
|
}
|
reserveDetailMapper.updateById(reserveDetail);
|
ReserveMain reserveMain = reserveMainMapper.selectById(reserveDetail.getWarehouseMainId());
|
StockInCode stockInCode = stockInCodeMapper.selectById(reserveMain.getResType());
|
stockUtils.updateById(stock.getId(), BigDecimal.ZERO, prepareDetail.getPrepareQty().negate(), BigDecimal.ZERO, BigDecimal.ZERO, reserveMain.getResNo(), stockInCode.getStockCodeName());
|
return true;
|
}
|
|
@Override
|
public boolean fullUpdate(PrepareDetail prepareDetail) {
|
//获取旧的备料数据
|
PrepareDetail prepareDetailOld = baseMapper.selectOne(Wrappers.<PrepareDetail>lambdaQuery()
|
.eq(PrepareDetail::getId, prepareDetail.getId()));
|
//找到旧的备料数据所对应的材料申请数据
|
ReserveDetail reserveDetail = reserveDetailMapper.selectOne(Wrappers.<ReserveDetail>lambdaQuery()
|
.eq(ReserveDetail::getId, prepareDetailOld.getWarehouseReserveDetailId()).eq(ReserveDetail::getPartId, prepareDetailOld.getPartId()));
|
if (reserveDetail.getPpoQty().subtract(prepareDetailOld.getPrepareQty()).add(prepareDetail.getPrepareQty()).compareTo(reserveDetail.getResQty()) == 1) {
|
throw new RuntimeException("备料数量超过了需求数量，请重新备料");
|
}
|
//获取旧的备料数据对应实时库存的数据
|
Stock stock = stockMapper.selectOne(Wrappers.<Stock>lambdaQuery().eq(Stock::getPartId, prepareDetailOld.getPartId())
|
.eq(Stock::getLocationId, prepareDetailOld.getLocationId()).eq(Stock::getPartBatchNo, prepareDetail.getPartBatchNo()).eq(Stock::getSystemNo,prepareDetail.getSystemNo()));
|
ReserveMain reserveMain = reserveMainMapper.selectById(reserveDetail.getWarehouseMainId());
|
StockInCode stockInCode = stockInCodeMapper.selectById(reserveMain.getResType());
|
stockUtils.updateById(stock.getId(), BigDecimal.ZERO, prepareDetail.getPrepareQty().subtract(prepareDetailOld.getPrepareQty()), BigDecimal.ZERO, BigDecimal.ZERO,reserveMain.getResNo(), stockInCode.getStockCodeName());
|
reserveDetail.setPpoQty(reserveDetail.getPpoQty().subtract(prepareDetailOld.getPrepareQty()).add(prepareDetail.getPrepareQty()));
|
reserveDetailMapper.updateById(reserveDetail);
|
//更新备料数据
|
baseMapper.updateById(prepareDetail);
|
return true;
|
}
|
|
@Override
|
public void fullSave(PrepareDetail prepareDetail) {
|
//获取对应实时库存的数据
|
Stock stock = stockMapper.selectOne(Wrappers.<Stock>lambdaQuery().eq(Stock::getPartId, prepareDetail.getPartId())
|
.eq(Stock::getLocationId, prepareDetail.getLocationId()).eq(Stock::getPartBatchNo, prepareDetail.getPartBatchNo()).eq(Stock::getSystemNo,prepareDetail.getSystemNo()));
|
//获取关于备料关联的零件申请明细的数据
|
ReserveDetail reserveDetail = reserveDetailMapper.selectOne(Wrappers.<ReserveDetail>lambdaQuery()
|
.eq(ReserveDetail::getId, prepareDetail.getWarehouseReserveDetailId()).eq(ReserveDetail::getPartId, prepareDetail.getPartId()));
|
//将新增的明细数量加上
|
BigDecimal totalPrepareQty = reserveDetail.getPpoQty() == null ? BigDecimal.ZERO : reserveDetail.getPpoQty();
|
if (prepareDetail.getPrepareQty().add(reserveDetail.getPpoQty()).compareTo(reserveDetail.getResQty()) == 1) {
|
throw new RuntimeException("备料数量超过了需求数量，请重新备料");
|
}
|
reserveDetail.setPpoQty(totalPrepareQty.add(prepareDetail.getPrepareQty()));
|
reserveDetail.setStatus("已配料");
|
reserveDetailMapper.updateById(reserveDetail);
|
ReserveMain reserveMain = reserveMainMapper.selectById(reserveDetail.getWarehouseMainId());
|
StockInCode stockInCode = stockInCodeMapper.selectById(reserveMain.getResType());
|
stockUtils.updateById(stock.getId(), BigDecimal.ZERO, prepareDetail.getPrepareQty(), BigDecimal.ZERO, BigDecimal.ZERO,reserveMain.getResNo(), stockInCode.getStockCodeName());
|
baseMapper.insert(prepareDetail);
|
|
}
|
|
@Override
|
public IPage<List<PrepareDetail>> getPrepare(Page page, QueryWrapper<PrepareDetail> prepareDetail) {
|
return baseMapper.getPrepare(page, prepareDetail);
|
}
|
|
@Override
|
public R<IPage<List<PrepareDetailDTO>>> getPrepareByNo(Page page, PrepareDetailDTO prepareDetailDTO) {
|
if (prepareDetailDTO.getResNo() == null) {
|
return R.failed("请选择领料单号");
|
}
|
IPage<List<PrepareDetailDTO>> newPrepareDetailDTO = baseMapper.getPrepareByNo(page, prepareDetailDTO);
|
if (newPrepareDetailDTO == null) {
|
throw new RuntimeException("查不到对应备料明细，请确认领料单号");
|
}
|
return R.ok(newPrepareDetailDTO);
|
}
|
|
@Override
|
public R<PrepareDetailDTO> pdaPrepareDetailSave(PrepareDetailDTO prepareDetailDTO) {
|
if (prepareDetailDTO.getOutQty() == null) {
|
return R.failed("请输入出库数量");
|
}
|
if (prepareDetailDTO.getOutQty().compareTo(BigDecimal.ZERO) != 1) {
|
return R.failed("出库数量不能小于等于0");
|
}
|
//1.先把领料单的所有数据拿到
|
PrepareDetail prepareDetail = prepareDetailMapper.selectById(prepareDetailDTO.getId());
|
//3.如果出库数量大于了预留数量并且状态为不允许超过预留数量，返回数量超过信息
|
if (prepareDetail.getOutQty().add(prepareDetailDTO.getOutQty()).compareTo(prepareDetail.getPrepareQty()) == 1) {
|
return R.failed("此领料单出库数量已大于预留数量");
|
}
|
Stock stock = stockMapper.selectOne(Wrappers.<Stock>lambdaQuery().eq(Stock::getPartId, prepareDetail.getPartId())
|
.eq(Stock::getLocationId, prepareDetail.getLocationId()).eq(Stock::getPartBatchNo, prepareDetail.getPartBatchNo()).eq(Stock::getSystemNo,prepareDetail.getSystemNo()));
|
if (stock == null) {
|
return R.failed("库存不存在，请申请仓库补货");
|
}
|
ReserveDetail reserveDetail = reserveDetailMapper.selectOne(Wrappers.<ReserveDetail>lambdaQuery()
|
.eq(ReserveDetail::getId, prepareDetail.getWarehouseReserveDetailId()).eq(ReserveDetail::getPartId, prepareDetail.getPartId()));
|
//2.判断出库数量是否已经存在
|
BigDecimal reserveQty = reserveDetail.getOutQty() == null ? BigDecimal.ZERO : reserveDetail.getOutQty();
|
BigDecimal outPrepareQty = prepareDetail.getOutQty() == null ? BigDecimal.ZERO : prepareDetail.getOutQty();
|
//4.更新领料单的出库数量
|
reserveDetail.setOutQty(reserveQty.add(prepareDetailDTO.getOutQty()));
|
if (reserveDetail.getOutQty().compareTo(reserveDetail.getPpoQty()) == 0) {
|
reserveDetail.setStatus("已拣料");
|
}
|
reserveDetailMapper.updateById(reserveDetail);
|
prepareDetail.setUpdateTime(LocalDateTime.now());
|
prepareDetail.setOutQty(outPrepareQty.add(prepareDetailDTO.getOutQty()));
|
baseMapper.updateById(prepareDetail);
|
//5.判断出库数量是否超过预留数量，不超过直接减去出库数量
|
ReserveMain reserveMain = reserveMainMapper.selectById(reserveDetail.getWarehouseMainId());
|
StockInCode stockInCode = stockInCodeMapper.selectById(reserveMain.getResType());
|
stockUtils.updateById(stock.getId(), prepareDetailDTO.getOutQty().negate(), prepareDetailDTO.getOutQty().negate(), BigDecimal.ZERO, BigDecimal.ZERO, reserveMain.getResNo(), stockInCode.getStockCodeName());
|
return R.ok(baseMapper.getPrepareResMain(prepareDetailDTO.getId()));
|
}
|
|
@Override
|
public PrepareDetailDTO getPrepareById(Long id) {
|
return baseMapper.getPrepareById(id);
|
}
|
|
@Override
|
public R<IPage<List<PrepareDetailDTO>>> getPrepareDetailByNo(Page page, PrepareDetailDTO prepareDetailDTO) {
|
if (prepareDetailDTO.getResNo() == null) {
|
return R.failed("请选择领料单号");
|
}
|
IPage<List<PrepareDetailDTO>> newPrepareDetailDTO = baseMapper.getPrepareDetailByNo(page, prepareDetailDTO);
|
if (newPrepareDetailDTO == null) {
|
return R.failed("查不到对应备料明细，请确认领料单号");
|
}
|
return R.ok(newPrepareDetailDTO);
|
}
|
|
@Override
|
public boolean batchSave(PrepareDetail[] prepareDetails) {
|
for (PrepareDetail pd : prepareDetails) {
|
if (pd.getId() != null && pd.getId() > 0) {
|
ReserveDetail reserveDetailByFind = reserveDetailMapper.selectOne(Wrappers.<ReserveDetail>lambdaQuery().eq(ReserveDetail::getPartId, pd.getPartId()).eq(ReserveDetail::getId, pd.getWarehouseReserveDetailId()));
|
if (reserveDetailByFind == null) {
|
throw new RuntimeException("材料申请零件不存在");
|
}
|
PrepareDetail prepareDetailByFind = this.getOne(Wrappers.<PrepareDetail>lambdaQuery().eq(PrepareDetail::getLocationId,pd.getLocationId()).eq(PrepareDetail::getWarehouseReserveDetailId,pd.getWarehouseReserveDetailId())
|
.ne(PrepareDetail::getId,pd.getId()).eq(PrepareDetail::getPartBatchNo,pd.getPartBatchNo()));
|
if (prepareDetailByFind != null) {
|
throw new RuntimeException("材料备料重复：" + prepareDetailByFind.getPartId() + "-" + prepareDetailByFind.getLocationId());
|
}
|
this.fullUpdate(pd);
|
}else {
|
PrepareDetail prepareDetailByFind = this.getOne(Wrappers.<PrepareDetail>lambdaQuery().eq(PrepareDetail::getLocationId,pd.getLocationId()).
|
eq(PrepareDetail::getWarehouseReserveDetailId,pd.getWarehouseReserveDetailId()).eq(PrepareDetail::getPartBatchNo,pd.getPartBatchNo()));
|
if (prepareDetailByFind != null) {
|
throw new RuntimeException("材料备料重复：" + prepareDetailByFind.getPartId() + "-" + prepareDetailByFind.getLocationId());
|
}
|
this.fullSave(pd);
|
}
|
}
|
return true;
|
}
|
|
@Override
|
public IPage<List<PrepareDetailDTO>> getPrepareByDate(Page page, ReserveMainDTO reserveMainDTO) {
|
return baseMapper.getPrepareDetailByDate(page, reserveMainDTO);
|
}
|
}
|
