// @Author gmy 2024/9/19 14:53:00 package document_manage_model import ( "github.com/beego/beego/v2/client/orm" "github.com/rdlucklib/rdluck_tools/paging" ) type OutsideReport struct { OutsideReportId int `orm:"column(outside_report_id);pk" description:"外部报告ID"` Source int `orm:"column(source)" description:"来源,1:ETA系统录入;2:API接口录入;3:邮件监听录入"` Title string `orm:"column(title)" description:"报告标题"` Abstract string `orm:"column(abstract)" description:"摘要"` ClassifyId int `orm:"column(classify_id)" description:"所属分类id"` ClassifyName string `orm:"column(classify_name)" description:"所属分类名称(整个分类链条)"` Content string `orm:"column(content)" description:"报告富文本内容"` SysUserId int `orm:"column(sys_user_id)" description:"创建人id"` SysUserName string `orm:"column(sys_user_name)" description:"创建人姓名"` EmailMessageUid int `orm:"column(email_message_uid)" description:"该邮件在邮箱中的唯一id"` ReportUpdateTime string `orm:"column(report_update_time)" description:"报告更新时间,如果来源于邮件,那么取邮件的收件时间"` ModifyTime string `orm:"column(modify_time)" description:"最近一次修改时间"` CreateTime string `orm:"column(create_time)" description:"创建时间"` } type OutsideReportPage struct { List []OutsideReport `description:"报告列表"` Paging *paging.PagingItem `description:"分页数据"` } type OutsideReportBO struct { OutsideReportId int `orm:"column(outside_report_id);pk" description:"外部报告ID"` Source int `orm:"column(source)" description:"来源,1:ETA系统录入;2:API接口录入;3:邮件监听录入"` Title string `orm:"column(title)" description:"报告标题"` Abstract string `orm:"column(abstract)" description:"摘要"` ClassifyId int `orm:"column(classify_id)" description:"所属分类id"` ClassifyName string `orm:"column(classify_name)" description:"所属分类名称(整个分类链条)"` Content string `orm:"column(content)" description:"报告富文本内容"` SysUserId int `orm:"column(sys_user_id)" description:"创建人id"` SysUserName string `orm:"column(sys_user_name)" description:"创建人姓名"` AttachmentList []*OutsideReportAttachment } // 在 init 函数中注册模型 func init() { orm.RegisterModel(new(OutsideReport)) } // GetOutsideReportListByConditionCount 根据条件查询列表条数 func GetOutsideReportListByConditionCount(condition string, pars []interface{}) (count int, err error) { o := orm.NewOrmUsingDB("rddp") sql := `select count(1) from outside_report t1 inner join chart_permission_search_key_word_mapping t2 on t1.classify_id = t2.classify_id where 1 = 1 ` sql += sql + condition err = o.Raw(sql, pars).QueryRow(&count) if err != nil { return 0, err } return 0, err } // GetOutsideReportListByCondition 根据条件查询列表 func GetOutsideReportListByCondition(condition string, pars []interface{}) (list []OutsideReport, err error) { o := orm.NewOrmUsingDB("rddp") sql := `select * from outside_report t1 left join chart_permission_search_key_word_mapping t2 on t1.classify_id = t2.classify_id where 1 = 1 ` sql += condition _, err = o.Raw(sql, pars).QueryRows(&list) if err != nil { return nil, err } return list, err } /*// GetOutsideReportListByDocumentTypeCount 根据文档类型查询列表条数 func GetOutsideReportListByDocumentTypeCount(documentType int, condition string, pars []interface{}) (count int, err error) { o := orm.NewOrmUsingDB("rddp") var sql string if documentType == 1 { sql = `select count(t1.OutsideReportId) from outside_report t1 left join chart_permission_search_key_word_mapping t2 on t1.classify_id = t2.classify_id where 1 = 1 ` } else if documentType == 2 { sql = `select count(t1.OutsideReportId) from outside_report t1 left join chart_permission_search_key_word_mapping t2 on t1.classify_id = t2.classify_id left join user_collect_classify t3 on t1.classify_id = t3.classify_id where 1 = 1 ` } sql += sql + condition err = o.Raw(sql, pars).QueryRow(&count) if err != nil { return 0, err } return 0, err } // GetOutsideReportListByDocumentType 根据文档类型查询列表 func GetOutsideReportListByDocumentType(documentType int, condition string, pars []interface{}) (list []OutsideReport, err error) { o := orm.NewOrmUsingDB("rddp") var sql string if documentType == 1 { sql = `select t1.* from outside_report t1 left join chart_permission_search_key_word_mapping t2 on t1.classify_id = t2.classify_id where 1 = 1 ` } else if documentType == 2 { sql = `select t1.* from outside_report t1 left join chart_permission_search_key_word_mapping t2 on t1.classify_id = t2.classify_id left join user_collect_classify t3 on t1.classify_id = t3.classify_id where 1 = 1 ` } sql += condition _, err = o.Raw(sql, pars).QueryRows(&list) if err != nil { return nil, err } return list, err }*/ // SaveOutsideReport 保存报告 func SaveOutsideReport(outsideReport OutsideReport) (id int64, err error) { o := orm.NewOrmUsingDB("rddp") id, err = o.Insert(&outsideReport) return } // GetOutsideReportById 根据ID获取报告 func GetOutsideReportById(id int) (outsideReport *OutsideReport, err error) { o := orm.NewOrmUsingDB("rddp") err = o.QueryTable("outside_report").Filter("outside_report_id", id).One(&outsideReport) return } // UpdateOutsideReport 更新报告 func UpdateOutsideReport(outsideReport *OutsideReport) (err error) { o := orm.NewOrmUsingDB("rddp") _, err = o.Update(&outsideReport) return } // DeleteOutsideReport 删除报告 func DeleteOutsideReport(id int) (err error) { o := orm.NewOrmUsingDB("rddp") _, err = o.QueryTable("outside_report").Filter("outside_report_id", id).Delete() return }