edb_data_from_python.go 2.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384
  1. package data_manage
  2. import (
  3. "eta/eta_api/global"
  4. "eta/eta_api/utils"
  5. "time"
  6. )
  7. // EdbDataPython python指标数据结构体
  8. type EdbDataPython struct {
  9. //EdbDataId int `orm:"column(edb_data_id);pk"`
  10. EdbDataId int `gorm:"column:edb_data_id;primaryKey"`
  11. EdbInfoId int
  12. EdbCode string
  13. DataTime string
  14. Value float64
  15. CreateTime time.Time
  16. ModifyTime time.Time
  17. DataTimestamp int64
  18. }
  19. // GetAllEdbDataPythonByEdbInfoId 根据指标id获取全部的数据
  20. func GetAllEdbDataPythonByEdbInfoId(edbInfoId int) (items []*EdbDataPython, err error) {
  21. //o := orm.NewOrmUsingDB("data")
  22. sql := ` SELECT * FROM edb_data_python WHERE edb_info_id=? ORDER BY data_time DESC `
  23. err = global.DbMap[utils.DbNameIndex].Raw(sql, edbInfoId).Find(&items).Error
  24. //_, err = o.Raw(sql, edbInfoId).QueryRows(&items)
  25. return
  26. }
  27. // EdbInfoPythonSaveReq 计算(运算)指标请求参数
  28. type EdbInfoPythonSaveReq struct {
  29. AdminId int `description:"添加人id"`
  30. AdminName string `description:"添加人名称"`
  31. EdbName string `description:"指标名称"`
  32. Frequency string `description:"频率"`
  33. Unit string `description:"单位"`
  34. ClassifyId int `description:"分类id"`
  35. CalculateFormula string `description:"计算公式"`
  36. EdbInfoIdArr []struct {
  37. EdbInfoId int `description:"指标id"`
  38. FromTag string `description:"指标对应标签"`
  39. }
  40. }
  41. // ExecPythonEdbReq 执行python代码运算指标的请求参数
  42. type ExecPythonEdbReq struct {
  43. PythonCode string `description:"python代码"`
  44. }
  45. // AddPythonEdbReq 添加python代码运算指标的请求参数
  46. type AddPythonEdbReq struct {
  47. EdbInfoId int `description:"指标id"`
  48. EdbName string `description:"指标名称"`
  49. Frequency string `description:"频度"`
  50. Unit string `description:"单位"`
  51. ClassifyId int `description:"分类id"`
  52. PythonCode string `description:"python代码"`
  53. }
  54. // PostAddPythonEdbReq 添加python代码运算指标的请求参数(请求指标服务)
  55. type PostAddPythonEdbReq struct {
  56. AdminId int `description:"添加人id"`
  57. AdminName string `description:"添加人名称"`
  58. EdbInfoId int `description:"指标id"`
  59. EdbName string `description:"指标名称"`
  60. Frequency string `description:"频度"`
  61. Unit string `description:"单位"`
  62. ClassifyId int `description:"分类id"`
  63. PythonCode string `description:"python代码"`
  64. }
  65. // PythonEdbDetailResp python指标详情接口
  66. type PythonEdbDetailResp struct {
  67. EdbInfoDetail *EdbInfo
  68. PythonCode string
  69. }
  70. // TableInfoResp 指标数据表结构
  71. type TableInfoResp struct {
  72. ColumnList []map[string]string
  73. TableName string
  74. TemplateStr string
  75. }