eta_api/models/document_manage_model/outside_report.go

// @Author gmy 2024/9/19 14:53:00
package document_manage_model

import (
	"eta/eta_api/global"
	"eta/eta_api/utils"

	"github.com/rdlucklib/rdluck_tools/paging"
	"gorm.io/gorm"
)

type OutsideReport struct {
	OutsideReportId  int    `orm:"column(outside_report_id);pk" gorm:"primaryKey" description:"外部报告ID"`
	Source           int    `orm:"column(source)" description:"来源，1：ETA系统录入；2：API接口录入；3：邮件监听录入"`
	Title            string `orm:"column(title)" description:"报告标题"`
	Abstract         string `orm:"column(abstract)" description:"摘要"`
	ClassifyId       int    `orm:"column(classify_id)" description:"所属分类id"`
	ClassifyName     string `orm:"column(classify_name)" description:"所属分类名称（整个分类链条）"`
	Content          string `orm:"column(content)" description:"报告富文本内容"`
	SysUserId        int    `orm:"column(sys_user_id)" description:"创建人id"`
	SysUserName      string `orm:"column(sys_user_name)" description:"创建人姓名"`
	EmailMessageUid  int    `orm:"column(email_message_uid)" description:"该邮件在邮箱中的唯一id"`
	ReportUpdateTime string `orm:"column(report_update_time)" description:"报告更新时间，如果来源于邮件，那么取邮件的收件时间"`
	ModifyTime       string `orm:"column(modify_time)" description:"最近一次修改时间"`
	CreateTime       string `orm:"column(create_time)" description:"创建时间"`
	ReportCode       string `orm:"column(report_code)" description:"报告唯一编码"`
}
// AfterFind
// @Description: 转成需要输出的格式
// @receiver m
func (m *OutsideReport) AfterFind(db *gorm.DB) (err error) {
	m.ReportUpdateTime = utils.GormDateStrToDateTimeStr(m.ReportUpdateTime)
	m.ModifyTime = utils.GormDateStrToDateTimeStr(m.ModifyTime)
	m.CreateTime = utils.GormDateStrToDateTimeStr(m.CreateTime)

	return
}

// ConvertTimeStr
// @Description: 转成需要输出的格式
// @receiver m
func (m *OutsideReport) ConvertTimeStr() {
	m.ReportUpdateTime = utils.GormDateStrToDateTimeStr(m.ReportUpdateTime)
	m.ModifyTime = utils.GormDateStrToDateTimeStr(m.ModifyTime)
	m.CreateTime = utils.GormDateStrToDateTimeStr(m.CreateTime)

	return
}
type OutsideReportPage struct {
	List   []OutsideReport    `description:"报告列表"`
	Paging *paging.PagingItem `description:"分页数据"`
}

type OutsideReportBO struct {
	OutsideReportId int    `orm:"column(outside_report_id);pk" gorm:"primaryKey" description:"外部报告ID"`
	Source          int    `orm:"column(source)" description:"来源，1：ETA系统录入；2：API接口录入；3：邮件监听录入"`
	Title           string `orm:"column(title)" description:"报告标题"`
	Abstract        string `orm:"column(abstract)" description:"摘要"`
	ClassifyId      int    `orm:"column(classify_id)" description:"所属分类id"`
	ClassifyName    string `orm:"column(classify_name)" description:"所属分类名称（整个分类链条）"`
	Content         string `orm:"column(content)" description:"报告富文本内容"`
	SysUserId       int    `orm:"column(sys_user_id)" description:"创建人id"`
	SysUserName     string `orm:"column(sys_user_name)" description:"创建人姓名"`
	ReportCode      string `orm:"column(report_code)" description:"报告唯一编码"`
	ModifyTime      string `orm:"column(modify_time)" description:"最近一次修改时间"`
	CreateTime      string `orm:"column(create_time)" description:"创建时间"`
	AttachmentList  []*OutsideReportAttachment
}

// GetOutsideReportListByConditionCount 根据条件查询列表条数
func GetOutsideReportListByConditionCount(condition string, pars []interface{}, chartPermissionIdList []string) (count int, err error) {
	o := global.DbMap[utils.DbNameReport]
	var sql string
	if len(chartPermissionIdList) > 0 {
		sql = `select count(1) from (`
	}
	sql += `SELECT COUNT( DISTINCT t1.outside_report_id ) 
			FROM outside_report t1 
			    LEFT JOIN chart_permission_search_key_word_mapping t2 ON t1.classify_id = t2.classify_id 
			WHERE 1 = 1 `
	sql += condition
	if len(chartPermissionIdList) > 0 {
		sql += ` ) t`
	}

	err = o.Raw(sql, pars...).Scan(&count).Error
	if err != nil {
		return 0, err
	}

	return count, nil
}

// GetOutsideReportListByCondition 根据条件查询列表
func GetOutsideReportListByCondition(condition string, pars []interface{}) (list []OutsideReport, err error) {
	o := global.DbMap[utils.DbNameReport]
	sql := `select DISTINCT t1.outside_report_id, t1.source, t1.title, t1.abstract, t1.classify_id, 
t1.classify_name, t1.sys_user_id, t1.sys_user_name, t1.email_message_uid, t1.report_update_time, 
t1.modify_time, t1.create_time, t1.report_code from outside_report t1 
left join chart_permission_search_key_word_mapping t2 on t1.classify_id = t2.classify_id  where 1 = 1 `
	sql += condition
	err = o.Raw(sql, pars...).Find(&list).Error
	if err != nil {
		return nil, err
	}

	return list, nil
}

// SaveOutsideReport 保存报告
func SaveOutsideReport(outsideReport OutsideReport) (id int64, err error) {
	o := global.DbMap[utils.DbNameReport]
	err = o.Create(&outsideReport).Error
	if err != nil {
		return
	}
	id = int64(outsideReport.OutsideReportId)
	return
}

// GetOutsideReportById 根据ID获取报告
func GetOutsideReportById(id int) (outsideReport *OutsideReport, err error) {
	o := global.DbMap[utils.DbNameReport]

	outsideReport = &OutsideReport{}

	//err = o.QueryTable("outside_report").Filter("outside_report_id", id).One(outsideReport)
	err = o.Raw("select * from outside_report where outside_report_id = ?", id).First(outsideReport).Error
	if err != nil {
		return
	}
	outsideReport.ConvertTimeStr()
	return
}

// UpdateOutsideReport 更新报告
func UpdateOutsideReport(outsideReport *OutsideReport, cols []string) (err error) {
	o := global.DbMap[utils.DbNameReport]
	err = o.Select(cols).Updates(outsideReport).Error
	return
}

// DeleteOutsideReport 删除报告
func DeleteOutsideReport(id int) (err error) {
	o := global.DbMap[utils.DbNameReport]
	err = o.Exec("delete from outside_report where outside_report_id = ?", id).Error
	//err = o.QueryTable("outside_report").Filter("outside_report_id", id).Delete()
	return
}

// GetOutsideReportListByClassifyId 根据分类id查询报告列表
func GetOutsideReportListByClassifyId(classifyId int) (list []OutsideReport, err error) {
	o := global.DbMap[utils.DbNameReport]
	sql := `select * from outside_report where classify_id = ?`
	err = o.Raw(sql, classifyId).Find(&list).Error
	if err != nil {
		return nil, err
	}

	return list, err
}