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

webSocket สาธุ99

Browse source
This commit is contained in:
AdisakKanthawilang 2025-03-06 14:41:41 +07:00
parent a828693d2e
commit 0f639826c3
3 changed files with 27 additions and 37 deletions
Download patch file Download diff file Expand all files Collapse all files

26
src/app.ts
View file

@ -38,14 +38,14 @@ async function main() {
app.use("/", express.static("static")); app.use("/", express.static("static"));
app.use("/api-docs", swaggerUi.serve, swaggerUi.setup(swaggerDocument)); app.use("/api-docs", swaggerUi.serve, swaggerUi.setup(swaggerDocument));
app.use((req, res, next) => { // app.use((req, res, next) => {
console.log(`Request received at: ${req.url}`); // console.log(`Request received at: ${req.url}`);
next(); // next();
}); // });
app.get('/api', (req, res) => { // app.get('/api', (req, res) => {
res.send('API route is working!'); // res.send('API route is working!');
}); // });
RegisterRoutes(app); RegisterRoutes(app);
@ -139,18 +139,6 @@ async function main() {
}); });
}); });
wss.clients.forEach((client: any) => {
if (client.readyState === WebSocket.OPEN) {
const message = "";
console.log("📤 Sending data to client:", message);
client.send(message, (err:any) => {
if (err) {
console.error("❌ Error sending message:", err);
}
});
}
});
// ตั้งค่า Express routes // ตั้งค่า Express routes
app.get('/', (req, res) => { app.get('/', (req, res) => {
res.send('Hello from Express!'); res.send('Hello from Express!');

22
src/controllers/ReportController.ts
View file

@ -31,9 +31,7 @@ import { Profile } from "../entities/Profile";
import { viewRegistryOfficer } from "../entities/view/viewRegistryOfficer"; import { viewRegistryOfficer } from "../entities/view/viewRegistryOfficer";
import { viewRegistryEmployee } from "../entities/view/viewRegistryEmployee"; import { viewRegistryEmployee } from "../entities/view/viewRegistryEmployee";
import { EmployeeTempPosMaster } from "../entities/EmployeeTempPosMaster"; import { EmployeeTempPosMaster } from "../entities/EmployeeTempPosMaster";
import { sendWebSocket } from "../services/webSocket";
// import { WebSocket } from "ws";
// import { wss } from "../app";
@Route("api/v1/org/report") @Route("api/v1/org/report")
@Tags("Report") @Tags("Report")
@ -3540,21 +3538,9 @@ export class ReportController extends Controller {
} }
} }
} }
// console.log(">>",data); const metaData = { template: "report2", reportName: "report2", data: { data } };
sendWebSocket(metaData)
// wss.clients.forEach((client: any) => { // return new HttpSuccess({ template: "report2", reportName: "report2", data: { data } });
// if (client.readyState === WebSocket.OPEN) {
// const message = JSON.stringify({ template: "report2", reportName: "report2", data: { data } });
// console.log("📤 Sending data to client:", message);
// client.send(message, (err:any) => {
// if (err) {
// console.error("❌ Error sending message:", err);
// }
// });
// }
// });
return new HttpSuccess({ template: "report2", reportName: "report2", data: { data } });
} }
/** /**

16
src/services/webSocket.ts Normal file
View file

@ -0,0 +1,16 @@
import { WebSocket } from "ws";
import { wss } from "../app";
export async function sendWebSocket(data:any){
wss.clients.forEach((client: any) => {
if (client.readyState === WebSocket.OPEN) {
const message = JSON.stringify(data);
console.log("📤 Sending data to client:", message);
client.send(message, (err:any) => {
if (err) {
console.error("❌ Error sending message:", err);
}
});
}
});
}