Merge pull request #55 from InserToken/feat/1-auth/eundong

[feat] per, pbr, psr 계산 로직 수정

Author: sillonjeu

app.js

@@ -79,6 +79,7 @@ app.use("/api/rank", rankRouter);
 app.use("/api/practicescores", practiceScoreRouter);
 const fetchFinancialData = require("./routes/financialRoutes");
 app.use("/api", fetchFinancialData);
+app.use("/api", require("./routes/fetchAllFinancials"));
 /* --------------------------------------- */
 require("./services/getHoliday");
 require("./tasks/dailyStockUpdater");

routes/fetchAllFinancials.js

@@ -0,0 +1,70 @@
+// routes/fetchAllFinancials.js
+const express = require("express");
+const router = express.Router();
+const path = require("path");
+const fs = require("fs").promises;
+
+const FinancialSummary = require("../models/FinancialSummary");
+const { getFinancialSummary } = require("../services/fetchFinancialData");
+const getCorpCodeByStockCode = require("../utils/getCorpCode");
+
+/**
+ * GET /api/fetch-all?start=2020&end=2024
+ * kospi200_codes.json에 있는 모든 종목에 대해 재무요약을 가져와 저장합니다.
+ */
+router.get("/fetch-all", async (req, res) => {
+  const startYear = parseInt(req.query.start, 10) || 2020;
+  const endYear = parseInt(req.query.end, 10) || new Date().getFullYear();
+
+  try {
+    // 1) JSON 파일 읽기
+    const codesPath = path.resolve(__dirname, "../kospi200_codes.json");
+    const raw = await fs.readFile(codesPath, "utf8");
+    const kospi200 = JSON.parse(raw); // [ { _id: "005930", name: "삼성전자" }, … ]
+
+    const results = [];
+
+    // 2) 순회하며 fetch & upsert
+    for (const { _id: stockCode, name } of kospi200) {
+      try {
+        const entries = await getFinancialSummary(
+          stockCode,
+          startYear,
+          endYear
+        );
+        if (!entries || entries.length === 0) {
+          results.push({ stockCode, name, status: "no data" });
+          continue;
+        }
+
+        const corp_code = getCorpCodeByStockCode(stockCode);
+        await FinancialSummary.updateOne(
+          { stock_code: stockCode },
+          { $set: { stock_code: stockCode, corp_code, entries } },
+          { upsert: true, runValidators: true, setDefaultsOnInsert: true }
+        );
+
+        results.push({
+          stockCode,
+          name,
+          status: "saved",
+          count: entries.length,
+        });
+      } catch (err) {
+        results.push({
+          stockCode,
+          name,
+          status: "error",
+          error: err.message,
+        });
+      }
+    }
+
+    // 3) 결과 리턴
+    res.json({ message: "✅ 완료", results });
+  } catch (err) {
+    res.status(500).json({ error: err.message });
+  }
+});
+
+module.exports = router;

services/metricsService.js

@@ -1,4 +1,3 @@
-// services/metricsService.js
 const FinancialSummary = require("../models/FinancialSummary");
 const { fetchStockPrice } = require("./fetchStockPrice");
 
@@ -28,49 +27,48 @@ async function computeMetrics(stockCode, dateStr) {
 
   // 기준일자 파싱
   const baseDate = new Date(dateStr.replace(/\./g, "-"));
-  // console.log(baseDate);
   if (isNaN(baseDate)) throw new Error("잘못된 날짜 형식: " + dateStr);
 
-  // entries 에 periodDate 부착 & 기준 이전만 필터링
-  const withDate = doc.entries.map((e) => ({
-    ...e,
-    periodDate: getPeriodDate(e),
-  }));
-  const valid = withDate
+  // entries에 periodDate 부착 & 기준 이전만 필터
+  const valid = doc.entries
+    .map((e) => ({ ...e, periodDate: getPeriodDate(e) }))
     .filter((e) => e.periodDate <= baseDate)
     .sort((a, b) => a.periodDate - b.periodDate);
 
-  if (valid.length < 2) throw new Error("조회일자 이전에 분기가 부족합니다");
+  // 최소 4분기 데이터 확보
+  if (valid.length < 4) {
+    throw new Error("4분기 이상 데이터가 필요합니다.");
+  }
 
-  // TTM 합산 및 평균자본
+  // 최신 분기 데이터
+  const last = valid[valid.length - 1];
+
+  // TTM 합산값과 주식수
+  const profit = last.profit;
+  const ttmRevenue = last.revenue_ttm;
+  const equityTTM = last.equity_ttm;
+  const shareCount = last.istc_totqy;
+
+  if (!profit || !ttmRevenue || !shareCount) {
+    throw new Error("TTM 데이터가 부족하여 EPS/BPS/PSR 계산이 불가능합니다.");
+  }
+
+  // EPS/BPS 보정 계산
+  const eps = last.eps != null ? last.eps : profit / shareCount;
+  const bps = last.bps != null ? last.bps : last.equity / shareCount;
+
+  // 주가 가져오기
   const { price: stockPrice, date: priceDate } = await fetchStockPrice(
     stockCode,
     dateStr
   );
 
-  const ttmProfit = valid[valid.length - 1].profit; //당기 순이익
-  const ttmRevenue = valid[valid.length - 1].revenue_ttm; //매출액
-  const ttmequity = valid[valid.length - 1].equity_ttm; // 순자산
-  const shareCount = valid[valid.length - 1].istc_totqy; // 총 발행 주식수
-  const profit_diff = valid[valid.length - 1].profit_diff; // 증감액
-  const profit_diff_rate = valid[valid.length - 1].profit_diff_rate; // 증감률
-  // const revenue = valid[valid.length - 1].revenue;
-  // const netProfit_govern = valid[valid.length - 1].net_profit_govern; // 순이익
-  // const profitMargin = valid[valid.length - 1].profit_margin; // 순 이익률
-  // const growthRate = valid[valid.length - 1].growth_rate; //순 이익 성장률
-  // const operatingProfit = valid[valid.length - 1].operating_profit; // 영업 이익
-  // const operatingMargin = valid[valid.length - 1].operating_margin; // 영업 이익률
-  // const operatingGrowthRate = valid[valid.length - 1].operating_growth_rate; // 영업 이익 성장률
-
   // 지표 계산
-  const eps = valid[valid.length - 1].eps;
-  const bps = valid[valid.length - 1].bps;
-  const roe = valid[valid.length - 1].roe;
-
-  // const pbr = bps ? stockPrice / bps : null;
-  // const per = eps ? stockPrice / eps : null;
-  // const psr = ttmRevenue ? (stockPrice * shareCount) / ttmRevenue : null;
+  const per = eps ? stockPrice / eps : null;
+  const pbr = bps ? stockPrice / bps : null;
+  const psr = ttmRevenue ? (stockPrice * shareCount) / ttmRevenue : null;
 
+  // 시계열 데이터
   const series = {
     period: valid.map((e) => `${e.bsns_year}.${e.reprt_code}`),
     revenue: valid.map((e) => e.revenue),
@@ -84,19 +82,22 @@ async function computeMetrics(stockCode, dateStr) {
 
   return {
     price: { price: stockPrice, date: priceDate },
+    per,
+    pbr,
+    psr,
     stockPrice,
     shareCount,
     // per,
     // psr,
     // pbr,
     eps,
     bps,
-    roe,
-    ttmProfit,
+    roe: last.roe,
+    ttmProfit: profit,
     ttmRevenue,
-    ttmequity,
-    profit_diff,
-    profit_diff_rate,
+    equityTTM,
+    profit_diff: last.profit_diff,
+    profit_diff_rate: last.profit_diff_rate,
     series,
   };
 }