C#.net 微信公衆帳號接口開發

微信愈來愈火,微信公衆平臺成爲開發成新寵,本文用C#.net開發微信公衆信號接口。 web

微信接口地址代碼: 數據庫

  weixin _wx = new weixin(); api

                string postStr = ""; 微信

                if (Request.HttpMethod.ToLower() == "post") app

                { 微信公衆平臺

                    Stream s = System.Web.HttpContext.Current.Request.InputStream; post

                    byte[] b = new byte[s.Length]; 網站

                    s.Read(b, 0, (int)s.Length); ui

                    postStr = Encoding.UTF8.GetString(b); google

                    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>

        /// * tokentimestampnonce三個參數進行字典序排序

        /// * 將三個參數字符串拼接成一個字符串進行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類,主要是調用數據庫進行關鍵詞匹配自動回覆內容,能夠根據本身的業務狀況編寫。

有任何問題能夠到咱們網站提問: http://www.mijiya.com

也能夠掃描咱們的公衆帳號提問:

相關文章
相關標籤/搜索