Merge branch 'xt_statistics_branch'

controllers/gobal_config_api_controller.go

@@ -59,6 +59,8 @@ func GobalConfigRegistRouters() {
 
 	beego.Router("/api/log/generate", &GobalConfigApiController{}, "get:GenerateLog")
 
+	beego.Router("/api/patients/search", &GobalConfigApiController{}, "Post:GetPatientsByKeyWord")
+
 }
 
 //provinces, _ := service.GetDistrictsByUpid(0)21
@@ -1200,3 +1202,17 @@ func (this *GobalConfigApiController) GenerateLog() {
 	})
 
 }
+
+func (this *GobalConfigApiController) GetPatientsByKeyWord() {
+	keyWord := this.GetString("keyword")
+	adminUserInfo := this.GetAdminUserInfo()
+	patient, err := service.GetPatientsByKey(adminUserInfo.CurrentOrgId, keyWord)
+	if err != nil {
+		utils.ErrorLog(err.Error())
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"patient": patient,
+	})
+}

controllers/mobile_api_controllers/mobile_api_router_register.go

@@ -110,4 +110,6 @@ func MobileAPIControllersRegisterRouters() {
 
 	beego.Router("/m/api/getPatientid", &DialysisAPIController{}, "Get:GetPatientId")
 
+	beego.Router("/m/api/patient/search", &PatientApiController{}, "Get:GetSearchPatient")
+
 }

controllers/mobile_api_controllers/patient_api_controller.go

@@ -2668,3 +2668,17 @@ func (this *PatientApiController) GetPatientsByKeyWord() {
 		"patient": patient,
 	})
 }
+
+func (this *PatientApiController) GetSearchPatient() {
+	keyWord := this.GetString("keyword")
+	adminUserInfo := this.GetMobileAdminUserInfo()
+	patient, err := service.GetPatientsByKey(adminUserInfo.Org.Id, keyWord)
+	if err != nil {
+		utils.ErrorLog(err.Error())
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"patient": patient,
+	})
+}

controllers/new_mobile_api_controllers/common_api_router.go

@@ -6,6 +6,29 @@ import (
 
 func CommonApiControllersRegisterRouters() {
 
+	beego.Router("/api/dialysisprocessindex/chart", &IndexEvaluationApiController{}, "Get:GetDialysisProcessIndexChartData")
+	beego.Router("/api/dialysisprocessindex/table", &IndexEvaluationApiController{}, "Get:GetDialysisProcessIndexTableData")
+
+	beego.Router("/api/dialysiswatch/chart", &IndexEvaluationApiController{}, "Get:GetDialysisWatchChartData")
+	beego.Router("/api/dialysiswatch/table", &IndexEvaluationApiController{}, "Get:GetDialysisWatchTableData")
+
+	beego.Router("/api/dialysisbloodpressure/chart", &IndexEvaluationApiController{}, "Get:GetDialysisBloodPressureChartData")
+	beego.Router("/api/dialysisbloodpressure/table", &IndexEvaluationApiController{}, "Get:GetDialysisBloodPressureTableData")
+	beego.Router("/api/patientdialysisbloodpressure/chart", &IndexEvaluationApiController{}, "Get:GetDialysisPatientBloodPressureChartData")
+
+	beego.Router("/api/dialysisweight/chart", &IndexEvaluationApiController{}, "Get:GetDialysisWeightChartData")
+	beego.Router("/api/dialysisweight/table", &IndexEvaluationApiController{}, "Get:GetDialysisWeightTableData")
+	beego.Router("/api/patientdialysisweight/chart", &IndexEvaluationApiController{}, "Get:GetDialysisPatientWeightChartData")
+
+	beego.Router("/api/doctorworkload/chart", &IndexEvaluationApiController{}, "Get:GetDoctorWorkloadChartData")
+	beego.Router("/api/doctorworkload/table", &IndexEvaluationApiController{}, "Get:GetDoctorWorkloadTableData")
+
+	beego.Router("/api/nurseworkload/chart", &IndexEvaluationApiController{}, "Get:GetNurseWorkloadChartData")
+	beego.Router("/api/nurseworkload/table", &IndexEvaluationApiController{}, "Get:GetNurseWorkloadTableData")
+
+	beego.Router("/api/adminuser/all", &IndexEvaluationApiController{}, "Get:GetAdminUser")
+	beego.Router("/api/defalutpatient/get", &IndexEvaluationApiController{}, "Get:GetDefaultPatient")
+
 	beego.Router("/com/api/getinspectionmajor", &CommonApiController{}, "Get:GetInspectionMajor")
 	beego.Router("/com/api/getinspectionminor", &CommonApiController{}, "Get:GetInspectionMinor")
 	beego.Router("/com/api/getinspectionrange", &CommonApiController{}, "Get:GetInspectionRange")

controllers/pc_index_evaluation_api_controller.go

@@ -0,0 +1,617 @@
+package controllers
+
+import (
+	"XT_New/enums"
+	"XT_New/service/statistics_service"
+	"XT_New/utils"
+	"time"
+)
+
+type PCIndexEvaluationApiController struct {
+	BaseAuthAPIController
+}
+
+func (this *PCIndexEvaluationApiController) GetAdminUser() {
+	admins, _ := statistics_service.GetAllAdminUser(this.GetAdminUserInfo().CurrentOrgId)
+	this.ServeSuccessJSON(map[string]interface{}{
+		"admin": admins,
+	})
+}
+
+func (this *PCIndexEvaluationApiController) GetDialysisProcessIndexChartData() {
+	adminUserInfo := this.GetAdminUserInfo()
+	statistics_type, _ := this.GetInt("statistics_type")
+	start_time := this.GetString("start_time")
+	end_time := this.GetString("end_time")
+	patient_id, _ := this.GetInt64("patient_id")
+	timeLayout := "2006-01-02"
+	loc, _ := time.LoadLocation("Local")
+
+	var theStartTIme int64
+	if len(start_time) > 0 {
+		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", start_time+" 00:00:00", loc)
+		if err != nil {
+			utils.ErrorLog(err.Error())
+		}
+		theStartTIme = theTime.Unix()
+	}
+	var theEndtTIme int64
+	if len(end_time) > 0 {
+		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", end_time+" 23:59:59", loc)
+		if err != nil {
+			utils.ErrorLog(err.Error())
+		}
+		theEndtTIme = theTime.Unix()
+	}
+
+	if patient_id == 0 {
+		patientInfo, _ := statistics_service.GetOrgFirstPatientInfo(adminUserInfo.CurrentOrgId)
+		if patientInfo == nil {
+			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeOrgNoPatient)
+			return
+		}
+		if statistics_type == 9 || statistics_type == 10 {
+			data, _ := statistics_service.GetDialysisProcessIndexOtherChartData(adminUserInfo.CurrentOrgId, patientInfo.ID, theStartTIme, theEndtTIme, statistics_type)
+
+			this.ServeSuccessJSON(map[string]interface{}{
+				"data": data,
+			})
+		} else {
+
+			data, _ := statistics_service.GetDialysisProcessIndexChartData(adminUserInfo.CurrentOrgId, patientInfo.ID, theStartTIme, theEndtTIme, statistics_type)
+
+			this.ServeSuccessJSON(map[string]interface{}{
+				"data": data,
+			})
+
+		}
+	} else {
+		if statistics_type == 9 || statistics_type == 10 {
+			data, _ := statistics_service.GetDialysisProcessIndexOtherChartData(adminUserInfo.CurrentOrgId, patient_id, theStartTIme, theEndtTIme, statistics_type)
+
+			this.ServeSuccessJSON(map[string]interface{}{
+				"data": data,
+			})
+
+		} else {
+			data, _ := statistics_service.GetDialysisProcessIndexChartData(adminUserInfo.CurrentOrgId, patient_id, theStartTIme, theEndtTIme, statistics_type)
+
+			this.ServeSuccessJSON(map[string]interface{}{
+				"data": data,
+			})
+
+		}
+	}
+
+}
+func (this *PCIndexEvaluationApiController) GetDialysisProcessIndexTableData() {
+	adminUserInfo := this.GetAdminUserInfo()
+	start_time := this.GetString("start_time")
+	end_time := this.GetString("end_time")
+	patient_id, _ := this.GetInt64("patient_id")
+
+	page, _ := this.GetInt64("page")
+	limit, _ := this.GetInt64("limit")
+
+	if page == 0 {
+		page = 1
+	}
+	if limit == 0 {
+		limit = 20
+	}
+
+	timeLayout := "2006-01-02"
+	loc, _ := time.LoadLocation("Local")
+
+	var theStartTIme int64
+	if len(start_time) > 0 {
+		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", start_time+" 00:00:00", loc)
+		if err != nil {
+			utils.ErrorLog(err.Error())
+		}
+		theStartTIme = theTime.Unix()
+	}
+	var theEndtTIme int64
+	if len(end_time) > 0 {
+		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", end_time+" 23:59:59", loc)
+		if err != nil {
+			utils.ErrorLog(err.Error())
+		}
+		theEndtTIme = theTime.Unix()
+	}
+
+	if patient_id == 0 {
+		patientInfo, _ := statistics_service.GetOrgFirstPatientInfo(adminUserInfo.CurrentOrgId)
+		if patientInfo == nil {
+			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeOrgNoPatient)
+			return
+		}
+
+		data, total, _ := statistics_service.GetDialysisProcessIndexTableData(adminUserInfo.CurrentOrgId, patientInfo.ID, page, limit, theStartTIme, theEndtTIme)
+
+		this.ServeSuccessJSON(map[string]interface{}{
+			"data":  data,
+			"total": total,
+		})
+
+	} else {
+		data, total, _ := statistics_service.GetDialysisProcessIndexTableData(adminUserInfo.CurrentOrgId, patient_id, page, limit, theStartTIme, theEndtTIme)
+		this.ServeSuccessJSON(map[string]interface{}{
+			"data":  data,
+			"total": total,
+		})
+
+	}
+
+}
+
+func (this *PCIndexEvaluationApiController) GetDialysisWatchChartData() {
+	adminUserInfo := this.GetAdminUserInfo()
+	statistics_type, _ := this.GetInt("statistics_type")
+	start_time := this.GetString("start_time")
+	end_time := this.GetString("end_time")
+	patient_id, _ := this.GetInt64("patient_id")
+	timeLayout := "2006-01-02"
+	loc, _ := time.LoadLocation("Local")
+
+	var theStartTIme int64
+	if len(start_time) > 0 {
+		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", start_time+" 00:00:00", loc)
+		if err != nil {
+			utils.ErrorLog(err.Error())
+		}
+		theStartTIme = theTime.Unix()
+	}
+	var theEndtTIme int64
+	if len(end_time) > 0 {
+		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", end_time+" 23:59:59", loc)
+		if err != nil {
+			utils.ErrorLog(err.Error())
+		}
+		theEndtTIme = theTime.Unix()
+	}
+
+	if patient_id == 0 {
+		patientInfo, _ := statistics_service.GetOrgFirstPatientInfo(adminUserInfo.CurrentOrgId)
+		if patientInfo == nil {
+			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeOrgNoPatient)
+			return
+		}
+		data, _ := statistics_service.GetDialysisWatchChartData(adminUserInfo.CurrentOrgId, patientInfo.ID, theStartTIme, theEndtTIme, statistics_type)
+		this.ServeSuccessJSON(map[string]interface{}{
+			"data": data,
+		})
+	} else {
+		data, _ := statistics_service.GetDialysisWatchChartData(adminUserInfo.CurrentOrgId, patient_id, theStartTIme, theEndtTIme, statistics_type)
+		this.ServeSuccessJSON(map[string]interface{}{
+			"data": data,
+		})
+	}
+
+}
+func (this *PCIndexEvaluationApiController) GetDialysisWatchTableData() {
+	adminUserInfo := this.GetAdminUserInfo()
+	start_time := this.GetString("start_time")
+	end_time := this.GetString("end_time")
+	patient_id, _ := this.GetInt64("patient_id")
+	page, _ := this.GetInt64("page")
+	limit, _ := this.GetInt64("limit")
+
+	if page == 0 {
+		page = 1
+	}
+	if limit == 0 {
+		limit = 20
+	}
+	timeLayout := "2006-01-02"
+	loc, _ := time.LoadLocation("Local")
+
+	var theStartTIme int64
+	if len(start_time) > 0 {
+		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", start_time+" 00:00:00", loc)
+		if err != nil {
+			utils.ErrorLog(err.Error())
+		}
+		theStartTIme = theTime.Unix()
+	}
+	var theEndtTIme int64
+	if len(end_time) > 0 {
+		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", end_time+" 23:59:59", loc)
+		if err != nil {
+			utils.ErrorLog(err.Error())
+		}
+		theEndtTIme = theTime.Unix()
+	}
+
+	if patient_id == 0 {
+		patientInfo, _ := statistics_service.GetOrgFirstPatientInfo(adminUserInfo.CurrentOrgId)
+		if patientInfo == nil {
+			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeOrgNoPatient)
+			return
+		}
+
+		data, total, _ := statistics_service.GetDialysisWatchTableData(adminUserInfo.CurrentOrgId, patientInfo.ID, page, limit, theStartTIme, theEndtTIme)
+
+		this.ServeSuccessJSON(map[string]interface{}{
+			"data":  data,
+			"total": total,
+		})
+
+	} else {
+
+		data, total, _ := statistics_service.GetDialysisWatchTableData(adminUserInfo.CurrentOrgId, patient_id, page, limit, theStartTIme, theEndtTIme)
+		this.ServeSuccessJSON(map[string]interface{}{
+			"data":  data,
+			"total": total,
+		})
+
+	}
+
+}
+
+func (this *PCIndexEvaluationApiController) GetDialysisBloodPressureChartData() {
+	adminUserInfo := this.GetAdminUserInfo()
+	statistics_type, _ := this.GetInt("statistics_type")
+	start_time := this.GetString("start_time")
+	end_time := this.GetString("end_time")
+	patient_id, _ := this.GetInt64("patient_id")
+
+	timeLayout := "2006-01-02"
+	loc, _ := time.LoadLocation("Local")
+
+	var theStartTIme int64
+	if len(start_time) > 0 {
+		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", start_time+" 00:00:00", loc)
+		if err != nil {
+			utils.ErrorLog(err.Error())
+		}
+		theStartTIme = theTime.Unix()
+	}
+	var theEndtTIme int64
+	if len(end_time) > 0 {
+		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", end_time+" 23:59:59", loc)
+		if err != nil {
+			utils.ErrorLog(err.Error())
+		}
+		theEndtTIme = theTime.Unix()
+	}
+
+	data, _ := statistics_service.GetBloodPressureChartData(adminUserInfo.CurrentOrgId, theStartTIme, theEndtTIme, statistics_type, patient_id)
+	this.ServeSuccessJSON(map[string]interface{}{
+		"data": data,
+	})
+
+}
+func (this *PCIndexEvaluationApiController) GetDialysisBloodPressureTableData() {
+	adminUserInfo := this.GetAdminUserInfo()
+	start_time := this.GetString("start_time")
+	end_time := this.GetString("end_time")
+	patient_id, _ := this.GetInt64("patient_id")
+	page, _ := this.GetInt64("page")
+	limit, _ := this.GetInt64("limit")
+
+	if page == 0 {
+		page = 1
+	}
+	if limit == 0 {
+		limit = 20
+	}
+	timeLayout := "2006-01-02"
+	loc, _ := time.LoadLocation("Local")
+
+	var theStartTIme int64
+	if len(start_time) > 0 {
+		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", start_time+" 00:00:00", loc)
+		if err != nil {
+			utils.ErrorLog(err.Error())
+		}
+		theStartTIme = theTime.Unix()
+	}
+	var theEndtTIme int64
+	if len(end_time) > 0 {
+		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", end_time+" 23:59:59", loc)
+		if err != nil {
+			utils.ErrorLog(err.Error())
+		}
+		theEndtTIme = theTime.Unix()
+	}
+
+	data, total, _ := statistics_service.GetBloodPressureTableData(adminUserInfo.CurrentOrgId, patient_id, page, limit, theStartTIme, theEndtTIme)
+	this.ServeSuccessJSON(map[string]interface{}{
+		"data":  data,
+		"total": total,
+	})
+
+}
+func (this *PCIndexEvaluationApiController) GetDialysisPatientBloodPressureChartData() {
+	adminUserInfo := this.GetAdminUserInfo()
+	statistics_type, _ := this.GetInt("statistics_type")
+	start_time := this.GetString("start_time")
+	end_time := this.GetString("end_time")
+	patient_id, _ := this.GetInt64("patient_id")
+
+	timeLayout := "2006-01-02"
+	loc, _ := time.LoadLocation("Local")
+
+	var theStartTIme int64
+	if len(start_time) > 0 {
+		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", start_time+" 00:00:00", loc)
+		if err != nil {
+			utils.ErrorLog(err.Error())
+		}
+		theStartTIme = theTime.Unix()
+	}
+	var theEndtTIme int64
+	if len(end_time) > 0 {
+		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", end_time+" 23:59:59", loc)
+		if err != nil {
+			utils.ErrorLog(err.Error())
+		}
+		theEndtTIme = theTime.Unix()
+	}
+
+	data, _ := statistics_service.GetPatientBloodPressureChartData(adminUserInfo.CurrentOrgId, patient_id, theStartTIme, theEndtTIme, statistics_type)
+	this.ServeSuccessJSON(map[string]interface{}{
+		"data": data,
+	})
+
+}
+
+func (this *PCIndexEvaluationApiController) GetDialysisWeightChartData() {
+	adminUserInfo := this.GetAdminUserInfo()
+	statistics_type, _ := this.GetInt("statistics_type")
+	start_time := this.GetString("start_time")
+	end_time := this.GetString("end_time")
+	timeLayout := "2006-01-02"
+	loc, _ := time.LoadLocation("Local")
+
+	var theStartTIme int64
+	if len(start_time) > 0 {
+		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", start_time+" 00:00:00", loc)
+		if err != nil {
+			utils.ErrorLog(err.Error())
+		}
+		theStartTIme = theTime.Unix()
+	}
+	var theEndtTIme int64
+	if len(end_time) > 0 {
+		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", end_time+" 23:59:59", loc)
+		if err != nil {
+			utils.ErrorLog(err.Error())
+		}
+		theEndtTIme = theTime.Unix()
+	}
+
+	data, _ := statistics_service.GetDialysisWeightChartData(adminUserInfo.CurrentOrgId, theStartTIme, theEndtTIme, statistics_type)
+	this.ServeSuccessJSON(map[string]interface{}{
+		"data": data,
+	})
+
+}
+func (this *PCIndexEvaluationApiController) GetDialysisWeightTableData() {
+	adminUserInfo := this.GetAdminUserInfo()
+	start_time := this.GetString("start_time")
+	end_time := this.GetString("end_time")
+	patient_id, _ := this.GetInt64("patient_id")
+	page, _ := this.GetInt64("page")
+	limit, _ := this.GetInt64("limit")
+
+	if page == 0 {
+		page = 1
+	}
+	if limit == 0 {
+		limit = 20
+	}
+	timeLayout := "2006-01-02"
+	loc, _ := time.LoadLocation("Local")
+
+	var theStartTIme int64
+	if len(start_time) > 0 {
+		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", start_time+" 00:00:00", loc)
+		if err != nil {
+			utils.ErrorLog(err.Error())
+		}
+		theStartTIme = theTime.Unix()
+	}
+	var theEndtTIme int64
+	if len(end_time) > 0 {
+		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", end_time+" 23:59:59", loc)
+		if err != nil {
+			utils.ErrorLog(err.Error())
+		}
+		theEndtTIme = theTime.Unix()
+	}
+
+	data, total, _ := statistics_service.GetDialysisWeightTableData(adminUserInfo.CurrentOrgId, patient_id, page, limit, theStartTIme, theEndtTIme)
+	this.ServeSuccessJSON(map[string]interface{}{
+		"data":  data,
+		"total": total,
+	})
+}
+func (this *PCIndexEvaluationApiController) GetDialysisPatientWeightChartData() {
+	adminUserInfo := this.GetAdminUserInfo()
+	statistics_type, _ := this.GetInt("statistics_type")
+	start_time := this.GetString("start_time")
+	end_time := this.GetString("end_time")
+	patient_id, _ := this.GetInt64("patient_id")
+
+	timeLayout := "2006-01-02"
+	loc, _ := time.LoadLocation("Local")
+
+	var theStartTIme int64
+	if len(start_time) > 0 {
+		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", start_time+" 00:00:00", loc)
+		if err != nil {
+			utils.ErrorLog(err.Error())
+		}
+		theStartTIme = theTime.Unix()
+	}
+	var theEndtTIme int64
+	if len(end_time) > 0 {
+		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", end_time+" 23:59:59", loc)
+		if err != nil {
+			utils.ErrorLog(err.Error())
+		}
+		theEndtTIme = theTime.Unix()
+	}
+
+	data, _ := statistics_service.GetPatientDialysisWeightChartData(adminUserInfo.CurrentOrgId, patient_id, theStartTIme, theEndtTIme, statistics_type)
+	this.ServeSuccessJSON(map[string]interface{}{
+		"data": data,
+	})
+
+}
+
+func (this *PCIndexEvaluationApiController) GetDoctorWorkloadChartData() {
+	adminUserInfo := this.GetAdminUserInfo()
+	statistics_type, _ := this.GetInt("statistics_type")
+	start_time := this.GetString("start_time")
+	end_time := this.GetString("end_time")
+	timeLayout := "2006-01-02"
+	loc, _ := time.LoadLocation("Local")
+
+	var theStartTIme int64
+	if len(start_time) > 0 {
+		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", start_time+" 00:00:00", loc)
+		if err != nil {
+			utils.ErrorLog(err.Error())
+		}
+		theStartTIme = theTime.Unix()
+	}
+	var theEndtTIme int64
+	if len(end_time) > 0 {
+		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", end_time+" 23:59:59", loc)
+		if err != nil {
+			utils.ErrorLog(err.Error())
+		}
+		theEndtTIme = theTime.Unix()
+	}
+
+	data, _ := statistics_service.GetDoctorWorkloadChartData(adminUserInfo.CurrentOrgId, theStartTIme, theEndtTIme, statistics_type)
+	this.ServeSuccessJSON(map[string]interface{}{
+		"data": data,
+	})
+
+}
+func (this *PCIndexEvaluationApiController) GetDoctorWorkloadTableData() {
+	adminUserInfo := this.GetAdminUserInfo()
+	start_time := this.GetString("start_time")
+	end_time := this.GetString("end_time")
+	admin_user_id, _ := this.GetInt64("admin_user_id")
+	page, _ := this.GetInt64("page")
+	limit, _ := this.GetInt64("limit")
+
+	if page == 0 {
+		page = 1
+	}
+	if limit == 0 {
+		limit = 20
+	}
+	timeLayout := "2006-01-02"
+	loc, _ := time.LoadLocation("Local")
+
+	var theStartTIme int64
+	if len(start_time) > 0 {
+		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", start_time+" 00:00:00", loc)
+		if err != nil {
+			utils.ErrorLog(err.Error())
+		}
+		theStartTIme = theTime.Unix()
+	}
+	var theEndtTIme int64
+	if len(end_time) > 0 {
+		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", end_time+" 23:59:59", loc)
+		if err != nil {
+			utils.ErrorLog(err.Error())
+		}
+		theEndtTIme = theTime.Unix()
+	}
+	data, _ := statistics_service.GetDoctorWorkloadTableData(adminUserInfo.CurrentOrgId, theStartTIme, theEndtTIme, admin_user_id)
+	this.ServeSuccessJSON(map[string]interface{}{
+		"data": data,
+	})
+}
+
+func (this *PCIndexEvaluationApiController) GetNurseWorkloadChartData() {
+	adminUserInfo := this.GetAdminUserInfo()
+	statistics_type, _ := this.GetInt("statistics_type")
+	start_time := this.GetString("start_time")
+	end_time := this.GetString("end_time")
+	timeLayout := "2006-01-02"
+	loc, _ := time.LoadLocation("Local")
+
+	var theStartTIme int64
+	if len(start_time) > 0 {
+		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", start_time+" 00:00:00", loc)
+		if err != nil {
+			utils.ErrorLog(err.Error())
+		}
+		theStartTIme = theTime.Unix()
+	}
+	var theEndtTIme int64
+	if len(end_time) > 0 {
+		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", end_time+" 23:59:59", loc)
+		if err != nil {
+			utils.ErrorLog(err.Error())
+		}
+		theEndtTIme = theTime.Unix()
+	}
+
+	data, _ := statistics_service.GetNurseWorkloadChartData(adminUserInfo.CurrentOrgId, theStartTIme, theEndtTIme, statistics_type)
+	this.ServeSuccessJSON(map[string]interface{}{
+		"data": data,
+	})
+
+}
+func (this *PCIndexEvaluationApiController) GetNurseWorkloadTableData() {
+	adminUserInfo := this.GetAdminUserInfo()
+	start_time := this.GetString("start_time")
+	end_time := this.GetString("end_time")
+	admin_user_id, _ := this.GetInt64("admin_user_id")
+	page, _ := this.GetInt64("page")
+	limit, _ := this.GetInt64("limit")
+
+	if page == 0 {
+		page = 1
+	}
+	if limit == 0 {
+		limit = 20
+	}
+	timeLayout := "2006-01-02"
+	loc, _ := time.LoadLocation("Local")
+
+	var theStartTIme int64
+	if len(start_time) > 0 {
+		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", start_time+" 00:00:00", loc)
+		if err != nil {
+			utils.ErrorLog(err.Error())
+		}
+		theStartTIme = theTime.Unix()
+	}
+	var theEndtTIme int64
+	if len(end_time) > 0 {
+		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", end_time+" 23:59:59", loc)
+		if err != nil {
+			utils.ErrorLog(err.Error())
+		}
+		theEndtTIme = theTime.Unix()
+	}
+	data, _ := statistics_service.GetNurseWorkloadTableData(adminUserInfo.CurrentOrgId, theStartTIme, theEndtTIme, admin_user_id)
+	this.ServeSuccessJSON(map[string]interface{}{
+		"data": data,
+	})
+}
+
+func (this *PCIndexEvaluationApiController) GetDefaultPatient() {
+	adminUserInfo := this.GetAdminUserInfo()
+	patientInfo, _ := statistics_service.GetOrgFirstPatientInfo(adminUserInfo.CurrentOrgId)
+	if patientInfo == nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeOrgNoPatient)
+		return
+	}
+
+	this.ServeSuccessJSON(map[string]interface{}{
+		"patient": patientInfo,
+	})
+
+}

service/patient_service.go

@@ -1328,3 +1328,14 @@ func UpdateDoctorEditAdvice(advice models.XtDoctorAdvice, orgid int64, groupno i
 	err := XTWriteDB().Model(&advice).Where("user_org_id = ? and groupno = ? and advice_date = ? and patient_id = ?", orgid, groupno, date, patientid).Update(map[string]interface{}{"start_time": advice.StartTime, "updated_time": advice.UpdatedTime}).Error
 	return err
 }
+
+func GetPatientsByKey(orgID int64, keywords string) (patient []*models.Patients, err error) {
+	db := readDb.Model(&models.Patients{}).Where("user_org_id=? and status=1 and lapseto = 1 ", orgID)
+	if len(keywords) > 0 {
+		likekey := "%" + keywords + "%"
+		err = db.Where("(name LIKE ? OR dialysis_no LIKE ?)", likekey, likekey).Find(&patient).Error
+	} else {
+		err = db.Find(&patient).Error
+	}
+	return
+}