no message

services/article.go

@@ -6,7 +6,6 @@ import (
 	"errors"
 	"fmt"
 	"github.com/PuerkitoBio/goquery"
-	"github.com/beego/beego/v2/client/orm"
 	"hongze/hongze_cygx/models"
 	"hongze/hongze_cygx/models/company"
 	"hongze/hongze_cygx/utils"
@@ -17,34 +16,8 @@ import (
 	"strconv"
 	"strings"
 	"time"
-	"unicode/utf8"
 )
 
-func GetReportContentSub(content string) (contentSub string, err error) {
-	content = html.UnescapeString(content)
-	doc, err := goquery.NewDocumentFromReader(strings.NewReader(content))
-	if err != nil {
-		fmt.Println("create doc err:", err.Error())
-		return
-	}
-	n := 0
-	doc.Find("p").Each(func(i int, s *goquery.Selection) {
-		if n > 3 {
-			return
-		}
-		n++
-		phtml, err := s.Html()
-		if err != nil {
-			fmt.Println("get html err", err.Error())
-			return
-		}
-		if s.Text() != "" || strings.Contains(phtml, "src") {
-			contentSub = contentSub + "<p>" + phtml + "</p>"
-		}
-	})
-	return
-}
-
 func GetReportContentTextSub(content string) (contentSub string, err error) {
 	content = html.UnescapeString(content)
 	doc, err := goquery.NewDocumentFromReader(strings.NewReader(content))
@@ -78,233 +51,6 @@ func GetReportContentTextSubNew(content string) (contentSub string, err error) {
 	return
 }
 
-// GetReportContentTextSubByarticle 解析文章内容
-func GetReportContentTextSubByarticle(content, abstract string, articleId int) (contentSub string, err error) {
-	var lenabstract int
-	//如果不是研选就这么展示
-	if articleId < utils.SummaryArticleId {
-		abstract = html.UnescapeString(abstract)
-		doc, errdoc := goquery.NewDocumentFromReader(strings.NewReader(abstract))
-		if errdoc != nil {
-			err = errdoc
-			return
-		}
-		docabstract := doc.Text()
-		lenabstract = utf8.RuneCountInString(docabstract)
-		if lenabstract >= 20 {
-			contentSub = docabstract
-			return
-		} else {
-			contentSub, err = GetReportContentTextSubNew(content)
-		}
-	} else {
-		contentSub, err = GetReportContentTextSubNew(content)
-	}
-
-	return
-
-}
-
-// 解析文章内容
-func GetArticleAll() {
-	var err error
-	defer func() {
-		if err != nil {
-			fmt.Println("err:", err.Error())
-			return
-		}
-	}()
-	list, err := models.GetArticleAll()
-	if err != nil {
-		return
-	}
-	for _, v := range list {
-		fmt.Println(v.ArticleId, v.Title)
-		FixArticleContent(v.ArticleId)
-	}
-}
-
-// 解析报告
-func FixArticleContent(articleId int) {
-	item, err := models.GetArticleDetailById(articleId)
-	if err != nil {
-		fmt.Println("GetArticleDetailById Err:" + err.Error())
-		return
-	}
-	content := item.Body
-	bodyText, _ := GetReportContentTextSub(content)
-	content = html.UnescapeString(content)
-
-	content = strings.Replace(content, "http", "https", -1)
-
-	doc, err := goquery.NewDocumentFromReader(strings.NewReader(content))
-	if err != nil {
-		fmt.Println("create doc err:", err.Error())
-		return
-	}
-
-	var expertNumArr []string
-	var expertContentArr []string
-	var interviewDateArr []string
-
-	doc.Find("p").Each(func(i int, s *goquery.Selection) {
-		contentTxt := s.Text()
-		if strings.Contains(contentTxt, "#访谈时间：") || strings.Contains(contentTxt, "访谈时间：") {
-			interviewDate := s.Next().Text()
-			interviewDateArr = append(interviewDateArr, interviewDate)
-		}
-		if strings.Contains(contentTxt, "#专家评价") || strings.Contains(contentTxt, "专家评价") {
-			expertContent := s.Next().Text()
-			if expertContent == "" {
-				expertContent = contentTxt
-			}
-			if expertContent != "" {
-				rightIndex := strings.Index(expertContent, "）")
-				if rightIndex == 0 {
-					rightIndex = strings.Index(expertContent, ")")
-				}
-				if rightIndex > 0 {
-					expertNum := expertContent[:rightIndex]
-					expertNum = strings.Replace(expertNum, "（", "", -1)
-					expertNum = strings.Replace(expertNum, "(", "", -1)
-					expertNum = strings.Replace(expertNum, "专家评价", "", -1)
-					if expertNum != "" {
-						expertNumArr = append(expertNumArr, expertNum)
-						rightIndex = rightIndex
-						expertContentStr := expertContent[rightIndex:]
-						expertContentStr = strings.Replace(expertContentStr, "）", "", -1)
-						expertContentStr = strings.TrimLeft(expertContentStr, "：")
-						expertContentStr = strings.TrimRight(expertContentStr, "（推荐")
-						expertContentArr = append(expertContentArr, expertContentStr)
-					}
-				}
-			}
-		}
-	})
-
-	if len(expertContentArr) <= 0 {
-		doc.Find("pre").Each(func(i int, pre *goquery.Selection) {
-			pre.Find("span").Each(func(n int, span *goquery.Selection) {
-				contentTxt := span.Text()
-				if strings.Contains(contentTxt, "#专家评价") || strings.Contains(contentTxt, "专家评价") {
-					span.Find("span").Each(func(m int, subspan *goquery.Selection) {
-						subspanText := subspan.Text()
-						if strings.Contains(subspanText, "专家评价") {
-							expertContent := subspan.Next().Text()
-							if expertContent != "" {
-								rightIndex := strings.Index(expertContent, "）")
-								if rightIndex == 0 {
-									rightIndex = strings.Index(expertContent, ")")
-								}
-								if rightIndex > 0 {
-									expertNum := expertContent[:rightIndex]
-									expertNum = strings.Replace(expertNum, "（", "", -1)
-									expertNum = strings.Replace(expertNum, "(", "", -1)
-									expertNum = strings.Replace(expertNum, "专家评价", "", -1)
-									if expertNum != "" {
-										expertNumArr = append(expertNumArr, expertNum)
-										rightIndex = rightIndex
-										expertContentStr := expertContent[rightIndex:]
-										expertContentStr = strings.Replace(expertContentStr, "）", "", -1)
-										expertContentStr = strings.TrimLeft(expertContentStr, "：")
-										expertContentStr = strings.TrimRight(expertContentStr, "（推荐")
-										expertContentArr = append(expertContentArr, expertContentStr)
-									}
-								}
-							}
-						}
-
-					})
-				}
-
-				span.Find("span").Each(func(k int, sspan *goquery.Selection) {
-					sspanText := sspan.Text()
-					if strings.Contains(sspanText, "访谈时间") {
-						sspanText = strings.Replace(sspanText, "#访谈时间：", "", -1)
-						sspanText = strings.Replace(sspanText, "访谈时间：", "", -1)
-						sspanText = strings.Replace(sspanText, "\n", "", -1)
-						sspanText = strings.Replace(sspanText, " ", "", -1)
-						sspanText = strings.Trim(sspanText, " ")
-						sspanText = sspanText[:10]
-						interviewDate := sspanText
-						if interviewDate != "" {
-							interviewDateArr = append(interviewDateArr, interviewDate)
-						}
-					}
-				})
-			})
-		})
-	}
-
-	if len(expertContentArr) <= 0 {
-		doc.Find("span").Each(func(i int, span *goquery.Selection) {
-			span.Find("strong").Each(func(n int, strong *goquery.Selection) {
-				spanText := span.Text()
-				strongText := strong.Text()
-				if strings.Contains(strongText, "#专家评价") || strings.Contains(strongText, "专家评价") {
-					expertContent := strong.Parents().Text()
-					if expertContent != "" {
-						rightIndex := strings.Index(expertContent, "）")
-						if rightIndex == 0 {
-							rightIndex = strings.Index(expertContent, ")")
-						}
-						if rightIndex > 0 {
-							expertNum := expertContent[:rightIndex]
-							expertNum = strings.Replace(expertNum, "（", "", -1)
-							expertNum = strings.Replace(expertNum, "(", "", -1)
-							expertNum = strings.Replace(expertNum, "专家评价", "", -1)
-							expertNum = strings.Replace(expertNum, "#", "", -1)
-							expertNum = strings.Replace(expertNum, "：", "", -1)
-							expertNum = strings.Replace(expertNum, "\n", "", -1)
-							if expertNum != "" {
-								expertNumArr = append(expertNumArr, expertNum)
-								rightIndex = rightIndex
-								expertContentStr := expertContent[rightIndex:]
-								expertContentStr = strings.Replace(expertContentStr, "）", "", -1)
-								expertContentStr = strings.TrimLeft(expertContentStr, "：")
-								expertContentStr = strings.TrimRight(expertContentStr, "（推荐")
-								expertContentArr = append(expertContentArr, expertContentStr)
-								return
-							}
-						}
-					}
-				}
-
-				if strings.Contains(spanText, "访谈时间") {
-					spanText = strings.Replace(spanText, "#访谈时间：", "", -1)
-					spanText = strings.Replace(spanText, "访谈时间：", "", -1)
-					spanText = strings.Replace(spanText, "\n", "", -1)
-					spanText = strings.Replace(spanText, " ", "", -1)
-					spanText = strings.Trim(spanText, " ")
-					spanText = spanText[:10]
-					interviewDate := spanText
-					if interviewDate != "" {
-						interviewDateArr = append(interviewDateArr, interviewDate)
-					}
-				}
-			})
-		})
-	}
-
-	var expertNumStr, expertContentStr, interviewDateStr string
-	if len(expertNumArr) > 0 {
-		expertNumStr = expertNumArr[0]
-	}
-	if len(expertContentArr) > 0 {
-		expertContentStr = expertContentArr[0]
-	}
-
-	if len(interviewDateArr) > 0 {
-		interviewDateStr = interviewDateArr[0]
-	}
-	expertNumStr = strings.Replace(expertNumStr, "#：", "", -1)
-	err = models.ModifyArticleExpert(articleId, expertNumStr, expertContentStr, interviewDateStr, bodyText)
-	if err != nil {
-		fmt.Println("ModifyArticleExpert Err:" + err.Error())
-		return
-	}
-}
-
 func FixArticleImgUrl(body string) (contentSub string, err error) {
 	r := strings.NewReader(string(body))
 	doc, err := goquery.NewDocumentFromReader(r)
@@ -321,21 +67,6 @@ func FixArticleImgUrl(body string) (contentSub string, err error) {
 	return
 }
 
-// 获取标签里的第一个内容
-func FixArticleFirstCount(body string) (contentSub string, err error) {
-
-	doc, err := goquery.NewDocumentFromReader(strings.NewReader(body))
-	if err != nil {
-		fmt.Println("create doc err:", err.Error())
-		return
-	}
-	doc.Find("p").Each(func(i int, s *goquery.Selection) {
-		contentTxt := s.Text()
-		fmt.Println(contentTxt)
-	})
-	return
-}
-
 func SynchronizationArtclehistory() {
 	fmt.Println("同步开始")
 	list, err := models.GetArticleHistoryList()
@@ -371,138 +102,6 @@ func SynchronizationArtclehistory() {
 	fmt.Println("同步结束")
 }
 
-// 统计报表
-func StatisticalReport() {
-	var isSummaryNumAll, isClassNum, pvNumAll, uvNumAll int
-	list, err := models.GetChartPermissionActivity()
-	if err != nil {
-		fmt.Println("获取列表失败", err)
-	}
-	for _, v := range list {
-		var listPv []*models.ReportMappingStatistical
-		if v.PermissionName == "研选" {
-			listPv, err = models.GetStatisticalReportArtilceExpert()
-			if err != nil {
-				fmt.Println("获取Pv列表失败", err)
-			}
-		} else {
-			listPv, err = models.GetStatisticalReportArtilce(v.ChartPermissionId)
-			if err != nil {
-				fmt.Println("获取Pv列表失败", err)
-			}
-		}
-		var pvNum, uvNum, isSummaryNum int
-		for _, v2 := range listPv {
-			pvNum += v2.Pv
-			uvNum += v2.Uv
-			if v2.IsSummary == "1" {
-				isSummaryNum += 1
-			}
-			if v2.IsClass == "1" && v.ChartPermissionId <= 22 {
-				isClassNum += 1
-			}
-			if v2.IsSummary == "1" && v.ChartPermissionId <= 22 {
-				isSummaryNumAll += 1
-			}
-		}
-		if v.ChartPermissionId <= 22 {
-			pvNumAll += pvNum
-			uvNumAll += uvNum
-		}
-		fmt.Println(v.PermissionName+"行业", len(listPv), "篇，其中主观类报告", isSummaryNum, "篇，客观类报告", len(listPv)-isSummaryNum, "篇。共产生阅读量pv-,", pvNum, "，uv-", uvNum)
-	}
-	fmt.Println("目前同步四大行业的总报告（已归类）数量", isClassNum, "篇，其中主观类报告", isSummaryNumAll, "篇，客观类报告", isClassNum-isSummaryNumAll, "篇。共产生阅读量pv-", pvNumAll, "，uv-", uvNumAll)
-	var totalOnline int        //线上
-	var totalOffline int       //线下
-	var totalPeople int        //共累计预约外呼人数
-	var totalSignUpOff int     //线下报名人数
-	var totalSignUpOffTime int //线下报名人数
-	var totalPeopleMeet int    //线下参会人数
-	o := orm.NewOrm()
-	sql := `SELECT COUNT(1) FROM cygx_activity WHERE activity_type_id IN (1,2,3) AND publish_status = 1 AND is_submit_meeting = 1 AND activity_time <= NOW();`
-	err = o.Raw(sql).QueryRow(&totalOnline)
-	if err != nil {
-		fmt.Println("获取线上", err)
-	}
-	sql = `SELECT COUNT(1) FROM cygx_activity WHERE activity_type_id IN (4,5,6) AND publish_status = 1 AND is_submit_meeting = 1 	AND activity_time <= NOW();`
-	err = o.Raw(sql).QueryRow(&totalOffline)
-	if err != nil {
-		fmt.Println("获取线下", err)
-	}
-	sql = `SELECT COUNT( 1 ) FROM
-			cygx_activity_signup  as s 
-			INNER JOIN cygx_activity as a ON  a.activity_id = s.activity_id
-		WHERE
-			s.do_fail_type = 0
-			AND a.is_submit_meeting = 1
-			AND a.activity_time <= NOW()
-			AND a.publish_status = 1`
-	err = o.Raw(sql).QueryRow(&totalPeople)
-	if err != nil {
-		fmt.Println("共累计预约外呼人数", err)
-	}
-
-	sql = `SELECT COUNT( 1 ) FROM
-			cygx_activity_signup  as s 
-			INNER JOIN cygx_activity as a ON  a.activity_id = s.activity_id
-		WHERE
-			s.do_fail_type = 0
-			AND a.is_submit_meeting = 1
-			AND a.activity_time <= NOW()
-			AND a.activity_type_id IN (4,5,6)
-			AND a.publish_status = 1`
-	err = o.Raw(sql).QueryRow(&totalSignUpOff)
-	if err != nil {
-		fmt.Println("共累计预约外呼人数", err)
-	}
-
-	sql = `SELECT COUNT( 1 ) FROM
-			cygx_activity_signup  as s 
-			INNER JOIN cygx_activity as a ON  a.activity_id = s.activity_id
-		WHERE
-			s.do_fail_type = 0
-			AND a.publish_status = 1
-			AND a.is_submit_meeting = 1
-			AND a.activity_time <= NOW()
-			AND a.is_submit_meeting = 1
-			AND a.activity_type_id IN (4,5,6);`
-	err = o.Raw(sql).QueryRow(&totalSignUpOffTime)
-	if err != nil {
-		fmt.Println("线下报名参会人数", err)
-	}
-
-	sql = `SELECT COUNT( 1 ) FROM
-			cygx_activity_signup  as s 
-			INNER JOIN cygx_activity as a ON  a.activity_id = s.activity_id
-		WHERE
-			s.do_fail_type = 0
-			AND a.is_submit_meeting = 1
-			AND a.activity_time <= NOW()
-			AND a.publish_status = 1
-			AND s.is_meeting = 1
-			AND a.activity_type_id IN (4,5,6);`
-	err = o.Raw(sql).QueryRow(&totalPeopleMeet)
-	if err != nil {
-		fmt.Println("线下参会人数", err)
-	}
-
-	fmt.Println("共上线活动", totalOnline+totalOffline, "个，其中线上", totalOnline, "个，线下", totalOffline, "个")
-	fmt.Println("共累计预约外呼人数", totalPeople, "人")
-	fmt.Println("报名线下参会", totalSignUpOff, "人，实际到会人数", totalPeopleMeet, "人，线下到会率约", totalPeopleMeet*100/totalSignUpOff, "%")
-
-	num := totalPeopleMeet / totalSignUpOffTime
-	fmt.Println(num)
-	fmt.Println(totalOnline)
-	fmt.Println(totalOffline)
-	fmt.Println(totalPeople)
-	fmt.Println(totalSignUpOff)
-	fmt.Println(totalPeopleMeet)
-	fmt.Println(totalSignUpOffTime)
-	fmt.Println(totalPeopleMeet / totalSignUpOffTime)
-	return
-
-}
-
 // UserViewRedisData 阅读数据
 type UserViewRedisData struct {
 	Mobile          string `json:"mobile"`
@@ -572,16 +171,6 @@ func PushViewRecordNewRedisData(reportViewRecord *ReportViewRecord, companyId in
 	return false
 }
 
-//func GetCeLueArticlePv() {
-//	sum := 0
-//	for i := 0; i <= 450; i++ {
-//		if i >= 102 {
-//			//GetCeLueArticlePvs(strconv.Itoa(i * 1000))
-//		}
-//	}
-//	fmt.Println(sum)
-//}
-
 // 获取策略平台报告阅读数据
 func GetCeLueArticlePv(cont context.Context) (err error) {
 	//func GetCeLueArticlePv() (err error) {
@@ -803,22 +392,6 @@ func UpdateArticleByRedis() (err error) {
 	}
 }
 
-//func init() {
-//	// allList, err := models.GetArticleAll()
-//	//
-//	// fmt.Println(err)
-//	//
-//	//	for _, v := range allList {
-//	//		HandleArticleListByApi(v.ArticleId)
-//	//	}
-//
-//	//for i := 8648; i < 9004; i++ {
-//	//	HandleArticleListByApi(9552)
-//	//}
-//	HandleArticleListByApi(10914)
-//	//UpdateArticleResourceData(9551)
-//}
-
 // 处理同步过来的文章
 func HandleArticleListByApi(artcleId int) (err error) {
 	defer func() {
@@ -1805,58 +1378,6 @@ func GetSpecialArticleDetailUserPower(user *models.WxUserItem, articleInfo *mode
 	return
 }
 
-//func init() {
-//	GetArticNewLabelWhithActivity3Month()
-//}
-
-// 弘则报告发布日期在三个月以内的
-func GetArticNewLabelWhithActivity3Month() (labelMap map[int]bool, err error) {
-	var condition string
-	var pars []interface{}
-	condition += ` AND publish_date  <= ?  AND article_id < ? `
-	pars = append(pars, time.Now().AddDate(0, -3, 0), utils.SummaryArticleId)
-	articleList, e := models.GetArticleList(condition, pars)
-	if e != nil {
-		err = errors.New("GetArticleList, Err: " + e.Error())
-		return
-	}
-	var articleIds []int
-	for _, v := range articleList {
-		articleIds = append(articleIds, v.ArticleId)
-	}
-	if len(articleIds) == 0 {
-		return
-	}
-
-	pars = make([]interface{}, 0)
-	condition = ` AND article_id IN (` + utils.GetOrmInReplace(len(articleIds)) + `)`
-	pars = append(pars, articleIds)
-	industrialList, e := models.GetIndustrialArticleGroupManagementList(condition, pars)
-	if e != nil {
-		err = errors.New("GetIndustrialArticleGroupManagementList, Err: " + e.Error())
-		return
-	}
-	labelMap = make(map[int]bool, 0)
-	var industrialIds []int
-	for _, v := range industrialList {
-		industrialIds = append(industrialIds, v.IndustrialManagementId)
-	}
-	// 获取活动关联的产业
-	var groupCond string
-	var groupPars []interface{}
-	groupCond += ` AND b.industrial_management_id IN (` + utils.GetOrmInReplace(len(industrialIds)) + `)  AND b.source = 1  `
-	groupPars = append(groupPars, industrialIds)
-	groups, e := models.GetActivityIndustryRelationList(groupCond, groupPars)
-	if e != nil {
-		err = errors.New("获取活动产业关联列表失败, Err: " + e.Error())
-		return
-	}
-	for _, v := range groups {
-		labelMap[v.ActivityId] = true
-	}
-	return
-}
-
 // HandleArticleCategoryImg 预处理文章的封面图片
 func HandleArticleCategoryImg(list []*models.HomeArticle) (items []*models.HomeArticle, err error) {
 	//研选的五张图片
@@ -2075,12 +1596,6 @@ func ArticleAnnotation(item *models.HomeArticle) (annotation string) {
 	return
 }
 
-//func init() {
-//	strss := AnnotationHtml("")
-//
-//	fmt.Println(strss)
-//}
-
 // 处理核心观点的展示规则
 func AnnotationHtml(bodyText string) (annotation string) {
 	if bodyText == "" {
@@ -2402,841 +1917,3 @@ func GetYxArticleIdMap(articleIds []int) (mapResp map[int]bool) {
 	}
 	return
 }
-
-//func init() {
-//
-//	//listarticle, err := models.GetArticleInit13_5()
-//	//fmt.Println(err)
-//	//fmt.Println("listarticle", len(listarticle))
-//	//
-//	//for _, v := range listarticle {
-//	//	HandleArticleListByApiInit13_5(v.ArticleId)
-//	//}
-//	//HandleArticleListByApiInit13_5(10825)
-//
-//	listarticle, err := models.GetArticleInit13_5GuSHou()
-//	fmt.Println(err)
-//	fmt.Println("listarticle", len(listarticle))
-//
-//	for _, v := range listarticle {
-//		HandleArticleListByApiInit13_5GuShou(v.ArticleId)
-//	}
-//
-//}
-
-// 处理同步过来的文章
-func HandleArticleListByApiInit13_5(artcleId int) (err error) {
-	defer func() {
-		if err != nil {
-			go utils.SendAlarmMsg("处理同步策略平台数据失败"+"GetArticleListByApi ErrMsg:"+err.Error()+"artcleId："+strconv.Itoa(artcleId), 2)
-			go utils.SendEmail(utils.APPNAME+"【"+utils.RunMode+"】"+"失败提醒", "GetArticleListByApi ErrMsg:"+err.Error()+"artcleId："+strconv.Itoa(artcleId), utils.EmailSendToUsers)
-		}
-	}()
-	var clueApiUrl string
-	clueApiUrl = fmt.Sprint(utils.ApiUrl, "articles/", artcleId)
-	fmt.Println(clueApiUrl)
-
-	authorization := utils.ApiAuthorization
-	body, err := PublicGetDate(clueApiUrl, authorization)
-	if err != nil {
-		fmt.Println(err)
-		return
-	}
-	var articleResultDate models.ArticleDetailResultApi
-	err = json.Unmarshal(body, &articleResultDate)
-	if err != nil {
-		fmt.Println("Getres.PublicGetDate Err:", err.Error())
-		return err
-	}
-	item := new(models.CygxShanghaiCompanyLog)
-	item.CreateTime = time.Now()
-	item.Url = clueApiUrl
-	item.Body = ""
-	item.Result = string(body)
-
-	articleResult := articleResultDate.Data
-
-	exitMap := make(map[int]int)
-	categoryIdMap := make(map[int]int)
-	classMap := make(map[int]int)
-	reportMap := make(map[int]int)
-	summaryMap := make(map[int]int)
-	listMap, err := models.GetArticleApiMap()
-	if err != nil {
-		fmt.Println("GetlistMap Err:", err.Error())
-		return err
-	}
-
-	//新旧分类 反向隐射,是否归类,是否是报告,是否是纪要库
-	for _, v := range listMap {
-		exitMap[v.SeriesId] = v.OldId
-		categoryIdMap[v.SeriesId] = v.OldIdMap
-		if v.IsClass == 1 {
-			classMap[v.OldId] = 1
-		}
-		if v.IsReport == 1 {
-			reportMap[v.OldId] = 1
-		}
-		if v.IsSummary == 1 {
-			summaryMap[v.OldId] = 1
-		}
-	}
-	var list []*models.Tactics2
-	var listArticleData []*models.CygxArticleData
-	var listAuthor []*models.CygxArticleAuthor
-	//如果是英文报告 ,或者香港类型那么则不同步  publish_area   ：all  全部  ;hk 香港
-	if articleResult.TypeId == 9 || articleResult.PublishArea != "all" {
-		// 如果是英文报告，或者是香港报告就进行删除处理
-		err = models.UpdateArticlePublish(artcleId, 0)
-		if err != nil {
-			fmt.Println("UpdateArticlePublish Err:", err.Error())
-			return err
-		}
-		UpdateArticleResourceData(artcleId) //把数据写入 cygx_resource_data 表
-		return
-	}
-
-	var cover string
-	if articleResult.Series.Name == "图解市场" {
-		cover = GetArticleCoverByChartFirst(articleResult.Content.Body)
-	} else if articleResult.Series.Name == "行业深度" {
-		cover = articleResult.Cover
-	}
-	fmt.Println(cover)
-	//return
-	//状态等于 2 跟 4 的进行同步 IsActive 为false 软删除的也不同步
-	if exitMap[articleResult.SeriesId] > 0 && (articleResult.PublishStatus == 2 || articleResult.PublishStatus == 4) && articleResult.IsActive {
-		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)
-		itemArticleData.ArticleId = articleResult.ArticleId
-		itemArticleData.Cover = articleResult.Cover
-		itemArticleData.CreateTime = time.Now()
-		listArticleData = append(listArticleData, itemArticleData)
-		itemAuthor := new(models.CygxArticleAuthor)
-		item.ArticleId = articleResult.ArticleId
-		item.Title = articleResult.Title
-		item.TitleEn = articleResult.TitleEn
-		item.File = articleResult.File
-		if articleResult.Frequency == "日度" {
-			item.UpdateFrequency = "daily"
-		} else if articleResult.Frequency == "周度" {
-			item.UpdateFrequency = "weekly"
-		} else if articleResult.Frequency == "月度" {
-			item.UpdateFrequency = "monthly"
-		} else if articleResult.Frequency == "季度" {
-			item.UpdateFrequency = "quarterly"
-		} else if articleResult.Frequency == "年度" {
-			item.UpdateFrequency = "yearly"
-		} else {
-			item.UpdateFrequency = "unknow"
-		}
-		item.CreateDate = articleResult.CreateDate
-		item.PublishDate = articleResult.PublishDate.Add(time.Hour * 8)
-		item.PublishStatus = 1
-		item.Body = articleResult.Content.Body
-		item.Abstract = articleResult.Content.Abstract
-		item.Annotation = articleResult.Content.Annotation
-		item.CategoryName = articleResult.Industry.Name
-		item.CategoryId = categoryIdMap[articleResult.SeriesId]
-		item.CategoryIdTwo = exitMap[articleResult.SeriesId]
-		item.SubCategoryName = articleResult.Series.Name
-		item.Cover = cover
-
-		fmt.Println("item.CategoryIdTwo", item.CategoryIdTwo)
-		fmt.Println("item.CategoryId", item.CategoryId)
-
-		{
-			//这两种情况特殊处理
-			if articleResult.Field.Name == "宏观利率" {
-				item.CategoryId = 10070
-				item.CategoryIdTwo = item.CategoryId
-			}
-			if articleResult.Field.Name == "信用" {
-				item.CategoryId = 10082
-				item.CategoryIdTwo = item.CategoryId
-			}
-		}
-
-		if len(articleResult.Stock) > 0 {
-			var stock string
-			for _, vS := range articleResult.Stock {
-				stock += vS + "/"
-			}
-			stock = strings.TrimRight(stock, "/")
-			item.Stock = stock
-		}
-		item.FieldName = articleResult.Field.Name
-		item.TypeName = articleResult.Type.Name
-		item.UpdateDate = articleResult.UpdateDate
-		item.CeLueFieldId = articleResult.Field.Id
-		list = append(list, item)
-		itemAuthor.ArticleId = articleResult.ArticleId
-		itemAuthor.Name = articleResult.Author.Name
-		itemAuthor.Mobile = articleResult.Author.PhoneNumber
-		fmt.Println(articleResult.Cover)
-		listAuthor = append(listAuthor, itemAuthor)
-	} else {
-		// 如果这篇文章没有发布，那么就不作处理。
-		err = models.UpdateArticlePublish(artcleId, 0)
-		if err != nil {
-			fmt.Println("UpdateArticlePublish Err:", err.Error())
-			return err
-		}
-		UpdateArticleResourceData(artcleId) //把数据写入 cygx_resource_data 表
-		//go UpdateResourceData(artcleId, "article", "delete", time.Now().Format(utils.FormatDateTime))
-		return
-	}
-
-	fmt.Println("同步文章条数：", len(list))
-	listCustomArticle, err := models.GetCustomArticleId() //手动归类的文章，不替换文章类型
-	if err != nil {
-		fmt.Println("GetTacticsList Err:", err.Error())
-		return err
-	}
-	listGetMatchTypeName, errMatch := models.GetMatchTypeNamenNotNull() //手动归类的文章，不替换文章类型
-	if errMatch != nil {
-		fmt.Println("GetTacticsList Err:", errMatch.Error())
-		return err
-	}
-	//mapCategoryIdSet := make(map[int]int)
-	//for _, vMatch := range listGetMatchTypeName {
-	//	mapCategoryIdSet[vMatch.CategoryId] = vMatch.CategoryIdSet
-	//}
-	fmt.Println("list len:", len(list))
-	noSummaryArticleIds := "" //非纪要库类型的文章ID
-	listNoSummaryArticleIds := strings.Split(noSummaryArticleIds, ",")
-	for k, v := range list {
-		//同步匹配类型
-		matchTypeName := ""
-		for _, vMatch := range listGetMatchTypeName {
-			if v.CategoryId == vMatch.CategoryId {
-				matchTypeName = vMatch.MatchTypeName
-			}
-		}
-		//是否属于纪要库的数据
-		//if _, has := summaryMap[v.CategoryId]; has {
-		//	v.IsSummary = 1
-		//}
-		if v.TypeName == "纪要" {
-			v.IsSummary = 1
-		}
-		//排除不属于纪要库类型的文章
-		for _, vArt := range listNoSummaryArticleIds {
-			vArtInt, _ := strconv.Atoi(vArt)
-			if v.ArticleId == vArtInt {
-				v.IsSummary = 0
-			}
-		}
-		if _, has := reportMap[v.CategoryIdTwo]; has {
-			v.IsReport = 1
-			if _, ok := classMap[v.CategoryIdTwo]; ok {
-				v.IsClass = 1
-				v.ReportType = 1 //是否属于行业报告
-			} else {
-				v.ReportType = 2 //是否属于产业报告
-			}
-		}
-		v.Department = "弘则权益研究"
-		//判断是否已经存在
-		if v.ArticleId < 0 {
-			fmt.Println("AddCygxArticle Err:")
-			return err
-		}
-		var count int
-		count, err = models.GetArticleCountById(v.ArticleId)
-		if err != nil && err.Error() != utils.ErrNoRow() {
-			fmt.Println("AddCygxArticle Err:", err.Error())
-			return err
-		}
-		v.Body = strings.Replace(v.Body, "http://vmp.hzinsights.com", "https://vmp.hzinsights.com", -1)
-		expertNumStr, expertContentStr, interviewDateStr, _, bodyReturn := BodyAnalysis2(v.Body)
-		if strings.Index(v.Body, "报告全文（") > 0 && strings.Index(v.Body, "PDF格式报告下载.pdf") > 0 {
-			v.Body = strings.Replace(v.Body, "报告全文（", "", -1)
-			v.Body = strings.Replace(v.Body, "PDF格式报告下载.pdf", "", -1)
-			v.Body = strings.Replace(v.Body, "）：", "", -1)
-		}
-		var titleNew string
-		titleNew = v.Title
-		// 7资金流向 、11大类资产 、51每日复盘 、80医药周报、9估值研究
-		if v.CategoryId == 7 || v.CategoryId == 11 || v.CategoryId == 51 || v.CategoryId == 9 {
-			if v.UpdateFrequency == "daily" {
-				var daystr string
-				daystr = strconv.Itoa(v.PublishDate.Day())
-				if len(daystr) == 1 {
-					daystr = "0" + daystr
-				}
-				titleNew = v.Title + "(" + strconv.Itoa(v.PublishDate.Year())[2:len(strconv.Itoa(v.PublishDate.Year()))-0] + v.PublishDate.Format("01") + daystr + ")"
-			} else if v.UpdateFrequency == "weekly" {
-				titleNew = v.Title + utils.WeekByDate(v.PublishDate)
-			}
-		}
-		if v.CategoryId == 80 {
-			titleNew = v.Title + utils.WeekByDate(v.PublishDate)
-		}
-
-		//类型是综述报告的，不区分是什么系列，统一归类到对应产业的路演精华
-		if articleResult.Type.Name == "综述报告" {
-			detailCategory, err := models.GetdetailByCategoryIdLyjh(v.CategoryIdTwo)
-			if err != nil && err.Error() != utils.ErrNoRow() {
-				return err
-			}
-			v.CategoryId = detailCategory.CategoryId
-			v.IsSummary = 0
-		}
-
-		if count > 0 {
-			fmt.Println(k, v.ArticleId, "edit")
-
-			bodyText, _ := GetReportContentTextSubNew(v.Body)
-
-			var isCustom bool
-			updateParams := make(map[string]interface{})
-			//updateParams["Title"] = v.Title
-			updateParams["Title"] = titleNew
-			updateParams["TitleEn"] = v.TitleEn
-			updateParams["UpdateFrequency"] = v.UpdateFrequency
-			updateParams["CreateDate"] = v.CreateDate
-			updateParams["PublishDate"] = v.PublishDate
-			//updateParams["Body"] = html.EscapeString(v.Body)
-			updateParams["Body"] = html.EscapeString(bodyReturn)
-			updateParams["BodyText"] = bodyText
-			updateParams["Abstract"] = html.EscapeString(v.Abstract)
-			updateParams["CategoryName"] = v.CategoryName
-			for _, vCustom := range listCustomArticle {
-				if v.ArticleId == vCustom.ArticleId {
-					fmt.Println("手动归类的文章:" + strconv.Itoa(v.ArticleId))
-					isCustom = true
-				}
-			}
-			if isCustom == false {
-				updateParams["CategoryId"] = v.CategoryId
-				updateParams["MatchTypeName"] = matchTypeName
-				updateParams["IsSummary"] = v.IsSummary
-				updateParams["IsReport"] = v.IsReport
-				updateParams["ReportType"] = v.ReportType
-				updateParams["SubCategoryName"] = v.SubCategoryName
-			}
-			//updateParams["CategoryId"] = v.CategoryId
-			updateParams["PublishStatus"] = 1
-			updateParams["ExpertBackground"] = expertContentStr
-			updateParams["ExpertNumber"] = expertNumStr
-			updateParams["InterviewDate"] = interviewDateStr
-			//updateParams["IsClass"] = v.IsClass
-			v.Department = "弘则权益研究"
-			updateParams["Department"] = v.Department
-			updateParams["FileLink"] = v.File
-			updateParams["Stock"] = v.Stock
-			updateParams["FieldName"] = v.FieldName
-			updateParams["Annotation"] = v.Annotation
-			updateParams["TypeName"] = v.TypeName
-			updateParams["ModifyTimeByCl"] = v.UpdateDate
-			updateParams["CeLueFieldId"] = v.CeLueFieldId
-			updateParams["Cover"] = v.Cover
-			//whereParam := map[string]interface{}{"article_id": v.ArticleId}
-			//err = models.UpdateByExpr(models.CygxArticle{}, whereParam, updateParams)
-			//if err != nil {
-			//	fmt.Println("UpdateByExpr Err:" + err.Error())
-			//	return err
-			//}
-			fmt.Println("v.ReportType", v.ReportType)
-
-			//if v.ReportType == 2 {
-			var subjectStr string
-			var industrialManagementIdStr string
-			var industrialSubjectIdStr string
-
-			sliceSubjects := strings.Split(v.Stock, "/")
-			mapManagementForSubject := make(map[string]string)
-			mapIndustrialId := make(map[int]int)
-			if len(sliceSubjects) > 0 {
-				for _, vSubject := range sliceSubjects {
-					sliceKuohao := strings.Split(vSubject, "(")           //过滤括号
-					sliceXiahuaxian := strings.Split(sliceKuohao[0], "-") //过滤下划线
-					subject := sliceXiahuaxian[0]
-					subjectStr += "'" + subject + "',"
-				}
-				//获取该产业下所对应的行业图片
-				detailCategory, errCategory := models.GetdetailByCategoryIdOne(v.CategoryId)
-				if errCategory != nil {
-					fmt.Println("GetdetailByCategoryIdOne Err:", err.Error())
-					return err
-				}
-				subjectStr = strings.TrimRight(subjectStr, ",")
-				if subjectStr != "" {
-					listIndustrial, err := models.GetIndustrialManagementForSubjecName(subjectStr, detailCategory.ChartPermissionId)
-					if err != nil {
-						fmt.Println("GetIndustrialManagementForSubjecName Err:", err.Error())
-						return err
-					}
-					subjectStr = strings.Replace(subjectStr, "','", "】【", -1)
-					subjectStr = strings.Replace(subjectStr, "'", "", -1)
-					subjectStr = "【" + subjectStr + "】"
-					if len(listIndustrial) > 0 {
-						for _, vIndustrial := range listIndustrial {
-							if _, ok := mapIndustrialId[vIndustrial.IndustrialManagementId]; !ok {
-								industrialManagementIdStr += strconv.Itoa(vIndustrial.IndustrialManagementId) + ","
-							}
-							mapIndustrialId[vIndustrial.IndustrialManagementId] = vIndustrial.IndustrialManagementId
-							industrialSubjectIdStr += strconv.Itoa(vIndustrial.IndustrialSubjectId) + ","
-							mapManagementForSubject[vIndustrial.IndustryName] += vIndustrial.SubjectName + "/"
-							if vIndustrial.LayoutTime == "0000-00-00 00:00:00" {
-								go models.UpdateIndustrialManagementLayoutTime(v.PublishDate.AddDate(0, 0, -10).Format(utils.FormatDateTime), vIndustrial.IndustrialManagementId)
-							}
-						}
-
-						industrialManagementIdStr = strings.TrimRight(industrialManagementIdStr, ",")
-						industrialSubjectIdStr = strings.TrimRight(industrialSubjectIdStr, ",")
-						if industrialManagementIdStr != "" {
-							err = models.ReportArticleClassificationEditNew(artcleId, industrialManagementIdStr, v.ArticleId, industrialSubjectIdStr)
-							if err != nil {
-								fmt.Println("ReportArticleClassificationEditNew Err:", err.Error())
-								return err
-							}
-						}
-					}
-					//}
-				}
-			}
-
-		}
-	}
-
-	AddComprehensiveIndustrialSource("Hz", artcleId) // 同步到综合页面的搜索引擎（添加产业资源包）
-
-	AddCygxReportMappingCategoryGroupByArticleId(artcleId)
-	return err
-}
-
-func HandleArticleListByApiInit13_5GuShou(artcleId int) (err error) {
-	defer func() {
-		if err != nil {
-			go utils.SendAlarmMsg("处理同步策略平台数据失败"+"GetArticleListByApi ErrMsg:"+err.Error()+"artcleId："+strconv.Itoa(artcleId), 2)
-			go utils.SendEmail(utils.APPNAME+"【"+utils.RunMode+"】"+"失败提醒", "GetArticleListByApi ErrMsg:"+err.Error()+"artcleId："+strconv.Itoa(artcleId), utils.EmailSendToUsers)
-		}
-	}()
-	var clueApiUrl string
-	clueApiUrl = fmt.Sprint(utils.ApiUrl, "articles/", artcleId)
-	fmt.Println(clueApiUrl)
-
-	authorization := utils.ApiAuthorization
-	body, err := PublicGetDate(clueApiUrl, authorization)
-	if err != nil {
-		fmt.Println(err)
-		return
-	}
-	var articleResultDate models.ArticleDetailResultApi
-	err = json.Unmarshal(body, &articleResultDate)
-	if err != nil {
-		fmt.Println("Getres.PublicGetDate Err:", err.Error())
-		return err
-	}
-	item := new(models.CygxShanghaiCompanyLog)
-	item.CreateTime = time.Now()
-	item.Url = clueApiUrl
-	item.Body = ""
-	item.Result = string(body)
-
-	articleResult := articleResultDate.Data
-
-	exitMap := make(map[int]int)
-	categoryIdMap := make(map[int]int)
-	classMap := make(map[int]int)
-	reportMap := make(map[int]int)
-	summaryMap := make(map[int]int)
-	listMap, err := models.GetArticleApiMap()
-	if err != nil {
-		fmt.Println("GetlistMap Err:", err.Error())
-		return err
-	}
-
-	//新旧分类 反向隐射,是否归类,是否是报告,是否是纪要库
-	for _, v := range listMap {
-		exitMap[v.SeriesId] = v.OldId
-		categoryIdMap[v.SeriesId] = v.OldIdMap
-		if v.IsClass == 1 {
-			classMap[v.OldId] = 1
-		}
-		if v.IsReport == 1 {
-			reportMap[v.OldId] = 1
-		}
-		if v.IsSummary == 1 {
-			summaryMap[v.OldId] = 1
-		}
-	}
-	var list []*models.Tactics2
-	var listArticleData []*models.CygxArticleData
-	var listAuthor []*models.CygxArticleAuthor
-	//如果是英文报告 ,或者香港类型那么则不同步  publish_area   ：all  全部  ;hk 香港
-	if articleResult.TypeId == 9 || articleResult.PublishArea != "all" {
-		// 如果是英文报告，或者是香港报告就进行删除处理
-		err = models.UpdateArticlePublish(artcleId, 0)
-		if err != nil {
-			fmt.Println("UpdateArticlePublish Err:", err.Error())
-			return err
-		}
-		UpdateArticleResourceData(artcleId) //把数据写入 cygx_resource_data 表
-		return
-	}
-
-	var cover string
-	if articleResult.Series.Name == "图解市场" {
-		cover = GetArticleCoverByChartFirst(articleResult.Content.Body)
-	} else if articleResult.Series.Name == "行业深度" {
-		cover = articleResult.Cover
-	}
-	fmt.Println(cover)
-	//return
-	//状态等于 2 跟 4 的进行同步 IsActive 为false 软删除的也不同步
-	if exitMap[articleResult.SeriesId] > 0 && (articleResult.PublishStatus == 2 || articleResult.PublishStatus == 4) && articleResult.IsActive {
-		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)
-		itemArticleData.ArticleId = articleResult.ArticleId
-		itemArticleData.Cover = articleResult.Cover
-		itemArticleData.CreateTime = time.Now()
-		listArticleData = append(listArticleData, itemArticleData)
-		itemAuthor := new(models.CygxArticleAuthor)
-		item.ArticleId = articleResult.ArticleId
-		item.Title = articleResult.Title
-		item.TitleEn = articleResult.TitleEn
-		item.File = articleResult.File
-		if articleResult.Frequency == "日度" {
-			item.UpdateFrequency = "daily"
-		} else if articleResult.Frequency == "周度" {
-			item.UpdateFrequency = "weekly"
-		} else if articleResult.Frequency == "月度" {
-			item.UpdateFrequency = "monthly"
-		} else if articleResult.Frequency == "季度" {
-			item.UpdateFrequency = "quarterly"
-		} else if articleResult.Frequency == "年度" {
-			item.UpdateFrequency = "yearly"
-		} else {
-			item.UpdateFrequency = "unknow"
-		}
-		item.CreateDate = articleResult.CreateDate
-		item.PublishDate = articleResult.PublishDate.Add(time.Hour * 8)
-		item.PublishStatus = 1
-		item.Body = articleResult.Content.Body
-		item.Abstract = articleResult.Content.Abstract
-		item.Annotation = articleResult.Content.Annotation
-		item.CategoryName = articleResult.Industry.Name
-		item.CategoryId = categoryIdMap[articleResult.SeriesId]
-		item.CategoryIdTwo = exitMap[articleResult.SeriesId]
-		item.SubCategoryName = articleResult.Series.Name
-		item.Cover = cover
-
-		fmt.Println("item.CategoryIdTwo", item.CategoryIdTwo)
-		fmt.Println("item.CategoryId", item.CategoryId)
-
-		{
-			//这两种情况特殊处理
-			if articleResult.Field.Name == "宏观利率" {
-				item.CategoryId = 10070
-				item.CategoryIdTwo = item.CategoryId
-			}
-			if articleResult.Field.Name == "信用" {
-				item.CategoryId = 10082
-				item.CategoryIdTwo = item.CategoryId
-			}
-		}
-
-		if len(articleResult.Stock) > 0 {
-			var stock string
-			for _, vS := range articleResult.Stock {
-				stock += vS + "/"
-			}
-			stock = strings.TrimRight(stock, "/")
-			item.Stock = stock
-		}
-		item.FieldName = articleResult.Field.Name
-		item.TypeName = articleResult.Type.Name
-		item.UpdateDate = articleResult.UpdateDate
-		item.CeLueFieldId = articleResult.Field.Id
-		list = append(list, item)
-		itemAuthor.ArticleId = articleResult.ArticleId
-		itemAuthor.Name = articleResult.Author.Name
-		itemAuthor.Mobile = articleResult.Author.PhoneNumber
-		fmt.Println(articleResult.Cover)
-		listAuthor = append(listAuthor, itemAuthor)
-	} else {
-		// 如果这篇文章没有发布，那么就不作处理。
-		//err = models.UpdateArticlePublish(artcleId, 0)
-		//if err != nil {
-		//	fmt.Println("UpdateArticlePublish Err:", err.Error())
-		//	return err
-		//}
-		//UpdateArticleResourceData(artcleId) //把数据写入 cygx_resource_data 表
-		//go UpdateResourceData(artcleId, "article", "delete", time.Now().Format(utils.FormatDateTime))
-		return
-	}
-
-	fmt.Println("同步文章条数：", len(list))
-	listCustomArticle, err := models.GetCustomArticleId() //手动归类的文章，不替换文章类型
-	if err != nil {
-		fmt.Println("GetTacticsList Err:", err.Error())
-		return err
-	}
-	listGetMatchTypeName, errMatch := models.GetMatchTypeNamenNotNull() //手动归类的文章，不替换文章类型
-	if errMatch != nil {
-		fmt.Println("GetTacticsList Err:", errMatch.Error())
-		return err
-	}
-	//mapCategoryIdSet := make(map[int]int)
-	//for _, vMatch := range listGetMatchTypeName {
-	//	mapCategoryIdSet[vMatch.CategoryId] = vMatch.CategoryIdSet
-	//}
-	fmt.Println("list len:", len(list))
-	noSummaryArticleIds := "" //非纪要库类型的文章ID
-	listNoSummaryArticleIds := strings.Split(noSummaryArticleIds, ",")
-	for k, v := range list {
-		//同步匹配类型
-		matchTypeName := ""
-		for _, vMatch := range listGetMatchTypeName {
-			if v.CategoryId == vMatch.CategoryId {
-				matchTypeName = vMatch.MatchTypeName
-			}
-		}
-		//是否属于纪要库的数据
-		//if _, has := summaryMap[v.CategoryId]; has {
-		//	v.IsSummary = 1
-		//}
-		if v.TypeName == "纪要" {
-			v.IsSummary = 1
-		}
-		//排除不属于纪要库类型的文章
-		for _, vArt := range listNoSummaryArticleIds {
-			vArtInt, _ := strconv.Atoi(vArt)
-			if v.ArticleId == vArtInt {
-				v.IsSummary = 0
-			}
-		}
-		if _, has := reportMap[v.CategoryIdTwo]; has {
-			v.IsReport = 1
-			if _, ok := classMap[v.CategoryIdTwo]; ok {
-				v.IsClass = 1
-				v.ReportType = 1 //是否属于行业报告
-			} else {
-				v.ReportType = 2 //是否属于产业报告
-			}
-		}
-		v.Department = "弘则权益研究"
-		//判断是否已经存在
-		if v.ArticleId < 0 {
-			fmt.Println("AddCygxArticle Err:")
-			return err
-		}
-		var count int
-		count, err = models.GetArticleCountById(v.ArticleId)
-		if err != nil && err.Error() != utils.ErrNoRow() {
-			fmt.Println("AddCygxArticle Err:", err.Error())
-			return err
-		}
-		v.Body = strings.Replace(v.Body, "http://vmp.hzinsights.com", "https://vmp.hzinsights.com", -1)
-		expertNumStr, expertContentStr, interviewDateStr, _, bodyReturn := BodyAnalysis2(v.Body)
-		if strings.Index(v.Body, "报告全文（") > 0 && strings.Index(v.Body, "PDF格式报告下载.pdf") > 0 {
-			v.Body = strings.Replace(v.Body, "报告全文（", "", -1)
-			v.Body = strings.Replace(v.Body, "PDF格式报告下载.pdf", "", -1)
-			v.Body = strings.Replace(v.Body, "）：", "", -1)
-		}
-		var titleNew string
-		titleNew = v.Title
-		// 7资金流向 、11大类资产 、51每日复盘 、80医药周报、9估值研究
-		if v.CategoryId == 7 || v.CategoryId == 11 || v.CategoryId == 51 || v.CategoryId == 9 {
-			if v.UpdateFrequency == "daily" {
-				var daystr string
-				daystr = strconv.Itoa(v.PublishDate.Day())
-				if len(daystr) == 1 {
-					daystr = "0" + daystr
-				}
-				titleNew = v.Title + "(" + strconv.Itoa(v.PublishDate.Year())[2:len(strconv.Itoa(v.PublishDate.Year()))-0] + v.PublishDate.Format("01") + daystr + ")"
-			} else if v.UpdateFrequency == "weekly" {
-				titleNew = v.Title + utils.WeekByDate(v.PublishDate)
-			}
-		}
-		if v.CategoryId == 80 {
-			titleNew = v.Title + utils.WeekByDate(v.PublishDate)
-		}
-
-		//类型是综述报告的，不区分是什么系列，统一归类到对应产业的路演精华
-		if articleResult.Type.Name == "综述报告" {
-			detailCategory, err := models.GetdetailByCategoryIdLyjh(v.CategoryIdTwo)
-			if err != nil && err.Error() != utils.ErrNoRow() {
-				return err
-			}
-			v.CategoryId = detailCategory.CategoryId
-			v.IsSummary = 0
-		}
-
-		if count > 0 {
-			fmt.Println(k, v.ArticleId, "edit")
-
-			bodyText, _ := GetReportContentTextSubNew(v.Body)
-
-			var isCustom bool
-			updateParams := make(map[string]interface{})
-			//updateParams["Title"] = v.Title
-			updateParams["Title"] = titleNew
-			updateParams["TitleEn"] = v.TitleEn
-			updateParams["UpdateFrequency"] = v.UpdateFrequency
-			updateParams["CreateDate"] = v.CreateDate
-			updateParams["PublishDate"] = v.PublishDate
-			//updateParams["Body"] = html.EscapeString(v.Body)
-			updateParams["Body"] = html.EscapeString(bodyReturn)
-			updateParams["BodyText"] = bodyText
-			updateParams["Abstract"] = html.EscapeString(v.Abstract)
-			updateParams["CategoryName"] = v.CategoryName
-			for _, vCustom := range listCustomArticle {
-				if v.ArticleId == vCustom.ArticleId {
-					fmt.Println("手动归类的文章:" + strconv.Itoa(v.ArticleId))
-					isCustom = true
-				}
-			}
-			if isCustom == false {
-				updateParams["CategoryId"] = v.CategoryId
-				updateParams["MatchTypeName"] = matchTypeName
-				updateParams["IsSummary"] = v.IsSummary
-				updateParams["IsReport"] = v.IsReport
-				updateParams["ReportType"] = v.ReportType
-				updateParams["SubCategoryName"] = v.SubCategoryName
-			}
-			//updateParams["CategoryId"] = v.CategoryId
-			updateParams["PublishStatus"] = 1
-			updateParams["ExpertBackground"] = expertContentStr
-			updateParams["ExpertNumber"] = expertNumStr
-			updateParams["InterviewDate"] = interviewDateStr
-			//updateParams["IsClass"] = v.IsClass
-			v.Department = "弘则权益研究"
-			updateParams["Department"] = v.Department
-			updateParams["FileLink"] = v.File
-			updateParams["Stock"] = v.Stock
-			updateParams["FieldName"] = v.FieldName
-			updateParams["Annotation"] = v.Annotation
-			updateParams["TypeName"] = v.TypeName
-			updateParams["ModifyTimeByCl"] = v.UpdateDate
-			updateParams["CeLueFieldId"] = v.CeLueFieldId
-			updateParams["Cover"] = v.Cover
-			whereParam := map[string]interface{}{"article_id": v.ArticleId}
-			err = models.UpdateByExpr(models.CygxArticle{}, whereParam, updateParams)
-			if err != nil {
-				fmt.Println("UpdateByExpr Err:" + err.Error())
-				return err
-			}
-			fmt.Println("v.ReportType", v.ReportType)
-
-			if v.ReportType == 2 {
-				var subjectStr string
-				var industrialManagementIdStr string
-				var industrialSubjectIdStr string
-
-				sliceSubjects := strings.Split(v.Stock, "/")
-				mapManagementForSubject := make(map[string]string)
-				mapIndustrialId := make(map[int]int)
-				if len(sliceSubjects) > 0 {
-					for _, vSubject := range sliceSubjects {
-						sliceKuohao := strings.Split(vSubject, "(")           //过滤括号
-						sliceXiahuaxian := strings.Split(sliceKuohao[0], "-") //过滤下划线
-						subject := sliceXiahuaxian[0]
-						subjectStr += "'" + subject + "',"
-					}
-					//获取该产业下所对应的行业图片
-					detailCategory, errCategory := models.GetdetailByCategoryIdOne(v.CategoryId)
-					if errCategory != nil {
-						fmt.Println("GetdetailByCategoryIdOne Err:", err.Error())
-						return err
-					}
-					subjectStr = strings.TrimRight(subjectStr, ",")
-					if subjectStr != "" {
-						listIndustrial, err := models.GetIndustrialManagementForSubjecName(subjectStr, detailCategory.ChartPermissionId)
-						if err != nil {
-							fmt.Println("GetIndustrialManagementForSubjecName Err:", err.Error())
-							return err
-						}
-						subjectStr = strings.Replace(subjectStr, "','", "】【", -1)
-						subjectStr = strings.Replace(subjectStr, "'", "", -1)
-						subjectStr = "【" + subjectStr + "】"
-						if len(listIndustrial) > 0 {
-							for _, vIndustrial := range listIndustrial {
-								if _, ok := mapIndustrialId[vIndustrial.IndustrialManagementId]; !ok {
-									industrialManagementIdStr += strconv.Itoa(vIndustrial.IndustrialManagementId) + ","
-								}
-								mapIndustrialId[vIndustrial.IndustrialManagementId] = vIndustrial.IndustrialManagementId
-								industrialSubjectIdStr += strconv.Itoa(vIndustrial.IndustrialSubjectId) + ","
-								mapManagementForSubject[vIndustrial.IndustryName] += vIndustrial.SubjectName + "/"
-								if vIndustrial.LayoutTime == "0000-00-00 00:00:00" {
-									go models.UpdateIndustrialManagementLayoutTime(v.PublishDate.AddDate(0, 0, -10).Format(utils.FormatDateTime), vIndustrial.IndustrialManagementId)
-								}
-							}
-
-							industrialManagementIdStr = strings.TrimRight(industrialManagementIdStr, ",")
-							industrialSubjectIdStr = strings.TrimRight(industrialSubjectIdStr, ",")
-							if industrialManagementIdStr != "" {
-								err = models.ReportArticleClassificationEditNew(artcleId, industrialManagementIdStr, v.ArticleId, industrialSubjectIdStr)
-								if err != nil {
-									fmt.Println("ReportArticleClassificationEditNew Err:", err.Error())
-									return err
-								}
-							}
-						}
-						//}
-					}
-				}
-
-			}
-		}
-	}
-
-	AddComprehensiveIndustrialSource("Hz", artcleId) // 同步到综合页面的搜索引擎（添加产业资源包）
-
-	AddCygxReportMappingCategoryGroupByArticleId(artcleId)
-	return err
-}
-
-// 需求池972 修改部分报告类型title
-func initweek() {
-	var category_id int
-	//category_id = 52
-	//category_id = 10074
-	//category_id = 1008
-	//category_id = 10071
-	//category_id = 10073
-	//category_id = 50
-	var condition string
-	var pars []interface{}
-	condition += ` AND category_id = ? AND  publish_date  > '2023-12-31'  `
-	pars = append(pars, category_id)
-	articleList, e := models.GetCygxCygxArticleList(condition, pars, 0, 1000)
-	if e != nil {
-		fmt.Println(e)
-		return
-	}
-	var clueApiUrl string
-	for _, v := range articleList {
-
-		clueApiUrl = fmt.Sprint(utils.ApiUrl, "articles/", v.ArticleId)
-		fmt.Println(clueApiUrl)
-
-		authorization := utils.ApiAuthorization
-		body, err := PublicGetDate(clueApiUrl, authorization)
-		if err != nil {
-			fmt.Println(err)
-			return
-		}
-		var articleResultDate models.ArticleDetailResultApi
-		err = json.Unmarshal(body, &articleResultDate)
-		if err != nil {
-			fmt.Println(err)
-			return
-		}
-		articleResult := articleResultDate.Data
-
-		titleWeek := articleResult.Title + utils.WeekByDate(articleResult.PublishDate)
-
-		fmt.Println(titleWeek)
-		e = models.ModifyArticleTitleByarticleId(v.ArticleId, titleWeek)
-		if e != nil {
-			fmt.Println(e)
-			return
-		}
-	}
-}