11.30

App.vue

@@ -1,9 +1,11 @@
 <script>
+	import {conn} from './utils/WebIM';
 	import {index} from "@/units/inquire.js"
 	export default {
 		onLaunch: function() {
 			setTimeout(() => {
 				if (uni.getStorageSync("token")) {
+					this.HXlogin()
 					/* if (uni.getStorageSync("company_id") == 0) {
 						if (getCurrentPages()[0].route != 'pages/login/login') {
 							uni.reLaunch({
@@ -35,6 +37,24 @@
 		},
 		onHide: function() {
 
+		},
+		methods: {
+			HXlogin() {
+				if(uni.getStorageSync('user_no') && uni.getStorageSync('pwd')) {
+					var user_no = uni.getStorageSync('user_no')
+					var pwd = uni.getStorageSync('pwd')
+					conn.open({
+						user: user_no,
+						pwd: pwd,
+						appKey: conn.appkey
+					}).then(() => {
+						console.log('res');
+					}).catch(reason => {
+						console.log('失败',reason);
+					})
+					
+				}
+ 			}
 		}
 	}
 </script>

main.js

@@ -2,10 +2,13 @@ import App from './App'
 import Vue from 'vue'
 import './uni.promisify.adaptor'
 import uView from "uview-ui";
+import WebIM from './newSDK/Easemob-chat.js'
+import {conn} from './utils/WebIM';
 Vue.use(uView);
 Vue.config.productionTip = false
 App.mpType = 'app'
 const app = new Vue({
+	WebIM,
   ...App
 })
 app.$mount()

pages/login/login.vue

@@ -28,6 +28,7 @@
 </template>
 
 <script>
+	import {conn} from '@/utils/WebIM.js'
 	import {
 		third,
 		third_mobile
@@ -70,6 +71,18 @@
 								code: res.code
 							}).then(res => {
 								that.$u.toast("登录成功")
+								var options = {
+								  user: res.data.userinfo.user_no,
+								  pwd: res.data.userinfo.emchat_password,
+								  appKey: conn.appkey,
+								  success: function (res2) {
+									uni.setStorageSync('user_no',res.data.userinfo.user_no)
+									uni.setStorageSync('pwd',res.data.userinfo.emchat_password)
+								  },
+								  error: function(){
+								  }
+								};
+								conn.open(options);
 								console.log(res);
 								if (res.data.is_mobile == 1) {
 									uni.setStorageSync("token", res.data.userinfo.token)

utils/Dispatcher.js

@@ -0,0 +1,37 @@
+var dispCbs = [];
+var dispIns = [];
+
+function Dispatcher() {
+  dispIns.push(this);
+  dispCbs.push({});
+}
+
+Dispatcher.prototype = {
+  on(type, cb) {
+    let cbtypes = dispCbs[dispIns.indexOf(this)];
+    let cbs = cbtypes[type] = cbtypes[type] || [];
+    if (!~cbs.indexOf(cb)) {
+		cbs.push(cb);
+    }
+  },
+
+  off(type, cb) {
+    let cbtypes = dispCbs[dispIns.indexOf(this)];
+    let cbs = cbtypes[type] = cbtypes[type] || [];
+    let curTypeCbIdx = cbs.indexOf(cb);
+    if (~curTypeCbIdx) {
+      cbs.splice(curTypeCbIdx, 1);
+    }
+  },
+
+  fire(type, ...args) {
+    let cbtypes = dispCbs[dispIns.indexOf(this)];
+    let cbs = cbtypes[type] = cbtypes[type] || [];
+
+    for (let i = 0; i < cbs.length; i++) {
+      cbs[i].apply(null, args);
+    }
+  }
+
+};
+module.exports = Dispatcher;

utils/WebIM.js

@@ -0,0 +1,76 @@
+import WebIM from '../newSDK/Easemob-chat.js'
+import config from './WebIMConfig.js'
+
+//初始化
+let conn = {};
+WebIM.config = config;
+conn = WebIM.conn = new WebIM.connection({
+    appKey: config.appkey,
+     https: true, //是否使用HTTPS
+     url: "wss://im-api-wechat.easemob.com/websocket", // socket server (3.0 SDK)
+     apiUrl: "https://a1.easemob.com", // rest server
+     heartBeatWait: 30000, //心跳间隔
+     autoReconnectNumMax: 5, //自动重连次数
+     useOwnUploadFun: false, // 是否使用自己的上传方式（如将图片文件等上传到自己的服务器，构建消息时只传url）
+// WebIM.config 为之前集成里介绍的WebIMConfig.js
+})
+
+let login = false
+
+//回调
+conn.listen({
+    onOpened: function ( message ) {
+        console.log('环信登录成功');
+    },         //连接成功回调 
+    onClosed: function ( message ) {
+        console.log('环信断开链接');
+		this.$u.toast('你已在其他地方登录')
+    },         //连接关闭回调
+    onTextMessage: function ( message ) {},    //收到文本消息
+    onEmojiMessage: function ( message ) {
+        
+    },   //收到表情消息
+    onPictureMessage: function ( message ) {}, //收到图片消息
+    onCmdMessage: function ( message ) {},     //收到命令消息
+    onAudioMessage: function ( message ) {},   //收到音频消息
+    onLocationMessage: function ( message ) {},//收到位置消息
+    onFileMessage: function ( message ) {},    //收到文件消息
+    onVideoMessage: function (message) {
+        var node = document.getElementById('privateVideo');
+        var option = {
+            url: message.url,
+            headers: {
+              'Accept': 'audio/mp4'
+            },
+            onFileDownloadComplete: function (response) {
+                var objectURL = WebIM.utils.parseDownloadResponse.call(conn, response);
+                node.src = objectURL;
+            },
+            onFileDownloadError: function () {
+                console.log('File down load error.')
+            }
+        };
+        WebIM.utils.download.call(conn, option);
+    },   //收到视频消息
+    onPresence: function ( message ) {},       //处理“广播”或“发布-订阅”消息，如联系人订阅请求、处理群组、聊天室被踢解散等消息
+    onRoster: function ( message ) {},         //处理好友申请
+    onInviteMessage: function ( message ) {},  //处理群组邀请
+    onOnline: function () {},                  //本机网络连接成功
+    onOffline: function () {},                 //本机网络掉线
+    onError: function ( message ) {},          //失败回调
+    onBlacklistUpdate: function (list) {       //黑名单变动
+        // 查询黑名单，将好友拉黑，将好友从黑名单移除都会回调这个函数，list则是黑名单现有的所有好友信息
+        console.log(list);
+    },
+    onRecallMessage: function(message){},      //收到撤回消息回调
+    onReceivedMessage: function(message){},    //收到消息送达服务器回执
+    onDeliveredMessage: function(message){
+
+    },   //收到消息送达客户端回执
+    onReadMessage: function(message){},        //收到消息已读回执
+    onCreateGroup: function(message){},        //创建群组成功回执（需调用createGroupNew）
+    onMutedMessage: function(message){},       //如果用户在A群组被禁言，在A群发消息会走这个回调并且消息不会传递给群其它成员
+    onChannelMessage: function(message){}      //收到整个会话已读的回执，在对方发送channel ack时会在这个回调里收到消息
+});
+
+export {conn};

utils/WebIMConfig.js

@@ -0,0 +1,96 @@
+/**
+ * git do not control webim.config.js
+ * everyone should copy webim.config.js to webim.config.js
+ * and have their own configs.
+ * In this way , others won't be influenced by this config while git pull.
+ *
+ */
+// for react native
+let location = {
+  protocol: "https"
+};
+let config = {
+  /*
+   * XMPP server
+   */
+
+  // xmppURL: "wss://im-api-new-hsb.easemob.com/websocket",// websdk 3.0 server 沙箱（测试用）
+  
+  // xmppURL: "wss://im-api.easemob.com/ws",  //小程序sdk 2.0 server
+
+  // xmppURL: 'wss://im-api-wechat.easemob.com/websocket', //小程序3.0 server 线上 小程序和原生客户端使用这个
+  
+  // xmppURL: 'wss://im-api-v2-hsb-alipay.easemob.com/websocket', // 支付宝沙箱 （测试用）
+  
+    // xmppURL: 'wss://im-api-alipay.easemob.com/websocket', // 支付宝线上 支付宝小程序请使用这个地址
+  
+  /*
+   * Backend REST API URL
+   */
+  // apiURL: (location.protocol === 'https:' ? 'https:' : 'http:') + '//a1.easemob.com',
+  // ios must be https!!! by lwz
+  apiURL: "https://a1.easemob.com",
+  
+  // apiURL: 'https://192.168.43.137:8080', // 支付宝测试
+  // apiURL: (location.protocol === 'https:' ? 'https:' : 'http:') + '//172.17.3.155:8080',
+
+  /*
+   * Application AppKey
+   */
+  appkey: "1145230719209454#neihe",
+
+  /*
+   * Whether to use HTTPS      '1177161227178308#xcx'
+   * @parameter {Boolean} true or false
+   */
+  https: false,
+
+  /*
+   * isMultiLoginSessions
+   * true: A visitor can sign in to multiple webpages and receive messages at all the webpages.
+   * false: A visitor can sign in to only one webpage and receive messages at the webpage.
+   */
+  isMultiLoginSessions: false,
+
+  /**
+   * Whether to use window.doQuery()
+   * @parameter {Boolean} true or false
+   */
+  isWindowSDK: false,
+
+  /**
+   * isSandBox=true:  xmppURL: 'im-api.sandbox.easemob.com',  apiURL: '//a1.sdb.easemob.com',
+   * isSandBox=false: xmppURL: 'im-api.easemob.com',          apiURL: '//a1.easemob.com',
+   * @parameter {Boolean} true or false
+   */
+  isSandBox: false,
+
+  /**
+   * Whether to console.log in strophe.log()
+   * @parameter {Boolean} true or false
+   */
+  isDebug: false,
+
+  /**
+   * will auto connect the xmpp server autoReconnectNumMax times in background when client is offline.
+   * won't auto connect if autoReconnectNumMax=0.
+   */
+  autoReconnectNumMax: 2,
+
+  /**
+   * the interval secons between each atuo reconnectting.
+   * works only if autoReconnectMaxNum >= 2.
+   */
+  autoReconnectInterval: 2,
+
+  /**
+   * webrtc supports WebKit and https only
+   */
+  isWebRTC: false,
+
+  /*
+   * Set to auto sign-in
+   */
+  isAutoLogin: true
+};
+export default config;

utils/broadcast.js

@@ -0,0 +1,3 @@
+var Dispatcher = require("./Dispatcher.js");
+
+module.exports = new Dispatcher();

utils/index.js

@@ -0,0 +1,16 @@
+export function renderTime(time) {
+    var t = new Date(parseInt(time));
+    var Y = t.getFullYear();
+    var M = t.getMonth() + 1 < 10 ? '0' + (t.getMonth() + 1) : t.getMonth() + 1;
+    var D = t.getDate() < 10 ? '0' + t.getDate() : t.getDate();
+    var H = t.getHours() < 10 ? '0' + t.getHours() : t.getHours();
+    var F = t.getMinutes() < 10 ? '0' + t.getMinutes() : t.getMinutes();
+    var S = t.getSeconds() < 10 ? '0' + t.getSeconds() : t.getSeconds();
+    return `${M}-${D} ${H}:${F}`;
+}
+
+export function readablizeBytes(value) {
+    let s = ['Bytes', 'KB', 'MB', 'GB', 'TB', 'PB'];
+    let e = Math.floor(Math.log(value) / Math.log(1024));
+    return (value / Math.pow(1024, Math.floor(e))).toFixed(2) + ' ' + s[e];
+}