package com.yeshi.fanli.service.impl.push;

import java.util.List;

import javax.annotation.Resource;

import org.springframework.stereotype.Service;

import com.yeshi.fanli.dao.mybatis.AppVersionInfoMapper;
import com.yeshi.fanli.entity.AppVersionInfo;
import com.yeshi.fanli.entity.bus.user.AccountMessage;
import com.yeshi.fanli.entity.system.SystemZnx;
import com.yeshi.fanli.entity.xinge.MessageInfo;
import com.yeshi.fanli.entity.xinge.PushRecord;
import com.yeshi.fanli.exception.PushException;
import com.yeshi.fanli.log.PushLogHelper;
import com.yeshi.fanli.service.inter.push.XMPushService;
import com.yeshi.fanli.util.Constant;
import com.yeshi.fanli.util.push.PushUtils;

import net.sf.json.JSONObject;

@Service
public class XMPushServiceImpl implements XMPushService {

	@Resource
	private AppVersionInfoMapper appVersionInfoMapper;

	@Override
	public void pushGoods(Long uid, Long auctionId, String title, String content) throws PushException {
		String gid = auctionId + "";
		JSONObject json = new JSONObject();
		// json.put("url", "http://item.taobao.com/item.htm?id=" + gid);// IOS使用
		json.put("id", gid);
		json.put("type", "goodsdetail");
		json.put("miPushUrl", String.format("%s.ui.recommend.GoodsBrowserActivity",
				Constant.systemCommonConfig.getAndroidBaseactivityName()));

		MessageInfo info = new MessageInfo();
		info.setTitle(title);
		info.setContent(content);
		info.setDescription(content);
		info.setPackageName(Constant.systemCommonConfig.getAndroidPackageName());
		info.setActivty(String.format("%s.ui.recommend.GoodsBrowserActivity",
				Constant.systemCommonConfig.getAndroidBaseactivityName()));

		PushRecord pushRecord = new PushRecord();
		if (uid == null || uid == 0) {
			// 小米 全推
			try {
				PushUtils.allPushXiaoMi(info, json, pushRecord);
			} catch (Exception e) {
				PushLogHelper.xmError(e);
			}
		} else {
			info.setAlias(uid + "");
			// 小米 单推
			PushUtils.singlePushXiaoMi(info, json, pushRecord);
		}
	}

	@Override
	public void pushUrl(Long uid, String url, String title, String content) throws PushException {
		JSONObject json = new JSONObject();
		json.put("url", url);
		json.put("type", "url");
		json.put("webUrl", url);
		json.put("miPushUrl", String.format("%s.ui.invite.ShareBrowserActivity",
				Constant.systemCommonConfig.getAndroidBaseactivityName()));

		MessageInfo info = new MessageInfo();
		info.setTitle(title);
		info.setContent(content);
		info.setDescription(content);
		// 小米推送网页
		info.setPackageName(Constant.systemCommonConfig.getAndroidPackageName());
		info.setActivty(String.format("%s.ui.invite.ShareBrowserActivity",
				Constant.systemCommonConfig.getAndroidBaseactivityName()));

		PushRecord pushRecord = new PushRecord();

		// 小米 全推
		if (uid == null || uid == 0) {
			try {
				PushUtils.allPushXiaoMi(info, json, pushRecord);
			} catch (Exception e) {
				PushLogHelper.xmError(e);
			}
		} else {
			info.setAlias(uid + "");
			PushUtils.singlePushXiaoMi(info, json, pushRecord);
		}

	}

	@Override
	public void pushZNX(Long uId, AccountMessage msg, SystemZnx systemZNX) throws PushException {
		MessageInfo info = new MessageInfo();

		info.setPackageName(Constant.systemCommonConfig.getAndroidPackageName());

		JSONObject contentJson = new JSONObject();

		contentJson.put("isOpen", 0);
		contentJson.put("createTime", java.lang.System.currentTimeMillis());

		/* 无uid , 广播 数据插入系统表 */
		if (systemZNX != null) {
			info.setTitle(systemZNX.getTitle());
			info.setContent(systemZNX.getContent());
			contentJson.put("title", systemZNX.getTitle());
			contentJson.put("content", systemZNX.getContent());
			info.setDescription(systemZNX.getContent());
			// 小米开始全推
			long id = systemZNX.getId();
			contentJson.put("id", id);

			JSONObject json = new JSONObject();
			json.put("type", "ZNX");
			json.put("content", contentJson);
			json.put("miPushUrl", String.format("%s.ui.mine.AppMailDetailActivity",
					Constant.systemCommonConfig.getAndroidBaseactivityName()));

			PushRecord pushRecord = new PushRecord();

			// 小米 全推
			try {
				PushUtils.allPushXiaoMi(info, json, pushRecord);
			} catch (Exception e1) {
				PushLogHelper.xmError(e1);
			}
		} else if (msg != null) {
			info.setTitle(msg.getTitle());
			info.setContent(msg.getContent());
			contentJson.put("title", msg.getTitle());
			contentJson.put("content", msg.getContent());
			info.setDescription(msg.getContent());

			// 插入推送记录
			PushRecord pushRecord = new PushRecord();
			info.setAlias(uId + "");
			info.setPackageName(Constant.systemCommonConfig.getAndroidPackageName());
			info.setActivty(
					String.format("%s.ui.BrowserActivity", Constant.systemCommonConfig.getAndroidBaseactivityName()));
			contentJson.put("id", msg.getId() + "");

			JSONObject json = new JSONObject();
			json.put("type", "ZNX");
			json.put("content", contentJson);
			json.put("miPushUrl", String.format("%s.ui.mine.AppMailDetailActivity",
					Constant.systemCommonConfig.getAndroidBaseactivityName()));
			// 小米 单推
			try {
				PushUtils.singlePushXiaoMi(info, json, pushRecord);
			} catch (Exception e) {
				PushLogHelper.xmError(e);
			}
		}
	}

	@Override
	public void pushWEEX(Long uid, String title, String content, String weexUrl) throws PushException {
		// TODO 推送weex页面
		JSONObject json = new JSONObject();
		json.put("url", weexUrl);
		json.put("type", "weex");
		// 设置可推送版本,1.4.8以后的版本可推送
		json.put("app_version", getVersionByMinVersionCode(31));
		MessageInfo info = new MessageInfo();
		info.setTitle(title);
		info.setContent(content);
		info.setDescription(content);
		// 小米推送网页
		info.setPackageName(Constant.systemCommonConfig.getAndroidPackageName());
		info.setActivty(String.format("%s.ui.mine.weex.WeexApplicationActivity",
				Constant.systemCommonConfig.getAndroidBaseactivityName()));

		PushRecord pushRecord = new PushRecord();

		// 小米 全推
		if (uid == null || uid == 0) {
			try {
				PushUtils.allPushXiaoMi(info, json, pushRecord);
			} catch (Exception e) {
				PushLogHelper.xmError(e);
			}
		} else {
			info.setAlias(uid + "");
			PushUtils.singlePushXiaoMi(info, json, pushRecord);
		}
	}

	private String getVersionByMinVersionCode(int versionCode) {
		List<AppVersionInfo> list = appVersionInfoMapper
				.listByPlatformAndMinVersionCode(AppVersionInfo.PLATFORM_ANDROID, versionCode);
		String versions = "";
		if (list != null)
			for (AppVersionInfo appVersion : list) {
				versions += appVersion.getVersion() + ",";

			}
		if (versions.endsWith(","))
			versions = versions.substring(0, versions.length() - 1);

		return versions;
	}

	@Override
	public void pushBaiChuanUrl(Long uid, String title, String content, String url) throws PushException {
		JSONObject json = new JSONObject();
		json.put("url", url);
		json.put("type", "baichuan");
		// 设置可推送版本,1.4.8以后的版本可推送
		json.put("app_version", getVersionByMinVersionCode(31));

		MessageInfo info = new MessageInfo();
		info.setTitle(title);
		info.setContent(content);
		info.setDescription(content);
		// 小米推送网页
		info.setPackageName(Constant.systemCommonConfig.getAndroidPackageName());

		PushRecord pushRecord = new PushRecord();

		// 小米 全推
		if (uid == null || uid == 0) {
			try {
				PushUtils.allPushXiaoMi(info, json, pushRecord);
			} catch (Exception e) {
				PushLogHelper.xmError(e);
			}
		} else {
			info.setAlias(uid + "");
			PushUtils.singlePushXiaoMi(info, json, pushRecord);
		}

	}

}