Update.

Author: xOS

db/badger.go

@@ -252,6 +252,33 @@ func (b *BadgerDB) FindAll(prefix string, result interface{}) error {
 
 		log.Printf("FindAll (server case): 已处理 %d 条服务器记录. Final JSON to unmarshal to result: %s", len(servers), string(serversJSON))
 		return json.Unmarshal(serversJSON, result)
+	case "monitor":
+		// 监控器记录也需要特殊处理布尔字段
+		var monitors []*map[string]interface{}
+		for i, item := range items {
+			log.Printf("FindAll (monitor case): Processing item %d, raw data: %s", i, string(item))
+			var data map[string]interface{}
+			if err := json.Unmarshal(item, &data); err != nil {
+				log.Printf("FindAll (monitor case): Item %d, 解析监控器数据失败: %v, 数据: %s", i, err, string(item))
+				continue
+			}
+			log.Printf("FindAll (monitor case): Item %d, successfully unmarshalled to map: %v", i, data)
+
+			// 转换字段类型，确保布尔字段正确
+			convertDbFieldTypes(&data)
+			log.Printf("FindAll (monitor case): Item %d, after convertDbFieldTypes: %v", i, data)
+			monitors = append(monitors, &data)
+		}
+
+		// 重新序列化为 JSON
+		monitorsJSON, err := json.Marshal(monitors)
+		if err != nil {
+			log.Printf("FindAll (monitor case): 重新序列化监控器数据失败: %v. Processed monitors data: %v", err, monitors)
+			return err
+		}
+
+		log.Printf("FindAll (monitor case): 已处理 %d 条监控器记录. Final JSON to unmarshal to result: %s", len(monitors), string(monitorsJSON))
+		return json.Unmarshal(monitorsJSON, result)
 	default:
 		// 其他类型的记录，使用标准处理方式
 		itemsJSON := "["
@@ -287,8 +314,16 @@ func convertDbFieldTypes(data *map[string]interface{}) {
 		}
 	}
 
-	// 处理布尔型字段
-	boolFields := []string{"is_online", "is_disabled", "hide_for_guest", "show_all", "tasker"}
+	// 处理布尔型字段 (支持多种命名格式)
+	boolFields := []string{
+		// Server fields
+		"is_online", "is_disabled", "hide_for_guest", "show_all", "tasker",
+		"HideForGuest", "EnableDDNS", "enable_ddns",
+		// Monitor fields  
+		"notify", "Notify", "enable_trigger_task", "EnableTriggerTask", 
+		"enable_show_in_service", "EnableShowInService", 
+		"latency_notify", "LatencyNotify",
+	}
 	for _, field := range boolFields {
 		if val, ok := d[field]; ok {
 			switch v := val.(type) {
@@ -316,10 +351,7 @@ func convertDbFieldTypes(data *map[string]interface{}) {
 		}
 	}
 
-	// 确保必要的字段存在
-	if _, ok := d["id"]; !ok {
-		d["id"] = float64(0)
-	}
+	// 确保必要的字段存在，但不要覆盖已存在的id字段
 	if _, ok := d["host_json"]; !ok {
 		d["host_json"] = ""
 	}

service/singleton/crontask.go

@@ -48,14 +48,19 @@ func InitCronTask() {
 		panic(err)
 	}
 
-	// 改为每30分钟同步一次所有服务器的累计流量，降低频率
-	if _, err := Cron.AddFunc("0 */30 * * * *", SyncAllServerTrafficFromDB); err != nil {
-		panic(err)
-	}
+	// 以下任务仅在非BadgerDB模式下注册，因为它们依赖GORM
+	if Conf == nil || Conf.DatabaseType != "badger" {
+		// 改为每30分钟同步一次所有服务器的累计流量，降低频率
+		if _, err := Cron.AddFunc("0 */30 * * * *", SyncAllServerTrafficFromDB); err != nil {
+			panic(err)
+		}
 
-	// 改为每15分钟保存一次流量数据到数据库，进一步降低频率
-	if _, err := Cron.AddFunc("0 */15 * * * *", SaveAllTrafficToDB); err != nil {
-		panic(err)
+		// 改为每15分钟保存一次流量数据到数据库，进一步降低频率
+		if _, err := Cron.AddFunc("0 */15 * * * *", SaveAllTrafficToDB); err != nil {
+			panic(err)
+		}
+	} else {
+		log.Println("BadgerDB模式：跳过注册GORM相关的定时任务")
 	}
 }
 

service/singleton/ddns.go

@@ -116,10 +116,10 @@ func DDNSChangeNotificationCallback(serverName string, serverID uint64, domain s
 		// 使用BadgerDB处理DDNS状态记录
 		if db.DB != nil {
 			ddnsOps := db.NewDDNSOps(db.DB)
-			
+
 			// 查询现有记录状态
 			recordState, err := ddnsOps.GetDDNSRecordStateByParams(serverID, domain, recordType)
-			
+
 			if err != nil {
 				// 记录不存在，创建新记录
 				if err == db.ErrorNotFound {