425 lines
36 KiB
Java
425 lines
36 KiB
Java
package com.baiyue.finance.service;
|
|
|
|
import com.baiyue.finance.repository.FinanceFeeSourceReadRepository;
|
|
import com.baiyue.finance.dto.FinancePhase1Dtos.AccountSummary;
|
|
import com.baiyue.finance.dto.FinancePhase1Dtos.FeeSourceDetail;
|
|
import com.baiyue.finance.dto.FinancePhase1Dtos.FeeSourceSummary;
|
|
import com.baiyue.finance.dto.FinancePhase1Dtos.LedgerEntry;
|
|
import com.baiyue.finance.dto.FinancePhase1Dtos.PageEnvelope;
|
|
import com.baiyue.finance.dto.FinancePhase1Dtos.ReviewRequest;
|
|
import com.baiyue.finance.dto.FinancePhase1Dtos.FeeSourceActionRequest;
|
|
import com.baiyue.finance.dto.FinancePhase1Dtos.FeeSourceEditRequest;
|
|
import com.baiyue.finance.client.FirstlegFeeSourceClient;
|
|
import com.fasterxml.jackson.databind.JsonNode;
|
|
import com.fasterxml.jackson.databind.ObjectMapper;
|
|
import com.fasterxml.jackson.databind.SerializationFeature;
|
|
import feign.FeignException;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.beans.factory.annotation.Value;
|
|
import org.slf4j.MDC;
|
|
import org.springframework.jdbc.core.JdbcTemplate;
|
|
import org.springframework.stereotype.Service;
|
|
import org.springframework.transaction.annotation.Transactional;
|
|
import org.springframework.util.StringUtils;
|
|
|
|
import java.math.BigDecimal;
|
|
import java.nio.charset.StandardCharsets;
|
|
import java.security.MessageDigest;
|
|
import java.sql.ResultSet;
|
|
import java.sql.SQLException;
|
|
import java.sql.Timestamp;
|
|
import java.time.LocalDate;
|
|
import java.time.LocalDateTime;
|
|
import java.util.ArrayList;
|
|
import java.util.Comparator;
|
|
import java.util.HexFormat;
|
|
import java.util.List;
|
|
import java.util.Map;
|
|
import java.util.Set;
|
|
|
|
@Service
|
|
public class FinancePhase1OperationService {
|
|
private static final String CUSTOMER_IDS = "SELECT tenant_id customer_id FROM fin_customer_settlement_profile UNION SELECT tenant_id FROM fin_bill UNION SELECT customer_id FROM fin_fee_source UNION SELECT tenant_id FROM fin_cost";
|
|
private final JdbcTemplate jdbc;
|
|
private final ObjectMapper objectMapper;
|
|
private final FirstlegFeeSourceClient firstleg;
|
|
private final String internalToken;
|
|
private final FinanceFeeSourceReadRepository feeSources;
|
|
|
|
/** 注入费用来源查询及现有业务依赖。 */
|
|
@Autowired
|
|
public FinancePhase1OperationService(JdbcTemplate jdbc, ObjectMapper objectMapper,
|
|
FirstlegFeeSourceClient firstleg,
|
|
@Value("${baiyue.security.internal-service-token}") String internalToken,
|
|
FinanceFeeSourceReadRepository feeSources) {
|
|
this.jdbc = jdbc;
|
|
this.objectMapper = objectMapper;
|
|
this.firstleg = firstleg;
|
|
this.internalToken = internalToken;
|
|
this.feeSources = feeSources;
|
|
}
|
|
|
|
public PageEnvelope<AccountSummary> listDerivedCustomerAccounts(int page, int pageSize, String customerName, String status) {
|
|
page = page(page); pageSize = pageSize(pageSize);
|
|
String normalizedStatus = status == null || status.isBlank() ? null : status.trim().toUpperCase(java.util.Locale.ROOT);
|
|
if (normalizedStatus != null && !List.of("ACTIVE", "DISABLED").contains(normalizedStatus)) throw error("FIN-REQ-400", "账户状态无效");
|
|
String filter = " WHERE (? IS NULL OR COALESCE(p.customer_name_snapshot,'') LIKE CONCAT('%',?,'%')) AND (? IS NULL OR COALESCE(p.status,'ACTIVE')=?)";
|
|
Object[] filterArgs = {blankToNull(customerName), blankToNull(customerName), normalizedStatus, normalizedStatus};
|
|
String base = " FROM (" + CUSTOMER_IDS + ") c LEFT JOIN fin_customer_settlement_profile p ON p.tenant_id=c.customer_id" + filter;
|
|
Long total = jdbc.queryForObject("SELECT COUNT(*)" + base, Long.class, filterArgs);
|
|
String select = "SELECT c.customer_id,COALESCE(p.customer_name_snapshot,CONCAT('客户',c.customer_id)) customer_name,COALESCE(p.status,'ACTIVE') account_status," +
|
|
"(SELECT COALESCE(SUM(outstanding_amount),0) FROM fin_settlement ar WHERE ar.tenant_id=c.customer_id AND ar.direction='RECEIVABLE' AND ar.status<>'VOIDED') outstanding_receivable," +
|
|
"(SELECT COALESCE(SUM(amount),0) FROM fin_fee_source f WHERE f.customer_id=c.customer_id AND f.direction='RECEIVABLE' AND f.review_status='APPROVED' AND f.currency_code='CNY' AND f.amount>0 AND f.status='AVAILABLE' AND NOT EXISTS(SELECT 1 FROM fin_bill_line bl JOIN fin_bill b ON b.id=bl.bill_id AND b.tenant_id=bl.tenant_id WHERE bl.tenant_id=f.customer_id AND bl.source_id=f.id AND bl.source_version=f.source_fee_version AND b.status<>'VOIDED')) pending_billing," +
|
|
"(SELECT COALESCE(SUM(received_amount),0) FROM fin_receipt r WHERE r.tenant_id=c.customer_id AND r.status='CONFIRMED') received_period," +
|
|
"((SELECT COALESCE(SUM(amount),0) FROM fin_fee_source f WHERE f.customer_id=c.customer_id AND f.direction='PAYABLE' AND f.settlement_mode='ON_ACCOUNT' AND f.review_status='APPROVED' AND f.currency_code='CNY' AND f.amount>0 AND f.status NOT IN ('VOIDED','SUPERSEDED'))+(SELECT COALESCE(SUM(cost_amount),0) FROM fin_cost x WHERE x.tenant_id=c.customer_id AND x.cost_origin IN ('FIRSTLEG_DIRECT_PAID','BUSINESS_DIRECT_PAID') AND x.status='CONFIRMED')) total_cost," +
|
|
"((SELECT COALESCE(SUM(cost_amount),0) FROM fin_cost x WHERE x.tenant_id=c.customer_id AND x.cost_origin IN ('FIRSTLEG_DIRECT_PAID','BUSINESS_DIRECT_PAID') AND x.status='CONFIRMED')+(SELECT COALESCE(SUM(paid_amount),0) FROM fin_settlement x WHERE x.tenant_id=c.customer_id AND x.direction='PAYABLE' AND x.status<>'VOIDED')) paid_cost," +
|
|
"((SELECT COALESCE(SUM(outstanding_amount),0) FROM fin_settlement x WHERE x.tenant_id=c.customer_id AND x.direction='PAYABLE' AND x.status<>'VOIDED')+(SELECT COALESCE(SUM(f.amount),0) FROM fin_fee_source f WHERE f.customer_id=c.customer_id AND f.direction='PAYABLE' AND f.settlement_mode='ON_ACCOUNT' AND f.review_status='APPROVED' AND f.currency_code='CNY' AND f.amount>0 AND f.status NOT IN ('VOIDED','SUPERSEDED') AND NOT EXISTS(SELECT 1 FROM fin_settlement_line sl JOIN fin_settlement s ON s.id=sl.settlement_id AND s.tenant_id=sl.tenant_id WHERE sl.tenant_id=f.customer_id AND sl.fee_source_id=f.id AND s.direction='PAYABLE' AND s.status<>'VOIDED'))) outstanding_payable," +
|
|
"COALESCE((SELECT actual_balance FROM fin_wallet_account w WHERE w.customer_id=c.customer_id),0) actual_balance," +
|
|
"COALESCE((SELECT frozen_balance FROM fin_wallet_account w WHERE w.customer_id=c.customer_id),0) frozen_balance," +
|
|
"COALESCE((SELECT available_balance FROM fin_wallet_account w WHERE w.customer_id=c.customer_id),0) available_balance," +
|
|
"COALESCE((SELECT credit_limit FROM fin_wallet_account w WHERE w.customer_id=c.customer_id),0) credit_limit," +
|
|
"COALESCE((SELECT credit_used FROM fin_wallet_account w WHERE w.customer_id=c.customer_id),0) credit_used," +
|
|
"COALESCE((SELECT credit_frozen FROM fin_wallet_account w WHERE w.customer_id=c.customer_id),0) credit_frozen," +
|
|
"COALESCE((SELECT credit_limit-credit_used-credit_frozen FROM fin_wallet_account w WHERE w.customer_id=c.customer_id),0) available_credit," +
|
|
"(SELECT credit_expires_on FROM fin_wallet_account w WHERE w.customer_id=c.customer_id) credit_expires_on," +
|
|
"COALESCE((SELECT version FROM fin_wallet_account w WHERE w.customer_id=c.customer_id),0) account_version," +
|
|
"(SELECT COUNT(*) FROM fin_recharge_request rr WHERE rr.customer_id=c.customer_id AND rr.status='PENDING') pending_recharge_count," +
|
|
"GREATEST(COALESCE((SELECT MAX(updated_at) FROM fin_bill b WHERE b.tenant_id=c.customer_id),'1970-01-01'),COALESCE((SELECT MAX(updated_at) FROM fin_receipt r WHERE r.tenant_id=c.customer_id),'1970-01-01'),COALESCE((SELECT MAX(updated_at) FROM fin_cost x WHERE x.tenant_id=c.customer_id),'1970-01-01'),COALESCE((SELECT MAX(updated_at) FROM fin_fee_source f WHERE f.customer_id=c.customer_id),'1970-01-01'),COALESCE((SELECT MAX(updated_at) FROM fin_settlement x WHERE x.tenant_id=c.customer_id),'1970-01-01')) last_changed_at" + base + " ORDER BY last_changed_at DESC,c.customer_id DESC LIMIT ? OFFSET ?";
|
|
Object[] args = java.util.Arrays.copyOf(filterArgs, filterArgs.length + 2);
|
|
args[args.length - 2] = pageSize; args[args.length - 1] = (page - 1) * pageSize;
|
|
List<AccountSummary> rows = jdbc.query(select, (rs, row) -> accountSummaryRow(rs), args);
|
|
return PageEnvelope.success(rows, page, pageSize, total == null ? 0 : total);
|
|
}
|
|
|
|
private static AccountSummary accountSummaryRow(ResultSet rs) throws SQLException {
|
|
BigDecimal actualBalance = money(rs, "actual_balance");
|
|
BigDecimal frozenBalance = money(rs, "frozen_balance");
|
|
BigDecimal creditLimit = money(rs, "credit_limit");
|
|
BigDecimal creditFrozen = money(rs, "credit_frozen");
|
|
LocalDate creditExpiresOn = rs.getDate("credit_expires_on") == null
|
|
? null : rs.getDate("credit_expires_on").toLocalDate();
|
|
boolean creditActive = creditLimit.signum() > 0 && creditExpiresOn != null
|
|
&& !creditExpiresOn.isBefore(LocalDate.now());
|
|
BigDecimal creditUsed = money(rs, "credit_used");
|
|
if (!creditActive && creditUsed.signum() > 0) {
|
|
actualBalance = actualBalance.subtract(creditUsed);
|
|
creditUsed = BigDecimal.ZERO;
|
|
}
|
|
BigDecimal availableCredit = creditActive
|
|
? creditLimit.subtract(creditUsed).subtract(creditFrozen) : BigDecimal.ZERO;
|
|
BigDecimal availableBalance = creditActive
|
|
? actualBalance.subtract(frozenBalance.subtract(creditFrozen)).add(availableCredit)
|
|
: actualBalance.subtract(frozenBalance);
|
|
return new AccountSummary(rs.getLong("customer_id"), String.valueOf(rs.getLong("customer_id")),
|
|
rs.getString("customer_name"), null, null, money(rs, "outstanding_receivable"),
|
|
money(rs, "pending_billing"), money(rs, "received_period"), money(rs, "total_cost"),
|
|
money(rs, "paid_cost"), money(rs, "outstanding_payable"), actualBalance, frozenBalance,
|
|
availableBalance, creditLimit, creditUsed, availableCredit, creditExpiresOn, creditActive,
|
|
rs.getInt("account_version"), rs.getLong("pending_recharge_count"), rs.getString("account_status"),
|
|
time(rs, "last_changed_at"));
|
|
}
|
|
|
|
public PageEnvelope<LedgerEntry> listDerivedCustomerAccountLedger(long customerId, int page, int pageSize,
|
|
String businessType, LocalDate startDate, LocalDate endDate) {
|
|
customer(customerId); page = page(page); pageSize = pageSize(pageSize);
|
|
if (startDate != null && endDate != null && startDate.isAfter(endDate)) throw error("FIN-REQ-400", "开始日期不能晚于结束日期");
|
|
List<RawLedger> rows = new ArrayList<>();
|
|
rows.addAll(jdbc.query("SELECT id,bill_no,created_at,total_amount,created_by,created_by_name,remark FROM fin_bill WHERE tenant_id=? AND status<>'VOIDED'", (rs, n) -> raw(rs, "SETTLEMENT_ISSUED", "BILL", "bill_no", "total_amount", null), customerId));
|
|
rows.addAll(jdbc.query("SELECT id,receipt_no,received_at received_time,received_amount,created_by,created_by_name,remark FROM fin_receipt WHERE tenant_id=? AND status='CONFIRMED'", (rs, n) -> raw(rs, "RECEIPT", "RECEIPT", "receipt_no", null, "received_amount"), customerId));
|
|
rows.addAll(jdbc.query("SELECT id,cost_no,created_at,cost_amount,created_by,created_by_name,remark FROM fin_cost WHERE tenant_id=? AND cost_origin IN ('FIRSTLEG_DIRECT_PAID','BUSINESS_DIRECT_PAID') AND status='CONFIRMED'", (rs, n) -> raw(rs, "SUPPLIER_DIRECT_PAID", "DIRECT_PAID_COST", "cost_no", null, null), customerId));
|
|
rows.addAll(jdbc.query("SELECT p.id,CONCAT(s.settlement_no,'-',p.id) payment_no,p.created_at,p.amount cost_amount,p.created_by,p.created_by_name,p.remark FROM fin_settlement_payment p JOIN fin_settlement s ON s.id=p.settlement_id AND s.tenant_id=p.tenant_id WHERE p.tenant_id=? AND p.transaction_type='PAYMENT' AND s.direction='PAYABLE' AND s.status<>'VOIDED'", (rs, n) -> raw(rs, "SUPPLIER_ON_ACCOUNT_PAYMENT", "AP_PAYMENT", "payment_no", null, null), customerId));
|
|
rows.sort(Comparator.comparing(RawLedger::occurredAt).thenComparing(RawLedger::id));
|
|
BigDecimal outstanding = BigDecimal.ZERO;
|
|
List<LedgerEntry> projected = new ArrayList<>();
|
|
for (RawLedger row : rows) {
|
|
BigDecimal receivableChange = row.receivable();
|
|
outstanding = outstanding.add(receivableChange);
|
|
BigDecimal payable = List.of("DIRECT_PAID_COST", "AP_PAYMENT").contains(row.documentType()) ? row.amount() : BigDecimal.ZERO;
|
|
LedgerEntry entry = new LedgerEntry(row.id(), row.occurredAt(), row.businessType(), row.documentType(), row.id(), row.documentNo(), receivableChange, payable, outstanding, row.operatorName(), row.remark(),
|
|
null, null, null, null, null, null, null, null, null, null, null, null, null, null);
|
|
if ((businessType == null || businessType.isBlank() || businessType.equals(entry.businessType())) && inRange(entry.occurredAt(), startDate, endDate)) projected.add(entry);
|
|
}
|
|
BigDecimal derivedOutstanding = outstanding;
|
|
projected.addAll(jdbc.query("SELECT * FROM fin_wallet_ledger WHERE customer_id=?", (rs, n) -> {
|
|
LocalDate occurredDate = rs.getDate("occurred_date").toLocalDate();
|
|
LocalDateTime occurredAt = occurredDate.atStartOfDay();
|
|
String type = rs.getString("change_type");
|
|
return new LedgerEntry(rs.getLong("id"), occurredAt, type, "WALLET_LEDGER", rs.getLong("id"),
|
|
rs.getString("business_no"), BigDecimal.ZERO, BigDecimal.ZERO, derivedOutstanding,
|
|
rs.getString("operator_name"), rs.getString("remark"), rs.getString("business_no"), type,
|
|
rs.getBigDecimal("amount"), rs.getBigDecimal("actual_balance_after"),
|
|
rs.getBigDecimal("frozen_balance_after"), rs.getBigDecimal("available_balance_after"),
|
|
rs.getBigDecimal("credit_limit_after"), rs.getBigDecimal("credit_used_after"),
|
|
rs.getBigDecimal("available_credit_after"),
|
|
rs.getString("source_type"), rs.getString("source_no"), occurredDate,
|
|
rs.getString("payment_method"), rs.getString("reference_no"));
|
|
}, customerId).stream().filter(entry ->
|
|
(businessType == null || businessType.isBlank() || businessType.equals(entry.businessType()))
|
|
&& inRange(entry.occurredAt(), startDate, endDate)).toList());
|
|
projected.sort(Comparator.comparing(LedgerEntry::occurredAt).reversed()
|
|
.thenComparing(Comparator.comparingLong(LedgerEntry::ledgerId).reversed()));
|
|
int from = Math.min((page - 1) * pageSize, projected.size());
|
|
int to = Math.min(from + pageSize, projected.size());
|
|
return PageEnvelope.success(List.copyOf(projected.subList(from, to)), page, pageSize, projected.size());
|
|
}
|
|
|
|
/** 按同一来源费用的当前版本分页，调整历史不重复计入客户应收应付。 */
|
|
public PageEnvelope<FeeSourceSummary> listFinanceFeeSources(int page, int pageSize, Long customerId,
|
|
String direction, String sourceStatus,
|
|
String reviewStatus,
|
|
Boolean statementGenerated, LocalDate businessDateFrom,
|
|
LocalDate businessDateTo, String keyword) {
|
|
page = page(page); pageSize = pageSize(pageSize);
|
|
if (customerId != null) customer(customerId);
|
|
if (businessDateFrom != null && businessDateTo != null && businessDateFrom.isAfter(businessDateTo)) {
|
|
throw error("FIN-REQ-400", "开始日期不能晚于结束日期");
|
|
}
|
|
String normalizedDirection = normalized(direction, List.of("RECEIVABLE", "PAYABLE"), "费用方向无效");
|
|
String normalizedReview = normalized(reviewStatus,
|
|
List.of("DRAFT", "PENDING", "APPROVED", "REJECTED"), "审核状态无效");
|
|
String normalizedSourceStatus = normalized(sourceStatus,
|
|
List.of("AVAILABLE", "LOCKED", "BILLED", "SETTLED", "VOIDED", "SUPERSEDED"), "费用来源状态无效");
|
|
Map<String, Object> filters = feeSources.filters(customerId, normalizedDirection, normalizedSourceStatus,
|
|
normalizedReview, statementGenerated, businessDateFrom, businessDateTo, blankToNull(keyword), page, pageSize);
|
|
return PageEnvelope.success(feeSources.list(filters), page, pageSize, feeSources.count(filters));
|
|
}
|
|
|
|
public FeeSourceDetail getFinanceFeeSource(long feeSourceId) {
|
|
if (feeSourceId <= 0) throw error("FIN-REQ-400", "费用来源ID无效");
|
|
List<FeeSourceDetail> rows = jdbc.query("SELECT * FROM fin_fee_source WHERE id=?", (rs, n) -> detail(rs), feeSourceId);
|
|
if (rows.isEmpty()) throw error("FIN-FEE-404", "费用来源不存在");
|
|
return rows.get(0);
|
|
}
|
|
|
|
@Transactional
|
|
public FeeSourceDetail reviewFinanceFeeSource(long feeSourceId, long operatorId, String key, ReviewRequest request) {
|
|
if (request == null || !List.of("APPROVE", "REJECT").contains(request.action()) || request.expectedVersion() < 0) throw error("FIN-REQ-400", "审核请求无效");
|
|
if ("REJECT".equals(request.action()) && !StringUtils.hasText(request.reason())) throw error("FIN-REQ-400", "驳回原因不能为空");
|
|
FeeSourceDetail before = getFinanceFeeSource(feeSourceId);
|
|
Long replay = reserve(before.customerId(), operatorId, "FEE_SOURCE_REVIEW", key, "POST", "/api/platform/finance/v1/fee-sources/" + feeSourceId + "/review", request);
|
|
if (replay != null) return getFinanceFeeSource(replay);
|
|
String review = "APPROVE".equals(request.action()) ? "APPROVED" : "REJECTED";
|
|
int changed = jdbc.update("UPDATE fin_fee_source SET review_status=?,review_reason=?,operation_version=operation_version+1 WHERE id=? AND operation_version=? AND status='AVAILABLE' AND review_status='PENDING'",
|
|
review, request.reason(), feeSourceId, request.expectedVersion());
|
|
if (changed != 1) throw error("FIN-FEE-409", "费用来源状态或版本不允许审核");
|
|
FeeSourceDetail after = getFinanceFeeSource(feeSourceId);
|
|
audit(after.customerId(), feeSourceId, "FEE_SOURCE_REVIEW_" + request.action(), request.reason(), before, after, operatorId);
|
|
complete(after.customerId(), operatorId, "FEE_SOURCE_REVIEW", key, feeSourceId);
|
|
return after;
|
|
}
|
|
|
|
@Transactional
|
|
public FeeSourceDetail editFinanceFeeSource(long feeSourceId, long operatorId, String key,
|
|
FeeSourceEditRequest request, boolean adjustment) {
|
|
if (request == null || request.expectedVersion() < 0 || request.amount() == null
|
|
|| request.amount().signum() <= 0 || !StringUtils.hasText(request.reason())) {
|
|
throw error("FIN-REQ-400", adjustment ? "费用调整请求无效" : "费用编辑请求无效");
|
|
}
|
|
FeeSourceDetail before = getFinanceFeeSource(feeSourceId);
|
|
if (Set.of("FIRSTLEG", "LASTLEG").contains(before.sourceSystem())) {
|
|
throw error("FIN-FEE-409", "业务费用必须回到对应业务费用明细调整，Finance不可直接修改来源金额");
|
|
}
|
|
String operation = adjustment ? "FEE_SOURCE_ADJUST" : "FEE_SOURCE_EDIT";
|
|
String path = "/api/platform/finance/v1/fee-sources/" + feeSourceId + (adjustment ? "/adjust" : "");
|
|
Long replay = reserve(before.customerId(), operatorId, operation, key,
|
|
adjustment ? "POST" : "PUT", path, request);
|
|
if (replay != null) return getFinanceFeeSource(replay);
|
|
if (before.statementGenerated()) throw error("FIN-FEE-409", "已生成单据的费用来源不可编辑或调整");
|
|
String requiredStatus = adjustment ? "APPROVED" : before.reviewStatus();
|
|
if (!adjustment && !List.of("DRAFT", "REJECTED").contains(requiredStatus)) {
|
|
throw error("FIN-FEE-409", "只有草稿或已驳回费用可编辑");
|
|
}
|
|
int changed = jdbc.update("UPDATE fin_fee_source SET amount=?,review_status='DRAFT',review_reason=NULL,operation_version=operation_version+1 WHERE id=? AND operation_version=? AND status='AVAILABLE' AND review_status=?",
|
|
request.amount(), feeSourceId, request.expectedVersion(), requiredStatus);
|
|
if (changed != 1) throw error("FIN-FEE-409", "费用来源状态或版本不允许编辑或调整");
|
|
FeeSourceDetail after = getFinanceFeeSource(feeSourceId);
|
|
audit(after.customerId(), feeSourceId, adjustment ? "FEE_SOURCE_ADJUST" : "FEE_SOURCE_EDIT", request.reason(), before, after, operatorId);
|
|
complete(after.customerId(), operatorId, operation, key, feeSourceId);
|
|
return after;
|
|
}
|
|
|
|
@Transactional
|
|
public FeeSourceDetail submitFinanceFeeSource(long feeSourceId, long operatorId, String key,
|
|
FeeSourceActionRequest request) {
|
|
return transitionFeeSource(feeSourceId, operatorId, key, request, "FEE_SOURCE_SUBMIT",
|
|
"PENDING", List.of("DRAFT", "REJECTED"), false);
|
|
}
|
|
|
|
@Transactional
|
|
public FeeSourceDetail voidFinanceFeeSource(long feeSourceId, long operatorId,
|
|
String operatorName, String key,
|
|
FeeSourceActionRequest request) {
|
|
if (request == null || request.expectedVersion() < 0 || !StringUtils.hasText(request.reason())) {
|
|
throw error("FIN-REQ-400", "费用操作请求无效");
|
|
}
|
|
FeeSourceDetail before = getFinanceFeeSource(feeSourceId);
|
|
if ("LASTLEG".equals(before.sourceSystem())) {
|
|
throw error("FIN-FEE-409", "海外业务费用必须在海外费用来源中作废，Finance只消费作废事件");
|
|
}
|
|
if (!"FIRSTLEG".equals(before.sourceSystem())) {
|
|
return transitionFeeSource(feeSourceId, operatorId, key, request, "FEE_SOURCE_VOID",
|
|
"VOIDED", List.of("DRAFT", "PENDING", "REJECTED", "APPROVED"), true);
|
|
}
|
|
Long replay = reserve(before.customerId(), operatorId, "FEE_SOURCE_VOID", key, "POST",
|
|
"/api/platform/finance/v1/fee-sources/" + feeSourceId + "/void", request);
|
|
if (replay != null) return getFinanceFeeSource(replay);
|
|
if (before.statementGenerated()) throw error("FIN-FEE-409", "已生成单据的费用来源不可作废");
|
|
if (before.operationVersion() != request.expectedVersion()) {
|
|
throw error("FIN-FEE-409", "费用来源状态或版本已变化");
|
|
}
|
|
if (!List.of("DRAFT", "PENDING", "REJECTED", "APPROVED").contains(before.reviewStatus())
|
|
|| !"AVAILABLE".equals(before.sourceStatus())) {
|
|
throw error("FIN-FEE-409", "费用来源当前状态不允许作废");
|
|
}
|
|
FirstlegFeeSourceClient.VoidCommand command = new FirstlegFeeSourceClient.VoidCommand(
|
|
before.sourceType(), before.sourceFeeId(), before.sourceVersion(), before.customerId(),
|
|
before.inboundId(), before.containerId(), operatorId,
|
|
StringUtils.hasText(operatorName) ? operatorName.trim() : "SYSTEM", request.reason().trim());
|
|
try {
|
|
var response = firstleg.voidSource(internalToken, key, hash(command), command);
|
|
if (response == null || !response.successful() || response.data() == null
|
|
|| !"VOIDED".equals(response.data().status())) {
|
|
throw error("FIN-UPSTREAM-502", "Firstleg未确认费用来源作废");
|
|
}
|
|
} catch (FeignException exception) {
|
|
throw error("FIN-UPSTREAM-503", "Firstleg费用作废服务暂不可用");
|
|
}
|
|
audit(before.customerId(), feeSourceId, "FEE_SOURCE_VOID_REQUESTED",
|
|
request.reason(), before, before, operatorId);
|
|
complete(before.customerId(), operatorId, "FEE_SOURCE_VOID", key, feeSourceId);
|
|
return getFinanceFeeSource(feeSourceId);
|
|
}
|
|
|
|
private FeeSourceDetail transitionFeeSource(long feeSourceId, long operatorId, String key,
|
|
FeeSourceActionRequest request, String operation,
|
|
String target, List<String> allowedReviews,
|
|
boolean voidSource) {
|
|
if (request == null || request.expectedVersion() < 0 || !StringUtils.hasText(request.reason())) {
|
|
throw error("FIN-REQ-400", "费用操作请求无效");
|
|
}
|
|
FeeSourceDetail before = getFinanceFeeSource(feeSourceId);
|
|
Long replay = reserve(before.customerId(), operatorId, operation, key, "POST",
|
|
"/api/platform/finance/v1/fee-sources/" + feeSourceId + (voidSource ? "/void" : "/submit"), request);
|
|
if (replay != null) return getFinanceFeeSource(replay);
|
|
if (before.statementGenerated()) throw error("FIN-FEE-409", "已生成单据的费用来源不可操作");
|
|
if (!allowedReviews.contains(before.reviewStatus())) throw error("FIN-FEE-409", "费用来源当前状态不允许该操作");
|
|
int changed = voidSource
|
|
? jdbc.update("UPDATE fin_fee_source SET status='VOIDED',operation_version=operation_version+1 WHERE id=? AND operation_version=? AND status='AVAILABLE' AND review_status=?",
|
|
feeSourceId, request.expectedVersion(), before.reviewStatus())
|
|
: jdbc.update("UPDATE fin_fee_source SET review_status=?,review_reason=NULL,operation_version=operation_version+1 WHERE id=? AND operation_version=? AND status='AVAILABLE' AND review_status=?",
|
|
target, feeSourceId, request.expectedVersion(), before.reviewStatus());
|
|
if (changed != 1) throw error("FIN-FEE-409", "费用来源状态或版本已变化");
|
|
FeeSourceDetail after = getFinanceFeeSource(feeSourceId);
|
|
audit(after.customerId(), feeSourceId, operation, request.reason(), before, after, operatorId);
|
|
complete(after.customerId(), operatorId, operation, key, feeSourceId);
|
|
return after;
|
|
}
|
|
|
|
/** 读取指定不可变版本，并附带同客户同方向的费用调整历史。 */
|
|
private FeeSourceDetail detail(ResultSet rs) throws SQLException {
|
|
JsonNode snapshot = parse(rs.getString("source_snapshot"));
|
|
long id = rs.getLong("id");
|
|
boolean generated = Boolean.TRUE.equals(jdbc.queryForObject("SELECT COUNT(*)>0 FROM fin_bill_line WHERE source_id=? AND source_version=?", Boolean.class, id, rs.getInt("source_fee_version")));
|
|
String status = rs.getString("status");
|
|
if (generated && "AVAILABLE".equals(status)) status = "BILLED";
|
|
BigDecimal quantity = decimal(snapshot, "chargeableQuantity");
|
|
BigDecimal amount = rs.getBigDecimal("amount");
|
|
BigDecimal originalAmount = firstDecimal(decimal(snapshot, "originalAmount"), amount);
|
|
BigDecimal unitPrice = firstDecimal(decimal(snapshot, "unitPrice"),
|
|
quantity != null && quantity.signum() > 0 ? originalAmount.divide(quantity, 6, java.math.RoundingMode.HALF_UP) : null);
|
|
return new FeeSourceDetail(id, rs.getString("source_system"), rs.getString("source_type"), firstText(rs.getString("source_no"), text(snapshot, "sourceBusinessId")), rs.getLong("source_fee_id"), rs.getInt("source_fee_version"), rs.getString("direction"), rs.getLong("customer_id"), text(snapshot, "customerName"), jsonLong(snapshot, "supplierId"), text(snapshot, "supplierName"),
|
|
nullableLong(rs, "order_id"), nullableLong(rs, "inbound_id"), text(snapshot, "inboundCode"), nullableLong(rs, "container_id"), text(snapshot, "containerNo"), date(snapshot, "businessDate"), rs.getString("fee_item_name"),
|
|
quantity, text(snapshot, "quantityUnit"), unitPrice, nullableDate(snapshot, "periodStart"), nullableDate(snapshot, "periodEnd"),
|
|
amount, rs.getString("currency_code"), firstText(text(snapshot, "originalCurrency"), rs.getString("currency_code")), originalAmount,
|
|
firstDecimal(decimal(snapshot, "exchangeRate"), BigDecimal.ONE), text(snapshot, "exchangeRateMonth"),
|
|
defaultString(rs.getString("review_status"), "DRAFT"), status, generated,
|
|
rs.getString("review_reason"), rs.getString("source_hash"), rs.getInt("operation_version"), feeSources.logs(rs.getLong("customer_id"), id));
|
|
}
|
|
|
|
private Long reserve(long customerId, long operatorId, String operation, String key, String method, String path, Object body) {
|
|
if (!StringUtils.hasText(key) || key.length() > 128) throw error("FIN-IDEM-400", "必须提供有效的Idempotency-Key");
|
|
String hash = hash(Map.of("method", method, "path", path, "customerId", customerId, "body", body));
|
|
List<Map<String,Object>> rows = jdbc.queryForList("SELECT request_hash,status,result_resource_id FROM fin_idempotency_record WHERE tenant_id=? AND operator_id=? AND operation=? AND idempotency_key=?", customerId, operatorId, operation, key);
|
|
if (!rows.isEmpty()) {
|
|
Map<String,Object> row = rows.get(0);
|
|
if (!hash.equals(row.get("request_hash"))) throw error("FIN-IDEM-409", "Idempotency-Key已用于其他请求");
|
|
if ("SUCCEEDED".equals(row.get("status")) && row.get("result_resource_id") != null) return ((Number) row.get("result_resource_id")).longValue();
|
|
throw error("FIN-IDEM-409", "相同请求正在处理中");
|
|
}
|
|
jdbc.update("INSERT INTO fin_idempotency_record(tenant_id,operator_id,operation,idempotency_key,request_hash,status) VALUES(?,?,?,?,?,'PROCESSING')", customerId, operatorId, operation, key, hash);
|
|
return null;
|
|
}
|
|
|
|
private void complete(long customerId, long operatorId, String operation, String key, long id) {
|
|
jdbc.update("UPDATE fin_idempotency_record SET status='SUCCEEDED',result_resource_id=? WHERE tenant_id=? AND operator_id=? AND operation=? AND idempotency_key=? AND status='PROCESSING'", id, customerId, operatorId, operation, key);
|
|
}
|
|
|
|
private void audit(long customerId, long id, String action, String reason, Object before, Object after, long operatorId) {
|
|
jdbc.update("INSERT INTO fin_audit_log(tenant_id,resource_type,resource_id,action,reason,before_data,after_data,operator_id,operator_name_snapshot,request_id,trace_id) VALUES(?,?,?,?,?,?,?,?,?,?,?)",
|
|
customerId, "FIN_FEE_SOURCE", id, action, reason, json(before), json(after), operatorId,
|
|
FinanceOperatorSnapshot.requiredName(operatorId), MDC.get("requestId"), MDC.get("traceId"));
|
|
}
|
|
|
|
private static RawLedger raw(ResultSet rs, String businessType, String documentType, String noColumn, String debitColumn, String creditColumn) throws SQLException {
|
|
LocalDateTime occurred = time(rs, documentType.equals("RECEIPT") ? "received_time" : "created_at");
|
|
BigDecimal amount = List.of("DIRECT_PAID_COST", "AP_PAYMENT").contains(documentType)
|
|
? money(rs, "cost_amount") : debitColumn != null ? money(rs, debitColumn) : money(rs, creditColumn);
|
|
BigDecimal receivable = debitColumn != null ? amount : creditColumn != null ? amount.negate() : BigDecimal.ZERO;
|
|
return new RawLedger(rs.getLong("id"), occurred, businessType, documentType, rs.getString(noColumn), amount, receivable,
|
|
rs.getLong("created_by"), rs.getString("created_by_name"), rs.getString("remark"));
|
|
}
|
|
private record RawLedger(long id, LocalDateTime occurredAt, String businessType, String documentType,
|
|
String documentNo, BigDecimal amount, BigDecimal receivable, long operatorId,
|
|
String operatorName, String remark) {}
|
|
|
|
private static int page(int value) { if (value < 1) throw error("FIN-REQ-400", "页码必须大于0"); return value; }
|
|
private static int pageSize(int value) { if (value < 1 || value > 200) throw error("FIN-REQ-400", "每页数量必须在1到200之间"); return value; }
|
|
private static void customer(long value) { if (value <= 0) throw error("FIN-REQ-400", "客户ID无效"); }
|
|
private static boolean inRange(LocalDateTime value, LocalDate start, LocalDate end) { return value != null && (start == null || !value.toLocalDate().isBefore(start)) && (end == null || !value.toLocalDate().isAfter(end)); }
|
|
private static String blankToNull(String value) { return value == null || value.isBlank() ? null : value.trim(); }
|
|
private static String normalized(String value, List<String> allowed, String message) {
|
|
String normalized = blankToNull(value);
|
|
if (normalized == null) return null;
|
|
normalized = normalized.toUpperCase(java.util.Locale.ROOT);
|
|
if (!allowed.contains(normalized)) throw error("FIN-REQ-400", message);
|
|
return normalized;
|
|
}
|
|
private static BigDecimal money(ResultSet rs, String column) throws SQLException { BigDecimal value = rs.getBigDecimal(column); return value == null ? BigDecimal.ZERO : value; }
|
|
private static LocalDateTime time(ResultSet rs, String column) throws SQLException { Timestamp value = rs.getTimestamp(column); return value == null ? null : value.toLocalDateTime(); }
|
|
private static Long nullableLong(ResultSet rs, String column) throws SQLException { long value = rs.getLong(column); return rs.wasNull() ? null : value; }
|
|
private JsonNode parse(String json) { try { return objectMapper.readTree(json); } catch (Exception e) { throw error("FIN-DATA-500", "费用来源快照损坏"); } }
|
|
private String json(Object value) { try { return objectMapper.writeValueAsString(value); } catch (Exception e) { throw error("FIN-DATA-500", "财务数据序列化失败"); } }
|
|
/** 固定映射键序，使同一请求在服务重启前后使用相同摘要。 */
|
|
private String hash(Object value) {
|
|
try {
|
|
byte[] canonical = objectMapper.writer().with(SerializationFeature.ORDER_MAP_ENTRIES_BY_KEYS)
|
|
.writeValueAsBytes(value);
|
|
return HexFormat.of().formatHex(MessageDigest.getInstance("SHA-256").digest(canonical));
|
|
} catch (Exception failure) { throw error("FIN-DATA-500", "幂等请求哈希失败"); }
|
|
}
|
|
private static String text(JsonNode node, String field) { JsonNode value = node.path(field); return value.isMissingNode() || value.isNull() ? null : value.asText(); }
|
|
private static Long jsonLong(JsonNode node, String field) {
|
|
JsonNode value = node.path(field);
|
|
if (value.isIntegralNumber() && value.canConvertToLong()) {
|
|
long parsed = value.longValue();
|
|
return parsed > 0 ? parsed : null;
|
|
}
|
|
if (!value.isTextual()) return null;
|
|
try {
|
|
long parsed = Long.parseLong(value.textValue());
|
|
return parsed > 0 ? parsed : null;
|
|
} catch (NumberFormatException ignored) {
|
|
return null;
|
|
}
|
|
}
|
|
private static Long firstLong(Long first, Long second) { return first != null ? first : second; }
|
|
private static BigDecimal firstDecimal(BigDecimal first, BigDecimal second) { return first != null ? first : second; }
|
|
private static String firstText(String first, String second) { return StringUtils.hasText(first) ? first : second; }
|
|
private static String defaultText(JsonNode node, String field, String fallback) { String value = text(node, field); return value == null || value.isBlank() ? fallback : value; }
|
|
private static String defaultString(String value, String fallback) { return value == null || value.isBlank() ? fallback : value; }
|
|
private static BigDecimal decimal(JsonNode node, String field) { String value = text(node, field); return value == null || value.isBlank() ? null : new BigDecimal(value); }
|
|
private static LocalDate date(JsonNode node, String field) { String value = text(node, field); return value == null || value.isBlank() ? LocalDate.of(1970, 1, 1) : LocalDate.parse(value); }
|
|
private static LocalDate nullableDate(JsonNode node, String field) { String value = text(node, field); return value == null || value.isBlank() ? null : LocalDate.parse(value); }
|
|
private static FinanceEventException error(String code, String message) { return new FinanceEventException(code, message); }
|
|
}
|