edb_info_calculate.go 24 KB

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