actions.js 6.1 KB

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