edb_info_delete_log.go 10 KB

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