from core.database import SchedulerDatabase
import json

db = SchedulerDatabase()

# Cerca schedule con "DataHub" e "Weekly"
print("=== SCHEDULE DATAHUB WEEKLY ===\n")
schedules = db.get_all_schedules()

for sched in schedules:
    name = sched.get('name', '').lower()
    if 'datahub' in name and 'weekly' in name:
        print(f"Schedule ID: {sched['id']}")
        print(f"Nome: {sched['name']}")
        print(f"Target Type: {sched['target_type']}")
        print(f"Target ID: {sched['target_id']}")
        print(f"Schedule Type: {sched['schedule_type']}")

        # Parse config
        config = sched['schedule_config']
        if isinstance(config, str):
            config = json.loads(config)

        print(f"Schedule Config: {json.dumps(config, indent=2)}")
        print(f"Enabled: {sched['enabled']}")
        print("-" * 50)

# Cerca anche nel target (job o group)
print("\n=== TARGET ASSOCIATO ===\n")
for sched in schedules:
    name = sched.get('name', '').lower()
    if 'datahub' in name and 'weekly' in name:
        target_type = sched['target_type']
        target_id = sched['target_id']

        if target_type == 'job':
            job = db.get_job(target_id)
            if job:
                print(f"Job ID: {job['id']}")
                print(f"Job Name: {job['name']}")
                print(f"Job Schedule Type: {job['schedule_type']}")
                print(f"Job Schedule Config: {job['schedule_config']}")

        elif target_type == 'group':
            with db._get_connection() as conn:
                cursor = conn.execute("SELECT * FROM job_groups WHERE id = ?", (target_id,))
                group = cursor.fetchone()
                if group:
                    print(f"Group ID: {group['id']}")
                    print(f"Group Name: {group['name']}")

                    # Get members
                    members = db.get_job_group_members(target_id)
                    print(f"Members: {len(members)}")
                    for mem in members:
                        print(f"  - Job: {mem['job_name']} (Order: {mem['execution_order']})")

print("\n=== ESECUZIONI OGGI ===\n")
with db._get_connection() as conn:
    cursor = conn.execute("""
        SELECT id, schedule_id, schedule_name, start_time, status, triggered_by
        FROM executions
        WHERE date(start_time) = date('now', 'localtime')
        AND (schedule_name LIKE '%DataHub%Weekly%' OR schedule_name LIKE '%DataHub Weekly%')
        ORDER BY start_time DESC
    """)
    execs = cursor.fetchall()

    for ex in execs:
        print(f"ID: {ex['id']}, Schedule: {ex['schedule_name']}, Time: {ex['start_time']}, Status: {ex['status']}, Triggered: {ex['triggered_by']}")