xwl2023/Yi.Framework
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: 修复银行汇率问题

Browse Source
This commit is contained in:
chenchun
2024-06-26 12:46:39 +08:00
parent 5b109e91d1
commit b30662d2b4
4 changed files with 39 additions and 34 deletions
Download Patch File Download Diff File Expand all files Collapse all files

40
Yi.Abp.Net8/module/bbs/Yi.Framework.Bbs.Domain/Managers/BankManager.cs
View File

@@ -15,6 +15,7 @@ namespace Yi.Framework.Bbs.Domain.Managers
/// </summary>
public class BankManager : DomainService
{
private const decimal DefalutRate = 1.3m;
private ISqlSugarRepository<BankCardAggregateRoot> _repository;
private ILocalEventBus _localEventBus;
private ISqlSugarRepository<InterestRecordsAggregateRoot> _interestRepository;
@@ -24,7 +25,7 @@ namespace Yi.Framework.Bbs.Domain.Managers
_repository = repository;
_localEventBus = localEventBus;
_interestRepository = interestRepository;
_bankValueProvider=bankValueProvider;
_bankValueProvider = bankValueProvider;
}
/// <summary>
@@ -52,22 +53,17 @@ namespace Yi.Framework.Bbs.Domain.Managers
output.CreationTime = currentInterestRecords.CreationTime;
output.Value = currentInterestRecords.Value;
_currentRateStore=new BankInterestRecordDto() { ComparisonValue= currentInterestRecords .ComparisonValue,
CreationTime=currentInterestRecords.CreationTime,Value=currentInterestRecords.Value};
_currentRateStore = new BankInterestRecordDto()
{
ComparisonValue = currentInterestRecords.ComparisonValue,
CreationTime = currentInterestRecords.CreationTime,
Value = currentInterestRecords.Value
};
}
return output;
}
/// <summary>
/// 获取第三方的值
/// </summary>
/// <returns></returns>
private decimal GetThirdPartyValue()
{
return _bankValueProvider.GetValueAsync().Result;
}
/// <summary>
/// 强制创建一个记录，不管时间到没到
/// </summary>
@@ -76,22 +72,19 @@ namespace Yi.Framework.Bbs.Domain.Managers
{
//获取最新的实体
var lastEntity = await _interestRepository._DbQueryable.OrderByDescending(x => x.CreationTime).FirstAsync();
decimal oldValue = 1.3m;
//获取第三方的值
var thirdPartyValue = GetThirdPartyValue();
//获取上一次第三方标准值
var lastThirdPartyStandardValue = thirdPartyValue;
decimal oldValue = DefalutRate;
var thirdPartyValue = await _bankValueProvider.GetValueAsync();
//获取实际值的变化率
decimal changeRate = 0;
decimal changeRate = (thirdPartyValue - _bankValueProvider.StandardValue) / (thirdPartyValue);
//说明不是第一次
if (lastEntity is not null)
{
oldValue = lastEntity.Value;
changeRate = (thirdPartyValue - lastEntity.ComparisonValue) / (thirdPartyValue);
}
//判断市场是否波动
@@ -102,11 +95,10 @@ namespace Yi.Framework.Bbs.Domain.Managers
changeRate = 2 * changeRate;
}
//根据上一次的老值进行变化率比较
var currentValue = oldValue + (oldValue* changeRate);
var currentValue = oldValue + (oldValue * changeRate);
var entity = new InterestRecordsAggregateRoot(lastThirdPartyStandardValue, currentValue);
var entity = new InterestRecordsAggregateRoot(thirdPartyValue, currentValue);
var output = await _interestRepository.InsertReturnEntityAsync(entity);
return output;