edb_info.go 80 KB

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