| docker-compose.yml | ●●●●● patch | view | raw | blame | history | |
| src/main/java/org/springblade/modules/FTP/Monitor.java | ●●●●● patch | view | raw | blame | history | |
| src/main/java/org/springblade/modules/system/controller/UserController.java | ●●●●● patch | view | raw | blame | history |
docker-compose.yml
@@ -7,8 +7,6 @@ container_name: zhbaw ports: - "81:81" volumes: - /home/zhongsong/anbao:/home/zhbaw/anbao # 容器停止后会重启 restart: always depends_on: src/main/java/org/springblade/modules/FTP/Monitor.java
@@ -36,6 +36,7 @@ try { //连接 ftp.connect(ftpHost, ftpPort); // 登陆 ftp.login(ftpUserNameIn, ftpPasswordIn); // 检验登陆操作的返回码是否正确 @@ -43,7 +44,7 @@ ftp.disconnect(); return new Result(400,null,"ftp 连接失败",null); } System.out.println("开始读取内网回传消息"); ftp.enterLocalActiveMode(); // 设置文件类型为二进制,与ASCII有区别 @@ -63,7 +64,8 @@ InputStream is = ftp.retrieveFileStream(new String(fileName.getBytes("GBK"), FTP.DEFAULT_CONTROL_ENCODING)); String substring1 = fileName.substring(0, 1); if (substring1.equals("n")){ //把文件下载到本地 System.out.println("-------接收到内网回传的文件: " + substring1); //把文件下载到本地 FtpUtil.downloadFtpFile(ftpHost, ftpUserNameIn, ftpPasswordIn, ftpPort, ftpPath, localPath, fileName); // 解析数据 String s = OutJson.TestJson(fileName); src/main/java/org/springblade/modules/system/controller/UserController.java
@@ -1622,6 +1622,7 @@ Result result = new Result(); //调用ftp获取返回数据 while (true){ System.out.println("用户新增开始接收消息......................"); Thread.sleep(1000); //调用ftp获取返回数据 result = Monitor.isFTPFileExist(uuid);