11月9日库存管理

conf/app.conf

 appname = 血透
-httpport = 9531
+httpport = 9529
 runmode = dev
 #dev/prod
 

controllers/dialysis_api_controller.go

 	adminUserInfo := c.GetAdminUserInfo()
 
 	list, total, _ := service.GetSchedulePrintList(page, limit, schedulType, partitionType, keywords, theStartTime, adminUserInfo.CurrentOrgId)
-
+	for _, item := range list {
+		order, _ := service.GetLastOrder(item.UserOrgId, item.PatientId, item.ScheduleDate)
+		item.DialysisOrderTwenty = order
+	}
 	listOne, _ := service.GetSchedulePrintListOne(page, limit, schedulType, partitionType, keywords, theStartTime, adminUserInfo.CurrentOrgId)
 	numberList, _ := service.GetAllBedNumberSix(adminUserInfo.CurrentOrgId)
 	c.ServeSuccessJSON(map[string]interface{}{

controllers/print_data_api_controller.go

 	idStrs := strings.Split(schIDStr, ",")
 	adminUserInfo := this.GetAdminUserInfo()
 
-	if this.GetAdminUserInfo().CurrentOrgId == 10016 {
-		schedules, getScheduleErr := service.GetSchedulesSix(adminUserInfo.CurrentOrgId, idStrs)
+	if this.GetAdminUserInfo().CurrentOrgId == 10016 || this.GetAdminUserInfo().CurrentOrgId == 9671 {
+		schedules, getScheduleErr := service.GetSchedulesSeven(adminUserInfo.CurrentOrgId, idStrs)
 		for _, item := range schedules {
+
+			//获取透析上机
+			order, _ := service.GetBatchDialysisOrder(this.GetAdminUserInfo().CurrentOrgId, item.PatientID, item.ScheduleDate)
+			item.DialysisOrder = order
+
+			//获取透析处方
+			prescription, _ := service.GetBatchPrescription(this.GetAdminUserInfo().CurrentOrgId, item.PatientID, item.ScheduleDate)
+			item.Prescription = prescription
+			//接诊评估
+			receiveTreatmentAsses, _ := service.GetBatchReceiveTreatmentAsses(this.GetAdminUserInfo().CurrentOrgId, item.PatientID, item.ScheduleDate)
+			item.ReceiveAssessment = receiveTreatmentAsses
+
+			//透前评估
+			assessmentBeforeDislysisVM, _ := service.GetBatchAssessmentBeforeDislysisVM(this.GetAdminUserInfo().CurrentOrgId, item.PatientID, item.ScheduleDate)
+			item.AssessmentBeforeDislysis = assessmentBeforeDislysisVM
+
+			//透后评估
+			assessmentAfterDislysisVM, _ := service.GetBatchAssessmentAfterDislysisVM(this.GetAdminUserInfo().CurrentOrgId, item.PatientID, item.ScheduleDate)
+			item.AssessmentAfterDislysis = assessmentAfterDislysisVM
+
+			//上次透后体重
+			lastAfterWeight, _ := service.GetBatchLastAfterWeight(this.GetAdminUserInfo().CurrentOrgId, item.PatientID, item.ScheduleDate)
+			item.LastAfterWeight = lastAfterWeight
+
+			//透析监测
+			monitor, _ := service.GetBatchMonitor(this.GetAdminUserInfo().CurrentOrgId, item.PatientID, item.ScheduleDate)
+			item.MonitoringRecords = monitor
+
+			//透析医嘱
+			advice, _ := service.GetBatchDoctorAdvice(this.GetAdminUserInfo().CurrentOrgId, item.PatientID, item.ScheduleDate)
+			item.Advices = advice
+
+			//双人核对
+			dobuleCheck, _ := service.GetBatchDobuleCheck(this.GetAdminUserInfo().CurrentOrgId, item.PatientID, item.ScheduleDate)
+			item.DoubleCheck = dobuleCheck
+
+			//透析小结
+			summerVM, _ := service.GetBatchSummerVM(this.GetAdminUserInfo().CurrentOrgId, item.PatientID, item.ScheduleDate)
+			item.Summer = summerVM
+
 			list, _ := service.GetDialysisOrderCountSeven(item.PatientID, item.ScheduleDate)
 			if this.GetAdminUserInfo().CurrentOrgId != 10101 && this.GetAdminUserInfo().CurrentOrgId != 9671 {
 				item.Count = list.Count
 		})
 	}
 
-	if this.GetAdminUserInfo().CurrentOrgId != 10016 {
+	if this.GetAdminUserInfo().CurrentOrgId != 10016 && this.GetAdminUserInfo().CurrentOrgId != 9671 {
 		schedules, getScheduleErr := service.GetSchedules(adminUserInfo.CurrentOrgId, idStrs)
 		for _, item := range schedules {
 			list, _ := service.GetDialysisOrderCountSeven(item.PatientID, item.ScheduleDate)

models/dialysis.go

 }
 
 type DialysisScheduleSix struct {
-	ID           int64  `gorm:"column:id" json:"id" form:"id"`
-	UserOrgId    int64  `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
-	PartitionId  int64  `gorm:"column:partition_id" json:"partition_id" form:"partition_id"`
-	BedId        int64  `gorm:"column:bed_id" json:"bed_id" form:"bed_id"`
-	PatientId    int64  `gorm:"column:patient_id" json:"patient_id" form:"patient_id"`
-	ScheduleDate int64  `gorm:"column:schedule_date" json:"schedule_date" form:"schedule_date"`
-	ScheduleType int64  `gorm:"column:schedule_type" json:"schedule_type" form:"schedule_type"`
-	ScheduleWeek int64  `gorm:"column:schedule_week" json:"schedule_week" form:"schedule_week"`
-	ModeId       int64  `gorm:"column:mode_id" json:"mode_id" form:"mode_id"`
-	Status       int64  `gorm:"column:status" json:"status" form:"status"`
-	Name         string `gorm:"column:name" json:"name" form:"name"`
+	ID                  int64  `gorm:"column:id" json:"id" form:"id"`
+	UserOrgId           int64  `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
+	PartitionId         int64  `gorm:"column:partition_id" json:"partition_id" form:"partition_id"`
+	BedId               int64  `gorm:"column:bed_id" json:"bed_id" form:"bed_id"`
+	PatientId           int64  `gorm:"column:patient_id" json:"patient_id" form:"patient_id"`
+	ScheduleDate        int64  `gorm:"column:schedule_date" json:"schedule_date" form:"schedule_date"`
+	ScheduleType        int64  `gorm:"column:schedule_type" json:"schedule_type" form:"schedule_type"`
+	ScheduleWeek        int64  `gorm:"column:schedule_week" json:"schedule_week" form:"schedule_week"`
+	ModeId              int64  `gorm:"column:mode_id" json:"mode_id" form:"mode_id"`
+	Status              int64  `gorm:"column:status" json:"status" form:"status"`
+	Name                string `gorm:"column:name" json:"name" form:"name"`
+	DialysisOrderTwenty `gorm:"ForeignKey:PatientId;AssociationForeignKey:PatientId" json:"order"`
 }
 
 type DialysisScheduleSeven struct {
 }
 
 type DialysisOrderTwenty struct {
-	ID           int64        `gorm:"column:id" json:"id"`
-	DialysisDate int64        `gorm:"column:dialysis_date" json:"dialysis_date"`
-	UserOrgId    int64        `gorm:"column:user_org_id" json:"user_org_id"`
-	PatientId    int64        `gorm:"column:patient_id" json:"patient_id"`
-	Stage        int64        `gorm:"column:stage" json:"stage"`
-	Remark       string       `gorm:"column:remark" json:"remark"`
-	BedID        int64        `gorm:"column:bed_id" json:"bed_id"`
-	Status       int64        `gorm:"column:status" json:"status"`
-	DeviceNumber DeviceNumber `gorm:"ForeignKey:BedID"`
-	StartTime    int64        `gorm:"column:start_time" json:"start_time"`
-	SchedualType int64        `gorm:"column:schedual_type" json:"schedual_type"`
-	ZoneId       int64        `gorm:"column:zone_id" json:"zone_id" form:"zone_id"`
+	ID                 int64        `gorm:"column:id" json:"id"`
+	DialysisDate       int64        `gorm:"column:dialysis_date" json:"dialysis_date"`
+	UserOrgId          int64        `gorm:"column:user_org_id" json:"user_org_id"`
+	PatientId          int64        `gorm:"column:patient_id" json:"patient_id"`
+	Stage              int64        `gorm:"column:stage" json:"stage"`
+	Remark             string       `gorm:"column:remark" json:"remark"`
+	BedID              int64        `gorm:"column:bed_id" json:"bed_id"`
+	Status             int64        `gorm:"column:status" json:"status"`
+	DeviceNumber       DeviceNumber `gorm:"ForeignKey:BedID"`
+	StartTime          int64        `gorm:"column:start_time" json:"start_time"`
+	SchedualType       int64        `gorm:"column:schedual_type" json:"schedual_type"`
+	ZoneId             int64        `gorm:"column:zone_id" json:"zone_id" form:"zone_id"`
+	BloodAccessId      int64        `gorm:"column:blood_access_id" json:"blood_access_id" form:"blood_access_id"`
+	DialysisIrrigation string       `gorm:"column:dialysis_irrigation" json:"dialysis_irrigation" form:"dialysis_irrigation"`
+	DialysisDialyszers string       `gorm:"column:dialysis_dialyszers" json:"dialysis_dialyszers" form:"dialysis_dialyszers"`
+	OrderRemark        string       `gorm:"column:order_remark" json:"order_remark" form:"order_remark"`
+	ScheduleRemark     string       `gorm:"column:schedule_remark" json:"schedule_remark" form:"schedule_remark"`
 }
 
 func (DialysisOrderTwenty) TableName() string {

service/dialysis_service.go

 	err := XTWriteDB().Model(&advice).Where("user_org_id = ? and id in(?) and status = 1", orgid, ids).Updates(map[string]interface{}{"check_time": advice.CheckTime, "checker": advice.Checker, "check_state": 1}).Error
 	return err
 }
+
+func GetLastOrder(user_org_id int64, patient_id int64, dialysis_date int64) (models.DialysisOrderTwenty, error) {
+
+	twenty := models.DialysisOrderTwenty{}
+
+	err := XTReadDB().Where("user_org_id = ? and patient_id =? and dialysis_date < ? and status = 1", user_org_id, patient_id, dialysis_date).Preload("DeviceNumber", func(db *gorm.DB) *gorm.DB {
+		return db.Preload("DeviceZone", "status =1").Where("org_id = ? AND status = 1", user_org_id)
+	}).Order("id desc").First(&twenty).Error
+
+	return twenty, err
+}

service/print_data_service/schedule_dialysis/print_schedule_dialysis_models.go

 	FinishModifier int64           `gorm:"column:finish_modifier" json:"finish_modifier"`
 	SchedualType   int64           `gorm:"column:schedual_type" json:"schedual_type"`
 	WashpipeNurse  int64           `gorm:"column:washpipe_nurse" json:"washpipe_nurse" form:"washpipe_nurse"`
+	UserOrgId      int64           `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
 }
 
 func (DialysisOrderVM) TableName() string {
 	ReplacementFlow            string  `gorm:"column:replacement_flow" json:"replacement_flow" form:"replacement_flow"`
 	PlasmaSeparator            string  `gorm:"column:plasma_separator" json:"plasma_separator" form:"plasma_separator"`
 	BilirubinAdsorptionColumn  string  `gorm:"column:bilirubin_adsorption_column" json:"bilirubin_adsorption_column" form:"bilirubin_adsorption_column"`
-
+	UserOrgId                  int64   `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
 	HemodialysisPipelines      string  `gorm:"column:hemodialysis_pipelines" json:"hemodialysis_pipelines" form:"hemodialysis_pipelines"`
 	HemodialysisPipelinesCount float64 `gorm:"column:hemodialysis_pipelines_count" json:"hemodialysis_pipelines_count" form:"hemodialysis_pipelines_count"`
 	PunctureNeedle             string  `gorm:"column:puncture_needle" json:"puncture_needle" form:"puncture_needle"`
 	PreDialysisDrugs               string  `gorm:"column:pre_dialysis_drugs" json:"pre_dialysis_drugs" form:"pre_dialysis_drugs"`
 	Period                         int64   `gorm:"column:period" json:"period" form:"period"`
 	EstimatedFoodIntake            string  `gorm:"column:estimated_food_intake" json:"estimated_food_intake" form:"estimated_food_intake"`
+	UserOrgId                      int64   `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
 }
 
 func (AssessmentBeforeDislysisVM) TableName() string {
 	Lapse                           int64   `gorm:"column:lapse" json:"lapse" form:"lapse"`
 	Consciousness                   int64   `gorm:"column:consciousness" json:"consciousness" form:"consciousness"`
 	Fallrisk                        int64   `gorm:"column:fallrisk" json:"fallrisk" form:"fallrisk"`
+	UserOrgId                       int64   `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
 }
 
 func (AssessmentAfterDislysisVM) TableName() string {
 	CvcA                            float64 `gorm:"column:cvc_a" json:"cvc_a" form:"cvc_a"`
 	CvcV                            float64 `gorm:"column:cvc_v" json:"cvc_v" form:"cvc_v"`
 	Channel                         int64   `gorm:"column:channel" json:"channel" form:"channel"`
+	UserOrgId                       int64   `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
 }
 
 func (XtAssessmentAfterDislysisVM) TableName() string {
 	PsychologicalOther           string `gorm:"column:psychological_other" json:"psychological_other"`
 	IsPrecaution                 int64  `gorm:"column:is_precaution" json:"is_precaution"`
 	AdmissionNumber              string `gorm:"column:admission_number" json:"admission_number" form:"admission_number"`
+	UserOrgId                    int64  `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
 }
 
 func (ReceiveAssessmentVM) TableName() string {
 	BloodThickness              float64 `gorm:"column:blood_thickness" json:"blood_thickness" form:"blood_thickness"`
 	BloodMonitor                float64 `gorm:"column:blood_monitor" json:"blood_monitor" form:"blood_monitor"`
 	BloodPressureMonitoringSite int64   `gorm:"column:blood_pressure_monitoring_site" json:"blood_pressure_monitoring_site" form:"blood_pressure_monitoring_site"`
+	UserOrgId                   int64   `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
 }
 
 func (MonitoringRecordVM) TableName() string {

service/print_data_service/schedule_dialysis/print_schedule_dialysis_service.go

 	return cancel, err
 }
 
+func GetSchedulesSeven(orgID int64, schIDs []string) ([]*ScheduleVMSix, error) {
+	//recordDateStr := time.Now().Format("2006-01-02")
+	//recordDate, _ := utils.ParseTimeStringToTime("2006-01-02", recordDateStr)
+	var schedules []*ScheduleVMSix
+	db := p_service.XTReadDB()
+	err := db.Model(&ScheduleVMSix{}).
+		Preload("Patient", "user_org_id = ? AND status = 1", orgID).
+		Preload("DeviceNumber", "org_id = ?", orgID).
+		Preload("DeviceZone", "org_id = ?", orgID).
+		Where("user_org_id = ? AND status = 1 AND id in (?)", orgID, schIDs).Order("schedule_date asc").
+		Find(&schedules).
+		Error
+	if err != nil {
+		return nil, err
+	}
+	for _, item := range schedules {
+		dialysis_count, _ := GetDialysisOrderCount(orgID, item.PatientID, item.ScheduleDate)
+		item.Patient.TotalDialysis = dialysis_count
+	}
+	return schedules, nil
+}
+
 func GetSchedulesSix(orgID int64, schIDs []string) ([]*ScheduleVMSix, error) {
 	recordDateStr := time.Now().Format("2006-01-02")
 	recordDate, _ := utils.ParseTimeStringToTime("2006-01-02", recordDateStr)
 	}
 	return schedules, nil
 }
+
+func GetBatchDialysisOrder(orgid int64, patient_id int64, dialysis_date int64) (DialysisOrderVM, error) {
+
+	orderVM := DialysisOrderVM{}
+	err := p_service.XTReadDB().Where("user_org_id = ? and patient_id = ? and dialysis_date = ? and status = 1", orgid, patient_id, dialysis_date).Preload("DeviceNumber", "org_id = ? AND status = 1", orgid).Find(&orderVM).Error
+	return orderVM, err
+}
+
+func GetBatchPrescription(orgid int64, patient_id int64, record_date int64) (PrescriptionVM, error) {
+
+	prescriptionVM := PrescriptionVM{}
+	err := p_service.XTReadDB().Where("user_org_id = ? and patient_id = ? and record_date = ? and status = 1", orgid, patient_id, record_date).Find(&prescriptionVM).Error
+	return prescriptionVM, err
+}
+
+func GetBatchReceiveTreatmentAsses(orgid int64, patient_id int64, record_date int64) (ReceiveAssessmentVM, error) {
+
+	receiveAssessmentVM := ReceiveAssessmentVM{}
+	err := p_service.XTReadDB().Where("user_org_id = ? and patient_id = ? and record_date = ? and status = 1", orgid, patient_id, record_date).Find(&receiveAssessmentVM).Error
+	return receiveAssessmentVM, err
+}
+
+func GetBatchAssessmentBeforeDislysisVM(orgid int64, patient_id int64, assessment_date int64) (AssessmentBeforeDislysisVM, error) {
+
+	AssessmentBeforeDislysisVM := AssessmentBeforeDislysisVM{}
+	err := p_service.XTReadDB().Where("user_org_id = ? and patient_id = ? and assessment_date = ? and status = 1", orgid, patient_id, assessment_date).Find(&AssessmentBeforeDislysisVM).Error
+	return AssessmentBeforeDislysisVM, err
+}
+
+func GetBatchAssessmentAfterDislysisVM(orgid int64, patient_id int64, assessment_date int64) (AssessmentAfterDislysisVM, error) {
+
+	assessmentAfterDislysisVM := AssessmentAfterDislysisVM{}
+	err := p_service.XTReadDB().Where("user_org_id = ? and patient_id = ? and assessment_date = ? and status = 1", orgid, patient_id, assessment_date).Find(&assessmentAfterDislysisVM).Error
+	return assessmentAfterDislysisVM, err
+}
+
+func GetBatchLastAfterWeight(orgid int64, patient_id int64, assessment_date int64) (XtAssessmentAfterDislysisVM, error) {
+
+	xtAssessmentAfterDislysisVM := XtAssessmentAfterDislysisVM{}
+	err := p_service.XTReadDB().Where("user_org_id = ? and patient_id = ? and assessment_date < ? and status = 1", orgid, patient_id, assessment_date).Order("id desc").First(&xtAssessmentAfterDislysisVM).Error
+	return xtAssessmentAfterDislysisVM, err
+}
+
+func GetBatchMonitor(orgid int64, patient_id int64, monitoring_date int64) (MonitoringRecordVM []*MonitoringRecordVM, err error) {
+
+	err = p_service.XTReadDB().Where("user_org_id = ? and patient_id = ? and monitoring_date = ? and status = 1", orgid, patient_id, monitoring_date).Order("operate_time asc").Find(&MonitoringRecordVM).Error
+	return MonitoringRecordVM, err
+}
+
+func GetBatchDoctorAdvice(orgid int64, patient_id int64, advice_date int64) (DoctorAdviceVM []*DoctorAdviceVM, err error) {
+
+	err = p_service.XTReadDB().Where("user_org_id = ? and patient_id = ? and advice_date = ? and status = 1 and  advice_type = 2", orgid, patient_id, advice_date).Order("start_time asc, groupno desc, id asc").Find(&DoctorAdviceVM).Error
+	return DoctorAdviceVM, err
+}
+
+func GetBatchDobuleCheck(orgid int64, patient_id int64, check_date int64) (*DoubleCheckVM, error) {
+
+	doubleCheckVM := DoubleCheckVM{}
+	err := p_service.XTReadDB().Where("user_org_id = ? and patient_id = ? and check_date =? and status = 1", orgid, patient_id, check_date).Find(&doubleCheckVM).Error
+	return &doubleCheckVM, err
+}
+
+func GetBatchSummerVM(orgid int64, patient_id int64, assessment_date int64) (*SummerVM, error) {
+
+	SummerVM := SummerVM{}
+	err := p_service.XTReadDB().Where("user_org_id = ? and patient_id = ? and assessment_date =? and status = 1", orgid, patient_id, assessment_date).Find(&SummerVM).Error
+	return &SummerVM, err
+}