opt;

liquidnet-bus-common/liquidnet-common-service-base/src/main/java/com/liquidnet/service/base/ErrorMapping.java

 package com.liquidnet.service.base;
 
 import lombok.Data;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 import java.io.IOException;
 import java.io.InputStream;
@@ -13,20 +15,22 @@ import java.util.Properties;
 
 @Data
 public class ErrorMapping {
+    private static final Logger log = LoggerFactory.getLogger(ErrorMapping.class);
+    private static final Properties errorsProperties;
     static {
-        reload();
+        errorsProperties = reload();
     }
-    private static Properties errorsProperties;
 
-    public static void reload() {
-        errorsProperties = new Properties();
+    public static Properties reload() {
+        Properties errorsProperties = new Properties();
         InputStream in = ErrorMapping.class.getClassLoader().getResourceAsStream("errors.properties");
         try {
             errorsProperties.load(new InputStreamReader(in, StandardCharsets.UTF_8));
-            System.out.printf("errorsProperties init count: %s\n", errorsProperties.size());
+            log.info("Load errorsProperties init count:{}", errorsProperties.size());
         } catch (IOException e) {
             e.printStackTrace();
         }
+        return errorsProperties;
     }
 
     public static ErrorMessage get(long code) {

liquidnet-bus-common/liquidnet-common-service-base/src/main/java/com/liquidnet/service/base/SqlMapping.java

@@ -2,33 +2,34 @@ package com.liquidnet.service.base;
 
 import com.liquidnet.commons.lang.util.CollectionUtil;
 import com.liquidnet.commons.lang.util.JsonUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 import java.io.IOException;
 import java.io.InputStream;
 import java.io.InputStreamReader;
 import java.io.Serializable;
-import java.lang.reflect.Array;
 import java.nio.charset.StandardCharsets;
-import java.util.ArrayList;
 import java.util.LinkedList;
-import java.util.List;
 import java.util.Properties;
 
 public class SqlMapping {
+    private static final Logger log = LoggerFactory.getLogger(SqlMapping.class);
+    private static final Properties sqlsProperties;
     static {
-        reload();
+        sqlsProperties = reload();
     }
-    private static Properties sqlsProperties;
 
-    public static void reload() {
-        sqlsProperties = new Properties();
+    public static Properties reload() {
+        Properties sqlsProperties = new Properties();
         InputStream in = ErrorMapping.class.getClassLoader().getResourceAsStream("sqlmap.properties");
         try {
             sqlsProperties.load(new InputStreamReader(in, StandardCharsets.UTF_8));
-            System.out.printf("errorsProperties init count: %s\n", sqlsProperties.size());
+            log.info("Load sqlsProperties init count:{}", sqlsProperties.size());
         } catch (IOException e) {
             e.printStackTrace();
         }
+        return sqlsProperties;
     }
 
     public static String get(String sql) {

liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/main/java/com/liquidnet/service/adam/util/NknameUtil.java

@@ -17,17 +17,16 @@ import java.util.Random;
 public class NknameUtil {
     private static final Logger log = LoggerFactory.getLogger(NknameUtil.class);
 
-    private static Random random = new Random();
+    private static int bound;
+    private static final List<String> nknameList;
+    private static final String nknamePrefix = "宇航员";
+    private static final Random random = new Random();
     static {
-        reload();
+        nknameList = reload();
     }
 
-    private static int bound;
-    private static List<String> nknameList;
-    private static String nknamePrefix = "宇航员";
-
-    public static void reload() {
-        nknameList = CollectionUtil.arrayListString();
+    public static List<String> reload() {
+        List<String> list = CollectionUtil.arrayListString();
         InputStream inputStream = null;
         InputStreamReader inputStreamReader = null;
         BufferedReader bufferedReader = null;
@@ -45,10 +44,10 @@ public class NknameUtil {
                 if (l > 11) {
                     line = line.substring(0, 11);
                 }
-                nknameList.add(line);
+                list.add(line);
             }
-            if (!CollectionUtils.isEmpty(nknameList)) {
-                bound = nknameList.size();
+            if (!CollectionUtils.isEmpty(list)) {
+                bound = list.size();
             }
         } catch (IOException e) {
             log.error("Read CSV[library_nickname.csv] failure.", e);
@@ -61,6 +60,8 @@ public class NknameUtil {
                 log.error("Close stream failure.", e);
             }
         }
+        log.info("Load nkname init:{}~{}", list.size(), bound);
+        return list;
     }
 
     public static String randomNkname() {

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/adam/dm/DMRdmService.java

@@ -6,7 +6,6 @@ import com.liquidnet.service.adam.constant.AdamRedisConst;
 import com.liquidnet.service.adam.dto.vo.*;
 import com.liquidnet.service.kylin.constant.KylinRedisConst;
 import com.liquidnet.service.kylin.dto.vo.mongo.KylinPerformanceVo;
-import com.liquidnet.service.platform.utils.NknameUtil;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/adam/dm/processor/DMTracesInfoProcessor.java

 package com.liquidnet.service.platform.service.impl.adam.dm.processor;
 
-import com.liquidnet.service.adam.constant.AdamRedisConst;
 import com.liquidnet.service.adam.dto.vo.AdamMemberPriceVo;
 import com.liquidnet.service.adam.dto.vo.AdamMemberVo;
 import com.liquidnet.service.adam.entity.AdamMember;
@@ -13,8 +12,6 @@ import lombok.SneakyThrows;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.data.mongodb.core.query.Criteria;
-import org.springframework.data.mongodb.core.query.Query;
 import org.springframework.stereotype.Service;
 
 import java.sql.Connection;
@@ -216,7 +213,5 @@ public class DMTracesInfoProcessor extends DataMigrationProcessorService {
     private void setRdsCache() {
 //        dmRdmService.setSwitch(AdamRedisConst.SWITCH_GRAY_LOGIN_SMS, 612543);
 //        log.info("switch {}:{}", AdamRedisConst.SWITCH_GRAY_LOGIN_SMS, dmRdmService.getSwitch(AdamRedisConst.SWITCH_GRAY_LOGIN_SMS));
-        List<String> nknameList = dmRdmService.getNknameList();
-        log.info("init loader nknameList.size:{}", nknameList.size());
     }
 }

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/utils/NknameUtil.java

-package com.liquidnet.service.platform.utils;
-
-import com.liquidnet.commons.lang.util.CollectionUtil;
-import org.apache.commons.lang3.StringUtils;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-import java.io.BufferedReader;
-import java.io.IOException;
-import java.io.InputStream;
-import java.io.InputStreamReader;
-import java.nio.charset.StandardCharsets;
-import java.util.ArrayList;
-
-public class NknameUtil {
-    private static final Logger log = LoggerFactory.getLogger(NknameUtil.class);
-
-    public static ArrayList<String> readForStringList() {
-        ArrayList<String> nknameList = CollectionUtil.arrayListString();
-        InputStream inputStream = null;
-        InputStreamReader inputStreamReader = null;
-        BufferedReader bufferedReader = null;
-        try {
-            inputStream = NknameUtil.class.getClassLoader().getResourceAsStream("META-FIL/library_nickname.csv");
-            inputStreamReader = new InputStreamReader(inputStream, StandardCharsets.UTF_8);
-            bufferedReader = new BufferedReader(inputStreamReader);
-
-            String line;
-            while ((line = bufferedReader.readLine()) != null) {
-                int l = StringUtils.length(line);
-                if (l == 0) {
-                    break;
-                }
-                if (l > 11) {
-                    line = line.substring(0, 11);
-                }
-                nknameList.add(line);
-            }
-        } catch (IOException e) {
-            log.error("Read CSV[library_nickname.csv] failure.", e);
-        } finally {
-            try {
-                if (null != bufferedReader) bufferedReader.close();
-                if (null != inputStreamReader) inputStreamReader.close();
-                if (null != inputStream) inputStream.close();
-            } catch (IOException e) {
-                log.error("Close stream failure.", e);
-            }
-        }
-        return nknameList;
-    }
-}
\ No newline at end of file