zh_his_service.go 33KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910
  1. package service
  2. import (
  3. "bytes"
  4. "encoding/json"
  5. "fmt"
  6. "gdyb/models"
  7. "github.com/astaxie/beego"
  8. "github.com/jinzhu/gorm"
  9. "io/ioutil"
  10. "net/http"
  11. "strconv"
  12. "time"
  13. _ "unsafe"
  14. )
  15. // 人员基本信息
  16. func ZHGdyb1101(certNo string, org_name string, doctor string, fixmedins_code string, insuplc_admdvs string, mdtrtarea_admvs string, secret_key string, id_card_type int64, card_sn string, certificates int64) string {
  17. //生成签名
  18. nonce := GetRandomString(32)
  19. timestamp := time.Now().Unix()
  20. signature := setSignature(timestamp, nonce, secret_key)
  21. //生成输入报文
  22. inputMessage := SetInputMessage(nonce, timestamp, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs)
  23. input := make(map[string]interface{})
  24. inputData := make(map[string]interface{})
  25. inputMessage["infno"] = "1101" // 交易编码
  26. if certificates == 3 {
  27. inputData["mdtrt_cert_type"] = "99" // 就诊凭证类型
  28. inputData["certno"] = certNo // 证件号码
  29. inputData["psn_cert_type"] = "99" // 人员证件类型
  30. } else {
  31. if id_card_type == 1 {
  32. inputData["mdtrt_cert_type"] = "03" // 就诊凭证类型
  33. inputData["card_sn"] = card_sn // 卡识别码
  34. inputData["certno"] = certNo // 证件号码
  35. inputData["psn_cert_type"] = "1" // 人员证件类型
  36. } else {
  37. inputData["mdtrt_cert_type"] = "02" // 就诊凭证类型
  38. inputData["card_sn"] = "" // 卡识别码
  39. inputData["certno"] = certNo // 证件号码
  40. inputData["psn_cert_type"] = "1" // 人员证件类型
  41. }
  42. }
  43. inputData["mdtrt_cert_no"] = certNo // 就诊凭证编号
  44. inputData["begntime"] = "" // 开始时间
  45. inputData["psn_name"] = "" // 人员姓名
  46. input["data"] = inputData
  47. inputMessage["input"] = input //交易输入
  48. bytesData, err := json.Marshal(inputMessage)
  49. fmt.Println(string(bytesData))
  50. if err != nil {
  51. fmt.Println(err.Error())
  52. return err.Error()
  53. }
  54. reader := bytes.NewReader(bytesData)
  55. gdyb_url := beego.AppConfig.String("gdyb_url")
  56. gdyb_paasid := beego.AppConfig.String("gdyb_paasid")
  57. //url := "http://igb.hsa.gdgov.cn/ebus/gdyb_api/prd/hsa/hgs/1101"
  58. url := gdyb_url + "1101"
  59. //url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/1101"
  60. request, err := http.NewRequest("POST", url, reader)
  61. if err != nil {
  62. fmt.Println(err.Error())
  63. return err.Error()
  64. }
  65. request.Header.Set("Content-Type", "application/json;charset=UTF-8")
  66. request.Header.Set("x-tif-paasid", gdyb_paasid)
  67. request.Header.Set("x-tif-signature", signature)
  68. request.Header.Set("x-tif-timestamp", strconv.FormatInt(timestamp, 10))
  69. request.Header.Set("x-tif-nonce", nonce)
  70. client := http.Client{}
  71. resp, err := client.Do(request)
  72. if err != nil {
  73. fmt.Println(err.Error())
  74. return err.Error()
  75. }
  76. respBytes, err := ioutil.ReadAll(resp.Body)
  77. if err != nil {
  78. fmt.Println(err.Error())
  79. return err.Error()
  80. }
  81. fmt.Println(string(respBytes))
  82. str := string(respBytes)
  83. return str
  84. }
  85. type DiseinfoStruct struct {
  86. PsnNo string
  87. DiagType string
  88. MaindiagFlag string
  89. DiagSrtNo string
  90. DiagCode string
  91. DiagName string
  92. DiagDept string
  93. DiseDorNo string
  94. DiseDorName string
  95. DiagTime string
  96. }
  97. type Struct2401 struct {
  98. PsnNo string
  99. Insutype string
  100. MdtrtCertType string
  101. MdtrtCertNo string
  102. MedType string
  103. IptNo string
  104. AtddrNo string
  105. ChfpdrName string
  106. AdmDiagDscr string
  107. AdmDeptCodg string
  108. AdmDeptName string
  109. AdmBed string
  110. DscgMaindiagCode string
  111. DscgMaindiagName string
  112. Diseinfo []DiseinfoStruct
  113. Begntime string
  114. DiseCodg string
  115. DiseName string
  116. }
  117. // 住院登记
  118. func ZHGdyb2401(struct2401 Struct2401, secret_key string, org_name string, fixmedins_code string, doctor string, insuplc_admdvs string, mdtrtarea_admvs string) string {
  119. // 生成签名
  120. nonce := GetRandomString(32)
  121. timestamp := time.Now().Unix()
  122. signature := setSignature(timestamp, nonce, secret_key)
  123. //tempTime := time.Unix(timestamp, 0)
  124. //timeFormatOne := tempTime.Format("2006-01-02 15:04:05")
  125. // 生成输入报文
  126. inputMessage := SetInputMessage(nonce, timestamp, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs)
  127. input := make(map[string]interface{})
  128. inputData := make(map[string]interface{})
  129. inputMessage["infno"] = "2201" // 交易编码
  130. inputData["psn_no"] = struct2401.PsnNo // 人员编号 (来自1101接口返回)
  131. inputData["insutype"] = struct2401.Insutype // 险种类型(来自1101接口返回)
  132. inputData["tel"] = ""
  133. inputData["coner_name"] = ""
  134. inputData["begntime"] = struct2401.Begntime // 开始时间
  135. inputData["mdtrt_cert_type"] = "02" // 就诊凭证类型
  136. inputData["mdtrt_cert_no"] = struct2401.MdtrtCertNo // 就诊凭证编号
  137. inputData["med_type"] = struct2401.MedType // 就诊凭证编号
  138. inputData["ipt_no"] = struct2401.IptNo // 住院/门诊号
  139. inputData["medrcdno"] = ""
  140. inputData["atddr_no"] = struct2401.AtddrNo
  141. inputData["chfpdr_name"] = struct2401.ChfpdrName
  142. inputData["adm_diag_dscr"] = struct2401.AdmDiagDscr
  143. inputData["adm_dept_codg"] = struct2401.AdmDeptCodg
  144. inputData["adm_dept_name"] = struct2401.AdmDeptName
  145. inputData["adm_bed"] = struct2401.AdmBed
  146. inputData["dscg_maindiag_code"] = struct2401.DscgMaindiagCode
  147. inputData["dscg_maindiag_name"] = struct2401.DscgMaindiagName
  148. inputData["main_cond_dscr"] = ""
  149. inputData["dise_codg"] = struct2401.DiseCodg
  150. inputData["dise_name"] = struct2401.DiseName
  151. inputData["oprn_oprt_code"] = ""
  152. inputData["oprn_oprt_name"] = ""
  153. inputData["fpsc_no"] = ""
  154. inputData["matn_type"] = ""
  155. inputData["birctrl_type"] = ""
  156. inputData["latechb_flag"] = ""
  157. inputData["geso_val"] = ""
  158. inputData["fetts"] = ""
  159. inputData["fetus_cnt"] = ""
  160. inputData["pret_flag"] = ""
  161. inputData["birctrl_matn_date"] = ""
  162. inputData["dise_type_code"] = ""
  163. inputDataArr := make([]map[string]interface{}, 0)
  164. for _, item := range struct2401.Diseinfo {
  165. inputDataTwo := make(map[string]interface{})
  166. inputDataTwo["psn_no"] = item.PsnNo
  167. inputDataTwo["diag_type"] = item.DiagType
  168. inputDataTwo["maindiag_flag"] = item.MaindiagFlag
  169. inputDataTwo["diag_srt_no"] = item.DiagSrtNo
  170. inputDataTwo["diag_code"] = item.DiagCode
  171. inputDataTwo["diag_name"] = item.DiagName
  172. inputDataTwo["adm_cond"] = ""
  173. inputDataTwo["diag_dept"] = item.DiagDept
  174. inputDataTwo["dise_dor_no"] = item.DiseDorNo
  175. inputDataTwo["dise_dor_name"] = item.DiseDorName
  176. inputDataTwo["diag_time"] = item.DiagTime
  177. inputDataArr = append(inputDataArr, inputDataTwo)
  178. }
  179. input["mdtrtinfo"] = inputData
  180. input["diseinfo"] = inputDataArr
  181. inputMessage["input"] = input //交易输入
  182. bytesData, err := json.Marshal(inputMessage)
  183. fmt.Println(string(bytesData))
  184. if err != nil {
  185. fmt.Println(err.Error())
  186. return err.Error()
  187. }
  188. reader := bytes.NewReader(bytesData)
  189. gdyb_url := beego.AppConfig.String("gdyb_url")
  190. gdyb_paasid := beego.AppConfig.String("gdyb_paasid")
  191. url := gdyb_url + "2401"
  192. request, err := http.NewRequest("POST", url, reader)
  193. if err != nil {
  194. fmt.Println(err.Error())
  195. return err.Error()
  196. }
  197. request.Header.Set("Content-Type", "application/json;charset=UTF-8")
  198. request.Header.Set("x-tif-paasid", gdyb_paasid)
  199. request.Header.Set("x-tif-signature", signature)
  200. request.Header.Set("x-tif-timestamp", strconv.FormatInt(timestamp, 10))
  201. request.Header.Set("x-tif-nonce", nonce)
  202. client := http.Client{}
  203. resp, err := client.Do(request)
  204. if err != nil {
  205. fmt.Println(err.Error())
  206. return err.Error()
  207. }
  208. respBytes, err := ioutil.ReadAll(resp.Body)
  209. if err != nil {
  210. fmt.Println(err.Error())
  211. return err.Error()
  212. }
  213. str := string(respBytes)
  214. fmt.Println(str)
  215. return str
  216. }
  217. //住院撤销
  218. func ZHGdyb2404(mdtrt_id string, psn_no string, secret_key string, org_name string, fixmedins_code string, doctor string, insuplc_admdvs string, mdtrtarea_admvs string) string {
  219. // 生成签名
  220. nonce := GetRandomString(32)
  221. timestamp := time.Now().Unix()
  222. signature := setSignature(timestamp, nonce, secret_key)
  223. // 生成输入报文
  224. inputMessage := SetInputMessage(nonce, timestamp, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs)
  225. input := make(map[string]interface{})
  226. inputData := make(map[string]interface{})
  227. inputMessage["infno"] = "2404" // 交易编码
  228. inputData["mdtrt_id"] = mdtrt_id // 人员编号 (来自1101接口返回)
  229. inputData["psn_no"] = psn_no // 人员编号 (来自1101接口返回)
  230. input["data"] = inputData
  231. inputMessage["input"] = input //交易输入
  232. bytesData, err := json.Marshal(inputMessage)
  233. fmt.Println(string(bytesData))
  234. if err != nil {
  235. fmt.Println(err.Error())
  236. return err.Error()
  237. }
  238. reader := bytes.NewReader(bytesData)
  239. gdyb_url := beego.AppConfig.String("gdyb_url")
  240. gdyb_paasid := beego.AppConfig.String("gdyb_paasid")
  241. url := gdyb_url + "2404"
  242. request, err := http.NewRequest("POST", url, reader)
  243. if err != nil {
  244. fmt.Println(err.Error())
  245. return err.Error()
  246. }
  247. request.Header.Set("Content-Type", "application/json;charset=UTF-8")
  248. request.Header.Set("x-tif-paasid", gdyb_paasid)
  249. request.Header.Set("x-tif-signature", signature)
  250. request.Header.Set("x-tif-timestamp", strconv.FormatInt(timestamp, 10))
  251. request.Header.Set("x-tif-nonce", nonce)
  252. client := http.Client{}
  253. resp, err := client.Do(request)
  254. if err != nil {
  255. fmt.Println(err.Error())
  256. return err.Error()
  257. }
  258. respBytes, err := ioutil.ReadAll(resp.Body)
  259. if err != nil {
  260. fmt.Println(err.Error())
  261. return err.Error()
  262. }
  263. str := string(respBytes)
  264. fmt.Println(str)
  265. return str
  266. }
  267. //出院撤销
  268. func ZHGdyb2405(mdtrt_id string, psn_no string, secret_key string, org_name string, fixmedins_code string, doctor string, insuplc_admdvs string, mdtrtarea_admvs string) string {
  269. // 生成签名
  270. nonce := GetRandomString(32)
  271. timestamp := time.Now().Unix()
  272. signature := setSignature(timestamp, nonce, secret_key)
  273. // 生成输入报文
  274. inputMessage := SetInputMessage(nonce, timestamp, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs)
  275. input := make(map[string]interface{})
  276. inputData := make(map[string]interface{})
  277. inputMessage["infno"] = "2405" // 交易编码
  278. inputData["mdtrt_id"] = mdtrt_id // 人员编号 (来自1101接口返回)
  279. inputData["psn_no"] = psn_no // 人员编号 (来自1101接口返回)
  280. input["data"] = inputData
  281. inputMessage["input"] = input //交易输入
  282. bytesData, err := json.Marshal(inputMessage)
  283. fmt.Println(string(bytesData))
  284. if err != nil {
  285. fmt.Println(err.Error())
  286. return err.Error()
  287. }
  288. reader := bytes.NewReader(bytesData)
  289. gdyb_url := beego.AppConfig.String("gdyb_url")
  290. gdyb_paasid := beego.AppConfig.String("gdyb_paasid")
  291. url := gdyb_url + "2405"
  292. request, err := http.NewRequest("POST", url, reader)
  293. if err != nil {
  294. fmt.Println(err.Error())
  295. return err.Error()
  296. }
  297. request.Header.Set("Content-Type", "application/json;charset=UTF-8")
  298. request.Header.Set("x-tif-paasid", gdyb_paasid)
  299. request.Header.Set("x-tif-signature", signature)
  300. request.Header.Set("x-tif-timestamp", strconv.FormatInt(timestamp, 10))
  301. request.Header.Set("x-tif-nonce", nonce)
  302. client := http.Client{}
  303. resp, err := client.Do(request)
  304. if err != nil {
  305. fmt.Println(err.Error())
  306. return err.Error()
  307. }
  308. respBytes, err := ioutil.ReadAll(resp.Body)
  309. if err != nil {
  310. fmt.Println(err.Error())
  311. return err.Error()
  312. }
  313. str := string(respBytes)
  314. fmt.Println(str)
  315. return str
  316. }
  317. type Diseinfo2402Struct struct {
  318. MdtrtId string
  319. PsnNo string
  320. DiagType string
  321. MaindiagFlag string
  322. DiagSrtNo string
  323. DiagCode string
  324. DiagName string
  325. DiagDept string
  326. DiseDorNo string
  327. DiseDorName string
  328. DiagTime string
  329. }
  330. type Struct2402 struct {
  331. MdtrtId string
  332. PsnNo string
  333. Insutype string
  334. Endtime string
  335. DscgDeptCodg string
  336. DscgDeptName string
  337. DscgWay string
  338. Diseinfo []Diseinfo2402Struct
  339. DiseName string
  340. DiseCode string
  341. }
  342. // 出院
  343. func ZHGdyb2402(struct2402 Struct2402, org_name string, doctor string, insuplc_admdvs string, mdtrtarea_admvs string, secret_key string, fixmedins_code string) string {
  344. // 生成签名
  345. nonce := GetRandomString(32)
  346. timestamp := time.Now().Unix()
  347. signature := setSignature(timestamp, nonce, secret_key)
  348. //tempTime := time.Unix(timestamp, 0)
  349. //timeFormatOne := tempTime.Format("2006-01-02 15:04:05")
  350. // 生成输入报文
  351. inputMessage := SetInputMessage(nonce, timestamp, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs)
  352. input := make(map[string]interface{})
  353. inputData := make(map[string]interface{})
  354. inputMessage["infno"] = "2402" // 交易编码
  355. inputData["mdtrt_id"] = struct2402.MdtrtId // 人员编号 (来自1101接口返回)
  356. inputData["psn_no"] = struct2402.PsnNo // 人员编号 (来自1101接口返回)
  357. inputData["insutype"] = struct2402.Insutype // 险种类型(来自1101接口返回)
  358. inputData["endtime"] = struct2402.Endtime // 结束时间
  359. inputData["dise_codg"] = struct2402.DiseCode // 就诊凭证类型
  360. inputData["dise_name"] = struct2402.DiseName // 就诊凭证类型
  361. inputData["oprn_oprt_code"] = "" // 就诊凭证类型
  362. inputData["oprn_oprt_name"] = "" // 就诊凭证类型
  363. inputData["fpsc_no"] = "" // 就诊凭证类型
  364. inputData["matn_type"] = "" // 就诊凭证类型
  365. inputData["birctrl_type"] = "" // 就诊凭证类型
  366. inputData["latechb_flag"] = "" // 就诊凭证类型
  367. inputData["geso_val"] = ""
  368. inputData["fetts"] = ""
  369. inputData["fetus_cnt"] = ""
  370. inputData["pret_flag"] = ""
  371. inputData["birctrl_matn_date"] = ""
  372. inputData["cop_flag"] = ""
  373. inputData["dscg_dept_codg"] = struct2402.DscgDeptCodg
  374. inputData["dscg_dept_name"] = struct2402.DscgDeptName
  375. inputData["dscg_bed"] = "待定"
  376. inputData["dscg_way"] = struct2402.DscgWay
  377. inputData["die_date"] = ""
  378. inputDataArr := make([]map[string]interface{}, 0)
  379. for _, item := range struct2402.Diseinfo {
  380. inputDataTwo := make(map[string]interface{})
  381. inputDataTwo["psn_no"] = item.PsnNo
  382. inputDataTwo["mdtrt_id"] = item.MdtrtId
  383. inputDataTwo["diag_type"] = item.DiagType
  384. inputDataTwo["maindiag_flag"] = item.MaindiagFlag
  385. inputDataTwo["diag_srt_no"] = item.DiagSrtNo
  386. inputDataTwo["diag_code"] = item.DiagCode
  387. inputDataTwo["diag_name"] = item.DiagName
  388. inputDataTwo["diag_dept"] = item.DiagDept
  389. inputDataTwo["dise_dor_no"] = item.DiseDorNo
  390. inputDataTwo["dise_dor_name"] = item.DiseDorName
  391. inputDataTwo["diag_time"] = item.DiagTime
  392. inputDataArr = append(inputDataArr, inputDataTwo)
  393. }
  394. input["dscginfo"] = inputData
  395. input["diseinfo"] = inputDataArr
  396. inputMessage["input"] = input //交易输入
  397. bytesData, err := json.Marshal(inputMessage)
  398. fmt.Println(string(bytesData))
  399. if err != nil {
  400. fmt.Println(err.Error())
  401. return err.Error()
  402. }
  403. reader := bytes.NewReader(bytesData)
  404. gdyb_url := beego.AppConfig.String("gdyb_url")
  405. gdyb_paasid := beego.AppConfig.String("gdyb_paasid")
  406. url := gdyb_url + "2402"
  407. //url := "http://igb.hsa.gdgov.cn/ebus/gdyb_api/prd/hsa/hgs/2202"
  408. //url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/2202"
  409. //url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/2202"
  410. request, err := http.NewRequest("POST", url, reader)
  411. if err != nil {
  412. fmt.Println(err.Error())
  413. return err.Error()
  414. }
  415. request.Header.Set("Content-Type", "application/json;charset=UTF-8")
  416. //request.Header.Set("x-tif-paasid", "test_hosp")
  417. request.Header.Set("x-tif-paasid", gdyb_paasid)
  418. request.Header.Set("x-tif-signature", signature)
  419. request.Header.Set("x-tif-timestamp", strconv.FormatInt(timestamp, 10))
  420. request.Header.Set("x-tif-nonce", nonce)
  421. client := http.Client{}
  422. resp, err := client.Do(request)
  423. if err != nil {
  424. fmt.Println(err.Error())
  425. return err.Error()
  426. }
  427. respBytes, err := ioutil.ReadAll(resp.Body)
  428. if err != nil {
  429. fmt.Println(err.Error())
  430. return err.Error()
  431. }
  432. str := string(respBytes)
  433. fmt.Println(str)
  434. return str
  435. }
  436. type ZHCustom struct {
  437. DetItemFeeSumamt string
  438. Cut string
  439. FeedetlSn string
  440. Price string
  441. MedListCodg string
  442. LmtUsedFlag int64
  443. HospApprFlag int64
  444. }
  445. type ZHRequestResult struct {
  446. Output ZHOutput `json:"output" form:"output"`
  447. Infcode int64 `gorm:"column:infcode" json:"infcode" form:"infcode"`
  448. WarnMsg string `gorm:"column:warn_msg" json:"warn_msg" form:"warn_msg"`
  449. Cainfo string `gorm:"column:cainfo" json:"cainfo" form:"cainfo"`
  450. ErrMsg string `gorm:"column:err_msg" json:"err_msg" form:"err_msg"`
  451. RespondTime string `gorm:"column:respond_time" json:"respond_time" form:"respond_time"`
  452. InfRefmsgid string `gorm:"column:inf_refmsgid" json:"inf_refmsgid" form:"inf_refmsgid"`
  453. }
  454. type ZHOutput struct {
  455. Result Result `json:"result" form:"result"`
  456. }
  457. type ZHResult struct {
  458. BasMednFlag string `json:"bas_medn_flag" form:"bas_medn_flag"`
  459. MedChrgitmType string `json:"med_chrgitm_type" form:"med_chrgitm_type"`
  460. DetItemFeeSumamt int64 `json:"det_item_fee_sumamt" form:"det_item_fee_sumamt"`
  461. HiNegoDrugFlag string `json:"hi_nego_drug_flag" form:"hi_nego_drug_flag"`
  462. FulamtOwnpayAmt float64 `json:"fulamt_ownpay_amt" form:"fulamt_ownpay_amt"`
  463. FeedtlSn int64 `json:"feedtl_sn" form:"feedtl_sn"`
  464. UploadDate int64 `json:"upload_date" form:"upload_date"`
  465. AdviceId int64 `json:"advice_id" form:"advice_id"`
  466. Cnt int64 `json:"cnt" form:"cnt"`
  467. Pric float64 `json:"pric" form:"pric"`
  468. PatientId int64 `json:"patient_id" form:"patient_id"`
  469. PricUplmtAmt float64 `json:"pric_uplmt_amt" form:"pric_uplmt_amt"`
  470. SelfpayProp float64 `json:"selfpay_prop" form:"selfpay_prop"`
  471. OverlmtAmt float64 `json:"overlmt_amt" form:"overlmt_amt"`
  472. PreselfpayAmt float64 `json:"preselfpay_amt" form:"preselfpay_amt"`
  473. Status int64 `json:"status" form:"status"`
  474. Memo string `json:"memo" form:"memo"`
  475. FeedetlSn string `json:"feedetl_sn" form:"feedetl_sn"`
  476. Mtime int64 `json:"mtime" form:"mtime"`
  477. InscpScpAmt float64 `json:"inscp_scp_amt" form:"inscp_scp_amt"`
  478. DrtReimFlag string `json:"drt_reim_flag" form:"drt_reim_flag"`
  479. Ctime int64 `json:"ctime" form:"ctime"`
  480. ListSpItemFlag string `json:"list_sp_item_flag" form:"list_sp_item_flag"`
  481. ChldMedcFlag string `json:"chld_medc_flag" form:"chld_medc_flag"`
  482. LmtUsedFlag string `json:"lmt_used_flag" form:"lmt_used_flag"`
  483. ChrgitmLv string `json:"chrgitm_lv" form:"chrgitm_lv"`
  484. UserOrgId int64 `json:"user_org_id" form:"user_org_id"`
  485. HisPatientId int64 `json:"his_patient_id" form:"his_patient_id"`
  486. OrderId int64 `json:"order_id" form:"order_id"`
  487. }
  488. // 住院费用明细信息上传
  489. func ZHGdyb2301(psnNo string, mdtrtId string, hisPrescription []*models.NewCustom, chrg_bchno string, org_name string, doctor string, dept string, fixmedins_code string, dept_code string, doctor_id string, insuplc_admdvs string, mdtrtarea_admvs string, secret_key string, med_type string) string {
  490. // 生成签名
  491. nonce := GetRandomString(32)
  492. timestamp := time.Now().Unix()
  493. signature := setSignature(timestamp, nonce, secret_key)
  494. tempTime := time.Unix(timestamp, 0)
  495. //timeFormat := tempTime.Format("20060102150405")
  496. timeFormatOne := tempTime.Format("2006-01-02 15:04:05")
  497. //chrgBchno := rand.Intn(100000) + 10000
  498. var customs []*models.NewCustom
  499. customs = hisPrescription
  500. // 生成输入报文
  501. inputMessage := SetInputMessage(nonce, timestamp, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs)
  502. input := make(map[string]interface{})
  503. feedetail := make([]map[string]interface{}, 0)
  504. inputMessage["infno"] = "2301" // 交易编码
  505. //chrg_bchno := timeFormat + strconv.FormatInt(int64(chrgBchno), 10)
  506. for _, item := range customs {
  507. feedetailInfo := make(map[string]interface{})
  508. feedetailInfo["feedetl_sn"] = item.FeedetlSn
  509. feedetailInfo["mdtrt_id"] = mdtrtId // 就诊 ID(来自2201接口返回)
  510. feedetailInfo["psn_no"] = psnNo // 人员编号 (来自1101接口返回)
  511. feedetailInfo["med_type"] = med_type
  512. feedetailInfo["fee_ocur_time"] = timeFormatOne // 费用发生时间
  513. feedetailInfo["med_list_codg"] = item.MedListCodg // 医疗目录编码
  514. feedetailInfo["medins_list_codg"] = fixmedins_code // 医药机构目录编码
  515. feedetailInfo["det_item_fee_sumamt"] = item.DetItemFeeSumamt // 明细项目费用总额
  516. feedetailInfo["cnt"] = item.Cut // 数量
  517. feedetailInfo["pric"] = item.Price // 单价
  518. feedetailInfo["bilg_dept_codg"] = dept_code // 开单科室编码
  519. feedetailInfo["bilg_dept_name"] = dept // 开单科室名称
  520. feedetailInfo["bilg_dr_codg"] = doctor_id // 开单医生编码
  521. feedetailInfo["bilg_dr_name"] = doctor
  522. feedetailInfo["acord_dept_codg"] = "" // 受单科室编码
  523. feedetailInfo["acord_dept_name"] = "" // 受单科室名称
  524. feedetailInfo["orders_dr_code"] = "" // 受单医生编码
  525. feedetailInfo["orders_dr_name"] = "" // 受单医生姓名
  526. feedetailInfo["chrg_bchno"] = chrg_bchno // 收费批次号
  527. feedetailInfo["dise_codg"] = "" // 病种编码
  528. feedetailInfo["rxno"] = "" // 处方号
  529. feedetailInfo["rx_circ_flag"] = "0" // 外购处方标志
  530. feedetailInfo["sin_dos_dscr"] = "" // 单次剂量描述
  531. feedetailInfo["used_frqu_dscr"] = "" // 使用频次描述
  532. feedetailInfo["prd_days"] = "0" // 周期天数
  533. feedetailInfo["medc_way_dscr"] = "" // 用药途径描述
  534. // 开单医师姓名
  535. if item.HospApprFlag != -1 {
  536. if item.HospApprFlag == 1 {
  537. feedetailInfo["hosp_appr_flag"] = "0" // 医院审批标志
  538. } else if item.HospApprFlag == 2 {
  539. feedetailInfo["hosp_appr_flag"] = "1" // 医院审批标志
  540. } else if item.HospApprFlag == 3 {
  541. feedetailInfo["hosp_appr_flag"] = "2" // 医院审批标志
  542. } else {
  543. feedetailInfo["hosp_appr_flag"] = "1" // 医院审批标志
  544. }
  545. } else {
  546. feedetailInfo["hosp_appr_flag"] = "1" // 医院审批标志
  547. }
  548. feedetailInfo["tcmdrug_used_way"] = "" // 中药使用方式
  549. feedetailInfo["etip_flag"] = "" // 外检标志
  550. feedetailInfo["etip_hosp_code"] = "" // 外检医院编码
  551. feedetailInfo["dscg_tkdrug_flag"] = "" // 出院带药标志
  552. feedetailInfo["matn_fee_flag"] = "" // 生育费用标志
  553. feedetail = append(feedetail, feedetailInfo)
  554. }
  555. input["feedetail"] = feedetail
  556. inputMessage["input"] = input //交易输入
  557. bytesData, err := json.Marshal(inputMessage)
  558. fmt.Println("----------")
  559. fmt.Println(string(bytesData))
  560. fmt.Println("----------")
  561. if err != nil {
  562. fmt.Println(err.Error())
  563. return ""
  564. }
  565. reader := bytes.NewReader(bytesData)
  566. gdyb_url := beego.AppConfig.String("gdyb_url")
  567. gdyb_paasid := beego.AppConfig.String("gdyb_paasid")
  568. url := gdyb_url + "2301"
  569. request, err := http.NewRequest("POST", url, reader)
  570. if err != nil {
  571. fmt.Println(err.Error())
  572. return ""
  573. }
  574. request.Header.Set("Content-Type", "application/json;charset=UTF-8")
  575. request.Header.Set("x-tif-paasid", gdyb_paasid)
  576. request.Header.Set("x-tif-signature", signature)
  577. request.Header.Set("x-tif-timestamp", strconv.FormatInt(timestamp, 10))
  578. request.Header.Set("x-tif-nonce", nonce)
  579. client := http.Client{}
  580. resp, err := client.Do(request)
  581. if err != nil {
  582. fmt.Println(err.Error())
  583. return ""
  584. }
  585. respBytes, err := ioutil.ReadAll(resp.Body)
  586. if err != nil {
  587. fmt.Println(err.Error())
  588. return ""
  589. }
  590. return string(respBytes)
  591. }
  592. // 住院费用明细信息撤销
  593. func Gdyb2302(psnNo string, mdtrtId string, org_name string, doctor string, insuplc_admdvs string, mdtrtarea_admvs string, secret_key string, fixmedins_code string) string {
  594. // 生成签名
  595. nonce := GetRandomString(32)
  596. timestamp := time.Now().Unix()
  597. signature := setSignature(timestamp, nonce, secret_key)
  598. // 生成输入报文
  599. inputMessage := SetInputMessage(nonce, timestamp, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs)
  600. input := make(map[string]interface{})
  601. inputData := make(map[string]interface{})
  602. inputMessage["infno"] = "2302" // 交易编码
  603. inputData["mdtrt_id"] = mdtrtId // 就诊 ID
  604. inputData["feedetl_sn"] = "0000" //
  605. inputData["psn_no"] = psnNo // 人员编号
  606. input["data"] = inputData
  607. inputMessage["input"] = input //交易输入
  608. bytesData, err := json.Marshal(inputMessage)
  609. fmt.Println(string(bytesData))
  610. if err != nil {
  611. fmt.Println(err.Error())
  612. return err.Error()
  613. }
  614. reader := bytes.NewReader(bytesData)
  615. gdyb_url := beego.AppConfig.String("gdyb_url")
  616. gdyb_paasid := beego.AppConfig.String("gdyb_paasid")
  617. //url := "http://igb.hsa.gdgov.cn/ebus/gdyb_api/prd/hsa/hgs/1101"
  618. url := gdyb_url + "2302"
  619. //url := "http://igb.hsa.gdgov.cn/ebus/gdyb_api/prd/hsa/hgs/2205"
  620. //url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/2205"
  621. //url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/2205"
  622. request, err := http.NewRequest("POST", url, reader)
  623. fmt.Println(err)
  624. fmt.Println(request)
  625. if err != nil {
  626. fmt.Println(err.Error())
  627. return err.Error()
  628. }
  629. request.Header.Set("Content-Type", "application/json;charset=UTF-8")
  630. request.Header.Set("x-tif-paasid", gdyb_paasid)
  631. request.Header.Set("x-tif-signature", signature)
  632. request.Header.Set("x-tif-timestamp", strconv.FormatInt(timestamp, 10))
  633. request.Header.Set("x-tif-nonce", nonce)
  634. client := http.Client{}
  635. resp, err := client.Do(request)
  636. if err != nil {
  637. fmt.Println(err.Error())
  638. return err.Error()
  639. }
  640. respBytes, err := ioutil.ReadAll(resp.Body)
  641. if err != nil {
  642. fmt.Println(err.Error())
  643. return err.Error()
  644. }
  645. str := string(respBytes)
  646. fmt.Println(str)
  647. return str
  648. }
  649. // 住院结算
  650. func ZHGdyb2304(psnNo string, mdtrtId string, chrgBchno string, certNo string, insutype string, total string, org_name string, doctor string, fixmedins_code string, insuplc_admdvs string, mdtrtarea_admvs string, secret_key string, mid_setl_flag string, id_card_type int64, fulamt_ownpay_amt float64, overlmt_selfpay float64, preselfpay_amt float64, inscp_scp_amt float64, certificates int64) (string, string) {
  651. // 生成签名
  652. nonce := GetRandomString(32)
  653. timestamp := time.Now().Unix()
  654. signature := setSignature(timestamp, nonce, secret_key)
  655. // 生成输入报文
  656. inputMessage := SetInputMessage(nonce, timestamp, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs)
  657. input := make(map[string]interface{})
  658. inputData := make(map[string]interface{})
  659. inputMessage["infno"] = "2304" // 交易编码
  660. inputData["psn_no"] = psnNo // 人员编号 (来自1101接口返回)
  661. if certificates == 3 {
  662. inputData["mdtrt_cert_type"] = "99" // 就诊凭证类型
  663. inputData["mdtrt_cert_no"] = certNo // 就诊凭证编号
  664. } else {
  665. if id_card_type == 1 {
  666. inputData["mdtrt_cert_type"] = "03" // 就诊凭证类型
  667. inputData["mdtrt_cert_no"] = certNo // 就诊凭证编号
  668. } else {
  669. inputData["mdtrt_cert_type"] = "02" // 就诊凭证类型
  670. inputData["mdtrt_cert_no"] = certNo // 就诊凭证编号
  671. }
  672. }
  673. inputData["mid_setl_flag"] = mid_setl_flag // 中途退费标志
  674. inputData["medfee_sumamt"] = total // 医疗费总额
  675. inputData["psn_setlway"] = "01" // 个人结算方式 01 按项目结 02 按定额结算
  676. inputData["mdtrt_id"] = mdtrtId // 就诊 ID(来自2201接口返回)
  677. inputData["acct_used_flag"] = "1" // 个人账户使用标志 0否 1是
  678. inputData["insutype"] = insutype // 险种类型
  679. inputData["invono"] = "" // 发票号
  680. input["data"] = inputData
  681. inputMessage["input"] = input //交易输入
  682. bytesData, err := json.Marshal(inputMessage)
  683. fmt.Println(string(bytesData))
  684. if err != nil {
  685. fmt.Println(err.Error())
  686. return err.Error(), ""
  687. }
  688. reader := bytes.NewReader(bytesData)
  689. gdyb_url := beego.AppConfig.String("gdyb_url")
  690. gdyb_paasid := beego.AppConfig.String("gdyb_paasid")
  691. //url := "http://igb.hsa.gdgov.cn/ebus/gdyb_api/prd/hsa/hgs/1101"
  692. url := gdyb_url + "2304"
  693. //url := "http://igb.hsa.gdgov.cn/ebus/gdyb_api/prd/hsa/hgs/2207"
  694. //url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/2207"
  695. //url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/2207"
  696. request, err := http.NewRequest("POST", url, reader)
  697. if err != nil {
  698. fmt.Println(err.Error())
  699. return err.Error(), ""
  700. }
  701. request.Header.Set("Content-Type", "application/json;charset=UTF-8")
  702. request.Header.Set("x-tif-paasid", gdyb_paasid)
  703. request.Header.Set("x-tif-signature", signature)
  704. request.Header.Set("x-tif-timestamp", strconv.FormatInt(timestamp, 10))
  705. request.Header.Set("x-tif-nonce", nonce)
  706. client := http.Client{}
  707. resp, err := client.Do(request)
  708. if err != nil {
  709. fmt.Println(err.Error())
  710. return err.Error(), ""
  711. }
  712. respBytes, err := ioutil.ReadAll(resp.Body)
  713. if err != nil {
  714. fmt.Println(err.Error())
  715. return err.Error(), ""
  716. }
  717. str := string(respBytes)
  718. fmt.Println(str)
  719. mjson, _ := json.Marshal(inputMessage)
  720. str2 := string(mjson)
  721. return str, str2
  722. }
  723. // 住院结算撤销
  724. func Gdyb2305(psnNo string, mdtrtId string, setlId string, org_name string, doctor string, secret_key string, fixmedins_code string, insuplc_admdvs string, mdtrtarea_admvs string) (string, string) {
  725. // 生成签名
  726. nonce := GetRandomString(32)
  727. timestamp := time.Now().Unix()
  728. signature := setSignature(timestamp, nonce, secret_key)
  729. // 生成输入报文
  730. inputMessage := SetInputMessage(nonce, timestamp, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs)
  731. input := make(map[string]interface{})
  732. inputData := make(map[string]interface{})
  733. inputMessage["infno"] = "2305" // 交易编码
  734. inputData["psn_no"] = psnNo // 人员编号 (来自1101接口返回)
  735. inputData["mdtrt_id"] = mdtrtId // 就诊 ID(来自2201接口返回)
  736. inputData["setl_id"] = setlId // 结算 ID
  737. input["data"] = inputData
  738. inputMessage["input"] = input //交易输入
  739. bytesData, err := json.Marshal(inputMessage)
  740. fmt.Println(string(bytesData))
  741. if err != nil {
  742. fmt.Println(err.Error())
  743. return err.Error(), ""
  744. }
  745. reader := bytes.NewReader(bytesData)
  746. gdyb_url := beego.AppConfig.String("gdyb_url")
  747. gdyb_paasid := beego.AppConfig.String("gdyb_paasid")
  748. url := gdyb_url + "2305"
  749. request, err := http.NewRequest("POST", url, reader)
  750. if err != nil {
  751. fmt.Println(err.Error())
  752. return err.Error(), ""
  753. }
  754. request.Header.Set("Content-Type", "application/json;charset=UTF-8")
  755. request.Header.Set("x-tif-paasid", gdyb_paasid)
  756. request.Header.Set("x-tif-signature", signature)
  757. request.Header.Set("x-tif-timestamp", strconv.FormatInt(timestamp, 10))
  758. request.Header.Set("x-tif-nonce", nonce)
  759. client := http.Client{}
  760. resp, err := client.Do(request)
  761. if err != nil {
  762. fmt.Println(err.Error())
  763. return err.Error(), ""
  764. }
  765. respBytes, err := ioutil.ReadAll(resp.Body)
  766. if err != nil {
  767. fmt.Println(err.Error())
  768. return err.Error(), ""
  769. }
  770. str := string(respBytes)
  771. fmt.Println(str)
  772. mjson, _ := json.Marshal(inputMessage)
  773. str2 := string(mjson)
  774. return str, str2
  775. }
  776. func CreateHospitalRecord(record *models.HisHospitalCheckRecord) (err error) {
  777. err = writeDb.Save(&record).Error
  778. return
  779. }
  780. func GetInHospitalRecord(id int64) (record models.HisHospitalCheckRecord, err error) {
  781. err = readDb.Model(&models.HisHospitalCheckRecord{}).Where("id = ? AND status = 1", id).First(&record).Error
  782. return
  783. }
  784. func GetInHospitalRecordByNumber(number string) (record models.HisHospitalCheckRecord, err error) {
  785. err = readDb.Model(&models.HisHospitalCheckRecord{}).Where("number = ? AND status = 1", number).First(&record).Error
  786. return
  787. }
  788. func GetLastHospitalRecord(id int64, user_org_id int64) (record models.HisHospitalCheckRecord, err error) {
  789. err = readDb.Model(&models.HisHospitalCheckRecord{}).Where("id = ? AND status = 1 AND user_org_id = ?", id, user_org_id).Last(&record).Error
  790. return
  791. }
  792. func GetZHHisPrescription(org_id int64, patient_id int64, record_date int64) (prescription []*models.HisPrescription, err error) {
  793. err = readDb.Model(&models.HisPrescription{}).
  794. Preload("HisAdditionalCharge", func(db *gorm.DB) *gorm.DB {
  795. return db.Where("status = 1 AND user_org_id = ?", org_id).Preload("XtHisAddtionConfig", "status=1")
  796. }).
  797. Preload("HisDoctorAdviceInfo", func(db *gorm.DB) *gorm.DB {
  798. return db.Where("status = 1 AND user_org_id = ?", org_id).Preload("BaseDrugLib", "status=1")
  799. }).
  800. Preload("HisPrescriptionProject", func(db *gorm.DB) *gorm.DB {
  801. return db.Where("status = 1 AND user_org_id = ?", org_id).Preload("HisProject", "status=1")
  802. }).
  803. Where("user_org_id = ? AND status = 1 AND record_date = ? AND patient_id = ? AND order_status <> 2 AND p_type = 1", org_id, record_date, patient_id).
  804. Find(&prescription).Error
  805. return
  806. }
  807. func GetZHMonthHisPrescription(org_id int64, patient_id int64, start_time int64, end_time int64) (prescription []*models.HisPrescription, err error) {
  808. err = readDb.Model(&models.HisPrescription{}).
  809. Preload("HisAdditionalCharge", func(db *gorm.DB) *gorm.DB {
  810. return db.Where("status = 1 AND user_org_id = ?", org_id).Preload("XtHisAddtionConfig", "status=1")
  811. }).
  812. Preload("HisDoctorAdviceInfo", func(db *gorm.DB) *gorm.DB {
  813. return db.Where("status = 1 AND user_org_id = ?", org_id).Preload("BaseDrugLib", "status=1")
  814. }).
  815. Preload("HisPrescriptionProject", func(db *gorm.DB) *gorm.DB {
  816. return db.Where("status = 1 AND user_org_id = ?", org_id).Preload("HisProject", "status=1")
  817. }).
  818. Where("user_org_id = ? AND record_date >= ? AND record_date <= ? AND patient_id = ? AND order_status <> 2 AND status = 1 AND p_type = 1 ", org_id, start_time, end_time, patient_id).
  819. Find(&prescription).Error
  820. return
  821. }