chart_info.go 42 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467
  1. package cross_variety
  2. import (
  3. "encoding/json"
  4. "eta/eta_api/controllers"
  5. "eta/eta_api/models"
  6. "eta/eta_api/models/data_manage"
  7. cross_varietyModels "eta/eta_api/models/data_manage/cross_variety"
  8. "eta/eta_api/models/data_manage/cross_variety/request"
  9. "eta/eta_api/models/data_manage/cross_variety/response"
  10. "eta/eta_api/models/system"
  11. "eta/eta_api/services/data"
  12. "eta/eta_api/services/data/cross_variety"
  13. "eta/eta_api/utils"
  14. "fmt"
  15. "github.com/rdlucklib/rdluck_tools/paging"
  16. "strconv"
  17. "strings"
  18. "time"
  19. )
  20. // ChartInfoController
  21. // @Description: 跨品种分析图表
  22. type ChartInfoController struct {
  23. controllers.BaseAuthController
  24. }
  25. // List
  26. // @Title 跨品种分析图表列表接口
  27. // @Description 跨品种分析图表列表接口
  28. // @Param PageSize query int true "每页数据条数"
  29. // @Param CurrentIndex query int true "当前页页码,从1开始"
  30. // @Param ChartClassifyId query int true "分类id"
  31. // @Param Keyword query string true "搜索关键词"
  32. // @Param IsShowMe query bool true "是否只看我的,true、false"
  33. // @Param Source query int true "图表类型,10:跨品种分析
  34. // @Success 200 {object} data_manage.ChartListResp
  35. // @router /chart_info/list [get]
  36. func (c *ChartInfoController) List() {
  37. br := new(models.BaseResponse).Init()
  38. defer func() {
  39. c.Data["json"] = br
  40. c.ServeJSON()
  41. }()
  42. sysUser := c.SysUser
  43. if sysUser == nil {
  44. br.Msg = "请登录"
  45. br.ErrMsg = "请登录,SysUser Is Empty"
  46. br.Ret = 408
  47. return
  48. }
  49. chartClassifyId, _ := c.GetInt("ChartClassifyId")
  50. pageSize, _ := c.GetInt("PageSize")
  51. currentIndex, _ := c.GetInt("CurrentIndex")
  52. keyword := c.GetString("KeyWord")
  53. var total int
  54. page := paging.GetPaging(currentIndex, pageSize, total)
  55. var startSize int
  56. if pageSize <= 0 {
  57. pageSize = utils.PageSize20
  58. }
  59. if currentIndex <= 0 {
  60. currentIndex = 1
  61. }
  62. startSize = paging.StartIndex(currentIndex, pageSize)
  63. source, _ := c.GetInt("Source")
  64. if source <= 0 {
  65. source = utils.CHART_SOURCE_CROSS_HEDGING
  66. }
  67. var condition string
  68. var pars []interface{}
  69. // 普通图表
  70. condition += ` AND source = ? `
  71. pars = append(pars, source)
  72. if chartClassifyId > 0 {
  73. chartClassifyId, err := data_manage.GetChartClassify(chartClassifyId)
  74. if err != nil && err.Error() != utils.ErrNoRow() {
  75. br.Msg = "获取图表信息失败"
  76. br.ErrMsg = "获取信息失败,GetChartClassify,Err:" + err.Error()
  77. return
  78. }
  79. condition += " AND chart_classify_id IN(" + chartClassifyId + ") "
  80. }
  81. if keyword != "" {
  82. condition += ` AND ( chart_name LIKE '%` + keyword + `%' )`
  83. }
  84. //只看我的
  85. isShowMe, _ := c.GetBool("IsShowMe")
  86. if isShowMe {
  87. condition += ` AND sys_user_id = ? `
  88. pars = append(pars, sysUser.AdminId)
  89. }
  90. // 获取当前账号的不可见指标
  91. noPermissionChartIdList := make([]int, 0)
  92. {
  93. obj := data_manage.EdbInfoNoPermissionAdmin{}
  94. confList, err := obj.GetAllChartListByAdminId(c.SysUser.AdminId)
  95. if err != nil && err.Error() != utils.ErrNoRow() {
  96. br.Msg = "获取失败"
  97. br.ErrMsg = "获取不可见指标配置数据失败,Err:" + err.Error()
  98. return
  99. }
  100. for _, v := range confList {
  101. noPermissionChartIdList = append(noPermissionChartIdList, v.ChartInfoId)
  102. }
  103. }
  104. lenNoPermissionChartIdList := len(noPermissionChartIdList)
  105. if lenNoPermissionChartIdList > 0 {
  106. condition += ` AND chart_info_id not in (` + utils.GetOrmInReplace(lenNoPermissionChartIdList) + `) `
  107. pars = append(pars, noPermissionChartIdList)
  108. }
  109. //获取图表信息
  110. list, err := data_manage.GetChartListByCondition(condition, pars, startSize, pageSize)
  111. if err != nil && err.Error() != utils.ErrNoRow() {
  112. br.Success = true
  113. br.Msg = "获取图表信息失败"
  114. br.ErrMsg = "获取图表信息失败,Err:" + err.Error()
  115. return
  116. }
  117. myChartList, err := data_manage.GetMyChartListByAdminId(sysUser.AdminId)
  118. if err != nil && err.Error() != utils.ErrNoRow() {
  119. br.Msg = "获取图表信息失败"
  120. br.ErrMsg = "获取我的图表信息失败,Err:" + err.Error()
  121. return
  122. }
  123. myChartMap := make(map[int]*data_manage.MyChartView)
  124. for _, v := range myChartList {
  125. myChartMap[v.ChartInfoId] = v
  126. }
  127. listLen := len(list)
  128. chartEdbMap := make(map[int][]*data_manage.ChartEdbInfoMapping)
  129. if listLen > 0 {
  130. chartInfoIds := ""
  131. for _, v := range list {
  132. chartInfoIds += strconv.Itoa(v.ChartInfoId) + ","
  133. }
  134. if chartInfoIds != "" {
  135. chartInfoIds = strings.Trim(chartInfoIds, ",")
  136. //判断是否需要展示英文标识
  137. edbList, e := data_manage.GetChartEdbMappingListByChartInfoIds(chartInfoIds)
  138. if e != nil {
  139. br.Msg = "获取失败"
  140. br.ErrMsg = "获取图表,指标信息失败,Err:" + e.Error()
  141. return
  142. }
  143. for _, v := range edbList {
  144. chartEdbMap[v.ChartInfoId] = append(chartEdbMap[v.ChartInfoId], v)
  145. }
  146. }
  147. }
  148. for i := 0; i < listLen; i++ {
  149. //判断是否需要展示英文标识
  150. if edbTmpList, ok := chartEdbMap[list[i].ChartInfoId]; ok {
  151. list[i].IsEnChart = data.CheckIsEnChart(list[i].ChartNameEn, edbTmpList, list[i].Source, list[i].ChartType)
  152. }
  153. if existItem, ok := myChartMap[list[i].ChartInfoId]; ok {
  154. list[i].IsAdd = true
  155. list[i].MyChartId = existItem.MyChartId
  156. list[i].MyChartClassifyId = existItem.MyChartClassifyId
  157. }
  158. }
  159. resp := new(data_manage.ChartListResp)
  160. if list == nil || len(list) <= 0 || (err != nil && err.Error() == utils.ErrNoRow()) {
  161. items := make([]*data_manage.ChartInfoView, 0)
  162. resp.Paging = page
  163. resp.List = items
  164. br.Ret = 200
  165. br.Success = true
  166. br.Msg = "获取成功"
  167. return
  168. }
  169. dataCount, err := data_manage.GetChartListCountByCondition(condition, pars)
  170. if err != nil && err.Error() != utils.ErrNoRow() {
  171. br.Msg = "获取指标信息失败"
  172. br.ErrMsg = "获取指标数据总数失败,Err:" + err.Error()
  173. return
  174. }
  175. page = paging.GetPaging(currentIndex, pageSize, dataCount)
  176. resp.Paging = page
  177. resp.List = list
  178. br.Ret = 200
  179. br.Success = true
  180. br.Msg = "获取成功"
  181. br.Data = resp
  182. }
  183. // Preview
  184. // @Title 跨品种分析图表-预览数据
  185. // @Description 跨品种分析图表-获取预览数据
  186. // // @Param request body request.ChartConfigReq true "type json string"
  187. // @Success 200 {object} data_manage.ChartEdbInfoDetailResp
  188. // @router /chart_info/preview [post]
  189. func (c *ChartInfoController) Preview() {
  190. br := new(models.BaseResponse).Init()
  191. defer func() {
  192. c.Data["json"] = br
  193. c.ServeJSON()
  194. }()
  195. sysUser := c.SysUser
  196. if sysUser == nil {
  197. br.Msg = "请登录"
  198. br.ErrMsg = "请登录,SysUser Is Empty"
  199. br.Ret = 408
  200. return
  201. }
  202. var req request.ChartConfigReq
  203. if err := json.Unmarshal(c.Ctx.Input.RequestBody, &req); err != nil {
  204. br.Msg = "参数解析异常!"
  205. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  206. return
  207. }
  208. if req.TagX <= 0 {
  209. br.Msg = "请选择X轴坐标的标签"
  210. br.IsSendEmail = false
  211. return
  212. }
  213. if req.TagY <= 0 {
  214. br.Msg = "请选择Y轴坐标的标签"
  215. br.IsSendEmail = false
  216. return
  217. }
  218. if req.CalculateValue <= 0 {
  219. br.Msg = "请设置时间长度"
  220. br.IsSendEmail = false
  221. return
  222. }
  223. if req.CalculateUnit == `` {
  224. br.Msg = "请设置时间频度"
  225. br.IsSendEmail = false
  226. return
  227. }
  228. // 品种配置
  229. varietyListList := len(req.VarietyList)
  230. if varietyListList < 0 {
  231. br.Msg = "请选择品种"
  232. br.IsSendEmail = false
  233. return
  234. }
  235. // 日期配置
  236. dateConfigList := len(req.DateConfigList)
  237. if dateConfigList < 0 {
  238. br.Msg = "请选择日期"
  239. br.IsSendEmail = false
  240. return
  241. }
  242. if dateConfigList > 5 {
  243. br.Msg = "日期数量已达上限!"
  244. br.IsSendEmail = false
  245. return
  246. }
  247. chartInfo := new(data_manage.ChartInfoView)
  248. chartInfo.ChartType = utils.CHART_SOURCE_CROSS_HEDGING
  249. // 获取图表x轴y轴
  250. edbInfoList, dataResp, err, errMsg, isSendEmail := cross_variety.GetChartData(0, req)
  251. if err != nil {
  252. br.IsSendEmail = isSendEmail
  253. br.Msg = "获取失败"
  254. if errMsg != `` {
  255. br.Msg = errMsg
  256. }
  257. br.ErrMsg = "获取图表,指标信息失败,Err:" + err.Error()
  258. return
  259. }
  260. resp := response.ChartPreviewResp{
  261. EdbInfoList: edbInfoList,
  262. DataResp: dataResp,
  263. }
  264. //resp.EdbInfoList = edbList
  265. br.Data = resp
  266. br.Ret = 200
  267. br.Success = true
  268. br.Msg = "获取成功"
  269. }
  270. // Add
  271. // @Title 新增图表接口
  272. // @Description 新增图表接口
  273. // @Param request body request.AddChartInfoReq true "type json string"
  274. // @Success 200 {object} data_manage.AddChartInfoResp
  275. // @router /chart_info/add [post]
  276. func (c *ChartInfoController) Add() {
  277. br := new(models.BaseResponse).Init()
  278. defer func() {
  279. c.Data["json"] = br
  280. c.ServeJSON()
  281. }()
  282. sysUser := c.SysUser
  283. if sysUser == nil {
  284. br.Msg = "请登录"
  285. br.ErrMsg = "请登录,SysUser Is Empty"
  286. br.Ret = 408
  287. return
  288. }
  289. cacheKey := "CACHE_CHART_INFO_ADD_" + strconv.Itoa(sysUser.AdminId)
  290. if !utils.Rc.SetNX(cacheKey, 1, 30*time.Second) {
  291. br.Msg = "系统处理中,请稍后重试!"
  292. br.ErrMsg = "系统处理中,请稍后重试!" + sysUser.RealName + ";data:" + string(c.Ctx.Input.RequestBody)
  293. return
  294. }
  295. defer func() {
  296. _ = utils.Rc.Delete(cacheKey)
  297. }()
  298. var req request.AddChartReq
  299. err := json.Unmarshal(c.Ctx.Input.RequestBody, &req)
  300. if err != nil {
  301. br.Msg = "参数解析异常!"
  302. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  303. return
  304. }
  305. // 添加图表
  306. chartInfo, err, errMsg, isSendEmail := cross_variety.AddChartInfo(req, sysUser)
  307. if err != nil {
  308. br.Msg = "保存失败"
  309. if errMsg != `` {
  310. br.Msg = errMsg
  311. }
  312. br.ErrMsg = err.Error()
  313. br.IsSendEmail = isSendEmail
  314. return
  315. }
  316. //新增操作日志
  317. {
  318. chartLog := new(data_manage.ChartInfoLog)
  319. chartLog.ChartInfoId = chartInfo.ChartInfoId
  320. chartLog.ChartName = req.ChartName
  321. chartLog.ChartClassifyId = chartInfo.ChartClassifyId
  322. chartLog.SysUserId = sysUser.AdminId
  323. chartLog.SysUserRealName = sysUser.RealName
  324. chartLog.UniqueCode = chartInfo.UniqueCode
  325. chartLog.CreateTime = time.Now()
  326. chartLog.Content = string(c.Ctx.Input.RequestBody)
  327. chartLog.Status = "新增跨品种分析图表"
  328. chartLog.Method = c.Ctx.Input.URI()
  329. go data_manage.AddChartInfoLog(chartLog)
  330. }
  331. resp := new(data_manage.AddChartInfoResp)
  332. resp.ChartInfoId = chartInfo.ChartInfoId
  333. resp.UniqueCode = chartInfo.UniqueCode
  334. resp.ChartType = chartInfo.ChartType
  335. br.Ret = 200
  336. br.Success = true
  337. br.Msg = "保存成功"
  338. br.Data = resp
  339. br.IsAddLog = true
  340. }
  341. // Edit
  342. // @Title 编辑图表接口
  343. // @Description 编辑图表接口
  344. // @Param request body request.EditChartInfoReq true "type json string"
  345. // @Success Ret=200 保存成功
  346. // @router /chart_info/edit [post]
  347. func (c *ChartInfoController) Edit() {
  348. br := new(models.BaseResponse).Init()
  349. defer func() {
  350. c.Data["json"] = br
  351. c.ServeJSON()
  352. }()
  353. sysUser := c.SysUser
  354. if sysUser == nil {
  355. br.Msg = "请登录"
  356. br.ErrMsg = "请登录,SysUser Is Empty"
  357. br.Ret = 408
  358. return
  359. }
  360. var req request.EditChartReq
  361. err := json.Unmarshal(c.Ctx.Input.RequestBody, &req)
  362. if err != nil {
  363. br.Msg = "参数解析异常!"
  364. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  365. return
  366. }
  367. chartItem, err, errMsg, isSendEmail := cross_variety.EditChartInfo(req, sysUser)
  368. if err != nil {
  369. br.Msg = "保存失败"
  370. if errMsg != `` {
  371. br.Msg = errMsg
  372. }
  373. br.ErrMsg = err.Error()
  374. br.IsSendEmail = isSendEmail
  375. return
  376. }
  377. resp := new(data_manage.AddChartInfoResp)
  378. resp.ChartInfoId = chartItem.ChartInfoId
  379. resp.UniqueCode = chartItem.UniqueCode
  380. //resp.ChartType = req.ChartType
  381. //新增操作日志
  382. {
  383. chartLog := new(data_manage.ChartInfoLog)
  384. chartLog.ChartName = chartItem.ChartName
  385. chartLog.ChartInfoId = req.ChartInfoId
  386. chartLog.ChartClassifyId = chartItem.ChartClassifyId
  387. chartLog.SysUserId = sysUser.AdminId
  388. chartLog.SysUserRealName = sysUser.RealName
  389. chartLog.UniqueCode = chartItem.UniqueCode
  390. chartLog.CreateTime = time.Now()
  391. chartLog.Content = string(c.Ctx.Input.RequestBody)
  392. chartLog.Status = "编辑跨品种分析图表"
  393. chartLog.Method = c.Ctx.Input.URL()
  394. go data_manage.AddChartInfoLog(chartLog)
  395. }
  396. br.Ret = 200
  397. br.Success = true
  398. br.Msg = "保存成功"
  399. br.Data = resp
  400. br.IsAddLog = true
  401. }
  402. // Detail
  403. // @Title 获取图表详情
  404. // @Description 获取图表详情接口
  405. // @Param ChartInfoId query int true "图表id"
  406. // @Success 200 {object} data_manage.ChartInfoDetailResp
  407. // @router /chart_info/detail [get]
  408. func (c *ChartInfoController) Detail() {
  409. br := new(models.BaseResponse).Init()
  410. defer func() {
  411. c.Data["json"] = br
  412. c.ServeJSON()
  413. }()
  414. sysUser := c.SysUser
  415. if sysUser == nil {
  416. br.Msg = "请登录"
  417. br.ErrMsg = "请登录,SysUser Is Empty"
  418. br.Ret = 408
  419. return
  420. }
  421. chartInfoId, _ := c.GetInt("ChartInfoId")
  422. if chartInfoId <= 0 {
  423. br.Msg = "参数有误"
  424. return
  425. }
  426. var err error
  427. chartInfo := new(data_manage.ChartInfoView)
  428. chartInfo, err = data_manage.GetChartInfoViewById(chartInfoId)
  429. if err != nil {
  430. if err.Error() == utils.ErrNoRow() {
  431. br.Msg = "图被删除,请刷新页面"
  432. br.ErrMsg = "图被删除,请刷新页面,Err:" + err.Error()
  433. return
  434. }
  435. br.Msg = "获取失败"
  436. br.ErrMsg = "获取图表信息失败,Err:" + err.Error()
  437. return
  438. }
  439. if chartInfo.ExtraConfig == `` {
  440. br.Msg = "图表配置信息异常"
  441. br.ErrMsg = "图表配置信息异常"
  442. br.IsSendEmail = false
  443. return
  444. }
  445. var config request.ChartConfigReq
  446. err = json.Unmarshal([]byte(chartInfo.ExtraConfig), &config)
  447. if err != nil {
  448. br.Msg = "解析跨品种分析配置失败"
  449. br.ErrMsg = "解析跨品种分析配置失败,Err:" + err.Error()
  450. return
  451. }
  452. //mappingList, err := cross_varietyModel.GetChartVarietyMappingList(chartInfo.ChartInfoId)
  453. //if err != nil {
  454. // br.Msg = "获取品种失败"
  455. // br.ErrMsg = "获取品种失败,Err:" + err.Error()
  456. // return
  457. //}
  458. // 获取跨品种分析配置
  459. //chartInfoCrossVariety, err := cross_varietyModel.GetChartInfoCrossVarietyByChartInfoId(chartInfo.ChartInfoId)
  460. //if err != nil {
  461. // br.Msg = "获取跨品种分析配置失败"
  462. // br.ErrMsg = "获取跨品种分析配置失败,Err:" + err.Error()
  463. // return
  464. //}
  465. //
  466. //varietyIdList := make([]int,0)
  467. //for _,v:=range mappingList{
  468. // varietyIdList = append(varietyIdList,v.ChartVarietyId)
  469. //}
  470. //config := request.ChartConfigReq{
  471. // TagX: chartInfoCrossVariety.ChartXTagId,
  472. // TagY: chartInfoCrossVariety.ChartYTagId,
  473. // CalculateValue: chartInfoCrossVariety.CalculateValue,
  474. // CalculateUnit: chartInfoCrossVariety.CalculateUnit,
  475. // DateConfigList: config.DateConfigList,
  476. // VarietyList: varietyIdList,
  477. //}
  478. //config.TagX =
  479. // 获取图表x轴y轴
  480. edbList, dataResp, err, errMsg, isSendEmail := cross_variety.GetChartData(0, config)
  481. if err != nil {
  482. br.IsSendEmail = isSendEmail
  483. br.Msg = "获取失败"
  484. if errMsg != `` {
  485. br.Msg = errMsg
  486. }
  487. br.ErrMsg = "获取图表,指标信息失败,Err:" + err.Error()
  488. return
  489. }
  490. // 完善指标信息
  491. //edbList, e := correlationServ.GetChartEdbInfoFormat(chartInfo.ChartInfoId, edbInfoMappingA, edbInfoMappingB)
  492. //if e != nil {
  493. // br.Msg = "获取失败"
  494. // br.ErrMsg = "获取跨品种分析图表, 完善指标信息失败, Err:" + e.Error()
  495. // return
  496. //}
  497. // 判断是否加入我的图库
  498. if chartInfoId > 0 && chartInfo != nil {
  499. {
  500. var myChartCondition string
  501. var myChartPars []interface{}
  502. myChartCondition += ` AND a.admin_id=? `
  503. myChartPars = append(myChartPars, sysUser.AdminId)
  504. myChartCondition += ` AND a.chart_info_id=? `
  505. myChartPars = append(myChartPars, chartInfo.ChartInfoId)
  506. myChartList, err := data_manage.GetMyChartByCondition(myChartCondition, myChartPars)
  507. if err != nil && err.Error() != utils.ErrNoRow() {
  508. br.Msg = "获取失败"
  509. br.ErrMsg = "获取我的图表信息失败,GetMyChartByCondition,Err:" + err.Error()
  510. return
  511. }
  512. if myChartList != nil && len(myChartList) > 0 {
  513. chartInfo.IsAdd = true
  514. chartInfo.MyChartId = myChartList[0].MyChartId
  515. chartInfo.MyChartClassifyId = myChartList[0].MyChartClassifyId
  516. }
  517. }
  518. }
  519. //图表操作权限
  520. chartInfo.IsEdit = data.CheckOpChartPermission(sysUser, chartInfo.SysUserId)
  521. ////判断是否需要展示英文标识
  522. //chartInfo.IsEnChart = data.CheckIsEnChart(chartInfo.ChartNameEn, edbList[0:1], chartInfo.Source, chartInfo.ChartType)
  523. //chartInfo.UnitEn = edbInfoMappingA.UnitEn
  524. // 另存为
  525. chartInfo.Button = data_manage.ChartViewButton{
  526. IsEdit: chartInfo.IsEdit,
  527. IsEnChart: chartInfo.IsEnChart,
  528. IsAdd: chartInfo.IsAdd,
  529. IsCopy: true,
  530. IsSetName: chartInfo.IsSetName,
  531. }
  532. resp := new(data_manage.ChartInfoDetailResp)
  533. resp.ChartInfo = chartInfo
  534. resp.DataResp = dataResp
  535. resp.EdbInfoList = edbList
  536. br.Ret = 200
  537. br.Success = true
  538. br.Msg = "获取成功"
  539. br.Data = resp
  540. }
  541. // Copy
  542. // @Title 复制并新增图表接口
  543. // @Description 新增图表接口
  544. // @Param request body data_manage.CopyAddChartInfoReq true "type json string"
  545. // @Success 200 {object} data_manage.AddChartInfoResp
  546. // @router /chart_info/copy [post]
  547. func (c *ChartInfoController) Copy() {
  548. br := new(models.BaseResponse).Init()
  549. defer func() {
  550. c.Data["json"] = br
  551. c.ServeJSON()
  552. }()
  553. sysUser := c.SysUser
  554. if sysUser == nil {
  555. br.Msg = "请登录"
  556. br.ErrMsg = "请登录,SysUser Is Empty"
  557. br.Ret = 408
  558. return
  559. }
  560. deleteCache := true
  561. cacheKey := "CACHE_CHART_INFO_ADD_" + strconv.Itoa(sysUser.AdminId)
  562. defer func() {
  563. if deleteCache {
  564. utils.Rc.Delete(cacheKey)
  565. }
  566. }()
  567. if !utils.Rc.SetNX(cacheKey, 1, 30*time.Second) {
  568. deleteCache = false
  569. br.Msg = "系统处理中,请稍后重试!"
  570. br.ErrMsg = "系统处理中,请稍后重试!" + sysUser.RealName + ";data:" + string(c.Ctx.Input.RequestBody)
  571. return
  572. }
  573. var req request.CopyAddChartInfoReq
  574. err := json.Unmarshal(c.Ctx.Input.RequestBody, &req)
  575. if err != nil {
  576. br.Msg = "参数解析异常!"
  577. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  578. return
  579. }
  580. // 获取原图表信息
  581. oldChartInfo, err := data_manage.GetChartInfoById(req.ChartInfoId)
  582. if err != nil {
  583. br.Msg = "获取原图表信息失败"
  584. br.ErrMsg = "获取原图表信息失败,Err:" + err.Error()
  585. return
  586. }
  587. var config request.AddChartReq
  588. err = json.Unmarshal([]byte(oldChartInfo.ExtraConfig), &config)
  589. if err != nil {
  590. br.Msg = "原图表信息配置解析异常!"
  591. br.ErrMsg = "原图表信息配置解析失败,Err:" + err.Error()
  592. return
  593. }
  594. config.ChartName = req.ChartName
  595. // 添加图表
  596. chartInfo, err, errMsg, isSendEmail := cross_variety.AddChartInfo(config, sysUser)
  597. if err != nil {
  598. br.Msg = "保存失败"
  599. if errMsg != `` {
  600. br.Msg = errMsg
  601. }
  602. br.ErrMsg = err.Error()
  603. br.IsSendEmail = isSendEmail
  604. return
  605. }
  606. if err != nil {
  607. br.Msg = "保存失败"
  608. if errMsg != `` {
  609. br.Msg = errMsg
  610. }
  611. br.ErrMsg = err.Error()
  612. br.IsSendEmail = isSendEmail
  613. return
  614. }
  615. //新增操作日志
  616. {
  617. chartLog := new(data_manage.ChartInfoLog)
  618. chartLog.ChartInfoId = chartInfo.ChartInfoId
  619. chartLog.ChartName = req.ChartName
  620. chartLog.ChartClassifyId = chartInfo.ChartClassifyId
  621. chartLog.SysUserId = sysUser.AdminId
  622. chartLog.SysUserRealName = sysUser.RealName
  623. chartLog.UniqueCode = chartInfo.UniqueCode
  624. chartLog.CreateTime = time.Now()
  625. chartLog.Content = string(c.Ctx.Input.RequestBody)
  626. chartLog.Status = "复制跨品种分析图表"
  627. chartLog.Method = c.Ctx.Input.URI()
  628. go data_manage.AddChartInfoLog(chartLog)
  629. }
  630. br.Ret = 200
  631. br.Success = true
  632. br.Msg = "保存成功"
  633. br.Data = data_manage.AddChartInfoResp{
  634. ChartInfoId: chartInfo.ChartInfoId,
  635. UniqueCode: chartInfo.UniqueCode,
  636. ChartType: chartInfo.ChartType,
  637. }
  638. br.IsAddLog = true
  639. }
  640. // Move
  641. // @Title 移动图表接口
  642. // @Description 移动图表接口
  643. // @Success 200 {object} data_manage.MoveChartInfoReq
  644. // @router /chart_info/move [post]
  645. func (c *ChartInfoController) Move() {
  646. br := new(models.BaseResponse).Init()
  647. defer func() {
  648. c.Data["json"] = br
  649. c.ServeJSON()
  650. }()
  651. sysUser := c.SysUser
  652. if sysUser == nil {
  653. br.Msg = "请登录"
  654. br.ErrMsg = "请登录,SysUser Is Empty"
  655. br.Ret = 408
  656. return
  657. }
  658. var req data_manage.MoveChartInfoReq
  659. err := json.Unmarshal(c.Ctx.Input.RequestBody, &req)
  660. if err != nil {
  661. br.Msg = "参数解析异常!"
  662. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  663. return
  664. }
  665. if req.ChartInfoId <= 0 {
  666. br.Msg = "参数错误"
  667. br.ErrMsg = "图表id小于等于0"
  668. br.IsSendEmail = false
  669. return
  670. }
  671. chartInfo, err := data_manage.GetChartInfoById(req.ChartInfoId)
  672. if err != nil {
  673. br.Msg = "移动失败"
  674. br.ErrMsg = "获取图表信息失败,Err:" + err.Error()
  675. return
  676. }
  677. if chartInfo.Source != utils.CHART_SOURCE_CROSS_HEDGING {
  678. br.Msg = "图表异常"
  679. br.ErrMsg = "分类异常,不是跨品种分析的图表"
  680. return
  681. }
  682. //移动排序
  683. updateCol := make([]string, 0)
  684. //如果有传入 上一个兄弟节点分类id
  685. if req.PrevChartInfoId > 0 {
  686. prevChartInfo, err := data_manage.GetChartInfoById(req.PrevChartInfoId)
  687. if err != nil {
  688. br.Msg = "移动失败"
  689. br.ErrMsg = "获取上一个兄弟节点分类信息失败,Err:" + err.Error()
  690. return
  691. }
  692. if prevChartInfo.ChartClassifyId != chartInfo.ChartClassifyId {
  693. br.Msg = "不允许跨分类移动"
  694. br.ErrMsg = "不允许跨分类移动"
  695. br.IsSendEmail = false
  696. return
  697. }
  698. //如果是移动在两个兄弟节点之间
  699. if req.NextChartInfoId > 0 {
  700. //下一个兄弟节点
  701. nextChartInfo, err := data_manage.GetChartInfoById(req.NextChartInfoId)
  702. if err != nil {
  703. br.Msg = "移动失败"
  704. br.ErrMsg = "获取下一个兄弟节点分类信息失败,Err:" + err.Error()
  705. return
  706. }
  707. //如果上一个兄弟与下一个兄弟的排序权重是一致的,那么需要将下一个兄弟(以及下个兄弟的同样排序权重)的排序权重+2,自己变成上一个兄弟的排序权重+1
  708. if prevChartInfo.Sort == nextChartInfo.Sort || prevChartInfo.Sort == chartInfo.Sort {
  709. //变更兄弟节点的排序
  710. updateSortStr := `sort + 2`
  711. _ = data_manage.UpdateChartInfoSortByClassifyId(prevChartInfo.ChartClassifyId, prevChartInfo.Sort, prevChartInfo.ChartInfoId, []int{chartInfo.Source}, updateSortStr)
  712. } else {
  713. //如果下一个兄弟的排序权重正好是上个兄弟节点的下一层,那么需要再加一层了
  714. if nextChartInfo.Sort-prevChartInfo.Sort == 1 {
  715. //变更兄弟节点的排序
  716. updateSortStr := `sort + 1`
  717. _ = data_manage.UpdateChartInfoSortByClassifyId(prevChartInfo.ChartClassifyId, prevChartInfo.Sort, prevChartInfo.ChartInfoId, []int{chartInfo.Source}, updateSortStr)
  718. }
  719. }
  720. }
  721. chartInfo.Sort = prevChartInfo.Sort + 1
  722. chartInfo.ModifyTime = time.Now()
  723. updateCol = append(updateCol, "Sort", "ModifyTime")
  724. } else {
  725. firstClassify, err := data_manage.GetFirstChartInfoByClassifyId(chartInfo.ChartClassifyId)
  726. if err != nil && err.Error() != utils.ErrNoRow() {
  727. br.Msg = "移动失败"
  728. br.ErrMsg = "获取获取当前父级分类下的排序第一条的分类信息失败,Err:" + err.Error()
  729. return
  730. }
  731. if firstClassify != nil && firstClassify.ChartClassifyId != chartInfo.ChartClassifyId {
  732. br.Msg = "不允许跨分类移动"
  733. br.ErrMsg = "不允许跨分类移动"
  734. br.IsSendEmail = false
  735. return
  736. }
  737. //如果该分类下存在其他分类,且第一个其他分类的排序等于0,那么需要调整排序
  738. if firstClassify != nil && firstClassify.Sort == 0 {
  739. updateSortStr := ` sort + 1 `
  740. _ = data_manage.UpdateChartInfoSortByClassifyId(firstClassify.ChartClassifyId, 0, firstClassify.ChartInfoId-1, []int{chartInfo.Source}, updateSortStr)
  741. }
  742. chartInfo.Sort = 0 //那就是排在第一位
  743. chartInfo.ModifyTime = time.Now()
  744. updateCol = append(updateCol, "Sort", "ModifyTime")
  745. }
  746. //更新
  747. if len(updateCol) > 0 {
  748. err = chartInfo.Update(updateCol)
  749. if err != nil {
  750. br.Msg = "移动失败"
  751. br.ErrMsg = "修改失败,Err:" + err.Error()
  752. return
  753. }
  754. }
  755. if err != nil {
  756. br.Msg = "移动失败"
  757. br.ErrMsg = "修改失败,Err:" + err.Error()
  758. return
  759. }
  760. //添加es数据
  761. go data.EsAddOrEditChartInfo(req.ChartInfoId)
  762. //修改my eta es数据
  763. go data.EsAddOrEditMyChartInfoByChartInfoId(req.ChartInfoId)
  764. //新增操作日志
  765. {
  766. chartLog := new(data_manage.ChartInfoLog)
  767. chartLog.ChartName = chartInfo.ChartName
  768. chartLog.ChartInfoId = req.ChartInfoId
  769. chartLog.ChartClassifyId = chartInfo.ChartClassifyId
  770. chartLog.SysUserId = sysUser.AdminId
  771. chartLog.SysUserRealName = sysUser.RealName
  772. chartLog.UniqueCode = chartInfo.UniqueCode
  773. chartLog.CreateTime = time.Now()
  774. chartLog.Content = string(c.Ctx.Input.RequestBody)
  775. chartLog.Status = "移动跨品种分析图表"
  776. chartLog.Method = c.Ctx.Input.URL()
  777. go data_manage.AddChartInfoLog(chartLog)
  778. }
  779. br.Ret = 200
  780. br.Success = true
  781. br.Msg = "移动成功"
  782. }
  783. // Refresh
  784. // @Title 图表刷新接口
  785. // @Description 图表刷新接口
  786. // @Param ChartInfoId query int true "图表id"
  787. // @Param UniqueCode query string true "唯一code"
  788. // @Success Ret=200 刷新成功
  789. // @router /chart_info/refresh [get]
  790. func (c *ChartInfoController) Refresh() {
  791. br := new(models.BaseResponse).Init()
  792. defer func() {
  793. c.Data["json"] = br
  794. c.ServeJSON()
  795. }()
  796. sysUser := c.SysUser
  797. if sysUser == nil {
  798. br.Msg = "请登录"
  799. br.ErrMsg = "请登录,SysUser Is Empty"
  800. br.Ret = 408
  801. return
  802. }
  803. chartInfoId, _ := c.GetInt("ChartInfoId")
  804. uniqueCode := c.GetString("UniqueCode")
  805. if chartInfoId <= 0 && uniqueCode == `` {
  806. br.Msg = "参数错误"
  807. br.ErrMsg = "参数错误:chartInfoId:" + strconv.Itoa(chartInfoId) + ",UniqueCode:" + uniqueCode
  808. return
  809. }
  810. var chartInfo *data_manage.ChartInfo
  811. var err error
  812. if chartInfoId > 0 {
  813. chartInfo, err = data_manage.GetChartInfoById(chartInfoId)
  814. } else {
  815. chartInfo, err = data_manage.GetChartInfoByUniqueCode(uniqueCode)
  816. }
  817. if err != nil {
  818. if err.Error() == utils.ErrNoRow() {
  819. br.Msg = "图表已被删除,无需刷新"
  820. br.ErrMsg = "获取指标信息失败,Err:" + err.Error()
  821. return
  822. }
  823. br.Msg = "刷新失败"
  824. br.ErrMsg = "获取图表信息失败,Err:" + err.Error()
  825. return
  826. }
  827. var config request.ChartConfigReq
  828. err = json.Unmarshal([]byte(chartInfo.ExtraConfig), &config)
  829. if err != nil {
  830. br.Msg = "解析跨品种分析配置失败"
  831. br.ErrMsg = "解析跨品种分析配置失败,Err:" + err.Error()
  832. return
  833. }
  834. // 获取关联的指标信息
  835. _, _, edbInfoIdList, err := cross_variety.GetXYEdbIdList(config.TagX, config.TagY, config.VarietyList)
  836. if err != nil {
  837. br.Msg = "刷新失败,获取指标信息失败"
  838. br.ErrMsg = "刷新失败,获取指标信息失败,Err:" + err.Error()
  839. return
  840. }
  841. // 批量刷新
  842. err, isAsync := data.EdbInfoRefreshAllFromBaseV3(edbInfoIdList, false, false)
  843. if err != nil {
  844. return
  845. }
  846. //清除图表缓存
  847. {
  848. key := utils.HZ_CHART_LIB_DETAIL + chartInfo.UniqueCode
  849. _ = utils.Rc.Delete(key)
  850. }
  851. br.Ret = 200
  852. br.Success = true
  853. br.Msg = "刷新成功"
  854. if isAsync {
  855. br.Msg = "图表关联指标较多,请10分钟后刷新页面查看最新数据"
  856. }
  857. }
  858. // EnInfoEdit
  859. // @Title 编辑图表英文信息接口
  860. // @Description 编辑图表英文信息接口
  861. // @Param request body data_manage.EditChartEnInfoReq true "type json string"
  862. // @Success Ret=200 编辑成功
  863. // @router /chart_info/en/edit [post]
  864. func (c *ChartInfoController) EnInfoEdit() {
  865. br := new(models.BaseResponse).Init()
  866. defer func() {
  867. c.Data["json"] = br
  868. c.ServeJSON()
  869. }()
  870. sysUser := c.SysUser
  871. if sysUser == nil {
  872. br.Msg = "请登录"
  873. br.ErrMsg = "请登录,SysUser Is Empty"
  874. br.Ret = 408
  875. return
  876. }
  877. var req request.EditChartEnInfoReq
  878. err := json.Unmarshal(c.Ctx.Input.RequestBody, &req)
  879. if err != nil {
  880. br.Msg = "参数解析异常!"
  881. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  882. return
  883. }
  884. req.ChartNameEn = strings.Trim(req.ChartNameEn, " ")
  885. if req.ChartInfoId <= 0 {
  886. br.Msg = "请选择图表"
  887. return
  888. }
  889. if req.ChartNameEn == "" {
  890. br.Msg = "请输入英文图表名称"
  891. return
  892. }
  893. //判断指标名称是否存在
  894. chartItem, err := data_manage.GetChartInfoById(req.ChartInfoId)
  895. if err != nil {
  896. if err.Error() == utils.ErrNoRow() {
  897. br.Msg = "图表已被删除,请刷新页面"
  898. br.ErrMsg = "图表已被删除,请刷新页面"
  899. return
  900. }
  901. br.Msg = "获取图表信息失败"
  902. br.ErrMsg = "获取图表信息失败,Err:" + err.Error()
  903. return
  904. }
  905. // 校验名称是否有重复
  906. //{
  907. // var condition string
  908. // var pars []interface{}
  909. // condition += " AND chart_info_id <> ? AND chart_name_en = ? AND source = ?"
  910. // pars = append(pars, req.ChartInfoId, req.ChartNameEn, utils.CHART_SOURCE_CROSS_HEDGING)
  911. // existItem, err := data_manage.GetChartInfoByCondition(condition, pars)
  912. // if err != nil {
  913. // if err.Error() != utils.ErrNoRow() {
  914. // br.Msg = "判断英文图表名称是否存在失败"
  915. // br.ErrMsg = "判断英文图表名称是否存在失败,Err:" + err.Error()
  916. // return
  917. // }
  918. // }
  919. // if err == nil && existItem.ChartInfoId > 0 {
  920. // br.Msg = existItem.ChartName + ":" + req.ChartNameEn + "图表名称已存在"
  921. // return
  922. // }
  923. //}
  924. chartItem.ChartNameEn = req.ChartNameEn
  925. chartItem.ModifyTime = time.Now().Local()
  926. if e := chartItem.Update([]string{"ChartNameEn", "ModifyTime"}); e != nil {
  927. br.Msg = "操作失败"
  928. br.ErrMsg = "更新图表信息失败, Err: " + e.Error()
  929. return
  930. }
  931. err = cross_varietyModels.EditChartEn(chartItem, req)
  932. if err != nil {
  933. br.Msg = "修改失败"
  934. br.ErrMsg = "更新图表英文信息失败, Err: " + err.Error()
  935. return
  936. }
  937. //添加es数据
  938. go data.EsAddOrEditChartInfo(chartItem.ChartInfoId)
  939. //修改my eta es数据
  940. go data.EsAddOrEditMyChartInfoByChartInfoId(chartItem.ChartInfoId)
  941. //指标 修改es信息
  942. //go data.AddOrEditEdbInfoToEs(edbInfo.EdbInfoId)
  943. //新增操作日志
  944. {
  945. chartLog := new(data_manage.ChartInfoLog)
  946. chartLog.ChartName = chartItem.ChartName
  947. chartLog.ChartInfoId = req.ChartInfoId
  948. chartLog.ChartClassifyId = chartItem.ChartClassifyId
  949. chartLog.SysUserId = sysUser.AdminId
  950. chartLog.SysUserRealName = sysUser.RealName
  951. chartLog.UniqueCode = chartItem.UniqueCode
  952. chartLog.CreateTime = time.Now()
  953. chartLog.Content = string(c.Ctx.Input.RequestBody)
  954. chartLog.Status = "编辑跨品种分析图表英文信息"
  955. chartLog.Method = c.Ctx.Input.URL()
  956. go data_manage.AddChartInfoLog(chartLog)
  957. }
  958. // 清除缓存
  959. if utils.Re == nil && utils.Rc != nil {
  960. _ = utils.Rc.Delete(utils.HZ_CHART_LIB_DETAIL + chartItem.UniqueCode) //图表分享链接缓存
  961. _ = utils.Rc.Delete(data.GetChartInfoDataKey(req.ChartInfoId))
  962. }
  963. br.Ret = 200
  964. br.Success = true
  965. br.Msg = "编辑成功"
  966. br.IsAddLog = true
  967. }
  968. // DeleteChartClassify
  969. // @Title 删除跨品种分析分类/图表
  970. // @Description 删除跨品种分析分类/图表接口
  971. // @Param request body data_manage.DeleteChartClassifyReq true "type json string"
  972. // @Success 200 Ret=200 删除成功
  973. // @router /chart_info/delete [post]
  974. func (c *ChartInfoController) DeleteChartClassify() {
  975. br := new(models.BaseResponse).Init()
  976. defer func() {
  977. c.Data["json"] = br
  978. c.ServeJSON()
  979. }()
  980. sysUser := c.SysUser
  981. if sysUser == nil {
  982. br.Msg = "请登录"
  983. br.ErrMsg = "请登录,SysUser Is Empty"
  984. br.Ret = 408
  985. return
  986. }
  987. var req data_manage.DeleteChartClassifyReq
  988. err := json.Unmarshal(c.Ctx.Input.RequestBody, &req)
  989. if err != nil {
  990. br.Msg = "参数解析异常!"
  991. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  992. return
  993. }
  994. if req.ChartInfoId <= 0 {
  995. br.Msg = "请选择图表"
  996. br.IsSendEmail = false
  997. return
  998. }
  999. resp := new(data_manage.AddChartInfoResp)
  1000. //删除图表
  1001. chartInfo, err := data_manage.GetChartInfoById(req.ChartInfoId)
  1002. if err != nil {
  1003. if err.Error() == utils.ErrNoRow() {
  1004. br.Msg = "图表已删除,请刷新页面"
  1005. br.ErrMsg = "指标不存在,Err:" + err.Error()
  1006. return
  1007. } else {
  1008. br.Msg = "删除失败"
  1009. br.ErrMsg = "删除失败,获取指标信息失败,Err:" + err.Error()
  1010. return
  1011. }
  1012. }
  1013. if chartInfo == nil {
  1014. br.Msg = "图表已删除,请刷新页面"
  1015. return
  1016. }
  1017. //图表操作权限
  1018. ok := data.CheckOpChartPermission(sysUser, chartInfo.SysUserId)
  1019. if !ok {
  1020. br.Msg = "没有该图表的操作权限"
  1021. br.ErrMsg = "没有该图表的操作权限"
  1022. return
  1023. }
  1024. myIds := make([]int, 0)
  1025. {
  1026. // 获取引用该图表的MyCharts, 用于ES删除
  1027. var myCond string
  1028. var myPars []interface{}
  1029. myCond += ` AND a.chart_info_id = ? `
  1030. myPars = append(myPars, req.ChartInfoId)
  1031. myCharts, e := data_manage.GetMyChartListGroupByCharyInfoIdAndAdminIdByCondition(myCond, myPars)
  1032. if e != nil {
  1033. br.Msg = "删除失败"
  1034. br.ErrMsg = "获取引用图表的MyChats失败, Err: " + e.Error()
  1035. return
  1036. }
  1037. for _, m := range myCharts {
  1038. myIds = append(myIds, m.MyChartId)
  1039. }
  1040. }
  1041. //删除图表及关联指标
  1042. err = data_manage.DeleteChartInfoAndData(chartInfo.ChartInfoId)
  1043. if err != nil {
  1044. br.Msg = "删除失败"
  1045. br.ErrMsg = "删除失败,Err:" + err.Error()
  1046. return
  1047. }
  1048. //删除ES
  1049. {
  1050. go data.EsDeleteChartInfo(chartInfo.ChartInfoId)
  1051. // 删除MY ETA 图表 es数据
  1052. go data.EsDeleteMyChartInfoByMyChartIds(myIds)
  1053. }
  1054. source := chartInfo.Source // 跨品种分析
  1055. var condition string
  1056. var pars []interface{}
  1057. condition += " AND chart_classify_id=? AND source = ? "
  1058. pars = append(pars, chartInfo.ChartClassifyId, source)
  1059. condition += " AND chart_info_id>? ORDER BY create_time ASC LIMIT 1 "
  1060. pars = append(pars, req.ChartInfoId)
  1061. nextItem, err := data_manage.GetChartInfoByCondition(condition, pars)
  1062. if err != nil && err.Error() != utils.ErrNoRow() {
  1063. br.Msg = "删除失败"
  1064. br.ErrMsg = "获取下一级图库信息失败,Err:" + err.Error()
  1065. return
  1066. }
  1067. if nextItem != nil {
  1068. resp.UniqueCode = nextItem.UniqueCode
  1069. resp.ChartInfoId = nextItem.ChartInfoId
  1070. } else {
  1071. var tmpCondition string
  1072. var tmpPars []interface{}
  1073. tmpCondition += " AND level=1 "
  1074. //pars = append(pars, chartInfo.ChartClassifyId)
  1075. tmpCondition += " AND chart_classify_id>? ORDER BY chart_classify_id ASC LIMIT 1 "
  1076. tmpPars = append(tmpPars, chartInfo.ChartClassifyId)
  1077. classifyItem, err := data_manage.GetChartClassifyByCondition(tmpCondition, tmpPars)
  1078. if err != nil && err.Error() != utils.ErrNoRow() {
  1079. br.Msg = "删除失败"
  1080. br.ErrMsg = "获取下一级图库分类信息失败,Err:" + err.Error()
  1081. return
  1082. }
  1083. if classifyItem != nil {
  1084. nextItem, err = data_manage.GetNextChartInfo(chartInfo.ChartClassifyId)
  1085. if err != nil && err.Error() != utils.ErrNoRow() {
  1086. br.Msg = "删除失败"
  1087. br.ErrMsg = "获取下一级图库信息失败,Err:" + err.Error()
  1088. return
  1089. }
  1090. if nextItem != nil {
  1091. resp.UniqueCode = nextItem.UniqueCode
  1092. resp.ChartInfoId = nextItem.ChartInfoId
  1093. }
  1094. }
  1095. }
  1096. //新增操作日志
  1097. {
  1098. chartLog := new(data_manage.ChartInfoLog)
  1099. chartLog.ChartName = chartInfo.ChartName
  1100. chartLog.ChartInfoId = req.ChartInfoId
  1101. chartLog.ChartClassifyId = chartInfo.ChartClassifyId
  1102. chartLog.SysUserId = sysUser.AdminId
  1103. chartLog.SysUserRealName = sysUser.RealName
  1104. chartLog.UniqueCode = chartInfo.UniqueCode
  1105. chartLog.CreateTime = time.Now()
  1106. chartLog.Content = string(c.Ctx.Input.RequestBody)
  1107. chartLog.Status = "删除图表"
  1108. chartLog.Method = c.Ctx.Input.URI()
  1109. go data_manage.AddChartInfoLog(chartLog)
  1110. }
  1111. br.Ret = 200
  1112. br.Msg = "删除成功"
  1113. br.Success = true
  1114. br.Data = resp
  1115. br.IsAddLog = true
  1116. }
  1117. // SearchByEs
  1118. // @Title 图表模糊搜索(从es获取)
  1119. // @Description 图表模糊搜索(从es获取)
  1120. // @Param Keyword query string true "图表名称"
  1121. // @Param IsShowMe query bool true "是否只看我的,true、false"
  1122. // @Param Source query int true "来源,3:拟合方程,4:滚动拟合方程,默认0:全部"
  1123. // @Success 200 {object} data_manage.ChartInfo
  1124. // @router /chart_info/search_by_es [get]
  1125. func (c *ChartInfoController) SearchByEs() {
  1126. br := new(models.BaseResponse).Init()
  1127. defer func() {
  1128. c.Data["json"] = br
  1129. c.ServeJSON()
  1130. }()
  1131. sysUser := c.SysUser
  1132. if sysUser == nil {
  1133. br.Msg = "请登录"
  1134. br.ErrMsg = "请登录,SysUser Is Empty"
  1135. br.Ret = 408
  1136. return
  1137. }
  1138. pageSize, _ := c.GetInt("PageSize")
  1139. currentIndex, _ := c.GetInt("CurrentIndex")
  1140. var startSize int
  1141. if pageSize <= 0 {
  1142. pageSize = utils.PageSize20
  1143. }
  1144. if currentIndex <= 0 {
  1145. currentIndex = 1
  1146. }
  1147. startSize = paging.StartIndex(currentIndex, pageSize)
  1148. keyword := c.GetString("Keyword")
  1149. //只看我的
  1150. isShowMe, _ := c.GetBool("IsShowMe")
  1151. showSysId := 0
  1152. if isShowMe {
  1153. showSysId = sysUser.AdminId
  1154. }
  1155. sourceList := []int{utils.CHART_SOURCE_CROSS_HEDGING}
  1156. var searchList []*data_manage.ChartInfo
  1157. var total int64
  1158. var err error
  1159. // 获取当前账号的不可见指标
  1160. noPermissionChartIdList := make([]int, 0)
  1161. {
  1162. obj := data_manage.EdbInfoNoPermissionAdmin{}
  1163. confList, err := obj.GetAllChartListByAdminId(c.SysUser.AdminId)
  1164. if err != nil && err.Error() != utils.ErrNoRow() {
  1165. br.Msg = "获取失败"
  1166. br.ErrMsg = "获取不可见指标配置数据失败,Err:" + err.Error()
  1167. return
  1168. }
  1169. for _, v := range confList {
  1170. noPermissionChartIdList = append(noPermissionChartIdList, v.ChartInfoId)
  1171. }
  1172. }
  1173. if keyword != "" {
  1174. searchList, total, err = data.EsSearchChartInfo(keyword, showSysId, sourceList, noPermissionChartIdList, startSize, pageSize)
  1175. } else {
  1176. total, searchList, err = data_manage.ChartInfoSearchByEmptyKeyWord(showSysId, sourceList, noPermissionChartIdList, startSize, pageSize)
  1177. if err != nil && err.Error() != utils.ErrNoRow() {
  1178. br.Msg = "获取失败"
  1179. br.ErrMsg = "获取图表信息失败,Err:" + err.Error()
  1180. return
  1181. }
  1182. }
  1183. finalList := make([]*data_manage.ChartInfoMore, 0)
  1184. if len(searchList) > 0 {
  1185. chartInfoIds := ""
  1186. chartEdbMap := make(map[int][]*data_manage.ChartEdbInfoMapping)
  1187. for _, v := range searchList {
  1188. chartInfoIds += strconv.Itoa(v.ChartInfoId) + ","
  1189. }
  1190. if chartInfoIds != "" {
  1191. chartInfoIds = strings.Trim(chartInfoIds, ",")
  1192. //判断是否需要展示英文标识
  1193. edbList, e := data_manage.GetChartEdbMappingListByChartInfoIds(chartInfoIds)
  1194. if e != nil {
  1195. br.Msg = "获取失败"
  1196. br.ErrMsg = "获取图表,指标信息失败,Err:" + e.Error()
  1197. return
  1198. }
  1199. for _, v := range edbList {
  1200. chartEdbMap[v.ChartInfoId] = append(chartEdbMap[v.ChartInfoId], v)
  1201. }
  1202. }
  1203. for _, v := range searchList {
  1204. tmp := new(data_manage.ChartInfoMore)
  1205. tmp.ChartInfo = *v
  1206. //判断是否需要展示英文标识
  1207. if _, ok := chartEdbMap[v.ChartInfoId]; ok {
  1208. tmp.IsEnChart = data.CheckIsEnChart(v.ChartNameEn, []*data_manage.ChartEdbInfoMapping{}, v.Source, v.ChartType)
  1209. }
  1210. finalList = append(finalList, tmp)
  1211. }
  1212. }
  1213. //新增搜索词记录
  1214. {
  1215. searchKeyword := new(data_manage.SearchKeyword)
  1216. searchKeyword.KeyWord = keyword
  1217. searchKeyword.CreateTime = time.Now()
  1218. go data_manage.AddSearchKeyword(searchKeyword)
  1219. }
  1220. page := paging.GetPaging(currentIndex, pageSize, int(total))
  1221. resp := data_manage.ChartInfoListByEsResp{
  1222. Paging: page,
  1223. List: finalList,
  1224. }
  1225. br.Ret = 200
  1226. br.Success = true
  1227. br.Msg = "获取成功"
  1228. br.Data = resp
  1229. }
  1230. // GetChartInfoDetailFromUniqueCode 根据编码获取图表详情
  1231. func GetChartInfoDetailFromUniqueCode(chartInfo *data_manage.ChartInfoView, isCache bool, sysUser *system.Admin) (resp *data_manage.ChartInfoDetailFromUniqueCodeResp, isOk bool, msg, errMsg string) {
  1232. resp = new(data_manage.ChartInfoDetailFromUniqueCodeResp)
  1233. adminId := sysUser.AdminId
  1234. //判断是否存在缓存,如果存在缓存,那么直接从缓存中获取
  1235. key := data.GetChartInfoDataKey(chartInfo.ChartInfoId)
  1236. if utils.Re == nil && isCache {
  1237. if utils.Re == nil && utils.Rc.IsExist(key) {
  1238. if chartData, err1 := utils.Rc.RedisBytes(key); err1 == nil {
  1239. err := json.Unmarshal(chartData, &resp)
  1240. if err == nil && resp != nil {
  1241. // 这里跟当前用户相关的信息重新查询写入resp, 不使用缓存中的
  1242. var myCond string
  1243. var myPars []interface{}
  1244. myCond += ` AND a.admin_id=? `
  1245. myPars = append(myPars, adminId)
  1246. myCond += ` AND a.chart_info_id=? `
  1247. myPars = append(myPars, chartInfo.ChartInfoId)
  1248. myList, err := data_manage.GetMyChartByCondition(myCond, myPars)
  1249. if err != nil && err.Error() != utils.ErrNoRow() {
  1250. msg = "获取失败"
  1251. errMsg = "获取我的图表信息失败,GetMyChartByCondition,Err:" + err.Error()
  1252. return
  1253. }
  1254. resp.ChartInfo.IsAdd = false
  1255. resp.ChartInfo.MyChartId = 0
  1256. resp.ChartInfo.MyChartClassifyId = ""
  1257. if myList != nil && len(myList) > 0 {
  1258. resp.ChartInfo.IsAdd = true
  1259. resp.ChartInfo.MyChartId = myList[0].MyChartId
  1260. resp.ChartInfo.MyChartClassifyId = myList[0].MyChartClassifyId
  1261. }
  1262. isOk = true
  1263. fmt.Println("source redis")
  1264. return
  1265. }
  1266. }
  1267. }
  1268. }
  1269. chartInfoId := chartInfo.ChartInfoId
  1270. if chartInfo.ExtraConfig == `` {
  1271. msg = "图表配置信息异常"
  1272. errMsg = "图表配置信息异常"
  1273. return
  1274. }
  1275. var config request.ChartConfigReq
  1276. err := json.Unmarshal([]byte(chartInfo.ExtraConfig), &config)
  1277. if err != nil {
  1278. msg = "解析跨品种分析配置失败"
  1279. errMsg = "解析跨品种分析配置失败,Err:" + err.Error()
  1280. return
  1281. }
  1282. // 获取图表x轴y轴
  1283. edbList, dataResp, err, msg, _ := cross_variety.GetChartData(0, config)
  1284. if err != nil {
  1285. errMsg = "获取图表,指标信息失败,Err:" + err.Error()
  1286. return
  1287. }
  1288. if chartInfoId > 0 && chartInfo != nil {
  1289. //判断是否加入我的图库
  1290. {
  1291. var myChartCondition string
  1292. var myChartPars []interface{}
  1293. myChartCondition += ` AND a.admin_id=? `
  1294. myChartPars = append(myChartPars, sysUser.AdminId)
  1295. myChartCondition += ` AND a.chart_info_id=? `
  1296. myChartPars = append(myChartPars, chartInfo.ChartInfoId)
  1297. myChartList, err := data_manage.GetMyChartByCondition(myChartCondition, myChartPars)
  1298. if err != nil && err.Error() != utils.ErrNoRow() {
  1299. msg = "获取失败"
  1300. errMsg = "获取我的图表信息失败,GetMyChartByCondition,Err:" + err.Error()
  1301. return
  1302. }
  1303. if myChartList != nil && len(myChartList) > 0 {
  1304. chartInfo.IsAdd = true
  1305. chartInfo.MyChartId = myChartList[0].MyChartId
  1306. chartInfo.MyChartClassifyId = myChartList[0].MyChartClassifyId
  1307. }
  1308. }
  1309. }
  1310. //图表操作权限
  1311. chartInfo.IsEdit = data.CheckOpChartPermission(sysUser, chartInfo.SysUserId)
  1312. //判断是否需要展示英文标识
  1313. //chartInfo.IsEnChart = data.CheckIsEnChart(chartInfo.ChartNameEn, edbList[0:1], chartInfo.Source, chartInfo.ChartType)
  1314. //chartInfo.UnitEn = edbInfoMappingA.UnitEn
  1315. //isSaveAs := true
  1316. // 另存为
  1317. chartInfo.Button = data_manage.ChartViewButton{
  1318. IsEdit: chartInfo.IsEdit,
  1319. IsEnChart: chartInfo.IsEnChart,
  1320. IsAdd: chartInfo.IsAdd,
  1321. IsCopy: true,
  1322. IsSetName: chartInfo.IsSetName,
  1323. }
  1324. resp.ChartInfo = chartInfo
  1325. resp.DataResp = dataResp
  1326. resp.EdbInfoList = edbList
  1327. resp.Status = true
  1328. // 将数据加入缓存
  1329. if utils.Re == nil {
  1330. d, _ := json.Marshal(resp)
  1331. _ = utils.Rc.Put(key, d, 2*time.Hour)
  1332. }
  1333. isOk = true
  1334. return
  1335. }