提交代码

src/main/java/com/fdkankan/tracking/entit/TrackingBody.java

@@ -9,9 +9,11 @@ public class TrackingBody {
     private String userId;
     private Date requestTime;
     private String url;
+    private String urlParam;
     private Object requestData;
     private String source;
     private String referrer;
+    private String referrerParam;
     private String eventType;
     private String eventName;
     private String userIP;
@@ -193,4 +195,20 @@ public class TrackingBody {
     public void setType(String type) {
         this.type = type;
     }
+
+    public String getUrlParam() {
+        return urlParam;
+    }
+
+    public void setUrlParam(String urlParam) {
+        this.urlParam = urlParam;
+    }
+
+    public String getReferrerParam() {
+        return referrerParam;
+    }
+
+    public void setReferrerParam(String referrerParam) {
+        this.referrerParam = referrerParam;
+    }
 }

src/main/java/com/fdkankan/tracking/service/TrackingService.java

@@ -18,6 +18,16 @@ public class TrackingService {
     private RestTemplate restTemplate = new RestTemplate();
 
     public void save(TrackingEntity entity) {
+        if(entity.getPayload().getUrl().contains("?")){
+            String[] url = entity.getPayload().getUrl().split("\\?");
+            entity.getPayload().setUrl(url[0]);
+            entity.getPayload().setUrlParam(url[1]);
+        }
+        if(entity.getPayload().getReferrer().contains("?")){
+            String[] reffer = entity.getPayload().getReferrer().split("\\?");
+            entity.getPayload().setReferrer(reffer[0]);
+            entity.getPayload().setReferrerParam(reffer[1]);
+        }
         String url = esHost.concat("/").concat(entity.getType().toLowerCase()).concat("/log?pretty&pretty");
         log.info("es host:{}", url);
         try{