20190108162000_insert_friendbuy_to_referral_share.php

<?php
use Phinx\Migration\AbstractMigration;
class InsertFriendbuyToReferralShare extends AbstractMigration
{
    public function change()
    {
        // we only care about rows that are not duplicate
        $friendbuyRows = $this->fetchAll("SELECT *  FROM friendbuy_shares");
        $referralTable = $this->table('referral_shares');
        foreach ($friendbuyRows as $friendbuyRow) {
            $data = [[
                'campaign_id' => $friendbuyRow['campaign_id'],
                'created_at' => $friendbuyRow['created_at'],
                'referrer_email' => $friendbuyRow['customer_email'],
                'referred_email' => $friendbuyRow['email'],
                'raw_data' => $friendbuyRow['raw_data'],
                'vendor_id' => 1 //set vendor_id to 1 for friendbuy
            ]];
            $referralTable->insert($data);
        }
        $referralTable->saveData();
    }
}