mq异步关键词功能类型 信息中心，美业资料，供应商主页搜索

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

@@ -45,8 +45,8 @@ public class IpSaveListener implements RocketMQListener<String> {
         String param = params[2];
         String saveName = params[3];
         IpSavePo ipSavePo = new IpSavePo();
-//        SearchFrequencyVo searchFrequencyVo=new SearchFrequencyVo();
-//        searchFrequencyVo.setPath(path);
+        SearchFrequencyVo searchFrequencyVo=new SearchFrequencyVo();
+        searchFrequencyVo.setPath(path);
         if (StringUtils.isNotBlank(param)) {
             ipSavePo.setParams(param);
             if (param.contains("userId") || param.contains("keyword")) {
@@ -73,7 +73,7 @@ public class IpSaveListener implements RocketMQListener<String> {
                                     va = java.net.URLDecoder.decode(va, "UTF-8");
                                 }
                                 ipSavePo.setKeyWord(va);
-//                                searchFrequencyVo.setKeyword(va);
+                                searchFrequencyVo.setKeyword(va);
                             } catch (UnsupportedEncodingException e) {
                                 e.printStackTrace();
                             }
@@ -95,35 +95,35 @@ public class IpSaveListener implements RocketMQListener<String> {
         String nowDate = format.format(new Date());
         Long aLong = Long.valueOf(nowDate);
         ipSavePo.setSaveTime(aLong);
-//        //根据来源统计关键词
-//        //首页搜索  fromSearch = 1
-//        if(null !=searchFrequencyVo &&"/commodity/search/query/product".equals(searchFrequencyVo.getPath())){
-//            searchFrequencyVo.setFromSearch(1);
-//            if(StringUtils.isNotBlank(searchFrequencyVo.getKeyword())){
-//                productService.conKeyword(searchFrequencyVo.getFromSearch(),searchFrequencyVo.getPath(),searchFrequencyVo.getKeyword());
-//            }
-//        }
-//        //信息中心搜索  fromSearch = 2
-//        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());
-//            }
-//        }
-//        //美业资料搜索 fromSearch=3
-//        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());
-//            }
-//        }
-//        //供应商主页搜索 fromSearch=4
-//        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());
-//            }
-//        }
+        //根据来源统计关键词
+        //首页搜索  fromSearch = 1
+        if(null !=searchFrequencyVo &&"/commodity/search/query/product".equals(searchFrequencyVo.getPath())){
+            searchFrequencyVo.setFromSearch(1);
+            if(StringUtils.isNotBlank(searchFrequencyVo.getKeyword())){
+                productService.conKeyword(searchFrequencyVo.getFromSearch(),searchFrequencyVo.getPath(),searchFrequencyVo.getKeyword());
+            }
+        }
+        //信息中心搜索  fromSearch = 2
+        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());
+            }
+        }
+        //美业资料搜索 fromSearch=3
+        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());
+            }
+        }
+        //供应商主页搜索 fromSearch=4
+        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());
+            }
+        }
         ipSaveService.save(ipSavePo);
     }
 }

src/main/java/com/caimei365/tools/mapper/BaseMapper.java

@@ -86,9 +86,9 @@ public interface BaseMapper {
     void insertProductViews(Integer productId, Integer views, Date viewTime);
 
 
-//    List<SearchFrequencyVo>  getInfoBykeyword(String keyword, Integer fromSearch);
-//
-//    void saveInfo(SearchFrequencyVo searchFrequencyVo);
-//
-//    void upFrequencyById(Integer id,Integer frequency);
+    List<SearchFrequencyVo>  getInfoBykeyword(String keyword, Integer fromSearch);
+
+    void saveInfo(SearchFrequencyVo searchFrequencyVo);
+
+    void upFrequencyById(Integer id,Integer frequency);
 }

src/main/java/com/caimei365/tools/service/ProductService.java

@@ -9,5 +9,5 @@ import org.springframework.stereotype.Service;
  * @date : 2021/10/26
  */
 public interface ProductService {
-//     void conKeyword(Integer fromType,String path,String keyword);
+     void conKeyword(Integer fromType,String path,String keyword);
     }

src/main/java/com/caimei365/tools/service/impl/ProductServiceImpl.java

@@ -29,29 +29,29 @@ public class ProductServiceImpl implements ProductService {
      * @param keyword
      * @return
      */
-//    @Override
-//    public void conKeyword(Integer fromType,String path,String keyword){
-//        Date date=new Date();
-//        SimpleDateFormat sd=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
-//        sd.format(date);
-////        searchFrequency.setSearchTime(new java.sql.Timestamp(date.getTime()));
-//        Calendar cal = Calendar.getInstance();
-//        cal.setTime(date);
-//        //根据关键词和来源查询数据库是否存在（存在来源也相同时增加次数,存在但来源不同时和不存在则新增）
-//        List<SearchFrequencyVo> searchFrequencyVoList = baseMapper.getInfoBykeyword(keyword,fromType);
-//        if(null!= searchFrequencyVoList && searchFrequencyVoList.size()>0){
-//            //存在 统计次数
-//            Integer frequency= searchFrequencyVoList.get(0).getFrequency()+1;
-//            baseMapper.upFrequencyById(searchFrequencyVoList.get(0).getId(),frequency);
-//        }else{
-//            //不存在 新增
-//            SearchFrequencyVo sea=new SearchFrequencyVo();
-//            sea.setKeyword(keyword);
-//            sea.setFrequency(1);
-//            sea.setPath(path);
-//            sea.setFromSearch(fromType);
-//            sea.setSearchTime(new java.sql.Timestamp(cal.getTime().getTime()));
-//            baseMapper.saveInfo(sea);
-//        }
-//    }
+    @Override
+    public void conKeyword(Integer fromType,String path,String keyword){
+        Date date=new Date();
+        SimpleDateFormat sd=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+        sd.format(date);
+//        searchFrequency.setSearchTime(new java.sql.Timestamp(date.getTime()));
+        Calendar cal = Calendar.getInstance();
+        cal.setTime(date);
+        //根据关键词和来源查询数据库是否存在（存在来源也相同时增加次数,存在但来源不同时和不存在则新增）
+        List<SearchFrequencyVo> searchFrequencyVoList = baseMapper.getInfoBykeyword(keyword,fromType);
+        if(null!= searchFrequencyVoList && searchFrequencyVoList.size()>0){
+            //存在 统计次数
+            Integer frequency= searchFrequencyVoList.get(0).getFrequency()+1;
+            baseMapper.upFrequencyById(searchFrequencyVoList.get(0).getId(),frequency);
+        }else{
+            //不存在 新增
+            SearchFrequencyVo sea=new SearchFrequencyVo();
+            sea.setKeyword(keyword);
+            sea.setFrequency(1);
+            sea.setPath(path);
+            sea.setFromSearch(fromType);
+            sea.setSearchTime(new java.sql.Timestamp(cal.getTime().getTime()));
+            baseMapper.saveInfo(sea);
+        }
+    }
 }

src/main/resources/mapper/BaseMapper.xml

@@ -103,25 +103,25 @@
         SELECT id FROM cm_short_link WHERE shortLink = #{shortLink}
     </select>
 
-<!--    <select id="getInfoBykeyword" resultType="com.caimei365.tools.model.po.SearchFrequencyVo">-->
-<!--        select-->
-<!--            id,-->
-<!--            fromSearch,-->
-<!--            path,-->
-<!--            keyword,-->
-<!--            frequency,-->
-<!--            searchTime,-->
-<!--            trueStatus-->
-<!--        from cm_user_search_frequency-->
-<!--        where keyword=#{keyword}-->
-<!--          and   fromSearch=#{fromSearch}-->
-<!--    </select>-->
-<!--    <update id="upFrequencyById">-->
-<!--        update cm_user_search_frequency set frequency=#{frequency} where id=#{id}-->
-<!--    </update>-->
-<!--    <insert id="saveInfo" parameterType="com.caimei365.tools.model.po.SearchFrequencyVo">-->
-<!--        insert into cm_user_search_frequency(fromSearch,path,keyword,frequency,searchTime)-->
-<!--        values (#{fromSearch},#{path},#{keyword},#{frequency},#{searchTime})-->
+    <select id="getInfoBykeyword" resultType="com.caimei365.tools.model.po.SearchFrequencyVo">
+        select
+            id,
+            fromSearch,
+            path,
+            keyword,
+            frequency,
+            searchTime,
+            trueStatus
+        from cm_user_search_frequency
+        where keyword=#{keyword}
+          and   fromSearch=#{fromSearch}
+    </select>
+    <update id="upFrequencyById">
+        update cm_user_search_frequency set frequency=#{frequency} where id=#{id}
+    </update>
+    <insert id="saveInfo" parameterType="com.caimei365.tools.model.po.SearchFrequencyVo">
+        insert into cm_user_search_frequency(fromSearch,path,keyword,frequency,searchTime)
+        values (#{fromSearch},#{path},#{keyword},#{frequency},#{searchTime})
 
-<!--    </insert>-->
+    </insert>
 </mapper>