dialysis_record_api_controller.go 68KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681
  1. package controllers
  2. import (
  3. "XT_New/models"
  4. "encoding/json"
  5. "github.com/jinzhu/gorm"
  6. "math"
  7. "strconv"
  8. "time"
  9. "XT_New/enums"
  10. "XT_New/service"
  11. "XT_New/utils"
  12. "fmt"
  13. "github.com/astaxie/beego"
  14. "net/http"
  15. "net/url"
  16. )
  17. func DialysisRecordAPIControllerRegistRouter() {
  18. beego.Router("/api/dialysis/initdata", &DialysisRecordAPIController{}, "get:RecordInitData")
  19. beego.Router("/api/dialysis/schedules", &DialysisRecordAPIController{}, "get:GetSchedules")
  20. beego.Router("/api/dislysis/schedule", &DialysisRecordAPIController{}, "get:DialysisSchedule")
  21. beego.Router("/api/dislysis/monitor/edit", &DialysisRecordAPIController{}, "post:EditMonitor")
  22. beego.Router("/api/dialysis/start_record", &DialysisRecordAPIController{}, "post:StartDialysis")
  23. beego.Router("/api/dialysis/finish", &DialysisRecordAPIController{}, "post:FinishDialysis")
  24. beego.Router("/api/start_dialysis/modify", &DialysisRecordAPIController{}, "post:ModifyStartDialysis")
  25. beego.Router("/api/finish_dialysis/modify", &DialysisRecordAPIController{}, "post:ModifyFinishDialysis")
  26. }
  27. type DialysisRecordAPIController struct {
  28. BaseAuthAPIController
  29. }
  30. // /api/dialysis/initdata [get]
  31. func (this *DialysisRecordAPIController) RecordInitData() {
  32. adminInfo := this.GetAdminUserInfo()
  33. orgID := adminInfo.CurrentOrgId
  34. now := time.Now()
  35. ymdDate, _ := utils.ParseTimeStringToTime("2006-01-02", now.Format("2006-01-02"))
  36. schedules, getSchedulesErr := service.GetDialysisScheduals(orgID, ymdDate.Unix())
  37. if getSchedulesErr != nil {
  38. this.ErrorLog("获取排班信息失败:%v", getSchedulesErr)
  39. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
  40. return
  41. }
  42. zones, getZonesErr := service.GetAllValidDeviceZones(orgID)
  43. if getZonesErr != nil {
  44. this.ErrorLog("获取全部分区失败:%v", getZonesErr)
  45. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
  46. return
  47. }
  48. this.ServeSuccessJSON(map[string]interface{}{
  49. "schedules": schedules,
  50. "zones": zones,
  51. })
  52. }
  53. // /api/dialysis/schedules [get]
  54. // @param date:string (yyyy-mm-dd)
  55. func (this *DialysisRecordAPIController) GetSchedules() {
  56. schedualDate := this.GetString("date")
  57. date, parseDateErr := utils.ParseTimeStringToTime("2006-01-02", schedualDate)
  58. if parseDateErr != nil {
  59. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
  60. return
  61. }
  62. adminInfo := this.GetAdminUserInfo()
  63. orgID := adminInfo.CurrentOrgId
  64. redis := service.RedisClient()
  65. defer redis.Close()
  66. key := "scheduals_" + schedualDate + "_" + strconv.FormatInt(orgID, 10)
  67. scheduals_json_str, _ := redis.Get(key).Result()
  68. if len(scheduals_json_str) == 0 { //没有到缓存数据,从数据库中获取数据,进行缓存到redis
  69. scheduals, err := service.GetDialysisSchedualsOne(orgID, date.Unix())
  70. if err != nil {
  71. this.ErrorLog("获取排班信息失败:%v", err)
  72. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
  73. } else {
  74. if len(scheduals) > 0 {
  75. patients, _ := service.GetAllPcPatientListByListSeven(orgID)
  76. dialysisOrders, _ := service.GetAllPcDialysisOrdersByList(orgID, date.Unix())
  77. prescriptions, _ := service.GetAllPrescriptionsByList(orgID, date.Unix())
  78. assessmentBefores, _ := service.GetAllAssessmentBeforesByList(orgID, date.Unix())
  79. treatmentSummarys, _ := service.GetAllPcTreatmentSummarysByList(orgID, date.Unix())
  80. AssessmentAfterDislysis, _ := service.GetAllPcAssessmentAfterDislysisByList(orgID, date.Unix())
  81. advices, _ := service.GetAllPcAdvicestByList(orgID, date.Unix())
  82. for key, item := range scheduals {
  83. // 获取患者信息
  84. for _, patient := range patients {
  85. if item.PatientId == patient.ID {
  86. scheduals[key].SchedualPatient = patient
  87. break
  88. }
  89. }
  90. for _, advice := range advices {
  91. if item.PatientId == advice.PatientId {
  92. scheduals[key].Advices = append(scheduals[key].Advices, advice)
  93. }
  94. }
  95. // 医嘱信息
  96. for _, prescription := range prescriptions {
  97. if item.PatientId == prescription.PatientId {
  98. scheduals[key].Prescription = prescription
  99. break
  100. }
  101. }
  102. // 透前评估
  103. for _, assessmentBefore := range assessmentBefores {
  104. if item.PatientId == assessmentBefore.PatientId {
  105. scheduals[key].AssessmentBeforeDislysis = assessmentBefore
  106. break
  107. }
  108. }
  109. // 透析上下机
  110. for _, dialysisOrder := range dialysisOrders {
  111. if item.PatientId == dialysisOrder.PatientId {
  112. scheduals[key].DialysisOrder = dialysisOrder
  113. break
  114. }
  115. }
  116. // 治疗小节
  117. for _, afterDislysis := range AssessmentAfterDislysis {
  118. if item.PatientId == afterDislysis.PatientId {
  119. scheduals[key].AssessmentAfterDislysis = afterDislysis
  120. break
  121. }
  122. }
  123. // 透后评估
  124. for _, treatmentSummary := range treatmentSummarys {
  125. if item.PatientId == treatmentSummary.PatientId {
  126. scheduals[key].TreatmentSummary = treatmentSummary
  127. break
  128. }
  129. }
  130. }
  131. //缓存数据
  132. scheduals_json, err := json.Marshal(&scheduals)
  133. if err == nil {
  134. redis.Set(key, scheduals_json, time.Second*60)
  135. }
  136. }
  137. _, errcodes := service.GetOrgFollowIsExist(orgID)
  138. if errcodes == gorm.ErrRecordNotFound {
  139. information, _ := service.GetAdminUserRoleInformation(0)
  140. this.ServeSuccessJSON(map[string]interface{}{
  141. "schedules": scheduals,
  142. "information": information,
  143. })
  144. } else if errcodes == nil {
  145. information, _ := service.GetAdminUserRoleInformation(orgID)
  146. this.ServeSuccessJSON(map[string]interface{}{
  147. "schedules": scheduals,
  148. "information": information,
  149. })
  150. }
  151. }
  152. } else { //缓存数据了数据,将redis缓存的json字符串转为map
  153. var dat []map[string]interface{}
  154. if err := json.Unmarshal([]byte(scheduals_json_str), &dat); err == nil {
  155. } else {
  156. }
  157. _, errcodes := service.GetOrgFollowIsExist(orgID)
  158. if errcodes == gorm.ErrRecordNotFound {
  159. information, _ := service.GetAdminUserRoleInformation(0)
  160. this.ServeSuccessJSON(map[string]interface{}{
  161. "schedules": dat,
  162. "information": information,
  163. })
  164. } else if errcodes == nil {
  165. information, _ := service.GetAdminUserRoleInformation(orgID)
  166. this.ServeSuccessJSON(map[string]interface{}{
  167. "schedules": dat,
  168. "information": information,
  169. })
  170. }
  171. }
  172. //if err != nil {
  173. // this.ErrorLog("获取排班信息失败:%v", err)
  174. // this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
  175. //} else {
  176. // this.ServeSuccessJSON(map[string]interface{}{
  177. // "schedules": schedules,
  178. // })
  179. //}
  180. }
  181. // /api/dislysis/schedule [get]
  182. // @param patient_id:int
  183. // @param date:string (yyyy-MM-dd)
  184. func (this *DialysisRecordAPIController) DialysisSchedule() {
  185. patientID, _ := this.GetInt64("patient_id")
  186. recordDateStr := this.GetString("date")
  187. if patientID <= 0 {
  188. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
  189. return
  190. }
  191. if len(recordDateStr) == 0 {
  192. recordDateStr = time.Now().Format("2006-01-02")
  193. }
  194. date, parseDateErr := utils.ParseTimeStringToTime("2006-01-02", recordDateStr)
  195. if parseDateErr != nil {
  196. this.ErrorLog("日期(%v)解析错误:%v", recordDateStr, parseDateErr)
  197. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
  198. return
  199. }
  200. adminInfo := this.GetAdminUserInfo()
  201. ch := make(chan struct{})
  202. count := 15 // count 表示活动的协程个数
  203. var patient *service.MPatient
  204. var schedual *service.MDialysisScheduleVM
  205. var receiverTreatmentAccess *models.ReceiveTreatmentAsses
  206. var predialysisEvaluation *models.PredialysisEvaluation
  207. var doctorAdvices []*models.DoctorAdvice
  208. var dialysisOrder *models.DialysisOrder
  209. var doubleCheck *models.DoubleCheck
  210. var monitorRecords []*models.MonitoringRecord
  211. var assessmentAfterDislysis *models.AssessmentAfterDislysis
  212. var treatmentSummary *models.TreatmentSummary
  213. var record models.GobalConfig
  214. var is_open_config models.XtHisConfig
  215. var stockType []*models.GoodsTypeOne
  216. var prepare []*models.XtDialysisBeforePrepare
  217. var lastAssessment models.XtPatientVascularAccess
  218. go func() {
  219. patient, _ = service.MobileGetPatientDetail(adminInfo.CurrentOrgId, patientID)
  220. ch <- struct{}{}
  221. }()
  222. go func() {
  223. schedual, _ = service.MobileGetSchedualDetail(adminInfo.CurrentOrgId, patientID, date.Unix())
  224. ch <- struct{}{}
  225. }()
  226. go func() {
  227. receiverTreatmentAccess, _ = service.MobileGetReceiverTreatmentAccessRecord(adminInfo.CurrentOrgId, patientID, date.Unix())
  228. ch <- struct{}{}
  229. }()
  230. go func() {
  231. predialysisEvaluation, _ = service.MobileGetPredialysisEvaluation(adminInfo.CurrentOrgId, patientID, date.Unix())
  232. ch <- struct{}{}
  233. }()
  234. go func() {
  235. doctorAdvices, _ = service.MobileGetDoctorAdvices(adminInfo.CurrentOrgId, patientID, date.Unix())
  236. ch <- struct{}{}
  237. }()
  238. go func() {
  239. dialysisOrder, _ = service.MobileGetSchedualDialysisRecord(adminInfo.CurrentOrgId, patientID, date.Unix())
  240. ch <- struct{}{}
  241. }()
  242. go func() {
  243. doubleCheck, _ = service.MobileGetDoubleCheck(adminInfo.CurrentOrgId, patientID, date.Unix())
  244. ch <- struct{}{}
  245. }()
  246. go func() {
  247. monitorRecords, _ = service.MobileGetMonitorRecords(adminInfo.CurrentOrgId, patientID, date.Unix())
  248. ch <- struct{}{}
  249. }()
  250. go func() {
  251. assessmentAfterDislysis, _ = service.MobileGetAssessmentAfterDislysis(adminInfo.CurrentOrgId, patientID, date.Unix())
  252. ch <- struct{}{}
  253. }()
  254. go func() {
  255. treatmentSummary, _ = service.MobileGetTreatmentSummary(adminInfo.CurrentOrgId, patientID, date.Unix())
  256. ch <- struct{}{}
  257. }()
  258. go func() {
  259. _, record = service.FindAutomaticReduceRecordByOrgId(adminInfo.CurrentOrgId)
  260. ch <- struct{}{}
  261. }()
  262. go func() {
  263. _, is_open_config = service.FindXTHisRecordByOrgId(adminInfo.CurrentOrgId)
  264. ch <- struct{}{}
  265. }()
  266. go func() {
  267. //获取耗材类型
  268. stockType, _ = service.GetStockType(adminInfo.CurrentOrgId)
  269. ch <- struct{}{}
  270. }()
  271. go func() {
  272. prepare, _ = service.GetDialyStockOut(adminInfo.CurrentOrgId, date.Unix(), patientID)
  273. ch <- struct{}{}
  274. }()
  275. go func() {
  276. //获取患者的最后一次血管通路数据
  277. lastAssessment, _ = service.GetLastPassWayAssessment(adminInfo.CurrentOrgId, patientID)
  278. ch <- struct{}{}
  279. }()
  280. for range ch {
  281. // 每次从ch中接收数据,表明一个活动的协程结束
  282. count--
  283. // 当所有活动的协程都结束时,关闭管道
  284. if count == 0 {
  285. close(ch)
  286. }
  287. }
  288. admins, getAdminsErr := service.GetAllAdminUsers(adminInfo.CurrentOrgId, adminInfo.CurrentAppId)
  289. if getAdminsErr != nil {
  290. this.ErrorLog("获取医护列表失败:%v", getAdminsErr)
  291. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
  292. return
  293. }
  294. devices, getDevicesErr := service.GetValidDevicesBy(adminInfo.CurrentOrgId, 0, 0)
  295. if getDevicesErr != nil {
  296. this.ErrorLog("获取设备列表失败:%v", getDevicesErr)
  297. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
  298. return
  299. }
  300. deviceNumbers, getDeviceNumbersErr := service.GetAllValidDeviceNumbers(adminInfo.CurrentOrgId)
  301. if getDeviceNumbersErr != nil {
  302. this.ErrorLog("获取床位号列表失败:%v", getDeviceNumbersErr)
  303. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
  304. return
  305. }
  306. lastPredialysisEvaluation, getLPEErr := service.GetLastTimePredialysisEvaluation(adminInfo.CurrentOrgId, patientID, date.Unix())
  307. if getLPEErr != nil {
  308. this.ErrorLog("获取上一次透前评估失败:%v", getLPEErr)
  309. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
  310. return
  311. }
  312. var lastMonitorRecord *models.MonitoringRecord
  313. lastMonitorRecord, getLastErr := service.GetLastMonitorRecord(adminInfo.CurrentOrgId, patientID, date.Unix())
  314. if getLastErr != nil {
  315. this.ErrorLog("获取上一次透析的监测记录失败:%v", getLastErr)
  316. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
  317. return
  318. }
  319. lastAssessmentAfterDislysis, getLAADErr := service.GetLastTimeAssessmentAfterDislysis(adminInfo.CurrentOrgId, patientID, date.Unix())
  320. if getLAADErr != nil {
  321. this.ErrorLog("获取上一次透后评估失败:%v", getLAADErr)
  322. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
  323. return
  324. }
  325. dialysisPrescribe, _ := service.GetDialysisPrescribe(adminInfo.CurrentOrgId, patientID, date.Unix())
  326. dialysisSolution, _ := service.GetDialysisSolution(adminInfo.CurrentOrgId, patientID, schedual.ModeId)
  327. //
  328. //if getDialysisSolutionErr != nil {
  329. // this.ErrorLog("获取透析方案失败:%v", getDialysisSolutionErr)
  330. // this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
  331. // return
  332. //}
  333. lastDialysisPrescribe, _ := service.GetLastDialysisPrescribeByModeId(adminInfo.CurrentOrgId, patientID, schedual.ModeId)
  334. systemDialysisPrescribe, _ := service.GetSystemDialysisPrescribeByModeId(adminInfo.CurrentOrgId, schedual.ModeId)
  335. lastDryWeightDislysis, getDryErr := service.GetLastDryWeight(adminInfo.CurrentOrgId, patientID)
  336. if getDryErr != nil {
  337. this.ErrorLog("获取最后一条干体重失败:%v", getDryErr)
  338. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
  339. return
  340. }
  341. headNurses, _ := service.GetAllSpecialPermissionAdminUsersWithoutStatus(adminInfo.CurrentOrgId, adminInfo.CurrentAppId, models.SpecialPermissionTypeHeadNurse)
  342. var his_advices []*models.HisDoctorAdviceInfo
  343. fmt.Println("hhh2333223322323223", is_open_config.IsOpen)
  344. if is_open_config.IsOpen == 1 {
  345. his_advices, _ = service.GetAllHisDoctorAdvice(adminInfo.CurrentOrgId, patientID, date.Unix())
  346. }
  347. _, errcode := service.GetOrgFollowIsExist(adminInfo.CurrentOrgId)
  348. if errcode == gorm.ErrRecordNotFound {
  349. information, _ := service.GetAdminUserRoleInformation(0)
  350. returnData := map[string]interface{}{
  351. "patient": patient,
  352. "schedual": schedual,
  353. "prescription": dialysisPrescribe,
  354. "solution": dialysisSolution,
  355. "receiver_treatment_access": receiverTreatmentAccess,
  356. "predialysis_evaluation": predialysisEvaluation,
  357. "doctor_advices": doctorAdvices,
  358. "double_check": doubleCheck,
  359. "assessment_after_dislysis": assessmentAfterDislysis,
  360. "treatment_summary": treatmentSummary,
  361. "monitor_records": monitorRecords,
  362. "dialysis_order": dialysisOrder,
  363. "doctors": admins,
  364. "config": record,
  365. "devices": devices,
  366. "device_numbers": deviceNumbers,
  367. "lastPredialysisEvaluation": lastPredialysisEvaluation,
  368. "lastMonitorRecord": lastMonitorRecord,
  369. "lastAssessmentAfterDislysis": lastAssessmentAfterDislysis,
  370. "lastDialysisPrescribe": lastDialysisPrescribe,
  371. "lastDryWeightDislysis": lastDryWeightDislysis,
  372. "headNurses": headNurses,
  373. "system_prescribe": systemDialysisPrescribe,
  374. "his_advices": his_advices,
  375. "is_open_config": is_open_config,
  376. "stockType": stockType,
  377. "prepare": prepare,
  378. "lastAssessment": lastAssessment,
  379. "information": information,
  380. }
  381. this.ServeSuccessJSON(returnData)
  382. } else if errcode == nil {
  383. information, _ := service.GetAdminUserRoleInformation(adminInfo.CurrentOrgId)
  384. returnData := map[string]interface{}{
  385. "patient": patient,
  386. "schedual": schedual,
  387. "prescription": dialysisPrescribe,
  388. "solution": dialysisSolution,
  389. "receiver_treatment_access": receiverTreatmentAccess,
  390. "predialysis_evaluation": predialysisEvaluation,
  391. "doctor_advices": doctorAdvices,
  392. "double_check": doubleCheck,
  393. "assessment_after_dislysis": assessmentAfterDislysis,
  394. "treatment_summary": treatmentSummary,
  395. "monitor_records": monitorRecords,
  396. "dialysis_order": dialysisOrder,
  397. "doctors": admins,
  398. "config": record,
  399. "devices": devices,
  400. "device_numbers": deviceNumbers,
  401. "lastPredialysisEvaluation": lastPredialysisEvaluation,
  402. "lastMonitorRecord": lastMonitorRecord,
  403. "lastAssessmentAfterDislysis": lastAssessmentAfterDislysis,
  404. "lastDialysisPrescribe": lastDialysisPrescribe,
  405. "lastDryWeightDislysis": lastDryWeightDislysis,
  406. "headNurses": headNurses,
  407. "system_prescribe": systemDialysisPrescribe,
  408. "his_advices": his_advices,
  409. "is_open_config": is_open_config,
  410. "stockType": stockType,
  411. "prepare": prepare,
  412. "lastAssessment": lastAssessment,
  413. "information": information,
  414. }
  415. this.ServeSuccessJSON(returnData)
  416. }
  417. }
  418. type EditMonitorParamObject struct {
  419. ID int64 `json:"id"`
  420. MonitoringDate int64 `json:"monitoring_date"`
  421. OperateTime int64 `json:"operate_time"`
  422. // MonitoringTime string `json:"monitoring_time"`
  423. SystolicBP float64 `json:"systolic_bp"`
  424. DiastolicBP float64 `json:"diastolic_bp"`
  425. PulseFrequency float64 `json:"pulse_frequency"`
  426. BreathingRated float64 `json:"breathing_rated"`
  427. BloodFlowVolume float64 `json:"blood_flow_volume"`
  428. VenousPressure float64 `json:"venous_pressure"`
  429. VenousPressureType int64 `json:"venous_pressure_type"`
  430. TransmembranePressure float64 `json:"transmembrane_pressure"`
  431. TransmembranePressureType int64 `json:"transmembrane_pressure_type"`
  432. UltrafiltrationVolume float64 `json:"ultrafiltration_volume"`
  433. UltrafiltrationRate float64 `json:"ultrafiltration_rate"`
  434. ArterialPressure float64 `json:"arterial_pressure"`
  435. ArterialPressureType int64 `json:"arterial_pressure_type"`
  436. SodiumConcentration float64 `json:"sodium_concentration"`
  437. DialysateTemperature float64 `json:"dialysate_temperature"`
  438. Temperature float64 `json:"temperature"`
  439. ReplacementRate float64 `json:"replacement_rate"`
  440. DisplacementQuantity float64 `json:"displacement_quantity"`
  441. KTV float64 `json:"ktv"`
  442. Symptom string `json:"symptom"`
  443. Dispose string `json:"dispose"`
  444. Result string `json:"result"`
  445. Conductivity float64 `json:"conductivity"`
  446. DisplacementFlowQuantity float64 `json:"displacement_flow_quantity"`
  447. BloodOxygenSaturation string `gorm:"column:blood_oxygen_saturation" json:"blood_oxygen_saturation" form:"blood_oxygen_saturation"`
  448. Heparin float64 `gorm:"column:heparin" json:"heparin" form:"heparin"`
  449. DialysateFlow float64 `gorm:"column:dialysate_flow" json:"dialysate_flow" form:"dialysate_flow"`
  450. Urr string `gorm:"column:urr" json:"urr" form:"urr"`
  451. BloodSugar float64 `gorm:"column:blood_sugar" json:"blood_sugar" form:"blood_sugar"`
  452. MonitorAnticoagulant int64 `gorm:"column:monitor_anticoagulant" json:"monitor_anticoagulant" form:"monitor_anticoagulant"`
  453. MonitorAnticoagulantValue string `gorm:"column:monitor_anticoagulant_value" json:"monitor_anticoagulant_value" form:"monitor_anticoagulant_value"`
  454. BloodPressureMonitoringSite int64 `gorm:"column:blood_pressure_monitoring_site" json:"blood_pressure_monitoring_site" form:"blood_pressure_monitoring_site"`
  455. Complication int64 `gorm:"column:complication" json:"complication" form:"complication"`
  456. AccumulatedBloodVolume float64 `gorm:"column:accumulated_blood_volume" json:"accumulated_blood_volume" form:"accumulated_blood_volume"`
  457. BloodTemperature float64 `gorm:"column:blood_temperature" json:"blood_temperature" form:"blood_temperature"`
  458. UreaMonitoring float64 `gorm:"column:urea_monitoring" json:"urea_monitoring" form:"urea_monitoring"`
  459. BloodThickness float64 `gorm:"column:blood_thickness" json:"blood_thickness" form:"blood_thickness"`
  460. BloodMonitor float64 `gorm:"column:blood_monitor" json:"blood_monitor" form:"blood_monitor"`
  461. HeparinAmount float64 `gorm:"column:heparin_amount" json:"heparin_amount" form:"heparin_amount"`
  462. Dehydration float64 `gorm:"column:dehydration" json:"dehydration" form:"dehydration"`
  463. }
  464. // /api/dislysis/monitor/edit [post]
  465. // @param patient_id:int 患者id
  466. // @param schedule_date:int 排班日期
  467. // 下面的参数放到 body
  468. // @param id?:int 监测记录ID(id为0时为创建记录,不为0时为修改记录)
  469. // @param monitoring_date:int 排班日期
  470. // @param operate_time:int 实际测量日期
  471. // @param monitoring_time:string (HH:mm) 监测时间 废弃
  472. // @param systolic_bp?:float 收缩压
  473. // @param diastolic_bp?:float 舒张压
  474. // @param pulse_frequency?:float 心率
  475. // @param breathing_rated?:float 呼吸频率
  476. // @param blood_flow_volume?:float 血流量
  477. // @param venous_pressure?:float 静脉压
  478. // @param transmembrane_pressure?:float 跨膜压
  479. // @param ultrafiltration_volume?:float 超滤量
  480. // @param ultrafiltration_rate?:float 超滤率
  481. // @param arterial_pressure?:float 动脉压
  482. // @param sodium_concentration?:float 钠浓度
  483. // @param dialysate_temperature?:float 透析液温度
  484. // @param replacement_rate?:float 置换率
  485. // @param displacement_quantity?:float 置换量
  486. // @param ktv?:float KT/V
  487. // @param symptom?:string 病情变化
  488. // @param dispose?:string 处理
  489. // @param result?:string 结果
  490. func (this *DialysisRecordAPIController) EditMonitor() {
  491. patientID, _ := this.GetInt64("patient_id")
  492. scheduleDate, _ := this.GetInt64("schedule_date")
  493. if patientID <= 0 || scheduleDate <= 0 {
  494. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
  495. return
  496. }
  497. var monitorParam EditMonitorParamObject
  498. if parseErr := json.Unmarshal(this.Ctx.Input.RequestBody, &monitorParam); parseErr != nil {
  499. this.ErrorLog("参数解析失败:%v", parseErr)
  500. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamFormatWrong)
  501. return
  502. }
  503. if monitorParam.MonitoringDate != scheduleDate {
  504. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
  505. return
  506. }
  507. adminUserInfo := this.GetAdminUserInfo()
  508. schedule, getScheduleErr := service.MobileGetSchedualDetail(adminUserInfo.CurrentOrgId, patientID, scheduleDate)
  509. if getScheduleErr != nil {
  510. this.ErrorLog("获取排班信息失败:%v", getScheduleErr)
  511. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
  512. return
  513. } else if schedule == nil {
  514. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeScheduleNotExist)
  515. return
  516. }
  517. // TODO 其实这里合理的逻辑是“透析记录存在的情况下才能添加监测记录的”
  518. dialysisOrder, getDialysisOrderErr := service.MobileGetDialysisRecord(adminUserInfo.CurrentOrgId, patientID, scheduleDate)
  519. if getDialysisOrderErr != nil {
  520. this.ErrorLog("获取透析记录失败:%v", getDialysisOrderErr)
  521. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
  522. return
  523. }
  524. orderID := int64(0)
  525. if dialysisOrder != nil {
  526. orderID = dialysisOrder.ID
  527. }
  528. if monitorParam.ID <= 0 { // 新建记录
  529. monitor := models.MonitoringRecord{
  530. UserOrgId: adminUserInfo.CurrentOrgId,
  531. PatientId: patientID,
  532. DialysisOrderId: orderID,
  533. MonitoringDate: monitorParam.MonitoringDate,
  534. OperateTime: monitorParam.OperateTime,
  535. // MonitoringTime: monitorParam.MonitoringTime,
  536. PulseFrequency: monitorParam.PulseFrequency,
  537. BreathingRate: monitorParam.BreathingRated,
  538. SystolicBloodPressure: monitorParam.SystolicBP,
  539. DiastolicBloodPressure: monitorParam.DiastolicBP,
  540. BloodFlowVolume: monitorParam.BloodFlowVolume,
  541. VenousPressure: monitorParam.VenousPressure,
  542. VenousPressureType: monitorParam.VenousPressureType,
  543. ArterialPressure: monitorParam.ArterialPressure,
  544. ArterialPressureType: monitorParam.ArterialPressureType,
  545. TransmembranePressure: monitorParam.TransmembranePressure,
  546. TransmembranePressureType: monitorParam.TransmembranePressureType,
  547. UltrafiltrationRate: monitorParam.UltrafiltrationRate,
  548. UltrafiltrationVolume: monitorParam.UltrafiltrationVolume,
  549. SodiumConcentration: monitorParam.SodiumConcentration,
  550. DialysateTemperature: monitorParam.DialysateTemperature,
  551. Temperature: monitorParam.Temperature,
  552. ReplacementRate: monitorParam.ReplacementRate,
  553. DisplacementQuantity: monitorParam.DisplacementQuantity,
  554. Ktv: monitorParam.KTV,
  555. Symptom: monitorParam.Symptom,
  556. Dispose: monitorParam.Dispose,
  557. Result: monitorParam.Result,
  558. MonitoringNurse: adminUserInfo.AdminUser.Id,
  559. Conductivity: monitorParam.Conductivity,
  560. DisplacementFlowQuantity: monitorParam.DisplacementFlowQuantity,
  561. Status: 1,
  562. CreatedTime: time.Now().Unix(),
  563. UpdatedTime: time.Now().Unix(),
  564. BloodOxygenSaturation: monitorParam.BloodOxygenSaturation,
  565. Creator: adminUserInfo.AdminUser.Id,
  566. Heparin: monitorParam.Heparin,
  567. DialysateFlow: monitorParam.DialysateFlow,
  568. Urr: monitorParam.Urr,
  569. BloodSugar: monitorParam.BloodSugar,
  570. MonitorAnticoagulant: monitorParam.MonitorAnticoagulant,
  571. MonitorAnticoagulantValue: monitorParam.MonitorAnticoagulantValue,
  572. BloodPressureMonitoringSite: monitorParam.BloodPressureMonitoringSite,
  573. Complication: monitorParam.Complication,
  574. AccumulatedBloodVolume: monitorParam.AccumulatedBloodVolume,
  575. BloodTemperature: monitorParam.BloodTemperature,
  576. UreaMonitoring: monitorParam.UreaMonitoring,
  577. BloodThickness: monitorParam.BloodThickness,
  578. BloodMonitor: monitorParam.BloodMonitor,
  579. HeparinAmount: monitorParam.HeparinAmount,
  580. Dehydration: monitorParam.Dehydration,
  581. }
  582. createErr := service.CreateMonitor(&monitor)
  583. key := strconv.FormatInt(adminUserInfo.CurrentOrgId, 10) + ":" + strconv.FormatInt(patientID, 10) + ":" + strconv.FormatInt(scheduleDate, 10) + ":monitor_records"
  584. redis := service.RedisClient()
  585. //清空key 值
  586. redis.Set(key, "", time.Second)
  587. keyOne := strconv.FormatInt(adminUserInfo.CurrentOrgId, 10) + ":" + strconv.FormatInt(monitorParam.MonitoringDate, 10) + ":monitor_record_list_all"
  588. redis.Set(keyOne, "", time.Second)
  589. defer redis.Close()
  590. if createErr != nil {
  591. this.ErrorLog("创建监测记录失败:%v", createErr)
  592. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
  593. return
  594. }
  595. this.ServeSuccessJSON(map[string]interface{}{
  596. "monitor": monitor,
  597. })
  598. } else { // 修改记录
  599. monitor, getMonitorErr := service.GetMonitor(adminUserInfo.CurrentOrgId, patientID, monitorParam.ID)
  600. if getMonitorErr != nil {
  601. this.ErrorLog("获取透析监测记录失败:%v", getMonitorErr)
  602. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
  603. return
  604. } else if monitor == nil {
  605. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeMonitorNotExist)
  606. return
  607. }
  608. //if monitor.MonitoringNurse != adminUserInfo.AdminUser.Id {
  609. // headNursePermission, getPermissionErr := service.GetAdminUserSpecialPermission(adminUserInfo.CurrentOrgId, adminUserInfo.CurrentAppId, adminUserInfo.AdminUser.Id, models.SpecialPermissionTypeHeadNurse)
  610. // if getPermissionErr != nil {
  611. // this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
  612. // return
  613. // } else if headNursePermission == nil {
  614. // this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDialysisPermissionDeniedModify)
  615. // return
  616. // }
  617. //}
  618. monitor.OperateTime = monitorParam.OperateTime
  619. monitor.PulseFrequency = monitorParam.PulseFrequency
  620. monitor.BreathingRate = monitorParam.BreathingRated
  621. monitor.SystolicBloodPressure = monitorParam.SystolicBP
  622. monitor.DiastolicBloodPressure = monitorParam.DiastolicBP
  623. monitor.BloodFlowVolume = monitorParam.BloodFlowVolume
  624. monitor.VenousPressure = monitorParam.VenousPressure
  625. monitor.VenousPressureType = monitorParam.VenousPressureType
  626. monitor.ArterialPressure = monitorParam.ArterialPressure
  627. monitor.ArterialPressureType = monitorParam.ArterialPressureType
  628. monitor.TransmembranePressure = monitorParam.TransmembranePressure
  629. monitor.TransmembranePressureType = monitorParam.TransmembranePressureType
  630. monitor.UltrafiltrationRate = monitorParam.UltrafiltrationRate
  631. monitor.UltrafiltrationVolume = monitorParam.UltrafiltrationVolume
  632. monitor.SodiumConcentration = monitorParam.SodiumConcentration
  633. monitor.DialysateTemperature = monitorParam.DialysateTemperature
  634. monitor.Temperature = monitorParam.Temperature
  635. monitor.ReplacementRate = monitorParam.ReplacementRate
  636. monitor.DisplacementQuantity = monitorParam.DisplacementQuantity
  637. monitor.Conductivity = monitorParam.Conductivity
  638. monitor.DisplacementFlowQuantity = monitorParam.DisplacementFlowQuantity
  639. monitor.Ktv = monitorParam.KTV
  640. monitor.Symptom = monitorParam.Symptom
  641. monitor.Dispose = monitorParam.Dispose
  642. monitor.Result = monitorParam.Result
  643. monitor.MonitoringNurse = adminUserInfo.AdminUser.Id
  644. monitor.UpdatedTime = time.Now().Unix()
  645. monitor.Modify = adminUserInfo.AdminUser.Id
  646. monitor.BloodOxygenSaturation = monitorParam.BloodOxygenSaturation
  647. monitor.Heparin = monitorParam.Heparin
  648. monitor.DialysateFlow = monitorParam.DialysateFlow
  649. monitor.Urr = monitorParam.Urr
  650. monitor.BloodSugar = monitorParam.BloodSugar
  651. monitor.MonitorAnticoagulant = monitorParam.MonitorAnticoagulant
  652. monitor.MonitorAnticoagulantValue = monitorParam.MonitorAnticoagulantValue
  653. monitor.AccumulatedBloodVolume = monitorParam.AccumulatedBloodVolume
  654. monitor.BloodTemperature = monitorParam.BloodTemperature
  655. monitor.UreaMonitoring = monitorParam.UreaMonitoring
  656. monitor.BloodThickness = monitorParam.BloodThickness
  657. monitor.BloodMonitor = monitorParam.BloodMonitor
  658. monitor.HeparinAmount = monitorParam.HeparinAmount
  659. monitor.Dehydration = monitorParam.Dehydration
  660. updateErr := service.UpdateMonitor(monitor)
  661. key := strconv.FormatInt(adminUserInfo.CurrentOrgId, 10) + ":" + strconv.FormatInt(patientID, 10) + ":" + strconv.FormatInt(scheduleDate, 10) + ":monitor_records"
  662. redis := service.RedisClient()
  663. defer redis.Close()
  664. //清空key 值
  665. redis.Set(key, "", time.Second)
  666. if updateErr != nil {
  667. this.ErrorLog("修改透析监测记录失败:%v", updateErr)
  668. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
  669. return
  670. }
  671. this.ServeSuccessJSON(map[string]interface{}{
  672. "monitor": monitor,
  673. })
  674. }
  675. }
  676. // /api/dialysis/start_record [post]
  677. // @param patient_id:int
  678. // @param date:string 排班时间 (yyyy-mm-dd)
  679. // @param nurse:int 上机护士
  680. // @param bed:int 上机床位号
  681. func (this *DialysisRecordAPIController) StartDialysis() {
  682. patientID, _ := this.GetInt64("patient_id")
  683. recordDateStr := this.GetString("date")
  684. nurseID, _ := this.GetInt64("nurse")
  685. punctureNurseId, _ := this.GetInt64("puncture_nurse")
  686. startDateStr := this.GetString("start_time")
  687. blood_drawing, _ := this.GetInt64("blood_drawing")
  688. schedual_type, _ := this.GetInt64("schedual_type")
  689. washpipe_nurse, _ := this.GetInt64("washpipe_nurse")
  690. change_nurse, _ := this.GetInt64("change_nurse")
  691. difficult_puncture_nurse, _ := this.GetInt64("difficult_puncture_nurse")
  692. new_fistula_nurse, _ := this.GetInt64("new_fistula_nurse")
  693. bedID, _ := this.GetInt64("bed")
  694. if patientID <= 0 || len(recordDateStr) == 0 || nurseID <= 0 || bedID <= 0 {
  695. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
  696. return
  697. }
  698. recordDate, parseErr := utils.ParseTimeStringToTime("2006-01-02", recordDateStr)
  699. if parseErr != nil {
  700. this.ErrorLog("时间解析失败:%v", parseErr)
  701. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
  702. return
  703. }
  704. startDate, parseErr := utils.ParseTimeStringToTime("2006-01-02 15:04", startDateStr)
  705. if parseErr != nil {
  706. this.ErrorLog("时间解析失败:%v", parseErr)
  707. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
  708. return
  709. }
  710. adminUserInfo := this.GetAdminUserInfo()
  711. patient, getPatientErr := service.MobileGetPatientById(adminUserInfo.CurrentOrgId, patientID)
  712. if getPatientErr != nil {
  713. this.ErrorLog("获取患者信息失败:%v", getPatientErr)
  714. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
  715. return
  716. } else if patient == nil {
  717. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodePatientNoExist)
  718. return
  719. }
  720. nurse, getNurseErr := service.GetAdminUserByUserID(nurseID)
  721. if getNurseErr != nil {
  722. this.ErrorLog("获取护士失败:%v", getNurseErr)
  723. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
  724. return
  725. } else if nurse == nil {
  726. this.ErrorLog("护士不存在")
  727. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
  728. return
  729. }
  730. //nurse, getNurseErr = service.GetAdminUserByUserID(punctureNurseId)
  731. //
  732. //if getNurseErr != nil {
  733. // this.ErrorLog("获取护士失败:%v", getNurseErr)
  734. // this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
  735. // return
  736. //} else if nurse == nil {
  737. // this.ErrorLog("护士不存在")
  738. // this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
  739. // return
  740. //}
  741. deviceNumber, getDeviceNumberErr := service.GetDeviceNumberByID(adminUserInfo.CurrentOrgId, bedID)
  742. if getDeviceNumberErr != nil {
  743. this.ErrorLog("获取床位号失败:%v", getDeviceNumberErr)
  744. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
  745. return
  746. } else if deviceNumber == nil {
  747. this.ErrorLog("床位号不存在")
  748. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
  749. return
  750. }
  751. dialysisRecord, getRecordErr := service.MobileGetDialysisRecord(adminUserInfo.CurrentOrgId, patientID, recordDate.Unix())
  752. if getRecordErr != nil {
  753. this.ErrorLog("获取透析记录失败:%v", getRecordErr)
  754. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
  755. return
  756. } else if dialysisRecord != nil {
  757. this.ServeFailJSONWithSGJErrorCode(enums.ErrorDialysisOrderRepeatStart)
  758. return
  759. }
  760. template, _ := service.GetOrgInfoTemplate(adminUserInfo.CurrentOrgId)
  761. scheduleDateStart := startDate.Format("2006-01-02") + " 00:00:00"
  762. scheduleDateEnd := startDate.Format("2006-01-02") + " 23:59:59"
  763. timeLayout := "2006-01-02 15:04:05"
  764. loc, _ := time.LoadLocation("Local")
  765. theStartTime, _ := time.ParseInLocation(timeLayout, scheduleDateStart, loc)
  766. theEndTime, _ := time.ParseInLocation(timeLayout, scheduleDateEnd, loc)
  767. schedulestartTime := theStartTime.Unix()
  768. scheduleendTime := theEndTime.Unix()
  769. //查询更改的机号,是否有人用了,如果只是排班了,但是没上机,直接替换,如果排班且上机了,就提示他无法上机
  770. schedule, err := service.GetDayScheduleByBedid(adminUserInfo.CurrentOrgId, schedulestartTime, bedID, schedual_type)
  771. //查询该床位是否有人用了
  772. order, order_err := service.GetDialysisOrderByBedId(adminUserInfo.CurrentOrgId, schedulestartTime, bedID, schedual_type)
  773. if err == gorm.ErrRecordNotFound { //空床位
  774. // 修改了床位逻辑
  775. daySchedule, _ := service.GetDaySchedule(adminUserInfo.CurrentOrgId, schedulestartTime, scheduleendTime, patientID)
  776. if daySchedule.ID > 0 {
  777. //daySchedule.PartitionId = deviceNumber.ZoneID
  778. //daySchedule.BedId = bedID
  779. //daySchedule.ScheduleType = schedual_type
  780. //daySchedule.UpdatedTime = time.Now().Unix()
  781. //err := service.UpdateSchedule(&daySchedule)
  782. xtSchedule := models.Schedule{
  783. PartitionId: deviceNumber.ZoneID,
  784. BedId: bedID,
  785. ScheduleType: schedual_type,
  786. UpdatedTime: time.Now().Unix(),
  787. }
  788. err := service.UpdateScheduleOne(daySchedule.ID, xtSchedule)
  789. if err != nil {
  790. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
  791. return
  792. }
  793. }
  794. } else if err == nil {
  795. if schedule.ID > 0 && schedule.DialysisOrder.ID == 0 { //有排班没上机记录
  796. if order_err == nil {
  797. if order.ID > 0 { //该机位被其他人占用了
  798. this.ServeFailJSONWithSGJErrorCode(enums.ErrorDialysisOrderRepeatBed)
  799. return
  800. } else {
  801. daySchedule, _ := service.GetDaySchedule(adminUserInfo.CurrentOrgId, schedulestartTime, scheduleendTime, patientID)
  802. if daySchedule.ID > 0 {
  803. //daySchedule.PartitionId = deviceNumber.ZoneID
  804. //daySchedule.BedId = bedID
  805. //daySchedule.ScheduleType = schedual_type
  806. //daySchedule.UpdatedTime = time.Now().Unix()
  807. //err := service.UpdateSchedule(&daySchedule)
  808. xtSchedule := models.Schedule{
  809. PartitionId: deviceNumber.ZoneID,
  810. BedId: bedID,
  811. ScheduleType: schedual_type,
  812. UpdatedTime: time.Now().Unix(),
  813. }
  814. err := service.UpdateScheduleOne(daySchedule.ID, xtSchedule)
  815. if err != nil {
  816. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
  817. return
  818. }
  819. }
  820. }
  821. } else if order_err == gorm.ErrRecordNotFound { //该床位没被占用
  822. daySchedule, _ := service.GetDaySchedule(adminUserInfo.CurrentOrgId, schedulestartTime, scheduleendTime, patientID)
  823. if daySchedule.ID > 0 {
  824. //daySchedule.PartitionId = deviceNumber.ZoneID
  825. //daySchedule.BedId = bedID
  826. //daySchedule.ScheduleType = schedual_type
  827. //daySchedule.UpdatedTime = time.Now().Unix()
  828. //err := service.UpdateSchedule(&daySchedule)
  829. xtSchedule := models.Schedule{
  830. PartitionId: deviceNumber.ZoneID,
  831. BedId: bedID,
  832. ScheduleType: schedual_type,
  833. UpdatedTime: time.Now().Unix(),
  834. }
  835. err := service.UpdateScheduleOne(daySchedule.ID, xtSchedule)
  836. if err != nil {
  837. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
  838. return
  839. }
  840. }
  841. } else if order_err != nil {
  842. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
  843. return
  844. }
  845. } else if schedule.ID > 0 && schedule.DialysisOrder.ID > 0 { //有排班且有上机记录
  846. this.ServeFailJSONWithSGJErrorCode(enums.ErrorDialysisOrderRepeatBed)
  847. return
  848. }
  849. } else if err != nil {
  850. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
  851. return
  852. }
  853. dialysisRecord = &models.DialysisOrder{
  854. DialysisDate: recordDate.Unix(),
  855. UserOrgId: adminUserInfo.CurrentOrgId,
  856. PatientId: patientID,
  857. Stage: 1,
  858. BedID: bedID,
  859. StartNurse: nurseID,
  860. Status: 1,
  861. StartTime: startDate.Unix(),
  862. CreatedTime: time.Now().Unix(),
  863. UpdatedTime: time.Now().Unix(),
  864. PunctureNurse: punctureNurseId,
  865. Creator: adminUserInfo.AdminUser.Id,
  866. Modifier: adminUserInfo.AdminUser.Id,
  867. SchedualType: schedual_type,
  868. WashpipeNurse: washpipe_nurse,
  869. ChangeNurse: change_nurse,
  870. DifficultPunctureNurse: difficult_puncture_nurse,
  871. NewFistulaNurse: new_fistula_nurse,
  872. }
  873. createErr := service.MobileCreateDialysisOrder(adminUserInfo.CurrentOrgId, patientID, dialysisRecord)
  874. key := strconv.FormatInt(adminUserInfo.CurrentOrgId, 10) + ":" + strconv.FormatInt(patientID, 10) + ":" + strconv.FormatInt(recordDate.Unix(), 10) + ":dialysis_order"
  875. redis := service.RedisClient()
  876. //清空key 值
  877. redis.Set(key, "", time.Second)
  878. keyOne := strconv.FormatInt(adminUserInfo.CurrentOrgId, 10) + ":" + strconv.FormatInt(recordDate.Unix(), 10) + ":dialysis_orders_list_all"
  879. redis.Set(keyOne, "", time.Second)
  880. keyTwo := "scheduals_" + recordDateStr + "_" + strconv.FormatInt(adminUserInfo.CurrentOrgId, 10)
  881. //清空key 值
  882. redis.Set(keyTwo, "", time.Second)
  883. defer redis.Close()
  884. newdialysisRecord, getRecordErr := service.MobileGetDialysisRecord(adminUserInfo.CurrentOrgId, patientID, recordDate.Unix())
  885. if createErr != nil {
  886. this.ErrorLog("上机失败:%v", createErr)
  887. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
  888. return
  889. } else if createErr == nil {
  890. var tempdispose string
  891. // 只针对中能建
  892. if blood_drawing > 0 && adminUserInfo.CurrentOrgId == 9538 { //adminUserInfo.CurrentOrgId == 9538
  893. tempdispose = "引血" + strconv.FormatInt(blood_drawing, 10) + "ml/min"
  894. }
  895. var ultrafiltration_rate float64
  896. _, prescription := service.FindDialysisPrescriptionByReordDate(patientID, schedulestartTime, adminUserInfo.CurrentOrgId)
  897. //获取预增水量
  898. _, evaluation := service.FindPredialysisEvaluationByReordDate(patientID, schedulestartTime, adminUserInfo.CurrentOrgId)
  899. if prescription.ID > 0 {
  900. if prescription.TargetUltrafiltration > 0 && prescription.DialysisDurationHour > 0 {
  901. totalMin := prescription.DialysisDurationHour*60 + prescription.DialysisDurationMinute
  902. fmt.Println("total23232323232322332", totalMin)
  903. if (template.TemplateId == 6 || template.TemplateId == 20 || template.TemplateId == 22 || template.TemplateId == 32 || template.TemplateId == 36) && adminUserInfo.CurrentOrgId != 9671 {
  904. ultrafiltration_rate = math.Floor(prescription.TargetUltrafiltration / float64(totalMin) * 60 * 1000)
  905. }
  906. //针对福建医师汇
  907. if template.TemplateId == 6 && adminUserInfo.CurrentOrgId == 10121 {
  908. if evaluation.ID > 0 {
  909. dehydration, _ := strconv.ParseFloat(evaluation.Dehydration, 64)
  910. ultrafiltration_rate = math.Floor((prescription.TargetUltrafiltration + dehydration) / float64(totalMin) * 60 * 1000)
  911. }
  912. }
  913. if template.TemplateId == 6 && adminUserInfo.CurrentOrgId == 10234 {
  914. if evaluation.ID > 0 {
  915. dehydration, _ := strconv.ParseFloat(evaluation.Dehydration, 64)
  916. ultrafiltration_rate = math.Floor((prescription.TargetUltrafiltration + dehydration) / float64(totalMin) * 60 * 1000)
  917. }
  918. }
  919. // 只针对方济医院
  920. if template.TemplateId == 1 && adminUserInfo.CurrentOrgId != 9849 {
  921. value, _ := strconv.ParseFloat(fmt.Sprintf("%.3f", prescription.TargetUltrafiltration/float64(totalMin)*60), 6)
  922. ultrafiltration_rate = value
  923. }
  924. //针对监利大垸医院
  925. if adminUserInfo.CurrentOrgId == 10101 {
  926. if evaluation.ID > 0 {
  927. ultrafiltration_rate = math.Ceil(prescription.TargetUltrafiltration / float64(totalMin) * 60 * 1000)
  928. fmt.Println("ultrafiltration_rate", ultrafiltration_rate)
  929. }
  930. }
  931. //针对肇庆三鹤血液透析中心
  932. if adminUserInfo.CurrentOrgId == 10215 || template.TemplateId == 43 {
  933. if evaluation.ID > 0 {
  934. ultrafiltration_rate = math.Ceil(prescription.TargetUltrafiltration / float64(totalMin) * 60)
  935. fmt.Println("hhhh2323323223322323323232", ultrafiltration_rate)
  936. }
  937. }
  938. }
  939. }
  940. record := models.MonitoringRecord{
  941. UserOrgId: adminUserInfo.CurrentOrgId,
  942. PatientId: patientID,
  943. DialysisOrderId: dialysisRecord.ID,
  944. MonitoringDate: schedulestartTime,
  945. OperateTime: startDate.Unix(),
  946. // MonitoringTime: recordTime,
  947. MonitoringNurse: nurseID,
  948. Dispose: tempdispose,
  949. UltrafiltrationRate: ultrafiltration_rate,
  950. UltrafiltrationVolume: 0,
  951. Status: 1,
  952. CreatedTime: time.Now().Unix(),
  953. UpdatedTime: time.Now().Unix(),
  954. }
  955. //只针对广慈医院
  956. if template.TemplateId == 26 || template.TemplateId == 25 || template.TemplateId == 28 || adminUserInfo.CurrentOrgId == 9987 || adminUserInfo.CurrentOrgId == 9526 || template.TemplateId == 32 || adminUserInfo.CurrentOrgId == 9918 || adminUserInfo.CurrentOrgId == 9671 || adminUserInfo.CurrentOrgId == 3877 || adminUserInfo.CurrentOrgId == 4 {
  957. // 查询病人是否有透前评估数据
  958. befor, errcode := service.GetAssessmentBefor(adminUserInfo.CurrentOrgId, patientID, recordDate.Unix())
  959. //如果有数据就插入
  960. if errcode == nil {
  961. record.SystolicBloodPressure = befor.SystolicBloodPressure
  962. record.DiastolicBloodPressure = befor.DiastolicBloodPressure
  963. record.BreathingRate = befor.BreathingRate
  964. record.PulseFrequency = befor.PulseFrequency
  965. record.Temperature = befor.Temperature
  966. }
  967. }
  968. // 如果当天有插入数据,则不再往透析纪录里插入数据
  969. if newdialysisRecord.ID > 0 {
  970. err := service.CreateMonitor(&record)
  971. key := strconv.FormatInt(adminUserInfo.CurrentOrgId, 10) + ":" + strconv.FormatInt(patientID, 10) + ":" + strconv.FormatInt(recordDate.Unix(), 10) + ":monitor_records"
  972. redis := service.RedisClient()
  973. //清空key 值
  974. redis.Set(key, "", time.Second)
  975. keyOne := strconv.FormatInt(adminUserInfo.CurrentOrgId, 10) + ":" + strconv.FormatInt(recordDate.Unix(), 10) + ":monitor_record_list_all"
  976. redis.Set(keyOne, "", time.Second)
  977. defer redis.Close()
  978. if err != nil {
  979. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeMonitorCreate)
  980. return
  981. }
  982. }
  983. go func() {
  984. ssoDomain := beego.AppConfig.String("call_domain")
  985. api := ssoDomain + "/index/uppatient"
  986. values := make(url.Values)
  987. values.Set("org_id", strconv.FormatInt(adminUserInfo.CurrentOrgId, 10))
  988. values.Set("admin_user_id", strconv.FormatInt(nurseID, 10))
  989. values.Set("patient_id", strconv.FormatInt(patientID, 10))
  990. values.Set("up_time", strconv.FormatInt(startDate.Unix(), 10))
  991. http.PostForm(api, values)
  992. }()
  993. this.ServeSuccessJSON(map[string]interface{}{
  994. "dialysis_order": dialysisRecord,
  995. "monitor": record,
  996. })
  997. }
  998. }
  999. // /api/dialysis/finish [post]
  1000. // @param patient_id:int
  1001. // @param date:string 排班时间 (yyyy-mm-dd)
  1002. // @param nurse:int 下机护士
  1003. func (this *DialysisRecordAPIController) FinishDialysis() {
  1004. patientID, _ := this.GetInt64("patient_id")
  1005. recordDateStr := this.GetString("date")
  1006. nurseID, _ := this.GetInt64("nurse")
  1007. end_time := this.GetString("end_time")
  1008. if patientID <= 0 || len(recordDateStr) == 0 || nurseID <= 0 {
  1009. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
  1010. return
  1011. }
  1012. recordDate, parseErr := utils.ParseTimeStringToTime("2006-01-02", recordDateStr)
  1013. if parseErr != nil {
  1014. this.ErrorLog("时间解析失败:%v", parseErr)
  1015. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
  1016. return
  1017. }
  1018. //if parseEndDateErr != nil {
  1019. // this.ErrorLog("时间解析失败:%v", parseEndDateErr)
  1020. // this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
  1021. // return
  1022. //}
  1023. adminUserInfo := this.GetAdminUserInfo()
  1024. patient, getPatientErr := service.MobileGetPatientById(adminUserInfo.CurrentOrgId, patientID)
  1025. if getPatientErr != nil {
  1026. this.ErrorLog("获取患者信息失败:%v", getPatientErr)
  1027. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
  1028. return
  1029. } else if patient == nil {
  1030. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodePatientNoExist)
  1031. return
  1032. }
  1033. nurse, getNurseErr := service.GetAdminUserByUserID(nurseID)
  1034. if getNurseErr != nil {
  1035. this.ErrorLog("获取护士失败:%v", getNurseErr)
  1036. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
  1037. return
  1038. } else if nurse == nil {
  1039. this.ErrorLog("护士不存在")
  1040. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
  1041. return
  1042. }
  1043. dialysisRecord, getRecordErr := service.MobileGetDialysisRecord(adminUserInfo.CurrentOrgId, patientID, recordDate.Unix())
  1044. if getRecordErr != nil {
  1045. this.ErrorLog("获取透析记录失败:%v", getRecordErr)
  1046. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
  1047. return
  1048. }
  1049. if dialysisRecord.Stage == 2 {
  1050. this.ServeFailJSONWithSGJErrorCode(enums.ErrorDialysisOrderNoEND)
  1051. return
  1052. }
  1053. endDate, parseEndDateErr := utils.ParseTimeStringToTime("2006-01-02 15:04", end_time)
  1054. if parseEndDateErr != nil {
  1055. this.ErrorLog("日期(%v)解析错误:%v", end_time, parseEndDateErr)
  1056. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
  1057. return
  1058. }
  1059. // 获取当天的第一条透析纪录
  1060. fmonitorRecords, getMonitorRecordsErr := service.MobileGetMonitorRecordFirst(adminUserInfo.CurrentOrgId, patientID, recordDate.Unix())
  1061. if getMonitorRecordsErr != nil {
  1062. this.ErrorLog("获取透析监测记录失败:%v", getMonitorRecordsErr)
  1063. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
  1064. return
  1065. }
  1066. // 获取当前的最后一条透析纪录
  1067. endmonitorRecords, getMonitorRecordsErr := service.MobileGetLastMonitorRecord(adminUserInfo.CurrentOrgId, patientID, recordDate.Unix())
  1068. if getMonitorRecordsErr != nil {
  1069. this.ErrorLog("获取透析监测记录失败:%v", getMonitorRecordsErr)
  1070. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
  1071. return
  1072. }
  1073. assessmentAfterDislysis, getAADErr := service.MobileGetAssessmentAfterDislysis(adminUserInfo.CurrentOrgId, patientID, recordDate.Unix())
  1074. if getAADErr != nil {
  1075. this.ErrorLog("获取透后评估失败:%v", getAADErr)
  1076. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
  1077. return
  1078. }
  1079. lastAssessmentAfterDislysis, _ := service.MobileGetLastTimeAssessmentAfterDislysis(adminUserInfo.CurrentOrgId, patientID, recordDate.Unix())
  1080. var tempassessmentAfterDislysis models.AssessmentAfterDislysis
  1081. if assessmentAfterDislysis != nil {
  1082. tempassessmentAfterDislysis = *assessmentAfterDislysis
  1083. tempassessmentAfterDislysis.UpdatedTime = time.Now().Unix()
  1084. } else {
  1085. tempassessmentAfterDislysis.CreatedTime = time.Now().Unix()
  1086. tempassessmentAfterDislysis.AssessmentDate = recordDate.Unix()
  1087. tempassessmentAfterDislysis.Status = 1
  1088. tempassessmentAfterDislysis.PatientId = patientID
  1089. tempassessmentAfterDislysis.UserOrgId = adminUserInfo.CurrentOrgId
  1090. }
  1091. if dialysisRecord.Stage == 1 {
  1092. temp_time := (float64(endDate.Unix()) - float64(dialysisRecord.StartTime)) / 3600
  1093. value, _ := strconv.ParseFloat(fmt.Sprintf("%.2f", temp_time), 64)
  1094. fmt.Println(value)
  1095. a, b := math.Modf(value)
  1096. c, _ := strconv.ParseFloat(fmt.Sprintf("%.2f", b), 64)
  1097. hour, _ := strconv.ParseInt(fmt.Sprintf("%.0f", a), 10, 64)
  1098. minute, _ := strconv.ParseInt(fmt.Sprintf("%.0f", c*60), 10, 64)
  1099. fmt.Println(hour)
  1100. fmt.Println(minute)
  1101. tempassessmentAfterDislysis.ActualTreatmentHour = hour
  1102. tempassessmentAfterDislysis.ActualTreatmentMinute = minute
  1103. }
  1104. if fmonitorRecords.ID > 0 && endmonitorRecords.ID > 0 {
  1105. tempassessmentAfterDislysis.Temperature = endmonitorRecords.Temperature
  1106. tempassessmentAfterDislysis.PulseFrequency = endmonitorRecords.PulseFrequency
  1107. tempassessmentAfterDislysis.BreathingRate = endmonitorRecords.BreathingRate
  1108. tempassessmentAfterDislysis.SystolicBloodPressure = endmonitorRecords.SystolicBloodPressure
  1109. tempassessmentAfterDislysis.DiastolicBloodPressure = endmonitorRecords.DiastolicBloodPressure
  1110. if adminUserInfo.CurrentOrgId == 10101 {
  1111. tempassessmentAfterDislysis.ActualUltrafiltration = endmonitorRecords.UltrafiltrationVolume / 1000
  1112. } else {
  1113. tempassessmentAfterDislysis.ActualUltrafiltration = endmonitorRecords.UltrafiltrationVolume / 1000
  1114. }
  1115. tempassessmentAfterDislysis.ActualDisplacement = endmonitorRecords.DisplacementQuantity
  1116. }
  1117. if adminUserInfo.CurrentOrgId == 9583 {
  1118. //获取最后一条透析处方数据
  1119. prescription, parseErr := service.GetLastDialysisPrescriptionByPatientId(adminUserInfo.CurrentOrgId, patientID, recordDate.Unix())
  1120. if parseErr != nil {
  1121. this.ErrorLog("获取透析处方失败:%v", getMonitorRecordsErr)
  1122. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
  1123. return
  1124. }
  1125. if prescription.ID > 0 && adminUserInfo.CurrentOrgId == 9583 {
  1126. tempassessmentAfterDislysis.ActualUltrafiltration = prescription.TargetUltrafiltration
  1127. }
  1128. if endmonitorRecords.ID > 0 && adminUserInfo.CurrentOrgId == 10060 {
  1129. tempassessmentAfterDislysis.ActualUltrafiltration = endmonitorRecords.UltrafiltrationVolume
  1130. }
  1131. }
  1132. if lastAssessmentAfterDislysis != nil {
  1133. tempassessmentAfterDislysis.BloodPressureType = lastAssessmentAfterDislysis.BloodPressureType
  1134. tempassessmentAfterDislysis.WeighingWay = lastAssessmentAfterDislysis.WeighingWay
  1135. tempassessmentAfterDislysis.Cruor = lastAssessmentAfterDislysis.Cruor
  1136. tempassessmentAfterDislysis.SymptomAfterDialysis = lastAssessmentAfterDislysis.SymptomAfterDialysis
  1137. tempassessmentAfterDislysis.InternalFistula = lastAssessmentAfterDislysis.InternalFistula
  1138. tempassessmentAfterDislysis.Catheter = lastAssessmentAfterDislysis.Catheter
  1139. tempassessmentAfterDislysis.Complication = lastAssessmentAfterDislysis.Complication
  1140. tempassessmentAfterDislysis.DialysisIntakes = lastAssessmentAfterDislysis.DialysisIntakes
  1141. tempassessmentAfterDislysis.DialysisIntakesFeed = lastAssessmentAfterDislysis.DialysisIntakesFeed
  1142. tempassessmentAfterDislysis.DialysisIntakesTransfusion = lastAssessmentAfterDislysis.DialysisIntakesTransfusion
  1143. tempassessmentAfterDislysis.DialysisIntakesBloodTransfusion = lastAssessmentAfterDislysis.DialysisIntakesBloodTransfusion
  1144. tempassessmentAfterDislysis.DialysisIntakesWashpipe = lastAssessmentAfterDislysis.DialysisIntakesWashpipe
  1145. tempassessmentAfterDislysis.BloodAccessPartId = lastAssessmentAfterDislysis.BloodAccessPartId
  1146. tempassessmentAfterDislysis.BloodAccessPartOperaId = lastAssessmentAfterDislysis.BloodAccessPartOperaId
  1147. tempassessmentAfterDislysis.PuncturePointOozingBlood = lastAssessmentAfterDislysis.PuncturePointOozingBlood
  1148. tempassessmentAfterDislysis.PuncturePointHaematoma = lastAssessmentAfterDislysis.PuncturePointHaematoma
  1149. tempassessmentAfterDislysis.InternalFistulaTremorAc = lastAssessmentAfterDislysis.InternalFistulaTremorAc
  1150. tempassessmentAfterDislysis.PatientGose = lastAssessmentAfterDislysis.PatientGose
  1151. tempassessmentAfterDislysis.InpatientDepartment = lastAssessmentAfterDislysis.InpatientDepartment
  1152. tempassessmentAfterDislysis.ObservationContent = lastAssessmentAfterDislysis.ObservationContent
  1153. tempassessmentAfterDislysis.ObservationContentOther = lastAssessmentAfterDislysis.ObservationContentOther
  1154. tempassessmentAfterDislysis.DryWeight = lastAssessmentAfterDislysis.DryWeight
  1155. tempassessmentAfterDislysis.DialysisProcess = lastAssessmentAfterDislysis.DialysisProcess
  1156. tempassessmentAfterDislysis.InAdvanceMinute = lastAssessmentAfterDislysis.InAdvanceMinute
  1157. tempassessmentAfterDislysis.InAdvanceReason = lastAssessmentAfterDislysis.InAdvanceReason
  1158. tempassessmentAfterDislysis.HemostasisMinute = lastAssessmentAfterDislysis.HemostasisMinute
  1159. tempassessmentAfterDislysis.HemostasisOpera = lastAssessmentAfterDislysis.HemostasisOpera
  1160. tempassessmentAfterDislysis.TremorNoise = lastAssessmentAfterDislysis.TremorNoise
  1161. tempassessmentAfterDislysis.DisequilibriumSyndrome = lastAssessmentAfterDislysis.DisequilibriumSyndrome
  1162. tempassessmentAfterDislysis.DisequilibriumSyndromeOption = lastAssessmentAfterDislysis.DisequilibriumSyndromeOption
  1163. tempassessmentAfterDislysis.ArterialTube = lastAssessmentAfterDislysis.ArterialTube
  1164. tempassessmentAfterDislysis.IntravenousTube = lastAssessmentAfterDislysis.IntravenousTube
  1165. tempassessmentAfterDislysis.Dialyzer = lastAssessmentAfterDislysis.Dialyzer
  1166. tempassessmentAfterDislysis.InAdvanceReasonOther = lastAssessmentAfterDislysis.InAdvanceReasonOther
  1167. tempassessmentAfterDislysis.IsEat = lastAssessmentAfterDislysis.IsEat
  1168. tempassessmentAfterDislysis.DialysisIntakesUnit = lastAssessmentAfterDislysis.DialysisIntakesUnit
  1169. tempassessmentAfterDislysis.CvcA = lastAssessmentAfterDislysis.CvcA
  1170. tempassessmentAfterDislysis.CvcV = lastAssessmentAfterDislysis.CvcV
  1171. tempassessmentAfterDislysis.Channel = lastAssessmentAfterDislysis.Channel
  1172. tempassessmentAfterDislysis.ReturnBlood = lastAssessmentAfterDislysis.ReturnBlood
  1173. tempassessmentAfterDislysis.RehydrationVolume = lastAssessmentAfterDislysis.RehydrationVolume
  1174. tempassessmentAfterDislysis.DialysisDuring = lastAssessmentAfterDislysis.DialysisDuring
  1175. tempassessmentAfterDislysis.StrokeVolume = lastAssessmentAfterDislysis.StrokeVolume
  1176. tempassessmentAfterDislysis.BloodFlow = lastAssessmentAfterDislysis.BloodFlow
  1177. tempassessmentAfterDislysis.SealingFluidDispose = lastAssessmentAfterDislysis.SealingFluidDispose
  1178. tempassessmentAfterDislysis.SealingFluidSpecial = lastAssessmentAfterDislysis.SealingFluidSpecial
  1179. }
  1180. err := service.UpdateAssessmentAfterDislysisRecord(&tempassessmentAfterDislysis)
  1181. if err != nil {
  1182. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
  1183. return
  1184. }
  1185. go func() {
  1186. ssoDomain := beego.AppConfig.String("call_domain")
  1187. api := ssoDomain + "/index/downpatient"
  1188. values := make(url.Values)
  1189. values.Set("org_id", strconv.FormatInt(adminUserInfo.CurrentOrgId, 10))
  1190. values.Set("admin_user_id", strconv.FormatInt(nurseID, 10))
  1191. values.Set("patient_id", strconv.FormatInt(patientID, 10))
  1192. http.PostForm(api, values)
  1193. }()
  1194. updateErr := service.ModifyDialysisRecord(dialysisRecord.ID, nurseID, endDate.Unix(), adminUserInfo.AdminUser.Id)
  1195. key := strconv.FormatInt(adminUserInfo.CurrentOrgId, 10) + ":" + strconv.FormatInt(patientID, 10) + ":" + strconv.FormatInt(recordDate.Unix(), 10) + ":dialysis_order"
  1196. redis := service.RedisClient()
  1197. defer redis.Close()
  1198. //清空key 值
  1199. redis.Set(key, "", time.Second)
  1200. keyOne := strconv.FormatInt(adminUserInfo.CurrentOrgId, 10) + ":" + strconv.FormatInt(recordDate.Unix(), 10) + ":dialysis_orders_list_all"
  1201. redis.Set(keyOne, "", time.Second)
  1202. if updateErr != nil {
  1203. this.ErrorLog("下机失败:%v", updateErr)
  1204. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
  1205. return
  1206. } else {
  1207. dialysisRecord.Stage = 2
  1208. dialysisRecord.FinishNurse = nurseID
  1209. dialysisRecord.FinishCreator = adminUserInfo.AdminUser.Id
  1210. dialysisRecord.FinishModifier = adminUserInfo.AdminUser.Id
  1211. dialysisRecord.EndTime = endDate.Unix()
  1212. // 结束时候透析次数加1
  1213. service.UpdateSolutionByPatientId(patientID)
  1214. this.ServeSuccessJSON(map[string]interface{}{
  1215. "dialysis_order": dialysisRecord,
  1216. "assessmentAfterDislysis": tempassessmentAfterDislysis,
  1217. })
  1218. }
  1219. }
  1220. func (this *DialysisRecordAPIController) ModifyStartDialysis() {
  1221. record_id, _ := this.GetInt64("id")
  1222. nurseID, _ := this.GetInt64("nurse")
  1223. puncture_nurse, _ := this.GetInt64("puncture_nurse")
  1224. bedID, _ := this.GetInt64("bed")
  1225. start_time := this.GetString("start_time")
  1226. washpipe_nurse, _ := this.GetInt64("washpipe_nurse")
  1227. schedual_type, _ := this.GetInt64("schedual_type")
  1228. change_nurse, _ := this.GetInt64("change_nurse")
  1229. difficult_puncture_nurse, _ := this.GetInt64("difficult_puncture_nurse")
  1230. new_fistula_nurse, _ := this.GetInt64("new_fistula_nurse")
  1231. if record_id == 0 {
  1232. this.ErrorLog("id:%v", record_id)
  1233. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
  1234. return
  1235. }
  1236. startDate, parseStartDateErr := utils.ParseTimeStringToTime("2006-01-02 15:04", start_time)
  1237. if parseStartDateErr != nil {
  1238. this.ErrorLog("时间解析失败:%v", parseStartDateErr)
  1239. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
  1240. return
  1241. }
  1242. adminUserInfo := this.GetAdminUserInfo()
  1243. nurse, getNurseErr := service.GetAdminUserByUserID(nurseID)
  1244. if getNurseErr != nil {
  1245. this.ErrorLog("获取护士失败:%v", getNurseErr)
  1246. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
  1247. return
  1248. } else if nurse == nil {
  1249. this.ErrorLog("护士不存在")
  1250. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
  1251. return
  1252. }
  1253. //nurse, getNurseErr = service.GetAdminUserByUserID(puncture_nurse)
  1254. //if getNurseErr != nil {
  1255. // this.ErrorLog("获取护士失败:%v", getNurseErr)
  1256. // this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
  1257. // return
  1258. //} else if nurse == nil {
  1259. // this.ErrorLog("护士不存在")
  1260. // this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
  1261. // return
  1262. //}
  1263. deviceNumber, getDeviceNumberErr := service.GetDeviceNumberByID(adminUserInfo.CurrentOrgId, bedID)
  1264. if getDeviceNumberErr != nil {
  1265. this.ErrorLog("获取床位号失败:%v", getDeviceNumberErr)
  1266. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
  1267. return
  1268. } else if deviceNumber == nil {
  1269. this.ErrorLog("床位号不存在")
  1270. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
  1271. return
  1272. }
  1273. _, tempDialysisRecord := service.FindDialysisOrderById(record_id)
  1274. //if tempDialysisRecord.Creator != adminUserInfo.AdminUser.Id {
  1275. // headNursePermission, getPermissionErr := service.GetAdminUserSpecialPermission(adminUserInfo.CurrentOrgId, adminUserInfo.CurrentAppId, adminUserInfo.AdminUser.Id, models.SpecialPermissionTypeHeadNurse)
  1276. // if getPermissionErr != nil {
  1277. // this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
  1278. // return
  1279. // } else if headNursePermission == nil {
  1280. // this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDialysisPermissionDeniedModify)
  1281. // return
  1282. // }
  1283. //}
  1284. scheduleDateStart := startDate.Format("2006-01-02") + " 00:00:00"
  1285. scheduleDateEnd := startDate.Format("2006-01-02") + " 23:59:59"
  1286. timeLayout := "2006-01-02 15:04:05"
  1287. loc, _ := time.LoadLocation("Local")
  1288. theStartTime, _ := time.ParseInLocation(timeLayout, scheduleDateStart, loc)
  1289. theEndTime, _ := time.ParseInLocation(timeLayout, scheduleDateEnd, loc)
  1290. schedulestartTime := theStartTime.Unix()
  1291. scheduleendTime := theEndTime.Unix()
  1292. //查询更改的机号,是否有人用了,如果只是排班了,但是没上机,直接替换,如果排班且上机了,就提示他无法上机
  1293. schedule, err := service.GetDayScheduleByBedid(adminUserInfo.CurrentOrgId, schedulestartTime, bedID, schedual_type)
  1294. daySchedule, _ := service.GetDaySchedule(adminUserInfo.CurrentOrgId, schedulestartTime, scheduleendTime, tempDialysisRecord.PatientId)
  1295. if daySchedule.BedId != bedID || daySchedule.ScheduleType != schedual_type {
  1296. if err == gorm.ErrRecordNotFound { //空床位
  1297. // 修改了床位逻辑
  1298. daySchedule, _ := service.GetDaySchedule(adminUserInfo.CurrentOrgId, schedulestartTime, scheduleendTime, tempDialysisRecord.PatientId)
  1299. if daySchedule.ID > 0 {
  1300. //daySchedule.BedId = bedID
  1301. //daySchedule.PartitionId = deviceNumber.ZoneID
  1302. //daySchedule.ScheduleType = schedual_type
  1303. //daySchedule.UpdatedTime = time.Now().Unix()
  1304. //err := service.UpdateSchedule(&daySchedule)
  1305. xtSchedule := models.Schedule{
  1306. PartitionId: deviceNumber.ZoneID,
  1307. BedId: bedID,
  1308. ScheduleType: schedual_type,
  1309. UpdatedTime: time.Now().Unix(),
  1310. }
  1311. err := service.UpdateScheduleOne(daySchedule.ID, xtSchedule)
  1312. if err != nil {
  1313. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
  1314. return
  1315. }
  1316. }
  1317. } else if err == nil {
  1318. if schedule.ID > 0 && schedule.DialysisOrder.ID == 0 { //有排班没上机记录
  1319. daySchedule, _ := service.GetDaySchedule(adminUserInfo.CurrentOrgId, schedulestartTime, scheduleendTime, tempDialysisRecord.PatientId)
  1320. if daySchedule.ID > 0 {
  1321. //daySchedule.BedId = bedID
  1322. //daySchedule.PartitionId = deviceNumber.ZoneID
  1323. //
  1324. //daySchedule.ScheduleType = schedual_type
  1325. //daySchedule.UpdatedTime = time.Now().Unix()
  1326. //err := service.UpdateSchedule(&daySchedule)
  1327. xtSchedule := models.Schedule{
  1328. PartitionId: deviceNumber.ZoneID,
  1329. BedId: bedID,
  1330. ScheduleType: schedual_type,
  1331. UpdatedTime: time.Now().Unix(),
  1332. }
  1333. err := service.UpdateScheduleOne(daySchedule.ID, xtSchedule)
  1334. if err != nil {
  1335. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
  1336. return
  1337. }
  1338. }
  1339. } else if schedule.ID > 0 && schedule.DialysisOrder.ID > 0 { //有排班且有上机记录
  1340. this.ServeFailJSONWithSGJErrorCode(enums.ErrorDialysisOrderRepeatBed)
  1341. return
  1342. }
  1343. } else if err != nil {
  1344. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
  1345. return
  1346. }
  1347. }
  1348. dialysisRecord := &models.DialysisOrder{
  1349. ID: record_id,
  1350. UserOrgId: adminUserInfo.CurrentOrgId,
  1351. BedID: bedID,
  1352. StartNurse: nurseID,
  1353. StartTime: startDate.Unix(),
  1354. PunctureNurse: puncture_nurse,
  1355. Creator: adminUserInfo.AdminUser.Id,
  1356. Modifier: adminUserInfo.AdminUser.Id,
  1357. SchedualType: schedual_type,
  1358. WashpipeNurse: washpipe_nurse,
  1359. ChangeNurse: change_nurse,
  1360. DifficultPunctureNurse: difficult_puncture_nurse,
  1361. NewFistulaNurse: new_fistula_nurse,
  1362. }
  1363. updateErr := service.ModifyStartDialysisOrder(dialysisRecord)
  1364. redis := service.RedisClient()
  1365. key := strconv.FormatInt(adminUserInfo.CurrentOrgId, 10) + ":" + strconv.FormatInt(startDate.Unix(), 10) + ":dialysis_orders_list_all"
  1366. redis.Set(key, "", time.Second)
  1367. redis.Close()
  1368. if updateErr != nil {
  1369. this.ErrorLog("修改上机失败:%v", updateErr)
  1370. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
  1371. return
  1372. }
  1373. if updateErr == nil {
  1374. if tempDialysisRecord.Stage == 2 {
  1375. temp_time := (float64(tempDialysisRecord.EndTime) - float64(startDate.Unix())) / 3600
  1376. value, _ := strconv.ParseFloat(fmt.Sprintf("%.2f", temp_time), 64)
  1377. fmt.Println(value)
  1378. a, b := math.Modf(value)
  1379. tempMinute, _ := strconv.ParseFloat(fmt.Sprintf("%.2f", b), 64)
  1380. hour, _ := strconv.ParseInt(fmt.Sprintf("%.0f", a), 10, 64)
  1381. minute, _ := strconv.ParseInt(fmt.Sprintf("%.0f", tempMinute*60), 10, 64)
  1382. updateAssessmentErr := service.UpdateAssessmentAfterDate(tempDialysisRecord.PatientId, tempDialysisRecord.UserOrgId, tempDialysisRecord.DialysisDate, hour, minute)
  1383. redis := service.RedisClient()
  1384. keyThree := strconv.FormatInt(adminUserInfo.CurrentOrgId, 10) + ":" + strconv.FormatInt(tempDialysisRecord.DialysisDate, 10) + ":assessment_after_dislysis_list_all"
  1385. key := strconv.FormatInt(adminUserInfo.CurrentOrgId, 10) + ":" + strconv.FormatInt(tempDialysisRecord.DialysisDate, 10) + ":dialysis_orders_list_all"
  1386. redis.Set(key, "", time.Second)
  1387. redis.Set(keyThree, "", time.Second)
  1388. redis.Close()
  1389. if updateAssessmentErr != nil {
  1390. utils.ErrorLog("%v", updateAssessmentErr)
  1391. }
  1392. after, _ := service.FindAssessmentAfterDislysisById(tempDialysisRecord.UserOrgId, tempDialysisRecord.PatientId, tempDialysisRecord.DialysisDate)
  1393. _, dialysisRecords := service.FindDialysisOrderById(record_id)
  1394. this.ServeSuccessJSON(map[string]interface{}{
  1395. "dialysis_order": dialysisRecords,
  1396. "after": after,
  1397. })
  1398. } else {
  1399. _, dialysisRecords := service.FindDialysisOrderById(record_id)
  1400. this.ServeSuccessJSON(map[string]interface{}{
  1401. "dialysis_order": dialysisRecords,
  1402. })
  1403. }
  1404. }
  1405. }
  1406. func (c *DialysisRecordAPIController) ModifyFinishDialysis() {
  1407. record_id, _ := c.GetInt64("id")
  1408. nurseID, _ := c.GetInt64("nurse")
  1409. end_time := c.GetString("end_time")
  1410. if record_id <= 0 || nurseID <= 0 {
  1411. c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
  1412. return
  1413. }
  1414. adminUserInfo := c.GetAdminUserInfo()
  1415. nurse, getNurseErr := service.GetAdminUserByUserID(nurseID)
  1416. if getNurseErr != nil {
  1417. c.ErrorLog("获取护士失败:%v", getNurseErr)
  1418. c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
  1419. return
  1420. } else if nurse == nil {
  1421. c.ErrorLog("护士不存在")
  1422. c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
  1423. return
  1424. }
  1425. endDate, parseEndDateErr := utils.ParseTimeStringToTime("2006-01-02 15:04", end_time)
  1426. if parseEndDateErr != nil {
  1427. c.ErrorLog("日期(%v)解析错误:%v", end_time, parseEndDateErr)
  1428. c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
  1429. return
  1430. }
  1431. _, tempDialysisRecords := service.FindDialysisOrderById(record_id)
  1432. //if tempDialysisRecords.FinishCreator != adminUserInfo.AdminUser.Id {
  1433. // headNursePermission, getPermissionErr := service.GetAdminUserSpecialPermission(adminUserInfo.CurrentOrgId, adminUserInfo.CurrentAppId, adminUserInfo.AdminUser.Id, models.SpecialPermissionTypeHeadNurse)
  1434. // if getPermissionErr != nil {
  1435. // c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
  1436. // return
  1437. // } else if headNursePermission == nil {
  1438. // c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDialysisPermissionDeniedModify)
  1439. // return
  1440. // }
  1441. //}
  1442. dialysisRecord := &models.DialysisOrder{
  1443. ID: record_id,
  1444. UserOrgId: adminUserInfo.CurrentOrgId,
  1445. EndTime: endDate.Unix(),
  1446. FinishNurse: nurseID,
  1447. FinishModifier: adminUserInfo.AdminUser.Id,
  1448. }
  1449. updateErr := service.ModifyFinishDialysisOrder(dialysisRecord)
  1450. key := strconv.FormatInt(adminUserInfo.CurrentOrgId, 10) + ":" + strconv.FormatInt(tempDialysisRecords.PatientId, 10) + ":" + strconv.FormatInt(tempDialysisRecords.DialysisDate, 10) + ":dialysis_order"
  1451. redis := service.RedisClient()
  1452. defer redis.Close()
  1453. //清空key 值
  1454. redis.Set(key, "", time.Second)
  1455. keyOne := strconv.FormatInt(adminUserInfo.CurrentOrgId, 10) + ":" + ":dialysis_orders_list_all"
  1456. redis.Set(keyOne, "", time.Second)
  1457. if updateErr != nil {
  1458. c.ErrorLog("修改下机失败:%v", updateErr)
  1459. c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
  1460. return
  1461. }
  1462. if updateErr == nil {
  1463. temp_time := (float64(endDate.Unix()) - float64(tempDialysisRecords.StartTime)) / 3600
  1464. value, _ := strconv.ParseFloat(fmt.Sprintf("%.2f", temp_time), 64)
  1465. fmt.Println(value)
  1466. a, b := math.Modf(value)
  1467. tempMinute, _ := strconv.ParseFloat(fmt.Sprintf("%.2f", b), 64)
  1468. hour, _ := strconv.ParseInt(fmt.Sprintf("%.0f", a), 10, 64)
  1469. minute, _ := strconv.ParseInt(fmt.Sprintf("%.0f", tempMinute*60), 10, 64)
  1470. updateAssessmentErr := service.UpdateAssessmentAfterDate(tempDialysisRecords.PatientId, tempDialysisRecords.UserOrgId, tempDialysisRecords.DialysisDate, hour, minute)
  1471. if updateAssessmentErr != nil {
  1472. utils.ErrorLog("%v", updateAssessmentErr)
  1473. }
  1474. }
  1475. after, _ := service.FindAssessmentAfterDislysisById(tempDialysisRecords.UserOrgId, tempDialysisRecords.PatientId, tempDialysisRecords.DialysisDate)
  1476. _, dialysisRecords := service.FindDialysisOrderById(record_id)
  1477. c.ServeSuccessJSON(map[string]interface{}{
  1478. "dialysis_order": dialysisRecords,
  1479. "after": after,
  1480. })
  1481. }