开发

controllers/new_mobile_api_controllers/common_api_controller.go

 		"total":   total,
 	})
 }
+
+func (this *CommonApiController) GetStatistics() {
+	adminUser := this.GetAdminUserInfo()
+	orgId := adminUser.CurrentOrgId
+	fmt.Println("orgid", orgId)
+	startime := this.GetString("start_time")
+	fmt.Println(startime)
+	endtime := this.GetString("end_time")
+	startDate, parseDateErr := utils.ParseTimeStringToTime("2006-01-02", startime)
+	fmt.Println("parseDateErr", parseDateErr)
+	statime := startDate.Unix()
+	fmt.Println("开始时间", statime)
+	endDate, _ := utils.ParseTimeStringToTime("2006-01-02", endtime)
+	entime := endDate.Unix()
+	fmt.Println("结束日期", entime)
+	value, _ := this.GetInt64("value")
+	fmt.Println("value", value)
+	limit, _ := this.GetInt64("limit")
+	fmt.Println("limit", limit)
+	page, _ := this.GetInt64("page")
+	fmt.Println("page", page)
+	modeId, _ := this.GetInt64("mode_id")
+	statistics, ttd, total, err := service.GetStatistics(orgId, statime, entime, value, limit, page, modeId)
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"statistics": statistics,
+		"ttd":        ttd,
+		"total":      total,
+	})
+}

controllers/new_mobile_api_controllers/common_api_router.go

 	beego.Router("/com/api/getlastchecklist", &CommonApiController{}, "Get:GetLastCheckList")
 	beego.Router("/com/api/getdialysisdetailbyid", &CommonApiController{}, "Get:GetDialysisDetailById")
 	beego.Router("/com/api/getprescriptionbyname", &CommonApiController{}, "Get:GetPrescritionByName")
+	beego.Router("/com/api/getstatistics", &CommonApiController{}, "Get:GetStatistics")
 }

controllers/new_mobile_api_controllers/new_common_api_controller.go

 		"total":   total,
 	})
 }
+
+func (this *NewCommonApiController) GetAllPatientsMode() {
+	adminUser := this.GetMobileAdminUserInfo()
+	orgId := adminUser.Org.Id
+	startime := this.GetString("startime")
+	fmt.Println(startime)
+	endtime := this.GetString("endtime")
+	startDate, parseDateErr := utils.ParseTimeStringToTime("2006-01-02", startime)
+	fmt.Println("parseDateErr", parseDateErr)
+	statime := startDate.Unix()
+	fmt.Println("开始时间", statime)
+	endDate, _ := utils.ParseTimeStringToTime("2006-01-02", endtime)
+	entime := endDate.Unix()
+	fmt.Println("结束日期", entime)
+	value, _ := this.GetInt64("value")
+	fmt.Println("value", value)
+	limit, _ := this.GetInt64("limit")
+	fmt.Println("limit", limit)
+	page, _ := this.GetInt64("page")
+	fmt.Println("page", page)
+	modeId, _ := this.GetInt64("mode_id")
+	fmt.Println("modeId", modeId)
+	statistics, ttd, total, err := service.GetStatistics(orgId, statime, entime, value, limit, page, modeId)
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"statistics": statistics,
+		"ttd":        ttd,
+		"total":      total,
+	})
+}

controllers/new_mobile_api_controllers/new_common_api_router.go

 	beego.Router("/m/api/getprescriptionlist", &NewCommonApiController{}, "Get:GetPrescriptionlist")
 	beego.Router("/m/api/getmobilepatientdetail", &NewCommonApiController{}, "Get:GetMobilePatientDetail")
 	beego.Router("/m/api/tosearchpatient", &NewCommonApiController{}, "Get:ToSearchPatient")
+	beego.Router("/m/api/getallpatientsmode", &NewCommonApiController{}, "Get:GetAllPatientsMode")
 }

models/common_models.go

 func (BloodDialysisPrescription) TableName() string {
 	return "xt_dialysis_prescription"
 }
+
+type DialysisTotalDataStruct struct {
+	Date   string `json:"date"`
+	Number string `json:"number"`
+	ModeID string `json:"mode_id"`
+}

service/common_service.go

 	err = db.Group("p.mode_id").Select("p.mode_id,p.patient_id,s.name,s.id_card_no,s.dialysis_no,s.total_dialysis,s.user_sys_before_count").Joins("left join xt_patients as s on s.id = p.patient_id").Count(&total).Offset(offset).Limit(limit).Scan(&prescription).Error
 	return prescription, total, err
 }
+
+func GetStatistics(orgID int64, startime int64, endtime int64, lapseto int64, limit int64, page int64, modeID int64) (dtd []*DialysisTotalDataStruct, ttd []*DialysisTotalDataStruct, total int64, err error) {
+	db := readDb
+	sql := "s.mode_id,from_unixtime(s.record_date, '%Y%m%d') as date, count(s.record_date) as number"
+	datesql := "s.record_date as date"
+	group := "from_unixtime(s.record_date, '%Y%m%d')"
+	db = db.Table("xt_dialysis_prescription as s")
+	if orgID > 0 {
+		db = db.Where("s.user_org_id = ?", orgID)
+	}
+	if modeID > 0 {
+		db = db.Where("s.mode_id=?", modeID)
+	}
+	if startime > 0 {
+		db = db.Where("s.record_date>=?", startime)
+	}
+	if endtime > 0 {
+		db = db.Where("s.record_date<=?", endtime)
+	}
+	db = db.Where("s.status=1")
+
+	if lapseto > 0 {
+		joinString := "JOIN xt_patients as p ON s.patient_id=p.id and p.lapseto=? and p.status=1"
+		joinParams := make([]interface{}, 0)
+		joinParams = append(joinParams, lapseto)
+		if orgID > 0 {
+			joinString += "AND p.user_org_id=?"
+			joinParams = append(joinParams, orgID)
+		}
+
+		db = db.Joins(joinString, joinParams...)
+	}
+
+	err = db.Select("s.mode_id, count(s.mode_id) as number").Group("s.mode_id").Order("s.mode_id asc").Find(&ttd).Error
+	if err != nil {
+		return
+	}
+
+	offset := (page - 1) * limit
+
+	var ds []*DialysisTotalDataStruct
+	err = db.Select(datesql).Group(group).Count(&total).Order("date asc").Offset(offset).Limit(limit).Find(&ds).Error
+	if err != nil {
+		return
+	}
+
+	dates := make([]string, 0)
+	if len(ds) > 0 {
+		for _, d := range ds {
+			dates = append(dates, d.Date)
+		}
+
+		db = db.Where("s.record_date IN (?)", dates)
+
+	}
+
+	err = db.Select(sql).Group(group + ", s.mode_id").Order("date asc, mode_id").Find(&dtd).Error
+	return
+}