From 5f75155116fe0585273271e546855371665540e5 Mon Sep 17 00:00:00 2001
From: hzj <826100833@qq.com>
Date: Wed, 30 Jul 2025 14:12:38 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0icd=E4=BF=AE=E6=94=B9?=
 =?UTF-8?q?=E6=97=A5=E5=BF=97?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../pq/service/impl/PqDevTypeServiceImpl.java | 46 +++++++++++++++++++
 1 file changed, 46 insertions(+)

diff --git a/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/impl/PqDevTypeServiceImpl.java b/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/impl/PqDevTypeServiceImpl.java
index dcc440c5a..673ff0f3e 100644
--- a/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/impl/PqDevTypeServiceImpl.java
+++ b/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/impl/PqDevTypeServiceImpl.java
@@ -11,15 +11,25 @@ import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.njcn.common.pojo.enums.common.DataStateEnum;
 import com.njcn.common.pojo.exception.BusinessException;
 import com.njcn.device.pms.enums.PmsDeviceResponseEnum;
+import com.njcn.device.pq.constant.Param;
+import com.njcn.device.pq.mapper.LineMapper;
 import com.njcn.device.pq.mapper.PqDevTypeMapper;
+import com.njcn.device.pq.mapper.PqsTerminalLogsMapper;
 import com.njcn.device.pq.pojo.param.PqDevTypeParam;
 import com.njcn.device.pq.pojo.po.Device;
+import com.njcn.device.pq.pojo.po.Line;
 import com.njcn.device.pq.pojo.po.PqDevType;
+import com.njcn.device.pq.pojo.po.PqsTerminalLogs;
 import com.njcn.device.pq.service.IDeviceService;
 import com.njcn.device.pq.service.PqDevTypeService;
+import com.njcn.system.api.DicDataFeignClient;
+import com.njcn.system.enums.DicDataEnum;
+import com.njcn.system.enums.DicDataTypeEnum;
+import com.njcn.system.pojo.po.DictData;
 import com.njcn.user.api.UserFeignClient;
 import com.njcn.user.pojo.po.User;
 import com.njcn.web.pojo.param.BaseParam;
+import com.njcn.web.utils.RequestUtil;
 import lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Service;
 import org.springframework.web.multipart.MultipartFile;
@@ -29,8 +39,12 @@ import java.io.File;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
+import java.util.Objects;
+import java.util.function.Function;
 import java.util.stream.Collectors;
 
+import static com.njcn.device.pq.enums.LineBaseEnum.SUB_LEVEL;
+
 
 /**
  * Description:
@@ -45,6 +59,9 @@ public class PqDevTypeServiceImpl extends ServiceImpl<PqDevTypeMapper, PqDevType
 
     private final UserFeignClient userFeignClient;
     private final IDeviceService deviceService;
+    private final PqsTerminalLogsMapper pqsTerminalLogsMapper;
+    private final DicDataFeignClient dicDataFeignClient;
+    private  final LineMapper lineMapper;
 
     @Override
     public Page<PqDevType> pageDevTypeList(BaseParam param) {
@@ -104,6 +121,35 @@ public class PqDevTypeServiceImpl extends ServiceImpl<PqDevTypeMapper, PqDevType
             throw new BusinessException(PmsDeviceResponseEnum.MODEL_NAME_REPEAT);
         }
         PqDevType pqDevType = BeanUtil.copyProperties(param, PqDevType.class);
+        //修改icd文件记录日志重启前置
+        PqDevType byId = this.getById(param.getId());
+        if(!Objects.equals(byId.getIcdId(),param.getId())){
+            List<Device> list = deviceService.lambdaQuery().eq(Device::getDevType, param.getId()).eq(Device::getRunFlag, 0).list();
+            list.forEach(temp->{
+                //记录日志
+                DictData dataDic = dicDataFeignClient.getDicDataByCodeAndType(DicDataEnum.DEV_PARAMETER.getCode(), DicDataTypeEnum.DEV_OPS.getCode()).getData();
+                String name = RequestUtil.getUserNickname();
+                PqsTerminalLogs pqsTerminalLogs = new PqsTerminalLogs();
+                pqsTerminalLogs.setLogsType(dataDic.getId());
+                //终端为4
+                pqsTerminalLogs.setTerminalType(4);
+
+                List<Line> subList = lineMapper.selectList(null);
+                Map<String,Line> subMap = subList.stream().collect(Collectors.toMap(Line::getId, Function.identity()));
+                Line dev = subMap.get(temp.getId());
+
+                String subName = subMap.get(dev.getPids().split(StrUtil.COMMA)[SUB_LEVEL.getCode()]).getName();
+                String temLos = "%s进行更新终端进程操作;终端名称 ：%s,修改了icd文件";
+                String tem = String.format(temLos,name,subName+"_"+dev.getName());
+                pqsTerminalLogs.setTerminalDescribe(tem);
+                pqsTerminalLogs.setState(DataStateEnum.ENABLE.getCode());
+                pqsTerminalLogs.setIsPush(0);
+                pqsTerminalLogs.setOperateType(Param.UPDATE);
+                pqsTerminalLogs.setObjIndex(temp.getId());
+                pqsTerminalLogsMapper.insert(pqsTerminalLogs);
+            });
+
+        }
         return this.updateById(pqDevType);
     }