|
@@ -62,6 +62,12 @@ func GetETAReports(id int) (reports []ETAReport, err error) {
|
|
|
err = models.ETA().Table("report").Select(colunms+strings.Join(classifyIds, ",")).Where("state =? or state=?", published, passed).Where("id > ?", id).Order("id asc").Limit(limit).Find(&reports).Error
|
|
|
if reports != nil {
|
|
|
for i := 0; i < len(reports); i++ {
|
|
|
+ var date time.Time
|
|
|
+ date, err = time.Parse(time.DateTime, reports[i].PublishTime)
|
|
|
+ if err != nil {
|
|
|
+ logger.Error("时间转换错误:%v", err)
|
|
|
+ }
|
|
|
+ reports[i].PublishedTime = date
|
|
|
setClassifyIdValue(&reports[i])
|
|
|
}
|
|
|
}
|
|
@@ -72,9 +78,18 @@ func GetUpdateETAReports() (reports []ETAReport, err error) {
|
|
|
duration := time.Now().Add(-30 * time.Second)
|
|
|
modifyTime := duration.Format(time.DateTime)
|
|
|
err = models.ETA().Table("report").Select(colunms+strings.Join(classifyIds, ",")).Where("(state =? or state=?) and modify_time >=?", published, passed, modifyTime).Order("id asc").Find(&reports).Error
|
|
|
+ if err != nil {
|
|
|
+ logger.Error("同步eta研报数据失败:%v", err)
|
|
|
+ }
|
|
|
if reports != nil {
|
|
|
- for _, report := range reports {
|
|
|
- setClassifyIdValue(&report)
|
|
|
+ for i := 0; i < len(reports); i++ {
|
|
|
+ var date time.Time
|
|
|
+ date, err = time.Parse(time.DateTime, reports[i].PublishTime)
|
|
|
+ if err != nil {
|
|
|
+ logger.Error("时间转换错误:%v", err)
|
|
|
+ }
|
|
|
+ reports[i].PublishedTime = date
|
|
|
+ setClassifyIdValue(&reports[i])
|
|
|
}
|
|
|
}
|
|
|
return
|