hongze_yb/logic/report/research_report.go

package report

import (
	"context"
	"encoding/json"
	"errors"
	"fmt"
	"hongze/hongze_yb/global"
	"hongze/hongze_yb/models/tables/company"
	"hongze/hongze_yb/models/tables/company_report_permission"
	"hongze/hongze_yb/models/tables/research_report"
	"hongze/hongze_yb/models/tables/research_report_type"
	"hongze/hongze_yb/models/tables/user_view_history"
	"hongze/hongze_yb/models/tables/wx_user"
	"hongze/hongze_yb/services"
	"hongze/hongze_yb/utils"
	"strconv"
	"time"
)

type ResearchReportInfo struct {
	ResearchReportInfo            *research_report.ResearchReport                     `json:"research_report_info"`
	ResearchReportTypeList        []*company_report_permission.ResearchReportTypeList `json:"research_report_type_list"`
	HasMenu                       int                                                 `json:"has_menu"`
	ResearchReportTypeContentList []*research_report.ResearchReportTypeContent        `description:"报告详情"`
	LikeNum                       int64                                               `description:"点赞总数" json:"like_num"`
	LikeEnabled                   int8                                                `description:"是否已点赞： 0-未点赞 1-已点赞" json:"like_enabled"`
}

// GetResearchReportInfo 获取报告详情
func GetResearchReportInfo(researchReportId, userId uint64) (result ResearchReportInfo, hasPermission bool, err error) {
	//获取报告详情
	reportInfo, err := research_report.GetByResearchReportId(researchReportId)
	if err != nil {
		return
	}
	reportType := reportInfo.Type
	//这些个报告需要做权限校验

	if utils.InArray(reportInfo.Type, []string{"month", "two_week", "other"}) {
		list, tmpErr := company_report_permission.GetReportVarietyList(userId, reportType)
		if tmpErr != nil {
			err = tmpErr
			return
		}
		for _, v := range list {
			if reportInfo.ResearchReportID == v.ReportChapterTypeId {
				hasPermission = true
				break
			}
		}
		if !hasPermission {
			//permissionName, tmpErr := company_report_permission.GetPermissionNameByReportId(reportInfo.ResearchReportID, reportType)
			//if tmpErr != nil {
			//	err = tmpErr
			//	return
			//}
			return
		}
	} else {
		hasPermission = true
	}

	researchReportTypeList := make([]*company_report_permission.ResearchReportTypeList, 0)
	tmpResearchReportTypeList, err := company_report_permission.GetResearchReportType(reportInfo.ResearchReportID, userId, reportInfo.Type)
	if err != nil {
		return
	}
	reportDate := reportInfo.ResearchReportDate
	for _, v := range tmpResearchReportTypeList {
		if reportDate.Before(v.PauseStartTime) || reportDate.After(v.PauseEndTime) {
			researchReportTypeList = append(researchReportTypeList, v)
		}
	}

	// 联系人信息
	strInt64 := strconv.FormatUint(userId, 10)
	id, _ := strconv.Atoi(strInt64)
	wxUserInfo, err := wx_user.GetByUserId(id)
	if err != nil {
		fmt.Println("GetByUserId:", err.Error())
		return
	}
	companyInfo, tmpErr := company.GetByCompanyId(wxUserInfo.CompanyID)
	if tmpErr != nil {
		err = tmpErr
		if tmpErr == utils.ErrNoRow {
			err = errors.New("找不到该客户")
			return
		}
		return
	}

	//查询是否读过这篇报告，如果未读过则阅读人数+1
	_, err = user_view_history.GetReportByUserId(userId, reportInfo.ResearchReportID)
	if err != nil {
		err = reportInfo.UpdateViewers()
		if err != nil {
			fmt.Println("UpdateViewers err:", err.Error())
		}
	}

	//新增userViewHistory记录
	userViewHistory := &user_view_history.UserViewHistory{
		ViewHistoryID:        0,
		UserID:               userId,
		Mobile:               wxUserInfo.Mobile,
		Email:                wxUserInfo.Email,
		RealName:             wxUserInfo.RealName,
		CompanyName:          companyInfo.CompanyName,
		ViewTitle:            "",
		ViewPage:             "",
		ReportChapterModule:  "",
		CreatedTime:          time.Now(),
		LastUpdatedTime:      time.Now(),
		Type:                 "weekly_report",
		ResearchReportID:     reportInfo.ResearchReportID,
		ResearchReportTypeID: 0,
	}
	err = userViewHistory.AddUserViewHistory()
	if err != nil {
		fmt.Println("AddUserViewHistory err", err.Error())
	}

	//添加阅读日志的数据加入到redis
	go PushViewRecordNewRedisData(userViewHistory, int(wxUserInfo.CompanyID))

	//查询点赞数
	likeNum,likeEnabled, _ := services.GetReportLikeByReportIdOldReportId(wxUserInfo.UserID, 0, 0, int(researchReportId),0)

	result = ResearchReportInfo{
		ResearchReportInfo:     reportInfo,
		ResearchReportTypeList: researchReportTypeList,
		HasMenu:                1,
		LikeNum:                likeNum,
		LikeEnabled:            likeEnabled,
	}

	if len(researchReportTypeList) <= 0 {
		
	} else if len(researchReportTypeList) == 1 {
		//只有一个章节，即没有目录的时候，需要直接返回章节详情
		result.HasMenu = 0
		researchReportTypeContent, tmpErr := research_report.GetResearchReportTypeContentList(researchReportTypeList[0].ResearchReportTypeId)
		if tmpErr != nil {
			return
		}
		result.ResearchReportTypeContentList = researchReportTypeContent
	}
	return
}

type ResearchReportTypeContentInfo struct {
	ResearchReportTypeInfo        *research_report_type.ResearchReportTypeInfo `json:"research_report_type_info"`
	Add                           int                                          `json:"add"`
	ResearchReportTypeContentList []*research_report.ResearchReportTypeContent `description:"报告详情" json:"research_report_type_content_list"`
	LikeNum                       int64                                        `description:"点赞总数" json:"like_num"`
	LikeEnabled                   int8                                         `description:"是否已点赞： 0-未点赞 1-已点赞" json:"like_enabled"`
}

// GetResearchReportTypeContentInfo 获取报告章节详情
func GetResearchReportTypeContentInfo(researchReportTypeId, userId uint64) (result ResearchReportTypeContentInfo, hasPermission bool, err error) {
	//获取章节详情
	researchReportTypeContentList, err := research_report.GetResearchReportTypeContentList(researchReportTypeId)
	if err != nil {
		return
	}
	researchReportTypeInfo, err := research_report_type.GetResearchReportTypeInfo(researchReportTypeId)
	//获取报告详情
	reportInfo, err := research_report.GetByResearchReportId(researchReportTypeInfo.ResearchReportID)
	if err != nil {
		return
	}
	reportType := reportInfo.Type

	//这些个报告需要做权限校验
	if utils.InArray(reportInfo.Type, []string{"week", "month", "two_week", "other"}) {
		list, tmpErr := company_report_permission.GetReportVarietyList(userId, reportType)
		if tmpErr != nil {
			err = tmpErr
			return
		}

		if reportInfo.Type == "week" {
			//周报校验章节是否在权限内
			for _, v := range list {
				if researchReportTypeInfo.ReportChapterTypeId == v.ReportChapterTypeId {
					hasPermission = true
					break
				}
			}
		} else {
			//双周报和月报校验 类型是否在权限内
			for _, v := range list {
				if reportInfo.ResearchReportID == v.ReportChapterTypeId {
					hasPermission = true
					break
				}
			}
		}

		if !hasPermission {
			//permissionName, tmpErr := company_report_permission.GetPermissionNameByReportId(reportInfo.ResearchReportID, reportType)
			//if tmpErr != nil {
			//	err = tmpErr
			//	return
			//}
			return
		}
	} else {
		hasPermission = true
	}
	add := 1
	if len(researchReportTypeContentList) > 0 {
		add = 0
	}
	// 联系人信息
	strInt64 := strconv.FormatUint(userId, 10)
	id, _ := strconv.Atoi(strInt64)
	wxUserInfo, err := wx_user.GetByUserId(id)
	if err != nil {
		fmt.Println("GetByUserId:", err.Error())
		return
	}
	companyInfo, tmpErr := company.GetByCompanyId(wxUserInfo.CompanyID)
	if tmpErr != nil {
		err = tmpErr
		if tmpErr == utils.ErrNoRow {
			err = errors.New("找不到该客户")
			return
		}
		return
	}

	//新增userViewHistory记录
	userViewHistory := &user_view_history.UserViewHistory{
		ViewHistoryID:        0,
		UserID:               userId,
		Mobile:               wxUserInfo.Mobile,
		Email:                wxUserInfo.Email,
		RealName:             wxUserInfo.RealName,
		CompanyName:          companyInfo.CompanyName,
		ViewTitle:            "",
		ViewPage:             "",
		ReportChapterModule:  "",
		CreatedTime:          time.Now(),
		LastUpdatedTime:      time.Now(),
		Type:                 "weekly_report",
		ResearchReportID:     reportInfo.ResearchReportID,
		ResearchReportTypeID: researchReportTypeId,
	}
	err = userViewHistory.AddUserViewHistory()
	if err != nil {
		fmt.Println("AddUserViewHistory err", err.Error())
	}

	//添加阅读日志的数据加入到redis
	go PushViewRecordNewRedisData(userViewHistory, int(wxUserInfo.CompanyID))

	//查询点赞数
	likeNum,likeEnabled, _ := services.GetReportLikeByReportIdOldReportId(wxUserInfo.UserID, 0, 0, int(researchReportTypeInfo.ResearchReportID), int(researchReportTypeInfo.ResearchReportTypeID))
	result = ResearchReportTypeContentInfo{
		ResearchReportTypeContentList: researchReportTypeContentList,
		ResearchReportTypeInfo:        researchReportTypeInfo,
		Add:                           add,
		LikeNum:                       likeNum,
		LikeEnabled:                   likeEnabled,
	}
	return
}

// UserViewRedisData 阅读数据
type UserViewRedisData struct {
	Mobile      string `json:"mobile"`
	Email       string `json:"email"`
	RealName    string `json:"real_name"`
	CompanyName string `json:"company_name"`
	ViewTime    string `json:"view_time" description:"阅读时间，格式：2022-02-17 13:06:13"`
	ProductId   int    `json:"product_id" description:"报告所属产品，ficc：1，权益：2"`
	CompanyId   int    `json:"company_id" description:"客户id"`
}

// PushViewRecordNewRedisData 阅读数据加入到redis
func PushViewRecordNewRedisData(userViewHistory *user_view_history.UserViewHistory, companyId int) bool {
	data := &UserViewRedisData{
		Mobile:      userViewHistory.Mobile,
		Email:       userViewHistory.Email,
		RealName:    userViewHistory.RealName,
		CompanyName: userViewHistory.CompanyName,
		ViewTime:    userViewHistory.CreatedTime.Format(utils.FormatDateTime),
		ProductId:   1,
		CompanyId:   companyId,
	}

	if global.Redis != nil {
		dataStr, _ := json.Marshal(data)
		_, err := global.Redis.LPush(context.TODO(), utils.CACHE_KEY_USER_VIEW, dataStr).Result()
		if err != nil {
			fmt.Println("PushViewRecordNewRedisData LPush Err:" + err.Error())
		}
		return true
	}
	return false
}