11月8日库存管理

controllers/new_mobile_api_controllers/staff_schedule_api_controller.go

@@ -372,22 +372,10 @@ func (this *StaffScheduleApiController) UpdatePatientScheduleById() {
 		"msg": "切换成功",
 	})
 }
-
-func (this *StaffScheduleApiController) UpdateBloodSchedule() {
-
-	id, _ := this.GetInt64("id")
+func (this *StaffScheduleApiController) UpdateDialysisPrescription() {
 	patient_id, _ := this.GetInt64("patient_id")
-	mode_id, _ := this.GetInt64("mode_id")
-	schedule_type, _ := this.GetInt64("schedule_type")
 	start_time, _ := this.GetInt64("start_time")
 	dialyzer_perfusion_apparatus := this.GetString("dialyzer_perfusion_apparatus")
-	//更改排班
-	schedule := models.XtSchedule{
-		ScheduleType: schedule_type,
-		ModeId:       mode_id,
-	}
-	service.UpdatedSchedule(schedule, id)
-
 	//更改透析模式
 	_, errcode := service.GetDialyisSolution(patient_id, start_time)
 	if errcode == gorm.ErrRecordNotFound {
@@ -411,6 +399,45 @@ func (this *StaffScheduleApiController) UpdateBloodSchedule() {
 	}
 }
 
+func (this *StaffScheduleApiController) UpdateBloodScheduleMode() {
+	id, _ := this.GetInt64("id")
+	mode_id, _ := this.GetInt64("mode_id")
+	schedule := models.XtSchedule{
+		ModeId: mode_id,
+	}
+	service.UpdatedScheduleMode(schedule, id)
+	this.ServeSuccessJSON(map[string]interface{}{
+		"msg": "保存成功",
+	})
+}
+
+func (this *StaffScheduleApiController) UpdateBloodSchedule() {
+
+	patient_id, _ := this.GetInt64("patient_id")
+	mode_id, _ := this.GetInt64("mode_id")
+	schedule_type, _ := this.GetInt64("schedule_type")
+	start_time, _ := this.GetInt64("start_time")
+	dialyzer_perfusion_apparatus := this.GetString("dialyzer_perfusion_apparatus")
+	bed_id, _ := this.GetInt64("bed_id")
+	//更改排班
+	schedule := models.XtSchedule{
+		ScheduleType: schedule_type,
+		ModeId:       mode_id,
+	}
+
+	//查询该床位该班次是否存在排班
+	_, errschedulecode := service.GetPatientScheduleIsExist(patient_id, start_time, schedule_type, bed_id)
+	if errschedulecode == gorm.ErrRecordNotFound {
+		service.UpdatedSchedule(schedule, patient_id, start_time, schedule_type, bed_id)
+	} else if errschedulecode == nil {
+		this.ServeSuccessJSON(map[string]interface{}{
+			"msg":    "1",
+			"msgerr": "排班已存在",
+		})
+	}
+
+}
+
 func (this *StaffScheduleApiController) GetSchedulePatient() {
 
 	schedule, _ := this.GetInt64("schedule", 0) //1已2未

controllers/new_mobile_api_controllers/staff_schedule_api_router.go

@@ -20,6 +20,8 @@ func StaffScheduleApiControllersRegisterRouters() {
 	beego.Router("/m/api/deleteSchedule", &StaffScheduleApiController{}, "Get:DeleteSchedule")
 	beego.Router("/m/api/ssearchpatient", &StaffScheduleApiController{}, "Get:SearchPatient")
 	beego.Router("/m/api/updatepatientschedule", &StaffScheduleApiController{}, "Get:UpdatePatientScheduleById")
+	beego.Router("/m/api/updateschedulemode", &StaffScheduleApiController{}, "Get:UpdateBloodScheduleMode")
+	beego.Router("/m/api/updatedialysisprescription", &StaffScheduleApiController{}, "Get:UpdateDialysisPrescription")
 	beego.Router("/m/api/updateschedule", &StaffScheduleApiController{}, "Get:UpdateBloodSchedule")
 	beego.Router("m/api/schedule/patients", &StaffScheduleApiController{}, "Get:GetSchedulePatient")
 	beego.Router("/m/api/schedule/create", &StaffScheduleApiController{}, "Post:CreateMobileSchedulePatient")

service/doctor_schedule_service.go

@@ -668,10 +668,17 @@ func UpdateStaffScheduleOne(nextid int64, schedule models.WeekSchedule) error {
 	return err
 }
 
-func UpdatedSchedule(schedule models.XtSchedule, id int64) error {
+func UpdatedScheduleMode(schedule models.XtSchedule, id int64) error {
 
 	xtSchedule := models.XtSchedule{}
-	err := XTWriteDB().Model(&xtSchedule).Where("id = ? and status =1", id).Updates(map[string]interface{}{"schedule_type": schedule.ScheduleType, "mode_id": schedule.ModeId}).Error
+	err := XTWriteDB().Model(&xtSchedule).Where("id = ? and status =1 ", id).Updates(map[string]interface{}{"mode_id": schedule.ModeId}).Error
+	return err
+}
+
+func UpdatedSchedule(schedule models.XtSchedule, patient_id int64, schedule_date int64, schedule_type int64, bed_id int64) error {
+
+	xtSchedule := models.XtSchedule{}
+	err := XTWriteDB().Model(&xtSchedule).Where("patient_id = ? and status =1 and schedule_date = ? and schedule_type = ? and bed_id = ?", patient_id, schedule_date, schedule_type, bed_id).Updates(map[string]interface{}{"schedule_type": schedule.ScheduleType, "mode_id": schedule.ModeId}).Error
 	return err
 }