小程序 公交查询.rar

// DO NOT EDIT THIS FILE - it is automatically generated, edit file under project/java dir // This string is autogenerated by ChangeAppSettings.sh, do not change spaces amount package com.xianle.traffic_sh; import java.io.BufferedInputStream; import java.io.File; import java.io.FileInputStream; import java.io.FileNotFoundException; import java.io.FileOutputStream; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.util.zip.CRC32; import java.util.zip.CheckedInputStream; import java.util.zip.ZipEntry; import java.util.zip.ZipInputStream; import org.apache.http.HttpResponse; import org.apache.http.client.methods.HttpGet; import org.apache.http.impl.client.DefaultHttpClient; import android.content.res.Resources; import android.widget.TextView; class CountingInputStream extends BufferedInputStream { private long bytesReadMark = 0; private long bytesRead = 0; public CountingInputStream(InputStream in, int size) { super(in, size); } public CountingInputStream(InputStream in) { super(in); } public long getBytesRead() { return bytesRead; } public synchronized int read() throws IOException { int read = super.read(); if (read >= 0) { bytesRead++; } return read; } public synchronized int read(byte[] b, int off, int len) throws IOException { int read = super.read(b, off, len); if (read >= 0) { bytesRead += read; } return read; } public synchronized long skip(long n) throws IOException { long skipped = super.skip(n); if (skipped >= 0) { bytesRead += skipped; } return skipped; } public synchronized void mark(int readlimit) { super.mark(readlimit); bytesReadMark = bytesRead; } public synchronized void reset() throws IOException { super.reset(); bytesRead = bytesReadMark; } } /** * @author Administrator * */ class DataDownloader extends Thread { class StatusWriter { private TextView Status; private MainActivity Parent; private String oldText = ""; public StatusWriter( TextView _Status, MainActivity _Parent ) { Status = _Status; Parent = _Parent; } public void setParent( TextView _Status, MainActivity _Parent ) { synchronized(DataDownloader.this) { Status = _Status; Parent = _Parent; setText( oldText ); } } public void setText(final String str) { class Callback implements Runnable { public TextView Status; public String text; public void run() { Status.setText(text); } } synchronized(DataDownloader.this) { Callback cb = new Callback(); oldText = new String(str); cb.text = new String(str); cb.Status = Status; if( Parent != null && Status != null ) Parent.runOnUiThread(cb); } } } public DataDownloader( MainActivity _Parent, TextView _Status ) { Parent = _Parent; Status = new StatusWriter( _Status, _Parent ); //Status.setText( "Connecting to " + Globals.DataDownloadUrl ); outFilesDir = Globals.DataDir; DownloadComplete = false; this.start(); } public void setStatusField(TextView _Status) { synchronized(this) { Status.setParent( _Status, Parent ); } } @Override public void run() { String [] downloadFiles = Globals.DataDownloadUrl.split("\\^"); for( int i = 0; i < downloadFiles.length; i++ ) { if( downloadFiles[i].length() > 0 /*&& Globals.OptionalDataDownload.length > i && Globals.OptionalDataDownload[i] */) if( ! DownloadDataFile(downloadFiles[i], "DownloadFinished-" + String.valueOf(i) + ".flag") ) { DownloadFailed = true; return; } } DownloadComplete = true; initParent(); } public boolean DownloadDataFile(final String DataDownloadUrl, final String DownloadFlagFileName) { String [] downloadUrls = DataDownloadUrl.split("[|]"); if( downloadUrls.length < 2 ) return false; Resources res = Parent.getResources(); String path = getOutFilePath(DownloadFlagFileName); InputStream checkFile = null; try { checkFile = new FileInputStream( path ); } catch( FileNotFoundException e ) { } catch( SecurityException e ) { }; if( checkFile != null ) { try { byte b[] = new byte[ Globals.DataDownloadUrl.getBytes("UTF-8").length + 1 ]; int readed = checkFile.read(b); String compare = new String( b, 0, readed, "UTF-8" ); boolean matched = false; //System.out.println("Read URL: '" + compare + "'"); for( int i = 1; i < downloadUrls.length; i++ ) { //System.out.println("Comparing: '" + downloadUrls[i] + "'"); if( compare.compareTo(downloadUrls[i]) == 0 ) matched = true; } //System.out.println("Matched: " + String.valueOf(matched)); if( ! matched ) throw new IOException(); Status.setText( res.getString(R.string.download_unneeded) ); return true; } catch ( IOException e ) {}; } checkFile = null; // Create output directory (not necessary for phone storage) // System.out.println("Downloading data to: '" + outFilesDir + "'"); try { (new File( outFilesDir )).mkdirs(); OutputStream out = new FileOutputStream( getOutFilePath(".nomedia") ); out.flush(); out.close(); } catch( SecurityException e ) {} catch( FileNotFoundException e ) {} catch( IOException e ) {}; HttpResponse response = null; HttpGet request; long totalLen = 0; CountingInputStream stream; byte[] buf = new byte[16384]; boolean DoNotUnzip = false; boolean FileInAssets = false; String url = ""; int downloadUrlIndex = 1; while( downloadUrlIndex < downloadUrls.length ) { System.out.println("Processing download " + downloadUrls[downloadUrlIndex]); url = new String(downloadUrls[downloadUrlIndex]); DoNotUnzip = false; if(url.indexOf(":") == 0) { url = url.substring( url.indexOf(":", 1) + 1 ); DoNotUnzip = true; } Status.setText( res.getString(R.string.connecting_to, url) ); if( url.indexOf("http://") == -1 && url.indexOf("https://") == -1 ) // File inside assets { System.out.println("Fetching file from assets: " + url); FileInAssets = true; break; } else { System.out.println("Connecting to: " + url); request = new HttpGet(url); request.addHeader("Accept", "*/*"); try { DefaultHttpClient client = HttpWithDisabledSslCertCheck(); client.getParams().setBooleanParameter("http.protocol.handle-redirects", true); response = client.execute(request); } catch (IOException e) { System.out.println("Failed to connect to " + url); downloadUrlIndex++; }; if( response != null ) { if( response.getStatusLine().getStatusCode() != 200 ) { response = null; System.out.println("Failed to connect to " + url); downloadUrlIndex++; } else break; } } } if( FileInAssets ) { System.out.println("Unpacking from assets: '" + url + "'"); try { // System.out.println("Unpacking from assets: '" + url + "' 1"); stream = new CountingInputStream(Parent.getAssets().open(url), 8192); // System.out.println("Unpacking from assets: '" + url + "' 2"); while( stream.skip(65536) > 0 ) { }; // System.out.println("Unpacking from assets: '" + url + "' 3"); totalLen = stream.getBytesRead(); // System.out.println("Unpacking from assets: '" + url + "' 4 totalLen = " + String.valueOf(totalLen)); stream.close(); // System.out.println("Unpacking from assets: '" + url + "' 5"); stream = new CountingInputStream(Parent.getAssets().open(url), 8192); // System.out.println("Unpacking from assets: '" + url + "' 6"); } catch( IOException e ) { System.out.println("Unpacking from assets '" + url + "' - error: " + e.toString());