This commit is contained in:
2025-12-21 15:12:09 +03:00
parent e149d7380d
commit 865224ba5a
10 changed files with 145 additions and 156 deletions
+17 -14
View File
@@ -332,6 +332,7 @@ def api_vk():
@app.route("/api/posts", methods=["POST", "GET"])
def api_posts():
response = {"status": "ok"}
match request.method:
case "POST":
requestData = request.json
@@ -362,32 +363,34 @@ def api_posts():
logger.info("Обновление расписания публикации")
try:
scheduler = PostScheduler.query.first()
startTime = schedulerData.get("startTime", None)
endTime = schedulerData.get("endTime", None)
interval_minutes = schedulerData.get("interval_minutes", None)
hour = schedulerData.get("hour", None)
minute = schedulerData.get("minute", None)
enabled = schedulerData.get("enabled", None)
if scheduler:
if startTime:
scheduler.start_hour = int(startTime)
if endTime:
scheduler.end_hour = int(endTime)
if interval_minutes:
scheduler.interval_minutes = int(interval_minutes)
if hour is not None:
if scheduler.hour != hour:
scheduler.hour = hour
if minute is not None:
if scheduler.minute != minute:
scheduler.minute = minute
if enabled is not None:
scheduler.enabled = enabled
if scheduler.enabled != enabled:
scheduler.enabled = enabled
else:
db.session.merge(
PostScheduler(
start_hour=int(startTime),
end_hour=int(endTime),
interval_minutes=int(interval_minutes),
hour=int(hour),
minute=int(minute),
enabled=enabled,
)
)
db.session.commit()
enable_publish_job()
scheduleInfo = get_scheduler_status()
response["next_run_time"] = scheduleInfo.get("next_run_time")
except Exception as e:
logger.error(f"Ошибка при обновлении расписания публикации: {e}")
return jsonify({"status": "ok"})
return jsonify(response)
case "GET":
queryParams = request.args.to_dict()