提交代码

controllers/statistics_api_controller.go

@@ -7,6 +7,7 @@ import (
 	"XT_New/utils"
 	"fmt"
 	"github.com/astaxie/beego"
+	"sort"
 	"strconv"
 	"strings"
 	"time"
@@ -345,27 +346,23 @@ func (c *StatisticsApiController) GetDialysisTotalDetail() {
 				//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
 
-					// 打印其他列的值，并添加到动态字段中
+					numericColumns := make(map[string]interface{})
+					nonNumericColumns := make(map[string]interface{})
+
+					// 分类处理列
 					for columnName, columnValue := range result {
-						if columnName == "日期" {
-							continue
-						}
-						if columnName == "合计" {
+						if columnName == "日期" || columnName == "合计" {
 							continue
 						}
 						if columnValue == nil {
-							dynamicField[columnName] = ""
+							nonNumericColumns[columnName] = ""
 							continue
 						}
 
@@ -376,36 +373,49 @@ func (c *StatisticsApiController) GetDialysisTotalDetail() {
 						}
 
 						strValue := string(byteValue)
-
 						floatValue, err := strconv.ParseFloat(strValue, 64)
 						if err != nil {
 							fmt.Printf("Error converting value for column %s: %v\n", columnName, err)
+							nonNumericColumns[columnName] = strValue
 						} else {
 							if floatValue == 0 {
-								dynamicField[columnName] = ""
+								nonNumericColumns[columnName] = ""
 							} else {
-								dynamicField[columnName] = floatValue
+								numericColumns[columnName] = floatValue
 							}
 						}
 					}
 
-					// 将合计放在末尾
+					// 添加数值列
+					for columnName, columnValue := range numericColumns {
+						dynamicField[columnName] = columnValue
+					}
+
+					// 添加非数值列
+					for columnName, columnValue := range nonNumericColumns {
+						dynamicField[columnName] = columnValue
+					}
+
 					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)
+
+						// 对字段进行排序，有值的排在前面
+						sortedField := sortFieldsByValue(field)
+						uniqueFields = append(uniqueFields, sortedField)
 					}
 				}
 			}
+
 			c.ServeSuccessJSON(map[string]interface{}{
 				"list": uniqueFields,
 			})
@@ -427,29 +437,25 @@ func (c *StatisticsApiController) GetDialysisTotalDetail() {
 			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
 
-					// 打印其他列的值，并添加到动态字段中
+					numericColumns := make(map[string]interface{})
+					nonNumericColumns := make(map[string]interface{})
+
+					// 分类处理列
 					for columnName, columnValue := range result {
-						if columnName == "日期" {
-							continue
-						}
-						if columnName == "合计" {
+						if columnName == "日期" || columnName == "合计" {
 							continue
 						}
 						if columnValue == nil {
-							dynamicField[columnName] = ""
+							nonNumericColumns[columnName] = ""
 							continue
 						}
 
@@ -460,27 +466,35 @@ func (c *StatisticsApiController) GetDialysisTotalDetail() {
 						}
 
 						strValue := string(byteValue)
-
 						floatValue, err := strconv.ParseFloat(strValue, 64)
 						if err != nil {
 							fmt.Printf("Error converting value for column %s: %v\n", columnName, err)
+							nonNumericColumns[columnName] = strValue
 						} else {
 							if floatValue == 0 {
-								dynamicField[columnName] = ""
+								nonNumericColumns[columnName] = ""
 							} else {
-								dynamicField[columnName] = floatValue
+								numericColumns[columnName] = floatValue
 							}
 						}
 					}
 
-					// 将合计放在末尾
+					// 添加数值列
+					for columnName, columnValue := range numericColumns {
+						dynamicField[columnName] = columnValue
+					}
+
+					// 添加非数值列
+					for columnName, columnValue := range nonNumericColumns {
+						dynamicField[columnName] = columnValue
+					}
+
 					hj := result["合计"].(int64)
 					dynamicField["合计"] = hj
 
 					dynamicFields = append(dynamicFields, dynamicField)
 				}
 
-				// 将日期放在首位
 				seen := make(map[interface{}]struct{})
 				for _, field := range dynamicFields {
 					value := field["日期"]
@@ -490,6 +504,143 @@ func (c *StatisticsApiController) GetDialysisTotalDetail() {
 					}
 				}
 			}
+
+			//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
+			//
+			//		// 临时存储无数值的列
+			//		nonNumericColumns := make(map[string]interface{})
+			//
+			//		// 先处理包含数值的列
+			//		for columnName, columnValue := range result {
+			//			if columnName == "日期" || columnName == "合计" {
+			//				continue
+			//			}
+			//			if columnValue == nil {
+			//				nonNumericColumns[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)
+			//				nonNumericColumns[columnName] = strValue
+			//			} else {
+			//				if floatValue == 0 {
+			//					nonNumericColumns[columnName] = ""
+			//				} else {
+			//					dynamicField[columnName] = floatValue
+			//				}
+			//			}
+			//		}
+			//
+			//		// 添加无数值的列
+			//		for columnName, columnValue := range nonNumericColumns {
+			//			dynamicField[columnName] = columnValue
+			//		}
+			//
+			//		// 将合计放在末尾
+			//		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)
+			//		}
+			//	}
+			//}
+			//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,
 			})
@@ -1173,6 +1324,8 @@ func (c *StatisticsApiController) GetDialyzer() {
 		return
 	}
 	dialyzers, err := service.GetDialyzerData(startTime, endTime, c.GetAdminUserInfo().CurrentOrgId)
+	DialysisIrrigation, err := service.GetDialysisIrrigationData(startTime, endTime, c.GetAdminUserInfo().CurrentOrgId)
+
 	if err != nil {
 		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
 		return
@@ -1190,6 +1343,13 @@ func (c *StatisticsApiController) GetDialyzer() {
 		respData.Percentage = float64(item.Count) / float64(total) * 100
 		respDatas = append(respDatas, respData)
 	}
+	for _, item := range DialysisIrrigation {
+		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,
 	})
@@ -1238,8 +1398,8 @@ func (c *StatisticsApiController) GetDialyzerDetail() {
 }
 func (c *StatisticsApiController) GetDialyzerConfig() {
 	dialyzers, _ := service.GetDialyzerSummary(c.GetAdminUserInfo().CurrentOrgId)
-	//Irrigation, _ := service.GetIrrigationSummary(c.GetAdminUserInfo().CurrentOrgId)
-	//dialyzers = append(dialyzers, Irrigation...)
+	Irrigation, _ := service.GetIrrigationSummary(c.GetAdminUserInfo().CurrentOrgId)
+	dialyzers = append(dialyzers, Irrigation...)
 	c.ServeSuccessJSON(map[string]interface{}{
 		"dialyzers": dialyzers,
 	})
@@ -2011,3 +2171,38 @@ func splitByDay(startDate, endDate time.Time) []time.Time {
 	}
 	return dates
 }
+
+// 排序函数
+func sortFieldsByValue(field map[string]interface{}) map[string]interface{} {
+	// 将键值对分成两个部分，一个有值，一个无值
+	var withValue, withoutValue []string
+
+	for key, value := range field {
+		if key == "日期" || key == "合计" {
+			continue
+		}
+		if value == "" {
+			withoutValue = append(withoutValue, key)
+		} else {
+			withValue = append(withValue, key)
+		}
+	}
+
+	// 对有值和无值部分分别排序
+	sort.Strings(withValue)
+	sort.Strings(withoutValue)
+
+	// 创建一个新的有序map
+	sortedField := make(map[string]interface{})
+	sortedField["日期"] = field["日期"]
+
+	for _, key := range withValue {
+		sortedField[key] = field[key]
+	}
+	for _, key := range withoutValue {
+		sortedField[key] = field[key]
+	}
+
+	sortedField["合计"] = field["合计"]
+	return sortedField
+}

service/statistis_qc_service.go

@@ -94,7 +94,7 @@ func GetDialysisStats(start int64, end int64, mode int64, org_id int64, time_way
 	// 构建动态查询语句
 	if time_way == 1 {
 		//selectClauses = []string{fmt.Sprintf("'%s' AS `日期`", strings.Split(startDate, " ")[0])}
-		selectClauses = []string{fmt.Sprintf("'%s' AS `日期`", strings.Split(startDate, " ")[0]+"~"+strings.Split(endDate, " ")[0])}
+		selectClauses = []string{fmt.Sprintf("'%s' AS `日期`", strings.Split(startDate, " ")[0])}
 
 	} else if time_way == 3 {
 		selectClauses = []string{fmt.Sprintf("'%s' AS `日期`", strings.Split(startDate, " ")[0]+"~"+strings.Split(endDate, " ")[0])}
@@ -555,9 +555,10 @@ func GetAnticoagulantData(start_time int64, end_time int64, org_id int64) (map[s
 	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
 		}
+		//else {
+		//	anticoagulantData[fmt.Sprintf("Unknown (%d)", result.Anticoagulant)] = result.Count
+		//}
 	}
 
 	return anticoagulantData, nil
@@ -601,7 +602,7 @@ type DialyzerResult struct {
 }
 
 func GetDialyzerData(start_time int64, end_time int64, org_id int64) (dr []DialyzerResult, err error) {
-	err = XTReadDB().Model(&models.DialysisPrescription{}).
+	err = XTReadDB().Model(&models.DialysisPrescription{}).Joins("join xt_dialysis_order oo on oo.patient_id = xt_dialysis_prescription.patient_id and oo.dialysis_date = xt_dialysis_prescription.record_date and oo.status = 1").
 		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").
@@ -609,6 +610,15 @@ func GetDialyzerData(start_time int64, end_time int64, org_id int64) (dr []Dialy
 	return
 }
 
+func GetDialysisIrrigationData(start_time int64, end_time int64, org_id int64) (dr []DialyzerResult, err error) {
+	err = XTReadDB().Model(&models.DialysisPrescription{}).Joins("join xt_dialysis_order oo on oo.patient_id = xt_dialysis_prescription.patient_id and oo.dialysis_date = xt_dialysis_prescription.record_date and oo.status = 1").
+		Select("dialysis_irrigation as dialysis_irrigation, COUNT(*) as count").
+		Where("record_date >= ? and record_date <= ? and user_org_id = ? and status = 1", start_time, end_time, org_id).
+		Group("dialysis_irrigation").
+		Scan(&dr).Error
+	return
+}
+
 func GetIrrigationData(start_time int64, end_time int64, org_id int64) (dr []DialyzerResult, err error) {
 	err = XTReadDB().Model(&models.DialysisPrescription{}).
 		Select("dialysis_irrigation as dialyzer, COUNT(*) as count").
@@ -619,15 +629,15 @@ func GetIrrigationData(start_time int64, end_time int64, org_id int64) (dr []Dia
 }
 
 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).
+	err = XTReadDB().Model(&models.DialysisPrescription{}).Joins("join xt_dialysis_order oo on oo.patient_id = xt_dialysis_prescription.patient_id and oo.dialysis_date = xt_dialysis_prescription.record_date and oo.status = 1").
+		Where("status = 1 and record_date >= ? and record_date <= ? and user_org_id = ?", 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{}).Preload("QCPatients", "status = 1 and user_org_id = ?", orgid).Where("status = 1")
+	db := XTReadDB().Model(&models.DialysisPrescription{}).Joins("join xt_dialysis_order oo on oo.patient_id = xt_dialysis_prescription.patient_id and oo.dialysis_date = xt_dialysis_prescription.record_date and oo.status = 1").Preload("QCPatients", "status = 1 and user_org_id = ?", orgid).Where("status = 1")
 	if anticoagulant > 0 {
 		db = db.Where("anticoagulant = ?", anticoagulant)
 	}
@@ -644,9 +654,9 @@ func GetPrescriptionByAnticoagulant(page int64, limit int64, orgid int64, antico
 
 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{}).Preload("QCPatients", "status = 1 and user_org_id = ?", orgid).Where("status = 1")
+	db := XTReadDB().Model(&models.DialysisPrescription{}).Joins("join xt_dialysis_order oo on oo.patient_id = xt_dialysis_prescription.patient_id and oo.dialysis_date = xt_dialysis_prescription.record_date and oo.status = 1").Preload("QCPatients", "status = 1 and user_org_id = ?", orgid).Where("status = 1")
 	if len(dialyzer) > 0 {
-		db = db.Where("dialysis_dialyszers = ?", dialyzer)
+		db = db.Where("dialysis_dialyszers = ? or dialysis_irrigation = ?", dialyzer, dialyzer)
 	}
 	if orgid > 0 {
 		db = db.Where("user_org_id = ?", orgid)