@@ -72,9 +72,11 @@ public class FtpUtil {
// 获取目录下的文件列表
List<String> fileList = ftp.ls(dir);
- // 下载目录下的文件
+ // 下载目录下的文件,下载完成后删除
for (String fileName : fileList) {
ftp.download(dir + fileName, FileUtil.file(localDir, fileName));
+ //TODO 先不删除
+ //ftp.delFile(dir + fileName);
}
return true;
} catch (Exception e) {
@@ -141,7 +141,11 @@ public class OutProcessServiceImpl extends OutBaseService implements IOutProcess
*/
@Override
public void deleteFtpFile() {
-
+ //TODO 需要了解怎么弄才行
+ String fgapInfo = sysConfigService.selectConfigByKey("out.fgap.info");
+ String syncDir = syncDIr();
+ FtpUtil ftpUtil = JSONObject.parseObject(fgapInfo, FtpUtil.class);
+ ftpUtil.delete();
/**