fix(OUT-2111): multiple prices mapping, unmaps the existing price and product

- [X] replaced delete all mechanisms with update one, on the basis of product id and price id

Author: SandipBajracharya

src/app/api/quickbooks/product/product.controller.ts

@@ -22,9 +22,8 @@ export async function storeProductMap(req: NextRequest) {
   const productService = new ProductService(user)
   const body = await req.json()
   const parsedBody = ProductMappingSchema.parse(body)
-  const products = await productService.bulkDeleteCreateQBProduct(
-    parsedBody.mappingItems,
-  )
+  const products = await productService.handleProductMap(parsedBody)
+
   if (parsedBody.changedItemReference.length > 0)
     await productService.formatAndSyncProductLogs(
       parsedBody.changedItemReference,

src/app/api/quickbooks/product/product.service.ts

@@ -10,6 +10,7 @@ import {
   QBProductUpdateSchemaType,
   QBProductUpdateSchema,
   ProductChangedItemReferenceType,
+  ProductMappingSchemaType,
 } from '@/db/schema/qbProductSync'
 import { ProductResponse, WhereClause } from '@/type/common'
 import { ProductFlattenArrayResponseType } from '@/type/dto/api.dto'
@@ -32,6 +33,7 @@ import APIError from '@/app/api/core/exceptions/api'
 import httpStatus from 'http-status'
 import { QBSyncLog, QBSyncLogCreateSchemaType } from '@/db/schema/qbSyncLogs'
 import User from '@/app/api/core/models/User.model'
+import { SettingService } from '@/app/api/quickbooks/setting/setting.service'
 
 export class ProductService extends BaseService {
   private syncLogService: SyncLogService
@@ -170,30 +172,68 @@ export class ProductService extends BaseService {
   }
 
   /**
-   * Bulk update or create the map between product, price with QB item
+   * On intial save, save all flatten products. If mapped, we include and if not, those are excluded
+   * On every save after that, we update the record on the basis of productId and priceId
    */
-  async bulkDeleteCreateQBProduct(
-    payload: QBProductCreateArraySchemaType,
+  async handleProductMap(
+    body: ProductMappingSchemaType,
     returningFields?: (keyof typeof QBProductSync)[],
-  ): Promise<Partial<QBProductSelectSchemaType>[] | undefined> {
-    const formattedPayload = payload.map((item) => {
-      return {
-        ...item,
-        portalId: this.user.workspaceId,
-      }
-    })
+  ) {
+    const { mappingItems, changedItemReference } = body
+    const settingService = new SettingService(this.user)
+    const setting = await settingService.getOneByPortalId([
+      'initialProductSettingMap',
+    ])
 
     return await this.db.transaction(async (tx) => {
-      await tx
-        .delete(QBProductSync)
-        .where(eq(QBProductSync.portalId, this.user.workspaceId))
-      const query = tx.insert(QBProductSync).values(formattedPayload)
-      const product = returningFields?.length
-        ? await query.returning(
-            buildReturningFields(QBProductSync, returningFields),
-          )
-        : await query.returning()
-      return product
+      this.setTransaction(tx)
+
+      if (!setting?.initialProductSettingMap) {
+        const formattedPayload = mappingItems.map((item) => {
+          return {
+            ...item,
+            copilotName: item.name,
+            portalId: this.user.workspaceId,
+          }
+        })
+        const query = this.db.insert(QBProductSync).values(formattedPayload)
+        const products = returningFields?.length
+          ? await query.returning(
+              buildReturningFields(QBProductSync, returningFields),
+            )
+          : await query.returning()
+        return products
+      }
+
+      if (changedItemReference.length > 0) {
+        Promise.all(
+          changedItemReference?.map(async (item) => {
+            const payload = {
+              portalId: this.user.workspaceId,
+              productId: item.id,
+              priceId: item.priceId,
+              name: item.isExcluded ? null : item.qbItem?.name,
+              description: item.isExcluded ? null : item.qbItem?.description,
+              qbItemId: item.isExcluded ? null : item.qbItem?.id,
+              qbSyncToken: item.isExcluded ? null : item.qbItem?.syncToken,
+              copilotName: item.name,
+              unitPrice: item.isExcluded
+                ? null
+                : item.qbItem?.numericPrice.toString(),
+              isExcluded: item.isExcluded,
+            }
+            const conditions = and(
+              eq(QBProductSync.portalId, this.user.workspaceId),
+              eq(QBProductSync.productId, item.id),
+              eq(QBProductSync.priceId, item.priceId),
+            ) as WhereClause
+            await this.updateOrCreateQBProduct(payload, conditions)
+          }),
+        )
+      }
+
+      this.unsetTransaction()
+      return await this.getAll()
     })
   }
 

src/db/schema/qbProductSync.ts

@@ -80,6 +80,7 @@ const QBItemSchema = z.object({
   name: z.string(),
   syncToken: z.string(),
   numericPrice: z.number(),
+  description: z.string(),
 })
 
 const ProductChangedItemReferenceSchema = z.object({
@@ -100,3 +101,4 @@ export const ProductMappingSchema = z.object({
   mappingItems: QBProductCreateArraySchema,
   changedItemReference: z.array(ProductChangedItemReferenceSchema),
 })
+export type ProductMappingSchemaType = z.infer<typeof ProductMappingSchema>