registeraddress/class.ext_update.php at develop · twaurisch/registeraddress · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
<?php

use TYPO3\CMS\Core\Utility\GeneralUtility;
use TYPO3\CMS\Core\Utility\VersionNumberUtility;
use TYPO3\CMS\Core\Database\Query\Restriction\DeletedRestriction;

/**
 * Class ext_update
 *
 * Performs update tasks for extension registeraddress
 */
// @codingStandardsIgnoreStart
class ext_update
{

    /**
     * @var \TYPO3\CMS\Core\Database\Query\QueryBuilder
     */
    protected $queryBuilder;

    /**
     * @var \TYPO3\CMS\Core\Database\DatabaseConnection
     */
    protected $databaseConnection;

    /**
     * Constructor
     *
     * @throws \InvalidArgumentException
     */
    public function __construct()
    {
        $typo3Version = VersionNumberUtility::getNumericTypo3Version();
        if (VersionNumberUtility::convertVersionNumberToInteger($typo3Version) >= 8000000) {
            // If TYPO3 version is version 8 or higher
            $this->queryBuilder = GeneralUtility::makeInstance(\TYPO3\CMS\Core\Database\ConnectionPool::class)->getQueryBuilderForTable('tt_address');
            $this->queryBuilder->getRestrictions()->removeAll()->add(GeneralUtility::makeInstance(DeletedRestriction::class));
        } else {
            // For TYPO3 Version 7 or lower
            $this->databaseConnection = $GLOBALS['TYPO3_DB'];
        }
    }

    /**
     * Called by the extension manager to determine if the update menu entry
     * should by showed.
     *
     * @return bool
     */
    public function access() {

        $typo3Version = VersionNumberUtility::getNumericTypo3Version();
        if (VersionNumberUtility::convertVersionNumberToInteger($typo3Version) >= 8000000) {
            // If TYPO3 version is version 8 or higher
            $count = $this->queryBuilder->count('uid')
                ->from('tt_address')
                ->where(
                    $this->queryBuilder->expr()->eq(
                        'registeraddresshash',
                        $this->queryBuilder->createNamedParameter('')
                    )
                )
                ->execute()
                ->fetchColumn(0);
        } else {
            // For TYPO3 Version 7 or lower
            $count = $this->databaseConnection->exec_SELECTcountRows(
                'uid',
                'tt_address',
                'registeraddresshash=""'
            );
        }

        return ($count > 0);
    }

    /**
     * Main update function called by the extension manager.
     *
     * @return string
     * @throws \Exception
     */
    public function main() {

        $content = '';

        $typo3Version = VersionNumberUtility::getNumericTypo3Version();
        if (VersionNumberUtility::convertVersionNumberToInteger($typo3Version) >= 8000000) {
            // If TYPO3 version is version 8 or higher
            $addresslist = $this->queryBuilder->select('uid', 'registeraddresshash', 'email')
                ->from('tt_address')
                ->where(
                    $this->queryBuilder->expr()->eq(
                        'registeraddresshash',
                        $this->queryBuilder->createNamedParameter('')
                    )
                )
                ->groupBy('uid')
                ->execute()->fetchAll();

            foreach ($addresslist as $fixAddress) {
                $content .= 'Updating tt_address uid:' . $fixAddress['uid'] . PHP_EOL;

                $rnd = microtime(true) . random_int(10000, 90000);
                $regHash = sha1($fixAddress['email'] . $rnd);

                $this->queryBuilder->update('tt_address')
                    ->set('registeraddresshash', $regHash)
                    ->where(
                        $this->queryBuilder->expr()->eq(
                            'uid',
                            $this->queryBuilder->createNamedParameter($fixAddress['uid'])
                        )
                    )
                    ->execute();
            }

        } else {
            // For TYPO3 Version 7 or lower
            $addresslist = $this->databaseConnection->exec_SELECTquery(
                'uid, registeraddresshash, email',
                'tt_address',
                'registeraddresshash=""'
            );

            foreach ($addresslist as $fixAddress) {
                $content .= 'Updating tt_address uid:' . $fixAddress['uid'] . PHP_EOL;

                $rnd = microtime(true) . random_int(10000, 90000);
                $regHash = sha1($fixAddress['email'] . $rnd);

                $this->databaseConnection->exec_UPDATEquery(
                    'tt_address',
                    'uid = "'.$fixAddress['uid'].'"',
                    ['registeraddresshash' => $regHash]
                );
            }
        }

        $content .= 'tt_address entries updates finished.' . PHP_EOL;

        return nl2br($content);

    }
}