wuweihua/BMS
2
1
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

处理同步退费逻辑

Browse Source
This commit is contained in:
wuweihua
2026-10-23 14:00:53 +08:00
parent 84939a8875
commit d46d1596e8
2 changed files with 11 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
bms-back/bms-system/src/main/java/com/bms/price/task/TabOrderSyncAsyncRunner.java
+9 -2
View File
@@ -27,7 +27,9 @@ import com.bms.price.domain.PrcBillingTaskRetryTask;
import com.bms.price.domain.vo.BillingTaskSubmitRequest;
import com.bms.price.domain.vo.TabOrderMonitorQuery;
import com.bms.price.domain.vo.TabOrderMonitorVo;
import com.bms.price.enums.BillOrderStatus;
import com.bms.price.enums.BillTaskSuccessStatus;
import com.bms.price.enums.BillTaskType;
import com.bms.price.oracle.TabOrderMonitorService;
import com.bms.price.search.IBillSearchStore;
import com.bms.price.search.TabOrderSyncEsLog;
@@ -200,7 +202,7 @@ public class TabOrderSyncAsyncRunner
/**
* Sync or refund selected rows.
* @param billType optional PENDING/REBILL/REFUND; null = auto PENDING/REBILL
* @param billType optional PENDING/REBILL/REFUND; null = auto by orderStatus / bill existence
*/
public Map<String, Object> syncRowsParallel(List<TabOrderMonitorVo> rows, String billType)
{
@@ -219,7 +221,7 @@ public class TabOrderSyncAsyncRunner
/**
* Sync or refund selected rows carrying the upstream Oracle full row (skip re-query).
* @param billType optional PENDING/REBILL/REFUND; null = auto PENDING/REBILL
* @param billType optional PENDING/REBILL/REFUND; null = auto by orderStatus / bill existence
*/
public Map<String, Object> syncRowsParallelRows(List<com.bms.price.oracle.TabOrderRow> rows, String billType)
{
@@ -509,6 +511,11 @@ public class TabOrderSyncAsyncRunner
{
req.setBillType(billType.trim());
}
else if (BillOrderStatus.REFUNDED.matches(row.getOrderStatus()))
{
// Upstream 已退件 (ORDER_STATUS=9) -> fee refund task
req.setBillType(BillTaskType.REFUND.getCode());
}
return req;
}
}