德云社岳云鹏专场,露西亚的情人,yihu
微信越来越火，微信公众平台成为开发成新宠，本文用c#.net开发微信公众信号接口。
微信接口地址代码:
我要评论
weixin _wx = new weixin();
string poststr = "";
if (request.httpmethod.tolower() == "post")
{
stream s = system.web.httpcontext.current.request.inputstream;
byte[] b = new byte[s.length];
s.read(b, 0, (int)s.length);
poststr = encoding.utf8.getstring(b);
if (!string.isnullorempty(poststr)) //请求处理
{
_wx.handle(poststr);
}
}
else
{
_wx.auth();
}
微信处理类：
public class weixin
{
private string token = "weixin_token"; //换成自己的token
public void auth()
{
string echostr = system.web.httpcontext.current.request.querystring["echostr"];
if (checksignature())
{
if (!string.isnullorempty(echostr))
{
system.web.httpcontext.current.response.write(echostr);
system.web.httpcontext.current.response.end();
}
}
}
public void handle(string poststr)
{
//封装请求类
xmldocument doc = new xmldocument();
doc.loadxml(poststr);
xmlelement rootelement = doc.documentelement;
xmlnode msgtype = rootelement.selectsinglenode("msgtype");
requestxml requestxml = new requestxml();
requestxml.tousername = rootelement.selectsinglenode("tousername").innertext;
requestxml.fromusername = rootelement.selectsinglenode("fromusername").innertext;
requestxml.createtime = rootelement.selectsinglenode("createtime").innertext;
requestxml.msgtype = msgtype.innertext;
if (requestxml.msgtype == "text")
{
requestxml.content = rootelement.selectsinglenode("content").innertext;
}
else if (requestxml.msgtype == "location")
{
requestxml.location_x = rootelement.selectsinglenode("location_x").innertext;
requestxml.location_y = rootelement.selectsinglenode("location_y").innertext;
requestxml.scale = rootelement.selectsinglenode("scale").innertext;
requestxml.label = rootelement.selectsinglenode("label").innertext;
}
else if (requestxml.msgtype == "image")
{
requestxml.picurl = rootelement.selectsinglenode("picurl").innertext;
}
//回复消息
responsemsg(requestxml);
}
/// <summary>
/// 验证微信签名
/// </summary>
/// * 将token、timestamp、nonce三个参数进行字典序排序
/// * 将三个参数字符串拼接成一个字符串进行sha1加密
/// * 开发者获得加密后的字符串可与signature对比，标识该请求来源于微信。
/// <returns></returns>
private bool checksignature()
{
string signature = system.web.httpcontext.current.request.querystring["signature"];
string timestamp = system.web.httpcontext.current.request.querystring["timestamp"];
string nonce = system.web.httpcontext.current.request.querystring["nonce"];
string[] arrtmp = { token, timestamp, nonce };
array.sort(arrtmp); //字典排序
string tmpstr = string.join("", arrtmp);
tmpstr = formsauthentication.hashpasswordforstoringinconfigfile(tmpstr, "sha1");
tmpstr = tmpstr.tolower();
if (tmpstr == signature)
{
return true;
}
else
{
return false;
}
}
/// <summary>
/// 回复消息(微信信息返回)
/// </summary>
/// <param name="weixinxml"></param>
private void responsemsg(requestxml requestxml)
{
try
{
string resxml = "";
mijiya mi = new mijiya(requestxml.content,requestxml.fromusername);
if (requestxml.msgtype == "text")
{
//在这里执行一系列操作，从而实现自动回复内容.
string _remsg = mi.getremsg();
if (mi.msgtype == 1)
{
resxml = "<xml><tousername><![cdata[" + requestxml.fromusername + "]]></tousername><fromusername><![cdata[" + requestxml.tousername + "]]></fromusername><createtime>" + convertdatetimeint(datetime.now) + "</createtime><msgtype><![cdata[news]]></msgtype><content><![cdata[]]></content><articlecount>2</articlecount><articles>";
resxml += mi.getrepic(requestxml.fromusername);
resxml += "</articles><funcflag>1</funcflag></xml>";
}
else
{
resxml = "<xml><tousername><![cdata[" + requestxml.fromusername + "]]></tousername><fromusername><![cdata[" + requestxml.tousername + "]]></fromusername><createtime>" + convertdatetimeint(datetime.now) + "</createtime><msgtype><![cdata[text]]></msgtype><content><![cdata[" + _remsg + "]]></content><funcflag>1</funcflag></xml>";
}
}
else if (requestxml.msgtype == "location")
{
string city = getmapinfo(requestxml.location_x, requestxml.location_y);
if (city == "0")
{
resxml = "<xml><tousername><![cdata[" + requestxml.fromusername + "]]></tousername><fromusername><![cdata[" + requestxml.tousername + "]]></fromusername><createtime>" + convertdatetimeint(datetime.now) + "</createtime><msgtype><![cdata[text]]></msgtype><content><![cdata[好啦，我们知道您的位置啦。您可以:" + mi.getdefault() + "]]></content><funcflag>1</funcflag></xml>";
}
else
{
resxml = "<xml><tousername><![cdata[" + requestxml.fromusername + "]]></tousername><fromusername><![cdata[" + requestxml.tousername + "]]></fromusername><createtime>" + convertdatetimeint(datetime.now) + "</createtime><msgtype><![cdata[text]]></msgtype><content><![cdata[好啦，我们知道您的位置啦。您可以:" + mi.getdefault() + "]]></content><funcflag>1</funcflag></xml>";
}
}
else if (requestxml.msgtype == "image")
{
resxml = "<xml><tousername><![cdata[" + requestxml.fromusername + "]]></tousername><fromusername><![cdata[" + requestxml.tousername + "]]></fromusername><createtime>" + convertdatetimeint(datetime.now) + "</createtime><msgtype><![cdata[text]]></msgtype><content><![cdata[亲,我没有看懂你的意思。您可以:" + mi.getdefault() + "]]></content><funcflag>1</funcflag></xml>";
//返回10以内条
//int size = 10;
//resxml = "<xml><tousername><![cdata[" + requestxml.fromusername + "]]></tousername><fromusername><![cdata[" + requestxml.tousername + "]]></fromusername><createtime>" + convertdatetimeint(datetime.now) + "</createtime><msgtype><![cdata[news]]></msgtype><content><![cdata[]]></content><articlecount>" + size + "</articlecount><articles>";
//list<string> list = new list<string>();
////假如有20条查询的返回结果
//for (int i = 0; i < 20; i++)
//{
// list.add("1");
//}
//string[] piclist = new string[] { "/abstract_pencil_scribble_background_vector_main.jpg", "/balloon_tree.jpg", "/bloom.jpg", "/colorful_flowers.jpg", "/colorful_summer_flower.jpg", "/fall.jpg", "/fall_tree.jpg", "/growing_flowers.jpg", "/shoes_illustration.jpg", "/splashed_tree.jpg" };
//for (int i = 0; i < size && i < list.count; i++)
//{
// resxml += "<item><title><![cdata[沈阳-黑龙江]]></title><description><![cdata[元旦特价：￥300 市场价：￥400]]></description><picurl><![cdata[" + "http://www.hougelou.com" + piclist[i] + "]]></picurl><url><![cdata[http://www.hougelou.com]]></url></item>";
//}
//resxml += "</articles><funcflag>1</funcflag></xml>";
}
else if (wx_tmsg.getmsgcount(requestxml.fromusername) == 0)
{
resxml = "<xml><tousername><![cdata[" + requestxml.fromusername + "]]></tousername><fromusername><![cdata[" + requestxml.tousername + "]]></fromusername><createtime>" + convertdatetimeint(datetime.now) + "</createtime><msgtype><![cdata[text]]></msgtype><content><![cdata[" + mi.getfirst() + "]]></content><funcflag>1</funcflag></xml>";
}
else
{
resxml = "<xml><tousername><![cdata[" + requestxml.fromusername + "]]></tousername><fromusername><![cdata[" + requestxml.tousername + "]]></fromusername><createtime>" + convertdatetimeint(datetime.now) + "</createtime><msgtype><![cdata[text]]></msgtype><content><![cdata[亲,我没有看懂你的意思。您可以:" + mi.getdefault() + "]]></content><funcflag>1</funcflag></xml>";
}
//writetxt(resxml);
system.web.httpcontext.current.response.write(resxml);
writetodb(requestxml, resxml,mi.pid);
}
catch (exception ex)
{
//writetxt("异常：" + ex.message + "struck:" + ex.stacktrace.tostring());
wx_logs.myinsert("异常：" + ex.message + "struck:" + ex.stacktrace.tostring());
}
}
/// <summary>
/// unix时间转换为datetime
/// </summary>
/// <param name="timestamp"></param>
/// <returns></returns>
private datetime unixtimetotime(string timestamp)
{
datetime dtstart = timezone.currenttimezone.tolocaltime(new datetime(1970, 1, 1));
long ltime = long.parse(timestamp + "0000000");
timespan tonow = new timespan(ltime);
return dtstart.add(tonow);
}
/// <summary>
/// datetime转换为unixtime
/// </summary>
/// <param name="time"></param>
/// <returns></returns>
private int convertdatetimeint(system.datetime time)
{
system.datetime starttime = timezone.currenttimezone.tolocaltime(new system.datetime(1970, 1, 1));
return (int)(time - starttime).totalseconds;
}
/// <summary>
/// 调用百度地图，返回坐标信息
/// </summary>
/// <param name="y">经度</param>
/// <param name="x">纬度</param>
/// <returns></returns>
public string getmapinfo(string x, string y)
{
try
{
string res = string.empty;
string parame = string.empty;
string url = "http://maps.googleapis.com/maps/api/geocode/xml";
parame = "latlng=" + x + "," + y + "&language=zh-cn&sensor=false";//此key为个人申请
res = webrequestpost(url, parame);
xmldocument doc = new xmldocument();
doc.loadxml(res);
xmlelement rootelement = doc.documentelement;
string status = rootelement.selectsinglenode("status").innertext;
if (status == "ok")
{
//仅获取城市
xmlnodelist xmlresults = rootelement.selectsinglenode("/geocoderesponse").childnodes;
for (int i = 0; i < xmlresults.count; i++)
{
xmlnode childnode = xmlresults[i];
if (childnode.name == "status")
{
continue;
}
string city = "0";
for (int w = 0; w < childnode.childnodes.count; w++)
{
for (int q = 0; q < childnode.childnodes[w].childnodes.count; q++)
{
xmlnode childetwo = childnode.childnodes[w].childnodes[q];
if (childetwo.name == "long_name")
{
city = childetwo.innertext;
}
else if (childetwo.innertext == "locality")
{
return city;
}
}
}
return city;
}
}
}
catch (exception ex)
{
//writetxt("map异常:" + ex.message.tostring() + "struck:" + ex.stacktrace.tostring());
return "0";
}
return "0";
}
/// <summary>
/// post 提交调用抓取
/// </summary>
/// <param name="url">提交地址</param>
/// <param name="param">参数</param>
/// <returns>string</returns>
public string webrequestpost(string url, string param)
{
byte[] bs = system.text.encoding.utf8.getbytes(param);
httpwebrequest req = (httpwebrequest)httpwebrequest.create(url + "?" + param);
req.method = "post";
req.timeout = 120 * 1000;
req.contenttype = "application/x-www-form-urlencoded;";
req.contentlength = bs.length;
using (stream reqstream = req.getrequeststream())
{
reqstream.write(bs, 0, bs.length);
reqstream.flush();
}
using (webresponse wr = req.getresponse())
{
//在这里对接收到的页面内容进行处理
stream strm = wr.getresponsestream();
streamreader sr = new streamreader(strm, system.text.encoding.utf8);
string line;
system.text.stringbuilder sb = new system.text.stringbuilder();
while ((line = sr.readline()) != null)
{
sb.append(line + system.environment.newline);
}
sr.close();
strm.close();
return sb.tostring();
}
}
private void writetodb(requestxml requestxml,string _xml,int _pid)
{
wx_tmsg wx = new wx_tmsg();
wx.addnew();
wx.fromusername = requestxml.fromusername;
wx.tousername = requestxml.tousername;
wx.msgtype = requestxml.msgtype;
wx.msg = requestxml.content;
wx.creatime = requestxml.createtime;
wx.location_x = requestxml.location_x;
wx.location_y = requestxml.location_y;
wx.label = requestxml.label;
wx.scale = requestxml.scale;
wx.picurl = requestxml.picurl;
wx.reply = _xml;
wx.pid = _pid;
try
{
wx.update();
}
catch (exception ex)
{
wx_logs.myinsert(ex.message);
//ex.message;
}
}
}
//微信请求类
public class requestxml
{
private string tousername="";
/// <summary>
/// 消息接收方微信号，一般为公众平台账号微信号
/// </summary>
public string tousername
{
get { return tousername; }
set { tousername = value; }
}
private string fromusername = "";
/// <summary>
/// 消息发送方微信号
/// </summary>
public string fromusername
{
get { return fromusername; }
set { fromusername = value; }
}
private string createtime = "";
/// <summary>
/// 创建时间
/// </summary>
public string createtime
{
get { return createtime; }
set { createtime = value; }
}
private string msgtype = "";
/// <summary>
/// 信息类型 地理位置:location,文本消息:text,消息类型:image
/// </summary>
public string msgtype
{
get { return msgtype; }
set { msgtype = value; }
}
private string content = "";
/// <summary>
/// 信息内容
/// </summary>
public string content
{
get { return content; }
set { content = value; }
}
private string location_x = "";
/// <summary>
/// 地理位置纬度
/// </summary>
public string location_x
{
get { return location_x; }
set { location_x = value; }
}
private string location_y = "";
/// <summary>
/// 地理位置经度
/// </summary>
public string location_y
{
get { return location_y; }
set { location_y = value; }
}
private string scale = "";
/// <summary>
/// 地图缩放大小
/// </summary>
public string scale
{
get { return scale; }
set { scale = value; }
}
private string label = "";
/// <summary>
/// 地理位置信息
/// </summary>
public string label
{
get { return label; }
set { label = value; }
}
private string picurl = "";
/// <summary>
/// 图片链接，开发者可以用http get获取
/// </summary>
public string picurl
{
get { return picurl; }
set { picurl = value; }
}
}
说明： 其中用到的mijiya类，主要是调用数据库进行关键词匹配自动回复内容，可以根据自己的业务情况编写。
如对本文有疑问，请在下面进行留言讨论，广大热心网友会与你互动！！ 点击进行留言回复
Blazor server side 自家的一些开源的, 实用型项目的进度之 CEF客户端
.NET IoC模式依赖反转(DIP)、控制反转(Ioc)、依赖注入(DI)
vue+.netcore可支持业务代码扩展的开发框架 VOL.Vue 2.0版本发布
网友评论