fix(core-flows): refresh payment collection (medusajs#13103)

carlos-r-l-rodrigues · web-flow · commit f6736d96616a · 2025-07-31T09:06:20.000-03:00
diff --git a/.changeset/light-gorillas-play.md b/.changeset/light-gorillas-play.md
@@ -0,0 +1,5 @@
+---
+"@medusajs/core-flows": patch
+---
+
+fix(core-flows): refresh payment collection using raw total
diff --git a/packages/core/core-flows/src/cart/workflows/refresh-payment-collection.ts b/packages/core/core-flows/src/cart/workflows/refresh-payment-collection.ts
@@ -120,7 +120,7 @@ export const refreshPaymentCollectionForCartWorkflow = createWorkflow(
         return {
           selector: { id: cart.payment_collection.id },
           update: {
-            amount: cart.total,
+            amount: cart.raw_total,
             currency_code: cart.currency_code,
           },
         }
diff --git a/packages/core/core-flows/src/order/utils/aggregate-status.ts b/packages/core/core-flows/src/order/utils/aggregate-status.ts
@@ -26,7 +26,7 @@ export const getLastPaymentStatus = (order: OrderDetailDTO) => {
       (isDefined(paymentCollection.amount) &&
         MathBN.eq(paymentCollection.amount, 0))
     ) {
-      paymentStatus[PaymentStatus.CAPTURED] += MathBN.eq(
+      paymentStatus[PaymentStatus.CAPTURED] += MathBN.gte(
         paymentCollection.captured_amount as number,
         paymentCollection.amount
       )
@@ -35,7 +35,7 @@ export const getLastPaymentStatus = (order: OrderDetailDTO) => {
     }
 
     if (MathBN.gt(paymentCollection.refunded_amount ?? 0, 0)) {
-      paymentStatus[PaymentStatus.REFUNDED] += MathBN.eq(
+      paymentStatus[PaymentStatus.REFUNDED] += MathBN.gte(
         paymentCollection.refunded_amount as number,
         paymentCollection.amount
       )

-Original file line number
+Diff line change
@@ @@ -0,0 +1,5 @@ @@
 +---
 +"@medusajs/core-flows": patch
 +---
++
 +fix(core-flows): refresh payment collection using raw total
Original file line number	Diff line number	Diff line change
`@@ -120,7 +120,7 @@ export const refreshPaymentCollectionForCartWorkflow = createWorkflow(`
`120`	`120`	`return {`
`121`	`121`	`selector: { id: cart.payment_collection.id },`
`122`	`122`	`update: {`
`123`		`- amount: cart.total,`
	`123`	`+ amount: cart.raw_total,`
`124`	`124`	`currency_code: cart.currency_code,`
`125`	`125`	`},`
`126`	`126`	`}`
Original file line number	Diff line number	Diff line change
`@@ -26,7 +26,7 @@ export const getLastPaymentStatus = (order: OrderDetailDTO) => {`
`26`	`26`	`(isDefined(paymentCollection.amount) &&`
`27`	`27`	`MathBN.eq(paymentCollection.amount, 0))`
`28`	`28`	`) {`
`29`		`- paymentStatus[PaymentStatus.CAPTURED] += MathBN.eq(`
	`29`	`+ paymentStatus[PaymentStatus.CAPTURED] += MathBN.gte(`
`30`	`30`	`paymentCollection.captured_amount as number,`
`31`	`31`	`paymentCollection.amount`
`32`	`32`	`)`
`@@ -35,7 +35,7 @@ export const getLastPaymentStatus = (order: OrderDetailDTO) => {`
`35`	`35`	`}`
`36`	`36`
`37`	`37`	`if (MathBN.gt(paymentCollection.refunded_amount ?? 0, 0)) {`
`38`		`- paymentStatus[PaymentStatus.REFUNDED] += MathBN.eq(`
	`38`	`+ paymentStatus[PaymentStatus.REFUNDED] += MathBN.gte(`
`39`	`39`	`paymentCollection.refunded_amount as number,`
`40`	`40`	`paymentCollection.amount`
`41`	`41`	`)`