feat(service): 添加设备版本信息中的通讯协议和nDid字段

- 在DevVersionVO中新增accessMethod和nDid属性 - 在CsEquipmentDeliveryServiceImpl中设置设备访问方法和nDid值 - 移除控制器中的多余空行以优化代码格式
feat(ed-data): 新增ED数据管理和设备版本功能
2026-07-17 15:38:33 +08:00 · 2026-07-17 13:43:07 +08:00 · 2026-07-14 11:10:46 +08:00 · 2026-07-13 16:35:48 +08:00 · 2026-07-08 10:05:16 +08:00 · 2026-07-07 20:29:05 +08:00
28 changed files with 500 additions and 116 deletions
--- a/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/api/CsEdDataFeignClient.java
+++ b/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/api/CsEdDataFeignClient.java
@@ -1,14 +1,23 @@
 package com.njcn.csdevice.api;

+import com.njcn.common.pojo.annotation.OperateInfo;
 import com.njcn.common.pojo.constant.ServerInfo;
+import com.njcn.common.pojo.enums.common.LogEnum;
+import com.njcn.common.pojo.enums.response.CommonResponseEnum;
 import com.njcn.common.pojo.response.HttpResult;
+import com.njcn.common.utils.HttpResultUtil;
 import com.njcn.csdevice.api.fallback.CsEdDataFeignClientFallbackFactory;
+import com.njcn.csdevice.pojo.param.CsEdDataAddParm;
+import com.njcn.csdevice.pojo.param.CsEdDataQueryParm;
 import com.njcn.csdevice.pojo.po.CsEdDataPO;
 import com.njcn.csdevice.pojo.vo.CsEdDataVO;
+import io.swagger.annotations.ApiImplicitParam;
+import io.swagger.annotations.ApiOperation;
 import org.springframework.cloud.openfeign.FeignClient;
 import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestParam;

 import java.util.List;
@@ -27,4 +36,12 @@ public interface CsEdDataFeignClient {

    @GetMapping("/getById")
    HttpResult<CsEdDataPO> getById(@RequestParam("id") String id);
+
+    @GetMapping("/addEdDataFirst")
+    @ApiOperation("首次录入版本信息")
+    HttpResult<CsEdDataPO> addEdDataFirst(@RequestBody CsEdDataAddParm param);
+
+    @GetMapping("/findByCondition")
+    @ApiOperation("根据条件查询是否存在数据")
+    HttpResult<CsEdDataPO> findByCondition(@RequestBody CsEdDataQueryParm param);
 }
--- a/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/api/CsUpgradeLogsFeignClient.java
+++ b/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/api/CsUpgradeLogsFeignClient.java
@@ -4,19 +4,23 @@ import com.njcn.common.pojo.constant.ServerInfo;
 import com.njcn.common.pojo.response.HttpResult;
 import com.njcn.csdevice.api.fallback.CsUpgradeLogsClientFallbackFactory;
 import com.njcn.csdevice.pojo.po.CsUpgradeLogs;
-import io.swagger.annotations.ApiImplicitParam;
 import io.swagger.annotations.ApiOperation;
 import org.springframework.cloud.openfeign.FeignClient;
 import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestParam;

 /**
 * @author caozehui
 * @data 2026-04-23
 */
-@FeignClient(value = ServerInfo.CS_DEVICE_BOOT, path = "/csUpgradeLogs", fallbackFactory = CsUpgradeLogsClientFallbackFactory.class,contextId = "csSoftInfo")
+@FeignClient(value = ServerInfo.CS_DEVICE_BOOT, path = "/csUpgradeLogs", fallbackFactory = CsUpgradeLogsClientFallbackFactory.class,contextId = "csUpgradeLogs")
 public interface CsUpgradeLogsFeignClient {
    @PostMapping("/add")
    HttpResult add(@RequestBody CsUpgradeLogs csUpgradeLogs);

+    @PostMapping("/update")
+    @ApiOperation("修改升级日志")
+    HttpResult<Boolean> update(@RequestParam("devId") String devId, @RequestParam("code") String code, @RequestParam("result") Integer result);
+
 }
--- a/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/api/fallback/CsEdDataFeignClientFallbackFactory.java
+++ b/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/api/fallback/CsEdDataFeignClientFallbackFactory.java
@@ -4,6 +4,8 @@ import com.njcn.common.pojo.enums.response.CommonResponseEnum;
 import com.njcn.common.pojo.exception.BusinessException;
 import com.njcn.common.pojo.response.HttpResult;
 import com.njcn.csdevice.api.CsEdDataFeignClient;
+import com.njcn.csdevice.pojo.param.CsEdDataAddParm;
+import com.njcn.csdevice.pojo.param.CsEdDataQueryParm;
 import com.njcn.csdevice.pojo.po.CsEdDataPO;
 import com.njcn.csdevice.pojo.vo.CsEdDataVO;
 import feign.hystrix.FallbackFactory;
@@ -45,6 +47,18 @@ public class CsEdDataFeignClientFallbackFactory implements FallbackFactory<CsEdD
                log.error("{}异常，降级处理，异常为：{}","根据id获取装置类型",cause.toString());
                throw new BusinessException(finalExceptionEnum);
            }
+
+            @Override
+            public HttpResult<CsEdDataPO> addEdDataFirst(CsEdDataAddParm param) {
+                log.error("{}异常，降级处理，异常为：{}","首次录入版本信息",cause.toString());
+                throw new BusinessException(finalExceptionEnum);
+            }
+
+            @Override
+            public HttpResult<CsEdDataPO> findByCondition(CsEdDataQueryParm param) {
+                log.error("{}异常，降级处理，异常为：{}","根据条件查询是否存在数据",cause.toString());
+                throw new BusinessException(finalExceptionEnum);
+            }
        };
    }
 }
--- a/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/api/fallback/CsUpgradeLogsClientFallbackFactory.java
+++ b/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/api/fallback/CsUpgradeLogsClientFallbackFactory.java
@@ -31,6 +31,12 @@ public class CsUpgradeLogsClientFallbackFactory implements FallbackFactory<CsUpg
                log.error("{}异常，降级处理，异常为：{}", "新增升级日志异常", cause.toString());
                throw new BusinessException(finalExceptionEnum);
            }
+
+            @Override
+            public HttpResult<Boolean> update(String devId, String code, Integer result) {
+                log.error("{}异常，降级处理，异常为：{}", "修改升级日志", cause.toString());
+                throw new BusinessException(finalExceptionEnum);
+            }
        };
    }
 }
--- a/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/pojo/param/CsEdDataAddParm.java
+++ b/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/pojo/param/CsEdDataAddParm.java
@@ -72,7 +72,7 @@ public class CsEdDataAddParm  {
    private String versionType;

    @ApiModelProperty(value = "crc信息")
-    private String crcInfo;
+    private String crc;

    @ApiModelProperty(value = ".bin文件")
    @NotNull(message="文件不能为空！")
--- a/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/pojo/param/CsEdDataQueryParm.java
+++ b/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/pojo/param/CsEdDataQueryParm.java
@@ -7,6 +7,7 @@ import org.springframework.format.annotation.DateTimeFormat;

 import javax.validation.constraints.Min;
 import javax.validation.constraints.NotNull;
+import java.time.LocalDate;

 /**
 * 
@@ -52,7 +53,17 @@ public class CsEdDataQueryParm {
    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss",timezone = "GMT+8")
    private String versionendDate;

+    @ApiModelProperty(value = "版本号")
+    private String versionNo;

+    @ApiModelProperty(value = "协议版本号")
+    private String versionAgreement;

+    @ApiModelProperty(value = "版本日期")
+    @DateTimeFormat(pattern="yyyy-MM-dd")
+    private LocalDate versionDate;
+
+    @ApiModelProperty(value = "校验码")
+    private String crc;

 }
--- a/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/pojo/po/CsUpgradeLogs.java
+++ b/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/pojo/po/CsUpgradeLogs.java
@@ -30,7 +30,18 @@ public class CsUpgradeLogs {
    private String versionNo;

    /**
-     * 升级结果(0:失败 1:成功)
+     * 前置返回的code编码，如果升级失败，能知道是什么原因
+     */
+    @TableField(value = "code")
+    private String code;
+
+    /**
+     * 当前状态
+     * (0:失败
+     * 1:成功
+     * 2:升级中
+     * 3:升级指令下发但是没有收到前置响应
+     * )
     */
    private Integer result;

--- a/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/pojo/vo/CsEquipmentDeliveryVO.java
+++ b/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/pojo/vo/CsEquipmentDeliveryVO.java
@@ -94,6 +94,9 @@ public class CsEquipmentDeliveryVO extends BaseEntity {
    @ApiModelProperty(value="前置服务器id")
    private String nodeId ;

+    @ApiModelProperty(value="前置进程号")
+    private Integer nodeProcess ;
+
    @ApiModelProperty(value="所属工程id")
    private String associatedEngineering;

--- a/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/pojo/vo/DevVersionVO.java
+++ b/cs-device/cs-device-api/src/main/java/com/njcn/csdevice/pojo/vo/DevVersionVO.java
@@ -33,7 +33,7 @@ public class DevVersionVO {
    /**
     * 版本日期
     */
-    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+    @JsonFormat(pattern = "yyyy-MM-dd")
    private LocalDateTime versionDate;

    /**
@@ -51,6 +51,20 @@ public class DevVersionVO {
     */
    private String icd;

+    /**
+     * crc校验码
+     */
+    private String crc;
+
+    /**
+     * 设备通讯协议
+     */
+    private String accessMethod;
+
+    /**
+     * nDid
+     */
+    private String nDid;

    /**
     * 所属工程
--- a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/controller/equipment/CsUpgradeLogsController.java
+++ b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/controller/equipment/CsUpgradeLogsController.java
@@ -12,6 +12,7 @@ import com.njcn.web.controller.BaseController;
 import com.njcn.web.utils.RequestUtil;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiImplicitParam;
+import io.swagger.annotations.ApiImplicitParams;
 import io.swagger.annotations.ApiOperation;
 import lombok.AllArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
@@ -44,6 +45,20 @@ public class CsUpgradeLogsController extends BaseController {
        return HttpResultUtil.assembleCommonResponseResult(csUpgradeLogsService.save(csUpgradeLogs) ? CommonResponseEnum.SUCCESS : CommonResponseEnum.FAIL, null, methodDescribe);
    }

+    @OperateInfo(info = LogEnum.SYSTEM_COMMON, operateType = OperateType.ADD)
+    @PostMapping("/update")
+    @ApiOperation("修改升级日志")
+    @ApiImplicitParams({
+            @ApiImplicitParam(name = "devId", value = "设备id", required = true),
+            @ApiImplicitParam(name = "code", value = "响应码", required = true),
+            @ApiImplicitParam(name = "result", value = "结果", required = true)
+    })
+    public HttpResult<Boolean> update(@RequestParam("devId") String devId, @RequestParam("code") String code, @RequestParam("result") Integer result) {
+        String methodDescribe = getMethodDescribe("update");
+        boolean re = csUpgradeLogsService.updateLogs(devId,code,result);
+        return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, re, methodDescribe);
+    }
+
    @OperateInfo(info = LogEnum.SYSTEM_COMMON, operateType = OperateType.ADD)
    @GetMapping("/getByDevId")
    @ApiOperation("查询指定devId的所有升级日志")
--- a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/controller/project/CsEdDataController.java
+++ b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/controller/project/CsEdDataController.java
@@ -90,4 +90,24 @@ public class CsEdDataController extends BaseController {
        return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, dataPO, methodDescribe);
    }

+    @OperateInfo(info = LogEnum.BUSINESS_COMMON)
+    @GetMapping("/findByCondition")
+    @ApiOperation("根据条件查询是否存在数据")
+    @ApiImplicitParam(name = "param", value = "param", required = true)
+    public HttpResult<CsEdDataPO> findByCondition(@RequestBody CsEdDataQueryParm param){
+        String methodDescribe = getMethodDescribe("findByCondition");
+        CsEdDataPO po = csEdDataService.findByCondition(param);
+        return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, po, methodDescribe);
+    }
+
+    @OperateInfo(info = LogEnum.BUSINESS_COMMON)
+    @GetMapping("/addEdDataFirst")
+    @ApiOperation("首次录入版本信息")
+    @ApiImplicitParam(name = "param", value = "param", required = true)
+    public HttpResult<CsEdDataPO> addEdDataFirst(@RequestBody CsEdDataAddParm param){
+        String methodDescribe = getMethodDescribe("addEdDataFirst");
+        csEdDataService.addEdDataFirst(param);
+        return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe);
+    }
+
 }
--- a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/CsEdDataService.java
+++ b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/CsEdDataService.java
@@ -56,5 +56,14 @@ public interface CsEdDataService extends IService<CsEdDataPO> {
     * @return
     */
    CsEdDataPO findByDevTypeIdAndVersionNo(String devTypeId, String versionNo);
+
+    /**
+     * @Description: 根据条件查询是否存在数据
+     * @param param
+     * @return
+     */
+    CsEdDataPO findByCondition(CsEdDataQueryParm param);
+
+    void addEdDataFirst(CsEdDataAddParm param);
 }

--- a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/CsUpgradeLogsService.java
+++ b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/CsUpgradeLogsService.java
@@ -8,4 +8,7 @@ import com.njcn.csdevice.pojo.po.CsUpgradeLogs;
 * @data 2026-04-23
 */
 public interface CsUpgradeLogsService extends IService<CsUpgradeLogs> {
+
+    boolean updateLogs(String devId, String code, Integer result);
+
 }
--- a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/CsDeviceUserPOServiceImpl.java
+++ b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/CsDeviceUserPOServiceImpl.java
@@ -60,6 +60,7 @@ public class CsDeviceUserPOServiceImpl extends ServiceImpl<CsDeviceUserPOMapper,
    private final UserFeignClient userFeignClient;
    private final IMqttUserService mqttUserService;
    private final CsCommTerminalFeignClient commTerminalService;
+    private final AppProjectService appProjectService;

    @Override
    @Transactional(rollbackFor = Exception.class)
@@ -272,9 +273,15 @@ public class CsDeviceUserPOServiceImpl extends ServiceImpl<CsDeviceUserPOMapper,
                    break;
                }
            }
-            //获取项目数量
-            if (CollectionUtil.isNotEmpty(currentProjectIds)) {
-                vo.setCurrentProjectCount(currentProjectIds.size());
+            //获取项目数量 这边可能项目下没有挂载设备，这边项目数量直接从接口获取
+//            if (CollectionUtil.isNotEmpty(currentProjectIds)) {
+//                vo.setCurrentProjectCount(currentProjectIds.size());
+//            }
+            List<AppProjectPO> projectInfoList = appProjectService.getProjectByEngineering(Collections.singletonList(id));
+            if (CollectionUtil.isNotEmpty(projectInfoList)) {
+                vo.setCurrentProjectCount(projectInfoList.size());
+            } else {
+                vo.setCurrentProjectCount(0);
            }
            //获取设备总数、在线设备、离线设备
            if (CollectionUtil.isNotEmpty(currentDevIds)) {
--- a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/CsEdDataServiceImpl.java
+++ b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/CsEdDataServiceImpl.java
@@ -20,6 +20,7 @@ import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.util.CollectionUtils;

+import java.time.ZoneId;
 import java.util.List;
 import java.util.Objects;

@@ -45,11 +46,13 @@ public class CsEdDataServiceImpl extends ServiceImpl<CsEdDataMapper, CsEdDataPO>
        BeanUtils.copyProperties(csEdDataAddParm, csEdDataPO);
        String remoteDir = StrUtil.SLASH + OssPath.EDDATA + csEdDataAddParm.getDevTypeName() + StrUtil.SLASH + csEdDataAddParm.getVersionNo() + StrUtil.SLASH;
        String filePath = fileStorageUtil.uploadMultipart(csEdDataAddParm.getFile(), remoteDir, true);
-        csEdDataPO.setCrc(csEdDataAddParm.getCrcInfo());
+        csEdDataPO.setCrc(csEdDataAddParm.getCrc());
        csEdDataPO.setFilePath(filePath);
        csEdDataPO.setStatus("1");
-        boolean save = this.save(csEdDataPO);
-        return save;
+        csEdDataPO.setVersionDate(csEdDataAddParm.getVersionDate().toInstant()
+                .atZone(ZoneId.systemDefault())
+                .toLocalDateTime());
+        return this.save(csEdDataPO);
    }

    @Override
@@ -93,5 +96,28 @@ public class CsEdDataServiceImpl extends ServiceImpl<CsEdDataMapper, CsEdDataPO>
                .eq(CsEdDataPO::getVersionNo, versionNo)
                .eq(CsEdDataPO::getStatus, 1).one();
    }
+
+    @Override
+    public CsEdDataPO findByCondition(CsEdDataQueryParm param) {
+        return this.lambdaQuery()
+                .eq(CsEdDataPO::getDevType, param.getDevType())
+                .eq(CsEdDataPO::getVersionNo, param.getVersionNo())
+                .eq(CsEdDataPO::getVersionAgreement, param.getVersionAgreement())
+                .eq(CsEdDataPO::getVersionDate, param.getVersionDate())
+                .eq(CsEdDataPO::getStatus, 1)
+                .one();
+    }
+
+    @Override
+    public void addEdDataFirst(CsEdDataAddParm param) {
+        CsEdDataPO csEdDataPO = new CsEdDataPO();
+        BeanUtils.copyProperties(param, csEdDataPO);
+        csEdDataPO.setCrc(param.getCrc());
+        csEdDataPO.setStatus("1");
+        csEdDataPO.setVersionDate(param.getVersionDate().toInstant()
+                .atZone(ZoneId.systemDefault())
+                .toLocalDateTime());
+        this.save(csEdDataPO);
+    }
 }

--- a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/CsEquipmentDeliveryServiceImpl.java
+++ b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/CsEquipmentDeliveryServiceImpl.java
@@ -10,6 +10,7 @@ import cn.hutool.core.collection.CollUtil;
 import cn.hutool.core.collection.CollectionUtil;
 import cn.hutool.core.date.DatePattern;
 import cn.hutool.core.text.StrPool;
+import cn.hutool.core.util.IdUtil;
 import cn.hutool.core.util.ObjectUtil;
 import cn.hutool.core.util.StrUtil;
 import com.alibaba.fastjson.JSONArray;
@@ -36,10 +37,7 @@ import com.njcn.csdevice.pojo.dto.DevDetailDTO;
 import com.njcn.csdevice.pojo.dto.PqsCommunicateDto;
 import com.njcn.csdevice.pojo.param.*;
 import com.njcn.csdevice.pojo.po.*;
-import com.njcn.csdevice.pojo.vo.CsEquipmentDeliveryVO;
-import com.njcn.csdevice.pojo.vo.DevVersionVO;
-import com.njcn.csdevice.pojo.vo.DeviceManagerVO;
-import com.njcn.csdevice.pojo.vo.ProjectEquipmentVO;
+import com.njcn.csdevice.pojo.vo.*;
 import com.njcn.csdevice.service.*;
 import com.njcn.csdevice.util.QRCodeUtil;
 import com.njcn.csdevice.utils.ExcelStyleUtil;
@@ -49,6 +47,8 @@ import com.njcn.csharmonic.api.EventUserFeignClient;
 import com.njcn.csharmonic.param.CsEventUserQueryParam;
 import com.njcn.csharmonic.pojo.po.CsEventPO;
 import com.njcn.device.biz.mapper.OverLimitWlMapper;
+import com.njcn.mq.message.CloudTopicMessage;
+import com.njcn.mq.template.CloudTopicMessageTemplate;
 import com.njcn.oss.constant.OssPath;
 import com.njcn.oss.utils.FileStorageUtil;
 import com.njcn.redis.pojo.enums.AppRedisKey;
@@ -133,6 +133,7 @@ public class CsEquipmentDeliveryServiceImpl extends ServiceImpl<CsEquipmentDeliv
    private final CsHarmonicPlanLineFeignClient csHarmonicPlanLineFeignClient;
    private final ICsDeviceRegistryService csDeviceRegistryService;
    private final StringRedisTemplate stringRedisTemplate;
+    private final CloudTopicMessageTemplate cloudTopicMessageTemplate;

    @Override
    public void refreshDeviceDataCache() {
@@ -172,6 +173,8 @@ public class CsEquipmentDeliveryServiceImpl extends ServiceImpl<CsEquipmentDeliv
        csEquipmentDeliveryPo.setQrPath(qr);
        String path = this.createPath(csEquipmentDeliveryAddParm.getNdid());
        csEquipmentDeliveryPo.setMac(path);
+        //PQCOM默认都支持升级
+        csEquipmentDeliveryPo.setUpgrade(1);
        //记录设备调试日志表
        CsEquipmentProcessPO csEquipmentProcess = new CsEquipmentProcessPO();
        csEquipmentProcess.setDevId(csEquipmentDeliveryAddParm.getNdid());
@@ -194,7 +197,6 @@ public class CsEquipmentDeliveryServiceImpl extends ServiceImpl<CsEquipmentDeliv
                refreshDeviceDataCache();
            }
        }
-
        return csEquipmentDeliveryPo;
    }

@@ -1275,6 +1277,17 @@ public class CsEquipmentDeliveryServiceImpl extends ServiceImpl<CsEquipmentDeliv
            //修改设备的运行状态，则录入influxdb表数据
            int communicateType = status == 2 ? 1 : 0;
            insertPqsCommunicateRecord(time, po.getNdid(), communicateType);
+            //如果是设备上线，则询问设备的版本信息
+            CloudTopicMessage message = new CloudTopicMessage();
+            message.setGuid(IdUtil.simpleUUID());
+            message.setDevId(po.getId());
+            message.setFrontId(po.getNodeId());
+            message.setNode(po.getNodeProcess());
+            CloudTopicMessage.Detail detail = new CloudTopicMessage.Detail();
+            detail.setType(1112);
+            detail.setMsg(new ArrayList<>());
+            message.setDetail(detail);
+            cloudTopicMessageTemplate.sendMember(message, po.getNodeId());
        }
    }

@@ -1317,6 +1330,10 @@ public class CsEquipmentDeliveryServiceImpl extends ServiceImpl<CsEquipmentDeliv

    @Override
    public IPage<DevVersionVO> versionPage(CsEquipmentDeliveryQueryParm baseParam) {
+        //获取台账信息
+        List<CsLedgerVO> allList = csLedgerMapper.getAll();
+        Map<String, CsLedgerVO> csLedgerMap = CollUtil.isEmpty(allList) ? Collections.emptyMap() : allList.stream().collect(Collectors.toMap(CsLedgerVO::getId, item -> item));
+
        LambdaQueryWrapper<CsEquipmentDeliveryPO> wrapper = new LambdaQueryWrapper<>();
        wrapper.ne(CsEquipmentDeliveryPO::getRunStatus, 0)
                .eq(StrUtil.isNotBlank(baseParam.getDevModel()), CsEquipmentDeliveryPO::getDevModel, baseParam.getDevModel())
@@ -1335,16 +1352,17 @@ public class CsEquipmentDeliveryServiceImpl extends ServiceImpl<CsEquipmentDeliv
            }
            if (StrUtil.isNotBlank(item.getSoftinfoId())) {
                CsSoftInfoPO softInfoPO = csSoftInfoService.getById(item.getSoftinfoId());
-
                if (ObjectUtil.isNotNull(softInfoPO)) {
+                    devVersionVO.setVersion(softInfoPO.getAppVersion());
+                    devVersionVO.setVersionDate(softInfoPO.getAppDate());
+                    devVersionVO.setCrc(softInfoPO.getAppCheck());
+                    devVersionVO.setAccessMethod(item.getDevAccessMethod());
+                    devVersionVO.setNDid(item.getNdid());
                    CsEdDataPO csEdDataPO = csEdDataService.findByDevTypeIdAndVersionNo(item.getDevModel(), softInfoPO.getAppVersion());
                    if (ObjectUtil.isNotNull(csEdDataPO)) {
-                        devVersionVO.setVersion(csEdDataPO.getVersionNo());
                        devVersionVO.setProtocolVersion(csEdDataPO.getVersionAgreement());
-                        devVersionVO.setVersionDate(csEdDataPO.getVersionDate());
                    }
                }
-
            }
            devVersionVO.setStatus(item.getUsageStatus());
            devVersionVO.setIcd(item.getIcd());
@@ -1354,18 +1372,19 @@ public class CsEquipmentDeliveryServiceImpl extends ServiceImpl<CsEquipmentDeliv
                    devVersionVO.setDevModelName(sysDicTreePO.getName());
                }
            }
-
-            if (StrUtil.isNotBlank(item.getAssociatedEngineering())) {
-                devVersionVO.setAssociatedEngineering(csEngineeringService.getById(item.getAssociatedEngineering()).getName());
+            //获取工程名称和项目名称
+            CsLedgerVO devVo = csLedgerMap.get(item.getId());
+            if (!Objects.isNull(devVo)) {
+                //项目
+                CsLedgerVO proVo = csLedgerMap.get(devVo.getPid());
+                devVersionVO.setAssociatedProject(proVo.getName());
+                //工程
+                CsLedgerVO engineeringVo = csLedgerMap.get(proVo.getPid());
+                devVersionVO.setAssociatedEngineering(engineeringVo.getName());
            }
-            if (StrUtil.isNotBlank(item.getAssociatedProject())) {
-                devVersionVO.setAssociatedProject(appProjectService.getById(item.getAssociatedProject()).getName());
-            }
-
-            //判断装置是否已经连接上mqtt服务器
-            String clientName = "NJCN-" + item.getNdid().substring(item.getNdid().length() - 6);
-            boolean mqttClient = mqttUtil.judgeClientOnline(clientName);
-            if (mqttClient) {
+            //设备通讯状态
+            Integer runStatus = item.getRunStatus();
+            if (!Objects.isNull(runStatus) && runStatus == 2) {
                devVersionVO.setConnectStatus(1);
            } else {
                devVersionVO.setConnectStatus(0);
--- a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/CsLedgerServiceImpl.java
+++ b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/CsLedgerServiceImpl.java
@@ -300,7 +300,7 @@ public class CsLedgerServiceImpl extends ServiceImpl<CsLedgerMapper, CsLedger> i
        List<CsLedgerVO> portables = ledger.stream()
                .peek(c -> {
                    CsEquipmentDeliveryPO po = poMap2.get(c.getId());
-                    c.setPid(portable.getId());
+                    c.setPid("2");
                    c.setComFlag(po.getRunStatus());
                    c.setNDId(po.getNdid());
                    c.setType("device");
@@ -365,13 +365,13 @@ public class CsLedgerServiceImpl extends ServiceImpl<CsLedgerMapper, CsLedger> i
                portable1.setLevel(0);
                portable1.setName("便携式工程");
                portable1.setPid("0");
-                portable1.setId(id);
+                portable1.setId("1");

                CsLedgerVO portable2 = new CsLedgerVO();
                portable2.setLevel(1);
                portable2.setName("便携式项目");
-                portable2.setPid(id);
-                portable2.setId(IdUtil.simpleUUID());
+                portable2.setPid("1");
+                portable2.setId("2");
                portable2.setChildren(portables);

                portable1.setChildren(Collections.singletonList(portable2));
@@ -719,7 +719,7 @@ public class CsLedgerServiceImpl extends ServiceImpl<CsLedgerMapper, CsLedger> i
        List<CsLedgerVO> portables = ledger.stream()
                .peek(c -> {
                    CsEquipmentDeliveryPO po = poMap2.get(c.getId());
-                    c.setPid(portable.getId());
+                    c.setPid("2");
                    c.setComFlag(po.getRunStatus());
                    c.setNDId(po.getNdid());
                    c.setType("device");
@@ -776,18 +776,17 @@ public class CsLedgerServiceImpl extends ServiceImpl<CsLedgerMapper, CsLedger> i
            tree.addAll(new ArrayList<>(engineeringMap.values()));

            if (CollUtil.isNotEmpty(portables)) {
-                String id = IdUtil.simpleUUID();
                CsLedgerVO portable1 = new CsLedgerVO();
                portable1.setLevel(0);
                portable1.setName("便携式工程");
                portable1.setPid("0");
-                portable1.setId(id);
+                portable1.setId("1");

                CsLedgerVO portable2 = new CsLedgerVO();
                portable2.setLevel(1);
                portable2.setName("便携式项目");
-                portable2.setPid(id);
-                portable2.setId(IdUtil.simpleUUID());
+                portable2.setPid("1");
+                portable2.setId("2");
                portable2.setChildren(portables);

                List<CsLedgerVO> portable2List = new ArrayList<>();
--- a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/CsUpgradeLogsServiceImpl.java
+++ b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/CsUpgradeLogsServiceImpl.java
@@ -1,9 +1,13 @@
 package com.njcn.csdevice.service.impl;

+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.njcn.csdevice.mapper.CsUpgradeLogsMapper;
 import com.njcn.csdevice.pojo.po.CsUpgradeLogs;
+import com.njcn.csdevice.service.CsEquipmentDeliveryService;
 import com.njcn.csdevice.service.CsUpgradeLogsService;
+import lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Service;

 /**
@@ -11,5 +15,26 @@ import org.springframework.stereotype.Service;
 * @data 2026-04-23
 */
@Service
+@RequiredArgsConstructor
 public class CsUpgradeLogsServiceImpl extends ServiceImpl<CsUpgradeLogsMapper, CsUpgradeLogs> implements CsUpgradeLogsService {
+
+    private final CsEquipmentDeliveryService csEquipmentDeliveryService;
+
+    @Override
+    public boolean updateLogs(String devId, String code, Integer result) {
+        CsUpgradeLogs latestLog = this.baseMapper.selectOne(
+                new LambdaQueryWrapper<CsUpgradeLogs>()
+                        .eq(CsUpgradeLogs::getDevId, devId)
+                        .orderByDesc(CsUpgradeLogs::getCreateTime)
+                        .last("LIMIT 1")
+        );
+        if (latestLog != null) {
+            LambdaUpdateWrapper<CsUpgradeLogs> updateWrapper = new LambdaUpdateWrapper<>();
+            updateWrapper.set(CsUpgradeLogs::getCode, code)
+                    .set(CsUpgradeLogs::getResult, result)
+                    .eq(CsUpgradeLogs::getId, latestLog.getId());
+            return this.update(null, updateWrapper);
+        }
+        return false;
+    }
 }
--- a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/PortableOfflLogServiceImpl.java
+++ b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/PortableOfflLogServiceImpl.java
@@ -628,6 +628,9 @@ public class PortableOfflLogServiceImpl extends ServiceImpl<PortableOfflLogMappe
        } else {
            rmpEventDetailPo.setDealFlag(0);
        }
+        if (!Objects.isNull(item.getSagSource())) {
+            rmpEventDetailPo.setSagsource(item.getSagSource());
+        }
        wlRmpEventDetailMapper.insert(rmpEventDetailPo);
    }

--- a/cs-harmonic/cs-harmonic-api/src/main/java/com/njcn/csharmonic/param/CsEventUserQueryPage.java
+++ b/cs-harmonic/cs-harmonic-api/src/main/java/com/njcn/csharmonic/param/CsEventUserQueryPage.java
@@ -7,6 +7,7 @@ import org.hibernate.validator.constraints.Range;

 import javax.validation.constraints.Min;
 import javax.validation.constraints.NotNull;
+import java.util.List;

 /**
 * 
@@ -81,4 +82,6 @@ public class CsEventUserQueryPage extends CsEventUserQueryParam{

    @ApiModelProperty(value = "是否是dvr治理效果 0:否 1:是")
    private Integer isDvr;
+
+    private List<String> epdTagList;
 }
--- a/cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/mapper/CsEventUserPOMapper.java
+++ b/cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/mapper/CsEventUserPOMapper.java
@@ -36,7 +36,7 @@ public interface CsEventUserPOMapper extends BaseMapper<CsEventUserPO> {
    Page<EventDetailVO> queryEventpage(Page<EventDetailVO> returnpage, @Param("csEventUserQueryPage") CsEventUserQueryPage csEventUserQueryPage, @Param("devIds") List<String> devIds);


-    Page<EventDetailVO> queryEventPageWeb(Page<EventDetailVO> returnpage,@Param("csEventUserQueryPage") CsEventUserQueryPage csEventUserQueryPage,@Param("devIds") List<String> collect);
+    Page<EventDetailVO> queryEventPageWeb(Page<EventDetailVO> returnpage,@Param("csEventUserQueryPage") CsEventUserQueryPage csEventUserQueryPage,@Param("devIds") List<String> collect,@Param("lineIds") List<String> collect2);

    Page<EventDetailVO> queryEventPageWebDvr(Page<EventDetailVO> returnpage,@Param("csEventUserQueryPage") CsEventUserQueryPage csEventUserQueryPage,@Param("lineIds") List<String> collect);

--- a/cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/mapper/mapping/CsEventUserPOMapper.xml
+++ b/cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/mapper/mapping/CsEventUserPOMapper.xml
@@ -223,13 +223,25 @@
    <if test="csEventUserQueryPage!=null and csEventUserQueryPage.severityMax  != null and csEventUserQueryPage.severityMax !=''">
      AND b.severity &lt; #{csEventUserQueryPage.severityMax}
    </if>
-    <if test="csEventUserQueryPage!=null and csEventUserQueryPage.searchValue  != null and csEventUserQueryPage.searchValue !=''">
-      <if test="csEventUserQueryPage.type != null and csEventUserQueryPage.type !='' and csEventUserQueryPage.type == 3 ">
-        AND e.name like concat('%',#{csEventUserQueryPage.searchValue},'%')
-      </if>
-      <if test="csEventUserQueryPage.type != null and csEventUserQueryPage.type !='' and csEventUserQueryPage.type != 3 ">
-        AND d.name like concat('%',#{csEventUserQueryPage.searchValue},'%')
+    <if test="csEventUserQueryPage != null and csEventUserQueryPage.searchValue != null and csEventUserQueryPage.searchValue != ''">
+      AND (
+      <!-- 名称匹配（根据type区分线路名/设备名） -->
+      <choose>
+        <when test="csEventUserQueryPage.type != null and csEventUserQueryPage.type == 3">
+          (e.name LIKE CONCAT('%', #{csEventUserQueryPage.searchValue}, '%') OR b.code LIKE CONCAT('%', #{csEventUserQueryPage.searchValue}, '%'))
+        </when>
+        <otherwise>
+          d.name LIKE CONCAT('%', #{csEventUserQueryPage.searchValue}, '%')
+        </otherwise>
+      </choose>
+      <!-- OR tag匹配：当epdTagList不为空时，加入tag IN条件 -->
+      <if test="csEventUserQueryPage.epdTagList != null and csEventUserQueryPage.epdTagList.size() > 0">
+        OR b.tag IN
+        <foreach collection="csEventUserQueryPage.epdTagList" item="tagItem" open="(" separator="," close=")">
+          #{tagItem}
+        </foreach>
      </if>
+      )
    </if>
    <if test="csEventUserQueryPage!=null and csEventUserQueryPage.fileFlag != null">
      <if test="csEventUserQueryPage!=null and csEventUserQueryPage.fileFlag == 0 ">
@@ -255,6 +267,12 @@
    <foreach collection="devIds" index="index" item="item" open="(" separator="," close=")">
      #{item}
    </foreach>
+    <if test="lineIds != null and lineIds.size() > 0">
+      AND b.line_id IN
+      <foreach collection="lineIds" item="item" open="(" separator="," close=")">
+        #{item}
+      </foreach>
+    </if>
    <if test="csEventUserQueryPage!=null and csEventUserQueryPage.type != null and csEventUserQueryPage.type !=''">
      <if test="csEventUserQueryPage!=null and csEventUserQueryPage.type == 3 ">
        AND b.type in (2,3) and b.level in (1,2,3,6,7)
@@ -320,7 +338,8 @@
    </if>
    <if test="csEventUserQueryPage!=null and csEventUserQueryPage.searchValue  != null and csEventUserQueryPage.searchValue !=''">
      <if test="csEventUserQueryPage.type != null and csEventUserQueryPage.type !='' and csEventUserQueryPage.type == 3 ">
-        AND e.name like concat('%',#{csEventUserQueryPage.searchValue},'%')
+--         AND e.name like concat('%',#{csEventUserQueryPage.searchValue},'%')
+        AND (e.name LIKE CONCAT('%', #{csEventUserQueryPage.searchValue}, '%') OR b.code LIKE CONCAT('%', #{csEventUserQueryPage.searchValue}, '%'))
      </if>
      <if test="csEventUserQueryPage.type != null and csEventUserQueryPage.type !='' and csEventUserQueryPage.type != 3 ">
        AND d.name like concat('%',#{csEventUserQueryPage.searchValue},'%')
--- a/cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/service/impl/CsAlarmServiceImpl.java
+++ b/cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/service/impl/CsAlarmServiceImpl.java
@@ -185,9 +185,7 @@ public class CsAlarmServiceImpl extends ServiceImpl<CsAlarmMapper, CsAlarm> impl
            for (int i = 0; i < devIds.length; i++) {
                for (int i1 = 0; i1 < param.getDevList().size(); i1++) {
                    if (Objects.equals(devIds[i], param.getDevList().get(i1))) {
-
                        CsLedgerVO csLedgerVO = ledgerMap.get(devIds[i]);
-
                        AlarmVO.AlarmDetail alarmDetail = new AlarmVO.AlarmDetail();
                        alarmDetail.setEngineeringName(ledgerMap.get(csLedgerVO.getPids().split(",")[1]).getName());
                        alarmDetail.setProjectName(ledgerMap.get(csLedgerVO.getPids().split(",")[2]).getName());
@@ -243,6 +241,36 @@ public class CsAlarmServiceImpl extends ServiceImpl<CsAlarmMapper, CsAlarm> impl
                }
            }
        }
+        //特殊处理，如果完整性和在线率没有告警，需要特殊处理下,模拟数据
+        if (CollectionUtil.isNotEmpty(result)) {
+            result.forEach(item->{
+                if (Objects.isNull(item.getDataDetails())) {
+                    item.setDataDetails(buildDefaultAlarmData(item.getDevName()));
+                }
+            });
+        }
        return result;
    }
+
+    /**
+     * 构建默认的告警数据详情
+     * @param deviceId 设备ID
+     * @return 默认结构的 CsAlarmData
+     */
+    private CsAlarmData buildDefaultAlarmData(String deviceId) {
+        CsAlarmData defaultData = new CsAlarmData();
+        defaultData.setDeviceId(deviceId);
+        // 构建 onlineRate 默认结构
+        CsAlarmData.OnlineRateAlarm onlineRate = new CsAlarmData.OnlineRateAlarm();
+        onlineRate.setValue(0.0);
+        onlineRate.setThreshold(0.0);
+        onlineRate.setIsAbnormal(false);
+        defaultData.setOnlineRate(onlineRate);
+        // 构建 integrity 默认结构
+        CsAlarmData.IntegrityAlarm integrity = new CsAlarmData.IntegrityAlarm();
+        integrity.setThreshold(0.0);
+        integrity.setMonitorPoints(new ArrayList<>());
+        defaultData.setIntegrity(integrity);
+        return defaultData;
+    }
 }
--- a/cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/service/impl/CsEventPOServiceImpl.java
+++ b/cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/service/impl/CsEventPOServiceImpl.java
@@ -479,7 +479,7 @@ public class CsEventPOServiceImpl extends ServiceImpl<CsEventPOMapper, CsEventPO
                influxDbUtils.batchInsert(influxDbUtils.getDbName(), "", InfluxDB.ConsistencyLevel.ALL, TimeUnit.MILLISECONDS, records);
            }
            //同步数据到 r_mp_event_detail
-            insertEvent(uuid, param, time, eventPo.getSeverity());
+            insertEvent(uuid, param, time, eventPo.getSeverity(),eventPo.getSagSource());

            //获取台账信息
            DevDetailDTO devDetailDto = csLedgerFeignclient.queryDevDetail(po.getDeviceId()).getData();
@@ -577,7 +577,7 @@ public class CsEventPOServiceImpl extends ServiceImpl<CsEventPOMapper, CsEventPO
        return result;
    }

-    public void insertEvent(String uuid, CldEventParam param, LocalDateTime time, Double severity) {
+    public void insertEvent(String uuid, CldEventParam param, LocalDateTime time, Double severity, String sagSource) {
        RmpEventDetailPO rmpEventDetailPO = new RmpEventDetailPO();
        rmpEventDetailPO.setEventId(uuid);
        rmpEventDetailPO.setMeasurementPointId(param.getMonitorId());
@@ -590,6 +590,7 @@ public class CsEventPOServiceImpl extends ServiceImpl<CsEventPOMapper, CsEventPO
        rmpEventDetailPO.setDealFlag(0);
        rmpEventDetailPO.setFileFlag(0);
        rmpEventDetailPO.setSeverity(severity);
+        rmpEventDetailPO.setSagsource(sagSource);
        wlRmpEventDetailMapper.insert(rmpEventDetailPO);
    }

--- a/cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/service/impl/CsEventUserPOServiceImpl.java
+++ b/cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/service/impl/CsEventUserPOServiceImpl.java
@@ -4,6 +4,7 @@ import cn.hutool.core.collection.CollUtil;
 import cn.hutool.core.collection.CollectionUtil;
 import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.util.ObjectUtil;
+import cn.hutool.core.util.StrUtil;
 import com.alibaba.csp.sentinel.util.StringUtil;
 import com.alibaba.fastjson.JSONArray;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
@@ -414,11 +415,16 @@ public class CsEventUserPOServiceImpl extends ServiceImpl<CsEventUserPOMapper, C
                cldDevTree = cldDevTree.get(0).getChildren();
            }
            if (ObjectUtil.isNull(csEventUserQueryPage.getDeviceId()) || StringUtils.isEmpty(csEventUserQueryPage.getDeviceId())) {
-                //便携式就1层下边就是设备
-                List<String> portableDevIds = portableDevTree.stream().filter(
-                        temp -> StringUtils.isEmpty(csEventUserQueryPage.getDeviceId()) ||
-                                Objects.equals(temp.getId(), csEventUserQueryPage.getDeviceId())
-                ).map(CsLedgerVO::getId).collect(Collectors.toList());
+                //便携式就1层下边就是设备 这边给便携式设备添加了假的工程和项目，id是写死的
+                List<String> portableDevIds = new ArrayList<>();
+                if (Objects.equals(csEventUserQueryPage.getEngineeringid(),"1")
+                        || Objects.equals(csEventUserQueryPage.getProjectId(),"2")
+                        || (!ObjectUtil.isNull(csEventUserQueryPage.getLineId()) && !StringUtils.isEmpty(csEventUserQueryPage.getLineId()))) {
+                    portableDevIds = portableDevTree.stream().map(CsLedgerVO::getId).filter(
+                            id -> StringUtils.isEmpty(csEventUserQueryPage.getDeviceId()) ||
+                                    Objects.equals(id, csEventUserQueryPage.getDeviceId())
+                    ).collect(Collectors.toList());
+                }
                List<String> governmentDevIds = governmentDevTree.stream().filter(temp->StringUtils.isEmpty(csEventUserQueryPage.getEngineeringid())||
                                Objects.equals(temp.getId(), csEventUserQueryPage.getEngineeringid()))
                        .map(CsLedgerVO::getChildren).flatMap(Collection::stream).filter(
@@ -453,6 +459,9 @@ public class CsEventUserPOServiceImpl extends ServiceImpl<CsEventUserPOMapper, C
            if (CollectionUtils.isEmpty(devIds)){
                return returnpage;
            }
+            if (!ObjectUtil.isNull(csEventUserQueryPage.getLineId()) && !StringUtils.isEmpty(csEventUserQueryPage.getLineId())) {
+                lineIds.add(csEventUserQueryPage.getLineId());
+            }
        }
        //获取tag
        if (Objects.equals(csEventUserQueryPage.getType(), "0")) {
@@ -461,13 +470,24 @@ public class CsEventUserPOServiceImpl extends ServiceImpl<CsEventUserPOMapper, C
                csEventUserQueryPage.setTarget(tag);
            }
        }
+        //获取告警码
+        String searchValue = csEventUserQueryPage.getSearchValue();
+        if (StrUtil.isNotBlank(searchValue)) {
+            List<EleEpdPqd> epdList = epdFeignClient.findListByCode(searchValue).getData();
+            if (CollUtil.isNotEmpty(epdList)) {
+                List<String> epdTagList = epdList.stream()
+                        .map(EleEpdPqd::getName)
+                        .collect(Collectors.toList());
+                csEventUserQueryPage.setEpdTagList(epdTagList);
+            }
+        }
        //获取监测点电压等级
        List<CsLineDTO> list = csLineFeignClient.getAllLineDetail().getData();
        Map<String, CsLineDTO> map = list.stream().collect(Collectors.toMap(CsLineDTO::getLineId, temp -> temp));
        if (!Objects.isNull(csEventUserQueryPage.getIsDvr()) && csEventUserQueryPage.getIsDvr() == 1) {
            returnpage  = this.getBaseMapper().queryEventPageWebDvr(returnpage,csEventUserQueryPage,lineIds);
        } else {
-            returnpage  = this.getBaseMapper().queryEventPageWeb(returnpage,csEventUserQueryPage,devIds);
+            returnpage  = this.getBaseMapper().queryEventPageWeb(returnpage,csEventUserQueryPage,devIds,lineIds);
        }
        returnpage.getRecords().forEach(temp->{
            CsLineDTO dto = map.get(temp.getLineId());
@@ -559,65 +579,172 @@ public class CsEventUserPOServiceImpl extends ServiceImpl<CsEventUserPOMapper, C
    @Override
    public Page<FrontWarnVo> getFrontWarnInfo(CldWarnParam baseParam) {
        Page<FrontWarnVo> result = new Page<>(baseParam.getPageNum(), baseParam.getPageSize());
-        Page<CsEventPO> page = new Page<>(baseParam.getPageNum(), baseParam.getPageSize());
-        List<Node> nodeList = nodeFeignClient.nodeAllList().getData();
-        Map<String, Node> nodeMap = new HashMap<>();

-        if (CollectionUtil.isNotEmpty(nodeList)) {
-            nodeMap = nodeList.stream().collect(Collectors.toMap(Node::getId, Function.identity()));
-            if (ObjectUtil.isNotNull(baseParam.getSearchValue()) || StringUtil.isNotBlank(baseParam.getSearchValue())) {
-                nodeList = nodeList.stream().filter(item-> item.getName().contains(baseParam.getSearchValue()) || item.getIp().contains(baseParam.getSearchValue())).collect(Collectors.toList());
+        // 1. 获取全量节点并构建映射（始终保留全量map用于后续VO转换）
+        List<Node> nodeList = nodeFeignClient.nodeAllList().getData();
+        if (CollectionUtil.isEmpty(nodeList)) {
+            return result;
        }
-            if (CollectionUtil.isNotEmpty(nodeList)) {
-                List<String> nodeIds = nodeList.stream().map(Node::getId).collect(Collectors.toList());
+        Map<String, Node> nodeMap = nodeList.stream()
+                .collect(Collectors.toMap(Node::getId, Function.identity(), (a, b) -> a));
+
+        // 2. 提取搜索关键词，避免重复调用getter
+        String searchValue = baseParam.getSearchValue();
+        boolean hasSearchValue = StrUtil.isNotBlank(searchValue);
+        // 3. 根据搜索词筛选出"名称/IP匹配"的节点ID（仅作为OR条件的一部分）
+        List<String> matchedNodeIds;
+        if (hasSearchValue) {
+            matchedNodeIds = nodeList.stream()
+                    .filter(item -> item.getName().contains(searchValue)
+
+                            || item.getIp().contains(searchValue))
+                    .map(Node::getId)
+                    .collect(Collectors.toList());
+        } else {
+            matchedNodeIds = Collections.emptyList();
+        }
+        // 4. 全量节点ID（用于限定查询总范围，防止code LIKE查到无关设备）
+        List<String> allNodeIds = nodeList.stream()
+                .map(Node::getId)
+                .collect(Collectors.toList());
+
+        // 5. 构建查询条件
        LambdaQueryWrapper<CsEventPO> queryWrapper = new LambdaQueryWrapper<>();
-                queryWrapper.in(CsEventPO::getDeviceId, nodeIds)
-                        .between(CsEventPO::getStartTime,
+        // 搜索条件下 deviceId 与 code 改为 OR 关系
+        if (hasSearchValue) {
+            if (CollectionUtil.isNotEmpty(matchedNodeIds)) {
+                // 有匹配节点：(deviceId IN 匹配节点 OR code LIKE) AND deviceId IN 全部节点
+                queryWrapper.in(CsEventPO::getDeviceId, allNodeIds)
+                        .and(w -> w
+                                .in(CsEventPO::getDeviceId, matchedNodeIds)
+                                .or()
+                                .like(CsEventPO::getCode, searchValue)
+                        );
+            } else {
+                // 无匹配节点：仅靠 code LIKE，但仍限定在全部节点范围内
+                queryWrapper.in(CsEventPO::getDeviceId, allNodeIds)
+                        .and(w -> w.like(CsEventPO::getCode, searchValue));
+            }
+        } else {
+            // 无搜索词：正常按全部节点查询
+            queryWrapper.in(CsEventPO::getDeviceId, allNodeIds);
+        }
+        // 时间范围 & 类型固定条件
+        queryWrapper.between(CsEventPO::getStartTime,
                        DateUtil.beginOfDay(DateUtil.parse(baseParam.getSearchBeginTime())).toString(),
                        DateUtil.endOfDay(DateUtil.parse(baseParam.getSearchEndTime())).toString())
                .eq(CsEventPO::getType, 4)
                .orderByDesc(CsEventPO::getStartTime);
-                if (ObjectUtil.isNotNull(baseParam.getLevel()) && StringUtil.isNotBlank(baseParam.getLevel())) {
+        // 等级筛选
+        if (StrUtil.isNotBlank(baseParam.getLevel())) {
            List<Integer> levelList = Arrays.stream(baseParam.getLevel().split(","))
                    .map(String::trim)
                    .filter(s -> !s.isEmpty())
                    .map(Integer::parseInt)
                    .collect(Collectors.toList());
+            if (CollectionUtil.isNotEmpty(levelList)) {
                queryWrapper.in(CsEventPO::getLevel, levelList);
            }
-                page = csEventPOMapper.selectPage(page, queryWrapper);
-            }
        }
+
+        // 6. 执行分页查询
+        Page<CsEventPO> page = csEventPOMapper.selectPage(
+                new Page<>(baseParam.getPageNum(), baseParam.getPageSize()), queryWrapper);
+        // 7. 结果转换
        List<CsEventPO> records = page.getRecords();
-        if (CollUtil.isNotEmpty(records)) {
-            List<FrontWarnVo> frontWarnVos = new ArrayList<>();
-            Map<String, Node> finalNodeMap = nodeMap;
-            page.getRecords().forEach(item->{
+        if (CollUtil.isEmpty(records)) {
+            return result;
+        }
+        List<FrontWarnVo> frontWarnVos = records.stream().map(item -> {
            FrontWarnVo vo = new FrontWarnVo();
-                //这边将前置名称放进lineId字段；将前置IP放进wavePath字段；进程号使用clDid
-                Node node = finalNodeMap.get(item.getDeviceId());
-                item.setLineId(Objects.isNull(node) ? null : node.getName());
-                item.setWavePath(Objects.isNull(node) ? null : node.getIp());
-                //事件等级(1:Ⅰ级||ERROR 2:Ⅱ级||WARN 3:Ⅲ级||(DEBUG&&NORMAL))
-                if (item.getLevel() == 4 || item.getLevel() == 5) {
+            // 填充节点信息（使用全量nodeMap，而非过滤后的列表）
+            Node node = nodeMap.get(item.getDeviceId());
+            item.setLineId(node != null ? node.getName() : null);
+            item.setWavePath(node != null ? node.getIp() : null);
+            // 事件等级映射: 4,5→3(DEBUG/NORMAL) | 6→2(WARN) | 7→1(ERROR)
+            Integer level = item.getLevel();
+            if (level == 4 || level == 5) {
                item.setLevel(3);
-                } else if (item.getLevel() == 6) {
+            } else if (level == 6) {
                item.setLevel(2);
-                } else if (item.getLevel() == 7) {
+            } else if (level == 7) {
                item.setLevel(1);
            }
            BeanUtils.copyProperties(item, vo);
-                frontWarnVos.add(vo);
-            });
+            return vo;
+        }).collect(Collectors.toList());
+
        result.setRecords(frontWarnVos);
        result.setTotal(page.getTotal());
        result.setPages(page.getPages());
        result.setCurrent(page.getCurrent());
        result.setSize(page.getSize());
-        }
        return result;
    }

+//    @Override
+//    public Page<FrontWarnVo> getFrontWarnInfo(CldWarnParam baseParam) {
+//        Page<FrontWarnVo> result = new Page<>(baseParam.getPageNum(), baseParam.getPageSize());
+//        Page<CsEventPO> page = new Page<>(baseParam.getPageNum(), baseParam.getPageSize());
+//        List<Node> nodeList = nodeFeignClient.nodeAllList().getData();
+//        Map<String, Node> nodeMap = new HashMap<>();
+//
+//        if (CollectionUtil.isNotEmpty(nodeList)) {
+//            nodeMap = nodeList.stream().collect(Collectors.toMap(Node::getId, Function.identity()));
+//            if (ObjectUtil.isNotNull(baseParam.getSearchValue()) || StringUtil.isNotBlank(baseParam.getSearchValue())) {
+//                nodeList = nodeList.stream().filter(item-> item.getName().contains(baseParam.getSearchValue()) || item.getIp().contains(baseParam.getSearchValue())).collect(Collectors.toList());
+//            }
+//            if (CollectionUtil.isNotEmpty(nodeList)) {
+//                List<String> nodeIds = nodeList.stream().map(Node::getId).collect(Collectors.toList());
+//                LambdaQueryWrapper<CsEventPO> queryWrapper = new LambdaQueryWrapper<>();
+//                queryWrapper.in(CsEventPO::getDeviceId, nodeIds)
+//                        .between(CsEventPO::getStartTime,
+//                                DateUtil.beginOfDay(DateUtil.parse(baseParam.getSearchBeginTime())).toString(),
+//                                DateUtil.endOfDay(DateUtil.parse(baseParam.getSearchEndTime())).toString())
+//                        .eq(CsEventPO::getType, 4)
+//                        .like(StrUtil.isNotBlank(baseParam.getSearchValue()), CsEventPO::getCode, baseParam.getSearchValue())
+//                        .orderByDesc(CsEventPO::getStartTime);
+//                if (ObjectUtil.isNotNull(baseParam.getLevel()) && StringUtil.isNotBlank(baseParam.getLevel())) {
+//                    List<Integer> levelList = Arrays.stream(baseParam.getLevel().split(","))
+//                            .map(String::trim)
+//                            .filter(s -> !s.isEmpty())
+//                            .map(Integer::parseInt)
+//                            .collect(Collectors.toList());
+//                    queryWrapper.in(CsEventPO::getLevel, levelList);
+//                }
+//                page = csEventPOMapper.selectPage(page, queryWrapper);
+//            }
+//        }
+//        List<CsEventPO> records = page.getRecords();
+//        if (CollUtil.isNotEmpty(records)) {
+//            List<FrontWarnVo> frontWarnVos = new ArrayList<>();
+//            Map<String, Node> finalNodeMap = nodeMap;
+//            page.getRecords().forEach(item->{
+//                FrontWarnVo vo = new FrontWarnVo();
+//                //这边将前置名称放进lineId字段；将前置IP放进wavePath字段；进程号使用clDid
+//                Node node = finalNodeMap.get(item.getDeviceId());
+//                item.setLineId(Objects.isNull(node) ? null : node.getName());
+//                item.setWavePath(Objects.isNull(node) ? null : node.getIp());
+//                //事件等级(1:Ⅰ级||ERROR 2:Ⅱ级||WARN 3:Ⅲ级||(DEBUG&&NORMAL))
+//                if (item.getLevel() == 4 || item.getLevel() == 5) {
+//                    item.setLevel(3);
+//                } else if (item.getLevel() == 6) {
+//                    item.setLevel(2);
+//                } else if (item.getLevel() == 7) {
+//                    item.setLevel(1);
+//                }
+//                BeanUtils.copyProperties(item, vo);
+//                frontWarnVos.add(vo);
+//            });
+//            result.setRecords(frontWarnVos);
+//            result.setTotal(page.getTotal());
+//            result.setPages(page.getPages());
+//            result.setCurrent(page.getCurrent());
+//            result.setSize(page.getSize());
+//        }
+//        return result;
+//    }
+
    @Override
    public List<CsEventUserPO> queryEventListByUserId(String userIndex, List<String> eventList) {
        LambdaQueryWrapper<CsEventUserPO> queryWrapper = new LambdaQueryWrapper<>();
--- a/cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/service/impl/DataServiceImpl.java
+++ b/cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/service/impl/DataServiceImpl.java
@@ -1757,7 +1757,7 @@ public class DataServiceImpl implements IDataService {
        if (CollUtil.isNotEmpty(result)) {
            result.sort(Comparator.comparing(AppLineDetailVo::getProjectName)
                    .thenComparing(AppLineDetailVo::getDeviceName)
-                    .thenComparing(AppLineDetailVo::getPointId));
+                    .thenComparing(AppLineDetailVo::getPointName));
        }
        return result;
    }
@@ -2042,7 +2042,7 @@ public class DataServiceImpl implements IDataService {
                children2.sort(Comparator.comparingInt(AppLineDetailVo.targetDetail::getSort));
                children2.forEach(item2->{
                    if (Objects.isNull(item2.getData())) {
-                        item2.setData(3.15159);
+                        item2.setData(3.14159);
                    }
                    if (!Objects.equals(item2.getData(),NULL_DATA)) {
                        item2.setData(BigDecimal.valueOf(item2.getData()).setScale(2, RoundingMode.HALF_UP).doubleValue());
--- a/cs-system/cs-system-boot/src/main/java/com/njcn/cssystem/service/impl/DataTaskServiceImpl.java
+++ b/cs-system/cs-system-boot/src/main/java/com/njcn/cssystem/service/impl/DataTaskServiceImpl.java
@@ -501,7 +501,7 @@ public class DataTaskServiceImpl implements IDataTaskService {
                        NoticeUserDto.Payload payload = new NoticeUserDto.Payload();
                        noticeUserDto.setPushClientId(harmonicDevCodes);
                        noticeUserDto.setTitle("稳态事件");
-                        noticeUserDto.setContent(time + "发生稳态事件"+harmonicList.size()+"次，点击查看详情");
+                        noticeUserDto.setContent(time + "发生稳态事件，点击查看详情");
                        payload.setType(1);
                        payload.setPath("/pages/index/message1?type="+payload.getType());
                        noticeUserDto.setPayload(payload);
@@ -512,7 +512,7 @@ public class DataTaskServiceImpl implements IDataTaskService {
                        NoticeUserDto.Payload payload = new NoticeUserDto.Payload();
                        noticeUserDto.setPushClientId(alarmDevCodes);
                        noticeUserDto.setTitle("告警事件");
-                        noticeUserDto.setContent(time + "发生告警事件"+alarmList.size()+"次，点击查看详情");
+                        noticeUserDto.setContent(time + "发生告警事件，点击查看详情");
                        payload.setType(2);
                        payload.setPath("/pages/index/message1?type="+payload.getType());
                        noticeUserDto.setPayload(payload);
@@ -571,7 +571,7 @@ public class DataTaskServiceImpl implements IDataTaskService {
                                NoticeUserDto.Payload payload = new NoticeUserDto.Payload();
                                noticeUserDto.setPushClientId(Collections.singletonList(item.getDevCode()));
                                noticeUserDto.setTitle("稳态事件");
-                                noticeUserDto.setContent(time + "发生稳态事件"+harmonicData.size()+"次，点击查看详情");
+                                noticeUserDto.setContent(time + "发生稳态事件，点击查看详情");
                                payload.setType(1);
                                payload.setPath("/pages/index/message1?type="+payload.getType());
                                noticeUserDto.setPayload(payload);
@@ -579,7 +579,7 @@ public class DataTaskServiceImpl implements IDataTaskService {
                            }
                        });
                    }
-                    //普通用户不为空，推送暂态消息
+                    //普通用户不为空，推送告警消息
                    if (CollectionUtil.isNotEmpty(alarmUser) && CollectionUtil.isNotEmpty(alarmList)) {
                        alarmUser.forEach(item->{
                            //根据用户获取设备
@@ -592,7 +592,7 @@ public class DataTaskServiceImpl implements IDataTaskService {
                                NoticeUserDto.Payload payload = new NoticeUserDto.Payload();
                                noticeUserDto.setPushClientId(Collections.singletonList(item.getDevCode()));
                                noticeUserDto.setTitle("告警事件");
-                                noticeUserDto.setContent(time + "发生告警事件"+alarmList.size()+"次，点击查看详情");
+                                noticeUserDto.setContent(time + "发生告警事件，点击查看详情");
                                payload.setType(2);
                                payload.setPath("/pages/index/message1?type="+payload.getType());
                                noticeUserDto.setPayload(payload);
Author	SHA1	Message	Date
xy	08d83c8c1e	feat(service): 添加设备版本信息中的通讯协议和nDid字段 - 在DevVersionVO中新增accessMethod和nDid属性 - 在CsEquipmentDeliveryServiceImpl中设置设备访问方法和nDid值 - 移除控制器中的多余空行以优化代码格式	2026-07-17 15:38:33 +08:00
xy	dbfd6e2b52	feat(ed-data): 新增ED数据管理和设备版本功能 - 重命名crcInfo字段为crc - 添加findByCondition和addEdDataFirst接口方法 - 在CsEdDataController中实现新接口 - 在CsEdDataFeignClient中添加对应feign接口 - 实现CsEdDataQueryParm参数类并添加相关字段 - 扩展CsEdDataService服务接口 - 实现CsEdDataServiceImpl中的业务逻辑 - 修改CsEquipmentDeliveryServiceImpl增强设备管理功能 - 更新CsEquipmentDeliveryVO添加前置进程号字段 - 优化CsUpgradeLogs数据结构和相关接口 - 重构DataTaskServiceImpl中的通知消息内容 - 调整DevVersionVO中的版本日期格式和添加crc字段	2026-07-17 13:43:07 +08:00
xy	a07a0fe6ed	fix(search): 优化事件用户查询功能 - 修改CsEventUserPOMapper.xml中的搜索条件，同时支持名称和代码字段的模糊匹配 - 修复CsEventUserPOServiceImpl中线路ID判断逻辑，避免空字符串和null值导致的异常 - 调整MqttMessageHandler中消息发送的缩进格式，确保代码风格一致	2026-07-14 11:10:46 +08:00
xy	4e7a10f46e	feat(device): 更新设备台账和事件查询功能 - 添加AppProjectService依赖以获取项目信息 - 修改项目数量获取逻辑，直接从接口获取项目信息而非设备关联数 - 在事件查询接口中添加线路ID参数支持 - 更新XML映射文件，添加线路ID过滤条件 - 修复便携式设备树结构中的固定ID分配 - 更新便携式工程和项目的固定ID为"1"和"2" - 优化事件查询服务中的设备和线路ID处理逻辑	2026-07-13 16:35:48 +08:00
xy	b265e95bdf	fix(alarm): 修复告警数据显示问题 - 移除多余的代码行和空行 - 添加完整性检测和在线率告警的默认数据构建逻辑 - 实现buildDefaultAlarmData方法为缺失数据提供默认结构 - 确保告警详情显示的完整性和一致性	2026-07-08 10:05:16 +08:00
xy	f185fa4706	feat(event): 添加电能质量事件源信息存储和查询功能 - 在事件详情表中新增 SagSource 字段存储 - 修改 insertEvent 方法增加 sagSource 参数传递 - 优化事件用户查询页面的搜索逻辑，支持按告警码查询 - 更新 XML 映射文件中的搜索条件构建方式 - 添加对电能质量参数 EPD 列表的查询支持 - 修复数据服务中排序字段错误问题 - 补充便携式离线日志处理中的源信息同步	2026-07-07 20:29:05 +08:00