Update.

Author: xOS

pkg/ddns/ddns.go

@@ -50,14 +50,35 @@ func InitDNSServers(s string) {
 
 func (provider *Provider) UpdateDomain(ctx context.Context) {
 	provider.ctx = ctx
+
+	// 验证必要的配置
+	if len(provider.DDNSProfile.Domains) == 0 {
+		log.Printf("DDNS配置错误: 没有配置域名")
+		return
+	}
+
+	if provider.IPAddrs == nil {
+		log.Printf("DDNS配置错误: IP地址为空")
+		return
+	}
+
 	for _, domain := range provider.DDNSProfile.Domains {
-		for retries := 0; retries < int(provider.DDNSProfile.MaxRetries); retries++ {
+		maxRetries := int(provider.DDNSProfile.MaxRetries)
+		if maxRetries == 0 {
+			maxRetries = 3 // 默认重试3次
+		}
+
+		for retries := 0; retries < maxRetries; retries++ {
 			provider.domain = domain
-			log.Printf("NG>> 正在尝试更新域名(%s)DDNS(%d/%d)", provider.domain, retries+1, provider.DDNSProfile.MaxRetries)
+			log.Printf("正在尝试更新域名(%s)DDNS(%d/%d)", provider.domain, retries+1, maxRetries)
 			if err := provider.updateDomain(); err != nil {
-				log.Printf("NG>> 尝试更新域名(%s)DDNS失败: %v", provider.domain, err)
+				log.Printf("尝试更新域名(%s)DDNS失败: %v", provider.domain, err)
+				if retries < maxRetries-1 {
+					// 等待一段时间后重试
+					time.Sleep(time.Duration(retries+1) * 5 * time.Second)
+				}
 			} else {
-				log.Printf("NG>> 尝试更新域名(%s)DDNS成功", provider.domain)
+				log.Printf("更新域名(%s)DDNS成功", provider.domain)
 				break
 			}
 		}
@@ -102,8 +123,15 @@ func (provider *Provider) addDomainRecord() error {
 
 	// 检查IP是否实际发生了变化
 	if currentIP != "" && currentIP == provider.ipAddr {
-		log.Printf("域名 %s 的 %s 记录IP未发生变化 (%s)，跳过更新", provider.domain, provider.recordType, currentIP)
-		return nil // IP没有变化，不需要更新
+		// IP没有变化，不需要更新（减少日志输出）
+		return nil
+	}
+
+	// 记录IP变化信息
+	if currentIP != "" {
+		log.Printf("域名 %s 的 %s 记录IP发生变化: %s -> %s", provider.domain, provider.recordType, currentIP, provider.ipAddr)
+	} else {
+		log.Printf("域名 %s 设置 %s 记录IP: %s", provider.domain, provider.recordType, provider.ipAddr)
 	}
 
 	_, err = provider.Setter.SetRecords(provider.ctx, provider.zone,

service/rpc/server.go

@@ -765,23 +765,42 @@ func (s *ServerHandler) ReportSystemInfo(c context.Context, r *pb.Host) (*pb.Rec
 	defer singleton.ServerLock.RUnlock()
 
 	// 检查并更新DDNS
-	if singleton.ServerList[clientID].EnableDDNS && host.IP != "" &&
-		(singleton.ServerList[clientID].Host == nil || singleton.ServerList[clientID].Host.IP != host.IP) {
-		ipv4, ipv6, _ := utils.SplitIPAddr(host.IP)
-		providers, err := singleton.GetDDNSProvidersFromProfilesWithServer(
-			singleton.ServerList[clientID].DDNSProfiles,
-			&ddns.IP{Ipv4Addr: ipv4, Ipv6Addr: ipv6},
-			singleton.ServerList[clientID].Name,
-			clientID,
-		)
-		if err == nil {
-			for _, provider := range providers {
-				go func(provider *ddns.Provider) {
-					provider.UpdateDomain(context.Background())
-				}(provider)
-			}
+	server := singleton.ServerList[clientID]
+	if server.EnableDDNS {
+		if host.IP == "" {
+			log.Printf("服务器 %s (ID:%d) DDNS已启用但IP为空，跳过更新", server.Name, clientID)
+		} else if len(server.DDNSProfiles) == 0 {
+			log.Printf("服务器 %s (ID:%d) DDNS已启用但未配置DDNS配置文件", server.Name, clientID)
+		} else if server.Host != nil && server.Host.IP == host.IP {
+			// IP 没有变化，跳过更新（但不记录日志，避免频繁输出）
 		} else {
-			log.Printf("获取DDNS配置时发生错误: %v", err)
+			// IP 发生变化或首次设置，触发 DDNS 更新
+			ipv4, ipv6, _ := utils.SplitIPAddr(host.IP)
+			providers, err := singleton.GetDDNSProvidersFromProfilesWithServer(
+				server.DDNSProfiles,
+				&ddns.IP{Ipv4Addr: ipv4, Ipv6Addr: ipv6},
+				server.Name,
+				clientID,
+			)
+			if err == nil {
+				log.Printf("服务器 %s (ID:%d) IP变化 (%s -> %s)，触发DDNS更新，配置数量: %d",
+					server.Name, clientID,
+					func() string {
+						if server.Host != nil {
+							return server.Host.IP
+						} else {
+							return "无"
+						}
+					}(),
+					host.IP, len(providers))
+				for _, provider := range providers {
+					go func(provider *ddns.Provider) {
+						provider.UpdateDomain(context.Background())
+					}(provider)
+				}
+			} else {
+				log.Printf("服务器 %s (ID:%d) 获取DDNS配置时发生错误: %v", server.Name, clientID, err)
+			}
 		}
 	}
 

service/singleton/ddns.go

@@ -3,6 +3,7 @@ package singleton
 import (
 	"fmt"
 	"log"
+	"strings"
 	"sync"
 	"time"
 
@@ -23,8 +24,16 @@ var (
 )
 
 func initDDNS() {
+	log.Printf("初始化DDNS配置...")
 	OnDDNSUpdate()
 	OnNameserverUpdate()
+
+	// 验证DDNS配置加载情况
+	ddnsCacheLock.RLock()
+	configCount := len(ddnsCache)
+	ddnsCacheLock.RUnlock()
+
+	log.Printf("DDNS初始化完成，加载了 %d 个配置", configCount)
 }
 
 func OnDDNSUpdate() {
@@ -55,6 +64,10 @@ func OnDDNSUpdate() {
 	defer ddnsCacheLock.Unlock()
 	ddnsCache = make(map[uint64]*model.DDNSProfile)
 	for i := 0; i < len(ddns); i++ {
+		// 确保 BadgerDB 模式下 Domains 字段正确解析
+		if ddns[i].DomainsRaw != "" && len(ddns[i].Domains) == 0 {
+			ddns[i].Domains = strings.Split(ddns[i].DomainsRaw, ",")
+		}
 		ddnsCache[ddns[i].ID] = ddns[i]
 	}
 }
@@ -68,6 +81,11 @@ func GetDDNSProvidersFromProfiles(profileId []uint64, ip *ddns2.IP) ([]*ddns2.Pr
 	ddnsCacheLock.RLock()
 	for _, id := range profileId {
 		if profile, ok := ddnsCache[id]; ok {
+			// 验证 DDNS 配置的完整性
+			if len(profile.Domains) == 0 {
+				log.Printf("警告: DDNS配置 ID %d 没有配置域名", id)
+				continue
+			}
 			profiles = append(profiles, profile)
 		} else {
 			ddnsCacheLock.RUnlock()
@@ -76,6 +94,10 @@ func GetDDNSProvidersFromProfiles(profileId []uint64, ip *ddns2.IP) ([]*ddns2.Pr
 	}
 	ddnsCacheLock.RUnlock()
 
+	if len(profiles) == 0 {
+		return nil, fmt.Errorf("没有有效的DDNS配置")
+	}
+
 	providers := make([]*ddns2.Provider, 0, len(profiles))
 	for _, profile := range profiles {
 		provider := &ddns2.Provider{DDNSProfile: profile, IPAddrs: ip}