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.ReceiveToKCModel; namespace MediII.Adapter.BizComponent.ADT { /// /// /// public abstract class ADTHandler { static readonly string SEDING_APPLICATION = System.Configuration.ConfigurationManager.AppSettings["SedingApplication"]; //数据库连接 protected Database ctx; protected Database Scanctx; /// /// /// public ADTHandler() { DatabaseProviderFactory factory = new DatabaseProviderFactory(); ctx = factory.Create("HealthCare"); Scanctx = 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[B01]": return new ADT_A01B01_Handler();// 住院就诊信息登记、相关明细任务生成 case "ADT^A01[B02]": return new ADT_A01B02_Handler();// 住院处方单 case "ADT^A01[B03]": return new ADT_A01B03_Handler();// 住院收费明细 case "ADT^A01[B04]": return new ADT_A01B04_Handler();// 住院转科转床 case "ADT^A02[B01]": return new ADT_A02B01_Handler();// 住院就诊信息登记、判断是否出院并生成明细任务 //case "ADT^A02[B02]": return new ADT_A02B02_Handler();// 门诊收费明细更新 //case "ADT^A02[B03]": return new ADT_A02B03_Handler();// 门诊挂号更新 //case "A03": return new ADT_A03_Handler();//出院(ADT^A03) case "ADT^A04[B01]": return new ADT_A04B01_Handler();// 门诊处方单 case "ADT^A04[B02]": return new ADT_A04B02_Handler();//门诊收费明细 case "ADT^A04[B03]": return new ADT_A04B03_Handler();//门诊挂号 //case "ADT^A05[B01]": return new ADT_A02B01_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, string ID); #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); } #region "患者建档(ADT^A28)消息规范" /// /// 检查是否建档 /// /// /// /// protected int HasPatient(string chartNo) { try { var sql = " select count(1) from HealthCare.dbo.Patient where ChartNo=@ChartNo "; var cmd = SqlDataAccess.GetSqlStringCommand(ctx, sql); SqlDataAccess.AddInParameter(ctx, cmd, "ChartNo", DbType.AnsiString, chartNo); return int.Parse(StrHelepr.Obj2StrTrim(SqlDataAccess.ExecuteScalar(ctx, cmd))); //病患是否建档 } catch (Exception ex) { throw ex; } } /// /// 建档 /// /// /// /// //protected void AddNewPatient(Database ctx, ADT_A05 m05 = null, ADT_A01 m01 = null) //{ // PID pid = null; // PV1 pv1 = null; // NK1 nk1 = null; // if (null != m05) // { // pid = m05.PID; // pv1 = m05.PV1; // nk1 = m05.GetNK1(0); // } // if (null != m01) // { // pid = m01.PID; // pv1 = m01.PV1; // nk1 = m01.GetNK1(0); // } // AddNewPatient(ctx, pid, pv1, nk1); //} // protected void AddNewPatient(Database ctx, PID pid, PV1 pv1, NK1 nk1) // { // DataRow rowTemp = null; // #region SQL // var sql1 = @"insert into HealthCare.dbo.Patient // (ChartNo, LastNumber,PtName,BirthDay,IdNo,CardNo,Sex, UnBloodType, BloodType,PtType, // DiscountType, EduLevel,JobType,BornFlag,Marriage, TakeMedInfo , SalaryInfo , // Tel1 , Tel2 , EMail, ConName , ConTel , ConTel1Area, ConTel1, ChartWhere, // FirstVisitDate , FirstVisitDivNo, NoPromiseCnt , NoPromiseDate, Private, AgreeUse , BadRecord, // LastVisitDate, CheckUser, CheckTime, UpdateUser , UpdateTime ,NationNo, NationName, WorkplaceZipCode, // HomeZipCode, ConRelationshipNo, ConRelationshipName, ConZipCode, // UnitAdrDesc,AdrAreaName, AdrArea, AdrDesc, // NativeNo,NativeName, // BirthAreaNo,BirthAreaName, // Nationality , NationalityName ,IsSigned,IsBlackList,ConArea,GreenChannelFlag) // Values // (@ChartNo , @LastNumber ,@PtName , @BirthDay , @IdNo , @CardNo , HealthCare.dbo.GetSexCodeIdByHisID(@Sex), // @UnBloodType , @BloodType , @PtType , // @DiscountType, @EduLevel , @JobType , @BornFlag , // HealthCare.dbo.GetMarriageCodeIdByHisID(@Marriage), @TakeMedInfo ,@SalaryInfo , // @Tel1 , @Tel2 , @EMail, @ConName , @ConTel , @ConTel1Area, @ConTel1, @ChartWhere, // GetDate() , @FirstVisitDivNo, @NoPromiseCnt , GetDate(), @Private, @AgreeUse , @BadRecord, // GetDate(), @CheckUser, GetDate(), @UpdateUser , GetDate() ,@NationNo, @NationName, @WorkplaceZipCode, // @HomeZipCode, @ConRelationshipNo, @ConRelationshipName, @ConZipCode, // @UnitAdrDesc, HealthCare.dbo.GetNativeCodeName(HealthCare.dbo.GetMinNativeCodeID(@AdrDesc,5),@AdrDesc),HealthCare.dbo.GetMinNativeCodeID(@AdrDesc,5), @AdrDesc, // HealthCare.dbo.GetMinNativeCodeID(@AdrDesc,5), HealthCare.dbo.GetNativeCodeName(HealthCare.dbo.GetMinNativeCodeID(@AdrDesc,5),@AdrDesc), // HealthCare.dbo.GetMinNativeCodeID(@BirthAreaName,5), HealthCare.dbo.GetNativeCodeName(HealthCare.dbo.GetMinNativeCodeID(@BirthAreaName,5),@AdrDesc), // @Nationality ,@NationalityName,@IsSigned,@IsBlackList,@ConArea,@GreenChannelFlag)"; // #endregion // var command = SqlDataAccess.GetSqlStringCommand(ctx, sql1); // //就诊卡号 // SqlDataAccess.AddInParameter(ctx, command, "ChartNo", DbType.AnsiString, pid.PatientID.ID.Value); // int LastNumberCount = pid.PatientID.ID.Value.Count(); // //最后两码 // if (LastNumberCount <= 2) // { // SqlDataAccess.AddInParameter(ctx, command, "LastNumber", DbType.AnsiString, pid.PatientID.ID.Value); // } // else // { // string LastNumberSubString = pid.PatientID.ID.Value.Substring(LastNumberCount - 2); // SqlDataAccess.AddInParameter(ctx, command, "LastNumber", DbType.AnsiString, LastNumberSubString); // } // //姓名 // SqlDataAccess.AddInParameter(ctx, command, "PtName", DbType.AnsiString, pid.GetPatientName(0).GivenName.Value); // string tmp = pid.DateTimeOfBirth.TimeOfAnEvent.GetAsDate().ToString(); // //出生日期 // SqlDataAccess.AddInParameter(ctx, command, "BirthDay", DbType.DateTime, pid.DateTimeOfBirth.TimeOfAnEvent.GetAsDate()); // //性别 // SqlDataAccess.AddInParameter(ctx, command, "Sex", DbType.AnsiString, pid.AdministrativeSex.Value); // //if (pid.AdministrativeSex.Value == "M") // // SqlDataAccess.AddInParameter(ctx,command, "Sex", DbType.AnsiString, "1"); // //else if (pid.AdministrativeSex.Value == "F") // // SqlDataAccess.AddInParameter(ctx,command, "Sex", DbType.AnsiString, "2"); // //else // // SqlDataAccess.AddInParameter(ctx,command, "Sex", DbType.AnsiString, ""); // SqlDataAccess.AddInParameter(ctx, command, "BirthAreaName", DbType.AnsiString, pid.BirthPlace.Value); // //SqlDataAccess.AddInParameter(ctx, command, "JobType", DbType.AnsiString, pid.GetCitizenship(0).Identifier.Value);his不发职业了 // SqlDataAccess.AddInParameter(ctx, command, "UnBloodType", DbType.AnsiString, ""); // SqlDataAccess.AddInParameter(ctx, command, "BloodType", DbType.AnsiString, ""); // if (pv1.PatientType.Value == "01") // { // SqlDataAccess.AddInParameter(ctx, command, "PtType", DbType.AnsiString, "1"); // } // else // { // SqlDataAccess.AddInParameter(ctx, command, "PtType", DbType.AnsiString, "2"); // } // SqlDataAccess.AddInParameter(ctx, command, "DiscountType", DbType.Int32, 0); // SqlDataAccess.AddInParameter(ctx, command, "EduLevel", DbType.Int32, 0); // SqlDataAccess.AddInParameter(ctx, command, "JobType", DbType.Int32, 0); // SqlDataAccess.AddInParameter(ctx, command, "BornFlag", DbType.AnsiString, "N"); // SqlDataAccess.AddInParameter(ctx, command, "TakeMedInfo", DbType.AnsiString, ""); // SqlDataAccess.AddInParameter(ctx, command, "SalaryInfo", DbType.AnsiString, ""); // #region "联系人" // var nName = nk1.GetName(0); // if (null != nName) // SqlDataAccess.AddInParameter(ctx, command, "ConName", DbType.AnsiString, nName.GivenName.Value); // else // SqlDataAccess.AddInParameter(ctx, command, "ConName", DbType.AnsiString, DBNull.Value); // var nPhone = nk1.GetPhoneNumber(0); // if (null != nPhone) // SqlDataAccess.AddInParameter(ctx, command, "ConTel", DbType.AnsiString, nPhone.PhoneNumber.Value); // else // SqlDataAccess.AddInParameter(ctx, command, "ConTel", DbType.AnsiString, DBNull.Value); // SqlDataAccess.AddInParameter(ctx, command, "ConTel1Area", DbType.AnsiString, "0"); // var nPhone2 = nk1.GetPhoneNumber(1); // if (null != nPhone2) // SqlDataAccess.AddInParameter(ctx, command, "ConTel1", DbType.AnsiString, nPhone2.PhoneNumber.Value); // else // SqlDataAccess.AddInParameter(ctx, command, "ConTel1", DbType.AnsiString, DBNull.Value); // var nAddr = nk1.GetAddress(0); // if (null != nAddr) // SqlDataAccess.AddInParameter(ctx, command, "ConArea", DbType.AnsiString, nAddr.StreetAddress.StreetName.Value); // else // SqlDataAccess.AddInParameter(ctx, command, "ConArea", DbType.AnsiString, DBNull.Value); // #endregion // SqlDataAccess.AddInParameter(ctx, command, "ChartWhere", DbType.AnsiString, "0"); //Todo // //SqlDataAccess.AddInParameter(ctx, command, "FirstVisitDate", DbType.DateTime, DateTime.Now); // SqlDataAccess.AddInParameter(ctx, command, "FirstVisitDivNo", DbType.Int32, "0"); // SqlDataAccess.AddInParameter(ctx, command, "NoPromiseCnt", DbType.Int32, "0"); // //SqlDataAccess.AddInParameter(ctx, command, "NoPromiseDate", DbType.DateTime, DateTime.Now); // SqlDataAccess.AddInParameter(ctx, command, "Private", DbType.AnsiString, ""); // SqlDataAccess.AddInParameter(ctx, command, "AgreeUse", DbType.AnsiString, ""); // SqlDataAccess.AddInParameter(ctx, command, "BadRecord", DbType.AnsiString, ""); // //SqlDataAccess.AddInParameter(ctx, command, "LastVisitDate", DbType.DateTime, DateTime.Now); // SqlDataAccess.AddInParameter(ctx, command, "EMail", DbType.AnsiString, ""); // //2016/01/14 杨燕要求Tel1为空时保存Tel2的数据进入Tel1中 // //家庭电话 // var tel1 = pid.GetPhoneNumberHome(0).PhoneNumber.Value; // if (string.IsNullOrEmpty(tel1) || tel1.Equals("0")) // SqlDataAccess.AddInParameter(ctx, command, "Tel1", DbType.AnsiString, pid.GetPhoneNumberBusiness(0).PhoneNumber.Value); // else // SqlDataAccess.AddInParameter(ctx, command, "Tel1", DbType.AnsiString, pid.GetPhoneNumberHome(0).PhoneNumber.Value); // //单位电话 // if (string.IsNullOrEmpty(pid.GetPhoneNumberBusiness(0).PhoneNumber.Value)) // SqlDataAccess.AddInParameter(ctx, command, "Tel2", DbType.AnsiString, string.Empty); // else // SqlDataAccess.AddInParameter(ctx, command, "Tel2", DbType.AnsiString, pid.GetPhoneNumberBusiness(0).PhoneNumber.Value); // //婚姻代码 // SqlDataAccess.AddInParameter(ctx, command, "Marriage", DbType.AnsiString, pid.MaritalStatus.Identifier.Value); // //医保卡号 // if (string.IsNullOrEmpty(pid.PatientAccountNumber.ID.Value)) // { // SqlDataAccess.AddInParameter(ctx, command, "CardNo", DbType.AnsiString, "0"); // } // else // { // SqlDataAccess.AddInParameter(ctx, command, "CardNo", DbType.AnsiString, pid.PatientAccountNumber.ID.Value); // } // //身分证号 // SqlDataAccess.AddInParameter(ctx, command, "IdNo", DbType.AnsiString, pid.SSNNumberPatient.Value); // #region "地址" // var address = pid.GetPatientAddress(0); // //工作单位 // SqlDataAccess.AddInParameter(ctx, command, "UnitAdrDesc", DbType.AnsiString, address.OtherDesignation.Value ?? string.Empty); // var Adrtmp = address.StreetAddress.StreetOrMailingAddress.Value; // if (string.IsNullOrWhiteSpace(Adrtmp)) // { // SqlDataAccess.AddInParameter(ctx, command, "AdrDesc", DbType.AnsiString, address.OtherDesignation.Value ?? string.Empty); // } // else // //家庭地址 // SqlDataAccess.AddInParameter(ctx, command, "AdrDesc", DbType.AnsiString, address.StreetAddress.StreetOrMailingAddress.Value ?? string.Empty); // ////@家庭地址 // //SqlDataAccess.AddInParameter(ctx, command, "AdrAreaName", DbType.AnsiString, address.StreetAddress.StreetOrMailingAddress.Value ?? string.Empty); // //#region // //var csd = pid.BirthPlace.Value; // ////出生地 BirthAreaName // //if (!string.IsNullOrEmpty(csd)) // //{ // // SqlDataAccess.AddInParameter(ctx, command, "BirthAreaName", DbType.AnsiString, csd); //出生地名称 // //} // //else // //{ // // SqlDataAccess.AddInParameter(ctx, command, "BirthAreaName", DbType.AnsiString, address.StreetAddress.StreetOrMailingAddress.Value ?? string.Empty); //出生地名称 // //} // #endregion // SqlDataAccess.AddInParameter(ctx, command, "CheckUser", DbType.AnsiString, "0");//建档人 // //SqlDataAccess.AddInParameter(ctx, command, "CheckTime", DbType.DateTime, DateTime.Now);//建档日期 // SqlDataAccess.AddInParameter(ctx, command, "UpdateUser", DbType.AnsiString, "0");//修改人 // //SqlDataAccess.AddInParameter(ctx, command, "UpdateTime", DbType.DateTime, DateTime.Now);//修改时间 // var eg = pid.GetEthnicGroup(0); // #region "民族" // var mzcoid = eg.Identifier.Value; // var mzname = eg.Text.Value; // rowTemp = GetDictionView(ctx, "V_Nation").Rows.Cast().Where(n => // StrHelepr.Obj2StrTrim(n["MedCodeID"]) == mzcoid || // StrHelepr.Obj2StrTrim(n["CodeName"]) == mzname).FirstOrDefault(); // //民族V_Nation // if (rowTemp != null) // { // SqlDataAccess.AddInParameter(ctx, command, "NationNo", DbType.AnsiString, StrHelepr.Obj2StrTrim(rowTemp["CodeID"])); // mzname = StrHelepr.Obj2StrTrim(rowTemp["CodeName"]); // } // else // { // SqlDataAccess.AddInParameter(ctx, command, "NationNo", DbType.AnsiString, DBNull.Value); //民族V_Nation // } // SqlDataAccess.AddInParameter(ctx, command, "NationName", DbType.AnsiString, mzname); //民族名称 // #endregion // SqlDataAccess.AddInParameter(ctx, command, "WorkplaceZipCode", DbType.AnsiString, DBNull.Value); //工作单位邮编 // SqlDataAccess.AddInParameter(ctx, command, "HomeZipCode", DbType.AnsiString, address.ZipOrPostalCode.Value); //家庭邮编 // #region 关系人 // var nkId = nk1.Relationship.Identifier.Value; // var nkText = nk1.Relationship.Text.Value; // rowTemp = GetDictionView(ctx, "V_Relationship").Rows.Cast().Where(n => // StrHelepr.Obj2StrTrim(n["MedCodeID"]) == nkId || // StrHelepr.Obj2StrTrim(n["CodeName"]) == nkText).FirstOrDefault(); // if (rowTemp != null) // { // SqlDataAccess.AddInParameter(ctx, command, "ConRelationshipNo", DbType.AnsiString, StrHelepr.Obj2StrTrim(rowTemp["CodeID"])); //关系人关系ID V_Relationship // nkText = StrHelepr.Obj2StrTrim(rowTemp["CodeName"]); // } // else // { // SqlDataAccess.AddInParameter(ctx, command, "ConRelationshipNo", DbType.AnsiString, DBNull.Value); //关系人关系ID V_Relationship // } // SqlDataAccess.AddInParameter(ctx, command, "ConRelationshipName", DbType.AnsiString, nkText); //关系人关系名称 V_Relationship // var gadd = nk1.GetAddress(0); // SqlDataAccess.AddInParameter(ctx, command, "ConZipCode", DbType.AnsiString, gadd.ZipOrPostalCode.Value); //关系人邮编 // #endregion // //#region "AdrArea" // //var area = address.ZipOrPostalCode.Value; // //SqlDataAccess.AddInParameter(ctx, command, "AdrArea", DbType.AnsiString, string.IsNullOrEmpty(address.ZipOrPostalCode.Value) ? "" : address.ZipOrPostalCode.Value);//邮编号 // //#endregion // #region 国籍 // var gj = pid.Nationality.Identifier.Value; // var gjmc = pid.Nationality.Text.Value; // rowTemp = GetDictionView(ctx, "V_Nationality").Rows.Cast().Where(n => // StrHelepr.Obj2StrTrim(n["MedCodeID"]) == gj // || StrHelepr.Obj2StrTrim(n["CodeName"]) == gjmc).FirstOrDefault(); // //国籍代码 // if (rowTemp != null) // { // SqlDataAccess.AddInParameter(ctx, command, "Nationality", DbType.AnsiString, StrHelepr.Obj2StrTrim(rowTemp["CodeID"])); // gjmc = StrHelepr.Obj2StrTrim(rowTemp["CodeName"]); // } // else // { // SqlDataAccess.AddInParameter(ctx, command, "Nationality", DbType.AnsiString, DBNull.Value); // } // //国籍名称 // SqlDataAccess.AddInParameter(ctx, command, "NationalityName", DbType.AnsiString, gjmc); //国籍名称 // #endregion // SqlDataAccess.AddInParameter(ctx, command, "IsSigned", System.Data.DbType.String, pid.PatientID.CheckDigit.Value ?? "0");//a05.PID.PatientID.CheckDigit.Value);//是否签约 // SqlDataAccess.AddInParameter(ctx, command, "IsBlackList", System.Data.DbType.String, pid.GetIdentityReliabilityCode(0).Value); //a05.PID.GetIdentityReliabilityCode(0).Value);//是否为黑名单 // SqlDataAccess.AddInParameter(ctx, command, "GreenChannelFlag", System.Data.DbType.Int32, pid.PatientID.IdentifierTypeCode.Value ?? "0"); // using (var scope = new TransactionScope(TransactionScopeOption.RequiresNew)) // { // SqlDataAccess.ExecuteNonQuery(ctx, command); // scope.Complete(); // } // #region 家庭地址和工作单位 // //住院先不处理 // if (pv1.PatientClass.Value == "I") // { // } // else // { // try // { // var sqlCode = @"SELECT CodeID,Str4 FROM HealthCare.dbo.PublicCode WHERE TypeID = '1008'"; // var cmdCode = ctx.DBGetSqlStringCommand(sqlCode); // DataTable dtCode = new DataTable(); // dtCode.Load(ctx.DBExecuteReader(cmdCode)); // //Patient // var sqlUpdPatient = @" UPDATE HealthCare.dbo.Patient // SET HomeProCode = @HomeProCode , // HomeCityCode = @HomeCityCode , // HomeDistrictCode = @HomeDistrictCode , // HomeAddress = @HomeAddress, // AdrDesc = @HomeAddress // WHERE ChartNo = @ChartNo "; // var cmdPatientUpd = SqlDataAccess.GetSqlStringCommand(ctx, sqlUpdPatient); // var homeAddress = string.Empty; // for (int i = 0; i < pid.PatientAddressRepetitionsUsed; i++) // { // var add = pid.GetPatientAddress(i); // if (add.AddressType.Value == "H") //现住址 // { // var pro = dtCode.AsEnumerable().FirstOrDefault(row => StrHelepr.ObjToStr(row["Str4"]) == StrHelepr.ObjToStr(add.StateOrProvince.Value)); // var city = dtCode.AsEnumerable().FirstOrDefault(row => StrHelepr.ObjToStr(row["Str4"]) == StrHelepr.ObjToStr(add.City.Value)); // var district = dtCode.AsEnumerable().FirstOrDefault(row => StrHelepr.ObjToStr(row["Str4"]) == StrHelepr.ObjToStr(add.OtherDesignation.Value)); // homeAddress = add.StreetAddress.StreetOrMailingAddress.Value; // SqlDataAccess.AddInParameter(ctx, cmdPatientUpd, "HomeProCode", DbType.AnsiString, pro == null ? string.Empty : StrHelepr.ObjToStr(pro["CodeID"])); //省编码 // SqlDataAccess.AddInParameter(ctx, cmdPatientUpd, "HomeCityCode", DbType.AnsiString, city == null ? string.Empty : StrHelepr.ObjToStr(city["CodeID"]));//市编码 // SqlDataAccess.AddInParameter(ctx, cmdPatientUpd, "HomeDistrictCode", DbType.AnsiString, district == null ? string.Empty : StrHelepr.ObjToStr(district["CodeID"])); //县区编码 // if (!string.IsNullOrEmpty(homeAddress)) // { // SqlDataAccess.AddInParameter(ctx, cmdPatientUpd, "HomeAddress", DbType.AnsiString, homeAddress); //详细地址信息 // } // SqlDataAccess.AddInParameter(ctx, cmdPatientUpd, "ChartNo", DbType.AnsiString, pid.PatientID.ID.Value); //ChartNo // } // } // //家庭地址如果为空,则填入工作单位名称 PID-11(n)-8 // if (string.IsNullOrEmpty(homeAddress)) // { // for (int i = 0; i < pid.PatientAddressRepetitionsUsed; i++) // { // var add = pid.GetPatientAddress(i); // if (add.AddressType.Value == "W") //工作地址 // { // homeAddress = add.OtherGeographicDesignation.Value; // SqlDataAccess.AddInParameter(ctx, cmdPatientUpd, "HomeAddress", DbType.AnsiString, homeAddress); //详细地址信息 // } // } // } // SqlDataAccess.ExecuteNonQuery(ctx, cmdPatientUpd); // } // catch (Exception ex) // { // LogHelper.LogError("更新门诊现住址失败!" + ex.Message + Environment.NewLine + ex.StackTrace); // } // } // #endregion // } #endregion /// /// 修改黑名单和签约 /// /// /// /// // protected void UpdatePatientBlackListAndSigned(Database ctx, ADT_A05 m05 = null, ADT_A01 m01 = null) // { // PID pid = null; // PV1 pv1 = null; // NK1 nk1 = null; // if (null != m05) // { // pid = m05.PID; // pv1 = m05.PV1; // nk1 = m05.GetNK1(0); // } // if (null != m01) // { // pid = m01.PID; // pv1 = m01.PV1; // nk1 = m01.GetNK1(0); // } // var sqlPatient = @" update HealthCare.dbo.Patient set // IsSigned = @IsSigned , // IsBlackList= @IsBlackList // where ChartNo=@ChartNo "; // var cmd = ctx.GetSqlStringCommand(sqlPatient); // SqlDataAccess.AddInParameter(ctx, cmd, "IsSigned", System.Data.DbType.String, pid.PatientID.CheckDigit.Value ?? "0"); //是否签约 // SqlDataAccess.AddInParameter(ctx, cmd, "IsBlackList", System.Data.DbType.String, pid.GetIdentityReliabilityCode(0).Value);//是否为黑名单 // SqlDataAccess.AddInParameter(ctx, cmd, "ChartNo", System.Data.DbType.String, pid.PatientID.ID.Value); //ChartNo // using (var scope = new TransactionScope(TransactionScopeOption.RequiresNew)) // { // SqlDataAccess.ExecuteNonQuery(ctx, cmd); // scope.Complete(); // } // } #region "患者基本信息修改(ADT^A31)" // internal void EditNewPatient(Database ctx, PID pid, PV1 pv1, NK1 nk1) // { // DataRow rowTemp = null; // StringBuilder sql2 = new StringBuilder(); // sql2.AppendLine(" update HealthCare.dbo.Patient set "); // var cmd = SqlDataAccess.GetSqlStringCommand(ctx, sql2.ToString()); // #region LastNumber // int LastNumberCount = pid.PatientID.ID.Value.Length; // sql2.AppendLine(" LastNumber=@LastNumber, "); // if (LastNumberCount <= 2) // { // SqlDataAccess.AddInParameter(ctx, cmd, "LastNumber", DbType.AnsiString, pid.PatientID.ID.Value); // } // else // { // string LastNumberSubString = pid.PatientID.ID.Value.Substring(LastNumberCount - 2); // SqlDataAccess.AddInParameter(ctx, cmd, "LastNumber", DbType.AnsiString, LastNumberSubString); // } // #endregion // #region "BirthDay" // sql2.AppendLine(" BirthDay=@BirthDay, "); // //出生日期 // SqlDataAccess.AddInParameter(ctx, cmd, "BirthDay", DbType.DateTime, pid.DateTimeOfBirth.TimeOfAnEvent.GetAsDate()); // #endregion // #region "Sex" // var sex = pid.AdministrativeSex.Value; // if (!string.IsNullOrEmpty(sex)) // { // sql2.AppendLine(" Sex=HealthCare.dbo.GetSexCodeIdByHisID(@Sex), "); // SqlDataAccess.AddInParameter(ctx, cmd, "Sex", DbType.AnsiString, sex); // } // #endregion // #region "PtType" // var PtType = pv1.PatientType.Value; // 费用类别 // if (!string.IsNullOrEmpty(PtType)) // { // sql2.AppendLine(" PtType=@PtType, "); // if (PtType == "01") { PtType = "1"; } // else { PtType = "2"; } // SqlDataAccess.AddInParameter(ctx, cmd, "PtType", DbType.AnsiString, PtType); // } // #endregion // #region "BirthAreaName" // var BirthAreaName = pid.BirthPlace.Value;//出生地 // if (!string.IsNullOrEmpty(BirthAreaName)) // { // sql2.AppendLine("BirthAreaName=@BirthAreaName,"); // SqlDataAccess.AddInParameter(ctx, cmd, "BirthAreaName", DbType.AnsiString, BirthAreaName); // } // #endregion // #region "Marriage" // var marr = pid.MaritalStatus.Identifier.Value; // if (!string.IsNullOrEmpty(marr)) // { // sql2.AppendLine(" Marriage= HealthCare.dbo.GetMarriageCodeIdByHisID(@Marriage), "); // SqlDataAccess.AddInParameter(ctx, cmd, "Marriage", DbType.AnsiString, pid.MaritalStatus.Identifier.Value); // } // #endregion // #region "Tel1" // var tel1 = pid.GetPhoneNumberHome(0).PhoneNumber.Value; // if (!string.IsNullOrEmpty(tel1)) // { // sql2.AppendLine(" Tel1=@Tel1, "); // SqlDataAccess.AddInParameter(ctx, cmd, "Tel1", DbType.AnsiString, tel1);//家庭电话 // } // #endregion // #region "Tel2" // var tel2 = pid.GetPhoneNumberBusiness(0).PhoneNumber.Value; // if (!string.IsNullOrEmpty(tel2)) // { // sql2.AppendLine(" Tel2=@Tel2, "); // SqlDataAccess.AddInParameter(ctx, cmd, "Tel2", DbType.AnsiString, tel2);//单位电话 // } // #endregion // var address = pid.GetPatientAddress(0); // #region "AdrDesc" // var addr = address.StreetAddress.StreetOrMailingAddress.Value; // if (!string.IsNullOrEmpty(addr)) // { // sql2.AppendLine(" AdrDesc=@AdrDesc, "); // SqlDataAccess.AddInParameter(ctx, cmd, "AdrDesc", DbType.AnsiString, addr);//家庭地址 // } // else // { // addr = address.OtherDesignation.Value;//工作单位 // if (!string.IsNullOrEmpty(addr)) // { // sql2.AppendLine(" AdrDesc=@AdrDesc, "); // SqlDataAccess.AddInParameter(ctx, cmd, "AdrDesc", DbType.AnsiString, addr);//家庭地址 // } // } // #endregion // #region "UnitAdrDesc" // sql2.AppendLine("UnitAdrDesc=@UnitAdrDesc,"); // SqlDataAccess.AddInParameter(ctx, cmd, "UnitAdrDesc", DbType.AnsiString, address.OtherDesignation.Value ?? string.Empty);//工作单位 // #endregion // //加入病人姓名 杨燕要求的 // var ptName = pid.GetPatientName(0).GivenName.Value; // if (!string.IsNullOrEmpty(ptName)) // { // sql2.AppendLine(" PtName=@PtName, "); // SqlDataAccess.AddInParameter(ctx, cmd, "PtName", DbType.AnsiString, ptName);//病人姓名 // } // //#region "AdrArea" // //var area = address.ZipOrPostalCode.Value; // //if (!string.IsNullOrEmpty(address.ZipOrPostalCode.Value)) // //{ // // sql2.AppendLine(" AdrArea=@AdrArea, "); // // SqlDataAccess.AddInParameter(ctx, cmd, "AdrArea", DbType.Int32, address.ZipOrPostalCode.Value);//邮编号 // // //SqlDataAccess.AddInParameter(ctx, command, "AdrArea", DbType.AnsiString, string.IsNullOrEmpty(address.ZipOrPostalCode.Value) ? "" : address.ZipOrPostalCode.Value);//邮编号 // //} // //#endregion // #region "CardNo" // var cardNo = pid.PatientAccountNumber.ID.Value; // if (!string.IsNullOrEmpty(cardNo)) // { // sql2.AppendLine(" CardNo=@CardNo, "); // SqlDataAccess.AddInParameter(ctx, cmd, "CardNo", DbType.AnsiString, cardNo);//医保卡号 // } // #endregion // #region "idNo" // var idNo = pid.SSNNumberPatient.Value; // if (!string.IsNullOrEmpty(idNo)) // { // sql2.AppendLine(" IdNo=@IdNo, "); // SqlDataAccess.AddInParameter(ctx, cmd, "IdNo", DbType.AnsiString, idNo);//身分证号 // } // #endregion // //SqlDataAccess.AddInParameter(ctx,command, "FirstVisitDate", DbType.DateTime, DateTime.Now); // //SqlDataAccess.AddInParameter(ctx,command, "FirstVisitDivNo", DbType.Int32, "0"); // //SqlDataAccess.AddInParameter(ctx,command, "NoPromiseCnt", DbType.Int32, "0"); // //SqlDataAccess.AddInParameter(ctx,command, "NoPromiseDate", DbType.DateTime, DateTime.Now); // //SqlDataAccess.AddInParameter(ctx,command, "Private", DbType.AnsiString, ""); // //SqlDataAccess.AddInParameter(ctx,command, "AgreeUse", DbType.AnsiString, ""); // //SqlDataAccess.AddInParameter(ctx,command, "BadRecord", DbType.AnsiString, ""); // sql2.AppendLine(" LastVisitDate=GetDate(), "); // //SqlDataAccess.AddInParameter(ctx, cmd, "LastVisitDate", DbType.DateTime, DateTime.Now); // #region "民族" // var eg = pid.GetEthnicGroup(0); // var mzcoid = eg.Identifier.Value; // var mzname = eg.Text.Value; // if (!string.IsNullOrEmpty(mzcoid) || !string.IsNullOrEmpty(mzname)) // { // rowTemp = GetDictionView(ctx, "V_Nation").Rows.Cast().Where(n => // StrHelepr.Obj2StrTrim(n["MedCodeID"]) == mzcoid || // StrHelepr.Obj2StrTrim(n["CodeName"]) == mzname).FirstOrDefault(); // //民族V_Nation // if (rowTemp != null) // { // sql2.AppendLine(" NationNo=@NationNo, "); // SqlDataAccess.AddInParameter(ctx, cmd, "NationNo", DbType.AnsiString, StrHelepr.Obj2StrTrim(rowTemp["CodeID"])); // mzname = StrHelepr.Obj2StrTrim(rowTemp["CodeName"]); // } // else // { // SqlDataAccess.AddInParameter(ctx, cmd, "NationNo", DbType.AnsiString, DBNull.Value); //民族V_Nation // } // sql2.AppendLine(" NationName=@NationName, "); // SqlDataAccess.AddInParameter(ctx, cmd, "NationName", DbType.AnsiString, mzname); //民族名称 // } // #endregion // #region 籍贯 // var sheng = address.StateOrProvince.Value; // if (!string.IsNullOrEmpty(sheng)) // { // rowTemp = GetDictionView(ctx, "V_Native").Rows.Cast().Where(n => // StrHelepr.Obj2StrTrim(n["CodeName"]) == sheng).FirstOrDefault(); // if (rowTemp != null) // { // sql2.AppendLine(" NativeNo=@NativeNo, "); // SqlDataAccess.AddInParameter(ctx, cmd, "NativeNo", DbType.AnsiString, StrHelepr.Obj2StrTrim(rowTemp["CodeID"])); //籍贯ID V_Native // } // sql2.AppendLine(" NativeName=@NativeName, "); // SqlDataAccess.AddInParameter(ctx, cmd, "NativeName", DbType.AnsiString, sheng); //籍贯名称 // } // #endregion // #region "ziocode" // var zipcode = address.ZipOrPostalCode.Value; // if (!string.IsNullOrEmpty(zipcode)) // { // sql2.AppendLine(" HomeZipCode=@HomeZipCode, "); // SqlDataAccess.AddInParameter(ctx, cmd, "HomeZipCode", DbType.AnsiString, zipcode); //家庭邮编 // } // #endregion // #region 关系人 // var nkId = nk1.Relationship.Identifier.Value; // var nkText = nk1.Relationship.Text.Value; // if (!string.IsNullOrEmpty(nkId) || !string.IsNullOrEmpty(nkText)) // { // rowTemp = GetDictionView(ctx, "V_Relationship").Rows.Cast().Where(n => // StrHelepr.Obj2StrTrim(n["MedCodeID"]) == nkId || // StrHelepr.Obj2StrTrim(n["CodeName"]) == nkText).FirstOrDefault(); // if (rowTemp != null) // { // sql2.AppendLine(" ConRelationshipNo=@ConRelationshipNo, "); // SqlDataAccess.AddInParameter(ctx, cmd, "ConRelationshipNo", DbType.AnsiString, StrHelepr.Obj2StrTrim(rowTemp["CodeID"])); //关系人关系ID V_Relationship // nkText = StrHelepr.Obj2StrTrim(rowTemp["CodeName"]); // } // sql2.AppendLine(" ConRelationshipName=@ConRelationshipName, "); // SqlDataAccess.AddInParameter(ctx, cmd, "ConRelationshipName", DbType.AnsiString, nkText); //关系人关系名称 V_Relationship // } // var gadd = nk1.GetAddress(0); // var gzode = gadd.ZipOrPostalCode.Value; // if (!string.IsNullOrEmpty(gzode)) // { // sql2.AppendLine(" ConZipCode=@ConZipCode, "); // SqlDataAccess.AddInParameter(ctx, cmd, "ConZipCode", DbType.AnsiString, gzode); //关系人邮编 // } // #endregion // #region "联系人" // var lNameP = nk1.GetName(0); // var lname = lNameP.GivenName.Value; // if (!string.IsNullOrEmpty(lname)) // { // sql2.AppendLine(" ConName=@ConName, "); // SqlDataAccess.AddInParameter(ctx, cmd, "ConName", DbType.AnsiString, lname); // } // var lphone = nk1.GetPhoneNumber(0).PhoneNumber.Value; // if (!string.IsNullOrEmpty(lphone)) // { // sql2.AppendLine(" ConTel=@ConTel, "); // SqlDataAccess.AddInParameter(ctx, cmd, "ConTel", DbType.AnsiString, lphone); // } // var nAddr = nk1.GetAddress(0); // if (!string.IsNullOrEmpty(nAddr.StreetAddress.StreetName.Value)) // { // sql2.AppendLine(" ConArea=@ConArea, "); // SqlDataAccess.AddInParameter(ctx, cmd, "ConArea", DbType.AnsiString, nAddr.StreetAddress.StreetName.Value); // } // #endregion // #region 国籍 // var gj = pid.Nationality.Identifier.Value; // var gjmc = pid.Nationality.Text.Value; // if (!string.IsNullOrEmpty(gj) || !string.IsNullOrEmpty(gjmc)) // { // rowTemp = GetDictionView(ctx, "V_Nationality").Rows.Cast().Where(n => // StrHelepr.Obj2StrTrim(n["MedCodeID"]) == gj // || StrHelepr.Obj2StrTrim(n["CodeName"]) == gjmc).FirstOrDefault(); // //国籍代码 // if (rowTemp != null) // { // sql2.AppendLine(" Nationality=@Nationality, "); // SqlDataAccess.AddInParameter(ctx, cmd, "Nationality", DbType.AnsiString, StrHelepr.Obj2StrTrim(rowTemp["CodeID"])); // gjmc = StrHelepr.Obj2StrTrim(rowTemp["CodeName"]); // } // sql2.AppendLine(" NationalityName=@NationalityName, "); // //国籍名称 // SqlDataAccess.AddInParameter(ctx, cmd, "NationalityName", DbType.AnsiString, gjmc); //国籍名称 // } // #endregion // sql2.AppendLine(" IsSigned=@IsSigned, "); // SqlDataAccess.AddInParameter(ctx, cmd, "IsSigned", System.Data.DbType.String, pid.PatientID.CheckDigit.Value ?? "0");//a05.PID.PatientID.CheckDigit.Value);//是否签约 // sql2.AppendLine(" IsBlackList=@IsBlackList, "); // SqlDataAccess.AddInParameter(ctx, cmd, "IsBlackList", System.Data.DbType.String, pid.GetIdentityReliabilityCode(0).Value); //a05.PID.GetIdentityReliabilityCode(0).Value);//是否为黑名单 // sql2.AppendLine(" GreenChannelFlag=@GreenChannelFlag, "); // SqlDataAccess.AddInParameter(ctx, cmd, "GreenChannelFlag", System.Data.DbType.String, string.IsNullOrWhiteSpace(pid.PatientID.IdentifierTypeCode.Value) ? "0" : pid.PatientID.IdentifierTypeCode.Value);//pid.PatientID.IdentifierTypeCode.Value ?? "0"); // sql2.AppendLine(" UpdateUser=@UpdateUser, "); // var UpdateUserID = pv1.GetOtherHealthcareProvider(0).IDNumber.Value; //操作者工号 // SqlDataAccess.AddInParameter(ctx, cmd, "UpdateUser", DbType.AnsiString, UpdateUserID);//修改人 // sql2.AppendLine(" UpdateTime=GetDate() "); // //SqlDataAccess.AddInParameter(ctx, cmd, "UpdateTime", DbType.DateTime, DateTime.Now);//修改时间 // #region "ChartNo" // sql2.Append("where ChartNo=@ChartNo"); // SqlDataAccess.AddInParameter(ctx, cmd, "ChartNo", DbType.AnsiString, pid.PatientID.ID.Value); //就诊卡号 // #endregion // cmd.CommandText = sql2.ToString(); // using (TransactionScope scope = new TransactionScope(TransactionScopeOption.RequiresNew)) // { // SqlDataAccess.ExecuteNonQuery(ctx, cmd); // scope.Complete(); // } // #region 病案首页现住址 // #region 住院 // if (pv1.PatientClass.Value == "I") // { // try // { // var sqlCode = @"SELECT CodeID,Str4 FROM HealthCare.dbo.PublicCode WHERE TypeID = '1008'"; // var cmdCode = ctx.DBGetSqlStringCommand(sqlCode); // DataTable dtCode = new DataTable(); // dtCode.Load(ctx.DBExecuteReader(cmdCode)); // //更新病案首页 // var sqlUpdAddress = @" UPDATE HealthCare.dbo.BASY_病人基本信息 // SET 现住址编号_省 = @现住址编号_省 , // 现住址编号_市 = @现住址编号_市 , // 现住址编号_县 = @现住址编号_县 , // 现住址 = @现住址 // WHERE 就诊ID = @就诊ID "; // var cmdAddressUpd = SqlDataAccess.GetSqlStringCommand(ctx, sqlUpdAddress); // //Patient // var sqlUpdPatient = @" UPDATE HealthCare.dbo.Patient // SET HomeProCode = @HomeProCode , // HomeCityCode = @HomeCityCode , // HomeDistrictCode = @HomeDistrictCode , // HomeAddress = @HomeAddress // WHERE ChartNo = @ChartNo "; // var cmdPatientUpd = SqlDataAccess.GetSqlStringCommand(ctx, sqlUpdPatient); // for (int i = 0; i < pid.PatientAddressRepetitionsUsed; i++) // { // var add = pid.GetPatientAddress(i); // if (add.AddressType.Value == "H") //现住址 // { // var pro = dtCode.AsEnumerable().FirstOrDefault(row => StrHelepr.ObjToStr(row["Str4"]) == StrHelepr.ObjToStr(add.StateOrProvince.Value)); // var city = dtCode.AsEnumerable().FirstOrDefault(row => StrHelepr.ObjToStr(row["Str4"]) == StrHelepr.ObjToStr(add.City.Value)); // var district = dtCode.AsEnumerable().FirstOrDefault(row => StrHelepr.ObjToStr(row["Str4"]) == StrHelepr.ObjToStr(add.OtherDesignation.Value)); // SqlDataAccess.AddInParameter(ctx, cmdAddressUpd, "现住址编号_省", DbType.AnsiString, pro == null ? string.Empty : StrHelepr.ObjToStr(pro["CodeID"])); //省编码 // SqlDataAccess.AddInParameter(ctx, cmdAddressUpd, "现住址编号_市", DbType.AnsiString, city == null ? string.Empty : StrHelepr.ObjToStr(city["CodeID"]));//市编码 // SqlDataAccess.AddInParameter(ctx, cmdAddressUpd, "现住址编号_县", DbType.AnsiString, district == null ? string.Empty : StrHelepr.ObjToStr(district["CodeID"])); //县区编码 // SqlDataAccess.AddInParameter(ctx, cmdAddressUpd, "现住址", DbType.AnsiString, add.StreetAddress.StreetOrMailingAddress.Value); //详细地址信息 // SqlDataAccess.AddInParameter(ctx, cmdAddressUpd, "就诊ID", DbType.AnsiString, pv1.VisitNumber.ID.Value); //VisitNo // if (SqlDataAccess.ExecuteNonQuery(ctx, cmdAddressUpd) == 0) // { // #region 旧的调用存储过程的方法,会经常导致超时 // //var db = DatabaseFactory.CreateDatabase("HealthCare"); // //var conn = db.CreateConnection(); // //conn.Open(); // //DbCommand cmdAddressInsert = db.GetStoredProcCommand("dbo.AddPtBaseInfoToBASY"); // //cmdAddressInsert.Connection = conn; // //var para = cmdAddressInsert.CreateParameter(); // //para.ParameterName = "@VisitNo"; // //para.DbType = DbType.String; // //para.Value = pv1.VisitNumber.ID.Value; // //cmdAddressInsert.Parameters.Add(para); // //if (cmdAddressInsert.ExecuteNonQuery() > 0) // //{ // // SqlDataAccess.ExecuteNonQuery(ctx, cmdAddressUpd); // //} // //conn.Close(); // #endregion // #region SQL // var sqlInsertBASY = @"INSERT INTO dbo.BASY_病人基本信息 // ( 病人姓名 , // 住院次数, // 性别 , // 出生日期 , // 年龄 , // 婚姻 , // 职业 , // 民族 , // 国籍 , // 身份证 , // 血型 , // 工作单位 , // 单位电话 , // 单位邮编 , // 关系人姓名 , // 关系 , // 关系人地址 , // 关系人电话 , // 出生地_省市县 , // 籍贯省市县 , // 现住址 , // 现住址电话 , // 现住址邮编 , // 病历号 , // 就诊ID , // 院区ID , // 主任医生ID , // 主治医生ID , // 住院医生ID , // 实习医生ID , // 入院科室 , // 入院日期 , // 入院床位 , // 出院床位 , // 出院科室 , // 出院日期 , // 住院天数 , // 当前科室 , // 婴儿标志 , // 当前病区 , // 当前床位 , // 身高 , // 体重 , // 责任护士ID , // 责任护士姓名 , // 出生地编号_省, // 出生地编号_市, // 出生地编号_县, // 籍贯编号_省, // 籍贯编号_市, // 籍贯编号_县, // 现住址编号_省, // 现住址编号_市, // 现住址编号_县 , // 现住址省市县, // 户口地址编号_省, // 户口地址编号_市, // 户口地址编号_县, // 户口地址省市县, // 医生组编号, // 户口地址 // ) // SELECT a.PtName , // b.HospTimes, // a.Sex , // a.BirthDay , // dbo.Fun_GetAge(a.BirthDay, b.AdmitTime, b.VisitNo) age , // a.Marriage , // a.JobType , // a.NationNo , // a.Nationality , // SUBSTRING(a.IdNo,1,18) , // CASE WHEN a.BloodType = 'A型' THEN 1 // WHEN a.BloodType = 'B型' THEN 2 // WHEN a.BloodType = 'O型' THEN 3 // WHEN a.BloodType = 'AB型' THEN 4 // ELSE 5 // END BloodType , // a.UnitAdrDesc , // a.Tel2 , // a.WorkplaceZipCode , // a.ConName , // a.ConRelationshipName , // a.ConArea , // a.ConTel , // dbo.GetAddrName(a.BirthAreaNo ) , // dbo.GetAddrName(a.NativeNo ) , // a.AdrDesc , // a.Tel1 , // a.HomeZipCode , // a.ChartNo , // b.VisitNo , // ISNULL(c.VisitZone, ( SELECT Zone // FROM Employee // WHERE EmpNo = b.UpdateUser // )) Zone , // b.ChiefDrNo , // b.DrNo1 , // b.DrNo3 , // b.DrNo4 , // b.AdmissDivNo , // ( CASE ( SELECT ParamValue // FROM dbo.SiteParamCtrl // WHERE SiteNo = '0000' // AND ParamID = '病案首页_入院日期取入科日期' // ) // WHEN 1 THEN (SELECT MIN(ipd.DynamicTime) FROM dbo.InPatientDynamic ipd WHERE ipd.VisitNo = b.VisitNo AND ipd.DynamicType=13) // ELSE AdmitTime // END ) AS AdmitTime , // AdmissBed , // ( CASE b.InHospitalStatus // WHEN 0 THEN '' // ELSE b.BedNo // END ) LeaveBedNo , // ( CASE b.InHospitalStatus // WHEN 0 THEN '' // ELSE b.DivNo // END ) LeaveDivNo , // ( CASE ( SELECT ParamValue // FROM dbo.SiteParamCtrl // WHERE SiteNo = '0000' // AND ParamID = '病案首页_出院日期启用预出院日期时间' // ) // WHEN 1 THEN b.PreDischargeTime // ELSE DischargeTime // END ) AS LeaveDate , // b.AdmitDays , // b.DivNo , // b.InfantFlag , // b.DepartNo , // b.BedNo , // b.PtHeight , // b.PtWeight , // b.DrNo2 , // dbo.GetEmpName(b.DrNo2), // dbo.GetAddrCode(a.BirthAreaNo,1) , // dbo.GetAddrCode(a.BirthAreaNo,2) , // dbo.GetAddrCode(a.BirthAreaNo,3) , // dbo.GetAddrCode(a.NativeNo,1) , // dbo.GetAddrCode(a.NativeNo,2) , // dbo.GetAddrCode(a.NativeNo,3) , // dbo.GetAddrCode(a.AdrArea,1) , // dbo.GetAddrCode(a.AdrArea,2) , // dbo.GetAddrCode(a.AdrArea,3) , // dbo.GetAddrName(a.AdrArea ), // dbo.GetAddrCode(a.AdrArea,1) , // dbo.GetAddrCode(a.AdrArea,2) , // dbo.GetAddrCode(a.AdrArea,3) , // dbo.GetAddrName(a.AdrArea ), // b.MedicalGroupNo, // AdrDesc // FROM dbo.Patient a , // dbo.InPatient b , // dbo.VisitRecord c // WHERE a.ChartNo = c.ChartNo // AND b.VisitNo = c.VisitNo // AND b.VisitNo = @VisitNo"; // #endregion // var cmdBASY = SqlDataAccess.GetSqlStringCommand(ctx, sqlInsertBASY); // SqlDataAccess.AddInParameter(ctx, cmdBASY, "VisitNo", DbType.AnsiString, pv1.VisitNumber.ID.Value); //VisitNo // SqlDataAccess.ExecuteNonQuery(ctx, cmdBASY); // } // //更新Patient表 // SqlDataAccess.AddInParameter(ctx, cmdPatientUpd, "HomeProCode", DbType.AnsiString, pro == null ? string.Empty : StrHelepr.ObjToStr(pro["CodeID"])); //省编码 // SqlDataAccess.AddInParameter(ctx, cmdPatientUpd, "HomeCityCode", DbType.AnsiString, city == null ? string.Empty : StrHelepr.ObjToStr(city["CodeID"]));//市编码 // SqlDataAccess.AddInParameter(ctx, cmdPatientUpd, "HomeDistrictCode", DbType.AnsiString, district == null ? string.Empty : StrHelepr.ObjToStr(district["CodeID"])); //县区编码 // SqlDataAccess.AddInParameter(ctx, cmdPatientUpd, "HomeAddress", DbType.AnsiString, add.StreetAddress.StreetOrMailingAddress.Value); //详细地址信息 // SqlDataAccess.AddInParameter(ctx, cmdPatientUpd, "ChartNo", DbType.AnsiString, pid.PatientID.ID.Value); //ChartNo // SqlDataAccess.ExecuteNonQuery(ctx, cmdPatientUpd); // } // } // } // catch (Exception ex) // { // LogHelper.LogError("更新现住址失败!" + ex.Message + Environment.NewLine + ex.StackTrace); // } // } // #endregion // #region 门急诊 // else // { // try // { // var sqlCode = @"SELECT CodeID,Str4 FROM HealthCare.dbo.PublicCode WHERE TypeID = '1008'"; // var cmdCode = ctx.DBGetSqlStringCommand(sqlCode); // DataTable dtCode = new DataTable(); // dtCode.Load(ctx.DBExecuteReader(cmdCode)); // //Patient // var sqlUpdPatient = @" UPDATE HealthCare.dbo.Patient // SET HomeProCode = @HomeProCode , // HomeCityCode = @HomeCityCode , // HomeDistrictCode = @HomeDistrictCode , // HomeAddress = @HomeAddress, // AdrDesc = @HomeAddress // WHERE ChartNo = @ChartNo "; // var cmdPatientUpd = SqlDataAccess.GetSqlStringCommand(ctx, sqlUpdPatient); // var homeAddress = string.Empty; // for (int i = 0; i < pid.PatientAddressRepetitionsUsed; i++) // { // var add = pid.GetPatientAddress(i); // if (add.AddressType.Value == "H") //现住址 // { // var pro = dtCode.AsEnumerable().FirstOrDefault(row => StrHelepr.ObjToStr(row["Str4"]) == StrHelepr.ObjToStr(add.StateOrProvince.Value)); // var city = dtCode.AsEnumerable().FirstOrDefault(row => StrHelepr.ObjToStr(row["Str4"]) == StrHelepr.ObjToStr(add.City.Value)); // var district = dtCode.AsEnumerable().FirstOrDefault(row => StrHelepr.ObjToStr(row["Str4"]) == StrHelepr.ObjToStr(add.OtherDesignation.Value)); // homeAddress = add.StreetAddress.StreetOrMailingAddress.Value; // SqlDataAccess.AddInParameter(ctx, cmdPatientUpd, "HomeProCode", DbType.AnsiString, pro == null ? string.Empty : StrHelepr.ObjToStr(pro["CodeID"])); //省编码 // SqlDataAccess.AddInParameter(ctx, cmdPatientUpd, "HomeCityCode", DbType.AnsiString, city == null ? string.Empty : StrHelepr.ObjToStr(city["CodeID"]));//市编码 // SqlDataAccess.AddInParameter(ctx, cmdPatientUpd, "HomeDistrictCode", DbType.AnsiString, district == null ? string.Empty : StrHelepr.ObjToStr(district["CodeID"])); //县区编码 // if (!string.IsNullOrEmpty(homeAddress)) // { // SqlDataAccess.AddInParameter(ctx, cmdPatientUpd, "HomeAddress", DbType.AnsiString, homeAddress); //详细地址信息 // } // SqlDataAccess.AddInParameter(ctx, cmdPatientUpd, "ChartNo", DbType.AnsiString, pid.PatientID.ID.Value); //ChartNo // } // } // //家庭地址如果为空,则填入工作单位名称 PID-11(n)-8 // if (string.IsNullOrEmpty(homeAddress)) // { // for (int i = 0; i < pid.PatientAddressRepetitionsUsed; i++) // { // var add = pid.GetPatientAddress(i); // if (add.AddressType.Value == "W") //工作地址 // { // homeAddress = add.OtherGeographicDesignation.Value; // SqlDataAccess.AddInParameter(ctx, cmdPatientUpd, "HomeAddress", DbType.AnsiString, homeAddress); //详细地址信息 // } // } // } // SqlDataAccess.ExecuteNonQuery(ctx, cmdPatientUpd); // } // catch (Exception ex) // { // LogHelper.LogError("更新门诊现住址失败!" + ex.Message + Environment.NewLine + ex.StackTrace); // } // } // #endregion // #endregion // } //protected void EditNewPatient(Database ctx, ADT_A05 a05) //{ // PID pid = a05.PID; // PV1 pv1 = a05.PV1; // NK1 nk1 = a05.GetNK1(0); // EditNewPatient(ctx, pid, pv1, nk1); //} #endregion /// /// 获取员工信息 /// /// /// /// //protected EmployeeEntity GetEmpNo(Database ctx, string empCode) //{ // var sql = string.Format("SELECT EmpNo,EmpCode,EmpName,PhoneticName,EngName,IdNo,Sex,Birthday,MobilePhone,Email,HireDate,Zone,DepartNo,WorkDepartNo,EmpType,Title,ChiefNo,SubTel,SimpleTel,Password,PasswordTime,PressCard,ResignDate,Remark,UpdateUser,UpdateTime,Keyword1,Keyword2,Keyword3,UserLevelId,InputCode FROM HealthCare.dbo.Employee WHERE EmpCode='{0}'", empCode); // return SqlDataAccess.ExecuteSqlStringAccessor(ctx, sql).FirstOrDefault(); //} /// /// 获取参数 /// /// /// /// 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 = Scanctx.DBGetSqlStringCommand(sql); Scanctx.AddInParameter(cmd, "VisitNo", DbType.String, visitNo); Scanctx.AddInParameter(cmd, "TaskType", DbType.String, type); var obj = int.Parse(StrHelepr.Obj2StrTrim(Scanctx.DBExecuteScalar(cmd))); return obj; } protected int GetOriginalCount(string VisitNo) { var sql = "SELECT count(1) FROM dbo.zhuyuan_original WITH(NOLOCK) WHERE patient_zyh=@VisitNo "; var cmd = ctx.DBGetSqlStringCommand(sql); ctx.AddInParameter(cmd, "VisitNo", DbType.String, VisitNo); var obj = int.Parse(StrHelepr.Obj2StrTrim(ctx.DBExecuteScalar(cmd))); return obj; } /// /// 获取急诊病人床位 /// /// /// /// //protected BedEntity GetBed(Database ctx, string roombed, string ward) //{ // if (string.IsNullOrWhiteSpace(roombed)) // return null; // var sql = string.Format("SELECT BedNo,RoomBed,Ward,Zone,DepartNo,StockLoc,OwnDivNo,BedLevel,BedType,LocArea,SexCtrl,IsQuery,IsTaint,IsICU,ChartNo,PtName,VisitNo,UDDTime,ExpandStatus,ReserveNo,BedStatue,Printer1,Printer2,BedItemCode,AddItemCode,InpItemCode,NurseItemCode,DrugItemCode,IsDelete,UpdateUser,UpdateTime,PatientType,RoomNo,BedUseStatus FROM HealthCare.dbo.Bed WHERE RoomBed='{0}' and Ward='{1}'", roombed, ward); // return SqlDataAccess.ExecuteSqlStringAccessor(ctx, sql).FirstOrDefault(); //} /// /// 获取床位 /// /// /// /// //protected BedEntity GetBed(Database ctx, string roomBed) //{ // var sql = string.Format("SELECT BedNo,RoomBed,Ward,Zone,DepartNo,StockLoc,OwnDivNo,BedLevel,BedType,LocArea,SexCtrl,IsQuery,IsTaint,IsICU,ChartNo,PtName,VisitNo,UDDTime,ExpandStatus,ReserveNo,BedStatue,Printer1,Printer2,BedItemCode,AddItemCode,InpItemCode,NurseItemCode,DrugItemCode,IsDelete,UpdateUser,UpdateTime,PatientType,RoomNo,BedUseStatus FROM dbo.Bed WHERE RoomBed='{0}'", roomBed); // return SqlDataAccess.ExecuteSqlStringAccessor(ctx, sql).FirstOrDefault(); //} //protected InPatientEntity GetInPatient(Database ctx, string visitNo) //{ // var sql = string.Format("SELECT VisitNo,AdmitTime,CheckInTime,CheckInFlag,Source,LastPtWeight,PtWeight,PtHeight,BMI,WBLoss,IntakeCondition,IsVisit,IsHighRiskFall,IsIllness,NutritionCare,RtnReason,BedNo,DivNo,DepartNo,Diag,DrNo1,DrNo2,DrNo3,DrNo4,PrePayment,LastReportTime,IsPlanDischarge,PreDischargeTime,DischargeTime,DischargeReason,MbdDocNo,DischargeBillNo,NhiAmt,GenAmt,AdmitDays,LinkNo,ChargeStatus,PtMark,PtSourceNo,ChargeUser,ChargeTime,UpdateUser,UpdateTime,RegisterTime,MedicalGroupNo,InHospitalStatus,AdmissDivNo,AdmissDepartNo,AdmissBed,MotherVisitNo,InfantFlag,ChiefDrNo,AdmittedDrNo,HospTimes,OutDirection,OutDiagNo1,OutDiagNo3,OutDiagName3,OutDiagNo2,OutDiagName2,OutDiagName1,DisputeFlag,OldPreDischargeTime FROM HealthCare.dbo.InPatient WHERE VisitNo='{0}'", visitNo); // return SqlDataAccess.ExecuteSqlStringAccessor(ctx, sql).FirstOrDefault(); //} } }