From 48db618606f0f0cafd1ce795f8bf26a0bcec2581 Mon Sep 17 00:00:00 2001
From: zhangchao <zc857179121@qq.com>
Date: 星期六, 20 七月 2024 07:56:54 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/xgmFlasrs' into xgmFlasrs
---
src/main/java/com/zy/third/erp/task/ERPItemScheduler.java | 63 +++++++++++++++++++++++++++++++
1 files changed, 63 insertions(+), 0 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
new file mode 100644
index 0000000..5d526de
--- /dev/null
+++ b/src/main/java/com/zy/third/erp/task/ERPItemScheduler.java
@@ -0,0 +1,63 @@
+package com.zy.third.erp.task;
+
+import com.zy.common.service.erp.ErpSqlServer;
+import com.zy.third.erp.entity.ItemTB;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+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;
+
+/**
+ * 鐗╂枡妗ｆ
+ */
+@Slf4j
+@Component
+public class ERPItemScheduler {
+ @Value("${erp.enabled}")
+ private Boolean erpEnabled;
+
+ @Autowired
+ private ERPItemService erpItemService;
+
+ @Autowired
+ private ErpSqlServer erpSqlServer;
+
+
+
+ @Transactional(rollbackFor = Throwable.class)
+ @Scheduled(cron = "${erp.refreshtime}")
+ public void ItemScheduler() {
+ log.info("ItemScheduler寮�濮嬩簡");
+ if (!erpEnabled) return;
+ String sqlItemTB = "select * 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);
+ //00浠ｈ〃鏂板
+ if (itemTB.getFlag().equals("00")) {
+ erpItemService.addToMainDatabase(itemTB);
+ }
+ //22浠ｈ〃鍒犻櫎
+ if (itemTB.getFlag().equals("22")) {
+ erpItemService.deleteFromMainDatabase(itemTB);
+ }
+ moveToBak(itemTB);
+ }
+ }
+ }
+
+ /**
+ * 鏁版嵁搴撻噷鏈夎Е鍙戝櫒,褰搃tem琛ㄧ殑鏁版嵁琚垹闄ゆ椂,浼氳嚜鍔ㄥ悜item_bak娣诲姞,涓嶇敤鍗歌浇浠ｇ爜閲�
+ *
+ * @param itemTB
+ */
+ //灏嗘暟鎹粠涓昏〃绉诲姩鍒癰ak琛ㄩ噷
+ private void moveToBak(ItemTB itemTB) {
+ erpSqlServer.update("delete from erp_ItemTB where LKName='涓壃浜屾湡' and ItemId = '" + itemTB.getItemId() + "'");
+ }
+}
--
Gitblit v1.9.1