edb_info.go 66 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858
  1. package data_manage
  2. import (
  3. "eta/eta_api/services/alarm_msg"
  4. "eta/eta_api/utils"
  5. "fmt"
  6. "github.com/beego/beego/v2/client/orm"
  7. "github.com/rdlucklib/rdluck_tools/paging"
  8. "strconv"
  9. "strings"
  10. "time"
  11. )
  12. type EdbInfo struct {
  13. EdbInfoId int `orm:"column(edb_info_id);pk"`
  14. EdbInfoType int `description:"指标类型,0:普通指标,1:预测指标"`
  15. SourceName string `description:"来源名称"`
  16. Source int `description:"来源id"`
  17. EdbCode string `description:"指标编码"`
  18. EdbName string `description:"指标名称"`
  19. EdbNameEn string `description:"英文指标名称"`
  20. EdbNameSource string `description:"指标名称来源"`
  21. Frequency string `description:"频率"`
  22. Unit string `description:"单位"`
  23. UnitEn string `description:"英文单位"`
  24. StartDate string `description:"起始日期"`
  25. EndDate string `description:"终止日期"`
  26. ClassifyId int `description:"分类id"`
  27. SysUserId int
  28. SysUserRealName string
  29. UniqueCode string `description:"指标唯一编码"`
  30. CreateTime time.Time
  31. ModifyTime time.Time
  32. MinValue float64 `description:"指标最小值"`
  33. MaxValue float64 `description:"指标最大值"`
  34. CalculateFormula string `description:"计算公式"`
  35. EdbType int `description:"指标类型:1:基础指标,2:计算指标"`
  36. Sort int `description:"排序字段"`
  37. LatestDate string `description:"数据最新日期"`
  38. LatestValue float64 `description:"数据最新值"`
  39. MoveType int `description:"移动方式:1:领先(默认),2:滞后"`
  40. MoveFrequency string `description:"移动频度"`
  41. NoUpdate int8 `description:"是否停止更新,0:继续更新;1:停止更新"`
  42. ServerUrl string `description:"服务器地址"`
  43. ChartImage string `description:"图表图片"`
  44. Calendar string `description:"公历/农历" orm:"default(公历);"`
  45. DataDateType string `orm:"column(data_date_type);size(255);null;default(交易日)"`
  46. ManualSave int `description:"是否有手动保存过上下限: 0-否; 1-是"`
  47. }
  48. type EdbInfoFullClassify struct {
  49. *EdbInfo
  50. CorrelationStr string `description:"相关性系数字符串"`
  51. ClassifyList []*EdbClassifyIdItems
  52. }
  53. func AddEdbInfo(item *EdbInfo) (lastId int64, err error) {
  54. o := orm.NewOrmUsingDB("data")
  55. lastId, err = o.Insert(item)
  56. return
  57. }
  58. type EdbInfoItem struct {
  59. EdbInfoId int `description:"指标id"`
  60. EdbName string `description:"指标名称"`
  61. ClassifyId int `description:"指标分类"`
  62. }
  63. // GetEdbInfoAll 用于分类展示
  64. func GetEdbInfoAll(edbInfoType uint8) (items []*EdbClassifyItems, err error) {
  65. o := orm.NewOrmUsingDB("data")
  66. sql := ` SELECT edb_info_id,classify_id,edb_name_source AS classify_name,edb_name_en AS classify_name_en,unique_code,source_name,source,sys_user_id,sys_user_real_name,start_date,edb_code,edb_type FROM edb_info WHERE edb_info_type = ? order by sort asc,edb_info_id asc`
  67. _, err = o.Raw(sql, edbInfoType).QueryRows(&items)
  68. return
  69. }
  70. // GetPredictEdbInfoAll 用于分类展示(预测指标)
  71. func GetPredictEdbInfoAll(edbInfoType uint8) (items []*EdbClassifyItems, err error) {
  72. o := orm.NewOrmUsingDB("data")
  73. sql := ` SELECT edb_info_id,classify_id,edb_name AS classify_name,edb_name_en AS classify_name_en,unique_code,source_name,source,sys_user_id,sys_user_real_name,start_date,edb_code,edb_type FROM edb_info WHERE edb_info_type = ? order by sort asc,edb_info_id asc`
  74. _, err = o.Raw(sql, edbInfoType).QueryRows(&items)
  75. return
  76. }
  77. // 用于分类展示
  78. func GetEdbInfoAllList() (items []*EdbInfo, err error) {
  79. o := orm.NewOrmUsingDB("data")
  80. sql := ` SELECT * FROM edb_info `
  81. _, err = o.Raw(sql).QueryRows(&items)
  82. return
  83. }
  84. // 指标检索数据
  85. type EdbInfoSearch struct {
  86. EdbCode string `description:"指标编码"`
  87. StartDate string `description:"起始日期"`
  88. EndDate string `description:"终止日期"`
  89. EdbName string `description:"指标名称"`
  90. Unit string `description:"单位"`
  91. Frequency string `description:"频率"`
  92. DataList []*EdbInfoSearchData
  93. }
  94. type EdbInfoSearchData struct {
  95. DataTime string `description:"数据日期"`
  96. Value float64 `description:"数据"`
  97. }
  98. type BaseIndexInfo struct {
  99. IndexName string `description:"数据日期"`
  100. Unit string `description:"单位"`
  101. Frequency string `description:"频率"`
  102. }
  103. type EdbInfoSearchResp struct {
  104. SearchItem *EdbInfoSearch `description:"指标分类"`
  105. Status int `description:"1:数据已存在于弘则数据库,2:新数据,3:数据已存在于弘则数据库,但是当前账号无权限"`
  106. ClassifyList []*EdbClassifySimplify
  107. StockSearchList []*EdbInfoSearch
  108. }
  109. func GetEdbInfoByEdbCode(source int, edbCode string) (item *EdbInfo, err error) {
  110. o := orm.NewOrmUsingDB("data")
  111. sql := ` SELECT * FROM edb_info WHERE source=? AND edb_code=? `
  112. err = o.Raw(sql, source, edbCode).QueryRow(&item)
  113. return
  114. }
  115. func GetEdbInfoById(edbInfoId int) (item *EdbInfo, err error) {
  116. o := orm.NewOrmUsingDB("data")
  117. sql := ` SELECT * FROM edb_info WHERE edb_info_id=? `
  118. err = o.Raw(sql, edbInfoId).QueryRow(&item)
  119. return
  120. }
  121. // GetEdbInfoByIdList 根据指标id集合 获取 指标列表
  122. func GetEdbInfoByIdList(edbInfoIdList []int) (items []*EdbInfo, err error) {
  123. num := len(edbInfoIdList)
  124. if num <= 0 {
  125. return
  126. }
  127. o := orm.NewOrmUsingDB("data")
  128. sql := ` SELECT * FROM edb_info WHERE edb_info_id in (` + utils.GetOrmInReplace(num) + `) `
  129. _, err = o.Raw(sql, edbInfoIdList).QueryRows(&items)
  130. return
  131. }
  132. type AddEdbInfoReq struct {
  133. Source int `description:"来源id"`
  134. EdbCode string `description:"指标编码"`
  135. EdbName string `description:"指标名称"`
  136. Frequency string `description:"频率"`
  137. Unit string `description:"单位"`
  138. ClassifyId int `description:"分类id"`
  139. StartDate string `description:"起始日期"`
  140. EndDate string `description:"终止日期"`
  141. }
  142. func DeleteEdbInfoAndData(edbInfoId, source int) (err error) {
  143. o := orm.NewOrmUsingDB("data")
  144. to, err := o.Begin()
  145. if err != nil {
  146. return
  147. }
  148. defer func() {
  149. if err != nil {
  150. _ = to.Rollback()
  151. } else {
  152. _ = to.Commit()
  153. }
  154. }()
  155. // 删除指标信息
  156. sql := ` DELETE FROM edb_info WHERE edb_info_id=? `
  157. _, err = to.Raw(sql, edbInfoId).Exec()
  158. if err != nil {
  159. return
  160. }
  161. // 删除指标数据
  162. tableName := GetEdbDataTableName(source)
  163. if tableName != "" {
  164. sql = ` DELETE FROM %s WHERE edb_info_id=? `
  165. sql = fmt.Sprintf(sql, tableName)
  166. _, err = to.Raw(sql, edbInfoId).Exec()
  167. if err != nil {
  168. return
  169. }
  170. }
  171. //calculateTableName := GetEdbInfoCalculateTableName(source)
  172. //if calculateTableName != "" {
  173. // sql = ` DELETE FROM %s WHERE edb_info_id=? `
  174. // sql = fmt.Sprintf(sql, calculateTableName)
  175. // _, err = to.Raw(sql, edbInfoId).Exec()
  176. // return
  177. //}
  178. //return
  179. // 删除计算指标的关系
  180. sql = ` DELETE FROM edb_info_calculate_mapping WHERE edb_info_id=? `
  181. _, err = to.Raw(sql, edbInfoId).Exec()
  182. // 删除预测指标的配置
  183. sql = ` DELETE FROM predict_edb_conf WHERE predict_edb_info_id=? `
  184. _, err = to.Raw(sql, edbInfoId).Exec()
  185. return
  186. }
  187. func GetEdbInfoCountByCondition(condition string, pars []interface{}) (count int, err error) {
  188. o := orm.NewOrmUsingDB("data")
  189. sql := ` SELECT COUNT(1) AS count FROM edb_info WHERE 1=1 `
  190. if condition != "" {
  191. sql += condition
  192. }
  193. err = o.Raw(sql, pars).QueryRow(&count)
  194. return
  195. }
  196. type EditEdbInfoReq struct {
  197. EdbInfoId int `description:"指标ID"`
  198. EdbName string `description:"指标名称"`
  199. Frequency string `description:"频率"`
  200. Unit string `description:"单位"`
  201. ClassifyId int `description:"分类id"`
  202. CalculateFormula string `description:"计算公式"`
  203. }
  204. type EditEdbEnInfoReq struct {
  205. EdbInfoId int `description:"指标ID"`
  206. EdbNameEn string `description:"英文指标名称"`
  207. UnitEn string `description:"英文单位"`
  208. }
  209. func ModifyEdbInfo(item *EditEdbInfoReq) (err error) {
  210. o := orm.NewOrmUsingDB("data")
  211. sql := ` UPDATE edb_info
  212. SET
  213. edb_name =?,
  214. edb_name_source =?,
  215. frequency = ?,
  216. unit = ?,
  217. classify_id = ?,
  218. modify_time = NOW()
  219. WHERE edb_info_id = ?`
  220. _, err = o.Raw(sql, item.EdbName, item.EdbName, item.Frequency, item.Unit, item.ClassifyId, item.EdbInfoId).Exec()
  221. return
  222. }
  223. // ModifyEdbEnInfo 修改指标英文信息
  224. func ModifyEdbEnInfo(item *EditEdbEnInfoReq) (err error) {
  225. o := orm.NewOrmUsingDB("data")
  226. sql := ` UPDATE edb_info
  227. SET
  228. edb_name_en =?,
  229. unit_en = ?,
  230. modify_time = NOW()
  231. WHERE edb_info_id = ?`
  232. _, err = o.Raw(sql, item.EdbNameEn, item.UnitEn, item.EdbInfoId).Exec()
  233. return
  234. }
  235. type EdbInfoList struct {
  236. EdbInfoId int `orm:"column(edb_info_id);pk"`
  237. EdbInfoType int `description:"指标类型,0:普通指标,1:预测指标"`
  238. SourceName string `description:"来源名称"`
  239. Source int `description:"来源id"`
  240. EdbCode string `description:"指标编码"`
  241. EdbNameEn string `description:"英文指标名称"`
  242. EdbName string `description:"指标名称"`
  243. Frequency string `description:"频率"`
  244. FrequencyEn string `description:"英文频率"`
  245. Unit string `description:"单位"`
  246. UnitEn string `description:"英文单位"`
  247. StartDate string `description:"起始日期"`
  248. EndDate string `description:"终止日期"`
  249. LatestDate string `description:"数据最新日期"`
  250. LatestValue float64 `description:"数据最新值"`
  251. ClassifyId int `description:"分类id"`
  252. UniqueCode string `description:"指标唯一编码"`
  253. SysUserId int `description:"创建人id"`
  254. SysUserRealName string `description:"创建人姓名"`
  255. ModifyTime string `description:"最新修改时间"`
  256. CreateTime string `description:"创建时间"`
  257. EdbNameAlias string `json:"-" description:"指标名称,别名"`
  258. EdbType int `description:"指标类型:1:基础指标,2:计算指标"`
  259. ChartImage string `description:"图表图片"`
  260. RuleType int `description:"预测规则,1:最新,2:固定值"`
  261. FixedValue float64 `description:"固定值"`
  262. DataList []*EdbData `description:"实际指标数据"`
  263. PredictDataList []*EdbData `description:"预测指标数据"`
  264. Button EdbClassifyItemsButton `description:"操作权限"`
  265. IsEnEdb bool `description:"是否展示英文标识"`
  266. DataInsertConfig EdbDataInsertConfigItem `description:"指标数据插入配置"`
  267. DataDateType string `description:"数据日期类型,枚举值:交易日、自然日"`
  268. }
  269. type EdbDataInsertConfigItem struct {
  270. Date string `description:"插入的日期"`
  271. RealDate string `description:"实际最晚的日期"`
  272. Value string `description:"插入的值"`
  273. }
  274. type EdbData struct {
  275. EdbDataId int `orm:"column(edb_data_id);pk"`
  276. EdbInfoId int
  277. DataTime string
  278. Value float64
  279. }
  280. type EdbInfoListResp struct {
  281. Paging *paging.PagingItem
  282. Item *EdbInfoList
  283. ClassifyList []*EdbClassifyIdItems
  284. }
  285. func GetEdbInfoByCondition(condition string, pars []interface{}) (item *EdbInfoList, err error) {
  286. o := orm.NewOrmUsingDB("data")
  287. sql := ` SELECT * FROM edb_info WHERE 1=1 `
  288. if condition != "" {
  289. sql += condition
  290. }
  291. err = o.Raw(sql, pars).QueryRow(&item)
  292. return
  293. }
  294. func GetEdbDataCountByCondition(condition string, pars []interface{}, source int) (count int, err error) {
  295. o := orm.NewOrmUsingDB("data")
  296. tableName := GetEdbDataTableName(source)
  297. sql := ` SELECT COUNT(1) AS count FROM %s WHERE 1=1 `
  298. sql = fmt.Sprintf(sql, tableName)
  299. if condition != "" {
  300. sql += condition
  301. }
  302. err = o.Raw(sql, pars).QueryRow(&count)
  303. return
  304. }
  305. func GetEdbDataListByCondition(condition string, pars []interface{}, source, pageSize, startSize int) (item []*EdbData, err error) {
  306. o := orm.NewOrmUsingDB("data")
  307. tableName := GetEdbDataTableName(source)
  308. sql := ` SELECT * FROM %s WHERE 1=1 `
  309. sql = fmt.Sprintf(sql, tableName)
  310. if condition != "" {
  311. sql += condition
  312. }
  313. sql += ` ORDER BY data_time DESC `
  314. sql += ` LIMIT ?,? `
  315. _, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&item)
  316. return
  317. }
  318. // GetAllEdbDataListByCondition 根据条件获取所有的数据
  319. func GetAllEdbDataListByCondition(condition string, pars []interface{}, source int) (item []*EdbData, err error) {
  320. o := orm.NewOrmUsingDB("data")
  321. tableName := GetEdbDataTableName(source)
  322. sql := ` SELECT * FROM %s WHERE 1=1 `
  323. sql = fmt.Sprintf(sql, tableName)
  324. if condition != "" {
  325. sql += condition
  326. }
  327. sql += ` ORDER BY data_time DESC `
  328. _, err = o.Raw(sql, pars).QueryRows(&item)
  329. return
  330. }
  331. func GetEdbInfoByNewest() (item *EdbInfoList, err error) {
  332. o := orm.NewOrmUsingDB("data")
  333. sql := ` SELECT * FROM edb_info WHERE 1=1 ORDER BY modify_time DESC LIMIT 1 `
  334. err = o.Raw(sql).QueryRow(&item)
  335. return
  336. }
  337. func ModifyEdbInfoModifyTime(edbInfoId int64) (err error) {
  338. o := orm.NewOrmUsingDB("data")
  339. sql := ` UPDATE edb_info SET modify_time = NOW() WHERE edb_info_id = ? `
  340. _, err = o.Raw(sql, edbInfoId).Exec()
  341. return
  342. }
  343. type MoveEdbInfoReq struct {
  344. EdbInfoId int `description:"指标ID"`
  345. PrevEdbInfoId int `description:"上一个指标ID"`
  346. NextEdbInfoId int `description:"下一个指标ID"`
  347. ClassifyId int `description:"分类id"`
  348. }
  349. func MoveEdbInfo(edbInfoId, classifyId int) (err error) {
  350. o := orm.NewOrmUsingDB("data")
  351. sql := ` UPDATE edb_info
  352. SET
  353. classify_id = ?
  354. WHERE edb_info_id = ?`
  355. _, err = o.Raw(sql, classifyId, edbInfoId).Exec()
  356. return
  357. }
  358. // GetEdbInfoByName 根据名称获取普通的指标
  359. func GetEdbInfoByName(edbName string) (items []*EdbInfoList, err error) {
  360. o := orm.NewOrmUsingDB("data")
  361. sql := ` SELECT * FROM edb_info WHERE edb_name=? AND edb_info_type = 0 `
  362. _, err = o.Raw(sql, edbName).QueryRows(&items)
  363. return
  364. }
  365. // GetPredictEdbInfoByName 根据指标名称获取预测指标
  366. func GetPredictEdbInfoByName(edbName string) (items []*EdbInfoList, err error) {
  367. o := orm.NewOrmUsingDB("data")
  368. sql := ` SELECT * FROM edb_info WHERE edb_name=? AND edb_info_type = 1 `
  369. _, err = o.Raw(sql, edbName).QueryRows(&items)
  370. return
  371. }
  372. func GetEdbInfoByEnName(edbNameEn string) (items []*EdbInfoList, err error) {
  373. o := orm.NewOrmUsingDB("data")
  374. sql := ` SELECT * FROM edb_info WHERE edb_name_en=? AND edb_info_type = 0 `
  375. _, err = o.Raw(sql, edbNameEn).QueryRows(&items)
  376. return
  377. }
  378. func ModifyEdbInfoNameSource(edbNameSource string, edbInfoId int) (err error) {
  379. o := orm.NewOrmUsingDB("data")
  380. sql := ` UPDATE edb_info SET edb_name_source=? WHERE edb_info_id = ? `
  381. _, err = o.Raw(sql, edbNameSource, edbInfoId).Exec()
  382. return
  383. }
  384. func GetChartEdbMappingCount(edbInfoId int) (count int, err error) {
  385. o := orm.NewOrmUsingDB("data")
  386. sql := ` SELECT COUNT(1) AS count FROM chart_edb_mapping WHERE edb_info_id=? `
  387. err = o.Raw(sql, edbInfoId).QueryRow(&count)
  388. return
  389. }
  390. type ChartEdbInfo struct {
  391. EdbInfoId int `description:"指标id"`
  392. EdbName string `description:"指标名称"`
  393. SourceName string `json:"-"`
  394. EdbNameAlias string `json:"-" description:"指标名称,别名"`
  395. }
  396. func EdbInfoSearchByKeyWord(KeyWord string) (searchList []*ChartEdbInfo, err error) {
  397. o := orm.NewOrmUsingDB("data")
  398. sql := ` SELECT edb_info_id,edb_name,source_name FROM edb_info WHERE 1=1 AND edb_info_type = 0 `
  399. if KeyWord != "" {
  400. sql += ` AND (edb_name LIKE '%` + KeyWord + `%' OR edb_code LIKE '%` + KeyWord + `%' ) `
  401. }
  402. sql += ` ORDER BY create_time DESC `
  403. _, err = o.Raw(sql).QueryRows(&searchList)
  404. return
  405. }
  406. type EdbInfoMaxAndMinInfo struct {
  407. MinDate string `description:"最小日期"`
  408. MaxDate string `description:"最大日期"`
  409. MinValue float64 `description:"最小值"`
  410. MaxValue float64 `description:"最大值"`
  411. LatestValue float64 `description:"最新值"`
  412. }
  413. func GetEdbInfoMaxAndMinInfo(source int, edbCode string) (item *EdbInfoMaxAndMinInfo, err error) {
  414. o := orm.NewOrmUsingDB("data")
  415. sql := ``
  416. tableName := GetEdbDataTableName(source)
  417. sql = ` SELECT MIN(data_time) AS min_date,MAX(data_time) AS max_date,MIN(value) AS min_value,MAX(value) AS max_value FROM %s WHERE edb_code=? `
  418. sql = fmt.Sprintf(sql, tableName)
  419. err = o.Raw(sql, edbCode).QueryRow(&item)
  420. if err != nil {
  421. return
  422. }
  423. var latest_value float64
  424. sql = ` SELECT value AS latest_value FROM %s WHERE edb_code=? ORDER BY data_time DESC LIMIT 1 `
  425. sql = fmt.Sprintf(sql, tableName)
  426. err = o.Raw(sql, edbCode).QueryRow(&latest_value)
  427. item.LatestValue = latest_value
  428. return
  429. }
  430. func ModifyEdbInfoMaxAndMinInfo(edbInfoId int, item *EdbInfoMaxAndMinInfo) (err error) {
  431. o := orm.NewOrmUsingDB("data")
  432. sql := ` UPDATE edb_info SET start_date=?,end_date=?,min_value=?,max_value=?,is_update=2,latest_date=?,latest_value=?,modify_time=NOW() WHERE edb_info_id=? `
  433. _, err = o.Raw(sql, item.MinDate, item.MaxDate, item.MinValue, item.MaxValue, item.MaxDate, item.LatestValue, edbInfoId).Exec()
  434. return
  435. }
  436. func GetEdbInfoFilter(condition string, pars []interface{}) (list []*EdbInfoList, err error) {
  437. o := orm.NewOrmUsingDB("data")
  438. sql := ` SELECT * FROM edb_info WHERE 1=1 AND edb_info_type = 0 `
  439. if condition != "" {
  440. sql += condition
  441. }
  442. sql += ` ORDER BY create_time DESC `
  443. _, err = o.Raw(sql, pars).QueryRows(&list)
  444. return
  445. }
  446. //order:1升序,其余值为降序
  447. func GetEdbDataListAll(condition string, pars []interface{}, source, order int) (item []*EdbInfoSearchData, err error) {
  448. o := orm.NewOrmUsingDB("data")
  449. sql := ``
  450. tableName := GetEdbDataTableName(source)
  451. sql = ` SELECT * FROM %s WHERE 1=1 `
  452. sql = fmt.Sprintf(sql, tableName)
  453. if condition != "" {
  454. sql += condition
  455. }
  456. if order == 1 {
  457. sql += ` ORDER BY data_time ASC `
  458. } else {
  459. sql += ` ORDER BY data_time DESC `
  460. }
  461. _, err = o.Raw(sql, pars).QueryRows(&item)
  462. return
  463. }
  464. // GetLastEdbData 获取最近的一条指标数据
  465. func GetLastEdbData(condition string, pars []interface{}, source int) (item *EdbInfoSearchData, err error) {
  466. o := orm.NewOrmUsingDB("data")
  467. sql := ``
  468. tableName := GetEdbDataTableName(source)
  469. sql = ` SELECT * FROM %s WHERE 1=1 `
  470. sql = fmt.Sprintf(sql, tableName)
  471. if condition != "" {
  472. sql += condition
  473. }
  474. sql += ` ORDER BY data_time DESC `
  475. err = o.Raw(sql, pars).QueryRow(&item)
  476. return
  477. }
  478. //order:1升序,其余值为降序
  479. func GetEdbDataCount(condition string, pars []interface{}, source int) (count int, err error) {
  480. o := orm.NewOrmUsingDB("data")
  481. sql := ``
  482. tableName := GetEdbDataTableName(source)
  483. sql = ` SELECT COUNT(1) AS count FROM %s WHERE 1=1 `
  484. sql = fmt.Sprintf(sql, tableName)
  485. if condition != "" {
  486. sql += condition
  487. }
  488. err = o.Raw(sql, pars).QueryRow(&count)
  489. return
  490. }
  491. func ModifyCalculateEdbInfo(item *EditEdbInfoReq) (err error) {
  492. o := orm.NewOrmUsingDB("data")
  493. sql := ` UPDATE edb_info
  494. SET
  495. edb_name =?,
  496. edb_name_source =?,
  497. frequency = ?,
  498. unit = ?,
  499. classify_id = ?,
  500. calculate_formula=?,
  501. modify_time = NOW()
  502. WHERE edb_info_id = ?`
  503. _, err = o.Raw(sql, item.EdbName, item.EdbName, item.Frequency, item.Unit, item.ClassifyId, item.CalculateFormula, item.EdbInfoId).Exec()
  504. return
  505. }
  506. type AddEdbInfoResp struct {
  507. EdbInfoId int `description:"指标ID"`
  508. UniqueCode string `description:"指标唯一编码"`
  509. ClassifyId int `description:"分类id"`
  510. }
  511. // 根据基础指标获取所有关联指标
  512. func GetNeedRefreshCalculateEdbInfoFromBase(fromEdbInfo int) (list []*EdbInfo, err error) {
  513. o := orm.NewOrmUsingDB("data")
  514. sql := ` SELECT b.*
  515. FROM edb_info_calculate AS a
  516. INNER JOIN edb_info AS b ON a.edb_info_id=b.edb_info_id
  517. WHERE from_edb_info_id=? `
  518. _, err = o.Raw(sql, fromEdbInfo).QueryRows(&list)
  519. return
  520. }
  521. func GetEdbInfoCalculateCount(edbInfoId int) (count int, err error) {
  522. o := orm.NewOrmUsingDB("data")
  523. sql := ` SELECT COUNT(1) AS count FROM edb_info_calculate WHERE from_edb_info_id=? `
  524. err = o.Raw(sql, edbInfoId).QueryRow(&count)
  525. return
  526. }
  527. func GetEdbInfoCalculateLjzzyCount(edbInfoId int) (count int, err error) {
  528. o := orm.NewOrmUsingDB("data")
  529. sql := ` SELECT COUNT(1) AS count FROM edb_info_calculate_ljzzy WHERE from_edb_info_id=? `
  530. err = o.Raw(sql, edbInfoId).QueryRow(&count)
  531. return
  532. }
  533. func GetEdbInfoCalculateTbzCount(edbInfoId int) (count int, err error) {
  534. o := orm.NewOrmUsingDB("data")
  535. sql := ` SELECT COUNT(1) AS count FROM edb_info_calculate_tbz WHERE from_edb_info_id=? `
  536. err = o.Raw(sql, edbInfoId).QueryRow(&count)
  537. return
  538. }
  539. func GetEdbInfoCalculateTczCount(edbInfoId int) (count int, err error) {
  540. o := orm.NewOrmUsingDB("data")
  541. sql := ` SELECT COUNT(1) AS count FROM edb_info_calculate_tcz WHERE from_edb_info_id=? `
  542. err = o.Raw(sql, edbInfoId).QueryRow(&count)
  543. return
  544. }
  545. func GetEdbInfoCalculateNszydpjjsCount(edbInfoId int) (count int, err error) {
  546. o := orm.NewOrmUsingDB("data")
  547. sql := ` SELECT COUNT(1) AS count FROM edb_info_calculate_nszydpjjs WHERE from_edb_info_id=? `
  548. err = o.Raw(sql, edbInfoId).QueryRow(&count)
  549. return
  550. }
  551. func GetEdbInfoCalculateCountByCondition(source int, condition string, pars []interface{}) (count int, err error) {
  552. o := orm.NewOrmUsingDB("data")
  553. //calculateTableName := GetEdbInfoCalculateTableName(source)
  554. //if calculateTableName == "" {
  555. // err = errors.New("无效的表名")
  556. // return
  557. //}
  558. sql := ` SELECT COUNT(1) AS count FROM edb_info_calculate_mapping WHERE 1=1 `
  559. //sql = fmt.Sprintf(sql, calculateTableName)
  560. if condition != "" {
  561. sql += condition
  562. }
  563. err = o.Raw(sql, pars).QueryRow(&count)
  564. return
  565. }
  566. // GetEdbInfoCalculateListByCondition 获取指标关系列表
  567. func GetEdbInfoCalculateListByCondition(condition string, pars []interface{}) (items []*EdbInfoCalculateMapping, err error) {
  568. o := orm.NewOrmUsingDB("data")
  569. //calculateTableName := GetEdbInfoCalculateTableName(source)
  570. //if calculateTableName == "" {
  571. // err = errors.New("无效的表名")
  572. // return
  573. //}
  574. sql := ` SELECT * FROM edb_info_calculate_mapping WHERE 1=1 `
  575. //sql = fmt.Sprintf(sql, calculateTableName)
  576. if condition != "" {
  577. sql += condition
  578. }
  579. _, err = o.Raw(sql, pars).QueryRows(&items)
  580. return
  581. }
  582. func GetRefreshEdbInfoFromCalculate(edbInfoId, source int) (baseEdbInfoArr, calculateInfoArr []*EdbInfo, err error) {
  583. calculateList, err := GetEdbInfoCalculateMap(edbInfoId, source)
  584. if err != nil && err.Error() != utils.ErrNoRow() {
  585. return
  586. }
  587. for _, item := range calculateList {
  588. if item.EdbType == 1 {
  589. baseEdbInfoArr = append(baseEdbInfoArr, item)
  590. } else {
  591. calculateInfoArr = append(calculateInfoArr, item)
  592. newBaseEdbInfoArr, newCalculateInfoArr, _ := GetRefreshEdbInfoFromCalculate(item.EdbInfoId, item.Source)
  593. baseEdbInfoArr = append(baseEdbInfoArr, newBaseEdbInfoArr...)
  594. calculateInfoArr = append(calculateInfoArr, newCalculateInfoArr...)
  595. }
  596. }
  597. return
  598. }
  599. // 获取基础指标对应的所有计算指标
  600. func GetEdbInfoAllCalculate(edbInfoId int) (list []*EdbInfo, err error) {
  601. o := orm.NewOrmUsingDB("data")
  602. sql := ` SELECT b.* FROM edb_info_calculate_mapping AS a
  603. INNER JOIN edb_info AS b ON a.edb_info_id=b.edb_info_id
  604. WHERE a.from_edb_info_id=?
  605. GROUP BY a.edb_info_id
  606. ORDER BY a.edb_info_id ASC `
  607. _, err = o.Raw(sql, edbInfoId).QueryRows(&list)
  608. return
  609. }
  610. // GetEdbInfoAllCalculateByEdbInfoIdList 根据指标id集合 获取基础指标对应的所有计算指标
  611. func GetEdbInfoAllCalculateByEdbInfoIdList(edbInfoIdList []int) (list []*EdbInfo, err error) {
  612. num := len(edbInfoIdList)
  613. if num <= 0 {
  614. return
  615. }
  616. o := orm.NewOrmUsingDB("data")
  617. sql := ` SELECT b.* FROM edb_info_calculate_mapping AS a
  618. INNER JOIN edb_info AS b ON a.edb_info_id=b.edb_info_id
  619. WHERE a.from_edb_info_id in (` + utils.GetOrmInReplace(num) + `)
  620. GROUP BY a.edb_info_id
  621. ORDER BY a.edb_info_id ASC `
  622. _, err = o.Raw(sql, edbInfoIdList).QueryRows(&list)
  623. return
  624. }
  625. func GetRefreshEdbInfoFromBase(edbInfoId, source int) (baseEdbInfoArr, calculateInfoArr []*EdbInfo, err error) {
  626. calculateList, err := GetEdbInfoCalculateMap(edbInfoId, source)
  627. if err != nil && err.Error() != utils.ErrNoRow() {
  628. return
  629. }
  630. for _, item := range calculateList {
  631. if item.EdbInfoId == edbInfoId { // 如果查出来关联的指标就是自己的话,那么就过滤
  632. continue
  633. }
  634. if item.EdbType == 1 {
  635. baseEdbInfoArr = append(baseEdbInfoArr, item)
  636. } else {
  637. calculateInfoArr = append(calculateInfoArr, item)
  638. newBaseEdbInfoArr, newCalculateInfoArr, _ := GetRefreshEdbInfoFromBase(item.EdbInfoId, item.Source)
  639. baseEdbInfoArr = append(baseEdbInfoArr, newBaseEdbInfoArr...)
  640. calculateInfoArr = append(calculateInfoArr, newCalculateInfoArr...)
  641. }
  642. }
  643. return
  644. }
  645. func ModifyEdbInfoDataStatus(edbInfoId int64, source int, edbCode string) (err error) {
  646. o := orm.NewOrmUsingDB("data")
  647. sql := ``
  648. tableName := GetEdbDataTableName(source)
  649. sql = ` UPDATE %s SET edb_info_id=?,modify_time=NOW() WHERE edb_code=? `
  650. sql = fmt.Sprintf(sql, tableName)
  651. _, err = o.Raw(sql, edbInfoId, edbCode).Exec()
  652. return
  653. }
  654. // GetFirstEdbInfoByClassifyId 获取当前分类下,且排序数相同 的排序第一条的数据
  655. func GetFirstEdbInfoByClassifyId(classifyId int) (item *EdbInfo, err error) {
  656. o := orm.NewOrmUsingDB("data")
  657. sql := ` SELECT * FROM edb_info WHERE classify_id=? order by sort asc,edb_info_id asc limit 1`
  658. err = o.Raw(sql, classifyId).QueryRow(&item)
  659. return
  660. }
  661. // UpdateEdbInfoSortByClassifyId 根据分类id更新排序
  662. func UpdateEdbInfoSortByClassifyId(classifyId, nowSort int, prevEdbInfoId int, updateSort string) (err error) {
  663. o := orm.NewOrmUsingDB("data")
  664. sql := ` update edb_info set sort = ` + updateSort + ` WHERE classify_id=?`
  665. if prevEdbInfoId > 0 {
  666. sql += ` AND ( sort > ? or ( edb_info_id > ` + fmt.Sprint(prevEdbInfoId) + ` and sort=` + fmt.Sprint(nowSort) + ` )) `
  667. } else {
  668. sql += ` AND ( sort > ? )`
  669. }
  670. _, err = o.Raw(sql, classifyId, nowSort).Exec()
  671. return
  672. }
  673. // Update 更新指标基础信息
  674. func (edbInfo *EdbInfo) Update(cols []string) (err error) {
  675. o := orm.NewOrmUsingDB("data")
  676. _, err = o.Update(edbInfo, cols...)
  677. return
  678. }
  679. type EdbInfoDataResp struct {
  680. EdbInfo *EdbInfo
  681. DataList []*EdbDataList
  682. }
  683. type EdbInfoDataFullClassifyResp struct {
  684. EdbInfo *EdbInfoFullClassify
  685. DataList []*EdbDataList
  686. }
  687. type EdbInfoReplaceReq struct {
  688. OldEdbInfoId int `description:"原指标ID"`
  689. NewEdbInfoId int `description:"替换为指标ID"`
  690. }
  691. /*
  692. EdbInfoReplace 替换指标初始版本(已废弃,废弃时间:2022年01月05日15:33:42)
  693. 1、替换图库中的指标
  694. 2、替换计算指标中的指标,完了计算指标中的指标,全部重新计算
  695. */
  696. func EdbInfoReplace(oldEdbInfo, newEdbInfo *EdbInfo, sysAdminId int, sysAdminRealName string) (replaceChartTotal, replaceCalculateTotal int, err error) {
  697. var errmsg string
  698. o := orm.NewOrmUsingDB("data")
  699. to, err := o.Begin()
  700. if err != nil {
  701. return
  702. }
  703. defer func() {
  704. if errmsg != "" {
  705. fmt.Println("errmsg:" + errmsg)
  706. }
  707. }()
  708. //替换图表
  709. chartEdbMappingList := make([]*ChartEdbInfoMapping, 0)
  710. csql := `SELECT * FROM chart_edb_mapping WHERE edb_info_id=?`
  711. _, err = to.Raw(csql, oldEdbInfo.EdbInfoId).QueryRows(&chartEdbMappingList)
  712. if err != nil {
  713. errmsg = "获取指标关联图表信息失败:Err:" + err.Error()
  714. return
  715. }
  716. replaceChartTotal = len(chartEdbMappingList)
  717. for _, mv := range chartEdbMappingList {
  718. //获取图表所有指标信息
  719. chartEdbList := make([]*ChartEdbInfoMapping, 0)
  720. csql := `SELECT * FROM chart_edb_mapping WHERE chart_info_id=?`
  721. _, err = to.Raw(csql, mv.ChartInfoId).QueryRows(&chartEdbList)
  722. if err != nil {
  723. errmsg = "获取图表所有指标信息失败:Err:" + err.Error()
  724. return
  725. }
  726. var minData, maxData float64
  727. minData = newEdbInfo.MinValue
  728. maxData = newEdbInfo.MaxValue
  729. for _, cv := range chartEdbList {
  730. if mv.IsAxis == cv.IsAxis {
  731. if minData > cv.MinData {
  732. minData = cv.MinData
  733. }
  734. if maxData < cv.MaxData {
  735. maxData = cv.MaxData
  736. }
  737. }
  738. }
  739. //修改图表关联指标
  740. rsql := ` UPDATE chart_edb_mapping SET edb_info_id=?,max_data=?,min_data=?,modify_time=NOW() WHERE chart_edb_mapping_id=? `
  741. _, err = to.Raw(rsql, newEdbInfo.EdbInfoId, maxData, minData, mv.ChartEdbMappingId).Exec()
  742. if err != nil {
  743. errmsg = "更新图库指标信息失败:Err:" + err.Error()
  744. return
  745. }
  746. }
  747. //替换计算指标
  748. //获取所有包含的计算指标
  749. mappingList := make([]*EdbInfoCalculateMapping, 0)
  750. msql := ` SELECT * FROM edb_info_calculate_mapping WHERE from_edb_info_id=? GROUP BY edb_info_id `
  751. _, err = to.Raw(msql, oldEdbInfo.EdbInfoId).QueryRows(&mappingList)
  752. if err != nil {
  753. errmsg = "获取计算指标关联基础指标信息失败:Err:" + err.Error()
  754. return
  755. }
  756. replaceCalculateTotal = len(mappingList)
  757. //计算指标
  758. for _, mv := range mappingList {
  759. //替换原指标
  760. msql := `UPDATE edb_info_calculate_mapping SET from_edb_info_id=?,from_edb_code=?,from_edb_name=?,from_source=?,from_source_name=? WHERE edb_info_calculate_mapping_id=? `
  761. _, err = to.Raw(msql, newEdbInfo.EdbInfoId, newEdbInfo.EdbCode, newEdbInfo.EdbName, newEdbInfo.Source, newEdbInfo.SourceName, mv.EdbInfoCalculateMappingId).Exec()
  762. if err != nil {
  763. return
  764. }
  765. }
  766. if err != nil && errmsg != "" {
  767. go alarm_msg.SendAlarmMsg("替换指标失败提醒,errmsg:"+errmsg, 3)
  768. //go utils.SendEmail(utils.APPNAME+"【"+utils.RunMode+"】"+"替换指标失败提醒", "errmsg:"+errmsg, utils.EmailSendToUsers)
  769. _ = to.Rollback()
  770. } else {
  771. _ = to.Commit()
  772. }
  773. //获取计算指标关联指标
  774. allMappingList := make([]*EdbInfoCalculateMapping, 0)
  775. allMapping := make(map[int]int)
  776. tmpMapping := make(map[int]int)
  777. for _, v := range mappingList {
  778. if _, ok := allMapping[v.EdbInfoId]; !ok {
  779. allMappingList = append(allMappingList, v)
  780. }
  781. newList, _ := GetAllCalculate(v.EdbInfoId, tmpMapping)
  782. for _, nv := range newList {
  783. if _, ok := allMapping[v.EdbInfoId]; !ok {
  784. allMappingList = append(allMappingList, nv)
  785. }
  786. allMapping[v.EdbInfoId] = v.EdbInfoId
  787. }
  788. allMapping[v.EdbInfoId] = v.EdbInfoId
  789. }
  790. for mk, mv := range allMappingList { //原指标关联的所有计算指标
  791. fmt.Println("mk/mv", mk, mv)
  792. //重新计算计算指标
  793. {
  794. edbInfo, err := GetEdbInfoById(mv.EdbInfoId) //计算指标
  795. if err != nil {
  796. if err.Error() == utils.ErrNoRow() {
  797. errmsg = "计算指标已被删除"
  798. return replaceChartTotal, replaceCalculateTotal, err
  799. }
  800. errmsg = "获取计算指标失败:err:" + err.Error()
  801. return replaceChartTotal, replaceCalculateTotal, err
  802. }
  803. fromEdbInfoList, err := GetEdbInfoCalculateDetail(mv.EdbInfoId, edbInfo.Source)
  804. if err != nil {
  805. errmsg = "获取计算指标失败:err:" + err.Error()
  806. return replaceChartTotal, replaceCalculateTotal, err
  807. }
  808. if len(fromEdbInfoList) <= 0 {
  809. errmsg = "计算指标所依赖指标不存在"
  810. return replaceChartTotal, replaceCalculateTotal, err
  811. }
  812. fromEdbInfoItem := fromEdbInfoList[0]
  813. if fromEdbInfoItem == nil {
  814. return replaceChartTotal, replaceCalculateTotal, err
  815. }
  816. fromEdbInfo, err := GetEdbInfoById(fromEdbInfoItem.FromEdbInfoId)
  817. if err != nil {
  818. errmsg = "获取计算指标 来源指标失败:err:" + err.Error()
  819. return replaceChartTotal, replaceCalculateTotal, err
  820. }
  821. edbCode := edbInfo.EdbCode
  822. uniqueCode := edbInfo.UniqueCode
  823. sourName := edbInfo.SourceName
  824. source := edbInfo.Source
  825. edbInfoId := edbInfo.EdbInfoId
  826. req := new(EdbInfoCalculateBatchSaveReq)
  827. req.EdbInfoId = edbInfoId
  828. req.EdbName = edbInfo.EdbName
  829. req.Frequency = edbInfo.Frequency
  830. req.Unit = edbInfo.Unit
  831. req.ClassifyId = edbInfo.ClassifyId
  832. req.FromEdbInfoId = fromEdbInfoList[0].FromEdbInfoId
  833. if source == utils.DATA_SOURCE_CALCULATE {
  834. //检验公式
  835. var formulaStr string
  836. var edbInfoIdBytes []string
  837. for _, v := range fromEdbInfoList {
  838. formulaStr += v.FromTag + ","
  839. edbInfoIdBytes = append(edbInfoIdBytes, v.FromTag)
  840. }
  841. formulaStr = strings.Trim(formulaStr, ",")
  842. formulaMap := CheckFormula(edbInfo.CalculateFormula)
  843. for _, v := range formulaMap {
  844. if !strings.Contains(formulaStr, v) {
  845. errmsg = "公式错误,请重新填写"
  846. return replaceChartTotal, replaceCalculateTotal, err
  847. }
  848. }
  849. edbInfoList := make([]*EdbInfo, 0)
  850. for _, v := range fromEdbInfoList {
  851. edbInfo, err := GetEdbInfoById(v.FromEdbInfoId)
  852. if err != nil {
  853. if err.Error() == utils.ErrNoRow() {
  854. errmsg = "指标 " + strconv.Itoa(v.FromEdbInfoId) + " 不存在"
  855. return replaceChartTotal, replaceCalculateTotal, err
  856. }
  857. errmsg = "获取指标失败:Err:" + err.Error()
  858. return replaceChartTotal, replaceCalculateTotal, err
  859. }
  860. edbInfoList = append(edbInfoList, edbInfo)
  861. }
  862. //清除历史数据
  863. err = DeleteCalculateData(edbInfoId)
  864. if err != nil {
  865. errmsg = "清空运算指标失败:Err:" + err.Error() + " edb_info_id:" + strconv.Itoa(edbInfoId)
  866. return replaceChartTotal, replaceCalculateTotal, err
  867. }
  868. err = Calculate(edbInfoList, int(edbInfoId), edbCode, edbInfo.CalculateFormula, edbInfoIdBytes)
  869. if err != nil {
  870. errmsg = "生成计算指标失败,Calculate Err:" + err.Error()
  871. return replaceChartTotal, replaceCalculateTotal, err
  872. }
  873. } else if source == utils.DATA_SOURCE_CALCULATE_LJZZY {
  874. _, err = AddCalculateLjzzy(req, fromEdbInfo, edbCode, uniqueCode, sysAdminId, sysAdminRealName)
  875. } else if source == utils.DATA_SOURCE_CALCULATE_TBZ {
  876. sourName = "同比值"
  877. edbInfoId, err = AddCalculateTbz(req, fromEdbInfo, edbCode, uniqueCode, sysAdminId, sysAdminRealName)
  878. } else if source == utils.DATA_SOURCE_CALCULATE_TCZ {
  879. sourName = "同差值"
  880. edbInfoId, err = AddCalculateTcz(req, fromEdbInfo, edbCode, uniqueCode, sysAdminId, sysAdminRealName)
  881. } else if source == utils.DATA_SOURCE_CALCULATE_NSZYDPJJS {
  882. sourName = "N数值移动平均计算"
  883. formulaInt, _ := strconv.Atoi(edbInfo.CalculateFormula)
  884. edbInfoId, err = AddCalculateNszydpjjs(req, fromEdbInfo, edbCode, uniqueCode, sysAdminId, sysAdminRealName, formulaInt)
  885. } else if source == utils.DATA_SOURCE_CALCULATE_HBZ {
  886. sourName = "环比值"
  887. formulaInt, _ := strconv.Atoi(edbInfo.CalculateFormula)
  888. edbInfoId, err = AddCalculateHbz(req, fromEdbInfo, edbCode, uniqueCode, sysAdminId, sysAdminRealName, formulaInt)
  889. } else if source == utils.DATA_SOURCE_CALCULATE_HCZ {
  890. sourName = "环差值"
  891. formulaInt, _ := strconv.Atoi(edbInfo.CalculateFormula)
  892. edbInfoId, err = AddCalculateHcz(req, fromEdbInfo, edbCode, uniqueCode, sysAdminId, sysAdminRealName, formulaInt)
  893. } else if source == utils.DATA_SOURCE_CALCULATE_BP {
  894. sourName = "变频"
  895. fmt.Println("变频", req, fromEdbInfo, edbCode, uniqueCode, sysAdminId, sysAdminRealName)
  896. edbInfoId, err = AddCalculateBp(req, fromEdbInfo, edbCode, uniqueCode, sysAdminId, sysAdminRealName)
  897. } else {
  898. errmsg = "无效计算方式,source:" + strconv.Itoa(source)
  899. return replaceChartTotal, replaceCalculateTotal, err
  900. }
  901. maxAndMinItem, err := GetEdbInfoMaxAndMinInfo(source, edbCode)
  902. if err != nil && err.Error() != utils.ErrNoRow() {
  903. errmsg = "生成" + sourName + "失败,GetEdbInfoMaxAndMinInfo Err:" + err.Error()
  904. return replaceChartTotal, replaceCalculateTotal, err
  905. }
  906. if maxAndMinItem != nil {
  907. err = ModifyEdbInfoMaxAndMinInfo(edbInfoId, maxAndMinItem)
  908. }
  909. }
  910. }
  911. return
  912. }
  913. // EdbInfoReplaceV2 替换指标v2版本(更换时间:2022年01月05日15:33:42)
  914. //func EdbInfoReplaceV2(oldEdbInfo, newEdbInfo *EdbInfo, sysAdminId int, sysAdminRealName string) (mappingList,replaceChartTotal, replaceCalculateTotal int, err error) {
  915. // defer func() {
  916. // if err != nil {
  917. // fmt.Println("ERR:", err.Error())
  918. // }
  919. // }()
  920. //
  921. // // 替换关联表中的source_edb_info_id
  922. // mappingList, replaceChartTotal, replaceCalculateTotal, err := replaceChartEdb(oldEdbInfo, newEdbInfo)
  923. // if err != nil {
  924. // return
  925. // }
  926. // err = replaceRelationEdbInfo(mappingList, oldEdbInfo, newEdbInfo, sysAdminId, sysAdminRealName)
  927. // return
  928. //}
  929. // ReplaceChartEdb 替换图表中的指标
  930. func ReplaceChartEdb(oldEdbInfo, newEdbInfo *EdbInfo) (relationEdbInfoIdList []int, replaceChartTotal, replaceCalculateTotal int, err error) {
  931. var errmsg string
  932. relationEdbInfoIdList = make([]int, 0) // 关联的指标id
  933. logMsg := `` // 记录替换的日志
  934. o := orm.NewOrmUsingDB("data")
  935. to, err := o.Begin()
  936. if err != nil {
  937. return
  938. }
  939. defer func() {
  940. if err != nil {
  941. _ = to.Rollback()
  942. } else {
  943. _ = to.Commit()
  944. if logMsg != `` {
  945. utils.FileLog.Info(fmt.Sprintf("替换指标记录,旧的指标id:%d,新的指标id:%d;%s", oldEdbInfo.EdbInfoId, newEdbInfo.EdbInfoId, logMsg))
  946. }
  947. }
  948. if errmsg != "" {
  949. fmt.Println("errmsg:" + errmsg)
  950. }
  951. if err != nil && errmsg != "" {
  952. go alarm_msg.SendAlarmMsg("替换图表中的指标失败提醒,errmsg:"+errmsg, 3)
  953. //go utils.SendEmail(utils.APPNAME+"【"+utils.RunMode+"】"+"替换指标失败提醒", "errmsg:"+errmsg, utils.EmailSendToUsers)
  954. }
  955. }()
  956. //替换图表
  957. {
  958. chartEdbMappingList := make([]*ChartEdbInfoMapping, 0)
  959. csql := `SELECT * FROM chart_edb_mapping WHERE edb_info_id=?`
  960. _, err = to.Raw(csql, oldEdbInfo.EdbInfoId).QueryRows(&chartEdbMappingList)
  961. if err != nil {
  962. errmsg = "获取指标关联图表信息失败:Err:" + err.Error()
  963. return
  964. }
  965. replaceChartTotal = len(chartEdbMappingList)
  966. if len(chartEdbMappingList) > 0 {
  967. chartInfoIdList := make([]string, 0)
  968. for _, mv := range chartEdbMappingList {
  969. //获取图表所有指标信息
  970. chartEdbList := make([]*ChartEdbInfoMapping, 0)
  971. csql := `SELECT * FROM chart_edb_mapping WHERE chart_info_id=?`
  972. _, err = to.Raw(csql, mv.ChartInfoId).QueryRows(&chartEdbList)
  973. if err != nil {
  974. errmsg = "获取图表所有指标信息失败:Err:" + err.Error()
  975. return
  976. }
  977. var minData, maxData float64
  978. minData = newEdbInfo.MinValue
  979. maxData = newEdbInfo.MaxValue
  980. for _, cv := range chartEdbList {
  981. if mv.IsAxis == cv.IsAxis {
  982. if minData > cv.MinData {
  983. minData = cv.MinData
  984. }
  985. if maxData < cv.MaxData {
  986. maxData = cv.MaxData
  987. }
  988. }
  989. }
  990. //修改图表关联指标
  991. rsql := ` UPDATE chart_edb_mapping SET edb_info_id=?,max_data=?,min_data=?,modify_time=NOW() WHERE chart_edb_mapping_id=? `
  992. _, err = to.Raw(rsql, newEdbInfo.EdbInfoId, maxData, minData, mv.ChartEdbMappingId).Exec()
  993. if err != nil {
  994. errmsg = "更新图库指标信息失败:Err:" + err.Error()
  995. return
  996. }
  997. chartInfoIdList = append(chartInfoIdList, fmt.Sprint(mv.ChartInfoId))
  998. }
  999. logMsg += `涉及到的图表id:` + strings.Join(chartInfoIdList, ",") + ";"
  1000. }
  1001. }
  1002. //替换计算指标
  1003. {
  1004. //获取所有包含的计算指标
  1005. mappingList := make([]*EdbInfoCalculateMapping, 0)
  1006. msql := ` SELECT * FROM edb_info_calculate_mapping WHERE from_edb_info_id=? GROUP BY edb_info_id `
  1007. _, err = to.Raw(msql, oldEdbInfo.EdbInfoId).QueryRows(&mappingList)
  1008. if err != nil {
  1009. errmsg = "获取计算指标关联基础指标信息失败:Err:" + err.Error()
  1010. return
  1011. }
  1012. replaceCalculateTotal = len(mappingList)
  1013. //计算指标
  1014. if len(mappingList) > 0 {
  1015. edbInfoIdList := make([]string, 0)
  1016. for _, mv := range mappingList {
  1017. //如果即将替换的指标与当前指标id一致,那么就退出当前循环,进入下一循环
  1018. if mv.EdbInfoId == newEdbInfo.EdbInfoId {
  1019. continue
  1020. }
  1021. //替换原指标
  1022. msql := `UPDATE edb_info_calculate_mapping SET from_edb_info_id=?,from_edb_code=?,from_edb_name=?,from_source=?,from_source_name=? WHERE edb_info_calculate_mapping_id=? `
  1023. _, err = to.Raw(msql, newEdbInfo.EdbInfoId, newEdbInfo.EdbCode, newEdbInfo.EdbName, newEdbInfo.Source, newEdbInfo.SourceName, mv.EdbInfoCalculateMappingId).Exec()
  1024. if err != nil {
  1025. return
  1026. }
  1027. relationEdbInfoIdList = append(relationEdbInfoIdList, mv.EdbInfoId)
  1028. edbInfoIdList = append(edbInfoIdList, fmt.Sprint(mv.EdbInfoId))
  1029. }
  1030. logMsg += `涉及到的指标id:` + strings.Join(edbInfoIdList, ",") + ";"
  1031. }
  1032. }
  1033. // 替换预测指标中的来源指标
  1034. {
  1035. //获取所有包含的计算指标
  1036. predictEdbConfList := make([]*PredictEdbConf, 0)
  1037. msql := ` SELECT * FROM predict_edb_conf WHERE source_edb_info_id=? GROUP BY predict_edb_info_id `
  1038. _, err = to.Raw(msql, oldEdbInfo.EdbInfoId).QueryRows(&predictEdbConfList)
  1039. if err != nil {
  1040. errmsg = "获取关联的预测指标信息失败:Err:" + err.Error()
  1041. return
  1042. }
  1043. replaceCalculateTotal += len(predictEdbConfList)
  1044. //替换预测指标的来源指标
  1045. msql = `UPDATE predict_edb_conf SET source_edb_info_id=? WHERE source_edb_info_id=? `
  1046. _, err = to.Raw(msql, newEdbInfo.EdbInfoId, oldEdbInfo.EdbInfoId).Exec()
  1047. if err != nil {
  1048. return
  1049. }
  1050. if len(predictEdbConfList) > 0 {
  1051. edbInfoIdList := make([]string, 0)
  1052. for _, v := range predictEdbConfList {
  1053. relationEdbInfoIdList = append(relationEdbInfoIdList, v.PredictEdbInfoId)
  1054. edbInfoIdList = append(edbInfoIdList, fmt.Sprint(v.PredictEdbInfoId))
  1055. }
  1056. logMsg += `涉及到的预测指标id:` + strings.Join(edbInfoIdList, ",") + ";"
  1057. }
  1058. }
  1059. return
  1060. }
  1061. // replaceRelationEdbInfo 替换关联指标
  1062. func replaceRelationEdbInfo(mappingList []*EdbInfoCalculateMapping, oldEdbInfo, newEdbInfo *EdbInfo, sysAdminId int, sysAdminRealName string) (err error) {
  1063. errmsg := ``
  1064. defer func() {
  1065. if errmsg != "" {
  1066. fmt.Println("errmsg:" + errmsg)
  1067. }
  1068. if err != nil && errmsg != "" {
  1069. go alarm_msg.SendAlarmMsg("替换关联指标失败提醒,errmsg:"+errmsg, 3)
  1070. //go utils.SendEmail(utils.APPNAME+"【"+utils.RunMode+"】"+"替换指标失败提醒", "errmsg:"+errmsg, utils.EmailSendToUsers)
  1071. }
  1072. }()
  1073. //获取计算指标关联指标
  1074. allMappingList := make([]*EdbInfoCalculateMapping, 0)
  1075. allMapping := make(map[int]int)
  1076. tmpMapping := make(map[int]int)
  1077. for _, v := range mappingList {
  1078. if _, ok := allMapping[v.EdbInfoId]; !ok {
  1079. allMappingList = append(allMappingList, v)
  1080. }
  1081. newList, _ := GetAllCalculateV2(v.EdbInfoId, newEdbInfo.EdbInfoId, tmpMapping)
  1082. for _, nv := range newList {
  1083. if _, ok := allMapping[v.EdbInfoId]; !ok {
  1084. allMappingList = append(allMappingList, nv)
  1085. }
  1086. allMapping[v.EdbInfoId] = v.EdbInfoId
  1087. }
  1088. allMapping[v.EdbInfoId] = v.EdbInfoId
  1089. }
  1090. for mk, mv := range allMappingList { //原指标关联的所有计算指标
  1091. fmt.Println("mk/mv", mk, mv)
  1092. //重新计算计算指标
  1093. {
  1094. edbInfo, tmpErr := GetEdbInfoById(mv.EdbInfoId) //计算指标
  1095. err = tmpErr
  1096. if err != nil {
  1097. if err.Error() == utils.ErrNoRow() {
  1098. errmsg = "计算指标已被删除"
  1099. } else {
  1100. errmsg = "获取计算指标失败:err:" + err.Error()
  1101. }
  1102. return
  1103. }
  1104. fromEdbInfoList, tmpErr := GetEdbInfoCalculateDetail(mv.EdbInfoId, edbInfo.Source)
  1105. err = tmpErr
  1106. if err != nil {
  1107. errmsg = "获取计算指标失败:err:" + err.Error()
  1108. return
  1109. }
  1110. if len(fromEdbInfoList) <= 0 {
  1111. errmsg = "计算指标所依赖指标不存在"
  1112. err = fmt.Errorf("计算指标所依赖指标不存在")
  1113. return
  1114. }
  1115. fromEdbInfoItem := fromEdbInfoList[0]
  1116. if fromEdbInfoItem == nil {
  1117. return
  1118. }
  1119. fromEdbInfo, tmpErr := GetEdbInfoById(fromEdbInfoItem.FromEdbInfoId)
  1120. err = tmpErr
  1121. if err != nil {
  1122. errmsg = "获取计算指标 来源指标失败:err:" + err.Error()
  1123. return
  1124. }
  1125. edbCode := edbInfo.EdbCode
  1126. uniqueCode := edbInfo.UniqueCode
  1127. sourName := edbInfo.SourceName
  1128. source := edbInfo.Source
  1129. edbInfoId := edbInfo.EdbInfoId
  1130. req := new(EdbInfoCalculateBatchSaveReq)
  1131. req.EdbInfoId = edbInfoId
  1132. req.EdbName = edbInfo.EdbName
  1133. req.Frequency = edbInfo.Frequency
  1134. req.Unit = edbInfo.Unit
  1135. req.ClassifyId = edbInfo.ClassifyId
  1136. req.FromEdbInfoId = fromEdbInfoList[0].FromEdbInfoId
  1137. if source == utils.DATA_SOURCE_CALCULATE {
  1138. //检验公式
  1139. var formulaStr string
  1140. var edbInfoIdBytes []string
  1141. for _, v := range fromEdbInfoList {
  1142. formulaStr += v.FromTag + ","
  1143. edbInfoIdBytes = append(edbInfoIdBytes, v.FromTag)
  1144. }
  1145. formulaStr = strings.Trim(formulaStr, ",")
  1146. formulaMap := CheckFormula(edbInfo.CalculateFormula)
  1147. for _, v := range formulaMap {
  1148. if !strings.Contains(formulaStr, v) {
  1149. errmsg = "公式错误,请重新填写"
  1150. err = fmt.Errorf("公式错误,请重新填写")
  1151. return
  1152. }
  1153. }
  1154. edbInfoList := make([]*EdbInfo, 0)
  1155. for _, v := range fromEdbInfoList {
  1156. edbInfo, tmpErr := GetEdbInfoById(v.FromEdbInfoId)
  1157. err = tmpErr
  1158. if err != nil {
  1159. if err.Error() == utils.ErrNoRow() {
  1160. errmsg = "指标 " + strconv.Itoa(v.FromEdbInfoId) + " 不存在"
  1161. } else {
  1162. errmsg = "获取指标失败:Err:" + err.Error()
  1163. }
  1164. return
  1165. }
  1166. edbInfoList = append(edbInfoList, edbInfo)
  1167. }
  1168. //清除历史数据
  1169. err = DeleteCalculateData(edbInfoId)
  1170. if err != nil {
  1171. errmsg = "清空运算指标失败:Err:" + err.Error() + " edb_info_id:" + strconv.Itoa(edbInfoId)
  1172. return
  1173. }
  1174. err = Calculate(edbInfoList, int(edbInfoId), edbCode, edbInfo.CalculateFormula, edbInfoIdBytes)
  1175. if err != nil {
  1176. errmsg = "生成计算指标失败,Calculate Err:" + err.Error()
  1177. return
  1178. }
  1179. } else if source == utils.DATA_SOURCE_CALCULATE_LJZZY {
  1180. _, err = AddCalculateLjzzy(req, fromEdbInfo, edbCode, uniqueCode, sysAdminId, sysAdminRealName)
  1181. } else if source == utils.DATA_SOURCE_CALCULATE_TBZ {
  1182. sourName = "同比值"
  1183. edbInfoId, err = AddCalculateTbz(req, fromEdbInfo, edbCode, uniqueCode, sysAdminId, sysAdminRealName)
  1184. } else if source == utils.DATA_SOURCE_CALCULATE_TCZ {
  1185. sourName = "同差值"
  1186. edbInfoId, err = AddCalculateTcz(req, fromEdbInfo, edbCode, uniqueCode, sysAdminId, sysAdminRealName)
  1187. } else if source == utils.DATA_SOURCE_CALCULATE_NSZYDPJJS {
  1188. sourName = "N数值移动平均计算"
  1189. formulaInt, _ := strconv.Atoi(edbInfo.CalculateFormula)
  1190. edbInfoId, err = AddCalculateNszydpjjs(req, fromEdbInfo, edbCode, uniqueCode, sysAdminId, sysAdminRealName, formulaInt)
  1191. } else if source == utils.DATA_SOURCE_CALCULATE_HBZ {
  1192. sourName = "环比值"
  1193. formulaInt, _ := strconv.Atoi(edbInfo.CalculateFormula)
  1194. edbInfoId, err = AddCalculateHbz(req, fromEdbInfo, edbCode, uniqueCode, sysAdminId, sysAdminRealName, formulaInt)
  1195. } else if source == utils.DATA_SOURCE_CALCULATE_HCZ {
  1196. sourName = "环差值"
  1197. formulaInt, _ := strconv.Atoi(edbInfo.CalculateFormula)
  1198. edbInfoId, err = AddCalculateHcz(req, fromEdbInfo, edbCode, uniqueCode, sysAdminId, sysAdminRealName, formulaInt)
  1199. } else if source == utils.DATA_SOURCE_CALCULATE_BP {
  1200. sourName = "变频"
  1201. fmt.Println("变频", req, fromEdbInfo, edbCode, uniqueCode, sysAdminId, sysAdminRealName)
  1202. edbInfoId, err = AddCalculateBp(req, fromEdbInfo, edbCode, uniqueCode, sysAdminId, sysAdminRealName)
  1203. } else if source == utils.DATA_SOURCE_CALCULATE_TIME_SHIFT {
  1204. req2 := &EdbInfoCalculateBatchEditReq{
  1205. EdbName: edbInfo.EdbName,
  1206. Frequency: edbInfo.Frequency,
  1207. Unit: edbInfo.Unit,
  1208. ClassifyId: edbInfo.ClassifyId,
  1209. Formula: edbInfo.CalculateFormula,
  1210. EdbInfoId: edbInfo.EdbInfoId,
  1211. FromEdbInfoId: fromEdbInfoList[0].FromEdbInfoId,
  1212. Source: edbInfo.Source,
  1213. MoveType: edbInfo.MoveType,
  1214. MoveFrequency: edbInfo.MoveFrequency,
  1215. }
  1216. sourName = "时间移位"
  1217. edbInfoId, err = EditCalculateTimeShift(req2, fromEdbInfo, edbCode, edbInfo)
  1218. } else if source == utils.DATA_SOURCE_CALCULATE_ZJPJ {
  1219. edbInfoIdArr := make([]EdbInfoFromTag, 0)
  1220. //A指标
  1221. aFromEdbInfoId := fromEdbInfoList[0].FromEdbInfoId
  1222. for _, v := range fromEdbInfoList {
  1223. if v.FromTag == "A" {
  1224. if v.FromEdbInfoId == oldEdbInfo.EdbInfoId {
  1225. aFromEdbInfoId = newEdbInfo.EdbInfoId
  1226. } else {
  1227. aFromEdbInfoId = fromEdbInfoList[0].FromEdbInfoId
  1228. }
  1229. }
  1230. if v.FromTag == "B" {
  1231. if v.FromEdbInfoId == oldEdbInfo.EdbInfoId {
  1232. edbInfoIdArr = append(edbInfoIdArr, EdbInfoFromTag{
  1233. EdbInfoId: newEdbInfo.EdbInfoId,
  1234. FromTag: v.FromTag,
  1235. MoveValue: v.MoveValue,
  1236. })
  1237. } else {
  1238. edbInfoIdArr = append(edbInfoIdArr, EdbInfoFromTag{
  1239. EdbInfoId: v.FromEdbInfoId,
  1240. FromTag: v.FromTag,
  1241. MoveValue: v.MoveValue,
  1242. })
  1243. }
  1244. }
  1245. }
  1246. req2 := &EdbInfoCalculateBatchEditReq{
  1247. EdbName: edbInfo.EdbName,
  1248. Frequency: edbInfo.Frequency,
  1249. Unit: edbInfo.Unit,
  1250. ClassifyId: edbInfo.ClassifyId,
  1251. Formula: edbInfo.CalculateFormula,
  1252. EdbInfoId: edbInfo.EdbInfoId,
  1253. FromEdbInfoId: aFromEdbInfoId,
  1254. Source: edbInfo.Source,
  1255. MoveType: edbInfo.MoveType,
  1256. MoveFrequency: edbInfo.MoveFrequency,
  1257. EdbInfoIdArr: edbInfoIdArr,
  1258. }
  1259. sourName = "直接拼接"
  1260. if len(req2.EdbInfoIdArr) != 1 {
  1261. errmsg = "请传入拼接日期之后的指标"
  1262. err = fmt.Errorf("请传入拼接日期之后的指标")
  1263. return
  1264. }
  1265. secondEdbInfoReq := req2.EdbInfoIdArr[0]
  1266. secondEdbInfo, tmpErr := GetEdbInfoById(secondEdbInfoReq.EdbInfoId)
  1267. err = tmpErr
  1268. if err != nil {
  1269. errmsg = "获取拼接日期之后的指标信息失败:Err:" + err.Error()
  1270. err = fmt.Errorf("获取拼接日期之后的指标信息失败:Err:" + err.Error())
  1271. return
  1272. }
  1273. if fromEdbInfo.EdbInfoId == secondEdbInfo.EdbInfoId {
  1274. errmsg = "两个指标不允许为同一个"
  1275. err = fmt.Errorf("两个指标不允许为同一个")
  1276. return
  1277. }
  1278. tmpEdbInfoId, tmpErr := EditCalculateZjpj(req2, edbInfo, fromEdbInfo, secondEdbInfo)
  1279. err = tmpErr
  1280. edbInfoId = tmpEdbInfoId
  1281. } else if source == utils.DATA_SOURCE_CALCULATE_LJZTBPJ { //累计值同比拼接
  1282. edbInfoIdArr := make([]EdbInfoFromTag, 0)
  1283. //A指标
  1284. aFromEdbInfoId := fromEdbInfoList[0].FromEdbInfoId
  1285. for _, v := range fromEdbInfoList {
  1286. if v.FromTag == "A" {
  1287. if v.FromEdbInfoId == oldEdbInfo.EdbInfoId {
  1288. aFromEdbInfoId = newEdbInfo.EdbInfoId
  1289. } else {
  1290. aFromEdbInfoId = fromEdbInfoList[0].FromEdbInfoId
  1291. }
  1292. }
  1293. if v.FromTag == "B" {
  1294. if v.FromEdbInfoId == oldEdbInfo.EdbInfoId {
  1295. edbInfoIdArr = append(edbInfoIdArr, EdbInfoFromTag{
  1296. EdbInfoId: newEdbInfo.EdbInfoId,
  1297. FromTag: v.FromTag,
  1298. MoveValue: v.MoveValue,
  1299. })
  1300. } else {
  1301. edbInfoIdArr = append(edbInfoIdArr, EdbInfoFromTag{
  1302. EdbInfoId: v.FromEdbInfoId,
  1303. FromTag: v.FromTag,
  1304. MoveValue: v.MoveValue,
  1305. })
  1306. }
  1307. }
  1308. }
  1309. req2 := &EdbInfoCalculateBatchEditReq{
  1310. EdbName: edbInfo.EdbName,
  1311. Frequency: edbInfo.Frequency,
  1312. Unit: edbInfo.Unit,
  1313. ClassifyId: edbInfo.ClassifyId,
  1314. Formula: edbInfo.CalculateFormula,
  1315. EdbInfoId: edbInfo.EdbInfoId,
  1316. FromEdbInfoId: aFromEdbInfoId,
  1317. Source: edbInfo.Source,
  1318. MoveType: edbInfo.MoveType,
  1319. MoveFrequency: edbInfo.MoveFrequency,
  1320. EdbInfoIdArr: edbInfoIdArr,
  1321. }
  1322. sourName = "累计值同比拼接"
  1323. if fromEdbInfo.Frequency != "月度" {
  1324. errmsg = "累计值同比拼接,待拼接指标只能筛选月度指标"
  1325. err = fmt.Errorf("累计值同比拼接,待拼接指标只能筛选月度指标")
  1326. return
  1327. }
  1328. if len(req2.EdbInfoIdArr) != 1 {
  1329. errmsg = "请传入同比值指标"
  1330. err = fmt.Errorf("请传入同比值指标")
  1331. return
  1332. }
  1333. secondEdbInfoReq := req2.EdbInfoIdArr[0]
  1334. tbzEdbInfo, tmpErr := GetEdbInfoById(secondEdbInfoReq.EdbInfoId)
  1335. err = tmpErr
  1336. if err != nil {
  1337. errmsg = "获取同比值指标信息失败:Err:" + err.Error()
  1338. err = fmt.Errorf("获取同比值指标信息失败:Err:" + err.Error())
  1339. return
  1340. }
  1341. if tbzEdbInfo.Source != utils.DATA_SOURCE_CALCULATE_TBZ {
  1342. errmsg = "指标必须是传入同比值指标类型"
  1343. err = fmt.Errorf("指标必须是传入同比值指标类型")
  1344. return
  1345. }
  1346. if tbzEdbInfo.Frequency != "月度" {
  1347. errmsg = "同比值指标只能筛选月度指标"
  1348. err = fmt.Errorf("同比值指标只能筛选月度指标")
  1349. return
  1350. }
  1351. if fromEdbInfo.EdbInfoId == tbzEdbInfo.EdbInfoId {
  1352. errmsg = "两个指标不允许为同一个"
  1353. err = fmt.Errorf("两个指标不允许为同一个")
  1354. return
  1355. }
  1356. tmpEdbInfoId, tmpErr := EditCalculateLjztbpj(req2, edbInfo, fromEdbInfo, tbzEdbInfo)
  1357. err = tmpErr
  1358. edbInfoId = tmpEdbInfoId
  1359. } else if source == utils.DATA_SOURCE_PYTHON {
  1360. //python代码运算的过滤
  1361. continue
  1362. } else {
  1363. errmsg = "无效计算方式,source:" + strconv.Itoa(source)
  1364. err = fmt.Errorf("无效计算方式,source:" + strconv.Itoa(source))
  1365. return
  1366. }
  1367. maxAndMinItem, tmpErr := GetEdbInfoMaxAndMinInfo(source, edbCode)
  1368. err = tmpErr
  1369. if err != nil && err.Error() != utils.ErrNoRow() {
  1370. errmsg = "生成" + sourName + "失败,GetEdbInfoMaxAndMinInfo Err:" + err.Error()
  1371. err = fmt.Errorf("生成" + sourName + "失败,GetEdbInfoMaxAndMinInfo Err:" + err.Error())
  1372. return
  1373. }
  1374. if maxAndMinItem != nil {
  1375. err = ModifyEdbInfoMaxAndMinInfo(edbInfoId, maxAndMinItem)
  1376. }
  1377. }
  1378. }
  1379. return
  1380. }
  1381. type EdbInfoView struct {
  1382. EdbInfoId int `orm:"column(edb_info_id);pk"`
  1383. EdbInfoType int `description:"指标类型,0:普通指标,1:预测指标"`
  1384. SourceName string `description:"来源名称"`
  1385. Source int `description:"来源id"`
  1386. EdbCode string `description:"指标编码"`
  1387. EdbName string `description:"指标名称"`
  1388. EdbNameSource string `description:"指标名称来源"`
  1389. Frequency string `description:"频率"`
  1390. Unit string `description:"单位"`
  1391. StartDate string `description:"起始日期"`
  1392. EndDate string `description:"终止日期"`
  1393. ClassifyId int `description:"分类id"`
  1394. SysUserId int
  1395. SysUserRealName string
  1396. UniqueCode string `description:"指标唯一编码"`
  1397. CreateTime string
  1398. ModifyTime string
  1399. MinValue float64 `description:"指标最小值"`
  1400. MaxValue float64 `description:"指标最大值"`
  1401. CalculateFormula string `description:"计算公式"`
  1402. EdbType int `description:"指标类型:1:基础指标,2:计算指标"`
  1403. Sort int `description:"排序字段"`
  1404. IsUpdate int `description:"当天是否已更新,1:未更新,2:已更新"`
  1405. LatestDate string `description:"数据最新日期"`
  1406. LatestValue float64 `description:"数据最新值"`
  1407. }
  1408. // 获取指标的所有计算指标,以及计算指标所依赖计算指标
  1409. func GetAllCalculateByEdbInfoId(edbInfoId int) (mappingList []*EdbInfoCalculateMapping, err error) {
  1410. o := orm.NewOrmUsingDB("data")
  1411. msql := ` SELECT * FROM edb_info_calculate_mapping WHERE from_edb_info_id=? GROUP BY edb_info_id `
  1412. _, err = o.Raw(msql, edbInfoId).QueryRows(&mappingList)
  1413. if err != nil {
  1414. return
  1415. }
  1416. return
  1417. }
  1418. func GetAllCalculate(edbInfoId int, edbInfoMap map[int]int) (mappingList []*EdbInfoCalculateMapping, err error) {
  1419. calculateList, err := GetAllCalculateByEdbInfoId(edbInfoId)
  1420. if err != nil && err.Error() != utils.ErrNoRow() {
  1421. return
  1422. }
  1423. for _, item := range calculateList {
  1424. _, ok := edbInfoMap[item.EdbInfoId]
  1425. if !ok {
  1426. edbInfoMap[item.EdbInfoId] = item.EdbInfoId
  1427. mappingList = append(mappingList, item)
  1428. newCalculateInfoArr, _ := GetAllCalculate(item.EdbInfoId, edbInfoMap)
  1429. mappingList = append(mappingList, newCalculateInfoArr...)
  1430. }
  1431. }
  1432. return
  1433. }
  1434. // GetAllCalculateByEdbInfoIdV2 获取计算指标的所有所依赖的指标(基础指标+计算指标)
  1435. func GetAllCalculateByEdbInfoIdV2(edbInfoId int) (mappingList []*EdbInfoCalculateMapping, err error) {
  1436. o := orm.NewOrmUsingDB("data")
  1437. msql := ` SELECT * FROM edb_info_calculate_mapping WHERE edb_info_id=? GROUP BY from_edb_info_id `
  1438. _, err = o.Raw(msql, edbInfoId).QueryRows(&mappingList)
  1439. if err != nil {
  1440. return
  1441. }
  1442. return
  1443. }
  1444. // GetAllCalculateV2 获取所有的指标(如果下层指标包含了待替换指标,那么就不加入)
  1445. func GetAllCalculateV2(oldEdbInfoId, replaceEdbInfoId int, edbInfoMap map[int]int) (mappingList []*EdbInfoCalculateMapping, err error) {
  1446. calculateList, err := GetAllCalculateByEdbInfoId(oldEdbInfoId)
  1447. if err != nil && err.Error() != utils.ErrNoRow() {
  1448. return
  1449. }
  1450. tmpMappingList := make([]*EdbInfoCalculateMapping, 0)
  1451. for _, item := range calculateList {
  1452. //如果计算指标里面存在即将替换的指标id,那么退出当前循环,进入下一循环
  1453. if item.EdbInfoId == replaceEdbInfoId {
  1454. err = fmt.Errorf("指标重复1")
  1455. return
  1456. }
  1457. //获取该指标的依赖指标列表,如果依赖指标列表中存在即将替换的指标,那么过滤该指标
  1458. childCalculateList, tmpErr := GetAllCalculateByEdbInfoIdV2(item.EdbInfoId)
  1459. if tmpErr != nil && tmpErr.Error() != utils.ErrNoRow() {
  1460. err = tmpErr
  1461. return
  1462. }
  1463. for _, childCalculate := range childCalculateList {
  1464. if childCalculate.FromEdbInfoId == replaceEdbInfoId {
  1465. err = fmt.Errorf("指标重复2")
  1466. return
  1467. }
  1468. }
  1469. _, ok := edbInfoMap[item.EdbInfoId]
  1470. if !ok {
  1471. edbInfoMap[item.EdbInfoId] = item.EdbInfoId
  1472. newCalculateInfoArr, tmpErr := GetAllCalculateV2(item.EdbInfoId, replaceEdbInfoId, edbInfoMap)
  1473. if tmpErr != nil {
  1474. err = tmpErr
  1475. continue
  1476. } else {
  1477. mappingList = append(mappingList, item)
  1478. tmpMappingList = append(tmpMappingList, newCalculateInfoArr...)
  1479. }
  1480. }
  1481. }
  1482. mappingList = append(mappingList, tmpMappingList...)
  1483. return
  1484. }
  1485. // EdbInfoFilterDataResp 搜索指标列表数据返回
  1486. type EdbInfoFilterDataResp struct {
  1487. Paging *paging.PagingItem
  1488. List []*EdbInfoList
  1489. }
  1490. // GetEdbInfoFilterList 获取指指标列表数据接口
  1491. func GetEdbInfoFilterList(condition string, pars []interface{}, startSize, pageSize int) (total int64, list []*EdbInfoList, err error) {
  1492. o := orm.NewOrmUsingDB("data")
  1493. sql := ` SELECT count(1) total FROM edb_info where 1=1 ` + condition + ` ORDER BY edb_info_id DESC `
  1494. err = o.Raw(sql, pars).QueryRow(&total)
  1495. if err != nil {
  1496. return
  1497. }
  1498. sql = ` SELECT * FROM edb_info where 1=1 ` + condition + ` ORDER BY edb_info_id DESC LIMIT ?,? `
  1499. _, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&list)
  1500. return
  1501. }
  1502. // SetEdbInfoImageReq 设置指标图片
  1503. type SetEdbInfoImageReq struct {
  1504. EdbInfoId int `description:"指标ID"`
  1505. ImageUrl string `description:"指标图片地址"`
  1506. }
  1507. // GetNextEdbInfoByCondition 根据条件获取下一个指标
  1508. func GetNextEdbInfoByCondition(condition string, pars []interface{}) (item *EdbInfo, err error) {
  1509. o := orm.NewOrmUsingDB("data")
  1510. sql := ` SELECT * FROM edb_info WHERE 1=1 `
  1511. if condition != "" {
  1512. sql += condition
  1513. }
  1514. sql += " ORDER BY sort asc , edb_info_id asc LIMIT 1 "
  1515. err = o.Raw(sql, pars).QueryRow(&item)
  1516. return
  1517. }
  1518. // GetNextEdbInfo 根据分类id获取下一个 指标
  1519. func GetNextEdbInfo(classifyId, classifySort, classifyType, edbInfoType int) (item *EdbInfo, err error) {
  1520. o := orm.NewOrmUsingDB("data")
  1521. sql := ` SELECT b.* FROM edb_classify AS a
  1522. INNER JOIN edb_info AS b ON a.classify_id=b.classify_id
  1523. WHERE (a.sort>? OR (a.sort=? and a.classify_id>?) )
  1524. AND a.classify_type=? AND b.edb_info_type=?
  1525. ORDER BY a.sort ASC,b.sort asc,b.edb_info_id asc
  1526. LIMIT 1 `
  1527. err = o.Raw(sql, classifySort, classifySort, classifyId, classifyType, edbInfoType).QueryRow(&item)
  1528. return
  1529. }
  1530. // GetEdbInfoByEdbCodeList 根据指标code集合获取指标列表
  1531. func GetEdbInfoByEdbCodeList(source int, edbCodeList []string) (items []*EdbInfo, err error) {
  1532. num := len(edbCodeList)
  1533. if num <= 0 {
  1534. return
  1535. }
  1536. o := orm.NewOrmUsingDB("data")
  1537. sql := ` SELECT * FROM edb_info WHERE source=? AND edb_code in (` + utils.GetOrmInReplace(num) + `) `
  1538. _, err = o.Raw(sql, source, edbCodeList).QueryRows(&items)
  1539. return
  1540. }
  1541. // GetEdbInfoByConditionCount 根据条件获取指标列表数据总数
  1542. func GetEdbInfoByConditionCount(condition string, pars []interface{}) (count int, err error) {
  1543. o := orm.NewOrmUsingDB("data")
  1544. sql := ` SELECT COUNT(1) AS count FROM edb_info WHERE 1=1 `
  1545. if condition != "" {
  1546. sql += condition
  1547. }
  1548. err = o.Raw(sql, pars).QueryRow(&count)
  1549. return
  1550. }
  1551. // GetEdbInfoListByCondition 根据条件获取指标列表数据
  1552. func GetEdbInfoListByCondition(condition string, pars []interface{}, startSize, pageSize int) (items []*EdbInfoList, err error) {
  1553. o := orm.NewOrmUsingDB("data")
  1554. sql := ` SELECT * FROM edb_info WHERE 1=1 `
  1555. if condition != "" {
  1556. sql += condition
  1557. }
  1558. sql += ` ORDER BY edb_info_id ASC LIMIT ?,? `
  1559. _, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&items)
  1560. return
  1561. }
  1562. // GetEdbInfoListV2ByCondition 根据条件获取指标列表数据(EdbInfo原始数据结构)
  1563. func GetEdbInfoListV2ByCondition(condition string, pars []interface{}, startSize, pageSize int) (items []*EdbInfo, err error) {
  1564. o := orm.NewOrmUsingDB("data")
  1565. sql := ` SELECT * FROM edb_info WHERE 1=1 `
  1566. if condition != "" {
  1567. sql += condition
  1568. }
  1569. sql += ` ORDER BY edb_info_id ASC LIMIT ?,? `
  1570. _, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&items)
  1571. return
  1572. }
  1573. // GetEdbInfoListGroupByUserId 根据指标id列表、用户分组获取指标信息
  1574. func GetEdbInfoListGroupByUserId(edbIdList []string) (items []*EdbInfo, err error) {
  1575. num := len(edbIdList)
  1576. if num <= 0 {
  1577. return
  1578. }
  1579. o := orm.NewOrmUsingDB("data")
  1580. sql := ` SELECT * FROM edb_info WHERE edb_info_id in (` + utils.GetOrmInReplace(num) + `) GROUP BY sys_user_id `
  1581. _, err = o.Raw(sql, edbIdList).QueryRows(&items)
  1582. return
  1583. }
  1584. // ModifyEdbInfoUserIdByCodeList 根据指标code列表修改创建人
  1585. func ModifyEdbInfoUserIdByCodeList(edbIdList []string, userId int, userName string) (err error) {
  1586. num := len(edbIdList)
  1587. if num <= 0 {
  1588. return
  1589. }
  1590. o := orm.NewOrmUsingDB("data")
  1591. sql := `UPDATE edb_info SET sys_user_id=?,sys_user_real_name=? WHERE edb_info_id in (` + utils.GetOrmInReplace(num) + `) `
  1592. _, err = o.Raw(sql, userId, userName, edbIdList).Exec()
  1593. return
  1594. }
  1595. // MoveEdbChartList 图表/指标信息
  1596. type MoveEdbChartList struct {
  1597. DataId string `description:"指标/图表唯一id"`
  1598. Code string `description:"指标code"`
  1599. Name string `description:"指标/图表名称"`
  1600. ClassifyName string `description:"分类名称"`
  1601. CreateUserId int `description:"创建人id"`
  1602. CreateUserName string `description:"创建人名称"`
  1603. }
  1604. // MoveEdbChartListResp 更改创建人返回数据
  1605. type MoveEdbChartListResp struct {
  1606. Paging *paging.PagingItem
  1607. List []MoveEdbChartList
  1608. }
  1609. // MoveEdbChartReq 转移指标/图表的请求
  1610. type MoveEdbChartReq struct {
  1611. Source int `description:"来源id"`
  1612. DataIdList []string `description:"指标/图表唯一id列表"`
  1613. NewUserId int `description:"新的创建人id"`
  1614. }
  1615. type EdbChartClassifyResp struct {
  1616. List []*EdbChartClassify
  1617. }
  1618. type EdbChartClassify struct {
  1619. ClassifyId int
  1620. ClassifyName string
  1621. ParentId int
  1622. Child []*EdbChartClassify
  1623. }
  1624. // EdbInfoDataSeasonalResp 指标季节性数据返回
  1625. type EdbInfoDataSeasonalResp struct {
  1626. EdbInfo *EdbInfo
  1627. DataList interface{}
  1628. }
  1629. // SetEdbDataInsertConfigReq 设置插入规则的请求
  1630. type SetEdbDataInsertConfigReq struct {
  1631. EdbInfoId int `description:"指标ID"`
  1632. Date string `description:"日期"`
  1633. Value float64 `description:"值"`
  1634. }
  1635. // GetEdbInfoByClassifyId 用于分类展示
  1636. func GetEdbInfoByClassifyId(classifyId, edbInfoType, adminId int) (items []*EdbClassifyItems, err error) {
  1637. o := orm.NewOrmUsingDB("data")
  1638. sql := ` SELECT edb_info_id,classify_id,edb_name_source AS classify_name,edb_name_en AS classify_name_en,unique_code,source_name,source,sys_user_id,sys_user_real_name,start_date,edb_code,edb_type, sort FROM edb_info WHERE classify_id = ? AND edb_info_type = ?`
  1639. pars := []interface{}{classifyId, edbInfoType}
  1640. // 如果筛选了用户id
  1641. if adminId > 0 {
  1642. sql += ` AND sys_user_id = ? `
  1643. pars = append(pars, adminId)
  1644. }
  1645. sql += ` order by sort asc,edb_info_id asc `
  1646. _, err = o.Raw(sql, pars).QueryRows(&items)
  1647. return
  1648. }
  1649. type EdbAndClassify struct {
  1650. EdbInfoId int `description:"指标id"`
  1651. EdbCode string `description:"指标code"`
  1652. UniqueCode string `description:"唯一code"`
  1653. EdbName string `description:"指标名称"`
  1654. FirstClassifyId int `description:"第1级的分类id"`
  1655. FirstClassifyName string `description:"第1级的分类名称"`
  1656. SecondClassifyId int `description:"第2级的分类id"`
  1657. SecondClassifyName string `description:"第2级的分类名称"`
  1658. }
  1659. // GetEdbInfoAndClassifyListByEdbIdList 根据指标id列表获取 指标及分类信息
  1660. func GetEdbInfoAndClassifyListByEdbIdList(edbIdList []int) (items []*EdbAndClassify, err error) {
  1661. num := len(edbIdList)
  1662. if num <= 0 {
  1663. return
  1664. }
  1665. o := orm.NewOrmUsingDB("data")
  1666. sql := ` SELECT a.edb_info_id,a.edb_code,a.unique_code,a.edb_name,b.classify_id as second_classify_id,b.classify_name as second_classify_name,c.classify_id as first_classify_id,c.classify_name as first_classify_name FROM edb_info AS a
  1667. JOIN edb_classify b on a.classify_id=b.classify_id
  1668. JOIN edb_classify c on b.parent_id=c.classify_id
  1669. WHERE a.edb_info_id in (` + utils.GetOrmInReplace(num) + `) `
  1670. _, err = o.Raw(sql, edbIdList).QueryRows(&items)
  1671. return
  1672. }
  1673. // TraceEdbInfoResp 指标追溯数据返回
  1674. type TraceEdbInfoResp struct {
  1675. EdbInfoId int `description:"指标id"`
  1676. EdbInfoType int `description:"指标类型: 0-普通指标; 1-预测指标"`
  1677. EdbName string `description:"指标名称"`
  1678. EdbType int `description:"指标类型: 1-基础指标; 2-计算指标"`
  1679. RuleTitle string `description:"指标规则"`
  1680. UniqueCode string `description:"唯一编码"`
  1681. ClassifyId int `description:"分类ID"`
  1682. Child []TraceEdbInfoResp `description:"下级来源"`
  1683. EdbInfo *EdbInfo `description:"指标信息" json:"-"`
  1684. }
  1685. // BeforeAndAfterDateDataResp 前后几期数据
  1686. type BeforeAndAfterDateDataResp struct {
  1687. List []*EdbDataList `description:"list"`
  1688. Date string `description:"实际日期"`
  1689. }
  1690. // GetEdbInfoAdminList
  1691. func GetEdbInfoAdminList(edbType int) (list []int, err error) {
  1692. o := orm.NewOrmUsingDB("data")
  1693. sql := ` SELECT sys_user_id FROM edb_info WHERE edb_info_type = ? GROUP BY sys_user_id `
  1694. _, err = o.Raw(sql, edbType).QueryRows(&list)
  1695. return
  1696. }
  1697. type EdbInfoExistCheckResp struct {
  1698. IndexExist bool `description:"指标是否存在:true,存在,false:不存在"`
  1699. ExistStockCodeArr []string `description:"存在的证券代码"`
  1700. ExistEdbCodeArr []string `description:"存在的指标代码"`
  1701. }