ahyb_controller.go 68KB

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