Parsa Nazer
122 lines
4.3 KiB
Python
122 lines
4.3 KiB
Python
import logging
|
|
from azbankgateways import (
|
|
bankfactories,
|
|
models as bank_models,
|
|
default_settings as settings,
|
|
)
|
|
from .models import OrderModel
|
|
from account.models import PushSubscription
|
|
import ghasedak_sms
|
|
from product.models import ProductImageModel
|
|
from celery import shared_task
|
|
|
|
@shared_task
|
|
def udpate_bank_status():
|
|
factory = bankfactories.BankFactory()
|
|
|
|
bank_models.Bank.objects.update_expire_records()
|
|
|
|
for item in bank_models.Bank.objects.filter_return_from_bank():
|
|
bank = factory.create(
|
|
bank_type=item.bank_type, identifier=item.bank_choose_identifier
|
|
)
|
|
bank.verify(item.tracking_code)
|
|
bank_record = bank_models.Bank.objects.get(tracking_code=item.tracking_code)
|
|
if bank_record.is_success:
|
|
bank_record.order.cart.clear_cart()
|
|
bank_record.order.is_paid = True
|
|
bank_record.order.save()
|
|
logging.debug("This record is verify now.", extra={"pk": bank_record.pk})
|
|
else:
|
|
order = bank_record.order
|
|
order.rollback_stock()
|
|
return 'update bank record is done'
|
|
|
|
|
|
@shared_task
|
|
def send_change_status_notif(instance_pk, new_status):
|
|
instance = OrderModel.objects.get(pk=instance_pk)
|
|
user_subs = PushSubscription.objects.filter(user=instance.user)
|
|
for user_sub in user_subs:
|
|
try:
|
|
user_sub.send_notif(f'سفارش شما به {new_status} تغییر کرد', f'سفارش شما به {new_status} تغییر کرد', ProductImageModel.objects.all().first().image.url)
|
|
except:
|
|
print('log later send notif error')
|
|
|
|
@shared_task
|
|
def send_change_status_sms(instance_pk, new_status):
|
|
instance = OrderModel.objects.get(pk=instance_pk)
|
|
sms_api = ghasedak_sms.Ghasedak(api_key="1227eaaddcba72bcb0169b37032cf16ae9ac6ed8b3b7c2768b74e2ee351d1b52gyRe3AGomZRPTNEd")
|
|
|
|
|
|
response = sms_api.send_single_sms(
|
|
ghasedak_sms.SendSingleSmsInput(
|
|
message=f'سفارش شما به {new_status} تغییر کرد',
|
|
receptor=instance.user.phone,
|
|
line_number='30005006004095',
|
|
client_reference_id=str(instance.user.pk)
|
|
)
|
|
)
|
|
if response['statusCode'] == 200:
|
|
return 'done log later'
|
|
else:
|
|
return f'error: {response}'
|
|
|
|
|
|
@shared_task
|
|
def generate_daily_shop_reports():
|
|
"""Generate daily shop reports for the previous day.
|
|
|
|
This task aggregates ShopOrderModel entries from yesterday
|
|
and creates/updates ShopDailyReport records for each shop.
|
|
Scheduled to run daily at midnight.
|
|
"""
|
|
from django.utils import timezone
|
|
from datetime import timedelta
|
|
from django.db.models import Sum
|
|
from .models import ShopOrderModel, ShopDailyReport
|
|
|
|
target_date = (timezone.now() - timedelta(days=1)).date()
|
|
logging.info(f'Generating shop reports for {target_date}')
|
|
|
|
shop_orders = ShopOrderModel.objects.filter(created_at__date=target_date)
|
|
if not shop_orders.exists():
|
|
logging.warning(f'No shop orders found for {target_date}')
|
|
return f'No shop orders for {target_date}'
|
|
|
|
shops = shop_orders.values('shop').distinct()
|
|
reports_created = 0
|
|
reports_updated = 0
|
|
|
|
for s in shops:
|
|
shop_id = s['shop']
|
|
aggr = shop_orders.filter(shop_id=shop_id).aggregate(
|
|
total_sales=Sum('subtotal'),
|
|
total_commission=Sum('commission_amount'),
|
|
total_payable=Sum('payable_amount')
|
|
)
|
|
|
|
total_sales = aggr['total_sales'] or 0
|
|
total_commission = aggr['total_commission'] or 0
|
|
total_payable = aggr['total_payable'] or 0
|
|
|
|
report, created = ShopDailyReport.objects.update_or_create(
|
|
shop_id=shop_id,
|
|
date=target_date,
|
|
defaults={
|
|
'total_sales': total_sales,
|
|
'total_commission': total_commission,
|
|
'total_payable': total_payable,
|
|
}
|
|
)
|
|
|
|
if created:
|
|
reports_created += 1
|
|
else:
|
|
reports_updated += 1
|
|
|
|
logging.info(f"Shop {shop_id}: sales={total_sales}, commission={total_commission}, payable={total_payable}")
|
|
|
|
result = f'Generated reports for {target_date}: {reports_created} created, {reports_updated} updated'
|
|
logging.info(result)
|
|
return result |