11月8日库存管理

conf/app.conf

 
 #redishost = 120.77.235.13
 #redishost = 112.74.16.180
-redishost = localhost
+redishost = kuyi6666.redis.rds.aliyuncs.com
 redisport = 6379
-redispasswrod = syh@#$%123456!
-redisdb = 0
+redispasswrod = TZtBW098WId3i27clkpj3q8dnUaVFP
+redisdb = 7
 
 niprocart =  83
 jms = 80

controllers/dialysis_api_controller.go

 		MaxUltrafiltrationRate:     max_ultrafiltration_rate,
 	}
 
-	//查询最近透析准备表里是否存在 透析器 灌流器
-
-	//splitStr := strings.Split(dialysis_dialyszers, ",")
-	//
-	//splitIrrigation := strings.Split(dialysis_irrigation, ",")
-	//
-	//mation, _ := service.GetGoodInfoMation(adminUserInfo.CurrentOrgId)
-	//if len(mation)>0{
-	//  for _, item := range splitStr {
-	//    for _,it := range mation{
-	//      if(item == it.SpecificationName){
-	//
-	//        //查询最近一次的透析器
-	//        _, errcode := service.GetDialysisBeforePrepare(it.GoodTypeId, it.ID, adminUserInfo.CurrentOrgId,patient)
-	//
-	//        if errcode == gorm.ErrRecordNotFound{
-	//          //插入数据
-	//          prepare := models.DialysisBeforePrepare{
-	//            UserOrgId:  adminUserInfo.CurrentOrgId,
-	//            PatientId:  patient,
-	//            RecordDate: recordDate.Unix(),
-	//            GoodTypeId: it.GoodTypeId,
-	//            GoodId:     it.ID,
-	//            Count:      1,
-	//            Ctime:      time.Now().Unix(),
-	//            Creater:    adminUserInfo.AdminUser.Id,
-	//            Status:1,
-	//
-	//          }
-	//          errcode := service.CreateDialysisBeforePrepareOne(&prepare)
-	//          fmt.Println("",errcode)
-	//        }
-	//      }
-	//    }
-	//
-	//  }
-	//
-	//  for _, item := range splitIrrigation {
-	//    for _,it := range mation{
-	//      if(item == it.SpecificationName){
-	//        //查询最近一次的透析器
-	//        _, errcode := service.GetDialysisBeforePrepare(it.GoodTypeId, it.ID, adminUserInfo.CurrentOrgId,patient)
-	//        if errcode == gorm.ErrRecordNotFound{
-	//          //插入数据
-	//          prepare := models.DialysisBeforePrepare{
-	//            UserOrgId:  adminUserInfo.CurrentOrgId,
-	//            PatientId:  patient,
-	//            RecordDate: recordDate.Unix(),
-	//            GoodTypeId: it.GoodTypeId,
-	//            GoodId:     it.ID,
-	//            Count:      1,
-	//            Ctime:      time.Now().Unix(),
-	//            Creater:    adminUserInfo.AdminUser.Id,
-	//            Status:1,
-	//
-	//          }
-	//          errcode := service.CreateDialysisBeforePrepareOne(&prepare)
-	//          fmt.Println(errcode)
-	//      }
-	//      }
-	//    }
-	//  }
-	//
-	//}
-
 	if appRole.UserType == 2 || appRole.UserType == 1 {
 		prescription.PrescriptionDoctor = appRole.AdminUserId
 	}
 
 		prescription.Creater = adminUserInfo.AdminUser.Id
 		err := service.AddSigleRecord(&prescription)
+		key := strconv.FormatInt(adminUserInfo.CurrentOrgId, 10) + ":" + strconv.FormatInt(patient, 10) + ":" + strconv.FormatInt(recordDate.Unix(), 10) + ":" + strconv.FormatInt(mode_id, 10) + ":dialysis_prescribe"
+		redis := service.RedisClient()
+		defer redis.Close()
+		//清空key 值
+		redis.Set(key, "", time.Second)
+
 		if err == nil {
 			updateErr := service.UpdateScheduleModeId(patient, adminUserInfo.CurrentOrgId, recordDate.Unix(), mode_id)
 			if updateErr != nil {
 		prescription.ID = dialysisPrescription.ID
 
 		updateErr := service.UpDateDialysisPrescription(&prescription)
+		key := strconv.FormatInt(adminUserInfo.CurrentOrgId, 10) + ":" + strconv.FormatInt(patient, 10) + ":" + strconv.FormatInt(recordDate.Unix(), 10) + ":" + strconv.FormatInt(mode_id, 10) + ":dialysis_prescribe"
+		redis := service.RedisClient()
+		defer redis.Close()
+		//清空key 值
+		redis.Set(key, "", time.Second)
 		if updateErr == nil {
 			updateErr := service.UpdateScheduleModeId(patient, adminUserInfo.CurrentOrgId, recordDate.Unix(), mode_id)
 			if updateErr != nil {
 		MaxUltrafiltrationRate:     max_ultrafiltration_rate,
 	}
 	err := service.SavePrescriptionAndCreateSolution(&solution, &prescription)
+	key := strconv.FormatInt(adminUserInfo.CurrentOrgId, 10) + ":" + strconv.FormatInt(patient, 10) + ":" + strconv.FormatInt(mode_id, 10) + ":dialysis_solution"
+	redis := service.RedisClient()
+
+	//清空key 值
+	redis.Set(key, "", time.Second)
+
+	keyOne := strconv.FormatInt(adminUserInfo.CurrentOrgId, 10) + ":" + strconv.FormatInt(patient, 10) + ":" + strconv.FormatInt(recordDate.Unix(), 10) + ":" + strconv.FormatInt(mode_id, 10) + ":dialysis_prescribe"
+	//清空key 值
+	redis.Set(keyOne, "", time.Second)
+	defer redis.Close()
 	if err == nil {
 		c.ServeSuccessJSON(map[string]interface{}{
 			"solution":     &solution,
 		doubleCheck.Modifier = modifier
 
 		err := service.AddSigleDoubleCheck(&doubleCheck)
+		key := strconv.FormatInt(adminUserInfo.CurrentOrgId, 10) + ":" + strconv.FormatInt(id, 10) + ":" + strconv.FormatInt(recordDate.Unix(), 10) + ":double_check"
+		redis := service.RedisClient()
+		defer redis.Close()
+		//清空key 值
+		redis.Set(key, "", time.Second)
 		if err == nil {
 			c.ServeSuccessJSON(map[string]interface{}{
 				"doubleCheck": doubleCheck,
 		assessment.AssessmentDate = recordDate.Unix()
 
 		err = service.AddSigleAssessmentAfterDislysisRecord(&assessment)
+		key := strconv.FormatInt(adminUserInfo.CurrentOrgId, 10) + ":" + strconv.FormatInt(patient, 10) + ":" + strconv.FormatInt(recordDate.Unix(), 10) + ":assessment_after_dislysis"
+		redis := service.RedisClient()
+		defer redis.Close()
+		//清空key 值
+		redis.Set(key, "", time.Second)
 	}
 
 	if err != nil {
 		}
 
 		err := service.AddSigleAssessmentBeforeDislysisRecord(&assessmentBeforeDislysis)
+		key := strconv.FormatInt(adminUserInfo.CurrentOrgId, 10) + ":" + strconv.FormatInt(patient, 10) + ":" + strconv.FormatInt(recordDate.Unix(), 10) + ":assessment_before_dislysis"
+		redis := service.RedisClient()
+		defer redis.Close()
+		//清空key 值
+		redis.Set(key, "", time.Second)
 		if err == nil {
 			c.ServeSuccessJSON(map[string]interface{}{
 				"assessmentBeforeDislysis": &assessmentBeforeDislysis,
 	if tempTreatmentSummary.ID == 0 { //新增
 		treatmentSummary.Creater = adminUserInfo.AdminUser.Id
 		err := service.AddSigleSummaryRecord(&treatmentSummary)
+		key := strconv.FormatInt(adminUserInfo.CurrentOrgId, 10) + ":" + strconv.FormatInt(patient, 10) + ":" + strconv.FormatInt(recordDate.Unix(), 10) + ":treatment_summary"
+		redis := service.RedisClient()
+		defer redis.Close()
+		//清空key 值
+		redis.Set(key, "", time.Second)
 		if err == nil {
 			c.ServeSuccessJSON(map[string]interface{}{
 				"summary": treatmentSummary,
 		treatmentSummary.Modifier = adminUserInfo.AdminUser.Id
 		treatmentSummary.ID = tempTreatmentSummary.ID
 		err := service.UpdateSummeRecord(&treatmentSummary)
+		key := strconv.FormatInt(adminUserInfo.CurrentOrgId, 10) + ":" + strconv.FormatInt(patient, 10) + ":" + strconv.FormatInt(recordDate.Unix(), 10) + ":treatment_summary"
+		//清空key 值
+		redis := service.RedisClient()
+		redis.Set(key, "", time.Second)
+		defer redis.Close()
 		if err == nil {
 			c.ServeSuccessJSON(map[string]interface{}{
 				"summary": treatmentSummary,
 	adminUserInfo := c.GetAdminUserInfo()
 	if len(keywords) > 0 {
 		dialysisSchedule, err, total := service.GetDialysisWatchByKeyword(adminUserInfo.CurrentOrgId, keywords, schedulType, partitionType, page, limit)
+
+		//获取所有床位号
+		numberList, _ := service.GetAllDeviceNumberByList(adminUserInfo.CurrentOrgId)
+
+		//获取所有分区
+		//zoneList, _ := service.GetAllZoneByList(adminUserInfo.CurrentOrgId)
+		//获取透析处方
+		prescriptions, _ := service.GetAllPrescriptionByListTwo(adminUserInfo.CurrentOrgId, startTime)
+		//获取透前评估
+		assessmentBefores, _ := service.GetAllAssessmentBeforesByListThree(adminUserInfo.CurrentOrgId, startTime)
+		//获取上机
+		dialysisOrders, _ := service.GetAllDialysisOrdersByListThree(adminUserInfo.CurrentOrgId, startTime)
+		//获取透后
+		AssessmentAfterDislysis, _ := service.GetAllAssessmentAfterDislysisByListThree(adminUserInfo.CurrentOrgId, startTime)
+
+		//获取透后监测
+		monitorlist, _ := service.GetAllMonitorListThree(adminUserInfo.CurrentOrgId, startTime)
+
+		//获取所有的患者
+		patients, _ := service.GetAllPatientListByListThree(adminUserInfo.CurrentOrgId)
+
+		//获取所有透析模式
+		treatments, _ := service.GetAllTreatModeByList(adminUserInfo.CurrentOrgId)
+
+		for key, scheduals := range dialysisSchedule {
+			// 获取患者信息
+			for _, patient := range patients {
+				if scheduals.PatientId == patient.ID {
+					dialysisSchedule[key].MonitorPatients = patient
+					break
+				}
+			}
+			// 床位信息
+			for _, device := range numberList {
+				if scheduals.BedId == device.ID {
+					dialysisSchedule[key].DeviceNumber = device
+					break
+				}
+			}
+
+			// 医嘱信息
+			for _, prescription := range prescriptions {
+				if scheduals.PatientId == prescription.PatientId {
+					dialysisSchedule[key].Prescription = prescription
+					break
+				}
+			}
+
+			// 透前评估
+			for _, assessmentBefore := range assessmentBefores {
+				if scheduals.PatientId == assessmentBefore.PatientId {
+					dialysisSchedule[key].AssessmentBeforeDislysis = assessmentBefore
+					break
+				}
+			}
+
+			// 透析上下机
+			for _, dialysisOrder := range dialysisOrders {
+				if scheduals.PatientId == dialysisOrder.PatientId {
+					dialysisSchedule[key].DialysisOrder = dialysisOrder
+					break
+				}
+			}
+
+			records := make([]*models.MonitoringRecord, 0)
+			// 透析监测
+			for _, it := range monitorlist {
+				records := append(records, it)
+				if scheduals.PatientId == it.PatientId {
+					dialysisSchedule[key].MonitoringRecord = records
+				}
+			}
+
+			// 透后评估
+			for _, afterDislysis := range AssessmentAfterDislysis {
+				if scheduals.PatientId == afterDislysis.PatientId {
+					dialysisSchedule[key].AssessmentAfterDislysis = afterDislysis
+					break
+				}
+			}
+
+			//透析模式
+			for _, treatment := range treatments {
+				if scheduals.ModeId == treatment.ID {
+					dialysisSchedule[key].TreatmentMode = treatment
+					break
+				}
+			}
+		}
+		//获取所有床位号
 		if err == nil {
 			c.ServeSuccessJSON(map[string]interface{}{
 				"schedule": dialysisSchedule,

controllers/dialysis_record_api_controller.go

 		return
 	}
 
-	dialysisPrescribe, getDialysisPrescribeErr := service.GetDialysisPrescribe(adminInfo.CurrentOrgId, patientID, date.Unix())
-	if getDialysisPrescribeErr != nil {
-		this.ErrorLog("获取透析处方失败:%v", getDialysisPrescribeErr)
-		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
-		return
-	}
+	dialysisPrescribe, _ := service.GetDialysisPrescribe(adminInfo.CurrentOrgId, patientID, date.Unix())
+	//if getDialysisPrescribeErr != nil {
+	//	this.ErrorLog("获取透析处方失败:%v", getDialysisPrescribeErr)
+	//	this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+	//	return
+	//}
 	dialysisSolution, getDialysisSolutionErr := service.GetDialysisSolution(adminInfo.CurrentOrgId, patientID, schedual.ModeId)
 	//dialysisSolution, getDialysisSolutionErr := service.GetDialysisSolutionOne(adminInfo.CurrentOrgId, schedual.ModeId)
 
 		return
 	}
 
-	lastDialysisPrescribe, getDialysisPrescribeErr := service.GetLastDialysisPrescribeByModeId(adminInfo.CurrentOrgId, patientID, schedual.ModeId)
-	if getDialysisPrescribeErr != nil {
-		this.ErrorLog("获取透析处方失败:%v", getDialysisPrescribeErr)
-		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
-		return
-	}
+	lastDialysisPrescribe, _ := service.GetLastDialysisPrescribeByModeId(adminInfo.CurrentOrgId, patientID, schedual.ModeId)
+	//if getDialysisPrescribeErr != nil {
+	//	this.ErrorLog("获取透析处方失败:%v", getDialysisPrescribeErr)
+	//	this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+	//	return
+	//}
 
-	systemDialysisPrescribe, getSystemDialysisPrescribeErr := service.GetSystemDialysisPrescribeByModeId(adminInfo.CurrentOrgId, schedual.ModeId)
-	if getSystemDialysisPrescribeErr != nil {
-		this.ErrorLog("获取系统透析处方失败:%v", getSystemDialysisPrescribeErr)
-		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
-		return
-	}
+	systemDialysisPrescribe, _ := service.GetSystemDialysisPrescribeByModeId(adminInfo.CurrentOrgId, schedual.ModeId)
+	//if getSystemDialysisPrescribeErr != nil {
+	//	this.ErrorLog("获取系统透析处方失败:%v", getSystemDialysisPrescribeErr)
+	//	this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+	//	return
+	//}
 
 	if getLPEErr != nil {
 		this.ErrorLog("获取上一次透前评估失败:%v", getLPEErr)
 			BloodMonitor:                monitorParam.BloodMonitor,
 		}
 		createErr := service.CreateMonitor(&monitor)
+		key := strconv.FormatInt(adminUserInfo.CurrentOrgId, 10) + ":" + strconv.FormatInt(patientID, 10) + ":" + strconv.FormatInt(scheduleDate, 10) + ":monitor_records"
+		redis := service.RedisClient()
+		defer redis.Close()
+		//清空key 值
+		redis.Set(key, "", time.Second)
 		if createErr != nil {
 			this.ErrorLog("创建监测记录失败：%v", createErr)
 			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
 	}
 
 	createErr := service.MobileCreateDialysisOrder(adminUserInfo.CurrentOrgId, patientID, dialysisRecord)
+	key := strconv.FormatInt(adminUserInfo.CurrentOrgId, 10) + ":" + strconv.FormatInt(patientID, 10) + ":" + strconv.FormatInt(recordDate.Unix(), 10) + ":dialysis_order"
+	redis := service.RedisClient()
+	defer redis.Close()
+	//清空key 值
+	redis.Set(key, "", time.Second)
 	newdialysisRecord, getRecordErr := service.MobileGetDialysisRecord(adminUserInfo.CurrentOrgId, patientID, recordDate.Unix())
 
 	if createErr != nil {

controllers/doctors_api_controller.go

 	orgID := adminUserInfo.CurrentOrgId
 
 	scheduals, err := service.MobileGetScheduleDoctorAdvicesOne(orgID, date.Unix(), adviceType, patientType, adminUserInfo.AdminUser.Id, delivery_way, schedule_type, partition_type)
+
 	hisAdvices, _ := service.GetHisDoctorAdvicesOne(orgID, date.Unix(), delivery_way, schedule_type, partition_type)
 
 	project, _ := service.GetPCHisPrescriptionProject(orgID, date.Unix(), delivery_way, patientType, partition_type)
 
+	//获取所有的患者
+	patients, _ := service.GetAllPatientListByListTwo(orgID)
+
+	//获取所有床位
+	numberList, _ := service.GetAllDeviceNumberByListOne(orgID)
+
+	//获取透析处方
+	prescriptions, _ := service.GetAllPrescriptionByListOne(orgID, date.Unix())
+
+	//获取上机
+	dialysisOrders, _ := service.GetAllDialysisOrdersByListTwo(orgID, date.Unix())
+	for key, item := range project {
+		for _, patient := range patients {
+			if item.PatientId == patient.ID {
+				project[key].SchedualPatient = patient
+				break
+			}
+		}
+		// 获取床位信息
+		for _, it := range numberList {
+			if item.BedId == it.ID {
+				project[key].DeviceNumber = it
+				break
+			}
+		}
+
+		// 获取处方
+		for _, it := range prescriptions {
+			if item.PatientId == it.PatientId {
+				project[key].Prescription = it
+				break
+			}
+		}
+
+		//获取上机
+		for _, it := range dialysisOrders {
+			if item.PatientId == it.PatientId {
+				project[key].DialysisOrder = it
+				break
+			}
+		}
+	}
 	config, _ := service.GetHisDoctorConfig(orgID)
 	project_config, _ := service.GetHisProjectConfig(orgID)
 

controllers/mobile_api_controllers/dialysis_api_controller.go

 
 	// cur_date := time.Now().Format("2006-01-02")
 	key := "scheduals_" + schedualDate + "_" + strconv.FormatInt(orgID, 10)
-	fmt.Println("keyhhhhhhhhhhhhhhhhhhhhhhhhhhhhhhh", key)
+
 	scheduals_json_str, _ := redis.Get(key).Result()
 
 	if len(scheduals_json_str) == 0 { //没有到缓存数据，从数据库中获取数据，进行缓存到redis
 		scheduals, err := service.MobileGetDialysisScheduals(orgID, date.Unix(), schedualType)
+		fmt.Println("hhhhhh2323232323223222我的", scheduals)
 		if err != nil {
 			this.ErrorLog("获取排班信息失败:%v", err)
 			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
 				prescriptions, _ := service.GetAllPrescriptionsByList(orgID, date.Unix())
 				assessmentBefores, _ := service.GetAllAssessmentBeforesByList(orgID, date.Unix())
 				dialysisOrders, _ := service.GetAllDialysisOrdersByList(orgID, date.Unix())
+				fmt.Println("hh23322332323232323233223", dialysisOrders)
 				treatmentSummarys, _ := service.GetAllTreatmentSummarysByList(orgID, date.Unix())
 				AssessmentAfterDislysis, _ := service.GetAllAssessmentAfterDislysisByList(orgID, date.Unix())
 				hisAdvices, _ := service.GetAllHisAdvicesByList(orgID, date.Unix())
 	adminInfo := this.GetMobileAdminUserInfo()
 
 	// 先走redis，没有走数据库
-	patient, getPatientErr := service.FindPatientByIdWithDiseases(adminInfo.Org.Id, patientID)
-	if getPatientErr != nil {
-		this.ErrorLog("获取患者信息失败：%v", getPatientErr)
-		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
-		return
-	} else if patient.ID == 0 {
-		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodePatientNoExist)
-		return
-	}
+	patient, _ := service.FindPatientByIdWithDiseases(adminInfo.Org.Id, patientID)
+
+	//if getPatientErr != nil {
+	//	this.ErrorLog("获取患者信息失败：%v", getPatientErr)
+	//	this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+	//	return
+	//} else if patient.ID == 0 {
+	//	this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodePatientNoExist)
+	//	return
+	//}
 
 	// 先走redis，没有走数据库
-	schedual, getSchedualErr := service.MobileGetSchedualDetail(adminInfo.Org.Id, patientID, date.Unix())
+	schedual, _ := service.MobileGetSchedualDetail(adminInfo.Org.Id, patientID, date.Unix())
 
-	if getSchedualErr != nil {
-		this.ErrorLog("获取患者排班信息失败:%v", getSchedualErr)
-		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
-		return
-	}
+	//if getSchedualErr != nil {
+	//	this.ErrorLog("获取患者排班信息失败:%v", getSchedualErr)
+	//	this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+	//	return
+	//}
 
 	// 先走redis，没有走数据库
-	receiverTreatmentAccess, getRTARErr := service.MobileGetReceiverTreatmentAccessRecord(adminInfo.Org.Id, patientID, date.Unix())
-	if getRTARErr != nil {
-		this.ErrorLog("获取接诊评估失败:%v", getRTARErr)
-		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
-		return
-	}
+	receiverTreatmentAccess, _ := service.MobileGetReceiverTreatmentAccessRecord(adminInfo.Org.Id, patientID, date.Unix())
+	//if getRTARErr != nil {
+	//	this.ErrorLog("获取接诊评估失败:%v", getRTARErr)
+	//	this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+	//	return
+	//}
 
 	// // 先走redis，没有走数据库
-	predialysisEvaluation, getPEErr := service.MobileGetPredialysisEvaluation(adminInfo.Org.Id, patientID, date.Unix())
-	if getPEErr != nil {
-		this.ErrorLog("获取透前评估失败:%v", getPEErr)
-		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
-		return
-	}
+	predialysisEvaluation, _ := service.MobileGetPredialysisEvaluation(adminInfo.Org.Id, patientID, date.Unix())
+	//if getPEErr != nil {
+	//	this.ErrorLog("获取透前评估失败:%v", getPEErr)
+	//	this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+	//	return
+	//}
 
 	// // 先走redis，没有走数据库
-	lastPredialysisEvaluation, getLPEErr := service.MobileGetLastTimePredialysisEvaluation(adminInfo.Org.Id, patientID, date.Unix())
-	if getLPEErr != nil {
-		this.ErrorLog("获取上一次透前评估失败:%v", getLPEErr)
-		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
-		return
-	}
+	lastPredialysisEvaluation, _ := service.MobileGetLastTimePredialysisEvaluation(adminInfo.Org.Id, patientID, date.Unix())
+	//if getLPEErr != nil {
+	//	this.ErrorLog("获取上一次透前评估失败:%v", getLPEErr)
+	//	this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+	//	return
+	//}
 
 	// // 先走redis，没有走数据库
-	doctorAdvices, getDoctorAdvicesErr := service.MobileGetDoctorAdvicesByGroups(adminInfo.Org.Id, patientID, date.Unix())
-	if getDoctorAdvicesErr != nil {
-		this.ErrorLog("获取临时医嘱失败:%v", getDoctorAdvicesErr)
-		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
-		return
-	}
+	doctorAdvices, _ := service.MobileGetDoctorAdvicesByGroups(adminInfo.Org.Id, patientID, date.Unix())
+
+	//if getDoctorAdvicesErr != nil {
+	//	this.ErrorLog("获取临时医嘱失败:%v", getDoctorAdvicesErr)
+	//	this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+	//	return
+	//}
 
 	// // 先走redis，没有走数据库
-	dialysisOrder, getDialysisOrderErr := service.MobileGetSchedualDialysisRecord(adminInfo.Org.Id, patientID, date.Unix())
-	if getDialysisOrderErr != nil {
-		this.ErrorLog("获取透析记录失败:%v", getDialysisOrderErr)
-		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
-		return
-	}
+	dialysisOrder, _ := service.MobileGetSchedualDialysisRecord(adminInfo.Org.Id, patientID, date.Unix())
+	//if getDialysisOrderErr != nil {
+	//	this.ErrorLog("获取透析记录失败:%v", getDialysisOrderErr)
+	//	this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+	//	return
+	//}
 
 	// // 先走redis，没有走数据库
-	doubleCheck, getDoubleCheckErr := service.MobileGetDoubleCheck(adminInfo.Org.Id, patientID, date.Unix())
-	if getDoubleCheckErr != nil {
-		this.ErrorLog("获取双人核对记录失败:%v", getDoubleCheckErr)
-		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
-		return
-	}
+	doubleCheck, _ := service.MobileGetDoubleCheck(adminInfo.Org.Id, patientID, date.Unix())
+	//if getDoubleCheckErr != nil {
+	//	this.ErrorLog("获取双人核对记录失败:%v", getDoubleCheckErr)
+	//	this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+	//	return
+	//}
 
 	// // 先走redis，没有走数据库
-	monitorRecords, getMonitorRecordsErr := service.MobileGetMonitorRecords(adminInfo.Org.Id, patientID, date.Unix())
-	if getMonitorRecordsErr != nil {
-		this.ErrorLog("获取透析监测记录失败:%v", getMonitorRecordsErr)
-		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
-		return
-	}
+	monitorRecords, _ := service.MobileGetMonitorRecords(adminInfo.Org.Id, patientID, date.Unix())
+	//if getMonitorRecordsErr != nil {
+	//	this.ErrorLog("获取透析监测记录失败:%v", getMonitorRecordsErr)
+	//	this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+	//	return
+	//}
 	var lastMonitorRecord *models.MonitoringRecord
 
 	// // 先走redis，没有走数据库
 	}
 
 	// // 先走redis，没有走数据库
-	assessmentAfterDislysis, getAADErr := service.MobileGetAssessmentAfterDislysis(adminInfo.Org.Id, patientID, date.Unix())
-	if getAADErr != nil {
-		this.ErrorLog("获取透后评估失败:%v", getAADErr)
-		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
-		return
-	}
+	assessmentAfterDislysis, _ := service.MobileGetAssessmentAfterDislysis(adminInfo.Org.Id, patientID, date.Unix())
+	//if getAADErr != nil {
+	//	this.ErrorLog("获取透后评估失败:%v", getAADErr)
+	//	this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+	//	return
+	//}
 
 	// // 先走redis，没有走数据库
-	lastAssessmentAfterDislysis, getLAADErr := service.MobileGetLastTimeAssessmentAfterDislysis(adminInfo.Org.Id, patientID, date.Unix())
-	if getLAADErr != nil {
-		this.ErrorLog("获取上一次透后评估失败:%v", getLAADErr)
-		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
-		return
-	}
+	lastAssessmentAfterDislysis, _ := service.MobileGetLastTimeAssessmentAfterDislysis(adminInfo.Org.Id, patientID, date.Unix())
+	//if getLAADErr != nil {
+	//	this.ErrorLog("获取上一次透后评估失败:%v", getLAADErr)
+	//	this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+	//	return
+	//}
 
 	// // 先走redis，没有走数据库
-	treatmentSummary, getTreatmentSummaryErr := service.MobileGetTreatmentSummary(adminInfo.Org.Id, patientID, date.Unix())
-	if getTreatmentSummaryErr != nil {
-		this.ErrorLog("获取治疗小结失败:%v", getTreatmentSummaryErr)
-		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
-		return
-	}
+	treatmentSummary, _ := service.MobileGetTreatmentSummary(adminInfo.Org.Id, patientID, date.Unix())
+	//if getTreatmentSummaryErr != nil {
+	//	this.ErrorLog("获取治疗小结失败:%v", getTreatmentSummaryErr)
+	//	this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+	//	return
+	//}
 
 	// // 先走redis，没有走数据库
 	dialysisPrescribe, _ := service.MobileGetDialysisPrescribeByModeId(adminInfo.Org.Id, patientID, date.Unix(), schedual.ModeId)
 	// }
 
 	// 先走redis，没有走数据库
-	lastDryWeightDislysis, getDryErr := service.MobileGetLastDryWeight(adminInfo.Org.Id, patientID)
-	if getDryErr != nil {
-		this.ErrorLog("获取最后一条干体重失败:%v", getDryErr)
-		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
-		return
-	}
+	lastDryWeightDislysis, _ := service.MobileGetLastDryWeight(adminInfo.Org.Id, patientID)
+	//if getDryErr != nil {
+	//	this.ErrorLog("获取最后一条干体重失败:%v", getDryErr)
+	//	this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+	//	return
+	//}
 
 	// //headNurses, _ := service.GetAllSpecialPermissionAdminUsersWithoutStatus(adminInfo.Org.Id, adminInfo.App.Id, models.SpecialPermissionTypeHeadNurse)
 
 
 	//consumables, _ := service.FindConsumablesByDate(adminInfo.Org.Id, patientID, date.Unix())
 	//lastConsumables, _ := service.FindConsumablesByDate(adminInfo.Org.Id, patientID, date.Unix())
-
 	returnData := map[string]interface{}{
 		"patient":                        patient,
 		"schedual":                       schedual,
 	if treatmentSummary.ID == 0 { //新增
 		summary.Creater = adminUserInfo.AdminUser.Id
 		service.AddSigleSummaryRecord(&summary)
+		key := strconv.FormatInt(adminUserInfo.Org.Id, 10) + ":" + strconv.FormatInt(id, 10) + ":" + strconv.FormatInt(recordDate.Unix(), 10) + ":treatment_summary"
+		redis := service.RedisClient()
+		defer redis.Close()
+		//清空key 值
+		redis.Set(key, "", time.Second)
 		c.ServeSuccessJSON(map[string]interface{}{
 			"summary": summary,
 		})
 		doubleCheck.Modifier = modifier
 
 		err := service.AddSigleDoubleCheck(&doubleCheck)
+		key := strconv.FormatInt(adminUserInfo.Org.Id, 10) + ":" + strconv.FormatInt(id, 10) + ":" + strconv.FormatInt(recordDate.Unix(), 10) + ":double_check"
+		redis := service.RedisClient()
+		defer redis.Close()
+		//清空key 值
+		redis.Set(key, "", time.Second)
 		if err == nil {
 			c.ServeSuccessJSON(map[string]interface{}{
 				"doubleCheck": &doubleCheck,
 		doubleCheck.CreatedTime = check.CreatedTime
 		doubleCheck.ID = check.ID
 		err := service.UpdateDoubleCheck(&doubleCheck)
+		key := strconv.FormatInt(adminUserInfo.Org.Id, 10) + ":" + strconv.FormatInt(id, 10) + ":" + strconv.FormatInt(recordDate.Unix(), 10) + ":double_check"
+		redis := service.RedisClient()
+		defer redis.Close()
+		//清空key 值
+		redis.Set(key, "", time.Second)
 		if err == nil {
 			c.ServeSuccessJSON(map[string]interface{}{
 				"doubleCheck": &doubleCheck,
 		}
 
 		err := service.AddSigleAssessmentAfterDislysisRecord(&assessmentAfterDislysis)
+		key := strconv.FormatInt(adminUserInfo.Org.Id, 10) + ":" + strconv.FormatInt(id, 10) + ":" + strconv.FormatInt(recordDate.Unix(), 10) + ":assessment_after_dislysis"
+		redis := service.RedisClient()
+		defer redis.Close()
+		//清空key 值
+		redis.Set(key, "", time.Second)
+
 		if err == nil {
 			c.ServeSuccessJSON(map[string]interface{}{
 				"assessmentAfterDislysis": assessmentAfterDislysis,
 	difficult_puncture_nurse, _ := this.GetInt64("difficult_puncture_nurse")
 	new_fistula_nurse, _ := this.GetInt64("new_fistula_nurse")
 	zone_id, _ := this.GetInt64("zone_id")
-	fmt.Println("zone23333232323232232332232323", zone_id)
+
 	if patientID <= 0 || len(recordDateStr) == 0 || nurseID <= 0 || bedID <= 0 {
 		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
 		return
 	_, errorscode := service.GetDialysisOrderByBedId(adminUserInfo.Org.Id, schedulestartTime, bedID, schedual_type)
 	if errorscode == gorm.ErrRecordNotFound {
 		createErr := service.MobileCreateDialysisOrder(adminUserInfo.Org.Id, patientID, dialysisRecord)
+
+		redis := service.RedisClient()
+		defer redis.Close()
+		keyOne := strconv.FormatInt(adminUserInfo.Org.Id, 10) + ":" + ":dialysis_orders_list_all"
+		//清空key 值
+		redis.Set(keyOne, "", time.Second)
 		if createErr != nil {
 			this.ErrorLog("上机失败：%v", createErr)
 			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
 	}
 
 	updateErr := service.ModifyStartDialysisOrder(dialysisRecord)
+
 	if updateErr != nil {
 		this.ErrorLog("修改上机失败：%v", updateErr)
 		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
 
 	if len(advices) > 0 {
 		list, err := service.CreateMGroupAdvice(adminUserInfo.Org.Id, advices, groupNo)
-
+		key := strconv.FormatInt(adminUserInfo.Org.Id, 10) + ":" + strconv.FormatInt(patient, 10) + ":" + strconv.FormatInt(RecordDate, 10) + ":doctor_advices"
+		redis := service.RedisClient()
+		defer redis.Close()
+		//清空key 值
+		redis.Set(key, "", time.Second)
 		if err != nil {
 			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeCreateDoctorAdviceFail)
 			return

controllers/mobile_api_controllers/dialysis_api_controller_extend.go

 	"XT_New/utils"
 	"fmt"
 	"github.com/jinzhu/gorm"
+	"strconv"
 	"time"
 )
 
 	}
 
 	err := service.CreateMonitor(&record)
+	key := strconv.FormatInt(adminInfo.Org.Id, 10) + ":" + strconv.FormatInt(patientID, 10) + ":" + strconv.FormatInt(date, 10) + ":monitor_records"
+	redis := service.RedisClient()
+	defer redis.Close()
+	//清空key 值
+	redis.Set(key, "", time.Second)
 	if err != nil {
 		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeMonitorCreate)
 		return
 	monitor.BloodThickness = blood_thickness
 	monitor.BloodTemperature = blood_temperature
 	err = service.UpdateMonitor(monitor)
+	key := strconv.FormatInt(adminInfo.Org.Id, 10) + ":" + strconv.FormatInt(patientID, 10) + ":" + strconv.FormatInt(date, 10) + ":monitor_records"
+	redis := service.RedisClient()
+	defer redis.Close()
+	//清空key 值
+	redis.Set(key, "", time.Second)
 	if err != nil {
 		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeMonitorUpdate)
 		return

controllers/mobile_api_controllers/doctor_advice_api_controller.go

 	"XT_New/models"
 	"XT_New/service"
 	"XT_New/utils"
-	"fmt"
 )
 
 type DoctorAdviceAPIController struct {
 	adminInfo := this.GetMobileAdminUserInfo()
 	orgID := adminInfo.Org.Id
 	scheduals, err := service.MobileGetScheduleDoctorAdvicesTwo(orgID, date.Unix(), adviceType, patientType, adminInfo.AdminUser.Id, delivery_way)
+	//获取所有的患者
+	blood_patients, _ := service.GetAllPatientListByListTwo(orgID)
+	//获取透析处方
+	blood_prescriptions, _ := service.GetAllPrescriptionByListOne(orgID, date.Unix())
+	//获取上机
+	blood_dialysisOrders, _ := service.GetAllDialysisOrdersByListTwo(orgID, date.Unix())
+
+	for key, schedule := range scheduals {
+		for _, patient := range blood_patients {
+			if schedule.PatientId == patient.ID {
+				scheduals[key].SchedualPatient = patient
+				break
+			}
+		}
+
+		for _, prescription := range blood_prescriptions {
+			if schedule.PatientId == prescription.PatientId {
+				scheduals[key].Prescription = prescription
+				break
+			}
+		}
+
+		//获取上机
+		for _, dialysisorder := range blood_dialysisOrders {
+			if schedule.PatientId == dialysisorder.PatientId {
+				scheduals[key].DialysisOrder = dialysisorder
+				break
+			}
+		}
+
+	}
+
 	config, _ := service.GetHisDoctorConfig(orgID)
 	project_config, _ := service.GetHisProjectConfig(orgID)
-	fmt.Println("project_config23223232323", project_config)
+
 	if project_config.IsOpen == 1 || project_config.IsOpen == 2 {
 		//获取his医嘱数据
 		project, _ := service.GetMobileHisPrescriptionProject(orgID, date.Unix(), delivery_way, patientType, adminInfo.AdminUser.Id)
+
+		//获取所有的患者
+		patients, _ := service.GetAllPatientListByListTwo(orgID)
+
+		//获取所有床位
+		numberList, _ := service.GetAllDeviceNumberByListOne(orgID)
+
+		//获取透析处方
+		prescriptions, _ := service.GetAllPrescriptionByListOne(orgID, date.Unix())
+
+		//获取上机
+		dialysisOrders, _ := service.GetAllDialysisOrdersByListTwo(orgID, date.Unix())
+
+		for key, item := range project {
+			for _, patient := range patients {
+				if item.PatientId == patient.ID {
+					project[key].SchedualPatient = patient
+					break
+				}
+			}
+			// 获取床位信息
+			for _, it := range numberList {
+				if item.BedId == it.ID {
+					project[key].DeviceNumber = it
+					break
+				}
+			}
+
+			// 获取处方
+			for _, it := range prescriptions {
+				if item.PatientId == it.PatientId {
+					project[key].Prescription = it
+					break
+				}
+			}
+
+			//获取上机
+			for _, it := range dialysisOrders {
+				if item.PatientId == it.PatientId {
+					project[key].DialysisOrder = it
+					break
+				}
+			}
+		}
+
 		hisAdvices, _ := service.GetHisDoctorAdvicesTwo(orgID, date.Unix(), delivery_way, patientType, adminInfo.AdminUser.Id)
 		adminUser, _ := service.GetAllAdminUsers(orgID, adminInfo.App.Id)
 		if err != nil {

controllers/mobile_api_controllers/patient_api_controller.go

 	advice.AdviceDoctor = adminUserInfo.AdminUser.Id
 
 	err := service.CreateDoctorAdvice(&advice)
+
 	if err != nil {
 		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeCreateDoctorAdviceFail)
 		return
 			UpdatedTime:   time.Now().Unix(),
 		}
 		service.ModifyExceDoctorAdviceById(&advicesinfo, ids)
+
 	}
 	if err != nil {
 		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeUpdateDoctorAdviceFail)
 	// }
 
 	err = service.UpadatePredialysisEvaluation(&evaluation)
+	key := strconv.FormatInt(adminUserInfo.Org.Id, 10) + ":" + strconv.FormatInt(id, 10) + ":" + strconv.FormatInt(theAssessmentDateTime, 10) + ":assessment_before_dislysis"
+	redis := service.RedisClient()
+	defer redis.Close()
+	//清空key 值
+	redis.Set(key, "", time.Second)
 	if err != nil {
 		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDBUpdate)
 		return
 	adminInfo := c.GetMobileAdminUserInfo()
 	orgID := adminInfo.Org.Id
 	monitor, err := service.GetMonitorRecord(orgID, theStartTime, partition, patient_id)
+	if err != nil {
+		c.ErrorLog("获取排班信息失败:%v", err)
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+	} else {
+		if len(monitor) > 0 {
+			//获取所有床位
+			numberList, _ := service.GetAllDeviceNumberByList(orgID)
+			//获取所有分区
+			zoneList, _ := service.GetAllZoneByList(orgID)
+			//获取透析处方
+			prescriptions, _ := service.GetAllPrescriptionByList(orgID, theStartTime)
+			//获取透前评估
+			assessmentBefores, _ := service.GetAllAssessmentBeforesByListOne(orgID, theStartTime)
+			//获取上机
+			dialysisOrders, _ := service.GetAllDialysisOrdersByListOne(orgID, theStartTime)
+			//获取透后
+			AssessmentAfterDislysis, _ := service.GetAllAssessmentAfterDislysisByListOne(orgID, theStartTime)
+
+			//获取透后监测
+			monitorlist, _ := service.GetAllMonitorList(orgID, theStartTime)
+
+			//获取所有的患者
+			patients, _ := service.GetAllPatientListByListOne(orgID)
+
+			//获取所有透析模式
+			treatments, _ := service.GetAllTreatModeByList(orgID)
+
+			for key, item := range monitor {
+				// 获取床位信息
+				for _, it := range numberList {
+					if item.BedId == it.ID {
+						monitor[key].DeviceNumber = it
+						break
+					}
+				}
+
+				//获取分区信息
+				for _, it := range zoneList {
+					if item.PartitionId == it.ID {
+						monitor[key].DeviceZone = it
+					}
+				}
+
+				for _, prescription := range prescriptions {
+					if item.PatientId == prescription.PatientId {
+						monitor[key].Prescription = prescription
+						break
+					}
+				}
+
+				// 透前评估
+				for _, assessmentBefore := range assessmentBefores {
+					if item.PatientId == assessmentBefore.PatientId {
+						monitor[key].AssessmentBeforeDislysis = assessmentBefore
+						break
+					}
+				}
+
+				// 透析上下机
+				for _, dialysisOrder := range dialysisOrders {
+					if item.PatientId == dialysisOrder.PatientId {
+						monitor[key].DialysisOrder = dialysisOrder
+						break
+					}
+				}
+
+				// 治疗小节
+				for _, afterDislysis := range AssessmentAfterDislysis {
+					if item.PatientId == afterDislysis.PatientId {
+						monitor[key].AssessmentAfterDislysis = afterDislysis
+						break
+					}
+				}
+				records := make([]*models.VMMonitoringRecord, 0)
+				// 透析监测
+				for _, it := range monitorlist {
+					records := append(records, it)
+					if item.PatientId == it.PatientId {
+						monitor[key].MonitoringRecord = records
+					}
+				}
+
+				for _, patient := range patients {
+					if item.PatientId == patient.ID {
+						monitor[key].MonitorPatients = patient
+						break
+					}
+				}
+
+				for _, treatment := range treatments {
+					if item.ModeId == treatment.ID {
+						monitor[key].TreatmentMode = treatment
+						break
+					}
+				}
+			}
+		}
+
+	}
+
 	//获取患者的透析次数
 	count, err := service.GetDialysisCount(orgID, partition)
 
 		}
 
 		newAdvices, createErr := service.CreateMGroupAdvice(adminUserInfo.Org.Id, advices, group_no)
+		key := strconv.FormatInt(adminUserInfo.Org.Id, 10) + ":" + strconv.FormatInt(patient, 10) + ":" + strconv.FormatInt(AdviceDate, 10) + ":doctor_advices"
+		redis := service.RedisClient()
+		defer redis.Close()
+		//清空key 值
+		redis.Set(key, "", time.Second)
 		if createErr != nil {
 			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeCreateDoctorAdviceFail)
 			return

controllers/new_mobile_api_controllers/new_manage_api_controller.go

 	adminUser := this.GetMobileAdminUserInfo()
 	orgid := adminUser.Org.Id
 	remander, err := service.GetRemanderData(orgid)
+
 	if err != nil {
 		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
 		return

main.go

 	//service.BeginAutoCreateStaffScheduleJob()
 	//service.BeginAutoCreateDrugJob()
 	//service.BeginAutoCreateStockJob()
-	beego.BConfig.WebConfig.Session.SessionGCMaxLifetime = 60
+	//beego.BConfig.WebConfig.Session.SessionGCMaxLifetime = 6000
 	beego.Run()
 }

models/dialysis.go

 	CreatedTime  int64 `gorm:"column:created_time" json:"created_time" form:"created_time"`
 	UpdatedTime  int64 `gorm:"column:updated_time" json:"updated_time" form:"updated_time"`
 
-	MonitorPatients MonitorPatients `gorm:"ForeignKey:PatientId" json:"patient"`
-	DeviceNumber    DeviceNumber    `gorm:"ForeignKey:BedId" json:"device_number"`
-	DeviceZone      DeviceZone      `gorm:"ForeignKey:PartitionId" json:"device_zone"`
-	TreatmentMode   TreatmentMode   `gorm:"ForeignKey:ModeId" json:"treatment_mode"`
+	MonitorPatients *MonitorPatients `gorm:"ForeignKey:PatientId" json:"patient"`
+	DeviceNumber    *DeviceNumber    `gorm:"ForeignKey:BedId" json:"device_number"`
+	DeviceZone      *DeviceZone      `gorm:"ForeignKey:PartitionId" json:"device_zone"`
+	TreatmentMode   *TreatmentMode   `gorm:"ForeignKey:ModeId" json:"treatment_mode"`
 
-	DialysisOrder            MonitorDialysisOrder    `gorm:"ForeignKey:DialysisDate,PatientId;AssociationForeignKey:ScheduleDate,PatientId" json:"dialysis_order"`
-	Prescription             DialysisPrescription    `gorm:"ForeignKey:RecordDate,PatientId;AssociationForeignKey:ScheduleDate,PatientId" json:"prescription"`
-	AssessmentBeforeDislysis PredialysisEvaluation   `gorm:"ForeignKey:AssessmentDate,PatientId;AssociationForeignKey:ScheduleDate,PatientId" json:"assessment_before_dislysis"`
-	AssessmentAfterDislysis  AssessmentAfterDislysis `gorm:"ForeignKey:AssessmentDate,PatientId;AssociationForeignKey:ScheduleDate,PatientId" json:"assessment_after_dislysis"`
-	MonitoringRecord         []MonitoringRecord      `gorm:"ForeignKey:MonitoringDate,PatientId;AssociationForeignKey:ScheduleDate,PatientId" json:"monitoring_record"`
+	DialysisOrder            *MonitorDialysisOrder    `gorm:"ForeignKey:DialysisDate,PatientId;AssociationForeignKey:ScheduleDate,PatientId" json:"dialysis_order"`
+	Prescription             *DialysisPrescription    `gorm:"ForeignKey:RecordDate,PatientId;AssociationForeignKey:ScheduleDate,PatientId" json:"prescription"`
+	AssessmentBeforeDislysis *PredialysisEvaluation   `gorm:"ForeignKey:AssessmentDate,PatientId;AssociationForeignKey:ScheduleDate,PatientId" json:"assessment_before_dislysis"`
+	AssessmentAfterDislysis  *AssessmentAfterDislysis `gorm:"ForeignKey:AssessmentDate,PatientId;AssociationForeignKey:ScheduleDate,PatientId" json:"assessment_after_dislysis"`
+	MonitoringRecord         []*MonitoringRecord      `gorm:"ForeignKey:MonitoringDate,PatientId;AssociationForeignKey:ScheduleDate,PatientId" json:"monitoring_record"`
 
 	//Patient         string          `gorm:"-" json:"patient" form:"patient"`
 	//SchedualPatient SchedualPatient `gorm:"ForeignKey:PatientId"`

models/new_monitor.go

 	ModeId       int64 `gorm:"column:mode_id" json:"mode_id"`
 	Status       int64 `gorm:"column:status" json:"status"`
 
-	MonitorPatients VMMonitorPatients `gorm:"ForeignKey:PatientId" json:"patient"`
-	DeviceNumber    DeviceNumber      `gorm:"ForeignKey:BedId" json:"device_number"`
-	DeviceZone      DeviceZone        `gorm:"ForeignKey:PartitionId" json:"device_zone"`
-	TreatmentMode   TreatmentMode     `gorm:"ForeignKey:ModeId" json:"treatment_mode"`
-
-	DialysisOrder            VMMonitorDialysisOrder    `gorm:"ForeignKey:PatientId;AssociationForeignKey:PatientId" json:"dialysis_order"`
-	Prescription             VMDialysisPrescription    `gorm:"ForeignKey:PatientId;AssociationForeignKey:PatientId" json:"prescription"`
-	AssessmentBeforeDislysis VMPredialysisEvaluation   `gorm:"ForeignKey:PatientId;AssociationForeignKey:PatientId" json:"assessment_before_dislysis"`
-	AssessmentAfterDislysis  VMAssessmentAfterDislysis `gorm:"ForeignKey:PatientId;AssociationForeignKey:PatientId" json:"assessment_after_dislysis"`
-	MonitoringRecord         []VMMonitoringRecord      `gorm:"ForeignKey:PatientId;AssociationForeignKey:PatientId" json:"monitoring_record"`
+	MonitorPatients *VMMonitorPatients `gorm:"ForeignKey:PatientId" json:"patient"`
+	DeviceNumber    *DeviceNumber      `gorm:"ForeignKey:BedId" json:"device_number"`
+	DeviceZone      *DeviceZone        `gorm:"ForeignKey:PartitionId" json:"device_zone"`
+	TreatmentMode   *TreatmentMode     `gorm:"ForeignKey:ModeId" json:"treatment_mode"`
+
+	DialysisOrder            *VMMonitorDialysisOrder    `gorm:"ForeignKey:PatientId;AssociationForeignKey:PatientId" json:"dialysis_order"`
+	Prescription             *VMDialysisPrescription    `gorm:"ForeignKey:PatientId;AssociationForeignKey:PatientId" json:"prescription"`
+	AssessmentBeforeDislysis *VMPredialysisEvaluation   `gorm:"ForeignKey:PatientId;AssociationForeignKey:PatientId" json:"assessment_before_dislysis"`
+	AssessmentAfterDislysis  *VMAssessmentAfterDislysis `gorm:"ForeignKey:PatientId;AssociationForeignKey:PatientId" json:"assessment_after_dislysis"`
+	MonitoringRecord         []*VMMonitoringRecord      `gorm:"ForeignKey:PatientId;AssociationForeignKey:PatientId" json:"monitoring_record"`
 }
 
 func (NewVMMonitorDialysisSchedule) TableName() string {

models/patient_models.go

 func (XtAssessmentBeforeDislysis) TableName() string {
 	return "xt_assessment_before_dislysis"
 }
+
+type MsDeviceNumber struct {
+	ID      int64  `gorm:"column:id" json:"id" form:"id"`
+	OrgId   int64  `gorm:"column:org_id" json:"org_id" form:"org_id"`
+	Number  string `gorm:"column:number" json:"number" form:"number"`
+	GroupId int64  `gorm:"column:group_id" json:"group_id" form:"group_id"`
+	ZoneId  int64  `gorm:"column:zone_id" json:"zone_id" form:"zone_id"`
+	Status  int64  `gorm:"column:status" json:"status" form:"status"`
+	Ctime   int64  `gorm:"column:ctime" json:"ctime" form:"ctime"`
+	Mtime   int64  `gorm:"column:mtime" json:"mtime" form:"mtime"`
+	Sort    int64  `gorm:"column:sort" json:"sort" form:"sort"`
+}
+
+func (MsDeviceNumber) TableName() string {
+	return "xt_device_number"
+}
+
+type MsDeviceZone struct {
+	ID     int64  `gorm:"column:id" json:"id" form:"id"`
+	OrgId  int64  `gorm:"column:org_id" json:"org_id" form:"org_id"`
+	Name   string `gorm:"column:name" json:"name" form:"name"`
+	Type   int64  `gorm:"column:type" json:"type" form:"type"`
+	Status int64  `gorm:"column:status" json:"status" form:"status"`
+	Ctime  int64  `gorm:"column:ctime" json:"ctime" form:"ctime"`
+	Mtime  int64  `gorm:"column:mtime" json:"mtime" form:"mtime"`
+	Sort   int64  `gorm:"column:sort" json:"sort" form:"sort"`
+}
+
+func (MsDeviceZone) TableName() string {
+	return "xt_device_zone"
+}

service/dialysis_service.go

 
 import (
 	"XT_New/models"
+	"encoding/json"
 	"fmt"
+	"github.com/jinzhu/gorm"
+	"strconv"
 	"strings"
 	"time"
-	"strconv"
-	"encoding/json"
-	"github.com/jinzhu/gorm"
 )
 
 //GetPatientList 返回患者的列表
 	return schedule, err, total
 }
 
-func GetDialysisWatchByKeyword(orgID int64, keyword string, schedulType int64, partitionType int64, page int64, limit int64) ([]*models.DialysisSchedule, error, int64) {
-	var patients []*models.Patients
-	getPatientErr := readDb.Model(&models.Patients{}).Where("status = 1 AND user_org_id = ? AND (name like ? OR dialysis_no like ?)", orgID, "%"+keyword+"%", "%"+keyword+"%").Find(&patients).Error
-	if getPatientErr != nil {
-		return nil, getPatientErr, 0
-	}
-	patientIDs := make([]int64, len(patients))
-	for index, patient := range patients {
-		patientIDs[index] = patient.ID
-	}
+func GetDialysisWatchByKeyword(orgID int64, keyword string, schedulType int64, partitionType int64, page int64, limit int64) (schedules []*models.DialysisSchedule, err error, total int64) {
+	//var patients []*models.Patients
+	//getPatientErr := readDb.Model(&models.Patients{}).Where("status = 1 AND user_org_id = ? AND (name like ? OR dialysis_no like ?)", orgID, "%"+keyword+"%", "%"+keyword+"%").Find(&patients).Error
+	//if getPatientErr != nil {
+	//	return nil, getPatientErr, 0
+	//}
+	//patientIDs := make([]int64, len(patients))
+	//for index, patient := range patients {
+	//	patientIDs[index] = patient.ID
+	//}
+	//
+	//db := readDb.
+	//	Model(&models.DialysisSchedule{}).
+	//	Preload("DeviceNumber", "status = 1 AND org_id = ?", orgID).
+	//	Preload("TreatmentMode", "status = 1").
+	//	Preload("Prescription", "status = 1 AND user_org_id = ?", orgID).
+	//	Preload("AssessmentBeforeDislysis", "status = 1 AND  user_org_id = ?", orgID).
+	//	Preload("AssessmentAfterDislysis", "status = 1 AND  user_org_id = ?", orgID).
+	//	Preload("MonitoringRecord", "status = 1 AND  user_org_id = ?", orgID).
+	//	Preload("DialysisOrder", "status = 1 AND user_org_id = ?", orgID).
+	//	Preload("MonitorPatients", "status = 1 AND user_org_id = ?", orgID)
+	//db = db.Where("xt_schedule.status = 1 AND patient_id in (?)", patientIDs)
+	//if schedulType > 0 {
+	//	db = db.Where("schedule_type = ?", schedulType)
+	//}
+	//if partitionType > 0 {
+	//	db = db.Joins("inner join xt_device_number as d_n on d_n.id = xt_schedule.bed_id and d_n.zone_id = ? and d_n.status = 1", partitionType)
+	//
+	//}
+	//var schedules []*models.DialysisSchedule
+	//total := int64(0)
+	//err := db.Count(&total).Offset(limit * (page - 1)).Limit(limit).Order("schedule_date desc").Find(&schedules).Error
+	//return schedules, err, total
+
+	db := readDb.Model(&models.DialysisSchedule{}).Where("status = 1")
 
-	db := readDb.
-		Model(&models.DialysisSchedule{}).
-		Preload("DeviceNumber", "status = 1 AND org_id = ?", orgID).
-		// Preload("DeviceZone", "status = 1 AND org_id = ?", orgID).
-		Preload("TreatmentMode", "status = 1").
-		Preload("Prescription", "status = 1 AND user_org_id = ?", orgID).
-		Preload("AssessmentBeforeDislysis", "status = 1 AND  user_org_id = ?", orgID).
-		Preload("AssessmentAfterDislysis", "status = 1 AND  user_org_id = ?", orgID).
-		Preload("MonitoringRecord", "status = 1 AND  user_org_id = ?", orgID).
-		Preload("DialysisOrder", "status = 1 AND user_org_id = ?", orgID).
-		Preload("MonitorPatients", "status = 1 AND user_org_id = ?", orgID)
-	db = db.Where("xt_schedule.status = 1 AND patient_id in (?)", patientIDs)
 	if schedulType > 0 {
-		db = db.Where("schedule_type = ?", schedulType)
+		db = db.Where("scheudle_type = ?", schedulType)
 	}
+
 	if partitionType > 0 {
-		db = db.Joins("inner join xt_device_number as d_n on d_n.id = xt_schedule.bed_id and d_n.zone_id = ? and d_n.status = 1", partitionType)
-		// db = db.Where("partition_id = ?", partitionType)
+		db = db.Where("partition_id = ?", partitionType)
 	}
-	var schedules []*models.DialysisSchedule
-	total := int64(0)
-	err := db.Count(&total).Offset(limit * (page - 1)).Limit(limit).Order("schedule_date desc").Find(&schedules).Error
+
+	err = db.Count(&total).Offset(limit * (page - 1)).Limit(limit).Order("schedule_date desc").Find(&schedules).Error
 	return schedules, err, total
 }
 
 				starfes_str, err := json.Marshal(es)
 				if err == nil {
 					redis.Set(key, starfes_str, time.Second*60*60*18)
+					return es, nil
 				}
 			} else {
 				redis.Set(key, " ", time.Second*60*60*18)
+				return es, nil
 			}
 			return es, nil
 		}

service/gobal_config_service.go

 
 import (
 	"XT_New/models"
+	"encoding/json"
 	"fmt"
 	"github.com/jinzhu/gorm"
-	"time"
-	"encoding/json"
 	"strconv"
+	"time"
 )
 
 func CreateAutomaticReduceRecord(config *models.GobalConfig) (err error) {
 	defer redis.Close()
 
 	// cur_date := time.Now().Format("2006-01-02")
-	key := strconv.FormatInt(org_id, 10) +  ":gobal_config"
+	key := strconv.FormatInt(org_id, 10) + ":gobal_config"
 	gobal_config_str, _ := redis.Get(key).Result()
 
 	if len(gobal_config_str) == 0 { //没有到缓存数据，从数据库中获取数据，进行缓存到redis
 		err = readDb.Model(&models.GobalConfig{}).Where("status = 1 AND org_id = ?", org_id).Find(&config).Error
 		if err != nil {
 			if err == gorm.ErrRecordNotFound {
-				return nil,config
+				return nil, config
 			} else {
-				return err,config
+				return err, config
 			}
 		} else {
 			if config.ID > 0 {
 				gobal_config_str, err := json.Marshal(config)
 				if err == nil {
 					redis.Set(key, gobal_config_str, time.Second*60*60*18)
+					return nil, config
 				}
 			} else {
 				redis.Set(key, " ", time.Second*60*60*18)
+				return nil, config
 			}
-			return nil,config
+			return nil, config
 		}
 	} else { //缓存数据了数据，将redis缓存的json字符串转为map
 		json.Unmarshal([]byte(gobal_config_str), &config)
-		return nil,config
+		return nil, config
 	}
 }
 
 		err = readDb.Model(&models.XtHisConfig{}).Where("status = 1 AND user_org_id = ?", org_id).Find(&config).Error
 		if err != nil {
 			if err == gorm.ErrRecordNotFound {
-				return nil,config
+				return nil, config
 			} else {
-				return err,config
+				return err, config
 			}
 		} else {
 			if config.ID > 0 {
 			} else {
 				redis.Set(key, " ", time.Second*60*60*18)
 			}
-			return nil,config
+			return nil, config
 		}
 	} else { //缓存数据了数据，将redis缓存的json字符串转为map
 		json.Unmarshal([]byte(his_config_str), &config)
-		return nil,config
+		return nil, config
 	}
 }
 
 			} else {
 				redis.Set(key, " ", time.Second*60*60*18)
 			}
-			return nil,config
+			return nil, config
 		}
 	} else { //缓存数据了数据，将redis缓存的json字符串转为map
 		json.Unmarshal([]byte(his_project_config_str), &config)
-		return nil,config
+		return nil, config
 	}
 }
 

service/mobile_dialysis_service.go

 // 用户基本信息
 func MobileGetPatientDetail(orgID int64, patientID int64) (*MPatient, error) {
 	var patient MPatient
-	err := readDb.Model(&MPatient{}).Where("status = 1 AND user_org_id = ? AND id = ?", orgID, patientID).First(&patient).Error
-	if err != nil {
-		if err == gorm.ErrRecordNotFound {
-			return nil, nil
+	//err := readDb.Model(&MPatient{}).Where("status = 1 AND user_org_id = ? AND id = ?", orgID, patientID).First(&patient).Error
+	//if err != nil {
+	//	if err == gorm.ErrRecordNotFound {
+	//		return nil, nil
+	//	} else {
+	//		return nil, err
+	//	}
+	//}
+	//return &patient, nil
+
+	redis := RedisClient()
+	defer redis.Close()
+	key := strconv.FormatInt(orgID, 10) + ":" + strconv.FormatInt(patientID, 10) + ":patient_info"
+
+	patient_info_str, _ := redis.Get(key).Result()
+
+	if len(patient_info_str) == 0 { //没有到缓存数据，从数据库中获取数据，进行缓存到redis
+		err = readDb.Model(&patient).Where("id = ? and user_org_id=? and status=1", patientID, orgID).First(&patient).Error
+		if err != nil {
+			if err == gorm.ErrRecordNotFound {
+				return &patient, nil
+			} else {
+				return &patient, err
+			}
 		} else {
-			return nil, err
+			if patient.ID > 0 {
+				//缓存数据
+				patient_info_json, err := json.Marshal(&patient)
+				if err == nil {
+					redis.Set(key, patient_info_json, time.Second*60*60*18)
+				}
+			}
+			return &patient, nil
 		}
+	} else { //缓存数据了数据，将redis缓存的json字符串转为map
+		json.Unmarshal([]byte(patient_info_str), &patient)
+		return &patient, nil
 	}
-	return &patient, nil
 }
 
 // 用户排班信息
 	defer redis.Close()
 	var vm MDialysisScheduleVM
 
-	// cur_date := time.Now().Format("2006-01-02")
 	key := strconv.FormatInt(orgID, 10) + ":" + strconv.FormatInt(patientID, 10) + ":" + strconv.FormatInt(schedualDate, 10) + ":schedual_detail"
 	schedual_detail_str, _ := redis.Get(key).Result()
 
 	if len(schedual_detail_str) == 0 { //没有到缓存数据，从数据库中获取数据，进行缓存到redis
 		err := readDb.
 			Table("xt_schedule").
-			// Preload("SchedualPatient", "status = 1 AND user_org_id = ?", orgID).
 			Preload("DeviceNumber", "status = 1 AND org_id = ?", orgID).
 			Preload("DeviceNumber.Zone", "status = 1 AND org_id = ?", orgID).
 			Where("status = 1 AND user_org_id = ? AND schedule_date = ? AND patient_id = ?", orgID, schedualDate, patientID).
 			if vm.ID > 0 {
 				//缓存数据
 				schedual_detail_str, err := json.Marshal(vm)
+
 				if err == nil {
 					redis.Set(key, schedual_detail_str, time.Second*60*60*18)
 				}
 		}
 	} else { //缓存数据了数据，将redis缓存的json字符串转为map
 		json.Unmarshal([]byte(schedual_detail_str), &vm)
+
 		return &vm, nil
 	}
 }
 	redis := RedisClient()
 	defer redis.Close()
 
-	// cur_date := time.Now().Format("2006-01-02")
 	key := strconv.FormatInt(orgID, 10) + ":" + strconv.FormatInt(patientID, 10) + ":" + strconv.FormatInt(recordDate, 10) + ":receive_treatment_asses"
 	receive_treatment_asses_str, _ := redis.Get(key).Result()
 
 	// cur_date := time.Now().Format("2006-01-02")
 	key := strconv.FormatInt(orgID, 10) + ":" + strconv.FormatInt(patientID, 10) + ":" + strconv.FormatInt(recordDate, 10) + ":doctor_advices"
 	doctor_advices_str, _ := redis.Get(key).Result()
-
 	if len(doctor_advices_str) == 0 { //没有到缓存数据，从数据库中获取数据，进行缓存到redis
-		err := readDb.
-			Model(&models.DoctorAdvice{}).
+		err := readDb.Model(&models.DoctorAdvice{}).
 			Where("patient_id = ? and user_org_id = ? and status = 1 and record_date = ? and (advice_type = 2 || advice_type = 3)", patientID, orgID, recordDate).
 			Select("id, user_org_id, patient_id, advice_type, advice_date, record_date, start_time, advice_name,advice_desc, reminder_date, drug_spec, drug_spec_unit, single_dose, single_dose_unit, prescribing_number, prescribing_number_unit, delivery_way, execution_frequency, advice_doctor, status, created_time,updated_time, advice_affirm, remark, stop_time, stop_reason, stop_doctor, stop_state, parent_id, execution_time, execution_staff, execution_state, checker, check_state, check_time, groupno,way,drug_id,drug_name_id, IF(parent_id > 0, parent_id, id) as advice_order").
 			Order("start_time asc, groupno desc, advice_order desc, id asc").
 				doctor_advices_str, err := json.Marshal(records)
 				if err == nil {
 					redis.Set(key, doctor_advices_str, time.Second*60*60*18)
+					return records, nil
 				}
 			} else {
 				redis.Set(key, " ", time.Second*60*60*18)
+				return records, nil
 			}
 			return records, nil
 		}
 	// cur_date := time.Now().Format("2006-01-02")
 	key := strconv.FormatInt(orgID, 10) + ":" + strconv.FormatInt(patientID, 10) + ":" + strconv.FormatInt(recordDate, 10) + ":treatment_summary"
 	treatment_summary_str, _ := redis.Get(key).Result()
-
+	fmt.Println("质量洗哦啊稼23323232323232323233232322332", treatment_summary_str)
 	if len(treatment_summary_str) == 0 { //没有到缓存数据，从数据库中获取数据，进行缓存到redis
 		err := readDb.Model(&models.TreatmentSummary{}).Where("patient_id = ? and user_org_id = ? and status = 1 and assessment_date = ?", patientID, orgID, recordDate).First(&record).Error
 		if err != nil {
 
 	db := readDb.
 		Table("xt_schedule").
-		Preload("SchedualPatient", "status = 1 AND user_org_id = ?", orgID).
-		Preload("DialysisOrder", func(db *gorm.DB) *gorm.DB {
-			return db.Where("status = 1 AND user_org_id = ? AND dialysis_date = ?", orgID, scheduleDate).Preload("DeviceNumber", "status = 1 AND org_id= ?", orgID)
-		}).
+		//Preload("SchedualPatient", "status = 1 AND user_org_id = ?", orgID).
+		//Preload("DialysisOrder", func(db *gorm.DB) *gorm.DB {
+		//	return db.Where("status = 1 AND user_org_id = ? AND dialysis_date = ?", orgID, scheduleDate).Preload("DeviceNumber", "status = 1 AND org_id= ?", orgID)
+		//}).
 		Preload("DeviceNumber", "status = 1 AND org_id = ?", orgID).
 		Preload("DeviceNumber.Zone", "status = 1 AND org_id = ?", orgID).
-		Preload("Prescription", "status = 1 AND user_org_id = ? AND record_date = ?", orgID, scheduleDate).
-		//Preload("DialysisAssesmentBefor", "status =1 AND user_org_id = ? and assessment_date =?", orgID, scheduleDate).
+		//Preload("Prescription", "status = 1 AND user_org_id = ? AND record_date = ?", orgID, scheduleDate).
 		Preload("DoctorAdvices", adviceCondition...).
 		Where("status = 1 AND user_org_id = ?", orgID)
 	if scheduleDate != 0 {
 
 func GetMobileHisPrescriptionProject(orgID int64, scheduleDate int64, deliverWay string, patientType int, adminUserId int64) ([]*HisMScheduleProjectVM, error) {
 	var vms []*HisMScheduleProjectVM
-	if patientType == 0 {
-		db := readDb.
-			Table("xt_schedule").
-			Preload("SchedualPatient", "status = 1 AND user_org_id = ?", orgID).
-			Preload("DialysisOrder", func(db *gorm.DB) *gorm.DB {
-				return db.Where("status = 1 AND user_org_id = ? AND dialysis_date = ?", orgID, scheduleDate).Preload("DeviceNumber", "status = 1 AND org_id= ?", orgID)
-			}).
-			Preload("DeviceNumber", "status = 1 AND org_id = ?", orgID).
-			Preload("DeviceNumber.Zone", "status = 1 AND org_id = ?", orgID).
-			Preload("Prescription", "status = 1 AND user_org_id = ? AND record_date = ?", orgID, scheduleDate).
-			Preload("HisPrescriptionProject", func(db *gorm.DB) *gorm.DB {
-				return db.Where("status = 1 AND user_org_id = ? AND record_date = ?", orgID, scheduleDate).Preload("HisProject").Preload("GoodInfo", "status=1")
-			}).
-			Where("status = 1 AND user_org_id = ?", orgID)
-		if scheduleDate != 0 {
-			db = db.Where("schedule_date = ?", scheduleDate)
-		}
-		err = db.Find(&vms).Error
-	}
+	//if patientType == 0 {
+	//	db := readDb.
+	//		Table("xt_schedule").
+	//		Preload("SchedualPatient", "status = 1 AND user_org_id = ?", orgID).
+	//		Preload("DialysisOrder", func(db *gorm.DB) *gorm.DB {
+	//			return db.Where("status = 1 AND user_org_id = ? AND dialysis_date = ?", orgID, scheduleDate).Preload("DeviceNumber", "status = 1 AND org_id= ?", orgID)
+	//		}).
+	//		Preload("DeviceNumber", "status = 1 AND org_id = ?", orgID).
+	//		Preload("DeviceNumber.Zone", "status = 1 AND org_id = ?", orgID).
+	//		Preload("Prescription", "status = 1 AND user_org_id = ? AND record_date = ?", orgID, scheduleDate).
+	//		Preload("HisPrescriptionProject", func(db *gorm.DB) *gorm.DB {
+	//			return db.Where("status = 1 AND user_org_id = ? AND record_date = ?", orgID, scheduleDate).Preload("HisProject").Preload("GoodInfo", "status=1")
+	//		}).
+	//		Where("status = 1 AND user_org_id = ?", orgID)
+	//	if scheduleDate != 0 {
+	//		db = db.Where("schedule_date = ?", scheduleDate)
+	//	}
+	//	err = db.Find(&vms).Error
+	//}
 
-	if patientType > 0 {
-		db := readDb.
-			Table("xt_schedule").
-			Preload("SchedualPatient", "status = 1 AND user_org_id = ?", orgID).
-			Preload("DialysisOrder", func(db *gorm.DB) *gorm.DB {
-				return db.Where("status = 1 AND user_org_id = ? AND dialysis_date = ?", orgID, scheduleDate).Preload("DeviceNumber", "status = 1 AND org_id= ?", orgID)
-			}).
-			Preload("DeviceNumber", "status = 1 AND org_id = ?", orgID).
-			Preload("DeviceNumber.Zone", "status = 1 AND org_id = ?", orgID).
-			Preload("Prescription", "status = 1 AND user_org_id = ? AND record_date = ?", orgID, scheduleDate).
-			Preload("HisDoctorAdviceInfo", "status = 1 AND user_org_id = ? AND advice_date = ? and  (advice_doctor = ? or execution_staff = ?) ", orgID, scheduleDate, adminUserId, adminUserId).
-			Preload("HisPrescriptionProject", func(db *gorm.DB) *gorm.DB {
-				return db.Where("status = 1 AND user_org_id = ? AND record_date = ?", orgID, scheduleDate).Preload("HisProject").Preload("GoodInfo", "status=1")
-			}).
-			Where("status = 1 AND user_org_id = ?", orgID)
-		if scheduleDate != 0 {
-			db = db.Where("schedule_date = ?", scheduleDate)
-		}
-		err = db.Find(&vms).Error
+	//if patientType > 0 {
+	//	db := readDb.
+	//		Table("xt_schedule").
+	//		Preload("SchedualPatient", "status = 1 AND user_org_id = ?", orgID).
+	//		Preload("DialysisOrder", func(db *gorm.DB) *gorm.DB {
+	//			return db.Where("status = 1 AND user_org_id = ? AND dialysis_date = ?", orgID, scheduleDate).Preload("DeviceNumber", "status = 1 AND org_id= ?", orgID)
+	//		}).
+	//		Preload("DeviceNumber", "status = 1 AND org_id = ?", orgID).
+	//		Preload("DeviceNumber.Zone", "status = 1 AND org_id = ?", orgID).
+	//		Preload("Prescription", "status = 1 AND user_org_id = ? AND record_date = ?", orgID, scheduleDate).
+	//		Preload("HisDoctorAdviceInfo", "status = 1 AND user_org_id = ? AND advice_date = ? and  (advice_doctor = ? or execution_staff = ?) ", orgID, scheduleDate, adminUserId, adminUserId).
+	//		Preload("HisPrescriptionProject", func(db *gorm.DB) *gorm.DB {
+	//			return db.Where("status = 1 AND user_org_id = ? AND record_date = ?", orgID, scheduleDate).Preload("HisProject").Preload("GoodInfo", "status=1")
+	//		}).
+	//		Where("status = 1 AND user_org_id = ?", orgID)
+	//	if scheduleDate != 0 {
+	//		db = db.Where("schedule_date = ?", scheduleDate)
+	//	}
+	//	err = db.Find(&vms).Error
+	//}
+
+	db := readDb.Table("xt_schedule").Where("status = 1")
+	if orgID > 0 {
+		db = db.Where("user_org_id = ?", orgID)
+	}
+	if scheduleDate > 0 {
+		db = db.Where("schedule_date =?", scheduleDate)
 	}
+	err = db.Find(&vms).Error
 
 	return vms, err
 }
 				last_dry_weight_str, err := json.Marshal(record)
 				if err == nil {
 					redis.Set(key, last_dry_weight_str, time.Second*60*60*18)
+					return nil, err
 				}
 			} else {
 				redis.Set(key, " ", time.Second*60*60*18)
+				return nil, err
 			}
 			return &record, nil
 		}
 
 	// cur_date := time.Now().Format("2006-01-02")
 	key := strconv.FormatInt(orgID, 10) + ":" + strconv.FormatInt(patientID, 10) + ":" + strconv.FormatInt(recordDate, 10) + ":" + strconv.FormatInt(mode_id, 10) + ":dialysis_prescribe"
-	fmt.Println("透析处方中的keyzhi", key)
+
 	dialysis_prescribe_str, _ := redis.Get(key).Result()
 
 	if len(dialysis_prescribe_str) == 0 { //没有到缓存数据，从数据库中获取数据，进行缓存到redis
 				return nil, err
 			}
 		} else {
+
 			if record.ID > 0 {
 				//缓存数据
 				dialysis_prescribe_by_mode_str, err := json.Marshal(record)
+
 				if err == nil {
 					redis.Set(key, dialysis_prescribe_by_mode_str, time.Second*60*60*18)
+					return nil, err
 				}
 			} else {
 				redis.Set(key, " ", time.Second*60*60*18)
+				return nil, err
 			}
 			return &record, nil
 		}
 }
 
 func MobileGetLastDialysisPrescribeByModeId(orgID int64, patientID int64, mode_id int64) (*models.DialysisPrescription, error) {
+	//var record models.DialysisPrescription
+	//err := readDb.Model(&models.DialysisPrescription{}).Where("patient_id = ? and user_org_id = ? and status = 1  AND mode_id = ?", patientID, orgID, mode_id).Last(&record).Error
+	//if err != nil {
+	//	if err == gorm.ErrRecordNotFound {
+	//		return nil, nil
+	//	} else {
+	//		return nil, err
+	//	}
+	//}
+	//return &record, nil
+
 	var record models.DialysisPrescription
-	err := readDb.Model(&models.DialysisPrescription{}).Where("patient_id = ? and user_org_id = ? and status = 1  AND mode_id = ?", patientID, orgID, mode_id).Last(&record).Error
-	if err != nil {
-		if err == gorm.ErrRecordNotFound {
-			return nil, nil
+	redis := RedisClient()
+	defer redis.Close()
+
+	key := strconv.FormatInt(orgID, 10) + ":" + strconv.FormatInt(patientID, 10) + ":" + strconv.FormatInt(mode_id, 10) + ":dialysis_prescribe_by_mode"
+	dialysis_prescribe_by_mode_id, _ := redis.Get(key).Result()
+
+	if len(dialysis_prescribe_by_mode_id) == 0 { //没有到缓存数据，从数据库中获取数据，进行缓存到redis
+		err := readDb.Model(&models.DialysisPrescription{}).Where("patient_id = ? and user_org_id = ? and status = 1 and mode_id = ?", patientID, orgID, mode_id).First(&record).Error
+		if err != nil {
+			if err == gorm.ErrRecordNotFound {
+				return nil, nil
+			} else {
+				return nil, err
+			}
 		} else {
-			return nil, err
+
+			if record.ID > 0 {
+				//缓存数据
+				dialysis_prescribe_by_mode_str, err := json.Marshal(record)
+
+				if err == nil {
+					redis.Set(key, dialysis_prescribe_by_mode_str, time.Second*60*60*18)
+					return nil, err
+				}
+			} else {
+				redis.Set(key, " ", time.Second*60*60*18)
+				return nil, err
+			}
+			return &record, nil
 		}
+	} else { //缓存数据了数据，将redis缓存的json字符串转为map
+		json.Unmarshal([]byte(dialysis_prescribe_by_mode_id), &record)
+		return &record, nil
 	}
-	return &record, nil
 }
 
 //func MobileGetLastDialysisPrescribeByModeId(orgID int64, patientID int64, recordDate int64,mode_id int64) (*models.DialysisPrescription, error) {
 
 func GetPCHisPrescriptionProject(orgID int64, scheduleDate int64, deliverWay string, patientType int, adminUserId int64) ([]*HisMScheduleProjectVM, error) {
 	var vms []*HisMScheduleProjectVM
-	if patientType == 0 {
-		db := readDb.
-			Table("xt_schedule").
-			Preload("SchedualPatient", "status = 1 AND user_org_id = ?", orgID).
-			Preload("DialysisOrder", func(db *gorm.DB) *gorm.DB {
-				return db.Where("status = 1 AND user_org_id = ?", orgID).Preload("DeviceNumber", "status = 1 AND org_id= ?", orgID)
-			}).
-			Preload("DeviceNumber", "status = 1 AND org_id = ?", orgID).
-			Preload("DeviceNumber.Zone", "status = 1 AND org_id = ?", orgID).
-			Preload("Prescription", "status = 1 AND user_org_id = ? AND record_date = ?", orgID, scheduleDate).
-			Preload("HisPrescriptionProject", func(db *gorm.DB) *gorm.DB {
-				return db.Where("status = 1 AND user_org_id = ? AND record_date = ?", orgID, scheduleDate).Preload("HisProject").Preload("GoodInfo", "status=1")
-			}).Where("status = 1 AND user_org_id = ?", orgID)
-		if scheduleDate != 0 {
-			db = db.Where("schedule_date = ?", scheduleDate)
-		}
-		err = db.Find(&vms).Error
-	}
+	//if patientType == 0 {
+	//	db := readDb.
+	//		Table("xt_schedule").
+	//		Preload("SchedualPatient", "status = 1 AND user_org_id = ?", orgID).
+	//		Preload("DialysisOrder", func(db *gorm.DB) *gorm.DB {
+	//			return db.Where("status = 1 AND user_org_id = ?", orgID).Preload("DeviceNumber", "status = 1 AND org_id= ?", orgID)
+	//		}).
+	//		Preload("DeviceNumber", "status = 1 AND org_id = ?", orgID).
+	//		Preload("DeviceNumber.Zone", "status = 1 AND org_id = ?", orgID).
+	//		Preload("Prescription", "status = 1 AND user_org_id = ? AND record_date = ?", orgID, scheduleDate).
+	//		Preload("HisPrescriptionProject", func(db *gorm.DB) *gorm.DB {
+	//			return db.Where("status = 1 AND user_org_id = ? AND record_date = ?", orgID, scheduleDate).Preload("HisProject").Preload("GoodInfo", "status=1")
+	//		}).Where("status = 1 AND user_org_id = ?", orgID)
+	//	if scheduleDate != 0 {
+	//		db = db.Where("schedule_date = ?", scheduleDate)
+	//	}
+	//	err = db.Find(&vms).Error
+	//}
+	//
+	//if patientType > 0 {
+	//	db := readDb.
+	//		Table("xt_schedule").
+	//		Preload("SchedualPatient", "status = 1 AND user_org_id = ?", orgID).
+	//		Preload("DialysisOrder", func(db *gorm.DB) *gorm.DB {
+	//			return db.Where("status = 1 AND user_org_id = ?", orgID).Preload("DeviceNumber", "status = 1 AND org_id= ?", orgID)
+	//		}).
+	//		Preload("DeviceNumber", "status = 1 AND org_id = ?", orgID).
+	//		Preload("DeviceNumber.Zone", "status = 1 AND org_id = ?", orgID).
+	//		Preload("Prescription", "status = 1 AND user_org_id = ? AND record_date = ?", orgID, scheduleDate).
+	//		Preload("HisDoctorAdviceInfo", "status = 1 AND user_org_id = ? AND advice_date = ? and  (advice_doctor = ? or execution_staff = ?) ", orgID, scheduleDate, adminUserId, adminUserId).
+	//		Preload("HisPrescriptionProject", func(db *gorm.DB) *gorm.DB {
+	//			return db.Where("status = 1 AND user_org_id = ? AND record_date = ?", orgID, scheduleDate).Preload("HisProject").Preload("GoodInfo", "status=1")
+	//		}).
+	//		Where("status = 1 AND user_org_id = ?", orgID)
+	//	if scheduleDate != 0 {
+	//		db = db.Where("schedule_date = ?", scheduleDate)
+	//	}
+	//	err = db.Find(&vms).Error
+	//}
 
-	if patientType > 0 {
-		db := readDb.
-			Table("xt_schedule").
-			Preload("SchedualPatient", "status = 1 AND user_org_id = ?", orgID).
-			Preload("DialysisOrder", func(db *gorm.DB) *gorm.DB {
-				return db.Where("status = 1 AND user_org_id = ?", orgID).Preload("DeviceNumber", "status = 1 AND org_id= ?", orgID)
-			}).
-			Preload("DeviceNumber", "status = 1 AND org_id = ?", orgID).
-			Preload("DeviceNumber.Zone", "status = 1 AND org_id = ?", orgID).
-			Preload("Prescription", "status = 1 AND user_org_id = ? AND record_date = ?", orgID, scheduleDate).
-			Preload("HisDoctorAdviceInfo", "status = 1 AND user_org_id = ? AND advice_date = ? and  (advice_doctor = ? or execution_staff = ?) ", orgID, scheduleDate, adminUserId, adminUserId).
-			Preload("HisPrescriptionProject", func(db *gorm.DB) *gorm.DB {
-				return db.Where("status = 1 AND user_org_id = ? AND record_date = ?", orgID, scheduleDate).Preload("HisProject").Preload("GoodInfo", "status=1")
-			}).
-			Where("status = 1 AND user_org_id = ?", orgID)
-		if scheduleDate != 0 {
-			db = db.Where("schedule_date = ?", scheduleDate)
-		}
-		err = db.Find(&vms).Error
+	db := readDb.Table("xt_schedule").Where("status = 1")
+	if scheduleDate > 0 {
+		db = db.Where("schedule_date = ?", scheduleDate)
 	}
+	if orgID > 0 {
+		db = db.Where("user_org_id = ?", orgID)
+	}
+
+	err = db.Find(&vms).Error
 
 	return vms, err
 }

service/patient_service.go

 	defer redis.Close()
 	key := strconv.FormatInt(orgID, 10) + ":" + ":dialysis_orders_list_all"
 	dialysis_orders_list_all, _ := redis.Get(key).Result()
-
+	fmt.Println("hhhhhahdhaf3e2323323223", len(dialysis_orders_list_all))
 	if len(dialysis_orders_list_all) == 0 { //没有到缓存数据，从数据库中获取数据，进行缓存到redis
 		err = readDb.Model(&models.MDialysisOrderForList{}).Preload("DeviceNumber", "status = 1 AND org_id = ?", orgID).Where("status = 1 AND user_org_id = ? AND dialysis_date = ?", orgID, scheduleDate).Find(&dialysisOrders).Error
+		fmt.Println("err2332233232323232232323", err)
 		if err != nil {
 			if err == gorm.ErrRecordNotFound {
 				return nil, nil
 	redis := RedisClient()
 	defer redis.Close()
 	key := strconv.FormatInt(orgID, 10) + ":" + strconv.FormatInt(id, 10) + ":patient_info"
-	fmt.Println("keyw233223322332332233232323232323223233", key)
+
 	patient_info_str, _ := redis.Get(key).Result()
 
 	if len(patient_info_str) == 0 { //没有到缓存数据，从数据库中获取数据，进行缓存到redis
 			if patient.ID > 0 {
 				//缓存数据
 				patient_info_json, err := json.Marshal(&patient)
+
 				if err == nil {
 					redis.Set(key, patient_info_json, time.Second*60*60*18)
 				}
 
 func GetMonitorRecord(orgID int64, date int64, partition int64, patientId int64) ([]*models.NewVMMonitorDialysisSchedule, error) {
 	var mds []*models.NewVMMonitorDialysisSchedule
-
-	if patientId == 0 {
-		db := readDb.
-			Model(&models.NewVMMonitorDialysisSchedule{}).
-			Preload("DeviceNumber", "status = 1 AND org_id = ?", orgID).
-			Preload("DeviceZone", "status = 1 AND org_id = ?", orgID).
-			Preload("TreatmentMode", "status = 1").
-			Preload("Prescription", "status = 1 AND user_org_id = ? AND record_date = ?", orgID, date).
-			Preload("AssessmentBeforeDislysis", "status = 1 AND  user_org_id = ? AND assessment_date = ?", orgID, date).
-			Preload("AssessmentAfterDislysis", "status = 1 AND  user_org_id = ? AND assessment_date = ? ", orgID, date).
-			Preload("MonitoringRecord", "status = 1 AND  user_org_id = ? AND monitoring_date = ?", orgID, date).
-			Preload("DialysisOrder", "status = 1 AND user_org_id = ? AND dialysis_date = ?", orgID, date).
-			Preload("DialysisOrder.DeviceNumber", "status = 1 AND  org_id = ?", orgID).
-			Preload("MonitorPatients", "status = 1 AND user_org_id = ?", orgID).
-			Where("status = 1 AND user_org_id = ?", orgID)
-		if date != 0 {
-			db = db.Where("schedule_date = ? ", date)
-		}
-		if partition != 0 {
-			db = db.Where("partition_id = ? ", partition)
-		}
-		err := db.Find(&mds).Error
-		fmt.Println("err", err)
+	//
+	//if patientId == 0 {
+	//	db := readDb.
+	//		Model(&models.NewVMMonitorDialysisSchedule{}).
+	//		Preload("DeviceNumber", "status = 1 AND org_id = ?", orgID).
+	//		Preload("DeviceZone", "status = 1 AND org_id = ?", orgID).
+	//		Preload("TreatmentMode", "status = 1").
+	//		Preload("Prescription", "status = 1 AND user_org_id = ? AND record_date = ?", orgID, date).
+	//		Preload("AssessmentBeforeDislysis", "status = 1 AND  user_org_id = ? AND assessment_date = ?", orgID, date).
+	//		Preload("AssessmentAfterDislysis", "status = 1 AND  user_org_id = ? AND assessment_date = ? ", orgID, date).
+	//		Preload("MonitoringRecord", "status = 1 AND  user_org_id = ? AND monitoring_date = ?", orgID, date).
+	//		Preload("DialysisOrder", "status = 1 AND user_org_id = ? AND dialysis_date = ?", orgID, date).
+	//		Preload("DialysisOrder.DeviceNumber", "status = 1 AND  org_id = ?", orgID).
+	//		Preload("MonitorPatients", "status = 1 AND user_org_id = ?", orgID).
+	//		Where("status = 1 AND user_org_id = ?", orgID)
+	//	if date != 0 {
+	//		db = db.Where("schedule_date = ? ", date)
+	//	}
+	//	if partition != 0 {
+	//		db = db.Where("partition_id = ? ", partition)
+	//	}
+	//	err := db.Find(&mds).Error
+	//	fmt.Println("err", err)
+
+	//if patientId > 0 {
+	//	db := readDb.Table("xt_schedule as x").Where("x.status = 1")
+	//	db = db.
+	//		Preload("DeviceNumber", "status = 1 AND org_id = ?", orgID).
+	//		Preload("TreatmentMode", "status = 1").
+	//		Preload("Prescription", "status = 1 AND user_org_id = ? AND patient_id = ?", orgID, patientId).
+	//		Preload("AssessmentBeforeDislysis", "status = 1 AND  user_org_id = ? AND patient_id = ?", orgID, patientId).
+	//		Preload("AssessmentAfterDislysis", "status = 1 AND  user_org_id = ? AND patient_id = ? ", orgID, patientId).
+	//		Preload("MonitoringRecord", "status = 1 AND  user_org_id = ?  AND patient_id = ?", orgID, patientId).
+	//		Preload("DialysisOrder", "status = 1 AND user_org_id = ? AND patient_id = ?", orgID, patientId).
+	//		Preload("DialysisOrder.DeviceNumber", "status = 1 AND  org_id = ?", orgID).
+	//		Preload("MonitorPatients", "status = 1 AND user_org_id = ?", orgID).
+	//		Where("status = 1 AND user_org_id = ?", orgID)
+	//	if partition != 0 {
+	//		db = db.Where("partition_id = ? ", partition)
+	//	}
+	//
+	//	db = db.Where("schedule_date <= ? ", time.Now().Unix())
+	//
+	//	db = db.Where("patient_id = ?", patientId)
+	//	db = db.Order("schedule_date desc")
+	//	err := db.Find(&mds).Error
+	//	fmt.Println("err", err)
+	//}
+
+	db := readDb.Model(&models.NewVMMonitorDialysisSchedule{})
+	if date > 0 {
+		db = db.Where("schedule_date = ?", date)
+	}
+	if partition > 0 {
+		db = db.Where("partition_id = ?", partition)
 	}
-
 	if patientId > 0 {
-		db := readDb.Table("xt_schedule as x").Where("x.status = 1")
-		db = db.
-			Preload("DeviceNumber", "status = 1 AND org_id = ?", orgID).
-			Preload("TreatmentMode", "status = 1").
-			Preload("Prescription", "status = 1 AND user_org_id = ? AND patient_id = ?", orgID, patientId).
-			Preload("AssessmentBeforeDislysis", "status = 1 AND  user_org_id = ? AND patient_id = ?", orgID, patientId).
-			Preload("AssessmentAfterDislysis", "status = 1 AND  user_org_id = ? AND patient_id = ? ", orgID, patientId).
-			Preload("MonitoringRecord", "status = 1 AND  user_org_id = ?  AND patient_id = ?", orgID, patientId).
-			Preload("DialysisOrder", "status = 1 AND user_org_id = ? AND patient_id = ?", orgID, patientId).
-			Preload("DialysisOrder.DeviceNumber", "status = 1 AND  org_id = ?", orgID).
-			Preload("MonitorPatients", "status = 1 AND user_org_id = ?", orgID).
-			Where("status = 1 AND user_org_id = ?", orgID)
-		if partition != 0 {
-			db = db.Where("partition_id = ? ", partition)
-		}
-
-		db = db.Where("schedule_date <= ? ", time.Now().Unix())
 
 		db = db.Where("patient_id = ?", patientId)
-		db = db.Order("schedule_date desc")
-		err := db.Find(&mds).Error
-		fmt.Println("err", err)
 	}
 
+	err = db.Where("status = 1 and user_org_id = ?", orgID).Find(&mds).Error
+
 	return mds, err
 }
 
 	err := XTWriteDB().Model(models.PatientScheduleTemplateItem{}).Where("patient_id = ? and status = 1", id).Updates(map[string]interface{}{"status": 0}).Error
 	return err
 }
+
+func GetAllDeviceNumberByList(orgID int64) (number []*models.DeviceNumber, err error) {
+	redis := RedisClient()
+	defer redis.Close()
+	key := strconv.FormatInt(orgID, 10) + ":" + ":device_number_all"
+	number_info_str, _ := redis.Get(key).Result()
+	if len(number_info_str) == 0 { //没有到缓存数据，从数据库中获取数据，进行缓存到redis
+		err = readDb.Model(&models.DeviceNumber{}).Where("org_id=? and status=1", orgID).Find(&number).Error
+		if err != nil {
+			if err == gorm.ErrRecordNotFound {
+				return nil, nil
+			} else {
+				return nil, err
+			}
+		} else {
+			if len(number) > 0 {
+				//缓存数据
+				device_number_json, err := json.Marshal(&number)
+				if err == nil {
+					redis.Set(key, device_number_json, time.Second*60*60*18)
+				}
+			}
+			return number, nil
+		}
+	} else { //缓存数据了数据，将redis缓存的json字符串转为map
+		json.Unmarshal([]byte(number_info_str), &number)
+		return number, nil
+	}
+}
+
+func GetAllZoneByList(orgID int64) (zone []*models.DeviceZone, err error) {
+
+	redis := RedisClient()
+	defer redis.Close()
+	key := strconv.FormatInt(orgID, 10) + ":" + ":device_zone_all"
+	zone_info_str, _ := redis.Get(key).Result()
+	if len(zone_info_str) == 0 { //没有到缓存数据，从数据库中获取数据，进行缓存到redis
+		err = readDb.Model(&models.DeviceZone{}).Where("org_id=? and status=1", orgID).Find(&zone).Error
+		if err != nil {
+			if err == gorm.ErrRecordNotFound {
+				return nil, nil
+			} else {
+				return nil, err
+			}
+		} else {
+			if len(zone) > 0 {
+				//缓存数据
+				zone_number_json, err := json.Marshal(&zone)
+				if err == nil {
+					redis.Set(key, zone_number_json, time.Second*60*60*18)
+				}
+			}
+			return zone, nil
+		}
+	} else { //缓存数据了数据，将redis缓存的json字符串转为map
+		json.Unmarshal([]byte(zone_info_str), &zone)
+		return zone, nil
+	}
+}
+
+func GetAllPrescriptionByList(orgID int64, scheduleDate int64) (prescriptions []*models.VMDialysisPrescription, err error) {
+
+	redis := RedisClient()
+	defer redis.Close()
+	key := strconv.FormatInt(orgID, 10) + ":" + ":prescriptions_list_all"
+	prescriptions_list_all, _ := redis.Get(key).Result()
+
+	if len(prescriptions_list_all) == 0 { //没有到缓存数据，从数据库中获取数据，进行缓存到redis
+		err = readDb.Model(&models.VMDialysisPrescription{}).Where("status = 1 AND user_org_id = ? AND record_date = ?", orgID, scheduleDate).Find(&prescriptions).Error
+		if err != nil {
+			if err == gorm.ErrRecordNotFound {
+				return nil, nil
+			} else {
+				return nil, err
+			}
+		} else {
+			if len(prescriptions) > 0 {
+				//缓存数据
+				prescriptions_list_all, err := json.Marshal(&prescriptions)
+				if err == nil {
+					redis.Set(key, prescriptions_list_all, time.Second*60*60*18)
+				}
+			}
+			return prescriptions, nil
+		}
+	} else { //缓存数据了数据，将redis缓存的json字符串转为map
+		json.Unmarshal([]byte(prescriptions_list_all), &prescriptions)
+		return prescriptions, nil
+	}
+}
+
+func GetAllAssessmentBeforesByListOne(orgID int64, scheduleDate int64) (assessmentBefores []*models.VMPredialysisEvaluation, err error) {
+	redis := RedisClient()
+	defer redis.Close()
+	key := strconv.FormatInt(orgID, 10) + ":" + ":assessment_befores_list_all"
+	assessment_befores_list_all, _ := redis.Get(key).Result()
+
+	if len(assessment_befores_list_all) == 0 { //没有到缓存数据，从数据库中获取数据，进行缓存到redis
+		err = readDb.Model(&models.VMPredialysisEvaluation{}).Where("status = 1 AND user_org_id = ? AND assessment_date = ? ", orgID, scheduleDate).Find(&assessmentBefores).Error
+		if err != nil {
+			if err == gorm.ErrRecordNotFound {
+				return nil, nil
+			} else {
+				return nil, err
+			}
+		} else {
+			if len(assessmentBefores) > 0 {
+				//缓存数据
+				assessment_befores_list_all, err := json.Marshal(&assessmentBefores)
+				if err == nil {
+					redis.Set(key, assessment_befores_list_all, time.Second*60*60*18)
+				}
+			}
+			return assessmentBefores, nil
+		}
+	} else { //缓存数据了数据，将redis缓存的json字符串转为map
+		json.Unmarshal([]byte(assessment_befores_list_all), &assessmentBefores)
+		return assessmentBefores, nil
+	}
+}
+
+func GetAllDialysisOrdersByListOne(orgID int64, scheduleDate int64) (dialysisOrders []*models.VMMonitorDialysisOrder, err error) {
+	redis := RedisClient()
+	defer redis.Close()
+	key := strconv.FormatInt(orgID, 10) + ":" + ":dialysis_orders_list_all"
+	dialysis_orders_list_all, _ := redis.Get(key).Result()
+
+	if len(dialysis_orders_list_all) == 0 { //没有到缓存数据，从数据库中获取数据，进行缓存到redis
+		err = readDb.Model(&models.VMMonitorDialysisOrder{}).Preload("DeviceNumber", "status = 1 AND org_id = ?", orgID).Where("status = 1 AND user_org_id = ? AND dialysis_date = ?", orgID, scheduleDate).Find(&dialysisOrders).Error
+		if err != nil {
+			if err == gorm.ErrRecordNotFound {
+				return nil, nil
+			} else {
+				return nil, err
+			}
+		} else {
+			if len(dialysisOrders) > 0 {
+				//缓存数据
+				dialysis_orders_list_all, err := json.Marshal(&dialysisOrders)
+				if err == nil {
+					redis.Set(key, dialysis_orders_list_all, time.Second*60*60*18)
+				}
+			}
+			return dialysisOrders, nil
+		}
+	} else { //缓存数据了数据，将redis缓存的json字符串转为map
+		json.Unmarshal([]byte(dialysis_orders_list_all), &dialysisOrders)
+		return dialysisOrders, nil
+	}
+}
+
+func GetAllAssessmentAfterDislysisByListOne(orgID int64, scheduleDate int64) (assessmentAfterDislysis []*models.VMAssessmentAfterDislysis, err error) {
+	redis := RedisClient()
+	defer redis.Close()
+	key := strconv.FormatInt(orgID, 10) + ":" + ":assessment_after_dislysis_list_all"
+	assessment_after_dislysis__all, _ := redis.Get(key).Result()
+
+	if len(assessment_after_dislysis__all) == 0 { //没有到缓存数据，从数据库中获取数据，进行缓存到redis
+		err = readDb.Model(&models.VMAssessmentAfterDislysis{}).Where("status = 1  AND user_org_id = ? AND assessment_date = ?", orgID, scheduleDate).Find(&assessmentAfterDislysis).Error
+		if err != nil {
+			if err == gorm.ErrRecordNotFound {
+				return nil, nil
+			} else {
+				return nil, err
+			}
+		} else {
+			if len(assessmentAfterDislysis) > 0 {
+				//缓存数据
+				assessment_after_dislysis__all, err := json.Marshal(&assessmentAfterDislysis)
+				if err == nil {
+					redis.Set(key, assessment_after_dislysis__all, time.Second*60*60*18)
+				}
+			}
+			return assessmentAfterDislysis, nil
+		}
+	} else { //缓存数据了数据，将redis缓存的json字符串转为map
+		json.Unmarshal([]byte(assessment_after_dislysis__all), &assessmentAfterDislysis)
+		return assessmentAfterDislysis, nil
+	}
+}
+
+func GetAllMonitorList(orgID int64, scheduleDate int64) (monitor []*models.VMMonitoringRecord, err error) {
+
+	//db := XTReadDB().Model(&monitor).Where("status = 1")
+	//if orgID > 0 {
+	//  db = db.Where("user_org_id = ?", orgID)
+	//}
+	//if scheduleDate > 0 {
+	//  db = db.Where("monitoring_date = ?", scheduleDate)
+	//}
+	//
+	//err = db.Find(&monitor).Error
+	//return  monitor,err
+
+	redis := RedisClient()
+	defer redis.Close()
+	key := strconv.FormatInt(orgID, 10) + ":" + ":monitor_record_list_all"
+	monitor_record_list_all, _ := redis.Get(key).Result()
+
+	if len(monitor_record_list_all) == 0 { //没有到缓存数据，从数据库中获取数据，进行缓存到redis
+		err = readDb.Model(&models.VMMonitoringRecord{}).Where("status = 1  AND user_org_id = ? AND  monitoring_date= ?", orgID, scheduleDate).Find(&monitor).Error
+		if err != nil {
+			if err == gorm.ErrRecordNotFound {
+				return nil, nil
+			} else {
+				return nil, err
+			}
+		} else {
+			if len(monitor) > 0 {
+				//缓存数据
+				assessment_after_dislysis__all, err := json.Marshal(&monitor)
+				if err == nil {
+					redis.Set(key, assessment_after_dislysis__all, time.Second*60*60*18)
+				}
+			}
+			return monitor, nil
+		}
+	} else { //缓存数据了数据，将redis缓存的json字符串转为map
+		json.Unmarshal([]byte(monitor_record_list_all), &monitor)
+		return monitor, nil
+	}
+}
+
+func GetAllPatientListByListOne(orgID int64) (patients []*models.VMMonitorPatients, err error) {
+	redis := RedisClient()
+	defer redis.Close()
+	key := strconv.FormatInt(orgID, 10) + ":" + ":patient_list_all"
+	patient_info_str, _ := redis.Get(key).Result()
+
+	if len(patient_info_str) == 0 { //没有到缓存数据，从数据库中获取数据，进行缓存到redis
+		err = readDb.Model(&models.VMMonitorPatients{}).Where("user_org_id=? and status=1 and lapseto = 1", orgID).Find(&patients).Error
+		if err != nil {
+			if err == gorm.ErrRecordNotFound {
+				return nil, nil
+			} else {
+				return nil, err
+			}
+		} else {
+			if len(patients) > 0 {
+				//缓存数据
+				patient_info_json, err := json.Marshal(&patients)
+				if err == nil {
+					redis.Set(key, patient_info_json, time.Second*60*60*18)
+				}
+			}
+			return patients, nil
+		}
+	} else { //缓存数据了数据，将redis缓存的json字符串转为map
+		json.Unmarshal([]byte(patient_info_str), &patients)
+		return patients, nil
+	}
+}
+
+func GetAllTreatModeByList(orgID int64) (treatement []*models.TreatmentMode, err error) {
+	redis := RedisClient()
+	defer redis.Close()
+	key := strconv.FormatInt(orgID, 10) + ":" + ":treatement_mode_all"
+	treatment_info_str, _ := redis.Get(key).Result()
+
+	if len(treatment_info_str) == 0 { //没有到缓存数据，从数据库中获取数据，进行缓存到redis
+		err = readDb.Model(&models.TreatmentMode{}).Where("status=1").Find(&treatement).Error
+		if err != nil {
+			if err == gorm.ErrRecordNotFound {
+				return nil, nil
+			} else {
+				return nil, err
+			}
+		} else {
+			if len(treatement) > 0 {
+				//缓存数据
+				patient_info_json, err := json.Marshal(&treatement)
+				if err == nil {
+					redis.Set(key, patient_info_json, time.Second*60*60*18)
+				}
+			}
+			return treatement, nil
+		}
+	} else { //缓存数据了数据，将redis缓存的json字符串转为map
+		json.Unmarshal([]byte(treatment_info_str), &treatement)
+		return treatement, nil
+	}
+}
+
+func GetAllPatientListByListTwo(orgID int64) (patients []*MSchedualPatientVM, err error) {
+	redis := RedisClient()
+	defer redis.Close()
+	key := strconv.FormatInt(orgID, 10) + ":" + ":patient_list_all"
+	patient_info_str, _ := redis.Get(key).Result()
+
+	if len(patient_info_str) == 0 { //没有到缓存数据，从数据库中获取数据，进行缓存到redis
+		err = readDb.Model(&MSchedualPatientVM{}).Where("user_org_id=? and status=1 and lapseto = 1", orgID).Find(&patients).Error
+		if err != nil {
+			if err == gorm.ErrRecordNotFound {
+				return nil, nil
+			} else {
+				return nil, err
+			}
+		} else {
+			if len(patients) > 0 {
+				//缓存数据
+				patient_info_json, err := json.Marshal(&patients)
+				if err == nil {
+					redis.Set(key, patient_info_json, time.Second*60*60*18)
+				}
+			}
+			return patients, nil
+		}
+	} else { //缓存数据了数据，将redis缓存的json字符串转为map
+		json.Unmarshal([]byte(patient_info_str), &patients)
+		return patients, nil
+	}
+}
+
+func GetAllDeviceNumberByListOne(orgID int64) (number []*MDeviceNumberVM, err error) {
+	redis := RedisClient()
+	defer redis.Close()
+	key := strconv.FormatInt(orgID, 10) + ":" + ":device_number_all"
+	number_info_str, _ := redis.Get(key).Result()
+	if len(number_info_str) == 0 { //没有到缓存数据，从数据库中获取数据，进行缓存到redis
+		err = readDb.Model(&MDeviceNumberVM{}).Where("org_id=? and status=1", orgID).Find(&number).Error
+		if err != nil {
+			if err == gorm.ErrRecordNotFound {
+				return nil, nil
+			} else {
+				return nil, err
+			}
+		} else {
+			if len(number) > 0 {
+				//缓存数据
+				device_number_json, err := json.Marshal(&number)
+				if err == nil {
+					redis.Set(key, device_number_json, time.Second*60*60*18)
+				}
+			}
+			return number, nil
+		}
+	} else { //缓存数据了数据，将redis缓存的json字符串转为map
+		json.Unmarshal([]byte(number_info_str), &number)
+		return number, nil
+	}
+}
+
+func GetAllPrescriptionByListOne(orgID int64, scheduleDate int64) (prescriptions []*models.DialysisPrescriptionList, err error) {
+
+	redis := RedisClient()
+	defer redis.Close()
+	key := strconv.FormatInt(orgID, 10) + ":" + ":prescriptions_list_all"
+	prescriptions_list_all, _ := redis.Get(key).Result()
+
+	if len(prescriptions_list_all) == 0 { //没有到缓存数据，从数据库中获取数据，进行缓存到redis
+		err = readDb.Model(&models.DialysisPrescriptionList{}).Where("status = 1 AND user_org_id = ? AND record_date = ?", orgID, scheduleDate).Find(&prescriptions).Error
+		if err != nil {
+			if err == gorm.ErrRecordNotFound {
+				return nil, nil
+			} else {
+				return nil, err
+			}
+		} else {
+			if len(prescriptions) > 0 {
+				//缓存数据
+				prescriptions_list_all, err := json.Marshal(&prescriptions)
+				if err == nil {
+					redis.Set(key, prescriptions_list_all, time.Second*60*60*18)
+				}
+			}
+			return prescriptions, nil
+		}
+	} else { //缓存数据了数据，将redis缓存的json字符串转为map
+		json.Unmarshal([]byte(prescriptions_list_all), &prescriptions)
+		return prescriptions, nil
+	}
+}
+
+func GetAllDialysisOrdersByListTwo(orgID int64, scheduleDate int64) (dialysisOrders []*MDialysisOrderVM, err error) {
+	redis := RedisClient()
+	defer redis.Close()
+	key := strconv.FormatInt(orgID, 10) + ":" + ":dialysis_orders_list_all"
+	dialysis_orders_list_all, _ := redis.Get(key).Result()
+
+	if len(dialysis_orders_list_all) == 0 { //没有到缓存数据，从数据库中获取数据，进行缓存到redis
+		err = readDb.Model(&MDialysisOrderVM{}).Preload("DeviceNumber", "status = 1 AND org_id = ?", orgID).Where("status = 1 AND user_org_id = ? AND dialysis_date = ?", orgID, scheduleDate).Find(&dialysisOrders).Error
+		if err != nil {
+			if err == gorm.ErrRecordNotFound {
+				return nil, nil
+			} else {
+				return nil, err
+			}
+		} else {
+			if len(dialysisOrders) > 0 {
+				//缓存数据
+				dialysis_orders_list_all, err := json.Marshal(&dialysisOrders)
+				if err == nil {
+					redis.Set(key, dialysis_orders_list_all, time.Second*60*60*18)
+				}
+			}
+			return dialysisOrders, nil
+		}
+	} else { //缓存数据了数据，将redis缓存的json字符串转为map
+		json.Unmarshal([]byte(dialysis_orders_list_all), &dialysisOrders)
+		return dialysisOrders, nil
+	}
+}
+
+func GetAllPatientListByListThree(orgID int64) (patients []*models.MonitorPatients, err error) {
+	redis := RedisClient()
+	defer redis.Close()
+	key := strconv.FormatInt(orgID, 10) + ":" + ":patient_list_all"
+	patient_info_str, _ := redis.Get(key).Result()
+
+	if len(patient_info_str) == 0 { //没有到缓存数据，从数据库中获取数据，进行缓存到redis
+		err = readDb.Model(&models.MonitorPatients{}).Where("user_org_id=? and status=1 and lapseto = 1", orgID).Find(&patients).Error
+		if err != nil {
+			if err == gorm.ErrRecordNotFound {
+				return nil, nil
+			} else {
+				return nil, err
+			}
+		} else {
+			if len(patients) > 0 {
+				//缓存数据
+				patient_info_json, err := json.Marshal(&patients)
+				if err == nil {
+					redis.Set(key, patient_info_json, time.Second*60*60*18)
+				}
+			}
+			return patients, nil
+		}
+	} else { //缓存数据了数据，将redis缓存的json字符串转为map
+		json.Unmarshal([]byte(patient_info_str), &patients)
+		return patients, nil
+	}
+}
+
+func GetAllPrescriptionByListTwo(orgID int64, scheduleDate int64) (prescriptions []*models.DialysisPrescription, err error) {
+
+	redis := RedisClient()
+	defer redis.Close()
+	key := strconv.FormatInt(orgID, 10) + ":" + ":prescriptions_list_all"
+	prescriptions_list_all, _ := redis.Get(key).Result()
+
+	if len(prescriptions_list_all) == 0 { //没有到缓存数据，从数据库中获取数据，进行缓存到redis
+		err = readDb.Model(&models.DialysisPrescription{}).Where("status = 1 AND user_org_id = ? AND record_date = ?", orgID, scheduleDate).Find(&prescriptions).Error
+		if err != nil {
+			if err == gorm.ErrRecordNotFound {
+				return nil, nil
+			} else {
+				return nil, err
+			}
+		} else {
+			if len(prescriptions) > 0 {
+				//缓存数据
+				prescriptions_list_all, err := json.Marshal(&prescriptions)
+				if err == nil {
+					redis.Set(key, prescriptions_list_all, time.Second*60*60*18)
+				}
+			}
+			return prescriptions, nil
+		}
+	} else { //缓存数据了数据，将redis缓存的json字符串转为map
+		json.Unmarshal([]byte(prescriptions_list_all), &prescriptions)
+		return prescriptions, nil
+	}
+}
+
+func GetAllAssessmentBeforesByListThree(orgID int64, scheduleDate int64) (assessmentBefores []*models.PredialysisEvaluation, err error) {
+	redis := RedisClient()
+	defer redis.Close()
+	key := strconv.FormatInt(orgID, 10) + ":" + ":assessment_befores_list_all"
+	assessment_befores_list_all, _ := redis.Get(key).Result()
+
+	if len(assessment_befores_list_all) == 0 { //没有到缓存数据，从数据库中获取数据，进行缓存到redis
+		err = readDb.Model(&models.PredialysisEvaluation{}).Where("status = 1 AND user_org_id = ? AND assessment_date = ? ", orgID, scheduleDate).Find(&assessmentBefores).Error
+		if err != nil {
+			if err == gorm.ErrRecordNotFound {
+				return nil, nil
+			} else {
+				return nil, err
+			}
+		} else {
+			if len(assessmentBefores) > 0 {
+				//缓存数据
+				assessment_befores_list_all, err := json.Marshal(&assessmentBefores)
+				if err == nil {
+					redis.Set(key, assessment_befores_list_all, time.Second*60*60*18)
+				}
+			}
+			return assessmentBefores, nil
+		}
+	} else { //缓存数据了数据，将redis缓存的json字符串转为map
+		json.Unmarshal([]byte(assessment_befores_list_all), &assessmentBefores)
+		return assessmentBefores, nil
+	}
+}
+
+func GetAllDialysisOrdersByListThree(orgID int64, scheduleDate int64) (dialysisOrders []*models.MonitorDialysisOrder, err error) {
+	redis := RedisClient()
+	defer redis.Close()
+	key := strconv.FormatInt(orgID, 10) + ":" + ":dialysis_orders_list_all"
+	dialysis_orders_list_all, _ := redis.Get(key).Result()
+
+	if len(dialysis_orders_list_all) == 0 { //没有到缓存数据，从数据库中获取数据，进行缓存到redis
+		err = readDb.Model(&models.MonitorDialysisOrder{}).Preload("DeviceNumber", "status = 1 AND org_id = ?", orgID).Where("status = 1 AND user_org_id = ? AND dialysis_date = ?", orgID, scheduleDate).Find(&dialysisOrders).Error
+		if err != nil {
+			if err == gorm.ErrRecordNotFound {
+				return nil, nil
+			} else {
+				return nil, err
+			}
+		} else {
+			if len(dialysisOrders) > 0 {
+				//缓存数据
+				dialysis_orders_list_all, err := json.Marshal(&dialysisOrders)
+				if err == nil {
+					redis.Set(key, dialysis_orders_list_all, time.Second*60*60*18)
+				}
+			}
+			return dialysisOrders, nil
+		}
+	} else { //缓存数据了数据，将redis缓存的json字符串转为map
+		json.Unmarshal([]byte(dialysis_orders_list_all), &dialysisOrders)
+		return dialysisOrders, nil
+	}
+}
+
+func GetAllAssessmentAfterDislysisByListThree(orgID int64, scheduleDate int64) (assessmentAfterDislysis []*models.AssessmentAfterDislysis, err error) {
+	redis := RedisClient()
+	defer redis.Close()
+	key := strconv.FormatInt(orgID, 10) + ":" + ":assessment_after_dislysis_list_all"
+	assessment_after_dislysis__all, _ := redis.Get(key).Result()
+
+	if len(assessment_after_dislysis__all) == 0 { //没有到缓存数据，从数据库中获取数据，进行缓存到redis
+		err = readDb.Model(&models.AssessmentAfterDislysis{}).Where("status = 1  AND user_org_id = ? AND assessment_date = ?", orgID, scheduleDate).Find(&assessmentAfterDislysis).Error
+		if err != nil {
+			if err == gorm.ErrRecordNotFound {
+				return nil, nil
+			} else {
+				return nil, err
+			}
+		} else {
+			if len(assessmentAfterDislysis) > 0 {
+				//缓存数据
+				assessment_after_dislysis__all, err := json.Marshal(&assessmentAfterDislysis)
+				if err == nil {
+					redis.Set(key, assessment_after_dislysis__all, time.Second*60*60*18)
+				}
+			}
+			return assessmentAfterDislysis, nil
+		}
+	} else { //缓存数据了数据，将redis缓存的json字符串转为map
+		json.Unmarshal([]byte(assessment_after_dislysis__all), &assessmentAfterDislysis)
+		return assessmentAfterDislysis, nil
+	}
+}
+
+func GetAllMonitorListThree(orgID int64, scheduleDate int64) (monitor []*models.MonitoringRecord, err error) {
+
+	redis := RedisClient()
+	defer redis.Close()
+	key := strconv.FormatInt(orgID, 10) + ":" + ":monitor_record_list_all"
+	monitor_record_list_all, _ := redis.Get(key).Result()
+
+	if len(monitor_record_list_all) == 0 { //没有到缓存数据，从数据库中获取数据，进行缓存到redis
+		err = readDb.Model(&models.MonitoringRecord{}).Where("status = 1  AND user_org_id = ? AND  monitoring_date= ?", orgID, scheduleDate).Find(&monitor).Error
+		if err != nil {
+			if err == gorm.ErrRecordNotFound {
+				return nil, nil
+			} else {
+				return nil, err
+			}
+		} else {
+			if len(monitor) > 0 {
+				//缓存数据
+				assessment_after_dislysis__all, err := json.Marshal(&monitor)
+				if err == nil {
+					redis.Set(key, assessment_after_dislysis__all, time.Second*60*60*18)
+				}
+			}
+			return monitor, nil
+		}
+	} else { //缓存数据了数据，将redis缓存的json字符串转为map
+		json.Unmarshal([]byte(monitor_record_list_all), &monitor)
+		return monitor, nil
+	}
+}

service/patientmanage_service.go

 
 import (
 	"XT_New/models"
+	"encoding/json"
 	"fmt"
 	"github.com/jinzhu/gorm"
 	"strconv"
 	"strings"
 	"time"
-	"encoding/json"
 )
 
 func GetIllnessListTwo() (ills []*models.Illness, err error) {
 		err := XTReadDB().Model(&assessment).Where("user_org_id = ? and patient_id = ? and status =1 and user_status = 1", orgid, patientId).Order("start_time desc").Last(&assessment).Error
 		if err != nil {
 			if err == gorm.ErrRecordNotFound {
-				return assessment,nil
+				return assessment, nil
 			} else {
-				return assessment,err
+				return assessment, err
 			}
 		} else {
 			if assessment.ID > 0 {
 				pass_way_assessment_last_str, err := json.Marshal(assessment)
 				if err == nil {
 					redis.Set(key, pass_way_assessment_last_str, time.Second*60*60*18)
+					return assessment, nil
 				}
 			} else {
 				redis.Set(key, " ", time.Second*60*60*18)
+				return assessment, nil
 			}
-			return assessment,nil
+			return assessment, nil
 		}
 	} else { //缓存数据了数据，将redis缓存的json字符串转为map
 		json.Unmarshal([]byte(pass_way_assessment_last_str), &assessment)
-		return assessment,nil
+		return assessment, nil
 	}
 }
 

service/redis.go

 
 func RedisClient() *redis.Client {
 	address := fmt.Sprintf("%s:%s", beego.AppConfig.String("redishost"), beego.AppConfig.String("redisport"))
+	dbs, _ := beego.AppConfig.Int("redisdb")
 	client := redis.NewClient(&redis.Options{
 		Addr:     address,
 		Password: beego.AppConfig.String("redispasswrod"), // no password set
-		DB:       0,                                       // use default DB
+		DB:       dbs,                                     // use default DB
 	})
 	pong, err := client.Ping().Result()
 	fmt.Println(pong, err)