patientmanage_service.go 68KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447
  1. package service
  2. import (
  3. "Xcx_New/models"
  4. "fmt"
  5. "github.com/jinzhu/gorm"
  6. "strconv"
  7. "strings"
  8. "time"
  9. )
  10. func GetIllnessListTwo() (ills []*models.Illness, err error) {
  11. err = readUserDb.Where("status=1").Find(&ills).Error
  12. return
  13. }
  14. func GetBloodDialysisPatient(orgid int64, page int64, limit int64) (patients []*models.Patients, total int64, err error) {
  15. db := XTReadDB().Table("xt_patients_new as x").Where("x.status = 1")
  16. if orgid > 0 {
  17. db = db.Where("x.user_org_id = ?", orgid)
  18. }
  19. offset := (page - 1) * limit
  20. err = db.Count(&total).Order("x.created_time desc").Offset(offset).Limit(limit).
  21. Select("x.id,x.user_org_id,x.user_id,x.avatar,x.patient_type,x.dialysis_no,x.admission_number,x.source,x.lapseto,x.partition_id,x.bed_id,x.name,x.alias,x.gender,x.marital_status,x.id_card_no,x.birthday,x.reimbursement_way_id,x.health_care_type,x.health_care_no,x.health_care_due_date,x.height,x.blood_type,x.rh,x.health_care_due_alert_date,x.education_level,x.profession,x.phone,x.home_telephone,x.relative_phone,x.relative_relations,x.home_address,x.work_unit,x.unit_address,x.children,x.receiving_date,x.is_hospital_first_dialysis,x.first_dialysis_date,x.first_dialysis_hospital,x.predialysis_condition,x.pre_hospital_dialysis_frequency,x.pre_hospital_dialysis_times,x.hospital_first_dialysis_date,x.induction_period,x.initial_dialysis,x.total_dialysis,x.attending_doctor_id,x.head_nurse_id,x.evaluate,x.diagnose,x.remark,x.registrars_id,x.registrars,x.qr_code,x.binding_state,x.patient_complains,x.present_history,x.past_history,x.temperature,x.pulse,x.respiratory,x.sbp,x.dbp,x.status,x.created_time,x.updated_time,x.nation,x.native_place,x.age,x.blood_patients,x.slow_patients,x.member_patients,x.ecommer_patients,x.blood_id,x.slow_id,x.member_id").Find(&patients).Error
  22. fmt.Println("err是什么", err)
  23. return
  24. }
  25. func GetAllBloodDialysisPatient(orgid int64, page int64, limit int64, lapseto int64, source int64) (patients []*models.XtPatientsNew, total int64, err error) {
  26. db := XTReadDB().Table("xt_patients_new as x").Where("x.status = 1")
  27. if orgid > 0 {
  28. db = db.Where("x.user_org_id = ? and x.blood_patients = 1", orgid)
  29. }
  30. if lapseto > 0 {
  31. db = db.Where("x.lapseto = ?", lapseto)
  32. }
  33. if source > 0 {
  34. db = db.Where("x.source = ?", source)
  35. }
  36. offset := (page - 1) * limit
  37. err = db.Count(&total).Order("x.created_time desc").Offset(offset).Limit(limit).
  38. Select("x.id,x.user_org_id,x.user_id,x.avatar,x.patient_type,x.dialysis_no,x.admission_number,x.source,x.lapseto,x.partition_id,x.bed_id,x.name,x.alias,x.gender,x.marital_status,x.id_card_no,x.birthday,x.reimbursement_way_id,x.health_care_type,x.health_care_no,x.health_care_due_date,x.height,x.blood_type,x.rh,x.health_care_due_alert_date,x.education_level,x.profession,x.phone,x.home_telephone,x.relative_phone,x.relative_relations,x.home_address,x.work_unit,x.unit_address,x.children,x.receiving_date,x.is_hospital_first_dialysis,x.first_dialysis_date,x.first_dialysis_hospital,x.predialysis_condition,x.pre_hospital_dialysis_frequency,x.pre_hospital_dialysis_times,x.hospital_first_dialysis_date,x.induction_period,x.initial_dialysis,x.total_dialysis,x.attending_doctor_id,x.head_nurse_id,x.evaluate,x.diagnose,x.remark,x.registrars_id,x.registrars,x.qr_code,x.binding_state,x.patient_complains,x.present_history,x.past_history,x.temperature,x.pulse,x.respiratory,x.sbp,x.dbp,x.status,x.created_time,x.updated_time,x.nation,x.native_place,x.age,x.blood_patients,x.slow_patients,x.member_patients,x.ecommer_patients,x.blood_id,x.slow_id,x.member_id").Find(&patients).Error
  39. fmt.Println("err是什么", err)
  40. return
  41. }
  42. func GetAllSlowPatient(orgid int64, page int64, limit int64) (patients []*models.XtPatientsNew, total int64, err error) {
  43. db := XTReadDB().Table("xt_patients_new as x").Where("x.status = 1")
  44. if orgid > 0 {
  45. db = db.Where("x.user_org_id = ? and x.slow_patients = 1", orgid)
  46. }
  47. offset := (page - 1) * limit
  48. err = db.Count(&total).Order("x.created_time desc").Offset(offset).Limit(limit).
  49. Select("x.id,x.user_org_id,x.user_id,x.avatar,x.patient_type,x.dialysis_no,x.admission_number,x.source,x.lapseto,x.partition_id,x.bed_id,x.name,x.alias,x.gender,x.marital_status,x.id_card_no,x.birthday,x.reimbursement_way_id,x.health_care_type,x.health_care_no,x.health_care_due_date,x.height,x.blood_type,x.rh,x.health_care_due_alert_date,x.education_level,x.profession,x.phone,x.home_telephone,x.relative_phone,x.relative_relations,x.home_address,x.work_unit,x.unit_address,x.children,x.receiving_date,x.is_hospital_first_dialysis,x.first_dialysis_date,x.first_dialysis_hospital,x.predialysis_condition,x.pre_hospital_dialysis_frequency,x.pre_hospital_dialysis_times,x.hospital_first_dialysis_date,x.induction_period,x.initial_dialysis,x.total_dialysis,x.attending_doctor_id,x.head_nurse_id,x.evaluate,x.diagnose,x.remark,x.registrars_id,x.registrars,x.qr_code,x.binding_state,x.patient_complains,x.present_history,x.past_history,x.temperature,x.pulse,x.respiratory,x.sbp,x.dbp,x.status,x.created_time,x.updated_time,x.nation,x.native_place,x.age,x.blood_patients,x.slow_patients,x.member_patients,x.ecommer_patients,x.blood_id,x.slow_id,x.member_id").Find(&patients).Error
  50. fmt.Println("err是什么", err)
  51. return
  52. }
  53. func GetAllMemberPatient(orgid int64, page int64, limit int64) (patients []*models.XtPatientsNew, total int64, err error) {
  54. db := XTReadDB().Table("xt_patients_new as x").Where("x.status = 1")
  55. if orgid > 0 {
  56. db = db.Where("x.user_org_id = ? and x.member_patients = 1", orgid)
  57. }
  58. offset := (page - 1) * limit
  59. err = db.Count(&total).Order("x.created_time desc").Offset(offset).Limit(limit).
  60. Select("x.id,x.user_org_id,x.user_id,x.avatar,x.patient_type,x.dialysis_no,x.admission_number,x.source,x.lapseto,x.partition_id,x.bed_id,x.name,x.alias,x.gender,x.marital_status,x.id_card_no,x.birthday,x.reimbursement_way_id,x.health_care_type,x.health_care_no,x.health_care_due_date,x.height,x.blood_type,x.rh,x.health_care_due_alert_date,x.education_level,x.profession,x.phone,x.home_telephone,x.relative_phone,x.relative_relations,x.home_address,x.work_unit,x.unit_address,x.children,x.receiving_date,x.is_hospital_first_dialysis,x.first_dialysis_date,x.first_dialysis_hospital,x.predialysis_condition,x.pre_hospital_dialysis_frequency,x.pre_hospital_dialysis_times,x.hospital_first_dialysis_date,x.induction_period,x.initial_dialysis,x.total_dialysis,x.attending_doctor_id,x.head_nurse_id,x.evaluate,x.diagnose,x.remark,x.registrars_id,x.registrars,x.qr_code,x.binding_state,x.patient_complains,x.present_history,x.past_history,x.temperature,x.pulse,x.respiratory,x.sbp,x.dbp,x.status,x.created_time,x.updated_time,x.nation,x.native_place,x.age,x.blood_patients,x.slow_patients,x.member_patients,x.ecommer_patients,x.blood_id,x.slow_id,x.member_id").Find(&patients).Error
  61. fmt.Println("err是什么", err)
  62. return
  63. }
  64. func GetAllPatient(orgid int64) (patients []*models.PatientsNew, err error) {
  65. db := XTReadDB().Table("xt_patients_new as x")
  66. err = db.Raw("select id,name from xt_patients_new where user_org_id = ? and status =1", orgid).Scan(&patients).Error
  67. return
  68. }
  69. func ChechLastDialysisNoTwo(orgID int64) (dialysisNo int64) {
  70. var patient models.Patients
  71. err := readDb.Model(&models.Patients{}).Where("user_org_id=? and status = 1", orgID).Order("dialysis_no desc").First(&patient).Error
  72. if err != nil {
  73. return
  74. }
  75. if patient.ID == 0 {
  76. return
  77. }
  78. dialysisNo, _ = strconv.ParseInt(patient.DialysisNo, 10, 64)
  79. return
  80. }
  81. func GetBloodPatientInfo(orgid int64, phone string) (*models.Patients, error) {
  82. patients := models.Patients{}
  83. var err error
  84. err = XTReadDB().Model(&patients).Where("user_org_id = ? and phone = ? and status = 1", orgid, phone).Find(&patients).Error
  85. if err == gorm.ErrRecordNotFound {
  86. return nil, err
  87. }
  88. if err != nil {
  89. return nil, err
  90. }
  91. return &patients, nil
  92. }
  93. func GetSlowPatientInfo(orgid int64, phone string) (*models.CdmPatients, error) {
  94. patients := models.CdmPatients{}
  95. var err error
  96. err = PatientReadDB().Model(&patients).Where("user_org_id = ? and phone = ? and status = 1", orgid, phone).Find(&patients).Error
  97. if err == gorm.ErrRecordNotFound {
  98. return nil, err
  99. }
  100. if err != nil {
  101. return nil, err
  102. }
  103. return &patients, nil
  104. }
  105. func GetMemberPatientInfo(orgid int64, phone string) (*models.SgjUserCustomer, error) {
  106. customer := models.SgjUserCustomer{}
  107. err := UserReadDB().Model(&customer).Where("user_org_id = ? and mobile = ? and status =1", orgid, phone).Find(&customer).Error
  108. if err == gorm.ErrRecordNotFound {
  109. return nil, err
  110. }
  111. if err != nil {
  112. return nil, err
  113. }
  114. return &customer, nil
  115. }
  116. func CreateOldPatient(patients *models.Patients) error {
  117. err := XTWriteDB().Create(&patients).Error
  118. return err
  119. }
  120. func GetLastOldPatient(orgid int64) (models.Patients, error) {
  121. patients := models.Patients{}
  122. err := XTReadDB().Model(&patients).Where("user_org_id = ? and status =1", orgid).Last(&patients).Error
  123. return patients, err
  124. }
  125. func AddContagions(patienid int64, createdtime int64, updatedtime int64, contagions []int64) (err error) {
  126. utx := writeDb.Begin()
  127. if len(contagions) > 0 {
  128. thisSQL := "INSERT INTO xt_patients_infectious_diseases (patient_id, disease_id, status, created_time, updated_time) VALUES "
  129. insertParams := make([]string, 0)
  130. insertData := make([]interface{}, 0)
  131. for _, contagion := range contagions {
  132. insertParams = append(insertParams, "(?, ?, ?, ?, ?)")
  133. insertData = append(insertData, patienid)
  134. insertData = append(insertData, contagion)
  135. insertData = append(insertData, 1)
  136. insertData = append(insertData, createdtime)
  137. insertData = append(insertData, updatedtime)
  138. }
  139. thisSQL += strings.Join(insertParams, ",")
  140. err = utx.Exec(thisSQL, insertData...).Error
  141. fmt.Println("这个错误err", err)
  142. }
  143. utx.Commit()
  144. return
  145. }
  146. func AddSlowContagions(patienid int64, createdtime int64, updatedtime int64, contagions []int64, orgid int64) (err error) {
  147. utx := PatientWriteDB().Begin()
  148. if len(contagions) > 0 {
  149. thisSQL := "INSERT INTO xt_patients_infectious_diseases (patient_id, disease_id, status, created_time, updated_time,user_org_id) VALUES "
  150. insertParams := make([]string, 0)
  151. insertData := make([]interface{}, 0)
  152. for _, contagion := range contagions {
  153. insertParams = append(insertParams, "(?, ?, ?, ?, ?,?)")
  154. insertData = append(insertData, patienid)
  155. insertData = append(insertData, contagion)
  156. insertData = append(insertData, 1)
  157. insertData = append(insertData, createdtime)
  158. insertData = append(insertData, updatedtime)
  159. insertData = append(insertData, orgid)
  160. }
  161. thisSQL += strings.Join(insertParams, ", ")
  162. err = utx.Exec(thisSQL, insertData...).Error
  163. if err != nil {
  164. utx.Rollback()
  165. utx.Rollback()
  166. return
  167. }
  168. }
  169. utx.Commit()
  170. return
  171. }
  172. func AddSlowDiseases(patienid int64, createdtime int64, updatedtime int64, diseases []int64, orgid int64) (err error) {
  173. utx := PatientWriteDB().Begin()
  174. if len(diseases) > 0 {
  175. thisSQL := "INSERT INTO xt_patients_chronic_diseases (patient_id, disease_id, status, created_time, updated_time,user_org_id) VALUES "
  176. insertParams := make([]string, 0)
  177. insertData := make([]interface{}, 0)
  178. for _, disease := range diseases {
  179. insertParams = append(insertParams, "(?, ?, ?, ?, ?,?)")
  180. insertData = append(insertData, patienid)
  181. insertData = append(insertData, disease)
  182. insertData = append(insertData, 1)
  183. insertData = append(insertData, createdtime)
  184. insertData = append(insertData, updatedtime)
  185. insertData = append(insertData, orgid)
  186. }
  187. thisSQL += strings.Join(insertParams, ", ")
  188. err = utx.Exec(thisSQL, insertData...).Error
  189. if err != nil {
  190. utx.Rollback()
  191. return
  192. }
  193. }
  194. utx.Commit()
  195. return
  196. }
  197. func CreateNewPatient(patientsNew *models.XtPatientsNew) error {
  198. err := XTWriteDB().Create(&patientsNew).Error
  199. return err
  200. }
  201. func CreateCdmPatient(cdmpatient *models.CdmPatients) error {
  202. err := PatientWriteDB().Create(&cdmpatient).Error
  203. return err
  204. }
  205. func CreateMemberPatient(customer *models.SgjUserCustomer) error {
  206. err := UserWriteDB().Create(&customer).Error
  207. return err
  208. }
  209. func GetOldCdmPatient(orgid int64) (models.CdmPatients, error) {
  210. patients := models.CdmPatients{}
  211. err := PatientReadDB().Model(&patients).Where("user_org_id = ? and status =1", orgid).Last(&patients).Error
  212. return patients, err
  213. }
  214. func GetPatientDetailTwo(id int64) (models.XtPatientsNew, error) {
  215. patients := models.XtPatientsNew{}
  216. err := XTReadDB().Where("id=? and status = 1", id).Find(&patients).Error
  217. return patients, err
  218. }
  219. func GetPatientNewId(id int64) (models.XtPatientsNew, error) {
  220. patientsNew := models.XtPatientsNew{}
  221. err := XTReadDB().Where("blood_id = ? and status = 1", id).Find(&patientsNew).Error
  222. return patientsNew, err
  223. }
  224. func GetPatientDiseasesTwo(id int64) []int64 {
  225. var dis []models.XtPatientsInfectiousDiseases
  226. ids := make([]int64, 0)
  227. err := XTReadDB().Model(&models.XtPatientsInfectiousDiseases{}).Where("patient_id = ? and status = 1", id).Find(&dis).Error
  228. if err != nil || len(dis) == 0 {
  229. return ids
  230. }
  231. for _, item := range dis {
  232. ids = append(ids, item.DiseaseId)
  233. }
  234. return ids
  235. }
  236. func GetSlowPatientDiseases(id int64) (infeciousdisease []*models.CdmPatientsInfectiousDiseases, err error) {
  237. //var dis []models.CdmPatientsInfectiousDiseases
  238. //diseases := models.CdmPatientsChronicDiseases{}
  239. //ids := make([]int64, 0)
  240. //err := PatientReadDB().Model(&diseases).Where("patient_id = ? and status =1", id).Find(&ids).Error
  241. //if err != nil || len(dis) == 0 {
  242. // return ids
  243. //}
  244. //for _, item := range dis {
  245. // ids = append(ids, item.DiseaseId)
  246. //}
  247. //return ids
  248. err = PatientReadDB().Model(&infeciousdisease).Where("patient_id = ? and status =1", id).Find(&infeciousdisease).Error
  249. return infeciousdisease, err
  250. }
  251. func GetCronicDiseases(id int64) (chronic []*models.CdmPatientsChronicDiseases, err error) {
  252. //var dis []models.CdmPatientsChronicDiseases
  253. //ids := make([]int64, 0)
  254. //err := PatientReadDB().Model(&models.CdmPatientsChronicDiseases{}).Where("patient_id = ? and status =1", id).Find(&ids).Error
  255. //if err != nil || len(dis) == 0 {
  256. // return ids
  257. //}
  258. //for _, item := range dis {
  259. // ids = append(ids, item.DiseaseId)
  260. //}
  261. //return ids
  262. err = PatientReadDB().Model(&chronic).Where("patient_id = ? and status =1", id).Find(&chronic).Error
  263. return chronic, err
  264. }
  265. func CreatePatientTwo(patient *models.Patients, contagions []int64, diseases []int64) (err error) {
  266. user, _ := GetSgjUserByMobild(patient.Phone)
  267. customer, _ := GetSgjCoustomerByMobile(patient.UserOrgId, patient.Phone)
  268. utx := writeDb.Begin()
  269. btx := writeUserDb.Begin()
  270. if user.ID == 0 {
  271. user.Mobile = patient.Phone
  272. user.Avatar = patient.Avatar
  273. user.AvatarThumb = patient.Avatar
  274. user.Birthday = patient.Birthday
  275. user.Username = patient.Name
  276. user.Gender = patient.Gender
  277. user.Sources = 11
  278. user.Introduce = patient.Remark
  279. user.Status = 1
  280. user.UpdatedTime = patient.UpdatedTime
  281. user.CreatedTime = patient.CreatedTime
  282. err = btx.Create(&user).Error
  283. if err != nil {
  284. utx.Rollback()
  285. btx.Rollback()
  286. return
  287. }
  288. }
  289. patient.UserId = user.ID
  290. if customer == nil {
  291. err = btx.Create(&models.SgjCustomer{
  292. UserOrgId: patient.UserOrgId,
  293. UserId: user.ID,
  294. Mobile: patient.Phone,
  295. Name: patient.Name,
  296. Gender: patient.Gender,
  297. Birthday: patient.Birthday,
  298. Sources: 11,
  299. Status: 1,
  300. CreatedTime: patient.CreatedTime,
  301. UpdatedTime: patient.UpdatedTime,
  302. Avatar: patient.Avatar,
  303. Remark: patient.Remark,
  304. }).Error
  305. if err != nil {
  306. utx.Rollback()
  307. btx.Rollback()
  308. return
  309. }
  310. }
  311. err = utx.Create(patient).Error
  312. if err != nil {
  313. utx.Rollback()
  314. btx.Rollback()
  315. return
  316. }
  317. var lapseto models.PatientLapseto
  318. lapseto.PatientId = patient.ID
  319. lapseto.LapsetoType = patient.Lapseto
  320. lapseto.CreatedTime = patient.CreatedTime
  321. lapseto.UpdatedTime = patient.CreatedTime
  322. lapseto.Status = 1
  323. lapseto.LapsetoTime = patient.CreatedTime
  324. err = utx.Create(&lapseto).Error
  325. if err != nil {
  326. utx.Rollback()
  327. btx.Rollback()
  328. return
  329. }
  330. if len(contagions) > 0 {
  331. thisSQL := "INSERT INTO xt_patients_infectious_diseases (patient_id, disease_id, status, created_time, updated_time) VALUES "
  332. insertParams := make([]string, 0)
  333. insertData := make([]interface{}, 0)
  334. for _, contagion := range contagions {
  335. insertParams = append(insertParams, "(?, ?, ?, ?, ?)")
  336. insertData = append(insertData, patient.ID)
  337. insertData = append(insertData, contagion)
  338. insertData = append(insertData, 1)
  339. insertData = append(insertData, patient.CreatedTime)
  340. insertData = append(insertData, patient.UpdatedTime)
  341. }
  342. thisSQL += strings.Join(insertParams, ", ")
  343. err = utx.Exec(thisSQL, insertData...).Error
  344. if err != nil {
  345. utx.Rollback()
  346. btx.Rollback()
  347. return
  348. }
  349. }
  350. if len(diseases) > 0 {
  351. thisSQL := "INSERT INTO xt_patients_chronic_diseases (patient_id, disease_id, status, created_time, updated_time) VALUES "
  352. insertParams := make([]string, 0)
  353. insertData := make([]interface{}, 0)
  354. for _, disease := range diseases {
  355. insertParams = append(insertParams, "(?, ?, ?, ?, ?)")
  356. insertData = append(insertData, patient.ID)
  357. insertData = append(insertData, disease)
  358. insertData = append(insertData, 1)
  359. insertData = append(insertData, patient.CreatedTime)
  360. insertData = append(insertData, patient.UpdatedTime)
  361. }
  362. thisSQL += strings.Join(insertParams, ", ")
  363. err = utx.Exec(thisSQL, insertData...).Error
  364. if err != nil {
  365. utx.Rollback()
  366. btx.Rollback()
  367. return
  368. }
  369. }
  370. utx.Commit()
  371. btx.Commit()
  372. return
  373. }
  374. func FindPatientByMobileFive(mobile string, orgID int64) (patient models.XtPatientsNew, err error) {
  375. err = readDb.Model(&models.Patients{}).Where("phone=? and user_org_id=? and status=1", mobile, orgID).First(&patient).Error
  376. return
  377. }
  378. func FindPatientByDialysisNoFive(orgID int64, dialysisNo string) (patient models.Patients, err error) {
  379. err = readDb.Model(&models.Patients{}).Where("status=1 and user_org_id=? and dialysis_no=?", orgID, dialysisNo).First(&patient).Error
  380. return
  381. }
  382. func FindPatientByIdCardNoFive(orgID int64, idCardNo string) (patient models.XtPatientsNew, err error) {
  383. err = readDb.Model(&models.Patients{}).Where("status=1 and user_org_id=? and id_card_no=?", orgID, idCardNo).First(&patient).Error
  384. return
  385. }
  386. func FindPatientByIdCardNoOne(orgID int64, idCardNo string, id int64) (patient models.XtPatientsNew, err error) {
  387. err = readDb.Model(&models.Patients{}).Where("status=1 and user_org_id=? and id_card_no=? and id<>?", orgID, idCardNo, id).First(&patient).Error
  388. return
  389. }
  390. func FindPatientByDialysisNoOne(orgID int64, dialysisNo string, id int64) (patient models.Patients, err error) {
  391. err = readDb.Model(&models.Patients{}).Where("status=1 and user_org_id=? and dialysis_no=? and id<>?", orgID, dialysisNo, id).First(&patient).Error
  392. return
  393. }
  394. func FindPatientByMobileOne(mobile string, orgID int64, id int64) (patient models.XtPatientsNew, err error) {
  395. //err = readDb.Model(&models.Patients{}).Where(" status=1 and user_org_id=? and phone=? and id<>?", orgID, mobile, id).First(&patient).Error
  396. //return
  397. db := readDb.Table("xt_patients_new as x")
  398. err = db.Not("phone = ?", mobile).Where("user_org_id = ? and id = ? and status =1", orgID, id).Find(&patient).Error
  399. return
  400. }
  401. func GetPatientData(phone string, orgid int64) (*models.XtPatientsNew, error) {
  402. var patientnew models.XtPatientsNew
  403. var err error
  404. err = XTReadDB().Model(&patientnew).Where("user_org_id = ? and phone = ? and status =? and blood_patients = ?", orgid, phone, 1, 1).Find(&patientnew).Error
  405. if err == gorm.ErrRecordNotFound {
  406. return nil, err
  407. }
  408. if err != nil {
  409. return nil, err
  410. }
  411. return &patientnew, nil
  412. }
  413. func GetSlowPatientData(phone string, orgid int64) (*models.CdmPatients, error) {
  414. var patientnew models.CdmPatients
  415. err = PatientReadDB().Model(&patientnew).Where("user_org_id = ? and phone = ? and status = ?", orgid, phone, 1).Find(&patientnew).Error
  416. if err == gorm.ErrRecordNotFound {
  417. return nil, err
  418. }
  419. if err != nil {
  420. return nil, err
  421. }
  422. return &patientnew, nil
  423. }
  424. func GetMemberNewPatient(phone string, orgid int64) (*models.XtPatientsNew, error) {
  425. var patientnew models.XtPatientsNew
  426. err = XTReadDB().Model(&patientnew).Where("user_org_id = ? and phone = ? and status = ? and member_patients = ?", orgid, phone, 1, 1).Find(&patientnew).Error
  427. if err == gorm.ErrRecordNotFound {
  428. return nil, err
  429. }
  430. if err != nil {
  431. return nil, err
  432. }
  433. return &patientnew, nil
  434. }
  435. func GetLastMemberPatient(orgid int64) (models.SgjUserCustomer, error) {
  436. customer := models.SgjUserCustomer{}
  437. err := UserReadDB().Model(&customer).Where("user_org_id = ? and status = 1", orgid).Last(&customer).Error
  438. return customer, err
  439. }
  440. func GetLastNewSlowPatient(phone string, orgid int64) (*models.XtPatientsNew, error) {
  441. var patientnew models.XtPatientsNew
  442. err = XTReadDB().Model(&patientnew).Where("user_org_id = ? and phone = ? and status = ? and slow_patients = ?", orgid, phone, 1, 1).Find(&patientnew).Error
  443. if err == gorm.ErrRecordNotFound {
  444. return nil, err
  445. }
  446. if err != nil {
  447. return nil, err
  448. }
  449. return &patientnew, nil
  450. }
  451. func GetNewDoctorAdvice(patientID int64, advice_type int64, start int64, end int64, limit int64, page int64, orgID int64) (doctoradvice []*models.DoctorAdvices, total int64, err error) {
  452. db := readDb.Table("xt_doctor_advice as x").Where("x.status = 1")
  453. table := UserReadDB().Table("sgj_user_admin_role as r")
  454. fmt.Print("table", table)
  455. if orgID > 0 {
  456. db = db.Where("x.user_org_id=?", orgID)
  457. }
  458. if patientID > 0 {
  459. db = db.Where("x.patient_id = ?", patientID)
  460. }
  461. if advice_type == 1 {
  462. db = db.Where("x.advice_type = ?", advice_type)
  463. }
  464. if advice_type == 3 {
  465. db = db.Where("x.advice_type <> 1")
  466. }
  467. if start > 0 {
  468. db = db.Where("x.start_time>=?", start)
  469. }
  470. if end > 0 {
  471. db = db.Where("x.start_time<=?", end)
  472. }
  473. //offset := (page - 1) * limit
  474. err = db.Group("x.id").Count(&total).Select("x.id, x.user_org_id, x.patient_id, x.advice_type, x.advice_date, x.record_date, x.start_time, x.advice_name,x.advice_desc, x.reminder_date, x.drug_spec, x.drug_spec_unit, x.single_dose, x.single_dose_unit, x.prescribing_number, x.prescribing_number_unit, x.delivery_way, x.execution_frequency, x.advice_doctor, x.status, x.created_time,x.updated_time, x.advice_affirm, x.remark, x.stop_time, x.stop_reason, x.stop_doctor, x.stop_state, x.parent_id, x.execution_time, x.execution_staff, x.execution_state, x.checker, x.check_state, x.check_time, x.groupno,x.remind_type,x.frequency_type,x.day_count,x.week_day,x.parent_id,r.user_name, IF(x.parent_id > 0, x.parent_id, x.id) as advice_order").Joins("Left join sgj_users.sgj_user_admin_role as r on r.admin_user_id = x.advice_doctor").Order("start_time desc, groupno desc, advice_order desc, id asc").Scan(&doctoradvice).Error
  475. fmt.Print("err", err)
  476. return
  477. }
  478. func GetNewDoctorAdviceOne(patientID int64, advice_type int64, start int64, end int64, limit int64, page int64, orgID int64) (doctoradvice []*models.DoctorAdvice, total int64, err error) {
  479. db := readDb.Table("xt_doctor_advice as x").Where("x.status = 1")
  480. table := UserReadDB().Table("sgj_user_admin_role as r")
  481. fmt.Println("table", table)
  482. if orgID > 0 {
  483. db = db.Where("x.user_org_id=?", orgID)
  484. }
  485. if patientID > 0 {
  486. db = db.Where("x.patient_id = ?", patientID)
  487. }
  488. if advice_type == 1 {
  489. db = db.Where("x.advice_type = ?", advice_type)
  490. }
  491. if advice_type == 3 {
  492. db = db.Where("x.advice_type <> 1")
  493. }
  494. if start > 0 {
  495. db = db.Where("x.start_time>=?", start)
  496. }
  497. if end > 0 {
  498. db = db.Where("x.start_time<=?", end)
  499. }
  500. offset := (page - 1) * limit
  501. err = db.Order("x.start_time desc").Group("x.start_time").Count(&total).Offset(offset).Limit(limit).Select("x.id, x.user_org_id, x.patient_id, x.advice_type, x.advice_date, x.record_date, x.start_time, x.advice_name,x.advice_desc, x.reminder_date, x.drug_spec, x.drug_spec_unit, x.single_dose, x.single_dose_unit, x.prescribing_number, x.prescribing_number_unit, x.delivery_way, x.execution_frequency, x.advice_doctor, x.status, x.created_time,x.updated_time, x.advice_affirm, x.remark, x.stop_time, x.stop_reason, x.stop_doctor, x.stop_state, x.parent_id, x.execution_time, x.execution_staff, x.execution_state, x.checker, x.check_state, x.check_time, x.groupno,x.remind_type,x.frequency_type,x.day_count,x.week_day,x.parent_id,r.user_name, IF(x.parent_id > 0, x.parent_id, x.id) as advice_order").Joins("Left join sgj_users.sgj_user_admin_role as r on r.admin_user_id = x.advice_doctor").Scan(&doctoradvice).Error
  502. fmt.Print("错误是什么", err)
  503. return
  504. }
  505. func GetDryWeight(patientid int64, startime int64, endtime int64, limit int64, page int64, orgId int64) (dryWeight []*models.XtPatientDryweight, total int64, err error) {
  506. db := XTReadDB().Table("xt_patient_dryweight as x").Where("x.status = 1")
  507. if orgId > 0 {
  508. db = db.Where("x.user_org_id = ?", orgId)
  509. }
  510. if patientid > 0 {
  511. db = db.Where("x.patient_id = ?", patientid)
  512. }
  513. if startime > 0 {
  514. db = db.Where("x.ctime >= ?", startime)
  515. }
  516. if endtime > 0 {
  517. db = db.Where("x.ctime <=?", endtime)
  518. }
  519. offset := (page - 1) * limit
  520. err = db.Count(&total).Order("x.ctime desc").Offset(offset).Limit(limit).Group("x.id").
  521. Select("x.id,x.dry_weight,x.creator,x.remakes,x.patient_id,x.ctime,x.adjusted_value,x.user_id,x.user_org_id,r.user_name").Joins("left join sgj_users.sgj_user_admin_role as r on r.admin_user_id = x.creator").Scan(&dryWeight).Error
  522. return dryWeight, total, err
  523. }
  524. func ToSearch(orgId int64, name string) (patient []*models.XtPatientsNew, err error) {
  525. likeKey := "%" + name + "%"
  526. err = XTReadDB().Where("name like ? and user_org_id = ?", likeKey, orgId).Find(&patient).Error
  527. return patient, err
  528. }
  529. func GetCourseManagement(patientid int64, startime int64, endtime int64, limit int64, page int64, orgid int64) (patientCourse []*models.PatientCourseOfDiseases, total int64, err error) {
  530. db := XTReadDB().Table("xt_patient_course_of_disease as x").Where("x.status = 1")
  531. if patientid > 0 {
  532. db = db.Where("x.patient_id = ?", patientid)
  533. }
  534. if orgid > 0 {
  535. db = db.Where("x.org_id = ?", orgid)
  536. }
  537. if startime > 0 {
  538. db = db.Where("x.record_time >=?", startime)
  539. }
  540. if endtime > 0 {
  541. db = db.Where("x.record_time <= ?", endtime)
  542. }
  543. offset := (page - 1) * limit
  544. err = db.Count(&total).Order("x.ctime desc").Offset(offset).Limit(limit).Group("x.id").
  545. Select("x.id,x.org_id,x.patient_id,x.recorder,x.record_time,x.content,x.title,r.user_name").Joins("left join sgj_users.sgj_user_admin_role as r on r.admin_user_id = x.recorder").Scan(&patientCourse).Error
  546. return patientCourse, total, err
  547. }
  548. func DeleteCouseManagement(patientid int64) error {
  549. err := XTWriteDB().Model(models.PatientCourseOfDisease{}).Where("id = ?", patientid).Update(map[string]interface{}{"status": 0, "mtime": time.Now().Unix()}).Error
  550. return err
  551. }
  552. func GetCouseManagentDetail(id int64) (models.PatientCourseOfDiseasess, error) {
  553. disease := models.PatientCourseOfDiseasess{}
  554. db := XTReadDB().Table("xt_patient_course_of_disease as x")
  555. err := db.Select("x.id,x.org_id,x.patient_id,x.recorder,x.record_time,x.content,x.title,s.name,r.user_name").Joins("left join xt_patients as s on s.id = x.patient_id ").Joins("left join sgj_users.sgj_user_admin_role as r on r.admin_user_id = x.recorder").Where("x.id = ?", id).Scan(&disease).Error
  556. return disease, err
  557. }
  558. func DeleteDryWeight(id int64) error {
  559. err := XTWriteDB().Model(models.SgjPatientDryweight{}).Where("id=?", id).Update(map[string]interface{}{"status": 0, "mtime": time.Now().Unix()}).Error
  560. return err
  561. }
  562. func GetDryWeightDetail(id int64) (models.SgjPatientDryweights, error) {
  563. dryweight := models.SgjPatientDryweights{}
  564. db := XTReadDB().Table("xt_patient_dryweight as x")
  565. err := db.Select("x.id,x.dry_weight,x.creator,x.remakes,x.patient_id,x.adjusted_value,x.user_org_id,x.user_id,x.ctime,s.name,r.user_name").Joins("left join xt_patients as s on s.id = x.patient_id").Joins("left join sgj_users.sgj_user_admin_role as r on r.admin_user_id = x.user_id").Where("x.id = ?", id).Scan(&dryweight).Error
  566. return dryweight, err
  567. }
  568. func GetlongDialysisrecord(patientid int64, startime int64, endtime int64, limit int64, page int64, orgid int64) (prescription []*models.XtDialysisSolution, total int64, err error) {
  569. db := XTReadDB().Table("xt_dialysis_solution as x").Where("x.status = 1")
  570. if patientid > 0 {
  571. db = db.Where("x.patient_id = ?", patientid)
  572. }
  573. if orgid > 0 {
  574. db = db.Where("x.user_org_id = ?", orgid)
  575. }
  576. if startime > 0 {
  577. db = db.Where("x.created_time >=?", startime)
  578. }
  579. if endtime > 0 {
  580. db = db.Where("x.created_time <= ?", endtime)
  581. }
  582. offset := (page - 1) * limit
  583. err = db.Count(&total).Order("x.created_time desc").Offset(offset).Limit(limit).Group("x.id").
  584. Select("x.id,x.name,x.sub_name,x.user_org_id,x.patient_id,x.parent_id,x.type,x.period,x.times,x.anticoagulant,x.anticoagulant_shouji,x.anticoagulant_weichi,x.anticoagulant_zongliang,x.anticoagulant_gaimingcheng,x.anticoagulant_gaijiliang,x.mode_name,x.mode_id,x.dialysis_duration,x.replacement_way,x.hemodialysis_machine,x.blood_filter,x.perfusion_apparatus,x.blood_flow_volume,x.dewater,x.displace_liqui,x.glucose,x.dry_weight,x.dialysate_flow,x.kalium,x.sodium,x.calcium,x.bicarbonate,x.doctor,x.first_dialysis,x.remark,x.initiate_mode,x.affirm_state,x.use_state,x.status,x.registrars_id,x.created_time,x.updated_time,x.solution_type,x.dialysate_temperature,x.conductivity,x.dialysis_duration_hour,x.dialysis_duration_minute,x.target_ultrafiltration,x.dialysate_formulation,x.dialyzer,x.replacement_total,x.dialyzer_perfusion_apparatus,x.body_fluid,x.special_medicine,x.special_medicine_other,x.displace_liqui_part,x.displace_liqui_value,x.blood_access,x.ultrafiltration,x.body_fluid_other,x.target_ktv").Find(&prescription).Error
  585. return
  586. }
  587. func GetRescuerecord(patientid int64, startime int64, endtime int64, limit int64, page int64, orgid int64) (rescuerecord []*models.XtPatientRescueRecords, total int64, err error) {
  588. db := XTReadDB().Table("xt_patient_rescue_record as x").Where("x.status = 1")
  589. if patientid > 0 {
  590. db = db.Where("x.patient_id = ?", patientid)
  591. }
  592. if orgid > 0 {
  593. db = db.Where("x.org_id = ?", orgid)
  594. }
  595. if startime > 0 {
  596. db = db.Where("x.record_time >=?", startime)
  597. }
  598. if endtime > 0 {
  599. db = db.Where("x.record_time <= ?", endtime)
  600. }
  601. offset := (page - 1) * limit
  602. err = db.Count(&total).Order("x.record_time desc").Offset(offset).Limit(limit).Group("x.id").
  603. Select("x.id,x.org_id,x.patient_id,x.recorder,x.record_time,x.content,x.status,r.user_name").Joins("left join sgj_users.sgj_user_admin_role as r on r.admin_user_id = x.recorder").Scan(&rescuerecord).Error
  604. return
  605. }
  606. func GetScheduling(patientid int64, startime int64, endtime int64, limit int64, page int64, orgid int64, modeType int64) (schedules []*models.XtSchedules, total int64, err error) {
  607. db := XTReadDB().Table("xt_schedule as x").Where("x.status = 1")
  608. if patientid > 0 {
  609. db = db.Where("x.patient_id = ?", patientid)
  610. }
  611. if orgid > 0 {
  612. db = db.Where("x.user_org_id = ?", orgid)
  613. }
  614. if startime > 0 {
  615. db = db.Where("x.schedule_date >=?", startime)
  616. }
  617. if endtime > 0 {
  618. db = db.Where("x.schedule_date <= ?", endtime)
  619. }
  620. if modeType > 0 {
  621. db = db.Where("x.mode_id = ?", modeType)
  622. }
  623. offset := (page - 1) * limit
  624. err = db.Count(&total).Order("x.schedule_date desc").Offset(offset).Limit(limit).Group("x.id").
  625. Select("x.id,x.user_org_id,x.partition_id,x.bed_id,x.patient_id,x.schedule_date,x.schedule_type,x.schedule_week,x.mode_id,x.status,x.created_time,x.updated_time,s.number,z.name").Joins("left join xt_device_number as s on s.id = x.bed_id").Joins("left join xt_device_zone as z on z.id = x.partition_id").Scan(&schedules).Error
  626. return
  627. }
  628. func GetEducation(patientid int64, startime int64, endtime int64, limit int64, page int64, orgid int64) (treatment []*models.XtTreatmentSummary, total int64, err error) {
  629. db := XTReadDB().Table("xt_treatment_summary as x").Where("x.status = 1")
  630. if patientid > 0 {
  631. db = db.Where("x.patient_id = ?", patientid)
  632. }
  633. if orgid > 0 {
  634. db = db.Where("x.user_org_id = ?", orgid)
  635. }
  636. if startime > 0 {
  637. db = db.Where("x.assessment_date >=?", startime)
  638. }
  639. if endtime > 0 {
  640. db = db.Where("x.assessment_date <= ?", endtime)
  641. }
  642. offset := (page - 1) * limit
  643. err = db.Count(&total).Order("x.assessment_date desc").Offset(offset).Limit(limit).Group("x.id").
  644. Select("x.id,x.user_org_id,x.patient_id,x.assessment_date,x.dialysis_order_id,x.mission,x.dialysis_summary,x.change,x.sj_nurse,x.zl_nurse,x.hd_nurse,x.xj_nurse,x.zl_doctor,x.channel_image,x.puncture,x.puncture_needle,x.puncture_direction,x.status,x.created_time,x.updated_time,x.creater,x.modifier").Scan(&treatment).Error
  645. return
  646. }
  647. func GetSchedulingDetail(id int64) (models.XtScheduless, error) {
  648. schedules := models.XtScheduless{}
  649. db := XTReadDB().Table("xt_schedule as x")
  650. err := db.Select("x.id,x.user_org_id,x.partition_id,x.bed_id,x.patient_id,x.schedule_date,x.schedule_type,x.schedule_week,x.mode_id,n.number,z.name").Joins("left join xt_device_number as n on n.id = x.bed_id").Joins("left join xt_device_zone as z on z.id = x.partition_id").Where("x.id =?", id).Scan(&schedules).Error
  651. return schedules, err
  652. }
  653. func GetSchedulingTwo(id int64) (models.XtScheduless, error) {
  654. schedules := models.XtScheduless{}
  655. db := XTReadDB().Table("xt_schedule as x")
  656. err := db.Select("x.id,x.user_org_id,x.partition_id,x.bed_id,x.patient_id,x.schedule_date,x.schedule_type,x.schedule_week,x.mode_id,z.name").Joins("left join xt_patients as z on z.id = x.patient_id").Where("x.id =?", id).Scan(&schedules).Error
  657. return schedules, err
  658. }
  659. func DeleteScheduling(id int64) error {
  660. err := XTWriteDB().Model(models.XtSchedules{}).Where("id=?", id).Update(map[string]interface{}{"status": 0, "updated_time": time.Now().Unix()}).Error
  661. return err
  662. }
  663. func GetEducationDetailOne(id int64) (models.XtTreatmentSummarys, error) {
  664. summarys := models.XtTreatmentSummarys{}
  665. db := XTReadDB().Table("xt_treatment_summary as x")
  666. err := db.Select("x.id,x.user_org_id,x.patient_id,x.assessment_date,x.dialysis_order_id,x.mission,x.dialysis_summary,x.change,x.sj_nurse,x.zl_nurse,x.hd_nurse,x.xj_nurse,x.zl_doctor,x.channel_image,x.puncture,x.puncture_needle,x.puncture_direction,x.status,x.created_time,x.creater,x.modifier,s.name").Joins("left join xt_patients as s on s.id = x.patient_id").Where("x.id = ?", id).Scan(&summarys).Error
  667. return summarys, err
  668. }
  669. func DeleteEducation(id int64) error {
  670. err := XTWriteDB().Model(models.XtTreatmentSummary{}).Where("id=?", id).Update(map[string]interface{}{"status": 0, "updated_time": time.Now().Unix()}).Error
  671. return err
  672. }
  673. func GetRescueRecordDetail(id int64) (models.XtPatientRescueRecords, error) {
  674. records := models.XtPatientRescueRecords{}
  675. db := XTReadDB().Table("xt_patient_rescue_record as x")
  676. err := db.Select("x.id,x.org_id,x.patient_id,x.recorder,x.record_time,x.content,x.status,r.user_name,s.name").Joins("left join sgj_users.sgj_user_admin_role as r on r.admin_user_id = x.recorder").Joins("left join xt_patients as s on s.id = x.patient_id").Where("x.id=?", id).Scan(&records).Error
  677. return records, err
  678. }
  679. func DeleteRescueRecord(id int64) error {
  680. err := XTWriteDB().Model(models.XtPatientRescueRecord{}).Where("id=?", id).Update(map[string]interface{}{"status": 0, "updated_time": time.Now().Unix()}).Error
  681. return err
  682. }
  683. func ToSearchePatient(keyword string, orgId int64) (paitents []*models.XtPatientsNew, err error) {
  684. likeKey := "%" + keyword + "%"
  685. err = XTReadDB().Where("user_org_id = ? and name like ? or dialysis_no like ?", orgId, likeKey, likeKey).Find(&paitents).Error
  686. return paitents, err
  687. }
  688. func SearchallPatient(keyword string, orgid int64) (patients []*models.XtPatientsNew, err error) {
  689. db := XTReadDB().Table("xt_patients_new as x").Where("x.status = 1")
  690. if len(keyword) > 0 {
  691. likeKey := "%" + keyword + "%"
  692. db = db.Where("x.name LIKE ? OR x.dialysis_no LIKE ?", likeKey, likeKey)
  693. }
  694. if orgid > 0 {
  695. db = db.Where("x.user_org_id = ?", orgid)
  696. }
  697. err = db.Select("x.id,x.user_org_id,x.user_id,x.avatar,x.patient_type,x.dialysis_no,x.admission_number,x.source,x.lapseto,x.partition_id,x.bed_id,x.name,x.alias,x.gender,x.marital_status,x.id_card_no,x.birthday,x.reimbursement_way_id,x.health_care_type,x.health_care_no,x.health_care_due_date,x.height,x.blood_type,x.rh,x.health_care_due_alert_date,x.education_level,x.profession,x.phone,x.home_telephone,x.relative_phone,x.relative_relations,x.home_address,x.work_unit,x.unit_address,x.children,x.receiving_date,x.is_hospital_first_dialysis,x.first_dialysis_date,x.first_dialysis_hospital,x.predialysis_condition,x.pre_hospital_dialysis_frequency,x.pre_hospital_dialysis_times,x.hospital_first_dialysis_date,x.induction_period,x.initial_dialysis,x.total_dialysis,x.attending_doctor_id,x.head_nurse_id,x.evaluate,x.diagnose,x.remark,x.registrars_id,x.registrars,x.qr_code,x.binding_state,x.patient_complains,x.present_history,x.past_history,x.temperature,x.pulse,x.respiratory,x.sbp,x.dbp,x.status,x.created_time,x.updated_time,x.nation,x.native_place,x.age,x.infectious_next_record_time,x.is_infectious,x.remind_cycle,x.response_result,x.is_open_remind,x.first_treatment_date,x.dialysis_age,x.expense_kind,x.tell_phone,x.contact_name,x.blood_patients,x.slow_patients,x.member_patients,x.ecommer_patients,x.blood_id,x.slow_id,x.member_id,x.member_fistdate,x.member_patienttype,x.member_treatement,x.equitment_id").Find(&patients).Error
  698. return patients, err
  699. }
  700. func GetSearchallBlood(keyword string, orgid int64) (patients []*models.XtPatientsNew, err error) {
  701. db := XTReadDB().Table("xt_patients_new as x").Where("x.status = 1 and x.blood_patients = 1")
  702. if len(keyword) > 0 {
  703. likeKey := "%" + keyword + "%"
  704. db = db.Where("x.name LIKE ? OR x.dialysis_no LIKE ?", likeKey, likeKey)
  705. }
  706. if orgid > 0 {
  707. db = db.Where("x.user_org_id = ?", orgid)
  708. }
  709. err = db.Select("x.id,x.user_org_id,x.user_id,x.avatar,x.patient_type,x.dialysis_no,x.admission_number,x.source,x.lapseto,x.partition_id,x.bed_id,x.name,x.alias,x.gender,x.marital_status,x.id_card_no,x.birthday,x.reimbursement_way_id,x.health_care_type,x.health_care_no,x.health_care_due_date,x.height,x.blood_type,x.rh,x.health_care_due_alert_date,x.education_level,x.profession,x.phone,x.home_telephone,x.relative_phone,x.relative_relations,x.home_address,x.work_unit,x.unit_address,x.children,x.receiving_date,x.is_hospital_first_dialysis,x.first_dialysis_date,x.first_dialysis_hospital,x.predialysis_condition,x.pre_hospital_dialysis_frequency,x.pre_hospital_dialysis_times,x.hospital_first_dialysis_date,x.induction_period,x.initial_dialysis,x.total_dialysis,x.attending_doctor_id,x.head_nurse_id,x.evaluate,x.diagnose,x.remark,x.registrars_id,x.registrars,x.qr_code,x.binding_state,x.patient_complains,x.present_history,x.past_history,x.temperature,x.pulse,x.respiratory,x.sbp,x.dbp,x.status,x.created_time,x.updated_time,x.nation,x.native_place,x.age,x.infectious_next_record_time,x.is_infectious,x.remind_cycle,x.response_result,x.is_open_remind,x.first_treatment_date,x.dialysis_age,x.expense_kind,x.tell_phone,x.contact_name,x.blood_patients,x.slow_patients,x.member_patients,x.ecommer_patients,x.blood_id,x.slow_id,x.member_id,x.member_fistdate,x.member_patienttype,x.member_treatement,x.equitment_id").Find(&patients).Error
  710. return patients, err
  711. }
  712. func GetSlowSearchePatient(keyword string, orgid int64) (patients []*models.XtPatientsNew, err error) {
  713. db := XTReadDB().Table("xt_patients_new as x").Where("x.status = 1 and x.slow_patients = 1")
  714. if len(keyword) > 0 {
  715. likeKey := "%" + keyword + "%"
  716. db = db.Where("x.name LIKE ? OR x.dialysis_no LIKE ?", likeKey, likeKey)
  717. }
  718. if orgid > 0 {
  719. db = db.Where("x.user_org_id = ?", orgid)
  720. }
  721. err = db.Select("x.id,x.user_org_id,x.user_id,x.avatar,x.patient_type,x.dialysis_no,x.admission_number,x.source,x.lapseto,x.partition_id,x.bed_id,x.name,x.alias,x.gender,x.marital_status,x.id_card_no,x.birthday,x.reimbursement_way_id,x.health_care_type,x.health_care_no,x.health_care_due_date,x.height,x.blood_type,x.rh,x.health_care_due_alert_date,x.education_level,x.profession,x.phone,x.home_telephone,x.relative_phone,x.relative_relations,x.home_address,x.work_unit,x.unit_address,x.children,x.receiving_date,x.is_hospital_first_dialysis,x.first_dialysis_date,x.first_dialysis_hospital,x.predialysis_condition,x.pre_hospital_dialysis_frequency,x.pre_hospital_dialysis_times,x.hospital_first_dialysis_date,x.induction_period,x.initial_dialysis,x.total_dialysis,x.attending_doctor_id,x.head_nurse_id,x.evaluate,x.diagnose,x.remark,x.registrars_id,x.registrars,x.qr_code,x.binding_state,x.patient_complains,x.present_history,x.past_history,x.temperature,x.pulse,x.respiratory,x.sbp,x.dbp,x.status,x.created_time,x.updated_time,x.nation,x.native_place,x.age,x.infectious_next_record_time,x.is_infectious,x.remind_cycle,x.response_result,x.is_open_remind,x.first_treatment_date,x.dialysis_age,x.expense_kind,x.tell_phone,x.contact_name,x.blood_patients,x.slow_patients,x.member_patients,x.ecommer_patients,x.blood_id,x.slow_id,x.member_id,x.member_fistdate,x.member_patienttype,x.member_treatement,x.equitment_id").Find(&patients).Error
  722. return patients, err
  723. }
  724. func GetMemberSearchPatient(keyword string, orgid int64) (patients []*models.XtPatientsNew, err error) {
  725. db := XTReadDB().Table("xt_patients_new as x").Where("x.status = 1 and x.member_patients = 1")
  726. if len(keyword) > 0 {
  727. likeKey := "%" + keyword + "%"
  728. db = db.Where("x.name LIKE ? OR x.dialysis_no LIKE ?", likeKey, likeKey)
  729. }
  730. if orgid > 0 {
  731. db = db.Where("x.user_org_id = ?", orgid)
  732. }
  733. err = db.Select("x.id,x.user_org_id,x.user_id,x.avatar,x.patient_type,x.dialysis_no,x.admission_number,x.source,x.lapseto,x.partition_id,x.bed_id,x.name,x.alias,x.gender,x.marital_status,x.id_card_no,x.birthday,x.reimbursement_way_id,x.health_care_type,x.health_care_no,x.health_care_due_date,x.height,x.blood_type,x.rh,x.health_care_due_alert_date,x.education_level,x.profession,x.phone,x.home_telephone,x.relative_phone,x.relative_relations,x.home_address,x.work_unit,x.unit_address,x.children,x.receiving_date,x.is_hospital_first_dialysis,x.first_dialysis_date,x.first_dialysis_hospital,x.predialysis_condition,x.pre_hospital_dialysis_frequency,x.pre_hospital_dialysis_times,x.hospital_first_dialysis_date,x.induction_period,x.initial_dialysis,x.total_dialysis,x.attending_doctor_id,x.head_nurse_id,x.evaluate,x.diagnose,x.remark,x.registrars_id,x.registrars,x.qr_code,x.binding_state,x.patient_complains,x.present_history,x.past_history,x.temperature,x.pulse,x.respiratory,x.sbp,x.dbp,x.status,x.created_time,x.updated_time,x.nation,x.native_place,x.age,x.infectious_next_record_time,x.is_infectious,x.remind_cycle,x.response_result,x.is_open_remind,x.first_treatment_date,x.dialysis_age,x.expense_kind,x.tell_phone,x.contact_name,x.blood_patients,x.slow_patients,x.member_patients,x.ecommer_patients,x.blood_id,x.slow_id,x.member_id,x.member_fistdate,x.member_patienttype,x.member_treatement,x.equitment_id").Find(&patients).Error
  734. return patients, err
  735. }
  736. func GetLongDialysisDetail(id int64) (models.XtDialysisSolution, error) {
  737. solution := models.XtDialysisSolution{}
  738. err := XTReadDB().Model(&solution).Where("id=? and status =1", id).Find(&solution).Error
  739. return solution, err
  740. }
  741. func GetPatientName(id int64) (models.Patients, error) {
  742. patientsNew := models.Patients{}
  743. err := XTReadDB().Model(&patientsNew).Where("id=? and status = 1", id).Find(&patientsNew).Error
  744. return patientsNew, err
  745. }
  746. func DeleteLongDialysis(id int64) error {
  747. err := XTWriteDB().Model(models.XtDialysisSolution{}).Where("id=?", id).Update(map[string]interface{}{"status": 0, "mtime": time.Now().Unix()}).Error
  748. return err
  749. }
  750. func GetDialysisrecord(patientID int64, start int64, end int64, limit int64, page int64, orgID int64, mode_id int64) ([]*models.PatientDialysisRecord, int64, error) {
  751. offset := (page - 1) * limit
  752. var total int64
  753. var err error
  754. var orders []*models.PatientDialysisRecord
  755. db := readDb.Table("xt_dialysis_order as do").
  756. Preload("DialysisPrescription", "patient_id=? and user_org_id=? and status=1", patientID, orgID).
  757. Preload("PredialysisEvaluation", "patient_id=? and user_org_id=? and status=1", patientID, orgID).
  758. Preload("DialysisPrescription", func(db *gorm.DB) *gorm.DB {
  759. return readDb.Where("patient_id=? and user_org_id=? and status=1", patientID, orgID).Preload("UserAdminRole", func(db *gorm.DB) *gorm.DB {
  760. return readUserDb.Where("status = 1")
  761. })
  762. }).
  763. Preload("AssessmentAfterDislysis", "patient_id=? and user_org_id=? and status=1", patientID, orgID).
  764. Preload("TreatmentSummary", "patient_id=? and user_org_id=? and status=1", patientID, orgID).
  765. Preload("Device", "org_id=? and status=1", orgID).
  766. Preload("UserAdminRole", func(db *gorm.DB) *gorm.DB {
  767. return readUserDb.Where("org_id=? and status = 1", orgID)
  768. }).
  769. Joins("JOIN xt_schedule as s ON s.patient_id=? and FROM_UNIXTIME(s.schedule_date, '%Y-%m-%d')=FROM_UNIXTIME(do.dialysis_date, '%Y-%m-%d')", patientID).
  770. Joins("JOIN xt_device_zone as dz ON dz.org_id = ? and dz.id=s.partition_id", orgID).
  771. Where("do.patient_id=? and do.user_org_id=? and do.stage = 2 and do.status=1", patientID, orgID).Group("s.schedule_date")
  772. if start > 0 {
  773. db = db.Where("do.dialysis_date>=?", start)
  774. }
  775. if end > 0 {
  776. db = db.Where("do.dialysis_date<=?", end)
  777. }
  778. if mode_id > 0 {
  779. db = db.Joins("JOIN xt_dialysis_prescription as dp ON dp.record_id=do.id")
  780. db = db.Where("dp.mode_id=?", mode_id)
  781. }
  782. err = db.Count(&total).Offset(offset).Limit(limit).Order("do.dialysis_date desc").Select("do.bed_id, do.id, do.dialysis_date, do.user_org_id, do.patient_id, do.prescription_id, do.stage, do.remark, do.status, do.created_time, do.updated_time,do.start_nurse,do.finish_nurse ,s.schedule_type, s.partition_id, dz.name as partition_name").Find(&orders).Error
  783. if len(orders) > 0 {
  784. ids := make([]int64, 0)
  785. for _, order := range orders {
  786. dialyzer := order.DialysisPrescription.Dialyzer
  787. ids = append(ids, dialyzer)
  788. }
  789. if len(ids) > 0 {
  790. var dialyzers []*models.DeviceNumber
  791. err = readDb.Model(&models.DeviceNumber{}).Where("id IN (?) and org_id=? and status=1", ids, orgID).Find(&dialyzers).Error
  792. if err != nil {
  793. return nil, 0, err
  794. }
  795. dialyzerMap := make(map[int64]models.DeviceNumber, 0)
  796. for _, item := range dialyzers {
  797. dialyzerMap[item.ID] = *item
  798. }
  799. for orderIndex, order := range orders {
  800. if _, exist := dialyzerMap[order.DialysisPrescription.Dialyzer]; exist {
  801. orders[orderIndex].DeviceNumber = dialyzerMap[order.DialysisPrescription.Dialyzer].Number
  802. }
  803. }
  804. }
  805. }
  806. return orders, total, err
  807. }
  808. func GetAllDoctorTwo(orgid int64, appid int64) (appRole []*models.SgjUserAdminRole, err error) {
  809. err = UserReadDB().Where("org_id = ? and app_id = ? and status = ? ", orgid, appid, 1).Find(&appRole).Error
  810. return appRole, err
  811. }
  812. func GetDoctorAdviceDetail(state int64, id int64, orgid int64) (advices []*models.DoctorAdvices, err error) {
  813. db := XTReadDB().Table("xt_doctor_advice as x")
  814. err = db.Order("x.id desc").Select("x.id,x.user_org_id,x.patient_id,x.advice_type,x.advice_date,x.start_time,x.advice_name,x.advice_desc,x.reminder_date,x.single_dose,x.single_dose_unit,x.prescribing_number,x.prescribing_number_unit,x.delivery_way,x.execution_frequency,x.advice_doctor,x.status,x.created_time,x.updated_time,x.advice_affirm,x.remark,x.stop_time,x.stop_reason,x.stop_doctor,x.stop_state,x.parent_id,x.execution_time,x.execution_staff,x.execution_state,x.checker,x.record_date,x.dialysis_order_id,x.check_time,x.check_state,x.drug_spec,x.drug_spec_unit,x.groupno,x.remind_type,x.frequency_type,x.day_count,x.week_day,x.template_id,x.modifier,s.name").Joins("left join xt_patients as s on s.id=x.patient_id").Where("x.start_time = ? and x.patient_id = ? and x.user_org_id = ? and x.status = 1", state, id, orgid).Scan(&advices).Error
  815. return advices, err
  816. }
  817. func DeleteManagement(groupid int64, orgid int64, patientid int64) error {
  818. err := XTWriteDB().Model(models.DoctorAdvice{}).Where("start_time =? and user_org_id = ? and patient_id =?", groupid, orgid, patientid).Update(map[string]interface{}{"status": 0, "updated_time": time.Now().Unix()}).Error
  819. return err
  820. }
  821. func DeleteChild(id int64) error {
  822. err := XTWriteDB().Model(models.DoctorAdvice{}).Where("id=?", id).Update(map[string]interface{}{"status": 0, "updated_time": time.Now().Unix()}).Error
  823. return err
  824. }
  825. func DeletePatient(id int64) error {
  826. err = XTWriteDB().Model(models.DoctorAdvice{}).Where("id=? or parent_id = ?", id, id).Update(map[string]interface{}{"status": 0, "updated_time": time.Now().Unix()}).Error
  827. return err
  828. }
  829. func GetNewPatient(id int64) (models.XtPatientsNew, error) {
  830. patientsNew := models.XtPatientsNew{}
  831. err := XTReadDB().Model(&patientsNew).Where("id=?", id).Find(&patientsNew).Error
  832. return patientsNew, err
  833. }
  834. func UpdatedPatient(patients models.Patients, id int64) error {
  835. err := XTWriteDB().Model(&patients).Where("id=?", id).Update(map[string]interface{}{"name": patients.Name, "gender": patients.Gender, "birthday": patients.Birthday, "age": patients.Age, "phone": patients.Phone, "lapseto": patients.Lapseto, "admission_number": patients.AdmissionNumber, "first_dialysis_date": patients.FirstDialysisDate, "diagnose": patients.Diagnose, "source": patients.Source, "dialysis_no": patients.DialysisNo, "avatar": patients.Avatar, "id_card_no": patients.IdCardNo, "is_infectious": patients.IsInfectious}).Error
  836. return err
  837. }
  838. func UpdateXtPatientNew(patients models.XtPatientsNew, id int64) error {
  839. err := XTWriteDB().Model(&patients).Where("id=?", id).Update(map[string]interface{}{"name": patients.Name, "gender": patients.Gender, "birthday": patients.Birthday, "age": patients.Age, "phone": patients.Phone, "lapseto": patients.Lapseto, "admission_number": patients.AdmissionNumber, "first_dialysis_date": patients.FirstDialysisDate, "diagnose": patients.Diagnose, "source": patients.Source, "dialysis_no": patients.DialysisNo, "avatar": patients.Avatar, "id_card_no": patients.IdCardNo, "is_infectious": patients.IsInfectious}).Error
  840. return err
  841. }
  842. func UpdateXtPatientNewOne(patients models.XtPatientsNew, id int64) error {
  843. err := XTWriteDB().Model(&patients).Where("id=?", id).Update(map[string]interface{}{"name": patients.Name, "gender": patients.Gender, "birthday": patients.Birthday, "age": patients.Age, "phone": patients.Phone, "lapseto": patients.Lapseto, "adminssion_number": patients.AdmissionNumber, "first_dialysis_date": patients.FirstDialysisDate, "diagnose": patients.Diagnose, "source": patients.Source, "dialysis_no": patients.DialysisNo, "avatar": patients.Avatar, "id_card_no": patients.IdCardNo, "is_infectious": patients.IsInfectious, "member_patienttype": patients.MemberPatienttype, "member_treatement": patients.MemberTreatement}).Error
  844. return err
  845. }
  846. func UpdateContagions(patientid int64) (models.XtPatientsInfectiousDiseases, error) {
  847. diseases := models.XtPatientsInfectiousDiseases{}
  848. err := XTWriteDB().Model(&diseases).Where("patient_id = ?", patientid).Update(map[string]interface{}{"status": 2, "updated_time": time.Now().Unix()}).Error
  849. return diseases, err
  850. }
  851. func UpdateCustomer(cdmpatient models.CdmPatients, id int64) error {
  852. err := PatientWriteDB().Model(&cdmpatient).Where("id=?", id).Update(map[string]interface{}{"name": cdmpatient.Name, "phone": cdmpatient.Phone, "gender": cdmpatient.Gender, "birthday": cdmpatient.Birthday, "diagnose": cdmpatient.Diagnose, "source": cdmpatient.Source, "avatar": cdmpatient.Avatar, "id_card_no": cdmpatient.IdCardNo, "updated_time": cdmpatient.UpdatedTime}).Error
  853. return err
  854. }
  855. func UpdatedCustomer(customer models.SgjUserCustomer, id int64) error {
  856. err := UserWriteDB().Model(&customer).Where("id = ?", id).Update(map[string]interface{}{"name": customer.Name, "mobile": customer.Mobile, "gender": customer.Gender, "birthday": customer.Birthday, "ill_date": customer.IllDate, "avatar": customer.Avatar, "illness_id": customer.IllnessId, "treat_type": customer.TreatType}).Error
  857. return err
  858. }
  859. func GetInspectionByOrgId(orgid int64) (*models.XtInspectionReference, error) {
  860. diseases := models.XtInspectionReference{}
  861. err := XTReadDB().Model(&diseases).Where("org_id = ? and status = 1", orgid).Find(&diseases).Error
  862. if err == gorm.ErrRecordNotFound {
  863. return nil, err
  864. }
  865. if err != nil {
  866. return nil, err
  867. }
  868. return &diseases, nil
  869. }
  870. func GetAllProjectName(date int64, orgid int64, patientid int64) (inspection []*models.XtInspection, err error) {
  871. err = XTReadDB().Model(&inspection).Where("inspect_date = ? and org_id = ? and patient_id = ? and status = 1", date, orgid, patientid).Order("inspect_date desc").Group("project_name").Find(&inspection).Error
  872. return inspection, err
  873. }
  874. func GetAllInspection(orgid int64) (inspection []*models.XtInspectionReference, err error) {
  875. err = XTReadDB().Model(&inspection).Where("org_id = ? and status = 1", orgid).Group("project_name").Find(&inspection).Error
  876. return inspection, err
  877. }
  878. func GetInspection(patientid int64, startime int64, endtime int64, limit int64, page int64, orgid int64, projectid int64) (inspection []*models.Inspection, total int64, err error) {
  879. db := XTReadDB().Table("xt_inspection as x").Where("x.status = 1")
  880. if patientid > 0 {
  881. db = db.Where("x.patient_id = ?", patientid)
  882. }
  883. if startime > 0 {
  884. db = db.Where("x.inspect_date >= ?", startime)
  885. }
  886. if endtime > 0 {
  887. db = db.Where("x.inspect_date<=?", endtime)
  888. }
  889. if orgid > 0 {
  890. db = db.Where("x.org_id = ?", orgid)
  891. }
  892. if projectid > 0 {
  893. db = db.Where("x.project_id = ?", projectid)
  894. }
  895. err = db.Count(&total).Order("x.inspect_date desc").Group("x.id").
  896. Select("x.id,x.patient_id,x.org_id,x.project_id,x.item_id,x.item_name,x.project_name,x.inspect_type,x.inspect_value,x.inspect_date,x.created_time").Find(&inspection).Error
  897. return inspection, total, err
  898. }
  899. func GetInspectionDetail(patientid int64, date int64, orgid int64, projectid int64) (inspection []*models.Inspections, err error) {
  900. db := XTReadDB().Table("xt_inspection as x").Where("x.status =1")
  901. table := XTReadDB().Table("xt_inspection_reference as r")
  902. fmt.Print("table", table)
  903. if patientid > 0 {
  904. db = db.Where("x.patient_id = ?", patientid)
  905. }
  906. if date > 0 {
  907. db = db.Where("x.inspect_date = ?", date)
  908. }
  909. if orgid > 0 {
  910. db = db.Where("x.org_id = ?", orgid)
  911. }
  912. if projectid > 0 {
  913. db = db.Where("x.project_id = ?", projectid)
  914. }
  915. err = db.Group("x.id").Select("x.id,x.patient_id,x.org_id,x.project_id,x.item_id,x.item_name,x.project_name,x.inspect_type,x.inspect_value,x.inspect_date,x.status,x.created_time,x.updated_time,r.range_type,r.range_min,r.range_max,r.range_value,r.range_options,r.unit").Joins("left join xt_inspection_reference as r on (r.item_id = x.item_id AND r.org_id > 0) OR ( x.item_id = r.id AND r.org_id = 0) ").Scan(&inspection).Error
  916. return inspection, err
  917. }
  918. func CreateFeedBack(feedback *models.XtPatientFeedback) error {
  919. err := XTWriteDB().Model(&feedback).Create(&feedback).Error
  920. return err
  921. }
  922. func DeleteInspection(date int64, orgid int64) error {
  923. err := XTWriteDB().Model(models.Inspection{}).Where("inspect_date = ? and org_id = ?", date, orgid).Update(map[string]interface{}{"status": 0, "updated_time": time.Now().Unix()}).Error
  924. return err
  925. }
  926. func DeleteChildInspection(name string, date int64, orgid int64) error {
  927. err := XTWriteDB().Model(models.Inspection{}).Where("project_name = ? and inspect_date = ? and org_id = ?", name, date, orgid).Update(map[string]interface{}{"status": 0, "updated_time": time.Now().Unix()}).Error
  928. return err
  929. }
  930. func SaveMessage(id int64, orgid int64, role *models.SgjUserAdminRole) error {
  931. err := UserWriteDB().Model(models.SgjUserAdminRole{}).Where("admin_user_id = ? and org_id = ?", id, orgid).Update(map[string]interface{}{"message": role.Message, "mtime": time.Now().Unix()}).Error
  932. return err
  933. }
  934. func SaveSex(id int64, role *models.SgjUserAdminRole) error {
  935. err := UserWriteDB().Model(models.SgjUserAdminRole{}).Where("admin_user_id = ?", id).Update(map[string]interface{}{"sex": role.Sex, "mtime": time.Now().Unix()}).Error
  936. return err
  937. }
  938. func SaveBirthday(id int64, role *models.SgjUserAdminRole) error {
  939. err := UserWriteDB().Model(models.SgjUserAdminRole{}).Where("admin_user_id = ?", id).Update(map[string]interface{}{"birthday": role.Birthday, "mtime": time.Now().Unix()}).Error
  940. return err
  941. }
  942. func GetPartitionByName(name string, orgid int64) (*models.DeviceZone, error) {
  943. zone := models.DeviceZone{}
  944. err := XTReadDB().Model(&zone).Where("name = ? and org_id = ? and status = 1", name, orgid).Find(&zone).Error
  945. if err == gorm.ErrRecordNotFound {
  946. return nil, err
  947. }
  948. if err != nil {
  949. return nil, err
  950. }
  951. return &zone, nil
  952. }
  953. func GetPartitionByNameOne(name string, orgid int64) (zone models.DeviceZone, err error) {
  954. err = XTReadDB().Model(&zone).Where("name = ? and org_id = ? and status = 1", name, orgid).First(&zone).Error
  955. return zone, err
  956. }
  957. func CreatedZone(zone *models.DeviceZone) error {
  958. err := XTWriteDB().Model(&zone).Create(&zone).Error
  959. return err
  960. }
  961. func GetAllZone(orgid int64, page int64, limit int64) (zone []*models.DeviceZones, total int64, err error) {
  962. db := XTReadDB().Table("xt_device_zone as x").Where("x.status =1")
  963. table := XTReadDB().Table("xt_device_number as n")
  964. fmt.Println("table", table)
  965. if orgid > 0 {
  966. db = db.Where("x.org_id = ?", orgid)
  967. }
  968. offset := (page - 1) * limit
  969. err = db.Group("x.id").Count(&total).Offset(offset).Limit(limit).Order("x.ctime desc").Select("x.id,x.org_id,x.name,x.type,n.number").Joins("left join xt_device_number as n on n.zone_id = x.id AND n.status = 1").Scan(&zone).Error
  970. return zone, total, err
  971. }
  972. func DeleteZoneById(id int64) error {
  973. err := XTWriteDB().Model(models.DeviceZone{}).Where("id=?", id).Update(map[string]interface{}{"status": 0, "updated_time": time.Now().Unix()}).Error
  974. return err
  975. }
  976. func GetGroupByName(name string, orgid int64) (*models.DeviceGroup, error) {
  977. group := models.DeviceGroup{}
  978. err := XTReadDB().Model(&group).Where("name = ? and org_id = ? and status = 1", name, orgid).Find(&group).Error
  979. if err == gorm.ErrRecordNotFound {
  980. return nil, err
  981. }
  982. if err != nil {
  983. return nil, err
  984. }
  985. return &group, nil
  986. }
  987. func GetGroupByNameOne(name string, orgid int64) (group models.DeviceGroup, err error) {
  988. err = XTReadDB().Model(&group).Where("name = ? and org_id = ? and status =1", name, orgid).First(&group).Error
  989. return group, err
  990. }
  991. func SaveGroup(group *models.DeviceGroup) error {
  992. err := XTWriteDB().Model(&group).Create(&group).Error
  993. return err
  994. }
  995. func GetAllGroup(orgid int64, page int64, limit int64) (group []*models.DeviceGroups, total int64, err error) {
  996. db := XTReadDB().Table("xt_device_group as x").Where("x.status = 1")
  997. table := XTReadDB().Table("xt_device_number as n")
  998. fmt.Println("table", table)
  999. if orgid > 0 {
  1000. db = db.Where("x.org_id = ?", orgid)
  1001. }
  1002. offset := (page - 1) * limit
  1003. err = db.Group("x.id").Count(&total).Offset(offset).Limit(limit).Order("x.ctime desc").Select("x.id,x.org_id,x.name,x.status,x.ctime,x.mtime,n.number").Joins("left join xt_device_number as n on n.group_id = x.id And n.status = 1").Scan(&group).Error
  1004. return group, total, err
  1005. }
  1006. func DeleteGroup(id int64) error {
  1007. err := XTWriteDB().Model(models.DeviceGroup{}).Where("id=?", id).Update(map[string]interface{}{"status": 0, "updated_time": time.Now().Unix()}).Error
  1008. return err
  1009. }
  1010. func GetAllZoneOne(orgid int64) (zone []*models.DeviceZone, err error) {
  1011. err = XTReadDB().Model(&zone).Where("org_id = ?", orgid).Find(&zone).Error
  1012. return zone, err
  1013. }
  1014. func GetAllGroupOne(orgid int64) (group []*models.DeviceGroup, err error) {
  1015. err = XTReadDB().Model(&group).Where("org_id =?", orgid).Find(&group).Error
  1016. return group, err
  1017. }
  1018. func GetBedByName(name string, orgid int64) (*models.DeviceNumber, error) {
  1019. number := models.DeviceNumber{}
  1020. err := XTReadDB().Model(&number).Where("number=? and org_id = ? and status =1", name, orgid).Find(&number).Error
  1021. if err == gorm.ErrRecordNotFound {
  1022. return nil, err
  1023. }
  1024. if err != nil {
  1025. return nil, err
  1026. }
  1027. return &number, nil
  1028. }
  1029. func GetBedByNameOne(name string, orgid int64) (number models.DeviceNumber, err error) {
  1030. err = XTReadDB().Model(&number).Where("number=? and org_id = ? and status = 1", name, orgid).First(&number).Error
  1031. return number, err
  1032. }
  1033. func CreateNumber(number *models.DeviceNumber) error {
  1034. err := XTWriteDB().Model(&number).Create(&number).Error
  1035. return err
  1036. }
  1037. func GetAllNumber(page int64, limit int64, orgid int64) (number []*models.DeviceNumber, total int64, err error) {
  1038. db := XTReadDB().Table("xt_device_number as x").Where("x.status = 1")
  1039. if orgid > 0 {
  1040. db = db.Where("x.org_id = ?", orgid)
  1041. }
  1042. offset := (page - 1) * limit
  1043. err = db.Count(&total).Offset(offset).Limit(limit).Order("x.ctime asc").Select("x.id,x.org_id,x.number,x.group_id,x.zone_id,x.status").Find(&number).Error
  1044. return number, total, err
  1045. }
  1046. func GetSchedu(bedid int64, thetime int64, orgid int64) (*models.XtSchedule, error) {
  1047. schedule := models.XtSchedule{}
  1048. err := XTReadDB().Model(&schedule).Where("bed_id = ? and schedule_date = ? and user_org_id = ? and status = 1", bedid, thetime, orgid).Find(&schedule).Error
  1049. if err == gorm.ErrRecordNotFound {
  1050. return nil, err
  1051. }
  1052. if err != nil {
  1053. return nil, err
  1054. }
  1055. return &schedule, nil
  1056. }
  1057. func DeleteBed(id int64) error {
  1058. err := XTWriteDB().Model(models.DeviceNumber{}).Where("id=?", id).Update(map[string]interface{}{"status": 0, "ctime": time.Now().Unix()}).Error
  1059. return err
  1060. }
  1061. func GetMemberPatient(orgid int64) (patients []*models.XtPatientsNew, err error) {
  1062. err = XTReadDB().Model(&patients).Where("user_org_id = ? AND member_patients = ? AND status = 1", orgid, 1).Find(&patients).Error
  1063. return patients, err
  1064. }
  1065. func GetSlowPatient(orgid int64) (patients []*models.XtPatientsNew, err error) {
  1066. err = XTReadDB().Model(&patients).Where("user_org_id = ? AND slow_patients = ? AND status = 1", orgid, 1).Find(&patients).Error
  1067. return patients, err
  1068. }
  1069. func GetBloodPatient(orgid int64) (patients []*models.XtPatientsNew, err error) {
  1070. err = XTReadDB().Model(&patients).Where("user_org_id = ? AND blood_patients = ? AND status = 1", orgid, 1).Find(&patients).Error
  1071. return patients, err
  1072. }
  1073. func SaveName(id int64, admin *models.SgjUserAdmin) error {
  1074. err = UserWriteDB().Model(models.SgjUserAdmin{}).Where("id=?", id).Update(map[string]interface{}{"name": admin.Name, "mtime": time.Now().Unix()}).Error
  1075. return err
  1076. }
  1077. func GetAdminUserId(id int64) (models.SgjUserAdminRole, error) {
  1078. role := models.SgjUserAdminRole{}
  1079. err := UserReadDB().Where("id=? and status =1", id).Find(&role).Error
  1080. return role, err
  1081. }
  1082. func GetMyOrganaziton(id int64) (org []*models.SgjUserOrg, err error) {
  1083. db := UserReadDB().Table("sgj_user_org as x").Where("x.status = 1")
  1084. table := UserReadDB().Table("sgj_user_admin as a")
  1085. fmt.Println("table", table)
  1086. err = db.Select("x.id,x.creator,x.org_name,x.org_short_name,x.org_logo,x.org_introduction,x.illness,x.province,x.city,x.district,x.address,x.longitude,x.latitude,x.org_type,x.comments,x.evaluate,x.gallery,x.business_week,x.business_time,x.contact_name,x.telephone,x.claim,x.operating_state,x.source,x.ttype,x.ttid,x.tuid,x.reason,x.level,x.website,x.import,x.sortno,a.is_super_admin").Joins("left join sgj_user_admin as a on a.id = x.creator").Where("x.creator = ?", id).Scan(&org).Error
  1087. return org, err
  1088. }
  1089. func GetOrgInformation(id int64) (models.SgjUserOrg, error) {
  1090. org := models.SgjUserOrg{}
  1091. err := UserReadDB().Where("id=? and status = 1", id).Find(&org).Error
  1092. return org, err
  1093. }
  1094. func GetShortName(orgtype int64) (models.SgjUserOrgType, error) {
  1095. orgType := models.SgjUserOrgType{}
  1096. err := UserReadDB().Model(&orgType).Where("id=? and status = 1", orgtype).Find(&orgType).Error
  1097. return orgType, err
  1098. }
  1099. func GetTypeName(id int64) (models.SgjUserOrgType, error) {
  1100. orgType := models.SgjUserOrgType{}
  1101. err := UserReadDB().Model(&orgType).Where("id=? and status = 1", id).Find(&orgType).Error
  1102. return orgType, err
  1103. }
  1104. func GetOrgProvince(id int64) (models.SgjUserDistrict, error) {
  1105. district := models.SgjUserDistrict{}
  1106. err := UserReadDB().Model(&district).Where("id=?", id).Find(&district).Error
  1107. return district, err
  1108. }
  1109. func GetAllOrgType() (orgType []*models.SgjUserOrgType, err error) {
  1110. err = UserReadDB().Model(&models.SgjUserOrgType{}).Where("status= ? AND id = ? OR id = ? OR id = ? OR id = ? OR id = ? OR id = ?", 1, 1, 7, 12, 16, 21, 26).Find(&orgType).Error
  1111. return
  1112. }
  1113. func UpdateOrg(id int64, org models.SgjUserOrg) error {
  1114. err := UserWriteDB().Model(&org).Where("id = ?", id).Update(map[string]interface{}{"org_name": org.OrgName, "org_short_name": org.OrgShortName, "province": org.Province, "city": org.City, "district": org.District, "address": org.Address, "org_type": org.OrgType, "telephone": org.Telephone, "contact_name": org.ContactName, "mtime": time.Now().Unix()}).Error
  1115. return err
  1116. }
  1117. func GetMyInfoName(id int64) (models.SgjUserAdminRole, error) {
  1118. role := models.SgjUserAdminRole{}
  1119. err := UserReadDB().Model(&role).Where("id=? and status = 1", id).Find(&role).Error
  1120. return role, err
  1121. }
  1122. func GetAdminName(id int64, orgid int64) (models.AdminUsers, error) {
  1123. user := models.AdminUsers{}
  1124. //err := UserReadDB().Model(&user).Where("id=? and status =1", id).Find(&user).Error
  1125. //return user, err
  1126. db := UserReadDB().Table("sgj_user_admin as x").Where("x.status = 1")
  1127. table := UserReadDB().Table("sgj_user_admin_role as r")
  1128. fmt.Println("table", table)
  1129. err := db.Group("x.id").Select("x.id,x.mobile,x.password,x.is_super_admin,x.source,x.name,r.admin_user_id,r.org_id,r.app_id,r.role_id,r.user_name,r.avatar,r.message,r.sex,r.birthday").Where("x.id = ?", id).Joins("left join sgj_user_admin_role as r on r.admin_user_id = x.id and r.org_id = ?", orgid).Scan(&user).Error
  1130. return user, err
  1131. }
  1132. func GetCreatByOrgId(orgid int64) (models.SgjUserOrg, error) {
  1133. org := models.SgjUserOrg{}
  1134. err := UserReadDB().Model(&org).Where("id=? and status = 1", orgid).Find(&org).Error
  1135. return org, err
  1136. }
  1137. func GetMyOrgInformationFour(creator int64, orgid int64) (models.SgjUserAdminRole, error) {
  1138. role := models.SgjUserAdminRole{}
  1139. err := UserReadDB().Model(&role).Where("admin_user_id = ? and org_id = ? and status = 1", creator, orgid).Find(&role).Error
  1140. return role, err
  1141. }
  1142. func GetPartionDetail(id int64) (models.DeviceZone, error) {
  1143. zone := models.DeviceZone{}
  1144. err := XTReadDB().Model(&zone).Where("id=? and status = 1", id).Find(&zone).Error
  1145. return zone, err
  1146. }
  1147. func UpdatePartition(id int64, zone *models.DeviceZone) error {
  1148. err := XTWriteDB().Model(&zone).Where("id=?", id).Update(map[string]interface{}{"name": zone.Name, "type": zone.Type, "mtime": time.Now().Unix()}).Error
  1149. return err
  1150. }
  1151. func GetGroupDetail(id int64) (models.DeviceGroup, error) {
  1152. group := models.DeviceGroup{}
  1153. err := XTReadDB().Model(&group).Where("id=? and status = 1", id).Find(&group).Error
  1154. return group, err
  1155. }
  1156. func UpdateGroup(id int64, group *models.DeviceGroup) error {
  1157. err := XTWriteDB().Model(&group).Where("id=?", id).Update(map[string]interface{}{"name": group.Name, "mtime": time.Now().Unix()}).Error
  1158. return err
  1159. }
  1160. func GetBedDetail(id int64) (models.DeviceNumber, error) {
  1161. number := models.DeviceNumber{}
  1162. err := XTReadDB().Model(&number).Where("id=? and status =1", id).Find(&number).Error
  1163. return number, err
  1164. }
  1165. func UpdatedBed(id int64, number *models.DeviceNumber) error {
  1166. err = XTWriteDB().Model(&number).Where("id=?", id).Update(map[string]interface{}{"number": number.Number, "zone_id": number.ZoneID, "group_id": number.GroupID, "mtime": time.Now().Unix()}).Error
  1167. return err
  1168. }
  1169. func CreateLoginLod(log *models.SgjUserAdminLoginLog) error {
  1170. err := UserWriteDB().Model(&log).Create(&log).Error
  1171. return err
  1172. }
  1173. func GetAppId(orgid int64) (models.OrgApp, error) {
  1174. app := models.OrgApp{}
  1175. err := UserReadDB().Model(&app).Where("org_id = ? and status = 1 and app_type = 3", orgid).Find(&app).Error
  1176. return app, err
  1177. }
  1178. func GetRoleName(adminid int64, orgid int64, appid int64) (models.Roles, error) {
  1179. role := models.Roles{}
  1180. err := UserReadDB().Model(&role).Where("creator = ? and org_id = ? and app_id = ? and status =1", adminid, orgid, appid).Find(&role).Error
  1181. return role, err
  1182. }
  1183. func GetRole(id int64) (models.Role, error) {
  1184. role := models.Role{}
  1185. err := UserReadDB().Model(&role).Where("id = ? and status =1", id).Find(&role).Error
  1186. return role, err
  1187. }
  1188. func GetPositionName(adminid int64, orgid int64, appid int64) (models.App_Role, error) {
  1189. role := models.App_Role{}
  1190. err := UserReadDB().Model(&role).Where("admin_user_id = ? and org_id = ? and app_id = ?", adminid, orgid, appid).Find(&role).Error
  1191. return role, err
  1192. }
  1193. func GetAdmin(id int64) (models.SgjUserAdmin, error) {
  1194. admin := models.SgjUserAdmin{}
  1195. err := UserReadDB().Model(&admin).Where("id=? and status =1", id).Find(&admin).Error
  1196. return admin, err
  1197. }
  1198. func GetPosition(id int64) (models.SgjUserAdminRole, error) {
  1199. roles := models.SgjUserAdminRole{}
  1200. err = UserReadDB().Model(&roles).Where("id=? and status = 1", id).Find(&roles).Error
  1201. return roles, err
  1202. }
  1203. func GetPositionOne(id int64) (models.SgjUserAdmin, error) {
  1204. admin := models.SgjUserAdmin{}
  1205. err = UserReadDB().Model(&admin).Where("id=? and status = 1", id).Find(&admin).Error
  1206. return admin, err
  1207. }
  1208. func GetMyOrgInformation(id int64, appid int64) (models.SgjUserAdminRole, error) {
  1209. admin := models.SgjUserAdminRole{}
  1210. err := UserReadDB().Model(&admin).Where("admin_user_id=? and app_id = ? and status = 1", id, appid).First(&admin).Error
  1211. return admin, err
  1212. }
  1213. func SaveNameTwo(id int64, orgid int64, role *models.SgjUserAdminRole) error {
  1214. err := UserWriteDB().Model(models.SgjUserAdminRole{}).Where("admin_user_id =? and org_id = ?", id, orgid).Update(map[string]interface{}{"user_name": role.UserName, "mtime": time.Now().Unix()}).Error
  1215. return err
  1216. }
  1217. func AddPatientLapseto(lapseto *models.PatientLapseto) error {
  1218. err := XTWriteDB().Create(&lapseto).Error
  1219. return err
  1220. }