1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843 |
- package models
- import (
- "errors"
- "eta/eta_mobile/utils"
- "fmt"
- "github.com/beego/beego/v2/client/orm"
- "github.com/rdlucklib/rdluck_tools/paging"
- "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 `orm:"column(id)" description:"报告Id"`
- AddType int `description:"新增方式:1:新增报告,2:继承报告"`
- ClassifyIdFirst int `description:"一级分类id"`
- ClassifyNameFirst string `description:"一级分类名称"`
- ClassifyIdSecond int `description:"二级分类id"`
- ClassifyNameSecond string `description:"二级分类名称"`
- Title string `description:"标题"`
- Abstract string `description:"摘要"`
- Author string `description:"作者"`
- Frequency string `description:"频度"`
- CreateTime string `description:"创建时间"`
- ModifyTime time.Time `description:"修改时间"`
- State int `description:"1:未发布;2:已发布;3-待提交;4-待审批;5-已驳回;6-已通过"`
- PublishTime time.Time `description:"发布时间"`
- Stage int `description:"期数"`
- MsgIsSend int `description:"消息是否已发送,0:否,1:是"`
- ThsMsgIsSend int `description:"客户群消息是否已发送,0:否,1:是"`
- Content string `description:"内容"`
- VideoUrl string `description:"音频文件URL"`
- VideoName string `description:"音频文件名称"`
- VideoPlaySeconds string `description:"音频播放时长"`
- VideoSize string `description:"音频文件大小,单位M"`
- ContentSub string `description:"内容前两个章节"`
- ReportCode string `description:"报告唯一编码"`
- ReportVersion int `description:"1:旧版,2:新版"`
- HasChapter int `description:"是否有章节 0-否 1-是"`
- ChapterType string `description:"章节类型 day-晨报 week-周报"`
- OldReportId int `description:"research_report表ID, 大于0则表示该报告为老后台同步过来的"`
- MsgSendTime time.Time `description:"模版消息发送时间"`
- AdminId int `description:"创建者账号"`
- AdminRealName string `description:"创建者姓名"`
- ApproveTime time.Time `description:"审批时间"`
- ApproveId int `description:"审批ID"`
- DetailImgUrl string `description:"报告详情长图地址"`
- DetailPdfUrl string `description:"报告详情PDF地址"`
- ContentStruct string `description:"内容组件"`
- LastModifyAdminId int `description:"最后更新人ID"`
- LastModifyAdminName string `description:"最后更新人姓名"`
- ContentModifyTime time.Time `description:"内容更新时间"`
- Pv int `description:"pv"`
- Uv int `description:"uv"`
- HeadImg string `description:"报告头图地址"`
- EndImg string `description:"报告尾图地址"`
- CanvasColor string `description:"画布颜色"`
- NeedSplice int `description:"是否拼接版头版位的标记,主要是为了兼容历史报告。0-不需要 1-需要"`
- HeadResourceId int `description:"版头资源ID"`
- EndResourceId int `description:"版尾资源ID"`
- ClassifyIdThird int `description:"三级分类id"`
- ClassifyNameThird string `description:"三级分类名称"`
- CollaborateType int8 `description:"协作方式,1:个人,2:多人协作。默认:1"`
- ReportLayout int8 `description:"报告布局,1:常规布局,2:智能布局。默认:1"`
- IsPublicPublish int8 `description:"是否公开发布,1:是,2:否"`
- ReportCreateTime time.Time `description:"报告时间创建时间"`
- InheritReportId int `description:"待继承的报告ID"`
- VoiceGenerateType int `description:"音频生成方式,0:系统生成,1:人工上传"`
- }
- type ReportList struct {
- Id int `description:"报告Id"`
- AddType int `description:"新增方式:1:新增报告,2:继承报告"`
- ClassifyIdFirst int `description:"一级分类id"`
- ClassifyNameFirst string `description:"一级分类名称"`
- ClassifyIdSecond int `description:"二级分类id"`
- ClassifyNameSecond string `description:"二级分类名称"`
- Title string `description:"标题"`
- Abstract string `description:"摘要"`
- Author string `description:"作者"`
- Frequency string `description:"频度"`
- CreateTime string `description:"创建时间"`
- ModifyTime time.Time `description:"修改时间"`
- State int `description:"1:未发布;2:已发布;3-待提交;4-待审批;5-已驳回;6-已通过"`
- PublishTime string `description:"发布时间"`
- PrePublishTime string `description:"预发布时间"`
- Stage int `description:"期数"`
- MsgIsSend int `description:"模板消息是否已发送,0:否,1:是"`
- Content string `description:"内容"`
- VideoUrl string `description:"音频文件URL"`
- VideoName string `description:"音频文件名称"`
- VideoPlaySeconds string `description:"音频播放时长"`
- ContentSub string `description:"内容前两个章节"`
- Pv int `description:"Pv"`
- Uv int `description:"Uv"`
- ReportCode string `description:"报告唯一编码"`
- ReportVersion int `description:"1:旧版,2:新版"`
- ThsMsgIsSend int `description:"客户群消息是否已发送,0:否,1:是"`
- NeedThsMsg int `description:"是否需要推送客群消息 0-否 1-是"`
- HasChapter int `description:"是否有章节 0-否 1-是"`
- ChapterType string `description:"章节类型 day-晨报 week-周报"`
- ChapterVideoList []*ReportChapterVideoList `description:"章节音频列表"`
- OldReportId int `description:"research_report表ID, 大于0则表示该报告为老后台同步过来的"`
- MsgSendTime string `description:"模版消息发送时间"`
- CanEdit bool `description:"是否可编辑"`
- HasAuth bool `description:"是否可操作"`
- Editor string `description:"编辑人"`
- AdminId int `description:"创建者账号"`
- AdminRealName string `description:"创建者姓名"`
- ApproveTime string `description:"审批时间"`
- DetailImgUrl string `description:"报告详情长图地址"`
- DetailPdfUrl string `description:"报告详情PDF地址"`
- CollaborateType int8 `description:"协作方式,1:个人,2:多人协作。默认:1"`
- ReportLayout int8 `description:"报告布局,1:常规布局,2:智能布局。默认:1"`
- IsPublicPublish int8 `description:"是否公开发布,1:是,2:否"`
- ReportCreateTime time.Time `description:"报告时间创建时间"`
- ContentStruct string `description:"内容组件"`
- LastModifyAdminId int `description:"最后更新人ID"`
- LastModifyAdminName string `description:"最后更新人姓名"`
- ContentModifyTime time.Time `description:"内容更新时间"`
- HeadImg string `description:"报告头图地址"`
- EndImg string `description:"报告尾图地址"`
- CanvasColor string `description:"画布颜色"`
- NeedSplice int `description:"是否拼接版头版位的标记,主要是为了兼容历史报告。0-不需要 1-需要"`
- HeadResourceId int `description:"版头资源ID"`
- EndResourceId int `description:"版尾资源ID"`
- ClassifyIdThird int `description:"三级分类id"`
- ClassifyNameThird string `description:"三级分类名称"`
- InheritReportId int `description:"待继承的报告ID"`
- IsCollect int `description:"是否收藏"`
- }
- 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) {
- o := orm.NewOrmUsingDB("rddp")
- sql := `SELECT COUNT(1) AS count FROM report as a WHERE 1=1 `
- if condition != "" {
- sql += condition
- }
- err = o.Raw(sql, pars).QueryRow(&count)
- 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) {
- o := orm.NewOrmUsingDB("rddp")
- 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 ?,?`
- _, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&items)
- 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
- }
- o := orm.NewOrmUsingDB("rddp")
- 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 = o.Raw(sql, reportIdList).QueryRows(&items)
- 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) {
- o := orm.NewOrmUsingDB("rddp")
- 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 = o.Raw(sql, pars).QueryRow(&count)
- 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) {
- o := orm.NewOrmUsingDB("rddp")
- sql := `SELECT a.* 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 ORDER BY FIELD(state,3,1,4,5,6,2), a.modify_time DESC LIMIT ?,?`
- _, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&items)
- return
- }
- func GetReportListCount(condition string, pars []interface{}) (count int, err error) {
- oRddp := orm.NewOrmUsingDB("rddp")
- sql := `SELECT COUNT(1) AS count FROM report WHERE 1=1 `
- if condition != "" {
- sql += condition
- }
- err = oRddp.Raw(sql, pars).QueryRow(&count)
- return
- }
- func GetReportList(condition string, pars []interface{}, startSize, pageSize int) (items []*ReportList, err error) {
- o := orm.NewOrmUsingDB("rddp")
- sql := `SELECT *,
- (SELECT COUNT(1) FROM report_view_record AS rvr WHERE rvr.report_id=report.id) AS pv,
- (SELECT COUNT(DISTINCT user_id) FROM report_view_record AS rvr WHERE rvr.report_id=report.id) AS uv
- FROM report 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 ?,?`
- _, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&items)
- return
- }
- // PublishReport 发布报告
- func PublishReport(reportIds []int) (err error) {
- if len(reportIds) == 0 {
- return
- }
- o := orm.NewOrmUsingDB("rddp")
- sql := `UPDATE report SET state=2,publish_time=now(),modify_time=NOW() WHERE id IN (` + utils.GetOrmInReplace(len(reportIds)) + `)`
- _, err = o.Raw(sql).Exec()
- return
- }
- // PublishCancelReport 取消发布报告
- func PublishCancelReport(reportId, state int, publishTimeNullFlag bool, lastModifyAdminId int, lastModifyAdminName string) (err error) {
- o := orm.NewOrmUsingDB("rddp")
- 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 = o.Raw(sql, state, lastModifyAdminId, lastModifyAdminName, reportId).Exec()
- return
- }
- // 删除报告
- func DeleteReport(reportIds int) (err error) {
- o := orm.NewOrmUsingDB("rddp")
- sql := ` DELETE FROM report WHERE id =? `
- _, err = o.Raw(sql, reportIds).Exec()
- return
- }
- type ReportDetail struct {
- Id int `orm:"column(id)" description:"报告Id"`
- AddType int `description:"新增方式:1:新增报告,2:继承报告"`
- ClassifyIdFirst int `description:"一级分类id"`
- ClassifyNameFirst string `description:"一级分类名称"`
- ClassifyIdSecond int `description:"二级分类id"`
- ClassifyNameSecond string `description:"二级分类名称"`
- Title string `description:"标题"`
- Abstract string `description:"摘要"`
- Author string `description:"作者"`
- Frequency string `description:"频度"`
- CreateTime string `description:"创建时间"`
- ModifyTime string `description:"修改时间"`
- State int `description:"1:未发布,2:已发布"`
- PublishTime string `description:"发布时间"`
- PrePublishTime string `description:"预发布时间"`
- Stage int `description:"期数"`
- MsgIsSend int `description:"消息是否已发送,0:否,1:是"`
- PreMsgSend int `description:"定时发布成功后是否立即推送模版消息:0否,1是"`
- Content string `description:"内容"`
- VideoUrl string `description:"音频文件URL"`
- VideoName string `description:"音频文件名称"`
- VideoPlaySeconds string `description:"音频播放时长"`
- ContentSub string `description:"内容前两个章节"`
- ThsMsgIsSend int `description:"客户群消息是否已发送,0:否,1:是"`
- HasChapter int `description:"是否有章节 0-否 1-是"`
- ChapterType string `description:"章节类型 day-晨报 week-周报"`
- AdminId int `description:"创建者账号"`
- AdminRealName string `description:"创建者姓名"`
- ReportCode string `description:"报告唯一编码"`
- // eta1.8.3(研报改版)相关内容
- ContentStruct string `description:"内容组件"`
- LastModifyAdminId int `description:"最后更新人ID"`
- LastModifyAdminName string `description:"最后更新人姓名"`
- ContentModifyTime time.Time `description:"内容更新时间"`
- Pv int `description:"pv"`
- Uv int `description:"uv"`
- HeadImg string `description:"报告头图地址"`
- EndImg string `description:"报告尾图地址"`
- HeadStyle string `description:"版头样式"`
- EndStyle string `description:"版尾样式"`
- CanvasColor string `description:"画布颜色"`
- NeedSplice int `description:"是否拼接版头版位的标记,主要是为了兼容历史报告。0-不需要 1-需要"`
- HeadResourceId int `description:"版头资源ID"`
- EndResourceId int `description:"版尾资源ID"`
- ClassifyIdThird int `description:"三级分类id"`
- ClassifyNameThird string `description:"三级分类名称"`
- CollaborateType int8 `description:"协作方式,1:个人,2:多人协作。默认:1"`
- ReportLayout int8 `description:"报告布局,1:常规布局,2:智能布局。默认:1"`
- IsPublicPublish int8 `description:"是否公开发布,1:是,2:否"`
- ReportCreateTime time.Time `description:"报告时间创建时间"`
- }
- func GetReportById(reportId int) (item *ReportDetail, err error) {
- o := orm.NewOrmUsingDB("rddp")
- sql := `SELECT * FROM report WHERE id=?`
- err = o.Raw(sql, reportId).QueryRow(&item)
- return
- }
- func GetReportByIds(reportIds string) (list []*ReportDetail, err error) {
- o := orm.NewOrmUsingDB("rddp")
- sql := `SELECT * FROM report WHERE id in ` + reportIds
- _, err = o.Raw(sql).QueryRows(&list)
- return
- }
- // GetSimpleReportByIds 根据报告ID查询报告基本信息
- func GetSimpleReportByIds(reportIds []int) (list []*Report, err error) {
- if len(reportIds) == 0 {
- return
- }
- o := orm.NewOrmUsingDB("rddp")
- sql := `SELECT id, title, report_code FROM report WHERE id IN (` + utils.GetOrmInReplace(len(reportIds)) + `)`
- _, err = o.Raw(sql, reportIds).QueryRows(&list)
- 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) {
- o := orm.NewOrmUsingDB("rddp")
- 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 MAX(stage) AS max_stage 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 = ? "
- }
- o.Raw(sql, yearStart, classifyId).QueryRow(&count)
- return
- }
- // GetReportStageEdit
- // @Description: 获取报告的最大期数(每一年的最大期数)
- // @author: Roc
- // @datetime 2024-06-04 13:50:34
- // @param classifyIdFirst int
- // @param classifyIdSecond int
- // @param classifyIdThird int
- // @param reportId int
- // @return count int
- // @return err error
- func GetReportStageEdit(classifyIdFirst, classifyIdSecond, classifyIdThird, reportId 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 MAX(stage) AS max_stage FROM report WHERE create_time > ? AND id<>? `
- if classifyIdThird > 0 {
- sql += " AND classify_id_third = ? "
- } else if classifyIdSecond > 0 {
- sql += " AND classify_id_second = ? "
- } else {
- sql = " AND classify_id_first = ? "
- }
- o := orm.NewOrmUsingDB("rddp")
- o.Raw(sql, yearStart, reportId, classifyId).QueryRow(&count)
- 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"`
- }
- func AddReport(item *Report) (lastId int64, err error) {
- o := orm.NewOrmUsingDB("rddp")
- lastId, err = o.Insert(item)
- return
- }
- 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) {
- o := orm.NewOrmUsingDB("rddp")
- 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 = o.Raw(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).Exec()
- return
- }
- func (m *Report) Update(cols []string) (err error) {
- o := orm.NewOrmUsingDB("rddp")
- _, err = o.Update(m, cols...)
- 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) {
- o := orm.NewOrmUsingDB("rddp")
- sql := ` SELECT * FROM report WHERE 1=1 `
- if classifyIdSecond > 0 {
- sql = sql + ` AND classify_id_second=? ORDER BY stage DESC LIMIT 1`
- err = o.Raw(sql, classifyIdSecond).QueryRow(&item)
- } else {
- sql = sql + ` AND classify_id_first=? ORDER BY stage DESC LIMIT 1`
- err = o.Raw(sql, classifyIdFirst).QueryRow(&item)
- }
- 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) {
- o := orm.NewOrmUsingDB("rddp")
- 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 = o.Raw(sql, reportId).Exec()
- }
- return
- }
- func ModifyReportVideo(reportId int, videoUrl, videoName, videoSize string, playSeconds float64) (err error) {
- o := orm.NewOrmUsingDB("rddp")
- sql := `UPDATE report SET video_url=?,video_name=?,video_play_seconds=?,video_size=? WHERE id=? `
- _, err = o.Raw(sql, videoUrl, videoName, playSeconds, videoSize, reportId).Exec()
- return
- }
- type ReportItem struct {
- Id int `orm:"column(id)" description:"报告Id"`
- AddType int `description:"新增方式:1:新增报告,2:继承报告"`
- ClassifyIdFirst int `description:"一级分类id"`
- ClassifyNameFirst string `description:"一级分类名称"`
- ClassifyIdSecond int `description:"二级分类id"`
- ClassifyNameSecond string `description:"二级分类名称"`
- Title string `description:"标题"`
- Abstract string `description:"摘要"`
- Author string `description:"作者"`
- Frequency string `description:"频度"`
- CreateTime time.Time `description:"创建时间"`
- ModifyTime time.Time `description:"修改时间"`
- State int `description:"1:未发布,2:已发布"`
- PublishTime time.Time `description:"发布时间"`
- Stage int `description:"期数"`
- MsgIsSend int `description:"消息是否已发送,0:否,1:是"`
- Content string `description:"内容"`
- VideoUrl string `description:"音频文件URL"`
- VideoName string `description:"音频文件名称"`
- VideoPlaySeconds string `description:"音频播放时长"`
- ContentSub string `description:"内容前两个章节"`
- }
- func GetReportItemById(reportId int) (item *ReportItem, err error) {
- o := orm.NewOrmUsingDB("rddp")
- sql := `SELECT * FROM report WHERE id=?`
- err = o.Raw(sql, reportId).QueryRow(&item)
- return
- }
- 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 EditReportContent(reportId int, content, contentSub string) (err error) {
- o := orm.NewOrmUsingDB("rddp")
- sql := ` UPDATE report SET content=?,content_sub=?,modify_time=NOW() WHERE id=? `
- _, err = o.Raw(sql, content, contentSub, reportId).Exec()
- return
- }
- func AddReportSaveLog(reportId, adminId int, content, contentSub, contentStruct, canvasColor, adminName string, headResourceId, endResourceId int) (err error) {
- o := orm.NewOrmUsingDB("rddp")
- 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 = o.Raw(sql, reportId, content, contentSub, contentStruct, canvasColor, headResourceId, endResourceId, adminId, adminName).Exec()
- return
- }
- func MultiAddReportChaptersSaveLog(items []*ReportChapter, adminId int, adminRealName string) (err error) {
- o := orm.NewOrmUsingDB("rddp")
- p, err := o.Raw(`INSERT INTO report_save_log(report_id, report_chapter_id, content, content_sub,content_struct,admin_id, admin_name) VALUES (?,?,?,?,?,?,?)`).Prepare()
- if err != nil {
- return
- }
- defer func() {
- _ = p.Close()
- }()
- for _, v := range items {
- _, err = p.Exec(v.ReportId, v.ReportChapterId, v.Content, v.ContentSub, v.ContentStruct, adminId, adminRealName)
- if err != nil {
- return
- }
- }
- return
- }
- type SaveReportContentResp struct {
- ReportId int `description:"报告id"`
- }
- func ModifyReportCode(reportId int64, reportCode string) (err error) {
- o := orm.NewOrmUsingDB("rddp")
- sql := `UPDATE report SET report_code=? WHERE id=? `
- _, err = o.Raw(sql, reportCode, reportId).Exec()
- return
- }
- func ModifyReportThsMsgIsSend(item *ReportDetail) (err error) {
- o := orm.NewOrmUsingDB("rddp")
- if item.ThsMsgIsSend == 0 {
- sql := `UPDATE report SET ths_msg_is_send = 1 WHERE id = ? `
- _, err = o.Raw(sql, item.Id).Exec()
- }
- 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:"创建时间"`
- }
- // GetDayWeekReportStage 获取晨报周报期数
- func GetDayWeekReportStage(classifyIdFirst int, yearStart time.Time) (count int, err error) {
- o := orm.NewOrmUsingDB("rddp")
- sql := " SELECT MAX(stage) AS max_stage FROM report WHERE classify_id_first = ? AND create_time > ? "
- o.Raw(sql, classifyIdFirst, yearStart).QueryRow(&count)
- return
- }
- // GetReportByReportId 主键获取报告
- func GetReportByReportId(reportId int) (item *Report, err error) {
- o := orm.NewOrmUsingDB("rddp")
- sql := `SELECT * FROM report WHERE id = ?`
- err = o.Raw(sql, reportId).QueryRow(&item)
- return
- }
- // GetReportByOldReportId 根据老报告id主键获取报告
- func GetReportByOldReportId(reportId int) (item *Report, err error) {
- o := orm.NewOrmUsingDB("rddp")
- sql := `SELECT * FROM report WHERE old_report_id = ?`
- err = o.Raw(sql, reportId).QueryRow(&item)
- return
- }
- // DeleteDayWeekReportAndChapter 删除晨周报及章节
- func DeleteDayWeekReportAndChapter(reportId int) (err error) {
- o := orm.NewOrmUsingDB("rddp")
- to, err := o.Begin()
- if err != nil {
- return
- }
- defer func() {
- if err != nil {
- _ = to.Rollback()
- } else {
- _ = to.Commit()
- }
- }()
- sql := ` DELETE FROM report WHERE id = ? LIMIT 1 `
- if _, err = to.Raw(sql, reportId).Exec(); err != nil {
- return
- }
- sql = ` DELETE FROM report_chapter WHERE report_id = ? `
- if _, err = to.Raw(sql, reportId).Exec(); err != nil {
- return
- }
- return
- }
- // UpdateReport 更新报告
- func (reportInfo *Report) UpdateReport(cols []string) (err error) {
- o := orm.NewOrmUsingDB("rddp")
- _, err = o.Update(reportInfo, cols...)
- 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
- }
- func GetUnPublishDayReport(startTime time.Time, endTime time.Time) (item *Report, err error) {
- o := orm.NewOrmUsingDB("rddp")
- sql := ` SELECT
- *
- FROM
- report AS a
- WHERE
- a.has_chapter = 1
- AND a.chapter_type = "day"
- AND a.state = 1
- AND (
- a.create_time BETWEEN ? AND ?
- )
- ORDER BY
- a.create_time DESC
- LIMIT 1 `
- err = o.Raw(sql, startTime, endTime).QueryRow(&item)
- return
- }
- type ElasticReportDetail struct {
- ReportId int `description:"报告ID"`
- ReportChapterId int `description:"报告章节ID"`
- Title string `description:"标题"`
- Abstract string `description:"摘要"`
- BodyContent string `description:"内容"`
- PublishTime string `description:"发布时间"`
- PublishState int `description:"发布状态 1-未发布 2-已发布"`
- Author string `description:"作者"`
- ClassifyIdFirst int `description:"一级分类ID"`
- ClassifyNameFirst string `description:"一级分类名称"`
- ClassifyIdSecond int `description:"二级分类ID"`
- ClassifyNameSecond string `description:"二级分类名称"`
- ClassifyId int `description:"最小单元的分类ID"`
- ClassifyName string `description:"最小单元的分类名称"`
- Categories string `description:"关联的品种名称(包括品种别名)"`
- StageStr string `description:"报告期数"`
- }
- // GetLastPublishedDayWeekReport 获取上一篇已发布的晨周报
- func GetLastPublishDayWeekReport(chapterType string) (item *Report, err error) {
- o := orm.NewOrmUsingDB("rddp")
- sql := ` SELECT * FROM report WHERE has_chapter = 1 AND chapter_type = ? AND state = 2 ORDER BY publish_time DESC LIMIT 1 `
- err = o.Raw(sql, chapterType).QueryRow(&item)
- return
- }
- // GetNewReportExist
- func GetNewReportExist(oldReportId int) (item *Report, err error) {
- o := orm.NewOrmUsingDB("rddp")
- sql := ` SELECT id FROM report WHERE old_report_id = ? LIMIT 1 `
- err = o.Raw(sql, oldReportId).QueryRow(&item)
- return
- }
- // PublishReportAndChapter 发布报告及章节
- func PublishReportAndChapter(reportInfo *Report, isPublishReport bool, cols []string) (err error) {
- o := orm.NewOrmUsingDB("rddp")
- to, err := o.Begin()
- if err != nil {
- return
- }
- defer func() {
- if err != nil {
- _ = to.Rollback()
- } else {
- _ = to.Commit()
- }
- }()
- // 更新报告
- if isPublishReport {
- _, err = to.Update(reportInfo, cols...)
- if err != nil {
- return
- }
- }
- // 发布该报告的所有章节
- sql := ` UPDATE report_chapter SET publish_state = 2, publish_time = ? WHERE report_id = ? `
- _, err = to.Raw(sql, reportInfo.PublishTime, reportInfo.Id).Exec()
- // 发布章节
- //if len(publishIds) > 0 {
- // sql := ` UPDATE report_chapter SET publish_state = 2, publish_time = ? WHERE report_id = ? AND report_chapter_id IN (` + utils.GetOrmInReplace(len(publishIds)) + `) `
- // _, err = to.Raw(sql, reportInfo.PublishTime, reportInfo.Id, publishIds).Exec()
- //}
- //if len(unPublishIds) > 0 {
- // sql := ` UPDATE report_chapter SET publish_state = 1, publish_time = NULL, is_edit = 0 WHERE report_id = ? AND report_chapter_id IN (` + utils.GetOrmInReplace(len(unPublishIds)) + `) `
- // _, err = to.Raw(sql, reportInfo.Id, unPublishIds).Exec()
- //}
- return
- }
- func GetSyncEmptyVideoReport() (list []*Report, err error) {
- o := orm.NewOrmUsingDB("rddp")
- sql := ` SELECT id FROM report WHERE old_report_id > 0 AND state = 2 AND chapter_type = "" AND (video_size = "" OR video_play_seconds = "")
- UNION ALL
- SELECT DISTINCT report_id FROM report_chapter WHERE publish_state = 2 AND (video_size = "" OR video_play_seconds = "") `
- _, err = o.Raw(sql).QueryRows(&list)
- return
- }
- // PublishReportById 发布报告
- func PublishReportById(reportId int, publishTime time.Time, lastModifyAdminId int, lastModifyAdminName string) (err error) {
- o := orm.NewOrmUsingDB("rddp")
- 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 = o.Raw(sql, publishTime, lastModifyAdminId, lastModifyAdminName, reportId).Exec()
- return
- }
- // ResetReportById 重置报告状态
- func ResetReportById(reportId, state int, lastModifyAdminId int, lastModifyAdminName string) (err error) {
- o := orm.NewOrmUsingDB("rddp")
- 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 = o.Raw(sql, state, lastModifyAdminId, lastModifyAdminName, reportId).Exec()
- return
- }
- // GetCommentReportByReportId 查询有留言的报告列表
- func GetCommentReportByReportId(condition string, pars []interface{}, startSize, pageSize int) (list []*Report, err error) {
- o := orm.NewOrmUsingDB("rddp")
- sql := `SELECT
- id,
- create_time,
- title,
- classify_name_first,
- classify_id_first,
- classify_name_second,
- classify_id_second,
- state,
- IF
- ( publish_time, publish_time, create_time ) AS publish_time
- FROM
- report
- WHERE
- 1=1
- `
- if condition != "" {
- sql += condition
- }
- sql += ` ORDER BY publish_time DESC , title ASC LIMIT ?,?`
- _, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&list)
- return
- }
- // GetCommentReportByReportIdOrderBy 查询有留言的报告列表(指定排序)
- func GetCommentReportByReportIdOrderBy(condition string, pars []interface{}, startSize, pageSize int, orderBy string) (list []*Report, err error) {
- o := orm.NewOrmUsingDB("rddp")
- sql := `SELECT
- id,
- create_time,
- title,
- classify_name_first,
- classify_id_first,
- classify_name_second,
- classify_id_second,
- state,
- IF
- ( publish_time, publish_time, create_time ) AS publish_time
- FROM
- report
- WHERE
- 1=1
- `
- if condition != "" {
- sql += condition
- }
- if orderBy == `` {
- sql += ` ORDER BY publish_time DESC , title ASC `
- } else {
- sql += orderBy
- }
- sql += ` LIMIT ?,? `
- _, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&list)
- return
- }
- // GetCommentReportTotalByReportId 查询有留言的报告列表总数
- func GetCommentReportTotalByReportId(condition string, pars []interface{}) (total int64, err error) {
- o := orm.NewOrmUsingDB("rddp")
- sql := `SELECT count(*)
- FROM report WHERE 1=1`
- if condition != "" {
- sql += condition
- }
- err = o.Raw(sql, pars).QueryRow(&total)
- return
- }
- // 点赞相关的报告列表
- type LikeReportItem struct {
- ReportId int `description:"报告Id"`
- ReportChapterId int `description:"报告章节Id"`
- ClassifyIdFirst int `description:"一级分类id"`
- ClassifyNameFirst string `description:"一级分类名称"`
- ClassifyIdSecond int `description:"二级分类id"`
- ClassifyNameSecond string `description:"二级分类名称"`
- ReportChapterTypeId int `description:"章节类型"`
- ReportChapterTypeName string `description:"品种名称"`
- PublishTime time.Time `description:"发布时间" `
- Title string `description:"标题"`
- }
- // GetLikeReportByReportIdReportChapterId 获取有被点赞的报告列表
- func GetLikeReportByReportIdReportChapterId(reportIds string, chapterIds string, orderStr string, startSize, pageSize int) (list []*LikeReportItem, err error) {
- o := orm.NewOrmUsingDB("rddp")
- sql := `( SELECT
- id AS report_id,
- 0 AS report_chapter_id,
- classify_id_first,
- classify_id_second,
- classify_name_first,
- classify_name_second,
- 0 as report_chapter_type_id,
- "" as report_chapter_type_name,
- publish_time,
- title
- FROM
- report
- WHERE
- classify_name_first != "晨报"
- AND classify_name_first != "周报"
- AND id in (` + reportIds + `)
- )
- UNION
-
- ( SELECT
- report_id,
- report_chapter_id,
- classify_id_first,
- 0 as classify_id_second,
- classify_name_first,
- null as classify_name_second,
- type_id as report_chapter_type_id,
- type_name as report_chapter_type_name,
- publish_time,
- title
- FROM
- report_chapter
- WHERE
- report_chapter_id in (` + chapterIds + `)
- )`
- if orderStr != "" {
- sql += ` ORDER BY FIELD(CONCAT(report_id, "-",report_chapter_id),` + orderStr + `)`
- } else {
- sql += ` ORDER BY publish_time DESC, report_id Desc`
- }
- sql += ` LIMIT ?,?`
- _, err = o.Raw(sql, startSize, pageSize).QueryRows(&list)
- return
- }
- // GetLikeReportTotalByReportIdReportChapterId 获取有被点赞的报告列表总数
- func GetLikeReportTotalByReportIdReportChapterId(reportIds string, chapterIds string) (total int64, err error) {
- o := orm.NewOrmUsingDB("rddp")
- sql := `select count(*) from (( SELECT
- id AS report_id,
- 0 AS report_chapter_id,
- classify_id_first,
- classify_id_second,
- classify_name_first,
- classify_name_second,
- 0 as report_chapter_type_id,
- publish_time,
- title
- FROM
- report
- WHERE
- classify_name_first != "晨报"
- AND classify_name_first != "周报"
- AND id in (` + reportIds + `)
- )
- UNION
-
- ( SELECT
- report_id,
- report_chapter_id,
- classify_id_first,
- 0 as classify_id_second,
- classify_name_first,
- null as classify_name_second,
- type_id as report_chapter_type_id,
- publish_time,
- title
- FROM
- report_chapter
- WHERE
- report_chapter_id in (` + chapterIds + `)
- )) r`
- err = o.Raw(sql).QueryRow(&total)
- return
- }
- // GetPageReportList 分页获取报告列表
- func GetPageReportList(condition string, pars []interface{}, startSize, pageSize int) (total int, items []*ReportList, err error) {
- o := orm.NewOrmUsingDB("rddp")
- sql := `SELECT * FROM report WHERE 1=1 `
- sql += condition
- sql += ` ORDER BY modify_time DESC`
- totalSql := `SELECT COUNT(1) total FROM (` + sql + `) z `
- err = o.Raw(totalSql, pars).QueryRow(&total)
- if err != nil {
- return
- }
- sql += ` LIMIT ?,? `
- _, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&items)
- return
- }
- // SunCodeReq 获取太阳码请求体
- type SunCodeReq struct {
- CodePage string `json:"CodePage" description:"太阳码page"`
- CodeScene string `json:"CodeScene" description:"太阳码scene"`
- }
- // YbPcSuncode 活动海报表
- type YbPcSuncode struct {
- SuncodeID uint32 `orm:"column(suncode_id);pk" `
- 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) {
- o := orm.NewOrmUsingDB("weekly")
- sql := `SELECT * FROM yb_pc_suncode WHERE scene = ? AND code_page = ? `
- err = o.Raw(sql, scene, page).QueryRow(&item)
- return
- }
- func AddYbPcSunCode(item *YbPcSuncode) (err error) {
- o := orm.NewOrmUsingDB("weekly")
- _, err = o.Insert(item)
- return
- }
- // YbSuncodePars 小程序太阳码scene参数
- type YbSuncodePars struct {
- ID uint32 `orm:"column(id);pk" `
- 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) {
- o := orm.NewOrmUsingDB("weekly")
- _, err = o.Insert(item)
- return
- }
- // UpdateReportSecondClassifyNameByClassifyId 更新报告分类名称字段
- func UpdateReportSecondClassifyNameByClassifyId(classifyId int, classifyName string) (err error) {
- o := orm.NewOrmUsingDB("rddp")
- sql := " UPDATE report SET classify_name_second = ? WHERE classify_id_second = ? "
- _, err = o.Raw(sql, classifyName, classifyId).Exec()
- return
- }
- // UpdateReportFirstClassifyNameByClassifyId 更新报告分类一级名称字段
- func UpdateReportFirstClassifyNameByClassifyId(classifyId int, classifyName string) (err error) {
- o := orm.NewOrmUsingDB("rddp")
- sql := " UPDATE report SET classify_name_first = ? WHERE classify_id_first = ? "
- _, err = o.Raw(sql, classifyName, classifyId).Exec()
- return
- }
- // UpdateReportThirdClassifyNameByClassifyId 更新报告的三级分类名称字段
- func UpdateReportThirdClassifyNameByClassifyId(classifyId int, classifyName string) (err error) {
- o := orm.NewOrmUsingDB("rddp")
- sql := " UPDATE report SET classify_name_third = ? WHERE classify_id_third = ? "
- _, err = o.Raw(sql, classifyName, classifyId).Exec()
- return
- }
- // UpdateReportSecondClassifyFirstNameByClassifyId 更新报告二级分类的一级分类名称和id
- func UpdateReportSecondClassifyFirstNameByClassifyId(classifyId, newClassifyId int, classifyName string) (err error) {
- o := orm.NewOrmUsingDB("rddp")
- sql := " UPDATE report SET classify_name_first = ?, classify_id_first = ? WHERE classify_id_second = ? "
- _, err = o.Raw(sql, classifyName, newClassifyId, classifyId).Exec()
- return
- }
- // GetEmptyContentSubPPTReport 获取前两章为空的PPT报告
- func GetEmptyContentSubPPTReport() (list []*Report, err error) {
- sql := `SELECT
- r.id,
- r.content,
- r.content_sub
- FROM
- report AS r
- JOIN ppt_v2 AS p ON r.id = p.report_id
- WHERE
- p.report_id > 0 AND r.content_sub = ""`
- _, err = orm.NewOrmUsingDB("rddp").Raw(sql).QueryRows(&list)
- return
- }
- // ModifyReportAuthor 更改报告作者
- func ModifyReportAuthor(condition string, pars []interface{}, authorName string) (count int, err error) {
- //产品权限
- oRddp := orm.NewOrmUsingDB("rddp")
- sql := `UPDATE english_report set author = ? WHERE 1=1 `
- if condition != "" {
- sql += condition
- }
- err = oRddp.Raw(sql, authorName, pars).QueryRow(&count)
- return
- }
- func UpdateReportPublishTime(reportId int, videoNameDate string) (err error) {
- o := orm.NewOrmUsingDB("rddp")
- sql1 := ` UPDATE report SET publish_time = NOW() WHERE id = ? `
- _, err = o.Raw(sql1, reportId).Exec()
- 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 = o.Raw(sql2, reportId).Exec()
- return
- }
- func UpdateReportChapterPublishTime(reportId int, videoNameDate string) (err error) {
- o := orm.NewOrmUsingDB("rddp")
- sql1 := ` UPDATE report_chapter SET publish_time = NOW() WHERE report_id = ? `
- _, err = o.Raw(sql1, reportId).Exec()
- 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 = o.Raw(sql2, reportId).Exec()
- 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) {
- o := orm.NewOrmUsingDB("rddp")
- 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 = o.Raw(sql, pars, startSize, pageSize).QueryRows(&items)
- } else {
- _, err = o.Raw(sql, pars).QueryRows(&items)
- }
- return
- }
- // ModifyReportMsgIsSendV2 更新报告消息状态
- func ModifyReportMsgIsSendV2(reportId int) (err error) {
- o := orm.NewOrmUsingDB("rddp")
- sql := `UPDATE report SET msg_is_send = 1, ths_msg_is_send = 1, msg_send_time = NOW() WHERE id = ? LIMIT 1`
- _, err = o.Raw(sql, reportId).Exec()
- return
- }
- // SetPrePublishReportById 设置定时发布
- func SetPrePublishReportById(reportId int, prePublishTime string, preMsgSend int) (err error) {
- o := orm.NewOrmUsingDB("rddp")
- sql := `UPDATE report SET pre_publish_time=?, pre_msg_send=? WHERE id = ? and state = 1 `
- _, err = o.Raw(sql, prePublishTime, preMsgSend, reportId).Exec()
- 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) {
- o := orm.NewOrmUsingDB("rddp")
- sql := `SELECT * FROM report WHERE id = ? LIMIT 1`
- err = o.Raw(sql, id).QueryRow(&item)
- return
- }
- // GetReportStateCount 获取指定状态的报告数量
- func GetReportStateCount(state int) (count int, err error) {
- o := orm.NewOrmUsingDB("rddp")
- sql := `SELECT COUNT(1) AS count FROM report WHERE state = ?`
- err = o.Raw(sql, state).QueryRow(&count)
- return
- }
- // UpdateReportsStateByCond 批量更新报告状态
- func UpdateReportsStateByCond(classifyFirstId, classifySecondId, classifyThirdId, oldState, newState int) (err error) {
- o := orm.NewOrmUsingDB("rddp")
- 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 = o.Raw(sql, newState, oldState).Exec()
- return
- }
- // UpdateReportsStateBySecondIds 批量更新二级分类报告状态
- func UpdateReportsStateBySecondIds(oldState, newState int, secondIds []int) (err error) {
- if len(secondIds) <= 0 {
- return
- }
- o := orm.NewOrmUsingDB("rddp")
- // (有审批流的)未发布->待提交
- sql := fmt.Sprintf(`UPDATE report SET state = ?, pre_publish_time = NULL WHERE state = ? AND classify_id_second IN (%s)`, utils.GetOrmInReplace(len(secondIds)))
- _, err = o.Raw(sql, newState, oldState, secondIds).Exec()
- 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 = o.Raw(sql, oldState, newState, secondIds).Exec()
- 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) {
- o := orm.NewOrmUsingDB("rddp")
- sql := `UPDATE report SET detail_pdf_url=? WHERE id=? `
- _, err = o.Raw(sql, detailPdfUrl, reportId).Exec()
- return
- }
- func ModifyReportImgUrl(reportId int, detailImgUrl string) (err error) {
- o := orm.NewOrmUsingDB("rddp")
- sql := `UPDATE report SET detail_img_url=? WHERE id=? `
- _, err = o.Raw(sql, detailImgUrl, reportId).Exec()
- return
- }
- // UpdatePdfUrlReportById 清空pdf相关字段
- func UpdatePdfUrlReportById(reportId int) (err error) {
- o := orm.NewOrmUsingDB("rddp")
- sql := `UPDATE report SET detail_img_url = '',detail_pdf_url='',modify_time=NOW() WHERE id = ? `
- _, err = o.Raw(sql, reportId).Exec()
- return
- }
- // InsertMultiReport
- // @Description: 批量新增报告
- // @author: Roc
- // @datetime 2024-06-27 15:55:25
- // @param items []*Report
- // @return err error
- func InsertMultiReport(items []*Report) (err error) {
- o := orm.NewOrmUsingDB("rddp")
- _, err = o.InsertMulti(500, items)
- return
- }
- func GetReportListByCollectCount(classifyIdFirst, classifyIdSecond, classifyIdThird []string, keyword, author string, state int) (count int, err error) {
- o := orm.NewOrmUsingDB("rddp")
- var params []interface{}
- // SQL 主体
- sql := `
- SELECT COUNT(DISTINCT t.id) AS totalCount
- FROM (
- SELECT b.id
- FROM report AS b
- LEFT JOIN user_collect_classify AS a ON a.classify_id = b.classify_id_first
- WHERE 1 = 1
- `
- // 处理 classifyIdFirst
- if len(classifyIdFirst) > 0 {
- sql += " AND a.classify_id IN ( " + utils.GetOrmInReplace(len(classifyIdFirst)) + " ) "
- for _, id := range classifyIdFirst {
- params = append(params, id)
- }
- }
- // 处理关键词
- if keyword != "" {
- sql += " AND (b.title LIKE ? OR b.admin_real_name LIKE ?)"
- params = append(params, "%"+keyword+"%", "%"+keyword+"%")
- }
- if author != "" {
- sql += " AND b.author = ? "
- params = append(params, author)
- }
- if state > 0 {
- sql += " AND b.state = ? "
- params = append(params, state)
- }
- // 第二段 SQL
- sql += `
- UNION ALL
- SELECT b.id
- FROM report AS b
- LEFT JOIN user_collect_classify AS a ON a.classify_id = b.classify_id_second
- WHERE 1 = 1
- `
- // 处理 classifyIdSecond
- if len(classifyIdSecond) > 0 {
- sql += " AND a.classify_id IN ( " + utils.GetOrmInReplace(len(classifyIdSecond)) + " ) "
- for _, id := range classifyIdSecond {
- params = append(params, id)
- }
- }
- // 处理关键词
- if keyword != "" {
- sql += " AND (b.title LIKE ? OR b.admin_real_name LIKE ?)"
- params = append(params, "%"+keyword+"%", "%"+keyword+"%")
- }
- if author != "" {
- sql += " AND b.author = ? "
- params = append(params, author)
- }
- if state > 0 {
- sql += " AND b.state = ? "
- params = append(params, state)
- }
- // 第三段 SQL
- sql += `
- UNION ALL
- SELECT b.id
- FROM report AS b
- LEFT JOIN user_collect_classify AS a ON a.classify_id = b.classify_id_third
- WHERE 1 = 1
- `
- // 处理 classifyIdThird
- if len(classifyIdThird) > 0 {
- sql += " AND a.classify_id IN ( " + utils.GetOrmInReplace(len(classifyIdThird)) + " ) "
- for _, id := range classifyIdThird {
- params = append(params, id)
- }
- }
- // 处理关键词
- if keyword != "" {
- sql += " AND (b.title LIKE ? OR b.admin_real_name LIKE ?)"
- params = append(params, "%"+keyword+"%", "%"+keyword+"%")
- }
- if author != "" {
- sql += " AND b.author = ? "
- params = append(params, author)
- }
- if state > 0 {
- sql += " AND b.state = ? "
- params = append(params, state)
- }
- sql += ") AS t"
- // 执行 SQL 查询获取总数
- err = o.Raw(sql, params...).QueryRow(&count)
- return count, err
- }
- func GetReportListByCollectList(classifyIdFirst, classifyIdSecond, classifyIdThird []string, keyword, orderField, orderType string, startSize, pageSize int, author string, state int) (items []*ReportList, err error) {
- o := orm.NewOrmUsingDB("rddp")
- var params []interface{}
- // SQL 主体
- sql := `
- SELECT DISTINCT t.id, t.title, t.author, t.modify_time, t.publish_time
- FROM (
- SELECT b.id, b.title, b.author, b.modify_time, b.publish_time
- FROM report AS b
- LEFT JOIN user_collect_classify AS a ON a.classify_id = b.classify_id_first
- WHERE 1 = 1
- `
- // 处理 classifyIdFirst
- if len(classifyIdFirst) > 0 {
- sql += " AND a.classify_id IN ( " + utils.GetOrmInReplace(len(classifyIdFirst)) + " ) "
- for _, id := range classifyIdFirst {
- params = append(params, id)
- }
- }
- // 处理关键词
- if keyword != "" {
- sql += " AND (b.title LIKE ? OR b.admin_real_name LIKE ?)"
- params = append(params, "%"+keyword+"%", "%"+keyword+"%")
- }
- if author != "" {
- sql += " AND b.author = ? "
- params = append(params, author)
- }
- if state > 0 {
- sql += " AND b.state = ? "
- params = append(params, state)
- }
- // 第二段 SQL
- sql += `
- UNION ALL
- SELECT b.id, b.title, b.author, b.modify_time, b.publish_time
- FROM report AS b
- LEFT JOIN user_collect_classify AS a ON a.classify_id = b.classify_id_second
- WHERE 1 = 1
- `
- // 处理 classifyIdSecond
- if len(classifyIdSecond) > 0 {
- sql += " AND a.classify_id IN ( " + utils.GetOrmInReplace(len(classifyIdSecond)) + " ) "
- for _, id := range classifyIdSecond {
- params = append(params, id)
- }
- }
- // 处理关键词
- if keyword != "" {
- sql += " AND (b.title LIKE ? OR b.admin_real_name LIKE ?)"
- params = append(params, "%"+keyword+"%", "%"+keyword+"%")
- }
- if author != "" {
- sql += " AND b.author = ? "
- params = append(params, author)
- }
- if state > 0 {
- sql += " AND b.state = ? "
- params = append(params, state)
- }
- // 第三段 SQL
- sql += `
- UNION ALL
- SELECT b.id, b.title, b.author, b.modify_time, b.publish_time
- FROM report AS b
- LEFT JOIN user_collect_classify AS a ON a.classify_id = b.classify_id_third
- WHERE 1 = 1
- `
- // 处理 classifyIdThird
- if len(classifyIdThird) > 0 {
- sql += " AND a.classify_id IN ( " + utils.GetOrmInReplace(len(classifyIdThird)) + " ) "
- for _, id := range classifyIdThird {
- params = append(params, id)
- }
- }
- // 处理关键词
- if keyword != "" {
- sql += " AND (b.title LIKE ? OR b.admin_real_name LIKE ?)"
- params = append(params, "%"+keyword+"%", "%"+keyword+"%")
- }
- if author != "" {
- sql += " AND b.author = ? "
- params = append(params, author)
- }
- if state > 0 {
- sql += " AND b.state = ? "
- params = append(params, state)
- }
- sql += ") AS t "
- // 排序处理
- if orderField != "" && orderType != "" {
- sql += " ORDER BY " + orderField + " " + orderType
- } else {
- sql += " ORDER BY t.modify_time DESC, t.publish_time DESC "
- }
- // 分页
- sql += " LIMIT ?, ?"
- params = append(params, (startSize-1)*pageSize, pageSize)
- // 执行 SQL 查询
- _, err = o.Raw(sql, params...).QueryRows(&items)
- return items, err
- }
- func GetReportListByCollectCountV2(classifyIdFirst, classifyIdSecond, classifyIdThird, chartPermissionIdList []string, keyword, author string, state int) (count int, err error) {
- o := orm.NewOrmUsingDB("rddp")
- var params []interface{}
- // SQL 主体
- sql := `
- SELECT COUNT(DISTINCT t.id) AS totalCount
- FROM (
- SELECT b.id
- FROM report AS b left join chart_permission_search_key_word_mapping c on
- b.classify_id_first = c.classify_id
- WHERE 1 = 1
- `
- if len(chartPermissionIdList) > 0 {
- sql += ` and c.chart_permission_id in (` + utils.GetOrmInReplace(len(chartPermissionIdList)) + `)`
- for _, chartPermissionId := range chartPermissionIdList {
- params = append(params, chartPermissionId)
- }
- }
- // 处理关键词
- if keyword != "" {
- sql += " AND (b.title LIKE ? OR b.admin_real_name LIKE ?)"
- params = append(params, "%"+keyword+"%", "%"+keyword+"%")
- }
- if author != "" {
- sql += " AND b.author = ? "
- params = append(params, author)
- }
- if state > 0 {
- sql += " AND b.state = ? "
- params = append(params, state)
- }
- // 分类id判断
- classifyIdSqlList := make([]string, 0)
- // 处理 classifyIdFirst
- if len(classifyIdFirst) > 0 {
- classifyIdSqlList = append(classifyIdSqlList, " ( b.classify_id_first IN ( "+utils.GetOrmInReplace(len(classifyIdFirst))+" ) AND classify_id_second = 0 AND classify_id_third = 0 ) ")
- for _, id := range classifyIdFirst {
- params = append(params, id)
- }
- }
- // 处理 classifyIdSecond
- if len(classifyIdSecond) > 0 {
- classifyIdSqlList = append(classifyIdSqlList, " ( b.classify_id_second IN ( "+utils.GetOrmInReplace(len(classifyIdSecond))+" ) AND classify_id_third = 0) ")
- for _, id := range classifyIdSecond {
- params = append(params, id)
- }
- }
- // 处理 classifyIdThird
- if len(classifyIdThird) > 0 {
- classifyIdSqlList = append(classifyIdSqlList, " ( b.classify_id_third IN ( "+utils.GetOrmInReplace(len(classifyIdThird))+" ) ) ")
- for _, id := range classifyIdThird {
- params = append(params, id)
- }
- }
- if len(classifyIdSqlList) > 0 {
- sql += ` AND (` + strings.Join(classifyIdSqlList, " OR ") + `) `
- }
- sql += ") AS t"
- // 执行 SQL 查询获取总数
- err = o.Raw(sql, params...).QueryRow(&count)
- return count, err
- }
- func GetReportListByCollectListV2(classifyIdFirst, classifyIdSecond, classifyIdThird, chartPermissionIdList []string, keyword, orderField, orderType string, startSize, pageSize int, author string, state int) (items []*ReportList, err error) {
- o := orm.NewOrmUsingDB("rddp")
- var params []interface{}
- // SQL 主体
- sql := `
- SELECT DISTINCT t.id, t.title, t.author, t.modify_time, t.publish_time,t.classify_id_first,t.classify_name_first,t.classify_id_second,t.classify_name_second,t.classify_id_third,t.classify_name_third
- FROM (
- SELECT b.id, b.title, b.author, b.modify_time, b.publish_time,b.classify_id_first,b.classify_name_first,b.classify_id_second,b.classify_name_second,b.classify_id_third,b.classify_name_third
- FROM report AS b left join chart_permission_search_key_word_mapping c on
- b.classify_id_first = c.classify_id
- WHERE 1 = 1
- `
- // 处理关键词
- if keyword != "" {
- sql += " AND (b.title LIKE ? OR b.admin_real_name LIKE ?)"
- params = append(params, "%"+keyword+"%", "%"+keyword+"%")
- }
- if author != "" {
- sql += " AND b.author = ? "
- params = append(params, author)
- }
- if state > 0 {
- sql += " AND b.state = ? "
- params = append(params, state)
- }
- // 分类id判断
- classifyIdSqlList := make([]string, 0)
- // 处理 classifyIdFirst
- if len(classifyIdFirst) > 0 {
- classifyIdSqlList = append(classifyIdSqlList, " ( b.classify_id_first IN ( "+utils.GetOrmInReplace(len(classifyIdFirst))+" ) AND classify_id_second = 0 AND classify_id_third = 0 ) ")
- for _, id := range classifyIdFirst {
- params = append(params, id)
- }
- }
- // 处理 classifyIdSecond
- if len(classifyIdSecond) > 0 {
- classifyIdSqlList = append(classifyIdSqlList, " ( b.classify_id_second IN ( "+utils.GetOrmInReplace(len(classifyIdSecond))+" ) AND classify_id_third = 0) ")
- for _, id := range classifyIdSecond {
- params = append(params, id)
- }
- }
- // 处理 classifyIdThird
- if len(classifyIdThird) > 0 {
- classifyIdSqlList = append(classifyIdSqlList, " ( b.classify_id_third IN ( "+utils.GetOrmInReplace(len(classifyIdThird))+" ) ) ")
- for _, id := range classifyIdThird {
- params = append(params, id)
- }
- }
- if len(classifyIdSqlList) > 0 {
- sql += ` AND (` + strings.Join(classifyIdSqlList, " OR ") + `) `
- }
- if len(chartPermissionIdList) > 0 {
- sql += ` and c.chart_permission_id in (` + utils.GetOrmInReplace(len(chartPermissionIdList)) + `)`
- for _, chartPermissionId := range chartPermissionIdList {
- params = append(params, chartPermissionId)
- }
- }
- sql += ") AS t "
- // 排序处理
- if orderField != "" && orderType != "" {
- sql += " ORDER BY " + orderField + " " + orderType
- } else {
- sql += " ORDER BY t.modify_time DESC, t.publish_time DESC "
- }
- // 分页
- sql += " LIMIT ?, ?"
- params = append(params, (startSize-1)*pageSize, pageSize)
- // 执行 SQL 查询
- _, err = o.Raw(sql, params...).QueryRows(&items)
- return items, err
- }
|