2024-04-02 이전변경파일 복구

함상기
1 parent 31cbf4da
Showing 3 changed files with 85 additions and 17 deletions Show diff stats
src/main/java/com/batch/controller/JobController.java
src/main/java/com/batch/util/FileUtil.java
src/main/java/com/batch/util/StatisticsUtil.java
@@ -17,12 +17,10 @@ import org.springframework.web.bind.annotation.RestController;
 import com.batch.config.MatchingSetup;
 import com.batch.config.MatchingSetup.Matching;
 import com.batch.mapper.primary.MatchingInnerDelingMapper;
-import com.batch.mapper.secondary.OracleMapper;
 import com.batch.service.JobService;
 import com.batch.util.FileUtil;
 import com.google.gson.JsonObject;
  
-import com.batch.controller.JobController;
 import lombok.extern.slf4j.Slf4j;
  
 @RestController
 package com.batch.util;
  
 import java.io.BufferedReader;
+import java.io.IOException;
 import java.io.InputStreamReader;
+import java.io.RandomAccessFile;
  
 import org.springframework.core.io.ClassPathResource;
  
@@ -12,27 +14,85 @@ import com.google.gson.JsonParser;
 public class FileUtil {
  
 	public static StringBuffer readFileToString(String resourceName) {
-        StringBuffer sb = new StringBuffer();
-        try {
+		StringBuffer sb = new StringBuffer();
+		try {
 			ClassPathResource resource = new ClassPathResource(resourceName);
-	        BufferedReader br = new BufferedReader(new InputStreamReader(resource.getInputStream()));
-	
-	        // br.readLine() 이 null 인지 검사할 때 한번 사용되므로 String 에 먼저 저장해둬야한다.
-	        String s = "";
-            while((s = br.readLine()) != null){
-            	sb.append(s);
-            }		
-        } catch (Exception e) {
-        	sb.append(e.getStackTrace());
-        }
-        return sb;
+			BufferedReader br = new BufferedReader(new InputStreamReader(resource.getInputStream()));
+
+			// br.readLine() 이 null 인지 검사할 때 한번 사용되므로 String 에 먼저 저장해둬야한다.
+			String s = "";
+			while ((s = br.readLine()) != null) {
+				sb.append(s);
+			}
+		} catch (Exception e) {
+			sb.append(e.getStackTrace());
+		}
+		return sb;
+	}
+
+	/**
+	 * 파일 마지막 부터 lineCnt행 읽기
+	 * @param resourceName
+	 * @param lineCnt
+	 * @return
+	 */
+	public static StringBuffer readFileLastLines(String resourceName, int lineCnt, String fEnc, String toEnc) {
+		StringBuffer sb = new StringBuffer();
+
+//		lineCnt = 50; // test case
+//		resourceName = "D://logs/localhost_access_log.2019-03-26.txt"; // test case
+		
+		if(resourceName == null || resourceName.isEmpty()) {
+			sb.append("파일 경로가 입력되지 않았습니다.");
+		}else if(lineCnt < 1) {
+			sb.append("라인갯수가 입력되지 않았습니다.");
+		}else {
+			RandomAccessFile rf = null;
+		
+			try {
+				
+				rf = new RandomAccessFile(resourceName, "r");
+				long len = rf.length();
+				for (long i = len - 1; i >= 0; i--) {
+					rf.seek(i);
+					char c = (char) rf.read();
+					if (c == '\n') {
+						lineCnt--;
+						if(lineCnt < 0) {
+							break;
+						}
+					}
+					
+					sb.insert(0, c);
+				}
+				
+				/*** 필요 시 파일 인코딩. utf-8 **/
+				if(fEnc != null && !fEnc.isBlank() && toEnc != null && !toEnc.isBlank()) {
+					sb = new StringBuffer(new String((sb.toString()).getBytes(fEnc), toEnc));
+				}
+
+			} catch (Exception e) {
+//				e.printStackTrace();
+				sb = new StringBuffer("유효한 파일경로가 아닙니다.("+resourceName+")");
+			} finally {
+				if (rf != null) {
+					try {
+						rf.close();
+					} catch (IOException e) {
+//						e.printStackTrace();
+						sb = new StringBuffer("유효한 파일경로가 아닙니다.("+resourceName+")");
+					}
+				}
+			}
+		}
+		return sb;
 	}
  
 	public static JsonObject strToJsonObj(String jsonString) {
 		JsonObject jsonObject = JsonParser.parseString(jsonString).getAsJsonObject();
 		return jsonObject;
 	}
-	
+
 	public static Object strToObj(String jsonString, Class<?> anyClass) {
 		Gson gson = new Gson();
 		Object convertedObject = gson.fromJson(jsonString, anyClass);
@@ -44,5 +104,5 @@ public class FileUtil {
 		String stringObject = gson.toJson(obj);
 		return stringObject;
 	}
-	
+
 }
@@ -25,6 +25,16 @@ public class StatisticsUtil {
 //		log.info("resultAll=" + resultAll.toString());
 //	}
  
+	private static long mtch_num = 0;
+	
+	public static long getMtchNum() {
+		return ++mtch_num;
+	}
+
+	public static void initMtchNum() {
+		mtch_num = 0;
+	}
+	
 	/**
 	 * 조합 구하기
 	 *