@@ -36,9 +36,9 @@ discard block |
||
| 36 | 36 | |
| 37 | 37 | protected function registerDatabaseExtend() |
| 38 | 38 | { |
| 39 | - $this->app->resolving('db', function ($db) { |
|
| 39 | + $this->app->resolving('db', function($db) { |
|
| 40 | 40 | /** @var DatabaseManager $db */ |
| 41 | - $db->extend('ots', function ($config, $name) { |
|
| 41 | + $db->extend('ots', function($config, $name) { |
|
| 42 | 42 | $config['name'] = $name; |
| 43 | 43 | |
| 44 | 44 | return new Connection($config); |
@@ -48,9 +48,9 @@ discard block |
||
| 48 | 48 | |
| 49 | 49 | protected function registerCacheExtend() |
| 50 | 50 | { |
| 51 | - $this->app->resolving('cache', function ($cache) { |
|
| 51 | + $this->app->resolving('cache', function($cache) { |
|
| 52 | 52 | /** @var CacheManager $cache */ |
| 53 | - $cache->extend('ots', function ($app, $config) { |
|
| 53 | + $cache->extend('ots', function($app, $config) { |
|
| 54 | 54 | /** @var CacheManager $this */ |
| 55 | 55 | |
| 56 | 56 | /** @var Connection $connection */ |
@@ -156,7 +156,7 @@ discard block |
||
| 156 | 156 | return []; |
| 157 | 157 | } |
| 158 | 158 | |
| 159 | - $primaryKeys = Collection::make($keys)->values()->map(function ($key) { |
|
| 159 | + $primaryKeys = Collection::make($keys)->values()->map(function($key) { |
|
| 160 | 160 | return $this->makePrimaryKey($key); |
| 161 | 161 | }); |
| 162 | 162 | |
@@ -172,7 +172,7 @@ discard block |
||
| 172 | 172 | |
| 173 | 173 | $response = $this->getOts()->batchGetRow($request); |
| 174 | 174 | |
| 175 | - $results = Collection::make($keys)->values()->mapWithKeys(function ($key) { |
|
| 175 | + $results = Collection::make($keys)->values()->mapWithKeys(function($key) { |
|
| 176 | 176 | return [$key => null]; |
| 177 | 177 | })->toArray(); |
| 178 | 178 | |
@@ -207,7 +207,7 @@ discard block |
||
| 207 | 207 | return true; |
| 208 | 208 | } |
| 209 | 209 | |
| 210 | - $rows = Collection::make($values)->map(function ($value, $key) use ($seconds) { |
|
| 210 | + $rows = Collection::make($values)->map(function($value, $key) use ($seconds) { |
|
| 211 | 211 | return [ |
| 212 | 212 | 'operation_type' => OperationTypeConst::CONST_PUT, |
| 213 | 213 | 'condition' => RowExistenceExpectationConst::CONST_IGNORE, |
@@ -252,7 +252,7 @@ discard block |
||
| 252 | 252 | */ |
| 253 | 253 | public function increment($key, $value = 1) |
| 254 | 254 | { |
| 255 | - return $this->incrementOrDecrement($key, $value, function ($current, $value) { |
|
| 255 | + return $this->incrementOrDecrement($key, $value, function($current, $value) { |
|
| 256 | 256 | return $current + $value; |
| 257 | 257 | }); |
| 258 | 258 | } |
@@ -265,7 +265,7 @@ discard block |
||
| 265 | 265 | */ |
| 266 | 266 | public function decrement($key, $value = 1) |
| 267 | 267 | { |
| 268 | - return $this->incrementOrDecrement($key, $value, function ($current, $value) { |
|
| 268 | + return $this->incrementOrDecrement($key, $value, function($current, $value) { |
|
| 269 | 269 | return $current - $value; |
| 270 | 270 | }); |
| 271 | 271 | } |
@@ -286,7 +286,7 @@ discard block |
||
| 286 | 286 | return false; |
| 287 | 287 | } |
| 288 | 288 | |
| 289 | - $new = $callback((int) $current, $value); |
|
| 289 | + $new = $callback((int)$current, $value); |
|
| 290 | 290 | |
| 291 | 291 | $request = [ |
| 292 | 292 | 'table_name' => $this->getTable(), |