diff --git a/SensorHub.HydrogenSulfide/App.config b/SensorHub.HydrogenSulfide/App.config
new file mode 100644
index 0000000..8e15646
--- /dev/null
+++ b/SensorHub.HydrogenSulfide/App.config
@@ -0,0 +1,6 @@
+
+
+
+
+
+
\ No newline at end of file
diff --git a/SensorHub.HydrogenSulfide/App.config b/SensorHub.HydrogenSulfide/App.config
new file mode 100644
index 0000000..8e15646
--- /dev/null
+++ b/SensorHub.HydrogenSulfide/App.config
@@ -0,0 +1,6 @@
+
+
+
+
+
+
\ No newline at end of file
diff --git a/SensorHub.HydrogenSulfide/HydrogenSulfide.cs b/SensorHub.HydrogenSulfide/HydrogenSulfide.cs
new file mode 100644
index 0000000..8691d2f
--- /dev/null
+++ b/SensorHub.HydrogenSulfide/HydrogenSulfide.cs
@@ -0,0 +1,223 @@
+using SensorHub.Servers;
+using SensorHub.Servers.Commands.CASICCommands;
+using SensorHub.Servers.JsonFormat;
+using SuperSocket.SocketBase.Command;
+using SuperSocket.SocketBase.Protocol;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+
+namespace SensorHub.HydrogenSulfide
+{
+ public class HydrogenSulfide : CommandBase
+ {
+ public override void ExecuteCommand(CasicSession session, StringRequestInfo requestInfo)
+ {
+ //TODO: construct the receving casic data
+ String preamble = requestInfo.Parameters[0];
+ String version = requestInfo.Parameters[1];
+ String leng = requestInfo.Parameters[2];
+ String devCode = requestInfo.Parameters[3];
+ String routeFlag = requestInfo.Parameters[4];
+ String dstNodeAddr = requestInfo.Parameters[5];
+ String pduType = requestInfo.Parameters[6];
+ String seq = requestInfo.Parameters[7];
+ String settings = requestInfo.Parameters[8];
+ String source = requestInfo.Parameters[9];
+ String exist = requestInfo.Parameters[10];
+
+ String devName = "HydrogenSulfide";
+
+ if (source.Contains("-"))
+ {
+ session.Send("HTTP/1.1 200 OK\r\n\r\n\r\n");
+ session.Close();
+ }
+
+ //print the receving data
+ String devType = "硫化氢监测终端";
+ String operType = Common.getOpeTypeByPdu(pduType);
+ session.Logger.Info("AD接收数据:" + requestInfo.Body);
+ session.Logger.Info("设备类型:" + devType);
+ session.Logger.Info("操作类型:" + operType);
+ session.Logger.Info("会话:" + session.HubAddr + "," + session.SessionID);
+
+ byte[] btPdu = new byte[2]; //2个字节
+ btPdu[0] = Common.getRespOperType(operType, source == "433" ? true : false);
+ btPdu[1] = 0x9E; // 最高位=1表示不拆包; 0x1E = 30 表示设备类型=30
+
+ if (exist == "0")//数据没有缓存
+ {
+ //判断是返回的设置确认数据帧, 回复第三方
+ if (operType == "SetResponse")
+ {
+ Common.sendSetResponse(session, devCode, "HydrogenSulfide");
+ return;
+ }
+
+ //获取电量信息，系统时间，传递给对应的handler
+ List tags = Common.getTags(settings, session);
+
+ //具体业务处理
+ String collectDate = "";
+ int cell = -1;
+ int? pci = null;
+ int? rsrp = null;
+ int? snr = null;
+
+ String softwareVersion = "";
+ uint offset = 0;
+ uint size = 0;
+
+ List eventList = new List();
+ List datasList = new List();
+ List startupList = new List();
+
+ foreach (Tag tag in tags)
+ {
+ if (!(tag is UploadTag))
+ {
+ //非业务处理
+ if (tag != null && tag is CellTag)
+ {
+ CellTag cellTag = (CellTag)tag;
+ cell = cellTag.Cell;
+ continue;
+ }
+
+ if (tag != null && tag is PCITag)
+ {
+ PCITag pciTag = (PCITag)tag;
+ pci = pciTag.PCI;
+ continue;
+ }
+
+ if (tag != null && tag is RSRPTag)
+ {
+ RSRPTag rsrpTag = (RSRPTag)tag;
+ rsrp = rsrpTag.RSRP;
+ continue;
+ }
+
+ if (tag != null && tag is SNRTag)
+ {
+ SNRTag snrTag = (SNRTag)tag;
+ snr = snrTag.SNR;
+ continue;
+ }
+
+ if (tag != null && tag is SystemDateTag)
+ {
+ SystemDateTag systemDateTag = (SystemDateTag)tag;
+ collectDate = systemDateTag.CollectDate;
+ continue;
+ }
+
+ if (tag != null && tag is SensorException0Tag)
+ {
+ SensorException0Tag sensorException0 = tag as SensorException0Tag;
+ int state = sensorException0.state;
+
+ if (state == 0) continue;
+
+ eventList.Add(getHydrogenSulfideAlarm(state));
+
+ session.Logger.Info("通道一发送容错信息：oid：" + tag.Oid + ";value:" + state);
+ continue;
+ }
+
+ if (tag != null && tag is SensorStartupTag)
+ {
+ SensorStartupTag sensorStartup = tag as SensorStartupTag;
+ String imei = sensorStartup.IMEI;
+ String iccid = sensorStartup.ICCID;
+
+ startupList.Add(imei);
+ startupList.Add(iccid);
+
+ session.Logger.Info("设备开机上报，设备编号DEVCODE：" + devCode + " IMEI:" + imei + " ICCID:" + iccid);
+ continue;
+ }
+
+ //非业务处理
+ if (tag != null && tag is SoftwareVersionTag)
+ {
+ SoftwareVersionTag versionTag = (SoftwareVersionTag)tag;
+ softwareVersion = versionTag.Version;
+ continue;
+ }
+
+ if (tag != null && tag is OffsetTag)
+ {
+ OffsetTag offsetTag = (OffsetTag)tag;
+ offset = offsetTag.Offset;
+ continue;
+ }
+
+ if (tag != null && tag is SizeTag)
+ {
+ SizeTag sizeTag = (SizeTag)tag;
+ size = sizeTag.Size;
+ continue;
+ }
+ }
+ else
+ {
+ //业务处理
+ UploadTag uploadTag = tag as UploadTag;
+ switch (uploadTag.BizType)
+ {
+ case 5:
+ //气体浓度
+ TagHandler pWatcherHandler = new HydrogenSulfideTagHandler();
+ pWatcherHandler.resolve(tag, session);
+
+ DateTime baseTime = Convert.ToDateTime(collectDate + " " + pWatcherHandler.CollecTime);
+ for (int i = 0; i < pWatcherHandler.DataList.Count; i++)
+ {
+ DateTime upTime = baseTime.AddMinutes(i * pWatcherHandler.Interval);
+ String uptime = upTime.ToString("yyyy") + upTime.ToString("MM") + upTime.ToString("dd")
+ + upTime.ToString("HH") + upTime.ToString("mm") + upTime.ToString("ss");
+
+ datasList.Add(new HydrogenSulfideDatasJson(uptime, (float)pWatcherHandler.DataList[i]));
+ }
+
+ break;
+ default:
+ session.Logger.Info("未知业务类型！");
+ break;
+ }
+ }
+ }
+
+ // Common.sendMessage(session, devName, devCode, cell, pci, rsrp, snr, eventList, datasList, startupList);
+ Common.kafkaProduce(session, devName, devCode, cell, pci, rsrp, snr, eventList, datasList, startupList);
+
+ if (softwareVersion != "" || size != 0 || offset != 0)//进入远程升级流程
+ {
+ Common.remoteUpgrade(session, operType, devName, devCode, btPdu, softwareVersion, size, offset, source);
+ return;
+ }
+ }
+
+ Common.sendConfig(session, devCode, routeFlag, source, btPdu);
+ }
+
+ private String getHydrogenSulfideAlarm(int state)
+ {
+ switch (state)
+ {
+ case 0:
+ return "HydrogenSulfideNormal";// 硫化氢正常
+ case 1:
+ return "HydrogenSulfideCommunicationFailure"; // 传感器通信失败 采集失败
+ case 2:
+ return "HydrogenSulfideError"; // 硫化氢传感器异常
+ default:
+ return "HydrogenSulfideUnknown"; // 管盯未知异常
+
+ }
+ }
+ }
+}
diff --git a/SensorHub.HydrogenSulfide/App.config b/SensorHub.HydrogenSulfide/App.config
new file mode 100644
index 0000000..8e15646
--- /dev/null
+++ b/SensorHub.HydrogenSulfide/App.config
@@ -0,0 +1,6 @@
+
+
+
+
+
+
\ No newline at end of file
diff --git a/SensorHub.HydrogenSulfide/HydrogenSulfide.cs b/SensorHub.HydrogenSulfide/HydrogenSulfide.cs
new file mode 100644
index 0000000..8691d2f
--- /dev/null
+++ b/SensorHub.HydrogenSulfide/HydrogenSulfide.cs
@@ -0,0 +1,223 @@
+using SensorHub.Servers;
+using SensorHub.Servers.Commands.CASICCommands;
+using SensorHub.Servers.JsonFormat;
+using SuperSocket.SocketBase.Command;
+using SuperSocket.SocketBase.Protocol;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+
+namespace SensorHub.HydrogenSulfide
+{
+ public class HydrogenSulfide : CommandBase
+ {
+ public override void ExecuteCommand(CasicSession session, StringRequestInfo requestInfo)
+ {
+ //TODO: construct the receving casic data
+ String preamble = requestInfo.Parameters[0];
+ String version = requestInfo.Parameters[1];
+ String leng = requestInfo.Parameters[2];
+ String devCode = requestInfo.Parameters[3];
+ String routeFlag = requestInfo.Parameters[4];
+ String dstNodeAddr = requestInfo.Parameters[5];
+ String pduType = requestInfo.Parameters[6];
+ String seq = requestInfo.Parameters[7];
+ String settings = requestInfo.Parameters[8];
+ String source = requestInfo.Parameters[9];
+ String exist = requestInfo.Parameters[10];
+
+ String devName = "HydrogenSulfide";
+
+ if (source.Contains("-"))
+ {
+ session.Send("HTTP/1.1 200 OK\r\n\r\n\r\n");
+ session.Close();
+ }
+
+ //print the receving data
+ String devType = "硫化氢监测终端";
+ String operType = Common.getOpeTypeByPdu(pduType);
+ session.Logger.Info("AD接收数据:" + requestInfo.Body);
+ session.Logger.Info("设备类型:" + devType);
+ session.Logger.Info("操作类型:" + operType);
+ session.Logger.Info("会话:" + session.HubAddr + "," + session.SessionID);
+
+ byte[] btPdu = new byte[2]; //2个字节
+ btPdu[0] = Common.getRespOperType(operType, source == "433" ? true : false);
+ btPdu[1] = 0x9E; // 最高位=1表示不拆包; 0x1E = 30 表示设备类型=30
+
+ if (exist == "0")//数据没有缓存
+ {
+ //判断是返回的设置确认数据帧, 回复第三方
+ if (operType == "SetResponse")
+ {
+ Common.sendSetResponse(session, devCode, "HydrogenSulfide");
+ return;
+ }
+
+ //获取电量信息，系统时间，传递给对应的handler
+ List tags = Common.getTags(settings, session);
+
+ //具体业务处理
+ String collectDate = "";
+ int cell = -1;
+ int? pci = null;
+ int? rsrp = null;
+ int? snr = null;
+
+ String softwareVersion = "";
+ uint offset = 0;
+ uint size = 0;
+
+ List eventList = new List();
+ List datasList = new List();
+ List startupList = new List();
+
+ foreach (Tag tag in tags)
+ {
+ if (!(tag is UploadTag))
+ {
+ //非业务处理
+ if (tag != null && tag is CellTag)
+ {
+ CellTag cellTag = (CellTag)tag;
+ cell = cellTag.Cell;
+ continue;
+ }
+
+ if (tag != null && tag is PCITag)
+ {
+ PCITag pciTag = (PCITag)tag;
+ pci = pciTag.PCI;
+ continue;
+ }
+
+ if (tag != null && tag is RSRPTag)
+ {
+ RSRPTag rsrpTag = (RSRPTag)tag;
+ rsrp = rsrpTag.RSRP;
+ continue;
+ }
+
+ if (tag != null && tag is SNRTag)
+ {
+ SNRTag snrTag = (SNRTag)tag;
+ snr = snrTag.SNR;
+ continue;
+ }
+
+ if (tag != null && tag is SystemDateTag)
+ {
+ SystemDateTag systemDateTag = (SystemDateTag)tag;
+ collectDate = systemDateTag.CollectDate;
+ continue;
+ }
+
+ if (tag != null && tag is SensorException0Tag)
+ {
+ SensorException0Tag sensorException0 = tag as SensorException0Tag;
+ int state = sensorException0.state;
+
+ if (state == 0) continue;
+
+ eventList.Add(getHydrogenSulfideAlarm(state));
+
+ session.Logger.Info("通道一发送容错信息：oid：" + tag.Oid + ";value:" + state);
+ continue;
+ }
+
+ if (tag != null && tag is SensorStartupTag)
+ {
+ SensorStartupTag sensorStartup = tag as SensorStartupTag;
+ String imei = sensorStartup.IMEI;
+ String iccid = sensorStartup.ICCID;
+
+ startupList.Add(imei);
+ startupList.Add(iccid);
+
+ session.Logger.Info("设备开机上报，设备编号DEVCODE：" + devCode + " IMEI:" + imei + " ICCID:" + iccid);
+ continue;
+ }
+
+ //非业务处理
+ if (tag != null && tag is SoftwareVersionTag)
+ {
+ SoftwareVersionTag versionTag = (SoftwareVersionTag)tag;
+ softwareVersion = versionTag.Version;
+ continue;
+ }
+
+ if (tag != null && tag is OffsetTag)
+ {
+ OffsetTag offsetTag = (OffsetTag)tag;
+ offset = offsetTag.Offset;
+ continue;
+ }
+
+ if (tag != null && tag is SizeTag)
+ {
+ SizeTag sizeTag = (SizeTag)tag;
+ size = sizeTag.Size;
+ continue;
+ }
+ }
+ else
+ {
+ //业务处理
+ UploadTag uploadTag = tag as UploadTag;
+ switch (uploadTag.BizType)
+ {
+ case 5:
+ //气体浓度
+ TagHandler pWatcherHandler = new HydrogenSulfideTagHandler();
+ pWatcherHandler.resolve(tag, session);
+
+ DateTime baseTime = Convert.ToDateTime(collectDate + " " + pWatcherHandler.CollecTime);
+ for (int i = 0; i < pWatcherHandler.DataList.Count; i++)
+ {
+ DateTime upTime = baseTime.AddMinutes(i * pWatcherHandler.Interval);
+ String uptime = upTime.ToString("yyyy") + upTime.ToString("MM") + upTime.ToString("dd")
+ + upTime.ToString("HH") + upTime.ToString("mm") + upTime.ToString("ss");
+
+ datasList.Add(new HydrogenSulfideDatasJson(uptime, (float)pWatcherHandler.DataList[i]));
+ }
+
+ break;
+ default:
+ session.Logger.Info("未知业务类型！");
+ break;
+ }
+ }
+ }
+
+ // Common.sendMessage(session, devName, devCode, cell, pci, rsrp, snr, eventList, datasList, startupList);
+ Common.kafkaProduce(session, devName, devCode, cell, pci, rsrp, snr, eventList, datasList, startupList);
+
+ if (softwareVersion != "" || size != 0 || offset != 0)//进入远程升级流程
+ {
+ Common.remoteUpgrade(session, operType, devName, devCode, btPdu, softwareVersion, size, offset, source);
+ return;
+ }
+ }
+
+ Common.sendConfig(session, devCode, routeFlag, source, btPdu);
+ }
+
+ private String getHydrogenSulfideAlarm(int state)
+ {
+ switch (state)
+ {
+ case 0:
+ return "HydrogenSulfideNormal";// 硫化氢正常
+ case 1:
+ return "HydrogenSulfideCommunicationFailure"; // 传感器通信失败 采集失败
+ case 2:
+ return "HydrogenSulfideError"; // 硫化氢传感器异常
+ default:
+ return "HydrogenSulfideUnknown"; // 管盯未知异常
+
+ }
+ }
+ }
+}
diff --git a/SensorHub.HydrogenSulfide/HydrogenSulfideDatasJson.cs b/SensorHub.HydrogenSulfide/HydrogenSulfideDatasJson.cs
new file mode 100644
index 0000000..8160915
--- /dev/null
+++ b/SensorHub.HydrogenSulfide/HydrogenSulfideDatasJson.cs
@@ -0,0 +1,20 @@
+using SensorHub.Servers.JsonFormat;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace SensorHub.HydrogenSulfide
+{
+ class HydrogenSulfideDatasJson : DatasJson
+ {
+ public float hs { get; set; } // 硫化氢气体浓度值
+
+ public HydrogenSulfideDatasJson(string uptime, float hs)
+ {
+ this.uptime = uptime;
+ this.hs = hs;
+ }
+ }
+}
diff --git a/SensorHub.HydrogenSulfide/App.config b/SensorHub.HydrogenSulfide/App.config
new file mode 100644
index 0000000..8e15646
--- /dev/null
+++ b/SensorHub.HydrogenSulfide/App.config
@@ -0,0 +1,6 @@
+
+
+
+
+
+
\ No newline at end of file
diff --git a/SensorHub.HydrogenSulfide/HydrogenSulfide.cs b/SensorHub.HydrogenSulfide/HydrogenSulfide.cs
new file mode 100644
index 0000000..8691d2f
--- /dev/null
+++ b/SensorHub.HydrogenSulfide/HydrogenSulfide.cs
@@ -0,0 +1,223 @@
+using SensorHub.Servers;
+using SensorHub.Servers.Commands.CASICCommands;
+using SensorHub.Servers.JsonFormat;
+using SuperSocket.SocketBase.Command;
+using SuperSocket.SocketBase.Protocol;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+
+namespace SensorHub.HydrogenSulfide
+{
+ public class HydrogenSulfide : CommandBase
+ {
+ public override void ExecuteCommand(CasicSession session, StringRequestInfo requestInfo)
+ {
+ //TODO: construct the receving casic data
+ String preamble = requestInfo.Parameters[0];
+ String version = requestInfo.Parameters[1];
+ String leng = requestInfo.Parameters[2];
+ String devCode = requestInfo.Parameters[3];
+ String routeFlag = requestInfo.Parameters[4];
+ String dstNodeAddr = requestInfo.Parameters[5];
+ String pduType = requestInfo.Parameters[6];
+ String seq = requestInfo.Parameters[7];
+ String settings = requestInfo.Parameters[8];
+ String source = requestInfo.Parameters[9];
+ String exist = requestInfo.Parameters[10];
+
+ String devName = "HydrogenSulfide";
+
+ if (source.Contains("-"))
+ {
+ session.Send("HTTP/1.1 200 OK\r\n\r\n\r\n");
+ session.Close();
+ }
+
+ //print the receving data
+ String devType = "硫化氢监测终端";
+ String operType = Common.getOpeTypeByPdu(pduType);
+ session.Logger.Info("AD接收数据:" + requestInfo.Body);
+ session.Logger.Info("设备类型:" + devType);
+ session.Logger.Info("操作类型:" + operType);
+ session.Logger.Info("会话:" + session.HubAddr + "," + session.SessionID);
+
+ byte[] btPdu = new byte[2]; //2个字节
+ btPdu[0] = Common.getRespOperType(operType, source == "433" ? true : false);
+ btPdu[1] = 0x9E; // 最高位=1表示不拆包; 0x1E = 30 表示设备类型=30
+
+ if (exist == "0")//数据没有缓存
+ {
+ //判断是返回的设置确认数据帧, 回复第三方
+ if (operType == "SetResponse")
+ {
+ Common.sendSetResponse(session, devCode, "HydrogenSulfide");
+ return;
+ }
+
+ //获取电量信息，系统时间，传递给对应的handler
+ List tags = Common.getTags(settings, session);
+
+ //具体业务处理
+ String collectDate = "";
+ int cell = -1;
+ int? pci = null;
+ int? rsrp = null;
+ int? snr = null;
+
+ String softwareVersion = "";
+ uint offset = 0;
+ uint size = 0;
+
+ List eventList = new List();
+ List datasList = new List();
+ List startupList = new List();
+
+ foreach (Tag tag in tags)
+ {
+ if (!(tag is UploadTag))
+ {
+ //非业务处理
+ if (tag != null && tag is CellTag)
+ {
+ CellTag cellTag = (CellTag)tag;
+ cell = cellTag.Cell;
+ continue;
+ }
+
+ if (tag != null && tag is PCITag)
+ {
+ PCITag pciTag = (PCITag)tag;
+ pci = pciTag.PCI;
+ continue;
+ }
+
+ if (tag != null && tag is RSRPTag)
+ {
+ RSRPTag rsrpTag = (RSRPTag)tag;
+ rsrp = rsrpTag.RSRP;
+ continue;
+ }
+
+ if (tag != null && tag is SNRTag)
+ {
+ SNRTag snrTag = (SNRTag)tag;
+ snr = snrTag.SNR;
+ continue;
+ }
+
+ if (tag != null && tag is SystemDateTag)
+ {
+ SystemDateTag systemDateTag = (SystemDateTag)tag;
+ collectDate = systemDateTag.CollectDate;
+ continue;
+ }
+
+ if (tag != null && tag is SensorException0Tag)
+ {
+ SensorException0Tag sensorException0 = tag as SensorException0Tag;
+ int state = sensorException0.state;
+
+ if (state == 0) continue;
+
+ eventList.Add(getHydrogenSulfideAlarm(state));
+
+ session.Logger.Info("通道一发送容错信息：oid：" + tag.Oid + ";value:" + state);
+ continue;
+ }
+
+ if (tag != null && tag is SensorStartupTag)
+ {
+ SensorStartupTag sensorStartup = tag as SensorStartupTag;
+ String imei = sensorStartup.IMEI;
+ String iccid = sensorStartup.ICCID;
+
+ startupList.Add(imei);
+ startupList.Add(iccid);
+
+ session.Logger.Info("设备开机上报，设备编号DEVCODE：" + devCode + " IMEI:" + imei + " ICCID:" + iccid);
+ continue;
+ }
+
+ //非业务处理
+ if (tag != null && tag is SoftwareVersionTag)
+ {
+ SoftwareVersionTag versionTag = (SoftwareVersionTag)tag;
+ softwareVersion = versionTag.Version;
+ continue;
+ }
+
+ if (tag != null && tag is OffsetTag)
+ {
+ OffsetTag offsetTag = (OffsetTag)tag;
+ offset = offsetTag.Offset;
+ continue;
+ }
+
+ if (tag != null && tag is SizeTag)
+ {
+ SizeTag sizeTag = (SizeTag)tag;
+ size = sizeTag.Size;
+ continue;
+ }
+ }
+ else
+ {
+ //业务处理
+ UploadTag uploadTag = tag as UploadTag;
+ switch (uploadTag.BizType)
+ {
+ case 5:
+ //气体浓度
+ TagHandler pWatcherHandler = new HydrogenSulfideTagHandler();
+ pWatcherHandler.resolve(tag, session);
+
+ DateTime baseTime = Convert.ToDateTime(collectDate + " " + pWatcherHandler.CollecTime);
+ for (int i = 0; i < pWatcherHandler.DataList.Count; i++)
+ {
+ DateTime upTime = baseTime.AddMinutes(i * pWatcherHandler.Interval);
+ String uptime = upTime.ToString("yyyy") + upTime.ToString("MM") + upTime.ToString("dd")
+ + upTime.ToString("HH") + upTime.ToString("mm") + upTime.ToString("ss");
+
+ datasList.Add(new HydrogenSulfideDatasJson(uptime, (float)pWatcherHandler.DataList[i]));
+ }
+
+ break;
+ default:
+ session.Logger.Info("未知业务类型！");
+ break;
+ }
+ }
+ }
+
+ // Common.sendMessage(session, devName, devCode, cell, pci, rsrp, snr, eventList, datasList, startupList);
+ Common.kafkaProduce(session, devName, devCode, cell, pci, rsrp, snr, eventList, datasList, startupList);
+
+ if (softwareVersion != "" || size != 0 || offset != 0)//进入远程升级流程
+ {
+ Common.remoteUpgrade(session, operType, devName, devCode, btPdu, softwareVersion, size, offset, source);
+ return;
+ }
+ }
+
+ Common.sendConfig(session, devCode, routeFlag, source, btPdu);
+ }
+
+ private String getHydrogenSulfideAlarm(int state)
+ {
+ switch (state)
+ {
+ case 0:
+ return "HydrogenSulfideNormal";// 硫化氢正常
+ case 1:
+ return "HydrogenSulfideCommunicationFailure"; // 传感器通信失败 采集失败
+ case 2:
+ return "HydrogenSulfideError"; // 硫化氢传感器异常
+ default:
+ return "HydrogenSulfideUnknown"; // 管盯未知异常
+
+ }
+ }
+ }
+}
diff --git a/SensorHub.HydrogenSulfide/HydrogenSulfideDatasJson.cs b/SensorHub.HydrogenSulfide/HydrogenSulfideDatasJson.cs
new file mode 100644
index 0000000..8160915
--- /dev/null
+++ b/SensorHub.HydrogenSulfide/HydrogenSulfideDatasJson.cs
@@ -0,0 +1,20 @@
+using SensorHub.Servers.JsonFormat;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace SensorHub.HydrogenSulfide
+{
+ class HydrogenSulfideDatasJson : DatasJson
+ {
+ public float hs { get; set; } // 硫化氢气体浓度值
+
+ public HydrogenSulfideDatasJson(string uptime, float hs)
+ {
+ this.uptime = uptime;
+ this.hs = hs;
+ }
+ }
+}
diff --git a/SensorHub.HydrogenSulfide/HydrogenSulfideTagHandler.cs b/SensorHub.HydrogenSulfide/HydrogenSulfideTagHandler.cs
new file mode 100644
index 0000000..0130a23
--- /dev/null
+++ b/SensorHub.HydrogenSulfide/HydrogenSulfideTagHandler.cs
@@ -0,0 +1,64 @@
+using SensorHub.Servers;
+using SensorHub.Servers.Commands.CASICCommands;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace SensorHub.HydrogenSulfide
+{
+ class HydrogenSulfideTagHandler : TagHandler
+ {
+ public override bool isThisTag(Tag tag)
+ {
+ if (!(tag is UploadTag))
+ {
+ return false;
+ }
+
+ UploadTag uploadTag = tag as UploadTag;
+
+ return uploadTag.BizType == 5 ? true : false;
+ }
+
+ public override void resolve(Tag tag, CasicSession session)
+ {
+ //TODO LIST:解析数据保存数据
+ UploadTag hsTag = tag as UploadTag;
+ Interval = hsTag.CollectInter;
+ CollecTime = hsTag.CollectTime;
+ int len = hsTag.Len;
+ String dataValue = hsTag.DataValue;
+
+ session.Logger.Info("硫化氢浓度数据上传TAG：oid：" + hsTag.Oid + " 采集间隔: " +
+ Interval + "采集时间：" + CollecTime + "上传数值：" + dataValue);
+
+ DataList = new List