midsuit
/
prasi-api
6
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

wip fix

This commit is contained in:
Rizky 2024-03-13 15:46:06 +07:00
parent 05b58b369b
commit f8afc41afb
1 changed files with 22 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

40
pkgs/utils/query.ts
View File

@ -14,31 +14,35 @@ export const execQuery = async (args: DBArg, prisma: any) => {
const { table, action, params } = args;
if (action === "batch_update") {
const { batch } = params as unknown as {
table: string;
batch: { table: string; data: any; where: any }[];
const { table, batch } = params as unknown as {
table?: { table: string; data: any; where: any }[];
batch?: { table: string; data: any; where: any }[];
};
const promises = [] as any[];
try {
for (const item of batch) {
if (
item.table &&
Object.entries(item.where).length > 0 &&
Object.entries(item.data).length > 0
) {
const tableInstance = prisma[item.table];
if (tableInstance) {
promises.push(
tableInstance.updateMany({ where: item.where, data: item.data })
);
const b = table || batch;
if (b) {
try {
for (const item of b) {
if (
item.table &&
Object.entries(item.where).length > 0 &&
Object.entries(item.data).length > 0
) {
const tableInstance = prisma[item.table];
if (tableInstance) {
promises.push(
tableInstance.updateMany({ where: item.where, data: item.data })
);
}
}
}
await Promise.all(promises);
} catch (e: any) {
throw new Error(e.message);
}
await Promise.all(promises);
} catch (e: any) {
throw new Error(e.message);
}
return;