File: /home/barbeatleanalyti/public_html/barisnew.beatleanalytics.com/site/backup/include/dbClass.php
<?php
/*
File Name : dbClass.php
Location : site/include/dbClass.php
Use : Main Database Functions File
*/
class MySQLCN
{
public $PostData = array();
public $objController;
public $objModel;
public $error;
public $msg;
static $objDB;
public $ClientID;
public $MasterAdminID;
public $CallMethod;
public $FromEmail;
public $UserName;
public $Password;
public $ToEmail;
public $Name;
public $EmailSubject;
public $EmailBody;
public $PageName;
public $Attachment = array();
public $skinArr = array("skin-blue","skin-black","skin-purple","skin-green","skin-red","skin-yellow","skin-blue-ligh","skin-black-ligh","skin-purple-ligh","skin-green-ligh","skin-red-ligh","skin-yellow-ligh");
public $IMAPData;
function ConnectNewDatabase($dbuser="", $dbpass="", $dbserver="", $dbname=""){
if($this->close()){
$objDB = new MySQLCN($dbuser, $dbpass, $dbserver, $dbname);
return $objDB;
}else{
die("Here is something wrong to close database.");
exit;
}
}
function __CONSTRUCT($dbuser="", $dbpass="", $dbserver="", $dbname="")
{
if($dbuser == "")
{
$user = DB_USERNAME;
$pass = DB_PASS;
$server = DB_SERVER;
$dbase = DB_DATABASE;
}
else
{
$user = $dbuser;
$pass = $dbpass;
$server = $dbserver;
$dbase = $dbname;
}
$conn = mysqli_connect($server,$user,$pass,$dbase);
mysqli_set_charset($conn,'utf8');
if(mysqli_connect_errno()) {
echo ("Connection attempt failed<br />").mysqli_connect_error();
exit;
}
//if(!mysql_select_db($dbase,$conn)) {
// echo ("Database selection failed.<br />").mysqli_error();
// exit;
//}
/*$conn1 = mysql_connect(DB_SERVER_2,DB_USERNAME_2,DB_PASS_2);
mysql_set_charset('utf8',$conn1);
if(!$conn1) {
$this->error("Connection attempt failed");
}
if(!mysql_select_db(DB_DATABASE_2,$conn1)) {
$this->error("Dbase Select failed");
}
*/
$this->CONN = $conn;
return true;
}
public function close()
{
$close = mysqli_close($this->CONN);
if(!$close) {
return false;
exit;
}
return true;
}
public function error($text)
{
$no = mysqli_errno();
$msg = mysqli_error();
exit;
}
public function PostData($PostData){
$this->PostData = $PostData;
}
public function select ($sql="")
{
if(empty($sql)) { return false; }
if(!@eregi("^select",$sql))
{
$ret_msg = "Wrong Query : ".$sql."";
if($_SERVER['HTTP_REFERER'] == '')
{
header("location:".ERROR_PATH."error_handle.php?err=1&msg=Data fetch error !&ret_msg=".base64_encode($ret_msg));
}else
{
$tmp = explode('admin/',$_SERVER['HTTP_REFERER']);
header("location:".ERROR_PATH."error_handle.php?err=1&msg=Data fetch error !&ret_msg=".base64_encode($ret_msg));
}
exit;
}
if(empty($this->CONN)) { return false; }
$conn = $this->CONN;
$results = @mysqli_query($conn,$sql);
if((!$results) or (empty($results)))
{
$ret_msg = "Wrong Query : ".$sql."--- Error :".mysqli_error()."";
if($_SERVER['HTTP_REFERER'] == '')
{
header("location:".ERROR_PATH."error_handle.php?err=1&msg=Data fetch error !&ret_msg=".base64_encode($ret_msg));
}else
{
$tmp = explode('admin/',$_SERVER['HTTP_REFERER']);
header("location:".ERROR_PATH."error_handle.php?err=1&msg=Data fetch error !&ret_msg=".base64_encode($ret_msg));
}
exit;
}
$count = 0;
$data = array();
while ( $row = mysql_fetch_array($results))
{
$data[$count] = $row;
$count++;
}
mysql_free_result($results);
return $data;
}
public function newselect ($sql="")
{
if(empty($sql)) { return false; }
if(!@eregi("^select",$sql))
{
echo "wrongquery<br>$sql<p>";
echo "<H2>Wrong function silly!</H2>\n";
return false;
}
if(empty($this->CONN)) { return false; }
$conn = $this->CONN;
$results = @mysqli_query($conn,$sql);
if( (!$results) or (empty($results)) ) {
return false;
}
$count = 0;
$data = array();
while ( $row = mysql_fetch_array($results)) {
$data[$count] = $row;
$count++;
}
mysql_free_result($results);
return $data;
}
public function affected($sql="")
{
if(empty($sql)) { return false; }
if(!@eregi("^select",$sql))
{
echo "wrongquery<br>$sql<p>";
echo "<H2>Wrong function silly!</H2>\n";
return false;
}
if(empty($this->CONN)) { return false; }
$conn = $this->CONN;
$results = @mysqli_query($conn,$sql);
if( (!$results) or (empty($results)) ) {
return false;
}
$tot=0;
$tot=mysql_affected_rows();
return $tot;
}
public function insert ($sql="")
{
if(empty($sql)) { return false; }
if(!@eregi("^insert",$sql))
{
return false;
}
if(empty($this->CONN))
{
return false;
}
$conn = $this->CONN;
$results = mysqli_query($conn,$sql);
if(!$results)
{
$ret_msg = "Wrong Query : ".$sql."<br>".mysqli_error()."";
if($_SERVER['HTTP_REFERER'] == '')
{
header("location:".ERROR_PATH."error_handle.php?err=1&msg=Data Insert error !&ret_msg=".base64_encode($ret_msg));
}else
{
$tmp = explode('admin/',$_SERVER['HTTP_REFERER']);
header("location:".ERROR_PATH."error_handle.php?err=1&msg=Data Insert error !&ret_msg=".base64_encode($ret_msg));
}
exit;
}
$id = mysqli_insert_id($this->CONN);
return $id;
}
//Dont remove this - Added by sreejan//
public function adder($sql="")
{ if(empty($sql)) { return false; }
if(!@eregi("^insert",$sql))
{
return false;
}
if(empty($this->CONN))
{
return false;
}
$conn = $this->CONN;
$results = @mysqli_query($conn,$sql);
if(!$results)$id = "";
else $id = mysqli_insert_id();
return $id;
}
public function edit($sql="")
{
if(empty($sql)) { return false; }
if(!@eregi("^update",$sql))
{
return false;
}
if(empty($this->CONN))
{
return false;
}
$conn = $this->CONN;
$results = mysqli_query($conn,$sql);
if(!$results)
{
$this->error("<H2>No results!</H2>\n");
return false;
}
$rows = 0;
$rows = mysql_affected_rows();
return $rows;
}
public function sql_query($sql="")
{
if(empty($sql)) { return false; }
if(empty($this->CONN)) { return false; }
$conn = $this->CONN;
mysqli_query($conn,"SET SQL_BIG_SELECTS=1");
$results = mysqli_query($conn,$sql);
$DataArr = array();
if(!$results)
{
$this->PageName = $this->PageName.".html";
$ret_msg = "Wrong Query : ".$sql."<br>".mysqli_error();
if($_SERVER['HTTP_REFERER'] == '')
{
$DataArr = array("error"=>1);
ReturnPostFormData(array(),"error.html","Data fetch error <br /><strong>".$ret_msg."</strong>! <br /><br />Page = ".$this->PageName."<br>User ID : ".$_SESSION['UserInfo']['UserID']."<br>User Type : ".$_SESSION['UserInfo']['UType']."<br>User UniqueID : #".$_SESSION['UserInfo']['UniqueID']."<br> Date : ".date("d/m/Y h:i A"),1);
exit;
}else
{
$tmp = explode('admin/',$_SERVER['HTTP_REFERER']);
$DataArr = array("error"=>1);
ReturnPostFormData(array(),"error.html","Data fetch error <br /><strong>".$ret_msg."</strong>! <br /><br />Page = ".$this->PageName."<br>User ID : ".$_SESSION['UserInfo']['UserID']."<br>User Type : ".$_SESSION['UserInfo']['UType']."<br>User UniqueID : #".$_SESSION['UserInfo']['UniqueID']."<br> Date : ".date("d/m/Y h:i A"),1);
}
exit;
}
// (Martin Huba) also SHOW... commands return some results
if(!(@eregi("^select",$sql) || @eregi("^show",$sql) || @eregi("^update",$sql) || @eregi("^delete",$sql) || @eregi("^insert",$sql) || @eregi("^alter",$sql)))
{
$this->PageName = $this->PageName.".html";
$ret_msg = "Wrong Query : ".$sql."<br>".mysqli_error();
if($_SERVER['HTTP_REFERER'] == '')
{
ReturnPostFormData(array(),"error.html","Data fetch error <br /><strong>".$ret_msg."</strong>! <br /><br />Page = ".$this->PageName."<br>User ID : ".$_SESSION['UserInfo']['UserID']."<br>User Type : ".$_SESSION['UserInfo']['UType']."<br>User UniqueID : #".$_SESSION['UserInfo']['UniqueID']."<br> Date : ".date("d/m/Y h:i A"),1);
exit;
}else
{
$tmp = explode('admin/',$_SERVER['HTTP_REFERER']);
ReturnPostFormData(array(),"error.html","Data fetch error <br /><strong>".$ret_msg."</strong>! <br /><br />Page = ".$this->PageName."<br>User ID : ".$_SESSION['UserInfo']['UserID']."<br>User Type : ".$_SESSION['UserInfo']['UType']."<br>User UniqueID : #".$_SESSION['UserInfo']['UniqueID']."<br> Date : ".date("d/m/Y h:i A"),1);
exit;
}
exit;
}
if (@eregi("^delete",$sql) || @eregi("^insert",$sql) || @eregi("^update",$sql)) {
return true;
} else {
$count = 0;
$data = array();
while ( $row = mysqli_fetch_array($results)) {
$data[$count] = $row;
$count++;
}
mysqli_free_result($results);
return $data;
}
}
public function GenerateActivationCode(){
$possible_letters = '0123456789abcdefghijklmnopqustuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ';
$code = '';
$totalCharacters = rand(30,35);
$rc = 0;
while ($rc < $totalCharacters) {
$code .= substr($possible_letters, mt_rand(0, strlen($possible_letters)-1), 1);
$rc++;
}
return $code;
}
public function FetchEmailTemplate($FetchTitle){
$SQL = "SELECT * FROM email_template WHERE AccessTitle = '{$FetchTitle}' AND IsActive = 'Y' ";
$Result = $this->sql_query($SQL);
if(count($Result) > 0){
return $Result;
}
else {
return false;
}
}
public function SendEMail(){
////////////////////////////////////////////////////////////////////
// Include mandatory file for php mailer
include_once('class.phpmailer.php');
include_once('class.smtp.php');
// Create object for phpmailer
$objMailer = new PHPMailer();
$objMailer->IsSMTP(); // telling the class to use SMTP
$objMailer->Host = MAIL_HOST; // SMTP server
//$objMailer->SMTPDebug = 2; // enables SMTP debug information (for testing)
// 1 = errors and messages
// 2 = messages only
$objMailer->SMTPAuth = MAIL_SMTP_AUTHONTICATION; // enable SMTP authentication
$objMailer->Port = MAIL_SMTP_PORT; // set the SMTP port for the GMAIL server
$objMailer->Username = MAIL_USERNAME; // Default SMTP account user from table
$objMailer->Password = base64_decode(MAIL_PASSWORD); // Default SMTP account password from table
$objMailer->SetFrom($this->UserName, "Beatle Analytics");
//$objMailer->AddReplyTo("tokalpeshdp@yahoo.co.in","First Last");
$objMailer->Subject = $this->EmailSubject;
$objMailer->AltBody = $this->EmailBody; // optional, comment out and test
$objMailer->MsgHTML($this->EmailBody);
$objMailer->AddAddress($this->ToEmail, $this->Name);
//$objMailer->AddAddress("tokalpeshdp@gmail.com", "tokalpeshdp@gmail.com");
/*
$objMailer->AddAttachment("import1.html"); // attachment
$objMailer->AddAttachment("import2.html"); // attachment
*/
if(!$objMailer->Send()) {
$objMailer->ErrorInfo;
return false;
} else {
$objMailer->ErrorInfo;
$objMailer->ClearAddresses();
// Cleare the attachments
$objMailer->ClearAttachments();
return true;
}
}
public function NotificaitonForResult($msg,$error){
if($msg != "" && $error != "") {
if($error == 1) {?>
<div id="common-error" class="callout callout-danger margin">
<script type="text/javascript">
$("#common-error").delay(7000).slideUp();
</script>
<h4 class="text-center"><?php echo $msg?></h4>
</div>
<? } else if($error == 0) { ?>
<div id="common-success" class="common-success callout callout-info margin" >
<h4 class="text-center"><?php echo $msg?></h4>
</div>
<script type="text/javascript">
$("#common-success").delay(7000).slideUp();
</script>
<? }else if($error == 2) {?>
<div id="common-error-notification" class="callout callout-info common-error-notification margin">
<script type="text/javascript">
$("#common-error-notification").delay(7000).slideUp();
</script>
<h4 class="text-center"><?php echo $msg?></h4>
</div>
<? }
}
?>
<?php
}
public function CheckUserNotLoggedIn($pg){
// Check user login or not;
if(!isset($_SESSION['UserInfo']) && count($_SESSION['UserInfo'])!== 4 && $_SESSION['UserInfo']['SessionID'] == session_id())
{
ReturnPostFormData($this->DataArr,"login.html","",1);
}
}
public function CheckUserLoggedIn($pg){
//$pgArr = array("user");
// Check user login or not;
if(isset($_SESSION['UserInfo']) && $_SESSION['UserInfo']['SessionID'] == session_id() && $_SESSION['UserInfo']['UniqueID'] != "" )
{
$pg= "";
/*
if($_SESSION['UserInfo']['UType']=="MasterAdmin"){
$pg = "dashboardma";
}else if($_SESSION['UserInfo']['UType']=="Admin")
{
$pg = "dashboardadmin";
}else if($_SESSION['UserInfo']['UType']=="Client")
{
$pg = "dashboardclt";
}else if($_SESSION['UserInfo']['UType']=="Sales")
{
$pg = "dashboardsls";
}else if($_SESSION['UserInfo']['UType']=="Manager")
{
$pg = "dashboardmng";
}else if($_SESSION['UserInfo']['UType']=="Employee")
{
$pg = "dashboardemp";
}else if($_SESSION['UserInfo']['UType']=="Recruiter")
{
$pg = "dashboardrec";
} */
$pg = "dashboardma";
ReturnPostFormData($aa = array(),$pg.".html",$this->msg,$this->error);
exit;
}
}
public function FetchPageTitle($pg){
$PGTitle = "";
switch($pg){
case "login":
$PGTitle = ": Login and get your work";
break;
case "signup":
$PGTitle = ": Sign up and get your work";
break;
case "user":
$PGTitle = ": User details ";
break;
case "profile":
$PGTitle = ": Set your profile and get your work";
break;
}
return $PGTitle;
}
public function CreateUniqueID($Val,$PreFix){
$val1 = strlen($Val);
$digit = "";
for($i=4; $i>$val1; $i--) {
$digit .= "0";
}
return $PreFix.$digit.$Val;
}
public function CreateUniqueIDForInvoce($Val){
$val1 = strlen($Val);
$digit = "";
for($i=5; $i>$val1; $i--) {
$digit .= "0";
}
return $digit.$Val;
}
public function CreateTicketNumber($Val){
$val1 = strlen($Val);
$digit = "";
for($i=5; $i>$val1; $i--) {
$digit .= "0";
}
return $digit.$Val;
}
public function InsertEmailLogData($Subject,$EmailBody,$IsSend,$FromEmailID="",$SentTo=""){
$ClientID = FetchClientID();
$SQL = "INSERT INTO log_email SET
Subject = '".AddFieldAddslashes($Subject)."',
EmailBody = '".AddFieldAddslashes($EmailBody)."',
IsSent = '".$IsSend."',
AddedDate = '".date("Y-m-d H:i:s")."',
AddedBy = '".$_SESSION['UserInfo']['UType']."',
AddedByID = '".$_SESSION['UserInfo']['UserID']."',
ClientID = '".$ClientID."',
SentFrom = '".$FromEmailID."',
SentTo = '".$SentTo."'";
$rsInsert = $this->sql_query($SQL);
return $rsInsert;
}
function call_stored_proc($procName,$para='',$returnType='array'){
if(empty($procName)) { return false; }
if(empty($this->CONN)) { return false; }
$conn = $this->CONN;
return $this->c_mysql_call($procName,$para,$returnType);
}
function c_mysql_call($procName, $params="",$returnType){
$returnType = 'fetch_'.$returnType;
$dbLink = $this->CONN;
if(!$dbLink) {
$ret_msg = "Wrong Query : ".$sql."--- Error :".$dbLink->error."";
if($_SERVER['HTTP_REFERER'] == '')
{
$DataArr = array("error"=>1);
ReturnPostFormData(array(),"error.html","Data fetch error <br /><strong>".$ret_msg."</strong>! <br /><br />Page = ".$this->PageName."<br>User ID : ".$_SESSION['UserInfo']['UserID']."<br>User Type : ".$_SESSION['UserInfo']['UType']."<br>User UniqueID : #".$_SESSION['UserInfo']['UniqueID']."<br> Date : ".date("d/m/Y h:i A"),1);
exit;
}else
{
$tmp = explode('admin/',$_SERVER['HTTP_REFERER']);
$DataArr = array("error"=>1);
ReturnPostFormData(array(),"error.html","Data fetch error <br /><strong>".$ret_msg."</strong>! <br /><br />Page = ".$this->PageName."<br>User ID : ".$_SESSION['UserInfo']['UserID']."<br>User Type : ".$_SESSION['UserInfo']['UType']."<br>User UniqueID : #".$_SESSION['UserInfo']['UniqueID']."<br> Date : ".date("d/m/Y h:i A"),1);
}
exit;
}
else
{
$sql = "CALL {$procName}({$params});";
$sqlSuccess = $dbLink->multi_query($sql);
if($sqlSuccess)
{
if($dbLink->more_results())
{
$result = $dbLink->use_result();
$output = array();
while($row = $result->{$returnType}())
{
$output[] = $row;
}
$result->free();
while($dbLink->more_results() && $dbLink->next_result())
{
$extraResult = $dbLink->use_result();
//mysql_result
if($extraResult instanceof mysql_free_result){
$extraResult->free();
}
}
return $output;
}
else
{
return true;
}
}
else
{
$ret_msg = "Wrong Query : ".$sql."--- Error :".$dbLink->error."";
if($_SERVER['HTTP_REFERER'] == '')
{
$DataArr = array("error"=>1);
ReturnPostFormData(array(),"error.html","Data fetch error <br /><strong>".$ret_msg."</strong>! <br /><br />Page = ".$this->PageName."<br>User ID : ".$_SESSION['UserInfo']['UserID']."<br>User Type : ".$_SESSION['UserInfo']['UType']."<br>User UniqueID : #".$_SESSION['UserInfo']['UniqueID']."<br> Date : ".date("d/m/Y h:i A"),1);
exit;
}else
{
$tmp = explode('admin/',$_SERVER['HTTP_REFERER']);
$DataArr = array("error"=>1);
ReturnPostFormData(array(),"error.html","Data fetch error <br /><strong>".$ret_msg."</strong>! <br /><br />Page = ".$this->PageName."<br>User ID : ".$_SESSION['UserInfo']['UserID']."<br>User Type : ".$_SESSION['UserInfo']['UType']."<br>User UniqueID : #".$_SESSION['UserInfo']['UniqueID']."<br> Date : ".date("d/m/Y h:i A"),1);
}
exit;
}
}
}
//ends the class over here
}
?>