arc/hesabixAPI/scripts/add_telephony_plugin.py

89 lines
2.5 KiB
Python

#!/usr/bin/env python3
"""ثبت افزونه اتصال به استریسک و ایزابل در بازار افزونه‌ها."""
import os
import sys
from datetime import datetime
sys.path.insert(0, os.path.dirname(os.path.dirname(os.path.abspath(__file__))))
from adapters.db.session import SessionLocal
from adapters.db.models.currency import Currency
from adapters.db.models.marketplace import MarketplacePlugin, MarketplacePluginPlan
PLUGIN_CODE = "asterisk_issabel_connector"
DESCRIPTION = (
"یکپارچگی مرکز تلفن Issabel/Asterisk با حسابیکس: Screen Pop، Click-to-Call، "
"تاریخچه تماس، نگاشت داخلی کاربران، اعلان لحظه‌ای و ثبت خودکار در CRM. "
"نیاز به نصب Hesabix Telephony Connector روی سرور تلفن دارد."
)
def main() -> int:
db = SessionLocal()
try:
currency = db.query(Currency).order_by(Currency.id.asc()).first()
if not currency:
print("✗ خطا: هیچ ارزی در سیستم یافت نشد")
return 1
currency_id = currency.id
plugin = db.query(MarketplacePlugin).filter(MarketplacePlugin.code == PLUGIN_CODE).first()
if plugin:
print("✓ افزونه از قبل وجود دارد — به‌روزرسانی...")
plugin.name = "اتصال به استریسک و ایزابل"
plugin.description = DESCRIPTION
plugin.category = "integration"
plugin.is_active = True
plugin.trial_days = 14
plugin.trial_allowed = True
plugin.updated_at = datetime.utcnow()
else:
plugin = MarketplacePlugin(
code=PLUGIN_CODE,
name="اتصال به استریسک و ایزابل",
description=DESCRIPTION,
category="integration",
icon_url=None,
is_active=True,
trial_days=14,
trial_allowed=True,
)
db.add(plugin)
db.flush()
plugin_id = plugin.id
for period, price in (("monthly", 350_000), ("yearly", 3_500_000)):
p = (
db.query(MarketplacePluginPlan)
.filter(MarketplacePluginPlan.plugin_id == plugin_id, MarketplacePluginPlan.period == period)
.first()
)
if not p:
db.add(
MarketplacePluginPlan(
plugin_id=plugin_id,
period=period,
price=price,
currency_id=currency_id,
is_active=True,
)
)
db.commit()
print(f"✓ افزونه استریسک/ایزابل آماده شد (plugin_id={plugin_id}).")
return 0
except Exception as e:
db.rollback()
print(f"✗ خطا: {e}")
import traceback
traceback.print_exc()
return 1
finally:
db.close()
if __name__ == "__main__":
sys.exit(main())