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