package com.dk.mdm.service.ivt.inbound; import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; import com.dk.common.exception.BaseBusinessException; import com.dk.common.infrastructure.annotaiton.Pagination; import com.dk.common.infrastructure.constant.Constant; import com.dk.common.infrastructure.enums.ErrorCodeEnum; import com.dk.common.mapper.BaseMapper; import com.dk.common.model.pojo.PageList; import com.dk.common.model.vo.AnnexVO; import com.dk.common.response.ResponseCodeEnum; import com.dk.common.response.ResponseResultUtil; import com.dk.common.response.ResponseResultVO; import com.dk.common.service.BaseService; import com.dk.mdm.infrastructure.convert.ivt.InboundConvert; import com.dk.mdm.infrastructure.convert.ivt.InboundItemConvert; import com.dk.mdm.mapper.common.CommonMapper; import com.dk.mdm.mapper.ivt.InboundItemMapper; import com.dk.mdm.mapper.ivt.InboundMapper; import com.dk.mdm.mapper.ivt.InventoryMapper; import com.dk.mdm.mapper.pur.PurchaseItemMapper; import com.dk.mdm.mapper.pur.PurchaseMapper; import com.dk.mdm.model.pojo.ivt.Inbound; import com.dk.mdm.model.pojo.ivt.InboundItem; import com.dk.mdm.model.pojo.ivt.Outbound; import com.dk.mdm.model.pojo.ivt.OutboundItem; import com.dk.mdm.model.pojo.pur.Purchase; import com.dk.mdm.model.pojo.pur.PurchaseItem; import com.dk.mdm.model.pojo.sale.Order; import com.dk.mdm.model.pojo.sale.OrderItem; import com.dk.mdm.model.query.ivt.InboundItemQuery; import com.dk.mdm.model.query.ivt.InboundQuery; import com.dk.mdm.model.query.ivt.InventoryQuery; import com.dk.mdm.model.query.ivt.OutboundItemQuery; import com.dk.mdm.model.response.ivt.*; import com.dk.mdm.model.response.pur.PurchaseItemResponse; import com.dk.mdm.model.response.pur.PurchaseResponse; import com.dk.mdm.model.response.sale.OrderItemResponse; import com.dk.mdm.model.response.sale.OrderResponse; import com.dk.mdm.model.vo.ivt.InboundItemVO; import com.dk.mdm.model.vo.ivt.InboundVO; import com.dk.mdm.model.vo.ivt.OutboundItemVO; import com.dk.mdm.model.vo.ivt.OutboundVO; import com.dk.mdm.service.common.CommonService; import com.dk.mdm.service.ivt.inventory.InventoryService; import com.dk.mdm.service.mac.AccountService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import java.math.BigDecimal; import java.time.LocalDate; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.UUID; import java.util.stream.Collectors; /** * @author : 寇珊珊 * @desc : 采购入库业务层 * @date : 2024/3/7 14:11 */ @Service public class InboundPurchaseService extends BaseService { @Override public BaseMapper getRepository() { return inboundMapper; } @Autowired private InboundMapper inboundMapper; @Autowired private InboundConvert inboundConvert; @Autowired private InboundItemMapper inboundItemMapper; @Autowired private InboundItemConvert inboundItemConvert; @Autowired private PurchaseMapper purchaseMapper; @Autowired private PurchaseItemMapper purchaseItemMapper; @Autowired private CommonService commonService; @Autowired private CommonMapper commonMapper; @Autowired private InventoryService inventoryService; @Autowired private AccountService accountService; @Autowired private InventoryMapper inventoryMapper; /** * @desc : 条件查询 * @date : 2024/3/7 14:12 * @author : 寇珊珊 */ @Pagination public ResponseResultVO> selectByCond(InboundQuery inboundQuery) { return super.mergeListWithCount(inboundQuery, inboundMapper.selectByCond(inboundQuery), inboundMapper.countByCond(inboundQuery)); } /** * @desc : 查询明细 * @date : 2024/3/9 15:43 * @author : 寇珊珊 */ @Pagination public ResponseResultVO> selectPurchaseInboundItemInfoById(String id) { Map result = new HashMap<>(); // 商品明细 List inboundItemResponses = inboundItemMapper.selectByCond(new InboundItemQuery().setIntoId(id)); result.put("itemList", inboundItemResponses); // 收款 // 附件 return ResponseResultUtil.success(result); } /** * @desc : 查询入库价 * @date : 2024/7/1 11:29 * @author : 寇珊珊 */ @Transactional(rollbackFor = {Exception.class}) public InboundItemResponse selectPriceInto(InboundItemVO inboundItemVO) { List inboundItemResponses = inboundItemMapper.selectPriceInto(new InboundItemQuery().setSkuId(inboundItemVO.getSkuId()) .setNonStdCode(inboundItemVO.getNonStdCode()) .setWhId(inboundItemVO.getWhId())); if (inboundItemResponses != null && inboundItemResponses.size() > 0) { return inboundItemResponses.get(0); } return null; } /** * @desc : 采购入库新建 * @date : 2024/3/7 14:13 * 入库中数量/金额 已入库数量/金额 由调用方传入 * @author : 寇珊珊 */ @Transactional(rollbackFor = {Exception.class}) public ResponseResultVO purchaseInboundInsert(InboundVO inboundVO) { //region 校验明细 if (inboundVO.getItemList().size() == 0) { throw new BaseBusinessException(ErrorCodeEnum.INBOUND_ITEM_NOT_EXIST.getCode(), ErrorCodeEnum.INBOUND_ITEM_NOT_EXIST.getMessage()); } //endregion //region 查询当前入库明细中是否存在未空或者0的入库价，如果存在去库存流水差最近一条有价格的数据赋值到当前明细 Boolean priceIntoFlag = false; for (InboundItemVO inboundItemVO : inboundVO.getItemList()) { if (inboundItemVO.getCostPrice() == null || inboundItemVO.getCostPrice().compareTo(BigDecimal.ZERO) == 0) { priceIntoFlag = true; //查询库存批次最近一条入库价 InboundItemResponse inboundItemResponse = this.selectPriceInto(inboundItemVO); //todo 2024年7月5日15:57:01 priceOut和outingAmt 前台传 z确认修改 //todo 2024年7月9日08:52:55 入库价和入库价总和后台计算 z确认修改 inboundItemVO.setCostPrice(inboundItemResponse != null ? inboundItemResponse.getCostPrice() : BigDecimal.ZERO); inboundItemVO.setCostAmt(inboundItemResponse != null ? inboundItemResponse.getCostPrice().multiply(inboundItemVO.getIntoingQty()).setScale(2, BigDecimal.ROUND_HALF_UP) : BigDecimal.ZERO); inboundItemVO.setPriceInto(inboundItemResponse != null ? inboundItemResponse.getCostPrice() : BigDecimal.ZERO); inboundItemVO.setIntoingAmt(inboundItemResponse != null ? inboundItemResponse.getPriceInto().multiply(inboundItemVO.getIntoingQty()).setScale(2, BigDecimal.ROUND_HALF_UP) : BigDecimal.ZERO); } } if (priceIntoFlag) { BigDecimal intoingAmt = inboundVO.getItemList().stream().map(InboundItemVO::getIntoingAmt).reduce(BigDecimal.ZERO, BigDecimal::add).setScale(6, BigDecimal.ROUND_HALF_UP); inboundVO.setIntoingAmt(intoingAmt); } //endregion //region 查询当前公司的系统参数 自动办理信息 并赋值 Map map = new HashMap<>(); map.put("cpId", inboundVO.getCpId()); map.put("code", Constant.SystemConstant.IVT_001.getValue()); //自动办理标识 String flgHandleSetting = commonMapper.getSettingValue(map); //自动办理标识为1 自动办理入库 if (Constant.FlgAutoHandleStringType.ONE.getValue().equals(flgHandleSetting)) { inboundVO.setFlgAutoHandle(Constant.FlgAutoHandle.TRUE.getValue()); } //endregion //region 总单 //获取 id/单号 Map codeMap = commonService.getUniqueNoteCode(Constant.docNameConstant.PURCASEINBOUND.getName(), false); inboundVO.setIntoId(codeMap.get("outId").toString()). setIntoNo(codeMap.get("outNote").toString()); //入库类型 inboundVO.setIntoType(Constant.IntoType.SALE.getName()); //自动入库标识 if (inboundVO.getFlgAutoHandle()) { //已入库 inboundVO.setIntoStatus(Constant.IntoStatus.YIRUKU.getName()); //入库日期 inboundVO.setIntoDate(inboundVO.getIntoDate() == null ? LocalDate.now() : inboundVO.getIntoDate()); } else { //入库中 inboundVO.setIntoStatus(Constant.IntoStatus.RUKUZHONG.getName()); } //入库状态等于已入库 更新合计入库数量/金额 = 入库中数量/入库中金额 if (Constant.IntoStatus.YIRUKU.getName().equals(inboundVO.getIntoStatus())) { inboundVO.setIntoQty(inboundVO.getIntoingQty()) .setIntoAmt(inboundVO.getIntoingAmt()) .setIntoingQty(BigDecimal.ZERO) .setIntoingAmt(BigDecimal.ZERO) ; } else { inboundVO.setIntoQty(BigDecimal.ZERO) .setIntoAmt(BigDecimal.ZERO) ; } //实体转换 Inbound inbound = inboundConvert.convertToPo(inboundVO); inboundMapper.insert(inbound); //endregion //region 采购总单 this.insertOrderMessageByEdit(inboundVO,inboundVO.getItemList()); //endregion //region 明细 for (InboundItemVO inboundItemVO : inboundVO.getItemList()) { //region 将库存需要的参数赋值 inboundItemVO.setInventoryType(Constant.InventoryType.INBOUND.getName()); inboundItemVO.setInventoryDocCode(Constant.InventoryDocCode.PURCHASE_ORDER.getValue()); inboundItemVO.setAddOrEditFlag(true); //endregion //总单id inboundItemVO.setIntoId(inboundVO.getIntoId()); //入库类型 inboundItemVO.setIntoType(inboundVO.getIntoType()); //入库状态等于已入库 更新合计入库数量/金额 = 入库中数量/入库中金额 if (Constant.IntoStatus.YIRUKU.getName().equals(inboundVO.getIntoStatus())) { inboundItemVO .setIntoQty(inboundItemVO.getIntoingQty()) .setIntoAmt(inboundItemVO.getIntoingAmt()) .setIntoingQty(BigDecimal.ZERO) .setIntoingAmt(BigDecimal.ZERO) ; } else { inboundItemVO .setIntoQty(BigDecimal.ZERO) .setIntoAmt(BigDecimal.ZERO); } //入库状态 inboundItemVO.setIntoStatus(inboundVO.getIntoStatus()); //实体转换 InboundItem inboundItem = inboundItemConvert.convertToPo(inboundItemVO); inboundItemMapper.insert(inboundItem); inboundItemVO.setItemId(inboundItem.getItemId()); //endregion //region 采购明细 if (inboundItemVO.getFromItemId() != null) { //赋值（这里重写了更新方法，数量在更新方法中有数据库院士数量+本次数量） PurchaseItem purchaseItem = new PurchaseItem(); purchaseItem.setItemId(inboundItemVO.getFromItemId()); //根据id查询 PurchaseItemResponse purchaseItemResponse = purchaseItemMapper.selectById(inboundItemVO.getFromItemId()); //已入库 if (Constant.IntoStatus.YIRUKU.getName().equals(inboundVO.getIntoStatus())) { purchaseItem.setIntoingQty(BigDecimal.ZERO); purchaseItem.setIntoingAmt(BigDecimal.ZERO); purchaseItem.setIntoQty(inboundItemVO.getIntoQty()); purchaseItem.setIntoAmt(inboundItemVO.getIntoAmt()); } //入库中 else { purchaseItem.setIntoingQty(inboundItemVO.getIntoingQty()); purchaseItem.setIntoingAmt(inboundItemVO.getIntoingAmt()); purchaseItem.setIntoQty(BigDecimal.ZERO); purchaseItem.setIntoAmt(BigDecimal.ZERO); } //入库状态 String intoStatus = this.setIntoStatus(purchaseItemResponse.getIntoingQty().add(purchaseItem.getIntoingQty()), purchaseItemResponse.getIntoQty().add(purchaseItem.getIntoQty()), purchaseItemResponse.getItemQty()); purchaseItem.setIntoStatus(intoStatus); int countRow = purchaseItemMapper.updateById(purchaseItem); //数量超出 if (countRow == 0) { throw new BaseBusinessException(ResponseCodeEnum.OPERATE_FAIL.getCode(), ErrorCodeEnum.INVENTORY_QUANTITY_EXCEEDED.getMessage()); } } //endregion } //endregion //region 入账 if (Constant.IntoStatus.YIRUKU.getName().equals(inboundVO.getIntoStatus())) { accountService.accPayable(inboundVO.getIntoId(), Constant.InventoryDocCode.INTOBOUND.getTableName()); } //endregion //region 库存 if (Constant.IntoStatus.YIRUKU.getName().equals(inboundVO.getIntoStatus())) { Map invMap = new HashMap<>(); invMap.put("intoDetail", inboundVO.getItemList()); inventoryService.operatingInventoryInformation(invMap); } //endregion return ResponseResultUtil.success(inboundVO); } /** * @desc : 新建采购入库修改采购订单信息 * @date : 2024/7/6 15:15 * @author : 寇珊珊 */ @Transactional(rollbackFor = {Exception.class}) public void insertOrderMessageByEdit(InboundVO inboundVO , List itemList){ //入库明细汇总 Map> purchaseIntoItemVOListMap = itemList.stream().collect(Collectors.groupingBy(InboundItemVO::getFromId)); //入库明细汇总循环 for (String fromId : purchaseIntoItemVOListMap.keySet()) { //region 提取新建分组后的明细 List purchaseIntoItemVOListGroup = purchaseIntoItemVOListMap.get(fromId); //分组后的明细 入库数量和金额总和 BigDecimal purchaseSumQty = purchaseIntoItemVOListGroup.stream().map(InboundItemVO::getIntoingQty).reduce(BigDecimal.ZERO, BigDecimal::add).setScale(6, BigDecimal.ROUND_HALF_UP); BigDecimal purchaseSumAmt = purchaseIntoItemVOListGroup.stream().map(InboundItemVO::getIntoingAmt).reduce(BigDecimal.ZERO, BigDecimal::add).setScale(2, BigDecimal.ROUND_HALF_UP); //endregion //region 反写订单数据 //根据id查询 PurchaseResponse purchaseResponse = purchaseMapper.selectById(fromId); Purchase purchase = new Purchase(); purchase.setPurId(fromId); //已入库 if (Constant.IntoStatus.YIRUKU.getName().equals(inboundVO.getIntoStatus())) { purchase.setIntoingQty(BigDecimal.ZERO); purchase.setIntoingAmt(BigDecimal.ZERO); purchase.setIntoQty(purchaseSumQty); purchase.setIntoAmt(purchaseSumAmt); } //出库中 else { purchase.setIntoingQty(purchaseSumQty); purchase.setIntoingAmt(purchaseSumAmt); purchase.setIntoQty(BigDecimal.ZERO); purchase.setIntoAmt(BigDecimal.ZERO); } //入库状态 String intoStatus = this.setIntoStatus(purchaseResponse.getIntoingQty().add(purchase.getIntoingQty()), purchaseResponse.getIntoQty().add(purchase.getIntoQty()), purchaseResponse.getSumQuantity()); purchase.setIntoStatus(intoStatus); //修改 int countRow = purchaseMapper.updateById(purchase); //数量超出 if (countRow == 0) { throw new BaseBusinessException(ResponseCodeEnum.OPERATE_FAIL.getCode(), ErrorCodeEnum.INVENTORY_QUANTITY_EXCEEDED.getMessage()); } //endregion } } /** * @desc : 采购入库编辑 * @date : 2024/3/25 16:25 * @author : 寇珊珊 */ @Transactional(rollbackFor = {Exception.class}) public ResponseResultVO purchaseInboundUpdate(InboundVO inboundVO) { //region 小编辑 if (!inboundVO.getLimitEdit()) { Inbound inbound = new Inbound(); inbound.setIntoId(inboundVO.getIntoId()); inbound.setRemarks(inboundVO.getRemarks()); inbound.setAnnexPaths(inboundVO.getAnnexPaths()); inboundMapper.update(inbound, new UpdateWrapper().lambda() .eq(Inbound::getIntoId, UUID.fromString(inbound.getIntoId())) ); for (InboundItemVO inboundItemVO : inboundVO.getItemList()) { InboundItem inboundItem = new InboundItem(); inboundItem.setItemId(inboundItemVO.getItemId()); if (inboundItemVO.getRemarks() != null && inboundItemVO.getRemarks() != "") { inboundItem.setRemarks(inboundItemVO.getRemarks()); inboundItemMapper.update(inboundItem, new UpdateWrapper().lambda() .eq(InboundItem::getItemId, UUID.fromString(inboundItem.getItemId())) ); } } } //endregion //region 大编辑 else { //region 根据id查询 此条入库单的数据还未更改前的数据 InboundResponse inboundResponse = inboundMapper.selectById(inboundVO.getIntoId()); BigDecimal sumQty = inboundVO.getItemList().stream().map(InboundItemVO::getIntoingQty).reduce(BigDecimal.ZERO, BigDecimal::add).setScale(6, BigDecimal.ROUND_HALF_UP); BigDecimal sumAmt = inboundVO.getItemList().stream().map(InboundItemVO::getIntoingAmt).reduce(BigDecimal.ZERO, BigDecimal::add).setScale(2, BigDecimal.ROUND_HALF_UP); //endregion //region 已入库编辑 if (Constant.IntoStatus.YIRUKU.getName().equals(inboundResponse.getIntoStatus())) { //region 退账 if (inboundVO.getReceivableId() != null) { accountService.reversePayable(inboundVO.getIntoId(), Constant.InventoryDocCode.INTOBOUND.getTableName()); } //endregion //region 修改明细 List itemList = inboundVO.getItemList(); for (InboundItemVO inboundItemVO : itemList) { //根据id查询 InboundItemResponse inboundItemResponse = inboundItemMapper.selectById(inboundItemVO.getItemId()); //region 编辑明细 if (inboundItemVO.getItemId() != null) { //region 反写订单总单 数据需要 把查出来的已入库数量用别的变量存起来 inboundItemVO.setUpdatePurchaseIntoQty(inboundItemResponse.getIntoQty()); inboundItemVO.setUpdatePurchaseIntoAmt(inboundItemResponse.getIntoAmt()); //endregion //region 将库存需要的参数赋值 inboundItemVO.setInventoryType(Constant.InventoryType.INBOUND.getName()); inboundItemVO.setInventoryDocCode(Constant.InventoryDocCode.PURCHASE_ORDER.getValue()); //编辑之前的数 inboundItemVO.setQtyBeforeUpdate(inboundItemResponse.getIntoQty()); inboundItemVO.setAmtBeforeUpdate(inboundItemResponse.getIntoAmt()); //编辑之后的数 inboundItemVO.setIntoQty(inboundItemVO.getIntoingQty()); inboundItemVO.setIntoAmt(inboundItemVO.getIntoingAmt()); inboundItemVO.setAddOrEditFlag(false); //endregion InboundItem inboundItem = new InboundItem(); inboundItem.setItemId(inboundItemVO.getItemId()); inboundItem.setIntoQty(inboundItemVO.getIntoingQty()); inboundItem.setIntoAmt(inboundItemVO.getIntoingAmt()); //修改 inboundItemMapper.update(inboundItem, new UpdateWrapper().lambda() .eq(InboundItem::getItemId, UUID.fromString(inboundItem.getItemId())) ); } //endregion //region 新建明细 else { inboundItemVO .setIntoQty(inboundItemVO.getIntoingQty()) .setIntoAmt(inboundItemVO.getIntoingAmt()) .setIntoingQty(BigDecimal.ZERO) .setIntoingAmt(BigDecimal.ZERO) ; inboundItemVO.setIntoId(inboundVO.getIntoId()); //入库状态 inboundItemVO.setIntoStatus(inboundVO.getIntoStatus()); inboundItemVO.setIntoType(Constant.IntoType.SALE.getName()); //实体转换 InboundItem inboundItem = inboundItemConvert.convertToPo(inboundItemVO); inboundItemMapper.insert(inboundItem); inboundItemVO.setItemId(inboundItem.getItemId()); //region 将库存需要的参数赋值 inboundItemVO.setInventoryType(Constant.InventoryType.INBOUND.getName()); inboundItemVO.setInventoryDocCode(Constant.InventoryDocCode.PURCHASE_ORDER.getValue()); inboundItemVO.setIntoQty(inboundItemVO.getIntoQty()); inboundItemVO.setIntoAmt(inboundItemVO.getIntoAmt()); inboundItemVO.setAddOrEditFlag(true); //endregion } //endregion //region 销售明细 if (inboundItemVO.getFromItemId() != null) { //根据id查询 PurchaseItemResponse purchaseItemResponse = purchaseItemMapper.selectById(inboundItemVO.getFromItemId()); PurchaseItem purchaseItem = new PurchaseItem(); purchaseItem.setItemId(inboundItemVO.getFromItemId()); purchaseItem.setIntoQty(inboundItemResponse.getIntoQty().negate().add(inboundItemVO.getIntoingQty())); purchaseItem.setIntoAmt(inboundItemResponse.getIntoAmt().negate().add(inboundItemVO.getIntoingAmt())); //入库状态 String intoStatus = this.setIntoStatus(purchaseItemResponse.getIntoingQty(), purchaseItemResponse.getIntoQty().add(purchaseItem.getIntoQty()), purchaseItemResponse.getItemQty()); purchaseItem.setIntoStatus(intoStatus); int countRow = purchaseItemMapper.updateById(purchaseItem); //数量超出 if (countRow == 0) { throw new BaseBusinessException(ResponseCodeEnum.OPERATE_FAIL.getCode(), ErrorCodeEnum.INVENTORY_QUANTITY_EXCEEDED.getMessage()); } } //endregion } //endregion //region 删除明细 BigDecimal delIntoQty = BigDecimal.ZERO; BigDecimal delIntoAmt = BigDecimal.ZERO; if (inboundVO.getDeleteItemList() != null && inboundVO.getDeleteItemList().size() > 0) { delIntoQty = inboundVO.getDeleteItemList().stream().map(InboundItemVO::getIntoQty).reduce(BigDecimal.ZERO, BigDecimal::add).setScale(6, BigDecimal.ROUND_HALF_UP); delIntoAmt = inboundVO.getDeleteItemList().stream().map(InboundItemVO::getIntoAmt).reduce(BigDecimal.ZERO, BigDecimal::add).setScale(2, BigDecimal.ROUND_HALF_UP); for (InboundItemVO inboundItemVO : inboundVO.getDeleteItemList()) { if (inboundItemVO.getItemId() != null) { //region 将库存需要的参数赋值 inboundItemVO.setInventoryType(Constant.InventoryType.INBOUND.getName()); inboundItemVO.setInventoryDocCode(Constant.InventoryDocCode.PURCHASE_ORDER.getValue()); inboundItemVO.setIntoQty(inboundItemVO.getIntoQty()); inboundItemVO.setIntoAmt(inboundItemVO.getIntoAmt()); //endregion InboundItem inboundItem = inboundItemConvert.convertToPo(inboundItemVO); inboundItem.setFlgValid(false); //修改 inboundItemMapper.update(inboundItem, new UpdateWrapper().lambda() .eq(InboundItem::getItemId, UUID.fromString(inboundItem.getItemId())) ); } //region 销售明细 if (inboundItemVO.getFromItemId() != null) { //根据id查询 PurchaseItemResponse purchaseItemResponse = purchaseItemMapper.selectById(inboundItemVO.getFromItemId()); PurchaseItem purchaseItem = new PurchaseItem(); purchaseItem.setItemId(inboundItemVO.getFromItemId()); purchaseItem.setIntoQty(inboundItemVO.getIntoQty().negate()); purchaseItem.setIntoAmt(inboundItemVO.getIntoAmt().negate()); purchaseItem.setIntoingQty(inboundItemVO.getIntoQty()); purchaseItem.setIntoingAmt(inboundItemVO.getIntoAmt()); //入库状态 String intoStatus = this.setIntoStatus(purchaseItemResponse.getIntoingQty().add(purchaseItem.getIntoingQty()), purchaseItemResponse.getIntoQty().add(purchaseItem.getIntoQty()), purchaseItemResponse.getItemQty()); purchaseItem.setIntoStatus(intoStatus); int countRow = purchaseItemMapper.updateById(purchaseItem); //数量超出 if (countRow == 0) { throw new BaseBusinessException(ResponseCodeEnum.OPERATE_FAIL.getCode(), ErrorCodeEnum.INVENTORY_QUANTITY_EXCEEDED.getMessage()); } } //endregion } } //endregion //region 修改入库总单 Inbound inbound = new Inbound(); inbound.setIntoId(inboundVO.getIntoId()); inbound.setIntoQty(sumQty); inbound.setIntoAmt(sumAmt); //修改 inboundMapper.update(inbound, new UpdateWrapper().lambda().eq(Inbound::getIntoId, UUID.fromString(inbound.getIntoId())) ); //endregion //region 修改采购订单总单 this.updateOrderMessageByEdit(inboundResponse, inboundVO.getItemList(), inboundVO.getDeleteItemList()); //endregion //region 入账 if (inboundVO.getReceivableId() != null) { accountService.accPayable(inboundVO.getIntoId(), Constant.InventoryDocCode.INTOBOUND.getTableName()); } //endregion //region 调用库存 Map map = new HashMap<>(); map.put("intoDetail", inboundVO.getItemList()); map.put("delIntoDetail", inboundVO.getDeleteItemList()); inventoryService.operatingInventoryInformation(map); //endregion } //endregion //region 入库中编辑 if (Constant.IntoStatus.RUKUZHONG.getName().equals(inboundResponse.getIntoStatus()) || Constant.IntoStatus.DAIRUKU.getName().equals(inboundResponse.getIntoStatus())) { //region 修改明细 List itemList = inboundVO.getItemList(); for (InboundItemVO inboundItemVO : itemList) { //根据id查询 获取到还未进行修改的数据 InboundItemResponse inboundItemResponse = inboundItemMapper.selectById(inboundItemVO.getItemId()); //region 编辑明细 if (inboundItemVO.getItemId() != null) { //region 反写订单总单 数据需要 把查出来的入库中数量用别的变量存起来 inboundItemVO.setUpdatePurchaseIntoingQty(inboundItemResponse.getIntoingQty()); inboundItemVO.setUpdatePurchaseIntoingAmt(inboundItemResponse.getIntoingAmt()); //endregion InboundItem inboundItem = new InboundItem(); inboundItem.setItemId(inboundItemVO.getItemId()); inboundItem.setIntoingQty(inboundItemVO.getIntoingQty()); inboundItem.setIntoingAmt(inboundItemVO.getIntoingAmt()); //修改 inboundItemMapper.update(inboundItem, new UpdateWrapper().lambda() .eq(InboundItem::getItemId, UUID.fromString(inboundItem.getItemId())) ); } //endregion //region 新建明细 else { inboundItemVO .setIntoQty(BigDecimal.ZERO) .setIntoAmt(BigDecimal.ZERO) ; inboundItemVO.setIntoId(inboundVO.getIntoId()); //入库状态 inboundItemVO.setIntoStatus(inboundVO.getIntoStatus()); inboundItemVO.setIntoType(Constant.IntoType.SALE.getName()); //实体转换 InboundItem inboundItem = inboundItemConvert.convertToPo(inboundItemVO); inboundItemMapper.insert(inboundItem); inboundItemVO.setItemId(inboundItem.getItemId()); } //endregion //region 销售明细 if (inboundItemVO.getFromItemId() != null) { //根据id查询 PurchaseItemResponse purchaseItemResponse = purchaseItemMapper.selectById(inboundItemVO.getFromItemId()); PurchaseItem purchaseItem = new PurchaseItem(); purchaseItem.setItemId(inboundItemVO.getFromItemId()); //本次修改几个传几个（负数） sql中是原数据+本次修改数据 purchaseItem.setIntoingQty(inboundItemResponse.getIntoingQty().negate().add(inboundItemVO.getIntoingQty())); purchaseItem.setIntoingAmt(inboundItemResponse.getIntoingAmt().negate().add(inboundItemVO.getIntoingAmt())); //入库状态 String intoStatus = this.setIntoStatus(purchaseItemResponse.getIntoingQty().add(purchaseItem.getIntoingQty()), purchaseItemResponse.getIntoQty().add(purchaseItem.getIntoQty()), purchaseItemResponse.getItemQty()); purchaseItem.setIntoStatus(intoStatus); int countRow = purchaseItemMapper.updateById(purchaseItem); //数量超出 if (countRow == 0) { throw new BaseBusinessException(ResponseCodeEnum.OPERATE_FAIL.getCode(), ErrorCodeEnum.INVENTORY_QUANTITY_EXCEEDED.getMessage()); } } //endregion } //endregion //region 删除明细 BigDecimal delIntoQty = BigDecimal.ZERO; BigDecimal delIntoAmt = BigDecimal.ZERO; if (inboundVO.getDeleteItemList() != null && inboundVO.getDeleteItemList().size() > 0) { delIntoQty = inboundVO.getDeleteItemList().stream().map(InboundItemVO::getIntoingQty).reduce(BigDecimal.ZERO, BigDecimal::add).setScale(6, BigDecimal.ROUND_HALF_UP); delIntoAmt = inboundVO.getDeleteItemList().stream().map(InboundItemVO::getIntoingAmt).reduce(BigDecimal.ZERO, BigDecimal::add).setScale(2, BigDecimal.ROUND_HALF_UP); for (InboundItemVO inboundItemVO : inboundVO.getDeleteItemList()) { //region 明细 if (inboundItemVO.getItemId() != null) { InboundItem inboundItem = inboundItemConvert.convertToPo(inboundItemVO); inboundItem.setFlgValid(false); //修改 inboundItemMapper.update(inboundItem, new UpdateWrapper().lambda() .eq(InboundItem::getItemId, UUID.fromString(inboundItem.getItemId())) ); } //endregion //region 销售明细 if (inboundItemVO.getFromItemId() != null) { //根据id查询 PurchaseItemResponse purchaseItemResponse = purchaseItemMapper.selectById(inboundItemVO.getFromItemId()); PurchaseItem purchaseItem = new PurchaseItem(); purchaseItem.setItemId(inboundItemVO.getFromItemId()); purchaseItem.setIntoingQty(inboundItemVO.getIntoingQty().negate()); purchaseItem.setIntoingAmt(inboundItemVO.getIntoingAmt().negate()); //入库状态 String intoStatus = this.setIntoStatus(purchaseItemResponse.getIntoingQty().add(purchaseItem.getIntoingQty()), purchaseItemResponse.getIntoQty(), purchaseItemResponse.getItemQty()); purchaseItem.setIntoStatus(intoStatus); int countRow = purchaseItemMapper.updateById(purchaseItem); //数量超出 if (countRow == 0) { throw new BaseBusinessException(ResponseCodeEnum.OPERATE_FAIL.getCode(), ErrorCodeEnum.INVENTORY_QUANTITY_EXCEEDED.getMessage()); } } //endregion } } //endregion //region 修改入库总单 Inbound inbound = new Inbound(); inbound.setIntoId(inboundVO.getIntoId()); inbound.setIntoingQty(sumQty); inbound.setIntoingAmt(sumAmt); //修改 inboundMapper.update(inbound, new UpdateWrapper().lambda().eq(Inbound::getIntoId, UUID.fromString(inbound.getIntoId())) ); //endregion //region 修改采购订单总单 this.updateOrderMessageByEdit(inboundResponse, inboundVO.getItemList(), inboundVO.getDeleteItemList()); //endregion } //endregion } //endregion return ResponseResultUtil.success(inboundVO); } /** * @desc : 采购入库编辑修改订单信息 * @date : 2024/7/8 9:12 * @author : 寇珊珊 */ @Transactional(rollbackFor = {Exception.class}) public void updateOrderMessageByEdit(InboundResponse inboundResponse, List itemList, List deleteItemList) { //入库明细汇总 Map> purchaseIntoItemVOListMap = itemList.stream().collect(Collectors.groupingBy(InboundItemVO::getFromId)); //入库明细删除汇总 Map> delPurchaseIntoItemVOListMap = deleteItemList.stream().collect(Collectors.groupingBy(InboundItemVO::getFromId)); //人库明细汇总循环 for (String fromId : purchaseIntoItemVOListMap.keySet()) { //有需要删除的修改数据 if(delPurchaseIntoItemVOListMap!=null && delPurchaseIntoItemVOListMap.keySet().size()>0){ //出库明细删除汇总循环 for (String delFromId : delPurchaseIntoItemVOListMap.keySet()) { //新建入库明细来源Id = 删除入库明细来源Id if (fromId.equals(delFromId)) { //region 提取新建分组后的明细 List purchaseIntoItemVOListGroup = purchaseIntoItemVOListMap.get(fromId); //分组后的明细 出库数量和金额总和 BigDecimal purchaseSumQty = purchaseIntoItemVOListGroup.stream().map(InboundItemVO::getIntoingQty).reduce(BigDecimal.ZERO, BigDecimal::add).setScale(6, BigDecimal.ROUND_HALF_UP); BigDecimal purchaseSumAmt = purchaseIntoItemVOListGroup.stream().map(InboundItemVO::getIntoingAmt).reduce(BigDecimal.ZERO, BigDecimal::add).setScale(2, BigDecimal.ROUND_HALF_UP); //分组后的明细 原出库数量和金额总和 BigDecimal updatePurchaseIntoQty = BigDecimal.ZERO; BigDecimal updatePurchaseIntoAmt = BigDecimal.ZERO; BigDecimal updatePurchaseIntoingQty = BigDecimal.ZERO; BigDecimal updatePurchaseIntoingAmt = BigDecimal.ZERO; //已入库 if (Constant.IntoStatus.YIRUKU.getName().equals(inboundResponse.getIntoStatus())) { updatePurchaseIntoQty = purchaseIntoItemVOListGroup.stream().filter(it->it.getUpdatePurchaseIntoQty()!=null).map(InboundItemVO::getUpdatePurchaseIntoQty).reduce(BigDecimal.ZERO, BigDecimal::add).setScale(6, BigDecimal.ROUND_HALF_UP); updatePurchaseIntoAmt = purchaseIntoItemVOListGroup.stream().filter(it->it.getUpdatePurchaseIntoAmt()!=null).map(InboundItemVO::getUpdatePurchaseIntoAmt).reduce(BigDecimal.ZERO, BigDecimal::add).setScale(2, BigDecimal.ROUND_HALF_UP); } //入库中 else { updatePurchaseIntoingQty = purchaseIntoItemVOListGroup.stream().filter(it->it.getUpdatePurchaseIntoingQty()!=null).map(InboundItemVO::getUpdatePurchaseIntoingQty).reduce(BigDecimal.ZERO, BigDecimal::add).setScale(6, BigDecimal.ROUND_HALF_UP); updatePurchaseIntoingAmt = purchaseIntoItemVOListGroup.stream().filter(it->it.getUpdatePurchaseIntoingAmt()!=null).map(InboundItemVO::getUpdatePurchaseIntoingAmt).reduce(BigDecimal.ZERO, BigDecimal::add).setScale(2, BigDecimal.ROUND_HALF_UP); } //endregion //region 提取删除分组后的明细 List delPurchaseIntoItemVOListGroup = delPurchaseIntoItemVOListMap.get(delFromId); BigDecimal purchaseDelOutQty = BigDecimal.ZERO; BigDecimal purchaseDelOutAmt = BigDecimal.ZERO; //已出库 if (Constant.IntoStatus.YIRUKU.getName().equals(inboundResponse.getIntoStatus())) { purchaseDelOutQty = delPurchaseIntoItemVOListGroup.stream().map(InboundItemVO::getIntoQty).reduce(BigDecimal.ZERO, BigDecimal::add).setScale(6, BigDecimal.ROUND_HALF_UP); purchaseDelOutAmt = delPurchaseIntoItemVOListGroup.stream().map(InboundItemVO::getIntoAmt).reduce(BigDecimal.ZERO, BigDecimal::add).setScale(2, BigDecimal.ROUND_HALF_UP); } //出库中 else if (Constant.IntoStatus.RUKUZHONG.getName().equals(inboundResponse.getIntoStatus())) { purchaseDelOutQty = delPurchaseIntoItemVOListGroup.stream().map(InboundItemVO::getIntoingQty).reduce(BigDecimal.ZERO, BigDecimal::add).setScale(6, BigDecimal.ROUND_HALF_UP); purchaseDelOutAmt = delPurchaseIntoItemVOListGroup.stream().map(InboundItemVO::getIntoingAmt).reduce(BigDecimal.ZERO, BigDecimal::add).setScale(2, BigDecimal.ROUND_HALF_UP); } //endregion //region 反写订单数据 //根据id查询 PurchaseResponse purchaseResponse = purchaseMapper.selectById(fromId); Purchase purchase = new Purchase(); purchase.setPurId(fromId); //已入库 if (Constant.IntoStatus.YIRUKU.getName().equals(inboundResponse.getIntoStatus())) { purchase.setIntoQty(purchaseSumQty.subtract(updatePurchaseIntoQty).subtract(purchaseDelOutQty)); purchase.setIntoAmt(purchaseSumAmt.subtract(updatePurchaseIntoAmt).subtract(purchaseDelOutAmt)); purchase.setIntoingQty(purchaseDelOutQty); purchase.setIntoingAmt(purchaseDelOutAmt); purchase.setUpdateIntoingMessageFlag(true); //入库状态 String intoStatus = this.setIntoStatus(purchaseResponse.getIntoingQty().add(purchase.getIntoingQty()), purchaseResponse.getIntoQty().add(purchase.getIntoQty()), purchaseResponse.getSumQuantity()); purchase.setIntoStatus(intoStatus); } //入库中 else if (Constant.IntoStatus.RUKUZHONG.getName().equals(inboundResponse.getIntoStatus())) { purchase.setIntoingQty(purchaseSumQty.subtract(updatePurchaseIntoingQty).subtract(purchaseDelOutQty)); purchase.setIntoingAmt(purchaseSumAmt.subtract(updatePurchaseIntoingAmt).subtract(purchaseDelOutAmt)); purchase.setUpdateIntoingMessageFlag(true); //入库状态 String intoStatus = this.setIntoStatus(purchaseResponse.getIntoingQty().add(purchase.getIntoingQty()), purchaseResponse.getIntoQty(), purchaseResponse.getSumQuantity()); purchase.setIntoStatus(intoStatus); } //修改 int countRow = purchaseMapper.updateById(purchase); //数量超出 if (countRow == 0) { throw new BaseBusinessException(ResponseCodeEnum.OPERATE_FAIL.getCode(), ErrorCodeEnum.INVENTORY_QUANTITY_EXCEEDED.getMessage()); } //endregion } } } //没有需要删除的修改数据 else{ //region 提取新建分组后的明细 List purchaseIntoItemVOListGroup = purchaseIntoItemVOListMap.get(fromId); //分组后的明细 出库数量和金额总和 BigDecimal purchaseSumQty = purchaseIntoItemVOListGroup.stream().map(InboundItemVO::getIntoQty).reduce(BigDecimal.ZERO, BigDecimal::add).setScale(6, BigDecimal.ROUND_HALF_UP); BigDecimal purchaseSumAmt = purchaseIntoItemVOListGroup.stream().map(InboundItemVO::getIntoAmt).reduce(BigDecimal.ZERO, BigDecimal::add).setScale(2, BigDecimal.ROUND_HALF_UP); //分组后的明细 原出库数量和金额总和 BigDecimal updatePurchaseIntoQty = BigDecimal.ZERO; BigDecimal updatePurchaseIntoAmt = BigDecimal.ZERO; BigDecimal updatePurchaseIntoingQty = BigDecimal.ZERO; BigDecimal updatePurchaseIntoingAmt = BigDecimal.ZERO; //已入库 if (Constant.IntoStatus.YIRUKU.getName().equals(inboundResponse.getIntoStatus())) { updatePurchaseIntoQty = purchaseIntoItemVOListGroup.stream().filter(it -> it.getUpdatePurchaseIntoQty() != null).map(InboundItemVO::getUpdatePurchaseIntoQty).reduce(BigDecimal.ZERO, BigDecimal::add).setScale(6, BigDecimal.ROUND_HALF_UP); updatePurchaseIntoAmt = purchaseIntoItemVOListGroup.stream().filter(it -> it.getUpdatePurchaseIntoAmt() != null).map(InboundItemVO::getUpdatePurchaseIntoAmt).reduce(BigDecimal.ZERO, BigDecimal::add).setScale(2, BigDecimal.ROUND_HALF_UP); } //入库中 else { updatePurchaseIntoingQty = purchaseIntoItemVOListGroup.stream().filter(it->it.getUpdatePurchaseIntoingQty()!=null).map(InboundItemVO::getUpdatePurchaseIntoingQty).reduce(BigDecimal.ZERO, BigDecimal::add).setScale(6, BigDecimal.ROUND_HALF_UP); updatePurchaseIntoingAmt = purchaseIntoItemVOListGroup.stream().filter(it->it.getUpdatePurchaseIntoingAmt()!=null).map(InboundItemVO::getUpdatePurchaseIntoingAmt).reduce(BigDecimal.ZERO, BigDecimal::add).setScale(2, BigDecimal.ROUND_HALF_UP); } //endregion //region 反写订单数据 //根据id查询 PurchaseResponse purchaseResponse = purchaseMapper.selectById(fromId); Purchase purchase = new Purchase(); purchase.setPurId(fromId); //已出库 if (Constant.IntoStatus.YIRUKU.getName().equals(inboundResponse.getIntoStatus())) { purchase.setIntoQty(purchaseSumQty.subtract(updatePurchaseIntoQty)); purchase.setIntoAmt(purchaseSumAmt.subtract(updatePurchaseIntoAmt)); purchase.setUpdateIntoMessageFlag(true); //入库状态 String intoStatus = this.setIntoStatus(purchaseResponse.getIntoingQty().add(purchase.getIntoingQty()), purchaseResponse.getIntoQty().add(purchase.getIntoQty()), purchaseResponse.getSumQuantity()); purchase.setIntoStatus(intoStatus); } //入库中 else if (Constant.IntoStatus.RUKUZHONG.getName().equals(inboundResponse.getIntoStatus())) { purchase.setIntoingQty(updatePurchaseIntoingQty.negate()); purchase.setIntoingAmt(updatePurchaseIntoingAmt.negate()); purchase.setUpdateIntoingMessageFlag(true); //入库状态 String intoStatus = this.setIntoStatus(purchaseResponse.getIntoingQty().add(purchase.getIntoingQty()), purchaseResponse.getIntoQty(), purchaseResponse.getSumQuantity()); purchase.setIntoStatus(intoStatus); } //修改 int countRow = purchaseMapper.updateById(purchase); //数量超出 if (countRow == 0) { throw new BaseBusinessException(ResponseCodeEnum.OPERATE_FAIL.getCode(), ErrorCodeEnum.INVENTORY_QUANTITY_EXCEEDED.getMessage()); } //endregion } } } /** * @desc : 采购入库作废 * @date : 2024/3/26 9:24 * @author : 寇珊珊 */ @Transactional(rollbackFor = {Exception.class}) public ResponseResultVO purchaseInboundRepeal(String intoId) { //region 查询总单 查询明细 //根据id查询 此条入库单的数据还未更改前的数据 InboundResponse inboundResponse = inboundMapper.selectById(intoId); //根据总单id查询 List inboundItemResponseList = inboundItemMapper.selectByCond(new InboundItemQuery().setIntoId(inboundResponse.getIntoId())); //endregion //region 已入库作废 if (Constant.IntoStatus.YIRUKU.getName().equals(inboundResponse.getIntoStatus())) { //region 退账 if (inboundResponse.getReceivableId() != null) { accountService.reversePayable(inboundResponse.getIntoId(), Constant.InventoryDocCode.INTOBOUND.getTableName()); } //endregion //region 修改明细 for (InboundItemResponse inboundItemResponse : inboundItemResponseList) { //region 将库存需要的参数赋值 inboundItemResponse.setInventoryType(Constant.InventoryType.INBOUND.getName()); inboundItemResponse.setInventoryDocCode(Constant.InventoryDocCode.PURCHASE_ORDER.getValue()); inboundItemResponse.setIntoQty(inboundItemResponse.getIntoQty().negate()); inboundItemResponse.setIntoAmt(inboundItemResponse.getIntoAmt().negate()); //endregion //region 编辑明细 赋值 赋值明细 防止作废的单据查不到明细 故注掉下面代码 // InboundItem inboundItem = new InboundItem(); // inboundItem.setItemId(inboundItemResponse.getItemId()); // inboundItem.setFlgValid(false); // //修改 // inboundItemMapper.update(inboundItem, // new UpdateWrapper().lambda() // .eq(InboundItem::getItemId, UUID.fromString(inboundItem.getItemId())) // ); //endregion //region 销售明细 if (inboundItemResponse.getFromItemId() != null) { //根据id查询 PurchaseItemResponse purchaseItemResponse = purchaseItemMapper.selectById(inboundItemResponse.getFromItemId()); PurchaseItem purchaseItem = new PurchaseItem(); purchaseItem.setItemId(inboundItemResponse.getFromItemId()); purchaseItem.setIntoQty(inboundItemResponse.getIntoQty().negate()); purchaseItem.setIntoAmt(inboundItemResponse.getIntoAmt().negate()); //入库状态 String intoStatus = this.setIntoStatus(purchaseItemResponse.getIntoingQty(), purchaseItemResponse.getIntoQty().add(purchaseItem.getIntoQty()), purchaseItemResponse.getItemQty()); purchaseItem.setIntoStatus(intoStatus); int countRow = purchaseItemMapper.updateById(purchaseItem); //数量超出 if (countRow == 0) { throw new BaseBusinessException(ResponseCodeEnum.OPERATE_FAIL.getCode(), ErrorCodeEnum.INVENTORY_QUANTITY_EXCEEDED.getMessage()); } } //endregion } //endregion //region 修改入库总单 Inbound inbound = new Inbound(); inbound.setIntoId(inboundResponse.getIntoId()); inbound.setFlgValid(false); //修改 inboundMapper.update(inbound, new UpdateWrapper().lambda().eq(Inbound::getIntoId, UUID.fromString(inbound.getIntoId())) ); //endregion //region 修改采购总单 this.updateOrderMessageByRepeal(inboundResponse, inboundItemResponseList); //endregion //region 入账 if (inboundResponse.getReceivableId() != null) { accountService.accPayable(inboundResponse.getIntoId(), Constant.InventoryDocCode.INTOBOUND.getTableName()); } //endregion //region 调用库存 Map map = new HashMap<>(); map.put("delIntoDetail", inboundItemResponseList); inventoryService.operatingInventoryInformation(map); //endregion } //endregion //region 入库中、待入库作废 if (Constant.IntoStatus.RUKUZHONG.getName().equals(inboundResponse.getIntoStatus()) || Constant.IntoStatus.DAIRUKU.getName().equals(inboundResponse.getIntoStatus())) { //region 修改明细 for (InboundItemResponse inboundItemResponse : inboundItemResponseList) { //region 编辑明细 赋值 InboundItem inboundItem = new InboundItem(); inboundItem.setItemId(inboundItemResponse.getItemId()); inboundItem.setIntoingQty(BigDecimal.ZERO); inboundItem.setIntoingAmt(BigDecimal.ZERO); // inboundItem.setFlgValid(false); //修改 inboundItemMapper.update(inboundItem, new UpdateWrapper().lambda() .eq(InboundItem::getItemId, UUID.fromString(inboundItem.getItemId())) ); //endregion //region 销售明细 if (inboundItemResponse.getFromItemId() != null) { //根据id查询 PurchaseItemResponse purchaseItemResponse = purchaseItemMapper.selectById(inboundItemResponse.getFromItemId()); PurchaseItem purchaseItem = new PurchaseItem(); purchaseItem.setItemId(inboundItemResponse.getFromItemId()); purchaseItem.setIntoingQty(inboundItemResponse.getIntoingQty().negate()); purchaseItem.setIntoingAmt(inboundItemResponse.getIntoingAmt().negate()); //入库状态 String intoStatus = this.setIntoStatus(purchaseItemResponse.getIntoingQty().add(purchaseItem.getIntoingQty()), purchaseItemResponse.getIntoQty(), purchaseItemResponse.getItemQty()); purchaseItem.setIntoStatus(intoStatus); int countRow = purchaseItemMapper.updateById(purchaseItem); //数量超出 if (countRow == 0) { throw new BaseBusinessException(ResponseCodeEnum.OPERATE_FAIL.getCode(), ErrorCodeEnum.INVENTORY_QUANTITY_EXCEEDED.getMessage()); } } //endregion } //endregion //region 修改入库总单 Inbound inbound = new Inbound(); inbound.setIntoId(inboundResponse.getIntoId()); inbound.setIntoingQty(BigDecimal.ZERO); inbound.setIntoAmt(BigDecimal.ZERO); inbound.setFlgValid(false); //修改 inboundMapper.update(inbound, new UpdateWrapper().lambda().eq(Inbound::getIntoId, UUID.fromString(inbound.getIntoId())) ); //endregion //region 修改采购总单 this.updateOrderMessageByRepeal(inboundResponse, inboundItemResponseList); //endregion } //endregion return ResponseResultUtil.success(); } /** * @desc : 采购入库作废修改采购订单信息 * @date : 2024/7/6 15:27 * @author : 寇珊珊 */ @Transactional(rollbackFor = {Exception.class}) public void updateOrderMessageByRepeal(InboundResponse inboundResponse, List itemList) { //出库明细汇总 Map> purchaseIntoItemListMap = itemList.stream().collect(Collectors.groupingBy(InboundItemResponse::getFromId)); //出库明细汇总循环 for (String fromId : purchaseIntoItemListMap.keySet()) { //region 提取新建分组后的明细 //分组后的明细 原入库数量和金额总和 List purchaseIntoItemListGroup = purchaseIntoItemListMap.get(fromId); BigDecimal updatePurchaseIntoQty = BigDecimal.ZERO; BigDecimal updatePurchaseIntoAmt = BigDecimal.ZERO; BigDecimal updatePurchaseIntoingQty = BigDecimal.ZERO; BigDecimal updatePurchaseIntoingAmt = BigDecimal.ZERO; //已入库 if (Constant.IntoStatus.YIRUKU.getName().equals(inboundResponse.getIntoStatus())) { updatePurchaseIntoQty = purchaseIntoItemListGroup.stream().map(InboundItemResponse::getIntoQty).reduce(BigDecimal.ZERO, BigDecimal::add).setScale(6, BigDecimal.ROUND_HALF_UP); updatePurchaseIntoAmt = purchaseIntoItemListGroup.stream().map(InboundItemResponse::getOutQty).reduce(BigDecimal.ZERO, BigDecimal::add).setScale(2, BigDecimal.ROUND_HALF_UP); } //入库中 else { updatePurchaseIntoingQty = purchaseIntoItemListGroup.stream().map(InboundItemResponse::getIntoingQty).reduce(BigDecimal.ZERO, BigDecimal::add).setScale(6, BigDecimal.ROUND_HALF_UP); updatePurchaseIntoingAmt = purchaseIntoItemListGroup.stream().map(InboundItemResponse::getIntoingAmt).reduce(BigDecimal.ZERO, BigDecimal::add).setScale(2, BigDecimal.ROUND_HALF_UP); } //endregion //region 反写订单数据 //根据id查询 PurchaseResponse purchaseResponse = purchaseMapper.selectById(fromId); Purchase purchase = new Purchase(); purchase.setPurId(fromId); //已入库 if (Constant.IntoStatus.YIRUKU.getName().equals(purchaseResponse.getIntoStatus())) { purchase.setIntoQty(updatePurchaseIntoQty.negate()); purchase.setIntoAmt(updatePurchaseIntoAmt.negate()); //入库转态 String intoStatus = this.setIntoStatus(purchaseResponse.getIntoingQty(), purchaseResponse.getIntoQty().add(purchase.getIntoQty()), purchaseResponse.getSumQuantity()); purchase.setIntoStatus(intoStatus); } //入库中 else if (Constant.IntoStatus.RUKUZHONG.getName().equals(purchaseResponse.getIntoStatus())) { purchase.setIntoingQty(updatePurchaseIntoingQty.negate()); purchase.setIntoingAmt(updatePurchaseIntoingAmt.negate()); //入库状态 String intoStatus = this.setIntoStatus(purchaseResponse.getIntoingQty().add(purchase.getIntoingQty()), purchaseResponse.getIntoQty(), purchaseResponse.getSumQuantity()); purchase.setIntoStatus(intoStatus); } //修改 int countRow = purchaseMapper.updateById(purchase); //数量超出 if (countRow == 0) { throw new BaseBusinessException(ResponseCodeEnum.OPERATE_FAIL.getCode(), ErrorCodeEnum.INVENTORY_QUANTITY_EXCEEDED.getMessage()); } //endregion } } /** * @desc : 采购入库办理 * @date : 2024/3/7 15:47 * @author : 寇珊珊 */ @Transactional(rollbackFor = {Exception.class}) public ResponseResultVO purchaseHandleInbound(InboundVO inboundVO) { //region 根据id查询 此条入库单的数据还未更改前的数据 InboundResponse inboundResponse = inboundMapper.selectById(inboundVO.getIntoId()); //endregion //region 退账 if (inboundResponse.getReceivableId() != null) { accountService.reversePayable(inboundResponse.getIntoId(), Constant.InventoryDocCode.INTOBOUND.getTableName()); } //endregion //region 编辑明细 //校验明细 if (inboundVO.getItemList().size() == 0) { throw new BaseBusinessException(ErrorCodeEnum.INBOUND_ITEM_NOT_EXIST.getCode(), ErrorCodeEnum.INBOUND_ITEM_NOT_EXIST.getMessage()); } for (InboundItemVO inboundItemVO : inboundVO.getItemList()) { //region 编辑明细 if (inboundItemVO.getItemId() != null) { //入库明细根据id查询 InboundItemResponse inboundItemResponse = inboundItemMapper.selectById(inboundItemVO.getItemId()); //region 校验数量是否超出 if (inboundItemVO.getIntoingQty().compareTo(inboundItemResponse.getIntoingQty()) > 0) { throw new BaseBusinessException(ErrorCodeEnum.CANNOT_EXCEED_THE_QUANTITY_IN_THE_OUTBOUND_SHIPMENT.getCode(), ErrorCodeEnum.CANNOT_EXCEED_THE_QUANTITY_IN_THE_OUTBOUND_SHIPMENT.getMessage()); } //endregion //region 反写订单总单 数据需要 把查出来的出库中数量用别的变量存起来 inboundItemVO.setUpdatePurchaseIntoingQty(inboundItemResponse.getIntoingQty()); inboundItemVO.setUpdatePurchaseIntoingAmt(inboundItemResponse.getIntoingAmt()); //endregion inboundItemVO .setIntoQty(inboundItemResponse.getIntoQty().add(inboundItemVO.getIntoingQty())) .setIntoAmt(inboundItemResponse.getIntoAmt().add(inboundItemVO.getIntoingAmt())) .setIntoingQty(BigDecimal.ZERO) .setIntoingAmt(BigDecimal.ZERO) ; //入库状态 String intoStatus = this.setIntoStatus(inboundItemVO.getIntoingQty(), inboundItemVO.getIntoQty()); inboundItemVO.setIntoStatus(intoStatus); //实体转换 InboundItem inboundItem = inboundItemConvert.convertToPo(inboundItemVO); //修改 inboundItemMapper.update(inboundItem, new UpdateWrapper().lambda() .eq(InboundItem::getItemId, UUID.fromString(inboundItem.getItemId())) ); //region 将库存需要的参数赋值 inboundItemVO.setInventoryType(Constant.InventoryType.INBOUND.getName()); inboundItemVO.setInventoryDocCode(Constant.InventoryDocCode.PURCHASE_ORDER.getValue()); //编辑之前的数 if (inboundItemResponse.getIntoQty().compareTo(BigDecimal.ZERO) > 0) { inboundItemVO.setQtyBeforeUpdate(inboundItemResponse.getIntoQty()); inboundItemVO.setAmtBeforeUpdate(inboundItemResponse.getIntoAmt()); } inboundItemVO.setAddOrEditFlag(true); //endregion } //endregion //region 新建明细 else { inboundItemVO .setIntoQty(inboundItemVO.getIntoingQty()) .setIntoAmt(inboundItemVO.getIntoingAmt()) .setIntoId(inboundVO.getIntoId()) .setIntoType(Constant.IntoType.SALE.getName()) .setIntoingQty(BigDecimal.ZERO) .setIntoingAmt(BigDecimal.ZERO) ; //入库状态 String intoStatus = this.setIntoStatus(inboundItemVO.getIntoingQty(), inboundItemVO.getIntoQty()); inboundItemVO.setIntoStatus(intoStatus); //实体转换 InboundItem inboundItem = inboundItemConvert.convertToPo(inboundItemVO); //新建 inboundItemMapper.insert(inboundItem); inboundItemVO.setItemId(inboundItem.getItemId()); //region 将库存需要的参数赋值 inboundItemVO.setInventoryType(Constant.InventoryType.INBOUND.getName()); inboundItemVO.setInventoryDocCode(Constant.InventoryDocCode.PURCHASE_ORDER.getValue()); inboundItemVO.setAddOrEditFlag(true); //endregion } //endregion //region 采购明细 if (inboundItemVO.getFromItemId() != null) { //根据id查询 PurchaseItemResponse purchaseItemResponse = purchaseItemMapper.selectById(inboundItemVO.getFromItemId()); //赋值（这里重写了更新方法，数量在更新方法中有数据库院士数量+本次数量） PurchaseItem purchaseItem = new PurchaseItem(); purchaseItem.setItemId(inboundItemVO.getFromItemId()); purchaseItem.setIntoingQty(inboundItemVO.getIntoQty().negate()); purchaseItem.setIntoingAmt(inboundItemVO.getIntoAmt().negate()); purchaseItem.setIntoQty(inboundItemVO.getIntoQty()); purchaseItem.setIntoAmt(inboundItemVO.getIntoAmt()); //入库状态 String purItemIntoStatus = this.setIntoStatus(purchaseItemResponse.getIntoingQty().add(purchaseItem.getIntoingQty()), purchaseItemResponse.getIntoQty().add(purchaseItem.getIntoQty()), purchaseItemResponse.getItemQty()); purchaseItem.setIntoStatus(purItemIntoStatus); int countRow = purchaseItemMapper.updateById(purchaseItem); //数量超出 if (countRow == 0) { throw new BaseBusinessException(ResponseCodeEnum.OPERATE_FAIL.getCode(), ErrorCodeEnum.INVENTORY_QUANTITY_EXCEEDED.getMessage()); } } //endregion } //endregion //region 删除明细 BigDecimal delIntoingQty = BigDecimal.ZERO; BigDecimal delIntoingAmt = BigDecimal.ZERO; BigDecimal delIntoQty = BigDecimal.ZERO; BigDecimal delIntoAmt = BigDecimal.ZERO; if (inboundVO.getDeleteItemList() != null && inboundVO.getDeleteItemList().size() > 0) { delIntoingQty = inboundVO.getDeleteItemList().stream().map(InboundItemVO::getIntoingQty).reduce(BigDecimal.ZERO, BigDecimal::add).setScale(6, BigDecimal.ROUND_HALF_UP); delIntoingAmt = inboundVO.getDeleteItemList().stream().map(InboundItemVO::getIntoingAmt).reduce(BigDecimal.ZERO, BigDecimal::add).setScale(2, BigDecimal.ROUND_HALF_UP); delIntoQty = inboundVO.getDeleteItemList().stream().map(InboundItemVO::getIntoQty).reduce(BigDecimal.ZERO, BigDecimal::add).setScale(6, BigDecimal.ROUND_HALF_UP); delIntoAmt = inboundVO.getDeleteItemList().stream().map(InboundItemVO::getIntoingAmt).reduce(BigDecimal.ZERO, BigDecimal::add).setScale(2, BigDecimal.ROUND_HALF_UP); for (InboundItemVO inboundItemVO : inboundVO.getDeleteItemList()) { if (inboundItemVO.getItemId() != null) { //region 将库存需要的参数赋值 inboundItemVO.setInventoryType(Constant.InventoryType.INBOUND.getName()); inboundItemVO.setInventoryDocCode(Constant.InventoryDocCode.PURCHASE_ORDER.getValue()); //endregion InboundItem inboundItem = inboundItemConvert.convertToPo(inboundItemVO); inboundItem.setFlgValid(false); //修改 inboundItemMapper.update(inboundItem, new UpdateWrapper().lambda() .eq(InboundItem::getItemId, UUID.fromString(inboundItem.getItemId())) ); } //region 采购 if (inboundItemVO.getFromItemId() != null) { //region 采购订单明细 //赋值（这里重写了更新方法，数量在更新方法中有数据库院士数量+本次数量） PurchaseItem purchaseItem = new PurchaseItem(); purchaseItem.setItemId(inboundItemVO.getFromItemId()); purchaseItem.setIntoingQty(inboundItemVO.getIntoingQty().negate()); purchaseItem.setIntoingAmt(inboundItemVO.getIntoingAmt().negate()); purchaseItem.setIntoQty(inboundItemVO.getIntoQty().negate()); purchaseItem.setIntoAmt(inboundItemVO.getIntoAmt().negate()); //根据id查询 PurchaseItemResponse purchaseItemResponse = purchaseItemMapper.selectById(inboundItemVO.getFromItemId()); //入库状态 String intoStatus = this.setIntoStatus(purchaseItemResponse.getIntoingQty().add(purchaseItem.getIntoingQty()), purchaseItemResponse.getIntoQty().add(purchaseItem.getIntoQty()), purchaseItemResponse.getItemQty()); purchaseItem.setIntoStatus(intoStatus); int countRow = purchaseItemMapper.updateById(purchaseItem); //数量超出 if (countRow == 0) { throw new BaseBusinessException(ResponseCodeEnum.OPERATE_FAIL.getCode(), ErrorCodeEnum.INVENTORY_QUANTITY_EXCEEDED.getMessage()); } //endregion } //endregion } } //endregion //region 编辑总单 BigDecimal sumIntoQty = inboundVO.getItemList().stream().map(InboundItemVO::getIntoQty).reduce(BigDecimal.ZERO, BigDecimal::add).setScale(6, BigDecimal.ROUND_HALF_UP); BigDecimal sumIntoAmt = inboundVO.getItemList().stream().map(InboundItemVO::getIntoAmt).reduce(BigDecimal.ZERO, BigDecimal::add).setScale(2, BigDecimal.ROUND_HALF_UP); inboundVO.setIntoQty(sumIntoQty); inboundVO.setIntoAmt(sumIntoAmt); inboundVO.setIntoingQty(BigDecimal.ZERO); inboundVO.setIntoingAmt(BigDecimal.ZERO); //入库状态 String intoStatus = this.setIntoStatus(inboundVO.getIntoingQty(), inboundVO.getIntoQty()); inboundVO.setIntoStatus(intoStatus); //实体转换 Inbound inbound = inboundConvert.convertToPo(inboundVO); //修改 inboundMapper.update(inbound, new UpdateWrapper().lambda().eq(Inbound::getIntoId, UUID.fromString(inbound.getIntoId())) ); //endregion //region 修改采购订单 this.updateOrderMessageByHandle(inboundVO.getItemList(),inboundVO.getDeleteItemList()); //endregion //region 入账 accountService.accPayable(inboundVO.getIntoId(), Constant.InventoryDocCode.INTOBOUND.getTableName()); //endregion //region 调用库存 Map map = new HashMap<>(); map.put("intoDetail", inboundVO.getItemList()); map.put("delIntoDetail", inboundVO.getDeleteItemList()); inventoryService.operatingInventoryInformation(map); //endregion return ResponseResultUtil.success(inboundVO); } /** * @desc : 采购入库办理修改采购订单信息 * @date : 2024/7/8 14:03 * @author : 寇珊珊 */ @Transactional(rollbackFor = {Exception.class}) public void updateOrderMessageByHandle(List itemList, List deleteItemList) { //出库明细汇总 Map> purchaseIntoItemVOListMap = itemList.stream().collect(Collectors.groupingBy(InboundItemVO::getFromId)); //出库明细删除汇总 Map> delPurchaseIntoItemVOListMap = deleteItemList.stream().collect(Collectors.groupingBy(InboundItemVO::getFromId)); //出库明细汇总循环g for (String fromId : purchaseIntoItemVOListMap.keySet()) { //有需要删除的办理数据 if (delPurchaseIntoItemVOListMap != null && delPurchaseIntoItemVOListMap.keySet().size() > 0) { //入库明细删除汇总循环 for (String delFromId : delPurchaseIntoItemVOListMap.keySet()) { //新建入库明细来源Id = 删除入库明细来源Id if (fromId.equals(delFromId)) { //region 提取新建分组后的明细 List purchaseIntoItemVOListGroup = purchaseIntoItemVOListMap.get(fromId); //分组后的明细 入库数量和金额总和 BigDecimal purchaseSumQty = purchaseIntoItemVOListGroup.stream().map(InboundItemVO::getIntoQty).reduce(BigDecimal.ZERO, BigDecimal::add).setScale(6, BigDecimal.ROUND_HALF_UP); BigDecimal purchaseSumAmt = purchaseIntoItemVOListGroup.stream().map(InboundItemVO::getIntoAmt).reduce(BigDecimal.ZERO, BigDecimal::add).setScale(2, BigDecimal.ROUND_HALF_UP); //分组后的明细 原入库数量和金额总和 BigDecimal updatePurchaseIntoingQty = purchaseIntoItemVOListGroup.stream().filter(it->it.getUpdatePurchaseIntoingQty()!=null).map(InboundItemVO::getUpdatePurchaseIntoingQty).reduce(BigDecimal.ZERO, BigDecimal::add).setScale(6, BigDecimal.ROUND_HALF_UP); BigDecimal updatePurchaseIntoingAmt = purchaseIntoItemVOListGroup.stream().filter(it->it.getUpdatePurchaseIntoingAmt()!=null).map(InboundItemVO::getUpdatePurchaseIntoingAmt).reduce(BigDecimal.ZERO, BigDecimal::add).setScale(2, BigDecimal.ROUND_HALF_UP); //endregion //region 提取删除分组后的明细 List delPurchaseIntoItemVOListGroup = delPurchaseIntoItemVOListMap.get(delFromId); BigDecimal purchaseDelIntoingQty = delPurchaseIntoItemVOListGroup.stream().map(InboundItemVO::getIntoingQty).reduce(BigDecimal.ZERO, BigDecimal::add).setScale(6, BigDecimal.ROUND_HALF_UP); BigDecimal purchaseDelIntoingAmt = delPurchaseIntoItemVOListGroup.stream().map(InboundItemVO::getIntoingAmt).reduce(BigDecimal.ZERO, BigDecimal::add).setScale(2, BigDecimal.ROUND_HALF_UP); BigDecimal purchaseDelIntoQty = delPurchaseIntoItemVOListGroup.stream().map(InboundItemVO::getIntoQty).reduce(BigDecimal.ZERO, BigDecimal::add).setScale(6, BigDecimal.ROUND_HALF_UP); BigDecimal purchaseDelIntoAmt = delPurchaseIntoItemVOListGroup.stream().map(InboundItemVO::getIntoAmt).reduce(BigDecimal.ZERO, BigDecimal::add).setScale(2, BigDecimal.ROUND_HALF_UP); //endregion //region 反写订单数据 //根据id查询 PurchaseResponse purchaseResponse = purchaseMapper.selectById(fromId); Purchase purchase = new Purchase(); purchase.setPurId(fromId); purchase.setIntoQty(purchaseSumQty.subtract(purchaseDelIntoQty)); purchase.setIntoAmt(purchaseSumAmt.subtract(purchaseDelIntoAmt)); purchase.setIntoingQty((updatePurchaseIntoingQty.add(purchaseDelIntoingQty)).negate()); purchase.setIntoingAmt((updatePurchaseIntoingAmt.add(purchaseDelIntoingAmt)).negate()); //入库状态 String purIntoStatus = this.setIntoStatus(purchaseResponse.getIntoingQty().add(purchase.getIntoingQty()), purchaseResponse.getIntoQty().add(purchase.getIntoQty()), purchaseResponse.getSumQuantity()); purchase.setIntoStatus(purIntoStatus); //修改 int countRow = purchaseMapper.updateById(purchase); //数量超出 if (countRow == 0) { throw new BaseBusinessException(ResponseCodeEnum.OPERATE_FAIL.getCode(), ErrorCodeEnum.INVENTORY_QUANTITY_EXCEEDED.getMessage()); } //endregion } } } //没有需要删除的办理数据 else { //region 提取新建分组后的明细 List purchaseIntoItemVOListGroup = purchaseIntoItemVOListMap.get(fromId); //分组后的明细 入库数量和金额总和 BigDecimal purchaseSumQty = purchaseIntoItemVOListGroup.stream().map(InboundItemVO::getIntoQty).reduce(BigDecimal.ZERO, BigDecimal::add).setScale(6, BigDecimal.ROUND_HALF_UP); BigDecimal purchaseSumAmt = purchaseIntoItemVOListGroup.stream().map(InboundItemVO::getIntoAmt).reduce(BigDecimal.ZERO, BigDecimal::add).setScale(2, BigDecimal.ROUND_HALF_UP); //分组后的明细 原入库数量和金额总和 BigDecimal updatePurchaseIntoingQty = purchaseIntoItemVOListGroup.stream().filter(it->it.getUpdatePurchaseIntoingQty()!=null).map(InboundItemVO::getUpdatePurchaseIntoingQty).reduce(BigDecimal.ZERO, BigDecimal::add).setScale(6, BigDecimal.ROUND_HALF_UP); BigDecimal updatePurchaseIntoingAmt = purchaseIntoItemVOListGroup.stream().filter(it->it.getUpdatePurchaseIntoingAmt()!=null).map(InboundItemVO::getUpdatePurchaseIntoingAmt).reduce(BigDecimal.ZERO, BigDecimal::add).setScale(2, BigDecimal.ROUND_HALF_UP); //endregion //region 反写订单数据 //根据id查询 PurchaseResponse purchaseResponse = purchaseMapper.selectById(fromId); Purchase purchase = new Purchase(); purchase.setPurId(fromId); purchase.setIntoQty(purchaseSumQty); purchase.setIntoAmt(purchaseSumAmt); purchase.setIntoingAmt(updatePurchaseIntoingQty.negate()); purchase.setIntoingQty(updatePurchaseIntoingAmt.negate()); //入库状态 String purIntoStatus = this.setIntoStatus(purchaseResponse.getIntoingQty().add(purchase.getIntoingQty()), purchaseResponse.getIntoQty().add(purchase.getIntoQty()), purchaseResponse.getSumQuantity()); purchase.setIntoStatus(purIntoStatus); //修改 int countRow = purchaseMapper.updateById(purchase); //数量超出 if (countRow == 0) { throw new BaseBusinessException(ResponseCodeEnum.OPERATE_FAIL.getCode(), ErrorCodeEnum.INVENTORY_QUANTITY_EXCEEDED.getMessage()); } //endregion } } } /** * @desc : 采购入库撤销 * @date : 2024/3/7 17:06 * @author : 寇珊珊 */ @Transactional(rollbackFor = {Exception.class}) public ResponseResultVO purchaseInboundCancel(InboundVO inboundVO) { //region 查询入库总单数据信息 InboundResponse inboundResponse = inboundMapper.selectById(inboundVO.getIntoId()); //endregion //region 根据总单id查明细 List inboundItemResponseList = inboundItemMapper.selectByCond(new InboundItemQuery().setIntoId(inboundResponse.getIntoId())); //endregion //region 退账 if (inboundResponse.getReceivableId() != null) { accountService.reversePayable(inboundVO.getIntoId(), Constant.InventoryDocCode.INTOBOUND.getTableName()); } //endregion //region 修改订单数据信息 this.updateOrderMessageByCancel(inboundItemResponseList); //endregion //region 修改总单数据信息 Inbound inbound = new Inbound(); inbound.setIntoId(inboundVO.getIntoId()); inbound.setIntoDate(null); inbound.setIntoStatus(Constant.IntoStatus.RUKUZHONG.getName()); inbound.setIntoingQty(inboundResponse.getIntoingQty().add(inboundResponse.getIntoQty())); inbound.setIntoingAmt(inboundResponse.getIntoingAmt().add(inboundResponse.getIntoAmt())); inbound.setIntoQty(BigDecimal.ZERO); inbound.setIntoAmt(BigDecimal.ZERO); //修改 inboundMapper.update(inbound, new UpdateWrapper().lambda() .eq(Inbound::getIntoId, UUID.fromString(inbound.getIntoId())) ); //endregion //region 明细数据 for (InboundItemResponse inboundItemResponse : inboundItemResponseList) { //region 修改采购明细数据信息 if (inboundItemResponse.getFromItemId() != null) { //根据id查询 PurchaseItemResponse purchaseItemResponse = purchaseItemMapper.selectById(inboundItemResponse.getFromItemId()); //赋值 （这里重写了更新方法，数量在更新方法中有数据库院士数量+本次数量） PurchaseItem purchaseItem = new PurchaseItem(); purchaseItem.setItemId(inboundItemResponse.getFromItemId()); purchaseItem.setIntoQty(inboundItemResponse.getIntoQty().negate()); purchaseItem.setIntoAmt(inboundItemResponse.getIntoAmt().negate()); purchaseItem.setIntoingQty(inboundItemResponse.getIntoQty()); purchaseItem.setIntoingAmt(inboundItemResponse.getIntoAmt()); //入库状态 String intoStatus = this.setIntoStatus(purchaseItemResponse.getIntoingQty().add(purchaseItem.getIntoingQty()), purchaseItemResponse.getIntoQty().add(purchaseItem.getIntoQty()), purchaseItemResponse.getItemQty()); purchaseItem.setIntoStatus(intoStatus); //修改 int countRow = purchaseItemMapper.updateById(purchaseItem); //数量超出 if (countRow == 0) { throw new BaseBusinessException(ResponseCodeEnum.OPERATE_FAIL.getCode(), ErrorCodeEnum.INVENTORY_QUANTITY_EXCEEDED.getMessage()); } } //endregion //region修改入库明细信息 InboundItem inboundItem = new InboundItem(); //region 将库存需要的参数赋值 inboundItemResponse.setInventoryType(Constant.InventoryType.INBOUND.getName()); inboundItemResponse.setInventoryDocCode(Constant.InventoryDocCode.PURCHASE_ORDER.getValue()); inboundItemResponse.setIntoQty(inboundItemResponse.getIntoQty().negate()); inboundItemResponse.setIntoAmt(inboundItemResponse.getIntoAmt().negate()); //endregion inboundItem .setIntoId(inbound.getIntoId()) .setIntoStatus(Constant.IntoStatus.RUKUZHONG.getName()) .setIntoingQty(inboundItemResponse.getIntoingQty().add(inboundItemResponse.getIntoQty())) .setIntoingAmt(inboundItemResponse.getIntoingAmt().add(inboundItemResponse.getIntoAmt())) .setIntoQty(BigDecimal.ZERO) .setIntoAmt(BigDecimal.ZERO) .setCostPrice(BigDecimal.ZERO) .setCostAmt(BigDecimal.ZERO) .setItemId(inboundItemResponse.getItemId()); //入库状态 String intoStatus = this.setIntoStatus(inboundItem.getIntoingQty(), inboundItem.getIntoQty()); inboundItem.setIntoStatus(intoStatus); //修改 inboundItemMapper.update(inboundItem, new UpdateWrapper().lambda() .eq(InboundItem::getItemId, UUID.fromString(inboundItem.getItemId())) ); //endregion } //endregion //region 调用库存 Map map = new HashMap<>(); map.put("delIntoDetail", inboundItemResponseList); inventoryService.operatingInventoryInformation(map); //endregion return ResponseResultUtil.success(); } /** * @desc : 采购入库撤销修改采购订单信息 * @date : 2024/7/8 16:50 * @author : 寇珊珊 */ @Transactional(rollbackFor = {Exception.class}) public void updateOrderMessageByCancel(List itemList) { //出库明细汇总 Map> purchaseIntoItemListMap = itemList.stream().collect(Collectors.groupingBy(InboundItemResponse::getFromId)); //出库明细汇总循环 for (String fromId : purchaseIntoItemListMap.keySet()) { //region 提取新建分组后的明细 List purchaseIntoItemListGroup = purchaseIntoItemListMap.get(fromId); //分组后的明细 入库数量和金额总和 BigDecimal purchaseSumQty = purchaseIntoItemListGroup.stream().map(InboundItemResponse::getIntoQty).reduce(BigDecimal.ZERO, BigDecimal::add).setScale(6, BigDecimal.ROUND_HALF_UP); BigDecimal purchaseSumAmt = purchaseIntoItemListGroup.stream().map(InboundItemResponse::getIntoAmt).reduce(BigDecimal.ZERO, BigDecimal::add).setScale(2, BigDecimal.ROUND_HALF_UP); //endregion //region 反写订单数据 //根据id查询 //根据id查询 PurchaseResponse purchaseResponse = purchaseMapper.selectById(fromId); Purchase purchase = new Purchase(); purchase.setPurId(fromId); purchase.setIntoingQty(purchaseSumQty); purchase.setIntoingAmt(purchaseSumAmt); purchase.setIntoQty(purchaseSumQty.negate()); purchase.setIntoAmt(purchaseSumAmt.negate()); //入库状态 String intoStatus = this.setIntoStatus(purchaseResponse.getIntoingQty().add(purchase.getIntoingQty()), purchaseResponse.getIntoQty().add(purchase.getIntoQty()), purchaseResponse.getSumQuantity()); purchase.setIntoStatus(intoStatus); int countRow = purchaseMapper.updateById(purchase); //数量超出 if (countRow == 0) { throw new BaseBusinessException(ResponseCodeEnum.OPERATE_FAIL.getCode(), ErrorCodeEnum.INVENTORY_QUANTITY_EXCEEDED.getMessage()); } //endregion } } /** * @desc : 校验库存是否存在和库存量是否足够本次退货作废 * @date : 2024/7/6 10:52 * @author : 寇珊珊 */ @Transactional( rollbackFor = {Exception.class} ) public void checkInventoryExist(List inboundItemResponseList) { for (InboundItemResponse inboundItemResponse : inboundItemResponseList) { //存在标识 //根据sku，仓库，非标号查询 InventoryResponse inventoryResponse = null; if (inboundItemResponse.getSkuId() != null) { inventoryResponse = inventoryMapper.selectByOther(new InventoryQuery() .setSkuId(inboundItemResponse.getSkuId()) .setWhId(inboundItemResponse.getWhId()) .setNonStdCode(inboundItemResponse.getNonStdCode())); } //库存不存在 if (inventoryResponse == null) { //当前出库商品中在库存中不存在 throw new BaseBusinessException(ErrorCodeEnum.SKU_IS_NOT_IN_INVENTORY.getCode(), ErrorCodeEnum.SKU_IS_NOT_IN_INVENTORY.getMessage()); } //判断库存中的数量是否足够本次采购退货作废（采购退货作废等于出库） if (inventoryResponse.getInvQty().compareTo(inboundItemResponse.getIntoQty()) < 0) { //当前库存数量不足,不允许采购退货作废操作 throw new BaseBusinessException(ErrorCodeEnum.INSUFFICIENT_INVENTORY_NOT_ALLOW_PURCHASE_RETURN.getCode(), ErrorCodeEnum.INSUFFICIENT_INVENTORY_NOT_ALLOW_PURCHASE_RETURN.getMessage()); } } } /** * @desc : 一键作废 * @date : 2024/7/6 11:03 * @author : 寇珊珊 */ @Transactional(rollbackFor = {Exception.class}) public ResponseResultVO oneKeyPurchaseInboundRepeal(String orderId) { List InboundItemResponses = inboundItemMapper.selectByCond(new InboundItemQuery().setSPurId(orderId)); if (InboundItemResponses != null && InboundItemResponses.size() > 0) { Map> inboundItemMap = InboundItemResponses.stream().collect(Collectors.groupingBy(InboundItemResponse::getIntoId)); for (String str : inboundItemMap.keySet()) { //region 查询总单 查询明细 //根据id查询 此条入库单的数据还未更改前的数据 InboundResponse inboundResponse = inboundMapper.selectById(str); //根据总单id查询 List inboundItemResponseList = inboundItemMapper.selectByCond(new InboundItemQuery().setOutId(inboundResponse.getIntoId())); //endregion //region 已入库状态作废 if (Constant.IntoStatus.YIRUKU.getName().equals(inboundResponse.getIntoStatus())) { //region 查询当前订单下的入库单的库存是否足够允许作废 this.checkInventoryExist(inboundItemResponseList); //endregion //region 退账 if (inboundResponse.getReceivableId() != null) { accountService.reversePayable(inboundResponse.getIntoId(), Constant.InventoryDocCode.INTOBOUND.getTableName()); } //endregion //region 修改明细 for (InboundItemResponse inboundItemResponse : inboundItemResponseList) { //region 将库存需要的参数赋值 inboundItemResponse.setInventoryType(Constant.InventoryType.INBOUND.getName()); inboundItemResponse.setInventoryDocCode(Constant.InventoryDocCode.PURCHASE_ORDER.getValue()); inboundItemResponse.setIntoQty(inboundItemResponse.getIntoQty().negate()); inboundItemResponse.setIntoAmt(inboundItemResponse.getIntoAmt().negate()); //endregion //region 编辑明细 赋值 赋值明细 防止作废的单据查不到明细 故注掉下面代码 // InboundItem inboundItem = new InboundItem(); // inboundItem.setItemId(inboundItemResponse.getItemId()); // inboundItem.setFlgValid(false); // //修改 // inboundItemMapper.update(inboundItem, // new UpdateWrapper().lambda() // .eq(InboundItem::getItemId, UUID.fromString(inboundItem.getItemId())) // ); //endregion //region 销售明细 if (inboundItemResponse.getFromItemId() != null) { //根据id查询 PurchaseItemResponse purchaseItemResponse = purchaseItemMapper.selectById(inboundItemResponse.getFromItemId()); PurchaseItem purchaseItem = new PurchaseItem(); purchaseItem.setItemId(inboundItemResponse.getFromItemId()); purchaseItem.setIntoQty(inboundItemResponse.getIntoQty().negate()); purchaseItem.setIntoAmt(inboundItemResponse.getIntoAmt().negate()); //入库状态 String intoStatus = this.setIntoStatus(purchaseItemResponse.getIntoingQty(), purchaseItemResponse.getIntoQty().add(purchaseItem.getIntoQty()), purchaseItemResponse.getItemQty()); purchaseItem.setIntoStatus(intoStatus); int countRow = purchaseItemMapper.updateById(purchaseItem); //数量超出 if (countRow == 0) { throw new BaseBusinessException(ResponseCodeEnum.OPERATE_FAIL.getCode(), ErrorCodeEnum.INVENTORY_QUANTITY_EXCEEDED.getMessage()); } } //endregion } //endregion //region 修改入库总单 Inbound inbound = new Inbound(); inbound.setIntoId(inboundResponse.getIntoId()); inbound.setFlgValid(false); //修改 inboundMapper.update(inbound, new UpdateWrapper().lambda().eq(Inbound::getIntoId, UUID.fromString(inbound.getIntoId())) ); //endregion //region 修改采购总单 this.updateOrderMessageByRepeal(inboundResponse, inboundItemResponseList); //endregion //region 入账 if (inboundResponse.getReceivableId() != null) { accountService.accPayable(inboundResponse.getIntoId(), Constant.InventoryDocCode.INTOBOUND.getTableName()); } //endregion //region 调用库存 Map map = new HashMap<>(); map.put("delIntoDetail", inboundItemResponseList); inventoryService.operatingInventoryInformation(map); //endregion } //endregion //region 出库中、待出库状态作废 if (Constant.IntoStatus.DAIRUKU.getName().equals(inboundResponse.getIntoStatus()) || Constant.IntoStatus.RUKUZHONG.getName().equals(inboundResponse.getIntoStatus())) { //region 修改明细 for (InboundItemResponse inboundItemResponse : inboundItemResponseList) { //region 编辑明细 赋值 InboundItem inboundItem = new InboundItem(); inboundItem.setItemId(inboundItemResponse.getItemId()); inboundItem.setIntoingQty(BigDecimal.ZERO); inboundItem.setIntoingAmt(BigDecimal.ZERO); // inboundItem.setFlgValid(false); //修改 inboundItemMapper.update(inboundItem, new UpdateWrapper().lambda() .eq(InboundItem::getItemId, UUID.fromString(inboundItem.getItemId())) ); //endregion //region 销售明细 if (inboundItemResponse.getFromItemId() != null) { //根据id查询 PurchaseItemResponse purchaseItemResponse = purchaseItemMapper.selectById(inboundItemResponse.getFromItemId()); PurchaseItem purchaseItem = new PurchaseItem(); purchaseItem.setItemId(inboundItemResponse.getFromItemId()); purchaseItem.setIntoingQty(inboundItemResponse.getIntoingQty().negate()); purchaseItem.setIntoingAmt(inboundItemResponse.getIntoingAmt().negate()); //入库状态 String intoStatus = this.setIntoStatus(purchaseItemResponse.getIntoingQty().add(purchaseItem.getIntoingQty()), purchaseItemResponse.getIntoQty(), purchaseItemResponse.getItemQty()); purchaseItem.setIntoStatus(intoStatus); int countRow = purchaseItemMapper.updateById(purchaseItem); //数量超出 if (countRow == 0) { throw new BaseBusinessException(ResponseCodeEnum.OPERATE_FAIL.getCode(), ErrorCodeEnum.INVENTORY_QUANTITY_EXCEEDED.getMessage()); } } //endregion } //endregion //region 修改入库总单 Inbound inbound = new Inbound(); inbound.setIntoId(inboundResponse.getIntoId()); inbound.setIntoingQty(BigDecimal.ZERO); inbound.setIntoAmt(BigDecimal.ZERO); inbound.setFlgValid(false); //修改 inboundMapper.update(inbound, new UpdateWrapper().lambda().eq(Inbound::getIntoId, UUID.fromString(inbound.getIntoId())) ); //endregion //region 修改采购总单 this.updateOrderMessageByRepeal(inboundResponse, inboundItemResponseList); //endregion } //endregion } } return ResponseResultUtil.success(); } /** * @desc : 入库状态通用（目前本页面） * @date : 2024/3/9 8:59 * @author : 寇珊珊 */ @Transactional(rollbackFor = {Exception.class}) public String setIntoStatus(BigDecimal intoingQty, BigDecimal intoQty) { //入库状态 String intoStatus = null; //已入库数量>0 入库中数量>0 if (intoQty.compareTo(BigDecimal.ZERO) >= 0 && intoingQty.compareTo(BigDecimal.ZERO) > 0) { //入库中 intoStatus = Constant.IntoStatus.RUKUZHONG.getName(); } //已入库数量=0 入库中数量=0 else if (intoQty.compareTo(BigDecimal.ZERO) == 0 && intoingQty.compareTo(BigDecimal.ZERO) == 0) { //待入库 intoStatus = Constant.IntoStatus.DAIRUKU.getName(); } //已入库数量>0 入库中数量=0 else if (intoQty.compareTo(BigDecimal.ZERO) > 0 && intoingQty.compareTo(BigDecimal.ZERO) == 0) { //已入库 intoStatus = Constant.IntoStatus.YIRUKU.getName(); } return intoStatus; } /** * @desc : 上游单据入库状态通用（目前本页面） * @date : 2024/4/1 17:14 * @author : 寇珊珊 */ @Transactional(rollbackFor = {Exception.class}) public String setIntoStatus(BigDecimal intoingQty, BigDecimal intoQty, BigDecimal sumQty) { //入库状态 String intoStatus = null; //入库中小于等于总数，已入库小于总数，并且入库中+已入库大于0 if (intoingQty.compareTo(sumQty) <= 0 && intoQty.compareTo(sumQty) < 0 && intoingQty.add(intoQty).compareTo(BigDecimal.ZERO) > 0) { //入库中 intoStatus = Constant.IntoStatus.RUKUZHONG.getName(); } //已入库数量=0 入库中数量=0 else if (intoQty.compareTo(BigDecimal.ZERO) == 0 && intoingQty.compareTo(BigDecimal.ZERO) == 0) { //待入库 intoStatus = Constant.IntoStatus.DAIRUKU.getName(); } //入库中+已入库 等于 总数 并且 入库中数量小于等于订单总数量 else if (intoingQty.compareTo(sumQty) < 0 && intoingQty.add(intoQty).compareTo(sumQty) == 0) { //已入库 intoStatus = Constant.IntoStatus.YIRUKU.getName(); } return intoStatus; } }