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;
下图是我测试的截图
uni-app 134同意添加好友实时通知