From 0e85601e2f80b6cb580c0fad9be9518f58c5882c Mon Sep 17 00:00:00 2001
From: cl <1442464845@qq.com>
Date: 星期二, 14 四月 2026 22:19:27 +0800
Subject: [PATCH] 云仓模拟视图数据sql
---
rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/OutStockServiceImpl.java | 28 +++++++++++-----------------
1 files changed, 11 insertions(+), 17 deletions(-)
diff --git a/rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/OutStockServiceImpl.java b/rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/OutStockServiceImpl.java
index 4e97b9b..f5cd546 100644
--- a/rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/OutStockServiceImpl.java
+++ b/rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/OutStockServiceImpl.java
@@ -265,7 +265,7 @@
}
WkOrder order = this.getById(id);
if (Objects.isNull(order)) {
- throw new CoolException("鍗曟嵁涓嶅瓨鍦紒锛�");
+ return R.ok("鍗曟嵁宸蹭笉瀛樺湪鎴栧凡鍙栨秷");
}
if (!order.getExceStatus().equals(AsnExceStatus.OUT_STOCK_STATUS_TASK_INIT.val)) {
throw new CoolException("褰撳墠鍗曟嵁鐘舵�佷负" + AsnExceStatus.getExceStatus(order.getExceStatus()) + "锛� 涓嶅彲鎵ц鍙栨秷鎿嶄綔锛侊紒");
@@ -295,10 +295,10 @@
}
if (!this.remove(new LambdaQueryWrapper<WkOrder>().eq(WkOrder::getId, id))) {
- throw new CoolException("涓诲崟鍒犻櫎澶辫触锛侊紒");
+ return R.ok("鍗曟嵁宸蹭笉瀛樺湪鎴栧凡鍙栨秷");
}
outStockItemService.remove(new LambdaQueryWrapper<WkOrderItem>().eq(WkOrderItem::getOrderId, id));
- return R.ok("鎿嶄綔鎴愬姛");
+ return R.ok("鍙栨秷鎴愬姛");
}
/**
@@ -755,16 +755,11 @@
.findFirst()
.orElse(null);
- // 涓ユ牸鍖归厤鏈壘鍒版椂锛氬啀鎸夈�屽悓鍗曞彿+鍚岀墿鏂欍�嶅鏉惧尮閰嶏紝閬垮厤鍘熸槑缁� fields_index 涓虹┖鑰屽垎閰嶅甫绁ㄥ彿瀵艰嚧閲嶅鍒涘缓涓�鏉�
+ // 涓ユ牸鍖归厤鏈壘鍒版椂锛氭寜銆屽悓鍗曞彿+鍚岀墿鏂�+鏈夊墿浣欍�嶅尮閰嶏紝涓嶆寜鎵规锛岄伩鍏嶅嚭搴撲笉妫�鏌ユ壒娆℃椂閫夊埌涓嶅悓鎵规搴撲綅鍗磋嚜鍔ㄦ柊澧炰竴鏉″嚭搴撳崟鏄庣粏
if (Objects.isNull(orderItem)) {
LambdaQueryWrapper<WkOrderItem> relaxedWrapper = new LambdaQueryWrapper<WkOrderItem>()
.eq(WkOrderItem::getOrderId, outId)
.eq(WkOrderItem::getMatnrId, locItem.getMatnrId());
- if (StringUtils.isNotBlank(locItem.getSplrBatch())) {
- relaxedWrapper.eq(WkOrderItem::getSplrBatch, locItem.getSplrBatch());
- } else if (StringUtils.isNotBlank(locItem.getBatch())) {
- relaxedWrapper.and(w -> w.eq(WkOrderItem::getBatch, locItem.getBatch()).or().eq(WkOrderItem::getSplrBatch, locItem.getBatch()));
- }
orderItem = outStockItemService.list(relaxedWrapper).stream()
.filter(o -> o.getAnfme() != null && o.getWorkQty() != null && o.getAnfme().compareTo(o.getWorkQty()) > 0)
.findFirst()
@@ -782,7 +777,7 @@
throw new CoolException("鍑哄簱鍗曟嵁涓嶅瓨鍦紒锛�");
}
boolean isStockRevise = locItem.getWkType() != null
- && locItem.getWkType().equals(Short.parseShort(OrderWorkType.ORDER_WORK_TYPE_STOCK_REVISE.type));
+ && Objects.equals(locItem.getWkType(), OrderWorkType.ORDER_WORK_TYPE_STOCK_REVISE.type);
if (isStockRevise) {
log.info("搴撳瓨璋冩暣浜х敓鐨勫簱瀛橈紝鑷姩鍒涘缓WkOrderItem - 鍑哄簱鍗旾D锛歿}锛岀墿鏂橧D锛歿}锛屾壒娆★細{}",
outId, locItem.getMatnrId(), locItem.getBatch());
@@ -894,11 +889,13 @@
@Transactional(rollbackFor = Exception.class)
public R cancelOutOrderByItems(List<WkOrderItem> orderItems) {
Map<Long, List<WkOrderItem>> listMap = orderItems.stream().collect(Collectors.groupingBy(WkOrderItem::getOrderId));
+ boolean anyProcessed = false;
for (Long key : listMap.keySet()) {
WkOrder order = this.getById(key);
if (Objects.isNull(order)) {
- throw new CoolException("鍗曟嵁涓嶅瓨鍦紒锛�");
+ continue;
}
+ anyProcessed = true;
List<WkOrderItem> items = listMap.get(key);
if (!items.isEmpty()) {
for (WkOrderItem orderItem : items) {
@@ -921,14 +918,11 @@
}
if (!this.remove(new LambdaQueryWrapper<WkOrder>().eq(WkOrder::getId, key))) {
- throw new CoolException("涓诲崟鍒犻櫎澶辫触锛侊紒");
+ continue;
}
- if (!outStockItemService.remove(new LambdaQueryWrapper<WkOrderItem>()
- .eq(WkOrderItem::getOrderId, key))) {
- throw new CoolException("鍗曟嵁鏄庣粏鍒犻櫎澶辫触锛侊紒");
- }
+ outStockItemService.remove(new LambdaQueryWrapper<WkOrderItem>().eq(WkOrderItem::getOrderId, key));
}
- return R.ok("鎿嶄綔鎴愬姛");
+ return R.ok(anyProcessed ? "鍙栨秷鎴愬姛" : "鍗曟嵁宸蹭笉瀛樺湪鎴栧凡鍙栨秷");
}
--
Gitblit v1.9.1