forked from demo/example
You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
51 lines
1.5 KiB
51 lines
1.5 KiB
6 years ago
|
package com.fr.output;
|
||
|
|
|
||
|
|
import com.fr.schedule.base.bean.output.OutputClass;
|
||
|
|
import com.fr.schedule.base.bean.output.OutputFtp;
|
||
|
|
import com.fr.schedule.base.constant.ScheduleConstants;
|
||
|
|
import com.fr.schedule.feature.output.FTPHandler;
|
||
|
|
import com.fr.schedule.feature.output.OutputActionHandler;
|
||
|
|
import com.fr.stable.Filter;
|
||
|
|
|
||
|
|
import java.util.ArrayList;
|
||
|
|
import java.util.List;
|
||
|
|
import java.util.Map;
|
||
|
|
|
||
|
|
public class FTPUpload extends OutputActionHandler<OutputClass> {
|
||
|
|
|
||
|
|
private FTPHandler handler = new FTPHandler();
|
||
|
|
|
||
|
|
@Override
|
||
|
|
public void doAction(OutputClass action, Map<String, Object> map) throws Exception {
|
||
|
|
OutputFtp ftp = new OutputFtp();
|
||
|
|
ftp.setServerAddress("192.168.1.45");
|
||
|
|
ftp.setPort(String.valueOf(21));
|
||
|
|
ftp.setSavePath("test");
|
||
|
|
ftp.setUsername("admin");
|
||
|
|
ftp.setPassword("123456");
|
||
|
|
|
||
|
|
action(ftp, map, new Filter<String>() {
|
||
|
|
@Override
|
||
|
|
public boolean accept(String s) {
|
||
|
|
// TODO: 2018/8/23 过滤
|
||
|
|
return true;
|
||
|
|
}
|
||
|
|
});
|
||
|
|
}
|
||
|
|
|
||
|
|
|
||
|
|
private void action(OutputFtp ftp, Map<String, Object> map, Filter<String> filter) throws Exception {
|
||
|
|
|
||
|
|
String[] files = (String[]) map.get(ScheduleConstants.OUTPUT_FILES);
|
||
|
|
List<String> fileList = new ArrayList<String>();
|
||
|
|
for (String file : files) {
|
||
|
|
if (filter.accept(file)) {
|
||
|
|
fileList.add(file);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
map.put(ScheduleConstants.OUTPUT_FILES, fileList.toArray(new String[0]));
|
||
|
|
|
||
|
|
handler.doAction(ftp, map);
|
||
|
|
}
|
||
|
|
|
||
|
|
}
|