tfoman/StockTransToDB
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Developed routine for new Stock registration

Browse Source
This commit is contained in:
Tommy Öman
2022-10-11 23:05:02 +02:00
parent 40c9027d77
commit e259d2c6eb
4 changed files with 41 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
StockTransToDB/Runners/FileToJson.cs
View File

@ -176,32 +176,34 @@ namespace StockTransToDB.Runners
private async Task PrepareNameConverter(List<FileModel> recList)
{
var tempListNew = new HashSet<string>();
await _dapperStocksProvider.CleanStockNames();
// Tar bort denna rensning, dumt att ta bort redan tillgängliga översättningar
// await _dapperStocksProvider.CleanStockNames();
foreach (var rec in recList)
{
if (rec.Transaktionstyp == ProcName.KOPT)
{
try
var stockName = await _dapperStocksProvider.GetBankStockName(rec.Beskrivning);
if (string.IsNullOrEmpty(stockName))
{
tempListNew.Add(rec.Beskrivning);
}
catch (Exception)
{
_log.LogInformation($"Dublett : {rec.Beskrivning}");
}
}
}
var templist = await _dapperStocksProvider.GetStockNames();
foreach (var webName in templist)
{
_log.LogInformation($"Upplägg : {webName}, --");
await _dapperStocksProvider.AddWebStockNames(webName);
}
//var templist = await _dapperStocksProvider.GetStockNames();
//foreach (var webName in templist)
//{
// _log.LogInformation($"Upplägg : {webName}, --");
// await _dapperStocksProvider.AddWebStockNames(webName);
//}
foreach (var newName in tempListNew)
{
_log.LogInformation($"Upplägg : {newName}, --");
await _dapperStocksProvider.AddWebStockNames(newName);
//var founds = templist.Where(t => t.StartsWith(newName.Substring(0, 3))).ToList();
var founds = await _dapperStocksProvider.GetStockNamesByPart(newName.Substring(0, 3));
if (founds.Any())

26
StockTransToDB/StocksProviders/DapperStocksProvider.cs
View File

@ -94,8 +94,8 @@ namespace StockTransToDB.StocksProviders
private const string UPDATE_STOCKNAME_BANK = @"
UPDATE StockNames
SET StockNameBank = @StockNameBank
WHERE StockNameWeb = @StockNameWeb";
SET StockNameWeb = @StockNameWeb
WHERE StockNameBank = @StockNameBank";
private const string GET_WEB_STOCKNAM_FULL = @"
SELECT *
@ -121,6 +121,9 @@ namespace StockTransToDB.StocksProviders
set Comment = substring(Comment,4)
where Substring(Comment,1,Length(@RunId))=@RunId";
private const string STOCKNAMES_BY_BANKNAME = @"
select StockNameWeb, StockNameBank from StockNames
where StockNameBank = @BankStockName";
private readonly SqliteDbConnectionFactory _sqliteDbConnectionFactory;
@ -319,6 +322,25 @@ namespace StockTransToDB.StocksProviders
}
}
public async Task<string> GetBankStockName(string bankStockName)
{
var stockNameBank = "";
using(IDbConnection database = _sqliteDbConnectionFactory.Connect())
{
_log.LogInformation("STOCKNAMES_BY_BANK");
var stockNames = await database.QueryAsync<StockNames>(STOCKNAMES_BY_BANKNAME, new { BankStockName = bankStockName });
if (stockNames.Count() > 0)
{
stockNameBank = stockNames.ToList()[0].StockNameBank;
}
return stockNameBank;
}
}
//RESET_STOCK_COMMENTS
public async Task ResetCommentsFromNew()
{

1
StockTransToDB/StocksProviders/IDapperStocksProvider.cs
View File

@ -8,6 +8,7 @@ namespace StockTransToDB.StocksProviders
Task AddWebStockNames(string stockName);
Task CleanStockNames();
Task<IEnumerable<StockMember>> GetAllStocks();
Task<string> GetBankStockName(string bankStockName);
Task<IEnumerable<string>> GetStockNames();
Task<List<string>> GetStockNamesByPart(string idPart);
Task<IEnumerable<StockNames>> GetStockNameTable();

4
StockTransToDB/appsettings.json
View File

@ -1,6 +1,6 @@
{
"TransFile": "Skandiabanken_transaktioner_insatsen.xls",
"StdFileName": "StockData2022-10-10.txt",
"TransFile": "Skandiabanken_transaktioner_vinsthant.xls",
//"StdFileName": "StockData2022-10-10.txt",
"Serilog": {
"MinimumLevel": {
"Default": "Information",