Fixed some problems withnameconverter routine

This commit is contained in:
2022-09-10 18:03:48 +02:00
parent 36c28196f4
commit fbe2af871e
2 changed files with 36 additions and 15 deletions

View File

@ -65,22 +65,30 @@ public class FileToJson : IFileToJson
{ {
if (rec.Transaktionstyp == "KÖPT") if (rec.Transaktionstyp == "KÖPT")
{ {
var stockmember = new StockMember(); try
stockmember.StockId = NameConverter[rec.Beskrivning.Trim()]; {
stockmember.StockExtId = NameConverter[rec.Beskrivning.Trim()]; var stockmember = new StockMember();
stockmember.BuyValue = rec.Kurs; stockmember.StockId = NameConverter[rec.Beskrivning.Trim()];
stockmember.BuyDate = rec.Affärsdag; stockmember.StockExtId = NameConverter[rec.Beskrivning.Trim()];
stockmember.ActValue = rec.Kurs; stockmember.BuyValue = rec.Kurs;
stockmember.ActDate = rec.Affärsdag; stockmember.BuyDate = rec.Affärsdag;
stockmember.ActAmount = rec.Antal; stockmember.ActValue = rec.Kurs;
stockmember.SoldValue = 0; stockmember.ActDate = rec.Affärsdag;
stockmember.SoldDate = null; stockmember.ActAmount = rec.Antal;
stockmember.Comment = "from trans"; stockmember.SoldValue = 0;
stockmember.PostAmount = rec.Antal; stockmember.SoldDate = null;
stockmember.SoldStockPrice = 0; stockmember.Comment = "from trans";
stockmember.PostAmount = rec.Antal;
stockmember.SoldStockPrice = 0;
_dapperStocksProvider.AddStock(stockmember); _dapperStocksProvider.AddStock(stockmember);
skrivna++; skrivna++;
}
catch (Exception e)
{
_log.LogError(e.Message, e.StackTrace);
}
} }
} }

View File

@ -91,6 +91,12 @@ namespace LoadStockDbFromTrans.StocksProviders
SELECT * SELECT *
FROM StockNames"; FROM StockNames";
private const string WEB_STOCKNAMES_EXISTS = @"
SELECT CAST(
CASE WHEN EXISTS (
SELECT 1 FROM StockNames WHERE StockNameWeb = @StockNameWeb)
THEN 1 ELSE 0 END as BIT)";
private readonly SqliteDbConnectionFactory _sqliteDbConnectionFactory; private readonly SqliteDbConnectionFactory _sqliteDbConnectionFactory;
private readonly ILogger<DapperStocksProvider> _log; private readonly ILogger<DapperStocksProvider> _log;
@ -212,6 +218,13 @@ namespace LoadStockDbFromTrans.StocksProviders
using (IDbConnection database = _sqliteDbConnectionFactory.Connect()) using (IDbConnection database = _sqliteDbConnectionFactory.Connect())
{ {
var exists = await database.ExecuteScalarAsync<bool>(WEB_STOCKNAMES_EXISTS, new { StockNameWeb = stockNameWeb });
if (!exists)
{
await AddWebStockNames(stockNameWeb);
}
object parameters = new object parameters = new
{ {
StockNameBank = stockNameBank, StockNameBank = stockNameBank,