package models import ( "encoding/json" "errors" "eta_gn/eta_api/global" "eta_gn/eta_api/utils" "fmt" "github.com/rdlucklib/rdluck_tools/paging" "gorm.io/gorm" "strings" "time" ) const ( ReportStateUnpublished = 1 // 未发布 ReportStatePublished = 2 // 已发布 ReportStateWaitSubmit = 3 // 待提交 ReportStateWaitApprove = 4 // 审批中 ReportStateRefused = 5 // 已驳回 ReportStatePass = 6 // 已通过 ) const ( ReportOperateAdd = 1 // 新增报告 ReportOperateEdit = 2 // 编辑报告 ReportOperatePublish = 3 // 发布报告 ReportOperateCancelPublish = 4 // 取消发布报告 ReportOperateSubmitApprove = 5 // 提交审批 ReportOperateCancelApprove = 6 // 撤回审批 ) type Report struct { Id int `gorm:"column:id;primaryKey;autoIncrement" description:"报告Id"` AddType int `gorm:"column:add_type" description:"新增方式：1:新增报告，2:继承报告"` ClassifyIdFirst int `gorm:"column:classify_id_first" description:"一级分类id"` ClassifyNameFirst string `gorm:"column:classify_name_first" description:"一级分类名称"` ClassifyIdSecond int `gorm:"column:classify_id_second" description:"二级分类id"` ClassifyNameSecond string `gorm:"column:classify_name_second" description:"二级分类名称"` Title string `gorm:"column:title" description:"标题"` Abstract string `gorm:"column:abstract" description:"摘要"` Author string `gorm:"column:author" description:"作者"` Frequency string `gorm:"column:frequency" description:"频度"` CreateTime time.Time `gorm:"column:create_time" description:"创建时间"` ModifyTime time.Time `gorm:"column:modify_time;autoUpdateTime" description:"修改时间"` State int `gorm:"column:state" description:"1:未发布；2:已发布；3-待提交；4-待审批；5-已驳回；6-已通过"` PublishTime time.Time `gorm:"column:publish_time" description:"发布时间"` Stage int `gorm:"column:stage" description:"期数"` MsgIsSend int `gorm:"column:msg_is_send" description:"消息是否已发送，0:否，1:是"` ThsMsgIsSend int `gorm:"column:ths_msg_is_send" description:"客户群消息是否已发送，0:否，1:是"` Content string `gorm:"column:content" description:"内容"` VideoUrl string `gorm:"column:video_url" description:"音频文件URL"` VideoName string `gorm:"column:video_name" description:"音频文件名称"` VideoPlaySeconds string `gorm:"column:video_play_seconds" description:"音频播放时长"` VideoSize string `gorm:"column:video_size" description:"音频文件大小，单位M"` ContentSub string `gorm:"column:content_sub" description:"内容前两个章节"` ReportCode string `gorm:"column:report_code" description:"报告唯一编码"` ReportVersion int `gorm:"column:report_version" description:"1:旧版,2:新版"` HasChapter int `gorm:"column:has_chapter" description:"是否有章节 0-否 1-是"` ChapterType string `gorm:"column:chapter_type" description:"章节类型 day-晨报 week-周报"` OldReportId int `gorm:"column:old_report_id" description:"research_report表ID, 大于0则表示该报告为老后台同步过来的"` MsgSendTime time.Time `gorm:"column:msg_send_time" description:"模版消息发送时间"` AdminId int `gorm:"column:admin_id" description:"创建者账号"` AdminRealName string `gorm:"column:admin_real_name" description:"创建者姓名"` ApproveTime time.Time `gorm:"column:approve_time" description:"审批时间"` ApproveId int `gorm:"column:approve_id" description:"审批ID"` DetailImgUrl string `gorm:"column:detail_img_url" description:"报告详情长图地址"` DetailPdfUrl string `gorm:"column:detail_pdf_url" description:"报告详情PDF地址"` ContentStruct string `gorm:"column:content_struct" description:"内容组件"` LastModifyAdminId int `gorm:"column:last_modify_admin_id" description:"最后更新人ID"` LastModifyAdminName string `gorm:"column:last_modify_admin_name" description:"最后更新人姓名"` ContentModifyTime time.Time `gorm:"column:content_modify_time" description:"内容更新时间"` Pv int `gorm:"column:pv" description:"pv"` Uv int `gorm:"column:uv" description:"uv"` HeadImg string `gorm:"column:head_img" description:"报告头图地址"` EndImg string `gorm:"column:end_img" description:"报告尾图地址"` CanvasColor string `gorm:"column:canvas_color" description:"画布颜色"` NeedSplice int `gorm:"column:need_splice" description:"是否拼接版头版位的标记，主要是为了兼容历史报告。0-不需要 1-需要"` HeadResourceId int `gorm:"column:head_resource_id" description:"版头资源ID"` EndResourceId int `gorm:"column:end_resource_id" description:"版尾资源ID"` ClassifyIdThird int `gorm:"column:classify_id_third" description:"三级分类id"` ClassifyNameThird string `gorm:"column:classify_name_third" description:"三级分类名称"` CollaborateType int8 `gorm:"column:collaborate_type" description:"协作方式，1：个人，2：多人协作。默认：1"` ReportLayout int8 `gorm:"column:report_layout" description:"报告布局，1：常规布局，2：智能布局。默认：1"` IsPublicPublish int8 `gorm:"column:is_public_publish" description:"是否公开发布，1：是，2：否"` ReportCreateTime time.Time `gorm:"column:report_create_time" description:"报告时间创建时间"` InheritReportId int `gorm:"column:inherit_report_id" description:"待继承的报告ID"` VoiceGenerateType int `gorm:"column:voice_generate_type" description:"音频生成方式，0：系统生成，1：人工上传"` } type ReportList struct { Id int `gorm:"column:id" description:"报告Id"` AddType int `gorm:"column:add_type" description:"新增方式：1:新增报告，2:继承报告"` ClassifyIdFirst int `gorm:"column:classify_id_first" description:"一级分类id"` ClassifyNameFirst string `gorm:"column:classify_name_first" description:"一级分类名称"` ClassifyIdSecond int `gorm:"column:classify_id_second" description:"二级分类id"` ClassifyNameSecond string `gorm:"column:classify_name_second" description:"二级分类名称"` Title string `gorm:"column:title" description:"标题"` Abstract string `gorm:"column:abstract" description:"摘要"` Author string `gorm:"column:author" description:"作者"` Frequency string `gorm:"column:frequency" description:"频度"` CreateTime *global.LocalTime `gorm:"column:create_time" description:"创建时间"` ModifyTime *global.LocalTime `gorm:"column:modify_time;autoUpdateTime" description:"修改时间"` State int `gorm:"column:state" description:"1:未发布；2:已发布；3-待提交；4-待审批；5-已驳回；6-已通过"` PublishTime *global.LocalTime `gorm:"column:publish_time" description:"发布时间"` PrePublishTime string `gorm:"column:pre_publish_time" description:"预发布时间"` Stage int `gorm:"column:stage" description:"期数"` MsgIsSend int `gorm:"column:msg_is_send" description:"模板消息是否已发送，0:否，1:是"` Content string `gorm:"column:content" description:"内容"` VideoUrl string `gorm:"column:video_url" description:"音频文件URL"` VideoName string `gorm:"column:video_name" description:"音频文件名称"` VideoPlaySeconds string `gorm:"column:video_play_seconds" description:"音频播放时长"` ContentSub string `gorm:"column:content_sub" description:"内容前两个章节"` Pv int `gorm:"column:pv" description:"Pv"` Uv int `gorm:"column:uv" description:"Uv"` ReportCode string `gorm:"column:report_code" description:"报告唯一编码"` ReportVersion int `gorm:"column:report_version" description:"1:旧版,2:新版"` ThsMsgIsSend int `gorm:"column:ths_msg_is_send" description:"客户群消息是否已发送，0:否，1:是"` NeedThsMsg int `gorm:"column:need_ths_msg" description:"是否需要推送客群消息 0-否 1-是"` HasChapter int `gorm:"column:has_chapter" description:"是否有章节 0-否 1-是"` ChapterType string `gorm:"column:chapter_type" description:"章节类型 day-晨报 week-周报"` ChapterVideoList []*ReportChapterVideoList `gorm:"-" description:"章节音频列表"` // 不映射到数据库 OldReportId int `gorm:"column:old_report_id" description:"research_report表ID, 大于0则表示该报告为老后台同步过来的"` MsgSendTime *global.LocalTime `gorm:"column:msg_send_time" description:"模版消息发送时间"` CanEdit bool `gorm:"column:can_edit" description:"是否可编辑"` HasAuth bool `gorm:"column:has_auth" description:"是否可操作"` Editor string `gorm:"column:editor" description:"编辑人"` AdminId int `gorm:"column:admin_id" description:"创建者账号"` AdminRealName string `gorm:"column:admin_real_name" description:"创建者姓名"` ApproveTime *global.LocalTime `gorm:"column:approve_time" description:"审批时间"` DetailImgUrl string `gorm:"column:detail_img_url" description:"报告详情长图地址"` DetailPdfUrl string `gorm:"column:detail_pdf_url" description:"报告详情PDF地址"` CollaborateType int8 `gorm:"column:collaborate_type" description:"协作方式，1：个人，2：多人协作。默认：1"` ReportLayout int8 `gorm:"column:report_layout" description:"报告布局，1：常规布局，2：智能布局。默认：1"` IsPublicPublish int8 `gorm:"column:is_public_publish" description:"是否公开发布，1：是，2：否"` ReportCreateTime *global.LocalTime `gorm:"column:report_create_time" description:"报告时间创建时间"` ContentStruct string `gorm:"column:content_struct" description:"内容组件"` LastModifyAdminId int `gorm:"column:last_modify_admin_id" description:"最后更新人ID"` LastModifyAdminName string `gorm:"column:last_modify_admin_name" description:"最后更新人姓名"` ContentModifyTime *global.LocalTime `gorm:"column:content_modify_time" description:"内容更新时间"` HeadImg string `gorm:"column:head_img" description:"报告头图地址"` EndImg string `gorm:"column:end_img" description:"报告尾图地址"` CanvasColor string `gorm:"column:canvas_color" description:"画布颜色"` NeedSplice int `gorm:"column:need_splice" description:"是否拼接版头版位的标记，主要是为了兼容历史报告。0-不需要 1-需要"` HeadResourceId int `gorm:"column:head_resource_id" description:"版头资源ID"` EndResourceId int `gorm:"column:end_resource_id" description:"版尾资源ID"` ClassifyIdThird int `gorm:"column:classify_id_third" description:"三级分类id"` ClassifyNameThird string `gorm:"column:classify_name_third" description:"三级分类名称"` InheritReportId int `gorm:"column:inherit_report_id" description:"待继承的报告ID"` } type ReportListResp struct { List []*ReportList Paging *paging.PagingItem `description:"分页数据"` } func GetReportListCountV1(condition string, pars []interface{}) (count int, err error) { sql := `SELECT COUNT(1) AS count FROM report as a WHERE 1=1 ` if condition != "" { sql += condition } err = global.DmSQL["rddp"].Raw(sql, pars...).Scan(&count).Error return } func GetReportListV1(condition string, pars []interface{}, startSize, pageSize int) (items []*ReportList, err error) { sql := `SELECT * FROM report as a WHERE 1=1 ` if condition != "" { sql += condition } sql += `ORDER BY FIELD(state,3,1,4,5,6,2), modify_time DESC LIMIT ?,?` pars = append(pars, startSize) pars = append(pars, pageSize) err = global.DmSQL["rddp"].Raw(sql, pars...).Find(&items).Error return } type ReportPvUv struct { ReportId int PvTotal int UvTotal int } func GetReportPvUvByReportIdList(reportIdList []int) (items []ReportPvUv, err error) { num := len(reportIdList) if num <= 0 { return } sql := `SELECT report_id, COUNT(1) as pv_total,COUNT(DISTINCT user_id) as uv_total FROM report_view_record WHERE report_id in (` + utils.GetOrmInReplace(num) + `) GROUP BY report_id` err = global.DmSQL["rddp"].Raw(sql, reportIdList).Find(&items).Error return } func GetReportListCountByGrant(condition string, pars []interface{}) (count int, err error) { sql := `SELECT a.id FROM report as a JOIN report_grant b on a.id=b.report_id WHERE 1=1 ` if condition != "" { sql += condition } sql += " GROUP BY a.id " sql = `SELECT COUNT(1) AS count FROM (` + sql + `) d` err = global.DmSQL["rddp"].Raw(sql, pars...).Scan(&count).Error return } func GetReportListByGrant(condition string, pars []interface{}, startSize, pageSize int) (items []*ReportList, err error) { sql := `SELECT a.id,a.add_type,a.classify_id_first,a.classify_name_first,a.classify_id_second,a.classify_name_second,a.title,a.abstract,a.author,a.frequency,a.create_time,a.modify_time,a.state,a.publish_time,a.pre_publish_time,a.stage,a.msg_is_send,a.pre_msg_send,a.video_url,a.video_name,a.video_play_seconds,a.report_code,a.video_size,a.report_version,a.ths_msg_is_send,a.has_chapter,a.chapter_type,a.old_report_id,a.msg_send_time,a.admin_id,a.admin_real_name,a.approve_time,a.approve_id,a.detail_img_url,a.detail_pdf_url,a.last_modify_admin_id,a.last_modify_admin_name,a.content_modify_time,a.pv,a.uv,a.canvas_color,a.need_splice,a.head_resource_id,a.end_resource_id,a.classify_id_third,a.classify_name_third,a.collaborate_type,a.report_layout,a.is_public_publish,a.report_create_time,a.inherit_report_id,a.voice_generate_type FROM report as a JOIN report_grant b on a.id = b.report_id WHERE 1=1 ` if condition != "" { sql += condition } sql += ` GROUP BY a.id,a.add_type,a.classify_id_first,a.classify_name_first,a.classify_id_second,a.classify_name_second,a.title,a.abstract,a.author,a.frequency,a.create_time,a.modify_time,a.state,a.publish_time,a.pre_publish_time,a.stage,a.msg_is_send,a.pre_msg_send,a.video_url,a.video_name,a.video_play_seconds,a.report_code,a.video_size,a.report_version,a.ths_msg_is_send,a.has_chapter,a.chapter_type,a.old_report_id,a.msg_send_time,a.admin_id,a.admin_real_name,a.approve_time,a.approve_id,a.detail_img_url,a.detail_pdf_url,a.last_modify_admin_id,a.last_modify_admin_name,a.content_modify_time,a.pv,a.uv,a.canvas_color,a.need_splice,a.head_resource_id,a.end_resource_id,a.classify_id_third,a.classify_name_third,a.collaborate_type,a.report_layout,a.is_public_publish,a.report_create_time,a.inherit_report_id,a.voice_generate_type ORDER BY CASE a."state" WHEN 3 THEN 1 WHEN 1 THEN 2 WHEN 4 THEN 3 WHEN 5 THEN 4 WHEN 6 THEN 5 ELSE 6 END, a.modify_time DESC LIMIT ?,?` pars = append(pars, startSize) pars = append(pars, pageSize) err = global.DmSQL["rddp"].Raw(sql, pars...).Find(&items).Error return } func GetReportListCount(condition string, pars []interface{}) (count int, err error) { sql := `SELECT COUNT(1) AS count FROM report WHERE 1=1 ` if condition != "" { sql += condition } err = global.DmSQL["rddp"].Raw(sql, pars...).Scan(&count).Error return } func PublishCancelReport(reportId, state int, publishTimeNullFlag bool, lastModifyAdminId int, lastModifyAdminName string) (err error) { var sql string if publishTimeNullFlag { sql = ` UPDATE report SET state=?, publish_time=null, pre_publish_time=null, pre_msg_send=0,last_modify_admin_id=?,last_modify_admin_name=?,modify_time = NOW() WHERE id =?` } else { sql = ` UPDATE report SET state=?, pre_publish_time=null, pre_msg_send=0,last_modify_admin_id=?,last_modify_admin_name=?,modify_time = NOW() WHERE id =?` } err = global.DmSQL["rddp"].Exec(sql, state, lastModifyAdminId, lastModifyAdminName, reportId).Error return } func DeleteReport(reportIds int) (err error) { sql := ` DELETE FROM report WHERE id =? ` err = global.DmSQL["rddp"].Exec(sql, reportIds).Error return } type ReportDetail struct { Id int `gorm:"column:id;primary_key;autoIncrement" description:"报告Id"` AddType int `gorm:"column:add_type" description:"新增方式：1:新增报告，2:继承报告"` ClassifyIdFirst int `gorm:"column:classify_id_first" description:"一级分类id"` ClassifyNameFirst string `gorm:"column:classify_name_first" description:"一级分类名称"` ClassifyIdSecond int `gorm:"column:classify_id_second" description:"二级分类id"` ClassifyNameSecond string `gorm:"column:classify_name_second" description:"二级分类名称"` Title string `gorm:"column:title" description:"标题"` Abstract string `gorm:"column:abstract" description:"摘要"` Author string `gorm:"column:author" description:"作者"` Frequency string `gorm:"column:frequency" description:"频度"` CreateTime string `gorm:"column:create_time" description:"创建时间"` ModifyTime string `gorm:"column:modify_time" description:"修改时间"` State int `gorm:"column:state" description:"1:未发布，2:已发布"` PublishTime string `gorm:"column:publish_time" description:"发布时间"` PrePublishTime string `gorm:"column:pre_publish_time" description:"预发布时间"` Stage int `gorm:"column:stage" description:"期数"` MsgIsSend int `gorm:"column:msg_is_send" description:"消息是否已发送，0:否，1:是"` PreMsgSend int `gorm:"column:pre_msg_send" description:"定时发布成功后是否立即推送模版消息：0否，1是"` Content string `gorm:"column:content" description:"内容"` VideoUrl string `gorm:"column:video_url" description:"音频文件URL"` VideoName string `gorm:"column:video_name" description:"音频文件名称"` VideoPlaySeconds string `gorm:"column:video_play_seconds" description:"音频播放时长"` ContentSub string `gorm:"column:content_sub" description:"内容前两个章节"` ThsMsgIsSend int `gorm:"column:ths_msg_is_send" description:"客户群消息是否已发送，0:否，1:是"` HasChapter int `gorm:"column:has_chapter" description:"是否有章节 0-否 1-是"` ChapterType string `gorm:"column:chapter_type" description:"章节类型 day-晨报 week-周报"` AdminId int `gorm:"column:admin_id" description:"创建者账号"` AdminRealName string `gorm:"column:admin_real_name" description:"创建者姓名"` ReportCode string `gorm:"column:report_code" description:"报告唯一编码"` ContentStruct string `gorm:"column:content_struct" description:"内容组件"` LastModifyAdminId int `gorm:"column:last_modify_admin_id" description:"最后更新人ID"` LastModifyAdminName string `gorm:"column:last_modify_admin_name" description:"最后更新人姓名"` ContentModifyTime string `gorm:"column:content_modify_time" description:"内容更新时间"` Pv int `gorm:"column:pv" description:"pv"` Uv int `gorm:"column:uv" description:"uv"` HeadImg string `gorm:"column:head_img" description:"报告头图地址"` EndImg string `gorm:"column:end_img" description:"报告尾图地址"` HeadStyle string `gorm:"column:head_style" description:"版头样式"` EndStyle string `gorm:"column:end_style" description:"版尾样式"` CanvasColor string `gorm:"column:canvas_color" description:"画布颜色"` NeedSplice int `gorm:"column:need_splice" description:"是否拼接版头版位的标记，主要是为了兼容历史报告。0-不需要 1-需要"` HeadResourceId int `gorm:"column:head_resource_id" description:"版头资源ID"` EndResourceId int `gorm:"column:end_resource_id" description:"版尾资源ID"` ClassifyIdThird int `gorm:"column:classify_id_third" description:"三级分类id"` ClassifyNameThird string `gorm:"column:classify_name_third" description:"三级分类名称"` CollaborateType int8 `gorm:"column:collaborate_type" description:"协作方式，1：个人，2：多人协作。默认：1"` ReportLayout int8 `gorm:"column:report_layout" description:"报告布局，1：常规布局，2：智能布局。默认：1"` IsPublicPublish int8 `gorm:"column:is_public_publish" description:"是否公开发布，1：是，2：否"` ReportCreateTime string `gorm:"column:report_create_time" description:"报告时间创建时间"` } func GetReportById(reportId int) (item *ReportDetail, err error) { reportInfo, err := GetReportByReportId(reportId) if err != nil { return } item, err = convertReportToReportDetail(*reportInfo) return } func convertReportToReportDetail(report Report) (*ReportDetail, error) { jsonBytes, err := json.Marshal(report) if err != nil { return nil, fmt.Errorf("failed to marshal input: %w", err) } reportDetail := new(ReportDetail) err = json.Unmarshal(jsonBytes, reportDetail) if err != nil { return nil, fmt.Errorf("failed to unmarshal input: %w", err) } reportDetail.CreateTime = report.CreateTime.Format(utils.FormatDateTime) reportDetail.ModifyTime = report.ModifyTime.Format(utils.FormatDateTime) if !report.PublishTime.IsZero() { reportDetail.PublishTime = report.PublishTime.Format(utils.FormatDateTime) } else { reportDetail.PublishTime = `` } if !report.ContentModifyTime.IsZero() { reportDetail.ContentModifyTime = report.ContentModifyTime.Format(utils.FormatDateTime) } else { reportDetail.ContentModifyTime = `` } if !report.ReportCreateTime.IsZero() { reportDetail.ReportCreateTime = report.ReportCreateTime.Format(utils.FormatDateTime) } else { reportDetail.ReportCreateTime = `` } return reportDetail, nil } func GetSimpleReportByIds(reportIds []int) (list []*Report, err error) { if len(reportIds) == 0 { return } sql := `SELECT id, title, report_code FROM report WHERE id IN (` + utils.GetOrmInReplace(len(reportIds)) + `)` err = global.DmSQL["rddp"].Raw(sql, reportIds).Find(&list).Error return } func GetReportStage(classifyIdFirst, classifyIdSecond, classifyIdThird int) (count int, err error) { classifyId := classifyIdThird if classifyId <= 0 { classifyId = classifyIdSecond } if classifyId <= 0 { classifyId = classifyIdFirst } if classifyId <= 0 { err = errors.New("错误的分类id") return } yearStart := time.Date(time.Now().Local().Year(), 1, 1, 0, 0, 0, 0, time.Local) sql := `SELECT COALESCE(MAX(stage),0) AS count FROM report WHERE create_time > ? ` if classifyIdThird > 0 { sql += " AND classify_id_third = ? " } else if classifyIdSecond > 0 { sql += " AND classify_id_second = ? " } else { sql += " AND classify_id_first = ? " } err = global.DmSQL["rddp"].Raw(sql, yearStart, classifyId).Scan(&count).Error return } type PublishReq struct { ReportIds string `description:"报告id,多个用英文逗号隔开"` ReportUrl string `description:"报告Url"` } type PublishCancelReq struct { ReportIds int `description:"报告id"` } type DeleteReq struct { ReportIds int `description:"报告id"` } type AddReq struct { AddType int `description:"新增方式：1:新增报告，2:继承报告"` ClassifyIdFirst int `description:"一级分类id"` ClassifyNameFirst string `description:"一级分类名称"` ClassifyIdSecond int `description:"二级分类id"` ClassifyNameSecond string `description:"二级分类名称"` ClassifyIdThird int `description:"三级分类id"` ClassifyNameThird string `description:"三级分类名称"` Title string `description:"标题"` Abstract string `description:"摘要"` Author string `description:"作者"` Frequency string `description:"频度"` State int `description:"状态：1:未发布，2:已发布"` Content string `description:"内容"` CreateTime string `description:"创建时间"` ReportVersion int `description:"1:旧版,2:新版"` ContentStruct string `description:"内容组件"` HeadImg string `description:"报告头图地址"` EndImg string `description:"报告尾图地址"` CanvasColor string `description:"画布颜色"` NeedSplice int `description:"是否拼接版头版位的标记，主要是为了兼容历史报告。0-不需要 1-需要"` HeadResourceId int `description:"版头资源ID"` EndResourceId int `description:"版尾资源ID"` CollaborateType int8 `description:"协作方式，1：个人，2：多人协作。默认：1"` ReportLayout int8 `description:"报告布局，1：常规布局，2：智能布局。默认：1"` IsPublicPublish int8 `description:"是否公开发布，1：是，2：否"` InheritReportId int `description:"待继承的报告ID"` GrantAdminIdList []int `description:"授权用户id列表"` } type PrePublishReq struct { ReportId int `description:"报告id"` PrePublishTime string `description:"预发布时间"` PreMsgSend int `description:"定时发布成功后是否立即推送模版消息：0否，1是"` ReportUrl string `description:"报告Url"` } type AddResp struct { ReportId int64 `description:"报告id"` ReportCode string `description:"报告code"` } type EditReq struct { ReportId int64 `description:"报告id"` ClassifyIdFirst int `description:"一级分类id"` ClassifyNameFirst string `description:"一级分类名称"` ClassifyIdSecond int `description:"二级分类id"` ClassifyNameSecond string `description:"二级分类名称"` ClassifyIdThird int `description:"三级分类id"` ClassifyNameThird string `description:"三级分类名称"` Title string `description:"标题"` Abstract string `description:"摘要"` Author string `description:"作者"` Frequency string `description:"频度"` State int `description:"状态：1:未发布，2:已发布"` Content string `description:"内容"` CreateTime string `description:"创建时间"` ContentStruct string `description:"内容组件"` HeadImg string `description:"报告头图地址"` EndImg string `description:"报告尾图地址"` CanvasColor string `description:"画布颜色"` NeedSplice int `description:"是否拼接版头版位的标记，主要是为了兼容历史报告。0-不需要 1-需要"` HeadResourceId int `description:"版头资源ID"` EndResourceId int `description:"版尾资源ID"` IsPublicPublish int8 `description:"是否公开发布，1：是，2：否"` GrantAdminIdList []int `description:"授权用户id列表"` } type EditResp struct { ReportId int64 `description:"报告id"` ReportCode string `description:"报告code"` } func EditReport(item *Report, reportId int64) (err error) { sql := `UPDATE report SET classify_id_first =?, classify_name_first = ?, classify_id_second = ?, classify_name_second = ?, title = ?, abstract = ?, author = ?, frequency = ?, state = ?, content = ?, content_sub = ?, stage =?, create_time = ?, modify_time = ? WHERE id = ? ` err = global.DmSQL["rddp"].Exec(sql, item.ClassifyIdFirst, item.ClassifyNameFirst, item.ClassifyIdSecond, item.ClassifyNameSecond, item.Title, item.Abstract, item.Author, item.Frequency, item.State, item.Content, item.ContentSub, item.Stage, item.CreateTime, time.Now(), reportId).Error return } func (m *Report) Update(cols []string) (err error) { err = global.DmSQL["rddp"].Select(cols).Updates(m).Error return } type ReportDetailReq struct { ReportId int `description:"报告id"` } type ClassifyIdDetailReq struct { ClassifyIdFirst int `description:"报告一级分类id"` ClassifyIdSecond int `description:"报告二级分类id"` } func GetReportDetailByClassifyId(classifyIdFirst, classifyIdSecond int) (item *Report, err error) { sql := ` SELECT * FROM report WHERE 1=1 ` if classifyIdSecond > 0 { sql = sql + ` AND classify_id_second=? ORDER BY stage DESC LIMIT 1` err = global.DmSQL["rddp"].Raw(sql, classifyIdSecond).First(&item).Error } else { sql = sql + ` AND classify_id_first=? ORDER BY stage DESC LIMIT 1` err = global.DmSQL["rddp"].Raw(sql, classifyIdFirst).First(&item).Error } return } type SendTemplateMsgReq struct { ReportId int `description:"报告id"` } type SendTemplateMsgResp struct { ReportId int `description:"报告id"` MsgSendTime string `description:"报告推送时间"` } func ModifyReportMsgIsSend(reportId int) (err error) { report, err := GetReportById(reportId) if err != nil { return } if report.MsgIsSend == 0 { sql := `UPDATE report SET msg_is_send = 1, msg_send_time=NOW() WHERE id = ? ` err = global.DmSQL["rddp"].Exec(sql, reportId).Error } return } func ModifyReportVideo(reportId int, videoUrl, videoName, videoSize string, playSeconds float64) (err error) { sql := `UPDATE report SET video_url=?,video_name=?,video_play_seconds=?,video_size=? WHERE id=? ` err = global.DmSQL["rddp"].Exec(sql, videoUrl, videoName, playSeconds, videoSize, reportId).Error return } func ModifyReportVideoByNoVideo(reportId int, videoUrl, videoName, videoSize string, playSeconds float64) (err error) { sql := `UPDATE report SET video_url=?,video_name=?,video_play_seconds=?,video_size=? WHERE id=? AND video_url=''` err = global.DmSQL["rddp"].Exec(sql, videoUrl, videoName, playSeconds, videoSize, reportId).Error return } type ReportItem struct { gorm.Model Id int `gorm:"column:id;primary_key;autoIncrement" description:"报告Id"` AddType int `gorm:"column:add_type" description:"新增方式：1:新增报告，2:继承报告"` ClassifyIdFirst int `gorm:"column:classify_id_first" description:"一级分类id"` ClassifyNameFirst string `gorm:"column:classify_name_first" description:"一级分类名称"` ClassifyIdSecond int `gorm:"column:classify_id_second" description:"二级分类id"` ClassifyNameSecond string `gorm:"column:classify_name_second" description:"二级分类名称"` Title string `gorm:"column:title" description:"标题"` Abstract string `gorm:"column:abstract" description:"摘要"` Author string `gorm:"column:author" description:"作者"` Frequency string `gorm:"column:frequency" description:"频度"` CreateTime time.Time `gorm:"column:create_time" description:"创建时间"` ModifyTime time.Time `gorm:"column:modify_time" description:"修改时间"` State int `gorm:"column:state" description:"1:未发布，2:已发布"` PublishTime time.Time `gorm:"column:publish_time" description:"发布时间"` Stage int `gorm:"column:stage" description:"期数"` MsgIsSend int `gorm:"column:msg_is_send" description:"消息是否已发送，0:否，1:是"` Content string `gorm:"column:content" description:"内容"` VideoUrl string `gorm:"column:video_url" description:"音频文件URL"` VideoName string `gorm:"column:video_name" description:"音频文件名称"` VideoPlaySeconds string `gorm:"column:video_play_seconds" description:"音频播放时长"` ContentSub string `gorm:"column:content_sub" description:"内容前两个章节"` } type SaveReportContent struct { Content string `description:"内容"` ReportId int `description:"报告id"` NoChange int `description:"内容是否未改变：1：内容未改变"` ContentStruct string `description:"内容组件"` HeadImg string `description:"报告头图地址"` EndImg string `description:"报告尾图地址"` CanvasColor string `description:"画布颜色"` NeedSplice int `description:"是否拼接版头版位的标记，主要是为了兼容历史报告。0-不需要 1-需要"` HeadResourceId int `description:"版头资源ID"` EndResourceId int `description:"版尾资源ID"` } func AddReportSaveLog(reportId, adminId int, content, contentSub, contentStruct, canvasColor, adminName string, headResourceId, endResourceId int) (err error) { sql := ` INSERT INTO report_save_log(report_id, content,content_sub,content_struct,canvas_color,head_resource_id,end_resource_id,admin_id,admin_name) VALUES (?,?,?,?,?,?,?,?,?) ` err = global.DmSQL["rddp"].Exec(sql, reportId, content, contentSub, contentStruct, canvasColor, headResourceId, endResourceId, adminId, adminName).Error return } func MultiAddReportChaptersSaveLog(items []*ReportChapter, adminId int, adminRealName string) (err error) { tx := global.DmSQL["rddp"].Begin() for _, v := range items { err = tx.Exec(`INSERT INTO report_save_log(report_id, report_chapter_id, content, content_sub,content_struct,admin_id, admin_name) VALUES (?,?,?,?,?,?,?)`, v.ReportId, v.ReportChapterId, v.Content, v.ContentSub, v.ContentStruct, adminId, adminRealName).Error if err != nil { tx.Rollback() return } } tx.Commit() return } type SaveReportContentResp struct { ReportId int `description:"报告id"` } func ModifyReportCode(reportId int64, reportCode string) (err error) { sql := `UPDATE report SET report_code=? WHERE id=? ` err = global.DmSQL["rddp"].Exec(sql, reportCode, reportId).Error return } func ModifyReportThsMsgIsSend(item *ReportDetail) (err error) { if item.ThsMsgIsSend == 0 { sql := `UPDATE report SET ths_msg_is_send = 1 WHERE id = ? ` err = global.DmSQL["rddp"].Exec(sql, item.Id).Error } return } type ThsSendTemplateMsgReq struct { ReportId []int `description:"报告id"` } type PublishDayWeekReportReq struct { ReportId int `description:"报告ID"` } type SaveDayWeekReportReq struct { ReportId int `description:"报告ID"` Title string `description:"标题"` ReportType string `description:"一级分类ID"` Author string `description:"作者"` CreateTime string `description:"创建时间"` } func GetReportByReportId(reportId int) (item *Report, err error) { sql := `SELECT * FROM report WHERE id = ?` err = global.DmSQL["rddp"].Raw(sql, reportId).First(&item).Error return } func DeleteDayWeekReportAndChapter(reportId int) (err error) { to := global.DmSQL["rddp"].Begin() defer func() { if err != nil { _ = to.Rollback() } else { _ = to.Commit() } }() sql := ` DELETE FROM report WHERE id = ? LIMIT 1 ` if err = to.Exec(sql, reportId).Error; err != nil { return } sql = ` DELETE FROM report_chapter WHERE report_id = ? ` if err = to.Exec(sql, reportId).Error; err != nil { return } return } func (reportInfo *Report) UpdateReport(cols []string) (err error) { err = global.DmSQL["rddp"].Select(cols).Updates(reportInfo).Error return } type ReportDetailView struct { *ReportDetail ChapterList []*ReportChapter GrandAdminList []ReportDetailViewAdmin PermissionList []ReportDetailViewPermission } type ReportDetailViewAdmin struct { AdminId int AdminName string } type ReportDetailViewPermission struct { PermissionId int PermissionName string } type ElasticReportDetail struct { gorm.Model ReportId int `gorm:"column:report_id;index" description:"报告ID"` ReportChapterId int `gorm:"column:report_chapter_id" description:"报告章节ID"` Title string `gorm:"column:title" description:"标题"` Abstract string `gorm:"column:abstract" description:"摘要"` BodyContent string `gorm:"column:body_content" description:"内容"` PublishTime string `gorm:"column:publish_time" description:"发布时间"` PublishState int `gorm:"column:publish_state" description:"发布状态 1-未发布 2-已发布"` Author string `gorm:"column:author" description:"作者"` ClassifyIdFirst int `gorm:"column:classify_id_first" description:"一级分类ID"` ClassifyNameFirst string `gorm:"column:classify_name_first" description:"一级分类名称"` ClassifyIdSecond int `gorm:"column:classify_id_second" description:"二级分类ID"` ClassifyNameSecond string `gorm:"column:classify_name_second" description:"二级分类名称"` ClassifyId int `gorm:"column:classify_id" description:"最小单元的分类ID"` ClassifyName string `gorm:"column:classify_name" description:"最小单元的分类名称"` Categories string `gorm:"column:categories" description:"关联的品种名称(包括品种别名)"` StageStr string `gorm:"column:stage_str" description:"报告期数"` } func PublishReportAndChapter(reportInfo *Report, isPublishReport bool, cols []string) (err error) { to := global.DmSQL["rddp"].Begin() defer func() { if err != nil { _ = to.Rollback() } else { _ = to.Commit() } }() if isPublishReport { err = to.Select(cols).Updates(reportInfo).Error if err != nil { return } } sql := ` UPDATE report_chapter SET publish_state = 2, publish_time = ? WHERE report_id = ? ` err = to.Exec(sql, reportInfo.PublishTime, reportInfo.Id).Error return } func PublishReportById(reportId int, publishTime time.Time, lastModifyAdminId int, lastModifyAdminName string) (err error) { sql := `UPDATE report SET state = 2, publish_time = ?, pre_publish_time=null, pre_msg_send=0, modify_time = NOW(),last_modify_admin_id=?,last_modify_admin_name=? WHERE id = ? ` err = global.DmSQL["rddp"].Exec(sql, publishTime, lastModifyAdminId, lastModifyAdminName, reportId).Error return } func ResetReportById(reportId, state int, lastModifyAdminId int, lastModifyAdminName string) (err error) { sql := `UPDATE report SET state = ?, pre_publish_time = null, pre_msg_send = 0, modify_time = NOW(),last_modify_admin_id=?,last_modify_admin_name=? WHERE id = ?` err = global.DmSQL["rddp"].Exec(sql, state, lastModifyAdminId, lastModifyAdminName, reportId).Error return } type LikeReportItem struct { gorm.Model ReportId int `gorm:"column:report_id;index" description:"报告Id"` ReportChapterId int `gorm:"column:report_chapter_id" description:"报告章节Id"` ClassifyIdFirst int `gorm:"column:classify_id_first" description:"一级分类id"` ClassifyNameFirst string `gorm:"column:classify_name_first" description:"一级分类名称"` ClassifyIdSecond int `gorm:"column:classify_id_second" description:"二级分类id"` ClassifyNameSecond string `gorm:"column:classify_name_second" description:"二级分类名称"` ReportChapterTypeId int `gorm:"column:report_chapter_type_id" description:"章节类型"` ReportChapterTypeName string `gorm:"column:report_chapter_type_name" description:"品种名称"` PublishTime time.Time `gorm:"column:publish_time" description:"发布时间"` Title string `gorm:"column:title" description:"标题"` } type SunCodeReq struct { CodePage string `json:"CodePage" description:"太阳码page"` CodeScene string `json:"CodeScene" description:"太阳码scene"` } type YbPcSuncode struct { SuncodeID uint32 `gorm:"column:suncode_id;primaryKey" json:"suncodeId"` //`orm:"column(suncode_id);pk" gorm:"primaryKey" ` Scene string `gorm:"column:scene;type:varchar(255);not null;default:0" json:"scene"` // 微信scene SceneMd5 string `gorm:"column:scene_md5;type:varchar(255);not null" json:"sceneMd5"` CodePage string `gorm:"column:code_page;type:varchar(255);not null;default:''" json:"codePage"` // 路径 SuncodeUrl string `gorm:"column:suncode_url;type:varchar(255);not null;default:''" json:"suncodeUrl"` // 太阳码储存地址 CreateTime time.Time `gorm:"column:create_time;type:timestamp;default:CURRENT_TIMESTAMP" json:"createTime"` } func GetYbPcSunCode(scene, page string) (item *YbPcSuncode, err error) { sql := `SELECT * FROM yb_pc_suncode WHERE scene = ? AND code_page = ? ` err = global.DmSQL["weekly"].Raw(sql, scene, page).First(&item).Error return } func AddYbPcSunCode(item *YbPcSuncode) (err error) { err = global.DmSQL["weekly"].Create(item).Error return } type YbSuncodePars struct { ID uint32 `gorm:"column:id;primaryKey" json:"id"` //`orm:"column(id);pk" gorm:"primaryKey" ` Scene string `gorm:"column:scene;type:varchar(255);not null;default:''" json:"scene"` // scene参数 SceneKey string `gorm:"column:scene_key;type:varchar(32);not null;default:''" json:"scene_key"` // MD5值 CreateTime time.Time `gorm:"column:create_time;type:datetime;default:CURRENT_TIMESTAMP" json:"createTime"` } func AddYbSuncodePars(item *YbSuncodePars) (err error) { err = global.DmSQL["weekly"].Create(item).Error return } func UpdateReportSecondClassifyNameByClassifyId(classifyId int, classifyName string) (err error) { sql := " UPDATE report SET classify_name_second = ? WHERE classify_id_second = ? " err = global.DmSQL["rddp"].Exec(sql, classifyName, classifyId).Error return } func UpdateReportFirstClassifyNameByClassifyId(classifyId int, classifyName string) (err error) { sql := " UPDATE report SET classify_name_first = ? WHERE classify_id_first = ? " err = global.DmSQL["rddp"].Exec(sql, classifyName, classifyId).Error return } func UpdateReportThirdClassifyNameByClassifyId(classifyId int, classifyName string) (err error) { sql := " UPDATE report SET classify_name_third = ? WHERE classify_id_third = ? " err = global.DmSQL["rddp"].Exec(sql, classifyName, classifyId).Error return } func ModifyReportAuthor(condition string, pars []interface{}, authorName string) (count int, err error) { sql := `UPDATE english_report set author = ? WHERE 1=1 ` if condition != "" { sql += condition } result := global.DmSQL["rddp"].Raw(sql, utils.ForwardPars(pars, authorName)...) count = int(result.RowsAffected) err = result.Error return } func UpdateReportPublishTime(reportId int, videoNameDate string) (err error) { sql1 := ` UPDATE report SET publish_time = NOW() WHERE id = ? ` err = global.DmSQL["rddp"].Exec(sql1, reportId).Error if err != nil { return } sql2 := ` UPDATE report SET video_name=CONCAT(SUBSTRING_INDEX(video_name,"(",1),"` + videoNameDate + `") WHERE id = ? and (video_name !='' and video_name is not null)` err = global.DmSQL["rddp"].Exec(sql2, reportId).Error return } func UpdateReportChapterPublishTime(reportId int, videoNameDate string) (err error) { sql1 := ` UPDATE report_chapter SET publish_time = NOW() WHERE report_id = ? ` err = global.DmSQL["rddp"].Exec(sql1, reportId).Error if err != nil { return } sql2 := ` UPDATE report_chapter SET video_name=CONCAT(SUBSTRING_INDEX(video_name,"(",1),"` + videoNameDate + `") WHERE report_id = ? and (video_name !='' and video_name is not null)` err = global.DmSQL["rddp"].Exec(sql2, reportId).Error return } type MarkEditReport struct { ReportId int `description:"研报id"` ReportChapterId int `description:"研报章节id"` Status int `description:"标记状态，1：编辑中，2：查询状态，3：编辑完成"` } type MarkReportResp struct { Status int `description:"状态：0:无人编辑, 1：当前有人在编辑"` Msg string `description:"提示信息"` Editor string `description:"编辑者姓名"` } type MarkReportItem struct { AdminId int `description:"编辑者ID"` Editor string `description:"编辑者姓名"` ReportClassifyNameFirst string } func GetReportByCondition(condition string, pars []interface{}, fieldArr []string, orderRule string, isPage bool, startSize, pageSize int) (items []*Report, err error) { fields := `*` if len(fieldArr) > 0 { fields = strings.Join(fieldArr, ",") } sql := `SELECT ` + fields + ` FROM report WHERE 1=1 ` sql += condition order := ` ORDER BY modify_time DESC` if orderRule != `` { order = orderRule } sql += order if isPage { sql += ` LIMIT ?,?` err = global.DmSQL["rddp"].Raw(sql, pars...).Find(&items).Error } else { err = global.DmSQL["rddp"].Raw(sql, pars...).Find(&items).Error } return } func SetPrePublishReportById(reportId int, prePublishTime string, preMsgSend int) (err error) { sql := `UPDATE report SET pre_publish_time=?, pre_msg_send=? WHERE id = ? and state = 1 ` err = global.DmSQL["rddp"].Exec(sql, prePublishTime, preMsgSend, reportId).Error return } type ReportSubmitApproveReq struct { ReportId int `description:"报告ID"` } type ReportCancelApproveReq struct { ReportId int `description:"报告ID"` } func (m *Report) GetItemById(id int) (item *Report, err error) { sql := `SELECT * FROM report WHERE id = ? LIMIT 1` err = global.DmSQL["rddp"].Raw(sql, id).First(&item).Error return } func GetReportStateCount(state int) (count int, err error) { sql := `SELECT COUNT(1) AS count FROM report WHERE state = ?` err = global.DmSQL["rddp"].Raw(sql, state).Scan(&count).Error return } func UpdateReportsStateByCond(classifyFirstId, classifySecondId, classifyThirdId, oldState, newState int) (err error) { cond := `` if classifyFirstId > 0 { cond += fmt.Sprintf(` AND classify_id_first = %d`, classifyFirstId) } if classifySecondId > 0 { cond += fmt.Sprintf(` AND classify_id_second = %d`, classifySecondId) } if classifyThirdId > 0 { cond += fmt.Sprintf(` AND classify_id_third = %d`, classifyThirdId) } sql := fmt.Sprintf(`UPDATE report SET state = ?, pre_publish_time = NULL WHERE state = ? %s`, cond) err = global.DmSQL["rddp"].Exec(sql, newState, oldState).Error return } func UpdateReportsStateBySecondIds(oldState, newState int, secondIds []int) (err error) { if len(secondIds) <= 0 { return } sql := fmt.Sprintf(`UPDATE report SET state = ?, pre_publish_time = NULL WHERE state = ? AND classify_id_second IN (%s)`, utils.GetOrmInReplace(len(secondIds))) err = global.DmSQL["rddp"].Exec(sql, newState, oldState, secondIds).Error if err != nil { return } sql = fmt.Sprintf(`UPDATE report SET state = ?, pre_publish_time = NULL WHERE state = ? AND classify_id_second NOT IN (%s)`, utils.GetOrmInReplace(len(secondIds))) err = global.DmSQL["rddp"].Exec(sql, oldState, newState, secondIds).Error return } type GetReportPdfUrlReq struct { ReportUrl string `description:"报告Url"` ReportCode string `description:"报告Code"` Type int `description:"类型 1-pdf 2-图片"` } func ModifyReportPdfUrl(reportId int, detailPdfUrl string) (err error) { sql := `UPDATE report SET detail_pdf_url=? WHERE id=? ` err = global.DmSQL["rddp"].Exec(sql, detailPdfUrl, reportId).Error return } func ModifyReportImgUrl(reportId int, detailImgUrl string) (err error) { sql := `UPDATE report SET detail_img_url=? WHERE id=? ` err = global.DmSQL["rddp"].Exec(sql, detailImgUrl, reportId).Error return } func UpdatePdfUrlReportById(reportId int) (err error) { sql := `UPDATE report SET detail_img_url = '',detail_pdf_url='',modify_time=NOW() WHERE id = ? ` err = global.DmSQL["rddp"].Exec(sql, reportId).Error return } func InsertMultiReport(items []*Report) (err error) { err = global.DmSQL["rddp"].CreateInBatches(items, utils.MultiAddNum).Error return } type ReportLayout struct { Id int `gorm:"column:id;primaryKey"` ReportLayout int8 `gorm:"column:report_layout"` //`description:"报告布局，1：常规布局，2：智能布局。默认：1"` } func GetReportLayoutByReportId(reportId int) (item ReportLayout, err error) { sql := `SELECT id, report_layout FROM report WHERE id = ? ` err = global.DmSQL["rddp"].Raw(sql, reportId).First(&item).Error return } func GetReportFieldsByIds(ids []int, fields []string) (items []*Report, err error) { if len(ids) == 0 { return } field := " * " if len(fields) > 0 { field = fmt.Sprintf(" %s ", strings.Join(fields, ",")) } sql := fmt.Sprintf(`SELECT %s FROM report WHERE id IN (%s)`, field, utils.GetOrmInReplace(len(ids))) err = global.DmSQL["rddp"].Raw(sql, ids).Find(&items).Error return }