Subversion-Projekte lars-tiefland.laravel_shop

Revision

Revision 552 | Revision 561 | 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;
551 lars 15 
    use App\Models\PriceAgency;
260 lars 16 
    use App\Models\ActionMedium;
17 
    use App\Models\ItemMedium;
18 
    use App\Models\DirectoryMedium;
527 lars 19 
    use App\Models\SalesPortal;
540 lars 20 
    use App\Models\SalesPortalItem;
529 lars 21 
    use App\Models\SalesPortalType;
509 lars 22 
    use App\Models\Shipping;
510 lars 23 
    use App\Models\ShippingGroup;
465 lars 24 
    use App\Models\Shop;
437 lars 25 
    use App\Models\User;
260 lars 26 
    use Illuminate\Console\Command;
27 
    use Illuminate\Support\Facades\DB;
233 lars 28 
 
260 lars 29 
    class convertDB extends Command
30 
    {
31 
        /**
32 
         * The name and signature of the console command.
33 
         *
34 
         * @var string
35 
         */
36 
        protected $signature = 'command:convertDB';
233 lars 37 
 
260 lars 38 
        /**
39 
         * The console command description.
40 
         *
41 
         * @var string
42 
         */
43 
        protected $description = 'Converts the old webanOS-DB to laravel';
233 lars 44 
 
260 lars 45 
        /**
46 
         * Execute the console command.
47 
         *
48 
         * @return void
49 
         */
50 
 
51 
        public function handle(): void
238 lars 52 
        {
294 lars 53 
            $this->info( date( "d.m.Y H:i:s" ) . ": Verarbeitung gestartet" );
465 lars 54 
            $migrateDirs = true;
488 lars 55 
            /*if ( !$this->confirm( "Kategorien migrieren?" ) )
422 lars 56 
            {
57 
                $migrateDirs = false;
488 lars 58 
            }*/
422 lars 59 
            $migrateItems = true;
488 lars 60 
            /*if ( !$this->confirm( "Artikel migrieren?" ) )
422 lars 61 
            {
62 
                $migrateItems = false;
488 lars 63 
            }*/
422 lars 64 
            $migrateActions = true;
488 lars 65 
            /*if ( !$this->confirm( "Aktionen migrieren?" ) )
422 lars 66 
            {
67 
                $migrateActions = false;
488 lars 68 
            }*/
422 lars 69 
            $migrateMedia = true;
488 lars 70 
            /*if ( !$this->confirm( "Medien migrieren?" ) )
422 lars 71 
            {
72 
                $migrateMedia = false;
488 lars 73 
            }*/
496 lars 74 
            $this->migrateShops();
505 lars 75 
            $this->migrateOrderTypes();
496 lars 76 
            $this->migratePaymentMethods();
508 lars 77 
            $this->migrateShippingGroups();
517 lars 78 
            $this->migrateShippings();
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 
            {
538 lars 100 
                $this->migratePriceAgencies();
465 lars 101 
                $this->migrateUsers();
102 
                $this->migrateAddresses();
103 
                $this->migrateOrderAddresses();
104 
                $this->migrateOrders();
105 
                $this->migrateOrderItems();
535 lars 106 
                $this->migrateSalesPortalTypes();
465 lars 107 
            }
536 lars 108 
            $this->migrateSalesPortals();
538 lars 109 
            $this->migrateSalesPortalItems();
294 lars 110 
            $this->info( date( "d.m.Y H:i:s" ) . ": Verarbeitung beendet" );
234 lars 111 
        }
260 lars 112 
 
527 lars 113 
        private function migrateShops()
433 lars 114 
        {
527 lars 115 
            $this->info( date( "d.m.Y H:i:s" ) . ": Migriere Shops" );
486 lars 116 
            $start = 0;
527 lars 117 
            $sql = "
118 
                SELECT
486 lars 119 
                    MAX(id) AS start
120 
                FROM
527 lars 121 
                    shops
486 lars 122 
            ";
527 lars 123 
            $row = DB::connection( 'mysql' )->select( $sql );
124 
            if ( $row[0]->start )
486 lars 125 
            {
527 lars 126 
                $start = $row[0]->start;
486 lars 127 
            }
527 lars 128 
            $sql = "SELECT
433 lars 129 
                    *
130 
                FROM
527 lars 131 
                    shops
486 lars 132 
                WHERE
133 
                    id>" . $start . "
433 lars 134 
            ";
527 lars 135 
            $shops = DB::connection( 'old' )->select( $sql );
136 
            foreach ( $shops as $oldShop )
433 lars 137 
            {
527 lars 138 
                $shop = new Shop();
139 
                $shop->id = $oldShop->ID;
140 
                $shop->name = $oldShop->Name;
141 
                $shop->short = $oldShop->short;
142 
                $shop->re_short = '';
143 
                if ( isset( $oldShop->re_short ) && $oldShop->re_short )
433 lars 144 
                {
527 lars 145 
                    $shop->re_short = $oldShop->re_short;
433 lars 146 
                }
527 lars 147 
                if ( isset( $oldShop->preisindex_ek ) && $oldShop->preisindex_ek )
433 lars 148 
                {
527 lars 149 
                    $shop->preisindex_ek = $oldShop->preisindex_ek;
433 lars 150 
                }
527 lars 151 
                $shop->ebay = $oldShop->ebay;
152 
                $shop->erfassung = $oldShop->erfassung;
153 
                if ( isset( $oldShop->status ) && $oldShop->status )
433 lars 154 
                {
527 lars 155 
                    $shop->status = $oldShop->status;
433 lars 156 
                }
527 lars 157 
                if ( isset( $oldShop->rang ) && $oldShop->rang )
158 
                {
159 
                    $shop->rank = $oldShop->rang;
160 
                }
161 
                $shop->klonziel = $oldShop->klonziel;
162 
                $shop->konroot = $oldShop->konroot;
163 
                if ( isset( $oldShop->home ) && $oldShop->home )
164 
                {
165 
                    $shop->home = $oldShop->home;
166 
                }
167 
                $shop->database = $oldShop->database;
168 
                $shop->domain = $oldShop->domain;
169 
                $shop->mail_server = $oldShop->mail_server;
170 
                $shop->mail_user = $oldShop->mail_user;
171 
                $shop->mail_password = $oldShop->mail_passwort;
172 
                $shop->save();
173 
            }
174 
 
175 
        }
176 
 
177 
        private function migrateOrderTypes()
178 
        {
179 
            $this->info( date( "d.m.Y H:i:s" ) . ": Migriere Bestellarten" );
180 
            $start = 0;
181 
            $sql = "SELECT
182 
                    MAX(id) AS start
183 
                FROM
184 
                    order_types
185 
            ";
186 
            $row = DB::connection( "mysql" )->select( $sql );
187 
            if ( $row[0]->start )
188 
            {
189 
                $start = $row[0]->start;
190 
            }
191 
            $sql = "SELECT
192 
                    *
193 
                FROM
194 
                    bestellart
195 
                WHERE
196 
                    id>" . $start . "
197 
            ";
198 
            $methods = DB::connection( 'old' )->select( $sql );
199 
            foreach ( $methods as $method )
200 
            {
201 
                OrderType::factory()->create( [
202 
                    "id"            => $method->id,
203 
                    "internal_name" => $method->rufname,
204 
                    "name"          => $method->name,
205 
                    "short"         => $method->short,
206 
                ] );
207 
            }
208 
        }
209 
 
210 
        private function migratePaymentMethods()
211 
        {
212 
            $this->info( date( "d.m.Y H:i:s" ) . ": Migriere Zahlungsmethoden" );
213 
            $start = 0;
214 
            $sql = "SELECT
215 
                    MAX(id) AS start
216 
                FROM
217 
                    payment_methods
218 
            ";
219 
            $row = DB::connection( "mysql" )->select( $sql );
220 
            if ( $row[0]->start )
221 
            {
222 
                $start = $row[0]->start;
223 
            }
224 
            $sql = "SELECT
225 
                    *
226 
                FROM
227 
                    zahlungsarten
228 
                WHERE
229 
                    id>" . $start . "
230 
            ";
231 
            $methods = DB::connection( 'old' )->select( $sql );
232 
            foreach ( $methods as $method )
233 
            {
234 
                PaymentMethod::factory()->create( [
235 
                    "id"            => $method->id,
236 
                    "name"          => $method->name,
237 
                    "discount"      => $method->abschlag,
238 
                    "internal_name" => $method->interner_name,
239 
                    "info_in_shop"  => $method->info_im_shop,
240 
                    "shipping_text" => $method->versandtextbaustein,
241 
                ] );
242 
            }
243 
        }
244 
 
245 
        private function migrateShippingGroups()
246 
        {
247 
            $this->info( date( "d.m.Y H:i:s" ) . ": Migriere Versandgruppen" );
248 
            $start = 0;
249 
            $sql = "SELECT
250 
                    MAX(id) AS start
251 
                FROM
252 
                    shipping_groups
253 
            ";
254 
            $row = DB::connection( "mysql" )->select( $sql );
255 
            if ( $row[0]->start )
256 
            {
257 
                $start = $row[0]->start;
258 
            }
259 
            $sql = "SELECT
260 
                    *
261 
                FROM
262 
                    versandgruppen
263 
                WHERE
264 
                    id>" . $start . "
265 
            ";
266 
            $methods = DB::connection( 'old' )->select( $sql );
267 
            foreach ( $methods as $group )
268 
            {
269 
                ShippingGroup::factory()->create( [
270 
                    "id"            => $group->id,
271 
                    "name"          => $group->name,
272 
                    "conditions"    => $group->bedingungen,
273 
                    "icon"          => $group->icon,
274 
                    "rank"          => $group->rang,
275 
                    "shipping_text" => $group->versandtextbaustein,
276 
                    "created_by"    => $group->erstellt_von,
277 
                    "updated_by"    => $group->geaendert_von,
278 
                    "updated_at"    => $group->geaendert_am,
279 
                    "created_at"    => $group->erstellt_am,
280 
                ] );
281 
            }
282 
        }
283 
 
284 
        private function migrateShippings()
285 
        {
286 
            $this->info( date( "d.m.Y H:i:s" ) . ": Migriere Versandoptionen" );
287 
            $start = 0;
288 
            $sql = "SELECT
289 
                    MAX(id) AS start
290 
                FROM
291 
                    shippings
292 
            ";
293 
            $row = DB::connection( "mysql" )->select( $sql );
294 
            if ( $row[0]->start )
295 
            {
296 
                $start = $row[0]->start;
297 
            }
298 
            $sql = "SELECT
299 
                    *
300 
                FROM
301 
                    versand
302 
                WHERE
303 
                    id>" . $start . "
304 
            ";
305 
            $methods = DB::connection( 'old' )->select( $sql );
306 
            foreach ( $methods as $group )
307 
            {
308 
                Shipping::factory()->create( [
309 
                    "id"                => $group->id,
310 
                    "rank"              => $group->rang,
311 
                    "shipping_group_id" => $group->versandgruppen_id,
312 
                    "name"              => $group->name,
313 
                    "info_shop"         => $group->info_shop,
314 
                    "info_mail"         => $group->info_mail,
315 
                    "info_internal"     => $group->info_intern,
316 
                    "island_shipping"   => $group->inselversand,
317 
                    "additions"         => $group->zusaetze,
318 
                    "status"            => $group->status,
319 
                    "price"             => $group->preis,
320 
                    "calc_weight_from"  => $group->berechnung_kg_von,
321 
                    "calc_weight_to"    => $group->berechnung_kg_bis,
322 
                    "calc_price_from"   => $group->berechnung_preis_von,
323 
                    "calc_price_to"     => $group->berechnung_preis_bis,
324 
                    "conditions"        => $group->bedingungen,
325 
                    "tax_rate"          => $group->steuersatz,
326 
                    "created_by"        => $group->erstellt_von,
327 
                    "updated_by"        => $group->geaendert_von,
328 
                    "updated_at"        => $group->geaendert_am,
329 
                    "created_at"        => $group->erstellt_am,
330 
                ] );
331 
            }
332 
        }
333 
 
334 
        private function migrateActions()
335 
        {
336 
            $this->info( date( "d.m.Y H:i:s" ) . ": Migriere Aktionen" );
337 
            $start = 0;
338 
            $sql = "SELECT
339 
                    MAX(id) AS start
340 
                FROM
341 
                    actions
342 
            ";
343 
            $row = DB::connection( "mysql" )->select( $sql );
344 
            if ( $row[0]->start )
345 
            {
346 
                $start = $row[0]->start;
347 
            }
348 
            $sql = "
349 
                SELECT
350 
                    *
351 
                FROM
352 
                    Aktionen
353 
                WHERE
354 
                    id>" . $start . "
355 
            ";
356 
            $actions = DB::connection( 'old' )->select( $sql );
357 
            $progressbar = $this->output->createProgressBar( count( $actions ) );
358 
            $progressbar->start();
359 
            foreach ( $actions as $action )
360 
            {
361 
                $actionDB = new Action();
362 
                $actionDB->id = $action->ID;
363 
                $actionDB->headline = $action->headline;
364 
                $actionDB->text = $action->text;
365 
                $actionDB->rang = $action->rang;
366 
                $actionDB->config = $action->config;
367 
                $actionDB->category = $action->Kategorie;
368 
                $actionDB->notes = $action->notizen;
369 
                $actionDB->valid_from = $action->von;
370 
                $actionDB->valid_to = $action->bis;
371 
                $actionDB->created_by = "WebanOS Laravel Upgrade";
372 
                $actionDB->updated_by = "WebanOS Laravel Upgrade";
373 
                $actionDB->save();
433 lars 374 
                $progressbar->advance();
375 
            }
376 
            $progressbar->finish();
377 
            $progressbar->clear();
378 
        }
379 
 
260 lars 380 
        private function migrateDirs()
381 
        {
294 lars 382 
            $this->info( date( "d.m.Y H:i:s" ) . ": Migriere Kategorien" );
486 lars 383 
            $start = 0;
384 
            $sql = "SELECT
385 
                    MAX(id) AS start
386 
                FROM
387 
                    directories
388 
            ";
389 
            $row = DB::connection( "mysql" )->select( $sql );
527 lars 390 
            if ( $row[0]->start )
486 lars 391 
            {
527 lars 392 
                $start = $row[0]->start;
486 lars 393 
            }
260 lars 394 
            $sql = '
395 
                SELECT
396 
                    *
397 
                FROM
398 
                    directory
486 lars 399 
                WHERE id>' . $start . '
260 lars 400 
            ';
401 
            $dirs = DB::connection( 'old' )->select( $sql );
301 lars 402 
            $progressbar = $this->output->createProgressBar( count( $dirs ) );
403 
            $progressbar->start();
260 lars 404 
            foreach ( $dirs as $row )
405 
            {
284 lars 406 
                $ersteller = $row->erstellt_von;
407 
                if ( !$ersteller )
408 
                {
409 
                    $ersteller = "WebanOS Laravel Upgrade";
410 
                }
285 lars 411 
                $bearbeiter = $row->letzte_Aenderung_von;
284 lars 412 
                if ( !$bearbeiter )
413 
                {
414 
                    $bearbeiter = "WebanOS Laravel Upgrade";
415 
                }
303 lars 416 
                $dir = new Directory();
417 
                $dir->id = $row->ID;
304 lars 418 
                $dir->directory_id = $row->Father;
303 lars 419 
                $dir->name = $row->Name;
432 lars 420 
                $dir->articlemaster = $row->Artikelstamm;
304 lars 421 
                $dir->status = $row->status;
303 lars 422 
                $dir->kennung = $row->Kennung;
304 lars 423 
                $dir->description = $row->Beschreibung;
424 
                $dir->short_line_1 = $row->short_line_1;
303 lars 425 
                $dir->url = $row->url;
426 
                $dir->created_at = $row->erstellt_am;
427 
                $dir->created_by = $ersteller;
428 
                $dir->updated_by = $bearbeiter;
429 
                $dir->updated_at = $row->letzte_Aenderung_am;
430 
                $dir->save();
301 lars 431 
                $progressbar->advance();
260 lars 432 
            }
301 lars 433 
            $progressbar->finish();
302 lars 434 
            $progressbar->clear();
260 lars 435 
        }
436 
 
437 
        private function migrateItems()
438 
        {
294 lars 439 
            $this->info( date( "d.m.Y H:i:s" ) . ": Migriere Artikel" );
486 lars 440 
            $start = 0;
441 
            $sql = "SELECT
442 
                    MAX(id) AS start
443 
                FROM
444 
                    items
445 
            ";
446 
            $row = DB::connection( "mysql" )->select( $sql );
527 lars 447 
            if ( $row[0]->start )
486 lars 448 
            {
527 lars 449 
                $start = $row[0]->start;
486 lars 450 
            }
260 lars 451 
            $sql = '
452 
                SELECT
453 
                    *
454 
                FROM
455 
                    artikel
456 
                WHERE
491 lars 457 
                    father >= -1
486 lars 458 
                AND
490 lars 459 
                    id>' . $start . '
260 lars 460 
            ';
461 
            $dirs = DB::connection( 'old' )->select( $sql );
301 lars 462 
            $progressbar = $this->output->createProgressBar( count( $dirs ) );
463 
            $progressbar->start();
260 lars 464 
            foreach ( $dirs as $row )
465 
            {
284 lars 466 
                $item = new Item();
467 
                $item->id = $row->ID;
468 
                $item->directory_id = $row->Father;
469 
                $item->name = $row->kurzbezeichnung;
470 
                $item->status = $row->status;
471 
                $item->kennung = $row->kennung;
472 
                $item->description = $row->beschreibung;
473 
                $item->created_at = $row->erstellt_am;
474 
                $item->updated_at = $row->letzte_Aenderung_am;
283 lars 475 
                $ersteller = $row->erstellt_von;
282 lars 476 
                if ( !$ersteller )
281 lars 477 
                {
282 lars 478 
                    $ersteller = "WebanOS Laravel Upgrade";
281 lars 479 
                }
287 lars 480 
                $bearbeiter = $row->letzte_Aenderung_von;
282 lars 481 
                if ( !$bearbeiter )
281 lars 482 
                {
282 lars 483 
                    $bearbeiter = "WebanOS Laravel Upgrade";
281 lars 484 
                }
284 lars 485 
                $item->created_by = $ersteller;
486 
                $item->updated_by = $bearbeiter;
487 
                $item->save();
301 lars 488 
                $progressbar->advance();
260 lars 489 
            }
301 lars 490 
            $progressbar->finish();
302 lars 491 
            $progressbar->clear();
294 lars 492 
            $this->info( date( "d.m.Y H:i:s" ) . ": Migriere Preise" );
494 lars 493 
            $start = 0;
492 lars 494 
            $sql = "SELECT
495 
                    MAX(id) AS start
496 
                FROM
497 
                    prices
498 
            ";
499 
            $row = DB::connection( "mysql" )->select( $sql );
527 lars 500 
            if ( $row[0]->start )
492 lars 501 
            {
527 lars 502 
                $start = $row[0]->start;
492 lars 503 
            }
260 lars 504 
            $sql = "
505 
                SELECT
506 
                    p.*
507 
                FROM
508 
                    preise p
509 
                JOIN
510 
                    artikel a
511 
                ON
512 
                    a.id=p.artikel_id
513 
                WHERE
514 
                    a.father >=-1
492 lars 515 
                AND
516 
                    p.id>" . $start . "
260 lars 517 
            ";
518 
            $prices = DB::connection( 'old' )->select( $sql );
301 lars 519 
            $progressbar = $this->output->createProgressBar( count( $prices ) );
520 
            $progressbar->start();
260 lars 521 
            foreach ( $prices as $price )
522 
            {
523 
                Price::factory()->createQuietly( [
493 lars 524 
                    "id"          => $price->id,
260 lars 525 
                    "item_id"     => $price->artikel_id,
526 
                    "preis_index" => $price->preis_index,
527 
                    "preis"       => $price->preis,
528 
                    "staffel"     => $price->staffel,
529 
                    "created_at"  => $price->geaendert_am,
288 lars 530 
                    "created_by"  => $price->geaendert_von,
531 
                    "updated_by"  => $price->geaendert_von,
260 lars 532 
                    "updated_at"  => $price->geaendert_am
533 
                ] );
301 lars 534 
                $progressbar->advance();
260 lars 535 
            }
301 lars 536 
            $progressbar->finish();
302 lars 537 
            $progressbar->clear();
260 lars 538 
        }
539 
 
527 lars 540 
        public function migrateMedia()
433 lars 541 
        {
527 lars 542 
            $this->info( date( "d.m.Y H:i:s" ) . ": Migriere Medien" );
486 lars 543 
            $start = 0;
433 lars 544 
            $sql = "SELECT
527 lars 545 
                    MAX(id) AS start
486 lars 546 
                FROM
527 lars 547 
                    media
486 lars 548 
            ";
549 
            $row = DB::connection( "mysql" )->select( $sql );
527 lars 550 
            if ( $row[0]->start )
486 lars 551 
            {
527 lars 552 
                $start = $row[0]->start;
486 lars 553 
            }
527 lars 554 
            $sql = "
555 
                SELECT
556 
                    *
557 
                FROM
558 
                    medien
559 
                WHERE
560 
                    id>" . $start . "
561 
            ";
562 
            $media = DB::connection( 'old' )->select( $sql );
563 
            $progressbar = $this->output->createProgressBar( count( $media ) );
564 
            $progressbar->start();
565 
            foreach ( $media as $medium )
566 
            {
567 
                $mediumDB = new Medium();
568 
                $mediumDB->id = $medium->id;
569 
                $mediumDB->name = $medium->name;
570 
                $mediumDB->folder = $medium->folder;
571 
                $mediumDB->medium_type_id = $medium->typ;
572 
                $mediumDB->description = $medium->beschreibung;
573 
                if ( $medium->erstellt_am )
574 
                {
575 
                    $mediumDB->created_at = date( "Y-m-d H:i:s", $medium->erstellt_am );
576 
                }
577 
                $ersteller = $medium->erstellt_von;
578 
                if ( !$ersteller )
579 
                {
580 
                    $ersteller = "WebanOS Laravel Upgrade";
581 
                }
582 
                $bearbeiter = $medium->letzte_aenderung_von;
583 
                if ( !$bearbeiter )
584 
                {
585 
                    $bearbeiter = "WebanOS Laravel Upgrade";
586 
                }
587 
                $mediumDB->created_by = $ersteller;
588 
                $mediumDB->updated_by = $bearbeiter;
589 
                $mediumDB->save();
590 
                $progressbar->advance();
591 
            }
592 
            $progressbar->finish();
593 
            $progressbar->clear();
594 
        }
595 
 
596 
        public function migrateActionMedia()
597 
        {
598 
            $this->info( date( "d.m.Y H:i:s" ) . ": Migriere Aktions-Bilder" );
599 
            $start = 0;
486 lars 600 
            $sql = "SELECT
527 lars 601 
                    MAX(id) AS start
602 
                FROM
603 
                    action_media
604 
            ";
605 
            $row = DB::connection( "mysql" )->select( $sql );
606 
            if ( $row[0]->start )
607 
            {
608 
                $start = $row[0]->start;
609 
            }
610 
            $sql = "SELECT
433 lars 611 
                    *
612 
                FROM
527 lars 613 
                    aktionen_medien
486 lars 614 
                WHERE
527 lars 615 
                    id>" . $start . "
433 lars 616 
            ";
617 
            $media = DB::connection( 'old' )->select( $sql );
618 
            $progressbar = $this->output->createProgressBar( count( $media ) );
619 
            $progressbar->start();
620 
            foreach ( $media as $row )
621 
            {
527 lars 622 
                $medium = new ActionMedium();
623 
                $medium->action_id = $row->aktionen_id;
433 lars 624 
                $medium->medium_id = $row->medien_id;
625 
                $medium->rank = $row->rang;
626 
                $medium->created_by = "WebanOS Laravel Upgrade";
627 
                $medium->updated_by = "WebanOS Laravel Upgrade";
628 
                $medium->save();
629 
                $progressbar->advance();
630 
            }
631 
            $progressbar->finish();
632 
            $progressbar->clear();
633 
        }
634 
 
527 lars 635 
        public function migrateDirMedia()
260 lars 636 
        {
527 lars 637 
            $this->info( date( "d.m.Y H:i:s" ) . ": Migriere Kategorie-Bilder" );
486 lars 638 
            $start = 0;
639 
            $sql = "SELECT
527 lars 640 
                    MAX(medium_id) AS start
486 lars 641 
                FROM
527 lars 642 
                    directory_media
486 lars 643 
            ";
644 
            $row = DB::connection( "mysql" )->select( $sql );
527 lars 645 
            if ( $row[0]->start )
486 lars 646 
            {
527 lars 647 
                $start = $row[0]->start;
486 lars 648 
            }
527 lars 649 
            $sql = "SELECT
260 lars 650 
                    *
651 
                FROM
527 lars 652 
                    directory_medien
486 lars 653 
                WHERE
527 lars 654 
                    medien_id>" . $start . "
260 lars 655 
            ";
527 lars 656 
            $media = DB::connection( 'old' )->select( $sql );
657 
            $progressbar = $this->output->createProgressBar( count( $media ) );
301 lars 658 
            $progressbar->start();
527 lars 659 
            foreach ( $media as $row )
260 lars 660 
            {
527 lars 661 
                $medium = new DirectoryMedium();
662 
                $medium->directory_id = $row->directory_id;
663 
                $medium->medium_id = $row->medien_id;
664 
                $medium->rank = $row->rang;
665 
                $medium->similar = $row->aehnlich;
666 
                $medium->created_at = $row->zugeordnet_am;
667 
                $medium->updated_at = $row->zugeordnet_am;
668 
                $medium->created_by = "WebanOS Laravel Upgrade";
669 
                $medium->updated_by = "WebanOS Laravel Upgrade";
670 
                $medium->save();
301 lars 671 
                $progressbar->advance();
260 lars 672 
            }
301 lars 673 
            $progressbar->finish();
302 lars 674 
            $progressbar->clear();
260 lars 675 
        }
272 lars 676 
 
527 lars 677 
        public function migrateItemMedia()
272 lars 678 
        {
527 lars 679 
            $this->info( date( "d.m.Y H:i:s" ) . ": Migriere Artikel-Bilder" );
486 lars 680 
            $start = 0;
433 lars 681 
            $sql = "SELECT
527 lars 682 
                    MAX(medium_id) AS start
486 lars 683 
                FROM
527 lars 684 
                    item_media
486 lars 685 
            ";
686 
            $row = DB::connection( "mysql" )->select( $sql );
527 lars 687 
            if ( $row[0]->start )
486 lars 688 
            {
527 lars 689 
                $start = $row[0]->start;
486 lars 690 
            }
691 
            $sql = "SELECT
272 lars 692 
                    *
693 
                FROM
527 lars 694 
                    artikel_medien
486 lars 695 
                WHERE
527 lars 696 
                    medien_id>" . $start . "
272 lars 697 
            ";
698 
            $media = DB::connection( 'old' )->select( $sql );
301 lars 699 
            $progressbar = $this->output->createProgressBar( count( $media ) );
700 
            $progressbar->start();
433 lars 701 
            foreach ( $media as $row )
272 lars 702 
            {
527 lars 703 
                $medium = new ItemMedium();
704 
                $medium->item_id = $row->artikel_id;
433 lars 705 
                $medium->medium_id = $row->medien_id;
706 
                $medium->rank = $row->rang;
527 lars 707 
                $medium->similar = $row->aehnlich;
708 
                $medium->created_at = $row->zugeordnet_am;
709 
                $medium->updated_at = $row->zugeordnet_am;
433 lars 710 
                $medium->created_by = "WebanOS Laravel Upgrade";
711 
                $medium->updated_by = "WebanOS Laravel Upgrade";
712 
                $medium->save();
301 lars 713 
                $progressbar->advance();
272 lars 714 
            }
301 lars 715 
            $progressbar->finish();
302 lars 716 
            $progressbar->clear();
272 lars 717 
        }
304 lars 718 
 
719 
        private function migrateUsers()
720 
        {
721 
            $this->info( date( "d.m.Y H:i:s" ) . ": Migriere User" );
433 lars 722 
            $start = 0;
723 
            $sql = "SELECT
724 
                    MAX(id) AS start
725 
                FROM
434 lars 726 
                    users
433 lars 727 
            ";
728 
            $row = DB::connection( "order" )->select( $sql );
527 lars 729 
            if ( $row[0]->start )
433 lars 730 
            {
527 lars 731 
                $start = $row[0]->start;
433 lars 732 
            }
733 
            $sql = "SELECT
734 
                    *
735 
                FROM
434 lars 736 
                    Logins
433 lars 737 
                WHERE
738 
                    id>" . $start . "
739 
            ";
437 lars 740 
            $users = DB::connection( "oldOrder" )->select( $sql );
741 
            $progressbar = $this->output->createProgressBar( count( $users ) );
448 lars 742 
            $progressbar->start();
437 lars 743 
            foreach ( $users as $oldUser )
433 lars 744 
            {
443 lars 745 
                $ersteller = $oldUser->erstellt_von;
442 lars 746 
                if ( !$ersteller )
747 
                {
748 
                    $ersteller = "WebanOS Laravel Upgrade";
749 
                }
443 lars 750 
                $bearbeiter = $oldUser->letzte_Aenderung_von;
442 lars 751 
                if ( !$bearbeiter )
752 
                {
753 
                    $bearbeiter = "WebanOS Laravel Upgrade";
754 
                }
437 lars 755 
                $user = new User();
438 lars 756 
                $user->id = $oldUser->ID;
437 lars 757 
                $user->email = $oldUser->E_Mail;
758 
                $user->created_at = $oldUser->erstellt_am;
442 lars 759 
                $user->created_by = $ersteller;
760 
                $user->updated_by = $bearbeiter;
437 lars 761 
                $user->updated_at = $oldUser->letzte_Aenderung_am;
762 
                $user->save();
441 lars 763 
                $progressbar->advance();
433 lars 764 
            }
441 lars 765 
            $progressbar->finish();
766 
            $progressbar->clear();
304 lars 767 
        }
768 
 
445 lars 769 
        private function migrateAddresses( bool $isOrder = false )
304 lars 770 
        {
445 lars 771 
            $typ = "Adressen";
772 
            $table = "addresses";
773 
            $oldTable = "adresse";
774 
            if ( $isOrder === true )
775 
            {
776 
                $typ = "Bestelladressen";
777 
                $table = "order_addresses";
778 
                $oldTable = "bestelladresse";
779 
            }
780 
            $this->info( date( "d.m.Y H:i:s" ) . ": Migriere " . $typ );
781 
            $start = 0;
782 
            $sql = "SELECT
783 
                    MAX(id) AS start
784 
                FROM
785 
                    " . $table . "
786 
            ";
787 
            $row = DB::connection( "order" )->select( $sql );
527 lars 788 
            if ( $row[0]->start )
445 lars 789 
            {
527 lars 790 
                $start = $row[0]->start;
445 lars 791 
            }
792 
            $sql = "SELECT
793 
                    *
794 
                FROM
795 
                    " . $oldTable . "
796 
                WHERE
797 
                    id>" . $start . "
798 
            ";
799 
            $addresses = DB::connection( "oldOrder" )->select( $sql );
800 
            $progressbar = $this->output->createProgressBar( count( $addresses ) );
447 lars 801 
            $progressbar->start();
445 lars 802 
            foreach ( $addresses as $oldAddress )
803 
            {
804 
                $ersteller = "WebanOS Laravel Upgrade";
805 
                $bearbeiter = "WebanOS Laravel Upgrade";
458 lars 806 
                if ( $isOrder === true )
452 lars 807 
                {
808 
                    $address = new OrderAddress();
809 
                }
810 
                else
811 
                {
812 
                    $address = new Address();
813 
                }
445 lars 814 
                $address->id = $oldAddress->id;
815 
                $address->user_id = $oldAddress->logins_id;
816 
                $address->salutation = $oldAddress->anrede;
817 
                $address->pro_title = $oldAddress->pro_title;
818 
                $address->name = $oldAddress->vorname;
819 
                $address->lastname = $oldAddress->nachname;
820 
                $address->company = $oldAddress->firma;
821 
                $address->company2 = $oldAddress->firma2;
822 
                $address->street = $oldAddress->strasse1;
823 
                $address->houseno = $oldAddress->str_nr1;
824 
                $address->street2 = $oldAddress->strasse2;
825 
                $address->zip = $oldAddress->plz;
826 
                $address->city = $oldAddress->ort;
827 
                $address->country_id = $oldAddress->land;
828 
                $address->state_id = $oldAddress->state;
829 
                $address->phone = $oldAddress->telefon;
830 
                $address->fax = $oldAddress->fax;
831 
                $address->email = $oldAddress->email;
832 
                $address->nettocalculation = $oldAddress->nettoberechnung;
450 lars 833 
                $address->hr_nr = $oldAddress->hr_nr;
445 lars 834 
                $address->vat_id = $oldAddress->vat_id;
835 
                $address->vat_free = $oldAddress->mwst_befreiung;
836 
                $address->legal_form = $oldAddress->legal_form;
837 
                $address->comment = $oldAddress->comment;
451 lars 838 
                $address->created_at = $oldAddress->letzte_aenderung_am;
445 lars 839 
                $address->created_by = $ersteller;
840 
                $address->updated_by = $bearbeiter;
841 
                $address->updated_at = $oldAddress->letzte_aenderung_am;
842 
                $address->save();
843 
                $progressbar->advance();
844 
            }
845 
            $progressbar->finish();
846 
            $progressbar->clear();
304 lars 847 
        }
848 
 
849 
        private function migrateOrderAddresses()
850 
        {
445 lars 851 
            $this->migrateAddresses( true );
304 lars 852 
        }
853 
 
854 
        private function migrateOrders()
855 
        {
856 
            $this->info( date( "d.m.Y H:i:s" ) . ": Migriere Bestellungen" );
454 lars 857 
            $start = 0;
858 
            $sql = "SELECT
859 
                    MAX(id) AS start
860 
                FROM
861 
                    orders
862 
            ";
863 
            $row = DB::connection( "order" )->select( $sql );
527 lars 864 
            if ( $row[0]->start )
454 lars 865 
            {
527 lars 866 
                $start = $row[0]->start;
454 lars 867 
            }
868 
            $sql = "SELECT
869 
                    *
870 
                FROM
871 
                    Bestellung
872 
                WHERE
873 
                    id>" . $start . "
874 
            ";
875 
            $orders = DB::connection( "oldOrder" )->select( $sql );
876 
            $progressbar = $this->output->createProgressBar( count( $orders ) );
877 
            $progressbar->start();
878 
            foreach ( $orders as $oldOrder )
879 
            {
501 lars 880 
                $paidAt = $oldOrder->bezahlt_am;
881 
                if ( $paidAt == "0000-00-00 00:00:00" )
882 
                {
502 lars 883 
                    $paidAt = null;
501 lars 884 
                }
454 lars 885 
                $order = new Order();
886 
                $order->id = $oldOrder->ID;
481 lars 887 
                $order->shop_id = $oldOrder->shops_ID;
459 lars 888 
                $order->order_type_id = $oldOrder->bestellart_id;
458 lars 889 
                $order->payment_method_id = $oldOrder->zahlart_id;
890 
                $order->user_id = $oldOrder->Login;
891 
                $order->ship_addr_id = $oldOrder->ship_addr_id;
892 
                $order->bill_addr_id = $oldOrder->bill_addr_id;
893 
                $order->paid = $oldOrder->bezahlt;
501 lars 894 
                $order->paid_at = $paidAt;
458 lars 895 
                $order->paid_comment = $oldOrder->bezahlt_bemerkung;
896 
                $order->foreign_id = $oldOrder->fremd_id;
897 
                $order->foreign_payment_id = $oldOrder->bezahlt_fremdid;
898 
                $order->status = $oldOrder->status;
899 
                $order->total_amount_buffer = $oldOrder->gesamtsumme_buffer;
900 
                $order->item_status_buffer = $oldOrder->artikelstatus_buffer;
901 
                $order->invoice_status_buffer = $oldOrder->rechnungsstatus_buffer;
504 lars 902 
                $order->delivery_note_status_buffer = $oldOrder->lieferscheinStatus_buffer;
458 lars 903 
                $order->tax = $oldOrder->tax;
904 
                $order->comment = $oldOrder->Bemerkung;
905 
                $order->external_comment = $oldOrder->Bemerkung_extern;
906 
                $order->note = $oldOrder->notiz;
460 lars 907 
                $order->additional_info = $oldOrder->zusatzInfo;
458 lars 908 
                $order->shipping_group_id = $oldOrder->versandgruppen_id;
909 
                $order->kk_info = $oldOrder->kk_info;
910 
                $order->created_by = $oldOrder->erstellt_von;
911 
                $order->updated_by = $oldOrder->letzte_Aenderung_von;
912 
                $order->updated_at = $oldOrder->letzte_Aenderung_am;
913 
                $order->created_at = $oldOrder->erstellt_am;
454 lars 914 
                $order->save();
915 
                $progressbar->advance();
916 
            }
917 
            $progressbar->finish();
918 
            $progressbar->clear();
304 lars 919 
        }
920 
 
921 
        private function migrateOrderItems()
922 
        {
923 
            $this->info( date( "d.m.Y H:i:s" ) . ": Migriere Artikel in Besetllungen" );
454 lars 924 
            $start = 0;
925 
            $sql = "SELECT
926 
                    MAX(id) AS start
927 
                FROM
928 
                    order_items
929 
            ";
930 
            $row = DB::connection( "order" )->select( $sql );
527 lars 931 
            if ( $row[0]->start )
454 lars 932 
            {
527 lars 933 
                $start = $row[0]->start;
454 lars 934 
            }
935 
            $sql = "SELECT
936 
                    *
937 
                FROM
938 
                    artikel_to_Bestellung
939 
                WHERE
940 
                    id>" . $start . "
941 
            ";
942 
            $orderItems = DB::connection( "oldOrder" )->select( $sql );
943 
            $progressbar = $this->output->createProgressBar( count( $orderItems ) );
944 
            $progressbar->start();
945 
            foreach ( $orderItems as $oldOrderItem )
946 
            {
947 
                $progressbar->advance();
948 
            }
949 
            $progressbar->finish();
950 
            $progressbar->clear();
304 lars 951 
        }
535 lars 952 
 
953 
        private function migrateSalesPortalTypes()
954 
        {
955 
            $this->info( date( "d.m.Y H:i:s" ) . ": Migriere Verkaufsportalarten" );
956 
            $start = 0;
957 
            $sql = "SELECT
958 
                    MAX(id) start
959 
                FROM
960 
                    sales_portal_types
961 
            ";
962 
            $row = DB::connection( 'cms' )->select( $sql );
963 
            if ( $row[0]->start )
964 
            {
965 
                $start = $row[0]->start;
966 
            }
967 
            $sql = "SELECT
968 
                    *
969 
                FROM
970 
                    vportale_art
971 
                WHERE
972 
                    id>" . $start . "
973 
            ";
974 
            $portals = DB::connection( 'cms' )->select( $sql );
552 lars 975 
            $progressbar = $this->output->createProgressBar( count( $portals ) );
976 
            $progressbar->start();
535 lars 977 
            foreach ( $portals as $portal )
978 
            {
979 
                SalesPortalType::factory()->create( [
980 
                    "id"                   => $portal->id,
981 
                    "type"                 => $portal->art,
982 
                    "name"                 => $portal->bezeichnung,
983 
                    "max_categories"       => $portal->max_categories,
984 
                    "min_depth_category"   => $portal->min_depth_category,
985 
                    "only_end_category"    => $portal->only_end_category,
986 
                    "script"               => $portal->skript,
987 
                    "script_folder"        => $portal->script_folder,
988 
                    "commit_possibilities" => $portal->commit_posibilities,
989 
                    "revokeable"           => $portal->stornierbar,
990 
                ] );
552 lars 991 
                $progressbar->advance();
535 lars 992 
            }
552 lars 993 
            $progressbar->finish();
994 
            $progressbar->clear();
535 lars 995 
        }
996 
 
997 
        private function migrateSalesPortals()
998 
        {
999 
            $this->info( date( "d.m.Y H:i:s" ) . ": Migriere Verkaufsportale" );
1000 
            $start = 0;
1001 
            $sql = "SELECT
1002 
                    MAX(id) start
1003 
                FROM
1004 
                    sales_portals
1005 
            ";
1006 
            $row = DB::connection( 'mysql' )->select( $sql );
1007 
            if ( $row[0]->start )
1008 
            {
1009 
                $start = $row[0]->start;
1010 
            }
1011 
            $sql = "SELECT
1012 
                    *
1013 
                FROM
1014 
                    vportale
1015 
                WHERE
1016 
                    id>" . $start . "
1017 
            ";
1018 
            $portals = DB::connection( 'old' )->select( $sql );
552 lars 1019 
            $progressbar = $this->output->createProgressBar( count( $portals ) );
1020 
            $progressbar->start();
535 lars 1021 
            foreach ( $portals as $portal )
538 lars 1022 
            {
1023 
                $max_preis = 0;
1024 
                $anrede = 1;
1025 
                if ( isset( $portal->anrede ) )
1026 
                {
1027 
                    $anrede = $portal->anrede;
1028 
                }
1029 
                if ( isset( $portal->max_preis ) )
1030 
                {
1031 
                    $max_preis = $portal->max_preis;
1032 
                }
535 lars 1033 
                SalesPortal::factory()->create( [
538 lars 1034 
                    "id"                   => $portal->id,
1035 
                    "name"                 => $portal->name,
1036 
                    "template"             => $portal->template,
1037 
                    "sales_portal_type_id" => $portal->art,
1038 
                    "sku_prefix"           => $portal->sku_prefix,
1039 
                    "price_number"         => $portal->preis_nummer,
1040 
                    "base_price"           => $portal->basis_preis,
1041 
                    "min_price"            => $portal->min_preis,
1042 
                    "max_price"            => $max_preis,
1043 
                    "digits"               => $portal->runden,
1044 
                    "standard_amount"      => $portal->standard_menge,
1045 
                    "item_url"             => $portal->artikel_url,
1046 
                    "currency"             => $portal->currency,
1047 
                    "shipping_state"       => $portal->lieferstatus,
1048 
                    "delivery"             => $portal->delivery,
1049 
                    "shipping_cost"        => $portal->shipping_cost,
1050 
                    "afterbuy"             => $portal->afterbuy,
1051 
                    "salutation"           => $anrede,
1052 
                    "commit_fields"        => $portal->commit_fields,
1053 
                    "zip"                  => $portal->plz,
1054 
                    "location"             => $portal->location,
1055 
                    "created_by"           => $portal->erstellt_von,
1056 
                    "updated_by"           => $portal->geaendert_von,
1057 
                    "created_at"           => $portal->erstellt_am,
1058 
                    "updated_at"           => $portal->geaendert_am,
535 lars 1059 
                ] );
552 lars 1060 
                $progressbar->advance();
535 lars 1061 
            }
552 lars 1062 
            $progressbar->finish();
1063 
            $progressbar->clear();
535 lars 1064 
        }
538 lars 1065 
 
1066 
        private function migrateSalesPortalItems()
1067 
        {
1068 
            $this->info( date( "d.m.Y H:i:s" ) . ": Migriere Verkaufsportalartikel" );
1069 
            $start = 0;
1070 
            $sql = "SELECT
1071 
                    MAX(id) start
1072 
                FROM
1073 
                    sales_portal_items
1074 
            ";
1075 
            $row = DB::connection( 'mysql' )->select( $sql );
1076 
            if ( $row[0]->start )
1077 
            {
1078 
                $start = $row[0]->start;
1079 
            }
1080 
            $sql = "SELECT
1081 
                    *
1082 
                FROM
1083 
                    artikel_vportale
1084 
                WHERE
1085 
                    id>" . $start . "
1086 
            ";
1087 
            $items = DB::connection( 'old' )->select( $sql );
552 lars 1088 
            $progressbar = $this->output->createProgressBar( count( $items ) );
1089 
            $progressbar->start();
538 lars 1090 
            foreach ( $items as $item )
1091 
            {
544 lars 1092 
                $pickup = 0;
1093 
                if ( isset( $item->pickup ) )
1094 
                {
1095 
                    $pickup = $item->pickup;
1096 
                }
549 lars 1097 
                $start = $item->start;
1098 
                if ( $start == "0000-00-00 00:00:00" )
1099 
                {
1100 
                    $start = null;
1101 
                }
547 lars 1102 
                $erstellt_am = $item->erstellt_am;
1103 
                if ( $erstellt_am == "0000-00-00 00:00:00" )
1104 
                {
1105 
                    $erstellt_am = null;
1106 
                }
548 lars 1107 
                $geaendert_am = $item->geaendert_am;
1108 
                if ( $geaendert_am == "0000-00-00 00:00:00" )
547 lars 1109 
                {
548 lars 1110 
                    $geaendert_am = null;
547 lars 1111 
                }
538 lars 1112 
                SalesPortalItem::factory()->create( [
1113 
                    "id"                              => $item->id,
1114 
                    "sales_portal_id"                 => $item->vportale_id,
1115 
                    "item_id"                         => $item->artikel_id,
1116 
                    "sales_portal_template_id"        => $item->template_id,
1117 
                    "sku"                             => $item->sku,
1118 
                    "additions"                       => $item->zusaetze,
1119 
                    "foreign_item_id"                 => $item->fremdartikel_id,
1120 
                    "name"                            => $item->name,
1121 
                    "autochange_name"                 => $item->autochange_name,
1122 
                    "name_bold"                       => $item->name_fett,
1123 
                    "highlight"                       => $item->highlight,
1124 
                    "sub_name"                        => $item->sub_name,
1125 
                    "manufacturer"                    => $item->hersteller,
1126 
                    "autochange_manufacturer"         => $item->autochange_hersteller,
1127 
                    "ean"                             => $item->ean,
1128 
                    "autochange_ean"                  => $item->autochange_ean,
1129 
                    "mpn"                             => $item->mpn,
1130 
                    "autochange_mpn"                  => $item->autochange_mpn,
1131 
                    "description"                     => $item->beschreibung,
1132 
                    "autochange_description"          => $item->autochange_beschreibung,
541 lars 1133 
                    "description_addition"            => $item->beschreibung_zusatz,
542 lars 1134 
                    "autochange_description_addition" => $item->autochange_beschreibung_zusatz,
538 lars 1135 
                    "price"                           => $item->preis,
1136 
                    "autochange_price"                => $item->autochange_preis,
543 lars 1137 
                    "currency"                        => $item->currency,
538 lars 1138 
                    "tax"                             => $item->tax,
1139 
                    "price_type"                      => $item->preisart,
1140 
                    "amount"                          => $item->menge,
1141 
                    "carrier"                         => $item->carrier,
1142 
                    "carrier_cost"                    => $item->carrier_cost,
549 lars 1143 
                    "start"                           => $start,
538 lars 1144 
                    "duration"                        => $item->dauer,
1145 
                    "category_1"                      => $item->kategorie_1,
1146 
                    "category_2"                      => $item->kategorie_2,
1147 
                    "category_3"                      => $item->kategorie_3,
1148 
                    "bp1"                             => $item->bp1,
1149 
                    "bp2"                             => $item->bp2,
1150 
                    "bp3"                             => $item->bp3,
1151 
                    "bp4"                             => $item->bp4,
1152 
                    "bp5"                             => $item->bp5,
1153 
                    "platin_search_1"                 => $item->platin_search_1,
1154 
                    "platin_search_2"                 => $item->platin_search_2,
1155 
                    "platin_search_3"                 => $item->platin_search_3,
1156 
                    "platin_search_4"                 => $item->platin_search_4,
1157 
                    "platin_search_5"                 => $item->platin_search_5,
1158 
                    "search_1"                        => $item->search_1,
1159 
                    "search_2"                        => $item->search_2,
1160 
                    "search_3"                        => $item->search_3,
1161 
                    "search_4"                        => $item->search_4,
1162 
                    "search_5"                        => $item->search_5,
1163 
                    "status"                          => $item->status,
1164 
                    "online_status"                   => $item->online_status,
1165 
                    "delivery_time"                   => $item->lieferzeit,
544 lars 1166 
                    "pickup"                          => $pickup,
538 lars 1167 
                    "last_feedback"                   => $item->last_feedback,
1168 
                    "created_by"                      => $item->erstellt_von,
1169 
                    "updated_by"                      => $item->geaendert_von,
547 lars 1170 
                    "created_at"                      => $erstellt_am,
1171 
                    "updated_at"                      => $geaendert_am,
538 lars 1172 
                ] );
552 lars 1173 
                $progressbar->advance();
538 lars 1174 
            }
552 lars 1175 
            $progressbar->finish();
1176 
            $progressbar->clear();
555 lars 1177 
        }
551 lars 1178 
 
555 lars 1179 
        private function migratePriceAgencies()
1180 
        {
552 lars 1181 
            $this->info( date( "d.m.Y H:i:s" ) . ": Migriere Preisagenturen" );
551 lars 1182 
            $start = 0;
1183 
            $sql = "SELECT
1184 
                    MAX(id) start
1185 
                FROM
1186 
                    price_agencies
1187 
            ";
1188 
            $row = DB::connection( 'mysql' )->select( $sql );
1189 
            if ( $row[0]->start )
1190 
            {
1191 
                $start = $row[0]->start;
1192 
            }
1193 
            $sql = "SELECT
1194 
                    *
1195 
                FROM
1196 
                    Preisagentur
1197 
                WHERE
1198 
                    id>" . $start . "
1199 
            ";
555 lars 1200 
            $agencies = DB::connection( 'old' )->select( $sql );
552 lars 1201 
            $progressbar = $this->output->createProgressBar( count( $agencies ) );
1202 
            $progressbar->start();
555 lars 1203 
            foreach ( $agencies as $agency )
1204 
            {
1205 
                $letzter_Abruf_am = $agency->letzter_Abruf_am;
1206 
                if ( $letzter_Abruf_am == "0000-00-00 00:00:00" )
1207 
                {
1208 
                    $letzter_Abruf_am = null;
1209 
                }
1210 
                $letzte_Aktualisierung_am = $agency->letzte_Aktualisierung_am;
1211 
                if ( $letzte_Aktualisierung_am == "0000-00-00 00:00:00" )
1212 
                {
1213 
                    $letzte_Aktualisierung_am = null;
1214 
                }
1215 
                PriceAgency::factory()->create( [
1216 
                    "id"                   => $agency->ID,
1217 
                    "shop_id"              => $agency->shops_ID,
1218 
                    "name"                 => $agency->Titel,
1219 
                    "logo_url"             => $agency->logo_url,
1220 
                    "home_url"             => $agency->home_url,
1221 
                    "csv_url"              => $agency->csv_url,
1222 
                    "trigger_url"          => $agency->trigger_URL,
1223 
                    "voting_url"           => $agency->bewertungs_URL,
1224 
                    "records"              => $agency->datensaetze,
1225 
                    "access_url"           => $agency->Zugang_URL,
1226 
                    "access_user"          => $agency->Zugang_Benutzer,
1227 
                    "access_password"      => $agency->Zugang_Passwort,
1228 
                    "comment"              => $agency->Bemerkung,
1229 
                    "locked_manufacturers" => $agency->gesperrte_hersteller,
1230 
                    "config"               => $agency->config,
1231 
                    "status"               => $agency->status,
1232 
                    "only_deliverable"     => $agency->nur_lieferbar,
1233 
                    "min_price"            => $agency->min_preis,
1234 
                    "last_updated_at"      => $letzte_Aktualisierung_am,
1235 
                    "last_access_at"       => $letzter_Abruf_am,
1236 
                    "last_access_by"       => $agency->letzter_Abruf_von,
1237 
                    "updated_at"           => $agency->letzte_Aenderung_am,
1238 
                    "updated_by"           => $agency->letzte_Aenderung_von,
1239 
                ] );
552 lars 1240 
                $progressbar->advance();
1241 
            }
1242 
            $progressbar->finish();
1243 
            $progressbar->clear();
555 lars 1244 
        }
233 lars 1245 
    }