chart_info.go 83 KB

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