From 14f982bf34e45b0ad5218212346cf2b33f0a6915 Mon Sep 17 00:00:00 2001 From: huangjiayang <5265313@qq.com> Date: 星期六, 10 五月 2025 18:06:16 +0800 Subject: [PATCH] 【ADD】1.新增同步物料定时任务 2.同步任务增加批次号 --- aps-modules/aps-job/src/main/java/com/aps/job/controller/SysJobController.java | 26 ++++++++++++++++++++++++-- 1 files changed, 24 insertions(+), 2 deletions(-) diff --git a/aps-modules/aps-job/src/main/java/com/aps/job/controller/SysJobController.java b/aps-modules/aps-job/src/main/java/com/aps/job/controller/SysJobController.java index 46c1747..e443ee2 100644 --- a/aps-modules/aps-job/src/main/java/com/aps/job/controller/SysJobController.java +++ b/aps-modules/aps-job/src/main/java/com/aps/job/controller/SysJobController.java @@ -1,7 +1,6 @@ package com.aps.job.controller; import com.aps.common.core.constant.Constants; -import com.aps.common.core.constant.SecurityConstants; import com.aps.common.core.exception.job.TaskException; import com.aps.common.core.utils.StringUtils; import com.aps.common.core.utils.poi.ExcelUtil; @@ -20,6 +19,7 @@ import jakarta.servlet.http.HttpServletResponse; import org.quartz.SchedulerException; import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.data.redis.core.RedisTemplate; import org.springframework.web.bind.annotation.*; import java.math.BigDecimal; @@ -59,7 +59,17 @@ private IApsMaterialStorageManagementJobService apsMaterialStorageManagementJobService; @Autowired + private IApsStandardProcessRouteHeaderJobService apsStandardProcessRouteHeaderJobService; + + @Autowired private RemoteCoreService remoteCoreService; + + @Autowired + public RedisTemplate redisTemplate; + + @Autowired + private IApsMaterialManagementJobService apsMaterialManagementJobService; + /** * 鏌ヨ瀹氭椂浠诲姟鍒楄〃 */ @@ -210,12 +220,24 @@ return apsBomHeaderJobService.syncBomDataJob(1, 1000, "", ""); } + @PostMapping("/refreshProcessRouteData") + public Boolean refreshProcessRouteData() throws SchedulerException, TaskException + { + return apsStandardProcessRouteHeaderJobService.syncProcessRouteDataJob(1, 1000, "", ""); + } + @PutMapping("/test") public void test(@RequestBody SysJob job) throws Exception { System.out.println("start"); + //鍚屾鐗╂枡鏁版嵁 + apsMaterialManagementJobService.syncApsMaterialData(1, 1000, "FORTUNA", ""); + //鍚屾宸ヨ壓璺嚎鏁版嵁 +// apsStandardProcessRouteHeaderJobService.syncProcessRouteData(1, 1000, "", ""); + //鑾峰彇Redis缂撳瓨涓殑BOM鏁版嵁 +// JSONArray jsonArray = (JSONArray)redisTemplate.opsForValue().get("BOM:BOM_FORTUNA_A6501-001080"); //灏咮OM鏁版嵁瀛樿繘Redis涓� - remoteCoreService.setBomDataToRedis(SecurityConstants.INNER); +// remoteCoreService.setBomDataToRedis(SecurityConstants.INNER); //鍚屾鐗╂枡搴撳瓨鏁版嵁 // apsMaterialStorageManagementJobService.syncApsMaterialStorageData(1, 1000, "", ""); //鍚屾BOM鏁版嵁 -- Gitblit v1.9.3