gdyb_service.go 90KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069207020712072207320742075207620772078207920802081208220832084208520862087208820892090209120922093209420952096209720982099210021012102210321042105210621072108210921102111211221132114211521162117211821192120212121222123212421252126212721282129213021312132213321342135213621372138213921402141214221432144214521462147214821492150215121522153215421552156215721582159216021612162216321642165216621672168216921702171217221732174217521762177217821792180218121822183218421852186218721882189219021912192219321942195219621972198219922002201220222032204220522062207220822092210221122122213221422152216221722182219222022212222222322242225222622272228222922302231223222332234223522362237223822392240224122422243224422452246224722482249225022512252225322542255225622572258225922602261226222632264226522662267226822692270227122722273227422752276227722782279228022812282228322842285228622872288228922902291229222932294229522962297229822992300230123022303230423052306230723082309231023112312231323142315231623172318231923202321232223232324232523262327232823292330233123322333233423352336233723382339234023412342234323442345234623472348234923502351235223532354235523562357235823592360236123622363236423652366236723682369237023712372237323742375237623772378237923802381238223832384238523862387238823892390
  1. package service
  2. import (
  3. "bytes"
  4. "crypto/sha256"
  5. "encoding/hex"
  6. "encoding/json"
  7. "fmt"
  8. "gdyb/models"
  9. "io"
  10. "io/ioutil"
  11. "math/rand"
  12. "mime/multipart"
  13. "net/http"
  14. "os"
  15. "path/filepath"
  16. "strconv"
  17. "strings"
  18. "time"
  19. _ "unsafe"
  20. )
  21. const (
  22. SceretKey = "RhaDw4H0RUbWYyTxmRKM1eSeN0qyGLds" // secretKey 私钥
  23. )
  24. //机构信息
  25. func Gdyb1201(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) string {
  26. // 生成签名
  27. nonce := GetRandomString(32)
  28. timestamp := time.Now().Unix()
  29. signature := setSignature(timestamp, nonce, secret_key)
  30. // 生成输入报文
  31. inputMessage := SetInputMessage(nonce, timestamp, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs)
  32. input := make(map[string]interface{})
  33. inputData := make(map[string]interface{})
  34. inputMessage["infno"] = "1201" // 交易编码
  35. inputData["fixmedins_type"] = "1"
  36. inputData["fixmedins_name"] = org_name
  37. inputData["fixmedins_code"] = fixmedins_code
  38. input["medinsinfo"] = inputData
  39. inputMessage["input"] = input //交易输入
  40. bytesData, err := json.Marshal(inputMessage)
  41. fmt.Println(string(bytesData))
  42. if err != nil {
  43. fmt.Println(err.Error())
  44. return err.Error()
  45. }
  46. reader := bytes.NewReader(bytesData)
  47. url := "http://igb.hsa.gdgov.cn/ebus/gdyb_api/prd/hsa/hgs/1201"
  48. //url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/1201"
  49. //url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/1101"
  50. request, err := http.NewRequest("POST", url, reader)
  51. if err != nil {
  52. fmt.Println(err.Error())
  53. return err.Error()
  54. }
  55. request.Header.Set("Content-Type", "application/json;charset=UTF-8")
  56. request.Header.Set("x-tif-paasid", "sg03_prd")
  57. request.Header.Set("x-tif-signature", signature)
  58. request.Header.Set("x-tif-timestamp", strconv.FormatInt(timestamp, 10))
  59. request.Header.Set("x-tif-nonce", nonce)
  60. client := http.Client{}
  61. resp, err := client.Do(request)
  62. if err != nil {
  63. fmt.Println(err.Error())
  64. return err.Error()
  65. }
  66. respBytes, err := ioutil.ReadAll(resp.Body)
  67. if err != nil {
  68. fmt.Println(err.Error())
  69. return err.Error()
  70. }
  71. fmt.Println(string(respBytes))
  72. str := string(respBytes)
  73. return str
  74. }
  75. // 人员基本信息
  76. func Gdyb1101(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) string {
  77. //生成签名
  78. nonce := GetRandomString(32)
  79. timestamp := time.Now().Unix()
  80. signature := setSignature(timestamp, nonce, secret_key)
  81. //生成输入报文
  82. inputMessage := SetInputMessage(nonce, timestamp, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs)
  83. input := make(map[string]interface{})
  84. inputData := make(map[string]interface{})
  85. inputMessage["infno"] = "1101" // 交易编码
  86. if id_card_type == 1 {
  87. inputData["mdtrt_cert_type"] = "03" // 就诊凭证类型
  88. inputData["card_sn"] = card_sn // 卡识别码
  89. inputData["certno"] = certNo // 证件号码
  90. } else {
  91. inputData["mdtrt_cert_type"] = "02" // 就诊凭证类型
  92. inputData["card_sn"] = "" // 卡识别码
  93. inputData["certno"] = certNo // 证件号码
  94. }
  95. inputData["psn_cert_type"] = "1" // 人员证件类型
  96. inputData["mdtrt_cert_no"] = certNo // 就诊凭证编号
  97. inputData["begntime"] = "" // 开始时间
  98. inputData["psn_name"] = "" // 人员姓名
  99. input["data"] = inputData
  100. inputMessage["input"] = input //交易输入
  101. bytesData, err := json.Marshal(inputMessage)
  102. fmt.Println(string(bytesData))
  103. if err != nil {
  104. fmt.Println(err.Error())
  105. return err.Error()
  106. }
  107. reader := bytes.NewReader(bytesData)
  108. //url := "http://igb.hsa.gdgov.cn/ebus/gdyb_api/prd/hsa/hgs/1101"
  109. url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/1101"
  110. //url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/1101"
  111. request, err := http.NewRequest("POST", url, reader)
  112. if err != nil {
  113. fmt.Println(err.Error())
  114. return err.Error()
  115. }
  116. request.Header.Set("Content-Type", "application/json;charset=UTF-8")
  117. request.Header.Set("x-tif-paasid", "test_hosp")
  118. request.Header.Set("x-tif-signature", signature)
  119. request.Header.Set("x-tif-timestamp", strconv.FormatInt(timestamp, 10))
  120. request.Header.Set("x-tif-nonce", nonce)
  121. client := http.Client{}
  122. resp, err := client.Do(request)
  123. if err != nil {
  124. fmt.Println(err.Error())
  125. return err.Error()
  126. }
  127. respBytes, err := ioutil.ReadAll(resp.Body)
  128. if err != nil {
  129. fmt.Println(err.Error())
  130. return err.Error()
  131. }
  132. fmt.Println(string(respBytes))
  133. str := string(respBytes)
  134. return str
  135. }
  136. func Gdyb1101A(certNo string, org_name string, doctor string, fixmedins_code string, insuplc_admdvs string, mdtrtarea_admvs string, secret_key string) string {
  137. //生成签名
  138. nonce := GetRandomString(32)
  139. timestamp := time.Now().Unix()
  140. signature := setSignature(timestamp, nonce, secret_key)
  141. //生成输入报文
  142. inputMessage := SetInputMessage(nonce, timestamp, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs)
  143. input := make(map[string]interface{})
  144. inputData := make(map[string]interface{})
  145. inputMessage["infno"] = "1101" // 交易编码
  146. inputData["mdtrt_cert_type"] = "02" // 就诊凭证类型
  147. inputData["card_sn"] = "" // 卡识别码
  148. inputData["certno"] = certNo // 证件号码
  149. inputData["psn_cert_type"] = "1" // 人员证件类型
  150. inputData["mdtrt_cert_no"] = certNo // 就诊凭证编号
  151. inputData["begntime"] = "" // 开始时间
  152. inputData["psn_name"] = "" // 人员姓名
  153. input["data"] = inputData
  154. inputMessage["input"] = input //交易输入
  155. bytesData, err := json.Marshal(inputMessage)
  156. fmt.Println(string(bytesData))
  157. if err != nil {
  158. fmt.Println(err.Error())
  159. return err.Error()
  160. }
  161. reader := bytes.NewReader(bytesData)
  162. //url := "http://igb.hsa.gdgov.cn/ebus/gdyb_api/prd/hsa/hgs/1101"
  163. url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/1101"
  164. //url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/1101"
  165. request, err := http.NewRequest("POST", url, reader)
  166. if err != nil {
  167. fmt.Println(err.Error())
  168. return err.Error()
  169. }
  170. request.Header.Set("Content-Type", "application/json;charset=UTF-8")
  171. request.Header.Set("x-tif-paasid", "test_hosp")
  172. request.Header.Set("x-tif-signature", signature)
  173. request.Header.Set("x-tif-timestamp", strconv.FormatInt(timestamp, 10))
  174. request.Header.Set("x-tif-nonce", nonce)
  175. client := http.Client{}
  176. resp, err := client.Do(request)
  177. if err != nil {
  178. fmt.Println(err.Error())
  179. return err.Error()
  180. }
  181. respBytes, err := ioutil.ReadAll(resp.Body)
  182. if err != nil {
  183. fmt.Println(err.Error())
  184. return err.Error()
  185. }
  186. fmt.Println(string(respBytes))
  187. str := string(respBytes)
  188. return str
  189. }
  190. // 门诊挂号
  191. func Gdyb2201(psnNo string, insutype string, certNo string, org_name string, doctor 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) string {
  192. // 生成签名
  193. nonce := GetRandomString(32)
  194. timestamp := time.Now().Unix()
  195. signature := setSignature(timestamp, nonce, secret_key)
  196. tempTime := time.Unix(timestamp, 0)
  197. timeFormatOne := tempTime.Format("2006-01-02 15:04:05")
  198. // 生成输入报文
  199. inputMessage := SetInputMessage(nonce, timestamp, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs)
  200. input := make(map[string]interface{})
  201. inputData := make(map[string]interface{})
  202. inputMessage["infno"] = "2201" // 交易编码
  203. inputData["psn_no"] = psnNo // 人员编号 (来自1101接口返回)
  204. inputData["insutype"] = insutype // 险种类型(来自1101接口返回)
  205. inputData["begntime"] = timeFormatOne // 开始时间
  206. //if id_card_type == 1 {
  207. // inputData["mdtrt_cert_type"] = "03" // 就诊凭证类型
  208. // inputData["mdtrt_cert_no"] = certNo // 就诊凭证编号
  209. //} else {
  210. inputData["mdtrt_cert_type"] = "02" // 就诊凭证类型
  211. inputData["mdtrt_cert_no"] = certNo // 就诊凭证编号
  212. //}
  213. inputData["ipt_otp_no"] = ipt_otp_no // 住院/门诊号
  214. inputData["atddr_no"] = doctor_id // 医师编码
  215. inputData["dr_name"] = doctor // 医师姓名
  216. inputData["dept_code"] = dept_code // 科室编码
  217. inputData["dept_name"] = dept // 科室名称
  218. inputData["caty"] = "A03.06" // 科别
  219. input["data"] = inputData
  220. inputMessage["input"] = input //交易输入
  221. bytesData, err := json.Marshal(inputMessage)
  222. fmt.Println(string(bytesData))
  223. if err != nil {
  224. fmt.Println(err.Error())
  225. return err.Error()
  226. }
  227. reader := bytes.NewReader(bytesData)
  228. url := "http://igb.hsa.gdgov.cn/ebus/gdyb_api/prd/hsa/hgs/2201"
  229. //url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/2201"
  230. //url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/2201"
  231. request, err := http.NewRequest("POST", url, reader)
  232. if err != nil {
  233. fmt.Println(err.Error())
  234. return err.Error()
  235. }
  236. request.Header.Set("Content-Type", "application/json;charset=UTF-8")
  237. request.Header.Set("x-tif-paasid", "sg03_prd")
  238. request.Header.Set("x-tif-signature", signature)
  239. request.Header.Set("x-tif-timestamp", strconv.FormatInt(timestamp, 10))
  240. request.Header.Set("x-tif-nonce", nonce)
  241. client := http.Client{}
  242. resp, err := client.Do(request)
  243. if err != nil {
  244. fmt.Println(err.Error())
  245. return err.Error()
  246. }
  247. respBytes, err := ioutil.ReadAll(resp.Body)
  248. if err != nil {
  249. fmt.Println(err.Error())
  250. return err.Error()
  251. }
  252. str := string(respBytes)
  253. fmt.Println(str)
  254. return str
  255. }
  256. // 门诊挂号撤销
  257. func Gdyb2202(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) string {
  258. // 生成签名
  259. nonce := GetRandomString(32)
  260. timestamp := time.Now().Unix()
  261. signature := setSignature(timestamp, nonce, secret_key)
  262. // 生成输入报文
  263. inputMessage := SetInputMessage(nonce, timestamp, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs)
  264. input := make(map[string]interface{})
  265. inputData := make(map[string]interface{})
  266. inputMessage["infno"] = "2202" // 交易编码
  267. inputData["psn_no"] = psnNo // 人员编号 (来自1101接口返回)
  268. inputData["mdtrt_id"] = mdtrtId // 就诊 ID(来自2201接口返回)
  269. inputData["ipt_otp_no"] = ipt_otp_no // 住院/门诊号
  270. input["data"] = inputData
  271. inputMessage["input"] = input //交易输入
  272. bytesData, err := json.Marshal(inputMessage)
  273. fmt.Println(string(bytesData))
  274. if err != nil {
  275. fmt.Println(err.Error())
  276. return err.Error()
  277. }
  278. reader := bytes.NewReader(bytesData)
  279. url := "http://igb.hsa.gdgov.cn/ebus/gdyb_api/prd/hsa/hgs/2202"
  280. //url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/2202"
  281. //url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/2202"
  282. request, err := http.NewRequest("POST", url, reader)
  283. if err != nil {
  284. fmt.Println(err.Error())
  285. return err.Error()
  286. }
  287. request.Header.Set("Content-Type", "application/json;charset=UTF-8")
  288. //request.Header.Set("x-tif-paasid", "test_hosp")
  289. request.Header.Set("x-tif-paasid", "sg03_prd")
  290. request.Header.Set("x-tif-signature", signature)
  291. request.Header.Set("x-tif-timestamp", strconv.FormatInt(timestamp, 10))
  292. request.Header.Set("x-tif-nonce", nonce)
  293. client := http.Client{}
  294. resp, err := client.Do(request)
  295. if err != nil {
  296. fmt.Println(err.Error())
  297. return err.Error()
  298. }
  299. respBytes, err := ioutil.ReadAll(resp.Body)
  300. if err != nil {
  301. fmt.Println(err.Error())
  302. return err.Error()
  303. }
  304. str := string(respBytes)
  305. fmt.Println(str)
  306. return str
  307. }
  308. // 门诊就诊信息上传
  309. func Gdyb2203(psnNo string, mdtrtId string, doctor string, department string, diag string, org_name string, med_type string, doctor_id int64, fixmedins_code string, diag_code string, insuplc_admdvs string, mdtrtarea_admvs string, secret_key string, sick_code string, sick_name string) string {
  310. // 生成签名
  311. nonce := GetRandomString(32)
  312. timestamp := time.Now().Unix()
  313. signature := setSignature(timestamp, nonce, secret_key)
  314. tempTime := time.Unix(timestamp, 0)
  315. timeFormatOne := tempTime.Format("2006-01-02 15:04:05")
  316. // 生成输入报文
  317. inputMessage := SetInputMessage(nonce, timestamp, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs)
  318. input := make(map[string]interface{})
  319. inputData := make(map[string]interface{})
  320. diseinfo := make([]map[string]interface{}, 0)
  321. inputMessage["infno"] = "2203" // 交易编码
  322. inputData["mdtrt_id"] = mdtrtId // 就诊 ID(来自2201接口返回)
  323. inputData["psn_no"] = psnNo // 人员编号 (来自1101接口返回)
  324. inputData["med_type"] = med_type // 医疗类别 16门诊特殊病
  325. inputData["begntime"] = timeFormatOne // 开始时间
  326. inputData["main_cond_dscr"] = "" // 主要病情描述
  327. inputData["dise_codg"] = sick_code // 病种编码
  328. inputData["dise_name"] = sick_name // 病种名称
  329. inputData["birctrl_type"] = "" // 计划生育手术类别
  330. inputData["birctrl_matn_date"] = "" // 计划生育手术或生育日期
  331. diseinfo_sun := make(map[string]interface{})
  332. diseinfo_sun["diag_type"] = "1" // 诊断类别
  333. diseinfo_sun["diag_srt_no"] = "1" // 诊断排序号
  334. diseinfo_sun["diag_code"] = diag_code // 诊断代码
  335. diseinfo_sun["diag_name"] = diag // 诊断名称
  336. diseinfo_sun["diag_dept"] = department // 诊断科室
  337. diseinfo_sun["dise_dor_no"] = doctor_id // 诊断医生编码
  338. diseinfo_sun["dise_dor_name"] = doctor // 诊断医生姓名
  339. diseinfo_sun["diag_time"] = timeFormatOne // 诊断时间
  340. diseinfo_sun["vali_flag"] = "1" // 有效标志
  341. diseinfo = append(diseinfo, diseinfo_sun)
  342. input["diseinfo"] = diseinfo
  343. input["mdtrtinfo"] = inputData
  344. inputMessage["input"] = input //交易输入
  345. bytesData, err := json.Marshal(inputMessage)
  346. fmt.Println(string(bytesData))
  347. if err != nil {
  348. fmt.Println(err.Error())
  349. return err.Error()
  350. }
  351. reader := bytes.NewReader(bytesData)
  352. url := "http://igb.hsa.gdgov.cn/ebus/gdyb_api/prd/hsa/hgs/2203"
  353. //url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/2203"
  354. //url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/2203"
  355. request, err := http.NewRequest("POST", url, reader)
  356. if err != nil {
  357. fmt.Println(err.Error())
  358. return err.Error()
  359. }
  360. request.Header.Set("Content-Type", "application/json;charset=UTF-8")
  361. request.Header.Set("x-tif-paasid", "sg03_prd")
  362. request.Header.Set("x-tif-signature", signature)
  363. request.Header.Set("x-tif-timestamp", strconv.FormatInt(timestamp, 10))
  364. request.Header.Set("x-tif-nonce", nonce)
  365. client := http.Client{}
  366. resp, err := client.Do(request)
  367. if err != nil {
  368. fmt.Println(err.Error())
  369. return err.Error()
  370. }
  371. respBytes, err := ioutil.ReadAll(resp.Body)
  372. if err != nil {
  373. fmt.Println(err.Error())
  374. return err.Error()
  375. }
  376. str := string(respBytes)
  377. fmt.Println(str)
  378. return str
  379. }
  380. // 门诊就诊信息上传
  381. func Gdyb2203A(psnNo string, mdtrtId string, doctor string, department string, diag string, org_name string, med_type string, doctor_id int64, fixmedins_code string, diag_code string, insuplc_admdvs string, mdtrtarea_admvs string, secret_key string, sick_code string, sick_name string) string {
  382. // 生成签名
  383. nonce := GetRandomString(32)
  384. timestamp := time.Now().Unix()
  385. signature := setSignature(timestamp, nonce, secret_key)
  386. tempTime := time.Unix(timestamp, 0)
  387. timeFormatOne := tempTime.Format("2006-01-02 15:04:05")
  388. // 生成输入报文
  389. inputMessage := SetInputMessage(nonce, timestamp, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs)
  390. input := make(map[string]interface{})
  391. inputData := make(map[string]interface{})
  392. diseinfo := make([]map[string]interface{}, 0)
  393. inputMessage["infno"] = "2203A" // 交易编码
  394. inputData["mdtrt_id"] = mdtrtId // 就诊 ID(来自2201接口返回)
  395. inputData["psn_no"] = psnNo // 人员编号 (来自1101接口返回)
  396. inputData["med_type"] = med_type // 医疗类别 16门诊特殊病
  397. inputData["begntime"] = timeFormatOne // 开始时间
  398. inputData["main_cond_dscr"] = "" // 主要病情描述
  399. inputData["dise_codg"] = sick_code // 病种编码
  400. inputData["dise_name"] = sick_name // 病种名称
  401. inputData["birctrl_type"] = "" // 计划生育手术类别
  402. inputData["birctrl_matn_date"] = "" // 计划生育手术或生育日期
  403. inputData["matn_type"] = "" // 生育类别
  404. inputData["geso_val"] = "" // 孕周数
  405. diseinfo_sun := make(map[string]interface{})
  406. diseinfo_sun["diag_type"] = "1" // 诊断类别
  407. diseinfo_sun["diag_srt_no"] = "1" // 诊断排序号
  408. diseinfo_sun["diag_code"] = diag_code // 诊断代码
  409. diseinfo_sun["diag_name"] = diag // 诊断名称
  410. diseinfo_sun["diag_dept"] = department // 诊断科室
  411. diseinfo_sun["dise_dor_no"] = doctor_id // 诊断医生编码
  412. diseinfo_sun["dise_dor_name"] = doctor // 诊断医生姓名
  413. diseinfo_sun["diag_time"] = timeFormatOne // 诊断时间
  414. diseinfo_sun["vali_flag"] = "1" // 有效标志
  415. diseinfo = append(diseinfo, diseinfo_sun)
  416. input["diseinfo"] = diseinfo
  417. input["mdtrtinfo"] = inputData
  418. inputMessage["input"] = input //交易输入
  419. bytesData, err := json.Marshal(inputMessage)
  420. fmt.Println(string(bytesData))
  421. if err != nil {
  422. fmt.Println(err.Error())
  423. return err.Error()
  424. }
  425. reader := bytes.NewReader(bytesData)
  426. url := "http://igb.hsa.gdgov.cn/ebus/gdyb_api/prd/hsa/hgs/2203A"
  427. //url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/2203"
  428. //url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/2203"
  429. request, err := http.NewRequest("POST", url, reader)
  430. if err != nil {
  431. fmt.Println(err.Error())
  432. return err.Error()
  433. }
  434. request.Header.Set("Content-Type", "application/json;charset=UTF-8")
  435. request.Header.Set("x-tif-paasid", "sg03_prd")
  436. request.Header.Set("x-tif-signature", signature)
  437. request.Header.Set("x-tif-timestamp", strconv.FormatInt(timestamp, 10))
  438. request.Header.Set("x-tif-nonce", nonce)
  439. client := http.Client{}
  440. resp, err := client.Do(request)
  441. if err != nil {
  442. fmt.Println(err.Error())
  443. return err.Error()
  444. }
  445. respBytes, err := ioutil.ReadAll(resp.Body)
  446. if err != nil {
  447. fmt.Println(err.Error())
  448. return err.Error()
  449. }
  450. str := string(respBytes)
  451. fmt.Println(str)
  452. return str
  453. }
  454. type Custom struct {
  455. DetItemFeeSumamt string
  456. Cut string
  457. FeedetlSn string
  458. Price string
  459. MedListCodg string
  460. }
  461. type RequestResult struct {
  462. Output Output `json:"output" form:"output"`
  463. Infcode int64 `gorm:"column:infcode" json:"infcode" form:"infcode"`
  464. WarnMsg string `gorm:"column:warn_msg" json:"warn_msg" form:"warn_msg"`
  465. Cainfo string `gorm:"column:cainfo" json:"cainfo" form:"cainfo"`
  466. ErrMsg string `gorm:"column:err_msg" json:"err_msg" form:"err_msg"`
  467. RespondTime string `gorm:"column:respond_time" json:"respond_time" form:"respond_time"`
  468. InfRefmsgid string `gorm:"column:inf_refmsgid" json:"inf_refmsgid" form:"inf_refmsgid"`
  469. }
  470. type Output struct {
  471. Result Result `json:"result" form:"result"`
  472. }
  473. type Result struct {
  474. BasMednFlag string `json:"bas_medn_flag" form:"bas_medn_flag"`
  475. MedChrgitmType string `json:"med_chrgitm_type" form:"med_chrgitm_type"`
  476. DetItemFeeSumamt int64 `json:"det_item_fee_sumamt" form:"det_item_fee_sumamt"`
  477. HiNegoDrugFlag string `json:"hi_nego_drug_flag" form:"hi_nego_drug_flag"`
  478. FulamtOwnpayAmt float64 `json:"fulamt_ownpay_amt" form:"fulamt_ownpay_amt"`
  479. FeedtlSn int64 `json:"feedtl_sn" form:"feedtl_sn"`
  480. UploadDate int64 `json:"upload_date" form:"upload_date"`
  481. AdviceId int64 `json:"advice_id" form:"advice_id"`
  482. Cnt int64 `json:"cnt" form:"cnt"`
  483. Pric float64 `json:"pric" form:"pric"`
  484. PatientId int64 `json:"patient_id" form:"patient_id"`
  485. PricUplmtAmt float64 `json:"pric_uplmt_amt" form:"pric_uplmt_amt"`
  486. SelfpayProp float64 `json:"selfpay_prop" form:"selfpay_prop"`
  487. OverlmtAmt float64 `json:"overlmt_amt" form:"overlmt_amt"`
  488. PreselfpayAmt float64 `json:"preselfpay_amt" form:"preselfpay_amt"`
  489. Status int64 `json:"status" form:"status"`
  490. Memo string `json:"memo" form:"memo"`
  491. FeedetlSn string `json:"feedetl_sn" form:"feedetl_sn"`
  492. Mtime int64 `json:"mtime" form:"mtime"`
  493. InscpScpAmt float64 `json:"inscp_scp_amt" form:"inscp_scp_amt"`
  494. DrtReimFlag string `json:"drt_reim_flag" form:"drt_reim_flag"`
  495. Ctime int64 `json:"ctime" form:"ctime"`
  496. ListSpItemFlag string `json:"list_sp_item_flag" form:"list_sp_item_flag"`
  497. ChldMedcFlag string `json:"chld_medc_flag" form:"chld_medc_flag"`
  498. LmtUsedFlag string `json:"lmt_used_flag" form:"lmt_used_flag"`
  499. ChrgitmLv string `json:"chrgitm_lv" form:"chrgitm_lv"`
  500. UserOrgId int64 `json:"user_org_id" form:"user_org_id"`
  501. HisPatientId int64 `json:"his_patient_id" form:"his_patient_id"`
  502. OrderId int64 `json:"order_id" form:"order_id"`
  503. }
  504. // 门诊费用明细信息上传
  505. func Gdyb2204(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) string {
  506. // 生成签名
  507. nonce := GetRandomString(32)
  508. timestamp := time.Now().Unix()
  509. signature := setSignature(timestamp, nonce, secret_key)
  510. tempTime := time.Unix(timestamp, 0)
  511. //timeFormat := tempTime.Format("20060102150405")
  512. timeFormatOne := tempTime.Format("2006-01-02 15:04:05")
  513. //chrgBchno := rand.Intn(100000) + 10000
  514. var customs []*Custom
  515. for _, item := range hisPrescription {
  516. if item.Type == 1 { //药品
  517. for _, subItem := range item.HisDoctorAdviceInfo {
  518. if len(subItem.BaseDrugLib.MedicalInsuranceNumber) > 0 {
  519. //var randNum int
  520. //randNum = rand.Intn(10000) + 1000
  521. cus := &Custom{
  522. DetItemFeeSumamt: fmt.Sprintf("%.2f", subItem.Price*subItem.PrescribingNumber),
  523. Cut: fmt.Sprintf("%.2f", subItem.PrescribingNumber),
  524. FeedetlSn: subItem.FeedetlSn,
  525. Price: fmt.Sprintf("%.2f", subItem.Price),
  526. MedListCodg: subItem.BaseDrugLib.MedicalInsuranceNumber,
  527. }
  528. customs = append(customs, cus)
  529. }
  530. }
  531. }
  532. if item.Type == 2 { //项目
  533. for _, subItem := range item.HisPrescriptionProject {
  534. //var randNum int
  535. //randNum = rand.Intn(10000) + 1000
  536. if len(subItem.HisProject.MedicalCode) > 0 {
  537. cus := &Custom{
  538. DetItemFeeSumamt: fmt.Sprintf("%.2f", subItem.Price*float64(subItem.Count)),
  539. Cut: fmt.Sprintf("%.2f", float64(subItem.Count)),
  540. FeedetlSn: subItem.FeedetlSn,
  541. Price: fmt.Sprintf("%.2f", float64(subItem.Price)),
  542. MedListCodg: subItem.HisProject.MedicalCode,
  543. }
  544. customs = append(customs, cus)
  545. }
  546. }
  547. }
  548. for _, subItem := range item.HisAdditionalCharge {
  549. if len(subItem.XtHisAddtionConfig.Code) > 0 {
  550. cus := &Custom{
  551. DetItemFeeSumamt: fmt.Sprintf("%.2f", subItem.Price*float64(subItem.Count)),
  552. Cut: fmt.Sprintf("%.2f", float64(subItem.Count)),
  553. FeedetlSn: subItem.FeedetlSn,
  554. Price: fmt.Sprintf("%.2f", float64(subItem.Price)),
  555. MedListCodg: subItem.XtHisAddtionConfig.Code,
  556. }
  557. customs = append(customs, cus)
  558. }
  559. }
  560. }
  561. // 生成输入报文
  562. inputMessage := SetInputMessage(nonce, timestamp, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs)
  563. input := make(map[string]interface{})
  564. feedetail := make([]map[string]interface{}, 0)
  565. inputMessage["infno"] = "2204" // 交易编码
  566. //chrg_bchno := timeFormat + strconv.FormatInt(int64(chrgBchno), 10)
  567. for _, item := range customs {
  568. feedetailInfo := make(map[string]interface{})
  569. feedetailInfo["feedetl_sn"] = item.FeedetlSn
  570. feedetailInfo["mdtrt_id"] = mdtrtId // 就诊 ID(来自2201接口返回)
  571. feedetailInfo["psn_no"] = psnNo // 人员编号 (来自1101接口返回)
  572. feedetailInfo["chrg_bchno"] = chrg_bchno // 收费批次号
  573. feedetailInfo["dise_codg"] = "" // 病种编码
  574. feedetailInfo["rxno"] = "" // 处方号
  575. feedetailInfo["rx_circ_flag"] = "0" // 外购处方标志
  576. feedetailInfo["fee_ocur_time"] = timeFormatOne // 费用发生时间
  577. feedetailInfo["med_list_codg"] = item.MedListCodg // 医疗目录编码
  578. feedetailInfo["medins_list_codg"] = fixmedins_code // 医药机构目录编码
  579. feedetailInfo["det_item_fee_sumamt"] = item.DetItemFeeSumamt // 明细项目费用总额
  580. feedetailInfo["cnt"] = item.Cut // 数量
  581. feedetailInfo["pric"] = item.Price // 单价
  582. feedetailInfo["sin_dos_dscr"] = "" // 单次剂量描述
  583. feedetailInfo["used_frqu_dscr"] = "" // 使用频次描述
  584. feedetailInfo["prd_days"] = "0" // 周期天数
  585. feedetailInfo["medc_way_dscr"] = "" // 用药途径描述
  586. feedetailInfo["bilg_dept_codg"] = dept_code // 开单科室编码
  587. feedetailInfo["bilg_dept_name"] = dept // 开单科室名称
  588. feedetailInfo["bilg_dr_codg"] = doctor_id // 开单医生编码
  589. feedetailInfo["bilg_dr_name"] = doctor // 开单医师姓名
  590. feedetailInfo["acord_dept_codg"] = "" // 受单科室编码
  591. feedetailInfo["acord_dept_name"] = "" // 受单科室名称
  592. feedetailInfo["orders_dr_code"] = "" // 受单医生编码
  593. feedetailInfo["orders_dr_name"] = "" // 受单医生姓名
  594. feedetailInfo["hosp_appr_flag"] = "1" // 医院审批标志
  595. feedetailInfo["tcmdrug_used_way"] = "" // 中药使用方式
  596. feedetailInfo["etip_flag"] = "" // 外检标志
  597. feedetailInfo["etip_hosp_code"] = "" // 外检医院编码
  598. feedetailInfo["dscg_tkdrug_flag"] = "" // 出院带药标志
  599. feedetailInfo["matn_fee_flag"] = "" // 生育费用标志
  600. feedetail = append(feedetail, feedetailInfo)
  601. }
  602. input["feedetail"] = feedetail
  603. inputMessage["input"] = input //交易输入
  604. bytesData, err := json.Marshal(inputMessage)
  605. fmt.Println("----------")
  606. fmt.Println(string(bytesData))
  607. fmt.Println("----------")
  608. if err != nil {
  609. fmt.Println(err.Error())
  610. return ""
  611. }
  612. reader := bytes.NewReader(bytesData)
  613. url := "http://igb.hsa.gdgov.cn/ebus/gdyb_api/prd/hsa/hgs/2204"
  614. //url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/2204"
  615. //url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/2204"
  616. request, err := http.NewRequest("POST", url, reader)
  617. if err != nil {
  618. fmt.Println(err.Error())
  619. return ""
  620. }
  621. request.Header.Set("Content-Type", "application/json;charset=UTF-8")
  622. request.Header.Set("x-tif-paasid", "sg03_prd")
  623. request.Header.Set("x-tif-signature", signature)
  624. request.Header.Set("x-tif-timestamp", strconv.FormatInt(timestamp, 10))
  625. request.Header.Set("x-tif-nonce", nonce)
  626. client := http.Client{}
  627. resp, err := client.Do(request)
  628. if err != nil {
  629. fmt.Println(err.Error())
  630. return ""
  631. }
  632. respBytes, err := ioutil.ReadAll(resp.Body)
  633. if err != nil {
  634. fmt.Println(err.Error())
  635. return ""
  636. }
  637. return string(respBytes)
  638. //var result RequestResult
  639. //json.Unmarshal(respBytes, &result)
  640. //return &result
  641. }
  642. // 门诊费用明细信息撤销
  643. func Gdyb2205(psnNo string, mdtrtId string, chrgBchno string, org_name string, doctor string, insuplc_admdvs string, mdtrtarea_admvs string, secret_key string, fixmedins_code string) string {
  644. // 生成签名
  645. nonce := GetRandomString(32)
  646. timestamp := time.Now().Unix()
  647. signature := setSignature(timestamp, nonce, secret_key)
  648. // 生成输入报文
  649. inputMessage := SetInputMessage(nonce, timestamp, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs)
  650. input := make(map[string]interface{})
  651. inputData := make(map[string]interface{})
  652. inputMessage["infno"] = "2205" // 交易编码
  653. inputData["mdtrt_id"] = mdtrtId // 就诊 ID(来自2201接口返回)
  654. inputData["chrg_bchno"] = chrgBchno // 收费批次号(来自2204生成的)
  655. inputData["psn_no"] = psnNo // 人员编号 (来自1101接口返回)
  656. input["data"] = inputData
  657. inputMessage["input"] = input //交易输入
  658. bytesData, err := json.Marshal(inputMessage)
  659. fmt.Println(string(bytesData))
  660. if err != nil {
  661. fmt.Println(err.Error())
  662. return err.Error()
  663. }
  664. reader := bytes.NewReader(bytesData)
  665. url := "http://igb.hsa.gdgov.cn/ebus/gdyb_api/prd/hsa/hgs/2205"
  666. //url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/2205"
  667. //url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/2205"
  668. request, err := http.NewRequest("POST", url, reader)
  669. fmt.Println(err)
  670. fmt.Println(request)
  671. if err != nil {
  672. fmt.Println(err.Error())
  673. return err.Error()
  674. }
  675. request.Header.Set("Content-Type", "application/json;charset=UTF-8")
  676. request.Header.Set("x-tif-paasid", "sg03_prd")
  677. request.Header.Set("x-tif-signature", signature)
  678. request.Header.Set("x-tif-timestamp", strconv.FormatInt(timestamp, 10))
  679. request.Header.Set("x-tif-nonce", nonce)
  680. client := http.Client{}
  681. resp, err := client.Do(request)
  682. if err != nil {
  683. fmt.Println(err.Error())
  684. return err.Error()
  685. }
  686. respBytes, err := ioutil.ReadAll(resp.Body)
  687. if err != nil {
  688. fmt.Println(err.Error())
  689. return err.Error()
  690. }
  691. str := string(respBytes)
  692. fmt.Println(str)
  693. return str
  694. }
  695. // 门诊预结算
  696. //func Gdyb2206(psnNo string, mdtrtId string, chrgBchno string, certNo string, insutype string, total string, org_name string, doctor string, secret_key string) string {
  697. func Gdyb2206(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) string {
  698. // 生成签名
  699. nonce := GetRandomString(32)
  700. timestamp := time.Now().Unix()
  701. signature := setSignature(timestamp, nonce, secret_key)
  702. // 生成输入报文
  703. inputMessage := SetInputMessage(nonce, timestamp, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs)
  704. input := make(map[string]interface{})
  705. inputData := make(map[string]interface{})
  706. inputMessage["infno"] = "2206" // 交易编码
  707. inputData["psn_no"] = psnNo // 人员编号 (来自1101接口返回)
  708. if id_card_type == 1 {
  709. inputData["mdtrt_cert_type"] = "03" // 就诊凭证类型
  710. inputData["mdtrt_cert_no"] = certNo // 就诊凭证编号
  711. } else {
  712. inputData["mdtrt_cert_type"] = "02" // 就诊凭证类型
  713. inputData["mdtrt_cert_no"] = certNo // 就诊凭证编号
  714. }
  715. inputData["med_type"] = "11" // 医疗类别 11 普通门诊 12 门诊挂号
  716. inputData["medfee_sumamt"] = total // 医疗费总额
  717. inputData["psn_setlway"] = "01" // 个人结算方式 01 按项目结 02 按定额结算
  718. inputData["mdtrt_id"] = mdtrtId // 就诊 ID(来自2201接口返回)
  719. inputData["chrg_bchno"] = chrgBchno // 收费批次号(来自2204生成的)
  720. inputData["acct_used_flag"] = "1" // 个人账户使用标志 0否 1是
  721. inputData["insutype"] = insutype // 险种类型
  722. input["data"] = inputData
  723. inputMessage["input"] = input //交易输入
  724. bytesData, err := json.Marshal(inputMessage)
  725. fmt.Println(string(bytesData))
  726. if err != nil {
  727. fmt.Println(err.Error())
  728. return err.Error()
  729. }
  730. reader := bytes.NewReader(bytesData)
  731. url := "http://igb.hsa.gdgov.cn/ebus/gdyb_api/prd/hsa/hgs/2206"
  732. //url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/2206"
  733. //url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/2206"
  734. request, err := http.NewRequest("POST", url, reader)
  735. if err != nil {
  736. fmt.Println(err.Error())
  737. return err.Error()
  738. }
  739. request.Header.Set("Content-Type", "application/json;charset=UTF-8")
  740. request.Header.Set("x-tif-paasid", "sg03_prd")
  741. request.Header.Set("x-tif-signature", signature)
  742. request.Header.Set("x-tif-timestamp", strconv.FormatInt(timestamp, 10))
  743. request.Header.Set("x-tif-nonce", nonce)
  744. client := http.Client{}
  745. resp, err := client.Do(request)
  746. if err != nil {
  747. fmt.Println(err.Error())
  748. return err.Error()
  749. }
  750. respBytes, err := ioutil.ReadAll(resp.Body)
  751. if err != nil {
  752. fmt.Println(err.Error())
  753. return err.Error()
  754. }
  755. str := string(respBytes)
  756. fmt.Println(str)
  757. return str
  758. }
  759. // 门诊结算
  760. func Gdyb2207(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) string {
  761. // 生成签名
  762. nonce := GetRandomString(32)
  763. timestamp := time.Now().Unix()
  764. signature := setSignature(timestamp, nonce, secret_key)
  765. // 生成输入报文
  766. inputMessage := SetInputMessage(nonce, timestamp, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs)
  767. input := make(map[string]interface{})
  768. inputData := make(map[string]interface{})
  769. inputMessage["infno"] = "2207" // 交易编码
  770. inputData["psn_no"] = psnNo // 人员编号 (来自1101接口返回)
  771. if id_card_type == 1 {
  772. inputData["mdtrt_cert_type"] = "03" // 就诊凭证类型
  773. inputData["mdtrt_cert_no"] = certNo // 就诊凭证编号
  774. } else {
  775. inputData["mdtrt_cert_type"] = "02" // 就诊凭证类型
  776. inputData["mdtrt_cert_no"] = certNo // 就诊凭证编号
  777. }
  778. inputData["med_type"] = med_type // 医疗类别 11 普通门诊 12 门诊挂号
  779. inputData["medfee_sumamt"] = total // 医疗费总额
  780. inputData["psn_setlway"] = "01" // 个人结算方式 01 按项目结 02 按定额结算
  781. inputData["mdtrt_id"] = mdtrtId // 就诊 ID(来自2201接口返回)
  782. inputData["chrg_bchno"] = chrgBchno // 收费批次号(来自2204生成的)
  783. inputData["acct_used_flag"] = "1" // 个人账户使用标志 0否 1是
  784. inputData["insutype"] = insutype // 险种类型
  785. inputData["invono"] = "" // 发票号
  786. inputData["fulamt_ownpay_amt"] = fulamt_ownpay_amt //
  787. inputData["overlmt_selfpay"] = overlmt_selfpay //
  788. inputData["preselfpay_amt"] = preselfpay_amt //
  789. inputData["inscp_scp_amt"] = inscp_scp_amt //
  790. input["data"] = inputData
  791. inputMessage["input"] = input //交易输入
  792. bytesData, err := json.Marshal(inputMessage)
  793. fmt.Println(string(bytesData))
  794. if err != nil {
  795. fmt.Println(err.Error())
  796. return err.Error()
  797. }
  798. reader := bytes.NewReader(bytesData)
  799. url := "http://igb.hsa.gdgov.cn/ebus/gdyb_api/prd/hsa/hgs/2207"
  800. //url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/2207"
  801. //url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/2207"
  802. request, err := http.NewRequest("POST", url, reader)
  803. if err != nil {
  804. fmt.Println(err.Error())
  805. return err.Error()
  806. }
  807. request.Header.Set("Content-Type", "application/json;charset=UTF-8")
  808. request.Header.Set("x-tif-paasid", "sg03_prd")
  809. request.Header.Set("x-tif-signature", signature)
  810. request.Header.Set("x-tif-timestamp", strconv.FormatInt(timestamp, 10))
  811. request.Header.Set("x-tif-nonce", nonce)
  812. client := http.Client{}
  813. resp, err := client.Do(request)
  814. if err != nil {
  815. fmt.Println(err.Error())
  816. return err.Error()
  817. }
  818. respBytes, err := ioutil.ReadAll(resp.Body)
  819. if err != nil {
  820. fmt.Println(err.Error())
  821. return err.Error()
  822. }
  823. str := string(respBytes)
  824. fmt.Println(str)
  825. return str
  826. }
  827. // 门诊结算撤销
  828. func Gdyb2208(psnNo string, mdtrtId string, setlId string, org_name string, doctor string, secret_key string, fixmedins_code string, insuplc_admdvs string, mdtrtarea_admvs string) string {
  829. // 生成签名
  830. nonce := GetRandomString(32)
  831. timestamp := time.Now().Unix()
  832. signature := setSignature(timestamp, nonce, secret_key)
  833. // 生成输入报文
  834. inputMessage := SetInputMessage(nonce, timestamp, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs)
  835. input := make(map[string]interface{})
  836. inputData := make(map[string]interface{})
  837. inputMessage["infno"] = "2208" // 交易编码
  838. inputData["psn_no"] = psnNo // 人员编号 (来自1101接口返回)
  839. inputData["mdtrt_id"] = mdtrtId // 就诊 ID(来自2201接口返回)
  840. inputData["setl_id"] = setlId // 结算 ID
  841. input["data"] = inputData
  842. inputMessage["input"] = input //交易输入
  843. bytesData, err := json.Marshal(inputMessage)
  844. fmt.Println(string(bytesData))
  845. if err != nil {
  846. fmt.Println(err.Error())
  847. return err.Error()
  848. }
  849. reader := bytes.NewReader(bytesData)
  850. url := "http://igb.hsa.gdgov.cn/ebus/gdyb_api/prd/hsa/hgs/2208"
  851. //url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/2208"
  852. //url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/2208"
  853. request, err := http.NewRequest("POST", url, reader)
  854. if err != nil {
  855. fmt.Println(err.Error())
  856. return err.Error()
  857. }
  858. request.Header.Set("Content-Type", "application/json;charset=UTF-8")
  859. request.Header.Set("x-tif-paasid", "sg03_prd")
  860. request.Header.Set("x-tif-signature", signature)
  861. request.Header.Set("x-tif-timestamp", strconv.FormatInt(timestamp, 10))
  862. request.Header.Set("x-tif-nonce", nonce)
  863. client := http.Client{}
  864. resp, err := client.Do(request)
  865. if err != nil {
  866. fmt.Println(err.Error())
  867. return err.Error()
  868. }
  869. respBytes, err := ioutil.ReadAll(resp.Body)
  870. if err != nil {
  871. fmt.Println(err.Error())
  872. return err.Error()
  873. }
  874. str := string(respBytes)
  875. fmt.Println(str)
  876. return str
  877. }
  878. //确认订单
  879. func Gdyb6201(org_name string, doctor string, fixmedins_code string, insuplc_admdvs string, mdtrtarea_admvs string, secret_key string, order models.HisOrder) string {
  880. // 生成签名
  881. nonce := GetRandomString(32)
  882. timestamp := time.Now().Unix()
  883. signature := setSignature(timestamp, nonce, secret_key)
  884. // 生成输入报文
  885. inputMessage := SetInputMessage(nonce, timestamp, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs)
  886. input := make(map[string]interface{})
  887. inputData := make(map[string]interface{})
  888. inputMessage["infno"] = "6201" // 交易编码
  889. inputData["mdtrt_id"] = order.MdtrtId
  890. inputData["chrg_bchno"] = order.Number
  891. inputData["psn_no"] = order.PsnNo
  892. inputData["psn_name"] = order.PsnName
  893. inputData["psn_cert_type"] = order.PsnCertType
  894. inputData["certno"] = order.Certno
  895. inputData["insutype"] = order.Insutype
  896. inputData["med_type"] = order.MedType
  897. inputData["medfee_sumamt"] = order.MedfeeSumamt
  898. inputData["fulamt_ownpay_amt"] = order.FulamtOwnpayAmt
  899. inputData["overlmt_selfpay"] = order.OverlmtSelfPay
  900. inputData["preselfpay_amt"] = order.PreselfpayAmt
  901. inputData["inscp_scp_amt"] = order.InscpScpAmt
  902. inputData["act_pay_dedc"] = order.ActPayDedc
  903. inputData["hifp_pay"] = order.HifpPay
  904. inputData["pool_prop_selfpay"] = order.PoolPropSelfpay
  905. inputData["cvlserv_pay"] = order.CvlservPay
  906. inputData["hifes_pay"] = order.HifesPay
  907. inputData["hifmi_pay"] = order.HifmiPay
  908. inputData["hifob_pay"] = order.HifobPay
  909. inputData["maf_pay"] = order.MafPay
  910. inputData["oth_pay"] = order.OthPay
  911. inputData["fund_pay_sumamt"] = order.FundPaySumamt
  912. inputData["psn_part_amt"] = order.PsnPartAmt
  913. inputData["acct_pay"] = order.AcctPay
  914. inputData["psn_cash_pay"] = order.PsnCashPay
  915. inputData["hosp_part_amt"] = order.HospPartAmt
  916. inputData["acct_mulaid_pay"] = order.AcctMulaidPay
  917. input["data"] = inputData
  918. inputMessage["input"] = input //交易输入
  919. bytesData, err := json.Marshal(inputMessage)
  920. fmt.Println(string(bytesData))
  921. if err != nil {
  922. fmt.Println(err.Error())
  923. return err.Error()
  924. }
  925. reader := bytes.NewReader(bytesData)
  926. url := "http://igb.hsa.gdgov.cn/ebus/gdyb_api/prd/hsa/hgs/6201"
  927. //url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/6201"
  928. //url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/2207"
  929. request, err := http.NewRequest("POST", url, reader)
  930. if err != nil {
  931. fmt.Println(err.Error())
  932. return err.Error()
  933. }
  934. request.Header.Set("Content-Type", "application/json;charset=UTF-8")
  935. request.Header.Set("x-tif-paasid", "sg03_prd")
  936. request.Header.Set("x-tif-signature", signature)
  937. request.Header.Set("x-tif-timestamp", strconv.FormatInt(timestamp, 10))
  938. request.Header.Set("x-tif-nonce", nonce)
  939. client := http.Client{}
  940. resp, err := client.Do(request)
  941. if err != nil {
  942. fmt.Println(err.Error())
  943. return err.Error()
  944. }
  945. respBytes, err := ioutil.ReadAll(resp.Body)
  946. if err != nil {
  947. fmt.Println(err.Error())
  948. return err.Error()
  949. }
  950. str := string(respBytes)
  951. fmt.Println(str)
  952. return str
  953. }
  954. // 医药机构费用结算对总账 func Gdyb3201( org_name string, doctor string, secret_key string, fixmedins_code string, insuplc_admdvs string, mdtrtarea_admvs string) string {
  955. func Gdyb3201(baseParams models.BaseParams, businessParams models.BusinessParams) string {
  956. fmt.Println("11222333-----")
  957. fmt.Println(baseParams)
  958. fmt.Println(businessParams)
  959. // 生成签名
  960. nonce := GetRandomString(32)
  961. timestamp := time.Now().Unix()
  962. signature := setSignature(timestamp, nonce, baseParams.SecretKey)
  963. // 生成输入报文
  964. inputMessage := SetInputMessage(nonce, timestamp, baseParams.OrgName, baseParams.Doctor, baseParams.FixmedinsCode, baseParams.InsuplcAdmdvs, baseParams.MdtrtareaAdmvs)
  965. input := make(map[string]interface{})
  966. inputData := make(map[string]interface{})
  967. inputMessage["infno"] = "3201" // 交易编码
  968. inputData["insutype"] = businessParams.Insutype // 险种
  969. inputData["clr_type"] = businessParams.ClrType // 就诊 ID(来自2201接口返回)
  970. inputData["setl_optins"] = "定点医保中心" // 结算经办机构
  971. inputData["stmt_begndate"] = businessParams.StmtBegndate // 对帐开始时间
  972. inputData["stmt_enddate"] = businessParams.StmtEnddate //对帐结束时间
  973. inputData["medfee_sumamt"] = businessParams.MedfeeSumamt //医疗费总额
  974. inputData["fund_pay_sumamt"] = businessParams.FundPaySumamt //基金支付总额
  975. inputData["acct_pay"] = businessParams.AcctPay //个人账户支付金额
  976. inputData["fixmedins_setl_cnt"] = businessParams.FixmedinsSetlCnt //定点医药机构结算笔数
  977. input["data"] = inputData
  978. inputMessage["input"] = input //交易输入
  979. bytesData, err := json.Marshal(inputMessage)
  980. fmt.Println(string(bytesData))
  981. if err != nil {
  982. fmt.Println(err.Error())
  983. return err.Error()
  984. }
  985. reader := bytes.NewReader(bytesData)
  986. url := "http://igb.hsa.gdgov.cn/ebus/gdyb_api/prd/hsa/hgs/3201"
  987. //url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/3201"
  988. //url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/3201"
  989. request, err := http.NewRequest("POST", url, reader)
  990. if err != nil {
  991. fmt.Println(err.Error())
  992. return err.Error()
  993. }
  994. request.Header.Set("Content-Type", "application/json;charset=UTF-8")
  995. request.Header.Set("x-tif-paasid", "sg03_prd")
  996. request.Header.Set("x-tif-signature", signature)
  997. request.Header.Set("x-tif-timestamp", strconv.FormatInt(timestamp, 10))
  998. request.Header.Set("x-tif-nonce", nonce)
  999. client := http.Client{}
  1000. resp, err := client.Do(request)
  1001. if err != nil {
  1002. fmt.Println(err.Error())
  1003. return err.Error()
  1004. }
  1005. respBytes, err := ioutil.ReadAll(resp.Body)
  1006. if err != nil {
  1007. fmt.Println(err.Error())
  1008. return err.Error()
  1009. }
  1010. str := string(respBytes)
  1011. fmt.Println(str)
  1012. return str
  1013. }
  1014. type Params struct {
  1015. FileName string `json:"file_name"` //产品ID
  1016. In []byte `json:"in"` //
  1017. FixmedinsCode string `json:"fixmedins_code"` //调用环境生产为1 沙盒2
  1018. }
  1019. //文件上传
  1020. //文件上传
  1021. func Gdyb9101(baseParams models.BaseParams, file_name string, file_byte []byte) string {
  1022. // 生成签名
  1023. nonce := GetRandomString(32)
  1024. timestamp := time.Now().Unix()
  1025. signature := setSignature(timestamp, nonce, baseParams.SecretKey)
  1026. buf := new(bytes.Buffer)
  1027. buf.ReadFrom(strings.NewReader(string(file_byte)))
  1028. inputMessage := SetInputMessage(nonce, timestamp, baseParams.OrgName, baseParams.Doctor, baseParams.FixmedinsCode, baseParams.InsuplcAdmdvs, baseParams.MdtrtareaAdmvs)
  1029. input := make(map[string]interface{})
  1030. inputData := make(map[string]interface{})
  1031. inputMessage["infno"] = "9101" // 交易编码
  1032. inputData["file_name"] = file_name //文件名
  1033. inputData["in"] = bytes.NewBuffer(file_byte).Bytes() //文件数据
  1034. inputData["fixmedins_code"] = baseParams.FixmedinsCode //编码
  1035. input["fsUploadIn"] = inputData
  1036. inputMessage["input"] = input //交易输入
  1037. bytesData, err := json.Marshal(inputMessage)
  1038. fmt.Println(string(bytesData))
  1039. if err != nil {
  1040. fmt.Println(err.Error())
  1041. return err.Error()
  1042. }
  1043. reader := bytes.NewReader(bytesData)
  1044. url := "http://igb.hsa.gdgov.cn/ebus/gdyb_api/prd/hsa/hgs/9101"
  1045. //url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/9101"
  1046. //url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/9101"
  1047. request, err := http.NewRequest("POST", url, reader)
  1048. if err != nil {
  1049. fmt.Println(err.Error())
  1050. return err.Error()
  1051. }
  1052. request.Header.Set("Content-Type", "application/json;charset=UTF-8")
  1053. request.Header.Set("x-tif-paasid", "sg03_prd")
  1054. request.Header.Set("x-tif-signature", signature)
  1055. request.Header.Set("x-tif-timestamp", strconv.FormatInt(timestamp, 10))
  1056. request.Header.Set("x-tif-nonce", nonce)
  1057. client := http.Client{}
  1058. resp, err := client.Do(request)
  1059. if err != nil {
  1060. fmt.Println(err.Error())
  1061. return err.Error()
  1062. }
  1063. respBytes, err := ioutil.ReadAll(resp.Body)
  1064. if err != nil {
  1065. fmt.Println(err.Error())
  1066. return err.Error()
  1067. }
  1068. str := string(respBytes)
  1069. fmt.Println(str)
  1070. return str
  1071. }
  1072. func Gdyb9102(baseParams models.BaseParams, file_name string, file_qury_no string) string {
  1073. // 生成签名
  1074. nonce := GetRandomString(32)
  1075. timestamp := time.Now().Unix()
  1076. signature := setSignature(timestamp, nonce, baseParams.SecretKey)
  1077. inputMessage := SetInputMessage(nonce, timestamp, baseParams.OrgName, baseParams.Doctor, baseParams.FixmedinsCode, baseParams.InsuplcAdmdvs, baseParams.MdtrtareaAdmvs)
  1078. input := make(map[string]interface{})
  1079. inputData := make(map[string]interface{})
  1080. inputMessage["infno"] = "9102" // 交易编码
  1081. inputData["file_name"] = file_name //文件名
  1082. inputData["file_qury_no"] = "fsi/H44022900158/" + file_qury_no //文件数据
  1083. inputData["fixmedins_code"] = baseParams.FixmedinsCode //编码
  1084. input["fsDownloadIn"] = inputData
  1085. inputMessage["input"] = input //交易输入
  1086. bytesData, err := json.Marshal(inputMessage)
  1087. fmt.Println(string(bytesData))
  1088. if err != nil {
  1089. fmt.Println(err.Error())
  1090. return err.Error()
  1091. }
  1092. reader := bytes.NewReader(bytesData)
  1093. url := "http://igb.hsa.gdgov.cn/ebus/gdyb_api/prd/hsa/hgs/9102"
  1094. //url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/9102"
  1095. //url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/9102"
  1096. request, err := http.NewRequest("POST", url, reader)
  1097. if err != nil {
  1098. fmt.Println(err.Error())
  1099. return err.Error()
  1100. }
  1101. request.Header.Set("Content-Type", "application/json;charset=UTF-8")
  1102. request.Header.Set("x-tif-paasid", "sg03_prd")
  1103. request.Header.Set("x-tif-signature", signature)
  1104. request.Header.Set("x-tif-timestamp", strconv.FormatInt(timestamp, 10))
  1105. request.Header.Set("x-tif-nonce", nonce)
  1106. client := http.Client{}
  1107. resp, err := client.Do(request)
  1108. if err != nil {
  1109. fmt.Println(err.Error())
  1110. return err.Error()
  1111. }
  1112. respBytes, err := ioutil.ReadAll(resp.Body)
  1113. if err != nil {
  1114. fmt.Println(err.Error())
  1115. return err.Error()
  1116. }
  1117. str := string(respBytes)
  1118. fmt.Println(str)
  1119. return str
  1120. }
  1121. func Gdyb3202(baseParams models.BaseParams, businessParams models.BusinessParams) string {
  1122. // 生成签名
  1123. nonce := GetRandomString(32)
  1124. timestamp := time.Now().Unix()
  1125. signature := setSignature(timestamp, nonce, baseParams.SecretKey)
  1126. // 生成输入报文
  1127. inputMessage := SetInputMessage(nonce, timestamp, baseParams.OrgName, baseParams.Doctor, baseParams.FixmedinsCode, baseParams.InsuplcAdmdvs, baseParams.MdtrtareaAdmvs)
  1128. input := make(map[string]interface{})
  1129. inputData := make(map[string]interface{})
  1130. inputMessage["infno"] = "3202" // 交易编码
  1131. inputData["file_qury_no"] = "fsi/H44022900158/" + businessParams.FileQuryNo // 险种
  1132. inputData["setl_optins"] = "定点医保中心" // 结算经办机构
  1133. inputData["stmt_begndate"] = businessParams.StmtBegndate // 对帐开始时间
  1134. inputData["stmt_enddate"] = businessParams.StmtEnddate //对帐结束时间
  1135. inputData["medfee_sumamt"] = businessParams.MedfeeSumamt //医疗费总额
  1136. inputData["fund_pay_sumamt"] = businessParams.FundPaySumamt //基金支付总额
  1137. inputData["cash_payamt"] = businessParams.CashPayamt //现金支付金额
  1138. inputData["fixmedins_setl_cnt"] = businessParams.FixmedinsSetlCnt //定点医药机构结算笔数
  1139. input["data"] = inputData
  1140. inputMessage["input"] = input //交易输入
  1141. bytesData, err := json.Marshal(inputMessage)
  1142. fmt.Println(string(bytesData))
  1143. if err != nil {
  1144. fmt.Println(err.Error())
  1145. return err.Error()
  1146. }
  1147. reader := bytes.NewReader(bytesData)
  1148. url := "http://igb.hsa.gdgov.cn/ebus/gdyb_api/prd/hsa/hgs/3202"
  1149. //url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/3202"
  1150. //url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/3202"
  1151. request, err := http.NewRequest("POST", url, reader)
  1152. if err != nil {
  1153. fmt.Println(err.Error())
  1154. return err.Error()
  1155. }
  1156. request.Header.Set("Content-Type", "application/json;charset=UTF-8")
  1157. request.Header.Set("x-tif-paasid", "sg03_prd")
  1158. request.Header.Set("x-tif-signature", signature)
  1159. request.Header.Set("x-tif-timestamp", strconv.FormatInt(timestamp, 10))
  1160. request.Header.Set("x-tif-nonce", nonce)
  1161. client := http.Client{}
  1162. resp, err := client.Do(request)
  1163. if err != nil {
  1164. fmt.Println(err.Error())
  1165. return err.Error()
  1166. }
  1167. respBytes, err := ioutil.ReadAll(resp.Body)
  1168. if err != nil {
  1169. fmt.Println(err.Error())
  1170. return err.Error()
  1171. }
  1172. str := string(respBytes)
  1173. fmt.Println(str)
  1174. return str
  1175. }
  1176. func Gdyb5203(baseParams models.BaseParams, businessParams models.BusinessParams) string {
  1177. // 生成签名
  1178. nonce := GetRandomString(32)
  1179. timestamp := time.Now().Unix()
  1180. signature := setSignature(timestamp, nonce, baseParams.SecretKey)
  1181. // 生成输入报文
  1182. inputMessage := SetInputMessage(nonce, timestamp, baseParams.OrgName, baseParams.Doctor, baseParams.FixmedinsCode, baseParams.InsuplcAdmdvs, baseParams.MdtrtareaAdmvs)
  1183. input := make(map[string]interface{})
  1184. inputData := make(map[string]interface{})
  1185. inputMessage["infno"] = "5203" // 交易编码
  1186. inputData["psn_no"] = businessParams.PsnNo
  1187. inputData["setl_id"] = businessParams.SetlId
  1188. inputData["mdtrt_id"] = businessParams.MdtrtId
  1189. input["data"] = inputData
  1190. inputMessage["input"] = input //交易输入
  1191. bytesData, err := json.Marshal(inputMessage)
  1192. fmt.Println(string(bytesData))
  1193. if err != nil {
  1194. fmt.Println(err.Error())
  1195. return err.Error()
  1196. }
  1197. reader := bytes.NewReader(bytesData)
  1198. url := "http://igb.hsa.gdgov.cn/ebus/gdyb_api/prd/hsa/hgs/5203"
  1199. //url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/5203"
  1200. //url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/5203"
  1201. request, err := http.NewRequest("POST", url, reader)
  1202. if err != nil {
  1203. fmt.Println(err.Error())
  1204. return err.Error()
  1205. }
  1206. request.Header.Set("Content-Type", "application/json;charset=UTF-8")
  1207. request.Header.Set("x-tif-paasid", "sg03_prd")
  1208. request.Header.Set("x-tif-signature", signature)
  1209. request.Header.Set("x-tif-timestamp", strconv.FormatInt(timestamp, 10))
  1210. request.Header.Set("x-tif-nonce", nonce)
  1211. client := http.Client{}
  1212. resp, err := client.Do(request)
  1213. if err != nil {
  1214. fmt.Println(err.Error())
  1215. return err.Error()
  1216. }
  1217. respBytes, err := ioutil.ReadAll(resp.Body)
  1218. if err != nil {
  1219. fmt.Println(err.Error())
  1220. return err.Error()
  1221. }
  1222. str := string(respBytes)
  1223. fmt.Println(str)
  1224. return str
  1225. }
  1226. func Gdyb2001(baseParams models.BaseParams, psn_no string, insutype string, med_type string) string {
  1227. // 生成签名
  1228. nonce := GetRandomString(32)
  1229. timestamp := time.Now().Unix()
  1230. signature := setSignature(timestamp, nonce, baseParams.SecretKey)
  1231. // 生成输入报文
  1232. inputMessage := SetInputMessage(nonce, timestamp, baseParams.OrgName, baseParams.Doctor, baseParams.FixmedinsCode, baseParams.InsuplcAdmdvs, baseParams.MdtrtareaAdmvs)
  1233. input := make(map[string]interface{})
  1234. inputData := make(map[string]interface{})
  1235. inputMessage["infno"] = "2001" // 交易编码
  1236. inputData["psn_no"] = psn_no
  1237. inputData["insutype"] = insutype
  1238. inputData["med_type"] = med_type
  1239. inputData["begntime"] = "2021-01-01 00:00:00"
  1240. input["data"] = inputData
  1241. inputMessage["input"] = input //交易输入
  1242. bytesData, err := json.Marshal(inputMessage)
  1243. fmt.Println(string(bytesData))
  1244. if err != nil {
  1245. fmt.Println(err.Error())
  1246. return err.Error()
  1247. }
  1248. reader := bytes.NewReader(bytesData)
  1249. url := "http://igb.hsa.gdgov.cn/ebus/gdyb_api/prd/hsa/hgs/3301"
  1250. //url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/5203"
  1251. request, err := http.NewRequest("POST", url, reader)
  1252. if err != nil {
  1253. fmt.Println(err.Error())
  1254. return err.Error()
  1255. }
  1256. request.Header.Set("Content-Type", "application/json;charset=UTF-8")
  1257. request.Header.Set("x-tif-paasid", "sg03_prd")
  1258. request.Header.Set("x-tif-signature", signature)
  1259. request.Header.Set("x-tif-timestamp", strconv.FormatInt(timestamp, 10))
  1260. request.Header.Set("x-tif-nonce", nonce)
  1261. client := http.Client{}
  1262. resp, err := client.Do(request)
  1263. if err != nil {
  1264. fmt.Println(err.Error())
  1265. return err.Error()
  1266. }
  1267. respBytes, err := ioutil.ReadAll(resp.Body)
  1268. if err != nil {
  1269. fmt.Println(err.Error())
  1270. return err.Error()
  1271. }
  1272. str := string(respBytes)
  1273. fmt.Println(str)
  1274. return str
  1275. }
  1276. func Gdyb3301(baseParams *models.BaseParams, name string, codg string, list_type_code string, start_time string, ent_time string) string {
  1277. // 生成签名
  1278. nonce := GetRandomString(32)
  1279. timestamp := time.Now().Unix()
  1280. signature := setSignature(timestamp, nonce, baseParams.SecretKey)
  1281. // 生成输入报文
  1282. inputMessage := SetInputMessage(nonce, timestamp, baseParams.OrgName, baseParams.Doctor, baseParams.FixmedinsCode, baseParams.InsuplcAdmdvs, baseParams.MdtrtareaAdmvs)
  1283. input := make(map[string]interface{})
  1284. inputData := make(map[string]interface{})
  1285. inputMessage["infno"] = "3301" // 交易编码
  1286. inputData["fixmedins_hilist_id"] = codg
  1287. inputData["fixmedins_hilist_name"] = name
  1288. inputData["list_type"] = list_type_code
  1289. inputData["med_list_codg"] = codg
  1290. inputData["begndate"] = start_time
  1291. inputData["enddate"] = ent_time
  1292. inputData["aprvno"] = ""
  1293. inputData["dosform"] = ""
  1294. inputData["exct_cont"] = ""
  1295. inputData["item_cont"] = ""
  1296. inputData["prcunt"] = ""
  1297. inputData["spec"] = ""
  1298. inputData["pacspec"] = ""
  1299. inputData["memo"] = ""
  1300. input["catalogcompin"] = inputData
  1301. inputMessage["input"] = input //交易输入
  1302. bytesData, err := json.Marshal(inputMessage)
  1303. fmt.Println(string(bytesData))
  1304. if err != nil {
  1305. fmt.Println(err.Error())
  1306. return err.Error()
  1307. }
  1308. reader := bytes.NewReader(bytesData)
  1309. //url := "http://igb.hsa.gdgov.cn/ebus/gdyb_api/prd/hsa/hgs/3301"
  1310. //
  1311. url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/3301"
  1312. request, err := http.NewRequest("POST", url, reader)
  1313. if err != nil {
  1314. fmt.Println(err.Error())
  1315. return err.Error()
  1316. }
  1317. request.Header.Set("Content-Type", "application/json;charset=UTF-8")
  1318. request.Header.Set("x-tif-paasid", "test_hosp")
  1319. request.Header.Set("x-tif-signature", signature)
  1320. request.Header.Set("x-tif-timestamp", strconv.FormatInt(timestamp, 10))
  1321. request.Header.Set("x-tif-nonce", nonce)
  1322. client := http.Client{}
  1323. resp, err := client.Do(request)
  1324. if err != nil {
  1325. fmt.Println(err.Error())
  1326. return err.Error()
  1327. }
  1328. respBytes, err := ioutil.ReadAll(resp.Body)
  1329. if err != nil {
  1330. fmt.Println(err.Error())
  1331. return err.Error()
  1332. }
  1333. str := string(respBytes)
  1334. fmt.Println(str)
  1335. return str
  1336. }
  1337. func Gdyb3302(baseParams *models.BaseParams, name string, codg string, list_type_code string) string {
  1338. // 生成签名
  1339. nonce := GetRandomString(32)
  1340. timestamp := time.Now().Unix()
  1341. signature := setSignature(timestamp, nonce, baseParams.SecretKey)
  1342. // 生成输入报文
  1343. inputMessage := SetInputMessage(nonce, timestamp, baseParams.OrgName, baseParams.Doctor, baseParams.FixmedinsCode, baseParams.InsuplcAdmdvs, baseParams.MdtrtareaAdmvs)
  1344. input := make(map[string]interface{})
  1345. inputData := make(map[string]interface{})
  1346. inputMessage["infno"] = "3302" // 交易编码
  1347. inputData["fixmedins_hilist_id"] = codg
  1348. inputData["fixmedins_hilist_name"] = name
  1349. inputData["list_type"] = list_type_code
  1350. inputData["med_list_codg"] = codg
  1351. inputData["begndate"] = "2021-01-01"
  1352. inputData["enddate"] = "2099-01-07"
  1353. input["catalogcompin"] = inputData
  1354. inputMessage["input"] = input //交易输入
  1355. bytesData, err := json.Marshal(inputMessage)
  1356. fmt.Println(string(bytesData))
  1357. if err != nil {
  1358. fmt.Println(err.Error())
  1359. return err.Error()
  1360. }
  1361. reader := bytes.NewReader(bytesData)
  1362. //url := "http://igb.hsa.gdgov.cn/ebus/gdyb_api/prd/hsa/hgs/3302"
  1363. url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/3302"
  1364. request, err := http.NewRequest("POST", url, reader)
  1365. if err != nil {
  1366. fmt.Println(err.Error())
  1367. return err.Error()
  1368. }
  1369. request.Header.Set("Content-Type", "application/json;charset=UTF-8")
  1370. request.Header.Set("x-tif-paasid", "test_hosp")
  1371. request.Header.Set("x-tif-signature", signature)
  1372. request.Header.Set("x-tif-timestamp", strconv.FormatInt(timestamp, 10))
  1373. request.Header.Set("x-tif-nonce", nonce)
  1374. client := http.Client{}
  1375. resp, err := client.Do(request)
  1376. if err != nil {
  1377. fmt.Println(err.Error())
  1378. return err.Error()
  1379. }
  1380. respBytes, err := ioutil.ReadAll(resp.Body)
  1381. if err != nil {
  1382. fmt.Println(err.Error())
  1383. return err.Error()
  1384. }
  1385. str := string(respBytes)
  1386. fmt.Println(str)
  1387. return str
  1388. }
  1389. func Gdyb2505(psnNo string, doctor string, org_name string, fixmedins_code string, insuplc_admdvs string, mdtrtarea_admvs string, secret_key string, start_time string, end_time string) string {
  1390. // 生成签名
  1391. nonce := GetRandomString(32)
  1392. timestamp := time.Now().Unix()
  1393. signature := setSignature(timestamp, nonce, secret_key)
  1394. // 生成输入报文
  1395. inputMessage := SetInputMessage(nonce, timestamp, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs)
  1396. input := make(map[string]interface{})
  1397. inputData := make(map[string]interface{})
  1398. inputMessage["infno"] = "2505"
  1399. inputData["psn_no"] = psnNo
  1400. inputData["biz_appy_type"] = "03"
  1401. inputData["begndate"] = start_time
  1402. inputData["enddate"] = end_time
  1403. inputData["fixmedins_code"] = fixmedins_code
  1404. inputData["fixmedins_name"] = org_name
  1405. inputData["tel"] = ""
  1406. inputData["addr"] = ""
  1407. inputData["agnter_name"] = ""
  1408. inputData["agnter_cert_type"] = ""
  1409. inputData["agnter_certno"] = ""
  1410. inputData["agnter_tel"] = ""
  1411. inputData["agnter_addr"] = ""
  1412. inputData["agnter_rlts"] = ""
  1413. inputData["fix_srt_no"] = ""
  1414. inputData["memo"] = ""
  1415. input["data"] = inputData
  1416. inputMessage["input"] = input //交易输入
  1417. bytesData, err := json.Marshal(inputMessage)
  1418. if err != nil {
  1419. fmt.Println(err.Error())
  1420. return err.Error()
  1421. }
  1422. reader := bytes.NewReader(bytesData)
  1423. //url := "http://igb.hsa.gdgov.cn/ebus/gdyb_api/prd/hsa/hgs/2505"
  1424. url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/2505"
  1425. request, err := http.NewRequest("POST", url, reader)
  1426. if err != nil {
  1427. fmt.Println(err.Error())
  1428. return err.Error()
  1429. }
  1430. request.Header.Set("Content-Type", "application/json;charset=UTF-8")
  1431. request.Header.Set("x-tif-paasid", "test_hosp")
  1432. request.Header.Set("x-tif-signature", signature)
  1433. request.Header.Set("x-tif-timestamp", strconv.FormatInt(timestamp, 10))
  1434. request.Header.Set("x-tif-nonce", nonce)
  1435. client := http.Client{}
  1436. resp, err := client.Do(request)
  1437. if err != nil {
  1438. fmt.Println(err.Error())
  1439. return err.Error()
  1440. }
  1441. respBytes, err := ioutil.ReadAll(resp.Body)
  1442. if err != nil {
  1443. fmt.Println(err.Error())
  1444. return err.Error()
  1445. }
  1446. str := string(respBytes)
  1447. fmt.Println(str)
  1448. return str
  1449. }
  1450. func Gdyb2506(psnNo string, doctor string, org_name string, fixmedins_code string, insuplc_admdvs string, mdtrtarea_admvs string, secret_key string, trt_dcla_detl_sn string) string {
  1451. // 生成签名
  1452. nonce := GetRandomString(32)
  1453. timestamp := time.Now().Unix()
  1454. signature := setSignature(timestamp, nonce, secret_key)
  1455. // 生成输入报文
  1456. inputMessage := SetInputMessage(nonce, timestamp, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs)
  1457. input := make(map[string]interface{})
  1458. inputData := make(map[string]interface{})
  1459. inputMessage["infno"] = "2506"
  1460. inputData["psn_no"] = psnNo
  1461. inputData["trt_dcla_detl_sn"] = trt_dcla_detl_sn
  1462. inputData["memo"] = ""
  1463. input["data"] = inputData
  1464. inputMessage["input"] = input //交易输入
  1465. bytesData, err := json.Marshal(inputMessage)
  1466. fmt.Println(string(bytesData))
  1467. if err != nil {
  1468. fmt.Println(err.Error())
  1469. return err.Error()
  1470. }
  1471. reader := bytes.NewReader(bytesData)
  1472. //url := "http://igb.hsa.gdgov.cn/ebus/gdyb_api/prd/hsa/hgs/2506"
  1473. url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/2506"
  1474. //url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/2203"
  1475. request, err := http.NewRequest("POST", url, reader)
  1476. if err != nil {
  1477. fmt.Println(err.Error())
  1478. return err.Error()
  1479. }
  1480. request.Header.Set("Content-Type", "application/json;charset=UTF-8")
  1481. request.Header.Set("x-tif-paasid", "test_hosp")
  1482. request.Header.Set("x-tif-signature", signature)
  1483. request.Header.Set("x-tif-timestamp", strconv.FormatInt(timestamp, 10))
  1484. request.Header.Set("x-tif-nonce", nonce)
  1485. client := http.Client{}
  1486. resp, err := client.Do(request)
  1487. if err != nil {
  1488. fmt.Println(err.Error())
  1489. return err.Error()
  1490. }
  1491. respBytes, err := ioutil.ReadAll(resp.Body)
  1492. if err != nil {
  1493. fmt.Println(err.Error())
  1494. return err.Error()
  1495. }
  1496. str := string(respBytes)
  1497. fmt.Println(str)
  1498. return str
  1499. }
  1500. func Gdyb2503(psnNo string, insutype string, org_name string, doctor string, fixmedins_code string, doctor_id string, insuplc_admdvs string, mdtrtarea_admvs string, secret_key string, sick_name string, sick_code string) string {
  1501. // 生成签名
  1502. nonce := GetRandomString(32)
  1503. timestamp := time.Now().Unix()
  1504. signature := setSignature(timestamp, nonce, secret_key)
  1505. tempTime := time.Unix(timestamp, 0)
  1506. //timeFormatOne := tempTime.Format("2006-01-02 15:04:05")
  1507. timeFormatTwo := tempTime.Format("2006-01-02")
  1508. // 生成输入报文
  1509. inputMessage := SetInputMessage(nonce, timestamp, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs)
  1510. input := make(map[string]interface{})
  1511. inputData := make(map[string]interface{})
  1512. inputMessage["infno"] = "2503" // 交易编码
  1513. inputData["psn_no"] = psnNo // 人员编号 (来自1101接口返回)
  1514. inputData["insutype"] = insutype // 险种类型(来自1101接口返回)
  1515. inputData["opsp_dise_code"] = sick_code // 险种类型(来自1101接口返回)
  1516. inputData["opsp_dise_name"] = sick_name // 险种类型(来自1101接口返回)
  1517. inputData["insu_optins"] = insuplc_admdvs // 险种类型(来自1101接口返回)
  1518. inputData["ide_fixmedins_no"] = fixmedins_code // 险种类型(来自1101接口返回)
  1519. inputData["ide_fixmedins_name"] = org_name // 险种类型(来自1101接口返回)
  1520. inputData["hosp_ide_date"] = timeFormatTwo // 险种类型(来自1101接口返回)
  1521. inputData["diag_dr_codg"] = doctor_id // 开始时间
  1522. inputData["diag_dr_name"] = doctor // 开始时间
  1523. inputData["begndate"] = timeFormatTwo // 医师编码
  1524. inputData["tel"] = "" // 医师编码
  1525. inputData["addr"] = "" // 医师编码
  1526. inputData["enddate"] = "" // 医师编码
  1527. input["data"] = inputData
  1528. inputMessage["input"] = input //交易输入
  1529. bytesData, err := json.Marshal(inputMessage)
  1530. fmt.Println(string(bytesData))
  1531. if err != nil {
  1532. fmt.Println(err.Error())
  1533. return err.Error()
  1534. }
  1535. reader := bytes.NewReader(bytesData)
  1536. //url := "http://igb.hsa.gdgov.cn/ebus/gdyb_api/prd/hsa/hgs/2503"
  1537. url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/2503"
  1538. request, err := http.NewRequest("POST", url, reader)
  1539. if err != nil {
  1540. fmt.Println(err.Error())
  1541. return err.Error()
  1542. }
  1543. request.Header.Set("Content-Type", "application/json;charset=UTF-8")
  1544. request.Header.Set("x-tif-paasid", "test_hosp")
  1545. request.Header.Set("x-tif-signature", signature)
  1546. request.Header.Set("x-tif-timestamp", strconv.FormatInt(timestamp, 10))
  1547. request.Header.Set("x-tif-nonce", nonce)
  1548. client := http.Client{}
  1549. resp, err := client.Do(request)
  1550. if err != nil {
  1551. fmt.Println(err.Error())
  1552. return err.Error()
  1553. }
  1554. respBytes, err := ioutil.ReadAll(resp.Body)
  1555. if err != nil {
  1556. fmt.Println(err.Error())
  1557. return err.Error()
  1558. }
  1559. str := string(respBytes)
  1560. fmt.Println(str)
  1561. return str
  1562. }
  1563. func Gdyb2504(psnNo string, org_name string, doctor string, fixmedins_code string, insuplc_admdvs string, mdtrtarea_admvs string, secret_key string, trt_dcla_detl_sn string) string {
  1564. // 生成签名
  1565. nonce := GetRandomString(32)
  1566. timestamp := time.Now().Unix()
  1567. signature := setSignature(timestamp, nonce, secret_key)
  1568. // 生成输入报文
  1569. inputMessage := SetInputMessage(nonce, timestamp, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs)
  1570. input := make(map[string]interface{})
  1571. inputData := make(map[string]interface{})
  1572. inputMessage["infno"] = "2504" // 交易编码
  1573. inputData["psn_no"] = psnNo // 人员编号 (来自1101接口返回)
  1574. inputData["trt_dcla_detl_sn"] = trt_dcla_detl_sn // 人员编号 (来自1101接口返回)
  1575. input["data"] = inputData
  1576. inputMessage["input"] = input //交易输入
  1577. bytesData, err := json.Marshal(inputMessage)
  1578. fmt.Println(string(bytesData))
  1579. if err != nil {
  1580. fmt.Println(err.Error())
  1581. return err.Error()
  1582. }
  1583. reader := bytes.NewReader(bytesData)
  1584. //url := "http://igb.hsa.gdgov.cn/ebus/gdyb_api/prd/hsa/hgs/2504"
  1585. url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/2504"
  1586. request, err := http.NewRequest("POST", url, reader)
  1587. if err != nil {
  1588. fmt.Println(err.Error())
  1589. return err.Error()
  1590. }
  1591. request.Header.Set("Content-Type", "application/json;charset=UTF-8")
  1592. request.Header.Set("x-tif-paasid", "test_hosp")
  1593. request.Header.Set("x-tif-signature", signature)
  1594. request.Header.Set("x-tif-timestamp", strconv.FormatInt(timestamp, 10))
  1595. request.Header.Set("x-tif-nonce", nonce)
  1596. client := http.Client{}
  1597. resp, err := client.Do(request)
  1598. if err != nil {
  1599. fmt.Println(err.Error())
  1600. return err.Error()
  1601. }
  1602. respBytes, err := ioutil.ReadAll(resp.Body)
  1603. if err != nil {
  1604. fmt.Println(err.Error())
  1605. return err.Error()
  1606. }
  1607. str := string(respBytes)
  1608. fmt.Println(str)
  1609. return str
  1610. }
  1611. //func Gdyb2503(psnNo string, doctor string, department string, diag string, org_name string, med_type string, doctor_id int64, fixmedins_code string, diag_code string, insuplc_admdvs string, mdtrtarea_admvs string, secret_key string, sick_code string, sick_name string) string {
  1612. // // 生成签名
  1613. // nonce := GetRandomString(32)
  1614. // timestamp := time.Now().Unix()
  1615. // signature := setSignature(timestamp, nonce, secret_key)
  1616. // tempTime := time.Unix(timestamp, 0)
  1617. // timeFormatOne := tempTime.Format("2006-01-02 15:04:05")
  1618. //
  1619. // // 生成输入报文
  1620. // inputMessage := SetInputMessage(nonce, timestamp, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs)
  1621. // input := make(map[string]interface{})
  1622. // inputData := make(map[string]interface{})
  1623. // diseinfo := make([]map[string]interface{}, 0)
  1624. //
  1625. // inputMessage["infno"] = "2203" // 交易编码
  1626. // inputData["mdtrt_id"] = mdtrtId // 就诊 ID(来自2201接口返回)
  1627. // inputData["psn_no"] = psnNo // 人员编号 (来自1101接口返回)
  1628. // inputData["med_type"] = med_type // 医疗类别 16门诊特殊病
  1629. // inputData["begntime"] = timeFormatOne // 开始时间
  1630. // inputData["main_cond_dscr"] = "" // 主要病情描述
  1631. // inputData["dise_codg"] = sick_code // 病种编码
  1632. // inputData["dise_name"] = sick_name // 病种名称
  1633. // inputData["birctrl_type"] = "" // 计划生育手术类别
  1634. // inputData["birctrl_matn_date"] = "" // 计划生育手术或生育日期
  1635. //
  1636. // diseinfo_sun := make(map[string]interface{})
  1637. // diseinfo_sun["diag_type"] = "1" // 诊断类别
  1638. // diseinfo_sun["diag_srt_no"] = "1" // 诊断排序号
  1639. // diseinfo_sun["diag_code"] = diag_code // 诊断代码
  1640. // diseinfo_sun["diag_name"] = diag // 诊断名称
  1641. // diseinfo_sun["diag_dept"] = department // 诊断科室
  1642. // diseinfo_sun["dise_dor_no"] = doctor_id // 诊断医生编码
  1643. // diseinfo_sun["dise_dor_name"] = doctor // 诊断医生姓名
  1644. // diseinfo_sun["diag_time"] = timeFormatOne // 诊断时间
  1645. // diseinfo_sun["vali_flag"] = "1" // 有效标志
  1646. //
  1647. // diseinfo = append(diseinfo, diseinfo_sun)
  1648. // input["diseinfo"] = diseinfo
  1649. // input["mdtrtinfo"] = inputData
  1650. // inputMessage["input"] = input //交易输入
  1651. //
  1652. // bytesData, err := json.Marshal(inputMessage)
  1653. // fmt.Println(string(bytesData))
  1654. // if err != nil {
  1655. // fmt.Println(err.Error())
  1656. // return err.Error()
  1657. // }
  1658. // reader := bytes.NewReader(bytesData)
  1659. //
  1660. // url := "http://igb.hsa.gdgov.cn/ebus/gdyb_api/prd/hsa/hgs/2203"
  1661. //
  1662. // //url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/2203"
  1663. // request, err := http.NewRequest("POST", url, reader)
  1664. // if err != nil {
  1665. // fmt.Println(err.Error())
  1666. // return err.Error()
  1667. // }
  1668. //
  1669. // request.Header.Set("Content-Type", "application/json;charset=UTF-8")
  1670. // request.Header.Set("x-tif-paasid", "sg03_prd")
  1671. // request.Header.Set("x-tif-signature", signature)
  1672. // request.Header.Set("x-tif-timestamp", strconv.FormatInt(timestamp, 10))
  1673. // request.Header.Set("x-tif-nonce", nonce)
  1674. //
  1675. // client := http.Client{}
  1676. // resp, err := client.Do(request)
  1677. // if err != nil {
  1678. // fmt.Println(err.Error())
  1679. // return err.Error()
  1680. // }
  1681. // respBytes, err := ioutil.ReadAll(resp.Body)
  1682. // if err != nil {
  1683. // fmt.Println(err.Error())
  1684. // return err.Error()
  1685. // }
  1686. // str := string(respBytes)
  1687. // fmt.Println(str)
  1688. // return str
  1689. //}
  1690. func Gdyb5301(psnNo string, insutype string, org_name string, doctor string, fixmedins_code string, doctor_id string, insuplc_admdvs string, mdtrtarea_admvs string, secret_key string, sick_name string, sick_code string) string {
  1691. // 生成签名
  1692. nonce := GetRandomString(32)
  1693. timestamp := time.Now().Unix()
  1694. signature := setSignature(timestamp, nonce, secret_key)
  1695. //tempTime := time.Unix(timestamp, 0)
  1696. //timeFormatOne := tempTime.Format("2006-01-02 15:04:05")
  1697. //timeFormatTwo := tempTime.Format("2006-01-02")
  1698. // 生成输入报文
  1699. inputMessage := SetInputMessage(nonce, timestamp, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs)
  1700. input := make(map[string]interface{})
  1701. inputData := make(map[string]interface{})
  1702. inputMessage["infno"] = "5301" // 交易编码
  1703. inputData["psn_no"] = psnNo // 人员编号 (来自1101接口返回)
  1704. input["data"] = inputData
  1705. inputMessage["input"] = input //交易输入
  1706. bytesData, err := json.Marshal(inputMessage)
  1707. fmt.Println(string(bytesData))
  1708. if err != nil {
  1709. fmt.Println(err.Error())
  1710. return err.Error()
  1711. }
  1712. reader := bytes.NewReader(bytesData)
  1713. url := "http://igb.hsa.gdgov.cn/ebus/gdyb_api/prd/hsa/hgs/5301"
  1714. request, err := http.NewRequest("POST", url, reader)
  1715. if err != nil {
  1716. fmt.Println(err.Error())
  1717. return err.Error()
  1718. }
  1719. request.Header.Set("Content-Type", "application/json;charset=UTF-8")
  1720. request.Header.Set("x-tif-paasid", "test_hosp")
  1721. request.Header.Set("x-tif-signature", signature)
  1722. request.Header.Set("x-tif-timestamp", strconv.FormatInt(timestamp, 10))
  1723. request.Header.Set("x-tif-nonce", nonce)
  1724. client := http.Client{}
  1725. resp, err := client.Do(request)
  1726. if err != nil {
  1727. fmt.Println(err.Error())
  1728. return err.Error()
  1729. }
  1730. respBytes, err := ioutil.ReadAll(resp.Body)
  1731. if err != nil {
  1732. fmt.Println(err.Error())
  1733. return err.Error()
  1734. }
  1735. str := string(respBytes)
  1736. fmt.Println(str)
  1737. return str
  1738. }
  1739. // 门诊结算撤销
  1740. //func Gdyb4101(psnNo string, mdtrtId string, setlId string) string {
  1741. // // 生成签名
  1742. // nonce := GetRandomString(32)
  1743. // timestamp := time.Now().Unix()
  1744. // signature := setSignature(timestamp, nonce)
  1745. //
  1746. // // 生成输入报文
  1747. // inputMessage := SetInputMessage(nonce, timestamp)
  1748. // input := make(map[string]interface{})
  1749. // inputData := make(map[string]interface{})
  1750. // inputMessage["infno"] = "4101" // 交易编码
  1751. //
  1752. // inputData["mdtrt_id"] = mdtrtId // 就诊 ID 必填(来自2201接口返回)
  1753. // inputData["setl_id"] = setlId // 结算 ID 必填
  1754. // inputData["fixmedins_name"] = "" // 定点医药机构名称 必填
  1755. // inputData["fixmedins_code"] = "" // 定点医药机构编码 必填
  1756. // inputData["hi_setl_lv"] = "" // 医保结算等级
  1757. // inputData["hi_no"] = "" // 医保编号
  1758. // inputData["medcasno"] = "" // 病案号 必填
  1759. // inputData["dcla_time"] = "" // 申报时间 必填
  1760. // inputData["psn_name"] = "" // 人员姓名 必填
  1761. // inputData["gend"] = "" // 性别 必填
  1762. // inputData["brdy"] = "" // 出生日期 必填
  1763. // inputData["age"] = "" // 年龄 必填
  1764. // inputData["ntly"] = "" // 国籍 必填
  1765. // inputData["nwb_age"] = "" // 年龄 必填
  1766. // inputData["naty"] = "" // 民族 必填
  1767. // inputData["patn_cert_type"] = "" // 患者证件类别 必填
  1768. // inputData["certno"] = "" // 证件号码 必填
  1769. // inputData["prfs"] = "" // 职业 必填
  1770. // inputData["curr_addr"] = "" // 现住址 必填
  1771. // inputData["emp_name"] = "" // 单位名称 必填
  1772. // inputData["emp_addr"] = "" // 单位地址 必填
  1773. // inputData["emp_tel"] = "" // 单位电话 必填
  1774. // inputData["poscode"] = "" // 邮编 必填
  1775. // inputData["coner_name"] = "" // 联系人姓名 必填
  1776. // inputData["patn_rlts"] = "" // 与患者关系 必填
  1777. // inputData["coner_addr"] = "" // 联系人地址 必填
  1778. // inputData["coner_tel"] = "" // 联系人电话 必填
  1779. // inputData["hi_type"] = "" // 医保类型 必填
  1780. // inputData["insuplc"] = "" // 参保地 必填
  1781. // inputData["sp_psn_type"] = "" // 特殊人员类型 必填
  1782. // inputData["nwb_adm_type"] = "" // 新生儿入院类型 必填
  1783. // inputData["nwb_bir_wt"] = "" // 新生儿出生体重 必填
  1784. // inputData["nwb_adm_wt"] = "" // 新生儿入院体重 必填
  1785. // inputData["opsp_diag_caty"] = "" // 门诊慢特病诊断 必填
  1786. // inputData["opsp_mdtrt_date"] = "" // 门诊慢特病就诊日期 必填
  1787. // inputData["ipt_med_type"] = "" // 住院医疗类型 必填
  1788. // inputData["adm_way"] = "" // 入院途径 必填
  1789. // inputData["trt_type"] = "" // 治疗类别 必填
  1790. // inputData["adm_time"] = "" // 入院时间 必填
  1791. // inputData["adm_caty"] = "" // 入院科别 必填
  1792. // inputData["refldept_dept"] = "" // 转科科别 必填
  1793. // inputData["dscg_time"] = "" // 出院时间 必填
  1794. // inputData["dscg_caty"] = "" // 出院科别 必填
  1795. // inputData["act_ipt_days"] = "" // 实际住院天数 必填
  1796. // inputData["otp_wm_dise"] = "" // 门(急) 诊西医诊断 必填
  1797. // inputData["wm_dise_code"] = "" // 门(急) 诊中医诊断 必填
  1798. // inputData["otp_tcm_dise"] = "" // 西医诊断疾病代码 必填
  1799. // inputData["tcm_dise_code"] = "" // 中医诊断代码 必填
  1800. // inputData["oprn_oprt_code_cnt"] = "" // 手术操作代码计数 必填
  1801. // inputData["vent_used_dura"] = "" // 呼吸机使用时长 必填
  1802. // inputData["pwcry_bfadm_coma_dura"] = "" // 颅脑损伤患者入院前昏迷时长 必填
  1803. // inputData["pwcry_afadm_coma_dura"] = "" // 颅脑损伤患者入院后昏迷时长 必填
  1804. // inputData["bld_cat"] = "" // 输血品种 必填
  1805. // inputData["bld_amt"] = "" // 输血量 必填
  1806. // inputData["bld_unt"] = "" // 输血计量单位 必填
  1807. // inputData["spga_nurscare_days"] = "" // 特级护理天数 必填
  1808. // inputData["lv1_nurscare_days"] = "" // 一级护理天数 必填
  1809. // inputData["scd_nurscare_days"] = "" // 二级护理天数 必填
  1810. // inputData["lv3_nurscare_days"] = "" // 三级护理天数 必填
  1811. // inputData["acp_medins_name"] = "" // 拟接收机构名称 必填
  1812. // inputData["acp_optins_code"] = "" // 拟接收机构代码 必填
  1813. // inputData["bill_code"] = "" // 票据代码 必填
  1814. // inputData["bill_no"] = "" // 票据号码 必填
  1815. // inputData["biz_sn"] = "" // 业务流水号 必填
  1816. // inputData["days_rinp_flag_31"] = "" // 出院 31 天内再住院计划标志 必填
  1817. // inputData["days_rinp_pup_31"] = "" // 出院 31 天内再住院目的 必填
  1818. // inputData["chfpdr_name"] = "" // 主诊医师姓名 必填
  1819. // inputData["chfpdr_code"] = "" // 主诊医师代码 必填
  1820. // inputData["setl_begn_date"] = "" // 结算开始日期 必填
  1821. // inputData["setl_end_date"] = "" // 结算结束日期 必填
  1822. // inputData["psn_selfpay"] = "" // 个人自付 必填
  1823. // inputData["psn_ownpay"] = "" // 个人自费 必填
  1824. // inputData["acct_pay"] = "" // 个人账户支出 必填
  1825. // inputData["hi_paymtd"] = "" // 医保支付方式 必填
  1826. // inputData["hsorg"] = "" // 医保机构 必填
  1827. // inputData["hsorg_opter"] = "" // 医保机构经办人 必填
  1828. // inputData["medins_fill_dept"] = "" // 医疗机构填报部门 必填
  1829. // inputData["medins_fill_psn"] = "" // 医疗机构填报人 必填
  1830. //
  1831. // payinfo := make([]map[string]interface{},0) // 基金支付信息
  1832. // payinfotemp := make(map[string]interface{})
  1833. // payinfotemp["fund_pay_type"] = "" // 基金支付类型 必填
  1834. // payinfotemp["fund_payamt"] = "" // 基金支付金额
  1835. // payinfo = append(payinfo,payinfotemp)
  1836. //
  1837. // opspdiseinfo := make([]map[string]interface{},0) // 门诊慢特病诊断信息
  1838. // opspdiseinfotemp := make(map[string]interface{})
  1839. // opspdiseinfotemp["diag_name"] = "" // 诊断名称 必填
  1840. // opspdiseinfotemp["diag_code"] = "" // 诊断代码 必填
  1841. // opspdiseinfotemp["oprn_oprt_name"] = "" // 手术操作名称 必填
  1842. // opspdiseinfotemp["oprn_oprt_code"] = "" // 手术操作代码 必填
  1843. // opspdiseinfo = append(opspdiseinfo,opspdiseinfotemp)
  1844. //
  1845. // diseinfo := make([]map[string]interface{},0) // 住院诊断信息
  1846. // diseinfotemp := make(map[string]interface{})
  1847. // diseinfotemp["diag_type"] = "" // 诊断类别 必填
  1848. // diseinfotemp["diag_code"] = "" // 诊断代码 必填
  1849. // diseinfotemp["diag_name"] = "" // 诊断名称 必填
  1850. // diseinfotemp["adm_cond_type"] = "" // 入院病情类型 必填
  1851. // diseinfo = append(diseinfo,diseinfotemp)
  1852. //
  1853. // iteminfo := make([]map[string]interface{},0) // 住院诊断信息
  1854. // iteminfotemp := make(map[string]interface{})
  1855. // iteminfotemp["med_chrgitm"] = "" // 医疗收费项目 必填
  1856. // iteminfotemp["amt"] = "" // 金额 必填
  1857. // iteminfotemp["claa_sumfee"] = "" // 甲类费用合计 必填
  1858. // iteminfotemp["clab_amt"] = "" // 乙类金额 必填
  1859. // iteminfotemp["fulamt_ownpay_amt"] = "" // 全自费金额 必填
  1860. // iteminfotemp["oth_amt"] = "" // 其他金额 必填
  1861. // iteminfo = append(iteminfo,iteminfotemp)
  1862. //
  1863. // oprninfo := make([]map[string]interface{},0) // 手术操作信息
  1864. // oprninfotemp := make(map[string]interface{})
  1865. // oprninfotemp["oprn_oprt_type"] = "" // 手术操作类别 必填
  1866. // oprninfotemp["oprn_oprt_name"] = "" // 手术操作名称 必填
  1867. // oprninfotemp["oprn_oprt_code"] = "" // 手术操作代码 必填
  1868. // oprninfotemp["oprn_oprt_date"] = "" // 手术操作日期 必填
  1869. // oprninfotemp["anst_way"] = "" // 麻醉方式 必填
  1870. // oprninfotemp["oper_dr_name"] = "" // 术者医师姓名 必填
  1871. // oprninfotemp["oper_dr_code"] = "" // 术者医师代码 必填
  1872. // oprninfotemp["anst_dr_name"] = "" // 麻醉医师姓名 必填
  1873. // oprninfotemp["anst_dr_code"] = "" // 麻醉医师代码 必填
  1874. // oprninfo = append(oprninfo,iteminfotemp)
  1875. //
  1876. // icuinfo := make([]map[string]interface{},0) // 重症监护信息
  1877. // icuinfotemp := make(map[string]interface{})
  1878. // icuinfotemp["scs_cutd_ward_type"] = "" // 重症监护病房类型 必填
  1879. // icuinfotemp["scs_cutd_inpool_time"] = "" // 重症监护进入时间 必填
  1880. // icuinfotemp["scs_cutd_exit_time"] = "" // 重症监护退出时间 必填
  1881. // icuinfotemp["scs_cutd_sum_dura"] = "" // 重症监护合计时长 必填
  1882. // icuinfo = append(icuinfo,iteminfotemp)
  1883. //
  1884. //
  1885. //
  1886. //
  1887. // input["setlinfo"] = inputData
  1888. // input["payinfo"] = payinfo
  1889. // input["opspdiseinfo"] = opspdiseinfo
  1890. // input["diseinfo"] = diseinfo
  1891. // input["iteminfo"] = iteminfo
  1892. // input["oprninfo"] = oprninfo
  1893. // input["icuinfo"] = icuinfo
  1894. // inputMessage["input"] = input //交易输入
  1895. //
  1896. // bytesData, err := json.Marshal(inputMessage)
  1897. // fmt.Println(string(bytesData))
  1898. // if err != nil {
  1899. // fmt.Println(err.Error())
  1900. // return err.Error()
  1901. // }
  1902. // reader := bytes.NewReader(bytesData)
  1903. //
  1904. // url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/2208"
  1905. // request, err := http.NewRequest("POST", url, reader)
  1906. // if err != nil {
  1907. // fmt.Println(err.Error())
  1908. // return err.Error()
  1909. // }
  1910. //
  1911. // request.Header.Set("Content-Type", "application/json;charset=UTF-8")
  1912. // request.Header.Set("x-tif-paasid", "test_hosp")
  1913. // request.Header.Set("x-tif-signature", signature)
  1914. // request.Header.Set("x-tif-timestamp", strconv.FormatInt(timestamp, 10))
  1915. // request.Header.Set("x-tif-nonce", nonce)
  1916. //
  1917. // client := http.Client{}
  1918. // resp, err := client.Do(request)
  1919. // if err != nil {
  1920. // fmt.Println(err.Error())
  1921. // return err.Error()
  1922. // }
  1923. // respBytes, err := ioutil.ReadAll(resp.Body)
  1924. // if err != nil {
  1925. // fmt.Println(err.Error())
  1926. // return err.Error()
  1927. // }
  1928. // str := string(respBytes)
  1929. // fmt.Println(str)
  1930. // return str
  1931. //}
  1932. // 生成签名
  1933. func setSignature(timestamp int64, nonce string, secret_key string) string {
  1934. str := strconv.FormatInt(timestamp, 10) + secret_key + nonce + strconv.FormatInt(timestamp, 10)
  1935. hash := sha256.New()
  1936. //输入数据
  1937. hash.Write([]byte(str))
  1938. //计算哈希值
  1939. bytes := hash.Sum(nil)
  1940. //将字符串编码为16进制格式,返回字符串
  1941. hashCode := hex.EncodeToString(bytes)
  1942. //返回哈希值
  1943. return hashCode
  1944. }
  1945. // 生成随机字符串
  1946. func GetRandomString(l int) string {
  1947. str := "0123456789abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ"
  1948. bytes := []byte(str)
  1949. result := []byte{}
  1950. r := rand.New(rand.NewSource(time.Now().UnixNano()))
  1951. for i := 0; i < l; i++ {
  1952. result = append(result, bytes[r.Intn(len(bytes))])
  1953. }
  1954. return string(result)
  1955. }
  1956. // 生成基础报文
  1957. func SetInputMessage(nonce string, timestamp int64, org_name string, doctor string, fixmedins_code string, insuplc_admdvs string, mdtrtarea_admvs string) map[string]interface{} {
  1958. // 生成签名
  1959. tempTime := time.Unix(timestamp, 0)
  1960. timeFormat := tempTime.Format("20060102150405")
  1961. timeFormatOne := tempTime.Format("2006-01-02 15:04:05")
  1962. randNum := rand.New(rand.NewSource(time.Now().UnixNano())).Int31n(10000)
  1963. // 生成输入报文
  1964. inputMessage := make(map[string]interface{})
  1965. inputMessage["infno"] = "1101" // 交易编码
  1966. inputMessage["msgid"] = fixmedins_code + timeFormat + strconv.FormatInt(int64(randNum), 10) // 发送方报文 ID
  1967. inputMessage["mdtrtarea_admvs"] = mdtrtarea_admvs // 就医地医保区划
  1968. inputMessage["insuplc_admdvs"] = insuplc_admdvs // 参保地医保区划
  1969. inputMessage["recer_sys_code"] = "01" // 接收方系统代码
  1970. inputMessage["dev_no"] = "" // 设备编号
  1971. inputMessage["dev_safe_info"] = "" // 设备安全信息
  1972. inputMessage["cainfo"] = "" // 数字签名信息
  1973. inputMessage["signtype"] = "" // 签名类型
  1974. inputMessage["infver"] = "V1.1" // 接收方系统代码
  1975. inputMessage["opter_type"] = "1" // 经办人类别
  1976. inputMessage["opter"] = doctor // 经办人
  1977. inputMessage["opter_name"] = doctor // 经办人姓名
  1978. inputMessage["inf_time"] = timeFormatOne // 交易时间
  1979. inputMessage["fixmedins_code"] = fixmedins_code // 定点医药机构编号
  1980. inputMessage["fixmedins_name"] = org_name //定点医药机构名称
  1981. inputMessage["sign_no"] = "" //交易签到流水号
  1982. return inputMessage
  1983. }
  1984. func postFile(filename string, target_url string) (*http.Response, error) {
  1985. body_buf := bytes.NewBufferString("")
  1986. body_writer := multipart.NewWriter(body_buf)
  1987. // use the body_writer to write the Part headers to the buffer
  1988. _, err := body_writer.CreateFormFile("userfile", filename)
  1989. if err != nil {
  1990. fmt.Println("error writing to buffer")
  1991. return nil, err
  1992. }
  1993. // the file data will be the second part of the body
  1994. fh, err := os.Open(filename)
  1995. if err != nil {
  1996. fmt.Println("error opening file")
  1997. return nil, err
  1998. }
  1999. // need to know the boundary to properly close the part myself.
  2000. boundary := body_writer.Boundary()
  2001. //close_string := fmt.Sprintf("\r\n--%s--\r\n", boundary)
  2002. close_buf := bytes.NewBufferString(fmt.Sprintf("\r\n--%s--\r\n", boundary))
  2003. // use multi-reader to defer the reading of the file data until
  2004. // writing to the socket buffer.
  2005. request_reader := io.MultiReader(body_buf, fh, close_buf)
  2006. fi, err := fh.Stat()
  2007. if err != nil {
  2008. fmt.Printf("Error Stating file: %s", filename)
  2009. return nil, err
  2010. }
  2011. req, err := http.NewRequest("POST", target_url, request_reader)
  2012. if err != nil {
  2013. return nil, err
  2014. }
  2015. // Set headers for multipart, and Content Length
  2016. req.Header.Add("Content-Type", "multipart/form-data; boundary="+boundary)
  2017. req.ContentLength = fi.Size() + int64(body_buf.Len()) + int64(close_buf.Len())
  2018. return http.DefaultClient.Do(req)
  2019. }
  2020. //func Gdyb1201(psnNo string, org_name string, doctor string) string {
  2021. // // 生成签名
  2022. // nonce := GetRandomString(32)
  2023. // timestamp := time.Now().Unix()
  2024. // signature := setSignature(timestamp, nonce)
  2025. //
  2026. // // 生成输入报文
  2027. // inputMessage := SetInputMessage(nonce, timestamp, org_name, doctor, "")
  2028. // input := make(map[string]interface{})
  2029. // inputData := make(map[string]interface{})
  2030. // inputMessage["infno"] = "1201" // 交易编码
  2031. // inputData["fixmedins_type"] = psnNo // 人员编号 (来自1101接口返回)
  2032. // inputData["fixmedins_name"] = org_name // 人员编号 (来自1101接口返回)
  2033. // inputData["fixmedins_code"] = "" // 人员编号 (来自1101接口返回)
  2034. //
  2035. // input["medinsinfo"] = inputData
  2036. // inputMessage["input"] = input //交易输入
  2037. //
  2038. // bytesData, err := json.Marshal(inputMessage)
  2039. // fmt.Println(string(bytesData))
  2040. // if err != nil {
  2041. // fmt.Println(err.Error())
  2042. // return err.Error()
  2043. // }
  2044. // reader := bytes.NewReader(bytesData)
  2045. //
  2046. // url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/1201"
  2047. // request, err := http.NewRequest("POST", url, reader)
  2048. // if err != nil {
  2049. // fmt.Println(err.Error())
  2050. // return err.Error()
  2051. // }
  2052. //
  2053. // request.Header.Set("Content-Type", "application/json;charset=UTF-8")
  2054. // request.Header.Set("x-tif-paasid", "test_hosp")
  2055. // request.Header.Set("x-tif-signature", signature)
  2056. // request.Header.Set("x-tif-timestamp", strconv.FormatInt(timestamp, 10))
  2057. // request.Header.Set("x-tif-nonce", nonce)
  2058. //
  2059. // client := http.Client{}
  2060. // resp, err := client.Do(request)
  2061. // if err != nil {
  2062. // fmt.Println(err.Error())
  2063. // return err.Error()
  2064. // }
  2065. // respBytes, err := ioutil.ReadAll(resp.Body)
  2066. // if err != nil {
  2067. // fmt.Println(err.Error())
  2068. // return err.Error()
  2069. // }
  2070. // str := string(respBytes)
  2071. // fmt.Println(str)
  2072. // return str
  2073. //}
  2074. func newfileUploadRequest(uri string, params map[string]string, paramName, path string) (*http.Request, error) {
  2075. file, err := os.Open(path)
  2076. if err != nil {
  2077. return nil, err
  2078. }
  2079. defer file.Close()
  2080. body := &bytes.Buffer{}
  2081. writer := multipart.NewWriter(body)
  2082. part, err := writer.CreateFormFile(paramName, filepath.Base(path))
  2083. if err != nil {
  2084. return nil, err
  2085. }
  2086. _, err = io.Copy(part, file)
  2087. for key, val := range params {
  2088. _ = writer.WriteField(key, val)
  2089. }
  2090. err = writer.Close()
  2091. if err != nil {
  2092. return nil, err
  2093. }
  2094. req, err := http.NewRequest("POST", uri, body)
  2095. req.Header.Set("Content-Type", writer.FormDataContentType())
  2096. return req, err
  2097. }
  2098. func CreateMedicalInsuranceCostCompareRecord(record *models.MedicalInsuranceCostCompare) error {
  2099. err := writeDb.Save(&record).Error
  2100. return err
  2101. }
  2102. //func Gdyb5203(certNo string, org_name string, doctor string, fixmedins_code string, insuplc_admdvs string, mdtrtarea_admvs string, secret_key string) string {
  2103. // // 生成签名
  2104. // nonce := GetRandomString(32)
  2105. // timestamp := time.Now().Unix()
  2106. // signature := setSignature(timestamp, nonce, secret_key)
  2107. //
  2108. // // 生成输入报文
  2109. // inputMessage := SetInputMessage(nonce, timestamp, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs)
  2110. // input := make(map[string]interface{})
  2111. // inputData := make(map[string]interface{})
  2112. // inputMessage["infno"] = "5203" // 交易编码
  2113. //
  2114. // inputData["fixmedins_type"] = "1"
  2115. // inputData["fixmedins_name"] = org_name
  2116. // inputData["fixmedins_code"] = fixmedins_code
  2117. // input["medinsinfo"] = inputData
  2118. // inputMessage["input"] = input //交易输入
  2119. //
  2120. // bytesData, err := json.Marshal(inputMessage)
  2121. // fmt.Println(string(bytesData))
  2122. // if err != nil {
  2123. // fmt.Println(err.Error())
  2124. // return err.Error()
  2125. // }
  2126. // reader := bytes.NewReader(bytesData)
  2127. // url := "http://igb.hsa.gdgov.cn/ebus/gdyb_api/prd/hsa/hgs/1201"
  2128. // //url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/1201"
  2129. // //url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/1101"
  2130. // request, err := http.NewRequest("POST", url, reader)
  2131. // if err != nil {
  2132. // fmt.Println(err.Error())
  2133. // return err.Error()
  2134. // }
  2135. //
  2136. // request.Header.Set("Content-Type", "application/json;charset=UTF-8")
  2137. // request.Header.Set("x-tif-paasid", "sg03_prd")
  2138. // request.Header.Set("x-tif-signature", signature)
  2139. // request.Header.Set("x-tif-timestamp", strconv.FormatInt(timestamp, 10))
  2140. // request.Header.Set("x-tif-nonce", nonce)
  2141. //
  2142. // client := http.Client{}
  2143. // resp, err := client.Do(request)
  2144. // if err != nil {
  2145. // fmt.Println(err.Error())
  2146. // return err.Error()
  2147. // }
  2148. // respBytes, err := ioutil.ReadAll(resp.Body)
  2149. // if err != nil {
  2150. // fmt.Println(err.Error())
  2151. // return err.Error()
  2152. // }
  2153. // fmt.Println(string(respBytes))
  2154. // str := string(respBytes)
  2155. // return str
  2156. //}
  2157. func CreatePsnRecord(record *models.GdybPsnRecord) {
  2158. writeDb.Save(&record)
  2159. return
  2160. }
  2161. func GetPsnRecordById(id int64) (record models.GdybPsnRecord, err error) {
  2162. err = readDb.Model(&models.GdybPsnRecord{}).Where("id = ?").First(&record).Error
  2163. return
  2164. }
  2165. func CreatePsnNCDSRecord(record *models.GdybPsnNcdsRecord) {
  2166. writeDb.Save(&record)
  2167. return
  2168. }
  2169. func GetPsnNCDSRecordById(id int64) (record models.GdybPsnNcdsRecord, err error) {
  2170. err = readDb.Model(&models.GdybPsnNcdsRecord{}).Where("id = ?").First(&record).Error
  2171. return
  2172. }
  2173. func GetPatientsByIds(ids []string, current_org_id int64) (patients []*models.Patients, err error) {
  2174. err = readDb.Model(&models.Patients{}).Where("id IN (?) AND user_org_id = ?", ids, current_org_id).Find(&patients).Error
  2175. return
  2176. }