| | |
| | | }) |
| | | } else if (!links.includes(item.verify.linkUrl)) { |
| | | links.push(item.verify.linkUrl) |
| | | } |
| | | }) |
| | | |
| | | let socket = null |
| | | socket = new WebSocket('ws://' + item.verify.linkUrl) |
| | | if (links.length === 0) return |
| | | |
| | | let defers = links.map(link => { |
| | | return new Promise((resolve) => { |
| | | let socket = new WebSocket('ws://' + link) |
| | | // 打开Socket |
| | | socket.onopen = () =>{ |
| | | let request = { |
| | |
| | | }) |
| | | } |
| | | |
| | | window.GLOB.UserCacheMap.set(item.verify.linkUrl, _printers) |
| | | } else if (data && data.cmd === 'getPrinters') { |
| | | notification.warning({ |
| | | top: 92, |
| | | message: data.message, |
| | | duration: 5 |
| | | }) |
| | | resolve({status: true, printers: _printers}) |
| | | } else if (data && data.cmd === 'getPrinters' && data.message) { |
| | | resolve({status: false, printers: null, message: data.message}) |
| | | } |
| | | } |
| | | |
| | | socket.onerror = () => { |
| | | let tool = item.verify.linkUrl |
| | | if (item.verify.linkUrl === '127.0.0.1:13529') { |
| | | let tool = link |
| | | |
| | | if (link === '127.0.0.1:13529') { |
| | | tool = '明科通讯组件' |
| | | } else if (item.verify.linkUrl === '127.0.0.1:13528') { |
| | | } else if (link === '127.0.0.1:13528') { |
| | | tool = 'CAINIAO打印组件' |
| | | } |
| | | notification.warning({ |
| | | top: 92, |
| | | message: '无法连接到: ' + tool, |
| | | duration: 5 |
| | | }) |
| | | |
| | | resolve({status: false, printers: null, message: '无法连接到: ' + tool}) |
| | | |
| | | } |
| | | }) |
| | | }) |
| | | |
| | | Promise.all(defers).then(results => { |
| | | let res = results.filter(item => item.status)[0] |
| | | if (res) { |
| | | links.forEach(link => { |
| | | window.GLOB.UserCacheMap.set(link, res.printers) |
| | | }) |
| | | } else { |
| | | notification.warning({ |
| | | top: 92, |
| | | message: results[0].message, |
| | | duration: 5 |
| | | }) |
| | | } |
| | | }) |
| | | } |