Raphaël G. Git Repositories - airbundle/blob - Repository/UserRepository.php

   1 <?php declare(strict_types=1);
   2
   3 /*
   4  * This file is part of the Rapsys AirBundle package.
   5  *
   6  * (c) Raphaël Gertz <symfony@rapsys.eu>
   7  *
   8  * For the full copyright and license information, please view the LICENSE
   9  * file that was distributed with this source code.
  10  */
  11
  12 namespace Rapsys\AirBundle\Repository;
  13
  14 use Doctrine\ORM\AbstractQuery;
  15 use Doctrine\ORM\Query\ResultSetMapping;
  16
  17 use Symfony\Component\Routing\Generator\UrlGeneratorInterface;
  18
  19 use Rapsys\AirBundle\Repository;
  20
  21 /**
  22  * UserRepository
  23  */
  24 class UserRepository extends Repository {
  25         /**
  26          * Find users with translated highest group and civility
  27          *
  28          * @return array The user ids keyed by group and pseudonym
  29          */
  30         public function findChoicesAsArray(): array {
  31                 //Set the request
  32                 $req =<<<SQL
  33 SELECT
  34         a.id,
  35         a.pseudonym,
  36         a.g_id,
  37         a.g_title
  38 FROM (
  39         SELECT
  40                 u.id,
  41                 u.pseudonym,
  42                 g.id AS g_id,
  43                 g.title AS g_title
  44         FROM Rapsys\AirBundle\Entity\User AS u
  45         JOIN Rapsys\AirBundle\Entity\UserGroup AS gu ON (gu.user_id = u.id)
  46         JOIN Rapsys\AirBundle\Entity\Group AS g ON (g.id = gu.group_id)
  47         WHERE g.title <> 'User'
  48         ORDER BY g.id DESC, u.pseudonym ASC
  49         LIMIT 0, :limit
  50 ) AS a
  51 GROUP BY a.id
  52 ORDER BY NULL
  53 SQL;
  54
  55                 //Replace bundle entity name by table name
  56                 $req = str_replace($this->tableKeys, $this->tableValues, $req);
  57
  58                 //Get result set mapping instance
  59                 //XXX: DEBUG: see ../blog.orig/src/Rapsys/BlogBundle/Repository/ArticleRepository.php
  60                 $rsm = new ResultSetMapping();
  61
  62                 //Declare all fields
  63                 //XXX: see vendor/doctrine/dbal/lib/Doctrine/DBAL/Types/Types.php
  64                 //XXX: we don't use a result set as we want to translate group and civility
  65                 $rsm->addScalarResult('id', 'id', 'integer')
  66                         ->addScalarResult('pseudonym', 'pseudonym', 'string')
  67                         ->addScalarResult('g_id', 'g_id', 'integer')
  68                         ->addScalarResult('g_title', 'g_title', 'string')
  69                         ->addIndexByScalar('id');
  70
  71                 //Fetch result
  72                 $res = $this->_em
  73                         ->createNativeQuery($req, $rsm)
  74                         ->getResult();
  75
  76                 //Init return
  77                 $ret = [];
  78
  79                 //Process result
  80                 foreach($res as $data) {
  81                         //Without group or simple user
  82                         #XXX: moved in sql by removing LEFT JOIN and excluding user group
  83                         #if (empty($data['g_title']) || $data['g_title'] == 'User') {
  84                         #       //Skip it
  85                         #       continue;
  86                         #}
  87
  88                         //Get translated group
  89                         $group = $this->translator->trans($data['g_title']);
  90
  91                         //Init group subarray
  92                         if (!isset($ret[$group])) {
  93                                 $ret[$group] = [];
  94                         }
  95
  96                         //Set data
  97                         //XXX: ChoiceType use display string as key
  98                         $ret[$group][trim($data['pseudonym'].' ('.$data['id'].')')] = intval($data['id']);
  99                 }
 100
 101                 //Send result
 102                 return $ret;
 103         }
 104
 105         /**
 106          * Find user ids by pseudonym
 107          *
 108          * @param array $pseudonym The pseudonym filter
 109          * @return array The user ids
 110          */
 111         public function findIdByPseudonymAsArray(array $pseudonym): array {
 112                 //Set the request
 113                 $req =<<<SQL
 114 SELECT
 115         a.id
 116 FROM (
 117         SELECT
 118                 u.id
 119         FROM Rapsys\AirBundle\Entity\User AS u
 120         LEFT JOIN Rapsys\AirBundle\Entity\UserGroup AS gu ON (gu.user_id = u.id)
 121         WHERE u.pseudonym IN (:pseudonym)
 122         ORDER BY gu.group_id DESC, u.pseudonym ASC
 123         LIMIT 0, :limit
 124 ) AS a
 125 GROUP BY a.id
 126 ORDER BY NULL
 127 SQL;
 128
 129                 //Replace bundle entity name by table name
 130                 $req = str_replace($this->tableKeys, $this->tableValues, $req);
 131
 132                 //Get result set mapping instance
 133                 //XXX: DEBUG: see ../blog.orig/src/Rapsys/BlogBundle/Repository/ArticleRepository.php
 134                 $rsm = new ResultSetMapping();
 135
 136                 //Declare all fields
 137                 //XXX: see vendor/doctrine/dbal/lib/Doctrine/DBAL/Types/Types.php
 138                 //XXX: we don't use a result set as we want to translate group and civility
 139                 $rsm->addScalarResult('id', 'id', 'integer');
 140
 141                 //Return result
 142                 return $this->_em
 143                         ->createNativeQuery($req, $rsm)
 144                         ->setParameter('pseudonym', $pseudonym)
 145                         //XXX: instead of array_column on the result
 146                         ->getResult(AbstractQuery::HYDRATE_SCALAR_COLUMN);
 147         }
 148
 149         /**
 150          * Find applicant by session id
 151          *
 152          * @param int $sessionId The Session id
 153          * @return array The pseudonym array keyed by id
 154          */
 155         public function findBySessionId(int $sessionId): array {
 156                 //Set the request
 157                 $req =<<<SQL
 158 SELECT u.id, u.pseudonym
 159 FROM Rapsys\AirBundle\Entity\Application AS a
 160 JOIN Rapsys\AirBundle\Entity\User AS u ON (u.id = a.user_id)
 161 WHERE a.session_id = :id
 162 SQL;
 163
 164                 //Replace bundle entity name by table name
 165                 $req = str_replace($this->tableKeys, $this->tableValues, $req);
 166
 167                 //Get result set mapping instance
 168                 //XXX: DEBUG: see ../blog.orig/src/Rapsys/BlogBundle/Repository/ArticleRepository.php
 169                 $rsm = new ResultSetMapping();
 170
 171                 //Declare all fields
 172                 //XXX: see vendor/doctrine/dbal/lib/Doctrine/DBAL/Types/Types.php
 173                 //XXX: we don't use a result set as we want to translate group and civility
 174                 $rsm->addScalarResult('id', 'id', 'integer')
 175                         ->addIndexByScalar('pseudonym');
 176
 177                 //Get result
 178                 $result = $this->_em
 179                         ->createNativeQuery($req, $rsm)
 180                         ->setParameter('id', $sessionId)
 181                         ->getArrayResult();
 182
 183                 //Set return
 184                 $return = [];
 185
 186                 //Iterate on each result
 187                 foreach($result as $id => $data) {
 188                         //Add to return
 189                         $return[$id] = $data['id'];
 190                 }
 191
 192                 //Return return
 193                 return $return;
 194         }
 195
 196         /**
 197          * Find user as array by id
 198          *
 199          * @param int $id The location id
 200          * @param string $locale The locale
 201          * @return array The location data
 202          */
 203         public function findOneByIdAsArray(int $id, string $locale): ?array {
 204                 //Set the request
 205                 //TODO: zipcode/city/country (on pourra matcher les locations avec ça ?)
 206                 $req =<<<SQL
 207 SELECT
 208         u.id,
 209         u.city,
 210         u.forename,
 211         u.mail,
 212         u.phone,
 213         u.pseudonym,
 214         u.surname,
 215         u.updated,
 216         u.zipcode,
 217         u.civility_id AS c_id,
 218         c.title AS c_title,
 219         u.country_id AS o_id,
 220         o.title AS o_title,
 221         GROUP_CONCAT(g.id ORDER BY g.id SEPARATOR "\\n") AS ids,
 222         GROUP_CONCAT(g.title ORDER BY g.id SEPARATOR "\\n") AS titles,
 223         GREATEST(COALESCE(u.updated, 0), COALESCE(c.updated, 0), COALESCE(o.updated, 0)) AS modified
 224 FROM Rapsys\AirBundle\Entity\User AS u
 225 LEFT JOIN Rapsys\AirBundle\Entity\Civility AS c ON (c.id = u.civility_id)
 226 LEFT JOIN Rapsys\AirBundle\Entity\Country AS o ON (o.id = u.country_id)
 227 LEFT JOIN Rapsys\AirBundle\Entity\UserGroup AS gu ON (gu.user_id = u.id)
 228 LEFT JOIN Rapsys\AirBundle\Entity\Group AS g ON (g.id = gu.group_id)
 229 WHERE u.id = :id
 230 SQL;
 231
 232                 //Replace bundle entity name by table name
 233                 $req = str_replace($this->tableKeys, $this->tableValues, $req);
 234
 235                 //Get result set mapping instance
 236                 //XXX: DEBUG: see ../blog.orig/src/Rapsys/BlogBundle/Repository/ArticleRepository.php
 237                 $rsm = new ResultSetMapping();
 238
 239                 //Declare all fields
 240                 //XXX: see vendor/doctrine/dbal/lib/Doctrine/DBAL/Types/Types.php
 241                 //addScalarResult($sqlColName, $resColName, $type = 'string');
 242                 $rsm->addScalarResult('id', 'id', 'integer')
 243                         ->addScalarResult('city', 'city', 'string')
 244                         ->addScalarResult('forename', 'forename', 'string')
 245                         ->addScalarResult('mail', 'mail', 'string')
 246                         ->addScalarResult('phone', 'phone', 'string')
 247                         ->addScalarResult('pseudonym', 'pseudonym', 'string')
 248                         ->addScalarResult('surname', 'surname', 'string')
 249                         ->addScalarResult('updated', 'updated', 'datetime')
 250                         ->addScalarResult('zipcode', 'zipcode', 'string')
 251                         ->addScalarResult('c_id', 'c_id', 'integer')
 252                         ->addScalarResult('c_title', 'c_title', 'string')
 253                         ->addScalarResult('o_id', 'o_id', 'integer')
 254                         ->addScalarResult('o_title', 'o_title', 'string')
 255                         //XXX: is a string because of \n separator
 256                         ->addScalarResult('ids', 'ids', 'string')
 257                         //XXX: is a string because of \n separator
 258                         ->addScalarResult('titles', 'titles', 'string')
 259                         ->addScalarResult('modified', 'modified', 'datetime')
 260                         ->addIndexByScalar('id');
 261
 262                 //Get result
 263                 $result = $this->_em
 264                         ->createNativeQuery($req, $rsm)
 265                         ->setParameter('id', $id)
 266                         ->getOneOrNullResult();
 267
 268                 //Without result
 269                 if ($result === null) {
 270                         //Return result
 271                         return $result;
 272                 }
 273
 274                 //Set alternates
 275                 $result['alternates'] = [];
 276
 277                 //Set route
 278                 $route = 'rapsysair_user_view';
 279
 280                 //Set route params
 281                 $routeParams = ['id' => $id, 'user' => $this->slugger->slug($result['pseudonym'])];
 282
 283                 //Milonga Raphaël exception
 284                 if ($routeParams['id'] == 1 && $routeParams['user'] == 'milonga-raphael') {
 285                         //Set route
 286                         $route = 'rapsysair_user_milongaraphael';
 287                         //Set route params
 288                         $routeParams = [];
 289                 }
 290
 291                 //Iterate on each languages
 292                 foreach($this->languages as $languageId => $language) {
 293                         //Without current locale
 294                         if ($languageId !== $locale) {
 295                                 //Set titles
 296                                 $titles = [];
 297
 298                                 //Set route params locale
 299                                 $routeParams['_locale'] = $languageId;
 300
 301                                 //Iterate on each locales
 302                                 foreach(array_keys($this->languages) as $other) {
 303                                         //Without other locale
 304                                         if ($other !== $languageId) {
 305                                                 //Set other locale title
 306                                                 $titles[$other] = $this->translator->trans($language, [], null, $other);
 307                                         }
 308                                 }
 309
 310                                 //Add alternates locale
 311                                 $result['alternates'][substr($languageId, 0, 2)] = $result['alternates'][str_replace('_', '-', $languageId)] = [
 312                                         'absolute' => $this->router->generate($route, $routeParams, UrlGeneratorInterface::ABSOLUTE_URL),
 313                                         'relative' => $this->router->generate($route, $routeParams),
 314                                         'title' => implode('/', $titles),
 315                                         'translated' => $this->translator->trans($language, [], null, $languageId)
 316                                 ];
 317                         }
 318                 }
 319
 320                 //Set titles
 321                 $titles = explode("\n", $result['titles']);
 322
 323                 //Set groups and roles
 324                 $groups = $roles = [];
 325
 326                 //Iterate on each location
 327                 foreach(explode("\n", $result['ids']) as $k => $id) {
 328                         //Add role
 329                         //XXX: roles are keyes by id
 330                         $roles[$id] = 'ROLE_'.strtoupper($titles[$k]);
 331
 332                         //Add group
 333                         $groups[$id] = $this->translator->trans($titles[$k]);
 334                 }
 335
 336                 //Return result
 337                 return [
 338                         'id' => $result['id'],
 339                         'mail' => $result['mail'],
 340                         'pseudonym' => $result['pseudonym'],
 341                         'forename' => $result['forename'],
 342                         'surname' => $result['surname'],
 343                         'phone' => $result['phone'],
 344                         'zipcode' => $result['zipcode'],
 345                         'city' => $result['city'],
 346                         'civility' => [
 347                                 'id' => $result['c_id'],
 348                                 'title' => $this->translator->trans($result['c_title'])
 349                         ],
 350                         'country' => [
 351                                 'id' => $result['o_id'],
 352                                 //XXX: without country, o_title is empty
 353                                 'title' => $this->translator->trans($result['o_title'])
 354                         ],
 355                         'updated' => $result['updated'],
 356                         'roles' => $roles,
 357                         'groups' => $groups,
 358                         'modified' => $result['modified'],
 359                         'multimap' => $this->translator->trans('%pseudonym% sector map', ['%pseudonym%' => $result['pseudonym']]),
 360                         'slug' => $this->slugger->slug($result['pseudonym']),
 361                         'link' => $this->router->generate($route, ['_locale' => $locale]+$routeParams),
 362                         'alternates' => $result['alternates']
 363                 ];
 364         }
 365
 366         /**
 367          * Find all users grouped by translated group
 368          *
 369          * @return array The user mail and pseudonym keyed by group and id
 370          */
 371         public function findIndexByGroupId(): array {
 372                 //Set the request
 373                 $req = <<<SQL
 374 SELECT
 375         t.id,
 376         t.mail,
 377         t.forename,
 378         t.surname,
 379         t.pseudonym,
 380         t.g_id,
 381         t.g_title,
 382         GROUP_CONCAT(t.d_id ORDER BY t.d_id SEPARATOR "\\n") AS d_ids,
 383         GROUP_CONCAT(t.d_name ORDER BY t.d_id SEPARATOR "\\n") AS d_names,
 384         GROUP_CONCAT(t.d_type ORDER BY t.d_id SEPARATOR "\\n") AS d_types
 385 FROM (
 386         SELECT
 387                 c.id,
 388                 c.mail,
 389                 c.forename,
 390                 c.surname,
 391                 c.pseudonym,
 392                 c.g_id,
 393                 c.g_title,
 394                 d.id AS d_id,
 395                 d.name AS d_name,
 396                 d.type AS d_type
 397         FROM (
 398                 SELECT
 399                         u.id,
 400                         u.mail,
 401                         u.forename,
 402                         u.surname,
 403                         u.pseudonym,
 404                         g.id AS g_id,
 405                         g.title AS g_title
 406                 FROM Rapsys\AirBundle\Entity\User AS u
 407                 JOIN Rapsys\AirBundle\Entity\UserGroup AS gu ON (gu.user_id = u.id)
 408                 JOIN Rapsys\AirBundle\Entity\Group AS g ON (g.id = gu.group_id)
 409                 ORDER BY NULL
 410                 LIMIT 0, :limit
 411         ) AS c
 412         LEFT JOIN Rapsys\AirBundle\Entity\Application AS a ON (a.user_id = c.id)
 413         LEFT JOIN Rapsys\AirBundle\Entity\Dance AS d ON (d.id = a.dance_id)
 414         GROUP BY d.id
 415         ORDER BY NULL
 416         LIMIT 0, :limit
 417 ) AS t
 418 GROUP BY t.g_id, t.id
 419 ORDER BY t.g_id DESC, t.id ASC
 420 SQL;
 421
 422                 //Replace bundle entity name by table name
 423                 $req = str_replace($this->tableKeys, $this->tableValues, $req);
 424
 425                 //Get result set mapping instance
 426                 //XXX: DEBUG: see ../blog.orig/src/Rapsys/BlogBundle/Repository/ArticleRepository.php
 427                 $rsm = new ResultSetMapping();
 428
 429                 //Declare all fields
 430                 //XXX: see vendor/doctrine/dbal/lib/Doctrine/DBAL/Types/Types.php
 431                 //addScalarResult($sqlColName, $resColName, $type = 'string');
 432                 $rsm->addScalarResult('id', 'id', 'integer')
 433                         ->addScalarResult('mail', 'mail', 'string')
 434                         ->addScalarResult('forename', 'forename', 'string')
 435                         ->addScalarResult('surname', 'surname', 'string')
 436                         ->addScalarResult('pseudonym', 'pseudonym', 'string')
 437                         ->addScalarResult('g_id', 'g_id', 'integer')
 438                         ->addScalarResult('g_title', 'g_title', 'string')
 439                         //XXX: is a string because of \n separator
 440                         ->addScalarResult('d_ids', 'd_ids', 'string')
 441                         //XXX: is a string because of \n separator
 442                         ->addScalarResult('d_names', 'd_names', 'string')
 443                         //XXX: is a string because of \n separator
 444                         ->addScalarResult('d_types', 'd_types', 'string');
 445
 446                 //Fetch result
 447                 $res = $this->_em
 448                         ->createNativeQuery($req, $rsm)
 449                         ->getResult();
 450
 451                 //Init return
 452                 $ret = [];
 453
 454                 //Process result
 455                 foreach($res as $data) {
 456                         //Get translated group
 457                         $group = $this->translator->trans($data['g_title']);
 458
 459                         //Init group subarray
 460                         if (!isset($ret[$group])) {
 461                                 $ret[$group] = [];
 462                         }
 463
 464                         //Set dances
 465                         $dances = [];
 466
 467                         //Set data
 468                         $ret[$group][$data['id']] = [
 469                                 'mail' => $data['mail'],
 470                                 'forename' => $data['forename'],
 471                                 'surname' => $data['surname'],
 472                                 'pseudonym' => $data['pseudonym'],
 473                                 'dances' => [],
 474                                 'slug' => $slug = $this->slugger->slug($data['pseudonym']),
 475                                 //Milonga Raphaël exception
 476                                 'link' => $data['id'] == 1 && $slug == 'milonga-raphael' ? $this->router->generate('rapsysair_user_milongaraphael', []) : $this->router->generate('rapsysair_user_view', ['id' => $data['id'], 'user' => $slug]),
 477                                 'edit' => $this->router->generate('rapsysuser_edit', ['mail' => $short = $this->slugger->short($data['mail']), 'hash' => $this->slugger->hash($short)])
 478                         ];
 479
 480                         //With dances
 481                         if (!empty($data['d_ids'])) {
 482                                 //Set names
 483                                 $names = explode("\n", $data['d_names']);
 484
 485                                 //Set types
 486                                 $types = explode("\n", $data['d_types']);
 487
 488                                 //Iterate on each dance
 489                                 foreach(explode("\n", $data['d_ids']) as $k => $id) {
 490                                         //Init dance when missing
 491                                         if (!isset($ret[$group][$data['id']]['dances'][$name = $this->translator->trans($names[$k])])) {
 492                                                 $ret[$group][$data['id']]['dances'][$name] = [
 493                                                         'link' => $this->router->generate('rapsysair_dance_name', ['name' => $this->slugger->short($names[$k]), 'dance' => $this->slugger->slug($name)]),
 494                                                         'types' => []
 495                                                 ];
 496                                         }
 497
 498                                         //Set type
 499                                         $ret[$group][$data['id']]['dances'][$name]['types'][$type = $this->translator->trans($types[$k])] = $this->router->generate('rapsysair_dance_view', ['id' => $id, 'name' => $this->slugger->slug($name), 'type' => $this->slugger->slug($type)]);
 500                                 }
 501                         }
 502                 }
 503
 504                 //Send result
 505                 return $ret;
 506         }
 507 }