From b10df09872f788e8ca75b9b3f3165265c8cf32c3 Mon Sep 17 00:00:00 2001
From: lty <876263681@qq.com>
Date: 星期一, 19 五月 2025 15:00:15 +0800
Subject: [PATCH] #pda盘点入库开发
---
src/main/java/com/zy/third/erp/task/ERPItemScheduler.java | 19 ++++++++++++-------
1 files changed, 12 insertions(+), 7 deletions(-)
diff --git a/src/main/java/com/zy/third/erp/task/ERPItemScheduler.java b/src/main/java/com/zy/third/erp/task/ERPItemScheduler.java
index b4b10c9..7106d57 100644
--- a/src/main/java/com/zy/third/erp/task/ERPItemScheduler.java
+++ b/src/main/java/com/zy/third/erp/task/ERPItemScheduler.java
@@ -7,6 +7,7 @@
import org.springframework.beans.factory.annotation.Value;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Transactional;
import java.util.List;
@@ -20,27 +21,31 @@
private Boolean erpEnabled;
@Autowired
- private ERPItemSchedulerMS erpItemSchedulerMS;
+ private ERPItemService erpItemService;
@Autowired
private ErpSqlServer erpSqlServer;
+
+
+ @Transactional(rollbackFor = Throwable.class)
@Scheduled(cron = "${erp.refreshtime}")
public void ItemScheduler() {
- log.info("ItemScheduler寮�濮嬩簡");
+// log.info("ItemScheduler寮�濮嬩簡");
if (!erpEnabled) return;
- String sqlItemTB = "select * from erp_ItemTB where LKName='涓壃浜屾湡'";
+ String sqlItemTB = "select TOP 1000 * from erp_ItemTB where LKName='楂橀湒绔嬪簱'";
List<ItemTB> itemTBS = erpSqlServer.select(sqlItemTB, ItemTB.class);
if (itemTBS != null && itemTBS.size() > 0) {
for (ItemTB itemTB : itemTBS) {
- System.out.println(itemTB);
+ log.info("鏂板鐗╂枡鎴愬姛,{}", itemTB);
//00浠ｈ〃鏂板
if (itemTB.getFlag().equals("00")) {
- erpItemSchedulerMS.addToMainDatabase(itemTB);
+ erpItemService.addToMainDatabase(itemTB);
}
//22浠ｈ〃鍒犻櫎
if (itemTB.getFlag().equals("22")) {
- erpItemSchedulerMS.deleteFromMainDatabase(itemTB);
+ log.info("鍒犻櫎鐗╂枡鎴愬姛,{}", itemTB);
+ erpItemService.deleteFromMainDatabase(itemTB);
}
moveToBak(itemTB);
}
@@ -54,6 +59,6 @@
*/
//灏嗘暟鎹粠涓昏〃绉诲姩鍒癰ak琛ㄩ噷
private void moveToBak(ItemTB itemTB) {
- erpSqlServer.update("delete from erp_ItemTB where LKName='涓壃浜屾湡' and ItemId = '" + itemTB.getItemId() + "'");
+ erpSqlServer.update("delete from erp_ItemTB where LKName='楂橀湒绔嬪簱' and Item_id = '" + itemTB.getItemId() + "'");
}
}
--
Gitblit v1.9.1