修改bug

pqs-advance/advance-api/src/main/java/com/njcn/advance/utils/CheckStringUtil.java

@@ -0,0 +1,25 @@
+package com.njcn.advance.utils;
+
+import cn.hutool.core.codec.Base64;
+import com.njcn.common.pojo.constant.PatternRegex;
+import com.njcn.common.pojo.exception.BusinessException;
+import com.njcn.web.constant.ValidMessage;
+
+import java.util.regex.Pattern;
+
+/**
+ * Description:
+ * Date: 2024/12/10  14:51【需求编号】
+ *
+ * @author clam
+ * @version V1.0.0
+ */
+public  class CheckStringUtil {
+    public static void checkName(String name) {
+        Pattern pattern = Pattern.compile(PatternRegex.SPECIAL_REGEX);
+        if(pattern.matcher(name).find()){
+            throw new BusinessException(ValidMessage.NAME_SPECIAL_REGEX);
+        }
+    }
+
+}

pqs-advance/advance-boot/src/main/java/com/njcn/advance/service/carrycapacity/impl/CarryCapacityDevicePOServiceImpl.java

@@ -6,6 +6,7 @@ import com.njcn.advance.mapper.carrycapacity.CarryCapacityDevicePOMapper;
 import com.njcn.advance.pojo.carrycapacity.param.CarryCapacityDeviceParam;
 import com.njcn.advance.pojo.carrycapacity.po.CarryCapacityDevicePO;
 import com.njcn.advance.service.carrycapacity.CarryCapacityDevicePOService;
+import com.njcn.advance.utils.CheckStringUtil;
 import com.njcn.common.pojo.exception.BusinessException;
 import org.apache.commons.lang.StringUtils;
 import org.springframework.beans.BeanUtils;
@@ -32,6 +33,7 @@ public class CarryCapacityDevicePOServiceImpl extends ServiceImpl<CarryCapacityD
         checkName(deviceParam,true);
         return this.lambdaUpdate().eq(CarryCapacityDevicePO::getDevId, deviceParam.getDevId())
                 .set(CarryCapacityDevicePO::getDevName, deviceParam.getDevName())
+                .set(CarryCapacityDevicePO::getDevScale, deviceParam.getDevScale())
                 .set(CarryCapacityDevicePO::getProtocolCapacity, deviceParam.getProtocolCapacity())
                 .update();
     }
@@ -55,6 +57,9 @@ public class CarryCapacityDevicePOServiceImpl extends ServiceImpl<CarryCapacityD
      * @return 结果
      */
     private void checkName(CarryCapacityDeviceParam carryCapacityDeviceParam, boolean isUpdate) {
+
+        CheckStringUtil.checkName(carryCapacityDeviceParam.getDevName());
+
         LambdaQueryWrapper<CarryCapacityDevicePO> lambdaQueryWrapper = new LambdaQueryWrapper<>();
         //条件组合：where state = 1 and name = ?
         lambdaQueryWrapper.eq(CarryCapacityDevicePO::getUserId,carryCapacityDeviceParam.getUserId()).eq(CarryCapacityDevicePO::getDevName, carryCapacityDeviceParam.getDevName());

pqs-advance/advance-boot/src/main/java/com/njcn/advance/service/carrycapacity/impl/CarryCapacityStrategyDhlPOServiceImpl.java

@@ -5,6 +5,7 @@ import com.njcn.advance.mapper.carrycapacity.CarryCapacityStrategyDhlPOMapper;
 import com.njcn.advance.pojo.carrycapacity.po.CarryCapacityStrategyDhlPO;
 import com.njcn.advance.pojo.carrycapacity.vo.CarryCapacityStrategyDhlVO;
 import com.njcn.advance.service.carrycapacity.CarryCapacityStrategyDhlPOService;
+import com.njcn.advance.utils.CheckStringUtil;
 import org.springframework.beans.BeanUtils;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;

pqs-advance/advance-boot/src/main/java/com/njcn/advance/service/carrycapacity/impl/CarryCapacityStrategyPOServiceImpl.java

@@ -11,6 +11,7 @@ import com.njcn.advance.pojo.carrycapacity.po.CarryCapacityStrategyDhlPO;
 import com.njcn.advance.pojo.carrycapacity.po.CarryCapacityStrategyPO;
 import com.njcn.advance.pojo.carrycapacity.vo.CarryCapacityStrategyVO;
 import com.njcn.advance.service.carrycapacity.CarryCapacityStrategyPOService;
+import com.njcn.advance.utils.CheckStringUtil;
 import com.njcn.common.pojo.exception.BusinessException;
 import lombok.RequiredArgsConstructor;
 import org.springframework.beans.BeanUtils;
@@ -38,6 +39,7 @@ public class CarryCapacityStrategyPOServiceImpl extends ServiceImpl<CarryCapacit
     @Override
     @Transactional(rollbackFor = {Exception.class})
     public Boolean add(CarryCapacityStrategyParam carryCapacityStrategyParam) {
+
         CarryCapacityStrategyPO carryCapacityStrategy = new CarryCapacityStrategyPO();
         BeanUtils.copyProperties(carryCapacityStrategyParam, carryCapacityStrategy);
         //将原始策略处理为不启用

pqs-advance/advance-boot/src/main/java/com/njcn/advance/service/carrycapacity/impl/CarryCapacityUserPOServiceImpl.java

@@ -11,7 +11,9 @@ import com.njcn.advance.mapper.carrycapacity.CarryCapacityUserPOMapper;
 import com.njcn.advance.pojo.carrycapacity.param.CarryCapacityUserParam;
 import com.njcn.advance.pojo.carrycapacity.po.CarryCapacityUserPO;
 import com.njcn.advance.service.carrycapacity.CarryCapacityUserPOService;
+import com.njcn.advance.utils.CheckStringUtil;
 import com.njcn.common.pojo.constant.LogInfo;
+import com.njcn.common.pojo.constant.PatternRegex;
 import com.njcn.common.pojo.enums.common.DataStateEnum;
 import com.njcn.common.pojo.exception.BusinessException;
 import com.njcn.harmonic.enums.HarmonicResponseEnum;
@@ -19,6 +21,7 @@ import com.njcn.harmonic.pojo.param.ReportTemplateParam;
 import com.njcn.harmonic.pojo.po.ExcelRptTemp;
 import com.njcn.user.api.UserFeignClient;
 import com.njcn.user.pojo.vo.UserVO;
+import com.njcn.web.constant.ValidMessage;
 import lombok.RequiredArgsConstructor;
 import org.apache.commons.lang.StringUtils;
 import org.springframework.beans.BeanUtils;
@@ -26,6 +29,7 @@ import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
 import java.util.Objects;
+import java.util.regex.Pattern;
 
 /**
  * 
@@ -57,6 +61,8 @@ public class CarryCapacityUserPOServiceImpl extends ServiceImpl<CarryCapacityUse
      * @return 结果
      */
     private void checkName(CarryCapacityUserParam carryCapacityUserParam, boolean isUpdate) {
+
+        CheckStringUtil.checkName(carryCapacityUserParam.getUserName());
         LambdaQueryWrapper<CarryCapacityUserPO> lambdaQueryWrapper = new LambdaQueryWrapper<>();
         //条件组合：where state = 1 and name = ?
         lambdaQueryWrapper.eq(CarryCapacityUserPO::getStatus, DataStateEnum.ENABLE.getCode()).eq(CarryCapacityUserPO::getUserName, carryCapacityUserParam.getUserName());

pqs-common/common-web/src/main/java/com/njcn/web/constant/ValidMessage.java

@@ -70,6 +70,8 @@ public interface ValidMessage {
     String SEARCH_DATA_ERROR = "搜索值过长,请检查搜索参数";
     String SPECIAL_REGEX = "搜索值包含特殊字符";
 
+    String NAME_SPECIAL_REGEX = "包含特殊字符";
+
     String DATA_TOO_LONG = "参数过长,请检查参数";
 
 }

pqs-common/common-web/src/main/java/com/njcn/web/utils/RestTemplateUtil.java

@@ -632,5 +632,42 @@ public class RestTemplateUtil {
         return restTemplate;
     }
 
+    public static void main(String[] args) {
+
+
+            String s1 = "runoob";
+            String s2 = "runoob";
+            System.out.println(s1 == s2);
+
+        String body ="[\n" +
+                "  {\n" +
+                "    \"monitorId\": [\n" +
+                "      \"id1\",\n" +
+                "      \"id2\",\n" +
+                "      \"id3\"\n" +
+                "    ],\n" +
+                "    \"dataType\": \"1\",\n" +
+                "    \"timeInterval\": [\n" +
+                "      \"2024-01-01 12:52:51~2024-01-01 13:53:00\",\n" +
+                "      \"2024-01-02 12:52:51~2024-01-02 13:53:00\",\n" +
+                "      \"2024-01-03 12:52:51~2024-01-03 13:53:00\",\n" +
+                "      \"2024-01-04 12:52:51~2024-01-04 13:53:00\"\n" +
+                "    ]\n" +
+                "  },\n" +
+                "  {\n" +
+                "    \"monitorId\": [\n" +
+                "      \"id4\"\n" +
+                "    ],\n" +
+                "    \"dataType\": \"0\",\n" +
+                "    \"timeInterval\": [\n" +
+                "      \"2024-01-01 12:40:00~2024-01-01 23:59:59\"\n" +
+                "    ]\n" +
+                "  }\n" +
+                "]";
+        ResponseEntity<Object> post = RestTemplateUtil.post("http://192.168.1.105:10004/powerQuality/recall", body, Object.class);
+        System.out.println(post);
+
+    }
+
 
 }