edb_info.go 78 KB

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