Sorgu 0x40E4B9F00A728CCB

(@ProfileStaleDays int)WITH seen AS (
        SELECT q.ServerID, CONCAT(q.ServerID, N'|', q.DatabaseName, N'|', CONVERT(varchar(18), q.query_hash, 1)) AS SourceRef, MAX(q.StatDateUtc) AS LastDay
        FROM perf.QueryDailyStats AS q GROUP BY q.ServerID, q.DatabaseName, q.query_hash
    ), lastDay AS (
        SELECT q.ServerID, MAX(q.StatDateUtc) AS LastDay FROM perf.QueryDailyStats AS q GROUP BY q.ServerID
    ), src AS (
        SELECT d.SourceType, d.SourceRef, 0 AS Ord, d.DocId AS Seq
        FROM rag.Document AS d WHERE d.SourceType = 'Case'
        UNION
        SELECT 'Case', CAST(r.RequestID AS nvarchar(20)), 0, 0
        FROM rag.AnalysisRequest AS r
        WHERE r.Status = 'Done'
          AND EXISTS (SELECT 1 FROM rag.AnalysisRecommendation AS a WHERE a.RequestID = r.RequestID AND a.Decision IN ('Approved', 'Applied'))
        UNION
        SELECT 'Case', N'plan:' + CAST(c.CaseID AS nvarchar(20)), 0, 0
        FROM rag.PlanChangeCase AS c WHERE c.Status IN ('Accepted', 'AutoAccepted')
        UNION
        SELECT d.SourceType, d.SourceRef, 1, d.DocId
        FROM rag.Document AS d
        LEFT JOIN seen AS s ON s.SourceRef = d.SourceRef
        LEFT JOIN lastDay AS l ON l.ServerID = d.ServerID
        WHERE d.SourceType = 'Profile' AND d.IsActive = 1
          AND (s.LastDay IS NULL OR s.LastDay < DATEADD(day, -@ProfileStaleDays, l.LastDay))
    ), one AS (
        SELECT SourceType, SourceRef, MIN(Ord) AS Ord, MAX(Seq) AS Seq FROM src GROUP BY SourceType, SourceRef
    )
    INSERT rag.EmbedQueue (SourceType, SourceRef)
    SELECT o.SourceType, o.SourceRef
    FROM one AS o
    WHERE NOT EXISTS (SELECT 1 FROM rag.EmbedQueue AS e
                      WHERE e.SourceType = o.SourceType AND e.SourceRef = o.SourceRef AND e.Status IN ('Queued', 'Running'))
      AND NOT EXISTS (SELECT 1 FROM rag.Document AS h
                      WHERE h.SourceType = o.SourceType AND h.SourceRef = o.SourceRef AND h.ExclusionReason IN ('Deleted', 'Manual'))
    ORDER BY o.Ord, o.Seq, o.SourceRef