3d 중간저장

2025-10-16 15:39:54 +09:00
parent 062efac47f
commit 8e2c66e2a4
11 changed files with 1339 additions and 9 deletions
--- a/backend-node/src/services/WarehouseService.ts
+++ b/backend-node/src/services/WarehouseService.ts
@@ -0,0 +1,170 @@
+import pool from "../database/db";
+
+export class WarehouseService {
+  // 창고 및 자재 데이터 조회
+  async getWarehouseData() {
+    try {
+      // 창고 목록 조회
+      const warehousesResult = await pool.query(`
+        SELECT 
+          id,
+          name,
+          position_x,
+          position_y,
+          position_z,
+          size_x,
+          size_y,
+          size_z,
+          color,
+          capacity,
+          current_usage,
+          status,
+          description,
+          created_at,
+          updated_at
+        FROM warehouse
+        WHERE status = 'active'
+        ORDER BY id
+      `);
+
+      // 자재 목록 조회
+      const materialsResult = await pool.query(`
+        SELECT 
+          id,
+          warehouse_id,
+          name,
+          material_code,
+          quantity,
+          unit,
+          position_x,
+          position_y,
+          position_z,
+          size_x,
+          size_y,
+          size_z,
+          color,
+          status,
+          last_updated,
+          created_at
+        FROM warehouse_material
+        ORDER BY warehouse_id, id
+      `);
+
+      return {
+        warehouses: warehousesResult,
+        materials: materialsResult,
+      };
+    } catch (error) {
+      throw error;
+    }
+  }
+
+  // 특정 창고 정보 조회
+  async getWarehouseById(id: string) {
+    try {
+      const result = await pool.query(
+        `
+        SELECT 
+          id,
+          name,
+          position_x,
+          position_y,
+          position_z,
+          size_x,
+          size_y,
+          size_z,
+          color,
+          capacity,
+          current_usage,
+          status,
+          description,
+          created_at,
+          updated_at
+        FROM warehouse
+        WHERE id = $1
+      `,
+        [id]
+      );
+
+      return result[0] || null;
+    } catch (error) {
+      throw error;
+    }
+  }
+
+  // 창고별 자재 목록 조회
+  async getMaterialsByWarehouse(warehouseId: string) {
+    try {
+      const result = await pool.query(
+        `
+        SELECT 
+          id,
+          warehouse_id,
+          name,
+          material_code,
+          quantity,
+          unit,
+          position_x,
+          position_y,
+          position_z,
+          size_x,
+          size_y,
+          size_z,
+          color,
+          status,
+          last_updated,
+          created_at
+        FROM warehouse_material
+        WHERE warehouse_id = $1
+        ORDER BY id
+      `,
+        [warehouseId]
+      );
+
+      return result;
+    } catch (error) {
+      throw error;
+    }
+  }
+
+  // 창고 통계 조회
+  async getWarehouseStats() {
+    try {
+      const result = await pool.query(`
+        SELECT 
+          COUNT(DISTINCT w.id) as total_warehouses,
+          COUNT(m.id) as total_materials,
+          SUM(w.capacity) as total_capacity,
+          SUM(w.current_usage) as total_usage,
+          ROUND(AVG((w.current_usage::numeric / NULLIF(w.capacity, 0)) * 100), 2) as avg_usage_percent
+        FROM warehouse w
+        LEFT JOIN warehouse_material m ON w.id = m.warehouse_id
+        WHERE w.status = 'active'
+      `);
+
+      // 상태별 자재 수
+      const statusResult = await pool.query(`
+        SELECT 
+          status,
+          COUNT(*) as count
+        FROM warehouse_material
+        GROUP BY status
+      `);
+
+      const statusCounts = statusResult.reduce(
+        (acc: Record<string, number>, row: any) => {
+          acc[row.status] = parseInt(row.count);
+          return acc;
+        },
+        {} as Record<string, number>
+      );
+
+      return {
+        ...result[0],
+        materialsByStatus: statusCounts,
+      };
+    } catch (error) {
+      throw error;
+    }
+  }
+}