工事管理システム製品化対応

        public static int s_SystemVersion = 26;

using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

using System.Data;

using System.Collections;

using log4net;

using Oracle.ManagedDataAccess.Client;

using ProcessManagement.DB.Oracle;

using ProcessManagement.DB.Core;

using ProcessManagement.DataModel;

using ProcessManagement.Common;

namespace ProcessManagement.DB.IOAccess

{

    /// <summary>

    /// 日報データＤＢアクセス

    /// </summary>

    public class IODailyData : OracleProcess

    {

        #region 定義部

        /// <summary>

        /// log4netログを使用する

        /// </summary>

        private static readonly ILog logger = LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType);

        #endregion

        #region 定数

        /// <summary>

        /// データフィールド並び

        /// </summary>

        public enum TableColumn

        {

            /// <summary>

            /// 作成者コード

            /// </summary>

            PersonCode,

            /// <summary>

            /// 日報作成日

            /// </summary>

            DailyDataDate,

            /// <summary>

            /// 行番号

            /// </summary>

            LineCount,

            /// <summary>

            /// 工事番号

            /// </summary>

            ConstructionCode,

            /// <summary>

            /// 作業内容

            /// </summary>

            WorkContentsText,

            /// <summary>

            /// 登録年月日

            /// </summary>

            EntryDate,

            /// <summary>

            /// 更新年月日

            /// </summary>

            UpdateDate,

        }

        #endregion

        #region コンストラクタ

        /// <summary>

        /// コンストラクタ

        /// </summary>

        /// <param name="ConnectionString"></param>

        public IODailyData()

            : base(DBCommon.Instance.DBConnectString)

        {

        }

        #endregion

        #region SQL作成

        /// <summary>

        /// SQL作成

        /// </summary>

        private string CreateSelectSQL()

        {

            // SQL作成（oracleのDateTime型が変換できないのでCharに変換しておく）

            string strcmd = "SELECT";

            strcmd += "  PersonCode";                                       // 担当者コード

            strcmd += " ,TO_CHAR(DailyDataDate, 'YYYY/MM/DD')";             // 日報作成日

            strcmd += " ,LineCount";                                        // 行番号

            strcmd += " ,ConstructionCode";                                 // 工事番号

            strcmd += " ,WorkContentsText";                                 // 作業内容

            strcmd += ", TO_CHAR(EntryDate, 'YYYY/MM/DD HH24:MI:ss')";      // 登録年月日

            strcmd += ", TO_CHAR(UpdateDate, 'YYYY/MM/DD HH24:MI:ss')";     // 更新年月日

            strcmd += " FROM DailyData";

            return strcmd;

        }

        #endregion

        #region 複数読込み処理

        public bool SelectAction(string AddSQLString, ref List<DailyData> data, bool bConnect = true)

        {

            //Oracle インターフェース

            string strcmd = "";

            ArrayList arData = new ArrayList();

            try

            {

                // SQL作成

                strcmd = CreateSelectSQL() + AddSQLString;

                // SQL実行

                if (!ExecuteReader(strcmd, ref arData, bConnect)) return false;

                // データセット

                foreach (object[] objwrk in arData)

                {

                    DailyData work = new DailyData();

                    Reader2Struct(objwrk, ref work);

                    data.Add(work);

                }

                return true;

            }

            catch (Exception ex)

            {

                logger.ErrorFormat("システムエラー：{0}：{1}：{2}", CommonMotions.GetMethodName(2), ex.Message, strcmd);

                return false;

            }

        }

        #endregion

        #region 1件読込み処理

        public bool SelectAction(string AddSQLString, ref DailyData data, bool bConnect = true)

        {

            //Oracle インターフェース

            string strcmd = "";

            ArrayList arData = new ArrayList();

            try

            {

                strcmd = CreateSelectSQL() + AddSQLString;

                // SQL実行

                if (!ExecuteReader(strcmd, ref arData, bConnect)) return false;

                if (arData.Count == 0) return false;

                // データセット

                foreach (object[] objwrk in arData)

                {

                    Reader2Struct(objwrk, ref data);

                    break;

                }

                return true;

            }

            catch (Exception ex)

            {

                logger.ErrorFormat("システムエラー：{0}：{1}：{2}", CommonMotions.GetMethodName(2), ex.Message, strcmd);

                return false;

            }

        }

        #endregion

        #region 1件追加処理

        /// <summary>

        /// 担当者毎経費データ追加

        /// </summary>

        /// <param name="data">担当者毎経費データデータ</param>

        /// <returns>true：成功 false：失敗</returns>

        public bool InsertAction(DailyData work, bool bConnect = true)

        {

            string strcmd = "";

            try

            {

                strcmd = "INSERT INTO DailyData";

                strcmd += " VALUES (";

                strcmd += string.Format("  {0}", work.PersonCode);                      // 担当者コード

                strcmd += string.Format(", TO_DATE('{0}','YYYY/MM/DD')"

                                            , work.DailyDataDate.ToShortDateString());  // 日報作成日

                strcmd += string.Format(", {0}", work.LineCoount);                      // 行番号

                strcmd += string.Format(", {0}", work.ConstructionCode);                // 工事番号

                strcmd += string.Format(",'{0}'", work.WorkContentsText);               // 作業内容

                strcmd += ", TO_DATE(TO_CHAR(sysdate,'YYYY/MM/DD HH24:MI:SS'),'YYYY/MM/DD HH24:MI:SS')";

                strcmd += ", TO_DATE(TO_CHAR(sysdate,'YYYY/MM/DD HH24:MI:SS'),'YYYY/MM/DD HH24:MI:SS')";

                strcmd = strcmd + ")";

                if (!ExecuteNonQuery(strcmd, bConnect)) return false;

                return true;

            }

            catch (Exception ex)

            {

                logger.ErrorFormat("システムエラー：{0}：{1}：{2}", CommonMotions.GetMethodName(2), ex.Message, strcmd);

                return false;

            }

        }

        #endregion

        #region 複数追加処理

        public bool InsertAction(List<DailyData> data, bool bConnect = true)

        {

            string strcmd = "";

            try

            {

                foreach (DailyData work in data)

                {

                    if (!InsertAction(work, bConnect)) return false;

                }

                return true;

            }

            catch (Exception ex)

            {

                logger.ErrorFormat("システムエラー：{0}：{1}：{2}", CommonMotions.GetMethodName(2), ex.Message, strcmd);

                return false;

            }

        }

        #endregion

        #region 更新処理

        /// <summary>

        /// 担当者毎経費データ更新

        /// </summary>

        /// <param name="AddSQLString">更新条件SQL文字列</param>

        /// <param name="data">担当者毎経費データデータ</param>

        /// <returns>true：成功 false：失敗</returns>

        public bool UpdateAction(string AddSQLString, DailyData data, bool bConnect = true)

        {

            string strcmd = "";

            try

            {

                strcmd = "UPDATE DailyData";

                strcmd += " SET";

                strcmd += string.Format(" PersonCode = {0}", data.PersonCode);                  // 担当者コード

                strcmd += string.Format(",DailyDataDate = TO_DATE('{0}','YYYY/MM/DD')"

                                        , data.DailyDataDate.ToShortDateString());              // 日報作成日

                strcmd += string.Format(",LineCoount = {0}", data.LineCoount);                  // 行番号

                strcmd += string.Format(",ConstructionCode = {0}", data.ConstructionCode);      // 工事番号

                strcmd += string.Format(",WorkContentsText = '{0}'", data.WorkContentsText);    // 作業内容

                strcmd += ", UpdateDate = TO_DATE(TO_CHAR(sysdate,'YYYY/MM/DD HH24:MI:SS'),'YYYY/MM/DD HH24:MI:SS')";

                strcmd += AddSQLString;

                if (!ExecuteNonQuery(strcmd, bConnect)) return false;

                return true;

            }

            catch (Exception ex)

            {

                logger.ErrorFormat("システムエラー：{0}：{1}：{2}", CommonMotions.GetMethodName(2), ex.Message, strcmd);

                return false;

            }

        }

        #endregion

        #region 削除処理

        /// <summary>

        /// 担当者毎経費データ削除

        /// </summary>

        /// <param name="AddSQLString">削除条件SQL文字列</param>

        /// <param name="data">担当者毎経費データデータ</param>

        /// <returns>true：成功 false：失敗</returns>

        public bool DeleteAction(string AddSQLString, bool bConnect = true)

        {

            //Oracle インターフェース

            string strcmd = "";

            try

            {

                strcmd = string.Format("{0}{1}", "DELETE FROM DailyData", AddSQLString);

                if (!ExecuteNonQuery(strcmd, bConnect)) return false;

                return true;

            }

            catch (Exception ex)

            {

                logger.ErrorFormat("システムエラー：{0}：{1}：{2}", CommonMotions.GetMethodName(2), ex.Message, strcmd);

                return false;

            }

        }

        #endregion

        #region データセット処理

        /// <summary>

        /// OracleDataReaderより構造体へセットする

        /// </summary>

        /// <param name="reader">OracleDataReader</param>

        /// <param name="wrk">構造体</param>

        public void Reader2Struct(object[] objwrk, ref DailyData wrk)

        {

            try

            {

                // データ取得

                wrk.PersonCode = int.Parse(objwrk[(int)TableColumn.PersonCode].ToString());                  // 担当者コード

                wrk.DailyDataDate = DateTime.Parse(objwrk[(int)TableColumn.DailyDataDate].ToString());       // 日報作成日

                wrk.LineCoount = int.Parse(objwrk[(int)TableColumn.LineCount].ToString());                   // 行番号

                wrk.ConstructionCode = int.Parse(objwrk[(int)TableColumn.ConstructionCode].ToString());      // 工事番号

                wrk.WorkContentsText = objwrk[(int)TableColumn.WorkContentsText].ToString();                 // 作業内容

                wrk.EntryDate = DateTime.Parse(objwrk[(int)TableColumn.EntryDate].ToString());

                wrk.UpdateDate = DateTime.Parse(objwrk[(int)TableColumn.UpdateDate].ToString());

            }

            catch (OracleException oraex)

            {

                logger.ErrorFormat("オラクルエラー：{0}：{1}", CommonMotions.GetMethodName(2), oraex.Message);

            }

            catch (Exception ex)

            {

                logger.ErrorFormat("システムエラー：{0}：{1}", CommonMotions.GetMethodName(2), ex.Message);

            }

        }

        #endregion

        #region 検索文字列作成処理

        /// <summary>

        /// 主キー検索の文字列を返す

        /// </summary>

        /// <param name="PersonCode"></param>

        /// <param name="ActionDate"></param>

        /// <param name="DataType"></param>

        /// <param name="DataAddCount"></param>

        /// <returns></returns>

        public string CreatePrimarykeyString(int PersonCode, DateTime DailyDataDate, int LineCount)

        {

            string strWork = "";

            try

            {

                strWork = string.Format(" WHERE PersonCode = {0}", PersonCode);

                if (DailyDataDate != DateTime.MinValue)

                    strWork += string.Format(" AND DailyDataDate = TO_DATE('{0}','YYYY/MM/DD')", DailyDataDate.ToShortDateString());

                if (LineCount != 0)

                    strWork += string.Format(" AND LineCount = {0}", LineCount);

            }

            catch (Exception ex)

            {

                logger.ErrorFormat("システムエラー：{0}：{1}：{2}", CommonMotions.GetMethodName(2), ex.Message, strWork);

            }

            return strWork;

        }

        #endregion

    }

}

using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

using System.Data;

using System.Collections;

using log4net;

using Oracle.ManagedDataAccess.Client;

using ProcessManagement.DB.Oracle;

using ProcessManagement.DB.Core;

using ProcessManagement.DataModel;

using ProcessManagement.Common;

namespace ProcessManagement.DB.IOAccess

{

    /// <summary>

    /// 発注者打ち合わせ議事録データアクセス（出席者）

    /// </summary>

    public class IOProceedingsDataAttend : OracleProcess

    {

        #region 定義部

        /// <summary>

        /// log4netログを使用する

        /// </summary>

        private static readonly ILog logger = LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType);

        #endregion

        #region 定数

        /// <summary>

        /// データフィールド並び

        /// </summary>

        public enum TableColumn

        {

            /// <summary>

            /// 工事番号

            /// </summary>

            ConstructionCode,

            /// <summary>

            /// 議事録作成日

            /// </summary>

            ProceedingsDataDate,

            /// <summary>

            /// 会議時間開始

            /// </summary>

            StartMeetingTime,

            /// <summary>

            /// データ行番号

            /// </summary>

            SeqNo,

            /// <summary>

            /// 出席者所属

            /// </summary>

            Department,

            /// <summary>

            /// 出席者氏名

            /// </summary>

            AttendName,

            /// <summary>

            /// 登録年月日

            /// </summary>

            EntryDate,

            /// <summary>

            /// 更新年月日

            /// </summary>

            UpdateDate,

        }

        #endregion

        #region コンストラクタ

        /// <summary>

        /// コンストラクタ

        /// </summary>

        /// <param name="ConnectionString"></param>

        public IOProceedingsDataAttend()

            : base(DBCommon.Instance.DBConnectString)

        {

        }

        #endregion

        #region SQL作成

        /// <summary>

        /// SQL作成

        /// </summary>

        private string CreateSelectSQL()

        {

            // SQL作成（oracleのDateTime型が変換できないのでCharに変換しておく）

            string strcmd = "SELECT";

            strcmd += " ConstructionCode";                                  // 工事番号

            strcmd += " ,TO_CHAR(ProceedingsDataDate, 'YYYY/MM/DD')";       // 議事録作成日

            strcmd += " ,StartMeetingTime";                                 // 会議時間開始

            strcmd += " ,SeqNo";                                            // データ行番号

            strcmd += " ,Department";                                       // 出席者所属

            strcmd += " ,AttendName";                                       // 出席者氏名

            strcmd += ", TO_CHAR(EntryDate, 'YYYY/MM/DD HH24:MI:ss')";      // 登録年月日

            strcmd += ", TO_CHAR(UpdateDate, 'YYYY/MM/DD HH24:MI:ss')";     // 更新年月日

            strcmd += " FROM ProceedingsDataAttend";

            return strcmd;

        }

        #endregion

        #region 複数読込み処理

        public bool SelectAction(string AddSQLString, ref List<ProceedingsDataAttend> data, bool bConnect = true)

        {

            //Oracle インターフェース

            string strcmd = "";

            ArrayList arData = new ArrayList();

            try

            {

                // SQL作成

                strcmd = CreateSelectSQL() + AddSQLString;

                // SQL実行

                if (!ExecuteReader(strcmd, ref arData, bConnect)) return false;

                // データセット

                foreach (object[] objwrk in arData)

                {

                    ProceedingsDataAttend work = new ProceedingsDataAttend();

                    Reader2Struct(objwrk, ref work);

                    data.Add(work);

                }

                return true;

            }

            catch (Exception ex)

            {

                logger.ErrorFormat("システムエラー：{0}：{1}：{2}", CommonMotions.GetMethodName(2), ex.Message, strcmd);

                return false;

            }

        }

        #endregion

        #region 1件読込み処理

        public bool SelectAction(string AddSQLString, ref ProceedingsDataAttend data, bool bConnect = true)

        {

            //Oracle インターフェース

            string strcmd = "";

            ArrayList arData = new ArrayList();

            try

            {

                strcmd = CreateSelectSQL() + AddSQLString;

                // SQL実行

                if (!ExecuteReader(strcmd, ref arData, bConnect)) return false;

                if (arData.Count == 0) return false;

                // データセット

                foreach (object[] objwrk in arData)

                {

                    Reader2Struct(objwrk, ref data);

                    break;

                }

                return true;

            }

            catch (Exception ex)

            {

                logger.ErrorFormat("システムエラー：{0}：{1}：{2}", CommonMotions.GetMethodName(2), ex.Message, strcmd);

                return false;

            }

        }

        #endregion

        #region 1件追加処理

        /// <summary>

        /// 担当者毎経費データ追加

        /// </summary>

        /// <param name="data">担当者毎経費データデータ</param>

        /// <returns>true：成功 false：失敗</returns>

        public bool InsertAction(ProceedingsDataAttend work, bool bConnect = true)

        {

            string strcmd = "";

            try

            {

                strcmd = "INSERT INTO ProceedingsDataAttend";

                strcmd += " (";

                bool bFirst = true;

                foreach (var gender in Enum.GetValues(typeof(TableColumn)))

                {

                    if (!bFirst) strcmd += " ,";

                    strcmd += gender.ToString();

                    bFirst = false;

                }

                strcmd += ") VALUES (";

                strcmd += string.Format(" {0}", work.ConstructionCode);                     // 工事番号

                strcmd += string.Format(", TO_DATE('{0}','YYYY/MM/DD')"

                                            , work.ProceedingsDataDate.ToShortDateString());// 議事録作成日

                strcmd += string.Format(", {0}", work.StartMeetingTime);                    // 会議時間開始

                strcmd += string.Format(", {0}", work.SeqNo);                               // データ行番号

                strcmd += string.Format(",'{0}'", work.Department);                         // 出席者所属

                strcmd += string.Format(",'{0}'", work.AttendName);                         // 出席者氏名

                strcmd += ", TO_DATE(TO_CHAR(sysdate,'YYYY/MM/DD HH24:MI:SS'),'YYYY/MM/DD HH24:MI:SS')";

                strcmd += ", TO_DATE(TO_CHAR(sysdate,'YYYY/MM/DD HH24:MI:SS'),'YYYY/MM/DD HH24:MI:SS')";

                strcmd = strcmd + ")";

                if (!ExecuteNonQuery(strcmd, bConnect)) return false;

                return true;

            }

            catch (Exception ex)

            {

                logger.ErrorFormat("システムエラー：{0}：{1}：{2}", CommonMotions.GetMethodName(2), ex.Message, strcmd);

                return false;

            }

        }

        #endregion

        #region 複数追加処理

        public bool InsertAction(List<ProceedingsDataAttend> data, bool bConnect = true)

        {

            string strcmd = "";

            try

            {

                foreach (ProceedingsDataAttend work in data)

                {

                    if (!InsertAction(work, bConnect)) return false;

                }

                return true;

            }

            catch (Exception ex)

            {

                logger.ErrorFormat("システムエラー：{0}：{1}：{2}", CommonMotions.GetMethodName(2), ex.Message, strcmd);

                return false;

            }

        }

        #endregion

        #region 更新処理

        /// <summary>

        /// 担当者毎経費データ更新

        /// </summary>

        /// <param name="AddSQLString">更新条件SQL文字列</param>

        /// <param name="data">担当者毎経費データデータ</param>

        /// <returns>true：成功 false：失敗</returns>

        public bool UpdateAction(string AddSQLString, ProceedingsDataAttend data, bool bConnect = true)

        {

            string strcmd = "";

            try

            {

                strcmd = "UPDATE ProceedingsDataAttend";

                strcmd += " SET";

                strcmd += string.Format(" ConstructionCode = {0}", data.ConstructionCode);      // 工事番号

                strcmd += string.Format(",ProceedingsDataDate = TO_DATE('{0}','YYYY/MM/DD')"

                                        , data.ProceedingsDataDate.ToShortDateString());        // 議事録作成日

                strcmd += string.Format(",StartMeetingTime = {0}", data.StartMeetingTime);      // 会議時間開始

                strcmd += string.Format(",SeqNo = {0}", data.SeqNo);                            // データ行番号

                strcmd += string.Format(",Department = '{0}'", data.Department);                // 出席者所属

                strcmd += string.Format(",AttendName = '{0}'", data.AttendName);                // 出席者氏名

                strcmd += ", UpdateDate = TO_DATE(TO_CHAR(sysdate,'YYYY/MM/DD HH24:MI:SS'),'YYYY/MM/DD HH24:MI:SS')";

                strcmd += AddSQLString;

                if (!ExecuteNonQuery(strcmd, bConnect)) return false;

                return true;

            }

            catch (Exception ex)

            {

                logger.ErrorFormat("システムエラー：{0}：{1}：{2}", CommonMotions.GetMethodName(2), ex.Message, strcmd);

                return false;

            }

        }

        #endregion

        #region 削除処理

        /// <summary>

        /// 担当者毎経費データ削除

        /// </summary>

        /// <param name="AddSQLString">削除条件SQL文字列</param>

        /// <param name="data">担当者毎経費データデータ</param>

        /// <returns>true：成功 false：失敗</returns>

        public bool DeleteAction(string AddSQLString, bool bConnect = true)

        {

            //Oracle インターフェース

            string strcmd = "";

            try

            {

                strcmd = string.Format("{0}{1}", "DELETE FROM ProceedingsDataAttend", AddSQLString);

                if (!ExecuteNonQuery(strcmd, bConnect)) return false;

                return true;

            }

            catch (Exception ex)

            {

                logger.ErrorFormat("システムエラー：{0}：{1}：{2}", CommonMotions.GetMethodName(2), ex.Message, strcmd);

                return false;

            }

        }

        #endregion

        #region データセット処理

        /// <summary>

        /// OracleDataReaderより構造体へセットする

        /// </summary>

        /// <param name="reader">OracleDataReader</param>

        /// <param name="wrk">構造体</param>

        public void Reader2Struct(object[] objwrk, ref ProceedingsDataAttend wrk)

        {

            try

            {

                // データ取得

                wrk.ConstructionCode = int.Parse(objwrk[(int)TableColumn.ConstructionCode].ToString());      // 工事番号

                wrk.ProceedingsDataDate = DateTime.Parse(objwrk[(int)TableColumn.ProceedingsDataDate].ToString());       // 議事録作成日

                wrk.StartMeetingTime = int.Parse(objwrk[(int)TableColumn.StartMeetingTime].ToString());      // 会議時間開始

                wrk.SeqNo = int.Parse(objwrk[(int)TableColumn.SeqNo].ToString());                            // データ行番号

                wrk.Department = objwrk[(int)TableColumn.Department].ToString();                             // 出席者所属

                wrk.AttendName = objwrk[(int)TableColumn.AttendName].ToString();                             // 出席者氏名

                wrk.EntryDate = DateTime.Parse(objwrk[(int)TableColumn.EntryDate].ToString());

                wrk.UpdateDate = DateTime.Parse(objwrk[(int)TableColumn.UpdateDate].ToString());

            }

            catch (OracleException oraex)

            {

                logger.ErrorFormat("オラクルエラー：{0}：{1}", CommonMotions.GetMethodName(2), oraex.Message);

            }

            catch (Exception ex)

            {

                logger.ErrorFormat("システムエラー：{0}：{1}", CommonMotions.GetMethodName(2), ex.Message);

            }

        }

        #endregion

        #region 検索文字列作成処理

        /// <summary>

        /// 主キー検索の文字列を返す

        /// </summary>

        /// <param name="PersonCode"></param>

        /// <param name="ActionDate"></param>

        /// <param name="DataType"></param>

        /// <param name="DataAddCount"></param>

        /// <returns></returns>

        public string CreatePrimarykeyString(int ConstructionCode, DateTime ProceedingsDataDate, int StartMeetingTime = 0, int SeqNo = 0)

        {

            string strWork = "";

            try

            {

                strWork = string.Format(" WHERE ConstructionCode = {0}", ConstructionCode);

                if (ProceedingsDataDate != DateTime.MinValue)

                    strWork += string.Format(" AND ProceedingsDataDate = TO_DATE('{0}','YYYY/MM/DD')", ProceedingsDataDate.ToShortDateString());

                if (StartMeetingTime != 0)

                    strWork += string.Format(" AND StartMeetingTime = {0}", StartMeetingTime);

                if (SeqNo != 0)

                    strWork += string.Format(" AND SeqNo = {0}", SeqNo);

            }

            catch (Exception ex)

            {

                logger.ErrorFormat("システムエラー：{0}：{1}：{2}", CommonMotions.GetMethodName(2), ex.Message, strWork);

            }

            return strWork;

        }

        #endregion

    }

}

using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

using System.Data;

using System.Collections;

using log4net;

using Oracle.ManagedDataAccess.Client;

using ProcessManagement.DB.Oracle;

using ProcessManagement.DB.Core;

using ProcessManagement.DataModel;

using ProcessManagement.Common;

namespace ProcessManagement.DB.IOAccess

{

    /// <summary>

    /// 施工工種マスタＤＢアクセス

    /// </summary>

    public class IOMConstructionWork : OracleProcess

    {

        #region 定義部

        /// <summary>

        /// log4netログを使用する

        /// </summary>

        private static readonly ILog logger = LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType);

        #endregion

        #region 定数

        /// <summary>

        /// 施工工種マスタフィールド並び

        /// </summary>

        public enum ConstructionWorkMasterColumn

        {

            ComponentCode = 0,

            ItemCode,

            WorkCode,

            DisplayOrder,

            ItemName,

            WorkName,

            UnitName,

            UnitPrice,

            DeleteFlg,

            EntryDate,

            UpdateDate,

        }

        #endregion

        #region コンストラクタ

        /// <summary>

        /// コンストラクタ

        /// </summary>

        /// <param name="ConnectionString"></param>

        public IOMConstructionWork()

            : base(DBCommon.Instance.DBConnectString)

        {

        }

        #endregion

        #region パブリックメソッド

        /// <summary>

        /// 施工工種マスタ検索

        /// </summary>

        /// <param name="AddSQLString">検索条件SQL文字列</param>

        /// <param name="data">施工工種マスタデータ</param>

        /// <returns>true：成功 false：失敗</returns>

        public bool SelectAction(string AddSQLString, ref List<ConstructionWorkMaster> data, bool bConnect = true)

        {

            //Oracle インターフェース

            string strcmd = "";

            ArrayList arData = new ArrayList();

            try

            {

                // SQL作成（oracleのDateTime型が変換できないのでCharに変換しておく）

                strcmd = "SELECT";

                strcmd += "  ComponentCode";

                strcmd += ", ItemCode";

                strcmd += ", WorkCode";

                strcmd += ", DisplayOrder";

                strcmd += ", ItemName";

                strcmd += ", WorkName";

                strcmd += ", UnitName";

                strcmd += ", UnitPrice";

                strcmd += ", DeleteFlg";

                strcmd += ", TO_CHAR(EntryDate, 'YYYY/MM/DD HH24:MI:ss')";

                strcmd += ", TO_CHAR(UpdateDate, 'YYYY/MM/DD HH24:MI:ss')";

                strcmd += " FROM ConstructionWorkMaster";

                strcmd += AddSQLString;

                // SQL実行

                if (!ExecuteReader(strcmd, ref arData, bConnect)) return false;

                // データセット

                foreach (object[] objwrk in arData)

                {

                    ConstructionWorkMaster work = new ConstructionWorkMaster();

                    Reader2Struct(objwrk, ref work);

                    data.Add(work);

                }

                return true;

            }

            catch (Exception ex)

            {

                logger.ErrorFormat("システムエラー：{0}：{1}：{2}", CommonMotions.GetMethodName(2), ex.Message, strcmd);

                return false;

            }

        }

        /// <summary>

        /// 施工工種マスタ追加

        /// </summary>

        /// <param name="data">施工工種マスタデータ</param>

        /// <returns>true：成功 false：失敗</returns>

        public bool InsertAction(List<ConstructionWorkMaster> data, bool bConnect = true)

        {

            string strcmd = "";

            try

            {

                foreach (ConstructionWorkMaster work in data)

                {

                    strcmd = "INSERT INTO ConstructionWorkMaster";

                    strcmd += " VALUES (";

                    strcmd += string.Format(" {0}", work.ComponentCode);

                    strcmd += string.Format(",{0}", work.ItemCode);

                    strcmd += string.Format(",{0}", work.WorkCode);

                    strcmd += string.Format(",{0}", work.DisplayOrder);

                    strcmd += string.Format(",'{0}'", work.ItemName);

                    strcmd += string.Format(",'{0}'", work.WorkName);

                    strcmd += string.Format(",'{0}'", work.UnitName);

                    strcmd += string.Format(",{0}", work.UnitPrice);

                    strcmd += string.Format(",{0}", work.DeleteFlg);

                    strcmd += ", TO_DATE(TO_CHAR(sysdate,'YYYY/MM/DD HH24:MI:SS'),'YYYY/MM/DD HH24:MI:SS')";

                    strcmd += ", TO_DATE(TO_CHAR(sysdate,'YYYY/MM/DD HH24:MI:SS'),'YYYY/MM/DD HH24:MI:SS')";

                    strcmd = strcmd + ")";

                    if (!ExecuteNonQuery(strcmd, bConnect)) return false;

                }

                return true;

            }

            catch (Exception ex)

            {

                logger.ErrorFormat("システムエラー：{0}：{1}：{2}", CommonMotions.GetMethodName(2), ex.Message, strcmd);

                return false;

            }

        }

        /// <summary>

        /// 施工工種マスタ更新

        /// </summary>

        /// <param name="AddSQLString">更新条件SQL文字列</param>

        /// <param name="data">施工工種マスタデータ</param>

        /// <returns>true：成功 false：失敗</returns>

        public bool UpdateAction(string AddSQLString, ConstructionWorkMaster data, bool bConnect = true)

        {

            string strcmd = "";

            try

            {

                strcmd = "UPDATE ConstructionWorkMaster";

                strcmd += " SET";

                strcmd += string.Format(" ComponentCode = {0}", data.ComponentCode);

                strcmd += string.Format(",ItemCode = {0}", data.ItemCode);

                strcmd += string.Format(",WorkCode = {0}", data.WorkCode);

                strcmd += string.Format(",DisplayOrder = {0}", data.DisplayOrder);

                strcmd += string.Format(",ItemName = '{0}'", data.ItemName);

                strcmd += string.Format(",WorkName = '{0}'", data.WorkName);

                strcmd += string.Format(",UnitName = '{0}'", data.UnitName);

                strcmd += string.Format(",UnitPrice = {0}", data.UnitPrice);

                strcmd += string.Format(",DeleteFlg = {0}", data.DeleteFlg);

                strcmd += ", UpdateDate = TO_DATE(TO_CHAR(sysdate,'YYYY/MM/DD HH24:MI:SS'),'YYYY/MM/DD HH24:MI:SS')";

                strcmd += AddSQLString;

                if (!ExecuteNonQuery(strcmd, bConnect)) return false;

                return true;

            }

            catch (Exception ex)

            {

                logger.ErrorFormat("システムエラー：{0}：{1}：{2}", CommonMotions.GetMethodName(2), ex.Message, strcmd);

                return false;

            }

        }

        /// <summary>

        /// 施工工種マスタ削除

        /// </summary>

        /// <param name="AddSQLString">削除条件SQL文字列</param>

        /// <param name="data">施工工種マスタデータ</param>

        /// <returns>true：成功 false：失敗</returns>

        public bool DeleteAction(string AddSQLString, bool bConnect = true)

        {

            //Oracle インターフェース

            string strcmd = "";

            try

            {

                strcmd = string.Format("{0}{1}", "DELETE FROM ConstructionWorkMaster", AddSQLString);

                if (!ExecuteNonQuery(strcmd, bConnect)) return false;

                return true;

            }

            catch (Exception ex)

            {

                logger.ErrorFormat("システムエラー：{0}：{1}：{2}", CommonMotions.GetMethodName(2), ex.Message, strcmd);

                return false;

            }

        }

        /// <summary>

        /// 論理削除

        /// </summary>

        /// <param name="ItemCode">カテゴリタイプ</param>

        /// <param name="Key2">名称コード</param>

        /// <param name="Key3">登録履歴</param>

        /// <returns>成功時：true　失敗時：false</returns>

        public bool LogicalDeleteAction(int ComponentCode, int ItemCode, int WorkCode, bool bConnect = true)

        {

            // Where文字列作成

            string strWhere = CreatePrimarykeyString(ComponentCode, ItemCode, WorkCode);

            try

            {

                List<ConstructionWorkMaster> workList = new List<ConstructionWorkMaster>();

                // データ読込

                if (SelectAction(strWhere, ref workList, bConnect))

                {

                    if (workList.Count == 0) return true;

                    // 削除フラグ

                    workList[0].DeleteFlg = 1;

                    // データ更新

                    if (!UpdateAction(strWhere, workList[0], bConnect))

                    {

                        rollback();

                        return false;

                    }

                }

                return true;

            }

            catch (Exception ex)

            {

                logger.ErrorFormat("システムエラー：：{0}：{1}：{2}", CommonMotions.GetMethodName(2), ex.Message, strWhere);

                return false;

            }

        }

        /// <summary>

        /// OracleDataReaderより構造体へセットする

        /// </summary>

        /// <param name="reader">OracleDataReader</param>

        /// <param name="wrk">構造体</param>

        public void Reader2Struct(object[] objwrk, ref ConstructionWorkMaster wrk)

        {

            try

            {

                // データ取得

                wrk.ComponentCode = int.Parse(objwrk[(int)ConstructionWorkMasterColumn.ComponentCode].ToString());

                wrk.ItemCode = int.Parse(objwrk[(int)ConstructionWorkMasterColumn.ItemCode].ToString());

                wrk.WorkCode = int.Parse(objwrk[(int)ConstructionWorkMasterColumn.WorkCode].ToString());

                wrk.DisplayOrder = int.Parse(objwrk[(int)ConstructionWorkMasterColumn.DisplayOrder].ToString());

                wrk.ItemName = objwrk[(int)ConstructionWorkMasterColumn.ItemName].ToString();

                wrk.WorkName = objwrk[(int)ConstructionWorkMasterColumn.WorkName].ToString();

                wrk.UnitName = objwrk[(int)ConstructionWorkMasterColumn.UnitName].ToString();

                wrk.UnitPrice = int.Parse(objwrk[(int)ConstructionWorkMasterColumn.UnitPrice].ToString());

                wrk.DeleteFlg = int.Parse(objwrk[(int)ConstructionWorkMasterColumn.DeleteFlg].ToString());

                wrk.EntryDate = DateTime.Parse(objwrk[(int)ConstructionWorkMasterColumn.EntryDate].ToString());

                wrk.UpdateDate = DateTime.Parse(objwrk[(int)ConstructionWorkMasterColumn.UpdateDate].ToString());

            }

            catch (OracleException oraex)

            {

                logger.ErrorFormat("オラクルエラー：{0}：{1}", CommonMotions.GetMethodName(2), oraex.Message);

            }

            catch (Exception ex)

            {

                logger.ErrorFormat("システムエラー：{0}：{1}", CommonMotions.GetMethodName(2), ex.Message);

            }

        }

        #endregion

        #region パブリックメソッド（特殊処理）

        /// <summary>

        /// 最大値を取得する

        /// </summary>

        /// <param name="AddSQLString"></param>

        /// <param name="bConnect"></param>

        /// <returns></returns>

        public int GetMaxWorkCodeCount(string AddSQLString, bool bConnect = true)

        {

            //Oracle インターフェース

            string strcmd = "";

            ArrayList arData = new ArrayList();

            int iRet = 0;

            try

            {

                // SQL作成

                strcmd = "SELECT MAX(WorkCode) FROM ConstructionWorkMaster" + AddSQLString;

                // SQL実行

                if (!ExecuteReader(strcmd, ref arData, bConnect)) return iRet;

                // データセット

                foreach (object[] objwrk in arData)

                {

                    if (objwrk[0].ToString().Equals(""))

                        iRet = 0;

                    else

                        iRet = int.Parse(objwrk[0].ToString());

                }

            }

            catch (Exception ex)

            {

                logger.ErrorFormat("システムエラー：{0}：{1}：{2}", CommonMotions.GetMethodName(2), ex.Message, strcmd);

            }

            return iRet;

        }

        /// <summary>

        /// 主キー検索の文字列を返す

        /// </summary>

        /// <param name="WorkCode">項目コード</param>

        /// <param name="History">登録履歴</param>

        /// <returns>Where文字列</returns>

        public string CreatePrimarykeyString(int ComponentCode, int ItemCode, int WorkCode = 0)

        {

            string strWork = "";

            try

            {

                strWork = string.Format(" Where ComponentCode = {0} And ItemCode = {1}", ComponentCode, ItemCode);

                if (WorkCode != 0) strWork += string.Format(" And WorkCode = {0}", WorkCode);

            }

            catch (Exception ex)

            {

                logger.ErrorFormat("システムエラー：{0}：{1}：{2}", CommonMotions.GetMethodName(2), ex.Message, strWork);

            }

            return strWork;

        }

        /// <summary>

        /// 指定表示順の最大値を取得する

        /// </summary>

        /// <param name="AddSQLString"></param>

        /// <param name="bConnect"></param>

        /// <returns></returns>

        public int GetMaxDisplayOrder(string AddSQLString, bool bConnect = true)

        {

            //Oracle インターフェース

            string strcmd = "";

            ArrayList arData = new ArrayList();

            int iRet = 0;

            try

            {

                // SQL作成

                strcmd = "SELECT MAX(DisplayOrder) FROM ConstructionWorkMaster" + AddSQLString;

                // SQL実行

                if (!ExecuteReader(strcmd, ref arData, bConnect)) return iRet;

                // データセット

                foreach (object[] objwrk in arData)

                {

                    if (objwrk[0].ToString().Equals("null"))

                        iRet = 0;

                    else

                        iRet = int.Parse(objwrk[0].ToString());

                }

            }

            catch (Exception ex)

            {

                logger.ErrorFormat("システムエラー：{0}：{1}：{2}", CommonMotions.GetMethodName(2), ex.Message, strcmd);

            }

            return iRet;

        }

        #endregion

    }

}

using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

using System.Collections;

using log4net;

using Oracle.ManagedDataAccess.Client;

using ProcessManagement.DB.Oracle;

using ProcessManagement.DB.Core;

using ProcessManagement.DataModel;

using ProcessManagement.Common;

namespace ProcessManagement.DB.IOAccess

{

    /// <summary>

    /// 工事項目マスタアクセスクラス

    /// </summary>

    public class IOMConstructionItemOLD : OracleProcess

    {

        #region 定義部

        /// <summary>

        /// log4netログを使用する

        /// </summary>

        private static readonly ILog logger = LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType);

        #endregion

        #region 定数

        /// <summary>

        /// 工事項目マスタフィールド並び

        /// </summary>

        public enum NameColumn

        {

            ComponentCode = 0,

            ItemCode,

            DisplayOrder,

            ItemName,

            SubitemsFlg,

            DeleteFlg,

            EntryDate,

            UpdateDate,

        }

        #endregion

        #region コンストラクタ

        /// <summary>

        /// コンストラクタ

        /// </summary>

        /// <param name="ConnectionString"></param>

        public IOMConstructionItemOLD()

            : base(DBCommon.Instance.DBConnectString)

        {

        }

        #endregion

        #region パブリックメソッド

        /// <summary>

        /// 工事項目マスタ検索

        /// </summary>

        /// <param name="AddSQLString">検索条件SQL文字列</param>

        /// <param name="data">工事項目マスタデータ</param>

        /// <returns>true：成功 false：失敗</returns>

        private string CreateSelectSQL()

        {

            // SQL作成（oracleのDateTime型が変換できないのでCharに変換しておく）

            string strcmd = "SELECT";

            strcmd += "  ComponentCode";

            strcmd += " ,ItemCode";

            strcmd += " ,DisplayOrder";

            strcmd += " ,ItemName";

            strcmd += " ,SubitemsFlg";

            strcmd += " ,DeleteFlg";

            strcmd += " ,TO_CHAR(EntryDate, 'YYYY/MM/DD HH24:MI:ss')";

            strcmd += " ,TO_CHAR(UpdateDate, 'YYYY/MM/DD HH24:MI:ss')";

            strcmd += " FROM ConstructionItemMaster_OLD";

            return strcmd;

        }

        public bool SelectAction(string AddSQLString, ref List<ConstructionItemOLDMaster> data, bool bConnect = true)

        {

            //Oracle インターフェース

            string strcmd = "";

            ArrayList arData = new ArrayList();

            try

            {

                // SQL作成（oracleのDateTime型が変換できないのでCharに変換しておく）

                strcmd = CreateSelectSQL() + AddSQLString;

                // SQL実行

                if (!ExecuteReader(strcmd, ref arData, bConnect)) return false;

                // データセット

                foreach (object[] objwrk in arData)

                {

                    ConstructionItemOLDMaster work = new ConstructionItemOLDMaster();

                    Reader2Struct(objwrk, ref work);

                    data.Add(work);

                }

                return true;

            }

            catch (Exception ex)

            {

                logger.ErrorFormat("システムエラー：：{0}：{1}：{2}", CommonMotions.GetMethodName(2), ex.Message, strcmd);

                return false;

            }

        }

        public bool SelectAction(string AddSQLString, ref ConstructionItemOLDMaster data, bool bConnect = true)

        {

            //Oracle インターフェース

            string strcmd = "";

            ArrayList arData = new ArrayList();

            try

            {

                // SQL作成（oracleのDateTime型が変換できないのでCharに変換しておく）

                strcmd = CreateSelectSQL() + AddSQLString;

                // SQL実行

                if (!ExecuteReader(strcmd, ref arData, bConnect)) return false;

                // データ無

                if (arData.Count == 0) return false;

                // データセット

                foreach (object[] objwrk in arData)

                {

                    Reader2Struct(objwrk, ref data);

                    break;

                }

                return true;

            }

            catch (Exception ex)

            {

                logger.ErrorFormat("システムエラー：：{0}：{1}：{2}", CommonMotions.GetMethodName(2), ex.Message, strcmd);

                return false;

            }

        }

        /// <summary>

        /// 工事項目マスタ追加

        /// </summary>

        /// <param name="data">工事項目マスタデータ</param>

        /// <returns>true：成功 false：失敗</returns>

        public bool InsertAction(List<ConstructionItemOLDMaster> data, bool bConnect = true)

        {

            string strcmd = "";

            try

            {

                foreach (ConstructionItemOLDMaster work in data)

                {

                    strcmd = "INSERT INTO ConstructionItemMaster_OLD";

                    strcmd += " VALUES (";

                    strcmd += string.Format("  {0}", work.ComponentCode.ToString());

                    strcmd += string.Format(", {0}", work.ItemCode.ToString());

                    strcmd += string.Format(", {0}", work.DisplayOrder.ToString());

                    strcmd += string.Format(", '{0}'", work.ItemName);

                    strcmd += string.Format(", {0}", work.SubitemsFlg.ToString());

                    strcmd += string.Format(", {0}", work.DeleteFlg.ToString());

                    strcmd += ", TO_DATE(TO_CHAR(sysdate,'YYYY/MM/DD HH24:MI:SS'),'YYYY/MM/DD HH24:MI:SS')";

                    strcmd += ", TO_DATE(TO_CHAR(sysdate,'YYYY/MM/DD HH24:MI:SS'),'YYYY/MM/DD HH24:MI:SS')";

                    strcmd = strcmd + ")";

                    if (!ExecuteNonQuery(strcmd, bConnect)) return false;

                }

                return true;

            }

            catch (Exception ex)

            {

                logger.ErrorFormat("システムエラー：：{0}：{1}：{2}", CommonMotions.GetMethodName(2), ex.Message, strcmd);

                return false;

            }

        }

        /// <summary>

        /// 工事項目マスタ更新

        /// </summary>

        /// <param name="AddSQLString">更新条件SQL文字列</param>

        /// <param name="data">工事項目マスタデータ</param>

        /// <returns>true：成功 false：失敗</returns>

        public bool UpdateAction(string AddSQLString, ConstructionItemOLDMaster data, bool bConnect = true)

        {

            string strcmd = "";

            try

            {

                strcmd = "UPDATE ConstructionItemMaster_OLD";

                strcmd += " SET";

                strcmd += string.Format(" ComponentCode = {0}", data.ComponentCode.ToString());

                strcmd += string.Format(",ItemCode = {0}", data.ItemCode.ToString());

                strcmd += string.Format(",DisplayOrder = {0}", data.DisplayOrder.ToString());

                strcmd += string.Format(",ItemName = '{0}'", data.ItemName);

                strcmd += string.Format(",SubitemsFlg = {0}", data.SubitemsFlg.ToString());

                strcmd += string.Format(",DeleteFlg = {0}", data.DeleteFlg.ToString());

                strcmd += ", UpdateDate = TO_DATE(TO_CHAR(sysdate,'YYYY/MM/DD HH24:MI:SS'),'YYYY/MM/DD HH24:MI:SS')";

                strcmd += AddSQLString;

                if (!ExecuteNonQuery(strcmd, bConnect)) return false;

                return true;

            }

            catch (Exception ex)

            {

                logger.ErrorFormat("システムエラー：：{0}：{1}：{2}", CommonMotions.GetMethodName(2), ex.Message, strcmd);

                return false;

            }

        }

        /// <summary>

        /// 工事項目マスタ削除

        /// </summary>

        /// <param name="AddSQLString">削除条件SQL文字列</param>

        /// <param name="data">工事項目マスタデータ</param>

        /// <returns>true：成功 false：失敗</returns>

        public bool DeleteAction(string AddSQLString, bool bConnect = true)

        {

            //Oracle インターフェース

            string strcmd = "";

            try

            {

                strcmd = string.Format("{0}{1}", "DELETE FROM ConstructionItemMaster_OLD", AddSQLString);

                if (!ExecuteNonQuery(strcmd, bConnect)) return false;

                return true;

            }

            catch (Exception ex)

            {

                logger.ErrorFormat("システムエラー：：{0}：{1}：{2}", CommonMotions.GetMethodName(2), ex.Message, strcmd);

                return false;

            }

        }

        /// <summary>

        /// 論理削除

        /// </summary>

        /// <param name="ItemCode">カテゴリタイプ</param>

        /// <param name="Key2">名称コード</param>

        /// <param name="Key3">登録履歴</param>

        /// <returns>成功時：true　失敗時：false</returns>

        public bool LogicalDeleteAction(int ComponentCode, int ItemCode, bool bConnect = true)

        {

            // Where文字列作成

            string strWhere = CreatePrimarykeyString(ComponentCode, ItemCode);

            try

            {

                List<ConstructionItemOLDMaster> workList = new List<ConstructionItemOLDMaster>();

                // データ読込

                if (SelectAction(strWhere, ref workList, bConnect))

                {

                    if (workList.Count == 0) return true;

                    // 削除フラグ

                    workList[0].DeleteFlg = 1;

                    // データ更新

                    if (!UpdateAction(strWhere, workList[0], bConnect))

                    {

                        rollback();

                        return false;

                    }

                }

                return true;

            }

            catch (Exception ex)

            {

                logger.ErrorFormat("システムエラー：：{0}：{1}：{2}", CommonMotions.GetMethodName(2), ex.Message, strWhere);

                return false;

            }

        }

        /// <summary>

        /// OracleDataReaderより構造体へセットする

        /// </summary>

        /// <param name="reader">OracleDataReader</param>

        /// <param name="wrk">構造体</param>

        public void Reader2Struct(object[] objwrk, ref ConstructionItemOLDMaster wrk)

        {

            try

            {

                // データ取得

                wrk.ComponentCode = CommonMotions.cnvInt(objwrk[(int)NameColumn.ComponentCode].ToString());

                wrk.ItemCode = CommonMotions.cnvInt(objwrk[(int)NameColumn.ItemCode].ToString());

                wrk.DisplayOrder = CommonMotions.cnvInt(objwrk[(int)NameColumn.DisplayOrder].ToString());

                wrk.ItemName = objwrk[(int)NameColumn.ItemName].ToString();

                wrk.SubitemsFlg = CommonMotions.cnvInt(objwrk[(int)NameColumn.SubitemsFlg].ToString());

                wrk.DeleteFlg = CommonMotions.cnvInt(objwrk[(int)NameColumn.DeleteFlg].ToString());

                wrk.EntryDate = DateTime.Parse(objwrk[(int)NameColumn.EntryDate].ToString());

                wrk.UpdateDate = DateTime.Parse(objwrk[(int)NameColumn.UpdateDate].ToString());

            }

            catch (OracleException oraex)

            {

                logger.ErrorFormat("オラクルエラー：{0}：{1}", CommonMotions.GetMethodName(), oraex.Message);

            }

            catch (Exception ex)

            {

                logger.ErrorFormat("システムエラー：：{0}：{1}：{2}", CommonMotions.GetMethodName(), ex.Message);

            }

        }

        #endregion

        #region パブリックメソッド（特殊処理）

        /// <summary>

        /// 最大値を取得する

        /// </summary>

        /// <param name="AddSQLString"></param>

        /// <param name="bConnect"></param>

        /// <returns></returns>

        public int SelectMaxItemCodeCount(string AddSQLString, bool bConnect = true)

        {

            //Oracle インターフェース

            string strcmd = "";

            ArrayList arData = new ArrayList();

            int iRet = 0;

            try

            {

                // SQL作成

                strcmd = "SELECT MAX(ItemCode) FROM ConstructionItemMaster_OLD" + AddSQLString;

                // SQL実行

                if (!ExecuteReader(strcmd, ref arData, bConnect)) return iRet;

                // データセット

                foreach (object[] objwrk in arData)