提交代码

controllers/statistics_api_controller.go

@@ -2,11 +2,13 @@ package controllers
 
 import (
 	"XT_New/enums"
+	"XT_New/models"
 	"XT_New/service"
 	"XT_New/utils"
 	"fmt"
 	"github.com/astaxie/beego"
 	"strconv"
+	"strings"
 	"time"
 )
 
@@ -26,6 +28,465 @@ func StatisticsApiRegistRouters() {
 	beego.Router("/api/commonqc/statistiscperson/get", &StatisticsApiController{}, "get:GetPersonCommonInspectionStatistisc")
 	beego.Router("/api/commonqc/patientstatistiscall/get", &StatisticsApiController{}, "get:GetPatientCommonInspectionStatistisc")
 
+	//透析总量统计
+	beego.Router("/api/commonqc/dialysis/total", &StatisticsApiController{}, "get:GetDialysisTotal")
+	beego.Router("/api/commonqc/dialysis/detail", &StatisticsApiController{}, "get:GetDialysisTotalDetail")
+	beego.Router("/api/commonqc/dialysis/details", &StatisticsApiController{}, "get:GetDialysisTotalDetailInfo")
+
+	beego.Router("/api/commonqc/anticoagulant", &StatisticsApiController{}, "get:GetAnticoagulant")
+	beego.Router("/api/commonqc/anticoagulant/detail", &StatisticsApiController{}, "get:GetAnticoagulantDetail")
+
+	beego.Router("/api/commonqc/dialyzer", &StatisticsApiController{}, "get:GetDialyzer")
+	beego.Router("/api/commonqc/dialyzer/config", &StatisticsApiController{}, "get:GetDialyzerConfig")
+	beego.Router("/api/commonqc/dialyzer/detail", &StatisticsApiController{}, "get:GetDialyzerDetail")
+
+	beego.Router("/api/commonqc/dialysistreat/finish", &StatisticsApiController{}, "get:GetDialysisTreatFinsh")
+	beego.Router("/api/commonqc/dialysistreat/detail", &StatisticsApiController{}, "get:GetDialysisTreatDetail")
+
+}
+
+func (c *StatisticsApiController) GetDialysisTreatFinsh() {
+	start_date := c.GetString("start_date")
+	end_date := c.GetString("end_date")
+	timeLayout := "2006-01-02"
+	loc, _ := time.LoadLocation("Local")
+	var startTime int64
+	if len(start_date) > 0 {
+		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", start_date+" 00:00:00", loc)
+		fmt.Println("err-----------", err)
+		if err != nil {
+			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+			return
+		}
+		startTime = theTime.Unix()
+	}
+	var endTime int64
+	if len(end_date) > 0 {
+		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", end_date+" 23:59:59", loc)
+		if err != nil {
+			utils.ErrorLog(err.Error())
+			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+			return
+		}
+		endTime = theTime.Unix()
+	}
+	data, _ := service.GetDialysisCompletionRate(c.GetAdminUserInfo().CurrentOrgId, startTime, endTime)
+	total, _ := service.GetDialysisCompletionTotal(c.GetAdminUserInfo().CurrentOrgId, startTime, endTime)
+	c.ServeSuccessJSON(map[string]interface{}{
+		"data":  data,
+		"total": total,
+	})
+}
+func (c *StatisticsApiController) GetDialysisTreatDetail() {
+	start_date := c.GetString("start_date")
+	end_date := c.GetString("end_date")
+	mode, _ := c.GetInt64("mode")
+	page, _ := c.GetInt64("page", 0)
+	limit, _ := c.GetInt64("limit", 0)
+	if page <= 0 {
+		page = 1
+	}
+	if limit <= 0 {
+		limit = 10
+	}
+	timeLayout := "2006-01-02"
+	loc, _ := time.LoadLocation("Local")
+	var startTime int64
+	if len(start_date) > 0 {
+		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", start_date+" 00:00:00", loc)
+		fmt.Println("err-----------", err)
+		if err != nil {
+			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+			return
+		}
+		startTime = theTime.Unix()
+	}
+	var endTime int64
+	if len(end_date) > 0 {
+		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", end_date+" 23:59:59", loc)
+		if err != nil {
+			utils.ErrorLog(err.Error())
+			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+			return
+		}
+		endTime = theTime.Unix()
+	}
+	data, total, _ := service.GetDialysisCompletionDetail(c.GetAdminUserInfo().CurrentOrgId, startTime, endTime, mode, limit, page)
+	c.ServeSuccessJSON(map[string]interface{}{
+		"list":  data,
+		"total": total,
+	})
+}
+
+func (c *StatisticsApiController) GetDialysisTotal() {
+	start_date := c.GetString("start_date")
+	end_date := c.GetString("end_date")
+	mode, _ := c.GetInt64("mode")
+	origin, _ := c.GetInt64("origin")
+	time_way, _ := c.GetInt64("time_way")
+
+	timeLayout := "2006-01-02"
+	loc, _ := time.LoadLocation("Local")
+	var startTime int64
+	if len(start_date) > 0 {
+		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", start_date+" 00:00:00", loc)
+		fmt.Println("err-----------", err)
+		if err != nil {
+			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+			return
+		}
+		startTime = theTime.Unix()
+	}
+	var endTime int64
+	if len(end_date) > 0 {
+		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", end_date+" 23:59:59", loc)
+		if err != nil {
+			utils.ErrorLog(err.Error())
+			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+			return
+		}
+		endTime = theTime.Unix()
+	}
+	if mode == 0 { //统计透析模式不限
+		//获取总人数
+		p_total, _ := service.GetNewDialysiTotal(startTime, endTime, c.GetAdminUserInfo().CurrentOrgId, origin)
+		count_struct, _ := service.GetNewDialysisCountMode(startTime, endTime, c.GetAdminUserInfo().CurrentOrgId, origin, 0)
+		c.ServeSuccessJSON(map[string]interface{}{
+			"patient_count": p_total,
+			"list":          count_struct,
+		})
+	} else { //固定某个模式
+		// 拆分日期范围
+		dates, err := splitDateRange(start_date, end_date)
+		if err != nil {
+			fmt.Println("Error:", err)
+			return
+		}
+
+		var cuss []models.CustomDialysisData
+		p_total, _ := service.GetNewDialysiTotal(startTime, endTime, c.GetAdminUserInfo().CurrentOrgId, origin)
+		switch time_way {
+		case 1:
+			// 按周统计
+			weeks := groupByWeek(dates)
+			for _, week := range weeks {
+				var cus models.CustomDialysisData
+				counts, _ := service.GetNewDialysisCountModeTwo(week[0].Unix(), week[len(week)-1].Unix(), c.GetAdminUserInfo().CurrentOrgId, origin, mode)
+				cus.Date = strings.Split(week[0].String(), " ")[0] + "~" + strings.Split(week[len(week)-1].String(), " ")[0]
+				cus.Count = counts.Count
+				cus.Total = p_total
+				cuss = append(cuss, cus)
+				c.ServeSuccessJSON(map[string]interface{}{
+					"list": cuss,
+				})
+			}
+
+			break
+		case 2:
+			startDate, err := time.Parse("2006-01-02", start_date)
+			if err != nil {
+				fmt.Println("Error parsing start date:", err)
+				return
+			}
+
+			endDate, err := time.Parse("2006-01-02", end_date)
+			if err != nil {
+				fmt.Println("Error parsing end date:", err)
+				return
+			}
+			dailyDates := splitByDay(startDate, endDate)
+			for _, date := range dailyDates {
+				//fmt.Println(date)
+				var cus models.CustomDialysisData
+				counts, _ := service.GetNewDialysisCountModeTwo(date.Unix(), date.Unix(), c.GetAdminUserInfo().CurrentOrgId, origin, mode)
+				cus.Date = date.Format("2006-01-02")
+				cus.Count = counts.Count
+				cus.Total = p_total
+				cuss = append(cuss, cus)
+				c.ServeSuccessJSON(map[string]interface{}{
+					"list": cuss,
+				})
+
+			}
+
+			break
+		case 3:
+			// 按月统计
+			months := groupByMonth(dates)
+			for _, month := range months {
+				var cus models.CustomDialysisData
+				counts, _ := service.GetNewDialysisCountModeTwo(month[0].Unix(), month[len(month)-1].Unix(), c.GetAdminUserInfo().CurrentOrgId, origin, mode)
+				cus.Date = strings.Split(month[0].String(), " ")[0] + "~" + strings.Split(month[len(month)-1].String(), " ")[0]
+				cus.Count = counts.Count
+				cus.Total = p_total
+				cuss = append(cuss, cus)
+				c.ServeSuccessJSON(map[string]interface{}{
+					"list": cuss,
+				})
+				//fmt.Println("Month:", month[0], "~", month[len(month)-1])
+			}
+			break
+		case 4:
+			// 按年统计
+			years := groupByYear(dates)
+			for _, year := range years {
+				var cus models.CustomDialysisData
+				counts, _ := service.GetNewDialysisCountModeTwo(year[0].Unix(), year[len(year)-1].Unix(), c.GetAdminUserInfo().CurrentOrgId, origin, mode)
+				cus.Date = strings.Split(year[0].String(), " ")[0] + "~" + strings.Split(year[len(year)-1].String(), " ")[0]
+				cus.Count = counts.Count
+				cus.Total = p_total
+				cuss = append(cuss, cus)
+				c.ServeSuccessJSON(map[string]interface{}{
+					"list": cuss,
+				})
+			}
+			break
+		}
+	}
+
+}
+func (c *StatisticsApiController) GetDialysisTotalDetail() {
+	start_date := c.GetString("start_date")
+	end_date := c.GetString("end_date")
+	mode, _ := c.GetInt64("mode")
+	origin, _ := c.GetInt64("origin")
+	time_way, _ := c.GetInt64("time_way")
+	timeLayout := "2006-01-02"
+	loc, _ := time.LoadLocation("Local")
+	var startTime int64
+	if len(start_date) > 0 {
+		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", start_date+" 00:00:00", loc)
+		fmt.Println("err-----------", err)
+		if err != nil {
+			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+			return
+		}
+		startTime = theTime.Unix()
+	}
+	var endTime int64
+	if len(end_date) > 0 {
+		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", end_date+" 23:59:59", loc)
+		if err != nil {
+			utils.ErrorLog(err.Error())
+			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+			return
+		}
+		endTime = theTime.Unix()
+	}
+
+	if origin == 1 {
+		data, _ := service.GetDialysisStats(startTime, endTime, time_way, mode)
+		c.ServeSuccessJSON(map[string]interface{}{
+			"data": data,
+		})
+	} else {
+		data, _ := service.GetScheduleStats(startTime, endTime, time_way, mode)
+		c.ServeSuccessJSON(map[string]interface{}{
+			"data": data,
+		})
+	}
+}
+func (c *StatisticsApiController) GetDialysisTotalDetailInfo() {
+
+}
+
+func (c *StatisticsApiController) GetAnticoagulant() {
+	start_date := c.GetString("start_date")
+	end_date := c.GetString("end_date")
+	timeLayout := "2006-01-02"
+	loc, _ := time.LoadLocation("Local")
+	var startTime int64
+	if len(start_date) > 0 {
+		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", start_date+" 00:00:00", loc)
+		fmt.Println("err-----------", err)
+		if err != nil {
+			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+			return
+		}
+		startTime = theTime.Unix()
+	}
+	var endTime int64
+	if len(end_date) > 0 {
+		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", end_date+" 23:59:59", loc)
+		if err != nil {
+			utils.ErrorLog(err.Error())
+			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+			return
+		}
+		endTime = theTime.Unix()
+	}
+
+	total, err2 := service.GetAnticoagulantTotal(startTime, endTime, c.GetAdminUserInfo().CurrentOrgId)
+	if err2 != nil {
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+		return
+	}
+	anticoagulantData, err := service.GetAnticoagulantData(startTime, endTime, c.GetAdminUserInfo().CurrentOrgId)
+	if err != nil {
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+		return
+	}
+	type respData struct {
+		Name       string  `json:"name"`
+		Count      int     `json:"count"`
+		Percentage float64 `json:"percentage"`
+	}
+	var respDatas []respData
+	for anticoagulant, count := range anticoagulantData {
+		var respData respData
+		respData.Name = anticoagulant
+		respData.Count = count
+		respData.Percentage = float64(count) / float64(total) * 100
+		respDatas = append(respDatas, respData)
+	}
+	c.ServeSuccessJSON(map[string]interface{}{
+		"data": respDatas,
+	})
+
+}
+func (c *StatisticsApiController) GetAnticoagulantDetail() {
+	anticoagulant, _ := c.GetInt64("anticoagulant")
+	start_date := c.GetString("start_date")
+	end_date := c.GetString("end_date")
+	timeLayout := "2006-01-02"
+	page, _ := c.GetInt64("page", 0)
+	limit, _ := c.GetInt64("limit", 0)
+	if page <= 0 {
+		page = 1
+	}
+	if limit <= 0 {
+		limit = 10
+	}
+	loc, _ := time.LoadLocation("Local")
+	var startTime int64
+	if len(start_date) > 0 {
+		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", start_date+" 00:00:00", loc)
+		fmt.Println("err-----------", err)
+		if err != nil {
+			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+			return
+		}
+		startTime = theTime.Unix()
+	}
+	var endTime int64
+	if len(end_date) > 0 {
+		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", end_date+" 23:59:59", loc)
+		if err != nil {
+			utils.ErrorLog(err.Error())
+			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+			return
+		}
+		endTime = theTime.Unix()
+	}
+	prescriptions, total, _ := service.GetPrescriptionByAnticoagulant(page, limit, c.GetAdminUserInfo().CurrentOrgId, anticoagulant, startTime, endTime)
+
+	c.ServeSuccessJSON(map[string]interface{}{
+		"prescriptions": prescriptions,
+		"total":         total,
+	})
+
+}
+
+func (c *StatisticsApiController) GetDialyzer() {
+	start_date := c.GetString("start_date")
+	end_date := c.GetString("end_date")
+	timeLayout := "2006-01-02"
+	loc, _ := time.LoadLocation("Local")
+	var startTime int64
+	if len(start_date) > 0 {
+		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", start_date+" 00:00:00", loc)
+		fmt.Println("err-----------", err)
+		if err != nil {
+			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+			return
+		}
+		startTime = theTime.Unix()
+	}
+	var endTime int64
+	if len(end_date) > 0 {
+		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", end_date+" 23:59:59", loc)
+		if err != nil {
+			utils.ErrorLog(err.Error())
+			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+			return
+		}
+		endTime = theTime.Unix()
+	}
+
+	total, err2 := service.GetDialyzerTotal(startTime, endTime, c.GetAdminUserInfo().CurrentOrgId)
+	if err2 != nil {
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+		return
+	}
+	dialyzers, err := service.GetDialyzerData(startTime, endTime, c.GetAdminUserInfo().CurrentOrgId)
+	if err != nil {
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+		return
+	}
+	type respData struct {
+		Name       string  `json:"name"`
+		Count      int     `json:"count"`
+		Percentage float64 `json:"percentage"`
+	}
+	var respDatas []respData
+	for _, item := range dialyzers {
+		var respData respData
+		respData.Name = item.Dialyzer
+		respData.Count = item.Count
+		respData.Percentage = float64(item.Count) / float64(total) * 100
+		respDatas = append(respDatas, respData)
+	}
+	c.ServeSuccessJSON(map[string]interface{}{
+		"data": respDatas,
+	})
+
+}
+func (c *StatisticsApiController) GetDialyzerDetail() {
+	dialyzer := c.GetString("Dialyzer")
+	start_date := c.GetString("start_date")
+	end_date := c.GetString("end_date")
+	timeLayout := "2006-01-02"
+	page, _ := c.GetInt64("page", 0)
+	limit, _ := c.GetInt64("limit", 0)
+	if page <= 0 {
+		page = 1
+	}
+	if limit <= 0 {
+		limit = 10
+	}
+	loc, _ := time.LoadLocation("Local")
+	var startTime int64
+	if len(start_date) > 0 {
+		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", start_date+" 00:00:00", loc)
+		fmt.Println("err-----------", err)
+		if err != nil {
+			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+			return
+		}
+		startTime = theTime.Unix()
+	}
+	var endTime int64
+	if len(end_date) > 0 {
+		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", end_date+" 23:59:59", loc)
+		if err != nil {
+			utils.ErrorLog(err.Error())
+			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+			return
+		}
+		endTime = theTime.Unix()
+	}
+	prescriptions, total, _ := service.GetPrescriptionByDialyzer(page, limit, c.GetAdminUserInfo().CurrentOrgId, dialyzer, startTime, endTime)
+	c.ServeSuccessJSON(map[string]interface{}{
+		"prescriptions": prescriptions,
+		"total":         total,
+	})
+
+}
+func (c *StatisticsApiController) GetDialyzerConfig() {
+	dialyzers, _ := service.GetDialyzerSummary(c.GetAdminUserInfo().CurrentOrgId)
+	c.ServeSuccessJSON(map[string]interface{}{
+		"dialyzers": dialyzers,
+	})
 }
 
 // 配置检验数据查询
@@ -206,34 +667,148 @@ func (c *StatisticsApiController) GetPatientCommonInspectionStatistisc() {
 }
 
 func (c *StatisticsApiController) GetFivePatientInspectionStatistisc() {
-	start_date := c.GetString("start_date")
+	//start_date := c.GetString("start_date")
 	end_date := c.GetString("end_date")
-	keyword := c.GetString("keyword")
-	timeLayout := "2006-01-02"
-	loc, _ := time.LoadLocation("Local")
-	var startTime int64
-	if len(start_date) > 0 {
-		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", start_date+" 00:00:00", loc)
-		if err != nil {
-			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
-			return
+	//keyword := c.GetString("keyword")
+	//timeLayout := "2006-01-02"
+	//loc, _ := time.LoadLocation("Local")
+
+	dynamicFields := make([]map[string]interface{}, 0)
+	list, _ := service.GetLatestInspectionValues(c.GetAdminUserInfo().CurrentOrgId, strings.Split(end_date, "-")[0]+"-"+strings.Split(end_date, "-")[1])
+	fmt.Println(list)
+
+	for _, result := range list {
+		fmt.Println(result)
+		// 打印患者ID
+		nb := result["姓名"].([]byte)
+		name := string(nb)
+
+		//ynamicFields := make([]map[string]interface{})
+
+		//var dynamicFields DynamicData
+		ynamicField := make(map[string]interface{})
+		ynamicField["姓名"] = name
+		// 打印其他列的值
+		for columnName, columnValue := range result {
+			// 跳过患者ID列
+
+			if columnName == "姓名" {
+				continue
+			}
+			// 检查值是否为nil
+			if columnValue == nil {
+				fmt.Printf("Column: %s, Value: <nil>\n", columnName)
+				continue
+			}
+
+			// 将字节切片转换为字符串
+			byteValue, ok := columnValue.([]byte)
+			if !ok {
+				// 如果无法转换为[]byte，输出错误信息
+				fmt.Printf("Error: Unable to convert value for column %s to []byte\n", columnName)
+				continue
+			}
+
+			// 将字节切片转换为字符串
+			strValue := string(byteValue)
+
+			// 尝试将字符串转换为浮点数
+			floatValue, err := strconv.ParseFloat(strValue, 64)
+			if err != nil {
+				// 如果转换失败，输出错误信息
+				fmt.Printf("Error converting value for column %s: %v\n", columnName, err)
+			} else {
+				// 如果转换成功，输出列名和浮点数值
+				fmt.Printf("Column: %s, Value: %f\n", columnName, floatValue)
+			}
+			ynamicField["年月"] = strings.Split(end_date, "-")[0] + "-" + strings.Split(end_date, "-")[1]
+			ynamicField[columnName] = floatValue
+			dynamicFields = append(dynamicFields, ynamicField)
 		}
-		startTime = theTime.Unix()
 	}
-	var endTime int64
-	if len(end_date) > 0 {
-		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", end_date+" 23:59:59", loc)
-		if err != nil {
-			utils.ErrorLog(err.Error())
-			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
-			return
+
+	seen := make(map[interface{}]struct{})
+	var uniqueFields []map[string]interface{}
+
+	for _, field := range dynamicFields {
+		value := field["姓名"]
+		// 如果值未在map中出现过，则将其添加到新的切片中，并将其添加到map中
+		if _, ok := seen[value]; !ok {
+			seen[value] = struct{}{}
+			uniqueFields = append(uniqueFields, field)
 		}
-		endTime = theTime.Unix()
 	}
-	list, _ := service.GetPatientFiveInspectionByID(startTime, endTime, c.GetAdminUserInfo().CurrentOrgId, keyword)
+
 	c.ServeSuccessJSON(map[string]interface{}{
-		"list": list,
+		"list": uniqueFields,
 	})
+	//list, _ := service.GetPatientFiveInspectionByID(startTime, endTime, c.GetAdminUserInfo().CurrentOrgId, keyword)
+	//
+	//var names []string
+	//
+	//for _, item := range list {
+	//	names = append(names, item.ItemName)
+	//}
+	//
+	//names = RemoveRepeatedNameElement(names)
+	//fmt.Println(names)
+	//
+	//var tempList []models.InspectionTen
+	//list_two := RemoveRepeatedInspectPatientElement(list)
+	//for _, item := range list_two {
+	//	var temp models.InspectionTen
+	//	var temptwos []models.InspectionValue
+	//	temp.PatientId = item.PatientId
+	//	temp.Name = item.Name
+	//	for _, subitem := range list {
+	//		if item.PatientId == subitem.PatientId {
+	//			var temptwo models.InspectionValue
+	//			temptwo.Name = subitem.ItemName
+	//			temptwo.Value = subitem.InspectValue
+	//			temptwos = append(temptwos, temptwo)
+	//		}
+	//	}
+	//	temp.Values = temptwos
+	//	tempList = append(tempList, temp)
+	//}
+	//
+	//var filtered []string
+	//for _, item := range names {
+	//	if item != "a" {
+	//		filtered = append(filtered, item)
+	//	}
+	//}
+	//
+	//for _, item := range tempList {
+	//	for _, subitem := range item.Values {
+	//		for _, name := range filtered {
+	//			if subitem.Name != name {
+	//				filtered = append(filtered, name)
+	//			}
+	//		}
+	//	}
+	//}
+	//
+	////// 将剩余字符串填充到 Inspection 数组中
+	////for _, name := range filtered {
+	////	var temptwo models.InspectionValue
+	////	temptwo.Name = subitem.ItemName
+	////	temptwo.Value = subitem.InspectValue
+	////	temptwos = append(temptwos, temptwo)
+	////}
+	//
+	//for _, item := range tempList {
+	//	//for _, subitem := range item.Values {
+	//	var temptwo models.InspectionValue
+	//	for _, name := range filtered {
+	//		temptwo.Name = name
+	//		temptwo.Value = ""
+	//	}
+	//	item.Values = append(item.Values, temptwo)
+	//	//}
+	//	fmt.Println(item.Values)
+	//}
+
 }
 func (c *StatisticsApiController) GetPatientInspectionStatistisc() {
 	start_date := c.GetString("start_date")
@@ -544,3 +1119,131 @@ func (c *StatisticsApiController) GetStatistics() {
 	})
 
 }
+
+func RemoveRepeatedInspectPatientElement(arr []models.InspectionTenOne) (newArr []models.InspectionTenOne) {
+	newArr = make([]models.InspectionTenOne, 0)
+	for i := 0; i < len(arr); i++ {
+		repeat := false
+		for j := i + 1; j < len(arr); j++ {
+			if arr[i].PatientId == arr[j].PatientId {
+				repeat = true
+				break
+			}
+		}
+		if !repeat {
+			newArr = append(newArr, arr[i])
+		}
+	}
+	return
+}
+
+func RemoveRepeatedNameElement(arr []string) (newArr []string) {
+	newArr = make([]string, 0)
+	for i := 0; i < len(arr); i++ {
+		repeat := false
+		for j := i + 1; j < len(arr); j++ {
+			if arr[i] == arr[j] {
+				repeat = true
+				break
+			}
+		}
+		if !repeat {
+			newArr = append(newArr, arr[i])
+		}
+	}
+	return
+}
+
+// 根据指定的日期范围拆分成周、月、年
+func splitDateRange(startDate, endDate string) ([]time.Time, error) {
+	startTime, err := time.Parse("2006-01-02", startDate)
+	if err != nil {
+		return nil, err
+	}
+
+	endTime, err := time.Parse("2006-01-02", endDate)
+	if err != nil {
+		return nil, err
+	}
+
+	var result []time.Time
+
+	for date := startTime; date.Before(endTime) || date.Equal(endTime); date = date.AddDate(0, 0, 1) {
+		result = append(result, date)
+	}
+
+	return result, nil
+}
+
+// 按周统计日期
+func groupByWeek(dates []time.Time) [][]time.Time {
+	var result [][]time.Time
+	var currentWeek []time.Time
+
+	for _, date := range dates {
+		currentWeek = append(currentWeek, date)
+		if date.Weekday() == time.Sunday {
+			result = append(result, currentWeek)
+			currentWeek = nil
+		}
+	}
+
+	if len(currentWeek) > 0 {
+		result = append(result, currentWeek)
+	}
+
+	return result
+}
+
+// 按月统计日期
+func groupByMonth(dates []time.Time) [][]time.Time {
+	var result [][]time.Time
+	var currentMonth []time.Time
+	lastMonth := dates[0].Month()
+
+	for _, date := range dates {
+		if date.Month() != lastMonth {
+			result = append(result, currentMonth)
+			currentMonth = nil
+			lastMonth = date.Month()
+		}
+		currentMonth = append(currentMonth, date)
+	}
+
+	if len(currentMonth) > 0 {
+		result = append(result, currentMonth)
+	}
+
+	return result
+}
+
+// 按年统计日期
+func groupByYear(dates []time.Time) [][]time.Time {
+	var result [][]time.Time
+	var currentYear []time.Time
+	lastYear := dates[0].Year()
+
+	for _, date := range dates {
+		if date.Year() != lastYear {
+			result = append(result, currentYear)
+			currentYear = nil
+			lastYear = date.Year()
+		}
+		currentYear = append(currentYear, date)
+	}
+
+	if len(currentYear) > 0 {
+		result = append(result, currentYear)
+	}
+
+	return result
+}
+
+// 将日期拆分为按天统计
+func splitByDay(startDate, endDate time.Time) []time.Time {
+	var dates []time.Time
+	for d := startDate; !d.After(endDate); d = d.AddDate(0, 0, 1) {
+		dates = append(dates, d)
+	}
+	return dates
+}

models/qc.go

@@ -0,0 +1,7 @@
+package models
+
+type CustomDialysisData struct {
+	Date  string `json:"date"`
+	Count int64  `json:"count"`
+	Total int64  `json:"total"`
+}

service/statistis_qc_service.go

@@ -0,0 +1,667 @@
+package service
+
+import (
+	"XT_New/models"
+	"fmt"
+	"strings"
+)
+
+func GetDialysisTotalDatas() {
+
+}
+
+func GetNewDialysiTotal(startime int64, endtime int64, orgid int64, origin int64) (int64, error) {
+	counts := models.PatientPrescriptionCountStruct{}
+	var err error
+	if origin == 1 { //透析记录，上机为准
+		db := XTReadDB().Table("xt_dialysis_order as x")
+		err = db.Select("count(x.id) as count").Where("x.dialysis_date >= ? and x.dialysis_date<=? and x.user_org_id = ? AND x.status = 1", startime, endtime, orgid).Scan(&counts).Error
+		return counts.Count, err
+
+	} else {
+		db := XTReadDB().Table("xt_schedule as sch")
+		//err = db.Select("COUNT(DISTINCT patient_id) AS total_employees").Where("x.dialysis_date >= ? and x.dialysis_date<=? and x.user_org_id = ? AND x.status = 1", startime, endtime, orgid).Scan(&counts).Error
+		var count int64
+		err := db.Model(&Schedule{}).
+			Select("patient_id, schedule_date").
+			Group("patient_id, schedule_date").
+			Where("schedule_date >= ? AND schedule_date  <= ?", startime, endtime).
+			Count(&count).
+			Error
+		return count, err
+
+	}
+
+}
+
+type TreatmentMode struct {
+	ModeID   int    `json:"mode_id"`
+	ModeName string `json:"mode_name"`
+}
+
+type DialysisStat struct {
+	Date   string         `json:"日期"`
+	Counts map[string]int `json:"counts"`
+	Total  int            `json:"合计"`
+}
+
+func getTreatmentModes() ([]TreatmentMode, error) {
+	var modes []TreatmentMode
+	if err := XTReadDB().Find(&modes).Error; err != nil {
+		return nil, err
+	}
+	return modes, nil
+}
+
+func GetDialysisStats(startDate int64, endDate int64, groupBy int64, mode int64) ([]DialysisStat, error) {
+	var stats []DialysisStat
+	var modes []TreatmentMode
+	if mode > 0 {
+		modes, _ = getTreatmentModes()
+	} else {
+		modes_two, _ := getTreatmentModes()
+		for _, item := range modes_two {
+			if item.ModeID == int(mode) {
+				modes = append(modes, item)
+			}
+		}
+	}
+	// 获取透析模式
+	if err != nil {
+		return nil, err
+	}
+
+	// 构建日期格式
+	dateFormat := "%Y-%m-%d"
+	switch groupBy {
+	case 2:
+		dateFormat = "%Y-%m-%d"
+	case 1:
+		dateFormat = "%Y-%u"
+	case 3:
+		dateFormat = "%Y-%m"
+	case 4:
+		dateFormat = "%Y"
+	default:
+		return nil, fmt.Errorf("invalid group by option")
+	}
+	// 构建动态查询语句
+	selectClauses := []string{fmt.Sprintf("DATE_FORMAT(p.record_date, '%s') AS `日期`", dateFormat)}
+	for _, mode := range modes {
+		selectClauses = append(selectClauses, fmt.Sprintf("SUM(CASE WHEN t.mode_name = '%s' THEN 1 ELSE 0 END) AS `%s`", mode.ModeName, mode.ModeName))
+	}
+	selectClauses = append(selectClauses, "COUNT(*) AS `合计`")
+
+	query := fmt.Sprintf(`
+        SELECT
+            %s
+        FROM
+            xt_dialysis_prescription p
+        JOIN
+            xt_treatment_mode t ON p.mode_id = t.mode_id
+        WHERE
+            p.record_date >= ? AND p.record_date <= ?
+        GROUP BY
+            DATE_FORMAT(p.record_date, '%s')
+    `, dateFormat, dateFormat, selectClauses)
+
+	rows, err := readDb.Raw(query, startDate, endDate).Rows()
+	if err != nil {
+		return nil, err
+	}
+	defer rows.Close()
+
+	// 解析查询结果
+	for rows.Next() {
+		var stat DialysisStat
+		stat.Counts = make(map[string]int)
+		cols := []interface{}{&stat.Date}
+		for _, mode := range modes {
+			var count int
+			cols = append(cols, &count)
+			stat.Counts[mode.ModeName] = count
+		}
+		var total int
+		cols = append(cols, &total)
+		stat.Total = total
+		if err := rows.Scan(cols...); err != nil {
+			return nil, err
+		}
+		stats = append(stats, stat)
+	}
+
+	return stats, nil
+}
+
+func GetScheduleStats(startDate int64, endDate int64, groupBy int64, mode int64) ([]DialysisStat, error) {
+	var stats []DialysisStat
+	var modes []TreatmentMode
+	if mode > 0 {
+		modes, _ = getTreatmentModes()
+	} else {
+		modes_two, _ := getTreatmentModes()
+		for _, item := range modes_two {
+			if item.ModeID == int(mode) {
+				modes = append(modes, item)
+			}
+		}
+	}
+	// 获取透析模式
+	if err != nil {
+		return nil, err
+	}
+
+	// 构建日期格式
+	dateFormat := "%Y-%m-%d"
+	switch groupBy {
+	case 2:
+		dateFormat = "%Y-%m-%d"
+	case 1:
+		dateFormat = "%Y-%u"
+	case 3:
+		dateFormat = "%Y-%m"
+	case 4:
+		dateFormat = "%Y"
+	default:
+		return nil, fmt.Errorf("invalid group by option")
+	}
+	// 构建动态查询语句
+	selectClauses := []string{fmt.Sprintf("DATE_FORMAT(p.schudle_date, '%s') AS `日期`", dateFormat)}
+	for _, mode := range modes {
+		selectClauses = append(selectClauses, fmt.Sprintf("SUM(CASE WHEN t.mode_name = '%s' THEN 1 ELSE 0 END) AS `%s`", mode.ModeName, mode.ModeName))
+	}
+	selectClauses = append(selectClauses, "COUNT(*) AS `合计`")
+
+	query := fmt.Sprintf(`
+        SELECT
+            %s
+        FROM
+            xt_schedule p
+        JOIN
+            xt_treatment_mode t ON p.mode_id = t.mode_id
+        WHERE
+            p.schedule_date >= ? AND p.schedule_date <= ?
+        GROUP BY
+            DATE_FORMAT(p.schedule_date, '%s')
+    `, dateFormat, dateFormat, selectClauses)
+
+	rows, err := readDb.Raw(query, startDate, endDate).Rows()
+	if err != nil {
+		return nil, err
+	}
+	defer rows.Close()
+
+	// 解析查询结果
+	for rows.Next() {
+		var stat DialysisStat
+		stat.Counts = make(map[string]int)
+		cols := []interface{}{&stat.Date}
+		for _, mode := range modes {
+			var count int
+			cols = append(cols, &count)
+			stat.Counts[mode.ModeName] = count
+		}
+		var total int
+		cols = append(cols, &total)
+		stat.Total = total
+		if err := rows.Scan(cols...); err != nil {
+			return nil, err
+		}
+		stats = append(stats, stat)
+	}
+
+	return stats, nil
+}
+
+func GetNewDialysisCountMode(starttime int64, endtime int64, orgid int64, origin int64, mode_id int64) (counts []*models.PatientPrescriptionCountStruct, err error) {
+	if origin == 1 {
+
+		db := readDb.Table("xt_dialysis_order as o").Where("o.status = 1")
+		if starttime > 0 {
+			db = db.Where("o.dialysis_date >=?", starttime)
+		}
+		if endtime > 0 {
+			db = db.Where("o.dialysis_date<=?", endtime)
+		}
+		if orgid > 0 {
+			db = db.Where("o.user_org_id = ?", orgid)
+		}
+		if mode_id == 0 {
+			err = db.Select("s.mode_id,count(s.mode_id) as count").Joins("join xt_dialysis_prescription as s on s.patient_id = o.patient_id and s.record_date = o.dialysis_date and s.status= 1 AND s.record_date >= ? AND s.record_date <= ? AND  s.mode_id > 0 ", starttime, endtime).Group("s.mode_id").Scan(&counts).Error
+
+		} else {
+
+			err = db.Select("s.mode_id,count(s.mode_id) as count").Joins("join xt_dialysis_prescription as s on s.patient_id = o.patient_id and s.record_date = o.dialysis_date and s.status= 1 AND s.record_date >= ? AND s.record_date <= ? AND  s.mode_id = ? ", starttime, endtime, mode_id).Group("s.mode_id").Scan(&counts).Error
+
+		}
+		return counts, err
+
+	} else {
+		db := readDb.Table("xt_schedule as o").Where("o.status = 1").Select("patient_id, schedule_date").Group("patient_id, schedule_date,mode_id")
+		if starttime > 0 {
+			db = db.Where("o.schedule_date >= ?", starttime)
+		}
+		if endtime > 0 {
+			db = db.Where("o.schedule_date <= ?", endtime)
+		}
+		if orgid > 0 {
+			db = db.Where("o.user_org_id = ?", orgid)
+		}
+		err = db.Select("o.mode_id,count(o.mode_id) as count").Scan(&counts).Error
+		return counts, err
+
+	}
+
+}
+
+func GetNewDialysisCountModeTwo(starttime int64, endtime int64, orgid int64, origin int64, mode_id int64) (counts models.CustomDialysisData, err error) {
+	if origin == 1 {
+		db := readDb.Table("xt_dialysis_order as o").Where("o.status = 1")
+		if starttime > 0 {
+			db = db.Where("o.dialysis_date >=?", starttime)
+		}
+		if endtime > 0 {
+			db = db.Where("o.dialysis_date<=?", endtime)
+		}
+		if orgid > 0 {
+			db = db.Where("o.user_org_id = ?", orgid)
+		}
+
+		err = db.Select("s.mode_id,count(s.mode_id) as count").Joins("join xt_dialysis_prescription as s on s.patient_id = o.patient_id and s.record_date = o.dialysis_date and s.status= 1 AND s.record_date >= ? AND s.record_date <= ? AND  s.mode_id = ? ", starttime, endtime, mode_id).Group("s.mode_id").Scan(&counts).Error
+		return counts, err
+
+	} else {
+		db := readDb.Table("xt_schedule as o").Where("o.status = 1").Select("patient_id, schedule_date").Group("patient_id, schedule_date,mode_id")
+		if starttime > 0 {
+			db = db.Where("o.schedule_date >= ?", starttime)
+		}
+		if endtime > 0 {
+			db = db.Where("o.schedule_date <= ?", endtime)
+		}
+		if orgid > 0 {
+			db = db.Where("o.user_org_id = ?", orgid)
+		}
+		if mode_id > 0 {
+			db = db.Where("o.mode_id = ?", mode_id)
+		}
+
+		err = db.Select("o.mode_id,count(o.mode_id) as count").Scan(&counts).Error
+		return counts, err
+
+	}
+
+}
+
+var anticoagulantMap = map[int]string{
+	1:  "无肝素",
+	2:  "普通肝素",
+	3:  "低分子肝素",
+	4:  "阿加曲班",
+	5:  "枸橼酸钠",
+	6:  "低分子肝素钙",
+	7:  "低分子肝素钠",
+	8:  "依诺肝素",
+	9:  "达肝素",
+	10: "体外抗凝",
+	11: "那屈肝素",
+	12: "无抗凝剂",
+	13: "那屈肝素钙",
+	14: "肝素钙注射液",
+	15: "甲磺酸萘莫司他",
+	16: "低分子量肝素钙",
+	17: "肝素钠",
+}
+
+func GetAnticoagulantData(start_time int64, end_time int64, org_id int64) (map[string]int, error) {
+	var results []struct {
+		Anticoagulant int
+		Count         int
+	}
+
+	err := XTReadDB().Model(&models.DialysisPrescription{}).
+		Select("anticoagulant, COUNT(*) as count").
+		Where("status = 1 and record_date >= ? and record_date <= ? and user_org_id = ?", start_time, end_time, org_id).
+		Group("anticoagulant").
+		Scan(&results).Error
+	if err != nil {
+		return nil, err
+	}
+	anticoagulantData := make(map[string]int)
+	for _, result := range results {
+		if name, ok := anticoagulantMap[result.Anticoagulant]; ok {
+			anticoagulantData[name] = result.Count
+		} else {
+			anticoagulantData[fmt.Sprintf("Unknown (%d)", result.Anticoagulant)] = result.Count
+		}
+	}
+
+	return anticoagulantData, nil
+}
+func GetAnticoagulantTotal(start_time int64, end_time int64, org_id int64) (total int64, err error) {
+	err = XTReadDB().Model(&models.DialysisPrescription{}).
+		Where("record_date >= ? and record_date <= ? and user_org_id = ? and status = 1", start_time, end_time, org_id).
+		Count(&total).Error
+
+	return
+}
+func GetDialyzerSummary(org_id int64) ([]string, error) {
+	var Dialyzer []string
+	err := XTReadDB().Model(&models.DialysisPrescription{}).
+		Select("dialysis_dialyszers").
+		Where(" user_org_id = ? and status = 1", org_id).
+		Group("dialysis_dialyszers").
+		Scan(&Dialyzer).Error
+	if err != nil {
+		return nil, err
+	}
+	return Dialyzer, nil
+}
+
+type DialyzerResult struct {
+	Dialyzer string
+	Count    int
+}
+
+func GetDialyzerData(start_time int64, end_time int64, org_id int64) (dr []DialyzerResult, err error) {
+	err = XTReadDB().Model(&models.DialysisPrescription{}).
+		Select("dialysis_dialyszers as dialyzer, COUNT(*) as count").
+		Where("record_date >= ? and record_date <= ? and user_org_id = ? and status = 1", start_time, end_time, org_id).
+		Group("dialysis_dialyszers").
+		Scan(&dr).Error
+	return
+}
+
+func GetDialyzerTotal(start_time int64, end_time int64, org_id int64) (total int64, err error) {
+	err = XTReadDB().Model(&models.DialysisPrescription{}).
+		Where("status = 1 and record_date >= ? and record_date <= ? and user_org_id = ? and dialysis_dialyszers <> ''", start_time, end_time, org_id).
+		Count(&total).Error
+	return
+}
+
+func GetPrescriptionByAnticoagulant(page int64, limit int64, orgid int64, anticoagulant int64, start_time int64, end_time int64) (solution []*models.DialysisPrescription, total int64, err error) {
+
+	db := XTReadDB().Model(&models.DialysisPrescription{}).Where("status = 1")
+	if anticoagulant > 0 {
+		db = db.Where("anticoagulant = ?", anticoagulant)
+	}
+	if orgid > 0 {
+		db = db.Where("user_org_id = ?", orgid)
+	}
+	db = db.Where("record_date >= ? and record_date <= ?", start_time, end_time)
+
+	offset := (page - 1) * limit
+
+	err = db.Count(&total).Offset(offset).Limit(limit).Find(&solution).Error
+	return solution, total, err
+}
+
+func GetPrescriptionByDialyzer(page int64, limit int64, orgid int64, dialyzer string, start_time int64, end_time int64) (solution []*models.DialysisPrescription, total int64, err error) {
+
+	db := XTReadDB().Model(&models.DialysisPrescription{}).Where("status = 1")
+	if len(dialyzer) > 0 {
+		db = db.Where("dialysis_dialyszers = ?", dialyzer)
+	}
+	if orgid > 0 {
+		db = db.Where("user_org_id = ?", orgid)
+	}
+	db = db.Where("record_date >= ? and record_date <= ?", start_time, end_time)
+
+	offset := (page - 1) * limit
+
+	err = db.Count(&total).Offset(offset).Limit(limit).Find(&solution).Error
+	return solution, total, err
+}
+
+type DialysisData struct {
+	DialysisStatus string `json:"dialysis_status"`
+	Count          int    `json:"count"`
+}
+
+type CustomData struct {
+	DialysisNo       string
+	PatientName      string
+	DialysisDate     string
+	DialysisDuration string
+	ActualDuration   string
+	Diff             string
+	Doctor           string
+	Nurse            string
+}
+
+func GetDialysisCompletionRate(org_id int64, start_time int64, end_time int64) (map[string]int, error) {
+	var results []DialysisData
+	query := `
+        SELECT
+            CASE
+                WHEN ABS(TIMESTAMPDIFF(MINUTE, MAKETIME(p.dialysis_duration_hour, p.dialysis_duration_minute, 0), MAKETIME(a.actual_treatment_hour, a.actual_treatment_minute, 0))) <= 15 THEN '达标'
+                WHEN TIMESTAMPDIFF(MINUTE, MAKETIME(p.dialysis_duration_hour, p.dialysis_duration_minute, 0), MAKETIME(a.actual_treatment_hour, a.actual_treatment_minute, 0)) < 0 THEN '未达标'
+                ELSE '超时'
+            END AS dialysis_status,
+            COUNT(*) AS count
+        FROM
+            xt_dialysis_order o
+        JOIN
+            xt_dialysis_prescription p ON o.dialysis_date = p.record_date AND o.patient_id = p.patient_id AND p.user_org_id = ?
+        JOIN
+            xt_assessment_after_dislysis a ON o.dialysis_date = a.assessment_date AND o.patient_id = a.patient_id AND a.user_org_id = ?
+        WHERE
+            o.stage = 2 AND o.user_org_id = ? AND o.dialysis_date >= ? AND o.dialysis_date <= ?
+        GROUP BY
+            dialysis_status;
+    `
+	if err := readDb.Raw(query, org_id, org_id, org_id, start_time, end_time).Scan(&results).Error; err != nil {
+		return nil, err
+	}
+	dialysisCompletionRate := make(map[string]int)
+	for _, result := range results {
+		dialysisCompletionRate[result.DialysisStatus] = result.Count
+	}
+	return dialysisCompletionRate, nil
+}
+func GetDialysisCompletionTotal(org_id int64, start_time int64, end_time int64) (int64, error) {
+	var Count int64
+	query := `
+        SELECT
+            COUNT(*) AS count
+        FROM
+            xt_dialysis_order o
+        JOIN
+            xt_dialysis_prescription p ON o.dialysis_date = p.record_date AND o.patient_id = p.patient_id AND p.user_org_id = ?
+        JOIN
+            xt_assessment_after_dislysis a ON o.dialysis_date = a.assessment_date AND o.patient_id = a.patient_id AND a.user_org_id = ?
+        WHERE
+            o.stage = 2 AND o.user_org_id = ? AND o.dialysis_date >= ? AND o.dialysis_date <= ?
+        GROUP BY
+            dialysis_status;
+    `
+	if err := readDb.Raw(query, org_id, org_id, org_id, start_time, end_time).Scan(&Count).Error; err != nil {
+		return 0, err
+	}
+
+	return Count, nil
+}
+func GetDialysisCompletionDetail(org_id int64, start_time int64, end_time int64, mode int64, limit int64, page int64) (date []*CustomData, total int64, err error) {
+	var query string
+	if mode == 0 {
+		query = `
+        SELECT
+           p.dialysis_no as dialysis_no,
+           p.name as patient_name,
+           FROM_UNIXTIME(o.dialysis_date) as dialysis_date,
+           CONCAT(p.dialysis_duration_hour, 'h', p.dialysis_duration_minute,'min') as dialysis_duration,
+           CONCAT(a.actual_treatment_hour, 'h', a.actual_treatment_minute,'min') as actual_duration,
+           ABS(TIMESTAMPDIFF(MINUTE, MAKETIME(p.dialysis_duration_hour, p.dialysis_duration_minute, 0), MAKETIME(a.actual_treatment_hour, a.actual_treatment_minute, 0))) as diff,
+           p.prescription_doctor as doctor,
+           p.finish_nurse as nurse
+        FROM
+            xt_dialysis_order o
+    	JOIN           
+            xt_patients pp ON o.patient_id = pp.id AND pp.user_org_id = ?
+        JOIN
+            xt_dialysis_prescription p ON o.dialysis_date = p.record_date AND o.patient_id = p.patient_id AND p.user_org_id = ?
+        JOIN
+            xt_assessment_after_dislysis a ON o.dialysis_date = a.assessment_date AND o.patient_id = a.patient_id AND a.user_org_id = ?
+        WHERE
+            o.stage = 2 AND o.user_org_id = ? AND o.dialysis_date >= ? AND o.dialysis_date <= ?
+    `
+
+	} else if mode == 1 {
+		query = `
+        SELECT
+           p.dialysis_no as dialysis_no,
+           p.name as patient_name,
+           FROM_UNIXTIME(o.dialysis_date) as dialysis_date,
+           CONCAT(p.dialysis_duration_hour, 'h', p.dialysis_duration_minute,'min') as dialysis_duration,
+           CONCAT(a.actual_treatment_hour, 'h', a.actual_treatment_minute,'min') as actual_duration,
+           ABS(TIMESTAMPDIFF(MINUTE, MAKETIME(p.dialysis_duration_hour, p.dialysis_duration_minute, 0), MAKETIME(a.actual_treatment_hour, a.actual_treatment_minute, 0))) as diff,
+           p.prescription_doctor as doctor,
+           p.finish_nurse as nurse
+        FROM
+            xt_dialysis_order o
+    	JOIN           
+            xt_patients pp ON o.patient_id = pp.id AND pp.user_org_id = ?
+        JOIN
+            xt_dialysis_prescription p ON o.dialysis_date = p.record_date AND o.patient_id = p.patient_id AND p.user_org_id = ?
+        JOIN
+            xt_assessment_after_dislysis a ON o.dialysis_date = a.assessment_date AND o.patient_id = a.patient_id AND a.user_org_id = ?
+        WHERE
+            o.stage = 2 AND o.user_org_id = ? AND o.dialysis_date >= ? AND o.dialysis_date <= ? AND ABS(TIMESTAMPDIFF(MINUTE, MAKETIME(p.dialysis_duration_hour, p.dialysis_duration_minute, 0), MAKETIME(a.actual_treatment_hour, a.actual_treatment_minute, 0))) <= 15
+    `
+
+	} else if mode == 2 {
+		query = `
+        SELECT
+           p.dialysis_no as dialysis_no,
+           p.name as patient_name,
+           FROM_UNIXTIME(o.dialysis_date) as dialysis_date,
+           CONCAT(p.dialysis_duration_hour, 'h', p.dialysis_duration_minute,'min') as dialysis_duration,
+           CONCAT(a.actual_treatment_hour, 'h', a.actual_treatment_minute,'min') as actual_duration,
+           ABS(TIMESTAMPDIFF(MINUTE, MAKETIME(p.dialysis_duration_hour, p.dialysis_duration_minute, 0), MAKETIME(a.actual_treatment_hour, a.actual_treatment_minute, 0))) as diff,
+           p.prescription_doctor as doctor,
+           p.finish_nurse as nurse
+        FROM
+            xt_dialysis_order o
+    	JOIN           
+            xt_patients pp ON o.patient_id = pp.id AND pp.user_org_id = ?
+        JOIN
+            xt_dialysis_prescription p ON o.dialysis_date = p.record_date AND o.patient_id = p.patient_id AND p.user_org_id = ?
+        JOIN
+            xt_assessment_after_dislysis a ON o.dialysis_date = a.assessment_date AND o.patient_id = a.patient_id AND a.user_org_id = ?
+        WHERE
+            o.stage = 2 AND o.user_org_id = ? AND o.dialysis_date >= ? AND o.dialysis_date <= ? AND TIMESTAMPDIFF(MINUTE, MAKETIME(p.dialysis_duration_hour, p.dialysis_duration_minute, 0), MAKETIME(a.actual_treatment_hour, a.actual_treatment_minute, 0)) < 0
+    `
+
+	} else if mode == 3 {
+		query = `
+        SELECT
+           p.dialysis_no as dialysis_no,
+           p.name as patient_name,
+           FROM_UNIXTIME(o.dialysis_date) as dialysis_date,
+           CONCAT(p.dialysis_duration_hour, 'h', p.dialysis_duration_minute,'min') as dialysis_duration,
+           CONCAT(a.actual_treatment_hour, 'h', a.actual_treatment_minute,'min') as actual_duration,
+           ABS(TIMESTAMPDIFF(MINUTE, MAKETIME(p.dialysis_duration_hour, p.dialysis_duration_minute, 0), MAKETIME(a.actual_treatment_hour, a.actual_treatment_minute, 0))) as diff,
+           p.prescription_doctor as doctor,
+           p.finish_nurse as nurse
+        FROM
+            xt_dialysis_order o
+    	JOIN           
+            xt_patients pp ON o.patient_id = pp.id AND pp.user_org_id = ?
+        JOIN
+            xt_dialysis_prescription p ON o.dialysis_date = p.record_date AND o.patient_id = p.patient_id AND p.user_org_id = ?
+        JOIN
+            xt_assessment_after_dislysis a ON o.dialysis_date = a.assessment_date AND o.patient_id = a.patient_id AND a.user_org_id = ?
+        WHERE
+            o.stage = 2 AND o.user_org_id = ? AND o.dialysis_date >= ? AND o.dialysis_date <= ? AND TIMESTAMPDIFF(MINUTE, MAKETIME(p.dialysis_duration_hour, p.dialysis_duration_minute, 0), MAKETIME(a.actual_treatment_hour, a.actual_treatment_minute, 0)) > 15
+    `
+	}
+	offset := (page - 1) * limit
+
+	if err := readDb.Raw(query, org_id, org_id, org_id, org_id, start_time, end_time).Count(&total).Offset(offset).Limit(limit).Scan(&date).Error; err != nil {
+		return nil, 0, err
+	}
+
+	return
+}
+
+type QualityControlStandard struct {
+	ItemName        string `json:"item_name"`
+	ProjectMame     string `json:"project_name"`
+	InspectionMajor int64  `json:"inspection_major"`
+	InspectionMinor int64  `json:"inspection_minor"`
+}
+
+func getQualityControlStandards(org_id int64) ([]QualityControlStandard, error) {
+	var standards []QualityControlStandard
+	if err := readDb.Model(&models.XtQualityControlStandard{}).Select("re.project_name as project_name,re.item_name as item_name,xt_quality_control_standard.inspection_major as inspection_major,xt_quality_control_standard.inspection_minor as inspection_minor").Joins("join xt_inspection_reference re on re.project_id = xt_quality_control_standard.inspection_major and re.item_id = xt_quality_control_standard.inspection_minor and re.org_id = ?", org_id).Where("xt_quality_control_standard.user_org_id = ? and xt_quality_control_standard.status = 1", org_id).Scan(&standards).Error; err != nil {
+		return nil, err
+	}
+	return standards, nil
+}
+
+type DialysisQualityStat struct {
+	Month  string             `json:"月"`
+	Name   string             `json:"姓名"`
+	Counts map[string]float64 `json:"counts"`
+}
+
+func GetLatestInspectionValues(org_id int64, yearMonth string) ([]map[string]interface{}, error) {
+	standards, err := getQualityControlStandards(org_id)
+	if err != nil {
+		return nil, err
+	}
+
+	var selectFields []string
+	for _, standard := range standards {
+		field := fmt.Sprintf("MAX(CASE WHEN i.item_name = %s THEN i.inspect_value END) AS `%s`",
+			"'"+standard.ItemName+"'", standard.ItemName)
+		selectFields = append(selectFields, field)
+	}
+
+	query := fmt.Sprintf(`
+		SELECT
+		    p.name as '姓名',
+			%s
+		FROM xt_inspection i
+		JOIN xt_patients p On p.id = i.patient_id
+		WHERE DATE_FORMAT(FROM_UNIXTIME(i.inspect_date), '%%Y-%%m') = ? and org_id = ?
+		
+		GROUP BY i.patient_id
+	`, strings.Join(selectFields, ", "))
+
+	var results []map[string]interface{}
+	rows, err := readDb.Raw(query, yearMonth, org_id).Rows()
+	if err != nil {
+		return nil, err
+	}
+	defer rows.Close()
+
+	columns, err := rows.Columns()
+	if err != nil {
+		return nil, err
+	}
+
+	for rows.Next() {
+		// 创建一个长度为列数的切片，用于存储每一行的值
+		columnValues := make([]interface{}, len(columns))
+		columnPointers := make([]interface{}, len(columns))
+		for i := range columnValues {
+			columnPointers[i] = &columnValues[i]
+		}
+
+		// 扫描当前行的值
+		if err := rows.Scan(columnPointers...); err != nil {
+			return nil, err
+		}
+
+		// 将扫描到的值放入结果 map 中
+		result := make(map[string]interface{})
+		for i, colName := range columns {
+			val := columnPointers[i].(*interface{})
+			result[colName] = *val
+		}
+
+		results = append(results, result)
+	}
+
+	return results, nil
+}