using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
|
namespace IStation.RedisCache
|
{
|
public class Smi_Expert_StoreVibrationRecord
|
{
|
private const string Flag = "smi-expert";//标志
|
|
//最后一条记录
|
private const string _lastRecord = "LastRecord";
|
|
|
//Redis客户端辅助类对象
|
private readonly RedisClientHelper _redisClient = new RedisClientHelper();
|
|
//创建RedisKey
|
private static string CreateRedisKey(string objectId)
|
{
|
return $"{RedisKeyHelper.CreateKey(Flag)}:{objectId}";
|
}
|
|
|
/// <summary>
|
/// 设置最后一条记录
|
/// </summary>
|
public void SetLastRecord(Model.Smi_Expert_VibrationRecord model)
|
{
|
if (model == null)
|
return;
|
var redisKey = CreateRedisKey(model.ObjectId);
|
_redisClient.HashSetJosn(redisKey, _lastRecord,model);
|
}
|
|
/// <summary>
|
/// 设置最后一条记录(批量)
|
/// </summary>
|
public void SetLastRecord(IEnumerable<Model.Smi_Expert_VibrationRecord> list)
|
{
|
if (list == null || list.Count() < 1)
|
return;
|
foreach (var item in list)
|
{
|
SetLastRecord(item);
|
}
|
}
|
|
/// <summary>
|
/// 获取最后一条记录
|
/// </summary>
|
public Model.Smi_Expert_VibrationRecord GetLastRecord(string ObjectId)
|
{
|
var redisKey = CreateRedisKey(ObjectId);
|
return _redisClient.HashGetJson<Model.Smi_Expert_VibrationRecord>(redisKey,_lastRecord);
|
}
|
|
/// <summary>
|
/// 获取最后一条记录
|
/// </summary>
|
public List<Model.Smi_Expert_VibrationRecord> GetLastRecord(IEnumerable<string> ObjectIds)
|
{
|
if (ObjectIds == null || ObjectIds.Count() < 1)
|
return default;
|
return ObjectIds.Select(x => GetLastRecord(x)).Where(x => x != null).ToList();
|
}
|
|
/// <summary>
|
/// 获取最后一条记录StartWith
|
/// </summary>
|
public List<Model.Smi_Expert_VibrationRecord> GetLastRecordStartWith(string objectId)
|
{
|
var key = CreateRedisKey(objectId);
|
var allKeys = _redisClient.AllKeyStartWidth(key);
|
if (allKeys == null || allKeys.Count < 1)
|
return default;
|
var vm_list = new List<Model.Smi_Expert_VibrationRecord>();
|
foreach (var redisKey in allKeys)
|
{
|
var vm = _redisClient.HashGetJson<Model.Smi_Expert_VibrationRecord>(redisKey, _lastRecord);
|
if (vm != null)
|
{
|
vm_list.Add(vm);
|
}
|
}
|
return vm_list;
|
}
|
|
|
|
|
|
|
}
|
}
|
