2024-08-25

king

2024-08-25 326aa6b3effaccc71cfe0775d47b0f29eb3695a6

 src/utils/utils-datamanage.js

@@ -1,16 +1,13 @@
import md5 from 'md5'
import moment from 'moment'
import { notification, Modal } from 'antd'

import MKEmitter from '@/utils/events.js'
import Utils from './utils.js'

export default class DataUtils {
  /**
   * @description 数据源名称，用于统一查询
   * @param {Object}   setting      数据源设置
   * @param {Array}    search       搜索条件
   * @param {String}   orderBy      排序方式
   * @param {Number}   pageIndex    页码
   * @param {Number}   pageSize     每页数量
   * @param {String}   BID          上级ID
   * @description 数据源统一查询
   */
  static getQueryDataParams (setting, search = [], orderBy = '', pageIndex = 1, pageSize = 10, BID, id, year) {
    let param = null
@@ -49,6 +46,10 @@
      param.PageSize = pageSize
    } else if (setting.$re_year) {
      param.mk_year = year
    }

    if (setting.hasExtend) {
      param.mk_time = setting.extendTime
    }

    if (setting.interType === 'inner') {
@@ -102,7 +103,7 @@
    let param = {
      func: 'sPC_Get_TableData',
      obj_name: 'data',
      exec_type: 'y',
      exec_type: window.GLOB.execType || 'y',
      arr_field: setting.arr_field,
      default_sql: setting.execute ? 'true' : 'false'
    }
@@ -141,20 +142,24 @@
      { 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') || ''}'`},
      { reg: /@SessionUid@/ig, value: `'${localStorage.getItem('SessionUid') || ''}'`},
      { reg: /@UserID@/ig, value: `'${sessionStorage.getItem('UserID') || ''}'`},
      { reg: /@Appkey@/ig, value: `'${window.GLOB.appkey || ''}'`},
      { reg: /@lang@/ig, value: `'${sessionStorage.getItem('lang')}'`},
      { reg: /@typename@/ig, value: `'admin'`},
    )

    if (setting.hasExtend) {
      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 => {
@@ -275,18 +280,84 @@

    // 测试系统打印查询语句
    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) {
      param.menuname = setting.$name
    }

    param.custom_script = Utils.formatOptions(_customScript)
    param.LText = Utils.formatOptions(LText)
    param.DateCount = Utils.formatOptions(DateCount)
    // if (window.backend && window.GLOB.CacheData.has('sql_' + setting.uuid)) {
    //   let item = window.GLOB.CacheData.get('sql_' + setting.uuid)
      
    //   let values = {
    //     userid: sessionStorage.getItem('UserID') || '',
    //     time_id: Utils.getguid(),
    //     username: userName,
    //     fullname: fullName,
    //     roleid: RoleID,
    //     mk_departmentcode: departmentcode,
    //     mk_organization: organization,
    //     mk_user_type: mk_user_type,
    //     mk_nation: nation,
    //     mk_province: province,
    //     mk_city: city,
    //     mk_district: district,
    //     mk_address: address,
    //     orderby: orderBy,
    //     pagesize: setting.laypage ? pageSize : '9999',
    //     pageindex: pageIndex,
    //     id: id || '',
    //     bid: BID || '',
    //     loginuid: sessionStorage.getItem('LoginUID') || '',
    //     sessionuid: localStorage.getItem('SessionUid') || '',
    //     appkey: window.GLOB.appkey || '',
    //     lang: sessionStorage.getItem('lang'),
    //     typename: 'admin',
    //     datam: sessionStorage.getItem('dataM') === 'true' ? 'Y' : '',
    //     datam_begin: sessionStorage.getItem('dataM') === 'true' ? '/*' : '',
    //     datam_end: sessionStorage.getItem('dataM') === 'true' ? '*/' : '',
    //   }

    //   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.forEach(key => {
    //     values[key] = item.urlparam[key]
    //   })

    //   let Ltext = item.LText
    //   let DateCount = item.DateCount
    //   let customScript = item.customScript
  
    //   item.reps.forEach(n => {
    //     let key = n.toLowerCase()
    //     if (values.hasOwnProperty(key)) {
    //       Ltext = Ltext.replace(new RegExp('@' + key + '@', 'ig'), values[key])
    //       DateCount = DateCount.replace(new RegExp('@' + key + '@', 'ig'), values[key])
    //       customScript = customScript.replace(new RegExp('@' + key + '@', 'ig'), values[key])
    //     }
    //   })

    //   if (search.length) {

    //   }
    // }

    param.custom_script = Utils.formatOptions(_customScript, param.exec_type)
    param.LText = Utils.formatOptions(LText, param.exec_type)
    param.DateCount = Utils.formatOptions(DateCount, param.exec_type)

    if (setting.sub_field) {
      param.sub_name = setting.subdata
@@ -295,9 +366,9 @@
      param.sub_field = setting.sub_field
    }

    // exec_type: 'y' 解码字段：LText、LText1、LText2、custom_script、DateCount
    // exec_type 解码字段：LText、LText1、LText2、custom_script、DateCount

    param.timestamp = moment().format('YYYY-MM-DD HH:mm:ss')
    param.timestamp = moment().format('YYYY-MM-DD HH:mm:ss.SSS')
    param.secretkey = Utils.encrypt('', param.timestamp)

    param.username = userName
@@ -318,6 +389,10 @@
      param.s_version_up = 'true'
    }

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

    return param
  }

@@ -328,7 +403,7 @@
    let param = {
      func: 'sPC_Get_TableData',
      obj_name: 'data',
      exec_type: 'y',
      exec_type: window.GLOB.execType || 'y',
      arr_field: statFields.map(col => col.field).join(','),
      default_sql: setting.execute ? 'true' : 'false'
    }
@@ -366,15 +441,16 @@
      { 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') || ''}'`},
      { reg: /@SessionUid@/ig, value: `'${localStorage.getItem('SessionUid') || ''}'`},
      { reg: /@UserID@/ig, value: `'${sessionStorage.getItem('UserID') || ''}'`},
      { reg: /@Appkey@/ig, value: `'${window.GLOB.appkey || ''}'`},
      { reg: /@lang@/ig, value: `'${sessionStorage.getItem('lang')}'`},
      { reg: /@typename@/ig, value: `'admin'`},
    )

@@ -409,16 +485,16 @@

    // 测试系统打印查询语句
    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) {
      param.menuname = setting.$name
    }
    
    param.custom_script = Utils.formatOptions(_customScript)
    param.LText = Utils.formatOptions(LText)
    param.custom_script = Utils.formatOptions(_customScript, param.exec_type)
    param.LText = Utils.formatOptions(LText, param.exec_type)
    param.DateCount = ''

    param.timestamp = moment().format('YYYY-MM-DD HH:mm:ss')
@@ -441,6 +517,46 @@
    }

    return param
  }

  /**
   * @description 数据获取成功
   */
  static querySuccess (result) {
    if (!result.message) return

    if (result.ErrCode === 'Y') {
      Modal.success({
        title: result.message
      })
    } else if (result.ErrCode === 'S') {
      notification.success({
        top: 92,
        message: result.message,
        duration: 2
      })
    }
  }

  /**
   * @description 数据获取失败
   */
  static queryFail (result) {
    if (!result.message && result.ErrCode !== 'version_up') return
    
    if (result.ErrCode === 'N') {
      Modal.error({
        title: result.message,
      })
    } else if (result.ErrCode === 'version_up') {
      MKEmitter.emit('reloadTabs')
    } else if (result.ErrCode !== '-2') {
      notification.error({
        top: 92,
        message: result.message,
        duration: 10
      })
    }
  }
}

@@ -520,7 +636,6 @@

/**
 * @description 生成sPC_Get_structured_data请求参数
 * 1、把大接口sPC_Get_structured_data的ltext拆成三份，第一段：@LText1，第二段@LText，第三段@LText2
 */
export function getStructuredParams (params, config, BID) {
  let LText_field = []
@@ -535,6 +650,7 @@
    { reg: /@SessionUid@/ig, value: `'${localStorage.getItem('SessionUid') || ''}'`},
    { reg: /@UserID@/ig, value: `'${sessionStorage.getItem('UserID') || ''}'`},
    { reg: /@Appkey@/ig, value: `'${window.GLOB.appkey || ''}'`},
    { reg: /@lang@/ig, value: `'${sessionStorage.getItem('lang')}'`},
    { reg: /@typename@/ig, value: `'admin'`},
  ]

@@ -556,8 +672,8 @@

    // 测试系统打印查询语句
    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 => {
@@ -568,23 +684,16 @@

  let param = {
    func: 'sPC_Get_structured_data',
    LText: _LText.join(' union all '),
    LText_field: LText_field.join(' union all '),
    BID: BID,
    username: sessionStorage.getItem('User_Name') || '',
    fullName: sessionStorage.getItem('Full_Name') || ''
  }

  if (config.MenuName) {
    param.menuname = config.MenuName
  }
  param.menuname = config.MenuName || config.$menuname || ''

  let { LText, LText1, LText2 } = Utils.sPCInUpDeFormatOptions(param.LText)

  param.LText1 = LText1
  param.LText = LText
  param.LText2 = LText2
  param.LText_field = Utils.formatOptions(param.LText_field)
  param.exec_type = window.GLOB.execType || 'y'
  param.LText = Utils.formatOptions(_LText.join(' union all '), param.exec_type)
  param.custom_script = Utils.formatOptions(LText_field.join(' union all '), param.exec_type)

  if (config.cacheUseful === 'true') {
    param.time_type = config.timeUnit
@@ -596,7 +705,7 @@
  }

  param.timestamp = moment().format('YYYY-MM-DD HH:mm:ss')
  param.secretkey = Utils.encrypt(param.LText, param.timestamp)
  param.secretkey = Utils.encrypt('', param.timestamp)

  return param
}