transform core api codes into this project, update modules as admin/pos context modules

2026-03-07 11:25:11 +03:30
parent b949500482
commit 8c5f1d4d49
167 changed files with 26975 additions and 1837 deletions
@@ -0,0 +1,194 @@
+import { PrismaService } from '@/prisma/prisma.service'
+import { Injectable } from '@nestjs/common'
+import { ResponseMapper } from 'common/response/response-mapper'
+import type { CustomerIndividual, CustomerLegal } from 'generated/prisma/client'
+import { CustomerType, PaymentMethodType } from 'generated/prisma/enums'
+import { CreateSalesInvoiceDto } from './dto/create-sales-invoice.dto'
+
+// Define type guard for CustomerIndividual
+function isCustomerIndividual(customer: any): customer is CustomerIndividual {
+  console.log(
+    customer &&
+      typeof customer.first_name === 'string' &&
+      typeof customer.last_name === 'string',
+  )
+
+  return (
+    customer &&
+    typeof customer.first_name === 'string' &&
+    typeof customer.last_name === 'string'
+  )
+}
+
+// Define type guard for CustomerLegal
+function isCustomerLegal(customer: any): customer is CustomerLegal {
+  return (
+    customer &&
+    typeof customer.company_name === 'string' &&
+    typeof customer.registration_number === 'string'
+  )
+}
+
+@Injectable()
+export class SalesInvoicesService {
+  constructor(private prisma: PrismaService) {}
+
+  findAll() {
+    // TODO: Implement fetching all sales invoices
+    return []
+  }
+
+  findOne(id: number) {
+    // TODO: Implement fetching a single sales invoice
+    return {}
+  }
+
+  async create(data: CreateSalesInvoiceDto, account) {
+    data.invoice_date = new Date(data.invoice_date).toISOString() as any
+
+    const salesInvoice = await this.prisma.$transaction(async $tx => {
+      const payments = Object.entries(data.payments)
+        .filter(([_, value]) => value > 0 && PaymentMethodType[_.toUpperCase()])
+        .map(([key, value]) => {
+          return {
+            amount: value,
+            payment_method: key.toLocaleUpperCase() as PaymentMethodType,
+            paid_at: data.invoice_date,
+          }
+        })
+
+      const totalPayments = payments.reduce((sum, payment) => sum + payment.amount, 0)
+      if (totalPayments !== data.total_amount) {
+        throw new Error('مبلغ پرداختی باید برابر با مبلغ کل فاکتور باشد.')
+      }
+
+      const { customer_id, customer_type, customer, ...invoiceData } = data
+      let newCustomerId: string | null = customer_id || null
+      if (customer_id) {
+      } else if (
+        customer_type === CustomerType.INDIVIDUAL &&
+        isCustomerIndividual(customer)
+      ) {
+        let customerIndividual = await $tx.customerIndividual.findUnique({
+          where: {
+            complex_id_national_id: {
+              complex_id: account.complex_id,
+              national_id: customer.national_id,
+            },
+          },
+        })
+
+        if (customerIndividual) {
+          await $tx.customerIndividual.update({
+            where: {
+              complex_id_national_id: {
+                complex_id: account.complex_id,
+                national_id: customer.national_id,
+              },
+            },
+            data: {
+              ...customer,
+            },
+          })
+        } else {
+          const customerIndividual = await $tx.customerIndividual.create({
+            data: {
+              ...customer,
+            },
+          })
+          const createdCustomer = await $tx.customer.create({
+            data: {
+              type: CustomerType.INDIVIDUAL,
+              complex_id: account.complex_id,
+              customerIndividuals: {
+                connect: {
+                  customer_id: customerIndividual.customer_id,
+                },
+              },
+            },
+          })
+
+          if (createdCustomer && createdCustomer.id) {
+            newCustomerId = createdCustomer.id
+          }
+        }
+      } else if (data.customer_type === CustomerType.LEGAL && isCustomerLegal(customer)) {
+        let customerLegal = await $tx.customerLegal.findUnique({
+          where: {
+            complex_id_registration_number: {
+              complex_id: account.complex_id,
+              registration_number: customer.registration_number,
+            },
+          },
+        })
+
+        if (customerLegal) {
+          await $tx.customerLegal.update({
+            where: {
+              complex_id_registration_number: {
+                complex_id: account.complex_id,
+                registration_number: customer.registration_number,
+              },
+            },
+            data: {
+              ...customer,
+            },
+          })
+        } else {
+          const customerLegal = await $tx.customerLegal.create({
+            data: {
+              ...customer,
+            },
+          })
+          const createdCustomer = await $tx.customer.create({
+            data: {
+              type: CustomerType.LEGAL,
+              complex_id: account.complex_id,
+              customerIndividuals: {
+                connect: {
+                  customer_id: customerLegal.customer_id,
+                },
+              },
+            },
+          })
+
+          if (createdCustomer && createdCustomer.id) {
+            newCustomerId = createdCustomer.id
+          }
+        }
+      }
+
+      const salesInvoice = await $tx.salesInvoice.create({
+        data: {
+          ...invoiceData,
+          account_id: account.account_id,
+          customer_id: newCustomerId,
+          total_amount: data.total_amount,
+          code: 'INV-' + Date.now(),
+          complex_id: account.complex_id,
+          items: {
+            createMany: {
+              data: data.items.map(item => ({
+                good_id: item.good_id,
+                quantity: item.quantity,
+                unit_price: item.unit_price,
+                total_amount: item.total_amount,
+                payload: item.payload,
+                unit_type: item.unit_type,
+                // pricing_model: item.pricingModel,
+              })),
+            },
+          },
+          payments: {
+            createMany: {
+              data: payments,
+            },
+          },
+        },
+      })
+
+      return salesInvoice
+    })
+    return ResponseMapper.create(salesInvoice)
+  }
+}