|
@@ -26,7 +26,6 @@ class WeixinController extends Controller {
|
|
|
// token - url带上token参数重定向到原始地址
|
|
|
async auth() {
|
|
|
const { redirect_uri, code, test, type, response_type = 'store', uid, qrcode, msgid, objid } = this.ctx.query;
|
|
|
- console.log(`code=${code}`);
|
|
|
if (test) {
|
|
|
return await this.authTest();
|
|
|
}
|
|
@@ -45,7 +44,6 @@ class WeixinController extends Controller {
|
|
|
const state = uuid();
|
|
|
const key = `visit:auth:state:${state}`;
|
|
|
const val = JSON.stringify({ redirect_uri, type, uid, qrcode, msgid, objid });
|
|
|
- console.log(`key=>${key}`);
|
|
|
await this.app.redis.set(key, val, 'EX', 600);
|
|
|
|
|
|
// TODO: 生成回调地址
|
|
@@ -54,23 +52,18 @@ class WeixinController extends Controller {
|
|
|
const to_uri = encodeURI(`${wxapi.baseUrl}/api/auth?appid=${wxapi.appid}&response_type=code&redirect_uri=${backUrl}#wechat`);
|
|
|
// const backUrl = encodeURI(`${this.app.config.baseUrl}${this.config.authUrl}/`);
|
|
|
// const to_uri = `https://open.weixin.qq.com/connect/oauth2/authorize?appid=${wxapi.appid}&response_type=code&scope=snsapi_base&redirect_uri=${backUrl}&state=${state}&connect_redirect=1#wechat_redirect`;
|
|
|
- console.log('url-->' + to_uri);
|
|
|
this.ctx.redirect(to_uri);
|
|
|
}
|
|
|
|
|
|
// GET 认证回调
|
|
|
async authBack({ code, state }) {
|
|
|
// const { code, state, type, redirecturi } = this.ctx.query;
|
|
|
- console.log(this.ctx.query);
|
|
|
this.ctx.logger.debug(`[auth-back] code - ${code}, state - ${state}`);
|
|
|
assert(code, 'code不能为空');
|
|
|
assert(state, 'state不能为空');
|
|
|
- console.log('code-->' + code);
|
|
|
const { weixin } = this.ctx.service;
|
|
|
const key = `visit:auth:state:${state}`;
|
|
|
const val = await this.app.redis.get(key);
|
|
|
- console.log(key);
|
|
|
- console.log(val);
|
|
|
let openid;
|
|
|
try {
|
|
|
({ openid } = await weixin.fetch(code));
|
|
@@ -78,41 +71,31 @@ class WeixinController extends Controller {
|
|
|
await this.ctx.render('error.njk', { title: err.message, message: err.details });
|
|
|
return;
|
|
|
}
|
|
|
- console.log('function in');
|
|
|
- console.log('openid--->' + openid);
|
|
|
if (openid) {
|
|
|
|
|
|
const { redirect_uri, type, uid, qrcode, msgid, objid } = JSON.parse(val);
|
|
|
- console.log('redirect_uri-->' + redirect_uri);
|
|
|
const user = await this.ctx.service.user.findByOpenid(openid);
|
|
|
- console.log('type-->' + type);
|
|
|
if (type === '0') {
|
|
|
// 通过openid取得用户信息
|
|
|
if (user) {
|
|
|
const token = await this.ctx.service.login.createJwt(user);
|
|
|
- console.log('token-->' + token);
|
|
|
- console.log('user.type-->' + user.type);
|
|
|
if (user.type === '4') {
|
|
|
const to_uri = urljoin(redirect_uri, `?token=${token}`);
|
|
|
// TODO: 重定性页面
|
|
|
- console.log('to_uri000-->' + to_uri);
|
|
|
this.ctx.redirect(to_uri);
|
|
|
} else if (user.type === '1') {
|
|
|
const touri = `${this.app.config.baseUrl}/mobiledirtea`;
|
|
|
const to_uri = urljoin(touri, `?token=${token}`);
|
|
|
// TODO: 重定性页面
|
|
|
- console.log('to_uri000-->' + to_uri);
|
|
|
this.ctx.redirect(to_uri);
|
|
|
} else if (user.type === '3') {
|
|
|
const touri = `${this.app.config.baseUrl}/mobiledirtea`;
|
|
|
const to_uri = urljoin(touri, `?token=${token}`);
|
|
|
// TODO: 重定性页面
|
|
|
- console.log('to_uri000-->' + to_uri);
|
|
|
this.ctx.redirect(to_uri);
|
|
|
}
|
|
|
|
|
|
} else {
|
|
|
- console.log('rrr0000--->' + redirect_uri);
|
|
|
// const resunionid = await weixin.fetchUnionID(openid);
|
|
|
const touri = `${this.app.config.baseUrl}/student/bind`;
|
|
|
const to_uri = urljoin(touri, `?openid=${openid}`); // &unionid=${resunionid.unionid}
|
|
@@ -122,18 +105,15 @@ class WeixinController extends Controller {
|
|
|
} else if (type === '1') {
|
|
|
const to_uri = urljoin(redirect_uri, `?openid=${openid}&uid=${uid}&type=${type}&qrcode=${qrcode}`);
|
|
|
// TODO: 重定性页面
|
|
|
- console.log('1111---?' + to_uri);
|
|
|
this.ctx.redirect(to_uri);
|
|
|
} else if (type === '2') {
|
|
|
const to_uri = urljoin(redirect_uri, `?openid=${openid}&type=${type}&qrcode=${qrcode}`);
|
|
|
// TODO: 重定性页面
|
|
|
- console.log('22222---?' + to_uri);
|
|
|
this.ctx.redirect(to_uri);
|
|
|
} else if (type === '9') {
|
|
|
// const token = await this.ctx.service.login.createJwt(user);
|
|
|
const to_uri = urljoin(redirect_uri, `?openid=${openid}&type=${type}&msgid=${msgid}&objid=${objid}`);
|
|
|
// TODO: 重定性页面
|
|
|
- console.log('99999---?' + to_uri);
|
|
|
this.ctx.redirect(to_uri);
|
|
|
}
|
|
|
}
|
|
@@ -152,24 +132,19 @@ class WeixinController extends Controller {
|
|
|
// 通过openid取得用户信息
|
|
|
if (user) {
|
|
|
const token = await this.ctx.service.login.createJwt(user);
|
|
|
- console.log('token-->' + token);
|
|
|
- console.log('user.type-->' + user.type);
|
|
|
if (user.type === '4') {
|
|
|
const to_uri = urljoin(redirect_uri, `?token=${token}`);
|
|
|
// TODO: 重定性页面
|
|
|
- console.log('to_uri000-->' + to_uri);
|
|
|
this.ctx.redirect(to_uri);
|
|
|
} else if (user.type === '1') {
|
|
|
const touri = `${this.app.config.baseUrl}/mobiledirtea`;
|
|
|
const to_uri = urljoin(touri, `?token=${token}`);
|
|
|
// TODO: 重定性页面
|
|
|
- console.log('to_uri000-->' + to_uri);
|
|
|
this.ctx.redirect(to_uri);
|
|
|
} else if (user.type === '3') {
|
|
|
const touri = `${this.app.config.baseUrl}/mobiledirtea`;
|
|
|
const to_uri = urljoin(touri, `?token=${token}`);
|
|
|
// TODO: 重定性页面
|
|
|
- console.log('to_uri000-->' + to_uri);
|
|
|
this.ctx.redirect(to_uri);
|
|
|
}
|
|
|
|
|
@@ -208,6 +183,9 @@ class WeixinController extends Controller {
|
|
|
if (!login) this.ctx.ok(appopenid);
|
|
|
console.warn('-------');
|
|
|
console.warn(`openid=>${appopenid}`);
|
|
|
+ const state = uuid();
|
|
|
+ const key = `appopenid:${state}`;
|
|
|
+ await this.app.redis.set(key, appopenid, 'EX', 600);
|
|
|
const res = await this.ctx.service.user.findByAppOpenid(appopenid);
|
|
|
console.warn({ user: res, openid: appopenid });
|
|
|
this.ctx.ok({ user: res, openid: appopenid });
|