ftpServer

README.md

@@ -1,5 +1,11 @@
# BaobaotangProbe
FTP主目录 /tmp/ftp
mkdir -p /tmp/ftp
chmod 777 /tmp/ftp
MIAOZHEN Log Reporter process
## 依赖

src/main/java/com/miaozhen/TestController.java

@@ -5,10 +5,8 @@ import com.miaozhen.tmssys.dto.CinemaInfo;
import com.miaozhen.tmssys.dto.Ftp;
import com.miaozhen.util.DateUtil;
import com.miaozhen.util.FileUtils;
import com.miaozhen.bean.ConfigBean;
import com.miaozhen.util.MD5Utils;
import net.sf.json.JSONObject;
import org.apache.commons.codec.digest.DigestUtils;
import org.springframework.boot.context.properties.EnableConfigurationProperties;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
@@ -22,85 +20,31 @@ import java.util.Date;
@Controller
@RequestMapping(value = "/api")
@EnableConfigurationProperties({ ConfigBean.class })
public class TestController {
    @Resource
    private ConfigBean configBean;
    @RequestMapping("test1")
    @ResponseBody
    public String test1(@RequestParam("serverType") String serverType) throws IOException {
//        FileUtils.connectSftp(configBean.getSftpHost(),configBean.getSftpPort(),configBean.getSftpaeUser(),configBean.getSftpaePassword());
//        //传输给MSM。
//        String sftpMsmDir=configBean.getSftpMsmDir()+LocalDate.now().toString()+"/serviceType";
//        boolean success=FileUtils.uploadString("<?xml version=\"1.0\" encoding=\"UTF-8\"?> <response status=\"OK\" version=\"2\">     <playback content_name=\"xiaofang_ADV-2D-24_S_CMN-CMN_CN-G_51-CMN_2K_20190311_OV\"               content_uuid=\"urn:uuid:7ec89ee9-ba5d-4f23-a336-17fa5580bec3\" start_time=\"2019-04-10T09:49:02\"               end_time=\"2019-04-10T09:50:03\">Success     </playback>     <playback content_name=\"FanTanFengBao4-2D_235_JP_98M_51_PTH_0320\"               content_uuid=\"urn:uuid:1b5070ba-4a70-4fb4-b20d-2ade32466c52\" start_time=\"2019-04-10T09:50:03\"               end_time=\"2019-04-10T09:53:06\">Success     </playback>     <playback content_name=\"xiaofang_ADV-2D-24_S_CMN-CMN_CN-G_51-CMN_2K_20190311_OV\"               content_uuid=\"urn:uuid:7ec89ee9-ba5d-4f23-a336-17fa5580bec3\" start_time=\"2019-04-10T12:19:03\"               end_time=\"2019-04-10T12:20:05\">Success     </playback>     <playback content_name=\"FanTanFengBao4-2D_235_JP_98M_51_PTH_0320\"               content_uuid=\"urn:uuid:1b5070ba-4a70-4fb4-b20d-2ade32466c52\" start_time=\"2019-04-10T12:20:05\"               end_time=\"2019-04-10T13:58:43\">Success     </playback>     <playback content_name=\"xiaofang_ADV-2D-24_S_CMN-CMN_CN-G_51-CMN_2K_20190311_OV\"               content_uuid=\"urn:uuid:7ec89ee9-ba5d-4f23-a336-17fa5580bec3\" start_time=\"2019-04-10T14:20:41\"               end_time=\"2019-04-10T14:21:42\">Success     </playback>     <playback content_name=\"Dumbo2019_FTR-1-3D_F_CMN-XX_CN_51-Dbox_2K_DI_20190312_DTB_IOP-3D_OV\"               content_uuid=\"urn:uuid:7b7bce1c-a467-40cc-8451-4756fe16b47b\" start_time=\"2019-04-10T14:21:43\"               end_time=\"2019-04-10T16:13:40\">Success     </playback>     <playback content_name=\"xiaofang_ADV-2D-24_S_CMN-CMN_CN-G_51-CMN_2K_20190311_OV\"               content_uuid=\"urn:uuid:7ec89ee9-ba5d-4f23-a336-17fa5580bec3\" start_time=\"2019-04-10T16:30:39\"               end_time=\"2019-04-10T16:31:40\">Success     </playback>     <playback content_name=\"LaoShiHao_FTR_S_CMN-QMS_51_2K_CFA_20190308_114M_OV\"               content_uuid=\"urn:uuid:767142bd-619c-4af0-8589-3e7c5364c06b\" start_time=\"2019-04-10T16:31:40\"               end_time=\"2019-04-10T18:26:02\">Success     </playback>     <playback content_name=\"xiaofang_ADV-2D-24_S_CMN-CMN_CN-G_51-CMN_2K_20190311_OV\"               content_uuid=\"urn:uuid:7ec89ee9-ba5d-4f23-a336-17fa5580bec3\" start_time=\"2019-04-10T18:30:41\"               end_time=\"2019-04-10T18:31:42\">Success     </playback>     <playback content_name=\"LaoShiHao_FTR_S_CMN-QMS_51_2K_CFA_20190308_114M_OV\"               content_uuid=\"urn:uuid:767142bd-619c-4af0-8589-3e7c5364c06b\" start_time=\"2019-04-10T18:31:43\"               end_time=\"2019-04-10T18:33:30\">Success     </playback>     <playback content_name=\"xiaofang_ADV-2D-24_S_CMN-CMN_CN-G_51-CMN_2K_20190311_OV\"               content_uuid=\"urn:uuid:7ec89ee9-ba5d-4f23-a336-17fa5580bec3\" start_time=\"2019-04-10T20:30:39\"               end_time=\"2019-04-10T20:31:40\">Success     </playback>     <playback content_name=\"TiaoYinShi-2D_235_JP_137M_51_PTH_0312\"               content_uuid=\"urn:uuid:a339ce0e-05fb-46af-9029-d898d9ada947\" start_time=\"2019-04-10T20:31:40\"               end_time=\"2019-04-10T22:45:08\">Success     </playback> </response>",
//                DateUtil.format(new Date(),"yyyy_MM_dd_HH_mm_SS")+".xml",sftpMsmDir);
//        FileUtils.disConnectSftp();
//        System.out.println("hhhh->success="+success);
//        FileUtils.connectSftp(configBean.getSftpHost(), configBean.getSftpPort(), configBean.getSftpaeUser(), configBean.getSftpaePassword());
        CinemaInfo cinemaInfo =new CinemaInfo();
        Ftp ftp=new Ftp();
        ftp.setFtpIP("127.0.0.1");
        cinemaInfo.setFtp(ftp);
        cinemaInfo.setCode("20901928489284");
        String encoding = "UTF-8";
        String logContent="";
        File file = new File(serverType+".xml");
        if (file.isFile() && file.exists()) { //判断文件是否存在
            InputStreamReader read = new InputStreamReader(
                    new FileInputStream(file), encoding);
            BufferedReader bufferedReader = new BufferedReader(read);
            String line;StringBuilder data= new StringBuilder();
            while ((line = bufferedReader.readLine()) != null) {
                data.append(line);
            }
            read.close();
            System.out.println(data);
            logContent=data.toString();
        } else {
            System.out.println("找不到文件");
        }
        //文件夹路径：ooh/yyyy-MM-dd
        String sftpMsmDir = configBean.getSftpMsmDir() + LocalDate.now().toString();
        //文件名字：IP_HH-mm-SS.json
        String fileName = cinemaInfo.getFtp().getFtpIP() + "_" + serverType + "_" + DateUtil.format(new Date(), "HH-mm-SS") + ".json";
        UploadBean bean = new UploadBean();
        bean.setServerType(serverType);
        bean.setServerIp(cinemaInfo.getFtp().getFtpIP());
        bean.setAuditNumber(1);
        bean.setCinemaCode(cinemaInfo.getCode());
        bean.setDate(LocalDate.now().toString());
        bean.setContent(logContent);
        FileUtils.connectSftp(configBean.getSftpHost(), configBean.getSftpPort(), configBean.getSftpaeUser(), configBean.getSftpaePassword());
        //上传
        String content = JSONObject.fromObject(bean).toString();
        boolean success = FileUtils.uploadString(content, fileName, sftpMsmDir);
        //关闭
        FileUtils.disConnectSftp();
        return success+"~"+configBean.toString();
    }
    @RequestMapping("test2")
    @ResponseBody
    public String test2() throws IOException {
       return ""+upLoadSucceedFile();
    }
    @RequestMapping("test3")
    @ResponseBody
    private void postLog(@RequestParam("serverType") String serverType,@RequestParam("content") String content,@RequestParam("cinemaCode") String cinemaCode) throws IOException {
        String ip =  FileUtils.getIp(),date="2021-12-06", dir = "/test/ooh/",deviceIp="192.168.1.2",
        fileName = ip + "_" + deviceIp + "_" + serverType + "_" +
                DateUtil.format(new Date(), "HH-mm-ss-SSS") + "-" + MD5Utils.getUUID() + ".json";
        FileUtils.sendData(content,serverType ,cinemaCode,1,ip,dir+date,fileName,date,"asd");
    }
    public static void main(String[] args) throws IOException {
//    @Resource
//    private ConfigBean configBean;
//    @RequestMapping("test1")
//    @ResponseBody
//    public String test1(@RequestParam("serverType") String serverType) throws IOException {
//
////        FileUtils.connectSftp(configBean.getSftpHost(),configBean.getSftpPort(),configBean.getSftpaeUser(),configBean.getSftpaePassword());
////        //传输给MSM。
////        String sftpMsmDir=configBean.getSftpMsmDir()+LocalDate.now().toString()+"/serviceType";
////        boolean success=FileUtils.uploadString("<?xml version=\"1.0\" encoding=\"UTF-8\"?> <response status=\"OK\" version=\"2\">     <playback content_name=\"xiaofang_ADV-2D-24_S_CMN-CMN_CN-G_51-CMN_2K_20190311_OV\"               content_uuid=\"urn:uuid:7ec89ee9-ba5d-4f23-a336-17fa5580bec3\" start_time=\"2019-04-10T09:49:02\"               end_time=\"2019-04-10T09:50:03\">Success     </playback>     <playback content_name=\"FanTanFengBao4-2D_235_JP_98M_51_PTH_0320\"               content_uuid=\"urn:uuid:1b5070ba-4a70-4fb4-b20d-2ade32466c52\" start_time=\"2019-04-10T09:50:03\"               end_time=\"2019-04-10T09:53:06\">Success     </playback>     <playback content_name=\"xiaofang_ADV-2D-24_S_CMN-CMN_CN-G_51-CMN_2K_20190311_OV\"               content_uuid=\"urn:uuid:7ec89ee9-ba5d-4f23-a336-17fa5580bec3\" start_time=\"2019-04-10T12:19:03\"               end_time=\"2019-04-10T12:20:05\">Success     </playback>     <playback content_name=\"FanTanFengBao4-2D_235_JP_98M_51_PTH_0320\"               content_uuid=\"urn:uuid:1b5070ba-4a70-4fb4-b20d-2ade32466c52\" start_time=\"2019-04-10T12:20:05\"               end_time=\"2019-04-10T13:58:43\">Success     </playback>     <playback content_name=\"xiaofang_ADV-2D-24_S_CMN-CMN_CN-G_51-CMN_2K_20190311_OV\"               content_uuid=\"urn:uuid:7ec89ee9-ba5d-4f23-a336-17fa5580bec3\" start_time=\"2019-04-10T14:20:41\"               end_time=\"2019-04-10T14:21:42\">Success     </playback>     <playback content_name=\"Dumbo2019_FTR-1-3D_F_CMN-XX_CN_51-Dbox_2K_DI_20190312_DTB_IOP-3D_OV\"               content_uuid=\"urn:uuid:7b7bce1c-a467-40cc-8451-4756fe16b47b\" start_time=\"2019-04-10T14:21:43\"               end_time=\"2019-04-10T16:13:40\">Success     </playback>     <playback content_name=\"xiaofang_ADV-2D-24_S_CMN-CMN_CN-G_51-CMN_2K_20190311_OV\"               content_uuid=\"urn:uuid:7ec89ee9-ba5d-4f23-a336-17fa5580bec3\" start_time=\"2019-04-10T16:30:39\"               end_time=\"2019-04-10T16:31:40\">Success     </playback>     <playback content_name=\"LaoShiHao_FTR_S_CMN-QMS_51_2K_CFA_20190308_114M_OV\"               content_uuid=\"urn:uuid:767142bd-619c-4af0-8589-3e7c5364c06b\" start_time=\"2019-04-10T16:31:40\"               end_time=\"2019-04-10T18:26:02\">Success     </playback>     <playback content_name=\"xiaofang_ADV-2D-24_S_CMN-CMN_CN-G_51-CMN_2K_20190311_OV\"               content_uuid=\"urn:uuid:7ec89ee9-ba5d-4f23-a336-17fa5580bec3\" start_time=\"2019-04-10T18:30:41\"               end_time=\"2019-04-10T18:31:42\">Success     </playback>     <playback content_name=\"LaoShiHao_FTR_S_CMN-QMS_51_2K_CFA_20190308_114M_OV\"               content_uuid=\"urn:uuid:767142bd-619c-4af0-8589-3e7c5364c06b\" start_time=\"2019-04-10T18:31:43\"               end_time=\"2019-04-10T18:33:30\">Success     </playback>     <playback content_name=\"xiaofang_ADV-2D-24_S_CMN-CMN_CN-G_51-CMN_2K_20190311_OV\"               content_uuid=\"urn:uuid:7ec89ee9-ba5d-4f23-a336-17fa5580bec3\" start_time=\"2019-04-10T20:30:39\"               end_time=\"2019-04-10T20:31:40\">Success     </playback>     <playback content_name=\"TiaoYinShi-2D_235_JP_137M_51_PTH_0312\"               content_uuid=\"urn:uuid:a339ce0e-05fb-46af-9029-d898d9ada947\" start_time=\"2019-04-10T20:31:40\"               end_time=\"2019-04-10T22:45:08\">Success     </playback> </response>",
////                DateUtil.format(new Date(),"yyyy_MM_dd_HH_mm_SS")+".xml",sftpMsmDir);
////        FileUtils.disConnectSftp();
////        System.out.println("hhhh->success="+success);
////        FileUtils.connectSftp(configBean.getSftpHost(), configBean.getSftpPort(), configBean.getSftpaeUser(), configBean.getSftpaePassword());
//
//        CinemaInfo cinemaInfo =new CinemaInfo();
//        Ftp ftp=new Ftp();
//        ftp.setFtpIP("127.0.0.1");
//        cinemaInfo.setFtp(ftp);
//        cinemaInfo.setCode("20901928489284");
//        String encoding = "UTF-8";
//        File file = new File("Barco.xml");
//        String logContent="";
//
//        File file = new File(serverType+".xml");
//        if (file.isFile() && file.exists()) { //判断文件是否存在
//            InputStreamReader read = new InputStreamReader(
//                    new FileInputStream(file), encoding);
@@ -111,17 +55,70 @@ public class TestController {
//            }
//            read.close();
//            System.out.println(data);
//            logContent=data.toString();
//        } else {
//            System.out.println("找不到文件");
//        }
    }
    private boolean upLoadSucceedFile() {
        //获取到日志则进行上报，连接
        FileUtils.connectSftp(configBean.getSftpHost(), configBean.getSftpPort(), configBean.getSftpaeUser(), configBean.getSftpaePassword());
        //文件夹路径：ooh/yyyy-MM-dd
        String sftpMsmDir = configBean.getSftpMsmDir() + LocalDate.now().toString();
        boolean success = FileUtils.uploadString("", "_success", sftpMsmDir);
        System.out.println("upLoadSucceedFile->"+success);
        //关闭
        FileUtils.disConnectSftp();
        return success;
    }
//        //文件夹路径：ooh/yyyy-MM-dd
//        String sftpMsmDir = configBean.getSftpMsmDir() + LocalDate.now().toString();
//        //文件名字：IP_HH-mm-SS.json
//        String fileName = cinemaInfo.getFtp().getFtpIP() + "_" + serverType + "_" + DateUtil.format(new Date(), "HH-mm-SS") + ".json";
//        UploadBean bean = new UploadBean();
//        bean.setServerType(serverType);
//        bean.setServerIp(cinemaInfo.getFtp().getFtpIP());
//        bean.setAuditNumber(1);
//        bean.setCinemaCode(cinemaInfo.getCode());
//        bean.setDate(LocalDate.now().toString());
//        bean.setContent(logContent);
//        FileUtils.connectSftp(configBean.getSftpHost(), configBean.getSftpPort(), configBean.getSftpaeUser(), configBean.getSftpaePassword());
//        //上传
//        String content = JSONObject.fromObject(bean).toString();
//        boolean success = FileUtils.uploadString(content, fileName, sftpMsmDir);
//        //关闭
//        FileUtils.disConnectSftp();
//
//        return success+"~"+configBean.toString();
//    }
//    @RequestMapping("test2")
//    @ResponseBody
//    public String test2() throws IOException {
//       return ""+upLoadSucceedFile();
//    }
//
//    @RequestMapping("test3")
//    @ResponseBody
//    private void postLog(@RequestParam("serverType") String serverType,@RequestParam("content") String content,@RequestParam("cinemaCode") String cinemaCode) throws IOException {
//        String ip =  FileUtils.getIp(),date="2021-12-06", dir = "/test/ooh/",deviceIp="192.168.1.2",
//        fileName = ip + "_" + deviceIp + "_" + serverType + "_" +
//                DateUtil.format(new Date(), "HH-mm-ss-SSS") + "-" + MD5Utils.getUUID() + ".json";
//        FileUtils.sendData(content,serverType ,cinemaCode,1,ip,dir+date,fileName,date,"asd");
//
//    }
//
//    public static void main(String[] args) throws IOException {
////        String encoding = "UTF-8";
////        File file = new File("Barco.xml");
////        if (file.isFile() && file.exists()) { //判断文件是否存在
////            InputStreamReader read = new InputStreamReader(
////                    new FileInputStream(file), encoding);
////            BufferedReader bufferedReader = new BufferedReader(read);
////            String line;StringBuilder data= new StringBuilder();
////            while ((line = bufferedReader.readLine()) != null) {
////                data.append(line);
////            }
////            read.close();
////            System.out.println(data);
////        }
//    }
//    private boolean upLoadSucceedFile() {
//        //获取到日志则进行上报，连接
//        FileUtils.connectSftp(configBean.getSftpHost(), configBean.getSftpPort(), configBean.getSftpaeUser(), configBean.getSftpaePassword());
//        //文件夹路径：ooh/yyyy-MM-dd
//        String sftpMsmDir = configBean.getSftpMsmDir() + LocalDate.now().toString();
//        boolean success = FileUtils.uploadString("", "_success", sftpMsmDir);
//        System.out.println("upLoadSucceedFile->"+success);
//        //关闭
//        FileUtils.disConnectSftp();
//        return success;
//    }
}

src/main/java/com/miaozhen/bean/ConfigBean.java

@@ -1,113 +0,0 @@
package com.miaozhen.bean;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Profile;
import org.springframework.stereotype.Component;
@Component
@ConfigurationProperties(prefix = "remote")
public class ConfigBean {
	/** ssh 命令格式 */
	private final static String SSH_FORMAT = "%s@%s:%s";
	/**
	 * checkfile 中内容的分隔符
	 */
	public final static String CHECKFILE_CONTENT_SEPARATOR = "\t";
	@Value("${sgm.push_sftp_server.remote.username}")
	private String sftpaeUser;
	@Value("${sgm.push_sftp_server.remote.password}")
	private String sftpaePassword;
	@Value("${sgm.push_sftp_server.remote.host}")
	private String sftpHost;
	@Value("${sgm.push_sftp_server.remote.port}")
	private Integer sftpPort;
	@Value("${sgm.push_sftp_server.bigDataDept.remote.dir}")
	private String sftpMsmDir;
	@Value("${sgm.push_sftp_server.bigDataDept.segment.dir}")
	private String segment;
	@Value("${sgm.push_sftp_server.bigDataDept.error.dir}")
	private String error;
	public static String getSshFormat() {
		return SSH_FORMAT;
	}
	public static String getCheckfileContentSeparator() {
		return CHECKFILE_CONTENT_SEPARATOR;
	}
	public String getSftpaeUser() {
		return sftpaeUser;
	}
	public void setSftpaeUser(String sftpaeUser) {
		this.sftpaeUser = sftpaeUser;
	}
	public String getSftpaePassword() {
		return sftpaePassword;
	}
	public void setSftpaePassword(String sftpaePassword) {
		this.sftpaePassword = sftpaePassword;
	}
	public String getSftpHost() {
		return sftpHost;
	}
	public void setSftpHost(String sftpHost) {
		this.sftpHost = sftpHost;
	}
	public Integer getSftpPort() {
		return sftpPort;
	}
	public void setSftpPort(Integer sftpPort) {
		this.sftpPort = sftpPort;
	}
	public String getSftpMsmDir() {
		return sftpMsmDir;
	}
	public String getSegment() {
		return segment;
	}
	public void setSegment(String segment) {
		this.segment = segment;
	}
	public void setSftpMsmDir(String sftpMsmDir) {
		this.sftpMsmDir = sftpMsmDir;
	}
	public String getError() {
		return error;
	}
	public void setError(String error) {
		this.error = error;
	}
	@Override
	public String toString() {
		return "ConfigBean{" +
				"sftpaeUser='" + sftpaeUser + '\'' +
				", sftpaePassword='" + sftpaePassword + '\'' +
				", sftpHost='" + sftpHost + '\'' +
				", sftpPort=" + sftpPort +
				", sftpMsmDir='" + sftpMsmDir + '\'' +
				", segment='" + segment + '\'' +
				", error='" + error + '\'' +
				'}';
	}
}

src/main/java/com/miaozhen/config/FTPServerConfig.java

@@ -0,0 +1,104 @@
package com.miaozhen.config;
import com.miaozhen.util.OSinfoUtil;
import com.pythagorastech.tms.util.FileUtil;
import org.apache.ftpserver.FtpServer;
import org.apache.ftpserver.FtpServerFactory;
import org.apache.ftpserver.ftplet.Authority;
import org.apache.ftpserver.ftplet.FtpException;
import org.apache.ftpserver.ftplet.UserManager;
import org.apache.ftpserver.listener.ListenerFactory;
import org.apache.ftpserver.usermanager.PropertiesUserManagerFactory;
import org.apache.ftpserver.usermanager.impl.BaseUser;
import org.apache.ftpserver.usermanager.impl.WritePermission;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import javax.annotation.PostConstruct;
import javax.annotation.PreDestroy;
import java.io.File;
import java.io.IOException;
import java.nio.file.Files;
import java.nio.file.Path;
import java.nio.file.Paths;
import java.util.ArrayList;
import java.util.List;
/**
 * @Description :
 * Created by liyongbo on 2025-03-13 15:08.
 */
@Configuration
public class FTPServerConfig {
    private FtpServer ftpServer;
    @Bean
    @PostConstruct
    public FtpServer ftpServer() throws FtpException {
        // 创建 FTP 服务器工厂
        FtpServerFactory serverFactory = new FtpServerFactory();
        // 配置监听器（设置端口）
        ListenerFactory listenerFactory = new ListenerFactory();
        listenerFactory.setPort(2121); // 默认 FTP 端口是 21，这里使用 2121 避免冲突
        serverFactory.addListener("default", listenerFactory.createListener());
        // 配置用户管理器
        PropertiesUserManagerFactory userManagerFactory = new PropertiesUserManagerFactory();
        UserManager userManager = userManagerFactory.createUserManager();
        // 创建用户
        BaseUser user = new BaseUser();
        user.setName("admin"); // 用户名
        user.setPassword("admin"); // 密码
        String path = "";
        if(OSinfoUtil.isLinux()){
            path = "/tmp/ftp";
        }else{
            path = "D:\\tmp\\ftp";
        }
        checkFolder(path);
        user.setHomeDirectory(path); // 用户主目录
        // 设置用户权限
        List<Authority> authorities = new ArrayList<>();
        authorities.add(new WritePermission()); // 写权限
        user.setAuthorities(authorities);
        // 添加用户到用户管理器
        userManager.save(user);
        // 设置用户管理器到服务器工厂
        serverFactory.setUserManager(userManager);
        // 创建并启动 FTP 服务器
        ftpServer = serverFactory.createServer();
        ftpServer.start();
        return ftpServer;
    }
    @PreDestroy
    public void onDestroy() {
        if (ftpServer != null) {
            ftpServer.stop();
        }
    }
    public static void checkFolder(String sPath) {
        // 指定目录路径
        Path path = Paths.get(sPath);
        // 判断目录是否存在，不存在则创建
        if (!Files.exists(path)) {
            try {
                Files.createDirectories(path); // 创建目录（包括父目录）
                System.out.println("目录创建成功: " + path);
            } catch (IOException e) {
                System.err.println("目录创建失败: " + e.getMessage());
            }
        } else {
            System.out.println("目录已存在: " + path);
        }
    }
}

src/main/java/com/miaozhen/service/impl/CrashReportImpl.java

@@ -1,7 +1,6 @@
package com.miaozhen.service.impl;
import com.jcraft.jsch.*;
import com.miaozhen.bean.ConfigBean;
import com.miaozhen.service.CrashReportServer;
import com.miaozhen.tmssys.dto.CinemaInfo;
import com.miaozhen.util.*;
@@ -19,144 +18,154 @@ import java.util.Properties;
@Service
public class CrashReportImpl implements CrashReportServer {
    private static Logger logger = LoggerFactory.getLogger(CrashReportImpl.class);
    private static ChannelSftp sftp = null;
    private static Session sshSession = null;
    @Resource
    private ConfigBean configBean;
    @Override
    public boolean uploadString(String errorData) {
        if (TextUtils.isEmpty(errorData)) {
            logger.info("errorData is empty");
            return false;
        }
        connectSftp();
        CinemaInfo cinemaInfo = (CinemaInfo) HashMapUtil.get(HashMapUtil.CACHE_KEY);
        String code = "";
        if (cinemaInfo == null) {
            cinemaInfo = FileUtil.getCinemaInfoFromXml();
        }
        if (cinemaInfo != null) {
            code = cinemaInfo.getCode();
        }
        String mFileName = code + "_" + DateUtil.format(new Date(), DateUtil.FORMAT_DATETIMESTAMP) + "-" + MD5Utils.getUUID() + ".txt";
        String path = configBean.getError() + DateUtils.formatDate(new Date(), DateUtil.FORMAT_DATE) + "/";
        String[] folders = path.split("/");
        logger.info("CrashReportImpl ->准备上传，文件名：{}，文件content长度：{}", mFileName, errorData.length());
        boolean success;
        try {
            sftp.cd("/");
            for (String folder : folders) {
                if (folder.length() > 0) {
                    try {
                        sftp.cd(folder);
                    } catch (SftpException e) {
                        sftp.mkdir(folder);
                        sftp.cd(folder);
                    }
                }
            }
            logger.info("CrashReportImpl: 当前所在目录:" + path);
            ByteArrayInputStream inputStream = new ByteArrayInputStream(errorData.getBytes());
            sftp.put(inputStream, mFileName);
            inputStream.close();
            logger.info("CrashReportImpl->错误日志上传完毕,路径：{},文件名：{}", path, mFileName);
            success = true;
        } catch (Exception e) {
            e.printStackTrace();
            success = false;
        }
        disConnectSftp();
        return success;
        return false;
    }
    @Override
    public void uploadErrorLogFileToFTP() {
        CinemaInfo cinemaInfo = (CinemaInfo)HashMapUtil.get(HashMapUtil.CACHE_KEY);
        String code = "";
        String sftpMsmDir = "";
        String date = DateUtils.formatDate(new Date(), DateUtil.FORMAT_DATE);
        if(cinemaInfo==null){
            cinemaInfo = FileUtil.getCinemaInfoFromXml();
        }
        if(cinemaInfo!=null){
            code = cinemaInfo.getCode();
            sftpMsmDir = configBean.getError() + File.separator +date+File.separator + code + File.separator ;
        }else{
            sftpMsmDir = configBean.getError() + File.separator +date+File.separator ;
        }
        logger.info("uploadErrorLogFileToFTP sftpMsmDir is:{}",sftpMsmDir);
        String startDateStr = DateUtil.format(new Date(), DateUtil.FORMAT_DATE_YYYYMMDD);
        String logsPath = FileUtil.getLogsDir();
        String infoFileName = "MiaozhenProbe_info."+startDateStr+".log";
        String errorFileName = "MiaozhenProbe_error." + startDateStr + ".log";
        String infoFilePath = logsPath + File.separator + infoFileName;
        String errorFilePath = logsPath + File.separator + errorFileName;
        String host = configBean.getSftpHost();
        Integer port = configBean.getSftpPort();
        String userName = configBean.getSftpaeUser();
        String password = configBean.getSftpaePassword();
        FileUtils.connectSftp(host, port, userName, password);
        logger.info("uploadErrorLogFileToFTP infoFilePath is:{}",infoFilePath);
        FileUtils.uploadFile(infoFilePath,sftpMsmDir);
        if(new File(errorFileName).length()>0){
            FileUtils.uploadFile(errorFilePath,sftpMsmDir);
        }
        FileUtils.disConnectSftp();
    }
    /**
     * sftp服务器连接
     *
     * @param
     */
    private ChannelSftp connectSftp() {
        String host = configBean.getSftpHost();
        Integer port = configBean.getSftpPort();
        String userName = configBean.getSftpaeUser();
        String password = configBean.getSftpaePassword();
        JSch jsch = new JSch();
        try {
            jsch.getSession(userName, host, port);
            sshSession = jsch.getSession(userName, host, port);
            sshSession.setPassword(password);
            Properties properties = new Properties();
            properties.put("StrictHostKeyChecking", "no");
            sshSession.setConfig(properties);
            sshSession.connect();
            Channel channel = sshSession.openChannel("sftp");
            channel.connect();
            sftp = (ChannelSftp) channel;
        } catch (JSchException e) {
            e.printStackTrace();
        }
        return sftp;
    }
    /**
     * 关闭sftp连接
     *
     * @param
     */
    private void disConnectSftp() {
        if (sftp != null) {
            if (sftp.isConnected()) {
                sftp.disconnect();
                sftp = null;
            }
        }
        if (sshSession != null) {
            if (sshSession.isConnected()) {
                sshSession.disconnect();
                sshSession = null;
            }
        }
    }
//    private static Logger logger = LoggerFactory.getLogger(CrashReportImpl.class);
//
//    private static ChannelSftp sftp = null;
//    private static Session sshSession = null;
////    @Resource
////    private ConfigBean configBean;
//
//    @Override
//    public boolean uploadString(String errorData) {
////        if (TextUtils.isEmpty(errorData)) {
////            logger.info("errorData is empty");
////            return false;
////        }
////        connectSftp();
////        CinemaInfo cinemaInfo = (CinemaInfo) HashMapUtil.get(HashMapUtil.CACHE_KEY);
////        String code = "";
////        if (cinemaInfo == null) {
////            cinemaInfo = FileUtil.getCinemaInfoFromXml();
////        }
////        if (cinemaInfo != null) {
////            code = cinemaInfo.getCode();
////        }
////        String mFileName = code + "_" + DateUtil.format(new Date(), DateUtil.FORMAT_DATETIMESTAMP) + "-" + MD5Utils.getUUID() + ".txt";
////        String path = configBean.getError() + DateUtils.formatDate(new Date(), DateUtil.FORMAT_DATE) + "/";
////        String[] folders = path.split("/");
////        logger.info("CrashReportImpl ->准备上传，文件名：{}，文件content长度：{}", mFileName, errorData.length());
////        boolean success;
////        try {
////            sftp.cd("/");
////            for (String folder : folders) {
////                if (folder.length() > 0) {
////                    try {
////                        sftp.cd(folder);
////                    } catch (SftpException e) {
////                        sftp.mkdir(folder);
////                        sftp.cd(folder);
////                    }
////                }
////            }
////            logger.info("CrashReportImpl: 当前所在目录:" + path);
////            ByteArrayInputStream inputStream = new ByteArrayInputStream(errorData.getBytes());
////            sftp.put(inputStream, mFileName);
////            inputStream.close();
////            logger.info("CrashReportImpl->错误日志上传完毕,路径：{},文件名：{}", path, mFileName);
////            success = true;
////        } catch (Exception e) {
////            e.printStackTrace();
////            success = false;
////        }
////
////        disConnectSftp();
////        return success;
//        return false;
//    }
//
//    @Override
//    public void uploadErrorLogFileToFTP() {
//        CinemaInfo cinemaInfo = (CinemaInfo)HashMapUtil.get(HashMapUtil.CACHE_KEY);
//        String code = "";
//        String sftpMsmDir = "";
//        String date = DateUtils.formatDate(new Date(), DateUtil.FORMAT_DATE);
//        if(cinemaInfo==null){
//            cinemaInfo = FileUtil.getCinemaInfoFromXml();
//        }
//        if(cinemaInfo!=null){
//            code = cinemaInfo.getCode();
//            sftpMsmDir = configBean.getError() + File.separator +date+File.separator + code + File.separator ;
//        }else{
//            sftpMsmDir = configBean.getError() + File.separator +date+File.separator ;
//        }
//        logger.info("uploadErrorLogFileToFTP sftpMsmDir is:{}",sftpMsmDir);
//        String startDateStr = DateUtil.format(new Date(), DateUtil.FORMAT_DATE_YYYYMMDD);
//        String logsPath = FileUtil.getLogsDir();
//        String infoFileName = "MiaozhenProbe_info."+startDateStr+".log";
//        String errorFileName = "MiaozhenProbe_error." + startDateStr + ".log";
//        String infoFilePath = logsPath + File.separator + infoFileName;
//        String errorFilePath = logsPath + File.separator + errorFileName;
//        String host = configBean.getSftpHost();
//        Integer port = configBean.getSftpPort();
//        String userName = configBean.getSftpaeUser();
//        String password = configBean.getSftpaePassword();
//        FileUtils.connectSftp(host, port, userName, password);
//
//        logger.info("uploadErrorLogFileToFTP infoFilePath is:{}",infoFilePath);
//        FileUtils.uploadFile(infoFilePath,sftpMsmDir);
//        if(new File(errorFileName).length()>0){
//            FileUtils.uploadFile(errorFilePath,sftpMsmDir);
//        }
//        FileUtils.disConnectSftp();
//    }
//
//    /**
//     * sftp服务器连接
//     *
//     * @param
//     */
//    private ChannelSftp connectSftp() {
//
//        String host = configBean.getSftpHost();
//        Integer port = configBean.getSftpPort();
//        String userName = configBean.getSftpaeUser();
//        String password = configBean.getSftpaePassword();
//        JSch jsch = new JSch();
//        try {
//            jsch.getSession(userName, host, port);
//            sshSession = jsch.getSession(userName, host, port);
//            sshSession.setPassword(password);
//            Properties properties = new Properties();
//            properties.put("StrictHostKeyChecking", "no");
//            sshSession.setConfig(properties);
//            sshSession.connect();
//            Channel channel = sshSession.openChannel("sftp");
//            channel.connect();
//            sftp = (ChannelSftp) channel;
//
//        } catch (JSchException e) {
//            e.printStackTrace();
//        }
//        return sftp;
//    }
//
//    /**
//     * 关闭sftp连接
//     *
//     * @param
//     */
//    private void disConnectSftp() {
//        if (sftp != null) {
//            if (sftp.isConnected()) {
//                sftp.disconnect();
//                sftp = null;
//            }
//        }
//        if (sshSession != null) {
//            if (sshSession.isConnected()) {
//                sshSession.disconnect();
//                sshSession = null;
//            }
//        }
//    }
}

src/main/java/com/miaozhen/task/job/ServerLogJob.java

@@ -1,7 +1,6 @@
package com.miaozhen.task.job;
import com.google.common.base.Stopwatch;
import com.miaozhen.bean.UploadBean;
import com.miaozhen.device.IDCServer;
import com.miaozhen.device.smi.PlaybackStatus;
import com.miaozhen.device.support.ChristieServer;
@@ -12,12 +11,8 @@ import com.miaozhen.task.JobInterface;
import com.miaozhen.tmssys.TmsService;
import com.miaozhen.tmssys.dto.*;
import com.miaozhen.util.*;
import com.miaozhen.bean.ConfigBean;
import net.sf.json.JSONObject;
import org.apache.commons.collections.map.HashedMap;
import org.apache.commons.lang.StringUtils;
import org.apache.http.client.utils.DateUtils;
import org.quartz.DisallowConcurrentExecution;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
@@ -26,7 +21,6 @@ import org.springframework.stereotype.Component;
import javax.annotation.PostConstruct;
import javax.annotation.Resource;
import java.io.File;
import java.net.NoRouteToHostException;
import java.net.SocketTimeoutException;
import java.util.Date;
@@ -48,8 +42,6 @@ public class ServerLogJob implements JobInterface {
    TmsService tmsService;
    @Autowired
    CrashReportServer crashReportServer;
    @Resource
    private ConfigBean configBean;
    private String tempLogPath;
@@ -167,21 +159,21 @@ public class ServerLogJob implements JobInterface {
                                                    //获取到日志则进行上报，连接
                                                    Stopwatch Stopwatch2 = Stopwatch.createStarted();
                                                    //文件夹路径：ooh/yyyy-MM-dd
                                                    String sftpMsmDir = configBean.getSftpMsmDir() + startDateStr;
                                                    if (i == 0) {
                                                        //实时日志路径
                                                        sftpMsmDir = configBean.getSegment() + startDateStr;
                                                    }
//                                                    String sftpMsmDir = configBean.getSftpMsmDir() + startDateStr;
//                                                    if (i == 0) {
//                                                        //实时日志路径
//                                                        sftpMsmDir = configBean.getSegment() + startDateStr;
//                                                    }
                                                    //文件名字：IP_服务器类型_HH-mm-ss-SSS-随机字符串.json.md5
                                                    String fileName = FileUtils.getIp() + "_" + device.getIP() + "_" + serverType + "_" +
                                                            DateUtil.format(new Date(), "HH-mm-ss-SSS") + "-" + MD5Utils.getUUID() + ".json";
                                                    logger.info("ServerLogJob fileName is:{}", fileName);
                                                    String result = FileUtils.sendData(logContent, serverType, cinemaInfo.getCode(), auditNumber, device.getIP(),
                                                            sftpMsmDir, fileName, startDateStr, FileUtil.getCinemaInfoMd5());
//                                                    String result = FileUtils.sendData(logContent, serverType, cinemaInfo.getCode(), auditNumber, device.getIP(),
//                                                            sftpMsmDir, fileName, startDateStr, FileUtil.getCinemaInfoMd5());
                                                    boolean success = false;
                                                    if (StringUtils.isNotBlank(result) && result.contains("success")) {
                                                        success = true;
                                                    }
//                                                    if (StringUtils.isNotBlank(result) && result.contains("success")) {
//                                                        success = true;
//                                                    }
                                                   /* UploadBean bean = new UploadBean();
                                                    bean.setServerType(serverType);
                                                    bean.setServerIp(device.getIP());

src/main/java/com/miaozhen/util/FTPServer.java

@@ -1,108 +0,0 @@
package com.miaozhen.util;
import org.apache.ftpserver.ConnectionConfigFactory;
import org.apache.ftpserver.FtpServer;
import org.apache.ftpserver.FtpServerFactory;
import org.apache.ftpserver.ftplet.FtpException;
import org.apache.ftpserver.listener.ListenerFactory;
import org.apache.ftpserver.usermanager.impl.BaseUser;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
 * The Class FTPServer.
 */
public class FTPServer {
    private static Logger log = LoggerFactory.getLogger(FTPServer.class);
    /** The port. */
    private int port;
    /** The user manager. */
    private InMemoryUserManager userManager;
    /** The server. */
    private FtpServer server;
    /**
     * Instantiates a new FTP server.
     */
    public FTPServer(){
        port = 21;
        userManager = new InMemoryUserManager();
    }
    /**
     * Sets the port.
     *
     * @param port the new port
     */
    public void setPort(int port){
        this.port = port;
    }
    /**
     * Sets the user.
     *
     * @param login the login
     * @param password the password
     * @param home the home
     */
    public void setUser(String login,char[] password,String home){
        BaseUser user = new BaseUser();
        user.setName(login);
        if(password !=null && password.length>0){
            user.setPassword(new String(password));
        }
        user.setHomeDirectory(home);
        user.setEnabled(true);
        userManager.setUser(user);
    }
    /**
     * Stop.
     */
    public void stop(){
        if (server!=null && !server.isStopped()){
            server.stop();
            server = null;
        }
    }
    /**
     * Start.
     */
    public boolean start(){
        ConnectionConfigFactory configFactory = new ConnectionConfigFactory();
        configFactory.setAnonymousLoginEnabled(false);
        configFactory.setMaxAnonymousLogins(0);
        configFactory.setMaxLoginFailures(5);
        configFactory.setLoginFailureDelay(30);
        configFactory.setMaxThreads(10);
        configFactory.setMaxLogins(10);
        ListenerFactory factory = new ListenerFactory();
        factory.setPort(port);
        FtpServerFactory serverFactory = new FtpServerFactory();
        serverFactory.addListener("default", factory.createListener());
        serverFactory.setUserManager(userManager);
        serverFactory.setConnectionConfig(configFactory.createConnectionConfig());
        server = serverFactory.createServer();
        try{
            server.start();
        } catch (FtpException ex){
            log.error("Start Ftp Server Error {}", ex);
            return false;
        }
        return true;
    }
}

src/main/java/com/miaozhen/util/OSinfoUtil.java

@@ -0,0 +1,156 @@
package com.miaozhen.util;
/**
 * @Description : 获取系统类型类
 * Created by liyongbo on 2020-07-28 10:26.
 */
public class OSinfoUtil {
    private static String OS = System.getProperty("os.name").toLowerCase();
    private static OSinfoUtil _instance = new OSinfoUtil();
    private EPlatform platform;
    private OSinfoUtil(){}
    public static boolean isLinux(){
        return OS.indexOf("linux")>=0;
    }
    public static boolean isMacOS(){
        return OS.indexOf("mac")>=0&&OS.indexOf("os")>0&&OS.indexOf("x")<0;
    }
    public static boolean isMacOSX(){
        return OS.indexOf("mac")>=0&&OS.indexOf("os")>0&&OS.indexOf("x")>0;
    }
    public static boolean isWindows(){
        return OS.indexOf("windows")>=0;
    }
    public static boolean isOS2(){
        return OS.indexOf("os/2")>=0;
    }
    public static boolean isSolaris(){
        return OS.indexOf("solaris")>=0;
    }
    public static boolean isSunOS(){
        return OS.indexOf("sunos")>=0;
    }
    public static boolean isMPEiX(){
        return OS.indexOf("mpe/ix")>=0;
    }
    public static boolean isHPUX(){
        return OS.indexOf("hp-ux")>=0;
    }
    public static boolean isAix(){
        return OS.indexOf("aix")>=0;
    }
    public static boolean isOS390(){
        return OS.indexOf("os/390")>=0;
    }
    public static boolean isFreeBSD(){
        return OS.indexOf("freebsd")>=0;
    }
    public static boolean isIrix(){
        return OS.indexOf("irix")>=0;
    }
    public static boolean isDigitalUnix(){
        return OS.indexOf("digital")>=0&&OS.indexOf("unix")>0;
    }
    public static boolean isNetWare(){
        return OS.indexOf("netware")>=0;
    }
    public static boolean isOSF1(){
        return OS.indexOf("osf1")>=0;
    }
    public static boolean isOpenVMS(){
        return OS.indexOf("openvms")>=0;
    }
    /**
     * 获取操作系统名字
     * @return 操作系统名
     */
    public static EPlatform getOSname(){
        if(isAix()){
            _instance.platform = EPlatform.AIX;
        }else if (isDigitalUnix()) {
            _instance.platform = EPlatform.Digital_Unix;
        }else if (isFreeBSD()) {
            _instance.platform = EPlatform.FreeBSD;
        }else if (isHPUX()) {
            _instance.platform = EPlatform.HP_UX;
        }else if (isIrix()) {
            _instance.platform = EPlatform.Irix;
        }else if (isLinux()) {
            _instance.platform = EPlatform.Linux;
        }else if (isMacOS()) {
            _instance.platform = EPlatform.Mac_OS;
        }else if (isMacOSX()) {
            _instance.platform = EPlatform.Mac_OS_X;
        }else if (isMPEiX()) {
            _instance.platform = EPlatform.MPEiX;
        }else if (isNetWare()) {
            _instance.platform = EPlatform.NetWare_411;
        }else if (isOpenVMS()) {
            _instance.platform = EPlatform.OpenVMS;
        }else if (isOS2()) {
            _instance.platform = EPlatform.OS2;
        }else if (isOS390()) {
            _instance.platform = EPlatform.OS390;
        }else if (isOSF1()) {
            _instance.platform = EPlatform.OSF1;
        }else if (isSolaris()) {
            _instance.platform = EPlatform.Solaris;
        }else if (isSunOS()) {
            _instance.platform = EPlatform.SunOS;
        }else if (isWindows()) {
            _instance.platform = EPlatform.Windows;
        }else{
            _instance.platform = EPlatform.Others;
        }
        return _instance.platform;
    }
    enum EPlatform {
        Any("any"),
        Linux("Linux"),
        Mac_OS("Mac OS"),
        Mac_OS_X("Mac OS X"),
        Windows("Windows"),
        OS2("OS/2"),
        Solaris("Solaris"),
        SunOS("SunOS"),
        MPEiX("MPE/iX"),
        HP_UX("HP-UX"),
        AIX("AIX"),
        OS390("OS/390"),
        FreeBSD("FreeBSD"),
        Irix("Irix"),
        Digital_Unix("Digital Unix"),
        NetWare_411("NetWare"),
        OSF1("OSF1"),
        OpenVMS("OpenVMS"),
        Others("Others");
        EPlatform(String desc) {
            this.description = desc;
        }
        private String description;
    }
}

src/main/resources/myusers.properties

@@ -0,0 +1,10 @@
# myusers.properties
#ftpserver.user.admin.userpassword=admin123
#ftpserver.user.admin.homedirectory=/tmp/ftp
ftpserver.user.admin.enableflag=true
ftpserver.user.admin.writepermission=true
ftpserver.user.admin.maxloginnumber=10
ftpserver.user.admin.maxloginperip=2
ftpserver.user.admin.idletime=300
ftpserver.user.admin.uploadrate=4800
ftpserver.user.admin.downloadrate=4800