Compare commits
No commits in common. "b0bbf67f870060d7d2439451b66acda4da7e1550" and "d97e38439a45c635ea4127ae9a16461b83be5a03" have entirely different histories.
b0bbf67f87
...
d97e38439a
@ -29,10 +29,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_00H
|
||||
AFN = input.AFN_FC.AFN,
|
||||
Fn = input.DT.Fn,
|
||||
Pn = input.DA.Pn,
|
||||
Data = true,
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
Data = true
|
||||
};
|
||||
result?.Invoke(dto);
|
||||
return Task.FromResult(true);
|
||||
|
||||
@ -16,30 +16,27 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_00H
|
||||
{
|
||||
_logger = logger;
|
||||
}
|
||||
public Task<bool> ExecuteAsync(TB3761 input, Action<dynamic>? result = null)
|
||||
public Task<bool> ExecuteAsync(TB3761 tB3761, Action<dynamic>? result = null)
|
||||
{
|
||||
try
|
||||
{
|
||||
ArgumentNullException.ThrowIfNull(input);
|
||||
ArgumentNullException.ThrowIfNull(input.A.Code);
|
||||
ArgumentNullException.ThrowIfNull(tB3761);
|
||||
ArgumentNullException.ThrowIfNull(tB3761.A.Code);
|
||||
UnitDataAnalysis<bool> dto = new UnitDataAnalysis<bool>
|
||||
{
|
||||
Code = input.A.Code,
|
||||
AFN = input.AFN_FC.AFN,
|
||||
Fn = input.DT.Fn,
|
||||
Pn = input.DA.Pn,
|
||||
Code = tB3761.A.Code,
|
||||
AFN = tB3761.AFN_FC.AFN,
|
||||
Fn = tB3761.DT.Fn,
|
||||
Pn = tB3761.DA.Pn,
|
||||
Data = false,
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
ReceivedTime =input.ReceivedTime
|
||||
};
|
||||
result?.Invoke(dto);
|
||||
return Task.FromResult(true);
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
_logger.LogError(ex, $"00_2解析失败:{input.A.Code}-{input.DT.Fn}-{input.BaseHexMessage.HexMessageString},{ex.Message}");
|
||||
return Task.FromResult(false);
|
||||
_logger.LogError(ex, $"00_2解析失败:{tB3761.A.Code}-{tB3761.DT.Fn}-{tB3761.BaseHexMessage.HexMessageString},{ex.Message}");
|
||||
return null;
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
@ -35,10 +35,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_02H
|
||||
AFN = input.AFN_FC.AFN,
|
||||
Fn = input.DT.Fn,
|
||||
Pn = input.DA.Pn,
|
||||
Data = $"登录帧",
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
Data = $"登录帧"
|
||||
};
|
||||
result?.Invoke(dto);
|
||||
return Task.FromResult(true);
|
||||
@ -50,5 +47,86 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_02H
|
||||
return Task.FromResult(false);
|
||||
}
|
||||
|
||||
|
||||
//public Task ExecuteAsync<TResult>(TB3761 input, Action<TResult>? callback = null) where TResult : UnitDataAnalysis<TResult>
|
||||
//{
|
||||
// try
|
||||
// {
|
||||
// ArgumentNullException.ThrowIfNull(input);
|
||||
// ArgumentNullException.ThrowIfNull(input.A.Code);
|
||||
// UnitDataAnalysis<string> dto = new UnitDataAnalysis<string>
|
||||
// {
|
||||
// Code = input.A.Code,
|
||||
// AFN = input.AFN_FC.AFN,
|
||||
// Fn = input.DT.Fn,
|
||||
// Pn = input.DA.Pn,
|
||||
// Data = $"登录帧"
|
||||
// };
|
||||
// callback?.Invoke(dto);
|
||||
// return Task.FromResult(dto);
|
||||
// }
|
||||
// catch (Exception ex)
|
||||
// {
|
||||
// _logger.LogError(ex, $"02_1解析失败:{input.A.Code}-{input.DT.Fn}-{input.BaseHexMessage.HexMessageString},{ex.Message}");
|
||||
// return null;
|
||||
// }
|
||||
//}
|
||||
|
||||
//public Task<UnitDataAnalysis<string>> ExecuteAsync(TB3761 input, Action<UnitDataAnalysis<string>>? callback = null)
|
||||
//{
|
||||
// try
|
||||
// {
|
||||
// ArgumentNullException.ThrowIfNull(input);
|
||||
// ArgumentNullException.ThrowIfNull(input.A.Code);
|
||||
// UnitDataAnalysis<string> dto = new UnitDataAnalysis<string>
|
||||
// {
|
||||
// Code = input.A.Code,
|
||||
// AFN = input.AFN_FC.AFN,
|
||||
// Fn = input.DT.Fn,
|
||||
// Pn = input.DA.Pn,
|
||||
// Data = $"登录帧"
|
||||
// };
|
||||
// callback?.Invoke(dto);
|
||||
// return Task.FromResult(dto);
|
||||
// }
|
||||
// catch (Exception ex)
|
||||
// {
|
||||
// _logger.LogError(ex, $"02_1解析失败:{input.A.Code}-{input.DT.Fn}-{input.BaseHexMessage.HexMessageString},{ex.Message}");
|
||||
// return null;
|
||||
// }
|
||||
//}
|
||||
|
||||
//public Task ExecuteAsync<TResult>(TB3761 input, Action<TResult>? callback = null)
|
||||
//{
|
||||
// try
|
||||
// {
|
||||
// ArgumentNullException.ThrowIfNull(input);
|
||||
// ArgumentNullException.ThrowIfNull(input.A.Code);
|
||||
// var dto = Activator.CreateInstance<TResult>();
|
||||
// dto.Code = input.A.Code;
|
||||
// dto.AFN = input.AFN_FC.AFN;
|
||||
// dto.Fn = input.DT.Fn;
|
||||
// dto.Pn = input.DA.Pn;
|
||||
// dto.Data = "登录帧";
|
||||
// //UnitDataAnalysis<string> dto = new UnitDataAnalysis<string>
|
||||
// //{
|
||||
// // Code = input.A.Code,
|
||||
// // AFN = input.AFN_FC.AFN,
|
||||
// // Fn = input.DT.Fn,
|
||||
// // Pn = input.DA.Pn,
|
||||
// // Data = $"登录帧"
|
||||
// //};
|
||||
// callback?.Invoke(dto);
|
||||
// return Task.FromResult(dto);
|
||||
// }
|
||||
// catch (Exception ex)
|
||||
// {
|
||||
// _logger.LogError(ex, $"02_1解析失败:{input.A.Code}-{input.DT.Fn}-{input.BaseHexMessage.HexMessageString},{ex.Message}");
|
||||
// return null;
|
||||
// }
|
||||
//}
|
||||
|
||||
|
||||
|
||||
}
|
||||
}
|
||||
|
||||
@ -22,29 +22,26 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_02H
|
||||
_logger = logger;
|
||||
}
|
||||
|
||||
public Task<bool> ExecuteAsync(TB3761 input, Action<dynamic>? result = null)
|
||||
public Task<bool> ExecuteAsync(TB3761 tB3761, Action<dynamic>? result = null)
|
||||
{
|
||||
try
|
||||
{
|
||||
ArgumentNullException.ThrowIfNull(input);
|
||||
ArgumentNullException.ThrowIfNull(input.A.Code);
|
||||
ArgumentNullException.ThrowIfNull(tB3761);
|
||||
ArgumentNullException.ThrowIfNull(tB3761.A.Code);
|
||||
UnitDataAnalysis<string> dto = new UnitDataAnalysis<string>
|
||||
{
|
||||
Code = input.A.Code,
|
||||
AFN = input.AFN_FC.AFN,
|
||||
Fn = input.DT.Fn,
|
||||
Pn = input.DA.Pn,
|
||||
Data = $"退出登录帧",
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
Code = tB3761.A.Code,
|
||||
AFN = tB3761.AFN_FC.AFN,
|
||||
Fn = tB3761.DT.Fn,
|
||||
Pn = tB3761.DA.Pn,
|
||||
Data = $"退出登录帧"
|
||||
};
|
||||
result?.Invoke(dto);
|
||||
return Task.FromResult(true);
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
_logger.LogError(ex, $"02_2解析失败:{input.A.Code}-{input.DT.Fn}-{input.BaseHexMessage.HexMessageString},{ex.Message}");
|
||||
_logger.LogError(ex, $"02_2解析失败:{tB3761.A.Code}-{tB3761.DT.Fn}-{tB3761.BaseHexMessage.HexMessageString},{ex.Message}");
|
||||
}
|
||||
return Task.FromResult(false);
|
||||
}
|
||||
|
||||
@ -34,10 +34,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_02H
|
||||
AFN = input.AFN_FC.AFN,
|
||||
Fn = input.DT.Fn,
|
||||
Pn = input.DA.Pn,
|
||||
Data = $"心跳帧",
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
Data = $"心跳帧"
|
||||
};
|
||||
result?.Invoke(dto);
|
||||
return Task.FromResult(true);
|
||||
|
||||
@ -35,10 +35,7 @@ namespace JiShe.CollectBus.Protocol.AnalysisData.AFN_09H
|
||||
AFN = input.AFN_FC.AFN,
|
||||
Fn = input.DT.Fn,
|
||||
Pn = input.DA.Pn,
|
||||
Data = data,
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
Data = data
|
||||
};
|
||||
result?.Invoke(dto);
|
||||
return Task.FromResult(true);
|
||||
|
||||
@ -31,10 +31,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_09H
|
||||
AFN = input.AFN_FC.AFN,
|
||||
Fn = input.DT.Fn,
|
||||
Pn = input.DA.Pn,
|
||||
Data = Encoding.ASCII.GetString(string.Join("", input.UnitData.HexMessageList.Skip(30).Take(20).ToList()).HexToByte()).Replace("\0", ""), //SIM卡
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
Data = Encoding.ASCII.GetString(string.Join("", input.UnitData.HexMessageList.Skip(30).Take(20).ToList()).HexToByte()).Replace("\0", "") //SIM卡
|
||||
};
|
||||
result?.Invoke(dto);
|
||||
return Task.FromResult(true);
|
||||
|
||||
@ -35,10 +35,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0AH
|
||||
{
|
||||
AFN10F10Entitys = tuple.Item2,
|
||||
ConfigNum = tuple.Item1
|
||||
},
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
}
|
||||
};
|
||||
result?.Invoke(dto);
|
||||
return Task.FromResult(true);
|
||||
|
||||
@ -36,10 +36,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0AH
|
||||
AFN = input.AFN_FC.AFN,
|
||||
Fn = input.DT.Fn,
|
||||
Pn = input.DA.Pn,
|
||||
Data = data,
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
Data = data
|
||||
};
|
||||
result?.Invoke(dto);
|
||||
return await Task.FromResult(true);
|
||||
|
||||
@ -29,10 +29,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0AH
|
||||
AFN = input.AFN_FC.AFN,
|
||||
Fn = input.DT.Fn,
|
||||
Pn = input.DA.Pn,
|
||||
Data = input.UnitData.HexMessageList[4].Equals("55"),
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
Data = input.UnitData.HexMessageList[4].Equals("55")
|
||||
};
|
||||
result?.Invoke(dto);
|
||||
return Task.FromResult(true);
|
||||
|
||||
@ -39,9 +39,6 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0CH
|
||||
Pn = input.DA.Pn,
|
||||
MSA= input.A.A3.D1_D7,
|
||||
PSEQ= input.SEQ.PSEQ,
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
};
|
||||
List<string> datas = await AnalysisDataUnitAsync(input.UnitData.HexMessageList);
|
||||
List<AFN12_F129_AnalysisDto> list = GenerateFinalResult(2, datas, "正向有功电能示值", input.AFN_FC.AFN, input.DT.Fn);
|
||||
|
||||
@ -36,10 +36,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0CH
|
||||
AFN = input.AFN_FC.AFN,
|
||||
Fn = input.DT.Fn,
|
||||
Pn = input.DA.Pn,
|
||||
Data = list,
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
Data = list
|
||||
};
|
||||
result?.Invoke(unitDataAnalysis);
|
||||
return await Task.FromResult(true);
|
||||
|
||||
@ -35,10 +35,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0CH
|
||||
AFN = input.AFN_FC.AFN,
|
||||
Fn = input.DT.Fn,
|
||||
Pn = input.DA.Pn,
|
||||
Data = list,
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
Data = list
|
||||
};
|
||||
result?.Invoke(unitDataAnalysis);
|
||||
return await Task.FromResult(true);
|
||||
|
||||
@ -33,14 +33,11 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0CH
|
||||
List<AFN12_F132_AnalysisDto> list = GenerateFinalResult(2, datas, "反向无功电能示值", (int)input.AFN_FC.AFN!, (int)input.DT.Fn!);
|
||||
UnitDataAnalysis<List<AFN12_F132_AnalysisDto>> unitDataAnalysis = new UnitDataAnalysis<List<AFN12_F132_AnalysisDto>>
|
||||
{
|
||||
Code = input.A.Code!,
|
||||
Code = input.A.Code,
|
||||
AFN = input.AFN_FC.AFN,
|
||||
Fn = input.DT.Fn ,
|
||||
Pn = input.DA.Pn,
|
||||
Data = list,
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
Data = list
|
||||
};
|
||||
result?.Invoke(unitDataAnalysis);
|
||||
return await Task.FromResult(true);
|
||||
|
||||
@ -38,10 +38,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0CH
|
||||
AFN = input.AFN_FC.AFN,
|
||||
Fn = input.DT.Fn,
|
||||
Pn = input.DA.Pn,
|
||||
Data = data,
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
Data = data
|
||||
};
|
||||
result?.Invoke(unitDataAnalysis);
|
||||
return await Task.FromResult(true);
|
||||
|
||||
@ -60,8 +60,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AFN_0CH
|
||||
HexMessage=input.BaseHexMessage.HexMessageString,
|
||||
MessageId=input.MessageId,
|
||||
TimeDensity=1,
|
||||
DensityUnit = DensityUnit.Month,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
DensityUnit = DensityUnit.Month
|
||||
};
|
||||
await _dataStorage.SaveDataToIotDbAsync<decimal>(unitDataAnalysis);
|
||||
result?.Invoke(unitDataAnalysis);
|
||||
@ -137,11 +136,12 @@ namespace JiShe.CollectBus.Protocol.T37612012.AFN_0CH
|
||||
//TODO:时间标
|
||||
if (!DateTime.TryParse(timeSpan, out DateTime dataTime))
|
||||
dto.ValidData = false;
|
||||
dto.TimeSpan = dataTime;
|
||||
dto.DataTime = dataTime;
|
||||
}
|
||||
if (DateTime.Now.Month.Equals(1) && dto.TimeSpan.HasValue)//如果为1月份，则日期减去1年
|
||||
if (DateTime.Now.Month.Equals(1))//如果为1月份，则日期减去1年
|
||||
{
|
||||
dto.TimeSpan= dto.TimeSpan.Value.AddYears(-1);
|
||||
dto.DataTime = dto.DataTime.AddYears(-1);
|
||||
dto.TimeSpan= dto.DataTime;
|
||||
}
|
||||
|
||||
dto.FiledDesc = "上月（上一结算日）正向有功最大需量及发生时间";
|
||||
|
||||
@ -39,10 +39,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AFN_0CH
|
||||
AFN = input.AFN_FC.AFN,
|
||||
Fn = input.DT.Fn,
|
||||
Pn = input.DA.Pn,
|
||||
Data = data,
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
Data = data
|
||||
};
|
||||
result?.Invoke(dto);
|
||||
return await Task.FromResult(true);
|
||||
|
||||
@ -59,10 +59,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AFN_0CH
|
||||
AFN = input.AFN_FC.AFN,
|
||||
Fn = input.DT.Fn,
|
||||
Pn = input.DA.Pn,
|
||||
Data = list,
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
Data = list
|
||||
};
|
||||
result?.Invoke(unitDataAnalysis);
|
||||
return await Task.FromResult(true);
|
||||
|
||||
@ -37,10 +37,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AFN_0CH
|
||||
AFN = input.AFN_FC.AFN,
|
||||
Fn = input.DT.Fn,
|
||||
Pn = input.DA.Pn,
|
||||
Data = data,
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
Data = data
|
||||
};
|
||||
result?.Invoke(dto);
|
||||
return await Task.FromResult(true);
|
||||
|
||||
@ -39,10 +39,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AFN_0CH
|
||||
AFN = input.AFN_FC.AFN,
|
||||
Fn = input.DT.Fn,
|
||||
Pn = input.DA.Pn,
|
||||
Data = await AnalysisDataUnit(input.UnitData.HexMessageList, rationgCount),
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
Data = await AnalysisDataUnit(input.UnitData.HexMessageList, rationgCount)
|
||||
};
|
||||
result?.Invoke(unitDataAnalysis);
|
||||
return await Task.FromResult(true);
|
||||
|
||||
@ -58,10 +58,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AFN_0CH
|
||||
AFN = input.AFN_FC.AFN,
|
||||
Fn = input.DT.Fn,
|
||||
Pn = input.DA.Pn,
|
||||
Data= list,
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
Data= list
|
||||
};
|
||||
result?.Invoke(unitDataAnalysis);
|
||||
return await Task.FromResult(true);
|
||||
|
||||
@ -67,8 +67,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
TimeDensity = density,//密度-间隔分钟数,
|
||||
DensityUnit = DensityUnit.Minute,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
DensityUnit = DensityUnit.Minute
|
||||
};
|
||||
await _dataStorage.SaveMultipleDataToIotDbAsync<decimal>(unitDataAnalysis);
|
||||
result?.Invoke(unitDataAnalysis);
|
||||
|
||||
@ -64,8 +64,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
TimeDensity = density,//密度-间隔分钟数,
|
||||
DensityUnit = DensityUnit.Minute,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
DensityUnit = DensityUnit.Minute
|
||||
};
|
||||
await _dataStorage.SaveMultipleDataToIotDbAsync<decimal>(unitDataAnalysis);
|
||||
result?.Invoke(unitDataAnalysis);
|
||||
|
||||
@ -65,8 +65,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
TimeDensity = density,//密度-间隔分钟数,
|
||||
DensityUnit = DensityUnit.Minute,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
DensityUnit = DensityUnit.Minute
|
||||
};
|
||||
await _dataStorage.SaveMultipleDataToIotDbAsync<decimal>(unitDataAnalysis);
|
||||
result?.Invoke(unitDataAnalysis);
|
||||
|
||||
@ -65,8 +65,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
TimeDensity = density,//密度-间隔分钟数,
|
||||
DensityUnit = DensityUnit.Minute,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
DensityUnit = DensityUnit.Minute
|
||||
};
|
||||
await _dataStorage.SaveMultipleDataToIotDbAsync<decimal>(unitDataAnalysis);
|
||||
result?.Invoke(unitDataAnalysis);
|
||||
|
||||
@ -65,8 +65,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
TimeDensity = density,//密度-间隔分钟数,
|
||||
DensityUnit = DensityUnit.Minute,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
DensityUnit = DensityUnit.Minute
|
||||
};
|
||||
await _dataStorage.SaveMultipleDataToIotDbAsync<decimal>(unitDataAnalysis);
|
||||
result?.Invoke(unitDataAnalysis);
|
||||
|
||||
@ -65,8 +65,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
TimeDensity = density,//密度-间隔分钟数,
|
||||
DensityUnit = DensityUnit.Minute,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
DensityUnit = DensityUnit.Minute
|
||||
};
|
||||
await _dataStorage.SaveMultipleDataToIotDbAsync<decimal>(unitDataAnalysis);
|
||||
result?.Invoke(unitDataAnalysis);
|
||||
|
||||
@ -65,8 +65,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
TimeDensity = density,//密度-间隔分钟数,
|
||||
DensityUnit = DensityUnit.Minute,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
DensityUnit = DensityUnit.Minute
|
||||
};
|
||||
await _dataStorage.SaveMultipleDataToIotDbAsync<decimal>(unitDataAnalysis);
|
||||
result?.Invoke(unitDataAnalysis);
|
||||
|
||||
@ -64,8 +64,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
TimeDensity = density,//密度-间隔分钟数,
|
||||
DensityUnit = DensityUnit.Minute,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
DensityUnit = DensityUnit.Minute
|
||||
};
|
||||
await _dataStorage.SaveMultipleDataToIotDbAsync<decimal>(unitDataAnalysis);
|
||||
result?.Invoke(unitDataAnalysis);
|
||||
|
||||
@ -65,8 +65,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
TimeDensity = density,//密度-间隔分钟数,
|
||||
DensityUnit = DensityUnit.Minute,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
DensityUnit = DensityUnit.Minute
|
||||
};
|
||||
await _dataStorage.SaveMultipleDataToIotDbAsync<decimal>(unitDataAnalysis);
|
||||
result?.Invoke(unitDataAnalysis);
|
||||
|
||||
@ -64,8 +64,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
TimeDensity = 1,//密度-间隔,
|
||||
DensityUnit = DensityUnit.Day,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
DensityUnit = DensityUnit.Day
|
||||
};
|
||||
await _dataStorage.SaveMultipleDataToIotDbAsync<decimal>(unitDataAnalysis);
|
||||
result?.Invoke(unitDataAnalysis);
|
||||
|
||||
@ -64,8 +64,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
TimeDensity = density,//密度-间隔分钟数,
|
||||
DensityUnit = DensityUnit.Minute,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
DensityUnit = DensityUnit.Minute
|
||||
};
|
||||
await _dataStorage.SaveMultipleDataToIotDbAsync<decimal>(unitDataAnalysis);
|
||||
result?.Invoke(unitDataAnalysis);
|
||||
|
||||
@ -64,8 +64,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
TimeDensity = density,//密度-间隔分钟数,
|
||||
DensityUnit = DensityUnit.Minute,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
DensityUnit = DensityUnit.Minute
|
||||
};
|
||||
await _dataStorage.SaveMultipleDataToIotDbAsync<decimal>(unitDataAnalysis);
|
||||
result?.Invoke(unitDataAnalysis);
|
||||
|
||||
@ -64,8 +64,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
TimeDensity = density,//密度-间隔分钟数,
|
||||
DensityUnit = DensityUnit.Minute,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
DensityUnit = DensityUnit.Minute
|
||||
};
|
||||
await _dataStorage.SaveMultipleDataToIotDbAsync<decimal>(unitDataAnalysis);
|
||||
result?.Invoke(unitDataAnalysis);
|
||||
|
||||
@ -65,8 +65,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
TimeDensity = density,//密度-间隔分钟数,
|
||||
DensityUnit = DensityUnit.Minute,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
DensityUnit = DensityUnit.Minute
|
||||
};
|
||||
await _dataStorage.SaveMultipleDataToIotDbAsync<decimal>(unitDataAnalysis);
|
||||
result?.Invoke(unitDataAnalysis);
|
||||
|
||||
@ -65,8 +65,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
TimeDensity = 1,//密度-间隔,
|
||||
DensityUnit = DensityUnit.Day,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
DensityUnit = DensityUnit.Day
|
||||
};
|
||||
await _dataStorage.SaveMultipleDataToIotDbAsync<decimal>(unitDataAnalysis);
|
||||
result?.Invoke(unitDataAnalysis);
|
||||
|
||||
@ -64,8 +64,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
TimeDensity = 1,//密度-间隔,
|
||||
DensityUnit = DensityUnit.Day,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
DensityUnit = DensityUnit.Day
|
||||
};
|
||||
await _dataStorage.SaveMultipleDataToIotDbAsync<decimal>(unitDataAnalysis);
|
||||
result?.Invoke(unitDataAnalysis);
|
||||
|
||||
@ -65,8 +65,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
TimeDensity = 1,//密度-间隔,
|
||||
DensityUnit = DensityUnit.Day,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
DensityUnit = DensityUnit.Day
|
||||
};
|
||||
await _dataStorage.SaveMultipleDataToIotDbAsync<decimal>(unitDataAnalysis);
|
||||
result?.Invoke(unitDataAnalysis);
|
||||
|
||||
@ -64,8 +64,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
TimeDensity = 1,//密度-间隔,
|
||||
DensityUnit = DensityUnit.Day,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
DensityUnit = DensityUnit.Day
|
||||
};
|
||||
await _dataStorage.SaveMultipleDataToIotDbAsync<decimal>(unitDataAnalysis);
|
||||
result?.Invoke(unitDataAnalysis);
|
||||
|
||||
@ -64,8 +64,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
TimeDensity = 1,//密度-间隔,
|
||||
DensityUnit = DensityUnit.Day,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
DensityUnit = DensityUnit.Day
|
||||
};
|
||||
await _dataStorage.SaveMultipleDataToIotDbAsync<decimal>(unitDataAnalysis);
|
||||
result?.Invoke(unitDataAnalysis);
|
||||
|
||||
@ -64,8 +64,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
TimeDensity = 1,//密度-间隔,
|
||||
DensityUnit = DensityUnit.Day,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
DensityUnit = DensityUnit.Day
|
||||
};
|
||||
await _dataStorage.SaveMultipleDataToIotDbAsync<decimal>(unitDataAnalysis);
|
||||
result?.Invoke(unitDataAnalysis);
|
||||
|
||||
@ -64,8 +64,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
TimeDensity = 1,//密度-间隔,
|
||||
DensityUnit = DensityUnit.Day,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
DensityUnit = DensityUnit.Day
|
||||
};
|
||||
await _dataStorage.SaveMultipleDataToIotDbAsync<decimal>(unitDataAnalysis);
|
||||
result?.Invoke(unitDataAnalysis);
|
||||
|
||||
@ -64,8 +64,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
TimeDensity = 1,//密度-间隔,
|
||||
DensityUnit = DensityUnit.Day,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
DensityUnit = DensityUnit.Day
|
||||
};
|
||||
await _dataStorage.SaveMultipleDataToIotDbAsync<decimal>(unitDataAnalysis);
|
||||
result?.Invoke(unitDataAnalysis);
|
||||
|
||||
@ -63,8 +63,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
TimeDensity = 1,//密度-间隔,
|
||||
DensityUnit = DensityUnit.Month,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
DensityUnit = DensityUnit.Month
|
||||
};
|
||||
await _dataStorage.SaveMultipleDataToIotDbAsync<decimal>(unitDataAnalysis);
|
||||
result?.Invoke(unitDataAnalysis);
|
||||
|
||||
@ -64,8 +64,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
TimeDensity = 1,//密度-间隔,
|
||||
DensityUnit = DensityUnit.Month,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
DensityUnit = DensityUnit.Month
|
||||
};
|
||||
await _dataStorage.SaveMultipleDataToIotDbAsync<decimal>(unitDataAnalysis);
|
||||
result?.Invoke(unitDataAnalysis);
|
||||
|
||||
@ -64,8 +64,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
TimeDensity = 1,//密度-间隔,
|
||||
DensityUnit = DensityUnit.Month,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
DensityUnit = DensityUnit.Month
|
||||
};
|
||||
await _dataStorage.SaveMultipleDataToIotDbAsync<decimal>(unitDataAnalysis);
|
||||
result?.Invoke(unitDataAnalysis);
|
||||
|
||||
@ -63,8 +63,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
TimeDensity = 1,//密度-间隔,
|
||||
DensityUnit = DensityUnit.Month,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
DensityUnit = DensityUnit.Month
|
||||
};
|
||||
await _dataStorage.SaveMultipleDataToIotDbAsync<decimal>(unitDataAnalysis);
|
||||
result?.Invoke(unitDataAnalysis);
|
||||
|
||||
@ -64,8 +64,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
TimeDensity = 1,//密度-间隔,
|
||||
DensityUnit = DensityUnit.Month,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
DensityUnit = DensityUnit.Month
|
||||
};
|
||||
await _dataStorage.SaveMultipleDataToIotDbAsync<decimal>(unitDataAnalysis);
|
||||
result?.Invoke(unitDataAnalysis);
|
||||
|
||||
@ -64,8 +64,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
TimeDensity = 1,//密度-间隔,
|
||||
DensityUnit = DensityUnit.Month,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
DensityUnit = DensityUnit.Month
|
||||
};
|
||||
await _dataStorage.SaveMultipleDataToIotDbAsync<decimal>(unitDataAnalysis);
|
||||
result?.Invoke(unitDataAnalysis);
|
||||
|
||||
@ -63,8 +63,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
TimeDensity = 1,//密度-间隔,
|
||||
DensityUnit = DensityUnit.Month,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
DensityUnit = DensityUnit.Month
|
||||
};
|
||||
await _dataStorage.SaveMultipleDataToIotDbAsync<decimal>(unitDataAnalysis);
|
||||
result?.Invoke(unitDataAnalysis);
|
||||
|
||||
@ -64,8 +64,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
TimeDensity = 1,//密度-间隔,
|
||||
DensityUnit = DensityUnit.Month,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
DensityUnit = DensityUnit.Month
|
||||
};
|
||||
await _dataStorage.SaveMultipleDataToIotDbAsync<decimal>(unitDataAnalysis);
|
||||
result?.Invoke(unitDataAnalysis);
|
||||
|
||||
@ -65,8 +65,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
TimeDensity = 1,//密度-间隔,
|
||||
DensityUnit = DensityUnit.Day,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
DensityUnit = DensityUnit.Day
|
||||
};
|
||||
await _dataStorage.SaveMultipleDataToIotDbAsync<decimal>(unitDataAnalysis);
|
||||
result?.Invoke(unitDataAnalysis);
|
||||
|
||||
@ -59,8 +59,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
TimeDensity = 1,//密度-间隔,
|
||||
DensityUnit = DensityUnit.Day,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
DensityUnit = DensityUnit.Day
|
||||
};
|
||||
await _dataStorage.SaveDataToIotDbAsync<decimal>(unitDataAnalysis);
|
||||
result?.Invoke(unitDataAnalysis);
|
||||
|
||||
@ -59,8 +59,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
TimeDensity = 1,//密度-间隔,
|
||||
DensityUnit = DensityUnit.Month,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
DensityUnit = DensityUnit.Month
|
||||
};
|
||||
await _dataStorage.SaveDataToIotDbAsync<decimal>(unitDataAnalysis);
|
||||
result?.Invoke(unitDataAnalysis);
|
||||
|
||||
@ -59,8 +59,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
TimeDensity = 1,//密度-间隔,
|
||||
DensityUnit = DensityUnit.Month,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
DensityUnit = DensityUnit.Month
|
||||
};
|
||||
await _dataStorage.SaveDataToIotDbAsync<decimal>(unitDataAnalysis);
|
||||
result?.Invoke(unitDataAnalysis);
|
||||
|
||||
@ -65,8 +65,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
TimeDensity = 1,//密度-间隔,
|
||||
DensityUnit = DensityUnit.Day,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
DensityUnit = DensityUnit.Day
|
||||
};
|
||||
await _dataStorage.SaveMultipleDataToIotDbAsync<decimal>(unitDataAnalysis);
|
||||
result?.Invoke(unitDataAnalysis);
|
||||
|
||||
@ -69,8 +69,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
TimeDensity = 1,//密度-间隔,
|
||||
DensityUnit = DensityUnit.Day,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
DensityUnit = DensityUnit.Day
|
||||
};
|
||||
await _dataStorage.SaveMultipleDataToIotDbAsync<decimal>(unitDataAnalysis);
|
||||
result?.Invoke(unitDataAnalysis);
|
||||
|
||||
@ -68,8 +68,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
TimeDensity = 1,//密度-间隔,
|
||||
DensityUnit = DensityUnit.Day,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
DensityUnit = DensityUnit.Day
|
||||
};
|
||||
await _dataStorage.SaveMultipleDataToIotDbAsync<decimal>(unitDataAnalysis);
|
||||
result?.Invoke(unitDataAnalysis);
|
||||
|
||||
@ -65,8 +65,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
TimeDensity = density,//密度-间隔分钟数,
|
||||
DensityUnit = DensityUnit.Minute,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
DensityUnit = DensityUnit.Minute
|
||||
};
|
||||
await _dataStorage.SaveMultipleDataToIotDbAsync<decimal>(unitDataAnalysis);
|
||||
result?.Invoke(unitDataAnalysis);
|
||||
|
||||
@ -66,8 +66,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
TimeDensity = density,//密度-间隔分钟数,
|
||||
DensityUnit = DensityUnit.Minute,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
DensityUnit = DensityUnit.Minute
|
||||
};
|
||||
await _dataStorage.SaveMultipleDataToIotDbAsync<decimal>(unitDataAnalysis);
|
||||
result?.Invoke(unitDataAnalysis);
|
||||
|
||||
@ -66,8 +66,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
TimeDensity = density,//密度-间隔分钟数,
|
||||
DensityUnit = DensityUnit.Minute,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
DensityUnit = DensityUnit.Minute
|
||||
};
|
||||
await _dataStorage.SaveMultipleDataToIotDbAsync<decimal>(unitDataAnalysis);
|
||||
result?.Invoke(unitDataAnalysis);
|
||||
|
||||
@ -65,8 +65,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
TimeDensity = density,//密度-间隔分钟数,
|
||||
DensityUnit = DensityUnit.Minute,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
DensityUnit = DensityUnit.Minute
|
||||
};
|
||||
await _dataStorage.SaveMultipleDataToIotDbAsync<decimal>(unitDataAnalysis);
|
||||
result?.Invoke(unitDataAnalysis);
|
||||
|
||||
@ -66,8 +66,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
TimeDensity = density,//密度-间隔分钟数,
|
||||
DensityUnit = DensityUnit.Minute,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
DensityUnit = DensityUnit.Minute
|
||||
};
|
||||
await _dataStorage.SaveMultipleDataToIotDbAsync<decimal>(unitDataAnalysis);
|
||||
result?.Invoke(unitDataAnalysis);
|
||||
|
||||
@ -66,8 +66,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
TimeDensity = density,//密度-间隔分钟数,
|
||||
DensityUnit = DensityUnit.Minute,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
DensityUnit = DensityUnit.Minute
|
||||
};
|
||||
await _dataStorage.SaveMultipleDataToIotDbAsync<decimal>(unitDataAnalysis);
|
||||
result?.Invoke(unitDataAnalysis);
|
||||
|
||||
@ -65,8 +65,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
TimeDensity = density,//密度-间隔分钟数,
|
||||
DensityUnit = DensityUnit.Minute,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
DensityUnit = DensityUnit.Minute
|
||||
};
|
||||
await _dataStorage.SaveMultipleDataToIotDbAsync<decimal>(unitDataAnalysis);
|
||||
result?.Invoke(unitDataAnalysis);
|
||||
|
||||
@ -66,8 +66,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
TimeDensity = density,//密度-间隔分钟数,
|
||||
DensityUnit = DensityUnit.Minute,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
DensityUnit = DensityUnit.Minute
|
||||
};
|
||||
await _dataStorage.SaveMultipleDataToIotDbAsync<decimal>(unitDataAnalysis);
|
||||
result?.Invoke(unitDataAnalysis);
|
||||
|
||||
@ -66,8 +66,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
TimeDensity = density,//密度-间隔分钟数,
|
||||
DensityUnit = DensityUnit.Minute,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
DensityUnit = DensityUnit.Minute
|
||||
};
|
||||
await _dataStorage.SaveMultipleDataToIotDbAsync<decimal>(unitDataAnalysis);
|
||||
result?.Invoke(unitDataAnalysis);
|
||||
|
||||
@ -66,8 +66,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
TimeDensity = density,//密度-间隔分钟数,
|
||||
DensityUnit = DensityUnit.Minute,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
DensityUnit = DensityUnit.Minute
|
||||
};
|
||||
await _dataStorage.SaveMultipleDataToIotDbAsync<decimal>(unitDataAnalysis);
|
||||
result?.Invoke(unitDataAnalysis);
|
||||
|
||||
@ -65,8 +65,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
TimeDensity = density,//密度-间隔分钟数,
|
||||
DensityUnit = DensityUnit.Minute,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
DensityUnit = DensityUnit.Minute
|
||||
};
|
||||
await _dataStorage.SaveMultipleDataToIotDbAsync<decimal>(unitDataAnalysis);
|
||||
result?.Invoke(unitDataAnalysis);
|
||||
|
||||
@ -66,8 +66,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
TimeDensity = density,//密度-间隔分钟数,
|
||||
DensityUnit = DensityUnit.Minute,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
DensityUnit = DensityUnit.Minute
|
||||
};
|
||||
await _dataStorage.SaveMultipleDataToIotDbAsync<decimal>(unitDataAnalysis);
|
||||
result?.Invoke(unitDataAnalysis);
|
||||
|
||||
@ -66,8 +66,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
TimeDensity = density,//密度-间隔分钟数,
|
||||
DensityUnit = DensityUnit.Minute,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
DensityUnit = DensityUnit.Minute
|
||||
};
|
||||
await _dataStorage.SaveMultipleDataToIotDbAsync<decimal>(unitDataAnalysis);
|
||||
result?.Invoke(unitDataAnalysis);
|
||||
|
||||
@ -66,8 +66,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
TimeDensity = density,//密度-间隔分钟数,
|
||||
DensityUnit = DensityUnit.Minute,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
DensityUnit = DensityUnit.Minute
|
||||
};
|
||||
await _dataStorage.SaveMultipleDataToIotDbAsync<decimal>(unitDataAnalysis);
|
||||
result?.Invoke(unitDataAnalysis);
|
||||
|
||||
@ -66,8 +66,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
TimeDensity = density,//密度-间隔分钟数,
|
||||
DensityUnit = DensityUnit.Minute,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
DensityUnit = DensityUnit.Minute
|
||||
};
|
||||
await _dataStorage.SaveMultipleDataToIotDbAsync<decimal>(unitDataAnalysis);
|
||||
result?.Invoke(unitDataAnalysis);
|
||||
|
||||
@ -66,8 +66,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
TimeDensity = density,//密度-间隔分钟数,
|
||||
DensityUnit = DensityUnit.Minute,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
DensityUnit = DensityUnit.Minute
|
||||
};
|
||||
await _dataStorage.SaveMultipleDataToIotDbAsync<decimal>(unitDataAnalysis);
|
||||
result?.Invoke(unitDataAnalysis);
|
||||
|
||||
@ -66,8 +66,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
TimeDensity = density,//密度-间隔分钟数,
|
||||
DensityUnit = DensityUnit.Minute,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
DensityUnit = DensityUnit.Minute
|
||||
};
|
||||
await _dataStorage.SaveMultipleDataToIotDbAsync<decimal>(unitDataAnalysis);
|
||||
result?.Invoke(unitDataAnalysis);
|
||||
|
||||
@ -66,8 +66,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
TimeDensity = density,//密度-间隔分钟数,
|
||||
DensityUnit = DensityUnit.Minute,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
DensityUnit = DensityUnit.Minute
|
||||
};
|
||||
await _dataStorage.SaveMultipleDataToIotDbAsync<decimal>(unitDataAnalysis);
|
||||
result?.Invoke(unitDataAnalysis);
|
||||
|
||||
@ -20,13 +20,13 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0EH
|
||||
_logger = logger;
|
||||
}
|
||||
|
||||
public Task<bool> ExecuteAsync(TB3761 input, Action<dynamic>? result = null)
|
||||
public Task<bool> ExecuteAsync(TB3761 tB3761, Action<dynamic>? result = null)
|
||||
{
|
||||
try
|
||||
{
|
||||
ArgumentNullException.ThrowIfNull(nameof(input));
|
||||
ArgumentNullException.ThrowIfNull(nameof(input.UnitData.HexMessageList));
|
||||
int erc = input.UnitData.HexMessageList![8].HexToDec();
|
||||
ArgumentNullException.ThrowIfNull(nameof(tB3761));
|
||||
ArgumentNullException.ThrowIfNull(nameof(tB3761.UnitData.HexMessageList));
|
||||
int erc = tB3761.UnitData.HexMessageList![8].HexToDec();
|
||||
bool isOnOffPower = erc.Equals(14) ? true : false;
|
||||
if (!isOnOffPower)
|
||||
{
|
||||
@ -34,14 +34,11 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0EH
|
||||
}
|
||||
UnitDataAnalysis<Tuple<string, string>> dto = new UnitDataAnalysis<Tuple<string, string>>
|
||||
{
|
||||
Code = input.A.Code!,
|
||||
AFN = input.AFN_FC.AFN,
|
||||
Fn = input.DT.Fn,
|
||||
Pn = input.DA.Pn,
|
||||
Data = AnalysisDataUnit(input.UnitData.HexMessageList),
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
Code = tB3761.A.Code!,
|
||||
AFN = tB3761.AFN_FC.AFN,
|
||||
Fn = tB3761.DT.Fn,
|
||||
Pn = tB3761.DA.Pn,
|
||||
Data = AnalysisDataUnit(tB3761.UnitData.HexMessageList)
|
||||
};
|
||||
// meterData.DataType = "0E_1";
|
||||
result?.Invoke(dto);
|
||||
@ -49,7 +46,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0EH
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
_logger.LogError(ex, $"0E_1解析失败:{input.A.Code}-{input.DT.Fn}-{input.BaseHexMessage.HexMessageString},{ex.Message}");
|
||||
_logger.LogError(ex, $"0E_1解析失败:{tB3761.A.Code}-{tB3761.DT.Fn}-{tB3761.BaseHexMessage.HexMessageString},{ex.Message}");
|
||||
}
|
||||
return Task.FromResult(false);
|
||||
}
|
||||
|
||||
@ -30,10 +30,7 @@ namespace GatherService.WattMeter.AnalysisData.AFN_10H
|
||||
AFN = input.AFN_FC.AFN,
|
||||
Fn = input.DT.Fn,
|
||||
Pn = input.DA.Pn,
|
||||
Data = AnalysisDataUnit(input.UnitData.HexMessageList), //SIM卡
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
Data = AnalysisDataUnit(input.UnitData.HexMessageList) //SIM卡
|
||||
};
|
||||
result?.Invoke(dto);
|
||||
return Task.FromResult(true);
|
||||
|
||||
@ -38,10 +38,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_10H
|
||||
AFN = input.AFN_FC.AFN,
|
||||
Fn = input.DT.Fn,
|
||||
Pn = input.DA.Pn,
|
||||
Data = AnalysisDataUnit(input.UnitData.HexMessageList),
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
Data = AnalysisDataUnit(input.UnitData.HexMessageList)
|
||||
};
|
||||
result?.Invoke(dto);
|
||||
return Task.FromResult(true);
|
||||
|
||||
@ -55,8 +55,7 @@ namespace GatherService.WattMeter.AnalysisData.AFN_10H
|
||||
HexMessage = input.BaseHexMessage.HexMessageString,
|
||||
MessageId = input.MessageId,
|
||||
TimeDensity = 1,//密度-间隔分钟数,
|
||||
DensityUnit = DensityUnit.Second,
|
||||
ReceivedTime = input.ReceivedTime
|
||||
DensityUnit = DensityUnit.Second
|
||||
};
|
||||
//await _dataStorage.SaveDataToIotDbAsync<decimal>(unitDataAnalysis);
|
||||
result?.Invoke(unitDataAnalysis);
|
||||
|
||||
@ -54,8 +54,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData
|
||||
public async Task<bool> SaveDataToIotDbAsync<T>(UnitDataAnalysis<AnalysisBaseDto<T>> analysisBaseDto)
|
||||
{
|
||||
var data = analysisBaseDto.Data!;
|
||||
if(!data.TimeSpan.HasValue)
|
||||
data.TimeSpan= analysisBaseDto.ReceivedTime;
|
||||
|
||||
string taskMark = CommonHelper.GetTaskMark(analysisBaseDto.AFN, analysisBaseDto.Fn, analysisBaseDto.Pn, analysisBaseDto.MSA, analysisBaseDto.PSEQ);
|
||||
string scoreValue = $"{analysisBaseDto.Code}.{taskMark}".Md5Fun();
|
||||
|
||||
@ -87,7 +86,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData
|
||||
DeviceId = $"{data.MeterId}",
|
||||
DeviceType = $"{data.MeterType}",
|
||||
ProjectId = $"{data.ProjectId}",
|
||||
Timestamps = data.TimeSpan!.Value.GetDateTimeOffset().ToUnixTimeMilliseconds(), // TODO:这里暂时格式化15分钟数据，需要进行调整
|
||||
Timestamps = data.TimeSpan.GetDateTimeOffset().ToUnixTimeMilliseconds(),
|
||||
SingleMeasuring = new Tuple<string, T>(data.FiledName ?? string.Empty, data.DataValue ?? default)
|
||||
};
|
||||
_runtimeContext.UseTableSessionPool = true; // 使用表模型池
|
||||
@ -111,9 +110,9 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData
|
||||
ProjectId = $"{data.ProjectId}",
|
||||
DeviceType = $"{data.MeterType}",
|
||||
DeviceId = $"{data.MeterId}",
|
||||
Timestamps = DateTime.Now.GetDateTimeOffset().ToUnixTimeNanoseconds(),
|
||||
Timestamps = DateTime.Now.CheckTimePoint().GetDateTimeOffset().ToUnixTimeNanoseconds(),
|
||||
DatabaseBusiID = data.DatabaseBusiID,
|
||||
PendingCopyReadTime = data.TimeSpan.Value.CheckTimePoint(), // // TODO:这里暂时格式化15分钟数据，需要进行调整
|
||||
PendingCopyReadTime = data.DataTime.CheckTimePoint(),
|
||||
CreationTime = currentTime,
|
||||
MeterAddress = data.MeterAddress,
|
||||
AFN = analysisBaseDto.AFN,
|
||||
@ -155,8 +154,6 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData
|
||||
var data = analysisBaseDto.Data!;
|
||||
foreach (var item in data)
|
||||
{
|
||||
if(!item.TimeSpan.HasValue)
|
||||
item.TimeSpan = analysisBaseDto.ReceivedTime;
|
||||
string taskMark = CommonHelper.GetTaskMark(analysisBaseDto.AFN, analysisBaseDto.Fn, analysisBaseDto.Pn, analysisBaseDto.MSA, analysisBaseDto.PSEQ);
|
||||
string scoreValue = $"{analysisBaseDto.Code}.{taskMark}".Md5Fun();
|
||||
|
||||
@ -188,7 +185,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData
|
||||
DeviceId = $"{item.MeterId}",
|
||||
DeviceType = $"{item.MeterType}",
|
||||
ProjectId = $"{item.ProjectId}",
|
||||
Timestamps = item.TimeSpan!.Value.CheckTimePoint().GetDateTimeOffset().ToUnixTimeMilliseconds(), // TODO:这里暂时格式化15分钟数据，需要进行调整
|
||||
Timestamps = item.TimeSpan.GetDateTimeOffset().ToUnixTimeMilliseconds(),
|
||||
SingleMeasuring = new Tuple<string, T>(item.FiledName ?? string.Empty, item.DataValue ?? default)
|
||||
};
|
||||
_runtimeContext.UseTableSessionPool = true; // 使用表模型池
|
||||
@ -214,7 +211,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData
|
||||
DeviceId = $"{item.MeterId}",
|
||||
Timestamps = DateTime.Now.CheckTimePoint().GetDateTimeOffset().ToUnixTimeNanoseconds(),
|
||||
DatabaseBusiID = item.DatabaseBusiID,
|
||||
PendingCopyReadTime = item.TimeSpan.Value.CheckTimePoint(), // TODO:这里暂时格式化15分钟数据，需要进行调整
|
||||
PendingCopyReadTime = item.DataTime.CheckTimePoint(),
|
||||
CreationTime = currentTime,
|
||||
MeterAddress = item.MeterAddress,
|
||||
AFN = analysisBaseDto.AFN,
|
||||
|
||||
@ -144,11 +144,6 @@ namespace JiShe.CollectBus.Protocol.T37612012
|
||||
return DateTime.Parse(dataTime);
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
/// 判断当前时间所在时标(5分钟)
|
||||
/// </summary>
|
||||
/// <param name="curTime"></param>
|
||||
/// <returns></returns>
|
||||
public static DateTime CheckTimeFivePoint(this DateTime curTime)
|
||||
{
|
||||
string dataTime;
|
||||
|
||||
@ -117,7 +117,6 @@ namespace JiShe.CollectBus.Protocol.T37612012
|
||||
//TODO：根据AFN进行分流推送到kafka
|
||||
string topicName = string.Format(ProtocolConst.AFNTopicNameFormat, tB3761.AFN_FC.AFN.ToString().PadLeft(2, '0'));
|
||||
tB3761.MessageId = Guid.NewGuid().ToString();
|
||||
tB3761.ReceivedTime = DateTime.Now;
|
||||
MessageProtocolAnalysis<TB3761> messageReceivedAnalysis = new MessageProtocolAnalysis<TB3761>()
|
||||
{
|
||||
ClientId = tcpSessionClient.Id,
|
||||
@ -126,7 +125,7 @@ namespace JiShe.CollectBus.Protocol.T37612012
|
||||
MessageHexString = tB3761.BaseHexMessage.HexMessageString!,
|
||||
DeviceNo = tB3761.A.Code!,
|
||||
MessageId = tB3761.MessageId,
|
||||
ReceivedTime = tB3761.ReceivedTime.ToString("yyyy-MM-dd HH:mm:ss"),
|
||||
ReceivedTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"),
|
||||
Data = tB3761
|
||||
};
|
||||
|
||||
|
||||
@ -73,8 +73,6 @@ namespace JiShe.CollectBus.Plugins
|
||||
// TODO: 暂时不处理，后续再处理
|
||||
_logger.LogError($"指令初步解析失败，指令内容：{messageHexString}");
|
||||
}
|
||||
|
||||
// TODO：要注意保存树模型的时时标字段，如果没有时标,则取接受时间做兼容
|
||||
await e.InvokeNext();
|
||||
}
|
||||
|
||||
|
||||
@ -147,7 +147,6 @@ namespace JiShe.CollectBus.Subscribers
|
||||
await executor.ExecuteAsync<TB3761>(serverName, receivedMessage.Data, (result) =>
|
||||
{
|
||||
var ssss = (UnitDataAnalysis<string>)result;
|
||||
_logger.LogInformation($"解析AFN02H数据：{ssss.Serialize()}");
|
||||
});
|
||||
return SubscribeAck.Success();
|
||||
}
|
||||
|
||||
@ -39,7 +39,12 @@ namespace JiShe.CollectBus.Protocol.Contracts.Protocol.Dto
|
||||
/// <summary>
|
||||
/// 数据时标
|
||||
/// </summary>
|
||||
public DateTime? TimeSpan { get; set; }
|
||||
public DateTime TimeSpan { get; set; }
|
||||
|
||||
/// <summary>
|
||||
/// 数据时间
|
||||
/// </summary>
|
||||
public DateTime DataTime { get; set; }
|
||||
|
||||
/// <summary>
|
||||
/// 项目Id
|
||||
|
||||
@ -1,5 +1,4 @@
|
||||
using JiShe.CollectBus.Common.Enums;
|
||||
using System;
|
||||
|
||||
namespace JiShe.CollectBus.Protocol.Dto
|
||||
{
|
||||
@ -45,11 +44,6 @@ namespace JiShe.CollectBus.Protocol.Dto
|
||||
/// </summary>
|
||||
public string? MessageId { get; set; }
|
||||
|
||||
/// <summary>
|
||||
/// 消息时间
|
||||
/// </summary>
|
||||
public DateTime? ReceivedTime { get; set; }
|
||||
|
||||
/// <summary>
|
||||
/// 采集密度
|
||||
/// </summary>
|
||||
|
||||
@ -22,11 +22,6 @@ namespace JiShe.CollectBus.Protocol3761
|
||||
/// </summary>
|
||||
public string? MessageId { get; set; }
|
||||
|
||||
/// <summary>
|
||||
/// 消息时间
|
||||
/// </summary>
|
||||
public DateTime ReceivedTime { get; set; }=DateTime.Now;
|
||||
|
||||
/// <summary>
|
||||
/// 控制域C
|
||||
/// </summary>
|
||||
|
||||
@ -16,7 +16,6 @@
|
||||
<meta name="viewport" content="width=device-width, initial-scale=1.0" />
|
||||
<link href="libs/bootstrap/css/bootstrap.min.css" rel="stylesheet" />
|
||||
<title>后端服务</title>
|
||||
|
||||
</head>
|
||||
|
||||
<body>
|
||||
|
||||
@ -80,7 +80,7 @@
|
||||
"SaslPassword": "lixiao1980",
|
||||
"KafkaReplicationFactor": 3,
|
||||
"NumPartitions": 30,
|
||||
"ServerTagName": "JiSheCollectBus4",
|
||||
"ServerTagName": "JiSheCollectBus99",
|
||||
"FirstCollectionTime": "2025-04-22 16:07:00"
|
||||
},
|
||||
"IoTDBOptions": {
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user