Merge pull request #177 from Dokyeongyun/develop

Develop

Author: Dokyeongyun

src/main/java/root/applications/ConsoleApp.java

@@ -8,10 +8,31 @@
 import java.util.List;
 import java.util.stream.Collectors;
 
+import dnl.utils.text.table.TextTable;
+import dnl.utils.text.table.csv.CsvTableModel;
+import root.common.database.contracts.AbstractDatabase;
+import root.common.database.implement.JdbcDatabase;
+import root.common.server.implement.JschServer;
+import root.core.batch.DBCheckBatch;
+import root.core.batch.ServerCheckBatch;
+import root.core.domain.AlertLogCommandPeriod;
+import root.core.domain.JdbcConnectionInfo;
+import root.core.domain.JschConnectionInfo;
+import root.core.repository.constracts.DBCheckRepository;
 import root.core.repository.constracts.PropertyRepository;
+import root.core.repository.constracts.ServerCheckRepository;
+import root.core.repository.implement.DBCheckRepositoryImpl;
 import root.core.repository.implement.PropertyRepositoryImpl;
+import root.core.repository.implement.ReportFileRepo;
+import root.core.repository.implement.ServerCheckRepositoryImpl;
 import root.core.service.contracts.PropertyService;
 import root.core.service.implement.FilePropertyService;
+import root.core.usecase.constracts.DBCheckUsecase;
+import root.core.usecase.constracts.ServerCheckUsecase;
+import root.core.usecase.implement.DBCheckUsecaseImpl;
+import root.core.usecase.implement.ServerCheckUsecaseImpl;
+import root.utils.CsvUtils;
+import root.utils.DateUtils;
 import root.utils.PatternUtils;
 
 /**
@@ -77,17 +98,17 @@ public static void main(String[] args) throws IOException {
 		String selectedPreset = "";
 		while (true) {
 			System.out.println(String.format("사용하실 모니터링여부 설정을 선택해주세요."));
-			
+
 			List<String> presetNames = propService.getMonitoringPresetNameList();
 			if (presetNames.size() == 0) {
 				System.out.println("모니터링여부 설정파일이 존재하지 않습니다. 프로그램을 종료합니다.");
 				return;
 			}
-			
+
 			for (int i = 0; i < presetNames.size(); i++) {
 				System.out.println(String.format("[%d] %s", (i + 1), presetNames.get(i)));
 			}
-			
+
 			String input = br.readLine().trim();
 			if (!PatternUtils.isOnlyNumber(input)) {
 				System.out.println("잘못 입력하셨습니다. 모니터링여부 설정파일을 다시 선택해주세요.");
@@ -104,5 +125,53 @@ public static void main(String[] args) throws IOException {
 			break;
 		}
 		System.out.println(String.format("선택된 파일은 [%s] 입니다.", selectedPreset));
+
+		// STEP4: 설정파일의 접속정보를 읽어 DB,Server 객체 생성 및 출력
+		List<String> dbNames = propService.getMonitoringDBNameList();
+		List<JdbcConnectionInfo> jdbcConnectionList = propService.getJdbcConnInfoList(dbNames);
+		System.out.println("저장된 DB접속정보는 다음과 같습니다.");
+		TextTable dbTable = new TextTable(
+				new CsvTableModel(CsvUtils.toCsvString(jdbcConnectionList, JdbcConnectionInfo.class)));
+		dbTable.printTable(System.out, 2);
+
+		List<String> serverNames = propService.getMonitoringServerNameList();
+		List<JschConnectionInfo> jschConnectionList = propService.getJschConnInfoList(serverNames);
+		System.out.println("저장된 Server접속정보는 다음과 같습니다.");
+		TextTable serverTable = new TextTable(
+				new CsvTableModel(CsvUtils.toCsvString(jschConnectionList, JschConnectionInfo.class)));
+		serverTable.printTable(System.out, 2);
+		
+		// TODO STEP5: 모니터링여부 설정 읽기
+
+		// STEP6: 모니터링 수행
+		System.out.println("DB 모니터링을 수행합니다.");
+		for (JdbcConnectionInfo jdbc : jdbcConnectionList) {
+			System.out.println("■ [ " + jdbc.getJdbcDBName() + " Monitoring Start ]\n");
+			AbstractDatabase db = new JdbcDatabase(jdbc);
+			db.init();
+			DBCheckRepository repo = new DBCheckRepositoryImpl(db);
+			DBCheckUsecase usecase = new DBCheckUsecaseImpl(repo, ReportFileRepo.getInstance());
+			DBCheckBatch dbBatch = new DBCheckBatch(usecase);
+			dbBatch.startBatchArchiveUsageCheck();
+			dbBatch.startBatchTableSpaceUsageCheck();
+			dbBatch.startBatchASMDiskUsageCheck();
+			System.out.println("■ [ " + jdbc.getJdbcDBName() + " Monitoring End ]\n\n");
+		}
+
+		System.out.println("Server 모니터링을 수행합니다.");
+		for (JschConnectionInfo jsch : jschConnectionList) {
+			System.out.println("■ [ " + jsch.getServerName() + " Monitoring Start ]\n");
+			JschServer server = new JschServer(jsch);
+			server.init();
+			ServerCheckRepository repo = new ServerCheckRepositoryImpl(server);
+			ServerCheckUsecase usecase = new ServerCheckUsecaseImpl(repo);
+			ServerCheckBatch serverBatch = new ServerCheckBatch(usecase);
+
+			AlertLogCommandPeriod alcp = new AlertLogCommandPeriod(jsch.getAlc(),
+					DateUtils.addDate(DateUtils.getToday("yyyy-MM-dd"), 0, 0, -1), DateUtils.getToday("yyyy-MM-dd"));
+			serverBatch.startBatchAlertLogCheckDuringPeriod(alcp);
+			serverBatch.startBatchOSDiskUsageCheck();
+			System.out.println("■ [ " + jsch.getServerName() + " Monitoring End ]\n\n");
+		}
 	}
 }

src/main/java/root/applications/Program.java

@@ -1,48 +1,51 @@
 package root.applications;
 
-import java.io.File;
-
 import javafx.application.Application;
-import javafx.fxml.FXMLLoader;
+import javafx.scene.Parent;
 import javafx.scene.Scene;
-import javafx.scene.layout.AnchorPane;
-import javafx.scene.text.Font;
 import javafx.stage.Stage;
 import root.core.repository.constracts.PropertyRepository;
 import root.core.repository.implement.PropertyRepositoryImpl;
+import root.javafx.Controller.HomeController;
+import root.javafx.Controller.LeftMenuController;
+import root.javafx.DI.DependencyInjection;
 
 public class Program extends Application {
 
+	public static Stage stage;
+	
 	PropertyRepository propRepo = PropertyRepositoryImpl.getInstance();
 
 	@Override
 	public void start(Stage primaryStage) throws Exception {
 
+		stage = primaryStage;
+
+		setUpDependecyInjector();
+
 		// configuration load
 		propRepo.loadCombinedConfiguration();
 
 		// fxml load
 		System.setProperty("prism.lcdtext", "false"); // ¾ÈƼ¾Ù¸®¾î½Ì (Font ºÎµå·´°Ô)
 
-		String[] fontFiles = new File("./src/main/resources/font").list();
-		for(String font : fontFiles) {
-			Font.loadFont(getClass().getResourceAsStream("./src/main/resources/font/" + font), 10);
-		}
-
-		FXMLLoader homeloader = new FXMLLoader();
-		homeloader.setLocation(getClass().getResource("/fxml/Home.fxml"));
-		AnchorPane homePane = homeloader.load();
-
-		Scene scene = new Scene(homePane, 1200, 650);
-		scene.getStylesheets().add(getClass().getResource("/css/javaFx.css").toExternalForm());
-
+		Parent root = DependencyInjection.load("/fxml/Home.fxml");
 		primaryStage.setTitle("DB Monitoring Window Program");
-		primaryStage.setScene(scene);
+		primaryStage.setScene(new Scene(root, 1200, 650));
 		primaryStage.show();
-
 	}
 
 	public static void main(String[] args) {
+		if(System.getProperty("resourceBaseDir") == null) {
+			System.setProperty("resourceBaseDir", "");	
+		}
+
 		launch(args);
 	}
+
+	private void setUpDependecyInjector() {
+		// save the factory in the injector
+		DependencyInjection.addInjectionMethod(HomeController.class, param -> {return new HomeController();});
+		DependencyInjection.addInjectionMethod(LeftMenuController.class, param -> {return new LeftMenuController();});
+	}
 }

src/main/java/root/core/batch/DBCheckBatch.java

@@ -12,7 +12,7 @@ public DBCheckBatch(DBCheckUsecase dbCheckUsecase) {
 	public void startBatchArchiveUsageCheck() {
 		try {
 			this.dbCheckUsecase.printArchiveUsageCheck();
-			this.dbCheckUsecase.writeExcelArchiveUsageCheck();
+		//	this.dbCheckUsecase.writeExcelArchiveUsageCheck();
 			this.dbCheckUsecase.writeCsvArchiveUsage();
 		}catch(Exception e) {
 			e.printStackTrace();

src/main/java/root/core/domain/MonitoringYN.java

@@ -0,0 +1,32 @@
+package root.core.domain;
+
+import java.util.List;
+import java.util.stream.Collectors;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import root.core.domain.enums.MonitoringType;
+
+@AllArgsConstructor
+@Data
+public class MonitoringYN {
+
+	private String monitoringAlias;
+	private List<MonitoringTypeAndYN> monitoringTypeList;
+
+	public MonitoringYN(String monitoringAlias) {
+		this.monitoringAlias = monitoringAlias;
+	}
+
+	public List<MonitoringType> getDistinctMonitoringTypes() {
+		return monitoringTypeList.stream().map(type -> type.getMonitoringType()).distinct()
+				.collect(Collectors.toList());
+	}
+
+	@AllArgsConstructor
+	@Data
+	public static class MonitoringTypeAndYN {
+		private MonitoringType monitoringType;
+		private boolean isMonitoring;
+	}
+}

src/main/java/root/core/domain/enums/MonitoringType.java

@@ -0,0 +1,18 @@
+package root.core.domain.enums;
+
+import lombok.Getter;
+
+@Getter
+public enum MonitoringType {
+
+	ARCHIVE("DB", "Archive"), TABLE_SPACE("DB", "TableSpace"), ASM_DISK("DB", "ASM Disk"), OS_DISK("SERVER", "OS Disk"),
+	ALERT_LOG("SERVER", "Alert Log");
+
+	private String category;
+	private String name;
+
+	MonitoringType(String category, String name) {
+		this.category = category;
+		this.name = name;
+	}
+}

src/main/java/root/core/domain/enums/RoundingDigits.java

@@ -0,0 +1,37 @@
+package root.core.domain.enums;
+
+import java.util.Collections;
+import java.util.Map;
+import java.util.Optional;
+import java.util.function.Function;
+import java.util.stream.Collectors;
+import java.util.stream.Stream;
+
+import lombok.Getter;
+
+@Getter
+public enum RoundingDigits {
+
+	ONE(1), TWO(2), THREE(3), FOUR(4), FIVE(5);
+
+	private int digits;
+
+	private RoundingDigits(int digits) {
+		this.digits = digits;
+	}
+
+	private static final Map<Integer, RoundingDigits> roundingDigitsMap = Collections.unmodifiableMap(
+			Stream.of(values()).collect(Collectors.toMap(RoundingDigits::getDigits, Function.identity())));
+
+	public static RoundingDigits find(final int digits) {
+		return Optional.ofNullable(roundingDigitsMap.get(digits)).orElse(TWO);
+	}
+
+	public static RoundingDigits find(final String digits) {
+		try {
+			return find(Integer.parseInt(digits));
+		} catch (NumberFormatException e) {
+			return TWO;
+		}
+	}
+}

src/main/java/root/core/repository/constracts/PropertyRepository.java

@@ -51,6 +51,8 @@ public interface PropertyRepository {
 
 	String getLastUseMonitoringPresetName();
 
+	String getLastUseMonitoringPresetName(String filePath);
+
 	String[] getMonitoringDBNames();
 
 	String[] getMonitoringServerNames();
@@ -59,9 +61,11 @@ public interface PropertyRepository {
 
 	void createNewPropertiesFile(String filePath, String type);
 
-	List<JdbcConnectionInfo> getJdbcConnectionMap();
-
-	List<JschConnectionInfo> getJschConnectionMap();
+	JdbcConnectionInfo getJdbcConnectionInfo(String dbName);
 
-	Map<String, AlertLogCommand> getAlertLogCommandMap();
+	JschConnectionInfo getJschConnectionInfo(String serverName);
+	
+	AlertLogCommand getAlertLogCommand(String serverName);
+	
+	String getMonitoringConfigResource(String key);
 }