users.js
3.5 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
const router = require('koa-router')()
var userContoller = require('../controller/userController')
var status = require('../util/resTemplate')
const inspectMediaChannelKey = require('../util/inspectMediaChannelKey')
const shellUtil = require('../util/Agora_Recording_SDK_for_Linux_FULL/samples/shellUtil')
router.prefix('/users')
/**
* 添加用户
*/
router.post('/addUser',async (ctx, next) => {
try{
var data = await userContoller.addUser(ctx, next);
status.successTemp(ctx,200,data);
}catch(e){
console.log(e)
status.catchError(ctx,400,e.message);
}
})
/**
* 用户登录
*/
router.post('/login',async(ctx, next)=>{
try{
var data = await userContoller.login(ctx, next);
status.successTemp(ctx,200,data);
}catch(e){
status.catchError(ctx,400,e.message);
}
})
router.get('/authLogin.html', async function(ctx, next){
let type = ctx.request.query.type;
if(type == "GITHUB"){
await ctx.redirect(`https://github.com/login/oauth/authorize?client_id=${config.github.client_id}&state=${Date.now()}&redirect_uri=${config.host}${config.github.redirect_url}`);
}else{
await ctx.redirect(`https://graph.qq.com/oauth2.0/authorize?response_type=code&client_id=${config.qq.appId}&state=${Date.now()}&redirect_uri=${config.host}${h}`);
}
});
/**
*获取用户列表
*/
router.post('/getUser',async(ctx, next)=>{
try{
var data = await userContoller.getStu(ctx, next);
status.successTemp(ctx,200,data);
}catch(e){
status.catchError(ctx,400,e.message);
}
})
/**
* 修改用户信息
*/
router.put('/updateUserByUserId/:userId',async(ctx, next)=>{
try{
let updateBackData = await userContoller.updateUserByUserId(ctx, next);
status.successTemp(ctx,200,updateBackData);
}catch(e){
console.log(e)
status.catchError(ctx,400,e.message);
}
})
/**
* 重置密码
*/
router.put('/resetPasswordByUserId/:userId',async(ctx, next)=>{
try{
let updateBackData = await userContoller.resetPasswordByUserId(ctx, next);
status.successTemp(ctx,200,updateBackData);
}catch(e){
console.log(e)
status.catchError(ctx,400,e.message);
}
})
/**
* 删除用户
*/
router.delete('/delUserByUserId/:userId',async(ctx, next)=>{
try{
let delData = await userContoller.delUserByUserId(ctx, next);
status.successTemp(ctx,200,delData);
}catch(e){
console.log(e)
status.catchError(ctx,400,e.message);
}
})
/**
* 根据手机号验证码修改密码
*/
router.put('/updatePwByTelphone',async(ctx, next)=>{
try{
let delData = await userContoller.updatePwByTelphone(ctx, next);
status.successTemp(ctx,200,delData);
}catch(e){
console.log(e)
status.catchError(ctx,400,e.message);
}
})
/**
* 加密token
*/
router.post('/encryptionToken',async (ctx, next) => {
try{
let body = ctx.request.body;
let inspectMediaChannel = await inspectMediaChannelKey(body.appID,body.appCertificate,body.channel,body.uid)
ctx.response.status= 200;
ctx.response.body= inspectMediaChannel
}catch(e){
console.log(e)
status.catchError(ctx,400,e.message);
}
})
/**
*
*/
router.post('/Recording',async (ctx, next) => {
try{
let body = ctx.request.body;
console.log()
let Recording = await shellUtil.Recording(body.appID,body.uid,body.channel,body.channelKey)
ctx.response.status= 200;
ctx.response.body= {msg:Recording};
}catch(e){
console.log(e)
status.catchError(ctx,400,e.message);
}
})
module.exports = router