From e60dc3245637eaac6bb7253e2c7547bc1357a5d4 Mon Sep 17 00:00:00 2001
From: qianjiawei <1184704771@qq.com>
Date: Fri, 10 Nov 2023 16:03:45 +0800
Subject: [PATCH] =?UTF-8?q?redis=E9=A1=B5=E9=9D=A2?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../Tnb.ProductionMgr/RedisDataService.cs     | 32 +++++++++++++++++--
 1 file changed, 29 insertions(+), 3 deletions(-)

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
     /// </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>
         /// 根据机号获取重量