b2894lxlx/tms-erp-api
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: HCS推送失败日志补全合规traceId（监控埋点，便于向合规方排查链路）

Browse Source
This commit is contained in:
刘泉佳
2026-09-27 23:59:25 +08:00
parent 12e2825e55
commit 815f3f68e5
8 changed files with 19 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files
blade-service/blade-transport/src/main/java/org/springblade/transport/support/hcs/HcsContractSyncSupport.java
+4 -4
View File
@@ -175,7 +175,7 @@ public class HcsContractSyncSupport {
HcsResult<HcsRiskVO> result = hcsClient.getRelativeRisk(param);
if (result == null || !result.isSuccess()) {
log.error("HCS客商风险查询失败响应：{}，contractNo={}，standing={}，fdNumber={}",
result == null ? "无响应" : result.getMsg(), contractManage.getContractNo(), standing, customerCode);
result == null ? "无响应" : String.format("msg=%s, traceId=%s", result.getMsg(), result.getTraceId()), contractManage.getContractNo(), standing, customerCode);
throw new HcsException("C101-1 客商风险查询失败：" + (result == null ? "响应为空" : result.getMsg()));
}
HcsRiskVO risk = result.getData();
@@ -199,7 +199,7 @@ public class HcsContractSyncSupport {
query.setPageSize(10);
HcsResult<HcsPageVO<HcsContractVO>> result = hcsClient.contractList(query);
if (result == null || !result.isSuccess()) {
log.error("HCS合同判重查询失败响应：{}，contractNo={}", result == null ? "无响应" : result.getMsg(), contractManage.getContractNo());
log.error("HCS合同判重查询失败响应：{}，contractNo={}", result == null ? "无响应" : String.format("msg=%s, traceId=%s", result.getMsg(), result.getTraceId()), contractManage.getContractNo());
throw new HcsException("C103-3 合同判重查询失败：" + (result == null ? "响应为空" : result.getMsg()));
}
HcsPageVO<HcsContractVO> page = result.getData();
@@ -227,7 +227,7 @@ public class HcsContractSyncSupport {
log.info("HCS合同推送开始：{}（C103-11 更新，§9-U5 定位方式待联调）", contractManage.getContractNo());
HcsResult<Void> result = hcsClient.contractUpdate(param);
if (result == null || !result.isSuccess()) {
log.error("HCS合同更新失败响应：{}，contractNo={}", result == null ? "无响应" : result.getMsg(), contractManage.getContractNo());
log.error("HCS合同更新失败响应：{}，contractNo={}", result == null ? "无响应" : String.format("msg=%s, traceId=%s", result.getMsg(), result.getTraceId()), contractManage.getContractNo());
throw new HcsException("C103-11 合同更新失败：" + (result == null ? "响应为空" : result.getMsg()));
}
}
@@ -344,7 +344,7 @@ public class HcsContractSyncSupport {
*/
private String validateDraftResult(ContractManage contractManage, HcsResult<HcsContractDraftVO> result) {
if (result == null || !result.isSuccess() || result.getData() == null || StringUtil.isBlank(result.getData().getFdContractId())) {
log.error("HCS合同发起失败响应：{}，contractNo={}", result == null ? "无响应" : result.getMsg(), contractManage.getContractNo());
log.error("HCS合同发起失败响应：{}，contractNo={}", result == null ? "无响应" : String.format("msg=%s, traceId=%s", result.getMsg(), result.getTraceId()), contractManage.getContractNo());
throw new HcsException("C103-1 合同发起失败：" + (result == null ? "响应为空" : result.getMsg()));
}
return result.getData().getFdContractId();
blade-service/blade-transport/src/main/java/org/springblade/transport/support/hcs/HcsCreditCheckSupport.java
+2 -2
View File
@@ -111,7 +111,7 @@ public class HcsCreditCheckSupport {
HcsResult<HcsRiskVO> result = hcsClient.getRelativeRisk(param);
if (result == null || !result.isSuccess()) {
log.error("HCS客商风险查询失败响应：{}，paymentNo={}，fdNumber={}",
result == null ? "无响应" : result.getMsg(), payment.getPaymentNo(), customerCode);
result == null ? "无响应" : String.format("msg=%s, traceId=%s", result.getMsg(), result.getTraceId()), payment.getPaymentNo(), customerCode);
throw new HcsException("C101-1 客商风险查询失败：" + (result == null ? "响应为空" : result.getMsg()));
}
HcsRiskVO risk = result.getData();
@@ -146,7 +146,7 @@ public class HcsCreditCheckSupport {
param.setFdApplyAmount(payment.getAppliedAmount() == null ? BigDecimal.ZERO : payment.getAppliedAmount());
HcsResult<HcsCreditCheckVO> result = hcsClient.contractCreditCheck(param);
if (result == null || !result.isSuccess()) {
log.error("HCS额度校验失败响应：{}，paymentNo={}", result == null ? "无响应" : result.getMsg(), payment.getPaymentNo());
log.error("HCS额度校验失败响应：{}，paymentNo={}", result == null ? "无响应" : String.format("msg=%s, traceId=%s", result.getMsg(), result.getTraceId()), payment.getPaymentNo());
throw new HcsException("C106-1 额度校验失败：" + (result == null ? "响应为空" : result.getMsg()));
}
HcsCreditCheckVO credit = result.getData();
blade-service/blade-transport/src/main/java/org/springblade/transport/support/hcs/HcsExeStageSyncSupport.java
+1 -1
View File
@@ -99,7 +99,7 @@ public class HcsExeStageSyncSupport {
param.getFdEopExeplanOperateType(), pendingRows.size());
HcsResult<HcsExeplanVO> result = hcsClient.exeplanAdd(param);
if (result == null || !result.isSuccess() || result.getData() == null) {
log.error("HCS履约规则同步失败响应：{}，contractNo={}", result == null ? "无响应" : result.getMsg(), contractManage.getContractNo());
log.error("HCS履约规则同步失败响应：{}，contractNo={}", result == null ? "无响应" : String.format("msg=%s, traceId=%s", result.getMsg(), result.getTraceId()), contractManage.getContractNo());
throw new HcsException("C103-9 履约规则同步失败：" + (result == null ? "响应为空" : result.getMsg()));
}
HcsExeplanVO exeplan = result.getData();
blade-service/blade-transport/src/main/java/org/springblade/transport/support/hcs/HcsInvoiceRegSyncSupport.java
+3 -3
View File
@@ -179,7 +179,7 @@ public class HcsInvoiceRegSyncSupport {
log.info("HCS开票登记新增开始：applicationNo={}", application.getApplicationNo());
HcsResult<HcsIdVO> result = hcsClient.invoiceRegistrationAdd(param);
if (result == null || !result.isSuccess() || result.getData() == null || StringUtil.isBlank(result.getData().getFdId())) {
log.error("HCS开票登记新增失败响应：{}，applicationNo={}", result == null ? "无响应" : result.getMsg(), application.getApplicationNo());
log.error("HCS开票登记新增失败响应：{}，applicationNo={}", result == null ? "无响应" : String.format("msg=%s, traceId=%s", result.getMsg(), result.getTraceId()), application.getApplicationNo());
throw new HcsException("C111-2 开票登记新增失败：" + (result == null ? "响应为空" : result.getMsg()));
}
return result.getData().getFdId();
@@ -199,7 +199,7 @@ public class HcsInvoiceRegSyncSupport {
log.info("HCS开票登记更新开始：applicationNo={}，fdId={}", application.getApplicationNo(), application.getHcsFdId());
HcsResult<HcsIdVO> result = hcsClient.invoiceRegistrationUpdate(param);
if (result == null || !result.isSuccess()) {
log.error("HCS开票登记更新失败响应：{}，applicationNo={}", result == null ? "无响应" : result.getMsg(), application.getApplicationNo());
log.error("HCS开票登记更新失败响应：{}，applicationNo={}", result == null ? "无响应" : String.format("msg=%s, traceId=%s", result.getMsg(), result.getTraceId()), application.getApplicationNo());
throw new HcsException("C111-3 开票登记更新失败：" + (result == null ? "响应为空" : result.getMsg()));
}
return "C111-3 开票登记更新成功";
@@ -217,7 +217,7 @@ public class HcsInvoiceRegSyncSupport {
query.setPageSize(10);
HcsResult<HcsPageVO<HcsInvoiceRegVO>> result = hcsClient.invoiceRegistrationList(query);
if (result == null || !result.isSuccess()) {
log.error("HCS开票登记判重查询失败响应：{}，applicationNo={}", result == null ? "无响应" : result.getMsg(), application.getApplicationNo());
log.error("HCS开票登记判重查询失败响应：{}，applicationNo={}", result == null ? "无响应" : String.format("msg=%s, traceId=%s", result.getMsg(), result.getTraceId()), application.getApplicationNo());
throw new HcsException("C111-1 开票登记判重查询失败：" + (result == null ? "响应为空" : result.getMsg()));
}
HcsPageVO<HcsInvoiceRegVO> page = result.getData();
blade-service/blade-transport/src/main/java/org/springblade/transport/support/hcs/HcsPerfRecordSyncSupport.java
+2 -2
View File
@@ -94,7 +94,7 @@ public class HcsPerfRecordSyncSupport {
log.info("HCS履约记录新建开始：paymentNo={}", payment.getPaymentNo());
HcsResult<HcsFormSaveVO> result = hcsClient.perfRecordAdd(param);
if (result == null || !result.isSuccess() || result.getData() == null || StringUtil.isBlank(result.getData().getFdId())) {
log.error("HCS履约记录新建失败响应：{}，paymentNo={}", result == null ? "无响应" : result.getMsg(), payment.getPaymentNo());
log.error("HCS履约记录新建失败响应：{}，paymentNo={}", result == null ? "无响应" : String.format("msg=%s, traceId=%s", result.getMsg(), result.getTraceId()), payment.getPaymentNo());
throw new HcsException("C108-1 履约记录新建失败：" + (result == null ? "响应为空" : result.getMsg()));
}
// 履约记录ID 立即持久化（调用方必须保存）
@@ -108,7 +108,7 @@ public class HcsPerfRecordSyncSupport {
log.info("HCS履约记录更新开始：paymentNo={}，perfFdId={}", payment.getPaymentNo(), payment.getHcsPerfFdId());
HcsResult<Void> result = hcsClient.perfRecordUpdate(param);
if (result == null || !result.isSuccess()) {
log.error("HCS履约记录更新失败响应：{}，paymentNo={}", result == null ? "无响应" : result.getMsg(), payment.getPaymentNo());
log.error("HCS履约记录更新失败响应：{}，paymentNo={}", result == null ? "无响应" : String.format("msg=%s, traceId=%s", result.getMsg(), result.getTraceId()), payment.getPaymentNo());
throw new HcsException("C108-2 履约记录更新失败：" + (result == null ? "响应为空" : result.getMsg()));
}
return "C108-2 履约记录更新成功";
blade-service/blade-transport/src/main/java/org/springblade/transport/support/hcs/HcsProjectSyncSupport.java
+3 -3
View File
@@ -131,7 +131,7 @@ public class HcsProjectSyncSupport {
log.info("HCS项目立项推送开始：{}（C102-1 新建）", projectApply.getProjectCode());
HcsResult<HcsFormSaveVO> result = hcsClient.projectAdd(param);
if (result == null || !result.isSuccess() || result.getData() == null || StringUtil.isBlank(result.getData().getFdId())) {
log.error("HCS项目立项新建失败响应：{}，projectCode={}", result == null ? "无响应" : result.getMsg(), projectApply.getProjectCode());
log.error("HCS项目立项新建失败响应：{}，projectCode={}", result == null ? "无响应" : String.format("msg=%s, traceId=%s", result.getMsg(), result.getTraceId()), projectApply.getProjectCode());
throw new HcsException("C102-1 项目立项新建失败：" + (result == null ? "响应为空" : result.getMsg()));
}
return result.getData().getFdId();
@@ -153,7 +153,7 @@ public class HcsProjectSyncSupport {
log.info("HCS项目立项推送开始：{}（C102-2 更新）", projectApply.getProjectCode());
HcsResult<Void> result = hcsClient.projectUpdate(param);
if (result == null || !result.isSuccess()) {
log.error("HCS项目立项更新失败响应：{}，projectCode={}", result == null ? "无响应" : result.getMsg(), projectApply.getProjectCode());
log.error("HCS项目立项更新失败响应：{}，projectCode={}", result == null ? "无响应" : String.format("msg=%s, traceId=%s", result.getMsg(), result.getTraceId()), projectApply.getProjectCode());
throw new HcsException("C102-2 项目立项更新失败：" + (result == null ? "响应为空" : result.getMsg()));
}
}
@@ -225,7 +225,7 @@ public class HcsProjectSyncSupport {
query.setCurUser(HcsUserRefVO.ofLoginName(requireLoginName(projectApply, "C102-3")));
HcsResult<HcsPageVO<HcsProjectVO>> result = hcsClient.projectList(query);
if (result == null || !result.isSuccess()) {
log.error("HCS项目立项判重查询失败响应：{}，projectCode={}", result == null ? "无响应" : result.getMsg(), projectApply.getProjectCode());
log.error("HCS项目立项判重查询失败响应：{}，projectCode={}", result == null ? "无响应" : String.format("msg=%s, traceId=%s", result.getMsg(), result.getTraceId()), projectApply.getProjectCode());
throw new HcsException("C102-3 项目立项判重查询失败：" + (result == null ? "响应为空" : result.getMsg()));
}
HcsPageVO<HcsProjectVO> page = result.getData();
blade-service/blade-transport/src/main/java/org/springblade/transport/support/hcs/HcsReceiptBillSyncSupport.java
+2 -2
View File
@@ -118,7 +118,7 @@ public class HcsReceiptBillSyncSupport {
log.info("HCS收票单更新开始：invoiceNo={}，fdId={}", invoiceReceipt.getInvoiceNo(), invoiceReceipt.getHcsFdId());
HcsResult<HcsResult<Void>> result = hcsClient.updateReceiveBill(param);
if (result == null || !result.isSuccess()) {
log.error("HCS收票单更新失败响应：{}，invoiceNo={}", result == null ? "无响应" : result.getMsg(), invoiceReceipt.getInvoiceNo());
log.error("HCS收票单更新失败响应：{}，invoiceNo={}", result == null ? "无响应" : String.format("msg=%s, traceId=%s", result.getMsg(), result.getTraceId()), invoiceReceipt.getInvoiceNo());
throw new HcsException("C109-2 收票单更新失败：" + (result == null ? "响应为空" : result.getMsg()));
}
return "C109-2 收票单更新成功";
@@ -211,7 +211,7 @@ public class HcsReceiptBillSyncSupport {
private String extractNestedFdId(InvoiceReceipt invoiceReceipt, HcsResult<HcsResult<HcsFormSaveVO>> result) {
if (result == null || !result.isSuccess() || result.getData() == null || !result.getData().isSuccess()
|| result.getData().getData() == null || StringUtil.isBlank(result.getData().getData().getFdId())) {
log.error("HCS收票单新建失败响应：{}，invoiceNo={}", result == null ? "无响应" : result.getMsg(), invoiceReceipt.getInvoiceNo());
log.error("HCS收票单新建失败响应：{}，invoiceNo={}", result == null ? "无响应" : String.format("msg=%s, traceId=%s", result.getMsg(), result.getTraceId()), invoiceReceipt.getInvoiceNo());
throw new HcsException("C109-1 收票单新建失败：" + (result == null ? "响应为空" : result.getMsg()));
}
return result.getData().getData().getFdId();
blade-service/blade-transport/src/main/java/org/springblade/transport/support/hcs/HcsSpecPaySyncSupport.java
+2 -2
View File
@@ -101,7 +101,7 @@ public class HcsSpecPaySyncSupport {
log.info("HCS结算付款特批更新开始：paymentNo={}，specFdId={}", payment.getPaymentNo(), payment.getHcsSpecFdId());
HcsResult<HcsResult<Void>> result = hcsClient.updateSpecApplyPay(param);
if (result == null || !result.isSuccess()) {
log.error("HCS结算付款特批更新失败响应：{}，paymentNo={}", result == null ? "无响应" : result.getMsg(), payment.getPaymentNo());
log.error("HCS结算付款特批更新失败响应：{}，paymentNo={}", result == null ? "无响应" : String.format("msg=%s, traceId=%s", result.getMsg(), result.getTraceId()), payment.getPaymentNo());
throw new HcsException("C106-4 特批更新失败：" + (result == null ? "响应为空" : result.getMsg()));
}
return "C106-4 特批更新成功";
@@ -197,7 +197,7 @@ public class HcsSpecPaySyncSupport {
private String extractNestedFdId(PaymentApplication payment, HcsResult<HcsResult<HcsFormSaveVO>> result) {
if (result == null || !result.isSuccess() || result.getData() == null || !result.getData().isSuccess()
|| result.getData().getData() == null || StringUtil.isBlank(result.getData().getData().getFdId())) {
log.error("HCS结算付款特批发起失败响应：{}，paymentNo={}", result == null ? "无响应" : result.getMsg(), payment.getPaymentNo());
log.error("HCS结算付款特批发起失败响应：{}，paymentNo={}", result == null ? "无响应" : String.format("msg=%s, traceId=%s", result.getMsg(), result.getTraceId()), payment.getPaymentNo());
throw new HcsException("C106-3 特批发起失败：" + (result == null ? "响应为空" : result.getMsg()));
}
return result.getData().getData().getFdId();