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

checkpoint fix

Browse source
This commit is contained in:
AdisakKanthawilang 2024-10-25 15:51:46 +07:00
parent 37b2d84c7e
commit c04c06ebb6
2 changed files with 5 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

4
src/controllers/PermissionController.ts
View file

@ -746,7 +746,6 @@ export class PermissionController extends Controller {
public async checkOrg(
@Path() keycloakId: string,
) {
console.log("[In Func]");
const redisClient = await this.redis.createClient({
host: REDIS_HOST,
port: REDIS_PORT,
@ -758,7 +757,6 @@ export class PermissionController extends Controller {
select: ["id"],
where: { keycloak: keycloakId },
});
console.log("[In Func Query Profile]",profile);
// if (!profile) {
// profileType = "EMPLOYEE";
// profile = await this.profileEmployeeRepo.findOne({
@ -801,7 +799,7 @@ export class PermissionController extends Controller {
orgChild4Id: posMaster.orgChild4Id,
};
}
redisClient.setex("org_" + profile.id, 86400, JSON.stringify(reply));
redisClient.setex("org_" + profile.id, 86400, JSON.stringify(reply)); //Create Redis
// } else {
// const posMaster = await this.posMasterEmpRepository.findOne({
// where: {

8
src/services/rabbitmq.ts
View file

@ -32,14 +32,14 @@ export async function init() {
});
};
sendToQueueOrg = (payload: any, persistent = true) => {
channel.sendToQueue(queue_org, Buffer.from(JSON.stringify(payload)), { persistent });
};
// sendToQueueOrg = (payload: any, persistent = true) => {
// channel.sendToQueue(queue_org, Buffer.from(JSON.stringify(payload)), { persistent });
// };
console.log("[AMQ] Listening for message...");
createConsumer(queue, channel, handler); //----> (3) Process Consumer
createConsumer(queue_org, channel, handler_org);
// createConsumer(queue_org, channel, handler_org);
// createConsumer(queue2, channel, handler2);
}