41 lines
1.8 KiB
C#
41 lines
1.8 KiB
C#
using System;
|
||
using System.Collections.Generic;
|
||
using System.Linq;
|
||
using System.Threading;
|
||
using System.Threading.Tasks;
|
||
using Senparc.NeuChar.Entities;
|
||
using Senparc.NeuChar.Entities.Request;
|
||
using Senparc.Weixin.MP.Entities;
|
||
|
||
namespace YBDevice.WX.MessageHandlers.CustomMessageHandler
|
||
{
|
||
/// <summary>
|
||
/// 自定义MessageHandler
|
||
/// </summary>
|
||
public partial class CustomMessageHandler
|
||
{
|
||
public override async Task OnExecutingAsync(CancellationToken cancellationToken)
|
||
{
|
||
//演示：MessageContext.StorageData
|
||
|
||
var currentMessageContext = await base.GetUnsafeMessageContext();//为了在分布式缓存下提高读写效率，使用此方法，如果需要获取实时数据，应该使用 base.GetCurrentMessageContext()
|
||
if (currentMessageContext.StorageData == null || !(currentMessageContext.StorageData is int))
|
||
{
|
||
currentMessageContext.StorageData = (int)0;
|
||
//await GlobalMessageContext.UpdateMessageContextAsync(currentMessageContext);//储存到缓存
|
||
}
|
||
await base.OnExecutingAsync(cancellationToken);
|
||
}
|
||
|
||
public override async Task OnExecutedAsync(CancellationToken cancellationToken)
|
||
{
|
||
//演示：MessageContext.StorageData
|
||
|
||
var currentMessageContext = await base.GetUnsafeMessageContext();//为了在分布式缓存下提高读写效率，使用此方法，如果需要获取实时数据，应该使用 base.GetCurrentMessageContext()
|
||
currentMessageContext.StorageData = ((int)currentMessageContext.StorageData) + 1;
|
||
GlobalMessageContext.UpdateMessageContext(currentMessageContext);//储存到缓存
|
||
await base.OnExecutedAsync(cancellationToken);
|
||
}
|
||
}
|
||
}
|