-- Invalid geometry 수정 스크립트
-- "Too few points" 에러를 해결하기 위해 단일 포인트를 2번 반복

-- ========================================
-- 1. 백업 (선택사항)
-- ========================================
-- CREATE TABLE signal.t_vessel_tracks_5min_backup_20251107 AS
-- SELECT * FROM signal.t_vessel_tracks_5min
-- WHERE track_geom IS NOT NULL AND NOT public.ST_IsValid(track_geom);

-- ========================================
-- 2. Invalid geometry 수정 (DRY RUN - 먼저 확인)
-- ========================================
SELECT
    'DRY RUN - Will fix these records' as action,
    sig_src_cd,
    target_id,
    time_bucket,
    public.ST_NPoints(track_geom) as current_points,
    public.ST_AsText(track_geom) as current_wkt,
    -- 수정 후 WKT 미리보기
    CASE
        WHEN public.ST_NPoints(track_geom) = 1 THEN
            'LINESTRING M(' ||
            public.ST_X(public.ST_PointN(track_geom, 1)) || ' ' ||
            public.ST_Y(public.ST_PointN(track_geom, 1)) || ' ' ||
            public.ST_M(public.ST_PointN(track_geom, 1)) || ',' ||
            public.ST_X(public.ST_PointN(track_geom, 1)) || ' ' ||
            public.ST_Y(public.ST_PointN(track_geom, 1)) || ' ' ||
            public.ST_M(public.ST_PointN(track_geom, 1)) || ')'
        ELSE 'NO FIX NEEDED'
    END as new_wkt
FROM signal.t_vessel_tracks_5min
WHERE track_geom IS NOT NULL
  AND public.ST_IsValidReason(track_geom) LIKE '%Too few points%'
LIMIT 10;

-- ========================================
-- 3. 실제 수정 (확인 후 실행)
-- ========================================
-- 주의: 이 쿼리는 실제 데이터를 변경합니다!
-- DRY RUN 결과를 확인한 후 주석을 해제하고 실행하세요.

/*
UPDATE signal.t_vessel_tracks_5min
SET track_geom = public.ST_GeomFromText(
    'LINESTRING M(' ||
    public.ST_X(public.ST_PointN(track_geom, 1)) || ' ' ||
    public.ST_Y(public.ST_PointN(track_geom, 1)) || ' ' ||
    public.ST_M(public.ST_PointN(track_geom, 1)) || ',' ||
    public.ST_X(public.ST_PointN(track_geom, 1)) || ' ' ||
    public.ST_Y(public.ST_PointN(track_geom, 1)) || ' ' ||
    public.ST_M(public.ST_PointN(track_geom, 1)) || ')',
    4326
)
WHERE track_geom IS NOT NULL
  AND public.ST_NPoints(track_geom) = 1
  AND public.ST_IsValidReason(track_geom) LIKE '%Too few points%';
*/

-- ========================================
-- 4. 수정 결과 확인
-- ========================================
SELECT
    'AFTER FIX' as status,
    COUNT(*) as total_records,
    COUNT(CASE WHEN public.ST_IsValid(track_geom) THEN 1 END) as valid_count,
    COUNT(CASE WHEN NOT public.ST_IsValid(track_geom) THEN 1 END) as invalid_count
FROM signal.t_vessel_tracks_5min
WHERE track_geom IS NOT NULL;

-- ========================================
-- 5. 여전히 Invalid한 geometry 확인
-- ========================================
SELECT
    'REMAINING INVALID' as status,
    public.ST_IsValidReason(track_geom) as reason,
    COUNT(*) as count
FROM signal.t_vessel_tracks_5min
WHERE track_geom IS NOT NULL
  AND NOT public.ST_IsValid(track_geom)
GROUP BY public.ST_IsValidReason(track_geom);

-- ========================================
-- 6. Hourly 테이블도 동일하게 수정 (필요시)
-- ========================================
/*
UPDATE signal.t_vessel_tracks_hourly
SET track_geom = public.ST_GeomFromText(
    'LINESTRING M(' ||
    public.ST_X(public.ST_PointN(track_geom, 1)) || ' ' ||
    public.ST_Y(public.ST_PointN(track_geom, 1)) || ' ' ||
    public.ST_M(public.ST_PointN(track_geom, 1)) || ',' ||
    public.ST_X(public.ST_PointN(track_geom, 1)) || ' ' ||
    public.ST_Y(public.ST_PointN(track_geom, 1)) || ' ' ||
    public.ST_M(public.ST_PointN(track_geom, 1)) || ')',
    4326
)
WHERE track_geom IS NOT NULL
  AND public.ST_NPoints(track_geom) = 1
  AND public.ST_IsValidReason(track_geom) LIKE '%Too few points%';
*/

-- ========================================
-- 7. Daily 테이블도 동일하게 수정 (필요시)
-- ========================================
/*
UPDATE signal.t_vessel_tracks_daily
SET track_geom = public.ST_GeomFromText(
    'LINESTRING M(' ||
    public.ST_X(public.ST_PointN(track_geom, 1)) || ' ' ||
    public.ST_Y(public.ST_PointN(track_geom, 1)) || ' ' ||
    public.ST_M(public.ST_PointN(track_geom, 1)) || ',' ||
    public.ST_X(public.ST_PointN(track_geom, 1)) || ' ' ||
    public.ST_Y(public.ST_PointN(track_geom, 1)) || ' ' ||
    public.ST_M(public.ST_PointN(track_geom, 1)) || ')',
    4326
)
WHERE track_geom IS NOT NULL
  AND public.ST_NPoints(track_geom) = 1
  AND public.ST_IsValidReason(track_geom) LIKE '%Too few points%';
*/