diff --git a/src/main/java/cokr/xit/interfaces/smg/service/bean/SmgInBean.java b/src/main/java/cokr/xit/interfaces/smg/service/bean/SmgInBean.java index d2ce163..02ed10d 100644 --- a/src/main/java/cokr/xit/interfaces/smg/service/bean/SmgInBean.java +++ b/src/main/java/cokr/xit/interfaces/smg/service/bean/SmgInBean.java @@ -76,27 +76,21 @@ public class SmgInBean extends FileJobBean { alert(interfaceSequences); if (!isEmpty(fileStatus)) - move( - fileStatus.stream().map(FileStatus::getPath).collect(Collectors.toList()), - successDir() - ); + move(FileStatus.getPaths(fileStatus), successDir()); fileStatus = received.get(false); if (!isEmpty(fileStatus)) - move( - fileStatus.stream().map(FileStatus::getPath).collect(Collectors.toList()), - failDir() - ); + move(FileStatus.getPaths(fileStatus), failDir()); return interfaceSequences; } private List parse() { String infoType = config("infoType"); - List paths = getReceivedFilePaths(); + List paths = getReceivedFilePaths(null); return paths.stream() .map(path -> parse(infoType, path)) - .collect(Collectors.toList()); + .toList(); } private FileStatus parse(String infoType, Path path) {