更新代码

controllers/new_mobile_api_controllers/new_dialysis_api_controller.go

@@ -321,10 +321,10 @@ func (this *NewDialysisApiController) SavePatient() {
 			}
 			errcodetwo := service.CreateCdmPatient(&patients)
 			fmt.Print("报错", errcodetwo)
-			patient, errcodetwo := service.GetOldCdmPatient(orgid)
-			errcodetwo = service.AddSlowContagions(patient.ID, patient.CreatedTime, patient.UpdatedTime, idss, orgid)
+			slowPatient, errcodetwo := service.GetOldCdmPatient(orgid)
+			errcodetwo = service.AddSlowContagions(slowPatient.ID, slowPatient.CreatedTime, slowPatient.UpdatedTime, idss, orgid)
 			fmt.Print("添加慢病传染病失败", errcodetwo)
-			errcodethree := service.AddSlowDiseases(patient.ID, patient.CreatedTime, patient.UpdatedTime, idsss, orgid)
+			errcodethree := service.AddSlowDiseases(slowPatient.ID, slowPatient.CreatedTime, slowPatient.UpdatedTime, idsss, orgid)
 			fmt.Print("添加慢性病失败", errcodethree)
 
 			_, errcodefour := service.GetLastNewSlowPatient(phone, orgid)
@@ -348,7 +348,7 @@ func (this *NewDialysisApiController) SavePatient() {
 					MemberPatients:    memberpatient,
 					BloodPatients:     bloodPatient,
 					SlowPatients:      slowpatient,
-					BloodId:           patient.ID,
+					SlowId:            slowPatient.ID,
 				}
 				err = service.CreateNewPatient(&patientsNew)
 				if err != nil {
@@ -360,6 +360,73 @@ func (this *NewDialysisApiController) SavePatient() {
 				})
 			} else if errcodetwo == nil {
 				fmt.Print("病人已存在")
+				if memberpatient == 1 {
+					fmt.Print("进来没有", memberpatient)
+					_, 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)
+						_, errmembercodetwo := service.GetMemberNewPatient(phone, orgid)
+						fmt.Print("错误", errmembercodetwo)
+						//获取机构的最后一条数据
+						memberPatient, errmembercode := service.GetLastMemberPatient(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,
+								MemberId:          memberPatient.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 errmembercode == nil {
+							fmt.Print("病人已存在")
+							return
+						} else {
+
+						}
+					} else if errmembercode == nil {
+						fmt.Print("病人已存在")
+						return
+					} else {
+
+					}
+				}
 				return
 			} else {
 
@@ -375,6 +442,7 @@ func (this *NewDialysisApiController) SavePatient() {
 	}
 
 	if memberpatient == 1 {
+		fmt.Print("进来没有", memberpatient)
 		_, errmembercode := service.GetMemberPatientInfo(orgid, phone)
 		if errmembercode == gorm.ErrRecordNotFound {
 			customer := models.SgjUserCustomer{
@@ -392,7 +460,10 @@ func (this *NewDialysisApiController) SavePatient() {
 			}
 			errmembercode := service.CreateMemberPatient(&customer)
 			fmt.Print("创建会员病人失败", errmembercode)
-			patient, errmembercodetwo := service.GetMemberNewPatient(phone, orgid)
+			_, errmembercodetwo := service.GetMemberNewPatient(phone, orgid)
+			fmt.Print("错误", errmembercodetwo)
+			//获取机构的最后一条数据
+			memberPatient, errmembercode := service.GetLastMemberPatient(orgid)
 			if errmembercodetwo == gorm.ErrRecordNotFound {
 				patientsNew := models.XtPatientsNew{
 					Name:              name,
@@ -413,9 +484,10 @@ func (this *NewDialysisApiController) SavePatient() {
 					MemberPatients:    memberpatient,
 					BloodPatients:     bloodPatient,
 					SlowPatients:      slowpatient,
-					BloodId:           patient.ID,
+					MemberId:          memberPatient.ID,
 				}
 				err = service.CreateNewPatient(&patientsNew)
+				fmt.Print("报错-----------------------", err)
 				if err != nil {
 					this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
 					return

service/patientmanage_service.go

@@ -226,7 +226,7 @@ func CreateMemberPatient(customer *models.SgjUserCustomer) error {
 
 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
+	err := PatientReadDB().Model(&patients).Where("user_org_id = ? and status =1", orgid).Last(&patients).Error
 	return patients, err
 }
 
@@ -393,6 +393,12 @@ func GetMemberNewPatient(phone string, orgid int64) (*models.XtPatientsNew, erro
 	return &patientnew, nil
 }
 
+func GetLastMemberPatient(orgid int64) (models.SgjUserCustomer, error) {
+	customer := models.SgjUserCustomer{}
+	err := UserReadDB().Model(&customer).Where("user_org_id = ? and status = 1", orgid).Last(&customer).Error
+	return customer, err
+}
+
 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