更新代码

conf/app.conf

@@ -152,6 +152,20 @@ writemiddleuser = root
 writemiddlepass = 1Q2W3e4r!@#$
 writemiddlename = ky_xt_middle
 
+
+
+readpatienthost = rm-wz9rg531npf61q03tro.mysql.rds.aliyuncs.com
+readpatientport = 3306
+readpatientuser = root
+readpatientpass = 1Q2W3e4r!@#$
+readpatientname = sgj_cdm
+
+writepatienthost = rm-wz9rg531npf61q03tro.mysql.rds.aliyuncs.com
+writepatientport = 3306
+writepatientuser = root
+writepatientpass = 1Q2W3e4r!@#$
+writepatientname = sgj_cdm
+
 #redishost = 120.77.235.13
 #redishost = 112.74.16.180
 redishost = localhost

controllers/new_mobile_api_controllers/new_dialysis_api_controller.go

@@ -46,7 +46,6 @@ func (this *NewDialysisApiController) GetPatient() {
 }
 
 func (this *NewDialysisApiController) GetAllPatient() {
-	fmt.Print("--------------------触发了没有")
 	adminInfo := this.GetMobileAdminUserInfo()
 	orgid := adminInfo.Org.Id
 	page, _ := this.GetInt64("page")
@@ -54,7 +53,6 @@ func (this *NewDialysisApiController) GetAllPatient() {
 	limit, _ := this.GetInt64("limit")
 	fmt.Print("limit", limit)
 	patient, err := service.GetAllPatient(orgid)
-	fmt.Print("err--------------------", err)
 	if err != nil {
 		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
 		return
@@ -88,6 +86,66 @@ func (this *NewDialysisApiController) GetGeneratedialysisno() {
 	return
 }
 
+func (this *NewDialysisApiController) GetBloodPatientInfo() {
+	adminInfo := this.GetMobileAdminUserInfo()
+	orgId := adminInfo.Org.Id
+	fmt.Print("机构ID", orgId)
+	phone := this.GetString("phone")
+	_, errcode := service.GetBloodPatientInfo(orgId, phone)
+	fmt.Print("errcode-----------------", errcode)
+	if errcode == gorm.ErrRecordNotFound {
+		returnData := make(map[string]interface{}, 0)
+		returnData["msg"] = "ok"
+		this.ServeSuccessJSON(returnData)
+		return
+	} else if errcode == nil {
+		return
+	} else {
+
+	}
+}
+
+func (this *NewDialysisApiController) GetSlowPatientInfo() {
+	adminInfo := this.GetMobileAdminUserInfo()
+	orgId := adminInfo.Org.Id
+	fmt.Print("机构ID", orgId)
+	phone := this.GetString("phone")
+	fmt.Print("phone", phone)
+	_, errcode := service.GetSlowPatientInfo(orgId, phone)
+	fmt.Print("errcode -----------------------", errcode)
+	if errcode == gorm.ErrRecordNotFound {
+		returnData := make(map[string]interface{}, 0)
+		returnData["msg"] = "ok"
+		this.ServeSuccessJSON(returnData)
+		return
+	} else if errcode == nil {
+		return
+	} else {
+
+	}
+
+}
+
+func (this *NewDialysisApiController) GetMemberpatientInfo() {
+	adminInfo := this.GetMobileAdminUserInfo()
+	orgId := adminInfo.Org.Id
+	fmt.Print("机构ID", orgId)
+	phone := this.GetString("phone")
+	fmt.Print("phone", phone)
+	_, errcode := service.GetMemberPatientInfo(orgId, phone)
+	fmt.Print("errcode --------------", errcode)
+	if errcode == gorm.ErrRecordNotFound {
+		returnData := make(map[string]interface{}, 0)
+		returnData["msg"] = "ok"
+		this.ServeSuccessJSON(returnData)
+		return
+	} else if errcode == nil {
+		return
+	} else {
+
+	}
+}
+
 func (this *NewDialysisApiController) SavePatient() {
 	adminInfo := this.GetMobileAdminUserInfo()
 	orgid := adminInfo.Org.Id
@@ -123,6 +181,12 @@ func (this *NewDialysisApiController) SavePatient() {
 	fmt.Print("留置状态", lapseto)
 	contagions := dataBody["resultTwo"].([]interface{})
 	fmt.Print("传染病", contagions)
+	ids := make([]int64, 0)
+	for _, contagion := range contagions {
+		id, _ := strconv.ParseInt(contagion.(string), 10, 64)
+		ids = append(ids, id)
+	}
+	fmt.Print("传染病2", contagions)
 	adminssionNumber := dataBody["admissionNumber"].(string)
 	fmt.Print("住院号", adminssionNumber)
 	fistdate := dataBody["fistDate"].(string)
@@ -139,8 +203,19 @@ func (this *NewDialysisApiController) SavePatient() {
 	fmt.Print("设备ID", requipmentId)
 	slowContagions := dataBody["resultThree"].([]interface{})
 	fmt.Print("慢性传染病", slowContagions)
-	slowDisease := int64(dataBody["slowDisease"].(float64))
-	fmt.Print("slowDisease", slowDisease)
+	idss := make([]int64, 0)
+	for _, contagion := range slowContagions {
+		id, _ := strconv.ParseInt(contagion.(string), 10, 64)
+		idss = append(ids, id)
+	}
+	slowDiseases := dataBody["resultFour"].([]interface{})
+	idsss := make([]int64, 0)
+	for _, contagion := range slowDiseases {
+		id, _ := strconv.ParseInt(contagion.(string), 10, 64)
+		idsss = append(ids, id)
+	}
+	fmt.Print("慢性病", slowDiseases)
+
 	bloodPatient := int64(dataBody["bloodPatient"].(float64))
 	fmt.Print("血透病人", bloodPatient)
 	slowpatient := int64(dataBody["slowPatient"].(float64))
@@ -158,65 +233,210 @@ func (this *NewDialysisApiController) SavePatient() {
 	treatmentmethod := int64(dataBody["treatmentMethod"].(float64))
 	fmt.Print("治疗方式", treatmentmethod)
 
-	_, errcode := service.GetPatientData(phone, orgid)
-	if errcode == gorm.ErrRecordNotFound {
-		patients := models.Patients{
-			Name:              name,
-			Gender:            sex,
-			Birthday:          birth,
-			Age:               ages,
-			Phone:             phone,
-			Lapseto:           lapseto,
-			AdmissionNumber:   adminssionNumber,
-			FirstDialysisDate: fisttime,
-			Diagnose:          diagonse,
-			Source:            patientsoure,
-			DialysisNo:        dialysis,
-			UserOrgId:         orgid,
-			Status:            1,
-			CreatedTime:       time.Now().Unix(),
-			Avatar:            avatar,
-		}
-		err := service.CreateOldPatient(&patients)
-		fmt.Print("报错-------------", err)
-		patient, err := service.GetLastOldPatient(7957)
-		fmt.Print("病人ID", patient.ID)
-		patientsNew := models.XtPatientsNew{
-			Name:              name,
-			Gender:            sex,
-			Birthday:          birth,
-			Age:               ages,
-			Phone:             phone,
-			Lapseto:           lapseto,
-			AdmissionNumber:   adminssionNumber,
-			FirstDialysisDate: fisttime,
-			Diagnose:          diagonse,
-			Source:            patientsoure,
-			DialysisNo:        dialysis,
-			UserOrgId:         orgid,
-			Status:            1,
-			CreatedTime:       time.Now().Unix(),
-			Avatar:            avatar,
-			MemberPatients:    memberpatient,
-			BloodPatients:     bloodPatient,
-			SlowPatients:      slowpatient,
-			BloodId:           patient.ID,
+	//如果是血透病人
+	if bloodPatient == 1 {
+		_, errcode := service.GetPatientData(phone, orgid)
+		if errcode == gorm.ErrRecordNotFound {
+			patients := models.Patients{
+				Name:              name,
+				Gender:            sex,
+				Birthday:          birth,
+				Age:               ages,
+				Phone:             phone,
+				Lapseto:           lapseto,
+				AdmissionNumber:   adminssionNumber,
+				FirstDialysisDate: fisttime,
+				Diagnose:          diagonse,
+				Source:            patientsoure,
+				DialysisNo:        dialysis,
+				UserOrgId:         orgid,
+				Status:            1,
+				CreatedTime:       time.Now().Unix(),
+				Avatar:            avatar,
+				IdCardNo:          idCard,
+			}
+			err := service.CreateOldPatient(&patients)
+			fmt.Print("报错", err)
+			patient, err := service.GetLastOldPatient(orgid)
+			fmt.Print("病人ID", patient.ID)
+			err = service.AddContagions(patient.ID, patient.CreatedTime, patient.UpdatedTime, ids)
+			fmt.Println("添加传染病失败", err)
+
+			patientsNew := models.XtPatientsNew{
+				Name:              name,
+				Gender:            sex,
+				Birthday:          birth,
+				Age:               ages,
+				Phone:             phone,
+				Lapseto:           lapseto,
+				AdmissionNumber:   adminssionNumber,
+				FirstDialysisDate: fisttime,
+				Diagnose:          diagonse,
+				Source:            patientsoure,
+				DialysisNo:        dialysis,
+				UserOrgId:         orgid,
+				Status:            1,
+				CreatedTime:       time.Now().Unix(),
+				Avatar:            avatar,
+				MemberPatients:    memberpatient,
+				BloodPatients:     bloodPatient,
+				SlowPatients:      slowpatient,
+				BloodId:           patient.ID,
+			}
+			err = service.CreateNewPatient(&patientsNew)
+			fmt.Print("报错", err)
+			if err != nil {
+				this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+				return
+			}
+			this.ServeSuccessJSON(map[string]interface{}{
+				"patient": patientsNew,
+			})
+		} else if errcode == nil {
+			fmt.Print("病人已存在")
+			return
+		} else {
+
 		}
-		err = service.CreateNewPatient(&patientsNew)
-		fmt.Print("报错", err)
-		if err != nil {
-			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+	}
+
+	fmt.Print("slowpatient----------------", slowpatient)
+	//如果是慢病病人
+	if slowpatient == 1 {
+		_, errcodetwo := service.GetSlowPatientData(phone, orgid)
+		fmt.Print("查询慢慢是吧", errcodetwo)
+		if errcodetwo == gorm.ErrRecordNotFound {
+			patients := models.CdmPatients{
+				Name:        name,
+				Gender:      sex,
+				Birthday:    birth,
+				Phone:       phone,
+				Diagnose:    diagonse,
+				Source:      patientsoure,
+				UserOrgId:   orgid,
+				Status:      1,
+				CreatedTime: time.Now().Unix(),
+				Avatar:      avatar,
+				IdCardNo:    idCard,
+			}
+			errcodetwo := service.CreateCdmPatient(&patients)
+			fmt.Print("报错", errcodetwo)
+			patient, errcodetwo := service.GetOldCdmPatient(orgid)
+			errcodetwo = service.AddSlowContagions(patient.ID, patient.CreatedTime, patient.UpdatedTime, idss, orgid)
+			fmt.Print("添加慢病传染病失败", errcodetwo)
+			errcodethree := service.AddSlowDiseases(patient.ID, patient.CreatedTime, patient.UpdatedTime, idsss, orgid)
+			fmt.Print("添加慢性病失败", errcodethree)
+
+			_, errcodefour := service.GetLastNewSlowPatient(phone, orgid)
+			if errcodefour == gorm.ErrRecordNotFound {
+				patientsNew := models.XtPatientsNew{
+					Name:              name,
+					Gender:            sex,
+					Birthday:          birth,
+					Age:               ages,
+					Phone:             phone,
+					Lapseto:           lapseto,
+					AdmissionNumber:   adminssionNumber,
+					FirstDialysisDate: fisttime,
+					Diagnose:          diagonse,
+					Source:            patientsoure,
+					DialysisNo:        dialysis,
+					UserOrgId:         orgid,
+					Status:            1,
+					CreatedTime:       time.Now().Unix(),
+					Avatar:            avatar,
+					MemberPatients:    memberpatient,
+					BloodPatients:     bloodPatient,
+					SlowPatients:      slowpatient,
+					BloodId:           patient.ID,
+				}
+				err = service.CreateNewPatient(&patientsNew)
+				if err != nil {
+					this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+					return
+				}
+				this.ServeSuccessJSON(map[string]interface{}{
+					"patient": patientsNew,
+				})
+			} else if errcodetwo == nil {
+				fmt.Print("病人已存在")
+				return
+			} else {
+
+			}
+
+		} else if errcodetwo == nil {
+			fmt.Print("病人已存在")
 			return
+		} else {
+
 		}
-		this.ServeSuccessJSON(map[string]interface{}{
-			"patient": patientsNew,
-		})
-	} else if errcode == nil {
-		fmt.Print("病人已存在")
-		return
-	} else {
 
 	}
+
+	if memberpatient == 1 {
+		_, errmembercode := service.GetMemberPatientInfo(orgid, phone)
+		if errmembercode == gorm.ErrRecordNotFound {
+			customer := models.SgjUserCustomer{
+				Name:        name,
+				UserOrgId:   orgid,
+				Mobile:      phone,
+				Gender:      sex,
+				Birthday:    birth,
+				IllDate:     memtime,
+				Status:      1,
+				CreatedTime: time.Now().Unix(),
+				Avatar:      avatar,
+				IllnessId:   patient_type,
+				TreatType:   treatmentmethod,
+			}
+			errmembercode := service.CreateMemberPatient(&customer)
+			fmt.Print("创建会员病人失败", errmembercode)
+			patient, errmembercodetwo := service.GetMemberNewPatient(phone, orgid)
+			if errmembercodetwo == gorm.ErrRecordNotFound {
+				patientsNew := models.XtPatientsNew{
+					Name:              name,
+					Gender:            sex,
+					Birthday:          birth,
+					Age:               ages,
+					Phone:             phone,
+					Lapseto:           lapseto,
+					AdmissionNumber:   adminssionNumber,
+					FirstDialysisDate: fisttime,
+					Diagnose:          diagonse,
+					Source:            patientsoure,
+					DialysisNo:        dialysis,
+					UserOrgId:         orgid,
+					Status:            1,
+					CreatedTime:       time.Now().Unix(),
+					Avatar:            avatar,
+					MemberPatients:    memberpatient,
+					BloodPatients:     bloodPatient,
+					SlowPatients:      slowpatient,
+					BloodId:           patient.ID,
+				}
+				err = service.CreateNewPatient(&patientsNew)
+				if err != nil {
+					this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+					return
+				}
+				this.ServeSuccessJSON(map[string]interface{}{
+					"patient": patientsNew,
+				})
+			} else if errmembercode == nil {
+				fmt.Print("病人已存在")
+				return
+			} else {
+
+			}
+		} else if errmembercode == nil {
+			fmt.Print("病人已存在")
+			return
+		} else {
+
+		}
+	}
+
 }
 
 func (this *NewDialysisApiController) GetPatientDetail() {
@@ -312,3 +532,165 @@ func (this *NewDialysisApiController) ToSearch() {
 		"search": search,
 	})
 }
+
+func (this *NewDialysisApiController) GetCourseManagement() {
+	timeLayout := "2006-01-02"
+	loc, _ := time.LoadLocation("Local")
+	id, _ := this.GetInt64("id")
+	fmt.Print("id", id)
+	patient, _ := service.GetPatientDetailTwo(id)
+	start := this.GetString("startime")
+	startTimes, _ := time.ParseInLocation(timeLayout+" 15:04:05", start+" 00:00:00", loc)
+	startime := startTimes.Unix()
+	fmt.Print("startime", startime)
+	end := this.GetString("endtime")
+	endTimes, _ := time.ParseInLocation(timeLayout+" 15:04:05", end+" 00:00:00", loc)
+	endtime := endTimes.Unix()
+	fmt.Print("endtime", endtime)
+	limit, _ := this.GetInt64("limit")
+	fmt.Print("limit", limit)
+	page, _ := this.GetInt64("page")
+	fmt.Print("page", page)
+	adminInfo := this.GetMobileAdminUserInfo()
+	orgid := adminInfo.Org.Id
+	management, total, err := service.GetCourseManagement(patient.BloodId, startime, endtime, limit, page, orgid)
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"coursemanagement": management,
+		"total":            total,
+	})
+}
+
+func (this *NewDialysisApiController) DeleteCourseManagement() {
+	id, _ := this.GetInt64("id")
+	err := service.DeleteCouseManagement(id)
+	fmt.Println("错误是什么", err)
+	returnData := make(map[string]interface{}, 0)
+	returnData["msg"] = "ok"
+	this.ServeSuccessJSON(returnData)
+	return
+}
+
+func (this *NewDialysisApiController) GetCouseManagentDetail() {
+	id, _ := this.GetInt64("id")
+	detail, err := service.GetCouseManagentDetail(id)
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"couseDetail": detail,
+	})
+}
+
+func (this *NewDialysisApiController) GetAllBloodDialysisPatient() {
+	page, _ := this.GetInt64("page")
+	fmt.Print("page", page)
+	limit, _ := this.GetInt64("limit")
+	fmt.Print("limit", limit)
+	adminUserInfo := this.GetMobileAdminUserInfo()
+	orgid := adminUserInfo.Org.Id
+	patient, total, err := service.GetAllBloodDialysisPatient(orgid, page, limit)
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"bloodpatient": patient,
+		"total":        total,
+	})
+}
+
+func (this *NewDialysisApiController) GetAllSlowPatent() {
+	page, _ := this.GetInt64("page")
+	fmt.Print("page", page)
+	limit, _ := this.GetInt64("limit")
+	fmt.Print("limit", limit)
+	adminUserInfo := this.GetMobileAdminUserInfo()
+	orgid := adminUserInfo.Org.Id
+	patient, total, err := service.GetAllSlowPatient(orgid, page, limit)
+	fmt.Print("err", err)
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"slowpatient": patient,
+		"total":       total,
+	})
+}
+
+func (this *NewDialysisApiController) GetAllMemberPatient() {
+	page, _ := this.GetInt64("page")
+	fmt.Print("page", page)
+	limit, _ := this.GetInt64("limit")
+	fmt.Print("limit", limit)
+	adminUserInfo := this.GetMobileAdminUserInfo()
+	orgid := adminUserInfo.Org.Id
+	patient, total, err := service.GetAllMemberPatient(orgid, page, limit)
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"memberpatient": patient,
+		"total":         total,
+	})
+}
+
+func (this *NewDialysisApiController) DeleteDryWeight() {
+	id, _ := this.GetInt64("id")
+	err := service.DeleteDryWeight(id)
+	fmt.Println("错误是什么", err)
+	returnData := make(map[string]interface{}, 0)
+	returnData["msg"] = "ok"
+	this.ServeSuccessJSON(returnData)
+	return
+}
+
+func (this *NewDialysisApiController) GetDryWeightDetail() {
+	id, _ := this.GetInt64("id")
+	fmt.Print("id", id)
+	drydetail, err := service.GetDryWeightDetail(id)
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"drydetail": drydetail,
+	})
+}
+
+func (this *NewDialysisApiController) GetlongDialysisrecord() {
+	timeLayout := "2006-01-02"
+	loc, _ := time.LoadLocation("Local")
+	id, _ := this.GetInt64("id")
+	fmt.Print("id", id)
+	patient, _ := service.GetPatientDetailTwo(id)
+	start := this.GetString("startime")
+	startTimes, _ := time.ParseInLocation(timeLayout+" 15:04:05", start+" 00:00:00", loc)
+	startime := startTimes.Unix()
+	fmt.Print("startime", startime)
+	end := this.GetString("endtime")
+	endTimes, _ := time.ParseInLocation(timeLayout+" 15:04:05", end+" 00:00:00", loc)
+	endtime := endTimes.Unix()
+	fmt.Print("endtime", endtime)
+	limit, _ := this.GetInt64("limit")
+	fmt.Print("limit", limit)
+	page, _ := this.GetInt64("page")
+	fmt.Print("page", page)
+	adminInfo := this.GetMobileAdminUserInfo()
+	orgid := adminInfo.Org.Id
+	dialysisrecord, total, err := service.GetlongDialysisrecord(patient.BloodId, startime, endtime, limit, page, orgid)
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"dialysisrecord": dialysisrecord,
+		"total":          total,
+	})
+}

controllers/new_mobile_api_controllers/new_mobile_api_router_register.go

@@ -8,10 +8,22 @@ func NewMobileAPIControllersRegisterRouters() {
 	beego.Router("m/api/patient/getillnesslist", &NewDialysisApiController{}, "Get:GetIllnesslist")
 	beego.Router("/m/api/patients/generatedialysisnotwo", &NewDialysisApiController{}, "Get:GetGeneratedialysisno")
 	beego.Router("/m/api/patient/getbloodDialysisPatient", &NewDialysisApiController{}, "Get:GetPatient")
+	beego.Router("/m/api/patient/getbloodpatientinfo", &NewDialysisApiController{}, "Get:GetBloodPatientInfo")
+	beego.Router("/m/api/patient/getslowpatientinfo", &NewDialysisApiController{}, "Get:GetSlowPatientInfo")
+	beego.Router("/m/api/patient/getmemberpatientinfo", &NewDialysisApiController{}, "Get:GetMemberpatientInfo")
 	beego.Router("/m/api/patient/savepatient", &NewDialysisApiController{}, "Post:SavePatient")
 	beego.Router("/m/api/patient/getpatientdetail", &NewDialysisApiController{}, "Get:GetPatientDetail")
 	beego.Router("/m/api/patient/getdoctoradvices", &NewDialysisApiController{}, "Get:GetDoctorAdvices")
 	beego.Router("/m/api/paitent/getdryweight", &NewDialysisApiController{}, "Get:GetDryWeight")
 	beego.Router("m/api/patient/getbloodDialysisPatientwo", &NewDialysisApiController{}, "Get:GetAllPatient")
 	beego.Router("m/api/patient/tosearch", &NewDialysisApiController{}, "Get:ToSearch")
+	beego.Router("/m/api/patient/getcoursemanagement", &NewDialysisApiController{}, "Get:GetCourseManagement")
+	beego.Router("/m/api/patient/delelecousemanage", &NewDialysisApiController{}, "Delete:DeleteCourseManagement")
+	beego.Router("/m/api/patient/getcousemanagementdetail", &NewDialysisApiController{}, "Get:GetCouseManagentDetail")
+	beego.Router("/m/api/patient/getallblooddialysispatient", &NewDialysisApiController{}, "Get:GetAllBloodDialysisPatient")
+	beego.Router("/m/api/patient/getallslowpatient", &NewDialysisApiController{}, "Get:GetAllSlowPatent")
+	beego.Router("/m/api/patient/getallmemberpatient", &NewDialysisApiController{}, "Get:GetAllMemberPatient")
+	beego.Router("/m/api/patient/deletedryweight", &NewDialysisApiController{}, "Delete:DeleteDryWeight")
+	beego.Router("/m/api/patient/getdryweightdetail", &NewDialysisApiController{}, "Get:GetDryWeightDetail")
+	beego.Router("/m/api/patient/getlongdialysisrecord", &NewDialysisApiController{}, "Get:GetlongDialysisrecord")
 }

models/patient_models.go

@@ -489,3 +489,129 @@ type PatientsNew struct {
 	ID   int64  `gorm:"column:id" json:"id" form:"id"`
 	Name string `gorm:"column:name" json:"name" form:"name"`
 }
+
+type CdmPatients struct {
+	ID                int64  `gorm:"column:id" json:"id" form:"id"`
+	UserOrgId         int64  `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
+	UserId            int64  `gorm:"column:user_id" json:"user_id" form:"user_id"`
+	Avatar            string `gorm:"column:avatar" json:"avatar" form:"avatar"`
+	PatientType       int64  `gorm:"column:patient_type" json:"patient_type" form:"patient_type"`
+	Source            int64  `gorm:"column:source" json:"source" form:"source"`
+	Name              string `gorm:"column:name" json:"name" form:"name"`
+	Alias             string `gorm:"column:alias" json:"alias" form:"alias"`
+	Gender            int64  `gorm:"column:gender" json:"gender" form:"gender"`
+	MaritalStatus     int64  `gorm:"column:marital_status" json:"marital_status" form:"marital_status"`
+	IdCardNo          string `gorm:"column:id_card_no" json:"id_card_no" form:"id_card_no"`
+	Birthday          int64  `gorm:"column:birthday" json:"birthday" form:"birthday"`
+	HealthCareType    int64  `gorm:"column:health_care_type" json:"health_care_type" form:"health_care_type"`
+	HealthCareNo      string `gorm:"column:health_care_no" json:"health_care_no" form:"health_care_no"`
+	Height            int64  `gorm:"column:height" json:"height" form:"height"`
+	BloodType         int64  `gorm:"column:blood_type" json:"blood_type" form:"blood_type"`
+	Rh                int64  `gorm:"column:rh" json:"rh" form:"rh"`
+	EducationLevel    int64  `gorm:"column:education_level" json:"education_level" form:"education_level"`
+	Profession        int64  `gorm:"column:profession" json:"profession" form:"profession"`
+	Phone             string `gorm:"column:phone" json:"phone" form:"phone"`
+	HomeTelephone     string `gorm:"column:home_telephone" json:"home_telephone" form:"home_telephone"`
+	RelativePhone     string `gorm:"column:relative_phone" json:"relative_phone" form:"relative_phone"`
+	RelativeRelations string `gorm:"column:relative_relations" json:"relative_relations" form:"relative_relations"`
+	HomeAddress       string `gorm:"column:home_address" json:"home_address" form:"home_address"`
+	WorkUnit          string `gorm:"column:work_unit" json:"work_unit" form:"work_unit"`
+	UnitAddress       string `gorm:"column:unit_address" json:"unit_address" form:"unit_address"`
+	Children          int64  `gorm:"column:children" json:"children" form:"children"`
+	AttendingDoctorId int64  `gorm:"column:attending_doctor_id" json:"attending_doctor_id" form:"attending_doctor_id"`
+	HeadNurseId       int64  `gorm:"column:head_nurse_id" json:"head_nurse_id" form:"head_nurse_id"`
+	Diagnose          string `gorm:"column:diagnose" json:"diagnose" form:"diagnose"`
+	Remark            string `gorm:"column:remark" json:"remark" form:"remark"`
+	RegistrarsId      int64  `gorm:"column:registrars_id" json:"registrars_id" form:"registrars_id"`
+	Registrars        string `gorm:"column:registrars" json:"registrars" form:"registrars"`
+	QrCode            string `gorm:"column:qr_code" json:"qr_code" form:"qr_code"`
+	BindingState      int64  `gorm:"column:binding_state" json:"binding_state" form:"binding_state"`
+	Status            int64  `gorm:"column:status" json:"status" form:"status"`
+	CreatedTime       int64  `gorm:"column:created_time" json:"created_time" form:"created_time"`
+	UpdatedTime       int64  `gorm:"column:updated_time" json:"updated_time" form:"updated_time"`
+}
+
+func (CdmPatients) TableName() string {
+	return "xt_patients"
+}
+
+type SgjUserCustomer struct {
+	ID              int64  `gorm:"column:id" json:"id" form:"id"`
+	UserOrgId       int64  `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
+	UserId          int64  `gorm:"column:user_id" json:"user_id" form:"user_id"`
+	Mobile          string `gorm:"column:mobile" json:"mobile" form:"mobile"`
+	Name            string `gorm:"column:name" json:"name" form:"name"`
+	Gender          int64  `gorm:"column:gender" json:"gender" form:"gender"`
+	ProvinceId      int64  `gorm:"column:province_id" json:"province_id" form:"province_id"`
+	CityId          int64  `gorm:"column:city_id" json:"city_id" form:"city_id"`
+	Address         string `gorm:"column:address" json:"address" form:"address"`
+	Birthday        int64  `gorm:"column:birthday" json:"birthday" form:"birthday"`
+	TreatType       int64  `gorm:"column:treat_type" json:"treat_type" form:"treat_type"`
+	Relationship    int64  `gorm:"column:relationship" json:"relationship" form:"relationship"`
+	IllnessId       int64  `gorm:"column:illness_id" json:"illness_id" form:"illness_id"`
+	WechatOpenid    string `gorm:"column:wechat_openid" json:"wechat_openid" form:"wechat_openid"`
+	Membership      int64  `gorm:"column:membership" json:"membership" form:"membership"`
+	Sources         int64  `gorm:"column:sources" json:"sources" form:"sources"`
+	Status          int64  `gorm:"column:status" json:"status" form:"status"`
+	CreatedTime     int64  `gorm:"column:created_time" json:"created_time" form:"created_time"`
+	UpdatedTime     int64  `gorm:"column:updated_time" json:"updated_time" form:"updated_time"`
+	Avatar          string `gorm:"column:avatar" json:"avatar" form:"avatar"`
+	WechatUnionid   string `gorm:"column:wechat_unionid" json:"wechat_unionid" form:"wechat_unionid"`
+	Remark          string `gorm:"column:remark" json:"remark" form:"remark"`
+	MedicalDiagnose string `gorm:"column:medical_diagnose" json:"medical_diagnose" form:"medical_diagnose"`
+	YzUid           int64  `gorm:"column:yz_uid" json:"yz_uid" form:"yz_uid"`
+	Tttime          int64  `gorm:"column:tttime" json:"tttime" form:"tttime"`
+	IllDate         int64  `gorm:"column:ill_date" json:"ill_date" form:"ill_date"`
+	DistrictId      int64  `gorm:"column:district_id" json:"district_id" form:"district_id"`
+}
+
+func (SgjUserCustomer) TableName() string {
+	return "sgj_user_customer"
+}
+
+type PatientCourseOfDiseases struct {
+	ID         int64  `gorm:"column:id" json:"id" form:"id"`
+	OrgId      int64  `gorm:"column:org_id" json:"org_id" form:"org_id"`
+	PatientId  int64  `gorm:"column:patient_id" json:"patient_id" form:"patient_id"`
+	Recorder   int64  `gorm:"column:recorder" json:"recorder" form:"recorder"`
+	RecordTime int64  `gorm:"column:record_time" json:"record_time" form:"record_time"`
+	Content    string `gorm:"column:content" json:"content" form:"content"`
+	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"`
+	Title      string `gorm:"column:title" json:"title" form:"title"`
+	UserName   string `gorm:"column:user_name" json:"user_name" form:"user_name"`
+}
+
+type PatientCourseOfDiseasess struct {
+	ID         int64  `gorm:"column:id" json:"id" form:"id"`
+	OrgId      int64  `gorm:"column:org_id" json:"org_id" form:"org_id"`
+	PatientId  int64  `gorm:"column:patient_id" json:"patient_id" form:"patient_id"`
+	Recorder   int64  `gorm:"column:recorder" json:"recorder" form:"recorder"`
+	RecordTime int64  `gorm:"column:record_time" json:"record_time" form:"record_time"`
+	Content    string `gorm:"column:content" json:"content" form:"content"`
+	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"`
+	Title      string `gorm:"column:title" json:"title" form:"title"`
+	UserName   string `gorm:"column:user_name" json:"user_name" form:"user_name"`
+	Name       string `gorm:"column:name" json:"name" form:"name"`
+}
+
+type PatientCourseOfDisease struct {
+	ID         int64  `gorm:"column:id" json:"id" form:"id"`
+	OrgId      int64  `gorm:"column:org_id" json:"org_id" form:"org_id"`
+	PatientId  int64  `gorm:"column:patient_id" json:"patient_id" form:"patient_id"`
+	Recorder   int64  `gorm:"column:recorder" json:"recorder" form:"recorder"`
+	RecordTime int64  `gorm:"column:record_time" json:"record_time" form:"record_time"`
+	Content    string `gorm:"column:content" json:"content" form:"content"`
+	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"`
+	Title      string `gorm:"column:title" json:"title" form:"title"`
+}
+
+func (PatientCourseOfDisease) TableName() string {
+
+	return "xt_patient_course_of_disease"
+}

models/user_models.go

@@ -88,6 +88,22 @@ func (SgjPatientDryweight) TableName() string {
 	return "xt_patient_dryweight"
 }
 
+type SgjPatientDryweights struct {
+	ID            int64   `gorm:"column:id" json:"id" form:"id"`
+	DryWeight     float64 `gorm:"column:dry_weight" json:"dry_weight" form:"dry_weight"`
+	Creator       int64   `gorm:"column:creator" json:"creator" form:"creator"`
+	Remakes       string  `gorm:"column:remakes" json:"remakes" form:"remakes"`
+	PatientId     int64   `gorm:"column:patient_id" json:"patient_id" form:"patient_id"`
+	Ctime         int64   `gorm:"column:ctime" json:"ctime" form:"ctime"`
+	Mtime         int64   `gorm:"column:mtime" json:"mtime" form:"mtime"`
+	Status        int64   `gorm:"column:status" json:"status" form:"status"`
+	AdjustedValue string  `gorm:"column:adjusted_value" json:"adjusted_value" form:"adjusted_value"`
+	UserOrgId     int64   `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
+	UserId        int64   `gorm:"column:user_id" json:"user_id" form:"user_id"`
+	UserName      string  `gorm:"column:user_name" json:"user_name" form:"user_name"`
+	Name          string  `gorm:"column:name" json:"name" form:"name"`
+}
+
 type XtPatientDryweight struct {
 	ID            int64   `gorm:"column:id" json:"id" form:"id"`
 	DryWeight     float64 `gorm:"column:dry_weight" json:"dry_weight" form:"dry_weight"`
@@ -102,3 +118,222 @@ type XtPatientDryweight struct {
 	UserId        int64   `gorm:"column:user_id" json:"user_id" form:"user_id"`
 	UserName      string  `gorm:"column:user_name" json:"user_name" form:"user_name"`
 }
+
+type XtDialysisPrescription struct {
+	ID                         int64   `gorm:"column:id" json:"id" form:"id"`
+	UserOrgId                  int64   `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
+	PatientId                  int64   `gorm:"column:patient_id" json:"patient_id" form:"patient_id"`
+	Dialyzer                   int64   `gorm:"column:dialyzer" json:"dialyzer" form:"dialyzer"`
+	MachineType                string  `gorm:"column:machine_type" json:"machine_type" form:"machine_type"`
+	DewaterAmount              float64 `gorm:"column:dewater_amount" json:"dewater_amount" form:"dewater_amount"`
+	DialyzerPerfusionApparatus string  `gorm:"column:dialyzer_perfusion_apparatus" json:"dialyzer_perfusion_apparatus" form:"dialyzer_perfusion_apparatus"`
+	PrescriptionDewatering     float64 `gorm:"column:prescription_dewatering" json:"prescription_dewatering" form:"prescription_dewatering"`
+	Anticoagulant              int64   `gorm:"column:anticoagulant" json:"anticoagulant" form:"anticoagulant"`
+	AnticoagulantShouji        float64 `gorm:"column:anticoagulant_shouji" json:"anticoagulant_shouji" form:"anticoagulant_shouji"`
+	AnticoagulantWeichi        float64 `gorm:"column:anticoagulant_weichi" json:"anticoagulant_weichi" form:"anticoagulant_weichi"`
+	AnticoagulantZongliang     float64 `gorm:"column:anticoagulant_zongliang" json:"anticoagulant_zongliang" form:"anticoagulant_zongliang"`
+	AnticoagulantGaimingcheng  string  `gorm:"column:anticoagulant_gaimingcheng" json:"anticoagulant_gaimingcheng" form:"anticoagulant_gaimingcheng"`
+	AnticoagulantGaijiliang    string  `gorm:"column:anticoagulant_gaijiliang" json:"anticoagulant_gaijiliang" form:"anticoagulant_gaijiliang"`
+	ModeId                     int64   `gorm:"column:mode_id" json:"mode_id" form:"mode_id"`
+	DialysisDurationHour       int64   `gorm:"column:dialysis_duration_hour" json:"dialysis_duration_hour" form:"dialysis_duration_hour"`
+	DialysisDurationMinute     int64   `gorm:"column:dialysis_duration_minute" json:"dialysis_duration_minute" form:"dialysis_duration_minute"`
+	DialysisDuration           float64 `gorm:"column:dialysis_duration" json:"dialysis_duration" form:"dialysis_duration"`
+	ReplacementTotal           float64 `gorm:"column:replacement_total" json:"replacement_total" form:"replacement_total"`
+	ReplacementWay             int64   `gorm:"column:replacement_way" json:"replacement_way" form:"replacement_way"`
+	HemodialysisMachine        int64   `gorm:"column:hemodialysis_machine" json:"hemodialysis_machine" form:"hemodialysis_machine"`
+	BloodFilter                int64   `gorm:"column:blood_filter" json:"blood_filter" form:"blood_filter"`
+	PerfusionApparatus         int64   `gorm:"column:perfusion_apparatus" json:"perfusion_apparatus" form:"perfusion_apparatus"`
+	DryWeight                  float64 `gorm:"column:dry_weight" json:"dry_weight" form:"dry_weight"`
+	VascularAccessMode         int64   `gorm:"column:vascular_access_mode" json:"vascular_access_mode" form:"vascular_access_mode"`
+	VascularAccess             int64   `gorm:"column:vascular_access" json:"vascular_access" form:"vascular_access"`
+	BloodFlowVolume            float64 `gorm:"column:blood_flow_volume" json:"blood_flow_volume" form:"blood_flow_volume"`
+	DialysateFlow              float64 `gorm:"column:dialysate_flow" json:"dialysate_flow" form:"dialysate_flow"`
+	DisplaceLiqui              float64 `gorm:"column:displace_liqui" json:"displace_liqui" form:"displace_liqui"`
+	Kalium                     float64 `gorm:"column:kalium" json:"kalium" form:"kalium"`
+	Sodium                     float64 `gorm:"column:sodium" json:"sodium" form:"sodium"`
+	Calcium                    float64 `gorm:"column:calcium" json:"calcium" form:"calcium"`
+	Bicarbonate                float64 `gorm:"column:bicarbonate" json:"bicarbonate" form:"bicarbonate"`
+	Glucose                    float64 `gorm:"column:glucose" json:"glucose" form:"glucose"`
+	DialysateTemperature       float64 `gorm:"column:dialysate_temperature" json:"dialysate_temperature" form:"dialysate_temperature"`
+	Conductivity               float64 `gorm:"column:conductivity" json:"conductivity" form:"conductivity"`
+	PrescriptionDoctor         int64   `gorm:"column:prescription_doctor" json:"prescription_doctor" form:"prescription_doctor"`
+	Creater                    int64   `gorm:"column:creater" json:"creater" form:"creater"`
+	Modifier                   int64   `gorm:"column:modifier" json:"modifier" form:"modifier"`
+	Remark                     string  `gorm:"column:remark" json:"remark" form:"remark"`
+	Status                     int64   `gorm:"column:status" json:"status" form:"status"`
+	CreatedTime                int64   `gorm:"column:created_time" json:"created_time" form:"created_time"`
+	UpdatedTime                int64   `gorm:"column:updated_time" json:"updated_time" form:"updated_time"`
+	RecordDate                 int64   `gorm:"column:record_date" json:"record_date" form:"record_date"`
+	RecordId                   int64   `gorm:"column:record_id" json:"record_id" form:"record_id"`
+	TargetUltrafiltration      float64 `gorm:"column:target_ultrafiltration" json:"target_ultrafiltration" form:"target_ultrafiltration"`
+	DialysateFormulation       int64   `gorm:"column:dialysate_formulation" json:"dialysate_formulation" form:"dialysate_formulation"`
+	BodyFluid                  int64   `gorm:"column:body_fluid" json:"body_fluid" form:"body_fluid"`
+	SpecialMedicine            int64   `gorm:"column:special_medicine" json:"special_medicine" form:"special_medicine"`
+	SpecialMedicineOther       string  `gorm:"column:special_medicine_other" json:"special_medicine_other" form:"special_medicine_other"`
+	DisplaceLiquiPart          int64   `gorm:"column:displace_liqui_part" json:"displace_liqui_part" form:"displace_liqui_part"`
+	BloodAccess                int64   `gorm:"column:blood_access" json:"blood_access" form:"blood_access"`
+	DisplaceLiquiValue         float64 `gorm:"column:displace_liqui_value" json:"displace_liqui_value" form:"displace_liqui_value"`
+	Ultrafiltration            float64 `gorm:"column:ultrafiltration" json:"ultrafiltration" form:"ultrafiltration"`
+	BodyFluidOther             string  `gorm:"column:body_fluid_other" json:"body_fluid_other" form:"body_fluid_other"`
+	Niprocart                  int64   `gorm:"column:niprocart" json:"niprocart" form:"niprocart"`
+	Jms                        int64   `gorm:"column:jms" json:"jms" form:"jms"`
+	FistulaNeedleSet           int64   `gorm:"column:fistula_needle_set" json:"fistula_needle_set" form:"fistula_needle_set"`
+	FistulaNeedleSet16         int64   `gorm:"column:fistula_needle_set_16" json:"fistula_needle_set_16" form:"fistula_needle_set_16"`
+	Hemoperfusion              int64   `gorm:"column:hemoperfusion" json:"hemoperfusion" form:"hemoperfusion"`
+	DialyserSterilised         int64   `gorm:"column:dialyser_sterilised" json:"dialyser_sterilised" form:"dialyser_sterilised"`
+	Filtryzer                  int64   `gorm:"column:filtryzer" json:"filtryzer" form:"filtryzer"`
+	TargetKtv                  float64 `gorm:"column:target_ktv" json:"target_ktv" form:"target_ktv"`
+	Dialyzers                  int64   `gorm:"column:dialyzers" json:"dialyzers" form:"dialyzers"`
+	Injector                   int64   `gorm:"column:injector" json:"injector" form:"injector"`
+	Bloodlines                 int64   `gorm:"column:bloodlines" json:"bloodlines" form:"bloodlines"`
+	TubingHemodialysis         int64   `gorm:"column:tubing_hemodialysis" json:"tubing_hemodialysis" form:"tubing_hemodialysis"`
+	Package                    int64   `gorm:"column:package" json:"package" form:"package"`
+	ALiquid                    int64   `gorm:"column:a_liquid" json:"a_liquid" form:"a_liquid"`
+}
+
+func (XtDialysisPrescription) TableName() string {
+
+	return "xt_dialysis_prescription"
+}
+
+type XtDialysisPrescriptions struct {
+	ID                         int64   `gorm:"column:id" json:"id" form:"id"`
+	UserOrgId                  int64   `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
+	PatientId                  int64   `gorm:"column:patient_id" json:"patient_id" form:"patient_id"`
+	Dialyzer                   int64   `gorm:"column:dialyzer" json:"dialyzer" form:"dialyzer"`
+	MachineType                string  `gorm:"column:machine_type" json:"machine_type" form:"machine_type"`
+	DewaterAmount              float64 `gorm:"column:dewater_amount" json:"dewater_amount" form:"dewater_amount"`
+	DialyzerPerfusionApparatus string  `gorm:"column:dialyzer_perfusion_apparatus" json:"dialyzer_perfusion_apparatus" form:"dialyzer_perfusion_apparatus"`
+	PrescriptionDewatering     float64 `gorm:"column:prescription_dewatering" json:"prescription_dewatering" form:"prescription_dewatering"`
+	Anticoagulant              int64   `gorm:"column:anticoagulant" json:"anticoagulant" form:"anticoagulant"`
+	AnticoagulantShouji        float64 `gorm:"column:anticoagulant_shouji" json:"anticoagulant_shouji" form:"anticoagulant_shouji"`
+	AnticoagulantWeichi        float64 `gorm:"column:anticoagulant_weichi" json:"anticoagulant_weichi" form:"anticoagulant_weichi"`
+	AnticoagulantZongliang     float64 `gorm:"column:anticoagulant_zongliang" json:"anticoagulant_zongliang" form:"anticoagulant_zongliang"`
+	AnticoagulantGaimingcheng  string  `gorm:"column:anticoagulant_gaimingcheng" json:"anticoagulant_gaimingcheng" form:"anticoagulant_gaimingcheng"`
+	AnticoagulantGaijiliang    string  `gorm:"column:anticoagulant_gaijiliang" json:"anticoagulant_gaijiliang" form:"anticoagulant_gaijiliang"`
+	ModeId                     int64   `gorm:"column:mode_id" json:"mode_id" form:"mode_id"`
+	DialysisDurationHour       int64   `gorm:"column:dialysis_duration_hour" json:"dialysis_duration_hour" form:"dialysis_duration_hour"`
+	DialysisDurationMinute     int64   `gorm:"column:dialysis_duration_minute" json:"dialysis_duration_minute" form:"dialysis_duration_minute"`
+	DialysisDuration           float64 `gorm:"column:dialysis_duration" json:"dialysis_duration" form:"dialysis_duration"`
+	ReplacementTotal           float64 `gorm:"column:replacement_total" json:"replacement_total" form:"replacement_total"`
+	ReplacementWay             int64   `gorm:"column:replacement_way" json:"replacement_way" form:"replacement_way"`
+	HemodialysisMachine        int64   `gorm:"column:hemodialysis_machine" json:"hemodialysis_machine" form:"hemodialysis_machine"`
+	BloodFilter                int64   `gorm:"column:blood_filter" json:"blood_filter" form:"blood_filter"`
+	PerfusionApparatus         int64   `gorm:"column:perfusion_apparatus" json:"perfusion_apparatus" form:"perfusion_apparatus"`
+	DryWeight                  float64 `gorm:"column:dry_weight" json:"dry_weight" form:"dry_weight"`
+	VascularAccessMode         int64   `gorm:"column:vascular_access_mode" json:"vascular_access_mode" form:"vascular_access_mode"`
+	VascularAccess             int64   `gorm:"column:vascular_access" json:"vascular_access" form:"vascular_access"`
+	BloodFlowVolume            float64 `gorm:"column:blood_flow_volume" json:"blood_flow_volume" form:"blood_flow_volume"`
+	DialysateFlow              float64 `gorm:"column:dialysate_flow" json:"dialysate_flow" form:"dialysate_flow"`
+	DisplaceLiqui              float64 `gorm:"column:displace_liqui" json:"displace_liqui" form:"displace_liqui"`
+	Kalium                     float64 `gorm:"column:kalium" json:"kalium" form:"kalium"`
+	Sodium                     float64 `gorm:"column:sodium" json:"sodium" form:"sodium"`
+	Calcium                    float64 `gorm:"column:calcium" json:"calcium" form:"calcium"`
+	Bicarbonate                float64 `gorm:"column:bicarbonate" json:"bicarbonate" form:"bicarbonate"`
+	Glucose                    float64 `gorm:"column:glucose" json:"glucose" form:"glucose"`
+	DialysateTemperature       float64 `gorm:"column:dialysate_temperature" json:"dialysate_temperature" form:"dialysate_temperature"`
+	Conductivity               float64 `gorm:"column:conductivity" json:"conductivity" form:"conductivity"`
+	PrescriptionDoctor         int64   `gorm:"column:prescription_doctor" json:"prescription_doctor" form:"prescription_doctor"`
+	Creater                    int64   `gorm:"column:creater" json:"creater" form:"creater"`
+	Modifier                   int64   `gorm:"column:modifier" json:"modifier" form:"modifier"`
+	Remark                     string  `gorm:"column:remark" json:"remark" form:"remark"`
+	Status                     int64   `gorm:"column:status" json:"status" form:"status"`
+	CreatedTime                int64   `gorm:"column:created_time" json:"created_time" form:"created_time"`
+	UpdatedTime                int64   `gorm:"column:updated_time" json:"updated_time" form:"updated_time"`
+	RecordDate                 int64   `gorm:"column:record_date" json:"record_date" form:"record_date"`
+	RecordId                   int64   `gorm:"column:record_id" json:"record_id" form:"record_id"`
+	TargetUltrafiltration      float64 `gorm:"column:target_ultrafiltration" json:"target_ultrafiltration" form:"target_ultrafiltration"`
+	DialysateFormulation       int64   `gorm:"column:dialysate_formulation" json:"dialysate_formulation" form:"dialysate_formulation"`
+	BodyFluid                  int64   `gorm:"column:body_fluid" json:"body_fluid" form:"body_fluid"`
+	SpecialMedicine            int64   `gorm:"column:special_medicine" json:"special_medicine" form:"special_medicine"`
+	SpecialMedicineOther       string  `gorm:"column:special_medicine_other" json:"special_medicine_other" form:"special_medicine_other"`
+	DisplaceLiquiPart          int64   `gorm:"column:displace_liqui_part" json:"displace_liqui_part" form:"displace_liqui_part"`
+	BloodAccess                int64   `gorm:"column:blood_access" json:"blood_access" form:"blood_access"`
+	DisplaceLiquiValue         float64 `gorm:"column:displace_liqui_value" json:"displace_liqui_value" form:"displace_liqui_value"`
+	Ultrafiltration            float64 `gorm:"column:ultrafiltration" json:"ultrafiltration" form:"ultrafiltration"`
+	BodyFluidOther             string  `gorm:"column:body_fluid_other" json:"body_fluid_other" form:"body_fluid_other"`
+	Niprocart                  int64   `gorm:"column:niprocart" json:"niprocart" form:"niprocart"`
+	Jms                        int64   `gorm:"column:jms" json:"jms" form:"jms"`
+	FistulaNeedleSet           int64   `gorm:"column:fistula_needle_set" json:"fistula_needle_set" form:"fistula_needle_set"`
+	FistulaNeedleSet16         int64   `gorm:"column:fistula_needle_set_16" json:"fistula_needle_set_16" form:"fistula_needle_set_16"`
+	Hemoperfusion              int64   `gorm:"column:hemoperfusion" json:"hemoperfusion" form:"hemoperfusion"`
+	DialyserSterilised         int64   `gorm:"column:dialyser_sterilised" json:"dialyser_sterilised" form:"dialyser_sterilised"`
+	Filtryzer                  int64   `gorm:"column:filtryzer" json:"filtryzer" form:"filtryzer"`
+	TargetKtv                  float64 `gorm:"column:target_ktv" json:"target_ktv" form:"target_ktv"`
+	Dialyzers                  int64   `gorm:"column:dialyzers" json:"dialyzers" form:"dialyzers"`
+	Injector                   int64   `gorm:"column:injector" json:"injector" form:"injector"`
+	Bloodlines                 int64   `gorm:"column:bloodlines" json:"bloodlines" form:"bloodlines"`
+	TubingHemodialysis         int64   `gorm:"column:tubing_hemodialysis" json:"tubing_hemodialysis" form:"tubing_hemodialysis"`
+	Package                    int64   `gorm:"column:package" json:"package" form:"package"`
+	ALiquid                    int64   `gorm:"column:a_liquid" json:"a_liquid" form:"a_liquid"`
+	UserName                   string  `gorm:"column:user_name" json:"user_name" form:"user_name"`
+}
+
+type XtDialysisSolution struct {
+	ID                         int64   `gorm:"column:id" json:"id" form:"id"`
+	Name                       string  `gorm:"column:name" json:"name" form:"name"`
+	SubName                    string  `gorm:"column:sub_name" json:"sub_name" form:"sub_name"`
+	UserOrgId                  int64   `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
+	PatientId                  int64   `gorm:"column:patient_id" json:"patient_id" form:"patient_id"`
+	ParentId                   int64   `gorm:"column:parent_id" json:"parent_id" form:"parent_id"`
+	Type                       int64   `gorm:"column:type" json:"type" form:"type"`
+	Period                     string  `gorm:"column:period" json:"period" form:"period"`
+	Times                      string  `gorm:"column:times" json:"times" form:"times"`
+	Anticoagulant              int64   `gorm:"column:anticoagulant" json:"anticoagulant" form:"anticoagulant"`
+	AnticoagulantShouji        float64 `gorm:"column:anticoagulant_shouji" json:"anticoagulant_shouji" form:"anticoagulant_shouji"`
+	AnticoagulantWeichi        float64 `gorm:"column:anticoagulant_weichi" json:"anticoagulant_weichi" form:"anticoagulant_weichi"`
+	AnticoagulantZongliang     float64 `gorm:"column:anticoagulant_zongliang" json:"anticoagulant_zongliang" form:"anticoagulant_zongliang"`
+	AnticoagulantGaimingcheng  string  `gorm:"column:anticoagulant_gaimingcheng" json:"anticoagulant_gaimingcheng" form:"anticoagulant_gaimingcheng"`
+	AnticoagulantGaijiliang    string  `gorm:"column:anticoagulant_gaijiliang" json:"anticoagulant_gaijiliang" form:"anticoagulant_gaijiliang"`
+	ModeName                   string  `gorm:"column:mode_name" json:"mode_name" form:"mode_name"`
+	ModeId                     int64   `gorm:"column:mode_id" json:"mode_id" form:"mode_id"`
+	DialysisDuration           float64 `gorm:"column:dialysis_duration" json:"dialysis_duration" form:"dialysis_duration"`
+	ReplacementWay             int64   `gorm:"column:replacement_way" json:"replacement_way" form:"replacement_way"`
+	HemodialysisMachine        int64   `gorm:"column:hemodialysis_machine" json:"hemodialysis_machine" form:"hemodialysis_machine"`
+	BloodFilter                int64   `gorm:"column:blood_filter" json:"blood_filter" form:"blood_filter"`
+	PerfusionApparatus         int64   `gorm:"column:perfusion_apparatus" json:"perfusion_apparatus" form:"perfusion_apparatus"`
+	BloodFlowVolume            float64 `gorm:"column:blood_flow_volume" json:"blood_flow_volume" form:"blood_flow_volume"`
+	Dewater                    float64 `gorm:"column:dewater" json:"dewater" form:"dewater"`
+	DisplaceLiqui              float64 `gorm:"column:displace_liqui" json:"displace_liqui" form:"displace_liqui"`
+	Glucose                    float64 `gorm:"column:glucose" json:"glucose" form:"glucose"`
+	DryWeight                  float64 `gorm:"column:dry_weight" json:"dry_weight" form:"dry_weight"`
+	DialysateFlow              float64 `gorm:"column:dialysate_flow" json:"dialysate_flow" form:"dialysate_flow"`
+	Kalium                     float64 `gorm:"column:kalium" json:"kalium" form:"kalium"`
+	Sodium                     float64 `gorm:"column:sodium" json:"sodium" form:"sodium"`
+	Calcium                    float64 `gorm:"column:calcium" json:"calcium" form:"calcium"`
+	Bicarbonate                float64 `gorm:"column:bicarbonate" json:"bicarbonate" form:"bicarbonate"`
+	Doctor                     int64   `gorm:"column:doctor" json:"doctor" form:"doctor"`
+	FirstDialysis              int64   `gorm:"column:first_dialysis" json:"first_dialysis" form:"first_dialysis"`
+	Remark                     string  `gorm:"column:remark" json:"remark" form:"remark"`
+	InitiateMode               int64   `gorm:"column:initiate_mode" json:"initiate_mode" form:"initiate_mode"`
+	AffirmState                int64   `gorm:"column:affirm_state" json:"affirm_state" form:"affirm_state"`
+	UseState                   int64   `gorm:"column:use_state" json:"use_state" form:"use_state"`
+	Status                     int64   `gorm:"column:status" json:"status" form:"status"`
+	RegistrarsId               int64   `gorm:"column:registrars_id" json:"registrars_id" form:"registrars_id"`
+	CreatedTime                int64   `gorm:"column:created_time" json:"created_time" form:"created_time"`
+	UpdatedTime                int64   `gorm:"column:updated_time" json:"updated_time" form:"updated_time"`
+	SolutionType               int64   `gorm:"column:solution_type" json:"solution_type" form:"solution_type"`
+	DialysateTemperature       float64 `gorm:"column:dialysate_temperature" json:"dialysate_temperature" form:"dialysate_temperature"`
+	Conductivity               float64 `gorm:"column:conductivity" json:"conductivity" form:"conductivity"`
+	DialysisDurationHour       int64   `gorm:"column:dialysis_duration_hour" json:"dialysis_duration_hour" form:"dialysis_duration_hour"`
+	DialysisDurationMinute     int64   `gorm:"column:dialysis_duration_minute" json:"dialysis_duration_minute" form:"dialysis_duration_minute"`
+	TargetUltrafiltration      float64 `gorm:"column:target_ultrafiltration" json:"target_ultrafiltration" form:"target_ultrafiltration"`
+	DialysateFormulation       int64   `gorm:"column:dialysate_formulation" json:"dialysate_formulation" form:"dialysate_formulation"`
+	Dialyzer                   int64   `gorm:"column:dialyzer" json:"dialyzer" form:"dialyzer"`
+	ReplacementTotal           float64 `gorm:"column:replacement_total" json:"replacement_total" form:"replacement_total"`
+	DialyzerPerfusionApparatus string  `gorm:"column:dialyzer_perfusion_apparatus" json:"dialyzer_perfusion_apparatus" form:"dialyzer_perfusion_apparatus"`
+	BodyFluid                  int64   `gorm:"column:body_fluid" json:"body_fluid" form:"body_fluid"`
+	SpecialMedicine            int64   `gorm:"column:special_medicine" json:"special_medicine" form:"special_medicine"`
+	SpecialMedicineOther       string  `gorm:"column:special_medicine_other" json:"special_medicine_other" form:"special_medicine_other"`
+	DisplaceLiquiPart          int64   `gorm:"column:displace_liqui_part" json:"displace_liqui_part" form:"displace_liqui_part"`
+	DisplaceLiquiValue         float64 `gorm:"column:displace_liqui_value" json:"displace_liqui_value" form:"displace_liqui_value"`
+	BloodAccess                int64   `gorm:"column:blood_access" json:"blood_access" form:"blood_access"`
+	Ultrafiltration            float64 `gorm:"column:ultrafiltration" json:"ultrafiltration" form:"ultrafiltration"`
+	BodyFluidOther             string  `gorm:"column:body_fluid_other" json:"body_fluid_other" form:"body_fluid_other"`
+	TargetKtv                  float64 `gorm:"column:target_ktv" json:"target_ktv" form:"target_ktv"`
+}
+
+func (XtDialysisSolution) TableName() string {
+
+	return "xt_dialysis_prescription"
+}

service/db.go

@@ -31,6 +31,9 @@ var writeUserDb *gorm.DB
 
 var readMiddleDb *gorm.DB
 var writeMiddleDb *gorm.DB
+
+var readPatientDb *gorm.DB
+var writePatientDb *gorm.DB
 var err error
 
 func ConnectDB() {
@@ -70,6 +73,18 @@ func ConnectDB() {
 	writeMiddlePass := beego.AppConfig.String("writemiddlepass")
 	writeMiddleName := beego.AppConfig.String("writemiddlename")
 
+	readPatientHost := beego.AppConfig.String("readpatienthost")
+	readPatientPort := beego.AppConfig.String("readpatientport")
+	readPatientUser := beego.AppConfig.String("readpatientuser")
+	readPatientPass := beego.AppConfig.String("readpatientpass")
+	readPatientName := beego.AppConfig.String("readpatientname")
+
+	writePatientHost := beego.AppConfig.String("writepatienthost")
+	writePatientPort := beego.AppConfig.String("writepatientport")
+	writePatientUser := beego.AppConfig.String("writepatientuser")
+	writePatientPass := beego.AppConfig.String("writepatientpass")
+	writePatientName := beego.AppConfig.String("writepatientname")
+
 	rdsn := fmt.Sprintf("%s:%s@tcp(%s:%s)/%s?charset=utf8mb4&parseTime=true", readUser, readPass, readHost, readPort, readName)
 	wdsn := fmt.Sprintf("%s:%s@tcp(%s:%s)/%s?charset=utf8mb4&parseTime=true", writeUser, writePass, writeHost, writePort, writeName)
 
@@ -79,6 +94,9 @@ func ConnectDB() {
 	rmdsn := fmt.Sprintf("%s:%s@tcp(%s:%s)/%s?charset=utf8mb4&parseTime=true", readMiddleUser, readMiddlePass, readMiddleHost, readMiddlePort, readMiddleName)
 	wmdsn := fmt.Sprintf("%s:%s@tcp(%s:%s)/%s?charset=utf8mb4&parseTime=true", writeMiddleUser, writeMiddlePass, writeMiddleHost, writeMiddlePort, writeMiddleName)
 
+	rpdsn := fmt.Sprintf("%s:%s@tcp(%s:%s)/%s?charset=utf8mb4&parseTime=true", readPatientUser, readPatientPass, readPatientHost, readPatientPort, readPatientName)
+	wpdsn := fmt.Sprintf("%s:%s@tcp(%s:%s)/%s?charset=utf8mb4&parseTime=true", writePatientUser, writePatientPass, writePatientHost, writePatientPort, writePatientName)
+
 	readDb, err = gorm.Open("mysql", rdsn)
 	if err != nil {
 		//beego.Error(err)
@@ -127,6 +145,21 @@ func ConnectDB() {
 	writeMiddleDb.DB().SetMaxOpenConns(100)
 	writeMiddleDb.LogMode(true)
 
+	readPatientDb, err = gorm.Open("mysql", rpdsn)
+	if err != nil {
+		beego.Error(err)
+	}
+	readPatientDb.DB().SetMaxIdleConns(10)
+	readPatientDb.DB().SetMaxOpenConns(100)
+	readPatientDb.LogMode(true)
+
+	writePatientDb, err = gorm.Open("mysql", wpdsn)
+	if err != nil {
+		beego.Error(err)
+	}
+	writePatientDb.DB().SetMaxIdleConns(10)
+	writePatientDb.DB().SetMaxOpenConns(100)
+	writePatientDb.LogMode(true)
 }
 
 //func DisconnectDB() {
@@ -154,3 +187,11 @@ func MiddleReadDB() *gorm.DB {
 func MiddleWriteDB() *gorm.DB {
 	return writeMiddleDb
 }
+
+func PatientReadDB() *gorm.DB {
+	return readPatientDb
+}
+
+func PatientWriteDB() *gorm.DB {
+	return writePatientDb
+}

service/patientmanage_service.go

@@ -6,6 +6,7 @@ import (
 	"github.com/jinzhu/gorm"
 	"strconv"
 	"strings"
+	"time"
 )
 
 func GetIllnessListTwo() (ills []*models.Illness, err error) {
@@ -25,6 +26,42 @@ func GetBloodDialysisPatient(orgid int64, page int64, limit int64) (patients []*
 	return
 }
 
+func GetAllBloodDialysisPatient(orgid int64, page int64, limit int64) (patients []*models.XtPatientsNew, total int64, err error) {
+	db := XTReadDB().Table("xt_patients_new as x").Where("x.status = 1")
+	if orgid > 0 {
+		db = db.Where("x.user_org_id = ? and x.blood_patients = 1", orgid)
+	}
+	offset := (page - 1) * limit
+	err = db.Count(&total).Order("x.created_time desc").Offset(offset).Limit(limit).
+		Select("x.id,x.user_org_id,x.user_id,x.avatar,x.patient_type,x.dialysis_no,x.admission_number,x.source,x.lapseto,x.partition_id,x.bed_id,x.name,x.alias,x.gender,x.marital_status,x.id_card_no,x.birthday,x.reimbursement_way_id,x.health_care_type,x.health_care_no,x.health_care_due_date,x.height,x.blood_type,x.rh,x.health_care_due_alert_date,x.education_level,x.profession,x.phone,x.home_telephone,x.relative_phone,x.relative_relations,x.home_address,x.work_unit,x.unit_address,x.children,x.receiving_date,x.is_hospital_first_dialysis,x.first_dialysis_date,x.first_dialysis_hospital,x.predialysis_condition,x.pre_hospital_dialysis_frequency,x.pre_hospital_dialysis_times,x.hospital_first_dialysis_date,x.induction_period,x.initial_dialysis,x.total_dialysis,x.attending_doctor_id,x.head_nurse_id,x.evaluate,x.diagnose,x.remark,x.registrars_id,x.registrars,x.qr_code,x.binding_state,x.patient_complains,x.present_history,x.past_history,x.temperature,x.pulse,x.respiratory,x.sbp,x.dbp,x.status,x.created_time,x.updated_time,x.nation,x.native_place,x.age,x.blood_patients,x.slow_patients,x.member_patients,x.ecommer_patients,x.blood_id,x.slow_id,x.member_id").Find(&patients).Error
+	fmt.Println("err是什么", err)
+	return
+}
+
+func GetAllSlowPatient(orgid int64, page int64, limit int64) (patients []*models.XtPatientsNew, total int64, err error) {
+	db := XTReadDB().Table("xt_patients_new as x").Where("x.status = 1")
+	if orgid > 0 {
+		db = db.Where("x.user_org_id = ? and x.slow_patients = 1", orgid)
+	}
+	offset := (page - 1) * limit
+	err = db.Count(&total).Order("x.created_time desc").Offset(offset).Limit(limit).
+		Select("x.id,x.user_org_id,x.user_id,x.avatar,x.patient_type,x.dialysis_no,x.admission_number,x.source,x.lapseto,x.partition_id,x.bed_id,x.name,x.alias,x.gender,x.marital_status,x.id_card_no,x.birthday,x.reimbursement_way_id,x.health_care_type,x.health_care_no,x.health_care_due_date,x.height,x.blood_type,x.rh,x.health_care_due_alert_date,x.education_level,x.profession,x.phone,x.home_telephone,x.relative_phone,x.relative_relations,x.home_address,x.work_unit,x.unit_address,x.children,x.receiving_date,x.is_hospital_first_dialysis,x.first_dialysis_date,x.first_dialysis_hospital,x.predialysis_condition,x.pre_hospital_dialysis_frequency,x.pre_hospital_dialysis_times,x.hospital_first_dialysis_date,x.induction_period,x.initial_dialysis,x.total_dialysis,x.attending_doctor_id,x.head_nurse_id,x.evaluate,x.diagnose,x.remark,x.registrars_id,x.registrars,x.qr_code,x.binding_state,x.patient_complains,x.present_history,x.past_history,x.temperature,x.pulse,x.respiratory,x.sbp,x.dbp,x.status,x.created_time,x.updated_time,x.nation,x.native_place,x.age,x.blood_patients,x.slow_patients,x.member_patients,x.ecommer_patients,x.blood_id,x.slow_id,x.member_id").Find(&patients).Error
+	fmt.Println("err是什么", err)
+	return
+}
+
+func GetAllMemberPatient(orgid int64, page int64, limit int64) (patients []*models.XtPatientsNew, total int64, err error) {
+	db := XTReadDB().Table("xt_patients_new as x").Where("x.status = 1")
+	if orgid > 0 {
+		db = db.Where("x.user_org_id = ? and x.member_patients = 1", orgid)
+	}
+	offset := (page - 1) * limit
+	err = db.Count(&total).Order("x.created_time desc").Offset(offset).Limit(limit).
+		Select("x.id,x.user_org_id,x.user_id,x.avatar,x.patient_type,x.dialysis_no,x.admission_number,x.source,x.lapseto,x.partition_id,x.bed_id,x.name,x.alias,x.gender,x.marital_status,x.id_card_no,x.birthday,x.reimbursement_way_id,x.health_care_type,x.health_care_no,x.health_care_due_date,x.height,x.blood_type,x.rh,x.health_care_due_alert_date,x.education_level,x.profession,x.phone,x.home_telephone,x.relative_phone,x.relative_relations,x.home_address,x.work_unit,x.unit_address,x.children,x.receiving_date,x.is_hospital_first_dialysis,x.first_dialysis_date,x.first_dialysis_hospital,x.predialysis_condition,x.pre_hospital_dialysis_frequency,x.pre_hospital_dialysis_times,x.hospital_first_dialysis_date,x.induction_period,x.initial_dialysis,x.total_dialysis,x.attending_doctor_id,x.head_nurse_id,x.evaluate,x.diagnose,x.remark,x.registrars_id,x.registrars,x.qr_code,x.binding_state,x.patient_complains,x.present_history,x.past_history,x.temperature,x.pulse,x.respiratory,x.sbp,x.dbp,x.status,x.created_time,x.updated_time,x.nation,x.native_place,x.age,x.blood_patients,x.slow_patients,x.member_patients,x.ecommer_patients,x.blood_id,x.slow_id,x.member_id").Find(&patients).Error
+	fmt.Println("err是什么", err)
+	return
+}
+
 func GetAllPatient(orgid int64) (patients []*models.PatientsNew, err error) {
 	db := XTReadDB().Table("xt_patients_new as x")
 
@@ -46,6 +83,44 @@ func ChechLastDialysisNoTwo(orgID int64) (dialysisNo int64) {
 	return
 }
 
+func GetBloodPatientInfo(orgid int64, phone string) (*models.Patients, error) {
+	patients := models.Patients{}
+	var err error
+	err = XTReadDB().Model(&patients).Where("user_org_id = ? and phone = ? and status = 1", orgid, phone).Find(&patients).Error
+	if err == gorm.ErrRecordNotFound {
+		return nil, err
+	}
+	if err != nil {
+		return nil, err
+	}
+	return &patients, nil
+}
+
+func GetSlowPatientInfo(orgid int64, phone string) (*models.CdmPatients, error) {
+	patients := models.CdmPatients{}
+	var err error
+	err = PatientReadDB().Model(&patients).Where("user_org_id = ? and phone = ? and status = 1", orgid, phone).Find(&patients).Error
+	if err == gorm.ErrRecordNotFound {
+		return nil, err
+	}
+	if err != nil {
+		return nil, err
+	}
+	return &patients, nil
+}
+
+func GetMemberPatientInfo(orgid int64, phone string) (*models.SgjUserCustomer, error) {
+	customer := models.SgjUserCustomer{}
+	err := UserReadDB().Model(&customer).Where("user_org_id = ? and mobile = ? and status =1", orgid, phone).Find(&customer).Error
+	if err == gorm.ErrRecordNotFound {
+		return nil, err
+	}
+	if err != nil {
+		return nil, err
+	}
+	return &customer, nil
+}
+
 func CreateOldPatient(patients *models.Patients) error {
 
 	err := XTWriteDB().Create(&patients).Error
@@ -58,11 +133,103 @@ func GetLastOldPatient(orgid int64) (models.Patients, error) {
 	return patients, err
 }
 
+func AddContagions(patienid int64, createdtime int64, updatedtime int64, contagions []int64) (err error) {
+	utx := writeDb.Begin()
+	if len(contagions) > 0 {
+		thisSQL := "INSERT INTO xt_patients_infectious_diseases (patient_id, disease_id, status, created_time, updated_time) VALUES "
+		insertParams := make([]string, 0)
+		insertData := make([]interface{}, 0)
+		for _, contagion := range contagions {
+			insertParams = append(insertParams, "(?, ?, ?, ?, ?)")
+			insertData = append(insertData, patienid)
+			insertData = append(insertData, contagion)
+			insertData = append(insertData, 1)
+			insertData = append(insertData, createdtime)
+			insertData = append(insertData, updatedtime)
+		}
+		thisSQL += strings.Join(insertParams, ",")
+		err = utx.Exec(thisSQL, insertData...).Error
+		fmt.Println("这个错误err", err)
+	}
+	utx.Commit()
+	return
+}
+
+func AddSlowContagions(patienid int64, createdtime int64, updatedtime int64, contagions []int64, orgid int64) (err error) {
+	utx := PatientWriteDB().Begin()
+	if len(contagions) > 0 {
+		thisSQL := "INSERT INTO xt_patients_infectious_diseases (patient_id, disease_id, status, created_time, updated_time,user_org_id) VALUES "
+		insertParams := make([]string, 0)
+		insertData := make([]interface{}, 0)
+		for _, contagion := range contagions {
+			insertParams = append(insertParams, "(?, ?, ?, ?, ?,?)")
+			insertData = append(insertData, patienid)
+			insertData = append(insertData, contagion)
+			insertData = append(insertData, 1)
+			insertData = append(insertData, createdtime)
+			insertData = append(insertData, updatedtime)
+			insertData = append(insertData, orgid)
+		}
+		thisSQL += strings.Join(insertParams, ", ")
+		err = utx.Exec(thisSQL, insertData...).Error
+		if err != nil {
+			utx.Rollback()
+			utx.Rollback()
+			return
+		}
+	}
+	utx.Commit()
+	return
+}
+
+func AddSlowDiseases(patienid int64, createdtime int64, updatedtime int64, diseases []int64, orgid int64) (err error) {
+	utx := PatientWriteDB().Begin()
+	if len(diseases) > 0 {
+		thisSQL := "INSERT INTO xt_patients_chronic_diseases (patient_id, disease_id, status, created_time, updated_time,user_org_id) VALUES "
+		insertParams := make([]string, 0)
+		insertData := make([]interface{}, 0)
+		for _, disease := range diseases {
+			insertParams = append(insertParams, "(?, ?, ?, ?, ?,?)")
+			insertData = append(insertData, patienid)
+			insertData = append(insertData, disease)
+			insertData = append(insertData, 1)
+			insertData = append(insertData, createdtime)
+			insertData = append(insertData, updatedtime)
+			insertData = append(insertData, orgid)
+		}
+		thisSQL += strings.Join(insertParams, ", ")
+		err = utx.Exec(thisSQL, insertData...).Error
+		if err != nil {
+			utx.Rollback()
+			return
+		}
+	}
+	utx.Commit()
+	return
+}
+
 func CreateNewPatient(patientsNew *models.XtPatientsNew) error {
 	err := XTWriteDB().Create(&patientsNew).Error
 	return err
 }
 
+func CreateCdmPatient(cdmpatient *models.CdmPatients) error {
+	err := PatientWriteDB().Create(&cdmpatient).Error
+	return err
+}
+
+func CreateMemberPatient(customer *models.SgjUserCustomer) error {
+
+	err := UserWriteDB().Create(&customer).Error
+	return err
+}
+
+func GetOldCdmPatient(orgid int64) (models.CdmPatients, error) {
+	patients := models.CdmPatients{}
+	err := XTReadDB().Model(&patients).Where("user_org_id = ? and status =1", orgid).Last(&patients).Error
+	return patients, err
+}
+
 func GetPatientDetailTwo(id int64) (models.XtPatientsNew, error) {
 	patients := models.XtPatientsNew{}
 	err := XTReadDB().Where("id=? and status = 1", id).Find(&patients).Error
@@ -189,10 +356,46 @@ func CreatePatientTwo(patient *models.Patients, contagions []int64, diseases []i
 	return
 }
 
-func GetPatientData(phone string, orgid int64) (*models.Patients, error) {
-	var patientnew models.Patients
+func GetPatientData(phone string, orgid int64) (*models.XtPatientsNew, error) {
+	var patientnew models.XtPatientsNew
 	var err error
-	err = XTReadDB().Model(&patientnew).Where("user_org_id = ? and phone = ? and status =?", orgid, phone, 1).Find(&patientnew).Error
+	err = XTReadDB().Model(&patientnew).Where("user_org_id = ? and phone = ? and status =? and blood_patients = ?", orgid, phone, 1, 1).Find(&patientnew).Error
+	if err == gorm.ErrRecordNotFound {
+		return nil, err
+	}
+	if err != nil {
+		return nil, err
+	}
+	return &patientnew, nil
+}
+
+func GetSlowPatientData(phone string, orgid int64) (*models.CdmPatients, error) {
+	var patientnew models.CdmPatients
+	err = PatientReadDB().Model(&patientnew).Where("user_org_id = ? and phone = ? and status = ?", orgid, phone, 1).Find(&patientnew).Error
+	if err == gorm.ErrRecordNotFound {
+		return nil, err
+	}
+	if err != nil {
+		return nil, err
+	}
+	return &patientnew, nil
+}
+
+func GetMemberNewPatient(phone string, orgid int64) (*models.XtPatientsNew, error) {
+	var patientnew models.XtPatientsNew
+	err = XTReadDB().Model(&patientnew).Where("user_org_id = ? and phone = ? and status = ? and member_patients = ?", orgid, phone, 1, 1).Find(&patientnew).Error
+	if err == gorm.ErrRecordNotFound {
+		return nil, err
+	}
+	if err != nil {
+		return nil, err
+	}
+	return &patientnew, nil
+}
+
+func GetLastNewSlowPatient(phone string, orgid int64) (*models.XtPatientsNew, error) {
+	var patientnew models.XtPatientsNew
+	err = XTReadDB().Model(&patientnew).Where("user_org_id = ? and phone = ? and status = ? and slow_patients = ?", orgid, phone, 1, 1).Find(&patientnew).Error
 	if err == gorm.ErrRecordNotFound {
 		return nil, err
 	}
@@ -251,3 +454,69 @@ func ToSearch(orgId int64, name string) (patient []*models.XtPatientsNew, err er
 	err = XTReadDB().Where("name like ? and user_org_id = ?", likeKey, orgId).Find(&patient).Error
 	return patient, err
 }
+
+func GetCourseManagement(patientid int64, startime int64, endtime int64, limit int64, page int64, orgid int64) (patientCourse []*models.PatientCourseOfDiseases, total int64, err error) {
+	db := XTReadDB().Table("xt_patient_course_of_disease as x").Where("x.status = 1")
+	if patientid > 0 {
+		db = db.Where("x.patient_id = ?", patientid)
+	}
+	if orgid > 0 {
+		db = db.Where("x.org_id = ?", orgid)
+	}
+	if startime > 0 {
+		db = db.Where("x.record_time >=?", startime)
+	}
+	if endtime > 0 {
+		db = db.Where("x.record_time <= ?", endtime)
+	}
+	offset := (page - 1) * limit
+	err = db.Count(&total).Order("x.ctime desc").Offset(offset).Limit(limit).Group("x.id").
+		Select("x.id,x.org_id,x.patient_id,x.recorder,x.record_time,x.content,x.title,r.user_name").Joins("left join sgj_users.sgj_user_admin_role as r on r.admin_user_id = x.recorder").Scan(&patientCourse).Error
+	return patientCourse, total, err
+}
+
+func DeleteCouseManagement(patientid int64) error {
+
+	err := XTWriteDB().Model(models.PatientCourseOfDisease{}).Where("id = ?", patientid).Update(map[string]interface{}{"status": 0, "mtime": time.Now().Unix()}).Error
+	return err
+}
+
+func GetCouseManagentDetail(id int64) (models.PatientCourseOfDiseasess, error) {
+	disease := models.PatientCourseOfDiseasess{}
+	db := XTReadDB().Table("xt_patient_course_of_disease as x")
+	err := db.Select("x.id,x.org_id,x.patient_id,x.recorder,x.record_time,x.content,x.title,s.name,r.user_name").Joins("left join xt_patients as s on s.id = x.patient_id ").Joins("left join sgj_users.sgj_user_admin_role as r on r.admin_user_id = x.recorder").Where("x.id = ?", id).Scan(&disease).Error
+	return disease, err
+}
+
+func DeleteDryWeight(id int64) error {
+	err := XTWriteDB().Model(models.SgjPatientDryweight{}).Where("id=?", id).Update(map[string]interface{}{"status": 0, "mtime": time.Now().Unix()}).Error
+	return err
+}
+
+func GetDryWeightDetail(id int64) (models.SgjPatientDryweights, error) {
+	dryweight := models.SgjPatientDryweights{}
+	db := XTReadDB().Table("xt_patient_dryweight as x")
+	err := db.Select("x.id,x.dry_weight,x.creator,x.remakes,x.patient_id,x.adjusted_value,x.user_org_id,x.user_id,x.ctime,s.name,r.user_name").Joins("left join xt_patients as s on s.id = x.patient_id").Joins("left join sgj_users.sgj_user_admin_role as r on r.admin_user_id = x.user_id").Where("x.id = ?", id).Scan(&dryweight).Error
+	return dryweight, err
+}
+
+func GetlongDialysisrecord(patientid int64, startime int64, endtime int64, limit int64, page int64, orgid int64) (prescription []*models.XtDialysisSolution, total int64, err error) {
+	db := XTReadDB().Table("xt_dialysis_solution as x").Where("x.status = 1")
+	if patientid > 0 {
+		db = db.Where("x.patient_id = ?", patientid)
+	}
+	if orgid > 0 {
+		db = db.Where("x.user_org_id = ?", orgid)
+	}
+	if startime > 0 {
+		db = db.Where("x.created_time >=?", startime)
+	}
+	if endtime > 0 {
+		db = db.Where("x.created_time <= ?", endtime)
+	}
+	offset := (page - 1) * limit
+	err = db.Count(&total).Order("x.created_time desc").Offset(offset).Limit(limit).Group("x.id").
+		Select("x.id,x.name,x.sub_name,x.user_org_id,x.patient_id,x.parent_id,x.type,x.period,x.times,x.anticoagulant,x.anticoagulant_shouji,x.anticoagulant_weichi,x.anticoagulant_zongliang,x.anticoagulant_gaimingcheng,x.anticoagulant_gaijiliang,x.mode_name,x.mode_id,x.dialysis_duration,x.replacement_way,x.hemodialysis_machine,x.blood_filter,x.perfusion_apparatus,x.blood_flow_volume,x.dewater,x.displace_liqui,x.glucose,x.dry_weight,x.dialysate_flow,x.kalium,x.sodium,x.calcium,x.bicarbonate,x.doctor,x.first_dialysis,x.remark,x.initiate_mode,x.affirm_state,x.use_state,x.status,x.registrars_id,x.created_time,x.updated_time,x.solution_type,x.dialysate_temperature,x.conductivity,x.dialysis_duration_hour,x.dialysis_duration_minute,x.target_ultrafiltration,x.dialysate_formulation,x.dialyzer,x.replacement_total,x.dialyzer_perfusion_apparatus,x.body_fluid,x.special_medicine,x.special_medicine_other,x.displace_liqui_part,x.displace_liqui_value,x.blood_access,x.ultrafiltration,x.body_fluid_other,x.target_ktv").Find(&prescription).Error
+
+	return
+}