|
@@ -31,7 +31,7 @@ async function syncSessionWithIdToken(token){
|
|
|
// 通过用户的 id_token 初始化之后获取用户信息
|
|
|
|
|
|
let authenticationClient = new AuthenticationClient({
|
|
|
- appId: '669b25e1731d50c59f5494d1',
|
|
|
+ appId: '6682ab96b7bd5db59d6785a0',
|
|
|
appHost: 'https://textbook.u2-dev.hep.com.cn', // 应用的认证地址
|
|
|
token: token
|
|
|
})
|
|
@@ -43,8 +43,10 @@ async function syncSessionWithIdToken(token){
|
|
|
let sessionObjectId = generateObjectId(user?.id+user?.token);
|
|
|
let username = user?.username || user?.phone || user?.email
|
|
|
let ParseExistUser = await getParseUserByAuthingUser(user);
|
|
|
- // console.log("ParseExistUser",ParseExistUser);
|
|
|
let userId = ParseExistUser?.objectId || user?.id;
|
|
|
+ console.log("userId",userId);
|
|
|
+ console.log("authingUser",user);
|
|
|
+ console.log("ParseExistUser",ParseExistUser);
|
|
|
let syncSessionSQL = `
|
|
|
INSERT INTO "_User" (
|
|
|
"objectId", "username","mobile","phone", "createdAt", "updatedAt",
|
|
@@ -88,7 +90,7 @@ async function syncSessionWithIdToken(token){
|
|
|
try {
|
|
|
// 查询:数据库版本信息
|
|
|
let data = await pgClient().any(syncSessionSQL,params);
|
|
|
- // console.log(data)
|
|
|
+ console.log("session sql",data)
|
|
|
return {
|
|
|
sid:sessionObjectId,
|
|
|
uid:user?.id,
|
|
@@ -111,6 +113,7 @@ async function getParseUserByAuthingUser(user){
|
|
|
"username"=$3 OR
|
|
|
"username"=$4 OR
|
|
|
"username"=$5 OR
|
|
|
+ "username"=$6 OR
|
|
|
("mobile" IS NOT NULL AND "mobile" = $4) OR
|
|
|
("phone" IS NOT NULL AND "phone" = $4) OR
|
|
|
("mobile" IS NOT NULL AND "mobile" = $5) OR
|
|
@@ -118,17 +121,17 @@ async function getParseUserByAuthingUser(user){
|
|
|
("email" IS NOT NULL AND "email" = $6)
|
|
|
`
|
|
|
let params = [
|
|
|
- user?.id,
|
|
|
- user?.externalId,
|
|
|
- user?.username,
|
|
|
- user?.phone,
|
|
|
- user?.mobile,
|
|
|
- user?.email
|
|
|
+ user?.id, //1
|
|
|
+ user?.externalId,//2
|
|
|
+ user?.username,//3
|
|
|
+ user?.phone,//4
|
|
|
+ user?.mobile,//5
|
|
|
+ user?.email//6
|
|
|
]
|
|
|
let data = []
|
|
|
try{
|
|
|
data = await pgClient().any(sql,params);
|
|
|
- // console.log("data",data)
|
|
|
+ console.log("data same user:",data)
|
|
|
if(data?.length){
|
|
|
return data[0]
|
|
|
}
|
|
@@ -141,6 +144,8 @@ async function getParseUserByAuthingUser(user){
|
|
|
|
|
|
const crypto = require('crypto');
|
|
|
function generateObjectId(inputString) {
|
|
|
+ inputString = inputString || ""
|
|
|
+ inputString = String(inputString)
|
|
|
const hash = crypto.createHash('sha256').update(inputString).digest('hex');
|
|
|
const objectId = hash;
|
|
|
return objectId;
|