From 63250869b7059e1ffc108a16eaffc557f8a44689 Mon Sep 17 00:00:00 2001 From: skyouc Date: 星期一, 28 七月 2025 09:30:14 +0800 Subject: [PATCH] 调拔单功能优化 --- rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/TransferServiceImpl.java | 66 +++++++++++++++++++++++--------- 1 files changed, 47 insertions(+), 19 deletions(-) diff --git a/rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/TransferServiceImpl.java b/rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/TransferServiceImpl.java index fa85fe3..cf840e9 100644 --- a/rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/TransferServiceImpl.java +++ b/rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/TransferServiceImpl.java @@ -4,6 +4,7 @@ import com.vincent.rsf.framework.common.R; import com.vincent.rsf.framework.exception.CoolException; import com.vincent.rsf.server.manager.controller.params.TransferItemParams; +import com.vincent.rsf.server.manager.entity.TransferItem; import com.vincent.rsf.server.manager.entity.WkOrder; import com.vincent.rsf.server.manager.entity.WkOrderItem; import com.vincent.rsf.server.manager.enums.AsnExceStatus; @@ -12,11 +13,14 @@ import com.vincent.rsf.server.manager.enums.OrderType; import com.vincent.rsf.server.manager.mapper.TransferMapper; import com.vincent.rsf.server.manager.entity.Transfer; +import com.vincent.rsf.server.manager.service.AsnOrderItemService; +import com.vincent.rsf.server.manager.service.TransferItemService; import com.vincent.rsf.server.manager.service.TransferService; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.vincent.rsf.server.system.constant.SerialRuleCode; import com.vincent.rsf.server.system.utils.SerialRuleUtils; import org.apache.commons.lang3.StringUtils; +import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; @@ -25,6 +29,9 @@ @Service("transferService") public class TransferServiceImpl extends ServiceImpl<TransferMapper, Transfer> implements TransferService { + + @Autowired + private TransferItemService transferItemService; /** * @author Ryan @@ -68,25 +75,29 @@ } + /** + * @author Ryan + * @date 2025/7/28 + * @description: 璋冩嫈鍗曟嵁淇敼 + * @version 1.0 + */ private void svaeOrUpdateOrderItem(TransferItemParams params, Long loginUserId) { -// Transfer orders = params.getTransfer(); -// params.getItems().forEach(item -> { -// item.put("orderId", orders.getId()); -// item.put("orderCode", orders.getCode()); -// item.put("poCode", orders.getPoCode()); -// item.put("createBy", loginUserId); -// item.put("updateBy", loginUserId); -// if (!asnOrderItemService.fieldsSave(item, loginUserId)) { -// throw new CoolException("鏄庣粏淇濆瓨澶辫触锛侊紒"); -// } -// }); -// List<WkOrderItem> orderItems = checkOrderItemService.list(new LambdaQueryWrapper<WkOrderItem>() -// .eq(WkOrderItem::getOrderId, params.getOrders().getId())); -// Double sum = orderItems.stream().mapToDouble(WkOrderItem::getAnfme).sum(); -// orders.setAnfme(sum); -// if (!this.updateById(orders)) { -// throw new CoolException("璁″垝鏀惰揣鏁伴噺淇敼澶辫触锛侊紒"); -// } + Transfer orders = params.getTransfer(); + params.getItems().forEach(item -> { + item.put("transferId", orders.getId()); + item.put("transferCode", orders.getCode()); + item.put("createBy", loginUserId); + item.put("updateBy", loginUserId); + if (!transferItemService.fieldsSave(item, loginUserId)) { + throw new CoolException("鏄庣粏淇濆瓨澶辫触锛侊紒"); + } + }); +// List<TransferItem> orderItems = transferItemService.list(new LambdaQueryWrapper<TransferItem>() +// .eq(TransferItem::getTransferId, params.getTransfer().getId())); +// Double sum = orderItems.stream().mapToDouble(TransferItem::getAnfme).sum(); + if (!this.updateById(orders)) { + throw new CoolException("璁″垝鏀惰揣鏁伴噺淇敼澶辫触锛侊紒"); + } } @@ -98,6 +109,23 @@ */ @Override public R updateTransfer(TransferItemParams params, Long loginUserId) { - return null; + Transfer orders = params.getTransfer(); + if (Objects.isNull(orders)) { + throw new CoolException("涓诲崟淇℃伅涓嶈兘涓虹┖锛侊紒"); + } + if (Objects.isNull(orders.getId())) { + throw new CoolException("鏁版嵁閿欒锛氬崟鎹甀D涓嶈兘涓虹┖锛侊紒"); + } + if (!this.updateById(orders)) { + throw new CoolException("涓诲崟淇敼澶辫触锛侊紒"); + } + if (Objects.isNull(params.getItems()) || params.getItems().isEmpty()) { + return R.ok("鏄庣粏鍙傛暟涓嶈兘涓虹┖锛侊紒"); + } + + svaeOrUpdateOrderItem(params, loginUserId); + + return R.ok("淇敼瀹屾垚锛侊紒"); + } } -- Gitblit v1.9.1