OMC/be.ems
1
0
Fork 0
Code Issues Releases 3 Activity

feat: 更新导出cdr分页逻辑，1页最大条数为条件的总条数

Browse Source
This commit is contained in:
TsMask
2025-08-27 10:25:25 +08:00
parent 888b1095f7
commit 1429d35167
5 changed files with 16 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/modules/crontask/processor/backup_export_cdr/backup_export_cdr.go
View File

@@ -111,6 +111,7 @@ func (s BackupExportCDRProcessor) exportIMS(hour int, rmUID, fileType string) st
StartTime: start.UnixMilli(),
EndTime: end.UnixMilli(),
PageNum: 1,
PageSize: 1000_0000,
}
rows, total := s.imsCDREventService.SelectPage(query)
if total == 0 {
@@ -403,6 +404,7 @@ func (s BackupExportCDRProcessor) exportSMSC(hour int, rmUID, fileType string) s
StartTime: start.UnixMilli(),
EndTime: end.UnixMilli(),
PageNum: 1,
PageSize: 1000_0000,
}
rows, total := s.smscCDREventService.SelectPage(query)
if total == 0 {
@@ -622,6 +624,7 @@ func (s BackupExportCDRProcessor) exportSMF(hour int, rmUID, fileType string) st
StartTime: start.UnixMilli(),
EndTime: end.UnixMilli(),
PageNum: 1,
PageSize: 1000_0000,
}
rows, total := s.smfCDREventService.SelectPage(query)
if total == 0 {
@@ -1033,6 +1036,7 @@ func (s BackupExportCDRProcessor) exportSGWC(hour int, rmUID, fileType string) s
StartTime: start.UnixMilli(),
EndTime: end.UnixMilli(),
PageNum: 1,
PageSize: 1000_0000,
}
rows, total := s.sgwcCDREventService.SelectPage(query)
if total == 0 {

6
src/modules/network_data/repository/cdr_event_ims.go
View File

@@ -254,11 +254,11 @@ func (r CDREventIMS) SelectByPage(querys model.CDREventIMSQuery) ([]model.CDREve
tx = tx.Order(sortField)
}
if querys.PageSize == 0 {
querys.PageSize = total
}
// 查询数据分页
pageNum, pageSize := datasource.PageNumSize(querys.PageNum, querys.PageSize)
if pageNum == 0 && pageSize > int(total) {
pageSize = int(total)
}
tx = tx.Limit(pageSize).Offset(pageSize * pageNum)
err := tx.Find(&rows).Error
if err != nil {

6
src/modules/network_data/repository/cdr_event_sgwc.go
View File

@@ -63,11 +63,11 @@ func (r CDREventSGWC) SelectByPage(querys model.CDREventSGWCQuery) ([]model.CDRE
tx = tx.Order(sortField)
}
if querys.PageSize == 0 {
querys.PageSize = total
}
// 查询数据分页
pageNum, pageSize := datasource.PageNumSize(querys.PageNum, querys.PageSize)
if pageNum == 0 && pageSize > int(total) {
pageSize = int(total)
}
tx = tx.Limit(pageSize).Offset(pageSize * pageNum)
err := tx.Find(&rows).Error
if err != nil {

6
src/modules/network_data/repository/cdr_event_smf.go
View File

@@ -235,11 +235,11 @@ func (r CDREventSMF) SelectByPage(querys model.CDREventSMFQuery) ([]model.CDREve
tx = tx.Order(sortField)
}
if querys.PageSize == 0 {
querys.PageSize = total
}
// 查询数据分页
pageNum, pageSize := datasource.PageNumSize(querys.PageNum, querys.PageSize)
if pageNum == 0 && pageSize > int(total) {
pageSize = int(total)
}
tx = tx.Limit(pageSize).Offset(pageSize * pageNum)
err := tx.Find(&rows).Error
if err != nil {

6
src/modules/network_data/repository/cdr_event_smsc.go
View File

@@ -255,11 +255,11 @@ func (r CDREventSMSC) SelectByPage(querys model.CDREventSMSCQuery) ([]model.CDRE
tx = tx.Order(sortField)
}
if querys.PageSize == 0 {
querys.PageSize = total
}
// 查询数据分页
pageNum, pageSize := datasource.PageNumSize(querys.PageNum, querys.PageSize)
if pageNum == 0 && pageSize > int(total) {
pageSize = int(total)
}
tx = tx.Limit(pageSize).Offset(pageSize * pageNum)
err := tx.Find(&rows).Error
if err != nil {