From 1f97a20465e29c4ae1824aa66408c77213812c40 Mon Sep 17 00:00:00 2001
From: lty <876263681@qq.com>
Date: 星期三, 19 十一月 2025 16:38:18 +0800
Subject: [PATCH] #新增erp中间表库存同步功能
---
src/main/java/com/zy/third/erp/task/ERPOutCancelScheduler.java | 24 ++++++++++++------------
1 files changed, 12 insertions(+), 12 deletions(-)
diff --git a/src/main/java/com/zy/third/erp/task/ERPOutCancelScheduler.java b/src/main/java/com/zy/third/erp/task/ERPOutCancelScheduler.java
index 3a42393..84c47f2 100644
--- a/src/main/java/com/zy/third/erp/task/ERPOutCancelScheduler.java
+++ b/src/main/java/com/zy/third/erp/task/ERPOutCancelScheduler.java
@@ -28,34 +28,34 @@
@Transactional(rollbackFor = Throwable.class)
- //@Scheduled(cron = "${erp.refreshtime}")
- public void InCancelScheduler() {
+ @Scheduled(cron = "${erp.refreshtime}")
+ public void OutCancelScheduler() {
//log.info("InCancelScheduler寮�濮嬩簡");
if (!erpEnabled) return;
- String sqlInCancelTB = "select * from erp_OutCancelTB where LKName='楂橀湒绔嬪簱'";
+ String sqlInCancelTB = "select * from erp_OutCancelTB";
List<OutCancelTB> ins = erpSqlServer.select(sqlInCancelTB, OutCancelTB.class);
for (OutCancelTB in : ins) {
- com.zy.third.lk.entity.InCancelTB lkCancel = inMS.tryCancel(in.getBillNo());
+ com.zy.third.lk.entity.OutCancelTB lkCancel = inMS.tryCancelOut(in.getBillNo());
if (lkCancel != null) {
HashMap<String, String> condition = new HashMap<>();
condition.put("BillNo", "'" + in.getBillNo() + "'");
- int delete = erpSqlServer.delete(InCancelTB.class, condition);
+ int delete = erpSqlServer.delete(com.zy.third.erp.entity.OutCancelTB.class, condition);
if (delete > 0) {
- log.info("灏嗗叆搴撳彇娑堥�氱煡鍗曞垹闄ゆ垚鍔�,{}", lkCancel.getBillNo());
+ log.info("灏嗗嚭搴撳彇娑堥�氱煡鍗曞垹闄ゆ垚鍔�,{}", lkCancel.getBillNo());
} else {
- log.error("灏嗗叆搴撳彇娑堥�氱煡鍗曞垹闄ゅけ璐�,{}", lkCancel.getBillNo());
+ log.error("灏嗗嚭搴撳彇娑堥�氱煡鍗曞垹闄ゅけ璐�,{}", lkCancel.getBillNo());
}
HashMap<String, Object> content = new HashMap<>();
content.put("BillNo", "'" + lkCancel.getBillNo() + "'");
- content.put("opFlag", lkCancel.getOpFlag());
- int insert = erpSqlServer.insert(com.zy.third.lk.entity.InCancelTB.class, content);
+// content.put("opFlag", lkCancel.getOpFlag());
+ int insert = erpSqlServer.insert(com.zy.third.lk.entity.OutCancelTB.class, content);
if (insert > 0) {
- log.info("灏嗗叆搴撳彇娑堥�氱煡鍗曞啓鍏ユ垚鍔�,{}", lkCancel.getBillNo());
+ log.info("灏嗗嚭搴撳彇娑堥�氱煡鍗曞啓鍏ユ垚鍔�,{}", lkCancel.getBillNo());
} else {
- log.error("灏嗗叆搴撳彇娑堥�氱煡鍗曞啓鍏ュけ璐�,{}", lkCancel.getBillNo());
+ log.error("灏嗗嚭搴撳彇娑堥�氱煡鍗曞啓鍏ュけ璐�,{}", lkCancel.getBillNo());
}
} else {
- log.error("灏嗗叆搴撳彇娑堥�氱煡鍗曞啓鍏ュけ璐�");
+ log.error("灏嗗嚭搴撳彇娑堥�氱煡鍗曞啓鍏ュけ璐�");
}
}
}
--
Gitblit v1.9.1