edb_info_calculate.go 23 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545
  1. package data_manage
  2. import (
  3. "eta/eta_api/global"
  4. "eta/eta_api/utils"
  5. "fmt"
  6. "strings"
  7. "time"
  8. "github.com/rdlucklib/rdluck_tools/paging"
  9. )
  10. type EdbInfoCalculateSaveReq struct {
  11. EdbName string `description:"指标名称"`
  12. Frequency string `description:"频率"`
  13. Unit string `description:"单位"`
  14. ClassifyId int `description:"分类id"`
  15. CalculateFormula string `description:"计算公式"`
  16. Calendar string `description:"公历/农历"`
  17. EmptyType int `description:"空值处理类型(0查找前后35天,1不计算,2前值填充,3后值填充,4等于0)"`
  18. MaxEmptyType int `description:"MAX、MIN公式空值处理类型(1、等于0;2、跳过空值)"`
  19. Extra string `description:"指标的额外配置"`
  20. EdbInfoIdArr []EdbInfoFromTag `description:"指标信息"`
  21. }
  22. // EdbInfoFromTag 计算指标的关联指标
  23. type EdbInfoFromTag struct {
  24. EdbInfoId int `description:"指标id"`
  25. FromTag string `description:"指标对应标签"`
  26. MoveValue int `description:"移动的值"`
  27. }
  28. type EdbInfoCalculate struct {
  29. EdbInfoCalculateId int `orm:"column(edb_info_calculate_id);pk" gorm:"primaryKey"`
  30. EdbInfoId int `description:"指标id"`
  31. EdbCode string `description:"指标编码"`
  32. FromEdbInfoId int `description:"计算指标id"`
  33. FromEdbCode string `description:"计算指标编码"`
  34. FromEdbName string `description:"计算指标名称"`
  35. FromSource int `description:"计算指标来源"`
  36. FromSourceName string `description:"计算指标来源名称"`
  37. FromTag string `description:"来源指标标签"`
  38. Sort int `description:"计算指标名称排序"`
  39. CreateTime time.Time `description:"创建时间"`
  40. ModifyTime time.Time `description:"修改时间"`
  41. }
  42. func AddEdbInfoCalculateMulti(items []*EdbInfoCalculate) (err error) {
  43. o := global.DbMap[utils.DbNameIndex]
  44. err = o.CreateInBatches(items, utils.MultiAddNum).Error
  45. return
  46. }
  47. type FromEdbInfoData struct {
  48. EdbInfoId int `description:"指标id"`
  49. EdbName string `description:"指标名称"`
  50. DataList []*EdbInfoSearchData
  51. }
  52. type EdbInfoCalculateDetail struct {
  53. EdbInfoCalculateId int `orm:"column(edb_info_calculate_id);pk" gorm:"primaryKey"`
  54. EdbInfoId int `description:"指标id"`
  55. EdbCode string `description:"指标编码"`
  56. FromEdbInfoId int `description:"计算指标id"`
  57. FromEdbCode string `description:"计算指标编码"`
  58. FromEdbName string `description:"计算指标名称"`
  59. FromEdbNameEn string `description:"计算指标名称"`
  60. FromSource int `description:"计算指标来源"`
  61. FromSourceName string `description:"计算指标来源名称"`
  62. FromTag string `description:"来源指标标签"`
  63. MoveValue int `description:"移动的值,小于0是提前,0是不变,大于0是滞后"`
  64. Sort int `description:"计算指标名称排序"`
  65. CreateTime time.Time `description:"创建时间"`
  66. ModifyTime time.Time `description:"修改时间"`
  67. StartDate string `description:"开始日期"`
  68. EndDate string `description:"结束日期"`
  69. LatestDate string `description:"实际的结束日期"`
  70. LatestValue float64 `description:"最近实际数据的值"`
  71. EndValue float64 `description:"结束日期的值(可能是插入值)"`
  72. EdbType int `description:"指标类型:1:基础指标,2:计算指标"`
  73. Frequency string `description:"频率"`
  74. Unit string `description:"单位"`
  75. ClassifyId int `description:"分类id"`
  76. }
  77. func GetEdbInfoCalculateDetail(edbInfoId, source int) (list []*EdbInfoCalculateDetail, err error) {
  78. o := global.DbMap[utils.DbNameIndex]
  79. //calculateTableName := GetEdbInfoCalculateTableName(source)
  80. //sql := ` SELECT a.*,b.start_date,b.end_date,b.edb_type FROM %s AS a
  81. // INNER JOIN edb_info AS b ON a.from_edb_info_id=b.edb_info_id
  82. // WHERE a.edb_info_id=? ORDER BY sort ASC `
  83. //
  84. //sql = fmt.Sprintf(sql, calculateTableName)
  85. sql := ` SELECT a.edb_info_calculate_mapping_id,a.edb_info_id,a.source,a.source_name,a.edb_code,a.from_edb_info_id,a.from_edb_code,a.from_source,a.from_source_name,a.sort,a.create_time,a.modify_time,a.from_tag,a.move_value,b.edb_name as from_edb_name,b.edb_name_en as from_edb_name_en,b.start_date,b.end_date,b.latest_date,b.latest_value,b.edb_type, b.frequency, b.unit, b.classify_id FROM edb_info_calculate_mapping AS a
  86. INNER JOIN edb_info AS b ON a.from_edb_info_id=b.edb_info_id
  87. WHERE a.edb_info_id=? ORDER BY sort ASC `
  88. err = o.Raw(sql, edbInfoId).Find(&list).Error
  89. return
  90. }
  91. type CalculateDetailResp struct {
  92. EdbInfoDetail *EdbInfoFullClassify
  93. CalculateList []*EdbInfoCalculateDetail
  94. }
  95. type EdbInfoCalculateEditReq struct {
  96. EdbInfoId int `description:"指标id"`
  97. EdbName string `description:"指标名称"`
  98. Frequency string `description:"频率"`
  99. Unit string `description:"单位"`
  100. ClassifyId int `description:"分类id"`
  101. CalculateFormula string `description:"计算公式"`
  102. EmptyType int `description:"空值处理类型(0查找前后35天,1不计算,2前值填充,3后值填充,4等于0)"`
  103. MaxEmptyType int `description:"MAX、MIN公式空值处理类型(1、等于0;2、跳过空值)"`
  104. Extra string `description:"指标的额外配置"`
  105. EdbInfoIdArr []EdbInfoFromTag `description:"指标信息"`
  106. }
  107. func GetCalculateEdbInfo(edbInfoId int) (from_edb_info_id string, err error) {
  108. o := global.DbMap[utils.DbNameIndex]
  109. sql := ` SELECT GROUP_CONCAT(from_edb_info_id ORDER BY sort ASC SEPARATOR ',') AS from_edb_info_id
  110. FROM edb_info_calculate_mapping
  111. WHERE edb_info_id=?
  112. GROUP BY edb_info_id
  113. `
  114. err = o.Raw(sql, edbInfoId).Scan(&from_edb_info_id).Error
  115. return
  116. }
  117. func DeleteCalculateEdbInfo(edbInfoId int) (err error) {
  118. o := global.DbMap[utils.DbNameIndex]
  119. to := o.Begin()
  120. if to.Error != nil {
  121. return to.Error
  122. }
  123. defer func() {
  124. if err != nil {
  125. _ = to.Rollback()
  126. } else {
  127. _ = to.Commit()
  128. }
  129. }()
  130. sql := `DELETE FROM edb_data_calculate WHERE edb_info_id=?`
  131. err = to.Exec(sql, edbInfoId).Error
  132. if err != nil {
  133. return
  134. }
  135. sql = `DELETE FROM edb_info_calculate_mapping WHERE edb_info_id=?`
  136. err = to.Exec(sql, edbInfoId).Error
  137. return
  138. }
  139. func DeleteCalculateData(edbInfoId int) (err error) {
  140. o := global.DbMap[utils.DbNameIndex]
  141. sql := `DELETE FROM edb_data_calculate WHERE edb_info_id=?`
  142. err = o.Exec(sql, edbInfoId).Error
  143. return
  144. }
  145. type EdbInfoBase struct {
  146. EdbInfoId int `description:"指标id"`
  147. EdbName string `description:"指标名称"`
  148. EdbNameEn string `description:"英文指标名称"`
  149. Frequency string `description:"频度"`
  150. Unit string `description:"单位"`
  151. UnitEn string `description:"英文单位"`
  152. ClassifyId int `description:"分类id"`
  153. HaveOperaAuth bool `description:"是否有数据权限,默认:false"`
  154. EdbInfoType int `description:"指标类型: 0-普通指标; 1-预测指标"`
  155. }
  156. type CalculateEdbInfoItem struct {
  157. EdbInfoId int `description:"指标id"`
  158. EdbName string `description:"指标名称"`
  159. Frequency string `description:"频度"`
  160. Unit string `description:"单位"`
  161. ClassifyId int `description:"分类id"`
  162. CalculateId string `description:"当前请求时,单个计算的唯一标识"`
  163. FromEdbInfoId int `description:"计算来源指标id"`
  164. }
  165. type EdbInfoCalculateBatchSaveMultiReq struct {
  166. List []CalculateEdbInfoItem
  167. Formula string `description:"N值/移动天数"`
  168. FromEdbInfoId int `description:"计算来源指标id"`
  169. Source int `description:"来源:1:同花顺,2:wind,3:彭博,4:指标运算,5:累计值转月,6:同比值,7:同差值,8:N数值移动平均计算,12:环比值,13:环差值,14:变频"`
  170. CalculateFormula string `description:"计算公式"`
  171. EdbInfoIdArr []EdbInfoFromTag `description:"指标信息"`
  172. MoveType int `description:"移动方式:1:领先(默认),2:滞后"`
  173. MoveFrequency string `description:"移动频度:天/周/月/季/年"`
  174. Extra string `description:"指标的额外配置"`
  175. Calendar string `description:"公历/农历"`
  176. }
  177. type EdbInfoCalculateBatchSaveReq struct {
  178. EdbInfoId int `description:"指标id"`
  179. EdbName string `description:"指标名称"`
  180. Frequency string `description:"频度"`
  181. Unit string `description:"单位"`
  182. ClassifyId int `description:"分类id"`
  183. Formula string `description:"N值/移动天数"`
  184. FromEdbInfoId int `description:"计算来源指标id"`
  185. Source int `description:"来源:1:同花顺,2:wind,3:彭博,4:指标运算,5:累计值转月,6:同比值,7:同差值,8:N数值移动平均计算,12:环比值,13:环差值,14:变频"`
  186. CalculateFormula string `description:"计算公式"`
  187. EdbInfoIdArr []EdbInfoFromTag `description:"指标信息"`
  188. MoveType int `description:"移动方式:1:领先(默认),2:滞后"`
  189. MoveFrequency string `description:"移动频度:天/周/月/季/年"`
  190. Extra string `description:"指标的额外配置"`
  191. Calendar string `description:"公历/农历"`
  192. EmptyType int `description:"空值处理类型(0查找前后35天,1不计算,2前值填充,3后值填充,4等于0)"`
  193. }
  194. type EdbInfoCalculateBatchEditReq struct {
  195. EdbName string `description:"指标名称"`
  196. Frequency string `description:"频度"`
  197. Unit string `description:"单位"`
  198. ClassifyId int `description:"分类id"`
  199. Formula string `description:"N值"`
  200. EdbInfoId int `description:"编辑指标id"`
  201. FromEdbInfoId int `description:"计算来源指标id"`
  202. Source int `description:"来源:1:同花顺,2:wind,3:彭博,4:指标运算,5:累计值转月,6:同比值,7:同差值,8:N数值移动平均计算,12:环比值,13:环差值,14:变频"`
  203. MoveType int `description:"移动方式:1:领先(默认),2:滞后"`
  204. MoveFrequency string `description:"移动频度:天/周/月/季/年"`
  205. Calendar string `description:"公历/农历"`
  206. Extra string `description:"指标的额外配置"`
  207. EdbInfoIdArr []EdbInfoFromTag
  208. EmptyType int `description:"空值处理类型(0查找前后35天,1不计算,2前值填充,3后值填充,4等于0)"`
  209. }
  210. // EdbInfoCalculateBatchSaveReqByEdbLib edb指标库的请求逻辑
  211. type EdbInfoCalculateBatchSaveReqByEdbLib struct {
  212. AdminId int `description:"添加人id"`
  213. AdminName string `description:"添加人名称"`
  214. EdbInfoId int `description:"指标id"`
  215. EdbName string `description:"指标名称"`
  216. Frequency string `description:"频度"`
  217. Unit string `description:"单位"`
  218. ClassifyId int `description:"分类id"`
  219. Formula string `description:"N值/移动天数"`
  220. FromEdbInfoId int `description:"计算来源指标id"`
  221. Source int `description:"来源:1:同花顺,2:wind,3:彭博,4:指标运算,5:累计值转月,6:同比值,7:同差值,8:N数值移动平均计算,12:环比值,13:环差值,14:变频"`
  222. CalculateFormula string `description:"计算公式"`
  223. EdbInfoIdArr []EdbInfoFromTag `description:"指标信息"`
  224. MoveType int `description:"移动方式:1:领先(默认),2:滞后"`
  225. MoveFrequency string `description:"移动频度:天/周/月/季/年"`
  226. Calendar string `description:"公历/农历"`
  227. Data interface{} `description:"数据列"`
  228. EmptyType int `description:"空值处理类型(0查找前后35天,1不计算,2前值填充,3后值填充,4等于0)"`
  229. MaxEmptyType int `description:"MAX、MIN公式空值处理类型(1、等于0;2、跳过空值)"`
  230. Extra string `description:"指标的额外配置"`
  231. }
  232. // EdbInfoCalculateBatchEditReqByEdbLib 编辑计算指标的请求参数
  233. type EdbInfoCalculateBatchEditReqByEdbLib struct {
  234. EdbName string `description:"指标名称"`
  235. Frequency string `description:"频度"`
  236. Unit string `description:"单位"`
  237. ClassifyId int `description:"分类id"`
  238. AdminId int `description:"操作人id"`
  239. AdminName string `description:"操作人姓名"`
  240. Formula string `description:"N值"`
  241. EdbInfoId int `description:"编辑指标id"`
  242. FromEdbInfoId int `description:"计算来源指标id"`
  243. Source int `description:"来源:1:同花顺,2:wind,3:彭博,4:指标运算,5:累计值转月,6:同比值,7:同差值,8:N数值移动平均计算,12:环比值,13:环差值,14:变频"`
  244. MoveType int `description:"移动方式:1:领先(默认),2:滞后"`
  245. MoveFrequency string `description:"移动频度:天/周/月/季/年"`
  246. Calendar string `description:"公历/农历"`
  247. EdbInfoIdArr []EdbInfoFromTag
  248. Data interface{} `description:"数据列"`
  249. Extra string `description:"指标的额外配置"`
  250. EmptyType int `description:"空值处理类型(0查找前后35天,1不计算,2前值填充,3后值填充,4等于0)"`
  251. CalculateFormula string `description:"计算公式"`
  252. }
  253. func GetEdbInfoCalculateMap(edbInfoId, source int) (list []*EdbInfo, err error) {
  254. o := global.DbMap[utils.DbNameIndex]
  255. //calculateTableName := GetEdbInfoCalculateTableName(source)
  256. //sql := ` SELECT b.* FROM %s AS a
  257. // INNER JOIN edb_info AS b ON a.from_edb_info_id=b.edb_info_id
  258. // WHERE a.edb_info_id=? ORDER BY sort ASC `
  259. //sql = fmt.Sprintf(sql, calculateTableName)
  260. sql := ` SELECT b.* FROM edb_info_calculate_mapping AS a
  261. INNER JOIN edb_info AS b ON a.from_edb_info_id=b.edb_info_id
  262. WHERE a.edb_info_id=? ORDER BY sort ASC `
  263. err = o.Raw(sql, edbInfoId).Find(&list).Error
  264. return
  265. }
  266. type CalculateItems struct {
  267. EdbInfoId int
  268. DataMap map[string]float64
  269. }
  270. func CheckFormula(formula string) map[string]string {
  271. mathFormula := []string{"MAX", "MIN", "ABS", "ACOS", "ASIN", "CEIL", "MOD", "POW", "ROUND", "SIGN", "SIN", "TAN", "LOG10", "LOG2", "LOG", "LN"}
  272. str := strings.ToUpper(formula)
  273. for _, v := range mathFormula {
  274. str = strings.Replace(str, v, "", -1)
  275. }
  276. str = strings.Replace(str, "(", "", -1)
  277. str = strings.Replace(str, ")", "", -1)
  278. byteMap := make(map[string]string)
  279. for i := 0; i < len(str); i++ {
  280. byteInt := str[i]
  281. if byteInt >= 65 && byteInt <= 90 {
  282. byteStr := string(byteInt)
  283. if _, ok := byteMap[byteStr]; !ok {
  284. byteMap[byteStr] = byteStr
  285. }
  286. }
  287. }
  288. return byteMap
  289. }
  290. func ReplaceFormula(edbInfoIdArr []*EdbInfo, valArr map[int]float64, formulaMap map[string]string, formulaStr string, edbInfoIdBytes []string) string {
  291. funMap := GetFormulaMap()
  292. for k, v := range funMap {
  293. formulaStr = strings.Replace(formulaStr, k, v, -1)
  294. }
  295. replaceCount := 0
  296. for dk, dv := range edbInfoIdArr {
  297. if dk == 0 {
  298. dKey := edbInfoIdBytes[dk]
  299. if _, ok := formulaMap[dKey]; ok { //公式中存在
  300. if val, valOk := valArr[dv.EdbInfoId]; valOk { //值存在
  301. dvStr := fmt.Sprintf("%v", val)
  302. formulaStr = strings.Replace(formulaStr, dKey, dvStr, -1)
  303. replaceCount++
  304. }
  305. }
  306. }
  307. if dk == 1 {
  308. dKey := edbInfoIdBytes[dk]
  309. if _, ok := formulaMap[dKey]; ok { //公式中存在
  310. if val, valOk := valArr[dv.EdbInfoId]; valOk { //值存在
  311. dvStr := fmt.Sprintf("%v", val)
  312. formulaStr = strings.Replace(formulaStr, dKey, dvStr, -1)
  313. replaceCount++
  314. }
  315. }
  316. }
  317. if dk == 2 {
  318. dKey := edbInfoIdBytes[dk]
  319. if _, ok := formulaMap[dKey]; ok { //公式中存在
  320. if val, valOk := valArr[dv.EdbInfoId]; valOk { //值存在
  321. dvStr := fmt.Sprintf("%v", val)
  322. formulaStr = strings.Replace(formulaStr, dKey, dvStr, -1)
  323. replaceCount++
  324. }
  325. }
  326. }
  327. if dk == 3 {
  328. dKey := edbInfoIdBytes[dk]
  329. if _, ok := formulaMap[dKey]; ok { //公式中存在
  330. if val, valOk := valArr[dv.EdbInfoId]; valOk { //值存在
  331. dvStr := fmt.Sprintf("%v", val)
  332. formulaStr = strings.Replace(formulaStr, dKey, dvStr, -1)
  333. replaceCount++
  334. }
  335. }
  336. }
  337. if dk == 4 {
  338. dKey := edbInfoIdBytes[dk]
  339. if _, ok := formulaMap[dKey]; ok { //公式中存在
  340. if val, valOk := valArr[dv.EdbInfoId]; valOk { //值存在
  341. dvStr := fmt.Sprintf("%v", val)
  342. formulaStr = strings.Replace(formulaStr, dKey, dvStr, -1)
  343. replaceCount++
  344. }
  345. }
  346. }
  347. if dk == 5 {
  348. dKey := edbInfoIdBytes[dk]
  349. if _, ok := formulaMap[dKey]; ok { //公式中存在
  350. if val, valOk := valArr[dv.EdbInfoId]; valOk { //值存在
  351. dvStr := fmt.Sprintf("%v", val)
  352. formulaStr = strings.Replace(formulaStr, dKey, dvStr, -1)
  353. replaceCount++
  354. }
  355. }
  356. }
  357. if dk == 6 {
  358. dKey := edbInfoIdBytes[dk]
  359. if _, ok := formulaMap[dKey]; ok { //公式中存在
  360. if val, valOk := valArr[dv.EdbInfoId]; valOk { //值存在
  361. dvStr := fmt.Sprintf("%v", val)
  362. formulaStr = strings.Replace(formulaStr, dKey, dvStr, -1)
  363. replaceCount++
  364. }
  365. }
  366. }
  367. if dk == 7 {
  368. dKey := edbInfoIdBytes[dk]
  369. if _, ok := formulaMap[dKey]; ok { //公式中存在
  370. if val, valOk := valArr[dv.EdbInfoId]; valOk { //值存在
  371. dvStr := fmt.Sprintf("%v", val)
  372. formulaStr = strings.Replace(formulaStr, dKey, dvStr, -1)
  373. replaceCount++
  374. }
  375. }
  376. }
  377. if dk == 8 {
  378. dKey := edbInfoIdBytes[dk]
  379. if _, ok := formulaMap[dKey]; ok { //公式中存在
  380. if val, valOk := valArr[dv.EdbInfoId]; valOk { //值存在
  381. dvStr := fmt.Sprintf("%v", val)
  382. formulaStr = strings.Replace(formulaStr, dKey, dvStr, -1)
  383. replaceCount++
  384. }
  385. }
  386. }
  387. }
  388. for k, v := range funMap {
  389. formulaStr = strings.Replace(formulaStr, v, k, -1)
  390. }
  391. if replaceCount == len(formulaMap) {
  392. return formulaStr
  393. } else {
  394. return ""
  395. }
  396. }
  397. func GetFormulaMap() map[string]string {
  398. funMap := make(map[string]string)
  399. funMap["MAX"] = "[@@]"
  400. funMap["MIN"] = "[@!]"
  401. funMap["ABS"] = "[@#]"
  402. funMap["CEIL"] = "[@$]"
  403. funMap["COS"] = "[@%]"
  404. funMap["FLOOR"] = "[@^]"
  405. funMap["MOD"] = "[@&]"
  406. funMap["POW"] = "[@*]"
  407. funMap["ROUND"] = "[@(]"
  408. return funMap
  409. }
  410. // SaveAdjustEdbInfoReq 保存数据调整请求参数(请求指标服务)
  411. type SaveAdjustEdbInfoReq struct {
  412. AdminId int `description:"添加人id"`
  413. AdminName string `description:"添加人名称"`
  414. EdbInfoId int `description:"指标id"`
  415. FromEdbInfoId int `description:"来源指标id"`
  416. EdbName string `description:"指标名称"`
  417. Frequency string `description:"频度"`
  418. Unit string `description:"单位"`
  419. ClassifyId int `description:"分类id"`
  420. DataList []SaveAdjustEdbDataReq `description:"指标对应的数据值"`
  421. }
  422. // SaveAdjustEdbDataReq 保存数据调整请求的数据的参数
  423. type SaveAdjustEdbDataReq struct {
  424. Date string `description:"数据日期"`
  425. Value float64 `description:"数据值"`
  426. }
  427. // BatchEdbInfoCalculateBatchSaveReq 批量添加 计算指标
  428. type BatchEdbInfoCalculateBatchSaveReq struct {
  429. AdminId int `description:"添加人id"`
  430. AdminName string `description:"添加人名称"`
  431. EdbList []*CalculateEdbInfoItem //需要批量计算的指标列表
  432. Formula string `description:"N值/移动天数"`
  433. Source int `description:"来源:1:同花顺,2:wind,3:彭博,4:指标运算,5:累计值转月,6:同比值,7:同差值,8:N数值移动平均计算,12:环比值,13:环差值,14:升频"`
  434. CalculateFormula string `description:"计算公式"`
  435. EdbInfoIdArr []EdbInfoFromTag `description:"关联指标列表"`
  436. MoveType int `description:"移动方式:1:领先(默认),2:滞后"`
  437. MoveFrequency string `description:"移动频度:天/周/月/季/年"`
  438. Calendar string `description:"公历/农历"`
  439. Data interface{} `description:"数据"`
  440. EmptyType int `description:"空值处理类型(0查找前后35天,1不计算,2前值填充,3后值填充,4等于0)"`
  441. MaxEmptyType int `description:"MAX、MIN公式空值处理类型(1、等于0;2、跳过空值)"`
  442. Extra string `description:"指标的额外配置"`
  443. }
  444. // BatchEdbInfoCalculateBatchSaveResp 批量添加 计算指标 返回数据
  445. type BatchEdbInfoCalculateBatchSaveResp struct {
  446. Fail []BatchEdbInfoCalculateBatchSaveFailResp `description:"添加失败的指标"`
  447. Success []BatchEdbInfoCalculateBatchSaveSuccessResp `description:"添加成功的指标"`
  448. }
  449. // BatchEdbInfoCalculateBatchSaveFailResp 添加失败的指标信息
  450. type BatchEdbInfoCalculateBatchSaveFailResp struct {
  451. CalculateId string `description:"当前请求时,单个计算的唯一标识"`
  452. Msg string `description:"用户提示信息"`
  453. ErrMsg string `description:"错误信息,内部查看"`
  454. }
  455. // BatchEdbInfoCalculateBatchSaveSuccessResp 添加成功的指标信息
  456. type BatchEdbInfoCalculateBatchSaveSuccessResp struct {
  457. ClassifyId int `description:"分类id"`
  458. CalculateId string `description:"当前请求时,单个计算的唯一标识"`
  459. EdbInfoId int `description:"指标ID"`
  460. UniqueCode string `description:"指标唯一编码"`
  461. }
  462. // CalculateMultiSearchReq 批量计算模块下的指标搜索
  463. type CalculateMultiChoiceReq struct {
  464. ClassifyIds string `description:"分类ID, 用英文逗号拼接"`
  465. Frequency string `description:"频度"`
  466. SysUserIds string `description:"创建人ID,用英文逗号拼接"`
  467. Keyword string `description:"关键字"`
  468. SelectAll bool `description:"是否全选"`
  469. EdbInfoIds string `description:"指标Id, 用英文逗号拼接"`
  470. }
  471. type CalculateMultiChoiceResp struct {
  472. SearchItem []EdbInfoBase `description:"查询结果"`
  473. }
  474. type CalculateMultiEdbSearchResp struct {
  475. SearchItem []CalculateMultiEdbSearchItem `description:"查询结果"`
  476. Paging *paging.PagingItem
  477. }
  478. type CalculateMultiEdbSearchItem struct {
  479. EdbInfoId int `description:"指标id"`
  480. EdbName string `description:"指标名称"`
  481. EdbNameEn string `description:"英文指标名称"`
  482. Frequency string `description:"频度"`
  483. Unit string `description:"单位"`
  484. UnitEn string `description:"英文单位"`
  485. ClassifyId int `description:"分类id"`
  486. SysUserId int
  487. SysUserRealName string
  488. EndValue float64 `description:"数据的最新值(预测日期的最新值)"`
  489. EndDate string `description:"终止日期"`
  490. HaveOperaAuth bool `description:"是否有数据权限,默认:false"`
  491. EdbInfoType int `description:"指标类型: 0-普通指标; 1-预测指标"`
  492. }
  493. // BaseStepCalculateReq 指标库-基础分步骤计算请求
  494. type BaseStepCalculateReq struct {
  495. DataList []*EdbInfoSearchData
  496. Calculates []FactorEdbSeriesCalculatePars
  497. }