123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284 |
- package models
- import (
- "encoding/json"
- "errors"
- "eta_gn/eta_api/global"
- "eta_gn/eta_api/utils"
- "fmt"
- "strings"
- "time"
- "github.com/rdlucklib/rdluck_tools/paging"
- "gorm.io/gorm"
- )
- // 报告状态
- 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:人工上传"`
- ReportSource int `gorm:"column:report_source" description:"报告来源:1-系统内;2-智力共享"`
- OutReportId string `gorm:"column:out_report_id" description:"外部报告ID(或编码)"`
- PrePublishTime *time.Time `gorm:"column:pre_publish_time" description:"预发布时间"`
- PreMsgSend int `gorm:"column:pre_msg_send" description:"定时发布成功后是否立即推送模版消息,0:未发送,1:已发送"`
- TopicEndTime time.Time `gorm:"column:topic_end_time" description:"课题结束时间"`
- }
- 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"`
- ReportSource int `gorm:"column:report_source" description:"报告来源:1-系统内;2-智力共享"`
- }
- type ReportListResp struct {
- List []*ReportList
- Paging *paging.PagingItem `description:"分页数据"`
- }
- // GetReportListCountV1
- // @Description: 获取普通报告列表的报告数量
- // @author: Roc
- // @datetime 2024-05-30 15:14:43
- // @param condition string
- // @param pars []interface{}
- // @return count int
- // @return err error
- 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 GetReportListCountV1(condition string, pars []interface{}) (count int, err error) {
- // sql := `SELECT COUNT(1) AS count FROM report as a
- // LEFT JOIN classify_visible c ON (
- // CASE
- // WHEN a.classify_id_third > 0 THEN a.classify_id_third
- // WHEN a.classify_id_second > 0 THEN a.classify_id_second
- // ELSE a.classify_id_first
- // END
- // ) = c.classify_id AND c.admin_id =?
- // WHERE 1=1 AND (c.admin_id IS NULL OR c.admin_id =?) AND a.id NOT IN (
- // SELECT id FROM report ta
- // JOIN classify_visible tb ON (
- // CASE
- // WHEN ta.classify_id_third > 0 THEN ta.classify_id_third
- // WHEN ta.classify_id_second > 0 THEN ta.classify_id_second
- // ELSE ta.classify_id_first
- // END
- // ) = tb.classify_id
- // GROUP BY ta."id"
- // HAVING SUM(CASE WHEN tb.admin_id = ? THEN 1 ELSE 0 END) = 0
- // ) `
- // if condition != "" {
- // sql += condition
- // }
- // err = global.DmSQL["rddp"].Raw(sql, pars...).Scan(&count).Error
- // return
- // }
- // GetReportListV1
- // @Description: 获取普通报告列表的数据
- // @author: Roc
- // @datetime 2024-05-30 15:14:25
- // @param condition string
- // @param pars []interface{}
- // @param startSize int
- // @param pageSize int
- // @return items []*ReportList
- // @return err error
- 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
- }
- // 排序:1:未发布;2:已发布;3-待提交;4-待审批;5-已驳回;6-已通过
- 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
- }
- // func GetReportListV1(condition string, pars []interface{}, startSize, pageSize int) (items []*ReportList, err error) {
- // sql := `SELECT * FROM report as a
- // LEFT JOIN classify_visible c ON (
- // CASE
- // WHEN a.classify_id_third > 0 THEN a.classify_id_third
- // WHEN a.classify_id_second > 0 THEN a.classify_id_second
- // ELSE a.classify_id_first
- // END
- // ) = c.classify_id AND c.admin_id =?
- // WHERE 1=1 AND (c.admin_id IS NULL OR c.admin_id =?) AND a.id NOT IN (
- // SELECT id FROM report ta
- // JOIN classify_visible tb ON (
- // CASE
- // WHEN ta.classify_id_third > 0 THEN ta.classify_id_third
- // WHEN ta.classify_id_second > 0 THEN ta.classify_id_second
- // ELSE ta.classify_id_first
- // END
- // ) = tb.classify_id
- // GROUP BY ta."id"
- // HAVING SUM(CASE WHEN tb.admin_id = ? THEN 1 ELSE 0 END) = 0
- // ) `
- // if condition != "" {
- // sql += condition
- // }
- // // 排序:1:未发布;2:已发布;3-待提交;4-待审批;5-已驳回;6-已通过
- // 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
- }
- // GetReportListCountByGrant
- // @Description: 获取共享报告列表的报告数量
- // @author: Roc
- // @datetime 2024-05-30 15:14:01
- // @param condition string
- // @param pars []interface{}
- // @return count int
- // @return err error
- 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 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
- // LEFT JOIN classify_visible c ON (
- // CASE
- // WHEN a.classify_id_third > 0 THEN a.classify_id_third
- // WHEN a.classify_id_second > 0 THEN a.classify_id_second
- // ELSE a.classify_id_first
- // END
- // ) = c.classify_id AND c.admin_id =?
- // WHERE 1=1 AND (c.admin_id IS NULL OR c.admin_id =?) AND a.id NOT IN (
- // SELECT id FROM report ta
- // JOIN classify_visible tb ON (
- // CASE
- // WHEN ta.classify_id_third > 0 THEN ta.classify_id_third
- // WHEN ta.classify_id_second > 0 THEN ta.classify_id_second
- // ELSE ta.classify_id_first
- // END
- // ) = tb.classify_id
- // GROUP BY ta."id"
- // HAVING SUM(CASE WHEN tb.admin_id = ? THEN 1 ELSE 0 END) = 0
- // ) `
- // 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
- // }
- // GetReportListByGrant
- // @Description: 获取共享报告列表的数据
- // @author: Roc
- // @datetime 2024-05-30 15:15:07
- // @param condition string
- // @param pars []interface{}
- // @param startSize int
- // @param pageSize int
- // @return items []*ReportList
- // @return err error
- 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,a.report_source FROM report as a JOIN report_grant b on a.id = b.report_id WHERE 1=1 `
- if condition != "" {
- sql += condition
- }
- // 排序:1:未发布;2:已发布;3-待提交;4-待审批;5-已驳回;6-已通过
- 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,a.report_source
- 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 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,a.report_source FROM report as a JOIN report_grant b on a.id = b.report_id
- // LEFT JOIN classify_visible c ON (
- // CASE
- // WHEN a.classify_id_third > 0 THEN a.classify_id_third
- // WHEN a.classify_id_second > 0 THEN a.classify_id_second
- // ELSE a.classify_id_first
- // END
- // ) = c.classify_id AND c.admin_id =?
- // WHERE 1=1 AND (c.admin_id IS NULL OR c.admin_id =?) AND a.id NOT IN (
- // SELECT id FROM report ta
- // JOIN classify_visible tb ON (
- // CASE
- // WHEN ta.classify_id_third > 0 THEN ta.classify_id_third
- // WHEN ta.classify_id_second > 0 THEN ta.classify_id_second
- // ELSE ta.classify_id_first
- // END
- // ) = tb.classify_id
- // GROUP BY ta."id"
- // HAVING SUM(CASE WHEN tb.admin_id = ? THEN 1 ELSE 0 END) = 0
- // ) `
- // if condition != "" {
- // sql += condition
- // }
- // // 排序:1:未发布;2:已发布;3-待提交;4-待审批;5-已驳回;6-已通过
- // 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,a.report_source
- // 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
- }
- // PublishCancelReport 取消发布报告
- 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:"报告时间创建时间"`
- ReportSource int `gorm:"column:report_source" description:"报告来源:1-系统内;2-智力共享"`
- OutReportId string `gorm:"column:out_report_id" description:"外部报告ID(或编码)"`
- }
- 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
- }
- // GetSimpleReportByIds 根据报告ID查询报告基本信息
- 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
- }
- // GetReportStage
- // @Description: 获取报告的最大期数(每一年的最大期数)
- // @author: Roc
- // @datetime 2024-06-03 17:44:14
- // @param classifyIdFirst int
- // @param classifyIdSecond int
- // @param classifyIdThird int
- // @return count int
- // @return err error
- 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"`
- //CollaborateType int8 `description:"协作方式,1:个人,2:多人协作。默认:1"`
- //ReportLayout int8 `description:"报告布局,1:常规布局,2:智能布局。默认:1"`
- 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"`
- }
- // SendTemplateMsgResp
- // @Description: 报告推送返回结构体
- 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
- }
- // ModifyReportVideoByNoVideo
- // @Description: 修改无音频的报告音频信息
- // @author: Roc
- // @datetime 2024-07-25 18:03:05
- // @param reportId int
- // @param videoUrl string
- // @param videoName string
- // @param videoSize string
- // @param playSeconds float64
- // @return err error
- 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"`
- }
- // SaveDayWeekReportReq 新增晨报周报请求体
- type SaveDayWeekReportReq struct {
- ReportId int `description:"报告ID"`
- Title string `description:"标题"`
- ReportType string `description:"一级分类ID"`
- Author string `description:"作者"`
- CreateTime string `description:"创建时间"`
- }
- // GetReportByReportId 主键获取报告
- 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
- }
- // DeleteDayWeekReportAndChapter 删除晨周报及章节
- 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
- }
- // UpdateReport 更新报告
- func (reportInfo *Report) UpdateReport(cols []string) (err error) {
- err = global.DmSQL["rddp"].Select(cols).Updates(reportInfo).Error
- return
- }
- // ReportDetailView
- // @Description: 晨周报详情
- type ReportDetailView struct {
- *ReportDetail
- ChapterList []*ReportChapter
- GrandAdminList []ReportDetailViewAdmin
- PermissionList []ReportDetailViewPermission
- }
- // ReportDetailViewAdmin
- // @Description: 报告里面的授权人
- type ReportDetailViewAdmin struct {
- AdminId int
- AdminName string
- }
- // ReportDetailViewPermission
- // @Description: 报告分类关联的品种权限
- 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:"报告期数"`
- }
- // PublishReportAndChapter 发布报告及章节
- 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
- }
- // PublishReportById 发布报告
- 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
- }
- // ResetReportById 重置报告状态
- 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:"标题"`
- }
- // SunCodeReq 获取太阳码请求体
- type SunCodeReq struct {
- CodePage string `json:"CodePage" description:"太阳码page"`
- CodeScene string `json:"CodeScene" description:"太阳码scene"`
- }
- // YbPcSuncode 活动海报表
- 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"`
- }
- // GetYbPcSunCode 获取太阳码
- 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
- }
- // YbSuncodePars 小程序太阳码scene参数
- 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
- }
- // UpdateReportSecondClassifyNameByClassifyId 更新报告分类名称字段
- 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
- }
- // UpdateReportFirstClassifyNameByClassifyId 更新报告分类一级名称字段
- 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
- }
- // UpdateReportThirdClassifyNameByClassifyId 更新报告的三级分类名称字段
- 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
- }
- // ModifyReportAuthor 更改报告作者
- 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
- }
- // MarkEditReport 标记编辑英文研报的请求数据
- 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
- }
- // GetReportByCondition 获取报告
- 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
- }
- // SetPrePublishReportById 设置定时发布
- 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
- }
- // ReportSubmitApproveReq 提交审批请求体
- type ReportSubmitApproveReq struct {
- ReportId int `description:"报告ID"`
- }
- // ReportCancelApproveReq 撤回审批请求体
- 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
- }
- // GetReportStateCount 获取指定状态的报告数量
- 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
- }
- // UpdateReportsStateByCond 批量更新报告状态
- 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
- }
- // UpdateReportsStateBySecondIds 批量更新二级分类报告状态
- 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
- }
- // GetReportPdfUrlReq 获取报告pdf地址请求体
- 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
- }
- // UpdatePdfUrlReportById 清空pdf相关字段
- 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
- }
- // InsertMultiReport
- // @Description: 批量新增报告
- // @author: Roc
- // @datetime 2024-06-27 15:55:25
- // @param items []*Report
- // @return err error
- func InsertMultiReport(items []*Report) (err error) {
- err = global.DmSQL["rddp"].CreateInBatches(items, utils.MultiAddNum).Error
- return
- }
- // ReportLayout
- // @Description: 报告布局
- type ReportLayout struct {
- Id int `gorm:"column:id;primaryKey"`
- ReportLayout int8 `gorm:"column:report_layout"` //`description:"报告布局,1:常规布局,2:智能布局。默认:1"`
- }
- // GetReportLayoutByReportId
- // @Description: 根据报告id获取报告的布局
- // @author: Roc
- // @datetime 2024-07-15 15:27:05
- // @param reportId int
- // @return item ReportLayout
- // @return err error
- 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
- }
- func (m *Report) GetCountByCondition(condition string, pars []interface{}) (count int, err error) {
- sql := fmt.Sprintf(`SELECT COUNT(1) FROM report WHERE 1=1 %s`, condition)
- err = global.DmSQL["rddp"].Raw(sql, pars...).Scan(&count).Error
- return
- }
- func (m *Report) GetItemsByCondition(condition string, pars []interface{}, fieldArr []string, orderRule string) (items []*Report, err error) {
- fields := strings.Join(fieldArr, ",")
- if len(fieldArr) == 0 {
- fields = `*`
- }
- order := `ORDER BY create_time DESC`
- if orderRule != "" {
- order = ` ORDER BY ` + orderRule
- }
- sql := fmt.Sprintf(`SELECT %s FROM report WHERE 1=1 %s %s`, fields, condition, order)
- err = global.DmSQL["rddp"].Raw(sql, pars...).Find(&items).Error
- return
- }
|