ahyb_controller.go 63KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069207020712072207320742075207620772078207920802081208220832084208520862087208820892090209120922093209420952096209720982099210021012102210321042105210621072108210921102111211221132114211521162117
  1. package ah
  2. import (
  3. "encoding/json"
  4. "fmt"
  5. "gdyb/controllers"
  6. "gdyb/enums"
  7. "gdyb/models"
  8. "gdyb/service"
  9. "gdyb/utils"
  10. "github.com/astaxie/beego"
  11. "github.com/axgle/mahonia"
  12. "github.com/gorilla/websocket"
  13. "golang.org/x/text/encoding/simplifiedchinese"
  14. "io/ioutil"
  15. "log"
  16. "net/url"
  17. "os"
  18. "regexp"
  19. "strconv"
  20. "strings"
  21. "syscall"
  22. "time"
  23. "unsafe"
  24. )
  25. type AHybController struct {
  26. controllers.BaseAuthAPIController
  27. }
  28. type Body struct {
  29. ErrMsg string `json:"err_msg"`
  30. InfRefMsgID string `json:"inf_refmsgid"`
  31. InfCode int `json:"infcode"`
  32. Output map[string]interface{} `json:"output"`
  33. }
  34. type Response struct {
  35. Body Body `json:"body"`
  36. Code int `json:"code"`
  37. CSBCode int `json:"csbCode"`
  38. Message string `json:"message"`
  39. RequestID string `json:"requestId"`
  40. State struct{} `json:"state"`
  41. }
  42. func AHybRegistRouters() {
  43. beego.Router("/ahyb/1101", &AHybController{}, "get:PostOne")
  44. beego.Router("/ahyb/2201", &AHybController{}, "get:PostTwo")
  45. beego.Router("/ahyb/2202", &AHybController{}, "get:PostThree")
  46. beego.Router("/ahyb/2203", &AHybController{}, "post:PostFour")
  47. beego.Router("/ahyb/2204", &AHybController{}, "post:PostFive")
  48. beego.Router("/ahyb/2205", &AHybController{}, "get:PostSix")
  49. beego.Router("/ahyb/2206", &AHybController{}, "get:PostSeven")
  50. beego.Router("/ahyb/2207", &AHybController{}, "get:PostEight")
  51. beego.Router("/ahyb/2208", &AHybController{}, "get:PostNine")
  52. beego.Router("/ahyb/5203", &AHybController{}, "get:PostTen")
  53. beego.Router("/ahyb/5301", &AHybController{}, "get:Get5301")
  54. beego.Router("/ahyb/3201", &AHybController{}, "get:Get3201")
  55. beego.Router("/ahyb/9001", &AHybController{}, "get:Get9001")
  56. beego.Router("/ahyb/4101", &AHybController{}, "post:Get4101")
  57. beego.Router("/ahyb/readcard", &AHybController{}, "get:ReadCard")
  58. beego.Router("/ahyb/2503", &AHybController{}, "get:Get2503")
  59. beego.Router("/ahyb/2406", &AHybController{}, "post:Get2406")
  60. beego.Router("/ahyb/readcardcharge", &AHybController{}, "get:Readcardcharge")
  61. beego.Router("/ahyb/2406", &AHybController{}, "post:Get2406")
  62. beego.Router("/ahyb/2406", &AHybController{}, "post:Get2406")
  63. }
  64. func (c *JSybController) Get3501() {
  65. body, _ := ioutil.ReadAll(c.Ctx.Request.Body)
  66. var respJSON map[string]interface{}
  67. if err := json.Unmarshal([]byte(string(body)), &respJSON); err != nil {
  68. utils.ErrorLog("接口返回数据解析JSON失败: %v", err)
  69. return
  70. }
  71. userJSONBytes, _ := json.Marshal(respJSON["struct_3501s"])
  72. var struct3501 models.Struct3501
  73. if err := json.Unmarshal(userJSONBytes, &struct3501); err != nil {
  74. utils.ErrorLog("解析失败:%v", err)
  75. return
  76. }
  77. result, request_log := service.Jsyb3501(struct3501)
  78. saveJsLog(result, request_log, "3501", "库存盘点", struct3501.OrgName)
  79. var dat2 map[string]interface{}
  80. if err := json.Unmarshal([]byte(request_log), &dat2); err == nil {
  81. } else {
  82. }
  83. var dat map[string]interface{}
  84. if err := json.Unmarshal([]byte(result), &dat); err == nil {
  85. } else {
  86. }
  87. c.ServeSuccessJSON(map[string]interface{}{
  88. "pre": dat,
  89. "request_log": dat2,
  90. })
  91. }
  92. func (c *JSybController) Get3502() {
  93. body, _ := ioutil.ReadAll(c.Ctx.Request.Body)
  94. var respJSON map[string]interface{}
  95. if err := json.Unmarshal([]byte(string(body)), &respJSON); err != nil {
  96. utils.ErrorLog("接口返回数据解析JSON失败: %v", err)
  97. return
  98. }
  99. userJSONBytes, _ := json.Marshal(respJSON["struct_3502s"])
  100. var struct3502s models.Struct3502
  101. if err := json.Unmarshal(userJSONBytes, &struct3502s); err != nil {
  102. utils.ErrorLog("解析失败:%v", err)
  103. return
  104. }
  105. result, request_log := service.Jsyb3502(struct3502s)
  106. saveJsLog(result, request_log, "3502", "库存变更", struct3502s.OrgName)
  107. var dat2 map[string]interface{}
  108. if err := json.Unmarshal([]byte(request_log), &dat2); err == nil {
  109. } else {
  110. }
  111. var dat map[string]interface{}
  112. if err := json.Unmarshal([]byte(result), &dat); err == nil {
  113. } else {
  114. }
  115. c.ServeSuccessJSON(map[string]interface{}{
  116. "pre": dat,
  117. "request_log": dat2,
  118. })
  119. }
  120. func (c *JSybController) Get3503() {
  121. body, _ := ioutil.ReadAll(c.Ctx.Request.Body)
  122. var respJSON map[string]interface{}
  123. if err := json.Unmarshal([]byte(string(body)), &respJSON); err != nil {
  124. utils.ErrorLog("接口返回数据解析JSON失败: %v", err)
  125. return
  126. }
  127. userJSONBytes, _ := json.Marshal(respJSON["struct_3503s"])
  128. var struct3503 models.Struct3503
  129. if err := json.Unmarshal(userJSONBytes, &struct3503); err != nil {
  130. utils.ErrorLog("解析失败:%v", err)
  131. return
  132. }
  133. fmt.Println(struct3503)
  134. result, request_log := service.Jsyb3503(struct3503)
  135. saveJsLog(result, request_log, "3503", "库存采购", struct3503.OrgName)
  136. var dat2 map[string]interface{}
  137. if err := json.Unmarshal([]byte(request_log), &dat2); err == nil {
  138. } else {
  139. }
  140. var dat map[string]interface{}
  141. if err := json.Unmarshal([]byte(result), &dat); err == nil {
  142. } else {
  143. }
  144. c.ServeSuccessJSON(map[string]interface{}{
  145. "pre": dat,
  146. "request_log": dat2,
  147. })
  148. }
  149. func (c *JSybController) Get3504() {
  150. body, _ := ioutil.ReadAll(c.Ctx.Request.Body)
  151. var respJSON map[string]interface{}
  152. if err := json.Unmarshal([]byte(string(body)), &respJSON); err != nil {
  153. utils.ErrorLog("接口返回数据解析JSON失败: %v", err)
  154. return
  155. }
  156. userJSONBytes, _ := json.Marshal(respJSON["struct_3504s"])
  157. var struct3504 []models.Struct3504
  158. if err := json.Unmarshal(userJSONBytes, &struct3504); err != nil {
  159. utils.ErrorLog("解析失败:%v", err)
  160. return
  161. }
  162. result, request_log := service.Jsyb3504(struct3504[0])
  163. saveJsLog(result, request_log, "3504", "库存盘点", struct3504[0].OrgName)
  164. var dat2 map[string]interface{}
  165. if err := json.Unmarshal([]byte(request_log), &dat2); err == nil {
  166. } else {
  167. }
  168. var dat map[string]interface{}
  169. if err := json.Unmarshal([]byte(result), &dat); err == nil {
  170. } else {
  171. }
  172. c.ServeSuccessJSON(map[string]interface{}{
  173. "pre": dat,
  174. "request_log": dat2,
  175. })
  176. }
  177. func (c *JSybController) Get3505() {
  178. body, _ := ioutil.ReadAll(c.Ctx.Request.Body)
  179. var respJSON map[string]interface{}
  180. if err := json.Unmarshal([]byte(string(body)), &respJSON); err != nil {
  181. utils.ErrorLog("接口返回数据解析JSON失败: %v", err)
  182. return
  183. }
  184. userJSONBytes, _ := json.Marshal(respJSON["struct_3505s"])
  185. var struct3505 models.Struct3505
  186. if err := json.Unmarshal(userJSONBytes, &struct3505); err != nil {
  187. utils.ErrorLog("解析失败:%v", err)
  188. return
  189. }
  190. result, request_log := service.Jsyb3505(struct3505)
  191. saveJsLog(result, request_log, "3505", "销售", struct3505.OrgName)
  192. var dat2 map[string]interface{}
  193. if err := json.Unmarshal([]byte(request_log), &dat2); err == nil {
  194. } else {
  195. }
  196. var dat map[string]interface{}
  197. if err := json.Unmarshal([]byte(result), &dat); err == nil {
  198. } else {
  199. }
  200. c.ServeSuccessJSON(map[string]interface{}{
  201. "pre": dat,
  202. "request_log": dat2,
  203. })
  204. }
  205. func (c *JSybController) Get3506() {
  206. body, _ := ioutil.ReadAll(c.Ctx.Request.Body)
  207. var respJSON map[string]interface{}
  208. if err := json.Unmarshal([]byte(string(body)), &respJSON); err != nil {
  209. utils.ErrorLog("接口返回数据解析JSON失败: %v", err)
  210. return
  211. }
  212. userJSONBytes, _ := json.Marshal(respJSON["struct_3506s"])
  213. var struct3506 models.Struct3506
  214. if err := json.Unmarshal(userJSONBytes, &struct3506); err != nil {
  215. utils.ErrorLog("解析失败:%v", err)
  216. return
  217. }
  218. result, request_log := service.Jsyb3506(struct3506)
  219. saveJsLog(result, request_log, "3506", "销售退库", struct3506.OrgName)
  220. var dat2 map[string]interface{}
  221. if err := json.Unmarshal([]byte(request_log), &dat2); err == nil {
  222. } else {
  223. }
  224. var dat map[string]interface{}
  225. if err := json.Unmarshal([]byte(result), &dat); err == nil {
  226. } else {
  227. }
  228. c.ServeSuccessJSON(map[string]interface{}{
  229. "pre": dat,
  230. "request_log": dat2,
  231. })
  232. }
  233. func (c *JSybController) Get3507() {
  234. body, _ := ioutil.ReadAll(c.Ctx.Request.Body)
  235. var respJSON map[string]interface{}
  236. if err := json.Unmarshal([]byte(string(body)), &respJSON); err != nil {
  237. utils.ErrorLog("接口返回数据解析JSON失败: %v", err)
  238. return
  239. }
  240. userJSONBytes, _ := json.Marshal(respJSON["struct_3507s"])
  241. var struct3507 models.Struct3507
  242. if err := json.Unmarshal(userJSONBytes, &struct3507); err != nil {
  243. utils.ErrorLog("解析失败:%v", err)
  244. return
  245. }
  246. result, request_log := service.Jsyb3507(struct3507)
  247. saveJsLog(result, request_log, "3507", "库存盘点", struct3507.OrgName)
  248. var dat2 map[string]interface{}
  249. if err := json.Unmarshal([]byte(request_log), &dat2); err == nil {
  250. } else {
  251. }
  252. var dat map[string]interface{}
  253. if err := json.Unmarshal([]byte(result), &dat); err == nil {
  254. } else {
  255. }
  256. c.ServeSuccessJSON(map[string]interface{}{
  257. "pre": dat,
  258. "request_log": dat2,
  259. })
  260. }
  261. func (c *JSybController) Get3508() {
  262. body, _ := ioutil.ReadAll(c.Ctx.Request.Body)
  263. var respJSON map[string]interface{}
  264. if err := json.Unmarshal([]byte(string(body)), &respJSON); err != nil {
  265. utils.ErrorLog("接口返回数据解析JSON失败: %v", err)
  266. return
  267. }
  268. userJSONBytes, _ := json.Marshal(respJSON["struct_3508s"])
  269. var struct3508 models.Struct3508
  270. if err := json.Unmarshal(userJSONBytes, &struct3508); err != nil {
  271. utils.ErrorLog("解析失败:%v", err)
  272. return
  273. }
  274. result, request_log := service.Jsyb3508(struct3508)
  275. saveJsLog(result, request_log, "3508", "库存查询", struct3508.OrgName)
  276. var dat2 map[string]interface{}
  277. if err := json.Unmarshal([]byte(request_log), &dat2); err == nil {
  278. } else {
  279. }
  280. var dat map[string]interface{}
  281. if err := json.Unmarshal([]byte(result), &dat); err == nil {
  282. } else {
  283. }
  284. c.ServeSuccessJSON(map[string]interface{}{
  285. "pre": dat,
  286. "request_log": dat2,
  287. })
  288. }
  289. func (c *JSybController) Get3509() {
  290. body, _ := ioutil.ReadAll(c.Ctx.Request.Body)
  291. var respJSON map[string]interface{}
  292. if err := json.Unmarshal([]byte(string(body)), &respJSON); err != nil {
  293. utils.ErrorLog("接口返回数据解析JSON失败: %v", err)
  294. return
  295. }
  296. userJSONBytes, _ := json.Marshal(respJSON["struct_3509s"])
  297. var struct3509 models.Struct3509
  298. if err := json.Unmarshal(userJSONBytes, &struct3509); err != nil {
  299. utils.ErrorLog("解析失败:%v", err)
  300. return
  301. }
  302. result, request_log := service.Jsyb3509(struct3509)
  303. saveJsLog(result, request_log, "3509", "库存查询", struct3509.OrgName)
  304. var dat2 map[string]interface{}
  305. if err := json.Unmarshal([]byte(request_log), &dat2); err == nil {
  306. } else {
  307. }
  308. var dat map[string]interface{}
  309. if err := json.Unmarshal([]byte(result), &dat); err == nil {
  310. } else {
  311. }
  312. c.ServeSuccessJSON(map[string]interface{}{
  313. "pre": dat,
  314. "request_log": dat2,
  315. })
  316. }
  317. func (c *JSybController) Get3510() {
  318. body, _ := ioutil.ReadAll(c.Ctx.Request.Body)
  319. var respJSON map[string]interface{}
  320. if err := json.Unmarshal([]byte(string(body)), &respJSON); err != nil {
  321. utils.ErrorLog("接口返回数据解析JSON失败: %v", err)
  322. return
  323. }
  324. userJSONBytes, _ := json.Marshal(respJSON["struct_3510s"])
  325. var struct3510 models.Struct3510
  326. if err := json.Unmarshal(userJSONBytes, &struct3510); err != nil {
  327. utils.ErrorLog("解析失败:%v", err)
  328. return
  329. }
  330. result, request_log := service.Jsyb3510(struct3510)
  331. saveJsLog(result, request_log, "3510", "库存盘点", struct3510.OrgName)
  332. var dat2 map[string]interface{}
  333. if err := json.Unmarshal([]byte(request_log), &dat2); err == nil {
  334. } else {
  335. }
  336. var dat map[string]interface{}
  337. if err := json.Unmarshal([]byte(result), &dat); err == nil {
  338. } else {
  339. }
  340. c.ServeSuccessJSON(map[string]interface{}{
  341. "pre": dat,
  342. "request_log": dat2,
  343. })
  344. }
  345. func (c *JSybController) Get3511() {
  346. body, _ := ioutil.ReadAll(c.Ctx.Request.Body)
  347. var respJSON map[string]interface{}
  348. if err := json.Unmarshal([]byte(string(body)), &respJSON); err != nil {
  349. utils.ErrorLog("接口返回数据解析JSON失败: %v", err)
  350. return
  351. }
  352. userJSONBytes, _ := json.Marshal(respJSON["struct_3511s"])
  353. var struct3511 models.Struct3511
  354. if err := json.Unmarshal(userJSONBytes, &struct3511); err != nil {
  355. utils.ErrorLog("解析失败:%v", err)
  356. return
  357. }
  358. result, request_log := service.Jsyb3511(struct3511)
  359. saveJsLog(result, request_log, "3511", "库存查询", struct3511.OrgName)
  360. var dat2 map[string]interface{}
  361. if err := json.Unmarshal([]byte(request_log), &dat2); err == nil {
  362. } else {
  363. }
  364. var dat map[string]interface{}
  365. if err := json.Unmarshal([]byte(result), &dat); err == nil {
  366. } else {
  367. }
  368. c.ServeSuccessJSON(map[string]interface{}{
  369. "pre": dat,
  370. "request_log": dat2,
  371. })
  372. }
  373. func (c *JSybController) Get3512() {
  374. body, _ := ioutil.ReadAll(c.Ctx.Request.Body)
  375. var respJSON map[string]interface{}
  376. if err := json.Unmarshal([]byte(string(body)), &respJSON); err != nil {
  377. utils.ErrorLog("接口返回数据解析JSON失败: %v", err)
  378. return
  379. }
  380. userJSONBytes, _ := json.Marshal(respJSON["struct_3512s"])
  381. var struct3512 models.Struct3512
  382. if err := json.Unmarshal(userJSONBytes, &struct3512); err != nil {
  383. utils.ErrorLog("解析失败:%v", err)
  384. return
  385. }
  386. result, request_log := service.Jsyb3512(struct3512)
  387. saveJsLog(result, request_log, "3512", "3512查询", struct3512.OrgName)
  388. var dat2 map[string]interface{}
  389. if err := json.Unmarshal([]byte(request_log), &dat2); err == nil {
  390. } else {
  391. }
  392. var dat map[string]interface{}
  393. if err := json.Unmarshal([]byte(result), &dat); err == nil {
  394. } else {
  395. }
  396. c.ServeSuccessJSON(map[string]interface{}{
  397. "pre": dat,
  398. "request_log": dat2,
  399. })
  400. }
  401. func (c *JSybController) Get3513() {
  402. body, _ := ioutil.ReadAll(c.Ctx.Request.Body)
  403. var respJSON map[string]interface{}
  404. if err := json.Unmarshal([]byte(string(body)), &respJSON); err != nil {
  405. utils.ErrorLog("接口返回数据解析JSON失败: %v", err)
  406. return
  407. }
  408. userJSONBytes, _ := json.Marshal(respJSON["struct_3513s"])
  409. var struct3513 models.Struct3513
  410. if err := json.Unmarshal(userJSONBytes, &struct3513); err != nil {
  411. utils.ErrorLog("解析失败:%v", err)
  412. return
  413. }
  414. result, request_log := service.Jsyb3513(struct3513)
  415. saveJsLog(result, request_log, "3513", "库存盘点", struct3513.OrgName)
  416. var dat2 map[string]interface{}
  417. if err := json.Unmarshal([]byte(request_log), &dat2); err == nil {
  418. } else {
  419. }
  420. var dat map[string]interface{}
  421. if err := json.Unmarshal([]byte(result), &dat); err == nil {
  422. } else {
  423. }
  424. c.ServeSuccessJSON(map[string]interface{}{
  425. "pre": dat,
  426. "request_log": dat2,
  427. })
  428. }
  429. func (c *AHybController) Readcardcharge() {
  430. fixmedins_code := c.GetString("fixmedins_code")
  431. secret_key := c.GetString("secret_key")
  432. ak := c.GetString("ak")
  433. org_name := c.GetString("org_name")
  434. doctor := c.GetString("doctor")
  435. //insuplc_admdvs := c.GetString("insuplc_admdvs")
  436. mdtrtarea_admvs := c.GetString("mdtrtarea_admvs")
  437. url := c.GetString("url")
  438. cainfo := c.GetString("cainfo")
  439. operator_id := c.GetString("operator_id")
  440. operator := c.GetString("operator")
  441. _, pBusiCardInfo := c.GetELeCertInfoThree(fixmedins_code, operator_id, operator)
  442. fmt.Println(pBusiCardInfo)
  443. pBusiCardInfo = Remove0000(pBusiCardInfo)
  444. var ele ELeCertData
  445. err := json.Unmarshal([]byte(pBusiCardInfo), &ele)
  446. if err != nil {
  447. utils.ErrorLog("解析失败:%v", err)
  448. }
  449. token := ele.Data.EcToken
  450. fmt.Println(token)
  451. if len(token) > 0 {
  452. userName := ele.Data.UserName
  453. fmt.Println(userName)
  454. userName = Remove0000(userName)
  455. userName = DeleteExtraSpace(userName)
  456. fmt.Println(userName)
  457. enc := mahonia.NewEncoder("gbk")
  458. fmt.Println(enc.ConvertString(userName))
  459. result, _ := service.AHyb1101ForEleCert(org_name, doctor, fixmedins_code, ele.Data.InsuOrg, mdtrtarea_admvs, secret_key, url, ak, token, cainfo, ele.Data.IDNo, userName)
  460. var response Response
  461. if err := json.Unmarshal([]byte(result), &response); err != nil {
  462. fmt.Println("Error decoding JSON:", err)
  463. return
  464. }
  465. if response.Code == 200 {
  466. c.ServeSuccessJSON(map[string]interface{}{
  467. "status": "1",
  468. "card_info": "",
  469. "busi_card_info": pBusiCardInfo,
  470. "token": token,
  471. "result": response.Body,
  472. })
  473. } else {
  474. c.ServeSuccessJSON(map[string]interface{}{
  475. "status": "0",
  476. "msg": response.Message,
  477. })
  478. }
  479. } else {
  480. c.ServeSuccessJSON(map[string]interface{}{
  481. "status": "-1",
  482. })
  483. }
  484. }
  485. func (c *AHybController) Get9001() {
  486. url := c.GetString("url")
  487. org_name := c.GetString("org_name")
  488. opera_name := c.GetString("opera_name")
  489. opera_id := c.GetString("opera_id")
  490. fixmedins_code := c.GetString("fixmedins_code")
  491. insuplc_admdvs := c.GetString("insuplc_admdvs")
  492. mdtrtarea_admvs := c.GetString("mdtrtarea_admvs")
  493. secret_key := c.GetString("secret_key")
  494. cainfo := c.GetString("cainfo")
  495. result, inputLog := service.AHyb9001(org_name, opera_name, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs, secret_key, opera_id, url, cainfo, "")
  496. fmt.Println(result)
  497. fmt.Println(inputLog)
  498. saveJsLog(result, inputLog, "9001", "签到", org_name)
  499. var response Response
  500. if err := json.Unmarshal([]byte(result), &response); err != nil {
  501. fmt.Println("Error decoding JSON:", err)
  502. return
  503. }
  504. if response.Code == 200 {
  505. var dat2 map[string]interface{}
  506. if err := json.Unmarshal([]byte(inputLog), &dat2); err == nil {
  507. } else {
  508. }
  509. c.ServeSuccessJSON(map[string]interface{}{
  510. "pre": response.Body,
  511. "log": dat2,
  512. "status": "1",
  513. "msg": "",
  514. })
  515. } else {
  516. c.ServeSuccessJSON(map[string]interface{}{
  517. "status": "0",
  518. "msg": response.Message,
  519. })
  520. }
  521. }
  522. func (c *AHybController) Get5301() {
  523. psn_no := c.GetString("psn_no")
  524. org_name := c.GetString("org_name")
  525. doctor := c.GetString("doctor")
  526. fixmedins_code := c.GetString("fixmedins_code")
  527. insuplc_admdvs := c.GetString("insuplc_admdvs")
  528. mdtrtarea_admvs := c.GetString("mdtrtarea_admvs")
  529. secret_key := c.GetString("secret_key")
  530. url := c.GetString("url")
  531. ak := c.GetString("ak")
  532. cainfo := c.GetString("cainfo")
  533. result, inputLog := service.AHyb5301(psn_no, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs, secret_key, url, ak, cainfo)
  534. //saveJsLog()
  535. saveJsLog(result, inputLog, "5301", "查询备案", org_name)
  536. var response Response
  537. if err := json.Unmarshal([]byte(result), &response); err != nil {
  538. fmt.Println("Error decoding JSON:", err)
  539. return
  540. }
  541. if response.Code == 200 {
  542. var dat2 map[string]interface{}
  543. if err := json.Unmarshal([]byte(inputLog), &dat2); err == nil {
  544. } else {
  545. }
  546. c.ServeSuccessJSON(map[string]interface{}{
  547. "pre": response.Body,
  548. "log": dat2,
  549. "status": "1",
  550. "msg": "",
  551. })
  552. } else {
  553. c.ServeSuccessJSON(map[string]interface{}{
  554. "status": "0",
  555. "msg": response.Message,
  556. })
  557. }
  558. }
  559. func (c *AHybController) PostOne() {
  560. certNo := c.GetString("cert_no")
  561. org_name := c.GetString("org_name")
  562. doctor := c.GetString("doctor")
  563. fixmedins_code := c.GetString("fixmedins_code")
  564. insuplc_admdvs := c.GetString("insuplc_admdvs")
  565. mdtrtarea_admvs := c.GetString("mdtrtarea_admvs")
  566. id_card_type, _ := c.GetInt64("id_card_type")
  567. card_sn := c.GetString("card_sn")
  568. certificates := c.GetString("certificates")
  569. url := c.GetString("url")
  570. token := c.GetString("token")
  571. name := c.GetString("name")
  572. result, inputLog := service.AHyb1101(certNo, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs, id_card_type, card_sn, certificates, url, name, token)
  573. fmt.Println(result)
  574. fmt.Println(inputLog)
  575. saveJsLog(result, inputLog, "1101", "查询个人信息", org_name)
  576. var response Response
  577. if err := json.Unmarshal([]byte(result), &response); err != nil {
  578. fmt.Println("Error decoding JSON:", err)
  579. return
  580. }
  581. if response.Code == 200 {
  582. var dat2 map[string]interface{}
  583. if err := json.Unmarshal([]byte(inputLog), &dat2); err == nil {
  584. } else {
  585. }
  586. c.ServeSuccessJSON(map[string]interface{}{
  587. "pre": response.Body,
  588. "log": dat2,
  589. "status": "1",
  590. "msg": "",
  591. })
  592. } else {
  593. c.ServeSuccessJSON(map[string]interface{}{
  594. "status": "0",
  595. "msg": response.Message,
  596. })
  597. }
  598. }
  599. func (c *AHybController) PostTwo() {
  600. psnNo := c.GetString("psn_no")
  601. insutype := c.GetString("insutype")
  602. certNo := c.GetString("cert_no")
  603. org_name := c.GetString("org_name")
  604. opera := c.GetString("opera")
  605. ipt_otp_no := c.GetString("ipt_otp_no")
  606. dept := c.GetString("dept")
  607. verify_number := c.GetString("verify_number")
  608. fixmedins_code := c.GetString("fixmedins_code")
  609. dept_code := c.GetString("dept_code")
  610. doctor_id := c.GetString("doctor_id")
  611. insuplc_admdvs := c.GetString("insuplc_admdvs")
  612. mdtrtarea_admvs := c.GetString("mdtrtarea_admvs")
  613. secret_key := c.GetString("secret_key")
  614. id_card_type, _ := c.GetInt64("id_card_type")
  615. url := c.GetString("url")
  616. ak := c.GetString("ak")
  617. doctor_name := c.GetString("doctor_name")
  618. cainfo := c.GetString("cainfo")
  619. card_sn := c.GetString("card_sn")
  620. result, inputLog := service.AHyb2201(psnNo, insutype, certNo, org_name, opera, ipt_otp_no, dept, fixmedins_code, dept_code, doctor_id, insuplc_admdvs, mdtrtarea_admvs, secret_key, id_card_type, doctor_name, url, ak, verify_number, cainfo, card_sn)
  621. var response Response
  622. if err := json.Unmarshal([]byte(result), &response); err != nil {
  623. fmt.Println("Error decoding JSON:", err)
  624. return
  625. }
  626. if response.Code == 200 {
  627. var dat2 map[string]interface{}
  628. if err := json.Unmarshal([]byte(inputLog), &dat2); err == nil {
  629. } else {
  630. }
  631. c.ServeSuccessJSON(map[string]interface{}{
  632. "pre": response.Body,
  633. "log": dat2,
  634. "status": "1",
  635. "msg": "",
  636. })
  637. } else {
  638. c.ServeSuccessJSON(map[string]interface{}{
  639. "status": "0",
  640. "msg": response.Message,
  641. })
  642. }
  643. }
  644. func (c *AHybController) PostThree() {
  645. psnNo := c.GetString("psn_no")
  646. mdtrtId := c.GetString("mdtrt_id")
  647. iptOtpNo := c.GetString("ipt_otp_no")
  648. org_name := c.GetString("org_name")
  649. doctor := c.GetString("doctor")
  650. insuplc_admdvs := c.GetString("insuplc_admdvs")
  651. mdtrtarea_admvs := c.GetString("mdtrtarea_admvs")
  652. secret_key := c.GetString("secret_key")
  653. fixmedins_code := c.GetString("fixmedins_code")
  654. url := c.GetString("url")
  655. ak := c.GetString("ak")
  656. cainfo := c.GetString("cainfo")
  657. result, inputLog := service.AHyb2202(psnNo, mdtrtId, iptOtpNo, org_name, doctor, insuplc_admdvs, mdtrtarea_admvs, secret_key, fixmedins_code, url, ak, cainfo)
  658. saveJsLog(result, inputLog, "2202", "退号", org_name)
  659. var response Response
  660. if err := json.Unmarshal([]byte(result), &response); err != nil {
  661. fmt.Println("Error decoding JSON:", err)
  662. return
  663. }
  664. if response.Code == 200 {
  665. var dat2 map[string]interface{}
  666. if err := json.Unmarshal([]byte(inputLog), &dat2); err == nil {
  667. } else {
  668. }
  669. c.ServeSuccessJSON(map[string]interface{}{
  670. "pre": response.Body,
  671. "log": dat2,
  672. "status": "1",
  673. "msg": "",
  674. })
  675. } else {
  676. c.ServeSuccessJSON(map[string]interface{}{
  677. "status": "0",
  678. "msg": response.Message,
  679. })
  680. }
  681. }
  682. func (c *AHybController) PostFour() {
  683. body, _ := ioutil.ReadAll(c.Ctx.Request.Body)
  684. var respJSON map[string]interface{}
  685. if err := json.Unmarshal([]byte(string(body)), &respJSON); err != nil {
  686. utils.ErrorLog("接口返回数据解析JSON失败: %v", err)
  687. return
  688. }
  689. userJSONBytes, _ := json.Marshal(respJSON["config"])
  690. var config []*models.HisXtDiagnoseConfig
  691. if err := json.Unmarshal(userJSONBytes, &config); err != nil {
  692. utils.ErrorLog("解析失败:%v", err)
  693. return
  694. }
  695. fmt.Println(respJSON["psn_no"].(string))
  696. fmt.Println(respJSON["mdtrt_id"].(string))
  697. psnNo := respJSON["psn_no"].(string)
  698. mdtrtId := respJSON["mdtrt_id"].(string)
  699. operator := respJSON["operator"].(string)
  700. department := respJSON["department"].(string)
  701. org_name := respJSON["org_name"].(string)
  702. med_type := respJSON["med_type"].(string)
  703. fixmedins_code := respJSON["fixmedins_code"].(string)
  704. sick_code := respJSON["sick_code"].(string)
  705. sick_name := respJSON["sick_name"].(string)
  706. insuplc_admdvs := respJSON["insuplc_admdvs"].(string)
  707. mdtrtarea_admvs := respJSON["mdtrtarea_admvs"].(string)
  708. url := respJSON["url"].(string)
  709. begin_time := respJSON["begin_time"].(string)
  710. cainfo := respJSON["cainfo"].(string)
  711. doctor_name := respJSON["doctor_name"].(string)
  712. doctor_number := respJSON["doctor_number"].(string)
  713. //cainfo := c.GetString("cainfo")
  714. result, inputLog := service.AHyb2203(psnNo, mdtrtId, operator, department, org_name, med_type, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs, sick_code, sick_name, config, url, begin_time, cainfo, doctor_name, doctor_number)
  715. saveJsLog(result, inputLog, "2203", "上传就诊信息", org_name)
  716. var response Response
  717. if err := json.Unmarshal([]byte(result), &response); err != nil {
  718. fmt.Println("Error decoding JSON:", err)
  719. return
  720. }
  721. if response.Code == 200 {
  722. var dat2 map[string]interface{}
  723. if err := json.Unmarshal([]byte(inputLog), &dat2); err == nil {
  724. } else {
  725. }
  726. c.ServeSuccessJSON(map[string]interface{}{
  727. "pre": response.Body,
  728. "log": dat2,
  729. "status": "1",
  730. "msg": "",
  731. })
  732. } else {
  733. c.ServeSuccessJSON(map[string]interface{}{
  734. "status": "0",
  735. "msg": response.Message,
  736. })
  737. }
  738. }
  739. func (c *AHybController) Get2406() {
  740. body, _ := ioutil.ReadAll(c.Ctx.Request.Body)
  741. var respJSON map[string]interface{}
  742. if err := json.Unmarshal([]byte(string(body)), &respJSON); err != nil {
  743. utils.ErrorLog("接口返回数据解析JSON失败: %v", err)
  744. return
  745. }
  746. psnNo := respJSON["psn_no"].(string)
  747. mdtrtId := respJSON["mdtrt_id"].(string)
  748. operator := respJSON["operator"].(string)
  749. cert_no := respJSON["cert_no"].(string)
  750. org_name := respJSON["org_name"].(string)
  751. psn_name := respJSON["psn_name"].(string)
  752. ipt_otp_no := respJSON["ipt_otp_no"].(string)
  753. ipt_psn_sp_flag_type := respJSON["ipt_psn_sp_flag_type"].(string)
  754. ipt_psn_sp_flag := respJSON["ipt_psn_sp_flag"].(string)
  755. fixmedins_code := respJSON["fixmedins_code"].(string)
  756. insuplc_admdvs := respJSON["insuplc_admdvs"].(string)
  757. mdtrtarea_admvs := respJSON["mdtrtarea_admvs"].(string)
  758. url := respJSON["url"].(string)
  759. result, inputLog := service.AHyb2406(psnNo, mdtrtId, cert_no, psn_name, operator, ipt_otp_no, ipt_psn_sp_flag_type, ipt_psn_sp_flag, org_name, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs, url)
  760. saveJsLog(result, inputLog, "2406", "上传2406信息", org_name)
  761. var response Response
  762. if err := json.Unmarshal([]byte(result), &response); err != nil {
  763. fmt.Println("Error decoding JSON:", err)
  764. return
  765. }
  766. if response.Code == 200 {
  767. var dat2 map[string]interface{}
  768. if err := json.Unmarshal([]byte(inputLog), &dat2); err == nil {
  769. } else {
  770. }
  771. c.ServeSuccessJSON(map[string]interface{}{
  772. "pre": response.Body,
  773. "log": dat2,
  774. "status": "1",
  775. "msg": "",
  776. })
  777. } else {
  778. c.ServeSuccessJSON(map[string]interface{}{
  779. "status": "0",
  780. "msg": response.Message,
  781. })
  782. }
  783. }
  784. type All struct {
  785. HisPrescription HisPrescription
  786. mdtrt_id string
  787. psn_no string
  788. }
  789. type HisPrescription struct {
  790. ID int64 `gorm:"column:id" json:"id" form:"id"`
  791. UserOrgId int64 `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
  792. RecordDate int64 `gorm:"column:record_date" json:"record_date" form:"record_date"`
  793. PatientId int64 `gorm:"column:patient_id" json:"patient_id" form:"patient_id"`
  794. HisPatientId int64 `gorm:"column:his_patient_id" json:"his_patient_id" form:"his_patient_id"`
  795. Status int64 `gorm:"column:status" json:"status" form:"status"`
  796. Ctime int64 `gorm:"column:ctime" json:"ctime" form:"ctime"`
  797. Mtime int64 `gorm:"column:mtime" json:"mtime" form:"mtime"`
  798. Number string `gorm:"column:number" json:"number" form:"number"`
  799. Type int64 `gorm:"column:type" json:"type" form:"type"`
  800. Doctor int64 `gorm:"column:doctor" json:"doctor" form:"doctor"`
  801. Creator int64 `gorm:"column:creator" json:"creator" form:"creator"`
  802. Modifier int64 `gorm:"column:modifier" json:"modifier" form:"modifier"`
  803. HisDoctorAdviceInfo []*models.HisDoctorAdviceInfo `gorm:"ForeignKey:PatientId,RecordDate,PrescriptionId;AssociationForeignKey:PatientId,RecordDate,ID" json:"advices"`
  804. HisPrescriptionProject []*models.HisPrescriptionProject `gorm:"ForeignKey:PatientId,RecordDate,PrescriptionId;AssociationForeignKey:PatientId,RecordDate,ID" json:"project"`
  805. }
  806. func (c *AHybController) PostFive() {
  807. body, _ := ioutil.ReadAll(c.Ctx.Request.Body)
  808. var respJSON map[string]interface{}
  809. if err := json.Unmarshal([]byte(string(body)), &respJSON); err != nil {
  810. utils.ErrorLog("接口返回数据解析JSON失败: %v", err)
  811. return
  812. }
  813. userJSONBytes, _ := json.Marshal(respJSON["pre"])
  814. var hp []*models.HisPrescription
  815. if err := json.Unmarshal(userJSONBytes, &hp); err != nil {
  816. utils.ErrorLog("解析失败:%v", err)
  817. return
  818. }
  819. //fmt.Println("2203A的time_stamp=" + respJSON["time_stamp"].(string))
  820. result, inputLog := service.AHyb2204(respJSON["psn_no"].(string), respJSON["mdtrt_id"].(string), hp, respJSON["chrg_bchno"].(string), respJSON["org_name"].(string),
  821. respJSON["doctor"].(string), respJSON["dept"].(string), respJSON["fixmedins_code"].(string), respJSON["dept_code"].(string), respJSON["doctor_id"].(string), respJSON["insuplc_admdvs"].(string), respJSON["mdtrtarea_admvs"].(string), respJSON["secret_key"].(string), respJSON["balance_accounts_type"].(string), respJSON["diag_code"].(string), respJSON["url"].(string), respJSON["ak"].(string), respJSON["new_doctor_name"].(string), "", respJSON["cainfo"].(string), respJSON["opter"].(string))
  822. saveJsLog(result, inputLog, "2204", "上传明细", respJSON["org_name"].(string))
  823. var response Response
  824. if err := json.Unmarshal([]byte(result), &response); err != nil {
  825. fmt.Println("Error decoding JSON:", err)
  826. return
  827. }
  828. if response.Code == 200 {
  829. var dat2 map[string]interface{}
  830. if err := json.Unmarshal([]byte(inputLog), &dat2); err == nil {
  831. } else {
  832. }
  833. c.ServeSuccessJSON(map[string]interface{}{
  834. "pre": response.Body,
  835. "log": dat2,
  836. "status": "1",
  837. "msg": "",
  838. })
  839. } else {
  840. c.ServeSuccessJSON(map[string]interface{}{
  841. "status": "0",
  842. "msg": response.Message,
  843. })
  844. }
  845. }
  846. func (c *AHybController) PostSix() {
  847. psnNo := c.GetString("psn_no")
  848. mdtrtId := c.GetString("mdtrt_id")
  849. chrgBchno := c.GetString("chrg_bchno")
  850. org_name := c.GetString("org_name")
  851. doctor := c.GetString("doctor")
  852. insuplc_admdvs := c.GetString("insuplc_admdvs")
  853. mdtrtarea_admvs := c.GetString("mdtrtarea_admvs")
  854. secret_key := c.GetString("secret_key")
  855. fixmedins_code := c.GetString("fixmedins_code")
  856. url := c.GetString("url")
  857. ak := c.GetString("ak")
  858. cainfo := c.GetString("cainfo")
  859. result, inputLog := service.AHyb2205(psnNo, mdtrtId, chrgBchno, org_name, doctor, insuplc_admdvs, mdtrtarea_admvs, secret_key, fixmedins_code, url, ak, cainfo)
  860. fmt.Println(inputLog)
  861. saveJsLog(result, inputLog, "2205", "撤销明细", org_name)
  862. var response Response
  863. if err := json.Unmarshal([]byte(result), &response); err != nil {
  864. fmt.Println("Error decoding JSON:", err)
  865. return
  866. }
  867. if response.Code == 200 {
  868. var dat2 map[string]interface{}
  869. if err := json.Unmarshal([]byte(inputLog), &dat2); err == nil {
  870. } else {
  871. }
  872. c.ServeSuccessJSON(map[string]interface{}{
  873. "pre": response.Body,
  874. "log": dat2,
  875. "status": "1",
  876. "msg": "",
  877. })
  878. } else {
  879. c.ServeSuccessJSON(map[string]interface{}{
  880. "status": "0",
  881. "msg": response.Message,
  882. })
  883. }
  884. }
  885. func (c *AHybController) PostSeven() {
  886. psnNo := c.GetString("psn_no")
  887. mdtrtId := c.GetString("mdtrt_id")
  888. chrgBchno := c.GetString("chrg_bchno")
  889. certNo := c.GetString("cert_no")
  890. insutype := c.GetString("insutype")
  891. total := c.GetString("total")
  892. org_name := c.GetString("org_name")
  893. doctor := c.GetString("doctor")
  894. fixmedins_code := c.GetString("fixmedins_code")
  895. insuplc_admdvs := c.GetString("insuplc_admdvs")
  896. mdtrtarea_admvs := c.GetString("mdtrtarea_admvs")
  897. secret_key := c.GetString("secret_key")
  898. med_type := c.GetString("med_type")
  899. id_card_type, _ := c.GetInt64("id_card_type")
  900. certificates, _ := c.GetInt64("certificates")
  901. verify_number := c.GetString("verify_number")
  902. cainfo := c.GetString("cainfo")
  903. mdtrt_grp_type := c.GetString("mdtrt_grp_type")
  904. url := c.GetString("url")
  905. ak := c.GetString("ak")
  906. var result string
  907. var inputLog string
  908. result, inputLog = service.AHyb2206(psnNo, mdtrtId, chrgBchno, certNo, insutype, total, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs, secret_key, med_type, id_card_type, certificates, url, ak, verify_number, cainfo, mdtrt_grp_type)
  909. saveJsLog(result, inputLog, "2206", "预结算", org_name)
  910. var response Response
  911. if err := json.Unmarshal([]byte(result), &response); err != nil {
  912. fmt.Println("Error decoding JSON:", err)
  913. return
  914. }
  915. if response.Code == 200 {
  916. var dat2 map[string]interface{}
  917. if err := json.Unmarshal([]byte(inputLog), &dat2); err == nil {
  918. } else {
  919. }
  920. c.ServeSuccessJSON(map[string]interface{}{
  921. "pre": response.Body,
  922. "log": dat2,
  923. "status": "1",
  924. "msg": "",
  925. })
  926. } else {
  927. c.ServeSuccessJSON(map[string]interface{}{
  928. "status": "0",
  929. "msg": response.Message,
  930. })
  931. }
  932. }
  933. func (c *AHybController) PostEight() {
  934. psnNo := c.GetString("psn_no")
  935. mdtrtId := c.GetString("mdtrt_id")
  936. chrgBchno := c.GetString("chrg_bchno")
  937. certNo := c.GetString("cert_no")
  938. insutype := c.GetString("insutype")
  939. total := c.GetString("total")
  940. org_name := c.GetString("org_name")
  941. doctor := c.GetString("doctor")
  942. fixmedins_code := c.GetString("fixmedins_code")
  943. insuplc_admdvs := c.GetString("insuplc_admdvs")
  944. mdtrtarea_admvs := c.GetString("mdtrtarea_admvs")
  945. secret_key := c.GetString("secret_key")
  946. med_type := c.GetString("med_type")
  947. id_card_type, _ := c.GetInt64("id_card_type")
  948. acct_used_flag := c.GetString("acct_used_flag")
  949. url := c.GetString("url")
  950. ak := c.GetString("ak")
  951. verify_number := c.GetString("verify_number")
  952. cainfo := c.GetString("cainfo")
  953. mdtrt_grp_type := c.GetString("mdtrt_grp_type")
  954. var result string
  955. var inputLog string
  956. result, inputLog = service.AHyb2207(psnNo, mdtrtId, chrgBchno, certNo, insutype, total, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs, secret_key, med_type, id_card_type, acct_used_flag, url, ak, verify_number, cainfo, mdtrt_grp_type)
  957. saveJsLog(result, inputLog, "2207", "结算", org_name)
  958. var response Response
  959. if err := json.Unmarshal([]byte(result), &response); err != nil {
  960. fmt.Println("Error decoding JSON:", err)
  961. return
  962. }
  963. if response.Code == 200 {
  964. var dat2 map[string]interface{}
  965. if err := json.Unmarshal([]byte(inputLog), &dat2); err == nil {
  966. } else {
  967. }
  968. c.ServeSuccessJSON(map[string]interface{}{
  969. "pre": response.Body,
  970. "log": dat2,
  971. "status": "1",
  972. "msg": "",
  973. })
  974. } else {
  975. c.ServeSuccessJSON(map[string]interface{}{
  976. "status": "0",
  977. "msg": response.Message,
  978. })
  979. }
  980. }
  981. func (c *AHybController) PostNine() {
  982. psnNo := c.GetString("psn_no")
  983. mdtrtId := c.GetString("mdtrt_id")
  984. setlId := c.GetString("setl_id")
  985. org_name := c.GetString("org_name")
  986. doctor := c.GetString("doctor")
  987. secret_key := c.GetString("secret_key")
  988. fixmedins_code := c.GetString("fixmedins_code")
  989. insuplc_admdvs := c.GetString("insuplc_admdvs")
  990. mdtrtarea_admvs := c.GetString("mdtrtarea_admvs")
  991. url := c.GetString("url")
  992. ak := c.GetString("ak")
  993. cainfo := c.GetString("cainfo")
  994. result, inputLog := service.AHyb2208(psnNo, mdtrtId, setlId, org_name, doctor, secret_key, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs, url, ak, cainfo)
  995. saveJsLog(result, inputLog, "2208", "退费", org_name)
  996. var response Response
  997. if err := json.Unmarshal([]byte(result), &response); err != nil {
  998. fmt.Println("Error decoding JSON:", err)
  999. return
  1000. }
  1001. if response.Code == 200 {
  1002. var dat2 map[string]interface{}
  1003. if err := json.Unmarshal([]byte(inputLog), &dat2); err == nil {
  1004. } else {
  1005. }
  1006. c.ServeSuccessJSON(map[string]interface{}{
  1007. "pre": response.Body,
  1008. "log": dat2,
  1009. "status": "1",
  1010. "msg": "",
  1011. })
  1012. } else {
  1013. c.ServeSuccessJSON(map[string]interface{}{
  1014. "status": "0",
  1015. "msg": response.Message,
  1016. })
  1017. }
  1018. }
  1019. func (c *AHybController) PostTen() {
  1020. psnNo := c.GetString("psn_no")
  1021. mdtrtId := c.GetString("mdtrt_id")
  1022. setlId := c.GetString("setl_id")
  1023. org_name := c.GetString("org_name")
  1024. doctor := c.GetString("doctor")
  1025. secret_key := c.GetString("secret_key")
  1026. fixmedins_code := c.GetString("fixmedins_code")
  1027. insuplc_admdvs := c.GetString("insuplc_admdvs")
  1028. mdtrtarea_admvs := c.GetString("mdtrtarea_admvs")
  1029. url := c.GetString("url")
  1030. ak := c.GetString("ak")
  1031. cainfo := c.GetString("cainfo")
  1032. baseParams := models.BaseParams{
  1033. SecretKey: secret_key,
  1034. FixmedinsCode: fixmedins_code,
  1035. InsuplcAdmdvs: insuplc_admdvs,
  1036. MdtrtareaAdmvs: mdtrtarea_admvs,
  1037. OrgName: org_name,
  1038. Doctor: doctor,
  1039. RequestUrl: url,
  1040. AccessKey: ak,
  1041. Cainfo: cainfo,
  1042. }
  1043. businessParams := models.BusinessParams{
  1044. PsnNo: psnNo,
  1045. MdtrtId: mdtrtId,
  1046. SetlId: setlId,
  1047. }
  1048. result, inputLog := service.AHyb5203(baseParams, businessParams)
  1049. saveJsLog(result, inputLog, "5203", "结算单", org_name)
  1050. var response Response
  1051. if err := json.Unmarshal([]byte(result), &response); err != nil {
  1052. fmt.Println("Error decoding JSON:", err)
  1053. return
  1054. }
  1055. if response.Code == 200 {
  1056. var dat2 map[string]interface{}
  1057. if err := json.Unmarshal([]byte(inputLog), &dat2); err == nil {
  1058. } else {
  1059. }
  1060. c.ServeSuccessJSON(map[string]interface{}{
  1061. "pre": response.Body,
  1062. "log": dat2,
  1063. "status": "1",
  1064. "msg": "",
  1065. })
  1066. } else {
  1067. c.ServeSuccessJSON(map[string]interface{}{
  1068. "status": "0",
  1069. "msg": response.Message,
  1070. })
  1071. }
  1072. }
  1073. func (c *AHybController) Get2503() {
  1074. psnNo := c.GetString("psn_no")
  1075. insutype := c.GetString("insutype")
  1076. sick_code := c.GetString("sick_code")
  1077. sick_name := c.GetString("sick_name")
  1078. insuplc_admdvs := c.GetString("insuplc_admdvs")
  1079. mdtrtarea_admvs := c.GetString("mdtrtarea_admvs")
  1080. secret_key := c.GetString("secret_key")
  1081. access_key := c.GetString("access_key")
  1082. fixmedins_code := c.GetString("fixmedins_code")
  1083. org_name := c.GetString("org_name")
  1084. check_time := c.GetString("check_time")
  1085. doctor_id := c.GetString("doctor_id")
  1086. doctor := c.GetString("doctor")
  1087. start_time := c.GetString("start_time")
  1088. end_time := c.GetString("end_time")
  1089. url := c.GetString("url")
  1090. cainfo := c.GetString("cainfo")
  1091. service.AHyb2503(psnNo, insutype, org_name, doctor, fixmedins_code, doctor_id, insuplc_admdvs, mdtrtarea_admvs, secret_key, sick_name, sick_code, start_time, end_time, check_time, url, access_key, cainfo)
  1092. }
  1093. func (c *AHybController) Get3201() {
  1094. insutype := c.GetString("insutype")
  1095. clrType := c.GetString("clr_type")
  1096. setlOptins := c.GetString("setl_optins")
  1097. stmtBegndate := c.GetString("stmt_begndate")
  1098. stmtEnddate := c.GetString("stm_enddate")
  1099. medfeeSumamt, _ := c.GetFloat("medfee_sumamt", 0)
  1100. fundPaySumamt, _ := c.GetFloat("fund_pay_sumamt", 0)
  1101. acctPay, _ := c.GetFloat("acct_pay", 0)
  1102. fixmedinsSetlCnt, _ := c.GetInt64("fixmedins_setl_cnt", 0)
  1103. fixmedins_code := c.GetString("fixmedins_code")
  1104. insuplc_admdvs := c.GetString("insuplc_admdvs")
  1105. mdtrtarea_admvs := c.GetString("mdtrtarea_admvs")
  1106. secret_key := c.GetString("secret_key")
  1107. org_name := c.GetString("org_name")
  1108. doctor := c.GetString("doctor")
  1109. url := c.GetString("url")
  1110. ak := c.GetString("ak")
  1111. cainfo := c.GetString("cainfo")
  1112. result, inputLog := service.AHyb3201(fixmedinsSetlCnt, acctPay, fundPaySumamt, medfeeSumamt, stmtBegndate, stmtEnddate, setlOptins, clrType, insutype, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs, url, ak, secret_key, cainfo)
  1113. saveJsLog(result, inputLog, "3201", "对总账", org_name)
  1114. var response Response
  1115. if err := json.Unmarshal([]byte(result), &response); err != nil {
  1116. fmt.Println("Error decoding JSON:", err)
  1117. return
  1118. }
  1119. if response.Code == 200 {
  1120. var dat2 map[string]interface{}
  1121. if err := json.Unmarshal([]byte(inputLog), &dat2); err == nil {
  1122. } else {
  1123. }
  1124. c.ServeSuccessJSON(map[string]interface{}{
  1125. "pre": response.Body,
  1126. "log": dat2,
  1127. "status": "1",
  1128. "msg": "",
  1129. })
  1130. } else {
  1131. c.ServeSuccessJSON(map[string]interface{}{
  1132. "status": "0",
  1133. "msg": response.Message,
  1134. })
  1135. }
  1136. }
  1137. type ELeData struct {
  1138. Data struct {
  1139. SiNo string `json:"si_no"`
  1140. SiCardNo string `json:"si_card_no"`
  1141. SiCardIssueArea string `json:"si_card_issue_area"`
  1142. Name string `json:"name"`
  1143. Gender string `json:"gender"`
  1144. IdType string `json:"id_type"`
  1145. IdNo string `json:"id_no"`
  1146. EcCardToken string `json:"ecCardToken"`
  1147. } `json:"data"`
  1148. Code int `json:"code"`
  1149. Message string `json:"message"`
  1150. }
  1151. type ELeCertData struct {
  1152. Data struct {
  1153. Extra string `json:"extra"`
  1154. IDNo string `json:"idNo"`
  1155. IDType string `json:"idType"`
  1156. EcToken string `json:"ecToken"`
  1157. InsuOrg string `json:"insuOrg"`
  1158. UserName string `json:"userName"`
  1159. EcIndexNo string `json:"ecIndexNo"`
  1160. Gender string `json:"gender"`
  1161. Birthday string `json:"birthday"`
  1162. Nationality string `json:"nationality"`
  1163. Email string `json:"email"`
  1164. } `json:"data"`
  1165. Code int `json:"code"`
  1166. Message string `json:"message"`
  1167. }
  1168. func (c *AHybController) ReadCard() {
  1169. fixmedins_code := c.GetString("fixmedins_code")
  1170. secret_key := c.GetString("secret_key")
  1171. ak := c.GetString("ak")
  1172. org_name := c.GetString("org_name")
  1173. doctor := c.GetString("doctor")
  1174. insuplc_admdvs := c.GetString("insuplc_admdvs")
  1175. mdtrtarea_admvs := c.GetString("mdtrtarea_admvs")
  1176. url := c.GetString("url")
  1177. cainfo := c.GetString("cainfo")
  1178. id_card_type := c.GetString("id_card_type")
  1179. operator_id := c.GetString("operator_id")
  1180. operator := c.GetString("operator")
  1181. //result, request := service.AHyb9001(org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs, secret_key, 1, url, cainfo, ak)
  1182. //fmt.Println(request)
  1183. //fmt.Println(result)
  1184. //c.TestGetBasBaseInit(fixmedins_code, secret_key, ak)
  1185. switch id_card_type {
  1186. case "1":
  1187. pCardInfo := c.GetBasBaseInfo()
  1188. pCardInfo = Remove0000(pCardInfo)
  1189. fmt.Println(":", ConvertToString(pCardInfo, "gbk", "utf-8"))
  1190. fmt.Println(pCardInfo)
  1191. bas := strings.Split(pCardInfo, "|")
  1192. basNumber := bas[2]
  1193. id_card_no := bas[1]
  1194. card_sn := bas[3]
  1195. id_card_type_int, _ := strconv.ParseInt(id_card_type, 10, 64)
  1196. if len(pCardInfo) > 0 {
  1197. result, _ := service.AHyb1101A(basNumber, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs, secret_key, id_card_type_int, card_sn, "1", url, ak, id_card_no, cainfo)
  1198. var response Response
  1199. if err := json.Unmarshal([]byte(result), &response); err != nil {
  1200. fmt.Println("Error decoding JSON:", err)
  1201. return
  1202. }
  1203. if response.Code == 200 {
  1204. c.ServeSuccessJSON(map[string]interface{}{
  1205. "status": "0",
  1206. "card_info": pCardInfo,
  1207. "result": response.Body,
  1208. "type": "1",
  1209. })
  1210. } else {
  1211. c.ServeSuccessJSON(map[string]interface{}{
  1212. "status": "0",
  1213. "msg": response.Message,
  1214. })
  1215. }
  1216. } else {
  1217. c.ServeSuccessJSON(map[string]interface{}{
  1218. "status": "-1",
  1219. })
  1220. }
  1221. break
  1222. case "3": //电子社保卡
  1223. _, pBusiCardInfo := c.GetELeInfo(fixmedins_code, operator_id, operator)
  1224. //fmt.Println(pCardInfo)
  1225. fmt.Println(pBusiCardInfo)
  1226. pBusiCardInfo = Remove0000(pBusiCardInfo)
  1227. //pCardInfo = Remove0000(pCardInfo)
  1228. var ele ELeData
  1229. err := json.Unmarshal([]byte(pBusiCardInfo), &ele)
  1230. if err != nil {
  1231. utils.ErrorLog("解析失败:%v", err)
  1232. }
  1233. token := ele.Data.EcCardToken
  1234. if len(token) > 0 {
  1235. result, _ := service.AHyb1101B(org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs, secret_key, url, ak, token, cainfo, ele.Data.IdNo)
  1236. var dat map[string]interface{}
  1237. if err := json.Unmarshal([]byte(result), &dat); err == nil {
  1238. fmt.Println(dat)
  1239. } else {
  1240. fmt.Println(err)
  1241. }
  1242. c.ServeSuccessJSON(map[string]interface{}{
  1243. "status": "0",
  1244. //"card_info": pCardInfo,
  1245. "busi_card_info": pBusiCardInfo,
  1246. "token": token,
  1247. "result": dat,
  1248. "type": "2",
  1249. })
  1250. } else {
  1251. c.ServeSuccessJSON(map[string]interface{}{
  1252. "status": "-1",
  1253. })
  1254. }
  1255. break
  1256. case "4": //电子凭证
  1257. fmt.Println(operator_id)
  1258. fmt.Println(operator)
  1259. _, pBusiCardInfo := c.GetELeCertInfoTwo(fixmedins_code, operator_id, operator)
  1260. fmt.Println(pBusiCardInfo)
  1261. pBusiCardInfo = Remove0000(pBusiCardInfo)
  1262. var ele ELeCertData
  1263. err := json.Unmarshal([]byte(pBusiCardInfo), &ele)
  1264. if err != nil {
  1265. utils.ErrorLog("解析失败:%v", err)
  1266. }
  1267. token := ele.Data.EcToken
  1268. fmt.Println(token)
  1269. if len(token) > 0 {
  1270. userName := ele.Data.UserName
  1271. fmt.Println(userName)
  1272. userName = Remove0000(userName)
  1273. userName = DeleteExtraSpace(userName)
  1274. fmt.Println(userName)
  1275. enc := mahonia.NewEncoder("gbk")
  1276. fmt.Println(enc.ConvertString(userName))
  1277. result, _ := service.AHyb1101ForEleCert(org_name, doctor, fixmedins_code, ele.Data.InsuOrg, mdtrtarea_admvs, secret_key, url, ak, token, cainfo, ele.Data.IDNo, userName)
  1278. var response Response
  1279. if err := json.Unmarshal([]byte(result), &response); err != nil {
  1280. fmt.Println("Error decoding JSON:", err)
  1281. return
  1282. }
  1283. if response.Code == 200 {
  1284. c.ServeSuccessJSON(map[string]interface{}{
  1285. "status": "1",
  1286. "card_info": "",
  1287. "busi_card_info": pBusiCardInfo,
  1288. "token": token,
  1289. "result": response.Body,
  1290. })
  1291. } else {
  1292. c.ServeSuccessJSON(map[string]interface{}{
  1293. "status": "0",
  1294. "msg": response.Message,
  1295. })
  1296. }
  1297. } else {
  1298. c.ServeSuccessJSON(map[string]interface{}{
  1299. "status": "-1",
  1300. })
  1301. }
  1302. break
  1303. }
  1304. }
  1305. func (c *AHybController) TestGetBasBaseInit(code string, secret_key string, ak string) {
  1306. DllDef := syscall.MustLoadDLL("HeaSecReadInfo.dll")
  1307. Iinit := DllDef.MustFindProc("Init")
  1308. //miConfig, _ := service.FindMedicalInsuranceInfo(c.GetAdminUserInfo().CurrentOrgId)
  1309. str := make([]byte, 2048)
  1310. inputData := make(map[string]interface{})
  1311. inputData["IP"] = "10.58.65.240"
  1312. inputData["PORT"] = "8086"
  1313. inputData["TIMEOUT"] = "180"
  1314. inputData["LOG_PATH"] = "C:\\log\\"
  1315. //inputData["EC_URL"] = "http://10.58.33.207:10086/localcfc/api/hsecfc/localQrCodeQuery"
  1316. inputData["EC_URL"] = "http://10.58.33.207:10086/localcfc/api/hsecfc/localQrCodeQuery"
  1317. inputData["CARD_PASSTYPE"] = "1"
  1318. inputData["API_NAME"] = "hssServives"
  1319. inputData["API_VERSION"] = "1.0.0"
  1320. inputData["ACCESS_KEY"] = ak
  1321. inputData["SECRETKEY"] = secret_key
  1322. inputData["ORG_ID"] = code
  1323. inputData["EXT"] = ""
  1324. bytesData, _ := json.Marshal(inputData)
  1325. fmt.Println(inputData)
  1326. fmt.Println(bytesData)
  1327. ret, _, err := Iinit.Call((uintptr)(unsafe.Pointer(&bytesData[0])), (uintptr)(unsafe.Pointer(&str[0])))
  1328. if ret != 0 {
  1329. fmt.Println("SSCard的报错原因:", err)
  1330. fmt.Println("SSCard的运算结果为:", ret)
  1331. fmt.Println("SSCard的返回结果为:", string(str))
  1332. c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeReadCardException)
  1333. return
  1334. }
  1335. fmt.Println("SSCard的返回结果为:", string(str))
  1336. result := int(ret)
  1337. fmt.Println("SSCard的运算结果为1:", result)
  1338. //initFlag = 1
  1339. return
  1340. }
  1341. func (c *AHybController) GetBasBaseInfo() string {
  1342. DllDef := syscall.MustLoadDLL("SSCardDriver.dll")
  1343. readCard := DllDef.MustFindProc("iReadCardBas")
  1344. fmt.Println(readCard)
  1345. fmt.Println("!!!!!")
  1346. pCardInfo := make([]byte, 2048)
  1347. ret2, _, _ := readCard.Call(uintptr(3), (uintptr)(unsafe.Pointer(&pCardInfo[0])))
  1348. fmt.Println(ret2)
  1349. fmt.Println(DeleteExtraSpace(string(pCardInfo)))
  1350. fmt.Println(":", ConvertToString(DeleteExtraSpace(string(pCardInfo)), "gbk", "utf-8"))
  1351. if ret2 != 0 {
  1352. return ""
  1353. }
  1354. return DeleteExtraSpace(string(pCardInfo))
  1355. }
  1356. func (c *AHybController) GetELeInfo(code string, operator_id string, operator_name string) (string, string) {
  1357. DllDef := syscall.MustLoadDLL("HeaSecReadInfo.dll")
  1358. readCard := DllDef.MustFindProc("EcCardQuery")
  1359. fmt.Println(readCard)
  1360. fmt.Println("!!!!!")
  1361. //pCardInfo := make([]byte, 8192)
  1362. pBusiCardInfo := make([]byte, 8192)
  1363. //data := make(map[string]interface{})
  1364. //pData := make(map[string]interface{})
  1365. //inputData := make(map[string]interface{})
  1366. //inputData["orgId"] = code
  1367. //inputData["businessType"] = "01101"
  1368. //inputData["operatorId"] = operator_id
  1369. //inputData["operatorName"] = operator_name
  1370. //inputData["officeId"] = "001"
  1371. //inputData["officeName"] = "血透室"
  1372. //data["data"] = inputData
  1373. //data["transType"] = "ec.query"
  1374. //data["orgId"] = code
  1375. //bytesData, _ := json.Marshal(data)
  1376. //pCardInfo = bytesData
  1377. ret2, _, _ := readCard.Call((uintptr)(unsafe.Pointer(&pBusiCardInfo[0])))
  1378. fmt.Println(ret2)
  1379. //fmt.Println(DeleteExtraSpace(string(bytesData)))
  1380. fmt.Println(DeleteExtraSpace(string(pBusiCardInfo)))
  1381. //fmt.Println(":", ConvertToString(DeleteExtraSpace(string(bytesData)), "gbk", "utf-8"))
  1382. fmt.Println(":", ConvertToString(DeleteExtraSpace(string(pBusiCardInfo)), "gbk", "utf-8"))
  1383. if ret2 != 0 {
  1384. return "", ""
  1385. }
  1386. return DeleteExtraSpace(""), DeleteExtraSpace(string(pBusiCardInfo))
  1387. }
  1388. func (c *AHybController) GetELeCertInfoFour1(code string, operator_id string, operator_name string) (string, string) {
  1389. DllDef := syscall.MustLoadDLL("NationEcCode.dll")
  1390. readCard := DllDef.MustFindProc("EcQuery")
  1391. pCardInfo := make([]byte, 8192)
  1392. pBusiCardInfo := make([]byte, 8192)
  1393. data := make(map[string]interface{})
  1394. inputData := make(map[string]interface{})
  1395. inputData["orgId"] = code
  1396. inputData["businessType"] = "01301"
  1397. inputData["operatorId"] = operator_id
  1398. inputData["operatorName"] = operator_name
  1399. inputData["officeId"] = "001"
  1400. inputData["officeName"] = "xuetou"
  1401. data["data"] = inputData
  1402. data["transType"] = "ec.query"
  1403. data["orgId"] = code
  1404. bytesData, _ := json.Marshal(data)
  1405. pCardInfo = bytesData
  1406. pCardInfo = []byte(ConvertByte2String(pCardInfo, GB18030))
  1407. ret2, _, _ := readCard.Call((uintptr)(unsafe.Pointer(&pCardInfo[0])), (uintptr)(unsafe.Pointer(&pBusiCardInfo[0])))
  1408. fmt.Println(ret2)
  1409. fmt.Println(":", ConvertToString(DeleteExtraSpace(string(bytesData)), "gbk", "utf-8"))
  1410. fmt.Println(":", ConvertToString(DeleteExtraSpace(string(pBusiCardInfo)), "gbk", "utf-8"))
  1411. if ret2 != 0 {
  1412. return "", ""
  1413. }
  1414. return ConvertByte2String([]byte(DeleteExtraSpace(string(bytesData))), GB18030), ConvertByte2String([]byte(DeleteExtraSpace(string(pBusiCardInfo))), GB18030)
  1415. }
  1416. func (c *AHybController) GetELeCertInfoFour(code string, operator_id string, operator_name string) (string, string) {
  1417. DllDef := syscall.MustLoadDLL("HeaSecReadInfo.dll")
  1418. readCard := DllDef.MustFindProc("GetPersonInfo")
  1419. pCardInfo := make([]byte, 8192)
  1420. pBusiCardInfo := make([]byte, 8192)
  1421. data := make(map[string]interface{})
  1422. inputData := make(map[string]interface{})
  1423. inputData["orgId"] = code
  1424. inputData["businessType"] = "01301"
  1425. inputData["operatorId"] = operator_id
  1426. inputData["operatorName"] = operator_name
  1427. inputData["officeId"] = "001"
  1428. inputData["officeName"] = "xuetou"
  1429. data["data"] = inputData
  1430. data["transType"] = "ec.query"
  1431. data["orgId"] = code
  1432. bytesData, _ := json.Marshal(data)
  1433. pCardInfo = bytesData
  1434. pCardInfo = []byte(ConvertByte2String(pCardInfo, GB18030))
  1435. ret2, _, _ := readCard.Call((uintptr)(unsafe.Pointer(&pCardInfo[0])), (uintptr)(unsafe.Pointer(&pBusiCardInfo[0])))
  1436. fmt.Println(ret2)
  1437. fmt.Println(":", ConvertToString(DeleteExtraSpace(string(bytesData)), "gbk", "utf-8"))
  1438. fmt.Println(":", ConvertToString(DeleteExtraSpace(string(pBusiCardInfo)), "gbk", "utf-8"))
  1439. if ret2 != 0 {
  1440. return "", ""
  1441. }
  1442. return ConvertByte2String([]byte(DeleteExtraSpace(string(bytesData))), GB18030), ConvertByte2String([]byte(DeleteExtraSpace(string(pBusiCardInfo))), GB18030)
  1443. }
  1444. func (c *AHybController) GetELeCertInfoFour2223(code string, operator_id string, operator_name string) (string, string) {
  1445. DllDef := syscall.MustLoadDLL("HeaSecReadInfo.dll")
  1446. readCard := DllDef.MustFindProc("GetPersonInfo")
  1447. pCardInfo := make([]byte, 8192)
  1448. pBusiCardInfo := make([]byte, 8192)
  1449. data := make(map[string]interface{})
  1450. inputData := make(map[string]interface{})
  1451. inputData["orgId"] = code
  1452. inputData["businessType"] = "01101"
  1453. inputData["operatorId"] = operator_id
  1454. inputData["operatorName"] = operator_name
  1455. inputData["officeId"] = "001"
  1456. inputData["officeName"] = "xuetou"
  1457. data["data"] = inputData
  1458. data["transType"] = "ec.query"
  1459. data["orgId"] = code
  1460. bytesData, _ := json.Marshal(data)
  1461. pCardInfo = bytesData
  1462. pCardInfo = []byte(ConvertByte2String(pCardInfo, GB18030))
  1463. ret2, _, _ := readCard.Call((uintptr)(unsafe.Pointer(&pCardInfo[0])), (uintptr)(unsafe.Pointer(&pBusiCardInfo[0])))
  1464. fmt.Println(ret2)
  1465. fmt.Println(":", ConvertToString(DeleteExtraSpace(string(bytesData)), "gbk", "utf-8"))
  1466. fmt.Println(":", ConvertToString(DeleteExtraSpace(string(pBusiCardInfo)), "gbk", "utf-8"))
  1467. if ret2 != 0 {
  1468. return "", ""
  1469. }
  1470. return ConvertByte2String([]byte(DeleteExtraSpace(string(bytesData))), GB18030), ConvertByte2String([]byte(DeleteExtraSpace(string(pBusiCardInfo))), GB18030)
  1471. }
  1472. func (c *AHybController) GetELeCertInfoTwo(code string, operator_id string, operator_name string) (string, string) {
  1473. // WebSocket服务器地址
  1474. serverURL := "ws://127.0.0.1:8899"
  1475. // 解析WebSocket服务器地址
  1476. u, err := url.Parse(serverURL)
  1477. if err != nil {
  1478. log.Fatal(err)
  1479. }
  1480. // 建立WebSocket连接
  1481. conn, _, err := websocket.DefaultDialer.Dial(u.String(), nil)
  1482. if err != nil {
  1483. log.Fatal(err)
  1484. }
  1485. defer conn.Close()
  1486. input2 := make(map[string]interface{})
  1487. input := make(map[string]interface{})
  1488. inputData := make(map[string]interface{})
  1489. inputData["orgId"] = code
  1490. inputData["businessType"] = "01101"
  1491. inputData["operatorId"] = operator_id
  1492. inputData["operatorName"] = operator_name
  1493. inputData["officeId"] = "001"
  1494. inputData["officeName"] = "血透室"
  1495. inputData["deviceType"] = ""
  1496. input["data"] = inputData
  1497. input["orgId"] = code
  1498. input["transType"] = "ec.query"
  1499. input2["url"] = "http://10.66.159.55:8080/localcfc/api/hsecfc/localQrCodeQuery"
  1500. input2["indata"] = input
  1501. bytesData, _ := json.Marshal(input2)
  1502. err = conn.WriteMessage(websocket.TextMessage, bytesData)
  1503. if err != nil {
  1504. fmt.Println(err)
  1505. }
  1506. // 接收消息
  1507. _, receivedMessage, err := conn.ReadMessage()
  1508. if err != nil {
  1509. fmt.Println(err)
  1510. }
  1511. return "", string(receivedMessage)
  1512. }
  1513. func (c *AHybController) GetELeCertInfoThree(code string, operator_id string, operator_name string) (string, string) {
  1514. // WebSocket服务器地址
  1515. serverURL := "ws://127.0.0.1:8899"
  1516. // 解析WebSocket服务器地址
  1517. u, err := url.Parse(serverURL)
  1518. if err != nil {
  1519. log.Fatal(err)
  1520. }
  1521. // 建立WebSocket连接
  1522. conn, _, err := websocket.DefaultDialer.Dial(u.String(), nil)
  1523. if err != nil {
  1524. log.Fatal(err)
  1525. }
  1526. defer conn.Close()
  1527. input2 := make(map[string]interface{})
  1528. input := make(map[string]interface{})
  1529. inputData := make(map[string]interface{})
  1530. inputData["orgId"] = code
  1531. inputData["businessType"] = "01301"
  1532. inputData["operatorId"] = operator_id
  1533. inputData["operatorName"] = operator_name
  1534. inputData["officeId"] = "001"
  1535. inputData["officeName"] = "血透室"
  1536. inputData["deviceType"] = ""
  1537. input["data"] = inputData
  1538. input["orgId"] = code
  1539. input["transType"] = "ec.query"
  1540. input2["url"] = "http://10.66.159.55:8080/localcfc/api/hsecfc/localQrCodeQuery"
  1541. input2["indata"] = input
  1542. bytesData, _ := json.Marshal(input2)
  1543. err = conn.WriteMessage(websocket.TextMessage, bytesData)
  1544. if err != nil {
  1545. fmt.Println(err)
  1546. }
  1547. // 接收消息
  1548. _, receivedMessage, err := conn.ReadMessage()
  1549. if err != nil {
  1550. fmt.Println(err)
  1551. }
  1552. return "", string(receivedMessage)
  1553. }
  1554. func IntPtr(n int) uintptr {
  1555. return uintptr(n)
  1556. }
  1557. func StrPtr(s string) uintptr {
  1558. return uintptr(unsafe.Pointer(syscall.StringBytePtr(s)))
  1559. }
  1560. type Charset string
  1561. const (
  1562. UTF8 = Charset("UTF-8")
  1563. GB18030 = Charset("GB18030")
  1564. )
  1565. func ConvertToString(src string, srcCode string, tagCode string) string {
  1566. srcCoder := mahonia.NewDecoder(srcCode)
  1567. srcResult := srcCoder.ConvertString(src)
  1568. tagCoder := mahonia.NewDecoder(tagCode)
  1569. _, cdata, _ := tagCoder.Translate([]byte(srcResult), true)
  1570. result := string(cdata)
  1571. return result
  1572. }
  1573. func DeleteExtraSpace(s string) string {
  1574. //删除字符串中的多余空格,有多个空格时,仅保留一个空格
  1575. s1 := strings.Replace(s, " ", " ", -1) //替换tab为空格
  1576. regstr := "\\s{2,}" //两个及两个以上空格的正则表达式
  1577. reg, _ := regexp.Compile(regstr) //编译正则表达式
  1578. s2 := make([]byte, len(s1)) //定义字符数组切片
  1579. copy(s2, s1) //将字符串复制到切片
  1580. spc_index := reg.FindStringIndex(string(s2)) //在字符串中搜索
  1581. for len(spc_index) > 0 { //找到适配项
  1582. s2 = append(s2[:spc_index[0]+1], s2[spc_index[1]:]...) //删除多余空格
  1583. spc_index = reg.FindStringIndex(string(s2)) //继续在字符串中搜索
  1584. }
  1585. return string(s2)
  1586. }
  1587. func Remove0000(s string) string {
  1588. str := make([]rune, 0, len(s))
  1589. for _, v := range []rune(s) {
  1590. if v == 0 {
  1591. continue
  1592. }
  1593. str = append(str, v)
  1594. }
  1595. return string(str)
  1596. }
  1597. func saveJsLog(result string, request string, infno string, desc string, org_name string) {
  1598. //org_id, _ := beego.AppConfig.Int64("org_id")
  1599. //miConfig, _ := service.FindMedicalInsuranceInfo(org_id)
  1600. dir := org_name + "日志"
  1601. utils.Mkdir(dir)
  1602. month := time.Unix(1557042972, 0).Format("1")
  1603. year := time.Now().Format("2006")
  1604. month = time.Now().Format("01")
  1605. day := time.Now().Format("02")
  1606. hour := time.Now().Format("15")
  1607. min := time.Now().Format("04")
  1608. sec := time.Now().Format("05")
  1609. result_time := year + "-" + month + "-" + day + " " + hour + ":" + min + ":" + sec
  1610. file := org_name + "_" + year + month + day + "_log"
  1611. file_name := file + ".txt"
  1612. file_path := org_name + "日志" + "/" + file_name
  1613. exist, _ := utils.PathExists(file_path)
  1614. if exist { //存在
  1615. fmt.Println("存在")
  1616. f, err := os.OpenFile(file_path, os.O_WRONLY, 0644)
  1617. if err != nil {
  1618. fmt.Println("read fail")
  1619. }
  1620. content := "\r\n" + "\r\n" + "\r\n" + result_time + " " + "【 " + desc + infno + "入参" + " 】:" + "\r\n" + request + "\r\n" + result_time + " " + "【 " + desc + infno + "出参" + " 】:" + "\r\n" + result
  1621. n, _ := f.Seek(0, 2)
  1622. _, err = f.WriteAt([]byte(content), n)
  1623. } else { //不存在
  1624. fmt.Println("文件不存在,创建文件")
  1625. f, err := os.Create(org_name + "日志" + "/" + file_name)
  1626. defer f.Close()
  1627. if err != nil {
  1628. } else {
  1629. _, err = f.Write([]byte("记录日志"))
  1630. }
  1631. }
  1632. }
  1633. func (c *AHybController) Get3101() {
  1634. body, _ := ioutil.ReadAll(c.Ctx.Request.Body)
  1635. var respJSON map[string]interface{}
  1636. if err := json.Unmarshal([]byte(string(body)), &respJSON); err != nil {
  1637. utils.ErrorLog("接口返回数据解析JSON失败: %v", err)
  1638. return
  1639. }
  1640. pdUserJSONBytes, _ := json.Marshal(respJSON["pd"])
  1641. var pd models.PatientDtos
  1642. if err := json.Unmarshal(pdUserJSONBytes, &pd); err != nil {
  1643. utils.ErrorLog("解析失败:%v", err)
  1644. return
  1645. }
  1646. fedUserJSONBytes, _ := json.Marshal(respJSON["fed"])
  1647. var fed models.FsiEncounterDtos
  1648. if err := json.Unmarshal(fedUserJSONBytes, &fed); err != nil {
  1649. utils.ErrorLog("解析失败:%v", err)
  1650. return
  1651. }
  1652. fddUserJSONBytes, _ := json.Marshal(respJSON["fdd"])
  1653. var fdd []*models.FsiDiagnoseDtos
  1654. if err := json.Unmarshal(fddUserJSONBytes, &fdd); err != nil {
  1655. utils.ErrorLog("解析失败:%v", err)
  1656. return
  1657. }
  1658. fodUserJSONBytes, _ := json.Marshal(respJSON["fod"])
  1659. var fod []*models.FsiOrderDtos
  1660. if err := json.Unmarshal(fodUserJSONBytes, &fod); err != nil {
  1661. utils.ErrorLog("解析失败:%v", err)
  1662. return
  1663. }
  1664. fopdUserJSONBytes, _ := json.Marshal(respJSON["fopd"])
  1665. var fopd []*models.FsiOperationDtosData
  1666. if err := json.Unmarshal(fopdUserJSONBytes, &fopd); err != nil {
  1667. utils.ErrorLog("解析失败:%v", err)
  1668. return
  1669. }
  1670. ppUserJSONBytes, _ := json.Marshal(respJSON["pp"])
  1671. var pp models.PublicParams
  1672. if err := json.Unmarshal(ppUserJSONBytes, &pp); err != nil {
  1673. utils.ErrorLog("解析失败:%v", err)
  1674. return
  1675. }
  1676. inputLog, result := service.AHyb3101(pd, fed, fdd, fod, fopd, pp, respJSON["trig_scen"].(string))
  1677. var response Response
  1678. if err := json.Unmarshal([]byte(result), &response); err != nil {
  1679. fmt.Println("Error decoding JSON:", err)
  1680. return
  1681. }
  1682. if response.Code == 200 {
  1683. var dat2 map[string]interface{}
  1684. if err := json.Unmarshal([]byte(inputLog), &dat2); err == nil {
  1685. } else {
  1686. }
  1687. c.ServeSuccessJSON(map[string]interface{}{
  1688. "pre": response.Body,
  1689. "log": dat2,
  1690. "status": 1,
  1691. "msg": "",
  1692. })
  1693. } else {
  1694. c.ServeSuccessJSON(map[string]interface{}{
  1695. "status": 0,
  1696. "msg": response.Message,
  1697. })
  1698. }
  1699. }
  1700. func (c *AHybController) Get3102() {
  1701. body, _ := ioutil.ReadAll(c.Ctx.Request.Body)
  1702. var respJSON map[string]interface{}
  1703. if err := json.Unmarshal([]byte(string(body)), &respJSON); err != nil {
  1704. utils.ErrorLog("接口返回数据解析JSON失败: %v", err)
  1705. return
  1706. }
  1707. pdUserJSONBytes, _ := json.Marshal(respJSON["pd"])
  1708. var pd models.PatientDtos
  1709. if err := json.Unmarshal(pdUserJSONBytes, &pd); err != nil {
  1710. utils.ErrorLog("解析失败:%v", err)
  1711. return
  1712. }
  1713. fedUserJSONBytes, _ := json.Marshal(respJSON["fed"])
  1714. var fed models.FsiEncounterDtos
  1715. if err := json.Unmarshal(fedUserJSONBytes, &fed); err != nil {
  1716. utils.ErrorLog("解析失败:%v", err)
  1717. return
  1718. }
  1719. fddUserJSONBytes, _ := json.Marshal(respJSON["fdd"])
  1720. var fdd []*models.FsiDiagnoseDtos
  1721. if err := json.Unmarshal(fddUserJSONBytes, &fdd); err != nil {
  1722. utils.ErrorLog("解析失败:%v", err)
  1723. return
  1724. }
  1725. fodUserJSONBytes, _ := json.Marshal(respJSON["fod"])
  1726. var fod []*models.FsiOrderDtos
  1727. if err := json.Unmarshal(fodUserJSONBytes, &fod); err != nil {
  1728. utils.ErrorLog("解析失败:%v", err)
  1729. return
  1730. }
  1731. fopdUserJSONBytes, _ := json.Marshal(respJSON["fopd"])
  1732. var fopd []*models.FsiOperationDtosData
  1733. if err := json.Unmarshal(fopdUserJSONBytes, &fopd); err != nil {
  1734. utils.ErrorLog("解析失败:%v", err)
  1735. return
  1736. }
  1737. ppUserJSONBytes, _ := json.Marshal(respJSON["pp"])
  1738. var pp models.PublicParams
  1739. if err := json.Unmarshal(ppUserJSONBytes, &pp); err != nil {
  1740. utils.ErrorLog("解析失败:%v", err)
  1741. return
  1742. }
  1743. _, result := service.AHyb3102(pd, fed, fdd, fod, fopd, pp, respJSON["trig_scen"].(string))
  1744. var response Response
  1745. if err := json.Unmarshal([]byte(result), &response); err != nil {
  1746. fmt.Println("Error decoding JSON:", err)
  1747. return
  1748. }
  1749. if response.Code == 200 {
  1750. c.ServeSuccessJSON(map[string]interface{}{
  1751. "pre": response.Body,
  1752. "status": 1,
  1753. "msg": "",
  1754. })
  1755. } else {
  1756. c.ServeSuccessJSON(map[string]interface{}{
  1757. "status": 0,
  1758. "msg": response.Message,
  1759. })
  1760. }
  1761. }
  1762. func (c *AHybController) Get4101() {
  1763. body, _ := ioutil.ReadAll(c.Ctx.Request.Body)
  1764. var respJSON map[string]interface{}
  1765. if err := json.Unmarshal([]byte(string(body)), &respJSON); err != nil {
  1766. utils.ErrorLog("接口返回数据解析JSON失败: %v", err)
  1767. return
  1768. }
  1769. struct4101UserJSONBytes, _ := json.Marshal(respJSON["struct4101"])
  1770. var struct4101 service.Struct4101
  1771. if err := json.Unmarshal(struct4101UserJSONBytes, &struct4101); err != nil {
  1772. utils.ErrorLog("解析失败:%v", err)
  1773. return
  1774. }
  1775. ppUserJSONBytes, _ := json.Marshal(respJSON["pp"])
  1776. var pp models.PublicParams
  1777. if err := json.Unmarshal(ppUserJSONBytes, &pp); err != nil {
  1778. utils.ErrorLog("解析失败:%v", err)
  1779. return
  1780. }
  1781. inputLog, result := service.AHyb4101(struct4101, pp)
  1782. saveJsLog(result, inputLog, "4101", "上传明细清单", pp.FixmedinsName)
  1783. var response Response
  1784. if err := json.Unmarshal([]byte(result), &response); err != nil {
  1785. fmt.Println("Error decoding JSON:", err)
  1786. return
  1787. }
  1788. if response.Code == 200 {
  1789. var dat2 map[string]interface{}
  1790. if err := json.Unmarshal([]byte(inputLog), &dat2); err == nil {
  1791. } else {
  1792. }
  1793. c.ServeSuccessJSON(map[string]interface{}{
  1794. "pre": response.Body,
  1795. "log": dat2,
  1796. "status": 1,
  1797. "msg": "",
  1798. })
  1799. } else {
  1800. c.ServeSuccessJSON(map[string]interface{}{
  1801. "status": 0,
  1802. "msg": response.Message,
  1803. })
  1804. }
  1805. }
  1806. func ConvertByte2String(byte []byte, charset Charset) string {
  1807. var str string
  1808. switch charset {
  1809. case GB18030:
  1810. decodeBytes, _ := simplifiedchinese.GB18030.NewDecoder().Bytes(byte)
  1811. str = string(decodeBytes)
  1812. case UTF8:
  1813. fallthrough
  1814. default:
  1815. str = string(byte)
  1816. }
  1817. return str
  1818. }