fix clusterResouces bugs

Former-commit-id: 52c5b84d89

api/internal/cron/aiCronTask.go

@@ -382,6 +382,10 @@ func UpdateClusterResource(svc *svc.ServiceContext) {
 						return
 					}
 				} else {
+					if stat.CpuCoreTotal == 0 || stat.MemTotal == 0 || stat.DiskTotal == 0 {
+						wg.Done()
+						return
+					}
 					clusterResource.CardTotal = cardTotal
 					clusterResource.CardTopsTotal = topsTotal
 					clusterResource.CpuAvail = float64(stat.CpuCoreAvail)

api/internal/cron/cron.go

@@ -44,7 +44,7 @@ func AddCronGroup(svc *svc.ServiceContext) {
 		UpdateAiAdapterMaps(svc)
 	})
 
-	svc.Cron.AddFunc("30 21 * * *", func() {
+	svc.Cron.AddFunc("@every 7h30m", func() {
 		UpdateClusterResource(svc)
 	})
 }

api/internal/logic/ai/getcenteroverviewlogic.go

@@ -134,6 +134,10 @@ func (l *GetCenterOverviewLogic) updateClusterResource(mu *sync.RWMutex, ch chan
 						return
 					}
 				} else {
+					if stat.CpuCoreTotal == 0 || stat.MemTotal == 0 || stat.DiskTotal == 0 {
+						wg.Done()
+						return
+					}
 					clusterResource.CardTotal = cardTotal
 					clusterResource.CardTopsTotal = topsTotal
 					clusterResource.CpuAvail = float64(stat.CpuCoreAvail)

api/internal/scheduler/database/aiStorage.go

@@ -234,13 +234,16 @@ func (s *AiStorage) UpdateClusterResources(clusterResource *models.TClusterResou
 	}
 	// prometheus
 	param := tracker.ClusterLoadRecord{
-		ClusterName: clusterResource.ClusterName,
-		CpuAvail:    clusterResource.CpuAvail,
-		CpuTotal:    clusterResource.CpuTotal,
-		MemoryAvail: clusterResource.MemAvail,
-		MemoryTotal: clusterResource.MemTotal,
-		DiskAvail:   clusterResource.DiskAvail,
-		DiskTotal:   clusterResource.DiskTotal,
+		ClusterName:       clusterResource.ClusterName,
+		CpuAvail:          clusterResource.CpuAvail,
+		CpuTotal:          clusterResource.CpuTotal,
+		CpuUtilisation:    clusterResource.CpuAvail / clusterResource.CpuTotal,
+		MemoryAvail:       clusterResource.MemAvail,
+		MemoryTotal:       clusterResource.MemTotal,
+		MemoryUtilisation: clusterResource.MemAvail / clusterResource.MemTotal,
+		DiskAvail:         clusterResource.DiskAvail,
+		DiskTotal:         clusterResource.DiskTotal,
+		DiskUtilisation:   clusterResource.DiskAvail / clusterResource.DiskTotal,
 	}
 	tracker.SyncClusterLoad(param)
 	return nil