From 31cbf4da86ba14f72b0814b052e7192654bf55b7 Mon Sep 17 00:00:00 2001
From: ham sangki <sangkiham@naver.com>
Date: Tue, 2 Apr 2024 09:15:48 +0900
Subject: [PATCH] 2024-04-02

---
 src/main/java/com/batch/controller/JobController.java | 19 +++++++++++++++++++
 src/main/java/com/batch/service/JobService.java       | 20 ++++++++++----------
 2 files changed, 29 insertions(+), 10 deletions(-)

diff --git a/src/main/java/com/batch/controller/JobController.java b/src/main/java/com/batch/controller/JobController.java
index f910d8a..d9899fe 100644
--- a/src/main/java/com/batch/controller/JobController.java
+++ b/src/main/java/com/batch/controller/JobController.java
@@ -35,6 +35,25 @@ public class JobController {
     @Autowired
     private MatchingInnerDelingMapper matchingInnerDelingMapper;
     
+    
+    
+    
+    /**
+     * TODO : AI 서버에 특정 경로에 생성되는 파일을 읽는(끝에 50줄 정도) API 
+     * */
+    @PostMapping("/readlogs")
+    public StringBuffer readLogs( @RequestBody Map<String, String> params) throws Exception {
+		StringBuffer sb = new StringBuffer();
+		
+		String filePath  = params.get("filePath");
+		int readCnt  = Integer.parseInt(params.get("readCnt"));
+		
+    	sb = FileUtil.readFileLastLines(filePath, readCnt, "ISO-8859-1", "UTF-8");
+
+    	log.info("sb ===");
+    	log.info(sb.toString());
+		return sb;
+    }
 
     @PostMapping("/create")
     public Map<String, String> createJob( @RequestBody Map<String, String> params) throws Exception {
diff --git a/src/main/java/com/batch/service/JobService.java b/src/main/java/com/batch/service/JobService.java
index c93a096..a14f6aa 100644
--- a/src/main/java/com/batch/service/JobService.java
+++ b/src/main/java/com/batch/service/JobService.java
@@ -139,8 +139,8 @@ public class JobService {
     	
     	String sThreadName = Thread.currentThread().getName();
     	long startTime = System.currentTimeMillis();
-    	log.info("[" + sThreadName + "]Job Started : " + startTime);
-    	log.debug("[" + sThreadName + "]params=" + paramRec.toString());
+    	log.info("extra [" + sThreadName + "]Job Started : " + startTime);
+    	log.debug("extra [" + sThreadName + "]params=" + paramRec.toString());
 
     	MatchingExtraProcessorAuto matchingExtraProcessorAuto = new MatchingExtraProcessorAuto(matchingInnerDelingMapper);
     	
@@ -201,8 +201,8 @@ public class JobService {
 
     	
     	long startTime = System.currentTimeMillis();
-    	log.info("Job Started : " + startTime);
-    	log.debug("params=" + paramRec.toString());
+    	log.info("ai Job Started : " + startTime);
+    	log.debug("ai Job params=" + paramRec.toString());
     	
     	String sSysSe = (String) paramRec.get("sys_se");
     	String sAccnutYm = (String) paramRec.get("accnut_ym");
@@ -224,14 +224,14 @@ public class JobService {
 	        .execute();   	
      	
     	long endTime = System.currentTimeMillis();
-    	log.info("Job Ended: " + endTime);
-    	log.info("Running Time : " + (endTime - startTime) + "ms");
+    	log.info("ai Job Ended: " + endTime);
+    	log.info("ai Job Running Time : " + (endTime - startTime) + "ms");
 
     	
-    	//작업종료에 대한 로그 업데이트
-    	paramLog.put("exit_code", "0");
-    	paramLog.put("exit_message", "");    	
-    	matchingInnerDelingMapper.finishUserJob(paramLog);
+//    	//작업종료에 대한 로그 업데이트
+//    	paramLog.put("exit_code", "0");
+//    	paramLog.put("exit_message", "");    	
+//    	matchingInnerDelingMapper.finishUserJob(paramLog);
     	
     }
     
--
libgit2 0.21.4