nm_service.go 31KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819
  1. package service
  2. import (
  3. "bytes"
  4. "encoding/json"
  5. "fmt"
  6. "gdyb/models"
  7. "io/ioutil"
  8. "net/http"
  9. "strconv"
  10. "time"
  11. )
  12. // 门诊挂号
  13. func Nmyb2201(psnNo string, insutype string, certNo string, org_name string, opera string, ipt_otp_no string, dept string, fixmedins_code string, dept_code string, doctor_id string, insuplc_admdvs string, mdtrtarea_admvs string, secret_key string, id_card_type int64, doctor_name string, request_url string, verify_number string, cainfo string) (string, string) {
  14. // 生成签名
  15. // 生成签名
  16. nonce := GetRandomString(32)
  17. timestamp := time.Now().Unix()
  18. signature := setSignature(timestamp, nonce, secret_key)
  19. tempTime := time.Unix(timestamp, 0)
  20. timeFormatOne := tempTime.Format("2006-01-02 15:04:05")
  21. // 生成输入报文
  22. inputMessage := SetJSInputMessage(timestamp, org_name, opera, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs, cainfo)
  23. input := make(map[string]interface{})
  24. inputData := make(map[string]interface{})
  25. inputMessage["infno"] = "2201" // 交易编码
  26. inputData["psn_no"] = psnNo // 人员编号 (来自1101接口返回)
  27. inputData["insutype"] = insutype // 险种类型(来自1101接口返回)
  28. inputData["begntime"] = timeFormatOne // 开始时间
  29. if id_card_type == 1 {
  30. inputData["mdtrt_cert_type"] = "03" // 就诊凭证类型
  31. inputData["mdtrt_cert_no"] = certNo + "|" + verify_number // 就诊凭证编号
  32. } else if id_card_type == 3 {
  33. inputData["mdtrt_cert_type"] = "04" // 就诊凭证类型
  34. inputData["mdtrt_cert_no"] = verify_number // 就诊凭证编号
  35. } else if id_card_type == 4 {
  36. inputData["mdtrt_cert_type"] = "01" // 就诊凭证类型
  37. inputData["mdtrt_cert_no"] = verify_number // 就诊凭证编号
  38. } else {
  39. inputData["mdtrt_cert_type"] = "02" // 就诊凭证类型
  40. inputData["mdtrt_cert_no"] = verify_number // 就诊凭证编号
  41. }
  42. inputData["ipt_otp_no"] = ipt_otp_no // 住院/门诊号
  43. inputData["atddr_no"] = doctor_id // 医师编码
  44. inputData["dr_name"] = doctor_name // 医师姓名
  45. inputData["dept_code"] = dept_code // 科室编码
  46. inputData["dept_name"] = dept // 科室名称
  47. inputData["caty"] = "A03.06" // 科别
  48. inputData["exp_content"] = "" //
  49. input["data"] = inputData
  50. inputMessage["input"] = input //交易输入
  51. var requestLog string
  52. bytesData, err := json.Marshal(inputMessage)
  53. requestLog = string(bytesData)
  54. fmt.Println(string(bytesData))
  55. if err != nil {
  56. fmt.Println(err.Error())
  57. return err.Error(), ""
  58. }
  59. reader := bytes.NewReader(bytesData)
  60. gdyb_url := beego.AppConfig.String("gdyb_url")
  61. gdyb_paasid := beego.AppConfig.String("gdyb_paasid")
  62. request_url = gdyb_url
  63. request, err := http.NewRequest("POST", request_url, reader)
  64. if err != nil {
  65. fmt.Println(err.Error())
  66. return err.Error(), ""
  67. }
  68. request.Header.Set("Content-Type", "application/json;charset=UTF-8")
  69. request.Header.Set("x-tif-paasid", gdyb_paasid)
  70. request.Header.Set("x-tif-signature", signature)
  71. request.Header.Set("x-tif-timestamp", strconv.FormatInt(timestamp, 10))
  72. request.Header.Set("x-tif-nonce", nonce)
  73. client := http.Client{}
  74. resp, err := client.Do(request)
  75. if err != nil {
  76. fmt.Println(err.Error())
  77. return err.Error(), ""
  78. }
  79. respBytes, err := ioutil.ReadAll(resp.Body)
  80. if err != nil {
  81. fmt.Println(err.Error())
  82. return err.Error(), ""
  83. }
  84. str := string(respBytes)
  85. fmt.Println(str)
  86. return str, requestLog
  87. }
  88. // 门诊挂号撤销
  89. func Nmyb2202(psnNo string, mdtrtId string, ipt_otp_no string, org_name string, doctor string, insuplc_admdvs string, mdtrtarea_admvs string, secret_key string, fixmedins_code string, cainfo string) (string, string) {
  90. // 生成签名
  91. // 生成签名
  92. nonce := GetRandomString(32)
  93. timestamp := time.Now().Unix()
  94. signature := setSignature(timestamp, nonce, secret_key)
  95. // 生成输入报文
  96. inputMessage := SetJSInputMessage(timestamp, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs, cainfo)
  97. input := make(map[string]interface{})
  98. inputData := make(map[string]interface{})
  99. inputMessage["infno"] = "2202" // 交易编码
  100. inputData["psn_no"] = psnNo // 人员编号 (来自1101接口返回)
  101. inputData["mdtrt_id"] = mdtrtId // 就诊 ID(来自2201接口返回)
  102. inputData["ipt_otp_no"] = ipt_otp_no // 住院/门诊号
  103. inputData["exp_content"] = "" //
  104. input["data"] = inputData
  105. inputMessage["input"] = input //交易输入
  106. var requestLog string
  107. bytesData, err := json.Marshal(inputMessage)
  108. fmt.Println(string(bytesData))
  109. requestLog = string(bytesData)
  110. if err != nil {
  111. fmt.Println(err.Error())
  112. return err.Error(), ""
  113. }
  114. reader := bytes.NewReader(bytesData)
  115. gdyb_url := beego.AppConfig.String("gdyb_url")
  116. gdyb_paasid := beego.AppConfig.String("gdyb_paasid")
  117. request, err := http.NewRequest("POST", gdyb_url, reader)
  118. if err != nil {
  119. fmt.Println(err.Error())
  120. return err.Error(), ""
  121. }
  122. request.Header.Set("Content-Type", "application/json;charset=UTF-8")
  123. request.Header.Set("x-tif-paasid", gdyb_paasid)
  124. request.Header.Set("x-tif-signature", signature)
  125. request.Header.Set("x-tif-timestamp", strconv.FormatInt(timestamp, 10))
  126. request.Header.Set("x-tif-nonce", nonce)
  127. client := http.Client{}
  128. resp, err := client.Do(request)
  129. if err != nil {
  130. fmt.Println(err.Error())
  131. return err.Error(), ""
  132. }
  133. respBytes, err := ioutil.ReadAll(resp.Body)
  134. if err != nil {
  135. fmt.Println(err.Error())
  136. return err.Error(), ""
  137. }
  138. str := string(respBytes)
  139. fmt.Println(str)
  140. return str, requestLog
  141. }
  142. // 门诊就诊信息上传
  143. func Nmyb2203(psnNo string, mdtrtId string, doctor string, department string, org_name string, med_type string, doctor_id string, fixmedins_code string, insuplc_admdvs string, mdtrtarea_admvs string, secret_key string, sick_code string, sick_name string, dept string, config []*models.HisXtDiagnoseConfig, begin_time string, cainfo string) (string, string) {
  144. // 生成签名
  145. // 生成签名
  146. nonce := GetRandomString(32)
  147. timestamp := time.Now().Unix()
  148. signature := setSignature(timestamp, nonce, secret_key)
  149. //tempTime := time.Unix(timestamp, 0)
  150. //timeFormatOne := tempTime.Format("2006-01-02 15:04:05")
  151. // 生成输入报文
  152. tempTime := time.Unix(timestamp, 0)
  153. timeFormatOne := tempTime.Format("2006-01-02 15:04:05")
  154. // 生成输入报文
  155. inputMessage := SetJSInputMessage(timestamp, org_name, dept, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs, cainfo)
  156. input := make(map[string]interface{})
  157. inputData := make(map[string]interface{})
  158. diseinfo := make([]map[string]interface{}, 0)
  159. if med_type == "1111" || med_type == "1112" {
  160. med_type = "11"
  161. }
  162. inputMessage["infno"] = "2203A" // 交易编码
  163. inputData["mdtrt_id"] = mdtrtId // 就诊 ID(来自2201接口返回)
  164. inputData["psn_no"] = psnNo // 人员编号 (来自1101接口返回)
  165. inputData["med_type"] = med_type // 医疗类别 16门诊特殊病
  166. inputData["begntime"] = begin_time // 开始时间
  167. inputData["main_cond_dscr"] = "" // 主要病情描述
  168. inputData["dise_codg"] = sick_code // 病种编码
  169. inputData["dise_name"] = sick_name // 病种名称
  170. inputData["birctrl_type"] = "" // 计划生育手术类别
  171. inputData["birctrl_matn_date"] = "" // 计划生育手术或生育日期
  172. for index, item := range config {
  173. diseinfo_sun := make(map[string]interface{})
  174. diseinfo_sun["diag_type"] = "1" // 诊断类别
  175. diseinfo_sun["diag_srt_no"] = index // 诊断排序号
  176. diseinfo_sun["diag_code"] = item.CountryCode // 诊断代码
  177. diseinfo_sun["diag_name"] = item.ClassName // 诊断名称
  178. diseinfo_sun["diag_dept"] = department // 诊断科室
  179. diseinfo_sun["dise_dor_no"] = doctor_id // 诊断医生编码
  180. diseinfo_sun["dise_dor_name"] = doctor // 诊断医生姓名
  181. diseinfo_sun["diag_time"] = timeFormatOne // 诊断时间
  182. diseinfo_sun["vali_flag"] = "1" // 有效标志
  183. diseinfo = append(diseinfo, diseinfo_sun)
  184. }
  185. //inputData["exp_content"] = "" // 人员编号 (来自1101接口返回)
  186. inputData["exp_content"] = "" //
  187. input["diseinfo"] = diseinfo
  188. input["mdtrtinfo"] = inputData
  189. inputMessage["input"] = input //交易输入
  190. var requestLog string
  191. bytesData, err := json.Marshal(inputMessage)
  192. fmt.Println(string(bytesData))
  193. requestLog = string(bytesData)
  194. if err != nil {
  195. fmt.Println(err.Error())
  196. return err.Error(), ""
  197. }
  198. reader := bytes.NewReader(bytesData)
  199. gdyb_url := beego.AppConfig.String("gdyb_url")
  200. gdyb_paasid := beego.AppConfig.String("gdyb_paasid")
  201. request, err := http.NewRequest("POST", gdyb_url, reader)
  202. if err != nil {
  203. fmt.Println(err.Error())
  204. return err.Error(), ""
  205. }
  206. request.Header.Set("Content-Type", "application/json;charset=UTF-8")
  207. request.Header.Set("x-tif-paasid", gdyb_paasid)
  208. request.Header.Set("x-tif-signature", signature)
  209. request.Header.Set("x-tif-timestamp", strconv.FormatInt(timestamp, 10))
  210. request.Header.Set("x-tif-nonce", nonce)
  211. client := http.Client{}
  212. resp, err := client.Do(request)
  213. if err != nil {
  214. fmt.Println(err.Error())
  215. return err.Error(), ""
  216. }
  217. respBytes, err := ioutil.ReadAll(resp.Body)
  218. if err != nil {
  219. fmt.Println(err.Error())
  220. return err.Error(), ""
  221. }
  222. str := string(respBytes)
  223. fmt.Println(str)
  224. return str, requestLog
  225. }
  226. // 门诊费用明细信息上传
  227. func Nmyb2204(psnNo string, mdtrtId string, hisPrescription []*models.HisPrescription, 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, balance_accounts_type string, diag_code string, request_url string, access_key string, new_doctor_name string, time_stamp_2203 string, cainfo string) (string, string) {
  228. // 生成签名
  229. timestamp := time.Now().Unix()
  230. // 生成签名
  231. nonce := GetRandomString(32)
  232. signature := setSignature(timestamp, nonce, secret_key)
  233. var customs []*Custom
  234. for _, item := range hisPrescription {
  235. tm := time.Unix(item.PreTime, 0)
  236. if item.Type == 1 { //药品
  237. for _, subItem := range item.HisDoctorAdviceInfo {
  238. if len(subItem.BaseDrugLib.MedicalInsuranceNumber) > 0 {
  239. //var randNum int
  240. //randNum = rand.Intn(10000) + 1000
  241. cus := &Custom{
  242. DetItemFeeSumamt: fmt.Sprintf("%.4f", subItem.Price*subItem.PrescribingNumber),
  243. Cut: fmt.Sprintf("%.4f", subItem.PrescribingNumber),
  244. FeedetlSn: subItem.FeedetlSn,
  245. Price: fmt.Sprintf("%.4f", subItem.Price),
  246. MedListCodg: subItem.BaseDrugLib.MedicalInsuranceNumber,
  247. HospApprFlag: subItem.HospApprFlag,
  248. DoctorNumber: doctor_id,
  249. DoctorName: new_doctor_name,
  250. ProvinceDrugMedListCodg: "",
  251. ProvinceGoodMedListCodg: "",
  252. FeeOcurTime: tm.Format("2006-01-02 15:04:05"),
  253. }
  254. if subItem.BaseDrugLib.DrugClassify == "2" {
  255. cus.ProvinceDrugMedListCodg = subItem.BaseDrugLib.ProvincesCode
  256. }
  257. customs = append(customs, cus)
  258. }
  259. }
  260. }
  261. if item.Type == 2 { //项目
  262. for _, subItem := range item.HisPrescriptionProject {
  263. //var randNum int
  264. //randNum = rand.Intn(10000) + 1000
  265. if subItem.Type == 2 {
  266. if len(subItem.HisProject.MedicalCode) > 0 {
  267. cnt, _ := strconv.ParseFloat(subItem.Count, 64)
  268. cus := &Custom{
  269. DetItemFeeSumamt: fmt.Sprintf("%.4f", subItem.Price*cnt),
  270. Cut: fmt.Sprintf("%.4f", cnt),
  271. FeedetlSn: subItem.FeedetlSn,
  272. Price: fmt.Sprintf("%.4f", float64(subItem.Price)),
  273. MedListCodg: subItem.HisProject.MedicalCode,
  274. DoctorNumber: doctor_id,
  275. DoctorName: new_doctor_name,
  276. HospApprFlag: -1,
  277. ProvinceDrugMedListCodg: "",
  278. ProvinceGoodMedListCodg: "",
  279. FeeOcurTime: tm.Format("2006-01-02 15:04:05"),
  280. }
  281. customs = append(customs, cus)
  282. }
  283. } else if subItem.Type == 3 {
  284. if len(subItem.GoodInfo.MedicalInsuranceNumber) > 0 {
  285. cnt, _ := strconv.ParseFloat(subItem.Count, 64)
  286. cus := &Custom{
  287. DetItemFeeSumamt: fmt.Sprintf("%.4f", subItem.Price*cnt),
  288. Cut: fmt.Sprintf("%.4f", cnt),
  289. FeedetlSn: subItem.FeedetlSn,
  290. Price: fmt.Sprintf("%.4f", float64(subItem.Price)),
  291. MedListCodg: subItem.GoodInfo.MedicalInsuranceNumber,
  292. HospApprFlag: -1,
  293. DoctorNumber: doctor_id,
  294. DoctorName: new_doctor_name,
  295. ProvinceDrugMedListCodg: "",
  296. ProvinceGoodMedListCodg: subItem.GoodInfo.ProvincesCode,
  297. FeeOcurTime: tm.Format("2006-01-02 15:04:05"),
  298. }
  299. customs = append(customs, cus)
  300. }
  301. }
  302. }
  303. }
  304. for _, subItem := range item.HisAdditionalCharge {
  305. if len(subItem.XtHisAddtionConfig.Code) > 0 {
  306. cus := &Custom{
  307. DetItemFeeSumamt: fmt.Sprintf("%.4f", subItem.Price*float64(subItem.Count)),
  308. Cut: fmt.Sprintf("%.4f", float64(subItem.Count)),
  309. FeedetlSn: subItem.FeedetlSn,
  310. Price: fmt.Sprintf("%.4f", float64(subItem.Price)),
  311. MedListCodg: subItem.XtHisAddtionConfig.Code,
  312. HospApprFlag: -1,
  313. DoctorNumber: doctor_id,
  314. DoctorName: new_doctor_name,
  315. }
  316. customs = append(customs, cus)
  317. }
  318. }
  319. }
  320. // 生成输入报文
  321. inputMessage := SetInputMessage(nonce, timestamp, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs)
  322. input := make(map[string]interface{})
  323. feedetail := make([]map[string]interface{}, 0)
  324. inputMessage["infno"] = "2204" // 交易编码
  325. //chrg_bchno := timeFormat + strconv.FormatInt(int64(chrgBchno), 10)
  326. for _, item := range customs {
  327. feedetailInfo := make(map[string]interface{})
  328. subfeedetailInfo := make(map[string]interface{})
  329. feedetailInfo["feedetl_sn"] = item.FeedetlSn
  330. feedetailInfo["mdtrt_id"] = mdtrtId // 就诊 ID(来自2201接口返回)
  331. feedetailInfo["psn_no"] = psnNo // 人员编号 (来自1101接口返回)
  332. feedetailInfo["chrg_bchno"] = chrg_bchno // 收费批次号
  333. feedetailInfo["dise_codg"] = diag_code // 病种编码
  334. feedetailInfo["rxno"] = "" // 处方号
  335. feedetailInfo["rx_circ_flag"] = "0" // 外购处方标志
  336. feedetailInfo["fee_ocur_time"] = item.FeeOcurTime // 费用发生时间
  337. feedetailInfo["med_list_codg"] = item.MedListCodg // 医疗目录编码
  338. feedetailInfo["medins_list_codg"] = fixmedins_code // 医药机构目录编码
  339. feedetailInfo["det_item_fee_sumamt"] = item.DetItemFeeSumamt // 明细项目费用总额
  340. feedetailInfo["cnt"] = item.Cut // 数量
  341. feedetailInfo["pric"] = item.Price // 单价
  342. feedetailInfo["sin_dos_dscr"] = "" // 单次剂量描述
  343. feedetailInfo["used_frqu_dscr"] = "" // 使用频次描述
  344. feedetailInfo["prd_days"] = "0" // 周期天数
  345. feedetailInfo["medc_way_dscr"] = "" // 用药途径描述
  346. feedetailInfo["bilg_dept_codg"] = dept_code // 开单科室编码
  347. feedetailInfo["bilg_dept_name"] = dept // 开单科室名称
  348. if fixmedins_code == "H32092103007" {
  349. feedetailInfo["bilg_dr_codg"] = "D320923012139" // 开单医生编码
  350. feedetailInfo["bilg_dr_name"] = "王曙光" // 开单医师姓名
  351. feedetailInfo["acord_dept_codg"] = "" // 受单科室编码
  352. feedetailInfo["acord_dept_name"] = "" // 受单科室名称
  353. feedetailInfo["orders_dr_code"] = "D320923012139" // 受单医生编码
  354. feedetailInfo["orders_dr_name"] = "王曙光" // 受单医生姓名
  355. } else {
  356. feedetailInfo["bilg_dr_codg"] = "D371621008686" // 开单医生编码
  357. feedetailInfo["bilg_dr_name"] = "王云刚" // 开单医师姓名
  358. feedetailInfo["acord_dept_codg"] = "" // 受单科室编码
  359. feedetailInfo["acord_dept_name"] = "" // 受单科室名称
  360. feedetailInfo["orders_dr_code"] = "D371621008686" // 受单医生编码
  361. feedetailInfo["orders_dr_name"] = "王云刚" // 受单医生姓名
  362. }
  363. if balance_accounts_type == "8" {
  364. feedetailInfo["hosp_appr_flag"] = "2" // 医院审批标志
  365. } else {
  366. if item.HospApprFlag != -1 {
  367. if item.HospApprFlag == 1 {
  368. feedetailInfo["hosp_appr_flag"] = "1" // 医院审批标志
  369. } else if item.HospApprFlag == 2 {
  370. feedetailInfo["hosp_appr_flag"] = "2" // 医院审批标志
  371. } else if item.HospApprFlag == 3 {
  372. feedetailInfo["hosp_appr_flag"] = "0" // 医院审批标志
  373. } else {
  374. feedetailInfo["hosp_appr_flag"] = "1" // 医院审批标志
  375. }
  376. } else {
  377. feedetailInfo["hosp_appr_flag"] = "1" // 医院审批标志
  378. }
  379. }
  380. feedetailInfo["tcmdrug_used_way"] = "" // 中药使用方式
  381. feedetailInfo["etip_flag"] = "" // 外检标志
  382. feedetailInfo["etip_hosp_code"] = "" // 外检医院编码
  383. feedetailInfo["dscg_tkdrug_flag"] = "" // 出院带药标志
  384. feedetailInfo["matn_fee_flag"] = "" // 生育费用标志
  385. subfeedetailInfo["tcmherb_prov_code"] = item.ProvinceDrugMedListCodg
  386. subfeedetailInfo["mcs_prov_code"] = item.ProvinceGoodMedListCodg
  387. feedetailInfo["exp_content"] = subfeedetailInfo
  388. feedetail = append(feedetail, feedetailInfo)
  389. }
  390. input["feedetail"] = feedetail
  391. inputMessage["input"] = input //交易输入
  392. var requestLog string
  393. bytesData, err := json.Marshal(inputMessage)
  394. requestLog = string(bytesData)
  395. fmt.Println(string(bytesData))
  396. if err != nil {
  397. fmt.Println(err.Error())
  398. return "", ""
  399. }
  400. reader := bytes.NewReader(bytesData)
  401. gdyb_url := beego.AppConfig.String("gdyb_url")
  402. gdyb_paasid := beego.AppConfig.String("gdyb_paasid")
  403. request, err := http.NewRequest("POST", gdyb_url, reader)
  404. if err != nil {
  405. fmt.Println(err.Error())
  406. return "", ""
  407. }
  408. request.Header.Set("Content-Type", "application/json;charset=UTF-8")
  409. request.Header.Set("x-tif-paasid", gdyb_paasid)
  410. request.Header.Set("x-tif-signature", signature)
  411. request.Header.Set("x-tif-timestamp", strconv.FormatInt(timestamp, 10))
  412. request.Header.Set("x-tif-nonce", nonce)
  413. client := http.Client{}
  414. resp, err := client.Do(request)
  415. if err != nil {
  416. fmt.Println(err.Error())
  417. return "", ""
  418. }
  419. respBytes, err := ioutil.ReadAll(resp.Body)
  420. if err != nil {
  421. fmt.Println(err.Error())
  422. return "", ""
  423. }
  424. return string(respBytes), requestLog
  425. }
  426. // 门诊费用明细信息撤销
  427. func Nmyb2205(psnNo string, mdtrtId string, chrgBchno string, org_name string, doctor string, insuplc_admdvs string, mdtrtarea_admvs string, secret_key string, fixmedins_code string, request_url string, access_key string, cainfo string) (string, string) {
  428. // 生成签名
  429. nonce := GetRandomString(32)
  430. timestamp := time.Now().Unix()
  431. signature := setSignature(timestamp, nonce, secret_key)
  432. inputMessage := SetInputMessage(nonce, timestamp, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs)
  433. input := make(map[string]interface{})
  434. inputData := make(map[string]interface{})
  435. inputMessage["infno"] = "2205" // 交易编码
  436. inputData["mdtrt_id"] = mdtrtId // 就诊 ID(来自2201接口返回)
  437. inputData["chrg_bchno"] = "0000" // 收费批次号(来自2204生成的)
  438. inputData["psn_no"] = psnNo // 人员编号 (来自1101接口返回)
  439. inputData["exp_content"] = "" // 人员编号 (来自1101接口返回)
  440. input["data"] = inputData
  441. inputMessage["input"] = input //交易输入
  442. bytesData, err := json.Marshal(inputMessage)
  443. fmt.Println(string(bytesData))
  444. var requestLog string
  445. requestLog = string(bytesData)
  446. if err != nil {
  447. fmt.Println(err.Error())
  448. return err.Error(), ""
  449. }
  450. reader := bytes.NewReader(bytesData)
  451. gdyb_url := beego.AppConfig.String("gdyb_url")
  452. gdyb_paasid := beego.AppConfig.String("gdyb_paasid")
  453. request, err := http.NewRequest("POST", gdyb_url, reader)
  454. fmt.Println(err)
  455. fmt.Println(request)
  456. if err != nil {
  457. fmt.Println(err.Error())
  458. return err.Error(), ""
  459. }
  460. request.Header.Set("Content-Type", "application/json;charset=UTF-8")
  461. request.Header.Set("x-tif-paasid", gdyb_paasid)
  462. request.Header.Set("x-tif-signature", signature)
  463. request.Header.Set("x-tif-timestamp", strconv.FormatInt(timestamp, 10))
  464. request.Header.Set("x-tif-nonce", nonce)
  465. client := http.Client{}
  466. resp, err := client.Do(request)
  467. if err != nil {
  468. fmt.Println(err.Error())
  469. return err.Error(), ""
  470. }
  471. respBytes, err := ioutil.ReadAll(resp.Body)
  472. if err != nil {
  473. fmt.Println(err.Error())
  474. return err.Error(), ""
  475. }
  476. str := string(respBytes)
  477. fmt.Println(str)
  478. return str, requestLog
  479. }
  480. // 门诊预结算
  481. func Nmyb2206(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, med_type string, id_card_type int64, fulamt_ownpay_amt float64, overlmt_selfpay float64, preselfpay_amt float64, inscp_scp_amt float64, certificates int64, request_url string, access_key string, verify_number string, cainfo string, mdtrt_grp_type string) (string, string) {
  482. // 生成签名
  483. nonce := GetRandomString(32)
  484. timestamp := time.Now().Unix()
  485. signature := setSignature(timestamp, nonce, secret_key)
  486. // 生成输入报文
  487. inputMessage := SetInputMessage(nonce, timestamp, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs)
  488. input := make(map[string]interface{})
  489. inputData := make(map[string]interface{})
  490. inputMessage["infno"] = "2206" // 交易编码
  491. inputData["psn_no"] = psnNo // 人员编号 (来自1101接口返回)
  492. if certificates == 3 {
  493. inputData["mdtrt_cert_type"] = "99" // 就诊凭证类型
  494. inputData["mdtrt_cert_no"] = certNo // 就诊凭证编号
  495. } else {
  496. if id_card_type == 1 {
  497. inputData["mdtrt_cert_type"] = "03" // 就诊凭证类型
  498. inputData["mdtrt_cert_no"] = certNo // 就诊凭证编号
  499. } else if id_card_type == 3 {
  500. inputData["mdtrt_cert_type"] = "04" // 就诊凭证类型
  501. inputData["mdtrt_cert_no"] = verify_number // 就诊凭证编号
  502. } else if id_card_type == 4 {
  503. inputData["mdtrt_cert_type"] = "01" // 就诊凭证类型
  504. inputData["mdtrt_cert_no"] = verify_number // 就诊凭证编号
  505. } else {
  506. inputData["mdtrt_cert_type"] = "01" // 就诊凭证类型
  507. inputData["mdtrt_cert_no"] = verify_number // 就诊凭证编号
  508. }
  509. }
  510. if insuplc_admdvs == "421300" {
  511. if med_type == "11" || med_type == "1112" || med_type == "1111" {
  512. inputData["med_type"] = "110104" // 医疗类别 11 普通门诊 12 门诊挂号
  513. } else if med_type == "14" {
  514. inputData["med_type"] = "140110" // 医疗类别 11 普通门诊 12 门诊挂号
  515. }
  516. } else {
  517. inputData["med_type"] = med_type // 医疗类别 11 普通门诊 12 门诊挂号
  518. }
  519. inputData["medfee_sumamt"] = total // 医疗费总额
  520. inputData["psn_setlway"] = "01" // 个人结算方式 01 按项目结 02 按定额结算
  521. inputData["mdtrt_id"] = mdtrtId // 就诊 ID(来自2201接口返回)
  522. inputData["chrg_bchno"] = chrgBchno // 收费批次号(来自2204生成的)
  523. inputData["acct_used_flag"] = "0" // 个人账户使用标志 0否 1是
  524. inputData["insutype"] = insutype // 险种类型
  525. inputData["invono"] = "" // 发票号
  526. inputData2 := make(map[string]interface{})
  527. inputData2["trum_flag"] = ""
  528. inputData2["rel_ttp_flag"] = ""
  529. inputData2["otp_er_refl_flag"] = ""
  530. inputData2["mdtrt_grp_type"] = mdtrt_grp_type
  531. inputData2["need_ipt_flag"] = ""
  532. inputData["exp_content"] = inputData2
  533. input["data"] = inputData
  534. inputMessage["input"] = input //交易输入
  535. var requestLog string
  536. bytesData, err := json.Marshal(inputMessage)
  537. requestLog = string(bytesData)
  538. fmt.Println(string(bytesData))
  539. if err != nil {
  540. fmt.Println(err.Error())
  541. return err.Error(), ""
  542. }
  543. reader := bytes.NewReader(bytesData)
  544. gdyb_url := beego.AppConfig.String("gdyb_url")
  545. gdyb_paasid := beego.AppConfig.String("gdyb_paasid")
  546. request, err := http.NewRequest("POST", gdyb_url, reader)
  547. if err != nil {
  548. fmt.Println(err.Error())
  549. return err.Error(), ""
  550. }
  551. request.Header.Set("Content-Type", "application/json;charset=UTF-8")
  552. request.Header.Set("x-tif-paasid", gdyb_paasid)
  553. request.Header.Set("x-tif-signature", signature)
  554. request.Header.Set("x-tif-timestamp", strconv.FormatInt(timestamp, 10))
  555. request.Header.Set("x-tif-nonce", nonce)
  556. client := http.Client{}
  557. resp, err := client.Do(request)
  558. if err != nil {
  559. fmt.Println(err.Error())
  560. return err.Error(), ""
  561. }
  562. respBytes, err := ioutil.ReadAll(resp.Body)
  563. if err != nil {
  564. fmt.Println(err.Error())
  565. return err.Error(), ""
  566. }
  567. str := string(respBytes)
  568. fmt.Println(str)
  569. return str, requestLog
  570. }
  571. // 门诊结算
  572. func Nmyb2207(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, med_type string, id_card_type int64, fulamt_ownpay_amt float64, overlmt_selfpay float64, preselfpay_amt float64, inscp_scp_amt float64, certificates int64, acct_used_flag string, request_url string, access_key string, verify_number string, cainfo string, mdtrt_grp_type string) (string, string) {
  573. // 生成签名
  574. nonce := GetRandomString(32)
  575. timestamp := time.Now().Unix()
  576. signature := setSignature(timestamp, nonce, secret_key)
  577. inputMessage := SetInputMessage(nonce, timestamp, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs)
  578. input := make(map[string]interface{})
  579. inputData := make(map[string]interface{})
  580. inputMessage["infno"] = "2207" // 交易编码
  581. inputData["psn_no"] = psnNo // 人员编号 (来自1101接口返回)
  582. if certificates == 3 {
  583. inputData["mdtrt_cert_type"] = "99" // 就诊凭证类型
  584. inputData["mdtrt_cert_no"] = certNo + "|" + verify_number // 就诊凭证编号
  585. } else {
  586. if id_card_type == 1 {
  587. inputData["mdtrt_cert_type"] = "03" // 就诊凭证类型
  588. inputData["mdtrt_cert_no"] = certNo + "|" + verify_number // 就诊凭证编号
  589. } else if id_card_type == 3 {
  590. inputData["mdtrt_cert_type"] = "04" // 就诊凭证类型
  591. inputData["mdtrt_cert_no"] = verify_number // 就诊凭证编号
  592. } else if id_card_type == 4 {
  593. inputData["mdtrt_cert_type"] = "01" // 就诊凭证类型
  594. inputData["mdtrt_cert_no"] = verify_number // 就诊凭证编号
  595. } else {
  596. }
  597. }
  598. if med_type == "1111" || med_type == "1112" {
  599. med_type = "11"
  600. }
  601. if insuplc_admdvs == "421300" {
  602. if med_type == "11" {
  603. inputData["med_type"] = "110104" // 医疗类别 11 普通门诊 12 门诊挂号
  604. } else if med_type == "14" {
  605. inputData["med_type"] = "140101" // 医疗类别 11 普通门诊 12 门诊挂号
  606. }
  607. } else {
  608. inputData["med_type"] = med_type // 医疗类别 11 普通门诊 12 门诊挂号
  609. }
  610. inputData["medfee_sumamt"] = total // 医疗费总额
  611. inputData["psn_setlway"] = "01" // 个人结算方式 01 按项目结 02 按定额结算
  612. inputData["mdtrt_id"] = mdtrtId // 就诊 ID(来自2201接口返回)
  613. inputData["chrg_bchno"] = chrgBchno // 收费批次号(来自2204生成的)
  614. inputData["acct_used_flag"] = acct_used_flag // 个人账户使用标志 0否 1是
  615. inputData["insutype"] = insutype // 险种类型
  616. inputData["invono"] = "" // 发票号
  617. inputData["fulamt_ownpay_amt"] = fulamt_ownpay_amt //
  618. inputData["overlmt_selfpay"] = overlmt_selfpay //
  619. inputData["preselfpay_amt"] = preselfpay_amt //
  620. inputData["inscp_scp_amt"] = inscp_scp_amt //
  621. inputData2 := make(map[string]interface{})
  622. inputData2["trum_flag"] = ""
  623. inputData2["rel_ttp_flag"] = ""
  624. inputData2["otp_er_refl_flag"] = ""
  625. inputData2["mdtrt_grp_type"] = mdtrt_grp_type
  626. inputData2["need_ipt_flag"] = ""
  627. inputData["exp_content"] = inputData2
  628. input["data"] = inputData
  629. inputMessage["input"] = input //交易输入
  630. bytesData, err := json.Marshal(inputMessage)
  631. fmt.Println(string(bytesData))
  632. if err != nil {
  633. fmt.Println(err.Error())
  634. return err.Error(), ""
  635. }
  636. reader := bytes.NewReader(bytesData)
  637. gdyb_url := beego.AppConfig.String("gdyb_url")
  638. gdyb_paasid := beego.AppConfig.String("gdyb_paasid")
  639. request, err := http.NewRequest("POST", gdyb_url, reader)
  640. if err != nil {
  641. fmt.Println(err.Error())
  642. return err.Error(), ""
  643. }
  644. request.Header.Set("Content-Type", "application/json;charset=UTF-8")
  645. request.Header.Set("x-tif-paasid", gdyb_paasid)
  646. request.Header.Set("x-tif-signature", signature)
  647. request.Header.Set("x-tif-timestamp", strconv.FormatInt(timestamp, 10))
  648. request.Header.Set("x-tif-nonce", nonce)
  649. client := http.Client{}
  650. resp, err := client.Do(request)
  651. if err != nil {
  652. fmt.Println(err.Error())
  653. return err.Error(), ""
  654. }
  655. respBytes, err := ioutil.ReadAll(resp.Body)
  656. if err != nil {
  657. fmt.Println(err.Error())
  658. return err.Error(), ""
  659. }
  660. str := string(respBytes)
  661. fmt.Println(str)
  662. mjson, _ := json.Marshal(inputMessage)
  663. str2 := string(mjson)
  664. return str, str2
  665. }
  666. // 门诊结算撤销
  667. func Nmyb2208(psnNo string, mdtrtId string, setlId string, org_name string, doctor string, secret_key string, fixmedins_code string, insuplc_admdvs string, mdtrtarea_admvs string, request_url string, access_key string, cainfo string) (string, string) {
  668. // 生成签名
  669. nonce := GetRandomString(32)
  670. timestamp := time.Now().Unix()
  671. signature := setSignature(timestamp, nonce, secret_key)
  672. // 生成输入报文
  673. inputMessage := SetInputMessage(nonce, timestamp, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs)
  674. input := make(map[string]interface{})
  675. inputData := make(map[string]interface{})
  676. inputMessage["infno"] = "2208" // 交易编码
  677. inputData["psn_no"] = psnNo // 人员编号 (来自1101接口返回)
  678. inputData["mdtrt_id"] = mdtrtId // 就诊 ID(来自2201接口返回)
  679. inputData["setl_id"] = setlId // 结算 ID
  680. inputData["exp_content"] = "" // 人员编号 (来自1101接口返回)
  681. input["data"] = inputData
  682. inputMessage["input"] = input //交易输入
  683. bytesData, err := json.Marshal(inputMessage)
  684. fmt.Println(string(bytesData))
  685. if err != nil {
  686. fmt.Println(err.Error())
  687. return err.Error(), ""
  688. }
  689. reader := bytes.NewReader(bytesData)
  690. gdyb_url := beego.AppConfig.String("gdyb_url")
  691. gdyb_paasid := beego.AppConfig.String("gdyb_paasid")
  692. request, err := http.NewRequest("POST", gdyb_url, reader)
  693. if err != nil {
  694. fmt.Println(err.Error())
  695. return err.Error(), ""
  696. }
  697. request.Header.Set("Content-Type", "application/json;charset=UTF-8")
  698. request.Header.Set("x-tif-paasid", gdyb_paasid)
  699. request.Header.Set("x-tif-signature", signature)
  700. request.Header.Set("x-tif-timestamp", strconv.FormatInt(timestamp, 10))
  701. request.Header.Set("x-tif-nonce", nonce)
  702. client := http.Client{}
  703. resp, err := client.Do(request)
  704. if err != nil {
  705. fmt.Println(err.Error())
  706. return err.Error(), ""
  707. }
  708. respBytes, err := ioutil.ReadAll(resp.Body)
  709. if err != nil {
  710. fmt.Println(err.Error())
  711. return err.Error(), ""
  712. }
  713. str := string(respBytes)
  714. fmt.Println(str)
  715. mjson, _ := json.Marshal(inputMessage)
  716. str2 := string(mjson)
  717. return str, str2
  718. }