actions.js 7.4 KB

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