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