From bdcc9b131d6b8bc6b15274123e04bbff1acdf56b Mon Sep 17 00:00:00 2001
From: tjq <tengjiqi@gmail.com>
Date: Mon, 14 Aug 2023 23:14:07 +0800
Subject: [PATCH] refactor: optimize DfsService's log

---
 .../server/persistence/storage/impl/AliOssService.java        | 2 +-
 .../server/persistence/storage/impl/EmptyDFsService.java      | 4 +++-
 .../server/persistence/storage/impl/GridFsService.java        | 2 ++
 .../persistence/storage/impl/MySqlSeriesDfsService.java       | 4 ++++
 4 files changed, 10 insertions(+), 2 deletions(-)

diff --git a/powerjob-server/powerjob-server-persistence/src/main/java/tech/powerjob/server/persistence/storage/impl/AliOssService.java b/powerjob-server/powerjob-server-persistence/src/main/java/tech/powerjob/server/persistence/storage/impl/AliOssService.java
index 7ae36243..d3a23657 100644
--- a/powerjob-server/powerjob-server-persistence/src/main/java/tech/powerjob/server/persistence/storage/impl/AliOssService.java
+++ b/powerjob-server/powerjob-server-persistence/src/main/java/tech/powerjob/server/persistence/storage/impl/AliOssService.java
@@ -142,7 +142,7 @@ public class AliOssService extends AbstractDFsService {
         }
 
         this.oss = new OSSClientBuilder().build(endpoint, credentialsProvider);
-        log.info("[AliOssService] initialize OSS successfully!");
+        log.info("[AliOssService] initialize successfully, THIS_WILL_BE_THE_STORAGE_LAYER.");
     }
 
     @Override
diff --git a/powerjob-server/powerjob-server-persistence/src/main/java/tech/powerjob/server/persistence/storage/impl/EmptyDFsService.java b/powerjob-server/powerjob-server-persistence/src/main/java/tech/powerjob/server/persistence/storage/impl/EmptyDFsService.java
index 9f464898..28b1340d 100644
--- a/powerjob-server/powerjob-server-persistence/src/main/java/tech/powerjob/server/persistence/storage/impl/EmptyDFsService.java
+++ b/powerjob-server/powerjob-server-persistence/src/main/java/tech/powerjob/server/persistence/storage/impl/EmptyDFsService.java
@@ -1,5 +1,6 @@
 package tech.powerjob.server.persistence.storage.impl;
 
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.context.ApplicationContext;
 import org.springframework.context.annotation.Conditional;
 import tech.powerjob.server.extension.dfs.*;
@@ -17,6 +18,7 @@ import java.util.Optional;
  * @author tjq
  * @since 2023/7/30
  */
+@Slf4j
 @Priority(value = Integer.MAX_VALUE)
 @Conditional(EmptyDFsService.EmptyCondition.class)
 public class EmptyDFsService extends AbstractDFsService {
@@ -41,7 +43,7 @@ public class EmptyDFsService extends AbstractDFsService {
 
     @Override
     protected void init(ApplicationContext applicationContext) {
-
+        log.info("[EmptyDFsService] initialize successfully, THIS_WILL_BE_THE_STORAGE_LAYER.");
     }
 
 
diff --git a/powerjob-server/powerjob-server-persistence/src/main/java/tech/powerjob/server/persistence/storage/impl/GridFsService.java b/powerjob-server/powerjob-server-persistence/src/main/java/tech/powerjob/server/persistence/storage/impl/GridFsService.java
index c5c4f70c..71f7b0d7 100644
--- a/powerjob-server/powerjob-server-persistence/src/main/java/tech/powerjob/server/persistence/storage/impl/GridFsService.java
+++ b/powerjob-server/powerjob-server-persistence/src/main/java/tech/powerjob/server/persistence/storage/impl/GridFsService.java
@@ -158,6 +158,8 @@ public class GridFsService extends AbstractDFsService {
     protected void init(ApplicationContext applicationContext) {
         String uri = parseMongoUri(applicationContext.getEnvironment());
         initMongo(uri);
+
+        log.info("[GridFsService] initialize successfully, THIS_WILL_BE_THE_STORAGE_LAYER.");
     }
 
     public static class GridFsCondition extends PropertyAndOneBeanCondition {
diff --git a/powerjob-server/powerjob-server-persistence/src/main/java/tech/powerjob/server/persistence/storage/impl/MySqlSeriesDfsService.java b/powerjob-server/powerjob-server-persistence/src/main/java/tech/powerjob/server/persistence/storage/impl/MySqlSeriesDfsService.java
index ca8348a8..e98008e0 100644
--- a/powerjob-server/powerjob-server-persistence/src/main/java/tech/powerjob/server/persistence/storage/impl/MySqlSeriesDfsService.java
+++ b/powerjob-server/powerjob-server-persistence/src/main/java/tech/powerjob/server/persistence/storage/impl/MySqlSeriesDfsService.java
@@ -17,6 +17,7 @@ import org.springframework.context.annotation.Conditional;
 import org.springframework.core.env.Environment;
 import tech.powerjob.common.serialize.JsonUtils;
 import tech.powerjob.common.utils.CommonUtils;
+import tech.powerjob.common.utils.NetUtils;
 import tech.powerjob.server.common.constants.SwitchableStatus;
 import tech.powerjob.server.common.spring.condition.PropertyAndOneBeanCondition;
 import tech.powerjob.server.extension.dfs.*;
@@ -138,6 +139,7 @@ public class MySqlSeriesDfsService extends AbstractDFsService {
         deleteByLocation(fileLocation);
 
         Map<String, Object> meta = Maps.newHashMap();
+        meta.put("_server_", NetUtils.getLocalHost());
         meta.put("_local_file_path_", storeRequest.getLocalFile().getAbsolutePath());
 
         Date date = new Date(System.currentTimeMillis());
@@ -262,6 +264,8 @@ public class MySqlSeriesDfsService extends AbstractDFsService {
             log.error("[MySqlSeriesDfsService] init datasource failed!", e);
             ExceptionUtils.rethrow(e);
         }
+
+        log.info("[MySqlSeriesDfsService] initialize successfully, THIS_WILL_BE_THE_STORAGE_LAYER.");
     }
 
     void initDatabase(MySQLProperty property) {