From 1443d5a84a4df99d9a86ac04c904554e91ae8271 Mon Sep 17 00:00:00 2001
From: zwl <1051256694@qq.com>
Date: 星期日, 12 四月 2026 15:35:06 +0800
Subject: [PATCH] 1.针对7.3接口文档，新增了几个字段需要加入到组托档中，不额外加字段 2.针对7.11接口文档，对outOrder方法进行重写，batchSeq在wrkMast表中新增一个字段放，entryWmsCode、outDoorNo这两个在wrkDetl中找两个字段存放 3.针对7.7接口文档，上报时加上orderId出库单号 4.针对7.9接口文档，wcs会先请求wms，只需要palletId托盘码，errorMsg错误信息；wms转发给加上orderId出库单号转发给ERP 5.针对7.10接口文档，ERP先按照这个文档发给wms，wms再发给wcs，发给wcs这块先不写
---
src/main/java/com/zy/asrs/controller/OpenController.java | 89 +++++++++++++++++++++++++++++++++++---------
1 files changed, 70 insertions(+), 19 deletions(-)
diff --git a/src/main/java/com/zy/asrs/controller/OpenController.java b/src/main/java/com/zy/asrs/controller/OpenController.java
index 0578025..9cfad2a 100644
--- a/src/main/java/com/zy/asrs/controller/OpenController.java
+++ b/src/main/java/com/zy/asrs/controller/OpenController.java
@@ -439,8 +439,7 @@
}
/**
- * 缁勬墭淇℃伅涓嬪彂
- * return
+ * 7.3 缁勬墭淇℃伅涓嬪彂
*/
@PostMapping("/comb/auth")
public synchronized R comb(@RequestBody ArrayList<MesToCombParam> param, HttpServletRequest request) {
@@ -487,9 +486,8 @@
}
/**
- * 鍑哄簱閫氱煡鍗�
+ * 7.11 鍑哄簱閫氱煡鍗曪紙浼犻�掓湁搴忔棤搴忚鍒欙級
*/
-
@PostMapping("/outOrder")
public synchronized R outOrder(@RequestBody ArrayList<OutTaskParam> params, HttpServletRequest request) {
if (Cools.isEmpty(params)) {
@@ -497,32 +495,51 @@
}
log.info("[outOrder] cache: {}", JSON.toJSONString(params));
request.setAttribute("cache", params);
- Set<String> orderIds = new LinkedHashSet<>();
+ Map<String, List<OutTaskParam>> linesByBatch = new LinkedHashMap<>();
for (OutTaskParam outTaskParam : params) {
if (Cools.isEmpty(outTaskParam) || Cools.isEmpty(outTaskParam.getOrderId())) {
return R.error("鍑哄簱鍗曞彿涓嶈兘涓虹┖");
}
- orderIds.add(outTaskParam.getOrderId());
+ if (Cools.isEmpty(outTaskParam.getBatchSeq())) {
+ outTaskParam.setBatchSeq(outTaskParam.getOrderId());
+ }
+ if (Cools.isEmpty(outTaskParam.getStationId())) {
+ return R.error("鎵樼洏銆�" + outTaskParam.getPalletId() + "銆嶅嚭搴撳彛缂栫爜涓嶈兘涓虹┖");
+ }
+ linesByBatch.computeIfAbsent(outTaskParam.getBatchSeq(), k -> new ArrayList<>()).add(outTaskParam);
}
- Map<String, List<OutTaskParam>> linesByOrder = new LinkedHashMap<>();
- for (OutTaskParam outTaskParam : params) {
- linesByOrder.computeIfAbsent(outTaskParam.getOrderId(), k -> new ArrayList<>()).add(outTaskParam);
- }
- for (Map.Entry<String, List<OutTaskParam>> entry : linesByOrder.entrySet()) {
- String oid = entry.getKey();
+ for (Map.Entry<String, List<OutTaskParam>> entry : linesByBatch.entrySet()) {
List<OutTaskParam> lines = entry.getValue();
- List<Integer> seqs = new ArrayList<>(lines.size());
+ OutTaskParam head = lines.get(0);
+ String oid = head.getOrderId();
+ String batchSeq = head.getBatchSeq();
+ boolean hasZero = false;
+ boolean hasPositive = false;
+ List<Integer> orderedSeqs = new ArrayList<>(lines.size());
for (OutTaskParam line : lines) {
if (line.getSeq() == null) {
- return R.error("鍑哄簱鍗曘��" + oid + "銆嶅簭鍙蜂笉鑳戒负绌�");
+ return R.error("鍑哄簱鍗曘��" + oid + "銆嶆壒娆°��" + batchSeq + "銆嶅簭鍙蜂笉鑳戒负绌�");
}
- seqs.add(line.getSeq());
+ if (line.getSeq() < 0) {
+ return R.error("鍑哄簱鍗曘��" + oid + "銆嶆壒娆°��" + batchSeq + "銆嶅簭鍙蜂笉鑳藉皬浜�0");
+ }
+ if (line.getSeq() == 0) {
+ hasZero = true;
+ } else {
+ hasPositive = true;
+ orderedSeqs.add(line.getSeq());
+ }
}
- Collections.sort(seqs);
- for (int i = 0; i < seqs.size(); i++) {
- if (!String.valueOf(seqs.get(i)).equals(String.valueOf(i + 1))) {
- return R.error("鍑哄簱鍗曘��" + oid + "銆嶅簭鍙蜂笉杩炶疮");
+ if (hasZero && hasPositive) {
+ return R.error("鍑哄簱鍗曘��" + oid + "銆嶆壒娆°��" + batchSeq + "銆嶅簭鍙蜂笉鑳芥贩鐢ㄦ棤搴忓拰鏈夊簭");
+ }
+ if (!hasZero) {
+ Collections.sort(orderedSeqs);
+ for (int i = 0; i < orderedSeqs.size(); i++) {
+ if (!Objects.equals(orderedSeqs.get(i), i + 1)) {
+ return R.error("鍑哄簱鍗曘��" + oid + "銆嶆壒娆°��" + batchSeq + "銆嶅簭鍙蜂笉杩炶疮");
+ }
}
}
}
@@ -589,6 +606,36 @@
}
/**
+ * 7.9 鍑哄簱寮傚父鍙樺姩涓婃姤
+ */
+ @PostMapping("/order/pakout/abnormal/report/v1")
+ public synchronized R outOrderAbnormalReport(@RequestBody OutOrderAbnormalReportParam param, HttpServletRequest request) {
+ if (request != null) {
+ log.info("[outOrderAbnormalReport] cache: {}", param == null ? "null" : JSON.toJSONString(param));
+ request.setAttribute("cache", param);
+ }
+ if (Cools.isEmpty(param) || Cools.isEmpty(param.getPalletId())) {
+ return R.error("palletId涓嶈兘涓虹┖");
+ }
+ return openService.outOrderAbnormalReport(param);
+ }
+
+ /**
+ * 7.10 鍑哄簱寮傚父鍙樺姩澶勭悊
+ */
+ @PostMapping("/order/pakout/abnormal/handle/v1")
+ public synchronized R outOrderAbnormalHandle(@RequestBody OutOrderAbnormalHandleParam param, HttpServletRequest request) {
+ if (request != null) {
+ log.info("[outOrderAbnormalHandle] cache: {}", param == null ? "null" : JSON.toJSONString(param));
+ request.setAttribute("cache", param);
+ }
+ if (Cools.isEmpty(param) || Cools.isEmpty(param.getPalletId())) {
+ return R.error("palletId涓嶈兘涓虹┖");
+ }
+ return openService.outOrderAbnormalHandle(param);
+ }
+
+ /**
* pause out order
*/
@PostMapping("/order/pakout/pause/default/v1")
@@ -603,6 +650,10 @@
return openService.pakoutOrderPause(param);
}
+ private String buildOutOrderBatchKey(OutTaskParam param) {
+ return param.getOrderId() + "#" + param.getBatchSeq();
+ }
+
/*************************************鐢佃鏈虹▼搴�***********************************************/
--
Gitblit v1.9.1