378 lines
16 KiB
C#
378 lines
16 KiB
C#
using HL7toXDocumentParser;
|
||
using System;
|
||
using System.Data;
|
||
using System.Net;
|
||
using System.Net.Sockets;
|
||
using System.ServiceProcess;
|
||
using System.Text;
|
||
using System.Threading;
|
||
using System.Windows.Forms;
|
||
using System.Xml.Linq;
|
||
|
||
namespace HL_FristAidPlatform_POCTWindowsService
|
||
{
|
||
public partial class POCTService : ServiceBase
|
||
{
|
||
#region 变量
|
||
/// <summary>
|
||
/// 同步锁
|
||
/// </summary>
|
||
private static object syncRoot = new object();
|
||
/// <summary>
|
||
/// 日志文件路径
|
||
/// </summary>
|
||
private string logPath = Application.StartupPath + @"\Log";
|
||
|
||
/// <summary>
|
||
/// 日志文件
|
||
/// </summary>
|
||
FileClass fileClass = new FileClass();
|
||
|
||
/// <summary>
|
||
/// 时间格式字符
|
||
/// </summary>
|
||
private string timeToString = "yyyy-MM-dd HH:mm:ss fff";
|
||
/// <summary>
|
||
/// 初始化配置文件
|
||
/// </summary>
|
||
Config config = new Config();
|
||
SqlDBHelper sqlDBHelp = new SqlDBHelper();
|
||
/// <summary>
|
||
/// UDP网络层套接字
|
||
/// </summary>
|
||
static Socket udpSocket;
|
||
/// <summary>
|
||
/// TCP网络层套接字
|
||
/// </summary>
|
||
private static Socket tcpSocket;
|
||
|
||
#endregion
|
||
|
||
public POCTService()
|
||
{
|
||
InitializeComponent();
|
||
InitService();
|
||
}
|
||
private void InitService()
|
||
{
|
||
StarServer(config.StrPort);
|
||
}
|
||
|
||
protected override void OnStart(string[] args)
|
||
{
|
||
MessageAdd(config.ServiceName + "已成功启动!");
|
||
}
|
||
|
||
protected override void OnStop()
|
||
{
|
||
MessageAdd(config.ServiceName + "已停止!");
|
||
}
|
||
|
||
protected override void OnContinue()
|
||
{
|
||
StarServer(config.StrPort);
|
||
}
|
||
/// <summary>
|
||
/// 系统关闭
|
||
/// </summary>
|
||
protected override void OnShutdown()
|
||
{
|
||
base.OnShutdown();
|
||
}
|
||
|
||
private void StarServer(int strPort)
|
||
{
|
||
try
|
||
{
|
||
//点击开始监听时 在服务端创建一个负责监听IP和端口号的Socket
|
||
tcpSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
|
||
IPAddress ip = IPAddress.Any;
|
||
//创建对象端口
|
||
IPEndPoint point = new IPEndPoint(ip, strPort);
|
||
tcpSocket.Bind(point);//绑定端口号
|
||
MessageAdd(string.Format("端口{0}监听成功! {1}", strPort, DateTime.Now.ToString(timeToString)));
|
||
tcpSocket.Listen(100);//设置监听
|
||
//创建监听线程
|
||
Thread thread = new Thread(Listen);
|
||
thread.IsBackground = true;
|
||
thread.Start(tcpSocket);
|
||
|
||
////UDP接受消息
|
||
//udpSocket = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
|
||
////udpSocket.Bind(new IPEndPoint(IPAddress.Parse("192.168.1.113"), strPort));
|
||
//udpSocket.Bind(new IPEndPoint(IPAddress.Any, strPort));
|
||
//MessageAdd(string.Format("UDP端口{0}监听成功! {1}", strPort, DateTime.Now.ToString(timeToString)));
|
||
//Thread t = new Thread(ReciveMsg);
|
||
//t.Start();
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
MessageAdd(string.Format("错误：端口{0}监听失败! {1},详细信息如下：\r\n{2}", strPort, DateTime.Now.ToString(timeToString), ex));
|
||
}
|
||
}
|
||
Socket socketSend;
|
||
private void Listen(object o)
|
||
{
|
||
try
|
||
{
|
||
Socket socketWatch = o as Socket;
|
||
socketSend = socketWatch.Accept();
|
||
MessageAdd(socketSend.RemoteEndPoint.ToString() + ":" + "连接成功!" + " " + DateTime.Now.ToString(timeToString));
|
||
|
||
//开启一个新线程，执行接收消息方法
|
||
Thread r_thread = new Thread(Received);
|
||
r_thread.IsBackground = true;
|
||
r_thread.Start(socketSend);
|
||
}
|
||
catch (Exception)
|
||
{
|
||
throw;
|
||
}
|
||
|
||
}
|
||
|
||
/// <summary>
|
||
/// 接收发送给本机ip对应端口号的数据报
|
||
/// </summary>
|
||
private void ReciveMsg()
|
||
{
|
||
while (true)
|
||
{
|
||
MessageAdd("UDP线程启动");
|
||
EndPoint point = new IPEndPoint(IPAddress.Any, 0);//用来保存发送方的ip和端口号
|
||
byte[] buffer = new byte[1024];
|
||
int length = udpSocket.ReceiveFrom(buffer, ref point);//接收数据报
|
||
string str = Encoding.ASCII.GetString(buffer, 0, length);
|
||
MessageAdd("UDP接受消息：" + point.ToString() + str);
|
||
//时间统一
|
||
DateTime RecordingTime = DateTime.Now;
|
||
string[] sHL7Lines = str.Split('\r');
|
||
MessageAdd(" 接收时间【 " + RecordingTime.ToString() + "】" + str);
|
||
if (sHL7Lines.Length > 3)
|
||
{
|
||
//数据处理
|
||
DataProcessing(str, RecordingTime);
|
||
}
|
||
}
|
||
}
|
||
|
||
/// <summary>
|
||
/// 服务器端不停的接收客户端发来的消息
|
||
/// </summary>
|
||
/// <param name="o"></param>
|
||
private void Received(object o)
|
||
{
|
||
try
|
||
{
|
||
Socket socketSend = o as Socket;
|
||
while (true)
|
||
{
|
||
DateTime RecordingTime = DateTime.Now;
|
||
//客户端连接服务器成功后，服务器接收客户端发送的消息
|
||
byte[] buffer = new byte[1024];
|
||
//实际接收到的有效字节数
|
||
int len = socketSend.Receive(buffer, buffer.Length, 0);
|
||
string str = "";
|
||
str += Encoding.UTF8.GetString(buffer, 0, len);
|
||
if (str.Contains("PID"))
|
||
{
|
||
str = str.Replace("\v", "");
|
||
MessageAdd(" 接收时间【 " + RecordingTime.ToString() + "】" + str);
|
||
Parser parser = new Parser();
|
||
XDocument xML = new XDocument();
|
||
xML = parser.Parse(str);
|
||
if (xML.Root.Element("PID") != null)
|
||
{
|
||
MessageAdd(xML.ToString());
|
||
//数据处理
|
||
DataProcessing(xML, RecordingTime);
|
||
}
|
||
}
|
||
}
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
MessageAdd(string.Format("错误：{0}:接收信息失败! {1},详细信息如下：\r\n{2}", socketSend.RemoteEndPoint, DateTime.Now.ToString(timeToString), ex));
|
||
}
|
||
}
|
||
/// <summary>
|
||
/// 开始数据处理
|
||
/// </summary>
|
||
/// <param name="dataStr">接收的字符</param>
|
||
/// <param name="time">时间:统一各步骤时间</param>
|
||
private void DataProcessing(string dataStr, DateTime time)
|
||
{
|
||
string resultStr = "";
|
||
//开始数据处理
|
||
if (!string.IsNullOrEmpty(dataStr))
|
||
{
|
||
string[] sHL7Lines = dataStr.Split('\r');
|
||
//单项目结果
|
||
if (sHL7Lines.Length == 10)
|
||
{
|
||
//病人信息
|
||
string[] PIDValueStr = sHL7Lines[1].Split('|');
|
||
string name = PIDValueStr[4].ToString();//姓名
|
||
//POCT结果
|
||
string[] OBXValueStr = sHL7Lines[3].Split('|');
|
||
string itemName = OBXValueStr[4].ToString();//项目名称
|
||
string result = OBXValueStr[5].ToString();//结果
|
||
string unit = OBXValueStr[6].ToString();//单位
|
||
string referenceRanges = OBXValueStr[7].ToString();//参考值范围
|
||
string notNormal = OBXValueStr[8].ToString();//不正常标记
|
||
string checkTime = OBXValueStr[14] + "";//检查时间
|
||
resultStr ="姓名"+ name +" 项目名称"+ itemName + " 项目结果" + result + " 检查时间" + checkTime+ " 参考值范围" + referenceRanges;
|
||
MessageAdd(resultStr);
|
||
Update(name, itemName, result, checkTime);
|
||
}
|
||
//肌钙三项结果
|
||
if (sHL7Lines.Length == 7)
|
||
{
|
||
string name = "";
|
||
for (int i = 0; i < sHL7Lines.Length; i++)
|
||
{
|
||
if (i==1)
|
||
{
|
||
string[] PIDValueStr = sHL7Lines[1].Split('|');
|
||
name = PIDValueStr[5].ToString();//姓名
|
||
}
|
||
if (i == 3)
|
||
{
|
||
//POCT cTnI结果
|
||
string[] OBXValueStr = sHL7Lines[3].Split('|');
|
||
string itemName = OBXValueStr[4].ToString();//项目名称
|
||
string result = OBXValueStr[5].ToString();//结果
|
||
string unit = OBXValueStr[6].ToString();//单位
|
||
string referenceRanges = OBXValueStr[7].ToString();//参考值范围
|
||
string notNormal = OBXValueStr[8].ToString();//不正常标记
|
||
string checkTime = OBXValueStr[14] + "";//检查时间
|
||
Update(name, itemName, result, checkTime);
|
||
}
|
||
if (i == 4)
|
||
{
|
||
//POCT CK-MB结果
|
||
string[] OBXValueStr = sHL7Lines[3].Split('|');
|
||
string itemName = OBXValueStr[4].ToString();//项目名称
|
||
string result = OBXValueStr[5].ToString();//结果
|
||
string unit = OBXValueStr[6].ToString();//单位
|
||
string referenceRanges = OBXValueStr[7].ToString();//参考值范围
|
||
string notNormal = OBXValueStr[8].ToString();//不正常标记
|
||
string checkTime = OBXValueStr[14] + "";//检查时间
|
||
Update(name, itemName, result, checkTime);
|
||
}
|
||
if (i == 5)
|
||
{
|
||
//POCT Myo结果
|
||
string[] OBXValueStr = sHL7Lines[3].Split('|');
|
||
string itemName = OBXValueStr[4].ToString();//项目名称
|
||
string result = OBXValueStr[5].ToString();//结果
|
||
string unit = OBXValueStr[6].ToString();//单位
|
||
string referenceRanges = OBXValueStr[7].ToString();//参考值范围
|
||
string notNormal = OBXValueStr[8].ToString();//不正常标记
|
||
string checkTime = OBXValueStr[14] + "";//检查时间
|
||
Update(name, itemName, result, checkTime);
|
||
}
|
||
}
|
||
}
|
||
}
|
||
else
|
||
{
|
||
}
|
||
}
|
||
/// <summary>
|
||
/// xml方式处理数据
|
||
/// </summary>
|
||
/// <param name="document">xml文档</param>
|
||
/// <param name="time">时间</param>
|
||
private void DataProcessing(XDocument document, DateTime time)
|
||
{
|
||
string resultStr = "";
|
||
//病人信息
|
||
string name = document.Root.Element("PID").Element("PID.5").Value;//姓名
|
||
//开始数据处理
|
||
foreach (XElement item in document.Root.Elements("OBX"))
|
||
{
|
||
//POCT结果
|
||
string itemName = item.Element("OBX.4").Value; //项目名称
|
||
string result = item.Element("OBX.5").Value;//结果
|
||
string unit = item.Element("OBX.6").Value;//单位
|
||
string referenceRanges = item.Element("OBX.7").Value;//参考值范围
|
||
string checkTime = item.Element("OBX.14").Value;//检查时间
|
||
resultStr = "姓名" + name + " 项目名称" + itemName + " 项目结果" + result + " 检查时间" + checkTime + " 参考值范围" + referenceRanges;
|
||
MessageAdd(resultStr);
|
||
Update(name, itemName, result, checkTime);
|
||
}
|
||
}
|
||
/// <summary>
|
||
/// 日志记录
|
||
/// </summary>
|
||
/// <param name="serviceName">内容</param>
|
||
public void MessageAdd(string str)
|
||
{
|
||
try
|
||
{
|
||
fileClass.WriteLogFile(logPath, str);//写入记录日志
|
||
}
|
||
catch
|
||
{
|
||
|
||
}
|
||
}
|
||
/// <summary>
|
||
/// 更新
|
||
/// </summary>
|
||
/// <param name="name"></param>
|
||
/// <param name="itemName"></param>
|
||
/// <param name="result"></param>
|
||
public void Update(string name,string itemName,string result,string time)
|
||
{
|
||
try
|
||
{
|
||
DataTable PatientDT = new DataTable();
|
||
string SqlStr = @"select top 1 GUID from T_Service_Patient where Name='{0}' order by ID desc";
|
||
SqlStr = string.Format(SqlStr, name);
|
||
PatientDT = sqlDBHelp.GetDT(SqlStr, config.StrCon);
|
||
if (PatientDT!=null)
|
||
{
|
||
if (itemName.ToUpper() == "CTNI")
|
||
{
|
||
sqlDBHelp.DoCom(@"update T_Service_ChestPain_CTNT set Value='" + result + "',Report_Time='" + time + "' where PatientGuid='" + PatientDT.Rows[0][0].ToString() + "'", config.StrCon);
|
||
}
|
||
if (itemName.ToUpper() == "CK-MB")
|
||
{
|
||
sqlDBHelp.DoCom(@"update T_Service_ChestPain_TreatmentInfo set CKMB_Value='" + result + "',Report_Time='" + time + "' where PatientGuid='" + PatientDT.Rows[0][0].ToString() + "'", config.StrCon);
|
||
}
|
||
if (itemName.ToUpper() == "MYO")
|
||
{
|
||
sqlDBHelp.DoCom(@"update T_Service_ChestPain_TreatmentInfo set MYO_Value='" + result + "',Report_Time='" + time + "' where PatientGuid='" + PatientDT.Rows[0][0].ToString() + "'", config.StrCon);
|
||
}
|
||
if (itemName.ToUpper() == "NT-PROBNP")
|
||
{
|
||
sqlDBHelp.DoCom(@"update T_Service_ChestPain_TreatmentInfo set NTproBNP_Value='" + result + "',Report_Time='" + time + "' where PatientGuid='" + PatientDT.Rows[0][0].ToString() + "'", config.StrCon);
|
||
}
|
||
if (itemName.ToUpper() == "BNP")
|
||
{
|
||
sqlDBHelp.DoCom(@"update T_Service_ChestPain_TreatmentInfo set BNP_Value='" + result + "',Report_Time='" + time + "' where PatientGuid='" + PatientDT.Rows[0][0].ToString() + "'", config.StrCon);
|
||
}
|
||
if (itemName.ToUpper() == "D-Dimer")
|
||
{
|
||
sqlDBHelp.DoCom(@"update T_Service_ChestPain_TreatmentInfo set Ddimer_Value='" + result + "',Report_Time='" + time + "' where PatientGuid='" + PatientDT.Rows[0][0].ToString() + "'", config.StrCon);
|
||
}
|
||
if (itemName.ToUpper() == "PCT")
|
||
{
|
||
|
||
}
|
||
if (itemName.ToUpper() == "CRP")
|
||
{
|
||
|
||
}
|
||
}
|
||
}
|
||
catch (Exception e)
|
||
{
|
||
MessageAdd(string.Format("更新数据库错误：{0} 时间: {1}", e.Message.ToString(), DateTime.Now.ToString(timeToString)));
|
||
}
|
||
}
|
||
}
|
||
}
|