2024/6/17

controllers/dialysis_api_controller.go

 
 		err := service.AddSigleRecord(&prescription)
 
+		if adminUserInfo.CurrentOrgId == 10721 || adminUserInfo.CurrentOrgId == 10164 {
+
+			monitorList, _ := service.GetMobilePatientMonitor(prescription.PatientId, prescription.RecordDate, prescription.UserOrgId)
+
+			if len(monitorList) > 0 {
+				var ultrafiltration_rate float64
+				totalMin := prescription.DialysisDurationHour*60 + prescription.DialysisDurationMinute
+
+				ultrafiltration_rate = (math.Floor(prescription.PrescriptionWater * 1000 / float64(totalMin) * 60 * 1000)) / 1000
+				var replacement_rate float64
+
+				//乘10 除10是为了保留一位小数
+				replacement_rate = math.Floor(prescription.ReplacementTotal*1000/float64(totalMin)*10) / 10
+
+				var firstOpeateTime = monitorList[0].OperateTime
+				for _, item := range monitorList {
+					//超滤率
+					service.ModifyDialysisPatientMonitor(item.ID, ultrafiltration_rate)
+
+					//置换率
+					service.ModifyDialysisPatientReplascementRate(item.ID, replacement_rate)
+
+					//超滤量
+					ultrafiltration_volume := math.Floor(float64(item.OperateTime-firstOpeateTime)/3600) * ultrafiltration_rate
+					service.ModifyPatientUltrafiltrationVolume(item.ID, ultrafiltration_volume)
+
+					//置换量
+					displacement_quantity := (math.Floor(float64(item.OperateTime+3600-firstOpeateTime)/3600) * replacement_rate) * 60 / 1000
+
+					service.ModifyPatientDisplacementQuantity(item.ID, displacement_quantity)
+
+				}
+			}
+
+		}
 		//记录日志
 		byterequest, _ := json.Marshal(prescription)
 		dialysisPrescriptionLog := models.XtDialysisPrescriptionLog{
 
 		updateErr := service.UpDateDialysisPrescription(&prescription)
 
+		if adminUserInfo.CurrentOrgId == 10721 || adminUserInfo.CurrentOrgId == 10164 {
+
+			monitorList, _ := service.GetMobilePatientMonitor(prescription.PatientId, prescription.RecordDate, prescription.UserOrgId)
+
+			if len(monitorList) > 0 {
+				var ultrafiltration_rate float64
+				totalMin := prescription.DialysisDurationHour*60 + prescription.DialysisDurationMinute
+
+				ultrafiltration_rate = (math.Floor(prescription.PrescriptionWater * 1000 / float64(totalMin) * 60 * 1000)) / 1000
+				var replacement_rate float64
+
+				//乘10 除10是为了保留一位小数
+				replacement_rate = math.Floor(prescription.ReplacementTotal*1000/float64(totalMin)*10) / 10
+
+				var firstOpeateTime = monitorList[0].OperateTime
+				for _, item := range monitorList {
+					//超滤率
+					service.ModifyDialysisPatientMonitor(item.ID, ultrafiltration_rate)
+
+					//置换率
+					service.ModifyDialysisPatientReplascementRate(item.ID, replacement_rate)
+
+					//超滤量
+					ultrafiltration_volume := math.Floor(float64(item.OperateTime-firstOpeateTime)/3600) * ultrafiltration_rate
+					service.ModifyPatientUltrafiltrationVolume(item.ID, ultrafiltration_volume)
+
+					//置换量
+					displacement_quantity := (math.Floor(float64(item.OperateTime+3600-firstOpeateTime)/3600) * replacement_rate) * 60 / 1000
+
+					service.ModifyPatientDisplacementQuantity(item.ID, displacement_quantity)
+
+				}
+			}
+
+		}
+
 		//记录日志
 		byterequest, _ := json.Marshal(prescription)
 		dialysisPrescriptionLog := models.XtDialysisPrescriptionLog{
 
 	err := service.SavePrescriptionAndCreateSolution(&solution, &prescription)
 
+	if adminUserInfo.CurrentOrgId == 10721 || adminUserInfo.CurrentOrgId == 10164 {
+
+		monitorList, _ := service.GetMobilePatientMonitor(prescription.PatientId, prescription.RecordDate, prescription.UserOrgId)
+
+		if len(monitorList) > 0 {
+			var ultrafiltration_rate float64
+			totalMin := prescription.DialysisDurationHour*60 + prescription.DialysisDurationMinute
+
+			ultrafiltration_rate = (math.Floor(prescription.PrescriptionWater * 1000 / float64(totalMin) * 60 * 1000)) / 1000
+			var replacement_rate float64
+
+			//乘10 除10是为了保留一位小数
+			replacement_rate = math.Floor(prescription.ReplacementTotal*1000/float64(totalMin)*10) / 10
+
+			var firstOpeateTime = monitorList[0].OperateTime
+			for _, item := range monitorList {
+				//超滤率
+				service.ModifyDialysisPatientMonitor(item.ID, ultrafiltration_rate)
+
+				//置换率
+				service.ModifyDialysisPatientReplascementRate(item.ID, replacement_rate)
+
+				//超滤量
+				ultrafiltration_volume := math.Floor(float64(item.OperateTime-firstOpeateTime)/3600) * ultrafiltration_rate
+				service.ModifyPatientUltrafiltrationVolume(item.ID, ultrafiltration_volume)
+
+				//置换量
+				displacement_quantity := (math.Floor(float64(item.OperateTime+3600-firstOpeateTime)/3600) * replacement_rate) * 60 / 1000
+
+				service.ModifyPatientDisplacementQuantity(item.ID, displacement_quantity)
+
+			}
+		}
+
+	}
 	//记录日志
 	byterequest, _ := json.Marshal(prescription)
 	dialysisPrescriptionLog := models.XtDialysisPrescriptionLog{
 				}
 			}
 
+			if adminUserInfo.CurrentOrgId == 10721 || adminUserInfo.CurrentOrgId == 10164 {
+
+				prescription, _ := service.GetTodayPrescription(patient, adminUserInfo.CurrentOrgId, recordDate.Unix())
+
+				monitorList, _ := service.GetMobilePatientMonitor(prescription.PatientId, prescription.RecordDate, prescription.UserOrgId)
+
+				if len(monitorList) > 0 {
+					var ultrafiltration_rate float64
+					totalMin := prescription.DialysisDurationHour*60 + prescription.DialysisDurationMinute
+
+					ultrafiltration_rate = (math.Floor(prescription.PrescriptionWater * 1000 / float64(totalMin) * 60 * 1000)) / 1000
+					var replacement_rate float64
+
+					//乘10 除10是为了保留一位小数
+					replacement_rate = math.Floor(prescription.ReplacementTotal*1000/float64(totalMin)*10) / 10
+
+					var firstOpeateTime = monitorList[0].OperateTime
+					for _, item := range monitorList {
+						//超滤率
+						service.ModifyDialysisPatientMonitor(item.ID, ultrafiltration_rate)
+
+						//置换率
+						service.ModifyDialysisPatientReplascementRate(item.ID, replacement_rate)
+
+						//超滤量
+						ultrafiltration_volume := math.Floor(float64(item.OperateTime-firstOpeateTime)/3600) * ultrafiltration_rate
+						service.ModifyPatientUltrafiltrationVolume(item.ID, ultrafiltration_volume)
+
+						//置换量
+						displacement_quantity := (math.Floor(float64(item.OperateTime+3600-firstOpeateTime)/3600) * replacement_rate) * 60 / 1000
+
+						service.ModifyPatientDisplacementQuantity(item.ID, displacement_quantity)
+
+					}
+				}
+
+			}
+
 		}
 
 		key := strconv.FormatInt(adminUserInfo.CurrentOrgId, 10) + ":" + strconv.FormatInt(patient, 10) + ":" + strconv.FormatInt(recordDate.Unix(), 10) + ":assessment_before_dislysis"
 
 		}
 
+		if adminUserInfo.CurrentOrgId == 10721 || adminUserInfo.CurrentOrgId == 10164 {
+
+			prescription, _ := service.GetTodayPrescription(patient, adminUserInfo.CurrentOrgId, recordDate.Unix())
+
+			monitorList, _ := service.GetMobilePatientMonitor(prescription.PatientId, prescription.RecordDate, prescription.UserOrgId)
+
+			if len(monitorList) > 0 {
+				var ultrafiltration_rate float64
+				totalMin := prescription.DialysisDurationHour*60 + prescription.DialysisDurationMinute
+
+				ultrafiltration_rate = (math.Floor(prescription.PrescriptionWater * 1000 / float64(totalMin) * 60 * 1000)) / 1000
+				var replacement_rate float64
+
+				//乘10 除10是为了保留一位小数
+				replacement_rate = math.Floor(prescription.ReplacementTotal*1000/float64(totalMin)*10) / 10
+
+				var firstOpeateTime = monitorList[0].OperateTime
+				for _, item := range monitorList {
+					//超滤率
+					service.ModifyDialysisPatientMonitor(item.ID, ultrafiltration_rate)
+
+					//置换率
+					service.ModifyDialysisPatientReplascementRate(item.ID, replacement_rate)
+
+					//超滤量
+					ultrafiltration_volume := math.Floor(float64(item.OperateTime-firstOpeateTime)/3600) * ultrafiltration_rate
+					service.ModifyPatientUltrafiltrationVolume(item.ID, ultrafiltration_volume)
+
+					//置换量
+					displacement_quantity := (math.Floor(float64(item.OperateTime+3600-firstOpeateTime)/3600) * replacement_rate) * 60 / 1000
+
+					service.ModifyPatientDisplacementQuantity(item.ID, displacement_quantity)
+
+				}
+			}
+
+		}
+
 		err := service.UpadatePredialysisEvaluation(&assessmentBeforeDislysis)
 
 		//创建步骤表

controllers/mobile_api_controllers/dialysis_api_controller.go

 		}
 		err := service.AddSigleRecord(&prescription)
 
+		//溪康 更改目标超滤量 同步监测里面的超滤量 超滤率 置换量 置换率
+		if adminUserInfo.Org.Id == 10721 || adminUserInfo.Org.Id == 10164 {
+
+			monitorList, _ := service.GetMobilePatientMonitor(prescription.PatientId, prescription.RecordDate, prescription.UserOrgId)
+
+			if len(monitorList) > 0 {
+				var ultrafiltration_rate float64
+				totalMin := prescription.DialysisDurationHour*60 + prescription.DialysisDurationMinute
+
+				ultrafiltration_rate = (math.Floor(prescription.PrescriptionWater * 1000 / float64(totalMin) * 60 * 1000)) / 1000
+				var replacement_rate float64
+
+				//乘10 除10是为了保留一位小数
+				replacement_rate = math.Floor(prescription.ReplacementTotal*1000/float64(totalMin)*10) / 10
+
+				var firstOpeateTime = monitorList[0].OperateTime
+				for _, item := range monitorList {
+					//超滤率
+					service.ModifyDialysisPatientMonitor(item.ID, ultrafiltration_rate)
+
+					//置换率
+					service.ModifyDialysisPatientReplascementRate(item.ID, replacement_rate)
+
+					//超滤量
+					ultrafiltration_volume := math.Floor(float64(item.OperateTime-firstOpeateTime)/3600) * ultrafiltration_rate
+					service.ModifyPatientUltrafiltrationVolume(item.ID, ultrafiltration_volume)
+
+					//置换量
+					displacement_quantity := (math.Floor(float64(item.OperateTime+3600-firstOpeateTime)/3600) * replacement_rate) * 60 / 1000
+
+					service.ModifyPatientDisplacementQuantity(item.ID, displacement_quantity)
+
+				}
+			}
+
+		}
 		//记录日志
 		byterequest, _ := json.Marshal(prescription)
 		prescriptionLog := models.XtDialysisPrescriptionLog{
 
 		service.UpDateDialysisPrescription(&prescription)
 
+		//溪康 更改目标超滤量 同步监测里面的超滤量 超滤率 置换量 置换率
+		if adminUserInfo.Org.Id == 10721 || adminUserInfo.Org.Id == 10164 {
+
+			monitorList, _ := service.GetMobilePatientMonitor(prescription.PatientId, prescription.RecordDate, prescription.UserOrgId)
+
+			if len(monitorList) > 0 {
+				var ultrafiltration_rate float64
+				totalMin := prescription.DialysisDurationHour*60 + prescription.DialysisDurationMinute
+
+				ultrafiltration_rate = (math.Floor(prescription.PrescriptionWater * 1000 / float64(totalMin) * 60 * 1000)) / 1000
+				var replacement_rate float64
+
+				//乘10 除10是为了保留一位小数
+				replacement_rate = math.Floor(prescription.ReplacementTotal*1000/float64(totalMin)*10) / 10
+
+				var firstOpeateTime = monitorList[0].OperateTime
+				for _, item := range monitorList {
+					//超滤率
+					service.ModifyDialysisPatientMonitor(item.ID, ultrafiltration_rate)
+
+					//置换率
+					service.ModifyDialysisPatientReplascementRate(item.ID, replacement_rate)
+
+					//超滤量
+					ultrafiltration_volume := math.Floor(float64(item.OperateTime-firstOpeateTime)/3600) * ultrafiltration_rate
+					service.ModifyPatientUltrafiltrationVolume(item.ID, ultrafiltration_volume)
+
+					//置换量
+					displacement_quantity := (math.Floor(float64(item.OperateTime+3600-firstOpeateTime)/3600) * replacement_rate) * 60 / 1000
+
+					service.ModifyPatientDisplacementQuantity(item.ID, displacement_quantity)
+
+				}
+			}
+
+		}
+
 		//记录日志
 		byterequest, _ := json.Marshal(prescription)
 		prescriptionLog := models.XtDialysisPrescriptionLog{
 	}
 
 	service.SavePrescriptionAndCreateSolution(&solution, &prescription)
+
+	if adminUserInfo.Org.Id == 10721 || adminUserInfo.Org.Id == 10164 {
+
+		monitorList, _ := service.GetMobilePatientMonitor(prescription.PatientId, prescription.RecordDate, prescription.UserOrgId)
+
+		if len(monitorList) > 0 {
+			var ultrafiltration_rate float64
+			totalMin := prescription.DialysisDurationHour*60 + prescription.DialysisDurationMinute
+
+			ultrafiltration_rate = (math.Floor(prescription.PrescriptionWater * 1000 / float64(totalMin) * 60 * 1000)) / 1000
+			var replacement_rate float64
+
+			//乘10 除10是为了保留一位小数
+			replacement_rate = math.Floor(prescription.ReplacementTotal*1000/float64(totalMin)*10) / 10
+
+			var firstOpeateTime = monitorList[0].OperateTime
+			for _, item := range monitorList {
+				//超滤率
+				service.ModifyDialysisPatientMonitor(item.ID, ultrafiltration_rate)
+
+				//置换率
+				service.ModifyDialysisPatientReplascementRate(item.ID, replacement_rate)
+
+				//超滤量
+				ultrafiltration_volume := math.Floor(float64(item.OperateTime-firstOpeateTime)/3600) * ultrafiltration_rate
+				service.ModifyPatientUltrafiltrationVolume(item.ID, ultrafiltration_volume)
+
+				//置换量
+				displacement_quantity := (math.Floor(float64(item.OperateTime+3600-firstOpeateTime)/3600) * replacement_rate) * 60 / 1000
+				fmt.Println("displacement_quantity----------------------", displacement_quantity)
+				service.ModifyPatientDisplacementQuantity(item.ID, displacement_quantity)
+
+			}
+		}
+
+	}
+
 	//记录日志
 	byterequest, _ := json.Marshal(prescription)
 	prescriptionLog := models.XtDialysisPrescriptionLog{
 		record.UltrafiltrationVolume = 0
 	}
 
-	if adminInfo.Org.Id == 10721 {
+	if adminInfo.Org.Id == 10721 || adminInfo.Org.Id == 10164 {
 		if ultrafiltration_rate > 0 {
 			ultrafiltration_volume := math.Floor(float64(record.OperateTime+3600-fristrecord.OperateTime) / 3600 * ultrafiltration_rate)
 			record.UltrafiltrationVolume = ultrafiltration_volume / 1000
 		var displacement_quantity float64
 		totalMin := prescription.DialysisDurationHour*60 + prescription.DialysisDurationMinute
 		replacement_rate = math.Floor(prescription.ReplacementTotal*1000/float64(totalMin)*60) / 1000
-		fmt.Println("replacement_rate-----------------", replacement_rate)
+
+		fmt.Println("replacement_rate--------------------------", replacement_rate)
 		record.ReplacementRate = replacement_rate
 
 		fmt.Println(math.Floor(float64(record.OperateTime+3600-fristrecord.OperateTime) / 3600))
 		displacement_quantity = math.Floor(float64(record.OperateTime+3600-fristrecord.OperateTime)/3600) * replacement_rate
-		fmt.Println("displacement_quantity-----------------", displacement_quantity)
 		record.DisplacementQuantity = displacement_quantity
 
 	}

controllers/mobile_api_controllers/patient_api_controller.go

 	}
 
 	//针对孝昌康桥超滤率计算问题
-	if adminUserInfo.Org.Id == 10702 || adminUserInfo.Org.Id == 10635 || adminUserInfo.Org.Id == 10721 || adminUserInfo.Org.Id == 10726 {
+	if adminUserInfo.Org.Id == 10702 || adminUserInfo.Org.Id == 10635 || adminUserInfo.Org.Id == 10721 || adminUserInfo.Org.Id == 10726 || adminUserInfo.Org.Id == 10164 {
 		if evaluation.ID == 0 {
 			dialysisPrescribeOne, _ := service.MobileGetDialysisPrescribeOne(adminUserInfo.Org.Id, id, theAssessmentDateTime)
 			if dialysisPrescribeOne.ID > 0 && evaluation.ID > 0 {
 
 	}
 
+	if adminUserInfo.Org.Id == 10721 || adminUserInfo.Org.Id == 10164 {
+
+		prescription, _ := service.GetTodayPrescription(id, adminUserInfo.Org.Id, theAssessmentDateTime)
+
+		if prescription.ID > 0 {
+
+			monitorList, _ := service.GetMobilePatientMonitor(prescription.PatientId, prescription.RecordDate, prescription.UserOrgId)
+
+			if len(monitorList) > 0 {
+				var ultrafiltration_rate float64
+				totalMin := prescription.DialysisDurationHour*60 + prescription.DialysisDurationMinute
+
+				ultrafiltration_rate = (math.Floor(prescription.PrescriptionWater * 1000 / float64(totalMin) * 60 * 1000)) / 1000
+				var replacement_rate float64
+
+				//乘10 除10是为了保留一位小数
+				replacement_rate = math.Floor(prescription.ReplacementTotal*1000/float64(totalMin)*10) / 10
+
+				var firstOpeateTime = monitorList[0].OperateTime
+				for _, item := range monitorList {
+					//超滤率
+					service.ModifyDialysisPatientMonitor(item.ID, ultrafiltration_rate)
+
+					//置换率
+					service.ModifyDialysisPatientReplascementRate(item.ID, replacement_rate)
+
+					//超滤量
+					ultrafiltration_volume := math.Floor(float64(item.OperateTime-firstOpeateTime)/3600) * ultrafiltration_rate
+					service.ModifyPatientUltrafiltrationVolume(item.ID, ultrafiltration_volume)
+
+					//置换量
+					displacement_quantity := (math.Floor(float64(item.OperateTime+3600-firstOpeateTime)/3600) * replacement_rate) * 60 / 1000
+
+					service.ModifyPatientDisplacementQuantity(item.ID, displacement_quantity)
+
+				}
+			}
+
+		}
+
+	}
+
 	err = service.UpadatePredialysisEvaluation(&evaluation)
 
 	//记录日志

controllers/new_mobile_api_controllers/new_dialysis_api_controller.go

 	remark := dataBody["remark"].(string)
 
 	treatment_plan := dataBody["treatment_plan"].(string)
+
+	patient_type_one := int64(dataBody["patient_type"].(float64))
+
+	fmt.Println("patient_type_one444444444444444444444444", patient_type_one)
 	//查询身份证号码是否存在
 	thisPatientOne, _ := service.FindPatientByIdCardNoFive(orgid, idCard)
 	if thisPatientOne.ID > 0 {
 		this.ServeSuccessJSON(returnData)
 		return
 	}
+	if patient_type_one == 1 || patient_type_one == 4 || patient_type_one == 5 || patient_type_one == 6 || patient_type_one == 0 {
+		bloodPatient = 1
+	}
+	if patient_type_one == 2 {
+		slowpatient = 1
+	}
+	if patient_type_one == 3 {
+		memberpatient = 1
+	}
+
 	//如果是血透病人
 	if bloodPatient == 1 {
 		//查询透析号是否存在
 			Remark:            "",
 			SchRemark:         remark,
 			TreatmentPlan:     treatment_plan,
+			PatientType:       patient_type_one,
+		}
+		if patient_type == 0 {
+			patients.PatientType = 1
 		}
 		patients.FirstLetter = firstLetter
 		err = service.CreateOldPatient(&patients)
 		err = service.AddContagions(patient.ID, patient.CreatedTime, patient.UpdatedTime, ids)
 		fmt.Println("添加传染病失败", err)
 
+		record := models.XtPatientLaspseRecord{
+			PatientId:     patients.ID,
+			RecordDate:    time.Now().Unix(),
+			LapseDate:     time.Now().Unix(),
+			LapseType:     1,
+			LapseClass:    0,
+			LapseReason:   "",
+			AdminUserId:   adminInfo.AdminUser.Id,
+			Remark:        "",
+			UserOrgId:     orgid,
+			Ctime:         time.Now().Unix(),
+			Mtime:         time.Now().Unix(),
+			Status:        1,
+			LapseTypeName: "转入",
+			HisType:       0,
+			HisZone:       "",
+			HisBed:        "",
+		}
+		service.CreatePatientRecord(record)
+
 		patientsNew := models.XtPatientsNew{
 			Name:              name,
 			Gender:            sex,
 			Remark:            "",
 			SchRemark:         remark,
 			TreatmentPlan:     treatment_plan,
+			PatientType:       patient_type_one,
+		}
+		if patient_type == 0 {
+			patientsNew.PatientType = 1
 		}
 		patientsNew.FirstLetter = firstLetter
 		err = service.CreateNewPatient(&patientsNew)
 func (this *NewDialysisApiController) DeleteManageMentTwo() {
 	groupno, _ := this.GetInt64("id")
 	patientid, _ := this.GetInt64("patientid")
-	fmt.Println("patientid------------------------------------", patientid)
+
 	orgId := this.GetMobileAdminUserInfo().Org.Id
 	err := service.DeleteManagement(groupno, orgId, patientid)
 	fmt.Println("错误是什么", err)
 	remark := dataBody["remark"].(string)
 
 	treatment_plan := dataBody["treatment_plan"].(string)
+
+	patient_type_one := int64(dataBody["patient_type"].(float64))
 	fmt.Print(fisttime)
+
+	if patient_type_one == 1 || patient_type_one == 4 || patient_type_one == 5 || patient_type_one == 6 || patient_type_one == 0 {
+		bloodPatient = 1
+	}
+	if patient_type_one == 2 {
+		slowpatient = 1
+	}
+	if patient_type_one == 3 {
+		memberpatient = 1
+	}
 	//如果是血透病人
 	if bloodPatient == 1 {
 		//根据新表ID获取老表病人ID
 			RelativePhone:     relative_phone,
 			SchRemark:         remark,
 			TreatmentPlan:     treatment_plan,
+			PatientType:       patient_type_one,
 		}
 		err = service.UpdatedPatient(patients, patient.BloodId)
 		key := strconv.FormatInt(orgid, 10) + ":" + strconv.FormatInt(patient.BloodId, 10) + ":patient_info"
 			RelativePhone:     relative_phone,
 			SchRemark:         remark,
 			TreatmentPlan:     treatment_plan,
+			PatientType:       patient_type_one,
 		}
 		err = service.UpdateXtPatientNew(patientsNew, id)
 		if err != nil {
 			Remark:            "",
 			SchRemark:         remark,
 			TreatmentPlan:     treatment_plan,
+			PatientType:       patient_type_one,
 		}
 		err = service.UpdateXtPatientNew(xtPatientsNew, id)
 		fmt.Print("更新失败", err)
 			Remark:            "",
 			SchRemark:         remark,
 			TreatmentPlan:     treatment_plan,
+			PatientType:       patient_type,
 		}
 		err = service.UpdateXtPatientNewOne(patientsNew, id)
 		if err != nil {

controllers/patient_api_controller.go

 		LapseReason:   "",
 		AdminUserId:   creater,
 		Remark:        "",
-		UserOrgId:     0,
+		UserOrgId:     adminUserInfo.CurrentOrgId,
 		Ctime:         time.Now().Unix(),
 		Mtime:         time.Now().Unix(),
 		Status:        1,

service/dialysis_service.go

 	tx.Commit()
 	return
 }
+
+func GetTodayPrescription(patient_id int64, user_org_id int64, record_date int64) (models.DialysisPrescription, error) {
+
+	prescription := models.DialysisPrescription{}
+
+	err := XTReadDB().Where("patient_id = ? and user_org_id = ? and record_date =? and status=1", patient_id, user_org_id, record_date).Find(&prescription).Error
+
+	return prescription, err
+}
+
+func GetMobilePatientMonitor(patient_id int64, record_date int64, user_org_id int64) (monitor []*models.MonitoringRecord, err error) {
+
+	err = XTReadDB().Where("patient_id = ? and monitoring_date = ? and user_org_id =? and status=1", patient_id, record_date, user_org_id).Order("operate_time asc").Find(&monitor).Error
+
+	return monitor, err
+}
+
+func ModifyDialysisPatientMonitor(id int64, ultrafiltration_rate float64) error {
+
+	err := XTWriteDB().Model(&models.MonitoringRecord{}).Where("id =? and status=1", id).Updates(map[string]interface{}{"ultrafiltration_rate": ultrafiltration_rate}).Error
+
+	return err
+}
+
+func ModifyDialysisPatientReplascementRate(id int64, replacement_rate float64) error {
+
+	err := XTWriteDB().Model(&models.MonitoringRecord{}).Where("id =? and status=1", id).Updates(map[string]interface{}{"replacement_rate": replacement_rate}).Error
+
+	return err
+}
+
+func ModifyPatientUltrafiltrationVolume(id int64, ultrafiltration_volume float64) error {
+
+	err := XTWriteDB().Model(&models.MonitoringRecord{}).Where("id =? and status=1", id).Updates(map[string]interface{}{"ultrafiltration_volume": ultrafiltration_volume}).Error
+
+	return err
+}
+
+func ModifyPatientDisplacementQuantity(id int64, displacement_quantity float64) error {
+
+	err := XTWriteDB().Model(&models.MonitoringRecord{}).Where("id = ? and status=1", id).Updates(map[string]interface{}{"displacement_quantity": displacement_quantity}).Error
+	return err
+}

service/patientmanage_service.go

 
 func UpdatedPatient(patients models.Patients, id int64) error {
 
-	err := XTWriteDB().Model(&patients).Where("id=?", id).Update(map[string]interface{}{"name": patients.Name, "gender": patients.Gender, "birthday": patients.Birthday, "age": patients.Age, "phone": patients.Phone, "lapseto": patients.Lapseto, "admission_number": patients.AdmissionNumber, "first_dialysis_date": patients.FirstDialysisDate, "diagnose": patients.Diagnose, "source": patients.Source, "dialysis_no": patients.DialysisNo, "avatar": patients.Avatar, "id_card_no": patients.IdCardNo, "is_infectious": patients.IsInfectious, "out_reason": patients.OutReason, "death_time": patients.DeathTime, "relative_phone": patients.RelativePhone, "sch_remark": patients.SchRemark, "treatment_plan": patients.TreatmentPlan}).Error
+	err := XTWriteDB().Model(&patients).Where("id=?", id).Update(map[string]interface{}{"name": patients.Name, "gender": patients.Gender, "birthday": patients.Birthday, "age": patients.Age, "phone": patients.Phone, "lapseto": patients.Lapseto, "admission_number": patients.AdmissionNumber, "first_dialysis_date": patients.FirstDialysisDate, "diagnose": patients.Diagnose, "source": patients.Source, "dialysis_no": patients.DialysisNo, "avatar": patients.Avatar, "id_card_no": patients.IdCardNo, "is_infectious": patients.IsInfectious, "out_reason": patients.OutReason, "death_time": patients.DeathTime, "relative_phone": patients.RelativePhone, "sch_remark": patients.SchRemark, "treatment_plan": patients.TreatmentPlan, "patient_type": patients.PatientType}).Error
 
 	return err
 }
 
 func UpdateXtPatientNew(patients models.XtPatientsNew, id int64) error {
 
-	err := XTWriteDB().Model(&patients).Where("id=?", id).Update(map[string]interface{}{"name": patients.Name, "gender": patients.Gender, "birthday": patients.Birthday, "age": patients.Age, "phone": patients.Phone, "lapseto": patients.Lapseto, "admission_number": patients.AdmissionNumber, "first_dialysis_date": patients.FirstDialysisDate, "diagnose": patients.Diagnose, "source": patients.Source, "dialysis_no": patients.DialysisNo, "avatar": patients.Avatar, "id_card_no": patients.IdCardNo, "is_infectious": patients.IsInfectious, "out_reason": patients.OutReason, "death_time": patients.DeathTime, "relative_phone": patients.RelativePhone, "sch_remark": patients.SchRemark, "treatment_plan": patients.TreatmentPlan}).Error
+	err := XTWriteDB().Model(&patients).Where("id=?", id).Update(map[string]interface{}{"name": patients.Name, "gender": patients.Gender, "birthday": patients.Birthday, "age": patients.Age, "phone": patients.Phone, "lapseto": patients.Lapseto, "admission_number": patients.AdmissionNumber, "first_dialysis_date": patients.FirstDialysisDate, "diagnose": patients.Diagnose, "source": patients.Source, "dialysis_no": patients.DialysisNo, "avatar": patients.Avatar, "id_card_no": patients.IdCardNo, "is_infectious": patients.IsInfectious, "out_reason": patients.OutReason, "death_time": patients.DeathTime, "relative_phone": patients.RelativePhone, "sch_remark": patients.SchRemark, "treatment_plan": patients.TreatmentPlan, "patient_type": patients.PatientType}).Error
 
 	return err
 }