wenkai.chen/tnb.server
Template
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

redis页面

Browse Source
This commit is contained in:
qianjiawei
2023-11-10 16:03:45 +08:00
parent fff6e527d3
commit e60dc32456
1 changed files with 29 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

32
ProductionMgr/Tnb.ProductionMgr/RedisDataService.cs
View File

@@ -1,11 +1,17 @@
using JNPF.Common.Cache;
using System.Reflection;
using JNPF.Common.Cache;
using JNPF.Common.Dtos.VisualDev;
using JNPF.Common.Security;
using JNPF.DependencyInjection;
using JNPF.DynamicApiController;
using JNPF.FriendlyException;
using JNPF.VisualDev;
using Microsoft.AspNetCore.Mvc;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using SqlSugar;
using Tnb.Common.Redis;
using Tnb.ProductionMgr.Entities;
using Tnb.ProductionMgr.Interfaces;
namespace Tnb.ProductionMgr
@@ -15,12 +21,32 @@ namespace Tnb.ProductionMgr
/// </summary>
[ApiDescriptionSettings(Tag = ModuleConst.Tag, Area = ModuleConst.Area, Order = 700)]
[Route("api/[area]/[controller]/[action]")]
public class RedisDataService : IRedisDataService, IDynamicApiController, ITransient
[OverideVisualDev(ModuleId)]
public class RedisDataService : IOverideVisualDevService, IRedisDataService, IDynamicApiController, ITransient
{
private const string ModuleId = "30062789830933";
private readonly RedisData _redisData;
public RedisDataService(RedisData redisData)
private readonly ISqlSugarRepository<RedisReadConfig> _repository;
public OverideVisualDevFunc OverideFuncs { get; } = new OverideVisualDevFunc();
public RedisDataService(RedisData redisData, ISqlSugarRepository<RedisReadConfig> repository)
{
_redisData = redisData;
_repository = repository;
OverideFuncs.CreateAsync = Create;
}
private async Task<dynamic> Create(VisualDevModelDataCrInput input)
{
RedisReadConfig redisReadConfig = new RedisReadConfig();
redisReadConfig.id = SnowflakeIdHelper.NextId();
redisReadConfig.dev_name = input.data[nameof(RedisReadConfig.dev_name)].ToString();
redisReadConfig.tag_name = input.data[nameof(RedisReadConfig.tag_name)].ToString();
redisReadConfig.data = input.data[nameof(RedisReadConfig.data)].ToString();
redisReadConfig.event_type = int.Parse(input.data[nameof(RedisReadConfig.event_type)].ToString()!);
redisReadConfig.data_type = int.Parse(input.data[nameof(RedisReadConfig.data_type)].ToString()!);
redisReadConfig.check_type = int.Parse(input.data[nameof(RedisReadConfig.check_type)].ToString()!);
redisReadConfig.enabled = int.Parse(input.data[nameof(RedisReadConfig.enabled)].ToString()!);
await _repository.AsSugarClient().Insertable(redisReadConfig).ExecuteCommandAsync();
return await Task.FromResult(true);
}
/// <summary>
/// 根据机号获取重量