actions.js 5.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169
  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: 'dark',
  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. originalConfig = { option: { ...setModules[chart.type] }, ...dataModules[chart.type] }
  73. // 如果没有版本号,或者版本号修改了则需要进行旧数据兼容
  74. if ((!chart.version) || chart.version !== originalConfig.version) {
  75. chart = compatibility(chart, originalConfig)
  76. } else {
  77. chart.option = cloneDeep(setModules[chart.type])
  78. }
  79. } else {
  80. originalConfig = plotList?.find(plot => plot.name === chart.name)
  81. chart.option = stringToFunction(chart.option)
  82. // 如果是自定义组件,且没配数据集,就给前端的模拟数据
  83. if (!chart?.dataSource?.businessKey) {
  84. chart.option.data = plotList?.find(plot => plot.name === chart.name)?.option?.data
  85. }
  86. // 如果没有版本号,或者版本号修改了则需要进行旧数据兼容
  87. if ((!chart.version) || (originalConfig && chart.version !== originalConfig?.version)) {
  88. // TODO 远程组件需要重新写处理函数
  89. if (chart.type === 'customComponent') {
  90. chart = compatibility(chart, originalConfig)
  91. }
  92. }
  93. }
  94. // 初始化时应该判断,是否存在theme配置,没有的话添加默认的两套主题,这是为了兼容旧组件
  95. if (!chart.theme) {
  96. chart.theme = settingToTheme(chart, 'dark')
  97. chart.theme = settingToTheme(chart, 'light')
  98. }
  99. chart.key = chart.code
  100. })
  101. // 主题兼容
  102. pageInfo.chartList = themeToSetting(pageInfo.chartList, pageInfo.pageConfig.customTheme)
  103. // 存储修改后的配置
  104. localStorage.setItem('pageInfo', JSON.stringify(pageInfo))
  105. return pageInfo
  106. }
  107. // 组件属性兼容
  108. function compatibility (config, originalConfig) {
  109. const newConfig = config
  110. newConfig.version = originalConfig.version
  111. newConfig.dataSource = objCompare(newConfig.dataSource, originalConfig.dataSource)
  112. newConfig.customize = objCompare(newConfig.customize, originalConfig.customize)
  113. newConfig.option = { ...objCompare(newConfig.option, originalConfig.option), displayOption: originalConfig.option.displayOption }
  114. newConfig.setting = arrCompare(newConfig.setting, originalConfig.setting)
  115. return newConfig
  116. }
  117. // 对象比较
  118. function objCompare (obj1, obj2) {
  119. const keys1 = obj1 ? Object.keys(obj1) : []
  120. const keys2 = obj2 ? Object.keys(obj2) : []
  121. // 交集
  122. const intersection = keys1?.filter(function (v) { return keys2.indexOf(v) > -1 }) || []
  123. // 差集
  124. const differenceSet = keys2?.filter(function (v) { return keys1.indexOf(v) === -1 }) || []
  125. const obj = {}
  126. for (const item of intersection) {
  127. obj[item] = obj1[item]
  128. }
  129. for (const item of differenceSet) {
  130. obj[item] = obj2[item]
  131. }
  132. return obj
  133. }
  134. // 数组比较
  135. function arrCompare (list1, list2) {
  136. const fieldList = list1?.map(item => item.field) || []
  137. const list = list2?.map(item => {
  138. let value = null
  139. // 如果存在交集
  140. if (fieldList.includes(item.field)) {
  141. // 保留旧数据的value
  142. value = (list1.filter(j => {
  143. return j.field === item.field
  144. }))[0].value
  145. } else {
  146. // 不存在交集,直接覆盖
  147. value = item.value
  148. }
  149. return {
  150. ...item,
  151. value
  152. }
  153. }) || []
  154. return list
  155. }
  156. // 推送数据到各个组件
  157. function emitDataToChart (dataSetId, data) {
  158. if (data && data.length) {
  159. EventBus.$emit('cacheDataInit',
  160. {
  161. success: true,
  162. data: data
  163. },
  164. dataSetId
  165. )
  166. }
  167. }