DataImoport.cs 38 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922
  1. /******************************************************************************
  2. * 文件名称: DataImoport.cs
  3. * 文件说明: 医保目录数据导入
  4. * 当前版本: V1.0
  5. * 创建日期: 2022-04-12
  6. *
  7. * 2020-04-12: 增加GetDrugsJsonByTxt方法
  8. * 2020-04-12: 增加GetMedicalServiceJsonByTxt方法
  9. * 2020-04-12: 增加 GetMaterialJsonByTxt 方法
  10. * 2020-04-14: 增加 GetDiagnoseJsonByTxt 方法
  11. * 2020-04-14: 增加 GetOperationJsonByTxt 方法
  12. * 2020-04-14: 增加 applyDataToIris 方法
  13. * 2020-04-14: 增加 importDataToIrisByTxt 方法
  14. * 2020-04-14: 增加 GetOperationJsonByTxt 方法
  15. * 2020-04-14: 增加 GetOperationJsonByTxt 方法
  16. * 2020-04-14: 增加 GetOperationJsonByTxt 方法
  17. * 2020-04-14: 增加 GetOperationJsonByTxt 方法
  18. ******************************************************************************/
  19. using Newtonsoft.Json.Linq;
  20. using System;
  21. using System.Collections.Generic;
  22. using System.Linq;
  23. using System.Text;
  24. using System.Threading.Tasks;
  25. using System.Windows.Forms;
  26. using PTMedicalInsurance.Business;
  27. using PTMedicalInsurance.Helper;
  28. namespace PTMedicalInsurance
  29. {
  30. class DataImoport
  31. {
  32. /// <summary>
  33. /// 读取TXT后,Array中的空值会返回NULL,将其转换为"".应有其他方式处理,后面再优化
  34. /// 明天试试Convert.ToString(a)
  35. /// </summary>
  36. /// <param name="arrayValue"></param>
  37. /// <returns></returns>
  38. private string convertArrayNull(string arrayValue)
  39. {
  40. string returnValue = string.Empty;
  41. if (arrayValue == "null")
  42. {
  43. returnValue = "";
  44. }
  45. else
  46. {
  47. returnValue = arrayValue;
  48. }
  49. return returnValue;
  50. }
  51. /// <summary>
  52. /// 从TXT文件中获取药品数据,并组装成JSON
  53. /// </summary>
  54. /// <param name="arr"></param>
  55. /// <returns></returns>
  56. private JObject GetDrugsJsonByTxt(string[] arr)
  57. {
  58. dynamic jsonTemp = new JObject();
  59. jsonTemp.ID = "";
  60. jsonTemp.updateUserID = GlobalVariables.operatorNO;
  61. jsonTemp.HospitalDr = GlobalVariables.hospitalDr;
  62. jsonTemp.InterfaceDr = GlobalVariables.interfaceDr_Download;
  63. jsonTemp.Code = arr[0];
  64. jsonTemp.Name = arr[7];
  65. jsonTemp.HisType = "1";
  66. jsonTemp.HisTypeName = "药品";
  67. jsonTemp.LocateCode = "";
  68. jsonTemp.LocateName = "";
  69. jsonTemp.DosageFormCode = arr[9];
  70. jsonTemp.DosageFormName = arr[10];
  71. jsonTemp.CategoryCode = arr[11];
  72. jsonTemp.CategoryName = arr[12];
  73. jsonTemp.Specification = arr[13];
  74. jsonTemp.SpecificationCode = arr[14];
  75. jsonTemp.UnitOfPackag = arr[43];
  76. jsonTemp.UnitOfValuation = arr[40];
  77. jsonTemp.StartDate = convertArrayNull(arr[37]);
  78. jsonTemp.EndDate = convertArrayNull(arr[38]);
  79. jsonTemp.PinyinSearchCode = arr[51];
  80. jsonTemp.Instructions = arr[36];
  81. jsonTemp.ExceptContent = "";
  82. jsonTemp.Connotation = "";
  83. jsonTemp.ValidFlag = 1;// convertArrayNull(arr[79]);
  84. jsonTemp.Note = arr[78];
  85. jsonTemp.VersionNO = arr[83];
  86. jsonTemp.VersionName = arr[84];
  87. jsonTemp.UseFlag = 1;
  88. jsonTemp.DrugSafetyStandardCode = arr[9];
  89. jsonTemp.ApprovalNO = arr[56];
  90. jsonTemp.SpecialFlag = convertArrayNull(arr[62]);
  91. jsonTemp.LimitFlag = convertArrayNull(arr[58]);
  92. jsonTemp.LimitRange = arr[57];
  93. jsonTemp.UniqueRecordNO = arr[79];
  94. jsonTemp.Manufacturers = arr[53];
  95. return jsonTemp;
  96. }
  97. /// <summary>
  98. /// 从TXT文件中获取诊疗数据,并组装成JSON
  99. /// </summary>
  100. /// <param name="arr"></param>
  101. /// <returns></returns>
  102. private JObject GetMedicalServiceJsonByTxt(string[] arr)
  103. {
  104. dynamic jsonTemp = new JObject();
  105. jsonTemp.ID = "";
  106. jsonTemp.updateUserID = GlobalVariables.operatorNO;
  107. jsonTemp.HospitalDr = GlobalVariables.hospitalDr;
  108. jsonTemp.InterfaceDr = GlobalVariables.interfaceDr_Download;
  109. jsonTemp.Code = arr[0];
  110. jsonTemp.Name = arr[9];
  111. jsonTemp.HisType = "2";
  112. jsonTemp.HisTypeName = "诊疗";
  113. jsonTemp.LocateCode = "";
  114. jsonTemp.LocateName = "";
  115. jsonTemp.DosageFormCode = arr[9];
  116. jsonTemp.DosageFormName = arr[10];
  117. jsonTemp.CategoryCode = arr[8];
  118. jsonTemp.CategoryName = arr[12];
  119. jsonTemp.Specification = "";
  120. jsonTemp.SpecificationCode = "";
  121. jsonTemp.UnitOfPackag = "";
  122. jsonTemp.UnitOfValuation = convertArrayNull(arr[3]);
  123. jsonTemp.StartDate = convertArrayNull(arr[11]);
  124. jsonTemp.EndDate = convertArrayNull(arr[12]);
  125. ////jsonTemp.PinyinSearchCode = SpellCodeHelper.GetFirstPYLetter(arr[9]);
  126. jsonTemp.Instructions = arr[3];
  127. jsonTemp.ExceptContent = arr[4];
  128. jsonTemp.Connotation = arr[5];
  129. jsonTemp.ValidFlag = arr[6];
  130. jsonTemp.Note = arr[7];
  131. jsonTemp.VersionNO = arr[14];
  132. jsonTemp.VersionName = arr[15];
  133. jsonTemp.UseFlag = 1;
  134. jsonTemp.DrugSafetyStandardCode = "";
  135. jsonTemp.ApprovalNO = "";
  136. jsonTemp.SpecialFlag = "";
  137. jsonTemp.LimitFlag = "";
  138. jsonTemp.LimitRange = "";
  139. jsonTemp.UniqueRecordNO = arr[13];
  140. return jsonTemp;
  141. }
  142. /// <summary>
  143. /// 从TXT文件中获取材料数据,并组装成JSON
  144. /// </summary>
  145. /// <param name="arr"></param>
  146. /// <returns></returns>
  147. private JObject GetMaterialJsonByTxt(string[] arr)
  148. {
  149. dynamic jsonTemp = new JObject();
  150. jsonTemp.updateUserID = GlobalVariables.operatorNO;
  151. jsonTemp.ID = "";
  152. jsonTemp.HospitalDr = GlobalVariables.hospitalDr;
  153. jsonTemp.InterfaceDr = GlobalVariables.interfaceDr_Download;
  154. jsonTemp.Code = arr[0];
  155. jsonTemp.Name = arr[5];
  156. jsonTemp.HisType = "3";
  157. jsonTemp.HisTypeName = "材料";
  158. jsonTemp.LocateCode = "";
  159. jsonTemp.LocateName = "";
  160. jsonTemp.DosageFormCode = "";
  161. jsonTemp.DosageFormName = "";
  162. jsonTemp.CategoryCode = "";
  163. jsonTemp.CategoryName = "";
  164. jsonTemp.Specification = arr[7];
  165. jsonTemp.SpecificationCode = arr[6];
  166. jsonTemp.UnitOfPackag = arr[15];
  167. jsonTemp.UnitOfValuation = convertArrayNull(arr[35]);
  168. jsonTemp.StartDate = convertArrayNull(arr[46]);
  169. jsonTemp.EndDate = convertArrayNull(arr[47]);
  170. //jsonTemp.PinyinSearchCode = SpellCodeHelper.GetFirstPYLetter(arr[5]);
  171. jsonTemp.Instructions = arr[27];
  172. jsonTemp.ExceptContent = "";
  173. jsonTemp.Connotation = "";
  174. jsonTemp.ValidFlag = arr[67];
  175. jsonTemp.Note = arr[7];
  176. jsonTemp.VersionNO = arr[69];
  177. jsonTemp.VersionName = arr[70];
  178. jsonTemp.UseFlag = 1;
  179. jsonTemp.DrugSafetyStandardCode = "";
  180. jsonTemp.ApprovalNO = "";
  181. jsonTemp.SpecialFlag = "";
  182. jsonTemp.LimitFlag = convertArrayNull(arr[33]);
  183. jsonTemp.LimitRange = arr[34];
  184. jsonTemp.UniqueRecordNO = arr[68];
  185. jsonTemp.Manufacturers = arr[59];
  186. return jsonTemp;
  187. }
  188. /// <summary>
  189. /// 从TXT文件中获取诊断数据,并组装成JSON
  190. /// </summary>
  191. /// <param name="arr"></param>
  192. /// <returns></returns>
  193. private JObject GetDiagnoseJsonByTxt(string[] arr)
  194. {
  195. dynamic jsonTemp = new JObject();
  196. jsonTemp.updateUserID = GlobalVariables.operatorNO;
  197. jsonTemp.ID = "";
  198. jsonTemp.HospitalDr = GlobalVariables.hospitalDr;
  199. jsonTemp.InterfaceDr = GlobalVariables.interfaceDr_Download;
  200. jsonTemp.Code = arr[10];
  201. jsonTemp.Name = arr[11];
  202. jsonTemp.HisType = "4";
  203. jsonTemp.HisTypeName = "诊断";
  204. jsonTemp.LocateCode = "";
  205. jsonTemp.LocateName = "";
  206. jsonTemp.DosageFormCode = "";
  207. jsonTemp.DosageFormName = "";
  208. jsonTemp.CategoryCode = "";
  209. jsonTemp.CategoryName = "";
  210. jsonTemp.Specification = "";
  211. jsonTemp.SpecificationCode = "";
  212. jsonTemp.UnitOfPackag = "";
  213. jsonTemp.UnitOfValuation = "";
  214. jsonTemp.StartDate = "";
  215. jsonTemp.EndDate = "";
  216. //jsonTemp.PinyinSearchCode = SpellCodeHelper.GetFirstPYLetter(arr[11]);
  217. jsonTemp.Instructions = "";
  218. jsonTemp.ExceptContent = "";
  219. jsonTemp.Connotation = "";
  220. jsonTemp.ValidFlag = arr[18];
  221. jsonTemp.Note = arr[17];
  222. jsonTemp.VersionNO = arr[22];
  223. jsonTemp.VersionName = arr[23];
  224. jsonTemp.UseFlag = 1;
  225. jsonTemp.DrugSafetyStandardCode = "";
  226. jsonTemp.ApprovalNO = "";
  227. jsonTemp.SpecialFlag = "";
  228. jsonTemp.LimitFlag = "";
  229. jsonTemp.LimitRange = "";
  230. jsonTemp.UniqueRecordNO = arr[19];
  231. jsonTemp.Manufacturers = "";
  232. return jsonTemp;
  233. }
  234. /// <summary>
  235. /// 慢性病
  236. /// </summary>
  237. /// <param name="arr"></param>
  238. /// <returns></returns>
  239. private JObject GetChronicDiseaseJsonByTxt(string[] arr)
  240. {
  241. dynamic jsonTemp = new JObject();
  242. jsonTemp.updateUserID = GlobalVariables.operatorNO;
  243. jsonTemp.ID = "";
  244. jsonTemp.HospitalDr = GlobalVariables.hospitalDr;
  245. jsonTemp.InterfaceDr = GlobalVariables.interfaceDr_Download;
  246. jsonTemp.Code = arr[0];
  247. jsonTemp.Name = arr[1];
  248. jsonTemp.HisType = "6";
  249. jsonTemp.HisTypeName = "慢性病";
  250. jsonTemp.LocateCode = "";
  251. jsonTemp.LocateName = "";
  252. jsonTemp.DosageFormCode = "";
  253. jsonTemp.DosageFormName = "";
  254. jsonTemp.CategoryCode = arr[14];
  255. jsonTemp.CategoryName = arr[15];
  256. jsonTemp.Specification = "";
  257. jsonTemp.SpecificationCode = "";
  258. jsonTemp.UnitOfPackag = "";
  259. jsonTemp.UnitOfValuation = "";
  260. jsonTemp.StartDate = "";
  261. jsonTemp.EndDate = "";
  262. //jsonTemp.PinyinSearchCode = SpellCodeHelper.GetFirstPYLetter(arr[2]);
  263. jsonTemp.Instructions = "";
  264. jsonTemp.ExceptContent = "";
  265. jsonTemp.Connotation = arr[10];
  266. jsonTemp.ValidFlag = arr[5];
  267. jsonTemp.Note = arr[4];
  268. jsonTemp.VersionNO = arr[9];
  269. jsonTemp.VersionName = arr[11];
  270. jsonTemp.UseFlag = 1;
  271. jsonTemp.DrugSafetyStandardCode = "";
  272. jsonTemp.ApprovalNO = "";
  273. jsonTemp.SpecialFlag = "";
  274. jsonTemp.LimitFlag = "";
  275. jsonTemp.LimitRange = "";
  276. jsonTemp.UniqueRecordNO = arr[6];
  277. jsonTemp.Manufacturers = "";
  278. return jsonTemp;
  279. }
  280. /// <summary>
  281. /// 从TXT文件中获取手术数据,并组装成JSON
  282. /// </summary>
  283. /// <param name="arr"></param>
  284. /// <returns></returns>
  285. private JObject GetOperationJsonByTxt(string[] arr)
  286. {
  287. dynamic jsonTemp = new JObject();
  288. jsonTemp.updateUserID = GlobalVariables.operatorNO;
  289. jsonTemp.ID = "";
  290. jsonTemp.HospitalDr = GlobalVariables.hospitalDr;
  291. jsonTemp.InterfaceDr = GlobalVariables.interfaceDr_Download;
  292. jsonTemp.Code = arr[10];
  293. jsonTemp.Name = arr[11];
  294. jsonTemp.HisType = "5";
  295. jsonTemp.HisTypeName = "手术";
  296. //jsonTemp.PinyinSearchCode = SpellCodeHelper.GetFirstPYLetter(arr[11]);
  297. jsonTemp.ValidFlag = arr[18];
  298. jsonTemp.Note = arr[17];
  299. jsonTemp.VersionNO = arr[22];
  300. jsonTemp.VersionName = arr[23];
  301. jsonTemp.UseFlag = 1;
  302. jsonTemp.UniqueRecordNO = arr[19];
  303. return jsonTemp;
  304. }
  305. /// <summary>
  306. /// DRGs
  307. /// </summary>
  308. /// <param name="arr"></param>
  309. /// <returns></returns>
  310. private JObject GetDRGsJsonByTxt(string[] arr)
  311. {
  312. dynamic jsonTemp = new JObject();
  313. jsonTemp.updateUserID = GlobalVariables.operatorNO;
  314. jsonTemp.ID = "";
  315. jsonTemp.HospitalDr = GlobalVariables.hospitalDr;
  316. jsonTemp.InterfaceDr = GlobalVariables.interfaceDr_Download;
  317. jsonTemp.Code = arr[1];
  318. jsonTemp.Name = arr[2];
  319. jsonTemp.HisType = "7";
  320. jsonTemp.HisTypeName = "DRGs";
  321. jsonTemp.Connotation = arr[10];
  322. //jsonTemp.PinyinSearchCode = SpellCodeHelper.GetFirstPYLetter(arr[11]);
  323. jsonTemp.ValidFlag = arr[5];
  324. jsonTemp.Note = arr[11];
  325. jsonTemp.VersionNO = arr[9];
  326. jsonTemp.VersionName = arr[12];
  327. jsonTemp.UseFlag = 1;
  328. jsonTemp.UniqueRecordNO = arr[6];
  329. return jsonTemp;
  330. }
  331. private JObject GetDaySurgeryJsonByTxt(string[] arr)
  332. {
  333. dynamic jsonTemp = new JObject();
  334. jsonTemp.updateUserID = GlobalVariables.operatorNO;
  335. jsonTemp.ID = "";
  336. jsonTemp.HospitalDr = GlobalVariables.hospitalDr;
  337. jsonTemp.InterfaceDr = GlobalVariables.interfaceDr_Download;
  338. jsonTemp.Code = arr[1];
  339. jsonTemp.Name = arr[2];
  340. jsonTemp.HisType = "8";
  341. jsonTemp.HisTypeName = "日间手术";
  342. jsonTemp.Connotation = arr[8];
  343. //jsonTemp.PinyinSearchCode = SpellCodeHelper.GetFirstPYLetter(arr[11]);
  344. jsonTemp.ValidFlag = arr[3];
  345. jsonTemp.Note = arr[9];
  346. jsonTemp.VersionNO = arr[7];
  347. jsonTemp.VersionName = arr[10];
  348. jsonTemp.UseFlag = 1;
  349. jsonTemp.UniqueRecordNO = arr[4];
  350. return jsonTemp;
  351. }
  352. /// <summary>
  353. /// 从TXT文件中获取中药饮片数据,并组装成JSON
  354. /// </summary>
  355. /// <param name="arr"></param>
  356. /// <returns></returns>
  357. private JObject GetChineseMedicineJsonByTxt(string[] arr)
  358. {
  359. dynamic jsonTemp = new JObject();
  360. jsonTemp.ID = "";
  361. jsonTemp.updateUserID = GlobalVariables.operatorNO;
  362. jsonTemp.HospitalDr = GlobalVariables.hospitalDr;
  363. jsonTemp.InterfaceDr = GlobalVariables.interfaceDr_Download;
  364. jsonTemp.Code = arr[0];
  365. jsonTemp.Name = arr[1];
  366. jsonTemp.HisType = "9";
  367. jsonTemp.HisTypeName = "中药饮片";
  368. jsonTemp.LocateCode = "";
  369. jsonTemp.LocateName = "";
  370. jsonTemp.DosageFormCode = arr[2]; //剂型
  371. jsonTemp.DosageFormName = arr[5]; //药用部位
  372. jsonTemp.CategoryCode = arr[3]; //质量等级
  373. jsonTemp.CategoryName = arr[4]; //中草药年份
  374. jsonTemp.Specification = arr[6]; //安全计量
  375. jsonTemp.SpecificationCode = arr[22]; //功效分类
  376. jsonTemp.UnitOfPackag = "";
  377. jsonTemp.UnitOfValuation = "";
  378. jsonTemp.StartDate = convertArrayNull(arr[11]);
  379. jsonTemp.EndDate = convertArrayNull(arr[12]);
  380. jsonTemp.PinyinSearchCode = "";
  381. jsonTemp.Instructions = arr[11];
  382. jsonTemp.ExceptContent = "";
  383. jsonTemp.Connotation = "";
  384. jsonTemp.ValidFlag = 1;// convertArrayNull(arr[79]);
  385. jsonTemp.Note = arr[21];
  386. jsonTemp.VersionNO = arr[17];
  387. jsonTemp.VersionName = arr[18];
  388. jsonTemp.UseFlag = 1;
  389. jsonTemp.DrugSafetyStandardCode = "";
  390. jsonTemp.ApprovalNO = "";
  391. jsonTemp.SpecialFlag = "0";
  392. jsonTemp.LimitFlag = "";
  393. jsonTemp.LimitRange = arr[26];
  394. jsonTemp.UniqueRecordNO = arr[27];
  395. jsonTemp.Manufacturers = arr[28];
  396. return jsonTemp;
  397. }
  398. /// <summary>
  399. /// 从TXT文件中获取医疗机构制剂目录数据,并组装成JSON
  400. /// </summary>
  401. /// <param name="arr"></param>
  402. /// <returns></returns>
  403. private JObject GetPreparationJsonByTxt(string[] arr)
  404. {
  405. dynamic jsonTemp = new JObject();
  406. jsonTemp.ID = "";
  407. jsonTemp.updateUserID = GlobalVariables.operatorNO;
  408. jsonTemp.HospitalDr = GlobalVariables.hospitalDr;
  409. jsonTemp.InterfaceDr = GlobalVariables.interfaceDr_Download;
  410. jsonTemp.Code = arr[0];
  411. jsonTemp.Name = arr[1];
  412. jsonTemp.HisType = "10";
  413. jsonTemp.HisTypeName = "医疗机构制剂";
  414. jsonTemp.LocateCode = "";
  415. jsonTemp.LocateName = "";
  416. jsonTemp.DosageFormCode = arr[4]; //剂型
  417. jsonTemp.DosageFormName = arr[5]; //剂型名称
  418. jsonTemp.CategoryCode = arr[18]; //药品类别
  419. jsonTemp.CategoryName = arr[19]; //药品类别名称
  420. jsonTemp.Specification = arr[10]; //规格
  421. jsonTemp.SpecificationCode = arr[11]; //规格代码
  422. jsonTemp.UnitOfPackag = arr[32]; //最小制剂单位
  423. jsonTemp.UnitOfValuation = arr[29]; //最小计量单位
  424. jsonTemp.StartDate = convertArrayNull(arr[65]);
  425. jsonTemp.EndDate = convertArrayNull(arr[66]);
  426. jsonTemp.PinyinSearchCode = "";
  427. jsonTemp.Instructions = arr[25];
  428. jsonTemp.ExceptContent = "";
  429. jsonTemp.Connotation = "";
  430. jsonTemp.ValidFlag = 1;// convertArrayNull(arr[79]);
  431. jsonTemp.Note = arr[63]; //备注
  432. jsonTemp.VersionNO = arr[70];
  433. jsonTemp.VersionName = arr[71];
  434. jsonTemp.UseFlag = 1;
  435. jsonTemp.DrugSafetyStandardCode = "";
  436. jsonTemp.ApprovalNO = arr[43]; //批准文号
  437. jsonTemp.SpecialFlag = convertArrayNull(arr[42]);
  438. jsonTemp.LimitFlag = arr[42]; //特殊限价药品标志
  439. jsonTemp.LimitRange = arr[50]; //限制范围
  440. jsonTemp.UniqueRecordNO = arr[67]; //唯一记录号
  441. jsonTemp.Manufacturers = arr[40]; //生产厂家
  442. return jsonTemp;
  443. }
  444. /// <summary>
  445. /// 肿瘤形态学
  446. /// </summary>
  447. /// <param name="arr"></param>
  448. /// <returns></returns>
  449. private JObject GetTumorMorphologyJsonByTxt(string[] arr)
  450. {
  451. dynamic jsonTemp = new JObject();
  452. jsonTemp.updateUserID = GlobalVariables.operatorNO;
  453. jsonTemp.ID = "";
  454. jsonTemp.HospitalDr = GlobalVariables.hospitalDr;
  455. jsonTemp.InterfaceDr = GlobalVariables.interfaceDr_Download;
  456. jsonTemp.Code = arr[6]; //唯一记录号
  457. jsonTemp.Name = arr[0]; //肿瘤形态学ID
  458. jsonTemp.HisType = "11";
  459. jsonTemp.HisTypeName = "肿瘤形态学";
  460. jsonTemp.Connotation = arr[1]; //肿瘤/细胞类型代码
  461. jsonTemp.DosageFormCode = arr[3]; //形态学分类代码
  462. jsonTemp.DosageFormName = arr[4]; //形态学分类
  463. jsonTemp.CategoryCode = arr[7]; //数据创建时间
  464. jsonTemp.CategoryName = arr[8]; //数据更新时间
  465. //jsonTemp.PinyinSearchCode = SpellCodeHelper.GetFirstPYLetter(arr[11]);
  466. jsonTemp.ValidFlag = arr[5]; //有效标志
  467. jsonTemp.Note = ""; //
  468. jsonTemp.VersionNO = arr[9]; //版本号
  469. jsonTemp.VersionName = arr[10]; //版本号名称
  470. jsonTemp.UseFlag = 1;
  471. jsonTemp.UniqueRecordNO = arr[6]; //唯一记录号
  472. return jsonTemp;
  473. }
  474. /// <summary>
  475. /// 从TXT文件中获取中医疾病数据,并组装成JSON
  476. /// </summary>
  477. /// <param name="arr"></param>
  478. /// <returns></returns>
  479. private JObject GetChineseDiagnoseJsonByTxt(string[] arr)
  480. {
  481. dynamic jsonTemp = new JObject();
  482. jsonTemp.updateUserID = GlobalVariables.operatorNO;
  483. jsonTemp.ID = "";
  484. jsonTemp.HospitalDr = GlobalVariables.hospitalDr;
  485. jsonTemp.InterfaceDr = GlobalVariables.interfaceDr_Download;
  486. jsonTemp.Code = arr[0]; //中医疾病诊断ID
  487. jsonTemp.Name = arr[6]; //疾病分类名称
  488. jsonTemp.HisType = "12";
  489. jsonTemp.HisTypeName = "中医疾病";
  490. jsonTemp.LocateCode = arr[1]; //科别类目代码
  491. jsonTemp.LocateName = arr[2]; //科别类目名称
  492. jsonTemp.DosageFormCode = arr[3]; //专科系统分类目代码
  493. jsonTemp.DosageFormName = arr[4]; //专科系统分类目名称
  494. jsonTemp.CategoryCode = arr[5]; //疾病分类代码
  495. jsonTemp.CategoryName = arr[6]; //疾病分类名称
  496. jsonTemp.Specification = "";
  497. jsonTemp.SpecificationCode = "";
  498. jsonTemp.UnitOfPackag = "";
  499. jsonTemp.UnitOfValuation = "";
  500. jsonTemp.StartDate = "";
  501. jsonTemp.EndDate = "";
  502. //jsonTemp.PinyinSearchCode = SpellCodeHelper.GetFirstPYLetter(arr[11]);
  503. jsonTemp.Instructions = "";
  504. jsonTemp.ExceptContent = "";
  505. jsonTemp.Connotation = "";
  506. jsonTemp.ValidFlag = arr[8]; //有效标志
  507. jsonTemp.Note = arr[7]; //备注
  508. jsonTemp.VersionNO = arr[12]; //版本号
  509. jsonTemp.VersionName = arr[13]; //版本名称
  510. jsonTemp.UseFlag = 1;
  511. jsonTemp.DrugSafetyStandardCode = "";
  512. jsonTemp.ApprovalNO = "";
  513. jsonTemp.SpecialFlag = "";
  514. jsonTemp.LimitFlag = "";
  515. jsonTemp.LimitRange = "";
  516. jsonTemp.UniqueRecordNO = arr[9]; //唯一记录号
  517. jsonTemp.Manufacturers = "";
  518. return jsonTemp;
  519. }
  520. /// <summary>
  521. /// 从TXT文件中获取中医证候数据,并组装成JSON
  522. /// </summary>
  523. /// <param name="arr"></param>
  524. /// <returns></returns>
  525. private JObject GetTCMSyndromeJsonByTxt(string[] arr)
  526. {
  527. dynamic jsonTemp = new JObject();
  528. jsonTemp.updateUserID = GlobalVariables.operatorNO;
  529. jsonTemp.ID = "";
  530. jsonTemp.HospitalDr = GlobalVariables.hospitalDr;
  531. jsonTemp.InterfaceDr = GlobalVariables.interfaceDr_Download;
  532. jsonTemp.Code = arr[0]; //中医证候ID
  533. jsonTemp.Name = arr[2]; //证候类目名称
  534. jsonTemp.HisType = "13";
  535. jsonTemp.HisTypeName = "中医证候";
  536. jsonTemp.LocateCode = arr[1]; //证候类目代码
  537. jsonTemp.LocateName = arr[2]; //证候类目名称
  538. jsonTemp.DosageFormCode = arr[3]; //证候属性代码
  539. jsonTemp.DosageFormName = arr[4]; //证候属性
  540. jsonTemp.CategoryCode = arr[5]; //证候分类代码
  541. jsonTemp.CategoryName = arr[6]; //证候分类名称
  542. jsonTemp.Specification = "";
  543. jsonTemp.SpecificationCode = "";
  544. jsonTemp.UnitOfPackag = "";
  545. jsonTemp.UnitOfValuation = "";
  546. jsonTemp.StartDate = "";
  547. jsonTemp.EndDate = "";
  548. //jsonTemp.PinyinSearchCode = SpellCodeHelper.GetFirstPYLetter(arr[11]);
  549. jsonTemp.Instructions = "";
  550. jsonTemp.ExceptContent = "";
  551. jsonTemp.Connotation = "";
  552. jsonTemp.ValidFlag = arr[8]; //有效标志
  553. jsonTemp.Note = arr[7]; //备注
  554. jsonTemp.VersionNO = arr[12]; //版本号
  555. jsonTemp.VersionName = arr[13]; //版本名称
  556. jsonTemp.UseFlag = 1;
  557. jsonTemp.DrugSafetyStandardCode = "";
  558. jsonTemp.ApprovalNO = "";
  559. jsonTemp.SpecialFlag = "";
  560. jsonTemp.LimitFlag = "";
  561. jsonTemp.LimitRange = "";
  562. jsonTemp.UniqueRecordNO = arr[9]; //唯一记录号
  563. jsonTemp.Manufacturers = "";
  564. return jsonTemp;
  565. }
  566. /// <summary>
  567. /// 提交数据给IRIS
  568. /// </summary>
  569. /// <param name="code"></param>
  570. /// <param name="jaParam"></param>
  571. /// <returns></returns>
  572. private JObject applyDataToIris(string code, JArray jaParam)
  573. {
  574. JObject joIn = new JObject();
  575. JObject joRtn = new JObject();
  576. string outParam = "";
  577. try
  578. {
  579. joIn.Add(new JProperty("params", jaParam));
  580. joIn.Add("code", code);
  581. joIn.Add("updateUserID", GlobalVariables.operatorNO);
  582. InvokeHelper invoker = new InvokeHelper();
  583. string sInput = joIn.ToString();
  584. joRtn = invoker.invokeInsuService(sInput, "applyDataToIris");
  585. outParam = joRtn.ToString();
  586. return joRtn;
  587. }
  588. catch (Exception ex)
  589. {
  590. joRtn = JsonHelper.getIrisExceptionJson(-1, "applyDataToIris", ex.Message);
  591. outParam = joRtn.ToString();
  592. return joRtn;
  593. }
  594. }
  595. /// <summary>
  596. /// 将Json格式数据提交存储到IRIS
  597. /// </summary>
  598. /// <param name="sInput"></param>
  599. /// <returns></returns>
  600. public JObject importDataToIrisByJson(string sInput,string Code)
  601. {
  602. string errorMsg = "";
  603. try
  604. {
  605. //循环调用IRIS接口进行数据插入
  606. //JObject obj = (JObject)JsonConvert.DeserializeObject(sOutpar);
  607. JObject obj = Newtonsoft.Json.Linq.JObject.Parse(sInput);
  608. string RecordData = obj["body"]["output"]["medinsinfo"].ToString();
  609. JArray array = Newtonsoft.Json.Linq.JArray.Parse(RecordData);
  610. JArray jaParams = new JArray();
  611. //遍历JArray数组
  612. foreach (var ss in array)
  613. {
  614. dynamic jsonTemp = new JObject();
  615. jsonTemp.updateUserID = GlobalVariables.operatorNO;
  616. jsonTemp.ID = "";
  617. jsonTemp.HospitalDr = GlobalVariables.hospitalDr;
  618. jsonTemp.InterfaceDr = GlobalVariables.interfaceDr_Download;
  619. jsonTemp.Code = ss["fixmedins_code"].ToString();
  620. jsonTemp.Descripts = ss["fixmedins_name"].ToString();
  621. jsonTemp.OrganizationCode = GlobalVariables.hospitalID;
  622. jsonTemp.HospTypeDr = ss["fixmedins_type"].ToString();
  623. jsonTemp.HospGradeDr = ss["hosp_lv"].ToString();
  624. jsonTemp.HospNatureDr = "MedInsu";
  625. jsonTemp.Businesslicense = "";
  626. jsonTemp.Active = "Y";
  627. jaParams.Add(jsonTemp);
  628. DataImoport DataImp = new DataImoport();
  629. JObject joRtn = applyDataToIris(Code, jaParams);
  630. if (joRtn["errorCode"].ToString() != "0")
  631. {
  632. errorMsg = joRtn["errorMessage"].ToString();
  633. return JsonHelper.getIrisExceptionJson(-1, "importDataToIrisByJson", errorMsg);
  634. }
  635. }
  636. return JsonHelper.getIrisReturnJson(0, errorMsg, new JObject());
  637. }
  638. catch (Exception ex)
  639. {
  640. return JsonHelper.getIrisExceptionJson(-1, "importDataToIrisByJson", ex.Message);
  641. }
  642. }
  643. /// <summary>
  644. /// 从TXT里导数据到IRIS
  645. /// </summary>
  646. /// <param name="sJson"></param>
  647. /// <param name="singleRows"></param>
  648. /// <param name="direcType"></param>
  649. /// <param name="processBar"></param>
  650. /// <returns></returns>
  651. public JObject importDataToIrisByJson(string sJson, int size, int direcType, Sunny.UI.UIProcessBar processBar)
  652. {
  653. int errorCount = 0;
  654. string errorMsg = "";
  655. try
  656. {
  657. return JsonHelper.getIrisReturnJson(0 - errorCount, errorMsg, new JObject());
  658. }
  659. catch (Exception ex)
  660. {
  661. return JsonHelper.getIrisExceptionJson(-1, "importDataToIrisByJson", ex.Message);
  662. }
  663. }
  664. /// <summary>
  665. /// 从TXT里导数据到IRIS
  666. /// </summary>
  667. /// <param name="txtPath"></param>
  668. /// <param name="singleRows"></param>
  669. /// <param name="direcType"></param>
  670. /// <param name="processBar"></param>
  671. /// <returns></returns>
  672. public JObject importDataToIrisByTxt(string txtPath, int size, int direcType, Sunny.UI.UIProcessBar processBar)
  673. {
  674. int errorCount = 0;
  675. string errorMsg = "";
  676. try
  677. {
  678. /*据说速度更快
  679. * https://www.cnblogs.com/eniac12/p/4398310.html
  680. * using (StreamReader sr = File.OpenText(fileName))
  681. {
  682. string s = String.Empty;
  683. while ((s = sr.ReadLine()) != null)
  684. {
  685. //do what you have to here
  686. }
  687. }
  688. Convert.ToString(a)
  689. */
  690. string[] lines = System.IO.File.ReadAllLines(txtPath);
  691. dynamic jaParams = new JArray();
  692. int rows = lines.Length;
  693. processBar.Maximum = rows;
  694. for (int i = 0; i < rows; i++)
  695. {
  696. processBar.Value = i + 1;
  697. Application.DoEvents();
  698. string lineTmp = lines[i];
  699. string[] arr = lineTmp.Split('\t');
  700. //判断是哪种目录类型
  701. string code = string.Empty;
  702. switch (direcType)
  703. {
  704. //药品
  705. case 1:
  706. {
  707. jaParams.Add(GetDrugsJsonByTxt(arr));
  708. break;
  709. }
  710. //诊疗
  711. case 2:
  712. {
  713. jaParams.Add(GetMedicalServiceJsonByTxt(arr));
  714. break;
  715. }
  716. //材料
  717. case 3:
  718. {
  719. jaParams.Add(GetMaterialJsonByTxt(arr));
  720. break;
  721. }
  722. //诊断
  723. case 4:
  724. {
  725. jaParams.Add(GetDiagnoseJsonByTxt(arr));
  726. break;
  727. }
  728. //手术
  729. case 5:
  730. {
  731. jaParams.Add(GetOperationJsonByTxt(arr));
  732. break;
  733. }
  734. //慢性病
  735. case 6:
  736. {
  737. jaParams.Add(GetChronicDiseaseJsonByTxt(arr));
  738. break;
  739. }
  740. //DRGs
  741. case 7:
  742. {
  743. jaParams.Add(GetDRGsJsonByTxt(arr));
  744. break;
  745. }
  746. //日间手术
  747. case 8:
  748. {
  749. jaParams.Add(GetDaySurgeryJsonByTxt(arr));
  750. break;
  751. }
  752. //中药饮片目录下载1
  753. case 9:
  754. {
  755. jaParams.Add(GetChineseMedicineJsonByTxt(arr));
  756. break;
  757. }
  758. //医药机构制剂目录下载
  759. case 10:
  760. {
  761. jaParams.Add(GetPreparationJsonByTxt(arr));
  762. break;
  763. }
  764. //肿瘤形态学下载
  765. case 11:
  766. {
  767. jaParams.Add(GetTumorMorphologyJsonByTxt(arr));
  768. break;
  769. }
  770. //中医疾病下载
  771. case 12:
  772. {
  773. jaParams.Add(GetChineseDiagnoseJsonByTxt(arr));
  774. break;
  775. }
  776. //中医证候下载
  777. case 13:
  778. {
  779. jaParams.Add(GetTCMSyndromeJsonByTxt(arr));
  780. break;
  781. }
  782. }
  783. code = "09010035";
  784. //每50行提交一次给后台
  785. int currentRows = i + 1;
  786. if ((currentRows % size == 0) && (i != 0))
  787. {
  788. JObject joRtn = applyDataToIris(code, jaParams);
  789. if (joRtn["errorCode"].ToString() != "0")
  790. {
  791. errorCount = errorCount + 1;
  792. errorMsg = "\r\n" +errorMsg + joRtn["errorMessage"].ToString();
  793. }
  794. jaParams = new JArray();
  795. }
  796. if ((currentRows == rows) && (currentRows % size != 0))
  797. {
  798. JObject joRtn = applyDataToIris(code, jaParams);
  799. if (joRtn["errorCode"].ToString() != "0")
  800. {
  801. errorCount = errorCount + 1;
  802. errorMsg = "\r\n" + errorMsg + joRtn["errorMessage"].ToString();
  803. }
  804. jaParams = new JArray();
  805. }
  806. }
  807. return JsonHelper.getIrisReturnJson(0 - errorCount, errorMsg, new JObject());
  808. }
  809. catch (Exception ex)
  810. {
  811. return JsonHelper.getIrisExceptionJson(-1, "importDataToIrisByTxt", ex.Message);
  812. }
  813. }
  814. public JObject importDictinary(Sunny.UI.UIProcessBar uiProcessBar,JArray jaList)
  815. {
  816. int errorCount = 0;
  817. string errorMsg = "",outParam = "";
  818. JObject joReturn = new JObject();
  819. try
  820. {
  821. JArray jaParams = new JArray();
  822. int rows = jaList.Count ;
  823. uiProcessBar.Maximum = rows;
  824. for (int i = 0; i < jaList.Count ; i++)
  825. {
  826. uiProcessBar.Value = i + 1;
  827. dynamic joTmp = new JObject();
  828. joTmp.ID = "";
  829. joTmp.updateUserID = GlobalVariables.operatorNO;
  830. joTmp.HospitalDr = GlobalVariables.hospitalDr;
  831. joTmp.InterfaceDr = GlobalVariables.interfaceDr_Download;
  832. joTmp.Type = jaList[i]["type"].ToString();
  833. joTmp.Code = jaList[i]["value"].ToString();
  834. joTmp.Name = jaList[i]["label"].ToString();
  835. joTmp.Description = jaList[i]["parent_value"].ToString();
  836. joTmp.PinyinSearchCode = "";
  837. joTmp.ValiFlag = jaList[i]["vali_flag"].ToString();
  838. joTmp.UseFlag = 1;
  839. jaParams.Add(joTmp);
  840. //每50行提交一次给后台
  841. int currentRows = i + 1;
  842. string code = "09010011";
  843. if ((currentRows % 50 == 0) && (i != 0))
  844. {
  845. JObject joRtn = applyDataToIris(code, jaParams);
  846. if (joRtn["errorCode"].ToString() != "0")
  847. {
  848. errorCount = errorCount + 1;
  849. errorMsg = "\r\n" + errorMsg + joRtn["errorMessage"].ToString();
  850. }
  851. jaParams = new JArray();
  852. }
  853. if ((currentRows == rows) && (currentRows % 50 != 0))
  854. {
  855. JObject joRtn = applyDataToIris(code, jaParams);
  856. if (joRtn["errorCode"].ToString() != "0")
  857. {
  858. errorCount = errorCount + 1;
  859. errorMsg = "\r\n" + errorMsg + joRtn["errorMessage"].ToString();
  860. }
  861. jaParams = new JArray();
  862. }
  863. }
  864. joReturn = JsonHelper.getIrisReturnJson(0 - errorCount, errorMsg, new JObject());
  865. outParam = joReturn.ToString();
  866. return joReturn;
  867. }
  868. catch (Exception ex)
  869. {
  870. joReturn = JsonHelper.getIrisExceptionJson(-1, "importDictinary", ex.Message);
  871. outParam = joReturn.ToString();
  872. return joReturn;
  873. }
  874. finally
  875. {
  876. GlobalVariables.writeLog("importDictinary", jaList.ToString(),outParam);
  877. }
  878. }
  879. }
  880. }