耗材参数

controllers/dialysis_record_api_controller.go

@@ -438,15 +438,15 @@ func (this *DialysisRecordAPIController) EditMonitor() {
 			MonitoringNurse:           adminUserInfo.AdminUser.Id,
 			Conductivity:              monitorParam.Conductivity,
 			DisplacementFlowQuantity:  monitorParam.DisplacementFlowQuantity,
-			Status:                1,
-			CreatedTime:           time.Now().Unix(),
-			UpdatedTime:           time.Now().Unix(),
-			BloodOxygenSaturation: monitorParam.BloodOxygenSaturation,
-			Creator:               adminUserInfo.AdminUser.Id,
-			Heparin:               monitorParam.Heparin,
-			DialysateFlow:         monitorParam.DialysateFlow,
-			Urr:                   monitorParam.Urr,
-			BloodSugar:            monitorParam.BloodSugar,
+			Status:                    1,
+			CreatedTime:               time.Now().Unix(),
+			UpdatedTime:               time.Now().Unix(),
+			BloodOxygenSaturation:     monitorParam.BloodOxygenSaturation,
+			Creator:                   adminUserInfo.AdminUser.Id,
+			Heparin:                   monitorParam.Heparin,
+			DialysateFlow:             monitorParam.DialysateFlow,
+			Urr:                       monitorParam.Urr,
+			BloodSugar:                monitorParam.BloodSugar,
 		}
 		createErr := service.CreateMonitor(&monitor)
 		if createErr != nil {
@@ -870,6 +870,9 @@ func (this *DialysisRecordAPIController) FinishDialysis() {
 		return
 	}
 
+	//获取最后一条透析处方数据
+	prescription, parseErr := service.GetLastDialysisPrescriptionByPatientId(adminUserInfo.CurrentOrgId, patientID, recordDate.Unix())
+
 	lastAssessmentAfterDislysis, _ := service.MobileGetLastTimeAssessmentAfterDislysis(adminUserInfo.CurrentOrgId, patientID, recordDate.Unix())
 
 	var tempassessmentAfterDislysis models.AssessmentAfterDislysis
@@ -909,6 +912,11 @@ func (this *DialysisRecordAPIController) FinishDialysis() {
 		tempassessmentAfterDislysis.ActualDisplacement = endmonitorRecords.DisplacementQuantity
 	}
 
+	if prescription.ID > 0 && adminUserInfo.CurrentOrgId == 9583 {
+
+		tempassessmentAfterDislysis.ActualUltrafiltration = prescription.TargetUltrafiltration
+	}
+
 	if lastAssessmentAfterDislysis != nil {
 		tempassessmentAfterDislysis.BloodPressureType = lastAssessmentAfterDislysis.BloodPressureType
 

controllers/doctors_api_controller.go

@@ -1,14 +1,14 @@
 package controllers
 
 import (
-	"XT_New/service"
-	"strconv"
 	"XT_New/enums"
 	"XT_New/models"
+	"XT_New/service"
 	"XT_New/utils"
 	"fmt"
 	"github.com/astaxie/beego"
 	"github.com/jinzhu/gorm"
+	"strconv"
 	"time"
 )
 
@@ -53,6 +53,7 @@ func (c *DoctorsApiController) ScheduleAdvices() {
 	orgID := adminUserInfo.CurrentOrgId
 
 	scheduals, err := service.MobileGetScheduleDoctorAdvices(orgID, date.Unix(), adviceType, patientType, adminUserInfo.AdminUser.Id)
+	hisAdvices, _ := service.GetHisDoctorAdvices(orgID, date.Unix())
 	adminUser, _ := service.GetAllAdminUsers(orgID, adminUserInfo.CurrentAppId)
 	if err != nil {
 		c.ErrorLog("获取排班信息失败:%v", err)
@@ -65,9 +66,9 @@ func (c *DoctorsApiController) ScheduleAdvices() {
 			}
 		}
 		c.ServeSuccessJSON(map[string]interface{}{
-			"scheduals": filtedScheduals,
-
-			"adminUser": adminUser,
+			"scheduals":  filtedScheduals,
+			"adminUser":  adminUser,
+			"hisAdvices": hisAdvices,
 		})
 	}
 }

controllers/mobile_api_controllers/doctor_advice_api_controller.go

@@ -5,6 +5,7 @@ import (
 	"XT_New/models"
 	"XT_New/service"
 	"XT_New/utils"
+	"fmt"
 )
 
 type DoctorAdviceAPIController struct {
@@ -38,6 +39,9 @@ func (this *DoctorAdviceAPIController) ScheduleAdvices() {
 	orgID := adminInfo.Org.Id
 
 	scheduals, err := service.MobileGetScheduleDoctorAdvices(orgID, date.Unix(), adviceType, patientType, adminInfo.AdminUser.Id)
+	//获取his医嘱数据
+	fmt.Println("date.un222222", date.Unix())
+	hisAdvices, _ := service.GetHisDoctorAdvices(orgID, date.Unix())
 	adminUser, _ := service.GetAllAdminUsers(orgID, adminInfo.App.Id)
 	if err != nil {
 		this.ErrorLog("获取排班信息失败:%v", err)
@@ -50,9 +54,9 @@ func (this *DoctorAdviceAPIController) ScheduleAdvices() {
 			}
 		}
 		this.ServeSuccessJSON(map[string]interface{}{
-			"scheduals": filtedScheduals,
-
-			"adminUser": adminUser,
+			"scheduals":  filtedScheduals,
+			"adminUser":  adminUser,
+			"hisAdvices": hisAdvices,
 		})
 	}
 }

service/mobile_dialysis_service.go

@@ -860,6 +860,29 @@ func MobileGetScheduleDoctorAdvices(orgID int64, scheduleDate int64, adviceType
 	return vms, err
 }
 
+func GetHisDoctorAdvices(orgID int64, scheduleDate int64) ([]*HisMScheduleDoctorAdviceVM, error) {
+
+	var vms []*HisMScheduleDoctorAdviceVM
+
+	db := readDb.
+		Table("xt_schedule").
+		Preload("SchedualPatient", "status = 1 AND user_org_id = ?", orgID).
+		Preload("DialysisOrder", func(db *gorm.DB) *gorm.DB {
+			return db.Where("status = 1 AND user_org_id = ?", orgID).Preload("DeviceNumber", "status = 1 AND org_id= ?", orgID)
+		}).
+		Preload("DeviceNumber", "status = 1 AND org_id = ?", orgID).
+		Preload("DeviceNumber.Zone", "status = 1 AND org_id = ?", orgID).
+		Preload("Prescription", "status = 1 AND user_org_id = ? AND record_date = ?", orgID, scheduleDate).
+		Preload("HisDoctorAdviceInfo", "status = 1 AND user_org_id = ? AND advice_date = ?", orgID, scheduleDate).
+		Where("status = 1 AND user_org_id = ?", orgID)
+	if scheduleDate != 0 {
+		db = db.Where("schedule_date = ?", scheduleDate)
+	}
+
+	err := db.Find(&vms).Error
+	return vms, err
+}
+
 func MobileCreateDialysisOrder(orgID int64, patientID int64, order *models.DialysisOrder) error {
 	now := time.Now()
 	tx := writeDb.Begin()
@@ -1617,3 +1640,37 @@ func GetAllHisDoctorAdvice(orgid int64, patientid int64, recorddate int64) (his
 	return
 
 }
+
+func GetLastDialysisPrescriptionByPatientId(orgid int64, patientid int64, recorddate int64) (*models.DialysisPrescription, error) {
+
+	prescription := models.DialysisPrescription{}
+	err := readDb.Model(&models.DialysisPrescription{}).Where("user_org_id = ? and patient_id = ? and record_date = ? and status = 1", orgid, patientid, recorddate).Find(&prescription).Error
+	if err == gorm.ErrRecordNotFound {
+		return nil, err
+	}
+	if err != nil {
+		return nil, err
+	}
+	return &prescription, nil
+}
+
+type HisMScheduleDoctorAdviceVM struct {
+	ID                  int64                            `gorm:"column:id" json:"id"`
+	UserOrgId           int64                            `gorm:"column:user_org_id" json:"user_org_id"`
+	PartitionId         int64                            `gorm:"column:partition_id" json:"partition_id"`
+	BedId               int64                            `gorm:"column:bed_id" json:"bed_id"`
+	PatientId           int64                            `gorm:"column:patient_id" json:"patient_id"`
+	ScheduleDate        int64                            `gorm:"column:schedule_date" json:"schedule_date"`
+	ScheduleType        int64                            `gorm:"column:schedule_type" json:"schedule_type"`
+	ModeId              int64                            `gorm:"column:mode_id" json:"mode_id"`
+	Status              int64                            `gorm:"column:status" json:"status"`
+	DialysisOrder       *MDialysisOrderVM                `gorm:"ForeignKey:DialysisDate,PatientId;AssociationForeignKey:ScheduleDate,PatientId" json:"dialysis_order"`
+	SchedualPatient     *MSchedualPatientVM              `gorm:"ForeignKey:PatientId;AssociationForeignKey:ID" json:"patient"`
+	DeviceNumber        *MDeviceNumberVM                 `gorm:"ForeignKey:BedId" json:"device_number"`
+	Prescription        *models.DialysisPrescriptionList `gorm:"ForeignKey:PatientId;AssociationForeignKey:PatientId" json:"prescription"`
+	HisDoctorAdviceInfo []*models.HisDoctorAdviceInfo    `gorm:"ForeignKey:PatientId;AssociationForeignKey:PatientId" json:"doctor_advice"`
+}
+
+func (HisMScheduleDoctorAdviceVM) TableName() string {
+	return "xt_schedule"
+}