You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
316 lines
10 KiB
316 lines
10 KiB
using BWP.B3WeChat;
|
|
using BWP.B3WeChat.Entities;
|
|
using Forks.Utils;
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using System.IO;
|
|
using System.Linq;
|
|
using System.Net;
|
|
using System.Text;
|
|
using System.Web;
|
|
using System.Web.Script.Serialization;
|
|
using System.Web.Security;
|
|
|
|
namespace BWP.B3WeChat.Utils
|
|
{
|
|
public static class InOutMessageUtil
|
|
{
|
|
|
|
static Logger logger = new Logger("InOutMessageUtil");
|
|
|
|
static string token;
|
|
|
|
|
|
static DateTime? getTokenTime;
|
|
|
|
static readonly TimeSpan expiredSpan = new TimeSpan(2, 0, 0);
|
|
static string TOKEN
|
|
{
|
|
get
|
|
{
|
|
if (getTokenTime.HasValue && ((TimeSpan)(DateTime.Now - getTokenTime.Value)) >= expiredSpan)
|
|
{
|
|
token = string.Empty;
|
|
}
|
|
|
|
if (string.IsNullOrEmpty(token))
|
|
{
|
|
token = GetToken();
|
|
getTokenTime = DateTime.Now;
|
|
}
|
|
return token;
|
|
}
|
|
}
|
|
|
|
public static B3WeChatConfig config = new B3WeChatConfig();
|
|
|
|
|
|
|
|
static JavaScriptSerializer jsonHelper = new JavaScriptSerializer();
|
|
|
|
static T GetRequest<T>(string uriStr) where T : WeChatResponseBase
|
|
{
|
|
var responseBody = GetRequestString(uriStr);
|
|
T obj = jsonHelper.Deserialize<T>(responseBody);
|
|
if (obj.IsError)
|
|
{
|
|
throw new Exception(string.Format("{0}:{1}", obj.errcode, obj.errmsg));
|
|
}
|
|
return obj;
|
|
}
|
|
|
|
private static string GetRequestString(string url)
|
|
{
|
|
WebClient client = new WebClient();
|
|
var data = client.DownloadData(url);
|
|
return Encoding.UTF8.GetString(data);
|
|
}
|
|
|
|
static T PostRequest<T>(string url, string json) where T : WeChatResponseBase
|
|
{
|
|
byte[] requestBuffer = Encoding.UTF8.GetBytes(json);
|
|
HttpWebRequest webRequest = (HttpWebRequest)WebRequest.Create(new Uri(url));
|
|
webRequest.Method = "POST";
|
|
webRequest.ContentType = "application/x-www-form-urlencoded";
|
|
webRequest.ContentLength = requestBuffer.Length;
|
|
using (var requestStream = webRequest.GetRequestStream())
|
|
{
|
|
requestStream.Write(requestBuffer, 0, requestBuffer.Length);
|
|
}
|
|
HttpWebResponse response = (HttpWebResponse)webRequest.GetResponse();
|
|
var data = new StreamReader(response.GetResponseStream(), Encoding.GetEncoding("utf-8")).ReadToEnd();
|
|
var obj = jsonHelper.Deserialize<T>(data);
|
|
if (obj.IsError)
|
|
{
|
|
throw new Exception(string.Format("{0}:{1}", obj.errcode, obj.errmsg));
|
|
}
|
|
return obj;
|
|
}
|
|
|
|
|
|
public static string GetToken()
|
|
{
|
|
string token = string.Empty;
|
|
string url = string.Format("https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid={0}&secret={1}", config.AppID.Value, config.AppSecret.Value);
|
|
var res = GetRequest<TokenObject>(url);
|
|
return res.access_token;
|
|
}
|
|
|
|
public static WeiChartServerList GetIPList()
|
|
{
|
|
WeiChartServerList result = new WeiChartServerList();
|
|
string uriStr = string.Format("https://api.weixin.qq.com/cgi-bin/getcallbackip?access_token={0}", TOKEN);
|
|
return GetRequest<WeiChartServerList>(uriStr);
|
|
}
|
|
|
|
public static SendTemplateMessageResult SendTemplateMessage(string openID, string templateID, Dictionary<string, ValueColor> dic, string url = "")
|
|
{
|
|
string uriStr = string.Format("https://api.weixin.qq.com/cgi-bin/message/template/send?access_token={0}", TOKEN);
|
|
JavaScriptSerializer jsonHelper = new JavaScriptSerializer();
|
|
SendTemplateMessageResult result = new SendTemplateMessageResult();
|
|
MeassageBody body = new MeassageBody();
|
|
body.touser = openID;
|
|
body.template_id = templateID;
|
|
body.url = url;
|
|
body.data = dic;
|
|
string postData = jsonHelper.Serialize(body);
|
|
return PostRequest<SendTemplateMessageResult>(uriStr, postData);
|
|
}
|
|
|
|
public static void SetCustomMenu(string menuJson)
|
|
{
|
|
var url = string.Format("https://api.weixin.qq.com/cgi-bin/menu/create?access_token={0}", TOKEN);
|
|
PostRequest<WeChatResponseBase>(url, menuJson);
|
|
}
|
|
|
|
public static string GetCustomMenu()
|
|
{
|
|
var url = string.Format("https://api.weixin.qq.com/cgi-bin/menu/get?access_token={0}", TOKEN);
|
|
return GetRequestString(url);
|
|
}
|
|
|
|
public static void DelteCustomMenu()
|
|
{
|
|
var url = string.Format("https://api.weixin.qq.com/cgi-bin/menu/delete?access_token={0}",TOKEN);
|
|
GetRequest<WeChatResponseBase>(url);
|
|
}
|
|
|
|
public static List<string> GetOpenIDList()
|
|
{
|
|
|
|
string openid = string.Empty;
|
|
string uriStr = string.Empty;
|
|
List<string> lstOpenID = new List<string>();
|
|
JavaScriptSerializer jsonHelper = new JavaScriptSerializer();
|
|
OpenIDObject result = new OpenIDObject();
|
|
WebClient client = new WebClient();
|
|
try
|
|
{
|
|
do
|
|
{
|
|
uriStr = string.Format("https://api.weixin.qq.com/cgi-bin/user/get?access_token={0}&next_openid={1}", TOKEN, openid);
|
|
byte[] bytes = client.DownloadData(uriStr);
|
|
string responseBody = Encoding.UTF8.GetString(bytes);
|
|
result = jsonHelper.Deserialize<OpenIDObject>(responseBody);
|
|
lstOpenID.AddRange(result.data.openid);
|
|
openid = result.data.openid.Last();
|
|
} while (lstOpenID.Count < result.total);
|
|
|
|
}
|
|
catch (Exception e)
|
|
{
|
|
throw e;
|
|
}
|
|
return lstOpenID;
|
|
}
|
|
|
|
public static UserBasicInfo GetUserInfo(string openid)
|
|
{
|
|
string uriStr = string.Empty;
|
|
List<string> lstOpenID = new List<string>();
|
|
JavaScriptSerializer jsonHelper = new JavaScriptSerializer();
|
|
UserBasicInfo result = new UserBasicInfo();
|
|
WebClient client = new WebClient();
|
|
try
|
|
{
|
|
uriStr = string.Format("https://api.weixin.qq.com/cgi-bin/user/info?access_token={0}&openid={1}&lang=zh_CN", TOKEN, openid);
|
|
|
|
byte[] bytes = client.DownloadData(uriStr);
|
|
string responseBody = Encoding.UTF8.GetString(bytes);
|
|
result = jsonHelper.Deserialize<UserBasicInfo>(responseBody);
|
|
}
|
|
catch (Exception e)
|
|
{
|
|
throw e;
|
|
}
|
|
return result;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 接收消息
|
|
/// </summary>
|
|
/// <param name="request"></param>
|
|
/// <returns></returns>
|
|
public static object GetMessage(HttpRequest request)
|
|
{
|
|
StreamReader reader = new StreamReader(request.InputStream);
|
|
String xmlData = reader.ReadToEnd();
|
|
object obj = null;
|
|
MessageType type = XmlUtil.Deserialize<MessageType>(xmlData);
|
|
if (type.MsgType == MsgType.文本)
|
|
{
|
|
obj = XmlUtil.Deserialize<ReceivedMsg>(xmlData);
|
|
}
|
|
else if (type.MsgType == MsgType.事件)
|
|
{
|
|
obj = XmlUtil.Deserialize<QRCodeMessage>(xmlData);
|
|
}
|
|
return obj;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 验证微信签名
|
|
/// </summary>
|
|
/// <returns></returns>
|
|
/// * 将token、timestamp、nonce三个参数进行字典序排序
|
|
/// * 将三个参数字符串拼接成一个字符串进行sha1加密
|
|
/// * 开发者获得加密后的字符串可与signature对比，标识该请求来源于微信。
|
|
public static bool CheckSignature()
|
|
{
|
|
string WeChat_Token = config.Token.Value;//从配置文件获取Token
|
|
string WeChat_Key = HttpContext.Current.Request.QueryString["key"];
|
|
|
|
//从微信服务器接收传递过来的数据
|
|
string signature = HttpContext.Current.Request.QueryString["signature"]; //微信加密签名
|
|
string timestamp = HttpContext.Current.Request.QueryString["timestamp"];//时间戳
|
|
string nonce = HttpContext.Current.Request.QueryString["nonce"];//随机数
|
|
string[] ArrTmp = { WeChat_Token, timestamp, nonce };
|
|
Array.Sort(ArrTmp); //字典排序
|
|
string tmpStr = string.Join("", ArrTmp);//将三个字符串组成一个字符串
|
|
tmpStr = FormsAuthentication.HashPasswordForStoringInConfigFile(tmpStr, "SHA1");//进行sha1加密
|
|
tmpStr = tmpStr.ToLower();
|
|
//加过密的字符串与微信发送的signature进行比较，一样则通过微信验证，否则失败。
|
|
if (tmpStr == signature)
|
|
{
|
|
return true;
|
|
}
|
|
else
|
|
{
|
|
return false;
|
|
}
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
/// 生成临时二维码
|
|
/// </summary>
|
|
/// <param name="days">二维码有效时间</param>
|
|
/// <param name="arg">二维码参数</param>
|
|
/// <returns></returns>
|
|
public static string GenerateEQCode(int days, int arg)
|
|
{
|
|
string ticket = string.Empty;
|
|
string uriStr = string.Format("https://api.weixin.qq.com/cgi-bin/qrcode/create?access_token={0}", TOKEN);
|
|
|
|
JavaScriptSerializer jsonHelper = new JavaScriptSerializer();
|
|
QRCodeResult result = new QRCodeResult();
|
|
QRCodeArgs body = new QRCodeArgs()
|
|
{
|
|
expire_seconds = 60 * 60 * 24 * days,
|
|
action_name = "QR_SCENE",
|
|
action_info = new QRCodeScene()
|
|
{
|
|
scene = new QRCodeSceneID()
|
|
{
|
|
scene_id = arg
|
|
}
|
|
}
|
|
};
|
|
string postData = jsonHelper.Serialize(body);
|
|
string data = string.Empty;
|
|
try
|
|
{
|
|
byte[] byteArray = Encoding.UTF8.GetBytes(postData);
|
|
HttpWebRequest webRequest = (HttpWebRequest)WebRequest.Create(new Uri(uriStr));
|
|
webRequest.Method = "post";
|
|
webRequest.ContentType = "application/x-www-form-urlencoded";
|
|
webRequest.ContentLength = byteArray.Length;
|
|
System.IO.Stream newStream = webRequest.GetRequestStream();
|
|
newStream.Write(byteArray, 0, byteArray.Length);
|
|
newStream.Close();
|
|
HttpWebResponse response = (HttpWebResponse)webRequest.GetResponse();
|
|
data = new System.IO.StreamReader(response.GetResponseStream(), Encoding.GetEncoding("utf-8")).ReadToEnd();
|
|
result = jsonHelper.Deserialize<QRCodeResult>(data);
|
|
}
|
|
catch (Exception e)
|
|
{
|
|
throw e;
|
|
}
|
|
if (result != null && !string.IsNullOrEmpty(result.ticket))
|
|
{
|
|
ticket = result.ticket;
|
|
}
|
|
return ticket;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 获取二维码图片
|
|
/// </summary>
|
|
/// <param name="ticket">票据</param>
|
|
/// <param name="path">图片保存路径</param>
|
|
/// <returns></returns>
|
|
public static void GetQRPic(string ticket, string path)
|
|
{
|
|
string uriStr = string.Format("https://mp.weixin.qq.com/cgi-bin/showqrcode?ticket={0}", ticket);
|
|
try
|
|
{
|
|
WebClient webClient = new WebClient();
|
|
webClient.DownloadFile(uriStr, path);
|
|
}
|
|
catch (Exception e)
|
|
{
|
|
throw e;
|
|
}
|
|
}
|
|
}
|
|
}
|