phares3757/mesareportingservices
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Used queries to get data from scrape database instead of FabTime to use a single data source.

Browse Source
This commit is contained in:
Daniel Wathen
2023-01-11 09:46:03 -07:00
parent cb14e93ad5
commit 43e5ec3e28
22 changed files with 1350 additions and 118 deletions
Download Patch File Download Diff File Expand all files Collapse all files

128
ReportingServices.Shared/Repositories/Implementations/ScrapeDatabaseRepository.cs
View File

@ -269,5 +269,133 @@ namespace ReportingServices.Shared.Repositories
return rdsList;
}
public List<ReactorOutsByRDS> GetRDSRunBetweenDates(string startDate, string endDate)
{
List<ReactorOutsByRDS> outs = new();
OpenConnection();
SqlCommand cmd = _connection.CreateCommand();
string query = "SELECT SEQ, WFRS_OUT, DATE_OUT " +
" FROM RDS " +
" WHERE DATE_OUT >= @startDate " +
" AND DATE_OUT < @endDate " +
"ORDER BY DATE_OUT ASC";
cmd.CommandText = query;
cmd.Parameters.AddWithValue("@startDate", startDate);
cmd.Parameters.AddWithValue("@endDate", endDate);
using (SqlDataReader reader = cmd.ExecuteReader())
{
while (reader.Read())
outs.Add(new ReactorOutsByRDS
{
RDS_NO = reader[0].ToString(),
Units = reader[1].ToString(),
EndProcessTime = reader[2].ToString()
});
}
cmd.Dispose();
CloseConnection();
return outs;
}
public List<ReactorEvent> GetReactorEvents(string startDate, string endDate, string reactorNumber)
{
List<ReactorEvent> events = new();
OpenConnection();
SqlCommand cmd = _connection.CreateCommand();
string query = "SELECT " +
" REACT_NO, " +
" EVENT_DTM, " +
" COMMENT, " +
" REACT_MODE " +
" FROM REACT_EVENT " +
" WHERE EVENT_DTM > @startDate " +
" AND EVENT_DTM < @endDate " +
" AND REACT_NO = @reactorNumber " +
"UNION ALL " +
"SELECT " +
" REACT_NO, " +
" EVENT_DTM, " +
" COMMENT, " +
" REACT_MODE " +
" FROM " +
" (SELECT TOP 1 * FROM REACT_EVENT " +
" WHERE EVENT_DTM < @startDate " +
" AND REACT_NO = @reactorNumber ORDER BY EVENT_DTM DESC) AS tbl1 " +
"ORDER BY EVENT_DTM ASC;";
cmd.CommandText = query;
cmd.Parameters.AddWithValue("@startDate", startDate);
cmd.Parameters.AddWithValue("@endDate", endDate);
cmd.Parameters.AddWithValue("@reactorNumber", reactorNumber);
using (SqlDataReader reader = cmd.ExecuteReader())
{
while (reader.Read())
events.Add(new ReactorEvent
{
REACT_NO = reader[0].ToString(),
EVENT_DTM = reader[1].ToString(),
COMMENT = reader[2].ToString(),
REACT_MODE = reader[3].ToString()
});
}
cmd.Dispose();
CloseConnection();
return events;
}
public ToolEvent GetLatestToolEvent(string toolID)
{
ToolEvent evnt = new();
OpenConnection();
SqlCommand cmd = _connection.CreateCommand();
string query = "SELECT TOP 1 " +
" TOOL_ID, " +
" START_DTM, " +
" TOOL_MODE, " +
" TOOL_MODE_DESC " +
" FROM TOOL_LOG " +
" WHERE TOOL_ID = @toolID " +
"ORDER BY START_DTM DESC;";
cmd.CommandText = query;
cmd.Parameters.AddWithValue("@toolID", toolID);
using (SqlDataReader reader = cmd.ExecuteReader())
{
while (reader.Read())
evnt = new ToolEvent
{
TOOL_ID = reader[0].ToString(),
START_DTM = reader[1].ToString(),
TOOL_MODE = reader[2].ToString(),
TOOL_MODE_DESC = reader[3].ToString()
};
}
cmd.Dispose();
CloseConnection();
return evnt;
}
}
}