|
@@ -34,6 +34,8 @@ import java.text.SimpleDateFormat;
|
|
|
import java.util.HashMap;
|
|
|
import java.util.List;
|
|
|
import java.util.Map;
|
|
|
+import java.util.stream.Collectors;
|
|
|
+import java.util.stream.Stream;
|
|
|
|
|
|
@Data
|
|
|
@Component
|
|
@@ -90,6 +92,26 @@ public class FiveGPmTask {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
+ @XxlJob("pm5gRestHandler")
|
|
|
+ public void pm5gRestHandler() {
|
|
|
+ // 读取目标文件夹下的文件
|
|
|
+ try (Stream<Path> stream = Files.list(Paths.get(distinctTargetDir))) {
|
|
|
+ List<Path> pathList = stream.collect(Collectors.toList());
|
|
|
+ log.info("pathList: {}", pathList);
|
|
|
+ XxlJobHelper.log("pathList: {}", pathList);
|
|
|
+ for (Path t : pathList) {
|
|
|
+ String filename = t.getFileName().toString();
|
|
|
+ log.info("file: {}", filename);
|
|
|
+ XxlJobHelper.log("file: {}", filename);
|
|
|
+ gpload(filename);
|
|
|
+ }
|
|
|
+ } catch (Exception e) {
|
|
|
+ log.error("发生异常了: {}", e.getMessage(), e);
|
|
|
+ XxlJobHelper.log("发生异常了: {}", e.getMessage(), e);
|
|
|
+ XxlJobHelper.handleFail(e.getMessage());
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
/**
|
|
|
* 单一任务
|
|
|
*
|