From 6fcb995547973223f4401745e5c2fbc77230089f Mon Sep 17 00:00:00 2001
From: Lius <Lius2225@163.com>
Date: 星期四, 10 七月 2025 10:42:33 +0800
Subject: [PATCH] 生产设备自主维护点检表导出

---
 lxzn-module-eam/src/main/java/org/jeecg/modules/eam/service/impl/EamInspectionOrderServiceImpl.java |  291 ++++++++++++++++++++++++++++++++++++++++++++++++++++++----
 1 files changed, 271 insertions(+), 20 deletions(-)

diff --git a/lxzn-module-eam/src/main/java/org/jeecg/modules/eam/service/impl/EamInspectionOrderServiceImpl.java b/lxzn-module-eam/src/main/java/org/jeecg/modules/eam/service/impl/EamInspectionOrderServiceImpl.java
index fa8dc1f..1bf8ee0 100644
--- a/lxzn-module-eam/src/main/java/org/jeecg/modules/eam/service/impl/EamInspectionOrderServiceImpl.java
+++ b/lxzn-module-eam/src/main/java/org/jeecg/modules/eam/service/impl/EamInspectionOrderServiceImpl.java
@@ -3,6 +3,7 @@
 import cn.hutool.core.collection.CollectionUtil;
 import cn.hutool.core.util.StrUtil;
 import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
@@ -20,18 +21,14 @@
 import org.jeecg.common.system.vo.LoginUser;
 import org.jeecg.common.util.oConvertUtils;
 import org.jeecg.modules.eam.aspect.annotation.EquipmentHistoryLog;
+import org.jeecg.modules.eam.constant.*;
+import org.jeecg.modules.eam.request.*;
 import org.jeecg.modules.system.entity.BaseFactory;
 import org.jeecg.modules.system.entity.BaseFactoryUser;
 import org.jeecg.modules.system.service.IBaseFactoryService;
 import org.jeecg.modules.system.service.IBaseFactoryUserService;
-import org.jeecg.modules.eam.constant.BusinessCodeConst;
-import org.jeecg.modules.eam.constant.EquipmentOperationTagEnum;
-import org.jeecg.modules.eam.constant.InspectionItemCategroyEnum;
-import org.jeecg.modules.eam.constant.InspectionStatus;
 import org.jeecg.modules.eam.entity.*;
 import org.jeecg.modules.eam.mapper.EamInspectionOrderMapper;
-import org.jeecg.modules.eam.request.EamInspectionOrderQuery;
-import org.jeecg.modules.eam.request.EamInspectionOrderRequest;
 import org.jeecg.modules.eam.service.*;
 import org.jeecg.modules.eam.util.DateUtils;
 import org.jeecg.modules.eam.vo.InspectionVo;
@@ -41,13 +38,20 @@
 import org.jeecg.modules.flowable.apithird.service.FlowCommonService;
 import org.jeecg.modules.flowable.service.IFlowDefinitionService;
 import org.jeecg.modules.flowable.service.IFlowTaskService;
+import org.jeecg.modules.system.service.ISysDictService;
 import org.springframework.beans.BeanUtils;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
 import javax.annotation.Resource;
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import java.time.ZoneId;
 import java.util.*;
+import java.util.concurrent.atomic.AtomicInteger;
 import java.util.stream.Collectors;
+import java.util.stream.IntStream;
 
 /**
  * @Description: 鐐规宸ュ崟
@@ -84,6 +88,8 @@
     private IEamReportRepairService eamReportRepairService;
     @Resource
     private IEamMaintenanceStandardDetailService eamMaintenanceStandardDetailService;
+    @Resource
+    private ISysDictService sysDictService;
 
     @Override
     public IPage<EamInspectionOrder> queryPageList(Page<EamInspectionOrder> page, EamInspectionOrderQuery query) {
@@ -156,6 +162,264 @@
         return eamInspectionOrderMapper.selectList(queryWrapper);
     }
 
+    /**
+     * 瀵煎嚭鑾峰彇鍩烘湰淇℃伅
+     * @param equipmentCode 璁惧缂栫爜
+     * @param inspectionDate 鐐规鏃ユ湡
+     * @return
+     */
+    @Override
+    public JSONObject exportInspectionOrderBaseInfo(String equipmentCode, String inspectionDate) {
+        // 鍒涘缓缁撴灉瀵硅薄
+        JSONObject result = new JSONObject();
+        EamInspectionOrderBaseResponse eamInspectionOrderBaseResponse = eamInspectionOrderMapper.findInsOrderBaseInfo(equipmentCode, inspectionDate);
+        // 澶勭悊鍗曚綅
+        String factoryOrgCode = eamInspectionOrderBaseResponse.getFactoryName();
+        BaseFactory baseFactory = baseFactoryService.getOne(new LambdaQueryWrapper<BaseFactory>().eq(BaseFactory::getOrgCode, factoryOrgCode.substring(0, 6)));
+        eamInspectionOrderBaseResponse.setFactoryName(baseFactory.getFactoryName());
+        result.put("data",Collections.singletonList(eamInspectionOrderBaseResponse));
+        return result;
+    }
+
+    /**
+     * 鏃ョ偣妫�椤瑰垪琛�
+     * @param equipmentCode 璁惧缂栫爜
+     * @param inspectionDate 鐐规鏃ユ湡
+     * @return
+     */
+    @Override
+    public JSONObject exportInspectionOrderDetailList(String equipmentCode, String inspectionDate) {
+        // 鍒涘缓缁撴灉瀵硅薄
+        JSONObject result = new JSONObject();
+        List<EamInsOrderDetailResultResponse> eamInsOrderDetailResultResponseList = eamInspectionOrderMapper.findInsOrderDetailList(equipmentCode, inspectionDate);
+        if (eamInsOrderDetailResultResponseList == null || eamInsOrderDetailResultResponseList.isEmpty()) {
+            return result;
+        }
+        Map<EamInsOrderDetailResultResponse, List<EamInsOrderDetailResultResponse>> groupMap = eamInsOrderDetailResultResponseList
+                .stream().collect(Collectors.groupingBy(
+                        // 鍒嗙粍閿細鍖呭惈 itemCode銆乮temName銆乮temDemand 鐨勫璞�
+                        item -> new EamInsOrderDetailResultResponse(
+                                item.getItemCode(),
+                                item.getItemName(),
+                                item.getItemDemand()
+                        ),
+                        // 鐢� TreeMap 浣滀负瀹瑰櫒锛屽苟鎸囧畾鎸� itemCode 鎺掑簭鐨勬瘮杈冨櫒
+                        () -> new TreeMap<>(Comparator.comparingInt(EamInsOrderDetailResultResponse::getItemCode)),
+                        // 鏀堕泦姣忕粍鐨勫厓绱犱负 List
+                        Collectors.toList()
+                ));
+        List<Map<String, Object>> resultList = new ArrayList<>();
+        groupMap.forEach((insOrderDetailResultResponse, insOrderDetailResultResponseList) -> {
+            Map<String, Object> resultMap = new LinkedHashMap<>();
+            resultMap.put("itemCode", insOrderDetailResultResponse.getItemCode());
+            resultMap.put("itemName", insOrderDetailResultResponse.getItemName());
+            resultMap.put("itemDemand", insOrderDetailResultResponse.getItemDemand());
+            Map<Integer, EamInsOrderDetailResultResponse> collect = insOrderDetailResultResponseList
+                    .stream().collect(Collectors.toMap(
+                            // 鍒嗙粍閿細鎻愬彇鏃ユ湡涓殑鈥滃ぉ鈥�
+                            item -> {
+                                Date date = item.getInspectionDate();
+                                LocalDate localDate = date.toInstant()
+                                        .atZone(ZoneId.systemDefault())
+                                        .toLocalDate();
+                                return localDate.getDayOfMonth(); // 閿负鈥滃ぉ鈥濓紙1-31锛�
+                            },
+                            // 鍊硷細鐩存帴浣跨敤褰撳墠瀵硅薄锛堜綔涓哄垵濮嬪�硷級
+                            item -> item,
+                            // 鍚堝苟鍑芥暟锛氬綋鍚屼竴鈥滃ぉ鈥濇湁澶氫釜瀵硅薄鏃讹紝濡備綍澶勭悊锛堣繖閲岀ず渚嬪彇绗竴涓級
+                            (existing, replacement) -> existing // 鑻ユ湁閲嶅閿紝淇濈暀宸插瓨鍦ㄧ殑瀵硅薄
+                    ));
+            for (int i = 1; i <= 31; i++) {
+                if (collect.containsKey(i)) {
+                    String inspectionResult = "";
+                    switch (collect.get(i).getInspectionResult()) {
+                        case "NORMAL":
+                            inspectionResult = "鈭�";
+                            break;
+                        case "ANOMALY":
+                            inspectionResult = "脳";
+                            break;
+                        case "FAULT":
+                            inspectionResult = "鈻�";
+                            break;
+                        case "CLOSE":
+                            inspectionResult = "T";
+                            break;
+                    }
+                    resultMap.put("inspectionResult" + i, inspectionResult);
+                } else {
+                    resultMap.put("inspectionResult" + i, "");
+                }
+            }
+            resultList.add(resultMap);
+        });
+        result.put("data", resultList);
+        return result;
+    }
+
+    /**
+     * 鏃ョ偣妫�璐d换浜哄垪琛�
+     * @param equipmentCode 璁惧缂栫爜
+     * @param inspectionDate 鐐规鏃ユ湡
+     * @return
+     */
+    @Override
+    public JSONObject exportInspectionOrderDetailUserList(String equipmentCode, String inspectionDate) {
+        // 鍒涘缓缁撴灉瀵硅薄
+        JSONObject result = new JSONObject();
+        List<EamInsOrderDetailUserResponse> eamInsOrderDetailUserResponseList = eamInspectionOrderMapper.findInspectionOrderDetailUserList(equipmentCode, inspectionDate);
+        if (eamInsOrderDetailUserResponseList == null || eamInsOrderDetailUserResponseList.isEmpty()) {
+            return result;
+        }
+        Map<Integer, EamInsOrderDetailUserResponse> groupMap = eamInsOrderDetailUserResponseList.stream().collect(Collectors.toMap(
+                // 鍒嗙粍閿細鎻愬彇鏃ユ湡涓殑鈥滃ぉ鈥�
+                item -> {
+                    Date date = item.getInspectionDate();
+                    LocalDate localDate = date.toInstant()
+                            .atZone(ZoneId.systemDefault())
+                            .toLocalDate();
+                    return localDate.getDayOfMonth(); // 閿负鈥滃ぉ鈥濓紙1-31锛�
+                },
+                // 鍊硷細鐩存帴浣跨敤褰撳墠瀵硅薄锛堜綔涓哄垵濮嬪�硷級
+                item -> item,
+                // 鍚堝苟鍑芥暟锛氬綋鍚屼竴鈥滃ぉ鈥濇湁澶氫釜瀵硅薄鏃讹紝濡備綍澶勭悊锛堣繖閲岀ず渚嬪彇绗竴涓級
+                (existing, replacement) -> existing // 鑻ユ湁閲嶅閿紝淇濈暀宸插瓨鍦ㄧ殑瀵硅薄
+        ));
+        List<Map<String, Object>> resultList = new ArrayList<>();
+        for (int i = 1; i <= 31; i++) {
+            Map<String, Object> resultMap = new HashMap<>();
+            if (groupMap.containsKey(i)) {
+                EamInsOrderDetailUserResponse eamInsOrderDetailUserResponse = groupMap.get(i);
+                resultMap.put("operator" + i, sysDictService.queryTableDictTextByKey("sys_user", "realname", "username", eamInsOrderDetailUserResponse.getOperator()));
+                resultMap.put("confirmUser" + i, sysDictService.queryTableDictTextByKey("sys_user", "realname", "username", eamInsOrderDetailUserResponse.getConfirmUser()));
+            } else {
+                resultMap.put("operator" + i, "");
+                resultMap.put("confirmUser" + i, "");
+            }
+            resultList.add(resultMap);
+        }
+        result.put("data", resultList);
+        return result;
+    }
+
+    /**
+     * 鍛ㄧ偣妫�椤瑰垪琛�
+     * @param equipmentCode 璁惧缂栫爜
+     * @param inspectionDate 鐐规鏃ユ湡
+     * @return
+     */
+    @Override
+    public JSONObject exportWeekInsDetailList(String equipmentCode, String inspectionDate) {
+        // 鍒涘缓缁撴灉瀵硅薄
+        JSONObject result = new JSONObject();
+        List<EamWeekInsDetailResultResponse> eamWeekInsDetailResultResponseList = eamInspectionOrderMapper.findWeekInsDetailList(equipmentCode, inspectionDate);
+        if (eamWeekInsDetailResultResponseList == null || eamWeekInsDetailResultResponseList.isEmpty()) {
+            return result;
+        }
+        Map<EamWeekInsDetailResultResponse, List<EamWeekInsDetailResultResponse>> groupMap = eamWeekInsDetailResultResponseList
+                .stream().collect(Collectors.groupingBy(
+                        // 鍒嗙粍閿細鍖呭惈 itemCode銆乮temName銆乮temDemand 鐨勫璞�
+                        item -> new EamWeekInsDetailResultResponse(
+                                item.getItemCode(),
+                                item.getItemName(),
+                                item.getItemDemand()
+                        ),
+                        // 鐢� TreeMap 浣滀负瀹瑰櫒锛屽苟鎸囧畾鎸� itemCode 鎺掑簭鐨勬瘮杈冨櫒
+                        () -> new TreeMap<>(Comparator.comparingInt(EamWeekInsDetailResultResponse::getItemCode)),
+                        // 鏀堕泦姣忕粍鐨勫厓绱犱负 List
+                        Collectors.toList()
+                ));
+        List<Map<String, Object>> resultList = new ArrayList<>();
+        groupMap.forEach((weekInsDetailResultResponse, weekInsDetailResultResponseList) -> {
+            Map<String, Object> resultMap = new LinkedHashMap<>();
+            resultMap.put("itemCode", weekInsDetailResultResponse.getItemCode());
+            resultMap.put("itemName", weekInsDetailResultResponse.getItemName());
+            resultMap.put("itemDemand", weekInsDetailResultResponse.getItemDemand());
+            // 浣跨敤AtomicInteger浣滀负璁℃暟鍣紝浠�1寮�濮�
+            AtomicInteger counter = new AtomicInteger(1);
+            Map<Integer, EamWeekInsDetailResultResponse> collect = weekInsDetailResultResponseList
+                    .stream()
+                    .collect(Collectors.toMap(
+                            // 鍒嗙粍閿細浣跨敤鑷搴忓彿锛堜粠1寮�濮嬶級
+                            item -> counter.getAndIncrement(),
+                            // 鍊硷細鐩存帴浣跨敤褰撳墠瀵硅薄
+                            item -> item,
+                            // 鍚堝苟鍑芥暟锛氬綋鍚屼竴搴忓彿鏈夊涓璞℃椂锛堢悊璁轰笂涓嶄細鍙戠敓锛夛紝濡備綍澶勭悊
+                            (existing, replacement) -> existing, // 鑻ユ湁閲嶅閿紝淇濈暀宸插瓨鍦ㄧ殑瀵硅薄
+                            // 鎸囧畾Map鐨勫叿浣撳疄鐜帮紙鍙�夛級
+                            LinkedHashMap::new // 淇濇寔鎻掑叆椤哄簭
+                    ));
+            for (int i = 1; i <= 5; i++) {
+                if (collect.containsKey(i)) {
+                    String inspectionResult = "";
+                    switch (collect.get(i).getInspectionResult()) {
+                        case "NORMAL":
+                            inspectionResult = "鈭�";
+                            break;
+                        case "ANOMALY":
+                            inspectionResult = "脳";
+                            break;
+                        case "FAULT":
+                            inspectionResult = "鈻�";
+                            break;
+                        case "CLOSE":
+                            inspectionResult = "T";
+                            break;
+                    }
+                    resultMap.put("inspectionResult" + i, inspectionResult);
+                } else {
+                    resultMap.put("inspectionResult" + i, "");
+                }
+            }
+            resultList.add(resultMap);
+        });
+        result.put("data", resultList);
+        return result;
+    }
+
+    /**
+     * 鍛ㄧ偣妫�璐d换浜哄垪琛�
+     * @param equipmentCode 璁惧缂栫爜
+     * @param inspectionDate 鐐规鏃ユ湡
+     * @return
+     */
+    @Override
+    public JSONObject exportWeekInsOrderDetailUserList(String equipmentCode, String inspectionDate) {
+        // 鍒涘缓缁撴灉瀵硅薄
+        JSONObject result = new JSONObject();
+        List<EamWeekInsDetailUserResponse> eamWeekInsDetailUserResponseList = eamInspectionOrderMapper.findWeekInsOrderDetailUserList(equipmentCode, inspectionDate);
+        if (eamWeekInsDetailUserResponseList == null || eamWeekInsDetailUserResponseList.isEmpty()) {
+            return result;
+        }
+        // 浣跨敤AtomicInteger浣滀负璁℃暟鍣紝浠�1寮�濮�
+        AtomicInteger counter = new AtomicInteger(1);
+        Map<Integer, EamWeekInsDetailUserResponse> groupMap = eamWeekInsDetailUserResponseList
+                .stream()
+                .collect(Collectors.toMap(
+                        // 鍒嗙粍閿細浣跨敤鑷搴忓彿锛堜粠1寮�濮嬶級
+                        item -> counter.getAndIncrement(),
+                        // 鍊硷細鐩存帴浣跨敤褰撳墠瀵硅薄锛堜綔涓哄垵濮嬪�硷級
+                        item -> item,
+                        // 鍚堝苟鍑芥暟锛氬綋鍚屼竴鈥滃ぉ鈥濇湁澶氫釜瀵硅薄鏃讹紝濡備綍澶勭悊锛堣繖閲岀ず渚嬪彇绗竴涓級
+                        (existing, replacement) -> existing // 鑻ユ湁閲嶅閿紝淇濈暀宸插瓨鍦ㄧ殑瀵硅薄
+                ));
+        List<Map<String, Object>> resultList = new ArrayList<>();
+        for (int i = 1; i <= 5; i++) {
+            Map<String, Object> resultMap = new HashMap<>();
+            if (groupMap.containsKey(i)) {
+                EamWeekInsDetailUserResponse eamWeekInsDetailUserResponse = groupMap.get(i);
+                resultMap.put("operator" + i, sysDictService.queryTableDictTextByKey("sys_user", "realname", "username", eamWeekInsDetailUserResponse.getInspector()));
+                resultMap.put("confirmUser" + i, sysDictService.queryTableDictTextByKey("sys_user", "realname", "username", eamWeekInsDetailUserResponse.getConfirmUser()));
+            } else {
+                resultMap.put("operator" + i, "");
+                resultMap.put("confirmUser" + i, "");
+            }
+            resultList.add(resultMap);
+        }
+        result.put("data", resultList);
+        return result;
+    }
+
     @Override
     @Transactional(rollbackFor = Exception.class)
     public Result<String> addInspectionOrder(EamInspectionOrderRequest eamInspectionOrderRequest) {
@@ -193,6 +457,7 @@
                 if (CollectionUtils.isNotEmpty(maintenanceStandardDetailList)) {
                     List<EamWeekInspectionDetail> weekInspectionDetailList = maintenanceStandardDetailList.stream().map(EamWeekInspectionDetail::new).collect(Collectors.toList());
                     weekInspectionDetailList.forEach(weekInspectionDetail -> {
+                        weekInspectionDetail.setEquipmentId(eamInspectionOrderRequest.getEquipmentId());
                         weekInspectionDetail.setStandardId(eamInspectionOrderRequest.getStandardId());
                         // TODO 鍛ㄧ偣妫�鏃ユ湡
                         weekInspectionDetail.setPlanInspectionDate(eamInspectionOrderRequest.getInspectionDate());
@@ -541,18 +806,4 @@
         return (List<String>) object;
     }
 
-    @Override
-    public List<InspectionVo> findInspectionResult(String equipmentId, String itemDemand, String yearMonth) {
-        return this.baseMapper.findInspectionResult(equipmentId, itemDemand, yearMonth);
-    }
-
-    @Override
-    public List<InspectionVo> findInspectionUser(String equipmentId, String yearMonth) {
-        return this.baseMapper.findInspectionUser(equipmentId, yearMonth);
-    }
-
-    @Override
-    public List<Map<String, Object>> findInspectionStandard(String equipmentId) {
-        return this.baseMapper.findInspectionStandard(equipmentId);
-    }
 }

--
Gitblit v1.9.3