From 875a183c5d5a12a4ba5c8d37559295ac1ce6cce3 Mon Sep 17 00:00:00 2001
From: skyouc
Date: 星期三, 09 七月 2025 21:13:11 +0800
Subject: [PATCH] 播种流程优化
---
zy-asrs-wms/src/main/java/com/zy/asrs/wms/asrs/service/impl/MobileServiceImpl.java | 25 +++++++++++++------------
1 files changed, 13 insertions(+), 12 deletions(-)
diff --git a/zy-asrs-wms/src/main/java/com/zy/asrs/wms/asrs/service/impl/MobileServiceImpl.java b/zy-asrs-wms/src/main/java/com/zy/asrs/wms/asrs/service/impl/MobileServiceImpl.java
index ba4967f..1adf5de 100644
--- a/zy-asrs-wms/src/main/java/com/zy/asrs/wms/asrs/service/impl/MobileServiceImpl.java
+++ b/zy-asrs-wms/src/main/java/com/zy/asrs/wms/asrs/service/impl/MobileServiceImpl.java
@@ -76,17 +76,15 @@
@Autowired
private OrderDetlMapper orderDetlMapper;
@Autowired
- private WaveSeedMapper waveSeedMapper;
+ private WaveSeedService waveSeedMapper;
@Autowired
private WaveSeedLogService waveSeedLogService;
@Autowired
private OrderDetlLogService orderDetlLogService;
-
@Autowired
private PlatformDetlService platformDetlService;
@Autowired
private PlatformDetlLogService platformDetlLogService;
-
@Override
@@ -427,15 +425,14 @@
.setOrderId(order.getId())
.setSiteStatus(CacheSiteStatusType.R.id)
.setBarcode(param.get("barcode").toString());
- if (cacheSiteMapper.updateById(siteNo) < 1) {
+ if (!cacheSiteService.saveOrUpdate(siteNo)) {
throw new CoolException("璁㈠崟鎾浣嶇粦瀹氬け璐ワ紒锛�" );
}
- int update = waveSeedMapper.update(new LambdaUpdateWrapper<WaveSeed>()
+ if (!waveSeedMapper.update(new LambdaUpdateWrapper<WaveSeed>()
.eq(WaveSeed::getOrderNo, order.getOrderNo())
.set(WaveSeed::getSiteId, siteNo.getId())
- .set(WaveSeed::getSiteNo, siteNo.getSiteNo()));
- if (update < 1) {
+ .set(WaveSeed::getSiteNo, siteNo.getSiteNo()))) {
throw new CoolException("鎾绔欑偣鏇存柊澶辫触锛侊紒");
}
} else {
@@ -524,7 +521,7 @@
}
}
- List<WaveSeed> waveSeeds = waveSeedMapper.selectList(new LambdaQueryWrapper<WaveSeed>().eq(WaveSeed::getOrderDetlId, order.getId()));
+ List<WaveSeed> waveSeeds = waveSeedMapper.list(new LambdaQueryWrapper<WaveSeed>().eq(WaveSeed::getOrderDetlId, order.getId()));
//fixme 璁㈠崟鏄庣粏鏈挱绉嶏紝榛樿鍙彂璐�
if (!waveSeeds.isEmpty()) {
ArrayList<WaveSeedLog> waveSeedLogs = new ArrayList<>();
@@ -537,11 +534,15 @@
if (!waveSeedLogService.saveBatch(waveSeedLogs)) {
throw new CoolException("娉㈡槑鍘嗗彶妗ｄ繚瀛樺け璐ワ紒锛�");
}
+
+ List<Long> list = waveSeeds.stream().map(WaveSeed::getId).collect(Collectors.toList());
+ //鍒犻櫎鎾鏄庣粏淇℃伅
+ if (!waveSeedMapper.removeByIds(list)) {
+ throw new CoolException("鎾鏄庣粏鍒犻櫎鎼虹▼锛侊紒");
+ }
+
}
- //鍒犻櫎鎾鏄庣粏淇℃伅
- if (waveSeedMapper.deleteByIds(waveSeeds) < 1) {
- throw new CoolException("鎾鏄庣粏鍒犻櫎鎼虹▼锛侊紒");
- }
+
});
orderList.forEach(one -> {
--
Gitblit v1.9.1