DTcms.API/DTcms.API.Weixin.Common/MessageFunction.cs

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

using DTcms.BLL;
using DTcms.Model;
using Senparc.Weixin.MP.Entities;
using System;
using System.Collections.Generic;
using System.Web;

namespace DTcms.API.Weixin.Common
{
	public class MessageFunction
	{
		private DTcms.Model.siteconfig siteConfig = new DTcms.BLL.siteconfig().loadConfig();

		public IResponseMessageBase EventSubscribe(int type, RequestMessageEventBase requestMessage)
		{
			int accountId = this.GetAccountId();
			string EventName = "";
			if (requestMessage.Event.ToString().Trim() != "")
			{
				EventName = requestMessage.Event.ToString();
			}
			else if (requestMessage.EventKey != null)
			{
				EventName += requestMessage.EventKey.ToString();
			}
			IResponseMessageBase result;
			if (!this.ExistsOriginalId(accountId, requestMessage.ToUserName))
			{
				new DTcms.BLL.weixin_response_content().Add(accountId, requestMessage.FromUserName, requestMessage.MsgType.ToString(), EventName, "none", "未取到关键词对应的数据", requestMessage.ToUserName);
				result = this.GetResponseMessageTxtByContent(requestMessage, "验证微帐号与微信原始帐号id不一致，可能原因【1】系统配置错误，【2】非法的数据来源", accountId);
			}
			else
			{
				int responseType = 0;
				int ruleId = new DTcms.BLL.weixin_request_rule().GetRuleIdAndResponseType(accountId, "request_type=" + type, out responseType);
				if (ruleId <= 0 || responseType <= 0)
				{
					new DTcms.BLL.weixin_response_content().Add(accountId, requestMessage.FromUserName, requestMessage.MsgType.ToString(), EventName, "none", "未取到关键词对应的数据", requestMessage.ToUserName);
					result = null;
				}
				else
				{
					IResponseMessageBase reponseMessage = null;
					switch (responseType)
					{
					case 1:
						reponseMessage = this.GetResponseMessageTxt(requestMessage, ruleId, accountId);
						break;
					case 2:
						reponseMessage = this.GetResponseMessageNews(requestMessage, ruleId, accountId);
						break;
					case 3:
						reponseMessage = this.GetResponseMessageeMusic(requestMessage, ruleId, accountId);
						break;
					}
					result = reponseMessage;
				}
			}
			return result;
		}