2024-04-02

함상기
1 parent d3e8a8a9
Showing 2 changed files with 29 additions and 10 deletions Show diff stats
src/main/java/com/batch/controller/JobController.java
src/main/java/com/batch/service/JobService.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 {
@@ -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);
  
     }