Oak-Team
/
oak-pay-business
13
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 26 Wiki Activity

trigger的进一步修正

This commit is contained in:
Xu Chang 2024-07-17 17:22:46 +08:00
parent 5c6c180c0a
commit 96991b9ef0
3 changed files with 28 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
es/triggers/pay.js
View File

@ -267,8 +267,7 @@ const triggers = [
priority: 99,
fn: async ({ operation }, context, option) => {
const { data, filter, action, id } = operation;
assert(typeof filter.id === 'string');
const [pay] = await context.select('pay', {
const pays = await context.select('pay', {
data: {
id: 1,
orderId: 1,
@ -288,11 +287,14 @@ const triggers = [
},
filter,
}, { dontCollect: true });
const { orderId, depositId, iState, deposit, application } = pay;
context.saveOperationToEvent(id, `${DATA_SUBSCRIBER_KEYS.payStateChanged}-${filter.id}`);
if (orderId) {
return await changeOrderStateByPay({ id: orderId }, context, option);
for (const pay of pays) {
const { orderId, depositId, iState, deposit, application } = pay;
context.saveOperationToEvent(id, `${DATA_SUBSCRIBER_KEYS.payStateChanged}-${filter.id}`);
if (orderId) {
await changeOrderStateByPay({ id: orderId }, context, option);
}
}
return pays.length;
},
},
{

14
lib/triggers/pay.js
View File

@ -270,8 +270,7 @@ const triggers = [
priority: 99,
fn: async ({ operation }, context, option) => {
const { data, filter, action, id } = operation;
(0, assert_1.default)(typeof filter.id === 'string');
const [pay] = await context.select('pay', {
const pays = await context.select('pay', {
data: {
id: 1,
orderId: 1,
@ -291,11 +290,14 @@ const triggers = [
},
filter,
}, { dontCollect: true });
const { orderId, depositId, iState, deposit, application } = pay;
context.saveOperationToEvent(id, `${constants_1.DATA_SUBSCRIBER_KEYS.payStateChanged}-${filter.id}`);
if (orderId) {
return await changeOrderStateByPay({ id: orderId }, context, option);
for (const pay of pays) {
const { orderId, depositId, iState, deposit, application } = pay;
context.saveOperationToEvent(id, `${constants_1.DATA_SUBSCRIBER_KEYS.payStateChanged}-${filter.id}`);
if (orderId) {
await changeOrderStateByPay({ id: orderId }, context, option);
}
}
return pays.length;
},
},
{

20
src/triggers/pay.ts
View File

@ -292,9 +292,8 @@ const triggers: Trigger<EntityDict, 'pay', BRC>[] = [
priority: 99,
fn: async ({ operation }, context, option) => {
const { data, filter, action, id } = operation as EntityDict['pay']['Update'];
assert(typeof filter!.id === 'string');
const [pay] = await context.select('pay', {
const pays = await context.select('pay', {
data: {
id: 1,
orderId: 1,
@ -314,12 +313,17 @@ const triggers: Trigger<EntityDict, 'pay', BRC>[] = [
},
filter,
}, { dontCollect: true });
const { orderId, depositId, iState, deposit, application } = pay;
context.saveOperationToEvent(id, `${DATA_SUBSCRIBER_KEYS.payStateChanged}-${filter!.id!}`);
if (orderId) {
return await changeOrderStateByPay({ id: orderId }, context, option);
for (const pay of pays) {
const { orderId, depositId, iState, deposit, application } = pay;
context.saveOperationToEvent(id, `${DATA_SUBSCRIBER_KEYS.payStateChanged}-${filter!.id!}`);
if (orderId) {
await changeOrderStateByPay({ id: orderId }, context, option);
}
}
return pays.length;
},
} as UpdateTriggerInTxn<EntityDict, 'pay', BRC>,
{