WordPress

<?php

namespace App\Command;

use App\Entity\Country;
use App\Entity\FtpUser;
use App\Entity\PayoutDetails;
use App\Entity\Stock;
use App\Entity\User;
use App\Service\FileUploader;
use App\Util\UserManipulator;
use FOS\UserBundle\Util\TokenGenerator;
use Symfony\Component\Console\Command\Command;
use Symfony\Component\Console\Input\InputArgument;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Input\InputOption;
use Symfony\Component\Console\Output\OutputInterface;
use Symfony\Component\Console\Style\SymfonyStyle;
use Psr\Container\ContainerInterface;
use Symfony\Component\DependencyInjection\ParameterBag\ParameterBagInterface;
use Symfony\Component\Filesystem\Filesystem;
use Symfony\Component\Finder\Finder;

class UpdateUserCommand extends Command
{
    protected static $defaultName = 'app:update-users';
    private $userManipulator;

    private $container;
    private $fileUploader;
    private $params;


    public function __construct(ContainerInterface $container, ParameterBagInterface $parameterBag,FileUploader $fileUploader)
    {


        parent::__construct();
        $this->params = $parameterBag;
        $this->container = $container;
        $this->fileUploader = $fileUploader;
        $this->em = $this->container->get('doctrine')->getManager();
    }

    protected function configure()
    {
//        parent::__construct();
        $this
            ->setDescription('Add a short description for your command')
            ->addArgument('arg1', InputArgument::OPTIONAL, 'Argument description')
            ->addOption('option1', null, InputOption::VALUE_NONE, 'Option description')
        ;
    }



    protected function execute(InputInterface $input, OutputInterface $output): int
    {
        $io = new SymfonyStyle($input, $output);


        $storage_dir=$this->params->get('ftp_directory');

        $servername = getenv('OLD_DATABASE_HOST');
        $username = getenv('OLD_DATABASE_USERNAME');
        $password = getenv('OLD_DATABASE_PASSWORD');
        $dbname = getenv('OLD_DATABASE_DATABASE');
//        $manipulator = $this->getContainer()->get('fos_user.util.user_manipulator');
// Create connection
        $conn = new \mysqli($servername, $username, $password, $dbname);

// Check connection
        if ($conn->connect_error) {
            die("Connection failed: " . $conn->connect_error);
        }

        $sql = "

SELECT
    `users`.*,user_payment_details.*,
       user_details.`firstname`,
       user_details.`middlename`,
       user_details.`surname`,
       user_details.`postaladdress`,
       user_details.`postaddress`,
       user_details.`zipcode`,
       user_details.`city`,
       user_details.`country`,
       user_details.`telnumber`,
       user_details.`email` as details_email,
       user_details.`id_file`,
       user_details.`id_name`,
       user_details.`id_status`,
       user_details.`contributor_status`,
       user_details.`upload_status`,
       user_details.`edit_status`,
       user_details. `video_upload_status`,
       user_details.`video_edit_status`,
       user_details.`user_id`


FROM `users`
         LEFT JOIN user_details on user_details.user_id = users.id
         LEFT JOIN user_payment_details on user_payment_details.user_id = users.id
where length(user_details.surname)<30
;
";
        $result = $conn->query($sql);
        if ($result->num_rows > 0) {
            while ($row = $result->fetch_assoc()) {
                 //print_r($row); die;
                $this->createPaymentDetails($row);
                $io->note($row['details_email'].'-- Impored');
            }//end sample
        } else {
            echo "0 results";
        }
        $conn->close();

        $arg1 = $input->getArgument('arg1');

        if ($arg1) {
            $io->note(sprintf('You passed an argument: %s', $arg1));
        }

        if ($input->getOption('option1')) {
            // ...
        }

        $io->success('All users imported!.');

        return 0;
    }


    public function createPaymentDetails ($oldUser )
    {
        /**
         * @var User $newUser
         */
         $newUser = $this->em->getRepository(User::class)->findOneBy(['email'=>$oldUser['email']]);
        if(!empty($newUser))
        {
//            if($newUser->hasRole('ROLE_CONTRIBUTOR'))
//            {
//                $paymentDetails = new PayoutDetails();
//                $paymentDetails->setUser($newUser);
//                $paymentDetails->setCity($oldUser['city']);
//                $paymentDetails->setBankName($oldUser['bank_name']);
//                $paymentDetails->setCountry( $this->em->getRepository(Country::class)->findOneBy(['Name'=>$oldUser['country']]));
//                $paymentDetails->setAccountNumber($oldUser['account_number']);
//                $paymentDetails->setZipCode($oldUser['zipcode']);
//                $paymentDetails->setAccountName($oldUser['account_name']);
//                $paymentDetails->setBranchName($oldUser['branch_name']);
//                $paymentDetails->setEmailAddress($newUser->getEmail());
//                $paymentDetails->setMobileNumber($oldUser['telnumber']);
//                $paymentDetails->setPostalAdress($oldUser['postaddress']);
//                if($oldUser['payment_mode']!=null)
//                {
//                    $paymentDetails->setMode($oldUser['payment_mode']);
//                }else{
//                    $paymentDetails->setMode('Not Set');
//                }
//
//                $this->em->persist($paymentDetails);
//                if($newUser->getIdentityFile()!=null)
//                {
//                    $newUser->setIdentityVerified(2);
//                    $newUser->setRegistrationComplete(1);
//
//                }else{
//
//                    $newUser->setRegistrationComplete(0);
//                }
//
//                $this->createFtp($newUser);
//
//            }else{
//                $newUser->setRegistrationComplete(1);
//                $newUser->setIdentityVerified(User::IDENTITY_NOT_UPLOADED);
//                $userManager = $this->container->get('fos_user.user_manager');
//                $userManager->updateUser($newUser, true);
//            }
//            $joinedOn= new \DateTime($oldUser['date_joined']);
//            $newUser->setJoinedOn($joinedOn);
//            $newUser->setPlainPassword('sura2020');
//            $newUser->setEnabled(true);
            if(!empty($oldUser['telnumber']))
            {
                $newUser->setPhoneNumber($oldUser['telnumber']);
            }else{
                $newUser->setPhoneNumber('not set');
            }

            $this->em->persist($newUser);
            $this->em->flush();
            $userManager = $this->container->get('fos_user.user_manager');
            $userManager->updateUser($newUser, true);

        }
        return true;
    }

    public function createFtp($currentUser){
        $storage_dir=$this->params->get('ftp_directory');
        $filesystem= new Filesystem();
        $finder = new Finder();
        /** @var User $currentUser */
        $ftpUser=$currentUser->getFtpUser();
        if($ftpUser==null) {
            $ftpUser = new FtpUser();
            $ftpUser->setUser($currentUser);
            $ftpUser->setUserid($currentUser->getUsernameCanonical());
            try {
                $ftpPath = $storage_dir . DIRECTORY_SEPARATOR . $currentUser->getUsername();
                $thumbnailPath = $storage_dir . DIRECTORY_SEPARATOR . $currentUser->getUsername().DIRECTORY_SEPARATOR.Stock::IMAGE_THUMBS_DIR;

                if (!$filesystem->exists($ftpPath)) {
                    $filesystem->mkdir($ftpPath);
                }
                if (!$filesystem->exists($thumbnailPath)) {
                    $filesystem->mkdir($thumbnailPath);
                }


                $ftpUser->setHomedir($ftpPath);
                $ftpUser->setPasswd(uniqid());
                $this->em->persist($ftpUser);
                $this->em->flush();


            } catch (IOExceptionInterface $exception) {
                echo "An error occurred while creating your directory at " . $exception->getPath();
                die;
            }
        }
    }
}