|
@@ -0,0 +1,253 @@
|
|
|
+const socketUrl = import.meta.env.VITE_COMMUNICATION_WEBSOCKET;
|
|
|
+const base64EncodeChars = 'ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/';
|
|
|
+const base64DecodeChars = new Array(
|
|
|
+ -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1,
|
|
|
+ -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1,
|
|
|
+ -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, -1, 62, -1, -1, -1, 63,
|
|
|
+ 52, 53, 54, 55, 56, 57, 58, 59, 60, 61, -1, -1, -1, -1, -1, -1,
|
|
|
+ -1, 0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14,
|
|
|
+ 15, 16, 17, 18, 19, 20, 21, 22, 23, 24, 25, -1, -1, -1, -1, -1,
|
|
|
+ -1, 26, 27, 28, 29, 30, 31, 32, 33, 34, 35, 36, 37, 38, 39, 40,
|
|
|
+ 41, 42, 43, 44, 45, 46, 47, 48, 49, 50, 51, -1, -1, -1, -1, -1);
|
|
|
+
|
|
|
+export class ConvergedCommunication {
|
|
|
+ private retryCount;
|
|
|
+ public socket;
|
|
|
+ public svr;
|
|
|
+ public port;
|
|
|
+ public userid;
|
|
|
+ public openchannelid;
|
|
|
+ // tmtype设置模板样式。
|
|
|
+ public tmtype;
|
|
|
+ // wndid设置在几号窗口接收openchannelid的图像
|
|
|
+ public wndid;
|
|
|
+ // top置顶窗口是否置顶:top="1":窗口置顶,top="0":窗口不置顶。
|
|
|
+ public top;
|
|
|
+ // x指定窗口的左边的位置。
|
|
|
+ public x;
|
|
|
+ // y指定窗口的顶部的位置。
|
|
|
+ public y;
|
|
|
+ // width指定窗口的宽度。
|
|
|
+ public width;
|
|
|
+ // height指定窗口的高度。
|
|
|
+ public height;
|
|
|
+ // visible窗口是否显示 1显示
|
|
|
+ public visible;
|
|
|
+ // showcaption设置是否显示标题栏 1显示
|
|
|
+ public showcaption;
|
|
|
+
|
|
|
+ // 初始化
|
|
|
+ constructor() {
|
|
|
+ this.svr = '19.152.196.106';
|
|
|
+ this.port = '4222';
|
|
|
+ this.userid = 'Of18NRTvjjpugOx37pezInXhuL0OEksX';
|
|
|
+ this.openchannelid = 'cs0001@xf_00';
|
|
|
+ this.tmtype = '4';
|
|
|
+ this.wndid = '0';
|
|
|
+ this.top = '1';
|
|
|
+ this.x = '20';
|
|
|
+ this.y = '20';
|
|
|
+ this.width = '960';
|
|
|
+ this.height = '540';
|
|
|
+ this.visible = '1';
|
|
|
+ this.showcaption = '1';
|
|
|
+ this.openSocket();
|
|
|
+ }
|
|
|
+
|
|
|
+ openSocket() {
|
|
|
+ if (this.socket != null) {
|
|
|
+ this.socket.close();
|
|
|
+ this.socket = null;
|
|
|
+ }
|
|
|
+
|
|
|
+ this.socket = new WebSocket(socketUrl);
|
|
|
+
|
|
|
+ this.socket.onopen = () => {
|
|
|
+ console.log('onopen');
|
|
|
+ };
|
|
|
+
|
|
|
+ this.socket.onclose = () => {
|
|
|
+ console.log('onclose');
|
|
|
+ };
|
|
|
+
|
|
|
+ this.socket.onmessage = (message) => {
|
|
|
+ console.log('onmessage: ', message);
|
|
|
+ };
|
|
|
+
|
|
|
+ this.socket.onerror = () => {
|
|
|
+ console.log('onerror');
|
|
|
+ this.restartSocket();
|
|
|
+ };
|
|
|
+ }
|
|
|
+ startSocket() {
|
|
|
+ this.openSocket();
|
|
|
+ }
|
|
|
+
|
|
|
+ restartSocket() {
|
|
|
+ this.retryCount++;
|
|
|
+ console.log('第' + this.retryCount + '次重连.');
|
|
|
+ setTimeout(() => {
|
|
|
+ this.openSocket();
|
|
|
+ }, 1000);
|
|
|
+ }
|
|
|
+
|
|
|
+ stopSocket() {
|
|
|
+ if (this.socket != null) {
|
|
|
+ this.socket.close();
|
|
|
+ this.socket = null;
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ base64encode(str) {
|
|
|
+ let out, i, len;
|
|
|
+ let c1, c2, c3;
|
|
|
+ len = str.length;
|
|
|
+ i = 0;
|
|
|
+ out = '';
|
|
|
+ while (i < len) {
|
|
|
+ c1 = str.charCodeAt(i++) & 0xff;
|
|
|
+ if (i == len) {
|
|
|
+ out += base64EncodeChars.charAt(c1 >> 2);
|
|
|
+ out += base64EncodeChars.charAt((c1 & 0x3) << 4);
|
|
|
+ out += '==';
|
|
|
+ break;
|
|
|
+ }
|
|
|
+ c2 = str.charCodeAt(i++);
|
|
|
+ if (i == len) {
|
|
|
+ out += base64EncodeChars.charAt(c1 >> 2);
|
|
|
+ out += base64EncodeChars.charAt(((c1 & 0x3) << 4) | ((c2 & 0xF0) >> 4));
|
|
|
+ out += base64EncodeChars.charAt((c2 & 0xF) << 2);
|
|
|
+ out += '=';
|
|
|
+ break;
|
|
|
+ }
|
|
|
+ c3 = str.charCodeAt(i++);
|
|
|
+ out += base64EncodeChars.charAt(c1 >> 2);
|
|
|
+ out += base64EncodeChars.charAt(((c1 & 0x3) << 4) | ((c2 & 0xF0) >> 4));
|
|
|
+ out += base64EncodeChars.charAt(((c2 & 0xF) << 2) | ((c3 & 0xC0) >> 6));
|
|
|
+ out += base64EncodeChars.charAt(c3 & 0x3F);
|
|
|
+ }
|
|
|
+ return out;
|
|
|
+ }
|
|
|
+
|
|
|
+ base64decode(str) {
|
|
|
+ let c1, c2, c3, c4;
|
|
|
+ let i, len, out;
|
|
|
+ len = str.length;
|
|
|
+ i = 0;
|
|
|
+ out = '';
|
|
|
+ while (i < len) {
|
|
|
+ /* c1 */
|
|
|
+ do {
|
|
|
+ c1 = base64DecodeChars[str.charCodeAt(i++) & 0xff];
|
|
|
+ } while (i < len && c1 == -1);
|
|
|
+ if (c1 == -1)
|
|
|
+ break;
|
|
|
+ /* c2 */
|
|
|
+ do {
|
|
|
+ c2 = base64DecodeChars[str.charCodeAt(i++) & 0xff];
|
|
|
+ } while (i < len && c2 == -1);
|
|
|
+ if (c2 == -1)
|
|
|
+ break;
|
|
|
+ out += String.fromCharCode((c1 << 2) | ((c2 & 0x30) >> 4));
|
|
|
+ /* c3 */
|
|
|
+ do {
|
|
|
+ c3 = str.charCodeAt(i++) & 0xff;
|
|
|
+ if (c3 == 61)
|
|
|
+ return out;
|
|
|
+ c3 = base64DecodeChars[c3];
|
|
|
+ } while (i < len && c3 == -1);
|
|
|
+ if (c3 == -1)
|
|
|
+ break;
|
|
|
+ out += String.fromCharCode(((c2 & 0XF) << 4) | ((c3 & 0x3C) >> 2));
|
|
|
+ /* c4 */
|
|
|
+ do {
|
|
|
+ c4 = str.charCodeAt(i++) & 0xff;
|
|
|
+ if (c4 == 61)
|
|
|
+ return out;
|
|
|
+ c4 = base64DecodeChars[c4];
|
|
|
+ } while (i < len && c4 == -1);
|
|
|
+ if (c4 == -1)
|
|
|
+ break;
|
|
|
+ out += String.fromCharCode(((c3 & 0x03) << 6) | c4);
|
|
|
+ }
|
|
|
+ return out;
|
|
|
+ }
|
|
|
+
|
|
|
+ utf16to8(str) {
|
|
|
+ let out, i, len, c;
|
|
|
+ out = '';
|
|
|
+ len = str.length;
|
|
|
+ for (i = 0; i < len; i++) {
|
|
|
+ c = str.charCodeAt(i);
|
|
|
+ if ((c >= 0x0001) && (c <= 0x007F)) {
|
|
|
+ out += str.charAt(i);
|
|
|
+ } else if (c > 0x07FF) {
|
|
|
+ out += String.fromCharCode(0xE0 | ((c >> 12) & 0x0F));
|
|
|
+ out += String.fromCharCode(0x80 | ((c >> 6) & 0x3F));
|
|
|
+ out += String.fromCharCode(0x80 | ((c >> 0) & 0x3F));
|
|
|
+ } else {
|
|
|
+ out += String.fromCharCode(0xC0 | ((c >> 6) & 0x1F));
|
|
|
+ out += String.fromCharCode(0x80 | ((c >> 0) & 0x3F));
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return out;
|
|
|
+ }
|
|
|
+
|
|
|
+ utf8to16(str) {
|
|
|
+ const len = str.length;
|
|
|
+ let out, i, c;
|
|
|
+ let char2, char3;
|
|
|
+ out = '';
|
|
|
+ i = 0;
|
|
|
+ while (i < len) {
|
|
|
+ c = str.charCodeAt(i++);
|
|
|
+ switch (c >> 4) {
|
|
|
+ case 0:
|
|
|
+ case 1:
|
|
|
+ case 2:
|
|
|
+ case 3:
|
|
|
+ case 4:
|
|
|
+ case 5:
|
|
|
+ case 6:
|
|
|
+ case 7:
|
|
|
+ // 0xxxxxxx
|
|
|
+ out += str.charAt(i - 1);
|
|
|
+ break;
|
|
|
+ case 12:
|
|
|
+ case 13:
|
|
|
+ // 110x xxxx 10xx xxxx
|
|
|
+ char2 = str.charCodeAt(i++);
|
|
|
+ out += String.fromCharCode(((c & 0x1F) << 6) | (char2 & 0x3F));
|
|
|
+ break;
|
|
|
+ case 14:
|
|
|
+ // 1110 xxxx 10xx xxxx 10xx xxxx
|
|
|
+ char2 = str.charCodeAt(i++);
|
|
|
+ char3 = str.charCodeAt(i++);
|
|
|
+ out += String.fromCharCode(((c & 0x0F) << 12) |
|
|
|
+ ((char2 & 0x3F) << 6) |
|
|
|
+ ((char3 & 0x3F) << 0));
|
|
|
+ break;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return out;
|
|
|
+ }
|
|
|
+
|
|
|
+ start() {
|
|
|
+ const str =
|
|
|
+ `-r svr="${this.svr}" port="${this.port}" userid="${this.port}" openchannelid="${this.openchannelid}"` +
|
|
|
+ `tmtype="${this.tmtype}" wndid="${this.wndid}" top="${this.top}" x="${this.x}" y="${this.y}"` +
|
|
|
+ `w="${this.width}" h="${this.height}" visible="${this.visible}" showcaption="${this.showcaption}"`;
|
|
|
+ const val = 'AVCON-OCX://' + this.base64encode(this.utf16to8(str));
|
|
|
+ if (str.match('-r') && str.match('startws="1"')) {
|
|
|
+ setTimeout(() => {
|
|
|
+ this.startSocket();
|
|
|
+ }, 5000);
|
|
|
+ }
|
|
|
+ // 创建一个a标签元素
|
|
|
+ const a = document.createElement('a');
|
|
|
+ // 设置a标签的href属性
|
|
|
+ a.href = val;
|
|
|
+ // 触发点击事件
|
|
|
+ a.click();
|
|
|
+ }
|
|
|
+}
|