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

Compare commits

base: phares3757:12-11-a
Branches Tags
phares3757:master phares3757:12-11-c phares3757:12-11-a
..
compare: phares3757:12-11-c
Branches Tags
phares3757:12-11-c phares3757:12-11-a phares3757:master

1 Commits
12-11-a ... 12-11-c

Author SHA1 Message Date
phares@iscn5cg20977xq
c401562813 Add joins for ReactorMode and Description in Job class query for enhanced data retrieval 2025-12-11 15:28:55 -07:00
1 changed files with 13 additions and 5 deletions
Expand all files Collapse all files

18
Adaptation/FileHandlers/TIBCO/Transport/Job.cs
View File

@ -113,10 +113,12 @@ public partial class Job
int? runCount; int? runCount;
string commandText = GetCommandText(commonB, jobNames); string commandText = GetCommandText(commonB, jobNames);
try try
{ runCount = GetScalar(iqsSQLConnectionString, commandText); } {
runCount = GetScalar(iqsSQLConnectionString, commandText);
basicType = runCount is null ? "1" : (runCount + 1).ToString();
}
catch (Exception) catch (Exception)
{ runCount = null; } { basicType = hyphen; }
basicType = runCount is null ? hyphen : (runCount + 1).ToString();
} }
Qty = "1"; Qty = "1";
CreationUser = hyphen; // ? CreationUser = hyphen; // ?
@ -828,10 +830,16 @@ public partial class Job
results.Add(" on se.f_part = pd.f_part "); results.Add(" on se.f_part = pd.f_part ");
results.Add(" join [spcepiworld].[dbo].[test_dat] td "); results.Add(" join [spcepiworld].[dbo].[test_dat] td ");
results.Add(" on se.f_test = td.f_test "); results.Add(" on se.f_test = td.f_test ");
results.Add(" join [spcepiworld].[dbo].[sgrp_dsc] sd ");
results.Add(" on se.f_sgrp = sd.f_sgrp ");
results.Add(" join [spcepiworld].[dbo].[desc_dat] ds ");
results.Add(" on sd.f_desc = ds.f_desc ");
results.Add(" where se.f_flag = 0 "); results.Add(" where se.f_flag = 0 ");
results.Add($" and pl.f_name = '{commonB.RDSNumber}' "); results.Add(" and sd.f_dsgp = 1765472498 /* Reactor Mode */ ");
results.Add($" and pr.f_name = '{commonB.ReactorNumber}' ");
results.Add($" and pd.f_name = '{commonB.PSN}' "); results.Add($" and pd.f_name = '{commonB.PSN}' ");
results.Add($" and pl.f_name = '{commonB.RDSNumber}' ");
results.Add($" and ds.f_name = '{commonB.ReactorMode}' ");
results.Add($" and pr.f_name = '{commonB.ReactorNumber}' ");
results.Add($" and jd.f_name in ({jobNames}) "); results.Add($" and jd.f_name in ({jobNames}) ");
results.Add(" group by se.f_sgrp "); results.Add(" group by se.f_sgrp ");
results.Add(" , se.f_sgtm "); results.Add(" , se.f_sgtm ");