package com.yuji.tdb.twitter;

import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Calendar;
import java.util.Date;
import java.util.List;
import java.util.TimeZone;
import java.util.logging.Logger;

import twitter4j.Query;
import twitter4j.QueryResult;
import twitter4j.Status;
import twitter4j.Tweet;
import twitter4j.Twitter;
import twitter4j.TwitterException;
import twitter4j.TwitterFactory;
import twitter4j.auth.AccessToken;
import twitter4j.conf.ConfigurationBuilder;

import com.yuji.tdb.common.CommonUtil;
import com.yuji.tdb.db.TrainDao;
import com.yuji.tdb.utility.StringUtility;

public class TwitterUtil {
	private static final Logger log = Logger
			.getLogger(TwitterUtil.class.getName());
	private static TwitterUtil instance = null;
	private static Object obj = new Object();
	private DateFormat df = new SimpleDateFormat("yyyy/MM/dd HH:mm:ss");

	public static TwitterUtil getInstance() {
		if (instance == null) {
			synchronized (obj) {
				if (instance == null) {
					instance = new TwitterUtil();
				}
			}
		}
		return instance;
	}

	private TwitterUtil() {
		//TimeZone.setDefault(TimeZone.getTimeZone("JST")); // TODO 場所
	}

	public void main(String consumerKey, String consumerSecret, AccessToken accessToken) {

		String text = "京浜東北";

		try {
			ConfigurationBuilder confBuilder = new ConfigurationBuilder();
			confBuilder.setDebugEnabled(true).setOAuthConsumerKey(consumerKey)
					.setOAuthConsumerSecret(consumerSecret);
			TwitterFactory factory = new TwitterFactory(confBuilder.build());
			Twitter twitter = factory.getInstance(accessToken);

			twite(text, twitter);
		} catch (TwitterException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
			log.severe(e.toString());
		}
	}

	private void twite(String text, Twitter twitter) throws TwitterException {
		Calendar cal = Calendar.getInstance();
		Date date = cal.getTime();
		long cur = date.getTime();
		
		Query query = new Query();
		//query.setRpp(1000); // TODO
		query.setQuery(text);
		QueryResult result = twitter.search(query);
		List<Tweet> tweets = result.getTweets();
		
		int count = 0;
		int hit = 0;
		int mhit = 0;
		
		int index;
		int mindex = 0;
		int size = tweets.size();
		for (index = 0; index < size; index++) {
			Tweet tweet = tweets.get(index);
			
			Date at = tweet.getCreatedAt();
			long t = at.getTime();
			
			String message = tweet.getText();
			
			if (t < cur - 30 * 60 * 1000){
				System.out.println("×" + tweet.getFromUser() + " - "
						+ tweet.getText() + at);
				continue;
			}
			hit = filter(message);
			if (hit <= 0) {
				// 遅延以外の書き込み
				continue;
			}
			if (hit > mhit){
				hit = mhit;
				mindex = index;
			}

			System.out.println("@" + tweet.getFromUser() + " - "
					+ tweet.getText() + at);
			count++;
		}

		String message = "";
		if (count < 5){
			message = "遅延なし " + df.format(date);	
		}
		else {
			int N = 100;
			
			String sample = tweets.get(mindex).getText();
			sample = CommonUtil.replaceString(sample, "@", "(a)");
			sample = StringUtility.parseSubstring(sample, N);
			message = sample + " " + df.format(date) + " count=" + count;							
		}
		System.out.println(message); //TODO
		Status status = twitter.updateStatus(message); //TODO
	}
	
	private List<Train> getTrainList(){
		TrainDao dao = TrainDao.getInstance();
		list = dao.search();
	}
	
	private static List<String> keywords = null;

	public int filter(String text) {
		if (keywords == null) {
			keywords = new ArrayList<String>();
			keywords.add("遅延");
			keywords.add("遅れ");
			keywords.add("振り替え");
			keywords.add("振替");
			keywords.add("停止");
			keywords.add("事故");
		}

		int count = 0;
		for (String keyword : keywords) {
			if (text.indexOf(keyword) >= 0) {
				count++;
			}
		}
		return count;
	}
}