edb_info_delete_log.go 7.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114
  1. package data_stat
  2. import (
  3. "eta_gn/eta_api/global"
  4. "github.com/rdlucklib/rdluck_tools/paging"
  5. )
  6. type EdbInfoDeleteLog struct {
  7. Id int `gorm:"primaryKey;unique;column:id;type:bigint(20) unsigned;not null"` // 自增id
  8. EdbInfoId int `gorm:"column:edb_info_id;type:int(11);not null"` // 指标id
  9. EdbInfoType int `gorm:"column:edb_info_type;type:tinyint(9) unsigned;not null;default:0"` // 指标类型,0:普通指标,1:预测指标
  10. SourceName string `gorm:"column:source_name;type:varchar(100)"` // 来源名称
  11. Source int `gorm:"column:source;type:tinyint(4)"` // 来源:1:同花顺,2:wind,3:彭博,4:指标运算,5:累计值转月,6:同比值,7:同差值,8:N数值移动平均计算,9:手工指标,10:隆众,11:有色,12:环比值,13:环差值,14:变频,15:钢联
  12. EdbCode string `gorm:"column:edb_code;type:varchar(255);not null;default:''"` // 指标编码
  13. EdbName string `gorm:"column:edb_name;type:varchar(255);default:''"` // 指标名称
  14. EdbNameSource string `gorm:"column:edb_name_source;type:varchar(255);default:''"` // 指标名称_来源
  15. Frequency string `gorm:"column:frequency;type:varchar(20);default:''"` // 频度
  16. Unit string `gorm:"column:unit;type:varchar(20);default:''"` // 单位
  17. StartDate string `gorm:"column:start_date;type:date"` // 更新开始日期
  18. EndDate string `gorm:"column:end_date;type:date"` // 更新结束日期
  19. SysUserId int `gorm:"column:sys_user_id;type:int(11)"` // 创建人
  20. SysUserRealName string `gorm:"column:sys_user_real_name;type:varchar(100)"` // 创建人姓名
  21. EdbCreateTime string `gorm:"column:edb_create_time;type:datetime"` // 指标创建时间
  22. EdbModifyTime string `gorm:"column:edb_modify_time;type:datetime"` // 指标修改时间
  23. UniqueCode string `gorm:"column:unique_code;type:varchar(50);default:''"` // 唯一编码
  24. MinValue float64 `gorm:"column:min_value;type:double;default:0"` // 最小值
  25. MaxValue float64 `gorm:"column:max_value;type:double;default:0"` // 最大值
  26. CalculateFormula string `gorm:"column:calculate_formula;type:varchar(255);default:''"` // 计算公式,N数值移动
  27. EdbType int `gorm:"column:edb_type;type:tinyint(4);default:1"` // 指标类型:1:基础指标,2:计算指标
  28. LatestDate string `gorm:"column:latest_date;type:date"` // 数据最新日期
  29. LatestValue float64 `gorm:"column:latest_value;type:double"` // 数据最新值
  30. MoveType int `gorm:"column:move_type;type:tinyint(4);default:1"` // 移动方式:1:领先(默认),2:滞后
  31. MoveFrequency string `gorm:"column:move_frequency;type:varchar(20);default:''"` // 移动频度
  32. NoUpdate int8 `gorm:"column:no_update;type:tinyint(4);default:0"` // 是否停止更新,0:继续更新;1:停止更新
  33. EdbNameEn string `gorm:"column:edb_name_en;type:varchar(255);default:''"` // 英文指标名称
  34. UnitEn string `gorm:"column:unit_en;type:varchar(20);default:''"` // 英文单位
  35. ChartImage string `gorm:"column:chart_image;type:varchar(255);default:''"` // 图表图片
  36. Calendar string `gorm:"column:calendar;type:varchar(16);default:公历"` // 公历/农历
  37. DataDateType string `gorm:"column:data_date_type;type:varchar(32);default:交易日"` // 数据日期类型,枚举值:交易日、自然日
  38. ManualSave int `gorm:"column:manual_save;type:tinyint(4);not null;default:0"` // 是否手动保存过上下限:0-否;1-是
  39. TerminalCode string `gorm:"column:terminal_code;type:varchar(255);default:''"` // 终端编码,用于配置在机器上
  40. CreateTime string `gorm:"index:create_time_idx;column:create_time;type:datetime"` // 创建时间
  41. DelSysUserId int `gorm:"column:del_sys_user_id;type:int(11);not null;default:0"` // 删除人
  42. DelSysUserRealName string `gorm:"column:del_sys_user_real_name;type:varchar(100);not null"` // 删除人姓名
  43. DataUpdateTime string `gorm:"column:data_update_time;type:datetime"` // 最近一次数据发生变化的时间
  44. ErDataUpdateDate string `gorm:"column:er_data_update_date;type:date"` // 本次更新,数据发生变化的最早日期
  45. }
  46. type EdbInfoDeleteLogItem struct {
  47. Id int `orm:"column(id);"`
  48. EdbInfoId int `description:"指标ID"`
  49. EdbInfoType int `description:"指标类型,0:普通指标,1:预测指标"`
  50. SourceName string `description:"来源名称"`
  51. Source int `description:"来源id"`
  52. EdbCode string `description:"指标编码"`
  53. EdbName string `description:"指标名称"`
  54. EdbNameEn string `description:"英文指标名称"`
  55. EdbNameSource string `description:"指标名称来源"`
  56. Frequency string `description:"频率"`
  57. Unit string `description:"单位"`
  58. StartDate string `description:"起始日期"`
  59. EndDate string `description:"终止日期"`
  60. SysUserId int `description:"创建人ID"`
  61. SysUserRealName string `description:"创建人姓名"`
  62. EdbCreateTime string `description:"指标创建时间"`
  63. CreateTime string `description:"创建时间即删除时间"`
  64. LatestDate string `description:"数据最新日期"`
  65. LatestValue float64 `description:"数据最新值"`
  66. TerminalCode string `description:"终端编码,用于配置在机器上"`
  67. DelSysUserId int `description:"删除人ID"`
  68. DelSysUserRealName string `description:"删除人姓名"`
  69. DataUpdateTime string `description:"最近一次数据发生变化的时间"`
  70. ErDataUpdateDate string `description:"本次更新,数据发生变化的最早日期"`
  71. }
  72. func AddEdbDeleteLog(item *EdbInfoDeleteLog) (lastId int64, err error) {
  73. err = global.DmSQL["data"].Create(item).Error
  74. lastId = int64(item.Id)
  75. return
  76. }
  77. type GetEdbDeleteLogResp struct {
  78. List []*EdbInfoDeleteLogItem
  79. Paging *paging.PagingItem
  80. }
  81. func GetEdbDeleteLogByCondition(condition string, pars []interface{}, orderStr string, pageSize, startSize int) (item []*EdbInfoDeleteLog, err error) {
  82. sql := ` SELECT * FROM edb_info_delete_log WHERE 1=1 `
  83. if condition != "" {
  84. sql += condition
  85. }
  86. if orderStr != "" {
  87. sql += orderStr
  88. } else {
  89. sql += ` ORDER BY create_time DESC, id DESC `
  90. }
  91. sql += ` LIMIT ?,? `
  92. pars = append(pars, startSize)
  93. pars = append(pars, pageSize)
  94. err = global.DmSQL["data"].Raw(sql, pars...).Find(&item).Error
  95. return
  96. }
  97. // GetEdbDeleteLogCount
  98. func GetEdbDeleteLogCount(condition string, pars []interface{}) (count int, err error) {
  99. sql := ` SELECT count(*) FROM edb_info_delete_log WHERE 1=1 `
  100. if condition != "" {
  101. sql += condition
  102. }
  103. err = global.DmSQL["data"].Raw(sql, pars...).Scan(&count).Error
  104. return
  105. }