From 2a64b537e8e3bce9ce030585a3da17d48379c0ad Mon Sep 17 00:00:00 2001
From: sfd <sun.sunshine@163.com>
Date: 星期一, 26 五月 2025 15:04:45 +0800
Subject: [PATCH] 修改json类型转换错误

---
 aps-modules/aps-core/src/main/java/com/aps/core/controller/basicData/ApsGasPipelineCapacityPlanController.java |   44 ++++++++++++++++++++++++++++++++------------
 1 files changed, 32 insertions(+), 12 deletions(-)

diff --git a/aps-modules/aps-core/src/main/java/com/aps/core/controller/basicData/ApsGasPipelineCapacityPlanController.java b/aps-modules/aps-core/src/main/java/com/aps/core/controller/basicData/ApsGasPipelineCapacityPlanController.java
index ac1167d..9547d84 100644
--- a/aps-modules/aps-core/src/main/java/com/aps/core/controller/basicData/ApsGasPipelineCapacityPlanController.java
+++ b/aps-modules/aps-core/src/main/java/com/aps/core/controller/basicData/ApsGasPipelineCapacityPlanController.java
@@ -10,8 +10,10 @@
 import com.aps.common.security.annotation.RequiresPermissions;
 import com.aps.common.security.utils.SecurityUtils;
 import com.aps.core.domain.ApsGasPipelineCapacityPlan;
+import com.aps.core.domain.ApsShop;
 import com.aps.core.domain.ApsStandardProcess;
 import com.aps.core.service.IApsGasPipelineCapacityPlanService;
+import com.aps.core.service.IApsShopService;
 import com.aps.core.service.IApsStandardProcessService;
 import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.tags.Tag;
@@ -20,6 +22,7 @@
 import org.springframework.web.bind.annotation.*;
 
 import java.util.ArrayList;
+import java.util.Comparator;
 import java.util.List;
 import java.util.Objects;
 
@@ -40,11 +43,14 @@
     @Autowired
     private IApsStandardProcessService apsStandardProcessService;
 
+    @Autowired
+    private IApsShopService apsShopService;
+
     /**
      * 鏌ヨ姘斾綋绠¤矾浜ц兘瑙勫垝鍒楄〃
      */
     @Operation(summary = "鏌ヨ姘斾綋绠¤矾浜ц兘瑙勫垝鍒楄〃", description = "鍒嗛〉鏌ヨ")
-//    @RequiresPermissions("aps:gasPipelineCapacityPlan:list")
+    @RequiresPermissions("aps:gasPipelineCapacityPlan:list")
     @GetMapping("/list")
     public TableDataInfo list(ApsGasPipelineCapacityPlan apsGasPipelineCapacityPlan) {
 //        startPage();
@@ -53,20 +59,30 @@
         apsStandardProcess.setMajor(apsGasPipelineCapacityPlan.getMajor());
         apsStandardProcess.setPlant(apsGasPipelineCapacityPlan.getOrgCode());
         List<ApsStandardProcess> processList = apsStandardProcessService.selectApsStandardProcessListAll(apsStandardProcess);
+        List<ApsShop> apsShops = apsShopService.findShopByFactory(apsGasPipelineCapacityPlan.getOrgCode());
         if (list.isEmpty()) {
             for (ApsStandardProcess apsStandardProcessTemp : processList) {
                 ApsGasPipelineCapacityPlan apsGasPipelineCapacityPlanTemp = new ApsGasPipelineCapacityPlan();
                 apsGasPipelineCapacityPlanTemp.setProcessName(apsStandardProcessTemp.getProcessName());
                 apsGasPipelineCapacityPlanTemp.setOrgCode(apsStandardProcessTemp.getPlant());
-                apsGasPipelineCapacityPlanTemp.setWorkshop(apsStandardProcessTemp.getWorkShop());
+                apsGasPipelineCapacityPlanTemp.setWorkshop(apsShops.stream()
+                        .filter(shop -> Objects.equals(shop.getShopCode(), apsStandardProcessTemp.getWorkShop()))
+                        .map(ApsShop::getShopName)
+                        .findFirst()
+                        .orElse(null));
                 list.add(apsGasPipelineCapacityPlanTemp);
             }
         } else {
-            list.forEach(item -> {
-                processList.stream().filter(p -> Objects.equals(p.getPlant(), item.getOrgCode()))
-                        .filter(p -> Objects.equals(p.getProcessName(), item.getProcessName()))
+            list.forEach(capacityPlan -> {
+                processList.stream().filter(p -> Objects.equals(p.getPlant(), capacityPlan.getOrgCode()))
+                        .filter(p -> Objects.equals(p.getMajor(), capacityPlan.getMajor()))
+                        .filter(p -> p.getWorkShop() != null)
                         .findFirst().ifPresent(p -> {
-                            item.setWorkshop(p.getWorkShop());
+                            capacityPlan.setWorkshop(apsShops.stream()
+                                    .filter(shop -> Objects.equals(shop.getShopCode(), p.getWorkShop()))
+                                    .map(ApsShop::getShopName)
+                                    .findFirst()
+                                    .orElse(null));
                         });
             });
         }
@@ -84,15 +100,19 @@
                     newProcess.add(apsStandardProcessTemp);
                 }
             }
-            for (ApsStandardProcess processName : newProcess) {
+            for (ApsStandardProcess process : newProcess) {
                 ApsGasPipelineCapacityPlan apsGasPipelineCapacityPlanTemp = new ApsGasPipelineCapacityPlan();
-                apsGasPipelineCapacityPlanTemp.setProcessName(processName.getProcessName());
-                apsGasPipelineCapacityPlanTemp.setOrgCode(processName.getPlant());
-                apsGasPipelineCapacityPlanTemp.setWorkshop(processName.getWorkShop());
+                apsGasPipelineCapacityPlanTemp.setProcessName(process.getProcessName());
+                apsGasPipelineCapacityPlanTemp.setOrgCode(process.getPlant());
+                apsGasPipelineCapacityPlanTemp.setWorkshop(apsShops.stream()
+                        .filter(shop -> Objects.equals(shop.getShopCode(), process.getWorkShop()))
+                        .map(ApsShop::getShopName)
+                        .findFirst()
+                        .orElse(null));
                 list.add(apsGasPipelineCapacityPlanTemp);
             }
         }
-        list.sort((a, b) -> a.getProcessName().compareTo(b.getProcessName()));
+        list.sort(Comparator.comparing(ApsGasPipelineCapacityPlan::getProcessName));
         return getDataTable(list);
     }
 
@@ -114,7 +134,7 @@
      * 澶嶅埗姘斾綋绠¤矾浜ц兘瑙勫垝
      */
     @Operation(summary = "澶嶅埗姘斾綋绠¤矾浜ц兘瑙勫垝", description = "澶嶅埗")
-//    @RequiresPermissions("aps:gasPipelineCapacityPlan:copy")
+    @RequiresPermissions("aps:gasPipelineCapacityPlan:copy")
     @Log(title = "澶嶅埗姘斾綋绠¤矾浜ц兘瑙勫垝", businessType = BusinessType.INSERT)
     @PutMapping("/copy")
     public AjaxResult copy(

--
Gitblit v1.9.3