自动回复调整

.gitignore

@@ -15,3 +15,5 @@ ServiceWechat/ServiceWechat.Utility/obj/ServiceWechat.Utility.csproj.nuget.cache
 ServiceWechat/ServiceWechat.Utility/obj/ServiceWechat.Utility.csproj.nuget.g.props
 ServiceWechat/ServiceWechat.Utility/obj/ServiceWechat.Utility.csproj.nuget.g.targets
 /ServiceWechat/.vs/ServiceWechat/v15
+/ServiceWechat/ServiceWechat.Utility/obj/Release/netcoreapp2.0
+/ServiceWechat/ServiceWechat.Utility/bin/Release/netcoreapp2.0

ServiceWechat/ServiceWechat/Controllers/WechatApis/HomeController.cs

@@ -9,6 +9,10 @@ using Senparc.Weixin.MP.MvcExtension;
 using Senparc.Weixin.MP.Entities.Request;
 using ServiceWechat.Api.MessageHandlers.CustomMessageHandler;
 using ServiceWechat.Api.Controllers.Base;
+using Microsoft.Extensions.Logging;
+using NLog;
+using System.Text;
+using System.IO;
 
 namespace ServiceWechat.Api.Controllers.WechatApis
 {
@@ -18,6 +22,7 @@ namespace ServiceWechat.Api.Controllers.WechatApis
         private readonly string Token;
         private readonly string AppId;
         private readonly string EncodingAESKey;
+        static Logger Logger = LogManager.GetCurrentClassLogger();
         public HomeController(IConfiguration configuration)
         {
             Token = configuration["WechatStatic:Token"];
@@ -36,8 +41,12 @@ namespace ServiceWechat.Api.Controllers.WechatApis
         [HttpGet]
         public string Verify(string signature, string timestamp, string nonce, string echostr)
         {
+
             if (CheckSignature.Check(signature, timestamp, nonce, Token))
+            {
+                Logger.Info($"接收微信开发验证");
                 return echostr; //返回随机字符串则表示验证通过
+            }
             return $"failed:{signature},{CheckSignature.GetSignature(timestamp, nonce, Token) }。如果您在浏览器中看到这条信息，表明此Url可以填入微信后台。";
         }
 
@@ -45,22 +54,41 @@ namespace ServiceWechat.Api.Controllers.WechatApis
         /// 用户发送消息后，微信平台自动Post一个请求到这里，并等待响应XML。
         /// </summary>
         [HttpPost]
-        public WeixinResult RecieveMsg(PostModel postModel)
+        public WeixinResult Verify(PostModel postModel)
         {
-            if (!CheckSignature.Check(postModel.Signature, postModel.Timestamp, postModel.Nonce, Token))
+
+            CustomMessageHandler messageHandler = null;
+            try
             {
-                return new WeixinResult("参数错误");
-            }
+                if (!CheckSignature.Check(postModel.Signature, postModel.Timestamp, postModel.Nonce, Token))
+                {
+                    return new WeixinResult("参数错误");
+                }
+
+                postModel.Token = Token;//根据自己后台的设置保持一致
+                postModel.EncodingAESKey = EncodingAESKey;//根据自己后台的设置保持一致
+                postModel.AppId = AppId;//根据自己后台的设置保持一致
 
-            postModel.Token = Token;//根据自己后台的设置保持一致
-            postModel.EncodingAESKey = EncodingAESKey;//根据自己后台的设置保持一致
-            postModel.AppId = AppId;//根据自己后台的设置保持一致
+                //StreamReader reader = new StreamReader(Request.Body, Encoding.);
+                //string text = reader.ReadToEnd();
 
-            //自定义MessageHandler，对微信请求的详细判断操作都在这里面。
-            var messageHandler = new CustomMessageHandler(Request.Body, postModel);//接收消息
-            messageHandler.Execute();//执行微信处理过程
+
+                //Logger.Info($"接收用户消息调用RecieveMsg 【{  text }】");
+                //自定义MessageHandler，对微信请求的详细判断操作都在这里面。
+                messageHandler = new CustomMessageHandler(Request.Body, postModel);//接收消息
+                messageHandler.Execute();//执行微信处理过程
+                return new WeixinResult(messageHandler);//返回结果
+            }
+            catch (Exception ex)
+            {
+                Logger.Error(ex);
+            }
             return new WeixinResult(messageHandler);//返回结果
         }
 
+        public string Test()
+        {
+            return "test";
+        }
     }
 }

ServiceWechat/ServiceWechat/Controllers/WechatApis/MenuController.cs

@@ -1,14 +1,20 @@
 using System;
 using System.Collections.Generic;
+using System.IO;
 using System.Linq;
+using System.Text;
 using System.Threading.Tasks;
 using Microsoft.AspNetCore.Mvc;
 using Microsoft.Extensions.Configuration;
+using Microsoft.Extensions.Logging;
+using Newtonsoft.Json;
+using NLog;
 using Senparc.Weixin.MP;
 using Senparc.Weixin.MP.CommonAPIs;
 using Senparc.Weixin.MP.Containers;
 using Senparc.Weixin.MP.Entities.Menu;
 using ServiceWechat.Api.Controllers.Base;
+using ServiceWechat.Api.Models;
 
 // For more information on enabling Web API for empty projects, visit https://go.microsoft.com/fwlink/?LinkID=397860
 
@@ -21,6 +27,7 @@ namespace ServiceWechat.Api.Controllers.WechatApis
         private readonly string AppId;
         private readonly string AppSecret;
         private readonly string EncodingAESKey;
+        static Logger Logger = LogManager.GetCurrentClassLogger();
         public MenuController(IConfiguration configuration)
         {
             Token = configuration["WechatStatic:Token"];
@@ -48,43 +55,83 @@ namespace ServiceWechat.Api.Controllers.WechatApis
         [HttpPost]
         public JsonResult CreateMenus()
         {
-            ButtonGroup btnGroup = new ButtonGroup();
+            StreamReader reader = new StreamReader(Request.Body, Encoding.UTF8);
+            string text = reader.ReadToEnd();
+            var MenuButtons = JsonConvert.DeserializeObject<MenuButtons>(text);
 
-            //单击
-            btnGroup.button.Add(new SingleClickButton()
+            ButtonGroup btnGroup = new ButtonGroup();
+            foreach (var list in MenuButtons.Menus)
             {
-                name = "单击测试",
-                key = "OneClick",
-                type = ButtonType.click.ToString(),//默认已经设为此类型，这里只作为演示
+                if (list.Count > 0)
+                {
+                    SubButton subButton = null;
+                    foreach (var item in list)
+                    {
+                        if (item == null) continue;
 
-            });
+                        SingleButton button = null;
+                        if (list.Count <= 1)
+                        {
+
+                            if (item.Type == "click")
+                            {
+                                button = new SingleClickButton()
+                                {
+                                    name = item.Name,
+                                    key = item.Key,
+                                    type = item.Type,
+                                };
+                            }
+                            else if (item.Type == "view")
+                            {
+                                button = new SingleViewButton()
+                                {
+                                    url = item.Url,
+                                    name = item.Name
+                                };
+                            }
+                            btnGroup.button.Add(button);
+                        }
+                        else
+                        {
+                            if (subButton == null)
+                            {
+                                subButton = new SubButton()
+                                {
+                                    name = item.Name
+                                };
+                            }
+                            else
+                            {
+                                if (item.Type == "click")
+                                {
+                                    button = new SingleClickButton()
+                                    {
+                                        name = item.Name,
+                                        key = item.Key,
+                                        type = item.Type,
+                                    };
+                                }
+                                else if (item.Type == "view")
+                                {
+                                    button = new SingleViewButton()
+                                    {
+                                        url = item.Url,
+                                        name = item.Name
+                                    };
+                                }
+                                subButton.sub_button.Add(button);
+                            }
+                        }
+                    }
+
+                    if (subButton != null && subButton.sub_button.Count > 0)
+                    {
+                        btnGroup.button.Add(subButton);
+                    }
+                }
+            }
 
-            //二级菜单
-            var subButton = new SubButton()
-            {
-                name = "二级菜单"
-            };
-            subButton.sub_button.Add(new SingleClickButton()
-            {
-                key = "SubClickRoot_Text",
-                name = "返回文本"
-            });
-            subButton.sub_button.Add(new SingleClickButton()
-            {
-                key = "SubClickRoot_News",
-                name = "返回图文"
-            });
-            subButton.sub_button.Add(new SingleClickButton()
-            {
-                key = "SubClickRoot_Music",
-                name = "返回音乐"
-            });
-            subButton.sub_button.Add(new SingleViewButton()
-            {
-                url = "http://weixin.senparc.com",
-                name = "Url跳转"
-            });
-            btnGroup.button.Add(subButton);
 
             var result = CommonApi.CreateMenu(AppId, btnGroup);
             return new JsonResult(result);

ServiceWechat/ServiceWechat/CryptCode/Cryptography.cs

@@ -0,0 +1,232 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Security.Cryptography;
+using System.IO;
+using System.Net;
+namespace ServiceWechat.Api.CryptCode
+{
+    public class Cryptography
+    {
+        public static UInt32 HostToNetworkOrder(UInt32 inval)
+        {
+            UInt32 outval = 0;
+            for (int i = 0; i < 4; i++)
+                outval = (outval << 8) + ((inval >> (i * 8)) & 255);
+            return outval;
+        }
+
+        public static Int32 HostToNetworkOrder(Int32 inval)
+        {
+            Int32 outval = 0;
+            for (int i = 0; i < 4; i++)
+                outval = (outval << 8) + ((inval >> (i * 8)) & 255);
+            return outval;
+        }
+        /// <summary>
+        /// 解密方法
+        /// </summary>
+        /// <param name="Input">密文</param>
+        /// <param name="EncodingAESKey"></param>
+        /// <returns></returns>
+        /// 
+        public static string AES_decrypt(String Input, string EncodingAESKey, ref string appid)
+        {
+            byte[] Key;
+            Key = Convert.FromBase64String(EncodingAESKey + "=");
+            byte[] Iv = new byte[16];
+            Array.Copy(Key, Iv, 16);
+            byte[] btmpMsg = AES_decrypt(Input, Iv, Key);
+
+            int len = BitConverter.ToInt32(btmpMsg, 16);
+            len = IPAddress.NetworkToHostOrder(len);
+
+
+            byte[] bMsg = new byte[len];
+            byte[] bAppid = new byte[btmpMsg.Length - 20 - len];
+            Array.Copy(btmpMsg, 20, bMsg, 0, len);
+            Array.Copy(btmpMsg, 20 + len, bAppid, 0, btmpMsg.Length - 20 - len);
+            string oriMsg = Encoding.UTF8.GetString(bMsg);
+            appid = Encoding.UTF8.GetString(bAppid);
+
+
+            return oriMsg;
+        }
+
+        public static String AES_encrypt(String Input, string EncodingAESKey, string appid)
+        {
+            byte[] Key;
+            Key = Convert.FromBase64String(EncodingAESKey + "=");
+            byte[] Iv = new byte[16];
+            Array.Copy(Key, Iv, 16);
+            string Randcode = CreateRandCode(16);
+            byte[] bRand = Encoding.UTF8.GetBytes(Randcode);
+            byte[] bAppid = Encoding.UTF8.GetBytes(appid);
+            byte[] btmpMsg = Encoding.UTF8.GetBytes(Input);
+            byte[] bMsgLen = BitConverter.GetBytes(HostToNetworkOrder(btmpMsg.Length));
+            byte[] bMsg = new byte[bRand.Length + bMsgLen.Length + bAppid.Length + btmpMsg.Length];
+
+            Array.Copy(bRand, bMsg, bRand.Length);
+            Array.Copy(bMsgLen, 0, bMsg, bRand.Length, bMsgLen.Length);
+            Array.Copy(btmpMsg, 0, bMsg, bRand.Length + bMsgLen.Length, btmpMsg.Length);
+            Array.Copy(bAppid, 0, bMsg, bRand.Length + bMsgLen.Length + btmpMsg.Length, bAppid.Length);
+
+            return AES_encrypt(bMsg, Iv, Key);
+
+        }
+        private static string CreateRandCode(int codeLen)
+        {
+            string codeSerial = "2,3,4,5,6,7,a,c,d,e,f,h,i,j,k,m,n,p,r,s,t,A,C,D,E,F,G,H,J,K,M,N,P,Q,R,S,U,V,W,X,Y,Z";
+            if (codeLen == 0)
+            {
+                codeLen = 16;
+            }
+            string[] arr = codeSerial.Split(',');
+            string code = "";
+            int randValue = -1;
+            Random rand = new Random(unchecked((int)DateTime.Now.Ticks));
+            for (int i = 0; i < codeLen; i++)
+            {
+                randValue = rand.Next(0, arr.Length - 1);
+                code += arr[randValue];
+            }
+            return code;
+        }
+
+        private static String AES_encrypt(String Input, byte[] Iv, byte[] Key)
+        {
+            var aes = new RijndaelManaged();
+            //秘钥的大小，以位为单位
+            aes.KeySize = 256;
+            //支持的块大小
+            aes.BlockSize = 128;
+            //填充模式
+            aes.Padding = PaddingMode.PKCS7;
+            aes.Mode = CipherMode.CBC;
+            aes.Key = Key;
+            aes.IV = Iv;
+            var encrypt = aes.CreateEncryptor(aes.Key, aes.IV);
+            byte[] xBuff = null;
+
+            using (var ms = new MemoryStream())
+            {
+                using (var cs = new CryptoStream(ms, encrypt, CryptoStreamMode.Write))
+                {
+                    byte[] xXml = Encoding.UTF8.GetBytes(Input);
+                    cs.Write(xXml, 0, xXml.Length);
+                }
+                xBuff = ms.ToArray();
+            }
+            String Output = Convert.ToBase64String(xBuff);
+            return Output;
+        }
+
+        private static String AES_encrypt(byte[] Input, byte[] Iv, byte[] Key)
+        {
+            var aes = new RijndaelManaged();
+            //秘钥的大小，以位为单位
+            aes.KeySize = 256;
+            //支持的块大小
+            aes.BlockSize = 128;
+            //填充模式
+            //aes.Padding = PaddingMode.PKCS7;
+            aes.Padding = PaddingMode.None;
+            aes.Mode = CipherMode.CBC;
+            aes.Key = Key;
+            aes.IV = Iv;
+            var encrypt = aes.CreateEncryptor(aes.Key, aes.IV);
+            byte[] xBuff = null;
+
+            #region 自己进行PKCS7补位，用系统自己带的不行
+            byte[] msg = new byte[Input.Length + 32 - Input.Length % 32];
+            Array.Copy(Input, msg, Input.Length);
+            byte[] pad = KCS7Encoder(Input.Length);
+            Array.Copy(pad, 0, msg, Input.Length, pad.Length);
+            #endregion
+
+            #region 注释的也是一种方法，效果一样
+            //ICryptoTransform transform = aes.CreateEncryptor();
+            //byte[] xBuff = transform.TransformFinalBlock(msg, 0, msg.Length);
+            #endregion
+
+            using (var ms = new MemoryStream())
+            {
+                using (var cs = new CryptoStream(ms, encrypt, CryptoStreamMode.Write))
+                {
+                    cs.Write(msg, 0, msg.Length);
+                }
+                xBuff = ms.ToArray();
+            }
+
+            String Output = Convert.ToBase64String(xBuff);
+            return Output;
+        }
+
+        private static byte[] KCS7Encoder(int text_length)
+        {
+            int block_size = 32;
+            // 计算需要填充的位数
+            int amount_to_pad = block_size - (text_length % block_size);
+            if (amount_to_pad == 0)
+            {
+                amount_to_pad = block_size;
+            }
+            // 获得补位所用的字符
+            char pad_chr = chr(amount_to_pad);
+            string tmp = "";
+            for (int index = 0; index < amount_to_pad; index++)
+            {
+                tmp += pad_chr;
+            }
+            return Encoding.UTF8.GetBytes(tmp);
+        }
+        /**
+         * 将数字转化成ASCII码对应的字符，用于对明文进行补码
+         * 
+         * @param a 需要转化的数字
+         * @return 转化得到的字符
+         */
+        static char chr(int a)
+        {
+
+            byte target = (byte)(a & 0xFF);
+            return (char)target;
+        }
+        private static byte[] AES_decrypt(String Input, byte[] Iv, byte[] Key)
+        {
+            RijndaelManaged aes = new RijndaelManaged();
+            aes.KeySize = 256;
+            aes.BlockSize = 128;
+            aes.Mode = CipherMode.CBC;
+            aes.Padding = PaddingMode.None;
+            aes.Key = Key;
+            aes.IV = Iv;
+            var decrypt = aes.CreateDecryptor(aes.Key, aes.IV);
+            byte[] xBuff = null;
+            using (var ms = new MemoryStream())
+            {
+                using (var cs = new CryptoStream(ms, decrypt, CryptoStreamMode.Write))
+                {
+                    byte[] xXml = Convert.FromBase64String(Input);
+                    byte[] msg = new byte[xXml.Length + 32 - xXml.Length % 32];
+                    Array.Copy(xXml, msg, xXml.Length);
+                    cs.Write(xXml, 0, xXml.Length);
+                }
+                xBuff = decode2(ms.ToArray());
+            }
+            return xBuff;
+        }
+        private static byte[] decode2(byte[] decrypted)
+        {
+            int pad = (int)decrypted[decrypted.Length - 1];
+            if (pad < 1 || pad > 32)
+            {
+                pad = 0;
+            }
+            byte[] res = new byte[decrypted.Length - pad];
+            Array.Copy(decrypted, 0, res, 0, decrypted.Length - pad);
+            return res;
+        }
+    }
+}

ServiceWechat/ServiceWechat/CryptCode/WXBizMsgCrypt.cs

@@ -0,0 +1,221 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Xml;
+using System.Collections;
+//using System.Web;
+using System.Security.Cryptography;
+//-40001 ： 签名验证错误
+//-40002 :  xml解析失败
+//-40003 :  sha加密生成签名失败
+//-40004 :  AESKey 非法
+//-40005 :  appid 校验错误
+//-40006 :  AES 加密失败
+//-40007 ： AES 解密失败
+//-40008 ： 解密后得到的buffer非法
+//-40009 :  base64加密异常
+//-40010 :  base64解密异常
+namespace ServiceWechat.Api.CryptCode
+{
+    public class WXBizMsgCrypt
+    {
+        string m_sToken;
+        string m_sEncodingAESKey;
+        string m_sAppID;
+        enum WXBizMsgCryptErrorCode
+        {
+            WXBizMsgCrypt_OK = 0,
+            WXBizMsgCrypt_ValidateSignature_Error = -40001,
+            WXBizMsgCrypt_ParseXml_Error = -40002,
+            WXBizMsgCrypt_ComputeSignature_Error = -40003,
+            WXBizMsgCrypt_IllegalAesKey = -40004,
+            WXBizMsgCrypt_ValidateAppid_Error = -40005,
+            WXBizMsgCrypt_EncryptAES_Error = -40006,
+            WXBizMsgCrypt_DecryptAES_Error = -40007,
+            WXBizMsgCrypt_IllegalBuffer = -40008,
+            WXBizMsgCrypt_EncodeBase64_Error = -40009,
+            WXBizMsgCrypt_DecodeBase64_Error = -40010
+        };
+
+        //构造函数
+        // @param sToken: 公众平台上，开发者设置的Token
+        // @param sEncodingAESKey: 公众平台上，开发者设置的EncodingAESKey
+        // @param sAppID: 公众帐号的appid
+        public WXBizMsgCrypt(string sToken, string sEncodingAESKey, string sAppID)
+        {
+            m_sToken = sToken;
+            m_sAppID = sAppID;
+            m_sEncodingAESKey = sEncodingAESKey;
+        }
+
+
+        // 检验消息的真实性，并且获取解密后的明文
+        // @param sMsgSignature: 签名串，对应URL参数的msg_signature
+        // @param sTimeStamp: 时间戳，对应URL参数的timestamp
+        // @param sNonce: 随机串，对应URL参数的nonce
+        // @param sPostData: 密文，对应POST请求的数据
+        // @param sMsg: 解密后的原文，当return返回0时有效
+        // @return: 成功0，失败返回对应的错误码
+        public int DecryptMsg(string sMsgSignature, string sTimeStamp, string sNonce, string sPostData, ref string sMsg)
+        {
+            if (m_sEncodingAESKey.Length != 43)
+            {
+                return (int)WXBizMsgCryptErrorCode.WXBizMsgCrypt_IllegalAesKey;
+            }
+            XmlDocument doc = new XmlDocument();
+            XmlNode root;
+            string sEncryptMsg;
+            try
+            {
+                doc.LoadXml(sPostData);
+                root = doc.FirstChild;
+                sEncryptMsg = root["Encrypt"].InnerText;
+            }
+            catch (Exception)
+            {
+                return (int)WXBizMsgCryptErrorCode.WXBizMsgCrypt_ParseXml_Error;
+            }
+            //verify signature
+            int ret = 0;
+            ret = VerifySignature(m_sToken, sTimeStamp, sNonce, sEncryptMsg, sMsgSignature);
+            if (ret != 0)
+                return ret;
+            //decrypt
+            string cpid = "";
+            try
+            {
+                sMsg = Cryptography.AES_decrypt(sEncryptMsg, m_sEncodingAESKey, ref cpid);
+            }
+            catch (FormatException)
+            {
+                return (int)WXBizMsgCryptErrorCode.WXBizMsgCrypt_DecodeBase64_Error;
+            }
+            catch (Exception)
+            {
+                return (int)WXBizMsgCryptErrorCode.WXBizMsgCrypt_DecryptAES_Error;
+            }
+            if (cpid != m_sAppID)
+                return (int)WXBizMsgCryptErrorCode.WXBizMsgCrypt_ValidateAppid_Error;
+            return 0;
+        }
+
+        //将企业号回复用户的消息加密打包
+        // @param sReplyMsg: 企业号待回复用户的消息，xml格式的字符串
+        // @param sTimeStamp: 时间戳，可以自己生成，也可以用URL参数的timestamp
+        // @param sNonce: 随机串，可以自己生成，也可以用URL参数的nonce
+        // @param sEncryptMsg: 加密后的可以直接回复用户的密文，包括msg_signature, timestamp, nonce, encrypt的xml格式的字符串,
+        //						当return返回0时有效
+        // return：成功0，失败返回对应的错误码
+        public int EncryptMsg(string sReplyMsg, string sTimeStamp, string sNonce, ref string sEncryptMsg)
+        {
+            if (m_sEncodingAESKey.Length != 43)
+            {
+                return (int)WXBizMsgCryptErrorCode.WXBizMsgCrypt_IllegalAesKey;
+            }
+            string raw = "";
+            try
+            {
+                raw = Cryptography.AES_encrypt(sReplyMsg, m_sEncodingAESKey, m_sAppID);
+            }
+            catch (Exception)
+            {
+                return (int)WXBizMsgCryptErrorCode.WXBizMsgCrypt_EncryptAES_Error;
+            }
+            string MsgSigature = "";
+            int ret = 0;
+            ret = GenarateSinature(m_sToken, sTimeStamp, sNonce, raw, ref MsgSigature);
+            if (0 != ret)
+                return ret;
+            sEncryptMsg = "";
+
+            string EncryptLabelHead = "<Encrypt><![CDATA[";
+            string EncryptLabelTail = "]]></Encrypt>";
+            string MsgSigLabelHead = "<MsgSignature><![CDATA[";
+            string MsgSigLabelTail = "]]></MsgSignature>";
+            string TimeStampLabelHead = "<TimeStamp><![CDATA[";
+            string TimeStampLabelTail = "]]></TimeStamp>";
+            string NonceLabelHead = "<Nonce><![CDATA[";
+            string NonceLabelTail = "]]></Nonce>";
+            sEncryptMsg = sEncryptMsg + "<xml>" + EncryptLabelHead + raw + EncryptLabelTail;
+            sEncryptMsg = sEncryptMsg + MsgSigLabelHead + MsgSigature + MsgSigLabelTail;
+            sEncryptMsg = sEncryptMsg + TimeStampLabelHead + sTimeStamp + TimeStampLabelTail;
+            sEncryptMsg = sEncryptMsg + NonceLabelHead + sNonce + NonceLabelTail;
+            sEncryptMsg += "</xml>";
+            return 0;
+        }
+
+        public class DictionarySort : System.Collections.IComparer
+        {
+            public int Compare(object oLeft, object oRight)
+            {
+                string sLeft = oLeft as string;
+                string sRight = oRight as string;
+                int iLeftLength = sLeft.Length;
+                int iRightLength = sRight.Length;
+                int index = 0;
+                while (index < iLeftLength && index < iRightLength)
+                {
+                    if (sLeft[index] < sRight[index])
+                        return -1;
+                    else if (sLeft[index] > sRight[index])
+                        return 1;
+                    else
+                        index++;
+                }
+                return iLeftLength - iRightLength;
+
+            }
+        }
+        //Verify Signature
+        private static int VerifySignature(string sToken, string sTimeStamp, string sNonce, string sMsgEncrypt, string sSigture)
+        {
+            string hash = "";
+            int ret = 0;
+            ret = GenarateSinature(sToken, sTimeStamp, sNonce, sMsgEncrypt, ref hash);
+            if (ret != 0)
+                return ret;
+            //System.Console.WriteLine(hash);
+            if (hash == sSigture)
+                return 0;
+            else
+            {
+                return (int)WXBizMsgCryptErrorCode.WXBizMsgCrypt_ValidateSignature_Error;
+            }
+        }
+
+        public static int GenarateSinature(string sToken, string sTimeStamp, string sNonce, string sMsgEncrypt, ref string sMsgSignature)
+        {
+            ArrayList AL = new ArrayList();
+            AL.Add(sToken);
+            AL.Add(sTimeStamp);
+            AL.Add(sNonce);
+            AL.Add(sMsgEncrypt);
+            AL.Sort(new DictionarySort());
+            string raw = "";
+            for (int i = 0; i < AL.Count; ++i)
+            {
+                raw += AL[i];
+            }
+
+            SHA1 sha;
+            ASCIIEncoding enc;
+            string hash = "";
+            try
+            {
+                sha = new SHA1CryptoServiceProvider();
+                enc = new ASCIIEncoding();
+                byte[] dataToHash = enc.GetBytes(raw);
+                byte[] dataHashed = sha.ComputeHash(dataToHash);
+                hash = BitConverter.ToString(dataHashed).Replace("-", "");
+                hash = hash.ToLower();
+            }
+            catch (Exception)
+            {
+                return (int)WXBizMsgCryptErrorCode.WXBizMsgCrypt_ComputeSignature_Error;
+            }
+            sMsgSignature = hash;
+            return 0;
+        }
+    }
+}

ServiceWechat/ServiceWechat/MessageHandlers/CustomMessageHandler/CustomMessageContext.cs

@@ -8,22 +8,29 @@ using Senparc.Weixin;
 
 namespace ServiceWechat.Api.MessageHandlers.CustomMessageHandler
 {
-    public class CustomMessageContext : IMessageContext<IRequestMessageBase, IResponseMessageBase>
+    public class CustomMessageContext : MessageContext<IRequestMessageBase, IResponseMessageBase>
     {
-        public string UserName { get => throw new NotImplementedException(); set => throw new NotImplementedException(); }
-        public DateTime LastActiveTime { get => throw new NotImplementedException(); set => throw new NotImplementedException(); }
-        public MessageContainer<IRequestMessageBase> RequestMessages { get => throw new NotImplementedException(); set => throw new NotImplementedException(); }
-        public MessageContainer<IResponseMessageBase> ResponseMessages { get => throw new NotImplementedException(); set => throw new NotImplementedException(); }
-        public int MaxRecordCount { get => throw new NotImplementedException(); set => throw new NotImplementedException(); }
-        public object StorageData { get => throw new NotImplementedException(); set => throw new NotImplementedException(); }
-        public double? ExpireMinutes { get => throw new NotImplementedException(); set => throw new NotImplementedException(); }
-        public AppStoreState AppStoreState { get => throw new NotImplementedException(); set => throw new NotImplementedException(); }
-
-        public event EventHandler<WeixinContextRemovedEventArgs<IRequestMessageBase, IResponseMessageBase>> MessageContextRemoved;
+        public CustomMessageContext()
+        {
+            base.MessageContextRemoved += CustomMessageContext_MessageContextRemoved;
+        }
 
-        public void OnRemoved()
+        void CustomMessageContext_MessageContextRemoved(object sender, WeixinContextRemovedEventArgs<IRequestMessageBase, IResponseMessageBase> e)
         {
-            throw new NotImplementedException();
+            /* 注意，这个事件不是实时触发的（当然你也可以专门写一个线程监控）
+             * 为了提高效率，根据WeixinContext中的算法，这里的过期消息会在过期后下一条请求执行之前被清除
+             */
+
+            var messageContext = e.MessageContext as CustomMessageContext;
+            if (messageContext == null)
+            {
+                return;//如果是正常的调用，messageContext不会为null
+            }
+
+            //TODO:这里根据需要执行消息过期时候的逻辑，下面的代码仅供参考
+
+            //Log.InfoFormat("{0}的消息上下文已过期",e.OpenId);
+            //api.SendMessage(e.OpenId, "由于长时间未搭理客服，您的客服状态已退出！");
         }
     }
 }

ServiceWechat/ServiceWechat/MessageHandlers/CustomMessageHandler/CustomMessageHandler.cs

@@ -1,4 +1,7 @@
-using Senparc.Weixin.MP.Entities;
+using Microsoft.Extensions.Logging;
+using NLog;
+using Senparc.Weixin.Context;
+using Senparc.Weixin.MP.Entities;
 using Senparc.Weixin.MP.Entities.Request;
 using Senparc.Weixin.MP.MessageHandlers;
 using System;
@@ -9,12 +12,14 @@ using System.Threading.Tasks;
 
 namespace ServiceWechat.Api.MessageHandlers.CustomMessageHandler
 {
-    public class CustomMessageHandler : MessageHandler<CustomMessageContext>
+    public partial class CustomMessageHandler : MessageHandler<MessageContext<IRequestMessageBase, IResponseMessageBase>>
     {
+        static Logger Logger = LogManager.GetCurrentClassLogger();
+
         public CustomMessageHandler(Stream inputStream, PostModel postModel)
             : base(inputStream, postModel)
         {
-
+            Logger.Info($"实例化CustomMessageHandler");
         }
 
         /// <summary>
@@ -24,7 +29,8 @@ namespace ServiceWechat.Api.MessageHandlers.CustomMessageHandler
         /// <returns></returns>
         public override IResponseMessageBase DefaultResponseMessage(IRequestMessageBase requestMessage)
         {
-            var responseMessage = base.CreateResponseMessage<ResponseMessageText>(); //ResponseMessageText也可以是News等其他类型
+            var responseMessage = this.CreateResponseMessage<ResponseMessageText>(); //ResponseMessageText也可以是News等其他类型
+            Logger.Info($"我是默认的自动回复 么么哒～～～。");
             responseMessage.Content = "我是默认的自动回复 么么哒～～～。";
             return responseMessage;
         }
@@ -38,19 +44,42 @@ namespace ServiceWechat.Api.MessageHandlers.CustomMessageHandler
         /// <returns></returns>
         public override IResponseMessageBase OnTextRequest(RequestMessageText requestMessage)
         {
-            //requestMessage.FromUserName也可以直接写成base.WeixinOpenId
-            var openId = base.WeixinOpenId;
-            //客户发来的文本信息
-            var content = requestMessage.Content;
 
-            //【TODO:查询已配置的文本回复信息】
+            ////requestMessage.FromUserName也可以直接写成base.WeixinOpenId
+            //var openId = base.WeixinOpenId;
+            ////客户发来的文本信息
+            //var content = requestMessage.Content;
+
+            //Logger.Info($"您的OpenID是{openId}。\r\n您发送了文字信息：{content}, requestMessage.MsgId={requestMessage.MsgId},requestMessage.MsgId={requestMessage.CreateTime}");
+            ////【TODO:查询已配置的文本回复信息】
+
+            //var responseMessage = base.CreateResponseMessage<ResponseMessageText>();
+            //responseMessage.Content = $"您的OpenID是{openId}。\r\n您发送了文字信息：{content}, requestMessage.MsgId={requestMessage.MsgId},requestMessage.MsgId={requestMessage.CreateTime}";
+            //Logger.Info($"responseMessage.FromUserName = {responseMessage.FromUserName}   responseMessage.MsgType={responseMessage.MsgType},responseMessage.ToUserName={responseMessage.ToUserName}");
+            //return responseMessage;
+
 
 
-            var responseMessage = base.CreateResponseMessage<ResponseMessageText>();
-            responseMessage.Content = $"您的OpenID是{openId}。\r\n您发送了文字信息：{content}";
+            var responseMessage = ResponseMessageBase.CreateFromRequestMessage<ResponseMessageText>(requestMessage);
+            responseMessage.Content = $"您的OpenID是{requestMessage.FromUserName}。\r\n您发送了文字信息：{requestMessage.Content}, requestMessage.MsgId={requestMessage.MsgId},requestMessage.MsgId={requestMessage.CreateTime}";
             return responseMessage;
         }
 
 
+        public override void OnExecuting()
+        {
+            //测试MessageContext.StorageData
+            if (CurrentMessageContext.StorageData == null)
+            {
+                CurrentMessageContext.StorageData = 0;
+            }
+            base.OnExecuting();
+        }
+
+        public override void OnExecuted()
+        {
+            base.OnExecuted();
+            CurrentMessageContext.StorageData = ((int)CurrentMessageContext.StorageData) + 1;
+        }
     }
 }

ServiceWechat/ServiceWechat/MessageHandlers/CustomMessageHandler/CustomMessageHandler_Events.cs

@@ -0,0 +1,59 @@
+using System;
+using System.Diagnostics;
+using System.Linq;
+using System.Web;
+using Senparc.Weixin.MP.Agent;
+using Senparc.Weixin.Context;
+using Senparc.Weixin.MP.Entities;
+using Senparc.Weixin.MP.Helpers;
+using Senparc.Weixin.MP.MessageHandlers;
+
+
+namespace ServiceWechat.Api.MessageHandlers.CustomMessageHandler
+{
+    /// <summary>
+    /// 自定义MessageHandler
+    /// </summary>
+    public partial class CustomMessageHandler
+    {
+
+        /// <summary>
+        /// 菜单点击事件
+        /// </summary>
+        /// <param name="requestMessage"></param>
+        /// <returns></returns>
+        public override IResponseMessageBase OnEvent_ClickRequest(RequestMessageEvent_Click requestMessage)
+        {
+            var responseMessage = ResponseMessageBase.CreateFromRequestMessage<ResponseMessageText>(requestMessage);
+            responseMessage.Content = "您刚才发送了ENTER事件请求。";
+            return responseMessage;
+        }
+        /// <summary>
+        /// 订阅（关注）事件
+        /// </summary>
+        /// <returns></returns>
+        public override IResponseMessageBase OnEvent_SubscribeRequest(RequestMessageEvent_Subscribe requestMessage)
+        {
+            return EventProcess(6, requestMessage);
+        }
+
+        /// <summary>
+        /// 退订
+        /// 实际上用户无法收到非订阅账号的消息，所以这里可以随便写。
+        /// unsubscribe事件的意义在于及时删除网站应用中已经记录的OpenID绑定，消除冗余数据。并且关注用户流失的情况。
+        /// </summary>
+        /// <returns></returns>
+        public override IResponseMessageBase OnEvent_UnsubscribeRequest(RequestMessageEvent_Unsubscribe requestMessage)
+        {
+            return EventProcess(7, requestMessage);
+        }
+
+        private IResponseMessageBase EventProcess(int type, RequestMessageEventBase requestMessage)
+        {
+            var responseMessage = ResponseMessageBase.CreateFromRequestMessage<ResponseMessageText>(requestMessage);
+            responseMessage.Content = "关注或者退订。";
+            return responseMessage;
+        }
+
+    }
+}

ServiceWechat/ServiceWechat/Models/MenuInput.cs

@@ -0,0 +1,23 @@
+using Senparc.Weixin.MP;
+using Senparc.Weixin.MP.Entities.Menu;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+
+namespace ServiceWechat.Api.Models
+{
+    public class MenuButtons
+    {
+        public List<List<MenuItem>> Menus { get; set; } = new List<List<MenuItem>>();
+    }
+
+    public class MenuItem
+    {
+        public int Level { get; set; }
+        public string Name { get; set; } = "";
+        public string Key { get; set; } = "OneClick";
+        public string Type { get; set; } = ButtonType.click.ToString();
+        public string Url { get; set; } = "";
+    }
+}

ServiceWechat/ServiceWechat/ServiceWechat.Api.csproj

@@ -11,10 +11,11 @@
   </ItemGroup>
 
   <ItemGroup>
-    <PackageReference Include="Microsoft.AspNetCore.All" Version="2.0.3" />
+    <PackageReference Include="Microsoft.AspNetCore.All" Version="2.0.5" />
     <PackageReference Include="Microsoft.VisualStudio.Web.CodeGeneration.Design" Version="2.0.2" />
-    <PackageReference Include="Senparc.Weixin" Version="4.18.9" />
-    <PackageReference Include="Senparc.Weixin.MP" Version="14.8.11" />
+    <PackageReference Include="NLog.Web.AspNetCore" Version="4.4.1" />
+    <PackageReference Include="Senparc.Weixin" Version="4.19.0" />
+    <PackageReference Include="Senparc.Weixin.MP" Version="14.9.0" />
     <PackageReference Include="Senparc.Weixin.MP.MVC" Version="5.0.0" />
   </ItemGroup>
 
@@ -26,4 +27,10 @@
     <ProjectReference Include="..\ServiceWechat.Utility\ServiceWechat.Utility.csproj" />
   </ItemGroup>
 
+  <ItemGroup>
+    <Content Update="StaticConfig\nlog.config">
+      <CopyToOutputDirectory>Always</CopyToOutputDirectory>
+    </Content>
+  </ItemGroup>
+
 </Project>

ServiceWechat/ServiceWechat/Startup.cs

@@ -8,6 +8,8 @@ using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Logging;
 using Microsoft.Extensions.Options;
+using NLog.Extensions.Logging;
+using NLog.Web;
 using Senparc.Weixin.MP.Containers;
 
 namespace ServiceWechat.Api
@@ -32,7 +34,7 @@ namespace ServiceWechat.Api
         }
 
         // This method gets called by the runtime. Use this method to configure the HTTP request pipeline.
-        public void Configure(IApplicationBuilder app, IHostingEnvironment env)
+        public void Configure(IApplicationBuilder app, IHostingEnvironment env, ILoggerFactory loggerFactory)
         {
             if (env.IsDevelopment())
             {
@@ -41,6 +43,10 @@ namespace ServiceWechat.Api
 
             app.UseMvc();
 
+            #region NLog
+            loggerFactory.AddNLog();//添加NLog
+            env.ConfigureNLog("StaticConfig/nlog.config");//读取Nlog配置文件
+            #endregion
 
             AccessTokenContainer.Register(AppId, AppSecret);
         }

ServiceWechat/ServiceWechat/StaticConfig/nlog.config

@@ -0,0 +1,30 @@
+<?xml version="1.0" encoding="utf-8" ?>
+<nlog xmlns="http://www.nlog-project.org/schemas/NLog.xsd"
+      xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+      autoReload="true"
+      internalLogLevel="Warn"
+      internalLogFile="internal-nlog.txt">
+
+  <!-- define various log targets -->
+  <targets>
+    <!-- write logs to file -->
+
+    <target xsi:type="File" name="allfile" fileName="nlog-all-${shortdate}.log"
+                 layout="${longdate}|${logger}|${uppercase:${level}}|${message} ${exception}" />
+
+
+    <target xsi:type="File" name="ownFile-web" fileName="${basedir}/logs/${shortdate}/${uppercase:${level}}.log"
+             layout="${longdate}|${logger}|${uppercase:${level}}|${message}|${exception}| ${stacktrace} ${event-context:item=stacktrace}" />
+
+    <target xsi:type="Null" name="blackhole" />
+  </targets>
+
+  <rules>
+    <!--All logs, including from Microsoft-->
+    <logger name="*" minlevel="Trace" writeTo="allfile" />
+
+    <!--Skip Microsoft logs and so log only own logs-->
+    <logger name="Microsoft.*" minlevel="Trace" writeTo="blackhole" final="true" />
+    <logger name="*" minlevel="Trace" writeTo="ownFile-web" />
+  </rules>
+</nlog>