chart_info.go 42 KB

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