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



Microsoft Visual Studio Solution File, Format Version 12.00

# Visual Studio 2013

VisualStudioVersion = 12.0.40629.0

MinimumVisualStudioVersion = 10.0.40219.1

Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "ProcessManagement", "ProcessManagement\ProcessManagement.csproj", "{BAF227D6-7D1E-4D46-AD17-B93F2C60E41B}"

EndProject

Global

	GlobalSection(SolutionConfigurationPlatforms) = preSolution

		Debug|Any CPU = Debug|Any CPU

		Debug|Mixed Platforms = Debug|Mixed Platforms

		Debug|x64 = Debug|x64

		Debug|x86 = Debug|x86

		Release|Any CPU = Release|Any CPU

		Release|Mixed Platforms = Release|Mixed Platforms

		Release|x64 = Release|x64

		Release|x86 = Release|x86

	EndGlobalSection

	GlobalSection(ProjectConfigurationPlatforms) = postSolution

		{BAF227D6-7D1E-4D46-AD17-B93F2C60E41B}.Debug|Any CPU.ActiveCfg = Debug|x86

		{BAF227D6-7D1E-4D46-AD17-B93F2C60E41B}.Debug|Any CPU.Build.0 = Debug|x86

		{BAF227D6-7D1E-4D46-AD17-B93F2C60E41B}.Debug|Mixed Platforms.ActiveCfg = Debug|x86

		{BAF227D6-7D1E-4D46-AD17-B93F2C60E41B}.Debug|Mixed Platforms.Build.0 = Debug|x86

		{BAF227D6-7D1E-4D46-AD17-B93F2C60E41B}.Debug|x64.ActiveCfg = Debug|x64

		{BAF227D6-7D1E-4D46-AD17-B93F2C60E41B}.Debug|x64.Build.0 = Debug|x64

		{BAF227D6-7D1E-4D46-AD17-B93F2C60E41B}.Debug|x86.ActiveCfg = Debug|x86

		{BAF227D6-7D1E-4D46-AD17-B93F2C60E41B}.Debug|x86.Build.0 = Debug|x86

		{BAF227D6-7D1E-4D46-AD17-B93F2C60E41B}.Release|Any CPU.ActiveCfg = Release|x86

		{BAF227D6-7D1E-4D46-AD17-B93F2C60E41B}.Release|Any CPU.Build.0 = Release|x86

		{BAF227D6-7D1E-4D46-AD17-B93F2C60E41B}.Release|Mixed Platforms.ActiveCfg = Release|x86

		{BAF227D6-7D1E-4D46-AD17-B93F2C60E41B}.Release|Mixed Platforms.Build.0 = Release|x86

		{BAF227D6-7D1E-4D46-AD17-B93F2C60E41B}.Release|x64.ActiveCfg = Release|x86

		{BAF227D6-7D1E-4D46-AD17-B93F2C60E41B}.Release|x64.Build.0 = Release|x86

		{BAF227D6-7D1E-4D46-AD17-B93F2C60E41B}.Release|x86.ActiveCfg = Release|x86

		{BAF227D6-7D1E-4D46-AD17-B93F2C60E41B}.Release|x86.Build.0 = Release|x86

	EndGlobalSection

	GlobalSection(SolutionProperties) = preSolution

		HideSolutionNode = FALSE

	EndGlobalSection

EndGlobal

using System;

using System.Collections.Generic;

using System.Collections;

using System.Data;

using System.Linq;

using System.Text;

using Oracle.ManagedDataAccess.Client;

using log4net;

using log4net.Appender;

using log4net.Repository.Hierarchy;

using ProcessManagement.DB.Core;

namespace ProcessManagement.DB.Oracle

{

    /// <summary>

    /// Oracle使用共通ラッパークラス

    /// </summary>

    public class OracleProcess : ABaseDBProcess

    {

        #region コンストラクタ

        /// <summary>

        /// コンストラクタ。

        /// </summary>

        /// <param name="connectionString">接続文字列</param>

        public OracleProcess(String connectionString)

            : base(connectionString)

        {

        }

        #endregion

        #region メソッド

        /// <summary>

        /// Connectionを取得。

        /// </summary>

        /// <param name="connectionString"></param>

        /// <returns>Connection</returns>

        public override IDbConnection getConnection(String connectionString)

        {

            return new OracleConnection(connectionString);

        }

        #endregion 

    }

}

using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

using log4net;

using ProcessManagement.Common;

namespace ProcessManagement.DB.Core

{

    /// <summary>

    /// データベース共通接続クラス

    /// </summary>

    public class DBCommon

    {

        #region 定義部

        /// <summary>

        /// データベース接続共通クラスインスタンスハンドル

        /// </summary>

        private static DBCommon m_instance = new DBCommon();

        /// <summary>

        /// log4netログを使用する

        /// </summary>

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

        #endregion

        #region 変数

        /// <summary>

        /// DB接続情報

        /// </summary>

        private string m_dbconnectString = string.Empty;

        #endregion

        #region コンストラクタ

        /// <summary>

        /// 何もしない

        /// </summary>

        #endregion

        #region プロパティ

        /// <summary>

        ///インスタンス

        /// </summary>

        public static DBCommon Instance

        {

            get { return m_instance; }

        }

        /// <summary>

        /// 接続文字列取得

        /// </summary>

        public string DBConnectString

        {

            get { return m_dbconnectString; }

        }

        #endregion

        #region メソッド

        /// <summary>

        /// 初期化メソッド

        /// </summary>

        public void Initialize()

        {

            // DB接続情報作成

            m_dbconnectString = string.Format("User Id={0};", CommonMotions.DFRModel.DBConnect.DBUser);

            m_dbconnectString += string.Format("Password={0};", CommonMotions.DFRModel.DBConnect.Password);

            m_dbconnectString += string.Format("Data Source={0};", CommonMotions.DFRModel.DBConnect.DBDataSource);

            //m_dbconnectString += "Pooling=false";

        }

        #endregion

    }

}

using System;

using System.Collections.Generic;

using System.Data;

using System.Linq;

using System.Text;

using System.Collections;

/// Oracle

using Oracle.ManagedDataAccess.Types;

using Oracle.ManagedDataAccess.Client;

using log4net;

using log4net.Appender;

using log4net.Repository.Hierarchy;

using ProcessManagement.Common;

namespace ProcessManagement.DB.Core

{

    /// <summary>

    /// データベース共通抽象クラス

    /// </summary>

    public abstract class ABaseDBProcess : IBaseDB

    {

        #region ログ定義

        /// <summary>

        /// log4netログを使用する

        /// </summary>

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

        #endregion

        #region メンバ変数

        /// <summary>

        /// DB接続

        /// </summary>

        protected IDbConnection m_connection = null;

        /// <summary>

        /// 接続有無(true:接続中)

        /// </summary>

        protected bool m_isConnect = false;

        /// <summary>

        /// トランザクション

        /// </summary>

        protected IDbTransaction m_transaction = null;

        /// <summary>

        /// 接続文字列

        /// </summary>

        protected String m_connectionString = null;

        #endregion

        #region コンストラクタ

        /// <summary>

        /// コンストラクタ

        /// </summary>

        /// <param name="connectionString">接続文字列</param>

        public ABaseDBProcess(String connectionString)

        {

            //接続文字列セット

            this.m_connectionString = connectionString;

        }

        #endregion

        #region プロパティ

        /// <summary>

        /// DCコネクション

        /// </summary>

        public IDbConnection DBConnection

        {

            get { return m_connection; }

            set { m_connection = value; }

        }

        #endregion

        #region プライベートメソッド

        /// <summary>

        /// 接続の確立判断。

        /// </summary>

        /// <returns>true：接続確立 false：接続無</returns>

        private bool isConnect()

        {

            //接続されていない場合

            if (this.m_connection == null || !this.m_isConnect) return false;

            return true;

        }

        /// <summary>

        /// パラメータの値を取得する

        /// </summary>

        /// <param name="value">値</param>

        /// <returns>パラメータの値</returns>

        protected object getParamValue(object value)

        {

            if (value != null) return value;

            return DBNull.Value;

        }

        #endregion

        #region コネクション接続

        /// <summary>

        /// Connectionを取得。

        /// </summary>

        /// <param name="connectionString"></param>

        /// <returns>Connectionのオブジェクト</returns>

        public virtual IDbConnection getConnection(String connectionString)

        {

            return new OracleConnection(connectionString);

        }

        #endregion

        #region connect

        /// <summary>

        /// コネクト処理。

        /// </summary>

        public void connect()

        {

            try

            {

                //接続有無＝無に設定

                this.m_isConnect = false;

                //接続済みの場合

                if (this.m_connection != null)

                {

                    //接続をClose

                    this.m_connection.Close();

                    //初期化

                    this.m_connection = null;

                }

                //Connectionを取得

                this.m_connection = getConnection(m_connectionString);

                //Open

                this.m_connection.Open();

                //接続有無＝ありに設定

                this.m_isConnect = true;

            }

            catch (Exception ex)

            {

                logger.ErrorFormat("{0}：{1}：{2}", CommonMotions.GetMethodName(2), ex.Message, m_connectionString);

            }

        }

        #endregion

        #region close

        /// <summary>

        /// クローズ処理。

        /// </summary>

        /// <returns>true：切断成功 false：接続無</returns>

        public bool close()

        {

            try

            {

                //接続が確立されていない場合は処理なし

                if (!isConnect()) return false;

                //トランザクションを破棄する

                if (this.m_transaction != null)

                {

                    this.m_transaction.Dispose();

                    this.m_transaction = null;

                }

                //接続をClose＆破棄する

                if (this.m_connection != null)

                {

                    this.m_connection.Close();

                    this.m_connection.Dispose();

                    this.m_connection = null;

                }

                //接続有無なしに設定

                this.m_isConnect = false;

                return true;

            }

            catch (Exception ex)

            {

                logger.ErrorFormat("{0}：{1}：{2}", CommonMotions.GetMethodName(2), ex.Message, m_connectionString);

                return false;

            }

        }

        #endregion

        #region begintran

        /// <summary>

        /// トランザクション開始。

        /// </summary>

        /// <returns>true：開始成功 false：接続無</returns>

        public bool beginTran()

        {

            try

            {

                //接続が確立されていない場合、処理なし

                if (!isConnect()) return false;

                //トランザクション開始

                this.m_transaction = m_connection.BeginTransaction();

                return true;

            }

            catch (Exception ex)

            {

                logger.ErrorFormat("{0}：{1}：{2}", CommonMotions.GetMethodName(2), ex.Message, m_connectionString);

                return false;

            }

        }

        #endregion

        #region commit

        /// <summary>

        /// コミット。

        /// </summary>

        /// <returns>true：Commit成功 false：トランザクション無・接続無</returns>

        public bool commit()

        {

            try

            {

                //接続が確立されていない場合は処理なし

                if (!isConnect()) return false;

                //トランザクションが開始されていない場合、処理なし

                if (this.m_transaction == null) return false;

                //コミット

                m_transaction.Commit();

                return true;

            }

            catch (Exception ex)

            {

                //ログ出力

                logger.ErrorFormat("{0}：{1}", CommonMotions.GetMethodName(2), ex.Message);

                return false;

            }

            finally

            {

                //トランザクションを破棄する

                if (this.m_transaction != null)

                {

                    this.m_transaction.Dispose();

                    this.m_transaction = null;

                }

            }

        }

        #endregion

        #region rollback

        /// <summary>

        /// ロールバック。

        /// </summary>

        /// <returns>true：Rollback成功 false：トランザクション無・接続無</returns>

        public bool rollback()

        {

            try

            {

                //接続が確立されていない場合は処理なし

                if (!isConnect()) return false;

                //トランザクションが開始されていない場合は処理なし

                if (this.m_transaction == null) return false;

                //ロールバック

                this.m_transaction.Rollback();

                return true;

            }

            catch (Exception ex)

            {

                //ログ出力

                logger.ErrorFormat("{0}：{1}", CommonMotions.GetMethodName(2), ex.Message);

                return false;

            }

            finally

            {

                //トランザクションを破棄する

                if (this.m_transaction != null)

                {

                    this.m_transaction.Dispose();

                    this.m_transaction = null;

                }

            }

        }

        #endregion

        #region ExecuteReader

        /// <summary>

        /// オラクルフリーSQLリーダー

        /// </summary>

        /// <param name="strSql">検索SQL</param>

        /// <param name="arData">取得データ</param>

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

        public bool ExecuteReader(string strSql, ref ArrayList arData, bool bconnect = true)

        {

            //Oracle インターフェース

            OracleCommand oracmd = new OracleCommand();

            OracleDataReader orareader = null;

            try

            {

                // 接続

                if (bconnect) this.connect();

                // OracleCommand・OracleDataReader作成

                oracmd.Connection = (OracleConnection)m_connection;

                // SQLセット

                oracmd.CommandText = strSql;

                orareader = oracmd.ExecuteReader();

                int iFeildcnt = oracmd.ExecuteReader().FieldCount;

                // 読込

                while (orareader.Read())

                {

                    object[] objwrk = new object[iFeildcnt];

                    orareader.GetOracleValues(objwrk);

                    // null抑制

                    int i = 0;

                    foreach (object www in objwrk)

                    {

                        objwrk[i++] = www.ToString().Equals("null") ? "" : www;

                    }

                    arData.Add(objwrk);

                }

                return true;

            }

            catch (OracleException oraex)

            {

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

                return false;

            }

            catch (Exception ex)

            {

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

                return false;

            }

            finally

            {

                if (orareader != null)

                {

                    orareader.Close();

                    orareader.Dispose();

                    orareader = null;

                }

                oracmd.Dispose();

                oracmd = null;

                // 切断

                if (bconnect) this.close();

            }

        }

        #endregion

        #region ExecuteNonQuery

        /// <summary>

        /// オラクルフリーExecuteNonQuery

        /// </summary>

        /// <param name="strSql">実行SQL</param>

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

        public bool ExecuteNonQuery(string strSql, bool bconnect = true)

        {

            //Oracle インターフェース

            OracleCommand oracmd = new OracleCommand();

            try

            {

                // 接続

                if (bconnect) this.connect();

                // コネクションセット

                oracmd.Connection = (OracleConnection)m_connection;

                // トランザクション

                if (bconnect)

                {

                    if (!this.beginTran()) return false;

                }

                // SQLセット

                oracmd.CommandText = strSql;

                //実行

                if (oracmd.ExecuteNonQuery() == 0)

                {

                    // エラー時rollbackして処理終了

                    if (bconnect) this.rollback();

                    return false;

                }

                // 成功時Commit

                if (bconnect)

                {

                    if (!this.commit()) return false;

                }

                return true;

            }

            catch (OracleException oraex)

            {

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

                return false;

            }

            catch (Exception ex)

            {

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

                return false;

            }

            finally

            {

                // 切断

                if (bconnect) this.close();

                oracmd.Dispose();

                oracmd = null;

            }

        }

        #endregion

    }

}

using System;

using System.Collections.Generic;

using System.Data;

using System.Linq;

using System.Text;

namespace ProcessManagement.DB.Core

{

    /// <summary>

    /// データベース共通インターフェースクラス

    /// </summary>

    public interface IBaseDB

    {

        /// <summary>

        /// コネクト処理。

        /// </summary>

        void connect();

        /// <summary>

        /// クローズ処理。

        /// </summary>

        bool close();

        /// <summary>

        /// トランザクション開始。

        /// </summary>

        bool beginTran();

        /// <summary>

        /// コミット。

        /// </summary>

        bool commit();

        /// <summary>

        /// ロールバック。

        /// </summary>

        bool rollback();

    }

}

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 IOProcessApproval : OracleProcess

    {

        #region 定義部

        /// <summary>

        /// log4netログを使用する

        /// </summary>

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

        #endregion

        #region 定数

        /// <summary>

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

        /// </summary>

        public enum ColumnName

        {

            ConstructionCode,

            ApprovalCode,

            OrderNo,

            SeqNo,

            PersonCode,

            PetitionApprovalDate,

            ApprovalLimitDates,

            ApprovalStatus,

            InputComment,

            EntryDate,

            UpdateDate

        }

        #endregion

        #region コンストラクタ

        /// <summary>

        /// コンストラクタ

        /// </summary>

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

        public IOProcessApproval()

            : 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 += " ConstructionCode";

            strcmd += ",ApprovalCode";

            strcmd += ",OrderNo";

            strcmd += ",SeqNo";

            strcmd += ",PersonCode";

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

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

            strcmd += ",ApprovalStatus";

            strcmd += ",InputComment";

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

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

            strcmd += " FROM ProcessApproval";

            return strcmd;

        }

        #endregion

        #region 承認データ検索（複数）

        /// <summary>

        /// 承認データ検索（複数）

        /// </summary>

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

        /// <param name="data"></param>

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

        /// <returns></returns>

        public bool SelectAction(string AddSQLString, ref List<ProcessApproval> 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)

                {

                    ProcessApproval work = new ProcessApproval();

                    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件）

        /// <summary>

        /// 承認データ検索（1件）

        /// </summary>

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

        /// <param name="data"></param>

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

        /// <returns></returns>

        public bool SelectAction(string AddSQLString, ref ProcessApproval 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;

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

                // データセット

                object[] objwrk = (object[])arData[0];

                Reader2Struct(objwrk, ref data);

                return true;

            }

            catch (Exception ex)

            {

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

                return false;

            }

        }

        #endregion

        #region 承認データ追加（複数）

        /// <summary>

        /// 承認データ追加（複数）

        /// </summary>

        /// <param name="data">承認データデータ</param>

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

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

        {

            string strcmd = "";

            try

            {

                foreach (ProcessApproval 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 承認データ追加（1件）

        /// <summary>

        /// 承認データ追加（1件）

        /// </summary>

        /// <param name="data"></param>

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

        /// <returns></returns>

        public bool InsertAction(ProcessApproval data, bool bConnect = true)

        {

            string strcmd = "";

            try

            {

                    strcmd = "INSERT INTO ProcessApproval";

                    strcmd += " (";

                    bool bFirst = true;

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

                    {

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

                        strcmd += gender.ToString();

                        bFirst = false;

                    }

                    strcmd += ") VALUES (";

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

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

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

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

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

                    strcmd += string.Format(", TO_DATE('{0}','YYYY/MM/DD HH24:MI:SS')", data.PetitionApprovalDate.ToString());

                    strcmd += string.Format(", TO_DATE('{0}','YYYY/MM/DD HH24:MI:SS')", data.ApprovalLimitDates.ToString());

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

                    strcmd += string.Format(",'{0}'", data.InputComment.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;

            }

        }

        #endregion

        #region 承認データ更新

        /// <summary>

        /// 承認データ更新

        /// </summary>

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

        /// <param name="data">承認データデータ</param>

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

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

        {

            string strcmd = "";

            try

            {

                strcmd = "UPDATE ProcessApproval";

                strcmd += " SET";

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

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

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

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

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

                strcmd += string.Format(",PetitionApprovalDate = TO_DATE('{0}','YYYY/MM/DD HH24:MI:SS')", data.PetitionApprovalDate.ToString());

                strcmd += string.Format(",ApprovalLimitDates = TO_DATE('{0}','YYYY/MM/DD HH24:MI:SS')", data.ApprovalLimitDates.ToString());

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

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

                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 ProcessApproval", 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 1項目更新処理

        /// <summary>

        /// 1項目の更新を行う

        /// </summary>

        /// <returns></returns>

        public bool UpdateFeild(int ConstructionCode, int FeildNo, object value, bool bConnect = true, int ApprovalCode = 0, int OrderNo = 0, int SeqNo = 0)

        {

            string strcmd = "";

            try

            {

                strcmd = "UPDATE ProcessApproval";

                strcmd += " SET";

                switch (FeildNo)

                {

                    case (int)ColumnName.ConstructionCode:

                        strcmd += string.Format(" ConstructionCode = {0}", ((int)value).ToString());

                        break;

                    case (int)ColumnName.ApprovalCode:

                        strcmd += string.Format(" ApprovalCode = {0}", ((int)value).ToString());

                        break;

                    case (int)ColumnName.OrderNo:

                        strcmd += string.Format(" OrderNo = {0}", ((int)value).ToString());

                        break;

                    case (int)ColumnName.SeqNo:

                        strcmd += string.Format(" SeqNo = {0}", ((int)value).ToString());

                        break;

                    case (int)ColumnName.PersonCode:

                        strcmd += string.Format(" PersonCode = {0}", ((int)value).ToString());

                        break;

                    case (int)ColumnName.PetitionApprovalDate:

                        strcmd += string.Format(" PetitionApprovalDate = TO_DATE('{0}','YYYY/MM/DD')", ((DateTime)value).ToShortDateString());

                        break;

                    case (int)ColumnName.ApprovalLimitDates:

                        strcmd += string.Format(" ApprovalLimitDates = TO_DATE('{0}','YYYY/MM/DD')", ((DateTime)value).ToShortDateString());

                        break;

                    case (int)ColumnName.ApprovalStatus:

                        strcmd += string.Format(" ApprovalStatus = {0}", ((int)value).ToString());

                        break;

                    case (int)ColumnName.InputComment:

                        strcmd += string.Format(" InputComment = '{0}'", value.ToString());

                        break;

                }

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

                strcmd += CreatePrimarykeyString(ConstructionCode, ApprovalCode, OrderNo, SeqNo);

                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 OracleDataReaderより構造体へセットする

        /// <summary>

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

        /// </summary>

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

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

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

        {

            try

            {

                // データ取得

                wrk.ConstructionCode = int.Parse(objwrk[(int)ColumnName.ConstructionCode].ToString());

                wrk.ApprovalCode = int.Parse(objwrk[(int)ColumnName.ApprovalCode].ToString());

                wrk.OrderNo = int.Parse(objwrk[(int)ColumnName.OrderNo].ToString());

                wrk.SeqNo = int.Parse(objwrk[(int)ColumnName.SeqNo].ToString());

                wrk.PersonCode = int.Parse(objwrk[(int)ColumnName.PersonCode].ToString());

                wrk.PetitionApprovalDate = DateTime.Parse(objwrk[(int)ColumnName.PetitionApprovalDate].ToString());

                wrk.ApprovalLimitDates = DateTime.Parse(objwrk[(int)ColumnName.ApprovalLimitDates].ToString());

                wrk.ApprovalStatus = int.Parse(objwrk[(int)ColumnName.ApprovalStatus].ToString());

                wrk.InputComment = objwrk[(int)ColumnName.InputComment].ToString();

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

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

            }

            catch (OracleException oraex)

            {

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

            }

            catch (Exception ex)

            {

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

            }

        }

        #endregion

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

        /// <summary>

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

        /// </summary>

        /// <param name="BusinessTypeCode"></param>

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

        public string CreatePrimarykeyString(int ConstructionCode, int ApprovalCode = 0, int OrderNo = 0, int SeqNo = 0, string APara = "")

        {

            string strWork = string.Empty;

            try

            {

                strWork = string.Format(" Where {0}ConstructionCode = {1}", APara, ConstructionCode.ToString());

                if (ApprovalCode != 0)

                    strWork += string.Format(" And {0}ApprovalCode = {1}", APara, ApprovalCode.ToString());

                if (OrderNo != 0)

                    strWork += string.Format(" And {0}OrderNo = {1}", APara, OrderNo.ToString());

                if (SeqNo != 0)

                    strWork += string.Format(" And {0}SeqNo = {1}", APara, SeqNo.ToString());

            }

            catch (Exception ex)

            {

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

            }

            return strWork;

        }

        #endregion

        #region 受付番号の最大値を取得する

        /// <summary>

        /// 受付番号の最大値を取得する

        /// </summary>

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

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

        /// <returns></returns>

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

        {

            //Oracle インターフェース

            string strcmd = "";

            ArrayList arData = new ArrayList();

            int iRet = 0;

            try

            {

                // SQL作成

                strcmd = "SELECT NVL(MAX(OrderNo), 0) FROM ProcessApproval" + 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

        #region 枝番の最大値を取得する

        /// <summary>

        /// 枝番の最大値を取得する

        /// </summary>

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

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

        /// <returns></returns>

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

        {

            //Oracle インターフェース

            string strcmd = "";

            ArrayList arData = new ArrayList();

            int iRet = 0;

            try

            {

                // SQL作成

                strcmd = "SELECT NVL(MAX(SeqNo), 0) FROM ProcessApproval" + 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 IOMTerm : OracleProcess

    {

        #region 定義部

        /// <summary>

        /// log4netログを使用する

        /// </summary>

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

        #endregion

        #region 定数

        /// <summary>

        /// 行動予定フィールド並び

        /// </summary>

        public enum NameColumn

        {

            ConstructionStatusFlg = 0,

            FieldNo,

            SeqNo,

            DisplayOrder,

            CheckSchdule,

            TermDays,

            SendTitle,

            SendMessage,

            BackColor,

            ForeColor,

            EntryDate,

            UpdateDate,

        }

        #endregion

        #region コンストラクタ

        /// <summary>

        /// コンストラクタ

        /// </summary>

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

        public IOMTerm()

            : 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<TermMaster> data, bool bConnect = true)

        {

            //Oracle インターフェース

            string strcmd = "";

            ArrayList arData = new ArrayList();

            try

            {

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

                strcmd = "SELECT";

                strcmd += "  ConstructionStatusFlg";

                strcmd += " ,FieldNo";

                strcmd += " ,SeqNo";

                strcmd += " ,DisplayOrder";

                strcmd += " ,CheckSchdule";

                strcmd += " ,TermDays";

                strcmd += " ,SendTitile";

                strcmd += " ,SendMessage";

                strcmd += " ,BackColor";

                strcmd += " ,ForeColor";

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

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

                strcmd += " FROM TermMaster";

                strcmd += AddSQLString;

                // SQL実行

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

                // データセット

                foreach (object[] objwrk in arData)

                {

                    TermMaster work = new TermMaster();

                    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 OneRecInsertAction(TermMaster data, bool bConnect = true)

        {

            string strcmd = "";

            try

            {

                strcmd = "INSERT INTO TermMaster";

                strcmd += " VALUES (";

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

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

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

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

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

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

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

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

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

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

                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;

            }

        }

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

        {

            string strcmd = "";

            try

            {

                foreach (TermMaster work in data)

                {

                    if (!OneRecInsertAction(work, 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, TermMaster data, bool bConnect = true)

        {

            string strcmd = "";

            try

            {

                strcmd = "UPDATE TermMaster";

                strcmd += " SET";

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

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

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

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

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

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

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

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

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

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

                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 TermMaster", 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>

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

        /// </summary>

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

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

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

        {

            try

            {

                // データ取得

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

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

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

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

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

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

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

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

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

                wrk.ForeColor = objwrk[(int)NameColumn.ForeColor].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}", CommonMotions.GetMethodName(), ex.Message);

            }

        }

        #endregion

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

        /// <summary>

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

        /// </summary>