提交代码

controllers/statistics_api_controller.go

@@ -292,39 +292,732 @@ func (c *StatisticsApiController) GetDialysisTotalDetail() {
 	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()
+	//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()
+	//}
+	dates, err := splitDateRange(start_date, end_date)
+	if err != nil {
+		fmt.Println("Error:", err)
+		return
 	}
 
 	if origin == 1 {
-		data, _ := service.GetDialysisStats(startTime, endTime, time_way, mode)
-		c.ServeSuccessJSON(map[string]interface{}{
-			"data": data,
-		})
+		switch time_way {
+		case 2:
+			weeks := groupByWeek(dates)
+			//var uniqueFields []map[string]interface{}
+			var uniqueFields []map[string]interface{}
+
+			for _, week := range weeks {
+				// 解析字符串时显式指定时区为 UTC
+				t, err := time.Parse("2006-01-02 15:04:05 -0700 MST", week[0].String())
+				if err != nil {
+					fmt.Println("解析时间出错:", err)
+					return
+				}
+				// 解析字符串时显式指定时区为 UTC
+				t2, err := time.Parse("2006-01-02 15:04:05 -0700 MST", week[len(week)-1].String())
+				if err != nil {
+					fmt.Println("解析时间出错:", err)
+					return
+				}
+				//dynamicFields := make([]map[string]interface{}, 0)
+				list, _ := service.GetDialysisStats(t.Unix(), t2.Unix(), mode, c.GetAdminUserInfo().CurrentOrgId, time_way)
+				//fmt.Println(aa)
+				var dynamicFields []map[string]interface{}
+				//var uniqueFields []map[string]interface{}
+
+				for _, result := range list {
+					// 打印患者ID
+					nb := result["日期"].([]byte)
+					name := string(nb)
+
+					// 创建动态字段的map
+					dynamicField := make(map[string]interface{})
+					// 将日期放在首位
+					dynamicField["日期"] = name
+
+					// 打印其他列的值，并添加到动态字段中
+					for columnName, columnValue := range result {
+						if columnName == "日期" {
+							continue
+						}
+						if columnName == "合计" {
+							continue
+						}
+						if columnValue == nil {
+							dynamicField[columnName] = ""
+							continue
+						}
+
+						byteValue, ok := columnValue.([]byte)
+						if !ok {
+							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 {
+							if floatValue == 0 {
+								dynamicField[columnName] = ""
+							} else {
+								dynamicField[columnName] = floatValue
+							}
+						}
+					}
+
+					// 将合计放在末尾
+					hj := result["合计"].(int64)
+					dynamicField["合计"] = hj
+
+					dynamicFields = append(dynamicFields, dynamicField)
+				}
+
+				// 将日期放在首位
+				seen := make(map[interface{}]struct{})
+				for _, field := range dynamicFields {
+					value := field["日期"]
+					if _, ok := seen[value]; !ok {
+						seen[value] = struct{}{}
+						uniqueFields = append(uniqueFields, field)
+					}
+				}
+			}
+			c.ServeSuccessJSON(map[string]interface{}{
+				"list": uniqueFields,
+			})
+
+			break
+		case 1:
+			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)
+			var uniqueFields []map[string]interface{}
+			for _, date := range dailyDates {
+				list, _ := service.GetDialysisStats(date.Unix(), date.Unix(), mode, c.GetAdminUserInfo().CurrentOrgId, time_way)
+				//fmt.Println(aa)
+				var dynamicFields []map[string]interface{}
+
+				for _, result := range list {
+					// 打印患者ID
+					nb := result["日期"].([]byte)
+					name := string(nb)
+
+					// 创建动态字段的map
+					dynamicField := make(map[string]interface{})
+					// 将日期放在首位
+					dynamicField["日期"] = name
+
+					// 打印其他列的值，并添加到动态字段中
+					for columnName, columnValue := range result {
+						if columnName == "日期" {
+							continue
+						}
+						if columnName == "合计" {
+							continue
+						}
+						if columnValue == nil {
+							dynamicField[columnName] = ""
+							continue
+						}
+
+						byteValue, ok := columnValue.([]byte)
+						if !ok {
+							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 {
+							if floatValue == 0 {
+								dynamicField[columnName] = ""
+							} else {
+								dynamicField[columnName] = floatValue
+							}
+						}
+					}
+
+					// 将合计放在末尾
+					hj := result["合计"].(int64)
+					dynamicField["合计"] = hj
+
+					dynamicFields = append(dynamicFields, dynamicField)
+				}
+
+				// 将日期放在首位
+				seen := make(map[interface{}]struct{})
+				for _, field := range dynamicFields {
+					value := field["日期"]
+					if _, ok := seen[value]; !ok {
+						seen[value] = struct{}{}
+						uniqueFields = append(uniqueFields, field)
+					}
+				}
+			}
+			c.ServeSuccessJSON(map[string]interface{}{
+				"list": uniqueFields,
+			})
+
+			break
+		case 3:
+			months := groupByMonth(dates)
+			var uniqueFields []map[string]interface{}
+			for _, month := range months {
+				// 解析字符串时显式指定时区为 UTC
+				t, err := time.Parse("2006-01-02 15:04:05 -0700 MST", month[0].String())
+				if err != nil {
+					fmt.Println("解析时间出错:", err)
+					return
+				}
+				// 解析字符串时显式指定时区为 UTC
+				t2, err := time.Parse("2006-01-02 15:04:05 -0700 MST", month[len(month)-1].String())
+				if err != nil {
+					fmt.Println("解析时间出错:", err)
+					return
+				}
+				//dynamicFields := make([]map[string]interface{}, 0)
+				list, _ := service.GetDialysisStats(t.Unix(), t2.Unix(), mode, c.GetAdminUserInfo().CurrentOrgId, time_way)
+				//fmt.Println(aa)
+				var dynamicFields []map[string]interface{}
+				//var uniqueFields []map[string]interface{}
+
+				for _, result := range list {
+					// 打印患者ID
+					nb := result["日期"].([]byte)
+					name := string(nb)
+
+					// 创建动态字段的map
+					dynamicField := make(map[string]interface{})
+					// 将日期放在首位
+					dynamicField["日期"] = name
+
+					// 打印其他列的值，并添加到动态字段中
+					for columnName, columnValue := range result {
+						if columnName == "日期" {
+							continue
+						}
+						if columnName == "合计" {
+							continue
+						}
+						if columnValue == nil {
+							dynamicField[columnName] = ""
+							continue
+						}
+
+						byteValue, ok := columnValue.([]byte)
+						if !ok {
+							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 {
+							if floatValue == 0 {
+								dynamicField[columnName] = ""
+							} else {
+								dynamicField[columnName] = floatValue
+							}
+						}
+					}
+
+					// 将合计放在末尾
+					hj := result["合计"].(int64)
+					dynamicField["合计"] = hj
+
+					dynamicFields = append(dynamicFields, dynamicField)
+				}
+
+				// 将日期放在首位
+				seen := make(map[interface{}]struct{})
+				for _, field := range dynamicFields {
+					value := field["日期"]
+					if _, ok := seen[value]; !ok {
+						seen[value] = struct{}{}
+						uniqueFields = append(uniqueFields, field)
+					}
+				}
+			}
+			c.ServeSuccessJSON(map[string]interface{}{
+				"list": uniqueFields,
+			})
+			break
+		case 4:
+			years := groupByYear(dates)
+			var uniqueFields []map[string]interface{}
+			for _, year := range years {
+				// 解析字符串时显式指定时区为 UTC
+				t, err := time.Parse("2006-01-02 15:04:05 -0700 MST", year[0].String())
+				if err != nil {
+					fmt.Println("解析时间出错:", err)
+					return
+				}
+				// 解析字符串时显式指定时区为 UTC
+				t2, err := time.Parse("2006-01-02 15:04:05 -0700 MST", year[len(year)-1].String())
+				if err != nil {
+					fmt.Println("解析时间出错:", err)
+					return
+				}
+				//dynamicFields := make([]map[string]interface{}, 0)
+				list, _ := service.GetDialysisStats(t.Unix(), t2.Unix(), mode, c.GetAdminUserInfo().CurrentOrgId, time_way)
+				//fmt.Println(aa)
+				var dynamicFields []map[string]interface{}
+				//var uniqueFields []map[string]interface{}
+
+				for _, result := range list {
+					// 打印患者ID
+					nb := result["日期"].([]byte)
+					name := string(nb)
+
+					// 创建动态字段的map
+					dynamicField := make(map[string]interface{})
+					// 将日期放在首位
+					dynamicField["日期"] = name
+
+					// 打印其他列的值，并添加到动态字段中
+					for columnName, columnValue := range result {
+						if columnName == "日期" {
+							continue
+						}
+						if columnName == "合计" {
+							continue
+						}
+						if columnValue == nil {
+							dynamicField[columnName] = ""
+							continue
+						}
+
+						byteValue, ok := columnValue.([]byte)
+						if !ok {
+							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 {
+							if floatValue == 0 {
+								dynamicField[columnName] = ""
+							} else {
+								dynamicField[columnName] = floatValue
+							}
+						}
+					}
+
+					// 将合计放在末尾
+					hj := result["合计"].(int64)
+					dynamicField["合计"] = hj
+
+					dynamicFields = append(dynamicFields, dynamicField)
+				}
+
+				// 将日期放在首位
+				seen := make(map[interface{}]struct{})
+				for _, field := range dynamicFields {
+					value := field["日期"]
+					if _, ok := seen[value]; !ok {
+						seen[value] = struct{}{}
+						uniqueFields = append(uniqueFields, field)
+					}
+				}
+			}
+			c.ServeSuccessJSON(map[string]interface{}{
+				"list": uniqueFields,
+			})
+			break
+
+		}
+
 	} else {
-		data, _ := service.GetScheduleStats(startTime, endTime, time_way, mode)
-		c.ServeSuccessJSON(map[string]interface{}{
-			"data": data,
-		})
+		switch time_way {
+		case 2:
+			weeks := groupByWeek(dates)
+			//var uniqueFields []map[string]interface{}
+			var uniqueFields []map[string]interface{}
+
+			for _, week := range weeks {
+				// 解析字符串时显式指定时区为 UTC
+				t, err := time.Parse("2006-01-02 15:04:05 -0700 MST", week[0].String())
+				if err != nil {
+					fmt.Println("解析时间出错:", err)
+					return
+				}
+				// 解析字符串时显式指定时区为 UTC
+				t2, err := time.Parse("2006-01-02 15:04:05 -0700 MST", week[len(week)-1].String())
+				if err != nil {
+					fmt.Println("解析时间出错:", err)
+					return
+				}
+				//dynamicFields := make([]map[string]interface{}, 0)
+				list, _ := service.GetScheduleStats(t.Unix(), t2.Unix(), mode, c.GetAdminUserInfo().CurrentOrgId, time_way)
+				//fmt.Println(aa)
+				var dynamicFields []map[string]interface{}
+				//var uniqueFields []map[string]interface{}
+
+				for _, result := range list {
+					// 打印患者ID
+					nb := result["日期"].([]byte)
+					name := string(nb)
+
+					// 创建动态字段的map
+					dynamicField := make(map[string]interface{})
+					// 将日期放在首位
+					dynamicField["日期"] = name
+
+					// 打印其他列的值，并添加到动态字段中
+					for columnName, columnValue := range result {
+						if columnName == "日期" {
+							continue
+						}
+						if columnName == "合计" {
+							continue
+						}
+						if columnValue == nil {
+							dynamicField[columnName] = ""
+							continue
+						}
+
+						byteValue, ok := columnValue.([]byte)
+						if !ok {
+							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 {
+							if floatValue == 0 {
+								dynamicField[columnName] = ""
+							} else {
+								dynamicField[columnName] = floatValue
+							}
+						}
+					}
+
+					// 将合计放在末尾
+					hj := result["合计"].(int64)
+					dynamicField["合计"] = hj
+
+					dynamicFields = append(dynamicFields, dynamicField)
+				}
+
+				// 将日期放在首位
+				seen := make(map[interface{}]struct{})
+				for _, field := range dynamicFields {
+					value := field["日期"]
+					if _, ok := seen[value]; !ok {
+						seen[value] = struct{}{}
+						uniqueFields = append(uniqueFields, field)
+					}
+				}
+			}
+			c.ServeSuccessJSON(map[string]interface{}{
+				"list": uniqueFields,
+			})
+
+			break
+		case 1:
+			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)
+			var uniqueFields []map[string]interface{}
+			for _, date := range dailyDates {
+				list, _ := service.GetScheduleStats(date.Unix(), date.Unix(), mode, c.GetAdminUserInfo().CurrentOrgId, time_way)
+				//fmt.Println(aa)
+				var dynamicFields []map[string]interface{}
+
+				for _, result := range list {
+					// 打印患者ID
+					nb := result["日期"].([]byte)
+					name := string(nb)
+
+					// 创建动态字段的map
+					dynamicField := make(map[string]interface{})
+					// 将日期放在首位
+					dynamicField["日期"] = name
+
+					// 打印其他列的值，并添加到动态字段中
+					for columnName, columnValue := range result {
+						if columnName == "日期" {
+							continue
+						}
+						if columnName == "合计" {
+							continue
+						}
+						if columnValue == nil {
+							dynamicField[columnName] = ""
+							continue
+						}
+
+						byteValue, ok := columnValue.([]byte)
+						if !ok {
+							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 {
+							if floatValue == 0 {
+								dynamicField[columnName] = ""
+							} else {
+								dynamicField[columnName] = floatValue
+							}
+						}
+					}
+
+					// 将合计放在末尾
+					hj := result["合计"].(int64)
+					dynamicField["合计"] = hj
+
+					dynamicFields = append(dynamicFields, dynamicField)
+				}
+
+				// 将日期放在首位
+				seen := make(map[interface{}]struct{})
+				for _, field := range dynamicFields {
+					value := field["日期"]
+					if _, ok := seen[value]; !ok {
+						seen[value] = struct{}{}
+						uniqueFields = append(uniqueFields, field)
+					}
+				}
+			}
+			c.ServeSuccessJSON(map[string]interface{}{
+				"list": uniqueFields,
+			})
+
+			break
+		case 3:
+			months := groupByMonth(dates)
+			var uniqueFields []map[string]interface{}
+			for _, month := range months {
+				// 解析字符串时显式指定时区为 UTC
+				t, err := time.Parse("2006-01-02 15:04:05 -0700 MST", month[0].String())
+				if err != nil {
+					fmt.Println("解析时间出错:", err)
+					return
+				}
+				// 解析字符串时显式指定时区为 UTC
+				t2, err := time.Parse("2006-01-02 15:04:05 -0700 MST", month[len(month)-1].String())
+				if err != nil {
+					fmt.Println("解析时间出错:", err)
+					return
+				}
+				//dynamicFields := make([]map[string]interface{}, 0)
+				list, _ := service.GetScheduleStats(t.Unix(), t2.Unix(), mode, c.GetAdminUserInfo().CurrentOrgId, time_way)
+				//fmt.Println(aa)
+				var dynamicFields []map[string]interface{}
+				//var uniqueFields []map[string]interface{}
+
+				for _, result := range list {
+					// 打印患者ID
+					nb := result["日期"].([]byte)
+					name := string(nb)
+
+					// 创建动态字段的map
+					dynamicField := make(map[string]interface{})
+					// 将日期放在首位
+					dynamicField["日期"] = name
+
+					// 打印其他列的值，并添加到动态字段中
+					for columnName, columnValue := range result {
+						if columnName == "日期" {
+							continue
+						}
+						if columnName == "合计" {
+							continue
+						}
+						if columnValue == nil {
+							dynamicField[columnName] = ""
+							continue
+						}
+
+						byteValue, ok := columnValue.([]byte)
+						if !ok {
+							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 {
+							if floatValue == 0 {
+								dynamicField[columnName] = ""
+							} else {
+								dynamicField[columnName] = floatValue
+							}
+						}
+					}
+
+					// 将合计放在末尾
+					hj := result["合计"].(int64)
+					dynamicField["合计"] = hj
+
+					dynamicFields = append(dynamicFields, dynamicField)
+				}
+
+				// 将日期放在首位
+				seen := make(map[interface{}]struct{})
+				for _, field := range dynamicFields {
+					value := field["日期"]
+					if _, ok := seen[value]; !ok {
+						seen[value] = struct{}{}
+						uniqueFields = append(uniqueFields, field)
+					}
+				}
+			}
+			c.ServeSuccessJSON(map[string]interface{}{
+				"list": uniqueFields,
+			})
+			break
+		case 4:
+			years := groupByYear(dates)
+			var uniqueFields []map[string]interface{}
+			for _, year := range years {
+				// 解析字符串时显式指定时区为 UTC
+				t, err := time.Parse("2006-01-02 15:04:05 -0700 MST", year[0].String())
+				if err != nil {
+					fmt.Println("解析时间出错:", err)
+					return
+				}
+				// 解析字符串时显式指定时区为 UTC
+				t2, err := time.Parse("2006-01-02 15:04:05 -0700 MST", year[len(year)-1].String())
+				if err != nil {
+					fmt.Println("解析时间出错:", err)
+					return
+				}
+				//dynamicFields := make([]map[string]interface{}, 0)
+				list, _ := service.GetScheduleStats(t.Unix(), t2.Unix(), mode, c.GetAdminUserInfo().CurrentOrgId, time_way)
+				//fmt.Println(aa)
+				var dynamicFields []map[string]interface{}
+				//var uniqueFields []map[string]interface{}
+
+				for _, result := range list {
+					// 打印患者ID
+					nb := result["日期"].([]byte)
+					name := string(nb)
+
+					// 创建动态字段的map
+					dynamicField := make(map[string]interface{})
+					// 将日期放在首位
+					dynamicField["日期"] = name
+
+					// 打印其他列的值，并添加到动态字段中
+					for columnName, columnValue := range result {
+						if columnName == "日期" {
+							continue
+						}
+						if columnName == "合计" {
+							continue
+						}
+						if columnValue == nil {
+							dynamicField[columnName] = ""
+							continue
+						}
+
+						byteValue, ok := columnValue.([]byte)
+						if !ok {
+							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 {
+							if floatValue == 0 {
+								dynamicField[columnName] = ""
+							} else {
+								dynamicField[columnName] = floatValue
+							}
+						}
+					}
+
+					// 将合计放在末尾
+					hj := result["合计"].(int64)
+					dynamicField["合计"] = hj
+
+					dynamicFields = append(dynamicFields, dynamicField)
+				}
+
+				// 将日期放在首位
+				seen := make(map[interface{}]struct{})
+				for _, field := range dynamicFields {
+					value := field["日期"]
+					if _, ok := seen[value]; !ok {
+						seen[value] = struct{}{}
+						uniqueFields = append(uniqueFields, field)
+					}
+				}
+			}
+			c.ServeSuccessJSON(map[string]interface{}{
+				"list": uniqueFields,
+			})
+			break
+		}
 	}
 }
 func (c *StatisticsApiController) GetDialysisTotalDetailInfo() {
@@ -597,8 +1290,8 @@ func (c *StatisticsApiController) GetAllCommonInspectionStatistisc() {
 
 }
 func (c *StatisticsApiController) GetPersonCommonInspectionStatistisc() {
-	start_date := c.GetString("start_time")
-	end_date := c.GetString("end_time")
+	start_date := c.GetString("start_date")
+	end_date := c.GetString("end_date")
 	project_id, _ := c.GetInt64("project_id")
 	item_id, _ := c.GetInt64("item_id")
 	patient_id, _ := c.GetInt64("patient_id")

service/statistis_qc_service.go

@@ -2,6 +2,7 @@ package service
 
 import (
 	"XT_New/models"
+	"database/sql"
 	"fmt"
 	"reflect"
 	"strings"
@@ -47,23 +48,37 @@ type DialysisStat struct {
 	Total  int            `json:"合计"`
 }
 
-func getTreatmentModes() ([]TreatmentMode, error) {
-	var modes []TreatmentMode
-	if err := XTReadDB().Find(&modes).Error; err != nil {
+func GetTreatmentModes() ([]models.TreatmentMode, error) {
+	var modes []models.TreatmentMode
+	if err := XTReadDB().Model(&models.TreatmentMode{}).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()
+func GetDialysisStats(start int64, end int64, mode int64, org_id int64, time_way int64) ([]map[string]interface{}, error) {
+	// 将时间戳转换为time.Time类型
+	t := time.Unix(start, 0)
+	// 使用布局定义格式化时间
+	layout := "2006-01-02"
+	// 将时间格式化为字符串
+	startDate := t.Format(layout) + " 00:00:00"
+
+	t2 := time.Unix(end, 0)
+	// 使用布局定义格式化时间
+	//layout := "2006-01-02"
+	// 将时间格式化为字符串
+	endDate := t2.Format(layout) + " 00:00:00"
+	//var stats []DialysisStat
+	var modes []models.TreatmentMode
+	fmt.Println(mode)
+	if mode == 0 {
+		modes, _ = GetTreatmentModes()
+
 	} else {
-		modes_two, _ := getTreatmentModes()
+		modes_two, _ := GetTreatmentModes()
 		for _, item := range modes_two {
-			if item.ModeID == int(mode) {
+			if item.ModeID == mode {
 				modes = append(modes, item)
 			}
 		}
@@ -73,28 +88,43 @@ func GetDialysisStats(startDate int64, endDate int64, groupBy int64, mode int64)
 		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")
-	}
+	var selectClauses []string
 	// 构建动态查询语句
-	selectClauses := []string{fmt.Sprintf("DATE_FORMAT(p.record_date, '%s') AS `日期`", dateFormat)}
+	if time_way == 1 {
+		selectClauses = []string{fmt.Sprintf("'%s' AS `日期`", strings.Split(startDate, " ")[0])}
+	} else if time_way == 3 {
+		selectClauses = []string{fmt.Sprintf("'%s' AS `日期`", strings.Split(strings.Split(startDate, " ")[0], "-")[0]+"-"+strings.Split(strings.Split(startDate, " ")[0], "-")[1])}
+	} else if time_way == 4 {
+		selectClauses = []string{fmt.Sprintf("'%s' AS `日期`", strings.Split(strings.Split(startDate, " ")[0], "-")[0])}
+	} else {
+		selectClauses = []string{fmt.Sprintf("'%s' AS `日期`", strings.Split(startDate, " ")[0]+"~"+strings.Split(endDate, " ")[0])}
+	}
 	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))
+		fmt.Println(mode)
+
+		selectClauses = append(selectClauses, fmt.Sprintf("COALESCE(SUM(CASE WHEN t.name = '%s' THEN 1 ELSE 0 END), 0) AS `%s`", mode.Name, mode.Name))
 	}
 	selectClauses = append(selectClauses, "COUNT(*) AS `合计`")
 
-	query := fmt.Sprintf(`
+	var rows *sql.Rows
+	var query string
+	if mode > 0 {
+		query = fmt.Sprintf(`
+        SELECT
+            %s
+        FROM
+            xt_dialysis_prescription p
+        JOIN
+            xt_treatment_mode t ON p.mode_id = t.mode_id
+        WHERE
+            FROM_UNIXTIME(p.record_date) >= ? AND FROM_UNIXTIME(p.record_date) <= ? AND p.user_org_id = ? and p.mode_id = ?
+        GROUP BY
+           日期
+    `, strings.Join(selectClauses, ", "))
+		rows, _ = readDb.Raw(query, startDate, endDate, org_id, mode).Rows()
+
+	} else {
+		query = fmt.Sprintf(`
         SELECT
             %s
         FROM
@@ -102,48 +132,93 @@ func GetDialysisStats(startDate int64, endDate int64, groupBy int64, mode int64)
         JOIN
             xt_treatment_mode t ON p.mode_id = t.mode_id
         WHERE
-            p.record_date >= ? AND p.record_date <= ?
+            FROM_UNIXTIME(p.record_date) >= ? AND FROM_UNIXTIME(p.record_date) <= ? AND p.user_org_id = ? 
         GROUP BY
-            DATE_FORMAT(p.record_date, '%s')
-    `, dateFormat, dateFormat, selectClauses)
+           日期
+    `, strings.Join(selectClauses, ", "))
+		rows, _ = readDb.Raw(query, startDate, endDate, org_id).Rows()
+	}
 
-	rows, err := readDb.Raw(query, startDate, endDate).Rows()
 	if err != nil {
 		return nil, err
 	}
 	defer rows.Close()
 
-	// 解析查询结果
+	columns, err := rows.Columns()
+	if err != nil {
+		return nil, err
+	}
+
+	var results []map[string]interface{}
+
 	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
+		// 创建一个长度为列数的切片，用于存储每一行的值
+		columnValues := make([]interface{}, len(columns))
+		columnPointers := make([]interface{}, len(columns))
+		for i := range columnValues {
+			columnPointers[i] = &columnValues[i]
 		}
-		var total int
-		cols = append(cols, &total)
-		stat.Total = total
-		if err := rows.Scan(cols...); err != nil {
+
+		// 扫描当前行的值
+		if err := rows.Scan(columnPointers...); err != nil {
 			return nil, err
 		}
-		stats = append(stats, stat)
+
+		// 将扫描到的值放入结果 map 中
+		result := make(map[string]interface{})
+		for i, colName := range columns {
+			val := columnPointers[i].(*interface{})
+			result[colName] = *val
+		}
+
+		results = append(results, result)
 	}
 
-	return stats, nil
+	//// 解析查询结果
+	//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.Name] = 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 results, nil
 }
 
-func GetScheduleStats(startDate int64, endDate int64, groupBy int64, mode int64) ([]DialysisStat, error) {
-	var stats []DialysisStat
-	var modes []TreatmentMode
-	if mode > 0 {
-		modes, _ = getTreatmentModes()
+func GetScheduleStats(start int64, end int64, mode int64, org_id int64, time_way int64) ([]map[string]interface{}, error) {
+	// 将时间戳转换为time.Time类型
+	t := time.Unix(start, 0)
+	// 使用布局定义格式化时间
+	layout := "2006-01-02"
+	// 将时间格式化为字符串
+	startDate := t.Format(layout) + " 00:00:00"
+
+	t2 := time.Unix(end, 0)
+	// 使用布局定义格式化时间
+	//layout := "2006-01-02"
+	// 将时间格式化为字符串
+	endDate := t2.Format(layout) + " 00:00:00"
+	//var stats []DialysisStat
+	var modes []models.TreatmentMode
+	fmt.Println(mode)
+	if mode == 0 {
+		modes, _ = GetTreatmentModes()
+
 	} else {
-		modes_two, _ := getTreatmentModes()
+		modes_two, _ := GetTreatmentModes()
 		for _, item := range modes_two {
-			if item.ModeID == int(mode) {
+			if item.ModeID == mode {
 				modes = append(modes, item)
 			}
 		}
@@ -153,28 +228,28 @@ func GetScheduleStats(startDate int64, endDate int64, groupBy int64, mode int64)
 		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")
-	}
+	var selectClauses []string
 	// 构建动态查询语句
-	selectClauses := []string{fmt.Sprintf("DATE_FORMAT(p.schudle_date, '%s') AS `日期`", dateFormat)}
+	if time_way == 1 {
+		selectClauses = []string{fmt.Sprintf("'%s' AS `日期`", strings.Split(startDate, " ")[0])}
+	} else if time_way == 3 {
+		selectClauses = []string{fmt.Sprintf("'%s' AS `日期`", strings.Split(strings.Split(startDate, " ")[0], "-")[0]+strings.Split(strings.Split(startDate, " ")[0], "-")[1])}
+	} else if time_way == 4 {
+		selectClauses = []string{fmt.Sprintf("'%s' AS `日期`", strings.Split(strings.Split(startDate, " ")[0], "-")[0])}
+	} else {
+		selectClauses = []string{fmt.Sprintf("'%s' AS `日期`", strings.Split(startDate, " ")[0]+"~"+strings.Split(endDate, " ")[0])}
+	}
 	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))
+		fmt.Println(mode)
+
+		selectClauses = append(selectClauses, fmt.Sprintf("COALESCE(SUM(CASE WHEN t.name = '%s' THEN 1 ELSE 0 END), 0) AS `%s`", mode.Name, mode.Name))
 	}
 	selectClauses = append(selectClauses, "COUNT(*) AS `合计`")
 
-	query := fmt.Sprintf(`
+	var rows *sql.Rows
+	var query string
+	if mode > 0 {
+		query = fmt.Sprintf(`
         SELECT
             %s
         FROM
@@ -182,39 +257,165 @@ func GetScheduleStats(startDate int64, endDate int64, groupBy int64, mode int64)
         JOIN
             xt_treatment_mode t ON p.mode_id = t.mode_id
         WHERE
-            p.schedule_date >= ? AND p.schedule_date <= ?
+            FROM_UNIXTIME(p.schedule_date) >= ? AND FROM_UNIXTIME(p.schedule_date) <= ? AND p.user_org_id = ? and p.mode_id = ?
         GROUP BY
-            DATE_FORMAT(p.schedule_date, '%s')
-    `, dateFormat, dateFormat, selectClauses)
+           日期
+    `, strings.Join(selectClauses, ", "))
+		rows, _ = readDb.Raw(query, startDate, endDate, org_id, mode).Rows()
+
+	} else {
+		query = fmt.Sprintf(`
+        SELECT
+            %s
+        FROM
+            xt_schedule p
+        JOIN
+            xt_treatment_mode t ON p.mode_id = t.mode_id
+        WHERE
+            FROM_UNIXTIME(p.schedule_date) >= ? AND FROM_UNIXTIME(p.schedule_date) <= ? AND p.user_org_id = ? 
+        GROUP BY
+           日期
+    `, strings.Join(selectClauses, ", "))
+		rows, _ = readDb.Raw(query, startDate, endDate, org_id).Rows()
+	}
 
-	rows, err := readDb.Raw(query, startDate, endDate).Rows()
 	if err != nil {
 		return nil, err
 	}
 	defer rows.Close()
 
-	// 解析查询结果
+	columns, err := rows.Columns()
+	if err != nil {
+		return nil, err
+	}
+
+	var results []map[string]interface{}
+
 	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
+		// 创建一个长度为列数的切片，用于存储每一行的值
+		columnValues := make([]interface{}, len(columns))
+		columnPointers := make([]interface{}, len(columns))
+		for i := range columnValues {
+			columnPointers[i] = &columnValues[i]
 		}
-		var total int
-		cols = append(cols, &total)
-		stat.Total = total
-		if err := rows.Scan(cols...); err != nil {
+
+		// 扫描当前行的值
+		if err := rows.Scan(columnPointers...); err != nil {
 			return nil, err
 		}
-		stats = append(stats, stat)
+
+		// 将扫描到的值放入结果 map 中
+		result := make(map[string]interface{})
+		for i, colName := range columns {
+			val := columnPointers[i].(*interface{})
+			result[colName] = *val
+		}
+
+		results = append(results, result)
 	}
 
-	return stats, nil
+	//// 解析查询结果
+	//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.Name] = 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 results, nil
 }
 
+//func GetScheduleStats(startDate int64, endDate int64, groupBy int64, mode int64, org_id int64) ([]DialysisStat, error) {
+//	var stats []DialysisStat
+//	var modes []models.TreatmentMode
+//	if mode > 0 {
+//		modes, _ = GetTreatmentModes()
+//	} else {
+//		modes_two, _ := GetTreatmentModes()
+//		for _, item := range modes_two {
+//			if item.ModeID == 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.Name, mode.Name))
+//	}
+//	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.Name] = 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 {