From 86637e6a48cc4511e34fe426d5a617e3ee018dfa Mon Sep 17 00:00:00 2001
From: huangjiayang <5265313@qq.com>
Date: 星期五, 09 五月 2025 13:21:52 +0800
Subject: [PATCH] 【ADD】1.新增同步物料库存数据任务 2.增加刷新BOM数据功能代码
---
aps-modules/aps-job/src/main/java/com/aps/job/service/impl/ApsBomHeaderJobServiceImpl.java | 33 ++++++++++++++++++++++++++++++---
1 files changed, 30 insertions(+), 3 deletions(-)
diff --git a/aps-modules/aps-job/src/main/java/com/aps/job/service/impl/ApsBomHeaderJobServiceImpl.java b/aps-modules/aps-job/src/main/java/com/aps/job/service/impl/ApsBomHeaderJobServiceImpl.java
index 3a1fa14..c307d96 100644
--- a/aps-modules/aps-job/src/main/java/com/aps/job/service/impl/ApsBomHeaderJobServiceImpl.java
+++ b/aps-modules/aps-job/src/main/java/com/aps/job/service/impl/ApsBomHeaderJobServiceImpl.java
@@ -19,6 +19,7 @@
import org.springframework.http.MediaType;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.client.RestTemplate;
import java.util.ArrayList;
@@ -39,9 +40,6 @@
@Autowired
private ApsBomLineJobMapper apsBomLineJobMapper;
- /**
- * 鑾峰彇璁㈠崟鎺ュ彛
- * */
@Value("${u9.bomJobUrl}")
private String getBomUrl;
@@ -223,4 +221,33 @@
}
return true;
}
+
+ /**
+ * 鍏ㄩ噺鍚屾BOM鏁版嵁瀹氭椂浠诲姟
+ * @param pageIndex
+ * @param pageSize
+ * @param orgCode
+ * @param itemCodeList
+ * @return
+ */
+ @Transactional(rollbackFor = Exception.class)
+ @Override
+ public boolean syncBomDataJob(Integer pageIndex, Integer pageSize, String orgCode, String itemCodeList){
+ try {
+ apsBomHeaderJobMapper.deleteApsBomHeaderJob();
+ apsBomLineJobMapper.deleteApsBomLineJob();
+ boolean res = syncBomData(pageIndex, pageSize, orgCode, itemCodeList);
+ if(!res){
+ return false;
+ }
+ apsBomHeaderJobMapper.deleteApsBomHeader();
+ apsBomLineJobMapper.deleteApsBomLine();
+ apsBomHeaderJobMapper.insertIntoApsBomHeader();
+ apsBomLineJobMapper.insertIntoApsBomLine();
+ } catch (Exception e) {
+ e.printStackTrace();
+ throw new RuntimeException(e);
+ }
+ return true;
+ }
}
--
Gitblit v1.9.3