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

import com.stylefeng.guns.core.exception.GunsException;
import io.rong.RongCloud;
import io.rong.messages.BaseMessage;
import io.rong.messages.TxtMessage;
import io.rong.methods.group.Group;
import io.rong.methods.user.User;
import io.rong.models.Result;
import io.rong.models.group.GroupMember;
import io.rong.models.group.GroupModel;
import io.rong.models.message.GroupMessage;
import io.rong.models.message.PrivateMessage;
import io.rong.models.message.SystemMessage;
import io.rong.models.response.ResponseResult;
import io.rong.models.response.TokenResult;
import io.rong.models.user.UserModel;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.URL;
import java.net.URLConnection;
import java.security.MessageDigest;
import java.util.HashMap;
import java.util.List;

/**
 * 融云
 */
public class RongCloudUtil {
	public static String appKey = "bmdehs6pbnozs";
	public static String appSecret = "RovVwtABN1";

	//  海外token获取RongCloud.getSingaporeInstance(appKey, appSecret);
	private static RongCloud rongCloud = RongCloud.getInstance(appKey, appSecret);
	public static void main(String[] args) throws Exception {
		TokenResult token = getToken("1", "1", "1");
		System.out.println(token.toString());
	}
	/**
	 * 融云注册
	 * @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;
//		rongCloud.message.group.recall()
	    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-sg01.ronghub.com/message/system");
		HttpURLConnection conn = HttpUtil.CreatePostHttpConnection(apiHostType, appKey, appSecret, "/publish.json", "application/json");
		HttpUtil.setBodyParameter(sb, conn);*/
		//return HttpUtil.returnResult("");
		return "";
	}

	/**
	 * 通过融云发送系统信息，详见https://www.rongcloud.cn/docs/message_architecture.html#group_notification_message
	 * @param senderId 发送人
	 * @param targetIds 接收人（数组）
	 * @param baseMessage 消息内容
	 * @param pushContent 推送内容
	 * @param pushData 推送数据
	 */
	public static void sendSystemMessage(String senderId, String[] targetIds, BaseMessage baseMessage, String pushContent, String pushData){
		SystemMessage systemMessage = new SystemMessage()
				.setSenderId(senderId)
				.setTargetId(targetIds)
				.setObjectName(baseMessage.getType())
				.setContent(baseMessage)
				.setPushContent(pushContent)
				.setPushData(pushData)
				.setIsPersisted(0)
				.setIsCounted(0)
				.setContentAvailable(0);
		try {
			ResponseResult responseResult = rongCloud.message.system.send(systemMessage);
			System.out.println(responseResult);
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
	public static void sendSystemMessage1(String senderId, String[] targetIds, BaseMessage baseMessage, String pushContent, String pushData){
		SystemMessage systemMessage = new SystemMessage()
				.setSenderId(senderId)
				.setTargetId(targetIds)
				.setObjectName(baseMessage.getType())
				.setContent(baseMessage)
				.setPushContent(pushContent)
				.setPushData(pushData)
				.setIsPersisted(0)
				.setIsCounted(0)
				.setContentAvailable(1);
		try {
			ResponseResult responseResult = rongCloud.message.system.send(systemMessage);
			System.out.println(responseResult);
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

	/**
	 * 通过融云发送单聊消息
	 */
	public static void sendPrivateMsg(String senderId, String targetId, BaseMessage baseMessage){
		PrivateMessage privateMessage = new PrivateMessage()
				.setSenderId(senderId)
				.setTargetId(new String[]{targetId})
				.setObjectName(baseMessage.getType())
				.setContent(baseMessage)
				.setPushContent("")
				.setPushData("")
				.setCount("")
				.setVerifyBlacklist(0)
				.setIsPersisted(1)
				.setIsCounted(1)
				.setIsIncludeSender(0);
		//发送单聊方法
		try {
			rongCloud.message.msgPrivate.send(privateMessage);
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
	public static void sendPrivateMsg1(String senderId, String targetId, BaseMessage baseMessage){
		PrivateMessage privateMessage = new PrivateMessage()
				.setSenderId(senderId)
				.setTargetId(new String[]{targetId})
				.setObjectName(baseMessage.getType())
				.setContent(baseMessage)
				.setPushContent("")
				.setPushData("")
				.setCount("")
				.setVerifyBlacklist(0)
				.setIsPersisted(1)
				.setIsCounted(1)
				.setIsIncludeSender(1);
		//发送单聊方法
		try {
			rongCloud.message.msgPrivate.send(privateMessage);
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

	public static void sendPrivateMsg(String senderId, String[] targetId, BaseMessage baseMessage){
		PrivateMessage privateMessage = new PrivateMessage()
				.setSenderId(senderId)
				.setTargetId(targetId)
				.setObjectName(baseMessage.getType())
				.setContent(baseMessage)
				.setPushContent("")
				.setPushData("")
				.setCount("")
				.setVerifyBlacklist(0)
				.setIsPersisted(1)
				.setIsCounted(1)
				.setIsIncludeSender(1);
		//发送单聊方法
		try {
			rongCloud.message.msgPrivate.send(privateMessage);
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

	/**
	 * 发送群组消息
	 * @param fromUserId 注意当前用户id不会接收到该消息
	 * @param toGroupId 群id
	 */
	public static void sendGroupMessage(String fromUserId, String toGroupId, BaseMessage baseMessage, String pushContent, String pushData){
		GroupMessage groupMessage = new GroupMessage()
				.setSenderId(fromUserId)
				.setTargetId(new String[]{toGroupId})
				.setObjectName(baseMessage.getType())
				.setContent(baseMessage)
				.setPushContent(pushContent)
				.setPushData(pushData)
				.setIsPersisted(1)
				.setIsIncludeSender(1)
				.setContentAvailable(0);
		try {
			ResponseResult groupResult = rongCloud.message.group.send(groupMessage);
			System.out.println(groupResult);
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
	public static void sendGroupMessage1(String fromUserId, String toGroupId, BaseMessage baseMessage, String pushContent, String pushData){
		GroupMessage groupMessage = new GroupMessage()
				.setSenderId(fromUserId)
				.setTargetId(new String[]{toGroupId})
				.setObjectName(baseMessage.getType())
				.setContent(baseMessage)
				.setPushContent(pushContent)
				.setPushData(pushData)
				.setIsPersisted(1)
				.setIsIncludeSender(1)
				.setContentAvailable(0);
		try {
			ResponseResult groupResult = rongCloud.message.group.send(groupMessage);
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

	/**
	 * 移除黑名单
	 */
	public static void removeBlackList(String userId,String friendId){
		UserModel user = getUserModel(userId,friendId);
		try {
			rongCloud.user.blackList.remove(user);
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

	/**
	 * 添加黑名单
	 */
	public static void addBlackList(String userId,String friendId){
		UserModel user = getUserModel(userId,friendId);
		try {
			rongCloud.user.blackList.add(user);
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

	private static UserModel getUserModel(String userId, String friendId){
		UserModel blackUser = new UserModel().setId(userId);
		UserModel[] blacklist = {blackUser};
		UserModel user = new UserModel()
				.setId(friendId)
				.setBlacklist(blacklist);
		return user;
	}

	/**
	 * 通过融云发送单聊消息
	 */
	public static void sendPrivateMsg(String fromUserId, String toUserId, String objectName, String content) {
		TxtMessage txtMessage  = new TxtMessage(content, content);

		PrivateMessage privateMessage = new PrivateMessage()
				.setSenderId(fromUserId)
				.setTargetId(new String[]{toUserId})
//				.setObjectName("RC:TxtMsg")
				.setObjectName(objectName)
				.setContent(txtMessage)
				.setPushContent("")
				.setPushData("")
				.setCount("")
				.setVerifyBlacklist(0)
				.setIsPersisted(1)
				.setIsCounted(1)
				.setIsIncludeSender(0);
		//发送单聊方法
		try {
			rongCloud.message.msgPrivate.send(privateMessage);
		} catch (Exception e) {
			e.printStackTrace();
		}
	}


	/**
	 * 发送文本消息
	 * @param userId        发送用户id
	 * @param toUserId    接收用户id
	 * @param content       消息文本内容
	 * @return
	 */
	public static Integer privatePushTxtMessage(String userId, String toUserId, String content){
		/*String url = "https://api-cn.ronghub.com/message/private/publish.json";
		String data = "fromUserId=" + userId + "&toUserId=" + toUserId + "&objectName=RC:TxtMsg&content=" + content;
		String s = this.pushHttp(url, data);
		JSONObject jsonObject = JSON.parseObject(s);
		if(jsonObject.getIntValue("code") == 200){
			return jsonObject.getIntValue("status");
		}*/
		//sendPrivateMsg(userId,toUserId,"RC:TxtMsg",content);
		String url = "https://api-sg01.ronghub.com/message/private/publish.json";
		String data = "fromUserId=" + userId + "&toUserId=" + toUserId + "&objectName=RC:TxtMsg&content=" + content;
		sendPost(url,data);
		return 1;
	}




	public static Integer pushSilentAll(String userId, String groupNo,String[] toUserId,String name){
		GroupMessage message = new GroupMessage();
		message.setIsIncludeSender(1);
		message.setSenderId(userId);
		message.setTargetId(new String[]{groupNo});
		message.setToUserId(toUserId);
		message.setObjectName("RC:TxtMsg");
		TxtMessage txtMessage = new TxtMessage(name, "");
		message.setContent(txtMessage);
		try{
			rongCloud.message.group.sendDirection(message);
		}catch (Exception e){
			e.printStackTrace();
		}
		return 1;
	}
	// 单人禁言
	public static Integer Silent(String userId, String groupNo,Integer minute,String groupName ) throws Exception {
//		String url = "https://api-cn.ronghub.com/group/user/gag/add.json";
//		HashMap<String, String> map = new HashMap<>();
//		map.put("userId",userId);
//		map.put("groupId",groupNo);
//		map.put("minute",minute);
	//	String data = "fromUserId=" + userId + "&toUserId=" + toUserId + "&objectName=RC:TxtMsg&content=" + name;
		//sendPost(url,data);
	//	String s = HttpRequestUtil.postRequest1(url, map, appKey, appSecret);
		GroupModel groupModel = new GroupModel();
		GroupMember[] members = new GroupMember[1];
		GroupMember groupMember = new GroupMember();
		groupMember.setGroupId(groupNo);
		groupMember.setId(userId);
		members[0]=groupMember;
		groupModel.setId(groupNo);
		groupModel.setMembers(members);
		groupModel.setName(groupName);
		groupModel.setMinute(minute);
		rongCloud.group.gag.add(groupModel);
		return 1;
	}


	private static GroupModel initGroupModel(String groupId, List<String> memberIds, String groupName) {
		GroupMember[] members = new GroupMember[memberIds.size()];
		for (int i = 0; i < memberIds.size(); i++) {
			members[i] = new GroupMember().setId(memberIds.get(i));
		}
		return new GroupModel()
				.setId(groupId)
				.setMembers(members)
				.setName(groupName);
	}
	/**
	 * 解散群组
	 * @param groupId	群组id
	 */
	public static Integer dismissGroup(String groupId, GroupMember[] members){
		Group Group = rongCloud.group;
		//GroupMember[] members = new GroupMember[]{new GroupMember().setId(memberId)};
		GroupModel group = new GroupModel()
				.setId(groupId)
				.setMembers(members);
		Result groupDismissResult = null;
		try {
			groupDismissResult = (Result)Group.dismiss(group);
		} catch (Exception e) {
			e.printStackTrace();
		}
		System.out.println("dismiss:  " + groupDismissResult.toString());
		return groupDismissResult.getCode();
	}
	/**
	 * 创建群组
	 */
	public static Integer createGroup(String groupNo, String groupName,GroupMember[] members){
		Group Group = rongCloud.group;
		//	GroupMember[] members = new GroupMember[]{new GroupMember().setId(userid)};
		GroupModel group = new GroupModel()
				.setId(groupNo).setName(groupName).setMembers(members);
		Result groupDismissResult = null;
		try {
			groupDismissResult = (Result)Group.create(group);
		} catch (Exception e) {
			e.printStackTrace();
		}
		return groupDismissResult.getCode();
	}


	/**
	 * 全体禁言
	 * @param groupIds
	 * @return
	 */
	public static Integer banAdd(String[] groupIds){
		Group Group = rongCloud.group;
		Result banAddResult = null;
		try {
			banAddResult = (Result)Group.ban.add(groupIds);
		} catch (Exception e) {
			e.printStackTrace();
		}
		System.out.println("banAdd:  " + banAddResult.toString());
		return banAddResult.getCode();
	}
	/**
	 * 移除禁言
	 * @param groupIds
	 * @return
	 */
	public static Integer banRemove(String[] groupIds){
		Group Group = rongCloud.group;
		Result banRemoveResult = null;
		try {
			banRemoveResult = (Result)Group.ban.remove(groupIds);
		} catch (Exception e) {
			e.printStackTrace();
		}
		System.out.println("banRemove:  " + banRemoveResult.toString());
		return banRemoveResult.getCode();
	}
	public static void addGroup(String groupNo,List<String> userid,String groupName) throws Exception {
		GroupModel groupModel = initGroupModel(groupNo, userid, groupName);
		rongCloud.group.join(groupModel);
		try {
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

	/**
	 * 向指定 URL 发送POST方法的请求
	 *
	 * @param url
	 *            发送请求的 URL
	 * @param param
	 *            请求参数，请求参数应该是 name1=value1&name2=value2 的形式。
	 * @return 所代表远程资源的响应结果
	 */
	public static String sendPost(String url, String param) {
		PrintWriter out = null;
		BufferedReader in = null;
		String result = "";
		try {
			URL realUrl = new URL(url);
			// 打开和URL之间的连接
			URLConnection conn = realUrl.openConnection();
			// 设置通用的请求属性
			conn.setRequestProperty("accept", "*/*");
			conn.setRequestProperty("connection", "Keep-Alive");
			conn.setRequestProperty("user-agent",
					"Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");
			String nonce = String.valueOf(Double.valueOf(Math.random() * 1000000.0D).intValue());
			String timeMillis = String.valueOf(System.currentTimeMillis());
			String signature  = string2Sha1(appSecret + nonce + timeMillis);
			conn.setConnectTimeout(1000 * 30);
			conn.setRequestProperty("Host", "api-cn.ronghub.com");
			conn.setRequestProperty("Content-Type", "application/x-www-form-urlencoded");
			conn.setRequestProperty("App-Key", appKey);
			conn.setRequestProperty("Nonce", nonce);
			conn.setRequestProperty("Timestamp", timeMillis);
			conn.setRequestProperty("Signature", signature);
			// 发送POST请求必须设置如下两行
			conn.setDoOutput(true);
			conn.setDoInput(true);
			// 获取URLConnection对象对应的输出流
			out = new PrintWriter(conn.getOutputStream());
			// 发送请求参数
			out.print(param);
			// flush输出流的缓冲
			out.flush();
			// 定义BufferedReader输入流来读取URL的响应
			in = new BufferedReader(
					new InputStreamReader(conn.getInputStream()));
			String line;
			while ((line = in.readLine()) != null) {
				result += line;
			}
		} catch (Exception e) {
			System.out.println("发送 POST 请求出现异常！"+e);
			e.printStackTrace();
		}
		//使用finally块来关闭输出流、输入流
		finally{
			try{
				if(out!=null){
					out.close();
				}
				if(in!=null){
					in.close();
				}
			}
			catch(IOException ex){
				ex.printStackTrace();
			}
		}
		return result;
	}

	private static String string2Sha1(String str){
		if(str==null||str.length()==0){
			return null;
		}
		char hexDigits[] = {'0','1','2','3','4','5','6','7','8','9',
				'a','b','c','d','e','f'};
		try {
			MessageDigest mdTemp = MessageDigest.getInstance("SHA1");
			mdTemp.update(str.getBytes("UTF-8"));

			byte[] md = mdTemp.digest();
			int j = md.length;
			char buf[] = new char[j*2];
			int k = 0;
			for (int i = 0; i < j; i++) {
				byte byte0 = md[i];
				buf[k++] = hexDigits[byte0 >>> 4 & 0xf];
				buf[k++] = hexDigits[byte0 & 0xf];
			}
			return new String(buf);
		} catch (Exception e) {
			// TODO: handle exception
			return null;
		}
	}
//	public String initPortraitUri(List<String> headImg) {
//		List<String> picUrls = new ArrayList<>();
//		int i = 0;
//		for (String memberAccount : headImg) {
//			if (memberAccount != null && StringUtils.isNotBlank(memberAccount)) {
//				picUrls.add(memberAccount);
//				i++;
//				if (i >= 9) {
//					break;
//				}
//			}
//		}
//		try {
//			// 生成九宫格群组头像
//			byte[] buff = ImageUtil.getCombinationOfhead(picUrls);
//			//上传到Oss
//            /*String url = dfsClient.uploadFile(buff, "jpg");
//            if (!Objects.equals(url, "")) {
//                return fileRoot + "/" + url;
//            }*/
//			return OssUploadUtil.uploadByteOSS(buff);
//		} catch (Exception e) {
//		}
//		return "";
//	}
	/*public static void main(String[] args) {
		try {
			TokenResult token = getToken("13688394165", "Crystal", "https://sinata.oss-cn-shenzhen.aliyuncs.com/Oo-logo.png");
			System.out.println("token");
			System.out.println(token);
			*//*if (SinataUtil.isNotEmpty(token)){
				if(token.code==200){
					System.out.println(token.getToken());
				}
			}*//*
		} catch (Exception e) {
			System.out.println("kkkkkkk");
			e.printStackTrace();
			System.out.println(e.getMessage());
		}
	}*/
}