提交代码

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

@@ -1,5 +1,8 @@
 package com.fdkankan.tracking.service;
 
+import com.alibaba.fastjson.JSONObject;
+import com.alibaba.fastjson.serializer.SerializerFeature;
+import com.fdkankan.tracking.entit.TrackingBody;
 import com.fdkankan.tracking.entit.TrackingEntity;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -31,7 +34,9 @@ public class TrackingService {
         String url = esHost.concat("/").concat(entity.getType().toLowerCase()).concat("/log?pretty&pretty");
         log.info("es host:{}", url);
         try{
-            restTemplate.postForEntity(url, entity.getPayload(), String.class);
+            // value 转换为String 格式
+            TrackingBody trackingBody = JSONObject.parseObject(JSONObject.toJSONString(entity.getPayload(), SerializerFeature.WriteNonStringValueAsString), TrackingBody.class);
+            restTemplate.postForEntity(url, trackingBody, String.class);
         }catch (Exception e){
             e.printStackTrace();
             throw new RuntimeException(e.getMessage());