mirror of
https://github.com/nocobase/nocobase
synced 2024-11-15 08:36:44 +00:00
chore: add transaction in set field action (#1647)
This commit is contained in:
parent
b7abdfb9e6
commit
83daf55741
@ -4,28 +4,40 @@ export default {
|
||||
async ['collections:setFields'](ctx, next) {
|
||||
const { filterByTk, values } = ctx.action.params;
|
||||
|
||||
// WARN: 删掉 key 才能保存
|
||||
const fields = values.fields?.map(f => {
|
||||
delete f.key;
|
||||
return f;
|
||||
});
|
||||
const transaction = await ctx.app.db.sequelize.transaction();
|
||||
|
||||
const db = ctx.app.db as Database;
|
||||
try {
|
||||
const fields = values.fields?.map((f) => {
|
||||
delete f.key;
|
||||
return f;
|
||||
});
|
||||
|
||||
const collection = await db.getRepository('collections').findOne({
|
||||
filter: {
|
||||
name: filterByTk,
|
||||
},
|
||||
});
|
||||
const db = ctx.app.db as Database;
|
||||
|
||||
await db.getRepository('collections').update({
|
||||
filterByTk,
|
||||
values: {
|
||||
fields,
|
||||
},
|
||||
});
|
||||
const collection = await db.getRepository('collections').findOne({
|
||||
filter: {
|
||||
name: filterByTk,
|
||||
},
|
||||
transaction,
|
||||
});
|
||||
|
||||
await collection.loadFields();
|
||||
await db.getRepository('collections').update({
|
||||
filterByTk,
|
||||
values: {
|
||||
fields,
|
||||
},
|
||||
transaction,
|
||||
});
|
||||
|
||||
await collection.loadFields({
|
||||
transaction,
|
||||
});
|
||||
|
||||
await transaction.commit();
|
||||
} catch (e) {
|
||||
await transaction.rollback();
|
||||
throw e;
|
||||
}
|
||||
|
||||
await next();
|
||||
},
|
||||
|
Loading…
Reference in New Issue
Block a user