feat: add log field into es in /ozhera-log (apache#523)

Author: UPYOI

ozhera-log/log-common/src/main/java/org/apache/ozhera/log/model/LogtailConfig.java

@@ -38,6 +38,8 @@ public class LogtailConfig {
     private String type;
     private Integer appType;
 
+    private String deploySpace;
+
     private Integer parseType;
     private String tail;
     /**

ozhera-log/log-manager/src/main/java/org/apache/ozhera/log/manager/model/vo/QuickQueryVO.java

@@ -46,6 +46,6 @@ public class QuickQueryVO implements Serializable {
     private String envName;
     private Integer isFavourite;
     private String deploySpace;
-
+    private String logPath;
     private Boolean collectionReady;
 }

ozhera-log/log-manager/src/main/java/org/apache/ozhera/log/manager/service/impl/LogTailServiceImpl.java

@@ -164,6 +164,7 @@ private QuickQueryVO applyQueryVO(MilogLogTailDo logTailDo, Integer isFavourite)
                 .envName(logTailDo.getEnvName())
                 .isFavourite(isFavourite == null || isFavourite < 1 ? 0 : 1)
                 .deploySpace(logTailDo.getDeploySpace())
+                .logPath(logTailDo.getLogPath())
                 .collectionReady(logTailDo.getCollectionReady())
                 .build();
     }

ozhera-log/log-manager/src/main/java/org/apache/ozhera/log/manager/service/impl/MilogConfigNacosServiceImpl.java

@@ -447,6 +447,7 @@ public LogtailConfig assembleLogTailConfigs(Long tailId) {
             logtailConfig.setParseScript(milogLogTail.getParseScript());
             logtailConfig.setValueList(milogLogTail.getValueList());
             logtailConfig.setAppType(milogLogTail.getAppType());
+            logtailConfig.setDeploySpace(milogLogTail.getDeploySpace());
             // Query MQ information
             handleTailConfig(tailId, milogLogTail.getStoreId(), milogLogTail.getSpaceId(),
                     milogLogTail.getMilogAppId(), logtailConfig, milogLogTail.getAppType());

ozhera-log/log-stream/src/main/java/org/apache/ozhera/log/stream/common/LogStreamConstants.java

@@ -38,5 +38,6 @@ public class LogStreamConstants {
     public static final String LOG_STREAM_SPACE_ID = "spaceId";
     public static final String LOG_STREAM_STORE_ID = "storeId";
     public static final String LOG_STREAM_TAIL_ID = "tailId";
+    public static final String DEPLOY_SPACE = "deploy_space";
 
 }

ozhera-log/log-stream/src/main/java/org/apache/ozhera/log/stream/job/JobManager.java

@@ -186,6 +186,7 @@ private SinkJobConfig buildSinkJobConfig(String type, String ak, String sk, Stri
                 .jobType(SinkJobEnum.NORMAL_JOB.name())
                 .storageType(sinkConfig.getStorageType())
                 .consumerGroup(logtailConfig.getConsumerGroup())
+                .deploySpace(logtailConfig.getDeploySpace())
                 .build();
         sinkJobConfig.setLogTailId(logtailConfig.getLogtailId());
         sinkJobConfig.setLogStoreId(sinkConfig.getLogstoreId());

ozhera-log/log-stream/src/main/java/org/apache/ozhera/log/stream/job/LogDataTransfer.java

@@ -143,6 +143,7 @@ private void putCommonData(Map<String, Object> dataMap) {
         dataMap.putIfAbsent(LOG_STREAM_SPACE_ID, sinkJobConfig.getLogSpaceId());
         dataMap.putIfAbsent(LOG_STREAM_STORE_ID, sinkJobConfig.getLogStoreId());
         dataMap.putIfAbsent(LOG_STREAM_TAIL_ID, sinkJobConfig.getLogTailId());
+        dataMap.putIfAbsent(DEPLOY_SPACE, sinkJobConfig.getDeploySpace());
     }
 
     private void sendMessage(Map<String, Object> dataMap) throws Exception {

ozhera-log/log-stream/src/main/java/org/apache/ozhera/log/stream/job/SinkJobConfig.java

@@ -61,4 +61,5 @@ public class SinkJobConfig extends LogConfig {
      */
     private String jobType;
     private String consumerGroup;
+    private String deploySpace;
 }