Insert from sleekflow

Check Data

WITH RankedTempLeads AS (
    SELECT 
        t.*,
        ROW_NUMBER() OVER (PARTITION BY t.phone ORDER BY t.created_at ASC) AS row_num
    FROM public.sleekflow t
    WHERE NOT EXISTS (
        SELECT 1
        FROM public.leads l
        WHERE l.phone = t.phone OR l.uid = t.id
    )
    AND NOT EXISTS (
        SELECT 1
        FROM public.family f
        WHERE f.family_phone = t.phone OR f.uid = t.id
    )
    AND t.phone IS NOT NULL
)
SELECT *
FROM RankedTempLeads
WHERE row_num = 1
ORDER BY phone ASC;

Insert

WITH rankedtempleads AS (
    SELECT 
    t.id, 
    t.conv_id, 
    t.created_at, 
    t.updated_at, 
    t.last_contact, 
    t.last_contact_from_customer, 
    t.last_channel, 
    t.interest, 
    t.interest_remarks, 
    t.language, 
    t.ad_source_url, 
    t.click_id, 
    t.phone, 
    t.name, 
    t.source, 
    t.sremarks, 
    t.medium, 
    t.mremarks, 
    t.branch, 
    t.contact_owner, 
    t.contact_owner_email, 
    t.last_contact_from_user, 
    t.last_contact_from_company, 
    t.sremarks_id, 
    t.ad_source_id, 
    t.uid,
        ROW_NUMBER() OVER (PARTITION BY t.phone ORDER BY t.created_at) AS row_num
    FROM public.sleekflow t
    WHERE 
        NOT EXISTS (
            SELECT 1
            FROM public.leads l
            WHERE l.phone = t.phone OR l.uid = t.id
        )
        AND NOT EXISTS (
            SELECT 1
            FROM public.family f
            WHERE f.family_phone = t.phone OR f.uid = t.id
        )
        AND t.phone IS NOT NULL
)
INSERT INTO public.leads (
    uid,
    "timestamp",
    phone,
    email,
    name,
    gender,
    date_of_birth,
    age,
    age_group,
    branch,
    language,
    contact_owner,
    source,
    sremarks,
    content,
    medium,
    mremarks,
    assigned_pic,
    interest,
    leads_notes,
    leads_qualification,
    user_type,
    kyzn_account,
    sleekflow_id,
    leads_date,
    mql_date,
    "mqlPlus_date",
    "tourPlus_date",
    convert_date,
    loss_date,
    tour_date,
    "is_tour_show?",
    trial_date,
    "is_trial_show?",
    "is_inbound?",
    "is_leads?",
    "is_mql?",
    "is_mqlPlus?",
    "is_tourPlus?",
    "is_trialPlus?",
    "is_convert?",
    interest_remarks,
    submitted_email,
    assigned_email,
    "trialPlus_date",
    membership_name,
    package_name,
    start_membership,
    member_id,
    total_amount,
    payment_method,
    promotion,
    ref_program,
    ref_id,
    ref_name,
    ref_phone,
    identity_photo,
    status,
    convert_by,
    end_membership,
    signature,
    contract,
    offer_trial,
    reply_after_offer,
    last_appt_category,
    "conversationId",
    assigned_date,
    last_created_by,
    is_renewal,
    approach_by,
    app_status,
    start_approach,
    expired_approach
)
SELECT 
    t.id AS uid,
    t.created_at,
    t.phone,
    NULL AS email,
    t.name,
    NULL AS gender,
    NULL AS  date_of_birth,
    NULL AS age,
    NULL AS age_group,
    t.branch,
    NULL AS language,
    t.contact_owner,
    t.source,
    t.sremarks,
    t.ad_source_url AS content,
    t.medium,
    t.mremarks,
    NULL AS assigned_pic,
    t.interest,
    NULL AS leads_notes,
    NULL AS leads_qualification,
    NULL AS user_type,
    NULL AS kyzn_account,
    t.id AS sleekflow_id,
    NULL AS leads_date,
    NULL AS mql_date,
    NULL AS "mqlPlus_date",
    NULL AS "tourPlus_date",
    NULL AS convert_date,
    NULL AS loss_date,
    NULL AS tour_date,
    NULL AS "is_tour_show?",
    NULL AS trial_date,
    NULL AS "is_trial_show?",
    TRUE AS "is_inbound?",
    NULL AS "is_leads?",
    NULL AS "is_mql?",
    NULL AS "is_mqlPlus?",
    NULL AS "is_tourPlus?",
    NULL AS "is_trialPlus?",
    NULL AS "is_convert?",
    t.interest_remarks,
    t.contact_owner_email AS submitted_email,
    NULL AS assigned_email,
    NULL AS "trialPlus_date",
    NULL AS membership_name,
    NULL AS package_name,
    NULL AS start_membership,
    NULL AS member_id,
    NULL AS total_amount,
    NULL AS payment_method,
    NULL AS promotion,
    NULL AS ref_program,
    NULL AS ref_id,
    NULL AS ref_name,
    NULL AS ref_phone,
    NULL AS identity_photo,
    NULL AS status,
    NULL AS convert_by,
    NULL AS end_membership,
    NULL AS signature,
    NULL AS contract,
    NULL AS offer_trial,
    NULL AS reply_after_offer,
    NULL AS last_appt_category,
    t.conv_id,
    NULL AS assigned_date,
    NULL AS last_created_by,
    NULL AS is_renewal,
    NULL AS approach_by,
    NULL AS app_status,
    NULL AS start_approach,
    NULL AS expired_approach
FROM rankedtempleads t
WHERE row_num = 1;