chart_framework_node.go 4.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136
  1. package data_manage
  2. import (
  3. "eta/eta_api/global"
  4. "eta/eta_api/utils"
  5. "fmt"
  6. "strings"
  7. "time"
  8. )
  9. // ChartFrameworkNode 图库框架节点表
  10. type ChartFrameworkNode struct {
  11. ChartFrameworkNodeId int `gorm:"column(chart_framework_node_id);primaryKey" description:"节点ID"`
  12. ChartFrameworkId int `gorm:"column(chart_framework_id)" description:"框架ID"`
  13. FrameworkName string `gorm:"column(framework_name)" description:"框架名称"`
  14. NodeId string `gorm:"column(node_id)" description:"节点ID"`
  15. NodeName string `gorm:"column(node_name)" description:"节点名称"`
  16. MyChartClassifyId int `gorm:"column(my_chart_classify_id)" description:"我的图表分类ID"`
  17. CreateTime time.Time `gorm:"column(create_time)" description:"创建时间"`
  18. }
  19. func (m *ChartFrameworkNode) TableName() string {
  20. return "chart_framework_node"
  21. }
  22. func (m *ChartFrameworkNode) PrimaryId() string {
  23. return "chart_framework_node_id"
  24. }
  25. func (m *ChartFrameworkNode) Create() (err error) {
  26. o := global.DbMap[utils.DbNameIndex]
  27. err = o.Create(m).Error
  28. return
  29. }
  30. func (m *ChartFrameworkNode) CreateMulti(items []*ChartFrameworkNode) (err error) {
  31. if len(items) == 0 {
  32. return
  33. }
  34. o := global.DbMap[utils.DbNameIndex]
  35. err = o.CreateInBatches(items, utils.MultiAddNum).Error
  36. return
  37. }
  38. func (m *ChartFrameworkNode) Update(cols []string) (err error) {
  39. o := global.DbMap[utils.DbNameIndex]
  40. err = o.Model(m).Select(cols).Updates(m).Error
  41. return
  42. }
  43. func (m *ChartFrameworkNode) Del() (err error) {
  44. o := global.DbMap[utils.DbNameIndex]
  45. sql := fmt.Sprintf(`DELETE FROM %s WHERE %s = ? LIMIT 1`, m.TableName(), m.PrimaryId())
  46. err = o.Exec(sql, m.ChartFrameworkNodeId).Error
  47. return
  48. }
  49. func (m *ChartFrameworkNode) GetItemById(id int) (item *ChartFrameworkNode, err error) {
  50. o := global.DbMap[utils.DbNameIndex]
  51. sql := fmt.Sprintf(`SELECT * FROM %s WHERE %s = ? LIMIT 1`, m.TableName(), m.PrimaryId())
  52. err = o.Raw(sql, id).First(&item).Error
  53. return
  54. }
  55. func (m *ChartFrameworkNode) GetItemByCondition(condition string, pars []interface{}) (item *ChartFrameworkNode, err error) {
  56. o := global.DbMap[utils.DbNameIndex]
  57. sql := fmt.Sprintf(`SELECT * FROM %s WHERE 1=1 %s LIMIT 1`, m.TableName(), condition)
  58. err = o.Raw(sql, pars...).First(&item).Error
  59. return
  60. }
  61. func (m *ChartFrameworkNode) GetCountByCondition(condition string, pars []interface{}) (count int, err error) {
  62. o := global.DbMap[utils.DbNameIndex]
  63. sql := fmt.Sprintf(`SELECT COUNT(1) FROM %s WHERE 1=1 %s`, m.TableName(), condition)
  64. err = o.Raw(sql, pars...).Scan(&count).Error
  65. return
  66. }
  67. func (m *ChartFrameworkNode) GetItemsByCondition(condition string, pars []interface{}, fieldArr []string, orderRule string) (items []*ChartFrameworkNode, err error) {
  68. o := global.DbMap[utils.DbNameIndex]
  69. fields := strings.Join(fieldArr, ",")
  70. if len(fieldArr) == 0 {
  71. fields = `*`
  72. }
  73. order := `ORDER BY create_time DESC`
  74. if orderRule != "" {
  75. order = ` ORDER BY ` + orderRule
  76. }
  77. sql := fmt.Sprintf(`SELECT %s FROM %s WHERE 1=1 %s %s`, fields, m.TableName(), condition, order)
  78. err = o.Raw(sql, pars...).Find(&items).Error
  79. return
  80. }
  81. func (m *ChartFrameworkNode) GetPageItemsByCondition(condition string, pars []interface{}, fieldArr []string, orderRule string, startSize, pageSize int) (items []*ChartFrameworkNode, err error) {
  82. o := global.DbMap[utils.DbNameIndex]
  83. fields := strings.Join(fieldArr, ",")
  84. if len(fieldArr) == 0 {
  85. fields = `*`
  86. }
  87. order := `ORDER BY create_time DESC`
  88. if orderRule != "" {
  89. order = ` ORDER BY ` + orderRule
  90. }
  91. sql := fmt.Sprintf(`SELECT %s FROM %s WHERE 1=1 %s %s LIMIT ?,?`, fields, m.TableName(), condition, order)
  92. err = o.Raw(sql, append(pars, startSize, pageSize)...).Find(&items).Error
  93. return
  94. }
  95. // ChartFrameworkNodeItem 图库框架节点信息
  96. type ChartFrameworkNodeItem struct {
  97. ChartFrameworkNodeId int
  98. ChartFrameworkId int `description:"框架ID"`
  99. FrameworkName string `description:"框架名称"`
  100. NodeId string `description:"节点ID"`
  101. NodeName string `description:"节点名称"`
  102. MyChartClassifyId int `description:"我的图表分类ID"`
  103. ChartNum int `description:"分类下的图表数"`
  104. CreateTime string `description:"创建时间"`
  105. }
  106. // FormatChartFrameworkNode2Item 格式化框架节点信息
  107. func FormatChartFrameworkNode2Item(origin *ChartFrameworkNode, chartNum int) (item *ChartFrameworkNodeItem) {
  108. if origin == nil {
  109. return
  110. }
  111. item = new(ChartFrameworkNodeItem)
  112. item.ChartFrameworkNodeId = origin.ChartFrameworkNodeId
  113. item.ChartFrameworkId = origin.ChartFrameworkId
  114. item.FrameworkName = origin.FrameworkName
  115. item.NodeId = origin.NodeId
  116. item.NodeName = origin.NodeName
  117. item.MyChartClassifyId = origin.MyChartClassifyId
  118. item.ChartNum = chartNum
  119. item.CreateTime = utils.TimeTransferString(utils.FormatDateTime, origin.CreateTime)
  120. return
  121. }