import java.io.BufferedWriter;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.OutputStreamWriter;


//JSONの取得・分解にはJackson Java JSON-processorを使用
//ダウンロードなどは下記ページ
//http://jackson.codehaus.org/
import com.fasterxml.jackson.core.JsonFactory;
import com.fasterxml.jackson.core.JsonParseException;
import com.fasterxml.jackson.core.JsonParser;
import com.fasterxml.jackson.core.JsonToken;

import twitter4j.*;
import twitter4j.json.DataObjectFactory;


//Streaming APIのsampleでstatusのlang（言語情報）を取得する
public class status_getLang_sample {

    public static void main(String[] args){

        try{

            //自動的に認証してくれる
            //（バージョン2.2.4以降はgetInstance()ではなくgetSingleton()を推奨）
            new TwitterStreamFactory();
            TwitterStream twitterstream = TwitterStreamFactory.getSingleton();

            twitterstream.addListener(new MyStatusAdapter());
            twitterstream.sample();

        } catch(Exception e){
            e.printStackTrace();
        }
    }
}

//出力する
class MyStatusAdapter extends StatusAdapter {

    public void onStatus(Status status){

        BufferedWriter wr = null;

        //書き出し先のファイルを指定
        String fileName = "○○.txt";
        String outdata;


        try {

            //ユーザの情報を取得
            User user = status.getUser();

            //statusオブジェクトのJSON文字列を取得
            String rawJSON = DataObjectFactory.getRawJSON(status);

            //JSON文字列を分解し必要な情報を取得
            //（statusオブジェクトのlang）
            String status_getLang = null;

            try {
                status_getLang = parseJSON(rawJSON);

            } catch (JsonParseException e) {
                e.printStackTrace();
            }

            //utf-8を指定、追記可能
            wr = new BufferedWriter(new OutputStreamWriter(new FileOutputStream(fileName,true), "utf-8"));

            //ツイートから改行記号を除去（半角スペースに変換）
            String strText = status.getText();
            strText = strText.replaceAll("\r\n"," ");
            strText = strText.replaceAll("\r"," ");
            strText = strText.replaceAll("\n"," ");

            //ツイートからタブ記号を除去（半角スペースに変換）
            strText = strText.replaceAll("\t"," ");


            //書き出し（ツイートの言語設定、ユーザの言語設定、タイムゾーン、位置情報、日時、利用アプリ、ユーザ名、ツイート）
            outdata = status_getLang + "\t" + user.getLang() + "\t"
                    + user.getTimeZone() + "\t" + status.getGeoLocation() + "\t" + status.getCreatedAt() + "\t"
                    + status.getSource() + "\t" +user.getScreenName() + "\t" + strText;

            wr.write(outdata);
            wr.write("\n");

            wr.flush();
            wr.close();

        }catch (IOException e) {
            e.printStackTrace();
        }
    }


    //JSON文字列からオブジェクトに変換する
    private static String parseJSON(String str) throws JsonParseException, IOException {

        JsonFactory factory = new JsonFactory();
        JsonParser jp = factory.createJsonParser(str);

        if(jp.nextToken() == JsonToken.START_OBJECT) {
            while (jp.nextToken() != JsonToken.END_OBJECT) {
                String _name = jp.getCurrentName();
                jp.nextToken();


                if(_name.equals("user")) {
                    jp.skipChildren();
                } else {

                    //言語設定ならば返す
                    if(_name == "lang") {
                        return jp.getText();
                    }
                }
            }
        } else {
            jp.skipChildren();
        }
        return null;
    }
}