|
@@ -124,20 +124,6 @@ public class InProcessServiceImpl extends InBaseService implements IInProcessSer
|
|
|
System.err.println("这个是错误滴" + desc.toString());
|
|
|
}
|
|
|
}
|
|
|
-
|
|
|
-//
|
|
|
-// // 判断File对象对应的目录是否存在
|
|
|
-// String[] names = file.list();
|
|
|
-// // 获得目录下的所有文件的文件名
|
|
|
-// for (String name : names) {
|
|
|
-// if (name.startsWith("base_")) {
|
|
|
-// File baseFile = new File(syncDir + name);
|
|
|
-// ObjectMapper mapper = new ObjectMapper();
|
|
|
-// IndexDO ido = mapper.readValue(baseFile, IndexDO.class);
|
|
|
-//
|
|
|
-// }
|
|
|
-// //输出文件名
|
|
|
-// }
|
|
|
}
|
|
|
} catch (Exception e) {
|
|
|
log.error("处理es出错啦:", e.getMessage());
|