Comando para actualizar campo extraData

Command/UpdateExtraDataCommand.php

@@ -0,0 +1,97 @@
+<?php
+
+namespace ExtraDataBundle\Command;
+
+use Buzz\Client\Curl;
+use Buzz\Message\Request as HttpRequest;
+use Buzz\Message\RequestInterface as HttpRequestInterface;
+use Buzz\Message\Response as HttpResponse;
+use Symfony\Bundle\FrameworkBundle\Command\ContainerAwareCommand;
+use Symfony\Component\Console\Input\InputInterface;
+use Symfony\Component\Console\Output\OutputInterface;
+use Symfony\Component\Console\Input\InputOption;
+
+class UpdateExtraDataCommand extends ContainerAwareCommand
+{
+
+    protected function configure()
+    {
+        $this
+                ->setName('extradata:update')
+                ->setDescription('Update entity extradata field')
+                ->setHelp('Update entity extradata field from remote data')
+                ->addOption('url', null, InputOption::VALUE_REQUIRED, 'Remote url', 'http://stats.fd3.flowdat.com/api/onus.json')
+                ->addOption('filter', null, InputOption::VALUE_OPTIONAL | InputOption::VALUE_IS_ARRAY, 'Array with filters. e.g., --filter=key1:value1 --filter=key2:value2')
+                ->addOption('username', null, InputOption::VALUE_REQUIRED, 'Remote username', 'admin')
+                ->addOption('password', null, InputOption::VALUE_REQUIRED, 'Remote password', 'adminpass')
+                ->addOption('entity-class', null, InputOption::VALUE_REQUIRED, 'Entity namespace. e.g. FTTHBundle:ONU', 'FTTHBundle:ONU')
+                ->addOption('id', null, InputOption::VALUE_REQUIRED, 'Entity Id')
+                ->addOption('fields', null, InputOption::VALUE_OPTIONAL | InputOption::VALUE_IS_ARRAY, 'Extradata fields to update')
+        ;
+    }
+
+    /**
+     * @param InputInterface $input
+     * @param OutputInterface $output
+     * 
+     * @return void
+     */
+    protected function execute(InputInterface $input, OutputInterface $output)
+    {
+        $url = $input->getOption('url');
+        $filter = $input->getOption('filter');
+        $username = $input->getOption('username');
+        $password = $input->getOption('password');
+        $entityClass = $input->getOption('entity-class');
+        $id = $input->getOption('id');
+        $fields = $input->getOption('fields');
+        try {
+            $filters = array();
+            if (!empty($filter)) {
+                foreach ($filter as $value) {
+                    $pieces = array_map('trim', explode(':', $value));
+                    if (isset($pieces[0]) && isset($pieces[1]) && $pieces[0] && $pieces[1]) {
+                        $filters[$pieces[0]] = $pieces[1];
+                    }
+                }
+            }
+
+            $client = new Curl();
+            $response = new HttpResponse();
+            $request = new HttpRequest(HttpRequestInterface::METHOD_GET, $url . '?' . http_build_query(array('filters' => $filters)));
+            $request->addHeader('Authorization: Basic ' . base64_encode($username . ':' . $password));
+            $client->send($request, $response);
+            $response = $response->getContent();
+
+            $em = $this->getContainer()->get('doctrine')->getEntityManager();
+            $repository = $em->getRepository($entityClass);
+            $entity = $repository->find($id);
+            if (is_null($entity)) {
+                $output->writeln(sprintf('<error>Entity: %s id: %s not Found!<error>', $entityClass, $entity->getId()));
+
+                return;
+            }
+            
+            $entityExtraData = json_decode($entity->getExtraData(), true);
+            $extradata = json_decode($response, true);
+            if (!empty($fields)) {
+                foreach ($fields as $field) {
+                    if (isset($extradata[0][$field])) {
+                        $entityExtraData[$field] = $extradata[0][$field];
+                    }
+                }
+            } else {
+                $entityExtraData = array_merge($entityExtraData, $extradata);
+            }
+            
+            $entity->setExtraData(json_encode($entityExtraData));
+            $em->flush($entity);
+
+            $output->writeln(sprintf('Entity: %s id: %s updated!', $entityClass, $entity->getId()));
+        } catch (\Exception $e) {
+            var_dump($e->getMessage());
+            die;
+        }
+    }
+
+}