using JiShe.CollectBus.Common.Extensions; using JiShe.CollectBus.Protocol.AnalysisData.Appendix; using JiShe.CollectBus.Protocol.Contracts; using JiShe.CollectBus.Protocol.Contracts.Protocol.Dto; using JiShe.CollectBus.Protocol.Dto; using JiShe.CollectBus.Protocol.Interfaces; using JiShe.CollectBus.Protocol3761; using Microsoft.Extensions.Logging; namespace JiShe.CollectBus.Protocol.AnalysisData.AFN_0CH { /// /// 5.12.2.4.101 F145:当月正向有功最大需量及发生时间(总、费率 1~M) /// public class AFN12_F145_Analysis : IAnalysisStrategy> { private readonly ILogger _logger; private readonly AnalysisStrategyContext _analysisStrategyContext; public AFN12_F145_Analysis(ILogger logger, AnalysisStrategyContext analysisStrategyContext) { _logger = logger; _analysisStrategyContext = analysisStrategyContext; } public async Task> ExecuteAsync(TB3761 input) { try { ArgumentNullException.ThrowIfNull(input); ArgumentNullException.ThrowIfNull(input.UnitData?.HexMessageList); List datas = await AnalysisDataUnitAsync(input.UnitData.HexMessageList); AFN12_F145_AnalysisDto data = GenerateFinalResult(2, datas, "当月正向有功最大需量及发生时间"); data.DataType = $"{input.AFN_FC.AFN.HexToDecStr().PadLeft(2, '0')}_{input.DT.Fn}"; UnitDataAnalysis unitDataAnalysis = new UnitDataAnalysis { Code = input.A.Code, AFN = input.AFN_FC.AFN, Fn = input.DT.Fn, Pn = input.DA.Pn, Data = data }; return await Task.FromResult(unitDataAnalysis); } catch (Exception ex) { _logger.LogError(ex, $"0C_145解析失败:{input.A.Code}-{input.DT.Fn}-{input.BaseHexMessage.HexMessageString},{ex.Message}"); return null; } } private async Task> AnalysisDataUnitAsync(List hexMessageList) { List values = new List(); values.Add(hexMessageList.GetReadTime(4, 5)); int ratingCount = hexMessageList.GetRatingCount(9, 1); values.Add(ratingCount.ToString()); for (int i = 0; i < ratingCount + 1; i++) { var arr = hexMessageList.GetRange(10 + i * 7, 3); var errorCode = arr.CheckErrorCode(); if (errorCode != null) values.Add(errorCode.Item1); else { var value = await _analysisStrategyContext.ExecuteAsync, decimal>(nameof(Appendix_A23), arr); values.Add(value.ToString());//正向有功总最大需量 } arr = hexMessageList.GetRange(10 + i * 7 + 3, 4); errorCode = arr.CheckErrorCode(); if (errorCode != null) values.Add(errorCode.Item1); else { var value = await _analysisStrategyContext.ExecuteAsync, string>(nameof(Appendix_A17), arr); values.Add(value.ToString());//正向有功总最大需量发生时间 } } return values; } public AFN12_F145_AnalysisDto GenerateFinalResult(int index, List data, string remark = "") { AFN12_F145_AnalysisDto dto = new AFN12_F145_AnalysisDto(); decimal value = 0; var errorCode = data[2].CheckErrorCode(); if (errorCode != null) dto.ValidData = false; else decimal.TryParse(data[2], out value); dto.DataValue = value; dto.TimeSpan = $"{DateTime.Now.Year}-{data[3].Substring(0, 2)}-{data[3].Substring(2, 2)} {data[3].Substring(4, 2)}:{data[3].Substring(6, 2)}:00";//$"{data[0].Substring(0, 4)}-{data[0].Substring(4, 2)}-{data[0].Substring(6, 2)}"; if (DateTime.TryParse(dto.TimeSpan, out DateTime readingDate)) { dto.ReadingDate = readingDate; } return dto; } } }