hongze_clpt/controllers/report.go

package controllers

import (
	"encoding/json"
	"github.com/rdlucklib/rdluck_tools/paging"
	"hongze/hongze_clpt/models"
	"hongze/hongze_clpt/services"
	"hongze/hongze_clpt/utils"
	"strconv"
	"strings"
	"time"
)

// 报告
type ReportController struct {
	BaseAuthController
}

type ReportCommonController struct {
	BaseCommonController
}

type MobileReportController struct {
	BaseAuthMobileController
}

// @Title 行业报告分类列表接口
// @Description 获取行业报告分类列表接口
// @Param   ChartPermissionId   query   int  true       "分类ID"
// @Success 200 {object} models.TradeReportMappingResp
// @router /tradeList [get]
func (this *MobileReportController) TradeList() {
	br := new(models.BaseResponse).Init()
	defer func() {
		this.Data["json"] = br
		this.ServeJSON()
	}()
	user := this.User
	if user == nil {
		br.Msg = "请重新登录"
		br.Ret = 408
		return
	}
	//uid := user.UserId
	ChartPermissionId, _ := this.GetInt("ChartPermissionId")
	if ChartPermissionId < 1 {
		br.Msg = "请输入分类ID"
		return
	}
	//var result []*models.SearchItem
	var list []*models.TradeReportMapping
	var err error
	mapCategory := make(map[int]int)
	mapCategoryFollowType := make(map[int]int)
	if ChartPermissionId == utils.CE_LUE_ID || ChartPermissionId == utils.GU_SHOU_ID {
		listTrade, errTrade := models.GetReportMappingStrategyHomeAllByCygx(user.UserId, ChartPermissionId)

		err = errTrade
		if ChartPermissionId == utils.CE_LUE_ID {
			cf, err := models.GetConfigByCode(utils.CYGX_TACTICS_TIME_LINE_STATUS)
			if err != nil {
				br.Msg = "获取失败"
				br.ErrMsg = "获取数据失败，Err:" + err.Error()
				return
			}
			if cf.ConfigValue == "1" || user.CompanyId == utils.HZ_COMPANY_ID {
				item := new(models.TradeReportMapping)
				item.CategoryId = utils.TIME_LINE_ID
				item.MatchTypeName = utils.TIME_LINE_NAME
				list = append(list, item)
			}
		}

		for _, v := range listTrade {
			list = append(list, v)
		}

		if user.Mobile != "" {
			//策略的处理
			categoryList, err := models.GetCygxXzsChooseCategoryList(user.Mobile)
			if err != nil && err.Error() != utils.ErrNoRow() {
				br.Msg = "获取信息失败"
				br.ErrMsg = "获取客户信息失败,Err:" + err.Error()
				return
			}
			for _, v := range categoryList {
				mapCategory[v.IdCygx] = v.IdCygx
				mapCategoryFollowType[v.IdCygx] = v.FollowType
			}
		}
	} else {
		listCategory, err := models.GetTradeArticleAndProductInterior(ChartPermissionId)
		if err != nil {
			br.Msg = "获取信息失败"
			br.ErrMsg = "获取品种信息失败,Err:" + err.Error()
			return
		}

		categoryMap := make(map[int]int)
		for _, v := range listCategory {
			if categoryMap[v.CategoryId] > 0 {
				continue
			}
			categoryMap[v.CategoryId] = v.CategoryId
			list = append(list, v)
		}
		//加了一个需求，现有数据结构不支持，手动添加  2023-06-12
		//if ChartPermissionId == utils.KE_JI_ID {
		//	list = append(list, &models.TradeReportMapping{MatchTypeName: "AI前沿", CategoryId: utils.ACTEGORY_ID_AI_QY})
		//}
	}

	if err != nil {
		br.Msg = "获取信息失败"
		br.ErrMsg = "获取品种信息失败,Err:" + err.Error()
		return
	}

	for k, v := range list {
		if ChartPermissionId != utils.CE_LUE_ID && ChartPermissionId != utils.GU_SHOU_ID {
			var pageSize int
			var listArticle []*models.HomeArticle
			pageSize = 3
			if v.CategoryId == utils.ACTEGORY_ID_AI_QY {
				//加了一个需求，现有数据结构不支持，手动添加  2023-06-12
				listArticle, _, err = services.GetAiQianYanArtilceList(0, pageSize)
			} else {
				listArticle, _, err = models.GetReportAndproductIndustrylList(v.CategoryId, 0, pageSize)
			}
			if err != nil {
				br.Msg = "获取信息失败"
				br.Msg = "GetHomeList，Err:" + err.Error()
				return
			}
			if len(listArticle) > 0 {
				list[k].UpdateTime = utils.StrTimeToTime(listArticle[0].PublishDate).Format(utils.FormatDate) //时间字符串格式转时间格式
			}
			list[k].ListArticle = listArticle
		} else {
			if mapCategory[v.CategoryId] > 0 {
				list[k].IsFollow = true
			}
			list[k].FollowType = mapCategoryFollowType[v.CategoryId]
			list[k].ListArticle = make([]*models.HomeArticle, 0)
		}
	}
	resp := new(models.TradeReportMappingResp)
	if len(list) == 0 {
		list = make([]*models.TradeReportMapping, 0)
	}
	resp.List = list
	br.Ret = 200
	br.Success = true
	br.Msg = "获取成功"
	br.Data = resp
}

// @Title 产业报告分类列表接口
// @Description 获取产业报告分类列表接口
// @Param   ChartPermissionId   query   int  true       "分类ID"
// @Param   DeepCover   query   int  false       "是否选择深度覆盖，1是，0否 不填默认为0"
// @Param   RecommendFocus   query   int  false       "是否选择推荐关注，1是，0否 不填默认为0"
// @Param   PageSize   query   int  true       "每页数据条数"
// @Param   CurrentIndex   query   int  true       "当前页页码，从1开始"
// @Param   IsBillboard   query   bool  false       "是否属于榜单 是true 否 false"
// @Success 200 {object} models.IndustrialManagementList
// @router /industryList [get]
func (this *MobileReportController) IndustryList() {
	br := new(models.BaseResponse).Init()
	defer func() {
		this.Data["json"] = br
		this.ServeJSON()
	}()
	user := this.User
	if user == nil {
		br.Msg = "请重新登录"
		br.Ret = 408
		return
	}
	uid := user.UserId
	ChartPermissionId, _ := this.GetInt("ChartPermissionId")
	orderColumn := this.GetString("OrderColumn")
	orderColumnNew := this.GetString("OrderColumn")
	isNewLabel := this.GetString("IsNewLabel")
	isDeepLabel := this.GetString("IsDeepLabel")
	pageSize, _ := this.GetInt("PageSize")
	currentIndex, _ := this.GetInt("CurrentIndex")
	deepCover, _ := this.GetInt("DeepCover")
	recommendFocus, _ := this.GetInt("RecommendFocus")
	isBillboard, _ := this.GetBool("IsBillboard", false)
	var orderSrt string
	var condition string
	var startSize int
	resp := new(models.IndustrialManagementList)
	if pageSize <= 0 {
		pageSize = utils.PageSize20
	}
	if currentIndex <= 0 {
		currentIndex = 1
	}
	startSize = paging.StartIndex(currentIndex, pageSize)
	if ChartPermissionId > 0 {
		condition += ` AND man.chart_permission_id IN (` + strconv.Itoa(ChartPermissionId) + `)`
	}

	// 获取近一个月产业报告阅读次数最多的产业
	var topCond string
	var topPars []interface{}
	topReadIndustryId := 0
	if ChartPermissionId > 0 {
		topCond += ` AND chart_permission_id = ?`
		topPars = append(topPars, ChartPermissionId)
	}
	topReadIndustry, e := models.GetTopOneMonthArtReadNumIndustry(topCond, topPars)
	if e != nil && e.Error() != utils.ErrNoRow() {
		br.Msg = "获取信息失败"
		br.ErrMsg = "获取近一个月报告阅读次数最多的产业失败, Err: " + e.Error()
		return
	}
	if topReadIndustry != nil {
		topReadIndustryId = topReadIndustry.IndustrialManagementId
	}
	// 深度覆盖
	if deepCover == 1 {
		// 查询深标签产业报告数
		var deepCondition string
		var deepPars []interface{}
		deepCondition += ` AND man.is_deep_label = 1`
		if ChartPermissionId > 0 {
			deepCondition += ` AND man.chart_permission_id = ?`
			deepPars = append(deepPars, ChartPermissionId)
		}
		industryCountList, e := models.GetIndustryArtCountByCondition(deepCondition, deepPars)
		if e != nil {
			br.Msg = "获取信息失败"
			br.ErrMsg = "获取深标签产业报告数失败, Err: " + e.Error()
			return
		}
		deepIdArr := make([]string, 0)
		for i := range industryCountList {
			if industryCountList[i].ArtNum > 10 {
				deepIdArr = append(deepIdArr, strconv.Itoa(industryCountList[i].IndustrialManagementId))
			}
		}
		deepIds := strings.Join(deepIdArr, ",")
		if deepIds != "" {
			condition = `AND man.industrial_management_id IN (` + deepIds + `)`
		}
	}
	// 推荐关注
	if recommendFocus == 1 {
		condition += ` AND man.recommended_index >= 80`
	}

	var list []*models.IndustrialManagement
	total, err := models.GetIndustrialManagementAllCount(condition)
	if err != nil {
		br.Msg = "获取信息失败"
		br.ErrMsg = "获取数量失败,Err:" + err.Error()
		return
	}

	if orderColumn == "" {
		orderColumn = "NewTime"
	}
	if orderColumn == "NewTime" {
		orderSrt = "update_time DESC"
	} else {
		orderSrt = "man.recommended_index DESC,update_time DESC"
	}

	if isBillboard {
		// 查询有已归类行业报告的行业IDs
		activeIndustryIds, e := models.GetActiveArticleIndustryIds()
		if e != nil {
			br.Msg = "获取失败"
			br.ErrMsg = "获取已归类行业失败, Err:" + e.Error()
			return
		}
		activeIndustryLen := len(activeIndustryIds)
		//topNum := pageSize
		condition = ""
		var parsBd []interface{}
		if ChartPermissionId > 0 {
			condition += ` 	AND man.chart_permission_id = ?  `
			parsBd = append(parsBd, ChartPermissionId)
		}
		if activeIndustryLen > 0 {
			condition += ` AND man.industrial_management_id IN (` + utils.GetOrmInReplace(activeIndustryLen) + `)`
			parsBd = append(parsBd, activeIndustryIds)
		}
		//nowTime := time.Now().Local()
		//startTime := nowTime.AddDate(0, -1, 0)
		//endTime := nowTime.AddDate(0, 0, -1)
		//condition += ` AND idf.create_time BETWEEN ? AND ?`
		//parsBd = append(parsBd, startTime, endTime)
		list, e = models.GetTopIndustryFollowData(uid, 0, pageSize, condition, parsBd)
		if e != nil {
			br.Msg = "获取失败"
			br.ErrMsg = "获取关注度最高的产业数据失败, Err:" + e.Error()
			return
		}
	} else {
		list, err = models.GetIndustrialManagementAll(uid, condition, orderSrt, startSize, pageSize, isBillboard)
		if err != nil {
			br.Msg = "获取信息失败"
			br.ErrMsg = "获取品种信息失败,Err:" + err.Error()
			return
		}
	}

	var resource string
	if ChartPermissionId == utils.CHART_PERMISSION_ID_YANXUAN {
		resource = utils.REOURCE_YX
	} else {
		resource = utils.REOURCE_HZ
	}
	list, err = services.HandleIndustryList(list, user, resource)
	if err != nil {
		br.Msg = "获取信息失败"
		br.ErrMsg = "获取信息失败,Err:" + err.Error()
		return
	}
	industrialIdArr := make([]int, 0)
	for k, v := range list {
		industrialIdArr = append(industrialIdArr, v.IndustrialManagementId)
		if topReadIndustryId > 0 && list[k].IndustrialManagementId == topReadIndustryId {
			list[k].IsHot = true
		}
	}
	if orderColumnNew != "" {
		item := new(models.CygxReportIndustrialSeaarchHistory)
		item.UserId = user.UserId
		item.Mobile = user.Mobile
		item.CompanyId = user.CompanyId
		item.CompanyName = user.CompanyName
		item.CreateTime = time.Now()
		item.IsDeepLabel = isDeepLabel
		item.IsNewLabel = isNewLabel
		item.ChartPermissionId = ChartPermissionId
		if orderColumnNew == "NewTime" {
			item.OrderColumn = "0"
		} else {
			item.OrderColumn = "1"
		}
		go models.AddCygxReportIndustrialSeaarchHistory(item)
	}
	if len(list) == 0 {
		list = make([]*models.IndustrialManagement, 0)
	}
	page := paging.GetPaging(currentIndex, pageSize, total)
	if isBillboard {
		total = len(list)
	}
	resp.List = list
	resp.Paging = page
	br.Ret = 200
	br.Success = true
	br.Msg = "获取成功"
	br.Data = resp
}

// @Title 产业下所关联的文章分类列表
// @Description 产业下所关联的文章分类列表接口
// @Param   IndustrialManagementId   query   int  true       "产业ID"
// @Success 200 {object} models.IndustrialToArticleCategoryListRep
// @router /toArticleCategoryList [get]
func (this *MobileReportController) ArticleCategoryList() {
	br := new(models.BaseResponse).Init()
	defer func() {
		this.Data["json"] = br
		this.ServeJSON()
	}()
	user := this.User
	if user == nil {
		br.Msg = "请重新登录"
		br.Ret = 408
		return
	}
	//uid := user.UserId
	industrialManagementId, _ := this.GetInt("IndustrialManagementId")
	if industrialManagementId < 1 {
		br.Msg = "请输入分类ID"
		return
	}

	detail, err := models.GetIndustrialManagementDetail(industrialManagementId)
	if err != nil {
		br.Msg = "获取信息失败"
		br.ErrMsg = "获取信息失败,Err:" + err.Error()
		return
	}
	listCategory, err := models.IndustrialToArticleAndProductInteriorCategoryNew(industrialManagementId)
	if err != nil {
		br.Msg = "获取信息失败"
		br.ErrMsg = "获取品种信息失败,Err:" + err.Error()
		return
	}
	var list []*models.IndustrialToArticleCategoryRep
	categoryMap := make(map[int]int)
	for _, v := range listCategory {
		if categoryMap[v.CategoryId] > 0 {
			continue
		}
		categoryMap[v.CategoryId] = v.CategoryId
		list = append(list, v)
	}
	//标的列表
	industrialSubjectList, err := models.GetIndustrialArticleGroupSubjectListByHz(industrialManagementId)
	if err != nil {
		br.Msg = "获取信息失败"
		br.ErrMsg = "获取品种信息失败,Err:" + err.Error()
		return
	}
	videoSimple, au, err := services.GetindustryVideo(user, industrialManagementId)
	if err != nil {
		br.Msg = "获取失败"
		br.ErrMsg = "获取用户权限失败, Err: " + err.Error()
		return
	}
	timeLineItem := models.IndustrialToArticleCategoryRep{
		CategoryId:    utils.TIME_CATEGORYID,
		MatchTypeName: "时间线",
	}
	timeLineIsRed, err := services.GetShowTimeLineIsRed(user, industrialManagementId)
	if err != nil {
		br.Msg = "获取失败"
		br.ErrMsg = "获取用户权限失败, Err: " + err.Error()
		return
	}
	followTypeMap := services.GetCygxIndustryFllowListTypeMapByMobile(user.Mobile) // 关注的对应状态
	timeLineItem.IsRed = timeLineIsRed
	list = append([]*models.IndustrialToArticleCategoryRep{&timeLineItem}, list...)
	resp := new(models.IndustrialToArticleCategoryListRep)
	resp.List = list
	resp.ListSubject = industrialSubjectList
	resp.LayoutTime = utils.TimeRemoveHms(detail.LayoutTime)
	resp.IndustryName = detail.IndustryName
	resp.IndustrialManagementId = industrialManagementId
	if videoSimple != nil && videoSimple.Id > 0 {
		resp.IndustryVideo = videoSimple
	}
	resp.AuthInfo = au
	resp.FollowType = followTypeMap[industrialManagementId]
	br.Ret = 200
	br.Success = true
	br.Msg = "获取成功"
	br.Data = resp
}

// @Title 根据行业分类获取文章列表
// @Description根据行业分类获取文章列表接口
// @Param   PageSize   query   int  true       "每页数据条数"
// @Param   CurrentIndex   query   int  true       "当前页页码，从1开始"
// @Param   CategoryId   query   int  true       "分类ID"
// @Param   IndustrialManagementId   query   int  false       "产业ID"
// @Success 200 {object} models.TacticsListResp
// @router /articleList/byCategoryId [get]
func (this *MobileReportController) List() {
	br := new(models.BaseResponse).Init()
	defer func() {
		this.Data["json"] = br
		this.ServeJSON()
	}()
	user := this.User
	if user == nil {
		br.Msg = "请重新登录"
		br.Ret = 408
		return
	}
	//uid := user.UserId
	pageSize, _ := this.GetInt("PageSize")
	currentIndex, _ := this.GetInt("CurrentIndex")
	categoryId, _ := this.GetInt("CategoryId")
	industrialManagementId, _ := this.GetInt("IndustrialManagementId")
	uid := user.UserId
	var startSize int
	if pageSize <= 0 {
		pageSize = utils.PageSize20
	}
	if currentIndex <= 0 {
		currentIndex = 1
	}
	startSize = paging.StartIndex(currentIndex, pageSize)
	//var condition string
	var pars []interface{}
	var total int
	resp := new(models.TacticsListResp)
	page := paging.GetPaging(currentIndex, pageSize, total)
	list := make([]*models.ArticleListResp, 0)

	if categoryId == utils.TIME_CATEGORYID {
		var err error
		list, total, err = models.GetTimeLineReportIndustrialList(industrialManagementId, startSize, pageSize)
		if err != nil {
			br.Msg = "获取信息失败"
			br.ErrMsg = "获取产业报告+晨会点评列表,Err:" + err.Error()
			return
		}
	} else {
		//获取该产业下所对应的行业图片
		//var reportType int
		//if industrialManagementId > 0 {
		//	reportType = 2
		//} else {
		//	reportType = 1
		//}
		//detail, errCategory := models.GetdetailByCategoryIdOne(categoryId, reportType)
		//if errCategory != nil {
		//	br.Msg = "获取信息失败"
		//	br.ErrMsg = "获取信息失败,Err:" + errCategory.Error() + "categoryID 不存在：" + strconv.Itoa(categoryId)
		//	return
		//}
		//对应行业的图片
		detailChartPermissionUrl, err := models.GetConfigByCode("category_chart_permissionimg_url")
		if err != nil {
			br.Msg = "获取数据失败"
			br.ErrMsg = "行业配置信息失败，Err:" + err.Error()
			return
		}
		chartPermissionUrlList := strings.Split(detailChartPermissionUrl.ConfigValue, "{|}")
		mapChartPermission := make(map[string]string)
		var permissionName string
		var imgUrlChartPermission string
		for _, v := range chartPermissionUrlList {
			vslice := strings.Split(v, "_")
			permissionName = vslice[0]
			imgUrlChartPermission = vslice[len(vslice)-1]
			mapChartPermission[permissionName] = imgUrlChartPermission
		}

		//对应分类的所图片
		detailCategoryUrl, err := models.GetConfigByCode("category_map_img_url")
		if err != nil {
			br.Msg = "获取数据失败"
			br.ErrMsg = "行业配置信息失败，Err:" + err.Error()
			return
		}
		categoryUrlList := strings.Split(detailCategoryUrl.ConfigValue, "{|}")
		mapCategoryUrl := make(map[string]string)
		var categoryIdStr string
		var imgUrlChart string
		for _, v := range categoryUrlList {
			vslice := strings.Split(v, "_")
			categoryIdStr = vslice[0]
			imgUrlChart = vslice[len(vslice)-1]
			mapCategoryUrl[categoryIdStr] = imgUrlChart
		}

		list, total, err = models.GetReportAndproductInteriorIndustrialList(pars, categoryId, industrialManagementId, uid, startSize, pageSize)
		if err != nil {
			br.Msg = "获取信息失败"
			br.ErrMsg = "获取帖子数据失败，Err:" + err.Error()
			return
		}

		articleIdMap, err := services.GetUserArticleHistoryRecord(user)
		if err != nil {
			br.Msg = "获取信息失败"
			br.Msg = "获取帖子数据失败，Err:" + err.Error()
			return
		}
		for k, v := range list {
			list[k].ImgUrlPc = mapCategoryUrl[v.CategoryId]
			if !articleIdMap[v.ArticleId] && user.CreatedTime.Before(utils.StrTimeToTime(v.PublishDate)) && utils.StrTimeToTime(utils.OnlineTime).Before(utils.StrTimeToTime(v.PublishDate)) {
				list[k].IsRed = true
			}
		}
	}

	listPublic, err := services.HandleArticleCategoryImg(list, user)
	if err != nil {
		br.Msg = "获取失败"
		br.ErrMsg = "获取报告封面图片失败, Err:" + err.Error()
		return
	}
	var articleIds []int
	for _, v := range listPublic {
		if v.Resource == 1 {
			articleIds = append(articleIds, v.ArticleId)
		}
	}

	articleMapPv := services.GetArticleHistoryByArticleId(articleIds)                       //文章Pv
	articleCollectMap, _ := services.GetCygxArticleCollectMap(user.UserId)                  //用户收藏的文章
	articleCollectNumMap, _ := services.GetCygxArticleCollectNumMapByArtcileIds(articleIds) //文章收藏的数量
	listResp := make([]*models.HomeArticle, 0)
	//listResp :=
	for _, v := range listPublic {
		listResp = append(listResp, &models.HomeArticle{
			ArticleId:   v.ArticleId,
			Title:       v.Title,
			Annotation:  "核心观点：" + v.Annotation,
			Abstract:    v.Abstract,
			ImgUrlPc:    v.ImgUrlPc,
			PublishDate: v.PublishDate,
			Resource:    v.Resource,
			Pv:          articleMapPv[v.ArticleId],
			IsCollect:   articleCollectMap[v.ArticleId],
			CollectNum:  articleCollectNumMap[v.ArticleId],
		})
	}
	//lenList := len(list)
	//for i := 0; i < lenList; i++ {
	//	item := list[i]
	//	list[i].Body = ""
	//	list[i].Abstract, _ = services.GetReportContentTextSub(item.Abstract)
	//	list[i].Annotation, _ = services.GetReportContentTextSub(item.Annotation)
	//	list[i].PublishDate = utils.StrTimeToTime(item.PublishDate).Format(utils.FormatDate) //时间字符串格式转时间格式
	//	//行业比较研究、资金流向，显示报告的摘要
	//	if resp.MatchTypeName == "行业比较研究" || resp.MatchTypeName == "资金流向" {
	//		list[i].Annotation = list[i].Abstract
	//	}
	//}
	if len(listResp) == 0 {
		listResp = make([]*models.HomeArticle, 0)
	}
	page = paging.GetPaging(currentIndex, pageSize, total)
	resp.List = listResp
	resp.Paging = page
	br.Ret = 200
	br.Success = true
	br.Msg = "获取成功"
	br.Data = resp
}

// @Title 产业关注/取消关注
// @Description 产业关注/取消关注 接口
// @Param	request	body models.CygxIndustryFllowRep true "type json string"
// @Success 200
// @router /industrial/fllow [post]
func (this *ReportController) IndustrialFllow() {
	br := new(models.BaseResponse).Init()
	defer func() {
		this.Data["json"] = br
		this.ServeJSON()
	}()
	user := this.User
	if user == nil {
		br.Msg = "请重新登录"
		br.Ret = 408
		return
	}
	uid := user.UserId
	var req models.CygxIndustryFllowRep
	err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
	if err != nil {
		br.Msg = "参数解析异常！"
		br.ErrMsg = "参数解析失败，Err:" + err.Error()
		return
	}
	industrialManagementId := req.IndustrialManagementId
	followType := req.FollowType
	var condition string
	countIndustrial, err := models.GetIndustrialManagementCount(industrialManagementId)
	if err != nil {
		br.Msg = "获取数据失败！"
		br.ErrMsg = "获取数据失败，Err:" + err.Error()
		return
	}
	if countIndustrial == 0 {
		br.Msg = "产业不存在！"
		br.ErrMsg = "产业ID不存在:" + strconv.Itoa(industrialManagementId)
		return
	}
	count, err := models.GetCountCygxIndustryFllow(industrialManagementId, user.UserId, condition)
	if err != nil {
		br.Msg = "获取数据失败！"
		br.ErrMsg = "获取数据失败，Err:" + err.Error()
		return
	}
	resp := new(models.CygxIndustryFllowResp)
	item := new(models.CygxIndustryFllow)
	item.IndustrialManagementId = industrialManagementId
	item.FollowType = followType
	item.UserId = uid
	item.Email = user.Email
	item.Mobile = user.Mobile
	item.RealName = user.RealName
	item.Source = utils.REGISTER_PLATFORM
	item.CompanyId = user.CompanyId
	item.CompanyName = user.CompanyName
	if followType == 3 {
		item.FollowTypeOrder = -1
	} else {
		item.FollowTypeOrder = followType
	}
	//if count == 0 {
	item.Type = 1
	item.CreateTime = time.Now()
	item.ModifyTime = time.Now()
	_, err = models.AddCygxIndustryFllow(item)
	if err != nil {
		br.Msg = "操作失败"
		br.ErrMsg = "操作失败,Err:" + err.Error()
		return
	}
	resp.Status = followType
	br.Msg = "操作成功"
	//} else {
	//	err = models.RemoveCygxIndustryFllow(uid, industrialManagementId)
	//	if err != nil {
	//		br.Msg = "操作失败"
	//		br.ErrMsg = "取消关注失败,Err:" + err.Error()
	//		return
	//	}
	//	resp.Status = 2
	//	br.Msg = "已取消关注"
	//}
	//处理是否关注全部赛道字段
	//go services.IndustryFllowWithTrack(industrialManagementId, count, uid)
	go services.IndustryFllowUserLabelLogAdd(industrialManagementId, count, uid) //处理用户标签
	go services.AddCygxIndustryFllowLog(item)                                    //添加操作日志记录
	br.Ret = 200
	br.Success = true
	br.Data = resp
}

// @Title 行业关注/取消关注
// @Description 行业关注/取消关注 接口
// @Param	request	body models.CygxCategoryFllowRep true "type json string"
// @Success 200
// @router /category/fllow [post]
func (this *ReportController) CategoryFllow() {
	br := new(models.BaseResponse).Init()
	defer func() {
		this.Data["json"] = br
		this.ServeJSON()
	}()
	user := this.User
	if user == nil {
		br.Msg = "请重新登录"
		br.Ret = 408
		return
	}
	uid := user.UserId
	var req models.CygxCategoryFllowRep
	err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
	if err != nil {
		br.Msg = "参数解析异常！"
		br.ErrMsg = "参数解析失败，Err:" + err.Error()
		return
	}
	categoryId := req.CategoryId
	followType := req.FollowType
	var condition string
	//countCategory, err := models.GetCategoryCount(categoryId)
	//if err != nil {
	//	br.Msg = "获取数据失败！"
	//	br.ErrMsg = "获取数据失败，Err:" + err.Error()
	//	return
	//}
	//if countCategory == 0 {
	//	br.Msg = "产业不存在！"
	//	br.ErrMsg = "产业ID不存在:" + strconv.Itoa(categoryId)
	//	return
	//}
	listMap, err := models.GetCygxXzsChooseCategoryMapList()
	if err != nil {
		br.Msg = "操作失败！"
		br.ErrMsg = "获取数据失败，Err:" + err.Error()
		return
	}
	mapReport := make(map[int]int)
	for _, v := range listMap {
		mapReport[v.Id] = v.CategoryId
	}
	if mapReport[categoryId] == 0 {
		br.Msg = "操作失败！"
		br.ErrMsg = "分类ID不存在，ID:" + strconv.Itoa(categoryId)
		return
	}

	count, err := models.GetCountCategoryFllow(mapReport[categoryId], user.Mobile, condition)
	if err != nil {
		br.Msg = "获取数据失败！"
		br.ErrMsg = "获取数据失败，Err:" + err.Error()
		return
	}
	resp := new(models.CygxIndustryFllowResp)
	//if count == 0 {
	item := new(models.CygxXzsChooseCategory)
	item.CategoryId = mapReport[categoryId]
	item.IdCygx = categoryId
	item.UserId = uid
	item.Email = user.Email
	item.Mobile = user.Mobile
	item.RealName = user.RealName
	item.CompanyId = user.CompanyId
	item.CompanyName = user.CompanyName
	item.FollowType = followType
	item.CreateTime = time.Now()
	item.ModifyTime = time.Now()
	_, err = models.AddCygxCategoryFllow(item)
	if err != nil {
		br.Msg = "操作失败"
		br.ErrMsg = "操作失败,Err:" + err.Error()
		return
	}
	resp.Status = followType
	br.Msg = "操作成功"
	//} else {
	//err = models.RemoveCygxCategoryFllow(user.Mobile, mapReport[categoryId])
	//	if err != nil {
	//		br.Msg = "操作失败"
	//		br.ErrMsg = "取消关注失败,Err:" + err.Error()
	//		return
	//	}
	//	resp.Status = 2
	//	br.Msg = "已取消关注"
	//}
	go services.CategoryFllowUserLabelLogAdd(categoryId, count, uid) //处理用户标签
	br.Ret = 200
	br.Success = true
	br.Data = resp
}

// @Title 报告搜索
// @Description 报告搜索接口
// @Param   PageSize   query   int  true       "每页数据条数"
// @Param   CurrentIndex   query   int  true       "当前页页码，从1开始"
// @Param   KeyWord   query   string  true       "搜索关键词"
// @Param   ArticleType   query   int  true       "文章类型，1弘则报告、2研选 "
// @Param   IsAll   query   bool  true       "是否为综合 "
// @Success 200 {object} models.ReoprtSearchResp
// @router /searchReport [get]
func (this *MobileReportController) SearchReport() {
	br := new(models.BaseResponse).Init()
	defer func() {
		this.Data["json"] = br
		this.ServeJSON()
	}()
	user := this.User
	if user == nil {
		br.Msg = "请重新登录"
		br.Ret = 408
		return
	}
	pageSize, _ := this.GetInt("PageSize")
	currentIndex, _ := this.GetInt("CurrentIndex")
	articleType, _ := this.GetInt("ArticleType", 1)
	keyWord := this.GetString("KeyWord")
	isAll, _ := this.GetBool("IsAll")
	var condition string
	var conditionYxSpecial string
	var pars []interface{}
	//var conditionSql string
	var total int
	var startSize int
	if pageSize <= 0 {
		pageSize = utils.PageSize20
	}
	if isAll {
		pageSize = utils.PageSize5
	}
	if currentIndex <= 0 {
		currentIndex = 1
	}
	startSize = paging.StartIndex(currentIndex, pageSize)

	resp := new(models.ReoprtSearchResp)
	//匹配报告标题、
	articleTypeIds, err := services.GetYanXuanArticleTypeIds()
	if err != nil {
		br.Msg = "获取信息失败"
		br.ErrMsg = "GetYanXuanArticleTypeIds,Err:" + err.Error()
		return
	}
	if articleTypeIds == "" {
		br.Msg = "获取信息失败"
		br.ErrMsg = "研选分类ID不能为空"
		return
	}
	//处理对应的文章类型标签按钮
	nameMap, styleMap, err := services.GetArticleTypeMap()
	if err != nil {
		br.Msg = "获取信息失败"
		br.ErrMsg = "GetArticleTypeMap Err:" + err.Error()
		return
	}
	if isAll {
		total = utils.PageSize5
		conditionHz := `  AND ( a.title LIKE '%` + keyWord + `%' OR  a.body LIKE '%` + keyWord + `%' OR  a.annotation LIKE '%` + keyWord + `%' OR  a.abstract LIKE '%` + keyWord + `%') AND a.publish_status = 1  AND a.article_type_id NOT IN (` + articleTypeIds + `)  `
		conditionYx := `  AND ( a.title LIKE '%` + keyWord + `%' OR  a.body LIKE '%` + keyWord + `%' OR  a.annotation LIKE '%` + keyWord + `%' OR  a.abstract LIKE '%` + keyWord + `%') AND a.publish_status = 1  AND a.article_type_id  IN (` + articleTypeIds + `)  `

		listHz, err := models.GetArticleResearchListHz(conditionHz, pars, startSize, pageSize, user.UserId)
		if err != nil {
			br.Msg = "获取信息失败"
			br.ErrMsg = "获取品种信息失败,Err:" + err.Error()
			return
		}
		listYx, err := models.GetArticleResearchList(conditionYx, pars, startSize, pageSize, user.UserId, true)
		if err != nil {
			br.Msg = "获取信息失败"
			br.ErrMsg = "获取品种信息失败,Err:" + err.Error()
			return
		}

		listHz, err = services.HandleArticleCategoryImg(listHz, user)
		if err != nil {
			br.Msg = "获取信息失败"
			br.ErrMsg = "HandleArticleCategoryImg,Err:" + err.Error()
			return
		}

		listYx, err = services.HandleArticleCategoryImg(listYx, user)
		if err != nil {
			br.Msg = "获取信息失败"
			br.ErrMsg = "HandleArticleCategoryImg,Err:" + err.Error()
			return
		}

		for _, v := range listHz {
			item := models.ArticleResearchResp{
				ArticleId:       v.ArticleId,
				ArticleTypeId:   v.ArticleTypeId,
				Title:           v.Title,
				PublishDate:     v.PublishDate,
				DepartmentId:    v.DepartmentId,
				NickName:        v.NickName,
				IsCollect:       v.IsCollect,
				Pv:              v.Pv,
				CollectNum:      v.CollectNum,
				Abstract:        v.Abstract,
				Annotation:      v.Annotation,
				ImgUrlPc:        v.ImgUrlPc,
				ArticleTypeName: nameMap[v.ArticleTypeId],
				ButtonStyle:     styleMap[v.ArticleTypeId],
				List:            v.List,
			}
			if v.ReportId > 0 {
				item.Resource = 3
				item.ReportId = v.ReportId
			}
			resp.ListHz = append(resp.ListHz, &item)
		}

		for _, v := range listYx {
			item := models.ArticleResearchResp{
				ArticleId:       v.ArticleId,
				ArticleTypeId:   v.ArticleTypeId,
				Title:           v.Title,
				PublishDate:     v.PublishDate,
				DepartmentId:    v.DepartmentId,
				NickName:        v.NickName,
				IsCollect:       v.IsCollect,
				Pv:              v.Pv,
				CollectNum:      v.CollectNum,
				Abstract:        v.Abstract,
				Annotation:      v.Annotation,
				ImgUrlPc:        v.ImgUrlPc,
				ArticleTypeName: nameMap[v.ArticleTypeId],
				ButtonStyle:     styleMap[v.ArticleTypeId],
				List:            v.List,
			}
			resp.ListYx = append(resp.ListYx, &item)
		}
	} else {

		if keyWord != "" {
			if articleType == 1 {
				condition = `  AND ( a.title LIKE '%` + keyWord + `%' OR  a.body LIKE '%` + keyWord + `%' OR  a.annotation LIKE '%` + keyWord + `%' OR  a.abstract LIKE '%` + keyWord + `%') AND a.publish_status = 1  AND a.article_type_id NOT IN (` + articleTypeIds + `)  `
				total, err = models.GetReoprtSearchCountHz(condition)
			} else {
				condition = `  AND ( a.title LIKE '%` + keyWord + `%' OR  a.body LIKE '%` + keyWord + `%' OR  a.annotation LIKE '%` + keyWord + `%' OR  a.abstract LIKE '%` + keyWord + `%') AND a.publish_status = 1  AND a.article_type_id  IN (` + articleTypeIds + `)  `
				total, err = models.GetReoprtSearchCountYx(condition)
			}

			conditionYxSpecial = `   AND ( a.title LIKE '%` + keyWord + `%' OR  a.content LIKE '%` + keyWord + `%')  `
		}
		if err != nil {
			br.Msg = "获取信息失败"
			br.Msg = "获取总数失败，Err:" + err.Error()
			return
		}
		var list []*models.ArticleListResp
		//list := new([]models.ArticleResearchResp)
		if articleType == 1 {
			list, err = models.GetArticleResearchListHz(condition, pars, startSize, pageSize, user.UserId)
		} else {
			total, list, err = models.GetArticleResearchAndYxSpecialList(condition, conditionYxSpecial, pars, startSize, pageSize, user.UserId, true)
		}
		if err != nil {
			br.Msg = "获取信息失败"
			br.ErrMsg = "获取品种信息失败,Err:" + err.Error()
			return
		}
		//return
		list, err = services.HandleArticleCategoryImg(list, user)
		if err != nil {
			br.Msg = "获取信息失败"
			br.ErrMsg = "HandleArticleCategoryImg,Err:" + err.Error()
			return
		}

		for _, v := range list {
			item := models.ArticleResearchResp{
				ArticleId:       v.ArticleId,
				ArticleTypeId:   v.ArticleTypeId,
				Title:           v.Title,
				PublishDate:     v.PublishDate,
				DepartmentId:    v.DepartmentId,
				NickName:        v.NickName,
				IsCollect:       v.IsCollect,
				Pv:              v.Pv,
				CollectNum:      v.CollectNum,
				Abstract:        v.Abstract,
				Annotation:      v.Annotation,
				ImgUrlPc:        v.ImgUrlPc,
				ArticleTypeName: nameMap[v.ArticleTypeId],
				ButtonStyle:     styleMap[v.ArticleTypeId],
				List:            v.List,
			}
			if v.ReportId > 0 {
				item.Resource = 3
				item.ReportId = v.ReportId
			}
			if v.IsSpecial == 1 {
				//去除图片标签
				item.Annotation = utils.ArticleRemoveImgUrl(item.Annotation)

				item.IsSpecial = true
				item.ImgUrlPc = utils.CYGX_YANXUAN_SPECIAL_IMG_PC
				if v.CompanyTags != "" {
					item.CompanyTags = strings.Split(v.CompanyTags, ",")
				} else {
					item.CompanyTags = []string{}
				}
				if v.IndustryTags != "" {
					item.IndustryTags = strings.Split(v.IndustryTags, ",")
				} else {
					item.IndustryTags = []string{}
				}
				item.ArticleTypeName = utils.CYGX_YANXUAN_SPECIAL
				if v.SpecialType == 1 {
					item.Title = "【笔记】" + item.Title
				} else if v.SpecialType == 2 {
					item.Title = "【观点】" + item.Title
				}
				if v.MyCollectNum > 0 {
					item.IsCollect = true
				}
			}
			if articleType == 1 {
				resp.ListHz = append(resp.ListHz, &item)
			} else {
				resp.ListYx = append(resp.ListYx, &item)
			}
		}
	}

	if keyWord != "" {
		//go services.AddUserSearchLog(user, keyWord, 5)
	}
	if len(resp.ListHz) == 0 {
		resp.ListHz = make([]*models.ArticleResearchResp, 0)
	}
	if len(resp.ListYx) == 0 {
		resp.ListYx = make([]*models.ArticleResearchResp, 0)
	}
	page := paging.GetPaging(currentIndex, pageSize, total)
	resp.Paging = page
	br.Ret = 200
	br.Success = true
	br.Msg = "获取成功"
	br.Data = resp
}

// @Title 资源包搜索
// @Description 资源包搜索接口
// @Param   KeyWord   query   string  true       "搜索关键词"
// @Success 200 {object} models.SearchResourceResp
// @router /searchResource [get]
func (this *MobileReportController) SearchResource() {
	br := new(models.BaseResponse).Init()
	defer func() {
		this.Data["json"] = br
		this.ServeJSON()
	}()
	user := this.User
	if user == nil {
		br.Msg = "请重新登录"
		br.Ret = 408
		return
	}
	uid := user.UserId
	fllowList, err := models.GetUserFllowIndustrialList(uid)
	if err != nil {
		br.Msg = "获取失败"
		br.ErrMsg = "获取失败，GetUserFllowIndustrialList Err:" + err.Error()
		return
	}
	fllowMap := make(map[int]int)
	if len(fllowList) > 0 {
		for _, v := range fllowList {
			fllowMap[v.IndustrialManagementId] = v.IndustrialManagementId
		}
	}
	keyWord := this.GetString("KeyWord")
	var condition string

	articleTypeIds, err := services.GetYanXuanArticleTypeIds()
	if err != nil {
		br.Msg = "获取信息失败"
		br.ErrMsg = "GetYanXuanArticleTypeIds,Err:" + err.Error()
		return
	}
	if articleTypeIds == "" {
		br.Msg = "获取信息失败"
		br.ErrMsg = "研选分类ID不能为空"
		return
	}

	condition = `  AND a.publish_status = 1 AND a.article_type_id NOT IN (` + articleTypeIds + `)  AND (m.industry_name LIKE '%` + keyWord + `%' OR m.subject_names LIKE '%` + keyWord + `%'  )  `
	listHz, err := models.GetSearchResourceList(condition)
	if err != nil {
		br.Msg = "获取信息失败"
		br.ErrMsg = "获取品种信息失败,Err:" + err.Error()
		return
	}

	condition = `  AND a.publish_status = 1 AND a.article_type_id IN (` + articleTypeIds + `)  AND (m.industry_name LIKE '%` + keyWord + `%' OR m.subject_names LIKE '%` + keyWord + `%'  )  `
	listYx, err := models.GetSearchResourceList(condition)
	if err != nil {
		br.Msg = "获取信息失败"
		br.ErrMsg = "获取品种信息失败,Err:" + err.Error()
		return
	}

	if len(listYx) > 0 {
		listYx, err = services.HandleIndustryList(listYx, user, "Yx")
		if err != nil {
			br.Msg = "获取信息失败"
			br.ErrMsg = "获取信息失败,Err:" + err.Error()
			return
		}
	}
	if len(listHz) > 0 {
		listHz, err = services.HandleIndustryList(listHz, user, "Hz")
		if err != nil {
			br.Msg = "获取信息失败"
			br.ErrMsg = "获取信息失败,Err:" + err.Error()
			return
		}
	}
	if keyWord != "" {
		//go services.AddUserSearchLog(user, keyWord, 4)
	}
	resp := new(models.SearchResourceResp)
	if len(listHz) == 0 {
		listHz = make([]*models.IndustrialManagement, 0)
	}
	if len(listYx) == 0 {
		listYx = make([]*models.IndustrialManagement, 0)
	}
	resp.ListHz = listHz
	resp.ListYx = listYx
	br.Ret = 200
	br.Success = true
	br.Msg = "获取成功"
	br.Data = resp
}

// @Title 报告搜索、资源包搜索接口
// @Description 报告搜索、资源包搜索接口接口
// @Param   KeyWord   query   string  true       "搜索关键词"
// @Param   PageSize   query   int  true       "每页数据条数"
// @Param   CurrentIndex   query   int  true       "当前页页码，从1开始"
// @Param   SearchType   query   int  true       "1：综合，2：全部"
// @Success 200 {object} models.SearchReportAndResourceResp
// @router /searchReportAndResource [get]
func (this *MobileReportController) SearchReportAndResource() {
	br := new(models.BaseResponse).Init()
	defer func() {
		this.Data["json"] = br
		this.ServeJSON()
	}()
	user := this.User
	if user == nil {
		br.Msg = "请重新登录"
		br.Ret = 408
		return
	}
	//uid := user.UserId
	keyWord := this.GetString("KeyWord")
	pageSize, _ := this.GetInt("PageSize")
	currentIndex, _ := this.GetInt("CurrentIndex")
	searchType, _ := this.GetInt("SearchType")
	var total int
	var startSize int
	if pageSize <= 0 {
		pageSize = utils.PageSize20
	}
	if currentIndex <= 0 {
		currentIndex = 1
	}
	startSize = paging.StartIndex(currentIndex, pageSize)
	page := paging.GetPaging(currentIndex, pageSize, total)
	var condition string
	var conditionSql string
	//匹配报告标题、
	condition = ` AND ( a.title LIKE '%` + keyWord + `%' OR  a.body LIKE '%` + keyWord + `%') AND a.publish_status = 1 `
	conditionSql = ` AND a.article_id <  ` + strconv.Itoa(utils.SummaryArticleId) + condition + ` OR ( article_type = 'lyjh' ` + condition + ` ) `
	total, err := models.GetReoprtSearchCount(conditionSql)
	if err != nil {
		br.Msg = "获取信息失败"
		br.Msg = "获取总数失败，Err:" + err.Error()
		return
	}
	if searchType == 1 {
		pageSize = utils.PageSize5
	}
	ListHzReport, err := services.GetReoprtSearchListHz(conditionSql, user.UserId, startSize, pageSize)
	if err != nil {
		br.Msg = "获取失败"
		br.ErrMsg = "获取失败，GetReoprtSearchListHz Err:" + err.Error()
		return
	}
	if len(ListHzReport) == 0 {
		ListHzReport = make([]*models.ArticleCollectionResp, 0)
	}
	var conditionOr string
	conditionOr += ` OR ( m.subject_names LIKE '%` + keyWord + `%' AND a.article_id < ` + strconv.Itoa(utils.SummaryArticleId) + `  AND publish_status = 1 ) `
	condition = ` AND m.industry_name LIKE '%` + keyWord + `%' AND a.article_id < ` + strconv.Itoa(utils.SummaryArticleId) + conditionOr
	listHzResource, err := services.GetSearchResourceListHz(condition, user)
	if err != nil {
		br.Msg = "获取信息失败"
		br.ErrMsg = "获取品种信息失败,Err:" + err.Error()
		return
	}
	resp := new(models.SearchReportAndResourceResp)
	if len(listHzResource) == 0 {
		listHzResource = make([]*models.IndustrialManagement, 0)
	}
	if keyWord != "" {
		//go services.AddUserSearchLog(user, keyWord, 5)
	}
	page = paging.GetPaging(currentIndex, pageSize, total)
	resp.Paging = page
	resp.ListHzResource = listHzResource
	resp.ListHzReport = ListHzReport
	br.Ret = 200
	br.Success = true
	br.Msg = "获取成功"
	br.Data = resp
}

// @Title 公司速览
// @Description 公司速览接口
// @Param   ChartPermissionId   query   int  false       "分类ID"
// @Success 200 {object} models.ArticleDataLogoListResp
// @router /companyList [get]
func (this *ReportCommonController) CompanyList() {
	br := new(models.BaseResponse).Init()
	defer func() {
		this.Data["json"] = br
		this.ServeJSON()
	}()
	var condition string
	var pars []interface{}
	chartPermissionId, _ := this.GetInt("ChartPermissionId")
	if chartPermissionId > 1 {
		categoryId, err := models.GetCategoryId(chartPermissionId)
		if err != nil && err.Error() != utils.ErrNoRow() {
			br.Msg = "获取信息失败"
			br.ErrMsg = "获取分类权限信息失败，Err:" + err.Error()
			return
		}
		if categoryId != "" {
			condition += ` AND a.category_id IN  (` + categoryId + `)`
		}
	}
	condition += ` 	AND a.type_name = '综述报告'   ORDER BY  a.modify_time_by_cl DESC  `
	list, err := models.CygxArticleDataList(condition, pars)
	if err != nil {
		br.Msg = "获取失败"
		br.ErrMsg = "获取报告封面图片失败, Err:" + err.Error()
		return
	}
	listLogo := make([]*models.ArticleDataLogoResp, 0)
	for i := range list {
		v := list[i]
		comapnyList := services.HandleArticleStock(v.Stock)
		if len(comapnyList) > 1 {
			for kC, vC := range comapnyList {
				sliceCovers := strings.Split(v.Cover, "{|}")
				cover := v.Cover
				if len(sliceCovers) == len(comapnyList) {
					cover = sliceCovers[kC]
				}
				listLogo = append(listLogo, &models.ArticleDataLogoResp{
					ArticleId:   v.ArticleId,
					Cover:       cover,
					ComapnyList: services.HandleArticleStock(vC.ComapnyName),
				})
			}
		} else {
			listLogo = append(listLogo, &models.ArticleDataLogoResp{
				ArticleId:   v.ArticleId,
				Cover:       v.Cover,
				ComapnyList: services.HandleArticleStock(v.Stock),
			})
		}

	}
	resp := new(models.ArticleDataLogoListResp)
	resp.List = listLogo
	br.Ret = 200
	br.Success = true
	br.Msg = "获取成功"
	br.Data = resp
}

// @Title 时间线
// @Description 时间线接口
// @Param   PageSize   query   int  true       "每页数据条数"
// @Param   CurrentIndex   query   int  true       "当前页页码，从1开始"
// @Param   IndustrialManagementId   query   int  false       "产业ID"
// @Success 200 {object} models.TacticsListResp
// @router /timeline [get]
func (this *MobileReportController) Timeline() {
	br := new(models.BaseResponse).Init()
	defer func() {
		this.Data["json"] = br
		this.ServeJSON()
	}()
	user := this.User
	if user == nil {
		br.Msg = "请重新登录"
		br.Ret = 408
		return
	}
	pageSize, _ := this.GetInt("PageSize")
	currentIndex, _ := this.GetInt("CurrentIndex")
	industrialManagementId, _ := this.GetInt("IndustrialManagementId")
	var startSize int
	if pageSize <= 0 {
		pageSize = utils.PageSize20
	}
	if currentIndex <= 0 {
		currentIndex = 1
	}
	startSize = paging.StartIndex(currentIndex, pageSize)
	var total int
	resp := new(models.TacticsListTimeResp)
	page := paging.GetPaging(currentIndex, pageSize, total)
	list := make([]*models.TimeLineReportItem, 0)
	var err error
	list, total, err = models.GetTimeLineReportIndustrialListTime(user.UserId, industrialManagementId, startSize, pageSize)
	if err != nil {
		br.Msg = "获取信息失败"
		br.ErrMsg = "获取产业报告+晨会点评列表,Err:" + err.Error()
		return
	}
	//处理晨会精华关联的标的，以及要跳转的文章ID
	var meetingreviewchaptIds []int
	var articleIds []int
	mapchaptIdAndArticleId := make(map[int]int)                              // 晨会精华ID与跳转文章ID的映射关系
	mapchaptIdListSubject := make(map[int][]*models.CygxIndustrialSubject)   // 晨会精华ID与标的列表的映射关系
	mapArticleIdListSubject := make(map[int][]*models.CygxIndustrialSubject) // 报告ID与标的列表的映射关系
	for _, v := range list {
		if v.Resource == 3 {
			meetingreviewchaptIds = append(meetingreviewchaptIds, v.Id)
		}
		if v.Resource == 1 {
			articleIds = append(articleIds, v.ArticleId)
		}
	}
	if len(meetingreviewchaptIds) > 0 {
		listMeet, err := services.GetCygxMorningMeetingReviewChapterListByIds(meetingreviewchaptIds)
		if err != nil {
			br.Msg = "获取失败"
			br.ErrMsg = "GetCygxMorningMeetingReviewChapterListByIds，Err:" + err.Error()
		}
		for _, v := range listMeet {
			mapchaptIdAndArticleId[v.Id] = v.LinkArticleId
			mapchaptIdListSubject[v.Id] = v.ListSubject
		}
	}

	if len(articleIds) > 0 {
		mapArticleIdListSubject = services.GetArticleGroupSubjectMapByIndustrialManagementId(articleIds, industrialManagementId)
	}

	//查询用户今天是否看过时间线
	//count, err := models.GetTimeLineRecordCount(user.UserId, industrialManagementId)
	//if err != nil {
	//	br.Msg = "查询浏览记录数量失败"
	//	br.ErrMsg = "查询浏览记录数量失败，Err:" + err.Error()
	//	return
	//}
	//var recordItem *models.CygxPageHistoryRecord
	//if count > 1 {
	//	recordItem, err = models.GetTimeLineRecordItem(user.UserId, industrialManagementId)
	//	if err != nil {
	//		br.Msg = "查询浏览记录失败"
	//		br.ErrMsg = "查询浏览记录失败，Err:" + err.Error()
	//		return
	//	}
	//}

	for k, v := range list {
		if v.SubCategoryName != "时间线" && v.Readnum == 0 && user.CreatedTime.Before(utils.StrTimeToTime(v.PublishDate)) && utils.StrTimeToTime(utils.OnlineTime).Before(utils.StrTimeToTime(v.PublishDate)) {
			list[k].IsRed = true
		}
		//timeLineRed := false
		//if count < 2 && v.SubCategoryName == "时间线" {
		//	timeLineRed = true
		//} else if count > 1 && recordItem.CreateTime.Before(utils.StrTimeToTime(v.PublishDate)) {
		//	timeLineRed = true
		//}
		//if v.SubCategoryName == "时间线" && timeLineRed {
		list[k].IsRed = true
		//}
		if v.VideoUrl != "" {
			list[k].IsHaveVideo = true
		}
		v.PublishDate = utils.TimeRemoveHms2(v.PublishDate)
		if v.Resource == 3 {
			v.LinkArticleId = mapchaptIdAndArticleId[v.Id]
			v.ListSubject = mapchaptIdListSubject[v.Id]
		}
		if v.Resource == 1 {
			v.ListSubject = mapArticleIdListSubject[v.Id]
		}
	}

	//添加我的日程访问记录
	item := new(models.CygxPageHistoryRecord)
	item.UserId = user.UserId
	item.CreateTime = time.Now()
	item.CompanyId = user.CompanyId
	item.CompanyName = user.CompanyName
	item.Router = utils.TIME_LINE_ROUTE + strconv.Itoa(industrialManagementId)
	go models.AddCygxPageHistoryRecord(item)
	if len(list) == 0 {
		list = make([]*models.TimeLineReportItem, 0)
	}
	go services.AddCygxTimelineLog(user, industrialManagementId)
	page = paging.GetPaging(currentIndex, pageSize, total)
	resp.List = list
	resp.Paging = page
	br.Ret = 200
	br.Success = true
	br.Msg = "获取成功"
	br.Data = resp
}

// @Title 文章留言接口
// @Description 文章留言接口
// @Param	request	body models.AddCygxActivityHelpAsk true "type json string"
// @Success 200 {object} models.TacticsListResp
// @router /commentAdd [post]
func (this *ReportController) CommentAdd() {
	br := new(models.BaseResponse).Init()
	defer func() {
		this.Data["json"] = br
		this.ServeJSON()
	}()
	user := this.User
	if user == nil {
		br.Msg = "请重新登录"
		br.Ret = 408
		return
	}
	var req models.AddCygxArticleCommentReq
	err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
	if err != nil {
		br.Msg = "参数解析异常！"
		br.ErrMsg = "参数解析失败，Err:" + err.Error()
		return
	}
	if req.ArticleId <= 0 {
		br.Msg = "文章不存在"
		br.ErrMsg = "文章不存在，文章ID错误"
		return
	}
	if req.Content == "" {
		br.Msg = "建议内容不可为空"
		return
	}
	content := req.Content
	if content == "" {
		br.Msg = "留言内容不能为空！"
		return
	}

	//itemToken, err := services.WxGetToken()
	//if err != nil {
	//	br.Msg = "GetWxAccessToken Err:" + err.Error()
	//	return
	//}
	//if itemToken.AccessToken == "" {
	//	br.Msg = "accessToken is empty"
	//	return
	//}
	//commerr, err := weapp.MSGSecCheck(itemToken.AccessToken, content)
	//if err != nil {
	//	br.Msg = "内容校验失败！"
	//	br.ErrMsg = "内容校验失败，Err:" + err.Error()
	//	return
	//}
	//if commerr.ErrCode != 0 {
	//	br.Msg = "内容违规,请重新提交！"
	//	br.ErrMsg = "内容违规，Err:" + commerr.ErrMSG
	//	return
	//}

	articleId := req.ArticleId
	articleInfo, errInfo := models.GetArticleDetailById(articleId)
	if articleInfo == nil {
		br.Msg = "操作失败"
		br.ErrMsg = "文章ID错误,不存在articleId：" + strconv.Itoa(articleId)
		return
	}
	if errInfo != nil {
		br.Msg = "操作失败"
		br.ErrMsg = "操作失败,Err:" + errInfo.Error()
		return
	}

	companyDetail, err := models.GetCompanyDetailById(user.CompanyId)
	if err != nil {
		br.Msg = "提交失败！"
		br.ErrMsg = "获取客户详情失败，Err:" + err.Error()
		return
	}
	if companyDetail == nil {
		br.Msg = "提交失败！"
		br.ErrMsg = "客户不存在，uid:" + strconv.Itoa(user.UserId)
		return
	}
	item := models.CygxArticleComment{
		UserId:      user.UserId,
		ArticleId:   req.ArticleId,
		CreateTime:  time.Now(),
		Mobile:      user.Mobile,
		Email:       user.Email,
		CompanyId:   user.CompanyId,
		CompanyName: companyDetail.CompanyName,
		Content:     content,
		Title:       articleInfo.Title,
	}
	msgId, err := models.AddArticleComment(&item)
	if err != nil {
		br.Msg = "提交失败"
		br.ErrMsg = "提交留言失败,Err:" + err.Error()
		return
	}
	go services.SendCommentWxTemplateMsg(req, user, articleInfo, int(msgId))
	go services.SendCommentWxTemplateMsgByYxCategory(req, user, articleInfo, int(msgId)) // 发送用户留言提醒（研选公众号类目模版消息）
	br.Ret = 200
	br.Success = true
	br.Msg = "提交成功"
}

// @Title 报告精选、本周研究汇总、上周纪要汇总列表
// @Description 获取报告精选、本周研究汇总、上周纪要汇总列表接口
// @Param   PageSize   query   int  true       "每页数据条数"
// @Param   CurrentIndex   query   int  true       "当前页页码，从1开始"
// @Param   ReportType   string   query     true       "报告类型 ，1报告精选、2本周研究汇总、3上周纪要汇总"
// @Success 200 {object} models.CygxReportSelectionListPublicRep
// @router /reportList/byType [get]
func (this *ReportController) ReportListByType() {
	br := new(models.BaseResponse).Init()
	defer func() {
		this.Data["json"] = br
		this.ServeJSON()
	}()
	user := this.User
	if user == nil {
		br.Msg = "请重新登录"
		br.Ret = 408
		return
	}
	uid := user.UserId
	pageSize, _ := this.GetInt("PageSize")
	currentIndex, _ := this.GetInt("CurrentIndex")
	reportType := this.GetString("ReportType")
	var condition string
	var startSize int
	if pageSize <= 0 {
		pageSize = utils.PageSize20
	}
	if currentIndex <= 0 {
		currentIndex = 1
	}
	startSize = paging.StartIndex(currentIndex, pageSize)
	var pars []interface{}
	var total int
	resp := new(models.CygxReportSelectionListPublicRep)
	page := paging.GetPaging(currentIndex, pageSize, total)
	var tbdb string
	var readSql string
	var reportTypeStr string
	if reportType == "1" {
		tbdb = "cygx_report_selection"
		reportTypeStr = "bgjx"
	} else if reportType == "2" {
		tbdb = "cygx_research_summary"
		reportTypeStr = "bzyjhz"
	} else if reportType == "3" {
		tbdb = "cygx_minutes_summary"
		reportTypeStr = "szjyhz"
	} else {
		br.Msg = "请选择报告类型"
		return
	}
	condition = ` AND publish_status = 1  `
	if user.CompanyId != utils.HZ_COMPANY_ID {
		condition += ` AND visible_range = 1  `
	}
	total, err := models.GetCygxReportSelectionPublic(condition, tbdb, pars)
	if err != nil {
		br.Msg = "获取信息失败"
		br.ErrMsg = "获取帖子总数失败，Err:" + err.Error()
		return
	}
	//研究汇总--报告精选 只显示最新一期，往期都隐藏
	if reportType == "1" {
		startSize = 0
		pageSize = 1
		total = 1
	}
	readSql = ` (SELECT COUNT(1) AS  count  FROM cygx_report_history_record AS h WHERE h.article_id = art.article_id AND  report_type ='` + reportTypeStr + `' AND h.user_id = ` + strconv.Itoa(uid) + `) as read_num`
	page = paging.GetPaging(currentIndex, pageSize, total)
	list, err := models.GetReportSelectionListPublic(condition, readSql, tbdb, pars, startSize, pageSize)
	if err != nil {
		br.Msg = "获取失败"
		br.ErrMsg = "获取失败，Err:" + err.Error()
		return
	}
	for k, v := range list {
		if reportType == "1" {
			list[k].Abstract = v.UpdateDescription
		}
		list[k].PublishDate = utils.StrTimeToTime(v.PublishDate).Format("2006-01-02")
		if v.ReadNum == 0 {
			list[k].IsRed = true
		}
	}
	resp.List = list
	resp.Paging = page
	br.Ret = 200
	br.Success = true
	br.Msg = "获取成功"
	br.Data = resp
}

// @Title 获取本周研究汇总详情
// @Description 获取本周研究汇总详情接口
// @Param   ArticleId   query   int  true       "报告ID"
// @Success 200 {object} models.ResearchSummaryLetailResp
// @router /researchSummary/detail [get]
func (this *ReportController) ResearchDetail() {
	br := new(models.BaseResponse).Init()
	defer func() {
		this.Data["json"] = br
		this.ServeJSON()
	}()
	user := this.User
	if user == nil {
		br.Msg = "请重新登录"
		br.Ret = 408
		return
	}
	//uid := user.UserId
	articleId, _ := this.GetInt("ArticleId")
	if articleId < 0 {
		br.Msg = "参数错误"
		br.ErrMsg = "参数错误"
		return
	}
	resp := new(models.ResearchSummaryLetailResp)
	//判断用户权限
	hasPermission, err := services.GetUserhasPermission(user)
	if err != nil {
		br.Msg = "获取信息失败"
		br.ErrMsg = "获取用户权限信息失败,Err:" + err.Error()
	}
	detail, err := models.GetCygxResearchSummaryInfoById(articleId)
	if err != nil {
		br.Msg = "获取信息失败"
		br.ErrMsg = "报告不存在,Err:" + err.Error() + "articleId：" + strconv.Itoa(articleId)
		return
	}
	PermissionNameMap, err := services.GetPermissionNameMap()
	if err != nil {
		br.Msg = "获取失败"
		br.ErrMsg = "获取失败 GetPermissionNameMap，Err:" + err.Error()
		return
	}

	PermissionIcoMap, err := services.GetPermissionNameIcoMap()
	if err != nil {
		br.Msg = "获取失败"
		br.ErrMsg = "获取失败 GetPermissionNameMap，Err:" + err.Error()
		return
	}

	//未设置全部可见的只能给弘则内部查看
	if detail.VisibleRange == 1 || user.CompanyId == utils.HZ_COMPANY_ID {
		resp.IsShow = true
	}
	resp.HasPermission = hasPermission
	if hasPermission != 1 || !resp.IsShow {
		br.Ret = 200
		br.Success = true
		br.Msg = "获取成功"
		br.Data = resp
		return
	}
	detail.PublishDate = utils.StrTimeToTime(detail.PublishDate).Format(utils.FormatDate)
	detail.VideoPlaySeconds = utils.Mp3Time(detail.VideoPlaySeconds)
	listFirst, err := models.GetResearchSummarylogListFirst(articleId)
	if err != nil {
		br.Msg = "获取失败"
		br.ErrMsg = "获取子类信息失败，Err:" + err.Error()
		return
	}
	listArticleType, err := models.GetCygxArticleTypeList()
	if err != nil {
		br.Msg = "获取失败"
		br.ErrMsg = "获取文章类型数据失败，Err:" + err.Error()
		return
	}
	for k, v := range listFirst {
		listSecond, err := models.GetResearchSummarylogSonListSecond(articleId, v.Type)
		if err != nil && err.Error() != utils.ErrNoRow() {
			br.Msg = "获取信息失败"
			br.ErrMsg = "获取信息失败,Err:" + err.Error()
			return
		}
		for k2, v2 := range listSecond {
			v2.PermissionName = PermissionNameMap[v2.ChartPermissionId]
			v2.IcoLink = PermissionIcoMap[v2.ChartPermissionId]
			listThird, err := models.GetResearchSummarylogSonListThird(articleId, v2.ChartPermissionId, v.Type)
			if err != nil && err.Error() != utils.ErrNoRow() {
				br.Msg = "获取信息失败"
				br.ErrMsg = "获取信息失败,Err:" + err.Error()
				return
			}
			for _, vType := range listArticleType {
				if v2.ChartPermissionId == vType.YanxPermissionId {
					listSecond[k2].IcoLink = vType.IcoLinkM
					listSecond[k2].PermissionName = vType.YanxPermissionName
				}
			}
			if len(listThird) > 0 {
				for k3, v3 := range listThird {
					if v3.VideoUrl != "" {
						listThird[k3].IsHaveVideo = true
					}
					if v3.ReportLink == "0" {
						listThird[k3].ReportLink = ""
					}
				}
				listSecond[k2].List = listThird
			}
		}
		if len(listSecond) > 0 {
			listFirst[k].List = listSecond
		}
		//`description:"类型'SDBG深度报告片篇,’CYDYJY：产业调研纪要’,’SJDP事件点评,’BZCHJH：本周晨会精华’"`
		if v.Type == "SDBG" {
			listFirst[k].ListName = "深度报告"
			listFirst[k].IcoLink = "https://hongze.oss-cn-shanghai.aliyuncs.com/static/images/202110/20211027/le8AcRjDz0MhA72bVDiaf3d5ALSe.png"
		} else if v.Type == "BZCHJH" {
			listFirst[k].ListName = "本周晨会精华"
			listFirst[k].IcoLink = "https://hongze.oss-cn-shanghai.aliyuncs.com/static/images/202110/20211020/DCfekcxaIKGePBsNVu1ULfmNcJBY.png"
		} else if v.Type == "CYDYJY" {
			listFirst[k].ListName = "产业调研纪要"
			listFirst[k].IcoLink = "https://hongze.oss-cn-shanghai.aliyuncs.com/static/images/202110/20211020/UPAdozy96z9ypzY04vi0Y3Ogqzji.png"
		} else if v.Type == "SSGS" {
			listFirst[k].ListName = "上市公司调研纪要篇"
			listFirst[k].IcoLink = "https://hongze.oss-cn-shanghai.aliyuncs.com/static/images/202111/20211101/ujHXB48I8ay9T0XoPRI7lorz7OkL.png"
		} else if v.Type == "SJDP" {
			listFirst[k].ListName = "市场QA汇总"
			listFirst[k].IcoLink = "https://hongze.oss-cn-shanghai.aliyuncs.com/static/images/202110/20211020/2a5cXafO3Iws4QcFp1bd5WPdYikV.png"
		} else if v.Type == "YANX" {
			listFirst[k].ListName = "买方研选"
			listFirst[k].IcoLink = "https://hongze.oss-cn-shanghai.aliyuncs.com/static/images/202111/20211104/QbTGTNhD9MxYp24cJ7V5WpCN0oNl.png"
		}
	}
	//go services.AddCygxReportHistoryRecord(user, articleId, "bzyjhz")
	go services.ResearchSummaryHistoryUserRmind(user, articleId) // 本周研究汇总用户阅读操作操作行为，模板消息推送
	resp.List = listFirst
	resp.Detail = detail
	br.Ret = 200
	br.Success = true
	br.Msg = "获取成功"
	br.Data = resp
}

// @Title 上周纪要汇总内容详情
// @Description 获取上周纪要汇总内容详情接口
// @Param   ArticleId   query   int  true       "报告ID"
// @Success 200 {object} models.MinutesSummaryLetailResp
// @router /minutesSummary/detail [get]
func (this *ReportController) MinutesDetail() {
	br := new(models.BaseResponse).Init()
	defer func() {
		this.Data["json"] = br
		this.ServeJSON()
	}()
	user := this.User
	if user == nil {
		br.Msg = "请重新登录"
		br.Ret = 408
		return
	}
	articleId, _ := this.GetInt("ArticleId")
	if articleId < 0 {
		br.Msg = "参数错误"
		br.ErrMsg = "参数错误"
		return
	}
	resp := new(models.MinutesSummaryLetailRespV4)
	//判断用户权限
	hasPermission, err := services.GetUserhasPermission(user)
	if err != nil {
		br.Msg = "获取信息失败"
		br.ErrMsg = "获取用户权限信息失败,Err:" + err.Error()
	}

	detail, err := models.GetCygxMinutesSummaryInfoById(articleId)
	if err != nil {
		br.Msg = "获取信息失败"
		br.ErrMsg = "报告不存在,Err:" + err.Error() + "articleId：" + strconv.Itoa(articleId)
		return
	}

	PermissionNameMap, err := services.GetPermissionNameMap()
	if err != nil {
		br.Msg = "获取失败"
		br.ErrMsg = "获取失败 GetPermissionNameMap，Err:" + err.Error()
		return
	}
	PermissionIcoMap, err := services.GetPermissionNameIcoMap()
	if err != nil {
		br.Msg = "获取失败"
		br.ErrMsg = "获取失败 GetPermissionNameMap，Err:" + err.Error()
		return
	}

	//未设置全部可见的只能给弘则内部查看
	if detail.VisibleRange == 1 || user.CompanyId == utils.HZ_COMPANY_ID {
		resp.IsShow = true
	}
	resp.HasPermission = hasPermission
	if hasPermission != 1 || !resp.IsShow {
		br.Ret = 200
		br.Success = true
		br.Msg = "获取成功"
		br.Data = resp
		return
	}
	detail.PublishDate = utils.StrTimeToTime(detail.PublishDate).Format(utils.FormatDate)
	detail.VideoPlaySeconds = utils.Mp3Time(detail.VideoPlaySeconds)
	listFirst, err := models.GetMinutesSummarylogListAllV4(articleId)
	if err != nil {
		br.Msg = "获取失败"
		br.ErrMsg = "获取子类信息失败，Err:" + err.Error()
		return
	}
	for k, v := range listFirst {
		listSecond, err := models.GetMinutesSummarylogSonListSecond(articleId, v.Type)
		if err != nil && err.Error() != utils.ErrNoRow() {
			br.Msg = "获取信息失败"
			br.ErrMsg = "获取信息失败,Err:" + err.Error()
			return
		}
		for k2, v2 := range listSecond {
			v2.PermissionName = PermissionNameMap[v2.ChartPermissionId]
			v2.IcoLink = PermissionIcoMap[v2.ChartPermissionId]
			listThird, err := models.GetMinutesSummarylogListThird(articleId, v2.ChartPermissionId, v.Type)
			if err != nil && err.Error() != utils.ErrNoRow() {
				br.Msg = "获取信息失败"
				br.ErrMsg = "获取信息失败,Err:" + err.Error()
				return
			}
			if len(listThird) > 0 {
				for k3, v3 := range listThird {
					if v3.VideoUrl != "" {
						listThird[k3].IsHaveVideo = true
					}
					if v3.ReportLink == "0" {
						listThird[k3].ReportLink = ""
					}
				}
				listSecond[k2].List = listThird
			}
		}
		if len(listSecond) > 0 {
			listFirst[k].List = listSecond
		}
		//`description:"类型'SDBG深度报告片篇,’CYDYJY：产业调研纪要’,’SJDP事件点评,’BZCHJH：本周晨会精华’"`
		if v.Type == "CYDYJY" {
			listFirst[k].ListName = "产业调研纪要"
			listFirst[k].IcoLink = "https://hongze.oss-cn-shanghai.aliyuncs.com/static/images/202110/20211020/UPAdozy96z9ypzY04vi0Y3Ogqzji.png"
		} else if v.Type == "SSGS" {
			listFirst[k].ListName = "上市公司调研纪要篇"
			listFirst[k].IcoLink = "https://hongze.oss-cn-shanghai.aliyuncs.com/static/images/202111/20211101/ujHXB48I8ay9T0XoPRI7lorz7OkL.png"
		} else if v.Type == "YANX" {
			listFirst[k].ListName = "买方研选纪要"
			listFirst[k].IcoLink = "https://hongze.oss-cn-shanghai.aliyuncs.com/static/images/202111/20211104/QbTGTNhD9MxYp24cJ7V5WpCN0oNl.png"
		}
	}

	//go services.AddCygxReportHistoryRecord(user, articleId, "szjyhz")
	go services.MinutesSummaryHistoryUserRmind(user, articleId) // 上周纪要汇总用户阅读，给销售发消息提醒
	resp.List = listFirst
	resp.Detail = detail
	br.Ret = 200
	br.Success = true
	br.Msg = "获取成功"
	br.Data = resp
}

// @Title 记录用户浏览音频回放接口
// @Description 记录用户浏览音频回放接口
// @Param	request	body models.ArticleIdReq true "type json string"
// @Success Ret=200 操作成功
// @router /voiceHistory/add [post]
func (this *ReportController) ResearchSummaryVoiceHistoryAdd() {
	br := new(models.BaseResponse).Init()
	defer func() {
		this.Data["json"] = br
		this.ServeJSON()
	}()
	user := this.User
	if user == nil {
		br.Msg = "请登录"
		br.ErrMsg = "请登录，用户信息为空"
		br.Ret = 408
		return
	}
	uid := user.UserId
	var req models.ArticleIdReq
	err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
	if err != nil {
		br.Msg = "参数解析异常！"
		br.ErrMsg = "参数解析失败，Err:" + err.Error()
		return
	}

	articleId := req.ArticleId
	playSeconds := req.PlaySeconds
	reportType := req.ReportType

	//本周研究汇总
	if reportType == 2 {
		articleInfo, errInfo := models.GetCygxResearchSummaryInfoById(articleId)
		if articleInfo == nil {
			br.Msg = "操作失败"
			br.ErrMsg = "文章ID错误,不存在articleId：" + strconv.Itoa(articleId)
			return
		}
		if errInfo != nil {
			br.Msg = "操作失败"
			br.ErrMsg = "操作失败,Err:" + errInfo.Error()
			return
		}

		var sellerName string
		sellerName, err = models.GetCompanySellerName(user.CompanyId)
		if err != nil {
			br.Msg = "报名失败！"
			br.ErrMsg = "获取对应销售失败，Err:" + err.Error()
			return
		}
		item := models.CygxResearchSummaryVoiceHistory{
			ArticleId:        articleId,
			UserId:           uid,
			CreateTime:       time.Now(),
			Mobile:           user.Mobile,
			Email:            user.Email,
			CompanyId:        user.CompanyId,
			CompanyName:      user.CompanyName,
			RealName:         user.RealName,
			SellerName:       sellerName,
			PlaySeconds:      strconv.Itoa(req.PlaySeconds),
			ModifyTime:       time.Now(),
			RegisterPlatform: utils.REGISTER_PLATFORM,
		}

		if playSeconds != 0 {
			lastItem, err := models.GetLastCygxResearchSummaryVoiceHistory(articleId, user.UserId)
			if err != nil {
				br.Msg = "操作失败"
				br.ErrMsg = "操作失败,GetLastCygxResearchSummaryVoiceHistory Err:" + err.Error()
				return
			}
			err = models.UpdateLastCygxResearchSummaryVoiceHistory(strconv.Itoa(req.PlaySeconds), lastItem.Id)
			if err != nil {
				br.Msg = "更新失败"
				br.ErrMsg = "更新失败,UpdateLastCygxResearchSummaryVoiceHistory Err:" + err.Error()
				return
			}
		} else {
			err = models.AddCygxResearchSummaryVoiceHistory(&item)
			if err != nil {
				br.Msg = "操作失败"
				br.ErrMsg = "操作失败,Err:" + err.Error()
				return
			}
			err = models.UpdateResearchSummaryVoiceCounts(articleId)
			if err != nil {
				br.Msg = "更新失败"
				br.ErrMsg = "更新失败,Err:" + err.Error()
				return
			}
		}
	} else if reportType == 3 {
		articleInfo, errInfo := models.GetCygxMinutesSummaryInfoById(articleId)
		if articleInfo == nil {
			br.Msg = "操作失败"
			br.ErrMsg = "文章ID错误,不存在articleId：" + strconv.Itoa(articleId)
			return
		}
		if errInfo != nil {
			br.Msg = "操作失败"
			br.ErrMsg = "操作失败,Err:" + errInfo.Error()
			return
		}

		var sellerName string
		sellerName, err = models.GetCompanySellerName(user.CompanyId)
		if err != nil {
			br.Msg = "报名失败！"
			br.ErrMsg = "获取对应销售失败，Err:" + err.Error()
			return
		}
		item := models.CygxMinutesSummaryVoiceHistory{
			ArticleId:        articleId,
			UserId:           uid,
			CreateTime:       time.Now(),
			Mobile:           user.Mobile,
			Email:            user.Email,
			CompanyId:        user.CompanyId,
			CompanyName:      user.CompanyName,
			RealName:         user.RealName,
			SellerName:       sellerName,
			PlaySeconds:      strconv.Itoa(req.PlaySeconds),
			ModifyTime:       time.Now(),
			RegisterPlatform: utils.REGISTER_PLATFORM,
		}

		if playSeconds != 0 {
			lastItem, err := models.GetLastCygxMinutesSummaryVoiceHistory(articleId, user.UserId)
			if err != nil {
				br.Msg = "操作失败"
				br.ErrMsg = "操作失败,GetLastCygxSummaryVoiceHistory Err:" + err.Error()
				return
			}
			err = models.UpdateLastCygxMinutesSummaryVoiceHistory(strconv.Itoa(req.PlaySeconds), lastItem.Id)
			if err != nil {
				br.Msg = "更新失败"
				br.ErrMsg = "更新失败,UpdateLastCygxSummaryVoiceHistory Err:" + err.Error()
				return
			}
		} else {
			err = models.AddCygxMinutesSummaryVoiceHistory(&item)
			if err != nil {
				br.Msg = "操作失败"
				br.ErrMsg = "操作失败,Err:" + err.Error()
				return
			}
			err = models.UpdateMinutesSummaryVoiceCounts(articleId)
			if err != nil {
				br.Msg = "更新失败"
				br.ErrMsg = "更新失败,Err:" + err.Error()
				return
			}
		}
	}

	br.Ret = 200
	br.Success = true
	br.Msg = "操作成功"
	return
}

// @Title 根据行业分类获取行业文章列表
// @Description 根据行业分类获取行业文章列表接口
// @Param   PageSize   query   int  true       "每页数据条数"
// @Param   CurrentIndex   query   int  true       "当前页页码，从1开始"
// @Param   CategoryId   query   int  true       "分类ID"
// @Param   IndustrialManagementId   query   int  false       "产业ID"
// @Success 200 {object} models.TacticsListResp
// @router /tactics/list [get]
func (this *MobileReportController) TacticsList() {
	br := new(models.BaseResponse).Init()
	defer func() {
		this.Data["json"] = br
		this.ServeJSON()
	}()
	user := this.User
	if user == nil {
		br.Msg = "请重新登录"
		br.Ret = 408
		return
	}
	//uid := user.UserId
	pageSize, _ := this.GetInt("PageSize")
	currentIndex, _ := this.GetInt("CurrentIndex")
	categoryId, _ := this.GetInt("CategoryId")
	industrialManagementId, _ := this.GetInt("IndustrialManagementId")

	var startSize int
	if pageSize <= 0 {
		pageSize = utils.PageSize20
	}
	if currentIndex <= 0 {
		currentIndex = 1
	}
	startSize = paging.StartIndex(currentIndex, pageSize)
	//var condition string
	//var pars []interface{}
	var total int
	var err error
	resp := new(models.TacticsListResp)
	page := paging.GetPaging(currentIndex, pageSize, total)
	list := make([]*models.ArticleListResp, 0)

	if categoryId == utils.TIME_CATEGORYID {

		list, total, err = models.GetTimeLineReportIndustrialList(industrialManagementId, startSize, pageSize)
		if err != nil {
			br.Msg = "获取信息失败"
			br.ErrMsg = "获取产业报告+晨会点评列表,Err:" + err.Error()
			return
		}
	} else {

		if categoryId == utils.ACTEGORY_ID_AI_QY {
			listArticle := make([]*models.HomeArticle, 0)
			listArticle, total, err = services.GetAiQianYanArtilceList(startSize, pageSize)
			if err != nil {
				br.Msg = "获取信息失败"
				br.Msg = "GetAiQianYanArtilceList，Err:" + err.Error()
				return
			}
			for _, v := range listArticle {
				list = append(list, &models.ArticleListResp{
					ArticleId:   v.ArticleId,
					Title:       v.Title,
					CategoryId:  v.CategoryId,
					Annotation:  v.Annotation,
					Abstract:    v.Abstract,
					Body:        v.Body,
					PublishDate: v.PublishDate,
					Resource:    1,
				})
			}

		} else {
			list, total, err = models.GetReportAndproductIndustrylListimg(categoryId, user.UserId, startSize, pageSize)
			if err != nil {
				br.Msg = "获取信息失败"
				br.Msg = "GetHomeList，Err:" + err.Error()
				return
			}

		}

		articleIdMap, err := services.GetUserArticleHistoryRecord(user)
		if err != nil {
			br.Msg = "获取信息失败"
			br.Msg = "获取帖子数据失败，Err:" + err.Error()
			return
		}
		for k, v := range list {
			//list[k].ImgUrlPc = mapCategoryUrl[v.CategoryId]
			if !articleIdMap[v.ArticleId] && user.CreatedTime.Before(utils.StrTimeToTime(v.PublishDate)) && utils.StrTimeToTime(utils.OnlineTime).Before(utils.StrTimeToTime(v.PublishDate)) {
				list[k].IsRed = true
			}
		}
		if categoryId > 0 {
			detail, errCategory := models.GetCygxReportMappingCygxByCategoryId(categoryId)
			if errCategory != nil {
				br.Msg = "获取信息失败"
				br.ErrMsg = "获取信息失败,Err:" + errCategory.Error() + "categoryID 不存在：" + strconv.Itoa(categoryId)
				return
			}
			resp.MatchTypeName = detail.MatchTypeName
		}
		//resp.CategoryImgUrlPc = mapChartPermission[detail.ChartPermissionName]
	}

	listPublic, err := services.HandleArticleCategoryImg(list, user)
	if err != nil {
		br.Msg = "获取失败"
		br.ErrMsg = "获取报告封面图片失败, Err:" + err.Error()
		return
	}

	var articleIds []int
	var productInteriorIs []int

	for _, v := range listPublic {
		if v.Resource == 1 {
			articleIds = append(articleIds, v.ArticleId)
		}
		if v.Resource == 2 {
			productInteriorIs = append(productInteriorIs, v.ArticleId)
		}
	}

	articleMapPv := services.GetArticleHistoryByArticleId(articleIds)                       //文章Pv
	articleCollectMap, _ := services.GetCygxArticleCollectMap(user.UserId)                  //用户收藏的文章
	articleCollectNumMap, _ := services.GetCygxArticleCollectNumMapByArtcileIds(articleIds) //文章收藏的数量

	productInteriorMapPv := services.GetCygxProductInteriorHistoryListPvMap(productInteriorIs) //产品内测Pv
	listResp := make([]*models.HomeArticle, 0)
	for _, v := range listPublic {
		item := new(models.HomeArticle)
		item.ArticleId = v.ArticleId
		item.ReportId = v.ReportId
		item.Title = v.Title
		item.Annotation = v.Annotation
		item.Abstract = v.Abstract
		item.ImgUrlPc = v.ImgUrlPc
		item.PublishDate = v.PublishDate
		item.Resource = v.Resource
		if v.Resource == 1 {
			item.Pv = articleMapPv[v.ArticleId]
			item.IsCollect = articleCollectMap[v.ArticleId]
			item.CollectNum = articleCollectNumMap[v.ArticleId]
		}
		if v.Resource == 2 {
			item.Pv = productInteriorMapPv[v.ArticleId]
		}

		if v.ReportId > 0 {
			item.Resource = 3
		}
		listResp = append(listResp, item)
	}
	if len(listResp) == 0 {
		listResp = make([]*models.HomeArticle, 0)
	}
	page = paging.GetPaging(currentIndex, pageSize, total)
	resp.List = listResp
	resp.Paging = page
	br.Ret = 200
	br.Success = true
	br.Msg = "获取成功"
	br.Data = resp
}

// @Title 周期行业报告分类列表接口
// @Description 周期获取行业报告分类列表接口
// @Success 200 {object} models.TradeReportMappingResp
// @router /zhouqi_tradeList [get]
func (this *MobileReportController) ZouqiTradeList() {
	br := new(models.BaseResponse).Init()
	defer func() {
		this.Data["json"] = br
		this.ServeJSON()
	}()
	user := this.User
	if user == nil {
		br.Msg = "请重新登录"
		br.Ret = 408
		return
	}
	listCategory, err := models.GetCygxZhouqiArticleMapFirst()
	if err != nil {
		br.Msg = "获取信息失败"
		br.ErrMsg = "获取品种信息失败,Err:" + err.Error()
		return
	}

	fllowMap, fllowMapType := services.GetXzsChooseCategoryZhouqiMapByMobile(user.Mobile)

	resp := new(models.TradeReportMappingResp)
	var list []*models.TradeReportMapping
	if len(listCategory) == 0 {
		list = make([]*models.TradeReportMapping, 0)
	} else {
		for _, v := range listCategory {
			item := new(models.TradeReportMapping)
			item.CategoryId = v.CategoryId
			item.MatchTypeName = v.MatchTypeName
			item.UpdateTime = utils.TimeRemoveHms(v.ArticleUpdateTime)
			item.IsFollow = fllowMap[item.CategoryId]
			item.FollowType = fllowMapType[item.CategoryId]
			item.ListArticle = make([]*models.HomeArticle, 0)
			list = append(list, item)
		}
	}
	resp.List = list
	br.Ret = 200
	br.Success = true
	br.Msg = "获取成功"
	br.Data = resp
}

// @Title 周期根据行业分类获取行业文章列表
// @Description 周期根据行业分类获取行业文章列表接口
// @Param   PageSize   query   int  true       "每页数据条数"
// @Param   CurrentIndex   query   int  true       "当前页页码，从1开始"
// @Param   CategoryId   query   int  true       "分类ID"
// @Success 200 {object} models.TacticsListResp
// @router /tactics/zhouqi_list [get]
func (this *MobileReportController) ZhouqiTacticsList() {
	br := new(models.BaseResponse).Init()
	defer func() {
		this.Data["json"] = br
		this.ServeJSON()
	}()
	user := this.User
	if user == nil {
		br.Msg = "请重新登录"
		br.Ret = 408
		return
	}
	//uid := user.UserId
	pageSize, _ := this.GetInt("PageSize")
	currentIndex, _ := this.GetInt("CurrentIndex")
	categoryId, _ := this.GetInt("CategoryId")

	var startSize int
	if pageSize <= 0 {
		pageSize = utils.PageSize20
	}
	if currentIndex <= 0 {
		currentIndex = 1
	}
	startSize = paging.StartIndex(currentIndex, pageSize)

	var total int
	var err error
	resp := new(models.TacticsListResp)
	page := paging.GetPaging(currentIndex, pageSize, total)
	list := make([]*models.ArticleListResp, 0)
	listCategory, err := models.GetCygxZhouqiArticleMapByParentId(categoryId)
	if err != nil {
		br.Msg = "获取信息失败"
		br.ErrMsg = "获取产业报告+晨会点评列表,Err:" + err.Error()
		return
	}
	var matchTypeName = []string{}
	var seriesName = []string{}
	for _, v := range listCategory {
		if v.MatchTypeName != "" {
			matchTypeName = append(matchTypeName, v.MatchTypeName)
		}

		if v.SeriesName != "" {
			seriesName = append(seriesName, v.SeriesName)
		}
	}

	var condition string
	//var pars []interface{}
	if len(seriesName) == 0 {
		condition = " AND field_name  IN  ('" + strings.Join(matchTypeName, "','") + "')"
	} else {
		condition = " AND  ( field_name  IN  ('" + strings.Join(matchTypeName, "','") + "')   OR series_name IN  ('" + strings.Join(seriesName, "','") + "')   )"
	}

	list, total, err = models.GetReportAndproductIndustrylListimgZhouqi(condition, startSize, pageSize)
	if err != nil {
		br.Msg = "获取信息失败"
		br.Msg = "GetHomeList，Err:" + err.Error()
		return
	}

	listPublic, err := services.HandleArticleCategoryImg(list, user)
	if err != nil {
		br.Msg = "获取失败"
		br.ErrMsg = "获取报告封面图片失败, Err:" + err.Error()
		return
	}

	var articleIds []int
	var productInteriorIs []int

	for _, v := range listPublic {
		if v.Resource == 1 {
			articleIds = append(articleIds, v.ArticleId)
		}
		if v.Resource == 2 {
			productInteriorIs = append(productInteriorIs, v.ArticleId)
		}
	}

	articleMapPv := services.GetArticleHistoryByArticleId(articleIds)                       //文章Pv
	articleCollectMap, _ := services.GetCygxArticleCollectMap(user.UserId)                  //用户收藏的文章
	articleCollectNumMap, _ := services.GetCygxArticleCollectNumMapByArtcileIds(articleIds) //文章收藏的数量

	productInteriorMapPv := services.GetCygxProductInteriorHistoryListPvMap(productInteriorIs) //产品内测Pv
	listResp := make([]*models.HomeArticle, 0)
	for _, v := range listPublic {
		item := new(models.HomeArticle)
		item.ArticleId = v.ArticleId
		item.ReportId = v.ReportId
		item.Title = v.Title
		item.Annotation = v.Annotation
		item.Abstract = v.Abstract
		item.ImgUrlPc = v.ImgUrlPc
		item.PublishDate = v.PublishDate
		item.Resource = v.Resource
		if v.Resource == 1 {
			item.Pv = articleMapPv[v.ArticleId]
			item.IsCollect = articleCollectMap[v.ArticleId]
			item.CollectNum = articleCollectNumMap[v.ArticleId]
		}
		if v.Resource == 2 {
			item.Pv = productInteriorMapPv[v.ArticleId]
		}

		if v.ReportId > 0 {
			item.Resource = 3
		}
		listResp = append(listResp, item)
	}
	if len(listResp) == 0 {
		listResp = make([]*models.HomeArticle, 0)
	}
	page = paging.GetPaging(currentIndex, pageSize, total)
	resp.List = listResp
	resp.Paging = page
	br.Ret = 200
	br.Success = true
	br.Msg = "获取成功"
	br.Data = resp
}

// @Title 周期行业关注/取消关注
// @Description 周期行业关注/取消关注 接口
// @Param	request	body models.CygxCategoryFllowRep true "type json string"
// @Success 200
// @router /category/zhouqi_fllow [post]
func (this *ReportController) CategoryZhouqiFllow() {
	br := new(models.BaseResponse).Init()
	defer func() {
		this.Data["json"] = br
		this.ServeJSON()
	}()
	user := this.User
	if user == nil {
		br.Msg = "请重新登录"
		br.Ret = 408
		return
	}
	uid := user.UserId
	var req models.CygxCategoryFllowRep
	err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
	if err != nil {
		br.Msg = "参数解析异常！"
		br.ErrMsg = "参数解析失败，Err:" + err.Error()
		return
	}
	categoryId := req.CategoryId
	followType := req.FollowType
	//count, err := models.GetCountCategoryFllowZhouqi(categoryId, user.Mobile)
	//if err != nil {
	//	br.Msg = "获取数据失败！"
	//	br.ErrMsg = "获取数据失败，Err:" + err.Error()
	//	return
	//}
	resp := new(models.CygxIndustryFllowResp)
	//if count == 0 {
	item := new(models.CygxXzsChooseCategoryZhouqi)
	item.CategoryId = categoryId
	item.UserId = uid
	item.Email = user.Email
	item.Mobile = user.Mobile
	item.RealName = user.RealName
	item.CompanyId = user.CompanyId
	item.CompanyName = user.CompanyName
	item.FollowType = followType
	item.CreateTime = time.Now()
	item.ModifyTime = time.Now()
	_, err = models.AddCygxCategoryFllowZhouqi(item)
	if err != nil {
		br.Msg = "操作失败"
		br.ErrMsg = "操作失败,Err:" + err.Error()
		return
	}
	resp.Status = followType
	br.Msg = "操作成功"
	//} else {
	//	err = models.RemoveCygxCategoryFllowZhouqi(user.Mobile, categoryId)
	//	if err != nil {
	//		br.Msg = "操作失败"
	//		br.ErrMsg = "取消关注失败,Err:" + err.Error()
	//		return
	//	}
	//	resp.Status = 2
	//	br.Msg = "已取消关注"
	//}
	br.Ret = 200
	br.Success = true
	br.Data = resp
}