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

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

@@ -95,8 +95,35 @@ public class IpSaveListener implements RocketMQListener<String> {
         String nowDate = format.format(new Date());
         Long aLong = Long.valueOf(nowDate);
         ipSavePo.setSaveTime(aLong);
-        searchFrequencyVo.setFromSearch(1);
+        //根据来源统计关键词
+        //首页搜索  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);
-        productService.conKeyword(searchFrequencyVo.getFromSearch(),searchFrequencyVo.getPath(),searchFrequencyVo.getKeyword());
     }
 }

src/main/java/com/caimei365/tools/model/po/SearchFrequencyVo.java

@@ -2,7 +2,7 @@ package com.caimei365.tools.model.po;
 
 import lombok.Data;
 
-import java.sql.Date;
+import java.sql.Timestamp;
 
 @Data
 public class SearchFrequencyVo {
@@ -26,7 +26,7 @@ public class SearchFrequencyVo {
     /**
      * 搜索时间
      */
-    private Date searchTime ;
+    private Timestamp searchTime ;
     /**
      * 0:未加入关键词库；1：已加入关键词库
      */

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

@@ -7,6 +7,7 @@ import org.springframework.stereotype.Service;
 
 import javax.annotation.Resource;
 import java.text.SimpleDateFormat;
+import java.util.Calendar;
 import java.util.Date;
 import java.util.List;
 
@@ -31,8 +32,11 @@ public class ProductServiceImpl implements ProductService {
     @Override
     public void conKeyword(Integer fromType,String path,String keyword){
         Date date=new Date();
-        SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd");
-        sf.format(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){
@@ -46,7 +50,7 @@ public class ProductServiceImpl implements ProductService {
             sea.setFrequency(1);
             sea.setPath(path);
             sea.setFromSearch(fromType);
-            sea.setSearchTime(new java.sql.Date(date.getTime()));
+            sea.setSearchTime(new java.sql.Timestamp(cal.getTime().getTime()));
             baseMapper.saveInfo(sea);
         }
     }