xref: /webtrees/app/Tree.php (revision f0a114195ac1eac96981ed21f4681b1f2d0de72c)
1<?php
2/**
3 * webtrees: online genealogy
4 * Copyright (C) 2018 webtrees development team
5 * This program is free software: you can redistribute it and/or modify
6 * it under the terms of the GNU General Public License as published by
7 * the Free Software Foundation, either version 3 of the License, or
8 * (at your option) any later version.
9 * This program is distributed in the hope that it will be useful,
10 * but WITHOUT ANY WARRANTY; without even the implied warranty of
11 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
12 * GNU General Public License for more details.
13 * You should have received a copy of the GNU General Public License
14 * along with this program. If not, see <http://www.gnu.org/licenses/>.
15 */
16namespace Fisharebest\Webtrees;
17
18use Exception;
19use Fisharebest\Webtrees\Functions\FunctionsExport;
20use Fisharebest\Webtrees\Functions\FunctionsImport;
21use PDOException;
22
23/**
24 * Provide an interface to the wt_gedcom table.
25 */
26class Tree
27{
28    /** @var int The tree's ID number */
29    private $tree_id;
30
31    /** @var string The tree's name */
32    private $name;
33
34    /** @var string The tree's title */
35    private $title;
36
37    /** @var int[] Default access rules for facts in this tree */
38    private $fact_privacy;
39
40    /** @var int[] Default access rules for individuals in this tree */
41    private $individual_privacy;
42
43    /** @var integer[][] Default access rules for individual facts in this tree */
44    private $individual_fact_privacy;
45
46    /** @var Tree[] All trees that we have permission to see. */
47    private static $trees = [];
48
49    /** @var string[] Cached copy of the wt_gedcom_setting table. */
50    private $preferences = [];
51
52    /** @var string[][] Cached copy of the wt_user_gedcom_setting table. */
53    private $user_preferences = [];
54
55    /**
56     * Create a tree object. This is a private constructor - it can only
57     * be called from Tree::getAll() to ensure proper initialisation.
58     *
59     * @param int    $tree_id
60     * @param string $tree_name
61     * @param string $tree_title
62     */
63    private function __construct($tree_id, $tree_name, $tree_title)
64    {
65        $this->tree_id                 = $tree_id;
66        $this->name                    = $tree_name;
67        $this->title                   = $tree_title;
68        $this->fact_privacy            = [];
69        $this->individual_privacy      = [];
70        $this->individual_fact_privacy = [];
71
72        // Load the privacy settings for this tree
73        $rows = Database::prepare(
74            "SELECT xref, tag_type, CASE resn WHEN 'none' THEN :priv_public WHEN 'privacy' THEN :priv_user WHEN 'confidential' THEN :priv_none WHEN 'hidden' THEN :priv_hide END AS resn" .
75            " FROM `##default_resn` WHERE gedcom_id = :tree_id"
76        )->execute([
77            'priv_public' => Auth::PRIV_PRIVATE,
78            'priv_user'   => Auth::PRIV_USER,
79            'priv_none'   => Auth::PRIV_NONE,
80            'priv_hide'   => Auth::PRIV_HIDE,
81            'tree_id'     => $this->tree_id,
82        ])->fetchAll();
83
84        foreach ($rows as $row) {
85            if ($row->xref !== null) {
86                if ($row->tag_type !== null) {
87                    $this->individual_fact_privacy[$row->xref][$row->tag_type] = (int) $row->resn;
88                } else {
89                    $this->individual_privacy[$row->xref] = (int) $row->resn;
90                }
91            } else {
92                $this->fact_privacy[$row->tag_type] = (int) $row->resn;
93            }
94        }
95    }
96
97    /**
98     * The ID of this tree
99     *
100     * @return int
101     */
102    public function getTreeId()
103    {
104        return $this->tree_id;
105    }
106
107    /**
108     * The name of this tree
109     *
110     * @return string
111     */
112    public function getName()
113    {
114        return $this->name;
115    }
116
117    /**
118     * The title of this tree
119     *
120     * @return string
121     */
122    public function getTitle()
123    {
124        return $this->title;
125    }
126
127    /**
128     * The fact-level privacy for this tree.
129     *
130     * @return int[]
131     */
132    public function getFactPrivacy()
133    {
134        return $this->fact_privacy;
135    }
136
137    /**
138     * The individual-level privacy for this tree.
139     *
140     * @return int[]
141     */
142    public function getIndividualPrivacy()
143    {
144        return $this->individual_privacy;
145    }
146
147    /**
148     * The individual-fact-level privacy for this tree.
149     *
150     * @return int[][]
151     */
152    public function getIndividualFactPrivacy()
153    {
154        return $this->individual_fact_privacy;
155    }
156
157    /**
158     * Get the tree’s configuration settings.
159     *
160     * @param string $setting_name
161     * @param string $default
162     *
163     * @return string
164     */
165    public function getPreference(string $setting_name, string $default = ''): string
166    {
167        if (empty($this->preferences)) {
168            $this->preferences = Database::prepare(
169                "SELECT setting_name, setting_value FROM `##gedcom_setting` WHERE gedcom_id = ?"
170            )->execute([$this->tree_id])->fetchAssoc();
171        }
172
173        if (array_key_exists($setting_name, $this->preferences)) {
174            return $this->preferences[$setting_name];
175        } else {
176            return $default;
177        }
178    }
179
180    /**
181     * Set the tree’s configuration settings.
182     *
183     * @param string $setting_name
184     * @param string $setting_value
185     *
186     * @return $this
187     */
188    public function setPreference(string $setting_name, string $setting_value): Tree
189    {
190        if ($setting_value !== $this->getPreference($setting_name)) {
191            Database::prepare(
192                "REPLACE INTO `##gedcom_setting` (gedcom_id, setting_name, setting_value)" .
193                " VALUES (:tree_id, :setting_name, LEFT(:setting_value, 255))"
194            )->execute([
195                'tree_id'       => $this->tree_id,
196                'setting_name'  => $setting_name,
197                'setting_value' => $setting_value,
198            ]);
199
200            $this->preferences[$setting_name] = $setting_value;
201
202            Log::addConfigurationLog('Tree preference "' . $setting_name . '" set to "' . $setting_value . '"', $this);
203        }
204
205        return $this;
206    }
207
208    /**
209     * Get the tree’s user-configuration settings.
210     *
211     * @param User   $user
212     * @param string $setting_name
213     * @param string $default
214     *
215     * @return string
216     */
217    public function getUserPreference(User $user, string $setting_name, string $default = ''): string
218    {
219        // There are lots of settings, and we need to fetch lots of them on every page
220        // so it is quicker to fetch them all in one go.
221        if (!array_key_exists($user->getUserId(), $this->user_preferences)) {
222            $this->user_preferences[$user->getUserId()] = Database::prepare(
223                "SELECT setting_name, setting_value FROM `##user_gedcom_setting` WHERE user_id = ? AND gedcom_id = ?"
224            )->execute([
225                $user->getUserId(),
226                $this->tree_id,
227            ])->fetchAssoc();
228        }
229
230        if (array_key_exists($setting_name, $this->user_preferences[$user->getUserId()])) {
231            return $this->user_preferences[$user->getUserId()][$setting_name];
232        } else {
233            return $default;
234        }
235    }
236
237    /**
238     * Set the tree’s user-configuration settings.
239     *
240     * @param User   $user
241     * @param string $setting_name
242     * @param string $setting_value
243     *
244     * @return $this
245     */
246    public function setUserPreference(User $user, string $setting_name, string $setting_value): Tree
247    {
248        if ($this->getUserPreference($user, $setting_name) !== $setting_value) {
249            // Update the database
250            if ($setting_value === '') {
251                Database::prepare(
252                    "DELETE FROM `##user_gedcom_setting` WHERE gedcom_id = :tree_id AND user_id = :user_id AND setting_name = :setting_name"
253                )->execute([
254                    'tree_id'      => $this->tree_id,
255                    'user_id'      => $user->getUserId(),
256                    'setting_name' => $setting_name,
257                ]);
258            } else {
259                Database::prepare(
260                    "REPLACE INTO `##user_gedcom_setting` (user_id, gedcom_id, setting_name, setting_value) VALUES (:user_id, :tree_id, :setting_name, LEFT(:setting_value, 255))"
261                )->execute([
262                    'user_id'       => $user->getUserId(),
263                    'tree_id'       => $this->tree_id,
264                    'setting_name'  => $setting_name,
265                    'setting_value' => $setting_value,
266                ]);
267            }
268            // Update our cache
269            $this->user_preferences[$user->getUserId()][$setting_name] = $setting_value;
270            // Audit log of changes
271            Log::addConfigurationLog('Tree preference "' . $setting_name . '" set to "' . $setting_value . '" for user "' . $user->getUserName() . '"', $this);
272        }
273
274        return $this;
275    }
276
277    /**
278     * Can a user accept changes for this tree?
279     *
280     * @param User $user
281     *
282     * @return bool
283     */
284    public function canAcceptChanges(User $user): bool
285    {
286        return Auth::isModerator($this, $user);
287    }
288
289    /**
290     * Fetch all the trees that we have permission to access.
291     *
292     * @return Tree[]
293     */
294    public static function getAll(): array
295    {
296        if (empty(self::$trees)) {
297            $rows        = Database::prepare(
298                "SELECT g.gedcom_id AS tree_id, g.gedcom_name AS tree_name, gs1.setting_value AS tree_title" .
299                " FROM `##gedcom` g" .
300                " LEFT JOIN `##gedcom_setting`      gs1 ON (g.gedcom_id=gs1.gedcom_id AND gs1.setting_name='title')" .
301                " LEFT JOIN `##gedcom_setting`      gs2 ON (g.gedcom_id=gs2.gedcom_id AND gs2.setting_name='imported')" .
302                " LEFT JOIN `##gedcom_setting`      gs3 ON (g.gedcom_id=gs3.gedcom_id AND gs3.setting_name='REQUIRE_AUTHENTICATION')" .
303                " LEFT JOIN `##user_gedcom_setting` ugs ON (g.gedcom_id=ugs.gedcom_id AND ugs.setting_name='canedit' AND ugs.user_id=?)" .
304                " WHERE " .
305                "  g.gedcom_id>0 AND (" . // exclude the "template" tree
306                "    EXISTS (SELECT 1 FROM `##user_setting` WHERE user_id=? AND setting_name='canadmin' AND setting_value=1)" . // Admin sees all
307                "   ) OR (" .
308                "    (gs2.setting_value = 1 OR ugs.setting_value = 'admin') AND (" . // Allow imported trees, with either:
309                "     gs3.setting_value <> 1 OR" . // visitor access
310                "     IFNULL(ugs.setting_value, 'none')<>'none'" . // explicit access
311                "   )" .
312                "  )" .
313                " ORDER BY g.sort_order, 3"
314            )->execute([
315                Auth::id(),
316                Auth::id(),
317            ])->fetchAll();
318
319            foreach ($rows as $row) {
320                self::$trees[$row->tree_name] = new self((int) $row->tree_id, $row->tree_name, $row->tree_title);
321            }
322        }
323
324        return self::$trees;
325    }
326
327    /**
328     * Find the tree with a specific ID.
329     *
330     * @param int $tree_id
331     *
332     * @throws \DomainException
333     * @return Tree
334     */
335    public static function findById($tree_id): Tree
336    {
337        foreach (self::getAll() as $tree) {
338            if ($tree->tree_id == $tree_id) {
339                return $tree;
340            }
341        }
342        throw new \DomainException();
343    }
344
345    /**
346     * Find the tree with a specific name.
347     *
348     * @param string $tree_name
349     *
350     * @return Tree|null
351     */
352    public static function findByName($tree_name)
353    {
354        foreach (self::getAll() as $tree) {
355            if ($tree->name === $tree_name) {
356                return $tree;
357            }
358        }
359
360        return null;
361    }
362
363    /**
364     * Create arguments to select_edit_control()
365     * Note - these will be escaped later
366     *
367     * @return string[]
368     */
369    public static function getIdList(): array
370    {
371        $list = [];
372        foreach (self::getAll() as $tree) {
373            $list[$tree->tree_id] = $tree->title;
374        }
375
376        return $list;
377    }
378
379    /**
380     * Create arguments to select_edit_control()
381     * Note - these will be escaped later
382     *
383     * @return string[]
384     */
385    public static function getNameList(): array
386    {
387        $list = [];
388        foreach (self::getAll() as $tree) {
389            $list[$tree->name] = $tree->title;
390        }
391
392        return $list;
393    }
394
395    /**
396     * Create a new tree
397     *
398     * @param string $tree_name
399     * @param string $tree_title
400     *
401     * @return Tree
402     */
403    public static function create(string $tree_name, string $tree_title): Tree
404    {
405        try {
406            // Create a new tree
407            Database::prepare(
408                "INSERT INTO `##gedcom` (gedcom_name) VALUES (?)"
409            )->execute([$tree_name]);
410            $tree_id = Database::prepare("SELECT LAST_INSERT_ID()")->fetchOne();
411        } catch (PDOException $ex) {
412            DebugBar::addThrowable($ex);
413
414            // A tree with that name already exists?
415            return self::findByName($tree_name);
416        }
417
418        // Update the list of trees - to include this new one
419        self::$trees = [];
420        $tree        = self::findById($tree_id);
421
422        $tree->setPreference('imported', '0');
423        $tree->setPreference('title', $tree_title);
424
425        // Module privacy
426        Module::setDefaultAccess($tree_id);
427
428        // Set preferences from default tree
429        Database::prepare(
430            "INSERT INTO `##gedcom_setting` (gedcom_id, setting_name, setting_value)" .
431            " SELECT :tree_id, setting_name, setting_value" .
432            " FROM `##gedcom_setting` WHERE gedcom_id = -1"
433        )->execute([
434            'tree_id' => $tree_id,
435        ]);
436
437        Database::prepare(
438            "INSERT INTO `##default_resn` (gedcom_id, tag_type, resn)" .
439            " SELECT :tree_id, tag_type, resn" .
440            " FROM `##default_resn` WHERE gedcom_id = -1"
441        )->execute([
442            'tree_id' => $tree_id,
443        ]);
444
445        Database::prepare(
446            "INSERT INTO `##block` (gedcom_id, location, block_order, module_name)" .
447            " SELECT :tree_id, location, block_order, module_name" .
448            " FROM `##block` WHERE gedcom_id = -1"
449        )->execute([
450            'tree_id' => $tree_id,
451        ]);
452
453        // Gedcom and privacy settings
454        $tree->setPreference('CONTACT_USER_ID', Auth::id());
455        $tree->setPreference('WEBMASTER_USER_ID', Auth::id());
456        $tree->setPreference('LANGUAGE', WT_LOCALE); // Default to the current admin’s language
457        switch (WT_LOCALE) {
458            case 'es':
459                $tree->setPreference('SURNAME_TRADITION', 'spanish');
460                break;
461            case 'is':
462                $tree->setPreference('SURNAME_TRADITION', 'icelandic');
463                break;
464            case 'lt':
465                $tree->setPreference('SURNAME_TRADITION', 'lithuanian');
466                break;
467            case 'pl':
468                $tree->setPreference('SURNAME_TRADITION', 'polish');
469                break;
470            case 'pt':
471            case 'pt-BR':
472                $tree->setPreference('SURNAME_TRADITION', 'portuguese');
473                break;
474            default:
475                $tree->setPreference('SURNAME_TRADITION', 'paternal');
476                break;
477        }
478
479        // Genealogy data
480        // It is simpler to create a temporary/unimported GEDCOM than to populate all the tables...
481        /* I18N: This should be a common/default/placeholder name of an individual. Put slashes around the surname. */
482        $john_doe = I18N::translate('John /DOE/');
483        $note     = I18N::translate('Edit this individual and replace their details with your own.');
484        Database::prepare("INSERT INTO `##gedcom_chunk` (gedcom_id, chunk_data) VALUES (?, ?)")->execute([
485            $tree_id,
486            "0 HEAD\n1 CHAR UTF-8\n0 @I1@ INDI\n1 NAME {$john_doe}\n1 SEX M\n1 BIRT\n2 DATE 01 JAN 1850\n2 NOTE {$note}\n0 TRLR\n",
487        ]);
488
489        // Update our cache
490        self::$trees[$tree->tree_id] = $tree;
491
492        return $tree;
493    }
494
495    /**
496     * Are there any pending edits for this tree, than need reviewing by a moderator.
497     *
498     * @return bool
499     */
500    public function hasPendingEdit(): bool
501    {
502        return (bool) Database::prepare(
503            "SELECT 1 FROM `##change` WHERE status = 'pending' AND gedcom_id = :tree_id"
504        )->execute([
505            'tree_id' => $this->tree_id,
506        ])->fetchOne();
507    }
508
509    /**
510     * Delete all the genealogy data from a tree - in preparation for importing
511     * new data. Optionally retain the media data, for when the user has been
512     * editing their data offline using an application which deletes (or does not
513     * support) media data.
514     *
515     * @param bool $keep_media
516     *
517     * @return void
518     */
519    public function deleteGenealogyData(bool $keep_media)
520    {
521        Database::prepare("DELETE FROM `##gedcom_chunk` WHERE gedcom_id = ?")->execute([$this->tree_id]);
522        Database::prepare("DELETE FROM `##individuals`  WHERE i_file    = ?")->execute([$this->tree_id]);
523        Database::prepare("DELETE FROM `##families`     WHERE f_file    = ?")->execute([$this->tree_id]);
524        Database::prepare("DELETE FROM `##sources`      WHERE s_file    = ?")->execute([$this->tree_id]);
525        Database::prepare("DELETE FROM `##other`        WHERE o_file    = ?")->execute([$this->tree_id]);
526        Database::prepare("DELETE FROM `##places`       WHERE p_file    = ?")->execute([$this->tree_id]);
527        Database::prepare("DELETE FROM `##placelinks`   WHERE pl_file   = ?")->execute([$this->tree_id]);
528        Database::prepare("DELETE FROM `##name`         WHERE n_file    = ?")->execute([$this->tree_id]);
529        Database::prepare("DELETE FROM `##dates`        WHERE d_file    = ?")->execute([$this->tree_id]);
530        Database::prepare("DELETE FROM `##change`       WHERE gedcom_id = ?")->execute([$this->tree_id]);
531
532        if ($keep_media) {
533            Database::prepare("DELETE FROM `##link` WHERE l_file =? AND l_type<>'OBJE'")->execute([$this->tree_id]);
534        } else {
535            Database::prepare("DELETE FROM `##link`  WHERE l_file =?")->execute([$this->tree_id]);
536            Database::prepare("DELETE FROM `##media` WHERE m_file =?")->execute([$this->tree_id]);
537            Database::prepare("DELETE FROM `##media_file` WHERE m_file =?")->execute([$this->tree_id]);
538        }
539    }
540
541    /**
542     * Delete everything relating to a tree
543     *
544     * @return void
545     */
546    public function delete()
547    {
548        // If this is the default tree, then unset it
549        if (Site::getPreference('DEFAULT_GEDCOM') === $this->name) {
550            Site::setPreference('DEFAULT_GEDCOM', '');
551        }
552
553        $this->deleteGenealogyData(false);
554
555        Database::prepare("DELETE `##block_setting` FROM `##block_setting` JOIN `##block` USING (block_id) WHERE gedcom_id=?")->execute([$this->tree_id]);
556        Database::prepare("DELETE FROM `##block`               WHERE gedcom_id = ?")->execute([$this->tree_id]);
557        Database::prepare("DELETE FROM `##user_gedcom_setting` WHERE gedcom_id = ?")->execute([$this->tree_id]);
558        Database::prepare("DELETE FROM `##gedcom_setting`      WHERE gedcom_id = ?")->execute([$this->tree_id]);
559        Database::prepare("DELETE FROM `##module_privacy`      WHERE gedcom_id = ?")->execute([$this->tree_id]);
560        Database::prepare("DELETE FROM `##hit_counter`         WHERE gedcom_id = ?")->execute([$this->tree_id]);
561        Database::prepare("DELETE FROM `##default_resn`        WHERE gedcom_id = ?")->execute([$this->tree_id]);
562        Database::prepare("DELETE FROM `##gedcom_chunk`        WHERE gedcom_id = ?")->execute([$this->tree_id]);
563        Database::prepare("DELETE FROM `##log`                 WHERE gedcom_id = ?")->execute([$this->tree_id]);
564        Database::prepare("DELETE FROM `##gedcom`              WHERE gedcom_id = ?")->execute([$this->tree_id]);
565
566        // After updating the database, we need to fetch a new (sorted) copy
567        self::$trees = [];
568    }
569
570    /**
571     * Export the tree to a GEDCOM file
572     *
573     * @param resource $stream
574     *
575     * @return void
576     */
577    public function exportGedcom($stream)
578    {
579        $stmt = Database::prepare(
580            "SELECT i_gedcom AS gedcom, i_id AS xref, 1 AS n FROM `##individuals` WHERE i_file = :tree_id_1" .
581            " UNION ALL " .
582            "SELECT f_gedcom AS gedcom, f_id AS xref, 2 AS n FROM `##families`    WHERE f_file = :tree_id_2" .
583            " UNION ALL " .
584            "SELECT s_gedcom AS gedcom, s_id AS xref, 3 AS n FROM `##sources`     WHERE s_file = :tree_id_3" .
585            " UNION ALL " .
586            "SELECT o_gedcom AS gedcom, o_id AS xref, 4 AS n FROM `##other`       WHERE o_file = :tree_id_4 AND o_type NOT IN ('HEAD', 'TRLR')" .
587            " UNION ALL " .
588            "SELECT m_gedcom AS gedcom, m_id AS xref, 5 AS n FROM `##media`       WHERE m_file = :tree_id_5" .
589            " ORDER BY n, LENGTH(xref), xref"
590        )->execute([
591            'tree_id_1' => $this->tree_id,
592            'tree_id_2' => $this->tree_id,
593            'tree_id_3' => $this->tree_id,
594            'tree_id_4' => $this->tree_id,
595            'tree_id_5' => $this->tree_id,
596        ]);
597
598        $buffer = FunctionsExport::reformatRecord(FunctionsExport::gedcomHeader($this));
599        while (($row = $stmt->fetch()) !== false) {
600            $buffer .= FunctionsExport::reformatRecord($row->gedcom);
601            if (strlen($buffer) > 65535) {
602                fwrite($stream, $buffer);
603                $buffer = '';
604            }
605        }
606        fwrite($stream, $buffer . '0 TRLR' . Gedcom::EOL);
607        $stmt->closeCursor();
608    }
609
610    /**
611     * Import data from a gedcom file into this tree.
612     *
613     * @param string $path     The full path to the (possibly temporary) file.
614     * @param string $filename The preferred filename, for export/download.
615     *
616     * @return void
617     * @throws Exception
618     */
619    public function importGedcomFile(string $path, string $filename)
620    {
621        // Read the file in blocks of roughly 64K. Ensure that each block
622        // contains complete gedcom records. This will ensure we don’t split
623        // multi-byte characters, as well as simplifying the code to import
624        // each block.
625
626        $file_data = '';
627        $fp        = fopen($path, 'rb');
628
629        // Don’t allow the user to cancel the request. We do not want to be left with an incomplete transaction.
630        ignore_user_abort(true);
631
632        $this->deleteGenealogyData((bool) $this->getPreference('keep_media'));
633        $this->setPreference('gedcom_filename', $filename);
634        $this->setPreference('imported', '0');
635
636        while (!feof($fp)) {
637            $file_data .= fread($fp, 65536);
638            // There is no strrpos() function that searches for substrings :-(
639            for ($pos = strlen($file_data) - 1; $pos > 0; --$pos) {
640                if ($file_data[$pos] === '0' && ($file_data[$pos - 1] === "\n" || $file_data[$pos - 1] === "\r")) {
641                    // We’ve found the last record boundary in this chunk of data
642                    break;
643                }
644            }
645            if ($pos) {
646                Database::prepare(
647                    "INSERT INTO `##gedcom_chunk` (gedcom_id, chunk_data) VALUES (?, ?)"
648                )->execute([
649                    $this->tree_id,
650                    substr($file_data, 0, $pos),
651                ]);
652                $file_data = substr($file_data, $pos);
653            }
654        }
655        Database::prepare(
656            "INSERT INTO `##gedcom_chunk` (gedcom_id, chunk_data) VALUES (?, ?)"
657        )->execute([
658            $this->tree_id,
659            $file_data,
660        ]);
661
662        fclose($fp);
663    }
664
665    /**
666     * Generate a new XREF, unique across all family trees
667     *
668     * @return string
669     */
670    public function getNewXref(): string
671    {
672        $prefix = 'X';
673
674        $increment = 1.0;
675        do {
676            // Use LAST_INSERT_ID(expr) to provide a transaction-safe sequence. See
677            // http://dev.mysql.com/doc/refman/5.6/en/information-functions.html#function_last-insert-id
678            $statement = Database::prepare(
679                "UPDATE `##site_setting` SET setting_value = LAST_INSERT_ID(setting_value + :increment) WHERE setting_name = 'next_xref'"
680            );
681            $statement->execute([
682                'increment' => (int) $increment,
683            ]);
684
685            if ($statement->rowCount() === 0) {
686                // First time we've used this record type.
687                Site::setPreference('next_xref', '1');
688                $num = 1;
689            } else {
690                $num = Database::prepare("SELECT LAST_INSERT_ID()")->fetchOne();
691            }
692
693            $xref = $prefix . $num;
694
695            // Records may already exist with this sequence number.
696            $already_used = Database::prepare(
697                "SELECT" .
698                " EXISTS (SELECT 1 FROM `##individuals` WHERE i_id = :i_id) OR" .
699                " EXISTS (SELECT 1 FROM `##families` WHERE f_id = :f_id) OR" .
700                " EXISTS (SELECT 1 FROM `##sources` WHERE s_id = :s_id) OR" .
701                " EXISTS (SELECT 1 FROM `##media` WHERE m_id = :m_id) OR" .
702                " EXISTS (SELECT 1 FROM `##other` WHERE o_id = :o_id) OR" .
703                " EXISTS (SELECT 1 FROM `##change` WHERE xref = :xref)"
704            )->execute([
705                'i_id' => $xref,
706                'f_id' => $xref,
707                's_id' => $xref,
708                'm_id' => $xref,
709                'o_id' => $xref,
710                'xref' => $xref,
711            ])->fetchOne();
712
713            // This exponential increment allows us to scan over large blocks of
714            // existing data in a reasonable time.
715            $increment *= 1.01;
716        } while ($already_used !== '0');
717
718        return $xref;
719    }
720
721    /**
722     * Create a new record from GEDCOM data.
723     *
724     * @param string $gedcom
725     *
726     * @return GedcomRecord|Individual|Family|Note|Source|Repository|Media
727     * @throws Exception
728     */
729    public function createRecord(string $gedcom): GedcomRecord
730    {
731        if (preg_match('/^0 @(' . WT_REGEX_XREF . ')@ (' . WT_REGEX_TAG . ')/', $gedcom, $match)) {
732            $xref = $match[1];
733            $type = $match[2];
734        } else {
735            throw new Exception('Invalid argument to GedcomRecord::createRecord(' . $gedcom . ')');
736        }
737        if (strpos($gedcom, "\r") !== false) {
738            // MSDOS line endings will break things in horrible ways
739            throw new Exception('Evil line endings found in GedcomRecord::createRecord(' . $gedcom . ')');
740        }
741
742        // webtrees creates XREFs containing digits. Anything else (e.g. “new”) is just a placeholder.
743        if (!preg_match('/\d/', $xref)) {
744            $xref   = $this->getNewXref();
745            $gedcom = preg_replace('/^0 @(' . WT_REGEX_XREF . ')@/', '0 @' . $xref . '@', $gedcom);
746        }
747
748        // Create a change record, if not already present
749        if (!preg_match('/\n1 CHAN/', $gedcom)) {
750            $gedcom .= "\n1 CHAN\n2 DATE " . date('d M Y') . "\n3 TIME " . date('H:i:s') . "\n2 _WT_USER " . Auth::user()->getUserName();
751        }
752
753        // Create a pending change
754        Database::prepare(
755            "INSERT INTO `##change` (gedcom_id, xref, old_gedcom, new_gedcom, user_id) VALUES (?, ?, '', ?, ?)"
756        )->execute([
757            $this->tree_id,
758            $xref,
759            $gedcom,
760            Auth::id(),
761        ]);
762
763        Log::addEditLog('Create: ' . $type . ' ' . $xref, $this);
764
765        // Accept this pending change
766        if (Auth::user()->getPreference('auto_accept')) {
767            FunctionsImport::acceptAllChanges($xref, $this);
768        }
769        // Return the newly created record. Note that since GedcomRecord
770        // has a cache of pending changes, we cannot use it to create a
771        // record with a newly created pending change.
772        return GedcomRecord::getInstance($xref, $this, $gedcom);
773    }
774
775    /**
776     * What is the most significant individual in this tree.
777     *
778     * @param User $user
779     *
780     * @return Individual
781     */
782    public function significantIndividual(User $user): Individual
783    {
784        static $individual; // Only query the DB once.
785
786        if (!$individual && $this->getUserPreference($user, 'rootid') !== '') {
787            $individual = Individual::getInstance($this->getUserPreference($user, 'rootid'), $this);
788        }
789        if (!$individual && $this->getUserPreference($user, 'gedcomid') !== '') {
790            $individual = Individual::getInstance($this->getUserPreference($user, 'gedcomid'), $this);
791        }
792        if (!$individual) {
793            $individual = Individual::getInstance($this->getPreference('PEDIGREE_ROOT_ID'), $this);
794        }
795        if (!$individual) {
796            $individual = Individual::getInstance(
797                Database::prepare(
798                    "SELECT MIN(i_id) FROM `##individuals` WHERE i_file = :tree_id"
799                )->execute([
800                    'tree_id' => $this->getTreeId(),
801                ])->fetchOne(),
802                $this
803            );
804        }
805        if (!$individual) {
806            // always return a record
807            $individual = new Individual('I', '0 @I@ INDI', null, $this);
808        }
809
810        return $individual;
811    }
812
813    /**
814     * Get significant information from this page, to allow other pages such as
815     * charts and reports to initialise with the same records
816     *
817     * @return Individual
818     */
819    public function getSignificantIndividual(): Individual
820    {
821        static $individual; // Only query the DB once.
822
823        if (!$individual && $this->getUserPreference(Auth::user(), 'rootid') !== '') {
824            $individual = Individual::getInstance($this->getUserPreference(Auth::user(), 'rootid'), $this);
825        }
826        if (!$individual && $this->getUserPreference(Auth::user(), 'gedcomid') !== '') {
827            $individual = Individual::getInstance($this->getUserPreference(Auth::user(), 'gedcomid'), $this);
828        }
829        if (!$individual) {
830            $individual = Individual::getInstance($this->getPreference('PEDIGREE_ROOT_ID'), $this);
831        }
832        if (!$individual) {
833            $individual = Individual::getInstance(
834                Database::prepare(
835                    "SELECT MIN(i_id) FROM `##individuals` WHERE i_file = ?"
836                )->execute([$this->getTreeId()])->fetchOne(),
837                $this
838            );
839        }
840        if (!$individual) {
841            // always return a record
842            $individual = new Individual('I', '0 @I@ INDI', null, $this);
843        }
844
845        return $individual;
846    }
847}
848