解决ipsaveLiistener冲突

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

@@ -2,6 +2,7 @@ package com.caimei365.tools.listener;
 
 import com.caimei365.tools.model.po.IpSavePo;
 import com.caimei365.tools.model.po.SearchFrequencyVo;
+import com.caimei365.tools.service.CmBehaviorRecordService;
 import com.caimei365.tools.service.ProductService;
 import com.caimei365.tools.service.impl.IpSaveService;
 import lombok.extern.slf4j.Slf4j;
@@ -34,7 +35,8 @@ public class IpSaveListener implements RocketMQListener<String> {
     private IpSaveService ipSaveService;
     @Resource
     private ProductService productService;
-
+    @Autowired
+    private CmBehaviorRecordService recordService;
     @Override
     public void onMessage(String message) {
         log.info("{}收到消息：{}", this.getClass().getSimpleName(), message);
@@ -131,6 +133,10 @@ public class IpSaveListener implements RocketMQListener<String> {
                 productService.conKeyword(searchFrequencyVo.getFromSearch(),searchFrequencyVo.getPath(),searchFrequencyVo.getKeyword());
             }
         }
+        // 用户行为记录
+        if ("/user/record/StatisticsPc".equals(ipSavePo.getRequestUrl().trim()) || "/user/record/StatisticsApp".equals(ipSavePo.getRequestUrl().trim())) {
+            recordService.insertRecord(ipSavePo);
+        }
         ipSaveService.save(ipSavePo);
     }
 }