合并代码

controllers/dialysis_api_controller.go

 		} else {
 			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeAdminUserIsExit)
 			return
-
 		}
-
 	} else {
 		this.ServeSuccessJSON(map[string]interface{}{
 			"is_has_create":       true,
 			"is_has_modify_exce":  true,
 			"module":              true,
 		})
-
 	}
-
 }

controllers/patient_api_controller.go

 	beego.Router("/api/patients/export", &PatientApiController{}, "Post:ExportPatients")
 
 	beego.Router("/api/patients/advices/saveditadvices", &PatientApiController{}, "Get:SaveEditAdvices")
+
+	beego.Router("/api/patients/dialysis_no", &PatientApiController{}, "Get:GetMaxDialysisNo")
+
 }
 
 //GetPatientsList 取患者列表
 
 func (c *PatientApiController) ExportPatients() {
 	dataBody := make(map[string]interface{}, 0)
-	dialysisNo := service.ChechLastDialysisNo(c.GetAdminUserInfo().CurrentOrgId)
-	if dialysisNo == 0 {
-		dialysisNo = 1
-	} else {
-		dialysisNo++
-	}
+
+	all_patient, _, _ := service.GetAllPatientList(c.GetAdminUserInfo().CurrentOrgId)
+
+	//all_patient, _,_ := service.GetAllPatientList(c.GetAdminUserInfo().CurrentOrgId )
+
+	org, _ := service.GetOrgById(c.GetAdminUserInfo().CurrentOrgId)
 
 	err := json.Unmarshal(c.Ctx.Input.RequestBody, &dataBody)
 	if err != nil {
 	export_time := time.Now().Unix()
 	var patients []*models.Patients
 	var total_patients []interface{}
-
 	if dataBody["patients"] != nil || reflect.TypeOf(dataBody["patients"]).String() == "[]interface {}" {
 		tempPatients := dataBody["patients"].([]interface{})
 		total_patients = tempPatients
 					service.CreateExportErrLog(&err_log)
 					continue
 				} else {
+					var tempPatient *models.Patients
+					for _, item := range all_patient {
+						if item.Phone == phone {
+							tempPatient = item
+						}
+					}
+
 					//需要判断该号码是否已经在系统内存在了，存在了则生成一条导入错误日志
-					count := service.FindPatientPhoneIsExist(phone, c.GetAdminUserInfo().CurrentOrgId)
-					if count > 0 {
+					//count := service.FindPatientPhoneIsExist(phone, c.GetAdminUserInfo().CurrentOrgId)
+					if tempPatient != nil && tempPatient.ID > 0 {
 						err_log := models.ExportErrLog{
 							LogType:    1,
 							UserOrgId:  c.GetAdminUserInfo().CurrentOrgId,
 
 			if patientNameM["id_card_no"] != nil || reflect.TypeOf(patientNameM["id_card_no"]).String() == "string" {
 				id_card_no, _ := patientNameM["id_card_no"].(string)
-				fmt.Println(id_card_no)
-
+				fmt.Println(IsIdCard(id_card_no))
 				if IsIdCard(id_card_no) == false { //身份证号码不符合要求则生成一条导入错误日志
 					err_log := models.ExportErrLog{
 						LogType:    1,
 					service.CreateExportErrLog(&err_log)
 					continue
 				} else {
-					count := service.FindPatientIdCardNoIsExist(id_card_no, c.GetAdminUserInfo().CurrentOrgId)
-					if count > 0 {
+					var tempPatient *models.Patients
+					for _, item := range all_patient {
+						if item.IdCardNo == id_card_no {
+							tempPatient = item
+						}
+					}
+					//count := service.FindPatientIdCardNoIsExist(id_card_no, c.GetAdminUserInfo().CurrentOrgId)
+					if tempPatient != nil && tempPatient.ID > 0 {
 						err_log := models.ExportErrLog{
 							LogType:    1,
 							UserOrgId:  c.GetAdminUserInfo().CurrentOrgId,
 				patient.Diagnose = diagnose
 
 			}
-			dialysisNo = dialysisNo + int64(index)
 
-			no := strconv.FormatInt(dialysisNo, 10)
-			rep := 3 - len(no)
+			if patientNameM["dialysis_no"] != nil || reflect.TypeOf(patientNameM["dialysis_no"]).String() == "string" {
+				dialysis_no, _ := patientNameM["dialysis_no"].(string)
+
+				var tempPatient *models.Patients
+				for _, item := range all_patient {
+					if item.DialysisNo == dialysis_no {
+						tempPatient = item
+					}
+				}
+				if tempPatient != nil && tempPatient.ID > 0 {
+					err_log := models.ExportErrLog{
+						LogType:    1,
+						UserOrgId:  c.GetAdminUserInfo().CurrentOrgId,
+						ErrMsg:     "第" + strconv.Itoa(index+3) + "行" + "的透析号在系统中已经存在",
+						Status:     1,
+						CreateTime: time.Now().Unix(),
+						UpdateTime: time.Now().Unix(),
+						ExportTime: export_time,
+					}
+					service.CreateExportErrLog(&err_log)
+					continue
+				}
+
+				patient.DialysisNo = dialysis_no
+
+			}
+
+			if patientNameM["height"] != nil || reflect.TypeOf(patientNameM["height"]).String() == "string" {
+				height, _ := patientNameM["height"].(string)
+				heights, _ := strconv.ParseFloat(height, 64)
+				patient.Height = int64(heights)
+			}
+
+			if patientNameM["home_address"] != nil || reflect.TypeOf(patientNameM["home_address"]).String() == "string" {
+				home_address, _ := patientNameM["home_address"].(string)
+				patient.HomeAddress = home_address
+			}
+			if patientNameM["dry_weight"] != nil || reflect.TypeOf(patientNameM["dry_weight"]).String() == "string" {
+				dry_weight, _ := patientNameM["dry_weight"].(string)
+				dry_weights, _ := strconv.ParseFloat(dry_weight, 64)
+				patient.DryWeight = dry_weights
 
-			if rep > 0 {
-				no = strings.Repeat("0", rep) + no
 			}
 
-			patient.DialysisNo = no
 			patient.CreatedTime = time.Now().Unix()
 			patient.UpdatedTime = time.Now().Unix()
 			patient.Status = 1
 
 	if len(patients) > 0 {
 		for _, item := range patients {
-			service.CreateExportPatient(item, item.ContagionIds)
+			service.CreateExportPatient(item, item.ContagionIds, org.Creator)
 		}
 
 		log := models.ExportLog{
 	adminInfo := c.GetAdminUserInfo()
 	orgid := adminInfo.CurrentOrgId
 	startTime := c.GetString("start_time")
-	fmt.Println("开始时间", startTime)
+
 	theTime, _ := utils.ParseTimeStringToTime("2006-01-02 15:04", startTime)
-	fmt.Println(theTime.Unix())
+
 	groupno, _ := c.GetInt64("groupno")
 	fmt.Println("组", groupno)
 	date, _ := c.GetInt64("date")
 		"advice": advice,
 	})
 }
+
+func (c *PatientApiController) GetMaxDialysisNo() {
+	dialysisNo := service.ChechLastDialysisNo(c.GetAdminUserInfo().CurrentOrgId)
+	c.ServeSuccessJSON(map[string]interface{}{
+		"dialysis_no": dialysisNo,
+	})
+
+}

controllers/schedule_api_controller.go

 				return
 			}
 
+			partition_name, _ := schMapM["partition_name"].(string)
+			zone, _ := service.FindDeviceZoneByName(partition_name, this.GetAdminUserInfo().CurrentOrgId)
+
 			device_number_name, _ := schMapM["device_number_name"].(string)
 			if len(device_number_name) == 0 { //分区为空
 				log := models.ExportLog{
 				return
 
 			} else {
-				device, err := service.FindDeviceByNameTwo(device_number_name, this.GetAdminUserInfo().CurrentOrgId)
+				device, err := service.FindDeviceByNameTwo(device_number_name, this.GetAdminUserInfo().CurrentOrgId, zone.ID)
 				if err == nil {
 					if len(device) == 0 { //没查到数据，插入错误日志
 						log := models.ExportLog{

models/patient_models.go

 	IsExcelExport            int64  `gorm:"column:is_excel_export" json:"is_excel_export" form:"is_excel_export"`
 
 	ContagionIds []int64 `gorm:"-"`
+	DryWeight    float64 `gorm:"-"`
 }
 
 func (Patients) TableName() string {

service/patient_service.go

 	return schedule, err
 }
 
-func CreateExportPatient(patient *models.Patients, contagions []int64) (err error) {
+func CreateExportPatient(patient *models.Patients, contagions []int64, org_creator int64) (err error) {
 	user, _ := GetSgjUserByMobild(patient.Phone)
 	customer, _ := GetSgjCoustomerByMobile(patient.UserOrgId, patient.Phone)
 	utx := writeDb.Begin()
 		return
 	}
 
+	var dryWeight models.SgjPatientDryweight
+	dryWeight.PatientId = patient.ID
+	dryWeight.UserOrgId = patient.UserOrgId
+	dryWeight.Status = 1
+	dryWeight.AdjustedValue = "/"
+	dryWeight.Creator = org_creator
+	dryWeight.UserId = org_creator
+	dryWeight.Ctime = time.Now().Unix()
+	dryWeight.Mtime = time.Now().Unix()
+	dryWeight.DryWeight = patient.DryWeight
+	dryWeight.Remakes = ""
+	err = utx.Create(&dryWeight).Error
+
 	var lapseto models.PatientLapseto
 	lapseto.PatientId = patient.ID
 	lapseto.LapsetoType = patient.Lapseto

service/schedule_service.go

 	return
 }
 
-func FindDeviceByNameTwo(device_name string, org_id int64) (devices []*models.DeviceNumber, err error) {
-	err = readDb.Model(&models.DeviceNumber{}).Where("org_id = ? AND number = ? AND status = 1", org_id, device_name).Find(&devices).Error
+func FindDeviceByNameTwo(device_name string, org_id int64, zone_id int64) (devices []*models.DeviceNumber, err error) {
+	err = readDb.Model(&models.DeviceNumber{}).Where("org_id = ? AND number = ? AND status = 1 AND zone_id = ?", org_id, device_name, zone_id).Find(&devices).Error
 	return
 }