历史排班

controllers/patient_dataconfig_api_controller.go

 
 	beego.Router("/api/patient/getpatientdialysisinforlist", &PatientDataConfigAPIController{}, "get:GetPatientDialysisInforList")
 
+	beego.Router("/api/patient/getcontextschedulelist", &PatientDataConfigAPIController{}, "Get:GetContextScheduleList")
+
 }
 
 type PatientDataConfigAPIController struct {
 		}
 		startTime = theTime.Unix()
 	}
-	fmt.Println("startTime0000000000000000", startTime)
 
 	//获取患者姓名
 	patient, _ := service.GetPatientName(patientID)
 		"afterDislysis":   afterDislysis,
 	})
 }
+
+func (this *PatientDataConfigAPIController) GetContextScheduleList() {
+
+	limit, _ := this.GetInt64("limit")
+
+	page, _ := this.GetInt64("page")
+
+	start_time := this.GetString("start_time")
+
+	end_time := this.GetString("end_time")
+
+	timeLayout := "2006-01-02"
+	loc, _ := time.LoadLocation("Local")
+	var startTime int64
+	if len(start_time) > 0 {
+		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", start_time+" 00:00:00", loc)
+		if err != nil {
+			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+			return
+		}
+		startTime = theTime.Unix()
+	}
+
+	var endTime int64
+	if len(end_time) > 0 {
+		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", end_time+" 00:00:00", loc)
+		if err != nil {
+			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+			return
+		}
+		startTime = theTime.Unix()
+	}
+
+	org_id := this.GetAdminUserInfo().CurrentOrgId
+
+	schedule, total, _ := service.GetContextScheduleListGroupPatientId(limit, page, startTime, endTime, org_id)
+
+	list, _, _ := service.GetContextScheduleListPatientId(startTime, endTime, org_id)
+
+	patients, _ := service.GetAllpatientThirty(org_id)
+
+	devicenumber, _ := service.GetAllBedNumber(org_id)
+	this.ServeSuccessJSON(map[string]interface{}{
+		"schedule":     schedule,
+		"total":        total,
+		"list":         list,
+		"patients":     patients,
+		"devicenumber": devicenumber,
+	})
+}

models/patient_models.go

 func (XtPatientPhysiqueCheck) TableName() string {
 	return "xt_patient_physique_check"
 }
+
+type ConScheduleList struct {
+	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"`
+	IsExport     int64 `gorm:"column:is_export" json:"is_export" form:"is_export"`
+	Status       int64 `gorm:"column:status" json:"status" form:"status"`
+}
+
+func (ConScheduleList) TableName() string {
+	return "xt_schedule"
+}

service/patient_service.go

 	err := XTWriteDB().Model(models.XtSchedule{}).Where("user_org_id = ? and schedule_date > ?", org_id, shcheduledate).Updates(map[string]interface{}{"status": 0}).Error
 	return err
 }
+
+func GetContextScheduleListGroupPatientId(limit int64, page int64, startTime int64, endTime int64, org_id int64) (schedule []*models.ConScheduleList, total int64, err error) {
+
+	db := XTReadDB().Model(&schedule).Where("status=1")
+
+	offset := (page - 1) * limit
+
+	if startTime > 0 {
+		db = db.Where("schedule_date >=?", startTime)
+	}
+	if endTime > 0 {
+		db = db.Where("schedule_date<=?", endTime)
+	}
+
+	if org_id > 0 {
+		db = db.Where("user_org_id = ?", org_id)
+	}
+	err = db.Count(&total).Offset(offset).Limit(limit).Group("patient_id").Find(&schedule).Error
+
+	return schedule, total, err
+}
+
+func GetContextScheduleListPatientId(startTime int64, endTime int64, org_id int64) (schedule []*models.ConScheduleList, total int64, err error) {
+
+	db := XTReadDB().Model(&schedule).Where("status=1")
+
+	if startTime > 0 {
+		db = db.Where("schedule_date >=?", startTime)
+	}
+	if endTime > 0 {
+		db = db.Where("schedule_date<=?", endTime)
+	}
+
+	if org_id > 0 {
+		db = db.Where("user_org_id = ?", org_id)
+	}
+	err = db.Find(&schedule).Error
+
+	return schedule, total, err
+}

service/patientmanage_service.go

 }
 
 func GetPatientInspectionByID(startime int64, endtime int64, orgid int64, projectid int64, item_id int64, patient_id int64) (inspections []*models.Inspection, err error) {
-	db := XTReadDB().Table("xt_inspection as x").Select("patient_id,inspect_date,inspect_value").Joins("xt_patient p On p.id = xt_inspection.patient_id and p.status = 1 and p.lapseto = 1").Where("x.status = 1")
+	db := XTReadDB().Table("xt_inspection as x").Select("patient_id,inspect_date,inspect_value").Joins("join xt_patients p On p.id = x.patient_id and p.status = 1 and p.lapseto = 1").Where("x.status = 1")
 	if startime > 0 {
 		db = db.Where("x.inspect_date >= ?", startime)
 	}