From 94209e3f73be2be52f2033300c1e336731b255db Mon Sep 17 00:00:00 2001 From: zccbbg Date: Fri, 5 May 2023 23:11:28 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E5=87=BA=E5=BA=93=E5=8D=95?= =?UTF-8?q?=E4=BF=9D=E5=AD=98=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../controller/ShipmentOrderController.java | 6 ++- .../cyl/wms/service/ShipmentOrderService.java | 42 ++++++++++--------- 2 files changed, 28 insertions(+), 20 deletions(-) diff --git a/wms/src/main/java/com/cyl/wms/controller/ShipmentOrderController.java b/wms/src/main/java/com/cyl/wms/controller/ShipmentOrderController.java index ee22626..77f1379 100644 --- a/wms/src/main/java/com/cyl/wms/controller/ShipmentOrderController.java +++ b/wms/src/main/java/com/cyl/wms/controller/ShipmentOrderController.java @@ -97,6 +97,10 @@ public class ShipmentOrderController extends BaseController { @Log(title = "出库单", businessType = BusinessType.INSERT) @PostMapping("add-or-update") public ResponseEntity addOrUpdate(@RequestBody ShipmentOrderFrom order) { - return ResponseEntity.ok(service.addOrUpdate(order)); + if(order.getId()==null){ + return ResponseEntity.ok(service.add(order)); + }else { + return ResponseEntity.ok(service.update(order)); + } } } diff --git a/wms/src/main/java/com/cyl/wms/service/ShipmentOrderService.java b/wms/src/main/java/com/cyl/wms/service/ShipmentOrderService.java index 74dbb6b..75a5bfc 100644 --- a/wms/src/main/java/com/cyl/wms/service/ShipmentOrderService.java +++ b/wms/src/main/java/com/cyl/wms/service/ShipmentOrderService.java @@ -40,7 +40,6 @@ import org.springframework.util.CollectionUtils; /** * 出库单Service业务层处理 * - * * @author zcc */ @Service @@ -106,7 +105,7 @@ public class ShipmentOrderService { * 查询出库单列表 * * @param query 查询条件 - * @param page 分页条件 + * @param page 分页条件 * @return 出库单 */ public Page selectList(ShipmentOrderQuery query, Pageable page) { @@ -115,7 +114,7 @@ public class ShipmentOrderService { } QueryWrapper qw = new QueryWrapper<>(); qw.orderByDesc("id"); - qw.eq("del_flag",0); + qw.eq("del_flag", 0); String shipmentOrderNo = query.getShipmentOrderNo(); if (!StringUtils.isEmpty(shipmentOrderNo)) { qw.eq("shipment_order_no", shipmentOrderNo); @@ -144,7 +143,7 @@ public class ShipmentOrderService { if (!CollUtil.isEmpty(res)) { List ids = res.stream().map(ShipmentOrderVO::getId).collect(Collectors.toList()); Map id2count = shipmentOrderDetailMapper.countByOrderId(ids) - .stream().collect(Collectors.toMap(ShipmentOrderVO::getId, ShipmentOrderVO::getDetailCount)); + .stream().collect(Collectors.toMap(ShipmentOrderVO::getId, ShipmentOrderVO::getDetailCount)); res.forEach(it -> it.setDetailCount(id2count.get(it.getId()))); } return new PageImpl<>(res, page, ((com.github.pagehelper.Page) list).getTotal()); @@ -192,20 +191,25 @@ public class ShipmentOrderService { Long[] ids = {id}; return shipmentOrderMapper.updateDelFlagByIds(ids); } + @Transactional - public int addOrUpdate(ShipmentOrderFrom order) { + public int add(ShipmentOrderFrom order) { int res; - // 1. 新增 - if (order.getId() == null) { - order.setDelFlag(0); - order.setCreateTime(LocalDateTime.now()); - res = shipmentOrderMapper.insert(order); - saveDetails(order.getId(), order.getDetails()); + order.setDelFlag(0); + order.setCreateTime(LocalDateTime.now()); + res = shipmentOrderMapper.insert(order); + saveDetails(order.getId(), order.getDetails()); + if (order.getReceivableAmount() != null && order.getCustomerId() != null) { //保存订单金额到客户流水表 saveOrUpdatePayAmount(order); - return res; } - // 2. 编辑 + return res; + + + } + + public int update(ShipmentOrderFrom order) { + int res; QueryWrapper qw = new QueryWrapper<>(); qw.eq("shipment_order_id", order.getId()); @@ -256,28 +260,28 @@ public class ShipmentOrderService { }); if (adds.size() > 0) { int add1 = inventoryHistoryService.batchInsert(adds); - adds.forEach(it->it.setQuantity(it.getQuantity().negate())); + adds.forEach(it -> it.setQuantity(it.getQuantity().negate())); int update1 = inventoryService.batchUpdate1(adds); log.info("inventoryHistory: {}, inventory: {}", add1, update1); } // 2.1 先删除details 再重新保存 shipmentOrderDetailMapper.delete(qw); saveDetails(order.getId(), order.getDetails()); - - //保存订单金额到客户流水表 - saveOrUpdatePayAmount(order); + if (order.getReceivableAmount() != null && order.getCustomerId() != null) {{ + //保存订单金额到客户流水表 + saveOrUpdatePayAmount(order); + }} // 2.2 更新出库单 //判断出库单的整体状态 Set statusList = order.getDetails().stream().map(it -> it.getShipmentOrderStatus()).collect(Collectors.toSet()); if (statusList.size() == 1) { order.setShipmentOrderStatus(statusList.iterator().next()); - }else if (statusList.contains(ShipmentOrderConstant.PART_IN)) { + } else if (statusList.contains(ShipmentOrderConstant.PART_IN)) { order.setShipmentOrderStatus(ShipmentOrderConstant.PART_IN); } res = shipmentOrderMapper.updateById(order); return res; - } /**