|
@@ -13,7 +13,7 @@ import (
|
|
|
"time"
|
|
|
)
|
|
|
|
|
|
-//同步策略文章
|
|
|
+// 同步策略文章
|
|
|
func SyncTacticsList() (err error) {
|
|
|
defer func() {
|
|
|
if err != nil {
|
|
@@ -133,7 +133,7 @@ func SyncTacticsList() (err error) {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//同步策略文章
|
|
|
+// 同步策略文章
|
|
|
func SyncCygxArticleList() (err error) {
|
|
|
defer func() {
|
|
|
if err != nil {
|
|
@@ -180,7 +180,7 @@ func SyncCygxArticleList() (err error) {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//body 解析
|
|
|
+// body 解析
|
|
|
func BodyAnalysis(body string) (expertNumStr, expertContentStr, interviewDateStr string) {
|
|
|
body = html.UnescapeString(body)
|
|
|
doc, err := goquery.NewDocumentFromReader(strings.NewReader(body))
|
|
@@ -284,7 +284,7 @@ func BodyAnalysis(body string) (expertNumStr, expertContentStr, interviewDateStr
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//同步策略,报告文章
|
|
|
+// 同步策略,报告文章
|
|
|
func SyncTacticsListAddreport(cont context.Context) (err error) {
|
|
|
defer func() {
|
|
|
if err != nil {
|
|
@@ -520,7 +520,7 @@ func SyncTacticsListAddreport(cont context.Context) (err error) {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//同步策略到Es
|
|
|
+// 同步策略到Es
|
|
|
func SyncTacticsListToEs() (err error) {
|
|
|
defer func() {
|
|
|
if err != nil {
|
|
@@ -570,7 +570,7 @@ func SyncTacticsListToEs() (err error) {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//body 解析
|
|
|
+// body 解析
|
|
|
func BodyAnalysis2(body string) (expertNumStr, expertContentStr, interviewDateStr, fileLink, bodyReturn string) {
|
|
|
body = html.UnescapeString(body)
|
|
|
//fmt.Println(body)
|
|
@@ -737,6 +737,12 @@ func GetSummarytoEs(articleId int) (err error) {
|
|
|
fmt.Println("GetArticleAll Err:", err.Error())
|
|
|
return
|
|
|
}
|
|
|
+ if v == nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if v.IsSummary != 1 {
|
|
|
+ return
|
|
|
+ }
|
|
|
indexName := utils.IndexName
|
|
|
//for _, v := range allList {
|
|
|
content := html.UnescapeString(v.Body)
|