using Swift.API.Common;
using Swift.DAL.Common;
using Swift.DAL.SwiftDAL;
using System;
using System.Data;

namespace Swift.DAL.OnlineAgent
{
    public class OnlineCustomerDao : RemittanceDao
    {
        public DbResult RegisterCustomer(OnlineCustomerModel onlineCustomerModel)
        {
            var sql = "EXEC proc_online_core_customerSetup";
            sql += " @Flag =" + FilterString(onlineCustomerModel.flag);
            sql += ",@customerId =" + FilterString(onlineCustomerModel.customerId);
            sql += ",@user = " + FilterString(onlineCustomerModel.createdBy);
            sql += ",@firstName=" + FilterString(onlineCustomerModel.firstName);
            sql += ",@middleName=" + FilterString(onlineCustomerModel.middleName);
            sql += ",@lastName1=" + FilterString(onlineCustomerModel.lastName1);
            sql += ",@custEmail=" + FilterString(onlineCustomerModel.email);
            sql += ",@custDOB=" + FilterString(onlineCustomerModel.dob);
            sql += ",@custAdd1=" + FilterString(onlineCustomerModel.address);
            sql += ",@occupation=" + FilterString(onlineCustomerModel.occupation);
            sql += ",@custCity=" + FilterString(onlineCustomerModel.city);
            sql += ",@custPostal=" + FilterString(onlineCustomerModel.postalCode);
            sql += ",@country=" + FilterString(onlineCustomerModel.country);
            sql += ",@custNativecountry=" + FilterString(onlineCustomerModel.nativeCountry.ToString());
            sql += ",@customerIdType=" + FilterString(onlineCustomerModel.idType);
            sql += ",@customerIdNo=" + FilterString(onlineCustomerModel.idNumber);
            sql += ",@custIdissueDate=" + FilterString(onlineCustomerModel.idIssueDate);
            sql += ",@custIdValidDate=" + FilterString(onlineCustomerModel.idExpiryDate);
            sql += ",@custMobile=" + FilterString(onlineCustomerModel.mobile);
            sql += ",@custTelNo=" + FilterString(onlineCustomerModel.telNo);
            sql += ",@ipAddress=" + FilterString(onlineCustomerModel.ipAddress);
            sql += ",@createdBy=" + FilterString(onlineCustomerModel.createdBy);
            sql += ",@custGender=" + FilterString(onlineCustomerModel.gender);
            sql += ",@verifyDoc1=" + FilterString(onlineCustomerModel.verifyDoc1);
            sql += ",@verifyDoc2=" + FilterString(onlineCustomerModel.verifyDoc2);
            sql += ",@verifyDoc3=" + FilterString(onlineCustomerModel.verifyDoc3);
            sql += ",@verifyDoc4=" + FilterString(onlineCustomerModel.verifyDoc4);
            sql += ",@bankId=" + FilterString(onlineCustomerModel.bankId);
            sql += ",@accountNumber=" + FilterString(onlineCustomerModel.accountNumber);
            sql += ",@HasDeclare=" + FilterString(onlineCustomerModel.HasDeclare.ToString());
            return ParseDbResult(sql);
        }

        public DataSet GetCustomerRegistrationStatusReport(string user, string customerId, string customerSource)
        {
            var sql = "EXEC proc_customerRegistrationStatus @flag ='get-registrationStatus'";
            sql += " ,@user =" + FilterString(user);
            sql += " ,@searchValue =" + FilterString(customerId);
            sql += " ,@customerSource =" + FilterString(customerSource);
            return ExecuteDataset(sql);
        }
        public DataTable GetCustomerComplianceDocumentByDocumentId(string customerId, string user, string tranId)
        {
            var sql = "EXEC proc_customerDocumentType @flag='getCustomerCompliance'";
            sql += " ,@user =" + FilterString(user);
            sql += " ,@cdId =" + FilterString(customerId);
            sql += " ,@rowIdField =" + FilterString(tranId);
            return ExecuteDataTable(sql);
        }

        public DataSet GetCustomerInfo(string user, string custId)
        {
            var sql = "EXEC proc_Customerinformation @flag='details'";
            sql += " ,@User =" + FilterString(user);
            sql += " ,@customerId =" + FilterString(custId);
            return ExecuteDataset(sql);
        }

        public DbResult ActivateMobileLogin(string user, string custId, string password, string referral = null, string membershipId = "")
        {
            var sql = "EXEC proc_online_approve_Customer";
            sql += " @Flag ='create-mobile-login'";
            sql += ",@customerId =" + FilterString(custId);
            sql += ",@user =" + FilterString(user);
            sql += ",@password =" + FilterString(password);
            sql += ",@referral =" + FilterString(referral);

            return ParseDbResult(sql);
        }

        public DataRow GetCustomerData(string user, string customerId)
        {
            var sql = "EXEC proc_online_core_customerSetup @flag='customerdetail'";
            sql += " ,@User =" + FilterString(user);
            sql += " ,@customerId =" + FilterString(customerId);

            return ExecuteDataRow(sql);
        }

        public DataRow GetCustomerDataForRefund(string user, string customerId)
        {
            var sql = "EXEC proc_customerRefund @flag='customerdetail'";
            sql += " ,@User =" + FilterString(user);
            sql += " ,@customerId =" + FilterString(customerId);

            return ExecuteDataRow(sql);
        }

        public DbResult AutoSetPassword(string User, string customerId)
        {
            var sql = "EXEC proc_online_core_customerSetup @flag='autosetpwd'";
            sql += " ,@User =" + FilterString(User);
            sql += " ,@customerId =" + FilterString(customerId);

            return ParseDbResult(sql);
        }

        public JsonResponse ResetPasswordMobile(PasswordReset pwdReset)
        {
            var sql = "EXEC JsonRx_Proc_UserRegistration @flag='pwd-reset-core' ";
            sql += ", @customerId = " + FilterString(pwdReset.CustomerId);
            sql += ", @randomPassword = " + FilterString(pwdReset.RandomPassword);
            sql += ", @user = " + FilterString(pwdReset.User);
            var res = ParseDbResult(sql);
            return new JsonResponse { ResponseCode = res.ErrorCode, Msg = res.Msg, Id = res.Id, Extra = res.Extra, Extra2 = res.Extra2 };
        }
        public JsonResponse ResetPinMobile(PasswordReset pwdReset)
        {
            var sql = "EXEC JsonRx_Proc_UserRegistration @flag='pin-reset-core' ";
            sql += ", @customerId = " + FilterString(pwdReset.CustomerId);
            sql += ", @user = " + FilterString(pwdReset.User);
            var res = ParseDbResult(sql);
            return new JsonResponse { ResponseCode = res.ErrorCode, Msg = res.Msg, Id = res.Id, Extra = res.Extra, Extra2 = res.Extra2 };
        }
        public DbResult RegisterCustomerNew(OnlineCustomerModel onlineCustomerModel)
        {
            var sql = "EXEC proc_online_core_customerSetup";
            sql += " @Flag =" + FilterString(onlineCustomerModel.flag);
            sql += " ,@customerId =" + FilterString(onlineCustomerModel.customerId);
            sql += ",@user = " + FilterString(onlineCustomerModel.createdBy);
            sql += ",@customerType = " + FilterString(onlineCustomerModel.customerType);
            if (onlineCustomerModel.companyName != null && onlineCustomerModel.companyName != "")
            {
                sql += ",@firstName=" + FilterString(onlineCustomerModel.companyName);
            }
            else
            {
                sql += ",@firstName=" + FilterString(onlineCustomerModel.firstName);
            }
            sql += ",@middleName=" + FilterString(onlineCustomerModel.middleName);
            sql += ",@lastName1=" + FilterString(onlineCustomerModel.lastName1);
            sql += ",@custEmail=" + FilterString(onlineCustomerModel.email);
            sql += ",@custDOB=" + FilterString(onlineCustomerModel.dob);
            sql += ",@custAdd1=" + FilterString(onlineCustomerModel.address);
            sql += ",@occupation=" + FilterString(onlineCustomerModel.occupation);
            sql += ",@custCity=" + FilterString(onlineCustomerModel.city);
            sql += ",@cityUnicode=" + FilterStringUnicode(onlineCustomerModel.senderCityjapan);
            sql += ",@custPostal=" + FilterString(onlineCustomerModel.postalCode);
            sql += ",@streetUnicode=" + FilterStringUnicode(onlineCustomerModel.streetJapanese);
            sql += ",@street=" + FilterString(onlineCustomerModel.street);
            sql += ",@state=" + FilterString(onlineCustomerModel.state);
            sql += ",@visaStatus=" + FilterString(onlineCustomerModel.visaStatus);
            sql += ",@employeeBusinessType=" + FilterString(onlineCustomerModel.employeeBusinessType);
            sql += ",@nameofEmployeer=" + FilterString(onlineCustomerModel.nameofEmployeer);
            sql += ",@SSNNO=" + FilterString(onlineCustomerModel.ssnNo);
            sql += ",@zipCode=" + FilterString(onlineCustomerModel.zipCode);
            sql += ",@sourceOfFound=" + FilterString(onlineCustomerModel.sourceOfFound);
            sql += ",@remittanceAllowed=" + onlineCustomerModel.remitanceAllowed;
            sql += ",@onlineUser=" + onlineCustomerModel.onlineUser;
            sql += ",@mobileUser=" + onlineCustomerModel.mobileUser;
            sql += ",@remarks=" + FilterString(onlineCustomerModel.remarks);
            sql += ",@country=" + FilterString(onlineCustomerModel.country);
            sql += ",@custNativecountry=" + FilterString(onlineCustomerModel.nativeCountry.ToString());
            sql += ",@customerIdType=" + FilterString(onlineCustomerModel.idType);
            sql += ",@customerIdNo=" + FilterString(onlineCustomerModel.idNumber);
            sql += ",@custIdissueDate=" + FilterString(onlineCustomerModel.idIssueDate);
            sql += ",@custIdValidDate=" + FilterString(onlineCustomerModel.idExpiryDate);
            sql += ",@custMobile=" + FilterString(onlineCustomerModel.mobile);
            sql += ",@custTelNo=" + FilterString(onlineCustomerModel.telNo);
            sql += ",@ipAddress=" + FilterString(onlineCustomerModel.ipAddress);
            sql += ",@createdBy=" + FilterString(onlineCustomerModel.createdBy);
            sql += ",@custGender=" + FilterString(onlineCustomerModel.gender);
            sql += ",@bankId=" + FilterString(onlineCustomerModel.bankId);
            sql += ",@accountNumber=" + FilterString(onlineCustomerModel.accountNumber);
            sql += ",@nameOfAuthorizedPerson=" + FilterString(onlineCustomerModel.nameofAuthoPerson);
            sql += ",@registerationNo=" + FilterString(onlineCustomerModel.registrationNo);
            sql += ",@organizationType=" + FilterString(onlineCustomerModel.organizationType);
            sql += ",@dateOfIncorporation=" + FilterString(onlineCustomerModel.dateOfIncorporation);
            sql += ",@natureOfCompany=" + FilterString(onlineCustomerModel.natureOfCompany);
            sql += ",@position=" + FilterString(onlineCustomerModel.position);
            sql += ",@membershipId=" + FilterString(onlineCustomerModel.membershipId);
            sql += ",@companyName=" + FilterString(onlineCustomerModel.companyName);
            sql += ",@monthlyIncome=" + FilterString(onlineCustomerModel.MonthlyIncome);
            sql += ",@isCounterVisited=" + FilterString(onlineCustomerModel.IsCounterVisited);
            sql += ",@newPassword=" + FilterString(onlineCustomerModel.customerPassword);
            sql += ",@additionalAddress=" + FilterString(onlineCustomerModel.AdditionalAddress);
            sql += ",@loginBranchId=" + FilterString(onlineCustomerModel.agentId.ToString());
            sql += ",@docType=" + FilterString(onlineCustomerModel.DocumentType);
            sql += ",@occupationOther=" + FilterString(onlineCustomerModel.occupationOther);
            sql += ",@referralId=" + FilterString(onlineCustomerModel.ReferralId);
            sql += ",@customerOtherIdNo=" + FilterString(onlineCustomerModel.otherIdNumber);
            sql += ",@serviceUsedFor=" + FilterString(onlineCustomerModel.serviceUsedFor);
            sql += ",@password=" + FilterString(onlineCustomerModel.password);
            sql += ",@registrationType =" + FilterString(onlineCustomerModel.RegistrationType);

            return ParseDbResult(sql);
        }

        public DbResult RegisterCustomerNewAgent(OnlineCustomerModel onlineCustomerModel)
        {
            var sql = "EXEC PROC_AGENT_CUTOMERSETUP";
            sql += " @Flag =" + FilterString(onlineCustomerModel.flag);
            sql += " ,@customerId =" + FilterString(onlineCustomerModel.customerId);
            sql += ",@user = " + FilterString(onlineCustomerModel.createdBy);
            sql += ",@customerType = " + FilterString(onlineCustomerModel.customerType);
            if (onlineCustomerModel.companyName != null && onlineCustomerModel.companyName != "")
            {
                sql += ",@firstName=" + FilterString(onlineCustomerModel.companyName);
            }
            else
            {
                sql += ",@firstName=" + FilterString(onlineCustomerModel.firstName);
            }
            sql += ",@middleName=" + FilterString(onlineCustomerModel.middleName);
            sql += ",@lastName1=" + FilterString(onlineCustomerModel.lastName1);
            sql += ",@custEmail=" + FilterString(onlineCustomerModel.email);
            sql += ",@custDOB=" + FilterString(onlineCustomerModel.dob);
            sql += ",@custAdd1=" + FilterString(onlineCustomerModel.address);
            sql += ",@occupation=" + FilterString(onlineCustomerModel.occupation);
            sql += ",@custCity=" + FilterString(onlineCustomerModel.city);
            sql += ",@cityUnicode=" + FilterStringUnicode(onlineCustomerModel.senderCityjapan);
            sql += ",@streetUnicode=" + FilterStringUnicode(onlineCustomerModel.streetJapanese);
            sql += ",@custPostal=" + FilterString(onlineCustomerModel.postalCode);
            sql += ",@street=" + FilterString(onlineCustomerModel.street);
            sql += ",@state=" + FilterString(onlineCustomerModel.state);
            sql += ",@visaStatus=" + FilterString(onlineCustomerModel.visaStatus);
            sql += ",@employeeBusinessType=" + FilterString(onlineCustomerModel.employeeBusinessType);
            sql += ",@nameofEmployeer=" + FilterString(onlineCustomerModel.nameofEmployeer);
            sql += ",@SSNNO=" + FilterString(onlineCustomerModel.ssnNo);
            sql += ",@zipCode=" + FilterString(onlineCustomerModel.zipCode);
            sql += ",@sourceOfFound=" + FilterString(onlineCustomerModel.sourceOfFound);
            sql += ",@remittanceAllowed=" + onlineCustomerModel.remitanceAllowed;
            sql += ",@onlineUser=" + onlineCustomerModel.onlineUser;
            sql += ",@mobileUser=" + onlineCustomerModel.mobileUser;
            sql += ",@remarks=" + FilterString(onlineCustomerModel.remarks);
            sql += ",@country=" + FilterString(onlineCustomerModel.country);
            sql += ",@custNativecountry=" + FilterString(onlineCustomerModel.nativeCountry.ToString());
            sql += ",@customerIdType=" + FilterString(onlineCustomerModel.idType);
            sql += ",@customerIdNo=" + FilterString(onlineCustomerModel.idNumber);
            sql += ",@custIdissueDate=" + FilterString(onlineCustomerModel.idIssueDate);
            sql += ",@custIdValidDate=" + FilterString(onlineCustomerModel.idExpiryDate);
            sql += ",@custMobile=" + FilterString(onlineCustomerModel.mobile);
            sql += ",@custTelNo=" + FilterString(onlineCustomerModel.telNo);
            sql += ",@ipAddress=" + FilterString(onlineCustomerModel.ipAddress);
            sql += ",@createdBy=" + FilterString(onlineCustomerModel.createdBy);
            sql += ",@custGender=" + FilterString(onlineCustomerModel.gender);
            sql += ",@bankId=" + FilterString(onlineCustomerModel.bankId);
            sql += ",@accountNumber=" + FilterString(onlineCustomerModel.accountNumber);
            sql += ",@nameOfAuthorizedPerson=" + FilterString(onlineCustomerModel.nameofAuthoPerson);
            sql += ",@registerationNo=" + FilterString(onlineCustomerModel.registrationNo);
            sql += ",@organizationType=" + FilterString(onlineCustomerModel.organizationType);
            sql += ",@dateOfIncorporation=" + FilterString(onlineCustomerModel.dateOfIncorporation);
            sql += ",@natureOfCompany=" + FilterString(onlineCustomerModel.natureOfCompany);
            sql += ",@position=" + FilterString(onlineCustomerModel.position);
            sql += ",@membershipId=" + FilterString(onlineCustomerModel.membershipId);
            sql += ",@companyName=" + FilterString(onlineCustomerModel.companyName);
            sql += ",@monthlyIncome=" + FilterString(onlineCustomerModel.MonthlyIncome);
            sql += ",@isCounterVisited=" + FilterString(onlineCustomerModel.IsCounterVisited);
            sql += ",@newPassword=" + FilterString(onlineCustomerModel.customerPassword);
            sql += ",@additionalAddress=" + FilterString(onlineCustomerModel.AdditionalAddress);
            sql += ",@loginBranchId=" + FilterString(onlineCustomerModel.agentId.ToString());
            sql += ",@docType=" + FilterString(onlineCustomerModel.DocumentType);
            sql += ",@occupationOther=" + FilterString(onlineCustomerModel.occupationOther);
            sql += ",@otherIdNumber=" + FilterString(onlineCustomerModel.otherIdNumber);
            sql += ",@verifyRemarks=" + FilterString(onlineCustomerModel.VerifyRemarks);
            sql += ",@RegistrationType=" + FilterString(onlineCustomerModel.RegistrationType);
            sql += ",@UseNFC=" + FilterString(onlineCustomerModel.IsNFC);
            return ParseDbResult(sql);
        }
        public DataRow GetCustomerDetails(string customerId, string user)
        {
            var sql = "EXEC proc_online_core_customerSetup";
            sql += " @Flag ='customer-details'";
            sql += ",@customerId =" + FilterString(customerId);
            sql += ",@user =" + FilterString(user);
            return ExecuteDataRow(sql);
        }
        public DataRow GetPendingCustomer(string customerId, string user)
        {
            var sql = "EXEC proc_change_customer_email";
            sql += " @Flag ='pending-cust-from-mobile'";
            sql += ",@customerId =" + FilterString(customerId);
            sql += ",@user =" + FilterString(user);
            return ExecuteDataRow(sql);
        }

        public DbResult DeleteReceiver(string customerId, string user)
        {
            var sql = "EXEC proc_online_receiverSetup";
            sql += " @Flag ='d'";
            sql += ",@receiverId =" + FilterString(customerId);
            sql += ",@user =" + FilterString(user);
            return ParseDbResult(sql);
        }


        public DataTable GetCustomerDetailsWitDT(string customerId, string user)
        {
            var sql = "EXEC proc_online_core_customerSetup";
            sql += " @Flag ='customer-details'";
            sql += ",@customerId =" + FilterString(customerId);
            sql += ",@user =" + FilterString(user);
            return ExecuteDataTable(sql);
        }

        public DataTable GetDetailsForEditCustomer(string customerId, string user)
        {
            var sql = "EXEC proc_online_core_customerSetup";
            sql += " @Flag ='customer-details'";
            sql += ",@customerId =" + FilterString(customerId);
            sql += ",@user =" + FilterString(user);
            return ExecuteDataTable(sql);
        }
        public DataTable GetDocumentForEditCustomerActivate(string customerId, string user)
        {
            var sql = "EXEC proc_online_core_customerSetup";
            sql += " @Flag ='customer-details-activate'";
            sql += ",@customerId =" + FilterString(customerId);
            sql += ",@user =" + FilterString(user);
            return ExecuteDataTable(sql);
        }

        public DataRow GetVerifyCustomerDetails(string customerId, string user)
        {
            var sql = "EXEC proc_online_core_customerSetup";
            sql += " @Flag ='verify-customer-details'";
            sql += ",@customerId =" + FilterString(customerId);
            sql += ",@user =" + FilterString(user);
            return ExecuteDataRow(sql);
        }

        public DataSet GetVerifyCustomerDetailsNew(string customerId, string user)
        {
            var sql = "EXEC proc_online_core_customerSetup";
            sql += " @Flag ='verify-customer-details'";
            sql += ",@customerId =" + FilterString(customerId);
            sql += ",@user =" + FilterString(user);
            return ExecuteDataset(sql);
        }
        public DataSet GetDetailsOfSendRequest(string customerId, string user)
        {
            var sql = "EXEC proc_online_core_customerSetup";
            sql += " @Flag ='getDetailsOfSendRequest'";
            sql += ",@rowId =" + FilterString(customerId);
            sql += ",@user =" + FilterString(user);
            return ExecuteDataset(sql);
        }

        public DataTable GetDocumentByCustomerId(string customerId)
        {
            string sql = "Exec proc_customerDocumentType @flag='getDocByCustomerId' ,@customerId=" + FilterString(customerId);
            return ExecuteDataTable(sql);
        }
        public DataTable GetMatcheData(string customerId, string user)
        {
            string sql = "Exec proc_online_core_customerSetup @flag='get-matched-data' ,@customerId=" + FilterString(customerId);
            return ExecuteDataTable(sql);
        }
        public DataSet GetOfacRemarks(string customerId, string user)
        {
            string sql = "Exec proc_online_core_customerSetup @flag='ofac-list' ,@customerId=" + FilterString(customerId);
            return ExecuteDataset(sql);
        }
        public DataTable GetDocumentByCustomerIdNew(string customerId, string fileDescription, string sessionId)
        {
            string sql = "Exec proc_customerDocumentType @flag='getSignatureByCustomerId'";
            sql += " ,@customerId =" + FilterString(customerId);
            sql += " ,@fileDescription =" + FilterString(fileDescription);
            sql += " ,@sessionId =" + FilterString(sessionId);
            return ExecuteDataTable(sql);
        }
        public DbResult VerifyCustomer(string customerId, string user)
        {
            var sql = "EXEC proc_online_core_customerSetup";
            sql += " @Flag ='verify-customer-agent'";
            sql += ",@customerId =" + FilterString(customerId);
            sql += ",@user =" + FilterString(user);
            return ParseDbResult(sql);
        }

        public DbResult VerifyPending(string customerId, string user)
        {
            var sql = "EXEC proc_online_approve_Customer";
            sql += " @Flag ='verify-pending'";
            sql += ",@customerId =" + FilterString(customerId);
            sql += ",@user =" + FilterString(user);
            return ParseDbResult(sql);
        }

        public DataSet ApprovePending(string customerId, string user, string BankAccName, string ofacRemarks = null)
        {
            var sql = "EXEC proc_online_approve_Customer";
            sql += " @Flag ='approve-pending'";
            sql += ",@customerId =" + FilterString(customerId);
            sql += ",@user =" + FilterString(user);
            sql += ",@CustomerBankName =N" + FilterString(BankAccName);
            sql += ",@ofacRemarks =" + FilterString(ofacRemarks);
            return ExecuteDataset(sql);
        }
        public DataSet ApprovePendingFromMobile(string customerId, string user, string createdUserFrom, string verifyType, string isValidatedCustomer, string verifyRemarks = null, string ofacRemarks = null, string referralId = "")
        {
            string flag = "approve-pending-mobile";
            if (createdUserFrom == "core" || createdUserFrom == "C")
                flag = "verify-mobile-user";

            var sql = "EXEC proc_online_approve_Customer";
            sql += " @Flag ='" + flag + "'";
            sql += ",@customerId =" + FilterString(customerId);
            sql += ",@user =" + FilterString(user);
            sql += ",@verifyType =" + FilterString(verifyType);
            sql += ",@isValidatedCustomer =" + FilterString(isValidatedCustomer);
            sql += ",@verifyRemarks =" + FilterString(verifyRemarks);
            sql += ",@ofacRemarks =" + FilterString(ofacRemarks);

            return ExecuteDataset(sql);
        }

        public DbResult UpdateObpId(string customerId, string user, string obpId)
        {
            var sql = "EXEC proc_online_approve_Customer";
            sql += " @Flag ='update-obpId'";
            sql += ",@customerId =" + FilterString(customerId);
            sql += ",@obpId =" + FilterString(obpId);
            sql += ",@user =" + FilterString(user);

            return ParseDbResult(sql);
        }

        public DbResult RequestLog(string requestJson)
        {
            var sql = "EXEC ws_proc_VirtualAccountDepositNotification @flag='i'";
            sql += " ,@RequestJSon =N" + FilterString(requestJson);
            return ParseDbResult(sql);
        }

        public DataRow GetCustomerForModification(string User, string id)
        {
            var sql = "EXEC proc_online_core_customerSetup @flag='kj-modificationList'";
            sql += " ,@User =" + FilterString(User);
            sql += " ,@customerId =" + FilterString(id);
            return ExecuteDataRow(sql);
        }

        public DbResult UpdateCustomer(string User, string id, string Depositor)
        {
            var sql = "EXEC proc_online_core_customerSetup @flag='kj-modification'";
            sql += " ,@User =" + FilterString(User);
            sql += " ,@customerId =" + FilterString(id);
            sql += " ,@fullName =N" + FilterString(Depositor);
            return ParseDbResult(sql);
        }

        public DbResult ResetPassword(string User, string newPassword, string customerId, string email = null)
        {
            var sql = "EXEC proc_online_core_customerSetup @flag='resetpwd'";
            sql += " ,@User =" + FilterString(User);
            sql += " ,@customerId =" + FilterString(customerId);
            sql += " ,@newPassword =" + FilterString(newPassword);
            sql += " ,@custEmail =" + FilterString(email);

            return ParseDbResult(sql);
        }

        public DataTable GetCustomerDetailsByCustomerId(string customerId, string user)
        {
            string sql = "exec proc_core_GetCustomerDetailsByCustomerId";
            sql += " @flag ='s'";
            sql += ",@customerId =" + FilterString(customerId);
            sql += ",@user =" + FilterString(user);
            var dt = ExecuteDataTable(sql);
            return dt;
        }

        public string GetEmail(string customerId, string user)
        {
            string sql = "exec proc_online_core_customerSetup";
            sql += " @flag ='sEmail'";
            sql += ",@customerId =" + FilterString(customerId);
            sql += ",@user =" + FilterString(user);

            return GetSingleResult(sql);
        }

        public DataRow GetCustomerDetailsForEdit(string customerId, string user)
        {
            var sql = "EXEC proc_online_core_customerManage";
            sql += " @Flag ='s-customer'";
            sql += ",@customerId =" + FilterString(customerId);
            sql += ",@user =" + FilterString(user);
            return ExecuteDataRow(sql);
        }

        public DbResult EnableDisable(string customerId, string user, string isActive)
        {
            string sql = "exec proc_online_core_customerManage";
            sql += " @flag ='enable-disable'";
            sql += ",@customerId =" + FilterString(customerId);
            sql += ",@user =" + FilterString(user);
            sql += ",@isActive =" + FilterString(isActive);

            return ParseDbResult(sql);
        }

        public DbResult AcceptCustomer(string customerId, string user, string isActive)
        {
            string sql = "exec proc_online_core_customerManage";
            sql += " @flag ='accept'";
            sql += ",@customerId =" + FilterString(customerId);
            sql += ",@user =" + FilterString(user);
            sql += ",@isActive =" + FilterString(isActive);

            return ParseDbResult(sql);
        }
        public DbResult ModifyCustomer(OnlineCustomerModel onlineCustomerModel)
        {
            var sql = "EXEC proc_online_core_customerManage";
            sql += " @Flag =" + FilterString(onlineCustomerModel.flag);
            sql += ",@customerId =" + FilterString(onlineCustomerModel.customerId);
            sql += ",@custEmail = " + FilterString(onlineCustomerModel.email);
            sql += ",@firstName = " + FilterString(onlineCustomerModel.firstName);
            sql += ",@user = " + FilterString(onlineCustomerModel.createdBy);
            sql += ",@custAdd1 = " + FilterString(onlineCustomerModel.address);
            sql += ",@occupation = " + FilterString(onlineCustomerModel.occupation);
            sql += ",@custCity = " + FilterString(onlineCustomerModel.city);
            sql += ",@country = " + FilterString(onlineCustomerModel.country);
            sql += ",@custNativecountry = " + FilterString(onlineCustomerModel.nativeCountry.ToString());
            sql += ",@customerIdType = " + FilterString(onlineCustomerModel.idType);
            sql += ",@customerIdNo = " + FilterString(onlineCustomerModel.idNumber);
            sql += ",@custIdissueDate = " + FilterString(onlineCustomerModel.idIssueDate);
            sql += ",@custIdValidDate = " + FilterString(onlineCustomerModel.idExpiryDate);
            sql += ",@custMobile = " + FilterString(onlineCustomerModel.mobile);
            sql += ",@custTelNo = " + FilterString(onlineCustomerModel.telNo);
            sql += ",@custGender = " + FilterString(onlineCustomerModel.gender);
            sql += ",@verifyDoc1 = " + FilterString(onlineCustomerModel.verifyDoc1);
            sql += ",@verifyDoc2 = " + FilterString(onlineCustomerModel.verifyDoc2);
            sql += ",@verifyDoc3 = " + FilterString(onlineCustomerModel.verifyDoc3);
            sql += ",@verifyDoc4=" + FilterString(onlineCustomerModel.verifyDoc4);
            sql += ",@bankId = " + FilterString(onlineCustomerModel.bankId);
            sql += ",@accountNumber = " + FilterString(onlineCustomerModel.accountNumber);
            sql += ",@dob = " + FilterString(onlineCustomerModel.dob);
            sql += ",@expiryDate = " + FilterString(onlineCustomerModel.idExpiryDate);
            sql += ",@issueDate = " + FilterString(onlineCustomerModel.idIssueDate);
            return ParseDbResult(sql);
        }

        public DataRow GetCustomerDetailForBankUpdate(string searchBy, string user, string searchValue)
        {
            string sql = "exec proc_customerBankModify";
            sql += " @flag ='S'";
            sql += ",@searchKey =" + FilterString(searchBy);
            sql += ",@user =" + FilterString(user);
            sql += ",@searchValue =" + FilterString(searchValue);

            return ExecuteDataRow(sql);
        }

        public DataRow GetAddressByZipCode(string zipCode, string user)
        {
            string sql = "exec proc_customerBankModify";
            sql += " @flag ='customerZip'";
            sql += ",@user =" + FilterString(user);
            sql += ",@searchKey =" + FilterString(zipCode);

            return ExecuteDataRow(sql);
        }

        public DataTable GetAddressByZipCodeNew(string zipCode, string user, string rowId, string customerId, string action = "")
        {
            string sql = "exec proc_customerBankModify";
            sql += " @flag ='customerZip'";
            sql += ",@user =" + FilterString(user);
            sql += ",@searchKey =" + FilterString(zipCode);
            sql += ",@rowId =" + FilterString(rowId);
            sql += ",@customerId =" + FilterString(customerId);
            sql += ",@action =" + FilterString(action);

            return ExecuteDataTable(sql);
        }
        public DataTable GetAddressByZipCodeAdmin(string zipCode, string user, string rowId, string customerId = null, string action = "")
        {
            string sql = "exec proc_customerBankModify";
            sql += " @flag ='customerZipAdmin'";
            sql += ",@user =" + FilterString(user);
            sql += ",@searchKey =" + FilterString(zipCode);
            sql += ",@rowId =" + FilterString(rowId);
            sql += ",@customerId =" + FilterString(customerId);
            sql += ",@action =" + FilterString(action);

            return ExecuteDataTable(sql);
        }

        public DataRow GetCustomerDetailForVerification(string searchBy, string user, string searchValue)
        {
            string sql = "exec proc_customerBankModify";
            sql += " @flag ='customervf'";
            sql += ",@searchKey =" + FilterString(searchBy);
            sql += ",@user =" + FilterString(user);
            sql += ",@searchValue =" + FilterString(searchValue);

            return ExecuteDataRow(sql);
        }

        public DbResult UpdateCustomerBankDetail(string user, string customerId, string newBank, string newAccNumber, string acNameInBank, string imageName)
        {
            string sql = "exec proc_customerBankModify";
            sql += " @flag ='U'";
            sql += ",@customerId =" + FilterString(customerId);
            sql += ",@user =" + FilterString(user);
            sql += ",@bankId =" + FilterString(newBank);
            sql += ",@accNumber =" + FilterString(newAccNumber);
            sql += ",@acNameInBank =N" + FilterString(acNameInBank);
            sql += ",@verifyDoc3 =" + FilterString(imageName);

            return ParseDbResult(sql);
        }

        public DbResult AuditDocument(string id, string User)
        {
            string sql = "exec proc_customerBankModify";
            sql += " @flag ='Audit'";
            sql += ",@customerId =" + FilterString(id);
            sql += ",@user =" + FilterString(User);

            return ParseDbResult(sql);
        }

        public DataSet ApproveReject(string user, string type, string customerId)
        {
            string sql = "exec PROC_KFTC_APPROVE_REJECT";
            sql += " @flag ='approve-reject'";
            sql += ",@customerId =" + FilterString(customerId);
            sql += ",@user =" + FilterString(user);
            sql += ",@type =" + FilterString(type);

            return ExecuteDataset(sql);
        }

        public JsonResponse InsertCustomerKYC(string user, string customerId, string kycmethod, string kycstatus, string selecteddate, string remarkstext, string trackNo = "")
        {
            string sql = "EXEC proc_customerKYC";
            sql += " @flag = 'i'";
            sql += ", @user = " + FilterString(user);
            sql += ", @customerId = " + FilterString(customerId);
            sql += ", @kycmethod = " + FilterString(kycmethod);
            sql += ", @kycstatus = " + FilterString(kycstatus);
            sql += ", @selecteddate = " + FilterString(selecteddate);
            sql += ", @remarkstext = " + FilterStringUnicode(remarkstext);
            sql += ", @trackingNo = " + FilterStringUnicode(trackNo);

            var res = ParseDbResult(sql);
            return new JsonResponse { ResponseCode = res.ErrorCode, Msg = res.Msg, Id = res.Id, Extra = res.Extra, Extra2 = res.Extra2, Extra1 = res.Extra1 };
        }

        public CustomerDetails GetUserDetails(string customerId)
        {
            var sql = "EXEC GetUserInfo @flag='kyc' ";
            sql += ", @customerId = " + FilterString(customerId);

            var row = ExecuteDataRow(sql);

            CustomerDetails userDetails = new CustomerDetails();
            if (row != null)
            {
                userDetails.FullName = row["fullName"].ToString();
                userDetails.CustomerId = Convert.ToInt32( row["customerid"].ToString());
                userDetails.MembershipId = row["membershipid"].ToString();
                userDetails.FirstName = row["Firstname"].ToString();
                userDetails.Mobile = row["mobile"].ToString();
                userDetails.MiddleName = row["middleName"].ToString();
                userDetails.LastName = row["Lastname1"].ToString();
                userDetails.Email = row["email"].ToString();
                userDetails.Address = row["address"].ToString();
                userDetails.RegisteredDate = row["createdDate"].ToString();
            }
            return userDetails;
        }

        private T ParseDbResult<T>(string sql)
        {
            throw new NotImplementedException();
        }

        public DbResult InsertCustomerKYCMobile(string user, string customerId, string kycmethod, string kycstatus, string selecteddate, string remarkstext, string trackNo = "")
        {
            string sql = "EXEC proc_customerKYC";
            sql += " @flag = 'i-mobile'";
            sql += ", @user = " + FilterString(user);
            sql += ", @customerId = " + FilterString(customerId);
            sql += ", @kycmethod = " + FilterString(kycmethod);
            sql += ", @kycstatus = " + FilterString(kycstatus);
            sql += ", @selecteddate = " + FilterString(selecteddate);
            sql += ", @remarkstext = " + FilterStringUnicode(remarkstext);
            sql += ", @trackingNo = " + FilterStringUnicode(trackNo);

            return ParseDbResult(sql);
        }

        public DbResult AddAndUpdateCustomerDocument(OnlineCustomerModel onlineCustomer)
        {
            var sql = "EXEC proc_online_core_customerSetup";
            sql += " @Flag =" + FilterString(onlineCustomer.flag);
            sql += ",@customerId =" + FilterString(onlineCustomer.customerId);
            sql += ",@verifyDoc1=" + FilterString(onlineCustomer.verifyDoc1);
            sql += ",@verifyDoc2=" + FilterString(onlineCustomer.verifyDoc2);
            sql += ",@verifyDoc3=" + FilterString(onlineCustomer.verifyDoc3);
            sql += ",@verifyDoc4=" + FilterString(onlineCustomer.verifyDoc4);
            return ParseDbResult(sql);
        }

        public DbResult DeleteCustomerKYC(string st_id, string user)
        {
            string sql = "Exec [proc_customerKYC]";
            sql += " @flag ='d'";
            sql += ", @user=" + FilterString(user);
            sql += ", @rowid=" + FilterString(st_id);
            return ParseDbResult(ExecuteDataset(sql).Tables[0]);
        }

        public DbResult DeleteCustomerDocument(string st_id, string user)
        {
            string sql = "Exec [proc_customerKYC]";
            sql += " @flag ='delete-doc'";
            sql += ", @user=" + FilterString(user);
            sql += ", @rowid=" + FilterString(st_id);
            return ParseDbResult(ExecuteDataset(sql).Tables[0]);
        }

        public DbResult DeleteCustomerDocumentTmp(string st_id, string user)
        {
            string sql = "Exec [proc_customerKYC]";
            sql += " @flag ='delete-tmp-doc'";
            sql += ", @user=" + FilterString(user);
            sql += ", @rowid=" + FilterString(st_id);
            return ParseDbResult(ExecuteDataset(sql).Tables[0]);
        }

        public DataRow GetCustomerDocPathData(string st_id, string flag, string user)
        {
            string sql = "Exec [proc_customerKYC]";
            sql += " @flag ='" + flag + "'";
            sql += ", @user=" + FilterString(user);
            sql += ", @rowid=" + FilterString(st_id);
            return ExecuteDataRow(sql);
        }
        public DataRow GetDepositSlipPathData(string st_id, string flag, string user)
        {
            string sql = "Exec [proc_depositSlipUpload]";
            sql += " @flag ='" + flag + "'";
            sql += ", @user=" + FilterString(user);
            sql += ", @cdId=" + FilterString(st_id);
            return ExecuteDataRow(sql);
        }

        public DbResult DeleteDepositSlipTmp(string st_id, string user)
        {
            string sql = "Exec [proc_depositSlipUpload]";
            sql += " @flag ='delete-tmp-doc'";
            sql += ", @user=" + FilterString(user);
            sql += ", @cdId=" + FilterString(st_id);
            return ParseDbResult(ExecuteDataset(sql).Tables[0]);
        }
        public DbResult MoveCustomerDocument(string st_id, string user)
        {
            string sql = "Exec [proc_customerKYC]";
            sql += " @flag ='move-doc'";
            sql += ", @user=" + FilterString(user);
            sql += ", @rowid=" + FilterString(st_id);
            return ParseDbResult(ExecuteDataset(sql).Tables[0]);
        }

        public DbResult MoveCustomerDocumentnew(string st_id, string user)
        {
            string sql = "Exec [proc_customerKYC]";
            sql += " @flag ='move-doc-new'";
            sql += ", @user=" + FilterString(user);
            sql += ", @rowid=" + FilterString(st_id);
            return ParseDbResult(ExecuteDataset(sql).Tables[0]);
        }
        //public DbResult MoveCustomerDepositSlip(string st_id, string user)
        //{
        //    string sql = "Exec [proc_depositSlipUpload]";
        //    sql += " @flag ='move-doc'";
        //    sql += ", @user=" + FilterString(user);
        //    sql += ", @cdId=" + FilterString(st_id);
        //    return ParseDbResult(ExecuteDataset(sql).Tables[0]);
        //}
        public JsonResponse MoveCustomerDepositSlip(string st_id, string user)
        {
            string sql = "Exec [proc_depositSlipUpload]";
            sql += " @flag ='move-doc'";
            sql += ", @user=" + FilterString(user);
            sql += ", @cdId=" + FilterString(st_id);
            var res = ParseDbResultNew(sql);

            return new JsonResponse { ResponseCode = res.ErrorCode, Msg = res.Msg, Id = res.Id, Extra = res.Extra, Extra2 = res.Extra2, Extra1 = res.Extra1 };
        }

        public DbResult DeleteCustomer(string st_id, string user)
        {
            string sql = "Exec proc_online_core_customerSetup";
            sql += " @flag ='delete'";
            sql += ", @user=" + FilterString(user);
            sql += ", @rowid=" + FilterString(st_id);
            return ParseDbResult(ExecuteDataset(sql).Tables[0]);
        }


        public DbResult DeleteCustomerFromMobile(string st_id, string user)
        {
            string sql = "Exec proc_online_core_customerSetup";
            sql += " @flag ='reject'";
            sql += ", @user=" + FilterString(user);
            sql += ", @rowid=" + FilterString(st_id);
            return ParseDbResult(ExecuteDataset(sql).Tables[0]);
        }
        public DbResult ClearCustomerKYC(string customerId, string user)
        {
            string sql = "Exec proc_online_core_customerSetup";
            sql += " @flag ='clearKYC'";
            sql += ", @user=" + FilterString(user);
            sql += ", @customerId=" + FilterString(customerId);
            return ParseDbResult(ExecuteDataset(sql).Tables[0]);
        }

        public DbResult DeleteCustomerDoc(string st_id, string user)
        {
            string sql = "Exec proc_customerDocumentType";
            sql += " @flag ='delete'";
            sql += ", @user=" + FilterString(user);
            sql += ", @cdId=" + FilterString(st_id);
            return ParseDbResult(ExecuteDataset(sql).Tables[0]);
        }

        public DbResult AddCustomerSignature(string customerId, string user, string fileName)
        {
            string sql = "exec proc_customerDocumentType @flag='AddSignature',@customerId =" + FilterString(customerId);
            sql += " ,@user=" + FilterString(user);
            sql += " ,@fileName=" + FilterString(fileName);
            return ParseDbResult(sql);
        }

        public DbResult UpdateCustomerDocument(string cdId, string customerId, string fileName, string fileDescription, string fileType, string documentType, string user, string sessionId = "")
        {
            string sql = "exec proc_customerDocumentType";
            if (cdId != "")
            {
                sql += " @flag ='u'";
            }
            else
            {
                sql += " @flag ='i'";
            }
            sql += ",@customerId =" + FilterString(customerId);
            sql += ",@cdId =" + FilterString(cdId);
            sql += ",@fileName =" + FilterString(fileName);
            sql += ",@fileDescription =" + FilterString(fileDescription);
            sql += ",@fileType =" + FilterString(fileType);
            sql += ",@documentType =" + FilterString(documentType);
            sql += ",@user =" + FilterString(user);
            sql += ",@rowIdField =" + FilterString(sessionId);

            return ParseDbResult(sql);
        }
        public DbResult UpdateCustomerDocumentEkyc(string cdId, string customerId, string fileName, string fileDescription, string fileType, string documentType
            , string user, string url, string sessionId = "")
        {
            string sql = "exec proc_customerDocumentType";
            sql += " @flag ='i-ekyc'";
            sql += ",@customerId =" + FilterString(customerId);
            sql += ",@cdId =" + FilterString(cdId);
            sql += ",@fileName =" + FilterString(fileName);
            sql += ",@fileDescription =" + FilterString(fileDescription);
            sql += ",@fileType =" + FilterString(fileType);
            sql += ",@documentType =" + FilterString(documentType);
            sql += ",@user =" + FilterString(user);
            sql += ",@rowIdField =" + FilterString(sessionId);
            sql += ",@url =" + FilterString(url);
            return ParseDbResult(sql);
        }

        public DbResult SaveEmail(string newEmail, string oldEmail, string user, string customerId)
        {
            string sql = "EXEC proc_change_customer_email @flag = 'updateEmail'";
            sql += " ,@newEmail=" + FilterString(newEmail);
            sql += " ,@oldEmail=" + FilterString(oldEmail);
            sql += " ,@user=" + FilterString(user);
            sql += " ,@customerId=" + FilterString(customerId);
            return ParseDbResult(sql);
        }


        public DbResult UpdateCustomerDocumentCompliance(string cdId, string customerId, string fileName, string fileDescription, string fileType, string documentType, string user, string sessionId = "")
        {
            string sql = "exec proc_customerDocumentType";
            sql += " @flag ='com-i'";
            sql += ",@customerId =" + FilterString(customerId);
            sql += ",@cdId =" + FilterString(cdId);
            sql += ",@fileName =" + FilterString(fileName);
            sql += ",@fileDescription =" + FilterString(fileDescription);
            sql += ",@fileType =" + FilterString(fileType);
            sql += ",@documentType =" + FilterString(documentType);
            sql += ",@user =" + FilterString(user);
            sql += ",@rowIdField =" + FilterString(sessionId);

            return ParseDbResult(sql);
        }

        public DataRow GetCustomerDocumentByDocumentId(string documentId, string user, string filedescription = null)
        {
            var sql = "EXEC proc_customerDocumentType @flag='getById'";
            sql += " ,@user =" + FilterString(user);
            sql += " ,@cdId =" + FilterString(documentId);
            sql += " ,@filedescription =" + FilterString(filedescription);
            return ExecuteDataRow(sql);
        }

        public DataRow GetCustomerDocumentByDocumentIdTmp(string documentId, string user)
        {
            var sql = "EXEC proc_customerDocumentType @flag='getById-tmp'";
            sql += " ,@user =" + FilterString(user);
            sql += " ,@cdId =" + FilterString(documentId);
            return ExecuteDataRow(sql);
        }

        public DataRow GetDepositSlipDocumentIdTmp(string documentId, string user)
        {
            var sql = "EXEC proc_depositSlipUpload @flag='getById-tmp'";
            sql += " ,@user =" + FilterString(user);
            sql += " ,@cdId =" + FilterString(documentId);
            return ExecuteDataRow(sql);
        }
        public DbResult UpdateBenificiarInformation(BenificiarData benificiar, string user)
        {
            string sql = "exec proc_online_receiverSetup";
            sql += " @flag =" + FilterString(benificiar.Flag);
            sql += ",@country =" + FilterString(benificiar.Country);
            sql += ",@nativeCountry =" + FilterString(benificiar.NativeCountry);
            sql += ",@receiverType =" + FilterString(benificiar.BenificiaryType);
            sql += ",@email =" + FilterString(benificiar.Email);
            sql += ",@firstName =" + FilterString(benificiar.ReceiverFName);
            sql += ",@middleName =" + FilterString(benificiar.ReceiverMName);
            sql += ",@lastName1 =" + FilterString(benificiar.ReceiverLName);
            sql += ",@lastName2 =" + FilterString(benificiar.ReceiverLName2);
            sql += ",@address =" + FilterString(benificiar.ReceiverAddress);
            sql += ",@city =" + FilterString(benificiar.ReceiverCity);
            sql += ",@homePhone =" + FilterString(benificiar.ContactNo);
            sql += ",@mobile =" + FilterString(benificiar.SenderMobileNo);
            sql += ",@relationship =" + FilterString(benificiar.Relationship);
            sql += ",@placeOfIssue =" + FilterString(benificiar.PlaceOfIssue);
            sql += ",@idType =" + FilterString(benificiar.TypeId);
            sql += ",@idNumber =" + FilterString(benificiar.TypeValue);
            sql += ",@purposeOfRemit =" + FilterString(benificiar.PurposeOfRemitance);
            sql += ",@paymentMode =" + FilterString(benificiar.PaymentMode);
            sql += ",@payOutPartner =" + FilterString(benificiar.PayoutPatner);
            sql += ",@bankLocation =" + FilterString(benificiar.BankLocation);
            sql += ",@bankName =" + FilterString(benificiar.BankName);
            sql += ",@receiverAccountNo =" + FilterString(benificiar.BenificaryAc);
            sql += ",@remarks =" + FilterString(benificiar.Remarks);
            sql += ",@receiverId =" + FilterString(benificiar.ReceiverId);
            sql += ",@customerId =" + FilterString(benificiar.customerId);
            sql += ",@membershipId =" + FilterString(benificiar.membershipId);
            sql += ",@otherRelationDesc =" + FilterString(benificiar.OtherRelationDescription);
            sql += ",@user =" + FilterString(user);
            sql += ",@loginBranchId=" + FilterString(benificiar.agentId.ToString());
            sql += ",@PurposeOfRemitanceOther=" + FilterString(benificiar.PurposeOfRemitanceOther);
            sql += ",@RelationshipOther=" + FilterString(benificiar.RelationshipOther);
            sql += ",@goodsType=" + FilterString(benificiar.GoodsType);
            sql += ",@goodsOrigin=" + FilterString(benificiar.GoodsOrigin);
            sql += ",@portOfShipment=" + FilterString(benificiar.PortOfShipment);
            sql += ",@isFromMobile=" + FilterString(benificiar.isFromMobile);
            return ParseDbResult(sql);
        }
        public DbResult UpdateBenificiarInformationNew(BenificiarData benificiar, string user)
        {
            string sql = "exec PROC_AGENT_RECEIVER_SETUP";
            sql += " @flag =" + FilterString(benificiar.Flag);
            sql += ",@country =" + FilterString(benificiar.Country);
            sql += ",@nativeCountry =" + FilterString(benificiar.NativeCountry);
            sql += ",@receiverType =" + FilterString(benificiar.BenificiaryType);
            sql += ",@email =" + FilterString(benificiar.Email);
            sql += ",@firstName =" + FilterString(benificiar.ReceiverFName);
            sql += ",@middleName =" + FilterString(benificiar.ReceiverMName);
            sql += ",@lastName1 =" + FilterString(benificiar.ReceiverLName);
            sql += ",@lastName2 =" + FilterString(benificiar.ReceiverLName2);
            sql += ",@address =" + FilterString(benificiar.ReceiverAddress);
            sql += ",@city =" + FilterString(benificiar.ReceiverCity);
            sql += ",@homePhone =" + FilterString(benificiar.ContactNo);
            sql += ",@mobile =" + FilterString(benificiar.SenderMobileNo);
            sql += ",@relationship =" + FilterString(benificiar.Relationship);
            sql += ",@placeOfIssue =" + FilterString(benificiar.PlaceOfIssue);
            sql += ",@idType =" + FilterString(benificiar.TypeId);
            sql += ",@idNumber =" + FilterString(benificiar.TypeValue);
            sql += ",@purposeOfRemit =" + FilterString(benificiar.PurposeOfRemitance);
            sql += ",@PurposeOfRemitanceOther =" + FilterString(benificiar.OtherPurpose);
            sql += ",@paymentMode =" + FilterString(benificiar.PaymentMode);
            sql += ",@payOutPartner =" + FilterString(benificiar.PayoutPatner);
            sql += ",@bankLocation =" + FilterString(benificiar.BankLocation);
            sql += ",@bankName =" + FilterString(benificiar.BankName);
            sql += ",@receiverAccountNo =" + FilterString(benificiar.BenificaryAc);
            sql += ",@remarks =" + FilterString(benificiar.Remarks);
            sql += ",@receiverId =" + FilterString(benificiar.ReceiverId);
            sql += ",@customerId =" + FilterString(benificiar.customerId);
            sql += ",@membershipId =" + FilterString(benificiar.membershipId);
            sql += ",@otherRelationDesc =" + FilterString(benificiar.OtherRelationDescription);
            sql += ",@user =" + FilterString(user);
            sql += ",@loginBranchId=" + FilterString(benificiar.agentId.ToString());
            sql += ",@branchManual=" + FilterString(benificiar.branchText);
            return ParseDbResult(sql);
        }

        public DbResult UpdateBenificiarInfoNew(BenificiarData benificiar, string user)
        {
            string sql = "exec PROC_AGENT_RECEIVER_SETUP";
            sql += " @flag =" + FilterString(benificiar.Flag);
            sql += ",@country =" + FilterString(benificiar.Country);
            sql += ",@nativeCountry =" + FilterString(benificiar.NativeCountry);
            sql += ",@receiverType =" + FilterString(benificiar.BenificiaryType);
            sql += ",@email =" + FilterString(benificiar.Email);
            sql += ",@firstName =" + FilterString(benificiar.ReceiverFName);
            sql += ",@middleName =" + FilterString(benificiar.ReceiverMName);
            sql += ",@lastName1 =" + FilterString(benificiar.ReceiverLName);
            sql += ",@lastName2 =" + FilterString(benificiar.ReceiverLName2);
            sql += ",@address =" + FilterString(benificiar.ReceiverAddress);
            sql += ",@city =" + FilterString(benificiar.ReceiverCity);
            sql += ",@homePhone =" + FilterString(benificiar.ContactNo);
            sql += ",@mobile =" + FilterString(benificiar.SenderMobileNo);
            sql += ",@relationship =" + FilterString(benificiar.Relationship);
            sql += ",@placeOfIssue =" + FilterString(benificiar.PlaceOfIssue);
            sql += ",@idType =" + FilterString(benificiar.TypeId);
            sql += ",@idNumber =" + FilterString(benificiar.TypeValue);
            sql += ",@purposeOfRemit =" + FilterString(benificiar.PurposeOfRemitance);
            sql += ",@PurposeOfRemitanceOther =" + FilterString(benificiar.OtherPurpose);
            sql += ",@paymentMode =" + FilterString(benificiar.PaymentMode);
            sql += ",@payOutPartner =" + FilterString(benificiar.PayoutPatner);
            sql += ",@bankLocation =" + FilterString(benificiar.BankLocation);
            sql += ",@bankName =" + FilterString(benificiar.BankName);
            sql += ",@receiverAccountNo =" + FilterString(benificiar.BenificaryAc);
            sql += ",@remarks =" + FilterString(benificiar.Remarks);
            sql += ",@receiverId =" + FilterString(benificiar.ReceiverId);
            sql += ",@customerId =" + FilterString(benificiar.customerId);
            sql += ",@membershipId =" + FilterString(benificiar.membershipId);
            sql += ",@otherRelationDesc =" + FilterString(benificiar.OtherRelationDescription);
            sql += ",@user =" + FilterString(user);
            sql += ",@loginBranchId=" + FilterString(benificiar.agentId.ToString());
            sql += ",@branchManual=" + FilterString(benificiar.branchText);
            return ParseDbResult(sql);
        }

        public DbResult SaveCustomerRefundData(string user, string customerId, string refAmount, string refundRemarks, string addCharge, string addRemarks, string collMode, string bankId)
        {
            var sql = "EXEC proc_customerRefund @flag='i'";
            sql += " ,@user =" + FilterString(user);
            sql += " ,@customerId =" + FilterString(customerId);
            sql += " ,@refundAmount =" + FilterString(refAmount);
            sql += " ,@refundCharge =" + FilterString(addCharge);
            sql += " ,@refundRemarks =" + FilterString(refundRemarks);
            sql += " ,@redfundChargeRemarks =" + FilterString(addRemarks);
            sql += " ,@collMode =" + FilterString(collMode);
            sql += " ,@bankId =" + FilterString(bankId);
            return ParseDbResult(sql);
        }

        public DbResult DeleteCustomerRefund(string st_id, string user)
        {
            string sql = "Exec [proc_customerRefund]";
            sql += " @flag ='d'";
            sql += ", @user=" + FilterString(user);
            sql += ", @rowid=" + FilterString(st_id);
            return ParseDbResult(ExecuteDataset(sql).Tables[0]);
        }

        public DataSet GetRequiredField(string countryId, string agentId, string user)
        {
            var sql = "EXEC proc_customerRefund @flag = 'collMode'";
            sql += ", @countryId = " + FilterString(countryId);
            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;
        }

        public DataTable LoadDataPaymentModeDdl(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 DataRow GetRequiredCustomerDetails(string customerId, string user)
        {
            var sql = "EXEC proc_online_remitance_core_customerSetup";
            sql += " @Flag ='requiredCustomer-details'";
            sql += ",@customerId =" + FilterString(customerId);
            sql += ",@user =" + FilterString(user);
            return ExecuteDataRow(sql);
        }

        public DataSet GetCustomerInfoFromMembershiId(string user, string membershipId)
        {
            var sql = "EXEC proc_Customerinformation @flag='detals-fromMembershipId'";
            sql += " ,@User =" + FilterString(user);
            sql += " ,@membershipId =" + FilterString(membershipId);
            return ExecuteDataset(sql);
        }

        public DataTable GetCustomerInfoFromCustomerId(string user, string customerId)
        {
            var sql = "EXEC proc_Customerinformation @flag='detals-customerId'";
            sql += " ,@User =" + FilterString(user);
            sql += " ,@customerId =" + FilterString(customerId);

            return ExecuteDataTable(sql);
        }

        public DataTable GetUsersOfBranch(string User, string BranchId)
        {
            var sql = "EXEC proc_dropDownLists @flag = 'userList1'";
            sql += " ,@branchId =" + FilterString(BranchId);
            return ExecuteDataTable(sql);
        }
        public DbResult ApproveRejectAgentTransaction(string User, string rowId, string flag)
        {
            var sql = "EXEC proc_approve_agent_Transaction";
            sql += " @flag =" + FilterString(flag);
            sql += " ,@user =" + FilterString(User);
            sql += " ,@rowId =" + FilterString(rowId);
            return ParseDbResult(sql);
        }
        public DbResult RegisterCustomerAndReceiver(OnlineCustomerModel onlineCustomerModel, BenificiaryModel beniciaryModel, string agentId = "")
        {
            try
            {
                var sql = "EXEC proc_jme_agent_system_customer";
                sql += " @Flag =" + FilterString(onlineCustomerModel.flag);
                sql += " ,@customerId =" + FilterString(onlineCustomerModel.customerId);
                sql += ",@user = " + FilterString(onlineCustomerModel.createdBy);
                sql += ",@loginUser = " + FilterString(onlineCustomerModel.loginUser);
                sql += ",@customerType = " + FilterString(onlineCustomerModel.customerType);
                if (onlineCustomerModel.companyName != null && onlineCustomerModel.companyName != "")
                {
                    sql += ",@firstName=" + FilterString(onlineCustomerModel.companyName);
                }
                else
                {
                    sql += ",@firstName=" + FilterString(onlineCustomerModel.firstName);
                }
                sql += ",@middleName=" + FilterString(onlineCustomerModel.middleName);
                sql += ",@lastName1=" + FilterString(onlineCustomerModel.lastName1);
                sql += ",@custEmail=" + FilterString(onlineCustomerModel.email);
                sql += ",@custDOB=" + FilterString(onlineCustomerModel.dob);
                sql += ",@custAdd1=" + FilterString(onlineCustomerModel.address);
                sql += ",@occupation=" + FilterString(onlineCustomerModel.occupation);
                sql += ",@custCity=" + FilterString(onlineCustomerModel.city);
                sql += ",@cityUnicode=" + FilterStringUnicode(onlineCustomerModel.senderCityjapan);
                sql += ",@streetUnicode=" + FilterStringUnicode(onlineCustomerModel.streetJapanese);
                sql += ",@custPostal=" + FilterString(onlineCustomerModel.postalCode);
                sql += ",@street=" + FilterString(onlineCustomerModel.street);
                sql += ",@state=" + FilterString(onlineCustomerModel.state);
                sql += ",@visaStatus=" + FilterString(onlineCustomerModel.visaStatus);
                sql += ",@employeeBusinessType=" + FilterString(onlineCustomerModel.employeeBusinessType);
                sql += ",@nameofEmployeer=" + FilterString(onlineCustomerModel.nameofEmployeer);
                sql += ",@SSNNO=" + FilterString(onlineCustomerModel.ssnNo);
                sql += ",@zipCode=" + FilterString(onlineCustomerModel.zipCode);
                sql += ",@sourceOfFound=" + FilterString(onlineCustomerModel.sourceOfFound);
                sql += ",@remittanceAllowed=" + onlineCustomerModel.remitanceAllowed;
                sql += ",@onlineUser=" + onlineCustomerModel.onlineUser;
                sql += ",@mobileUser=" + onlineCustomerModel.mobileUser;
                sql += ",@remarks=" + FilterString(onlineCustomerModel.remarks);
                sql += ",@country=" + FilterString(onlineCustomerModel.country);
                sql += ",@custNativecountry=" + FilterString(onlineCustomerModel.nativeCountry.ToString());
                sql += ",@customerIdType=" + FilterString(onlineCustomerModel.idType);
                sql += ",@customerIdNo=" + FilterString(onlineCustomerModel.idNumber);
                sql += ",@custIdissueDate=" + FilterString(onlineCustomerModel.idIssueDate);
                sql += ",@custIdValidDate=" + FilterString(onlineCustomerModel.idExpiryDate);
                sql += ",@custMobile=" + FilterString(onlineCustomerModel.mobile);
                sql += ",@custTelNo=" + FilterString(onlineCustomerModel.telNo);
                sql += ",@ipAddress=" + FilterString(onlineCustomerModel.ipAddress);
                sql += ",@createdBy=" + FilterString(onlineCustomerModel.createdBy);
                sql += ",@custGender=" + FilterString(onlineCustomerModel.gender);
                sql += ",@bankId=" + FilterString(onlineCustomerModel.bankId);
                sql += ",@accountNumber=" + FilterString(onlineCustomerModel.accountNumber);
                sql += ",@nameOfAuthorizedPerson=" + FilterString(onlineCustomerModel.nameofAuthoPerson);
                sql += ",@registerationNo=" + FilterString(onlineCustomerModel.registrationNo);
                sql += ",@organizationType=" + FilterString(onlineCustomerModel.organizationType);
                sql += ",@dateOfIncorporation=" + FilterString(onlineCustomerModel.dateOfIncorporation);
                sql += ",@natureOfCompany=" + FilterString(onlineCustomerModel.natureOfCompany);
                sql += ",@position=" + FilterString(onlineCustomerModel.position);
                sql += ",@membershipId=" + FilterString(onlineCustomerModel.membershipId);
                sql += ",@companyName=" + FilterString(onlineCustomerModel.companyName);
                sql += ",@monthlyIncome=" + FilterString(onlineCustomerModel.MonthlyIncome);
                sql += ",@isCounterVisited=" + FilterString(onlineCustomerModel.IsCounterVisited);
                sql += ",@newPassword=" + FilterString(onlineCustomerModel.customerPassword);
                sql += ",@additionalAddress=" + FilterString(onlineCustomerModel.AdditionalAddress);
                sql += ",@loginBranchId=" + FilterString(string.IsNullOrEmpty(agentId) ? onlineCustomerModel.agentId.ToString() : agentId);
                sql += ",@docType=" + FilterString(onlineCustomerModel.DocumentType);
                sql += ",@otherOccupationText =" + FilterString(onlineCustomerModel.occupationOther);

                sql += ",@recCountry =" + FilterString(beniciaryModel.Country);
                sql += ",@recNativeCountry =" + FilterString(beniciaryModel.NativeCountry);
                sql += ",@recReceiverType =" + FilterString(beniciaryModel.BenificiaryType);
                sql += ",@recEmail =" + FilterString(beniciaryModel.Email);
                sql += ",@recFirstName =" + FilterString(beniciaryModel.ReceiverFName);
                sql += ",@recMiddleName =" + FilterString(beniciaryModel.ReceiverMName);
                sql += ",@recLastName1 =" + FilterString(beniciaryModel.ReceiverLName);
                sql += ",@recLastName2 =" + FilterString(beniciaryModel.ReceiverLName2);
                sql += ",@recAddress =" + FilterString(beniciaryModel.ReceiverAddress);
                sql += ",@recCity =" + FilterString(beniciaryModel.ReceiverCity);
                sql += ",@recHomePhone =" + FilterString(beniciaryModel.ContactNo);
                sql += ",@recMobile =" + FilterString(beniciaryModel.SenderMobileNo);
                sql += ",@recRelationship =" + FilterString(beniciaryModel.Relationship);
                sql += ",@recPlaceOfIssue =" + FilterString(beniciaryModel.PlaceOfIssue);
                sql += ",@recIdType =" + FilterString(beniciaryModel.TypeId);
                sql += ",@recIdNumber =" + FilterString(beniciaryModel.TypeValue);
                sql += ",@recPurposeOfRemit =" + FilterString(beniciaryModel.PurposeOfRemitance);
                sql += ",@purposeOfRemitanceOther =" + FilterString(beniciaryModel.OtherPurpose);
                sql += ",@recPaymentMode =" + FilterString(beniciaryModel.PaymentMode);
                sql += ",@recPayOutPartner =" + FilterString(beniciaryModel.PayoutPatner);
                sql += ",@recBankLocation =" + FilterString(beniciaryModel.BankLocation);
                sql += ",@recBankName =" + FilterString(beniciaryModel.BankName);
                sql += ",@recReceiverAccountNo =" + FilterString(beniciaryModel.BenificaryAc);
                sql += ",@recRemarks =" + FilterString(beniciaryModel.Remarks);
                sql += ",@recOtherRelationDesc =" + FilterString(beniciaryModel.OtherRelationDescription);
                sql += ",@branchManual=" + FilterString(beniciaryModel.branchText);


                return ParseDbResult(sql);
            }
            catch (Exception ex)
            {
                return new DbResult()
                {
                    ErrorCode = "1",
                    Msg = ex.InnerException.ToString()
                };
            }

        }
        public DbResult RegisterCustomerAndReceiverNew(OnlineCustomerModel onlineCustomerModel, BenificiaryModel beniciaryModel, string agentId = "")
        {
            try
            {
                var sql = "EXEC PROC_CUSTOMERREGISTRATION_NEW";
                sql += " @Flag =" + FilterString(onlineCustomerModel.flag);
                sql += " ,@customerId =" + FilterString(onlineCustomerModel.customerId);
                sql += ",@user = " + FilterString(onlineCustomerModel.createdBy);
                sql += ",@loginUser = " + FilterString(onlineCustomerModel.loginUser);
                sql += ",@customerType = " + FilterString(onlineCustomerModel.customerType);
                if (onlineCustomerModel.companyName != null && onlineCustomerModel.companyName != "")
                {
                    sql += ",@firstName=" + FilterString(onlineCustomerModel.companyName);
                }
                else
                {
                    sql += ",@firstName=" + FilterString(onlineCustomerModel.firstName);
                }
                sql += ",@middleName=" + FilterString(onlineCustomerModel.middleName);
                sql += ",@lastName1=" + FilterString(onlineCustomerModel.lastName1);
                sql += ",@custEmail=" + FilterString(onlineCustomerModel.email);
                sql += ",@custDOB=" + FilterString(onlineCustomerModel.dob);
                sql += ",@custAdd1=" + FilterString(onlineCustomerModel.address);
                sql += ",@occupation=" + FilterString(onlineCustomerModel.occupation);
                sql += ",@custCity=" + FilterString(onlineCustomerModel.city);
                sql += ",@cityUnicode=" + FilterStringUnicode(onlineCustomerModel.senderCityjapan);
                sql += ",@streetUnicode=" + FilterStringUnicode(onlineCustomerModel.streetJapanese);
                sql += ",@custPostal=" + FilterString(onlineCustomerModel.postalCode);
                sql += ",@street=" + FilterString(onlineCustomerModel.street);
                sql += ",@state=" + FilterString(onlineCustomerModel.state);
                sql += ",@visaStatus=" + FilterString(onlineCustomerModel.visaStatus);
                sql += ",@employeeBusinessType=" + FilterString(onlineCustomerModel.employeeBusinessType);
                sql += ",@nameofEmployeer=" + FilterString(onlineCustomerModel.nameofEmployeer);
                sql += ",@SSNNO=" + FilterString(onlineCustomerModel.ssnNo);
                sql += ",@zipCode=" + FilterString(onlineCustomerModel.zipCode);
                sql += ",@sourceOfFound=" + FilterString(onlineCustomerModel.sourceOfFound);
                sql += ",@remittanceAllowed=" + onlineCustomerModel.remitanceAllowed;
                sql += ",@onlineUser=" + onlineCustomerModel.onlineUser;
                sql += ",@mobileUser=" + onlineCustomerModel.mobileUser;
                sql += ",@remarks=" + FilterString(onlineCustomerModel.remarks);
                sql += ",@country=" + FilterString(onlineCustomerModel.country);
                sql += ",@custNativecountry=" + FilterString(onlineCustomerModel.nativeCountry.ToString());
                sql += ",@customerIdType=" + FilterString(onlineCustomerModel.idType);
                sql += ",@customerIdNo=" + FilterString(onlineCustomerModel.idNumber);
                sql += ",@custIdissueDate=" + FilterString(onlineCustomerModel.idIssueDate);
                sql += ",@custIdValidDate=" + FilterString(onlineCustomerModel.idExpiryDate);
                sql += ",@custMobile=" + FilterString(onlineCustomerModel.mobile);
                sql += ",@custTelNo=" + FilterString(onlineCustomerModel.telNo);
                sql += ",@ipAddress=" + FilterString(onlineCustomerModel.ipAddress);
                sql += ",@createdBy=" + FilterString(onlineCustomerModel.createdBy);
                sql += ",@custGender=" + FilterString(onlineCustomerModel.gender);
                sql += ",@bankId=" + FilterString(onlineCustomerModel.bankId);
                sql += ",@accountNumber=" + FilterString(onlineCustomerModel.accountNumber);
                sql += ",@nameOfAuthorizedPerson=" + FilterString(onlineCustomerModel.nameofAuthoPerson);
                sql += ",@registerationNo=" + FilterString(onlineCustomerModel.registrationNo);
                sql += ",@organizationType=" + FilterString(onlineCustomerModel.organizationType);
                sql += ",@dateOfIncorporation=" + FilterString(onlineCustomerModel.dateOfIncorporation);
                sql += ",@natureOfCompany=" + FilterString(onlineCustomerModel.natureOfCompany);
                sql += ",@position=" + FilterString(onlineCustomerModel.position);
                sql += ",@membershipId=" + FilterString(onlineCustomerModel.membershipId);
                sql += ",@companyName=" + FilterString(onlineCustomerModel.companyName);
                sql += ",@monthlyIncome=" + FilterString(onlineCustomerModel.MonthlyIncome);
                sql += ",@isCounterVisited=" + FilterString(onlineCustomerModel.IsCounterVisited);
                sql += ",@newPassword=" + FilterString(onlineCustomerModel.customerPassword);
                sql += ",@additionalAddress=" + FilterString(onlineCustomerModel.AdditionalAddress);
                sql += ",@loginBranchId=" + FilterString(string.IsNullOrEmpty(agentId) ? onlineCustomerModel.agentId.ToString() : agentId);
                sql += ",@docType=" + FilterString(onlineCustomerModel.DocumentType);
                sql += ",@otherOccupationText =" + FilterString(onlineCustomerModel.occupationOther);

                sql += ",@recCountry =" + FilterString(beniciaryModel.Country);
                sql += ",@recNativeCountry =" + FilterString(beniciaryModel.NativeCountry);
                sql += ",@recReceiverType =" + FilterString(beniciaryModel.BenificiaryType);
                sql += ",@recEmail =" + FilterString(beniciaryModel.Email);
                sql += ",@recFirstName =" + FilterString(beniciaryModel.ReceiverFName);
                sql += ",@recMiddleName =" + FilterString(beniciaryModel.ReceiverMName);
                sql += ",@recLastName1 =" + FilterString(beniciaryModel.ReceiverLName);
                sql += ",@recLastName2 =" + FilterString(beniciaryModel.ReceiverLName2);
                sql += ",@recAddress =" + FilterString(beniciaryModel.ReceiverAddress);
                sql += ",@recCity =" + FilterString(beniciaryModel.ReceiverCity);
                sql += ",@recHomePhone =" + FilterString(beniciaryModel.ContactNo);
                sql += ",@recMobile =" + FilterString(beniciaryModel.SenderMobileNo);
                sql += ",@recRelationship =" + FilterString(beniciaryModel.Relationship);
                sql += ",@recPlaceOfIssue =" + FilterString(beniciaryModel.PlaceOfIssue);
                sql += ",@recIdType =" + FilterString(beniciaryModel.TypeId);
                sql += ",@recIdNumber =" + FilterString(beniciaryModel.TypeValue);
                sql += ",@recPurposeOfRemit =" + FilterString(beniciaryModel.PurposeOfRemitance);
                sql += ",@purposeOfRemitanceOther =" + FilterString(beniciaryModel.OtherPurpose);
                sql += ",@recPaymentMode =" + FilterString(beniciaryModel.PaymentMode);
                sql += ",@recPayOutPartner =" + FilterString(beniciaryModel.PayoutPatner);
                sql += ",@recBankLocation =" + FilterString(beniciaryModel.BankLocation);
                sql += ",@recBankName =" + FilterString(beniciaryModel.BankName);
                sql += ",@recReceiverAccountNo =" + FilterString(beniciaryModel.BenificaryAc);
                sql += ",@recRemarks =" + FilterString(beniciaryModel.Remarks);
                sql += ",@recOtherRelationDesc =" + FilterString(beniciaryModel.OtherRelationDescription);
                sql += ",@branchManual=" + FilterString(beniciaryModel.branchText);


                return ParseDbResult(sql);
            }
            catch (Exception ex)
            {
                return new DbResult()
                {
                    ErrorCode = "1",
                    Msg = ex.InnerException.ToString()
                };
            }

        }
        public DbResult AddCustomerSignature(string customerId, string user, string fileName, string signaturetype, string signatureId)
        {
            string sql = "exec proc_customerDocumentType @flag='AddSignature',@customerId =" + FilterString(customerId);
            sql += " ,@user=" + FilterString(user);
            sql += " ,@fileName=" + FilterString(fileName);
            sql += " ,@signatureType=" + FilterString(signaturetype);
            sql += " ,@signatureUploadId=" + FilterString(signatureId);
            return ParseDbResult(sql);
        }
        public DataTable GetDocumentByCustomerId(string customerId, string fileDescription, string sessionId)
        {
            string sql = "Exec proc_customerDocumentType @flag='getSignatureByCustomerId'";
            sql += " ,@customerId =" + FilterString(customerId);
            sql += " ,@fileDescription =" + FilterString(fileDescription);
            sql += " ,@sessionId =" + FilterString(sessionId);
            return ExecuteDataTable(sql);
        }
        public DataSet GetCustomerInfoFromMembershiId(string user, string membershipId, string receiverId, string rowId)
        {

            var sql = "EXEC proc_customerInfo @flag='details-fromMembershipId'";
            sql += " ,@User =" + FilterString(user);
            sql += " ,@membershipId =" + FilterString(membershipId);
            sql += " ,@receiverId =" + FilterString(receiverId);
            sql += " ,@rowId =" + FilterString(rowId);
            return ExecuteDataset(sql);
        }
        public string GetCustomerDetailsForFileUpload(string customerId)
        {
            string sql = "exec proc_customerDocumentType @flag='customer-upload-path'";
            sql += " ,@customerId=" + FilterString(customerId);

            return GetSingleResult(sql);
        }
        public string GetCustomerDetailsForPDFSave(string membershipId, string rowIdField, string type, string isCustomerId = "N")
        {
            string sql = "exec proc_customerDocumentType @flag='customer-path-check'";
            sql += " ,@membershipId=" + FilterString(membershipId);
            sql += " ,@rowIdField=" + FilterString(rowIdField);
            sql += " ,@fileType=" + FilterString(type);
            sql += " ,@isCustomerId=" + FilterString(isCustomerId);

            return GetSingleResult(sql);
        }
        public string GetCustomerDetailsForLetterPDFSave(string membershipId, string rowIdField, string type)
        {
            string sql = "exec proc_customerDocumentType @flag='customer-path-check-new'";
            sql += " ,@membershipId=" + FilterString(membershipId);
            sql += " ,@rowIdField=" + FilterString(rowIdField);
            sql += " ,@fileType=" + FilterString(type);

            return GetSingleResult(sql);
        }
        public DbResult AddCustomerPDFUpload(string customerId, string user, string fileName, string fileType, string rowIdField)
        {
            string sql = "exec proc_customerDocumentType @flag='Add-file-save',@customerId =" + FilterString(customerId);
            sql += " ,@user=" + FilterString(user);
            sql += " ,@fileName=" + FilterString(fileName);
            sql += " ,@fileType=" + FilterString(fileType);
            sql += " ,@rowIdField=" + FilterString(rowIdField);

            return ParseDbResult(sql);
        }
        public DbResult AddBenefeciaryPDFUpload(string customerId, string user, string fileName, string fileType, string rowIdField)
        {
            string sql = "exec proc_customerDocumentType @flag='Add-file-bene',@customerId =" + FilterString(customerId);
            sql += " ,@user=" + FilterString(user);
            sql += " ,@fileName=" + FilterString(fileName);
            sql += " ,@fileType=" + FilterString(fileType);
            sql += " ,@rowIdField=" + FilterString(rowIdField);

            return ParseDbResult(sql);
        }
        public DbResult AddCustomerLetterPDFUpload(string customerId, string user, string fileName, string fileType, string rowIdField)
        {
            string sql = "exec proc_customerDocumentType @flag='Add-letter-save',@customerId =" + FilterString(customerId);
            sql += " ,@user=" + FilterString(user);
            sql += " ,@fileName=" + FilterString(fileName);
            sql += " ,@fileType=" + FilterString(fileType);
            sql += " ,@rowIdField=" + FilterString(rowIdField);

            return ParseDbResult(sql);
        }
        public DataSet GetCustomerAndReceiver(string customerId, string user)
        {
            string sql = "Exec proc_customerInfo @flag='getCustomerAndReceiverInfo'";
            sql += " ,@customerId =" + FilterString(customerId);
            sql += " ,@user =" + FilterString(user);
            return ExecuteDataset(sql);
        }
        public DataSet GetCustomerAndReceiverForTablet(string customerId, string user)
        {
            string sql = "Exec proc_customerInfo @flag='getCustomer-tablet'";
            sql += " ,@customerId =" + FilterString(customerId);
            sql += " ,@user =" + FilterString(user);
            return ExecuteDataset(sql);
        }
        public DataRow GetDetailsWithPinNo(string customerId, string user)
        {
            string sql = "Exec proc_customerInfoWithPinNo @flag='getDetailsWithPin'";
            sql += " ,@customerId =" + FilterString(customerId);
            sql += " ,@user =" + FilterString(user);
            return ExecuteDataRow(sql);
        }

        public DbResult ReVerifyCust(string customerId, string user)
        {
            string sql = "Exec proc_online_core_customerSetup";
            sql += " @flag ='reVerify'";
            sql += ", @user=" + FilterString(user);
            sql += ", @customerId=" + FilterString(customerId);
            return ParseDbResult(ExecuteDataset(sql).Tables[0]);
        }
        public DbResult deleteCustomer(string customerId, string user)
        {
            string sql = "Exec proc_online_core_customerSetup";
            sql += " @flag ='deleteCustomer'";
            sql += ", @user=" + FilterString(user);
            sql += ", @customerId=" + FilterString(customerId);
            return ParseDbResult(ExecuteDataset(sql).Tables[0]);
        }
        public DbResult DeleteCustomerM(string id, string user, string ofacRemarks = "")
        {
            string sql = "Exec proc_online_core_customerSetup";
            sql += " @flag ='deleteCustomer'";
            sql += ", @user=" + FilterString(user);
            sql += ", @customerId=" + FilterString(id);
            sql += ", @ofacReason=" + FilterString("Y");
            sql += ", @ofacRemarks=" + FilterString(ofacRemarks);

            return ParseDbResult(ExecuteDataset(sql).Tables[0]);
        }
        public DataTable GetTrustDoc(string customerId, string user)
        {
            string sql = "Exec Proc_trustdoc_customer";
            sql += " @flag ='get_trustDoc'";
            sql += ", @user=" + FilterString(user);
            sql += ", @customerId=" + FilterString(customerId);
            return ExecuteDataTable(sql);
        }
        public DataTable UpdateEKYC(string customerId, string user)
        {
            string sql = "Exec Proc_trustdoc_customer";
            sql += " @flag ='compare_data'";
            sql += ", @user=" + FilterString(user);
            sql += ", @customerId=" + FilterString(customerId);
            return ExecuteDataTable(sql);
        }


        public DbResult DeleteCustomerNew(string st_id, string source, string deleteReason, string user)
        {
            string sql = "Exec proc_online_core_customerSetup";
            sql += " @flag ='deleteCustomer-new'";
            sql += ", @deleteReason=" + FilterString(deleteReason);
            sql += ", @source="+ FilterString(source);
            sql += ", @user=" + FilterString(user);
            sql += ", @customerId=" + FilterString(st_id);
            return ParseDbResult(ExecuteDataset(sql).Tables[0]);
        }

        public DataTable Update_VerifyStatus(string customerId, string user, string expiryDate, string comparing_dataDate)
        {
            string sql = "Exec Proc_trustdoc_customer";
            sql += " @flag ='update_verifystatus'";
            sql += ", @user=" + FilterString(user);
            sql += ", @customerId=" + FilterString(customerId);
            sql += ", @expiryDate=" + FilterString(expiryDate);
            sql += ", @comparing_dataDate=" + FilterString(comparing_dataDate);
            return ExecuteDataTable(sql);
        }
	  public DbResult updateTrustdoc(string trustdocId, string user)
        {
            var sql = "EXEC Proc_trustdoc_customer";
            sql += " @flag = 'update-trustdoc-deleted'";
            sql += ",@id=" + FilterString(trustdocId);
            sql += ",@user=" + FilterString(user);
            return ParseDbResult(sql);
        }

        public DbResult UpdateKycType(string customerId, string kycType, string customerSource, string user)
        {
            var sql = "Exec proc_customerRegistrationStatus @flag='update-kycType'";
            sql += " ,@kycType =" + FilterString(kycType);
            sql += " ,@customerId =" + FilterString(customerId);
            sql += " ,@customerSource =" + FilterString(customerSource);
            sql += " ,@user =" + FilterString(user);

            return ParseDbResult(sql);
        }
    }
}