From 822f9ac35a23e50a2f062afed4c26de5edd1ccee Mon Sep 17 00:00:00 2001 From: kjs Date: Tue, 7 Apr 2026 10:35:16 +0900 Subject: [PATCH] feat: Implement smart factory log functionality - Added a new controller for managing smart factory logs, including retrieval and statistics endpoints. - Integrated smart factory log migration to set up the necessary database structure. - Enhanced the authentication controller to include user name in log submissions. - Developed a frontend page for displaying and filtering smart factory logs, accessible only to super admins. - Implemented API calls for fetching logs and statistics, improving data visibility and management. These changes aim to provide comprehensive logging capabilities for smart factory activities, enhancing monitoring and analysis for administrators. --- backend-node/src/app.ts | 2 + .../src/controllers/authController.ts | 1 + .../controllers/smartFactoryLogController.ts | 218 ++++++++ backend-node/src/database/runMigration.ts | 29 ++ backend-node/src/routes/adminRoutes.ts | 8 + backend-node/src/utils/smartFactoryLog.ts | 92 +++- docker/prod/docker-compose.backend.prod.yml | 5 +- .../(main)/admin/smart-factory-log/page.tsx | 478 ++++++++++++++++++ frontend/lib/api/smartFactoryLog.ts | 69 +++ 9 files changed, 895 insertions(+), 7 deletions(-) create mode 100644 backend-node/src/controllers/smartFactoryLogController.ts create mode 100644 frontend/app/(main)/admin/smart-factory-log/page.tsx create mode 100644 frontend/lib/api/smartFactoryLog.ts diff --git a/backend-node/src/app.ts b/backend-node/src/app.ts index 1c6a9d9e..33d072d4 100644 --- a/backend-node/src/app.ts +++ b/backend-node/src/app.ts @@ -449,6 +449,7 @@ async function initializeServices() { runApprovalSystemMigration, runUserMailAccountsMigration, runMessengerMigration, + runSmartFactoryLogMigration, } = await import("./database/runMigration"); await runDashboardMigration(); @@ -457,6 +458,7 @@ async function initializeServices() { await runApprovalSystemMigration(); await runUserMailAccountsMigration(); await runMessengerMigration(); + await runSmartFactoryLogMigration(); } catch (error) { logger.error(`❌ 마이그레이션 실패:`, error); } diff --git a/backend-node/src/controllers/authController.ts b/backend-node/src/controllers/authController.ts index 4b40ce6e..4dcdc275 100644 --- a/backend-node/src/controllers/authController.ts +++ b/backend-node/src/controllers/authController.ts @@ -87,6 +87,7 @@ export class AuthController { // 스마트공장 활용 로그 전송 (비동기, 응답 블로킹 안 함) sendSmartFactoryLog({ userId: userInfo.userId, + userName: userInfo.userName, remoteAddr, useType: "접속", companyCode: userInfo.companyCode, diff --git a/backend-node/src/controllers/smartFactoryLogController.ts b/backend-node/src/controllers/smartFactoryLogController.ts new file mode 100644 index 00000000..ed4b353c --- /dev/null +++ b/backend-node/src/controllers/smartFactoryLogController.ts @@ -0,0 +1,218 @@ +// 스마트공장 활용 로그 조회 컨트롤러 +// 최고관리자(*) 전용 — 회사별 필터링 가능 + +import { Response } from "express"; +import { AuthenticatedRequest } from "../middleware/permissionMiddleware"; +import { query, queryOne } from "../database/db"; +import { logger } from "../utils/logger"; + +/** + * GET /api/admin/smart-factory-log + * 스마트공장 로그 목록 조회 + */ +export const getSmartFactoryLogs = async ( + req: AuthenticatedRequest, + res: Response +): Promise => { + try { + const { + companyCode, + userId, + sendStatus, + dateFrom, + dateTo, + search, + page = "1", + limit = "50", + } = req.query; + + const whereConditions: string[] = []; + const queryParams: any[] = []; + let paramIndex = 1; + + // 회사 필터 + if (companyCode && companyCode !== "all") { + whereConditions.push(`sfl.company_code = $${paramIndex}`); + queryParams.push(companyCode); + paramIndex++; + } + + // 사용자 필터 + if (userId && (userId as string).trim()) { + whereConditions.push(`sfl.user_id ILIKE $${paramIndex}`); + queryParams.push(`%${(userId as string).trim()}%`); + paramIndex++; + } + + // 전송 상태 필터 + if (sendStatus && sendStatus !== "all") { + whereConditions.push(`sfl.send_status = $${paramIndex}`); + queryParams.push(sendStatus); + paramIndex++; + } + + // 날짜 범위 필터 + if (dateFrom) { + whereConditions.push(`sfl.created_at >= $${paramIndex}`); + queryParams.push(dateFrom); + paramIndex++; + } + if (dateTo) { + whereConditions.push(`sfl.created_at < ($${paramIndex}::date + 1)`); + queryParams.push(dateTo); + paramIndex++; + } + + // 통합 검색 + if (search && (search as string).trim()) { + whereConditions.push( + `(sfl.user_id ILIKE $${paramIndex} OR sfl.user_name ILIKE $${paramIndex} OR sfl.connect_ip ILIKE $${paramIndex} OR sfl.error_message ILIKE $${paramIndex})` + ); + queryParams.push(`%${(search as string).trim()}%`); + paramIndex++; + } + + const whereClause = + whereConditions.length > 0 ? `WHERE ${whereConditions.join(" AND ")}` : ""; + + // 총 개수 + const countResult = await queryOne<{ total: string }>( + `SELECT COUNT(*) as total FROM smart_factory_log sfl ${whereClause}`, + queryParams + ); + const total = parseInt(countResult?.total || "0", 10); + + // 페이지네이션 + const pageNum = Math.max(1, parseInt(page as string, 10)); + const limitNum = Math.min(100, Math.max(1, parseInt(limit as string, 10))); + const offset = (pageNum - 1) * limitNum; + + // 데이터 조회 (회사명 JOIN) + const logs = await query( + `SELECT sfl.*, cm.company_name + FROM smart_factory_log sfl + LEFT JOIN company_mng cm ON cm.company_code = sfl.company_code + ${whereClause} + ORDER BY sfl.created_at DESC + LIMIT $${paramIndex} OFFSET $${paramIndex + 1}`, + [...queryParams, limitNum, offset] + ); + + res.status(200).json({ + success: true, + data: logs, + total, + page: pageNum, + limit: limitNum, + }); + } catch (error) { + logger.error("스마트공장 로그 조회 실패:", error); + res.status(500).json({ + success: false, + message: "스마트공장 로그 조회 중 오류가 발생했습니다.", + error: { + code: "SERVER_ERROR", + details: error instanceof Error ? error.message : "알 수 없는 오류", + }, + }); + } +}; + +/** + * GET /api/admin/smart-factory-log/stats + * 스마트공장 로그 통계 (회사별 요약) + */ +export const getSmartFactoryLogStats = async ( + req: AuthenticatedRequest, + res: Response +): Promise => { + try { + const { companyCode, days = "30" } = req.query; + const daysNum = parseInt(days as string, 10) || 30; + + const whereConditions: string[] = [ + `sfl.created_at >= NOW() - INTERVAL '${daysNum} days'`, + ]; + const queryParams: any[] = []; + let paramIndex = 1; + + if (companyCode && companyCode !== "all") { + whereConditions.push(`sfl.company_code = $${paramIndex}`); + queryParams.push(companyCode); + paramIndex++; + } + + const whereClause = `WHERE ${whereConditions.join(" AND ")}`; + + // 상태별 건수 + const statusCounts = await query<{ send_status: string; count: string }>( + `SELECT send_status, COUNT(*) as count + FROM smart_factory_log sfl + ${whereClause} + GROUP BY send_status`, + queryParams + ); + + // 회사별 건수 + const companyCounts = await query<{ + company_code: string; + company_name: string; + count: string; + }>( + `SELECT sfl.company_code, COALESCE(cm.company_name, sfl.company_code) as company_name, COUNT(*) as count + FROM smart_factory_log sfl + LEFT JOIN company_mng cm ON cm.company_code = sfl.company_code + ${whereClause} + GROUP BY sfl.company_code, cm.company_name + ORDER BY count DESC`, + queryParams + ); + + // 일별 추이 + const dailyCounts = await query<{ date: string; count: string }>( + `SELECT DATE(sfl.created_at) as date, COUNT(*) as count + FROM smart_factory_log sfl + ${whereClause} + GROUP BY DATE(sfl.created_at) + ORDER BY date DESC + LIMIT ${daysNum}`, + queryParams + ); + + // 전체 건수 + const totalResult = await queryOne<{ total: string }>( + `SELECT COUNT(*) as total FROM smart_factory_log sfl ${whereClause}`, + queryParams + ); + + res.status(200).json({ + success: true, + data: { + total: parseInt(totalResult?.total || "0", 10), + statusCounts: statusCounts.map((r) => ({ + status: r.send_status, + count: parseInt(r.count, 10), + })), + companyCounts: companyCounts.map((r) => ({ + companyCode: r.company_code, + companyName: r.company_name, + count: parseInt(r.count, 10), + })), + dailyCounts: dailyCounts.map((r) => ({ + date: r.date, + count: parseInt(r.count, 10), + })), + }, + }); + } catch (error) { + logger.error("스마트공장 로그 통계 조회 실패:", error); + res.status(500).json({ + success: false, + message: "통계 조회 중 오류가 발생했습니다.", + error: { + code: "SERVER_ERROR", + details: error instanceof Error ? error.message : "알 수 없는 오류", + }, + }); + } +}; diff --git a/backend-node/src/database/runMigration.ts b/backend-node/src/database/runMigration.ts index 73523b92..f915d962 100644 --- a/backend-node/src/database/runMigration.ts +++ b/backend-node/src/database/runMigration.ts @@ -170,6 +170,35 @@ export async function runMessengerMigration() { } } +/** + * 스마트공장 활용 로그 테이블 마이그레이션 + */ +export async function runSmartFactoryLogMigration() { + try { + console.log("🔄 스마트공장 로그 테이블 마이그레이션 시작..."); + + const sqlFilePath = path.join( + __dirname, + "../../db/migrations/200_create_smart_factory_log.sql" + ); + + if (!fs.existsSync(sqlFilePath)) { + console.log("⚠️ 마이그레이션 파일이 없습니다:", sqlFilePath); + return; + } + + const sqlContent = fs.readFileSync(sqlFilePath, "utf8"); + await PostgreSQLService.query(sqlContent); + + console.log("✅ 스마트공장 로그 테이블 마이그레이션 완료!"); + } catch (error) { + console.error("❌ 스마트공장 로그 테이블 마이그레이션 실패:", error); + if (error instanceof Error && error.message.includes("already exists")) { + console.log("ℹ️ 테이블이 이미 존재합니다."); + } + } +} + export async function runDtgManagementLogMigration() { try { console.log("🔄 DTG Management 이력 테이블 마이그레이션 시작..."); diff --git a/backend-node/src/routes/adminRoutes.ts b/backend-node/src/routes/adminRoutes.ts index 3a173cbe..d02aac7e 100644 --- a/backend-node/src/routes/adminRoutes.ts +++ b/backend-node/src/routes/adminRoutes.ts @@ -32,6 +32,10 @@ import { setUserLocale, getTableSchema, // 테이블 스키마 조회 } from "../controllers/adminController"; +import { + getSmartFactoryLogs, + getSmartFactoryLogStats, +} from "../controllers/smartFactoryLogController"; import { authenticateToken } from "../middleware/authMiddleware"; import { requireSuperAdmin } from "../middleware/permissionMiddleware"; @@ -84,4 +88,8 @@ router.post("/user-locale", setUserLocale); // 테이블 스키마 API (엑셀 업로드 컬럼 매핑용) router.get("/tables/:tableName/schema", getTableSchema); +// 스마트공장 활용 로그 API (최고관리자 전용) +router.get("/smart-factory-log", requireSuperAdmin, getSmartFactoryLogs); +router.get("/smart-factory-log/stats", requireSuperAdmin, getSmartFactoryLogStats); + export default router; diff --git a/backend-node/src/utils/smartFactoryLog.ts b/backend-node/src/utils/smartFactoryLog.ts index 18c5b573..e4fd89f0 100644 --- a/backend-node/src/utils/smartFactoryLog.ts +++ b/backend-node/src/utils/smartFactoryLog.ts @@ -3,20 +3,26 @@ import axios from "axios"; import { logger } from "./logger"; +import { query } from "../database/db"; const SMART_FACTORY_LOG_URL = "https://log.smart-factory.kr/apisvc/sendLogDataJSON.do"; /** - * 스마트공장 활용 로그 전송 + * 스마트공장 활용 로그 전송 + DB 저장 * 로그인 성공 시 비동기로 호출하여 응답을 블로킹하지 않음 */ export async function sendSmartFactoryLog(params: { userId: string; + userName?: string; remoteAddr: string; useType?: string; companyCode?: string; }): Promise { + const now = new Date(); + const logDt = formatDateTime(now); + const useType = params.useType || "접속"; + // 회사별 키 우선 조회, 없으면 공통 키 폴백 const apiKey = (params.companyCode && process.env[`SMART_FACTORY_API_KEY_${params.companyCode}`]) || process.env.SMART_FACTORY_API_KEY; @@ -25,17 +31,26 @@ export async function sendSmartFactoryLog(params: { logger.warn( "SMART_FACTORY_API_KEY 환경변수가 설정되지 않아 스마트공장 로그 전송을 건너뜁니다." ); + // SKIPPED 상태로 DB 기록 + await saveLog({ + companyCode: params.companyCode || "", + userId: params.userId, + userName: params.userName, + useType, + connectIp: params.remoteAddr, + sendStatus: "SKIPPED", + responseStatus: null, + errorMessage: "API 키 미설정", + logDt: now, + }); return; } try { - const now = new Date(); - const logDt = formatDateTime(now); - const logData = { crtfcKey: apiKey, logDt, - useSe: params.useType || "접속", + useSe: useType, sysUser: params.userId, conectIp: params.remoteAddr, dataUsgqty: "", @@ -52,11 +67,76 @@ export async function sendSmartFactoryLog(params: { userId: params.userId, status: response.status, }); + + // SUCCESS 상태로 DB 기록 + await saveLog({ + companyCode: params.companyCode || "", + userId: params.userId, + userName: params.userName, + useType, + connectIp: params.remoteAddr, + sendStatus: "SUCCESS", + responseStatus: response.status, + errorMessage: null, + logDt: now, + }); } catch (error) { + const errorMsg = error instanceof Error ? error.message : String(error); // 스마트공장 로그 전송 실패해도 로그인에 영향 없도록 에러만 기록 logger.error("스마트공장 로그 전송 실패", { userId: params.userId, - error: error instanceof Error ? error.message : error, + error: errorMsg, + }); + + // FAIL 상태로 DB 기록 + await saveLog({ + companyCode: params.companyCode || "", + userId: params.userId, + userName: params.userName, + useType, + connectIp: params.remoteAddr, + sendStatus: "FAIL", + responseStatus: null, + errorMessage: errorMsg, + logDt: now, + }); + } +} + +/** DB에 로그 저장 */ +async function saveLog(params: { + companyCode: string; + userId: string; + userName?: string; + useType: string; + connectIp: string; + sendStatus: string; + responseStatus: number | null; + errorMessage: string | null; + logDt: Date; +}): Promise { + try { + await query( + `INSERT INTO smart_factory_log + (company_code, user_id, user_name, use_type, connect_ip, send_status, response_status, error_message, log_dt) + VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9)`, + [ + params.companyCode, + params.userId, + params.userName || null, + params.useType, + params.connectIp, + params.sendStatus, + params.responseStatus, + params.errorMessage, + params.logDt, + ] + ); + } catch (dbError) { + // DB 저장 실패해도 로그인 프로세스에 영향 없도록 + logger.error("스마트공장 로그 DB 저장 실패", { + userId: params.userId, + error: dbError instanceof Error ? dbError.message : dbError, }); } } diff --git a/docker/prod/docker-compose.backend.prod.yml b/docker/prod/docker-compose.backend.prod.yml index 755475ff..8ab60253 100644 --- a/docker/prod/docker-compose.backend.prod.yml +++ b/docker/prod/docker-compose.backend.prod.yml @@ -23,8 +23,11 @@ services: - KMA_API_KEY=${KMA_API_KEY} - ITS_API_KEY=${ITS_API_KEY} - EXPRESSWAY_API_KEY=${EXPRESSWAY_API_KEY:-} - - SMART_FACTORY_API_KEY_COMPANY_10=${SMART_FACTORY_API_KEY_COMPANY_10:-} + - SMART_FACTORY_API_KEY_COMPANY_7=${SMART_FACTORY_API_KEY_COMPANY_7:-} + - SMART_FACTORY_API_KEY_COMPANY_8=${SMART_FACTORY_API_KEY_COMPANY_8:-} - SMART_FACTORY_API_KEY_COMPANY_9=${SMART_FACTORY_API_KEY_COMPANY_9:-} + - SMART_FACTORY_API_KEY_COMPANY_10=${SMART_FACTORY_API_KEY_COMPANY_10:-} + - SMART_FACTORY_API_KEY_COMPANY_16=${SMART_FACTORY_API_KEY_COMPANY_16:-} restart: unless-stopped healthcheck: test: ["CMD", "curl", "-f", "http://localhost:3001/health"] diff --git a/frontend/app/(main)/admin/smart-factory-log/page.tsx b/frontend/app/(main)/admin/smart-factory-log/page.tsx new file mode 100644 index 00000000..73a93daf --- /dev/null +++ b/frontend/app/(main)/admin/smart-factory-log/page.tsx @@ -0,0 +1,478 @@ +"use client"; + +import React, { useState, useEffect, useCallback } from "react"; +import { Card, CardContent, CardHeader, CardTitle } from "@/components/ui/card"; +import { Button } from "@/components/ui/button"; +import { Input } from "@/components/ui/input"; +import { Badge } from "@/components/ui/badge"; +import { + Select, + SelectContent, + SelectItem, + SelectTrigger, + SelectValue, +} from "@/components/ui/select"; +import { + Table, + TableBody, + TableCell, + TableHead, + TableHeader, + TableRow, +} from "@/components/ui/table"; +import { + Search, + RefreshCw, + ChevronLeft, + ChevronRight, + Factory, + CheckCircle2, + XCircle, + MinusCircle, + Building2, + Activity, + Users, +} from "lucide-react"; +import { + getSmartFactoryLogs, + getSmartFactoryLogStats, + SmartFactoryLogEntry, + SmartFactoryLogFilters, + SmartFactoryLogStats, +} from "@/lib/api/smartFactoryLog"; +import { getCompanyList } from "@/lib/api/company"; +import { useAuth } from "@/hooks/useAuth"; +import { Company } from "@/types/company"; + +const STATUS_CONFIG = { + SUCCESS: { label: "성공", variant: "success" as const, icon: CheckCircle2 }, + FAIL: { label: "실패", variant: "destructive" as const, icon: XCircle }, + SKIPPED: { label: "건너뜀", variant: "secondary" as const, icon: MinusCircle }, +}; + +export default function SmartFactoryLogPage() { + const { user } = useAuth(); + const [logs, setLogs] = useState([]); + const [stats, setStats] = useState(null); + const [companies, setCompanies] = useState([]); + const [loading, setLoading] = useState(false); + const [total, setTotal] = useState(0); + + const [filters, setFilters] = useState({ + companyCode: "", + sendStatus: "", + search: "", + dateFrom: "", + dateTo: "", + page: 1, + limit: 50, + }); + + // 회사 목록 로드 + useEffect(() => { + getCompanyList() + .then(setCompanies) + .catch(() => {}); + }, []); + + // 로그 데이터 로드 + const fetchLogs = useCallback(async () => { + setLoading(true); + try { + const [logRes, statsRes] = await Promise.all([ + getSmartFactoryLogs(filters), + getSmartFactoryLogStats( + filters.companyCode || undefined, + 30 + ), + ]); + if (logRes.success) { + setLogs(logRes.data); + setTotal(logRes.total); + } + if (statsRes.success) { + setStats(statsRes.data); + } + } catch (error) { + console.error("스마트공장 로그 조회 실패:", error); + } finally { + setLoading(false); + } + }, [filters]); + + useEffect(() => { + fetchLogs(); + }, [fetchLogs]); + + const totalPages = Math.ceil(total / (filters.limit || 50)); + + const handleFilterChange = (key: keyof SmartFactoryLogFilters, value: string) => { + setFilters((prev) => ({ ...prev, [key]: value, page: 1 })); + }; + + const formatDate = (dateStr: string) => { + if (!dateStr) return "-"; + const d = new Date(dateStr); + return d.toLocaleString("ko-KR", { + year: "numeric", + month: "2-digit", + day: "2-digit", + hour: "2-digit", + minute: "2-digit", + second: "2-digit", + }); + }; + + // 최고관리자가 아니면 접근 불가 안내 + if (user && user.userType !== "SUPER_ADMIN" && user.companyCode !== "*") { + return ( +
+

최고 관리자만 접근할 수 있습니다.

+
+ ); + } + + return ( +
+ {/* 헤더 */} +
+
+

+ + 스마트공장 활용 로그 +

+

+ 로그인 시 log.smart-factory.kr로 전송된 로그 기록 +

+
+ +
+ + {/* 통계 카드 */} + {stats && ( +
+ + +
+
+ +
+
+

최근 30일 전체

+

{stats.total.toLocaleString()}건

+
+
+ + + + +
+
+ +
+
+

전송 성공

+

+ {(stats.statusCounts.find((s) => s.status === "SUCCESS")?.count || 0).toLocaleString()}건 +

+
+
+ + + + +
+
+ +
+
+

전송 실패

+

+ {(stats.statusCounts.find((s) => s.status === "FAIL")?.count || 0).toLocaleString()}건 +

+
+
+ + + + +
+
+ +
+
+

활용 회사

+

+ {stats.companyCounts.length}개사 +

+
+
+ + +
+ )} + + {/* 회사별 현황 */} + {stats && stats.companyCounts.length > 0 && ( + + + + + 회사별 전송 현황 (최근 30일) + + + +
+ {stats.companyCounts.map((c) => ( + + ))} +
+ + + )} + + {/* 필터 */} + + +
+
+ +
+ + handleFilterChange("search", e.target.value)} + /> +
+
+ +
+ + +
+ +
+ + +
+ +
+ + handleFilterChange("dateFrom", e.target.value)} + /> +
+ +
+ + handleFilterChange("dateTo", e.target.value)} + /> +
+
+ + + + {/* 테이블 */} + + +
+ + 전송 기록 ({total.toLocaleString()}건) + +
+ +
+
+ + +
+ + + + No + 회사 + 사용자 + 유형 + 접속 IP + 상태 + 응답 + 에러 메시지 + 전송 시각 + + + + {loading ? ( + + + 로딩 중... + + + ) : logs.length === 0 ? ( + + + 로그가 없습니다. + + + ) : ( + logs.map((log, idx) => { + const statusConf = STATUS_CONFIG[log.send_status as keyof typeof STATUS_CONFIG] || STATUS_CONFIG.FAIL; + const StatusIcon = statusConf.icon; + return ( + + + {total - ((filters.page || 1) - 1) * (filters.limit || 50) - idx} + + + {log.company_name || log.company_code} + + +
+ {log.user_name || "-"} + + {log.user_id} + +
+ + {log.use_type} + {log.connect_ip} + + + + {statusConf.label} + + + + {log.response_status || "-"} + + + {log.error_message || "-"} + + {formatDate(log.created_at)} + + ); + }) + )} + +
+
+ + {/* 페이지네이션 */} + {totalPages > 1 && ( +
+

+ {((filters.page || 1) - 1) * (filters.limit || 50) + 1}~ + {Math.min((filters.page || 1) * (filters.limit || 50), total)} / {total.toLocaleString()}건 +

+
+ + + {filters.page || 1} / {totalPages} + + +
+
+ )} + + +
+ ); +} diff --git a/frontend/lib/api/smartFactoryLog.ts b/frontend/lib/api/smartFactoryLog.ts new file mode 100644 index 00000000..cd70b94f --- /dev/null +++ b/frontend/lib/api/smartFactoryLog.ts @@ -0,0 +1,69 @@ +import { apiClient } from "./client"; + +export interface SmartFactoryLogEntry { + id: number; + company_code: string; + company_name: string | null; + user_id: string; + user_name: string | null; + use_type: string; + connect_ip: string; + send_status: "SUCCESS" | "FAIL" | "SKIPPED"; + response_status: number | null; + error_message: string | null; + log_dt: string; + created_at: string; +} + +export interface SmartFactoryLogFilters { + companyCode?: string; + userId?: string; + sendStatus?: string; + dateFrom?: string; + dateTo?: string; + search?: string; + page?: number; + limit?: number; +} + +export interface SmartFactoryLogStats { + total: number; + statusCounts: Array<{ status: string; count: number }>; + companyCounts: Array<{ companyCode: string; companyName: string; count: number }>; + dailyCounts: Array<{ date: string; count: number }>; +} + +export async function getSmartFactoryLogs( + filters: SmartFactoryLogFilters +): Promise<{ + success: boolean; + data: SmartFactoryLogEntry[]; + total: number; + page: number; + limit: number; +}> { + const params = new URLSearchParams(); + if (filters.companyCode) params.append("companyCode", filters.companyCode); + if (filters.userId) params.append("userId", filters.userId); + if (filters.sendStatus) params.append("sendStatus", filters.sendStatus); + if (filters.dateFrom) params.append("dateFrom", filters.dateFrom); + if (filters.dateTo) params.append("dateTo", filters.dateTo); + if (filters.search) params.append("search", filters.search); + if (filters.page) params.append("page", String(filters.page)); + if (filters.limit) params.append("limit", String(filters.limit)); + + const response = await apiClient.get(`/admin/smart-factory-log?${params.toString()}`); + return response.data; +} + +export async function getSmartFactoryLogStats( + companyCode?: string, + days?: number +): Promise<{ success: boolean; data: SmartFactoryLogStats }> { + const params = new URLSearchParams(); + if (companyCode) params.append("companyCode", companyCode); + if (days) params.append("days", String(days)); + + const response = await apiClient.get(`/admin/smart-factory-log/stats?${params.toString()}`); + return response.data; +}