using Furion;
|
using InitQ.Cache;
|
using Newtonsoft.Json;
|
using StackExchange.Redis;
|
|
namespace EzInitqMessageDef
|
{
|
/// <summary>
|
/// 队列消息定义
|
/// </summary>
|
public static class InitQMessages
|
{
|
/// <summary>
|
/// 转账
|
/// </summary>
|
public const string WxTransferMSQ = "WxTransferMSQ";
|
/// <summary>
|
///微信提现只传递ID
|
/// </summary>
|
public const string WxTransfer = "WxTransfer";
|
/// <summary>
|
///重新支付
|
/// </summary>
|
public const string WxTransferAg = "WxTransferAg";
|
/// <summary>
|
/// 向堆栈中压入一个消息
|
/// </summary>
|
/// <typeparam name="T"> 类型</typeparam>
|
/// <param name="MessageName"> 消息名称</param>
|
/// <param name="msg">类型</param>
|
/// <returns></returns>
|
public static async Task<bool> SendMessageAsync<T>(string MessageName,T msg)
|
{
|
var _redis= App.GetService<ICacheService>();
|
|
await _redis.ListRightPushAsync(MessageName, JsonConvert.SerializeObject(msg));
|
return true;
|
}
|
/// <summary>
|
/// 向堆栈中压入一个消息
|
/// </summary>
|
/// <param name="MessageName"></param>
|
/// <param name="msg"></param>
|
/// <returns></returns>
|
public static async Task<bool> SendMessageAsync(string MessageName, string msg)
|
{
|
var _redis = App.GetService<ICacheService>();
|
|
await _redis.ListRightPushAsync(MessageName, msg);
|
|
return true;
|
}
|
}
|
}
|