hrms-bangkok/hrms-api-org
7
0
Fork 0
Code Issues Pull requests Projects Releases Packages 1 Wiki Activity Actions

Merge branch 'develop' of github.com:Frappet/hrms-api-org into develop

Browse source
This commit is contained in:
kittapath 2025-03-18 22:10:19 +07:00
commit c0715bc45c
1 changed files with 11 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

13
src/services/rabbitmq.ts
View file

@ -1684,7 +1684,6 @@ async function handler_org_draft(msg: amqp.ConsumeMessage): Promise<boolean> {
} }
} }
} }
console.log("ssssssssss");
const _orgRevisions = await orgRevisionRepository.find({ const _orgRevisions = await orgRevisionRepository.find({
where: [{ orgRevisionIsDraft: true, id: Not(revision.id) }], where: [{ orgRevisionIsDraft: true, id: Not(revision.id) }],
}); });
@ -1712,7 +1711,17 @@ async function handler_org_draft(msg: amqp.ConsumeMessage): Promise<boolean> {
await posMasterActRepository.delete({ await posMasterActRepository.delete({
posMasterChildId: In(_posMasters.map((x) => x.id)), posMasterChildId: In(_posMasters.map((x) => x.id)),
}); });
await posMasterRepository.remove(_posMasters); // await posMasterRepository.remove(_posMasters);
const batchSize = 1000;
for (let i = 0; i < _posMasters.length; i += batchSize) {
const batch = _posMasters.slice(i, i + batchSize);
try {
await posMasterRepository.remove(batch);
console.log(`Removed PosMaster batch ${i / batchSize + 1}`);
} catch (error) {
console.log(`Failed to remove batch ${i / batchSize + 1}`);
}
}
await employeePosMasterRepository.remove(_employeePosMasters); await employeePosMasterRepository.remove(_employeePosMasters);
await employeeTempPosMasterRepository.remove(_employeeTempPosMasters); await employeeTempPosMasterRepository.remove(_employeeTempPosMasters);
await child4Repository.delete({ orgRevisionId: In(_orgRevisions.map((x) => x.id)) }); await child4Repository.delete({ orgRevisionId: In(_orgRevisions.map((x) => x.id)) });