端口监测bugfix

src/main/java/com/caimei365/tools/listener/IpSaveListener.java

@@ -51,7 +51,7 @@ public class IpSaveListener implements RocketMQListener<String> {
         IpSavePo ipSavePo = new IpSavePo();
         if (StringUtils.isNotBlank(param)) {
             ipSavePo.setParams(param);
-            if (param.contains("userId")||param.contains("keyword")) {
+            if (param.contains("userId") || param.contains("keyword")) {
                 String[] split = param.split("&");
                 for (String s : split) {
                     if (s.contains("userId") && s.contains("=")) {
@@ -64,12 +64,15 @@ public class IpSaveListener implements RocketMQListener<String> {
                             }
                         }
                     }
-                    if(s.contains("keyword") && s.contains("=")){
+                    if (s.contains("keyword") && s.contains("=")) {
                         String[] split1 = s.split("=");
-                        if(split1.length > 1){
+                        if (split1.length > 1) {
                             String value = split1[1];
                             try {
                                 String va = java.net.URLDecoder.decode(value, "UTF-8");
+                                if (va.contains("%")) {
+                                    va = java.net.URLDecoder.decode(va, "UTF-8");
+                                }
                                 ipSavePo.setKeyWord(va);
                             } catch (UnsupportedEncodingException e) {
                                 e.printStackTrace();