chart_info_excel_balance.go 23 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727
  1. package data
  2. import (
  3. "encoding/json"
  4. "errors"
  5. "eta/eta_mobile/models/data_manage"
  6. excelModel "eta/eta_mobile/models/data_manage/excel"
  7. "eta/eta_mobile/models/system"
  8. "eta/eta_mobile/services/data/data_manage_permission"
  9. "eta/eta_mobile/utils"
  10. "fmt"
  11. "math"
  12. "sort"
  13. "strings"
  14. "time"
  15. )
  16. func GetBalanceExcelChartDetail(chartInfo *data_manage.ChartInfoView, mappingListTmp []*excelModel.ExcelChartEdb, sysUser *system.Admin, dataListMap map[int][]*data_manage.EdbDataList) (resp *data_manage.ChartInfoDetailResp, err error, errMsg string) {
  17. // 图表数据权限
  18. {
  19. // 已授权分类id
  20. permissionChartIdList, permissionClassifyIdList, e := data_manage_permission.GetUserChartAndClassifyPermissionList(sysUser.AdminId, chartInfo.ChartInfoId, chartInfo.ChartClassifyId)
  21. if e != nil {
  22. errMsg = "获取失败"
  23. err = fmt.Errorf("获取已授权分类id数据失败,Err:" + err.Error())
  24. return
  25. }
  26. chartInfo.HaveOperaAuth = data_manage_permission.CheckChartPermissionByPermissionIdList(chartInfo.IsJoinPermission, 0, chartInfo.ChartInfoId, chartInfo.ChartClassifyId, permissionChartIdList, permissionClassifyIdList)
  27. }
  28. chartInfoId := chartInfo.ChartInfoId
  29. resp = new(data_manage.ChartInfoDetailResp)
  30. // 获取主题样式
  31. chartTheme, err := GetChartThemeConfig(chartInfo.ChartThemeId, 1, chartInfo.ChartType)
  32. if err != nil {
  33. errMsg = "获取失败"
  34. err = fmt.Errorf(" 获取主题信息失败 Err:%s", err.Error())
  35. return
  36. }
  37. chartInfo.ChartThemeStyle = chartTheme.Config
  38. chartInfo.ChartThemeId = chartTheme.ChartThemeId
  39. dateType := chartInfo.DateType
  40. fmt.Println("dateType:", dateType)
  41. chartType := chartInfo.ChartType
  42. startDate := chartInfo.StartDate
  43. endDate := chartInfo.EndDate
  44. seasonStartDate := chartInfo.SeasonStartDate
  45. seasonEndDate := chartInfo.SeasonEndDate
  46. startYear := chartInfo.StartYear
  47. calendar := chartInfo.Calendar
  48. if calendar == "" {
  49. calendar = "公历"
  50. }
  51. mappingList, err := TransferChartEdbToEdbMappingFormat(chartInfoId, chartType, mappingListTmp, dataListMap)
  52. if err != nil {
  53. return
  54. }
  55. if chartType == 2 {
  56. startDate = seasonStartDate
  57. endDate = seasonEndDate
  58. if dateType <= 0 {
  59. if startDate != "" {
  60. dateType = 5
  61. } else {
  62. dateType = utils.DateTypeNYears
  63. }
  64. }
  65. } else {
  66. if dateType <= 0 {
  67. dateType = 3
  68. }
  69. }
  70. yearMax := 0
  71. if dateType == utils.DateTypeNYears {
  72. for _, v := range mappingList {
  73. if v.LatestDate != "" {
  74. lastDateT, tErr := time.Parse(utils.FormatDate, v.LatestDate)
  75. if tErr != nil {
  76. errMsg = "获取失败"
  77. err = fmt.Errorf("获取图表日期信息失败,Err:" + tErr.Error())
  78. return
  79. }
  80. if lastDateT.Year() > yearMax {
  81. yearMax = lastDateT.Year()
  82. }
  83. }
  84. }
  85. }
  86. startDate, endDate = utils.GetDateByDateTypeV2(dateType, startDate, endDate, startYear, yearMax)
  87. if chartInfo.ChartType == 2 {
  88. chartInfo.StartDate = startDate
  89. chartInfo.EndDate = endDate
  90. }
  91. // 图表额外数据参数
  92. extraConfigStr := chartInfo.ExtraConfig
  93. // 柱方图的一些配置
  94. var barConfig data_manage.BarChartInfoReq
  95. if chartInfo != nil && chartInfo.ChartType == 7 {
  96. if chartInfo.BarConfig == `` {
  97. err = fmt.Errorf("柱方图未配置")
  98. errMsg = "柱方图未配置"
  99. return
  100. }
  101. err = json.Unmarshal([]byte(chartInfo.BarConfig), &barConfig)
  102. if err != nil {
  103. err = fmt.Errorf("柱方图配置异常 json.Unmarshal Err:%s", err.Error())
  104. errMsg = "柱方图配置异常"
  105. return
  106. }
  107. extraConfigStr = chartInfo.BarConfig
  108. }
  109. // 获取表格数据
  110. excelChartInfoDataShow := new(ExcelChartInfoDataShow)
  111. excelChartInfoDataShow.DataListMap = dataListMap
  112. if chartInfo.HaveOperaAuth {
  113. // 获取图表中的指标数据
  114. edbList, xEdbIdValue, yDataList, dataResp, e, msg := GetChartEdbDataV2(chartInfoId, chartType, calendar, startDate, endDate, mappingList, extraConfigStr, chartInfo.SeasonExtraConfig, excelChartInfoDataShow)
  115. if e != nil {
  116. err = fmt.Errorf("获取图表,指标数据失败,Err:%s", e.Error())
  117. errMsg = msg
  118. return
  119. }
  120. // 单位
  121. if chartType == utils.CHART_TYPE_BAR && len(yDataList) > 0 {
  122. chartInfo.Unit = yDataList[0].Unit
  123. chartInfo.UnitEn = yDataList[0].UnitEn
  124. }
  125. warnEdbList := make([]string, 0)
  126. for _, v := range edbList {
  127. if v.IsNullData {
  128. warnEdbList = append(warnEdbList, v.EdbName+"("+v.EdbCode+")")
  129. }
  130. }
  131. if len(warnEdbList) > 0 {
  132. chartInfo.WarnMsg = `图表引用指标异常,异常指标:` + strings.Join(warnEdbList, ",")
  133. }
  134. if chartInfoId > 0 && chartInfo != nil {
  135. //判断是否加入我的图库
  136. {
  137. var myChartCondition string
  138. var myChartPars []interface{}
  139. myChartCondition += ` AND a.admin_id=? `
  140. myChartPars = append(myChartPars, sysUser.AdminId)
  141. myChartCondition += ` AND a.chart_info_id=? `
  142. myChartPars = append(myChartPars, chartInfo.ChartInfoId)
  143. myChartList, e := data_manage.GetMyChartByCondition(myChartCondition, myChartPars)
  144. if e != nil && e.Error() != utils.ErrNoRow() {
  145. errMsg = "获取失败"
  146. err = fmt.Errorf("获取我的图表信息失败,GetMyChartByCondition,Err:" + e.Error())
  147. return
  148. }
  149. if myChartList != nil && len(myChartList) > 0 {
  150. chartInfo.IsAdd = true
  151. chartInfo.MyChartId = myChartList[0].MyChartId
  152. chartInfo.MyChartClassifyId = myChartList[0].MyChartClassifyId
  153. }
  154. }
  155. }
  156. //判断是否需要展示英文标识
  157. chartInfo.IsEnChart = CheckIsEnChart(chartInfo.ChartNameEn, edbList, chartInfo.Source, chartInfo.ChartType)
  158. // 图表的指标来源
  159. sourceNameList, sourceNameEnList := GetEdbSourceByEdbInfoIdList(edbList)
  160. chartInfo.ChartSource = strings.Join(sourceNameList, ",")
  161. chartInfo.ChartSourceEn = strings.Join(sourceNameEnList, ",")
  162. // todo 指标权限
  163. {
  164. for _, item := range edbList {
  165. // 数据权限
  166. item.HaveOperaAuth = true
  167. }
  168. }
  169. resp.EdbInfoList = edbList
  170. resp.XEdbIdValue = xEdbIdValue
  171. resp.YDataList = yDataList
  172. resp.DataResp = dataResp
  173. } else {
  174. resp.EdbInfoList = mappingList
  175. }
  176. // todo 平衡表图表操作权限平衡表表格的操作权限保持一致,前端未用到该按钮权限,故不处理
  177. chartInfo.IsEdit, _ = GetBalanceExcelInfoOpButtonByChartInfoId(sysUser.AdminId, chartInfo.ChartInfoId, chartInfo.HaveOperaAuth)
  178. chartInfo.Button = data_manage.ChartViewButton{
  179. IsEdit: chartInfo.IsEdit,
  180. IsEnChart: chartInfo.IsEnChart,
  181. IsAdd: chartInfo.IsAdd,
  182. IsCopy: true,
  183. IsSetName: chartInfo.IsSetName,
  184. }
  185. resp.ChartInfo = chartInfo
  186. resp.BarChartInfo = barConfig
  187. return
  188. }
  189. // GetBalanceExcelEdbDataMapList 获取指标最后的基础数据
  190. func GetBalanceExcelEdbDataMapList(chartInfoId, chartType int, calendar, startDate, endDate string, mappingList []*data_manage.ChartEdbInfoMapping, seasonExtraConfig string, dataListMap map[int][]*data_manage.EdbDataList) (edbDataListMap map[int][]*data_manage.EdbDataList, edbList []*data_manage.ChartEdbInfoMapping, err error) {
  191. // 指标对应的所有数据
  192. edbDataListMap = make(map[int][]*data_manage.EdbDataList)
  193. for _, v := range mappingList {
  194. //fmt.Println("v:", v.EdbInfoId)
  195. item := new(data_manage.ChartEdbInfoMapping)
  196. item.EdbInfoId = v.EdbInfoId
  197. item.SourceName = v.SourceName
  198. item.Source = v.Source
  199. item.EdbCode = v.EdbCode
  200. item.EdbName = v.EdbName
  201. item.EdbNameEn = v.EdbNameEn
  202. item.Frequency = v.Frequency
  203. item.EdbType = v.EdbType
  204. item.FrequencyEn = GetFrequencyEn(v.Frequency)
  205. if v.Unit != `无` {
  206. item.Unit = v.Unit
  207. }
  208. item.UnitEn = v.UnitEn
  209. item.StartDate = v.StartDate
  210. item.EndDate = v.EndDate
  211. item.ModifyTime = v.ModifyTime
  212. item.EdbInfoCategoryType = v.EdbInfoCategoryType
  213. item.PredictChartColor = v.PredictChartColor
  214. item.ClassifyId = v.ClassifyId
  215. if chartInfoId <= 0 {
  216. item.IsAxis = 1
  217. item.LeadValue = 0
  218. item.LeadUnit = ""
  219. item.ChartEdbMappingId = 0
  220. item.ChartInfoId = 0
  221. item.IsOrder = false
  222. item.EdbInfoType = 1
  223. item.ChartStyle = ""
  224. item.ChartColor = ""
  225. item.ChartWidth = 1
  226. item.MaxData = v.MaxValue
  227. item.MinData = v.MinValue
  228. } else {
  229. item.IsAxis = v.IsAxis
  230. item.EdbInfoType = v.EdbInfoType
  231. item.LeadValue = v.LeadValue
  232. item.LeadUnit = v.LeadUnit
  233. item.LeadUnitEn = GetLeadUnitEn(v.LeadUnit)
  234. item.ChartEdbMappingId = v.ChartEdbMappingId
  235. item.ChartInfoId = v.ChartInfoId
  236. item.ChartStyle = v.ChartStyle
  237. item.ChartColor = v.ChartColor
  238. item.ChartWidth = v.ChartWidth
  239. item.IsOrder = v.IsOrder
  240. item.MaxData = v.MaxData
  241. item.MinData = v.MinData
  242. }
  243. item.LatestValue = v.LatestValue
  244. item.LatestDate = v.LatestDate
  245. item.UniqueCode = v.UniqueCode
  246. item.MoveLatestDate = v.LatestDate
  247. item.EdbAliasName = v.EdbAliasName
  248. item.IsConvert = v.IsConvert
  249. item.ConvertType = v.ConvertType
  250. item.ConvertValue = v.ConvertValue
  251. item.ConvertUnit = v.ConvertUnit
  252. item.ConvertEnUnit = v.ConvertEnUnit
  253. item.IsJoinPermission = v.IsJoinPermission
  254. var startDateReal string
  255. var diffSeconds int64
  256. if chartType == 2 { //季节性图
  257. startDateReal = startDate
  258. } else {
  259. if v.EdbInfoType == 0 && v.LeadUnit != "" && v.LeadValue > 0 { //领先指标
  260. var startTimeRealTemp time.Time
  261. startDateParse, _ := time.Parse(utils.FormatDate, startDate)
  262. switch v.LeadUnit {
  263. case "天":
  264. startTimeRealTemp = startDateParse.AddDate(0, 0, -v.LeadValue)
  265. case "月":
  266. startTimeRealTemp = startDateParse.AddDate(0, -v.LeadValue, 0)
  267. case "季":
  268. startTimeRealTemp = startDateParse.AddDate(0, -3*v.LeadValue, 0)
  269. case "周":
  270. startTimeRealTemp = startDateParse.AddDate(0, 0, -7*v.LeadValue)
  271. case "年":
  272. startTimeRealTemp = startDateParse.AddDate(-v.LeadValue, 0, 0)
  273. }
  274. if startTimeRealTemp.Before(startDateParse) {
  275. startDateReal = startTimeRealTemp.Format(utils.FormatDate)
  276. diffSeconds = (int64(startTimeRealTemp.UnixNano()) - int64(startDateParse.UnixNano())) / 1e6
  277. } else {
  278. startDateReal = startDate
  279. diffSeconds = 0
  280. }
  281. // 预测指标的开始日期也要偏移
  282. {
  283. day, tmpErr := utils.GetDaysBetween2Date(utils.FormatDate, startDate, startDateReal)
  284. if tmpErr != nil {
  285. err = tmpErr
  286. return
  287. }
  288. moveLatestDateTime, tmpErr := time.ParseInLocation(utils.FormatDate, item.MoveLatestDate, time.Local)
  289. if tmpErr != nil {
  290. err = tmpErr
  291. return
  292. }
  293. item.MoveLatestDate = moveLatestDateTime.AddDate(0, 0, day).Format(utils.FormatDate)
  294. }
  295. } else {
  296. startDateReal = startDate
  297. }
  298. }
  299. //fmt.Println("line 1011 chart:", v.Source, v.EdbInfoId, startDateReal, endDate)
  300. calendarPreYear := 0
  301. if calendar == "农历" {
  302. newStartDateReal, e := time.Parse(utils.FormatDate, startDateReal)
  303. if e != nil {
  304. err = fmt.Errorf("时间解析 time.Parse(%s, %s) error: %v", utils.FormatDate, startDateReal, e)
  305. return
  306. }
  307. calendarPreYear = newStartDateReal.Year() - 1
  308. newStartDateReal = newStartDateReal.AddDate(-1, 0, 0)
  309. startDateReal = newStartDateReal.Format(utils.FormatDate)
  310. }
  311. dataList := make([]*data_manage.EdbDataList, 0)
  312. dataListTmp, ok := dataListMap[v.EdbInfoId]
  313. if ok {
  314. dataList = dataListTmp
  315. // 对dataList 根据dataTimestamp 进行排序
  316. sort.Slice(dataList, func(i, j int) bool {
  317. return dataList[i].DataTimestamp < dataList[j].DataTimestamp
  318. })
  319. } else {
  320. //err = errors.New(fmt.Sprint("获取失败,指标类型异常", v.EdbInfoId))
  321. utils.FileLog.Info(fmt.Sprintf("获取失败,指标数据异常 %d", v.EdbInfoId))
  322. }
  323. if v.IsConvert == 1 {
  324. switch v.ConvertType {
  325. case 1:
  326. for i, data := range dataList {
  327. dataList[i].Value = data.Value * v.ConvertValue
  328. }
  329. //item.MaxData = item.MaxData * v.ConvertValue
  330. //item.MinData = item.MinData * v.ConvertValue
  331. case 2:
  332. for i, data := range dataList {
  333. dataList[i].Value = data.Value / v.ConvertValue
  334. }
  335. //item.MaxData = item.MaxData / v.ConvertValue
  336. //item.MinData = item.MinData / v.ConvertValue
  337. case 3:
  338. for i, data := range dataList {
  339. if data.Value <= 0 {
  340. err = errors.New("数据中含有负数或0,无法对数运算")
  341. return
  342. }
  343. dataList[i].Value = math.Log(data.Value) / math.Log(v.ConvertValue)
  344. }
  345. //item.MaxData = math.Log(item.MaxData) / math.Log(v.ConvertValue)
  346. //item.MinData = math.Log(item.MinData) / math.Log(v.ConvertValue)
  347. }
  348. }
  349. edbDataListMap[v.EdbInfoId] = dataList
  350. if diffSeconds != 0 && v.EdbInfoType == 0 {
  351. dataListLen := len(dataList)
  352. for i := 0; i < dataListLen; i++ {
  353. dataList[i].DataTimestamp = dataList[i].DataTimestamp - diffSeconds
  354. }
  355. }
  356. if chartType == 2 {
  357. latestDate, tmpErr := time.Parse(utils.FormatDate, v.LatestDate)
  358. if tmpErr != nil {
  359. //item.DataList = dataList
  360. item.IsNullData = true
  361. edbList = append(edbList, item)
  362. continue
  363. }
  364. if calendar == "农历" {
  365. if len(dataList) <= 0 {
  366. result := new(data_manage.EdbDataResult)
  367. item.DataList = result
  368. } else {
  369. result, tmpErr := data_manage.AddCalculateQuarterV6(dataList)
  370. if tmpErr != nil {
  371. err = errors.New("获取农历数据失败,Err:" + tmpErr.Error())
  372. return
  373. }
  374. quarterDataList, tErr := GetSeasonEdbInfoDataListByXDateNong(result, latestDate, seasonExtraConfig, calendarPreYear)
  375. if tErr != nil {
  376. err = errors.New("获取季节性图表数据失败,Err:" + tErr.Error())
  377. return
  378. }
  379. item.DataList = quarterDataList
  380. }
  381. } else {
  382. quarterDataList, tErr := GetSeasonEdbInfoDataListByXDate(dataList, latestDate, seasonExtraConfig)
  383. if tErr != nil {
  384. err = errors.New("获取季节性图表数据失败,Err:" + tErr.Error())
  385. return
  386. }
  387. item.DataList = quarterDataList
  388. }
  389. } else if chartType == 7 || chartType == utils.CHART_TYPE_RADAR { //柱方图
  390. //item.DataList = dataList
  391. } else {
  392. item.DataList = dataList
  393. }
  394. edbList = append(edbList, item)
  395. }
  396. return
  397. }
  398. func CheckBalanceChartCacheAndPermission(chartInfo *data_manage.ChartInfoView, isCache bool, sysUser *system.Admin) (resp *data_manage.ChartInfoDetailFromUniqueCodeResp, isOk bool, msg, errMsg string) {
  399. //判断是否存在缓存,如果存在缓存,那么直接从缓存中获取
  400. adminId := sysUser.AdminId
  401. // todo 图表数据权限
  402. // 已授权分类id
  403. permissionChartIdList, permissionClassifyIdList, err := data_manage_permission.GetUserChartAndClassifyPermissionList(adminId, chartInfo.ChartInfoId, chartInfo.ChartClassifyId)
  404. if err != nil {
  405. errMsg = "获取已授权分类id数据失败,Err:" + err.Error()
  406. return
  407. }
  408. defer func() {
  409. if isOk {
  410. // 图表权限校验
  411. {
  412. resp.ChartInfo.HaveOperaAuth = data_manage_permission.CheckChartPermissionByPermissionIdList(chartInfo.IsJoinPermission, 0, chartInfo.ChartInfoId, chartInfo.ChartClassifyId, permissionChartIdList, permissionClassifyIdList)
  413. //图表操作权限
  414. chartInfo.IsEdit = CheckOpChartPermission(sysUser, chartInfo.SysUserId, resp.ChartInfo.HaveOperaAuth)
  415. chartInfo.Button = data_manage.ChartViewButton{
  416. IsEdit: chartInfo.IsEdit,
  417. IsEnChart: chartInfo.IsEnChart,
  418. IsAdd: chartInfo.IsAdd,
  419. IsCopy: true,
  420. IsSetName: chartInfo.IsSetName,
  421. }
  422. //if !resp.ChartInfo.HaveOperaAuth {
  423. // for _, v := range resp.EdbInfoList {
  424. // v.DataList = nil
  425. // }
  426. // resp.DataResp = nil
  427. // resp.XEdbIdValue = []int{}
  428. // resp.YDataList = []data_manage.YData{}
  429. //}
  430. }
  431. // todo 是否需要返回平衡表指标权限即判断平衡表的表格数据权限
  432. {
  433. // 查询图表关联的表格ID
  434. excelInfo, e := excelModel.GetExcelInfoByChartInfoId(chartInfo.ChartInfoId)
  435. if e != nil {
  436. errMsg = "获取图表关联的表格ID失败,Err:" + e.Error()
  437. err = e
  438. return
  439. }
  440. checkExcelInfo := excelInfo
  441. if excelInfo.Source == utils.BALANCE_TABLE {
  442. checkExcelInfoId := excelInfo.ExcelInfoId
  443. if excelInfo.BalanceType == 1 {
  444. checkExcelInfoId = excelInfo.RelExcelInfoId
  445. } else {
  446. if excelInfo.ParentId > 0 {
  447. checkExcelInfoId = excelInfo.ParentId
  448. }
  449. }
  450. if checkExcelInfoId != excelInfo.ExcelInfoId {
  451. checkExcelInfo, err = excelModel.GetExcelInfoById(checkExcelInfoId)
  452. if err != nil {
  453. errMsg = "获取平衡表格信息失败"
  454. err = errors.New("获取平衡表格信息失败,Err:" + err.Error())
  455. return
  456. }
  457. }
  458. }
  459. haveOperaAuth, e := data_manage_permission.CheckExcelPermissionByExcelInfoId(checkExcelInfo.ExcelInfoId, checkExcelInfo.ExcelClassifyId, checkExcelInfo.IsJoinPermission, adminId)
  460. if e != nil {
  461. errMsg = "获取平衡表格数据权限失败"
  462. err = errors.New("获取表格权限信息失败,Err" + e.Error())
  463. return
  464. }
  465. // 数据权限
  466. for _, v := range resp.EdbInfoList {
  467. v.HaveOperaAuth = haveOperaAuth
  468. }
  469. }
  470. }
  471. }()
  472. key := GetChartInfoDataKey(chartInfo.ChartInfoId)
  473. if utils.Re == nil && isCache {
  474. if utils.Re == nil && utils.Rc.IsExist(key) {
  475. if redisData, err1 := utils.Rc.RedisBytes(key); err1 == nil {
  476. err := json.Unmarshal(redisData, &resp)
  477. if err != nil || resp == nil {
  478. return
  479. }
  480. // 这里跟当前用户相关的信息重新查询写入resp, 不使用缓存中的
  481. var myCond string
  482. var myPars []interface{}
  483. myCond += ` AND a.admin_id=? `
  484. myPars = append(myPars, adminId)
  485. myCond += ` AND a.chart_info_id=? `
  486. myPars = append(myPars, chartInfo.ChartInfoId)
  487. myList, err := data_manage.GetMyChartByCondition(myCond, myPars)
  488. if err != nil && err.Error() != utils.ErrNoRow() {
  489. msg = "获取失败"
  490. errMsg = "获取我的图表信息失败,GetMyChartByCondition,Err:" + err.Error()
  491. return
  492. }
  493. resp.ChartInfo.IsAdd = false
  494. resp.ChartInfo.MyChartId = 0
  495. resp.ChartInfo.MyChartClassifyId = ""
  496. if myList != nil && len(myList) > 0 {
  497. resp.ChartInfo.IsAdd = true
  498. resp.ChartInfo.MyChartId = myList[0].MyChartId
  499. resp.ChartInfo.MyChartClassifyId = myList[0].MyChartClassifyId
  500. }
  501. //判断是否加入我的图库
  502. {
  503. var myChartCondition string
  504. var myChartPars []interface{}
  505. myChartCondition += ` AND a.admin_id=? `
  506. myChartPars = append(myChartPars, adminId)
  507. myChartCondition += ` AND a.chart_info_id=? `
  508. myChartPars = append(myChartPars, chartInfo.ChartInfoId)
  509. myChartList, err := data_manage.GetMyChartByCondition(myChartCondition, myChartPars)
  510. if err != nil && err.Error() != utils.ErrNoRow() {
  511. msg = "获取失败"
  512. errMsg = "获取我的图表信息失败,GetMyChartByCondition,Err:" + err.Error()
  513. return
  514. }
  515. if myChartList != nil && len(myChartList) > 0 {
  516. chartInfo.IsAdd = true
  517. chartInfo.MyChartId = myChartList[0].MyChartId
  518. chartInfo.MyChartClassifyId = myChartList[0].MyChartClassifyId
  519. }
  520. }
  521. isOk = true
  522. fmt.Println("source redis")
  523. return
  524. }
  525. }
  526. }
  527. return
  528. }
  529. func getBalanceDataListStartDateAndValue(dataList []*data_manage.EdbDataList) (startDate, endDate string, startVal, endVal, maxVal, minVal float64) {
  530. if len(dataList) == 0 {
  531. return
  532. }
  533. startDate = dataList[0].DataTime
  534. startVal = dataList[0].Value
  535. maxVal = dataList[0].Value
  536. minVal = dataList[0].Value
  537. endDate = dataList[len(dataList)-1].DataTime
  538. endVal = dataList[len(dataList)-1].Value
  539. for _, v := range dataList {
  540. if v.DataTime < startDate {
  541. startDate = v.DataTime
  542. startVal = v.Value
  543. }
  544. if v.DataTime > endDate {
  545. endDate = v.DataTime
  546. endVal = v.Value
  547. }
  548. if v.Value > maxVal {
  549. maxVal = v.Value
  550. }
  551. if v.Value < minVal {
  552. minVal = v.Value
  553. }
  554. }
  555. return
  556. }
  557. func TransferChartEdbToEdbMappingFormat(chartInfoId, chartType int, mappingListTmp []*excelModel.ExcelChartEdb, dataListMap map[int][]*data_manage.EdbDataList) (mappingList []*data_manage.ChartEdbInfoMapping, err error) {
  558. mappingList = make([]*data_manage.ChartEdbInfoMapping, 0)
  559. //循环组装映射关系
  560. for _, v := range mappingListTmp {
  561. dataList := make([]*data_manage.EdbDataList, 0)
  562. dataListTmp, ok := dataListMap[v.ExcelChartEdbId]
  563. if ok {
  564. dataList = dataListTmp
  565. } else {
  566. //err = errors.New(fmt.Sprint("获取失败,指标类型异常", v.ExcelChartEdbId))
  567. utils.FileLog.Info(fmt.Sprintf("获取失败,指标数据异常 %d", v.ExcelChartEdbId))
  568. }
  569. startDateStr, endDateStr, _, endVal, maxValue, minValue := getBalanceDataListStartDateAndValue(dataList)
  570. mapping := &data_manage.ChartEdbInfoMapping{
  571. EdbInfoId: v.ExcelChartEdbId,
  572. SourceName: "平衡表",
  573. Source: 0,
  574. SubSource: 0,
  575. EdbCode: v.EdbCode,
  576. EdbName: v.EdbName,
  577. EdbAliasName: v.EdbName,
  578. EdbNameEn: v.EdbNameEn,
  579. EdbAliasNameEn: "",
  580. EdbType: 0,
  581. Frequency: "",
  582. FrequencyEn: "",
  583. Unit: v.Unit,
  584. UnitEn: v.UnitEn,
  585. StartDate: startDateStr,
  586. EndDate: endDateStr,
  587. ModifyTime: v.ModifyTime.Format(utils.FormatDateTime),
  588. ChartEdbMappingId: v.ExcelChartEdbId,
  589. ChartInfoId: chartInfoId,
  590. MaxData: v.MaxData,
  591. MinData: v.MinData,
  592. IsOrder: v.IsOrder,
  593. IsAxis: v.IsAxis,
  594. EdbInfoType: v.EdbInfoType,
  595. //EdbInfoCategoryType: 0,
  596. LeadValue: v.LeadValue,
  597. LeadUnit: v.LeadUnit,
  598. LeadUnitEn: "",
  599. ChartStyle: "",
  600. ChartColor: "",
  601. PredictChartColor: "",
  602. ChartWidth: v.ChartWidth,
  603. ChartType: chartType,
  604. LatestDate: endDateStr,
  605. LatestValue: endVal,
  606. MoveLatestDate: "",
  607. UniqueCode: "",
  608. MinValue: minValue,
  609. MaxValue: maxValue,
  610. DataList: nil,
  611. IsNullData: false,
  612. MappingSource: 0,
  613. RegionType: "",
  614. ClassifyId: 0,
  615. IsConvert: 0,
  616. ConvertType: 0,
  617. ConvertValue: 0,
  618. ConvertUnit: "",
  619. ConvertEnUnit: "",
  620. IsJoinPermission: 0,
  621. HaveOperaAuth: true,
  622. }
  623. mappingList = append(mappingList, mapping)
  624. }
  625. return
  626. }
  627. // GetBalanceExcelInfoOpButtonByChartInfoId 获取图表权限
  628. func GetBalanceExcelInfoOpButtonByChartInfoId(sysUserId, chartInfoId int, chartHaveOperaAuth bool) (opButton bool, err error) {
  629. // 如果没有数据权限,那么直接返回
  630. if !chartHaveOperaAuth {
  631. return
  632. }
  633. // 获取表格信息
  634. excelInfo, e := excelModel.GetExcelInfoByChartInfoId(chartInfoId)
  635. if e != nil {
  636. err = fmt.Errorf("获取ETA表格失败 Err %s", e.Error())
  637. return
  638. }
  639. checkExcelInfo := excelInfo
  640. if excelInfo.Source == utils.BALANCE_TABLE {
  641. checkExcelInfoId := excelInfo.ExcelInfoId
  642. if excelInfo.BalanceType == 1 {
  643. checkExcelInfoId = excelInfo.RelExcelInfoId
  644. } else {
  645. if excelInfo.ParentId > 0 {
  646. checkExcelInfoId = excelInfo.ParentId
  647. }
  648. }
  649. if checkExcelInfoId != excelInfo.ExcelInfoId {
  650. checkExcelInfo, e = excelModel.GetExcelInfoById(checkExcelInfoId)
  651. if e != nil {
  652. err = fmt.Errorf("获取平衡表格信息失败,Err:" + e.Error())
  653. return
  654. }
  655. }
  656. } else {
  657. return
  658. }
  659. // 数据权限
  660. haveOperaAuth, e := data_manage_permission.CheckExcelPermissionByExcelInfoId(checkExcelInfo.ExcelInfoId, checkExcelInfo.ExcelClassifyId, checkExcelInfo.IsJoinPermission, sysUserId)
  661. if e != nil {
  662. err = fmt.Errorf("获取表格权限信息失败,Err" + e.Error())
  663. return
  664. }
  665. // 如果没有数据权限,那么直接返回
  666. if !haveOperaAuth {
  667. return
  668. }
  669. //button := GetBalanceExcelInfoOpButton(sysUserId, checkExcelInfo.SysUserId, haveOperaAuth, checkExcelInfo.ExcelInfoId)
  670. if sysUserId == checkExcelInfo.SysUserId {
  671. opButton = true
  672. } else {
  673. obj := new(excelModel.ExcelWorker)
  674. workerList, e := obj.GetByExcelInfoId(checkExcelInfo.ExcelInfoId)
  675. if e == nil {
  676. for _, v := range workerList {
  677. if v.SysUserId == sysUserId {
  678. opButton = true
  679. break
  680. }
  681. }
  682. }
  683. }
  684. return
  685. }