refactor stat code (#3)

Author: Argeric

cmd/stat.go

@@ -3,9 +3,9 @@ package cmd
 import (
 	"context"
 	"github.com/Conflux-Chain/go-conflux-util/viper"
-	"github.com/zero-gravity-labs/zerog-storage-scan/stat"
 	"github.com/sirupsen/logrus"
 	"github.com/spf13/cobra"
+	"github.com/zero-gravity-labs/zerog-storage-scan/stat"
 	"sync"
 )
 
@@ -34,14 +34,8 @@ func startStatService(*cobra.Command, []string) {
 	ctx, cancel := context.WithCancel(context.Background())
 	var wg sync.WaitGroup
 
-	stTx := stat.MustNewStatTx(&cfg, dataCtx.DB, dataCtx.Eth, startTime)
-	go stTx.DoStat(ctx, &wg)
 	stSubmit := stat.MustNewStatSubmit(&cfg, dataCtx.DB, dataCtx.Eth, startTime)
 	go stSubmit.DoStat(ctx, &wg)
-	stBasicCost := stat.MustNewStatBasicCost(&cfg, dataCtx.DB, dataCtx.Eth, startTime)
-	go stBasicCost.DoStat(ctx, &wg)
-	stUplinkRate := stat.MustNewUplinkRateStat(dataCtx.DB)
-	go stUplinkRate.DoStat(ctx, &wg)
 
 	GracefulShutdown(&wg, cancel)
 }

stat/stat_basic_cost.go

@@ -1,9 +1,9 @@
 package stat
 
 import (
-	"github.com/zero-gravity-labs/zerog-storage-scan/store"
 	"github.com/openweb3/web3go"
 	"github.com/pkg/errors"
+	"github.com/zero-gravity-labs/zerog-storage-scan/store"
 	"gorm.io/gorm"
 	"time"
 )
@@ -83,6 +83,7 @@ func (ts *StatSubmit) calculateStat(tr *TimeRange) error {
 	})
 }
 
+// TODO add stat for cost and cost total when refactor db domains
 func (ts *StatSubmit) statBasicRange(tr *TimeRange) (*store.SubmitStat, error) {
 	fileCount, dataSize, err := ts.Db.SubmitStore.Count(tr.start, tr.end)
 	if err != nil {
@@ -103,6 +104,7 @@ func (ts *StatSubmit) statBasicRange(tr *TimeRange) (*store.SubmitStat, error) {
 	}, nil
 }
 
+// TODO add stat for cost and cost total when refactor db domains
 func (ts *StatSubmit) statRange(rangEnd *time.Time, srcStatType, descStatType string, latestStat *store.SubmitStat) (*store.SubmitStat, error) {
 	rangeStart, err := ts.calStatRangeStart(rangEnd, descStatType)
 	if err != nil {