package com.j2medev.chapter4;

import java.io.*;
import java.util.Vector;
import javax.microedition.io.*;
import javax.microedition.lcdui.Form;
import org.kxml2.io.KXmlParser;
import org.xmlpull.v1.XmlPullParser;
import org.xmlpull.v1.XmlPullParserException;

public class WeatherReader implements Runnable{
    
    //MIDlet實(shí)例，方便回調(diào)
    private WeatherMIDlet midlet;
    //請(qǐng)求的p,u參數(shù)
    private String param;
    public static final String host = "http://xml.weather.yahoo.com/forecastrss?";
    
    public WeatherReader(WeatherMIDlet midlet,String param) {
        this.midlet = midlet;
        this.param = param;
    }
    
    public void run(){
        HttpConnection conn = null;
        try{
            //等待界面
            WaitingForm wait = new WaitingForm();
            midlet.setCurrent(wait);
            wait.update();
            conn = (HttpConnection)Connector.open(host+param);
            conn.setRequestMethod(HttpConnection.GET);
            int responseCode = conn.getResponseCode();
            wait.update();
            if(responseCode != HttpConnection.HTTP_OK){
                //簡(jiǎn)單起見(jiàn)，只要返回碼不等于200則拋出異常
                throw new IOException("Can't connect to server");
            }
            KXmlParser parser = new KXmlParser();
            //設(shè)置KXmlParser的輸入，注意編碼格式為UTF-8
            parser.setInput(new InputStreamReader(conn.openInputStream(),"UTF-8"));
            wait.update();
            int eventType = parser.getEventType();
            Unit unit = new Unit();
            Location location = new Location();
            //存儲(chǔ)
            Vector v = new Vector();
            while(eventType != XmlPullParser.END_DOCUMENT){
                //根據(jù)事件類(lèi)型解析XML數(shù)據(jù)
                switch(eventType){
                    case XmlPullParser.START_TAG:{
                        String tag = parser.getName();
                        StringBuffer sb = new StringBuffer();
                        sb.append("<"+tag);
                        for(int i = 0;i<parser.getAttributeCount();i++){
                            sb.append(" "+parser.getAttributeName(i)+"=\""+parser.getAttributeValue(i)+"\"");
                        }
                        sb.append("/>");
                        if(tag.equals("yweather:location")){
                            for(int i = 0;i<parser.getAttributeCount();i++){
                                location.set(i,parser.getAttributeValue(i));
                            }
                            wait.update();
                        }else if(tag.equals("yweather:units")){
                            for(int i = 0;i<parser.getAttributeCount();i++){
                                unit.set(i,parser.getAttributeValue(i));
                            }
                            wait.update();
                        }else if(tag.equals("yweather:forecast")){
                            Forecast forecast = new Forecast();
                            forecast.setUnit(unit);
                            for(int i = 0;i<parser.getAttributeCount();i++){
                                forecast.set(i,parser.getAttributeValue(i));
                            }
                            v.addElement(forecast);
                            wait.update();
                        }
                        System.out.println(sb.toString());
                        break;
                    }
                    case XmlPullParser.START_DOCUMENT:{
                        System.out.println("Start Document");
                        break;
                    }case XmlPullParser.END_TAG:{
                        System.out.println("</"+parser.getName()+">");
                        break;
                    }case XmlPullParser.TEXT:{
                        System.out.println(parser.getText());
                        break;
                    }
                    default:
                        break;
                }
                eventType = parser.next();
            }
            System.out.println("End Doucment");
            wait.update();
            //顯示結(jié)果
            midlet.displayWeather(v,location);
            
        }catch(IOException ex){
            //出錯(cuò)提示信息
            Form form = new Form("error");
            form.append(ex.getMessage());
            midlet.setCurrent(form);
        }catch(XmlPullParserException e){
            e.printStackTrace();
        }finally{
            //關(guān)閉連接
            try{
                if(conn != null)
                    conn.close();
            }catch(IOException e){
                
            }
        }
    }
}