#156 택시 탑승이 혼자인 경우, 자동으로 결제 완료 및 과거 참여 방으로 이동

src/routes/docs/rooms.js

@@ -657,7 +657,8 @@ roomsDocs[`${apiPrefix}/searchByUser`] = {
     summary: "사용자가 참여 중인 방 검색",
     description: `로그인 된 사용자가 참여 중인 방을 검색합니다.<br/>
     정산 완료 여부 기준으로 진행 중인 방과 완료된 방을 \`ongoing\`과 \`done\`으로 각각 분리하여 응답을 전송합니다.<br/>
-    (\`ongoing\`은 \`isOver\`이 flase인 방, \`done\`은 \`isOver\`이 true인 방을 의미합니다.)`,
+    (\`ongoing\`은 \`isOver\`이 flase인 방, \`done\`은 \`isOver\`이 true인 방을 의미합니다.)<br/>
+    혼자 참여 중인 방 중 이미 출발한 방이 있으면 정산 완료 처리한 후 과거 참여 방으로 옮긴다.`,
     parameters: {},
     responses: {
       200: {

src/schedules/autoProcessingRoom.js

@@ -0,0 +1,51 @@
+const { emitChatEvent } = require("../modules/socket");
+const { userModel, roomModel } = require("../modules/stores/mongo");
+const logger = require("../modules/logger");
+
+const MS_PER_MINUTE = 60000;
+
+// 탑승자가 1명인 상태로 탑승 시간이 지난 방에 대해서 정산 완료 처리
+module.exports = (app) => async () => {
+  try {
+    const io = app.get("io");
+    const expiredDate = new Date(Date.now() - 60 * MS_PER_MINUTE).toISOString();
+    const arrivalDate = new Date(Date.now()).toISOString();
+    const candidateRooms = await roomModel.find({
+      $and: [
+        { time: { $gte: expiredDate } },
+        { time: { $lte: arrivalDate } },
+        { "part.0": { $exists: true }, "part.1": { $exists: false } },
+        { "part.0.settlementStatus": { $nin: ["paid", "sent"] } }, // "sent"의 경우 로직상 불가능 하지만, 문서화 측면에서 의도적으로 남겨두었음음.
+      ],
+    });
+
+    await Promise.all(
+      candidateRooms.map(async ({ _id: roomId, part }) => {
+        const user = await userModel.findById(part[0].user._id);
+
+        // 정산 채팅을 보냅니다.
+        await emitChatEvent(io, {
+          roomId: roomId,
+          type: "settlement",
+          content: user.id,
+          authorId: user._id,
+        });
+
+        // 1명의 참여자만 존재하는 room에 대하여 정산 완료 처리
+        await roomModel.findByIdAndUpdate(roomId, {
+          ["part.0.settlementStatus"]: "paid",
+          settlementTotal: 1,
+        });
+
+        // Atomic update로 각 Room을 한번에 제거 및 추가함.
+        // 아토믹하게 처리하지 않을 경우 각 Promise가 동일한 user의 여러 ongoingRoom 또는 doneRoom을 동시에 수정하여 경합조건이 발생할 수 있음에 유의.
+        await userModel.findByIdAndUpdate(user._id, {
+          $pull: { ongoingRoom: roomId },
+          $push: { doneRoom: roomId },
+        });
+      })
+    );
+  } catch (err) {
+    logger.error(err);
+  }
+};

src/schedules/index.ts

@@ -5,11 +5,12 @@ import notifyBeforeDepart from "./notifyBeforeDepart";
 import notifyAfterArrival from "./notifyAfterArrival";
 import updateMajorTaxiFare from "./updateMajorTaxiFare";
 import updateMinorTaxiFare from "./updateMinorTaxiFare";
+import autoProcessingRoom from "./autoProcessingRoom";
 
 const registerSchedules = (app: Express) => {
   cron.schedule("*/5 * * * *", notifyBeforeDepart(app));
   cron.schedule("*/10 * * * *", notifyAfterArrival(app));
-
+  cron.schedule("1,11,21,31,41,51 * * * *", autoProcessingRoom(app));
   if (naverMap.apiId && naverMap.apiKey) {
     cron.schedule("0,30 * * * * ", updateMajorTaxiFare(app));
     cron.schedule("0 18 * * *", updateMinorTaxiFare(app));

src/services/rooms.js

@@ -485,7 +485,8 @@ const searchHandler = async (req, res) => {
 
 const searchByUserHandler = async (req, res) => {
   try {
-    const user = await userModel
+    // lean()이 적용된 user를 response에 반환해줘야 하기 때문에 user를 한 번 더 지정한다.
+    let user = await userModel
       .findOne({ id: req.userId })
       .populate({
         path: "ongoingRoom",