Develop

.gitignore

@@ -4,4 +4,7 @@ node_modules
 .env.dev
 
 /generated/prisma
-dist/
+dist/
+
+# Local tooling state
+.omc/

package.json

@@ -37,6 +37,7 @@
     "jsonwebtoken": "^9.0.2",
     "morgan": "^1.10.1",
     "multer": "^2.0.2",
+    "node-cron": "^4.2.1",
     "nodemailer": "^7.0.10",
     "passport": "^0.7.0",
     "passport-google-oauth20": "^2.0.0",
@@ -67,6 +68,7 @@
     "@types/morgan": "^1.9.10",
     "@types/multer": "^2.0.0",
     "@types/node": "^24.0.10",
+    "@types/node-cron": "^3.0.11",
     "@types/nodemailer": "^7.0.3",
     "@types/passport": "^1.0.17",
     "@types/passport-jwt": "^4.0.1",

prisma/migrations/20260517005759_add_user_last_active_at/migration.sql

@@ -0,0 +1,2 @@
+-- AlterTable
+ALTER TABLE `User` ADD COLUMN `last_active_at` DATETIME(3) NULL;

prisma/migrations/20260517013225_add_prompt_stat_daily/migration.sql

@@ -0,0 +1,13 @@
+-- CreateTable
+CREATE TABLE `PromptStatDaily` (
+    `id` INTEGER NOT NULL AUTO_INCREMENT,
+    `prompt_id` INTEGER NOT NULL,
+    `snapshot_date` VARCHAR(10) NOT NULL,
+    `views` INTEGER NOT NULL DEFAULT 0,
+    `downloads` INTEGER NOT NULL DEFAULT 0,
+    `created_at` DATETIME(3) NOT NULL DEFAULT CURRENT_TIMESTAMP(3),
+
+    INDEX `PromptStatDaily_snapshot_date_idx`(`snapshot_date`),
+    UNIQUE INDEX `PromptStatDaily_prompt_id_snapshot_date_key`(`prompt_id`, `snapshot_date`),
+    PRIMARY KEY (`id`)
+) DEFAULT CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci;

prisma/schema.prisma

@@ -18,6 +18,7 @@ model User {
   status               Boolean
   userstatus            userStatus                @default(active)
   inactive_date        DateTime?
+  last_active_at       DateTime?
   created_at           DateTime                   @default(now())
   updated_at           DateTime                   @updatedAt
   role                 Role                       @default(USER)
@@ -283,6 +284,18 @@ model PromptModel {
   @@index([prompt_id], map: "PromptModel_prompt_id_fkey")
 }
 
+model PromptStatDaily {
+  id            Int      @id @default(autoincrement())
+  prompt_id     Int
+  snapshot_date String   @db.VarChar(10)
+  views         Int      @default(0)
+  downloads     Int      @default(0)
+  created_at    DateTime @default(now())
+
+  @@unique([prompt_id, snapshot_date])
+  @@index([snapshot_date])
+}
+
 model Model {
   model_id          Int           @id @default(autoincrement())
   name              String        @db.VarChar(50)

src/config/passport.ts

@@ -12,6 +12,7 @@ import { configureGoogleStrategy } from "./social/google";
 import { configureNaverStrategy } from "./social/naver";
 import { configureKakaoStrategy } from "./social/kakao";
 import { isActive } from "../utils/status";
+import { recordUserActivity } from "../utils/user-activity";
 import prisma from "./prisma";
 
 // JWT Strategy 설정
@@ -40,6 +41,8 @@ passport.use(
           return done(error, false);
         }
 
+        void recordUserActivity(user.user_id);
+
         return done(null, user);
       } catch (err) {
         return done(err as Error, false);

src/index.ts

@@ -3,6 +3,7 @@ import http from "http";
 import { Server } from "socket.io"
 import { responseHandler } from "./middlewares/responseHandler";
 import { errorHandler } from "./middlewares/errorHandler";
+import { visitorTracker } from "./middlewares/visitorTracker";
 import "reflect-metadata";
 import passport from "./config/passport";
 import swaggerUi from "swagger-ui-express";
@@ -29,11 +30,14 @@ import "./notifications/listeners/notification.listener"; // 알림 리스터 im
 import messageRouter from "./messages/routes/message.route";
 import adminPromptRouter from "./prompts/routes/admin-prompt.route";
 import adminMemberRouter from "./members/routes/admin-member.route";
+import adminSellerRouter from "./settlements/routes/admin-seller.route";
+import adminStatsRouter from "./stats/routes/admin-stats.route";
 import signupRouter from "./signup/routes/signup.route"
 import signinRouter from "./signin/routes/signin.route";
 import passwordRouter from "./password/routes/password.route";
 import chatRouter from "./chat/routes/chat.route";
 import { initSocket } from "./socket/server";
+import { startPromptStatSnapshotJob } from "./stats/jobs/prompt-stat-snapshot.job";
 import morgan = require('morgan');
 const PORT = 3000;
 const app = express();
@@ -42,6 +46,7 @@ const app = express();
 const server = http.createServer(app); 
 
 initSocket(server)
+startPromptStatSnapshotJob();
 // 1. 응답 핸들러(json 파서보다 위에)
 app.use(responseHandler);
 app.use((req, res, next) => {
@@ -100,6 +105,9 @@ app.use(
   swaggerUi.setup(swaggerJsdoc(swaggerOptions))
 );
 
+// 방문자 추적 미들웨어 (응답 종료 시 HyperLogLog에 visitor_id 누적)
+app.use(visitorTracker);
+
 // 3. 모든 라우터들
 
 // 로그인 라우터
@@ -153,6 +161,8 @@ app.use("/api/prompts", promptLikeRouter);
 
 // admin
 app.use("/api/admin/prompts", adminPromptRouter);
+app.use("/api/admin/sellers", adminSellerRouter);
+app.use("/api/admin/stats", adminStatsRouter);
 app.use("/api/admin", adminMemberRouter);
 
 // 팁 라우터

src/middlewares/visitorTracker.ts

@@ -0,0 +1,34 @@
+import { Request, Response, NextFunction } from 'express';
+import {
+  computeVisitorId,
+  isBotUserAgent,
+  recordVisit,
+} from '../utils/visitor-tracking';
+
+const SKIP_PATH_PREFIXES = [
+  '/health',
+  '/api-docs',
+  '/uploads',
+  '/api/notifications/sse',
+];
+
+const SKIP_METHODS = new Set(['OPTIONS', 'HEAD']);
+
+export const visitorTracker = (
+  req: Request,
+  res: Response,
+  next: NextFunction,
+): void => {
+  if (SKIP_METHODS.has(req.method)) return next();
+  if (SKIP_PATH_PREFIXES.some((prefix) => req.path.startsWith(prefix))) {
+    return next();
+  }
+  if (isBotUserAgent(req.headers['user-agent'])) return next();
+
+  res.on('finish', () => {
+    if (res.statusCode >= 400) return;
+    void recordVisit(computeVisitorId(req));
+  });
+
+  next();
+};

src/settlements/controllers/admin-seller.controller.ts

@@ -0,0 +1,163 @@
+import { Request, Response, NextFunction } from 'express';
+import { AppError } from '../../errors/AppError';
+import {
+  approvePendingBusinessSeller,
+  cancelSeller,
+  getBusinessSellerDetail,
+  getIndividualSellerDetail,
+  getPendingBusinessSellerDetail,
+  listBusinessSellers,
+  listIndividualSellers,
+  listPendingBusinessSellers,
+  rejectPendingBusinessSeller,
+} from '../services/admin-seller.service';
+import {
+  ListPendingQueryDto,
+  ListSellersQueryDto,
+} from '../dtos/admin-seller.dto';
+
+const parseUserIdParam = (raw: string): number => {
+  const userId = Number(raw);
+  if (!Number.isInteger(userId) || userId <= 0) {
+    throw new AppError(
+      '유효하지 않은 사용자 ID입니다.',
+      400,
+      'ValidationError',
+    );
+  }
+  return userId;
+};
+
+export const getPendingSellerList = async (
+  req: Request<unknown, unknown, unknown, ListPendingQueryDto>,
+  res: Response,
+  next: NextFunction,
+) => {
+  try {
+    const result = await listPendingBusinessSellers(
+      req.query.page,
+      req.query.limit,
+    );
+    return res.success(result, '승인 대기 사업자 판매자 목록을 조회했습니다.');
+  } catch (error) {
+    return next(error);
+  }
+};
+
+export const getPendingSellerDetail = async (
+  req: Request<{ userId: string }>,
+  res: Response,
+  next: NextFunction,
+) => {
+  try {
+    const userId = parseUserIdParam(req.params.userId);
+    const result = await getPendingBusinessSellerDetail(userId);
+    return res.success(result, '승인 대기 사업자 판매자 상세 정보를 조회했습니다.');
+  } catch (error) {
+    return next(error);
+  }
+};
+
+export const approveSeller = async (
+  req: Request<{ userId: string }>,
+  res: Response,
+  next: NextFunction,
+) => {
+  try {
+    const userId = parseUserIdParam(req.params.userId);
+    await approvePendingBusinessSeller(userId);
+    return res.success({ user_id: userId }, '사업자 판매자 등록을 승인했습니다.');
+  } catch (error) {
+    return next(error);
+  }
+};
+
+export const rejectSeller = async (
+  req: Request<{ userId: string }>,
+  res: Response,
+  next: NextFunction,
+) => {
+  try {
+    const userId = parseUserIdParam(req.params.userId);
+    await rejectPendingBusinessSeller(userId);
+    return res.success({ user_id: userId }, '사업자 판매자 등록을 반려했습니다.');
+  } catch (error) {
+    return next(error);
+  }
+};
+
+export const getIndividualSellerList = async (
+  req: Request<unknown, unknown, unknown, ListSellersQueryDto>,
+  res: Response,
+  next: NextFunction,
+) => {
+  try {
+    const result = await listIndividualSellers(
+      req.query.page,
+      req.query.limit,
+      req.query.search,
+    );
+    return res.success(result, '개인 판매자 목록을 조회했습니다.');
+  } catch (error) {
+    return next(error);
+  }
+};
+
+export const getBusinessSellerList = async (
+  req: Request<unknown, unknown, unknown, ListSellersQueryDto>,
+  res: Response,
+  next: NextFunction,
+) => {
+  try {
+    const result = await listBusinessSellers(
+      req.query.page,
+      req.query.limit,
+      req.query.search,
+    );
+    return res.success(result, '사업자 판매자 목록을 조회했습니다.');
+  } catch (error) {
+    return next(error);
+  }
+};
+
+export const getIndividualSellerDetailHandler = async (
+  req: Request<{ userId: string }>,
+  res: Response,
+  next: NextFunction,
+) => {
+  try {
+    const userId = parseUserIdParam(req.params.userId);
+    const result = await getIndividualSellerDetail(userId);
+    return res.success(result, '개인 판매자 상세 정보를 조회했습니다.');
+  } catch (error) {
+    return next(error);
+  }
+};
+
+export const getBusinessSellerDetailHandler = async (
+  req: Request<{ userId: string }>,
+  res: Response,
+  next: NextFunction,
+) => {
+  try {
+    const userId = parseUserIdParam(req.params.userId);
+    const result = await getBusinessSellerDetail(userId);
+    return res.success(result, '사업자 판매자 상세 정보를 조회했습니다.');
+  } catch (error) {
+    return next(error);
+  }
+};
+
+export const cancelSellerHandler = async (
+  req: Request<{ userId: string }>,
+  res: Response,
+  next: NextFunction,
+) => {
+  try {
+    const userId = parseUserIdParam(req.params.userId);
+    const result = await cancelSeller(userId);
+    return res.success(result, '판매자 등록을 취소했습니다.');
+  } catch (error) {
+    return next(error);
+  }
+};