耗材参数

controllers/dialysis_api_controller.go

@@ -251,6 +251,9 @@ func (c *DialysisApiController) PostPrescription() {
 	displace_speed := c.GetString("displace_speed")
 	illness, _ := c.GetInt64("illness")
 	amylaceum := c.GetString("amylaceum")
+	single_time := c.GetString("single_time")
+	single_water := c.GetString("single_water")
+	replacement_flow := c.GetString("replacement_flow")
 	appRole, _ := service.FindAdminRoleTypeById(adminUserInfo.CurrentOrgId, adminUserInfo.AdminUser.Id, adminUserInfo.CurrentAppId)
 	//template, _ := service.GetOrgInfoTemplate(adminUserInfo.CurrentOrgId)
 
@@ -336,6 +339,9 @@ func (c *DialysisApiController) PostPrescription() {
 		DisplaceSpeed:              displace_speed,
 		Illness:                    illness,
 		Amylaceum:                  amylaceum,
+		SingleTime:                 single_time,
+		SingleWater:                single_water,
+		ReplacementFlow:            replacement_flow,
 	}
 
 	//查询最近透析准备表里是否存在 透析器 灌流器
@@ -573,6 +579,9 @@ func (c *DialysisApiController) PostSoulution() {
 	displace_speed := c.GetString("displace_speed")
 	illness, _ := c.GetInt64("illness")
 	amylaceum := c.GetString("amylaceum")
+	single_time := c.GetString("single_time")
+	single_water := c.GetString("single_water")
+	replacement_flow := c.GetString("replacement_flow")
 	var prescription_doctor int64
 	appRole, _ := service.FindAdminRoleTypeById(adminUserInfo.CurrentAppId, adminUserInfo.AdminUser.Id, adminUserInfo.CurrentAppId)
 
@@ -669,6 +678,9 @@ func (c *DialysisApiController) PostSoulution() {
 		DisplaceSpeed:             displace_speed,
 		Illness:                   illness,
 		Amylaceum:                 amylaceum,
+		SingleTime:                single_time,
+		SingleWater:               single_water,
+		ReplacementFlow:           replacement_flow,
 	}
 
 	//查询最近透析准备表里是否存在 透析器 灌流器

controllers/mobile_api_controllers/dialysis_api_controller.go

@@ -1096,6 +1096,9 @@ func (c *DialysisAPIController) PostDialysisPrescription() {
 	displace_speed := c.GetString("displace_speed")
 	illness, _ := c.GetInt64("illness")
 	amylaceum := c.GetString("amylaceum")
+	single_time := c.GetString("single_time")
+	single_water := c.GetString("single_water")
+	replacement_flow := c.GetString("replacement_flow")
 	appRole, _ := service.FindAdminRoleTypeById(adminUserInfo.Org.Id, adminUserInfo.AdminUser.Id, adminUserInfo.App.Id)
 	//template, _ := service.GetOrgInfoTemplate(adminUserInfo.Org.Id)
 	//
@@ -1185,6 +1188,9 @@ func (c *DialysisAPIController) PostDialysisPrescription() {
 		DisplaceSpeed:              displace_speed,
 		Illness:                    illness,
 		Amylaceum:                  amylaceum,
+		SingleTime:                 single_time,
+		SingleWater:                single_water,
+		ReplacementFlow:            replacement_flow,
 	}
 
 	//查询最近透析准备表里是否存在 透析器 灌流器
@@ -1980,6 +1986,9 @@ func (c *DialysisAPIController) PostSolution() {
 	displace_speed := c.GetString("displace_speed")
 	illness, _ := c.GetInt64("illness")
 	amylaceum := c.GetString("amylaceum")
+	single_time := c.GetString("single_time")
+	single_water := c.GetString("single_water")
+	replacement_flow := c.GetString("replacement_flow")
 	if mode_id > 0 {
 		service.ModifyScheduleMode(mode_id, patient.ID, recordDate.Unix(), adminUserInfo.Org.Id)
 	}
@@ -2070,6 +2079,9 @@ func (c *DialysisAPIController) PostSolution() {
 		DisplaceSpeed:             displace_speed,
 		Illness:                   illness,
 		Amylaceum:                 amylaceum,
+		SingleWater:               single_water,
+		SingleTime:                single_time,
+		ReplacementFlow:           replacement_flow,
 	}
 
 	_, dialysisPrescription := service.FindDialysisPrescriptionByReordDate(id, recordDate.Unix(), adminUserInfo.Org.Id)

controllers/schedule_api_controller.go

@@ -22,6 +22,7 @@ type ScheduleApiController struct {
 
 func ScheduleApiRegistRouters() {
 	beego.Router("/api/schedule/weekpanel", &ScheduleApiController{}, "Get:GetWeekPanels")
+
 	beego.Router("/api/schedule/schedules", &ScheduleApiController{}, "Get:GetSchedules")
 	beego.Router("/api/excel_date/init", &ScheduleApiController{}, "Get:GetInitExcelInitDate")
 
@@ -56,6 +57,11 @@ func ScheduleApiRegistRouters() {
 	beego.Router("/api/schedule/getprintlist", &ScheduleApiController{}, "Get:GetPrintList")
 
 	beego.Router("/api/schedule/getallzonelist", &ScheduleApiController{}, "Get:GetAllZoneList")
+
+	beego.Router("/api/schedule/getpatientschedulecount", &ScheduleApiController{}, "Get:GetPatientScheduleCount")
+
+	beego.Router("/api/schedule/weekpanelone", &ScheduleApiController{}, "Get:GetWeekPanelsOne")
+	beego.Router("/api/schedule/schedulesone", &ScheduleApiController{}, "Get:GetScheduleOne")
 }
 
 func (c *ScheduleApiController) GetWeekPanels() {
@@ -2411,3 +2417,171 @@ func (this *ScheduleApiController) GetAllZoneList() {
 		"zoneList": zoneList,
 	})
 }
+
+func (this *ScheduleApiController) GetPatientScheduleCount() {
+	patitionIdStr := this.GetString("partition_id")
+	week, _ := this.GetInt64("weekTime", 0) //1:last, 2:this 3:next 4 nextTwo
+	ids := strings.Split(patitionIdStr, ",")
+	adminUserInfo := this.GetAdminUserInfo()
+	orgId := adminUserInfo.CurrentOrgId
+	thisTime := time.Now()
+	weekDay := int(thisTime.Weekday())
+	if week < 1 || week > 4 {
+		week = 2
+	}
+	if week == 1 {
+		thisTime = thisTime.AddDate(0, 0, -7)
+	} else if week == 3 {
+		thisTime = thisTime.AddDate(0, 0, 7)
+	} else if week == 4 {
+		thisTime = thisTime.AddDate(0, 0, 14)
+	}
+	if weekDay == 0 {
+		weekDay = 7
+	}
+	weekEnd := 7 - weekDay
+	weekStart := weekEnd - 6
+	weekTitle := make([]string, 0)
+	days := make([]string, 0)
+	for index := weekStart; index <= weekEnd; index++ {
+		theDay := thisTime.AddDate(0, 0, index)
+		indexYear, indexMonthTime, indexDay := theDay.Date()
+		indexMonth := int(indexMonthTime)
+		indexWeek := strconv.Itoa(indexYear) + "." + strconv.Itoa(indexMonth) + "." + strconv.Itoa(indexDay)
+		weekTitle = append(weekTitle, indexWeek)
+		days = append(days, theDay.Format("2006-01-02"))
+	}
+
+	weekStartDay := thisTime.AddDate(0, 0, weekStart)
+	weekEndDay := thisTime.AddDate(0, 0, weekEnd)
+	weekStartTime := weekStartDay.Format("2006-01-02") + " 00:00:00"
+	weekEndTime := weekEndDay.Format("2006-01-02") + " 23:59:59"
+
+	timeLayout := "2006-01-02 15:04:05"
+	loc, _ := time.LoadLocation("Local")
+	theStarTime, _ := time.ParseInLocation(timeLayout, weekStartTime, loc)
+	theEndTime, _ := time.ParseInLocation(timeLayout, weekEndTime, loc)
+	weekStartPoint := theStarTime.Unix()
+	weekEndPoint := theEndTime.Unix()
+	fmt.Println("startTime222222222222222", weekStartPoint)
+	fmt.Println("endtime33333333333333", weekEndPoint)
+	list, err := service.GetPatientScheduleCount(orgId, weekStartPoint, weekEndPoint, ids)
+	_, total, _ := service.GetTotalBedNumber(orgId, ids)
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+		return
+	}
+
+	this.ServeSuccessJSON(map[string]interface{}{
+		"list":  list,
+		"total": total,
+	})
+}
+
+func (c *ScheduleApiController) GetWeekPanelsOne() {
+
+	data, _ := c.GetInt64("data", 1)
+	patitionIdStr := c.GetString("patitionid")
+
+	ids := strings.Split(patitionIdStr, ",")
+
+	adminInfo := c.GetAdminUserInfo()
+	thisTime := time.Now()
+	year, monthTime, day := thisTime.Date()
+	month := int(monthTime)
+	_, theWeek := thisTime.ISOWeek()
+	weekDay := int(thisTime.Weekday())
+	if weekDay == 0 {
+		weekDay = 7
+	}
+	weekEnd := 7 - weekDay
+	weekStart := weekEnd - 6
+	weekDays := make([]string, 0)
+	for index := weekStart; index <= weekEnd; index++ {
+		theDay := thisTime.AddDate(0, 0, index)
+		indexYear, indexMonthTime, indexDay := theDay.Date()
+		indexMonth := int(indexMonthTime)
+		indexWeek := strconv.Itoa(indexYear) + "." + strconv.Itoa(indexMonth) + "." + strconv.Itoa(indexDay)
+		weekDays = append(weekDays, indexWeek)
+	}
+
+	returnData := map[string]interface{}{
+		"year":     year,
+		"month":    month,
+		"day":      day,
+		"theWeek":  theWeek,
+		"weekDay":  weekDay,
+		"weekDays": weekDays,
+	}
+
+	if data == 1 {
+		partitions, _ := service.GetSchedulePartitionPanelTwo(adminInfo.CurrentOrgId, ids)
+		returnData["partitions"] = partitions
+	}
+
+	c.ServeSuccessJSON(returnData)
+	return
+}
+
+func (c *ScheduleApiController) GetScheduleOne() {
+
+	week, _ := c.GetInt64("weekTime", 0) //1:last, 2:this 3:next 4 nextTwo
+	patitionIdStr := c.GetString("patitionid")
+
+	ids := strings.Split(patitionIdStr, ",")
+	fmt.Println("patitonStr", ids)
+	schedule_type, _ := c.GetInt64("schedule_type")
+
+	adminInfo := c.GetAdminUserInfo()
+
+	thisTime := time.Now()
+	today := thisTime.Format("2006-01-02")
+	if week < 1 || week > 4 {
+		week = 2
+	}
+	if week == 1 {
+		thisTime = thisTime.AddDate(0, 0, -7)
+	} else if week == 3 {
+		thisTime = thisTime.AddDate(0, 0, 7)
+	} else if week == 4 {
+		thisTime = thisTime.AddDate(0, 0, 14)
+	}
+
+	weekDay := int(thisTime.Weekday())
+	if weekDay == 0 {
+		weekDay = 7
+	}
+	weekEnd := 7 - weekDay
+	weekStart := weekEnd - 6
+	weekTitle := make([]string, 0)
+	days := make([]string, 0)
+	for index := weekStart; index <= weekEnd; index++ {
+		theDay := thisTime.AddDate(0, 0, index)
+		indexYear, indexMonthTime, indexDay := theDay.Date()
+		indexMonth := int(indexMonthTime)
+		indexWeek := strconv.Itoa(indexYear) + "." + strconv.Itoa(indexMonth) + "." + strconv.Itoa(indexDay)
+		weekTitle = append(weekTitle, indexWeek)
+		days = append(days, theDay.Format("2006-01-02"))
+	}
+
+	weekStartDay := thisTime.AddDate(0, 0, weekStart)
+	weekEndDay := thisTime.AddDate(0, 0, weekEnd)
+	weekStartTime := weekStartDay.Format("2006-01-02") + " 00:00:00"
+	weekEndTime := weekEndDay.Format("2006-01-02") + " 23:59:59"
+
+	timeLayout := "2006-01-02 15:04:05"
+	loc, _ := time.LoadLocation("Local")
+	theStarTime, _ := time.ParseInLocation(timeLayout, weekStartTime, loc)
+	theEndTime, _ := time.ParseInLocation(timeLayout, weekEndTime, loc)
+	weekStartPoint := theStarTime.Unix()
+	weekEndPoint := theEndTime.Unix()
+
+	schdules, _ := service.GetWeekScheduleTwo(adminInfo.CurrentOrgId, weekStartPoint, weekEndPoint, ids, schedule_type)
+	c.ServeSuccessJSON(map[string]interface{}{
+		"days":      days,
+		"weekTitle": weekTitle,
+		"schdules":  schdules,
+		"today":     today,
+	})
+	return
+}

models/device_models.go

@@ -1047,3 +1047,10 @@ func (XtRemindPrintSetting) TableName() string {
 
 	return "xt_remind_print_setting"
 }
+
+type VmXtSchedule struct {
+	ID           int64 `gorm:"column:id" json:"id" form:"id"`
+	ScheduleType int64 `gorm:"column:schedule_type" json:"schedule_type" form:"schedule_type"`
+	ScheduleWeek int64 `gorm:"column:schedule_week" json:"schedule_week" form:"schedule_week"`
+	Count        int64
+}

models/patient_models.go

@@ -232,6 +232,9 @@ type DialysisPrescription struct {
 	DisplaceSpeed              string        `gorm:"column:displace_speed" json:"displace_speed" form:"displace_speed"`
 	Illness                    int64         `gorm:"column:illness" json:"illness" form:"illness"`
 	Amylaceum                  string        `gorm:"column:amylaceum" json:"amylaceum" form:"amylaceum"`
+	SingleTime                 string        `gorm:"column:single_time" json:"single_time" form:"single_time"`
+	SingleWater                string        `gorm:"column:single_water" json:"single_water" form:"single_water"`
+	ReplacementFlow            string        `gorm:"column:replacement_flow" json:"replacement_flow" form:"replacement_flow"`
 }
 
 func (DialysisPrescription) TableName() string {

service/patientmanage_service.go

@@ -1587,3 +1587,37 @@ func GetBloodAccess(orgid int64) (*models.Dataconfig, error) {
 	err := XTReadDB().Model(&dataconfig).Where("org_id = 0 and name = '血管通路部位' and status = 1 ").Find(&dataconfig).Error
 	return &dataconfig, err
 }
+
+func GetPatientScheduleCount(orgid int64, startTime int64, endTime int64, ids []string) (schedule []*models.VmXtSchedule, err error) {
+
+	db := XTReadDB().Table("xt_schedule as x").Where("x.status =1")
+	if orgid > 0 {
+		db = db.Where("x.user_org_id = ?", orgid)
+	}
+	if startTime > 0 {
+		db = db.Where("x.schedule_date >=?", startTime)
+	}
+	if endTime > 0 {
+		db = db.Where("x.schedule_date<=?", endTime)
+	}
+	if len(ids) > 0 {
+		db = db.Where("x.partition_id in (?)", ids)
+	}
+	err = db.Select("count(x.id) as count,x.schedule_type,x.schedule_week").Group("x.schedule_week,x.schedule_type").Scan(&schedule).Error
+	return schedule, err
+}
+
+func GetTotalBedNumber(orgid int64, ids []string) (list []*models.XtDeviceNumber, total int64, err error) {
+
+	//err = XTReadDB().Model(&list).Where("org_id = ? and status = 1 ",orgid).Count(&total).Find(&list).Error
+	//return list,total,err
+	db := XTReadDB().Table("xt_device_number as x").Where("x.status = 1")
+	if orgid > 0 {
+		db = db.Where("x.org_id = ?", orgid)
+	}
+	if len(ids) > 0 {
+		db = db.Where("x.zone_id in (?)", ids)
+	}
+	err = db.Count(&total).Find(&list).Error
+	return list, total, err
+}

service/schedule_service.go

@@ -30,6 +30,18 @@ func GetSchedulePartitionPanelOne(orgID int64, partionId int64) (partitions []*m
 	return
 }
 
+func GetSchedulePartitionPanelTwo(orgID int64, schIDs []string) (partitions []*models.Partition, err error) {
+
+	if len(schIDs) == 0 {
+		err = readDb.Model(&models.DeviceZone{}).Preload("Jihaos", "org_id=? and status=1", orgID).Where("org_id=? and status=1", orgID).Find(&partitions).Error
+	}
+	if len(schIDs) > 0 {
+		err = readDb.Model(&models.DeviceZone{}).Preload("Jihaos", "org_id=? and status=1 and zone_id in(?)", orgID, schIDs).Where("org_id=? and status=1 and id in(?)", orgID, schIDs).Find(&partitions).Error
+	}
+
+	return
+}
+
 func GetPatientWithScheduleAndSolution(orgID int64, keywords string, weekStart, weekEnd, schedule, contagion int64) (patients []*models.Patients, err error) {
 	db := readDb.Table("xt_patients as p").
 		Preload("DialysisSolutions", "user_org_id=? and initiate_mode=1 and affirm_state=1 and parent_id=0 and status=1", orgID).
@@ -83,6 +95,25 @@ func GetWeekScheduleOne(orgID int64, start, end int64, partionid int64, schedule
 	return
 }
 
+func GetWeekScheduleTwo(orgID int64, start, end int64, schIds []string, scheduletype int64) (schedules []*models.Schedule, err error) {
+
+	db := readDb.Table("xt_schedule as s")
+	fmt.Println("schIds2222222")
+	if len(schIds) > 0 {
+		db = db.Where("s.partition_id in (?)", schIds)
+	}
+	if scheduletype > 0 {
+		db = db.Where("s.schedule_type = ?", scheduletype)
+	}
+	err = db.Preload("PatientInfectiousDiseases", "status = 1 ").
+		Joins("JOIN xt_patients as p ON p.id = s.patient_id").
+		Where("s.user_org_id=? and s.schedule_date>=? and s.schedule_date<=? and s.status=1", orgID, start, end).
+		Select("s.id, s.user_org_id, s.partition_id, s.bed_id, s.patient_id, s.schedule_date, s.schedule_type, s.schedule_week, s.mode_id, s.status, s.created_time, s.updated_time, p.name as patient").
+		Order("updated_time asc").
+		Find(&schedules).Error
+	return
+}
+
 func GetDaySchedule(orgID, start, end, patientID int64) (schedule models.Schedule, err error) {
 	err = readDb.Model(&models.Schedule{}).Where("user_org_id=? and patient_id=? and schedule_date>=? and schedule_date<=? and status=1", orgID, patientID, start, end).First(&schedule).Error
 	return