package zy.cloud.wms.manager.service.impl; import com.baomidou.mybatisplus.mapper.EntityWrapper; import com.core.common.Arith; import com.core.common.Cools; import com.core.common.R; import com.core.common.SnowflakeIdWorker; import com.core.exception.CoolException; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import zy.cloud.wms.common.config.CodeCoolException; import zy.cloud.wms.common.model.BillDto; import zy.cloud.wms.common.model.MatnrDto; import zy.cloud.wms.common.model.OrderStoDto; import zy.cloud.wms.common.service.MainService; import zy.cloud.wms.common.service.asrs.AsrsService; import zy.cloud.wms.common.service.asrs.entity.Result1; import zy.cloud.wms.common.service.erp.ErpR; import zy.cloud.wms.common.service.erp.ErpService; import zy.cloud.wms.common.utils.VersionUtils; import zy.cloud.wms.manager.entity.*; import zy.cloud.wms.manager.entity.param.*; import zy.cloud.wms.manager.entity.result.StoPrintVo; import zy.cloud.wms.manager.service.*; import java.util.*; /** * Created by vincent on 2021/2/25 */ @Slf4j @Service("workService") public class WorkServiceImpl implements WorkService { @Autowired private MainService mainService; @Autowired private NodeService nodeService; @Autowired private CombService combService; @Autowired private LocDetlService locDetlService; @Autowired private PakoutService pakoutService; @Autowired private SnowflakeIdWorker snowflakeIdWorker; @Autowired private MatService matService; @Autowired private CheckService checkService; @Autowired private OrderService orderService; @Autowired private OrderDetlService orderDetlService; @Autowired private ItemService itemService; @Autowired private CstmrService cstmrService; @Autowired private ErpService erpService; @Autowired private AsrsService asrsService; @Autowired private PakinService pakinService; @Override @Transactional public R stockPakin(PakinParam param, Long userId) { Node node = nodeService.selectByUuid(param.getNodeId()); if (node == null) { try { node = nodeService.selectById(param.getNodeId()); } catch (Exception e) { return R.error("货位不存在"); } } if (node == null) { return R.error("货位不存在"); } if (Cools.isEmpty(param.getMats())) { return R.error("入库物料不能为空"); } Integer docId = Optional.ofNullable(param.getDocType()).orElse(34); String docNum = String.valueOf(snowflakeIdWorker.nextId()); switch (docId) { case 34: // 采购单 docNum = "PU-" + String.valueOf(snowflakeIdWorker.nextId()).substring(0, 15); break; case 45: // 销售退货单 docNum = "SR-" + String.valueOf(snowflakeIdWorker.nextId()).substring(0, 15); break; default: break; } Date now = new Date(); for (MatnrDto dto : param.getMats()) { Mat mat = matService.selectByMatnr(dto.getMatnr()); if (mat == null) { throw new CoolException("物料数据错误，请联系管理员"); } // 保存入库记录 Pakin pakin = new Pakin( "I" + String.valueOf(snowflakeIdWorker.nextId()), // 任务号[非空] null, // 工作状态 null, // 托盘号 dto.getCount(), // 入库数量 node.getId(), // 关联货位[非空] node.getUuid(), // 货位[非空] mat.getMatnr(), // 商品编码[非空] null, // 商品名称 null, // 名称 null, // 尺码 null, // 型号 null, // 批号 null, // 单位 null, // SKC null, // 单据类型 null, // 单据编号 null, // 客户名称 null, // 品项数 null, // 数量 null, // 重量 1, // 状态 userId, // 添加人员 now, // 添加时间 userId, // 修改人员 now, // 修改时间 null // 备注 ); VersionUtils.setPakin(pakin, mat); if (!pakinService.insert(pakin)) { throw new CoolException("保存入库记录失败"); } LocDetl locDetl = locDetlService.getLocDetl(node.getId(), dto.getMatnr()); if (locDetl == null) { // 更新货位库存明细 locDetl = new LocDetl(); locDetl.setLocNo(node.getName()); locDetl.setNodeId(node.getId()); locDetl.setZpallet(""); locDetl.setAnfme(dto.getCount()); VersionUtils.setLocDetl(locDetl, mat); locDetl.setDocId(docId.longValue()); locDetl.setDocNum(docNum); locDetl.setStatus(1); locDetl.setCreateBy(userId); locDetl.setCreateTime(now); locDetl.setUpdateBy(userId); locDetl.setUpdateTime(now); boolean insert = locDetlService.insert(locDetl); if (!insert) { throw new CoolException("新增库存明细档失败"); } } else { if (!locDetlService.incrementStock(node.getId(), dto.getMatnr(), dto.getCount())) { throw new CoolException("新增库存明细档失败"); } } } // 上报给erp List dtos = new ArrayList<>(); for (MatnrDto dto : param.getMats()) { BillDto billDto = new BillDto(); billDto.setMatnr(dto.getMatnr()); billDto.setQty(dto.getCount()); dtos.add(billDto); } ErpR erpR = erpService.uploadBill(dtos, docId, docNum); if (!erpR.getSuccess()) { throw new CoolException("无法上报至erp："+erpR.getMsg()); } return R.ok("入库成功"); } @Override @Transactional public R stockPakout(PakoutParam param, Long userId) { Mat mat = matService.selectByMatnr(param.getMatnr()); Node node = nodeService.selectByUuid(param.getNodeUuid()); LocDetl locDetl = locDetlService.getLocDetl(node.getId(), mat.getMatnr()); if (locDetl == null || locDetl.getAnfme() < param.getCount()) { return R.error(mat.getMaktx() + "库存不足"); } Pakout pakout = new Pakout( String.valueOf(snowflakeIdWorker.nextId()), // 任务号[非空] 3L, // 工作状态 null, // 托盘号 param.getCount(), // 出库数量 node.getId(), // 关联货位[非空] node.getUuid(), // 货位[非空] mat.getMatnr(), // 商品编码[非空] null, // 商品名称 null, // 名称 null, // 尺码 null, // 型号 null, // 批号 null, // 单位 null, // SKC null, // 单据类型 null, // 单据编号 null, // 客户名称 null, // 品项数 null, // 数量 null, // 重量 1, // 状态 userId, // 添加人员 new Date(), // 添加时间 userId, // 修改人员 new Date(), // 修改时间 null // 备注 ); VersionUtils.setPakout(pakout, mat); // 保存出库通知单 if (!pakoutService.insert(pakout)) { throw new CoolException("保存出库通知单失败"); } if (param.getCount()>=locDetl.getAnfme()) { // 删除库存明细 if (!locDetlService.removeStock(node.getId(), mat.getMatnr())) { throw new CoolException("删除库存明细失败"); } } else { // 修改库存明细数量 if (!locDetlService.reduceStock(node.getId(), mat.getMatnr(), param.getCount())) { throw new CoolException("修改库存明细数量失败"); } } return R.ok(); } @Override @Transactional public R stockIn(StockInParam param, Long userId) { Node node = nodeService.selectByUuid(param.getNodeId()); if (node == null) { return R.error("货位不存在"); } List combs = combService.selectList(new EntityWrapper().eq("zpallet", param.getZpallet()).eq("io_status", 1)); if (Cools.isEmpty(combs)) { return R.error("物料不存在"); } Date now = new Date(); String docNum = String.valueOf(snowflakeIdWorker.nextId()); switch (param.getDocType()) { case 34: // 采购单 docNum = "PU-" + String.valueOf(snowflakeIdWorker.nextId()).substring(0, 15); break; case 45: // 销售退货单 docNum = "SR-" + String.valueOf(snowflakeIdWorker.nextId()).substring(0, 15); break; default: break; } for (Comb comb : combs) { // 改变组托档状态 comb.setIoStatus(4); comb.setUpdateBy(userId); comb.setUpdateTime(now); boolean update = combService.update(comb, new EntityWrapper().eq("zpallet", param.getZpallet()).eq("matnr", comb.getMatnr())); if (!update) { throw new CoolException("修改托盘资料档失败"); } LocDetl locDetl = locDetlService.getLocDetl(node.getId(), comb.getMatnr()); if (locDetl == null) { // 更新货位库存明细 locDetl = new LocDetl(); locDetl.setLocNo(node.getName()); locDetl.setNodeId(node.getId()); locDetl.setZpallet(param.getZpallet()); locDetl.setAnfme(comb.getAnfme()); VersionUtils.setLocDetl(locDetl, comb); locDetl.setDocId(param.getDocType().longValue()); locDetl.setDocNum(docNum); locDetl.setStatus(1); locDetl.setCreateBy(userId); locDetl.setCreateTime(now); locDetl.setUpdateBy(userId); locDetl.setUpdateTime(now); boolean insert = locDetlService.insert(locDetl); if (!insert) { throw new CoolException("新增库存明细档失败"); } } else { if (!locDetlService.incrementStock(node.getId(), comb.getMatnr(), comb.getAnfme())) { throw new CoolException("新增库存明细档失败"); } } } // 上报给erp List dtos = new ArrayList<>(); for (Comb comb : combs) { BillDto billDto = new BillDto(); billDto.setMatnr(comb.getMatnr()); billDto.setQty(comb.getAnfme()); dtos.add(billDto); } ErpR erpR = erpService.uploadBill(dtos, param.getDocType(), docNum); if (!erpR.getSuccess()) { throw new CoolException("无法上报至erp："+erpR.getMsg()); } return R.ok(); } @Override public R stockOutCheck(String number, Long userId) { return null; } @Override public R stockOutPreview(StockOutParam param, Long userId) { Order order = orderService.selectByOrderNo(param.getOrderNo()); if (order.getSettle() != 1) { return R.error("此单据无法生成拣货单"); } List orderDetls = orderDetlService.selectByOrderNo(order.getOrderNo()); if (Cools.isEmpty(orderDetls)) { return R.error("此单据已失效，请联系管理员"); } OrderStoDto dto = new OrderStoDto().create(order.getOrderNo(), orderDetls); return R.ok().add(mainService.stockOutPreview(dto)); } @Override public R stockOutCreate(StockOutParam param, Long userId) { Order order = orderService.selectByOrderNo(param.getOrderNo()); if (order.getSettle() != 1) { return R.error("此单据无法生成拣货单"); } List orderDetls = orderDetlService.selectByOrderNo(param.getOrderNo()); if (Cools.isEmpty(orderDetls)) { return R.error("此单据已失效，请联系管理员"); } for (OrderDetl orderDetl : orderDetls) { if (Arith.remainder(orderDetl.getAnfme(), 1) > 0) { return R.error(orderDetl.getMaktx() + "数量必须为整数"); } } OrderStoDto dto = new OrderStoDto().create(order.getOrderNo(), orderDetls); // 开始整理出库数据 mainService.stockOutProcess(dto); return R.ok("生成拣货单成功"); } @Override public R stockOutPrint(StockOutParam param, Long userId) { Order order = orderService.selectByOrderNo(param.getOrderNo()); if (order == null) { return R.error("此单据已失效"); } List pakouts = pakoutService.selectList(new EntityWrapper().eq("doc_num", order.getOrderNo())); Double total = 0.0D; for (Pakout pakout : pakouts) { total = pakout.getAnfme() + total; } StoPrintVo vo = new StoPrintVo(); vo.setDocNum(param.getOrderNo()); vo.setList(pakouts); vo.setTotal(total); vo.setCstmrName(order.getCstmrName()); vo.setWorkerName(Cools.isEmpty(order.getOperMemb())? "" : order.getOperMemb()); return R.ok().add(vo); } @Override @Transactional public R stockOutComplete(StockConfirmParam param, Long userId) { List pakouts = pakoutService.selectList(new EntityWrapper() .eq("doc_num", param.getOrderNo()) .in("wrk_sts", 1, 2)); for (Pakout pakout : pakouts) { LocDetl locDetl = locDetlService.getLocDetl(pakout.getNodeId(), pakout.getMatnr()); // 缺货 or 立库 if (locDetl == null) { // 缺货 if (pakout.getLocNo().equals("缺货")) { Double count = Optional.ofNullable(locDetlService.selectCountByMatnr(pakout.getMatnr())).orElse(0.0D); if (count < pakout.getAnfme()) { throw new CoolException(pakout.getMaktx()+"缺货"); } Date now = new Date(); // 查找推荐货位是否库存足够 List locDetls = locDetlService.findOfSort(pakout.getMatnr()); double issued = Optional.ofNullable(pakout.getAnfme()).orElse(0.0D) ; for (LocDetl locDetl1 : locDetls) { if (issued > 0) { // 保存出库通知单 Pakout newPakout = new Pakout(); newPakout.setWrkSts(3L); newPakout.setAnfme(issued>=locDetl1.getAnfme()?locDetl1.getAnfme():issued); newPakout.setZpallet(locDetl1.getZpallet()); newPakout.setLocNo(locDetl1.getLocNo()); newPakout.setNodeId(locDetl1.getNodeId()); newPakout.setWrkNo(String.valueOf(snowflakeIdWorker.nextId())); VersionUtils.setPakout(newPakout, locDetl1); newPakout.setDocId(pakout.getDocId()); // 单据类型 newPakout.setDocNum(pakout.getDocNum()); // 单据编号 newPakout.setCreateTime(now); newPakout.setUpdateTime(now); newPakout.setStatus(1); if (!pakoutService.insert(newPakout)) { throw new CoolException("保存出库通知单失败"); } if (issued>=locDetl1.getAnfme()) { // 删除库存明细 if (!locDetlService.removeStock(locDetl1.getNodeId(), newPakout.getMatnr())) { throw new CoolException("删除库存明细失败"); } } else { // 修改库存明细数量 if (!locDetlService.reduceStock(locDetl1.getNodeId(), newPakout.getMatnr(), issued)) { throw new CoolException("修改库存明细数量失败"); } } // 剩余待出数量递减 issued = issued - locDetl1.getAnfme(); } } } continue; } // 修改库存数量 if (pakout.getAnfme()>=locDetl.getAnfme()) { // 删除库存明细 if (!locDetlService.removeStock(locDetl.getNodeId(), pakout.getMatnr())) { throw new CoolException("删除库存明细失败"); } } else { // 修改库存明细数量 if (!locDetlService.reduceStock(locDetl.getNodeId(), pakout.getMatnr(), pakout.getAnfme())) { throw new CoolException("修改库存明细数量失败"); } } } // 修改出库单状态 if (!pakoutService.stockOutComplete(param.getWrkNo(), param.getOrderNo(), userId)) { return R.error("保存数据失败"); } // 修改单据状态 if (!orderService.updateSettle(param.getOrderNo(), 4L)) { throw new CoolException("修改单据状态失败"); } return R.ok(); } @Override @Transactional public R initPakout(List params, Long userId) { if (!Cools.isEmpty(params)) { Date now = new Date(); for (InitPakoutParam param : params) { LocDetl locDetl = locDetlService.getLocDetl(param.getNodeId(), param.getMatnr()); // 保存出库通知单 Pakout pakout = new Pakout(); pakout.setWrkSts(1L); pakout.setAnfme(param.getCount()); pakout.setWrkNo(String.valueOf(snowflakeIdWorker.nextId())); VersionUtils.setPakout(pakout, locDetl); pakout.setCreateTime(now); pakout.setCreateBy(userId); pakout.setUpdateTime(now); pakout.setUpdateBy(userId); pakout.setStatus(1); if (!pakoutService.insert(pakout)) { throw new CoolException("生成拣货单失败"); } if (param.getCount() > locDetl.getAnfme()) { throw new CoolException("库存不足"); } else if (param.getCount()().eq("wrk_no", wrkNo)); if (null != pakout) { // 修改库存数量 LocDetl locDetl = locDetlService.getLocDetl(pakout.getNodeId(), pakout.getMatnr()); if (pakout.getAnfme()>=locDetl.getAnfme()) { // 删除库存明细 if (!locDetlService.removeStock(locDetl.getNodeId(), pakout.getMatnr())) { throw new CoolException("删除库存明细失败"); } } else { // 修改库存明细数量 if (!locDetlService.reduceStock(locDetl.getNodeId(), pakout.getMatnr(), pakout.getAnfme())) { throw new CoolException("修改库存明细数量失败"); } } // 修改拣货单状态 if (pakoutService.stockOutComplete(wrkNo, null, userId)) { boolean complete = true; List pakouts = pakoutService.selectList(new EntityWrapper().eq("doc_num", pakout.getDocNum())); for (Pakout item : pakouts) { if (item.getWrkSts() != 3) { complete = false; break; } } if (complete) { // 修改单据状态 if (!orderService.updateSettle(pakout.getDocNum(), 4L)) { throw new CoolException("修改单据状态失败"); } } return R.ok("拣货单已完成"); } } return R.error(); } @Override @Transactional public R cancelPakout(String wrkNo, Long userId) { Pakout pakout = pakoutService.selectOne(new EntityWrapper().eq("wrk_no", wrkNo)); if (!pakoutService.delete(new EntityWrapper().eq("wrk_no", pakout.getWrkNo()))) { throw new CoolException("删除拣货单失败"); } // 取消销售订单 List pakouts = pakoutService.selectList(new EntityWrapper().eq("doc_num", pakout.getDocNum())); if (Cools.isEmpty(pakouts)){ // 修改单据状态 if (!orderService.updateSettle(pakout.getDocNum(), 3L)) { throw new CoolException("修改单据状态失败"); } } return R.ok("拣货单已取消"); } @Override @Transactional public R initOrder(InitOrderParam param, Long userId) { Order order = orderService.selectByOrderNo(param.getOrderNo()); if (order != null) { return R.error("抱歉单号已存在，请修改单号"); } Date now = new Date(); Item item = itemService.selectByName(param.getItem()); Cstmr cstmr = cstmrService.selectByName(param.getCstmr()); // 采购退货单检验 if (param.getDocType() == 6) { for (MatnrDto dto : param.getList()) { if (locDetlService.getStockByDocType34(dto.getMatnr()) < dto.getCount()) { return R.error(dto.getMatnr() + "采购量不足以生成退货单！"); } } } // 新增订单表头 order = new Order( String.valueOf(snowflakeIdWorker.nextId()), // 编号[非空] param.getOrderNo(), // 订单编号 param.getOrderTime(), // 单据日期 param.getDocType(), // 单据类型 item==null?null:item.getId(), // 项目编号 param.getItem(), // 项目名称 null, // 调拨项目编号 null, // 初始票据号 null, // 票据号 cstmr==null?null:cstmr.getId(), // 客户编号 param.getCstmr(), // 客户 null, // 联系方式 null, // 操作人员 null, // 合计金额 null, // 优惠率 null, // 优惠金额 null, // 销售或采购费用合计 null, // 实付金额 null, // 付款类型 null, // 业务员 null, // 结算天数 null, // 邮费支付类型 null, // 邮费 null, // 付款时间 null, // 发货时间 null, // 物流名称 null, // 物流单号 1L, // 订单状态 1, // 状态 userId, // 添加人员 now, // 添加时间 userId, // 修改人员 now, // 修改时间 null // 备注 ); if (!orderService.insert(order)) { throw new CoolException("保存订单表头失败！"); } // 遍历商品数量并保存 for (MatnrDto dto : param.getList()){ Mat mat = matService.selectByMatnr(dto.getMatnr()); if (mat == null) { log.error("{}商品不存在。", dto.getMatnr()); continue; } OrderDetl orderDetl = new OrderDetl(); orderDetl.setOrderId(order.getId()); // 订单内码 orderDetl.setAnfme(dto.getCount()); // 数量 orderDetl.setCreateBy(userId); orderDetl.setCreateTime(now); orderDetl.setUpdateBy(userId); orderDetl.setUpdateTime(now); orderDetl.setStatus(1); VersionUtils.setOrderDetl(orderDetl, mat); if (!orderDetlService.insert(orderDetl)) { throw new CoolException("保存订单明细失败"); } } return R.ok("创建订单成功"); } @Override public R asrsStockTransfer(AsrsTransferParam param, Long userId) { if (Cools.isEmpty(param.getNode_id(), param.getMatnr(), param.getSafe_qua(), param.getAmount())) { return R.error("数量错误"); } Node node = nodeService.selectById(param.getNode_id()); Mat mat = matService.selectByMatnr(param.getMatnr()); if (node == null || mat == null) { return R.error(); } double anfme = Arith.subtract(2, param.getSafe_qua(), param.getAmount()); List params = new ArrayList<>(); StockTransferParam transferParam = new StockTransferParam(); transferParam.setMatnr(param.getMatnr()); transferParam.setAnfme(anfme); transferParam.setAllotNo(param.getNode_id()+ "_" +param.getMatnr()); params.add(transferParam); Result1 result = asrsService.stockTransfer(params); if (result.getCode() == 500) { if (Cools.isEmpty(result.getData())) { throw new CoolException(result.getMsg()); } else { throw new CodeCoolException("20001-" + result.getData()); } } // 直接增加库存 // LocDetl locDetl = locDetlService.getLocDetl(param.getNode_id(), param.getMatnr()); // if (locDetl == null) { // // 更新货位库存明细 // locDetl = new LocDetl(); // locDetl.setLocNo(node.getName()); // locDetl.setNodeId(node.getId()); // locDetl.setAnfme(anfme); // VersionUtils.setLocDetl(locDetl, mat); // locDetl.setStatus(1); // locDetl.setCreateBy(userId); // locDetl.setCreateTime(new Date()); // locDetl.setUpdateBy(userId); // locDetl.setUpdateTime(new Date()); // boolean insert = locDetlService.insert(locDetl); // if (!insert) { // throw new CoolException("新增库存明细档失败"); // } // } else { // if (!locDetlService.incrementStock(node.getId(), param.getMatnr(), anfme)) { // throw new CoolException("新增库存明细档失败"); // } // } return R.ok("补仓成功，等待立库调拨"); } @Override public R asrsStockTransferLocMode(AsrsTransferParam param, Long userId) { if (Cools.isEmpty(param.getNode_id(), param.getMatnr(), param.getSafe_qua(), param.getAmount())) { return R.error("数量错误"); } Node node = nodeService.selectById(param.getNode_id()); Mat mat = matService.selectByMatnr(param.getMatnr()); if (node == null || mat == null) { return R.error(); } double anfme = Arith.subtract(2, param.getSafe_qua(), param.getAmount()); List params = new ArrayList<>(); StockTransferParam transferParam = new StockTransferParam(); transferParam.setMatnr(param.getMatnr()); transferParam.setAnfme(anfme); transferParam.setAllotNo(param.getNode_id()+ "_" +param.getMatnr()); transferParam.setLocNo(param.getLocNo()); params.add(transferParam); Result1 result = asrsService.stockTransferLocMode(params); if (result.getCode() == 500) { if (Cools.isEmpty(result.getData())) { throw new CoolException(result.getMsg()); } else { throw new CodeCoolException("20001-" + result.getData()); } } return R.ok("补仓成功，等待立库调拨"); } @Override public R stockCheck(StoCheckParam param, Long userId) { if (Cools.isEmpty(param.getLocNo())) { return R.error("请选择货位"); } Node node = nodeService.selectByUuid(param.getLocNo()); if (Cools.isEmpty(node)) { return R.error("货位异常,请联系管理员"); } // 准备数据 Date now = new Date(); List locDetls = locDetlService.selectList(new EntityWrapper().eq("node_id", node.getId())); List locDetlMatnrs = new ArrayList<>(); locDetls.forEach(locDetl -> locDetlMatnrs.add(locDetl.getMatnr())); Iterator detlIterator = locDetls.iterator(); List dtos = param.getDtos(); // 1.盈亏 修改数量 while (detlIterator.hasNext()){ LocDetl locDetl = detlIterator.next(); for (PakinMatDto dto : dtos) { if (locDetl.getMatnr().equals(dto.getMatnr())) { if (!locDetl.getAnfme().equals(dto.getCount())) { Check check = new Check( String.valueOf(snowflakeIdWorker.nextId()), // 盘点编号 node.getId(), // 盘点货位 node.getUuid(), // 货位编号 node.getName(), // 货位名称 locDetl.getMatnr(), // 商品编号 locDetl.getMaktx(), // 商品名称 locDetl.getUnit(), // 单位 null, // 单据类型 null, // 单据编号 locDetl.getAnfme(), // 账面数量 dto.getCount(), // 实盘数量 dto.getCount() - locDetl.getAnfme(), // 差值 locDetl.getAnfme() < dto.getCount() ? 1 : 2, // 盈亏 1, // 状态 userId, // 添加人员 now, // 添加时间 userId, // 修改人员 now, // 修改时间 null // 备注 ); if (!checkService.insert(check)) { throw new CoolException("保存盘点记录失败"); } } detlIterator.remove(); break; } } } // 2.盘亏 删除库存 for (LocDetl locDetl : locDetls) { Check check = new Check( String.valueOf(snowflakeIdWorker.nextId()), // 盘点编号 node.getId(), // 盘点货位 node.getUuid(), // 货位编号 node.getName(), // 货位名称 locDetl.getMatnr(), // 商品编号 locDetl.getMaktx(), // 商品名称 locDetl.getUnit(), // 单位 null, // 单据类型 null, // 单据编号 locDetl.getAnfme(), // 账面数量 0D, // 实盘数量 0D - locDetl.getAnfme(), // 差值 2, // 盈亏 1, // 状态 userId, // 添加人员 now, // 添加时间 userId, // 修改人员 now, // 修改时间 null // 备注 ); if (!checkService.insert(check)) { throw new CoolException("保存盘点记录失败"); } } // 3.盘盈 新增库存 for (PakinMatDto dto : dtos) { if (!locDetlMatnrs.contains(dto.getMatnr())) { Mat mat = matService.selectByMatnr(dto.getMatnr()); Check check = new Check( String.valueOf(snowflakeIdWorker.nextId()), // 盘点编号 node.getId(), // 盘点货位 node.getUuid(), // 货位编号 node.getName(), // 货位名称 mat.getMatnr(), // 商品编号 mat.getMaktx(), // 商品名称 mat.getUnit(), // 单位 null, // 单据类型 null, // 单据编号 0D, // 账面数量 dto.getCount(), // 实盘数量 dto.getCount() - 0D, // 差值 1, // 盈亏 1, // 状态 userId, // 添加人员 now, // 添加时间 userId, // 修改人员 now, // 修改时间 null // 备注 ); if (!checkService.insert(check)) { throw new CoolException("保存盘点记录失败"); } } } return R.ok(); } @Override @Transactional public R stockCheckAuditing(Long checkId, Long userId) { Check check = checkService.selectById(checkId); if (null == check || check.getStatus() != 1) { return R.error("盘点记录已失效"); } Date now = new Date(); // 1.修改库存数量 if (check.getOriQty() != 0 && check.getCekQty() != 0) { // 更新库存明细 if (check.getSettle() == 1) { if (!locDetlService.incrementStock(check.getNodeId(), check.getMatnr(), Math.abs(check.getDiffQty()))) { throw new CoolException("修改库存明细数量失败"); } } else if (check.getSettle() == 2) { if (!locDetlService.reduceStock(check.getNodeId(), check.getMatnr(), Math.abs(check.getDiffQty()))) { throw new CoolException("修改库存明细数量失败"); } } } // 2.删除库存 if (check.getOriQty() != 0 && check.getCekQty() == 0) { if (!locDetlService.delete(new EntityWrapper().eq("node_id", check.getNodeId()).eq("matnr", check.getMatnr()))) { throw new CoolException("删除库存明细数量失败"); } } // 3.新增库存 if (check.getOriQty() == 0 && check.getCekQty() != 0) { Mat mat = matService.selectByMatnr(check.getMatnr()); if (mat == null) { throw new CoolException("商品数据异常，请联系管理员"); } // 更新货位库存明细 LocDetl locDetl = new LocDetl(); locDetl.setLocNo(check.getLocNo()); locDetl.setNodeId(check.getNodeId()); // locDetl.setZpallet(param.getZpallet()); locDetl.setAnfme(check.getCekQty()); VersionUtils.setLocDetl(locDetl, mat); locDetl.setStatus(1); locDetl.setCreateBy(userId); locDetl.setCreateTime(now); locDetl.setUpdateBy(userId); locDetl.setUpdateTime(now); if (!locDetlService.insert(locDetl)) { throw new CoolException("新增库存明细失败"); } } // 修改盘点记录 String docNum = null; Long docId = null; switch (check.getSettle()) { case 1: // 盘盈 todo 前期用采购单上报 // docNum = "CS-" + String.valueOf(snowflakeIdWorker.nextId()).substring(0, 15); // docId = 14L; // 报溢单 docNum = "PU-" + String.valueOf(snowflakeIdWorker.nextId()).substring(0, 15); docId = 34L; // 采购单 break; case 2: // 盘亏 docNum = "CD-" + String.valueOf(snowflakeIdWorker.nextId()).substring(0, 15); docId = 9L; // 报损单 break; default: throw new CoolException("盘点记录盈亏情况异常"); } check.setStatus(2); check.setDocId(docId); check.setDocNum(docNum); check.setUpdateBy(userId); check.setUpdateTime(now); if (!checkService.updateById(check)) { throw new CoolException("修改盘点记录状态失败"); } // 上报给erp List dtos = new ArrayList<>(); BillDto billDto = new BillDto(); billDto.setMatnr(check.getMatnr()); billDto.setQty(Math.abs(check.getDiffQty())); dtos.add(billDto); ErpR erpR = erpService.uploadBill(dtos, docId.intValue(), docNum); if (!erpR.getSuccess()) { throw new CoolException("无法上报至erp："+erpR.getMsg()); } return R.ok(); } }