using CnasSynchronousCommon;
using CnasSynchronusIDAL;
using CnasSynchrousModel;
using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Text;

namespace CnasSynchronusDAL
{
    public class OracleDBService : IOracleService
    {
        public bool CheckMacMessage(DataBaseInfo dataBase, string strMac)
        {
            OracleDAL.CreateConnection(dataBase.DBHost, dataBase.DBName, dataBase.DBUser, dataBase.DBPwd, dataBase.DBPort);
            return OracleDAL.CheckMacMessage(strMac);
        }

        public DataTable GetAllCNASTablesName(DataBaseInfo dataBase)
        {
            OracleDAL.CreateConnection(dataBase.DBHost, dataBase.DBName, dataBase.DBUser, dataBase.DBPwd, dataBase.DBPort);
            return OracleDAL.GetTableNames(dataBase.DBName);
        }

        public DataTable GetCNASTablesStruct(string strTableName, DataBaseInfo dataBase)
        {
            OracleDAL.CreateConnection(dataBase.DBHost, dataBase.DBName, dataBase.DBUser, dataBase.DBPwd, dataBase.DBPort);
            return OracleDAL.GetTableStruct(strTableName, "", "");
        }

        public DataTable GetCNASTableTypeLenth(string strTableName, DataBaseInfo dataBase)
        {
            OracleDAL.CreateConnection(dataBase.DBHost, dataBase.DBName, dataBase.DBUser, dataBase.DBPwd, dataBase.DBPort);
            return OracleDAL.GetTableTypeAndLenth(strTableName);
        }

        public Dictionary<string, DataTable> GetInstrumentData(OracleOpenParams t)
        {
            OracleDAL.CreateConnection(t.StrHost, t.StrServer, t.StrUser, t.StrPwd, t.StrPort);
            return OracleDAL.GetAllTableNameAndStructure(t.StrUser);
        }

        public DataTable GetInstrumentDataByDate(OracleOpenParams t, ConditionParams u)
        {
            OracleDAL.CreateConnection(t.StrHost, t.StrServer, t.StrUser, t.StrPwd, t.StrPort);
            return OracleDAL.GetDataByDateColumn(
                t.autoSql.OracleViewName,
                t.autoSql.OracleViewSql,
                u.TableName, 
                u.DateColumn, 
                u.DateValue);
        }

        public DataTable GetInstrumentDataStruct(OracleOpenParams t, ConditionParams u)
        {
            OracleDAL.CreateConnection(t.StrHost, t.StrServer, t.StrUser, t.StrPwd,t.StrPort);
            return OracleDAL.GetTableDataStruct(
                t.autoSql.OracleViewName,
                t.autoSql.OracleViewSql,
                u.TableName
                );
        }

        public DataTable GetLoginNameByPwd(DataBaseInfo dataBase, string strUserName, string strPwd)
        {
            OracleDAL.CreateConnection(dataBase.DBHost, dataBase.DBName, dataBase.DBUser, dataBase.DBPwd, dataBase.DBPort);
            strPwd = EncryptionOperation.GetMD5Hash(strPwd);
            return OracleDAL.GetLoginNameByPwd(strUserName, strPwd);
        }

        public string GetMaxTimeByTableName(DataBaseInfo dataBase, string strTableName, string strDateColumn, string strInstrumentColumn, string strInstrumentValue)
        {
            OracleDAL.CreateConnection(dataBase.DBHost, dataBase.DBName, dataBase.DBUser, dataBase.DBPwd, dataBase.DBPort);
            return OracleDAL.GetMaxTimeByTableName(strTableName, strDateColumn, strInstrumentColumn, strInstrumentValue);
        }

        public DataTable GetTableData(DataBaseInfo dataBase, string strSql)
        {
            throw new NotImplementedException();
        }

        public int InsertDataToCNASTable(DataTable dt, DataBaseInfo dataBase, List<SyncParamasInfo> syncParamasInfos, string strInstrumentColumn, List<CnasConditionMapValue> lstFixedValue = null)
        {
            OracleDAL.CreateConnection(dataBase.DBHost, dataBase.DBName, dataBase.DBUser, dataBase.DBPwd, dataBase.DBPort);
            return OracleDAL.InsertCnasData(dt, syncParamasInfos, lstFixedValue, strInstrumentColumn);
        }

        public bool InsertTableData(DataBaseInfo dataBase, string strSql)
        {
            throw new NotImplementedException();
        }

        public bool TestConnect(string strHost, string strName, string strUser, string strPwd, string strPort)
        {
            OracleDAL.CreateConnection(strHost, strName, strUser, strPwd, strPort);
            return OracleDAL.TestLink();
        }
    }
}