From c945a29f5be6b38dd5fb0b398abf3ca3e937dd56 Mon Sep 17 00:00:00 2001
From: mrzhssss <pro6@qq.com>
Date: 星期六, 19 三月 2022 09:39:34 +0800
Subject: [PATCH] #
---
src/main/java/zy/cloud/wms/manager/service/impl/WaveServiceImpl.java | 55 +++++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 55 insertions(+), 0 deletions(-)
diff --git a/src/main/java/zy/cloud/wms/manager/service/impl/WaveServiceImpl.java b/src/main/java/zy/cloud/wms/manager/service/impl/WaveServiceImpl.java
index 724cbb7..841a1cb 100644
--- a/src/main/java/zy/cloud/wms/manager/service/impl/WaveServiceImpl.java
+++ b/src/main/java/zy/cloud/wms/manager/service/impl/WaveServiceImpl.java
@@ -1,12 +1,67 @@
package zy.cloud.wms.manager.service.impl;
+import com.baomidou.mybatisplus.mapper.EntityWrapper;
+import com.core.common.Cools;
+import com.core.exception.CoolException;
+import org.springframework.beans.factory.annotation.Autowired;
+import zy.cloud.wms.manager.entity.WaveDetl;
import zy.cloud.wms.manager.mapper.WaveMapper;
import zy.cloud.wms.manager.entity.Wave;
+import zy.cloud.wms.manager.service.OrderService;
+import zy.cloud.wms.manager.service.WaveDetlService;
import zy.cloud.wms.manager.service.WaveService;
import com.baomidou.mybatisplus.service.impl.ServiceImpl;
import org.springframework.stereotype.Service;
+import java.util.ArrayList;
+import java.util.HashSet;
+import java.util.List;
+
@Service("waveService")
public class WaveServiceImpl extends ServiceImpl<WaveMapper, Wave> implements WaveService {
+ @Autowired
+ private WaveDetlService waveDetlService;
+ @Autowired
+ private OrderService orderService;
+ @Autowired
+ private WaveService waveService;
+ /**
+ * 閫氳繃娉㈡鐢熸垚鎷ｈ揣鍗�
+ * @param wave
+ * @param userId
+ * @param hostId
+ */
+ @Override
+ public void createOut(Wave wave, Long userId, Long hostId) {
+ HashSet<String> orderIds = new HashSet<>();
+ /**
+ * 鎺х
+ */
+ List<WaveDetl> waveDetls = waveDetlService.selectList(new EntityWrapper<WaveDetl>()
+ .eq("wave_id", wave.getId()));
+ if (Cools.isEmpty(waveDetls)) {
+ throw new CoolException("鎵句笉鍒拌娉㈡鍗曠殑璇︽儏,璇疯仈绯荤鐞嗗憳");
+ }
+
+ /**
+ * 鏇存敼鍑哄簱鍗曠姸鎬�,浠�"鐢熸垚娉㈡"鍒�"娉㈡鎷ｈ揣涓�"
+ */
+ for (WaveDetl waveDetl : waveDetls) {
+ String orderNos = waveDetl.getOrderNos();
+ String[] split = orderNos.split(",");
+ for (String s : split) {
+ orderIds.add(s);
+ }
+ }
+ for (String s : new ArrayList<String>(orderIds)) {
+ orderService.changeSettleTo12(s);
+ }
+ /**
+ * 鏇存敼娉㈡鍗曠姸鎬�,浠�"寰呭鐞�"鍒�"澶勭悊涓�"
+ */
+ wave.setStatus((short) 1);
+ waveService.update(wave,new EntityWrapper<Wave>()
+ .eq("id",wave.getId()));
+ }
}
--
Gitblit v1.9.1