前回のブログ投稿で述べたように、WeChat メッセージは、テキスト、音声、写真などを含む通常のメッセージと、この記事で説明するイベント タイプに大別されます。含まれるもの: イベントのフォロー/フォロー解除、パラメーターを使用した QR コード イベントのスキャン、地理的位置イベントのレポート、カスタム メニュー関連イベントなど。この記事では、それらを 1 つずつ説明します。
前の記事で述べたように、WeChatサーバーが5秒以内に応答を受信しない場合、接続を切断してリクエストを再開始し、合計3回再試行します。 この場合、問題が発生します。このようなシナリオがあります。ユーザーが WeChat アカウントをフォローすると、現在のユーザー情報が取得され、その情報がデータベースに書き込まれます。 PCサイトでの登録と同様です。おそらくこの懸念のため、処理する必要があるビジネス ロジックは比較的複雑です。ポイントの送信、ユーザー ログの書き込み、ユーザー グループの割り当てなど。お待ちください... 一連のロジックを実行する必要があるか、ネットワーク環境が比較的複雑で、現在のユーザーの操作が 5 秒以内に応答されるという保証はありません。操作がまだ完了していない場合は、WeChat サーバーが応答します。同じアテンション イベントをサーバーにプッシュします。ロジックを再度実行します。これにより、データベース内にデータが重複する可能性があります (データを挿入する前に、まずデータが存在するかどうかを判断し、存在する場合は、と言う人もいます)。何が言いたいかというと、私も最初はそう思っていましたが、実際の動作環境とデバッグ環境にはまだ大きな差があることに初めて気づきました。データベース内の重複したユーザー情報の重要性を発見しました)。
メッセージの重複排除と、通常のメッセージおよびイベント メッセージには違いがあります。通常のメッセージでは msgid が使用されますが、イベント メッセージでは FromUserName + CreateTime が使用されます。私のアイデアは次のとおりです:属性 、つまり FromUser、MsgFlag、および CreateTime を持つ新しいクラス BaseMsg を作成します。コードは次のとおりです。
public class BaseMsg
{ /// <summary>
/// 发送者标识 /// </summary>
public string FromUser { get; set; } /// <summary>
/// 消息表示。普通消息时，为msgid，事件消息时，为事件的创建时间 /// </summary>
public string MsgFlag { get; set; } /// <summary>
/// 添加到队列的时间 /// </summary>
public DateTime CreateTime { get; set; }
}if (_queue == null)
{
_queue = new List<BaseMsg>();
} else if(_queue.Count>=50)
{
_queue = _queue.Where(q => { return q.CreateTime.AddSeconds(20) > DateTime.Now; }).ToList();//保留20秒内未响应的消息 }
XElement xdoc = XElement.Parse(xml); var msgtype = xdoc.Element("MsgType").Value.ToUpper(); var FromUserName = xdoc.Element("FromUserName").Value; var MsgId = xdoc.Element("MsgId").Value; var CreateTime = xdoc.Element("CreateTime").Value;
MsgType type = (MsgType)Enum.Parse(typeof(MsgType), msgtype); if (type!=MsgType.EVENT)
{ if (_queue.FirstOrDefault(m => { return m.MsgFlag == MsgId; }) == null)
{
_queue.Add(new BaseMsg
{
CreateTime = DateTime.Now,
FromUser = FromUserName,
MsgFlag = MsgId
});
} else
{ return null;
}
} else
{ if (_queue.FirstOrDefault(m => { return m.MsgFlag == CreateTime; }) == null)
{
_queue.Add(new BaseMsg
{
CreateTime = DateTime.Now,
FromUser = FromUserName,
MsgFlag = CreateTime
});
} else
{ return null;
}
}BaseMessage を継承し、すべてのイベント タイプには Event プロパティが含まれます。呼び出しの便宜上、メッセージ タイプは列挙として定義されます。コードは次のとおりです。 /// <summary>
/// 事件类型枚举 /// </summary>
public enum Event
{ /// <summary>
/// 非事件类型 /// </summary> NOEVENT, /// <summary>
/// 订阅 /// </summary> SUBSCRIBE, /// <summary>
/// 取消订阅 /// </summary> UNSUBSCRIBE, /// <summary>
/// 扫描带参数的二维码 /// </summary> SCAN, /// <summary>
/// 地理位置 /// </summary> LOCATION, /// <summary>
/// 单击按钮 /// </summary> CLICK, /// <summary>
/// 链接按钮 /// </summary> VIEW, /// <summary>
/// 扫码推事件 /// </summary> SCANCODE_PUSH, /// <summary>
/// 扫码推事件且弹出“消息接收中”提示框 /// </summary> SCANCODE_WAITMSG, /// <summary>
/// 弹出系统拍照发图 /// </summary> PIC_SYSPHOTO, /// <summary>
/// 弹出拍照或者相册发图 /// </summary> PIC_PHOTO_OR_ALBUM, /// <summary>
/// 弹出微信相册发图器 /// </summary> PIC_WEIXIN, /// <summary>
/// 弹出地理位置选择器 /// </summary> LOCATION_SELECT, /// <summary>
/// 模板消息推送 /// </summary> TEMPLATESENDJOBFINISH
}
<xml><ToUserName><![CDATA[toUser]]></ToUserName><FromUserName><![CDATA[FromUser]]></FromUserName><CreateTime>123456789</CreateTime><MsgType><![CDATA[event]]></MsgType><Event><![CDATA[subscribe]]></Event></xml>
対応するエンティティ:
/// <summary>
/// 订阅/取消订阅事件 /// </summary>
public class SubEventMessage : EventMessage
{ private string _eventkey; /// <summary>
/// 事件KEY值，qrscene_为前缀，后面为二维码的参数值（已去掉前缀，可以直接使用） /// </summary>
public string EventKey
{ get { return _eventkey; } set { _eventkey = value.Replace("qrscene_", ""); }
} /// <summary>
/// 二维码的ticket，可用来换取二维码图片 /// </summary>
public string Ticket { get; set; }
}ここで、ユーザーがパラメータを使用してQRコードをスキャンするときに、ユーザーが現在のイベントに従っていない場合に注意する必要があります。公式アカウント では、ユーザーが注目すると、メッセージ本文に qrscene_ パラメーターと Ticket が含まれるため、ここでは EventKey と Ticket の 2 つの属性を定義します。 EventKey に値を割り当てるときは、qrscene_ を置き換えます。実際に必要なのは次のパラメーターであるためです。
パラメータを使用してQRコードイベントをスキャンxmlパッケージをフォローしたときのイベントプッシュは次のとおりです:
<xml><ToUserName><![CDATA[toUser]]></ToUserName><FromUserName><![CDATA[FromUser]]></FromUserName><CreateTime>123456789</CreateTime><MsgType><![CDATA[event]]></MsgType><Event><![CDATA[SCAN]]></Event><EventKey><![CDATA[SCENE_VALUE]]></EventKey><Ticket><![CDATA[TICKET]]></Ticket></xml>
/// <summary>
/// 扫描带参数的二维码实体 /// </summary>
public class ScanEventMessage : EventMessage
{ /// <summary>
/// 事件KEY值，是一个32位无符号整数，即创建二维码时的二维码scene_id /// </summary>
public string EventKey { get; set; } /// <summary>
/// 二维码的ticket，可用来换取二维码图片 /// </summary>
public string Ticket { get; set; }
}xml データ パッケージは次のとおりです:
<xml><ToUserName><![CDATA[toUser]]></ToUserName><FromUserName><![CDATA[fromUser]]></FromUserName><CreateTime>123456789</CreateTime><MsgType><![CDATA[event]]></MsgType><Event><![CDATA[LOCATION]]></Event><Latitude>23.137466</Latitude><Longitude>113.352425</Longitude><Precision>119.385040</Precision></xml>
対応するエンティティは次のとおりです:
/// <summary>
/// 上报地理位置实体 /// </summary>
public class LocationEventMessage : EventMessage
{ /// <summary>
/// 地理位置纬度 /// </summary>
public string Latitude { get; set; } /// <summary>
/// 地理位置经度 /// </summary>
public string Longitude { get; set; } /// <summary>
/// 地理位置精度 /// </summary>
public string Precision { get; set; }
}自定义菜单事件常用的事件有：click，view，scancode_puth，scancode_waitmsg，location_select。另外还有三种发图的事件，由于并不常用，笔者也没想到使用场景，再次就不一一讲述了，有兴趣的可以自己研究下，或者和我进行交流。
click事件推送的xml数据包：
<xml><ToUserName><![CDATA[toUser]]></ToUserName><FromUserName><![CDATA[FromUser]]></FromUserName><CreateTime>123456789</CreateTime><MsgType><![CDATA[event]]></MsgType><Event><![CDATA[CLICK]]></Event><EventKey><![CDATA[EVENTKEY]]></EventKey></xml>
view事件推送的xml数据包和click的格式是一样的，所以定义一个类就可以了，如下：
/// <summary>
/// 普通菜单事件，包括click和view /// </summary>
public class NormalMenuEventMessage : EventMessage
{ /// <summary>
/// 事件KEY值，设置的跳转URL /// </summary>
public string EventKey { get; set; }
}scancode事件的xml数据包如下：
<xml><ToUserName><![CDATA[ToUserName]]></ToUserName><FromUserName><![CDATA[FromUserName]]></FromUserName><CreateTime>1419265698</CreateTime><MsgType><![CDATA[event]]></MsgType><Event><![CDATA[scancode_push]]></Event><EventKey><![CDATA[EventKey]]></EventKey><ScanCodeInfo><ScanType><![CDATA[qrcode]]></ScanType><ScanResult><![CDATA[http://weixin.qq.com/r/JEy5oRLE0U_urVbC9xk2]]></ScanResult></ScanCodeInfo></xml>
对应的实体如下：
/// <summary>
/// 菜单扫描事件 /// </summary>
public class ScanMenuEventMessage : EventMessage
{ /// <summary>
/// 事件KEY值 /// </summary>
public string EventKey { get; set; } /// <summary>
/// 扫码类型。qrcode是二维码，其他的是条码 /// </summary>
public string ScanType { get; set; } /// <summary>
/// 扫描结果 /// </summary>
public string ScanResult { get; set; }
}至此，当前常用的事件类型消息都已定义完毕，结合上一篇所讲的，将xml数据包转换成对象的完整代码如下：
public class MessageFactory
{ private static List _queue;
public static BaseMessage CreateMessage(string xml)
{ if (_queue == null)
{
_queue = new List<BaseMsg>();
} else if(_queue.Count>=50)
{
_queue = _queue.Where(q => { return q.CreateTime.AddSeconds(20) > DateTime.Now; }).ToList();//保留20秒内未响应的消息 }
XElement xdoc = XElement.Parse(xml); var msgtype = xdoc.Element("MsgType").Value.ToUpper(); var FromUserName = xdoc.Element("FromUserName").Value; var MsgId = xdoc.Element("MsgId").Value; var CreateTime = xdoc.Element("CreateTime").Value;
MsgType type = (MsgType)Enum.Parse(typeof(MsgType), msgtype); if (type!=MsgType.EVENT)
{ if (_queue.FirstOrDefault(m => { return m.MsgFlag == MsgId; }) == null)
{
_queue.Add(new BaseMsg
{
CreateTime = DateTime.Now,
FromUser = FromUserName,
MsgFlag = MsgId
});
} else
{ return null;
}
} else
{ if (_queue.FirstOrDefault(m => { return m.MsgFlag == CreateTime; }) == null)
{
_queue.Add(new BaseMsg
{
CreateTime = DateTime.Now,
FromUser = FromUserName,
MsgFlag = CreateTime
});
} else
{ return null;
}
} switch (type)
{ case MsgType.TEXT: return Utils.ConvertObj(xml); case MsgType.IMAGE: return Utils.ConvertObj(xml); case MsgType.VIDEO: return Utils.ConvertObj(xml); case MsgType.VOICE: return Utils.ConvertObj(xml); case MsgType.LINK: return Utils.ConvertObj(xml); case MsgType.LOCATION: return Utils.ConvertObj(xml); case MsgType.EVENT://事件类型 { var eventtype = (Event)Enum.Parse(typeof(Event), xdoc.Element("Event").Value.ToUpper()); switch (eventtype)
{ case Event.CLICK: return Utils.ConvertObj(xml); case Event.VIEW: return Utils.ConvertObj(xml); case Event.LOCATION: return Utils.ConvertObj(xml); case Event.LOCATION_SELECT: return Utils.ConvertObj(xml); case Event.SCAN: return Utils.ConvertObj(xml); case Event.SUBSCRIBE: return Utils.ConvertObj(xml); case Event.UNSUBSCRIBE: return Utils.ConvertObj(xml); case Event.SCANCODE_WAITMSG: return Utils.ConvertObj(xml); default: return Utils.ConvertObj(xml);
}
} break; default: return Utils.ConvertObj(xml);
}
}
} 【相关推荐】
以上がイベントプッシュ受信とメッセージ重複排除の WeChat 開発の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。
![[Web フロントエンド] Node.js クイック スタート](https://img.php.cn/upload/course/000/000/067/662b5d34ba7c0227.png)
