shjung 1 year ago
parent
commit
3c064fd671

+ 6 - 9
src/main/java/com/ggits/comm/server/config/SchedulingConfig.java

@@ -16,18 +16,15 @@ import javax.annotation.PostConstruct;
 @ConfigurationProperties(prefix = "application.scheduling")
 public class SchedulingConfig implements SchedulingConfigurer {
 
-    private int poolCore = 0;
-
-    private final int SCHEDULE_THREAD_POOL_SIZE = 10;
-
+    private int poolSize = 0;
     @PostConstruct
     private void init() {
         log.info("[{}] ------------", this.getClass().getSimpleName());
-        if (this.poolCore == 0) {
-            log.warn("[{}] poolCore size set as default: {} EA.", this.getClass().getSimpleName(), this.poolCore);
-            this.poolCore = 10;
+        if (this.poolSize == 0) {
+            log.warn("[{}] poolSize size set as default: {} EA.", this.getClass().getSimpleName(), this.poolSize);
+            this.poolSize = 10;
         }
-        log.info("[{}] poolCore: {} EA.", this.getClass().getSimpleName(), this.poolCore);
+        log.info("[{}] poolSize: {} EA.", this.getClass().getSimpleName(), this.poolSize);
     }
 
     @Override
@@ -35,7 +32,7 @@ public class SchedulingConfig implements SchedulingConfigurer {
 
         ThreadPoolTaskScheduler threadPoolTaskScheduler = new ThreadPoolTaskScheduler();
 
-        threadPoolTaskScheduler.setPoolSize(SCHEDULE_THREAD_POOL_SIZE);
+        threadPoolTaskScheduler.setPoolSize(poolSize);
         threadPoolTaskScheduler.setThreadNamePrefix("scheduler-");
         threadPoolTaskScheduler.initialize();
 

+ 12 - 12
src/main/java/com/ggits/comm/server/repository/ApplicationRepository.java

@@ -61,19 +61,19 @@ public class ApplicationRepository {
         int qSeq = 0;
         try {
             List<TbRegionCenter> lists  = this.mapper.selectRegionCenter();
-            log.info("loadRegionCenterInfo.loadRegionCenterInfo: {} EA", lists.size());
+            log.info("AppRepositoryService.loadRegionCenterInfo: {} EA", lists.size());
             for (TbRegionCenter entity : lists) {
-                log.info("loadRegionCenterInfo.loadRegionCenterInfo: {}.", entity);
+                log.info("AppRepositoryService.loadRegionCenterInfo: {}.", entity);
                 RegionCenter dto = entity.toDto();
                 dto.setQSeq(qSeq++);
                 this.centerMap.put(dto.getRegionId(), dto);
             }
         }
         catch (Exception e) {
-            log.error("loadRegionCenterInfo.loadRegionCenterInfo: {}.", e.toString());
+            log.error("AppRepositoryService.loadRegionCenterInfo: {}.", e.toString());
         }
 
-        log.info("loadRegionCenterInfo.loadRegionCenterInfo: {} EA. {} ms.", this.centerMap.size(), elapsed.milliSeconds());
+        log.info("AppRepositoryService.loadRegionCenterInfo: {} EA. {} ms.", this.centerMap.size(), elapsed.milliSeconds());
     }
     private void loadRegionGgitsInfo() {
         Elapsed elapsed = new Elapsed();
@@ -81,20 +81,20 @@ public class ApplicationRepository {
         int regionGgits = 0;
         try {
             List<TbRegionGgits> lists  = this.mapper.selectRegionGgits();
-            log.info("loadRegionCenterInfo.loadRegionGgitsInfo: {} EA", lists.size());
+            log.info("AppRepositoryService.loadRegionGgitsInfo: {} EA", lists.size());
             for (TbRegionGgits entity : lists) {
                 RegionCenter center = this.centerMap.get(entity.getRegionId());
                 if (center != null && center.getRegionId() != 0 && entity.getGgitsRegionNo() != 0) {
                     center.setGgitsRegionNo(entity.getGgitsRegionNo());
                     regionGgits++;
-                    log.info("loadRegionCenterInfo.loadRegionGgitsInfo: {}.", entity);
+                    log.info("AppRepositoryService.loadRegionGgitsInfo: {}.", entity);
                 }
             }
         }
         catch (Exception e) {
-            log.error("loadRegionCenterInfo.loadRegionGgitsInfo: {}.", e.toString());
+            log.error("AppRepositoryService.loadRegionGgitsInfo: {}.", e.toString());
         }
-        log.info("loadRegionCenterInfo.loadRegionGgitsInfo: {} EA. {} ms.", regionGgits, elapsed.milliSeconds());
+        log.info("AppRepositoryService.loadRegionGgitsInfo: {} EA. {} ms.", regionGgits, elapsed.milliSeconds());
     }
     private void loadIntInfo() {
         Elapsed elapsed = new Elapsed();
@@ -103,7 +103,7 @@ public class ApplicationRepository {
             for (Map.Entry<Integer, RegionCenter> entry : this.centerMap.entrySet()) {
                 RegionCenter center = entry.getValue();
                 List<TbInt> lists = this.intMapper.selectAll(center.getRegionCd());
-                log.info("loadRegionCenterInfo.loadIntInfo: {} ==> {} EA", center.getRegionCd(), lists.size());
+                log.info("AppRepositoryService.loadIntInfo: {} ==> {} EA", center.getRegionCd(), lists.size());
                 totalInts += lists.size();
                 for (TbInt entity : lists) {
                     IntDto dto = entity.toDto();
@@ -113,10 +113,10 @@ public class ApplicationRepository {
             }
         }
         catch (Exception e) {
-            log.error("loadRegionCenterInfo.loadIntInfo: {}.", e.toString());
+            log.error("AppRepositoryService.loadIntInfo: {}.", e.toString());
         }
 
-        log.info("loadRegionCenterInfo.loadIntInfo: {} EA. {} ms.", totalInts, elapsed.milliSeconds());
+        log.info("AppRepositoryService.loadIntInfo: {} EA. {} ms.", totalInts, elapsed.milliSeconds());
     }
     public void updateRegionCenterStts(RegionCenter AObj, boolean isRun) {
         if (isRun) {
@@ -137,7 +137,7 @@ public class ApplicationRepository {
 
     @PreDestroy
     public void destroyService() {
-        log.error("loadRegionCenterInfo.destroy. system terminated.......");
+        log.error("AppRepositoryService.destroyService. system terminated.......");
         this.centerMap.forEach((key, center) -> {
             updateRegionCenterStts(center, false);
         });