add: update export table task

This commit is contained in:
simonzhangsz committed 2024-09-06 14:58:02 +08:00
1 parent 83cd5fbd58
commit 13b322a038
5 files changed
+16 -5

No files matched your search

@@ -8,7 +8,7 @@ import (
"os"
"time"
"be.ems/lib/core/datasource"
"be.ems/lib/dborm"
"be.ems/lib/log"
"be.ems/src/framework/cron"
)
@@ -103,7 +103,7 @@ func (s *BarProcessor) Execute(data any) (any, error) {
}
func (s *BarProcessor) exportData(query, filePath string) (int64, error) {
rows, err := datasource.DefaultDB().DB().Query(query)
rows, err := dborm.XCoreDB().Query(query)
if err != nil {
return 0, err
}