BankingSystem/Repository/DAO/SendTxnIRHDao/SendTxnIRHDao.cs

using Common.Model.BankModel;
using Common.Utility;
using Repository.Model;
using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace Repository.DAO.SendTxnIRHDao
{
    public class SendTxnIRHDao : RemittanceDao
    {
        public DataTable LoadReceiverData(string user, string tranId)
        {
            var sql = "EXEC proc_sendPageLoadData @flag = 'receiverDataBySender'";
            sql += ", @user = " + FilterString(user);
            sql += ", @RECEIVERID = " + FilterString(tranId);

            return ExecuteDataTable(sql);
        }
        public DataTable LoadDataFromDdl(string sCountryid, string pCountry, string collMode, string agentId, string flag, string user)
        {
            //var sql = "EXEC proc_dropDownLists @flag = 'collModeByCountry'";
            //sql += ", @param = " + FilterString(pCountry);

            var sql = "EXEC proc_sendPageLoadData @flag =" + FilterString(flag);
            sql += ", @countryId = " + FilterString(sCountryid);
            sql += ", @pCountryId = " + FilterString(pCountry);
            sql += ", @param = " + FilterString(collMode);
            sql += ", @agentId = " + FilterString(agentId);
            sql += ", @user = " + FilterString(user);

            var ds = ExecuteDataset(sql);

            if (ds == null || ds.Tables.Count == 0 || ds.Tables[0].Rows.Count == 0)
                return null;
            return ds.Tables[0];
        }
        public DataTable LoadCustomerRate(string user, string sCountryId, string sSuperAgent, string sAgent, string sBranch, string collCurr,
                                        string pCountryId, string pAgent, string pCurr, string deliveryMethod)
        {
            var sql = "EXEC proc_sendIRH @flag = 'customerRate'";
            sql += ", @user = " + FilterString(user);
            sql += ", @sCountryId = " + FilterString(sCountryId);
            sql += ", @sAgent = " + FilterString(sAgent);
            sql += ", @sSuperAgent = " + FilterString(sSuperAgent);
            sql += ", @sBranch = " + FilterString(sBranch);
            sql += ", @collCurr = " + FilterString(collCurr);
            sql += ", @pCountryId = " + FilterString(pCountryId);
            sql += ", @pAgent = " + FilterString(pAgent);
            sql += ", @pCurr = " + FilterString(pCurr);
            sql += ", @deliveryMethod = " + FilterString(deliveryMethod);

            var ds = ExecuteDataset(sql);

            if (ds == null || ds.Tables.Count == 0 || ds.Tables[0].Rows.Count == 0)
                return null;
            return ds.Tables[0];
        }
        public DataTable LoadPayCurr(string pCountry, string pMode = "", string pAgent = "")
        {
            var sql = "EXEC proc_sendPageLoadData @flag = 'pcurr'";
            sql += ", @countryId = " + FilterString(pCountry);
            sql += ", @pMode = " + FilterString(pMode);
            sql += ", @pAgent = " + FilterString(pAgent);
            var ds = ExecuteDataset(sql);
            return ds.Tables[0];
        }
        public DataTable GetAgentSetting(string user, string countryId, string agentId, string deliveryMethodId, string pBankType)
        {
            var sql = "EXEC proc_sendPageLoadData @flag = 'agentsetting'";
            sql += ", @user = " + FilterString(user);
            sql += ", @countryId = " + FilterString(countryId);
            sql += ", @agentId = " + FilterString(agentId);
            sql += ", @deliveryMethodId = " + FilterString(deliveryMethodId);
            sql += ", @pBankType = " + FilterString(pBankType);

            return ExecuteDataTable(sql);
        }

        public DataTable GetPayoutPartner(string user, string pCountry, string pMode)
        {
            string sql = "EXEC PROC_API_ROUTE_PARTNERS @flag='payout-partner'";
            sql += " , @CountryId = " + FilterString(pCountry);
            sql += " , @PaymentMethod = " + FilterString(pMode);
            sql += " , @user = " + FilterString(user);

            return ExecuteDataTable(sql);
        }
        public IList<BranchModel> LoadBranchByAgent(BankSearchModel bankSearchModel)
        {
            var sql = "EXEC proc_sendPageLoadData @flag = 'branchByBank'";
            sql += ", @user = " + FilterString(bankSearchModel.User);
            sql += ", @param = " + FilterString(bankSearchModel.SearchValue);
            sql += ", @agentId = " + FilterString(bankSearchModel.PAgent);
            sql += ", @countryId = " + FilterString(bankSearchModel.PCountryName);
            sql += ", @partnerId = " + FilterString(bankSearchModel.PayoutPartner);
            sql += ", @deliveryMethodId = " + FilterString(bankSearchModel.PaymentMode);

            DataTable dt = ExecuteDataTable(sql);

            return Mapper.DataTableToClass<BranchModel>(dt);
        }
        public DataTable GetExRateTP(string user, string sCountryId, string sSuperAgent, string sAgent, string sBranch, string collCurr,
                                        string pCountryId, string pAgent, string pCurr, string deliveryMethod, string cAmt, string pAmt,
                                        string schemeCode, string senderId, string sessionId, string couponId
                                        , string isManualSc, string sc
                                        , string exRateTp, string pCurrTp)
        {
            var sql = "EXEC proc_sendIRHTP @flag = 'exRate'";
            sql += ", @user = " + FilterString(user);
            sql += ", @sCountryId = " + FilterString(sCountryId);
            sql += ", @sAgent = " + FilterString(sAgent);
            sql += ", @sSuperAgent = " + FilterString(sSuperAgent);
            sql += ", @sBranch = " + FilterString(sBranch);
            sql += ", @collCurr = " + FilterString(collCurr);
            sql += ", @pCountryId = " + FilterString(pCountryId);
            sql += ", @pAgent = " + FilterString(pAgent);
            sql += ", @pCurr = " + FilterString(pCurr);
            sql += ", @deliveryMethod = " + FilterString(deliveryMethod);
            sql += ", @cAmt = " + FilterString(cAmt);
            sql += ", @pAmt = " + FilterString(pAmt);
            sql += ", @schemeCode = " + FilterString(schemeCode);
            sql += ", @senderId = " + FilterString(senderId);
            sql += ", @sessionId = " + FilterString(sessionId);
            sql += ", @couponTranNo = " + FilterString(couponId);
            sql += ", @tpExRate = " + FilterString(exRateTp);
            sql += ", @tpPCurr = " + FilterString(pCurrTp);
            sql += ", @isManualSc = " + FilterString(isManualSc);
            sql += ", @manualSc = " + FilterString(sc);

            var ds = ExecuteDataset(sql);

            if (ds == null || ds.Tables.Count == 0 || ds.Tables[0].Rows.Count == 0)
                return null;
            return ds.Tables[0];
        }
        public DataTable GetExRate(string user, string sCountryId, string sSuperAgent, string sAgent, string sBranch, string collCurr,
                                string pCountryId, string pAgent, string pCurr, string deliveryMethod, string cAmt, string pAmt,
                                string schemeCode, string senderId, string sessionId, string couponId, string isManualSc = "", string sc = "")
        {
            var sql = "EXEC proc_sendIRH @flag = 'exRate'";
            sql += ", @user = " + FilterString(user);
            sql += ", @sCountryId = " + FilterString(sCountryId);
            sql += ", @sAgent = " + FilterString(sAgent);
            sql += ", @sSuperAgent = " + FilterString(sSuperAgent);
            sql += ", @sBranch = " + FilterString(sBranch);
            sql += ", @collCurr = " + FilterString(collCurr);
            sql += ", @pCountryId = " + FilterString(pCountryId);
            sql += ", @pAgent = " + FilterString(pAgent);
            sql += ", @pCurr = " + FilterString(pCurr);
            sql += ", @deliveryMethod = " + FilterString(deliveryMethod);
            sql += ", @cAmt = " + FilterString(cAmt);
            sql += ", @pAmt = " + FilterString(pAmt);
            sql += ", @schemeCode = " + FilterString(schemeCode);
            sql += ", @senderId = " + FilterString(senderId);
            sql += ", @sessionId = " + FilterString(sessionId);
            sql += ", @couponTranNo = " + FilterString(couponId);
            sql += ", @isManualSc = " + FilterString(isManualSc);
            sql += ", @manualSc = " + FilterString(sc);

            var ds = ExecuteDataset(sql);

            if (ds == null || ds.Tables.Count == 0 || ds.Tables[0].Rows.Count == 0)
                return null;
            return ds.Tables[0];
        }

        public DbResult SaveSendRequest(string user, SendTransactionModel sendTxn)
        {
            var sql = "EXEC proc_sendRequest @flag = 'sendRequest'";
            sql += ", @user = " + FilterString(user);
            sql += ", @idNumber = " + FilterString(sendTxn.IdNumber);
            sql += ", @receiverFullName = " + FilterString(sendTxn.ReceiverFullName);
            sql += ", @receiveraddress = " + FilterString(sendTxn.Receiveraddress);
            sql += ", @receiverMobileNumber = " + FilterString(sendTxn.ReceiverMobileNumber);
            sql += ", @pCountryId = " + FilterString(sendTxn.PCountryId);
            sql += ", @pModeId = " + FilterString(sendTxn.PmodeId);
            sql += ", @pagentId = " + FilterString(sendTxn.PagentId);
            sql += ", @branchId = " + FilterString(sendTxn.BranchId);
            sql += ", @accountNumber = " + FilterString(sendTxn.AccountNumber);
            sql += ", @cAmt = " + FilterString(sendTxn.CAmt);
            sql += ", @tamt = " + FilterString(sendTxn.Tamt);
            sql += ", @serviceCharge = " + FilterString(sendTxn.ServiceCharge);
            sql += ", @purposeOfRemittanceId = " + FilterString(sendTxn.PurposeOfRemittance);
            sql += ", @otherPurposeOfRemittance = " + FilterString(sendTxn.OtherPurposeOfRemittance);
            sql += ", @relationShipId = " + FilterString(sendTxn.RelationShip);
            sql += ", @otherRelation = " + FilterString(sendTxn.OtherRelationShip);
            sql += ", @referralName = " + FilterString(sendTxn.ReferralName);
            sql += ", @branchManual = " + FilterString(sendTxn.BranchManual);
            sql += ", @bankName = " + FilterString(sendTxn.bankName);
            sql += ", @branchName = " + FilterString(sendTxn.branchName);


            DbResult dr = ParseDbResult(sql);
            return dr;
        }
        public DataTable ValidateData(string user, string customerIdNumber)
        {
            var sql = "EXEC proc_sendRequest @flag = 'validateData'";
            sql += ", @user = " + FilterString(user);
            sql += ", @idNumber = " + FilterString(customerIdNumber);

            DataTable dr = ExecuteDataTable(sql);
            return dr;
        }
        public DataTable GetBenefeciaryDetails(string user, string benefeciaryId)
        {
            var sql = "EXEC proc_sendPageLoadData @flag = 'receiverDataBySender'";
            sql += ", @user = " + FilterString(user);
            sql += ", @RECEIVERID = " + FilterString(benefeciaryId);

            DataTable dr = ExecuteDataTable(sql);
            return dr;
        }
    }
}