1. 程式人生 > >通過調用支付寶查詢對賬單接口返回bill_download_url下載zip,解壓縮

通過調用支付寶查詢對賬單接口返回bill_download_url下載zip,解壓縮

read new edi p2s turn zipentry path public ipa

通過url下載zip對賬單文件,進行解壓。

讀取壓縮文件內容

import java.io.BufferedOutputStream;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.FileWriter;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;

import java.net.URL;
import java.net.URLConnection;

import java.text.SimpleDateFormat;

import java.util.Date;

import com.alipay.downOrdession.*;//修改zip源碼包



public class Zip2String {
	
    public static void main(String[] args) throws Exception {
    	String alipay_url = 
"http://dwbillcenter.alipay.com/downloadBillFile.resource?bizType=trade&userId=20889117596609430156&fileType=csv.zip&bizDates=20170628&downloadFileName=20889117596609430156_20170628.csv.zip&fileId=%2Ftrade%2F20889117596609430156%2F20170628.csv.zip&timestamp=1499075857&token=fdcd1fa66d4270ff19f727db0db7af70";
        String filename=getDownloadFileName(alipay_url);
        
        String down_url = "d:\\test\\ceshi123\\"+filename+".zip";
        /*
    	 * 通過調用支付寶接口返回的url下載zip文件
    	 */
        boolean down_success = downLoadZip(alipay_url,down_url);
        String connetall = "";
        
        //true or  false 下載成功,調用解壓方法
        if(down_success){
        	File save_down_url = new File(down_url);
        	/*
        	 * 解壓下載的zip文件
        	 */
//        	String unzipFilePath = comZipCvsFile(save_down_url);
        	
        	/*
        	 * 讀取下載的zip文件,返回一個string字符串
        	 */
        	connetall = readZipToString(save_down_url);
        }
        /* 返回結果
         * 1.false,下載失敗
         * 2.空字符串||"false"。解壓或者讀取轉string失敗
         */
        //return connetall;
    }

    /**
     * 通過支付寶查詢對賬單接口返回的url,下載zip文件
     * @param alipay_url
     * @param down_url
     * @return
     */
    public static boolean downLoadZip(String alipay_url,String down_url) {
    	boolean down_success = false;
        int bytesum = 0;
        int byteread = 0;
        Date date = new Date();
        SimpleDateFormat sf = new SimpleDateFormat("yyyy/MM/dd");
        String dateFloder = sf.format(date);

        InputStream inStream = null;
        FileOutputStream fs = null;
        
        try {
          
        	URL url = new URL(alipay_url);
            URLConnection conn = url.openConnection();
            inStream = conn.getInputStream();
            
        	//自定義文件保存地址
        	String unzipFilePath =  down_url.substring(0, down_url.lastIndexOf("\\"));//判斷下載保存路徑文件夾
        	
            File unzipFileDir = new File(unzipFilePath);//下載文件存放地址
            if (!unzipFileDir.exists() || !unzipFileDir.isDirectory()) {
                unzipFileDir.mkdirs();
            }
            //解壓文件是否已存在
            File entryFile = new File(down_url);
            if (entryFile.exists()) {
            	//刪除已存在的目標文件 
                entryFile.delete();
            }
            
            fs = new FileOutputStream(down_url);

            byte[] buffer = new byte[4028];

            while ((byteread = inStream.read(buffer)) != -1) {
                bytesum += byteread;
                fs.write(buffer, 0, byteread);
            }
            down_success = true;
            System.out.println(dateFloder+"文件下載成功.....");
        } catch (Exception e) {
            System.out.println(dateFloder+"文件下載失敗" + e);

            return false;
        } finally {
            try {
                if (inStream != null) {
                    inStream.close();
                }
            } catch (IOException e) {
                inStream = null;
            }

            try {
                if (fs != null) {
                    fs.close();
                }
            } catch (IOException e) {
                fs = null;
            }
        }
        return down_success;
    }
    
    
    
    /** 
     * 讀取zip文件,不解壓縮直接解析,支持文件名中文,解決內容亂碼 
     * @param file 
     * @return   讀取zip文件,返回字符串
     * @throws Exception 
     */  
    @SuppressWarnings("unchecked")  
    public static  String readZipToString(File file) throws Exception {
    	String connet = "";
       try {
		
    	   //獲得輸入流,文件為zip格式,  
           //支付寶提供  
           //20886126836996110156_20160906.csv.zip內包含  
           //20886126836996110156_20160906_業務明細.csv  
           //20886126836996110156_20160906_業務明細(匯總).csv  
           ZipInputStream in = new ZipInputStream(new FileInputStream(file));  
           //不解壓直接讀取,加上gbk解決亂碼問題  
           BufferedReader br = new BufferedReader(new InputStreamReader(in,"gbk"));   
           ZipEntry zipFile;
           //返回的字符串---每個文件內容相加
           BufferedWriter bw = null;
           //循環讀取zip中的cvs文件,無法使用jdk自帶,因為文件名中有中文  
           while ((zipFile=in.getNextEntry())!=null) {
               if (zipFile.isDirectory()){
                   //如果是目錄,不處理  
               }
               String file_connet = "";
               //獲得cvs名字  
               String fileName = zipFile.getName();
               System.out.println("-----"+fileName);
               //檢測文件是否存在  
               if (fileName != null && fileName.indexOf(".") != -1) {
                    String line;
                    /*
                     * 1.每一行用 | 隔開
                     * 2.每一個文件用 ; 隔開
                     */
                  //  bw = new BufferedWriter(new FileWriter("d:\\test\\test.txt")); //測試讀取內容
                    while ((line = br.readLine()) != null) {
                   	 
                   	 file_connet = file_connet + "|" + line;
                       // System.out.println(line);
                   	 
                    }    
               }
               
               connet = connet + file_connet + ";";
           }
         //  bw.write(connet);
           //關閉流  
         //  bw.close();
           br.close();  
           in.close();
    	   
    	   
	} catch (Exception e) {
		System.out.println("zip文件讀取失敗" + e);

         return "false";
	}
        
	return connet;
    }
    
    
    
    /**解壓縮 
     * 解壓通過url獲得對賬單數據流(.zip)
     * @param file //zip文件存放地址
     * @return 
     */  
    @SuppressWarnings("unchecked")
    public static String comZipCvsFile(File file) throws Exception {
    	//自定義文件保存地址
    	String unzipFilePath = file.getCanonicalPath();
    	unzipFilePath = unzipFilePath.substring(0, unzipFilePath.lastIndexOf("."));
    	System.out.println("解壓後文件保存路徑:"+unzipFilePath);
    	
        //獲得輸入流,文件為zip格式,
        //支付寶提供  
        //20886126836996110156_20160906.csv.zip內包含  
        //20886126836996110156_20160906_業務明細.csv  
        //20886126836996110156_20160906_業務明細(匯總).csv   
        ZipInputStream in = new ZipInputStream(new FileInputStream(file));

        ZipInputStream zin = new ZipInputStream(in);
        ZipEntry zipFile;
        BufferedOutputStream bos = null;
        try {
			
        	zin = new ZipInputStream(new FileInputStream(file));

            while ((zipFile = zin.getNextEntry()) != null) {
                System.out.println(zipFile.getName());

                File target = new File(file.getParent(), zipFile.getName());

                if (!target.getParentFile().exists()) {
                	// 創建文件父目錄
                    target.getParentFile().mkdirs();
                }

               //創建解壓縮文件保存的路徑 文件夾
                File unzipFileDir = new File(unzipFilePath);//解壓文件存放地址---unzipFilePath(解壓文件去吃.zip)
                if (!unzipFileDir.exists() || !unzipFileDir.isDirectory()) {
                    unzipFileDir.mkdirs();
                }

              
                String file_Name_csv = target.getName();
                String entryFilePath = unzipFilePath + File.separator + file_Name_csv;//decom_Path(存放地址)+文件名

                //解壓文件是否已存在
                File entryFile = new File(entryFilePath);
                if (entryFile.exists()) {
                	//刪除已存在的目標文件 
                    entryFile.delete();
                }

                /*
                 * 寫入文件
                 */
//              bos = new BufferedOutputStream(new FileOutputStream(target));//解壓到和zip在同一個文件夾
                bos = new BufferedOutputStream(new FileOutputStream(entryFile));//自定義文件夾

                int read = 0;
                byte[] buffer = new byte[1024 * 10];

                while ((read = zin.read(buffer, 0, buffer.length)) != -1) {
                    bos.write(buffer, 0, read);
                }

                bos.flush();
            }
            //關閉流
            zin.close();
            bos.close();
        	
		} catch (Exception e) {
			// TODO: handle exception
			System.out.println("zip文件解壓失敗" + e);

            return "false";
		}
		return unzipFilePath;//返回解壓文件保存路徑
        
    }
    
    
    /**
     * 通過alipay_url獲取下載的文件名稱
     * @param alipay_url
     * @return
     */
    private static String getDownloadFileName(String alipay_url){  
        String tempStr = alipay_url.substring(alipay_url.indexOf("downloadFileName")+17, alipay_url.length());  
        tempStr = tempStr.substring(0,tempStr.indexOf(".zip"));  
        return tempStr;  
    }
    
}

百度網盤下載地址 http://pan.baidu.com/s/1jHRSaUU

通過調用支付寶查詢對賬單接口返回bill_download_url下載zip,解壓縮