chat.js 4.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146
  1. import {
  2. YeIMUniSDK,
  3. YeIMUniSDKDefines
  4. } from '@/uni_modules/wzJun1-YeIM-Uni-SDK/js_sdk/yeim-uni-sdk.min.js'
  5. import {
  6. login
  7. } from '@/request/api/chat.js'
  8. import md5 from '@/js_sdk/js-md5/build/md5.min.js';
  9. let userIds;
  10. const connect = success => {
  11. let code = YeIMUniSDK.getInstance().readyState();
  12. if (code !== 3) {
  13. if (success) success();
  14. return;
  15. }
  16. YeIMUniSDK.getInstance().connect({
  17. userId: userIds,
  18. token: uni.getStorageSync('chatToken'),
  19. success: (response) => {
  20. if (response.code === 200) {
  21. if (success) success();
  22. }
  23. },
  24. fail: (err) => {
  25. console.log(err);
  26. }
  27. });
  28. }
  29. export default {
  30. init() {
  31. //初始化YeIMUniSDK
  32. uni.$YeIMUniSDKDefines = YeIMUniSDKDefines;
  33. uni.$YeIM = YeIMUniSDK.init({
  34. baseURL: 'https://www.waywish.com/im', // YeIMServer http url (如无特殊需求,服务端启动后仅需修改ip或者域名即可)
  35. socketURL: 'wss://www.waywish.com/im/im', // YeIMServer socket url(如无特殊需求,服务端启动后仅需修改ip或者域名即可)
  36. /**
  37. * 日志等级
  38. * 0 普通日志,日志量较多,接入时建议使用
  39. * 1 关键性日志,日志量较少,生产环境时建议使用
  40. * 2 无日志级别,SDK 将不打印任何日志
  41. */
  42. logLevel: 0, // 日志等级,
  43. reConnectInterval: 3000, // 重连时间间隔
  44. reConnectTotal: 99, // 最大重连次数,0不限制一直重连
  45. heartInterval: 35000, //心跳时间间隔(默认30s)
  46. });
  47. },
  48. connect(userId) {
  49. userIds = userId;
  50. if (!uni.getStorageSync('chatToken')) {
  51. let timestamp = (new Date()).getTime() + 86400 * 1000; //1000天后过期
  52. let sign = md5(String(userId) + timestamp + "50abd47112ebe8c5a73f4694c96a49ce");
  53. login({
  54. userId: userId,
  55. timestamp: timestamp,
  56. sign: sign
  57. }).then(res => {
  58. if (res.code === 200) {
  59. uni.setStorageSync('chatToken', res.data.token);
  60. connect();
  61. }
  62. })
  63. } else {
  64. connect();
  65. }
  66. },
  67. getConversationList(success) {
  68. connect(() => {
  69. YeIMUniSDK.getInstance().getConversationList({
  70. page: 1, //页码
  71. limit: 20, //每页数量
  72. success: success,
  73. fail: (err) => {}
  74. });
  75. });
  76. },
  77. getHistoryMessageList(nextMessageId, userId, success) {
  78. connect(() => {
  79. YeIMUniSDK.getInstance().getHistoryMessageList({
  80. nextMessageId: nextMessageId,
  81. conversationId: userId,
  82. success: success,
  83. fail: (err) => {}
  84. });
  85. });
  86. },
  87. sendImage(userId, success) {
  88. connect(() => {
  89. uni.chooseImage({
  90. count: 1, //图片数量
  91. sizeType: ['original', 'compressed'], //可以指定是原图还是压缩图,默认二者都有
  92. sourceType: ['album'], //从相册选择
  93. success: res => {
  94. uni.getImageInfo({
  95. src: res.tempFilePaths[0],
  96. success: image => {
  97. //创建图片消息
  98. let message = YeIMUniSDK.getInstance().createImageMessage({
  99. toId: userId, //接收者用户ID字符串
  100. conversationType: YeIMUniSDKDefines
  101. .CONVERSATION_TYPE
  102. .PRIVATE, //会话类型:私聊
  103. body: {
  104. file: {
  105. tempFilePath: res.tempFilePaths[
  106. 0], //本地图片临时路径
  107. width: image.width, //图片宽度
  108. height: image.height //图片高度
  109. }
  110. },
  111. extra: "",
  112. onProgress: (progress) => {}
  113. });
  114. //发送消息
  115. YeIMUniSDK.getInstance().sendMessage({
  116. message: message,
  117. success: success,
  118. fail: (err) => {}
  119. });
  120. }
  121. });
  122. }
  123. });
  124. });
  125. },
  126. sendText(userId, content, success) {
  127. connect(() => {
  128. //创建文字消息
  129. let message = YeIMUniSDK.getInstance().createTextMessage({
  130. toId: userId, //接收者用户ID字符串
  131. conversationType: YeIMUniSDKDefines.CONVERSATION_TYPE.PRIVATE, //会话类型:私聊
  132. body: {
  133. text: content //文本消息内容字符串
  134. },
  135. extra: ""
  136. });
  137. //发送消息
  138. YeIMUniSDK.getInstance().sendMessage({
  139. message: message,
  140. success: success,
  141. fail: (err) => {}
  142. });
  143. });
  144. }
  145. }