|
|
@@ -53,6 +53,7 @@ public class IpSaveListener implements RocketMQListener<String> {
|
|
|
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) {
|
|
|
@@ -78,12 +79,13 @@ public class IpSaveListener implements RocketMQListener<String> {
|
|
|
}
|
|
|
ipSavePo.setKeyWord(va);
|
|
|
searchFrequencyVo.setKeyword(va);
|
|
|
+ log.info("keyword----"+va);
|
|
|
} catch (UnsupportedEncodingException e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
- if (s.contains("producFlag") && s.contains("=")) {
|
|
|
+ if (s.contains("productFlag") && s.contains("=")) {
|
|
|
String[] split1 = s.split("=");
|
|
|
if (split1.length > 1) {
|
|
|
String value = split1[1];
|
|
|
@@ -95,6 +97,7 @@ public class IpSaveListener implements RocketMQListener<String> {
|
|
|
}
|
|
|
ipSavePo.setKeyWord(va);
|
|
|
productFlag=va;
|
|
|
+ log.info("product----"+va);
|
|
|
} catch (UnsupportedEncodingException e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
|
@@ -112,6 +115,7 @@ public class IpSaveListener implements RocketMQListener<String> {
|
|
|
}
|
|
|
ipSavePo.setKeyWord(va);
|
|
|
linkageFlag=va;
|
|
|
+ log.info("lingkage----"+va);
|
|
|
} catch (UnsupportedEncodingException e) {
|
|
|
e.printStackTrace();
|
|
|
}
|
|
|
@@ -135,6 +139,7 @@ public class IpSaveListener implements RocketMQListener<String> {
|
|
|
ipSavePo.setSaveTime(aLong);
|
|
|
//根据来源统计关键词
|
|
|
//首页搜索 fromSearch = 1
|
|
|
+ log.info("-------------开始统计------------");
|
|
|
if(null !=searchFrequencyVo &&StringUtils.isNotEmpty(productFlag)&&"1".equals(productFlag)&&"/commodity/search/query/product".equals(searchFrequencyVo.getPath())){
|
|
|
searchFrequencyVo.setFromSearch(1);
|
|
|
if(StringUtils.isNotBlank(searchFrequencyVo.getKeyword())){
|
JiangChongBo