自动回复调整，模板消息测试

.gitignore

@@ -17,3 +17,5 @@ ServiceWechat/ServiceWechat.Utility/obj/ServiceWechat.Utility.csproj.nuget.g.tar
 /ServiceWechat/.vs/ServiceWechat/v15
 /ServiceWechat/ServiceWechat.Utility/obj/Release/netcoreapp2.0
 /ServiceWechat/ServiceWechat.Utility/bin/Release/netcoreapp2.0
+/ServiceWechat/ServiceWechat.Utility/obj/Release
+/ServiceWechat/ServiceWechat.Utility/bin/Release

ServiceWechat/ServiceWechat.Utility/XmlHelper.cs

@@ -0,0 +1,276 @@
+using System.Xml;
+
+namespace ServiceWechat.Utility
+{
+    /// <summary>
+    /// C#XML文件操作类 包含常用XML操作信息
+    /// by CrazyCoder.Cn
+    /// 转载请注明出处
+    /// </summary>
+    public class XmlHelper
+    {
+        protected XmlDocument xdoc = new XmlDocument();
+        public XmlElement root;
+
+        #region LoadXml
+        /// <summary>
+        /// 加载Xml文档
+        /// </summary>
+        /// <param name="xml"></param>
+        public void LoadXml(string xml)
+        {
+            xdoc.Load(xml);
+
+        }
+
+        /// <summary>
+        /// 获取XML文件内容
+        /// </summary>
+        /// <param name="xml"></param>
+        public string InnerXml(string xml)
+        {
+            xdoc.Load(xml);
+            return xdoc.InnerXml;
+        }
+        /// <summary>
+        /// 获取XML文件内容
+        /// </summary>
+        /// <param name="xml"></param>
+        public void LoadFromXmlString(string xml)
+        {
+            xdoc.LoadXml(xml);
+        }
+        #endregion
+
+        #region 创建一个节点，并在该节点下加入子节点
+
+        /// <summary>
+        /// 创建一个节点，并在该节点下加入子节点
+        /// </summary>
+        /// <param name="RootNode"></param>
+        /// <param name="ElementName"></param>
+        /// <param name="ChildName"></param>
+        /// <param name="ChildValue"></param>
+        /// <returns></returns>
+        public void CreateElement(string RootNode, string ElementName, string[] ChildName, string[] ChildValue)
+        {
+            XmlNode Root = xdoc.SelectSingleNode(RootNode);
+            XmlElement Node = xdoc.CreateElement(ElementName);
+            if (ChildName.Length == ChildValue.Length)
+            {
+                for (int i = 0; i < ChildName.Length; i++)
+                {
+                    XmlElement ChildNode = xdoc.CreateElement(ChildName[i]);
+                    ChildNode.InnerText = ChildValue[i];
+                    Node.AppendChild(ChildNode);
+                }
+            }
+            if (Root != null) Root.AppendChild(Node);
+        }
+        #endregion
+
+        #region 删除某一节点
+
+        /// <summary>
+        /// 创建一个节点，并在该节点下加入子节点
+        /// </summary>
+        /// <param name="RootNode"></param>
+        /// <param name="ChildName"></param>
+        /// <param name="ChildValue"></param>
+        /// <returns></returns>
+        public void DeleteElement(string RootNode, string ChildName, string ChildValue)
+        {
+            XmlNode Root = xdoc.SelectSingleNode(RootNode);
+            if (Root != null)
+            {
+                XmlNodeList Node = Root.ChildNodes;
+                foreach (XmlNode xn in Node)
+                {
+                    var selectSingleNode = xn.SelectSingleNode(ChildName);
+                    if (selectSingleNode != null && selectSingleNode.InnerText == ChildValue)
+                    {
+                        Root.RemoveChild(xn);
+                    }
+                }
+            }
+        }
+        #endregion
+
+        #region 编辑某一节点
+
+        /// <summary>
+        /// 创建一个节点，并在该节点下加入子节点
+        /// </summary>
+        /// <returns></returns>
+        public void UpdateElement(string RootNode, string ElementName, string ElementValue, string[] ChildName, string[] ChildValue)
+        {
+            XmlNode Root = xdoc.SelectSingleNode(RootNode);
+            if (Root != null)
+            {
+                XmlNodeList Node = Root.ChildNodes;
+                foreach (XmlNode xn in Node)
+                {
+                    var selectSingleNode = xn.SelectSingleNode(ElementName);
+                    if (selectSingleNode != null && selectSingleNode.InnerText == ElementValue)
+                    {
+                        if (ChildName.Length == ChildValue.Length)
+                        {
+                            for (int i = 0; i < ChildName.Length; i++)
+                            {
+                                var singleNode = xn.SelectSingleNode(ChildName[i]);
+                                if (singleNode != null)
+                                    singleNode.InnerText = ChildValue[i];
+                            }
+                        }
+                        break;
+                    }
+                }
+            }
+        }
+
+        public void UpdateElement(string RootNode, string[] ChildName, string[] ChildValue)
+        {
+            XmlNode Root = xdoc.SelectSingleNode(RootNode);
+            if (ChildName.Length == ChildValue.Length)
+            {
+                for (int i = 0; i < ChildName.Length; i++)
+                {
+                    if (Root != null)
+                    {
+                        var selectSingleNode = Root.SelectSingleNode(ChildName[i]);
+                        if (selectSingleNode != null)
+                            selectSingleNode.InnerText = ChildValue[i];
+                    }
+                }
+            }
+
+        }
+
+
+        public void UpdateElement(string RootNode, string NodeName, string[] ChildName, string[] ChildValue)
+        {
+            XmlNode Root = xdoc.SelectSingleNode(RootNode);
+            if (Root != null)
+            {
+                XmlNode Node = Root.SelectSingleNode(NodeName);
+                if (ChildName.Length == ChildValue.Length)
+                {
+                    for (int i = 0; i < ChildName.Length; i++)
+                    {
+                        if (Node != null)
+                        {
+                            var selectSingleNode = Node.SelectSingleNode(ChildName[i]);
+                            if (selectSingleNode != null)
+                                selectSingleNode.InnerText = ChildValue[i];
+                        }
+                    }
+                }
+            }
+        }
+
+        #endregion
+
+        #region 取得名称为name的结点的值
+        /// <summary>
+        /// 取得名称为name的结点的值
+        /// </summary>
+        /// <param name="name"></param>
+        /// <returns></returns>
+        public string GetValue(string name)
+        {
+            if (xdoc.DocumentElement != null)
+            {
+                XmlNode xn = FindXnByName(xdoc.DocumentElement.ChildNodes, name);
+                if (xn == null) return null;
+                return xn.InnerText;
+            }
+            return null;
+        }
+
+        #endregion
+
+        #region 在某节点下取名称为name的结点的值
+        /// <summary>
+        /// 在某节点下取名称为name的结点的值
+        /// </summary>
+        /// <returns></returns>
+        public string GetValue(string NodeName, string name)
+        {
+            string BackString = "";
+            if (xdoc.DocumentElement != null)
+            {
+                XmlNode xn = FindXnByName(xdoc.DocumentElement.ChildNodes, NodeName);
+                if (xn == null)
+                {
+                    return "";
+                }
+                XmlNode nn = FindXnByName(xn.ChildNodes, name);
+                if (nn == null)
+                {
+                    return "";
+                }
+                BackString = nn.InnerText;
+            }
+            return BackString;
+        }
+        #endregion
+
+        #region 通过节点名称找到指定的节点
+        /// <summary>
+        /// 通过节点名称找到指定的节点
+        /// </summary>
+        /// <param name="xnl"></param>
+        /// <param name="strName"></param>
+        /// <returns></returns>
+        protected XmlNode FindXnByName(XmlNodeList xnl, string strName)
+        {
+            for (int i = 0; i < xnl.Count; i++)
+            {
+                var item = xnl.Item(i);
+                if (item != null && item.LocalName == strName)
+                {
+                    return xnl.Item(i);
+                }
+            }
+            return null;
+        }
+        #endregion
+
+        #region 为一个节点指定值
+        /// <summary>
+        /// 为一个节点指定值
+        /// </summary>
+        /// <param name="strName"></param>
+        /// <param name="strValue"></param>
+        public void SetValue(string strName, string strValue)
+        {
+            if (xdoc.DocumentElement != null)
+            {
+                XmlNodeList xnl = xdoc.DocumentElement.ChildNodes;
+                for (int i = 0; i < xnl.Count; i++)
+                {
+                    var xmlNode = xnl.Item(i);
+                    if (xmlNode != null && xmlNode.LocalName == strName)
+                    {
+                        var item = xnl.Item(i);
+                        if (item != null) item.InnerText = strValue;
+                        return;
+                    }
+                }
+            }
+            return;
+        }
+        #endregion
+
+        #region 保存XML文档
+        /// <summary>
+        ///  保存XML文档
+        /// </summary>
+        public void Save(string name)
+        {
+            xdoc.Save(name);
+        }
+        #endregion
+    }
+}
+

ServiceWechat/ServiceWechat/Controllers/WechatApis/HomeController.cs

@@ -5,14 +5,18 @@ using System.Threading.Tasks;
 using Microsoft.AspNetCore.Mvc;
 using Senparc.Weixin.MP;
 using Microsoft.Extensions.Configuration;
-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;
+using ServiceWechat.Api.CryptCode;
+using ServiceWechat.Utility;
+using System.Xml;
+using System.Xml.Linq;
+using ServiceWechat.Api.MessageHandlers;
+using Senparc.Weixin.MP.MvcExtension;
 
 namespace ServiceWechat.Api.Controllers.WechatApis
 {
@@ -56,34 +60,75 @@ namespace ServiceWechat.Api.Controllers.WechatApis
         [HttpPost]
         public WeixinResult Verify(PostModel postModel)
         {
+            if (!CheckSignature.Check(postModel.Signature, postModel.Timestamp, postModel.Nonce, Token))
+            {
+                Logger.Info($"参数错误");
+                return new WeixinResult("参数错误");
+            }
 
-            CustomMessageHandler messageHandler = null;
-            try
+            postModel.Token = Token;//根据自己后台的设置保持一致
+            postModel.EncodingAESKey = EncodingAESKey;//根据自己后台的设置保持一致
+            postModel.AppId = AppId;//根据自己后台的设置保持一致
+
+            //var memoryStream = new MemoryStream();
+            //Request.Body.CopyTo(memoryStream);
+
+            //byte[] requestByte = new byte[memoryStream.Length];
+            //memoryStream.Read(requestByte, 0, (int)memoryStream.Length);
+            //string dataEncrypt = Encoding.UTF8.GetString(requestByte);
+
+
+            var maxRecordCount = 10;
+            var inputStream = Request.Body;
+            byte[] buffer = new byte[Request.ContentLength ?? 0];
+            inputStream.Read(buffer, 0, buffer.Length);
+            var requestXmlStream = new MemoryStream(buffer);
+            var requestXml = Encoding.UTF8.GetString(buffer);
+
+            if (inputStream.Position > 0)
+            {
+                inputStream.Position = 0;
+            }
+
+
+            //StreamReader reader = new StreamReader(inputStream, Encoding.UTF8);
+            string dataEncrypt = requestXml;
+            string dataDecrypt = "";
+            int ret = 0;
+            WXBizMsgCrypt wxcpt = new WXBizMsgCrypt(Token, EncodingAESKey, AppId);
+            Logger.Info($"data ={dataEncrypt}");
+            ret = wxcpt.DecryptMsg(postModel.Msg_Signature, postModel.Timestamp, postModel.Nonce, dataEncrypt, ref dataDecrypt);
+            if (ret != 0)
             {
-                if (!CheckSignature.Check(postModel.Signature, postModel.Timestamp, postModel.Nonce, Token))
-                {
-                    return new WeixinResult("参数错误");
-                }
+                Logger.Error($"微信消息推送解密失败，错误代码：{ret}");
+            }
+            Logger.Info($"接收用户消息调用RecieveMsg =【{  dataDecrypt }】");
+            //自定义MessageHandler，对微信请求的详细判断操作都在这里面。
 
-                postModel.Token = Token;//根据自己后台的设置保持一致
-                postModel.EncodingAESKey = EncodingAESKey;//根据自己后台的设置保持一致
-                postModel.AppId = AppId;//根据自己后台的设置保持一致
 
-                //StreamReader reader = new StreamReader(Request.Body, Encoding.);
-                //string text = reader.ReadToEnd();
 
+            //if (Request.Body.Position > 0)
+            //{
+            //    Request.Body.Position = 0;
+            //}
 
-                //Logger.Info($"接收用户消息调用RecieveMsg 【{  text }】");
-                //自定义MessageHandler，对微信请求的详细判断操作都在这里面。
-                messageHandler = new CustomMessageHandler(Request.Body, postModel);//接收消息
-                messageHandler.Execute();//执行微信处理过程
-                return new WeixinResult(messageHandler);//返回结果
+            //XDocument xml = null;
+            //using (XmlReader xr = XmlReader.Create(Request.Body))
+            //{
+            //    xml = XDocument.Load(xr);
+            //}
+            CustomMessageHandler messageHandler = null;
+            try
+            {
+                messageHandler = new CustomMessageHandler(inputStream, postModel);//接收消息
             }
             catch (Exception ex)
             {
-                Logger.Error(ex);
+                Logger.Error(ex, $"{ex.StackTrace}");
             }
+            messageHandler.Execute();//执行微信处理过程
             return new WeixinResult(messageHandler);//返回结果
+
         }
 
         public string Test()

ServiceWechat/ServiceWechat/Controllers/WechatApis/TemplateMsgController.cs

@@ -26,33 +26,33 @@ namespace ServiceWechat.Api.Controllers.WechatApis
             EncodingAESKey = configuration["WechatStatic:EncodingAESKey"];
         }
 
-        ///// <summary>
-        ///// 发送模板消息【需要安全验证】
-        ///// </summary>
-        ///// <returns></returns>
-        //public JsonResult Send()
-        //{
-        //    //根据userId获取关注该公众号的微信号
+        /// <summary>
+        /// 发送模板消息【需要安全验证】
+        /// </summary>
+        /// <returns></returns>
+        public JsonResult Send()
+        {
+            //根据userId获取关注该公众号的微信号
 
 
-        //    var url = "url";
-        //    var first = "你好，你有一条新的任务";
-        //    var result = TemplateApi.SendTemplateMessage(
-        //    AppId,
-        //    "openId",
-        //    "TempleteMessageId",
-        //    url,
-        //       new
-        //       {
-        //           first = new { value = first, color = "#173177" },
-        //           keyword1 = new { value = place, color = "#173177" },
-        //           keyword2 = new { value = detail, color = "#173177" },
-        //           keyword3 = new { value = username, color = "#173177" },
-        //           keyword4 = new { value = phone, color = "#173177" },
-        //           remark = new { value = string.IsNullOrWhiteSpace(remark) ? "请尽快处理！" : remark, color = "#173177" },
-        //       });
-        //    return Success("OK");
-        //}
+            var url = "http://www.baidu.com";
+            var first = "你好，你有一条新的任务";
+            var result = TemplateApi.SendTemplateMessage(
+            AppId,
+            "oKOqcv_4HD3qeuf6aL5gaD--z4Xs",
+            "1xACNqCQ7t8VTpR9pz5puo2G9eMHSeZgac1SQCZWqzY",
+            url,
+               new
+               {
+                   first = new { value = first, color = "#173177" },
+                   keyword1 = new { value = "测试地点", color = "#173177" },
+                   keyword2 = new { value = "测试详细内容", color = "#173177" },
+                   keyword3 = new { value = "flameiris", color = "#173177" },
+                   keyword4 = new { value = "15537150907", color = "#173177" },
+                   remark = new { value = string.IsNullOrWhiteSpace("") ? "请尽快处理！" : "", color = "#173177" },
+               });
+            return Success("OK", result);
+        }
 
 
         /// <summary>

ServiceWechat/ServiceWechat/MessageHandlers/CustomMessageHandler/CustomMessageContext.cs

@@ -6,7 +6,7 @@ using System.Linq;
 using System.Threading.Tasks;
 using Senparc.Weixin;
 
-namespace ServiceWechat.Api.MessageHandlers.CustomMessageHandler
+namespace ServiceWechat.Api.MessageHandlers
 {
     public class CustomMessageContext : MessageContext<IRequestMessageBase, IResponseMessageBase>
     {

ServiceWechat/ServiceWechat/MessageHandlers/CustomMessageHandler/CustomMessageHandler.cs

@@ -9,8 +9,9 @@ using System.Collections.Generic;
 using System.IO;
 using System.Linq;
 using System.Threading.Tasks;
+using System.Xml.Linq;
 
-namespace ServiceWechat.Api.MessageHandlers.CustomMessageHandler
+namespace ServiceWechat.Api.MessageHandlers
 {
     public partial class CustomMessageHandler : MessageHandler<MessageContext<IRequestMessageBase, IResponseMessageBase>>
     {
@@ -22,6 +23,12 @@ namespace ServiceWechat.Api.MessageHandlers.CustomMessageHandler
             Logger.Info($"实例化CustomMessageHandler");
         }
 
+        public CustomMessageHandler(XDocument inputStream, PostModel postModel)
+          : base(inputStream, postModel)
+        {
+            Logger.Info($"实例化CustomMessageHandler");
+        }
+
         /// <summary>
         /// 默认回复
         /// </summary>
@@ -36,48 +43,58 @@ namespace ServiceWechat.Api.MessageHandlers.CustomMessageHandler
         }
 
 
+        public override IResponseMessageBase OnTextRequest(RequestMessageText requestMessage)
+        {
+            var responseMessage = base.CreateResponseMessage<ResponseMessageText>();
+            //responseMessage.Content = "您的OpenID是：" + responseMessage.FromUserName+".\r\n您发送的文字是："+requestMessage.Content;  
+            if (requestMessage.Content == "ID")
+                responseMessage.Content = "您的OpenID是：" + responseMessage.FromUserName;
+            if (requestMessage.Content == "天气")
+                responseMessage.Content = "抱歉，还未开通此功能！";
+            return responseMessage;
+        }
+
 
         /// <summary>
         /// 处理用户发来的文本信息
         /// </summary>
         /// <param name="requestMessage"></param>
         /// <returns></returns>
-        public override IResponseMessageBase OnTextRequest(RequestMessageText requestMessage)
-        {
+        //public override IResponseMessageBase OnTextRequest(RequestMessageText requestMessage)
+        //{
 
-            ////requestMessage.FromUserName也可以直接写成base.WeixinOpenId
-            //var openId = base.WeixinOpenId;
-            ////客户发来的文本信息
-            //var content = requestMessage.Content;
+        //    //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:查询已配置的文本回复信息】
+        //    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}, 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 = 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()
         {
+            Logger.Info($"OnExecuting");
             //测试MessageContext.StorageData
             if (CurrentMessageContext.StorageData == null)
             {
                 CurrentMessageContext.StorageData = 0;
             }
+
             base.OnExecuting();
         }
 
         public override void OnExecuted()
         {
+            Logger.Info($"OnExecuted");
             base.OnExecuted();
             CurrentMessageContext.StorageData = ((int)CurrentMessageContext.StorageData) + 1;
         }

ServiceWechat/ServiceWechat/MessageHandlers/CustomMessageHandler/CustomMessageHandler_Events.cs

@@ -9,7 +9,7 @@ using Senparc.Weixin.MP.Helpers;
 using Senparc.Weixin.MP.MessageHandlers;
 
 
-namespace ServiceWechat.Api.MessageHandlers.CustomMessageHandler
+namespace ServiceWechat.Api.MessageHandlers
 {
     /// <summary>
     /// 自定义MessageHandler

ServiceWechat/ServiceWechat/ServiceWechat.Api.csproj

@@ -14,9 +14,9 @@
     <PackageReference Include="Microsoft.AspNetCore.All" Version="2.0.5" />
     <PackageReference Include="Microsoft.VisualStudio.Web.CodeGeneration.Design" Version="2.0.2" />
     <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" />
+    <PackageReference Include="Senparc.Weixin" Version="4.20.0" />
+    <PackageReference Include="Senparc.Weixin.MP" Version="14.10.0" />
+    <PackageReference Include="Senparc.Weixin.MP.MVC" Version="5.2.0" />
   </ItemGroup>
 
   <ItemGroup>