smart_resource.go 3.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118
  1. package models
  2. import (
  3. "eta/eta_hub/global"
  4. "eta/eta_hub/utils"
  5. "fmt"
  6. "github.com/rdlucklib/rdluck_tools/paging"
  7. "strings"
  8. "time"
  9. )
  10. type SmartReportResource struct {
  11. ResourceId int `orm:"column(resource_id);pk" description:"智能研报资源ID"`
  12. ImgUrl string // 图片链接
  13. Style string // 版图样式
  14. ImgName string // 图片名称
  15. Type int // 类型 1-版头 2-版尾
  16. CreateTime time.Time // 创建时间
  17. }
  18. func (m *SmartReportResource) TableName() string {
  19. return "smart_report_resource"
  20. }
  21. func (m *SmartReportResource) PrimaryId() string {
  22. return "resource_id"
  23. }
  24. func (m *SmartReportResource) Create() (err error) {
  25. //o := orm.NewOrmUsingDB("rddp")
  26. err = global.DbMap[utils.MYSQL_URL_RDDP].Create(m).Error
  27. if err != nil {
  28. return
  29. }
  30. return
  31. }
  32. func (m *SmartReportResource) Update(cols []string) (err error) {
  33. //o := orm.NewOrmUsingDB("rddp")
  34. err = global.DbMap[utils.MYSQL_URL_RDDP].Select(cols).Updates(m).Error
  35. return
  36. }
  37. func (m *SmartReportResource) Del() (err error) {
  38. //o := orm.NewOrmUsingDB("rddp")
  39. sql := fmt.Sprintf(`DELETE FROM %s WHERE %s = ? LIMIT 1`, m.TableName(), m.PrimaryId())
  40. err = global.DbMap[utils.MYSQL_URL_RDDP].Exec(sql, m.ResourceId).Error
  41. return
  42. }
  43. type SmartReportResourceItem struct {
  44. ResourceId int `orm:"column(resource_id);pk" description:"智能研报资源ID"`
  45. ImgUrl string // 图片链接
  46. ImgName string // 图片名称
  47. Style string // 版图样式
  48. Type int // 类型 1-版头 2-版尾
  49. CreateTime string // 创建时间
  50. }
  51. // SmartReportResourceListResp 智能研报资源库
  52. type SmartReportResourceListResp struct {
  53. List []*SmartReportResourceItem
  54. Paging *paging.PagingItem `description:"分页数据"`
  55. }
  56. func (m *SmartReportResource) GetCountByCondition(condition string, pars []interface{}) (count int, err error) {
  57. //o := orm.NewOrmUsingDB("rddp")
  58. sql := fmt.Sprintf(`SELECT COUNT(1) FROM %s WHERE 1=1 %s`, m.TableName(), condition)
  59. err = global.DbMap[utils.MYSQL_URL_RDDP].Raw(sql, pars).Scan(&count).Error
  60. return
  61. }
  62. func (m *SmartReportResource) GetPageItemsByCondition(condition string, pars []interface{}, fieldArr []string, startSize, pageSize int) (items []*SmartReportResourceItem, err error) {
  63. //o := orm.NewOrmUsingDB("rddp")
  64. fields := strings.Join(fieldArr, ",")
  65. if len(fieldArr) == 0 {
  66. fields = `*`
  67. }
  68. order := ` ORDER BY create_time DESC`
  69. sql := fmt.Sprintf(`SELECT %s FROM %s WHERE 1=1 %s %s LIMIT ?,?`, fields, m.TableName(), condition, order)
  70. err = global.DbMap[utils.MYSQL_URL_RDDP].Raw(sql, pars, startSize, pageSize).Find(&items).Error
  71. return
  72. }
  73. // SmartReportResourceEditReq 智能研报资源编辑请求体
  74. type SmartReportResourceEditReq struct {
  75. ResourceId int `description:"资源ID"`
  76. ImgName string `description:"图片名称"`
  77. Style string `description:"版图样式"`
  78. }
  79. func (m *SmartReportResource) GetItemById(id int) (item *SmartReportResource, err error) {
  80. //o := orm.NewOrmUsingDB("rddp")
  81. sql := fmt.Sprintf(`SELECT * FROM %s WHERE %s = ? LIMIT 1`, m.TableName(), m.PrimaryId())
  82. err = global.DbMap[utils.MYSQL_URL_RDDP].Raw(sql, id).Scan(&item).Error
  83. return
  84. }
  85. // SmartReportResourceRemoveReq 删除智能研报资源请求体
  86. type SmartReportResourceRemoveReq struct {
  87. ResourceIds string `description:"资源IDs"`
  88. }
  89. // SmartReportResourceAddReq 新增智能研报资源请求体
  90. type SmartReportResourceAddReq struct {
  91. Type int `description:"类型 1-版头 2-版尾"`
  92. ImgUrl string `description:"图片链接"`
  93. ImgName string `description:"图片名称"`
  94. Style string `description:"版图样式"`
  95. }
  96. func GetResourceItemById(id int) (item *SmartReportResource, err error) {
  97. //o := orm.NewOrmUsingDB("rddp")
  98. sql := fmt.Sprintf(`SELECT * FROM smart_report_resource WHERE resource_id = ? LIMIT 1`)
  99. err = global.DbMap[utils.MYSQL_URL_RDDP].Raw(sql, id).Scan(&item).Error
  100. return
  101. }