diff --git a/ProductionMgr/Tnb.ProductionMgr/RedisDataService.cs b/ProductionMgr/Tnb.ProductionMgr/RedisDataService.cs index 6007f34f..fd7cad38 100644 --- a/ProductionMgr/Tnb.ProductionMgr/RedisDataService.cs +++ b/ProductionMgr/Tnb.ProductionMgr/RedisDataService.cs @@ -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 /// [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 _repository; + public OverideVisualDevFunc OverideFuncs { get; } = new OverideVisualDevFunc(); + public RedisDataService(RedisData redisData, ISqlSugarRepository repository) { _redisData = redisData; + _repository = repository; + OverideFuncs.CreateAsync = Create; + } + private async Task 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); } /// /// 根据机号获取重量