ADTHandler.cs 71 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Linq;
  4. using System.Text;
  5. using Microsoft.Practices.EnterpriseLibrary.Data;
  6. using System.Data;
  7. using System.Data.Common;
  8. using System.Transactions;
  9. using System.Text.RegularExpressions;
  10. using System.Management;
  11. using IL.Common;
  12. using MediII.Adapter.ReceiveToKCModel;
  13. namespace MediII.Adapter.BizComponent.ADT
  14. {
  15. /// <summary>
  16. ///
  17. /// </summary>
  18. public abstract class ADTHandler
  19. {
  20. static readonly string SEDING_APPLICATION = System.Configuration.ConfigurationManager.AppSettings["SedingApplication"];
  21. //数据库连接
  22. protected Database ctx;
  23. protected Database Scanctx;
  24. /// <summary>
  25. ///
  26. /// </summary>
  27. public ADTHandler()
  28. {
  29. DatabaseProviderFactory factory = new DatabaseProviderFactory();
  30. ctx = factory.Create("HealthCare");
  31. Scanctx = factory.CreateDefault();
  32. }
  33. protected string GetZone(string value)
  34. {
  35. string sql = @"SELECT Zone FROM HealthCare.dbo.HisInfo WHERE HisZone = @HisZone";
  36. var command1 = ctx.GetSqlStringCommand(sql.ToString());
  37. ctx.AddInParameter(command1, "HisZone", System.Data.DbType.AnsiString, value);
  38. DataTable dt = ctx.ExecuteDataSet(command1).Tables[0];
  39. string ZONE = "";
  40. if (dt.Rows.Count > 0)
  41. {
  42. ZONE = dt.Rows[0]["Zone"].ToString();
  43. }
  44. return ZONE;
  45. }
  46. /// <summary>
  47. /// 根据事件类型获取不同的处理类
  48. /// </summary>
  49. /// <param name="evntType">消息类型</param>
  50. /// <returns>ADTHandler的子类</returns>
  51. public static ADTHandler GetHandler(string evntType)
  52. {
  53. try
  54. {
  55. switch (evntType)
  56. {
  57. case "ADT^A01[B01]": return new ADT_A01B01_Handler();// 住院就诊信息登记、相关明细任务生成
  58. case "ADT^A01[B02]": return new ADT_A01B02_Handler();// 住院处方单
  59. case "ADT^A01[B03]": return new ADT_A01B03_Handler();// 住院收费明细
  60. case "ADT^A01[B04]": return new ADT_A01B04_Handler();// 住院转科转床
  61. case "ADT^A02[B01]": return new ADT_A02B01_Handler();// 住院就诊信息登记、判断是否出院并生成明细任务
  62. //case "ADT^A02[B02]": return new ADT_A02B02_Handler();// 门诊收费明细更新
  63. //case "ADT^A02[B03]": return new ADT_A02B03_Handler();// 门诊挂号更新
  64. //case "A03": return new ADT_A03_Handler();//出院(ADT^A03)
  65. case "ADT^A04[B01]": return new ADT_A04B01_Handler();// 门诊处方单
  66. case "ADT^A04[B02]": return new ADT_A04B02_Handler();//门诊收费明细
  67. case "ADT^A04[B03]": return new ADT_A04B03_Handler();//门诊挂号
  68. //case "ADT^A05[B01]": return new ADT_A02B01_Handler();//住院就诊信息更新
  69. //case "A08": return new ADT_A08_Handler();//患者信息修改:
  70. //case "A10": return new ADT_A10_Handler();//入科
  71. //case "A11": return new ADT_A11_Handler();//取消入院
  72. //case "A13": return new ADT_A13_Handler();//取消出院(ADT^A13)
  73. //case "A16": return new ADT_A16_Handler();//患者预出院
  74. //case "A25": return new ADT_A25_Handler();//患者取消预出院
  75. //case "A28": return new ADT_A28_Handler();//患者建档
  76. //case "A31": return new ADT_A31_Handler();//患者基本信息修改(ADT^A31)
  77. //case "A29": return new ADT_A29_Handler();//删除婴儿信息(ADT^A29^ADT_A21)
  78. //case "A54": return new ADT_A54_Handler();//修改主治医生
  79. //case "A60": return new ADT_A60_Handler();//患者副作用信息修改
  80. default: throw new NotImplementedException();
  81. }
  82. }
  83. catch (Exception ex)
  84. {
  85. LogHelper.LogError(ex, LogCatagories.General);
  86. throw ex;
  87. }
  88. }
  89. /// <summary>
  90. /// 待实现的处理
  91. /// </summary>
  92. /// <param name="m">传入的消息结构</param>
  93. /// <returns>ACK</returns>
  94. public abstract void Handler(string m, string ID);
  95. #region 获取字典信息
  96. /// <summary>
  97. /// 获取字典信息
  98. /// </summary>
  99. /// <returns></returns>
  100. protected DataTable GetDictionView(Database ctx, string viewName)
  101. {
  102. var ntb = new DataTable();
  103. var sql = string.Format("SELECT CodeID,CodeName,HisCodeID,MedCodeID FROM HealthCare.dbo.[{0}] WHERE IsDel=0", viewName);
  104. var cmd = SqlDataAccess.GetSqlStringCommand(ctx, sql);
  105. ntb.Load(SqlDataAccess.ExecuteReader(ctx, cmd));
  106. return ntb;
  107. }
  108. /// <summary>
  109. /// 获取本地Zone
  110. /// </summary>
  111. /// <param name="ctx"></param>
  112. /// <param name="hisZone"></param>
  113. /// <returns></returns>
  114. protected string GetZone(Database ctx, string hisZone)
  115. {
  116. var sql = string.Format("SELECT top 1 Zone FROM HealthCare.dbo.HisInfo WHERE HisZone='{0}'", hisZone);
  117. var cmd = SqlDataAccess.GetSqlStringCommand(ctx, sql);
  118. var val = StrHelepr.Obj2StrTrim(SqlDataAccess.ExecuteScalar(ctx, cmd));
  119. if (string.IsNullOrEmpty(val))
  120. {
  121. return hisZone;
  122. }
  123. return val;
  124. }
  125. #endregion
  126. #region 取序列
  127. ///<summary>
  128. /// 取序列
  129. /// </summary>
  130. protected string GetSeq(Database ctx, string seqName)
  131. {
  132. string sql = string.Format("SELECT NEXT VALUE FOR {0}", seqName);
  133. var cmd = SqlDataAccess.GetSqlStringCommand(ctx, sql);
  134. object obj = SqlDataAccess.ExecuteScalar(ctx, cmd);
  135. if (obj != null)
  136. return obj.ToString();
  137. else
  138. return "0";
  139. }
  140. #endregion
  141. #region 取服务器当前时间
  142. /// <summary>
  143. /// 获取当前时间
  144. /// </summary>
  145. internal DateTime GetNow(Database ctx)
  146. {
  147. object obj = (DateTime)SqlDataAccess.ExecuteScalar(ctx, CommandType.Text, "select GETDATE()");
  148. if (obj != null)
  149. return Convert.ToDateTime(obj.ToString());
  150. else
  151. return DateTime.Now;
  152. }
  153. #endregion
  154. /// <summary>
  155. /// 添加床位日志
  156. /// </summary>
  157. /// <param name="ctx">数据库操作类</param>
  158. /// <param name="visitNo"></param>
  159. /// <param name="updateUser"></param>
  160. /// <param name="OperateTypeInstr"></param>
  161. /// <param name="remark"></param>
  162. /// <param name="oldMsg"></param>
  163. /// <param name="newMsg"></param>
  164. protected void AddNewWardLog(Database ctx, string visitNo, string updateUser, string OperateTypeInstr, string remark, string oldMsg, string newMsg)
  165. {
  166. 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) ";
  167. var cmd = SqlDataAccess.GetSqlStringCommand(ctx, sql);
  168. SqlDataAccess.AddInParameter(ctx, cmd, "VisitNo", DbType.AnsiString, visitNo);
  169. SqlDataAccess.AddInParameter(ctx, cmd, "UpdateUser", DbType.AnsiString, updateUser);
  170. SqlDataAccess.AddInParameter(ctx, cmd, "OperateTypeInstr", DbType.AnsiString, OperateTypeInstr);
  171. SqlDataAccess.AddInParameter(ctx, cmd, "IP", DbType.AnsiString, NetHelper.GetIP());
  172. SqlDataAccess.AddInParameter(ctx, cmd, "Mac", DbType.AnsiString, NetHelper.GetMacAddress());
  173. SqlDataAccess.AddInParameter(ctx, cmd, "Remark", DbType.AnsiString, remark);
  174. SqlDataAccess.AddInParameter(ctx, cmd, "OldContent", DbType.AnsiString, oldMsg);
  175. SqlDataAccess.AddInParameter(ctx, cmd, "NewContent", DbType.AnsiString, newMsg);
  176. SqlDataAccess.ExecuteNonQuery(ctx, cmd);
  177. }
  178. #region "患者建档(ADT^A28)消息规范"
  179. /// <summary>
  180. /// 检查是否建档
  181. /// </summary>
  182. /// <param name="OptProfile"></param>
  183. /// <param name="chartNo"></param>
  184. /// <returns></returns>
  185. protected int HasPatient(string chartNo)
  186. {
  187. try
  188. {
  189. var sql = " select count(1) from HealthCare.dbo.Patient where ChartNo=@ChartNo ";
  190. var cmd = SqlDataAccess.GetSqlStringCommand(ctx, sql);
  191. SqlDataAccess.AddInParameter(ctx, cmd, "ChartNo", DbType.AnsiString, chartNo);
  192. return int.Parse(StrHelepr.Obj2StrTrim(SqlDataAccess.ExecuteScalar(ctx, cmd))); //病患是否建档
  193. }
  194. catch (Exception ex)
  195. {
  196. throw ex;
  197. }
  198. }
  199. /// <summary>
  200. /// 建档
  201. /// </summary>
  202. /// <param name="ctx"></param>
  203. /// <param name="m05"></param>
  204. /// <param name="m01"></param>
  205. //protected void AddNewPatient(Database ctx, ADT_A05 m05 = null, ADT_A01 m01 = null)
  206. //{
  207. // PID pid = null;
  208. // PV1 pv1 = null;
  209. // NK1 nk1 = null;
  210. // if (null != m05)
  211. // {
  212. // pid = m05.PID;
  213. // pv1 = m05.PV1;
  214. // nk1 = m05.GetNK1(0);
  215. // }
  216. // if (null != m01)
  217. // {
  218. // pid = m01.PID;
  219. // pv1 = m01.PV1;
  220. // nk1 = m01.GetNK1(0);
  221. // }
  222. // AddNewPatient(ctx, pid, pv1, nk1);
  223. //}
  224. // protected void AddNewPatient(Database ctx, PID pid, PV1 pv1, NK1 nk1)
  225. // {
  226. // DataRow rowTemp = null;
  227. // #region SQL
  228. // var sql1 = @"insert into HealthCare.dbo.Patient
  229. // (ChartNo, LastNumber,PtName,BirthDay,IdNo,CardNo,Sex, UnBloodType, BloodType,PtType,
  230. // DiscountType, EduLevel,JobType,BornFlag,Marriage, TakeMedInfo , SalaryInfo ,
  231. // Tel1 , Tel2 , EMail, ConName , ConTel , ConTel1Area, ConTel1, ChartWhere,
  232. // FirstVisitDate , FirstVisitDivNo, NoPromiseCnt , NoPromiseDate, Private, AgreeUse , BadRecord,
  233. // LastVisitDate, CheckUser, CheckTime, UpdateUser , UpdateTime ,NationNo, NationName, WorkplaceZipCode,
  234. // HomeZipCode, ConRelationshipNo, ConRelationshipName, ConZipCode,
  235. // UnitAdrDesc,AdrAreaName, AdrArea, AdrDesc,
  236. // NativeNo,NativeName,
  237. // BirthAreaNo,BirthAreaName,
  238. // Nationality , NationalityName ,IsSigned,IsBlackList,ConArea,GreenChannelFlag)
  239. // Values
  240. // (@ChartNo , @LastNumber ,@PtName , @BirthDay , @IdNo , @CardNo , HealthCare.dbo.GetSexCodeIdByHisID(@Sex),
  241. // @UnBloodType , @BloodType , @PtType ,
  242. // @DiscountType, @EduLevel , @JobType , @BornFlag ,
  243. // HealthCare.dbo.GetMarriageCodeIdByHisID(@Marriage), @TakeMedInfo ,@SalaryInfo ,
  244. // @Tel1 , @Tel2 , @EMail, @ConName , @ConTel , @ConTel1Area, @ConTel1, @ChartWhere,
  245. // GetDate() , @FirstVisitDivNo, @NoPromiseCnt , GetDate(), @Private, @AgreeUse , @BadRecord,
  246. // GetDate(), @CheckUser, GetDate(), @UpdateUser , GetDate() ,@NationNo, @NationName, @WorkplaceZipCode,
  247. // @HomeZipCode, @ConRelationshipNo, @ConRelationshipName, @ConZipCode,
  248. // @UnitAdrDesc, HealthCare.dbo.GetNativeCodeName(HealthCare.dbo.GetMinNativeCodeID(@AdrDesc,5),@AdrDesc),HealthCare.dbo.GetMinNativeCodeID(@AdrDesc,5), @AdrDesc,
  249. // HealthCare.dbo.GetMinNativeCodeID(@AdrDesc,5), HealthCare.dbo.GetNativeCodeName(HealthCare.dbo.GetMinNativeCodeID(@AdrDesc,5),@AdrDesc),
  250. // HealthCare.dbo.GetMinNativeCodeID(@BirthAreaName,5), HealthCare.dbo.GetNativeCodeName(HealthCare.dbo.GetMinNativeCodeID(@BirthAreaName,5),@AdrDesc),
  251. // @Nationality ,@NationalityName,@IsSigned,@IsBlackList,@ConArea,@GreenChannelFlag)";
  252. // #endregion
  253. // var command = SqlDataAccess.GetSqlStringCommand(ctx, sql1);
  254. // //就诊卡号
  255. // SqlDataAccess.AddInParameter(ctx, command, "ChartNo", DbType.AnsiString, pid.PatientID.ID.Value);
  256. // int LastNumberCount = pid.PatientID.ID.Value.Count();
  257. // //最后两码
  258. // if (LastNumberCount <= 2)
  259. // {
  260. // SqlDataAccess.AddInParameter(ctx, command, "LastNumber", DbType.AnsiString, pid.PatientID.ID.Value);
  261. // }
  262. // else
  263. // {
  264. // string LastNumberSubString = pid.PatientID.ID.Value.Substring(LastNumberCount - 2);
  265. // SqlDataAccess.AddInParameter(ctx, command, "LastNumber", DbType.AnsiString, LastNumberSubString);
  266. // }
  267. // //姓名
  268. // SqlDataAccess.AddInParameter(ctx, command, "PtName", DbType.AnsiString, pid.GetPatientName(0).GivenName.Value);
  269. // string tmp = pid.DateTimeOfBirth.TimeOfAnEvent.GetAsDate().ToString();
  270. // //出生日期
  271. // SqlDataAccess.AddInParameter(ctx, command, "BirthDay", DbType.DateTime, pid.DateTimeOfBirth.TimeOfAnEvent.GetAsDate());
  272. // //性别
  273. // SqlDataAccess.AddInParameter(ctx, command, "Sex", DbType.AnsiString, pid.AdministrativeSex.Value);
  274. // //if (pid.AdministrativeSex.Value == "M")
  275. // // SqlDataAccess.AddInParameter(ctx,command, "Sex", DbType.AnsiString, "1");
  276. // //else if (pid.AdministrativeSex.Value == "F")
  277. // // SqlDataAccess.AddInParameter(ctx,command, "Sex", DbType.AnsiString, "2");
  278. // //else
  279. // // SqlDataAccess.AddInParameter(ctx,command, "Sex", DbType.AnsiString, "");
  280. // SqlDataAccess.AddInParameter(ctx, command, "BirthAreaName", DbType.AnsiString, pid.BirthPlace.Value);
  281. // //SqlDataAccess.AddInParameter(ctx, command, "JobType", DbType.AnsiString, pid.GetCitizenship(0).Identifier.Value);his不发职业了
  282. // SqlDataAccess.AddInParameter(ctx, command, "UnBloodType", DbType.AnsiString, "");
  283. // SqlDataAccess.AddInParameter(ctx, command, "BloodType", DbType.AnsiString, "");
  284. // if (pv1.PatientType.Value == "01")
  285. // {
  286. // SqlDataAccess.AddInParameter(ctx, command, "PtType", DbType.AnsiString, "1");
  287. // }
  288. // else
  289. // {
  290. // SqlDataAccess.AddInParameter(ctx, command, "PtType", DbType.AnsiString, "2");
  291. // }
  292. // SqlDataAccess.AddInParameter(ctx, command, "DiscountType", DbType.Int32, 0);
  293. // SqlDataAccess.AddInParameter(ctx, command, "EduLevel", DbType.Int32, 0);
  294. // SqlDataAccess.AddInParameter(ctx, command, "JobType", DbType.Int32, 0);
  295. // SqlDataAccess.AddInParameter(ctx, command, "BornFlag", DbType.AnsiString, "N");
  296. // SqlDataAccess.AddInParameter(ctx, command, "TakeMedInfo", DbType.AnsiString, "");
  297. // SqlDataAccess.AddInParameter(ctx, command, "SalaryInfo", DbType.AnsiString, "");
  298. // #region "联系人"
  299. // var nName = nk1.GetName(0);
  300. // if (null != nName)
  301. // SqlDataAccess.AddInParameter(ctx, command, "ConName", DbType.AnsiString, nName.GivenName.Value);
  302. // else
  303. // SqlDataAccess.AddInParameter(ctx, command, "ConName", DbType.AnsiString, DBNull.Value);
  304. // var nPhone = nk1.GetPhoneNumber(0);
  305. // if (null != nPhone)
  306. // SqlDataAccess.AddInParameter(ctx, command, "ConTel", DbType.AnsiString, nPhone.PhoneNumber.Value);
  307. // else
  308. // SqlDataAccess.AddInParameter(ctx, command, "ConTel", DbType.AnsiString, DBNull.Value);
  309. // SqlDataAccess.AddInParameter(ctx, command, "ConTel1Area", DbType.AnsiString, "0");
  310. // var nPhone2 = nk1.GetPhoneNumber(1);
  311. // if (null != nPhone2)
  312. // SqlDataAccess.AddInParameter(ctx, command, "ConTel1", DbType.AnsiString, nPhone2.PhoneNumber.Value);
  313. // else
  314. // SqlDataAccess.AddInParameter(ctx, command, "ConTel1", DbType.AnsiString, DBNull.Value);
  315. // var nAddr = nk1.GetAddress(0);
  316. // if (null != nAddr)
  317. // SqlDataAccess.AddInParameter(ctx, command, "ConArea", DbType.AnsiString, nAddr.StreetAddress.StreetName.Value);
  318. // else
  319. // SqlDataAccess.AddInParameter(ctx, command, "ConArea", DbType.AnsiString, DBNull.Value);
  320. // #endregion
  321. // SqlDataAccess.AddInParameter(ctx, command, "ChartWhere", DbType.AnsiString, "0"); //Todo
  322. // //SqlDataAccess.AddInParameter(ctx, command, "FirstVisitDate", DbType.DateTime, DateTime.Now);
  323. // SqlDataAccess.AddInParameter(ctx, command, "FirstVisitDivNo", DbType.Int32, "0");
  324. // SqlDataAccess.AddInParameter(ctx, command, "NoPromiseCnt", DbType.Int32, "0");
  325. // //SqlDataAccess.AddInParameter(ctx, command, "NoPromiseDate", DbType.DateTime, DateTime.Now);
  326. // SqlDataAccess.AddInParameter(ctx, command, "Private", DbType.AnsiString, "");
  327. // SqlDataAccess.AddInParameter(ctx, command, "AgreeUse", DbType.AnsiString, "");
  328. // SqlDataAccess.AddInParameter(ctx, command, "BadRecord", DbType.AnsiString, "");
  329. // //SqlDataAccess.AddInParameter(ctx, command, "LastVisitDate", DbType.DateTime, DateTime.Now);
  330. // SqlDataAccess.AddInParameter(ctx, command, "EMail", DbType.AnsiString, "");
  331. // //2016/01/14 杨燕要求Tel1为空时保存Tel2的数据进入Tel1中
  332. // //家庭电话
  333. // var tel1 = pid.GetPhoneNumberHome(0).PhoneNumber.Value;
  334. // if (string.IsNullOrEmpty(tel1) || tel1.Equals("0"))
  335. // SqlDataAccess.AddInParameter(ctx, command, "Tel1", DbType.AnsiString, pid.GetPhoneNumberBusiness(0).PhoneNumber.Value);
  336. // else
  337. // SqlDataAccess.AddInParameter(ctx, command, "Tel1", DbType.AnsiString, pid.GetPhoneNumberHome(0).PhoneNumber.Value);
  338. // //单位电话
  339. // if (string.IsNullOrEmpty(pid.GetPhoneNumberBusiness(0).PhoneNumber.Value))
  340. // SqlDataAccess.AddInParameter(ctx, command, "Tel2", DbType.AnsiString, string.Empty);
  341. // else
  342. // SqlDataAccess.AddInParameter(ctx, command, "Tel2", DbType.AnsiString, pid.GetPhoneNumberBusiness(0).PhoneNumber.Value);
  343. // //婚姻代码
  344. // SqlDataAccess.AddInParameter(ctx, command, "Marriage", DbType.AnsiString, pid.MaritalStatus.Identifier.Value);
  345. // //医保卡号
  346. // if (string.IsNullOrEmpty(pid.PatientAccountNumber.ID.Value))
  347. // {
  348. // SqlDataAccess.AddInParameter(ctx, command, "CardNo", DbType.AnsiString, "0");
  349. // }
  350. // else
  351. // {
  352. // SqlDataAccess.AddInParameter(ctx, command, "CardNo", DbType.AnsiString, pid.PatientAccountNumber.ID.Value);
  353. // }
  354. // //身分证号
  355. // SqlDataAccess.AddInParameter(ctx, command, "IdNo", DbType.AnsiString, pid.SSNNumberPatient.Value);
  356. // #region "地址"
  357. // var address = pid.GetPatientAddress(0);
  358. // //工作单位
  359. // SqlDataAccess.AddInParameter(ctx, command, "UnitAdrDesc", DbType.AnsiString, address.OtherDesignation.Value ?? string.Empty);
  360. // var Adrtmp = address.StreetAddress.StreetOrMailingAddress.Value;
  361. // if (string.IsNullOrWhiteSpace(Adrtmp))
  362. // {
  363. // SqlDataAccess.AddInParameter(ctx, command, "AdrDesc", DbType.AnsiString, address.OtherDesignation.Value ?? string.Empty);
  364. // }
  365. // else
  366. // //家庭地址
  367. // SqlDataAccess.AddInParameter(ctx, command, "AdrDesc", DbType.AnsiString, address.StreetAddress.StreetOrMailingAddress.Value ?? string.Empty);
  368. // ////@家庭地址
  369. // //SqlDataAccess.AddInParameter(ctx, command, "AdrAreaName", DbType.AnsiString, address.StreetAddress.StreetOrMailingAddress.Value ?? string.Empty);
  370. // //#region
  371. // //var csd = pid.BirthPlace.Value;
  372. // ////出生地 BirthAreaName
  373. // //if (!string.IsNullOrEmpty(csd))
  374. // //{
  375. // // SqlDataAccess.AddInParameter(ctx, command, "BirthAreaName", DbType.AnsiString, csd); //出生地名称
  376. // //}
  377. // //else
  378. // //{
  379. // // SqlDataAccess.AddInParameter(ctx, command, "BirthAreaName", DbType.AnsiString, address.StreetAddress.StreetOrMailingAddress.Value ?? string.Empty); //出生地名称
  380. // //}
  381. // #endregion
  382. // SqlDataAccess.AddInParameter(ctx, command, "CheckUser", DbType.AnsiString, "0");//建档人
  383. // //SqlDataAccess.AddInParameter(ctx, command, "CheckTime", DbType.DateTime, DateTime.Now);//建档日期
  384. // SqlDataAccess.AddInParameter(ctx, command, "UpdateUser", DbType.AnsiString, "0");//修改人
  385. // //SqlDataAccess.AddInParameter(ctx, command, "UpdateTime", DbType.DateTime, DateTime.Now);//修改时间
  386. // var eg = pid.GetEthnicGroup(0);
  387. // #region "民族"
  388. // var mzcoid = eg.Identifier.Value;
  389. // var mzname = eg.Text.Value;
  390. // rowTemp = GetDictionView(ctx, "V_Nation").Rows.Cast<DataRow>().Where(n =>
  391. // StrHelepr.Obj2StrTrim(n["MedCodeID"]) == mzcoid ||
  392. // StrHelepr.Obj2StrTrim(n["CodeName"]) == mzname).FirstOrDefault();
  393. // //民族V_Nation
  394. // if (rowTemp != null)
  395. // {
  396. // SqlDataAccess.AddInParameter(ctx, command, "NationNo", DbType.AnsiString, StrHelepr.Obj2StrTrim(rowTemp["CodeID"]));
  397. // mzname = StrHelepr.Obj2StrTrim(rowTemp["CodeName"]);
  398. // }
  399. // else
  400. // {
  401. // SqlDataAccess.AddInParameter(ctx, command, "NationNo", DbType.AnsiString, DBNull.Value); //民族V_Nation
  402. // }
  403. // SqlDataAccess.AddInParameter(ctx, command, "NationName", DbType.AnsiString, mzname); //民族名称
  404. // #endregion
  405. // SqlDataAccess.AddInParameter(ctx, command, "WorkplaceZipCode", DbType.AnsiString, DBNull.Value); //工作单位邮编
  406. // SqlDataAccess.AddInParameter(ctx, command, "HomeZipCode", DbType.AnsiString, address.ZipOrPostalCode.Value); //家庭邮编
  407. // #region 关系人
  408. // var nkId = nk1.Relationship.Identifier.Value;
  409. // var nkText = nk1.Relationship.Text.Value;
  410. // rowTemp = GetDictionView(ctx, "V_Relationship").Rows.Cast<DataRow>().Where(n =>
  411. // StrHelepr.Obj2StrTrim(n["MedCodeID"]) == nkId ||
  412. // StrHelepr.Obj2StrTrim(n["CodeName"]) == nkText).FirstOrDefault();
  413. // if (rowTemp != null)
  414. // {
  415. // SqlDataAccess.AddInParameter(ctx, command, "ConRelationshipNo", DbType.AnsiString, StrHelepr.Obj2StrTrim(rowTemp["CodeID"])); //关系人关系ID V_Relationship
  416. // nkText = StrHelepr.Obj2StrTrim(rowTemp["CodeName"]);
  417. // }
  418. // else
  419. // {
  420. // SqlDataAccess.AddInParameter(ctx, command, "ConRelationshipNo", DbType.AnsiString, DBNull.Value); //关系人关系ID V_Relationship
  421. // }
  422. // SqlDataAccess.AddInParameter(ctx, command, "ConRelationshipName", DbType.AnsiString, nkText); //关系人关系名称 V_Relationship
  423. // var gadd = nk1.GetAddress(0);
  424. // SqlDataAccess.AddInParameter(ctx, command, "ConZipCode", DbType.AnsiString, gadd.ZipOrPostalCode.Value); //关系人邮编
  425. // #endregion
  426. // //#region "AdrArea"
  427. // //var area = address.ZipOrPostalCode.Value;
  428. // //SqlDataAccess.AddInParameter(ctx, command, "AdrArea", DbType.AnsiString, string.IsNullOrEmpty(address.ZipOrPostalCode.Value) ? "" : address.ZipOrPostalCode.Value);//邮编号
  429. // //#endregion
  430. // #region 国籍
  431. // var gj = pid.Nationality.Identifier.Value;
  432. // var gjmc = pid.Nationality.Text.Value;
  433. // rowTemp = GetDictionView(ctx, "V_Nationality").Rows.Cast<DataRow>().Where(n =>
  434. // StrHelepr.Obj2StrTrim(n["MedCodeID"]) == gj
  435. // || StrHelepr.Obj2StrTrim(n["CodeName"]) == gjmc).FirstOrDefault();
  436. // //国籍代码
  437. // if (rowTemp != null)
  438. // {
  439. // SqlDataAccess.AddInParameter(ctx, command, "Nationality", DbType.AnsiString, StrHelepr.Obj2StrTrim(rowTemp["CodeID"]));
  440. // gjmc = StrHelepr.Obj2StrTrim(rowTemp["CodeName"]);
  441. // }
  442. // else
  443. // {
  444. // SqlDataAccess.AddInParameter(ctx, command, "Nationality", DbType.AnsiString, DBNull.Value);
  445. // }
  446. // //国籍名称
  447. // SqlDataAccess.AddInParameter(ctx, command, "NationalityName", DbType.AnsiString, gjmc); //国籍名称
  448. // #endregion
  449. // SqlDataAccess.AddInParameter(ctx, command, "IsSigned", System.Data.DbType.String, pid.PatientID.CheckDigit.Value ?? "0");//a05.PID.PatientID.CheckDigit.Value);//是否签约
  450. // SqlDataAccess.AddInParameter(ctx, command, "IsBlackList", System.Data.DbType.String, pid.GetIdentityReliabilityCode(0).Value); //a05.PID.GetIdentityReliabilityCode(0).Value);//是否为黑名单
  451. // SqlDataAccess.AddInParameter(ctx, command, "GreenChannelFlag", System.Data.DbType.Int32, pid.PatientID.IdentifierTypeCode.Value ?? "0");
  452. // using (var scope = new TransactionScope(TransactionScopeOption.RequiresNew))
  453. // {
  454. // SqlDataAccess.ExecuteNonQuery(ctx, command);
  455. // scope.Complete();
  456. // }
  457. // #region 家庭地址和工作单位
  458. // //住院先不处理
  459. // if (pv1.PatientClass.Value == "I")
  460. // {
  461. // }
  462. // else
  463. // {
  464. // try
  465. // {
  466. // var sqlCode = @"SELECT CodeID,Str4 FROM HealthCare.dbo.PublicCode WHERE TypeID = '1008'";
  467. // var cmdCode = ctx.DBGetSqlStringCommand(sqlCode);
  468. // DataTable dtCode = new DataTable();
  469. // dtCode.Load(ctx.DBExecuteReader(cmdCode));
  470. // //Patient
  471. // var sqlUpdPatient = @" UPDATE HealthCare.dbo.Patient
  472. // SET HomeProCode = @HomeProCode ,
  473. // HomeCityCode = @HomeCityCode ,
  474. // HomeDistrictCode = @HomeDistrictCode ,
  475. // HomeAddress = @HomeAddress,
  476. // AdrDesc = @HomeAddress
  477. // WHERE ChartNo = @ChartNo ";
  478. // var cmdPatientUpd = SqlDataAccess.GetSqlStringCommand(ctx, sqlUpdPatient);
  479. // var homeAddress = string.Empty;
  480. // for (int i = 0; i < pid.PatientAddressRepetitionsUsed; i++)
  481. // {
  482. // var add = pid.GetPatientAddress(i);
  483. // if (add.AddressType.Value == "H") //现住址
  484. // {
  485. // var pro = dtCode.AsEnumerable().FirstOrDefault(row => StrHelepr.ObjToStr(row["Str4"]) == StrHelepr.ObjToStr(add.StateOrProvince.Value));
  486. // var city = dtCode.AsEnumerable().FirstOrDefault(row => StrHelepr.ObjToStr(row["Str4"]) == StrHelepr.ObjToStr(add.City.Value));
  487. // var district = dtCode.AsEnumerable().FirstOrDefault(row => StrHelepr.ObjToStr(row["Str4"]) == StrHelepr.ObjToStr(add.OtherDesignation.Value));
  488. // homeAddress = add.StreetAddress.StreetOrMailingAddress.Value;
  489. // SqlDataAccess.AddInParameter(ctx, cmdPatientUpd, "HomeProCode", DbType.AnsiString, pro == null ? string.Empty : StrHelepr.ObjToStr(pro["CodeID"])); //省编码
  490. // SqlDataAccess.AddInParameter(ctx, cmdPatientUpd, "HomeCityCode", DbType.AnsiString, city == null ? string.Empty : StrHelepr.ObjToStr(city["CodeID"]));//市编码
  491. // SqlDataAccess.AddInParameter(ctx, cmdPatientUpd, "HomeDistrictCode", DbType.AnsiString, district == null ? string.Empty : StrHelepr.ObjToStr(district["CodeID"])); //县区编码
  492. // if (!string.IsNullOrEmpty(homeAddress))
  493. // {
  494. // SqlDataAccess.AddInParameter(ctx, cmdPatientUpd, "HomeAddress", DbType.AnsiString, homeAddress); //详细地址信息
  495. // }
  496. // SqlDataAccess.AddInParameter(ctx, cmdPatientUpd, "ChartNo", DbType.AnsiString, pid.PatientID.ID.Value); //ChartNo
  497. // }
  498. // }
  499. // //家庭地址如果为空,则填入工作单位名称 PID-11(n)-8
  500. // if (string.IsNullOrEmpty(homeAddress))
  501. // {
  502. // for (int i = 0; i < pid.PatientAddressRepetitionsUsed; i++)
  503. // {
  504. // var add = pid.GetPatientAddress(i);
  505. // if (add.AddressType.Value == "W") //工作地址
  506. // {
  507. // homeAddress = add.OtherGeographicDesignation.Value;
  508. // SqlDataAccess.AddInParameter(ctx, cmdPatientUpd, "HomeAddress", DbType.AnsiString, homeAddress); //详细地址信息
  509. // }
  510. // }
  511. // }
  512. // SqlDataAccess.ExecuteNonQuery(ctx, cmdPatientUpd);
  513. // }
  514. // catch (Exception ex)
  515. // {
  516. // LogHelper.LogError("更新门诊现住址失败!" + ex.Message + Environment.NewLine + ex.StackTrace);
  517. // }
  518. // }
  519. // #endregion
  520. // }
  521. #endregion
  522. /// <summary>
  523. /// 修改黑名单和签约
  524. /// </summary>
  525. /// <param name="ctx"></param>
  526. /// <param name="m05"></param>
  527. /// <param name="m01"></param>
  528. // protected void UpdatePatientBlackListAndSigned(Database ctx, ADT_A05 m05 = null, ADT_A01 m01 = null)
  529. // {
  530. // PID pid = null;
  531. // PV1 pv1 = null;
  532. // NK1 nk1 = null;
  533. // if (null != m05)
  534. // {
  535. // pid = m05.PID;
  536. // pv1 = m05.PV1;
  537. // nk1 = m05.GetNK1(0);
  538. // }
  539. // if (null != m01)
  540. // {
  541. // pid = m01.PID;
  542. // pv1 = m01.PV1;
  543. // nk1 = m01.GetNK1(0);
  544. // }
  545. // var sqlPatient = @" update HealthCare.dbo.Patient set
  546. // IsSigned = @IsSigned ,
  547. // IsBlackList= @IsBlackList
  548. // where ChartNo=@ChartNo ";
  549. // var cmd = ctx.GetSqlStringCommand(sqlPatient);
  550. // SqlDataAccess.AddInParameter(ctx, cmd, "IsSigned", System.Data.DbType.String, pid.PatientID.CheckDigit.Value ?? "0"); //是否签约
  551. // SqlDataAccess.AddInParameter(ctx, cmd, "IsBlackList", System.Data.DbType.String, pid.GetIdentityReliabilityCode(0).Value);//是否为黑名单
  552. // SqlDataAccess.AddInParameter(ctx, cmd, "ChartNo", System.Data.DbType.String, pid.PatientID.ID.Value); //ChartNo
  553. // using (var scope = new TransactionScope(TransactionScopeOption.RequiresNew))
  554. // {
  555. // SqlDataAccess.ExecuteNonQuery(ctx, cmd);
  556. // scope.Complete();
  557. // }
  558. // }
  559. #region "患者基本信息修改(ADT^A31)"
  560. // internal void EditNewPatient(Database ctx, PID pid, PV1 pv1, NK1 nk1)
  561. // {
  562. // DataRow rowTemp = null;
  563. // StringBuilder sql2 = new StringBuilder();
  564. // sql2.AppendLine(" update HealthCare.dbo.Patient set ");
  565. // var cmd = SqlDataAccess.GetSqlStringCommand(ctx, sql2.ToString());
  566. // #region LastNumber
  567. // int LastNumberCount = pid.PatientID.ID.Value.Length;
  568. // sql2.AppendLine(" LastNumber=@LastNumber, ");
  569. // if (LastNumberCount <= 2)
  570. // {
  571. // SqlDataAccess.AddInParameter(ctx, cmd, "LastNumber", DbType.AnsiString, pid.PatientID.ID.Value);
  572. // }
  573. // else
  574. // {
  575. // string LastNumberSubString = pid.PatientID.ID.Value.Substring(LastNumberCount - 2);
  576. // SqlDataAccess.AddInParameter(ctx, cmd, "LastNumber", DbType.AnsiString, LastNumberSubString);
  577. // }
  578. // #endregion
  579. // #region "BirthDay"
  580. // sql2.AppendLine(" BirthDay=@BirthDay, ");
  581. // //出生日期
  582. // SqlDataAccess.AddInParameter(ctx, cmd, "BirthDay", DbType.DateTime, pid.DateTimeOfBirth.TimeOfAnEvent.GetAsDate());
  583. // #endregion
  584. // #region "Sex"
  585. // var sex = pid.AdministrativeSex.Value;
  586. // if (!string.IsNullOrEmpty(sex))
  587. // {
  588. // sql2.AppendLine(" Sex=HealthCare.dbo.GetSexCodeIdByHisID(@Sex), ");
  589. // SqlDataAccess.AddInParameter(ctx, cmd, "Sex", DbType.AnsiString, sex);
  590. // }
  591. // #endregion
  592. // #region "PtType"
  593. // var PtType = pv1.PatientType.Value; // 费用类别
  594. // if (!string.IsNullOrEmpty(PtType))
  595. // {
  596. // sql2.AppendLine(" PtType=@PtType, ");
  597. // if (PtType == "01") { PtType = "1"; }
  598. // else { PtType = "2"; }
  599. // SqlDataAccess.AddInParameter(ctx, cmd, "PtType", DbType.AnsiString, PtType);
  600. // }
  601. // #endregion
  602. // #region "BirthAreaName"
  603. // var BirthAreaName = pid.BirthPlace.Value;//出生地
  604. // if (!string.IsNullOrEmpty(BirthAreaName))
  605. // {
  606. // sql2.AppendLine("BirthAreaName=@BirthAreaName,");
  607. // SqlDataAccess.AddInParameter(ctx, cmd, "BirthAreaName", DbType.AnsiString, BirthAreaName);
  608. // }
  609. // #endregion
  610. // #region "Marriage"
  611. // var marr = pid.MaritalStatus.Identifier.Value;
  612. // if (!string.IsNullOrEmpty(marr))
  613. // {
  614. // sql2.AppendLine(" Marriage= HealthCare.dbo.GetMarriageCodeIdByHisID(@Marriage), ");
  615. // SqlDataAccess.AddInParameter(ctx, cmd, "Marriage", DbType.AnsiString, pid.MaritalStatus.Identifier.Value);
  616. // }
  617. // #endregion
  618. // #region "Tel1"
  619. // var tel1 = pid.GetPhoneNumberHome(0).PhoneNumber.Value;
  620. // if (!string.IsNullOrEmpty(tel1))
  621. // {
  622. // sql2.AppendLine(" Tel1=@Tel1, ");
  623. // SqlDataAccess.AddInParameter(ctx, cmd, "Tel1", DbType.AnsiString, tel1);//家庭电话
  624. // }
  625. // #endregion
  626. // #region "Tel2"
  627. // var tel2 = pid.GetPhoneNumberBusiness(0).PhoneNumber.Value;
  628. // if (!string.IsNullOrEmpty(tel2))
  629. // {
  630. // sql2.AppendLine(" Tel2=@Tel2, ");
  631. // SqlDataAccess.AddInParameter(ctx, cmd, "Tel2", DbType.AnsiString, tel2);//单位电话
  632. // }
  633. // #endregion
  634. // var address = pid.GetPatientAddress(0);
  635. // #region "AdrDesc"
  636. // var addr = address.StreetAddress.StreetOrMailingAddress.Value;
  637. // if (!string.IsNullOrEmpty(addr))
  638. // {
  639. // sql2.AppendLine(" AdrDesc=@AdrDesc, ");
  640. // SqlDataAccess.AddInParameter(ctx, cmd, "AdrDesc", DbType.AnsiString, addr);//家庭地址
  641. // }
  642. // else
  643. // {
  644. // addr = address.OtherDesignation.Value;//工作单位
  645. // if (!string.IsNullOrEmpty(addr))
  646. // {
  647. // sql2.AppendLine(" AdrDesc=@AdrDesc, ");
  648. // SqlDataAccess.AddInParameter(ctx, cmd, "AdrDesc", DbType.AnsiString, addr);//家庭地址
  649. // }
  650. // }
  651. // #endregion
  652. // #region "UnitAdrDesc"
  653. // sql2.AppendLine("UnitAdrDesc=@UnitAdrDesc,");
  654. // SqlDataAccess.AddInParameter(ctx, cmd, "UnitAdrDesc", DbType.AnsiString, address.OtherDesignation.Value ?? string.Empty);//工作单位
  655. // #endregion
  656. // //加入病人姓名 杨燕要求的
  657. // var ptName = pid.GetPatientName(0).GivenName.Value;
  658. // if (!string.IsNullOrEmpty(ptName))
  659. // {
  660. // sql2.AppendLine(" PtName=@PtName, ");
  661. // SqlDataAccess.AddInParameter(ctx, cmd, "PtName", DbType.AnsiString, ptName);//病人姓名
  662. // }
  663. // //#region "AdrArea"
  664. // //var area = address.ZipOrPostalCode.Value;
  665. // //if (!string.IsNullOrEmpty(address.ZipOrPostalCode.Value))
  666. // //{
  667. // // sql2.AppendLine(" AdrArea=@AdrArea, ");
  668. // // SqlDataAccess.AddInParameter(ctx, cmd, "AdrArea", DbType.Int32, address.ZipOrPostalCode.Value);//邮编号
  669. // // //SqlDataAccess.AddInParameter(ctx, command, "AdrArea", DbType.AnsiString, string.IsNullOrEmpty(address.ZipOrPostalCode.Value) ? "" : address.ZipOrPostalCode.Value);//邮编号
  670. // //}
  671. // //#endregion
  672. // #region "CardNo"
  673. // var cardNo = pid.PatientAccountNumber.ID.Value;
  674. // if (!string.IsNullOrEmpty(cardNo))
  675. // {
  676. // sql2.AppendLine(" CardNo=@CardNo, ");
  677. // SqlDataAccess.AddInParameter(ctx, cmd, "CardNo", DbType.AnsiString, cardNo);//医保卡号
  678. // }
  679. // #endregion
  680. // #region "idNo"
  681. // var idNo = pid.SSNNumberPatient.Value;
  682. // if (!string.IsNullOrEmpty(idNo))
  683. // {
  684. // sql2.AppendLine(" IdNo=@IdNo, ");
  685. // SqlDataAccess.AddInParameter(ctx, cmd, "IdNo", DbType.AnsiString, idNo);//身分证号
  686. // }
  687. // #endregion
  688. // //SqlDataAccess.AddInParameter(ctx,command, "FirstVisitDate", DbType.DateTime, DateTime.Now);
  689. // //SqlDataAccess.AddInParameter(ctx,command, "FirstVisitDivNo", DbType.Int32, "0");
  690. // //SqlDataAccess.AddInParameter(ctx,command, "NoPromiseCnt", DbType.Int32, "0");
  691. // //SqlDataAccess.AddInParameter(ctx,command, "NoPromiseDate", DbType.DateTime, DateTime.Now);
  692. // //SqlDataAccess.AddInParameter(ctx,command, "Private", DbType.AnsiString, "");
  693. // //SqlDataAccess.AddInParameter(ctx,command, "AgreeUse", DbType.AnsiString, "");
  694. // //SqlDataAccess.AddInParameter(ctx,command, "BadRecord", DbType.AnsiString, "");
  695. // sql2.AppendLine(" LastVisitDate=GetDate(), ");
  696. // //SqlDataAccess.AddInParameter(ctx, cmd, "LastVisitDate", DbType.DateTime, DateTime.Now);
  697. // #region "民族"
  698. // var eg = pid.GetEthnicGroup(0);
  699. // var mzcoid = eg.Identifier.Value;
  700. // var mzname = eg.Text.Value;
  701. // if (!string.IsNullOrEmpty(mzcoid) || !string.IsNullOrEmpty(mzname))
  702. // {
  703. // rowTemp = GetDictionView(ctx, "V_Nation").Rows.Cast<DataRow>().Where(n =>
  704. // StrHelepr.Obj2StrTrim(n["MedCodeID"]) == mzcoid ||
  705. // StrHelepr.Obj2StrTrim(n["CodeName"]) == mzname).FirstOrDefault();
  706. // //民族V_Nation
  707. // if (rowTemp != null)
  708. // {
  709. // sql2.AppendLine(" NationNo=@NationNo, ");
  710. // SqlDataAccess.AddInParameter(ctx, cmd, "NationNo", DbType.AnsiString, StrHelepr.Obj2StrTrim(rowTemp["CodeID"]));
  711. // mzname = StrHelepr.Obj2StrTrim(rowTemp["CodeName"]);
  712. // }
  713. // else
  714. // {
  715. // SqlDataAccess.AddInParameter(ctx, cmd, "NationNo", DbType.AnsiString, DBNull.Value); //民族V_Nation
  716. // }
  717. // sql2.AppendLine(" NationName=@NationName, ");
  718. // SqlDataAccess.AddInParameter(ctx, cmd, "NationName", DbType.AnsiString, mzname); //民族名称
  719. // }
  720. // #endregion
  721. // #region 籍贯
  722. // var sheng = address.StateOrProvince.Value;
  723. // if (!string.IsNullOrEmpty(sheng))
  724. // {
  725. // rowTemp = GetDictionView(ctx, "V_Native").Rows.Cast<DataRow>().Where(n =>
  726. // StrHelepr.Obj2StrTrim(n["CodeName"]) == sheng).FirstOrDefault();
  727. // if (rowTemp != null)
  728. // {
  729. // sql2.AppendLine(" NativeNo=@NativeNo, ");
  730. // SqlDataAccess.AddInParameter(ctx, cmd, "NativeNo", DbType.AnsiString, StrHelepr.Obj2StrTrim(rowTemp["CodeID"])); //籍贯ID V_Native
  731. // }
  732. // sql2.AppendLine(" NativeName=@NativeName, ");
  733. // SqlDataAccess.AddInParameter(ctx, cmd, "NativeName", DbType.AnsiString, sheng); //籍贯名称
  734. // }
  735. // #endregion
  736. // #region "ziocode"
  737. // var zipcode = address.ZipOrPostalCode.Value;
  738. // if (!string.IsNullOrEmpty(zipcode))
  739. // {
  740. // sql2.AppendLine(" HomeZipCode=@HomeZipCode, ");
  741. // SqlDataAccess.AddInParameter(ctx, cmd, "HomeZipCode", DbType.AnsiString, zipcode); //家庭邮编
  742. // }
  743. // #endregion
  744. // #region 关系人
  745. // var nkId = nk1.Relationship.Identifier.Value;
  746. // var nkText = nk1.Relationship.Text.Value;
  747. // if (!string.IsNullOrEmpty(nkId) || !string.IsNullOrEmpty(nkText))
  748. // {
  749. // rowTemp = GetDictionView(ctx, "V_Relationship").Rows.Cast<DataRow>().Where(n =>
  750. // StrHelepr.Obj2StrTrim(n["MedCodeID"]) == nkId ||
  751. // StrHelepr.Obj2StrTrim(n["CodeName"]) == nkText).FirstOrDefault();
  752. // if (rowTemp != null)
  753. // {
  754. // sql2.AppendLine(" ConRelationshipNo=@ConRelationshipNo, ");
  755. // SqlDataAccess.AddInParameter(ctx, cmd, "ConRelationshipNo", DbType.AnsiString, StrHelepr.Obj2StrTrim(rowTemp["CodeID"])); //关系人关系ID V_Relationship
  756. // nkText = StrHelepr.Obj2StrTrim(rowTemp["CodeName"]);
  757. // }
  758. // sql2.AppendLine(" ConRelationshipName=@ConRelationshipName, ");
  759. // SqlDataAccess.AddInParameter(ctx, cmd, "ConRelationshipName", DbType.AnsiString, nkText); //关系人关系名称 V_Relationship
  760. // }
  761. // var gadd = nk1.GetAddress(0);
  762. // var gzode = gadd.ZipOrPostalCode.Value;
  763. // if (!string.IsNullOrEmpty(gzode))
  764. // {
  765. // sql2.AppendLine(" ConZipCode=@ConZipCode, ");
  766. // SqlDataAccess.AddInParameter(ctx, cmd, "ConZipCode", DbType.AnsiString, gzode); //关系人邮编
  767. // }
  768. // #endregion
  769. // #region "联系人"
  770. // var lNameP = nk1.GetName(0);
  771. // var lname = lNameP.GivenName.Value;
  772. // if (!string.IsNullOrEmpty(lname))
  773. // {
  774. // sql2.AppendLine(" ConName=@ConName, ");
  775. // SqlDataAccess.AddInParameter(ctx, cmd, "ConName", DbType.AnsiString, lname);
  776. // }
  777. // var lphone = nk1.GetPhoneNumber(0).PhoneNumber.Value;
  778. // if (!string.IsNullOrEmpty(lphone))
  779. // {
  780. // sql2.AppendLine(" ConTel=@ConTel, ");
  781. // SqlDataAccess.AddInParameter(ctx, cmd, "ConTel", DbType.AnsiString, lphone);
  782. // }
  783. // var nAddr = nk1.GetAddress(0);
  784. // if (!string.IsNullOrEmpty(nAddr.StreetAddress.StreetName.Value))
  785. // {
  786. // sql2.AppendLine(" ConArea=@ConArea, ");
  787. // SqlDataAccess.AddInParameter(ctx, cmd, "ConArea", DbType.AnsiString, nAddr.StreetAddress.StreetName.Value);
  788. // }
  789. // #endregion
  790. // #region 国籍
  791. // var gj = pid.Nationality.Identifier.Value;
  792. // var gjmc = pid.Nationality.Text.Value;
  793. // if (!string.IsNullOrEmpty(gj) || !string.IsNullOrEmpty(gjmc))
  794. // {
  795. // rowTemp = GetDictionView(ctx, "V_Nationality").Rows.Cast<DataRow>().Where(n =>
  796. // StrHelepr.Obj2StrTrim(n["MedCodeID"]) == gj
  797. // || StrHelepr.Obj2StrTrim(n["CodeName"]) == gjmc).FirstOrDefault();
  798. // //国籍代码
  799. // if (rowTemp != null)
  800. // {
  801. // sql2.AppendLine(" Nationality=@Nationality, ");
  802. // SqlDataAccess.AddInParameter(ctx, cmd, "Nationality", DbType.AnsiString, StrHelepr.Obj2StrTrim(rowTemp["CodeID"]));
  803. // gjmc = StrHelepr.Obj2StrTrim(rowTemp["CodeName"]);
  804. // }
  805. // sql2.AppendLine(" NationalityName=@NationalityName, ");
  806. // //国籍名称
  807. // SqlDataAccess.AddInParameter(ctx, cmd, "NationalityName", DbType.AnsiString, gjmc); //国籍名称
  808. // }
  809. // #endregion
  810. // sql2.AppendLine(" IsSigned=@IsSigned, ");
  811. // SqlDataAccess.AddInParameter(ctx, cmd, "IsSigned", System.Data.DbType.String, pid.PatientID.CheckDigit.Value ?? "0");//a05.PID.PatientID.CheckDigit.Value);//是否签约
  812. // sql2.AppendLine(" IsBlackList=@IsBlackList, ");
  813. // SqlDataAccess.AddInParameter(ctx, cmd, "IsBlackList", System.Data.DbType.String, pid.GetIdentityReliabilityCode(0).Value); //a05.PID.GetIdentityReliabilityCode(0).Value);//是否为黑名单
  814. // sql2.AppendLine(" GreenChannelFlag=@GreenChannelFlag, ");
  815. // 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");
  816. // sql2.AppendLine(" UpdateUser=@UpdateUser, ");
  817. // var UpdateUserID = pv1.GetOtherHealthcareProvider(0).IDNumber.Value; //操作者工号
  818. // SqlDataAccess.AddInParameter(ctx, cmd, "UpdateUser", DbType.AnsiString, UpdateUserID);//修改人
  819. // sql2.AppendLine(" UpdateTime=GetDate() ");
  820. // //SqlDataAccess.AddInParameter(ctx, cmd, "UpdateTime", DbType.DateTime, DateTime.Now);//修改时间
  821. // #region "ChartNo"
  822. // sql2.Append("where ChartNo=@ChartNo");
  823. // SqlDataAccess.AddInParameter(ctx, cmd, "ChartNo", DbType.AnsiString, pid.PatientID.ID.Value); //就诊卡号
  824. // #endregion
  825. // cmd.CommandText = sql2.ToString();
  826. // using (TransactionScope scope = new TransactionScope(TransactionScopeOption.RequiresNew))
  827. // {
  828. // SqlDataAccess.ExecuteNonQuery(ctx, cmd);
  829. // scope.Complete();
  830. // }
  831. // #region 病案首页现住址
  832. // #region 住院
  833. // if (pv1.PatientClass.Value == "I")
  834. // {
  835. // try
  836. // {
  837. // var sqlCode = @"SELECT CodeID,Str4 FROM HealthCare.dbo.PublicCode WHERE TypeID = '1008'";
  838. // var cmdCode = ctx.DBGetSqlStringCommand(sqlCode);
  839. // DataTable dtCode = new DataTable();
  840. // dtCode.Load(ctx.DBExecuteReader(cmdCode));
  841. // //更新病案首页
  842. // var sqlUpdAddress = @" UPDATE HealthCare.dbo.BASY_病人基本信息
  843. // SET 现住址编号_省 = @现住址编号_省 ,
  844. // 现住址编号_市 = @现住址编号_市 ,
  845. // 现住址编号_县 = @现住址编号_县 ,
  846. // 现住址 = @现住址
  847. // WHERE 就诊ID = @就诊ID ";
  848. // var cmdAddressUpd = SqlDataAccess.GetSqlStringCommand(ctx, sqlUpdAddress);
  849. // //Patient
  850. // var sqlUpdPatient = @" UPDATE HealthCare.dbo.Patient
  851. // SET HomeProCode = @HomeProCode ,
  852. // HomeCityCode = @HomeCityCode ,
  853. // HomeDistrictCode = @HomeDistrictCode ,
  854. // HomeAddress = @HomeAddress
  855. // WHERE ChartNo = @ChartNo ";
  856. // var cmdPatientUpd = SqlDataAccess.GetSqlStringCommand(ctx, sqlUpdPatient);
  857. // for (int i = 0; i < pid.PatientAddressRepetitionsUsed; i++)
  858. // {
  859. // var add = pid.GetPatientAddress(i);
  860. // if (add.AddressType.Value == "H") //现住址
  861. // {
  862. // var pro = dtCode.AsEnumerable().FirstOrDefault(row => StrHelepr.ObjToStr(row["Str4"]) == StrHelepr.ObjToStr(add.StateOrProvince.Value));
  863. // var city = dtCode.AsEnumerable().FirstOrDefault(row => StrHelepr.ObjToStr(row["Str4"]) == StrHelepr.ObjToStr(add.City.Value));
  864. // var district = dtCode.AsEnumerable().FirstOrDefault(row => StrHelepr.ObjToStr(row["Str4"]) == StrHelepr.ObjToStr(add.OtherDesignation.Value));
  865. // SqlDataAccess.AddInParameter(ctx, cmdAddressUpd, "现住址编号_省", DbType.AnsiString, pro == null ? string.Empty : StrHelepr.ObjToStr(pro["CodeID"])); //省编码
  866. // SqlDataAccess.AddInParameter(ctx, cmdAddressUpd, "现住址编号_市", DbType.AnsiString, city == null ? string.Empty : StrHelepr.ObjToStr(city["CodeID"]));//市编码
  867. // SqlDataAccess.AddInParameter(ctx, cmdAddressUpd, "现住址编号_县", DbType.AnsiString, district == null ? string.Empty : StrHelepr.ObjToStr(district["CodeID"])); //县区编码
  868. // SqlDataAccess.AddInParameter(ctx, cmdAddressUpd, "现住址", DbType.AnsiString, add.StreetAddress.StreetOrMailingAddress.Value); //详细地址信息
  869. // SqlDataAccess.AddInParameter(ctx, cmdAddressUpd, "就诊ID", DbType.AnsiString, pv1.VisitNumber.ID.Value); //VisitNo
  870. // if (SqlDataAccess.ExecuteNonQuery(ctx, cmdAddressUpd) == 0)
  871. // {
  872. // #region 旧的调用存储过程的方法,会经常导致超时
  873. // //var db = DatabaseFactory.CreateDatabase("HealthCare");
  874. // //var conn = db.CreateConnection();
  875. // //conn.Open();
  876. // //DbCommand cmdAddressInsert = db.GetStoredProcCommand("dbo.AddPtBaseInfoToBASY");
  877. // //cmdAddressInsert.Connection = conn;
  878. // //var para = cmdAddressInsert.CreateParameter();
  879. // //para.ParameterName = "@VisitNo";
  880. // //para.DbType = DbType.String;
  881. // //para.Value = pv1.VisitNumber.ID.Value;
  882. // //cmdAddressInsert.Parameters.Add(para);
  883. // //if (cmdAddressInsert.ExecuteNonQuery() > 0)
  884. // //{
  885. // // SqlDataAccess.ExecuteNonQuery(ctx, cmdAddressUpd);
  886. // //}
  887. // //conn.Close();
  888. // #endregion
  889. // #region SQL
  890. // var sqlInsertBASY = @"INSERT INTO dbo.BASY_病人基本信息
  891. // ( 病人姓名 ,
  892. // 住院次数,
  893. // 性别 ,
  894. // 出生日期 ,
  895. // 年龄 ,
  896. // 婚姻 ,
  897. // 职业 ,
  898. // 民族 ,
  899. // 国籍 ,
  900. // 身份证 ,
  901. // 血型 ,
  902. // 工作单位 ,
  903. // 单位电话 ,
  904. // 单位邮编 ,
  905. // 关系人姓名 ,
  906. // 关系 ,
  907. // 关系人地址 ,
  908. // 关系人电话 ,
  909. // 出生地_省市县 ,
  910. // 籍贯省市县 ,
  911. // 现住址 ,
  912. // 现住址电话 ,
  913. // 现住址邮编 ,
  914. // 病历号 ,
  915. // 就诊ID ,
  916. // 院区ID ,
  917. // 主任医生ID ,
  918. // 主治医生ID ,
  919. // 住院医生ID ,
  920. // 实习医生ID ,
  921. // 入院科室 ,
  922. // 入院日期 ,
  923. // 入院床位 ,
  924. // 出院床位 ,
  925. // 出院科室 ,
  926. // 出院日期 ,
  927. // 住院天数 ,
  928. // 当前科室 ,
  929. // 婴儿标志 ,
  930. // 当前病区 ,
  931. // 当前床位 ,
  932. // 身高 ,
  933. // 体重 ,
  934. // 责任护士ID ,
  935. // 责任护士姓名 ,
  936. // 出生地编号_省,
  937. // 出生地编号_市,
  938. // 出生地编号_县,
  939. // 籍贯编号_省,
  940. // 籍贯编号_市,
  941. // 籍贯编号_县,
  942. // 现住址编号_省,
  943. // 现住址编号_市,
  944. // 现住址编号_县 ,
  945. // 现住址省市县,
  946. // 户口地址编号_省,
  947. // 户口地址编号_市,
  948. // 户口地址编号_县,
  949. // 户口地址省市县,
  950. // 医生组编号,
  951. // 户口地址
  952. // )
  953. // SELECT a.PtName ,
  954. // b.HospTimes,
  955. // a.Sex ,
  956. // a.BirthDay ,
  957. // dbo.Fun_GetAge(a.BirthDay, b.AdmitTime, b.VisitNo) age ,
  958. // a.Marriage ,
  959. // a.JobType ,
  960. // a.NationNo ,
  961. // a.Nationality ,
  962. // SUBSTRING(a.IdNo,1,18) ,
  963. // CASE WHEN a.BloodType = 'A型' THEN 1
  964. // WHEN a.BloodType = 'B型' THEN 2
  965. // WHEN a.BloodType = 'O型' THEN 3
  966. // WHEN a.BloodType = 'AB型' THEN 4
  967. // ELSE 5
  968. // END BloodType ,
  969. // a.UnitAdrDesc ,
  970. // a.Tel2 ,
  971. // a.WorkplaceZipCode ,
  972. // a.ConName ,
  973. // a.ConRelationshipName ,
  974. // a.ConArea ,
  975. // a.ConTel ,
  976. // dbo.GetAddrName(a.BirthAreaNo ) ,
  977. // dbo.GetAddrName(a.NativeNo ) ,
  978. // a.AdrDesc ,
  979. // a.Tel1 ,
  980. // a.HomeZipCode ,
  981. // a.ChartNo ,
  982. // b.VisitNo ,
  983. // ISNULL(c.VisitZone, ( SELECT Zone
  984. // FROM Employee
  985. // WHERE EmpNo = b.UpdateUser
  986. // )) Zone ,
  987. // b.ChiefDrNo ,
  988. // b.DrNo1 ,
  989. // b.DrNo3 ,
  990. // b.DrNo4 ,
  991. // b.AdmissDivNo ,
  992. // ( CASE ( SELECT ParamValue
  993. // FROM dbo.SiteParamCtrl
  994. // WHERE SiteNo = '0000'
  995. // AND ParamID = '病案首页_入院日期取入科日期'
  996. // )
  997. // WHEN 1 THEN (SELECT MIN(ipd.DynamicTime) FROM dbo.InPatientDynamic ipd WHERE ipd.VisitNo = b.VisitNo AND ipd.DynamicType=13)
  998. // ELSE AdmitTime
  999. // END ) AS AdmitTime ,
  1000. // AdmissBed ,
  1001. // ( CASE b.InHospitalStatus
  1002. // WHEN 0 THEN ''
  1003. // ELSE b.BedNo
  1004. // END ) LeaveBedNo ,
  1005. // ( CASE b.InHospitalStatus
  1006. // WHEN 0 THEN ''
  1007. // ELSE b.DivNo
  1008. // END ) LeaveDivNo ,
  1009. // ( CASE ( SELECT ParamValue
  1010. // FROM dbo.SiteParamCtrl
  1011. // WHERE SiteNo = '0000'
  1012. // AND ParamID = '病案首页_出院日期启用预出院日期时间'
  1013. // )
  1014. // WHEN 1 THEN b.PreDischargeTime
  1015. // ELSE DischargeTime
  1016. // END ) AS LeaveDate ,
  1017. // b.AdmitDays ,
  1018. // b.DivNo ,
  1019. // b.InfantFlag ,
  1020. // b.DepartNo ,
  1021. // b.BedNo ,
  1022. // b.PtHeight ,
  1023. // b.PtWeight ,
  1024. // b.DrNo2 ,
  1025. // dbo.GetEmpName(b.DrNo2),
  1026. // dbo.GetAddrCode(a.BirthAreaNo,1) ,
  1027. // dbo.GetAddrCode(a.BirthAreaNo,2) ,
  1028. // dbo.GetAddrCode(a.BirthAreaNo,3) ,
  1029. // dbo.GetAddrCode(a.NativeNo,1) ,
  1030. // dbo.GetAddrCode(a.NativeNo,2) ,
  1031. // dbo.GetAddrCode(a.NativeNo,3) ,
  1032. // dbo.GetAddrCode(a.AdrArea,1) ,
  1033. // dbo.GetAddrCode(a.AdrArea,2) ,
  1034. // dbo.GetAddrCode(a.AdrArea,3) ,
  1035. // dbo.GetAddrName(a.AdrArea ),
  1036. // dbo.GetAddrCode(a.AdrArea,1) ,
  1037. // dbo.GetAddrCode(a.AdrArea,2) ,
  1038. // dbo.GetAddrCode(a.AdrArea,3) ,
  1039. // dbo.GetAddrName(a.AdrArea ),
  1040. // b.MedicalGroupNo,
  1041. // AdrDesc
  1042. // FROM dbo.Patient a ,
  1043. // dbo.InPatient b ,
  1044. // dbo.VisitRecord c
  1045. // WHERE a.ChartNo = c.ChartNo
  1046. // AND b.VisitNo = c.VisitNo
  1047. // AND b.VisitNo = @VisitNo";
  1048. // #endregion
  1049. // var cmdBASY = SqlDataAccess.GetSqlStringCommand(ctx, sqlInsertBASY);
  1050. // SqlDataAccess.AddInParameter(ctx, cmdBASY, "VisitNo", DbType.AnsiString, pv1.VisitNumber.ID.Value); //VisitNo
  1051. // SqlDataAccess.ExecuteNonQuery(ctx, cmdBASY);
  1052. // }
  1053. // //更新Patient表
  1054. // SqlDataAccess.AddInParameter(ctx, cmdPatientUpd, "HomeProCode", DbType.AnsiString, pro == null ? string.Empty : StrHelepr.ObjToStr(pro["CodeID"])); //省编码
  1055. // SqlDataAccess.AddInParameter(ctx, cmdPatientUpd, "HomeCityCode", DbType.AnsiString, city == null ? string.Empty : StrHelepr.ObjToStr(city["CodeID"]));//市编码
  1056. // SqlDataAccess.AddInParameter(ctx, cmdPatientUpd, "HomeDistrictCode", DbType.AnsiString, district == null ? string.Empty : StrHelepr.ObjToStr(district["CodeID"])); //县区编码
  1057. // SqlDataAccess.AddInParameter(ctx, cmdPatientUpd, "HomeAddress", DbType.AnsiString, add.StreetAddress.StreetOrMailingAddress.Value); //详细地址信息
  1058. // SqlDataAccess.AddInParameter(ctx, cmdPatientUpd, "ChartNo", DbType.AnsiString, pid.PatientID.ID.Value); //ChartNo
  1059. // SqlDataAccess.ExecuteNonQuery(ctx, cmdPatientUpd);
  1060. // }
  1061. // }
  1062. // }
  1063. // catch (Exception ex)
  1064. // {
  1065. // LogHelper.LogError("更新现住址失败!" + ex.Message + Environment.NewLine + ex.StackTrace);
  1066. // }
  1067. // }
  1068. // #endregion
  1069. // #region 门急诊
  1070. // else
  1071. // {
  1072. // try
  1073. // {
  1074. // var sqlCode = @"SELECT CodeID,Str4 FROM HealthCare.dbo.PublicCode WHERE TypeID = '1008'";
  1075. // var cmdCode = ctx.DBGetSqlStringCommand(sqlCode);
  1076. // DataTable dtCode = new DataTable();
  1077. // dtCode.Load(ctx.DBExecuteReader(cmdCode));
  1078. // //Patient
  1079. // var sqlUpdPatient = @" UPDATE HealthCare.dbo.Patient
  1080. // SET HomeProCode = @HomeProCode ,
  1081. // HomeCityCode = @HomeCityCode ,
  1082. // HomeDistrictCode = @HomeDistrictCode ,
  1083. // HomeAddress = @HomeAddress,
  1084. // AdrDesc = @HomeAddress
  1085. // WHERE ChartNo = @ChartNo ";
  1086. // var cmdPatientUpd = SqlDataAccess.GetSqlStringCommand(ctx, sqlUpdPatient);
  1087. // var homeAddress = string.Empty;
  1088. // for (int i = 0; i < pid.PatientAddressRepetitionsUsed; i++)
  1089. // {
  1090. // var add = pid.GetPatientAddress(i);
  1091. // if (add.AddressType.Value == "H") //现住址
  1092. // {
  1093. // var pro = dtCode.AsEnumerable().FirstOrDefault(row => StrHelepr.ObjToStr(row["Str4"]) == StrHelepr.ObjToStr(add.StateOrProvince.Value));
  1094. // var city = dtCode.AsEnumerable().FirstOrDefault(row => StrHelepr.ObjToStr(row["Str4"]) == StrHelepr.ObjToStr(add.City.Value));
  1095. // var district = dtCode.AsEnumerable().FirstOrDefault(row => StrHelepr.ObjToStr(row["Str4"]) == StrHelepr.ObjToStr(add.OtherDesignation.Value));
  1096. // homeAddress = add.StreetAddress.StreetOrMailingAddress.Value;
  1097. // SqlDataAccess.AddInParameter(ctx, cmdPatientUpd, "HomeProCode", DbType.AnsiString, pro == null ? string.Empty : StrHelepr.ObjToStr(pro["CodeID"])); //省编码
  1098. // SqlDataAccess.AddInParameter(ctx, cmdPatientUpd, "HomeCityCode", DbType.AnsiString, city == null ? string.Empty : StrHelepr.ObjToStr(city["CodeID"]));//市编码
  1099. // SqlDataAccess.AddInParameter(ctx, cmdPatientUpd, "HomeDistrictCode", DbType.AnsiString, district == null ? string.Empty : StrHelepr.ObjToStr(district["CodeID"])); //县区编码
  1100. // if (!string.IsNullOrEmpty(homeAddress))
  1101. // {
  1102. // SqlDataAccess.AddInParameter(ctx, cmdPatientUpd, "HomeAddress", DbType.AnsiString, homeAddress); //详细地址信息
  1103. // }
  1104. // SqlDataAccess.AddInParameter(ctx, cmdPatientUpd, "ChartNo", DbType.AnsiString, pid.PatientID.ID.Value); //ChartNo
  1105. // }
  1106. // }
  1107. // //家庭地址如果为空,则填入工作单位名称 PID-11(n)-8
  1108. // if (string.IsNullOrEmpty(homeAddress))
  1109. // {
  1110. // for (int i = 0; i < pid.PatientAddressRepetitionsUsed; i++)
  1111. // {
  1112. // var add = pid.GetPatientAddress(i);
  1113. // if (add.AddressType.Value == "W") //工作地址
  1114. // {
  1115. // homeAddress = add.OtherGeographicDesignation.Value;
  1116. // SqlDataAccess.AddInParameter(ctx, cmdPatientUpd, "HomeAddress", DbType.AnsiString, homeAddress); //详细地址信息
  1117. // }
  1118. // }
  1119. // }
  1120. // SqlDataAccess.ExecuteNonQuery(ctx, cmdPatientUpd);
  1121. // }
  1122. // catch (Exception ex)
  1123. // {
  1124. // LogHelper.LogError("更新门诊现住址失败!" + ex.Message + Environment.NewLine + ex.StackTrace);
  1125. // }
  1126. // }
  1127. // #endregion
  1128. // #endregion
  1129. // }
  1130. //protected void EditNewPatient(Database ctx, ADT_A05 a05)
  1131. //{
  1132. // PID pid = a05.PID;
  1133. // PV1 pv1 = a05.PV1;
  1134. // NK1 nk1 = a05.GetNK1(0);
  1135. // EditNewPatient(ctx, pid, pv1, nk1);
  1136. //}
  1137. #endregion
  1138. /// <summary>
  1139. /// 获取员工信息
  1140. /// </summary>
  1141. /// <param name="ctx"></param>
  1142. /// <param name="empCode"></param>
  1143. /// <returns></returns>
  1144. //protected EmployeeEntity GetEmpNo(Database ctx, string empCode)
  1145. //{
  1146. // 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);
  1147. // return SqlDataAccess.ExecuteSqlStringAccessor<EmployeeEntity>(ctx, sql).FirstOrDefault();
  1148. //}
  1149. /// <summary>
  1150. /// 获取参数
  1151. /// </summary>
  1152. /// <param name="ctx"></param>
  1153. /// <param name="key"></param>
  1154. /// <returns></returns>
  1155. protected string GetParam(Database ctx, string key)
  1156. {
  1157. try
  1158. {
  1159. var sql = string.Format("SELECT ParamValue FROM HealthCare.dbo.SiteParamCtrl WHERE SiteNo='0000' AND ParamID='{0}' AND IsDel=0", key);
  1160. var cmd = SqlDataAccess.GetSqlStringCommand(ctx, sql);
  1161. var obj = SqlDataAccess.ExecuteScalar(ctx, cmd);
  1162. return StrHelepr.Obj2StrTrim(obj);
  1163. }
  1164. catch (Exception ex)
  1165. {
  1166. IL.Common.LogHelper.LogError(string.Format("获取参数错误:{0} {1}\r\n{2}", key, ex.Message, ex.StackTrace), LogCatagories.MQAccess);
  1167. return string.Empty;
  1168. }
  1169. }
  1170. protected int GetScanTaskCount(string visitNo, string type)
  1171. {
  1172. 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'";
  1173. var cmd = Scanctx.DBGetSqlStringCommand(sql);
  1174. Scanctx.AddInParameter(cmd, "VisitNo", DbType.String, visitNo);
  1175. Scanctx.AddInParameter(cmd, "TaskType", DbType.String, type);
  1176. var obj = int.Parse(StrHelepr.Obj2StrTrim(Scanctx.DBExecuteScalar(cmd)));
  1177. return obj;
  1178. }
  1179. protected int GetOriginalCount(string VisitNo)
  1180. {
  1181. var sql = "SELECT count(1) FROM dbo.zhuyuan_original WITH(NOLOCK) WHERE patient_zyh=@VisitNo ";
  1182. var cmd = ctx.DBGetSqlStringCommand(sql);
  1183. ctx.AddInParameter(cmd, "VisitNo", DbType.String, VisitNo);
  1184. var obj = int.Parse(StrHelepr.Obj2StrTrim(ctx.DBExecuteScalar(cmd)));
  1185. return obj;
  1186. }
  1187. /// <summary>
  1188. /// 获取急诊病人床位
  1189. /// </summary>
  1190. /// <param name="ctx"></param>
  1191. /// <param name="visitNo"></param>
  1192. /// <returns></returns>
  1193. //protected BedEntity GetBed(Database ctx, string roombed, string ward)
  1194. //{
  1195. // if (string.IsNullOrWhiteSpace(roombed))
  1196. // return null;
  1197. // 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);
  1198. // return SqlDataAccess.ExecuteSqlStringAccessor<BedEntity>(ctx, sql).FirstOrDefault();
  1199. //}
  1200. /// <summary>
  1201. /// 获取床位
  1202. /// </summary>
  1203. /// <param name="ctx"></param>
  1204. /// <param name="roomBed"></param>
  1205. /// <returns></returns>
  1206. //protected BedEntity GetBed(Database ctx, string roomBed)
  1207. //{
  1208. // 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);
  1209. // return SqlDataAccess.ExecuteSqlStringAccessor<BedEntity>(ctx, sql).FirstOrDefault();
  1210. //}
  1211. //protected InPatientEntity GetInPatient(Database ctx, string visitNo)
  1212. //{
  1213. // 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);
  1214. // return SqlDataAccess.ExecuteSqlStringAccessor<InPatientEntity>(ctx, sql).FirstOrDefault();
  1215. //}
  1216. }
  1217. }