耗材参数

controllers/new_mobile_api_controllers/common_api_controller.go

 	startime := this.GetString("startime")
 	startTimes, _ := time.ParseInLocation(timeLayout+" 15:04:05", startime+" 00:00:00", loc)
 	startnunix := startTimes.Unix()
-	fmt.Println("开始时间---------------", startnunix)
 	endtime := this.GetString("endtime")
 	endtimes, _ := time.ParseInLocation(timeLayout+" 15:04:05", endtime+" 23:59:59", loc)
 	endunix := endtimes.Unix()
-	fmt.Println("endunix==========", endunix)
+
 	//统计该机构的转出人数
 	patients, err := service.GetTotalRollOutPatients(orgid, startnunix, endunix)
 	//统计该机构转出病人
 		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
 		return
 	}
+
+	//统计当前机构转出的人数
+	rollout, err := service.GetCountRollout(orgid, startnunix, endunix)
 	this.ServeSuccessJSON(map[string]interface{}{
 		"patients":   patients,
 		"count":      count,
 		"patienttwo": patienttwo,
+		"rollout":    rollout,
 	})
 }
 
 	})
 
 }
+
+func (this *CommonApiController) GetTreatModeList() {
+
+	start_time, _ := this.GetInt64("start_time")
+	end_time, _ := this.GetInt64("end_time")
+	adminUserInfo := this.GetAdminUserInfo()
+	orgId := adminUserInfo.CurrentOrgId
+	list, err := service.GetTreatModeList(start_time, end_time, orgId)
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"list": list,
+	})
+}
+
+func (this *CommonApiController) GetCountModeId() {
+
+	start_time, _ := this.GetInt64("start_time")
+	end_time, _ := this.GetInt64("end_time")
+	mode_id, _ := this.GetInt64("mode_id")
+	adminUserInfo := this.GetAdminUserInfo()
+	orgId := adminUserInfo.CurrentOrgId
+	fmt.Println("start_time", start_time)
+	fmt.Println("end_time", end_time)
+	fmt.Println("mode_id", mode_id)
+
+	modeCount, err := service.GetCountModeId(start_time, end_time, mode_id, orgId)
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"modeCount": modeCount,
+	})
+}
+
+func (this *CommonApiController) GetRolloutCount() {
+
+	start_time, _ := this.GetInt64("start_time")
+	end_time, _ := this.GetInt64("end_time")
+	adminUserInfo := this.GetAdminUserInfo()
+	orgId := adminUserInfo.CurrentOrgId
+
+	//统计当前机构转出的人数
+	rollout, err := service.GetCountRollout(orgId, start_time, end_time)
+
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"rollout": rollout,
+	})
+}

controllers/new_mobile_api_controllers/common_api_router.go

 	beego.Router("/com/api/getbloodpressurelist", &CommonApiController{}, "Get:GetBloodPressureList")
 	beego.Router("/com/api/getmonthbloodlist", &CommonApiController{}, "Get:GetMonthBloodList")
 	beego.Router("/com/api/getidslist", &CommonApiController{}, "Post:GetIdsListTwo")
+	beego.Router("/com/api/getreatmodelist", &CommonApiController{}, "Get:GetTreatModeList")
+	beego.Router("/com/api/getcountmodeid", &CommonApiController{}, "Get:GetCountModeId")
+	beego.Router("/com/api/getrolloutcount", &CommonApiController{}, "Get:GetRolloutCount")
 }

controllers/new_mobile_api_controllers/new_common_api_controller.go

 		"recoredtwo":    recoredtwo,
 	})
 }
+
+func (this *NewCommonApiController) GetMobileTreatModeList() {
+
+	timeLayout := "2006-01-02"
+	loc, _ := time.LoadLocation("Local")
+	startime := this.GetString("start_time")
+	endtime := this.GetString("end_time")
+	startTimes, _ := time.ParseInLocation(timeLayout+" 15:04:05", startime+" 00:00:00", loc)
+	startimes := startTimes.Unix()
+
+	endtimes, _ := time.ParseInLocation(timeLayout+" 15:04:05", endtime+" 23:59:59", loc)
+	endtimeData := endtimes.Unix()
+	adminUserInfo := this.GetMobileAdminUserInfo()
+	orgid := adminUserInfo.Org.Id
+	list, err := service.GetTreatModeList(startimes, endtimeData, orgid)
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"list": list,
+	})
+}
+
+func (this *NewCommonApiController) GetMobileCountModeId() {
+
+	timeLayout := "2006-01-02"
+	loc, _ := time.LoadLocation("Local")
+	startime := this.GetString("start_time")
+	endtime := this.GetString("end_time")
+	startTimes, _ := time.ParseInLocation(timeLayout+" 15:04:05", startime+" 00:00:00", loc)
+	startimes := startTimes.Unix()
+
+	endtimes, _ := time.ParseInLocation(timeLayout+" 15:04:05", endtime+" 23:59:59", loc)
+	endtimeData := endtimes.Unix()
+	mode_id, _ := this.GetInt64("mode_id")
+
+	adminUserInfo := this.GetMobileAdminUserInfo()
+	orgId := adminUserInfo.Org.Id
+
+	modeCount, err := service.GetCountModeId(startimes, endtimeData, mode_id, orgId)
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"modeCount": modeCount,
+	})
+}
+
+func (this *NewCommonApiController) GetMobileRolloutCount() {
+
+	timeLayout := "2006-01-02"
+	loc, _ := time.LoadLocation("Local")
+	startime := this.GetString("start_time")
+	endtime := this.GetString("end_time")
+	startTimes, _ := time.ParseInLocation(timeLayout+" 15:04:05", startime+" 00:00:00", loc)
+	startimes := startTimes.Unix()
+
+	endtimes, _ := time.ParseInLocation(timeLayout+" 15:04:05", endtime+" 23:59:59", loc)
+	endtimeData := endtimes.Unix()
+
+	adminUserInfo := this.GetMobileAdminUserInfo()
+	orgId := adminUserInfo.Org.Id
+	//统计当前机构转出的人数
+	rollout, err := service.GetCountRollout(orgId, startimes, endtimeData)
+	fmt.Println("rollout============", rollout)
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"rollout": rollout,
+	})
+}

controllers/new_mobile_api_controllers/new_common_api_router.go

 	beego.Router("/m/api/getsystolicbloodstand", &NewCommonApiController{}, "Get:GetSystolicBloodStand")
 	beego.Router("/m/api/getmobileidslist", &NewCommonApiController{}, "post:GetMobileIdsList")
 	beego.Router("/m/api/getsystolicbloodnostand", &NewCommonApiController{}, "Get:GetSystolicBloodNoStand")
+	beego.Router("/m/api/getmobiletreatmodelist", &NewCommonApiController{}, "Get:GetMobileTreatModeList")
+	beego.Router("/m/api/getmobileCountModeId", &NewCommonApiController{}, "Get:GetMobileCountModeId")
+	beego.Router("/m/api/getmobilerolloutcount", &NewCommonApiController{}, "Get:GetMobileRolloutCount")
 }

models/common_models.go

 	ModeId    int64 `gorm:"column:mode_id" json:"mode_id" form:"mode_id"`
 	Count     int64
 }
+
+type BloodTreateModeIdCount struct {
+	ModeId       int64 `gorm:"column:mode_id" json:"mode_id" form:"mode_id"`
+	Count        int64
+	DialysisDate int64 `gorm:"column:dialysis_date" json:"dialysis_date" form:"dialysis_date"`
+}
+
+type BloodLapsetoCount struct {
+	ID          int64 `gorm:"column:id" json:"id" form:"id"`
+	Count       int64
+	LapsetoTime int64 `gorm:"column:lapseto_time" json:"lapseto_time" form:"lapseto_time"`
+	LapsetoType int64 `gorm:"column:lapseto_type" json:"lapseto_type" form:"lapseto_type"`
+}

service/common_service.go

 	err = db.Group(" s.patient_id,s.mode_id").Select("s.mode_id,	s.patient_id,	count(o.id) as count").Joins("left join xt_schedule as s on s.patient_id = o.patient_id").Where("s.schedule_date = o.dialysis_date and s.status =1 ").Scan(&order).Error
 	return order, err
 }
+
+func GetTreatModeList(startime int64, endtime int64, orgid int64) (order []*models.BloodDialysisModeIdCount, err error) {
+
+	table := XTReadDB().Table("xt_schedule as s")
+	fmt.Println("table", table)
+	db := XTReadDB().Table("xt_dialysis_order as o")
+	if orgid > 0 {
+		db = db.Where("o.user_org_id = ?", orgid)
+	}
+	if startime > 0 {
+		db = db.Where("o.dialysis_date>=?", startime)
+	}
+	if endtime > 0 {
+		db = db.Where("o.dialysis_date<=?", endtime)
+	}
+	err = db.Group("s.mode_id").Select("s.mode_id,	s.patient_id").Joins("left join xt_schedule as s on s.patient_id = o.patient_id").Where("s.schedule_date = o.dialysis_date and s.status =1 ").Scan(&order).Error
+	return order, err
+
+}
+
+func GetCountModeId(startime int64, endtime int64, modeid int64, orgid int64) (order []*models.BloodTreateModeIdCount, err error) {
+
+	table := XTReadDB().Table("xt_schedule as s")
+	fmt.Println("table", table)
+	db := XTReadDB().Table("xt_dialysis_order as o")
+	if orgid > 0 {
+		db = db.Where("o.user_org_id = ?", orgid)
+	}
+	if startime > 0 {
+		db = db.Where("o.dialysis_date>=?", startime)
+	}
+	if endtime > 0 {
+		db = db.Where("o.dialysis_date<=?", endtime)
+	}
+	err = db.Group("o.dialysis_date,s.mode_id").Select("s.mode_id,	count(s.mode_id) as count,o.dialysis_date").Joins("left join xt_schedule as s on s.patient_id = o.patient_id").Where("s.schedule_date = o.dialysis_date and s.status =1 and s.mode_id = ? and o.dialysis_date <> ''", modeid).Scan(&order).Error
+	return order, err
+
+}
+
+func GetCountRollout(orgid int64, startime int64, endtime int64) (lapseto []*models.BloodLapsetoCount, err error) {
+
+	table := XTReadDB().Table("xt_patients as s")
+	fmt.Println(table)
+	db := XTReadDB().Table("xt_patient_lapseto as x").Where("x.status = 1")
+	if startime > 0 {
+		db = db.Where("x.lapseto_time >=?", startime)
+	}
+	if endtime > 0 {
+		db = db.Where("x.lapseto_time<=?", endtime)
+	}
+	err = db.Group("x.lapseto_time,x.lapseto_type").Select("count(x.id) as count,x.lapseto_type,x.lapseto_time").Joins("left join xt_patients as s  on s.id = x.patient_id").Where("s.user_org_id = ?", orgid).Scan(&lapseto).Error
+	return lapseto, err
+}