refactor: update the package path of the startup class

ozhera-app/app-server/src/main/java/org/apache/ozhera/app/AppBootstrap.java

@@ -33,8 +33,8 @@
  */
 @Slf4j
 @SpringBootApplication
-@DubboComponentScan(basePackages = "com.xiaomi.mone.app")
-@MapperScan("com.xiaomi.mone.app.dao")
+@DubboComponentScan(basePackages = "org.apache.ozhera.app")
+@MapperScan("org.apache.ozhera.app.dao")
 @EnableScheduling
 public class AppBootstrap {
 

ozhera-app/app-server/src/main/java/org/apache/ozhera/app/aop/OperateAppBaseInfoAspect.java

@@ -47,7 +47,7 @@
 @Slf4j
 public class OperateAppBaseInfoAspect {
 
-    private final String appGetResultDataPoint = "execution(* com.xiaomi.mone.app.service.impl.HeraAppBaseInfoServiceImpl.appBaseInfoOperate(..))";
+    private final String appGetResultDataPoint = "execution(* org.apache.ozhera.app.service.impl.HeraAppBaseInfoServiceImpl.appBaseInfoOperate(..))";
 
     @Value("${rocket.mq.hera.app.topic}")
     private String topic;

ozhera-app/app-server/src/main/java/org/apache/ozhera/app/exception/AppExceptionControllerAdvice.java

@@ -33,7 +33,7 @@
  * @date 2022/10/29 13:27
  */
 @Slf4j
-@RestControllerAdvice(basePackages = "com.xiaomi.mone.app.controller")
+@RestControllerAdvice(basePackages = "org.apache.ozhera.app.controller")
 public class AppExceptionControllerAdvice {
 
     @ExceptionHandler(value = MethodArgumentNotValidException.class)

ozhera-app/app-server/src/main/resources/application.properties

@@ -10,7 +10,7 @@ spring.datasource.default.maxPoolSize=20
 spring.datasource.default.minialPoolSize=10
 
 mybatis-plus.mapper-locations=classpath:mapper/*.xml
-mybatis-plus.type-aliases-package=com.xiaomi.mone.app.model
+mybatis-plus.type-aliases-package=org.apache.ozhera.app.model
 mybatis-plus.configuration.map-underscore-to-camel-case=true
 mybatis-plus.global-config.db-config.id-type=auto
 #mybatis-plus.configuration.log-impl=org.apache.ibatis.logging.stdout.StdOutImpl

ozhera-demo-client/ozhera-demo-client-server/src/main/java/org/apache/ozhera/demo/client/bootstrap/HeraDemoClientBootstrap.java

@@ -26,8 +26,8 @@
  * @author dingtao
  */
 @EnableAutoConfiguration(exclude= {DataSourceAutoConfiguration.class})
-@ComponentScan(basePackages = {"com.xiaomi.mone.hera.demo.client"})
-@DubboComponentScan(basePackages = "com.xiaomi.mone.hera.demo.client")
+@ComponentScan(basePackages = {"org.apache.ozhera.demo.client"})
+@DubboComponentScan(basePackages = "org.apache.ozhera.demo.client")
 @Slf4j
 public class HeraDemoClientBootstrap {
 

ozhera-demo-client/ozhera-demo-client-service/src/main/java/org/apache/ozhera/demo/client/service/DubboHealthServiceImpl.java

@@ -27,7 +27,7 @@
 public class DubboHealthServiceImpl implements DubboHealthService {
 
     @Reference(group = "${dubbo.group}",version = "1.0",timeout = 3000,retries = 0,check = false)
-    private com.xiaomi.mone.hera.demo.server.service.DubboHealthService  dubboHealthService;
+    private org.apache.ozhera.demo.server.service.DubboHealthService  dubboHealthService;
 
     @Override
     public int remoteHealth(int size) {

ozhera-demo-server/ozhera-demo-server-server/src/main/java/org/apache/ozhera/demo/server/HeraDemoServerBootstrap.java

@@ -26,8 +26,7 @@
  */
 @Slf4j
 @SpringBootApplication
-@ComponentScan(basePackages = {"com.xiaomi.mone.hera.demo.server"})
-@DubboComponentScan(basePackages = {"com.xiaomi.mone.hera.demo.server"})
+@DubboComponentScan(basePackages = {"org.apache.ozhera.demo.server"})
 public class HeraDemoServerBootstrap {
     public static void main(String... args) {
         try {

ozhera-intelligence/ozhera-intelligence-server/src/main/java/org/apache/ozhera/intelligence/bootstrap/IntelligenceBootStrap.java

@@ -21,7 +21,7 @@
 import org.springframework.context.annotation.ComponentScan;
 
 @EnableAutoConfiguration
-@ComponentScan(basePackages = {"run.mone.hera.intelligence"})
+@ComponentScan(basePackages = {"org.apache.ozhera.intelligence"})
 @Slf4j
 public class IntelligenceBootStrap {
     public static void main(String... args) {

ozhera-log/log-agent-server/src/main/java/org/apache/ozhera/log/server/LogAgentServerBootstrap.java

@@ -19,13 +19,13 @@
 import com.xiaomi.data.push.rpc.RpcCmd;
 import com.xiaomi.data.push.rpc.RpcServer;
 import com.xiaomi.data.push.rpc.common.Pair;
+import com.xiaomi.youpin.docean.Ioc;
+import lombok.extern.slf4j.Slf4j;
 import org.apache.ozhera.log.common.Config;
 import org.apache.ozhera.log.common.Constant;
 import org.apache.ozhera.log.server.porcessor.AgentCollectProgressProcessor;
 import org.apache.ozhera.log.server.porcessor.AgentConfigProcessor;
 import org.apache.ozhera.log.server.porcessor.PingProcessor;
-import com.xiaomi.youpin.docean.Ioc;
-import lombok.extern.slf4j.Slf4j;
 
 import java.io.IOException;
 
@@ -56,7 +56,7 @@ public static void main(String[] args) throws IOException {
         rpcServer.start();
 
         Ioc.ins().putBean(rpcServer);
-        Ioc.ins().init("com.xiaomi.mone", "com.xiaomi.youpin");
+        Ioc.ins().init("com.xiaomi.mone", "com.xiaomi.youpin", "org.apache.ozhera.log.server");
         log.info("log server start finish");
     }
 }

ozhera-log/log-agent/src/main/java/org/apache/ozhera/log/agent/bootstrap/MiLogAgentBootstrap.java

@@ -60,7 +60,7 @@ public static void main(String[] args) throws IOException {
         client.waitStarted();
         log.info("create rpc client finish");
         Aop.ins().init(Maps.newLinkedHashMap());
-        Ioc.ins().putBean(client).init("com.xiaomi.mone.log.agent", "com.xiaomi.youpin.docean");
+        Ioc.ins().putBean(client).init("org.apache.ozhera.log.agent", "com.xiaomi.youpin.docean");
         //Because the client life cycle is advanced, the processor needs to be re-registered here
         client.registerProcessor();
         System.in.read();

ozhera-log/log-agent/src/main/java/org/apache/ozhera/log/agent/channel/AbstractChannelService.java

@@ -15,16 +15,17 @@
  */
 package org.apache.ozhera.log.agent.channel;
 
+import cn.hutool.core.io.FileUtil;
 import com.xiaomi.mone.file.ReadResult;
 import com.xiaomi.mone.file.common.FileInfoCache;
+import lombok.extern.slf4j.Slf4j;
 import org.apache.ozhera.log.agent.channel.memory.ChannelMemory;
 import org.apache.ozhera.log.agent.common.ChannelUtil;
 import org.apache.ozhera.log.agent.input.Input;
 import org.apache.ozhera.log.api.enums.LogTypeEnum;
 import org.apache.ozhera.log.api.model.meta.LogPattern;
 import org.apache.ozhera.log.api.model.msg.LineMessage;
 import org.apache.ozhera.log.utils.NetUtil;
-import lombok.extern.slf4j.Slf4j;
 
 import java.util.HashMap;
 import java.util.List;
@@ -152,7 +153,7 @@ private Map<String, ChannelMemory.FileProgress> buildFileProgressMap(List<String
     protected static void wildcardGraceShutdown(List<String> directory, String matchExpress) {
         // Add a shutdown hook to gracefully shutdown FileInfoCache
         Runtime.getRuntime().addShutdownHook(new Thread(() -> {
-            log.info("wildcardGraceShutdown Shutdown,directory:{},express:{}", GSON.toJson(directory), matchExpress);
+            log.info("wildcardGraceShutdown Shutdown,directory:{},express:{},cacheSize:{}", GSON.toJson(directory), matchExpress, FileInfoCache.ins().caches().size());
             FileInfoCache.ins().shutdown();
         }));
     }
@@ -192,7 +193,9 @@ protected void updateChannelMemory(ChannelMemory channelMemory, String fileName,
         if (null != readResult.get().getFileMaxPointer()) {
             fileProgress.setFileMaxPointer(readResult.get().getFileMaxPointer());
         }
-        fileProgress.setUnixFileNode(ChannelUtil.buildUnixFileNode(fileName));
+        if (FileUtil.exist(fileName)) {
+            fileProgress.setUnixFileNode(ChannelUtil.buildUnixFileNode(fileName));
+        }
         fileProgress.setPodType(channelDefine.getPodType());
         fileProgress.setCtTime(ct);
     }

ozhera-log/log-manager/src/main/java/org/apache/ozhera/log/manager/bootstrap/MiLogManagerBootstrap.java

@@ -15,8 +15,6 @@
  */
 package org.apache.ozhera.log.manager.bootstrap;
 
-import org.apache.ozhera.log.common.Config;
-import org.apache.ozhera.log.manager.controller.interceptor.HttpRequestInterceptor;
 import com.xiaomi.youpin.docean.Aop;
 import com.xiaomi.youpin.docean.Ioc;
 import com.xiaomi.youpin.docean.anno.RequestMapping;
@@ -25,6 +23,8 @@
 import com.xiaomi.youpin.docean.config.HttpServerConfig;
 import com.xiaomi.youpin.docean.mvc.DoceanHttpServer;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.ozhera.log.common.Config;
+import org.apache.ozhera.log.manager.controller.interceptor.HttpRequestInterceptor;
 
 import java.util.LinkedHashMap;
 
@@ -45,7 +45,7 @@ public static void main(String[] args) throws InterruptedException {
         Aop.ins().init(m);
 
         Ioc.ins().putBean(Cons.AUTO_FIND_IMPL, "true")
-                .init("com.xiaomi.mone", "com.xiaomi.youpin");
+                .init("com.xiaomi.mone", "com.xiaomi.youpin", "org.apache.ozhera.log.manager");
         Config ins = Config.ins();
 
         int port = Integer.parseInt(ins.get("serverPort", ""));

ozhera-log/log-stream/src/main/java/org/apache/ozhera/log/stream/bootstrap/MiLogStreamBootstrap.java

@@ -49,7 +49,7 @@ public static void main(String[] args) {
     private static void initializeApplication() {
         OkHttpClient okHttpClient = getOkHttpClient();
         Ioc.ins().putBean(okHttpClient)
-                .init("com.xiaomi.mone.log.stream", "com.xiaomi.youpin.docean");
+                .init("org.apache.ozhera.log.stream", "com.xiaomi.youpin.docean");
     }
 
     private static void startHealthCheckTask() {

ozhera-monitor/ozhera-monitor-server/src/main/java/org/apache/ozhera/monitor/bootstrap/MiMonitorBootstrap.java

@@ -25,9 +25,9 @@
 
 @Slf4j
 @EnableAutoConfiguration
-@ComponentScan(basePackages = {"com.xiaomi.mone.monitor"})
-@DubboComponentScan(basePackages = "com.xiaomi.mone.monitor")
-@ServletComponentScan("com.xiaomi.mone.monitor.filter")
+@ComponentScan(basePackages = {"org.apache.ozhera.monitor"})
+@DubboComponentScan(basePackages = "org.apache.ozhera.monitor")
+@ServletComponentScan("org.apache.ozhera.monitor.filter")
 public class MiMonitorBootstrap {
 
     public static void main(String[] args) throws InterruptedException {

ozhera-operator/ozhera-operator-server/src/main/java/org/apache/ozhera/operator/HeraBootstrap.java

@@ -27,7 +27,7 @@
 public class HeraBootstrap {
 
     public static void main(String[] args) throws InterruptedException {
-        Ioc.ins().init("run.mone.docean.plugin","com.xiaomi.youpin.docean.plugin","run.mone.hera.operator");
+        Ioc.ins().init("run.mone.docean.plugin","com.xiaomi.youpin.docean.plugin","org.apache.ozhera.operator");
         //Mvc.ins();
         Mvc.ins().getMvcConfig().setResponseOriginalValue(true);
 

ozhera-prometheus-agent/ozhera-prometheus-agent-server/src/main/java/org/apache/ozhera/prometheus/agent/bootstrap/PrometheusAgentBootstrap.java

@@ -27,8 +27,8 @@
  * @author dingtao
  */
 @EnableAutoConfiguration
-@ComponentScan(basePackages = {"com.xiaomi.youpin.prometheus.agent", "com.xiaomi.youpin"})
-@DubboComponentScan(basePackages = "com.xiaomi.youpin.prometheus.agent")
+@ComponentScan(basePackages = {"org.apache.ozhera.prometheus.agent", "com.xiaomi.youpin"})
+@DubboComponentScan(basePackages = "org.apache.ozhera.prometheus.agent")
 @Slf4j
 public class PrometheusAgentBootstrap {
     private static final Logger logger = LoggerFactory.getLogger(PrometheusAgentBootstrap.class);

ozhera-webhook/ozhera-webhook-server/src/main/java/org/apache/ozhera/webhook/Bootstrap.java

@@ -37,7 +37,7 @@
  * @author dingtao
  */
 @EnableAutoConfiguration
-@ComponentScan(basePackages = {"run.mone.hera.webhook"})
+@ComponentScan(basePackages = {"org.apache.ozhera.webhook"})
 @Slf4j
 public class Bootstrap {
 

pom.xml

@@ -1058,14 +1058,16 @@
     </build>
 
     <distributionManagement>
-        <snapshotRepository>
-            <id>ossrh</id>
-            <url>https://s01.oss.sonatype.org/content/repositories/snapshots</url>
-        </snapshotRepository>
         <repository>
-            <id>ossrh</id>
-            <url>https://s01.oss.sonatype.org/service/local/staging/deploy/maven2/</url>
+            <id>central</id>
+            <name>maven-release-virtual</name>
+            <url>https://pkgs.d.xiaomi.net/artifactory/maven-release-virtual</url>
         </repository>
+        <snapshotRepository>
+            <id>snapshots</id>
+            <name>snapshots</name>
+            <url>https://pkgs.d.xiaomi.net/artifactory/snapshots</url>
+        </snapshotRepository>
     </distributionManagement>
 
 </project>

trace-etl/trace-etl-es/src/main/java/org/apache/ozhera/trace/etl/es/bootstrap/TraceEtlEsBootstrap.java

@@ -26,9 +26,9 @@
  * @author dingtao
  */
 @EnableAutoConfiguration
-@ComponentScan(basePackages = {"com.xiaomi.hera.trace.etl", "com.xiaomi.data.push.redis", "run.mone.trace.etl"})
-@DubboComponentScan(basePackages = "com.xiaomi.hera.trace.etl.es.dubbo")
-@MapperScan("com.xiaomi.hera.trace.etl.mapper")
+@ComponentScan(basePackages = {"org.apache.ozhera.trace.etl.es", "com.xiaomi.data.push.redis", "run.mone.trace.etl"})
+@DubboComponentScan(basePackages = "org.apache.ozhera.trace.etl.es.dubbo")
+@MapperScan("org.apache.ozhera.trace.etl.mapper")
 @Slf4j
 public class TraceEtlEsBootstrap {
 

trace-etl/trace-etl-manager/src/main/java/org/apache/ozhera/trace/etl/manager/bootstrap/TraceEtlManagerBootstrap.java

@@ -25,9 +25,9 @@
  * @author dingtao
  */
 @EnableAutoConfiguration
-@ComponentScan(basePackages = {"com.xiaomi.hera.trace.etl", "run.mone.trace.etl"})
-@DubboComponentScan(basePackages = "com.xiaomi.hera.trace.etl")
-@MapperScan("com.xiaomi.hera.trace.etl.mapper")
+@ComponentScan(basePackages = {"org.apache.ozhera.trace.etl", "run.mone.trace.etl"})
+@DubboComponentScan(basePackages = "org.apache.ozhera.trace.etl")
+@MapperScan("org.apache.ozhera.trace.etl.mapper")
 public class TraceEtlManagerBootstrap {
 
     public static void main(String... args) {

trace-etl/trace-etl-nginx/src/main/java/org/apache/ozhera/trace/etl/nginx/bootstrap/TraceEtlNginxBootstrap.java

@@ -26,7 +26,7 @@
  * @author dingtao
  */
 @EnableAutoConfiguration(exclude={DataSourceAutoConfiguration.class})
-@ComponentScan(basePackages = {"com.xiaomi.hera.trace.etl.nginx"})
+@ComponentScan(basePackages = {"org.apache.ozhera.trace.etl.nginx"})
 @SpringBootApplication(exclude= {DataSourceAutoConfiguration.class})
 @Slf4j
 public class TraceEtlNginxBootstrap {

trace-etl/trace-etl-server/src/main/java/org/apache/ozhera/trace/etl/bootstrap/TraceEtlBootstrap.java

@@ -26,9 +26,9 @@
  * @author dingtao
  */
 @EnableAutoConfiguration
-@ComponentScan(basePackages = {"com.xiaomi.hera.trace.etl", "com.xiaomi.data.push.redis", "run.mone.trace.etl"})
-@DubboComponentScan(basePackages = "com.xiaomi.hera.trace.etl.dubbo")
-@MapperScan("com.xiaomi.hera.trace.etl.mapper")
+@ComponentScan(basePackages = {"org.apache.ozhera.trace.etl", "com.xiaomi.data.push.redis", "run.mone.trace.etl"})
+@DubboComponentScan(basePackages = "org.apache.ozhera.trace.etl.dubbo")
+@MapperScan("org.apache.ozhera.trace.etl.mapper")
 @Slf4j
 public class TraceEtlBootstrap {