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"` }