From dc13d06680b693b22fd21cbea6b3b06ed8f964d4 Mon Sep 17 00:00:00 2001 From: zc <zc> Date: 星期四, 25 七月 2024 14:51:07 +0800 Subject: [PATCH] 新增盘点入库 --- src/main/java/com/zy/third/erp/task/ERPItemScheduler.java | 12 ++++++++---- 1 files changed, 8 insertions(+), 4 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..9349421 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,14 +21,17 @@ 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='涓壃浜屾湡'"; List<ItemTB> itemTBS = erpSqlServer.select(sqlItemTB, ItemTB.class); @@ -36,11 +40,11 @@ System.out.println(itemTB); //00浠h〃鏂板 if (itemTB.getFlag().equals("00")) { - erpItemSchedulerMS.addToMainDatabase(itemTB); + erpItemService.addToMainDatabase(itemTB); } //22浠h〃鍒犻櫎 if (itemTB.getFlag().equals("22")) { - erpItemSchedulerMS.deleteFromMainDatabase(itemTB); + erpItemService.deleteFromMainDatabase(itemTB); } moveToBak(itemTB); } -- Gitblit v1.9.1