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
|
<?php
/**
* Contact CSV importer — matches the export_contacts.php column layout.
*
* CSV column layout (0-based, header row skipped by loader):
* 0 title Contact name — match key (lc.title)
* 1 type xref item code: $00 (person), $01–$05 (business types)
* 2 person_name Pipe-separated name for $00: prefix|forename|surname|suffix
* 3 scref SCREF xkey (stock source reference / short code)
* 4 phone #P xkey
* 5 address #C xkey_ext (full address text)
* 6 postcode #C xkey
* 7 fax #F xkey
* 8 website #W xkey_ext (URLs exceed xkey C(32))
* 9 email #E xkey_ext (addresses exceed xkey C(32))
* 10 accno ACCNO xkey
*
* Existing contacts (matched by title) are updated in place.
* New contacts are created via Contact::store() — liberty handles all required fields.
*
* @package contact
*/
namespace Bitweaver\Liberty;
use Bitweaver\Contact\Contact;
function contactCsvUpsertXref( int $contentId, string $item, string $xkey = '', string $xkeyExt = '', int $xorder = 0 ): void {
global $gBitDb;
$gBitDb->query(
"DELETE FROM `" . BIT_DB_PREFIX . "liberty_xref` WHERE `content_id` = ? AND `item` = ?",
[ $contentId, $item ]
);
if( $xkey !== '' || $xkeyExt !== '' ) {
$gBitDb->associateInsert( BIT_DB_PREFIX . 'liberty_xref', [
'xref_id' => $gBitDb->GenID( 'liberty_xref_seq' ),
'content_id' => $contentId,
'item' => $item,
'xorder' => $xorder,
'xkey' => $xkey !== '' ? substr( $xkey, 0, 32 ) : null,
'xkey_ext' => $xkeyExt !== '' ? substr( $xkeyExt, 0, 250 ) : null,
'last_update_date' => $gBitDb->NOW(),
] );
}
}
function contactCsvImportRow( array $row, int $rowNum ): array {
global $gBitDb;
$result = [ 'loaded' => 0, 'updated' => 0, 'skipped' => 0, 'errors' => [] ];
$title = trim( $row[0] ?? '' );
$type = trim( $row[1] ?? '' );
$personName = trim( $row[2] ?? '' );
$scref = trim( $row[3] ?? '' );
$phone = trim( $row[4] ?? '' );
// Restore leading zero stripped by Excel on 10-digit UK numbers
if( strlen( $phone ) === 10 && ctype_digit( $phone ) ) {
$phone = '0' . $phone;
}
$address = trim( $row[5] ?? '' );
$postcode = trim( $row[6] ?? '' );
$fax = trim( $row[7] ?? '' );
if( strlen( $fax ) === 10 && ctype_digit( $fax ) ) {
$fax = '0' . $fax;
}
$website = trim( $row[8] ?? '' );
$email = trim( $row[9] ?? '' );
$accno = trim( $row[10] ?? '' );
if( empty( $title ) ) {
$result['skipped']++;
return $result;
}
// --- Find existing or create new via Contact class ---
$contentId = $gBitDb->getOne(
"SELECT `content_id` FROM `" . BIT_DB_PREFIX . "liberty_content`
WHERE `content_type_guid` = 'contact' AND `title` = ?",
[ $title ]
);
$contact = new Contact( null, $contentId ?: null );
if( $contentId ) {
$contact->load();
}
$pHash = [
'title' => $title,
'edit' => '',
'format_guid' => 'bithtml',
];
if( $contentId ) {
$pHash['content_id'] = $contentId;
}
if( !empty( $type ) && $type[0] === '$' ) {
$pHash['contact_types'] = [ $type ];
if( $type === '$00' ) {
$pHash['name'] = $personName;
}
}
if( !$contact->store( $pHash ) ) {
$result['skipped']++;
$result['errors'][] = "Row $rowNum: failed to store '$title': " . implode( ', ', $contact->mErrors ?? [] );
return $result;
}
$contentId ? $result['updated']++ : $result['loaded']++;
$contentId = $contact->mContentId;
// --- Remaining xref items ---
contactCsvUpsertXref( $contentId, 'SCREF', $scref );
contactCsvUpsertXref( $contentId, '#P', $phone, '', 1 );
contactCsvUpsertXref( $contentId, '#C', $postcode, $address );
contactCsvUpsertXref( $contentId, '#F', $fax, '', 1 );
contactCsvUpsertXref( $contentId, '#W', '', $website );
contactCsvUpsertXref( $contentId, '#E', '', $email );
contactCsvUpsertXref( $contentId, 'ACCNO', $accno );
return $result;
}
|
