import axios from 'axios' import qs from 'qs' 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' window.GLOB.IndexDB = null window.GLOB.OuterToken = {} window.GLOB.$error = false let service = window.GLOB.service ? '-' + window.GLOB.service.replace('/', '') : '' 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.crossDomain = true axios.defaults.headers.post['Content-Type'] = 'application/x-www-form-urlencoded;charset=UTF-8' axios.defaults.withCredentials = false axios.interceptors.response.use((response) => { if (response.data.ErrCode === 'LoginError') { if (window.GLOB.developing) { sessionStorage.setItem('devError', 'true') response.data.ErrCode = 'E' return Promise.resolve(response.data) } 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 || '' 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) }) class Api { constructor() { axios.defaults.baseURL = window.GLOB.baseurl } /** * @description 使用dostar接口,跳过验证 */ dostarInterface (param) { param.userid = param.userid || '' return axios({ url: `/webapi/dostar${param.func ? '/' + param.func : ''}`, method: 'post', data: JSON.stringify(param) }) } /** * @description 微信业务请求 原接口 'wxpay/getaccesstoken' */ // wxAccessToken (appId, domain = '') { // let _url = domain || window.GLOB.baseurl // return axios({ // url: _url + 'wechat/getaccesstoken', // method: 'post', // data: JSON.stringify({app_id: appId}) // }) // } /** * @description 快递查询 */ expressRequest (url) { return axios({ url: window.GLOB.location + '/' + url, method: 'get' }) } /** * @description 直接请求 */ 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') || '' let param = { func: 's_visitor_login', timestamp: moment().format('YYYY-MM-DD HH:mm:ss'), SessionUid: _SessionUid, TypeCharOne: 'pc', kei_id: window.btoa(window.encodeURIComponent(window.GLOB.host)), appkey: window.GLOB.appkey || '' } let url = '/webapi/dologon/s_visitor_login' if (window.GLOB.mainSystemApi) { param.rduri = window.GLOB.mainSystemApi.replace(/\/webapi(.*)/, '/webapi/dologon/s_visitor_login') } if (binding_type === 'mk') { param.binding_type = 'mk' param.thd_party_member_id = memberid param.thd_party_openid = openid param.thd_party_appid = appid param.id = scanId } else if (binding_type === 'login_check') { // appid 此时为目标地址 param.v_type = 'login_check' param.LoginUID = sessionStorage.getItem('LoginUID') || '' if (!param.rduri) { param.rduri = window.GLOB.baseurl + 'webapi/dologon/s_visitor_login' } if (appid) { url = appid.replace(/\/webapi(.*)/, '/webapi/dologon/s_visitor_login') param.linkurl = appid.replace(/\/webapi(.*)/, '/index.html') } 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 || ''))) // param.secretkey = md5(param.LText + 'mingke' + param.timestamp) // v_type 为空时 let solt = md5((window.GLOB.appkey + window.btoa(window.GLOB.appkey + 'mingke') + 'mingke').toLowerCase()).slice(-6).toUpperCase() param.v_type = param.v_type || 'Y' param.secretkey = md5(param.LText + solt + param.timestamp) return axios({ url: url, method: 'post', data: JSON.stringify(param) }) } /** * @description 手机号验证码登录 */ getphoneusermsg (phoneNo, checkcode, isCloud = false) { let param = { // func: 'webapi_login', mob: phoneNo, UserName: '', Password: '', check_code: checkcode, way_no: 'sms_vcode', 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 || '', lang: sessionStorage.getItem('lang') || '' } let url = '/webapi/dologon' if (isCloud) { param.debug = 'Y' if (window.GLOB.cloudServiceApi) { param.rduri = window.GLOB.cloudServiceApi.replace(/\/webapi(.*)/, '/webapi/dologon') } } else if (window.GLOB.mainSystemApi) { 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: JSON.stringify(param) }) } /** * @description 登录系统, 获取用户信息 */ getusermsg (username, password, isCloud = false) { let shim = +sessionStorage.getItem('sys_time_shim') let param = { // func: 'webapi_login', UserName: username, 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 || '', lang: sessionStorage.getItem('lang') || '' } // Type: 'S' 时 let shaObj = new jsSHA('SHA-1', 'TEXT') shaObj.update(password) param.Password = shaObj.getHash('HEX').toUpperCase() param.Password = md5(username + param.Password + param.timestamp) // Type: 'mk_' 时 // param.Type = '公钥' // let shaObj = new jsSHA('SHA-1', 'TEXT') // shaObj.update(password) // param.Password = shaObj.getHash('HEX').toUpperCase() // param.Password = md5('私钥' + username + param.Password + param.timestamp) // Type: 'X' 时 // param.Password = Utils.formatOptions(password) let url = '/webapi/dologon' if (isCloud) { param.debug = 'Y' if (window.GLOB.cloudServiceApi) { param.rduri = window.GLOB.cloudServiceApi.replace(/\/webapi(.*)/, '/webapi/dologon') } } else if (window.GLOB.mainSystemApi) { 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: 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 获取系统版本信息 */ getAppVersion (reload) { if (!window.GLOB.IndexDB) { return Promise.reject() } let shim = +sessionStorage.getItem('sys_time_shim') let curTime = moment().add(shim, 'seconds').format('YYYY-MM-DD HH:mm:ss') + '.000' 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) } localStorage.setItem(db, curTime.substr(0, 10)) } this.getSystemConfig(param).then(res => { if (!res.status) { reject(res.message) 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 _appkey = window.GLOB.appkey.substr(-10) let reg = new RegExp(_appkey + '$', 'i') let reHome = list.includes('home_page_id') list.forEach(mid => { if (reg.test(mid)) { clear = true } }) if (clear) { 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(list) }) }, () => { reject() }) }) } /** * @description 更新系统版本信息,清空配置信息 */ updateAppVersion () { CacheUtils.delIndexDBConfig() CacheUtils.updateIndexDBversion() // CacheUtils.clearFuncs() } /** * @description 删除某个菜单配置信息 */ deleteMenuStorage (menuId) { CacheUtils.delIndexDBConfig(menuId) } /** * @description 获取或修改云端配置 */ getCloudConfig (param) { param.lang = param.lang || sessionStorage.getItem('lang') || '' param.appkey = param.appkey || window.GLOB.appkey || '' param.SessionUid = localStorage.getItem('SessionUid') || '' param.userid = param.userid || sessionStorage.getItem('CloudUserID') || '' param.LoginUID = param.LoginUID || sessionStorage.getItem('CloudLoginUID') || '' param = this.encryptParam(param) let url = window.GLOB.cloudServiceApi ? window.GLOB.cloudServiceApi : '/webapi/dostars' if (param.func) { url = url + '/' + param.func } return axios({ url, method: 'post', 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 // } // let url = window.GLOB.mainSystemApi || '/webapi/dostars' // param = this.encryptParam(param) // return axios({ // url: `${url}/${param.func}`, // method: 'post', // data: JSON.stringify(param) // }) // } /** * @description 获取或修改系统配置,增加appkey */ getSystemConfig (param) { 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 = param.appkey || window.GLOB.appkey let url = '/webapi/dostars' if (window.GLOB.mainSystemApi) { if (!window.GLOB.transfer) { url = window.GLOB.mainSystemApi } else { param.rduri = window.GLOB.mainSystemApi } } param = this.encryptParam(param) return axios({ url: `${url}${param.func ? '/' + param.func : ''}`, method: 'post', data: JSON.stringify(param) }) } /** * @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 = param.appkey || window.GLOB.appkey || '' let url = '/webapi/dostars' if (window.GLOB.mainSystemApi) { if (!window.GLOB.transfer) { url = window.GLOB.mainSystemApi } else { param.rduri = window.GLOB.mainSystemApi } } let key = md5(param.MenuID + param.userid) if (window.GLOB.IndexDB) { return new Promise(resolve => { CacheUtils.getIndexDBMenuConfig(key).then(res => { resolve(res) }, () => { param = this.encryptParam(param) axios({ url: `${url}${param.func ? '/' + param.func : ''}`, method: 'post', data: JSON.stringify(param) }).then(res => { if (res.status && window.GLOB.IndexDB) { let msg = { ...res, userid: param.userid, menuid: param.MenuID, id: key } CacheUtils.writeInIndexDB(msg) } else if (res.status) { window.GLOB.CacheMap.set(key, res) } resolve(res) }) }) }) } else if (window.GLOB.CacheMap.has(key)) { return Promise.resolve(window.GLOB.CacheMap.get(key)) } else { param = this.encryptParam(param) return new Promise(resolve => { axios({ url: `${url}${param.func ? '/' + param.func : ''}`, method: 'post', data: JSON.stringify(param) }).then(res => { if (res.status) { window.GLOB.CacheMap.set(key, res) } resolve(res) }) }) } } /** * @description 获取本地系统配置 */ getLocalCacheConfig (param) { 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 || '' let _param = md5(JSON.stringify(param)) if (window.GLOB.CacheMap.has(_param)) { return Promise.resolve(window.GLOB.CacheMap.get(_param)) } else { return Promise.resolve({ErrCode: 'S', LongParam: '', message: '', status: false}) } } /** * @description dostars 参数加密 */ encryptParam (param) { param.nonc = Utils.getuuid() let keys = Object.keys(param).sort() let values = '' keys.forEach(key => { if (key === 'rduri' || key === 't') return if (param[key] === undefined) { delete param[key] } else if (typeof(param[key]) === 'object') { values += key + JSON.stringify(param[key]) } else { values += key + param[key] } }) param.sign = md5(values) param.t = new Date().getTime(); ['arr_field', 'custom_script', 'LText', 'DateCount'].forEach(key => { if (param[key]) { let val = param[key] delete param[key] param[key] = val } }) return param } /** * @description 获取系统配置,优先从缓存中取值,增加appkey * @param {Object} param 请求参数 * @param {Boolean} cache 是否使用缓存 */ getSystemCacheConfig (param, cache = true) { 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 || '' 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) { url = param.rduri delete param.rduri } 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)) } else { param = this.encryptParam(param) return new Promise(resolve => { axios({ url: `${url}${param.func ? '/' + param.func : ''}`, method: 'post', data: JSON.stringify(param) }).then(res => { if (res.status) { window.GLOB.CacheMap.set(_param, res) } resolve(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, 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 || '' 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.rduri) { delete param.rduri } } 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) if (promise instanceof Promise) { return promise } } catch (e) { console.warn(e) } 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) let time = +sessionStorage.getItem(rduri) let c_time = Math.round(new Date().getTime() / 1000) if (time && c_time - time <= 1800) { sessionStorage.setItem(rduri, c_time) 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() }) }) } return new Promise((resolve, reject) => { this.getTouristMsg('login_check', rduri).then(res => { if (res.status) { sessionStorage.setItem(rduri, c_time) axios({ 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') { res.message = window.GLOB.dict['permission_deny'] || '无当前菜单或按钮的访问权限,请联系管理员!' res.ErrMesg = window.GLOB.dict['permission_deny'] || '无当前菜单或按钮的访问权限,请联系管理员!' } } 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), 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 上传base64 * @param {String} base64 base64图片编码 */ fileuploadbase64 (param) { param.func = '' param.BasePath = 'Content/Upload' param.lang = sessionStorage.getItem('lang') || '' param.appkey = window.GLOB.appkey || '' param.SessionUid = localStorage.getItem('SessionUid') || '' param.userid = param.userid || sessionStorage.getItem('UserID') || '' param.LoginUID = param.LoginUID || sessionStorage.getItem('LoginUID') || '' param = this.encryptParam(param) let url = '/webapi/SaveBase64Image' if (param.rduri) { param.rduri = param.rduri.replace(/webapi(.*)$/, 'webapi/SaveBase64Image') if (/\s|\n/.test(param.rduri)) { param.rduri = param.rduri.replace(/\s|\n/g, '') if (!param.rduri) { delete param.rduri } } } if (param.rduri && !window.GLOB.transfer) { url = param.rduri delete param.rduri } return axios({ url, method: 'post', data: JSON.stringify(param) }) } /** * @description 大文件上传 */ 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 // }) // } /** * @description oss文件上传 */ fileOssUpload (param) { return axios({ url: window.GLOB.location + '/file/oss/upload', method: 'post', headers: { 'Content-Type': 'multipart/form-data' }, data: param }) } /** * @description 获取微信支付二维码 原接口wxpay/wxNativePay */ getWxNativePay (param) { return axios({ url: window.GLOB.baseurl + 'wechat/native', method: 'post', data: JSON.stringify(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, 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()