文件从一个ftp服务器传到另一个ftp服务器

超、凢脫俗 2023-05-22 06:37 59阅读 0赞

由ftpClient1 -->ftpClient2
    
    public void uploadeFile(String filePath,String ywh,String xzqu,String bjbh,Map fj,String id){
        filePath=filePath.trim();
        String fileName=filePath.substring(filePath.lastIndexOf("/")+1);
        String folderPath=filePath.replace(("/"+fileName),"");
        //folderPath="/"+folderPath;
       // System.out.println("==================================folderPath================"+folderPath);
    
        String targetPath=ftpBasePath;
        FTPClient ftpClient1 = new FTPClient();
    
        FTPClient ftpClient2 = new FTPClient();
        try{
            //连接FTP服务器
            ftpClient2 .connect(ftpIP,port);
            ftpClient1 .connect(bdcFtpIP,bdcProt);
            //登录FTP服务器
            ftpClient2 .login(loginName,pwd);
            ftpClient1 .login(bdcFtpLogin,bdcFtpPwd);
    
            Date currentDate = new Date();
            String dateStr=new SimpleDateFormat("yyyy/MMdd").format(currentDate);
            for(String pathStr:dateStr.split("/")){
                targetPath=targetPath+"/"+pathStr;
                boolean flag = ftpClient2.changeWorkingDirectory(targetPath);
                if(!flag){
                    //创建上传的路径  该方法只能创建一级目录，在这里如果/home/ftpuser存在则可创建image
                    ftpClient2.makeDirectory(targetPath);
                }
            }
            targetPath=targetPath+"/"+ywh;
           // System.out.println("============targetPath======================="+targetPath);
            boolean flag = ftpClient2.changeWorkingDirectory(targetPath);
           // System.out.println("=============2.printWorkingDirectory()=========="+ftpClient2.printWorkingDirectory());
            if(!flag){
                //创建上传的路径  该方法只能创建一级目录
                ftpClient2.makeDirectory(targetPath);
            }
            ftpClient1.setFileType(FTP.BINARY_FILE_TYPE);
            
            //获取FTP服务器路径下的所有文件,当路径中有中文时需进行以下操作
    
            ftpClient1.changeWorkingDirectory(new String(folderPath.getBytes(),FTP.DEFAULT_CONTROL_ENCODING)); ftpClient1.enterLocalPassiveMode(); FTPFile[] ftpFiles = ftpClient1.listFiles();
          
    
            for(FTPFile ftpFile : ftpFiles){
                //获取文件名称
           //     System.out.println("=============ftpClient2.printWorkingDirectory()=========="+ftpClient2.printWorkingDirectory());
                OutputStream is = ftpClient2.storeFileStream( targetPath + "/" + ftpFile.getName());
                //这句话就是获取targetFtpClient的流
    
               // System.out.println(ftpClient1.printWorkingDirectory());
                //ftpClient1.changeWorkingDirectory(new String(folderPath.getBytes(),FTP.DEFAULT_CONTROL_ENCODING));
               // System.out.println("=============ftpClient1.printWorkingDirectory()=========="+ftpClient1.printWorkingDirectory());
                ftpClient1.setFileType(FTP.BINARY_FILE_TYPE);
                System.out.println(ftpFile.getName());
                Boolean b = ftpClient1.retrieveFile(ftpFile.getName(), is);
                //这句话是把文件从ftp1复制到ftp2中，通过流is Boolean b = localFtpClient.retrieveFile(ff.getName(), is);
              //  System.out.println("=============b=========="+b);
                is.close();
                ftpClient2.completePendingCommand();
    
             //数据库保存
    TDjCaseattachmentWithBLOBs caseattachment=new TDjCaseattachmentWithBLOBs();
                caseattachment=new TDjCaseattachmentWithBLOBs();
                caseattachment.setCaseno(bjbh);
                caseattachment.setAttapath(targetPath + "/" + ftpFile.getName());
                caseattachment.setAttatitle(fj.get("FILETITLE").toString());
                caseattachment.setAttachmentname(fj.get("FILETITLE").toString());
                caseattachment.setAttatype("1");
                caseattachment.setAttafkonlymark(id);
                caseattachment.setDistno(xzqu);
                caseattachment.setOpersign("1");
                caseattachment.setSyncdatetime(new Date());
                caseattachment.setSyncsign(0);
                this.saveOrUpdateAttachment(caseattachment);
    
    
            }
            ftpClient1.logout();
            ftpClient2.logout();
        }catch(Exception e){
            e.printStackTrace();
        }
    
    
    }