<?php namespace App\Http\Controllers;

use App\Http\Controllers\Controller;

use Auth;
use Input;
/*use Session;
use Redirect;
use Crypt;
use Mail;
use Hash;
use URL;
use Request;
use Cache;
use File;
use Route;*/

use App\Models\Group;
use App\Models\Sipid;
use App\Models\Message;
use App\Models\Role;
use App\Models\Kqueue;
use App\Models\ConfServer;
use App\Models\LiveConf;
use App\Jobs\KFriendLib;
use App\Jobs\KPushNotify;
use App\Jobs\KFileLib;
use App\Jobs\KAuthLib;
use App\Jobs\KHRMSLib;

use Illuminate\Console\Command;
use Mail;
use DB;
use Config;

use App\Models\User;
use App\Models\Accesslog;

use App\Models\CRMCall;
use Schema;
use PDO;

use Illuminate\Database\Schema\Blueprint;

use \Aws\Ec2\Ec2Client;

class egController extends Controller {


 public function eg()
	{

	$server_ip = "10.3.179.49";
	$location = "Mumbai";

    $wakka = new KHRMSLib();

  $kformlib=new \App\Jobs\KFormLib($wakka->HRCoreVars["HRFiledsStr"]);
  $kformlib->gthis=$wakka;

  $themehome=$wakka->GetThemePath('/');
  $updatetime=time();

  $clientlst=$wakka->GetBBBUserData("clientslist");

          $isadmin=$wakka->IsAdmin();
          $username=$wakka->GetUserName();
          $triggers=Input::get("triggers");
          $tmpstr=explode(",",$kformlib->HRFiledsStr);

          $success="";$message="";$successcnt=0;$duplicatecount=0;

	     $conn = array(
                                'driver'    => 'mysql',
                                'host'      => '10.3.177.14',
                                'database'  => env('DB_DATABASE', 'kstych_flexydial'),
                                'username'  => env('DB_USERNAME', 'root'),
                                'password'  => env('DB_PASSWORD', 'yb9738z'),
                                'charset'   => 'utf8',
                                'collation' => 'utf8_unicode_ci',
                                'prefix'    => '',
                                'options'   => array(
                                        PDO::ATTR_TIMEOUT => 5,
                                        ),
                                );
                        Config::set("database.connections.conn", $conn);

                        DB::connection("conn")->getDatabaseName();

      $excelarray = DB::connection("conn")->select(DB::raw("select * from bz_record_upload_uat where SERVER_IP='10.3.179.49' and ins_date>'2016-11-29' order by auto_id asc limit 0,1"));


  foreach($excelarray as $key => $array){
    $excelarray[$key] = (array)$array;
}

	$highestColumn = DB::connection("conn")->select(DB::raw("select count(*) as cnt from information_schema.columns where table_name='bz_record_upload_uat'"));
    $highestColumn = $highestColumn[0]->cnt;

          $highestrow = count($excelarray);

          $flag = 0;
          $editflag=0;

          for($i=0;$i<=$highestrow;$i++)
          {
          if($excelarray[$i]["id"]!="")
            {
              if($excelarray[$i]["id"]=="CREATE")
              {
                                        //$excelarray[$i]["id"]=$wakka->Query("insert into","","records",array('created'=>date('Y-m-d H:i:s')));
              }
              else $excelarray[$i]["id"]=intval($excelarray[$i]["id"]);

              if($wakka->getCount("records","id='".$excelarray[$i]["id"]."'")==1)
              {
                                $empdata=$wakka->getPerson($excelarray[$i]["id"]);
                                $ppldata=$empdata["peopledata"];
                                $createdlog=$empdata['modifylog'];
                                $fdirty=$empdata['dirty'];

                                $createdlog[$updatetime]=$username."::";
                                $createdlog["updated"]=$updatetime;
				
				$newdata=$ppldata;
                                foreach($excelarray[$i] as $key => $value)
                                        {
                                                        if($value!="")
                                                        {
                                                                if("A".$ppldata[$key]!="A".$value)//forcing string comparrision //MAGIC
                                                                {
                                                                        $value=str_replace("'"," ",$value);
                                                                        if(strstr($createdlog[$updatetime],$key)==FALSE)$createdlog[$updatetime].="$key|".str_replace(array("|",",")," ",$ppldata[$key])."|".str_replace(array("|",",")," ",$value).",";

                                                                        $fdirty[$key]=1;

                                                                        $newdata[$key]=$value;
                                                                }
                                                        }
                                        }
                                $empdata["peopledata"]=$newdata;
                                $empdata['modifylog']=$createdlog;
                                $empdata['dirty']=$fdirty;

                                //$wakka->setPerson($excelarray[$i]["id"],$empdata);
                                $excelarray[$i]['modified']=date('Y-m-d H:i:s');
                                $successArr[] = $excelarray[$i];
               }
        }
	else
        {
                $reason = "";

                if($excelarray[$i]["id"]=="")
                        $reason .= "Column ID is blank,";

                $excelarray[$i]['server_ip'] = $server_ip;
		$excelarray[$i]['location'] = $location;

		if($excelarray[$i]["clientcode"]!="")
		$excelarray[$i]['cust_id'] = $excelarray[$i]["clientcode"];

		$excelarray[$i]['Reason'] = $reason;

                $failureArr[] = $excelarray[$i];
        }

}

	if(!empty($successArr)){
	foreach($successArr as $succes)
	{
		$setSuccess=array();

		$setSuccess[] = "server_ip='$server_ip'";
		$setSuccess[] = "location='$location'";
		$setSuccess[] = "record_id='".$succes['id']."'";
		$setSuccess[] = "cust_id='".$succes['clientcode']."'";
		$setSuccess[] = "modified='".$succes['modified']."'";

		$setSuccess = implode(",",$setSuccess);
		
		DB::connection("conn")->insert(DB::raw("insert into bz_record_upload_uat_success set $setSuccess"));
	}
	}

	if(!empty($failureArr)){
	foreach($failureArr as $failur)
        {
		$setFailure=array();

                $setFailure[] = "server_ip='$server_ip'";
                $setFailure[] = "location='$location'";
                $setFailure[] = "cust_id='".$failur['clientcode']."'";
                $setFailure[] = "reason='".$failur['Reason']."'";

                $setFailure = implode(",",$setFailure);

		DB::connection("conn")->insert(DB::raw("insert into bz_record_upload_uat_failure set $setFailure"));
        }
	}

        DB::connection("conn")->disconnect();
	


	}
  
}