actions.js 6.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170
  1. // 组件配置转化
  2. // import _ from 'lodash'
  3. import cloneDeep from 'lodash/cloneDeep'
  4. import { setModules, dataModules } from 'data-room-ui/js/utils/configImport'
  5. import { getScreenInfo, getDataSetDetails, getDataByDataSetId } from '../api/bigScreenApi'
  6. import { stringToFunction } from '../utils/evalFunctions'
  7. import { EventBus } from '../utils/eventBus'
  8. import plotList from 'data-room-ui/G2Plots/plotList'
  9. import { settingToTheme, themeToSetting } from 'data-room-ui/js/utils/themeFormatting'
  10. export default {
  11. // 初始化页面数据
  12. initLayout ({ commit, dispatch }, code) {
  13. return new Promise(resolve => {
  14. getScreenInfo(code).then(data => {
  15. const pageInfo = handleResData(data)
  16. // 改变页面数据
  17. commit('changePageInfo', pageInfo)
  18. commit('changeZIndex', pageInfo.chartList)
  19. // 初始化缓存数据集数据
  20. // eslint-disable-next-line no-unused-expressions
  21. pageInfo.pageConfig.cacheDataSets?.map((cacheDataSet) => {
  22. dispatch('getCacheDataSetData', { dataSetId: cacheDataSet.dataSetId })
  23. dispatch('getCacheDataFields', { dataSetId: cacheDataSet.dataSetId })
  24. })
  25. // 页面加载成功
  26. resolve(true)
  27. commit('saveTimeLine', '初始化')
  28. })
  29. })
  30. },
  31. // 初始化缓存数据集数据
  32. getCacheDataSetData ({ commit, dispatch }, { dataSetId }) {
  33. getDataByDataSetId(dataSetId).then(res => {
  34. const data = res.data
  35. commit('changeCacheDataSetData', { dataSetId, data })
  36. // 推送数据到各个组件
  37. emitDataToChart(dataSetId, data)
  38. })
  39. },
  40. // 初始化缓存数据集字段
  41. getCacheDataFields ({ commit, dispatch }, { dataSetId }) {
  42. getDataSetDetails(dataSetId).then(data => {
  43. commit('changeCacheDataFields', { dataSetId, data })
  44. commit('changeCacheDataParams', { dataSetId, data })
  45. })
  46. }
  47. }
  48. // 处理后端返回的数据
  49. export function handleResData (data) {
  50. let pageInfo = {}
  51. if (data.pageConfig) {
  52. pageInfo = data
  53. } else {
  54. pageInfo = {
  55. ...data,
  56. pageConfig: {
  57. w: 1920,
  58. h: 1080,
  59. bgColor: '#151a26', // 背景色
  60. bg: '', // 背景图
  61. customTheme: 'auto',
  62. opacity: 100
  63. }
  64. }
  65. }
  66. // 如果pageConfig中的cacheDataSets为null,赋值[]
  67. pageInfo.pageConfig.cacheDataSets = pageInfo.pageConfig.cacheDataSets || []
  68. pageInfo.pageConfig.refreshConfig = pageInfo.pageConfig.refreshConfig || []
  69. let originalConfig = {}
  70. pageInfo.chartList.forEach((chart) => {
  71. if (!['customComponent', 'remoteComponent'].includes(chart.type)) {
  72. // TODO:一般组件也需要添加主题的兼容处理
  73. originalConfig = { option: { ...setModules[chart.type] }, ...dataModules[chart.type] }
  74. // 如果没有版本号,或者版本号修改了则需要进行旧数据兼容
  75. if ((!chart.version) || chart.version !== originalConfig.version) {
  76. chart = compatibility(chart, originalConfig)
  77. } else {
  78. chart.option = cloneDeep(setModules[chart.type])
  79. }
  80. } else {
  81. originalConfig = plotList?.find(plot => plot.name === chart.name)
  82. chart.option = stringToFunction(chart.option)
  83. // 如果是自定义组件,且没配数据集,就给前端的模拟数据
  84. if (!chart?.dataSource?.businessKey) {
  85. chart.option.data = plotList?.find(plot => plot.name === chart.name)?.option?.data
  86. }
  87. // 如果没有版本号,或者版本号修改了则需要进行旧数据兼容
  88. if ((!chart.version) || (originalConfig && chart.version !== originalConfig?.version)) {
  89. // TODO 远程组件需要重新写处理函数
  90. if (chart.type === 'customComponent') {
  91. chart = compatibility(chart, originalConfig)
  92. }
  93. }
  94. // 初始化时应该判断,是否存在theme配置,没有的话添加默认的两套主题,这是为了兼容旧组件
  95. if (!chart.theme) {
  96. chart.theme = settingToTheme(chart, 'dark')
  97. chart.theme = settingToTheme(chart, 'light')
  98. }
  99. }
  100. chart.key = chart.code
  101. })
  102. // 主题兼容
  103. pageInfo.chartList = themeToSetting(pageInfo.chartList, pageInfo.pageConfig.customTheme)
  104. // 存储修改后的配置
  105. localStorage.setItem('pageInfo', JSON.stringify(pageInfo))
  106. return pageInfo
  107. }
  108. // 组件属性兼容
  109. function compatibility (config, originalConfig) {
  110. const newConfig = config
  111. newConfig.version = originalConfig.version
  112. newConfig.dataSource = objCompare(newConfig.dataSource, originalConfig.dataSource)
  113. newConfig.customize = objCompare(newConfig.customize, originalConfig.customize)
  114. newConfig.option = { ...objCompare(newConfig.option, originalConfig.option), displayOption: originalConfig.option.displayOption }
  115. newConfig.setting = arrCompare(newConfig.setting, originalConfig.setting)
  116. return newConfig
  117. }
  118. // 对象比较
  119. function objCompare (obj1, obj2) {
  120. const keys1 = obj1 ? Object.keys(obj1) : []
  121. const keys2 = obj2 ? Object.keys(obj2) : []
  122. // 交集
  123. const intersection = keys1?.filter(function (v) { return keys2.indexOf(v) > -1 }) || []
  124. // 差集
  125. const differenceSet = keys2?.filter(function (v) { return keys1.indexOf(v) === -1 }) || []
  126. const obj = {}
  127. for (const item of intersection) {
  128. obj[item] = obj1[item]
  129. }
  130. for (const item of differenceSet) {
  131. obj[item] = obj2[item]
  132. }
  133. return obj
  134. }
  135. // 数组比较
  136. function arrCompare (list1, list2) {
  137. const fieldList = list1?.map(item => item.field) || []
  138. const list = list2?.map(item => {
  139. let value = null
  140. // 如果存在交集
  141. if (fieldList.includes(item.field)) {
  142. // 保留旧数据的value
  143. value = (list1.filter(j => {
  144. return j.field === item.field
  145. }))[0].value
  146. } else {
  147. // 不存在交集,直接覆盖
  148. value = item.value
  149. }
  150. return {
  151. ...item,
  152. value
  153. }
  154. }) || []
  155. return list
  156. }
  157. // 推送数据到各个组件
  158. function emitDataToChart (dataSetId, data) {
  159. if (data && data.length) {
  160. EventBus.$emit('cacheDataInit',
  161. {
  162. success: true,
  163. data: data
  164. },
  165. dataSetId
  166. )
  167. }
  168. }