|
@@ -9,27 +9,29 @@ export default {
|
|
|
* @param {Number} params.group_id 会话id
|
|
|
* @param {Number} params.client_hash 客户端上的最新消息的hash 【可为null】
|
|
|
*/
|
|
|
- getNewMsg (params) {
|
|
|
- return axios.request({
|
|
|
+ async getNewMsg (params) {
|
|
|
+ let res = await axios.request({
|
|
|
url: 'group/newMsg',
|
|
|
method: 'get',
|
|
|
needLogin: false,
|
|
|
params: params
|
|
|
- }).then(res => {
|
|
|
- const objMessage = new Message()
|
|
|
- objMessage.saveMsg(params['group_id'], res.data.data)
|
|
|
- // 解密数据
|
|
|
- res.data.data.list.forEach(item => {
|
|
|
- if (item.msg_type == 4) {
|
|
|
- // 针对红包类型
|
|
|
- item.msg = JSON.parse(decryptoMsg(item.msg))
|
|
|
- } else {
|
|
|
- item.msg = decryptoMsg(item.msg)
|
|
|
- }
|
|
|
- })
|
|
|
+ })
|
|
|
|
|
|
- return Promise.resolve(res)
|
|
|
+ const objMessage = new Message()
|
|
|
+ // 如果不同步执行,第一次初始化数据库会出现很奇怪的问题...
|
|
|
+ await objMessage.saveMsg(params['group_id'], res.data.data)
|
|
|
+
|
|
|
+ // 解密数据
|
|
|
+ res.data.data.list.forEach(item => {
|
|
|
+ if (item.msg_type == 4) {
|
|
|
+ // 针对红包类型
|
|
|
+ item.msg = JSON.parse(decryptoMsg(item.msg))
|
|
|
+ } else {
|
|
|
+ item.msg = decryptoMsg(item.msg)
|
|
|
+ }
|
|
|
})
|
|
|
+
|
|
|
+ return res
|
|
|
},
|
|
|
/**
|
|
|
* 群聊 获取历史消息【不需要登录】
|