表iot_device_diagnose_threshold添加thresholdId字段

project_data/sql/1.0.11/soc.sql

@@ -211,6 +211,7 @@ CREATE TABLE `iot_device_diagnose_mission_ch` (
 
 drop table if exists `iot_device_diagnose_threshold`;
 CREATE TABLE `iot_device_diagnose_threshold` (
+  `threshold_id` bigint NOT NULL,
   `threshold_code` varchar(200) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci COMMENT 'MD5生成唯一码',
   `threshold_name` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL COMMENT '阈值名称',
   `nosignal` varchar(100) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci DEFAULT NULL COMMENT '信号丢失',
@@ -228,10 +229,10 @@ CREATE TABLE `iot_device_diagnose_threshold` (
   `begin_time` time DEFAULT NULL COMMENT '有效开始时间',
   `end_time` time DEFAULT NULL COMMENT '有效结束时间',
   `iot_token` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci DEFAULT NULL COMMENT 'iot服务唯一编码',
-  PRIMARY KEY (`threshold_code`) USING BTREE
+  PRIMARY KEY (`threshold_id`) USING BTREE
 ) ENGINE=InnoDB  DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci COMMENT='摄像机诊断阈值表';
 -- 诊断阈值默认
-INSERT INTO `iot_device_diagnose_threshold` VALUES ('0cdd75ea0d73056dbd6727b96339f2f6', '默认', '@value==255', '@value>=250', '@value>=150', '@value>=7', '@value>=255', '@value>=225', '@value>=140', '@value>=253', '@value<=0',  '2024-11-18 17:03:54', '0', '1', '00:00:00', '23:59:59',null);
+INSERT INTO `iot_device_diagnose_threshold` VALUES (1858433123521220610,'0cdd75ea0d73056dbd6727b96339f2f6', '默认', '@value==255', '@value>=250', '@value>=150', '@value>=7', '@value>=255', '@value>=225', '@value>=140', '@value>=253', '@value<=0',  '2024-11-18 17:03:54', '0', '1', '00:00:00', '23:59:59',null);
 
 drop table if exists `iot_device_diagnose_threshold_ch`;
 CREATE TABLE `iot_device_diagnose_threshold_ch` (

soc-common/soc-common-core/src/main/java/com/xunmei/common/core/domain/iot/domain/IotDeviceDiagnoseThreshold.java

@@ -25,8 +25,12 @@ public class IotDeviceDiagnoseThreshold implements Serializable {
 
     private static final long serialVersionUID = 1L;
 
+    @ApiModelProperty(value = "主键id")
+    @TableId("threshold_id")
+    private Long thresholdId;
+
     @ApiModelProperty(value = "MD5生成唯一码")
-    @TableId("threshold_code")
+    @TableField("threshold_code")
     private String thresholdCode;
 
     @ApiModelProperty(value = "阈值名称")

soc-modules/soc-modules-host/src/main/java/com/xunmei/host/iot/service/impl/IotCameraMissionRuleServiceImpl.java

@@ -113,6 +113,7 @@ public class IotCameraMissionRuleServiceImpl implements IotCameraMissionRuleServ
                 if (bean == null) {
                     thresholdMapper.insert(threshold);
                 }else{
+                    threshold.setThresholdId(bean.getThresholdId());
                     thresholdMapper.updateById(threshold);
                 }
 

soc-modules/soc-modules-iot/src/main/java/com/xunmei/iot/service/impl/DiagnoseMissionServiceImpl.java

@@ -207,7 +207,9 @@ public class DiagnoseMissionServiceImpl implements DiagnoseMissionService {
 
     @Override
     public List<IotDeviceDiagnoseMission> selectMissionPage(){
-        return diagnoseMissionChMapper.selectList(Wrappers.emptyWrapper());
+        QueryWrapper<IotDeviceDiagnoseMission> queryWrapper = new QueryWrapper();
+        queryWrapper.orderByAsc("create_time");
+        return diagnoseMissionChMapper.selectList(queryWrapper);
     }
 
     @Override

soc-modules/soc-modules-iot/src/main/java/com/xunmei/iot/service/impl/DiagnoseThresholdServiceImpl.java

@@ -200,13 +200,18 @@ public class DiagnoseThresholdServiceImpl  implements DiagnoseThresholdService {
 
     @Override
     public List<IotDeviceDiagnoseThreshold> selectThresholdPage(){
-        return diagnoseThresholdChMapper.selectList(Wrappers.emptyWrapper());
+        QueryWrapper<IotDeviceDiagnoseThreshold> queryWrapper = new QueryWrapper();
+        queryWrapper.orderByAsc("create_time");
+        return diagnoseThresholdChMapper.selectList(queryWrapper);
     }
 
     @Override
     @Transactional
     public void deleteThreshold(String thresholdCode){
-        IotDeviceDiagnoseThreshold system = diagnoseThresholdChMapper.selectById(thresholdCode);
+        QueryWrapper<IotDeviceDiagnoseThreshold> queryWrapper = new QueryWrapper();
+        queryWrapper.eq("threshold_code",thresholdCode);
+        queryWrapper.last("limit 1");
+        IotDeviceDiagnoseThreshold system = diagnoseThresholdChMapper.selectOne(queryWrapper);
         if (system == null) {
             String errorMsg = "当前阈值不存在!";
             throw  new ServiceException(errorMsg);
@@ -216,7 +221,7 @@ public class DiagnoseThresholdServiceImpl  implements DiagnoseThresholdService {
             throw  new ServiceException(errorMsg);
         }
         //删除阈值
-        diagnoseThresholdChMapper.deleteById(thresholdCode);
+        diagnoseThresholdChMapper.delete(queryWrapper);
         //删除关联视频通道
         diagnoseThresholdChMapper.deleteCamerasByThresholdCode(thresholdCode);
     }
@@ -252,6 +257,7 @@ public class DiagnoseThresholdServiceImpl  implements DiagnoseThresholdService {
         threshold.setBeginTime(request.getTimeRange()[0]);
         threshold.setEndTime(request.getTimeRange()[1]);
 
+        threshold.setThresholdId(IDHelper.id());
         threshold.setThresholdCode(thresholdCode);
         threshold.setCreateTime(DateUtils.getTime());
         threshold.setDiagnoseNumber(0);
@@ -262,19 +268,23 @@ public class DiagnoseThresholdServiceImpl  implements DiagnoseThresholdService {
 
     @Override
     public void editThreshold(DiagnoseThresholdAddVo request){
-        //todo:
+        String nosignal=request.getNosignal().replace("&gt;",">").replace("&lt;","<");
+        String covered=request.getCovered().replace("&gt;",">").replace("&lt;","<");
+        request.setNosignal(nosignal);
+        request.setCovered(covered);
+
         String thresholdCode = DigestUtils.md5DigestAsHex(getThresholdGuid(request).getBytes());
 
         QueryWrapper<IotDeviceDiagnoseThreshold> queryWrapper = new QueryWrapper();
-//        queryWrapper.eq("threshold_code", thresholdCode);
-//        List<IotDeviceDiagnoseThreshold> list = diagnoseThresholdChMapper.selectList(queryWrapper);
-//        if (!list.isEmpty()) {
-//            String errorMsg = "已存在相同参数的阈值配置'" + list.get(0).getThresholdName() + "'!";
-//            throw  new ServiceException(errorMsg);
-//        }
+        queryWrapper.eq("threshold_code", thresholdCode).ne("threshold_id", request.getThresholdId());
+        List<IotDeviceDiagnoseThreshold> list = diagnoseThresholdChMapper.selectList(queryWrapper);
+        if (!list.isEmpty()) {
+            String errorMsg = "已存在相同参数的阈值配置'" + list.get(0).getThresholdName() + "'!";
+            throw  new ServiceException(errorMsg);
+        }
 
         queryWrapper = new QueryWrapper();
-        queryWrapper.eq("threshold_name", request.getThresholdName()).ne("threshold_code", thresholdCode);
+        queryWrapper.eq("threshold_name", request.getThresholdName()).ne("threshold_id", request.getThresholdId());
         long nameCount = diagnoseThresholdChMapper.selectCount(queryWrapper);
         if (nameCount > 0) {
             String errorMsg = "已存在相同名称的阈值配置";