This commit is contained in:
behruz-dev
2025-11-12 14:45:33 +05:00
parent d376aaa6c1
commit 41a01b4251
5 changed files with 86 additions and 5 deletions

View File

@@ -0,0 +1,82 @@
import requests
from datetime import datetime
from django.core.management import BaseCommand
from core.apps.finance.models import (
Income,
Expence,
TypeIncome,
ExpenceType,
CashTransaction,
PaymentType
)
from core.apps.projects.models import ProjectFolder
from core.apps.accounts.models import User
from core.apps.wherehouse.models import WhereHouse
from core.apps.counterparty.models import Counterparty
from core.apps.orders.models import Party
headers = {
"Authorization": "Bearer eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJpc3MiOiJodHRwczovL2JhY2tlbmQuYXBwLnV5cXVyLnV6L21haW4vYXV0aC9sb2dpbiIsImlhdCI6MTc2Mjg2MzgyOCwiZXhwIjoxNzYyOTUwMjI4LCJuYmYiOjE3NjI4NjM4MjgsImp0aSI6IlBPd2xJd1kwQXZSQlE3UkoiLCJzdWIiOiIxMDQiLCJwcnYiOiIyM2JkNWM4OTQ5ZjYwMGFkYjM5ZTcwMWM0MDA4NzJkYjdhNTk3NmY3In0.1Pi_4vJaTqPRi92zsueZ-eGoTAiIJa-xd2AbRHvg5Gk"
}
def get_data(id):
url = f"https://backend.app.uyqur.uz/main/payment/view?id={id}"
response = requests.get(url, headers=headers)
if response.status_code == 200:
return response.json()
return response.json()
def create_expense(data):
statuses = {
"passive": "PENDING",
"active": "CONFIRMED",
"cancel": "CANCELLED"
}
user = User.objects.filter(full_name=data['creator']['full_name']).first()
cash_transaction = CashTransaction.objects.filter(name=data['cash']['name']).first()
expence_type = None
if data.get('financila'):
expence_type = ExpenceType.objects.filter(name=data['financial']['name']).first()
project_folder = None
if data.get('project'):
project_folder = ProjectFolder.objects.filter(name=data['project']['name']).first()
payment_type, created = PaymentType.objects.get_or_create(name=data['payment_type']['name'])
counterparty = None
if data.get('company_person'):
counterparty = Counterparty.objects.filter(name=data['company_person']['name']).first()
party = None
if data.get('order_ids'):
party_number = data.get('order_ids')[0]
party = Party.objects.filter(number=party_number).first()
Expence.objects.update_or_create(
user=user,
cash_transaction=cash_transaction,
expence_type=expence_type,
price=data['amount'],
currency=data['currency']['symbol'].lower(),
payment_type=payment_type,
project_folder= project_folder,
counterparty= counterparty,
exchange_rate= data['currency_amount'],
date=datetime.strptime(data['date'], "%d.%m.%Y").date(),
comment=data['description'],
status=statuses.get(data['status']),
party=party,
)
class Command(BaseCommand):
def add_arguments(self, parser):
parser.add_argument('ids', type=int, nargs='+')
def handle(self, *args, **options):
ids = options['ids']
for id in ids:
data = get_data(id)
create_expense(data['data'])
self.stdout.write(self.style.SUCCESS("Expense qo'shildi"))