From 025934b151c3f5edc782f5a35cd126910a720740 Mon Sep 17 00:00:00 2001
From: zc <zc>
Date: 星期六, 27 七月 2024 18:09:49 +0800
Subject: [PATCH] 代码bug修改调试

---
 src/main/java/com/zy/third/erp/task/ERPItemScheduler.java |   17 +++++++++++------
 1 files changed, 11 insertions(+), 6 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..f5dd32b 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浠h〃鏂板
                 if (itemTB.getFlag().equals("00")) {
-                    erpItemSchedulerMS.addToMainDatabase(itemTB);
+                    erpItemService.addToMainDatabase(itemTB);
                 }
                 //22浠h〃鍒犻櫎
                 if (itemTB.getFlag().equals("22")) {
-                    erpItemSchedulerMS.deleteFromMainDatabase(itemTB);
+                    log.info("鍒犻櫎鐗╂枡鎴愬姛,{}", itemTB);
+                    erpItemService.deleteFromMainDatabase(itemTB);
                 }
                 moveToBak(itemTB);
             }

--
Gitblit v1.9.1