|
@@ -121,13 +121,13 @@ func InitEtaReportPushStatus() {
|
|
|
func InitPdfReportPushStatus() {
|
|
|
for {
|
|
|
maxId, err := models.GetMaxSyncIdReportPush(2)
|
|
|
- fmt.Println("同步研报开始, maxId:", maxId)
|
|
|
+ fmt.Println("同步pdf研报开始, maxId:", maxId)
|
|
|
if err != nil {
|
|
|
- fmt.Println("同步研报失败, Err:", err)
|
|
|
+ fmt.Println("同步研pdf报失败, Err:", err)
|
|
|
}
|
|
|
reportList, err := models.GetBatchPdfReport(maxId, 100)
|
|
|
if err != nil {
|
|
|
- fmt.Println("同步研报失败, Err:", err)
|
|
|
+ fmt.Println("同步pdf研报失败, Err:", err)
|
|
|
}
|
|
|
var reportIds []int
|
|
|
for _, v := range reportList {
|
|
@@ -169,7 +169,7 @@ func InitPdfReportPushStatus() {
|
|
|
return
|
|
|
}
|
|
|
if len(reportList) != 100 {
|
|
|
- fmt.Println("同步研报完成")
|
|
|
+ fmt.Println("同步pdf研报完成")
|
|
|
return
|
|
|
}
|
|
|
}
|