Catch duplicate document exception on X3 #180

apps/billing/services/financial_processor_service.py

@@ -8,7 +8,7 @@ class TransactionProcessorInterface:
     Each new transcation processor needs to implements its logic by signing to this class.
     """
 
-    def send_transaction_to_processor(self, transaction: Transaction) -> str:
+    def send_transaction_to_processor(self, transaction: Transaction) -> dict:
         raise Exception("This method needs to be implemented")
 
 

apps/billing/services/processor_service.py

@@ -25,7 +25,7 @@ def __init__(self) -> None:
         self.__user_processor_auth = getattr(settings, "USER_PROCESSOR_AUTH")
         self.__user_processor_password = getattr(settings, "USER_PROCESSOR_PASSWORD")
 
-    def send_transaction_to_processor(self, transaction: Transaction) -> str:
+    def send_transaction_to_processor(self, transaction: Transaction) -> dict:
         """
         This method sends the transaction informations to the `Sage X3` service.
         """

apps/billing/services/transaction_service.py

@@ -1,3 +1,5 @@
+import xmltodict
+
 from apps.billing.models import Transaction
 from apps.billing.services.financial_processor_service import ProcessorInstantiator, TransactionProcessorInterface
 from apps.billing.services.processor_service import SageX3Processor
@@ -12,11 +14,47 @@ class TransactionService:
     def __init__(self) -> None:
         self.__processor: TransactionProcessorInterface = ProcessorInstantiator(processor=SageX3Processor)
 
-    def run_transaction_steps(self, transaction: Transaction):
+    def __check_transaction_state(self, document_id):
+        pass
+
+    def send_transaction_to_processor(self, transaction: Transaction) -> str:
+        """
+        This method receives a Transaction to send to the processor and deals with the request result.
+
+        From the result is extracted the document id, which is provided to invocate the `__check_transaction_state`
+        method, that checks and updates the transaction status.
+        """
+
         try:
+            response_from_service = self.__processor.send_transaction_to_processor(transaction=transaction)
+            response_from_service = response_from_service["soapenv:Envelope"]["soapenv:Body"]
+
+            if "multiRef" in list(dict(response_from_service).keys()):
+                message = "Nº Fatura NAU já registada no documento: "
+                if message in response_from_service["multiRef"]["message"]:
+                    document_id = response_from_service["multiRef"]["message"].replace(message, "")
+                    self.__check_transaction_state(document_id=document_id)
+
+                    return document_id
 
-            document_id = self.__processor.send_transaction_to_processor(transaction=transaction)
+            result = xmltodict.parse(response_from_service["wss:saveResponse"]["saveReturn"]["resultXml"]["#text"])
+            document_id = ""
+            for r in result["RESULT"]["GRP"]:
+                for field in r["FLD"]:
+                    if field["@NAME"] == "NUM":
+                        document_id = field["#text"]
+                        break
+
+                if document_id:
+                    break
 
             return document_id
         except Exception as e:
             raise e
+
+    def run_steps_to_send_transaction(self, transaction: Transaction) -> None:
+        try:
+            document_id = self.send_transaction_to_processor(transaction=transaction)
+            self.__check_transaction_state(document_id=document_id)
+        except Exception as e:
+            raise e