به ازای هر کاربری که با لینک دعوت شما عضو ربات شود، تعداد {invite_connects} کانکت (بید) به صورت آنی به موجودی شما افزوده میشود.
" "| 📊 تعداد کل دعوتشدهها | {stats['count']} نفر |
|---|---|
| 🎁 کل کانکتهای هدیه دریافتی | {stats['count'] * invite_connects} کانکت |
{ref_link}"
"(لینک بالا را کپی کرده و برای دوستان خود بفرستید)
" ) rich_msg = InputRichMessage(html=html_content) await bot.send_rich_message(chat_id=message.chat.id, rich_message=rich_msg) @router.message(F.text == texts.BTN_SUPPORT, StateFilter("*")) async def start_support(message: Message, state: FSMContext, bot: Bot): await check_and_clear_chat_session(state, bot) await state.clear() try: await message.react([ReactionTypeEmoji(emoji="📞")]) except: pass from aiogram.utils.keyboard import InlineKeyboardBuilder builder = InlineKeyboardBuilder() builder.button(text="📖 راهنمای استفاده و سوالات متداول", callback_data="support_faq") builder.button(text="🎫 ثبت تیکت پشتیبانی", callback_data="support_submit_ticket") builder.adjust(1) html_menu = ( "به بخش پشتیبانی خوش آمدید. لطفاً یکی از گزینههای زیر را انتخاب کنید:
" "💡 پیشنهاد میکنیم قبل از ثبت تیکت، بخش راهنما و سوالات متداول را مطالعه کنید. اکثر سوالات کارفرمایان و فریلنسرها در آنجا پاسخ داده شده است." ) rich_msg = InputRichMessage(html=html_menu) await bot.send_rich_message(chat_id=message.chat.id, rich_message=rich_msg, reply_markup=builder.as_markup()) async def forward_message_with_quote(bot: Bot, message: Message, target_id: int, prefix_text: str = None): quoted_text = "" if message.quote: quoted_text = message.quote.text elif message.reply_to_message: quoted_text = message.reply_to_message.text or message.reply_to_message.caption or "پیوست رسانهای" if quoted_text: if len(quoted_text) > 150: quoted_text = quoted_text[:147] + "..." quote_html = f"
نقلقول:\n{quoted_text}\n\n" if prefix_text: quote_html = prefix_text + "\n" + quote_html msg_text = message.html_text or "" try: if message.text: await bot.send_message(target_id, quote_html + msg_text, parse_mode="HTML") elif message.photo: await bot.send_photo(target_id, message.photo[-1].file_id, caption=quote_html + msg_text, parse_mode="HTML") elif message.document: await bot.send_document(target_id, message.document.file_id, caption=quote_html + msg_text, parse_mode="HTML") elif message.video: await bot.send_video(target_id, message.video.file_id, caption=quote_html + msg_text, parse_mode="HTML") elif message.voice: await bot.send_voice(target_id, message.voice.file_id, caption=quote_html + msg_text, parse_mode="HTML") elif message.audio: await bot.send_audio(target_id, message.audio.file_id, caption=quote_html + msg_text, parse_mode="HTML") else: if prefix_text: await bot.send_message(target_id, prefix_text, parse_mode="HTML") await message.copy_to(chat_id=target_id) except Exception as e: raise e else: if prefix_text: await bot.send_message(target_id, prefix_text, parse_mode="HTML") await message.copy_to(chat_id=target_id) @router.message(ChatSession.in_chat) async def chat_message_forwarder(message: Message, state: FSMContext, bot: Bot): data = await state.get_data() target_id = data.get("target_id") is_fulltime = data.get("is_fulltime", False) if not target_id: await state.clear() db_user = await db.get_user(message.from_user.id) await message.answer("❌ خطا: گفتگوی فعال یافت نشد. به منوی اصلی بازگشتید.") await send_main_menu(message, db_user) return content_text = message.text or message.caption or "" if not is_fulltime and contains_forbidden_info(content_text): try: await message.delete() except: pass await message.answer(texts.CHAT_BLOCKED_MSG, parse_mode="HTML") return try: await forward_message_with_quote(bot, message, target_id) except Exception as e: await message.answer("❌ ارسال پیام با خطا مواجه شد. ممکن است طرف مقابل ربات را بلاک کرده باشد.") @router.callback_query(F.data.startswith("user_enter_dispute_chat_")) async def user_enter_dispute_chat(callback: CallbackQuery, state: FSMContext, bot: Bot): project_id = int(callback.data.split("_")[-1]) project = await db.get_project(project_id) if not project: return await callback.answer("پروژه یافت نشد.", show_alert=True) # Ensure project status is disputed if project['status'] != 'disputed': return await callback.answer("این پروژه در وضعیت شکایت/داوری نیست.", show_alert=True) user_id = callback.from_user.id # Ensure user is client or chosen freelancer if user_id != project['client_id'] and user_id != project['chosen_freelancer_id']: return await callback.answer("شما دسترسی به این چت داوری را ندارید.", show_alert=True) # Set FSM state await state.set_state(DisputeChat.in_chat) await state.update_data(project_id=project_id) # Ensure dispute chat record exists await db.create_dispute_chat(project_id, project['client_id'], project['chosen_freelancer_id']) welcome_text = ( f"⚖️ شما وارد چت داوری پروژه #{project_id} شدید.\n\n" f"پیامهای متنی و رسانهای شما به صورت خودکار برای سایر اعضا (طرف مقابل پروژه و داور ادمین) ارسال میشود.\n" f"مدارک و توضیحات خود را در این بخش ارسال کنید.\n" f"برای خروج از چت از دکمه زیر استفاده کنید:" ) from keyboards.reply import dispute_chat_keyboard await callback.message.answer( welcome_text, reply_markup=dispute_chat_keyboard(), parse_mode="HTML" ) await callback.answer("وارد چت داوری شدید.") @router.message(DisputeChat.in_chat) async def dispute_message_forwarder(message: Message, state: FSMContext, bot: Bot): # If the user wants to leave if message.text == "خروج از چت داوری ⚖️": await state.clear() user_id = message.from_user.id db_user = await db.get_user(user_id) await message.answer("⚖️ شما از چت داوری خارج شدید.") if db_user: await send_main_menu(message, db_user) return data = await state.get_data() project_id = data.get("project_id") if not project_id: await state.clear() user_id = message.from_user.id db_user = await db.get_user(user_id) await message.answer("❌ خطا: گفتگوی فعال یافت نشد. به منوی اصلی بازگشتید.") if db_user: await send_main_menu(message, db_user) return # Fetch chat info chat_info = await db.get_dispute_chat(project_id) if not chat_info: await message.answer("❌ خطا: اطلاعات چت داوری یافت نشد.") return client_id = chat_info['client_id'] freelancer_id = chat_info['freelancer_id'] admin_id = chat_info['admin_id'] sender_id = message.from_user.id # Determine sender label if sender_id == client_id: label = "👔 کارفرما:" recipients = [r for r in [freelancer_id, admin_id] if r and r != sender_id] elif sender_id == freelancer_id: label = "💻 فریلنسر:" recipients = [r for r in [client_id, admin_id] if r and r != sender_id] elif sender_id in ADMIN_IDS or sender_id == admin_id: label = "🛡️ داور (ادمین):" recipients = [r for r in [client_id, freelancer_id] if r and r != sender_id] else: # Fallback just in case label = "👤 کاربر ناشناس:" recipients = [r for r in [client_id, freelancer_id, admin_id] if r and r != sender_id] # Forward to all recipients for recipient in recipients: try: await forward_message_with_quote(bot, message, recipient, prefix_text=label) except Exception as e: # We can log or notify sender, but continue to other recipients pass # ── Invoice Helper ────────────────────────────────────────────────── async def send_invoice_to_parties( bot: Bot, project_id: int, project_title: str, client_id: int, client_name: str, freelancer_id: int, freelancer_name: str, amount: int, commission: int, payout: int, commission_pct: int, is_refund: bool = False, milestone_title: str = None, milestone_id: int = None, ): """Generate and send Farsi invoice PDF to both parties.""" from utils.pdf_invoice import generate_farsi_invoice_pdf from aiogram.types import FSInputFile filepath = await generate_farsi_invoice_pdf( project_id=project_id, project_title=project_title, client_id=client_id, client_name=client_name, freelancer_id=freelancer_id, freelancer_name=freelancer_name, amount=amount, commission=commission, payout=payout, commission_pct=commission_pct, is_refund=is_refund, milestone_title=milestone_title, milestone_id=milestone_id, ) if not filepath: return caption = ( f"📄 {'رسید رسمی استرداد وجه' if is_refund else 'فاکتور رسمی تسویهحساب'} پرداخت امن\n\n" f"📌 پروژه: {project_title}\n" f"🆔 شناسه پروژه:
#{project_id}\n"
f"💰 مبلغ کل: {amount:,} تومان\n\n"
f"فاکتور رسمی پرداخت امن پروژه شما صادر شد."
)
try:
doc = FSInputFile(filepath)
await bot.send_document(client_id, doc, caption=caption, parse_mode="HTML")
except Exception:
pass
if freelancer_id and freelancer_id != 0:
try:
doc = FSInputFile(filepath)
await bot.send_document(freelancer_id, doc, caption=caption, parse_mode="HTML")
except Exception:
pass
# Clean up file after sending
import os
try:
os.remove(filepath)
except Exception:
pass
# ── Jury Vote Handler ──────────────────────────────────────────────
@router.callback_query(F.data.startswith("jury_vote_"))
async def jury_vote_handler(callback: CallbackQuery, bot: Bot, state: FSMContext):
# Parse: jury_vote_{pid}_{release|refund}
parts = callback.data.split("_")
vote_type = parts[-1] # release or refund
pid = int(parts[-2])
juror_id = callback.from_user.id
# Validate vote type
if vote_type not in ('release', 'refund'):
return await callback.answer("❌ رأی نامعتبر.", show_alert=True)
# Check eligibility: juror should not be client or freelancer of this project
project = await db.get_project(pid)
if not project:
return await callback.answer("پروژه یافت نشد.", show_alert=True)
if juror_id == project['client_id'] or juror_id == project['chosen_freelancer_id']:
return await callback.answer("⚠️ شما طرف این پروژه هستید و مجاز به رأیدهی نیستید.", show_alert=True)
# Cast vote
result = await db.cast_jury_vote(pid, juror_id, vote_type)
if result['status'] == 'already_voted':
return await callback.answer("⚠️ شما قبلاً در این پرونده رأی دادهاید.", show_alert=True)
if result['status'] == 'voted':
# Vote registered but quorum not met yet
await callback.message.edit_text(
(callback.message.text or callback.message.caption or "پرونده داوری") + f"\n\n✅ رأی شما ثبت شد. ({result['total_votes']}/{db.JURY_QUORUM} رأی)",
parse_mode="HTML"
)
await callback.answer("✅ رأی شما با موفقیت ثبت شد!")
return
if result['status'] == 'resolved':
if result['result'] is None:
# Case was already resolved before this vote
return await callback.answer("⚠️ این پرونده قبلاً حلوفصل شده است.", show_alert=True)
# Quorum reached! Execute resolution
verdict = result['result']
import aiosqlite
from config import DB_PATH, COMMISSION_FREE, COMMISSION_VIP
# Fetch escrow info
amount = 0
freelancer_id = project['chosen_freelancer_id']
client_id = project['client_id']
try:
async with aiosqlite.connect(DB_PATH) as conn:
conn.row_factory = aiosqlite.Row
async with conn.execute('SELECT amount FROM escrow WHERE project_id = ? AND status = "held"', (pid,)) as cursor:
row = await cursor.fetchone()
amount = row['amount'] if row else 0
except Exception:
pass
# Execute verdict
if verdict == 'release':
commission_rate = await db.get_user_commission_rate(freelancer_id)
commission_pct = int(commission_rate * 100)
commission = int(amount * commission_rate)
payout = amount - commission
try:
await db.complete_project(
project_id=pid,
freelancer_id=freelancer_id,
amount=amount,
commission_rate=commission_rate,
client_id=client_id,
)
except Exception:
pass
else: # refund
commission_pct = 0
commission = 0
payout = 0
await db.refund_project(pid)
# Send invoice to both parties
client_user = await db.get_user(client_id)
freelancer_user = await db.get_user(freelancer_id)
client_name = (client_user['full_name'] or client_user['username'] or str(client_id)) if client_user else str(client_id)
freelancer_name = (freelancer_user['full_name'] or freelancer_user['username'] or str(freelancer_id)) if freelancer_user else str(freelancer_id)
await send_invoice_to_parties(
bot=bot,
project_id=pid,
project_title=project['title'],
client_id=client_id,
client_name=client_name,
freelancer_id=freelancer_id,
freelancer_name=freelancer_name,
amount=amount,
commission=commission,
payout=payout,
commission_pct=commission_pct,
is_refund=(verdict == 'refund'),
)
# Reward jurors who voted with the majority
JURY_REWARD_BALANCE = 5000 # 5,000 Tomans
JURY_REWARD_CONNECTS = 5
votes = await db.get_jury_votes_for_case(pid)
for v in votes:
if v['vote'] == verdict:
await db.update_balance(
v['juror_id'], JURY_REWARD_BALANCE, 'jury_reward',
f'پاداش داوری پروژه #{pid}'
)
await db.update_connects(
v['juror_id'], JURY_REWARD_CONNECTS, 'jury_reward',
f'پاداش کانکت داوری پروژه #{pid}'
)
# Clear dispute chat states for all participants
from handlers.admin import clear_dispute_chat_states
await clear_dispute_chat_states(bot, state.storage, pid, client_id, freelancer_id)
# Notify parties
verdict_fa = "آزادسازی وجه به فریلنسر ✅" if verdict == 'release' else "استرداد وجه به کارفرما ↩️"
verdict_text = (
f"⚖️🗳 رأی نهایی هیئت داوران ایکسلنسر\n\n"
f"📌 پروژه #{pid}: {project['title']}\n"
f"🗳 نتیجه: {verdict_fa}\n"
f"💰 مبلغ: {amount:,} تومان\n\n"
f"📄 فاکتور رسمی تسویهحساب به صورت PDF ارسال شد."
)
try:
await bot.send_message(client_id, verdict_text, parse_mode="HTML")
except Exception:
pass
try:
await bot.send_message(freelancer_id, verdict_text, parse_mode="HTML")
except Exception:
pass
# Notify admins
recipients = await db.get_admin_recipients('disputes')
for admin_id in recipients:
try:
jury_case = await db.get_jury_case(pid)
await bot.send_message(
admin_id,
f"🗳 نتیجه داوری هیئتمنصفه — پروژه #{pid}\n\n"
f"📌 پروژه: {project['title']}\n"
f"🔢 آرا: 🔓 آزادسازی: {jury_case['votes_release']} | ↩️ استرداد: {jury_case['votes_refund']}\n"
f"✅ رأی نهایی: {verdict_fa}",
parse_mode="HTML"
)
except Exception:
pass
# Update juror's message
await callback.message.edit_text(
(callback.message.text or callback.message.caption or "پرونده داوری") + f"\n\n✅ رأی شما ثبت و پرونده حل شد!\nنتیجه: {verdict_fa}\n🎁 پاداش ۵,۰۰۰ تومان + ۵ کانکت واریز شد.",
parse_mode="HTML"
)
await callback.answer("✅ پرونده حل شد! پاداش واریز گردید.")
return
@router.message(CommandStart())
async def cmd_start(message: Message, db_user, state: FSMContext, is_new_user: bool = False):
await state.clear()
try: await message.react([ReactionTypeEmoji(emoji="👋")])
except: pass
args = message.text.split()
# Handle deep link start parameter
if len(args) > 1:
param = args[1]
if param.startswith("project_"):
try:
project_id = int(param.split("_")[1])
project = await db.get_project(project_id)
if project:
bid_count = len(await db.get_bids_for_project(project_id))
client_stats = await db.get_client_rating_stats(project['client_id'])
if client_stats and client_stats['total_projects'] > 0:
client_rating_str = f"⭐️ {client_stats['avg_rating']:.1f} ({client_stats['total_projects']} همکاری)"
else:
client_rating_str = "جدید (بدون امتیاز)"
card = texts.project_card(project)
card += f"\n👔 اعتبار کارفرما: {client_rating_str}"
card += f"\n👥 تعداد پیشنهادها: {bid_count}"
role = db_user['role'] if db_user else 'freelancer'
if role == 'freelancer':
await message.answer(card, reply_markup=inline.project_action_keyboard(project_id), parse_mode="HTML")
else:
await message.answer(card, parse_mode="HTML")
return
except Exception:
pass
# Referral link logic for new users
if is_new_user:
args = message.text.split()
referrer_id = None
if len(args) > 1 and args[1].startswith("ref_"):
try:
referrer_id = int(args[1].split("_")[1])
except:
pass
if referrer_id and referrer_id != message.from_user.id:
ref_user = await db.get_user(referrer_id)
if ref_user:
success = await db.save_referral(message.from_user.id, referrer_id)
if success:
invite_connects = await db.get_setting_int("invite_connects", 5)
await db.update_connects(referrer_id, invite_connects, "referral", f"دعوت از کاربر ({message.from_user.full_name or message.from_user.id})")
try:
await message.bot.send_message(
referrer_id,
f"🎉 پاداش زیرمجموعهگیری!\n\n"
f"کاربر «{message.from_user.full_name}» با دعوت شما عضو شد و {invite_connects} کانکت (بید) هدیه به موجودی شما افزوده گردید.",
parse_mode="HTML"
)
except:
pass
is_admin_user = message.from_user.id in __import__('config').ADMIN_IDS
if not db_user or not db_user['role']:
if is_admin_user:
# Admins bypass registration
await db.set_user_role(message.from_user.id, 'client')
db_user = await db.get_user(message.from_user.id)
return await send_main_menu(message, db_user)
banner_file_id = await db.get_setting("welcome_banner_file_id", "")
sent = False
if banner_file_id:
try:
await message.answer_photo(
photo=banner_file_id,
caption=texts.ONBOARDING_1,
reply_markup=inline.onboarding_step_1(),
parse_mode="HTML"
)
sent = True
except Exception:
pass
if not sent:
import os
from aiogram.types import FSInputFile
banner_path = "assets/welcome_banner.png"
if os.path.exists(banner_path):
try:
photo_file = FSInputFile(banner_path)
sent_msg = await message.answer_photo(
photo=photo_file,
caption=texts.ONBOARDING_1,
reply_markup=inline.onboarding_step_1(),
parse_mode="HTML"
)
if sent_msg.photo:
new_file_id = sent_msg.photo[-1].file_id
await db.update_setting("welcome_banner_file_id", new_file_id)
sent = True
except Exception:
pass
if not sent:
await message.answer(texts.ONBOARDING_1, reply_markup=inline.onboarding_step_1())
else:
await send_main_menu(message, db_user)
@router.callback_query(F.data.startswith("role_"))
async def process_role_selection(callback: CallbackQuery, state: FSMContext, db_user):
role = callback.data.split("_")[1]
await db.set_user_role(callback.from_user.id, role)
try:
await callback.message.delete()
except Exception:
pass
await state.set_state(Registration.waiting_for_name)
await callback.message.answer(
"📝 مرحله ۱ از ۲: نام و نام خانوادگی\n\n"
"لطفاً نام و نام خانوادگی واقعی خود را جهت نمایش در پروفایل وارد کنید:",
parse_mode="HTML"
)
await callback.answer()
@router.message(Registration.waiting_for_name)
async def process_registration_name(message: Message, state: FSMContext):
if len(message.text) < 3:
return await message.answer("❌ نام وارد شده بسیار کوتاه است. لطفاً نام کامل خود را وارد کنید.")
await db.update_user_full_name(message.from_user.id, message.text)
await state.set_state(Registration.waiting_for_rules)
from aiogram.utils.keyboard import InlineKeyboardBuilder
rules_kb = InlineKeyboardBuilder()
rules_kb.button(text="✅ قوانین را میپذیرم", callback_data="accept_rules")
rules_kb.adjust(1)
await message.answer(
"⚖️ مرحله ۲ از ۲: پذیرش قوانین\n\n"
"۱. احترام به طرفین در چتها الزامی است.\n"
"۲. انجام هرگونه تراکنش مالی خارج از پلتفرم ممنوع است.\n"
"۳. پلتفرم هیچگونه مسئولیتی در قبال توافقات خارج از ربات ندارد.\n\n"
"آیا با قوانین پلتفرم ایکسلنسر موافق هستید؟",
reply_markup=rules_kb.as_markup(),
parse_mode="HTML"
)
@router.callback_query(Registration.waiting_for_rules, F.data == "accept_rules")
async def process_registration_rules(callback: CallbackQuery, state: FSMContext):
await state.clear()
try:
await callback.message.delete()
except:
pass
updated_user = await db.get_user(callback.from_user.id)
await callback.message.answer("🎉 ثبتنام شما با موفقیت تکمیل شد!\nبه ایکسلنسر خوش آمدید.", parse_mode="HTML")
await send_main_menu(callback.message, updated_user)
await callback.answer()
@router.message(SupportSession.waiting_for_message)
async def process_support_message(message: Message, state: FSMContext, bot: Bot):
if message.text == texts.BTN_BACK:
await state.clear()
# Fallthrough to back_handler
return
query_text = message.text or message.caption or "رسانه/فایل ارسال شده است."
try: await message.react([ReactionTypeEmoji(emoji="📨")])
except: pass
ticket_id = await db.create_support_ticket(message.from_user.id, query_text)
await state.clear()
confirm_text = (
"✅ پیام شما با موفقیت به عنوان تیکت ثبت شد!\n\n"
f"🎫 شناسه تیکت: #SP-{ticket_id}\n"
"پشتیبانهای ما پس از بررسی پاسخ تیکت را برای شما ارسال خواهند کرد."
)
is_admin = message.from_user.id in __import__('config').ADMIN_IDS
await message.answer(confirm_text, reply_markup=reply.client_main_menu(is_admin=is_admin), parse_mode="HTML", message_effect_id="5107584321108051014")
recipients = await db.get_admin_recipients('support')
for admin_id in recipients:
try:
await bot.send_message(
admin_id,
f"📞 تیکت پشتیبانی جدید (#SP-{ticket_id})\n\n"
f"👤 فرستنده: {message.from_user.full_name} (ID: `{message.from_user.id}`)\n"
f"شناسه کاربری: @{message.from_user.username or 'ندارد'}\n\n"
f"متن پیام:\n{query_text}",
parse_mode="HTML",
reply_markup=inline.admin_ticket_action_keyboard(ticket_id)
)
if message.content_type != 'text':
await message.copy_to(admin_id)
except: pass
# Back button is handled by the global StateFilter("*") handler at the top
async def send_main_menu(message: Message, db_user):
if not db_user:
return
user_id = db_user['user_id']
is_admin = user_id in ADMIN_IDS
role = db_user['role'] or 'freelancer'
balance = db_user['balance'] or 0
vip_level = await db.check_vip_level(user_id)
vip_names = {0: "👤 کاربر عادی", 1: "🥉 برنزی", 2: "🥈 نقرهای", 3: "🥇 طلایی"}
vip_str = vip_names.get(vip_level, "👤 کاربر عادی")
full_name = db_user['full_name'] or db_user['username'] or "کاربر"
ref_stats = await db.get_referral_stats(user_id)
referrals_count = ref_stats.get('count', 0)
referrals_reward = ref_stats.get('earnings', 0)
if role == 'client':
project_stats = await db.get_client_project_status_stats(user_id)
open_projects = project_stats.get('open', 0)
in_progress_projects = project_stats.get('in_progress', 0) + project_stats.get('delivered', 0)
completed_projects = project_stats.get('completed', 0)
html_dashboard = (
"به داشبورد کارفرمایی خوش آمدید. در این بخش میتوانید سفارشهای ثبت شده را مدیریت کنید.
" "| 👤 مشخصات کاربری | " "|
|---|---|
| 👤 نام شما | " f"{full_name} | "
"
| ✨ سطح کاربری | " f"{vip_str} | " "
| Purse 👛 موجودی کیف پول | " f"{balance:,} تومان | "
"
| 📊 آمار پروژههای شما | " "||
|---|---|---|
| 🟢 باز | " "🔵 در حال انجام | " "✅ تکمیل شده | " "
| {open_projects} | " f"{in_progress_projects} | " f"{completed_projects} | " "
| 👥 سیستم دعوت دوستان | " "|
|---|---|
| 🔗 تعداد دعوتشدگان | " f"{referrals_count} نفر | " "
| 🎁 درآمد کسبشده | " f"{referrals_reward:,} تومان | "
"
🚀 از دکمههای زیر جهت ثبت سفارش و مدیریت استفاده کنید:
" ) kb = reply.client_main_menu(is_admin=is_admin) else: connects = db_user['connects'] if 'connects' in dict(db_user) else 5 bids_count = await db.count_freelancer_bids(user_id) # Query completed projects and ratings import aiosqlite from database.db import DB_PATH completed_projects = 0 avg_rating = 0.0 try: async with aiosqlite.connect(DB_PATH) as conn: conn.row_factory = aiosqlite.Row async with conn.execute( '''SELECT COUNT(*) as total_projects, COALESCE(AVG(rating_to_freelancer), 0) as avg_rating FROM projects WHERE chosen_freelancer_id = ? AND status = 'completed' AND rating_to_freelancer IS NOT NULL''', (user_id,) ) as cursor: stats = await cursor.fetchone() if stats: completed_projects = stats['total_projects'] avg_rating = round(stats['avg_rating'], 1) except Exception: pass html_dashboard = ( "به داشبورد فریلنسری خوش آمدید. از بخش زیر میتوانید پروژهها را جستجو کرده و پیشنهاد ارسال کنید.
" "| 👤 مشخصات کاربری | " "|
|---|---|
| 👤 نام شما | " f"{full_name} | "
"
| ✨ سطح کاربری | " f"{vip_str} | " "
| Purse 👛 موجودی کیف پول | " f"{balance:,} تومان | "
"
| 🪙 اعتبار کانکت (بید) | " f"{connects} عدد | " "
| 📊 خلاصه عملکرد کاری | " "||
|---|---|---|
| 📨 پیشنهادات | " "✅ موفق | " "⭐️ امتیاز میانگین | " "
| {bids_count} | " f"{completed_projects} | " f"{avg_rating} از ۵ | " "
| 👥 سیستم دعوت دوستان | " "|
|---|---|
| 🔗 تعداد دعوتشدگان | " f"{referrals_count} نفر | " "
🚀 از دکمههای زیر جهت یافتن پروژه و ارسال پیشنهاد استفاده کنید:
" ) kb = reply.freelancer_main_menu(is_admin=is_admin) rich_msg = InputRichMessage(html=html_dashboard) await message.bot.send_rich_message(chat_id=message.chat.id, rich_message=rich_msg, reply_markup=kb) @router.message(AsyncChat.waiting_for_message) async def process_async_chat_message(message: Message, state: FSMContext, bot: Bot, db_user): data = await state.get_data() target_id = data.get("target_id") is_fulltime = data.get("is_fulltime", False) project_title = data.get("project_title", "") role = data.get("role", "freelancer") project_id = data.get("project_id") await state.clear() is_admin = message.from_user.id in __import__('config').ADMIN_IDS kb = reply.client_main_menu(is_admin=is_admin) if role == 'client' else reply.freelancer_main_menu(is_admin=is_admin) if message.text == texts.BTN_BACK: return await message.answer("عملیات لغو شد.", reply_markup=kb) content_text = message.text or message.caption or "" if not is_fulltime and contains_forbidden_info(content_text): try: await message.delete() except: pass await message.answer(texts.CHAT_BLOCKED_MSG, reply_markup=kb, parse_mode="HTML") return try: await message.react([ReactionTypeEmoji(emoji="📨")]) except: pass # Extract message details for database log msg_type = 'text' file_id = None if message.voice: msg_type = 'voice' file_id = message.voice.file_id elif message.photo: msg_type = 'photo' file_id = message.photo[-1].file_id elif message.document: msg_type = 'document' file_id = message.document.file_id # Save message in database if project_id: try: await db.save_chat_message(project_id, message.from_user.id, target_id, msg_type, content_text, file_id) except Exception as e: logger.error(f"Error saving chat message to db: {e}") # Send success to sender await message.answer("✅ پیام شما با موفقیت ارسال شد.", reply_markup=kb, parse_mode="HTML") # Create reply inline button for recipient from aiogram.utils.keyboard import InlineKeyboardBuilder builder = InlineKeyboardBuilder() reply_role = "client" if role == "freelancer" else "freelancer" builder.button(text="💬 پاسخ", callback_data=f"async_reply_{message.from_user.id}_{reply_role}_{1 if is_fulltime else 0}_{project_id or 'none'}") sender_role_fa = "فریلنسر" if role == "freelancer" else "کارفرما" header = f"📨 پیام جدید از طرف {sender_role_fa} (پروژه: {project_title})\n\n" try: if message.text: await bot.send_message(target_id, header + message.text, reply_markup=builder.as_markup(), parse_mode="HTML") elif message.voice: await bot.send_voice(target_id, message.voice.file_id, caption=header, reply_markup=builder.as_markup(), parse_mode="HTML") elif message.photo: await bot.send_photo(target_id, message.photo[-1].file_id, caption=header + (message.caption or ""), reply_markup=builder.as_markup(), parse_mode="HTML") elif message.document: await bot.send_document(target_id, message.document.file_id, caption=header + (message.caption or ""), reply_markup=builder.as_markup(), parse_mode="HTML") except: pass @router.callback_query(F.data.startswith("async_reply_")) async def async_reply_handler(callback: CallbackQuery, state: FSMContext): parts = callback.data.split("_") target_id = int(parts[2]) role = parts[3] is_fulltime = parts[4] == "1" project_id = None if len(parts) > 5 and parts[5] != "none": try: project_id = int(parts[5]) except: pass chat_data = { "target_id": target_id, "role": role, "project_id": project_id, "project_title": "پاسخ مستقیم", "is_fulltime": is_fulltime } await state.set_state(AsyncChat.waiting_for_message) await state.set_data(chat_data) warning = "" if not is_fulltime: warning = "\n\n⚠️ توجه: ارسال هرگونه اطلاعات تماس اکیداً ممنوع است." await callback.message.answer(f"💬 ارسال پاسخ\nلطفاً پیام خود را تایپ کنید:{warning}", reply_markup=reply.cancel_menu(), parse_mode="HTML") await callback.answer() @router.callback_query(F.data == "start_support_ticket") async def start_support_callback(callback: CallbackQuery, state: FSMContext, bot: Bot): await check_and_clear_chat_session(state, bot) await state.clear() from aiogram.utils.keyboard import InlineKeyboardBuilder builder = InlineKeyboardBuilder() builder.button(text="📖 راهنمای استفاده و سوالات متداول", callback_data="support_faq") builder.button(text="🎫 ثبت تیکت پشتیبانی", callback_data="support_submit_ticket") builder.adjust(1) html_menu = ( "به بخش پشتیبانی خوش آمدید. لطفاً یکی از گزینههای زیر را انتخاب کنید:
" "💡 پیشنهاد میکنیم قبل از ثبت تیکت، بخش راهنما و سوالات متداول را مطالعه کنید. اکثر سوالات کارفرمایان و فریلنسرها در آنجا پاسخ داده شده است." ) rich_msg = InputRichMessage(html=html_menu) try: await callback.message.edit_text(text=None, rich_message=rich_msg, reply_markup=builder.as_markup()) except Exception: await bot.send_rich_message(chat_id=callback.message.chat.id, rich_message=rich_msg, reply_markup=builder.as_markup()) await callback.answer() @router.callback_query(F.data == "support_faq") async def support_faq_handler(callback: CallbackQuery, bot: Bot): from aiogram.utils.keyboard import InlineKeyboardBuilder builder = InlineKeyboardBuilder() builder.button(text="🔙 بازگشت", callback_data="start_support_ticket") builder.adjust(1) faq_html = ( "
برای مشاهده پاسخ هر سوال، روی آن ضربه بزنید:
" "پرداخت امن (اسکرو) سازوکاری است که امنیت مالی کارفرما و فریلنسر را ۱۰۰٪ تضمین میکند. در این روش، کارفرما پیش از شروع کار، مبلغ پروژه را در صندوق امن ربات بلوکه میکند. فریلنسر با خیال راحت از وجود وجه کار خود را آغاز کرده و پس از ارائه خروجی کار و تأیید کارفرما، مبلغ به صورت خودکار به کیف پول فریلنسر آزاد میشود.
" "اگر اختلافی در حین پروژه پیش بیاید، هر یک از طرفین میتوانند پروژه را به داوری ارجاع دهند. ابتدا داور (ادمین) تلاش میکند در چت سهنفره اختلاف را مستقیماً حل کند. در صورت لزوم، پرونده به هیئت منصفه (سایر کاربران واجد شرایط) ارجاع میشود و بر اساس آرای ثبتشده، کل مبلغ یا بخشی از آن به کارفرما عودت و مابقی به فریلنسر آزاد میشود.
" "کانکت، اعتبار مورد نیاز فریلنسرها برای ارسال پیشنهاد (بید) روی پروژههاست. هر پیشنهاد معادل تعدادی کانکت است. روشهای کسب کانکت:
"
"۱. هدیه ثبتنام اولیه در ربات.
"
"۲. خرید بستههای کانکت از طریق درگاه پرداخت کیف پول.
"
"۳. سیستم زیرمجموعهگیری (با دعوت هر دوست، کانکت رایگان دریافت میکنید).
"
"۴. دریافت کانکتهای هدیه روزانه برای اعضای ویژه VIP.
کارفرمایان: با رفتن به منوی اصلی و کلیک روی «ثبت پروژه جدید»، عنوان، بودجه و توضیحات را وارد کنید تا پروژه برای فریلنسرها منتشر شود.
"
"فریلنسرها: از منوی فریلنسری و بخش «خدمات من»، میتوانید خدمات خود (جیگ) را با قیمت مشخص ثبت کنید تا کارفرمایان بتوانند مستقیماً آن را بخرند.
ایکسلنسر کمترین میزان کارمزد را در بین پلتفرمهای فریلنسینگ دارد:
"
"• برای کاربران عادی: ۱۰٪ از مبلغ پروژههای آزاد شده.
"
"• برای اعضای ویژه VIP: کارمزد به نصف (فقط ۵٪) کاهش مییابد!
با مراجعه به بخش کیف پول و کلیک روی دکمه «برداشت وجه»، میتوانید مبلغ دلخواه خود را (حداقل ۱۰,۰۰۰ تومان) وارد کنید. مبالغ تسویه حساب پس از تأیید ادمین، حداکثر ظرف مدت ۲۴ ساعت کاری از طریق پایا/کارتبهکارت به حساب شما واریز میگردد.
" "اعضای VIP پلتفرم از مزایای متمایز زیر برخوردار میشوند:
"
"۱. کاهش کارمزد پروژهها از ۱۰٪ به ۵٪.
"
"۲. اولویت نمایش در بالای لیست پیشنهادها برای کارفرما.
"
"۳. دریافت کانکتهای رایگان روزانه جهت بید زدن.
"
"۴. دریافت نشان متمایز VIP در پروفایل عمومی جهت جذب اعتماد کارفرمایان.
ایکسلنسر برای حفظ امنیت کاربران، قوانین سختگیرانهای دارد:
"
"۱. به اشتراکگذاری اطلاعات تماس مستقیم (مانند شماره تلفن، آیدی تلگرام، اینستاگرام، واتساپ، روبیکا و...) در پیامهای عمومی، بیدها، بیو و توضیحات ممنوع است و سیستم هوشمند محتوا را مسدود میکند.
"
"۲. هرگونه توافق مالی خارج از سیستم پرداخت امن ربات ممنوع بوده و پلتفرم هیچ مسئولیتی در قبال کلاهبرداریهای خارج از ربات نمیپذیرد و حساب خاطی مسدود خواهد شد.
فریلنسر پس از اتمام کار، از طریق بخش مدیریت پروژه روی دکمه «ارسال فایل نهایی / تحویل کار» کلیک کرده و فایل یا توضیحات تحویل را ثبت میکند. پس از آن، کارفرما فرصت دارد کار را بررسی کرده و در صورت صحت، دکمه «آزادسازی وجه» را بزند تا هزینه به حساب فریلنسر منتقل شود.
" "| رتبه / نام فریلنسر | پروژهها | نوع حساب |
|---|---|---|
| دادهای ثبت نشده است. اولین نفری باشید که پروژه تکمیل میکند! 🚀 | ||
| {medal} {name} | {row['completed_count']} | {vip_star} |
| رتبه / نام فریلنسر | پروژهها | نوع حساب |
|---|---|---|
| دادهای ثبت نشده است. | ||
| {medal} {name} | {row['completed_count']} | {vip_star} |
💡 رتبهبندی هفتگی بر اساس پروژههای تکمیل شده در ۷ روز گذشته و رتبهبندی کل دوره بر اساس کل پروژههای موفق انجام میشود.
" ) rich_msg = InputRichMessage(html=html_content) await bot.send_rich_message(chat_id=message.chat.id, rich_message=rich_msg) @router.message(Command("promo")) async def cmd_promo(message: Message, command: CommandObject): if not command.args: return await message.answer("🎁 لطفاً کد هدیه را بعد از دستور وارد کنید. مثال:\n`/promo GIFT2023`", parse_mode="Markdown") code = command.args.strip().upper() success, msg = await db.use_promo_code(message.from_user.id, code) if success: await message.answer(f"✅ {msg}") else: await message.answer(f"❌ {msg}") @router.message(Command("alerts")) async def cmd_alerts(message: Message, command: CommandObject): if not command.args: alerts = await db.get_user_alerts(message.from_user.id) if not alerts: return await message.answer("🔕 شما هیچ هشدار شغلی فعالی ندارید.\n\nبرای ایجاد هشدار جدید، از دستور زیر استفاده کنید:\n`/alerts کلمه_کلیدی`\nمثال: `/alerts پایتون`", parse_mode="Markdown") text = "🔔 هشدارهای شغلی شما:\n\n" for a in alerts: text += f"▪️{a['keyword']} (حذف: /delalert_{a['alert_id']})\n"
return await message.answer(text, parse_mode="HTML")
keyword = command.args.strip()
await db.add_job_alert(message.from_user.id, keyword)
await message.answer(f"✅ هشدار شغلی برای کلمه «{keyword}» با موفقیت ثبت شد!\nهرگاه پروژهای با این کلمه ثبت شود، به شما اطلاع میدهیم.", parse_mode="HTML")
@router.message(F.text.startswith("/delalert_"))
async def cmd_delalert(message: Message):
try:
alert_id = int(message.text.split("_")[1])
await db.delete_job_alert(alert_id, message.from_user.id)
await message.answer("🗑 هشدار شغلی با موفقیت حذف شد.")
except:
pass
@router.message(F.text == texts.BTN_REFRESH, StateFilter("*"))
async def global_refresh(message: Message, state: FSMContext, db_user, bot: Bot):
await check_and_clear_chat_session(state, bot)
await state.clear()
await send_main_menu(message, db_user)
from aiogram.types import PreCheckoutQuery, LabeledPrice
@router.callback_query(F.data == "buy_vip_stars")
async def buy_vip_stars(callback: CallbackQuery, bot: Bot):
await bot.send_invoice(
chat_id=callback.from_user.id,
title="اشتراک ویژه (VIP)",
description="یک ماه اشتراک ویژه در ربات برای فریلنسری حرفهای",
payload="vip_subscription_1_month",
provider_token="", # Empty for Telegram Stars
currency="XTR",
prices=[LabeledPrice(label="VIP 1 Month", amount=100)],
)
await callback.answer()
@router.pre_checkout_query()
async def process_pre_checkout(pre_checkout_query: PreCheckoutQuery, bot: Bot):
await bot.answer_pre_checkout_query(pre_checkout_query.id, ok=True)
@router.message(F.successful_payment)
async def process_successful_payment(message: Message, bot: Bot):
payload = message.successful_payment.invoice_payload
if payload == "vip_subscription_1_month":
await db.update_vip_status(message.from_user.id, 30)
await message.answer("🎉 تبریک! اشتراک ویژه شما با موفقیت از طریق Stars فعال شد.", message_effect_id="5104841245755180586", parse_mode="HTML")
# ── Chat Join Request (Bot API 10.1 Auto-Approve) ────────────────────────
@router.chat_join_request()
async def handle_chat_join_request(join_request: ChatJoinRequest, bot: Bot):
try:
# Auto-approve the request using Bot API 10.1 answer_query or standard approve
if hasattr(join_request, "query_id") and join_request.query_id:
await join_request.answer_query(approve=True)
else:
await join_request.approve()
# Notify the user
await bot.send_message(
chat_id=join_request.from_user.id,
text=f"✅ درخواست عضویت شما در کانال با موفقیت تایید شد!\n\nاکنون میتوانید از تمامی خدمات ربات استفاده کنید.",
parse_mode="HTML"
)
except Exception as e:
import logging
logging.getLogger(__name__).error(f"Error approving join request: {e}")