From dc3dd99bd0eb9e9297e66b958ed4b7b31dd21d1d Mon Sep 17 00:00:00 2001
From: zhanghl <253316343@qq.com>
Date: 星期三, 16 四月 2025 19:03:34 +0800
Subject: [PATCH] 钣金统计表

---
 aps-modules/aps-core/src/main/java/com/aps/core/service/impl/ApsWeldSeamServiceImpl.java |   94 +++++++++++++++++++++++++++++++++++++++++-----
 1 files changed, 83 insertions(+), 11 deletions(-)

diff --git a/aps-modules/aps-core/src/main/java/com/aps/core/service/impl/ApsWeldSeamServiceImpl.java b/aps-modules/aps-core/src/main/java/com/aps/core/service/impl/ApsWeldSeamServiceImpl.java
index 583080b..397dcd5 100644
--- a/aps-modules/aps-core/src/main/java/com/aps/core/service/impl/ApsWeldSeamServiceImpl.java
+++ b/aps-modules/aps-core/src/main/java/com/aps/core/service/impl/ApsWeldSeamServiceImpl.java
@@ -17,7 +17,8 @@
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
-import java.util.List;
+import java.util.*;
+import java.util.stream.Collectors;
 
 /**
  * 鐒婄紳Service涓氬姟灞傚鐞�
@@ -109,22 +110,23 @@
         List<ApsWeldSeamTemp> apsWeldSeamTemps = apsWeldSeamTempMapper.selectApsWeldSeamTempList(apsWeldSeamTemp);
         int count = 0;
         String[] ids = new String[apsWeldSeamTemps.size()];
+        apsWeldSeamMapper.removeLastBatch();
         for (int i = 0; i < apsWeldSeamTemps.size(); i++) {
             //璁板綍涓存椂琛╥d
             ids[i] = apsWeldSeamTemps.get(i).getId();
             ApsWeldSeam apsWeldSeam = new ApsWeldSeam();
             BeanUtils.copyProperties(apsWeldSeamTemps.get(i), apsWeldSeam);
             //閫氳繃宸ュ崟鍙锋煡璇㈡槸鍚﹀瓨鍦ㄦ暟鎹�
-            ApsWeldSeam apsWeldSeam1 = apsWeldSeamMapper.selectApsWeldSeamByWorkOrderNo(apsWeldSeam.getWorkOrderNo());
+            /*ApsWeldSeam apsWeldSeam1 = apsWeldSeamMapper.selectApsWeldSeamByWorkOrderNo(apsWeldSeam.getWorkOrderNo());
             //褰撳伐鍗曞彿瀛樺湪鍒欐洿鏂版暟鎹惁鍒欐彃鍏ユ暟鎹�
             if (apsWeldSeam1!=null&&apsWeldSeam1.getId()!=null) {
                 apsWeldSeam.setId(apsWeldSeam1.getId());
                 apsWeldSeamMapper.updateApsWeldSeam(apsWeldSeam);
-            } else {
+            } else {*/
                 //鎻掑叆姝e紡琛紝骞惰褰�
-                apsWeldSeam.setId(IdUtils.fastUUID());
-                apsWeldSeamMapper.insertApsWeldSeam(apsWeldSeam);
-            }
+            apsWeldSeam.setId(IdUtils.fastUUID());
+            apsWeldSeamMapper.insertApsWeldSeam(apsWeldSeam);
+            //}
             count++;
         }
         //鎻掑叆鏁伴噺涓庝复鏃惰〃鏌ヨ涓�鐩村垯鍒犻櫎涓存椂琛ㄦ暟鎹�
@@ -139,20 +141,27 @@
         List<Long> years = apsWeldSeamStatistics.stream().map(ApsWeldSeamStatistics::getYear).distinct().toList();
         List<Long> months = apsWeldSeamStatistics.stream().map(ApsWeldSeamStatistics::getMonth).distinct().toList();
         List<String> bases = apsWeldSeamStatistics.stream().map(ApsWeldSeamStatistics::getProductionBase).distinct().toList();
-
+        /*宸ュ崟绫诲瀷锛氳鍗�*/
+        String WorkOrderType_Order="0";
+        /*宸ュ崟绫诲瀷锛氶娴�*/
+        String WorkOrderType_Prediction="1";
+        /*绫诲瀷锛氭皵浣�*/
+        String Classification_Gas="0";
+        /*绫诲瀷锛氱璺�*/
+        String Classification_Piping="1";
         for (Long year : years) {
             for (Long month : months) {
                 for (String basis : bases) {
                     List<ApsWeldSeamStatistics> list = apsWeldSeamStatistics.stream()
                             .filter(x -> x.getYear().equals(year) && x.getMonth().equals(month) && x.getProductionBase().equals(basis)).toList();
 
-                    long gasOrderRequirement = list.stream().filter(x -> x.getWorkOrderType().equals("0") && x.getClassification().equals("0"))
+                    long gasOrderRequirement = list.stream().filter(x -> x.getWorkOrderType().equals(WorkOrderType_Order) && x.getClassification().equals(Classification_Gas))
                             .mapToLong(ApsWeldSeamStatistics::getTotal).sum();
-                    long gasPredictionRequirement = list.stream().filter(x -> x.getWorkOrderType().equals("1") && x.getClassification().equals("0"))
+                    long gasPredictionRequirement = list.stream().filter(x -> x.getWorkOrderType().equals(WorkOrderType_Prediction) && x.getClassification().equals(Classification_Gas))
                             .mapToLong(ApsWeldSeamStatistics::getTotal).sum();
-                    long pipingOrderRequirement = list.stream().filter(x -> x.getWorkOrderType().equals("0") && x.getClassification().equals("1"))
+                    long pipingOrderRequirement = list.stream().filter(x -> x.getWorkOrderType().equals(WorkOrderType_Order) && x.getClassification().equals(Classification_Piping))
                             .mapToLong(ApsWeldSeamStatistics::getTotal).sum();
-                    long pipingPredictionRequirement = list.stream().filter(x -> x.getWorkOrderType().equals("1") && x.getClassification().equals("1"))
+                    long pipingPredictionRequirement = list.stream().filter(x -> x.getWorkOrderType().equals(WorkOrderType_Prediction) && x.getClassification().equals(Classification_Piping))
                             .mapToLong(ApsWeldSeamStatistics::getTotal).sum();
                     long total = gasOrderRequirement + gasPredictionRequirement + pipingOrderRequirement + pipingPredictionRequirement;
                     if(total>0) {
@@ -217,4 +226,67 @@
         }*/
         return 1;
     }
+
+    @Override
+    public List<List<String>> weldSeamEchartsList(ApsWeldSeam apsWeldSeam) {
+
+        Map<String, Object> params = apsWeldSeam.getParams();
+        if(ObjectUtils.isNotEmpty(params)){
+            String startDay = params.get("startDay").toString();
+            String endDay = params.get("endDay").toString();
+            List<Long> produceYears = new ArrayList<>();
+            List<Long> produceMonths = new ArrayList<>();
+            String startQueryYear = startDay.substring(0,4);
+            String endQueryYear = endDay.substring(0,4);
+            String startQueryDay = startDay.substring(6,7);
+            String endQueryDay = endDay.substring(6,7);
+            produceYears.add(Long.valueOf(startQueryYear));
+            produceYears.add(Long.valueOf(endQueryYear));
+            produceMonths.add(Long.valueOf(startQueryDay));
+            produceMonths.add(Long.valueOf(endQueryDay));
+            apsWeldSeam.setProduceYears(produceYears);
+            apsWeldSeam.setProduceMonths(produceMonths);
+        }
+        List<Map> mapList =apsWeldSeamMapper.weldSeamEcharts(apsWeldSeam);
+        Set monthSet=mapList.stream().map(e->e.get("produce_month").toString()).collect(Collectors.toSet());
+        List monthList = new ArrayList(monthSet);
+        Collections.sort(monthList);
+
+        List<List<String>> echartsList = new ArrayList<>();
+
+        Set<String> titleSet = new HashSet<>();
+        List<String> title = new ArrayList<>(titleSet);
+        title.add("product");
+        mapList.forEach(item->{
+            StringBuilder sb = new StringBuilder();
+            sb.append(item.get("production_base"));
+            sb.append("-");
+            sb.append(item.get("work_order_name"));
+            sb.append("-");
+            sb.append(item.get("classification_name"));
+            title.add(sb.toString());
+
+        });
+        echartsList.add(title);
+        monthList.forEach(month->{
+            List<String> table = new ArrayList<>();
+            table.add(month+"鏈�");
+            for (int i=1;i<title.size();i++){
+                for(int j=0;j<mapList.size();j++){
+                    Map value =mapList.get(j);
+                    StringBuilder sb = new StringBuilder();
+                    sb.append(value.get("production_base"));
+                    sb.append("-");
+                    sb.append(value.get("work_order_name"));
+                    sb.append("-");
+                    sb.append(value.get("classification_name"));
+                    if(sb.toString().equals(title.get(i)) && month.equals(value.get("produce_month").toString())){
+                        table.add(value.get("total_weld_seam").toString());
+                    }
+                }
+            }
+            echartsList.add(table);
+        });
+        return echartsList;
+    }
 }

--
Gitblit v1.9.3