tengyufan 336cc3d88b feat: 新增TRS合约日终Kafka推送 ...

- 在日终任务的逐日循环中，于当日收盘、风险监控和日终文件生成完成后，
  按 valueDate 推送一条 TRS 合约全量快照；区间收盘逐日推送，空日推送空快照。
- 基于 eod_swap、trade、eod_swap_position、swap_position 组装合约字段，
  Kafka Key 使用 yyyy-MM-dd 格式的 valueDate。
- 新增带 Key 的 Kafka 发送重载；保留原有无 Key 发送及其吞异常行为，避免影响既有调用。
- 推送失败最多尝试 3 次；最终失败记录 Error 日志，并按 eod_swap.id 写入 push_status，
  空快照失败使用 record_id=0。
- 增加 ContractTopic 配置，默认及各部署环境使用 onederiv.trs.contract.v1。
- 增加定向单测，覆盖空快照、区间逐日推送、重试成功、三次失败和字段映射。

2026-08-25 16:07:21 +08:00

..

Enum

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

ExternalCashFlow

feat(资金流水): 添加外部银行流水导入功能

2026-03-13 11:15:19 +08:00

FinancialVoucherCreator

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

HengTaiModel

chore(swap): 删除衡泰旧直连方案孤儿DTO——HengTaiModel下22个零引用报文模型+3处无用using

2026-08-22 07:35:41 +08:00

ApprovalReq.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

Assetunit.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

CalcBondRequest.cs

fix: js 处理空成交收益率

2025-10-15 18:09:23 +08:00

CalculateMarginRequest.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

Calendar.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

CashCalcReq.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

CashNoticeReq.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

CheckQuotaMoitorModel.cs

dv01全局去除

2024-06-12 10:28:49 +08:00

CheckSelectedGroupTradesForActionReq.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

CheckSelectedGroupTradesForActionResponse.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

CheckUnderlyingRequest.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

Client.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

ClientAssessmentLogModel.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

ClientBalanceForTrsResponse.cs

feat(kafka): 添加实时资金计算topic配置

2025-12-17 10:05:57 +08:00

ClientBalanceKafkaReq.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

ClientBalanceMonitorForTrsRespone.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

ClientBalanceMonitorFroTrsRequest.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

ClientBlackApprovalQueryRes.cs

feat(ClientBlack): 新增客户黑名单审批流程

2026-08-13 17:21:04 +08:00

ClientBlackAuditReq.cs

feat(ClientBlack): 新增客户黑名单审批流程

2026-08-13 17:21:04 +08:00

clientblackReq.cs

feat(ClientBlack): 新增客户黑名单审批流程

2026-08-13 17:21:04 +08:00

ClientCashAuditReq.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

ClientCashInCashOut.cs

保证金算法&资金计算

2025-04-16 15:15:59 +08:00

ClientCashInCashOutHistoryReq.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

ClientcashincashoutProduct.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

ClientChangeKafkaRequest.cs

TRS-ZS-336在管理端将交易员的账号禁用后，交易端应限制其不能登录

2025-04-24 17:48:59 +08:00

ClientCredit.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

clientLinq.cs

TRS-ZS-546 资金监控增加费用及利息

2025-07-08 10:28:28 +08:00

ClientMarginConfigReq.cs

TRS-ZS-566、TRS-ZS-568 客户保证金率需求完成

2025-07-18 17:44:58 +08:00

ClientMarginDetailDto.cs

利率债TRS保证金期限档位切换为<5y/5y-10y/10y-30y/>30y

2026-04-29 10:51:26 +08:00

ClientMarginTemplate.cs

#EQD-6947 国联民生-保证金计算整体改造-实现第一版盯市规则（不支持同一客户多部门）（1）保证金规则的设置 阶段1,开放v2

2026-08-12 15:38:55 +08:00

ClientMarginTemplateReq.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

clientPayment.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

clientReq.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

ClientSwapPositionRequest.cs

feat(swap): 更新互换估值功能并优化数据模型

2026-07-14 09:46:54 +08:00

ClientVarietyConfigReq.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

CommissionByTrade.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

CommissionDetailByTrade.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

CommissionsGroupByClient.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

companycollateral.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

Configcolumn.cs

feat(swap): 更新互换估值功能并优化数据模型

2026-07-14 09:46:54 +08:00

Correlation.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

DayUnwindReport.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

DividendTrade.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

EntryExitApprovalQueryReq.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

EntryExitApprovalQueryRes.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

Eod_forward_marginReq.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

eod_position.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

Eod_trade_position_static.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

EodClientBalanceReCalcModel.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

EodCurrencyRateReq.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

EodPnl.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

EodPnlTradePosition.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

EodPositionRisks.cs

增加vega(1bp)希腊值

2026-08-20 14:15:12 +08:00

EodPositionSwapMannual.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

EodStockPrice.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

EodSwapPositionQueryRequest.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

EodSwapQueryRequest.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

EodTrade.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

EodTradeVolOverride.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

EtradingRuleKafkaModel.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

ExcelDeclareModel.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

Exchange_Option_Trade.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

ExDividendInfo.cs

feat(bond): 支持债券与股票基金公司行为现金流计算的差异化处理 - init2

2026-08-19 17:48:34 +08:00

FinancialStatement.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

FinancialSummaryModel.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

FinancialSummaryOptionExportModel.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

FinancialVoucherGenerator.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

FlatPriceQuotation.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

GetClientMarginDetailReq.cs

TRS-ZS-566、TRS-ZS-568 客户保证金率需求完成

2025-07-18 17:44:58 +08:00

GJTradeComfirmModel.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

GlobalSkewMap.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

GroupAction.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

HedgeRiskMonitoringReq.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

HedgingMonitor.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

HedgingOrderCancelReq.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

HedgingOrderCancelResp.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

ImportResultModel.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

IntradayTradePosition.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

KafkaConfig.cs

feat: 新增TRS合约日终Kafka推送

2026-08-25 16:07:21 +08:00

margin_ratioReq.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

margin_template_v2Req.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

margin_templateReq.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

MatchRateRequest.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

Processlog.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

Processtradelog.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

PushLogQueryRequest.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

QouteFileQueryRequest.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

QuotaMonitor_UnderlyingModel.cs

客户设置互换天数&利息计算重置频率

2025-04-14 16:31:35 +08:00

QuotaMonitor.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

QuotaRule.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

QuotaTrial.cs

feat:根据ai merge意见修改：dbContext取消与单例riskEngienService的绑定，反射代码修改。

2026-07-14 17:18:33 +08:00

QuoteFileMJson.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

QuoteFileUpRequest.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

RealTimePositionRisks.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

RealtimeTradeRisk.cs

dv01全局去除

2024-06-12 10:28:49 +08:00

Result.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

RiskCheckReportItem.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

RiskCheckReportSumModel.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

RiskExposureModel.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

RiskLimit.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

RptContractNoGenRule.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

SalesDepartment.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

SaveGroupTradeCashReq.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

SaveSettlementEmailRequest.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

SealTask.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

SearchGroupActionChildrenListReq.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

SendEmailResult.cs

山证bug修复及功能 迁移

2024-06-04 18:19:49 +08:00

SendSwapEventEmailRequest.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

ServiceconfigView.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

SpreadOptionPayoff.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

StockBlackWhiteReq.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

StockCommissionConfig.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

Supervise_UndelryingReq.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

SuperviseClientCashReportModel.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

SuperviseReportReq.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

SwapCapitalAccountQueryRequest.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

SwapEndConfirmReq.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

SwapEventEmailRequest.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

SwapEventEmailResponse.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

SwapFloatRateSearchRequest.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

SwapFlowEventExportModel.cs

Revert "refactor(swap): 互换开平仓事件流水 导出小数点精度调整"

2026-07-28 14:30:03 +08:00

SwapFlowQueryRequest.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

SwapLongShortCloseModel.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

SwapMarginMonitorRequest.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

SwapMonitorConfig.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

SwapPayOffCalcRequest.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

SwapRateExportModel.cs

feat: 新增线下费率

2025-12-26 14:00:19 +08:00

SwapRateKafkaModel.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

SwapRateSearchRequest.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

SwapTradeContractDto.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

SwapTradeContractGroup.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

SwapTradePushModel.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

SwapTradeQuery.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

SwapTradeSendEmailReq.cs

TRS-ZS-183 一个客户一天所有开仓的多头交易都放到一个交易确认书里

2025-04-22 09:45:21 +08:00

SwapTradeSendEmailResp.cs

TRS-ZS-183 一个客户一天所有开仓的多头交易都放到一个交易确认书里

2025-04-22 09:45:21 +08:00

SwpFlowCombookingReq.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

SwpFlowResetReq.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

SyntheticUnderlying.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

Trade_Self.cs

refactor(Trade_Self): 优化互换交易编辑权限判断逻辑

2026-07-02 10:14:42 +08:00

Trade_StructureOption.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

trade_swap_flow_group.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

Trade.cs

fix: 收益率空处理

2025-10-15 15:08:37 +08:00

TradeAutoRule.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

TradeCash.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

TradeCashImportReq.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

TradeChangeList.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

TradeCheck.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

TradeClientCashCalcReq.cs

名义本金算价格

2025-04-11 16:25:46 +08:00

TradeClientCashCalcResp.cs

可用资金 从山证搬迁

2024-07-16 14:43:18 +08:00

TradeContractDocument.cs

OA用印自动同步，完善确认书来源标识

2026-04-16 15:12:39 +08:00

TradeContractR.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

TradeDetailsReport.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

TradeFlowCheckResultReq.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

TradeFlowCheckResultResponse.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

TradeFlowMoreReq.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

TradeFlowReq.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

TradeGroup.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

TradeLinq.cs

feat: 收益互换开平仓及收益结算接入OA移动审批

2026-08-21 15:54:54 +08:00

TradeMarginTemplate.cs

#EQD-6947 国联民生-保证金计算整体改造-实现第一版盯市规则（不支持同一客户多部门）（1）保证金规则的设置 阶段1,开放v2

2026-08-12 15:38:55 +08:00

TradeMarginTemplateReq.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

TradeOtherDocument.cs

OA用印自动同步，完善确认书来源标识

2026-04-16 15:12:39 +08:00

TradePositionMerge.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

tradeReq.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

TradeRiskCheckLogExportModel.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

TradeSpan.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

TradeWithSettlement.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

TradingRiskParameter.cs

BugFix 添加信用债的计算

2026-03-11 15:04:10 +08:00

TrsAccountManageRequest.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

TrsAccountManageSaveRequest.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

TrsOpenConfigDto.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

TrsRespone.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

TTableModel.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

Underlying_BasiscurveDot.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

Underlying_basisCurveLinq.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

Underlying_basiscurveReq.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

UnderlyingMainContract.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

UnderlyingMainContractViewModel.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

Underlyingmanager_self.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

Underlyingmanager.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

UnwindReportInputModel.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

ValuedateHistory.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

Variety.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

VarietyMappingDeductReq.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

VarietyVolAdjustModel.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00

Volatility.cs

从山证v2.3.0拷贝

2024-05-09 14:06:26 +08:00