rdluck 4 years ago
parent
commit
05baff3a13
2 changed files with 9 additions and 6 deletions
  1. 4 3
      services/tactics.go
  2. 5 3
      services/task.go

+ 4 - 3
services/tactics.go

@@ -21,9 +21,9 @@ func SyncTacticsList() (err error) {
 	fmt.Println("同步数据")
 	indexName := "article_list"
 
-	//endDate := time.Now().AddDate(0, 0, -5).Format(utils.FormatDate)
-	//list, err := models.GetTacticsList(endDate)
-	list, err := models.GetTacticsListAll()
+	endDate := time.Now().AddDate(0, 0, -5).Format(utils.FormatDate)
+	list, err := models.GetTacticsList(endDate)
+	//list, err := models.GetTacticsListAll()
 	if err != nil {
 		fmt.Println("GetTacticsList Err:", err.Error())
 		return
@@ -54,6 +54,7 @@ func SyncTacticsList() (err error) {
 			return err
 		}
 
+		v.Body = strings.Replace(v.Body, "http://vmp.hzinsights.com", "https://vmp.hzinsights.com", -1)
 		expertNumStr, expertContentStr, interviewDateStr := BodyAnalysis(v.Body)
 		if count > 0 {
 			bodyText, _ := GetReportContentTextSub(v.Body)

+ 5 - 3
services/task.go

@@ -2,15 +2,17 @@ package services
 
 import (
 	"fmt"
+	"github.com/astaxie/beego/toolbox"
+
 	//"github.com/astaxie/beego/cache"
 )
 
 func Task() {
 	fmt.Println("start")
 	//同步数据
-	//syncTacticsList := toolbox.NewTask("syncTacticsList", "0 */5 * * * *", SyncTacticsList)
-	//toolbox.AddTask("syncTacticsList", syncTacticsList)
-	//toolbox.StartTask()
+	syncTacticsList := toolbox.NewTask("syncTacticsList", "0 */5 * * * *", SyncTacticsList)
+	toolbox.AddTask("syncTacticsList", syncTacticsList)
+	toolbox.StartTask()
 	//SyncTacticsList()
 	fmt.Println("end")
 }