From 582bb2627712f66157b5608c8f5798775fc38266 Mon Sep 17 00:00:00 2001
From: lyh <925863403@qq.com>
Date: 星期五, 22 八月 2025 15:20:31 +0800
Subject: [PATCH] 设备管理首页

---
 lxzn-module-eam-common/src/main/java/org/jeecg/modules/eam/service/impl/EamEquipmentServiceImpl.java |   59 +++++++++++++++++++++++++++++++++++++++++++++++++++++------
 1 files changed, 53 insertions(+), 6 deletions(-)

diff --git a/lxzn-module-eam-common/src/main/java/org/jeecg/modules/eam/service/impl/EamEquipmentServiceImpl.java b/lxzn-module-eam-common/src/main/java/org/jeecg/modules/eam/service/impl/EamEquipmentServiceImpl.java
index 5d7a2c8..24afdf3 100644
--- a/lxzn-module-eam-common/src/main/java/org/jeecg/modules/eam/service/impl/EamEquipmentServiceImpl.java
+++ b/lxzn-module-eam-common/src/main/java/org/jeecg/modules/eam/service/impl/EamEquipmentServiceImpl.java
@@ -15,6 +15,7 @@
 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.dto.EchartsDto;
 import org.jeecg.modules.eam.entity.EamEquipment;
 import org.jeecg.modules.eam.entity.EamEquipmentExtend;
 import org.jeecg.modules.eam.mapper.EamEquipmentMapper;
@@ -235,7 +236,7 @@
     }
 
     @Override
-    public List<EquipmentSearchResult> asyncLoadEquipment(String keyword, Integer pageSize, String id) {
+    public List<EquipmentSearchResult> asyncLoadEquipment(String keyword, Integer pageSize, String id, String factoryOrgCode) {
         if (StringUtils.isNotBlank(id)) {
             EamEquipment eamEquipment = eamEquipmentMapper.selectById(id);
             if (eamEquipment != null) {
@@ -261,7 +262,7 @@
                     list(new LambdaQueryWrapper<BaseFactoryUser>().eq(BaseFactoryUser::getUserId,sysUser.getId()));
             if(!CollectionUtils.isEmpty(baseFactoryUserList)){
                 Set<String> factoryIds = baseFactoryUserList.stream().map(BaseFactoryUser::getFactoryId).collect(Collectors.toSet());
-                Set<String> factoryCode= baseFactoryService.listByIds(factoryIds).stream().map(BaseFactory::getOrgCode).collect(Collectors.toSet());
+                Set<String> factoryCode = baseFactoryService.listByIds(factoryIds).stream().map(BaseFactory::getOrgCode).collect(Collectors.toSet());
                 queryWrapper.in("e.factory_org_code", factoryCode);
             } else {
                 return Collections.emptyList();
@@ -269,10 +270,13 @@
         }
 
         if (StringUtils.isNotBlank(keyword)) {
-            queryWrapper.like("equipment_code", keyword);
-            queryWrapper.or().like("equipment_name", keyword);
+            queryWrapper.like("e.equipment_code", keyword);
+            queryWrapper.or().like("e.equipment_name", keyword);
         }
-        queryWrapper.eq("del_flag", CommonConstant.DEL_FLAG_0);
+        if(StringUtils.isNotBlank(factoryOrgCode)){
+            queryWrapper.likeRight("e.factory_org_code", factoryOrgCode);
+        }
+        queryWrapper.eq("e.del_flag", CommonConstant.DEL_FLAG_0);
         IPage<EamEquipment> pageResult = eamEquipmentMapper.queryPageList(page, queryWrapper);
         if (pageResult != null && CollectionUtil.isNotEmpty(pageResult.getRecords())) {
             List<EquipmentSearchResult> resultList = new ArrayList<>();
@@ -410,10 +414,53 @@
         queryWrapper.eq("e.del_flag", CommonConstant.DEL_FLAG_0);
         queryWrapper.ne("ext.technology_status", TechnologyStatusEnum.PROHIBITED.name());
         queryWrapper.isNotNull("ext.technology_check_period");
-        queryWrapper.isNotNull("e.next_technology_check");
+        queryWrapper.isNotNull("ext.next_technology_check");
         return this.getBaseMapper().selectTechnicalEquipmentList(queryWrapper);
     }
 
+    @Override
+    public List<EamEquipment> selectThreeMaintenanceEquipmentList() {
+        QueryWrapper<EamEquipment> queryWrapper = new QueryWrapper<>();
+        queryWrapper.eq("e.del_flag", CommonConstant.DEL_FLAG_0);
+        queryWrapper.ne("ext.maintenance_status", MaintenanceStatusEnum.PROHIBITED.name());
+        queryWrapper.isNotNull("ext.third_maintenance_period");
+        queryWrapper.isNotNull("ext.next_third_maintenance");
+        return this.getBaseMapper().selectThreeMaintenanceEquipmentList(queryWrapper);
+    }
+
+    /**
+     * 璁惧绠$悊棣栭〉-鎶�鏈姸鎬�
+     * @return
+     */
+    @Override
+    public List<EchartsDto> echartsList(){
+        QueryWrapper<EamEquipment> queryWrapper = new QueryWrapper<>();
+        queryWrapper.eq("e.del_flag", CommonConstant.DEL_FLAG_0);
+        //鐢ㄦ埛鏁版嵁鏉冮檺
+        LoginUser sysUser = (LoginUser) SecurityUtils.getSubject().getPrincipal();
+        if (sysUser == null) {
+            return null;
+        }
+        if (StringUtils.isNotBlank(sysUser.getEamEquipmentIds())) {
+            //閫夋嫨浜嗚澶囷紝鏍规嵁璁惧id杩囨护璁惧
+            List<String> equipArr = Arrays.asList(sysUser.getEamEquipmentIds().split(","));
+            queryWrapper.in("e.equipment_code", equipArr);
+        } else {
+            //娌℃湁閫夋嫨璁惧锛屾牴鎹腑蹇冭繃婊よ澶�
+            List<BaseFactoryUser> baseFactoryUserList=baseFactoryUserService.
+                    list(new LambdaQueryWrapper<BaseFactoryUser>().eq(BaseFactoryUser::getUserId,sysUser.getId()));
+            if(!CollectionUtils.isEmpty(baseFactoryUserList)){
+                Set<String> factoryIds = baseFactoryUserList.stream().map(BaseFactoryUser::getFactoryId).collect(Collectors.toSet());
+                Set<String> factoryCode= baseFactoryService.listByIds(factoryIds).stream().map(BaseFactory::getOrgCode).collect(Collectors.toSet());
+                queryWrapper.in("e.factory_org_code", factoryCode);
+            }else {
+                return null;
+            }
+        }
+        List<String> ids=this.baseMapper.queryList(queryWrapper).stream().map(EamEquipment::getId).collect(Collectors.toList());
+        return this.baseMapper.echartsList(ids);
+    }
+
     /**
      * 鑾峰彇鎵�鏈夌殑浜х嚎id锛堝寘鍚墍鏈変笂绾э級
      */

--
Gitblit v1.9.3