hongze_cygx/controllers/report_billboard.go

package controllers

import (
	"github.com/rdlucklib/rdluck_tools/paging"
	"hongze/hongze_cygx/models"
	"hongze/hongze_cygx/utils"
	"time"
)

//报告榜单
type ReportBillboardController struct {
	BaseAuthController
}

// @Title 报告榜单table栏
// @Description 报告榜单table栏
// @Success 200 {object} models.ReportBillboardTableListResp
// @router /table/list [get]
func (this *ReportBillboardController) CompanyTableList() {
	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
	}
	ListPermission := []*models.ChartPermission{{PermissionName: utils.YI_YAO_NAME, ChartPermissionId: utils.YI_YAO_ID}, {PermissionName: utils.XIAO_FEI_NAME, ChartPermissionId: utils.XIAO_FEI_ID}, {PermissionName: utils.KE_JI_NAME, ChartPermissionId: utils.KE_JI_ID}, {PermissionName: utils.ZHI_ZAO_NAME, ChartPermissionId: utils.ZHI_ZAO_ID}}
	ListAllPermission := []*models.ChartPermission{{PermissionName: utils.YI_YAO_NAME, ChartPermissionId: utils.YI_YAO_ID}, {PermissionName: utils.XIAO_FEI_NAME, ChartPermissionId: utils.XIAO_FEI_ID}, {PermissionName: utils.KE_JI_NAME, ChartPermissionId: utils.KE_JI_ID}, {PermissionName: utils.ZHI_ZAO_NAME, ChartPermissionId: utils.ZHI_ZAO_ID}, {PermissionName: utils.CE_LUE_NAME, ChartPermissionId: utils.CE_LUE_ID}}
	List := []*models.ReportBillboardTableResp{{Name: "产业关注榜", Source: 1, List: ListPermission}, {Name: "阅读飙升榜", Source: 2, List: ListAllPermission}, {Name: "报告收藏榜", Source: 3, List: ListAllPermission}}
	resp := new(models.ReportBillboardTableListResp)
	resp.List = List
	br.Ret = 200
	br.Success = true
	br.Msg = "获取成功"
	br.Data = resp
}

// @Title 产业关注榜
// @Description 获取产业关注榜接口
// @Param   ChartPermissionId   query   int  false       "行业ID"
// @Success 200 {object} models.IndustrialManagementList
// @router /industry/fllowList [get]
func (this *ReportBillboardController) FllowList() {
	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
	// 行业ID暂时不需要了调整为非必填
	chartPermissionId, _ := this.GetInt("ChartPermissionId")

	// 查询有已归类行业报告的行业IDs
	activeIndustryIds, e := models.GetActiveArticleIndustryIds()
	if e != nil {
		br.Msg = "获取失败"
		br.ErrMsg = "获取已归类行业失败, Err:" + e.Error()
		return
	}
	activeIndustryLen := len(activeIndustryIds)

	topNum := utils.PageSize15
	var condition, subCond string
	var pars, subPars []interface{}
	if chartPermissionId > 0 {
		condition += ` 	AND man.chart_permission_id = ?  `
		pars = append(pars, chartPermissionId)
	}
	if activeIndustryLen > 0 {
		condition += ` AND man.industrial_management_id IN (` + utils.GetOrmInReplace(activeIndustryLen) + `)`
		pars = append(pars, activeIndustryIds)
	}
	nowTime := time.Now().Local()
	startTime := nowTime.AddDate(0, -1, 0)
	endTime := nowTime.AddDate(0, 0, -1)
	condition += ` AND idf.create_time BETWEEN ? AND ?`
	pars = append(pars, startTime, endTime)

	// 查询近一个月至昨日关注度最高的15个产业(不再指定行业, chartPermissionId可筛选行业)
	list, e := models.GetTopIndustryFollowData(0, topNum, condition, pars)
	if e != nil {
		br.Msg = "获取失败"
		br.ErrMsg = "获取关注度最高的产业数据失败, Err:" + e.Error()
		return
	}
	industryIdArr := make([]int, 0)
	for i := range list {
		industryIdArr = append(industryIdArr, list[i].IndustrialManagementId)
	}
	idsLen := len(industryIdArr)

	// 查询当前用户关注的产业
	followList, err := models.GetUserFllowIndustrialList(uid)
	if err != nil {
		br.Msg = "获取失败"
		br.ErrMsg = "获取失败，GetUserFllowIndustrialList Err:" + err.Error()
		return
	}
	followMap := make(map[int]int, 0)
	for i := range followList {
		followMap[followList[i].IndustrialManagementId] = 1
	}

	// 查询产业标的
	if idsLen > 0 {
		subCond = `AND s.industrial_management_id IN (  ` + utils.GetOrmInReplace(idsLen) + ` )  `
		subPars = append(subPars, industryIdArr)
	}
	subjectList, err := models.GetSubjectList(subPars, subCond)
	if err != nil {
		br.Msg = "获取失败"
		br.ErrMsg = "获取失败，GetSubjectList Err:" + err.Error()
		return
	}
	subjectMap := make(map[int][]*models.IndustrialSubject)
	for i := range subjectList {
		item := new(models.IndustrialSubject)
		item.SubjectName = subjectList[i].SubjectName
		item.IndustrialManagementId = subjectList[i].IndustrialManagementId
		subjectMap[subjectList[i].IndustrialManagementId] = append(subjectMap[subjectList[i].IndustrialManagementId], item)
	}

	// 查询行业
	permissionList, e := models.GetChartPermissionAll("")
	if e != nil {
		br.Msg = "获取失败"
		br.ErrMsg = "获取行业信息失败, Err: " + e.Error()
		return
	}
	permissionMap := make(map[int]string, 0)
	for i := range permissionList {
		permissionMap[permissionList[i].ChartPermissionId] = permissionList[i].PermissionName
	}

	for k, v := range list {
		list[k].IsFollow = followMap[v.IndustrialManagementId]
		list[k].IndustrialSubjectList = subjectMap[v.IndustrialManagementId]
		list[k].PermissionName = permissionMap[v.ChartPermissionId]
	}

	page := paging.GetPaging(1, topNum, len(list))
	resp := new(models.IndustrialManagementList)
	resp.List = list
	resp.Paging = page
	br.Ret = 200
	br.Success = true
	br.Msg = "获取成功"
	br.Data = resp
}

// @Title 阅读飙升榜/报告收藏榜
// @Description 获取阅读飙升榜/报告收藏榜接口
// @Param   ChartPermissionId   query   int  false       "分类ID"
// @Param   Source   query   int  true       "来源 2：阅读飙升 ，3：报告收藏"
// @Success 200 {object} models.ArticleReportBillboardLIstResp
// @router /industry/readList [get]
func (this *ReportBillboardController) ReadList() {
	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
	}
	chartPermissionId, _ := this.GetInt("ChartPermissionId")
	source, _ := this.GetInt("Source")
	sourceArr := []int{2, 3}
	if !utils.InArrayByInt(sourceArr, source) {
		br.Msg = "来源有误"
		return
	}

	topNum := utils.PageSize15
	list := make([]*models.ArticleReportBillboardResp, 0)

	// 阅读飙升榜
	if source == 2 {
		var topCond string
		var topPars []interface{}
		if chartPermissionId > 0 {
			topCond += ` AND chart_permission_id = ?`
			topPars = append(topPars, chartPermissionId)
		}
		topList, e := models.GetTopReadRecordArticleListByCondition(topNum, topCond, topPars)
		if e != nil {
			br.Msg = "获取失败"
			br.ErrMsg = "获取报告阅读增量排行榜失败, Err:" + e.Error()
			return
		}
		for i := range topList {
			list = append(list, &models.ArticleReportBillboardResp{
				ArticleId:      topList[i].ArticleId,
				Title:          topList[i].Title,
				PublishDate:    topList[i].PublishDate,
				PermissionName: topList[i].PermissionName,
			})
		}
	}

	// 报告收藏榜
	if source == 3 {
		var collectCond string
		var collectPars []interface{}
		if chartPermissionId > 0 {
			collectCond += ` AND m.chart_permission_id = ?`
			collectPars = append(collectPars, chartPermissionId)
		}
		// 根据关注时间一个月前至昨日的增量数据排序
		nowTime := time.Now().Local()
		startTime := nowTime.AddDate(0, -1, 0)
		endTime := nowTime.AddDate(0, 0, -1)
		collectCond += ` AND ac.create_time BETWEEN ? AND ?`
		collectPars = append(collectPars, startTime, endTime)
		collectList, e := models.GetReportCollectionBillboardList(topNum, collectPars, collectCond)
		if e != nil {
			br.Msg = "获取失败"
			br.ErrMsg = "获取报告收藏排行榜失败, Err:" + e.Error()
			return
		}
		list = collectList
	}
	articleIds := make([]int, 0)
	for i := range list {
		articleIds = append(articleIds, list[i].ArticleId)
	}

	// 报告关联产业信息
	industryMap := make(map[int][]*models.IndustrialManagementIdInt, 0)
	if len(articleIds) > 0 {
		var industryCond string
		var industryPars []interface{}
		industryCond += ` AND mg.article_id IN (` + utils.GetOrmInReplace(len(articleIds)) + `)`
		industryPars = append(industryPars, articleIds)
		industryList, e := models.GetIndustrialListByarticleId(industryPars, industryCond)
		if e != nil {
			br.Msg = "获取失败"
			br.ErrMsg = "获取报告关联的产业信息失败, Err: " + e.Error()
			return
		}
		for i := range industryList {
			v := industryList[i]
			industryMap[v.ArticleId] = append(industryMap[v.ArticleId], &models.IndustrialManagementIdInt{
				ArticleId:              v.ArticleId,
				IndustrialManagementId: v.IndustrialManagementId,
				IndustryName:           v.IndustryName,
			})
		}
	}
	for k, v := range list {
		if len(industryMap[v.ArticleId]) > 0 {
			list[k].List = industryMap[v.ArticleId]
		} else {
			list[k].List = make([]*models.IndustrialManagementIdInt, 0)
		}
	}

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