edb_info.go 61 KB

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