491 lines
25 KiB
C#
491 lines
25 KiB
C#
using Adaptation.Shared;
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using System.Data;
|
|
using System.Data.SqlClient;
|
|
using System.Globalization;
|
|
using System.IO;
|
|
using System.Linq;
|
|
using System.Text;
|
|
using System.Text.Json;
|
|
using System.Threading;
|
|
|
|
namespace Adaptation.FileHandlers.OpenInsight;
|
|
|
|
public class FromIQS
|
|
{
|
|
|
|
#nullable enable
|
|
|
|
private static string GetCommandText(DateTime dateTime)
|
|
{ // cSpell:disable
|
|
List<string> results = new();
|
|
TimeSpan timeSpan = new(dateTime.ToUniversalTime().AddDays(-1).Ticks - new DateTime(1970, 01, 01).Ticks);
|
|
long infinityQS = (long)Math.Floor(timeSpan.TotalSeconds);
|
|
results.Add(" select count_se_sgtm CountSeSgtm, ");
|
|
results.Add(" dateadd(HH, -7, (dateadd(SS, convert(bigint, max_se_sgtm), '19700101'))) DateTime, ");
|
|
results.Add(" max_max_se_test MaxMaxSeTest, ");
|
|
results.Add(" ( ");
|
|
results.Add(" select td.f_name ");
|
|
results.Add(" from [SPCEPIWORLD].[dbo].[TEST_DAT] td ");
|
|
results.Add(" where td.f_test = max_max_se_test ");
|
|
results.Add(" ) MaxMaxSeTestName, ");
|
|
results.Add(" max_max_se_val MaxMaxSeVal, ");
|
|
results.Add(" max_se_lot MaxSeLot, ");
|
|
results.Add(" ( ");
|
|
results.Add(" select pl.f_name ");
|
|
results.Add(" from [SPCEPIWORLD].[dbo].[PART_LOT] pl ");
|
|
results.Add(" where max_se_lot = pl.f_lot ");
|
|
results.Add(" ) MaxSeLotName, ");
|
|
results.Add(" max_se_part MaxSePart, ");
|
|
results.Add(" ( ");
|
|
results.Add(" select rd.f_name ");
|
|
results.Add(" from [SPCEPIWORLD].[dbo].[PART_DAT] rd ");
|
|
results.Add(" where max_se_part = rd.f_part ");
|
|
results.Add(" ) MaxSePartName, ");
|
|
results.Add(" max_se_prcs MaxSePrcs, ");
|
|
results.Add(" ( ");
|
|
results.Add(" select rd.f_name ");
|
|
results.Add(" from [SPCEPIWORLD].[dbo].[PRCS_DAT] rd ");
|
|
results.Add(" where max_se_prcs = rd.f_prcs ");
|
|
results.Add(" ) MaxSePrcsName, ");
|
|
results.Add(" max_se_sgrp MaxSeSgrp, ");
|
|
results.Add(" min_min_se_test MinMinSeTest, ");
|
|
results.Add(" ( ");
|
|
results.Add(" select td.f_name ");
|
|
results.Add(" from [SPCEPIWORLD].[dbo].[TEST_DAT] td ");
|
|
results.Add(" where td.f_test = min_min_se_test ");
|
|
results.Add(" ) MinMinSeTestName, ");
|
|
results.Add(" min_min_se_val MinMinSeVal, ");
|
|
results.Add(" min_se_sgrp MinSeSgrp ");
|
|
results.Add(" from ( ");
|
|
results.Add(" select count_se_sgtm, ");
|
|
results.Add(" max_se_lot, ");
|
|
results.Add(" max_se_part, ");
|
|
results.Add(" max_se_prcs, ");
|
|
results.Add(" max_se_sgrp, ");
|
|
results.Add(" max_se_sgtm, ");
|
|
results.Add(" min_se_sgrp, ");
|
|
results.Add(" max(max_se_val) max_max_se_val, ");
|
|
results.Add(" min(min_se_val) min_min_se_val, ");
|
|
results.Add(" max(max_se_test) max_max_se_test, ");
|
|
results.Add(" min(min_se_test) min_min_se_test ");
|
|
results.Add(" from ( ");
|
|
results.Add(" select count_se_sgtm, ");
|
|
results.Add(" max_se_lot, ");
|
|
results.Add(" max_se_val, ");
|
|
results.Add(" min_se_val, ");
|
|
results.Add(" max_se_part, ");
|
|
results.Add(" max_se_prcs, ");
|
|
results.Add(" max_se_sgrp, ");
|
|
results.Add(" max_se_sgtm, ");
|
|
results.Add(" max_se_test, ");
|
|
results.Add(" min_se_sgrp, ");
|
|
results.Add(" min_se_test ");
|
|
results.Add(" from ( ");
|
|
results.Add(" select ");
|
|
results.Add(" max(se.f_lot) max_se_lot, ");
|
|
results.Add(" max(se.f_val) max_se_val, ");
|
|
results.Add(" min(se.f_lot) min_se_lot, ");
|
|
results.Add(" min(se.f_val) min_se_val, ");
|
|
results.Add(" max(se.f_part) max_se_part, ");
|
|
results.Add(" max(se.f_prcs) max_se_prcs, ");
|
|
results.Add(" max(se.f_sgrp) max_se_sgrp, ");
|
|
results.Add(" max(se.f_sgtm) max_se_sgtm, ");
|
|
results.Add(" max(se.f_test) max_se_test, ");
|
|
results.Add(" min(se.f_part) min_se_part, ");
|
|
results.Add(" min(se.f_prcs) min_se_prcs, ");
|
|
results.Add(" min(se.f_sgrp) min_se_sgrp, ");
|
|
results.Add(" min(se.f_sgtm) min_se_sgtm, ");
|
|
results.Add(" min(se.f_test) min_se_test, ");
|
|
results.Add(" count(se.f_sgtm) count_se_sgtm ");
|
|
results.Add(" from [spcepiworld].[dbo].[sgrp_ext] se ");
|
|
results.Add(" where se.f_tsno = 1 ");
|
|
results.Add(" and se.f_flag = 0 ");
|
|
results.Add($" and se.f_sgtm > {infinityQS} ");
|
|
results.Add(" group by se.f_sgtm, se.f_prcs, se.f_lot, se.f_test, se.f_val ");
|
|
results.Add(" ) qa ");
|
|
results.Add(" where qa.count_se_sgtm > 1 ");
|
|
results.Add(" and min_se_lot = max_se_lot ");
|
|
results.Add(" and min_se_val = max_se_val ");
|
|
results.Add(" and min_se_val = max_se_val ");
|
|
results.Add(" and min_se_part = max_se_part ");
|
|
results.Add(" and min_se_prcs = max_se_prcs ");
|
|
results.Add(" and min_se_sgtm = max_se_sgtm ");
|
|
results.Add(" and min_se_test = max_se_test ");
|
|
results.Add(" ) qb ");
|
|
results.Add(" group by count_se_sgtm, ");
|
|
results.Add(" max_se_lot, ");
|
|
results.Add(" max_se_part, ");
|
|
results.Add(" max_se_prcs, ");
|
|
results.Add(" max_se_sgrp, ");
|
|
results.Add(" max_se_sgtm, ");
|
|
results.Add(" min_se_sgrp ");
|
|
results.Add(" ");
|
|
results.Add(" ) qc ");
|
|
results.Add(" order by max_se_sgrp desc ");
|
|
results.Add(" for json path ");
|
|
return string.Join(Environment.NewLine, results);
|
|
} // cSpell:restore
|
|
|
|
private static string GetCommandText(Logistics logistics, SECS.Description description, string dateTime, long? subGroupId)
|
|
{ // cSpell:disable
|
|
List<string> results = new();
|
|
results.Add(" select iq.ev_count, iq.cl_count, iq.sl_count, iq.se_sgrp, iq.se_sgtm, iq.se_tsno, iq.td_test, iq.pr_name, iq.jd_name, iq.pl_name, iq.pd_name, iq.td_name, iq.se_val ");
|
|
results.Add(" from ( ");
|
|
results.Add(" select ");
|
|
results.Add(" se.f_sgrp se_sgrp, ");
|
|
results.Add(" se.f_sgtm se_sgtm, ");
|
|
results.Add(" se.f_tsno se_tsno, ");
|
|
results.Add(" se.f_val se_val, ");
|
|
results.Add(" pr.f_name pr_name, ");
|
|
results.Add(" jd.f_name jd_name, ");
|
|
results.Add(" pl.f_name pl_name, ");
|
|
results.Add(" pd.f_name pd_name, ");
|
|
results.Add(" td.f_test td_test, ");
|
|
results.Add(" td.f_name td_name, ");
|
|
results.Add(" (select count(cl.f_part) ");
|
|
results.Add(" from [spcepiworld].[dbo].[ctrl_lim] cl ");
|
|
results.Add(" where cl.f_part = pd.f_part ");
|
|
results.Add(" and cl.f_test = td.f_test ");
|
|
results.Add(" ) cl_count, ");
|
|
results.Add(" (select count(sl.f_part) ");
|
|
results.Add(" from [spcepiworld].[dbo].[spec_lim] sl ");
|
|
results.Add(" where sl.f_part = pd.f_part ");
|
|
results.Add(" and sl.f_test = td.f_test ");
|
|
results.Add(" ) sl_count, ");
|
|
results.Add(" (select count(ev.f_evnt) ");
|
|
results.Add(" from [spcepiworld].[dbo].[evnt_inf] ev ");
|
|
results.Add(" where ev.f_prcs = pr.f_prcs ");
|
|
results.Add(" and ev.f_part = pd.f_part ");
|
|
results.Add(" and ev.f_sgtm = se.f_sgtm ");
|
|
results.Add(" ) ev_count ");
|
|
results.Add(" from [spcepiworld].[dbo].[sgrp_ext] se ");
|
|
results.Add(" join [spcepiworld].[dbo].[prcs_dat] pr ");
|
|
results.Add(" on se.f_prcs = pr.f_prcs ");
|
|
results.Add(" join [spcepiworld].[dbo].[job_dat] jd ");
|
|
results.Add(" on se.f_job = jd.f_job ");
|
|
results.Add(" join [spcepiworld].[dbo].[part_lot] pl ");
|
|
results.Add(" on se.f_lot = pl.f_lot ");
|
|
results.Add(" join [spcepiworld].[dbo].[part_dat] pd ");
|
|
results.Add(" on se.f_part = pd.f_part ");
|
|
results.Add(" join [spcepiworld].[dbo].[test_dat] td ");
|
|
results.Add(" on se.f_test = td.f_test ");
|
|
results.Add(" where se.f_flag = 0 ");
|
|
if (subGroupId is not null)
|
|
results.Add($" and se.f_sgrp = {subGroupId} ");
|
|
if (!string.IsNullOrEmpty(description.RDS))
|
|
results.Add($" and pl.f_name = '{description.RDS}' ");
|
|
results.Add($" and pr.f_name = '{description.Reactor}' ");
|
|
results.Add($" and pd.f_name = '{description.PSN}' ");
|
|
results.Add(" and jd.f_name in ('SPV01') ");
|
|
results.Add($" and jd.f_name = '{logistics.MesEntity}' ");
|
|
results.Add($" and dateadd(HH, -7, (dateadd(SS, convert(bigint, se.f_sgtm), '19700101'))) = '{dateTime}' ");
|
|
results.Add(" ) as iq ");
|
|
results.Add(" order by iq.ev_count desc, iq.cl_count desc, iq.sl_count desc, iq.se_sgrp, iq.se_tsno, iq.td_test ");
|
|
results.Add(" for json path ");
|
|
return string.Join(Environment.NewLine, results);
|
|
} // cSpell:restore
|
|
|
|
private static StringBuilder GetForJsonPath(string connectionString, string commandText)
|
|
{
|
|
StringBuilder stringBuilder = new();
|
|
using SqlConnection sqlConnection = new(connectionString);
|
|
sqlConnection.Open();
|
|
using SqlCommand sqlCommand = new(commandText, sqlConnection);
|
|
SqlDataReader sqlDataReader = sqlCommand.ExecuteReader(CommandBehavior.SequentialAccess);
|
|
while (sqlDataReader.Read())
|
|
_ = stringBuilder.Append(sqlDataReader.GetString(0));
|
|
return stringBuilder;
|
|
}
|
|
|
|
private static string GetCommandText(List<long> subGroups)
|
|
{ // cSpell:disable
|
|
List<string> results = new();
|
|
results.Add(" update [spcepiworld].[dbo].[sgrp_ext] ");
|
|
results.Add(" set f_flag = 1 ");
|
|
results.Add(" where f_flag = 0 ");
|
|
results.Add($" and f_sgrp in ({string.Join($",{Environment.NewLine} ", subGroups)}) ");
|
|
return string.Join(Environment.NewLine, results);
|
|
} // cSpell:enable
|
|
|
|
private static int? ExecuteNonQuery(string connectionString, string commandText)
|
|
{
|
|
int? result;
|
|
if (string.IsNullOrEmpty(connectionString))
|
|
result = null;
|
|
else
|
|
{
|
|
using SqlConnection sqlConnection = new(connectionString);
|
|
sqlConnection.Open();
|
|
using SqlCommand sqlCommand = new(commandText, sqlConnection);
|
|
result = sqlCommand.ExecuteNonQuery();
|
|
}
|
|
return result;
|
|
}
|
|
|
|
private static void FlagDuplicates(string connectionString, string json)
|
|
{
|
|
JsonElement[]? jsonElements = JsonSerializer.Deserialize<JsonElement[]>(json);
|
|
JsonSerializerOptions jsonSerializerOptions = new() { PropertyNameCaseInsensitive = true };
|
|
if (jsonElements is not null && jsonElements.Length != 0 && jsonElements[0].ValueKind == JsonValueKind.Object)
|
|
{
|
|
Root? root;
|
|
List<long> collection = new();
|
|
JsonElement[] array = jsonElements.ToArray();
|
|
foreach (JsonElement jsonElement in array)
|
|
{
|
|
root = JsonSerializer.Deserialize<Root>(jsonElement.ToString(), jsonSerializerOptions);
|
|
if (root is null || root.MaxSeSgrp < 1)
|
|
continue;
|
|
if (collection.Count > 99)
|
|
break;
|
|
collection.Add(root.MaxSeSgrp);
|
|
}
|
|
if (collection.Count > 0)
|
|
{
|
|
try
|
|
{
|
|
string commandText = GetCommandText(collection);
|
|
File.WriteAllText("D:/.sql", commandText);
|
|
_ = ExecuteNonQuery(connectionString, commandText);
|
|
}
|
|
catch (Exception)
|
|
{ }
|
|
}
|
|
}
|
|
}
|
|
|
|
internal static (long?, int?, string) GetCommandText(string connectionString, Logistics logistics, SECS.Description description, long breakAfter, long preWait)
|
|
{
|
|
DateTime dateTime;
|
|
int? count = null;
|
|
string commandText;
|
|
long? result = null;
|
|
StringBuilder stringBuilder;
|
|
string dateFormat = SECS.Description.GetDateFormat();
|
|
if (DateTime.TryParseExact(description.Date, dateFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out DateTime dateTimeParsed))
|
|
dateTime = dateTimeParsed.ToLocalTime();
|
|
else if (DateTime.TryParse(description.Date, CultureInfo.InvariantCulture, DateTimeStyles.None, out dateTimeParsed))
|
|
dateTime = dateTimeParsed.ToLocalTime();
|
|
else
|
|
dateTime = logistics.DateTimeFromSequence;
|
|
commandText = GetCommandText(dateTime);
|
|
stringBuilder = GetForJsonPath(connectionString, commandText);
|
|
if (stringBuilder.Length > 0)
|
|
FlagDuplicates(connectionString, stringBuilder.ToString());
|
|
commandText = GetCommandText(logistics, description, dateTime.ToString("yyyy-MM-dd HH:mm:ss"), subGroupId: null);
|
|
for (short i = 0; i < short.MaxValue; i++)
|
|
{
|
|
if (DateTime.Now.Ticks > preWait)
|
|
break;
|
|
Thread.Sleep(100);
|
|
}
|
|
for (short z = 0; z < short.MaxValue; z++)
|
|
{
|
|
stringBuilder = GetForJsonPath(connectionString, commandText);
|
|
if (stringBuilder.Length > 0)
|
|
{
|
|
long postBreakAfter = DateTime.Now.AddSeconds(5).Ticks;
|
|
for (short y = 0; y < short.MaxValue; y++)
|
|
{
|
|
if (DateTime.Now.Ticks > postBreakAfter)
|
|
break;
|
|
Thread.Sleep(250);
|
|
}
|
|
stringBuilder = GetForJsonPath(connectionString, commandText);
|
|
break;
|
|
}
|
|
if (DateTime.Now.Ticks > breakAfter)
|
|
// throw new Exception($"After {breakAfterSeconds} seconds, didn't find sub group id!");
|
|
break;
|
|
Thread.Sleep(250);
|
|
}
|
|
if (stringBuilder.Length == 0)
|
|
commandText = stringBuilder.ToString();
|
|
else
|
|
{
|
|
JsonElement[]? jsonElements = JsonSerializer.Deserialize<JsonElement[]>(stringBuilder.ToString());
|
|
if (jsonElements is null || jsonElements.Length == 0 || jsonElements[0].ValueKind != JsonValueKind.Object)
|
|
commandText = stringBuilder.ToString();
|
|
else
|
|
{
|
|
JsonProperty[] jsonProperties = jsonElements[0].EnumerateObject().ToArray();
|
|
if (jsonProperties.Length == 0 || jsonProperties[3].Name != "se_sgrp" || !long.TryParse(jsonProperties[3].Value.ToString(), out long subGroupId))
|
|
commandText = stringBuilder.ToString();
|
|
else
|
|
{
|
|
result = subGroupId;
|
|
if (jsonProperties.Length != 0 && jsonProperties[0].Name == "ev_count" && int.TryParse(jsonProperties[0].Value.ToString(), out int evCount))
|
|
count = evCount;
|
|
}
|
|
}
|
|
}
|
|
return new(result, count, commandText);
|
|
}
|
|
|
|
private static string GetJson(Logistics logistics, ProcessDataStandardFormat processDataStandardFormat, SECS.Description description)
|
|
{
|
|
string result;
|
|
StringBuilder stringBuilder = new();
|
|
var @object = new
|
|
{
|
|
description.MesEntity,
|
|
description.Employee,
|
|
// description.Layer,
|
|
description.PSN,
|
|
description.RDS,
|
|
description.Reactor,
|
|
description.Recipe,
|
|
// description.Zone,
|
|
logistics.DateTimeFromSequence.Ticks
|
|
};
|
|
string[] pair;
|
|
string safeValue;
|
|
string[] segments;
|
|
string serializerValue;
|
|
foreach (string line in processDataStandardFormat.Logistics)
|
|
{
|
|
segments = line.Split('\t');
|
|
if (segments.Length < 2)
|
|
continue;
|
|
segments = segments[1].Split(';');
|
|
_ = stringBuilder.Append('{');
|
|
foreach (string segment in segments)
|
|
{
|
|
pair = segment.Split('=');
|
|
if (pair.Length != 2 || pair[0].Length < 3)
|
|
continue;
|
|
serializerValue = JsonSerializer.Serialize(pair[1]);
|
|
safeValue = serializerValue.Substring(1, serializerValue.Length - 2);
|
|
_ = stringBuilder.Append('"').Append(pair[0].Substring(2)).Append('"').Append(':').Append('"').Append(safeValue).Append('"').Append(',');
|
|
}
|
|
if (stringBuilder.Length > 0)
|
|
_ = stringBuilder.Remove(stringBuilder.Length - 1, 1);
|
|
_ = stringBuilder.Append('}').Append(',');
|
|
}
|
|
if (stringBuilder.Length > 0)
|
|
_ = stringBuilder.Remove(stringBuilder.Length - 1, 1);
|
|
_ = stringBuilder.Append(']').Append('}');
|
|
_ = stringBuilder.Insert(0, ",\"Logistics\":[");
|
|
string json = JsonSerializer.Serialize(@object);
|
|
_ = stringBuilder.Insert(0, json.Substring(0, json.Length - 1));
|
|
JsonElement? jsonElement = JsonSerializer.Deserialize<JsonElement>(stringBuilder.ToString());
|
|
result = jsonElement is null ? "{}" : JsonSerializer.Serialize(jsonElement, new JsonSerializerOptions { WriteIndented = true });
|
|
return result;
|
|
}
|
|
|
|
internal static void Save(string openInsightApiECDirectory, Logistics logistics, string reportFullPath, ProcessDataStandardFormat processDataStandardFormat, SECS.Description description, long? subGroupId, string weekOfYear)
|
|
{
|
|
string checkFile;
|
|
string fileName = Path.GetFileName(reportFullPath);
|
|
string json = GetJson(logistics, processDataStandardFormat, description);
|
|
string? ecPathRoot = Path.GetPathRoot(openInsightApiECDirectory);
|
|
bool ecExists = ecPathRoot is not null && Directory.Exists(ecPathRoot);
|
|
string weekYear = $"{logistics.DateTimeFromSequence:yyyy}_Week_{weekOfYear}";
|
|
string ecDirectory = Path.Combine(openInsightApiECDirectory, weekYear, $"-{description.PSN}", $"-{description.Reactor}", $"-{description.RDS}", $"-{subGroupId}");
|
|
if (ecExists && !Directory.Exists(ecDirectory))
|
|
_ = Directory.CreateDirectory(ecDirectory);
|
|
checkFile = Path.Combine(ecDirectory, fileName);
|
|
if (ecExists && !File.Exists(checkFile))
|
|
File.Copy(reportFullPath, checkFile);
|
|
checkFile = Path.Combine(ecDirectory, $"{logistics.DateTimeFromSequence.Ticks}.json");
|
|
if (ecExists && !File.Exists(checkFile))
|
|
File.WriteAllText(checkFile, json);
|
|
}
|
|
|
|
private static string GetCommandText(string[] iqsCopyValues)
|
|
{ // cSpell:disable
|
|
List<string> results = new();
|
|
if (iqsCopyValues.Length != 4)
|
|
throw new NotSupportedException();
|
|
string find = iqsCopyValues[1];
|
|
string replace = iqsCopyValues[3];
|
|
results.Add(" select pd.f_name [Part Name], ");
|
|
results.Add(" null [Part Revision], ");
|
|
results.Add($" '{replace}' [Test Name], ");
|
|
results.Add(" null [Description], ");
|
|
results.Add(" null [Lot Number], ");
|
|
results.Add(" null [Job Name], ");
|
|
results.Add(" null [Process Name], ");
|
|
results.Add(" case when sl.f_url = 0 then null else sl.f_url end [Reasonable Limit (Upper)], ");
|
|
results.Add(" case when sl.f_url = 0 then 0 else 1 end [Alarm Reasonable Limit (Upper)], ");
|
|
results.Add(" case when sl.f_usl = 0 then null else sl.f_usl end [Specification Limit (Upper)], ");
|
|
results.Add(" case when sl.f_usl = 0 then 0 else 1 end [Alarm Specification Limit (Upper)], ");
|
|
results.Add(" case when sl.f_ugb = 0 then null else sl.f_ugb end [Warning Limit (Upper)], ");
|
|
results.Add(" case when sl.f_ugb = 0 then 0 else 1 end [Alarm Warning Limit (Upper)], ");
|
|
results.Add(" case when sl.f_tar = 0 then null else sl.f_tar end [Specification Limit (Target)], ");
|
|
results.Add(" case when sl.f_lgb = 0 then null else sl.f_lgb end [Warning Limit (Lower)], ");
|
|
results.Add(" case when sl.f_lgb = 0 then 0 else 1 end [Alarm Warning Limit (Lower)], ");
|
|
results.Add(" case when sl.f_lsl = 0 then null else sl.f_lsl end [Specification Limit (Lower)], ");
|
|
results.Add(" case when sl.f_lsl = 0 then 0 else 1 end [Alarm Specification Limit (Lower)], ");
|
|
results.Add(" case when sl.f_lrl = 0 then null else sl.f_lrl end [Reasonable Limit (Lower)], ");
|
|
results.Add(" case when sl.f_lrl = 0 then 0 else 1 end [Alarm Reasonable Limit (Lower)], ");
|
|
results.Add(" td.f_name [Original Test Name], ");
|
|
results.Add(" td.f_test [Test Id], ");
|
|
results.Add(" ( ");
|
|
results.Add(" select count(sl_b.f_spec) ");
|
|
results.Add(" from [spcepiworld].[dbo].[spec_lim] sl_b ");
|
|
results.Add(" join [spcepiworld].[dbo].[part_dat] pd_b ");
|
|
results.Add(" on sl_b.f_part = pd_b.f_part ");
|
|
results.Add(" join [spcepiworld].[dbo].[test_dat] td_b ");
|
|
results.Add(" on sl_b.f_test = td_b.f_test ");
|
|
results.Add(" where sl_b.f_prcs = 0 ");
|
|
results.Add($" and td_b.f_name = '{replace}' ");
|
|
results.Add(" and pd_b.f_name = pd.f_name ");
|
|
results.Add(" and sl_b.f_url = sl.f_url ");
|
|
results.Add(" and sl_b.f_usl = sl.f_usl ");
|
|
results.Add(" and sl_b.f_ugb = sl.f_ugb ");
|
|
results.Add(" and sl_b.f_tar = sl.f_tar ");
|
|
results.Add(" and sl_b.f_lgb = sl.f_lgb ");
|
|
results.Add(" and sl_b.f_lsl = sl.f_lsl ");
|
|
results.Add(" and sl_b.f_lrl = sl.f_lrl ");
|
|
results.Add(" group by sl_b.f_spec ");
|
|
results.Add(" ) count ");
|
|
results.Add(" from [spcepiworld].[dbo].[spec_lim] sl ");
|
|
results.Add(" join [spcepiworld].[dbo].[part_dat] pd ");
|
|
results.Add(" on sl.f_part = pd.f_part ");
|
|
results.Add(" join [spcepiworld].[dbo].[test_dat] td ");
|
|
results.Add(" on sl.f_test = td.f_test ");
|
|
results.Add(" where sl.f_prcs = 0 ");
|
|
results.Add($" and td.f_name = '{find}' ");
|
|
results.Add(" and isnull(( ");
|
|
results.Add(" select count(sl_b.f_spec) ");
|
|
results.Add(" from [spcepiworld].[dbo].[spec_lim] sl_b ");
|
|
results.Add(" join [spcepiworld].[dbo].[part_dat] pd_b ");
|
|
results.Add(" on sl_b.f_part = pd_b.f_part ");
|
|
results.Add(" join [spcepiworld].[dbo].[test_dat] td_b ");
|
|
results.Add(" on sl_b.f_test = td_b.f_test ");
|
|
results.Add(" where sl_b.f_prcs = 0 ");
|
|
results.Add($" and td_b.f_name = '{replace}' ");
|
|
results.Add(" and pd_b.f_name = pd.f_name ");
|
|
results.Add(" and sl_b.f_url = sl.f_url ");
|
|
results.Add(" and sl_b.f_usl = sl.f_usl ");
|
|
results.Add(" and sl_b.f_ugb = sl.f_ugb ");
|
|
results.Add(" and sl_b.f_tar = sl.f_tar ");
|
|
results.Add(" and sl_b.f_lgb = sl.f_lgb ");
|
|
results.Add(" and sl_b.f_lsl = sl.f_lsl ");
|
|
results.Add(" and sl_b.f_lrl = sl.f_lrl ");
|
|
results.Add(" group by sl_b.f_spec ");
|
|
results.Add(" ), 0) = 0 ");
|
|
results.Add(" for json path ");
|
|
return string.Join(Environment.NewLine, results);
|
|
} // cSpell:restore
|
|
|
|
internal static void SaveCopy(string fileConnectorConfigurationSourceFileLocation, string connectionString, string name, string[] iqsCopyValues)
|
|
{
|
|
string checkFile = Path.Combine(fileConnectorConfigurationSourceFileLocation, $"{name}.json");
|
|
if (!File.Exists(checkFile))
|
|
{
|
|
string commandText = GetCommandText(iqsCopyValues);
|
|
StringBuilder stringBuilder = GetForJsonPath(connectionString, commandText);
|
|
if (stringBuilder.Length != 0)
|
|
File.WriteAllText(checkFile, stringBuilder.ToString());
|
|
else
|
|
File.WriteAllText(Path.Combine(fileConnectorConfigurationSourceFileLocation, $"{name}.sql"), commandText);
|
|
}
|
|
}
|
|
|
|
#nullable disable
|
|
|
|
} |