From fb5aa087eaf6a68cf7ea8114beb270551016e7dd Mon Sep 17 00:00:00 2001
From: lyh <925863403@qq.com>
Date: 星期二, 29 七月 2025 11:27:45 +0800
Subject: [PATCH] 添加定型指派设备

---
 lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/service/impl/MdcEquipmentRunningSectionServiceImpl.java |   43 +++++++++++++++++++++++++++++++++----------
 1 files changed, 33 insertions(+), 10 deletions(-)

diff --git a/lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/service/impl/MdcEquipmentRunningSectionServiceImpl.java b/lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/service/impl/MdcEquipmentRunningSectionServiceImpl.java
index d171beb..b4ca2fa 100644
--- a/lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/service/impl/MdcEquipmentRunningSectionServiceImpl.java
+++ b/lxzn-module-mdc/src/main/java/org/jeecg/modules/mdc/service/impl/MdcEquipmentRunningSectionServiceImpl.java
@@ -1,6 +1,7 @@
 package org.jeecg.modules.mdc.service.impl;
 
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import org.apache.commons.lang3.StringUtils;
 import org.jeecg.common.system.vo.DictModel;
@@ -79,9 +80,18 @@
                 dto = new MdcEquipmentRunningSectionDto();
                 BeanUtils.copyProperties(entity, dto);
                 if (entity.getStatus() == 3 && StringUtils.isBlank(entity.getSequenceNumber()) && isTableExist && !"ZUOLAN".equals(equip.getDrivetype())) {
-                    List<EquipmentMachingDto> esList = equipmentWorkLineService.getEquipmentSequencenumber(tableName, entity.getStartTime(), entity.getEndTime());
-                    if (esList != null && esList.size() > 1) {
-                        dto.setSequenceNumber(esList.get(0).getSequencenumber());
+                    //FANUC鑾峰彇绋嬪簭鍚嶇壒娈婂鐞�
+                    if (equip.getDrivetype().startsWith("FANUC")) {
+                        List<EquipmentMachingDto> esList = equipmentWorkLineService.getEquipProgramNum(equip.getDrivetype(), equip.getEquipmentid(),
+                                entity.getStartTime(), entity.getEndTime());
+                        if (esList != null && esList.size() > 1) {
+                            dto.setSequenceNumber(esList.get(0).getProductName());
+                        }
+                    }else {
+                        List<EquipmentMachingDto> esList = equipmentWorkLineService.getEquipmentSequencenumber(tableName, entity.getStartTime(), entity.getEndTime());
+                        if (esList != null && esList.size() > 1) {
+                            dto.setSequenceNumber(esList.get(0).getSequencenumber());
+                        }
                     }
                 }
                 dtos.add(dto);
@@ -94,9 +104,14 @@
                 BeanUtils.copyProperties(entity, dto);
                 if (entity.getStatus() == 22) {
                     if (equip != null) {
-                        List<MdcAlarmInfo> mdcAlarmInfo = mdcAlarmInfoService.list(new LambdaQueryWrapper<MdcAlarmInfo>().eq(MdcAlarmInfo::getDriveType, equip.getDrivetype()).eq(MdcAlarmInfo::getAlarmCode, entity.getAlarm()).eq(MdcAlarmInfo::getIsUse, 0));
-                        if (mdcAlarmInfo != null && !mdcAlarmInfo.isEmpty()) {
-                            dto.setAlarmContent(mdcAlarmInfo.get(0).getAlarmContent());
+                        Set<TmpEquipmentAlarm> tmpEquipmentAlarmSet = entity.getTmpEquipmentAlarmSet();
+                        if (CollectionUtils.isNotEmpty(tmpEquipmentAlarmSet)) {
+                            dto.setAlarmContent(tmpEquipmentAlarmSet.stream().findFirst().get().getAlarmContent());
+                        }else {
+                            List<MdcAlarmInfo> mdcAlarmInfo = mdcAlarmInfoService.list(new LambdaQueryWrapper<MdcAlarmInfo>().eq(MdcAlarmInfo::getDriveType, equip.getDrivetype()).eq(MdcAlarmInfo::getAlarmCode, entity.getAlarm()).eq(MdcAlarmInfo::getIsUse, 0));
+                            if (mdcAlarmInfo != null && !mdcAlarmInfo.isEmpty()) {
+                                dto.setAlarmContent(mdcAlarmInfo.get(0).getAlarmContent());
+                            }
                         }
                     }
                 }
@@ -215,6 +230,9 @@
             queryWrapper.le(MdcEquipmentRunningSection::getStartTime, endTime);
             queryWrapper.orderByAsc(MdcEquipmentRunningSection::getStartTime);
             list = this.baseMapper.selectList(queryWrapper);
+
+            list = mergeErrorRunningTrace(list);
+
         }
         if (list == null || list.isEmpty()) {
             return Collections.emptyList();
@@ -520,9 +538,9 @@
             //鑾峰彇running杩愯鐨勬棩蹇楄褰�
             List<MdcEquipmentRunningSection> list = this.equipmentRunningTracesLog(equipment.getEquipmentid());
             if (list != null && !list.isEmpty()) {
-//                List<MdcEquipmentRunningSection> equipList = addSequenceNumber(list); //娣诲姞绋嬪簭鍙�
-                this.ergodicTrim(list);
-                super.saveBatch(list);
+                List<MdcEquipmentRunningSection> equipList = addSequenceNumber(list); //娣诲姞绋嬪簭鍙�
+                this.ergodicTrim(equipList);
+                super.saveBatch(equipList);
             }
             //鑾峰彇鎶ヨ鐨勬棩蹇楄褰�
             List<MdcEquipmentRunningSection> errorList = this.equipmentRunningTracesErrorLog(equipment.getEquipmentid());
@@ -556,7 +574,7 @@
                     List<EquipmentMachingDto> esList = equipmentWorkLineService.getEquipProgramNum(equip.getDrivetype(), equip.getEquipmentid(),
                             e.getStartTime(), e.getEndTime());
                     if (esList != null && esList.size() > 1) {
-                        e.setSequenceNumber(esList.get(0).getProgramnumber());
+                        e.setSequenceNumber(esList.get(0).getProductName());
                     }
                 } else if (StringUtils.isNotBlank(equip.getDrivetype()) && equip.getDrivetype().startsWith("SIEMENS")) {
                     List<EquipmentMachingDto> esList = equipmentWorkLineService.getEquipmentSequencenumber(equip.getDrivetype() + "_" + equip.getEquipmentid(), e.getStartTime(), e.getEndTime());
@@ -746,6 +764,11 @@
         return this.baseMapper.findWaitList(date);
     }
 
+    @Override
+    public MdcEquipmentRunningSection getFirstRecord() {
+        return this.baseMapper.getFirstRecord();
+    }
+
     private Map<String, List<MdcEquipmentRunningSectionDto>> logCharts(MdcEquipmentRunningSectionVo equipmentRunningSectionVo, String date) {
         Map<String, List<MdcEquipmentRunningSectionDto>> map = new HashMap<>();
         List<MdcEquipmentRunningSectionDto> normal = new ArrayList<>();

--
Gitblit v1.9.3