wjwapi/Home/Lib/Action/CronAction.class.php

<?php



class CronAction extends Action {
			


 
	public  function releaseRedisExpiredLicenseplate(  ){
		$start = time();
		$preselect_plate_queue = Redis("wjw_preselect_plate_queue","queue");	
		$plate_preselect_pool = Redis("plate_preselect_pool","set");
		do{	
			$info = $preselect_plate_queue -> pop();
			if(!$info){
				echo "no more message".PHP_EOL;
				sleep(1);
				continue;
			}
			if(!$info['LicensePlate']){
				echo "LicensePlate empty!".PHP_EOL;
				continue;
			}
			//过期预约车牌，释放到公选池
			if(time()>$info['ExpireTime']){
				$plate_preselect_pool -> add($info['LicensePlate']);
				echo 'LicensePlate: '.$info['LicensePlate'].' timeout, push to plate_preselect_pool'.PHP_EOL;
			}
		}while(time()-$start<60);
		
		
		/*
		$config = parse_url(C('REDIS_DSN'));
		$redis = new Redis();
		$redis->connect($config["host"],$config["port"]?:6379);  
		$redis->auth($config["pass"]?: ""); 
		$redis->select(trim($config['path'],'//') ? : 0);
		
		$all = $redis->hgetall('wjw_plate');
		foreach($all as $key=>$val){
			$data = json_decode($val,true);
			$orderstatus = M('jms_order')->where(array('LicensePlate'=>$key))->getField('OrderStatus');
			if($orderstatus == NULL){
						$time = time() - (C('EXPIREIN')*60);
						if($time > $data['Timestamp']){
							$result = $redis->sAdd('plate_preselect_pool' , $key);
							if(!$result){
								json_fail('释放过期车牌失败');
							}
						}
					}
					if($orderstatus == 2){
							$p = Redis("wjw_plate","hash");
							$res = $p->where($key)->delete();
							if(!$res){
								json_fail('删除过期车牌失败');
							}
							$result = $redis->sAdd('plate_preselect_pool' , $key);
							if(!$result){
								json_fail('释放过期车牌失败');
							}
					}
					if($orderstatus == 1){
					    $p = Redis("wjw_plate","hash");
					    $res = $p->where($key)->delete();
					    if(!$res){
					     json_fail('删除已开户车牌失败');
					    }
					}
		}
		json_success('执行完毕');
		*/
	}
	

}