11月8日库存管理

controllers/new_mobile_api_controllers/staff_schedule_api_controller.go

@@ -375,6 +375,7 @@ func (this *StaffScheduleApiController) UpdatePatientScheduleById() {
 func (this *StaffScheduleApiController) UpdateDialysisPrescription() {
 	patient_id, _ := this.GetInt64("patient_id")
 	start_time, _ := this.GetInt64("start_time")
+	mode_id, _ := this.GetInt64("mode_id")
 	dialyzer_perfusion_apparatus := this.GetString("dialyzer_perfusion_apparatus")
 	//更改透析模式
 	_, errcode := service.GetDialyisSolution(patient_id, start_time)
@@ -388,8 +389,10 @@ func (this *StaffScheduleApiController) UpdateDialysisPrescription() {
 			Status:                     1,
 			RecordDate:                 start_time,
 			CreatedTime:                time.Now().Unix(),
+			ModeId:                     mode_id,
 		}
 		err := service.CreateDialysisPrescription(&prescription)
+
 		if err != nil {
 			this.ServeFailJsonSend(enums.ErrorCodeDataException, "添加设备失败")
 			return
@@ -401,8 +404,9 @@ func (this *StaffScheduleApiController) UpdateDialysisPrescription() {
 		prescription := models.DialysisPrescription{
 			DialyzerPerfusionApparatus: dialyzer_perfusion_apparatus,
 			DialysisDialyszers:         dialyzer_perfusion_apparatus,
+			ModeId:                     mode_id,
 		}
-		err := service.UpdateDialysisPrescriptionOne(prescription, patient_id, start_time)
+		err := service.UpdateDialysisPrescriptionOne(prescription, patient_id, start_time, mode_id)
 		if err != nil {
 			this.ServeFailJsonSend(enums.ErrorCodeDataException, "添加设备失败")
 			return

service/doctor_schedule_service.go

@@ -717,8 +717,14 @@ func CreateDialysisPrescription(prescription *models.DialysisPrescription) error
 	return err
 }
 
-func UpdateDialysisPrescriptionOne(prescription models.DialysisPrescription, patientid int64, recordate int64) error {
+func CreateDialysisSolution(solution models.DialysisSolution) error {
 
-	err := XTReadDB().Model(&prescription).Where("patient_id = ? and record_date = ? and status = 1", patientid, recordate).Updates(map[string]interface{}{"dialysis_dialyszers": prescription.DialysisDialyszers, "dialyzer_perfusion_apparatus": prescription.DialyzerPerfusionApparatus}).Error
+	err := XTReadDB().Create(&solution).Error
+	return err
+}
+
+func UpdateDialysisPrescriptionOne(prescription models.DialysisPrescription, patientid int64, recordate int64, mode_id int64) error {
+
+	err := XTReadDB().Model(&prescription).Where("patient_id = ? and record_date = ? and status = 1 and mode_id = ?", patientid, recordate).Updates(map[string]interface{}{"dialysis_dialyszers": prescription.DialysisDialyszers, "dialyzer_perfusion_apparatus": prescription.DialyzerPerfusionApparatus, "mode_id": mode_id}).Error
 	return err
 }