주석 보완

src/main/java/cokr/xit/interfaces/filejob/JobConf.java

@@ -12,9 +12,29 @@ import cokr.xit.foundation.AbstractComponent;
 import cokr.xit.foundation.Assert;
 import cokr.xit.foundation.data.JSON;
 
-/**파일 작업을 위한 설정 정보.
- * <p>설정 정보는 conf/file-job.conf 파일의 내용을 읽어 적재한다.
- *
+/**파일 작업을 위한 설정 정보. 설정 정보는 conf/file-job.conf 파일의 내용을 읽어 적재한다.
+ * <p>file-job.conf의 설정 정보는 JSON 형식으로 정의하며 다음과 같은 구조를 갖는다.
+ * <pre><code> {
+ *   "dirs": {    //용도별 최상위 디렉토리 경로
+ *     "receive": "수신 파일 최상위 디렉토리",
+ *     "send": "전송 파일 최상위 디렉토리",
+ *     "working": "파일 작업 최상위 디렉토리",
+ *     "success": "작업을 완료한 파일의 최상위 디렉토리",
+ *     "fail": "작업 실패한 파일의 최상위 디렉토리"
+ *   },
+ *   "dirCodes": { // 기관별 디렉토리 코드
+ *     "기관1 키": "기관1 코드",
+ *     "기관2 키": "기관2 코드",
+ *     ...
+ *   },
+ *   "jobs": [    // 작업별 설정 정보
+ *     {
+ *       "name": "작업 이름",
+ *       "dirCode": "기관별 디렉토리 코드, dicCodes에 설정한 키를 설정",
+ *       ... //작업별 설정 정보(key-value pair)
+ *     },
+ *   ]
+ * }</code></pre>
  * @author mjkhan
  */
 public class JobConf extends AbstractComponent {
@@ -84,10 +104,17 @@ public class JobConf extends AbstractComponent {
 		return ifEmpty(dirCodes != null ? dirCodes.get(key) : null, "");
 	}
 
+	/**key와 매핑한 디렉토리 코드를 설정한다.
+	 * @param dirCodes 디렉토리 코드
+	 */
 	public void setDirCodes(Map<String, String> dirCodes) {
 		this.dirCodes = dirCodes;
 	}
 
+	/**지정한 key에 해당하는 작업 설정 정보를 반환한다.
+	 * @param key 작업 설정 정보를 반환한다.
+	 * @return key에 해당하는 작업 설정 정보
+	 */
 	public Map<String, String> getJob(String key) {
 		if (jobMap == null) {
 			if (jobs == null)
@@ -99,10 +126,18 @@ public class JobConf extends AbstractComponent {
 		return Assert.ifEmpty(jobMap.get(key), Collections::emptyMap);
 	}
 
+	/**key와 매핑한 작업 설정 정보를 지정한다.
+	 * @param jobs key와 매핑한 작업 설정 정보
+	 */
 	public void setJobs(List<Map<String, String>> jobs) {
 		this.jobs = jobs;
 	}
 
+	/**지정한 이름의 작업 정보 중 key에 해당하는 값을 반환한다.
+	 * @param jobName 작업 이름
+	 * @param key 설정 정보 키
+	 * @return 지정한 이름의 작업 정보 중 key에 해당하는 값
+	 */
 	public String getJobConf(String jobName, String key) {
 		Map<String, String> job = getJob(jobName);
 		return Assert.ifEmpty(job.get(key), () -> getDefault(key));
@@ -112,12 +147,28 @@ public class JobConf extends AbstractComponent {
 		return String.join(File.separator, str);
 	}
 
+	/**지정한 이름의 작업이 파일을 읽거나 쓰기 위한 최상위 디렉토리의 경로를 반환한다.
+	 * @param jobName 작업 이름
+	 * @param dir 디렉토리 종류
+	 * <ul><li>receive - 수신 파일 디렉토리</li>
+	 *     <li>send - 전송 파일 디렉토리</li>
+	 * </ul>
+	 * @return 파일을 읽거나 쓰기 위한 최상위 디렉토리
+	 */
 	public String getDir(String jobName, String dir) {
 		String org = getJob(jobName).get("dirCode");
 		String code = getDirCode(org);
 		return path(getDir(dir), code);
 	}
 
+	/**지정한 이름의 작업이 작업 중 사용하는 디렉토리의 경로를 반환한다.
+	 * @param jobName 작업 이름
+	 * @param dir 디렉토리 종류
+	 * <ul><li>receive - 수신 파일 작업 디렉토리</li>
+	 *     <li>send - 전송 파일 작업 디렉토리</li>
+	 * </ul>
+	 * @return 작업 중 사용하는 디렉토리의 경로
+	 */
 	public String getWorkingDir(String jobName, String dir) {
 		String org = getJob(jobName).get("dirCode");
 		String code = getDirCode(org);
@@ -127,6 +178,10 @@ public class JobConf extends AbstractComponent {
 */
 	}
 
+	/**지정한 이름의 작업이 성공한 파일을 위치할 디렉토리 경로를 반환한다.
+	 * @param jobName 작업 이름
+	 * @return 작업이 성공한 파일을 위치할 디렉토리 경로
+	 */
 	public String getSuccessDir(String jobName) {
 		String org = getJob(jobName).get("dirCode");
 		String code = getDirCode(org);
@@ -136,6 +191,10 @@ public class JobConf extends AbstractComponent {
 */
 	}
 
+	/**지정한 이름의 작업이 실패한 파일을 위치할 디렉토리 경로를 반환한다.
+	 * @param jobName 작업 이름
+	 * @return 작업이 실패한 파일을 위치할 디렉토리 경로
+	 */
 	public String getFailDir(String jobName) {
 		String org = getJob(jobName).get("dirCode");
 		String code = getDirCode(org);

src/main/java/cokr/xit/interfaces/filejob/package-info.java

@@ -1,3 +1,4 @@
-/**파일의 수신과 전송을 위한 작업의 설정을 지원하는 클래스를 정의한다.
+/**파일의 수신과 전송을 위한 작업을 지원하는 service와 bean 클래스를 정의한다.
+ * <p>파일 작업을 정의하는 클래스들은 작업에 필요한 정보를 {@link JobConf conf/file-job.conf}에 정의해야 한다.
  */
 package cokr.xit.interfaces.filejob;

src/main/java/cokr/xit/interfaces/filejob/service/bean/FileJobBean.java

@@ -4,16 +4,16 @@ import java.io.File;
 import java.nio.file.Files;
 import java.nio.file.Path;
 import java.nio.file.Paths;
+import java.util.Collections;
 import java.util.HashMap;
 import java.util.List;
 import java.util.function.Predicate;
-import java.util.stream.Collectors;
 import java.util.stream.Stream;
 
 import cokr.xit.foundation.AbstractComponent;
 import cokr.xit.interfaces.filejob.JobConf;
 
-/**파일 작업을 수행하는 클래스가 상속하는 베이스 클래스
+/**파일 작업을 수행하는 Bean이 상속하는 베이스 클래스
  * @author mjkhan
  */
 public abstract class FileJobBean extends AbstractComponent {
@@ -142,6 +142,12 @@ public abstract class FileJobBean extends AbstractComponent {
 			this.cause = rootCause(cause);
 			return setSuccess(this.cause == null);
 		}
+
+		public static List<Path> getPaths(List<FileStatus> fileStatus) {
+			return !isEmpty(fileStatus) ?
+				fileStatus.stream().map(FileStatus::getPath).toList() :
+				Collections.emptyList();
+		}
 	}
 
 	/**수신 파일의 최상위 디렉토리 경로를 반환한다.
@@ -201,7 +207,7 @@ public abstract class FileJobBean extends AbstractComponent {
 	 */
 	protected List<Path> getFilePaths(String dir, Predicate<Path> filter) {
 		try (Stream<Path> walk = Files.list(Paths.get(dir))) {
-			return walk.filter(ifEmpty(filter, path -> true)).collect(Collectors.toList());
+			return walk.filter(ifEmpty(filter, path -> true)).toList();
 		} catch (Exception e) {
 			throw runtimeException(e);
 		}
@@ -237,15 +243,19 @@ public abstract class FileJobBean extends AbstractComponent {
 	}
 
 	/**수신 디렉토리의 파일들을 작업 디렉토리로 이동하고, 경로를 반환한다.
+	 * @param filter 작업 대상 파일에 적용할 필터. 지정하지 않으면 모든 파일을 이동한다.
 	 * @return 수신 작업 디렉토리의 파일 경로 목록
 	 */
-	protected List<Path> getReceivedFilePaths() {
+	protected List<Path> getReceivedFilePaths(Predicate<Path> filter) {
 		String receiveDir = receiveDir(),
 			   workingDir = receiveWorkingDir();
+		Predicate<Path> test = ifEmpty(filter, Files::isRegularFile);
+
+		List<Path> paths = getFilePaths(receiveDir, test);
+		if (paths.isEmpty()) return Collections.emptyList();
 
-		List<Path> paths = getFilePaths(receiveDir, Files::isRegularFile);
 		move(paths, workingDir);
 
-		return getFilePaths(workingDir, null);
+		return getFilePaths(workingDir, test);
 	}
 }

src/main/resources/conf/file-job.conf

@@ -0,0 +1,51 @@
+{
+	"dirs": {
+		"receive": "C:\\workspace\\ESB_AGENT\\RCV",         /* 수신 파일 최상위 디렉토리 */
+		"send": "C:\\workspace\\ESB_AGENT\\SND",            /* 전송 파일 최상위 디렉토리 */
+
+		"working": "C:\\workspace\\xit\\filesite\\work",    /* 파일 작업 최상위 디렉토리 */
+		"success": "C:\\workspace\\xit\\filesite\\success", /* 작업 완료한 파일의 최상위 디렉토리 */
+		"fail": "C:\\workspace\\xit\\filesite\\fail"        /* 작업 실패한 파일의 최상위 디렉토리 */
+	},
+
+	"dirCodes": {
+		"smg": "CG131000000768",                            /* 국민신문고 기관코드 */
+		"epost": "CG144523401150"                           /* epost 기관코드 */
+	},
+
+	"defaults": {
+		"charset": "euc-kr",
+		"fetchSize": 100
+	},
+
+	"jobs": [
+		{	/* 국민신문고 수신 */
+			"name": "smg-in",
+			"dirCode": "smg", /* <-- dirCodes */
+			"infoType": "100",
+			"alert": "http://localhost:8080/xit-filegate/api/smg/petition/receive.do" /* 업무 통보 url */
+		},
+		{	/* 국민신문고 전송 */
+			"name": "smg-out",
+			"dirCode": "smg", /* <-- dirCodes */
+			"alert": "http://localhost:8080/xit-filegate/api/smg/petition/reply.do"   /* 업무 통보 url */
+		},
+
+		{   /* epost 전자우편 신청 전송 */
+			"name": "epost-send-request",
+			"dirCode": "epost", /* <-- dirCodes */
+			
+			"conOrg": "YICT",    /* 외부기관 구분코드 */
+			"rceptId": "40219",  /* 접수우체국 국기호 */
+			"attachmentDir": "", /* 원본 첨부파일 디렉토리 경로 */
+			
+			"txtFilename": "POSDF5$send_{yyyyMMddHHmmssSSS}.txt",
+			"zipFilename": "POSDF5${conKey}.zip"
+		},
+
+		{   /* epost 전자우편 신청 수신 결과 */
+			"name": "epost-receive-result",
+			"dirCode": "epost" /* <-- dirCodes */
+		}
+	]
+}