12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853 |
- package models
- import (
- "errors"
- "eta/eta_mobile/utils"
- "fmt"
- "strings"
- "time"
- "github.com/beego/beego/v2/client/orm"
- "github.com/rdlucklib/rdluck_tools/paging"
- )
- // 报告状态
- 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
- }
- type ReportShartUrlReq struct {
- Url string `description:"分享链接"`
- ReportId int `description:"报告ID"`
- }
- type ReportShartUrlResp struct {
- UrlToken string `description:"分享链接token"`
- }
|