|
@@ -391,6 +391,17 @@ func UpdateArticleByRedis() (err error) {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
+//func init() {
|
|
|
+// tiemStart := utils.StrTimeToTime("2025-01-01")
|
|
|
+// if time.Now().After(tiemStart) {
|
|
|
+// fmt.Println("同步")
|
|
|
+// }
|
|
|
+//}
|
|
|
+
|
|
|
+//func init() {
|
|
|
+// HandleArticleListByApi(12448)
|
|
|
+//}
|
|
|
+
|
|
|
// 处理同步过来的文章
|
|
|
func HandleArticleListByApi(artcleId int) (err error) {
|
|
|
defer func() {
|
|
@@ -474,10 +485,16 @@ func HandleArticleListByApi(artcleId int) (err error) {
|
|
|
} else if articleResult.Series.Name == "行业深度" {
|
|
|
cover = articleResult.Cover
|
|
|
}
|
|
|
- fmt.Println(cover)
|
|
|
+
|
|
|
+ var isSynchronous bool // 有些报告可以自定义同步,满足这个条件就同步过去
|
|
|
+ if articleResult.Series.Name == "周度首席说" && articleResult.PublishDate.After(utils.StrTimeToTime("2025-01-01")) {
|
|
|
+ isSynchronous = true
|
|
|
+ }
|
|
|
+ //fmt.Println("isSynchronous", isSynchronous)
|
|
|
+ //fmt.Println(cover)
|
|
|
//return
|
|
|
//状态等于 2 跟 4 的进行同步 IsActive 为false 软删除的也不同步
|
|
|
- if exitMap[articleResult.SeriesId] > 0 && (articleResult.PublishStatus == 2 || articleResult.PublishStatus == 4) && articleResult.IsActive {
|
|
|
+ if exitMap[articleResult.SeriesId] > 0 && (articleResult.PublishStatus == 2 || articleResult.PublishStatus == 4) && articleResult.IsActive || isSynchronous {
|
|
|
articleResult.PublishDate = time.Date(articleResult.PublishDate.Year(), articleResult.PublishDate.Month(), articleResult.PublishDate.Day(), articleResult.PublishDate.Hour(), articleResult.PublishDate.Minute(), articleResult.PublishDate.Second(), articleResult.PublishDate.Nanosecond(), time.Local)
|
|
|
item := new(models.Tactics2)
|
|
|
itemArticleData := new(models.CygxArticleData)
|