using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using Microsoft.Practices.EnterpriseLibrary.Data;
using System.Data;
using System.Data.Common;
using System.Transactions;
using System.Text.RegularExpressions;
using System.Management;
using IL.Common;
using MediII.Adapter.ReceiveToScanModel;
namespace MediII.Adapter.BizComponent.ADT
{
///
///
///
public abstract class ADTHandler
{
static readonly string SEDING_APPLICATION = System.Configuration.ConfigurationManager.AppSettings["SedingApplication"];
//数据库连接
protected Database ctx;
///
///
///
public ADTHandler()
{
DatabaseProviderFactory factory = new DatabaseProviderFactory();
ctx = factory.CreateDefault();
}
protected string GetZone(string value)
{
string sql = @"SELECT Zone FROM HealthCare.dbo.HisInfo WHERE HisZone = @HisZone";
var command1 = ctx.GetSqlStringCommand(sql.ToString());
ctx.AddInParameter(command1, "HisZone", System.Data.DbType.AnsiString, value);
DataTable dt = ctx.ExecuteDataSet(command1).Tables[0];
string ZONE = "";
if (dt.Rows.Count > 0)
{
ZONE = dt.Rows[0]["Zone"].ToString();
}
return ZONE;
}
///
/// 根据事件类型获取不同的处理类
///
/// 消息类型
/// ADTHandler的子类
public static ADTHandler GetHandler(string evntType)
{
try
{
switch (evntType)
{
case "ADT^A01": return new ADT_A01_Handler();// 住院患者
case "ADT^A02": return new ADT_A02_Handler();//住院更新
case "ADT^A05": return new ADT_A05_Handler();//门诊患者更新
case "ADT^A04": return new ADT_A04_Handler();// 门诊患者入院
//case "A08": return new ADT_A08_Handler();//患者信息修改：
//case "A10": return new ADT_A10_Handler();//入科
//case "A11": return new ADT_A11_Handler();//取消入院
//case "A13": return new ADT_A13_Handler();//取消出院（ADT^A13）
//case "A16": return new ADT_A16_Handler();//患者预出院
//case "A25": return new ADT_A25_Handler();//患者取消预出院
//case "A28": return new ADT_A28_Handler();//患者建档
//case "A31": return new ADT_A31_Handler();//患者基本信息修改（ADT^A31）
//case "A29": return new ADT_A29_Handler();//删除婴儿信息(ADT^A29^ADT_A21)
//case "A54": return new ADT_A54_Handler();//修改主治医生
//case "A60": return new ADT_A60_Handler();//患者副作用信息修改
default: throw new NotImplementedException();
}
}
catch (Exception ex)
{
LogHelper.LogError(ex, LogCatagories.General);
throw ex;
}
}
///
/// 待实现的处理
///
/// 传入的消息结构
/// ACK
public abstract void Handler(string m);
#region 获取字典信息
///
/// 获取字典信息
///
///
protected DataTable GetDictionView(Database ctx, string viewName)
{
var ntb = new DataTable();
var sql = string.Format("SELECT CodeID,CodeName,HisCodeID,MedCodeID FROM HealthCare.dbo.[{0}] WHERE IsDel=0", viewName);
var cmd = SqlDataAccess.GetSqlStringCommand(ctx, sql);
ntb.Load(SqlDataAccess.ExecuteReader(ctx, cmd));
return ntb;
}
///
/// 获取本地Zone
///
///
///
///
protected string GetZone(Database ctx, string hisZone)
{
var sql = string.Format("SELECT top 1 Zone FROM HealthCare.dbo.HisInfo WHERE HisZone='{0}'", hisZone);
var cmd = SqlDataAccess.GetSqlStringCommand(ctx, sql);
var val = StrHelepr.Obj2StrTrim(SqlDataAccess.ExecuteScalar(ctx, cmd));
if (string.IsNullOrEmpty(val))
{
return hisZone;
}
return val;
}
#endregion
#region 取序列
///
/// 取序列
///
protected string GetSeq(Database ctx, string seqName)
{
string sql = string.Format("SELECT NEXT VALUE FOR {0}", seqName);
var cmd = SqlDataAccess.GetSqlStringCommand(ctx, sql);
object obj = SqlDataAccess.ExecuteScalar(ctx, cmd);
if (obj != null)
return obj.ToString();
else
return "0";
}
#endregion
#region 取服务器当前时间
///
/// 获取当前时间
///
internal DateTime GetNow(Database ctx)
{
object obj = (DateTime)SqlDataAccess.ExecuteScalar(ctx, CommandType.Text, "select GETDATE()");
if (obj != null)
return Convert.ToDateTime(obj.ToString());
else
return DateTime.Now;
}
#endregion
///
/// 添加床位日志
///
/// 数据库操作类
///
///
///
///
///
///
protected void AddNewWardLog(Database ctx, string visitNo, string updateUser, string OperateTypeInstr, string remark, string oldMsg, string newMsg)
{
var sql = @" INSERT INTO HealthCare.dbo.Log_WardOperateLog( VisitNo , UpdateUser , UpdateDateTime , OperateTypeInstr , IP , Mac , Remark , OldContent , NewContent) VALUES( @VisitNo , @UpdateUser , GETDATE() , @OperateTypeInstr , @IP , @Mac , @Remark , @OldContent , @NewContent) ";
var cmd = SqlDataAccess.GetSqlStringCommand(ctx, sql);
SqlDataAccess.AddInParameter(ctx, cmd, "VisitNo", DbType.AnsiString, visitNo);
SqlDataAccess.AddInParameter(ctx, cmd, "UpdateUser", DbType.AnsiString, updateUser);
SqlDataAccess.AddInParameter(ctx, cmd, "OperateTypeInstr", DbType.AnsiString, OperateTypeInstr);
SqlDataAccess.AddInParameter(ctx, cmd, "IP", DbType.AnsiString, NetHelper.GetIP());
SqlDataAccess.AddInParameter(ctx, cmd, "Mac", DbType.AnsiString, NetHelper.GetMacAddress());
SqlDataAccess.AddInParameter(ctx, cmd, "Remark", DbType.AnsiString, remark);
SqlDataAccess.AddInParameter(ctx, cmd, "OldContent", DbType.AnsiString, oldMsg);
SqlDataAccess.AddInParameter(ctx, cmd, "NewContent", DbType.AnsiString, newMsg);
SqlDataAccess.ExecuteNonQuery(ctx, cmd);
}
///
/// 获取参数
///
///
///
///
protected string GetParam(Database ctx, string key)
{
try
{
var sql = string.Format("SELECT ParamValue FROM HealthCare.dbo.SiteParamCtrl WHERE SiteNo='0000' AND ParamID='{0}' AND IsDel=0", key);
var cmd = SqlDataAccess.GetSqlStringCommand(ctx, sql);
var obj = SqlDataAccess.ExecuteScalar(ctx, cmd);
return StrHelepr.Obj2StrTrim(obj);
}
catch (Exception ex)
{
IL.Common.LogHelper.LogError(string.Format("获取参数错误:{0} {1}\r\n{2}", key, ex.Message, ex.StackTrace), LogCatagories.MQAccess);
return string.Empty;
}
}
protected int GetScanTaskCount(string visitNo,string type)
{
var sql = "SELECT count(1) FROM dbo.HL7_Scan WITH(NOLOCK) WHERE VisitNo=@VisitNo and TaskType=@TaskType and TaskStatus=1 and UpdateTime>'2023-01-01'";
var cmd = ctx.DBGetSqlStringCommand(sql);
ctx.AddInParameter(cmd, "VisitNo", DbType.String, visitNo);
ctx.AddInParameter(cmd, "TaskType", DbType.String, type);
var obj = int.Parse(StrHelepr.Obj2StrTrim(ctx.DBExecuteScalar(cmd)));
return obj;
}
}
}