merge

models/cloudbrain_static.go

@@ -164,6 +164,12 @@ func GetTodayCreatorCount(beginTime time.Time, endTime time.Time) (int64, error)
 		" and created_unix<" + strconv.FormatInt(endTime.Unix(), 10)
 	return x.SQL(countSql).Count()
 }
+func GetTodayCloudbrainCount(beginTime time.Time, endTime time.Time) (int64, error) {
+	countSql := "SELECT count FROM  " +
+		"public.cloudbrain where created_unix >=" + strconv.FormatInt(beginTime.Unix(), 10) +
+		" and created_unix<=" + strconv.FormatInt(endTime.Unix(), 10)
+	return x.SQL(countSql).Count()
+}
 func GetCreatorCount() (int64, error) {
 	countSql := "SELECT count(distinct user_id) FROM  public.cloudbrain"
 	return x.SQL(countSql).Count()
@@ -282,13 +288,4 @@ func GetRunHourPeriodCount(dateBeginTime string, dateEndTime string) (map[string
 		dateHourMap[strconv.Itoa(key)] = cout
 	}
 	return dateHourMap, nil
-	cloudBrainStatusResult := make(map[string]int)
-	for _, cloudbrain := range cloudbrains {
-		if _, ok := cloudBrainStatusResult[cloudbrain.Status]; !ok {
-			cloudBrainStatusResult[cloudbrain.Status] = 1
-		} else {
-			cloudBrainStatusResult[cloudbrain.Status] += 1
-		}
-	}
-	return cloudBrainStatusResult
 }

routers/api/v1/repo/cloudbrain_dashboard.go

@@ -26,6 +26,15 @@ type DateCloudbrainInfo struct {
 	CloudBrainPeriodNum       map[int]int    `json:"cloudBrainPeriodNum"`
 	CloudBrainComputeResource map[string]int `json:"cloudBrainComputeResource"`
 }
+type CloudbrainsStatusAnalysis struct {
+	JobWaitingCount   int64 `json:"jobWaitingCount"`
+	JobRunningCount   int64 `json:"jobRunningCount"`
+	JobStoppedCount   int64 `json:"jobStoppedCount"`
+	JobCompletedCount int64 `json:"jobCompletedCount"`
+	JobFailedCount    int64 `json:"jobFailedCount"`
+	JobKilledCount    int64 `json:"jobKilledCount"`
+	JobInitCount      int64 `json:"jobInitCount"`
+}
 
 func GetAllCloudbrainsOverview(ctx *context.Context) {
 	recordCloudbrain, err := models.GetRecordBeginTime()
@@ -43,6 +52,7 @@ func GetAllCloudbrainsOverview(ctx *context.Context) {
 		log.Error("Can not query todayCreatorCount.", err)
 		return
 	}
+	GetTodayCloudbrainCount
 	creatorCount, err := models.GetCreatorCount()
 	if err != nil {
 		log.Error("Can not query creatorCount.", err)
@@ -1138,14 +1148,6 @@ func getMonthCloudbrainInfo(beginTime time.Time, endTime time.Time) ([]DateCloud
 		count += 1
 	}
 	return dayCloudbrainInfo, count, nil
-type CloudbrainsStatusAnalysis struct {
-	JobWaitingCount   int64 `json:"jobWaitingCount"`
-	JobRunningCount   int64 `json:"jobRunningCount"`
-	JobStoppedCount   int64 `json:"jobStoppedCount"`
-	JobCompletedCount int64 `json:"jobCompletedCount"`
-	JobFailedCount    int64 `json:"jobFailedCount"`
-	JobKilledCount    int64 `json:"jobKilledCount"`
-	JobInitCount      int64 `json:"jobInitCount"`
 }
 
 func DownloadCloudBrainBoard(ctx *context.Context) {
@@ -1373,4 +1375,3 @@ func getCloudbrainTimePeroid(ctx *context.Context, recordBeginTime time.Time) (t
 
 	return beginTime, endTime, nil
 }
-