搜索

controllers/new_mobile_api_controllers/new_dialysis_api_controller.go

@@ -1042,3 +1042,64 @@ func (this *NewDialysisApiController) GetMemberSearchPatent() {
 		"memberPatient": memberPatient,
 	})
 }
+
+func (this *NewDialysisApiController) GetLongDialysisDetail() {
+	id, err := this.GetInt64("id")
+	longDialysisDetail, err := service.GetLongDialysisDetail(id)
+	patient, err := service.GetPatientName(longDialysisDetail.PatientId)
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"longDialysisDetail": longDialysisDetail,
+		"patient":            patient,
+	})
+}
+
+func (this *NewDialysisApiController) DeleteLongDialysis() {
+	id, _ := this.GetInt64("id")
+	fmt.Print("id", id)
+	err := service.DeleteLongDialysis(id)
+	fmt.Println("错误是什么", err)
+	returnData := make(map[string]interface{}, 0)
+	returnData["msg"] = "ok"
+	this.ServeSuccessJSON(returnData)
+	return
+}
+
+func (this *NewDialysisApiController) GetDialysisrecord() {
+	timeLayout := "2006-01-02"
+	loc, _ := time.LoadLocation("Local")
+	id, _ := this.GetInt64("id")
+	fmt.Print("id", id)
+	patient, _ := service.GetPatientDetailTwo(id)
+	start := this.GetString("startime")
+	startTimes, _ := time.ParseInLocation(timeLayout+" 15:04:05", start+" 00:00:00", loc)
+	startime := startTimes.Unix()
+	fmt.Print("startime", startime)
+	end := this.GetString("endtime")
+	endTimes, _ := time.ParseInLocation(timeLayout+" 15:04:05", end+" 00:00:00", loc)
+	endtime := endTimes.Unix()
+	fmt.Print("endtime", endtime)
+	limit, _ := this.GetInt64("limit")
+	fmt.Print("limit", limit)
+	page, _ := this.GetInt64("page")
+	fmt.Print("page", page)
+	adminInfo := this.GetMobileAdminUserInfo()
+	orgid := adminInfo.Org.Id
+	appid := adminInfo.App.Id
+	dislystype, _ := this.GetInt64("dislysType")
+	fmt.Print("透析模式", dislystype)
+	dialysisrecord, total, err := service.GetDialysisrecord(patient.BloodId, startime, endtime, limit, page, orgid, dislystype)
+	doctor, err := service.GetAllDoctorTwo(orgid, appid)
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"dialysisrecord": dialysisrecord,
+		"total":          total,
+		"doctor":         doctor,
+	})
+}

controllers/new_mobile_api_controllers/new_mobile_api_router_register.go

@@ -61,4 +61,7 @@ func NewMobileAPIControllersRegisterRouters() {
 	beego.Router("/m/api/patient/searchallblood", &NewDialysisApiController{}, "Get:GetSearchallBlood")
 	beego.Router("/m/api/patient/getslowsearchepatient", &NewDialysisApiController{}, "Get:GetSlowSearchePatient")
 	beego.Router("/m/api/patient/getmembersearchpatient", &NewDialysisApiController{}, "Get:GetMemberSearchPatent")
+	beego.Router("/m/api/patient/getlongdialysisdetail", &NewDialysisApiController{}, "Get:GetLongDialysisDetail")
+	beego.Router("/m/api/patient/deletelongdialysis", &NewDialysisApiController{}, "Delete:DeleteLongDialysis")
+	beego.Router("/m/api/patient/getdialysisrecord", &NewDialysisApiController{}, "Get:GetDialysisrecord")
 }

models/user_models.go

@@ -335,7 +335,7 @@ type XtDialysisSolution struct {
 
 func (XtDialysisSolution) TableName() string {
 
-	return "xt_dialysis_prescription"
+	return "xt_dialysis_solution"
 }
 
 type XtPatientRescueRecords struct {

service/patientmanage_service.go

@@ -707,3 +707,91 @@ func GetMemberSearchPatient(keyword string, orgid int64) (patients []*models.XtP
 	err = XTReadDB().Where("name like ? or dialysis_no = ? and user_org_id = ? and member_patients = 1", likeKey, keyword, orgid).Find(&patients).Error
 	return patients, err
 }
+
+func GetLongDialysisDetail(id int64) (models.XtDialysisSolution, error) {
+	solution := models.XtDialysisSolution{}
+	err := XTReadDB().Model(&solution).Where("id=? and status =1", id).Find(&solution).Error
+	return solution, err
+}
+
+func GetPatientName(id int64) (models.Patients, error) {
+	patientsNew := models.Patients{}
+	err := XTReadDB().Model(&patientsNew).Where("id=? and status = 1", id).Find(&patientsNew).Error
+	return patientsNew, err
+}
+
+func DeleteLongDialysis(id int64) error {
+	err := XTWriteDB().Model(models.XtDialysisSolution{}).Where("id=?", id).Update(map[string]interface{}{"status": 0, "mtime": time.Now().Unix()}).Error
+	return err
+}
+
+func GetDialysisrecord(patientID int64, start int64, end int64, limit int64, page int64, orgID int64, mode_id int64) ([]*models.PatientDialysisRecord, int64, error) {
+	offset := (page - 1) * limit
+	var total int64
+	var err error
+	var orders []*models.PatientDialysisRecord
+
+	db := readDb.Table("xt_dialysis_order as do").
+		Preload("DialysisPrescription", "patient_id=? and user_org_id=? and status=1", patientID, orgID).
+		Preload("PredialysisEvaluation", "patient_id=? and user_org_id=? and status=1", patientID, orgID).
+		Preload("DialysisPrescription", func(db *gorm.DB) *gorm.DB {
+			return readDb.Where("patient_id=? and user_org_id=? and status=1", patientID, orgID).Preload("UserAdminRole", func(db *gorm.DB) *gorm.DB {
+				return readUserDb.Where("status = 1")
+			})
+		}).
+		Preload("AssessmentAfterDislysis", "patient_id=? and user_org_id=? and status=1", patientID, orgID).
+		Preload("TreatmentSummary", "patient_id=? and user_org_id=? and status=1", patientID, orgID).
+		Preload("Device", "org_id=? and status=1", orgID).
+		Preload("UserAdminRole", func(db *gorm.DB) *gorm.DB {
+			return readUserDb.Where("org_id=? and status = 1", orgID)
+		}).
+		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).
+		Joins("JOIN xt_device_zone as dz ON dz.org_id = ? and dz.id=s.partition_id", orgID).
+		Where("do.patient_id=? and do.user_org_id=? and do.stage = 2 and do.status=1", patientID, orgID).Group("s.schedule_date")
+
+	if start != 0 {
+		db = db.Where("do.dialysis_date>=?", start)
+	}
+	if end != 0 {
+		db = db.Where("do.dialysis_date<=?", end)
+	}
+	if mode_id > 0 {
+		db = db.Joins("JOIN xt_dialysis_prescription as dp ON dp.record_id=do.id")
+		db = db.Where("dp.mode_id=?", mode_id)
+	}
+
+	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
+
+	if len(orders) > 0 {
+		ids := make([]int64, 0)
+		for _, order := range orders {
+			dialyzer := order.DialysisPrescription.Dialyzer
+			ids = append(ids, dialyzer)
+		}
+		if len(ids) > 0 {
+			var dialyzers []*models.DeviceNumber
+			err = readDb.Model(&models.DeviceNumber{}).Where("id IN (?) and org_id=? and status=1", ids, orgID).Find(&dialyzers).Error
+			if err != nil {
+				return nil, 0, err
+			}
+
+			dialyzerMap := make(map[int64]models.DeviceNumber, 0)
+			for _, item := range dialyzers {
+				dialyzerMap[item.ID] = *item
+			}
+			for orderIndex, order := range orders {
+				if _, exist := dialyzerMap[order.DialysisPrescription.Dialyzer]; exist {
+					orders[orderIndex].DeviceNumber = dialyzerMap[order.DialysisPrescription.Dialyzer].Number
+				}
+			}
+		}
+	}
+
+	return orders, total, err
+}
+
+func GetAllDoctorTwo(orgid int64, appid int64) (appRole []*models.App_Role, err error) {
+
+	err = UserReadDB().Where("org_id = ? AND app_id = ? AND status = ? ", orgid, appid, 1).Find(&appRole).Error
+	return appRole, err
+}

service/user_service.go

@@ -93,7 +93,6 @@ func GetDryWeightByPatientId(patientid int64, orgid int64) (pre []*models.SgjPat
 func GetAllDoctor(orgid int64, appid int64) (appRole []*models.App_Role, err error) {
 
 	err = UserReadDB().Where("org_id = ? AND app_id = ? AND status = ? AND  (user_type = ? OR user_type = ?) ", orgid, appid, 1, 2, 1).Find(&appRole).Error
-	fmt.Println("errrrrrrrrrrerrrrrrrrrrrrrrrrrrr", err)
 	return appRole, err
 }