actions.js 8.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227
  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 plotSettings from 'data-room-ui/G2Plots/settings'
  7. import { stringToFunction } from '../utils/evalFunctions'
  8. import { EventBus } from '../utils/eventBus'
  9. import plotList from 'data-room-ui/G2Plots/plotList'
  10. import { settingToTheme, themeToSetting } from 'data-room-ui/js/utils/themeFormatting'
  11. export default {
  12. // 初始化页面数据
  13. initLayout ({ commit, dispatch }, code) {
  14. return new Promise(resolve => {
  15. getScreenInfo(code).then(data => {
  16. // 配置兼容
  17. const pageInfo = handleResData(data)
  18. // 兼容边框配置
  19. pageInfo.chartList.forEach((chart) => {
  20. // 对数据源的方式进行兼容
  21. if (chart.dataSource && ['texts', 'numbers'].includes(chart.type)) {
  22. if (chart.dataSource.source === 'dataset' && (!chart.dataSource.businessKey)) {
  23. chart.dataSource.source = 'static'
  24. }
  25. } else if (!chart.dataSource.source) {
  26. chart.dataSource.source = 'dataset'
  27. }
  28. if (!chart.border) {
  29. chart.border = { type: '', titleHeight: 60, fontSize: 16, isTitle: true, padding: [0, 0, 0, 0] }
  30. }
  31. if (!chart.border.padding) {
  32. chart.border.padding = [0, 0, 0, 0]
  33. }
  34. const plotSettingsIterator = false
  35. if (chart.type == 'customComponent') {
  36. // 为本地G2组件配置添加迭代器
  37. if (!plotSettingsIterator) {
  38. plotSettings[Symbol.iterator] = function * () {
  39. const keys = Object.keys(plotSettings)
  40. for (const k of keys) {
  41. yield [k, plotSettings[k]]
  42. }
  43. }
  44. }
  45. for (const [key, localPlotSetting] of plotSettings) {
  46. if (chart.name == localPlotSetting.name) {
  47. // 本地配置项
  48. const localSettings = JSON.parse(JSON.stringify(localPlotSetting.setting))
  49. chart.setting = localSettings.map((localSet) => {
  50. // 在远程组件配置中找到 与 本地组件的配置项 相同的项索引
  51. const index = chart.setting.findIndex(remoteSet => remoteSet.field == localSet.field)
  52. if (index !== -1) {
  53. // 使用远程的值替换本地值
  54. localSet.field = chart.setting[index].field
  55. localSet.value = chart.setting[index].value
  56. }
  57. return localSet
  58. })
  59. }
  60. }
  61. }
  62. })
  63. // 改变页面数据
  64. commit('changePageInfo', pageInfo)
  65. commit('changeZIndex', pageInfo.chartList)
  66. // 初始化缓存数据集数据
  67. // eslint-disable-next-line no-unused-expressions
  68. pageInfo.pageConfig.cacheDataSets?.map((cacheDataSet) => {
  69. dispatch('getCacheDataSetData', { dataSetId: cacheDataSet.dataSetId })
  70. dispatch('getCacheDataFields', { dataSetId: cacheDataSet.dataSetId })
  71. })
  72. // 页面加载成功
  73. resolve(true)
  74. commit('saveTimeLine', '初始化')
  75. })
  76. })
  77. },
  78. // 初始化缓存数据集数据
  79. getCacheDataSetData ({ commit, dispatch }, { dataSetId }) {
  80. getDataByDataSetId(dataSetId).then(res => {
  81. const data = res.data
  82. commit('changeCacheDataSetData', { dataSetId, data })
  83. // 推送数据到各个组件
  84. emitDataToChart(dataSetId, data)
  85. })
  86. },
  87. // 初始化缓存数据集字段
  88. getCacheDataFields ({ commit, dispatch }, { dataSetId }) {
  89. getDataSetDetails(dataSetId).then(data => {
  90. commit('changeCacheDataFields', { dataSetId, data })
  91. commit('changeCacheDataParams', { dataSetId, data })
  92. })
  93. }
  94. }
  95. // 处理后端返回的数据
  96. export function handleResData (data) {
  97. let pageInfo = {}
  98. if (data.pageConfig) {
  99. pageInfo = {
  100. ...data,
  101. pageConfig: {
  102. ...data.pageConfig,
  103. lightBgColor: data.pageConfig.lightBgColor || '#f5f7fa'
  104. }
  105. }
  106. } else {
  107. pageInfo = {
  108. ...data,
  109. pageConfig: {
  110. w: 1920,
  111. h: 1080,
  112. bgColor: '#151a26', // 背景色
  113. lightBgColor: '#f5f7fa',
  114. lightBg: '',
  115. bg: '', // 背景图
  116. customTheme: 'dark',
  117. opacity: 100
  118. }
  119. }
  120. }
  121. // 如果pageConfig中的cacheDataSets为null,赋值[]
  122. pageInfo.pageConfig.cacheDataSets = pageInfo.pageConfig.cacheDataSets || []
  123. pageInfo.pageConfig.refreshConfig = pageInfo.pageConfig.refreshConfig || []
  124. let originalConfig = {}
  125. pageInfo.chartList.forEach((chart) => {
  126. if (!['customComponent', 'remoteComponent', 'echartsComponent'].includes(chart.type)) {
  127. originalConfig = { option: { ...setModules[chart.type] }, ...dataModules[chart.type] }
  128. // 如果没有版本号,或者版本号修改了则需要进行旧数据兼容
  129. if ((!chart.version) || chart.version !== originalConfig.version) {
  130. chart = compatibility(chart, originalConfig)
  131. } else {
  132. chart.option = cloneDeep(setModules[chart.type])
  133. }
  134. } else {
  135. originalConfig = plotList?.find(plot => plot.name === chart.name)
  136. chart.option = stringToFunction(chart.option)
  137. // 如果是自定义组件,且没配数据集,就给前端的模拟数据
  138. if (!chart?.dataSource?.businessKey) {
  139. chart.option.data = plotList?.find(plot => plot.name === chart.name)?.option?.data || chart?.option?.data
  140. }
  141. // 如果没有版本号,或者版本号修改了则需要进行旧数据兼容
  142. if ((!chart.version) || (originalConfig && chart.version !== originalConfig?.version)) {
  143. // TODO 远程组件需要重新写处理函数
  144. if (chart.type === 'customComponent') {
  145. chart = compatibility(chart, originalConfig)
  146. }
  147. }
  148. }
  149. // 初始化时应该判断,是否存在theme配置,没有的话添加默认的两套主题,这是为了兼容旧组件
  150. if (!chart.theme) {
  151. chart.theme = settingToTheme(chart, 'dark')
  152. chart.theme = settingToTheme(chart, 'light')
  153. }
  154. chart.key = chart.code
  155. })
  156. // 主题兼容
  157. pageInfo.chartList = themeToSetting(pageInfo.chartList, pageInfo.pageConfig.customTheme)
  158. // 存储修改后的配置
  159. localStorage.setItem('pageInfo', JSON.stringify(pageInfo))
  160. return pageInfo
  161. }
  162. // 组件属性兼容
  163. function compatibility (config, originalConfig) {
  164. const newConfig = config
  165. newConfig.version = originalConfig?.version || '2023071001'
  166. newConfig.optionHandler = originalConfig.optionHandler || ''
  167. newConfig.dataSource = objCompare(newConfig?.dataSource, originalConfig?.dataSource)
  168. newConfig.customize = objCompare(newConfig?.customize, originalConfig?.customize)
  169. newConfig.option = { ...objCompare(newConfig.option, originalConfig?.option), displayOption: originalConfig?.option?.displayOption }
  170. newConfig.setting = arrCompare(newConfig?.setting, originalConfig?.setting)
  171. return newConfig
  172. }
  173. // 对象比较
  174. function objCompare (obj1, obj2) {
  175. const keys1 = obj1 ? Object.keys(obj1) : []
  176. const keys2 = obj2 ? Object.keys(obj2) : []
  177. // 交集
  178. const intersection = keys1?.filter(function (v) { return keys2.indexOf(v) > -1 }) || []
  179. // 差集
  180. const differenceSet = keys2?.filter(function (v) { return keys1.indexOf(v) === -1 }) || []
  181. const obj = {}
  182. for (const item of intersection) {
  183. obj[item] = obj1[item]
  184. }
  185. for (const item of differenceSet) {
  186. obj[item] = obj2[item]
  187. }
  188. return obj
  189. }
  190. // 数组比较
  191. function arrCompare (list1, list2) {
  192. const fieldList = list1?.map(item => item.field) || []
  193. const list = list2?.map(item => {
  194. let value = null
  195. // 如果存在交集
  196. if (fieldList.includes(item.field)) {
  197. // 保留旧数据的value
  198. value = (list1.filter(j => {
  199. return j.field === item.field
  200. }))[0].value
  201. } else {
  202. // 不存在交集,直接覆盖
  203. value = item.value
  204. }
  205. return {
  206. ...item,
  207. value
  208. }
  209. }) || []
  210. return list
  211. }
  212. // 推送数据到各个组件
  213. function emitDataToChart (dataSetId, data) {
  214. if (data && data.length) {
  215. EventBus.$emit('cacheDataInit',
  216. {
  217. success: true,
  218. data: data
  219. },
  220. dataSetId
  221. )
  222. }
  223. }