hz_crm_api/controllers/help_doc/doc.go

package help_doc

import (
	"encoding/json"
	"hongze/hz_crm_api/controllers"
	"hongze/hz_crm_api/models"
	"hongze/hz_crm_api/models/help_doc"
	"html"
	"time"
)

// HelpDocController 帮助文档
type HelpDocController struct {
	controllers.BaseAuthController
}

// @Title 新增报告接口
// @Description 新增报告
// @Param	request	body help_doc.AddHelpDocReq true "type json string"
// @Success 200 {object} models.AddEnglishReportResp
// @router /add [post]
func (this *HelpDocController) Add() {
	br := new(models.BaseResponse).Init()
	defer func() {
		this.Data["json"] = br
		this.ServeJSON()
	}()
	sysUser := this.SysUser
	if sysUser == nil {
		br.Msg = "请登录"
		br.ErrMsg = "请登录，SysUser Is Empty"
		br.Ret = 408
		return
	}
	var req help_doc.AddHelpDocReq
	err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
	if err != nil {
		br.Msg = "参数解析异常！"
		br.ErrMsg = "参数解析失败，Err:" + err.Error()
		return
	}
	if req.Content == "" {
		br.Msg = "请输入内容"
		return
	}
	var anchor []byte
	if req.AnchorData != nil{
		anchor,err = json.Marshal(req.AnchorData)
		if err != nil {
			br.Msg = "参数解析异常！"
			br.ErrMsg = "参数解析失败，Err:" + err.Error()
			return
		}
	}

	item := new(help_doc.HelpDoc)
	item.ClassifyId = req.ClassifyId
	item.Title = req.Title
	item.Author = req.Author
	item.Status = req.Status
	item.Content = html.EscapeString(req.Content)
	item.CreateTime = time.Now()
	item.ModifyTime = time.Now()
	item.AdminId = sysUser.AdminId
	item.AdminRealName = sysUser.RealName
	item.Anchor = string(anchor)
	if req.Status == 2 {
		item.PublishTime = time.Now()
	}
	_, err = help_doc.AddHelpDoc(item)
	if err != nil {
		br.Msg = "保存失败"
		br.ErrMsg = "保存失败,Err:" + err.Error()
		return
	}

	if req.Status == 1 {
		br.Msg = "新增成功"
	} else {
		br.Msg = "发布成功"
	}
	br.Ret = 200
	br.Success = true

}

//// @Title 编辑报告接口
//// @Description 编辑报告
//// @Param	request	body models.EditEnglishReportReq true "type json string"
//// @Success 200 {object} models.EditEnglishReportResp
//// @router /edit [post]
//func (this *HelpDocController) Edit() {
//	br := new(models.BaseResponse).Init()
//	defer func() {
//		this.Data["json"] = br
//		this.ServeJSON()
//	}()
//	sysUser := this.SysUser
//	if sysUser == nil {
//		br.Msg = "请登录"
//		br.ErrMsg = "请登录，SysUser Is Empty"
//		br.Ret = 408
//		return
//	}
//	var req models.EditEnglishReportReq
//	err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
//	if err != nil {
//		br.Msg = "参数解析异常！"
//		br.ErrMsg = "参数解析失败，Err:" + err.Error()
//		return
//	}
//	if req.Content == "" {
//		br.Msg = "请输入内容"
//		return
//	}
//	if req.Overview == "" {
//		br.Msg = "请输入overview"
//		return
//	}
//	if req.Abstract == "" {
//		br.Msg = "请输入摘要"
//		return
//	}
//
//	//var contentSub string
//	//if req.Content != "" {
//	//	content, e := services.FilterReportContentBr(req.Content)
//	//	if e != nil {
//	//		br.Msg = "内容去除前后空格失败"
//	//		br.ErrMsg = "内容去除前后空格失败, Err: " + e.Error()
//	//		return
//	//	}
//	//	req.Content = content
//	//
//	//	contentSub, err = services.GetReportContentSub(req.Content)
//	//	if err != nil {
//	//		go alarm_msg.SendAlarmMsg("解析 ContentSub 失败，Err："+err.Error(), 3)
//	//		//utils.SendEmail(utils.APPNAME+"失败提醒", "解析 ContentSub 失败，Err:"+err.Error(), utils.EmailSendToUsers)
//	//	}
//	//}
//
//
//	item := new(help_doc.HelpDoc)
//	item.ClassifyId = req.ClassifyIdFirst
//	item.ClassifyName = req.ClassifyNameFirst
//	item.Title = req.Title
//	item.Author = req.Author
//	item.Content = html.EscapeString(req.Content)
//	item.ModifyTime = time.Now()
//	err = models.EditEnglishReport(item, req.ReportId)
//	if err != nil {
//		br.Msg = "保存失败"
//		br.ErrMsg = "保存失败,Err:" + err.Error()
//		return
//	}
//
//	reportCode := utils.MD5(strconv.Itoa(int(req.ReportId)))
//	resp := new(models.EditEnglishReportResp)
//	resp.ReportId = req.ReportId
//	resp.ReportCode = reportCode
//	br.Ret = 200
//	br.Success = true
//	br.Msg = "保存成功"
//	br.Data = resp
//}



// @Title 获取报告详情接口
// @Description 获取报告详情
// @Param	request	body models.ReportDetailReq true "type json string"
// @Success 200 {object} models.EnglishReportDetailView
// @router /detail [get]
func (this *HelpDocController) Detail() {
	br := new(models.BaseResponse).Init()
	defer func() {
		this.Data["json"] = br
		this.ServeJSON()
	}()

	docId, err := this.GetInt("DocId")
	if err != nil {
		br.Msg = "获取参数失败！"
		br.ErrMsg = "获取参数失败，Err:" + err.Error()
		return
	}
	if docId <= 0 {
		br.Msg = "参数错误"
		return
	}
	item, err := help_doc.GetHelpDocById(docId)
	if err != nil {
		br.Msg = "获取失败"
		br.ErrMsg = "获取失败，Err:" + err.Error()
		return
	}

	item.Content = html.UnescapeString(item.Content)

	var anchor []help_doc.AnchorList
	if item.Anchor != "" {
		err = json.Unmarshal([]byte(item.Anchor),&anchor)
		if err != nil {
			br.Msg = "解析失败"
			br.ErrMsg = "解析失败，Err:" + err.Error()
			return
		}
	}

	resp := help_doc.HelpDocResp{
		Id:            item.Id,
		ClassifyId:    item.ClassifyId,
		ClassifyName:  item.ClassifyName,
		Title:         item.Title,
		Author:        item.Author,
		CreateTime:    item.CreateTime,
		ModifyTime:    item.ModifyTime,
		Status:        item.Status,
		PublishTime:   item.PublishTime,
		Content:       item.Content,
		AdminId:       item.AdminId,
		AdminRealName: item.AdminRealName,
		Anchor:        anchor,
	}

	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   StartDate   query   string  true       "开始时间"
//// @Param   EndDate   query   string  true       "结束时间"
//// @Param   Frequency   query   string  true       "频度"
//// @Param   ClassifyNameFirst   query   string  true       "一级分类名称"
//// @Param   ClassifyNameSecond   query   string  true       "二级分类名称"
//// @Param   State   query   int  true       "状态"
//// @Param   KeyWord   query   string  true       "搜索关键词"
//// @Param   PublishSort   query   string  true       "desc:降序，asc 升序（预留）"
//// @Param   CompanyType   query   string  false       "产品类型，枚举值：'ficc','权益';不传默认返回全部"
//// @Success 200 {object} models.ReportListResp
//// @router /list [get]
//func (this *HelpDocController) ListReport() {
//	br := new(models.BaseResponse).Init()
//	defer func() {
//		this.Data["json"] = br
//		this.ServeJSON()
//	}()
//	sysUser := this.SysUser
//	if sysUser == nil {
//		br.Msg = "请登录"
//		br.ErrMsg = "请登录，SysUser Is Empty"
//		br.Ret = 408
//		return
//	}
//
//	pageSize, _ := this.GetInt("PageSize")
//	currentIndex, _ := this.GetInt("CurrentIndex")
//
//	startDate := this.GetString("StartDate")
//	endDate := this.GetString("EndDate")
//	frequency := this.GetString("Frequency")
//	classifyNameFirst := this.GetString("ClassifyNameFirst")
//	classifyNameSecond := this.GetString("ClassifyNameSecond")
//	state, _ := this.GetInt("State")
//	keyWord := this.GetString("KeyWord")
//	companyType := this.GetString("CompanyType")
//	// 群发邮件状态筛选
//	emailState, _ := this.GetInt("EmailState")
//
//	var startSize int
//	if pageSize <= 0 {
//		pageSize = utils.PageSize20
//	}
//	if currentIndex <= 0 {
//		currentIndex = 1
//	}
//	startSize = utils.StartIndex(currentIndex, pageSize)
//
//	var condition string
//	var pars []interface{}
//
//	if keyWord != "" {
//		condition += ` AND (title LIKE '%` + keyWord + `%' OR author LIKE '%` + keyWord + `%' ) `
//	}
//	if startDate != "" {
//		condition += ` AND create_time >= ? `
//		pars = append(pars, startDate)
//	}
//	if endDate != "" {
//		condition += ` AND create_time <= ? `
//		pars = append(pars, endDate)
//	}
//	if frequency != "" {
//		condition += ` AND frequency = ? `
//		pars = append(pars, frequency)
//	}
//	if classifyNameFirst != "" {
//		condition += ` AND classify_name_first = ? `
//		pars = append(pars, classifyNameFirst)
//	}
//
//	if classifyNameSecond != "" {
//		condition += ` AND classify_name_second = ? `
//		pars = append(pars, classifyNameSecond)
//	}
//	if state > 0 {
//		condition += ` AND state = ? `
//		pars = append(pars, state)
//	}
//	// 未群发邮件(包含推送邮件失败的)
//	if emailState == 1 {
//		failIds, e := models.GetHasFailEmailLogReportIds()
//		if e != nil {
//			br.Msg = "获取失败"
//			br.ErrMsg = "获取存在邮件推送失败记录的英文报告IDs失败, Err:" + e.Error()
//			return
//		}
//		condition += ` AND email_state = 0`
//		if len(failIds) > 0 {
//			condition += ` OR id IN (` + utils.GetOrmInReplace(len(failIds)) + `)`
//			pars = append(pars, failIds)
//		}
//	}
//	// 已群发邮件
//	if emailState == 2 {
//		successIds, e := models.GetSuccessEmailLogReportIds()
//		if e != nil {
//			br.Msg = "获取失败"
//			br.ErrMsg = "获取邮件推送记录均为成功的英文报告IDs失败, Err:" + e.Error()
//			return
//		}
//		condition += ` AND email_state = 1`
//		if len(successIds) > 0 {
//			condition += ` AND id IN (` + utils.GetOrmInReplace(len(successIds)) + `)`
//			pars = append(pars, successIds)
//		}
//	}
//
//	total, err := models.GetEnglishReportListCount(condition, pars, companyType)
//	if err != nil {
//		br.Msg = "获取失败"
//		br.ErrMsg = "获取失败，Err:" + err.Error()
//		return
//	}
//	list, err := models.GetEnglishReportList(condition, pars, companyType, startSize, pageSize)
//	if err != nil {
//		br.Msg = "获取失败"
//		br.ErrMsg = "获取失败，Err:" + err.Error()
//		return
//	}
//
//	// 获取邮件配置-是否有权限群发
//	conf := new(models.EnglishReportEmailConf)
//	authKey := "english_report_email_conf"
//	confAuth, e := company.GetConfigDetailByCode(authKey)
//	if e != nil {
//		br.Msg = "获取失败"
//		br.ErrMsg = "获取群发邮件权限失败, Err: " + e.Error()
//		return
//	}
//	if confAuth.ConfigValue == "" {
//		br.Msg = "获取失败"
//		br.ErrMsg = "群发邮件配置为空"
//		return
//	}
//	if e := json.Unmarshal([]byte(confAuth.ConfigValue), &conf); e != nil {
//		br.Msg = "获取失败"
//		br.ErrMsg = "群发邮件配置有误"
//		return
//	}
//	authOk := false
//	authArr := strings.Split(conf.SendAuthGroup, ",")
//	if utils.InArrayByStr(authArr, sysUser.RoleTypeCode) {
//		authOk = true
//	}
//
//	// 是否有群发邮件失败的记录，标记红点
//	failList, e := models.GetEnglishReportEmailLogFailList(0)
//	if e != nil {
//		br.Msg = "获取失败"
//		br.ErrMsg = "获取群发邮件记录失败, Err: " + e.Error()
//		return
//	}
//	failMap := make(map[int]bool, 0)
//	for i := range failList {
//		failMap[failList[i].ReportId] = true
//	}
//
//	for _, item := range list {
//		if item.State == 2 {
//			item.ShareUrl = "https://share.hzinsights.com/reportEn?code=" + item.ReportCode
//		}
//		item.EmailAuth = authOk
//		item.EmailHasFail = failMap[item.Id]
//		// 邮箱PV大于0的时候, 不展示最初版本的PV
//		if item.PvEmail > 0 {
//			item.Pv = 0
//		}
//
//		/*key := fmt.Sprint(`crm:enReport:edit:`, item.Id)
//		opUserId, _ := utils.Rc.RedisInt(key)
//		//如果当前没有人操作，获取当前操作人是本人，那么编辑按钮可用
//		if opUserId <= 0 || (opUserId == this.SysUser.AdminId) {
//			item.CanEdit = true
//		} else {
//			adminInfo, errAdmin := system.GetSysUserById(opUserId)
//			if errAdmin != nil {
//				br.Msg = "获取失败"
//				br.ErrMsg = "获取失败，Err:" + errAdmin.Error()
//				return
//			}
//			item.Editor = adminInfo.RealName
//		}*/
//		markStatus, err := services.UpdateEnReportEditMark(item.Id, this.SysUser.AdminId, 2, this.SysUser.RealName)
//		if err != nil {
//			br.Msg = "查询标记状态失败"
//			br.ErrMsg = "查询标记状态失败，Err:" + err.Error()
//			return
//		}
//		if markStatus.Status == 0 {
//			item.CanEdit = true
//		} else {
//			item.Editor = markStatus.Editor
//		}
//	}
//	page := paging.GetPaging(currentIndex, pageSize, total)
//	resp := new(models.EnglishReportListResp)
//	resp.Paging = page
//	resp.List = list
//	br.Ret = 200
//	br.Success = true
//	br.Msg = "获取成功"
//	br.Data = resp
//}
//
//// @Title 发布报告接口
//// @Description 发布报告
//// @Param	request	body models.PublishReq true "type json string"
//// @Success 200 Ret=200 发布成功
//// @router /publish [post]
//func (this *HelpDocController) PublishReport() {
//	br := new(models.BaseResponse).Init()
//	defer func() {
//		this.Data["json"] = br
//		this.ServeJSON()
//	}()
//	var req models.PublishReq
//	err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
//	if err != nil {
//		br.Msg = "参数解析异常！"
//		br.ErrMsg = "参数解析失败，Err:" + err.Error()
//		return
//	}
//	reportIds := req.ReportIds
//	if reportIds == "" {
//		br.Msg = "参数错误"
//		br.ErrMsg = "参数错误，报告id不可为空"
//		return
//	}
//
//	reportArr := strings.Split(reportIds, ",")
//	for _, v := range reportArr {
//		vint, err := strconv.Atoi(v)
//		if err != nil {
//			br.Msg = "参数错误"
//			br.ErrMsg = "参数错误,Err:" + err.Error()
//			return
//		}
//		report, err := models.GetEnglishReportById(vint)
//		if err != nil {
//			br.Msg = "获取报告信息失败"
//			br.ErrMsg = "获取报告信息失败,Err:" + err.Error()
//			return
//		}
//		if report == nil {
//			br.Msg = "报告不存在"
//			return
//		}
//
//		var tmpErr error
//
//		if report.Content == "" {
//			br.Msg = "报告内容为空，不可发布"
//			br.ErrMsg = "报告内容为空，不需要生成,report_id:" + strconv.Itoa(report.Id)
//			return
//		}
//		if tmpErr = models.PublishEnglishReportById(report.Id); tmpErr != nil {
//			br.Msg = "报告发布失败"
//			br.ErrMsg = "报告发布失败, Err:" + tmpErr.Error() + ", report_id:" + strconv.Itoa(report.Id)
//			return
//		}
//		go func() {
//			_ = services.UpdateEnglishReportEs(report.Id, 2)
//		}()
//	}
//
//	br.Ret = 200
//	br.Success = true
//	br.Msg = "发布成功"
//}
//
//// @Title 取消发布报告接口
//// @Description 取消发布报告
//// @Param	request	body models.PublishCancelReq true "type json string"
//// @Success 200 Ret=200 取消发布成功
//// @router /publish/cancel [post]
//func (this *HelpDocController) PublishCancleReport() {
//	br := new(models.BaseResponse).Init()
//	defer func() {
//		this.Data["json"] = br
//		this.ServeJSON()
//	}()
//	var req models.PublishCancelReq
//	err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
//	if err != nil {
//		br.Msg = "参数解析异常！"
//		br.ErrMsg = "参数解析失败，Err:" + err.Error()
//		return
//	}
//	if req.ReportIds <= 0 {
//		br.Msg = "参数错误"
//		br.ErrMsg = "参数错误，报告id不可为空"
//		return
//	}
//	err = models.PublishCancelEnglishReport(req.ReportIds)
//	if err != nil {
//		br.Msg = "取消发布失败"
//		br.ErrMsg = "取消发布失败,Err:" + err.Error()
//		return
//	}
//	// 更新es里的报告状态
//	go func() {
//		_ = services.UpdateEnglishReportEs(req.ReportIds, 1)
//	}()
//	br.Ret = 200
//	br.Success = true
//	br.Msg = "取消发布成功"
//}
//
//// @Title 删除报告接口
//// @Description 删除报告
//// @Param	request	body models.DeleteReq true "type json string"
//// @Success 200 Ret=200 删除成功
//// @router /delete [post]
//func (this *HelpDocController) Delete() {
//	br := new(models.BaseResponse).Init()
//	defer func() {
//		this.Data["json"] = br
//		this.ServeJSON()
//	}()
//	var req models.DeleteReq
//	err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
//	if err != nil {
//		br.Msg = "参数解析异常！"
//		br.ErrMsg = "参数解析失败，Err:" + err.Error()
//		return
//	}
//	if req.ReportIds <= 0 {
//		br.Msg = "参数错误"
//		br.ErrMsg = "参数错误，报告id不可为空"
//		return
//	}
//	reportInfo, err := models.GetEnglishReportById(req.ReportIds)
//	if err != nil {
//		if err.Error() == utils.ErrNoRow() {
//			br.Msg = "报告不存在"
//			return
//		}
//		br.Msg = "查询报告信息失败"
//		br.ErrMsg = "查询报告信息失败, Err" + err.Error()
//		return
//	}
//
//	// 更新es里的报告状态
//	_ = services.UpdateEnglishReportEs(req.ReportIds, 1)
//	if err = models.DeleteEnglishReportAndChapter(reportInfo); err != nil {
//		br.Msg = "删除失败"
//		br.ErrMsg = "删除报告失败, Err: " + err.Error()
//		return
//	}
//
//	// 重置PPT关联报告
//	go func() {
//		_ = services.ResetPPTReport(req.ReportIds, true)
//	}()
//
//	go func() {
//		_ = services.EnglishPolicyReportSyncCancel(reportInfo)
//	}()
//	br.Ret = 200
//	br.Success = true
//	br.Msg = "删除成功"
//}