Subversion Repositories SmartDukaan

<?php

class SaholiccheckerShell extends AppShell {

    public $uses = array('User','UserAccount');		

    public function main() {

		Configure::load('live');

		$conditions = array('UserAccount.account_key' => -1);

		$userAccounts = $this->UserAccount->find('all',array('conditions' => $conditions,'recursive'=>-1));

		if(!empty($userAccounts)) {

			foreach($userAccounts AS $account) {

				$sql = "DELETE FROM user_accounts WHERE user_id =".$account['UserAccount']['user_id'];

				$this->out($sql);

				$this->UserAccount->query($sql);

			}

		}

    	$apihost = Configure::read('saholicapihost');

    	$users = $this->User->find('all',array('fields'=>array('id','email'),'recursive'=>-1));

		foreach ($users as $key => $user) {

			$userId = $user['User']['id'];

			$email = $user['User']['email'];

			$options = array('conditions'=>array('user_id' => $userId,'account_type' => 'saholic'),'recursive'=>-1);

			$exists = $this->UserAccount->find('count',$options);

			if(!$exists){

				$url = $apihost."register?email=$email&from=profitmandi";

				$response = $this->make_request($url,null);

				$this->out('response '.print_r($response,1));

				if(!empty($response)) {

					if($response['userId']<1)return;

					$data = array('account_type'=>'saholic','user_id'=>$userId,'account_key'=>$response['userId']);

					$this->UserAccount->create();

					$this->UserAccount->save($data);

					$data = array('account_type'=>'cartId','user_id'=>$userId,'account_key'=>$response['cartId']);

					$this->UserAccount->create();

					$this->UserAccount->save($data);

				}

			}

		}

	}

	function make_request($url,$fields,$format='json'){

		$this->out("[url] $url");

		$this->out("[fields] ".print_r($fields,1));

		$fields_string = '';

		//open connection

		$ch = curl_init();

		//set the url, number of POST vars, POST data

		curl_setopt($ch,CURLOPT_URL, $url);

		curl_setopt($ch,CURLOPT_RETURNTRANSFER , true);

		if(!empty($fields)) {

			curl_setopt($ch,CURLOPT_POSTFIELDS, $fields);

			curl_setopt($ch, CURLOPT_HTTPHEADER, array(                                                                          

			    'Content-Type: application/json',                                                                                

			    // 'Content-Length: ' . sizeof($fields))                                                                       

			    'Content-Length: ' . strlen($fields))                                                                       

			);   

		}

		//execute post

		$result = curl_exec($ch);

		$this->log("[response] ".print_r($result,1),'api');

		//close connection

		curl_close($ch);

		switch($format){

			case 'json':

			$response = json_decode($result,1);

			break;

		}

		return $response;	

	}

}