Update app.py

app.py

@@ -56,7 +56,7 @@ def create_plan(account, limit):
     times = []
     for i in range(limit):
         planned_time = now + i * time_gap
-        # Ensure future time
+        # Ensure it's a future time (at least 1 minute ahead)
         if planned_time <= now:
             planned_time = now + timedelta(minutes=1)
         times.append(planned_time)
@@ -66,9 +66,12 @@ def create_plan(account, limit):
             "account_id": account["_id"],
             "scheduled_time": t.isoformat()
         })
+    print(f"✅ Created {len(times)} plan(s) for account {account['_id']}")
+
 
 def apply_plan():
     now = datetime.now(tz)
+    count = 0
     for plan in plans.find():
         plan_time = datetime.fromisoformat(plan["scheduled_time"]).astimezone(tz)
         if plan_time > now:
@@ -78,19 +81,25 @@ def apply_plan():
 
             userbot = userbots.get(account["_id"])
             if not userbot:
+                print(f"⚠️ No userbot for account {account['_id']}, skipping...")
                 continue
 
             def job_wrapper(acc_id):
                 def job():
-                    print(f"Running job for account {acc_id} at {datetime.now(tz)}")
-                    # Your action here
+                    print(f"🕒 Running job for account {acc_id} at {datetime.now(tz)}")
+                    # Put your real logic here
                 return job
 
-            scheduler.add_job(job_wrapper(account["_id"]), trigger='date', run_date=plan_time)
+            job_id = f"job_{plan['_id']}"
+            scheduler.add_job(job_wrapper(account["_id"]), trigger='date', run_date=plan_time, id=job_id)
+            print(f"📌 Scheduled job for account {account['_id']} at {plan_time.strftime('%H:%M:%S')} (ID: {job_id})")
+            count += 1
+    print(f"✅ Applied and scheduled {count} job(s).")
+
 
 def reset_and_plan():
     print("🔁 Resetting plans and scheduling new ones...")
-    plans.delete_many({})  # Clear all plans
+    plans.delete_many({})
     for acc in accounts.find():
         limit = random.randint(3, 5)
         create_plan(acc, limit)