| | |
| | | import axios from 'axios' |
| | | import qs from 'qs' |
| | | import { notification } from 'antd' |
| | | import { notification, Modal } from 'antd' |
| | | import md5 from 'md5' |
| | | import CryptoJS from 'crypto-js' |
| | | import jsSHA from 'jssha' |
| | | import moment from 'moment' |
| | | |
| | | import Utils from '@/utils/utils.js' |
| | | import MKEmitter from '@/utils/events.js' |
| | | import CacheUtils from './cacheutils' |
| | | import options from '@/store/options.js' |
| | | |
| | | window.GLOB.IndexDB = null |
| | | window.GLOB.OuterToken = {} |
| | | window.GLOB.$error = false |
| | | |
| | | let service = window.GLOB.service ? '-' + window.GLOB.service.replace('/', '') : '' |
| | | let db = `mkdb${service}` |
| | | let lang = sessionStorage.getItem('lang') || 'zh-CN' |
| | | lang = lang !== 'zh-CN' ? lang : '' |
| | | let db = `mkdb${service + lang}` |
| | | |
| | | if (window.indexedDB) { |
| | | CacheUtils.openIndexDB(db) |
| | |
| | | axios.defaults.headers.post['Content-Type'] = 'application/x-www-form-urlencoded;charset=UTF-8' |
| | | axios.defaults.withCredentials = false |
| | | |
| | | // axios.interceptors.request.use((config) => { |
| | | // return config |
| | | // }, (error) => { |
| | | // return Promise.reject(error) |
| | | // }) |
| | | |
| | | const setCurrentUrl = (res) => { |
| | | if (!!(window.history && window.history.pushState)) { |
| | | sessionStorage.clear() |
| | | sessionStorage.setItem('loginError', JSON.stringify({url: res.config ? res.config.url : '', request: res.config ? res.config.data : '', response: JSON.stringify(res.data)})) |
| | | window.history.replaceState(null, null, window.location.href.split('#')[0] + '#/login') |
| | | window.location.reload() |
| | | } |
| | | } |
| | | |
| | | axios.interceptors.response.use((response) => { |
| | | if (response.data.ErrCode === 'LoginError') { |
| | | if (window.debugger === true) { |
| | | response.data.ErrCode = 'E' |
| | | return Promise.resolve(response.data) |
| | | } else if (window.GLOB.developing) { |
| | | if (window.GLOB.developing) { |
| | | sessionStorage.setItem('devError', 'true') |
| | | response.data.ErrCode = 'E' |
| | | return Promise.resolve(response.data) |
| | | } else if (!sessionStorage.getItem('loginError')) { |
| | | setCurrentUrl(response) |
| | | } else if (response.config.url.indexOf('https://sso.mk9h.cn/webapi/dostars') > -1) { |
| | | return Promise.reject(response.data) |
| | | } else if (response.config.url.indexOf('https://epc.mk9h.cn/webapi/dostars') > -1) { |
| | | return Promise.reject(response.data) |
| | | } |
| | | |
| | | if (!window.GLOB.$error) { |
| | | window.GLOB.$error = true |
| | | |
| | | Modal.destroyAll() |
| | | Modal.error({ |
| | | title: response.data.message, |
| | | okText: '知道了', |
| | | onOk: () => { |
| | | window.GLOB.$error = false |
| | | if (!/#\/login/.test(window.location.href)) { |
| | | sessionStorage.clear() |
| | | if (!!(window.history && window.history.pushState)) { |
| | | window.history.replaceState(null, null, window.location.href.split('#')[0] + '#/login') |
| | | window.location.reload() |
| | | } |
| | | } |
| | | } |
| | | }) |
| | | } |
| | | |
| | | return Promise.reject(response.data) |
| | | } else { |
| | | if (response.data.ErrCode === 'E') { |
| | | if (/死锁|尚未从池中获取连接/.test(response.data.message)) { |
| | | response.data.message = (window.GLOB.dict['server_busy'] || '服务器繁忙,请稍后重试!') + (/死锁/.test(response.data.message) ? '01' : '02') |
| | | response.data.ErrMesg = response.data.message |
| | | } else if (/无法打开登录所请求的数据库|在与\s*SQL\s+Server\s*建立连接时出现/.test(response.data.message)) { |
| | | response.data.message = '服务器链接不可用,请关闭浏览器重新打开!' |
| | | response.data.ErrMesg = response.data.message |
| | | } |
| | | } |
| | | if (response.config.requestId) { |
| | | response.data.$requestId = response.config.requestId |
| | | } |
| | | return Promise.resolve(response.data) |
| | | } |
| | | }, (error) => { |
| | | let response = error.response |
| | | let response = error.response || '' |
| | | |
| | | if (response) { |
| | | if (!response.data || !response.data.errors) { // 过滤旷视报错信息 |
| | | notification.error({ |
| | | className: 'notification-custom-error', |
| | | bottom: 0, |
| | | message: '状态码-' + response.status + ',请联系管理员', |
| | | placement: 'bottomRight', |
| | | duration: 15 |
| | | }) |
| | | if (!response) { |
| | | notification.error({ |
| | | className: 'notification-custom-error', |
| | | bottom: 0, |
| | | message: error.message.includes('Network Error') && sessionStorage.getItem('lang') === 'zh-CN' ? '网络连接失败!' : error.message, |
| | | placement: 'bottomRight', |
| | | duration: 15 |
| | | }) |
| | | } else if (response && response.status) { |
| | | notification.error({ |
| | | className: 'notification-custom-error', |
| | | bottom: 0, |
| | | message: '状态码-' + response.status + ',请联系管理员', |
| | | placement: 'bottomRight', |
| | | duration: 15 |
| | | }) |
| | | if ([500, 504].includes(response.status) && error.config && error.config.url && error.config.data) { |
| | | window.mkInfo(error.config.url) |
| | | window.mkInfo(error.config.data) |
| | | if (window.GLOB.errorLog && !sessionStorage.getItem('local_error')) { |
| | | let urlReg = new RegExp('^(' + window.GLOB.baseurl + '|/)webapi/(exstars|dostars)', 'ig') |
| | | if (urlReg.test(error.config.url) && !/s_special_error_note_log/.test(error.config.url)) { |
| | | let res = null |
| | | try { |
| | | let data = JSON.parse(error.config.data) |
| | | if (!data.rduri) { |
| | | res = { |
| | | api_url: error.config.url, |
| | | error_code: response.status, |
| | | error_time: moment().format('YYYY-MM-DD HH:mm:ss'), |
| | | api_param: error.config.data |
| | | } |
| | | } |
| | | } catch (e) { |
| | | res = null |
| | | } |
| | | if (res) { |
| | | sessionStorage.setItem('local_error', JSON.stringify(res)) |
| | | } |
| | | } |
| | | } |
| | | } |
| | | return Promise.reject(response) |
| | | } else { |
| | | return Promise.reject() |
| | | } |
| | | |
| | | return Promise.reject(response) |
| | | }) |
| | | |
| | | class Api { |
| | |
| | | |
| | | /** |
| | | * @description 使用dostar接口,跳过验证 |
| | | * @param {Object} param 查询及提交参数 |
| | | */ |
| | | dostarInterface (param) { |
| | | param.userid = param.userid || '' |
| | |
| | | } |
| | | |
| | | /** |
| | | * @description 微信业务请求 |
| | | * @description 微信业务请求 原接口 'wxpay/getaccesstoken' |
| | | */ |
| | | wxAccessToken (domain = '') { |
| | | let _url = window.GLOB.baseurl + 'wxpay/getaccesstoken' |
| | | // wxAccessToken (appId, domain = '') { |
| | | // let _url = domain || window.GLOB.baseurl |
| | | |
| | | if (domain) { |
| | | _url = domain + 'wxpay/getaccesstoken' |
| | | } |
| | | |
| | | return new Promise(resolve => { |
| | | if (window.GLOB.accessToken.domain === domain && window.GLOB.accessToken.accessTime && (parseInt(new Date().getTime() / 1000) - window.GLOB.accessToken.accessTime < 30)) { |
| | | resolve(window.GLOB.accessToken) |
| | | } else { |
| | | window.GLOB.accessToken = {domain} |
| | | axios({ |
| | | url: _url, |
| | | method: 'get' |
| | | }).then(res => { |
| | | if (res.oa_access_token || res.mini_access_token) { |
| | | window.GLOB.accessToken.accessTime = parseInt(new Date().getTime() / 1000) |
| | | window.GLOB.accessToken.oa_access_token = res.oa_access_token |
| | | window.GLOB.accessToken.mini_access_token = res.mini_access_token |
| | | } |
| | | resolve(res) |
| | | }) |
| | | } |
| | | }) |
| | | } |
| | | // return axios({ |
| | | // url: _url + 'wechat/getaccesstoken', |
| | | // method: 'post', |
| | | // data: JSON.stringify({app_id: appId}) |
| | | // }) |
| | | // } |
| | | |
| | | /** |
| | | * @description 微信业务请求 |
| | | * @description 快递查询 |
| | | */ |
| | | wxNginxRequest (url, method, param) { |
| | | let _url = url |
| | | |
| | | if (!/^http/.test(url)) { |
| | | _url = window.GLOB.location + '/' + url |
| | | if (process.env.NODE_ENV === 'production') { |
| | | _url = document.location.origin + '/' + url |
| | | } |
| | | if (/^http:\/\/(qingqiumarket.cn|cloud.mk9h.cn|sso.mk9h.cn)/.test(_url)) { |
| | | _url = window.GLOB.location + ':8080/' + url |
| | | if (process.env.NODE_ENV === 'production') { |
| | | _url = document.location.origin + ':8080/' + url |
| | | } |
| | | } else if (/^https:\/\/(qingqiumarket.cn|cloud.mk9h.cn|sso.mk9h.cn)/.test(_url)) { |
| | | _url = window.GLOB.location + ':8443/' + url |
| | | if (process.env.NODE_ENV === 'production') { |
| | | _url = document.location.origin + ':8443/' + url |
| | | } |
| | | } |
| | | } |
| | | |
| | | if (param) { |
| | | return axios({ |
| | | url: _url, |
| | | method, |
| | | data: param |
| | | }) |
| | | } |
| | | |
| | | expressRequest (url) { |
| | | return axios({ |
| | | url: _url, |
| | | method |
| | | url: window.GLOB.location + '/' + url, |
| | | method: 'get' |
| | | }) |
| | | } |
| | | |
| | | /** |
| | | * @description 直接请求 |
| | | */ |
| | | directRequest (params) { |
| | | directRequest (params, script, position) { |
| | | if (script) { |
| | | try { |
| | | // eslint-disable-next-line |
| | | let func = new Function('axios', 'Api', 'param', 'position', 'systemType', 'notification', script) |
| | | let promise = func(axios, this, params, position, window.GLOB.systemType, notification) |
| | | |
| | | if (promise instanceof Promise) { |
| | | return promise |
| | | } |
| | | } catch (e) { |
| | | console.warn(e) |
| | | } |
| | | |
| | | return Promise.resolve({ |
| | | status: false, |
| | | message: '自定义脚本执行错误', |
| | | ErrCode: 'E' |
| | | }) |
| | | } |
| | | |
| | | return axios(params) |
| | | } |
| | | |
| | |
| | | * @description 游客登录 |
| | | */ |
| | | getTouristMsg (binding_type, appid, openid, memberid, scanId) { |
| | | let _SessionUid = localStorage.getItem('SessionUid') |
| | | |
| | | if (!_SessionUid) { // 手动清除SessionUid时,实时生成 |
| | | _SessionUid = Utils.getuuid() |
| | | localStorage.setItem('SessionUid', _SessionUid) |
| | | } |
| | | let _SessionUid = localStorage.getItem('SessionUid') || '' |
| | | |
| | | let param = { |
| | | func: 's_visitor_login', |
| | |
| | | } else { |
| | | param.linkurl = window.GLOB.linkurl |
| | | } |
| | | } else if (binding_type === 'cloud') { // 登录云端 |
| | | delete param.rduri |
| | | url = window.atob('aHR0cHM6Ly9jbG91$mkZC5tazloLmNu'.replace('$mk', '')) + '/webapi/dologon/s_visitor_login' |
| | | } |
| | | |
| | | param.LText = md5(window.btoa(_SessionUid + param.timestamp + (param.linkurl || ''))) |
| | |
| | | Password: '', |
| | | check_code: checkcode, |
| | | way_no: 'sms_vcode', |
| | | systemType: options.sysType, |
| | | systemType: window.GLOB.sysType, |
| | | login_city: sessionStorage.getItem('city') || '', |
| | | login_id_address: sessionStorage.getItem('ipAddress') || '', |
| | | kei_id: window.btoa(window.encodeURIComponent(window.GLOB.host)), |
| | | device_id: localStorage.getItem('SessionUid'), |
| | | appkey: window.GLOB.appkey || '' |
| | | appkey: window.GLOB.appkey || '', |
| | | lang: sessionStorage.getItem('lang') || '' |
| | | } |
| | | |
| | | let url = '/webapi/dologon' |
| | | if (isCloud) { |
| | | param.debug = 'Y' |
| | | if (options.cloudServiceApi) { |
| | | param.rduri = options.cloudServiceApi.replace(/\/webapi(.*)/, '/webapi/dologon') |
| | | if (window.GLOB.cloudServiceApi) { |
| | | param.rduri = window.GLOB.cloudServiceApi.replace(/\/webapi(.*)/, '/webapi/dologon') |
| | | } |
| | | } else if (window.GLOB.mainSystemApi) { |
| | | if (options.sysType !== 'cloud' && window.GLOB.systemType !== 'production') { |
| | | if (window.GLOB.sysType !== 'cloud' && window.GLOB.systemType !== 'production') { |
| | | param.linkurl = window.GLOB.linkurl |
| | | } |
| | | param.rduri = window.GLOB.mainSystemApi.replace(/\/webapi(.*)/, '/webapi/dologon') |
| | |
| | | let param = { |
| | | // func: 'webapi_login', |
| | | UserName: username, |
| | | systemType: options.sysType, |
| | | systemType: window.GLOB.sysType, |
| | | Type: 'S', |
| | | login_city: sessionStorage.getItem('city') || '', |
| | | login_id_address: sessionStorage.getItem('ipAddress') || '', |
| | | kei_id: window.btoa(window.encodeURIComponent(window.GLOB.host)), |
| | | device_id: localStorage.getItem('SessionUid'), |
| | | timestamp: moment().add(shim, 'seconds').format('YYYY-MM-DD HH:mm:ss'), |
| | | appkey: window.GLOB.appkey || '' |
| | | appkey: window.GLOB.appkey || '', |
| | | lang: sessionStorage.getItem('lang') || '' |
| | | } |
| | | |
| | | // Type: 'S' 时 |
| | |
| | | |
| | | if (isCloud) { |
| | | param.debug = 'Y' |
| | | if (options.cloudServiceApi) { |
| | | param.rduri = options.cloudServiceApi.replace(/\/webapi(.*)/, '/webapi/dologon') |
| | | if (window.GLOB.cloudServiceApi) { |
| | | param.rduri = window.GLOB.cloudServiceApi.replace(/\/webapi(.*)/, '/webapi/dologon') |
| | | } |
| | | } else if (window.GLOB.mainSystemApi) { |
| | | if (options.sysType !== 'cloud' && window.GLOB.systemType !== 'production') { |
| | | if (window.GLOB.sysType !== 'cloud' && window.GLOB.systemType !== 'production') { |
| | | param.linkurl = window.GLOB.linkurl |
| | | } |
| | | param.rduri = window.GLOB.mainSystemApi.replace(/\/webapi(.*)/, '/webapi/dologon') |
| | |
| | | } |
| | | |
| | | delCacheConfig (type = '') { |
| | | let date = moment().subtract(7, 'days').format('YYYY-MM-DD') |
| | | let date = moment().subtract(7, 'days').format('YYYY-MM-DD HH:mm:ss') |
| | | CacheUtils.delIndexDBCacheConfig(date, type) |
| | | } |
| | | |
| | | writeCacheConfig (menuid, data) { |
| | | writeCacheConfig (menuid, data, BID = '', id = '') { |
| | | if (!menuid) return |
| | | let date = moment().format('YYYY-MM-DD') |
| | | let date = moment().format('YYYY-MM-DD HH:mm:ss') |
| | | let _data = data ? JSON.stringify(data) : '' |
| | | let userid = sessionStorage.getItem('UserID') || '' |
| | | |
| | | CacheUtils.writeCacheInIndexDB({menuid, CreateDate: date, LongParam: _data}) |
| | | CacheUtils.writeCacheInIndexDB({menuid: md5(menuid + userid + BID + id), BID: BID, id: id, CreateDate: date, LongParam: _data}) |
| | | } |
| | | |
| | | getLCacheConfig (menuid) { |
| | | getLCacheConfig (menuid, minutes, BID = '', id = '') { |
| | | return new Promise((resolve, reject) => { |
| | | if (window.GLOB.IndexDB) { |
| | | CacheUtils.getIndexDBCacheConfig(menuid).then(res => { |
| | | if (res && res.LongParam) { |
| | | let _data = JSON.parse(res.LongParam) |
| | | if (_data.length === 0) { |
| | | resolve() |
| | | } else { |
| | | resolve(_data) |
| | | } |
| | | } else { |
| | | resolve() |
| | | } |
| | | }) |
| | | } else { |
| | | resolve() |
| | | } |
| | | let limit = minutes ? moment().subtract(minutes, 'minutes').format('YYYY-MM-DD HH:mm:ss') : '' |
| | | let userid = sessionStorage.getItem('UserID') || '' |
| | | |
| | | CacheUtils.getIndexDBCacheConfig(md5(menuid + userid + BID + id)).then(res => { |
| | | if (res && res.LongParam) { |
| | | resolve({data: JSON.parse(res.LongParam), valid: !limit || res.CreateDate > limit}) |
| | | } else { |
| | | resolve({data: null, valid: false}) |
| | | } |
| | | }) |
| | | }) |
| | | } |
| | | |
| | |
| | | let param = { |
| | | func: 's_get_app_version', |
| | | modifydate: msg.createDate |
| | | } |
| | | |
| | | if (window.GLOB.initVersion && sessionStorage.getItem('visitorUserID')) { |
| | | param.userid = sessionStorage.getItem('visitorUserID') |
| | | param.LoginUID = sessionStorage.getItem('visitorLoginUID') |
| | | } |
| | | |
| | | param.TypeCharOne = '' |
| | |
| | | |
| | | this.getSystemConfig(param).then(res => { |
| | | if (!res.status) { |
| | | reject() |
| | | reject(res.message) |
| | | return |
| | | } |
| | | |
| | |
| | | if (list.length > 0) { |
| | | let clear = false |
| | | let _appkey = window.GLOB.appkey.substr(-10) |
| | | let reg = new RegExp(_appkey + '$', 'ig') |
| | | let reg = new RegExp(_appkey + '$', 'i') |
| | | let reHome = list.includes('home_page_id') |
| | | |
| | | list.forEach(mid => { |
| | | if (reg.test(mid)) { |
| | |
| | | list = '' |
| | | } |
| | | CacheUtils.delIndexDBConfig(list) |
| | | this.delCacheConfig('all') |
| | | |
| | | if (reHome && reload !== 'home_page_id') { |
| | | MKEmitter.emit('reloadMenuView', 'home_page_id') |
| | | } |
| | | } |
| | | |
| | | CacheUtils.updateIndexDBversion({version: res.app_version || '1.00', createDate: curTime}) |
| | | |
| | | resolve() |
| | | resolve(list) |
| | | }) |
| | | }, () => { |
| | | reject() |
| | |
| | | */ |
| | | getCloudConfig (param) { |
| | | param.lang = param.lang || sessionStorage.getItem('lang') || '' |
| | | param.appkey = window.GLOB.appkey || '' |
| | | param.appkey = param.appkey || window.GLOB.appkey || '' |
| | | param.SessionUid = localStorage.getItem('SessionUid') || '' |
| | | param.userid = sessionStorage.getItem('CloudUserID') || '' |
| | | param.LoginUID = sessionStorage.getItem('CloudLoginUID') || '' |
| | | param.userid = param.userid || sessionStorage.getItem('CloudUserID') || '' |
| | | param.LoginUID = param.LoginUID || sessionStorage.getItem('CloudLoginUID') || '' |
| | | |
| | | param = this.encryptParam(param) |
| | | |
| | | let url = options.cloudServiceApi ? options.cloudServiceApi : '/webapi/dostars' |
| | | let url = window.GLOB.cloudServiceApi ? window.GLOB.cloudServiceApi : '/webapi/dostars' |
| | | if (param.func) { |
| | | url = url + '/' + param.func |
| | | } |
| | |
| | | /** |
| | | * @description 获取或修改系统配置,增加appkey |
| | | */ |
| | | getSystemFuncs (time) { |
| | | let param = { |
| | | func: 's_get_func_base_sso', |
| | | update_date: time, |
| | | userid: sessionStorage.getItem('UserID') || '', |
| | | lang: sessionStorage.getItem('lang') || '', |
| | | SessionUid: localStorage.getItem('SessionUid') || '', |
| | | LoginUID: sessionStorage.getItem('LoginUID') || '', |
| | | appkey: window.GLOB.appkey |
| | | } |
| | | // getSystemFuncs (time) { |
| | | // let param = { |
| | | // func: 's_get_func_base_sso', |
| | | // update_date: time, |
| | | // userid: sessionStorage.getItem('UserID') || '', |
| | | // lang: sessionStorage.getItem('lang') || '', |
| | | // SessionUid: localStorage.getItem('SessionUid') || '', |
| | | // LoginUID: sessionStorage.getItem('LoginUID') || '', |
| | | // appkey: window.GLOB.appkey |
| | | // } |
| | | |
| | | let url = window.GLOB.mainSystemApi || '/webapi/dostars' |
| | | param = this.encryptParam(param) |
| | | // let url = window.GLOB.mainSystemApi || '/webapi/dostars' |
| | | // param = this.encryptParam(param) |
| | | |
| | | return axios({ |
| | | url: `${url}/${param.func}`, |
| | | method: 'post', |
| | | data: JSON.stringify(param) |
| | | }) |
| | | } |
| | | // return axios({ |
| | | // url: `${url}/${param.func}`, |
| | | // method: 'post', |
| | | // data: JSON.stringify(param) |
| | | // }) |
| | | // } |
| | | |
| | | /** |
| | | * @description 获取或修改系统配置,增加appkey |
| | |
| | | param.appkey = param.appkey || window.GLOB.appkey |
| | | |
| | | let url = '/webapi/dostars' |
| | | if (sessionStorage.getItem('isEditState') === 'true' && options.cloudServiceApi) { // 编辑状态,且存在云端地址 |
| | | url = options.cloudServiceApi |
| | | param.userid = sessionStorage.getItem('CloudUserID') || '' |
| | | param.LoginUID = sessionStorage.getItem('CloudLoginUID') || '' |
| | | } else if (window.GLOB.mainSystemApi) { |
| | | if (window.GLOB.mainSystemApi) { |
| | | if (!window.GLOB.transfer) { |
| | | url = window.GLOB.mainSystemApi |
| | | } else { |
| | |
| | | param.lang = param.lang || sessionStorage.getItem('lang') || '' |
| | | param.SessionUid = localStorage.getItem('SessionUid') || '' |
| | | param.LoginUID = sessionStorage.getItem('LoginUID') || '' |
| | | param.appkey = window.GLOB.appkey || '' |
| | | param.appkey = param.appkey || window.GLOB.appkey || '' |
| | | |
| | | let url = '/webapi/dostars' |
| | | if (sessionStorage.getItem('isEditState') === 'true') { // 编辑状态,单点登录服务器为云端 |
| | | if (options.cloudServiceApi) { // 存在云端地址时,使用云端系统参数 |
| | | url = options.cloudServiceApi |
| | | param.userid = sessionStorage.getItem('CloudUserID') || '' |
| | | param.LoginUID = sessionStorage.getItem('CloudLoginUID') || '' |
| | | } |
| | | } else if (window.GLOB.mainSystemApi) { |
| | | if (window.GLOB.mainSystemApi) { |
| | | if (!window.GLOB.transfer) { |
| | | url = window.GLOB.mainSystemApi |
| | | } else { |
| | |
| | | if (window.GLOB.CacheMap.has(_param)) { |
| | | return Promise.resolve(window.GLOB.CacheMap.get(_param)) |
| | | } else { |
| | | return Promise.resolve({ErrCode: 'S', ErrMesg: '', LongParam: '', message: '', status: false}) |
| | | return Promise.resolve({ErrCode: 'S', LongParam: '', message: '', status: false}) |
| | | } |
| | | } |
| | | |
| | |
| | | param.sign = md5(values) |
| | | param.t = new Date().getTime(); |
| | | |
| | | ['arr_field', 'LText_field', 'custom_script', 'LText1', 'LText', 'LText2', 'DateCount'].forEach(key => { |
| | | ['arr_field', 'custom_script', 'LText', 'DateCount'].forEach(key => { |
| | | if (param[key]) { |
| | | let val = param[key] |
| | | delete param[key] |
| | |
| | | /** |
| | | * @description 获取系统配置,优先从缓存中取值,增加appkey |
| | | * @param {Object} param 请求参数 |
| | | * @param {Boolean} SSO 是否为单点登录地址 |
| | | * @param {Boolean} cache 是否使用缓存 |
| | | */ |
| | | getSystemCacheConfig (param, cache = true) { |
| | | param.userid = param.userid || sessionStorage.getItem('UserID') || '' |
| | |
| | | param.SessionUid = localStorage.getItem('SessionUid') || '' |
| | | param.LoginUID = param.LoginUID || sessionStorage.getItem('LoginUID') || '' |
| | | param.appkey = window.GLOB.appkey || '' |
| | | |
| | | if (param.$backend) { |
| | | delete param.$backend |
| | | |
| | | let id = '' |
| | | if (cache) { |
| | | id = param.data[0].id |
| | | |
| | | if (window.GLOB.CacheMap.has(id)) { |
| | | return Promise.resolve(window.GLOB.CacheMap.get(id)) |
| | | } |
| | | } |
| | | |
| | | param.username = sessionStorage.getItem('User_Name') || '' |
| | | param.fullname = sessionStorage.getItem('Full_Name') || '' |
| | | param.s_debug = window.GLOB.debugger ? 'Y' : '' |
| | | param.data_md5 = param.data_md5 || '' |
| | | param.time_limit = param.time_limit || 0 |
| | | |
| | | let url = '/webapi/exstars' |
| | | if (param.rduri) { |
| | | param.rduri = param.rduri.replace(/dostars/ig, 'exstars') |
| | | if (!window.GLOB.transfer) { |
| | | url = param.rduri |
| | | delete param.rduri |
| | | } |
| | | } |
| | | |
| | | if (param.$type) { |
| | | url += '/' + param.$type |
| | | } |
| | | |
| | | delete param.$type |
| | | |
| | | param = this.encryptParam(param) |
| | | |
| | | return new Promise((resolve) => { |
| | | axios({ |
| | | url: url, |
| | | method: 'post', |
| | | data: JSON.stringify(param) |
| | | }).then(res => { |
| | | if (res.mksqls) { |
| | | res.mksqls.forEach(n => { |
| | | n = n.replace(/(UNION ALL\s+)?SELECT obj_name='[\S\s]+sub_field=''\s+/ig, '') |
| | | if (!res.status && param.data[0] && param.data[0].menuname) { |
| | | window.mkInfo('%c' + param.data[0].menuname, 'color: #f5222d') |
| | | } |
| | | window.mkInfo(n) |
| | | }) |
| | | } |
| | | delete res.mksqls |
| | | if (res.ErrCode === 'version_error') { |
| | | res.ErrCode = '-2' |
| | | MKEmitter.emit('reloadTabs') |
| | | } |
| | | if (res.status && id) { |
| | | window.GLOB.CacheMap.set(id, res) |
| | | } |
| | | resolve(res) |
| | | }) |
| | | }) |
| | | } |
| | | |
| | | let url = '/webapi/dostars' |
| | | if (param.rduri && !window.GLOB.transfer) { |
| | |
| | | } |
| | | } |
| | | |
| | | visitOuterSystem (param, _resolve) { |
| | | visitOuterSystem (param, _resolve, _reject) { |
| | | let token = param.$token |
| | | delete param.$token |
| | | |
| | |
| | | token = JSON.parse(window.decodeURIComponent(window.atob(token))) |
| | | } catch (e) { |
| | | token = null |
| | | _resolve({status: false, ErrCode: 'E', message: '接口信息解析失败!', ErrMesg: 'token_error'}) |
| | | _resolve({status: false, ErrCode: 'token_error', message: '接口信息解析失败!'}) |
| | | } |
| | | |
| | | if (!token) return |
| | |
| | | param = this.encryptParam(param) |
| | | |
| | | axios({ |
| | | url: token.interface, |
| | | url: `${token.interface}${param.func ? '/' + param.func : ''}`, |
| | | method: 'post', |
| | | data: JSON.stringify(param) |
| | | }).then(res => { |
| | | _resolve(res) |
| | | }, () => { |
| | | _reject() |
| | | }) |
| | | } else { |
| | | let _param = { |
| | | UserName: token.username, |
| | | systemType: options.sysType, |
| | | systemType: window.GLOB.sysType, |
| | | login_city: sessionStorage.getItem('city') || '', |
| | | device_id: token.appkey || '', |
| | | timestamp: moment().format('YYYY-MM-DD HH:mm:ss'), |
| | |
| | | param = this.encryptParam(param) |
| | | |
| | | axios({ |
| | | url: token.interface, |
| | | url: `${token.interface}${param.func ? '/' + param.func : ''}`, |
| | | method: 'post', |
| | | data: JSON.stringify(param) |
| | | }).then(res => { |
| | | _resolve(res) |
| | | }, () => { |
| | | _reject() |
| | | }) |
| | | } else { |
| | | _resolve(result) |
| | | } |
| | | }, (e) => { |
| | | if (!e || !e.status) { |
| | | let msg = '网络连接不正常。' |
| | | |
| | | if (/^http:/.test(token.interface) && /https:/.test(window.location.protocol)) { |
| | | msg = '网络连接不正常,接口地址可能不支持https。' |
| | | } |
| | | _resolve({status: false, ErrCode: 'E', message: msg}) |
| | | } else { |
| | | _reject() |
| | | } |
| | | }) |
| | | } |
| | |
| | | * @description 获取业务通用接口 |
| | | * 访问 'https://sso.mk9h.cn/webapi/dostars'或云端时,传入userid、LoginUID |
| | | */ |
| | | genericInterface (param) { |
| | | genericInterface (param, script = '', position, requestId = '') { |
| | | param.userid = param.userid || sessionStorage.getItem('UserID') || '' |
| | | param.lang = param.lang || sessionStorage.getItem('lang') || '' |
| | | param.SessionUid = localStorage.getItem('SessionUid') || '' |
| | |
| | | param.appkey = window.GLOB.appkey || '' |
| | | |
| | | if (param.$token === '') { |
| | | return Promise.resolve({status: false, ErrCode: 'E', message: '接口地址尚未设置!', ErrMesg: 'token_error'}) |
| | | return Promise.resolve({status: false, ErrCode: 'token_error', message: '接口地址尚未设置!'}) |
| | | } else if (param.$token) { |
| | | return new Promise(resolve => this.visitOuterSystem(param, resolve)) |
| | | return new Promise((resolve, reject) => this.visitOuterSystem(param, resolve, reject)) |
| | | } |
| | | |
| | | if (['sPC_Get_TableData', 'sPC_Get_TableData_debug', 'sPC_TableData_InUpDe', 'sPC_TableData_InUpDe_debug', 'sPC_Get_structured_data'].includes(param.func)) { |
| | | if (sessionStorage.getItem('isEditState') === 'true') { |
| | | param.username = sessionStorage.getItem('CloudUserName') || '' |
| | | param.fullname = sessionStorage.getItem('CloudFullName') || '' |
| | | } else { |
| | | param.username = sessionStorage.getItem('User_Name') || '' |
| | | param.fullname = sessionStorage.getItem('Full_Name') || '' |
| | | } |
| | | if (['sPC_TableData_InUpDe', 'sPC_TableData_InUpDe_debug'].includes(param.func)) { |
| | | param.username = sessionStorage.getItem('User_Name') || '' |
| | | param.fullname = sessionStorage.getItem('Full_Name') || '' |
| | | } |
| | | |
| | | let login = false |
| | | let rduri = null |
| | | |
| | | if (param.rduri && /\s|\n/.test(param.rduri)) { |
| | | param.rduri = param.rduri.replace(/\s|\n/g, '') |
| | |
| | | } |
| | | } |
| | | |
| | | if (param.$login && !window.GLOB.transfer) { |
| | | login = true |
| | | rduri = param.rduri || '' |
| | | } |
| | | delete param.$login |
| | | if (script) { |
| | | try { |
| | | // eslint-disable-next-line |
| | | let func = new Function('axios', 'Api', 'param', 'position', 'systemType', 'notification', script) |
| | | let promise = func(axios, this, param, position, window.GLOB.systemType, notification) |
| | | |
| | | let url = '/webapi/dostars' |
| | | if (promise instanceof Promise) { |
| | | return promise |
| | | } |
| | | } catch (e) { |
| | | console.warn(e) |
| | | } |
| | | |
| | | if (param.rduri && !window.GLOB.transfer && /\/dostars/.test(param.rduri) && param.func !== 'webapi_ChangeUser') { |
| | | url = param.rduri |
| | | return Promise.resolve({ |
| | | status: false, |
| | | message: '自定义脚本执行错误', |
| | | ErrCode: 'E' |
| | | }) |
| | | } else if (param.$login) { |
| | | let rduri = param.rduri || '' |
| | | |
| | | delete param.$login |
| | | delete param.rduri |
| | | } |
| | | |
| | | param = this.encryptParam(param) |
| | | param = this.encryptParam(param) |
| | | |
| | | if (login) { |
| | | let time = +sessionStorage.getItem(rduri) |
| | | let c_time = Math.round(new Date().getTime() / 1000) |
| | | |
| | | if (time && c_time - time <= 60) { |
| | | if (time && c_time - time <= 1800) { |
| | | sessionStorage.setItem(rduri, c_time) |
| | | return axios({ |
| | | url: `${url}${param.func ? '/' + param.func : ''}`, |
| | | method: 'post', |
| | | data: JSON.stringify(param) |
| | | return new Promise((resolve, reject) => { |
| | | axios({ |
| | | url: `${rduri}${param.func ? '/' + param.func : ''}`, |
| | | method: 'post', |
| | | data: JSON.stringify(param) |
| | | }).then(result => { |
| | | if (result && result.ErrCode === 'LoginError') { |
| | | sessionStorage.removeItem(rduri) |
| | | } |
| | | resolve(result) |
| | | }, () => { |
| | | reject() |
| | | }) |
| | | }) |
| | | } |
| | | |
| | |
| | | if (res.status) { |
| | | sessionStorage.setItem(rduri, c_time) |
| | | axios({ |
| | | url: `${url}${param.func ? '/' + param.func : ''}`, |
| | | url: `${rduri}${param.func ? '/' + param.func : ''}`, |
| | | method: 'post', |
| | | data: JSON.stringify(param) |
| | | }).then(result => { |
| | | resolve(result) |
| | | }, () => { |
| | | reject() |
| | | }) |
| | | } else { |
| | | resolve(res) |
| | | } |
| | | }, (e) => { |
| | | if (!e || !e.status) { |
| | | let msg = '网络连接不正常。' |
| | | |
| | | if (/^http:/.test(rduri) && /https:/.test(window.location.protocol)) { |
| | | msg = '网络连接不正常,接口地址可能不支持https。' |
| | | } |
| | | resolve({status: false, ErrCode: 'E', message: msg}) |
| | | } else { |
| | | reject() |
| | | } |
| | | }) |
| | | }) |
| | | } else if (param.$backend) { |
| | | delete param.$backend |
| | | |
| | | let url = '/webapi/exstars' |
| | | if (param.rduri) { |
| | | param.rduri = param.rduri.replace(/dostars/ig, 'exstars') |
| | | if (!window.GLOB.transfer) { |
| | | url = param.rduri |
| | | delete param.rduri |
| | | } |
| | | } |
| | | |
| | | if (param.$type) { |
| | | url += '/' + param.$type |
| | | } |
| | | |
| | | delete param.$type |
| | | |
| | | param.username = sessionStorage.getItem('User_Name') || '' |
| | | param.fullname = sessionStorage.getItem('Full_Name') || '' |
| | | param.s_debug = window.GLOB.debugger ? 'Y' : '' |
| | | param.data_md5 = param.data_md5 || '' |
| | | param.time_limit = param.time_limit || 0 |
| | | |
| | | param.data.forEach(item => { |
| | | item.exps.forEach(cell => { |
| | | if (typeof(cell.value) === 'number') { |
| | | cell.value = cell.value + '' |
| | | } |
| | | }) |
| | | }) |
| | | |
| | | param = this.encryptParam(param) |
| | | |
| | | return new Promise((resolve) => { |
| | | axios({ |
| | | url: url, |
| | | method: 'post', |
| | | data: JSON.stringify(param), |
| | | requestId |
| | | }).then(res => { |
| | | if (res.mksqls) { |
| | | res.mksqls.forEach(n => { |
| | | n = n.replace(/(UNION ALL\s+)?SELECT obj_name='[\S\s]+sub_field=''\s+/ig, '') |
| | | if (!res.status && param.data[0] && param.data[0].menuname) { |
| | | window.mkInfo('%c' + param.data[0].menuname, 'color: #f5222d') |
| | | } |
| | | window.mkInfo(n) |
| | | }) |
| | | } |
| | | delete res.mksqls |
| | | if (!res.status) { |
| | | if (res.ErrCode === 'version_error') { |
| | | res.ErrCode = '-2' |
| | | MKEmitter.emit('reloadTabs') |
| | | } else if (res.message === 'permission deny') { |
| | | let isBtn = url.indexOf('s_TableData_InUpDe') > -1 |
| | | res.message = window.GLOB.dict['permission_deny'] || `无当前${isBtn ? '按钮' : '菜单'}的访问权限,请联系管理员!` |
| | | res.ErrMesg = res.message |
| | | } |
| | | } |
| | | resolve(res) |
| | | }) |
| | | }) |
| | | } else { |
| | | let url = '/webapi/dostars' |
| | | if (param.rduri && (!window.GLOB.transfer || /https:\/\/sso.mk9h.cn/.test(param.rduri)) && /\/dostars/.test(param.rduri) && param.func !== 'webapi_ChangeUser') { |
| | | url = param.rduri |
| | | delete param.rduri |
| | | } |
| | | |
| | | param = this.encryptParam(param) |
| | | |
| | | return axios({ |
| | | url: `${url}${param.func ? '/' + param.func : ''}`, |
| | | method: 'post', |
| | | data: JSON.stringify(param) |
| | | data: JSON.stringify(param), |
| | | requestId |
| | | }) |
| | | } |
| | | } |
| | | |
| | | /** |
| | | * @description 清空后端缓存 |
| | | */ |
| | | cacheInterface (param) { |
| | | param.appkey = window.GLOB.appkey || '' |
| | | param.userid = param.userid || sessionStorage.getItem('UserID') || '' |
| | | param.LoginUID = param.LoginUID || sessionStorage.getItem('LoginUID') || '' |
| | | |
| | | let url = '/webapi/excache' |
| | | if (param.rduri && !window.GLOB.transfer) { |
| | | url = param.rduri |
| | | delete param.rduri |
| | | } |
| | | |
| | | param = this.encryptParam(param) |
| | | |
| | | return axios({ |
| | | url: url, |
| | | method: 'post', |
| | | data: JSON.stringify(param), |
| | | }) |
| | | } |
| | | |
| | | /** |
| | |
| | | /** |
| | | * @description 大文件上传 |
| | | */ |
| | | getLargeFileUpload (param) { |
| | | return axios({ |
| | | url: '/webapi/doupload', |
| | | method: 'post', |
| | | headers: { 'Content-Type': 'multipart/form-data' }, |
| | | data: param |
| | | getFileUpload (param) { |
| | | param.append('shardingCnt', 1) |
| | | param.append('LoginUID', sessionStorage.getItem('LoginUID') || '') |
| | | param.append('UserID', sessionStorage.getItem('UserID') || '') |
| | | |
| | | return new Promise((resolve, reject) => { |
| | | axios({ |
| | | url: '/webapi/doupload', |
| | | method: 'post', |
| | | headers: { 'Content-Type': 'multipart/form-data' }, |
| | | data: param |
| | | }).then(res => { |
| | | if (res.status && res.urlPath) { |
| | | if (!/Content\/images/.test(res.urlPath)) { |
| | | let key = CryptoJS.enc.Utf8.parse('D1185ED7B32568C9') |
| | | let wordArray = CryptoJS.enc.Base64.parse(res.urlPath) |
| | | let decryptedWordArray = CryptoJS.AES.decrypt({ ciphertext: wordArray }, key, { mode: CryptoJS.mode.ECB, padding: CryptoJS.pad.Pkcs7 }) |
| | | res.urlPath = CryptoJS.enc.Utf8.stringify(decryptedWordArray) |
| | | } |
| | | if (!/^http/.test(res.urlPath)) { |
| | | res.urlPath = window.GLOB.baseurl + res.urlPath |
| | | } |
| | | } |
| | | resolve(res) |
| | | }) |
| | | }) |
| | | } |
| | | |
| | | /** |
| | | * @description 查询文件是否已上传 |
| | | */ |
| | | getFilePreUpload (param) { |
| | | return axios({ |
| | | url: '/webapi/dopreload', |
| | | method: 'post', |
| | | headers: { 'Content-Type': 'multipart/form-data' }, |
| | | data: param |
| | | }) |
| | | } |
| | | // getFilePreUpload (param) { |
| | | // return axios({ |
| | | // url: '/webapi/dopreload', |
| | | // method: 'post', |
| | | // headers: { 'Content-Type': 'multipart/form-data' }, |
| | | // data: param |
| | | // }) |
| | | // } |
| | | |
| | | /** |
| | | * @description oss文件上传 |
| | | */ |
| | | fileOssUpload (param) { |
| | | let _url = window.GLOB.location + '/file/oss/upload' |
| | | if (process.env.NODE_ENV === 'production') { |
| | | _url = document.location.origin + '/file/oss/upload' |
| | | } |
| | | if (/^http:\/\/(qingqiumarket.cn|cloud.mk9h.cn|sso.mk9h.cn)/.test(_url)) { |
| | | _url = window.GLOB.location + ':8080/file/oss/upload' |
| | | if (process.env.NODE_ENV === 'production') { |
| | | _url = document.location.origin + ':8080/file/oss/upload' |
| | | } |
| | | } else if (/^https:\/\/(qingqiumarket.cn|cloud.mk9h.cn|sso.mk9h.cn)/.test(_url)) { |
| | | _url = window.GLOB.location + ':8443/file/oss/upload' |
| | | if (process.env.NODE_ENV === 'production') { |
| | | _url = document.location.origin + ':8443/file/oss/upload' |
| | | } |
| | | } |
| | | |
| | | return axios({ |
| | | url: _url, |
| | | url: window.GLOB.location + '/file/oss/upload', |
| | | method: 'post', |
| | | headers: { 'Content-Type': 'multipart/form-data' }, |
| | | data: param |
| | |
| | | } |
| | | |
| | | /** |
| | | * @description 获取微信支付二维码 |
| | | * @description 获取微信支付二维码 原接口wxpay/wxNativePay |
| | | */ |
| | | getWxNativePay (param) { |
| | | let _url = window.GLOB.baseurl + 'wxpay/wxNativePay' |
| | | |
| | | return axios({ |
| | | url: _url, |
| | | url: window.GLOB.baseurl + 'wechat/native', |
| | | method: 'post', |
| | | data: qs.stringify(param) |
| | | data: JSON.stringify(param) |
| | | }) |
| | | } |
| | | |
| | | /** |
| | | * @description 微信支付退款 原接口wxpay/wxRefund |
| | | */ |
| | | setRefund (param) { |
| | | return axios({ |
| | | url: window.GLOB.baseurl + 'wechat/wxRefund', |
| | | method: 'post', |
| | | data: JSON.stringify(param) |
| | | }) |
| | | } |
| | | |
| | |
| | | data: qs.stringify(data) |
| | | }) |
| | | } |
| | | |
| | | /** |
| | | * @description sql检验 |
| | | */ |
| | | sDebug (sql, skip = false) { |
| | | let param = { |
| | | func: 's_debug_sql', |
| | | exec_type: window.GLOB.execType || 'y', |
| | | timestamp: moment().format('YYYY-MM-DD HH:mm:ss'), |
| | | userid: sessionStorage.getItem('UserID') || '', |
| | | lang: sessionStorage.getItem('lang') || '', |
| | | SessionUid: localStorage.getItem('SessionUid') || '', |
| | | LoginUID: sessionStorage.getItem('LoginUID') || '', |
| | | appkey: window.GLOB.appkey || '' |
| | | } |
| | | |
| | | sql = sql.replace(/@time_id@/ig, `'${Utils.getuuid()}'`) |
| | | sql = sql.replace(/@ID@/ig, `'${Utils.getuuid()}'`) |
| | | sql = sql.replace(/@BID@/ig, `'${Utils.getuuid()}'`) |
| | | sql = sql.replace(/@LoginUID@/ig, `'${sessionStorage.getItem('LoginUID')}'`) |
| | | sql = sql.replace(/@SessionUid@/ig, `'${localStorage.getItem('SessionUid')}'`) |
| | | sql = sql.replace(/@UserID@/ig, `'${sessionStorage.getItem('UserID')}'`) |
| | | sql = sql.replace(/@Appkey@/ig, `'${window.GLOB.appkey}'`) |
| | | sql = sql.replace(/@lang@/ig, `'${sessionStorage.getItem('lang')}'`) |
| | | // sql = sql.replace(/@datam@/ig, `''`) |
| | | |
| | | if (window.GLOB.externalDatabase !== null) { |
| | | sql = sql.replace(/@db@/ig, window.GLOB.externalDatabase) |
| | | } |
| | | |
| | | window.mkInfo(`/* sql 验证 */\n${sql.replace(/\n\s{6,20}/ig, '\n')}`) |
| | | |
| | | if (skip) return |
| | | |
| | | sql = sql.replace(/\n/ig, ' ') |
| | | |
| | | param.LText = Utils.formatOptions(sql, param.exec_type) |
| | | param.secretkey = Utils.encrypt('', param.timestamp) |
| | | |
| | | param = this.encryptParam(param) |
| | | |
| | | let url = '/webapi/dostars' |
| | | |
| | | let timer = setTimeout(() => { |
| | | let _param = { |
| | | func: 's_debug_sql_cancel', |
| | | userid: sessionStorage.getItem('UserID') || '', |
| | | lang: sessionStorage.getItem('lang') || '', |
| | | SessionUid: localStorage.getItem('SessionUid') || '', |
| | | LoginUID: sessionStorage.getItem('LoginUID') || '', |
| | | appkey: window.GLOB.appkey || '' |
| | | } |
| | | _param = this.encryptParam(_param) |
| | | axios({ |
| | | url: `${url}/s_debug_sql_cancel`, |
| | | method: 'post', |
| | | data: JSON.stringify(_param) |
| | | }) |
| | | }, 20000) |
| | | |
| | | return new Promise(resolve => { |
| | | axios({ |
| | | url: `${url}/s_debug_sql`, |
| | | method: 'post', |
| | | data: JSON.stringify(param) |
| | | }).then(res => { |
| | | clearTimeout(timer) |
| | | if (/Shared Memory Provider|会话处于终止状态|当前命令发生了严重错误/.test(res.message)) { |
| | | res.message = '验证失败,请检查SQL中是否存在死循环。' |
| | | } else if (res.message.indexOf('EXECUTE 后的事务计数指示 BEGIN 和 COMMIT 语句的数目不匹配。上一计数 = 1,当前计数 = 0') > -1) { |
| | | res.ErrCode = '-2' |
| | | } |
| | | resolve(res) |
| | | }, () => { |
| | | clearTimeout(timer) |
| | | resolve({status: false, ErrCode: 'E', message: '验证失败:1请检查SQL中是否存在死循环;2请检查网络连接是否正常。'}) |
| | | }) |
| | | }) |
| | | } |
| | | } |
| | | |
| | | export default new Api() |