2025-05-27

king

2025-05-27 a5bc394eceeaae5923057f1fd919968fd234af23

 src/utils/utils-datamanage.js

@@ -5,6 +5,136 @@
import MKEmitter from '@/utils/events.js'
import Utils from './utils.js'

const getBackendQueryParam = (setting, search, orderBy, pageIndex, pageSize, id, BID, year, dataName) => {
  let item = window.GLOB.CacheData.get('sql_' + setting.uuid)

  let searchKeys = null
  if (setting.dataresource) {
    searchKeys = []

    if (search.length && setting.queryType !== 'statistics') {
      searchKeys = Utils.getSearchkeys(search)
    }

    if (id) {
      if (/^excel:/.test(id)) {
        id = id.replace(/^excel:/, '')
        searchKeys.push({
          key: setting.primaryKey || 'ID',
          match: '',
          type: 'text_in',
          value: id
        })
      } else {
        searchKeys.push({
          key: setting.primaryKey || 'ID',
          match: '03',
          type: 'text',
          value: id
        })
      }
    }
  }

  let values = {
    time_id: Utils.getguid(),
    roleid: sessionStorage.getItem('role_id') || '',
    mk_departmentcode: sessionStorage.getItem('departmentcode') || '',
    mk_organization: sessionStorage.getItem('organization') || '',
    mk_user_type: sessionStorage.getItem('mk_user_type') || '',
    mk_nation: sessionStorage.getItem('nation') || '',
    mk_province: sessionStorage.getItem('province') || '',
    mk_city: sessionStorage.getItem('city') || '',
    mk_district: sessionStorage.getItem('district') || '',
    mk_address: sessionStorage.getItem('address') || '',
    orderby: orderBy || '',
    pagesize: setting.laypage ? pageSize : '9999',
    pageindex: pageIndex,
    id: id || '',
    bid: BID || '',
    typename: 'admin',
    datam: sessionStorage.getItem('dataM') === 'true' ? 'Y' : '',
    datam_begin: sessionStorage.getItem('dataM') === 'true' ? 'Y' : '',
    datam_end: sessionStorage.getItem('dataM') === 'true' ? 'Y' : '',
    mk_obj_name: dataName || 'data'
  }

  if (setting.hasExtend) {
    values.mk_time = setting.extendTime
  }
  if (setting.$re_year) {
    values.mk_year = year
  }
  if (window.GLOB.externalDatabase !== null) {
    values.db = window.GLOB.externalDatabase
  }
  if (item.works_flow_code) {
    values.works_flow_code = item.works_flow_code
  }

  item.urlkeys && item.urlkeys.forEach(key => {
    if (values.hasOwnProperty(key.toLowerCase())) return
    
    values[key] = item.urlparam[key]
  })

  let allSearch = Utils.getAllSearchOptions(search)

  allSearch.forEach(cell => {
    values[cell.key.toLowerCase()] = cell.value
  })

  let exps = []

  if (searchKeys) {
    exps.push({
      key: 'mk_search',
      value: searchKeys
    })
  }

  item.reps.forEach(n => {
    let key = n.toLowerCase()
    if (values.hasOwnProperty(key)) {
      exps.push({
        key: n,
        value: values[key]
      })
    }
  })

  let md5_id = ''
  if (window.GLOB.probation) {
    md5_id = md5(item.id + JSON.stringify(exps) + Math.floor(new Date().getTime() / 600000))
    md5_id = moment().format('YYYYMMDDHHmmss') + md5_id.slice(-18)
  }

  let cell = {
    id: item.id,
    menuname: setting.$name || '',
    exps: exps,
    md5_id: md5_id
  }

  if (dataName) {
    cell.dataName = dataName
    cell.luser = item.luser
    return cell
  }

  let param = {
    $backend: true,
    $type: 's_Get_TableData',
    data: [cell]
  }

  if (setting.database === 'sso' && window.GLOB.mainSystemApi) {
    param.rduri = window.GLOB.mainSystemApi
  }

  return param
}

export default class DataUtils {
  /**
   * @description 数据源统一查询
@@ -13,17 +143,23 @@
    let param = null

    if (setting.interType === 'system') {
      param = this.getDefaultQueryParam(setting, search, orderBy, pageIndex, pageSize, id, BID, year)
      if (window.backend && window.GLOB.CacheData.has('sql_' + setting.uuid)) {
        param = getBackendQueryParam(setting, search, orderBy, pageIndex, pageSize, id, BID, year)
      } else {
        param = this.getDefaultQueryParam(setting, search, orderBy, pageIndex, pageSize, id, BID, year)
        param.BID = BID || ''
        param.dataM = sessionStorage.getItem('dataM') === 'true' ? 'Y' : ''
      }
    } else {
      param = this.getCustomQueryParam(setting, search, orderBy, pageIndex, pageSize, id, year)
    }

    if (BID) {
      param.BID = BID
    }
    // 数据管理权限
    if (sessionStorage.getItem('dataM') === 'true') {
      param.dataM = 'Y'
      if (BID) {
        param.BID = BID
      }
      // 数据管理权限
      if (sessionStorage.getItem('dataM') === 'true') {
        param.dataM = 'Y'
      }
    }

    return param
@@ -142,9 +278,9 @@
      { reg: /@orderBy@/ig, value: orderBy },
      { reg: /@pageSize@/ig, value: setting.laypage ? pageSize : '9999' },
      { reg: /@pageIndex@/ig, value: pageIndex},
      { reg: /@select\$|\$select@/ig, value: ''},
      { reg: /\$sum@/ig, value: '/*'},
      { reg: /@sum\$/ig, value: '*/'},
      // { reg: /@select\$|\$select@/ig, value: ''},
      // { reg: /\$sum@/ig, value: '/*'},
      // { reg: /@sum\$/ig, value: '*/'},
      { reg: /@ID@/ig, value: `'${id || ''}'`},
      { reg: /@BID@/ig, value: `'${BID || ''}'`},
      { reg: /@LoginUID@/ig, value: `'${sessionStorage.getItem('LoginUID') || ''}'`},
@@ -156,10 +292,10 @@
    )

    if (setting.hasExtend) {
      regoptions.push({ reg: /@mk_time@/ig, value: setting.extendTime })
      regoptions.push({ reg: /@mk_time@/ig, value: `'${setting.extendTime}'` })
    }
    if (setting.$re_year) {
      regoptions.push({ reg: /@mk_year@/ig, value: year })
      regoptions.push({ reg: /@mk_year@/ig, value: `'${year}'` })
    }

    regoptions.forEach(item => {
@@ -280,9 +416,9 @@

    // 测试系统打印查询语句
    if (window.GLOB.debugger === true) {
      _customScript && console.info(`${setting.$name ? `/*${setting.$name} 自定义脚本*/\n` : ''}${LText ? '' : '/*不执行默认sql*/\n'}${_customScript}`)
      LText && console.info(`${setting.$name ? `/*${setting.$name} 数据源*/\n` : ''}` + LText.replace(/\n\s{8}/ig, '\n'))
      DateCount && console.info(`${setting.$name ? `/*${setting.$name} 总数查询*/\n` : ''}` + DateCount.replace(/\n\s{8}/ig, '\n'))
      _customScript && window.mkInfo(`${setting.$name ? `/*${setting.$name} 自定义脚本*/\n` : ''}${LText ? '' : '/*不执行默认sql*/\n'}${_customScript}`)
      LText && window.mkInfo(`${setting.$name ? `/*${setting.$name} 数据源*/\n` : ''}` + LText.replace(/\n\s{8}/ig, '\n'))
      DateCount && window.mkInfo(`${setting.$name ? `/*${setting.$name} 总数查询*/\n` : ''}` + DateCount.replace(/\n\s{8}/ig, '\n'))
    }

    if (setting.$name) {
@@ -321,6 +457,10 @@
      }
    } else if (window.GLOB.forcedUpdate) {
      param.s_version_up = 'true'
    }

    if (setting.database === 'sso' && window.GLOB.mainSystemApi) {
      param.rduri = window.GLOB.mainSystemApi
    }

    return param
@@ -371,9 +511,9 @@
      { reg: /@orderBy@/ig, value: orderBy },
      { reg: /@pageSize@/ig, value: 999999 },
      { reg: /@pageIndex@/ig, value: 1},
      { reg: /\$select@/ig, value: '/*'},
      { reg: /@select\$/ig, value: '*/'},
      { reg: /@sum\$|\$sum@/ig, value: ''},
      // { reg: /\$select@/ig, value: '/*'},
      // { reg: /@select\$/ig, value: '*/'},
      // { reg: /@sum\$|\$sum@/ig, value: ''},
      { reg: /@ID@/ig, value: `''`},
      { reg: /@BID@/ig, value: `'${BID || ''}'`},
      { reg: /@LoginUID@/ig, value: `'${sessionStorage.getItem('LoginUID') || ''}'`},
@@ -415,8 +555,8 @@

    // 测试系统打印查询语句
    if (window.GLOB.debugger === true) {
      _customScript &&  console.info(`${setting.$name ? `/*${setting.$name} 自定义脚本 统计查询*/\n` : ''}${LText ? '' : '/*不执行默认sql*/\n'}${_customScript}`)
      LText &&  console.info(`${setting.$name ? `/*${setting.$name} 数据源 统计查询*/\n` : ''}` + LText.replace(/\n\s{8}/ig, '\n'))
      _customScript && window.mkInfo(`${setting.$name ? `/*${setting.$name} 自定义脚本 统计查询*/\n` : ''}${LText ? '' : '/*不执行默认sql*/\n'}${_customScript}`)
      LText && window.mkInfo(`${setting.$name ? `/*${setting.$name} 数据源 统计查询*/\n` : ''}` + LText.replace(/\n\s{8}/ig, '\n'))
    }

    if (setting.$name) {
@@ -493,8 +633,17 @@
/**
 * @description 生成单个组件sPC_Get_structured_data请求参数
 */
export function getStructDefaultParam (component, searchlist, first) {
export function getStructDefaultParam (component, searchlist, first, BID) {
  const { columns, setting, dataName, format, uuid } = component

  if (window.backend && window.GLOB.CacheData.has('sql_' + uuid)) {
    if (first) {
      let item = window.GLOB.CacheData.get('sql_' + uuid)
      window.GLOB.CacheData.set('first_' + item.id, uuid)
    }

    return getBackendQueryParam(setting, searchlist, setting.order, 1, 1000, '', BID, '', dataName)
  }

  let _dataresource = setting.dataresource
  let _customScript = setting.customScript
@@ -551,7 +700,7 @@

  return {
    uuid: uuid,
    name: dataName,
    dataName: dataName,
    $name: setting.$name,
    columns: columns,
    par_tablename: '',
@@ -568,6 +717,39 @@
 * @description 生成sPC_Get_structured_data请求参数
 */
export function getStructuredParams (params, config, BID) {
  if (window.backend && params[0].exps) {
    let param = {
      $backend: true,
      $type: 's_Get_structured_data',
      data: params.map(item => {
        let cell = {...item}

        delete cell.dataName
        delete cell.luser

        return cell
      })
    }

    if (config.cacheUseful === 'true') {
      param.time_limit = config.cacheTime

      if (config.timeUnit === 'day') {
        param.time_limit = param.time_limit * 1440
      } else if (config.timeUnit === 'hour') {
        param.time_limit = param.time_limit * 60
      }

      if (params.findIndex(item => item.luser) > -1) {
        param.data_md5 = md5(window.GLOB.appkey + params[0].id + sessionStorage.getItem('UserID'))
      } else {
        param.data_md5 = md5(window.GLOB.appkey + params[0].id)
      }
    }

    return param
  }

  let LText_field = []
  let diffUser = false

@@ -602,14 +784,14 @@

    // 测试系统打印查询语句
    if (window.GLOB.debugger === true) {
      _script && console.info(`${item.$name ? `/*${item.$name} 自定义脚本（同步查询）*/\n` : ''}${_sql ? '' : '/*不执行默认sql*/\n'}${_script}`)
      _sql && console.info(`${item.$name ? `/*${item.$name} 数据源（同步查询）*/\n` : ''}` + _sql)
      _script && window.mkInfo(`${item.$name ? `/*${item.$name} 自定义脚本（同步查询）*/\n` : ''}${_sql ? '' : '/*不执行默认sql*/\n'}${_script}`)
      _sql && window.mkInfo(`${item.$name ? `/*${item.$name} 数据源（同步查询）*/\n` : ''}` + _sql)
    }

    item.columns.forEach(cell => {
      LText_field.push(`Select '${item.name}' as tablename,'${cell.field}' as fieldname,'${cell.datatype}' as field_type`)
      LText_field.push(`Select '${item.dataName}' as tablename,'${cell.field}' as fieldname,'${cell.datatype}' as field_type`)
    })
    return `Select '${item.name}' as tablename,'${window.btoa(window.encodeURIComponent(_sql))}' as LText,'${window.btoa(window.encodeURIComponent(_script))}' as Lcustomize,'${item.type}' as table_type,'${item.primaryKey}' as primary_key,'${item.par_tablename}' as par_tablename,'${item.foreign_key}' as foreign_key,'${index}' as Sort`
    return `Select '${item.dataName}' as tablename,'${window.btoa(window.encodeURIComponent(_sql))}' as LText,'${window.btoa(window.encodeURIComponent(_script))}' as Lcustomize,'${item.type}' as table_type,'${item.primaryKey}' as primary_key,'${item.par_tablename}' as par_tablename,'${item.foreign_key}' as foreign_key,'${index}' as Sort`
  })

  let param = {