edb_info_delete_log.go 10 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213
  1. package data_stat
  2. import (
  3. "eta/eta_api/utils"
  4. "github.com/beego/beego/v2/client/orm"
  5. "github.com/rdlucklib/rdluck_tools/paging"
  6. "time"
  7. )
  8. // EdbInfoDeleteLog 指标删除日志表
  9. type EdbInfoDeleteLog struct {
  10. Id uint64 `orm:"column(id);pk;auto"`
  11. EdbInfoId int `description:"指标ID"`
  12. EdbInfoType int `description:"指标类型,0:普通指标,1:预测指标"`
  13. SourceName string `description:"来源名称"`
  14. Source int `description:"来源id"`
  15. EdbCode string `description:"指标编码"`
  16. EdbName string `description:"指标名称"`
  17. EdbNameEn string `description:"英文指标名称"`
  18. EdbNameSource string `description:"指标名称来源"`
  19. Frequency string `description:"频率"`
  20. Unit string `description:"单位"`
  21. UnitEn string `description:"英文单位"`
  22. StartDate string `description:"起始日期"`
  23. EndDate string `description:"终止日期"`
  24. SysUserId int `description:"创建人ID"`
  25. SysUserRealName string `description:"创建人姓名"`
  26. UniqueCode string `description:"指标唯一编码"`
  27. EdbCreateTime string `description:"指标创建时间"`
  28. EdbModifyTime string `description:"指标修改时间"`
  29. CreateTime string `description:"创建时间即删除时间"`
  30. MinValue float64 `description:"指标最小值"`
  31. MaxValue float64 `description:"指标最大值"`
  32. CalculateFormula string `description:"计算公式"`
  33. EdbType int `description:"指标类型:1:基础指标,2:计算指标"`
  34. LatestDate string `description:"数据最新日期"`
  35. LatestValue float64 `description:"数据最新值"`
  36. MoveType int `description:"移动方式:1:领先(默认),2:滞后"`
  37. MoveFrequency string `description:"移动频度"`
  38. NoUpdate int8 `description:"是否停止更新,0:继续更新;1:停止更新"`
  39. ChartImage string `description:"图表图片"`
  40. Calendar string `description:"公历/农历" orm:"default(公历);"`
  41. DataDateType string `orm:"column(data_date_type);size(255);null;default(交易日)"`
  42. ManualSave int `description:"是否有手动保存过上下限: 0-否; 1-是"`
  43. TerminalCode string `description:"终端编码,用于配置在机器上"`
  44. DelSysUserId int `description:"删除人ID"`
  45. DelSysUserRealName string `description:"删除人姓名"`
  46. DataUpdateTime string `description:"最近一次数据发生变化的时间"`
  47. ErDataUpdateDate string `description:"本次更新,数据发生变化的最早日期"`
  48. }
  49. // [2025-zsh-时间类型修复-chenhan]
  50. type EdbInfoDeleteLogOrm struct {
  51. Id uint64 `orm:"column(id);pk;auto"`
  52. EdbInfoId int `description:"指标ID"`
  53. EdbInfoType int `description:"指标类型,0:普通指标,1:预测指标"`
  54. SourceName string `description:"来源名称"`
  55. Source int `description:"来源id"`
  56. EdbCode string `description:"指标编码"`
  57. EdbName string `description:"指标名称"`
  58. EdbNameEn string `description:"英文指标名称"`
  59. EdbNameSource string `description:"指标名称来源"`
  60. Frequency string `description:"频率"`
  61. Unit string `description:"单位"`
  62. UnitEn string `description:"英文单位"`
  63. StartDate time.Time `description:"起始日期"`
  64. EndDate time.Time `description:"终止日期"`
  65. SysUserId int `description:"创建人ID"`
  66. SysUserRealName string `description:"创建人姓名"`
  67. UniqueCode string `description:"指标唯一编码"`
  68. EdbCreateTime time.Time `description:"指标创建时间"`
  69. EdbModifyTime time.Time `description:"指标修改时间"`
  70. CreateTime time.Time `description:"创建时间即删除时间"`
  71. MinValue float64 `description:"指标最小值"`
  72. MaxValue float64 `description:"指标最大值"`
  73. CalculateFormula string `description:"计算公式"`
  74. EdbType int `description:"指标类型:1:基础指标,2:计算指标"`
  75. LatestDate time.Time `description:"数据最新日期"`
  76. LatestValue float64 `description:"数据最新值"`
  77. MoveType int `description:"移动方式:1:领先(默认),2:滞后"`
  78. MoveFrequency string `description:"移动频度"`
  79. NoUpdate int8 `description:"是否停止更新,0:继续更新;1:停止更新"`
  80. ChartImage string `description:"图表图片"`
  81. Calendar string `description:"公历/农历" orm:"default(公历);"`
  82. DataDateType string `orm:"column(data_date_type);size(255);null;default(交易日)"`
  83. ManualSave int `description:"是否有手动保存过上下限: 0-否; 1-是"`
  84. TerminalCode string `description:"终端编码,用于配置在机器上"`
  85. DelSysUserId int `description:"删除人ID"`
  86. DelSysUserRealName string `description:"删除人姓名"`
  87. DataUpdateTime time.Time `description:"最近一次数据发生变化的时间"`
  88. ErDataUpdateDate time.Time `description:"本次更新,数据发生变化的最早日期"`
  89. }
  90. func (edblogorm *EdbInfoDeleteLogOrm) toView() *EdbInfoDeleteLog {
  91. return &EdbInfoDeleteLog{
  92. Id: edblogorm.Id,
  93. EdbInfoId: edblogorm.EdbInfoId,
  94. EdbInfoType: edblogorm.EdbInfoType,
  95. SourceName: edblogorm.SourceName,
  96. Source: edblogorm.Source,
  97. EdbCode: edblogorm.EdbCode,
  98. EdbName: edblogorm.EdbName,
  99. EdbNameEn: edblogorm.EdbNameEn,
  100. EdbNameSource: edblogorm.EdbNameSource,
  101. Frequency: edblogorm.Frequency,
  102. Unit: edblogorm.Unit,
  103. UnitEn: edblogorm.UnitEn,
  104. StartDate: edblogorm.StartDate.Format(utils.FormatDate),
  105. EndDate: edblogorm.EndDate.Format(utils.FormatDate),
  106. SysUserId: edblogorm.SysUserId,
  107. SysUserRealName: edblogorm.SysUserRealName,
  108. UniqueCode: edblogorm.UniqueCode,
  109. EdbCreateTime: edblogorm.EdbCreateTime.Format(utils.FormatDateTime),
  110. EdbModifyTime: edblogorm.EdbModifyTime.Format(utils.FormatDateTime),
  111. CreateTime: edblogorm.CreateTime.Format(utils.FormatDateTime),
  112. MinValue: edblogorm.MinValue,
  113. MaxValue: edblogorm.MaxValue,
  114. CalculateFormula: edblogorm.CalculateFormula,
  115. EdbType: edblogorm.EdbType,
  116. LatestDate: edblogorm.LatestDate.Format(utils.FormatDate),
  117. LatestValue: edblogorm.LatestValue,
  118. MoveType: edblogorm.MoveType,
  119. MoveFrequency: edblogorm.MoveFrequency,
  120. NoUpdate: edblogorm.NoUpdate,
  121. ChartImage: edblogorm.ChartImage,
  122. Calendar: edblogorm.Calendar,
  123. DataDateType: edblogorm.DataDateType,
  124. ManualSave: edblogorm.ManualSave,
  125. TerminalCode: edblogorm.TerminalCode,
  126. DelSysUserId: edblogorm.DelSysUserId,
  127. DelSysUserRealName: edblogorm.DelSysUserRealName,
  128. DataUpdateTime: edblogorm.DataUpdateTime.Format(utils.FormatDateTime),
  129. ErDataUpdateDate: edblogorm.ErDataUpdateDate.Format(utils.FormatDate),
  130. }
  131. }
  132. func toEdbInfoDeleteLogList(edblogOrmList []*EdbInfoDeleteLogOrm) (logList []*EdbInfoDeleteLog) {
  133. for _, edblogOrm := range edblogOrmList {
  134. logList = append(logList, edblogOrm.toView())
  135. }
  136. return
  137. }
  138. type EdbInfoDeleteLogItem struct {
  139. Id uint64 `orm:"column(id);"`
  140. EdbInfoId int `description:"指标ID"`
  141. EdbInfoType int `description:"指标类型,0:普通指标,1:预测指标"`
  142. SourceName string `description:"来源名称"`
  143. Source int `description:"来源id"`
  144. EdbCode string `description:"指标编码"`
  145. EdbName string `description:"指标名称"`
  146. EdbNameEn string `description:"英文指标名称"`
  147. EdbNameSource string `description:"指标名称来源"`
  148. Frequency string `description:"频率"`
  149. Unit string `description:"单位"`
  150. StartDate string `description:"起始日期"`
  151. EndDate string `description:"终止日期"`
  152. SysUserId int `description:"创建人ID"`
  153. SysUserRealName string `description:"创建人姓名"`
  154. EdbCreateTime string `description:"指标创建时间"`
  155. CreateTime string `description:"创建时间即删除时间"`
  156. LatestDate string `description:"数据最新日期"`
  157. LatestValue float64 `description:"数据最新值"`
  158. TerminalCode string `description:"终端编码,用于配置在机器上"`
  159. DelSysUserId int `description:"删除人ID"`
  160. DelSysUserRealName string `description:"删除人姓名"`
  161. DataUpdateTime string `description:"最近一次数据发生变化的时间"`
  162. ErDataUpdateDate string `description:"本次更新,数据发生变化的最早日期"`
  163. }
  164. func AddEdbDeleteLog(item *EdbInfoDeleteLog) (lastId int64, err error) {
  165. o := orm.NewOrmUsingDB("data")
  166. lastId, err = o.Insert(item)
  167. return
  168. }
  169. type GetEdbDeleteLogResp struct {
  170. List []*EdbInfoDeleteLogItem
  171. Paging *paging.PagingItem
  172. }
  173. func GetEdbDeleteLogByCondition(condition string, pars []interface{}, orderStr string, pageSize, startSize int) (item []*EdbInfoDeleteLog, err error) {
  174. o := orm.NewOrmUsingDB("data")
  175. sql := ` SELECT * FROM edb_info_delete_log WHERE 1=1 `
  176. if condition != "" {
  177. sql += condition
  178. }
  179. if orderStr != "" {
  180. sql += orderStr
  181. } else {
  182. sql += ` ORDER BY create_time DESC, id DESC `
  183. }
  184. sql += ` LIMIT ?,? `
  185. // [2025-zsh-时间类型修复-chenhan]
  186. var ormItems []*EdbInfoDeleteLogOrm
  187. _, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&ormItems)
  188. if err != nil {
  189. return
  190. }
  191. item = toEdbInfoDeleteLogList(ormItems)
  192. return
  193. }
  194. // GetEdbDeleteLogCount
  195. func GetEdbDeleteLogCount(condition string, pars []interface{}) (count int, err error) {
  196. o := orm.NewOrmUsingDB("data")
  197. sql := ` SELECT count(*) FROM edb_info_delete_log WHERE 1=1 `
  198. if condition != "" {
  199. sql += condition
  200. }
  201. err = o.Raw(sql, pars).QueryRow(&count)
  202. return
  203. }