smart_resource.go 3.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120
  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. pars = append(pars, startSize, pageSize)
  71. err = global.DbMap[utils.MYSQL_URL_RDDP].Raw(sql, pars...).Find(&items).Error
  72. return
  73. }
  74. // SmartReportResourceEditReq 智能研报资源编辑请求体
  75. type SmartReportResourceEditReq struct {
  76. ResourceId int `description:"资源ID"`
  77. ImgName string `description:"图片名称"`
  78. Style string `description:"版图样式"`
  79. }
  80. func (m *SmartReportResource) GetItemById(id int) (item *SmartReportResource, err error) {
  81. //o := orm.NewOrmUsingDB("rddp")
  82. sql := fmt.Sprintf(`SELECT * FROM %s WHERE %s = ? LIMIT 1`, m.TableName(), m.PrimaryId())
  83. err = global.DbMap[utils.MYSQL_URL_RDDP].Raw(sql, id).Scan(&item).Error
  84. return
  85. }
  86. // SmartReportResourceRemoveReq 删除智能研报资源请求体
  87. type SmartReportResourceRemoveReq struct {
  88. ResourceIds string `description:"资源IDs"`
  89. }
  90. // SmartReportResourceAddReq 新增智能研报资源请求体
  91. type SmartReportResourceAddReq struct {
  92. Type int `description:"类型 1-版头 2-版尾"`
  93. ImgUrl string `description:"图片链接"`
  94. ImgName string `description:"图片名称"`
  95. Style string `description:"版图样式"`
  96. }
  97. func GetResourceItemById(id int) (item *SmartReportResource, err error) {
  98. //o := orm.NewOrmUsingDB("rddp")
  99. sql := fmt.Sprintf(`SELECT * FROM smart_report_resource WHERE resource_id = ? LIMIT 1`)
  100. err = global.DbMap[utils.MYSQL_URL_RDDP].Raw(sql, id).Scan(&item).Error
  101. return
  102. }