edb_info.go 68 KB

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