차량위치 위젯 기존꺼 분할 완료

backend-node/src/services/mapDataService.ts

@@ -0,0 +1,229 @@
+import { logger } from "../utils/logger";
+import { query } from "../database/db";
+import { ExternalDbConnectionService } from "./externalDbConnectionService";
+
+interface MapDataQuery {
+  connectionId?: number;
+  tableName: string;
+  latColumn: string;
+  lngColumn: string;
+  labelColumn?: string;
+  statusColumn?: string;
+  additionalColumns?: string[];
+  whereClause?: string;
+}
+
+export interface MapMarker {
+  id: string | number;
+  latitude: number;
+  longitude: number;
+  label?: string;
+  status?: string;
+  additionalInfo?: Record<string, any>;
+}
+
+/**
+ * 지도 데이터 서비스
+ * 외부/내부 DB에서 위도/경도 데이터를 조회하여 지도 마커로 변환
+ */
+export class MapDataService {
+  constructor() {
+    // ExternalDbConnectionService는 static 메서드를 사용
+  }
+
+  /**
+   * 외부 DB에서 지도 데이터 조회
+   */
+  async getMapData(params: MapDataQuery): Promise<MapMarker[]> {
+    try {
+      logger.info("🗺️ 외부 DB 지도 데이터 조회 시작:", params);
+
+      // SELECT할 컬럼 목록 구성
+      const selectColumns = [
+        params.latColumn,
+        params.lngColumn,
+        params.labelColumn,
+        params.statusColumn,
+        ...(params.additionalColumns || []),
+      ].filter(Boolean);
+
+      // 중복 제거
+      const uniqueColumns = Array.from(new Set(selectColumns));
+
+      // SQL 쿼리 구성
+      let sql = `SELECT ${uniqueColumns.map((col) => `"${col}"`).join(", ")} FROM "${params.tableName}"`;
+
+      if (params.whereClause) {
+        sql += ` WHERE ${params.whereClause}`;
+      }
+
+      logger.info("📝 실행할 SQL:", sql);
+
+      // 외부 DB 쿼리 실행 (static 메서드 사용)
+      const result = await ExternalDbConnectionService.executeQuery(
+        params.connectionId!,
+        sql
+      );
+
+      if (!result.success || !result.data) {
+        throw new Error("외부 DB 쿼리 실패");
+      }
+
+      // 데이터를 MapMarker 형식으로 변환
+      const markers = this.convertToMarkers(
+        result.data,
+        params.latColumn,
+        params.lngColumn,
+        params.labelColumn,
+        params.statusColumn,
+        params.additionalColumns
+      );
+
+      logger.info(`✅ ${markers.length}개의 마커 데이터 변환 완료`);
+
+      return markers;
+    } catch (error) {
+      logger.error("❌ 외부 DB 지도 데이터 조회 오류:", error);
+      throw error;
+    }
+  }
+
+  /**
+   * 내부 DB에서 지도 데이터 조회
+   */
+  async getInternalMapData(
+    params: Omit<MapDataQuery, "connectionId">
+  ): Promise<MapMarker[]> {
+    try {
+      logger.info("🗺️ 내부 DB 지도 데이터 조회 시작:", params);
+
+      // SELECT할 컬럼 목록 구성
+      const selectColumns = [
+        params.latColumn,
+        params.lngColumn,
+        params.labelColumn,
+        params.statusColumn,
+        ...(params.additionalColumns || []),
+      ].filter(Boolean);
+
+      // 중복 제거
+      const uniqueColumns = Array.from(new Set(selectColumns));
+
+      // SQL 쿼리 구성
+      let sql = `SELECT ${uniqueColumns.map((col) => `"${col}"`).join(", ")} FROM "${params.tableName}"`;
+
+      if (params.whereClause) {
+        sql += ` WHERE ${params.whereClause}`;
+      }
+
+      logger.info("📝 실행할 SQL:", sql);
+
+      // 내부 DB 쿼리 실행
+      const rows = await query(sql);
+
+      // 데이터를 MapMarker 형식으로 변환
+      const markers = this.convertToMarkers(
+        rows,
+        params.latColumn,
+        params.lngColumn,
+        params.labelColumn,
+        params.statusColumn,
+        params.additionalColumns
+      );
+
+      logger.info(`✅ ${markers.length}개의 마커 데이터 변환 완료`);
+
+      return markers;
+    } catch (error) {
+      logger.error("❌ 내부 DB 지도 데이터 조회 오류:", error);
+      throw error;
+    }
+  }
+
+  /**
+   * DB 결과를 MapMarker 배열로 변환
+   */
+  private convertToMarkers(
+    data: any[],
+    latColumn: string,
+    lngColumn: string,
+    labelColumn?: string,
+    statusColumn?: string,
+    additionalColumns?: string[]
+  ): MapMarker[] {
+    const markers: MapMarker[] = [];
+
+    for (let i = 0; i < data.length; i++) {
+      const row = data[i];
+
+      // 위도/경도 추출 (다양한 컬럼명 지원)
+      const lat = this.extractCoordinate(row, latColumn);
+      const lng = this.extractCoordinate(row, lngColumn);
+
+      // 유효한 좌표인지 확인
+      if (lat === null || lng === null || isNaN(lat) || isNaN(lng)) {
+        logger.warn(`⚠️ 유효하지 않은 좌표 스킵: row ${i}`, { lat, lng });
+        continue;
+      }
+
+      // 위도 범위 체크 (-90 ~ 90)
+      if (lat < -90 || lat > 90) {
+        logger.warn(`⚠️ 위도 범위 초과: ${lat}`);
+        continue;
+      }
+
+      // 경도 범위 체크 (-180 ~ 180)
+      if (lng < -180 || lng > 180) {
+        logger.warn(`⚠️ 경도 범위 초과: ${lng}`);
+        continue;
+      }
+
+      // 추가 정보 수집
+      const additionalInfo: Record<string, any> = {};
+      if (additionalColumns) {
+        for (const col of additionalColumns) {
+          if (col && row[col] !== undefined) {
+            additionalInfo[col] = row[col];
+          }
+        }
+      }
+
+      // 마커 생성
+      markers.push({
+        id: row.id || row.ID || `marker-${i}`,
+        latitude: lat,
+        longitude: lng,
+        label: labelColumn ? row[labelColumn] : undefined,
+        status: statusColumn ? row[statusColumn] : undefined,
+        additionalInfo: Object.keys(additionalInfo).length > 0 ? additionalInfo : undefined,
+      });
+    }
+
+    return markers;
+  }
+
+  /**
+   * 다양한 형식의 좌표 추출
+   */
+  private extractCoordinate(row: any, columnName: string): number | null {
+    const value = row[columnName];
+
+    if (value === null || value === undefined) {
+      return null;
+    }
+
+    // 이미 숫자인 경우
+    if (typeof value === "number") {
+      return value;
+    }
+
+    // 문자열인 경우 파싱
+    if (typeof value === "string") {
+      const parsed = parseFloat(value);
+      return isNaN(parsed) ? null : parsed;
+    }
+
+    return null;
+  }
+}
+