Husky/dcnsanplanung
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Klassifizierungssystem hinzugefügt

Browse Source
This commit is contained in:
Damian Wessels
2023-09-13 12:56:39 +02:00
parent 49ab3598d7
commit bfa77de720
42 changed files with 886 additions and 112 deletions
Download Patch File Download Diff File Expand all files Collapse all files

38
dcnsanplanung.DAL/Services/PostgresqlData/SchadenDataService.cs
View File

@@ -22,7 +22,7 @@ namespace dcnsanplanung.DAL.Services.PostgresqlData
public async Task<IEnumerable<Schaden>> GetAllByHaltung(string haltungs_guid)
{
List<Schaden> result = new List<Schaden>();
string command = "SELECT * FROM " + tableName + " WHERE ref_haltung_guid = @1;";
string command = "SELECT * FROM " + tableName + " WHERE ref_haltung_guid = @1 ORDER BY id ASC;";
using (var cmd = new NpgsqlCommand(command, conn))
{
cmd.Parameters.AddWithValue("1", haltungs_guid);
@@ -52,16 +52,17 @@ namespace dcnsanplanung.DAL.Services.PostgresqlData
CH2 = reader.GetString(6),
Q1 = reader.GetString(7),
Q2 = reader.GetString(8),
KD = reader.GetDataTypeOID(9),
KB = reader.GetDataTypeOID(10),
KS = reader.GetDataTypeOID(11),
KD = reader.IsDBNull(9) ? 5 : reader.GetInt32(9),
KB = reader.IsDBNull(10) ? 5 : reader.GetInt32(10),
KS = reader.IsDBNull(11) ? 5 : reader.GetInt32(11),
StreckenschadenCode = reader.GetString(12)
};
}
public async Task<Schaden> Create(Schaden entity)
{
string command = "INSERT INTO " + tableName + " (guid, ref_haltung_guid, entfernung, hauptcode, ch1,ch2,q1,q2) VALUES " +
"(@1,@2,@3,@4,@5,@6,@7,@8) RETURNING id";
string command = "INSERT INTO " + tableName + " (guid, ref_haltung_guid, entfernung, hauptcode, ch1,ch2,q1,q2,streckenschaden) VALUES " +
"(@1,@2,@3,@4,@5,@6,@7,@8,@9) RETURNING id";
using(var cmd = new NpgsqlCommand(command,conn))
{
cmd.Parameters.AddWithValue("1", entity.Guid.ToString());
@@ -72,6 +73,7 @@ namespace dcnsanplanung.DAL.Services.PostgresqlData
cmd.Parameters.AddWithValue("6", entity.CH2);
cmd.Parameters.AddWithValue("7", entity.Q1);
cmd.Parameters.AddWithValue("8", entity.Q2);
cmd.Parameters.AddWithValue("9", entity.StreckenschadenCode);
//cmd.Parameters.AddWithValue("5", NpgsqlTypes.NpgsqlDbType.Oid, entity.Schadensklasse);
using var reader = await cmd.ExecuteReaderAsync();
reader.Read();
@@ -80,6 +82,21 @@ namespace dcnsanplanung.DAL.Services.PostgresqlData
return entity;
}
public async Task<Schaden> Update(Schaden entity)
{
string command = @"UPDATE " + tableName + " SET kd=@1, kb=@2, ks=@3 WHERE id=@4";
using (var cmd = new NpgsqlCommand(command, conn))
{
cmd.Parameters.AddWithValue("1", entity.KD);
cmd.Parameters.AddWithValue("2", entity.KB);
cmd.Parameters.AddWithValue("3", entity.KS);
cmd.Parameters.AddWithValue("4", entity.ID);
await cmd.ExecuteNonQueryAsync();
}
return entity;
}
public async Task<bool> InsertSchadenBulk(List<Schaden> schaden)
{
foreach(var item in schaden)
@@ -88,5 +105,14 @@ namespace dcnsanplanung.DAL.Services.PostgresqlData
}
return true;
}
public async Task<bool> UpdateSchadenBuld(List<Schaden> schaden)
{
foreach(var item in schaden)
{
await Update(item);
}
return true;
}
}
}