package com.dsh.guns.modular.system.util;

import io.rong.RongCloud;
import io.rong.methods.push.Push;
import io.rong.methods.user.User;
import io.rong.models.Result;
import io.rong.models.push.Audience;
import io.rong.models.push.Notification;
import io.rong.models.push.PlatformNotification;
import io.rong.models.push.PushModel;
import io.rong.models.response.PushResult;
import io.rong.models.response.TokenResult;
import io.rong.models.user.UserModel;
import io.rong.util.HostType;
import io.rong.util.HttpUtil;

import java.net.HttpURLConnection;
import java.util.HashMap;
import java.util.Map;

/**
 * 融云
 */
public class RongCloudUtil {
	private static String appKey = "25wehl3u20ddw";
	private static String appSecret = "gG3IjHADkAK";
	       
	private static RongCloud rongCloud = RongCloud.getInstance(appKey, appSecret);
	/**
	 * 融云注册
	 * @param id
	 * @param name
	 * @param portrait
	 * @return
	 * @throws Exception
	 */
	public static TokenResult getToken(String id,String name,String portrait) throws Exception{
		User user = rongCloud.user;
	    UserModel userModel = new UserModel()
	            .setId(id)
	            .setName(name)
	            .setPortrait(portrait);
	    TokenResult result = user.register(userModel);
	    return result;
	}
	/**
	 * 修改
	 * @param id
	 * @param name
	 * @param portrait
	 * @return
	 * @throws Exception
	 */
	public static Result update(String id,String name,String portrait) throws Exception{
		User user = rongCloud.user;
	    UserModel userModel = new UserModel()
	            .setId(id)
	            .setName(name)
	            .setPortrait(portrait);
	    Result result = user.update(userModel);
	    return result;
	}

	/**
	 * 推送
	 * @param userId
	 * @param content
	 * @param extras
	 * @return
	 * @throws Exception
	 */
	public static String push( String userId, String content,String extras) throws Exception {
		String platform="[\"ios\",\"android\"]";
		String audience="{\"userid\":"+"[\""+userId+"\"]"+",\"is_to_all\":false}";
		String notification="{\"alert\":\""+content+"\",\"ios\":"+extras+",\"android\":"+extras+"}";
		String[] tag = {"10"};
		StringBuilder sb = new StringBuilder();
		sb.append("platform=").append(platform);
		sb.append("&tag=").append(tag.toString());
		sb.append("&audience=").append(audience);
		sb.append("&notification=").append(notification);
		/*sb.append(",");
		sb.append("\"extras\":").append(extras);*/
		HostType apiHostType = new HostType("https://api-cn.ronghub.com/message/system");
		HttpURLConnection conn = HttpUtil.CreatePostHttpConnection(apiHostType, appKey, appSecret, "/publish.json", "application/json");
		HttpUtil.setBodyParameter(sb, conn);
		return HttpUtil.returnResult(conn);
	}

	/**
	 * 发送推送信息
	 *
	 * @param alert 消息内容
	 * @param fromUserId 1
	 * @param toUserId  userId
//	 * @param objectName  RC:TxtMsg
//	 * @param pushContent 消息标题
//	 * @param pushData 空-安卓  非空：苹果
	 * @throws Exception
	 */
	public static PushResult pushSystemMessage(String alert, String fromUserId, String[] toUserId,Map<String, String> extras) throws Exception {

		//请求路径
		Push push = rongCloud.push;
		//推送条件
		Audience audience = new Audience();
		audience.setIs_to_all(false);
		audience.setUserid(toUserId);

		////按操作系统类型推送消息内容
		Notification notification = new Notification();
		notification.setAlert(alert);

		//IOS内容
		PlatformNotification ios = new PlatformNotification();
		ios.setAlert(alert);
		ios.setExtras(extras);
		notification.setIos(ios);

		//Android内容
		PlatformNotification android = new PlatformNotification();
		android.setAlert(alert);
		android.setExtras(extras);
		notification.setAndroid(android);

		PushModel  pushModel = new PushModel();
		//目标操作系统
		String[] platform="ios,android".split(",");
		pushModel.setPlatform(platform);
		pushModel.setAudience(audience);
		pushModel.setNotification(notification);
		//推送消息
		PushResult result = push.push(pushModel);
		return result;
	}



}