git %!s(int64=6) %!d(string=hai) anos
pai
achega
e893ef3d9c
Modificáronse 2 ficheiros con 18 adicións e 3 borrados
  1. 5 2
      Home/Lib/Action/ApiAction.class.php
  2. 13 1
      Home/Lib/Action/IndexAction.class.php

+ 5 - 2
Home/Lib/Action/ApiAction.class.php

@@ -123,7 +123,7 @@ class ApiAction extends Action {
 		
 		//车牌加锁(20分钟)
 		$servers = [
-		    parse_url(C('REDIS_DSN_LOCK'),
+		    parse_url(C('REDIS_DSN_LOCK')),
 		];
 		$expirein = C('EXPIREIN')?:10;
 		$redLock = new \RedLock\RedLock($servers);
@@ -139,7 +139,10 @@ class ApiAction extends Action {
 			'LicensePlate' => $licenseplate
 		);
 		$preselect_plate_queue = Redis("wjw_preselect_plate_queue","queue");		
-		$preselect_plate_queue -> add($info);
+		$result = $preselect_plate_queue -> add($info);
+		if(!$result){
+			json_fail('预选车牌失败,请稍后重试');
+		}
 		//返回成功信息
 		$response = array(
 		  'LicensePlate' => $licenseplate,

+ 13 - 1
Home/Lib/Action/IndexAction.class.php

@@ -13,13 +13,25 @@ class IndexAction extends Action {
 	
  
 	public  function test(  ){
+		$info = array(
+			'ExpireTime' => time()+600,
+			'LicensePlate' => 'BJ000001'
+		);
+		$preselect_plate_queue = Redis("wjw_preselect_plate_queue","queue");		
+		//$result = $preselect_plate_queue -> add($info);
+		//var_dump($result);
+		var_dump($preselect_plate_queue -> pop());
+		exit;
+		
 		$servers = [
-		    parse_url(C('REDIS_DSN'),
+		    parse_url(C('REDIS_DSN')),
 		];
 		
 		$redLock = new RedLock($servers);
 		$lock = $redLock->lock('QS000001', 1000, $openid);
 		var_dump($lock);
+					  
+					  
 	}