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

<?php



class CronAction extends Action {
			


 
	public  function releaseRedisExpiredLicenseplate(  ){
		$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']){
							/*$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 == 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('执行完毕');
	}
	

}