Api/kwan

server/app.js

@@ -0,0 +1,26 @@
+import authRouter from "./apps/auth.js";
+import express from "express";
+import bodyParser from "body-parser";
+import cors from "cors";
+
+async function init() {
+  const app = express();
+  const port = 4000;
+
+  app.use(cors());
+  app.use(bodyParser.json());
+  app.use("/auth", authRouter);
+
+  app.get("/", (req, res) => {
+    res.send("Hello World!");
+  });
+
+  app.get("*", (req, res) => {
+    res.status(404).send("Not found");
+  });
+
+  app.use("/auth", authRouter);
+  app.listen(port, () => {
+    console.log(`Server is listening on ${port}`);
+    })};
+init();

server/apps/auth.js

@@ -0,0 +1,50 @@
+import { Router } from "express";
+import { pool } from "../utils/db.js";
+import bcrypt from "bcrypt";
+
+const authRouter = Router();
+
+authRouter.get("/", async (req, res) => {
+
+  const result = await pool.query("select * from users");
+
+  return res.json({
+    data: result.rows,
+  });
+});
+
+authRouter.post("/", async (req, res) => {
+const hasRegistered = req.body.status === "registered";
+const newUser = {
+        ...req.body,
+     };
+const salt = await bcrypt.genSalt(10);
+
+newUser.password = await bcrypt.hash(newUser.password, salt);
+     await pool.query(
+       `insert into users
+       (fullname, username, email, password, id_number, date_of_birth,
+       country, profile_picture, role, card_number, card_owner, expiry_date, cvc_cvv) 
+       VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11, $12, $13)`,
+       [
+         newUser.fullname,
+         newUser.username,
+         newUser.email,
+         newUser.password,
+         newUser.id_number,
+         newUser.date_of_birth,
+         newUser.country,
+         newUser.profile_picture,
+         newUser.role,
+         newUser.card_number,
+         newUser.card_owner,
+         newUser.expiry_date,
+         newUser.cvc_cvv
+       ]
+     );
+
+     return res.json({
+       message: "User has been created.",
+     });
+   });
+export default authRouter;

server/apps/reservation.js

@@ -0,0 +1,174 @@
+import { Router } from "express";
+import { pool } from "../utils/db.js";
+import Stripe from "stripe";
+const stripe = new Stripe(
+  "sk_test_51M3GnmJPsAkb5CJr0bn5EbkjmC74103qjI3F5nR5iOTGdkEoWfgzw0DASleURWLOwC2ojBNX5RAS2c5iFiLuihDY00oj8F1qLs"
+);
+const reserveRouter = Router();
+reserveRouter.post("/", async (req, res) => {
+  try {
+    const paymentMethod = await stripe.paymentMethods.create({
+      type: "card",
+      card: {
+        number: String(req.body.cardNumber),
+        exp_month: Number(req.body.exp_month),
+        exp_year: Number(req.body.exp_year),
+        cvc: String(req.body.cvc),
+      },
+    });
+    const payment = await stripe.paymentIntents.create({
+      amount: req.body.sumPrice,
+      currency: "THB",
+      description: "Neatly Company",
+      payment_method: paymentMethod.id,
+      confirm: true,
+    });
+    console.log("Payment", payment);
+
+    ////// insert db
+
+    if (payment.status == "succeeded") {
+      const newReservations = {
+        ...req.body,
+        booking_date: new Date(),
+        payment_method: "credit card",
+      };
+
+      console.log("newReservations", newReservations);
+      //1
+      const reservationsid = await pool.query(
+        `insert into reservations
+             (booking_date, check_in_date, check_out_date, room_type_id, amount, guest_no,payment_method)
+             VALUES ($1, $2, $3, $4, $5, $6, $7) RETURNING *`,
+        [
+          newReservations.booking_date,
+          newReservations.checkIn,
+          newReservations.checkOut,
+          newReservations.roomId,
+          newReservations.amountRoom,
+          newReservations.guest,
+          newReservations.payment_method,
+        ]
+      );
+
+      console.log("reservation_id",reservationsid.rows[0].reservation_id);
+      // console.log(reservationsid.rows[0].userId);
+
+      newReservations.specialRequest.map(async (item) => {
+        let req_id;
+        if (item.req === "Baby cot") req_id = 6;
+        else if (item.req === "Airport transfer") req_id = 7;
+        else if (item.req === "Extra bed") req_id = 8;
+        else if (item.req === "Extra pillows") req_id = 9;
+        else if (item.req === "Phone chargers and adapters") req_id = 10;
+        else if (item.req === "Breakfast") req_id = 11;
+
+        await pool.query(
+          `insert into reservations_request
+         (reservation_id, request_id)
+         VALUES ($1, $2) `,
+          [reservationsid.rows[0].reservation_id, req_id]
+        );
+
+        // const request_id = await pool.query(
+        //   `SELECT * FROM request where have = $1 `,
+        //   [item.req]
+        // );
+        // // console.log(request_id.rows[0].request_id);
+        // await pool.query(
+        //   `insert into reservations_request
+        //  (reservation_id, request_id)
+        //  VALUES ($1, $2) `,
+        //   [reservationsid.rows[0].reservation_id, request_id.rows[0].request_id]
+        // );
+      });
+
+      newReservations.standardRequest.map(async (item) => {
+        let req_id;
+        if (item.standard_req === "Early check-in") req_id = 1;
+        else if (item.standard_req === "Late check-out") req_id = 2;
+        else if (item.standard_req === "Non-smoking room") req_id = 3;
+        else if (item.standard_req === "A room on the high floor") req_id = 4;
+        else if (item.standard_req === "A quiet room") req_id = 5;
+
+        await pool.query(
+          `insert into reservations_request
+         (reservation_id, request_id)
+         VALUES ($1, $2) `,
+          [reservationsid.rows[0].reservation_id, req_id]
+        );
+        // const request_id = await pool.query(
+        //   `SELECT * FROM request where have = $1 `,
+        //   [item.standard_req]
+        // );
+        // // console.log(request_id.rows[0].request_id);
+
+        // await pool.query(
+        //   `insert into reservations_request
+        //  (reservation_id, request_id)
+        //  VALUES ($1, $2) `,
+        //   [reservationsid.rows[0].reservation_id, request_id.rows[0].request_id]
+        // );
+      });
+
+      //2
+      await pool.query(
+        `insert into bills
+         (reservation_id, total_price)
+         VALUES ($1, $2) `,
+        [reservationsid.rows[0].reservation_id, newReservations.sumPrice]
+      );
+
+      //3
+      await pool.query(
+        `insert into users_reservations
+         (reservation_id, user_id)
+         VALUES ($1, $2) `,
+        [reservationsid.rows[0].reservation_id, newReservations.userId]
+      );
+
+      res.json({
+        message: "Payment successful",
+        success: true,
+        reservationsid: reservationsid.rows[0].reservation_id,
+      });
+    } else {
+      res.json({
+        message: "Payment failed",
+        success: false,
+      });
+    }
+  } catch (error) {
+    // console.log("Error", error);
+    res.json({
+      message: "Payment failed",
+      success: false,
+    });
+  }
+});
+
+reserveRouter.get("/:reservationid", async (req, res) => {
+    const reservation_id = req.params.reservationid;
+
+    const result = await pool.query(
+      "select bills.total_price,request.have,users.card_number from reservations where reservation_id = $1",
+      [reservation_id]
+    );
+    return res.json({
+      data: result.rows,
+    });
+  });
+
+reserveRouter.get("/:roomid", async (req, res) => {
+  const roomid = req.params.roomid;
+
+  const result = await pool.query(
+    "select type_name,promotion_price from room_types where room_types_id = $1",
+    [roomid]
+  );
+  return res.json({
+    data: result.rows,
+  });
+});
+
+export default reserveRouter;

server/utils/db.js

@@ -0,0 +1,9 @@
+import * as pg from "pg";
+const { Pool } = pg.default;
+const pool = new Pool({
+
+  connectionString:
+    "postgres://vkhwmske:[email protected]/vkhwmske",
+});
+
+export { pool };