chart_info.go 65 KB

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