bugfix

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

@@ -37,6 +37,7 @@ public class IpSaveListener implements RocketMQListener<String> {
     private ProductService productService;
     @Autowired
     private CmBehaviorRecordService recordService;
+
     @Override
     public void onMessage(String message) {
         log.info("{}收到消息：{}", this.getClass().getSimpleName(), message);
@@ -47,13 +48,12 @@ public class IpSaveListener implements RocketMQListener<String> {
         String param = params[2];
         String saveName = params[3];
         IpSavePo ipSavePo = new IpSavePo();
-        SearchFrequencyVo searchFrequencyVo=new SearchFrequencyVo();
-        String productFlag="";
-        String linkageFlag="";
+        SearchFrequencyVo searchFrequencyVo = new SearchFrequencyVo();
+        String productFlag = "";
+        String linkageFlag = "";
         searchFrequencyVo.setPath(path);
         if (StringUtils.isNotBlank(param)) {
             ipSavePo.setParams(param);
-            log.info("param----"+param);
             if (param.contains("userId") || param.contains("keyword")) {
                 String[] split = param.split("&");
                 for (String s : split) {
@@ -79,7 +79,6 @@ public class IpSaveListener implements RocketMQListener<String> {
                                 }
                                 ipSavePo.setKeyWord(va);
                                 searchFrequencyVo.setKeyword(va);
-                                log.info("keyword----"+va);
                             } catch (UnsupportedEncodingException e) {
                                 e.printStackTrace();
                             }
@@ -96,8 +95,7 @@ public class IpSaveListener implements RocketMQListener<String> {
                                     va = java.net.URLDecoder.decode(va, "UTF-8");
                                 }
                                 ipSavePo.setKeyWord(va);
-                                productFlag=va;
-                                log.info("product----"+va);
+                                productFlag = va;
                             } catch (UnsupportedEncodingException e) {
                                 e.printStackTrace();
                             }
@@ -114,8 +112,7 @@ public class IpSaveListener implements RocketMQListener<String> {
                                     va = java.net.URLDecoder.decode(va, "UTF-8");
                                 }
                                 ipSavePo.setKeyWord(va);
-                                linkageFlag=va;
-                                log.info("lingkage----"+va);
+                                linkageFlag = va;
                             } catch (UnsupportedEncodingException e) {
                                 e.printStackTrace();
                             }
@@ -140,24 +137,24 @@ public class IpSaveListener implements RocketMQListener<String> {
         //根据来源统计关键词
         //首页搜索  fromSearch = 1
         log.info("-------------开始统计------------");
-        if(null !=searchFrequencyVo &&StringUtils.isNotEmpty(productFlag)&&"1".equals(productFlag)&&"/commodity/search/query/product".equals(searchFrequencyVo.getPath())){
+        if (null != searchFrequencyVo && StringUtils.isNotEmpty(productFlag) && "1".equals(productFlag) && "/commodity/search/query/product".equals(searchFrequencyVo.getPath())) {
             searchFrequencyVo.setFromSearch(1);
-            if(StringUtils.isNotBlank(searchFrequencyVo.getKeyword())){
-                productService.conKeyword(searchFrequencyVo.getFromSearch(),searchFrequencyVo.getPath(),searchFrequencyVo.getKeyword(),linkageFlag);
+            if (StringUtils.isNotBlank(searchFrequencyVo.getKeyword())) {
+                productService.conKeyword(searchFrequencyVo.getFromSearch(), searchFrequencyVo.getPath(), searchFrequencyVo.getKeyword(), linkageFlag);
             }
         }
         //信息中心搜索  fromSearch = 2
-        if(null !=searchFrequencyVo &&"/commodity/search/query/article".equals(searchFrequencyVo.getPath())){
+        if (null != searchFrequencyVo && "/commodity/search/query/article".equals(searchFrequencyVo.getPath())) {
             searchFrequencyVo.setFromSearch(2);
-            if(StringUtils.isNotBlank(searchFrequencyVo.getKeyword())){
-                productService.conKeyword(searchFrequencyVo.getFromSearch(),searchFrequencyVo.getPath(),searchFrequencyVo.getKeyword(),linkageFlag);
+            if (StringUtils.isNotBlank(searchFrequencyVo.getKeyword())) {
+                productService.conKeyword(searchFrequencyVo.getFromSearch(), searchFrequencyVo.getPath(), searchFrequencyVo.getKeyword(), linkageFlag);
             }
         }
         //美业资料搜索 fromSearch=3
-        if(null !=searchFrequencyVo &&"/commodity/product/archive".equals(searchFrequencyVo.getPath())){
+        if (null != searchFrequencyVo && "/commodity/product/archive".equals(searchFrequencyVo.getPath())) {
             searchFrequencyVo.setFromSearch(3);
-            if(StringUtils.isNotBlank(searchFrequencyVo.getKeyword())){
-                productService.conKeyword(searchFrequencyVo.getFromSearch(),searchFrequencyVo.getPath(),searchFrequencyVo.getKeyword(),linkageFlag);
+            if (StringUtils.isNotBlank(searchFrequencyVo.getKeyword())) {
+                productService.conKeyword(searchFrequencyVo.getFromSearch(), searchFrequencyVo.getPath(), searchFrequencyVo.getKeyword(), linkageFlag);
             }
         }
 //        //供应商主页搜索 fromSearch=4 （2022.11.15暂时不考虑该关键词信息来源）
@@ -168,10 +165,10 @@ public class IpSaveListener implements RocketMQListener<String> {
 //            }
 //        }
         //采美百科搜索 fromSearch=5
-        if(null !=searchFrequencyVo &&"/commodity/search/query/baike/keyword".equals(searchFrequencyVo.getPath())){
+        if (null != searchFrequencyVo && "/commodity/search/query/baike/keyword".equals(searchFrequencyVo.getPath())) {
             searchFrequencyVo.setFromSearch(4);
-            if(StringUtils.isNotBlank(searchFrequencyVo.getKeyword())){
-                productService.conKeyword(searchFrequencyVo.getFromSearch(),searchFrequencyVo.getPath(),searchFrequencyVo.getKeyword(),linkageFlag);
+            if (StringUtils.isNotBlank(searchFrequencyVo.getKeyword())) {
+                productService.conKeyword(searchFrequencyVo.getFromSearch(), searchFrequencyVo.getPath(), searchFrequencyVo.getKeyword(), linkageFlag);
             }
         }
         // 用户行为记录

src/main/resources/mapper/BaseMapper.xml

@@ -59,7 +59,7 @@
     </select>
 
     <update id="updateProductValidFlag">
-        UPDATE product
+        UPDATE cm_organize_product_info
         SET validFlag = #{validFlag}
         where productID = #{productId}
     </update>