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 | 88 +++++++++++++++++++++++++++++++++++++++++--- 1 files changed, 82 insertions(+), 6 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 eefc16c..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 @@ -1,9 +1,10 @@ package com.aps.job.task; +import com.aps.common.core.constant.SecurityConstants; import com.aps.common.core.utils.StringUtils; import com.aps.job.param.ApsWorkOrderJobParam; -import com.aps.job.service.IApsWorkOrderJobService; -import com.aps.job.service.IApsWorkOrderProcessService; +import com.aps.job.service.*; +import com.aps.system.api.RemoteCoreService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; @@ -26,6 +27,21 @@ @Autowired private IApsWorkOrderJobService iApsWorkOrderJobService; + + @Autowired + private IApsBomHeaderJobService iApsBomHeaderJobService; + + @Autowired + private RemoteCoreService remoteCoreService; + + @Autowired + private IApsMaterialStorageManagementJobService apsMaterialStorageManagementJobService; + + @Autowired + private IApsStandardProcessRouteHeaderJobService apsStandardProcessRouteHeaderJobService; + + @Autowired + private IApsMaterialManagementJobService apsMaterialManagementJobService; public void ryMultipleParams(String s, Boolean b, Long l, Double d, Integer i) { @@ -90,7 +106,7 @@ param.setDocState(Arrays.asList(0,1,2,4)); param.setBeginDate(yesterdayMidnight.format(formatter)); param.setEndDate(today.format(formatter)); - param.setPageSize(1000); + param.setPageSize(500); while (continueFlag){ param.setPageIndex(currentPage); continueFlag= iApsWorkOrderJobService.batchSaveByPager(param); @@ -103,12 +119,13 @@ public void syncAllWorkOrder() { + iApsWorkOrderJobService.deleteAllWorkOrderJob(); boolean continueFlag = true; Integer currentPage = 1; ApsWorkOrderJobParam param=new ApsWorkOrderJobParam(); param.setPageIndex(currentPage); param.setDocState(Arrays.asList(0,1,2,4)); - param.setPageSize(1000); + param.setPageSize(500); while (continueFlag){ param.setPageIndex(currentPage); continueFlag= iApsWorkOrderJobService.batchSaveByPager(param); @@ -120,7 +137,66 @@ */ public void insertIntoApsProcessRoute() { - iApsWorkOrderProcessService.deleteApsProcessRoute(); - iApsWorkOrderProcessService.insertIntoApsProcessRoute(); + iApsWorkOrderProcessService.syncProcessRouteData(); } + + /** + * 鍚屾闆朵欢銆侀挘閲戙�佹皵鏌滅璺殑宸ュ崟鏁版嵁鍒颁笟鍔¤〃涓�佸悓姝ュ伐搴忔暟鎹埌宸ヨ壓璺嚎琛ㄤ腑 + */ + public void syncAllTypeOrder() + { + iApsWorkOrderJobService.syncPartOrderData(); + iApsWorkOrderJobService.syncPlateOrderData(); + iApsWorkOrderJobService.syncGasPipingData(); + iApsWorkOrderProcessService.syncProcessRouteData(); + } + + /** + * 鍚屾鍏ㄩ噺BOM鏁版嵁瀹氭椂浠诲姟 + */ + public void syncBomDataJob(Integer pageIndex, Integer pageSize, String orgCode, String itemCodeList) + { + boolean res = iApsBomHeaderJobService.syncBomDataJob(pageIndex, pageSize, orgCode, itemCodeList); + if(res){ + remoteCoreService.setBomDataToRedis(SecurityConstants.INNER); + } + } + + /** + * 鍚屾鍏ㄩ噺搴撳瓨鏁版嵁瀹氭椂浠诲姟 + */ + public void syncApsMaterialStorageDataJob(Integer pageIndex, Integer pageSize, String orgCode, String itemCodeList) + { + boolean res = apsMaterialStorageManagementJobService.syncApsMaterialStorageDataJob(pageIndex, pageSize, orgCode, itemCodeList); + if(res){ + remoteCoreService.setStorageDataToRedis(SecurityConstants.INNER); + } + } + + /** + * 鍚屾鍏ㄩ噺宸ヨ壓璺嚎鏁版嵁瀹氭椂浠诲姟 + */ + public void syncProcessRouteJob(Integer pageIndex, Integer pageSize, String orgCode, String itemCodeList) + { + boolean res = apsStandardProcessRouteHeaderJobService.syncProcessRouteDataJob(pageIndex, pageSize, orgCode, itemCodeList); + 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