MigrateOldDatabase::migrateLeagueUsers() - Code Metrics - t2t2/draft - Measure and Improve Code Quality continuously with Scrutinizer

MigrateOldDatabase::migrateLeagueUsers() B
last analyzed 2016-09-26 09:48 UTC

↳ Parent: MigrateOldDatabase

Complexity

Conditions	6
Paths	9

Size

Total Lines	41
Code Lines	26

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	42

Importance

Changes

Metric	Value
dl	0
loc	41
ccs	0
cts	32
cp	0
rs	8.439
c	0
b	0
f	0
cc	6
eloc	26
nc	9
nop	1
crap	42

<?php

use Illuminate\Console\Command;
use Illuminate\Support\Collection;
use Symfony\Component\Console\Input\InputArgument;

class MigrateOldDatabase extends Command {
namespace YourVendor;

class YourClass { }

	/**
	 * The console command name.
	 *
	 * @var string
	 */
	protected $name = 'upgrade:old-database';

	/**
	 * The console command description.
	 *
	 * @var string
	 */
	protected $description = 'Upgrade database from alpha.';

	/**
	 * Execute the console command.
	 *
	 * @return mixed
	 */
	public function fire() {

		if (App::environment() == 'production' || ! $this->confirm('Are you sure?')) {
			$this->error('Disabled for safety');

			return;
		}

		$disableForeignKeyChecks = in_array(DB::connection()->getDriverName(), ['mysql']);

		Eloquent::unguard();
		if ($disableForeignKeyChecks) {
			DB::statement('SET FOREIGN_KEY_CHECKS=0;');
		}

		DB::beginTransaction();

		// Users
		$users = $this->migrateUsers();
		$this->migrateMovies();
		$this->migrateMovieEarnings();
		$this->migrateLeagues();
		$league_movie_by_league_and_movie_id = $this->migrateLeagueMovies();
		$team_by_league_and_user_id = $this->migrateLeagueUsers($users);
		$this->migrateLeagueMovieUsers($team_by_league_and_user_id, $league_movie_by_league_and_movie_id);


		DB::commit();
		if ($disableForeignKeyChecks) {
			DB::statement('SET FOREIGN_KEY_CHECKS=1;');
		}
	}

	/**
	 * Get stuff from old database
	 *
	 * @return \Illuminate\Database\Connection
	 */
	public function fromOldDB() {
		return DB::connection($this->argument('old-connection'));
	}

	/**
	 * Get the console command arguments.
	 *
	 * @return array
	 */
	protected function getArguments() {
		return [
			['old-connection', InputArgument::REQUIRED, 'The old connection to use'],
		];
	}

	/**
	 * Get the console command options.
	 *
	 * @return array
	 */
	protected function getOptions() {
		return [
		];
	}

	/**
	 * @return Collection Users
	 */
	protected function migrateUsers() {
		$this->info('Migrating users...');
		$users = (new Collection($this->fromOldDB()->table('users')->get()))->keyBy('id');
		$count = 0;
		foreach ($users as $user) {
			if (++$count % 1000 == 0) $this->info($count);
			DB::table('users')->insert([
				'id'          => $user->id,
				'username'    => $user->username,
				'displayname' => $user->displayname,
				'email'       => $user->email ?: null,
				'admin'       => $user->admin,
				'created_at'  => $user->created_at,
				'updated_at'  => $user->updated_at,
			]);
		}

		return $users;
	}

	/**
	 */
	protected function migrateMovies() {
		$this->info('Migrating movies...');
		$movies = (new Collection($this->fromOldDB()->table('movies')->get()))->keyBy('id');
		$count = 0;
		foreach ($movies as $movie) {
			if (++$count % 1000 == 0) $this->info($count);
			DB::table('movies')->insert([
				'id'                 => $movie->id,
				'name'               => $movie->name,
				'boxmojo_id'         => $movie->boxmojo_id,
				'release'            => $movie->release,
				'latest_earnings_id' => $movie->latest_earnings_id,
				'created_at'         => $movie->created_at,
			]);
		}

	}

	/**
	 */
	protected function migrateMovieEarnings() {
		$this->info('Migrating movie_earnings...');
		$movie_earnings = (new Collection($this->fromOldDB()->table('movie_earnings')->get()))->keyBy('id');
		$count = 0;
		foreach ($movie_earnings as $movie_earning) {
			if (++$count % 1000 == 0) $this->info($count);
			DB::table('movie_earnings')->insert([
				'id'         => $movie_earning->id,
				'movie_id'   => $movie_earning->movie_id,
				'date'       => $movie_earning->date,
				'domestic'   => $movie_earning->domestic,
				'created_at' => $movie_earning->created_at,
				'updated_at' => $movie_earning->updated_at,
			]);
		}
	}

	/**
	 */
	protected function migrateLeagues() {
		$this->info('Migrating leagues...');
		$leagues = (new Collection($this->fromOldDB()->table('leagues')->get()))->keyBy('id');
		$count = 0;
		foreach ($leagues as $league) {
			if (++$count % 1000 == 0) $this->info($count);
			DB::table('leagues')->insert([
				'id'          => $league->id,
				'name'        => $league->name,
				'slug'        => $league->slug,
				'description' => $league->description,
				'url'         => $league->url,
				'mode'        => $league->mode,
				'money'       => $league->money,
				'units'       => $league->units,
				'extra_weeks' => $league->extra_weeks,
				'start_date'  => $league->start_date,
				'end_date'    => $league->end_date,
				'active'      => true,
				'private'     => $league->private,
				'featured'    => $league->featured,
				'created_at'  => $league->created_at,
				'updated_at'  => $league->updated_at,
			]);
		}
	}

	/**
	 * @return array
	 */
	protected function migrateLeagueMovies() {
		$this->info('Migrating league_movies...');
		$league_movies = (new Collection($this->fromOldDB()->table('league_movie')->get()))->keyBy('id');
		$league_movie_by_league_and_movie_id = [];

		$count = 0;
		foreach ($league_movies as $league_movie) {
			if (++$count % 1000 == 0) $this->info($count);
			$league_movie_id = DB::table('league_movies')->insertGetId([
				// ID's are skippable here, so getting fresh ones
				'league_id'          => $league_movie->league_id,
				'movie_id'           => $league_movie->movie_id,
				'price'              => $league_movie->price,
				'latest_earnings_id' => $league_movie->latest_earnings_id,
				'created_at'         => $league_movie->created_at,
				'updated_at'         => $league_movie->updated_at,
			]);

			$league_movie_by_league_and_movie_id[$league_movie->league_id][$league_movie->movie_id] = $league_movie_id;
		}

		return $league_movie_by_league_and_movie_id;
	}

	/**
	 * @param $users
	 *
	 * @return array
	 */
	protected function migrateLeagueUsers(Collection $users) {
		$this->info('Migrating league_users...');
		$league_users = (new Collection($this->fromOldDB()->table('league_user')->get()))->keyBy('id');
		$team_by_league_and_user_id = [];

		$count = 0;
		foreach ($league_users as $league_user) {
			if (++$count % 500 == 0) $this->info($count);
			// For league admins
			if ($league_user->admin) {
				DB::table('league_admins')->insert([
					// Skip id's
					'league_id'  => $league_user->league_id,
					'user_id'    => $league_user->user_id,
					'created_at' => $league_user->created_at,
					'updated_at' => $league_user->updated_at,
				]);
			}
			// For league players create a team named after them
			if ($league_user->player) {
				$team_id = DB::table('league_teams')->insertGetId([
					// Get a new ID
					'league_id'  => $league_user->league_id,
					'name'       => $users->get($league_user->user_id)->displayname ?: $users->get($league_user->user_id)->username,
					'created_at' => $league_user->created_at,
					'updated_at' => $league_user->updated_at,
				]);
				$team_by_league_and_user_id[$league_user->league_id][$league_user->user_id] = $team_id;

				DB::table('league_team_user')->insert([
					// Skip id's
					'league_team_id' => $team_id,
					'user_id'        => $league_user->user_id,
					'created_at'     => $league_user->created_at,
					'updated_at'     => $league_user->updated_at,
				]);
			}
		}

		return $team_by_league_and_user_id;
	}

	/**
	 * @param $team_by_league_and_user_id
	 * @param $league_movie_by_league_and_movie_id
	 */
	protected function migrateLeagueMovieUsers($team_by_league_and_user_id, $league_movie_by_league_and_movie_id) {

		$this->info('Migrating league_movie_users...');
		$league_movie_users = (new Collection($this->fromOldDB()->table('league_movie_user')->get()))->keyBy('id');
		$count = 0;
		foreach ($league_movie_users as $league_movie_user) {
			if (++$count % 1000 == 0) $this->info($count);

			$league_id = $league_movie_user->league_id;
			$user_id = $league_movie_user->user_id;
			$movie_id = $league_movie_user->movie_id;
			if (! isset($team_by_league_and_user_id[$league_id][$user_id])
				|| ! isset($league_movie_by_league_and_movie_id[$league_id][$movie_id])
			) {
				$this->error("Movie bugged: - League: {$league_id} - Movie: {$movie_id}");
				continue;
			}
			DB::table('league_team_movies')->insert([
				'league_team_id'  => $team_by_league_and_user_id[$league_id][$user_id],
				'league_movie_id' => $league_movie_by_league_and_movie_id[$league_id][$movie_id],
				'created_at'      => $league_movie_user->created_at,
				'updated_at'      => $league_movie_user->updated_at,
			]);
		}
	}

}


1		<?php
2
3		use Illuminate\Console\Command;
4		use Illuminate\Support\Collection;
5		use Symfony\Component\Console\Input\InputArgument;
6
7		class MigrateOldDatabase extends Command {
		0 ignored issues – show Coding Style Compatibility introduced 2016-04-12 22:00 UTC by Report Bug Copy Issue Report PSR1 recommends that each class must be in a namespace of at least one level to avoid collisions. You can fix this by adding a namespace to your class: namespace YourVendor; class YourClass { } When choosing a vendor namespace, try to pick something that is not too generic to avoid conflicts with other libraries. Loading history...
8
9		/**
10		* The console command name.
11		*
12		* @var string
13		*/
14		protected $name = 'upgrade:old-database';
15
16		/**
17		* The console command description.
18		*
19		* @var string
20		*/
21		protected $description = 'Upgrade database from alpha.';
22
23		/**
24		* Execute the console command.
25		*
26		* @return mixed
27		*/
28		public function fire() {
29
30		if (App::environment() == 'production' \|\| ! $this->confirm('Are you sure?')) {
31		$this->error('Disabled for safety');
32
33		return;
34		}
35
36		$disableForeignKeyChecks = in_array(DB::connection()->getDriverName(), ['mysql']);
37
38		Eloquent::unguard();
39		if ($disableForeignKeyChecks) {
40		DB::statement('SET FOREIGN_KEY_CHECKS=0;');
41		}
42
43		DB::beginTransaction();
44
45		// Users
46		$users = $this->migrateUsers();
47		$this->migrateMovies();
48		$this->migrateMovieEarnings();
49		$this->migrateLeagues();
50		$league_movie_by_league_and_movie_id = $this->migrateLeagueMovies();
51		$team_by_league_and_user_id = $this->migrateLeagueUsers($users);
52		$this->migrateLeagueMovieUsers($team_by_league_and_user_id, $league_movie_by_league_and_movie_id);
53
54
55		DB::commit();
56		if ($disableForeignKeyChecks) {
57		DB::statement('SET FOREIGN_KEY_CHECKS=1;');
58		}
59		}
60
61		/**
62		* Get stuff from old database
63		*
64		* @return \Illuminate\Database\Connection
65		*/
66		public function fromOldDB() {
67		return DB::connection($this->argument('old-connection'));
68		}
69
70		/**
71		* Get the console command arguments.
72		*
73		* @return array
74		*/
75	9	protected function getArguments() {
76		return [
77	9	['old-connection', InputArgument::REQUIRED, 'The old connection to use'],
78	9	];
79		}
80
81		/**
82		* Get the console command options.
83		*
84		* @return array
85		*/
86	9	protected function getOptions() {
87		return [
88	9	];
89		}
90
91		/**
92		* @return Collection Users
93		*/
94		protected function migrateUsers() {
95		$this->info('Migrating users...');
96		$users = (new Collection($this->fromOldDB()->table('users')->get()))->keyBy('id');
97		$count = 0;
98		foreach ($users as $user) {
99		if (++$count % 1000 == 0) $this->info($count);
100		DB::table('users')->insert([
101		'id' => $user->id,
102		'username' => $user->username,
103		'displayname' => $user->displayname,
104		'email' => $user->email ?: null,
105		'admin' => $user->admin,
106		'created_at' => $user->created_at,
107		'updated_at' => $user->updated_at,
108		]);
109		}
110
111		return $users;
112		}
113
114		/**
115		*/
116		protected function migrateMovies() {
117		$this->info('Migrating movies...');
118		$movies = (new Collection($this->fromOldDB()->table('movies')->get()))->keyBy('id');
119		$count = 0;
120		foreach ($movies as $movie) {
121		if (++$count % 1000 == 0) $this->info($count);
122		DB::table('movies')->insert([
123		'id' => $movie->id,
124		'name' => $movie->name,
125		'boxmojo_id' => $movie->boxmojo_id,
126		'release' => $movie->release,
127		'latest_earnings_id' => $movie->latest_earnings_id,
128		'created_at' => $movie->created_at,
129		]);
130		}
131
132		}
133
134		/**
135		*/
136		protected function migrateMovieEarnings() {
137		$this->info('Migrating movie_earnings...');
138		$movie_earnings = (new Collection($this->fromOldDB()->table('movie_earnings')->get()))->keyBy('id');
139		$count = 0;
140		foreach ($movie_earnings as $movie_earning) {
141		if (++$count % 1000 == 0) $this->info($count);
142		DB::table('movie_earnings')->insert([
143		'id' => $movie_earning->id,
144		'movie_id' => $movie_earning->movie_id,
145		'date' => $movie_earning->date,
146		'domestic' => $movie_earning->domestic,
147		'created_at' => $movie_earning->created_at,
148		'updated_at' => $movie_earning->updated_at,
149		]);
150		}
151		}
152
153		/**
154		*/
155		protected function migrateLeagues() {
156		$this->info('Migrating leagues...');
157		$leagues = (new Collection($this->fromOldDB()->table('leagues')->get()))->keyBy('id');
158		$count = 0;
159		foreach ($leagues as $league) {
160		if (++$count % 1000 == 0) $this->info($count);
161		DB::table('leagues')->insert([
162		'id' => $league->id,
163		'name' => $league->name,
164		'slug' => $league->slug,
165		'description' => $league->description,
166		'url' => $league->url,
167		'mode' => $league->mode,
168		'money' => $league->money,
169		'units' => $league->units,
170		'extra_weeks' => $league->extra_weeks,
171		'start_date' => $league->start_date,
172		'end_date' => $league->end_date,
173		'active' => true,
174		'private' => $league->private,
175		'featured' => $league->featured,
176		'created_at' => $league->created_at,
177		'updated_at' => $league->updated_at,
178		]);
179		}
180		}
181
182		/**
183		* @return array
184		*/
185		protected function migrateLeagueMovies() {
186		$this->info('Migrating league_movies...');
187		$league_movies = (new Collection($this->fromOldDB()->table('league_movie')->get()))->keyBy('id');
188		$league_movie_by_league_and_movie_id = [];
189
190		$count = 0;
191		foreach ($league_movies as $league_movie) {
192		if (++$count % 1000 == 0) $this->info($count);
193		$league_movie_id = DB::table('league_movies')->insertGetId([
194		// ID's are skippable here, so getting fresh ones
195		'league_id' => $league_movie->league_id,
196		'movie_id' => $league_movie->movie_id,
197		'price' => $league_movie->price,
198		'latest_earnings_id' => $league_movie->latest_earnings_id,
199		'created_at' => $league_movie->created_at,
200		'updated_at' => $league_movie->updated_at,
201		]);
202
203		$league_movie_by_league_and_movie_id[$league_movie->league_id][$league_movie->movie_id] = $league_movie_id;
204		}
205
206		return $league_movie_by_league_and_movie_id;
207		}
208
209		/**
210		* @param $users
211		*
212		* @return array
213		*/
214		protected function migrateLeagueUsers(Collection $users) {
215		$this->info('Migrating league_users...');
216		$league_users = (new Collection($this->fromOldDB()->table('league_user')->get()))->keyBy('id');
217		$team_by_league_and_user_id = [];
218
219		$count = 0;
220		foreach ($league_users as $league_user) {
221		if (++$count % 500 == 0) $this->info($count);
222		// For league admins
223		if ($league_user->admin) {
224		DB::table('league_admins')->insert([
225		// Skip id's
226		'league_id' => $league_user->league_id,
227		'user_id' => $league_user->user_id,
228		'created_at' => $league_user->created_at,
229		'updated_at' => $league_user->updated_at,
230		]);
231		}
232		// For league players create a team named after them
233		if ($league_user->player) {
234		$team_id = DB::table('league_teams')->insertGetId([
235		// Get a new ID
236		'league_id' => $league_user->league_id,
237		'name' => $users->get($league_user->user_id)->displayname ?: $users->get($league_user->user_id)->username,
238		'created_at' => $league_user->created_at,
239		'updated_at' => $league_user->updated_at,
240		]);
241		$team_by_league_and_user_id[$league_user->league_id][$league_user->user_id] = $team_id;
242
243		DB::table('league_team_user')->insert([
244		// Skip id's
245		'league_team_id' => $team_id,
246		'user_id' => $league_user->user_id,
247		'created_at' => $league_user->created_at,
248		'updated_at' => $league_user->updated_at,
249		]);
250		}
251		}
252
253		return $team_by_league_and_user_id;
254		}
255
256		/**
257		* @param $team_by_league_and_user_id
258		* @param $league_movie_by_league_and_movie_id
259		*/
260		protected function migrateLeagueMovieUsers($team_by_league_and_user_id, $league_movie_by_league_and_movie_id) {
		0 ignored issues – show Coding Style Naming introduced 2016-04-12 22:00 UTC by Report Bug Copy Issue Report The parameter $team_by_league_and_user_id is not named in camelCase. This check marks parameter names that have not been written in camelCase. In camelCase names are written without any punctuation, the start of each new word being marked by a capital letter. Thus the name database connection string becomes `databaseConnectionString`. Loading history... Coding Style Naming introduced 2016-04-12 22:00 UTC by Report Bug Copy Issue Report The parameter $league_movie_by_league_and_movie_id is not named in camelCase. This check marks parameter names that have not been written in camelCase. In camelCase names are written without any punctuation, the start of each new word being marked by a capital letter. Thus the name database connection string becomes `databaseConnectionString`. Loading history...
261		$this->info('Migrating league_movie_users...');
262		$league_movie_users = (new Collection($this->fromOldDB()->table('league_movie_user')->get()))->keyBy('id');
263		$count = 0;
264		foreach ($league_movie_users as $league_movie_user) {
265		if (++$count % 1000 == 0) $this->info($count);
266
267		$league_id = $league_movie_user->league_id;
268		$user_id = $league_movie_user->user_id;
269		$movie_id = $league_movie_user->movie_id;
270		if (! isset($team_by_league_and_user_id[$league_id][$user_id])
271		\|\| ! isset($league_movie_by_league_and_movie_id[$league_id][$movie_id])
272		) {
273		$this->error("Movie bugged: - League: {$league_id} - Movie: {$movie_id}");
274		continue;
275		}
276		DB::table('league_team_movies')->insert([
277		'league_team_id' => $team_by_league_and_user_id[$league_id][$user_id],
278		'league_movie_id' => $league_movie_by_league_and_movie_id[$league_id][$movie_id],
279		'created_at' => $league_movie_user->created_at,
280		'updated_at' => $league_movie_user->updated_at,
281		]);
282		}
283		}
284
285		}
286

t2t2 / draft

MigrateOldDatabase::migrateLeagueUsers() B last analyzed 2016-09-26 09:48 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

MigrateOldDatabase::migrateLeagueUsers() B
last analyzed 2016-09-26 09:48 UTC