@@ -151,7 +151,7 @@ discard block |
||
| 151 | 151 | return []; |
| 152 | 152 | } |
| 153 | 153 | |
| 154 | - $primaryKeys = Collection::make($keys)->values()->map(function ($key) { |
|
| 154 | + $primaryKeys = Collection::make($keys)->values()->map(function($key) { |
|
| 155 | 155 | return $this->makePrimaryKey($key); |
| 156 | 156 | }); |
| 157 | 157 | |
@@ -165,7 +165,7 @@ discard block |
||
| 165 | 165 | |
| 166 | 166 | $response = $this->ots->batchGetRow($request); |
| 167 | 167 | |
| 168 | - $results = Collection::make($keys)->values()->mapWithKeys(function ($key) { |
|
| 168 | + $results = Collection::make($keys)->values()->mapWithKeys(function($key) { |
|
| 169 | 169 | return [$key => null]; |
| 170 | 170 | })->toArray(); |
| 171 | 171 | |
@@ -201,7 +201,7 @@ discard block |
||
| 201 | 201 | return true; |
| 202 | 202 | } |
| 203 | 203 | |
| 204 | - $rows = Collection::make($values)->map(function ($value, $key) use ($seconds) { |
|
| 204 | + $rows = Collection::make($values)->map(function($value, $key) use ($seconds) { |
|
| 205 | 205 | return [ |
| 206 | 206 | 'operation_type' => OperationTypeConst::CONST_PUT, |
| 207 | 207 | 'condition' => RowExistenceExpectationConst::CONST_IGNORE, |
@@ -245,7 +245,7 @@ discard block |
||
| 245 | 245 | */ |
| 246 | 246 | public function increment($key, $value = 1) |
| 247 | 247 | { |
| 248 | - return $this->incrementOrDecrement($key, $value, function ($current, $value) { |
|
| 248 | + return $this->incrementOrDecrement($key, $value, function($current, $value) { |
|
| 249 | 249 | return $current + $value; |
| 250 | 250 | }); |
| 251 | 251 | } |
@@ -259,7 +259,7 @@ discard block |
||
| 259 | 259 | */ |
| 260 | 260 | public function decrement($key, $value = 1) |
| 261 | 261 | { |
| 262 | - return $this->incrementOrDecrement($key, $value, function ($current, $value) { |
|
| 262 | + return $this->incrementOrDecrement($key, $value, function($current, $value) { |
|
| 263 | 263 | return $current - $value; |
| 264 | 264 | }); |
| 265 | 265 | } |
@@ -278,7 +278,7 @@ discard block |
||
| 278 | 278 | return false; |
| 279 | 279 | } |
| 280 | 280 | |
| 281 | - $new = $callback((int) $current, $value); |
|
| 281 | + $new = $callback((int)$current, $value); |
|
| 282 | 282 | |
| 283 | 283 | $request = [ |
| 284 | 284 | 'table_name' => $this->table, |
@@ -35,9 +35,9 @@ discard block |
||
| 35 | 35 | |
| 36 | 36 | protected function registerDatabaseExtend() |
| 37 | 37 | { |
| 38 | - $this->app->resolving('db', function ($db) { |
|
| 38 | + $this->app->resolving('db', function($db) { |
|
| 39 | 39 | /** @var DatabaseManager $db */ |
| 40 | - $db->extend('ots', function ($config, $name) { |
|
| 40 | + $db->extend('ots', function($config, $name) { |
|
| 41 | 41 | $config['name'] = $name; |
| 42 | 42 | return new Connection($config); |
| 43 | 43 | }); |
@@ -46,9 +46,9 @@ discard block |
||
| 46 | 46 | |
| 47 | 47 | protected function registerCacheExtend() |
| 48 | 48 | { |
| 49 | - $this->app->resolving('cache', function ($cache) { |
|
| 49 | + $this->app->resolving('cache', function($cache) { |
|
| 50 | 50 | /** @var CacheManager $cache */ |
| 51 | - $cache->extend('ots', function ($app, $config) { |
|
| 51 | + $cache->extend('ots', function($app, $config) { |
|
| 52 | 52 | /** @var CacheManager $this */ |
| 53 | 53 | |
| 54 | 54 | /** @var Connection $connection */ |