mirror of
https://github.com/CoreUnion/CoreShop.git
synced 2026-10-22 08:46:12 +08:00
JianWeie
189 lines
8.7 KiB
C#
189 lines
8.7 KiB
C#
/*----------------------------------------------------------------
|
||
Copyright (C) 2020 Senparc
|
||
|
||
文件名：EventService.cs
|
||
文件功能描述：事件处理程序，此代码的简化MessageHandler方法已由/CustomerMessageHandler/CustomerMessageHandler_Event.cs完成
|
||
|
||
|
||
创建标识：Senparc - 20150312
|
||
----------------------------------------------------------------*/
|
||
|
||
|
||
using System;
|
||
using System.Diagnostics;
|
||
using System.Linq;
|
||
using System.Threading;
|
||
using System.Threading.Tasks;
|
||
using Senparc.Weixin.Exceptions;
|
||
using Senparc.Weixin.MP.Entities;
|
||
using Senparc.Weixin.MP.Helpers;
|
||
using Senparc.NeuChar.Entities;
|
||
using Senparc.NeuChar.Helpers;
|
||
using Senparc.CO2NET.Utilities;
|
||
using Senparc.Weixin;
|
||
using Senparc.Weixin.MP;
|
||
#if NET45
|
||
using System.Web;
|
||
using System.Configuration;
|
||
//DPBMARK MP
|
||
using CoreCms.Net.WeChatService.TemplateMessage;
|
||
//DPBMARK_END
|
||
#else
|
||
using Microsoft.AspNetCore.Http;
|
||
using CoreCms.Net.WeChatService.TemplateMessage;
|
||
using CoreCms.Net.WeChatService.Utilities;
|
||
#endif
|
||
|
||
|
||
namespace CoreCms.Net.WeChatService
|
||
{
|
||
/// <summary>
|
||
/// 全局微信事件有关的处理程序
|
||
/// </summary>
|
||
public class EventService
|
||
{
|
||
/// <summary>
|
||
/// 微信MessageHandler事件处理，此代码的简化MessageHandler方法已由/CustomerMessageHandler/CustomerMessageHandler_Event.cs完成，
|
||
/// 此方法不再更新
|
||
/// </summary>
|
||
/// <param name="requestMessage"></param>
|
||
/// <returns></returns>
|
||
public ResponseMessageBase GetResponseMessage(RequestMessageEventBase requestMessage)
|
||
{
|
||
ResponseMessageBase responseMessage = null;
|
||
switch (requestMessage.Event)
|
||
{
|
||
case Event.ENTER:
|
||
{
|
||
var strongResponseMessage = requestMessage.CreateResponseMessage<ResponseMessageText>();
|
||
strongResponseMessage.Content = "您刚才发送了ENTER事件请求。";
|
||
responseMessage = strongResponseMessage;
|
||
break;
|
||
}
|
||
case Event.LOCATION:
|
||
throw new Exception("暂不可用");
|
||
//break;
|
||
case Event.subscribe://订阅
|
||
{
|
||
var strongResponseMessage = requestMessage.CreateResponseMessage<ResponseMessageText>();
|
||
|
||
//获取Senparc.Weixin.MP.dll版本信息
|
||
#if NET45
|
||
var dllPath = HttpContext.Current.Server.MapPath("~/bin/Senparc.Weixin.MP.dll");
|
||
#else
|
||
//var dllPath = ServerUtility.ContentRootMapPath("~/bin/Release/netcoreapp2.2/Senparc.Weixin.MP.dll");//本地测试路径
|
||
var dllPath = ServerUtility.ContentRootMapPath("~/Senparc.Weixin.MP.dll");//发布路径
|
||
#endif
|
||
|
||
var fileVersionInfo = FileVersionInfo.GetVersionInfo(dllPath);
|
||
|
||
var version = fileVersionInfo.FileVersion;
|
||
strongResponseMessage.Content = string.Format(
|
||
"欢迎关注【Senparc.Weixin.MP 微信公众平台SDK】，当前运行版本：v{0}。\r\n您还可以发送【位置】【图片】【语音】信息，查看不同格式的回复。\r\nSDK官方地址：https://sdk.weixin.senparc.com",
|
||
version);
|
||
responseMessage = strongResponseMessage;
|
||
break;
|
||
}
|
||
case Event.unsubscribe://退订
|
||
{
|
||
//实际上用户无法收到非订阅账号的消息，所以这里可以随便写。
|
||
//unsubscribe事件的意义在于及时删除网站应用中已经记录的OpenID绑定，消除冗余数据。
|
||
var strongResponseMessage = requestMessage.CreateResponseMessage<ResponseMessageText>();
|
||
strongResponseMessage.Content = "有空再来";
|
||
responseMessage = strongResponseMessage;
|
||
break;
|
||
}
|
||
case Event.CLICK://菜单点击事件，根据自己需要修改
|
||
//这里的CLICK在此DEMO中不会被执行到，因为已经重写了OnEvent_ClickRequest
|
||
break;
|
||
default:
|
||
throw new ArgumentOutOfRangeException();
|
||
}
|
||
|
||
return responseMessage;
|
||
}
|
||
|
||
//public async Task ConfigOnWeixinExceptionFunc(WeixinException ex)
|
||
public void ConfigOnWeixinExceptionFunc(WeixinException ex)
|
||
{
|
||
Senparc.Weixin.WeixinTrace.SendCustomLog("进入 ConfigOnWeixinExceptionFunc() 方法", ex.Message);
|
||
try
|
||
{
|
||
var appId = Config.SenparcWeixinSetting.WeixinAppId;
|
||
|
||
string openId = "olPjZjsXuQPJoV0HlruZkNzKc91E";//收到通知的管理员OpenId
|
||
var host = "A1 / AccessTokenOrAppId：" + (ex.AccessTokenOrAppId ?? "null");
|
||
string service = null;
|
||
string message = ex.Message;
|
||
var status = ex.GetType().Name;
|
||
var remark = "\r\n这是一条通过OnWeixinExceptionFunc事件发送的异步模板消息";
|
||
string url = "https://github.com/JeffreySu/WeiXinMPSDK/blob/master/Samples/netcore3.0-mvc/Senparc.Weixin.Sample.NetCore3/Startup.cs#L410";//需要点击打开的URL
|
||
|
||
var sendTemplateMessage = true;
|
||
|
||
if (ex is ErrorJsonResultException)
|
||
{
|
||
var jsonEx = (ErrorJsonResultException)ex;
|
||
service = $"{jsonEx.JsonResult?.errcode}:{jsonEx.JsonResult?.errmsg} - {jsonEx.Url?.Replace("https://api.weixin.qq.com/cgi-bin", "ApiUrl")}".Substring(0, 30);
|
||
message = jsonEx.Message;
|
||
|
||
//需要忽略的类型
|
||
var ignoreErrorCodes = new[]
|
||
{
|
||
ReturnCode.获取access_token时AppSecret错误或者access_token无效,
|
||
ReturnCode.access_token超时,
|
||
ReturnCode.template_id不正确,
|
||
ReturnCode.缺少access_token参数,
|
||
ReturnCode.回复时间超过限制,
|
||
ReturnCode.api功能未授权,
|
||
ReturnCode.用户未授权该api,
|
||
ReturnCode.参数错误invalid_parameter,
|
||
ReturnCode.接口调用超过限制,
|
||
ReturnCode.需要接收者关注,//43004
|
||
ReturnCode.超出响应数量限制,//43004 - out of response count limit，一般只允许连续接收20条客服消息
|
||
|
||
//其他更多可能的情况
|
||
};
|
||
if (ignoreErrorCodes.Contains(jsonEx.JsonResult.errcode))
|
||
{
|
||
sendTemplateMessage = false;//防止无限递归，这种请款那个下不发送消息
|
||
}
|
||
|
||
//TODO:防止更多的接口自身错误导致的无限递归。
|
||
}
|
||
else
|
||
{
|
||
if (ex.Message.StartsWith("openid:"))
|
||
{
|
||
openId = ex.Message.Split(':')[1];//发送给指定OpenId
|
||
}
|
||
service = "WeixinException";
|
||
message = ex.Message;
|
||
}
|
||
|
||
if (sendTemplateMessage) // DPBMARK MP
|
||
{
|
||
int sleepSeconds = 3;
|
||
Thread.Sleep(sleepSeconds * 1000);
|
||
var data = new WeixinTemplate_ExceptionAlert(string.Format("微信发生异常（延时{0}秒）", sleepSeconds), host, service, status, message, remark);
|
||
|
||
//修改OpenId、启用以下代码后即可收到模板消息
|
||
if (!string.IsNullOrEmpty(openId))
|
||
{
|
||
var result = Senparc.Weixin.MP.AdvancedAPIs.TemplateApi.SendTemplateMessageAsync(appId, openId, data.TemplateId,
|
||
url, data);
|
||
Task.WaitAll(new[] { result });
|
||
if (result.IsFaulted)
|
||
{
|
||
Senparc.Weixin.WeixinTrace.SendCustomLog("OnWeixinExceptionFunc过程模板消息发送异常", result.Exception?.Message + "\r\n" + result.Exception?.StackTrace);
|
||
}
|
||
}
|
||
} // DPBMARK_END
|
||
}
|
||
catch (Exception e)
|
||
{
|
||
Senparc.Weixin.WeixinTrace.SendCustomLog("OnWeixinExceptionFunc过程错误", e.Message);
|
||
}
|
||
}
|
||
}
|
||
} |