bug 修复

2025-04-23 15:03:29 +08:00
parent b22c4d3e0e
commit 56092011ef
4 changed files with 5 additions and 23 deletions
@@ -37,11 +37,7 @@ namespace YLErp.Modules.SwapModule
        {
            _kafkaConsumer.Subscribe(msg =>
            {
-                var hedgingSource = OtcAppConfigHelper.HedgingSource==1|| OtcAppConfigHelper.HedgingSource==0;
-                if (hedgingSource)
-                {
-                    return;
-                }
+                LogFactory.GetLogger("SwapConsumerService").Info("TRS对冲交易回执接口:"+ msg);
                if (!string.IsNullOrEmpty(msg))
                {
                    var result = JsonHelper.Deserialize<SwapAsset>(msg);