-- t_abnormal_tracks 테스트용 INSERT 쿼리
-- PostGIS ST_GeomFromText 함수 테스트

-- 1. 기본 테스트 (track_geom 컬럼 사용)
INSERT INTO signal.t_abnormal_tracks (
    sig_src_cd,
    target_id,
    time_bucket,
    track_geom,
    abnormal_type,
    abnormal_reason,
    distance_nm,
    avg_speed,
    max_speed,
    point_count,
    source_table
) VALUES (
    'AIS',                                          -- sig_src_cd
    'TEST_VESSEL_001',                              -- target_id
    '2025-10-10 12:00:00'::timestamp,              -- time_bucket
    ST_GeomFromText('LINESTRING M(126.0 37.0 1728547200, 126.1 37.1 1728547260)', 4326),  -- track_geom (LineString M 타입)
    'EXCESSIVE_SPEED',                              -- abnormal_type
    '{"reason": "Speed exceeds 200 knots", "detected_speed": 250.5}'::jsonb,  -- abnormal_reason
    15.5,                                           -- distance_nm
    180.3,                                          -- avg_speed
    250.5,                                          -- max_speed
    10,                                             -- point_count
    'hourly'                                        -- source_table
)
ON CONFLICT (sig_src_cd, target_id, time_bucket, source_table)
DO UPDATE SET
    track_geom = EXCLUDED.track_geom,
    abnormal_type = EXCLUDED.abnormal_type,
    abnormal_reason = EXCLUDED.abnormal_reason,
    distance_nm = EXCLUDED.distance_nm,
    avg_speed = EXCLUDED.avg_speed,
    max_speed = EXCLUDED.max_speed,
    point_count = EXCLUDED.point_count,
    detected_at = NOW();

-- 2. track_geom_v2 컬럼을 사용하는 경우
INSERT INTO signal.t_abnormal_tracks (
    sig_src_cd,
    target_id,
    time_bucket,
    track_geom_v2,
    abnormal_type,
    abnormal_reason,
    distance_nm,
    avg_speed,
    max_speed,
    point_count,
    source_table
) VALUES (
    'LRIT',                                         -- sig_src_cd
    'TEST_VESSEL_002',                              -- target_id
    '2025-10-10 13:00:00'::timestamp,              -- time_bucket
    ST_GeomFromText('LINESTRING M(127.0 38.0 1728550800, 127.2 38.2 1728550860, 127.4 38.4 1728550920)', 4326),  -- track_geom_v2
    'UNREALISTIC_DISTANCE',                         -- abnormal_type
    '{"reason": "Distance too large for time interval", "distance_nm": 120.0, "time_interval_minutes": 5}'::jsonb,  -- abnormal_reason
    120.0,                                          -- distance_nm
    1440.0,                                         -- avg_speed (120nm / 5min = 1440 knots)
    1500.0,                                         -- max_speed
    3,                                              -- point_count
    '5min'                                          -- source_table
)
ON CONFLICT (sig_src_cd, target_id, time_bucket, source_table)
DO UPDATE SET
    track_geom_v2 = EXCLUDED.track_geom_v2,
    abnormal_type = EXCLUDED.abnormal_type,
    abnormal_reason = EXCLUDED.abnormal_reason,
    distance_nm = EXCLUDED.distance_nm,
    avg_speed = EXCLUDED.avg_speed,
    max_speed = EXCLUDED.max_speed,
    point_count = EXCLUDED.point_count,
    detected_at = NOW();

-- 3. public 스키마를 명시적으로 지정한 버전
INSERT INTO signal.t_abnormal_tracks (
    sig_src_cd,
    target_id,
    time_bucket,
    track_geom,
    abnormal_type,
    abnormal_reason,
    distance_nm,
    avg_speed,
    max_speed,
    point_count,
    source_table
) VALUES (
    'VPASS',                                        -- sig_src_cd
    'TEST_VESSEL_003',                              -- target_id
    '2025-10-10 14:00:00'::timestamp,              -- time_bucket
    public.ST_GeomFromText('LINESTRING M(128.0 36.0 1728554400, 128.1 36.1 1728554460)', 4326),  -- public 스키마 명시
    'SUDDEN_DIRECTION_CHANGE',                      -- abnormal_type
    '{"reason": "Unrealistic turn angle", "angle_degrees": 175}'::jsonb,  -- abnormal_reason
    8.5,                                            -- distance_nm
    102.0,                                          -- avg_speed
    120.0,                                          -- max_speed
    2,                                              -- point_count
    'hourly'                                        -- source_table
)
ON CONFLICT (sig_src_cd, target_id, time_bucket, source_table)
DO UPDATE SET
    track_geom = EXCLUDED.track_geom,
    abnormal_type = EXCLUDED.abnormal_type,
    abnormal_reason = EXCLUDED.abnormal_reason,
    distance_nm = EXCLUDED.distance_nm,
    avg_speed = EXCLUDED.avg_speed,
    max_speed = EXCLUDED.max_speed,
    point_count = EXCLUDED.point_count,
    detected_at = NOW();

-- 4. 검증 쿼리
SELECT
    sig_src_cd,
    target_id,
    time_bucket,
    abnormal_type,
    abnormal_reason,
    distance_nm,
    avg_speed,
    max_speed,
    point_count,
    source_table,
    ST_AsText(track_geom) as track_geom_wkt,
    ST_AsText(track_geom_v2) as track_geom_v2_wkt,
    detected_at
FROM signal.t_abnormal_tracks
WHERE target_id LIKE 'TEST_VESSEL_%'
ORDER BY time_bucket DESC;

-- 5. 정리 (테스트 데이터 삭제)
-- DELETE FROM signal.t_abnormal_tracks WHERE target_id LIKE 'TEST_VESSEL_%';