feat: sync stockMovement

frappe · Dec 5, 2024 · 9d3f0fd · 9d3f0fd
1 parent b28aa8e
commit 9d3f0fd
Showing 1 changed file with 31 additions and 4 deletions.
diff --git a/src/utils/erpnextSync.ts b/src/utils/erpnextSync.ts
@@ -6,6 +6,7 @@ import { DocValueMap } from 'fyo/core/types';
 import { Doc } from 'fyo/model/doc';
 import { ERPNextSyncQueue } from 'models/baseModels/ERPNextSyncQueue/ERPNextSyncQueue';
 import { SalesInvoice } from 'models/baseModels/SalesInvoice/SalesInvoice';
+import { StockMovementItem } from 'models/inventory/StockMovementItem';
 
 export async function updateERPNSyncSettings(fyo: Fyo) {
   const syncSettingsDoc = (await fyo.doc.getDoc(
@@ -193,23 +194,41 @@ async function performPreSync(fyo: Fyo, doc: DocValueMap) {
       }
       return;
 
-    case ModelNameEnum.Party:
+    case 'Customer':
+    case 'Supplier':
       const isAddressExists = await fyo.db.exists(
         ModelNameEnum.Address,
-        doc.addressName as string
+        doc.address as string
       );
 
       if (!isAddressExists) {
         await addToFetchFromERPNextQueue(fyo, {
           referenceType: ModelNameEnum.Address,
-          documentName: doc.addressName,
+          documentName: doc.address,
         });
       }
 
       return;
 
     case ModelNameEnum.SalesInvoice:
       return await preSyncSalesInvoice(fyo, doc as SalesInvoice);
+
+    case ModelNameEnum.StockMovement:
+      if (!doc || !doc.items) {
+        return;
+      }
+
+      for (const item of doc.items as StockMovementItem[]) {
+        const isItemExists = await fyo.db.exists(ModelNameEnum.Item, item.item);
+
+        if (!isItemExists) {
+          await addToFetchFromERPNextQueue(fyo, {
+            referenceType: ModelNameEnum.Item,
+            documentName: item.item,
+          });
+        }
+      }
+      return;
     default:
       return;
   }
@@ -364,7 +383,9 @@ export async function syncDocumentsToERPNext(fyo: Fyo) {
         await logDoc.delete();
       }
     }
-  } catch (error) {}
+  } catch (error) {
+    return error;
+  }
 }
 
 async function syncFetchFromERPNextQueue(fyo: Fyo) {
@@ -551,6 +572,12 @@ export interface ERPNSyncDocsResponse {
     failed_log?: DocValueMap[];
   };
 }
+export interface FetchFromBooksResponse {
+  message: {
+    success: boolean;
+    data?: DocValueMap[];
+  };
+}
 
 export interface ERPNextSyncSettingsAPIResponse {
   message: {