diff --git a/Service/Ammeter/Client/AmmeterClient.cs b/Service/Ammeter/Client/AmmeterClient.cs index 621bc2b..519edd8 100644 --- a/Service/Ammeter/Client/AmmeterClient.cs +++ b/Service/Ammeter/Client/AmmeterClient.cs @@ -1,9 +1,11 @@ using Common.Const; +using Entity.Ammeter; using Entity.DbModel.Station; using HybirdFrameworkCore.Autofac.Attribute; using HybirdFrameworkCore.Const; using HybirdFrameworkDriver.ModbusTcpMaster; using log4net; +using Repository.Ammeter; using Repository.Station; using Service.Ammeter.Msg; using Service.FireControl.Msg; @@ -14,7 +16,9 @@ namespace Service.FireControl.Client; public class AmmeterClient : ModbusTcpMaster { private static readonly ILog Log = LogManager.GetLogger(typeof(AmmeterClient)); - + public EmeterEnergyRepository EmeterEnergyRepository { get; set; } + public EmeterEnergyChangeRepository EmeterEnergyChangeRepository { get; set; } + public AmmeterClient() { ReadAction = BatchRead; @@ -38,6 +42,29 @@ public class AmmeterClient : ModbusTcpMaster { connectResult = true; ModbusDecoder.Decode(readPowerValue, AmmeterMgr.ACMeters, EndingConst.ByteSeq.AB, EndingConst.WordSeq.DC); + + + + + #region 插入电能数据 + DateTime time = DateTime.Now.AddDays(-7); + EmeterEnergyRepository.Delete(i => i.UploadTime < time); + EmeterEnergyChangeRepository.Delete(i => i.UploadTime < time); + + string id = DateTime.Now.ToString("yyyyMMddHHmmss"); + string code = "";//电表编号 + id = id + "_" + code; + EmeterEnergyChange emeterEnergyChange = new() + { + Id = id, + UploadFlag = 0, + Value = AmmeterMgr.ACMeters.ActiveTotalEnergy.Value, + Code = code, + UploadTime = DateTime.Now + }; + EmeterEnergyChangeRepository.Insert(emeterEnergyChange); + #endregion + } #endregion return connectResult;