Merge branch 'xt_statistics_branch' of http://git.shengws.com/csx/XT_New into xt_statistics_branch

controllers/data_api_controller.go

@@ -54,9 +54,7 @@ func DataApiRegistRouters() {
 //GetPatientsList 取配置信息列表
 func (c *DataApiController) GetConfigList() {
 	adminUserInfo := c.GetAdminUserInfo()
-
 	configList, _ := service.GetConfigList(adminUserInfo.CurrentOrgId)
-
 	c.ServeSuccessJSON(map[string]interface{}{
 		"configlist": configList,
 	})

controllers/gobal_config_api_controller.go

@@ -1025,6 +1025,20 @@ func (this *GobalConfigApiController) ChangeOrg() {
 			}
 		}
 
+		QualityeList, err := service.FindQualityByOrgId(tempOrg.Id)
+		if len(QualityeList) == 0 {
+			err = service.BatchInsertQualityControl(tempOrg.Id)
+		} else {
+			utils.ErrorLog("字段批量插入失败：%v", err)
+		}
+
+		InspectionList, err := service.FindeInspectionByOrgId(tempOrg.Id)
+		if len(InspectionList) == 0 {
+			err = service.BatchInspectionConfiguration(tempOrg.Id)
+		} else {
+			utils.ErrorLog("字段批量插入失败：%v", err)
+		}
+
 		var didRegistedForSCRM bool = false
 		var didRegistedForCDM bool = false
 		var didRegistedForMall bool = false

controllers/mobile_api_controllers/login_api_controller.go

@@ -167,6 +167,22 @@ func (this *LoginAPIController) LoginByPwd() {
 			}
 		}
 
+		//批量插入质控达标统计配置
+		QualityeList, err := service.FindQualityByOrgId(org.Id)
+		if len(QualityeList) == 0 {
+			err = service.BatchInsertQualityControl(org.Id)
+		} else {
+			utils.ErrorLog("字段批量插入失败：%v", err)
+		}
+
+		//批量插入检验检查统计配置
+		InspectionList, err := service.FindeInspectionByOrgId(org.Id)
+		if len(InspectionList) == 0 {
+			err = service.BatchInspectionConfiguration(org.Id)
+		} else {
+			utils.ErrorLog("字段批量插入失败：%v", err)
+		}
+
 		this.ServeSuccessJSON(map[string]interface{}{
 			"admin": adminUser,
 			"user":  appRole,

controllers/new_mobile_api_controllers/common_api_controller.go

@@ -5,6 +5,7 @@ import (
 	"XT_New/enums"
 	"XT_New/models"
 	"XT_New/service"
+	"XT_New/utils"
 	"encoding/json"
 	"fmt"
 	"github.com/jinzhu/gorm"
@@ -468,12 +469,19 @@ func (this *CommonApiController) GetTotalDialysisCount() {
 	fmt.Println(startime)
 	endtime, _ := this.GetInt64("endtime")
 	fmt.Println(endtime)
+	recordDateStr := time.Now().Format("2006-01-02")
+	recordDate, parseDateErr := utils.ParseTimeStringToTime("2006-01-02", recordDateStr)
+	fmt.Println("parseDateErr", parseDateErr)
+	nowtime := recordDate.Unix()
 	//统计透析总人数
 	total := service.GetPatientTotalCount(orgid)
-	fmt.Println("total--------------", total)
+	fmt.Println("total", total)
 	//获取该机构下的所有病人数据
 	patients, err := service.GetTotalDialysisAgeCount(orgid)
-	fmt.Println("patients--------", patients)
+	fmt.Println("patients", patients)
+
+	//统计透年龄
+	dataage, _ := service.GetDialysisAgeData(orgid)
 	if err != nil {
 		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
 		return
@@ -481,5 +489,309 @@ func (this *CommonApiController) GetTotalDialysisCount() {
 	this.ServeSuccessJSON(map[string]interface{}{
 		"total":    total,
 		"patients": patients,
+		"nowtime":  nowtime,
+		"dataage":  dataage,
+	})
+}
+
+func (this *CommonApiController) GetCurentOrgPatients() {
+
+	adminUser := this.GetAdminUserInfo()
+	orgid := adminUser.CurrentOrgId
+	patients, err := service.GetCurentOrgPatients(orgid)
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"patients": patients,
+	})
+}
+
+func (this *CommonApiController) GetDialysislist() {
+	startime := this.GetString("startime")
+	fmt.Println("startime", startime)
+	endtime := this.GetString("endtime")
+	fmt.Println("enditme", 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("开始时间", statime)
+	page, _ := this.GetInt64("page")
+	fmt.Println("page", page)
+	limit, _ := this.GetInt64("limit")
+	fmt.Println("limit", limit)
+	adminUser := this.GetAdminUserInfo()
+	orgId := adminUser.CurrentOrgId
+
+	dialysislist, total, err := service.GetDialysisList(statime, entime, page, limit, orgId)
+
+	prescriptionList, _ := service.GetAllDialysisList(statime, entime, orgId)
+	list, totallist, _ := service.GetDialysisPatientList(statime, entime, page, limit, orgId)
+	fmt.Println("err", err)
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"dialysislist":     dialysislist,
+		"total":            total,
+		"list":             list,
+		"totallist":        totallist,
+		"prescriptionList": prescriptionList,
+	})
+}
+
+func (this *CommonApiController) GetLastSort() {
+
+	adminUser := this.GetAdminUserInfo()
+	orgid := adminUser.CurrentOrgId
+	standard, err := service.GetLastSort(orgid)
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"standard": standard,
+	})
+}
+
+func (this *CommonApiController) GetLastCheckList() {
+	adminUser := this.GetAdminUserInfo()
+	orgid := adminUser.CurrentOrgId
+	checkList, err := service.GetLastCheckList(orgid)
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"checkList": checkList,
+	})
+}
+
+func (this *CommonApiController) GetDialysisDetailById() {
+	adminUser := this.GetAdminUserInfo()
+	orgId := adminUser.CurrentOrgId
+	id, _ := this.GetInt64("id")
+	fmt.Println("id", 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("开始时间", statime)
+	fmt.Println(endtime)
+	limit, _ := this.GetInt64("limit")
+	fmt.Println("limit", limit)
+	page, _ := this.GetInt64("page")
+	fmt.Println("page", page)
+	patients, total, err := service.GetDialysisDetailById(id, orgId, statime, entime, limit, page)
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"patients": patients,
+		"total":    total,
+	})
+}
+
+func (this *CommonApiController) GetPrescritionByName() {
+	adminUser := this.GetAdminUserInfo()
+	orgId := adminUser.CurrentOrgId
+	keyword := this.GetString("keyword")
+	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("开始时间", statime)
+	fmt.Println(endtime)
+	limit, _ := this.GetInt64("limit")
+	fmt.Println("limit", limit)
+	page, _ := this.GetInt64("page")
+	fmt.Println("page", page)
+	patient, total, err := service.GetPrescritionByName(orgId, keyword, statime, entime, limit, page)
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"patient": patient,
+		"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,
+	})
+}
+
+func (this *CommonApiController) GetInspectionTatolCount() {
+	adminUser := this.GetAdminUserInfo()
+	orgid := adminUser.CurrentOrgId
+	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)
+	references, err := service.GetInspectionTotalCount(orgid)
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
+
+	counts, err := service.GetInspectionProjectCount(orgid, statime, entime)
+
+	this.ServeSuccessJSON(map[string]interface{}{
+		"Inspection": references,
+		"counts":     counts,
+	})
+}
+
+func (this *CommonApiController) GetInspectionDetailById() {
+	adminUser := this.GetAdminUserInfo()
+	orgId := adminUser.CurrentOrgId
+	id, _ := this.GetInt64("id")
+	fmt.Println("id", id)
+	startime := this.GetString("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)
+	patientdetail, err := service.GetInspectionDetailById(id, orgId, statime, entime)
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"patientdetail": patientdetail,
+	})
+}
+
+func (this *CommonApiController) GetSearchPatientInfo() {
+	adminUser := this.GetAdminUserInfo()
+	orgId := adminUser.CurrentOrgId
+	keyword := this.GetString("keyword")
+	fmt.Println("keyword", keyword)
+	startime := this.GetString("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)
+	PatientsInfo, err := service.GetSearchPatientInfo(orgId, keyword, statime, entime)
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"PatientsInfo": PatientsInfo,
+	})
+}
+
+func (this *CommonApiController) GetAllMajorInspection() {
+	adminUser := this.GetAdminUserInfo()
+	orgid := adminUser.CurrentOrgId
+	inspection, err := service.GetMajorInspectionByOrgid(orgid)
+	if len(inspection) == 0 {
+		inspect, err := service.GetDefaultByOrgId(0)
+		if err != nil {
+			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+			return
+		}
+		this.ServeSuccessJSON(map[string]interface{}{
+			"inspection": inspect,
+		})
+	} else {
+		if err != nil {
+			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+			return
+		}
+		this.ServeSuccessJSON(map[string]interface{}{
+			"inspection": inspection,
+		})
+	}
+}
+
+func (this *CommonApiController) GetPatientList() {
+	adminUser := this.GetAdminUserInfo()
+	orgid := adminUser.CurrentOrgId
+	startime := this.GetString("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)
+	limit, _ := this.GetInt64("limit")
+	fmt.Println("limit", limit)
+	page, _ := this.GetInt64("page")
+	fmt.Println("page", page)
+	patientInfo, total, err := service.GetPatientListData(orgid, statime, entime, limit, page)
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"patientInfo": patientInfo,
+		"total":       total,
 	})
 }

controllers/new_mobile_api_controllers/common_api_router.go

@@ -27,4 +27,16 @@ func CommonApiControllersRegisterRouters() {
 	beego.Router("/com/api/gettoalinfectiouscount", &CommonApiController{}, "Get:GetTotalInfectiouscount")
 	beego.Router("/com/api/gettotalagecount", &CommonApiController{}, "Get:GetTotalAgeCount")
 	beego.Router("/com/api/gettotaldialysiscount", &CommonApiController{}, "Get:GetTotalDialysisCount")
+	beego.Router("/com/api/getcurentorgpatients", &CommonApiController{}, "Get:GetCurentOrgPatients")
+	beego.Router("/com/api/getdialysislist", &CommonApiController{}, "Get:GetDialysislist")
+	beego.Router("/com/api/getlastsort", &CommonApiController{}, "Get:GetLastSort")
+	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")
+	beego.Router("/com/api/getinspectiontotalcount", &CommonApiController{}, "Get:GetInspectionTatolCount")
+	beego.Router("/com/api/getinspectionDetailById", &CommonApiController{}, "Get:GetInspectionDetailById")
+	beego.Router("/com/api/getsearchpatientinfo", &CommonApiController{}, "Get:GetSearchPatientInfo")
+	beego.Router("/com/api/getallmajorInspection", &CommonApiController{}, "Get:GetAllMajorInspection")
+	beego.Router("/com/api/getpatientlist", &CommonApiController{}, "Get:GetPatientList")
 }

controllers/new_mobile_api_controllers/forget_password_controller.go

@@ -179,6 +179,22 @@ func (this *ForgetPwdController) ModifyPassword() {
 				}
 			}
 
+			if org.Id > 0 {
+				QualityeList, err := service.FindQualityByOrgId(org.Id)
+				if len(QualityeList) == 0 {
+					err = service.BatchInsertQualityControl(org.Id)
+				} else {
+					utils.ErrorLog("字段批量插入失败：%v", err)
+				}
+
+				InspectionList, err := service.FindeInspectionByOrgId(org.Id)
+				if len(InspectionList) == 0 {
+					err = service.BatchInspectionConfiguration(org.Id)
+				} else {
+					utils.ErrorLog("字段批量插入失败：%v", err)
+				}
+			}
+
 			this.ServeSuccessJSON(map[string]interface{}{
 				"admin": adminUser,
 				"user":  appRole,

controllers/new_mobile_api_controllers/home_api_controller.go

@@ -232,6 +232,23 @@ func (this *HomeController) ChangeOrg() {
 			} else {
 				FiledList = make([]*models.FiledConfig, 0)
 			}
+
+			if org.Id > 0 {
+				QualityeList, err := service.FindQualityByOrgId(org.Id)
+				if len(QualityeList) == 0 {
+					err = service.BatchInsertQualityControl(org.Id)
+				} else {
+					utils.ErrorLog("字段批量插入失败：%v", err)
+				}
+
+				InspectionList, err := service.FindeInspectionByOrgId(org.Id)
+				if len(InspectionList) == 0 {
+					err = service.BatchInspectionConfiguration(org.Id)
+				} else {
+					utils.ErrorLog("字段批量插入失败：%v", err)
+				}
+			}
+
 		}
 		this.ServeSuccessJSON(map[string]interface{}{
 			"admin": adminUser,
@@ -516,6 +533,22 @@ func (this *HomeController) CreateOrg() {
 					}
 				}
 
+				if org.Id > 0 {
+					QualityeList, err := service.FindQualityByOrgId(org.Id)
+					if len(QualityeList) == 0 {
+						err = service.BatchInsertQualityControl(org.Id)
+					} else {
+						utils.ErrorLog("字段批量插入失败：%v", err)
+					}
+
+					InspectionList, err := service.FindeInspectionByOrgId(org.Id)
+					if len(InspectionList) == 0 {
+						err = service.BatchInspectionConfiguration(org.Id)
+					} else {
+						utils.ErrorLog("字段批量插入失败：%v", err)
+					}
+				}
+
 				this.ServeSuccessJSON(map[string]interface{}{
 					"admin": adminUser,
 					"user":  appRole,

controllers/new_mobile_api_controllers/mobile_regist_controller.go

@@ -382,6 +382,22 @@ func (this *MobileRegistController) CreateOrg() {
 				}
 			}
 
+			if org.Id > 0 {
+				QualityeList, err := service.FindQualityByOrgId(org.Id)
+				if len(QualityeList) == 0 {
+					err = service.BatchInsertQualityControl(org.Id)
+				} else {
+					utils.ErrorLog("字段批量插入失败：%v", err)
+				}
+
+				InspectionList, err := service.FindeInspectionByOrgId(org.Id)
+				if len(InspectionList) == 0 {
+					err = service.BatchInspectionConfiguration(org.Id)
+				} else {
+					utils.ErrorLog("字段批量插入失败：%v", err)
+				}
+			}
+
 			this.ServeSuccessJSON(map[string]interface{}{
 				"admin": adminUser,
 				"user":  appRole,

controllers/new_mobile_api_controllers/new_common_api_controller.go

@@ -4,6 +4,7 @@ import (
 	"XT_New/controllers/mobile_api_controllers"
 	"XT_New/enums"
 	"XT_New/service"
+	"XT_New/utils"
 	"fmt"
 	"time"
 )
@@ -123,3 +124,249 @@ func (this *NewCommonApiController) GetMobileTotalAgeCount() {
 		"ageCount": agecount,
 	})
 }
+
+func (this *NewCommonApiController) GetMobileTotalDialysisCount() {
+	startime, _ := this.GetInt64("startime")
+	fmt.Println("开始时间", startime)
+	endtime, _ := this.GetInt64("endtime")
+	fmt.Println("结束时间", endtime)
+	adminUser := this.GetMobileAdminUserInfo()
+	orgid := adminUser.Org.Id
+	recordDateStr := time.Now().Format("2006-01-02")
+	recordDate, parseDateErr := utils.ParseTimeStringToTime("2006-01-02", recordDateStr)
+	fmt.Println(parseDateErr)
+	nowtime := recordDate.Unix()
+	//统计透析总人数
+	total := service.GetPatientTotalCount(orgid)
+	fmt.Println("total", total)
+	//获取该机构下的所有病人数据
+	patients, err := service.GetTotalDialysisAgeCount(orgid)
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"total":    total,
+		"patients": patients,
+		"nowtime":  nowtime,
+	})
+}
+
+func (this *NewCommonApiController) GetMobilePatientList() {
+	adminUser := this.GetMobileAdminUserInfo()
+	orgid := adminUser.Org.Id
+	patients, err := service.GetCurentOrgPatients(orgid)
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"patients": patients,
+	})
+}
+
+func (this *NewCommonApiController) GetPrescriptionlist() {
+
+	startime := this.GetString("startime")
+	fmt.Println("startime", startime)
+	endtime := this.GetString("endtime")
+	fmt.Println("enditme", 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("开始时间", statime)
+	page, _ := this.GetInt64("page")
+	fmt.Println("page", page)
+	limit, _ := this.GetInt64("limit")
+	fmt.Println("limit", limit)
+	adminInfo := this.GetMobileAdminUserInfo()
+	orgId := adminInfo.Org.Id
+	prescriptionList, _ := service.GetAllDialysisList(statime, entime, orgId)
+	list, totallist, err := service.GetDialysisPatientList(statime, entime, page, limit, orgId)
+	fmt.Println("err--------------------", err)
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"list":             list,
+		"totallist":        totallist,
+		"prescriptionList": prescriptionList,
+	})
+}
+
+func (this *NewCommonApiController) GetMobilePatientDetail() {
+	adminUser := this.GetMobileAdminUserInfo()
+	orgId := adminUser.Org.Id
+	id, _ := this.GetInt64("id")
+	fmt.Println("id", 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("开始时间", statime)
+	fmt.Println(endtime)
+	limit, _ := this.GetInt64("limit")
+	fmt.Println("limit", limit)
+	page, _ := this.GetInt64("page")
+	fmt.Println("page", page)
+	patients, total, err := service.GetDialysisDetailById(id, orgId, statime, entime, limit, page)
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"patients": patients,
+		"total":    total,
+	})
+}
+
+func (this *NewCommonApiController) ToSearchPatient() {
+	adminUser := this.GetMobileAdminUserInfo()
+	orgId := adminUser.Org.Id
+	keyword := this.GetString("keyword")
+	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("开始时间", statime)
+	fmt.Println(endtime)
+	limit, _ := this.GetInt64("limit")
+	fmt.Println("limit", limit)
+	page, _ := this.GetInt64("page")
+	fmt.Println("page", page)
+	patient, total, err := service.GetPrescritionByName(orgId, keyword, statime, entime, limit, page)
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"patient": patient,
+		"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,
+	})
+}
+
+func (this *NewCommonApiController) GetMobileInspectionList() {
+	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)
+	references, err := service.GetInspectionTotalCount(orgid)
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
+
+	counts, err := service.GetInspectionProjectCount(orgid, statime, entime)
+
+	this.ServeSuccessJSON(map[string]interface{}{
+		"Inspection": references,
+		"counts":     counts,
+	})
+}
+
+func (this *NewCommonApiController) GetPatientInspectionDetail() {
+	adminUser := this.GetMobileAdminUserInfo()
+	orgId := adminUser.Org.Id
+	id, _ := this.GetInt64("id")
+	fmt.Println("id", id)
+	startime := this.GetString("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)
+	patientdetail, err := service.GetInspectionDetailById(id, orgId, statime, entime)
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"patientdetail": patientdetail,
+	})
+}
+
+func (this *NewCommonApiController) GetSeachPatientDetail() {
+	adminUser := this.GetMobileAdminUserInfo()
+	orgId := adminUser.Org.Id
+	keyword := this.GetString("keyword")
+	fmt.Println("keyword", keyword)
+	startime := this.GetString("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)
+	PatientsInfo, err := service.GetSearchPatientInfo(orgId, keyword, statime, entime)
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"PatientsInfo": PatientsInfo,
+	})
+}

controllers/new_mobile_api_controllers/new_common_api_router.go

@@ -9,4 +9,13 @@ func NewCommonApiControllersRegisterRouters() {
 	beego.Router("/m/api/getmobiletotalsexcount", &NewCommonApiController{}, "Get:GetMobileTotalSexCount")
 	beego.Router("/m/api/getmobiletotalinfectiouscount", &NewCommonApiController{}, "Get:GetMobileTotalInfectiousCout")
 	beego.Router("/m/api/getmobiletotalagecount", &NewCommonApiController{}, "Get:GetMobileTotalAgeCount")
+	beego.Router("/m/api/getmobiletotaldialysiscount", &NewCommonApiController{}, "Get:GetMobileTotalDialysisCount")
+	beego.Router("/m/api/gemobilepatientlist", &NewCommonApiController{}, "Get:GetMobilePatientList")
+	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")
+	beego.Router("/m/api/getmobileInspectionList", &NewCommonApiController{}, "Get:GetMobileInspectionList")
+	beego.Router("/m/api/getpatientinspectiondetail", &NewCommonApiController{}, "Get:GetPatientInspectionDetail")
+	beego.Router("m/api/getseachpatientdetail", &NewCommonApiController{}, "Get:GetSeachPatientDetail")
 }

controllers/new_mobile_api_controllers/new_login_api_controller.go

@@ -295,6 +295,22 @@ func (this *NewLoginApiController) LoginByCs() {
 				}
 			}
 
+			if org.Id > 0 {
+				QualityeList, err := service.FindQualityByOrgId(org.Id)
+				if len(QualityeList) == 0 {
+					err = service.BatchInsertQualityControl(org.Id)
+				} else {
+					utils.ErrorLog("字段批量插入失败0：%v", err)
+				}
+
+				InspectionList, err := service.FindeInspectionByOrgId(org.Id)
+				if len(InspectionList) == 0 {
+					err = service.BatchInspectionConfiguration(org.Id)
+				} else {
+					utils.ErrorLog("字段批量插入失败0：%v", err)
+				}
+			}
+
 			this.ServeSuccessJSON(map[string]interface{}{
 				"admin": adminUser,
 				"user": map[string]interface{}{

controllers/patient_api_controller.go

@@ -252,29 +252,29 @@ func (c *PatientApiController) CreatePatient() {
 	//获取老表的最后一条数据
 	patients, err := service.GetLastPatientData(adminUserInfo.CurrentOrgId)
 	patientsNew := models.XtPatientsNew{
-		UserOrgId:          adminUserInfo.CurrentOrgId,
-		UserId:             0,
-		Avatar:             patients.Avatar,
-		PatientType:        patients.PatientType,
-		DialysisNo:         patients.DialysisNo,
-		AdmissionNumber:    patients.AdmissionNumber,
-		Source:             patients.Source,
-		Lapseto:            patients.Lapseto,
-		PartitionId:        patients.PartitionId,
-		BedId:              patients.BedId,
-		Name:               patients.Name,
-		Alias:              patients.Alias,
-		Gender:             patients.Gender,
-		MaritalStatus:      patients.MaritalStatus,
-		IdCardNo:           patients.IdCardNo,
-		Birthday:           patients.Birthday,
-		ReimbursementWayId: patients.ReimbursementWayId,
-		HealthCareType:     patients.HealthCareType,
-		HealthCareNo:       patients.HealthCareNo,
-		HealthCareDueDate:  patients.HealthCareDueDate,
-		Height:             patients.Height,
-		BloodType:          patients.BloodType,
-		Rh:                 patients.Rh,
+		UserOrgId:                    adminUserInfo.CurrentOrgId,
+		UserId:                       0,
+		Avatar:                       patients.Avatar,
+		PatientType:                  patients.PatientType,
+		DialysisNo:                   patients.DialysisNo,
+		AdmissionNumber:              patients.AdmissionNumber,
+		Source:                       patients.Source,
+		Lapseto:                      patients.Lapseto,
+		PartitionId:                  patients.PartitionId,
+		BedId:                        patients.BedId,
+		Name:                         patients.Name,
+		Alias:                        patients.Alias,
+		Gender:                       patients.Gender,
+		MaritalStatus:                patients.MaritalStatus,
+		IdCardNo:                     patients.IdCardNo,
+		Birthday:                     patients.Birthday,
+		ReimbursementWayId:           patients.ReimbursementWayId,
+		HealthCareType:               patients.HealthCareType,
+		HealthCareNo:                 patients.HealthCareNo,
+		HealthCareDueDate:            patients.HealthCareDueDate,
+		Height:                       patients.Height,
+		BloodType:                    patients.BloodType,
+		Rh:                           patients.Rh,
 		HealthCareDueAlertDate:       patients.HealthCareDueAlertDate,
 		EducationLevel:               patients.EducationLevel,
 		Profession:                   patients.Profession,
@@ -320,28 +320,28 @@ func (c *PatientApiController) CreatePatient() {
 		Nation:                       patients.Nation,
 		NativePlace:                  patients.NativePlace,
 		Age:                          patients.Age,
-		InfectiousNextRecordTime: patients.InfectiousNextRecordTime,
-		IsInfectious:             patients.IsInfectious,
-		RemindCycle:              patients.RemindCycle,
-		ResponseResult:           patients.ResponseResult,
-		IsOpenRemind:             patients.IsOpenRemind,
-		FirstTreatmentDate:       patients.FirstTreatmentDate,
-		DialysisAge:              patients.DialysisAge,
-		ExpenseKind:              patients.ExpenseKind,
-		TellPhone:                patients.TellPhone,
-		ContactName:              patients.ContactName,
-		BloodPatients:            1,
-		SlowPatients:             0,
-		MemberPatients:           0,
-		EcommerPatients:          "",
-		BloodId:                  patients.ID,
-		SlowId:                   0,
-		MemberId:                 0,
-		MemberFistdate:           0,
-		MemberPatienttype:        0,
-		MemberTreatement:         0,
-		EquitmentId:              "",
-		UserSysBeforeCount:       patient.UserSysBeforeCount,
+		InfectiousNextRecordTime:     patients.InfectiousNextRecordTime,
+		IsInfectious:                 patients.IsInfectious,
+		RemindCycle:                  patients.RemindCycle,
+		ResponseResult:               patients.ResponseResult,
+		IsOpenRemind:                 patients.IsOpenRemind,
+		FirstTreatmentDate:           patients.FirstTreatmentDate,
+		DialysisAge:                  patients.DialysisAge,
+		ExpenseKind:                  patients.ExpenseKind,
+		TellPhone:                    patients.TellPhone,
+		ContactName:                  patients.ContactName,
+		BloodPatients:                1,
+		SlowPatients:                 0,
+		MemberPatients:               0,
+		EcommerPatients:              "",
+		BloodId:                      patients.ID,
+		SlowId:                       0,
+		MemberId:                     0,
+		MemberFistdate:               0,
+		MemberPatienttype:            0,
+		MemberTreatement:             0,
+		EquitmentId:                  "",
+		UserSysBeforeCount:           patient.UserSysBeforeCount,
 	}
 
 	err = service.CreatePatientsNew(&patientsNew)
@@ -469,29 +469,29 @@ func (c *PatientApiController) EditPatient() {
 	}
 	fmt.Println("病人--------------------------------------------------------------", patient.Name, patient.Age)
 	patientsNew := models.XtPatientsNew{
-		UserOrgId:          patient.UserOrgId,
-		UserId:             patient.UserId,
-		Avatar:             patient.Avatar,
-		PatientType:        patient.PatientType,
-		DialysisNo:         patient.DialysisNo,
-		AdmissionNumber:    patient.AdmissionNumber,
-		Source:             patient.Source,
-		Lapseto:            patient.Lapseto,
-		PartitionId:        patient.PartitionId,
-		BedId:              patient.BedId,
-		Name:               patient.Name,
-		Alias:              patient.Alias,
-		Gender:             patient.Gender,
-		MaritalStatus:      patient.MaritalStatus,
-		IdCardNo:           patient.IdCardNo,
-		Birthday:           patient.Birthday,
-		ReimbursementWayId: patient.ReimbursementWayId,
-		HealthCareType:     patient.HealthCareType,
-		HealthCareNo:       patient.HealthCareNo,
-		HealthCareDueDate:  patient.HealthCareDueDate,
-		Height:             patient.Height,
-		BloodType:          patient.BloodType,
-		Rh:                 patient.Rh,
+		UserOrgId:                 patient.UserOrgId,
+		UserId:                    patient.UserId,
+		Avatar:                    patient.Avatar,
+		PatientType:               patient.PatientType,
+		DialysisNo:                patient.DialysisNo,
+		AdmissionNumber:           patient.AdmissionNumber,
+		Source:                    patient.Source,
+		Lapseto:                   patient.Lapseto,
+		PartitionId:               patient.PartitionId,
+		BedId:                     patient.BedId,
+		Name:                      patient.Name,
+		Alias:                     patient.Alias,
+		Gender:                    patient.Gender,
+		MaritalStatus:             patient.MaritalStatus,
+		IdCardNo:                  patient.IdCardNo,
+		Birthday:                  patient.Birthday,
+		ReimbursementWayId:        patient.ReimbursementWayId,
+		HealthCareType:            patient.HealthCareType,
+		HealthCareNo:              patient.HealthCareNo,
+		HealthCareDueDate:         patient.HealthCareDueDate,
+		Height:                    patient.Height,
+		BloodType:                 patient.BloodType,
+		Rh:                        patient.Rh,
 		HealthCareDueAlertDate:    patient.HealthCareDueAlertDate,
 		EducationLevel:            patient.EducationLevel,
 		Profession:                patient.Profession,
@@ -533,17 +533,17 @@ func (c *PatientApiController) EditPatient() {
 		Nation:                    patient.Nation,
 		NativePlace:               patient.NativePlace,
 		Age:                       patient.Age,
-		InfectiousNextRecordTime: patient.InfectiousNextRecordTime,
-		IsInfectious:             patient.IsInfectious,
-		RemindCycle:              patient.RemindCycle,
-		ResponseResult:           patient.ResponseResult,
-		IsOpenRemind:             patient.IsOpenRemind,
-		FirstTreatmentDate:       patient.FirstTreatmentDate,
-		DialysisAge:              patient.DialysisAge,
-		ExpenseKind:              patient.ExpenseKind,
-		TellPhone:                patient.TellPhone,
-		ContactName:              patient.ContactName,
-		UpdatedTime:              time.Now().Unix(),
+		InfectiousNextRecordTime:  patient.InfectiousNextRecordTime,
+		IsInfectious:              patient.IsInfectious,
+		RemindCycle:               patient.RemindCycle,
+		ResponseResult:            patient.ResponseResult,
+		IsOpenRemind:              patient.IsOpenRemind,
+		FirstTreatmentDate:        patient.FirstTreatmentDate,
+		DialysisAge:               patient.DialysisAge,
+		ExpenseKind:               patient.ExpenseKind,
+		TellPhone:                 patient.TellPhone,
+		ContactName:               patient.ContactName,
+		UpdatedTime:               time.Now().Unix(),
 	}
 	//	//更新病人ID获取新表病人ID
 	err = service.UpdatepatientTwo(&patientsNew, id)

controllers/verify_login_controller.go

@@ -166,6 +166,20 @@ func (this *VerifyUserLoginAPIController) VerifyToken() {
 				}
 			}
 
+			QualityeList, err := service.FindQualityByOrgId(curOrg.Id)
+			if len(QualityeList) == 0 {
+				err = service.BatchInsertQualityControl(curOrg.Id)
+			} else {
+				utils.ErrorLog("字段批量插入失败：%v", err)
+			}
+
+			InspectionList, err := service.FindeInspectionByOrgId(curOrg.Id)
+			if len(InspectionList) == 0 {
+				err = service.BatchInspectionConfiguration(curOrg.Id)
+			} else {
+				utils.ErrorLog("字段批量插入失败：%v", err)
+			}
+
 			var pruviews []*models.Purview
 			var curAppUrlfors []string
 			if len(curAppUrlfors) == 0 {

models/common_models.go

@@ -109,3 +109,219 @@ type PatientAgeCountStruct struct {
 	Age   int64 `json:"age"`
 	Count int64 `json:"count"`
 }
+
+type DialysisAgePieDataStruct struct {
+	Age   int64 `json:"age"`
+	Count int64 `json:"count"`
+}
+
+type BloodPatients struct {
+	ID                           int64   `gorm:"column:id" json:"id" form:"id"`
+	UserOrgId                    int64   `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
+	UserId                       int64   `gorm:"column:user_id" json:"user_id" form:"user_id"`
+	Avatar                       string  `gorm:"column:avatar" json:"avatar" form:"avatar"`
+	PatientType                  int64   `gorm:"column:patient_type" json:"patient_type" form:"patient_type"`
+	DialysisNo                   string  `gorm:"column:dialysis_no" json:"dialysis_no" form:"dialysis_no"`
+	AdmissionNumber              string  `gorm:"column:admission_number" json:"admission_number" form:"admission_number"`
+	Source                       int64   `gorm:"column:source" json:"source" form:"source"`
+	Lapseto                      int64   `gorm:"column:lapseto" json:"lapseto" form:"lapseto"`
+	PartitionId                  int64   `gorm:"column:partition_id" json:"partition_id" form:"partition_id"`
+	BedId                        int64   `gorm:"column:bed_id" json:"bed_id" form:"bed_id"`
+	Name                         string  `gorm:"column:name" json:"name" form:"name"`
+	Alias                        string  `gorm:"column:alias" json:"alias" form:"alias"`
+	Gender                       int64   `gorm:"column:gender" json:"gender" form:"gender"`
+	MaritalStatus                int64   `gorm:"column:marital_status" json:"marital_status" form:"marital_status"`
+	IdCardNo                     string  `gorm:"column:id_card_no" json:"id_card_no" form:"id_card_no"`
+	Birthday                     int64   `gorm:"column:birthday" json:"birthday" form:"birthday"`
+	ReimbursementWayId           int64   `gorm:"column:reimbursement_way_id" json:"reimbursement_way_id" form:"reimbursement_way_id"`
+	HealthCareType               int64   `gorm:"column:health_care_type" json:"health_care_type" form:"health_care_type"`
+	HealthCareNo                 string  `gorm:"column:health_care_no" json:"health_care_no" form:"health_care_no"`
+	HealthCareDueDate            int64   `gorm:"column:health_care_due_date" json:"health_care_due_date" form:"health_care_due_date"`
+	Height                       int64   `gorm:"column:height" json:"height" form:"height"`
+	BloodType                    int64   `gorm:"column:blood_type" json:"blood_type" form:"blood_type"`
+	Rh                           int64   `gorm:"column:rh" json:"rh" form:"rh"`
+	HealthCareDueAlertDate       int64   `gorm:"column:health_care_due_alert_date" json:"health_care_due_alert_date" form:"health_care_due_alert_date"`
+	EducationLevel               int64   `gorm:"column:education_level" json:"education_level" form:"education_level"`
+	Profession                   int64   `gorm:"column:profession" json:"profession" form:"profession"`
+	Phone                        string  `gorm:"column:phone" json:"phone" form:"phone"`
+	HomeTelephone                string  `gorm:"column:home_telephone" json:"home_telephone" form:"home_telephone"`
+	RelativePhone                string  `gorm:"column:relative_phone" json:"relative_phone" form:"relative_phone"`
+	RelativeRelations            string  `gorm:"column:relative_relations" json:"relative_relations" form:"relative_relations"`
+	HomeAddress                  string  `gorm:"column:home_address" json:"home_address" form:"home_address"`
+	WorkUnit                     string  `gorm:"column:work_unit" json:"work_unit" form:"work_unit"`
+	UnitAddress                  string  `gorm:"column:unit_address" json:"unit_address" form:"unit_address"`
+	Children                     int64   `gorm:"column:children" json:"children" form:"children"`
+	ReceivingDate                int64   `gorm:"column:receiving_date" json:"receiving_date" form:"receiving_date"`
+	IsHospitalFirstDialysis      int64   `gorm:"column:is_hospital_first_dialysis" json:"is_hospital_first_dialysis" form:"is_hospital_first_dialysis"`
+	FirstDialysisDate            int64   `gorm:"column:first_dialysis_date" json:"first_dialysis_date" form:"first_dialysis_date"`
+	FirstDialysisHospital        string  `gorm:"column:first_dialysis_hospital" json:"first_dialysis_hospital" form:"first_dialysis_hospital"`
+	PredialysisCondition         string  `gorm:"column:predialysis_condition" json:"predialysis_condition" form:"predialysis_condition"`
+	PreHospitalDialysisFrequency string  `gorm:"column:pre_hospital_dialysis_frequency" json:"pre_hospital_dialysis_frequency" form:"pre_hospital_dialysis_frequency"`
+	PreHospitalDialysisTimes     int64   `gorm:"column:pre_hospital_dialysis_times" json:"pre_hospital_dialysis_times" form:"pre_hospital_dialysis_times"`
+	HospitalFirstDialysisDate    int64   `gorm:"column:hospital_first_dialysis_date" json:"hospital_first_dialysis_date" form:"hospital_first_dialysis_date"`
+	InductionPeriod              int64   `gorm:"column:induction_period" json:"induction_period" form:"induction_period"`
+	InitialDialysis              int64   `gorm:"column:initial_dialysis" json:"initial_dialysis" form:"initial_dialysis"`
+	TotalDialysis                int64   `gorm:"column:total_dialysis" json:"total_dialysis" form:"total_dialysis"`
+	AttendingDoctorId            int64   `gorm:"column:attending_doctor_id" json:"attending_doctor_id" form:"attending_doctor_id"`
+	HeadNurseId                  int64   `gorm:"column:head_nurse_id" json:"head_nurse_id" form:"head_nurse_id"`
+	Evaluate                     string  `gorm:"column:evaluate" json:"evaluate" form:"evaluate"`
+	Diagnose                     string  `gorm:"column:diagnose" json:"diagnose" form:"diagnose"`
+	Remark                       string  `gorm:"column:remark" json:"remark" form:"remark"`
+	RegistrarsId                 int64   `gorm:"column:registrars_id" json:"registrars_id" form:"registrars_id"`
+	Registrars                   string  `gorm:"column:registrars" json:"registrars" form:"registrars"`
+	QrCode                       string  `gorm:"column:qr_code" json:"qr_code" form:"qr_code"`
+	BindingState                 int64   `gorm:"column:binding_state" json:"binding_state" form:"binding_state"`
+	PatientComplains             string  `gorm:"column:patient_complains" json:"patient_complains" form:"patient_complains"`
+	PresentHistory               string  `gorm:"column:present_history" json:"present_history" form:"present_history"`
+	PastHistory                  string  `gorm:"column:past_history" json:"past_history" form:"past_history"`
+	Temperature                  float64 `gorm:"column:temperature" json:"temperature" form:"temperature"`
+	Pulse                        int64   `gorm:"column:pulse" json:"pulse" form:"pulse"`
+	Respiratory                  int64   `gorm:"column:respiratory" json:"respiratory" form:"respiratory"`
+	Sbp                          int64   `gorm:"column:sbp" json:"sbp" form:"sbp"`
+	Dbp                          int64   `gorm:"column:dbp" json:"dbp" form:"dbp"`
+	Status                       int64   `gorm:"column:status" json:"status" form:"status"`
+	CreatedTime                  int64   `gorm:"column:created_time" json:"created_time" form:"created_time"`
+	UpdatedTime                  int64   `gorm:"column:updated_time" json:"updated_time" form:"updated_time"`
+	Nation                       string  `gorm:"column:nation" json:"nation" form:"nation"`
+	NativePlace                  string  `gorm:"column:native_place" json:"native_place" form:"native_place"`
+	Age                          int64   `gorm:"column:age" json:"age" form:"age"`
+	InfectiousNextRecordTime     int64   `gorm:"column:infectious_next_record_time" json:"infectious_next_record_time" form:"infectious_next_record_time"`
+	IsInfectious                 int64   `gorm:"column:is_infectious" json:"is_infectious" form:"is_infectious"`
+	RemindCycle                  int64   `gorm:"column:remind_cycle" json:"remind_cycle" form:"remind_cycle"`
+	ResponseResult               string  `gorm:"column:response_result" json:"response_result" form:"response_result"`
+	IsOpenRemind                 int64   `gorm:"column:is_open_remind" json:"is_open_remind" form:"is_open_remind"`
+	FirstTreatmentDate           int64   `gorm:"column:first_treatment_date" json:"first_treatment_date" form:"first_treatment_date"`
+	DialysisAge                  int64   `gorm:"column:dialysis_age" json:"dialysis_age" form:"dialysis_age"`
+	ExpenseKind                  int64   `gorm:"column:expense_kind" json:"expense_kind" form:"expense_kind"`
+	TellPhone                    string  `gorm:"column:tell_phone" json:"tell_phone" form:"tell_phone"`
+	ContactName                  string  `gorm:"column:contact_name" json:"contact_name" form:"contact_name"`
+	UserSysBeforeCount           int64   `gorm:"column:user_sys_before_count" json:"user_sys_before_count" form:"user_sys_before_count"`
+	IsExcelExport                int64   `gorm:"column:is_excel_export" json:"is_excel_export" form:"is_excel_export"`
+}
+
+func (BloodPatients) TableName() string {
+	return "xt_patients"
+}
+
+type BloodDialysisPrescription struct {
+	ID                         int64   `gorm:"column:id" json:"id" form:"id"`
+	UserOrgId                  int64   `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
+	PatientId                  int64   `gorm:"column:patient_id" json:"patient_id" form:"patient_id"`
+	Dialyzer                   int64   `gorm:"column:dialyzer" json:"dialyzer" form:"dialyzer"`
+	MachineType                string  `gorm:"column:machine_type" json:"machine_type" form:"machine_type"`
+	DewaterAmount              float64 `gorm:"column:dewater_amount" json:"dewater_amount" form:"dewater_amount"`
+	DialyzerPerfusionApparatus string  `gorm:"column:dialyzer_perfusion_apparatus" json:"dialyzer_perfusion_apparatus" form:"dialyzer_perfusion_apparatus"`
+	PrescriptionDewatering     float64 `gorm:"column:prescription_dewatering" json:"prescription_dewatering" form:"prescription_dewatering"`
+	Anticoagulant              int64   `gorm:"column:anticoagulant" json:"anticoagulant" form:"anticoagulant"`
+	AnticoagulantShouji        float64 `gorm:"column:anticoagulant_shouji" json:"anticoagulant_shouji" form:"anticoagulant_shouji"`
+	AnticoagulantWeichi        float64 `gorm:"column:anticoagulant_weichi" json:"anticoagulant_weichi" form:"anticoagulant_weichi"`
+	AnticoagulantZongliang     float64 `gorm:"column:anticoagulant_zongliang" json:"anticoagulant_zongliang" form:"anticoagulant_zongliang"`
+	AnticoagulantGaimingcheng  string  `gorm:"column:anticoagulant_gaimingcheng" json:"anticoagulant_gaimingcheng" form:"anticoagulant_gaimingcheng"`
+	AnticoagulantGaijiliang    string  `gorm:"column:anticoagulant_gaijiliang" json:"anticoagulant_gaijiliang" form:"anticoagulant_gaijiliang"`
+	ModeId                     int64   `gorm:"column:mode_id" json:"mode_id" form:"mode_id"`
+	DialysisDurationHour       int64   `gorm:"column:dialysis_duration_hour" json:"dialysis_duration_hour" form:"dialysis_duration_hour"`
+	DialysisDurationMinute     int64   `gorm:"column:dialysis_duration_minute" json:"dialysis_duration_minute" form:"dialysis_duration_minute"`
+	DialysisDuration           float64 `gorm:"column:dialysis_duration" json:"dialysis_duration" form:"dialysis_duration"`
+	ReplacementTotal           float64 `gorm:"column:replacement_total" json:"replacement_total" form:"replacement_total"`
+	ReplacementWay             int64   `gorm:"column:replacement_way" json:"replacement_way" form:"replacement_way"`
+	HemodialysisMachine        int64   `gorm:"column:hemodialysis_machine" json:"hemodialysis_machine" form:"hemodialysis_machine"`
+	BloodFilter                int64   `gorm:"column:blood_filter" json:"blood_filter" form:"blood_filter"`
+	PerfusionApparatus         int64   `gorm:"column:perfusion_apparatus" json:"perfusion_apparatus" form:"perfusion_apparatus"`
+	DryWeight                  float64 `gorm:"column:dry_weight" json:"dry_weight" form:"dry_weight"`
+	VascularAccessMode         int64   `gorm:"column:vascular_access_mode" json:"vascular_access_mode" form:"vascular_access_mode"`
+	VascularAccess             int64   `gorm:"column:vascular_access" json:"vascular_access" form:"vascular_access"`
+	BloodFlowVolume            float64 `gorm:"column:blood_flow_volume" json:"blood_flow_volume" form:"blood_flow_volume"`
+	DialysateFlow              float64 `gorm:"column:dialysate_flow" json:"dialysate_flow" form:"dialysate_flow"`
+	DisplaceLiqui              float64 `gorm:"column:displace_liqui" json:"displace_liqui" form:"displace_liqui"`
+	Kalium                     float64 `gorm:"column:kalium" json:"kalium" form:"kalium"`
+	Sodium                     float64 `gorm:"column:sodium" json:"sodium" form:"sodium"`
+	Calcium                    float64 `gorm:"column:calcium" json:"calcium" form:"calcium"`
+	Bicarbonate                float64 `gorm:"column:bicarbonate" json:"bicarbonate" form:"bicarbonate"`
+	Glucose                    float64 `gorm:"column:glucose" json:"glucose" form:"glucose"`
+	DialysateTemperature       float64 `gorm:"column:dialysate_temperature" json:"dialysate_temperature" form:"dialysate_temperature"`
+	Conductivity               float64 `gorm:"column:conductivity" json:"conductivity" form:"conductivity"`
+	PrescriptionDoctor         int64   `gorm:"column:prescription_doctor" json:"prescription_doctor" form:"prescription_doctor"`
+	Creater                    int64   `gorm:"column:creater" json:"creater" form:"creater"`
+	Modifier                   int64   `gorm:"column:modifier" json:"modifier" form:"modifier"`
+	Remark                     string  `gorm:"column:remark" json:"remark" form:"remark"`
+	Status                     int64   `gorm:"column:status" json:"status" form:"status"`
+	CreatedTime                int64   `gorm:"column:created_time" json:"created_time" form:"created_time"`
+	UpdatedTime                int64   `gorm:"column:updated_time" json:"updated_time" form:"updated_time"`
+	RecordDate                 int64   `gorm:"column:record_date" json:"record_date" form:"record_date"`
+	RecordId                   int64   `gorm:"column:record_id" json:"record_id" form:"record_id"`
+	TargetUltrafiltration      float64 `gorm:"column:target_ultrafiltration" json:"target_ultrafiltration" form:"target_ultrafiltration"`
+	DialysateFormulation       int64   `gorm:"column:dialysate_formulation" json:"dialysate_formulation" form:"dialysate_formulation"`
+	BodyFluid                  int64   `gorm:"column:body_fluid" json:"body_fluid" form:"body_fluid"`
+	SpecialMedicine            int64   `gorm:"column:special_medicine" json:"special_medicine" form:"special_medicine"`
+	SpecialMedicineOther       string  `gorm:"column:special_medicine_other" json:"special_medicine_other" form:"special_medicine_other"`
+	DisplaceLiquiPart          int64   `gorm:"column:displace_liqui_part" json:"displace_liqui_part" form:"displace_liqui_part"`
+	BloodAccess                int64   `gorm:"column:blood_access" json:"blood_access" form:"blood_access"`
+	DisplaceLiquiValue         float64 `gorm:"column:displace_liqui_value" json:"displace_liqui_value" form:"displace_liqui_value"`
+	Ultrafiltration            float64 `gorm:"column:ultrafiltration" json:"ultrafiltration" form:"ultrafiltration"`
+	BodyFluidOther             string  `gorm:"column:body_fluid_other" json:"body_fluid_other" form:"body_fluid_other"`
+	Niprocart                  int64   `gorm:"column:niprocart" json:"niprocart" form:"niprocart"`
+	Jms                        int64   `gorm:"column:jms" json:"jms" form:"jms"`
+	FistulaNeedleSet           int64   `gorm:"column:fistula_needle_set" json:"fistula_needle_set" form:"fistula_needle_set"`
+	FistulaNeedleSet16         int64   `gorm:"column:fistula_needle_set_16" json:"fistula_needle_set_16" form:"fistula_needle_set_16"`
+	Hemoperfusion              int64   `gorm:"column:hemoperfusion" json:"hemoperfusion" form:"hemoperfusion"`
+	DialyserSterilised         int64   `gorm:"column:dialyser_sterilised" json:"dialyser_sterilised" form:"dialyser_sterilised"`
+	Filtryzer                  int64   `gorm:"column:filtryzer" json:"filtryzer" form:"filtryzer"`
+	TargetKtv                  float64 `gorm:"column:target_ktv" json:"target_ktv" form:"target_ktv"`
+	Dialyzers                  int64   `gorm:"column:dialyzers" json:"dialyzers" form:"dialyzers"`
+	Injector                   int64   `gorm:"column:injector" json:"injector" form:"injector"`
+	Bloodlines                 int64   `gorm:"column:bloodlines" json:"bloodlines" form:"bloodlines"`
+	TubingHemodialysis         int64   `gorm:"column:tubing_hemodialysis" json:"tubing_hemodialysis" form:"tubing_hemodialysis"`
+	Package                    int64   `gorm:"column:package" json:"package" form:"package"`
+	ALiquid                    int64   `gorm:"column:a_liquid" json:"a_liquid" form:"a_liquid"`
+	Name                       string  `gorm:"column:name" json:"name" form:"name"`
+	DialysisNo                 string  `gorm:"column:dialysis_no" json:"dialysis_no" form:"dialysis_no"`
+	IdCardNo                   string  `gorm:"column:id_card_no" json:"id_card_no" form:"id_card_no"`
+	TotalDialysis              int64   `gorm:"column:total_dialysis" json:"total_dialysis" form:"total_dialysis"`
+	UserSysBeforeCount         int64   `gorm:"column:user_sys_before_count" json:"user_sys_before_count" form:"user_sys_before_count"`
+}
+
+func (BloodDialysisPrescription) TableName() string {
+	return "xt_dialysis_prescription"
+}
+
+type DialysisTotalDataStruct struct {
+	Date   string `json:"date"`
+	Number string `json:"number"`
+	ModeID string `json:"mode_id"`
+}
+
+type UserInspectionProjectCount struct {
+	PatientId int64
+	Count     int64
+	ProjectId int64
+}
+
+type InspectionReferenceMaps struct {
+	ProjectName        string               `gorm:"-" json:"project_name" form:"project_name"`
+	Project            string               `gorm:"-" json:"project" form:"project"`
+	ProjectId          int64                `gorm:"-" json:"project_id" form:"project_id"`
+	Count              int64                `gorm:"-" json:"count" form:"count"`
+	CheckConfiguration []CheckConfiguration `gorm:"-" json:"inspection_reference" form:"inspection_reference"`
+}
+
+type PatientsInspection struct {
+	ID           int64  `gorm:"column:id" json:"id" form:"id"`
+	PatientId    int64  `gorm:"column:patient_id" json:"patient_id" form:"patient_id"`
+	OrgId        int64  `gorm:"column:org_id" json:"org_id" form:"org_id"`
+	ProjectId    int64  `gorm:"column:project_id" json:"project_id" form:"project_id"`
+	ItemId       int64  `gorm:"column:item_id" json:"item_id" form:"item_id"`
+	ItemName     string `gorm:"column:item_name" json:"item_name" form:"item_name"`
+	ProjectName  string `gorm:"column:project_name" json:"project_name" form:"project_name"`
+	InspectType  int64  `gorm:"column:inspect_type" json:"inspect_type" form:"inspect_type"`
+	InspectValue string `gorm:"column:inspect_value" json:"inspect_value" form:"inspect_value"`
+	InspectDate  int64  `gorm:"column:inspect_date" json:"inspect_date" form:"inspect_date"`
+	Status       int64  `gorm:"column:status" json:"status" form:"status"`
+	CreatedTime  int64  `gorm:"column:created_time" json:"created_time" form:"created_time"`
+	UpdatedTime  int64  `gorm:"column:updated_time" json:"updated_time" form:"updated_time"`
+	Name         string `gorm:"column:name" json:"name" form:"name"`
+}
+
+func (PatientsInspection) TableName() string {
+
+	return "xt_inspection"
+}

models/inspection_models.go

@@ -68,10 +68,12 @@ func (InspectionReference) TableName() string {
 	return "xt_inspection_reference"
 }
 
-type UserInspectionProjectCount struct {
-	PatientId int64
-	Count     int64
-	ProjectId int64
+type UserInspectionProjectCounts struct {
+	PatientId           int64
+	Count               int64
+	ProjectId           int64
+	ProjectName         string
+	InspectionFrequency string
 }
 
 type UserDoctorAdvicesCount struct {

service/common_service.go

@@ -263,3 +263,350 @@ func GetTotalDialysisAgeCount(orgid int64) (patients []*models.XtPatients, err e
 	err = XTReadDB().Where("user_org_id = ? and status =1", orgid).Find(&patients).Error
 	return patients, err
 }
+
+func GetDialysisAgeData(orgID int64) (counts []*models.DialysisAgePieDataStruct, err error) {
+	loc, _ := time.LoadLocation("Local")
+	nowTime := time.Now()
+	nowDay := nowTime.Format("2006-01-02")
+	dayTime, err := time.ParseInLocation("2006-01-02 15:04:05", nowDay+" 00:00:00", loc)
+	fmt.Println("datTime", dayTime)
+	if err != nil {
+		return
+	}
+	oneYearPoint := dayTime.AddDate(-12, 0, 0).Unix()
+
+	fiveYearPoint := dayTime.AddDate(-36, 0, 0).Unix()
+
+	tenYearPoint := dayTime.AddDate(-60, 0, 0).Unix()
+
+	twentyYearPoint := dayTime.AddDate(-61, 0, 0).Unix()
+
+	db := readDb.Table("xt_patients").Where("status=1")
+	countSQL := "SELECT nnd AS 'age',COUNT(*) AS 'count' FROM(" +
+		"SELECT " +
+		"CASE " +
+		" WHEN first_dialysis_date<>0 AND first_dialysis_date>? THEN '1'" +
+		" WHEN first_dialysis_date<>0 AND first_dialysis_date>? && first_dialysis_date<=? THEN '2'" +
+		" WHEN first_dialysis_date<>0 AND first_dialysis_date>? && first_dialysis_date<=? THEN '3'" +
+		" WHEN first_dialysis_date<>0 AND first_dialysis_date>? && first_dialysis_date<=? THEN '4'" +
+		" WHEN first_dialysis_date<>0 AND first_dialysis_date<=? THEN '5'" +
+		" ELSE '0'" +
+		"END AS nnd FROM xt_patients WHERE status=1"
+	countParams := make([]interface{}, 0)
+	countParams = append(countParams, oneYearPoint)
+	countParams = append(countParams, fiveYearPoint)
+	countParams = append(countParams, oneYearPoint)
+	countParams = append(countParams, tenYearPoint)
+	countParams = append(countParams, fiveYearPoint)
+	countParams = append(countParams, twentyYearPoint)
+	countParams = append(countParams, tenYearPoint)
+	countParams = append(countParams, twentyYearPoint)
+
+	if orgID > 0 {
+		db = db.Where("user_org_id=?", orgID)
+		countSQL += " AND user_org_id=?"
+		countParams = append(countParams, orgID)
+	}
+
+	countSQL += ")a GROUP BY nnd"
+	err = readDb.Raw(countSQL, countParams...).Scan(&counts).Error
+	return
+
+}
+
+func GetCurentOrgPatients(orgid int64) (patients []*models.XtPatients, err error) {
+
+	err = XTReadDB().Where("user_org_id = ? and status =1", orgid).Order("created_time desc").Find(&patients).Error
+	return patients, err
+}
+
+func GetDialysisList(startime int64, endtime int64, page int64, limit int64, orgid int64) (prescription []*models.BloodDialysisPrescription, total int64, err error) {
+	db := XTReadDB().Table("xt_dialysis_prescription as p").Where("p.status =1 ")
+	table := XTReadDB().Table("xt_patients as s")
+	fmt.Println("table", table)
+	if orgid > 0 {
+		db = db.Where("p.user_org_id = ?", orgid)
+	}
+	if startime > 0 {
+		db = db.Where("p.record_date >= ?", startime)
+	}
+	if endtime > 0 {
+		db = db.Where("p.record_date <=?", endtime)
+	}
+	offset := (page - 1) * limit
+	err = db.Group("p.patient_id,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 GetAllDialysisList(startime int64, endtime int64, orgid int64) (prescription []*models.BloodDialysisPrescription, err error) {
+
+	db := XTReadDB().Table("xt_dialysis_prescription as p").Where("p.status =1 ")
+	table := XTReadDB().Table("xt_patients as s")
+	fmt.Println(table)
+	if orgid > 0 {
+		db = db.Where("p.user_org_id = ?", orgid)
+	}
+	if startime > 0 {
+		db = db.Where("p.record_date >= ?", startime)
+	}
+	if endtime > 0 {
+		db = db.Where("p.record_date <=?", endtime)
+	}
+	err = db.Group("p.patient_id,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").Scan(&prescription).Error
+	return prescription, err
+}
+
+func GetDialysisPatientList(startime int64, endtime int64, page int64, limit int64, orgid int64) (prescription []*models.BloodDialysisPrescription, total int64, err error) {
+	db := XTReadDB().Table("xt_dialysis_prescription as p").Where("p.status =1 ")
+	table := XTReadDB().Table("xt_patients as s")
+	fmt.Println("table", table)
+	if orgid > 0 {
+		db = db.Where("p.user_org_id = ?", orgid)
+	}
+	if startime > 0 {
+		db = db.Where("p.record_date >= ?", startime)
+	}
+	if endtime > 0 {
+		db = db.Where("p.record_date <=?", endtime)
+	}
+	offset := (page - 1) * limit
+	err = db.Group("p.patient_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 GetLastSort(orgid int64) (models.XtQualityControlStandard, error) {
+	standard := models.XtQualityControlStandard{}
+	err := XTReadDB().Model(&standard).Where("user_org_id = ? and status =1", orgid).Last(&standard).Error
+	return standard, err
+}
+
+func GetLastCheckList(orgid int64) (models.XtCheckConfiguration, error) {
+	configuration := models.XtCheckConfiguration{}
+	err := XTReadDB().Model(&configuration).Where("user_org_id = ? and status =1", orgid).Last(&configuration).Error
+	return configuration, err
+}
+
+func GetDialysisDetailById(id int64, orgid int64, startime int64, endtime int64, limit int64, page int64) (prescription []*models.BloodDialysisPrescription, total int64, err error) {
+
+	db := XTReadDB().Table("xt_dialysis_prescription as p").Where("p.status =1 ")
+	table := XTReadDB().Table("xt_patients as s")
+	fmt.Println(table)
+	if id > 0 {
+		db = db.Where("p.patient_id = ?", id)
+	}
+
+	if orgid > 0 {
+		db = db.Where("p.user_org_id = ?", orgid)
+	}
+	if startime > 0 {
+		db = db.Where("p.record_date >= ?", startime)
+	}
+	if endtime > 0 {
+		db = db.Where("p.record_date <=?", endtime)
+	}
+	offset := (page - 1) * limit
+	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 GetPrescritionByName(orgid int64, keywords string, startime int64, endtime int64, limit int64, page int64) (prescription []*models.BloodDialysisPrescription, total int64, err error) {
+
+	db := XTReadDB().Table("xt_dialysis_prescription as p").Where("p.status =1 ")
+	table := XTReadDB().Table("xt_patients as s")
+	fmt.Println(table)
+	if len(keywords) > 0 {
+		likeKey := "%" + keywords + "%"
+		db = db.Where("s.name LIKE ? OR s.dialysis_no LIKE ?", likeKey, likeKey)
+	}
+	if orgid > 0 {
+		db = db.Where("p.user_org_id = ?", orgid)
+	}
+	if startime > 0 {
+		db = db.Where("p.record_date >= ?", startime)
+	}
+	if endtime > 0 {
+		db = db.Where("p.record_date <=?", endtime)
+	}
+	offset := (page - 1) * limit
+	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
+}
+
+func GetInspectionTotalCount(orgid int64) (configuration []*models.CheckConfiguration, err error) {
+	var count int
+	db := XTReadDB().Table("xt_check_configuration as x").Where("x.status = 1")
+	table := XTReadDB().Table("xt_inspection_reference as s")
+	if orgid > 0 {
+		db = db.Where("x.user_org_id = ?", orgid)
+	}
+	fmt.Println(table)
+	err = db.Group("x.inspection_major").Select("x.id,x.inspection_major,x.inspection_frequency,x.sort,x.user_org_id,s.project_name").Joins("left join xt_inspection_reference as s on s.project_id = x.inspection_major").Count(&count).Order("x.sort asc").Scan(&configuration).Error
+	return configuration, err
+}
+
+func GetInspectionProjectCount(orgid int64, startime int64, endtime int64) (projectCounts []*models.UserInspectionProjectCounts, err error) {
+
+	db := XTReadDB().Table("xt_inspection as x").Where("x.status = 1")
+	table := XTReadDB().Table("xt_inspection_reference as r")
+	fmt.Println(table)
+	d := XTReadDB().Table("xt_check_configuration as t").Where("t.status = 1")
+	fmt.Println(d)
+	if orgid > 0 {
+		db = db.Where("x.org_id = ?", orgid)
+	}
+	if startime > 0 {
+		db = db.Where("x.inspect_date >=?", startime)
+	}
+	if endtime > 0 {
+		db = db.Where("x.inspect_date <=?", endtime)
+	}
+
+	err = db.Select("count(distinct x.inspect_date) as count,x.patient_id,x.project_id,r.project_name").Joins("left join xt_check_configuration as t on t.inspection_major = x.project_id").Joins("left  join xt_inspection_reference as r on r.project_id = x.project_id").Group("project_id,patient_id").Scan(&projectCounts).Error
+	return
+}
+
+func GetInspectionDetailById(id int64, orgid int64, startime int64, endtime int64) (projectCounts []*models.UserInspectionProjectCounts, err error) {
+	db := XTReadDB().Table("xt_inspection as x").Where("x.status = 1")
+	table := XTReadDB().Table("xt_inspection_reference as r")
+	fmt.Println(table)
+	d := XTReadDB().Table("xt_check_configuration as t").Where("t.status = 1")
+	fmt.Println(d)
+	if id > 0 {
+		db = db.Where("x.patient_id=?", id)
+	}
+	if orgid > 0 {
+		db = db.Where("x.org_id = ?", orgid)
+	}
+	if startime > 0 {
+		db = db.Where("x.inspect_date >=?", startime)
+	}
+	if endtime > 0 {
+		db = db.Where("x.inspect_date <=?", endtime)
+	}
+
+	err = db.Select("count(distinct x.inspect_date) as count,x.patient_id,x.project_id,r.project_name,t.inspection_frequency").Joins("left join xt_check_configuration as t on t.inspection_major = x.project_id").Joins("left  join xt_inspection_reference as r on r.project_id = x.project_id").Group("project_id,patient_id").Scan(&projectCounts).Error
+	return
+}
+
+func GetSearchPatientInfo(orgid int64, keywords string, startime int64, endtime int64) (projectCounts []*models.UserInspectionProjectCounts, err error) {
+
+	db := XTReadDB().Table("xt_inspection as x").Where("x.status = 1")
+	table := XTReadDB().Table("xt_inspection_reference as r")
+	fmt.Println(table)
+	d := XTReadDB().Table("xt_check_configuration as t").Where("t.status = 1")
+	fmt.Println(d)
+	p := XTReadDB().Table("xt_patients as p")
+	fmt.Println(p)
+	if len(keywords) > 0 {
+		likeKey := "%" + keywords + "%"
+		db = db.Where("p.name LIKE ? OR p.dialysis_no LIKE ?", likeKey, likeKey)
+	}
+	if orgid > 0 {
+		db = db.Where("x.org_id = ?", orgid)
+	}
+	if startime > 0 {
+		db = db.Where("x.inspect_date >=?", startime)
+	}
+	if endtime > 0 {
+		db = db.Where("x.inspect_date <=?", endtime)
+	}
+
+	err = db.Select("count(distinct x.inspect_date) as count,x.patient_id,x.project_id,r.project_name,t.inspection_frequency").Joins("left join xt_check_configuration as t on t.inspection_major = x.project_id").Joins("left  join xt_inspection_reference as r on r.project_id = x.project_id").Joins("left join xt_patients as p on p.id = x.patient_id").Group("project_id,patient_id").Scan(&projectCounts).Error
+	return
+}
+
+func GetMajorInspectionByOrgid(orgid int64) (checkconfiguration []*models.CheckConfiguration, err error) {
+
+	db := XTReadDB().Table("xt_check_configuration as x").Where("x.status =1")
+	table := XTReadDB().Table("xt_inspection_reference ar r")
+	fmt.Println(table)
+	err = db.Group("x.inspection_major").Select("x.id,x.inspection_major,x.inspection_frequency,x.sort,x.user_org_id,r.project_name").Where("x.user_org_id = ?", orgid).Joins("left join xt_inspection_reference as r on r.project_id = x.inspection_major").Scan(&checkconfiguration).Error
+	return checkconfiguration, err
+}
+
+func GetDefaultByOrgId(orgid int64) (checkconfiguration []*models.CheckConfiguration, err error) {
+
+	db := XTReadDB().Table("xt_check_configuration as x").Where("x.status =1")
+	table := XTReadDB().Table("xt_inspection_reference ar r")
+	fmt.Println(table)
+	err = db.Group("x.inspection_major").Select("x.id,x.inspection_major,x.inspection_frequency,x.sort,x.user_org_id,r.project_name").Where("x.user_org_id = ?", orgid).Joins("left join xt_inspection_reference as r on r.project_id = x.inspection_major").Scan(&checkconfiguration).Error
+	return checkconfiguration, err
+}
+
+func GetPatientListData(orgid int64, startime int64, endtime int64, limit int64, page int64) (inspection []*models.PatientsInspection, total int64, err error) {
+
+	db := XTReadDB().Table("xt_inspection as x").Where("x.status = 1")
+	table := XTReadDB().Table("xt_patients as s")
+	fmt.Println("table", table)
+	if orgid > 0 {
+		db = db.Where("x.org_id = ?", orgid)
+	}
+	if startime > 0 {
+		db = db.Where("x.inspect_date >= ?", startime)
+	}
+	if endtime > 0 {
+		db = db.Where("x.inspect_date <=?", endtime)
+	}
+	offset := (page - 1) * limit
+	err = db.Group("x.patient_id").Select("x.id,x.patient_id,x.project_id,x.project_name,s.name").Joins("left join xt_patients as s on s.id = x.patient_id").Count(&total).Offset(offset).Limit(limit).Scan(&inspection).Error
+	return inspection, total, err
+}

service/data.go

@@ -171,11 +171,35 @@ func FindFiledByOrgId(org_id int64) (filedConfig []*models.FiledConfig, err erro
 	return
 }
 
+func FindQualityByOrgId(orgid int64) (xtquality []*models.XtQualityControlStandard, err error) {
+
+	err = readDb.Model(&models.XtQualityControlStandard{}).Where("user_org_id =? and status =1", orgid).Find(&xtquality).Error
+	return
+}
+
+func FindeInspectionByOrgId(orgid int64) (xtquality []*models.XtCheckConfiguration, err error) {
+
+	err = readDb.Model(&models.XtQualityControlStandard{}).Where("user_org_id = ? and status =1", orgid).Find(&xtquality).Error
+	return
+}
+
 func BatchInsertFiledConfig(org_id int64) (err error) {
 	err = readDb.Exec("INSERT  INTO sgj_xt.xt_filed_config  ( org_id,  module,  filed_name,  filed_name_cn,  is_show ) SELECT ?,  module,  filed_name,  filed_name_cn,  is_show FROM sgj_xt.xt_filed_config  WHERE org_id = 0 AND is_show = 1", org_id).Error
 	return
 }
 
+func BatchInsertQualityControl(org_id int64) (err error) {
+
+	err = readDb.Exec("INSERT INTO xt_quality_control_standard(user_org_id,inspection_major,inspection_minor,min_range,large_range,sort,created_time,status) SELECT ?,inspection_major,inspection_minor,min_range,large_range,sort,created_time,status FROM xt_quality_control_standard where user_org_id = 0", org_id).Error
+	return
+}
+
+func BatchInspectionConfiguration(orgid int64) (err error) {
+
+	err = readDb.Exec("INSERT INTO xt_check_configuration(user_org_id,inspection_major,inspection_frequency,sort,created_time,status) SELECT ?,inspection_major,inspection_frequency,sort,created_time,status FROM xt_check_configuration where user_org_id = 0", orgid).Error
+	return
+}
+
 func ShowFiledConfig(org_id int64, isShow int, id int64) (err error) {
 	err = readDb.Model(&models.FiledConfig{}).Where("org_id = ? AND id = ?", org_id, id).Updates(map[string]interface{}{"ctime": time.Now().Unix(), "mtime": time.Now().Unix(), "is_show": isShow}).Error
 	return

service/qcd_service.go

@@ -114,6 +114,7 @@ func GetProcessIndicatorsData(orgID, page, limit, lapseto, dialysisAge, projectI
 			nowTime := time.Now()
 			nowDay := nowTime.Format("2006-01-02")
 			dayTime, err := time.ParseInLocation("2006-01-02 15:04:05", nowDay+" 00:00:00", loc)
+
 			if err != nil {
 				return inspections, references, patients, counts, total, err
 			}
@@ -526,6 +527,7 @@ type PADialysisAgePieDataStruct struct {
 }
 
 func GetPADialysisAgeData(orgID, page, limit, lapseto, age, dialysisAge, startTime, endTime int64, isStartTime, isEndTime bool) (patients []*models.Patients, counts []*PADialysisAgePieDataStruct, total int64, err error) {
+
 	loc, _ := time.LoadLocation("Local")
 	nowTime := time.Now()
 	nowDay := nowTime.Format("2006-01-02")
@@ -550,7 +552,7 @@ func GetPADialysisAgeData(orgID, page, limit, lapseto, age, dialysisAge, startTi
 		" WHEN first_dialysis_date<>0 AND first_dialysis_date>? && first_dialysis_date<=? THEN '4'" +
 		" WHEN first_dialysis_date<>0 AND first_dialysis_date<=? THEN '5'" +
 		" ELSE '0'" +
-		"END AS nnd FROM xt_patients WHERE status=1 "
+		"END AS nnd FROM xt_patients WHERE status=1"
 	countParams := make([]interface{}, 0)
 	countParams = append(countParams, oneYearPoint)
 	countParams = append(countParams, fiveYearPoint)