개정판 3210f690
issue #000: PSN
Change-Id: I8feaf4df24a663e7ec10fe8249d0704a704808fb
DTI_PID/ID2PSN/DB.cs | ||
---|---|---|
28 | 28 |
const string PSN_PIPELINE = "SPPIDPipeLine"; |
29 | 29 |
//2021.11.26 추가 |
30 | 30 |
const string PSN_INSULATIONPURPOSE = "SPPIDInsulationPurpose"; |
31 |
//2021.12.01 추가 |
|
32 |
const string PSN_REVISION_HISTORY = "T_PSN_REVISION_HISTORY"; |
|
31 | 33 |
/// <summary> |
32 | 34 |
/// ID2 Project.db 데이터를 가져온다. |
33 | 35 |
/// DB 접속 정보 및 DBType (Sqlite, Mssql) 정보를 가져옴 |
... | ... | |
416 | 418 | |
417 | 419 |
return dt; |
418 | 420 |
} |
419 | ||
420 | ||
421 |
|
|
421 | 422 |
public static DataTable SelectInsulationPurpose() |
422 | 423 |
{ |
423 | 424 |
DataTable dt = null; |
... | ... | |
1426 | 1427 | |
1427 | 1428 |
return result; |
1428 | 1429 |
} |
1430 | ||
1429 | 1431 |
public static PSN GetDBPSN() |
1430 | 1432 |
{ |
1431 | 1433 |
PSN result = new PSN(); |
... | ... | |
1435 | 1437 |
{ |
1436 | 1438 |
try |
1437 | 1439 |
{ |
1438 |
//var query = $"SELECT * FROM {PSN_PIPESYSTEMNETWORK} WHERE PSNRevisionNumber = '{string.Format("V{0:D4}", GetRevision())}'";
|
|
1440 |
//query = $"SELECT * FROM {PSN_PIPESYSTEMNETWORK}";
|
|
1439 | 1441 |
//using (var ds = connection.ExecuteDataSet(connection.GetSqlStringCommand(query))) |
1440 | 1442 |
//{ |
1441 |
// result.PipeSystemNetwork = ds.Tables[0].Clone(); |
|
1442 |
// result.PipeSystemNetwork.Columns["IsValid"].DataType = typeof(string); |
|
1443 | ||
1444 |
// foreach (DataRow row in ds.Tables[0].Rows) |
|
1445 |
// { |
|
1446 |
// DataRow newRow = result.PipeSystemNetwork.NewRow(); |
|
1447 |
// newRow["OID"] = row["OID"].ToString(); |
|
1448 |
// newRow["Type"] = row["Type"].ToString(); |
|
1449 |
// newRow["OrderNumber"] = row["OrderNumber"].ToString(); |
|
1450 |
// newRow["Pipeline_OID"] = row["Pipeline_OID"].ToString(); |
|
1451 |
// newRow["FROM_DATA"] = row["FROM_DATA"].ToString(); |
|
1452 |
// newRow["TO_DATA"] = row["TO_DATA"].ToString(); |
|
1453 |
// newRow["TopologySet_OID_Key"] = row["TopologySet_OID_Key"].ToString(); |
|
1454 |
// newRow["PSNRevisionNumber"] = row["PSNRevisionNumber"].ToString(); |
|
1455 |
|
|
1456 |
// string IsValid = string.Empty; |
|
1457 | ||
1458 |
// if (Convert.ToInt32(row["IsValid"].ToString()) == 0) |
|
1459 |
// IsValid = string.Empty;//"OK"; |
|
1460 |
// else if (Convert.ToInt32(row["IsValid"].ToString()) == 1) |
|
1461 |
// IsValid = "InValid"; |
|
1462 |
// else if (Convert.ToInt32(row["IsValid"].ToString()) == -1) |
|
1463 |
// IsValid = "Error"; |
|
1464 | ||
1465 |
// newRow["IsValid"] = IsValid; |
|
1466 | ||
1467 |
// newRow["Status"] = row["Status"].ToString(); |
|
1468 |
// newRow["PBS"] = row["PBS"].ToString(); |
|
1469 |
// newRow["Drawings"] = row["Drawings"].ToString(); |
|
1470 | ||
1471 |
// newRow["IncludingVirtualData"] = row["IncludingVirtualData"].ToString(); |
|
1472 |
// newRow["PSNAccuracy"] = row["PSNAccuracy"].ToString(); |
|
1473 | ||
1474 |
// result.PipeSystemNetwork.Rows.Add(newRow); |
|
1475 |
// } |
|
1443 |
// result.PipeSystemNetwork = ds.Tables[0].Copy(); |
|
1476 | 1444 |
//} |
1477 | 1445 | |
1478 |
var query = $"SELECT * FROM {PSN_EQUIPMENT}"; |
|
1446 |
var query = $"SELECT * FROM {PSN_PIPESYSTEMNETWORK} WHERE PSNRevisionNumber = '{string.Format("V{0:D4}", GetRevision())}'"; |
|
1447 |
using (var ds = connection.ExecuteDataSet(connection.GetSqlStringCommand(query))) |
|
1448 |
{ |
|
1449 |
result.PipeSystemNetwork = ds.Tables[0].Clone(); |
|
1450 |
result.PipeSystemNetwork.Columns["IsValid"].DataType = typeof(string); |
|
1451 | ||
1452 |
foreach (DataRow row in ds.Tables[0].Rows) |
|
1453 |
{ |
|
1454 |
DataRow newRow = result.PipeSystemNetwork.NewRow(); |
|
1455 |
newRow["OID"] = row["OID"].ToString(); |
|
1456 |
newRow["Type"] = row["Type"].ToString(); |
|
1457 |
newRow["OrderNumber"] = row["OrderNumber"].ToString(); |
|
1458 |
newRow["Pipeline_OID"] = row["Pipeline_OID"].ToString(); |
|
1459 |
newRow["FROM_DATA"] = row["FROM_DATA"].ToString(); |
|
1460 |
newRow["TO_DATA"] = row["TO_DATA"].ToString(); |
|
1461 |
newRow["TopologySet_OID_Key"] = row["TopologySet_OID_Key"].ToString(); |
|
1462 |
newRow["PSNRevisionNumber"] = row["PSNRevisionNumber"].ToString(); |
|
1463 | ||
1464 |
string IsValid = string.Empty; |
|
1465 | ||
1466 |
if (Convert.ToInt32(row["IsValid"].ToString()) == 0) |
|
1467 |
IsValid = string.Empty;//"OK"; |
|
1468 |
else if (Convert.ToInt32(row["IsValid"].ToString()) == 1) |
|
1469 |
IsValid = "InValid"; |
|
1470 |
else if (Convert.ToInt32(row["IsValid"].ToString()) == -1) |
|
1471 |
IsValid = "Error"; |
|
1472 | ||
1473 |
newRow["IsValid"] = IsValid; |
|
1474 | ||
1475 |
newRow["Status"] = row["Status"].ToString(); |
|
1476 |
newRow["PBS"] = row["PBS"].ToString(); |
|
1477 |
newRow["Drawings"] = row["Drawings"].ToString(); |
|
1478 | ||
1479 |
newRow["IncludingVirtualData"] = row["IncludingVirtualData"].ToString(); |
|
1480 |
newRow["PSNAccuracy"] = row["PSNAccuracy"].ToString(); |
|
1481 | ||
1482 |
result.PipeSystemNetwork.Rows.Add(newRow); |
|
1483 |
} |
|
1484 |
} |
|
1485 | ||
1486 |
query = $"SELECT * FROM {PSN_EQUIPMENT}"; |
|
1479 | 1487 |
using (var ds = connection.ExecuteDataSet(connection.GetSqlStringCommand(query))) |
1480 | 1488 |
{ |
1481 | 1489 |
result.Equipment = ds.Tables[0].Copy(); |
... | ... | |
1505 | 1513 |
result.TopologySet = ds.Tables[0].Copy(); |
1506 | 1514 |
} |
1507 | 1515 | |
1516 |
|
|
1517 | ||
1508 | 1518 |
query = $"SELECT * FROM {PSN_PIPELINE}"; |
1509 | 1519 |
using (var ds = connection.ExecuteDataSet(connection.GetSqlStringCommand(query))) |
1510 | 1520 |
{ |
내보내기 Unified diff