diff --git a/application/init.go b/application/init.go index 760be25..b7ef118 100644 --- a/application/init.go +++ b/application/init.go @@ -15,6 +15,7 @@ import ( "go.uber.org/zap" "io" "log" + "time" "path/filepath" "strconv" @@ -232,7 +233,7 @@ func InitDebugSarama() (fn func(), err error) { func RefreshTableId() (fn func(), err error) { fn = func() { - go report.RefreshTableIdMap() + go report.RefreshTableIdMap(5*time.Minute) } return } diff --git a/platform-basic-libs/service/report/report_service.go b/platform-basic-libs/service/report/report_service.go index 7b9588c..9b8d6d8 100644 --- a/platform-basic-libs/service/report/report_service.go +++ b/platform-basic-libs/service/report/report_service.go @@ -22,9 +22,9 @@ type ReportService struct { var tableIdMap sync.Map -func RefreshTableIdMap() { +func RefreshTableIdMap(t time.Duration) { for { - time.Sleep(time.Minute * 10) + time.Sleep(t) tableIdMap.Range(func(key, value interface{}) bool { tableIdMap.Delete(key) return true @@ -32,10 +32,6 @@ func RefreshTableIdMap() { } } -func NewReportService() *ReportService { - return &ReportService{buff: bytes.Buffer{}} -} - func (this *ReportService) GetTableid(appid, appkey string) (table string, err error) { this.buff.Reset()