.

함상기
1 parent 7eae5008
Showing 2 changed files with 13 additions and 2 deletions Show diff stats
src/main/java/com/batch/service/JobService.java
src/main/resources/mybatis/primaryMapper/MatchingInnerDelingMapper.xml
@@ -53,6 +53,9 @@ public class JobService {
  
 	@Value("${matching.auto.exceptListByComma}")
 	String sExceptMatchType;
+
+	@Value("${thread.ai.count}")
+	BigDecimal bdAiAsyncCount;
  
 	@Value("${thread.ai.count.rowmax}")
 	BigDecimal bdAiAsyncMaxRowCount;
@@ -312,6 +315,7 @@ public class JobService {
     	matchingInnerDelingMapper.createUserJob(paramLog);
  
     	List<ThreadAiMatching> lThread = new ArrayList<ThreadAiMatching>();
+    	BigDecimal bdTotalThread = BigDecimal.ZERO;
     	for(Map curMap : retData) {
     		Map<String, Object> curMParams = new HashMap<String, Object>();
     		curMParams.putAll(curMap);
@@ -328,10 +332,12 @@ public class JobService {
     				sPythonAiTarget
     		);
     		threadAiMatching.start();
+    		bdTotalThread = bdTotalThread.add(BigDecimal.ONE);
  
     		//전체카운트가 처리가능카운트를 넘어설때
-    		if (bdCurrentRowCount.compareTo(bdAiAsyncMaxRowCount) > -1) {
+    		if (bdCurrentRowCount.compareTo(bdAiAsyncMaxRowCount) > -1 || bdTotalThread.compareTo(bdAiAsyncCount) > -1) {
     			bdCurrentRowCount = BigDecimal.ZERO;
+    			bdTotalThread = BigDecimal.ZERO;
  
     			//현재 작업그룹이 종료가 되었는지 체크해서 종료시 카운트 초기화 하고 다음작업을 한다.
     	    	boolean blnStatus = true;
@@ -340,8 +346,10 @@ public class JobService {
     	    	do {
 	    	    	Map<String, Object> mParam = new HashMap<String, Object>();
 	    	    	mParam.put("userJobGroup", jobGroupId);
+	    	    	mParam.put("exceptJobId", sDate);  // 메인 User Job Id 제외	    	
 	    	    	List<Map> lmJob = matchingInnerDelingMapper.getUserJobStatus(mParam);
 	    	    	for (Map curJob : lmJob) {
+	    	    		blnStatus = true;
 	    	    		String ScurStatus = (String) curJob.get("status"); 
 	    	    		if (!"Finished".equalsIgnoreCase(ScurStatus)) {
 	    	    			blnStatus = false;	    	    			
@@ -350,7 +358,7 @@ public class JobService {
 	    	    			break;
 	    	    		}
 	    	    	}
-    	    	} while (!blnStatus && iTotalWait < bdAiAsyncTotalWaitTime.intValue());  //전체 기다리는 시간까지 체크  
+    	    	} while (!blnStatus && iTotalWait < (bdAiAsyncTotalWaitTime.intValue() * 1000));  //전체 기다리는 시간까지 체크  
     	    	log.info("Next Thread Group Processing");
     		}
     	}
@@ -659,6 +659,9 @@
 		    public.batch_user_job_status
 		WHERE
 			user_job_group = #{userJobGroup}
+			<if test='exceptJobId != null  and !exceptJobId.equals("")'>
+				and user_job_id != #{exceptJobId}
+			</if>									
 		ORDER BY 
 			user_job_id ASC
 	</select>