hz_crm_api/models/cygx/summary_manage.go

package cygx

import (
	"fmt"
	"github.com/PuerkitoBio/goquery"
	"github.com/beego/beego/v2/client/orm"
	"github.com/rdlucklib/rdluck_tools/paging"
	"hongze/hz_crm_api/utils"
	"html"
	"strconv"
	"strings"
	"time"
)

type SummaryManageAddRep struct {
	ArticleId               int    `description:"文章ID，等于0新增，大于0修改"`
	ArticleTypeId           int    `description:"文章类型ID"`
	ChartPermissionIds      string `description:"行业ID ,多个用 , 隔开"`
	IndustryName            string `description:"产业名称"`
	SubjectName             string `description:"标的名称,多标的 用 , 隔开"`
	Title                   string `description:"标题"`
	Abstract                string `description:"摘要"`
	Body                    string `description:"内容"`
	SellerAndMobile         string `description:"销售和手机号"`
	DoType                  int    `description:"操作类型 0，保存 、1，发布"`
	Department              string `description:"作者"`
	IndustrialManagementIds string `description:"产业id 多个用 , 隔开"`
	IndustrialSubjectIds    string `description:"标的id 多个用 , 隔开"`
	PublishDate             string `description:"发布时间 列如 2020-03-23"`
	ReportLink              string `description:"报告链接"`
}

type SummaryManageEditDetail struct {
	SummaryManageId int `description:"纪要ID 等于0新增纪要，大于0修改纪要"`
	ArticleId       int `description:"文章ID"`
	//ChartPermissionId  int    `description:"行业ID"`
	ChartPermissionIds string `description:"行业ID ,多个用 , 隔开"`
	Title              string `description:"标题"`
	Abstract           string `description:"摘要"`
	Body               string `description:"内容"`
	SellerAndMobile    string `description:"销售和手机号"`
	SubjectName        string `description:"标的名称"`
	IndustryName       string `description:"产业名称"`
	PublishStatus      int    `description:"发布状态，0未发布 ，1已发布"`
	ListIndustrial     []*IndustrialActivityGroupManagementRep
	ListSubject        []*SubjectActivityGroupManagementRep
}

type SummaryManageIdRep struct {
	ArticleId int `description:"文章ID"`
}

type CygxArticle struct {
	SummaryManageId    int       `orm:"column(id);pk"`
	CategoryName       string    `description:"行业分类名称"`
	CategoryId         int       `description:"行业分类ID"`
	CategoryIdTwo      int       `description:"分类id用作修改匹配类型使用"`
	ArticleId          int       `description:"文章ID"`
	Title              string    `description:"标题"`
	Abstract           string    `description:"摘要"`
	Body               string    `description:"内容"`
	BodyText           string    `description:"内容"`
	PublishStatus      int       `description:"发布状态，0未发布 ，1已发布"`
	PublishDate        time.Time `description:"发布时间"`
	CreateDate         time.Time `description:"创建时间"`
	LastUpdatedTime    time.Time `description:"更新时间"`
	IsSummary          int       `description:"是否属于纪要库 1是、0否"`
	IsReport           int       `description:"是否属于报告 1是、0否"`
	ReportType         int       `description:"'报告类型，1行业报告，2产业报告'"`
	Source             int       `description:"来源 0策略平台同步，1小程序后台添加"`
	MatchTypeName      string    `description:"匹配类型名称"`
	ArticleIdMd5       string    `description:"ID，md5值"`
	UpdateFrequency    string    `description:"更新周期"`
	SellerAndMobile    string    `description:"销售和手机号"`
	Department         string    `description:"作者"`
	ExpertBackground   string    `description:"专家背景"`
	ExpertNumber       string    `description:"专家编号"`
	InterviewDate      string    `description:"访谈日期"`
	FileLink           string    `description:"下载预览链接"`
	ChartPermissionIds string    `description:"行业ID ,多个用 , 隔开"`
	DepartmentId       int       `description:"作者ID"`
	Periods            string    `description:"期数"`
	ReportLink         string    `description:"报告链接"`
	ArticleType        string    `description:"文章类型 文章类型，lyjh:路演精华 "`
	HavePublish        int       `description:"是否发布过，1是 ，0 否"`
	IsClass            int       `description:"是否归类过，1是 ，0 否"`
	SubCategoryName    string    `description:"主题名称"`
	LinkArticleId      int       `description:"报告ID链接"`
	AdminId            int       `description:"销售/管理员ID"`
	AdminName          string    `description:"销售/管理员姓名"`
	ArticleTypeId      int       `description:"文章类型ID"`
	ArticleTypeName    string    `description:"文章类型名称"`
	Annotation         string    `description:"核心观点"`
	VisibleRange       int       `description:"设置可见范围1全部，0内部"`
	//NickName           string    `description:"作者昵称"`
	ChartPermissionId   int    `description:"行业id"`
	ChartPermissionName string `description:"行业名称"`
}

type CygxArticleResp struct {
	SummaryManageId    int       `orm:"column(id);pk"`
	CategoryName       string    `description:"行业分类名称"`
	CategoryId         int       `description:"行业分类ID"`
	CategoryIdTwo      int       `description:"行业分类ID"`
	ArticleId          int       `description:"文章ID"`
	Title              string    `description:"标题"`
	Abstract           string    `description:"摘要"`
	Body               string    `description:"内容"`
	BodyText           string    `description:"内容"`
	PublishStatus      int       `description:"发布状态，0未发布 ，1已发布"`
	PublishDate        time.Time `description:"发布时间"`
	CreateDate         time.Time `description:"创建时间"`
	LastUpdatedTime    time.Time `description:"更新时间"`
	IsSummary          int       `description:"是否属于纪要库 1是、0否"`
	IsReport           int       `description:"是否属于报告 1是、0否"`
	Source             int       `description:"来源 0策略平台同步，1小程序后台添加"`
	ArticleIdMd5       string    `description:"ID，md5值"`
	UpdateFrequency    string    `description:"更新周期"`
	SellerAndMobile    string    `description:"销售和手机号"`
	Department         string    `description:"作者"`
	ExpertBackground   string    `description:"专家背景"`
	ExpertNumber       string    `description:"专家编号"`
	InterviewDate      string    `description:"访谈日期"`
	FileLink           string    `description:"下载预览链接"`
	ChartPermissionIds string    `description:"行业ID ,多个用 , 隔开"`
	DepartmentId       int       `description:"作者ID"`
	Periods            string    `description:"期数"`
	ReportLink         string    `description:"报告链接"`
	ArticleType        string    `description:"文章类型 文章类型，lyjh:路演精华 "`
	HavePublish        int       `description:"是否发布过，1是 ，0 否"`
	IsClass            int       `description:"是否归类过，1是 ，0 否"`
	IsClassFail        int       `description:"是否自动归类失败，1是 ，0 否"`
	SubCategoryName    string    `description:"主题名称"`
	LinkArticleId      int       `description:"报告ID链接"`
	NickName           string    `description:"作者昵称"`
	HeadImgUrl         string    `description:"作者头像"`
	SubjectIds         string    `description:"报告所关联的标的"`
	AdminId            int       `description:"销售/管理员ID"`
	AdminName          string    `description:"销售/管理员姓名"`
	Annotation         string    `description:"核心观点"`
	VisibleRange       int       `description:"设置可见范围1全部，0内部"`
	TopTime            int       `description:"置顶时间"`
}

type GetSummaryManageListRep struct {
	Paging *paging.PagingItem `description:"分页数据"`
	List   []*CygxArticleList
}

type ElasticTestArticleDetail struct {
	ArticleId        int    `description:"报告id"`
	Title            string `description:"标题"`
	BodyText         string `description:"内容"`
	PublishDate      string `description:"发布时间"`
	ExpertBackground string `description:"专家背景"`
	CategoryId       string `description:"文章分类"`
	Abstract         string `description:"摘要"`
	Annotation       string `description:"核心观点"`
}

// 添加文章
func AddArticle(item *CygxArticle) (newId int64, err error) {
	o := orm.NewOrmUsingDB("hz_cygx")
	newId, err = o.Insert(item)
	fmt.Println(newId)
	return
}

//item.ExpertBackground = expertContentStr
//item.ExpertNumber = expertNumStr
//item.InterviewDate = interviewDateStr
//item.FileLink = fileLink

// 修改文章
func EditArticle(item *CygxArticle, oldPublishStatus int) (err error) {
	o := orm.NewOrmUsingDB("hz_cygx")
	if oldPublishStatus == 1 {
		sql := `UPDATE cygx_article SET category_name=?, title=?, abstract=?, body=?, body_text=?, publish_status=?,last_updated_time = ?,seller_and_mobile=?,expert_background =?, expert_number=? ,interview_date=?, file_link=? ,chart_permission_ids =? WHERE id=? AND source = 1`
		_, err = o.Raw(sql, item.CategoryName, item.Title, item.Abstract, item.Body, item.BodyText, item.PublishStatus, item.LastUpdatedTime, item.SellerAndMobile, item.ExpertBackground, item.ExpertNumber, item.InterviewDate, item.FileLink, item.ChartPermissionIds, item.SummaryManageId).Exec()
	} else {
		if item.PublishStatus == 1 {
			sql := `UPDATE cygx_article SET category_name=?, title=?, abstract=?, body=?, body_text=?, publish_status=?, publish_date =? ,last_updated_time = ?,seller_and_mobile=?,expert_background =?, expert_number=? ,interview_date=?, file_link=?,chart_permission_ids =? WHERE id=? AND source = 1`
			_, err = o.Raw(sql, item.CategoryName, item.Title, item.Abstract, item.Body, item.BodyText, item.PublishStatus, item.PublishDate, item.LastUpdatedTime, item.SellerAndMobile, item.ExpertBackground, item.ExpertNumber, item.InterviewDate, item.FileLink, item.ChartPermissionIds, item.SummaryManageId).Exec()
		} else {
			sql := `UPDATE cygx_article SET category_name=?, title=?, abstract=?, body=?, body_text=?, publish_status=?,last_updated_time = ?, publish_date = '' ,seller_and_mobile=?,expert_background =?, expert_number=? ,interview_date=?, file_link=?,chart_permission_ids =? WHERE id=? AND source = 1`
			_, err = o.Raw(sql, item.CategoryName, item.Title, item.Abstract, item.Body, item.BodyText, item.PublishStatus, item.LastUpdatedTime, item.SellerAndMobile, item.ExpertBackground, item.ExpertNumber, item.InterviewDate, item.FileLink, item.ChartPermissionIds, item.SummaryManageId).Exec()
		}
	}
	return
}

func GetMaxArticleIdInfo() (item *ArticleDetail, err error) {
	o := orm.NewOrmUsingDB("hz_cygx")
	sql := `SELECT * FROM cygx_article   ORDER BY article_id desc  LIMIT 1`
	err = o.Raw(sql).QueryRow(&item)
	return
}

// 通过纪要ID获取文章详情
func GetArticleIdInfoBySummaryManageId(summaryManageId int) (item *CygxArticleResp, err error) {
	o := orm.NewOrmUsingDB("hz_cygx")
	sql := `SELECT art.* ,dm.nick_name  FROM cygx_article as art 
			LEFT JOIN cygx_article_department as dm ON dm.department_id = art.department_id  WHERE id=? AND source = 1`
	err = o.Raw(sql, summaryManageId).QueryRow(&item)
	return
}

// 通过文章ID获取文章、以及所关联的标的详情
func GetArticleInfoOtherByArticleId(articleId int) (item *CygxArticleResp, err error) {
	o := orm.NewOrmUsingDB("hz_cygx")
	sql := `SELECT art.* ,dm.nick_name ,dm.img_url as head_img_url   FROM cygx_article as art 
			LEFT JOIN cygx_article_department as dm ON dm.department_id = art.department_id  WHERE article_id=? `
	err = o.Raw(sql, articleId).QueryRow(&item)
	return
}

// 通过纪要ID获取文章详情
func GetArticleIdInfoByArticleId(articleId int) (item *CygxArticle, err error) {
	o := orm.NewOrmUsingDB("hz_cygx")
	sql := `SELECT * FROM cygx_article  WHERE article_id= ?`
	err = o.Raw(sql, articleId).QueryRow(&item)
	return
}

func GetReportContentTextSub(content string) (contentSub string, err error) {
	content = html.UnescapeString(content)
	doc, err := goquery.NewDocumentFromReader(strings.NewReader(content))
	docText := doc.Text()
	bodyRune := []rune(docText)
	bodyRuneLen := len(bodyRune)
	if bodyRuneLen > 200 {
		bodyRuneLen = 200
	}
	body := string(bodyRune[:bodyRuneLen])
	contentSub = body
	return
}

// 修改发布状态
func PublishAndCancel(item *CygxArticle) (err error) {
	sql := `UPDATE cygx_article SET  publish_status=? ,admin_id =? ,admin_name =?  WHERE article_id=? `
	o := orm.NewOrmUsingDB("hz_cygx")
	_, err = o.Raw(sql, item.PublishStatus, item.AdminId, item.AdminName, item.ArticleId).Exec()
	return
}

// 修改发布状态
func ArticleVisibleRange(item *CygxArticle) (err error) {
	sql := `UPDATE cygx_article SET  visible_range=? ,admin_id =? ,admin_name =?  WHERE article_id=? `
	o := orm.NewOrmUsingDB("hz_cygx")
	_, err = o.Raw(sql, item.VisibleRange, item.AdminId, item.AdminName, item.ArticleId).Exec()
	return
}

// 修改发布状态
func UpdateIsClassFail(item *CygxArticleResp) (err error) {
	sql := `UPDATE cygx_article SET  is_class_fail=0  WHERE article_id=? `
	o := orm.NewOrmUsingDB("hz_cygx")
	_, err = o.Raw(sql, item.ArticleId).Exec()
	return
}

// 通过纪要ID获取文章详情
func GetArticleIdInfoBySummaryManageIdEdit(summaryManageId int) (item *CygxArticle, err error) {
	o := orm.NewOrmUsingDB("hz_cygx")
	sql := `SELECT * FROM cygx_article  WHERE id=? AND source = 1`
	err = o.Raw(sql, summaryManageId).QueryRow(&item)
	return
}

// 删除数据
func DeleteSummaryManage(summaryManageId int) (err error) {
	o := orm.NewOrmUsingDB("hz_cygx")
	sql := ` DELETE FROM cygx_article  WHERE id=? AND source = 1`
	_, err = o.Raw(sql, summaryManageId).Exec()
	return
}

type CygxArticleList struct {
	ArticleId       int    `description:"报告id"`
	CategoryName    string `description:"行业分类名称"`
	Title           string `description:"标题"`
	Abstract        string `description:"摘要"`
	Body            string `description:"内容"`
	PublishStatus   int    `description:"发布状态，0未发布 ，1已发布"`
	PublishDate     string `description:"发布时间"`
	LastUpdatedTime string `description:"更新时间"`
	ArticleIdMd5    string `description:"ID，md5值"`
	Pv              int    `description:"PV"`
	Uv              int    `description:"UV"`
	CommentNum      int    `description:"留言总数"`
	CollectionNum   int    `description:"收藏"`
	NickName        string `description:"作者昵称"`
	DepartmentId    int    `description:"作者ID"`
	IndustryName    string `description:"产业名称"`
	SubjectName     string `description:"标的名称"`
	ArticleTypeId   int    `description:"文章类型ID"`
	ArticleTypeName string `description:"文章类型名称"`
	VisibleRange    int    `description:"设置可见范围1全部，0内部"`
	TopTime         int    `description:"置顶时间"`
}

// 列表
func GetSummaryManageList(condition string, pars []interface{}, startSize, pageSize int) (items []*CygxArticleList, err error) {
	o := orm.NewOrmUsingDB("hz_cygx")
	sql := ` SELECT 
		(SELECT COUNT(1) FROM cygx_article_history_record_newpv AS h   WHERE h.article_id=art.article_id AND h.company_id != ` + strconv.Itoa(utils.HZ_COMPANY_ID) + ` ) AS pv,
	   	(SELECT COUNT(DISTINCT h.user_id) FROM cygx_article_history_record_newpv AS h  WHERE h.article_id=art.article_id AND h.company_id != ` + strconv.Itoa(utils.HZ_COMPANY_ID) + ` ) AS uv,
		(SELECT COUNT(1) FROM cygx_article_comment AS k    WHERE k.article_id=art.article_id) AS comment_num,
		(SELECT COUNT(1) FROM cygx_article_collect AS c   WHERE c.article_id = art.article_id ) AS collection_num,
		(SELECT GROUP_CONCAT(DISTINCT s.subject_name  SEPARATOR '/')  FROM cygx_industrial_subject as s  WHERE s.industrial_management_id = m.industrial_management_id) AS subject_name ,
		art.title ,art.category_name ,art.publish_date ,art.id,art.last_updated_time,art.publish_status,art.abstract,art.body,art.article_id_md5 ,art.article_id,dm.nick_name , art.department_id,m.industry_name,art.article_type_id,art.article_type_name,art.visible_range,art.top_time
		FROM cygx_article as art 
		LEFT JOIN cygx_article_department as dm ON dm.department_id = art.department_id
		LEFT JOIN cygx_industrial_article_group_management as mg ON mg.article_id = art.article_id 
		LEFT JOIN cygx_industrial_management as m ON m.industrial_management_id = mg.industrial_management_id`
	if condition != "" {
		sql += condition
	}
	sql += `   LIMIT ?,?`
	_, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&items)
	return
}

// 列表
func GetSummaryManageListInit(condition string, pars []interface{}, startSize, pageSize int) (items []*CygxArticleList, err error) {
	o := orm.NewOrmUsingDB("hz_cygx")
	sql := `SELECT
	art.title,
	art.article_id,
	dm.nick_name,
	art.top_time 
FROM
	cygx_article AS art
	INNER JOIN cygx_article_department AS dm ON dm.department_id = art.department_id`
	if condition != "" {
		sql += condition
	}
	sql += `   LIMIT ?,?`
	_, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&items)
	return
}

// 列表
func GetCygxArticleList(condition string, pars []interface{}, startSize, pageSize int) (items []*CygxReportArticle, err error) {
	o := orm.NewOrmUsingDB("hz_cygx")
	sql := ` SELECT *
		FROM cygx_article as art WHERE  1 =1 `
	if condition != "" {
		sql += condition
	} else {
		return
	}
	sql += `   LIMIT ?,?`
	_, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&items)
	return
}

type CygxArticleSubjectList struct {
	ArticleId   int    `description:"报告id"`
	SubjectName string `description:"标的名称"`
}

// 文章标的列表
func GetArticleSubjectList(articleId string) (items []*CygxArticleSubjectList, err error) {
	if articleId == "" {
		articleId = "0"
	}
	o := orm.NewOrmUsingDB("hz_cygx")
	sql := ` SELECT GROUP_CONCAT( DISTINCT s.subject_name SEPARATOR '/' )  AS subject_name,
			 sg.article_id
			FROM
				cygx_industrial_article_group_subject AS sg
				LEFT  JOIN cygx_industrial_subject AS s ON s.industrial_subject_id = sg.industrial_subject_id 
			WHERE
				sg.article_id IN (` + articleId + `)
				GROUP BY sg.article_id`
	_, err = o.Raw(sql).QueryRows(&items)
	return
}

// 获取文章数量
func GetASummaryManageCount(condition string, pars []interface{}) (count int, err error) {
	sqlCount := ` SELECT COUNT(1) AS count  FROM cygx_article as art  `
	if condition != "" {
		sqlCount += condition
	}
	o := orm.NewOrmUsingDB("hz_cygx")
	err = o.Raw(sqlCount, pars).QueryRow(&count)
	return
}

// body 解析
func BodyAnalysis(body string) (expertNumStr, expertContentStr, interviewDateStr, fileLink string) {
	body = html.UnescapeString(body)
	doc, err := goquery.NewDocumentFromReader(strings.NewReader(body))
	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()
			//Powered 是编辑器传过来的字段
			if expertContent == "" || strings.Contains(expertContent, "Powered") {
				expertContent = contentTxt
			}
			//如果内容中最前的文字是 "专家" 这个词，则认为这句话是专家背景
			if !strings.Contains(expertContent, "专家评价") && strings.Contains(expertContent, "专家") && strings.Index(expertContent, "专家") == 0 {
				expertContentArr = append(expertContentArr, expertContent)
			}
			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 !strings.Contains(contentTxt, "（") || !strings.Contains(contentTxt, "(") {
					expertContentArr = append(expertContentArr, expertContent)
				}

			}
		}
	})
	if len(expertContentArr) == 0 {
		doc.Find("pre").Each(func(i int, s *goquery.Selection) {
			contentTxt := s.Text()
			if strings.Contains(contentTxt, "#访谈时间：") || strings.Contains(contentTxt, "访谈时间：") {
				interviewDate := s.Next().Text()
				numStar := strings.Index(contentTxt, " #访谈时间：")
				numEnd := strings.Index(contentTxt, " #纪要详情：")
				interviewDate = contentTxt[numStar+19 : numEnd]
				if interviewDate != "" {
					interviewDateArr = append(interviewDateArr, interviewDate)
				}
			}
			if strings.Contains(contentTxt, "#专家评价") || strings.Contains(contentTxt, "专家评价") {
				expertContent := s.Next().Text()
				if expertContent == "" {
					expertContent = contentTxt
				}

				if expertContent != "" {
					expertIsHave := strings.Index(expertContent, "专家评价")
					if expertIsHave > 0 {
						expertContent = expertContent[expertIsHave:]
						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)
							if expertNum != "" {
								expertNumArr = append(expertNumArr, expertNum)
								rightIndex = rightIndex
								expertContentStr := expertContent[rightIndex:]
								expertContentStr = strings.Replace(expertContentStr, "）", "", -1)
								expertContentStr = strings.TrimLeft(expertContentStr, "：")
								expertContentStr = strings.TrimRight(expertContentStr, "（推荐")
								if expertContentStr != "" {
									expertContentArr = append(expertContentArr, expertContentStr)
								}
							}
						}
					}
					if !strings.Contains(contentTxt, "（") || !strings.Contains(contentTxt, "(") {
						expertContentArr = append(expertContentArr, expertContent)
					}
				}
			}
		})
	}
	if len(expertNumArr) > 0 {
		expertNumStr = expertNumArr[0]
		if expertNumStr != "" {
			expertNumStr = strings.Replace(expertNumStr, "#：", "", -1)
			expertNumStr = strings.Replace(expertNumStr, "# ", "", -1)
			expertNumStr = strings.Trim(expertNumStr, "")
		}
	}

	if len(expertContentArr) > 0 {
		expertContentStr = expertContentArr[0]
	}
	if len(expertContentStr) > 600 {
		strnum := strings.Index(expertContentStr, "#专家评价：")
		content := expertContentStr[strnum:]
		strnum2 := strings.Index(content, "（")
		content = content[strnum2+9:] //中文括号3位 专家编号6位
		expertContentStr = content
	}
	if len(interviewDateArr) > 0 {
		interviewDateStr = interviewDateArr[0]
	}
	return
}

// 列表
func GetCygxArticleCollectionList(articleId int) (items []*CygxDepartmentFllowList, err error) {
	o := orm.NewOrmUsingDB("hz_cygx")
	sql := `SELECT
			f.* 
		FROM
			cygx_article_collect AS f
		WHERE
			f.article_id = ?
			GROUP BY f.id`
	_, err = o.Raw(sql, articleId).QueryRows(&items)
	return
}

type ArticleHistoryRep struct {
	ArticleId   int    `description:"文章ID"`
	RealName    string `description:"姓名"`
	Mobile      string `description:"手机号"`
	CompanyName string `description:"公司名称"`
	CompanyId   int    `description:"文章ID"`
	SellerName  string `description:"所属销售"`
	StopTime    string `description:"阅读停留时间"`
	CreateTime  string `description:"创建时间"`
	Ly          string `description:"创建时间"`
	Source      string `description:"创建时间"`
	PublishDate string `description:"创建时间"`
	Title       string `description:"标题"`
}

// 列表
func GetArticleHistoryList(articleId int, condition string) (items []*ArticleHistoryRep, err error) {
	o := orm.NewOrmUsingDB("hz_cygx")
	sql := `SELECT
			h.*
			FROM
				cygx_article_history_record_all AS h
			WHERE
				h.article_id = ?
				AND h.platfor = 1  AND h.is_del = 0   `
	if condition != "" {
		sql = sql + condition + ` group by mobile `
	}
	_, err = o.Raw(sql, articleId).QueryRows(&items)
	return
}

// 列表
func GetArticleHistoryListInitss() (items []*ArticleHistoryRep, err error) {
	o := orm.NewOrmUsingDB("hz_cygx")
	sql := `SELECT
	s.mobile,
	s.real_name,
	s.company_name,
	s.create_time,
	a.title,
	a.publish_date 
FROM
	cygx_article_history_record_all AS s
	INNER JOIN cygx_article AS a ON a.article_id = s.article_id 
WHERE
	s.article_id IN ( SELECT article_id FROM cygx_article WHERE chart_permission_id = 53 AND publish_status = 1 ) 
	AND s.company_id IN ( 1012, 5599, 15184, 5468, 8728 ) 
	AND s.is_del = 0 
	LIMIT 1000 `
	_, err = o.Raw(sql).QueryRows(&items)
	return
}

func GetArticleHistoryListInitss5349() (items []*ArticleHistoryRep, err error) {
	o := orm.NewOrmUsingDB("hz_cygx")
	sql := `SELECT
	s.mobile,
	s.real_name,
	s.company_name,
	s.create_time,
	a.title,
	a.publish_date 
FROM
	cygx_article_history_record_all AS s
	INNER JOIN cygx_article AS a ON a.article_id = s.article_id 
WHERE
	1 = 1 
	AND s.company_id IN ( 5349 ) 
	AND s.create_time >= '2025-04-01' 
	AND s.create_time <= '2025-05-01' 
	AND s.is_del = 0 
	LIMIT 1000 `
	_, err = o.Raw(sql).QueryRows(&items)
	return
}

// 列表
func GetArticleHistoryList121(articleId int, condition string) (items []*ArticleHistoryRep, err error) {
	o := orm.NewOrmUsingDB("hz_cygx")
	sql := `SELECT
			h.*
			FROM
				cygx_article_history_record_all AS h
			WHERE
				h.article_id = ?  AND h.is_del = 0   `
	if condition != "" {
		sql = sql + condition
	}
	_, err = o.Raw(sql, articleId).QueryRows(&items)
	return
}

// 列表
func GetArticleHistoryList_H(articleId int, condition string) (items []*ArticleHistoryRep, err error) {
	o := orm.NewOrmUsingDB("hz_cygx")
	sql := `SELECT
			h.*
			FROM
				cygx_article_history_record_all AS h
			WHERE
				h.article_id = ?
				AND h.platfor = 1  AND h.is_del = 0  AND h.create_time <'2024-12-19 15:55' `
	if condition != "" {
		sql = sql + condition + ` group by mobile  `
	}
	_, err = o.Raw(sql, articleId).QueryRows(&items)
	return
}

// 列表
func GetArticleHistoryList_ZHouqi(articleId int, condition string) (items []*ArticleHistoryRep, err error) {
	o := orm.NewOrmUsingDB("hz_cygx")
	sql := `SELECT
			h.*
			FROM
				cygx_article_history_record_all AS h
			WHERE
				h.article_id = ?
				AND h.platfor = 1  AND h.is_del = 0  AND h.stop_time > 0  `
	if condition != "" {
		sql = sql + condition
	}
	_, err = o.Raw(sql, articleId).QueryRows(&items)
	return
}

// 列表
func GetArticleHistoryListInit(ArticleIds, companyIds []int) (items []*ArticleHistoryRep, err error) {
	o := orm.NewOrmUsingDB("hz_cygx")
	sql := `SELECT
			h.*
			FROM
				cygx_article_history_record_all AS h
			WHERE
1=1
				AND h.platfor = 1  AND create_time >= '2023.09.01' AND create_time < '2024.09.02'  AND h.is_del = 0   AND article_id IN (` + utils.GetOrmInReplace(len(ArticleIds)) + `)  AND company_id IN (` + utils.GetOrmInReplace(len(companyIds)) + `)  `

	sql += ` ORDER BY id DESC  `

	_, err = o.Raw(sql, ArticleIds, companyIds).QueryRows(&items)
	return
}

// 用户阅读记录，不过滤弘则内部的
func GetArticleHistoryListOld(articleId int, condition string) (items []*ArticleHistoryRep, err error) {
	o := orm.NewOrmUsingDB("hz_cygx")
	sql := `SELECT
			h.*
			FROM
				cygx_article_history_record AS h
			WHERE
				h.article_id = ?
				AND c.product_id = 2`
	if condition != "" {
		sql = sql + condition + ` GROUP BY h.id`
	}
	_, err = o.Raw(sql, articleId).QueryRows(&items)
	return
}

// 列表
func GetSellerUserMobileList(condition string) (items []*ArticleHistoryRep, err error) {
	o := orm.NewOrm()
	sql := `SELECT mobile FROM wx_user as h WHERE h.mobile != '' ` + condition
	_, err = o.Raw(sql).QueryRows(&items)
	return
}

type ArticleTypeAndAbstract struct {
	Abstract      string
	ArticleTypeId int
}

func GetArticleTypeAndAbstract() (list []*ArticleTypeAndAbstract, err error) {
	o := orm.NewOrmUsingDB("hz_cygx")
	sql := `SELECT
	* 
FROM
	( SELECT abstract, article_type_id FROM cygx_article GROUP BY publish_date DESC ) AS a 
GROUP BY
	a.article_type_id `
	_, err = o.Raw(sql).QueryRows(&list)
	return
}

// 更新文章置顶时间
func UpdateArticleTopTime(activityId, topTime int) (err error) {
	o := orm.NewOrmUsingDB("hz_cygx")
	sql := ` UPDATE cygx_article SET  top_time=? WHERE article_id=?`
	_, err = o.Raw(sql, topTime, activityId).Exec()
	return
}

// 添加朋友圈分享封面图片
func UpdateCygxArticleMomentsImg(momentsImg string, articleId int) (err error) {
	sql := `UPDATE cygx_article SET  moments_img=?  WHERE article_id=? `
	o := orm.NewOrmUsingDB("hz_cygx")
	_, err = o.Raw(sql, momentsImg, articleId).Exec()
	return
}