Merge branch 'xt_statistics_branch'

controllers/new_mobile_api_controllers/index_evaluation_api_controller.go

@@ -685,6 +685,7 @@ func (this *IndexEvaluationApiController) GetDoctorWorkloadChartData() {
 	adminUserInfo := this.GetMobileAdminUserInfo()
 	statistics_type, _ := this.GetInt("statistics_type")
 	start_time := this.GetString("start_time")
+	admin_user_id, _ := this.GetInt64("admin_user_id")
 	end_time := this.GetString("end_time")
 	timeLayout := "2006-01-02"
 	loc, _ := time.LoadLocation("Local")
@@ -706,7 +707,7 @@ func (this *IndexEvaluationApiController) GetDoctorWorkloadChartData() {
 		theEndtTIme = theTime.Unix()
 	}
 
-	data, _ := statistics_service.GetDoctorWorkloadChartData(adminUserInfo.Org.Id, theStartTIme, theEndtTIme, statistics_type)
+	data, _ := statistics_service.GetDoctorWorkloadChartData(adminUserInfo.Org.Id, theStartTIme, theEndtTIme, statistics_type, admin_user_id)
 	this.ServeSuccessJSON(map[string]interface{}{
 		"data": data,
 	})
@@ -755,6 +756,8 @@ func (this *IndexEvaluationApiController) GetNurseWorkloadChartData() {
 	adminUserInfo := this.GetMobileAdminUserInfo()
 	statistics_type, _ := this.GetInt("statistics_type")
 	start_time := this.GetString("start_time")
+	admin_user_id, _ := this.GetInt64("admin_user_id")
+
 	end_time := this.GetString("end_time")
 	timeLayout := "2006-01-02"
 	loc, _ := time.LoadLocation("Local")
@@ -776,7 +779,7 @@ func (this *IndexEvaluationApiController) GetNurseWorkloadChartData() {
 		theEndtTIme = theTime.Unix()
 	}
 
-	data, _ := statistics_service.GetNurseWorkloadChartData(adminUserInfo.Org.Id, theStartTIme, theEndtTIme, statistics_type)
+	data, _ := statistics_service.GetNurseWorkloadChartData(adminUserInfo.Org.Id, theStartTIme, theEndtTIme, statistics_type, admin_user_id)
 	this.ServeSuccessJSON(map[string]interface{}{
 		"data": data,
 	})

controllers/pc_index_evaluation_api_controller.go

@@ -719,6 +719,8 @@ func (this *PCIndexEvaluationApiController) GetDoctorWorkloadChartData() {
 	adminUserInfo := this.GetAdminUserInfo()
 	statistics_type, _ := this.GetInt("statistics_type")
 	start_time := this.GetString("start_time")
+	admin_user_id, _ := this.GetInt64("admin_user_id")
+
 	end_time := this.GetString("end_time")
 	timeLayout := "2006-01-02"
 	loc, _ := time.LoadLocation("Local")
@@ -740,7 +742,7 @@ func (this *PCIndexEvaluationApiController) GetDoctorWorkloadChartData() {
 		theEndtTIme = theTime.Unix()
 	}
 
-	data, _ := statistics_service.GetDoctorWorkloadChartData(adminUserInfo.CurrentOrgId, theStartTIme, theEndtTIme, statistics_type)
+	data, _ := statistics_service.GetDoctorWorkloadChartData(adminUserInfo.CurrentOrgId, theStartTIme, theEndtTIme, statistics_type, admin_user_id)
 	this.ServeSuccessJSON(map[string]interface{}{
 		"data": data,
 	})
@@ -790,6 +792,8 @@ func (this *PCIndexEvaluationApiController) GetNurseWorkloadChartData() {
 	statistics_type, _ := this.GetInt("statistics_type")
 	start_time := this.GetString("start_time")
 	end_time := this.GetString("end_time")
+	admin_user_id, _ := this.GetInt64("admin_user_id")
+
 	timeLayout := "2006-01-02"
 	loc, _ := time.LoadLocation("Local")
 
@@ -810,7 +814,7 @@ func (this *PCIndexEvaluationApiController) GetNurseWorkloadChartData() {
 		theEndtTIme = theTime.Unix()
 	}
 
-	data, _ := statistics_service.GetNurseWorkloadChartData(adminUserInfo.CurrentOrgId, theStartTIme, theEndtTIme, statistics_type)
+	data, _ := statistics_service.GetNurseWorkloadChartData(adminUserInfo.CurrentOrgId, theStartTIme, theEndtTIme, statistics_type, admin_user_id)
 	this.ServeSuccessJSON(map[string]interface{}{
 		"data": data,
 	})

service/statistics_service/index_evaluation_service.go

@@ -1159,19 +1159,23 @@ func GetPatientBloodPressureChartData(user_org_id int64, patient_id int64, start
 //透析血压统计
 
 //工作量统计
-func GetDoctorWorkloadChartData(user_org_id int64, start_time int64, end_time int64, statistics_type int) (datas []*VMUserAdminRole, err error) {
+func GetDoctorWorkloadChartData(user_org_id int64, start_time int64, end_time int64, statistics_type int, admin_user_id int64) (datas []*VMUserAdminRole, err error) {
 	userDb := service.UserReadDB()
 	db := service.XTReadDB()
-	userDb.Raw("select admin_user_id, user_name,org_id  from sgj_user_admin_role  Where status = 1 AND org_id = ?  AND user_type = 2 ", user_org_id).Scan(&datas)
+	if admin_user_id == 0 {
+		userDb.Raw("select admin_user_id, user_name,org_id  from sgj_user_admin_role  Where status = 1 AND org_id = ?  AND user_type = 2 ", user_org_id).Scan(&datas)
+	} else {
+		userDb.Raw("select admin_user_id, user_name,org_id  from sgj_user_admin_role  Where status = 1 AND org_id = ?  AND user_type = 2  AND admin_user_id = ?", user_org_id, admin_user_id).Scan(&datas)
+	}
 
 	switch statistics_type {
 	case 1:
 		var Total int64
-		db.Table("xt_dialysis_prescription as p").Where("user_org_id = ? AND status = 1  AND record_date >= ? AND  record_date <= ? AND prescription_doctor <> 0 ", user_org_id, start_time, end_time).Count(&Total)
+		db.Table("xt_dialysis_prescription as p").Where("user_org_id = ? AND status = 1  AND record_date >= ? AND  record_date <= ? AND creater <> 0 ", user_org_id, start_time, end_time).Count(&Total)
 
 		for _, item := range datas {
 			var total int64
-			db.Table("xt_dialysis_prescription as p").Where("user_org_id = ? AND status = 1 AND prescription_doctor = ? AND record_date >= ? AND  record_date <= ?", user_org_id, item.AdminUserId, start_time, end_time).Count(&total)
+			db.Table("xt_dialysis_prescription as p").Where("user_org_id = ? AND status = 1 AND creater = ? AND record_date >= ? AND  record_date <= ?", user_org_id, item.AdminUserId, start_time, end_time).Count(&total)
 			item.PCount = total
 
 			if math.IsNaN(float64(item.PCount) / float64(Total)) {
@@ -1242,7 +1246,7 @@ func GetDoctorWorkloadTableData(user_org_id int64, start_time int64, end_time in
 		var Total int64
 		var TotalOne int64
 		var TotalTwo int64
-		db.Table("xt_dialysis_prescription as p").Where("user_org_id = ? AND status = 1 AND prescription_doctor = ?  AND record_date >= ? AND  record_date <= ?", user_org_id, item.AdminUserId, start_time, end_time).Count(&Total)
+		db.Table("xt_dialysis_prescription as p").Where("user_org_id = ? AND status = 1 AND creater = ?  AND record_date >= ? AND  record_date <= ?", user_org_id, item.AdminUserId, start_time, end_time).Count(&Total)
 		db.Table("xt_patient_course_of_disease as course").Where("org_id = ? AND status = 1 AND recorder = ? AND record_time >= ? AND record_time <= ?", user_org_id, item.AdminUserId, start_time, end_time).Count(&TotalOne)
 		db.Table("xt_patient_rescue_record as rescue").Where("org_id = ? AND status = 1 AND recorder = ? AND record_time >= ? AND record_time <= ?", user_org_id, item.AdminUserId, start_time, end_time).Count(&TotalTwo)
 		item.PCount = Total
@@ -1255,21 +1259,20 @@ func GetDoctorWorkloadTableData(user_org_id int64, start_time int64, end_time in
 	return datas, nil
 
 }
-func GetNurseWorkloadChartData(user_org_id int64, start_time int64, end_time int64, statistics_type int) (datas []*VMUserAdminRole, err error) {
+func GetNurseWorkloadChartData(user_org_id int64, start_time int64, end_time int64, statistics_type int, admin_user_id int64) (datas []*VMUserAdminRole, err error) {
 	userDb := service.UserReadDB()
 	db := service.XTReadDB()
-	userDb.Raw("select admin_user_id, user_name,org_id  from sgj_user_admin_role  Where status = 1 AND org_id = ?  AND user_type = 3 ", user_org_id).Scan(&datas)
+
+	if admin_user_id == 0 {
+		userDb.Raw("select admin_user_id, user_name,org_id  from sgj_user_admin_role  Where status = 1 AND org_id = ?  AND user_type = 3 ", user_org_id).Scan(&datas)
+	} else {
+		userDb.Raw("select admin_user_id, user_name,org_id  from sgj_user_admin_role  Where status = 1 AND org_id = ?  AND user_type = 3  AND admin_user_id = ?", user_org_id, admin_user_id).Scan(&datas)
+	}
 
 	var NewTotalOne int64
 	var NewTotalThree int64
 	var NewTotalFour int64
 
-	//var tempConfig models.Dataconfig
-	//db.Model(&models.Dataconfig{}).Where("name = '血管通路' AND module = 'hemodialysis' AND field_name = 'vascular_access_desc' AND parent_id = 0").First(&tempConfig)
-
-	//db.Raw("select count(*) as total from xt_dialysis_order where status = 1 AND dialysis_date >= ? AND dialysis_date <= ? AND user_org_id = ?",start_time,end_time,user_org_id).Count(&NewTotalOne)
-	//db.Raw("select count(*) as total_one from  (select d.patient_id as patient, d.id, d.`assessment_date` as date,config.name as name from  xt_assessment_before_dislysis as d  JOIN `xt_data_config` config on  d.`blood_access_part_opera_id` = config.value AND config.org_id = ? AND config.parent_id = ? AND FIND_IN_SET('导管',config.name) > 0  Where d.user_org_id = ? AND d.assessment_date >=? AND d.assessment_date <= ?  Group by d.id)  b JOIN `xt_dialysis_order`  on xt_dialysis_order.`dialysis_date` = b.date AND xt_dialysis_order.user_org_id = ? AND xt_dialysis_order.status = 1  AND xt_dialysis_order.dialysis_date >= ? AND xt_dialysis_order.dialysis_date <= ? ", user_org_id, tempConfig.ID, user_org_id, start_time, end_time, user_org_id, start_time, end_time).Count(&NewTotalTwo)
-
 	db.Table("xt_dialysis_order ").Where("user_org_id = ? AND status = 1  AND dialysis_date >= ? AND dialysis_date <= ?", user_org_id, start_time, end_time).Count(&NewTotalOne)
 	db.Table("xt_monitoring_record ").Where("user_org_id = ? AND status = 1  AND operate_time >= ? AND operate_time <= ?", user_org_id, start_time, end_time).Count(&NewTotalThree)
 	db.Table("xt_treatment_summary").Where("user_org_id = ? AND status = 1  AND assessment_date >= ? AND assessment_date <= ?", user_org_id, start_time, end_time).Count(&NewTotalFour)