package com.kuanzhai.driver.utils;
|
|
|
import com.google.gson.Gson;
|
|
import java.io.*;
|
import java.net.*;
|
import java.security.MessageDigest;
|
import java.util.HashMap;
|
import java.util.Map;
|
|
/**
|
* 融云及时通讯工具类
|
*/
|
public class RongYunUtil {
|
|
// @Value("${rongyun.app_key}")
|
private static String app_key = "pwe86ga5p9ar6";
|
|
// @Value("${rongyun.app_secret}")
|
private static String app_secret = "FvpwfHqk5o";
|
|
|
/**
|
* 发送系统消息
|
*
|
* @param fromUserId 发送人id
|
* @param toUserId 接收人id
|
* @param content 消息内容
|
* @return
|
*/
|
public static boolean pushSystem(String fromUserId, String toUserId, String content) {
|
String url = "http://api-cn.ronghub.com/message/system/publish.json";
|
Map<String, String> jsonObject = new HashMap();
|
jsonObject.put("fromUserId", "1");
|
jsonObject.put("toUserId", "122");
|
jsonObject.put("content", "推送消息内容");
|
String s = pushHttp(url, new Gson().toJson(jsonObject));
|
jsonObject = new Gson().fromJson(s, Map.class);
|
if (jsonObject.get("code").toString() == "200") {
|
return true;
|
}
|
return false;
|
}
|
|
|
/**
|
* 请求接口
|
*
|
* @param path
|
* @param json
|
* @return
|
*/
|
public static String pushHttp(String path, String json) {
|
String nonce = String.valueOf(Double.valueOf(Math.random() * 1000000.0D).intValue());
|
String timeMillis = String.valueOf(System.currentTimeMillis());
|
String signature = getSha1(app_secret + nonce + timeMillis);
|
|
URL url = null;
|
try {
|
url = new URL(path);
|
HttpURLConnection connection = (HttpURLConnection) url.openConnection();
|
connection.setRequestMethod("POST");
|
connection.setConnectTimeout(1000 * 30);
|
connection.setRequestProperty("Host", "api-cn.ronghub.com");
|
connection.setRequestProperty("Content-Type", "application/x-www-form-urlencoded");
|
connection.setRequestProperty("App-Key", app_key);
|
connection.setRequestProperty("Nonce", nonce);
|
connection.setRequestProperty("Timestamp", timeMillis);
|
connection.setRequestProperty("Signature", signature);
|
connection.setDoOutput(true);
|
connection.setDoInput(true);
|
connection.setUseCaches(false);
|
connection.setInstanceFollowRedirects(true);
|
connection.connect();
|
DataOutputStream outputStream = new DataOutputStream(connection.getOutputStream());
|
outputStream.writeBytes(json);
|
outputStream.flush();
|
outputStream.close();
|
|
InputStream inputStream = connection.getInputStream();
|
DataInputStream dataInputStream = new DataInputStream(inputStream);
|
ByteArrayOutputStream stream = new ByteArrayOutputStream();
|
int len;
|
byte[] bytes = new byte[1024];
|
while ((len = dataInputStream.read(bytes)) != -1) {
|
stream.write(bytes, 0, len);
|
}
|
return stream.toString();
|
} catch (MalformedURLException e) {
|
e.printStackTrace();
|
} catch (ProtocolException e) {
|
e.printStackTrace();
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
return null;
|
}
|
|
public static String getSha1(String str) {
|
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) {
|
return null;
|
}
|
}
|
}
|
