From 0de5177472b36c76408d8b03d8cf4bb8cb4b8425 Mon Sep 17 00:00:00 2001
From: zenghongyao <873884283@qq.com>
Date: Thu, 8 May 2025 09:25:17 +0800
Subject: [PATCH 1/8] =?UTF-8?q?=E7=BB=9F=E4=B8=80=E8=A7=A3=E6=9E=90?=
=?UTF-8?q?=E5=AD=97=E6=AE=B5=E5=90=8D=E7=A7=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
.../JiShe.CollectBus.Domain/Protocol3761/Dto/AnalysisBaseDto.cs | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/services/JiShe.CollectBus.Domain/Protocol3761/Dto/AnalysisBaseDto.cs b/services/JiShe.CollectBus.Domain/Protocol3761/Dto/AnalysisBaseDto.cs
index c6026d6..c6f7fae 100644
--- a/services/JiShe.CollectBus.Domain/Protocol3761/Dto/AnalysisBaseDto.cs
+++ b/services/JiShe.CollectBus.Domain/Protocol3761/Dto/AnalysisBaseDto.cs
@@ -65,7 +65,7 @@ namespace JiShe.CollectBus.Protocol.Contracts.Protocol.Dto
///
/// 表地址
///
- public string MeterAddress { get; set; } = null!;
+ public string DeviceAddress { get; set; } = null!;
}
From 7a18dc4df9dd1cd333b58d98a36100f2860f09e6 Mon Sep 17 00:00:00 2001
From: zenghongyao <873884283@qq.com>
Date: Thu, 8 May 2025 09:25:41 +0800
Subject: [PATCH 2/8] =?UTF-8?q?=E7=BB=9F=E4=B8=80=E5=AD=97=E6=AE=B5?=
=?UTF-8?q?=E5=90=8D=E7=A7=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
.../AnalysisData/AFN_02H/AFN2_F1_Analysis.cs | 2 +-
.../AnalysisData/AFN_02H/AFN2_F2_Analysis.cs | 2 +-
.../AnalysisData/AFN_02H/AFN2_F3_Analysis.cs | 2 +-
.../AFN_0CH/AFN12_F149_Analysis.cs | 2 +-
.../AFN_0DH/AFN13_F100_Analysis.cs | 2 +-
.../AFN_0DH/AFN13_F101_Analysis.cs | 2 +-
.../AFN_0DH/AFN13_F102_Analysis.cs | 2 +-
.../AFN_0DH/AFN13_F103_Analysis.cs | 2 +-
.../AFN_0DH/AFN13_F104_Analysis.cs | 2 +-
.../AFN_0DH/AFN13_F105_Analysis.cs | 2 +-
.../AFN_0DH/AFN13_F106_Analysis.cs | 2 +-
.../AFN_0DH/AFN13_F107_Analysis.cs | 2 +-
.../AFN_0DH/AFN13_F108_Analysis.cs | 2 +-
.../AFN_0DH/AFN13_F11_Analysis.cs | 2 +-
.../AFN_0DH/AFN13_F145_Analysis.cs | 2 +-
.../AFN_0DH/AFN13_F146_Analysis.cs | 2 +-
.../AFN_0DH/AFN13_F147_Analysis.cs | 2 +-
.../AFN_0DH/AFN13_F148_Analysis.cs | 2 +-
.../AFN_0DH/AFN13_F161_Analysis.cs | 2 +-
.../AFN_0DH/AFN13_F162_Analysis.cs | 2 +-
.../AFN_0DH/AFN13_F163_Analysis.cs | 2 +-
.../AFN_0DH/AFN13_F164_Analysis.cs | 2 +-
.../AFN_0DH/AFN13_F165_Analysis.cs | 2 +-
.../AFN_0DH/AFN13_F166_Analysis.cs | 2 +-
.../AFN_0DH/AFN13_F167_Analysis.cs | 2 +-
.../AFN_0DH/AFN13_F168_Analysis.cs | 2 +-
.../AFN_0DH/AFN13_F177_Analysis.cs | 2 +-
.../AFN_0DH/AFN13_F178_Analysis.cs | 2 +-
.../AFN_0DH/AFN13_F179_Analysis.cs | 2 +-
.../AFN_0DH/AFN13_F180_Analysis.cs | 2 +-
.../AFN_0DH/AFN13_F181_Analysis.cs | 2 +-
.../AFN_0DH/AFN13_F182_Analysis.cs | 2 +-
.../AFN_0DH/AFN13_F183_Analysis.cs | 2 +-
.../AFN_0DH/AFN13_F184_Analysis.cs | 2 +-
.../AFN_0DH/AFN13_F189_Analysis.cs | 2 +-
.../AFN_0DH/AFN13_F190_Analysis.cs | 2 +-
.../AFN_0DH/AFN13_F193_Analysis.cs | 2 +-
.../AFN_0DH/AFN13_F195_Analysis.cs | 2 +-
.../AFN_0DH/AFN13_F19_Analysis.cs | 2 +-
.../AnalysisData/AFN_0DH/AFN13_F3_Analysis.cs | 2 +-
.../AnalysisData/AFN_0DH/AFN13_F4_Analysis.cs | 2 +-
.../AFN_0DH/AFN13_F81_Analysis.cs | 2 +-
.../AFN_0DH/AFN13_F82_Analysis.cs | 2 +-
.../AFN_0DH/AFN13_F83_Analysis.cs | 2 +-
.../AFN_0DH/AFN13_F84_Analysis.cs | 2 +-
.../AFN_0DH/AFN13_F85_Analysis.cs | 2 +-
.../AFN_0DH/AFN13_F86_Analysis.cs | 2 +-
.../AFN_0DH/AFN13_F87_Analysis.cs | 2 +-
.../AFN_0DH/AFN13_F88_Analysis.cs | 2 +-
.../AFN_0DH/AFN13_F89_Analysis.cs | 2 +-
.../AFN_0DH/AFN13_F90_Analysis.cs | 2 +-
.../AFN_0DH/AFN13_F91_Analysis.cs | 2 +-
.../AFN_0DH/AFN13_F92_Analysis.cs | 2 +-
.../AFN_0DH/AFN13_F93_Analysis.cs | 2 +-
.../AFN_0DH/AFN13_F94_Analysis.cs | 2 +-
.../AFN_0DH/AFN13_F95_Analysis.cs | 2 +-
.../AFN_0DH/AFN13_F97_Analysis.cs | 2 +-
.../AFN_0DH/AFN13_F98_Analysis.cs | 2 +-
.../AFN_0DH/AFN13_F99_Analysis.cs | 2 +-
.../AnalysisData/AFN_0EH/AFN14_F1_Analysis.cs | 73 +++++++++++++----
.../AFN_10H/AFN16_F97_Analysis.cs | 2 +-
.../AnalysisData/DataStorage.cs | 81 ++++++++++++++++++-
.../Protocol3761/Dto/AnalysisBaseDto.cs | 2 +-
63 files changed, 196 insertions(+), 80 deletions(-)
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_02H/AFN2_F1_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_02H/AFN2_F1_Analysis.cs
index b287391..e7e6655 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_02H/AFN2_F1_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_02H/AFN2_F1_Analysis.cs
@@ -48,7 +48,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_02H
data.ProjectId = ammeterInfo.ProjectID;
data.DeviceId = ammeterInfo.FocusId;
data.DatabaseBusiID = ammeterInfo.DatabaseBusiID;
- data.MeterAddress = ammeterInfo.AmmerterAddress;
+ data.DeviceAddress = ammeterInfo.Address;
data.DeviceType = MeterTypeEnum.Focus;
}
UnitDataAnalysis> dto = new UnitDataAnalysis>
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_02H/AFN2_F2_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_02H/AFN2_F2_Analysis.cs
index 5d940f6..fe3efcc 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_02H/AFN2_F2_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_02H/AFN2_F2_Analysis.cs
@@ -45,7 +45,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_02H
data.ProjectId = ammeterInfo.ProjectID;
data.DeviceId = ammeterInfo.FocusId;
data.DatabaseBusiID = ammeterInfo.DatabaseBusiID;
- data.MeterAddress = ammeterInfo.AmmerterAddress;
+ data.DeviceAddress = ammeterInfo.Address;
data.DeviceType = MeterTypeEnum.Focus;
}
UnitDataAnalysis> dto = new UnitDataAnalysis>
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_02H/AFN2_F3_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_02H/AFN2_F3_Analysis.cs
index f4342f8..ce982b3 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_02H/AFN2_F3_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_02H/AFN2_F3_Analysis.cs
@@ -45,7 +45,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_02H
data.ProjectId = ammeterInfo.ProjectID;
data.DeviceId = ammeterInfo.FocusId;
data.DatabaseBusiID = ammeterInfo.DatabaseBusiID;
- data.MeterAddress = ammeterInfo.AmmerterAddress;
+ data.DeviceAddress = ammeterInfo.Address;
data.DeviceType = MeterTypeEnum.Focus;
}
UnitDataAnalysis> dto = new UnitDataAnalysis>
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0CH/AFN12_F149_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0CH/AFN12_F149_Analysis.cs
index c5afb48..53b0e23 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0CH/AFN12_F149_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0CH/AFN12_F149_Analysis.cs
@@ -46,7 +46,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AFN_0CH
data.ProjectId = ammeterInfo.ProjectID;
data.DeviceId = ammeterInfo.MeterId;
data.DatabaseBusiID=ammeterInfo.DatabaseBusiID;
- data.MeterAddress= ammeterInfo.AmmerterAddress;
+ data.DeviceAddress= ammeterInfo.AmmerterAddress;
}
UnitDataAnalysis> unitDataAnalysis = new UnitDataAnalysis>
{
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F100_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F100_Analysis.cs
index 65e3b28..084338b 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F100_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F100_Analysis.cs
@@ -51,7 +51,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
item.ProjectId = ammeterInfo.ProjectID;
item.DeviceId = ammeterInfo.MeterId;
item.DatabaseBusiID = ammeterInfo.DatabaseBusiID;
- item.MeterAddress = ammeterInfo.AmmerterAddress;
+ item.DeviceAddress = ammeterInfo.AmmerterAddress;
});
}
}
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F101_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F101_Analysis.cs
index 17750b8..5457f1d 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F101_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F101_Analysis.cs
@@ -49,7 +49,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
item.ProjectId = ammeterInfo.ProjectID;
item.DeviceId = ammeterInfo.MeterId;
item.DatabaseBusiID = ammeterInfo.DatabaseBusiID;
- item.MeterAddress = ammeterInfo.AmmerterAddress;
+ item.DeviceAddress = ammeterInfo.AmmerterAddress;
});
}
}
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F102_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F102_Analysis.cs
index 12d0136..9a10a3d 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F102_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F102_Analysis.cs
@@ -51,7 +51,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
item.ProjectId = ammeterInfo.ProjectID;
item.DeviceId = ammeterInfo.MeterId;
item.DatabaseBusiID = ammeterInfo.DatabaseBusiID;
- item.MeterAddress = ammeterInfo.AmmerterAddress;
+ item.DeviceAddress = ammeterInfo.AmmerterAddress;
});
}
}
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F103_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F103_Analysis.cs
index f72e60c..790f871 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F103_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F103_Analysis.cs
@@ -51,7 +51,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
item.ProjectId = ammeterInfo.ProjectID;
item.DeviceId = ammeterInfo.MeterId;
item.DatabaseBusiID = ammeterInfo.DatabaseBusiID;
- item.MeterAddress = ammeterInfo.AmmerterAddress;
+ item.DeviceAddress = ammeterInfo.AmmerterAddress;
});
}
}
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F104_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F104_Analysis.cs
index a258b18..c19133c 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F104_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F104_Analysis.cs
@@ -50,7 +50,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
item.ProjectId = ammeterInfo.ProjectID;
item.DeviceId = ammeterInfo.MeterId;
item.DatabaseBusiID = ammeterInfo.DatabaseBusiID;
- item.MeterAddress = ammeterInfo.AmmerterAddress;
+ item.DeviceAddress = ammeterInfo.AmmerterAddress;
});
}
}
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F105_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F105_Analysis.cs
index 5caebd9..2b0b1e8 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F105_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F105_Analysis.cs
@@ -50,7 +50,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
item.ProjectId = ammeterInfo.ProjectID;
item.DeviceId = ammeterInfo.MeterId;
item.DatabaseBusiID = ammeterInfo.DatabaseBusiID;
- item.MeterAddress = ammeterInfo.AmmerterAddress;
+ item.DeviceAddress = ammeterInfo.AmmerterAddress;
});
}
}
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F106_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F106_Analysis.cs
index b138b3f..76cb330 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F106_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F106_Analysis.cs
@@ -50,7 +50,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
item.ProjectId = ammeterInfo.ProjectID;
item.DeviceId = ammeterInfo.MeterId;
item.DatabaseBusiID = ammeterInfo.DatabaseBusiID;
- item.MeterAddress = ammeterInfo.AmmerterAddress;
+ item.DeviceAddress = ammeterInfo.AmmerterAddress;
});
}
}
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F107_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F107_Analysis.cs
index bcaf15c..b774044 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F107_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F107_Analysis.cs
@@ -49,7 +49,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
item.ProjectId = ammeterInfo.ProjectID;
item.DeviceId = ammeterInfo.MeterId;
item.DatabaseBusiID = ammeterInfo.DatabaseBusiID;
- item.MeterAddress = ammeterInfo.AmmerterAddress;
+ item.DeviceAddress = ammeterInfo.AmmerterAddress;
});
}
}
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F108_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F108_Analysis.cs
index f8d185a..89b569b 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F108_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F108_Analysis.cs
@@ -50,7 +50,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
item.ProjectId = ammeterInfo.ProjectID;
item.DeviceId = ammeterInfo.MeterId;
item.DatabaseBusiID = ammeterInfo.DatabaseBusiID;
- item.MeterAddress = ammeterInfo.AmmerterAddress;
+ item.DeviceAddress = ammeterInfo.AmmerterAddress;
});
}
}
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F11_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F11_Analysis.cs
index 48fb9ae..9502506 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F11_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F11_Analysis.cs
@@ -48,7 +48,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
item.ProjectId = ammeterInfo.ProjectID;
item.DeviceId = ammeterInfo.MeterId;
item.DatabaseBusiID = ammeterInfo.DatabaseBusiID;
- item.MeterAddress = ammeterInfo.AmmerterAddress;
+ item.DeviceAddress = ammeterInfo.AmmerterAddress;
});
}
}
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F145_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F145_Analysis.cs
index b674500..5348f46 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F145_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F145_Analysis.cs
@@ -49,7 +49,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
item.ProjectId = ammeterInfo.ProjectID;
item.DeviceId = ammeterInfo.MeterId;
item.DatabaseBusiID = ammeterInfo.DatabaseBusiID;
- item.MeterAddress = ammeterInfo.AmmerterAddress;
+ item.DeviceAddress = ammeterInfo.AmmerterAddress;
});
}
}
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F146_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F146_Analysis.cs
index 2d80010..aa7e1b3 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F146_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F146_Analysis.cs
@@ -49,7 +49,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
item.ProjectId = ammeterInfo.ProjectID;
item.DeviceId = ammeterInfo.MeterId;
item.DatabaseBusiID = ammeterInfo.DatabaseBusiID;
- item.MeterAddress = ammeterInfo.AmmerterAddress;
+ item.DeviceAddress = ammeterInfo.AmmerterAddress;
});
}
}
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F147_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F147_Analysis.cs
index fd60c25..f253797 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F147_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F147_Analysis.cs
@@ -49,7 +49,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
item.ProjectId = ammeterInfo.ProjectID;
item.DeviceId = ammeterInfo.MeterId;
item.DatabaseBusiID = ammeterInfo.DatabaseBusiID;
- item.MeterAddress = ammeterInfo.AmmerterAddress;
+ item.DeviceAddress = ammeterInfo.AmmerterAddress;
});
}
}
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F148_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F148_Analysis.cs
index 797eaf9..abeaa33 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F148_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F148_Analysis.cs
@@ -50,7 +50,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
item.ProjectId = ammeterInfo.ProjectID;
item.DeviceId = ammeterInfo.MeterId;
item.DatabaseBusiID = ammeterInfo.DatabaseBusiID;
- item.MeterAddress = ammeterInfo.AmmerterAddress;
+ item.DeviceAddress = ammeterInfo.AmmerterAddress;
});
}
}
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F161_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F161_Analysis.cs
index 0702077..c8c0709 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F161_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F161_Analysis.cs
@@ -49,7 +49,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
item.ProjectId = ammeterInfo.ProjectID;
item.DeviceId = ammeterInfo.MeterId;
item.DatabaseBusiID = ammeterInfo.DatabaseBusiID;
- item.MeterAddress = ammeterInfo.AmmerterAddress;
+ item.DeviceAddress = ammeterInfo.AmmerterAddress;
});
}
}
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F162_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F162_Analysis.cs
index 4aca266..37586a4 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F162_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F162_Analysis.cs
@@ -48,7 +48,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
item.ProjectId = ammeterInfo.ProjectID;
item.DeviceId = ammeterInfo.MeterId;
item.DatabaseBusiID = ammeterInfo.DatabaseBusiID;
- item.MeterAddress = ammeterInfo.AmmerterAddress;
+ item.DeviceAddress = ammeterInfo.AmmerterAddress;
});
}
}
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F163_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F163_Analysis.cs
index b040842..2eca6e7 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F163_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F163_Analysis.cs
@@ -49,7 +49,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
item.ProjectId = ammeterInfo.ProjectID;
item.DeviceId = ammeterInfo.MeterId;
item.DatabaseBusiID = ammeterInfo.DatabaseBusiID;
- item.MeterAddress = ammeterInfo.AmmerterAddress;
+ item.DeviceAddress = ammeterInfo.AmmerterAddress;
});
}
}
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F164_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F164_Analysis.cs
index a1b8084..5f65463 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F164_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F164_Analysis.cs
@@ -48,7 +48,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
item.ProjectId = ammeterInfo.ProjectID;
item.DeviceId = ammeterInfo.MeterId;
item.DatabaseBusiID = ammeterInfo.DatabaseBusiID;
- item.MeterAddress = ammeterInfo.AmmerterAddress;
+ item.DeviceAddress = ammeterInfo.AmmerterAddress;
});
}
}
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F165_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F165_Analysis.cs
index b4de0ab..ba7ea40 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F165_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F165_Analysis.cs
@@ -48,7 +48,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
item.ProjectId = ammeterInfo.ProjectID;
item.DeviceId = ammeterInfo.MeterId;
item.DatabaseBusiID = ammeterInfo.DatabaseBusiID;
- item.MeterAddress = ammeterInfo.AmmerterAddress;
+ item.DeviceAddress = ammeterInfo.AmmerterAddress;
});
}
}
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F166_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F166_Analysis.cs
index ce97c66..a9e3dfe 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F166_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F166_Analysis.cs
@@ -48,7 +48,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
item.ProjectId = ammeterInfo.ProjectID;
item.DeviceId = ammeterInfo.MeterId;
item.DatabaseBusiID = ammeterInfo.DatabaseBusiID;
- item.MeterAddress = ammeterInfo.AmmerterAddress;
+ item.DeviceAddress = ammeterInfo.AmmerterAddress;
});
}
}
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F167_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F167_Analysis.cs
index a383cb5..b30f48c 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F167_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F167_Analysis.cs
@@ -48,7 +48,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
item.ProjectId = ammeterInfo.ProjectID;
item.DeviceId = ammeterInfo.MeterId;
item.DatabaseBusiID = ammeterInfo.DatabaseBusiID;
- item.MeterAddress = ammeterInfo.AmmerterAddress;
+ item.DeviceAddress = ammeterInfo.AmmerterAddress;
});
}
}
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F168_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F168_Analysis.cs
index 2ed4694..e6c2143 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F168_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F168_Analysis.cs
@@ -48,7 +48,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
item.ProjectId = ammeterInfo.ProjectID;
item.DeviceId = ammeterInfo.MeterId;
item.DatabaseBusiID = ammeterInfo.DatabaseBusiID;
- item.MeterAddress = ammeterInfo.AmmerterAddress;
+ item.DeviceAddress = ammeterInfo.AmmerterAddress;
});
}
}
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F177_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F177_Analysis.cs
index 4589d46..a5aafb0 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F177_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F177_Analysis.cs
@@ -47,7 +47,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
item.ProjectId = ammeterInfo.ProjectID;
item.DeviceId = ammeterInfo.MeterId;
item.DatabaseBusiID = ammeterInfo.DatabaseBusiID;
- item.MeterAddress = ammeterInfo.AmmerterAddress;
+ item.DeviceAddress = ammeterInfo.AmmerterAddress;
});
}
}
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F178_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F178_Analysis.cs
index 793a2ec..33597da 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F178_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F178_Analysis.cs
@@ -48,7 +48,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
item.ProjectId = ammeterInfo.ProjectID;
item.DeviceId = ammeterInfo.MeterId;
item.DatabaseBusiID = ammeterInfo.DatabaseBusiID;
- item.MeterAddress = ammeterInfo.AmmerterAddress;
+ item.DeviceAddress = ammeterInfo.AmmerterAddress;
});
}
}
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F179_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F179_Analysis.cs
index 326ce3e..e1cf7c9 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F179_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F179_Analysis.cs
@@ -48,7 +48,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
item.ProjectId = ammeterInfo.ProjectID;
item.DeviceId = ammeterInfo.MeterId;
item.DatabaseBusiID = ammeterInfo.DatabaseBusiID;
- item.MeterAddress = ammeterInfo.AmmerterAddress;
+ item.DeviceAddress = ammeterInfo.AmmerterAddress;
});
}
}
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F180_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F180_Analysis.cs
index fd69e70..7c9dc8a 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F180_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F180_Analysis.cs
@@ -47,7 +47,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
item.ProjectId = ammeterInfo.ProjectID;
item.DeviceId = ammeterInfo.MeterId;
item.DatabaseBusiID = ammeterInfo.DatabaseBusiID;
- item.MeterAddress = ammeterInfo.AmmerterAddress;
+ item.DeviceAddress = ammeterInfo.AmmerterAddress;
});
}
}
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F181_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F181_Analysis.cs
index 01464e6..c799490 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F181_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F181_Analysis.cs
@@ -48,7 +48,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
item.ProjectId = ammeterInfo.ProjectID;
item.DeviceId = ammeterInfo.MeterId;
item.DatabaseBusiID = ammeterInfo.DatabaseBusiID;
- item.MeterAddress = ammeterInfo.AmmerterAddress;
+ item.DeviceAddress = ammeterInfo.AmmerterAddress;
});
}
}
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F182_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F182_Analysis.cs
index d0e3e3e..7e1fd3f 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F182_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F182_Analysis.cs
@@ -48,7 +48,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
item.ProjectId = ammeterInfo.ProjectID;
item.DeviceId = ammeterInfo.MeterId;
item.DatabaseBusiID = ammeterInfo.DatabaseBusiID;
- item.MeterAddress = ammeterInfo.AmmerterAddress;
+ item.DeviceAddress = ammeterInfo.AmmerterAddress;
});
}
}
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F183_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F183_Analysis.cs
index f1d8bda..9f00652 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F183_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F183_Analysis.cs
@@ -47,7 +47,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
item.ProjectId = ammeterInfo.ProjectID;
item.DeviceId = ammeterInfo.MeterId;
item.DatabaseBusiID = ammeterInfo.DatabaseBusiID;
- item.MeterAddress = ammeterInfo.AmmerterAddress;
+ item.DeviceAddress = ammeterInfo.AmmerterAddress;
});
}
}
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F184_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F184_Analysis.cs
index fed55e1..732af70 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F184_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F184_Analysis.cs
@@ -48,7 +48,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
item.ProjectId = ammeterInfo.ProjectID;
item.DeviceId = ammeterInfo.MeterId;
item.DatabaseBusiID = ammeterInfo.DatabaseBusiID;
- item.MeterAddress = ammeterInfo.AmmerterAddress;
+ item.DeviceAddress = ammeterInfo.AmmerterAddress;
});
}
}
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F189_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F189_Analysis.cs
index f353949..4c5461d 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F189_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F189_Analysis.cs
@@ -49,7 +49,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
item.ProjectId = ammeterInfo.ProjectID;
item.DeviceId = ammeterInfo.MeterId;
item.DatabaseBusiID = ammeterInfo.DatabaseBusiID;
- item.MeterAddress = ammeterInfo.AmmerterAddress;
+ item.DeviceAddress = ammeterInfo.AmmerterAddress;
});
}
}
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F190_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F190_Analysis.cs
index e9e56e2..2f5723b 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F190_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F190_Analysis.cs
@@ -45,7 +45,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
data.ProjectId = ammeterInfo.ProjectID;
data.DeviceId = ammeterInfo.MeterId;
data.DatabaseBusiID = ammeterInfo.DatabaseBusiID;
- data.MeterAddress = ammeterInfo.AmmerterAddress;
+ data.DeviceAddress = ammeterInfo.AmmerterAddress;
}
UnitDataAnalysis> unitDataAnalysis = new UnitDataAnalysis>
{
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F193_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F193_Analysis.cs
index b0cdbf2..9805b15 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F193_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F193_Analysis.cs
@@ -45,7 +45,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
data.ProjectId = ammeterInfo.ProjectID;
data.DeviceId = ammeterInfo.MeterId;
data.DatabaseBusiID = ammeterInfo.DatabaseBusiID;
- data.MeterAddress = ammeterInfo.AmmerterAddress;
+ data.DeviceAddress = ammeterInfo.AmmerterAddress;
}
UnitDataAnalysis> unitDataAnalysis = new UnitDataAnalysis>
{
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F195_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F195_Analysis.cs
index 0bee263..229c4cd 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F195_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F195_Analysis.cs
@@ -45,7 +45,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
data.ProjectId = ammeterInfo.ProjectID;
data.DeviceId = ammeterInfo.MeterId;
data.DatabaseBusiID = ammeterInfo.DatabaseBusiID;
- data.MeterAddress = ammeterInfo.AmmerterAddress;
+ data.DeviceAddress = ammeterInfo.AmmerterAddress;
}
UnitDataAnalysis> unitDataAnalysis = new UnitDataAnalysis>
{
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F19_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F19_Analysis.cs
index 818309f..7fd8ea4 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F19_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F19_Analysis.cs
@@ -49,7 +49,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
item.ProjectId = ammeterInfo.ProjectID;
item.DeviceId = ammeterInfo.MeterId;
item.DatabaseBusiID = ammeterInfo.DatabaseBusiID;
- item.MeterAddress = ammeterInfo.AmmerterAddress;
+ item.DeviceAddress = ammeterInfo.AmmerterAddress;
});
}
}
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F3_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F3_Analysis.cs
index c461225..9342427 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F3_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F3_Analysis.cs
@@ -53,7 +53,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
item.ProjectId = ammeterInfo.ProjectID;
item.DeviceId = ammeterInfo.MeterId;
item.DatabaseBusiID = ammeterInfo.DatabaseBusiID;
- item.MeterAddress = ammeterInfo.AmmerterAddress;
+ item.DeviceAddress = ammeterInfo.AmmerterAddress;
});
}
}
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F4_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F4_Analysis.cs
index 84c3532..8b7e7eb 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F4_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F4_Analysis.cs
@@ -52,7 +52,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
item.ProjectId = ammeterInfo.ProjectID;
item.DeviceId = ammeterInfo.MeterId;
item.DatabaseBusiID = ammeterInfo.DatabaseBusiID;
- item.MeterAddress = ammeterInfo.AmmerterAddress;
+ item.DeviceAddress = ammeterInfo.AmmerterAddress;
});
}
}
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F81_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F81_Analysis.cs
index 50b6cd4..4f917de 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F81_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F81_Analysis.cs
@@ -50,7 +50,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
item.ProjectId = ammeterInfo.ProjectID;
item.DeviceId = ammeterInfo.MeterId;
item.DatabaseBusiID = ammeterInfo.DatabaseBusiID;
- item.MeterAddress = ammeterInfo.AmmerterAddress;
+ item.DeviceAddress = ammeterInfo.AmmerterAddress;
});
}
}
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F82_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F82_Analysis.cs
index 4a5c8d7..1854237 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F82_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F82_Analysis.cs
@@ -51,7 +51,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
item.ProjectId = ammeterInfo.ProjectID;
item.DeviceId = ammeterInfo.MeterId;
item.DatabaseBusiID = ammeterInfo.DatabaseBusiID;
- item.MeterAddress = ammeterInfo.AmmerterAddress;
+ item.DeviceAddress = ammeterInfo.AmmerterAddress;
});
}
}
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F83_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F83_Analysis.cs
index 69b2fa1..a35f66f 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F83_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F83_Analysis.cs
@@ -51,7 +51,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
item.ProjectId = ammeterInfo.ProjectID;
item.DeviceId = ammeterInfo.MeterId;
item.DatabaseBusiID = ammeterInfo.DatabaseBusiID;
- item.MeterAddress = ammeterInfo.AmmerterAddress;
+ item.DeviceAddress = ammeterInfo.AmmerterAddress;
});
}
}
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F84_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F84_Analysis.cs
index 976e500..4c70465 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F84_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F84_Analysis.cs
@@ -50,7 +50,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
item.ProjectId = ammeterInfo.ProjectID;
item.DeviceId = ammeterInfo.MeterId;
item.DatabaseBusiID = ammeterInfo.DatabaseBusiID;
- item.MeterAddress = ammeterInfo.AmmerterAddress;
+ item.DeviceAddress = ammeterInfo.AmmerterAddress;
});
}
}
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F85_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F85_Analysis.cs
index 19dbbc5..4b85f94 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F85_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F85_Analysis.cs
@@ -51,7 +51,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
item.ProjectId = ammeterInfo.ProjectID;
item.DeviceId = ammeterInfo.MeterId;
item.DatabaseBusiID = ammeterInfo.DatabaseBusiID;
- item.MeterAddress = ammeterInfo.AmmerterAddress;
+ item.DeviceAddress = ammeterInfo.AmmerterAddress;
});
}
}
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F86_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F86_Analysis.cs
index b09ea25..cc86276 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F86_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F86_Analysis.cs
@@ -51,7 +51,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
item.ProjectId = ammeterInfo.ProjectID;
item.DeviceId = ammeterInfo.MeterId;
item.DatabaseBusiID = ammeterInfo.DatabaseBusiID;
- item.MeterAddress = ammeterInfo.AmmerterAddress;
+ item.DeviceAddress = ammeterInfo.AmmerterAddress;
});
}
}
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F87_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F87_Analysis.cs
index 73d4804..8aeaef4 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F87_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F87_Analysis.cs
@@ -50,7 +50,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
item.ProjectId = ammeterInfo.ProjectID;
item.DeviceId = ammeterInfo.MeterId;
item.DatabaseBusiID = ammeterInfo.DatabaseBusiID;
- item.MeterAddress = ammeterInfo.AmmerterAddress;
+ item.DeviceAddress = ammeterInfo.AmmerterAddress;
});
}
}
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F88_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F88_Analysis.cs
index 2e39463..3f1cdb7 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F88_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F88_Analysis.cs
@@ -51,7 +51,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
item.ProjectId = ammeterInfo.ProjectID;
item.DeviceId = ammeterInfo.MeterId;
item.DatabaseBusiID = ammeterInfo.DatabaseBusiID;
- item.MeterAddress = ammeterInfo.AmmerterAddress;
+ item.DeviceAddress = ammeterInfo.AmmerterAddress;
});
}
}
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F89_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F89_Analysis.cs
index eabab57..227418b 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F89_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F89_Analysis.cs
@@ -51,7 +51,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
item.ProjectId = ammeterInfo.ProjectID;
item.DeviceId = ammeterInfo.MeterId;
item.DatabaseBusiID = ammeterInfo.DatabaseBusiID;
- item.MeterAddress = ammeterInfo.AmmerterAddress;
+ item.DeviceAddress = ammeterInfo.AmmerterAddress;
});
}
}
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F90_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F90_Analysis.cs
index a5be397..428eeae 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F90_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F90_Analysis.cs
@@ -51,7 +51,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
item.ProjectId = ammeterInfo.ProjectID;
item.DeviceId = ammeterInfo.MeterId;
item.DatabaseBusiID = ammeterInfo.DatabaseBusiID;
- item.MeterAddress = ammeterInfo.AmmerterAddress;
+ item.DeviceAddress = ammeterInfo.AmmerterAddress;
});
}
}
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F91_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F91_Analysis.cs
index c0d7fa5..3a7f5c0 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F91_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F91_Analysis.cs
@@ -50,7 +50,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
item.ProjectId = ammeterInfo.ProjectID;
item.DeviceId = ammeterInfo.MeterId;
item.DatabaseBusiID = ammeterInfo.DatabaseBusiID;
- item.MeterAddress = ammeterInfo.AmmerterAddress;
+ item.DeviceAddress = ammeterInfo.AmmerterAddress;
});
}
}
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F92_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F92_Analysis.cs
index 2e0fbdc..6c7f733 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F92_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F92_Analysis.cs
@@ -51,7 +51,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
item.ProjectId = ammeterInfo.ProjectID;
item.DeviceId = ammeterInfo.MeterId;
item.DatabaseBusiID = ammeterInfo.DatabaseBusiID;
- item.MeterAddress = ammeterInfo.AmmerterAddress;
+ item.DeviceAddress = ammeterInfo.AmmerterAddress;
});
}
}
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F93_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F93_Analysis.cs
index 10bddfa..5176d2f 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F93_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F93_Analysis.cs
@@ -51,7 +51,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
item.ProjectId = ammeterInfo.ProjectID;
item.DeviceId = ammeterInfo.MeterId;
item.DatabaseBusiID = ammeterInfo.DatabaseBusiID;
- item.MeterAddress = ammeterInfo.AmmerterAddress;
+ item.DeviceAddress = ammeterInfo.AmmerterAddress;
});
}
}
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F94_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F94_Analysis.cs
index 4f722e8..60e0820 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F94_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F94_Analysis.cs
@@ -51,7 +51,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
item.ProjectId = ammeterInfo.ProjectID;
item.DeviceId = ammeterInfo.MeterId;
item.DatabaseBusiID = ammeterInfo.DatabaseBusiID;
- item.MeterAddress = ammeterInfo.AmmerterAddress;
+ item.DeviceAddress = ammeterInfo.AmmerterAddress;
});
}
}
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F95_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F95_Analysis.cs
index 295e6fd..391f375 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F95_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F95_Analysis.cs
@@ -51,7 +51,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
item.ProjectId = ammeterInfo.ProjectID;
item.DeviceId = ammeterInfo.MeterId;
item.DatabaseBusiID = ammeterInfo.DatabaseBusiID;
- item.MeterAddress = ammeterInfo.AmmerterAddress;
+ item.DeviceAddress = ammeterInfo.AmmerterAddress;
});
}
}
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F97_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F97_Analysis.cs
index e880d2a..e31ea6f 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F97_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F97_Analysis.cs
@@ -51,7 +51,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
item.ProjectId = ammeterInfo.ProjectID;
item.DeviceId = ammeterInfo.MeterId;
item.DatabaseBusiID = ammeterInfo.DatabaseBusiID;
- item.MeterAddress = ammeterInfo.AmmerterAddress;
+ item.DeviceAddress = ammeterInfo.AmmerterAddress;
});
}
}
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F98_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F98_Analysis.cs
index 1969c24..7e863aa 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F98_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F98_Analysis.cs
@@ -51,7 +51,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
item.ProjectId = ammeterInfo.ProjectID;
item.DeviceId = ammeterInfo.MeterId;
item.DatabaseBusiID = ammeterInfo.DatabaseBusiID;
- item.MeterAddress = ammeterInfo.AmmerterAddress;
+ item.DeviceAddress = ammeterInfo.AmmerterAddress;
});
}
}
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F99_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F99_Analysis.cs
index e2a5922..b3763db 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F99_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F99_Analysis.cs
@@ -51,7 +51,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
item.ProjectId = ammeterInfo.ProjectID;
item.DeviceId = ammeterInfo.MeterId;
item.DatabaseBusiID = ammeterInfo.DatabaseBusiID;
- item.MeterAddress = ammeterInfo.AmmerterAddress;
+ item.DeviceAddress = ammeterInfo.AmmerterAddress;
});
}
}
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0EH/AFN14_F1_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0EH/AFN14_F1_Analysis.cs
index b2177a6..39b36c8 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0EH/AFN14_F1_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0EH/AFN14_F1_Analysis.cs
@@ -1,9 +1,13 @@
using JiShe.CollectBus.Common.Enums;
using JiShe.CollectBus.Common.Extensions;
+using JiShe.CollectBus.IotSystems.Ammeters;
+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;
+using System;
+using System.Collections.Generic;
namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0EH
{
@@ -15,13 +19,14 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0EH
public class AFN14_F1_Analysis : IAnalysisStrategy
{
private readonly ILogger _logger;
-
- public AFN14_F1_Analysis(ILogger logger)
+ private readonly DataStorage _dataStorage;
+ public AFN14_F1_Analysis(ILogger logger, DataStorage dataStorage)
{
_logger = logger;
+ _dataStorage= dataStorage;
}
- public Task ExecuteAsync(TB3761 input, Action? result = null)
+ public async Task ExecuteAsync(TB3761 input, Action? result = null)
{
try
{
@@ -31,15 +36,35 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0EH
bool isOnOffPower = erc.Equals(14) ? true : false;
if (!isOnOffPower)
{
- throw new Exception($"ERC{erc}非上掉电事件");
+ // TODO:非终端停/上电事件直接确认
+ _logger.LogWarning($"0E_1解析ERC{erc}非终端停/上电事件:{input.A.Code}-{input.DT.Fn}-{input.BaseHexMessage.HexMessageString}");
+ return await Task.FromResult(true);
}
- UnitDataAnalysis> dto = new UnitDataAnalysis>
+
+ List> data = AnalysisDataUnit(input.UnitData.HexMessageList);
+ if (data.Count > 0)
+ {
+ // 查询电表信息
+ AmmeterInfo ammeterInfo = await _dataStorage.GetMeterInfoAsync(data[0].DeviceType.ToString(), "15");
+ if (ammeterInfo != null)
+ {
+ data.ForEach(item =>
+ {
+ item.ProjectId = ammeterInfo.ProjectID;
+ item.DeviceId = ammeterInfo.FocusId;
+ item.DatabaseBusiID = ammeterInfo.DatabaseBusiID;
+ item.DeviceAddress = ammeterInfo.Address;
+ item.DeviceType = MeterTypeEnum.Focus;
+ });
+ }
+ }
+ UnitDataAnalysis>> dto = new UnitDataAnalysis>>
{
Code = input.A.Code!,
AFN = input.AFN_FC.AFN,
Fn = input.DT.Fn,
Pn = input.DA.Pn,
- Data = AnalysisDataUnit(input.UnitData.HexMessageList),
+ Data = data,
HexMessage = input.BaseHexMessage.HexMessageString,
MessageId = input.MessageId,
ReceivedTime = input.ReceivedTime,
@@ -48,37 +73,55 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0EH
};
// meterData.DataType = "0E_1";
result?.Invoke(dto);
- return Task.FromResult(true);
+ await _dataStorage.SaveMultipleStatusToIotDbAsync(dto);
+ return await Task.FromResult(true);
}
catch (Exception ex)
{
_logger.LogError(ex, $"0E_1解析失败:{input.A.Code}-{input.DT.Fn}-{input.BaseHexMessage.HexMessageString},{ex.Message}");
}
- return Task.FromResult(false);
+ return await Task.FromResult(false);
}
- private Tuple AnalysisDataUnit(List hexMessageList)
+ private List> AnalysisDataUnit(List hexMessageList)
{
/// Item1=停电事件
/// Item2=上电事件
- return Tuple.Create(HandlerTime(hexMessageList.GetRange(10, 5)), HandlerTime(hexMessageList.GetRange(15, 5)));
+ List > values = new List>
+ {
+ new AnalysisBaseDto
+ {
+ FiledDesc = "停电事件",
+ FiledName = "Type",
+ DataValue = "PowerDownEvent",
+ TimeSpan=HandlerTime(hexMessageList.GetRange(10, 5))
+ },
+ new AnalysisBaseDto
+ {
+ FiledDesc = "上电事件",
+ FiledName = "Type",
+ DataValue = "PowerOnEvent",
+ TimeSpan=HandlerTime(hexMessageList.GetRange(15, 5))
+ }
+ };
+ return values;
}
///
/// /解析时间
///
///
- /// 时间验证失败是否默认为当前时间
///
- private string HandlerTime(List times)
+ private DateTime? HandlerTime(List times)
{
- var time = string.Empty;
try
{
times.Reverse();
- time = $"{DateTime.Now.ToString("yyyy").Substring(0, 2)}{times[0]}-{times[1]}-{times[2]} {times[3]}:{times[4]}:00";
+ string time = $"{DateTime.Now.ToString("yyyy").Substring(0, 2)}{times[0]}-{times[1]}-{times[2]} {times[3]}:{times[4]}:00";
+ DateTime.TryParse(time, out DateTime dateTime);
+ return dateTime;
}
catch { }
- return time;
+ return null;
}
}
}
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_10H/AFN16_F97_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_10H/AFN16_F97_Analysis.cs
index 4681548..3d17fd7 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_10H/AFN16_F97_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_10H/AFN16_F97_Analysis.cs
@@ -45,7 +45,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_10H
data.ProjectId = ammeterInfo.ProjectID;
data.DeviceId = ammeterInfo.MeterId;
data.DatabaseBusiID = ammeterInfo.DatabaseBusiID;
- data.MeterAddress = ammeterInfo.AmmerterAddress;
+ data.DeviceAddress = ammeterInfo.AmmerterAddress;
}
UnitDataAnalysis> unitDataAnalysis = new UnitDataAnalysis>
{
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/DataStorage.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/DataStorage.cs
index 8b13ac0..46be873 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/DataStorage.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/DataStorage.cs
@@ -123,7 +123,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData
DatabaseBusiID = data.DatabaseBusiID,
PendingCopyReadTime = data.TimeSpan.Value.GetFormatTime(analysisBaseDto.DensityUnit, analysisBaseDto.TimeDensity),
CreationTime = currentTime,
- MeterAddress = data.MeterAddress,
+ MeterAddress = data.DeviceAddress,
AFN = analysisBaseDto.AFN,
Fn = analysisBaseDto.Fn,
Seq = analysisBaseDto.PSEQ,
@@ -226,7 +226,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData
DatabaseBusiID = item.DatabaseBusiID,
PendingCopyReadTime = item.TimeSpan.Value.GetFormatTime(analysisBaseDto.DensityUnit, analysisBaseDto.TimeDensity),
CreationTime = currentTime,
- MeterAddress = item.MeterAddress,
+ MeterAddress = item.DeviceAddress,
AFN = analysisBaseDto.AFN,
Fn = analysisBaseDto.Fn,
Seq = analysisBaseDto.PSEQ,
@@ -269,8 +269,8 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData
public async Task SaveStatusToIotDbAsync(UnitDataAnalysis> analysisBaseDto)
{
ArgumentNullException.ThrowIfNull(nameof(analysisBaseDto.Data));
- ArgumentNullException.ThrowIfNullOrWhiteSpace(nameof(analysisBaseDto.Data.FiledName));
- ArgumentNullException.ThrowIfNullOrWhiteSpace(nameof(analysisBaseDto.Data.DataValue));
+ ArgumentException.ThrowIfNullOrWhiteSpace(nameof(analysisBaseDto.Data.FiledName));
+ ArgumentException.ThrowIfNullOrWhiteSpace(nameof(analysisBaseDto.Data.DataValue));
var data = analysisBaseDto.Data!;
if (!data.TimeSpan.HasValue)
data.TimeSpan = analysisBaseDto.ReceivedTime;
@@ -329,5 +329,78 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData
return await Task.FromResult(true);
}
+ ///
+ /// 保存状态到IotDb
+ ///
+ ///
+ ///
+ ///
+ public async Task SaveMultipleStatusToIotDbAsync(UnitDataAnalysis>> analysisBaseDto)
+ {
+ ArgumentNullException.ThrowIfNull(nameof(analysisBaseDto.Data));
+
+ var data = analysisBaseDto.Data!;
+ foreach (var item in data)
+ {
+ ArgumentException.ThrowIfNullOrWhiteSpace(nameof(item.FiledName));
+ ArgumentException.ThrowIfNullOrWhiteSpace(nameof(item.DataValue));
+
+ if (!item.TimeSpan.HasValue)
+ item.TimeSpan = analysisBaseDto.ReceivedTime;
+ // 类型(心跳,登录,上电,掉电)
+ long timestamps = DateTime.Now.GetDateTimeOffset().ToUnixTimeNanoseconds();
+ var treeData = new TreeModelSingleMeasuringEntity()
+ {
+ SystemName = _applicationOptions.SystemType,
+ DeviceId = $"{item.DeviceId}",
+ DeviceType = $"{item.DeviceType}.{IOTDBDataType.Status}",
+ ProjectId = $"{item.ProjectId}",
+ Timestamps = timestamps,
+ SingleMeasuring = new Tuple(item.FiledName!, item.DataValue!)
+ };
+ _runtimeContext.UseTableSessionPool = false; // 使树模型池
+ await _dbProvider.InsertAsync(treeData);
+ // 数据帧
+ var treeFrameData = new TreeModelSingleMeasuringEntity()
+ {
+ SystemName = _applicationOptions.SystemType,
+ DeviceId = $"{item.DeviceId}",
+ DeviceType = $"{item.DeviceType}.{IOTDBDataType.Status}",
+ ProjectId = $"{item.ProjectId}",
+ Timestamps = timestamps,
+ SingleMeasuring = new Tuple(ConcentratorStatusFieldConst.FrameData, analysisBaseDto.HexMessage ?? string.Empty)
+ };
+
+ _runtimeContext.UseTableSessionPool = false; // 使树模型池
+ await _dbProvider.InsertAsync(treeFrameData);
+
+ // 时间
+ var treeRecordingTimeData = new TreeModelSingleMeasuringEntity()
+ {
+ SystemName = _applicationOptions.SystemType,
+ DeviceId = $"{item.DeviceId}",
+ DeviceType = $"{item.DeviceType}.{IOTDBDataType.Status}",
+ ProjectId = $"{item.ProjectId}",
+ Timestamps = timestamps,
+ SingleMeasuring = new Tuple(ConcentratorStatusFieldConst.RecordingTime, (data.TimeSpan.HasValue ? data.TimeSpan.Value : DateTime.Now).GetDateTimeOffset().ToUnixTimeNanoseconds())
+ };
+ _runtimeContext.UseTableSessionPool = false; // 使树模型池
+ await _dbProvider.InsertAsync(treeRecordingTimeData);
+ // 备注
+ var treeRemarkData = new TreeModelSingleMeasuringEntity()
+ {
+ SystemName = _applicationOptions.SystemType,
+ DeviceId = $"{item.DeviceId}",
+ DeviceType = $"{item.DeviceType}.{IOTDBDataType.Status}",
+ ProjectId = $"{item.ProjectId}",
+ Timestamps = timestamps,
+ SingleMeasuring = new Tuple(ConcentratorStatusFieldConst.Remark, data.FiledDesc ?? string.Empty)
+ };
+ _runtimeContext.UseTableSessionPool = false; // 使树模型池
+ await _dbProvider.InsertAsync(treeRemarkData);
+
+ }
+ return await Task.FromResult(true);
+ }
}
}
diff --git a/services/JiShe.CollectBus.Domain/Protocol3761/Dto/AnalysisBaseDto.cs b/services/JiShe.CollectBus.Domain/Protocol3761/Dto/AnalysisBaseDto.cs
index c6f7fae..8d693e3 100644
--- a/services/JiShe.CollectBus.Domain/Protocol3761/Dto/AnalysisBaseDto.cs
+++ b/services/JiShe.CollectBus.Domain/Protocol3761/Dto/AnalysisBaseDto.cs
@@ -63,7 +63,7 @@ namespace JiShe.CollectBus.Protocol.Contracts.Protocol.Dto
public int DatabaseBusiID { get; set; }
///
- /// 表地址
+ /// 设备地址(电表地址,水表地址,气表地址,集中器地址等)
///
public string DeviceAddress { get; set; } = null!;
From a5ed0a37a041c9720338369abc806b9fb13e5160 Mon Sep 17 00:00:00 2001
From: zenghongyao <873884283@qq.com>
Date: Thu, 8 May 2025 09:29:31 +0800
Subject: [PATCH 3/8] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E4=BB=A3=E7=A0=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
.../AnalysisData/DataStorage.cs | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/DataStorage.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/DataStorage.cs
index 46be873..00c5c63 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/DataStorage.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/DataStorage.cs
@@ -382,7 +382,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData
DeviceType = $"{item.DeviceType}.{IOTDBDataType.Status}",
ProjectId = $"{item.ProjectId}",
Timestamps = timestamps,
- SingleMeasuring = new Tuple(ConcentratorStatusFieldConst.RecordingTime, (data.TimeSpan.HasValue ? data.TimeSpan.Value : DateTime.Now).GetDateTimeOffset().ToUnixTimeNanoseconds())
+ SingleMeasuring = new Tuple(ConcentratorStatusFieldConst.RecordingTime, (item.TimeSpan.HasValue ? item.TimeSpan.Value : DateTime.Now).GetDateTimeOffset().ToUnixTimeNanoseconds())
};
_runtimeContext.UseTableSessionPool = false; // 使树模型池
await _dbProvider.InsertAsync(treeRecordingTimeData);
@@ -394,7 +394,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData
DeviceType = $"{item.DeviceType}.{IOTDBDataType.Status}",
ProjectId = $"{item.ProjectId}",
Timestamps = timestamps,
- SingleMeasuring = new Tuple(ConcentratorStatusFieldConst.Remark, data.FiledDesc ?? string.Empty)
+ SingleMeasuring = new Tuple(ConcentratorStatusFieldConst.Remark, item.FiledDesc ?? string.Empty)
};
_runtimeContext.UseTableSessionPool = false; // 使树模型池
await _dbProvider.InsertAsync(treeRemarkData);
From 245c91c9e34ef5170c79673c7aa49a7f773b4bd3 Mon Sep 17 00:00:00 2001
From: zenghongyao <873884283@qq.com>
Date: Thu, 8 May 2025 11:25:08 +0800
Subject: [PATCH 4/8] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E6=B5=8B=E8=AF=95?=
=?UTF-8?q?=E4=B8=8B=E5=8F=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
.../Samples/SampleDto.cs | 9 ++++
.../Plugins/TcpMonitor.cs | 21 +++++----
.../Samples/SampleAppService.cs | 47 ++++++++++++++++++-
.../Consts/ProtocolConst.cs | 5 ++
.../Pages/Monitor.cshtml | 1 -
5 files changed, 71 insertions(+), 12 deletions(-)
diff --git a/services/JiShe.CollectBus.Application.Contracts/Samples/SampleDto.cs b/services/JiShe.CollectBus.Application.Contracts/Samples/SampleDto.cs
index 12f46d1..c32d892 100644
--- a/services/JiShe.CollectBus.Application.Contracts/Samples/SampleDto.cs
+++ b/services/JiShe.CollectBus.Application.Contracts/Samples/SampleDto.cs
@@ -14,3 +14,12 @@ public class SampleDto2
{
public int Value { get; set; }
}
+
+
+public class KafkaSendDto
+{
+ public string Address { get; set; }
+
+ public string Frame { get; set; }
+
+}
diff --git a/services/JiShe.CollectBus.Application/Plugins/TcpMonitor.cs b/services/JiShe.CollectBus.Application/Plugins/TcpMonitor.cs
index 25d16f3..049db1f 100644
--- a/services/JiShe.CollectBus.Application/Plugins/TcpMonitor.cs
+++ b/services/JiShe.CollectBus.Application/Plugins/TcpMonitor.cs
@@ -100,16 +100,17 @@ namespace JiShe.CollectBus.Plugins
{
//todo: 删除Redis缓存
var tcpSessionClient = (ITcpSessionClient)client;
- var entity = await _deviceRepository.FindAsync(a => a.ClientId == tcpSessionClient.Id);
- if (entity != null)
- {
- entity.UpdateByOnClosed();
- await _deviceRepository.UpdateAsync(entity);
- }
- else
- {
- _logger.LogWarning($"[TCP] ID:{tcpSessionClient.Id} IP:{client.GetIPPort()}已关闭连接,但采集程序检索失败");
- }
+ //var entity = await _deviceRepository.FindAsync(a => a.ClientId == tcpSessionClient.Id);
+ //if (entity != null)
+ //{
+ // entity.UpdateByOnClosed();
+ // await _deviceRepository.UpdateAsync(entity);
+ //}
+ //else
+ //{
+ //_logger.LogWarning($"[TCP] ID:{tcpSessionClient.Id} IP:{client.GetIPPort()}已关闭连接,但采集程序检索失败");
+ //}
+ _logger.LogWarning($"[TCP] ID:{tcpSessionClient.Id} IP:{client.GetIPPort()}已关闭连接");
await e.InvokeNext();
}
diff --git a/services/JiShe.CollectBus.Application/Samples/SampleAppService.cs b/services/JiShe.CollectBus.Application/Samples/SampleAppService.cs
index ea2415e..4cb325c 100644
--- a/services/JiShe.CollectBus.Application/Samples/SampleAppService.cs
+++ b/services/JiShe.CollectBus.Application/Samples/SampleAppService.cs
@@ -14,6 +14,7 @@ using JiShe.CollectBus.IotSystems.Ammeters;
using JiShe.CollectBus.IotSystems.PrepayModel;
using JiShe.CollectBus.Kafka.Attributes;
using JiShe.CollectBus.Kafka.Internal;
+using JiShe.CollectBus.Kafka.Producer;
using JiShe.CollectBus.Protocol.Interfaces;
using Microsoft.AspNetCore.Authorization;
using Microsoft.AspNetCore.Mvc;
@@ -24,6 +25,7 @@ using System;
using System.Collections.Generic;
using System.Diagnostics;
using System.Threading.Tasks;
+using TouchSocket.Sockets;
namespace JiShe.CollectBus.Samples;
@@ -35,14 +37,18 @@ public class SampleAppService : CollectBusAppService, ISampleAppService, IKafkaS
private readonly IoTDbOptions _options;
private readonly IRedisDataCacheService _redisDataCacheService;
+ private readonly IProducerService _producerService;
+ private readonly ITcpService _tcpService;
public SampleAppService(IIoTDbProvider iotDBProvider, IOptions options,
- IoTDBRuntimeContext dbContext, ILogger logger, IRedisDataCacheService redisDataCacheService)
+ IoTDBRuntimeContext dbContext, ILogger logger, IRedisDataCacheService redisDataCacheService, IProducerService producerService, ITcpService tcpService)
{
_iotDBProvider = iotDBProvider;
_options = options.Value;
_dbContext = dbContext;
_logger = logger;
_redisDataCacheService = redisDataCacheService;
+ _producerService =producerService;
+ _tcpService=tcpService;
}
///
@@ -399,5 +405,44 @@ public class SampleAppService : CollectBusAppService, ISampleAppService, IKafkaS
_logger.LogWarning($"收到订阅消息: {obj}");
return SubscribeAck.Success();
}
+
+ ///
+ /// 测试Kafka下发报文
+ ///
+ ///
+ ///
+ [AllowAnonymous]
+ public async Task KafkaSendAsync(KafkaSendDto input)
+ {
+ ArgumentException.ThrowIfNullOrWhiteSpace(input.Address);
+ ArgumentException.ThrowIfNullOrWhiteSpace(input.Frame);
+ input.Frame = input.Frame.Replace(" ", "");
+ await _producerService.ProduceAsync(ProtocolConst.TESTSENDTOPIC, input);
+ return await Task.FromResult(true);
+ }
+
+
+ ///
+ /// 订阅下发的数据
+ ///
+ ///
+ ///
+ [KafkaSubscribe(ProtocolConst.TESTSENDTOPIC)]
+
+ public async Task KafkaSubscribeTestSendAsync(KafkaSendDto dto)
+ {
+ if (_tcpService.ClientExists(dto.Address))
+ {
+ // 发送给设备
+ await _tcpService.SendAsync(dto.Address, dto.Frame);
+ _logger.LogWarning($"{dto.Address}下发消息报文:{dto.Frame}");
+ }
+ else
+ {
+ _logger.LogWarning($"{dto.Address}集中器未上线: {dto.Serialize()}");
+ }
+ // 测试不管是否上线都ACK
+ return SubscribeAck.Success();
+ }
}
diff --git a/shared/JiShe.CollectBus.Common/Consts/ProtocolConst.cs b/shared/JiShe.CollectBus.Common/Consts/ProtocolConst.cs
index 95c2c44..0758899 100644
--- a/shared/JiShe.CollectBus.Common/Consts/ProtocolConst.cs
+++ b/shared/JiShe.CollectBus.Common/Consts/ProtocolConst.cs
@@ -170,5 +170,10 @@ namespace JiShe.CollectBus.Common.Consts
/// 测试主题格式
///
public const string TESTTOPIC = "test-topic";
+
+ ///
+ /// 测试下发主题格式
+ ///
+ public const string TESTSENDTOPIC = "test-send-topic";
}
}
diff --git a/web/JiShe.CollectBus.Host/Pages/Monitor.cshtml b/web/JiShe.CollectBus.Host/Pages/Monitor.cshtml
index 30e91e8..a58ded5 100644
--- a/web/JiShe.CollectBus.Host/Pages/Monitor.cshtml
+++ b/web/JiShe.CollectBus.Host/Pages/Monitor.cshtml
@@ -16,7 +16,6 @@
后端服务
-
From 91386007ae053a41672cf765cee7755780357095 Mon Sep 17 00:00:00 2001
From: zenghongyao <873884283@qq.com>
Date: Thu, 8 May 2025 11:58:26 +0800
Subject: [PATCH 5/8] =?UTF-8?q?=E6=B5=8B=E8=AF=95=E4=B8=8B=E5=8F=91?=
=?UTF-8?q?=E6=9B=B4=E6=94=B9=E5=8F=91=E4=B8=BA=E5=AD=97=E8=8A=82?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
.../Protocol3761Extensions.cs | 2 +-
.../JiShe.CollectBus.Application/Samples/SampleAppService.cs | 3 ++-
web/JiShe.CollectBus.Host/Pages/Monitor.cshtml | 1 +
3 files changed, 4 insertions(+), 2 deletions(-)
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/Protocol3761Extensions.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/Protocol3761Extensions.cs
index f9f3801..caa6793 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/Protocol3761Extensions.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/Protocol3761Extensions.cs
@@ -257,7 +257,7 @@ namespace JiShe.CollectBus.Protocol.T37612012
else
decimal.TryParse(data[i], out value);
meter.DataValue = value;
- meter.DataType = dataType;
+ meter.DataType = dataType.ToUpper();
meter.FiledDesc = filedDesc;
meter.FiledName = meter.DataType.GetDataFieldByGatherDataType() ?? string.Empty;
if (DateTime.TryParse(CalculateTimeSpan(i - 3, data[0], density), out DateTime readingDate))
diff --git a/services/JiShe.CollectBus.Application/Samples/SampleAppService.cs b/services/JiShe.CollectBus.Application/Samples/SampleAppService.cs
index 4cb325c..56e895a 100644
--- a/services/JiShe.CollectBus.Application/Samples/SampleAppService.cs
+++ b/services/JiShe.CollectBus.Application/Samples/SampleAppService.cs
@@ -25,6 +25,7 @@ using System;
using System.Collections.Generic;
using System.Diagnostics;
using System.Threading.Tasks;
+using TouchSocket.Core;
using TouchSocket.Sockets;
namespace JiShe.CollectBus.Samples;
@@ -434,7 +435,7 @@ public class SampleAppService : CollectBusAppService, ISampleAppService, IKafkaS
if (_tcpService.ClientExists(dto.Address))
{
// 发送给设备
- await _tcpService.SendAsync(dto.Address, dto.Frame);
+ await _tcpService.SendAsync(dto.Address, Convert.FromHexString(dto.Frame));
_logger.LogWarning($"{dto.Address}下发消息报文:{dto.Frame}");
}
else
diff --git a/web/JiShe.CollectBus.Host/Pages/Monitor.cshtml b/web/JiShe.CollectBus.Host/Pages/Monitor.cshtml
index a58ded5..30e91e8 100644
--- a/web/JiShe.CollectBus.Host/Pages/Monitor.cshtml
+++ b/web/JiShe.CollectBus.Host/Pages/Monitor.cshtml
@@ -16,6 +16,7 @@
后端服务
+
From 3488b0012a16fa23c156bc535c7fd51f35c01ded Mon Sep 17 00:00:00 2001
From: zenghongyao <873884283@qq.com>
Date: Thu, 8 May 2025 15:12:37 +0800
Subject: [PATCH 6/8] =?UTF-8?q?=E8=A7=A3=E6=9E=90=E9=94=99=E8=AF=AF?=
=?UTF-8?q?=E6=95=B0=E6=8D=AE=E4=BF=9D=E5=AD=98NULL?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
.../AFN_0CH/AFN12_F129_Analysis.cs | 30 ++++--
.../AFN_0CH/AFN12_F130_Analysis.cs | 27 ++++--
.../AFN_0CH/AFN12_F131_Analysis.cs | 29 ++++--
.../AFN_0CH/AFN12_F132_Analysis.cs | 32 +++++--
.../AFN_0CH/AFN12_F145_Analysis.cs | 26 ++++--
.../AFN_0CH/AFN12_F149_Analysis.cs | 15 +--
.../AFN_0CH/AFN12_F188_Analysis.cs | 20 ++--
.../AFN_0CH/AFN12_F25_Analysis.cs | 22 +++--
.../AFN_0CH/AFN12_F49_Analysis.cs | 23 +++--
.../AFN_0DH/AFN13_F100_Analysis.cs | 6 +-
.../AFN_0DH/AFN13_F101_Analysis.cs | 6 +-
.../AFN_0DH/AFN13_F102_Analysis.cs | 6 +-
.../AFN_0DH/AFN13_F103_Analysis.cs | 6 +-
.../AFN_0DH/AFN13_F104_Analysis.cs | 6 +-
.../AFN_0DH/AFN13_F105_Analysis.cs | 6 +-
.../AFN_0DH/AFN13_F106_Analysis.cs | 6 +-
.../AFN_0DH/AFN13_F107_Analysis.cs | 6 +-
.../AFN_0DH/AFN13_F108_Analysis.cs | 6 +-
.../AFN_0DH/AFN13_F11_Analysis.cs | 38 ++++----
.../AFN_0DH/AFN13_F145_Analysis.cs | 6 +-
.../AFN_0DH/AFN13_F146_Analysis.cs | 9 +-
.../AFN_0DH/AFN13_F147_Analysis.cs | 6 +-
.../AFN_0DH/AFN13_F148_Analysis.cs | 6 +-
.../AFN_0DH/AFN13_F161_Analysis.cs | 6 +-
.../AFN_0DH/AFN13_F162_Analysis.cs | 6 +-
.../AFN_0DH/AFN13_F163_Analysis.cs | 6 +-
.../AFN_0DH/AFN13_F164_Analysis.cs | 6 +-
.../AFN_0DH/AFN13_F165_Analysis.cs | 6 +-
.../AFN_0DH/AFN13_F166_Analysis.cs | 6 +-
.../AFN_0DH/AFN13_F167_Analysis.cs | 6 +-
.../AFN_0DH/AFN13_F168_Analysis.cs | 6 +-
.../AFN_0DH/AFN13_F177_Analysis.cs | 6 +-
.../AFN_0DH/AFN13_F178_Analysis.cs | 6 +-
.../AFN_0DH/AFN13_F179_Analysis.cs | 6 +-
.../AFN_0DH/AFN13_F180_Analysis.cs | 6 +-
.../AFN_0DH/AFN13_F181_Analysis.cs | 6 +-
.../AFN_0DH/AFN13_F182_Analysis.cs | 6 +-
.../AFN_0DH/AFN13_F183_Analysis.cs | 6 +-
.../AFN_0DH/AFN13_F184_Analysis.cs | 6 +-
.../AFN_0DH/AFN13_F189_Analysis.cs | 12 +--
.../AFN_0DH/AFN13_F190_Analysis.cs | 44 ++++-----
.../AFN_0DH/AFN13_F193_Analysis.cs | 37 ++++----
.../AFN_0DH/AFN13_F195_Analysis.cs | 37 ++++----
.../AFN_0DH/AFN13_F19_Analysis.cs | 37 ++++----
.../AnalysisData/AFN_0DH/AFN13_F3_Analysis.cs | 91 +++++++++----------
.../AnalysisData/AFN_0DH/AFN13_F4_Analysis.cs | 33 ++++---
.../AFN_0DH/AFN13_F81_Analysis.cs | 6 +-
.../AFN_0DH/AFN13_F82_Analysis.cs | 6 +-
.../AFN_0DH/AFN13_F83_Analysis.cs | 6 +-
.../AFN_0DH/AFN13_F84_Analysis.cs | 6 +-
.../AFN_0DH/AFN13_F85_Analysis.cs | 6 +-
.../AFN_0DH/AFN13_F86_Analysis.cs | 6 +-
.../AFN_0DH/AFN13_F87_Analysis.cs | 6 +-
.../AFN_0DH/AFN13_F88_Analysis.cs | 6 +-
.../AFN_0DH/AFN13_F89_Analysis.cs | 6 +-
.../AFN_0DH/AFN13_F90_Analysis.cs | 6 +-
.../AFN_0DH/AFN13_F91_Analysis.cs | 6 +-
.../AFN_0DH/AFN13_F92_Analysis.cs | 6 +-
.../AFN_0DH/AFN13_F93_Analysis.cs | 6 +-
.../AFN_0DH/AFN13_F94_Analysis.cs | 6 +-
.../AFN_0DH/AFN13_F95_Analysis.cs | 6 +-
.../AFN_0DH/AFN13_F97_Analysis.cs | 6 +-
.../AFN_0DH/AFN13_F98_Analysis.cs | 6 +-
.../AFN_0DH/AFN13_F99_Analysis.cs | 6 +-
.../AFN_10H/AFN16_F97_Analysis.cs | 21 +++--
.../AnalysisData/DataStorage.cs | 2 +-
.../Protocol3761Extensions.cs | 82 ++++++++++-------
.../Protocol3761/Dto/AnalysisBaseDto.cs | 8 +-
.../Extensions/StringExtensions.cs | 4 +-
.../Pages/Monitor.cshtml | 1 -
70 files changed, 520 insertions(+), 436 deletions(-)
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0CH/AFN12_F129_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0CH/AFN12_F129_Analysis.cs
index 4eb05ad..a7538ca 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0CH/AFN12_F129_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0CH/AFN12_F129_Analysis.cs
@@ -33,7 +33,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0CH
ArgumentNullException.ThrowIfNull(input);
ArgumentNullException.ThrowIfNull(input.UnitData?.HexMessageList);
ArgumentNullException.ThrowIfNull(input.A.A3?.D1_D7);
- UnitDataAnalysis>> unitDataAnalysis = new UnitDataAnalysis>>
+ UnitDataAnalysis>> unitDataAnalysis = new UnitDataAnalysis>>
{
Code = input.A.Code!,
AFN = input.AFN_FC.AFN,
@@ -48,7 +48,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0CH
TimeDensity = 0
};
List datas = await AnalysisDataUnitAsync(input.UnitData.HexMessageList);
- List> list = GenerateFinalResult(2, datas, "正向有功电能示值", input.AFN_FC.AFN, input.DT.Fn);
+ List> list = GenerateFinalResult(2, datas, "正向有功电能示值", input.AFN_FC.AFN, input.DT.Fn);
unitDataAnalysis.Data= list;
result?.Invoke(unitDataAnalysis);
return await Task.FromResult(true);
@@ -90,22 +90,32 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0CH
}
#endregion
- public List> GenerateFinalResult(int index, List data, string filedDesc = "", int afn = 0, int fn = 0)
+ public List> GenerateFinalResult(int index, List data, string filedDesc = "", int afn = 0, int fn = 0)
{
- List> list = new List>();
+ List> list = new List>();
for (int i = index; i < data.Count; i++)
{
- AnalysisBaseDto meter = new AnalysisBaseDto();
-
- decimal value = 0;
+ AnalysisBaseDto meter = new AnalysisBaseDto
+ {
+ DeviceType = MeterTypeEnum.Ammeter
+ };
var errorCode = data[i].CheckErrorCode();
if (errorCode != null)
+ {
+ meter.ErrorCodeMsg= errorCode.Item2;
meter.ValidData = false;
+ }
else
- decimal.TryParse(data[i], out value);
- meter.DataValue = value;
+ {
+ if(decimal.TryParse(data[i], out decimal value))
+ meter.DataValue = value;
+ }
meter.DataType = $"{afn.ToString().PadLeft(2, '0')}_{fn}_{i - index}";
- meter.TimeSpan = Convert.ToDateTime($"{data[0].Substring(0, 4)}-{data[0].Substring(4, 2)}-{data[0].Substring(6, 2)} {data[0].Substring(8, 2)}:{data[0].Substring(10, 2)}:00");
+ string timeSpan = $"{data[0].Substring(0, 4)}-{data[0].Substring(4, 2)}-{data[0].Substring(6, 2)} {data[0].Substring(8, 2)}:{data[0].Substring(10, 2)}:00";
+ if (DateTime.TryParse(timeSpan, out DateTime readingDate))
+ {
+ meter.TimeSpan = readingDate;
+ }
meter.FiledDesc = filedDesc;
meter.FiledName = meter.DataType.GetDataFieldByGatherDataType() ?? string.Empty;
list.Add(meter);
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0CH/AFN12_F130_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0CH/AFN12_F130_Analysis.cs
index cce2df4..d67d8d1 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0CH/AFN12_F130_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0CH/AFN12_F130_Analysis.cs
@@ -31,8 +31,8 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0CH
ArgumentNullException.ThrowIfNull(input);
ArgumentNullException.ThrowIfNull(input.UnitData?.HexMessageList);
List datas = await AnalysisDataUnitAsync(input.UnitData.HexMessageList);
- List> list = GenerateFinalResult(2, datas, "正向无功电能示值", input.AFN_FC.AFN, input.DT.Fn);
- UnitDataAnalysis>> unitDataAnalysis = new UnitDataAnalysis>>
+ List> list = GenerateFinalResult(2, datas, "正向无功电能示值", input.AFN_FC.AFN, input.DT.Fn);
+ UnitDataAnalysis>> unitDataAnalysis = new UnitDataAnalysis>>
{
Code = input.A.Code!,
AFN = input.AFN_FC.AFN,
@@ -78,21 +78,30 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0CH
}
return values;
}
- public List> GenerateFinalResult(int index, List data, string filedDesc = "", int afn = 0, int fn = 0)
+ public List> GenerateFinalResult(int index, List data, string filedDesc = "", int afn = 0, int fn = 0)
{
- List> list = new List>();
+ List> list = new List>();
for (int i = index; i < data.Count; i++)
{
- AnalysisBaseDto meter = new AnalysisBaseDto();
- decimal value = 0;
+ AnalysisBaseDto meter = new AnalysisBaseDto
+ {
+ DeviceType = MeterTypeEnum.Ammeter
+ };
var errorCode = data[i].CheckErrorCode();
if (errorCode != null)
+ {
+ meter.ErrorCodeMsg = errorCode.Item2;
meter.ValidData = false;
+ }
else
- decimal.TryParse(data[i], out value);
- meter.DataValue = value;
+ {
+ if(decimal.TryParse(data[i], out decimal value))
+ meter.DataValue = value;
+ }
meter.DataType = $"{afn.ToString().PadLeft(2, '0')}_{fn}_{i - index}";
- meter.TimeSpan = Convert.ToDateTime($"{data[0].Substring(0, 4)}-{data[0].Substring(4, 2)}-{data[0].Substring(6, 2)} {data[0].Substring(8, 2)}:{data[0].Substring(10, 2)}:00");
+ string timeSpan = $"{data[0].Substring(0, 4)}-{data[0].Substring(4, 2)}-{data[0].Substring(6, 2)} {data[0].Substring(8, 2)}:{data[0].Substring(10, 2)}:00"
+ if(DateTime.TryParse(timeSpan, out DateTime readingDate))
+ meter.TimeSpan = readingDate;
meter.FiledDesc = filedDesc;
meter.FiledName = meter.DataType.GetDataFieldByGatherDataType() ?? string.Empty;
list.Add(meter);
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0CH/AFN12_F131_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0CH/AFN12_F131_Analysis.cs
index 4cbb5b5..9b57ea1 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0CH/AFN12_F131_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0CH/AFN12_F131_Analysis.cs
@@ -6,6 +6,8 @@ using JiShe.CollectBus.Protocol.Interfaces;
using JiShe.CollectBus.Protocol.T37612012.Appendix;
using JiShe.CollectBus.Protocol3761;
using Microsoft.Extensions.Logging;
+using Newtonsoft.Json.Linq;
+using YamlDotNet.Core.Tokens;
namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0CH
{
@@ -30,8 +32,8 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0CH
ArgumentNullException.ThrowIfNull(input);
ArgumentNullException.ThrowIfNull(input.UnitData?.HexMessageList);
List datas = await AnalysisDataUnitAsync(input.UnitData.HexMessageList);
- List> list = GenerateFinalResult(2, datas, "反向有功总电能示值", input.AFN_FC.AFN, input.DT.Fn);
- UnitDataAnalysis>> unitDataAnalysis = new UnitDataAnalysis>>
+ List> list = GenerateFinalResult(2, datas, "反向有功总电能示值", input.AFN_FC.AFN, input.DT.Fn);
+ UnitDataAnalysis>> unitDataAnalysis = new UnitDataAnalysis>>
{
Code = input.A.Code!,
AFN = input.AFN_FC.AFN,
@@ -78,21 +80,30 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0CH
}
return values;
}
- public List> GenerateFinalResult(int index, List data, string filedDesc = "", int afn = 0, int fn = 0)
+ public List> GenerateFinalResult(int index, List data, string filedDesc = "", int afn = 0, int fn = 0)
{
- List> list = new List>();
+ List> list = new List>();
for (int i = index; i < data.Count; i++)
{
- AnalysisBaseDto meter = new AnalysisBaseDto();
- decimal value = 0;
+ AnalysisBaseDto meter = new AnalysisBaseDto
+ {
+ DeviceType = MeterTypeEnum.Ammeter
+ };
var errorCode = data[i].CheckErrorCode();
if (errorCode != null)
+ {
+ meter.ErrorCodeMsg = errorCode.Item2;
meter.ValidData = false;
+ }
else
- decimal.TryParse(data[i], out value);
- meter.DataValue = value;
+ {
+ if(decimal.TryParse(data[i], out decimal value))
+ meter.DataValue = value;
+ }
meter.DataType = $"{afn.ToString().PadLeft(2, '0')}_{fn}_{i - index}";
- meter.TimeSpan = Convert.ToDateTime($"{data[0].Substring(0, 4)}-{data[0].Substring(4, 2)}-{data[0].Substring(6, 2)} {data[0].Substring(8, 2)}:{data[0].Substring(10, 2)}:00");
+ string timeSpan = $"{data[0].Substring(0, 4)}-{data[0].Substring(4, 2)}-{data[0].Substring(6, 2)} {data[0].Substring(8, 2)}:{data[0].Substring(10, 2)}:00";
+ if(DateTime.TryParse(timeSpan, out DateTime readTime))
+ meter.TimeSpan = readTime;
meter.FiledDesc = filedDesc;
meter.FiledName = meter.DataType.GetDataFieldByGatherDataType() ?? string.Empty;
list.Add(meter);
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0CH/AFN12_F132_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0CH/AFN12_F132_Analysis.cs
index 59096de..70db824 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0CH/AFN12_F132_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0CH/AFN12_F132_Analysis.cs
@@ -7,6 +7,7 @@ using JiShe.CollectBus.Protocol.Interfaces;
using JiShe.CollectBus.Protocol.T37612012.Appendix;
using JiShe.CollectBus.Protocol3761;
using Microsoft.Extensions.Logging;
+using YamlDotNet.Core.Tokens;
namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0CH
{
@@ -34,9 +35,8 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0CH
ArgumentNullException.ThrowIfNull(input.UnitData?.HexMessageList);
List datas = await AnalysisDataUnitAsync(input.UnitData.HexMessageList);
string dataType = $"{input.AFN_FC.AFN.HexToDecStr().PadLeft(2, '0')}_{input.DT.Fn}";
-
- List> list = GenerateFinalResult(2, datas, "反向无功电能示值", dataType);
- UnitDataAnalysis>> unitDataAnalysis = new UnitDataAnalysis>>
+ List> list = GenerateFinalResult(2, datas, "反向无功电能示值", dataType);
+ UnitDataAnalysis>> unitDataAnalysis = new UnitDataAnalysis>>
{
Code = input.A.Code!,
AFN = input.AFN_FC.AFN,
@@ -82,21 +82,33 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0CH
}
return values;
}
- public List> GenerateFinalResult(int index, List data, string dataType, string filedDesc = "")
+ public List> GenerateFinalResult(int index, List data, string dataType, string filedDesc = "")
{
- List> list = new List>();
+ List> list = new List>();
for (int i = index; i < data.Count; i++)
{
- AnalysisBaseDto meter = new AnalysisBaseDto();
- decimal value = 0;
+ AnalysisBaseDto meter = new AnalysisBaseDto
+ {
+ DeviceType = MeterTypeEnum.Ammeter
+ };
var errorCode = data[i].CheckErrorCode();
if (errorCode != null)
+ {
+ meter.ErrorCodeMsg = errorCode.Item2;
meter.ValidData = false;
+ }
else
- decimal.TryParse(data[i], out value);
- meter.DataValue = value;
+ {
+ if(decimal.TryParse(data[i], out decimal value))
+ meter.DataValue = value;
+ }
+
meter.DataType = $"{dataType}_{i - index}";
- meter.TimeSpan = Convert.ToDateTime($"{data[0].Substring(0, 4)}-{data[0].Substring(4, 2)}-{data[0].Substring(6, 2)} {data[0].Substring(8, 2)}:{data[0].Substring(10, 2)}:00");
+ string timeSpan = $"{data[0].Substring(0, 4)}-{data[0].Substring(4, 2)}-{data[0].Substring(6, 2)} {data[0].Substring(8, 2)}:{data[0].Substring(10, 2)}:00";
+ if (DateTime.TryParse(timeSpan,out DateTime readingDate))
+ {
+ meter.TimeSpan = readingDate;
+ }
meter.FiledDesc = filedDesc;
meter.FiledName = meter.DataType.GetDataFieldByGatherDataType() ?? string.Empty;
list.Add(meter);
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0CH/AFN12_F145_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0CH/AFN12_F145_Analysis.cs
index e0d143b..ecbaef0 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0CH/AFN12_F145_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0CH/AFN12_F145_Analysis.cs
@@ -35,8 +35,8 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0CH
List datas = await AnalysisDataUnitAsync(input.UnitData.HexMessageList);
string dataType = $"{input.AFN_FC.AFN.HexToDecStr().PadLeft(2, '0')}_{input.DT.Fn}";
- AnalysisBaseDto data = GenerateFinalResult(datas, "当月正向有功最大需量及发生时间", dataType);
- UnitDataAnalysis> unitDataAnalysis = new UnitDataAnalysis>
+ AnalysisBaseDto data = GenerateFinalResult(datas, "当月正向有功最大需量及发生时间", dataType);
+ UnitDataAnalysis> unitDataAnalysis = new UnitDataAnalysis>
{
Code = input.A.Code!,
AFN = input.AFN_FC.AFN,
@@ -96,19 +96,25 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0CH
return values;
}
- public AnalysisBaseDto GenerateFinalResult(List data, string filedDesc,string dataType)
+ public AnalysisBaseDto GenerateFinalResult(List data, string filedDesc,string dataType)
{
- AnalysisBaseDto dto = new AnalysisBaseDto();
-
- decimal value = 0;
+ AnalysisBaseDto dto = new AnalysisBaseDto
+ {
+ DeviceType = MeterTypeEnum.Ammeter
+ };
var errorCode = data[2].CheckErrorCode();
if (errorCode != null)
+ {
+ dto.ErrorCodeMsg = errorCode.Item2;
dto.ValidData = false;
+ }
else
- decimal.TryParse(data[2], out value);
-
- dto.DataValue = value;
- string 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(decimal.TryParse(data[2], out decimal value))
+ dto.DataValue = value;
+ }
+
+ string 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";
if (DateTime.TryParse(timeSpan, out DateTime readingDate))
{
dto.TimeSpan = readingDate;
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0CH/AFN12_F149_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0CH/AFN12_F149_Analysis.cs
index 53b0e23..671e625 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0CH/AFN12_F149_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0CH/AFN12_F149_Analysis.cs
@@ -38,7 +38,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AFN_0CH
List datas = await AnalysisDataUnit(input.UnitData.HexMessageList);
string dataType = $"{input.AFN_FC.AFN.HexToDecStr().PadLeft(2, '0')}_{input.DT.Fn}";
- AnalysisBaseDto data = GenerateFinalResult(datas, dataType,"上月(上一结算日)正向有功最大需量及发生时间");
+ AnalysisBaseDto data = GenerateFinalResult(datas, dataType,"上月(上一结算日)正向有功最大需量及发生时间");
// 查询电表信息
AmmeterInfo ammeterInfo = await _dataStorage.GetMeterInfoAsync(data.DeviceType.ToString(), "15");
if (ammeterInfo != null)
@@ -48,7 +48,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AFN_0CH
data.DatabaseBusiID=ammeterInfo.DatabaseBusiID;
data.DeviceAddress= ammeterInfo.AmmerterAddress;
}
- UnitDataAnalysis> unitDataAnalysis = new UnitDataAnalysis>
+ UnitDataAnalysis> unitDataAnalysis = new UnitDataAnalysis>
{
Code = input.A.Code!,
AFN = input.AFN_FC.AFN,
@@ -63,7 +63,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AFN_0CH
DensityUnit = DensityUnit.Second,
TimeDensity = 0
};
- await _dataStorage.SaveDataToIotDbAsync(unitDataAnalysis);
+ await _dataStorage.SaveDataToIotDbAsync(unitDataAnalysis);
result?.Invoke(unitDataAnalysis);
return await Task.FromResult(true);
}
@@ -110,10 +110,12 @@ namespace JiShe.CollectBus.Protocol.T37612012.AFN_0CH
}
return values;
}
- public AnalysisBaseDto GenerateFinalResult(List data,string dataType, string filedDesc = "")
+ public AnalysisBaseDto GenerateFinalResult(List data,string dataType, string filedDesc = "")
{
- AnalysisBaseDto dto = new AnalysisBaseDto();
-
+ AnalysisBaseDto dto = new AnalysisBaseDto
+ {
+ DeviceType = MeterTypeEnum.Ammeter
+ };
var errorCodeInfo = data[2].CheckErrorCode();
if (errorCodeInfo != null)
{
@@ -133,7 +135,6 @@ namespace JiShe.CollectBus.Protocol.T37612012.AFN_0CH
else
{
string 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";
-
//TODO:时间标
if (!DateTime.TryParse(timeSpan, out DateTime dataTime))
dto.ValidData = false;
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0CH/AFN12_F188_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0CH/AFN12_F188_Analysis.cs
index 5758459..e48cdc4 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0CH/AFN12_F188_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0CH/AFN12_F188_Analysis.cs
@@ -6,6 +6,7 @@ using JiShe.CollectBus.Protocol.Dto;
using JiShe.CollectBus.Protocol.Interfaces;
using JiShe.CollectBus.Protocol3761;
using Microsoft.Extensions.Logging;
+using YamlDotNet.Core.Tokens;
namespace JiShe.CollectBus.Protocol.T37612012.AFN_0CH
{
@@ -34,8 +35,8 @@ namespace JiShe.CollectBus.Protocol.T37612012.AFN_0CH
ArgumentNullException.ThrowIfNull(input.AFN_FC.AFN);
ArgumentNullException.ThrowIfNull(input.DT.Fn);
string dataType = $"{input.AFN_FC.AFN.HexToDecStr().PadLeft(2, '0')}_{input.DT.Fn}";
- AnalysisBaseDto data = GenerateFinalResult(input.UnitData.HexMessageList, dataType);
- UnitDataAnalysis> dto = new UnitDataAnalysis>
+ AnalysisBaseDto data = GenerateFinalResult(input.UnitData.HexMessageList, dataType);
+ UnitDataAnalysis> dto = new UnitDataAnalysis>
{
Code = input.A.Code!,
AFN = input.AFN_FC.AFN,
@@ -58,10 +59,12 @@ namespace JiShe.CollectBus.Protocol.T37612012.AFN_0CH
}
return await Task.FromResult(false);
}
- public AnalysisBaseDto GenerateFinalResult(List hexMessageList,string dataType)
+ public AnalysisBaseDto GenerateFinalResult(List hexMessageList,string dataType)
{
- AnalysisBaseDto dto = new AnalysisBaseDto();
- decimal value = 0;
+ AnalysisBaseDto dto = new AnalysisBaseDto
+ {
+ DeviceType = MeterTypeEnum.WaterMeter
+ };
var arr = hexMessageList.GetRange(11, 4);
var errorCodeInfo = arr.CheckErrorCode();
if (errorCodeInfo != null)
@@ -70,9 +73,10 @@ namespace JiShe.CollectBus.Protocol.T37612012.AFN_0CH
dto.ErrorCodeMsg = errorCodeInfo.Item2;
}
else
- decimal.TryParse($"{arr[11]}{arr[12]}{arr[13]}.{arr[14]}", out value);
-
- dto.DataValue = value;
+ {
+ if (decimal.TryParse($"{arr[11]}{arr[12]}{arr[13]}.{arr[14]}", out decimal value))
+ dto.DataValue = value;
+ }
dto.DataType = dataType;
dto.FiledDesc = "水示值";
dto.FiledName = dto.DataType.GetDataFieldByGatherDataType() ?? string.Empty;
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0CH/AFN12_F25_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0CH/AFN12_F25_Analysis.cs
index a58c574..4c754e3 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0CH/AFN12_F25_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0CH/AFN12_F25_Analysis.cs
@@ -1,11 +1,14 @@
using JiShe.CollectBus.Common.Enums;
using JiShe.CollectBus.Common.Extensions;
+using JiShe.CollectBus.Common.Helpers;
using JiShe.CollectBus.Protocol.Contracts.Protocol.Dto;
using JiShe.CollectBus.Protocol.Dto;
using JiShe.CollectBus.Protocol.Interfaces;
using JiShe.CollectBus.Protocol.T37612012.Appendix;
using JiShe.CollectBus.Protocol3761;
using Microsoft.Extensions.Logging;
+using Newtonsoft.Json.Linq;
+using YamlDotNet.Core.Tokens;
namespace JiShe.CollectBus.Protocol.T37612012.AFN_0CH
{
@@ -32,13 +35,15 @@ namespace JiShe.CollectBus.Protocol.T37612012.AFN_0CH
ArgumentNullException.ThrowIfNull(input);
ArgumentNullException.ThrowIfNull(input.UnitData?.HexMessageList);
List remarks = new List() { "当前总有功功率", "当前A相有功功率", "当前B相有功功率", "当前C相有功功率", "当前总无功功率", "当前A相无功功率", "当前B相无功功率", "当前C相无功功率", "当前总功率因数", "当前A相功率因数", "当前B相功率因数", "当前C相功率因数", "当前A相电压", "当前B相电压", "当前C相电压", "当前A相电流", "当前C相电流", "当前 C相电流", "当前零序电流", "当前总视在功率", "当前A相视在功率", "当前B相视在功率", "当前C相视在功率" };
- List> list = new List>();
+ List> list = new List>();
List data = await AnalysisDataUnitAsync(input.UnitData.HexMessageList);
for (int i = 1; i < data.Count; i++)
{
- AnalysisBaseDto dto = new AnalysisBaseDto();
- decimal value = 0;
+ AnalysisBaseDto dto = new AnalysisBaseDto
+ {
+ DeviceType = MeterTypeEnum.Ammeter
+ };
var errorCodeInfo = data[i].CheckErrorCode();
if (errorCodeInfo != null)
{
@@ -46,15 +51,18 @@ namespace JiShe.CollectBus.Protocol.T37612012.AFN_0CH
dto.ErrorCodeMsg = errorCodeInfo.Item2;
}
else
- decimal.TryParse(data[i], out value);
- dto.DataValue = value;
+ {
+ if(decimal.TryParse(data[i], out decimal value))
+ dto.DataValue = value;
+ }
+
dto.DataType = $"{input.AFN_FC.AFN.HexToDecStr().PadLeft(2, '0')}_{input.DT.Fn}_{DataType[i-1]}";
- dto.FiledName = DataType[i - 1];
+ dto.FiledName = DataType[i - 1].GetDataFieldByGatherDataType() ?? string.Empty;
dto.TimeSpan = Convert.ToDateTime($"{data[0].Substring(0, 4)}-{data[0].Substring(4, 2)}-{data[0].Substring(6, 2)} {data[0].Substring(8, 2)}:{data[0].Substring(10, 2)}:00");
dto.FiledDesc = remarks[i - 1];
list.Add(dto);
}
- UnitDataAnalysis>> unitDataAnalysis = new UnitDataAnalysis>>
+ UnitDataAnalysis>> unitDataAnalysis = new UnitDataAnalysis>>
{
Code = input.A.Code!,
AFN = input.AFN_FC.AFN,
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0CH/AFN12_F49_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0CH/AFN12_F49_Analysis.cs
index b639f0d..c54d058 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0CH/AFN12_F49_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0CH/AFN12_F49_Analysis.cs
@@ -1,11 +1,13 @@
using JiShe.CollectBus.Common.Enums;
using JiShe.CollectBus.Common.Extensions;
+using JiShe.CollectBus.Common.Helpers;
using JiShe.CollectBus.Protocol.Contracts.Protocol.Dto;
using JiShe.CollectBus.Protocol.Dto;
using JiShe.CollectBus.Protocol.Interfaces;
using JiShe.CollectBus.Protocol.T37612012.Appendix;
using JiShe.CollectBus.Protocol3761;
using Microsoft.Extensions.Logging;
+using YamlDotNet.Core.Tokens;
namespace JiShe.CollectBus.Protocol.T37612012.AFN_0CH
{
@@ -33,27 +35,30 @@ namespace JiShe.CollectBus.Protocol.T37612012.AFN_0CH
List data = await AnalysisDataUnitAsync(input.UnitData?.HexMessageList!);
List remarks = new List() { "Uab/Ua 相位角", "Ub 相位角", "Ucb/Uc 相位角", "Ia 相位角", "Ib 相位角", "Ic 相位角" };
- List> list = new List>();
+ List> list = new List>();
for (int i = 0; i < data.Count; i++)
{
- AnalysisBaseDto dto = new AnalysisBaseDto();
- decimal value = 0;
+ AnalysisBaseDto dto = new AnalysisBaseDto
+ {
+ DeviceType = MeterTypeEnum.Ammeter
+ };
var errorCodeInfo = data[i].CheckErrorCode();
if (errorCodeInfo != null)
{
dto.ValidData = false;
dto.ErrorCodeMsg = errorCodeInfo.Item2;
- }
+ }
else
- decimal.TryParse(data[i], out value);
- dto.DataValue = value;
-
+ {
+ if(decimal.TryParse(data[i], out decimal value))
+ dto.DataValue = value;
+ }
dto.DataType = $"{input.AFN_FC.AFN.HexToDecStr().PadLeft(2, '0')}_{input.DT.Fn}_{DataType[i]}";
- dto.FiledName = DataType[i];
+ dto.FiledName = DataType[i].GetDataFieldByGatherDataType() ?? string.Empty;
dto.FiledDesc= remarks[i];
list.Add(dto);
}
- UnitDataAnalysis>> unitDataAnalysis = new UnitDataAnalysis>>
+ UnitDataAnalysis>> unitDataAnalysis = new UnitDataAnalysis>>
{
Code = input.A.Code!,
AFN = input.AFN_FC.AFN,
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F100_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F100_Analysis.cs
index 084338b..3df913f 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F100_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F100_Analysis.cs
@@ -38,7 +38,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
int density = Convert.ToInt32(Convert.ToInt32(datas[1]).GetEnumDescription(typeof(DensityEnums)));
string dataType = $"{input.AFN_FC.AFN.HexToDecStr().PadLeft(2, '0')}_{input.DT.Fn}";
- List> data = datas.GenerateFinalResultTd_c(3, density, dataType, "反向无功总电能量");
+ List> data = datas.GenerateFinalResultTd_c(3, density, dataType, "反向无功总电能量");
if (data.Count > 0)
{
@@ -56,7 +56,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
}
}
- UnitDataAnalysis>> unitDataAnalysis = new UnitDataAnalysis>>
+ UnitDataAnalysis>> unitDataAnalysis = new UnitDataAnalysis>>
{
Code = input.A.Code!,
AFN = input.AFN_FC.AFN,
@@ -71,7 +71,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
DensityUnit = DensityUnit.Minute,
ReceivedTime = input.ReceivedTime
};
- await _dataStorage.SaveMultipleDataToIotDbAsync(unitDataAnalysis);
+ await _dataStorage.SaveMultipleDataToIotDbAsync(unitDataAnalysis);
result?.Invoke(unitDataAnalysis);
return await Task.FromResult(true);
}
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F101_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F101_Analysis.cs
index 5457f1d..f4d4c0a 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F101_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F101_Analysis.cs
@@ -37,7 +37,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
int density = Convert.ToInt32(Convert.ToInt32(datas[1]).GetEnumDescription(typeof(DensityEnums)));
string dataType = $"{input.AFN_FC.AFN.HexToDecStr().PadLeft(2, '0')}_{input.DT.Fn}";
- List> data = datas.GenerateFinalResultTd_c(3, density, dataType, "正向有功总电能示值");
+ List> data = datas.GenerateFinalResultTd_c(3, density, dataType, "正向有功总电能示值");
if (data.Count > 0)
{
// 查询电表信息
@@ -53,7 +53,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
});
}
}
- UnitDataAnalysis>> unitDataAnalysis = new UnitDataAnalysis>>
+ UnitDataAnalysis>> unitDataAnalysis = new UnitDataAnalysis>>
{
Code = input.A.Code!,
AFN = input.AFN_FC.AFN,
@@ -68,7 +68,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
DensityUnit = DensityUnit.Minute,
ReceivedTime = input.ReceivedTime
};
- await _dataStorage.SaveMultipleDataToIotDbAsync(unitDataAnalysis);
+ await _dataStorage.SaveMultipleDataToIotDbAsync(unitDataAnalysis);
result?.Invoke(unitDataAnalysis);
return await Task.FromResult(true);
}
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F102_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F102_Analysis.cs
index 9a10a3d..4e02149 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F102_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F102_Analysis.cs
@@ -38,7 +38,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
string dataType = $"{input.AFN_FC.AFN.HexToDecStr().PadLeft(2, '0')}_{input.DT.Fn}";
- List> data = datas.GenerateFinalResultTd_c(3, density, dataType, "正向无功总电能示值");
+ List> data = datas.GenerateFinalResultTd_c(3, density, dataType, "正向无功总电能示值");
if (data.Count > 0)
{
@@ -55,7 +55,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
});
}
}
- UnitDataAnalysis>> unitDataAnalysis = new UnitDataAnalysis>>
+ UnitDataAnalysis>> unitDataAnalysis = new UnitDataAnalysis>>
{
Code = input.A.Code!,
AFN = input.AFN_FC.AFN,
@@ -70,7 +70,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
DensityUnit = DensityUnit.Minute,
ReceivedTime = input.ReceivedTime
};
- await _dataStorage.SaveMultipleDataToIotDbAsync(unitDataAnalysis);
+ await _dataStorage.SaveMultipleDataToIotDbAsync(unitDataAnalysis);
result?.Invoke(unitDataAnalysis);
return await Task.FromResult(true);
}
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F103_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F103_Analysis.cs
index 790f871..94faa02 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F103_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F103_Analysis.cs
@@ -38,7 +38,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
string dataType = $"{input.AFN_FC.AFN.HexToDecStr().PadLeft(2, '0')}_{input.DT.Fn}";
- List> data = datas.GenerateFinalResultTd_c(3, density, dataType, "反向有功总电能示值");
+ List> data = datas.GenerateFinalResultTd_c(3, density, dataType, "反向有功总电能示值");
if (data.Count > 0)
{
@@ -55,7 +55,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
});
}
}
- UnitDataAnalysis>> unitDataAnalysis = new UnitDataAnalysis>>
+ UnitDataAnalysis>> unitDataAnalysis = new UnitDataAnalysis>>
{
Code = input.A.Code!,
AFN = input.AFN_FC.AFN,
@@ -70,7 +70,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
DensityUnit = DensityUnit.Minute,
ReceivedTime = input.ReceivedTime
};
- await _dataStorage.SaveMultipleDataToIotDbAsync(unitDataAnalysis);
+ await _dataStorage.SaveMultipleDataToIotDbAsync(unitDataAnalysis);
result?.Invoke(unitDataAnalysis);
return await Task.FromResult(true);
}
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F104_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F104_Analysis.cs
index c19133c..a76189a 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F104_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F104_Analysis.cs
@@ -37,7 +37,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
int density = Convert.ToInt32(Convert.ToInt32(datas[1]).GetEnumDescription(typeof(DensityEnums)));
string dataType = $"{input.AFN_FC.AFN.HexToDecStr().PadLeft(2, '0')}_{input.DT.Fn}";
- List> data = datas.GenerateFinalResultTd_c(3, density, dataType, "反向无功总电能示值");
+ List> data = datas.GenerateFinalResultTd_c(3, density, dataType, "反向无功总电能示值");
if (data.Count > 0)
{
@@ -54,7 +54,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
});
}
}
- UnitDataAnalysis>> unitDataAnalysis = new UnitDataAnalysis>>
+ UnitDataAnalysis>> unitDataAnalysis = new UnitDataAnalysis>>
{
Code = input.A.Code!,
AFN = input.AFN_FC.AFN,
@@ -69,7 +69,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
DensityUnit = DensityUnit.Minute,
ReceivedTime = input.ReceivedTime
};
- await _dataStorage.SaveMultipleDataToIotDbAsync(unitDataAnalysis);
+ await _dataStorage.SaveMultipleDataToIotDbAsync(unitDataAnalysis);
result?.Invoke(unitDataAnalysis);
return await Task.FromResult(true);
}
diff --git a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F105_Analysis.cs b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F105_Analysis.cs
index 2b0b1e8..05fa701 100644
--- a/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F105_Analysis.cs
+++ b/protocols/JiShe.CollectBus.Protocol.T37612012/AnalysisData/AFN_0DH/AFN13_F105_Analysis.cs
@@ -37,7 +37,7 @@ namespace JiShe.CollectBus.Protocol.T37612012.AnalysisData.AFN_0DH
int density = Convert.ToInt32(Convert.ToInt32(datas[1]).GetEnumDescription(typeof(DensityEnums)));
string dataType = $"{input.AFN_FC.AFN.HexToDecStr().PadLeft(2, '0')}_{input.DT.Fn}";
- List> data = datas.GenerateFinalResultTd_c(3, density, dataType, "功率因数");
+ List