/DTI_PID/ID2PSN/DB.cs - Diff - HYTOS - 일정관리

개정판 ddc1c369

ID	ddc1c3698212d6d252112170ca9fcd92b92d9cae
상위	3b2a2291
하위	81bdaeed

이지연이(가) 3년 이상 전에 추가함

issue #000: UI 추가중, Pathitems 안나오는 현상 수정, PipeSystemNetwork Table 열추가 및 해당 데이터 관련 Save, load 수정

Change-Id: Iae7d0dcb99a4710bfecc5782c840b8a9e22731ab

             const string PSN_HEADER_SETTING = "T_PSN_HEADER_SETTING";
             const string PSN_VENTDRAIN_SETTING = "T_PSN_VENTDRAIN_SETTING";
             const string PSN_VIEW = "T_PSN_VIEW";
             const string PSN_TRANSFORMKEYWORD_SETTING = "T_PSN_TRANSFORMKEYWORD_SETTING";
             const string PSN_PATHITEMS = "SPPIDPathItem";
             const string PSN_SEQUENCEDATA = "SPPIDSequenceData";
-...
+                        {
                             var query = $"CREATE TABLE {PSN_PIPESYSTEMNETWORK} (OID NVARCHAR(50), Type NVARCHAR(20), OrderNumber NVARCHAR(20), Pipeline_OID NVARCHAR(125), FROM_DATA NVARCHAR(255), " +
                                 "TO_DATA NVARCHAR(255), TopologySet_OID_Key NVARCHAR(125), PSNRevisionNumber NVARCHAR(255), PBS NVARCHAR(255), PIDDrawings NVARCHAR(255), " +
                                 "Validity INTEGER, Status NVARCHAR(255))";
                                 "Validity INTEGER, Status NVARCHAR(255), IncludingVirtualData NVARCHAR(10),  PSNAccuracy REAL)";
                             using (var cmd = connection.GetSqlStringCommand(query))
+                            {
                                 cmd.ExecuteNonQuery();
-...
                                 cmd.ExecuteNonQuery();
+                            }
+                        }
                         matched = names.FirstOrDefault(param => param == PSN_TRANSFORMKEYWORD_SETTING);
                         if (matched == null)
+                        {
                             var query = $"CREATE TABLE {PSN_TRANSFORMKEYWORD_SETTING} (KEYWORD_ID NVARCHAR(125), KeyWord NVARCHAR(255), Description NVARCHAR(255), Remarks NVARCHAR(255), TargetSymbol NVARCHAR(255))";
                             using (var cmd = connection.GetSqlStringCommand(query))
+                            {
                                 cmd.ExecuteNonQuery();
+                            }
+                        }
                         result = true;
+                    }
                     catch (Exception ex)
-...
                 return dt;
+            }
             public static DataTable SelectKeywordsSetting()
+            {
                 DataTable dt = null;
                 ID2Info id2Info = ID2Info.GetInstance();
                 using (IAbstractDatabase connection = id2Info.CreateConnection(ID2DB_Type.SQLite))
+                {
                     try
+                    {
                         var query = $@"SELECT KEYWORD_ID, KeyWord, Description, Remarks, TargetSymbol FROM {PSN_TRANSFORMKEYWORD_SETTING};";
                         using (var ds = connection.ExecuteDataSet(connection.GetSqlStringCommand(query)))
+                        {
                             dt = ds.Tables[0].Copy();
+                        }
+                    }
                     catch (Exception ex)
+                    {
                         Log.Write(ex.Message + "\r\n" + ex.StackTrace);
+                    }
+                }
                 return dt;
+            }
             public static bool SaveHeaderSetting(List<HeaderInfo> headerInfos)
+            {
                 ID2Info id2Info = ID2Info.GetInstance();
-...
                 return true;
+            }
             public static bool SaveKeywordsSetting(List<KeywordInfo> keywordInfos)
+            {
                 ID2Info id2Info = ID2Info.GetInstance();
                 using (IAbstractDatabase connection = id2Info.CreateConnection(ID2DB_Type.SQLite))
+                {
                     using (var txn = connection.BeginTransaction())
+                    {
                         try
+                        {
                             var query = $"DELETE FROM {PSN_VENTDRAIN_SETTING}";
                             connection.ExecuteNonQuery(connection.GetSqlStringCommand(query), txn);
                             foreach (KeywordInfo keywordInfo in keywordInfos)
+                            {
                                 foreach (KeywordItem KeywordIItem in keywordInfo.KeywordItems)
+                                {
                                     query = $"INSERT INTO {PSN_VENTDRAIN_SETTING} VALUES (@KEYWORD_ID, @KeyWord, @Description, @Remarks, @TargetSymbol)";
                                     var cmd = connection.GetSqlStringCommand(query);
                                     AddWithValue(cmd, "@KEYWORD_ID", keywordInfo.UID);
                                     AddWithValue(cmd, "@KeyWord", keywordInfo.KeyWord);
                                     AddWithValue(cmd, "@Description", keywordInfo.Description);
                                     AddWithValue(cmd, "@Remarks", KeywordIItem.Remarks);
                                     AddWithValue(cmd, "@TargetSymbol", KeywordIItem.TargetSymbol);
                                     connection.ExecuteNonQuery(cmd, txn);
+                                }
+                            }
+                        }
                         catch (Exception ex)
+                        {
                             Log.Write(ex.Message + "\r\n" + ex.StackTrace);
                             return false;
+                        }
+                    }
+                }
                 return true;
+            }
             public static bool SaveTopologyRule(DataTable dt)
+            {
                 ID2Info id2Info = ID2Info.GetInstance();
-...
                                 connection.ExecuteNonQuery(connection.GetSqlStringCommand(query), txn);
                                 foreach (DataRow row in item.PipeSystemNetwork.Rows)
+                                {
                                     query = $"INSERT INTO {PSN_PIPESYSTEMNETWORK} VALUES (@OID, @Type, @OrderNumber, @Pipeline_OID, @FROM_DATA, @TO_DATA, @TopologySet_OID_Key, @PSNRevisionNumber, @PBS, @PIDDrawings, @Validity, @Status)";
                                     query = $"INSERT INTO {PSN_PIPESYSTEMNETWORK} VALUES (@OID, @Type, @OrderNumber, @Pipeline_OID, @FROM_DATA, @TO_DATA, @TopologySet_OID_Key, @PSNRevisionNumber, " +
                                         $"@PBS, @PIDDrawings, @Validity, @Status, @IncludingVirtualData, @PSNAccuracy)";
                                     var cmd = connection.GetSqlStringCommand(query);
                                     AddWithValue(cmd, "@OID", row["OID"].ToString());
                                     AddWithValue(cmd, "@Type", row["Type"].ToString());
-...
                                         Validity = -1;
                                     AddWithValue(cmd, "@Validity", Validity);
                                     AddWithValue(cmd, "@Status", row["Status"].ToString());
                                     AddWithValue(cmd, "@IncludingVirtualData", row["IncludingVirtualData"].ToString());
                                     AddWithValue(cmd, "@PSNAccuracy", row["PSNAccuracy"].ToString());
                                     connection.ExecuteNonQuery(cmd, txn);
+                                }
-...
                                 newRow["Validity"] = Validity;
                                 newRow["Status"] = row["Status"].ToString();
                                 newRow["IncludingVirtualData"] = row["IncludingVirtualData"].ToString();
                                 newRow["PSNAccuracy"] = row["PSNAccuracy"].ToString();
                                 result.PipeSystemNetwork.Rows.Add(newRow);
+                            }
+                        }
-...
                                 newRow["Validity"] = Validity;
                                 newRow["Status"] = row["Status"].ToString();
                                 newRow["IncludingVirtualData"] = row["IncludingVirtualData"].ToString();
                                 newRow["PSNAccuracy"] = row["PSNAccuracy"].ToString();
                                 dt.Rows.Add(newRow);
+                            }
+                        }

내보내기 Unified diff

프로젝트

일반

사용자정보

HYTOS

개정판 ddc1c369