vusakhoza/velocity-pay-springboot
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

updating sequence of flows

Browse Source
This commit is contained in:
Vusumuzi Khoza
2025-11-02 19:48:31 +02:00
parent 683da10748
commit 29e5036346
4 changed files with 16 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/java/zw/qantra/tm/domain/services/processors/integrations/StewardIntegrationProcessor.java
View File

@@ -76,7 +76,7 @@ public class StewardIntegrationProcessor implements TransactionProcessorInterfac
.build(); .build();
if(Objects.equals(powertelClientId, transaction.getBillClientId())) { if(Objects.equals(powertelClientId, transaction.getBillClientId())) {
logger.info("send confirmation again"); logger.info("send confirmation again for - " + transaction.getBillClientId());
String url = aggregatorUrl + "/merchant/aggregation/transaction"; String url = aggregatorUrl + "/merchant/aggregation/transaction";
LinkedHashMap response = restService.postWithToken(token, url, request, LinkedHashMap.class); LinkedHashMap response = restService.postWithToken(token, url, request, LinkedHashMap.class);
logger.info("response: {}", response.toString()); logger.info("response: {}", response.toString());

9
src/main/java/zw/qantra/tm/domain/workflows/TransactionWorkflow.java
View File

@@ -66,7 +66,7 @@ public class TransactionWorkflow extends WorkflowDefinition {
permit(GATEWAY_PAYMENT_SUCCESS, INTEGRATION); permit(GATEWAY_PAYMENT_SUCCESS, INTEGRATION);
permit(INTEGRATION, PURCHASE_INVOICE, TRAN_FAILED); permit(INTEGRATION, PURCHASE_INVOICE, TRAN_FAILED);
permit(PURCHASE_INVOICE, PURCHASE_INVOICE_PAYMENT); permit(PURCHASE_INVOICE, PURCHASE_INVOICE_PAYMENT);
permit(PURCHASE_INVOICE_PAYMENT, PURCHASE_INVOICE_PAYMENT_SUCCESS); permit(PURCHASE_INVOICE_PAYMENT, PURCHASE_INVOICE_PAYMENT_SUCCESS, DONE);
permit(PURCHASE_INVOICE_PAYMENT_SUCCESS, POLL_STATUS); permit(PURCHASE_INVOICE_PAYMENT_SUCCESS, POLL_STATUS);
permit(POLL_STATUS, SALES_INVOICE, TRAN_FAILED); permit(POLL_STATUS, SALES_INVOICE, TRAN_FAILED);
permit(SALES_INVOICE, JOURNAL_ENTRY); permit(SALES_INVOICE, JOURNAL_ENTRY);
@@ -219,6 +219,13 @@ public class TransactionWorkflow extends WorkflowDefinition {
transaction = (Transaction) handlerInterface.process(transaction); transaction = (Transaction) handlerInterface.process(transaction);
execution.setVariable("body", Utils.toJson(transaction)); execution.setVariable("body", Utils.toJson(transaction));
// it's possible to have a flow that ends up event though
// polling has already happened
if(transaction.getPollingStatus() == Status.SUCCESS){
return NextAction.moveToState(DONE,
"Polling already complete");
}
return NextAction.moveToState(PURCHASE_INVOICE_PAYMENT_SUCCESS, return NextAction.moveToState(PURCHASE_INVOICE_PAYMENT_SUCCESS,
"Purchase invoice payment generated - id: " + transaction.getErpPurchasePaymentRef()); "Purchase invoice payment generated - id: " + transaction.getErpPurchasePaymentRef());
}catch (Exception e) { }catch (Exception e) {

3
src/main/resources/application-lab.properties
View File

@@ -52,3 +52,6 @@ nflow.db.postgresql.user=postgres
nflow.db.postgresql.password=zdDZMzq6F4B4L1IUl nflow.db.postgresql.password=zdDZMzq6F4B4L1IUl
powertel.clientid=powertel_zesa powertel.clientid=powertel_zesa
ecocash.apikey=OUzGezwTgktLg_9v0I48I6WUM4LVLGFl
ecocash.url=https://developers.ecocash.co.zw/api/ecocash_pay/api/v2/payment/instant/c2b/sandbox

5
src/main/resources/application.properties
View File

@@ -66,4 +66,7 @@ spring.mail.password=QdZucpJMJIZ
spring.mail.properties.mail.smtp.auth=true spring.mail.properties.mail.smtp.auth=true
spring.mail.properties.mail.smtp.starttls.enable=true spring.mail.properties.mail.smtp.starttls.enable=true
powertel.clientid=zesa_prepaid_usd powertel.clientid=zesa_prepaid_usd
ecocash.apikey=OUzGezwTgktLg_9v0I48I6WUM4LVLGFl
ecocash.url=https://developers.ecocash.co.zw/api/ecocash_pay/api/v2/payment/instant/c2b/sandbox