zongzhilinglan/pkg/Senparc.Weixin.Sample.CommonService/EventService.cs

/*----------------------------------------------------------------
    Copyright (C) 2023 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.NeuChar.Entities;
using Senparc.NeuChar.Helpers;
using Senparc.CO2NET.Utilities;
using Senparc.CO2NET.Trace;
//DPBMARK MP
using Senparc.Weixin.MP.Entities;
using Senparc.Weixin.MP.Helpers;
using Senparc.Weixin.MP;
//DPBMARK_END
#if NET462
using System.Web;
using System.Configuration;
using Senparc.Weixin.Sample.CommonService.TemplateMessage;//DPBMARK MP DPBMARK_END
#else
using Microsoft.AspNetCore.Http;
using Senparc.Weixin.Sample.CommonService.TemplateMessage;//DPBMARK MP DPBMARK_END
#endif


namespace Senparc.Weixin.Sample.CommonService
{
    /// <summary>
    /// 全局微信事件有关的处理程序
    /// </summary>
    public class EventService
    {
        #region DPBMARK MP

        /// <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 NET462
                        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;
        }

        #endregion DPBMARK_END


        public async Task 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.1-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.调用接口的IP地址不在白名单中,//比较容易出现，需要注意！
                                ReturnCode.缺少access_token参数,
                                ReturnCode.回复时间超过限制,
                                ReturnCode.api功能未授权,
                                ReturnCode.用户未授权该api,
                                ReturnCode.参数错误invalid_parameter,
                                ReturnCode.接口调用超过限制,
                                ReturnCode.需要接收者关注,//43004
                                ReturnCode.超出响应数量限制,//43004 - out of response count limit，一般只允许连续接收20条客服消息
                                ReturnCode.不合法的APPID,
                                ReturnCode.不合法的OpenID,

                                //其他更多可能的情况
                            };
                    if (ignoreErrorCodes.Contains(jsonEx.JsonResult.errcode))
                    {
                        if (jsonEx.JsonResult.errcode == ReturnCode.调用接口的IP地址不在白名单中)
                        {
                            SenparcTrace.SendCustomLog("无法发送模板消息", "IP 未设置到白名单");
                        }

                        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);
                        }

                        if (result.Result.errcode != ReturnCode.请求成功)
                        {
                            Senparc.Weixin.WeixinTrace.SendCustomLog("异常模板消息发送过程中再次失败", result.Exception?.Message + "\r\n" + result.Exception?.StackTrace);
                        }
                    }
                }                           // DPBMARK_END
            }
            catch (Exception e)
            {
                Senparc.Weixin.WeixinTrace.SendCustomLog("OnWeixinExceptionFunc过程错误", e.Message);
            }
        }
    }
}