| | |
| | | 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.WebSql = null |
| | | window.GLOB.IndexDB = null |
| | | const systemMenuKeys = `1581067625930haged11ieaivpavv77k,1581734956310scks442ul2d955g9tu5,1583991994144ndddg0bhh0is6shi0v1,1583979633842550imkchl4qt4qppsiv,1578900109100np8aqd0a77q3na46oas,16044812935562g807p3p12huk8kokmb, |
| | | 1585192949946f3et2ts8tn82krmumdf,15855615451212m12ip23vpcm79kloro,1587005717541lov40vg61q7l1rbveon,1590458676585agbbr63t6ihighg2i1g,1602315375262ikd33ii0nii34pt861o,1582771068837vsv54a089lgp45migbg, |
| | | 1582777675954ifu05upurs465omoth7,158294809668898cklbv6c5bou8e1fpu,1584676379094iktph45fb8imhg96bql,1584695125339vo5g7iqgfn01qmrd6s2,1584699661372vhmpp9dn9foo0eob722,15848421131551gg04ie8sitsd3f7467, |
| | | 1589782279158ngr675kk3oksin35sul,1589788042787ffdt9hle4s45k9r1nvs,15900310928174dro07ihfckghpb5h13,1594095599055qicg2eb642v5qglhnuo,1599613340050c8nu6rbst9d4emnnbsq,1577972969199lei1g0qkvlh4tkc908m, |
| | | 1578479100252lfbp29v1kafk4s4q4ig,1577971621421tg4v0i1ur8873k7e0ob,1577929944419lgc5h3hepum765e2k7u,1588493493409k9guqp067d31lu7blsv,15827879285193g85m3i2uprektpgmpf` |
| | | window.GLOB.OuterToken = {} |
| | | window.GLOB.$error = false |
| | | |
| | | if (window.openDatabase) { |
| | | CacheUtils.openWebSql(options.sysType) |
| | | } else if (window.indexedDB) { |
| | | CacheUtils.openIndexDB(options.sysType) |
| | | let service = window.GLOB.service ? '-' + window.GLOB.service.replace('/', '') : '' |
| | | let lang = sessionStorage.getItem('lang') !== 'zh-CN' ? sessionStorage.getItem('lang') : '' |
| | | let db = `mkdb${service + lang}` |
| | | |
| | | if (window.indexedDB) { |
| | | CacheUtils.openIndexDB(db) |
| | | } |
| | | |
| | | axios.defaults.crossDomain = true |
| | | axios.defaults.headers.post['Content-Type'] = 'application/x-www-form-urlencoded;charset=UTF-8' |
| | | axios.defaults.withCredentials = false |
| | | |
| | | axios.interceptors.request.use((config) => { |
| | | if (config.url.includes('LoginAndRedirect') || config.url.includes('getjsonresult') || config.url.includes('wxNativePay')) { |
| | | config.data = qs.stringify(config.data) |
| | | } else if (/\/doupload|\/dopreload|\/upload/.test(config.url)) { |
| | | config.headers = { 'Content-Type': 'multipart/form-data' } |
| | | } else if (config.method === 'post' && config.data) { |
| | | config.data = JSON.stringify(config.data) |
| | | } |
| | | |
| | | 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) { |
| | | 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 |
| | | 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.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 |
| | | }) |
| | | } |
| | | return Promise.reject(response) |
| | | } else { |
| | | return Promise.reject() |
| | | if (response && response.status) { |
| | | notification.error({ |
| | | className: 'notification-custom-error', |
| | | bottom: 0, |
| | | message: '状态码-' + response.status + ',请联系管理员', |
| | | placement: 'bottomRight', |
| | | duration: 15 |
| | | }) |
| | | } |
| | | |
| | | return Promise.reject(response) |
| | | }) |
| | | |
| | | class Api { |
| | |
| | | |
| | | /** |
| | | * @description 使用dostar接口,跳过验证 |
| | | * @param {Object} param 查询及提交参数 |
| | | */ |
| | | dostarInterface (param) { |
| | | param.userid = param.userid || '' |
| | |
| | | return axios({ |
| | | url: `/webapi/dostar${param.func ? '/' + param.func : ''}`, |
| | | method: 'post', |
| | | data: param |
| | | data: JSON.stringify(param) |
| | | }) |
| | | } |
| | | |
| | | /** |
| | | * @description 微信业务请求 |
| | | * @description 微信业务请求 原接口 'wxpay/getaccesstoken' |
| | | */ |
| | | wxAccessToken () { |
| | | let _url = window.GLOB.baseurl + 'wxpay/getaccesstoken' |
| | | if (process.env.NODE_ENV !== 'production') { |
| | | _url = document.location.origin + '/wxpay/getaccesstoken' |
| | | } |
| | | // wxAccessToken (appId, domain = '') { |
| | | // let _url = domain || window.GLOB.baseurl |
| | | |
| | | return new Promise(resolve => { |
| | | if (window.GLOB.accessToken.accessTime && (parseInt(new Date().getTime() / 1000) - window.GLOB.accessToken.accessTime < 30)) { |
| | | resolve(window.GLOB.accessToken) |
| | | } else { |
| | | window.GLOB.accessToken = {} |
| | | 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 微信业务请求 |
| | | * 39上 qingqiumarket.cn|cloud.mk9h.cn|sso.mk9h.cn |
| | | */ |
| | | wxNginxRequest (url, method, param) { |
| | | let _url = window.GLOB.location + '/' + url |
| | | if (process.env.NODE_ENV === 'production') { |
| | | _url = document.location.origin + '/' + url |
| | | 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 (/qingqiumarket.cn|cloud.mk9h.cn/.test(_url)) { |
| | | _url = _url.replace('http://qingqiumarket.cn/', 'http://qingqiumarket.cn:8080/') |
| | | _url = _url.replace('http://cloud.mk9h.cn/', 'http://cloud.mk9h.cn:8080/') |
| | | _url = _url.replace('https://qingqiumarket.cn/', 'https://qingqiumarket.cn:8443/') |
| | | _url = _url.replace('https://cloud.mk9h.cn/', 'https://cloud.mk9h.cn:8443/') |
| | | } |
| | | |
| | | if (param) { |
| | |
| | | |
| | | /** |
| | | * @description 直接请求 |
| | | * @param {Object} param 查询及提交参数 |
| | | */ |
| | | directRequest (url, method = 'post', param, cross) { |
| | | if (cross === 'true' && param) { |
| | | return axios({ |
| | | url, |
| | | method, |
| | | data: param |
| | | }) |
| | | } else if (cross === 'true') { |
| | | return axios({ |
| | | url, |
| | | method |
| | | }) |
| | | } |
| | | 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) |
| | | |
| | | let params = { method: 'post' } |
| | | let _url = url |
| | | |
| | | if (method === 'get' && param) { |
| | | let keys = Object.keys(param).map(key => `${key}=${param[key]}`) |
| | | keys = keys.join('&') |
| | | if (keys) { |
| | | _url = _url + '?' + keys |
| | | if (promise instanceof Promise) { |
| | | return promise |
| | | } |
| | | } catch (e) { |
| | | console.warn(e) |
| | | } |
| | | } else if (method === 'post' && param) { |
| | | params.data = param |
| | | |
| | | return Promise.resolve({ |
| | | status: false, |
| | | message: '自定义脚本执行错误', |
| | | ErrCode: 'E' |
| | | }) |
| | | } |
| | | |
| | | _url = _url.replace(/&/ig, '%26') |
| | | params.url = '/trans/redirect?rd=' + _url + '&method=' + method |
| | | |
| | | |
| | | return axios(params) |
| | | } |
| | | |
| | |
| | | timestamp: moment().format('YYYY-MM-DD HH:mm:ss'), |
| | | SessionUid: _SessionUid, |
| | | TypeCharOne: 'pc', |
| | | kei_id: window.btoa(window.encodeURIComponent(window.GLOB.host)) |
| | | kei_id: window.btoa(window.encodeURIComponent(window.GLOB.host)), |
| | | appkey: window.GLOB.appkey || '' |
| | | } |
| | | |
| | | let url = '/webapi/dologon/s_visitor_login' |
| | |
| | | param.thd_party_openid = openid |
| | | param.thd_party_appid = appid |
| | | param.id = scanId |
| | | } else if (binding_type === 'login_check') { // appid 此时为目标 |
| | | } else if (binding_type === 'login_check') { // appid 此时为目标地址 |
| | | param.v_type = 'login_check' |
| | | param.LoginUID = sessionStorage.getItem('LoginUID') || '' |
| | | url = appid.replace(/\/webapi(.*)/, '/webapi/dologon/s_visitor_login') |
| | | |
| | | |
| | | if (!param.rduri) { |
| | | param.rduri = window.GLOB.baseurl + 'webapi/dologon/s_visitor_login' |
| | | } |
| | | |
| | | param.linkurl = appid.replace(/\/webapi(.*)/, '/index.html') |
| | | |
| | | if (appid) { |
| | | url = appid.replace(/\/webapi(.*)/, '/webapi/dologon/s_visitor_login') |
| | | param.linkurl = appid.replace(/\/webapi(.*)/, '/index.html') |
| | | } else { |
| | | param.linkurl = window.GLOB.linkurl |
| | | } |
| | | } |
| | | |
| | | param.LText = md5(window.btoa(_SessionUid + param.timestamp + (param.linkurl || ''))) |
| | |
| | | param.v_type = param.v_type || 'Y' |
| | | param.secretkey = md5(param.LText + solt + param.timestamp) |
| | | |
| | | param.appkey = window.GLOB.appkey || '' |
| | | |
| | | return axios({ |
| | | url: url, |
| | | method: 'post', |
| | | data: param |
| | | data: JSON.stringify(param) |
| | | }) |
| | | } |
| | | |
| | | /** |
| | | * @description 手机号验证码登录 |
| | | */ |
| | | getphoneusermsg (phoneNo, checkcode, isCloud = false, ipAddress, city) { |
| | | getphoneusermsg (phoneNo, checkcode, isCloud = false) { |
| | | let param = { |
| | | // func: 'webapi_login', |
| | | mob: phoneNo, |
| | |
| | | Password: '', |
| | | check_code: checkcode, |
| | | way_no: 'sms_vcode', |
| | | systemType: options.sysType, |
| | | login_city: city, |
| | | login_id_address: ipAddress, |
| | | 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') |
| | | device_id: localStorage.getItem('SessionUid'), |
| | | appkey: window.GLOB.appkey || '' |
| | | } |
| | | |
| | | param.appkey = window.GLOB.appkey || '' |
| | | |
| | | 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') |
| | |
| | | return axios({ |
| | | url, |
| | | method: 'post', |
| | | data: param |
| | | data: JSON.stringify(param) |
| | | }) |
| | | } |
| | | |
| | | /** |
| | | * @description 登录系统, 获取用户信息 |
| | | */ |
| | | getusermsg (username, password, isCloud = false, ipAddress, city) { |
| | | getusermsg (username, password, isCloud = false) { |
| | | let shim = +sessionStorage.getItem('sys_time_shim') |
| | | let param = { |
| | | // func: 'webapi_login', |
| | | UserName: username, |
| | | systemType: options.sysType, |
| | | systemType: window.GLOB.sysType, |
| | | Type: 'S', |
| | | login_city: city, |
| | | login_id_address: ipAddress, |
| | | 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') |
| | | } |
| | | |
| | | param.timestamp = moment().format('YYYY-MM-DD HH:mm:ss') |
| | | |
| | | let sys_datetime = sessionStorage.getItem('sys_datetime') |
| | | let app_datetime = sessionStorage.getItem('app_datetime') |
| | | if (sys_datetime && app_datetime) { |
| | | let seconds = Math.floor((new Date().getTime() - app_datetime) / 1000) |
| | | param.timestamp = moment(sys_datetime, 'YYYY-MM-DD HH:mm:ss').add(seconds, 'seconds').format('YYYY-MM-DD HH:mm:ss') |
| | | device_id: localStorage.getItem('SessionUid'), |
| | | timestamp: moment().add(shim, 'seconds').format('YYYY-MM-DD HH:mm:ss'), |
| | | appkey: window.GLOB.appkey || '' |
| | | } |
| | | |
| | | // Type: 'S' 时 |
| | |
| | | // Type: 'X' 时 |
| | | // param.Password = Utils.formatOptions(password) |
| | | |
| | | param.appkey = window.GLOB.appkey || '' |
| | | let url = '/webapi/dologon' |
| | | |
| | | if (isCloud) { |
| | | param.debug = 'Y' |
| | | if (options.cloudServiceApi) { |
| | | // url = options.cloudServiceApi.replace(/\/webapi(.*)/, '/webapi/dologon') |
| | | 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 |
| | | } |
| | | // url = window.GLOB.mainSystemApi.replace(/\/webapi(.*)/, '/webapi/dologon') |
| | | param.rduri = window.GLOB.mainSystemApi.replace(/\/webapi(.*)/, '/webapi/dologon') |
| | | } |
| | | |
| | | return axios({ |
| | | url, |
| | | method: 'post', |
| | | data: param |
| | | data: JSON.stringify(param) |
| | | }) |
| | | } |
| | | |
| | | delCacheConfig (type = '') { |
| | | let date = moment().subtract(7, 'days').format('YYYY-MM-DD HH:mm:ss') |
| | | CacheUtils.delIndexDBCacheConfig(date, type) |
| | | } |
| | | |
| | | writeCacheConfig (menuid, data, BID = '', id = '') { |
| | | if (!menuid) return |
| | | let date = moment().format('YYYY-MM-DD HH:mm:ss') |
| | | let _data = data ? JSON.stringify(data) : '' |
| | | let userid = sessionStorage.getItem('UserID') || '' |
| | | |
| | | CacheUtils.writeCacheInIndexDB({menuid: md5(menuid + userid + BID + id), BID: BID, id: id, CreateDate: date, LongParam: _data}) |
| | | } |
| | | |
| | | getLCacheConfig (menuid, minutes, BID = '', id = '') { |
| | | return new Promise((resolve, reject) => { |
| | | 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}) |
| | | } |
| | | }) |
| | | }) |
| | | } |
| | | |
| | | /** |
| | | * @description 获取系统版本信息,启用或更新websql |
| | | * @description 获取系统版本信息 |
| | | */ |
| | | getAppVersion (_resolve, _reject) { |
| | | if (!window.GLOB.WebSql && !window.GLOB.IndexDB) { |
| | | getAppVersion (reload) { |
| | | if (!window.GLOB.IndexDB) { |
| | | return Promise.reject() |
| | | } |
| | | |
| | | let curTime = moment().format('YYYY-MM-DD HH:mm:ss') + '.000' |
| | | let sys_datetime = sessionStorage.getItem('sys_datetime') |
| | | let app_datetime = sessionStorage.getItem('app_datetime') |
| | | if (sys_datetime && app_datetime) { |
| | | let seconds = Math.floor((new Date().getTime() - app_datetime) / 1000) |
| | | curTime = moment(sys_datetime, 'YYYY-MM-DD HH:mm:ss').add(seconds, 'seconds').format('YYYY-MM-DD HH:mm:ss') + '.000' |
| | | } |
| | | let shim = +sessionStorage.getItem('sys_time_shim') |
| | | let curTime = moment().add(shim, 'seconds').format('YYYY-MM-DD HH:mm:ss') + '.000' |
| | | |
| | | if (window.GLOB.WebSql) { |
| | | return new Promise((resolve, reject) => { |
| | | CacheUtils.getWebSqlVersion().then(msg => { |
| | | let modifydate = msg.createDate || curTime |
| | | if (modifydate.indexOf('Invalid date') > -1) { |
| | | modifydate = curTime |
| | | return new Promise((resolve, reject) => { |
| | | CacheUtils.getIndexDBVersion().then(msg => { |
| | | 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 = '' |
| | | param.typename = '' |
| | | |
| | | if (!msg.createDate && !msg.menuids) { |
| | | CacheUtils.updateIndexDBversion({version: '1.00', createDate: curTime}) |
| | | resolve() |
| | | return |
| | | } else if (!msg.createDate || reload === true) { |
| | | param.modifydate = curTime |
| | | param.menuids = window.btoa(msg.menuids) |
| | | } else if (msg.menuids) { |
| | | let d = localStorage.getItem(db) |
| | | |
| | | if (!d || curTime.indexOf(d) === -1) { |
| | | param.menuids = window.btoa(msg.menuids) |
| | | } |
| | | |
| | | let param = { |
| | | func: 's_get_app_version', |
| | | modifydate |
| | | localStorage.setItem(db, curTime.substr(0, 10)) |
| | | } |
| | | |
| | | this.getSystemConfig(param).then(res => { |
| | | if (!res.status) { |
| | | reject(res.message) |
| | | return |
| | | } |
| | | |
| | | this.getSystemConfig(param).then(res => { |
| | | if (!res.status) { |
| | | reject() |
| | | return |
| | | } |
| | | |
| | | let list = res.menu_data || [] |
| | | |
| | | if (res.menu_del) { |
| | | list.push(...res.menu_del) |
| | | } |
| | | |
| | | list = list.map(mid => mid.menuid) |
| | | |
| | | if (typeof(reload) === 'string' && !list.includes(reload)) { |
| | | list.push(reload) |
| | | } |
| | | |
| | | if (list.length > 0) { |
| | | let clear = false |
| | | let version = '1.00' |
| | | |
| | | if (res.menu_data && res.menu_data.length > 0) { |
| | | res.menu_data.forEach(mid => { |
| | | if (systemMenuKeys.indexOf(mid.menuid) > -1) { |
| | | clear = true |
| | | } |
| | | }) |
| | | let _appkey = window.GLOB.appkey.substr(-10) |
| | | let reg = new RegExp(_appkey + '$', 'i') |
| | | let reHome = list.includes('home_page_id') |
| | | |
| | | if (clear) { |
| | | CacheUtils.clearWebSqlConfig() |
| | | } else { |
| | | let keys = res.menu_data.map(mid => `'${mid.menuid}'`).join(',') |
| | | CacheUtils.delWebSqlConfig(keys) |
| | | list.forEach(mid => { |
| | | if (reg.test(mid)) { |
| | | clear = true |
| | | } |
| | | }) |
| | | if (clear) { |
| | | list = '' |
| | | } |
| | | |
| | | if (msg.version) { |
| | | CacheUtils.updateWebSqlTime(curTime) |
| | | } else { |
| | | CacheUtils.createWebSqlversion(version, curTime) |
| | | CacheUtils.delIndexDBConfig(list) |
| | | this.delCacheConfig('all') |
| | | |
| | | if (reHome) { |
| | | MKEmitter.emit('reloadMenuView', 'home_page_id') |
| | | } |
| | | |
| | | resolve() |
| | | }) |
| | | }, () => { |
| | | reject() |
| | | }) |
| | | }) |
| | | } else { |
| | | return new Promise((resolve, reject) => { |
| | | CacheUtils.getIndexDBVersion().then(msg => { |
| | | let modifydate = msg.createDate || curTime |
| | | if (modifydate.indexOf('Invalid date') > -1) { |
| | | modifydate = curTime |
| | | } |
| | | let param = { |
| | | func: 's_get_app_version', |
| | | modifydate |
| | | } |
| | | |
| | | this.getSystemConfig(param).then(res => { |
| | | if (!res.status) { |
| | | reject() |
| | | return |
| | | } |
| | | let clear = false |
| | | let version = '1.00' |
| | | |
| | | if (res.menu_data && res.menu_data.length > 0) { |
| | | res.menu_data.forEach(mid => { |
| | | if (systemMenuKeys.indexOf(mid.menuid) > -1) { |
| | | clear = true |
| | | } |
| | | }) |
| | | CacheUtils.updateIndexDBversion({version: res.app_version || '1.00', createDate: curTime}) |
| | | |
| | | if (clear) { |
| | | CacheUtils.clearIndexDBConfig() |
| | | } else { |
| | | let keys = res.menu_data.map(mid => `'${mid.menuid}'`) |
| | | CacheUtils.delIndexDBConfig(keys) |
| | | } |
| | | } |
| | | |
| | | CacheUtils.updateIndexDBversion({version: version, createDate: curTime}) |
| | | |
| | | resolve() |
| | | }) |
| | | }, () => { |
| | | reject() |
| | | resolve(list) |
| | | }) |
| | | }, () => { |
| | | reject() |
| | | }) |
| | | } |
| | | }) |
| | | } |
| | | |
| | | /** |
| | | * @description 更新系统版本信息,清空配置信息 |
| | | */ |
| | | updateAppVersion () { |
| | | let curTime = moment().format('YYYY-MM-DD HH:mm:ss') + '.000' |
| | | CacheUtils.clearWebSqlConfig() |
| | | CacheUtils.updateWebSqlversion('1.00', curTime) |
| | | CacheUtils.clearIndexDBConfig() |
| | | CacheUtils.updateIndexDBversion({version: '1.00', createDate: curTime}) |
| | | CacheUtils.clearFuncs(options.sysType) |
| | | CacheUtils.delIndexDBConfig() |
| | | CacheUtils.updateIndexDBversion() |
| | | // CacheUtils.clearFuncs() |
| | | } |
| | | |
| | | /** |
| | | * @description 删除某个菜单配置信息 |
| | | */ |
| | | deleteMenuStorage (menuId) { |
| | | if (window.GLOB.IndexDB) { |
| | | let key = menuId + (sessionStorage.getItem('UserID') || '') |
| | | |
| | | if (sessionStorage.getItem('isEditState') === 'true' && options.cloudServiceApi) { |
| | | key = menuId + (sessionStorage.getItem('CloudUserID') || '') |
| | | } |
| | | |
| | | return CacheUtils.delMenuIndexDBConfig(key) |
| | | } else { |
| | | return CacheUtils.delMenuWebSqlConfig(menuId) |
| | | } |
| | | CacheUtils.delIndexDBConfig(menuId) |
| | | } |
| | | |
| | | /** |
| | |
| | | */ |
| | | 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 |
| | | } |
| | |
| | | return axios({ |
| | | url, |
| | | method: 'post', |
| | | data: param |
| | | data: JSON.stringify(param) |
| | | }) |
| | | } |
| | | |
| | | /** |
| | | * @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: 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 { |
| | |
| | | return axios({ |
| | | url: `${url}${param.func ? '/' + param.func : ''}`, |
| | | method: 'post', |
| | | data: param |
| | | data: JSON.stringify(param) |
| | | }) |
| | | } |
| | | |
| | | /** |
| | | * @description 获取系统配置,取值优先等级websql、缓存、服务器 |
| | | * @description 获取系统配置,取值优先等级IndexDB、缓存、服务器 |
| | | */ |
| | | getCacheConfig (param) { |
| | | param.userid = sessionStorage.getItem('UserID') || '' |
| | | 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 { |
| | |
| | | } |
| | | } |
| | | |
| | | let _param = JSON.parse(JSON.stringify(param)) // 缓存校验,去除时间和加密字符 |
| | | delete _param.timestamp |
| | | delete _param.secretkey |
| | | delete _param.open_key |
| | | _param = JSON.stringify(_param) |
| | | _param = md5(_param) |
| | | let key = md5(param.MenuID + param.userid) |
| | | |
| | | if (window.GLOB.WebSql) { |
| | | if (window.GLOB.IndexDB) { |
| | | return new Promise(resolve => { |
| | | CacheUtils.getWebSqlMenuConfig(param.MenuID, param.userid).then(res => { |
| | | CacheUtils.getIndexDBMenuConfig(key).then(res => { |
| | | resolve(res) |
| | | }, () => { |
| | | param = this.encryptParam(param) |
| | | axios({ |
| | | url: `${url}${param.func ? '/' + param.func : ''}`, |
| | | method: 'post', |
| | | data: param |
| | | }).then(res => { |
| | | if (res.status && window.GLOB.WebSql) { |
| | | CacheUtils.writeInWebSql([param.MenuID, param.userid, res.open_edition, res.web_edition, res.LongParam, res.LongParamUser]) |
| | | } else if (res.status) { |
| | | window.GLOB.CacheMap.set(_param, res) |
| | | } |
| | | resolve(res) |
| | | }) |
| | | }) |
| | | }) |
| | | } else if (window.GLOB.IndexDB) { |
| | | return new Promise(resolve => { |
| | | CacheUtils.getIndexDBMenuConfig(param.MenuID, param.userid).then(res => { |
| | | resolve(res) |
| | | }, () => { |
| | | param = this.encryptParam(param) |
| | | axios({ |
| | | url: `${url}${param.func ? '/' + param.func : ''}`, |
| | | method: 'post', |
| | | data: param |
| | | data: JSON.stringify(param) |
| | | }).then(res => { |
| | | if (res.status && window.GLOB.IndexDB) { |
| | | let msg = { |
| | | ...res, |
| | | userid: param.userid, |
| | | menuid: param.MenuID, |
| | | id: param.MenuID + param.userid |
| | | id: key |
| | | } |
| | | CacheUtils.writeInIndexDB(msg) |
| | | } else if (res.status) { |
| | | window.GLOB.CacheMap.set(_param, res) |
| | | window.GLOB.CacheMap.set(key, res) |
| | | } |
| | | resolve(res) |
| | | }) |
| | | }) |
| | | }) |
| | | } else if (window.GLOB.CacheMap.has(_param)) { |
| | | return Promise.resolve(window.GLOB.CacheMap.get(_param)) |
| | | } else if (window.GLOB.CacheMap.has(key)) { |
| | | return Promise.resolve(window.GLOB.CacheMap.get(key)) |
| | | } else { |
| | | param = this.encryptParam(param) |
| | | |
| | |
| | | axios({ |
| | | url: `${url}${param.func ? '/' + param.func : ''}`, |
| | | method: 'post', |
| | | data: param |
| | | data: JSON.stringify(param) |
| | | }).then(res => { |
| | | if (res.status) { |
| | | window.GLOB.CacheMap.set(_param, res) |
| | | window.GLOB.CacheMap.set(key, res) |
| | | } |
| | | resolve(res) |
| | | }) |
| | |
| | | param.appkey = window.GLOB.appkey || '' |
| | | |
| | | let _param = md5(JSON.stringify(param)) |
| | | |
| | | if (window.GLOB.WebSql) { |
| | | return new Promise(resolve => { |
| | | CacheUtils.getWebSqlMenuConfig(param.MenuID, param.userid).then(res => { |
| | | resolve(res) |
| | | }, () => { |
| | | resolve({ ErrCode: 'S', ErrMesg: '', LongParam: '', message: '', status: false }) |
| | | }) |
| | | }) |
| | | } else if (window.GLOB.CacheMap.has(_param)) { |
| | | |
| | | 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.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, '') |
| | | window.mkInfo(n) |
| | | }) |
| | | } |
| | | 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) { |
| | | url = param.rduri |
| | | delete param.rduri |
| | | } |
| | | |
| | | let _param = JSON.parse(JSON.stringify(param)) // 缓存校验,去除时间和加密字符 |
| | | delete _param.timestamp |
| | | delete _param.secretkey |
| | | delete _param.open_key |
| | | _param = JSON.stringify(_param) |
| | | _param = md5(_param) |
| | | let _param = '' |
| | | if (cache) { |
| | | _param = JSON.parse(JSON.stringify(param)) // 缓存校验,去除时间和加密字符 |
| | | delete _param.timestamp |
| | | delete _param.secretkey |
| | | delete _param.open_key |
| | | _param = JSON.stringify(_param) |
| | | _param = md5(_param) |
| | | } |
| | | |
| | | if (cache && window.GLOB.CacheMap.has(_param)) { |
| | | return Promise.resolve(window.GLOB.CacheMap.get(_param)) |
| | |
| | | axios({ |
| | | url: `${url}${param.func ? '/' + param.func : ''}`, |
| | | method: 'post', |
| | | data: param |
| | | data: JSON.stringify(param) |
| | | }).then(res => { |
| | | if (res.status) { |
| | | window.GLOB.CacheMap.set(_param, res) |
| | |
| | | } |
| | | } |
| | | |
| | | visitOuterSystem (param, _resolve, _reject) { |
| | | let token = param.$token |
| | | delete param.$token |
| | | |
| | | try { |
| | | token = JSON.parse(token) |
| | | token = token.message |
| | | |
| | | const key = CryptoJS.enc.Utf8.parse(window.GLOB.appkey.slice(-16)) |
| | | const iv = CryptoJS.enc.Utf8.parse('mksoft') |
| | | |
| | | let encryptedHexStr = CryptoJS.enc.Hex.parse(token) |
| | | let _srcs = CryptoJS.enc.Base64.stringify(encryptedHexStr) |
| | | let decrypt = CryptoJS.AES.decrypt(_srcs, key, { iv: iv, mode: CryptoJS.mode.CBC, padding: CryptoJS.pad.Pkcs7 }) |
| | | let decryptedStr = decrypt.toString(CryptoJS.enc.Utf8) |
| | | token = decryptedStr.toString() |
| | | |
| | | token = JSON.parse(window.decodeURIComponent(window.atob(token))) |
| | | } catch (e) { |
| | | token = null |
| | | _resolve({status: false, ErrCode: 'token_error', message: '接口信息解析失败!'}) |
| | | } |
| | | |
| | | if (!token) return |
| | | |
| | | let userid = '' |
| | | let loginUid = '' |
| | | let dataM = '' |
| | | |
| | | if (window.GLOB.OuterToken[token.interface]) { |
| | | let msg = window.GLOB.OuterToken[token.interface] |
| | | |
| | | let seconds = Math.floor((new Date().getTime() - msg.timestamp) / 1000) |
| | | if (seconds >= 3600) { |
| | | delete window.GLOB.OuterToken[token.interface] |
| | | } else { |
| | | userid = msg.userid |
| | | loginUid = msg.loginUid |
| | | dataM = msg.dataM || '' |
| | | } |
| | | } |
| | | |
| | | // param.appkey = token.appkey || '' |
| | | |
| | | if (userid && loginUid) { |
| | | param.dataM = dataM |
| | | param.userid = userid |
| | | param.LoginUID = loginUid |
| | | param = this.encryptParam(param) |
| | | |
| | | axios({ |
| | | 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: window.GLOB.sysType, |
| | | login_city: sessionStorage.getItem('city') || '', |
| | | device_id: token.appkey || '', |
| | | timestamp: moment().format('YYYY-MM-DD HH:mm:ss'), |
| | | Type: token.publicKey, |
| | | appkey: token.appkey || '' |
| | | } |
| | | |
| | | let shaObj = new jsSHA('SHA-1', 'TEXT') |
| | | shaObj.update(token.password) |
| | | _param.Password = shaObj.getHash('HEX').toUpperCase() |
| | | _param.Password = md5(token.privateKey + token.username + _param.Password + _param.timestamp) |
| | | |
| | | let url = token.interface.replace(/\/webapi(.*)/, '/webapi/dologon') |
| | | |
| | | if (token.ssoInterface) { |
| | | _param.rduri = token.ssoInterface.replace(/\/webapi(.*)/, '/webapi/dologon') |
| | | } |
| | | |
| | | axios({ |
| | | url, |
| | | method: 'post', |
| | | data: JSON.stringify(_param) |
| | | }).then(result => { |
| | | if (result.status) { |
| | | window.GLOB.OuterToken[token.interface] = { |
| | | userid: result.UserID, |
| | | loginUid: result.LoginUID, |
| | | timestamp: new Date().getTime(), |
| | | dataM: result.dataM ? 'Y' : '' |
| | | } |
| | | |
| | | param.dataM = result.dataM ? 'Y' : '' |
| | | param.userid = result.UserID |
| | | param.LoginUID = result.LoginUID |
| | | param = this.encryptParam(param) |
| | | |
| | | axios({ |
| | | 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.LoginUID = param.LoginUID || sessionStorage.getItem('LoginUID') || '' |
| | | param.appkey = window.GLOB.appkey || '' |
| | | |
| | | let login = false |
| | | let rduri = null |
| | | if (param.$token === '') { |
| | | return Promise.resolve({status: false, ErrCode: 'token_error', message: '接口地址尚未设置!'}) |
| | | } else if (param.$token) { |
| | | return new Promise((resolve, reject) => this.visitOuterSystem(param, resolve, reject)) |
| | | } |
| | | |
| | | if (['sPC_TableData_InUpDe', 'sPC_TableData_InUpDe_debug'].includes(param.func)) { |
| | | param.username = sessionStorage.getItem('User_Name') || '' |
| | | param.fullname = sessionStorage.getItem('Full_Name') || '' |
| | | } |
| | | |
| | | 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: 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: param |
| | | 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 = 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, '') |
| | | window.mkInfo(n) |
| | | }) |
| | | } |
| | | if (res.ErrCode === 'version_error') { |
| | | res.ErrCode = '-2' |
| | | MKEmitter.emit('reloadTabs') |
| | | } |
| | | 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: param |
| | | data: JSON.stringify(param), |
| | | requestId |
| | | }) |
| | | } |
| | | } |
| | | |
| | | /** |
| | | * @description 导出Excel,后台生成文件 |
| | | * @description 清空后端缓存 |
| | | */ |
| | | // getExcelOut (param, name) { |
| | | // param.userid = sessionStorage.getItem('UserID') |
| | | // param.lang = sessionStorage.getItem('lang') || '' |
| | | // param.SessionUid = localStorage.getItem('SessionUid') || '' |
| | | // param.LoginUID = sessionStorage.getItem('LoginUID') || '' |
| | | // param.appkey = window.GLOB.appkey || '' |
| | | |
| | | // return new Promise(resolve => { |
| | | // axios({ |
| | | // url: '/webapi/doexcel', |
| | | // responseType: 'blob', |
| | | // method: 'post', |
| | | // data: param |
| | | // }).then(res => { |
| | | // try { |
| | | // const blob = new Blob([res]) |
| | | |
| | | // if (res.type === 'application/json') { |
| | | // const reader = new FileReader() |
| | | // reader.onload = e => resolve(JSON.parse(e.target.result)) |
| | | // reader.readAsText(blob) |
| | | // } else { |
| | | // if ('download' in document.createElement('a')) { // 非IE下载 |
| | | // const elink = document.createElement('a') |
| | | // elink.download = name |
| | | // elink.style.display = 'none' |
| | | // elink.href = URL.createObjectURL(blob) |
| | | // document.body.appendChild(elink) |
| | | // elink.click() |
| | | // URL.revokeObjectURL(elink.href) // 释放URL 对象 |
| | | // document.body.removeChild(elink) |
| | | // } else { // IE10+下载 |
| | | // navigator.msSaveBlob(blob, name) |
| | | // } |
| | | // resolve() |
| | | // } |
| | | // } catch (e) { |
| | | // resolve({ |
| | | // ErrCode: 'E', |
| | | // ErrMesg: '文件解析错误', |
| | | // message: '', |
| | | // status: false |
| | | // }) |
| | | // } |
| | | // }) |
| | | // }) |
| | | // } |
| | | cacheInterface (param) { |
| | | param.appkey = window.GLOB.appkey || '' |
| | | |
| | | 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 上传base64 |
| | |
| | | return axios({ |
| | | url, |
| | | method: 'post', |
| | | data: param |
| | | data: JSON.stringify(param) |
| | | }) |
| | | } |
| | | |
| | | /** |
| | | * @description 大文件上传 |
| | | */ |
| | | getLargeFileUpload (param) { |
| | | return axios({ |
| | | url: '/webapi/doupload', |
| | | method: 'post', |
| | | 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', |
| | | data: param |
| | | }) |
| | | } |
| | | // getFilePreUpload (param) { |
| | | // return axios({ |
| | | // url: '/webapi/dopreload', |
| | | // method: 'post', |
| | | // headers: { 'Content-Type': 'multipart/form-data' }, |
| | | // data: param |
| | | // }) |
| | | // } |
| | | |
| | | /** |
| | | * @description oss文件上传 |
| | |
| | | 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' |
| | | } |
| | | if (/qingqiumarket.cn|cloud.mk9h.cn/.test(_url)) { |
| | | _url = _url.replace('http://qingqiumarket.cn/', 'http://qingqiumarket.cn:8080/') |
| | | _url = _url.replace('http://cloud.mk9h.cn/', 'http://cloud.mk9h.cn:8080/') |
| | | _url = _url.replace('https://qingqiumarket.cn/', 'https://qingqiumarket.cn:8443/') |
| | | _url = _url.replace('https://cloud.mk9h.cn/', 'https://cloud.mk9h.cn:8443/') |
| | | } |
| | | |
| | | return axios({ |
| | | url: _url, |
| | | method: 'post', |
| | | headers: { 'Content-Type': 'multipart/form-data' }, |
| | | data: param |
| | | }) |
| | | } |
| | | |
| | | /** |
| | | * @description 获取微信支付二维码 |
| | | * @description 获取微信支付二维码 原接口wxpay/wxNativePay |
| | | */ |
| | | getWxNativePay (param) { |
| | | let _url = window.GLOB.baseurl + 'wxpay/wxNativePay' |
| | | if (process.env.NODE_ENV !== 'production') { |
| | | _url = document.location.origin + '/wxpay/wxNativePay' |
| | | } |
| | | |
| | | return axios({ |
| | | url: _url, |
| | | url: window.GLOB.baseurl + 'wechat/native', |
| | | method: 'post', |
| | | data: param |
| | | data: JSON.stringify(param) |
| | | }) |
| | | } |
| | | |
| | | // /** |
| | | // * @description 文件上传 |
| | | // */ |
| | | // getFileUpload (param) { |
| | | // return axios({ |
| | | // url: '/zh-CN/Home/Upload', |
| | | // method: 'post', |
| | | // data: param |
| | | // }) |
| | | // } |
| | | /** |
| | | * @description 微信支付退款 原接口wxpay/wxRefund |
| | | */ |
| | | setRefund (param) { |
| | | return axios({ |
| | | url: window.GLOB.baseurl + 'wechat/wxRefund', |
| | | method: 'post', |
| | | data: JSON.stringify(param) |
| | | }) |
| | | } |
| | | |
| | | postekPrint (data) { |
| | | return axios({ |
| | | url: 'http://127.0.0.1:888/postek/print', |
| | | method: 'post', |
| | | data: qs.stringify(data) |
| | | }) |
| | | } |
| | | |
| | | /** |
| | | * @description sql检验 |
| | | */ |
| | | sDebug (sql) { |
| | | 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')}`) |
| | | |
| | | 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() |