From 24d37bcb29bbafe3f8c917e08b6d3828c6e6d8c4 Mon Sep 17 00:00:00 2001 From: zhanghl <253316343@qq.com> Date: 星期四, 15 五月 2025 16:59:11 +0800 Subject: [PATCH] 优化同步WorkOrder:先全部删除,再进行同步 --- aps-modules/aps-job/src/main/java/com/aps/job/task/RyTask.java | 29 +++++++++++++++++++++++++---- 1 files changed, 25 insertions(+), 4 deletions(-) diff --git a/aps-modules/aps-job/src/main/java/com/aps/job/task/RyTask.java b/aps-modules/aps-job/src/main/java/com/aps/job/task/RyTask.java index efecb7a..dbbdb6a 100644 --- a/aps-modules/aps-job/src/main/java/com/aps/job/task/RyTask.java +++ b/aps-modules/aps-job/src/main/java/com/aps/job/task/RyTask.java @@ -40,6 +40,9 @@ @Autowired private IApsStandardProcessRouteHeaderJobService apsStandardProcessRouteHeaderJobService; + @Autowired + private IApsMaterialManagementJobService apsMaterialManagementJobService; + public void ryMultipleParams(String s, Boolean b, Long l, Double d, Integer i) { System.out.println(StringUtils.format("鎵ц澶氬弬鏂规硶锛� 瀛楃涓茬被鍨媨}锛屽竷灏旂被鍨媨}锛岄暱鏁村瀷{}锛屾诞鐐瑰瀷{}锛屾暣褰}", s, b, l, d, i)); @@ -116,6 +119,7 @@ public void syncAllWorkOrder() { + iApsWorkOrderJobService.deleteAllWorkOrderJob(); boolean continueFlag = true; Integer currentPage = 1; ApsWorkOrderJobParam param=new ApsWorkOrderJobParam(); @@ -163,7 +167,10 @@ */ public void syncApsMaterialStorageDataJob(Integer pageIndex, Integer pageSize, String orgCode, String itemCodeList) { - apsMaterialStorageManagementJobService.syncApsMaterialStorageDataJob(pageIndex, pageSize, orgCode, itemCodeList); + boolean res = apsMaterialStorageManagementJobService.syncApsMaterialStorageDataJob(pageIndex, pageSize, orgCode, itemCodeList); + if(res){ + remoteCoreService.setStorageDataToRedis(SecurityConstants.INNER); + } } /** @@ -172,10 +179,24 @@ public void syncProcessRouteJob(Integer pageIndex, Integer pageSize, String orgCode, String itemCodeList) { boolean res = apsStandardProcessRouteHeaderJobService.syncProcessRouteDataJob(pageIndex, pageSize, orgCode, itemCodeList); -// if(res){ -// remoteCoreService.setBomDataToRedis(SecurityConstants.INNER); -// } + if(res){ + remoteCoreService.setProcessRouteDataToRedis(SecurityConstants.INNER); + } } + /** + * 鍚屾鍏ㄩ噺鐗╂枡鏁版嵁瀹氭椂浠诲姟 + */ + public void syncApsMaterialDataJob(Integer pageIndex, Integer pageSize, String orgCode, String itemCodeList) + { + apsMaterialManagementJobService.syncApsMaterialDataJob(pageIndex, pageSize, orgCode, itemCodeList); + } + + /** + * 鍒锋柊閽i噾瀛愬崟鏁版嵁鍒癛edis + */ + public void setPlateSubPlansToRedis(){ + remoteCoreService.setPlateSubPlansToRedis(SecurityConstants.INNER); + } } -- Gitblit v1.9.3