mirror of
https://github.com/BEDOLAGA-DEV/remnawave-bedolaga-telegram-bot.git
synced 2026-01-19 19:32:10 +00:00
Update campaigns.py
This commit is contained in:
@@ -5,7 +5,10 @@ from typing import Annotated, Literal, Optional
|
|||||||
|
|
||||||
from pydantic import BaseModel, Field, validator
|
from pydantic import BaseModel, Field, validator
|
||||||
|
|
||||||
CampaignBonusType = Annotated[Literal["balance", "subscription"], Field(description="Тип бонуса кампании")]
|
CampaignBonusType = Annotated[
|
||||||
|
Literal["balance", "subscription", "none", "tariff"],
|
||||||
|
Field(description="Тип бонуса кампании: balance (баланс), subscription (пробная подписка), none (без награды), tariff (тариф)")
|
||||||
|
]
|
||||||
|
|
||||||
|
|
||||||
class CampaignBase(BaseModel):
|
class CampaignBase(BaseModel):
|
||||||
@@ -17,6 +20,9 @@ class CampaignBase(BaseModel):
|
|||||||
subscription_traffic_gb: Optional[int] = Field(None, ge=0)
|
subscription_traffic_gb: Optional[int] = Field(None, ge=0)
|
||||||
subscription_device_limit: Optional[int] = Field(None, ge=0)
|
subscription_device_limit: Optional[int] = Field(None, ge=0)
|
||||||
subscription_squads: list[str] = Field(default_factory=list)
|
subscription_squads: list[str] = Field(default_factory=list)
|
||||||
|
# Поля для типа "tariff"
|
||||||
|
tariff_id: Optional[int] = Field(None, ge=1, description="ID тарифа для выдачи")
|
||||||
|
tariff_duration_days: Optional[int] = Field(None, ge=1, description="Длительность тарифа в днях")
|
||||||
|
|
||||||
@validator("name", "start_parameter")
|
@validator("name", "start_parameter")
|
||||||
def strip_strings(cls, value: str) -> str: # noqa: D401,B902
|
def strip_strings(cls, value: str) -> str: # noqa: D401,B902
|
||||||
@@ -39,6 +45,20 @@ class CampaignCreateRequest(CampaignBase):
|
|||||||
raise ValueError("subscription_duration_days must be positive for subscription bonus")
|
raise ValueError("subscription_duration_days must be positive for subscription bonus")
|
||||||
return value
|
return value
|
||||||
|
|
||||||
|
@validator("tariff_id")
|
||||||
|
def validate_tariff_id(cls, value: Optional[int], values: dict): # noqa: D401,B902
|
||||||
|
if values.get("bonus_type") == "tariff":
|
||||||
|
if value is None or value <= 0:
|
||||||
|
raise ValueError("tariff_id must be specified for tariff bonus")
|
||||||
|
return value
|
||||||
|
|
||||||
|
@validator("tariff_duration_days")
|
||||||
|
def validate_tariff_duration(cls, value: Optional[int], values: dict): # noqa: D401,B902
|
||||||
|
if values.get("bonus_type") == "tariff":
|
||||||
|
if value is None or value <= 0:
|
||||||
|
raise ValueError("tariff_duration_days must be positive for tariff bonus")
|
||||||
|
return value
|
||||||
|
|
||||||
|
|
||||||
class CampaignResponse(BaseModel):
|
class CampaignResponse(BaseModel):
|
||||||
id: int
|
id: int
|
||||||
@@ -51,6 +71,10 @@ class CampaignResponse(BaseModel):
|
|||||||
subscription_traffic_gb: Optional[int] = None
|
subscription_traffic_gb: Optional[int] = None
|
||||||
subscription_device_limit: Optional[int] = None
|
subscription_device_limit: Optional[int] = None
|
||||||
subscription_squads: list[str] = Field(default_factory=list)
|
subscription_squads: list[str] = Field(default_factory=list)
|
||||||
|
# Поля для типа "tariff"
|
||||||
|
tariff_id: Optional[int] = None
|
||||||
|
tariff_duration_days: Optional[int] = None
|
||||||
|
tariff_name: Optional[str] = None # Для отображения названия тарифа
|
||||||
is_active: bool
|
is_active: bool
|
||||||
created_by: Optional[int] = None
|
created_by: Optional[int] = None
|
||||||
created_at: datetime
|
created_at: datetime
|
||||||
@@ -74,6 +98,9 @@ class CampaignUpdateRequest(BaseModel):
|
|||||||
subscription_traffic_gb: Optional[int] = Field(None, ge=0)
|
subscription_traffic_gb: Optional[int] = Field(None, ge=0)
|
||||||
subscription_device_limit: Optional[int] = Field(None, ge=0)
|
subscription_device_limit: Optional[int] = Field(None, ge=0)
|
||||||
subscription_squads: Optional[list[str]] = None
|
subscription_squads: Optional[list[str]] = None
|
||||||
|
# Поля для типа "tariff"
|
||||||
|
tariff_id: Optional[int] = Field(None, ge=1)
|
||||||
|
tariff_duration_days: Optional[int] = Field(None, ge=1)
|
||||||
is_active: Optional[bool] = None
|
is_active: Optional[bool] = None
|
||||||
|
|
||||||
@validator("name", "start_parameter", pre=True)
|
@validator("name", "start_parameter", pre=True)
|
||||||
@@ -95,3 +122,17 @@ class CampaignUpdateRequest(BaseModel):
|
|||||||
if bonus_type == "subscription" and value is not None and value <= 0:
|
if bonus_type == "subscription" and value is not None and value <= 0:
|
||||||
raise ValueError("subscription_duration_days must be positive for subscription bonus")
|
raise ValueError("subscription_duration_days must be positive for subscription bonus")
|
||||||
return value
|
return value
|
||||||
|
|
||||||
|
@validator("tariff_id")
|
||||||
|
def validate_tariff_id(cls, value: Optional[int], values: dict): # noqa: D401,B902
|
||||||
|
bonus_type = values.get("bonus_type")
|
||||||
|
if bonus_type == "tariff" and value is not None and value <= 0:
|
||||||
|
raise ValueError("tariff_id must be positive for tariff bonus")
|
||||||
|
return value
|
||||||
|
|
||||||
|
@validator("tariff_duration_days")
|
||||||
|
def validate_tariff_duration(cls, value: Optional[int], values: dict): # noqa: D401,B902
|
||||||
|
bonus_type = values.get("bonus_type")
|
||||||
|
if bonus_type == "tariff" and value is not None and value <= 0:
|
||||||
|
raise ValueError("tariff_duration_days must be positive for tariff bonus")
|
||||||
|
return value
|
||||||
|
|||||||
Reference in New Issue
Block a user