using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
|
namespace IStation.RedisCache
|
{
|
/// <summary>
|
/// 对接监测流程记录缓存辅助类
|
/// </summary>
|
public class MonitorDataDockingFlowRecordCacheHelper
|
{
|
//标志
|
private const string _flag = "monitor-datadocking-flow";
|
|
//最后一条记录
|
private const string _lastRecord = "last-record";
|
|
//Redis客户端辅助类对象
|
private readonly RedisClientHelper _redisClient = new RedisClientHelper();
|
|
//创建RedisKey
|
private static string CreateRedisKey(long CorpID, long ConfigureID)
|
{
|
return $"{RedisKeyHelper.CreateKey(_flag)}:{CorpID}-{ConfigureID}";
|
}
|
|
#region 最后一条记录
|
|
/// <summary>
|
/// 设置最后一条记录
|
/// </summary>
|
public void SetLastRecord(Model.MonitorDataDockingFlowRecord model)
|
{
|
if (model == null)
|
return;
|
var redisKey = CreateRedisKey(model.CorpID, model.ConfigureID);
|
_redisClient.HashSetJosn(redisKey, _lastRecord, model);
|
}
|
|
/// <summary>
|
/// 设置最后一条记录
|
/// </summary>
|
public void SetLastRecord(IEnumerable<Model.MonitorDataDockingFlowRecord> list)
|
{
|
if (list == null || list.Count() < 1)
|
return;
|
foreach (var item in list)
|
{
|
SetLastRecord(item);
|
}
|
}
|
|
/// <summary>
|
/// 获取最后一条记录
|
/// </summary>
|
public Model.MonitorDataDockingFlowRecord GetLastRecord(long CorpID, long ConfigureID)
|
{
|
var redisKey = CreateRedisKey(CorpID, ConfigureID);
|
return _redisClient.HashGetJson<Model.MonitorDataDockingFlowRecord>(redisKey, _lastRecord);
|
}
|
|
/// <summary>
|
/// 获取最后一条记录
|
/// </summary>
|
public List<Model.MonitorDataDockingFlowRecord> GetLastRecord(long CorpID, IEnumerable<long> ConfigureIds)
|
{
|
if (ConfigureIds == null || ConfigureIds.Count() < 1)
|
return default;
|
return ConfigureIds.Select(x => GetLastRecord(CorpID, x)).Where(x => x != null).ToList();
|
}
|
|
|
#endregion
|
|
|
|
}
|
}
|
