From faed059302b334b39f247fa8bde5daa8f0b924f5 Mon Sep 17 00:00:00 2001
From: zwl <1051256694@qq.com>
Date: 星期一, 24 十一月 2025 17:58:23 +0800
Subject: [PATCH] 1.晚上erp订单同步删除功能
---
src/main/java/com/zy/third/task/handler/OrderHandler.java | 66 ++++++++++++++++++++++++++++----
1 files changed, 57 insertions(+), 9 deletions(-)
diff --git a/src/main/java/com/zy/third/task/handler/OrderHandler.java b/src/main/java/com/zy/third/task/handler/OrderHandler.java
index d5015da..7eed914 100644
--- a/src/main/java/com/zy/third/task/handler/OrderHandler.java
+++ b/src/main/java/com/zy/third/task/handler/OrderHandler.java
@@ -211,18 +211,41 @@
}
@Transactional
- public ReturnT<String> deletereadInOrder(List<ExdInstockSource> exdInstockSource) {
- String fbillno = exdInstockSource.get(0).getFbillno();
+ public ReturnT<String> deletereadInOrder(ExdInstockSource exdInstockSource) {
+ String fbillno = exdInstockSource.getFbillno();
Order order = orderService.selectByNo(fbillno);
- if (!Cools.isEmpty(order)&&order.getStatus()>1) {
+ if (!Cools.isEmpty(order)) {
if (order.getSettle() > 1L) {
throw new CoolException(fbillno + "鍗曟嵁姝ｅ湪浣滀笟涓紝鏃犳硶鍒犻櫎");
}
- orderService.remove(order.getId());
+ Mat mat = matService.selectBySku(exdInstockSource.getFitemid() + "");
+ OrderDetl orderDetl = orderDetlService.selectOne(new EntityWrapper<OrderDetl>().eq("order_no", order.getOrderNo())
+ .eq("matnr", mat.getMatnr())
+ .eq("batch", exdInstockSource.getFbatchno())
+ .eq("anfme", exdInstockSource.getFqty()<0 ? -exdInstockSource.getFqty():exdInstockSource.getFqty()));
+ if (orderDetl != null) {
+ boolean delete = orderDetlService.deleteById(orderDetl.getId());
+ if (delete) {
+ log.info("鍒犻櫎璁㈠崟鏄庣粏鎴愬姛锛岃鍗曞彿={},鐗╂枡鍙�={}锛屾壒鍙�={}锛屾暟閲�={}鎴愬姛",order.getOrderNo(),exdInstockSource.getFitemid(),exdInstockSource.getFbatchno(),exdInstockSource.getFqty());
+ }else {
+ log.error("鍒犻櫎璁㈠崟鏄庣粏澶辫触锛岃鍗曞彿={},鐗╂枡鍙�={}锛屾壒鍙�={}锛屾暟閲�={}",order.getOrderNo(),exdInstockSource.getFitemid(),exdInstockSource.getFbatchno(),exdInstockSource.getFqty());
+ throw new CoolException(fbillno + "鍗曟嵁鏄庣粏鍒犻櫎澶辫触");
+ }
+ }else {
+ log.error("娌℃湁鏌ヨ鍒拌鍗曟槑缁嗭紝璁㈠崟鍙�={},鐗╂枡鍙�={}锛屾壒鍙�={}锛屾暟閲�={}",order.getOrderNo(),exdInstockSource.getFitemid(),exdInstockSource.getFbatchno(),exdInstockSource.getFqty());
+ throw new CoolException(fbillno + "娌℃湁鏌ヨ鍒拌鍗曟槑缁�");
+ }
+
+ int orderNo = orderDetlService.selectCount(new EntityWrapper<OrderDetl>().eq("order_no", order.getOrderNo()));
+ if(orderNo==0){
+ orderService.remove(order.getId());
+ log.info("鍒犻櫎璁㈠崟涓昏〃鎴愬姛锛岃鍗�={}",order.getOrderNo());
+ }
+ }else if(Cools.isEmpty(order)){
+ throw new CoolException(fbillno + "鍗曟嵁涓哄湪WMS涓壘鍒�");
}
return SUCCESS;
}
-
@Transactional
public ReturnT<String> readOutOrder(List<ExdOutstockSource> exdOutstockSource) {
@@ -328,14 +351,39 @@
}
@Transactional
- public ReturnT<String> deletereadOutOrder(List<ExdOutstockSource> exdInstockSource) {
- String fbillno = exdInstockSource.get(0).getFbillno();
+ public ReturnT<String> deletereadOutOrder(ExdOutstockSource exdInstockSource) {
+ String fbillno = exdInstockSource.getFbillno();
Order order = orderService.selectByNo(fbillno);
- if (!Cools.isEmpty(order)&&order.getStatus()>1) {
+ if (!Cools.isEmpty(order)) {
if (order.getSettle() > 1L) {
throw new CoolException(fbillno + "鍗曟嵁姝ｅ湪浣滀笟涓紝鏃犳硶鍒犻櫎");
}
- orderService.remove(order.getId());
+ Mat mat = matService.selectBySku(exdInstockSource.getFitemid() + "");
+ OrderDetl orderDetl = orderDetlService.selectOne(new EntityWrapper<OrderDetl>().eq("order_no", order.getOrderNo())
+ .eq("matnr", mat.getMatnr())
+ .eq("batch", exdInstockSource.getFbatchno())
+ .eq("anfme", exdInstockSource.getFqty()<0 ? -exdInstockSource.getFqty():exdInstockSource.getFqty()));
+ if (orderDetl != null) {
+ boolean delete = orderDetlService.deleteById(orderDetl.getId());
+ if (delete) {
+ log.info("鍒犻櫎璁㈠崟鏄庣粏鎴愬姛锛岃鍗曞彿={},鐗╂枡鍙�={}锛屾壒鍙�={}锛屾暟閲�={}鎴愬姛",order.getOrderNo(),exdInstockSource.getFitemid(),exdInstockSource.getFbatchno(),exdInstockSource.getFqty());
+ }else {
+ log.error("鍒犻櫎璁㈠崟鏄庣粏澶辫触锛岃鍗曞彿={},鐗╂枡鍙�={}锛屾壒鍙�={}锛屾暟閲�={}",order.getOrderNo(),exdInstockSource.getFitemid(),exdInstockSource.getFbatchno(),exdInstockSource.getFqty());
+ throw new CoolException(fbillno + "鍗曟嵁鏄庣粏鍒犻櫎澶辫触");
+ }
+ }else {
+ log.error("娌℃湁鏌ヨ鍒拌鍗曟槑缁嗭紝璁㈠崟鍙�={},鐗╂枡鍙�={}锛屾壒鍙�={}锛屾暟閲�={}",order.getOrderNo(),exdInstockSource.getFitemid(),exdInstockSource.getFbatchno(),exdInstockSource.getFqty());
+ throw new CoolException(fbillno + "娌℃湁鏌ヨ鍒拌鍗曟槑缁�");
+ }
+ int orderNo = orderDetlService.selectCount(new EntityWrapper<OrderDetl>().eq("order_no", order.getOrderNo()));
+ if(orderNo==0){
+ orderService.remove(order.getId());
+ log.info("鍒犻櫎璁㈠崟涓昏〃鎴愬姛锛岃鍗�={}",order.getOrderNo());
+ }
+
+
+ }else if (Cools.isEmpty(order)) {
+ throw new CoolException(fbillno + "鍗曟嵁鏈湪WMS涓壘鍒�");
}
return SUCCESS;
}
--
Gitblit v1.9.1