<?php 
	class Api_model extends CI_Model
	{

		public function loginSurvey($staId)
		{
			$this->load->database();
			// $query = $this->db->get_where("baris_station" , array("db_stLoginId"=>$staId));
			$this->db->select('baris_station.*,baris_division.DivisionName');
		    $this->db->from('baris_station');
		    $this->db->join('baris_division', 'baris_station.DivisionId = baris_division.DivisionId','left');
		    $this->db->where('baris_station.db_stLoginId', $staId); 
		    $query = $this->db->get();
			$result = $query->result();
			if($result){
				if($result[0]->DivisionName == null)$result[0]->DivisionName="";

				$response["status"] = "success";
				$response["message"] = "station found successfully";
				$response["data"] = $result[0];
				echo json_encode($response);
			}else{
				$response["status"] = "error";
				$response["message"] = "station not found";
				echo json_encode($response);
			}
		}
		
		public function endUserLogin($username,$password,$orgid)
		{
			$this->load->database();
			$pass = md5($password);

			$SQL = "SELECT * FROM baris_userlogin WHERE db_userLoginName = '".$username."' AND db_password = '".$pass."' AND db_usertype = 'auditor' AND OrgID = ".$orgid;
			$query = $this->db->query($SQL);
			$result = $query->result();			
			
			// $this->db->select('baris_userlogin.*,baris_division.DivisionName');
		 //    $this->db->from('baris_userlogin');
		 //    $this->db->join('baris_division', 'baris_userlogin.DivisionId = baris_division.DivisionId','left');
		 //    $this->db->where('baris_userlogin.db_userLoginName', $username); 
		 //    $this->db->where('baris_userlogin.db_password', $pass); 
		 //    $this->db->where('baris_userlogin.OrgID', $orgid); 
		 //    $this->db->where('baris_userlogin.db_usertype', 'auditor'); 
		 //    $query = $this->db->get();
			// $result = $query->result();

			if($result){
				$response["status"] = "success";
				$response["message"] = "auditor found successfully";
				$response["data"] = $result[0];
				echo json_encode($response);
			}else{
				$response["status"] = "error";
				$response["message"] = "auditor not found";
				echo json_encode($response);
			}
		}

		public function getAllquestionBystd($stationId)
		{
			$this->load->database();
			$query = $this->db->get_where("baris_station" , array("stationId"=>$stationId));
			$result = $query->result();
			if($result){
				$SQL = "SELECT * FROM baris_question WHERE queId in (".$result[0]->db_questionsId.") ";
				$query = $this->db->query($SQL);
				$data = $query->result();
				//return $data;
				$response["status"] = "success";
				$response["message"] = "data found successfully";
				$response["data"] = $data;
				echo json_encode($response);
			}else{
				$response["status"] = "error";
				$response["message"] = "data not found";
				echo json_encode($response);
			}
		}


		// public function getsubquestionlist($queId)
		// {
		// 	$this->load->database();

		// 	$question 	= $this->Api_model->getAllquestion($queId);
		// 	$params 	= $this->Api_model->getParamsDetails($question[0]->db_paramId);
		// 	$pages		= $this->Api_model->getPagesDetails($question[0]->db_pagesId);

		// 	$paramsData = array();
		// 	foreach ($params as $key => $value) {
		// 		$param = array();
		// 		$param['paramId'] = $value->paramId;
		// 		$param['paramName'] = $value->paramName;
		// 		$param['pages'] = $pages;
		// 		array_push($paramsData, $param);
		// 	}

		// 	// $query = $this->db->get_where("baris_station" , array("stationId"=>$stationId));
		// 	// $result = $query->result();
		// 	if($params){
		// 		$response["status"] = "success";
		// 		$response["message"] = "data found successfully";
		// 		$response["data"] = $paramsData;
		// 		echo json_encode($response);
		// 	}else{
		// 		$response["status"] = "error";
		// 		$response["message"] = "data not found";
		// 		echo json_encode($response);
		// 	}
		// }

		public function getsubquestionlist($queId)
		{
			$this->load->database();

			$question 	= $this->Api_model->getAllquestion($queId);
			// $params 	= $this->Api_model->getParamsDetails($question[0]->db_paramId);
			// $pages		= $this->Api_model->getPagesDetails($question[0]->db_pagesId);
			$subqueData = array();
			$subQuesionId = explode(',', $question[0]->subqueId);
			foreach ($subQuesionId as $value) {
				$SQL = "SELECT * FROM baris_subquestion WHERE subqueId = ".$value;
				$query = $this->db->query($SQL);
				$result = $query->result();	
				$param = array();
				$param['subqueId'] = $result[0]->subqueId;
				$param['subqueName'] = $result[0]->subqueName;
				$param['db_paramId'] = $result[0]->db_paramId;
				$param['subqueType'] = $result[0]->subqueType;
				array_push($subqueData, $param);
			}
			
			if($question){
				$response["status"] = "success";
				$response["message"] = "data found successfully";
				$response["data"] = $subqueData;
				echo json_encode($response);
			}else{
				$response["status"] = "error";
				$response["message"] = "data not found";
				echo json_encode($response);
			}
		}

		public function getpageslist($queId)
		{
			$this->load->database();

			$question 	= $this->Api_model->getAllquestion($queId);
			if($question){
				$pages		= $this->Api_model->getPagesDetails($question[0]->db_pagesId);

				if($pages){
					$response["status"] = "success";
					$response["message"] = "data found successfully";
					$response["data"] = $pages;
					echo json_encode($response);
				}else{
					$response["status"] = "error";
					$response["message"] = "data not found";
					echo json_encode($response);
				}
			}else{
				$response["status"] = "error";
				$response["message"] = "data not found";
				echo json_encode($response);
			}
		}


		public function getAllquestion($queId = ""){
			$this->load->database();
			if(empty($queId))
				$query = $this->db->get('baris_question');
			else
				$query = $this->db->get_where("baris_question",array("queId"=>$queId));
			
			$result = $query->result();
			return $result;
		}

		public function getParamsDetails($subqueId){
			$this->load->database();
			
			//$query = $this->db->get_where("baris_param",array("queId"=>$queId));
			$SQL = "SELECT * FROM baris_subquestion WHERE subqueId = ".$subqueId;
			$query = $this->db->query($SQL);
			$result = $query->result();	
			
			$SQL = "SELECT * FROM baris_param where paramId in (".$result[0]->db_paramId.")";
			// $SQL = "
			// 	SELECT 
			// 	baris_param.* ,
			// 	baris_target.value
			// 	FROM 
			// 	baris_param 
			// 	LEFT JOIN baris_target ON baris_param.paramId = baris_target.pageId 
			// 	WHERE 
			// 	baris_param.paramId IN (".$result[0]->db_paramId.") AND 
			// 	baris_target.subqueId = ".$subqueId." ";
				
			$query = $this->db->query($SQL);
			$paramdata = $query->result();

			if($paramdata){
					$response["status"] = "success";
					$response["message"] = "data found successfully";
					$response["data"] = $paramdata;
					echo json_encode($response);
				}else{
					$response["status"] = "error";
					$response["message"] = "data not found";
					echo json_encode($response);
				}

		}

		public function getpageslistForSubque($pageid)
		{
			$this->load->database();
			//if(empty($orgId))
			$SQL = "SELECT * FROM baris_page where pageId in (".$pageid.") ORDER BY FIND_IN_SET(pageId,'".$pageid."')";
			// else
			// $SQL = "
			// 	SELECT 
			// 	baris_page.* ,
			// 	baris_target.value
			// 	FROM 
			// 	baris_page 
			// 	LEFT JOIN baris_target ON baris_page.pageId = baris_target.pageId 
			// 	WHERE 
			// 	baris_page.pageId IN (".$pageid.") AND 
			// 	baris_target.OrgID = ".$orgId." ";

			// echo $SQL;

			$query = $this->db->query($SQL);
			$pagedata = $query->result();
			if($pagedata){
				$response["status"] = "success";
				$response["message"] = "data found successfully";
				$response["data"] = $pagedata;
				echo json_encode($response);
			}else{
				$response["status"] = "error";
				$response["message"] = "data not found";
				echo json_encode($response);
			}
		}

		public function getPagesDetails($pageid){
			$this->load->database();
			$SQL = "SELECT * FROM baris_page where pageId in (".$pageid.") ORDER BY FIND_IN_SET(pageId,'".$pageid."')";
			$query = $this->db->query($SQL);
			return $query->result();
		}

		public function insertUserFeedback($stationId,$userId,$questionId,$subquestionId,$coachNo,$coachName,$OrgID,$DivisionId,$trainno,$departtime,$totalCoachCount,$tokenid,$arrivaltime,$workstarttime,$workcompletetime,$pageid,$avavalue)
		{ 
			
			$this->load->database();

			$date = date('Y-m-d H:i:s');
			//$$tokenid  = md5($stationId."".$userId."".date("Ymd"));
			$insertdata = array
			(
				'db_surveyStationId' 	=> $stationId,
				'db_surveyUserid' 		=> $userId,
				'db_surveyQuestionId' 	=> $questionId,
				'db_surveySubQuestionId' => $subquestionId,
				'db_surveyParamId' 		=> "0",
				'db_coachNo' 			=> $coachNo,
				'db_coachName' 			=> $coachName,
				'db_surveyPageId' 		=> $pageid,
				'db_surveyValue' 		=> $avavalue,
				'OrgID' 				=> $OrgID,
				'DivisionId' 			=> $DivisionId,
				'created_date' 			=> $date,
				'tokenid' 				=> $tokenid,
				'is_submit' 			=> "Y",
				'db_trainno' 			=> $trainno,
				'db_depart_time' 		=> $departtime,
				'db_totalCoachCount' 	=> $totalCoachCount,
				'db_arrival_time' 		=> $arrivaltime,
				'db_work_start_time' 	=> $workstarttime,
				'db_work_complete_time' => $workcompletetime
			);
			
			$insertquery = $this->db->insert("baris_survey" , $insertdata);
			/*if($insertquery){
				$response["status"] = "success";
				$response["message"] = "feedback inserted";
				echo json_encode($response);
			}else{
				$response["status"] = "error";
				$response["message"] = "feedback not inserted";
				echo json_encode($response);
			}*/
		}

		public function insertUserFeedback_demo($stationId,$userId,$questionId,$subquestionId,$coachNo,$coachName,$OrgID,$DivisionId,$trainno,$departtime,$totalCoachCount,$tokenid,$arrivaltime,$workstarttime,$workcompletetime,$pageid,$avavalue)
		{ 
			
			$this->load->database();

			$date = date('Y-m-d H:i:s');
			//$$tokenid  = md5($stationId."".$userId."".date("Ymd"));
			$insertdata = array
			(
				'db_surveyStationId' 	=> $stationId,
				'db_surveyUserid' 		=> $userId,
				'db_surveyQuestionId' 	=> $questionId,
				'db_surveySubQuestionId' => $subquestionId,
				'db_surveyParamId' 		=> "0",
				'db_coachNo' 			=> $coachNo,
				'db_coachName' 			=> $coachName,
				'db_surveyPageId' 		=> $pageid,
				'db_surveyValue' 		=> $avavalue,
				'OrgID' 				=> $OrgID,
				'DivisionId' 			=> $DivisionId,
				'created_date' 			=> $date,
				'tokenid' 				=> $tokenid,
				'is_submit' 			=> "Y",
				'db_trainno' 			=> $trainno,
				'db_depart_time' 		=> $departtime,
				'db_totalCoachCount' 	=> $totalCoachCount,
				'db_arrival_time' 		=> $arrivaltime,
				'db_work_start_time' 	=> $workstarttime,
				'db_work_complete_time' => $workcompletetime
			);
			
			$insertquery = $this->db->insert("baris_survey" , $insertdata);
			/*if($insertquery){
				$response["status"] = "success";
				$response["message"] = "feedback inserted";
				echo json_encode($response);
			}else{
				$response["status"] = "error";
				$response["message"] = "feedback not inserted";
				echo json_encode($response);
			}*/
		}


		public function insertSubUserFeedback($stationId,$userId,$questionId,$subquestionId,$paramid,$OrgID,$DivisionId,$tokenid,$auditorname,$extra_manpower,$pageid,$avavalue)
		{ 
			
			$this->load->database();

			$date = date('Y-m-d H:i:s');
			//$$tokenid  = md5($stationId."".$userId."".date("Ymd"));
			$insertdata = array
			(
				'db_surveyStationId' 	=> $stationId,
				'db_surveyUserid' 		=> $userId,
				'db_surveyQuestionId' 	=> $questionId,
				'db_surveySubQuestionId' => $subquestionId,
				'db_surveyParamId' 		=> $paramid,
				'db_surveyPageId' 		=> $pageid,
				'db_surveyValue' 		=> $avavalue,
				'OrgID' 				=> $OrgID,
				'DivisionId' 			=> $DivisionId,
				'created_date' 			=> $date,
				'tokenid' 				=> $tokenid,
				'auditorname'			=> $auditorname,
				'extra_manpower'		=> $extra_manpower,
				'is_submit' 			=> "Y"
			);
			
			$insertquery = $this->db->insert("baris_survey" , $insertdata);
			/*if($insertquery){
				$response["status"] = "success";
				$response["message"] = "feedback inserted";
				echo json_encode($response);
			}else{
				$response["status"] = "error";
				$response["message"] = "feedback not inserted";
				echo json_encode($response);
			}*/
		}

		public function deleteOngoingReport($tokenid)
		{
			$this->load->database();
			
			$this->db->where('tokenid',$tokenid);
			$this->db->delete('baris_survey');

			$response["status"] = "success";
			$response["message"] = "report deleted successfully";
			echo json_encode($response);
		}

		public function getOngoingReportforshift($stationId,$userId,$questionId,$subqueId)
		{
			$this->load->database();
			
			$SQL = "SELECT * FROM baris_survey where db_surveyStationId = ".$stationId." and db_surveyUserid = ".$userId." and db_surveyQuestionId = ".$questionId." and db_surveySubQuestionId = ".$subqueId." group by db_surveyParamId ORDER BY created_date asc";

			$query = $this->db->query($SQL);
			$shiftdata = $query->result();

			if(count($shiftdata) >0){
				$response["status"] = "success";
				$response["message"] = "report fetch successfully";
				$response["data"] = $shiftdata;
				echo json_encode($response);
			}else{
				$response["status"] = "error";
				$response["message"] = "data not found";
				echo json_encode($response);

			}
		}

		public function uploadImageReport($stationId,$userId,$processtype,$orgID,$divisionId,$remarks)
		{
			$this->load->database();
			
			// echo "<prev>";
			// print_r($_FILES);
			// die();

			$date = date('Y-m-d H:i:s');
			//$$tokenid  = md5($stationId."".$userId."".date("Ymd"));
			$image = "";
			if(!empty($_FILES['image']['name'])){
				
				$imgExt = pathinfo($_FILES['image']['name'],PATHINFO_EXTENSION);
				$extArr = array('jpg','JPG','jpeg','JPEG','png','PNG','gif','GIF','gif');
				
				if(!in_array($imgExt,$extArr)){
					// Please select proper image format for product image
					return 1;
					exit;
				}
				
				$imageName = date('YmdHis').'_'.rand(999999999,100000000).'.'.$imgExt;
				$dirfile = "assets/upload/".$imageName;
				if(move_uploaded_file($_FILES['image']['tmp_name'],$dirfile)){
					$image = $imageName;
				}
			}

			$insertdata = array
			(
				'db_surveyStationId' 	=> $stationId,
				'db_surveyUserid' 		=> $userId,
				'db_process_type' 		=> $processtype,
				'OrgID' 				=> $orgID,
				'DivisionId' 			=> $divisionId,
				'imagename' 			=> $image,
				'remarks'				=> $remarks,
				'created_date' 			=> $date
			);
			
			$insertquery = $this->db->insert("baris_pictures" , $insertdata);

			if(count($insertquery) >0){
				$response["status"] = "success";
				$response["message"] = "picture uploaded successfully";
				echo json_encode($response);
			}else{
				$response["status"] = "error";
				$response["message"] = "something wrong! try after sometime.";
				echo json_encode($response);

			}

		}

		public function getTarget($orgID,$questionId,$subqueId,$paramId)
		{
			$this->load->database();
			
			$SQL = "SELECT * FROM baris_target WHERE OrgID = ".$orgID." AND queId = ".$questionId." AND subqueId = ".$subqueId." AND pageId = ".$paramId;

			$query = $this->db->query($SQL);
			$targetdata = $query->result();

			if(count($targetdata) >0){
				$response["status"] = "success";
				$response["message"] = "Target fetched successfully";
				$response["data"] = $targetdata;
				echo json_encode($response);
			}else{
				$response["status"] = "error";
				$response["message"] = "Data not found";
				echo json_encode($response);
			}
		}
	}
?>