package com.newvideo.util.video;

import java.io.IOException;
import java.util.ArrayList;
import java.util.List;

import org.apache.commons.httpclient.HttpClient;
import org.apache.commons.httpclient.HttpException;
import org.apache.commons.httpclient.methods.GetMethod;
import org.hibernate.Session;

import com.newvideo.dao.BaseDao;
import com.newvideo.domain.FengXingUrlId;
import com.newvideo.domain.FengXingVideoUrl;
import com.newvideo.domain.VideoDetailInfo;
import com.newvideo.domain.VideoInfo;
import com.newvideo.domain.VideoUrl;
import com.newvideo.util.HibernateSessionFactory;
import com.newvideo.util.LogUtil;
import com.newvideo.util.StringUtil;

import net.sf.json.JSONArray;
import net.sf.json.JSONObject;

public class FengXingVideoParser {
	static HibernateSessionFactory hibernateSessionFactory;
	// 根据url获取实体
	public static FengXingUrlId getFengXingVideoId(String url) {
		FengXingUrlId fx = new FengXingUrlId();
		fx.setUrl(url);
		HttpClient client = new HttpClient();
		GetMethod method = new GetMethod(url);
		method.setRequestHeader("User-Agent",
				"Mozilla/5.0 (Linux; U; Android 4.4.2; zh-cn; HUAWEI G750-T01 Build/HuaweiG750-T01) AppleWebKit/533.1 (KHTML, like Gecko)Version/4.0 MQQBrowser/5.4 TBS/025469 Mobile Safari/533.1 V1_AND_SQ_5.8.0_264_YYB_D QQ/5.8.0.2505 NetType/WIFI WebP/0.3.0");
		try {
			client.executeMethod(method);
			String result = method.getQueryString();
			LogUtil.i(result);
			String sts[] = result.split("&");
			for (String st : sts)
				if (st.contains("vid=")) {
					fx.setVid(st.replace("vid=", ""));
				} else if (st.contains("mid=")) {
					fx.setMid(st.replace("mid=", ""));
				}
		} catch (HttpException e) {
			e.printStackTrace();
		} catch (IOException e) {
			e.printStackTrace();
		}
		return fx;
	}

	public static void addUrlIds(VideoInfo info) {
		for (VideoDetailInfo detail : info.getVideoDetailList())
			for (VideoUrl videoUrl : detail.getUrls()) {
				FengXingUrlId ui = getFengXingVideoId(videoUrl.getUrl());
				BaseDao<FengXingUrlId> dao = new BaseDao<FengXingUrlId>();
				List<FengXingUrlId> list = dao.list("from FengXingUrlId u where u.url=?", new String[] { ui.getUrl() });
				if (list == null || list.size() == 0)
					dao.create(ui);
			}
	}

	public static String getFirstRequestUrl(FengXingUrlId ids) {
		if (!StringUtil.isNullOrEmpty(ids.getMid())) {
			return "http://pm.funshion.com/v5/media/play/?id=" + ids.getMid() + "&cl=mweb&uc=30";
		} else {
			return "http://pv.funshion.com/v5/video/play?id=" + ids.getVid()
					+ "&cl=aphone&ve=2.4.0.4&mac=9cc372a7d0e4&uc=99";
		}
	}

	public static List<String> parseSecondResponse(String result) {
		JSONObject obj = JSONObject.fromObject(result);
		JSONArray array = obj.optJSONArray("playlist");
		array = array.optJSONObject(0).optJSONArray("urls");
		List<String> list = new ArrayList<String>();
		for (int i = 0; i < array.size(); i++) {
			list.add(array.optString(i));
		}
		return list;
	}

	public static List<String> parseFirstResponse(String data) {
		List<String> list = new ArrayList<String>();
		JSONObject obj =JSONObject.fromObject(data);
		JSONArray array = obj.optJSONArray("mp4");
		for (int i = 0; i < array.size(); i++) {
			JSONObject object = array.optJSONObject(i);
			list.add(object.optString("http"));
		}
		return list;
	}

	public static String getNewRequestUrl(String url) {
		return FlvCdVideoParser.getRequestUrl(url);
	}

	public static FengXingVideoUrl getVideoUrl(String url) {
		BaseDao<FengXingVideoUrl> dao = new BaseDao<FengXingVideoUrl>();
		List<FengXingVideoUrl> list = dao.list("from FengXingVideoUrl fx where fx.url=?", new String[] { url });
		if (list != null && list.size() > 0)
			return list.get(0);
		else
			return null;
	}

	@SuppressWarnings("unchecked")
	public static void saveOrUpdateVideoUrl(FengXingVideoUrl fx) {
		Session session = hibernateSessionFactory.getSession();
		try {
			List<FengXingVideoUrl> list = session.createQuery("from FengXingVideoUrl fx where fx.url=?")
					.setParameter(0, fx.getUrl()).list();
			session.getTransaction().begin();
			if (list != null && list.size() > 0) {
				list.get(0).setRealUrl(fx.getRealUrl());
				list.get(0).setUpdatetime(System.currentTimeMillis() + "");
				session.update(list.get(0));
			} else
				session.persist(fx);
			session.getTransaction().commit();

		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			session.close();
		}
	}

	public static String parseNewResponse(String data) {

		return FlvCdVideoParser.parseResult(data);
	}
}