using System;

using System.Data.OracleClient;
using NLog;

namespace CCSTrace.CCS.Object
{
    public class LocateEquipment
    {
        private static readonly Logger Logger = LogManager.GetCurrentClassLogger();

        private int _caseId = 0;
        private int _dsUfid = -1;
        private int _fsc = 0;
        private int _ufid = 0;
        private string _fdr = "";
        private string _tpclid = "";

        public LocateEquipment(int mCaseId, bool hasData, OracleConnection conn, OracleTransaction transaction)
        {
            OracleCommand command = null;
            OracleDataReader reader = null;

            CaseId = mCaseId;

            try
            {
                string sqlStmt;
                if (hasData)
                {
                    sqlStmt = "SELECT DSUFID,FSC,UFID,FDR,TPCLID FROM EOS.EVENTRECORD_EX WHERE CASEID = " + mCaseId;

                    command = new OracleCommand(sqlStmt, conn, transaction);
                    reader = command.ExecuteReader();

                    if (reader.Read())
                    {
                        DsUfid =Convert.ToInt32(reader["DSUFID"].ToString());
                        Fsc = Convert.ToInt32(reader["FSC"].ToString());
                        Ufid = Convert.ToInt32(reader["UFID"].ToString());
                        Fdr = reader["FDR"].ToString();
                        Tpclid = reader["TPCLID"].ToString();
                    }
                }
                else
                {
                    sqlStmt = "SELECT UFID FROM EOS.DISASTER_EX WHERE ISDISASTER = " + GlobalVariable.IsDisaster;

                    command = new OracleCommand(sqlStmt, conn, transaction);
                    reader = command.ExecuteReader();

                    if (reader.Read())
                        DsUfid = Convert.ToInt32(reader["UFID"].ToString());
                }
            }
            catch (Exception e)
            {
                Logger.Warn(e, e.Message);
            }
            finally
            {
                reader?.Close();
                command?.Dispose();
            }
        }

        public int CaseId
        {
            get { return _caseId; }
            set { _caseId = value; }
        }

        public int DsUfid
        {
            get { return _dsUfid; }
            set { _dsUfid = value; }
        }

        public int Fsc
        {
            get { return _fsc; }
            set { _fsc = value; }
        }

        public int Ufid
        {
            get { return _ufid; }
            set { _ufid = value; }
        }

        public string Fdr
        {
            get { return _fdr; }
            set { _fdr = value; }
        }

        public string Tpclid
        {
            get { return _tpclid; }
            set { _tpclid = value; }
        }

        public string GetInsertSqlStmt()
        {
            var sqlStmt = "INSERT INTO EOS.EVENTRECORD_EX (CASEID,DSUFID,FSC,UFID,TPCLID,FDR) VALUES(" + CaseId + "," + DsUfid + "," + Fsc
                             + "," + Ufid + ",'" + Tpclid + "','" + Fdr + "')";
            return sqlStmt;
        }

        //public String getUpdateSqlStmt()
        //{
        //    String SqlStmt;

        //    SqlStmt = "UPDATE EOS.EVENTRECORD_EX SET DSUFID = " + getDSUFID() + ",FSC = " + getFSC() + ",UFID = " + getUFID() + ",TPCLID = '"
        //            + getTPCLID() + "',FDR = '" + getFDR() + "' WHERE CASEID = " + getCaseID();

        //    return SqlStmt;
        //}
    }
}