added field export_url in expense group and util to generate URL

apps/fyle/migrations/0027_expensegroup_employee_name.py

@@ -0,0 +1,18 @@
+# Generated by Django 3.1.14 on 2023-11-20 10:48
+
+from django.db import migrations, models
+
+
+class Migration(migrations.Migration):
+
+    dependencies = [
+        ('fyle', '0026_auto_20231025_0913'),
+    ]
+
+    operations = [
+        migrations.AddField(
+            model_name='expensegroup',
+            name='employee_name',
+            field=models.CharField(help_text='Expense Group Employee Name', max_length=100, null=True),
+        ),
+    ]

apps/fyle/migrations/0028_expensegroup_export_url.py

@@ -0,0 +1,18 @@
+# Generated by Django 3.1.14 on 2023-11-22 10:11
+
+from django.db import migrations, models
+
+
+class Migration(migrations.Migration):
+
+    dependencies = [
+        ('fyle', '0027_expensegroup_employee_name'),
+    ]
+
+    operations = [
+        migrations.AddField(
+            model_name='expensegroup',
+            name='export_url',
+            field=models.CharField(help_text='Netsuite URL for the exported expenses', max_length=255, null=True),
+        ),
+    ]

apps/fyle/models.py

@@ -325,8 +325,10 @@ class ExpenseGroup(models.Model):
                                   help_text='To which workspace this expense group belongs to')
     fund_source = models.CharField(max_length=255, help_text='Expense fund source')
     expenses = models.ManyToManyField(Expense, help_text="Expenses under this Expense Group")
+    employee_name = models.CharField(max_length=100, help_text='Expense Group Employee Name', null=True)
     description = JSONField(max_length=255, help_text='Description', null=True)
     response_logs = JSONField(help_text='Reponse log of the export', null=True)
+    export_url = models.CharField(max_length=255, help_text='Netsuite URL for the exported expenses', null=True)
     created_at = models.DateTimeField(auto_now_add=True, help_text='Created at')
     exported_at = models.DateTimeField(help_text='Exported at', null=True)
     updated_at = models.DateTimeField(auto_now=True, help_text='Updated at')
@@ -392,6 +394,10 @@ def create_expense_groups_by_report_id_fund_source(expense_objects: List[Expense
             if expense_group_settings.ccc_export_date_type == 'last_spent_at':
                 expense_group['last_spent_at'] = Expense.objects.filter(
                     id__in=expense_group['expense_ids']).order_by('-spent_at').first().spent_at
+
+            employee_name = Expense.objects.filter(
+                id__in=expense_group['expense_ids']
+            ).first().employee_name
 
             expense_ids = expense_group['expense_ids']
             expense_group.pop('total')
@@ -407,7 +413,8 @@ def create_expense_groups_by_report_id_fund_source(expense_objects: List[Expense
             expense_group_object = ExpenseGroup.objects.create(
                 workspace_id=workspace_id,
                 fund_source=expense_group['fund_source'],
-                description=expense_group
+                description=expense_group,
+                employee_name=employee_name
             )
 
             expense_group_object.expenses.add(*expense_ids)

apps/netsuite/tasks.py

@@ -11,6 +11,7 @@
 from django.utils.module_loading import import_string
 from django_q.models import Schedule
 from django_q.tasks import Chain, async_task
+from fyle_netsuite_api.utils import generate_netsuite_export_url
 
 from netsuitesdk.internal.exceptions import NetSuiteRequestError
 from netsuitesdk import NetSuiteRateLimitError, NetSuiteLoginError
@@ -447,7 +448,10 @@ def create_bill(expense_group, task_log_id):
 
             expense_group.exported_at = datetime.now()
             expense_group.response_logs = created_bill
+            expense_group.url = generate_netsuite_export_url(response_logs=created_bill, ns_account_id=netsuite_credentials)
+
             expense_group.save()
+
 
             async_task(
                 'apps.netsuite.tasks.upload_attachments_and_update_export',
@@ -564,6 +568,7 @@ def create_credit_card_charge(expense_group, task_log_id):
 
             expense_group.exported_at = datetime.now()
             expense_group.response_logs = created_credit_card_charge
+            expense_group.export_url = generate_netsuite_export_url(response_logs=created_credit_card_charge, ns_account_id=netsuite_credentials)
             expense_group.save()
 
     except NetSuiteCredentials.DoesNotExist:
@@ -654,6 +659,7 @@ def create_expense_report(expense_group, task_log_id):
 
             expense_group.exported_at = datetime.now()
             expense_group.response_logs = created_expense_report
+            expense_group.export_url = generate_netsuite_export_url(response_logs=created_expense_report, ns_account_id=netsuite_credentials)
             expense_group.save()
 
             async_task(
@@ -749,6 +755,7 @@ def create_journal_entry(expense_group, task_log_id):
 
             expense_group.exported_at = datetime.now()
             expense_group.response_logs = created_journal_entry
+            expense_group.export_url = generate_netsuite_export_url(response_logs=created_journal_entry, ns_account_id=netsuite_credentials)      
             expense_group.save()
 
             async_task(

fyle_netsuite_api/utils.py

@@ -1,6 +1,17 @@
 from rest_framework.views import Response
 from rest_framework.serializers import ValidationError
+import logging
 
+logger = logging.getLogger(__name__)
+logger.level = logging.INFO
+
+EXPORT_TYPE_REDIRECTION = {
+    'vendorBill': 'vendbill',
+    'expenseReport': 'exprept',
+    'journalEntry': 'journal',
+    'chargeCard': 'cardchrg',
+    'chargeCardRefund': 'cardrfnd'
+}
 
 def assert_valid(condition: bool, message: str) -> Response or None:
     """
@@ -23,3 +34,16 @@ def filter_queryset(self, queryset):
             filter_kwargs = {self.lookup_field: lookup_value}
             queryset = queryset.filter(**filter_kwargs)
         return super().filter_queryset(queryset)
+
+
+def generate_netsuite_export_url(response_logs, ns_account_id):
+    if response_logs:
+        try:
+            export_type = response_logs['type'] if response_logs['type'] else 'chargeCard'
+            internal_id = response_logs['internalId']
+            redirection = EXPORT_TYPE_REDIRECTION[export_type]
+            url = f'https://{ns_account_id}.app.netsuite.com/app/accounting/transactions/${redirection}.nl?id={internal_id}'
+            return url
+        except Exception as exception:
+            logger.info({'error': exception})
+    return None

scripts/python/update-export-url.py

@@ -0,0 +1,23 @@
+from apps.fyle.models import ExpenseGroup
+from apps.workspaces.models import NetSuiteCredentials, Workspace
+from fyle_netsuite_api.utils import generate_netsuite_export_url
+
+
+folder_created_workspace_ids = []
+
+prod_workspaces = Workspace.objects.exclude(
+    name__iregex=r'(fyle|test)',
+    id__in=folder_created_workspace_ids
+)
+
+for workspace in prod_workspaces:
+    page_size = 200
+    expense_group_counts = ExpenseGroup.objects.filter(workspace_id=workspace.id, response_logs__isnull=False).count()
+    for offset in range(0, expense_group_counts, page_size):
+        expense_to_be_updated = []
+        limit = offset + page_size
+        paginated_expense_groups = ExpenseGroup.objects.filter(workspace_id=workspace.id, response_logs__isnull=False)[offset:limit]
+        for expense_group in paginated_expense_groups:
+            netsuite_cred = NetSuiteCredentials.objects.get(workspace_id=workspace.id)
+            expense_group.export_url = generate_netsuite_export_url(response_logs=expense_group.response_logs, ns_account_id=netsuite_cred.ns_account_id)
+            expense_group.save()

scripts/sql/scripts/020-fill-employee_name-in-expenses-and-expense_groups.sql

@@ -0,0 +1,29 @@
+rollback;
+begin;
+
+with ws as (
+  select expense_attributes.detail->>'full_name' as expense_attributes_full_name,
+    expense_attributes.workspace_id as expense_attributes_workspace_id,
+    expense_attributes.value as expense_attribute_email
+  from expense_groups
+    inner join expense_attributes on expense_attributes.value = expense_groups.description->>'employee_email'
+  where expense_groups.workspace_id = expense_attributes.workspace_id
+)
+
+update expense_groups
+set employee_name = ws.expense_attributes_full_name
+from ws
+where expense_groups.description->>'employee_email' = ws.expense_attribute_email;
+
+
+-- Run this in after running the above query.
+with ex as (
+  select expense_groups.employee_name as employee_name
+  from expense_groups
+    inner join expense_groups_expenses on expense_groups.id = expense_groups_expenses.expensegroup_id
+    inner join expenses on expense_groups_expenses.expense_id = expenses.id
+)
+
+update expenses
+set employee_name = ex.employee_name
+from ex;