<?php if ( ! defined('BASEPATH')) exit('No direct script access allowed');
/**
 * Viettel Class
 * 
 * @author dzungnv02
 *
 */

class Sendmessage extends MX_Controller 
{
	private $_xmlHeader = "<?xml version=\"1.0\" encoding=\"utf-8\" ?>\n";
		
	public function __construct() 
	{
		parent::__construct();
	}
	
	public function index () 
	{
		error_reporting(E_ALL);
		$this->load->model('Services_model');
		//$this->Services_model->cardPaidProcess($aryParams);
		//echo $this->Services_model->processMORequest('01662860000', strtoupper('sbg DDT 0979947802 123456'));
		$aryParams = array(
			'EWalletID' => 0,
			'CardSerial' => '122346',
			'PinCard' => '123456789',
		);
		echo $this->Services_model->cardPaidProcess($aryParams);
	}
	
	public function testmo() {
		$url = 'http://10.58.38.162/violetservice/soanbai/mo?wsdl';

		$aryParams = array(
				'username' => 'sbg',
				'password' => 'sbg571285',
				'requestID' => '4',
				'userID' => '841662860000',
				'receiverID' => '84988568786',
				'serviceID' => '8062',
				'commandCode' => 'SBG',
				'contentType' => '0',
				'info' => 'SBG DK',
				'receiveTime' => date('Ymd H:i:s')
		);
		
		$client = new nusoap_client($url, false);
		$client->useHTTPPersistentConnection();
		$xml = $this->load->view('mo', null, true);
		
		$operator = 'MOReceiver';
		$operation = 'http://tempuri.org/MOReceiver';

		$client->soap_defencoding = 'UTF-8';
		$client->operation = $operation;
		$result = $client->send($this->_xmlHeader.$xml, $operation);		
		//$result = $client->call('MOReceiver', $aryParams ,$operator ,$operation);
		
		echo $client->responseData;
		
		/* $err = $client->getError();
			
		if ($err) {
			echo '<p><b>Error: ' . $err . '</b></p>';
		}
		
		echo "<br/>";
		echo "<h2>Request</h2>";
		echo "<pre>" . htmlspecialchars($client->request, ENT_QUOTES) . "</pre>";
		echo "<h2>Response</h2>";
		echo "<pre>" . htmlspecialchars($client->response, ENT_QUOTES) . "</pre>"; */		
	}
	
	public function send($msg, $receiverID)
	{
		$url = $this->config->item('mt_service_url');
		$username = 'sbg';
		$password = 'sbg56ab77cdsgb';
		$operator = 'InsertMT';
		$operation = 'http://tempuri.org/InsertMT';
		
		$aryMatch = array();
		if (preg_match('/^(0)([0-9]{9,10})$/', $receiverID, $aryMatch) == 1) {
			$receiverID = '84'. $aryMatch[2];
		}
		
		$aryParams = array(
				'User' => $username,
				'Pass' => $password,
				'CPCode' => '601',
				'UserID' => '841662860000',
				'RequestID' => '4',
				'ReceiverID' => $receiverID,
				'ServiceID' => '8062',
				'CommandCode' => 'SBG',
				'ContentType' => '0',
				'Info' => urldecode($msg).' - Host: '.$_SERVER['HTTP_HOST'].' - '. date('Y-m-d H:i:s')//'Test MT '. date('Y-m-d H:i:s'),
		);
	
		$xml = $this->load->view('mt', $aryParams, true);
		$client = new nusoap_client($url);
		$client->useHTTPPersistentConnection();
		$client->soap_defencoding = 'UTF-8';
		$client->operation = $operation;
	
		$result = $client->send($this->_xmlHeader.$xml, $operation);
		$err = $client->getError();
			
		if ($err) {
			echo '<p><b>Error: ' . $err . '</b></p>';
		}
		
		var_dump($result);
		
		echo "<br/>";
		echo "<h2>Request</h2>";
		echo "<pre>" . htmlspecialchars($client->request, ENT_QUOTES) . "</pre>";
		echo "<h2>Response</h2>";
		echo "<pre>" . htmlspecialchars($client->response, ENT_QUOTES) . "</pre>";
	
	}
	
	public function topup () 
	{
		$url = $this->config->item('topup_service_url');
		
		//echo file_get_contents($url);
		//exit();
		
		$operation = 'http://tempuri.org/ITopupService/TopUp';
		
		$username = 'sbg';
		$password = 'sbg56ab77cdsgb';
		
		$aryParams = array(
			'EWalletID' => 0,
			'CardSerial' => '1111',
			'PinCard' => '222',
		);
		$xml = $this->load->view('topup', $aryParams, true);
		$client = new nusoap_client($url);
		$client->useHTTPPersistentConnection();
		$client->soap_defencoding = 'UTF-8';
		$client->operation = $operation;
		
		$result = $client->send($this->_xmlHeader.$xml, $operation);
		$err = $client->getError();
		
		if ($client->fault) {
		    echo "<h2>Fault loi:</h2><pre>";
		    print_r($result);
		    echo "</pre>";
		}
		else {
		    $error = $client->getError();
		    if ($error) {
		        echo "<h2>Error</h2><pre>" . $error . "</pre>";
		    }
		    else {
		        echo "<h2>Ket Qua</h2><pre>";
		        var_dump($result);
		        echo "</pre>";
		    }
		}
		echo "<br/>";
		echo "<h2>Request</h2>";
		echo "<pre>" . htmlspecialchars($client->request, ENT_QUOTES) . "</pre>";
		echo "<h2>Response</h2>";
		echo "<pre>" . htmlspecialchars($client->response, ENT_QUOTES) . "</pre>";
		
	}
	
	public function charging ()
	{
		$url = $this->config->item('charging_service_url');
		
		$username = $this->config->item('charging_username');
		$password = $this->config->item('charging_password');
		
		$operator = 'processCharging';
		$operation = 'http://tempuri.org/processCharging';
		
		$aryParams = array(
				'user' => $username,
				'pass' => $password,
				'MSISDN' => '01662860000',
				'Charging' => '100',
				'Contents' => 'Namta-Active'
		);
		
		$xml = $this->load->view('charging', $aryParams, true);
		$client = new nusoap_client($url);
		$client->useHTTPPersistentConnection();
		$client->soap_defencoding = 'UTF-8';
		$client->operation = $operation;
		
		$result = $client->send($this->_xmlHeader.$xml, $operation);
		$err = $client->getError();
			
		if ($err) {
			echo '<p><b>Error: ' . $err . '</b></p>';
		}
		
		var_dump($result);
		
		echo "<br/>";
		echo "<h2>Request</h2>";
		echo "<pre>" . htmlspecialchars($client->request, ENT_QUOTES) . "</pre>";
		echo "<h2>Response</h2>";
		echo "<pre>" . htmlspecialchars($client->response, ENT_QUOTES) . "</pre>";		
	}
	
	public function collaborator () 
	{
		error_reporting(E_ALL);

		$this->load->model('Services_model');
		
		//$totalpage = 10213;
		
		// get total page
		$totalpage = 1;
		
		$default = $this->Services_model->getCollaborator(2,1,100);
		//var_dump($default);
		$data = mb_convert_encoding($default, 'UTF-8', 'ISO-8859-1');
		if($data){
			$xml = simplexml_load_string($data);
			$xml->registerXPathNamespace("S", "http://schemas.xmlsoap.org/soap/envelope/");
			
			$xml = $xml->xpath('//S:Body');
			$xml = $xml[0];

			$xml->registerXPathNamespace("ns2", "http://process.wsim.viettel.com/");
			
			$totalpage = $xml->xpath('//return//totalpage');
			$totalpage = (int)$totalpage[0];
		}
		
		for ($i=1; $i<=$totalpage; $i++){
			$result = $this->Services_model->getCollaborator(2,$i,100);
			$data = mb_convert_encoding($result, 'UTF-8', 'ISO-8859-1');
			if($data && $data != -1){
				$xml = simplexml_load_string($data);
				$xml->registerXPathNamespace("S", "http://schemas.xmlsoap.org/soap/envelope/");
				$xml = $xml->xpath('//S:Body');
				$xml = $xml[0];
				$xml->registerXPathNamespace("ns2", "http://process.wsim.viettel.com/");
				$lst = $xml->xpath('//return//lst');
				foreach($lst as $item){
					$item = (array)$item;
			
					$data = array(
							'address'=> (string)$item['address'],
							'code'=>(string)$item['code'],
							'district'=>(string)$item['district'],
							'email'=>(string)$item['email'],
							'id'=>(int)$item['id'],
							'full_name'=>(string)$item['name'],
							'cellphone'=>(string)$item['phone'],
							'precinct'=>(string)$item['precinct'],
							'province'=>(string)$item['province'],
							'updated_time'=>date('Y-m-d H:i:s')
						);
					write_file('./log/sync_collaborator.log', var_export($data, TRUE), FOPEN_WRITE_CREATE);
					if ((string)$item['phone']){
						$this->Services_model->syncCollaborator($data);
					}
				}
			}else{
				$logMsg = date('Y-m-d H:i:s') . " Result is null \n";
				write_file('./log/sync_collaborator.log', $logMsg, FOPEN_WRITE_CREATE);
			}
		}
	}
}

	function fix_latin1_mangled_with_utf8_maybe_hopefully_most_of_the_time($str)
	{
		return preg_replace_callback('#[\\xA1-\\xFF](?![\\x80-\\xBF]{2,})#', 'utf8_encode_callback', $str);
	}

	function utf8_encode_callback($m)
	{
		return utf8_encode($m[0]);
	}