Subversion-Projekte lars-tiefland.laravel_shop

Revision

Revision 533 | Revision 535 | Zur aktuellen Revision | Details | Vergleich mit vorheriger | Letzte Änderung | Log anzeigen | RSS feed

Revision Autor Zeilennr. Zeile
233 lars 1 
<?php
2 
 
260 lars 3 
    namespace App\Console\Commands;
233 lars 4 
 
445 lars 5 
    use App\Models\Address;
260 lars 6 
    use App\Models\Directory;
7 
    use App\Models\Item;
8 
    use App\Models\Action;
272 lars 9 
    use App\Models\Medium;
454 lars 10 
    use App\Models\Order;
453 lars 11 
    use App\Models\OrderAddress;
507 lars 12 
    use App\Models\OrderType;
482 lars 13 
    use App\Models\PaymentMethod;
263 lars 14 
    use App\Models\Price;
260 lars 15 
    use App\Models\ActionMedium;
16 
    use App\Models\ItemMedium;
17 
    use App\Models\DirectoryMedium;
527 lars 18 
    use App\Models\SalesPortal;
529 lars 19 
    use App\Models\SalesPortalType;
509 lars 20 
    use App\Models\Shipping;
510 lars 21 
    use App\Models\ShippingGroup;
465 lars 22 
    use App\Models\Shop;
437 lars 23 
    use App\Models\User;
260 lars 24 
    use Illuminate\Console\Command;
25 
    use Illuminate\Support\Facades\DB;
233 lars 26 
 
260 lars 27 
    class convertDB extends Command
28 
    {
29 
        /**
30 
         * The name and signature of the console command.
31 
         *
32 
         * @var string
33 
         */
34 
        protected $signature = 'command:convertDB';
233 lars 35 
 
260 lars 36 
        /**
37 
         * The console command description.
38 
         *
39 
         * @var string
40 
         */
41 
        protected $description = 'Converts the old webanOS-DB to laravel';
233 lars 42 
 
260 lars 43 
        /**
44 
         * Execute the console command.
45 
         *
46 
         * @return void
47 
         */
48 
 
49 
        public function handle(): void
238 lars 50 
        {
294 lars 51 
            $this->info( date( "d.m.Y H:i:s" ) . ": Verarbeitung gestartet" );
465 lars 52 
            $migrateDirs = true;
488 lars 53 
            /*if ( !$this->confirm( "Kategorien migrieren?" ) )
422 lars 54 
            {
55 
                $migrateDirs = false;
488 lars 56 
            }*/
422 lars 57 
            $migrateItems = true;
488 lars 58 
            /*if ( !$this->confirm( "Artikel migrieren?" ) )
422 lars 59 
            {
60 
                $migrateItems = false;
488 lars 61 
            }*/
422 lars 62 
            $migrateActions = true;
488 lars 63 
            /*if ( !$this->confirm( "Aktionen migrieren?" ) )
422 lars 64 
            {
65 
                $migrateActions = false;
488 lars 66 
            }*/
422 lars 67 
            $migrateMedia = true;
488 lars 68 
            /*if ( !$this->confirm( "Medien migrieren?" ) )
422 lars 69 
            {
70 
                $migrateMedia = false;
488 lars 71 
            }*/
496 lars 72 
            $this->migrateShops();
505 lars 73 
            $this->migrateOrderTypes();
496 lars 74 
            $this->migratePaymentMethods();
508 lars 75 
            $this->migrateShippingGroups();
517 lars 76 
            $this->migrateShippings();
527 lars 77 
            $this->migrateSalesPortalTypes();
529 lars 78 
            //$this->migrateSalesPortals();
422 lars 79 
            if ( $migrateActions )
80 
            {
496 lars 81 
                $this->migrateActions();
422 lars 82 
            }
83 
            if ( $migrateDirs )
84 
            {
85 
                $this->migrateDirs();
86 
            }
87 
            if ( $migrateItems )
88 
            {
89 
                $this->migrateItems();
90 
            }
496 lars 91 
            if ( $migrateMedia )
422 lars 92 
            {
496 lars 93 
                $this->migrateMedia();
94 
                $this->migrateActionMedia();
95 
                $this->migrateDirMedia();
96 
                $this->migrateItemMedia();
465 lars 97 
            }
98 
            if ( env( 'site' ) == env( 'shop' ) )
99 
            {
100 
                $this->migrateUsers();
101 
                $this->migrateAddresses();
102 
                $this->migrateOrderAddresses();
103 
                $this->migrateOrders();
104 
                $this->migrateOrderItems();
105 
            }
294 lars 106 
            $this->info( date( "d.m.Y H:i:s" ) . ": Verarbeitung beendet" );
234 lars 107 
        }
260 lars 108 
 
527 lars 109 
        private function migrateShops()
433 lars 110 
        {
527 lars 111 
            $this->info( date( "d.m.Y H:i:s" ) . ": Migriere Shops" );
486 lars 112 
            $start = 0;
527 lars 113 
            $sql = "
114 
                SELECT
486 lars 115 
                    MAX(id) AS start
116 
                FROM
527 lars 117 
                    shops
486 lars 118 
            ";
527 lars 119 
            $row = DB::connection( 'mysql' )->select( $sql );
120 
            if ( $row[0]->start )
486 lars 121 
            {
527 lars 122 
                $start = $row[0]->start;
486 lars 123 
            }
527 lars 124 
            $sql = "SELECT
433 lars 125 
                    *
126 
                FROM
527 lars 127 
                    shops
486 lars 128 
                WHERE
129 
                    id>" . $start . "
433 lars 130 
            ";
527 lars 131 
            $shops = DB::connection( 'old' )->select( $sql );
132 
            foreach ( $shops as $oldShop )
433 lars 133 
            {
527 lars 134 
                $shop = new Shop();
135 
                $shop->id = $oldShop->ID;
136 
                $shop->name = $oldShop->Name;
137 
                $shop->short = $oldShop->short;
138 
                $shop->re_short = '';
139 
                if ( isset( $oldShop->re_short ) && $oldShop->re_short )
433 lars 140 
                {
527 lars 141 
                    $shop->re_short = $oldShop->re_short;
433 lars 142 
                }
527 lars 143 
                if ( isset( $oldShop->preisindex_ek ) && $oldShop->preisindex_ek )
433 lars 144 
                {
527 lars 145 
                    $shop->preisindex_ek = $oldShop->preisindex_ek;
433 lars 146 
                }
527 lars 147 
                $shop->ebay = $oldShop->ebay;
148 
                $shop->erfassung = $oldShop->erfassung;
149 
                if ( isset( $oldShop->status ) && $oldShop->status )
433 lars 150 
                {
527 lars 151 
                    $shop->status = $oldShop->status;
433 lars 152 
                }
527 lars 153 
                if ( isset( $oldShop->rang ) && $oldShop->rang )
154 
                {
155 
                    $shop->rank = $oldShop->rang;
156 
                }
157 
                $shop->klonziel = $oldShop->klonziel;
158 
                $shop->konroot = $oldShop->konroot;
159 
                if ( isset( $oldShop->home ) && $oldShop->home )
160 
                {
161 
                    $shop->home = $oldShop->home;
162 
                }
163 
                $shop->database = $oldShop->database;
164 
                $shop->domain = $oldShop->domain;
165 
                $shop->mail_server = $oldShop->mail_server;
166 
                $shop->mail_user = $oldShop->mail_user;
167 
                $shop->mail_password = $oldShop->mail_passwort;
168 
                $shop->save();
169 
            }
170 
 
171 
        }
172 
 
173 
        private function migrateOrderTypes()
174 
        {
175 
            $this->info( date( "d.m.Y H:i:s" ) . ": Migriere Bestellarten" );
176 
            $start = 0;
177 
            $sql = "SELECT
178 
                    MAX(id) AS start
179 
                FROM
180 
                    order_types
181 
            ";
182 
            $row = DB::connection( "mysql" )->select( $sql );
183 
            if ( $row[0]->start )
184 
            {
185 
                $start = $row[0]->start;
186 
            }
187 
            $sql = "SELECT
188 
                    *
189 
                FROM
190 
                    bestellart
191 
                WHERE
192 
                    id>" . $start . "
193 
            ";
194 
            $methods = DB::connection( 'old' )->select( $sql );
195 
            foreach ( $methods as $method )
196 
            {
197 
                OrderType::factory()->create( [
198 
                    "id"            => $method->id,
199 
                    "internal_name" => $method->rufname,
200 
                    "name"          => $method->name,
201 
                    "short"         => $method->short,
202 
                ] );
203 
            }
204 
        }
205 
 
206 
        private function migratePaymentMethods()
207 
        {
208 
            $this->info( date( "d.m.Y H:i:s" ) . ": Migriere Zahlungsmethoden" );
209 
            $start = 0;
210 
            $sql = "SELECT
211 
                    MAX(id) AS start
212 
                FROM
213 
                    payment_methods
214 
            ";
215 
            $row = DB::connection( "mysql" )->select( $sql );
216 
            if ( $row[0]->start )
217 
            {
218 
                $start = $row[0]->start;
219 
            }
220 
            $sql = "SELECT
221 
                    *
222 
                FROM
223 
                    zahlungsarten
224 
                WHERE
225 
                    id>" . $start . "
226 
            ";
227 
            $methods = DB::connection( 'old' )->select( $sql );
228 
            foreach ( $methods as $method )
229 
            {
230 
                PaymentMethod::factory()->create( [
231 
                    "id"            => $method->id,
232 
                    "name"          => $method->name,
233 
                    "discount"      => $method->abschlag,
234 
                    "internal_name" => $method->interner_name,
235 
                    "info_in_shop"  => $method->info_im_shop,
236 
                    "shipping_text" => $method->versandtextbaustein,
237 
                ] );
238 
            }
239 
        }
240 
 
241 
        private function migrateShippingGroups()
242 
        {
243 
            $this->info( date( "d.m.Y H:i:s" ) . ": Migriere Versandgruppen" );
244 
            $start = 0;
245 
            $sql = "SELECT
246 
                    MAX(id) AS start
247 
                FROM
248 
                    shipping_groups
249 
            ";
250 
            $row = DB::connection( "mysql" )->select( $sql );
251 
            if ( $row[0]->start )
252 
            {
253 
                $start = $row[0]->start;
254 
            }
255 
            $sql = "SELECT
256 
                    *
257 
                FROM
258 
                    versandgruppen
259 
                WHERE
260 
                    id>" . $start . "
261 
            ";
262 
            $methods = DB::connection( 'old' )->select( $sql );
263 
            foreach ( $methods as $group )
264 
            {
265 
                ShippingGroup::factory()->create( [
266 
                    "id"            => $group->id,
267 
                    "name"          => $group->name,
268 
                    "conditions"    => $group->bedingungen,
269 
                    "icon"          => $group->icon,
270 
                    "rank"          => $group->rang,
271 
                    "shipping_text" => $group->versandtextbaustein,
272 
                    "created_by"    => $group->erstellt_von,
273 
                    "updated_by"    => $group->geaendert_von,
274 
                    "updated_at"    => $group->geaendert_am,
275 
                    "created_at"    => $group->erstellt_am,
276 
                ] );
277 
            }
278 
        }
279 
 
280 
        private function migrateShippings()
281 
        {
282 
            $this->info( date( "d.m.Y H:i:s" ) . ": Migriere Versandoptionen" );
283 
            $start = 0;
284 
            $sql = "SELECT
285 
                    MAX(id) AS start
286 
                FROM
287 
                    shippings
288 
            ";
289 
            $row = DB::connection( "mysql" )->select( $sql );
290 
            if ( $row[0]->start )
291 
            {
292 
                $start = $row[0]->start;
293 
            }
294 
            $sql = "SELECT
295 
                    *
296 
                FROM
297 
                    versand
298 
                WHERE
299 
                    id>" . $start . "
300 
            ";
301 
            $methods = DB::connection( 'old' )->select( $sql );
302 
            foreach ( $methods as $group )
303 
            {
304 
                Shipping::factory()->create( [
305 
                    "id"                => $group->id,
306 
                    "rank"              => $group->rang,
307 
                    "shipping_group_id" => $group->versandgruppen_id,
308 
                    "name"              => $group->name,
309 
                    "info_shop"         => $group->info_shop,
310 
                    "info_mail"         => $group->info_mail,
311 
                    "info_internal"     => $group->info_intern,
312 
                    "island_shipping"   => $group->inselversand,
313 
                    "additions"         => $group->zusaetze,
314 
                    "status"            => $group->status,
315 
                    "price"             => $group->preis,
316 
                    "calc_weight_from"  => $group->berechnung_kg_von,
317 
                    "calc_weight_to"    => $group->berechnung_kg_bis,
318 
                    "calc_price_from"   => $group->berechnung_preis_von,
319 
                    "calc_price_to"     => $group->berechnung_preis_bis,
320 
                    "conditions"        => $group->bedingungen,
321 
                    "tax_rate"          => $group->steuersatz,
322 
                    "created_by"        => $group->erstellt_von,
323 
                    "updated_by"        => $group->geaendert_von,
324 
                    "updated_at"        => $group->geaendert_am,
325 
                    "created_at"        => $group->erstellt_am,
326 
                ] );
327 
            }
328 
        }
329 
 
330 
        private function migrateSalesPortalTypes()
331 
        {
533 lars 332 
            $this->info( date( "d.m.Y H:i:s" ) . ": Migriere Verkaufsportalarten" );
527 lars 333 
            $start = 0;
334 
            $sql = "SELECT
335 
                    MAX(id) start
336 
                FROM
337 
                    sales_portal_types
338 
            ";
339 
            $row = DB::connection( 'cms' )->select( $sql );
340 
            if ( $row[0]->start )
341 
            {
342 
                $start = $row[0]->start;
343 
            }
344 
            $sql = "SELECT
345 
                    *
346 
                FROM
347 
                    vportale_art
348 
                WHERE
349 
                    id>" . $start . "
350 
            ";
528 lars 351 
            $portals = DB::connection( 'cms' )->select( $sql );
527 lars 352 
            foreach ( $portals as $portal )
353 
            {
354 
                SalesPortalType::factory()->create( [
355 
                    "id"                   => $portal->id,
356 
                    "type"                 => $portal->art,
357 
                    "name"                 => $portal->bezeichnung,
358 
                    "max_categories"       => $portal->max_categories,
531 lars 359 
                    "min_depth_category"   => $portal->min_depth_category,
527 lars 360 
                    "only_end_category"    => $portal->only_end_category,
361 
                    "script"               => $portal->skript,
362 
                    "script_folder"        => $portal->script_folder,
363 
                    "commit_possibilities" => $portal->commit_posibilities,
364 
                    "revokeable"           => $portal->stornierbar,
365 
                ] );
366 
            }
367 
        }
368 
 
369 
        private function migrateSalesPortals()
370 
        {
534 lars 371 
            $this->info( date( "d.m.Y H:i:s" ) . ": Migriere Verkaufsportale" );
527 lars 372 
            $start = 0;
373 
            $sql = "SELECT
374 
                    MAX(id) start
375 
                FROM
376 
                    sales_portals
377 
            ";
378 
            $row = DB::connection( 'mysql' )->select( $sql );
379 
            if ( $row[0]->start )
380 
            {
381 
                $start = $row[0]->start;
382 
            }
383 
            $sql = "SELECT
384 
                    *
385 
                FROM
528 lars 386 
                    vportale
527 lars 387 
                WHERE
388 
                    id>" . $start . "
389 
            ";
390 
            $portals = DB::connection( 'old' )->select( $sql );
391 
            foreach ( $portals as $portal )
392 
            {
393 
                SalesPortal::factory()->create( [
394 
 
395 
                ] );
396 
            }
397 
        }
398 
 
399 
        private function migrateActions()
400 
        {
401 
            $this->info( date( "d.m.Y H:i:s" ) . ": Migriere Aktionen" );
402 
            $start = 0;
403 
            $sql = "SELECT
404 
                    MAX(id) AS start
405 
                FROM
406 
                    actions
407 
            ";
408 
            $row = DB::connection( "mysql" )->select( $sql );
409 
            if ( $row[0]->start )
410 
            {
411 
                $start = $row[0]->start;
412 
            }
413 
            $sql = "
414 
                SELECT
415 
                    *
416 
                FROM
417 
                    Aktionen
418 
                WHERE
419 
                    id>" . $start . "
420 
            ";
421 
            $actions = DB::connection( 'old' )->select( $sql );
422 
            $progressbar = $this->output->createProgressBar( count( $actions ) );
423 
            $progressbar->start();
424 
            foreach ( $actions as $action )
425 
            {
426 
                $actionDB = new Action();
427 
                $actionDB->id = $action->ID;
428 
                $actionDB->headline = $action->headline;
429 
                $actionDB->text = $action->text;
430 
                $actionDB->rang = $action->rang;
431 
                $actionDB->config = $action->config;
432 
                $actionDB->category = $action->Kategorie;
433 
                $actionDB->notes = $action->notizen;
434 
                $actionDB->valid_from = $action->von;
435 
                $actionDB->valid_to = $action->bis;
436 
                $actionDB->created_by = "WebanOS Laravel Upgrade";
437 
                $actionDB->updated_by = "WebanOS Laravel Upgrade";
438 
                $actionDB->save();
433 lars 439 
                $progressbar->advance();
440 
            }
441 
            $progressbar->finish();
442 
            $progressbar->clear();
443 
        }
444 
 
260 lars 445 
        private function migrateDirs()
446 
        {
294 lars 447 
            $this->info( date( "d.m.Y H:i:s" ) . ": Migriere Kategorien" );
486 lars 448 
            $start = 0;
449 
            $sql = "SELECT
450 
                    MAX(id) AS start
451 
                FROM
452 
                    directories
453 
            ";
454 
            $row = DB::connection( "mysql" )->select( $sql );
527 lars 455 
            if ( $row[0]->start )
486 lars 456 
            {
527 lars 457 
                $start = $row[0]->start;
486 lars 458 
            }
260 lars 459 
            $sql = '
460 
                SELECT
461 
                    *
462 
                FROM
463 
                    directory
486 lars 464 
                WHERE id>' . $start . '
260 lars 465 
            ';
466 
            $dirs = DB::connection( 'old' )->select( $sql );
301 lars 467 
            $progressbar = $this->output->createProgressBar( count( $dirs ) );
468 
            $progressbar->start();
260 lars 469 
            foreach ( $dirs as $row )
470 
            {
284 lars 471 
                $ersteller = $row->erstellt_von;
472 
                if ( !$ersteller )
473 
                {
474 
                    $ersteller = "WebanOS Laravel Upgrade";
475 
                }
285 lars 476 
                $bearbeiter = $row->letzte_Aenderung_von;
284 lars 477 
                if ( !$bearbeiter )
478 
                {
479 
                    $bearbeiter = "WebanOS Laravel Upgrade";
480 
                }
303 lars 481 
                $dir = new Directory();
482 
                $dir->id = $row->ID;
304 lars 483 
                $dir->directory_id = $row->Father;
303 lars 484 
                $dir->name = $row->Name;
432 lars 485 
                $dir->articlemaster = $row->Artikelstamm;
304 lars 486 
                $dir->status = $row->status;
303 lars 487 
                $dir->kennung = $row->Kennung;
304 lars 488 
                $dir->description = $row->Beschreibung;
489 
                $dir->short_line_1 = $row->short_line_1;
303 lars 490 
                $dir->url = $row->url;
491 
                $dir->created_at = $row->erstellt_am;
492 
                $dir->created_by = $ersteller;
493 
                $dir->updated_by = $bearbeiter;
494 
                $dir->updated_at = $row->letzte_Aenderung_am;
495 
                $dir->save();
301 lars 496 
                $progressbar->advance();
260 lars 497 
            }
301 lars 498 
            $progressbar->finish();
302 lars 499 
            $progressbar->clear();
260 lars 500 
        }
501 
 
502 
        private function migrateItems()
503 
        {
294 lars 504 
            $this->info( date( "d.m.Y H:i:s" ) . ": Migriere Artikel" );
486 lars 505 
            $start = 0;
506 
            $sql = "SELECT
507 
                    MAX(id) AS start
508 
                FROM
509 
                    items
510 
            ";
511 
            $row = DB::connection( "mysql" )->select( $sql );
527 lars 512 
            if ( $row[0]->start )
486 lars 513 
            {
527 lars 514 
                $start = $row[0]->start;
486 lars 515 
            }
260 lars 516 
            $sql = '
517 
                SELECT
518 
                    *
519 
                FROM
520 
                    artikel
521 
                WHERE
491 lars 522 
                    father >= -1
486 lars 523 
                AND
490 lars 524 
                    id>' . $start . '
260 lars 525 
            ';
526 
            $dirs = DB::connection( 'old' )->select( $sql );
301 lars 527 
            $progressbar = $this->output->createProgressBar( count( $dirs ) );
528 
            $progressbar->start();
260 lars 529 
            foreach ( $dirs as $row )
530 
            {
284 lars 531 
                $item = new Item();
532 
                $item->id = $row->ID;
533 
                $item->directory_id = $row->Father;
534 
                $item->name = $row->kurzbezeichnung;
535 
                $item->status = $row->status;
536 
                $item->kennung = $row->kennung;
537 
                $item->description = $row->beschreibung;
538 
                $item->created_at = $row->erstellt_am;
539 
                $item->updated_at = $row->letzte_Aenderung_am;
283 lars 540 
                $ersteller = $row->erstellt_von;
282 lars 541 
                if ( !$ersteller )
281 lars 542 
                {
282 lars 543 
                    $ersteller = "WebanOS Laravel Upgrade";
281 lars 544 
                }
287 lars 545 
                $bearbeiter = $row->letzte_Aenderung_von;
282 lars 546 
                if ( !$bearbeiter )
281 lars 547 
                {
282 lars 548 
                    $bearbeiter = "WebanOS Laravel Upgrade";
281 lars 549 
                }
284 lars 550 
                $item->created_by = $ersteller;
551 
                $item->updated_by = $bearbeiter;
552 
                $item->save();
301 lars 553 
                $progressbar->advance();
260 lars 554 
            }
301 lars 555 
            $progressbar->finish();
302 lars 556 
            $progressbar->clear();
294 lars 557 
            $this->info( date( "d.m.Y H:i:s" ) . ": Migriere Preise" );
494 lars 558 
            $start = 0;
492 lars 559 
            $sql = "SELECT
560 
                    MAX(id) AS start
561 
                FROM
562 
                    prices
563 
            ";
564 
            $row = DB::connection( "mysql" )->select( $sql );
527 lars 565 
            if ( $row[0]->start )
492 lars 566 
            {
527 lars 567 
                $start = $row[0]->start;
492 lars 568 
            }
260 lars 569 
            $sql = "
570 
                SELECT
571 
                    p.*
572 
                FROM
573 
                    preise p
574 
                JOIN
575 
                    artikel a
576 
                ON
577 
                    a.id=p.artikel_id
578 
                WHERE
579 
                    a.father >=-1
492 lars 580 
                AND
581 
                    p.id>" . $start . "
260 lars 582 
            ";
583 
            $prices = DB::connection( 'old' )->select( $sql );
301 lars 584 
            $progressbar = $this->output->createProgressBar( count( $prices ) );
585 
            $progressbar->start();
260 lars 586 
            foreach ( $prices as $price )
587 
            {
588 
                Price::factory()->createQuietly( [
493 lars 589 
                    "id"          => $price->id,
260 lars 590 
                    "item_id"     => $price->artikel_id,
591 
                    "preis_index" => $price->preis_index,
592 
                    "preis"       => $price->preis,
593 
                    "staffel"     => $price->staffel,
594 
                    "created_at"  => $price->geaendert_am,
288 lars 595 
                    "created_by"  => $price->geaendert_von,
596 
                    "updated_by"  => $price->geaendert_von,
260 lars 597 
                    "updated_at"  => $price->geaendert_am
598 
                ] );
301 lars 599 
                $progressbar->advance();
260 lars 600 
            }
301 lars 601 
            $progressbar->finish();
302 lars 602 
            $progressbar->clear();
260 lars 603 
        }
604 
 
527 lars 605 
        public function migrateMedia()
433 lars 606 
        {
527 lars 607 
            $this->info( date( "d.m.Y H:i:s" ) . ": Migriere Medien" );
486 lars 608 
            $start = 0;
433 lars 609 
            $sql = "SELECT
527 lars 610 
                    MAX(id) AS start
486 lars 611 
                FROM
527 lars 612 
                    media
486 lars 613 
            ";
614 
            $row = DB::connection( "mysql" )->select( $sql );
527 lars 615 
            if ( $row[0]->start )
486 lars 616 
            {
527 lars 617 
                $start = $row[0]->start;
486 lars 618 
            }
527 lars 619 
            $sql = "
620 
                SELECT
621 
                    *
622 
                FROM
623 
                    medien
624 
                WHERE
625 
                    id>" . $start . "
626 
            ";
627 
            $media = DB::connection( 'old' )->select( $sql );
628 
            $progressbar = $this->output->createProgressBar( count( $media ) );
629 
            $progressbar->start();
630 
            foreach ( $media as $medium )
631 
            {
632 
                $mediumDB = new Medium();
633 
                $mediumDB->id = $medium->id;
634 
                $mediumDB->name = $medium->name;
635 
                $mediumDB->folder = $medium->folder;
636 
                $mediumDB->medium_type_id = $medium->typ;
637 
                $mediumDB->description = $medium->beschreibung;
638 
                if ( $medium->erstellt_am )
639 
                {
640 
                    $mediumDB->created_at = date( "Y-m-d H:i:s", $medium->erstellt_am );
641 
                }
642 
                $ersteller = $medium->erstellt_von;
643 
                if ( !$ersteller )
644 
                {
645 
                    $ersteller = "WebanOS Laravel Upgrade";
646 
                }
647 
                $bearbeiter = $medium->letzte_aenderung_von;
648 
                if ( !$bearbeiter )
649 
                {
650 
                    $bearbeiter = "WebanOS Laravel Upgrade";
651 
                }
652 
                $mediumDB->created_by = $ersteller;
653 
                $mediumDB->updated_by = $bearbeiter;
654 
                $mediumDB->save();
655 
                $progressbar->advance();
656 
            }
657 
            $progressbar->finish();
658 
            $progressbar->clear();
659 
        }
660 
 
661 
        public function migrateActionMedia()
662 
        {
663 
            $this->info( date( "d.m.Y H:i:s" ) . ": Migriere Aktions-Bilder" );
664 
            $start = 0;
486 lars 665 
            $sql = "SELECT
527 lars 666 
                    MAX(id) AS start
667 
                FROM
668 
                    action_media
669 
            ";
670 
            $row = DB::connection( "mysql" )->select( $sql );
671 
            if ( $row[0]->start )
672 
            {
673 
                $start = $row[0]->start;
674 
            }
675 
            $sql = "SELECT
433 lars 676 
                    *
677 
                FROM
527 lars 678 
                    aktionen_medien
486 lars 679 
                WHERE
527 lars 680 
                    id>" . $start . "
433 lars 681 
            ";
682 
            $media = DB::connection( 'old' )->select( $sql );
683 
            $progressbar = $this->output->createProgressBar( count( $media ) );
684 
            $progressbar->start();
685 
            foreach ( $media as $row )
686 
            {
527 lars 687 
                $medium = new ActionMedium();
688 
                $medium->action_id = $row->aktionen_id;
433 lars 689 
                $medium->medium_id = $row->medien_id;
690 
                $medium->rank = $row->rang;
691 
                $medium->created_by = "WebanOS Laravel Upgrade";
692 
                $medium->updated_by = "WebanOS Laravel Upgrade";
693 
                $medium->save();
694 
                $progressbar->advance();
695 
            }
696 
            $progressbar->finish();
697 
            $progressbar->clear();
698 
        }
699 
 
527 lars 700 
        public function migrateDirMedia()
260 lars 701 
        {
527 lars 702 
            $this->info( date( "d.m.Y H:i:s" ) . ": Migriere Kategorie-Bilder" );
486 lars 703 
            $start = 0;
704 
            $sql = "SELECT
527 lars 705 
                    MAX(medium_id) AS start
486 lars 706 
                FROM
527 lars 707 
                    directory_media
486 lars 708 
            ";
709 
            $row = DB::connection( "mysql" )->select( $sql );
527 lars 710 
            if ( $row[0]->start )
486 lars 711 
            {
527 lars 712 
                $start = $row[0]->start;
486 lars 713 
            }
527 lars 714 
            $sql = "SELECT
260 lars 715 
                    *
716 
                FROM
527 lars 717 
                    directory_medien
486 lars 718 
                WHERE
527 lars 719 
                    medien_id>" . $start . "
260 lars 720 
            ";
527 lars 721 
            $media = DB::connection( 'old' )->select( $sql );
722 
            $progressbar = $this->output->createProgressBar( count( $media ) );
301 lars 723 
            $progressbar->start();
527 lars 724 
            foreach ( $media as $row )
260 lars 725 
            {
527 lars 726 
                $medium = new DirectoryMedium();
727 
                $medium->directory_id = $row->directory_id;
728 
                $medium->medium_id = $row->medien_id;
729 
                $medium->rank = $row->rang;
730 
                $medium->similar = $row->aehnlich;
731 
                $medium->created_at = $row->zugeordnet_am;
732 
                $medium->updated_at = $row->zugeordnet_am;
733 
                $medium->created_by = "WebanOS Laravel Upgrade";
734 
                $medium->updated_by = "WebanOS Laravel Upgrade";
735 
                $medium->save();
301 lars 736 
                $progressbar->advance();
260 lars 737 
            }
301 lars 738 
            $progressbar->finish();
302 lars 739 
            $progressbar->clear();
260 lars 740 
        }
272 lars 741 
 
527 lars 742 
        public function migrateItemMedia()
272 lars 743 
        {
527 lars 744 
            $this->info( date( "d.m.Y H:i:s" ) . ": Migriere Artikel-Bilder" );
486 lars 745 
            $start = 0;
433 lars 746 
            $sql = "SELECT
527 lars 747 
                    MAX(medium_id) AS start
486 lars 748 
                FROM
527 lars 749 
                    item_media
486 lars 750 
            ";
751 
            $row = DB::connection( "mysql" )->select( $sql );
527 lars 752 
            if ( $row[0]->start )
486 lars 753 
            {
527 lars 754 
                $start = $row[0]->start;
486 lars 755 
            }
756 
            $sql = "SELECT
272 lars 757 
                    *
758 
                FROM
527 lars 759 
                    artikel_medien
486 lars 760 
                WHERE
527 lars 761 
                    medien_id>" . $start . "
272 lars 762 
            ";
763 
            $media = DB::connection( 'old' )->select( $sql );
301 lars 764 
            $progressbar = $this->output->createProgressBar( count( $media ) );
765 
            $progressbar->start();
433 lars 766 
            foreach ( $media as $row )
272 lars 767 
            {
527 lars 768 
                $medium = new ItemMedium();
769 
                $medium->item_id = $row->artikel_id;
433 lars 770 
                $medium->medium_id = $row->medien_id;
771 
                $medium->rank = $row->rang;
527 lars 772 
                $medium->similar = $row->aehnlich;
773 
                $medium->created_at = $row->zugeordnet_am;
774 
                $medium->updated_at = $row->zugeordnet_am;
433 lars 775 
                $medium->created_by = "WebanOS Laravel Upgrade";
776 
                $medium->updated_by = "WebanOS Laravel Upgrade";
777 
                $medium->save();
301 lars 778 
                $progressbar->advance();
272 lars 779 
            }
301 lars 780 
            $progressbar->finish();
302 lars 781 
            $progressbar->clear();
272 lars 782 
        }
304 lars 783 
 
784 
        private function migrateUsers()
785 
        {
786 
            $this->info( date( "d.m.Y H:i:s" ) . ": Migriere User" );
433 lars 787 
            $start = 0;
788 
            $sql = "SELECT
789 
                    MAX(id) AS start
790 
                FROM
434 lars 791 
                    users
433 lars 792 
            ";
793 
            $row = DB::connection( "order" )->select( $sql );
527 lars 794 
            if ( $row[0]->start )
433 lars 795 
            {
527 lars 796 
                $start = $row[0]->start;
433 lars 797 
            }
798 
            $sql = "SELECT
799 
                    *
800 
                FROM
434 lars 801 
                    Logins
433 lars 802 
                WHERE
803 
                    id>" . $start . "
804 
            ";
437 lars 805 
            $users = DB::connection( "oldOrder" )->select( $sql );
806 
            $progressbar = $this->output->createProgressBar( count( $users ) );
448 lars 807 
            $progressbar->start();
437 lars 808 
            foreach ( $users as $oldUser )
433 lars 809 
            {
443 lars 810 
                $ersteller = $oldUser->erstellt_von;
442 lars 811 
                if ( !$ersteller )
812 
                {
813 
                    $ersteller = "WebanOS Laravel Upgrade";
814 
                }
443 lars 815 
                $bearbeiter = $oldUser->letzte_Aenderung_von;
442 lars 816 
                if ( !$bearbeiter )
817 
                {
818 
                    $bearbeiter = "WebanOS Laravel Upgrade";
819 
                }
437 lars 820 
                $user = new User();
438 lars 821 
                $user->id = $oldUser->ID;
437 lars 822 
                $user->email = $oldUser->E_Mail;
823 
                $user->created_at = $oldUser->erstellt_am;
442 lars 824 
                $user->created_by = $ersteller;
825 
                $user->updated_by = $bearbeiter;
437 lars 826 
                $user->updated_at = $oldUser->letzte_Aenderung_am;
827 
                $user->save();
441 lars 828 
                $progressbar->advance();
433 lars 829 
            }
441 lars 830 
            $progressbar->finish();
831 
            $progressbar->clear();
304 lars 832 
        }
833 
 
445 lars 834 
        private function migrateAddresses( bool $isOrder = false )
304 lars 835 
        {
445 lars 836 
            $typ = "Adressen";
837 
            $table = "addresses";
838 
            $oldTable = "adresse";
839 
            if ( $isOrder === true )
840 
            {
841 
                $typ = "Bestelladressen";
842 
                $table = "order_addresses";
843 
                $oldTable = "bestelladresse";
844 
            }
845 
            $this->info( date( "d.m.Y H:i:s" ) . ": Migriere " . $typ );
846 
            $start = 0;
847 
            $sql = "SELECT
848 
                    MAX(id) AS start
849 
                FROM
850 
                    " . $table . "
851 
            ";
852 
            $row = DB::connection( "order" )->select( $sql );
527 lars 853 
            if ( $row[0]->start )
445 lars 854 
            {
527 lars 855 
                $start = $row[0]->start;
445 lars 856 
            }
857 
            $sql = "SELECT
858 
                    *
859 
                FROM
860 
                    " . $oldTable . "
861 
                WHERE
862 
                    id>" . $start . "
863 
            ";
864 
            $addresses = DB::connection( "oldOrder" )->select( $sql );
865 
            $progressbar = $this->output->createProgressBar( count( $addresses ) );
447 lars 866 
            $progressbar->start();
445 lars 867 
            foreach ( $addresses as $oldAddress )
868 
            {
869 
                $ersteller = "WebanOS Laravel Upgrade";
870 
                $bearbeiter = "WebanOS Laravel Upgrade";
458 lars 871 
                if ( $isOrder === true )
452 lars 872 
                {
873 
                    $address = new OrderAddress();
874 
                }
875 
                else
876 
                {
877 
                    $address = new Address();
878 
                }
445 lars 879 
                $address->id = $oldAddress->id;
880 
                $address->user_id = $oldAddress->logins_id;
881 
                $address->salutation = $oldAddress->anrede;
882 
                $address->pro_title = $oldAddress->pro_title;
883 
                $address->name = $oldAddress->vorname;
884 
                $address->lastname = $oldAddress->nachname;
885 
                $address->company = $oldAddress->firma;
886 
                $address->company2 = $oldAddress->firma2;
887 
                $address->street = $oldAddress->strasse1;
888 
                $address->houseno = $oldAddress->str_nr1;
889 
                $address->street2 = $oldAddress->strasse2;
890 
                $address->zip = $oldAddress->plz;
891 
                $address->city = $oldAddress->ort;
892 
                $address->country_id = $oldAddress->land;
893 
                $address->state_id = $oldAddress->state;
894 
                $address->phone = $oldAddress->telefon;
895 
                $address->fax = $oldAddress->fax;
896 
                $address->email = $oldAddress->email;
897 
                $address->nettocalculation = $oldAddress->nettoberechnung;
450 lars 898 
                $address->hr_nr = $oldAddress->hr_nr;
445 lars 899 
                $address->vat_id = $oldAddress->vat_id;
900 
                $address->vat_free = $oldAddress->mwst_befreiung;
901 
                $address->legal_form = $oldAddress->legal_form;
902 
                $address->comment = $oldAddress->comment;
451 lars 903 
                $address->created_at = $oldAddress->letzte_aenderung_am;
445 lars 904 
                $address->created_by = $ersteller;
905 
                $address->updated_by = $bearbeiter;
906 
                $address->updated_at = $oldAddress->letzte_aenderung_am;
907 
                $address->save();
908 
                $progressbar->advance();
909 
            }
910 
            $progressbar->finish();
911 
            $progressbar->clear();
304 lars 912 
        }
913 
 
914 
        private function migrateOrderAddresses()
915 
        {
445 lars 916 
            $this->migrateAddresses( true );
304 lars 917 
        }
918 
 
919 
        private function migrateOrders()
920 
        {
921 
            $this->info( date( "d.m.Y H:i:s" ) . ": Migriere Bestellungen" );
454 lars 922 
            $start = 0;
923 
            $sql = "SELECT
924 
                    MAX(id) AS start
925 
                FROM
926 
                    orders
927 
            ";
928 
            $row = DB::connection( "order" )->select( $sql );
527 lars 929 
            if ( $row[0]->start )
454 lars 930 
            {
527 lars 931 
                $start = $row[0]->start;
454 lars 932 
            }
933 
            $sql = "SELECT
934 
                    *
935 
                FROM
936 
                    Bestellung
937 
                WHERE
938 
                    id>" . $start . "
939 
            ";
940 
            $orders = DB::connection( "oldOrder" )->select( $sql );
941 
            $progressbar = $this->output->createProgressBar( count( $orders ) );
942 
            $progressbar->start();
943 
            foreach ( $orders as $oldOrder )
944 
            {
501 lars 945 
                $paidAt = $oldOrder->bezahlt_am;
946 
                if ( $paidAt == "0000-00-00 00:00:00" )
947 
                {
502 lars 948 
                    $paidAt = null;
501 lars 949 
                }
454 lars 950 
                $order = new Order();
951 
                $order->id = $oldOrder->ID;
481 lars 952 
                $order->shop_id = $oldOrder->shops_ID;
459 lars 953 
                $order->order_type_id = $oldOrder->bestellart_id;
458 lars 954 
                $order->payment_method_id = $oldOrder->zahlart_id;
955 
                $order->user_id = $oldOrder->Login;
956 
                $order->ship_addr_id = $oldOrder->ship_addr_id;
957 
                $order->bill_addr_id = $oldOrder->bill_addr_id;
958 
                $order->paid = $oldOrder->bezahlt;
501 lars 959 
                $order->paid_at = $paidAt;
458 lars 960 
                $order->paid_comment = $oldOrder->bezahlt_bemerkung;
961 
                $order->foreign_id = $oldOrder->fremd_id;
962 
                $order->foreign_payment_id = $oldOrder->bezahlt_fremdid;
963 
                $order->status = $oldOrder->status;
964 
                $order->total_amount_buffer = $oldOrder->gesamtsumme_buffer;
965 
                $order->item_status_buffer = $oldOrder->artikelstatus_buffer;
966 
                $order->invoice_status_buffer = $oldOrder->rechnungsstatus_buffer;
504 lars 967 
                $order->delivery_note_status_buffer = $oldOrder->lieferscheinStatus_buffer;
458 lars 968 
                $order->tax = $oldOrder->tax;
969 
                $order->comment = $oldOrder->Bemerkung;
970 
                $order->external_comment = $oldOrder->Bemerkung_extern;
971 
                $order->note = $oldOrder->notiz;
460 lars 972 
                $order->additional_info = $oldOrder->zusatzInfo;
458 lars 973 
                $order->shipping_group_id = $oldOrder->versandgruppen_id;
974 
                $order->kk_info = $oldOrder->kk_info;
975 
                $order->created_by = $oldOrder->erstellt_von;
976 
                $order->updated_by = $oldOrder->letzte_Aenderung_von;
977 
                $order->updated_at = $oldOrder->letzte_Aenderung_am;
978 
                $order->created_at = $oldOrder->erstellt_am;
454 lars 979 
                $order->save();
980 
                $progressbar->advance();
981 
            }
982 
            $progressbar->finish();
983 
            $progressbar->clear();
304 lars 984 
        }
985 
 
986 
        private function migrateOrderItems()
987 
        {
988 
            $this->info( date( "d.m.Y H:i:s" ) . ": Migriere Artikel in Besetllungen" );
454 lars 989 
            $start = 0;
990 
            $sql = "SELECT
991 
                    MAX(id) AS start
992 
                FROM
993 
                    order_items
994 
            ";
995 
            $row = DB::connection( "order" )->select( $sql );
527 lars 996 
            if ( $row[0]->start )
454 lars 997 
            {
527 lars 998 
                $start = $row[0]->start;
454 lars 999 
            }
1000 
            $sql = "SELECT
1001 
                    *
1002 
                FROM
1003 
                    artikel_to_Bestellung
1004 
                WHERE
1005 
                    id>" . $start . "
1006 
            ";
1007 
            $orderItems = DB::connection( "oldOrder" )->select( $sql );
1008 
            $progressbar = $this->output->createProgressBar( count( $orderItems ) );
1009 
            $progressbar->start();
1010 
            foreach ( $orderItems as $oldOrderItem )
1011 
            {
1012 
                $progressbar->advance();
1013 
            }
1014 
            $progressbar->finish();
1015 
            $progressbar->clear();
304 lars 1016 
        }
233 lars 1017 
    }