package com.newvideo.util.push;

import java.io.IOException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.Set;

import org.apache.commons.httpclient.HttpClient;
import org.apache.commons.httpclient.HttpException;
import org.apache.commons.httpclient.methods.PostMethod;
import org.apache.commons.httpclient.methods.RequestEntity;
import org.apache.commons.httpclient.methods.StringRequestEntity;

import com.newvideo.domain.DetailSystem;
import com.newvideo.domain.VideoInfo;
import com.newvideo.domain.VideoIntersection;
import com.newvideo.service.imp.SystemService;
import com.newvideo.util.LogUtil;
import com.newvideo.util.StringUtil;
import com.newvideo.util.TimeUtil;

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

/**
 * 推送帮助类
 * 
 * @author Administrator
 * 
 */
public class PushUtil {

	public static String getSign(String body, String masterkey) {
		LogUtil.i(StringUtil.Md5("你好"));
		String st = "POST" + "http://msg.umeng.com/api/send" + body + masterkey;
		return StringUtil.Md5(st);
	}

	/**
	 * 推送系统通知
	 * 
	 * @param title
	 * @param content
	 * @param extraVal
	 * @return
	 */
	public static boolean sendBroadcastAndroid(String title, String content, JSONObject extraVal,
			List<String> versionList, List<DetailSystem> detailSystem) {
		for (DetailSystem system : detailSystem)
			sendBroadcastAndroid(title, content, "1", null, "com.weikou.beibeivideo.ui.mine.SystemMessageActivity",
					extraVal == null ? "" : extraVal.toString(), system.getUmengAppKey(), system.getUmengMasterKey(),
					versionList);
		return true;
	}

	/**
	 * 推送视频--android
	 * 
	 * @param title
	 * @param content
	 * @param info
	 * @return
	 */
	public static boolean sendAndroidVideoInfo(String title, String content, VideoInfo info, List<String> versionList,
			List<DetailSystem> detailSystem) {
		JSONObject obj = new JSONObject();
		obj.put("Id", info.getId());
		obj.put("ThirdType", info.getThirdType());
		obj.put("Share", info.getShare());
		for (DetailSystem system : detailSystem)
			sendBroadcastAndroid(title, content, "2", null, "com.weikou.beibeivideo.ui.media.VideoDetailActivity",
					obj.toString(), system.getUmengAppKey(), system.getUmengMasterKey(), versionList);

		return true;
	}

	public static boolean sendAndroidUrl(String title, String content, String url, List<String> versionList,
			List<DetailSystem> detailSystem) {
		JSONObject obj = new JSONObject();
		obj.put("url", url);
		for (DetailSystem system : detailSystem)
			sendBroadcastAndroid(title, content, "3", null, "com.weikou.beibeivideo.ui.mine.BrowserActivity",
					obj.toString(), system.getUmengAppKey(), system.getUmengMasterKey(), versionList);

		return true;
	}

	public static boolean sendAndroidIntersection(String title, String content, String t, String id,
			List<String> versionList, List<DetailSystem> detailSystem) {
		JSONObject obj = new JSONObject();
		obj.put("id", id);
		obj.put("title", t);
		obj.put("push", "true");

		for (int i = 0; i < detailSystem.size(); i++) {
			sendBroadcastAndroid(title, content, "4", null, "com.weikou.beibeivideo.ui.common.MVideosActivity",
					obj.toString(), detailSystem.get(i).getUmengAppKey(), detailSystem.get(i).getUmengMasterKey(),
					versionList);
		}
		return true;
	}

	private static boolean sendBroadcastAndroid(String title, String content, String custom, String[] device,
			String activity, String extraVal, String appkey, String masterkey, List<String> appversion) {

		JSONObject object = new JSONObject();
		object.put("appkey", appkey);
		object.put("timestamp", System.currentTimeMillis() + "");
		if (device == null || device.length == 0)
			object.put("type", "groupcast");
		else {
			object.put("type", "listcast");
			String device_tokens = "";
			for (String st : device) {
				device_tokens += st + ",";
			}
			device_tokens = device_tokens.substring(0, device_tokens.length() - 1);
			object.put("device_tokens", device_tokens);
		}

		JSONObject payJson = new JSONObject();
		payJson.put("display_type", "notification");
		JSONObject body = new JSONObject();
		body.put("ticker", title);
		body.put("title", title);
		body.put("text", content);
		body.put("custom", custom);
		// body.put("alias", "2508");
		body.put("after_open", "go_activity");
		body.put("activity", activity);// com.weikou.beibeivideo.ui.mine.SystemMessageActivity
		payJson.put("body", body);
		payJson.put("extra", extraVal);
		object.put("filter", getVersionFilter(appversion));
		object.put("payload", payJson);
		object.put("production_mode", "true");// true--正式设备 false--测试模式
		object.put("description", "Android");
		String url = "http://msg.umeng.com/api/send?sign=" + getSign(object.toString(), masterkey);
		String result = post(url, object.toString());
		JSONObject obj =JSONObject.fromObject(result);
		if (obj.optString("ret").equalsIgnoreCase("SUCCESS")) {
			return true;
		} else
			return false;
	}

	private static String getVersionFilter(List<String> versionList) {
		if (versionList == null || versionList.size() == 0)
			return "";
		JSONObject object = new JSONObject();
		JSONArray array = new JSONArray();
		for (String st : versionList) {
			JSONObject c = new JSONObject();
			c.put("app_version", st);
			array.add(c);
		}

		JSONObject ar = new JSONObject();
		ar.put("or", array);
		JSONArray arr = new JSONArray();
		arr.add(ar);
		JSONObject aj = new JSONObject();
		aj.put("and", arr);
		object.put("where", aj);
		LogUtil.i(object.toString());
		return object.toString();
	}

	private static boolean sendBroadcastIOS(String title, String content, String custom, String[] device,
			JSONObject extraVal, String appkey, String masterkey) {

		JSONObject object = new JSONObject();
		object.put("appkey", appkey);
		object.put("timestamp", System.currentTimeMillis() + "");
		if (device == null || device.length == 0)
			object.put("type", "broadcast");
		else {
			object.put("type", "listcast");
			String device_tokens = "";
			for (String st : device) {
				device_tokens += st + ",";
			}
			device_tokens = device_tokens.substring(0, device_tokens.length() - 1);
			object.put("device_tokens", device_tokens);
		}

		JSONObject payJson = new JSONObject();
		payJson.put("display_type", "notification");
		JSONObject aps = new JSONObject();
		aps.put("alert", title);
		payJson.put("aps", aps);
		JSONObject data = new JSONObject();
		data.put("type", "1");
		data.put("title", title);
		data.put("content", content);
		payJson.put("data", data);
		object.put("payload", payJson);
		object.put("production_mode", "false");
		object.put("description", "IOS");
		String url = "http://msg.umeng.com/api/send?sign=" + getSign(object.toString(), masterkey);
		String result = post(url, object.toString());
		JSONObject obj =JSONObject.fromObject(result);
		if (obj.optString("ret").equalsIgnoreCase("SUCCESS")) {
			return true;
		} else
			return false;
	}

	public static boolean sendBroadcastIos(String title, String content, JSONObject extraVal) {
		SystemService service = new SystemService();
		List<DetailSystem> list = service.getDetailSystemList();

		for (int i = 0; i < list.size(); i++) {
			if (list.get(i).getAppName().contains("神器看片")) {
				sendBroadcastIOS(title, content, "",
						new String[] { "1b0ab38ea422f582eda3b04739b0007ac9bdddc5566092f675b05f55787d3452" }, extraVal,
						list.get(i).getIosUmengAppKey(), list.get(i).getIosUmengMasterKey());
			}
		}
		return true;
	}

	public static String post(String url, String body, Map<String, String> map) {
		HttpClient client = new HttpClient();
		PostMethod method = new PostMethod(url);
		try {
			RequestEntity entity = new StringRequestEntity(body, "", "UTF-8");
			if (map != null) {
				Set<String> set = map.keySet();
				Iterator<String> its = set.iterator();
				while (its.hasNext()) {
					String key = its.next();
					method.setRequestHeader(key, map.get(key));
				}
			}

			method.setRequestEntity(entity);
			client.executeMethod(method);
			String responseBodyAsString = method.getResponseBodyAsString();
			LogUtil.i(responseBodyAsString);
			return responseBodyAsString;
		} catch (HttpException e) {
			e.printStackTrace();
		} catch (IOException e) {
			e.printStackTrace();
		}
		return "";
	}

	public static String post(String url, String body) {
		return post(url, body, null);
	}

	public static void testIos() {
		sendBroadcastIos("测试标题123", "测试内容456", null);
	}

	/**
	 * 推送通知
	 * 
	 * @param type
	 *            2-视频 3-网页链接 4-合集
	 * @param title
	 * @param target
	 */
	public static void sendBroadCastIOS(int type, String title, Object target, DetailSystem ds) {
		if (type == 2) {
			VideoInfo video = (VideoInfo) target;
			JSONObject obj = new JSONObject();
			obj.put("Id", video.getId());
			obj.put("ThirdType", video.getThirdType());
			obj.put("Share", video.getShare());
			// obj.put("Picture", video.getPicture());
			sendIosNotification(1, title, null, type + "", obj.toString(), ds);
		} else if (type == 3) {
			JSONObject obj = new JSONObject();
			obj.put("url", target.toString());
			sendIosNotification(1, title, null, type + "", obj.toString(), ds);
		} else if (type == 4) {
			VideoIntersection vi = (VideoIntersection) target;
			JSONObject obj = new JSONObject();
			obj.put("id", vi.getId());
			obj.put("title", vi.getName());
			sendIosNotification(1, title, null, type + "", obj.toString(), ds);
		}

	}

	public static void sendBroadCastIOS(String title, String content, Object target, DetailSystem ds) {

	}

	public static boolean sendText(String title, String content, List<String> versionList,
			List<DetailSystem> systemList) {

		List<DetailSystem> androidList = new ArrayList<DetailSystem>();
		List<DetailSystem> iosList = new ArrayList<DetailSystem>();
		for (DetailSystem sy : systemList) {
			if (sy.getPlatform() == 1) {// Android
				androidList.add(sy);
			} else {// IOS
				iosList.add(sy);
			}
		}
		if (androidList.size() > 0)
			sendBroadcastAndroid(title, content, null, versionList, androidList);

		if (iosList.size() > 0) {
			for (DetailSystem ds : iosList) {
				sendIosNotification(2, title, content, null, null, ds);
			}
		}
		return true;
	}

	public static boolean sendVideoInfo(String title, String content, List<String> versionList,
			List<DetailSystem> systemList, Object target) {

		List<DetailSystem> androidList = new ArrayList<DetailSystem>();
		List<DetailSystem> iosList = new ArrayList<DetailSystem>();
		for (DetailSystem sy : systemList) {
			if (sy.getPlatform() == 1) {// Android
				androidList.add(sy);
			} else {// IOS
				iosList.add(sy);
			}
		}
		if (androidList.size() > 0)
			sendAndroidVideoInfo(title, content, (VideoInfo) target, versionList, androidList);

		if (iosList.size() > 0) {
			for (DetailSystem ds : iosList) {
				sendBroadCastIOS(2, title, target, ds);
			}
		}
		return true;
	}

	public static boolean sendUrl(String title, String content, List<String> versionList, List<DetailSystem> systemList,
			Object target) {
		List<DetailSystem> androidList = new ArrayList<DetailSystem>();
		List<DetailSystem> iosList = new ArrayList<DetailSystem>();
		for (DetailSystem sy : systemList) {
			if (sy.getPlatform() == 1) {// Android
				androidList.add(sy);
			} else {// IOS
				iosList.add(sy);
			}
		}
		if (androidList.size() > 0)
			sendAndroidUrl(title, content, target.toString(), versionList, androidList);

		if (iosList.size() > 0) {
			for (DetailSystem ds : iosList) {
				sendBroadCastIOS(3, title, target, ds);
			}
		}

		return true;
	}

	public static boolean sendIntersection(String title, String content, List<String> versionList,
			List<DetailSystem> systemList, Object target) {

		List<DetailSystem> androidList = new ArrayList<DetailSystem>();
		List<DetailSystem> iosList = new ArrayList<DetailSystem>();
		for (DetailSystem sy : systemList) {
			if (sy.getPlatform() == 1) {// Android
				androidList.add(sy);
			} else {// IOS
				iosList.add(sy);
			}
		}
		if (androidList.size() > 0) {
			VideoIntersection vi = (VideoIntersection) target;
			sendAndroidIntersection(title, content, vi.getName(), vi.getId(), versionList, androidList);
		}
		if (iosList.size() > 0) {
			for (DetailSystem ds : iosList) {
				sendBroadCastIOS(4, title, target, ds);
			}
		}
		return true;
	}

	public static void sendIosNotification(int pushtype, String title, String content, String type, String paramsStr,
			DetailSystem ds) {
		JSONObject object = new JSONObject();
		object.put("platform", "all");
		object.put("audience", "all");

		if (pushtype == 1) {// 通知发送
			JSONObject ios = new JSONObject();
			ios.put("alert", title);
			ios.put("sound", "default");
			JSONObject data = new JSONObject();
			data.put("type", type);
			JSONObject params = new JSONObject();
			params.put("thirdType", "1");
			data.put("params", StringUtil.getBase64(paramsStr));
			ios.put("extras", data);
			JSONObject notification = new JSONObject();
			notification.put("ios", ios);
			object.put("notification", notification);
		} else if (pushtype == 2) {// 自定义消息发送
			JSONObject msgContent = new JSONObject();
			JSONObject in = new JSONObject();
			in.put("title", title);
			in.put("content", content);
			in.put("createtime", TimeUtil.getAllTime(System.currentTimeMillis()));
			msgContent.put("data", in);

			JSONObject message = new JSONObject();
			message.put("msg_content", msgContent);
			message.put("content_type", "text");
			message.put("title", title);
			object.put("message", message);
		}
		JSONObject options = new JSONObject();
		options.put("apns_production", false);
		object.put("options", options);
		Map<String, String> map = new HashMap<String, String>();

		map.put("Authorization",
				"Basic " + StringUtil.getBase64(ds.getUmengMasterKey() + ":" + ds.getIosUmengMasterKey()));
		String result = post("https://api.jpush.cn/v3/push", object.toString(), map);
		System.out.println(result);
	}
}