table_edb_mapping.go 2.2 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152
  1. package data_manage
  2. import (
  3. "github.com/rdlucklib/rdluck_tools/orm"
  4. "time"
  5. )
  6. // TableEdbMapping ETA表格指标关系表
  7. type TableEdbMapping struct {
  8. TableEdbMappingId int `orm:"column(table_edb_mapping_id);pk"`
  9. TableInfoId int `description:"表格id"`
  10. EdbInfoId int `description:"指标id"`
  11. UniqueCode string `description:"唯一编码"`
  12. EdbDataColIndex int `description:"指标数据对应的列,从1开始"`
  13. EndDate time.Time `description:"最后一次数据更新日期"`
  14. ModifyTime time.Time `description:"修改时间"`
  15. CreateTime time.Time `description:"创建时间"`
  16. }
  17. // TableEdbMappingItem ETA表格指标关系表
  18. type TableEdbMappingItem struct {
  19. TableEdbMappingId int ``
  20. TableInfoId int `description:"表格id"`
  21. EdbInfoId int `description:"指标id"`
  22. Source int `description:"指标来源"`
  23. UniqueCode string `description:"唯一编码"`
  24. EdbDataColIndex int `description:"指标数据对应的列,从1开始"`
  25. EndDate time.Time `description:"最后一次数据更新日期"`
  26. EdbDataEndDate time.Time `description:"指标数据更新结束日期"`
  27. ModifyTime time.Time `description:"修改时间"`
  28. CreateTime time.Time `description:"创建时间"`
  29. }
  30. // GetAllTableEdbMappingItemList 获取所有的 ETA表格指标关系列表数据
  31. func GetAllTableEdbMappingItemList() (items []*TableEdbMappingItem, err error) {
  32. o := orm.NewOrm()
  33. o.Using("data")
  34. sql := ` select a.*,b.source,b.end_date edb_data_end_date from table_edb_mapping a
  35. join edb_info b on a.edb_info_id=b.edb_info_id `
  36. _, err = o.Raw(sql).QueryRows(&items)
  37. return
  38. }
  39. // GetAllTableEdbMappingItemListByTableInfoId 根据表格id获取ETA表格所有的指标关系列表数据
  40. func GetAllTableEdbMappingItemListByTableInfoId(tableInfoId int) (items []*TableEdbMappingItem, err error) {
  41. o := orm.NewOrm()
  42. o.Using("data")
  43. sql := ` select a.*,b.source,b.end_date edb_data_end_date from table_edb_mapping a
  44. join edb_info b on a.edb_info_id=b.edb_info_id where a.table_info_id = ?`
  45. _, err = o.Raw(sql, tableInfoId).QueryRows(&items)
  46. return
  47. }