uni-app 134同意添加好友实时通知

Posted 2021-12-28 2019ab

app/controller/apply.js

'use strict';

const Controller = require('egg').Controller;

class ApplyController extends Controller 
  // 申请添加好友
  async addFriend() 
    const  ctx,app  = this;
    // 拿到当前用户id
    let current_user_id = ctx.authUser.id;
    // 验证参数
     ctx.validate(
          friend_id:type: 'int', required: true,desc: '好友id',
          nickname:type: 'string', required: false, desc: '昵称',
          lookme:type: 'int', required: true, range:in:[0,1],desc: '看我',
          lookhim:type: 'int', required: true,range:in:[0,1], desc: '看他',
        );
        let friend_id,nickname,lookme,lookhim = ctx.request.body;
    // 不能添加自己
    if(current_user_id === friend_id)
        ctx.throw(400,'不能添加自己');
    
    // 对方是否存在
    let user = await app.model.User.findOne(
        where:
            id:friend_id,
            status:1
        
    )
    
    if(!user)
        ctx.throw(400,'该用户不存在或者已经被禁用');
    
    // 之前是否申请过了
    if(await app.model.Apply.findOne(
        where:
            user_id:current_user_id,
            friend_id,
            status:['pending','agree']
        
    ))
        ctx.throw(400,'你之前已经申请过了');
    
    // 创建申请
   let apply = await app.model.Apply.create(
        user_id:current_user_id,
        friend_id,
        lookhim,
        lookme,
        nickname
    );
    if(!apply)
        ctx.throw(400,'申请失败');
    
    ctx.apiSuccess(apply);
    // 消息推送 在线的话推送不在线不需要
    if(app.ws.user && app.ws.user[friend_id])
        app.ws.user[friend_id].send(JSON.stringify(
            msg:'updateApplyList'
        ));
    
  
  
  // 获取好友申请列表
  async list()
      const  ctx,app  = this;
      // 拿到当前用户id
      let current_user_id = ctx.authUser.id;
      
      let page = ctx.params.page ? parseInt(ctx.params.page) : 1;
      let limit = ctx.query.limit ? parseInt(ctx.query.limit) : 10;
      let offset = (page-1)*limit;
      let rows = await app.model.Apply.findAll(
          where:
              friend_id:current_user_id
          ,
          include:[
             model:app.model.User,
             attributes:['id','username','nickname','avatar']
          ],
          offset,
          limit,
          order:[
              ['id','DESC']
          ]
      )
      let count = await app.model.Apply.count(
          where:
              friend_id:current_user_id,
              status:'pending'
          
      );
      ctx.apiSuccess(rows,count);
  
  // 处理好友申请
  async handle()
     const  ctx,app  = this;
     // 拿到当前用户id
     let current_user_id = ctx.authUser.id;
     let id = parseInt(ctx.params.id); 
     // 验证参数
     ctx.validate(
          nickname:type: 'string', required: false, desc: '昵称',
          status:type: 'string', required: true,range:in:['refuse','agree','ignore'], desc: '处理结果',
          lookme:type: 'int', required: true, range:in:[0,1],desc: '看我',
          lookhim:type: 'int', required: true,range:in:[0,1], desc: '看他',
     );
     // 查询改申请是否存在
     let apply = await app.model.Apply.findOne(
         where:
             id,
             friend_id:current_user_id,
             status:'pending'
         ,
         include:[
             model:app.model.User
         ]
     );
     if(!apply)
         ctx.throw('400','该记录不存在');
     
     let status,nickname,lookhim,lookme = ctx.request.body;
   
     let transaction;
     try 
        // 开启事务
        transaction = await app.model.transaction();
    
        // 设置该申请状态
        await apply.update(
            status
        ,  transaction );
        // apply.status = status;
        // apply.save();
        // 同意，添加到好友列表
        if (status == 'agree') 
            // 加入到对方好友列表
            await app.model.Friend.create(
                friend_id: current_user_id,
                user_id: apply.user_id,
                nickname: apply.nickname,
                lookme: apply.lookme,
                lookhim: apply.lookhim,
            ,  transaction );
            // 将对方加入到我的好友列表
            await app.model.Friend.create(
                friend_id: apply.user_id,
                user_id: current_user_id,
                nickname,
                lookme,
                lookhim,
            ,  transaction );
        
        
        // 提交事务
        await transaction.commit();
        // 消息推送
        if(status == 'agree')
            let message = 
                id:(new Date()).getTime(), // 唯一id，后端生成唯一id
                from_avatar:ctx.authUser.avatar, // 发送者头像
                from_name:ctx.authUser.nickname || ctx.authUser.username,// 发送者昵称
                from_id:current_user_id,// 发送者id
                to_id:apply.user_id, // 接收人、群 id 
                to_name:nickname || apply.user.nickname || apply.user.username, // 接收人、群 名称
                to_avatar:apply.user.avatar, // 接收人、群 头像 
                chat_type:'user', // 接收类型
                type:'system',// 消息类型
                data:'你们已经是好友了，可以开始聊天了', // 消息内容
                options:, // 其他参数
                create_time:(new Date()).getTime(), // 创建时间
                isremove:0, // 是否撤回
            
            
            ctx.sendAndSaveMessage(apply.user_id,message);
            
            message.from_avatar = apply.user.avatar;
            message.from_name = nickname || apply.user.nickname || apply.user.username;
            message.from_id = apply.user.id;

            message.to_avatar = ctx.authUser.avatar;
            message.to_name = apply.nickname || ctx.authUser.nickname || ctx.authUser.username;
            message.to_id = current_user_id;

            ctx.sendAndSaveMessage(current_user_id,  ...message );
        
        
        // 消息推送
        return ctx.apiSuccess('操作成功');
      catch (e) 
        // 事务回滚
        await transaction.rollback();
        return ctx.apiFail('操作失败');
     
  


module.exports = ApplyController;

下图是我测试的截图

感谢大家观看，我们下次见