This commit is contained in:
parent
63888e2d64
commit
9fa6e2df71
|
@ -200,10 +200,11 @@ module.exports = function(Self) {
|
|||
const connector = this.dataSource.connector;
|
||||
let conn;
|
||||
let res;
|
||||
const opts = Object.assign({}, options);
|
||||
|
||||
try {
|
||||
if (userId) {
|
||||
if (!options.transaction) {
|
||||
options = Object.assign({}, options);
|
||||
conn = await new Promise((resolve, reject) => {
|
||||
connector.client.getConnection(function(err, conn) {
|
||||
if (err)
|
||||
|
@ -212,10 +213,7 @@ module.exports = function(Self) {
|
|||
resolve(conn);
|
||||
});
|
||||
});
|
||||
|
||||
const opts = Object.assign({}, options);
|
||||
if (!opts.transaction) {
|
||||
opts.transaction = {
|
||||
options.transaction = {
|
||||
connection: conn,
|
||||
connector
|
||||
};
|
||||
|
@ -223,15 +221,14 @@ module.exports = function(Self) {
|
|||
|
||||
await connector.executeP(
|
||||
'CALL account.myUser_loginWithName((SELECT name FROM account.user WHERE id = ?))',
|
||||
[userId], opts
|
||||
[userId], options
|
||||
);
|
||||
}
|
||||
|
||||
res = await connector.executeP(query, params, opts);
|
||||
res = await connector.executeP(query, params, options);
|
||||
|
||||
if (userId) {
|
||||
await connector.executeP('CALL account.myUser_logout()', null, opts);
|
||||
}
|
||||
if (userId)
|
||||
await connector.executeP('CALL account.myUser_logout()', null, options);
|
||||
} finally {
|
||||
if (conn) conn.release();
|
||||
}
|
||||
|
|
|
@ -21,7 +21,6 @@ module.exports = Self => {
|
|||
|
||||
Self.confirm = async(ctx, orderFk) => {
|
||||
const userId = ctx.req.accessToken.userId;
|
||||
console.log(orderFk, userId);
|
||||
const query = `CALL hedera.order_confirmWithUser(?, ?)`;
|
||||
const response = await Self.rawSql(query, [orderFk, userId], {userId});
|
||||
|
||||
|
|
Loading…
Reference in New Issue