chart_info.go 72 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910
  1. package data_manage
  2. import (
  3. "errors"
  4. "eta/eta_mobile/utils"
  5. "fmt"
  6. "github.com/beego/beego/v2/client/orm"
  7. "github.com/rdlucklib/rdluck_tools/paging"
  8. "strconv"
  9. "strings"
  10. "time"
  11. )
  12. type ChartInfo struct {
  13. ChartInfoId int `orm:"column(chart_info_id);pk"`
  14. ChartName string `description:"来源名称"`
  15. ChartNameEn string `description:"英文图表名称"`
  16. ChartClassifyId int `description:"图表分类id"`
  17. SysUserId int
  18. SysUserRealName string
  19. UniqueCode string `description:"图表唯一编码"`
  20. CreateTime time.Time
  21. ModifyTime time.Time
  22. DateType int `description:"日期类型:1:00年至今,2:10年至今,3:15年至今,4:年初至今,5:自定义时间"`
  23. StartDate string `description:"自定义开始日期"`
  24. EndDate string `description:"自定义结束日期"`
  25. IsSetName int `description:"设置名称"`
  26. EdbInfoIds string `description:"指标id"`
  27. ChartType int `description:"生成样式:1:曲线图,2:季节性图,3:面积图,4:柱状图,5:散点图,6:组合图,7:柱方图,8:商品价格曲线图,9:相关性图"`
  28. Calendar string `description:"公历/农历"`
  29. SeasonStartDate string `description:"季节性图开始日期"`
  30. SeasonEndDate string `description:"季节性图开始日期"`
  31. ChartImage string `description:"图表图片"`
  32. Sort int `description:"排序字段,数字越小越排前面"`
  33. XMin string `description:"图表X轴最小值"`
  34. XMax string `description:"图表X轴最大值"`
  35. LeftMin string `description:"图表左侧最小值"`
  36. LeftMax string `description:"图表左侧最大值"`
  37. RightMin string `description:"图表右侧最小值"`
  38. RightMax string `description:"图表右侧最大值"`
  39. Right2Min string `description:"图表右侧2最小值"`
  40. Right2Max string `description:"图表右侧2最大值"`
  41. MinMaxSave int `description:"是否手动保存过上下限:0-否;1-是"`
  42. Disabled int `description:"是否禁用,0:启用,1:禁用,默认:0"`
  43. BarConfig string `description:"柱方图的配置,json数据"`
  44. Source int `description:"1:ETA图库;2:商品价格曲线"`
  45. ExtraConfig string `description:"图表额外配置,json数据"`
  46. SeasonExtraConfig string `description:"季节性图表中的配置,json数据"`
  47. StartYear int `description:"当选择的日期类型为最近N年类型时,即date_type=20, 用start_year表示N"`
  48. ChartThemeId int `description:"图表应用主题ID"`
  49. SourcesFrom string `description:"图表来源"`
  50. Instructions string `description:"图表说明"`
  51. MarkersLines string `description:"标识线"`
  52. MarkersAreas string `description:"标识区"`
  53. Unit string `description:"中文单位名称"`
  54. UnitEn string `description:"英文单位名称"`
  55. }
  56. type ChartInfoMore struct {
  57. ChartInfo
  58. IsEnChart bool `description:"是否展示英文标识"`
  59. }
  60. func AddChartInfo(item *ChartInfo) (lastId int64, err error) {
  61. o := orm.NewOrmUsingDB("data")
  62. lastId, err = o.Insert(item)
  63. return
  64. }
  65. type ChartInfoItem struct {
  66. ChartInfoId int `description:"图表id"`
  67. ChartName string `description:"图表名称"`
  68. ChartClassifyId int `description:"图表分类"`
  69. }
  70. // GetChartInfoAll 用于分类展示
  71. // @param source int 1:ETA图库;2:商品价格曲线
  72. func GetChartInfoAll(sourceList []int) (items []*ChartClassifyItems, err error) {
  73. num := len(sourceList)
  74. if num <= 0 {
  75. return
  76. }
  77. o := orm.NewOrmUsingDB("data")
  78. sql := ` SELECT chart_info_id,chart_classify_id,chart_name AS chart_classify_name,
  79. unique_code,sys_user_id,sys_user_real_name,date_type,start_date,end_date,chart_type,calendar,season_start_date,season_end_date,source
  80. FROM chart_info WHERE source in (` + utils.GetOrmInReplace(num) + `) ORDER BY sort asc,create_time ASC `
  81. _, err = o.Raw(sql, sourceList).QueryRows(&items)
  82. return
  83. }
  84. // GetChartInfoByAdminId 获取所有我创建的图表,用于分类展示
  85. func GetChartInfoByAdminId(sourceList []int, adminId int) (items []*ChartClassifyItems, err error) {
  86. num := len(sourceList)
  87. if num <= 0 {
  88. return
  89. }
  90. o := orm.NewOrmUsingDB("data")
  91. sql := ` SELECT chart_info_id,chart_classify_id,chart_name AS chart_classify_name,
  92. unique_code,sys_user_id,sys_user_real_name,date_type,start_date,end_date,chart_type,calendar,season_start_date,season_end_date
  93. FROM chart_info where source in (` + utils.GetOrmInReplace(num) + `) AND sys_user_id = ? ORDER BY sort asc,create_time ASC `
  94. _, err = o.Raw(sql, sourceList, adminId).QueryRows(&items)
  95. return
  96. }
  97. // 用于分类展示
  98. func GetChartInfoAllList() (items []*ChartInfo, err error) {
  99. o := orm.NewOrmUsingDB("data")
  100. sql := ` SELECT *
  101. FROM chart_info ORDER BY create_time ASC `
  102. _, err = o.Raw(sql).QueryRows(&items)
  103. return
  104. }
  105. // 图表检索数据
  106. type ChartInfoSearch struct {
  107. EdbCode string `description:"图表编码"`
  108. StartDate string `description:"起始日期"`
  109. EndDate string `description:"终止日期"`
  110. DataList []*EdbInfoSearchData
  111. }
  112. type ChartInfoSearchData struct {
  113. DataTime string `description:"数据日期"`
  114. Value float64 `description:"数据"`
  115. }
  116. type ChartInfoSearchResp struct {
  117. SearchItem *EdbInfoSearch `description:"图表分类"`
  118. Status int `description:"1:数据已存在于弘则数据库,2:新数据"`
  119. }
  120. func GetChartInfoById(chartInfoId int) (item *ChartInfo, err error) {
  121. o := orm.NewOrmUsingDB("data")
  122. sql := ` SELECT * FROM chart_info WHERE chart_info_id=? `
  123. err = o.Raw(sql, chartInfoId).QueryRow(&item)
  124. return
  125. }
  126. func GetChartInfoViewById(chartInfoId int) (item *ChartInfoView, err error) {
  127. o := orm.NewOrmUsingDB("data")
  128. sql := ` SELECT * FROM chart_info WHERE chart_info_id=? `
  129. err = o.Raw(sql, chartInfoId).QueryRow(&item)
  130. return
  131. }
  132. func GetChartInfoViewByIds(chartInfoIds []string) (list []*ChartInfoView, err error) {
  133. o := orm.NewOrmUsingDB("data")
  134. sql := ` SELECT * FROM chart_info WHERE chart_info_id in ("` + strings.Join(chartInfoIds, `","`) + `") `
  135. _, err = o.Raw(sql).QueryRows(&list)
  136. return
  137. }
  138. type SaveChartInfoReq struct {
  139. ChartEdbInfoList []*ChartSaveItem `description:"指标及配置信息"`
  140. ChartInfoId int `description:"图表id,新增时传0"`
  141. DateType int `description:"日期类型:1:00年至今,2:10年至今,3:15年至今,4:年初至今,5:自定义时间,6:起始日期至今"`
  142. StartDate string `description:"自定义开始日期"`
  143. EndDate string `description:"自定义结束日期"`
  144. Calendar string `description:"公历/农历"`
  145. LeftMin string `description:"图表左侧最小值"`
  146. LeftMax string `description:"图表左侧最大值"`
  147. RightMin string `description:"图表右侧最小值"`
  148. RightMax string `description:"图表右侧最大值"`
  149. Right2Min string `description:"图表右侧最小值"`
  150. Right2Max string `description:"图表右侧最大值"`
  151. MinMaxSave int `description:"是否手动保存过上下限:0-否;1-是"`
  152. ExtraConfig string `description:"图表额外配置,json数据"`
  153. StartYear int `description:"当选择的日期类型为最近N年类型时,即date_type=20, 用start_year表示N"`
  154. }
  155. type ChartSaveItem struct {
  156. EdbInfoId int `description:"指标id"`
  157. MaxData float64 `description:"上限"`
  158. MinData float64 `description:"下限"`
  159. IsOrder bool `description:"true:正序,false:逆序"`
  160. IsAxis int `description:"1:左轴,0:右轴"`
  161. EdbInfoType int `description:"1:标准指标,0:领先指标"`
  162. LeadValue int `description:"领先值"`
  163. LeadUnit string `description:"领先单位"`
  164. ChartStyle string `description:"图表类型"`
  165. ChartColor string `description:"颜色"`
  166. PredictChartColor string `description:"预测数据的颜色"`
  167. ChartWidth float64 `description:"线条大小"`
  168. Source int `description:"1:ETA图库;2:商品价格曲线"`
  169. }
  170. func DeleteChartInfoAndData(chartInfoId int) (err error) {
  171. o := orm.NewOrmUsingDB("data")
  172. to, err := o.Begin()
  173. if err != nil {
  174. return
  175. }
  176. defer func() {
  177. if err != nil {
  178. _ = to.Rollback()
  179. } else {
  180. _ = to.Commit()
  181. }
  182. }()
  183. sql := ` DELETE FROM chart_info WHERE chart_info_id=? `
  184. _, err = to.Raw(sql, chartInfoId).Exec()
  185. if err != nil {
  186. return
  187. }
  188. sql = ` DELETE FROM chart_edb_mapping WHERE chart_info_id=? `
  189. _, err = to.Raw(sql, chartInfoId).Exec()
  190. return
  191. }
  192. func GetChartInfoCountByCondition(condition string, pars []interface{}) (count int, err error) {
  193. o := orm.NewOrmUsingDB("data")
  194. sql := ` SELECT COUNT(1) AS count FROM chart_info WHERE 1=1 `
  195. if condition != "" {
  196. sql += condition
  197. }
  198. err = o.Raw(sql, pars).QueryRow(&count)
  199. return
  200. }
  201. type EditChartInfoReq struct {
  202. ChartInfoId int `description:"图表ID"`
  203. ChartName string `description:"图表名称"`
  204. ChartClassifyId int `description:"分类id"`
  205. ChartEdbInfoList []*ChartSaveItem `description:"指标及配置信息"`
  206. ChartType int `description:"生成样式:1:曲线图,2:季节性图,3:面积图,4:柱状图,5:散点图,6:组合图,7:柱方图,8:商品价格曲线图,9:相关性图,10:截面散点图"`
  207. DateType int `description:"日期类型:1:00年至今,2:10年至今,3:15年至今,4:年初至今,5:自定义时间,6:起始日期至今"`
  208. StartDate string `description:"自定义开始日期"`
  209. EndDate string `description:"自定义结束日期"`
  210. Calendar string `description:"公历/农历"`
  211. SeasonStartDate string `description:"季节性图开始日期"`
  212. SeasonEndDate string `description:"季节性图开始日期"`
  213. LeftMin string `description:"图表左侧最小值"`
  214. LeftMax string `description:"图表左侧最大值"`
  215. RightMin string `description:"图表右侧最小值"`
  216. RightMax string `description:"图表右侧最大值"`
  217. Right2Min string `description:"图表右侧最小值"`
  218. Right2Max string `description:"图表右侧最大值"`
  219. BarChartInfo BarChartInfoReq `description:"柱方图的配置"`
  220. CorrelationChartInfo CorrelationChartInfoReq `description:"相关性图表配置"`
  221. ExtraConfig string `description:"图表额外配置信息,json字符串"`
  222. }
  223. type EditChartEnInfoReq struct {
  224. ChartInfoId int `description:"图表ID"`
  225. ChartNameEn string `description:"英文图表名称"`
  226. ChartEdbInfoList []*EditChartEnInfoEdbItem `description:"指标及配置信息"`
  227. ExtraConfig string `description:"图表额外配置信息,json字符串"`
  228. }
  229. type EditChartEnInfoEdbItem struct {
  230. EdbInfoId int `description:"指标ID"`
  231. EdbNameEn string `description:"英文指标名称"`
  232. UnitEn string `description:"英文单位"`
  233. }
  234. func ModifyChartInfo(item *EditChartInfoReq) (err error) {
  235. o := orm.NewOrmUsingDB("data")
  236. sql := ` UPDATE chart_info
  237. SET
  238. chart_name =?,
  239. chart_classify_id = ?,
  240. is_set_name=1,
  241. modify_time = NOW()
  242. WHERE chart_info_id = ?`
  243. _, err = o.Raw(sql, item.ChartName, item.ChartClassifyId, item.ChartInfoId).Exec()
  244. return
  245. }
  246. type ChartInfoList struct {
  247. ChartInfoId int `orm:"column(chart_info_id);pk"`
  248. ChartName string `description:"来源名称"`
  249. ChartChartClassifyId int `description:"图表分类id"`
  250. SysUserId int
  251. SysUserRealName string
  252. UniqueCode string `description:"图表唯一编码"`
  253. CreateTime time.Time
  254. ModifyTime time.Time
  255. EdbInfoList []*EdbInfoList
  256. }
  257. type ChartInfoListResp struct {
  258. Paging *paging.PagingItem
  259. Item *ChartInfoList
  260. }
  261. func GetChartInfoByCondition(condition string, pars []interface{}) (item *ChartInfo, err error) {
  262. o := orm.NewOrmUsingDB("data")
  263. sql := ` SELECT * FROM chart_info WHERE 1=1 `
  264. if condition != "" {
  265. sql += condition
  266. }
  267. err = o.Raw(sql, pars).QueryRow(&item)
  268. return
  269. }
  270. func GetChartInfoByNewest(source int) (item *ChartInfoList, err error) {
  271. o := orm.NewOrmUsingDB("data")
  272. sql := ` SELECT * FROM chart_info WHERE 1=1 AND source = ? ORDER BY modify_time DESC LIMIT 1 `
  273. err = o.Raw(sql, source).QueryRow(&item)
  274. return
  275. }
  276. func ModifyChartInfoModifyTime(chartInfoId int64) (err error) {
  277. o := orm.NewOrmUsingDB("data")
  278. sql := ` UPDATE chart_info SET modify_time = NOW() WHERE chart_info_id = ? `
  279. _, err = o.Raw(sql, chartInfoId).Exec()
  280. return
  281. }
  282. type MoveChartInfoReq struct {
  283. ChartInfoId int `description:"图表ID"`
  284. PrevChartInfoId int `description:"上一个图表ID"`
  285. NextChartInfoId int `description:"下一个图表ID"`
  286. ChartClassifyId int `description:"分类id"`
  287. }
  288. func MoveChartInfo(chartInfoId, classifyId int) (err error) {
  289. o := orm.NewOrmUsingDB("data")
  290. sql := ` UPDATE chart_info
  291. SET
  292. chart_classify_id = ?
  293. WHERE chart_info_id = ?`
  294. _, err = o.Raw(sql, classifyId, chartInfoId).Exec()
  295. return
  296. }
  297. type DeleteChartInfoReq struct {
  298. ChartInfoId int `description:"图表ID"`
  299. }
  300. type EdbDataList struct {
  301. EdbDataId int `description:" 指标数据ID"`
  302. EdbInfoId int `description:"指标ID"`
  303. DataTime string //`json:"-" description:"数据日期"`
  304. DataTimestamp int64 `description:"数据日期"`
  305. Value float64 `description:"数据值"`
  306. }
  307. func GetEdbDataList(source, subSource, endInfoId int, startDate, endDate string) (list []*EdbDataList, err error) {
  308. tableName := GetEdbDataTableName(source, subSource)
  309. if tableName == "" {
  310. err = errors.New("无效的渠道:" + strconv.Itoa(source))
  311. list = make([]*EdbDataList, 0)
  312. return list, err
  313. }
  314. var pars []interface{}
  315. sql := `SELECT edb_data_id,edb_info_id,data_time,value,data_timestamp FROM %s WHERE edb_info_id=? `
  316. if startDate != "" {
  317. sql += ` AND data_time>=? `
  318. pars = append(pars, startDate)
  319. }
  320. if endDate != "" {
  321. sql += ` AND data_time<=? `
  322. pars = append(pars, endDate)
  323. }
  324. sql += ` ORDER BY data_time ASC `
  325. sql = fmt.Sprintf(sql, tableName)
  326. o := orm.NewOrmUsingDB("data")
  327. _, err = o.Raw(sql, endInfoId, pars).QueryRows(&list)
  328. return
  329. }
  330. type EdbDataListByUniqueCode struct {
  331. EdbDataId int `description:" 指标数据ID" json:"-"`
  332. EdbInfoId int `description:"指标ID" json:"-"`
  333. DataTime string //`json:"-" description:"数据日期"`
  334. DataTimestamp int64 `description:"数据日期"`
  335. Value float64 `description:"数据值"`
  336. }
  337. func GetEdbDataListByByUniqueCode(source, subSource, endInfoId int, startDate, endDate string) (list []*EdbDataListByUniqueCode, err error) {
  338. tableName := GetEdbDataTableName(source, subSource)
  339. if tableName == "" {
  340. err = errors.New("无效的渠道:" + strconv.Itoa(source))
  341. list = make([]*EdbDataListByUniqueCode, 0)
  342. return list, err
  343. }
  344. var pars []interface{}
  345. sql := `SELECT edb_data_id,edb_info_id,data_time,value,data_timestamp FROM %s WHERE edb_info_id=? `
  346. if startDate != "" {
  347. sql += ` AND data_time>=? `
  348. pars = append(pars, startDate)
  349. }
  350. if endDate != "" {
  351. sql += ` AND data_time<=? `
  352. pars = append(pars, endDate)
  353. }
  354. sql += ` ORDER BY data_time ASC `
  355. sql = fmt.Sprintf(sql, tableName)
  356. o := orm.NewOrmUsingDB("data")
  357. _, err = o.Raw(sql, endInfoId, pars).QueryRows(&list)
  358. return
  359. }
  360. func GetEdbDataLunarList(endInfoId int, startDate, endDate string) (list []*EdbDataList, err error) {
  361. tableName := "edb_data_quarter"
  362. sql := `SELECT edb_data_id,edb_info_id,data_time,TRUNCATE(value,2) AS value,data_timestamp FROM %s WHERE edb_info_id=? AND data_time>=? AND data_time<=? ORDER BY data_time ASC `
  363. sql = fmt.Sprintf(sql, tableName)
  364. o := orm.NewOrmUsingDB("data")
  365. _, err = o.Raw(sql, endInfoId, startDate, endDate).QueryRows(&list)
  366. return
  367. }
  368. func GetEdbDataListMinAndMax(source, subSource, endInfoId int, startDate, endDate string) (min_data, max_data float64, err error) {
  369. tableName := GetEdbDataTableName(source, subSource)
  370. sql := `SELECT min(value) AS min_data,max(value) AS max_data FROM %s WHERE edb_info_id=? `
  371. var pars []interface{}
  372. var condition string
  373. if startDate != "" {
  374. condition += ` AND data_time>=? `
  375. pars = append(pars, startDate)
  376. }
  377. if endDate != "" {
  378. condition += ` AND data_time<=? `
  379. pars = append(pars, endDate)
  380. }
  381. sql = fmt.Sprintf(sql, tableName)
  382. o := orm.NewOrmUsingDB("data")
  383. if condition != "" {
  384. sql += condition
  385. }
  386. err = o.Raw(sql, endInfoId, pars).QueryRow(&min_data, &max_data)
  387. return
  388. }
  389. type ChartEdbInfoMapping struct {
  390. EdbInfoId int `description:"指标id"`
  391. SourceName string `description:"来源名称"`
  392. Source int `description:"来源id"`
  393. EdbCode string `description:"指标编码"`
  394. EdbName string `description:"指标名称"`
  395. EdbAliasName string `description:"指标名称(别名)"`
  396. EdbNameEn string `description:"英文指标名称"`
  397. EdbAliasNameEn string `description:"英文指标名称(别名)"`
  398. EdbType int `description:"指标类型:1:基础指标,2:计算指标"`
  399. Frequency string `description:"频率"`
  400. FrequencyEn string `description:"英文频率"`
  401. Unit string `description:"单位"`
  402. UnitEn string `description:"英文单位"`
  403. StartDate string `description:"起始日期"`
  404. EndDate string `description:"终止日期"`
  405. ModifyTime string `description:"指标最后更新时间"`
  406. ChartEdbMappingId int `description:"图表指标id"`
  407. ChartInfoId int `description:"图表id"`
  408. MaxData float64 `description:"上限"`
  409. MinData float64 `description:"下限"`
  410. IsOrder bool `description:"true:正序,false:逆序"`
  411. IsAxis int `description:"1:左轴,0:右轴"`
  412. EdbInfoType int `description:"1:标准指标,0:领先指标"`
  413. EdbInfoCategoryType int `description:"0:普通指标,1:预测指标"`
  414. LeadValue int `description:"领先值"`
  415. LeadUnit string `description:"领先单位"`
  416. LeadUnitEn string `description:"领先英文单位"`
  417. ChartStyle string `description:"图表类型"`
  418. ChartColor string `description:"颜色"`
  419. PredictChartColor string `description:"预测数据的颜色"`
  420. ChartWidth float64 `description:"线条大小"`
  421. ChartType int `description:"生成样式:1:曲线图,2:季节性图,3:面积图,4:柱状图,5:散点图,6:组合图,7:柱方图,8:商品价格曲线图,9:相关性图"`
  422. LatestDate string `description:"数据最新日期"`
  423. LatestValue float64 `description:"数据最新值"`
  424. MoveLatestDate string `description:"移动后的数据最新日期"`
  425. UniqueCode string `description:"指标唯一编码"`
  426. MinValue float64 `json:"-" description:"最小值"`
  427. MaxValue float64 `json:"-" description:"最大值"`
  428. DataList interface{}
  429. IsNullData bool `json:"-" description:"是否空数据"`
  430. MappingSource int `description:"1:ETA图库;2:商品价格曲线"`
  431. RegionType string `description:"交易所来源,海外还是国内" json:"-"`
  432. ClassifyId int `description:"分类id"`
  433. SubSource int `description:"子数据来源:0:经济数据库,1:日期序列"`
  434. SubSourceName string `description:"子数据来源名称"`
  435. IndicatorCode string `description:"指标代码"`
  436. StockCode string `description:"证券代码"`
  437. IsConvert int `description:"是否数据转换 0不转 1转"`
  438. ConvertType int `description:"数据转换类型 1乘 2除 3对数"`
  439. ConvertValue float64 `description:"数据转换值"`
  440. ConvertUnit string `description:"数据转换单位"`
  441. ConvertEnUnit string `description:"数据转换单位"`
  442. }
  443. type QuarterData struct {
  444. Year int
  445. DataList []*EdbDataList
  446. CuttingDataTimestamp int64 `description:"切割的时间戳"`
  447. ChartLegend string
  448. Years string
  449. }
  450. type QuarterXDateItem struct {
  451. StartDate time.Time
  452. EndDate time.Time
  453. ShowName string
  454. ChartLegend string
  455. CuttingDataTimestamp int64 `description:"切割的时间戳"`
  456. }
  457. type SeasonExtraItem struct {
  458. ChartLegend []SeasonChartLegend `description:"自定义的图例名称"`
  459. XStartDate string `description:"横坐标显示的起始日"`
  460. XEndDate string `description:"横坐标显示的截止日"`
  461. JumpYear int `description:"横坐标日期是否跨年,1跨年,0不跨年"`
  462. }
  463. type QuarterDataList []*QuarterData
  464. func (m QuarterDataList) Len() int {
  465. return len(m)
  466. }
  467. func (m QuarterDataList) Less(i, j int) bool {
  468. return m[i].Years < m[j].Years
  469. }
  470. func (m QuarterDataList) Swap(i, j int) {
  471. m[i], m[j] = m[j], m[i]
  472. }
  473. type SeasonChartLegend struct {
  474. Name string
  475. Value string
  476. }
  477. type QuarterDataByUniqueCode struct {
  478. Year int
  479. DataList []*EdbDataListByUniqueCode
  480. }
  481. type ChartEdbInfoDetailResp struct {
  482. EdbInfo *ChartEdbInfoMapping
  483. }
  484. type ChartInfoDetailResp struct {
  485. ChartInfo *ChartInfoView
  486. EdbInfoList []*ChartEdbInfoMapping
  487. XEdbIdValue []int `description:"柱方图的x轴数据,指标id"`
  488. YDataList []YData `description:"柱方图的y轴数据"`
  489. XDataList []XData `description:"商品价格曲线的X轴数据"`
  490. BarChartInfo BarChartInfoReq `description:"柱方图的配置"`
  491. CorrelationChartInfo *CorrelationInfo `description:"相关性图表信息"`
  492. DataResp interface{} `description:"图表数据,根据图的类型而定的,没有确定的数据格式"`
  493. }
  494. // XData 商品价格曲线的的x轴数据
  495. type XData struct {
  496. Name string `description:"别名"`
  497. NameEn string `description:"英文别名"`
  498. }
  499. // YData 柱方图的y轴数据
  500. type YData struct {
  501. Date string `description:"数据日期"`
  502. ConfigDate time.Time `description:"配置的日期" json:"-"`
  503. Color string `description:"数据颜色"`
  504. Name string `description:"别名"`
  505. NameEn string `description:"英文别名"`
  506. Value []float64 `description:"每个指标的值"`
  507. NoDataEdbList []int `description:"没有数据的指标列表"`
  508. XEdbInfoIdList []int `description:"对应X轴的指标id列表"`
  509. NameList []string `description:"每个值对应的名称"`
  510. EnNameList []string `description:"每个值对应的英文名称"`
  511. EdbValMap map[int]float64 `description:"指标与值的对应" json:"-"`
  512. M []int `description:"对应开始日期的间隔值" json:"-"`
  513. Unit string `description:"中文单位名称"`
  514. UnitEn string `description:"英文单位名称"`
  515. }
  516. func ModifyChartInfoAndMapping(edbInfoIdStr string, req *SaveChartInfoReq, chartType int) (err error) {
  517. o := orm.NewOrmUsingDB("data")
  518. to, err := o.Begin()
  519. if err != nil {
  520. return
  521. }
  522. defer func() {
  523. if err != nil {
  524. _ = to.Rollback()
  525. } else {
  526. _ = to.Commit()
  527. }
  528. }()
  529. //非季节图
  530. if chartType != 2 {
  531. updateStr := `edb_info_ids=?,
  532. modify_time = NOW(),
  533. date_type=?,
  534. start_date=?,
  535. end_date=?,
  536. left_min=?,
  537. left_max=?,
  538. right_min=?,
  539. right_max=?,
  540. right2_min=?,
  541. right2_max=?,
  542. min_max_save=?,
  543. start_year=?`
  544. pars := []interface{}{edbInfoIdStr, req.DateType, req.StartDate, req.EndDate, req.LeftMin, req.LeftMax, req.RightMin, req.RightMax, req.Right2Min, req.Right2Max, req.MinMaxSave, req.StartYear}
  545. if req.ExtraConfig != `` {
  546. updateStr += `,extra_config=? `
  547. pars = append(pars, req.ExtraConfig)
  548. }
  549. pars = append(pars, req.ChartInfoId)
  550. sql := ` UPDATE chart_info SET ` + updateStr + ` WHERE chart_info_id = ?`
  551. _, err = to.Raw(sql, pars).Exec()
  552. if err != nil {
  553. fmt.Println("UPDATE chart_info Err:", err.Error())
  554. return err
  555. }
  556. } else {
  557. sql := ` UPDATE chart_info
  558. SET
  559. edb_info_ids=?,
  560. modify_time = NOW(),
  561. calendar=?,
  562. date_type=?,
  563. start_date=?,
  564. end_date=?,
  565. season_start_date=?,
  566. season_end_date=?,
  567. left_min=?,
  568. left_max=?,
  569. right_min=?,
  570. right_max=?,
  571. right2_min=?,
  572. right2_max=?,
  573. min_max_save=?,
  574. start_year=?
  575. WHERE chart_info_id = ?`
  576. _, err = to.Raw(sql, edbInfoIdStr, req.Calendar, req.DateType, req.StartDate, req.EndDate, req.StartDate, req.EndDate, req.LeftMin, req.LeftMax, req.RightMin, req.RightMax, req.Right2Min, req.Right2Max, req.MinMaxSave, req.StartYear, req.ChartInfoId).Exec()
  577. if err != nil {
  578. fmt.Println("UPDATE chart_info Err:", err.Error())
  579. return err
  580. }
  581. }
  582. var edbInfoIdArr []string
  583. mapList := make([]*ChartEdbMapping, 0)
  584. for _, v := range req.ChartEdbInfoList {
  585. edbInfoIdArr = append(edbInfoIdArr, strconv.Itoa(v.EdbInfoId))
  586. var count int
  587. csql := `SELECT COUNT(1) AS count FROM chart_edb_mapping WHERE chart_info_id=? AND edb_info_id=? `
  588. err = to.Raw(csql, req.ChartInfoId, v.EdbInfoId).QueryRow(&count)
  589. if err != nil {
  590. fmt.Println("QueryRow Err:", err.Error())
  591. return err
  592. }
  593. if count > 0 {
  594. msql := `UPDATE chart_edb_mapping
  595. SET
  596. modify_time = NOW(),
  597. max_data = ?,
  598. min_data = ?,
  599. is_order = ?,
  600. is_axis = ?,
  601. edb_info_type = ?,
  602. lead_value = ?,
  603. lead_unit = ?,
  604. chart_style = ?,
  605. chart_color = ?,
  606. predict_chart_color = ?,
  607. chart_width = ?
  608. WHERE chart_info_id =? AND edb_info_id=? `
  609. _, err = to.Raw(msql, v.MaxData, v.MinData, v.IsOrder, v.IsAxis, v.EdbInfoType, v.LeadValue, v.LeadUnit, v.ChartStyle, v.ChartColor, v.PredictChartColor, v.ChartWidth, req.ChartInfoId, v.EdbInfoId).Exec()
  610. if err != nil {
  611. fmt.Println("chart_edb_mapping Err:" + err.Error())
  612. return err
  613. }
  614. } else {
  615. mapItem := new(ChartEdbMapping)
  616. mapItem.ChartInfoId = req.ChartInfoId
  617. mapItem.EdbInfoId = v.EdbInfoId
  618. mapItem.CreateTime = time.Now()
  619. mapItem.ModifyTime = time.Now()
  620. timestamp := strconv.FormatInt(time.Now().UnixNano(), 10)
  621. mapItem.UniqueCode = utils.MD5(utils.CHART_PREFIX + "_" + timestamp)
  622. mapItem.MaxData = v.MaxData
  623. mapItem.MinData = v.MinData
  624. mapItem.IsOrder = v.IsOrder
  625. mapItem.IsAxis = v.IsAxis
  626. mapItem.EdbInfoType = v.EdbInfoType
  627. mapItem.LeadValue = v.LeadValue
  628. mapItem.LeadUnit = v.LeadUnit
  629. mapItem.ChartStyle = v.ChartStyle
  630. mapItem.ChartColor = v.ChartColor
  631. mapItem.PredictChartColor = v.PredictChartColor
  632. mapItem.ChartWidth = v.ChartWidth
  633. mapList = append(mapList, mapItem)
  634. }
  635. }
  636. if len(mapList) > 0 {
  637. _, err = to.InsertMulti(1, mapList)
  638. if err != nil {
  639. fmt.Println("AddChartEdbMapping Err:" + err.Error())
  640. return err
  641. }
  642. }
  643. if len(edbInfoIdArr) > 0 {
  644. edbInfoIdStr := strings.Join(edbInfoIdArr, ",")
  645. if edbInfoIdStr != "" {
  646. dsql := `DELETE FROM chart_edb_mapping WHERE chart_info_id=? AND edb_info_id NOT IN(` + edbInfoIdStr + `)`
  647. _, err = to.Raw(dsql, req.ChartInfoId).Exec()
  648. if err != nil {
  649. fmt.Println("delete err:" + err.Error())
  650. return err
  651. }
  652. }
  653. }
  654. return
  655. }
  656. // EditChartInfoAndMapping 修改 ETA图库 的 图表与指标 的关系
  657. func EditChartInfoAndMapping(req *EditChartInfoReq, edbInfoIdStr string, calendar string, dateType, disabled int, barChartConf string, chartEdbInfoList []*ChartSaveItem) (err error) {
  658. o := orm.NewOrmUsingDB("data")
  659. to, err := o.Begin()
  660. if err != nil {
  661. return
  662. }
  663. defer func() {
  664. if err != nil {
  665. _ = to.Rollback()
  666. } else {
  667. _ = to.Commit()
  668. }
  669. }()
  670. var pars []interface{}
  671. pars = append(pars, req.ChartName)
  672. pars = append(pars, edbInfoIdStr)
  673. pars = append(pars, req.ChartType)
  674. pars = append(pars, req.ChartClassifyId)
  675. pars = append(pars, disabled)
  676. pars = append(pars, barChartConf)
  677. pars = append(pars, req.ExtraConfig)
  678. sql := ` UPDATE chart_info
  679. SET
  680. chart_name =?,
  681. edb_info_ids=?,
  682. chart_type=?,
  683. chart_classify_id = ?,
  684. modify_time = NOW(),
  685. disabled = ?,
  686. bar_config = ?,extra_config = ?
  687. `
  688. if calendar != "" {
  689. sql += `,calendar = ? `
  690. pars = append(pars, calendar)
  691. }
  692. if dateType > 0 {
  693. sql += `,date_type = ? `
  694. pars = append(pars, dateType)
  695. }
  696. sql += `,start_date = ? `
  697. pars = append(pars, req.StartDate)
  698. sql += `,end_date = ? `
  699. pars = append(pars, req.EndDate)
  700. sql += `,season_start_date = ? `
  701. pars = append(pars, req.SeasonStartDate)
  702. sql += `,season_end_date = ? `
  703. pars = append(pars, req.SeasonEndDate)
  704. sql += `,left_min = ? `
  705. pars = append(pars, req.LeftMin)
  706. sql += `,left_max = ? `
  707. pars = append(pars, req.LeftMax)
  708. sql += `,right_min = ? `
  709. pars = append(pars, req.RightMin)
  710. sql += `,right_max = ? `
  711. pars = append(pars, req.RightMax)
  712. sql += `WHERE chart_info_id = ?`
  713. pars = append(pars, req.ChartInfoId)
  714. _, err = to.Raw(sql, pars).Exec()
  715. if err != nil {
  716. fmt.Println("UPDATE chart_info Err:", err.Error())
  717. return err
  718. }
  719. chartEdbMappingIdList := make([]string, 0)
  720. for _, v := range chartEdbInfoList {
  721. // 查询该指标是否存在,如果存在的话,那么就去修改,否则新增
  722. var tmpChartEdbMapping *ChartEdbMapping
  723. csql := `SELECT * FROM chart_edb_mapping WHERE chart_info_id=? AND edb_info_id=? AND source = ? `
  724. err = to.Raw(csql, req.ChartInfoId, v.EdbInfoId, utils.CHART_SOURCE_DEFAULT).QueryRow(&tmpChartEdbMapping)
  725. if err != nil && err.Error() != utils.ErrNoRow() {
  726. fmt.Println("QueryRow Err:", err.Error())
  727. return err
  728. }
  729. if tmpChartEdbMapping != nil {
  730. chartEdbMappingIdList = append(chartEdbMappingIdList, strconv.Itoa(tmpChartEdbMapping.ChartEdbMappingId))
  731. tmpChartEdbMapping.ModifyTime = time.Now()
  732. tmpChartEdbMapping.MaxData = v.MaxData
  733. tmpChartEdbMapping.MinData = v.MinData
  734. tmpChartEdbMapping.IsOrder = v.IsOrder
  735. tmpChartEdbMapping.IsAxis = v.IsAxis
  736. tmpChartEdbMapping.EdbInfoType = v.EdbInfoType
  737. tmpChartEdbMapping.LeadValue = v.LeadValue
  738. tmpChartEdbMapping.LeadUnit = v.LeadUnit
  739. tmpChartEdbMapping.ChartStyle = v.ChartStyle
  740. tmpChartEdbMapping.ChartColor = v.ChartColor
  741. tmpChartEdbMapping.PredictChartColor = v.PredictChartColor
  742. tmpChartEdbMapping.ChartWidth = v.ChartWidth
  743. _, err = to.Update(tmpChartEdbMapping, "ModifyTime", "MaxData", "MinData", "IsOrder", "IsAxis", "EdbInfoType", "LeadValue", "LeadUnit", "ChartStyle", "ChartColor", "PredictChartColor", "ChartWidth")
  744. if err != nil {
  745. fmt.Println("chart_edb_mapping Err:" + err.Error())
  746. return err
  747. }
  748. } else {
  749. mapItem := new(ChartEdbMapping)
  750. mapItem.ChartInfoId = req.ChartInfoId
  751. mapItem.EdbInfoId = v.EdbInfoId
  752. mapItem.CreateTime = time.Now()
  753. mapItem.ModifyTime = time.Now()
  754. timestamp := strconv.FormatInt(time.Now().UnixNano(), 10)
  755. mapItem.UniqueCode = utils.MD5(utils.CHART_PREFIX + "_" + timestamp + "_" + strconv.Itoa(v.EdbInfoId))
  756. mapItem.MaxData = v.MaxData
  757. mapItem.MinData = v.MinData
  758. mapItem.IsOrder = v.IsOrder
  759. mapItem.IsAxis = v.IsAxis
  760. mapItem.EdbInfoType = v.EdbInfoType
  761. mapItem.LeadValue = v.LeadValue
  762. mapItem.LeadUnit = v.LeadUnit
  763. mapItem.ChartStyle = v.ChartStyle
  764. mapItem.ChartColor = v.ChartColor
  765. mapItem.PredictChartColor = v.PredictChartColor
  766. mapItem.ChartWidth = v.ChartWidth
  767. mapItem.Source = utils.CHART_SOURCE_DEFAULT
  768. tmpId, err := to.Insert(mapItem)
  769. if err != nil {
  770. fmt.Println("AddChartEdbMapping Err:" + err.Error())
  771. return err
  772. }
  773. mapItem.ChartEdbMappingId = int(tmpId)
  774. chartEdbMappingIdList = append(chartEdbMappingIdList, strconv.Itoa(mapItem.ChartEdbMappingId))
  775. }
  776. }
  777. if len(chartEdbMappingIdList) > 0 {
  778. chartEdbMappingIdStr := strings.Join(chartEdbMappingIdList, ",")
  779. dsql := `DELETE FROM chart_edb_mapping WHERE chart_info_id=? AND chart_edb_mapping_id NOT IN(` + chartEdbMappingIdStr + `)`
  780. _, err = to.Raw(dsql, req.ChartInfoId).Exec()
  781. if err != nil {
  782. fmt.Println("delete err:" + err.Error())
  783. return err
  784. }
  785. }
  786. return
  787. }
  788. // EditFutureGoodChartInfoAndMapping 修改商品价格曲线的 图表与指标 的关系
  789. func EditFutureGoodChartInfoAndMapping(req *EditChartInfoReq, edbInfoIdStr string, calendar string, dateType, disabled int, barChartConf string) (err error) {
  790. o := orm.NewOrmUsingDB("data")
  791. to, err := o.Begin()
  792. if err != nil {
  793. return
  794. }
  795. defer func() {
  796. if err != nil {
  797. _ = to.Rollback()
  798. } else {
  799. _ = to.Commit()
  800. }
  801. }()
  802. var pars []interface{}
  803. pars = append(pars, req.ChartName)
  804. pars = append(pars, edbInfoIdStr)
  805. pars = append(pars, req.ChartType)
  806. pars = append(pars, req.ChartClassifyId)
  807. pars = append(pars, disabled)
  808. pars = append(pars, barChartConf)
  809. sql := ` UPDATE chart_info
  810. SET
  811. chart_name =?,
  812. edb_info_ids=?,
  813. chart_type=?,
  814. chart_classify_id = ?,
  815. modify_time = NOW(),
  816. disabled = ?,
  817. bar_config = ?
  818. `
  819. if calendar != "" {
  820. sql += `,calendar = ? `
  821. pars = append(pars, calendar)
  822. }
  823. if dateType > 0 {
  824. sql += `,date_type = ? `
  825. pars = append(pars, dateType)
  826. }
  827. sql += `,start_date = ? `
  828. pars = append(pars, req.StartDate)
  829. sql += `,end_date = ? `
  830. pars = append(pars, req.EndDate)
  831. sql += `,season_start_date = ? `
  832. pars = append(pars, req.SeasonStartDate)
  833. sql += `,season_end_date = ? `
  834. pars = append(pars, req.SeasonEndDate)
  835. sql += `,left_min = ? `
  836. pars = append(pars, req.LeftMin)
  837. sql += `,left_max = ? `
  838. pars = append(pars, req.LeftMax)
  839. sql += `,right_min = ? `
  840. pars = append(pars, req.RightMin)
  841. sql += `,right_max = ? `
  842. pars = append(pars, req.RightMax)
  843. sql += `WHERE chart_info_id = ?`
  844. pars = append(pars, req.ChartInfoId)
  845. _, err = to.Raw(sql, pars).Exec()
  846. if err != nil {
  847. fmt.Println("UPDATE chart_info Err:", err.Error())
  848. return err
  849. }
  850. chartEdbMappingIdList := make([]string, 0)
  851. for _, v := range req.BarChartInfo.EdbInfoIdList {
  852. // 查询该指标是否存在,如果存在的话,那么就去修改,否则新增
  853. var tmpChartEdbMapping *ChartEdbMapping
  854. csql := `SELECT * FROM chart_edb_mapping WHERE chart_info_id=? AND edb_info_id=? AND source = ? `
  855. err = to.Raw(csql, req.ChartInfoId, v.EdbInfoId, v.Source).QueryRow(&tmpChartEdbMapping)
  856. if err != nil && err.Error() != utils.ErrNoRow() {
  857. fmt.Println("QueryRow Err:", err.Error())
  858. return err
  859. }
  860. if tmpChartEdbMapping != nil {
  861. chartEdbMappingIdList = append(chartEdbMappingIdList, strconv.Itoa(tmpChartEdbMapping.ChartEdbMappingId))
  862. //tmpChartEdbMapping.ModifyTime = time.Now()
  863. //tmpChartEdbMapping.MaxData = v.MaxData
  864. //tmpChartEdbMapping.MinData = v.MinData
  865. //tmpChartEdbMapping.IsOrder = v.IsOrder
  866. //tmpChartEdbMapping.IsAxis = v.IsAxis
  867. //tmpChartEdbMapping.EdbInfoType = v.EdbInfoType
  868. //tmpChartEdbMapping.LeadValue = v.LeadValue
  869. //tmpChartEdbMapping.LeadUnit = v.LeadUnit
  870. //tmpChartEdbMapping.ChartStyle = v.ChartStyle
  871. //tmpChartEdbMapping.ChartColor = v.ChartColor
  872. //tmpChartEdbMapping.PredictChartColor = v.PredictChartColor
  873. //tmpChartEdbMapping.ChartWidth = v.ChartWidth
  874. //_, err = to.Update(tmpChartEdbMapping, "ModifyTime", "MaxData", "MinData", "IsOrder", "IsAxis", "EdbInfoType", "LeadValue", "LeadUnit", "ChartStyle", "ChartColor", "PredictChartColor", "ChartWidth")
  875. //if err != nil {
  876. // fmt.Println("chart_edb_mapping Err:" + err.Error())
  877. // return err
  878. //}
  879. } else {
  880. mapItem := new(ChartEdbMapping)
  881. mapItem.ChartInfoId = req.ChartInfoId
  882. mapItem.EdbInfoId = v.EdbInfoId
  883. mapItem.CreateTime = time.Now()
  884. mapItem.ModifyTime = time.Now()
  885. timestamp := strconv.FormatInt(time.Now().UnixNano(), 10)
  886. mapItem.UniqueCode = utils.MD5(utils.CHART_PREFIX + "_" + timestamp + "_" + strconv.Itoa(v.EdbInfoId))
  887. //mapItem.MaxData = v.MaxData
  888. //mapItem.MinData = v.MinData
  889. mapItem.IsOrder = true
  890. mapItem.IsAxis = 1
  891. mapItem.EdbInfoType = 1
  892. //mapItem.LeadValue = v.LeadValue
  893. //mapItem.LeadUnit = v.LeadUnit
  894. //mapItem.ChartStyle = v.ChartStyle
  895. //mapItem.ChartColor = v.ChartColor
  896. //mapItem.PredictChartColor = v.PredictChartColor
  897. //mapItem.ChartWidth = v.ChartWidth
  898. mapItem.Source = v.Source
  899. tmpId, err := to.Insert(mapItem)
  900. if err != nil {
  901. fmt.Println("AddChartEdbMapping Err:" + err.Error())
  902. return err
  903. }
  904. mapItem.ChartEdbMappingId = int(tmpId)
  905. chartEdbMappingIdList = append(chartEdbMappingIdList, strconv.Itoa(mapItem.ChartEdbMappingId))
  906. }
  907. }
  908. if len(chartEdbMappingIdList) > 0 {
  909. chartEdbMappingIdStr := strings.Join(chartEdbMappingIdList, ",")
  910. dsql := `DELETE FROM chart_edb_mapping WHERE chart_info_id=? AND chart_edb_mapping_id NOT IN(` + chartEdbMappingIdStr + `)`
  911. _, err = to.Raw(dsql, req.ChartInfoId).Exec()
  912. if err != nil {
  913. fmt.Println("delete err:" + err.Error())
  914. return err
  915. }
  916. }
  917. return
  918. }
  919. func EditChartEnInfoAndEdbEnInfo(req *EditChartEnInfoReq) (err error) {
  920. o := orm.NewOrmUsingDB("data")
  921. to, err := o.Begin()
  922. if err != nil {
  923. return
  924. }
  925. defer func() {
  926. if err != nil {
  927. _ = to.Rollback()
  928. } else {
  929. _ = to.Commit()
  930. }
  931. }()
  932. var pars []interface{}
  933. updateField := ` chart_name_en =?, `
  934. pars = append(pars, req.ChartNameEn)
  935. if req.ExtraConfig != `` {
  936. updateField += ` extra_config =?, `
  937. pars = append(pars, req.ExtraConfig)
  938. }
  939. sql := ` UPDATE chart_info
  940. SET ` + updateField + ` modify_time = NOW()
  941. WHERE chart_info_id = ?`
  942. pars = append(pars, req.ChartInfoId)
  943. _, err = to.Raw(sql, pars).Exec()
  944. if err != nil {
  945. fmt.Println("UPDATE chart_info Err:", err.Error())
  946. return err
  947. }
  948. var edbInfoIdArr []string
  949. for _, v := range req.ChartEdbInfoList {
  950. edbInfoIdArr = append(edbInfoIdArr, strconv.Itoa(v.EdbInfoId))
  951. var count int
  952. csql := `SELECT COUNT(1) AS count FROM chart_edb_mapping WHERE chart_info_id=? AND edb_info_id=? `
  953. err = to.Raw(csql, req.ChartInfoId, v.EdbInfoId).QueryRow(&count)
  954. if err != nil {
  955. fmt.Println("QueryRow Err:", err.Error())
  956. return err
  957. }
  958. if count > 0 {
  959. msql := ` UPDATE edb_info
  960. SET
  961. edb_name_en =?,
  962. unit_en = ?,
  963. modify_time = NOW()
  964. WHERE edb_info_id = ? `
  965. _, err = to.Raw(msql, v.EdbNameEn, v.UnitEn, v.EdbInfoId).Exec()
  966. if err != nil {
  967. fmt.Println("edb_info Err:" + err.Error())
  968. return err
  969. }
  970. }
  971. }
  972. return
  973. }
  974. func ModifyEdbDatadTimestamp(source, subSource, edbDataId int, dataTimestamp int64) (err error) {
  975. tableName := GetEdbDataTableName(source, subSource)
  976. sql := `UPDATE %s SET data_timestamp=? WHERE edb_data_id=? `
  977. sql = fmt.Sprintf(sql, tableName)
  978. o := orm.NewOrmUsingDB("data")
  979. _, err = o.Raw(sql, dataTimestamp, edbDataId).Exec()
  980. return
  981. }
  982. type AddChartInfoReq struct {
  983. ChartEdbInfoList []*ChartSaveItem `description:"指标及配置信息"`
  984. ChartClassifyId int `description:"分类id"`
  985. ChartName string `description:"图表名称"`
  986. ChartType int `description:"生成样式:1:曲线图,2:季节性图,3:面积图,4:柱状图,5:散点图,6:组合图,7:柱方图"`
  987. DateType int `description:"日期类型:1:00年至今,2:10年至今,3:15年至今,4:年初至今,5:自定义时间,6:起始日期至今"`
  988. StartDate string `description:"自定义开始日期"`
  989. EndDate string `description:"自定义结束日期"`
  990. Calendar string `description:"公历/农历"`
  991. SeasonStartDate string `description:"季节性图开始日期"`
  992. SeasonEndDate string `description:"季节性图开始日期"`
  993. LeftMin string `description:"图表左侧最小值"`
  994. LeftMax string `description:"图表左侧最大值"`
  995. RightMin string `description:"图表右侧最小值"`
  996. RightMax string `description:"图表右侧最大值"`
  997. Right2Min string `description:"图表右侧2最小值"`
  998. Right2Max string `description:"图表右侧2最大值"`
  999. BarChartInfo BarChartInfoReq `description:"柱方图的配置"`
  1000. CorrelationChartInfo CorrelationChartInfoReq `description:"相关性图表配置"`
  1001. ExtraConfig string `description:"图表额外配置信息,json字符串"`
  1002. ChartImage string `description:"封面图" json:"-"`
  1003. }
  1004. type AddChartInfoResp struct {
  1005. ChartInfoId int `description:"图表id"`
  1006. UniqueCode string `description:"图表唯一编码"`
  1007. ChartType int `description:"生成样式:1:曲线图,2:季节性图"`
  1008. }
  1009. // 判断图表指标是否已经存在
  1010. func ChartInfoExist(condition, edbInfoIdStr string) (count int, err error) {
  1011. sql := `SELECT COUNT(1) AS count FROM (
  1012. SELECT GROUP_CONCAT(edb_info_id ORDER BY edb_info_id ASC SEPARATOR ',') AS edb_info_id_str
  1013. FROM chart_edb_mapping AS a
  1014. WHERE 1=1`
  1015. if condition != "" {
  1016. sql += condition
  1017. }
  1018. sql += ` GROUP BY chart_info_id
  1019. )AS t
  1020. WHERE t.edb_info_id_str=?
  1021. GROUP BY t.edb_info_id_str `
  1022. o := orm.NewOrmUsingDB("data")
  1023. err = o.Raw(sql, edbInfoIdStr).QueryRow(&count)
  1024. return
  1025. }
  1026. func ChartInfoSearchByKeyWord(KeyWord string, showSysId int) (searchList []*ChartInfo, err error) {
  1027. o := orm.NewOrmUsingDB("data")
  1028. sql := ` SELECT * FROM chart_info WHERE 1=1 `
  1029. var pars []interface{}
  1030. if KeyWord != "" {
  1031. sql += `AND chart_name LIKE ? `
  1032. pars = append(pars, "%"+KeyWord+"%")
  1033. }
  1034. if showSysId > 0 {
  1035. sql += ` AND sys_user_id = ? `
  1036. pars = append(pars, showSysId)
  1037. }
  1038. sql += ` ORDER BY create_time DESC `
  1039. if KeyWord == "" {
  1040. sql += ` LIMIT 100 `
  1041. }
  1042. _, err = o.Raw(sql, pars).QueryRows(&searchList)
  1043. return
  1044. }
  1045. // ChartInfoSearchByEmptyKeyWord 没有关键字的时候获取默认100条数据
  1046. func ChartInfoSearchByEmptyKeyWord(showSysId int, sourceList []int, noPermissionChartIdList []int, startSize, pageSize int) (total int64, searchList []*ChartInfo, err error) {
  1047. num := len(sourceList)
  1048. o := orm.NewOrmUsingDB("data")
  1049. baseSql := ` FROM chart_info WHERE 1=1 AND source in (` + utils.GetOrmInReplace(num) + `)`
  1050. var basePars []interface{}
  1051. basePars = append(basePars, sourceList)
  1052. if showSysId > 0 {
  1053. baseSql += ` AND sys_user_id = ? `
  1054. basePars = append(basePars, showSysId)
  1055. }
  1056. lenNoPermissionChartIdList := len(noPermissionChartIdList)
  1057. if lenNoPermissionChartIdList > 0 {
  1058. baseSql += ` AND chart_info_id not in (` + utils.GetOrmInReplace(lenNoPermissionChartIdList) + `) `
  1059. basePars = append(basePars, noPermissionChartIdList)
  1060. }
  1061. // 查找数量
  1062. totalSql := " SELECT count(1) as total " + baseSql
  1063. err = o.Raw(totalSql, basePars).QueryRow(&total)
  1064. if err != nil {
  1065. return
  1066. }
  1067. // 查找列表数据
  1068. sql := " SELECT * " + baseSql + ` ORDER BY create_time DESC LIMIT ?,? `
  1069. basePars = append(basePars, startSize, pageSize)
  1070. _, err = o.Raw(sql, basePars).QueryRows(&searchList)
  1071. return
  1072. }
  1073. func GetNextChartInfo(classifyId int) (item *ChartInfo, err error) {
  1074. o := orm.NewOrmUsingDB("data")
  1075. sql := ` SELECT b.* FROM chart_classify AS a
  1076. INNER JOIN chart_info AS b ON a.chart_classify_id=b.chart_classify_id
  1077. WHERE a.chart_classify_id>?
  1078. ORDER BY a.chart_classify_id ASC
  1079. LIMIT 1 `
  1080. err = o.Raw(sql, classifyId).QueryRow(&item)
  1081. return
  1082. }
  1083. // GetChartInfoRefreshData 获取图表关联的指标信息
  1084. func GetChartInfoRefreshData(chartInfoId int) (baseEdbInfoArr, calculateInfoArr []*EdbInfo, err error) {
  1085. o := orm.NewOrmUsingDB("data")
  1086. sql := ` SELECT b.* FROM chart_edb_mapping AS a
  1087. INNER JOIN edb_info AS b ON a.edb_info_id=b.edb_info_id
  1088. WHERE a.chart_info_id=? `
  1089. edbInfoList := make([]*EdbInfo, 0)
  1090. _, err = o.Raw(sql, chartInfoId).QueryRows(&edbInfoList)
  1091. if err != nil {
  1092. return
  1093. }
  1094. for _, v := range edbInfoList {
  1095. fmt.Println(v.EdbInfoId, v.EdbType)
  1096. if v.EdbType == 1 {
  1097. baseEdbInfoArr = append(baseEdbInfoArr, v)
  1098. } else {
  1099. calculateInfoArr = append(calculateInfoArr, v)
  1100. newBaseEdbInfoArr, newCalculateInfoArr, err := GetChartRefreshEdbInfo(v.EdbInfoId, v.Source, 0)
  1101. if err != nil {
  1102. return baseEdbInfoArr, calculateInfoArr, err
  1103. }
  1104. baseEdbInfoArr = append(baseEdbInfoArr, newBaseEdbInfoArr...)
  1105. calculateInfoArr = append(calculateInfoArr, newCalculateInfoArr...)
  1106. }
  1107. }
  1108. return
  1109. }
  1110. func GetChartRefreshEdbInfo(edbInfoId, source, n int) (baseEdbInfoArr, calculateInfoArr []*EdbInfo, err error) {
  1111. calculateList, err := GetEdbInfoCalculateMap(edbInfoId, source)
  1112. if err != nil && err.Error() != utils.ErrNoRow() {
  1113. return
  1114. }
  1115. n++
  1116. for _, item := range calculateList {
  1117. fmt.Println(item.EdbInfoId)
  1118. if item.EdbType == 1 {
  1119. baseEdbInfoArr = append(baseEdbInfoArr, item)
  1120. } else {
  1121. calculateInfoArr = append(calculateInfoArr, item)
  1122. if n > 10 {
  1123. return
  1124. }
  1125. newBaseEdbInfoArr, newCalculateInfoArr, _ := GetChartRefreshEdbInfo(item.EdbInfoId, item.Source, n)
  1126. baseEdbInfoArr = append(baseEdbInfoArr, newBaseEdbInfoArr...)
  1127. calculateInfoArr = append(calculateInfoArr, newCalculateInfoArr...)
  1128. }
  1129. }
  1130. return
  1131. }
  1132. type SetChartInfoImageReq struct {
  1133. ChartInfoId int `description:"图表ID"`
  1134. ImageUrl string `description:"图表图片地址"`
  1135. }
  1136. func EditChartInfoImage(req *SetChartInfoImageReq) (err error) {
  1137. o := orm.NewOrmUsingDB("data")
  1138. sql := ` UPDATE chart_info SET chart_image=?, modify_time = NOW() WHERE chart_info_id = ? `
  1139. _, err = o.Raw(sql, req.ImageUrl, req.ChartInfoId).Exec()
  1140. if err != nil {
  1141. fmt.Println("EditChartInfoImage Err:", err.Error())
  1142. return err
  1143. }
  1144. return
  1145. }
  1146. type ChartInfoDetailFromUniqueCodeResp struct {
  1147. ChartInfo *ChartInfoView
  1148. Status bool `description:"true:图表存在,false:图表不存在"`
  1149. EdbInfoList []*ChartEdbInfoMapping
  1150. XEdbIdValue []int `description:"柱方图的x轴数据,指标id"`
  1151. YDataList []YData `description:"柱方图的y轴数据"`
  1152. XDataList []XData `description:"商品价格曲线的X轴数据"`
  1153. BarChartInfo BarChartInfoReq `description:"柱方图的配置"`
  1154. CorrelationChartInfo *CorrelationInfo `description:"相关性图表信息"`
  1155. DataResp interface{} `description:"图表数据,根据图的类型而定的,没有确定的数据格式"`
  1156. }
  1157. func GetChartInfoByUniqueCode(uniqueCode string) (item *ChartInfo, err error) {
  1158. o := orm.NewOrmUsingDB("data")
  1159. sql := ` SELECT * FROM chart_info WHERE unique_code=? `
  1160. err = o.Raw(sql, uniqueCode).QueryRow(&item)
  1161. return
  1162. }
  1163. func GetChartInfoViewByUniqueCode(uniqueCode string) (item *ChartInfoView, err error) {
  1164. o := orm.NewOrmUsingDB("data")
  1165. sql := ` SELECT * FROM chart_info WHERE unique_code=? `
  1166. err = o.Raw(sql, uniqueCode).QueryRow(&item)
  1167. return
  1168. }
  1169. // GetFirstChartInfoByClassifyId 获取当前分类下,且排序数相同 的排序第一条的数据
  1170. func GetFirstChartInfoByClassifyId(classifyId int) (item *ChartInfo, err error) {
  1171. o := orm.NewOrmUsingDB("data")
  1172. sql := ` SELECT * FROM chart_info WHERE chart_classify_id=? order by sort asc,chart_info_id asc limit 1`
  1173. err = o.Raw(sql, classifyId).QueryRow(&item)
  1174. return
  1175. }
  1176. // UpdateChartInfoSortByClassifyId 根据图表id更新排序
  1177. func UpdateChartInfoSortByClassifyId(classifyId, nowSort, prevChartInfoId int, sourceList []int, updateSort string) (err error) {
  1178. o := orm.NewOrmUsingDB("data")
  1179. num := len(sourceList)
  1180. if num <= 0 {
  1181. return
  1182. }
  1183. sql := ` update chart_info set sort = ` + updateSort + ` WHERE chart_classify_id=? AND source in (` + utils.GetOrmInReplace(num) + `) AND `
  1184. if prevChartInfoId > 0 {
  1185. sql += ` (sort > ? or (chart_info_id > ` + fmt.Sprint(prevChartInfoId) + ` and sort = ` + fmt.Sprint(nowSort) + `))`
  1186. }
  1187. _, err = o.Raw(sql, classifyId, sourceList, nowSort).Exec()
  1188. return
  1189. }
  1190. // Update 更新图表基础信息
  1191. func (chartInfo *ChartInfo) Update(cols []string) (err error) {
  1192. o := orm.NewOrmUsingDB("data")
  1193. _, err = o.Update(chartInfo, cols...)
  1194. return
  1195. }
  1196. type ChartInfoView struct {
  1197. ChartInfoId int `orm:"column(chart_info_id);pk"`
  1198. ChartName string `description:"来源名称"`
  1199. ChartNameEn string `description:"英文图表名称"`
  1200. UnitEn string `description:"英文单位名称"`
  1201. Unit string `description:"图表单位"`
  1202. ChartClassifyId int `description:"图表分类id"`
  1203. ChartClassifyName string `description:"图表名称"`
  1204. SysUserId int
  1205. SysUserRealName string
  1206. UniqueCode string `description:"图表唯一编码"`
  1207. CreateTime time.Time
  1208. ModifyTime time.Time
  1209. DateType int `description:"日期类型:1:00年至今,2:10年至今,3:15年至今,4:年初至今,5:自定义时间"`
  1210. StartDate string `description:"自定义开始日期"`
  1211. EndDate string `description:"自定义结束日期"`
  1212. IsSetName int `description:"设置名称"`
  1213. EdbInfoIds string `description:"指标id"`
  1214. ChartType int `description:"生成样式:1:曲线图,2:季节性图"`
  1215. Calendar string `description:"公历/农历"`
  1216. SeasonStartDate string `description:"季节性图开始日期"`
  1217. SeasonEndDate string `description:"季节性图开始日期"`
  1218. ChartImage string `description:"图表图片"`
  1219. Sort int `description:"排序字段,数字越小越排前面"`
  1220. IsAdd bool `description:"true:已加入我的图库,false:未加入我的图库"`
  1221. MyChartId int
  1222. MyChartClassifyId string `description:"我的图表分类,多个用逗号隔开"`
  1223. ChartClassify []*ChartClassifyView
  1224. EdbEndDate string `description:"指标最新更新日期"`
  1225. XMin string `description:"图表X轴最小值"`
  1226. XMax string `description:"图表X轴最大值"`
  1227. LeftMin string `description:"图表左侧最小值"`
  1228. LeftMax string `description:"图表左侧最大值"`
  1229. RightMin string `description:"图表右侧最小值"`
  1230. RightMax string `description:"图表右侧最大值"`
  1231. Right2Min string `description:"图表右侧最小值"`
  1232. Right2Max string `description:"图表右侧最大值"`
  1233. MinMaxSave int `description:"是否手动保存过上下限:0-否;1-是"`
  1234. IsEdit bool `description:"是否有编辑权限"`
  1235. IsEnChart bool `description:"是否展示英文标识"`
  1236. WarnMsg string `description:"错误信息"`
  1237. Disabled int `description:"是否禁用,0:启用,1:禁用,默认:0"`
  1238. BarConfig string `description:"柱方图的配置,json数据" json:"-"`
  1239. Source int `description:"1:ETA图库;2:商品价格曲线;3:相关性图表"`
  1240. //CorrelationLeadUnit string `description:"相关性图表-领先单位"`
  1241. ExtraConfig string `description:"图表额外配置,json数据"`
  1242. Button ChartViewButton `description:"操作按钮"`
  1243. SeasonExtraConfig string `description:"季节性图表中的配置,json数据"`
  1244. StartYear int `description:"当选择的日期类型为最近N年类型时,即date_type=20, 用start_year表示N"`
  1245. ChartThemeId int `description:"图表应用主题ID"`
  1246. ChartThemeStyle string `description:"图表应用主题样式"`
  1247. SourcesFrom string `description:"图表来源"`
  1248. Instructions string `description:"图表说明"`
  1249. MarkersLines string `description:"标识线"`
  1250. }
  1251. type ChartViewButton struct {
  1252. IsEdit bool `description:"是否有编辑权限"`
  1253. IsEnChart bool `description:"是否展示英文标识"`
  1254. IsAdd bool `description:"true:已加入我的图库,false:未加入我的图库"`
  1255. IsCopy bool `description:"是否有另存为按钮"`
  1256. IsSetName int `description:"设置名称"`
  1257. }
  1258. type ImageSvgToPngResp struct {
  1259. Data struct {
  1260. ResourceURL string `json:"ResourceUrl"`
  1261. } `json:"Data"`
  1262. ErrCode string `json:"ErrCode"`
  1263. ErrMsg string `json:"ErrMsg"`
  1264. IsSendEmail bool `json:"IsSendEmail"`
  1265. Msg string `json:"Msg"`
  1266. Ret int64 `json:"Ret"`
  1267. Success bool `json:"Success"`
  1268. }
  1269. // GetChartInfoByClassifyIdAndName 根据分类id和图表名获取图表信息
  1270. func GetChartInfoByClassifyIdAndName(classifyId int, chartName string) (item *ChartInfo, err error) {
  1271. o := orm.NewOrmUsingDB("data")
  1272. sql := ` SELECT * FROM chart_info WHERE chart_classify_id = ? and chart_name=? `
  1273. err = o.Raw(sql, classifyId, chartName).QueryRow(&item)
  1274. return
  1275. }
  1276. // BatchChartRefreshReq 批量刷新图表请求
  1277. type BatchChartRefreshReq struct {
  1278. ChartInfoCode []string `description:"图表编码数组"`
  1279. ReportId int `description:"报告id"`
  1280. ReportChapterId int `description:"报告章节id"`
  1281. Source string `description:"来源,枚举值:report、english_report、smart_report"`
  1282. }
  1283. // GetChartInfoListByUniqueCodeSlice 根据图表编码获取图表列表数据
  1284. func GetChartInfoListByUniqueCodeSlice(uniqueCodeSlice []string) (total int64, items []*ChartInfo, err error) {
  1285. if len(uniqueCodeSlice) <= 0 {
  1286. return
  1287. }
  1288. o := orm.NewOrmUsingDB("data")
  1289. sql := ` SELECT * FROM chart_info WHERE unique_code in ("` + strings.Join(uniqueCodeSlice, `","`) + `") `
  1290. total, err = o.Raw(sql).QueryRows(&items)
  1291. return
  1292. }
  1293. // GetChartInfoRefreshDataByChartInfoIdSlice 根据图表id切片获取对应的指标数据
  1294. func GetChartInfoRefreshDataByChartInfoIdSlice(chartInfoIdSlice []string) (baseEdbInfoArr, calculateInfoArr []*EdbInfo, err error) {
  1295. o := orm.NewOrmUsingDB("data")
  1296. if len(chartInfoIdSlice) <= 0 {
  1297. return
  1298. }
  1299. sql := ` SELECT b.* FROM chart_edb_mapping AS a
  1300. INNER JOIN edb_info AS b ON a.edb_info_id=b.edb_info_id
  1301. WHERE a.chart_info_id in (` + strings.Join(chartInfoIdSlice, ",") + `) `
  1302. edbInfoList := make([]*EdbInfo, 0)
  1303. _, err = o.Raw(sql).QueryRows(&edbInfoList)
  1304. if err != nil {
  1305. return
  1306. }
  1307. for _, v := range edbInfoList {
  1308. if v.EdbType == 1 {
  1309. baseEdbInfoArr = append(baseEdbInfoArr, v)
  1310. } else {
  1311. calculateInfoArr = append(calculateInfoArr, v)
  1312. newBaseEdbInfoArr, newCalculateInfoArr, err := GetChartRefreshEdbInfo(v.EdbInfoId, v.Source, 0)
  1313. if err != nil {
  1314. return baseEdbInfoArr, calculateInfoArr, err
  1315. }
  1316. baseEdbInfoArr = append(baseEdbInfoArr, newBaseEdbInfoArr...)
  1317. calculateInfoArr = append(calculateInfoArr, newCalculateInfoArr...)
  1318. }
  1319. }
  1320. return
  1321. }
  1322. // CopyAddChartInfoReq 复制并新增图表
  1323. type CopyAddChartInfoReq struct {
  1324. ChartInfoId int `description:"待复制的图表id"`
  1325. ChartClassifyId int `description:"分类id"`
  1326. ChartName string `description:"图表名称"`
  1327. }
  1328. // ChartInfoListByEsResp 图表数据Es搜索返回
  1329. type ChartInfoListByEsResp struct {
  1330. Paging *paging.PagingItem
  1331. List []*ChartInfoMore
  1332. }
  1333. // GetChartInfoListByCondition 根据条件获取图表数据了列表
  1334. func GetChartInfoListByCondition(condition string, pars []interface{}, startSize, pageSize int) (items []*ChartInfo, err error) {
  1335. o := orm.NewOrmUsingDB("data")
  1336. sql := ` SELECT * FROM chart_info WHERE 1=1 `
  1337. if condition != "" {
  1338. sql += condition
  1339. }
  1340. sql += ` ORDER BY chart_info_id DESC LIMIT ?,? `
  1341. _, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&items)
  1342. return
  1343. }
  1344. // GetChartInfoListGroupByUserId 根据指标id列表、用户分组获取指标信息
  1345. func GetChartInfoListGroupByUserId(edbIdList []string) (items []*ChartInfo, err error) {
  1346. num := len(edbIdList)
  1347. if num <= 0 {
  1348. return
  1349. }
  1350. o := orm.NewOrmUsingDB("data")
  1351. sql := ` SELECT * FROM chart_info WHERE chart_info_id in (` + utils.GetOrmInReplace(num) + `) GROUP BY sys_user_id `
  1352. _, err = o.Raw(sql, edbIdList).QueryRows(&items)
  1353. return
  1354. }
  1355. // ModifyChartInfoUserIdByCodeList 根据指标code列表修改创建人
  1356. func ModifyChartInfoUserIdByCodeList(edbIdList []string, userId int, userName string) (err error) {
  1357. num := len(edbIdList)
  1358. if num <= 0 {
  1359. return
  1360. }
  1361. o := orm.NewOrmUsingDB("data")
  1362. sql := `UPDATE chart_info SET sys_user_id=?,sys_user_real_name=? WHERE chart_info_id in (` + utils.GetOrmInReplace(num) + `) `
  1363. _, err = o.Raw(sql, userId, userName, edbIdList).Exec()
  1364. return
  1365. }
  1366. // BarChartInfoReq 柱方图预览请求数据
  1367. type BarChartInfoReq struct {
  1368. EdbInfoIdList []BarChartInfoEdbItemReq `description:"指标信息"`
  1369. DateList []BarChartInfoDateReq `description:"日期配置"`
  1370. Sort BarChartInfoSortReq `description:"排序"`
  1371. XEdbList []BarChartInfoEdbItemReq `description:"X轴选择的指标列表"`
  1372. YEdbList []BarChartInfoEdbItemReq `description:"Y轴选择的指标列表"`
  1373. Unit string `description:"中文单位名称"`
  1374. UnitEn string `description:"英文单位名称"`
  1375. }
  1376. // BarChartInfoEdbItemReq 柱方图预览请求数据(指标相关)
  1377. type BarChartInfoEdbItemReq struct {
  1378. EdbInfoId int `description:"指标ID"`
  1379. Name string `description:"别名"`
  1380. NameEn string `description:"英文别名"`
  1381. Source int `description:"1:ETA图库;2:商品价格"`
  1382. }
  1383. // BarChartInfoDateReq 柱方图预览请求数据(日期相关)
  1384. type BarChartInfoDateReq struct {
  1385. Type int `description:"配置类型"`
  1386. Date string `description:"固定日期"`
  1387. Value int `description:"N天的值"`
  1388. Color string `description:"颜色"`
  1389. Name string `description:"别名"`
  1390. }
  1391. // BarChartInfoSortReq 柱方图预览请求数据(排序相关)
  1392. type BarChartInfoSortReq struct {
  1393. Sort int `description:"排序类型,0:默认,1:升序,2:降序"`
  1394. DateIndex int `description:"日期数据的下标,从0开始"`
  1395. }
  1396. // CorrelationChartInfoReq 相关性图表请求体
  1397. type CorrelationChartInfoReq struct {
  1398. LeadValue int `description:"领先期数"`
  1399. LeadUnit string `description:"频度"`
  1400. CalculateValue int `description:"计算窗口"`
  1401. CalculateUnit string `description:"计算频度"`
  1402. BaseCalculateValue int `description:"基础计算窗口(滚动相关性的时候用到)"`
  1403. BaseCalculateUnit string `description:"基础计算频度(滚动相关性的时候用到)"`
  1404. DateType int `description:"日期类型:1:00年至今,2:10年至今,3:15年至今,4:年初至今,5:自定义时间,6:起始日期至今"`
  1405. StartDate string `description:"开始日期"`
  1406. EndDate string `description:"结束日期"`
  1407. EdbInfoIdList []CorrelationChartInfoEdbItemReq `description:"指标信息"`
  1408. }
  1409. // CorrelationChartInfoEdbItemReq 相关性图表请求指标
  1410. type CorrelationChartInfoEdbItemReq struct {
  1411. EdbInfoId int `description:"指标ID"`
  1412. Name string `description:"别名"`
  1413. NameEn string `description:"英文别名"`
  1414. //Source int `description:"1:ETA图库;2:商品价格"`
  1415. }
  1416. // EditCorrelationChartInfoAndMapping 修改相关性图表的 图表与指标 的关系
  1417. func EditCorrelationChartInfoAndMapping(req *EditChartInfoReq, edbInfoIdStr string, calendar string, dateType, disabled int, barChartConf string, correlationChart *ChartInfoCorrelation, correlationUpdateCols []string) (err error) {
  1418. o := orm.NewOrmUsingDB("data")
  1419. to, err := o.Begin()
  1420. if err != nil {
  1421. return
  1422. }
  1423. defer func() {
  1424. if err != nil {
  1425. _ = to.Rollback()
  1426. } else {
  1427. _ = to.Commit()
  1428. }
  1429. }()
  1430. var pars []interface{}
  1431. pars = append(pars, req.ChartName)
  1432. pars = append(pars, edbInfoIdStr)
  1433. pars = append(pars, req.ChartType)
  1434. pars = append(pars, req.ChartClassifyId)
  1435. pars = append(pars, disabled)
  1436. pars = append(pars, barChartConf)
  1437. sql := ` UPDATE chart_info
  1438. SET
  1439. chart_name =?,
  1440. edb_info_ids=?,
  1441. chart_type=?,
  1442. chart_classify_id = ?,
  1443. modify_time = NOW(),
  1444. disabled = ?,
  1445. bar_config = ?
  1446. `
  1447. if calendar != "" {
  1448. sql += `,calendar = ? `
  1449. pars = append(pars, calendar)
  1450. }
  1451. if dateType > 0 {
  1452. sql += `,date_type = ? `
  1453. pars = append(pars, dateType)
  1454. }
  1455. sql += `,start_date = ? `
  1456. pars = append(pars, req.StartDate)
  1457. sql += `,end_date = ? `
  1458. pars = append(pars, req.EndDate)
  1459. sql += `,season_start_date = ? `
  1460. pars = append(pars, req.SeasonStartDate)
  1461. sql += `,season_end_date = ? `
  1462. pars = append(pars, req.SeasonEndDate)
  1463. sql += `,left_min = ? `
  1464. pars = append(pars, req.LeftMin)
  1465. sql += `,left_max = ? `
  1466. pars = append(pars, req.LeftMax)
  1467. sql += `,right_min = ? `
  1468. pars = append(pars, req.RightMin)
  1469. sql += `,right_max = ? `
  1470. pars = append(pars, req.RightMax)
  1471. sql += `WHERE chart_info_id = ?`
  1472. pars = append(pars, req.ChartInfoId)
  1473. _, err = to.Raw(sql, pars).Exec()
  1474. if err != nil {
  1475. fmt.Println("UPDATE chart_info Err:", err.Error())
  1476. return err
  1477. }
  1478. chartEdbMappingIdList := make([]string, 0)
  1479. for _, v := range req.CorrelationChartInfo.EdbInfoIdList {
  1480. // 查询该指标是否存在,如果存在的话,那么就去修改,否则新增
  1481. var tmpChartEdbMapping *ChartEdbMapping
  1482. csql := `SELECT * FROM chart_edb_mapping WHERE chart_info_id=? AND edb_info_id=? AND source = ? `
  1483. err = to.Raw(csql, req.ChartInfoId, v.EdbInfoId, utils.CHART_SOURCE_CORRELATION).QueryRow(&tmpChartEdbMapping)
  1484. if err != nil && err.Error() != utils.ErrNoRow() {
  1485. fmt.Println("QueryRow Err:", err.Error())
  1486. return err
  1487. }
  1488. if tmpChartEdbMapping != nil {
  1489. chartEdbMappingIdList = append(chartEdbMappingIdList, strconv.Itoa(tmpChartEdbMapping.ChartEdbMappingId))
  1490. //tmpChartEdbMapping.ModifyTime = time.Now()
  1491. //tmpChartEdbMapping.MaxData = v.MaxData
  1492. //tmpChartEdbMapping.MinData = v.MinData
  1493. //tmpChartEdbMapping.IsOrder = v.IsOrder
  1494. //tmpChartEdbMapping.IsAxis = v.IsAxis
  1495. //tmpChartEdbMapping.EdbInfoType = v.EdbInfoType
  1496. //tmpChartEdbMapping.LeadValue = v.LeadValue
  1497. //tmpChartEdbMapping.LeadUnit = v.LeadUnit
  1498. //tmpChartEdbMapping.ChartStyle = v.ChartStyle
  1499. //tmpChartEdbMapping.ChartColor = v.ChartColor
  1500. //tmpChartEdbMapping.PredictChartColor = v.PredictChartColor
  1501. //tmpChartEdbMapping.ChartWidth = v.ChartWidth
  1502. //_, err = to.Update(tmpChartEdbMapping, "ModifyTime", "MaxData", "MinData", "IsOrder", "IsAxis", "EdbInfoType", "LeadValue", "LeadUnit", "ChartStyle", "ChartColor", "PredictChartColor", "ChartWidth")
  1503. //if err != nil {
  1504. // fmt.Println("chart_edb_mapping Err:" + err.Error())
  1505. // return err
  1506. //}
  1507. } else {
  1508. mapItem := new(ChartEdbMapping)
  1509. mapItem.ChartInfoId = req.ChartInfoId
  1510. mapItem.EdbInfoId = v.EdbInfoId
  1511. mapItem.CreateTime = time.Now()
  1512. mapItem.ModifyTime = time.Now()
  1513. timestamp := strconv.FormatInt(time.Now().UnixNano(), 10)
  1514. mapItem.UniqueCode = utils.MD5(utils.CHART_PREFIX + "_" + timestamp + "_" + strconv.Itoa(v.EdbInfoId))
  1515. //mapItem.MaxData = v.MaxData
  1516. //mapItem.MinData = v.MinData
  1517. mapItem.IsOrder = true
  1518. mapItem.IsAxis = 1
  1519. mapItem.EdbInfoType = 1
  1520. //mapItem.LeadValue = v.LeadValue
  1521. //mapItem.LeadUnit = v.LeadUnit
  1522. //mapItem.ChartStyle = v.ChartStyle
  1523. //mapItem.ChartColor = v.ChartColor
  1524. //mapItem.PredictChartColor = v.PredictChartColor
  1525. //mapItem.ChartWidth = v.ChartWidth
  1526. mapItem.Source = utils.CHART_SOURCE_CORRELATION
  1527. tmpId, err := to.Insert(mapItem)
  1528. if err != nil {
  1529. fmt.Println("AddChartEdbMapping Err:" + err.Error())
  1530. return err
  1531. }
  1532. mapItem.ChartEdbMappingId = int(tmpId)
  1533. chartEdbMappingIdList = append(chartEdbMappingIdList, strconv.Itoa(mapItem.ChartEdbMappingId))
  1534. }
  1535. }
  1536. if len(chartEdbMappingIdList) > 0 {
  1537. chartEdbMappingIdStr := strings.Join(chartEdbMappingIdList, ",")
  1538. dsql := `DELETE FROM chart_edb_mapping WHERE chart_info_id=? AND chart_edb_mapping_id NOT IN(` + chartEdbMappingIdStr + `)`
  1539. _, err = to.Raw(dsql, req.ChartInfoId).Exec()
  1540. if err != nil {
  1541. fmt.Println("delete err:" + err.Error())
  1542. return err
  1543. }
  1544. }
  1545. // 相关性图表
  1546. _, err = to.Update(correlationChart, correlationUpdateCols...)
  1547. return
  1548. }
  1549. // PreviewSectionScatterChartReq 预览截面散点图的请求
  1550. type PreviewSectionScatterChartReq struct {
  1551. ChartName string `description:"图表名称"`
  1552. ChartClassifyId int `description:"分类id"`
  1553. ExtraConfig string `description:"图表额外配置信息,json字符串"`
  1554. }
  1555. // SectionScatterReq 截面散点请求
  1556. type SectionScatterReq struct {
  1557. XName string `description:"x轴名称"`
  1558. XNameEn string `description:"x轴名称(英文)"`
  1559. XUnitName string `description:"x轴单位名称"`
  1560. XUnitNameEn string `description:"x轴单位名称(英文)"`
  1561. YName string `description:"y轴名称"`
  1562. YNameEn string `description:"y轴名称(英文)"`
  1563. YUnitName string `description:"y轴单位名称"`
  1564. YUnitNameEn string `description:"y轴单位名称(英文)"`
  1565. XMinValue string `description:"X轴的最小值"`
  1566. XMaxValue string `description:"X轴的最大值"`
  1567. YMinValue string `description:"Y轴的最小值"`
  1568. YMaxValue string `description:"Y轴的最大值"`
  1569. //EdbList []SectionScatterEdbItemReq `description:"指标数据"`
  1570. SeriesList []SectionScatterSeriesItemReq `description:"系列数据"`
  1571. }
  1572. // SectionScatterSeriesItemReq 系列的请求
  1573. type SectionScatterSeriesItemReq struct {
  1574. Name string `description:"系列名"`
  1575. NameEn string `description:"系列名(英文名)"`
  1576. Color string `description:"颜色"`
  1577. EdbInfoList []SectionScatterEdbItemReq
  1578. ShowTrendLine bool `description:"是否展示趋势线"`
  1579. ShowFitEquation bool `description:"是否展示方程式"`
  1580. ShowRSquare bool `description:"是否展示R平方"`
  1581. }
  1582. // SectionScatterEdbItemReq 截面散点请求的指标
  1583. type SectionScatterEdbItemReq struct {
  1584. XEdbInfoId int `description:"X轴的指标ID"`
  1585. YEdbInfoId int `description:"Y轴的指标ID"`
  1586. Name string `description:"别名"`
  1587. NameEn string `description:"英文别名"`
  1588. XDateType int `description:"X轴的日期配置类型"`
  1589. XDate string `description:"X轴的日期固定日期"`
  1590. XDateValue int `description:"X轴的日期N天的值"`
  1591. YDateType int `description:"Y轴的日期配置类型"`
  1592. YDate string `description:"Y轴的日期固定日期"`
  1593. YDateValue int `description:"Y轴的日期N天的值"`
  1594. IsShow bool `description:"是否展示"`
  1595. }
  1596. // SectionScatterInfoResp 截面散点图数据
  1597. type SectionScatterInfoResp struct {
  1598. XName string `description:"x轴名称"`
  1599. XNameEn string `description:"x轴名称(英文)"`
  1600. XUnitName string `description:"x轴单位名称"`
  1601. XUnitNameEn string `description:"x轴单位名称(英文)"`
  1602. YName string `description:"y轴名称"`
  1603. YNameEn string `description:"y轴名称(英文)"`
  1604. YUnitName string `description:"y轴单位名称"`
  1605. YUnitNameEn string `description:"y轴单位名称(英文)"`
  1606. XMinValue string `description:"X轴的最小值"`
  1607. XMaxValue string `description:"X轴的最大值"`
  1608. YMinValue string `description:"Y轴的最小值"`
  1609. YMaxValue string `description:"Y轴的最大值"`
  1610. DataList []SectionScatterSeriesItemResp `description:"数据列"`
  1611. }
  1612. // SectionScatterSeriesItemResp 系列的返回
  1613. type SectionScatterSeriesItemResp struct {
  1614. Name string `description:"系列名"`
  1615. NameEn string `description:"系列名(英文)"`
  1616. Color string `description:"颜色"`
  1617. EdbInfoList []SectionScatterEdbItemResp
  1618. ShowTrendLine bool `description:"是否展示趋势线"`
  1619. ShowFitEquation bool `description:"是否展示方程式"`
  1620. ShowRSquare bool `description:"是否展示R平方"`
  1621. TrendLine string `description:"方程式"`
  1622. RSquare string `description:"R平方的值(决定系数R2)"`
  1623. TrendLimitData []CoordinatePoint `description:"趋势线的前后坐标点"`
  1624. }
  1625. // SectionScatterEdbItemResp 截面散点的返回参数
  1626. type SectionScatterEdbItemResp struct {
  1627. XEdbInfoId int `description:"X轴指标id"`
  1628. XDate string `description:"X轴指标实际日期"`
  1629. XName string `description:"X轴指标名称"`
  1630. XNameEn string `description:"X轴指标英文名称"`
  1631. XValue float64 `description:"X轴实际值"`
  1632. YEdbInfoId int `description:"Y轴指标id"`
  1633. YDate string `description:"Y轴指标实际日期"`
  1634. YName string `description:"Y轴指标名称"`
  1635. YNameEn string `description:"Y轴指标英文名称"`
  1636. YValue float64 `description:"Y轴实际值"`
  1637. IsShow bool `description:"是否展示"`
  1638. Name string `description:"标签名称"`
  1639. NameEn string `description:"英文标签名称"`
  1640. }
  1641. // CoordinatePoint 坐标点
  1642. type CoordinatePoint struct {
  1643. X float64
  1644. Y float64
  1645. }
  1646. // RollingCorrelationChartDataResp 滚动相关性图
  1647. type RollingCorrelationChartDataResp struct {
  1648. XDateTimeValue []string `description:"滚动相关性图的x轴数据,日期数据"`
  1649. YDataList []YData `description:"滚动相关性图的y轴数据"`
  1650. }
  1651. // GetChartInfoAll 用于分类展示
  1652. // @param source int 1:ETA图库;2:商品价格曲线
  1653. func GetChartInfoAllByClassifyId(source, classifyId int) (items []*ChartClassifyItems, err error) {
  1654. o := orm.NewOrmUsingDB("data")
  1655. sql := ` SELECT chart_info_id,chart_classify_id,chart_name AS chart_classify_name,chart_name_en AS chart_classify_name_en,
  1656. unique_code,sys_user_id,sys_user_real_name,date_type,start_date,end_date,chart_type,calendar,season_start_date,season_end_date
  1657. FROM chart_info WHERE chart_classify_id = ? AND source = ? ORDER BY sort asc,create_time DESC `
  1658. _, err = o.Raw(sql, classifyId, source).QueryRows(&items)
  1659. return
  1660. }
  1661. // ProfitFutureGoodChartResp 商品利润图
  1662. type ProfitFutureGoodChartResp struct {
  1663. XDataList []XData
  1664. YDataList []YData
  1665. ProfitName string `description:"利润的名称"`
  1666. ProfitNameEn string `description:"利润的英文名称"`
  1667. }
  1668. // ChartInfoLocate 图表位置响应体
  1669. type ChartInfoLocate struct {
  1670. ChartInfoId int `description:"图表ID"`
  1671. ChartName string `description:"图表名称"`
  1672. ChartType int `description:"图表类型"`
  1673. ChartClassifyId int `description:"图表分类id"`
  1674. ChartClassifyName string `description:"图表分类名称"`
  1675. UniqueCode string `description:"图表唯一编码"`
  1676. Source int `description:"1:ETA图库;2:商品价格曲线;3:相关性图表"`
  1677. StartDate string `description:""`
  1678. EndDate string `description:""`
  1679. SeasonStartDate string `description:""`
  1680. SeasonEndDate string `description:""`
  1681. DateType int `description:""`
  1682. Calendar string `description:""`
  1683. StartYear int `description:"当选择的日期类型为最近N年类型时,即date_type=20, 用start_year表示N"`
  1684. }
  1685. // GetChartInfoByAdminIdAndClassify 获取所有我创建的图表,用于分类展示
  1686. func GetChartInfoByAdminIdAndClassify(sourceList []int, adminId, classifyId int) (items []*ChartClassifyItems, err error) {
  1687. num := len(sourceList)
  1688. if num <= 0 {
  1689. return
  1690. }
  1691. o := orm.NewOrmUsingDB("data")
  1692. sql := ` SELECT chart_info_id,chart_classify_id,chart_name AS chart_classify_name,
  1693. unique_code,sys_user_id,sys_user_real_name,date_type,start_date,end_date,chart_type,calendar,season_start_date,season_end_date
  1694. FROM chart_info where source in (` + utils.GetOrmInReplace(num) + `) AND sys_user_id = ? AND chart_classify_id = ? ORDER BY sort asc,create_time ASC `
  1695. _, err = o.Raw(sql, sourceList, adminId, classifyId).QueryRows(&items)
  1696. return
  1697. }
  1698. // PreviewRadarChartReq 预览雷达图的请求入参
  1699. type PreviewRadarChartReq struct {
  1700. ChartEdbInfoList []*ChartSaveItem `description:"指标及配置信息"`
  1701. ExtraConfig string `description:"图表额外配置信息,json字符串"`
  1702. }
  1703. // RadarChartInfoReq 雷达图预览请求数据
  1704. type RadarChartInfoReq struct {
  1705. DateList []RadarChartInfoDateReq `description:"日期配置"`
  1706. }
  1707. // RadarChartInfoEdbItemReq 雷达图预览请求数据(指标相关)
  1708. type RadarChartInfoEdbItemReq struct {
  1709. EdbInfoId int `description:"指标ID"`
  1710. Name string `description:"别名"`
  1711. //NameEn string `description:"英文别名"`
  1712. //Source int `description:"1:ETA图库;2:商品价格"`
  1713. }
  1714. // RadarChartInfoDateReq 雷达图预览请求数据(日期相关)
  1715. type RadarChartInfoDateReq struct {
  1716. Type int `description:"配置类型"`
  1717. Date string `description:"固定日期"`
  1718. Value int `description:"N天的值"`
  1719. Color string `description:"颜色"`
  1720. Name string `description:"别名"`
  1721. }
  1722. // RadarChartInfoResp 雷达图数据
  1723. type RadarChartInfoResp struct {
  1724. YDataList []RadarYData `description:"数据列"`
  1725. XEdbIdValue []int
  1726. }
  1727. // RadarYData 雷达图的y轴数据
  1728. type RadarYData struct {
  1729. Date string `description:"数据日期"`
  1730. Color string `description:"数据颜色"`
  1731. Name string `description:"别名"`
  1732. Value []float64 `description:"每个指标的值"`
  1733. }