提交

ServiceWechat/ServiceWechat.Utility/HttpHelper.cs

@@ -0,0 +1,143 @@
+using System;
+using System.Collections.Generic;
+using System.Net.Http;
+using System.Net.Http.Headers;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace ServiceWechat.Utility
+{
+    public static class HttpHelper
+    {
+        /// <summary>
+        /// 异步请求get(UTF-8)
+        /// </summary>
+        /// <param name="url">链接地址</param>   
+        /// <param name="formData">写在header中的内容</param>
+        /// <returns></returns>
+        public static async Task<string> HttpGetAsync(string url, List<KeyValuePair<string, string>> formData = null)
+        {
+            HttpClient httpClient = new HttpClient();
+            HttpContent content = new FormUrlEncodedContent(formData);
+            if (formData != null)
+            {
+                content.Headers.ContentType = new MediaTypeHeaderValue("application/x-www-form-urlencoded");
+                content.Headers.ContentType.CharSet = "UTF-8";
+                for (int i = 0; i < formData.Count; i++)
+                {
+                    content.Headers.Add(formData[i].Key, formData[i].Value);
+                }
+            }
+            var request = new HttpRequestMessage()
+            {
+                RequestUri = new Uri(url),
+                Method = HttpMethod.Get,
+            };
+            for (int i = 0; i < formData.Count; i++)
+            {
+                request.Headers.Add(formData[i].Key, formData[i].Value);
+            }
+            var resp = await httpClient.SendAsync(request);
+            resp.EnsureSuccessStatusCode();
+            string token = await resp.Content.ReadAsStringAsync();
+
+            return token;
+        }
+
+        /// <summary>
+        /// 异步请求post（键值对形式,可等待的）
+        /// </summary>
+        /// <param name="uri">网络基址("http://localhost:59315")</param>
+        /// <param name="url">网络的地址("/api/UMeng")</param>
+        /// <param name="formData">键值对List<KeyValuePair<string, string>> formData = new List<KeyValuePair<string, string>>();formData.Add(new KeyValuePair<string, string>("userid", "29122"));formData.Add(new KeyValuePair<string, string>("umengids", "29122"));</param>
+        /// <param name="charset">编码格式</param>
+        /// <param name="mediaType">头媒体类型</param>
+        /// <returns></returns>
+        public static async Task<string> HttpPostAsync(string uri, string url, List<KeyValuePair<string, string>> formData = null, string charset = "UTF-8", string mediaType = "application/x-www-form-urlencoded")
+        {
+
+            string tokenUri = url;
+            var client = new HttpClient();
+            client.BaseAddress = new Uri(uri);
+            HttpContent content = new FormUrlEncodedContent(formData);
+            content.Headers.ContentType = new MediaTypeHeaderValue(mediaType);
+            content.Headers.ContentType.CharSet = charset;
+            for (int i = 0; i < formData.Count; i++)
+            {
+                content.Headers.Add(formData[i].Key, formData[i].Value);
+            }
+
+            HttpResponseMessage resp = await client.PostAsync(tokenUri, content);
+            resp.EnsureSuccessStatusCode();
+            string token = await resp.Content.ReadAsStringAsync();
+            return token;
+        }
+
+        ///// <summary>
+        ///// 
+        ///// </summary>
+        ///// <param name="url"></param>
+        ///// <param name="data"></param>
+        ///// <param name="encoding"></param>
+        ///// <param name="type"></param>
+        ///// <returns></returns>
+        //public string Post(string url, string data, Encoding encoding, int type)
+        //{
+        //    try
+        //    {
+        //        HttpWebRequest req = WebRequest.CreateHttp(new Uri(url));
+        //        if (type == 1)
+        //        {
+        //            req.ContentType = "application/json;charset=utf-8";
+        //        }
+        //        else if (type == 2)
+        //        {
+        //            req.ContentType = "application/xml;charset=utf-8";
+        //        }
+        //        else
+        //        {
+        //            req.ContentType = "application/x-www-form-urlencoded;charset=utf-8";
+        //        }
+
+        //        req.Method = "POST";
+        //        //req.Accept = "text/xml,text/javascript";
+        //        req.ContinueTimeout = 60000;
+
+        //        byte[] postData = encoding.GetBytes(data);
+        //        Stream reqStream = req.GetRequestStreamAsync().Result;
+        //        reqStream.Write(postData, 0, postData.Length);
+        //        reqStream.Dispose();
+
+        //        var rsp = (HttpWebResponse)req.GetResponseAsync().Result;
+        //        var result = GetResponseAsString(rsp, encoding);
+        //        return result;
+
+        //    }
+        //    catch (Exception ex)
+        //    {
+        //        throw;
+        //    }
+        //}
+
+        //private string GetResponseAsString(HttpWebResponse rsp, Encoding encoding)
+        //{
+        //    Stream stream = null;
+        //    StreamReader reader = null;
+
+        //    try
+        //    {
+        //        // 以字符流的方式读取HTTP响应
+        //        stream = rsp.GetResponseStream();
+        //        reader = new StreamReader(stream, encoding);
+        //        return reader.ReadToEnd();
+        //    }
+        //    finally
+        //    {
+        //        // 释放资源
+        //        if (reader != null) reader.Dispose();
+        //        if (stream != null) stream.Dispose();
+        //        if (rsp != null) rsp.Dispose();
+        //    }
+        //}
+    }
+}

ServiceWechat/ServiceWechat.sln

@@ -1,7 +1,7 @@
 
 Microsoft Visual Studio Solution File, Format Version 12.00
 # Visual Studio 15
-VisualStudioVersion = 15.0.26730.16
+VisualStudioVersion = 15.0.27130.2024
 MinimumVisualStudioVersion = 10.0.40219.1
 Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "ServiceWechat.Api", "ServiceWechat\ServiceWechat.Api.csproj", "{4EA25C0F-1647-48DD-92F1-DE70D3D79465}"
 EndProject

ServiceWechat/ServiceWechat/Controllers/WechatApis/HomeController.cs

@@ -17,21 +17,25 @@ using System.Xml;
 using System.Xml.Linq;
 using ServiceWechat.Api.MessageHandlers;
 using Senparc.Weixin.MP.MvcExtension;
+using Microsoft.AspNetCore.Hosting;
 
 namespace ServiceWechat.Api.Controllers.WechatApis
 {
     [Route("wechatapi/Home/[action]")]
-    public class HomeController : BaseController
+    public class HomeController : Controller
     {
+        readonly Func<string> _getRandomFileName = () => DateTime.Now.ToString("yyyyMMdd-HHmmss") + Guid.NewGuid().ToString("n").Substring(0, 6);
         private readonly string Token;
         private readonly string AppId;
         private readonly string EncodingAESKey;
         static Logger Logger = LogManager.GetCurrentClassLogger();
-        public HomeController(IConfiguration configuration)
+        private IHostingEnvironment _host;
+        public HomeController(IConfiguration configuration, IHostingEnvironment host)
         {
             Token = configuration["WechatStatic:Token"];
             AppId = configuration["WechatStatic:AppId"];
             EncodingAESKey = configuration["WechatStatic:EncodingAESKey"];
+            _host = host;
         }
 
         /// <summary>
@@ -58,77 +62,45 @@ namespace ServiceWechat.Api.Controllers.WechatApis
         /// 用户发送消息后，微信平台自动Post一个请求到这里，并等待响应XML。
         /// </summary>
         [HttpPost]
-        public WeixinResult Verify(PostModel postModel)
+        [Produces("text/xml")]
+        public ActionResult Verify(PostModel postModel)
         {
             if (!CheckSignature.Check(postModel.Signature, postModel.Timestamp, postModel.Nonce, Token))
             {
-                Logger.Info($"参数错误");
                 return new WeixinResult("参数错误");
             }
-
             postModel.Token = Token;//根据自己后台的设置保持一致
             postModel.EncodingAESKey = EncodingAESKey;//根据自己后台的设置保持一致
             postModel.AppId = AppId;//根据自己后台的设置保持一致
 
-            //var memoryStream = new MemoryStream();
-            //Request.Body.CopyTo(memoryStream);
+            string body = new StreamReader(Request.Body).ReadToEnd();
+            byte[] requestData = Encoding.UTF8.GetBytes(body);
+            Stream inputStream = new MemoryStream(requestData);
 
-            //byte[] requestByte = new byte[memoryStream.Length];
-            //memoryStream.Read(requestByte, 0, (int)memoryStream.Length);
-            //string dataEncrypt = Encoding.UTF8.GetString(requestByte);
 
+            CustomMessageHandler messageHandler = new CustomMessageHandler(inputStream, postModel);//接收消息
+            messageHandler.Execute();//执行微信处理过程
 
-            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);
+            var responseDocumentFileName = Path.Combine(_host.ContentRootPath, string.Format("{0}_Response_{1}.txt", _getRandomFileName(), messageHandler.RequestMessage.FromUserName));
+            var ecryptResponseDocumentFileName = Path.Combine(_host.ContentRootPath, string.Format("{0}_Response_Final_{1}.txt", _getRandomFileName(), messageHandler.RequestMessage.FromUserName));
 
-            if (inputStream.Position > 0)
+            if (messageHandler.ResponseDocument != null)
             {
-                inputStream.Position = 0;
+                using (FileStream fs = new FileStream(responseDocumentFileName, FileMode.CreateNew, FileAccess.ReadWrite))
+                {
+                    messageHandler.ResponseDocument.Save(fs);
+                }
             }
 
-
-            //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 (messageHandler.UsingEcryptMessage && messageHandler.FinalResponseDocument != null)
             {
-                Logger.Error($"微信消息推送解密失败，错误代码：{ret}");
+                using (FileStream fs = new FileStream(ecryptResponseDocumentFileName, FileMode.CreateNew, FileAccess.ReadWrite))
+                {
+                    //记录加密后的响应信息
+                    messageHandler.FinalResponseDocument.Save(fs);
+                }
             }
-            Logger.Info($"接收用户消息调用RecieveMsg =【{  dataDecrypt }】");
-            //自定义MessageHandler，对微信请求的详细判断操作都在这里面。
-
-
-
-            //if (Request.Body.Position > 0)
-            //{
-            //    Request.Body.Position = 0;
-            //}
-
-            //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, $"{ex.StackTrace}");
-            }
-            messageHandler.Execute();//执行微信处理过程
             return new WeixinResult(messageHandler);//返回结果
-
         }
 
         public string Test()

ServiceWechat/ServiceWechat/Controllers/WechatApis/PaymentController.cs

@@ -0,0 +1,93 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+using Microsoft.AspNetCore.Mvc;
+using Microsoft.Extensions.Configuration;
+using Microsoft.Extensions.Logging;
+using NLog;
+using Senparc.Weixin.MP.TenPayLibV3;
+
+// For more information on enabling Web API for empty projects, visit https://go.microsoft.com/fwlink/?LinkID=397860
+
+namespace ServiceWechat.Api.Controllers.WechatApis
+{
+
+    [Route("wechatapi/payment/[action]")]
+    public class PaymentController : Controller
+    {
+        private readonly string AppId;
+        private readonly string MchId;
+        private readonly string TenPayV3Notify;
+        private readonly string Key;
+
+        static Logger Logger = LogManager.GetCurrentClassLogger();
+
+        public PaymentController(IConfiguration configuration)
+        {
+            AppId = configuration["WechatStatic:AppId"];
+            MchId = configuration["WechatStatic:MchId"];
+            TenPayV3Notify = configuration["WechatStatic:TenPayV3Notify"];
+            Key = configuration["Key"];
+        }
+        public string MakeOrder()
+        {
+            #region 生成商户订单(系统内订单)TODO
+
+            #endregion 
+
+
+            #region 调用微信统一下单API，生成预付单，获取预付单信息
+
+            var attach = "efg";
+            var body = "abc";
+            var openId = "oKOqcv_4HD3qeuf6aL5gaD--z4Xs";
+            var orderNum = DateTime.Now.ToString("yyyyMMddHHmmss");
+            var total_fee = "1";
+
+            RequestHandler requestHandler = new RequestHandler(HttpContext);
+            requestHandler.SetParameter("appid", this.AppId);                       //公众账号ID
+            requestHandler.SetParameter("mch_id", this.MchId);                      //商户号
+            //requestHandler.SetParameterWhenNotNull("sub_appid", this.SubAppId);     //子商户公众账号ID
+            //requestHandler.SetParameterWhenNotNull("sub_mch_id", this.SubMchId);    //子商户号
+            //requestHandler.SetParameterWhenNotNull("device_info", this.DeviceInfo); //自定义参数
+            requestHandler.SetParameter("nonce_str", TenPayV3Util.GetNoncestr());                //随机字符串
+            requestHandler.SetParameterWhenNotNull("sign_type", "MD5");     //签名类型，默认为MD5
+            requestHandler.SetParameter("body", body);                         //商品信息
+            //requestHandler.SetParameterWhenNotNull("detail", this.Detail);          //商品详细列表
+            requestHandler.SetParameterWhenNotNull("attach", attach);          //附加数据
+            requestHandler.SetParameter("out_trade_no", orderNum);           //商家订单号
+            requestHandler.SetParameterWhenNotNull("fee_type", "CNY");       //符合ISO 4217标准的三位字母代码，默认人民币：CNY
+            requestHandler.SetParameter("total_fee", total_fee);     //商品金额,以分为单位(money * 100).ToString()
+            requestHandler.SetParameter("spbill_create_ip", "");   //用户的公网ip，不是商户服务器IP
+            requestHandler.SetParameterWhenNotNull("time_start", DateTime.Now.ToString());   //订单生成时间
+            requestHandler.SetParameterWhenNotNull("time_expire", DateTime.Now.AddDays(1).ToString());  //订单失效时间
+            //requestHandler.SetParameterWhenNotNull("goods_tag", this.GoodsTag);     //商品标记
+            requestHandler.SetParameter("notify_url", TenPayV3Notify);              //接收财付通通知的URL
+            requestHandler.SetParameter("trade_type", "JSAPI");   //交易类型
+            //requestHandler.SetParameterWhenNotNull("product_id", this.ProductId);   //trade_type=NATIVE时（即扫码支付），此参数必传。
+            //requestHandler.SetParameterWhenNotNull("limit_pay", this.LimitPay);     //上传此参数no_credit--可限制用户不能使用信用卡支付
+            requestHandler.SetParameterWhenNotNull("openid", openId);                     //用户的openId，trade_type=JSAPI时（即公众号支付），此参数必传
+            //requestHandler.SetParameterWhenNotNull("sub_openid", this.SubOpenid);              //用户子标识
+            //if (SceneInfo != null)
+            //{
+            //    requestHandler.SetParameter("scene_info", SceneInfo.ToString());   //场景信息
+            //}
+
+            var sign = requestHandler.CreateMd5Sign("key", this.Key);
+
+            requestHandler.SetParameter("sign", sign);                              //签名
+
+            var xml = requestHandler.ParseXML();
+            var result = TenPayV3.Unifiedorder(xml);
+            //获取并返回预支付XML信息
+            return $"xml= {xml} ||||||  result={TenPayV3.Unifiedorder(result)}";
+            #endregion
+        }
+
+        public void callback()
+        {
+
+        }
+    }
+}

ServiceWechat/ServiceWechat/MessageHandlers/CustomMessageHandler.cs

@@ -1,9 +1,11 @@
 using Microsoft.Extensions.Logging;
 using NLog;
 using Senparc.Weixin.Context;
+using Senparc.Weixin.MP;
 using Senparc.Weixin.MP.Entities;
 using Senparc.Weixin.MP.Entities.Request;
 using Senparc.Weixin.MP.MessageHandlers;
+using ServiceWechat.Api.CryptCode;
 using System;
 using System.Collections.Generic;
 using System.IO;
@@ -13,22 +15,116 @@ using System.Xml.Linq;
 
 namespace ServiceWechat.Api.MessageHandlers
 {
-    public partial class CustomMessageHandler : MessageHandler<MessageContext<IRequestMessageBase, IResponseMessageBase>>
+    public partial class CustomMessageHandler : MessageHandler<CustomMessageContext>
     {
         static Logger Logger = LogManager.GetCurrentClassLogger();
 
+        private PostModel _postModel;
         public CustomMessageHandler(Stream inputStream, PostModel postModel)
             : base(inputStream, postModel)
         {
             Logger.Info($"实例化CustomMessageHandler");
+            _postModel = postModel;
         }
-
-        public CustomMessageHandler(XDocument inputStream, PostModel postModel)
-          : base(inputStream, postModel)
+        /// <summary>
+        /// 初始化时【解密】
+        /// </summary>
+        /// <param name="postDataDocument"></param>
+        /// <param name="postData"></param>
+        /// <returns></returns>
+        public override XDocument Init(XDocument postDataDocument, object postData = null)
         {
-            Logger.Info($"实例化CustomMessageHandler");
+
+            //进行加密判断并处理
+            _postModel = postData as PostModel;
+            var postDataStr = postDataDocument.ToString();
+            Logger.Info($"Init  postDataStr={postDataStr}");
+
+
+            XDocument decryptDoc = postDataDocument;
+
+            if (_postModel != null && postDataDocument.Root.Element("Encrypt") != null && !string.IsNullOrEmpty(postDataDocument.Root.Element("Encrypt").Value))
+            {
+                //使用了加密
+                UsingEcryptMessage = true;
+                EcryptRequestDocument = postDataDocument;
+
+                WXBizMsgCrypt msgCrype = new WXBizMsgCrypt(_postModel.Token, _postModel.EncodingAESKey, _postModel.AppId);
+                string msgXml = null;
+                var result = msgCrype.DecryptMsg(_postModel.Msg_Signature, _postModel.Timestamp, _postModel.Nonce, postDataStr, ref msgXml);
+
+                //判断result类型
+                if (result != 0)
+                {
+                    //验证没有通过，取消执行
+                    CancelExcute = true;
+                    return null;
+                }
+
+                if (postDataDocument.Root.Element("FromUserName") != null && !string.IsNullOrEmpty(postDataDocument.Root.Element("FromUserName").Value))
+                {
+                    //TODO：使用了兼容模式，进行验证即可
+                    UsingCompatibilityModelEcryptMessage = true;
+                }
+
+                decryptDoc = XDocument.Parse(msgXml);//完成解密
+            }
+
+            RequestMessage = RequestMessageFactory.GetRequestEntity(decryptDoc);
+            if (UsingEcryptMessage)
+            {
+                RequestMessage.Encrypt = postDataDocument.Root.Element("Encrypt").Value;
+            }
+
+
+            //TODO:分布式系统中本地的上下文会有同步问题，需要同步使用远程的储存
+            if (WeixinContextGlobal.UseWeixinContext)
+            {
+
+                var omit = OmitRepeatedMessageFunc == null || OmitRepeatedMessageFunc(RequestMessage);
+
+                lock (WeixinContextGlobal.OmitRepeatLock)//TODO:使用分布式锁
+                {
+                    #region 消息去重
+
+                    if (omit &&
+                        OmitRepeatedMessage &&
+                        CurrentMessageContext.RequestMessages.Count > 0
+                         //&& !(RequestMessage is RequestMessageEvent_Merchant_Order)批量订单的MsgId可能会相同
+                         )
+                    {
+                        //lastMessage必定有值（除非极端小的过期时间条件下，几乎不可能发生）
+                        var lastMessage = CurrentMessageContext.RequestMessages[CurrentMessageContext.RequestMessages.Count - 1];
+
+                        if (
+                            //使用MsgId去重
+                            (lastMessage.MsgId != 0 && lastMessage.MsgId == RequestMessage.MsgId)
+                            //使用CreateTime去重（OpenId对象已经是同一个）
+                            || (lastMessage.MsgId == RequestMessage.MsgId
+                                && lastMessage.CreateTime == RequestMessage.CreateTime
+                                && lastMessage.MsgType == RequestMessage.MsgType)
+                            )
+                        {
+                            CancelExcute = true;//重复消息，取消执行
+                            MessageIsRepeated = true;
+                        }
+                    }
+
+                    #endregion
+
+                    //在消息没有被去重的情况下记录上下文
+                    if (!MessageIsRepeated)
+                    {
+                        WeixinContext.InsertMessage(RequestMessage);
+                    }
+                }
+            }
+
+            Logger.Info($"接收用户消息调用RecieveMsg =【{  decryptDoc }】");
+            return decryptDoc;
         }
 
+
         /// <summary>
         /// 默认回复
         /// </summary>
@@ -36,49 +132,13 @@ namespace ServiceWechat.Api.MessageHandlers
         /// <returns></returns>
         public override IResponseMessageBase DefaultResponseMessage(IRequestMessageBase requestMessage)
         {
-            var responseMessage = this.CreateResponseMessage<ResponseMessageText>(); //ResponseMessageText也可以是News等其他类型
+            var responseMessage = ResponseMessageBase.CreateFromRequestMessage<ResponseMessageText>(RequestMessage);
             Logger.Info($"我是默认的自动回复 么么哒～～～。");
             responseMessage.Content = "我是默认的自动回复 么么哒～～～。";
             return responseMessage;
         }
 
 
-        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)
-        //{
-
-        //    //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;
-
-
-        //}
-
 
         public override void OnExecuting()
         {
@@ -98,5 +158,30 @@ namespace ServiceWechat.Api.MessageHandlers
             base.OnExecuted();
             CurrentMessageContext.StorageData = ((int)CurrentMessageContext.StorageData) + 1;
         }
+
+        public override XDocument FinalResponseDocument
+        {
+            get
+            {
+                Logger.Info($"ResponseDocument");
+                if (ResponseDocument == null)
+                {
+                    Logger.Info($"ResponseDocument=null");
+                    return null;
+                }
+
+                var timeStamp = _postModel.Timestamp;
+                var nonce = _postModel.Nonce;
+
+                WXBizMsgCrypt msgCrype = new WXBizMsgCrypt(_postModel.Token, _postModel.EncodingAESKey, _postModel.AppId);
+                string finalResponseXml = null;
+                msgCrype.EncryptMsg(ResponseDocument.ToString(), timeStamp, nonce, ref finalResponseXml);//TODO:这里官方的方法已经把EncryptResponseMessage对应的XML输出出来了
+                Logger.Info($"ResponseDocument.ToString() =【{  ResponseDocument.ToString() }】");
+                Logger.Info($"finalResponseXml =【{  finalResponseXml }】");
+                return XDocument.Parse(finalResponseXml);
+
+            }
+
+        }
     }
-}
+}

ServiceWechat/ServiceWechat/Program.cs

@@ -20,7 +20,9 @@ namespace ServiceWechat.Api
         public static IWebHost BuildWebHost(string[] args) =>
             WebHost.CreateDefaultBuilder(args)
                 .UseStartup<Startup>()
-                .UseIISIntegration()
+                .UseKestrel()
+                .UseUrls("http://meiwang.800100.net:80")
+                //.UseIISIntegration()
                 .Build();
     }
 }

ServiceWechat/ServiceWechat/ServiceWechat.Api.csproj

@@ -6,7 +6,12 @@
   </PropertyGroup>
 
   <ItemGroup>
+    <None Remove="Properties\PublishProfiles\FolderProfile.pubxml" />
+  </ItemGroup>
+
+  <ItemGroup>
     <Folder Include="Controllers\ManageApis\" />
+    <Folder Include="Properties\PublishProfiles\" />
     <Folder Include="wwwroot\" />
   </ItemGroup>
 
@@ -14,8 +19,8 @@
     <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.20.0" />
-    <PackageReference Include="Senparc.Weixin.MP" Version="14.10.0" />
+    <PackageReference Include="Senparc.Weixin" Version="4.20.2" />
+    <PackageReference Include="Senparc.Weixin.MP" Version="14.10.3" />
     <PackageReference Include="Senparc.Weixin.MP.MVC" Version="5.2.0" />
   </ItemGroup>
 

ServiceWechat/ServiceWechat/ServiceWechat.Api.csproj.user

@@ -15,5 +15,6 @@
     <WebStackScaffolding_IsReferencingScriptLibrariesSelected>True</WebStackScaffolding_IsReferencingScriptLibrariesSelected>
     <WebStackScaffolding_LayoutPageFile />
     <WebStackScaffolding_IsAsyncSelected>False</WebStackScaffolding_IsAsyncSelected>
+    <ShowAllFiles>true</ShowAllFiles>
   </PropertyGroup>
 </Project>

ServiceWechat/ServiceWechat/Startup.cs

@@ -31,6 +31,7 @@ namespace ServiceWechat.Api
         public void ConfigureServices(IServiceCollection services)
         {
             services.AddMvc();
+
         }
 
         // This method gets called by the runtime. Use this method to configure the HTTP request pipeline.
@@ -42,12 +43,12 @@ namespace ServiceWechat.Api
             }
 
             app.UseMvc();
+            app.UseStaticFiles(); // For the wwwroot folder
 
             #region NLog
             loggerFactory.AddNLog();//添加NLog
             env.ConfigureNLog("StaticConfig/nlog.config");//读取Nlog配置文件
             #endregion
-
             AccessTokenContainer.Register(AppId, AppSecret);
         }
     }

ServiceWechat/ServiceWechat/appsettings.json

@@ -16,9 +16,13 @@
     "AppId": "wxe03366d8c63d9b09",
     "AppSecret": "3e42313935a4d6dc8b450172b8be2765",
     "Token": "72E4E2C7EC8BBF6AF535F53A213E8EBB",
-    "EncodingAESKey": "bOs7gmWm6FaqAViH9ZngbfhZS47pvzOucCrGO7tkMlD"
+    "EncodingAESKey": "bOs7gmWm6FaqAViH9ZngbfhZS47pvzOucCrGO7tkMlD",
+    "MchId": "1493808312", //商户号
+    "TenPayV3Notify": "http://meiwang.800100.net/wechatapi/payment/callback/", //回调地址
+    "Key": "u92kcvielwoc045kigdslwod937ckw9c" //api秘钥
   }
 
 
 
+
 }

ServiceWechat/ServiceWechat/wwwroot/makeorder.html

@@ -0,0 +1,25 @@
+<!DOCTYPE html>
+<html lang="en">
+<head>
+    <meta charset="utf-8">
+    <title>订单页面</title>
+</head>
+<body>
+    <h1>订单页面</h1>
+    <input id="btn" type="button" value="点击下订单" />
+    <script type="text/javascript" src="script/jquery.min.js"></script>
+    <script>
+        $(function () {
+            $("#btn").click(function () {
+                $.ajax({
+                    "url": "/wechatapi/payment/makeorder",
+                    "type": "json",
+                    "success": function (res) {
+                        alert(res);
+                    }
+                });
+            });
+        });
+    </script>
+</body>
+</html>

ServiceWechat/ServiceWechat/wwwroot/payment.html

@@ -0,0 +1,34 @@
+<!DOCTYPE html>
+<html lang="en">
+<head>
+    <meta charset="utf-8">
+    <title>支付页面</title>
+</head>
+<body>
+    <h1>这是支付测试页面</h1>
+    <input id="btn" type="button" value="点击调用微信公众号的支付api" />
+    <script>
+        function onBridgeReady() {
+            WeixinJSBridge.invoke(
+                'getBrandWCPayRequest', {
+                    "appId": $('#APPID').val(),     //公众号名称，由商户传入
+                    "timeStamp": $('#Timestamp').val(),         //时间戳，自1970年以来的秒数
+                    "nonceStr": $('#Noncestr').val(), //随机串
+                    "package": $('#package').val(),
+                    "signType": "MD5",         //微信签名方式：
+                    "paySign": $('#paySign').val() //微信签名
+                },
+                function (res) {
+                    if (res.err_msg == "get_brand_wcpay_request:ok") {
+                        //支付成功，后续自行处理
+
+                    }
+                    else {
+                        //支付取消，或者其他错误，自行处理
+                    }
+                }
+            );
+        }
+    </script>
+</body>
+</html>