public void downConentBill() throws Exception { String alipay_url =this.getBillDownloadUrl(); String filename=getDownloadFileName(alipay_url); String down_url = "f:\\alipaybill\\"+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; }