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
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
|
<?php
/**
* Phase 2: Import KitlockerAssemblies.csv under their KitLocker group assemblies.
*
* CSV columns: Title, KLID, Data, KLSGL, KL3M, Group
* Group is numeric — 'G' is prepended to match the KLID xref stored by
* load_kitlocker_groups.php.
*
* Existing assemblies are matched by KLID xref so the title can be updated to
* a tidier version. Old kitlocker xrefs are wiped and replaced on each run.
*
* Run load_kitlocker_groups.php first.
*
* @package stock
*/
namespace Bitweaver\Stock;
require_once '../../kernel/includes/setup_inc.php';
global $gBitSystem, $gBitSmarty, $gBitDb;
$gBitSystem->verifyPackage( 'stock' );
$gBitSystem->verifyPermission( 'p_stock_admin' );
require_once STOCK_PKG_CLASS_PATH.'StockAssembly.php';
$csvFile = __DIR__.'/data/KitlockerAssemblies.csv';
$loaded = $skipped = $updated = 0;
$errors = [];
// KLID → content_id map for group assemblies (G1, G2, …)
$klidMap = $gBitDb->getAssoc(
"SELECT lx.xkey, lx.content_id FROM `".BIT_DB_PREFIX."liberty_xref` lx
INNER JOIN `".BIT_DB_PREFIX."liberty_content` lc ON lc.content_id=lx.content_id
WHERE lx.item=? AND lc.content_type_guid=?",
[ 'KLID', STOCKASSEMBLY_CONTENT_TYPE_GUID ]
);
$kitlockerXrefItems = [ 'KLID', 'KLPR', 'KLSGL', 'KL3M', 'KLURL', 'KLSGL' ];
if( empty( $klidMap ) ) {
$errors[] = 'No KLID xref entries found — run load_kitlocker_groups.php first.';
} elseif( !file_exists( $csvFile ) ) {
$errors[] = "File not found: $csvFile";
} else {
$fh = fopen( $csvFile, 'r' );
$rowNum = 0;
while( ($cols = fgetcsv( $fh, 0, ',', '"', '' )) !== false ) {
$rowNum++;
if( $rowNum === 1 ) continue; // header: Title, KLID, Data, KLSGL, KL3M, Group
$title = trim( $cols[0] ?? '' );
$klid = trim( $cols[1] ?? '' );
$data = trim( $cols[2] ?? '' );
$klsgl = trim( $cols[3] ?? '' );
$kl3m = trim( $cols[4] ?? '' );
$groupNum = trim( $cols[5] ?? '' );
$groupKey = 'G'.$groupNum;
if( $title === '' || $klid === '' || $groupNum === '' ) {
$skipped++;
continue;
}
if( !isset( $klidMap[$groupKey] ) ) {
$errors[] = "Row $rowNum: '$title' — group '$groupKey' not in KLID map, skipped.";
$skipped++;
continue;
}
$groupContentId = (int)$klidMap[$groupKey];
$contentId = 0;
if( $title === $klid ) {
// Title unchanged — find by KLID xref, fall back to title if xref not yet stored
$contentId = (int)$gBitDb->getOne(
"SELECT lx.content_id FROM `".BIT_DB_PREFIX."liberty_xref` lx
INNER JOIN `".BIT_DB_PREFIX."liberty_content` lc ON lc.content_id=lx.content_id
WHERE lx.item=? AND lx.xkey=? AND lc.content_type_guid=?",
[ 'KLID', $klid, STOCKASSEMBLY_CONTENT_TYPE_GUID ]
);
if( !$contentId ) {
$contentId = (int)$gBitDb->getOne(
"SELECT lc.content_id FROM `".BIT_DB_PREFIX."liberty_content` lc
WHERE lc.content_type_guid=? AND lc.title=?",
[ STOCKASSEMBLY_CONTENT_TYPE_GUID, $title ]
);
}
} else {
// Title is a tidier replacement for the old title (= col1/KLID).
// Find the keeper by new title; find the old stale record by old title.
$contentId = (int)$gBitDb->getOne(
"SELECT lc.content_id FROM `".BIT_DB_PREFIX."liberty_content` lc
WHERE lc.content_type_guid=? AND lc.title=?",
[ STOCKASSEMBLY_CONTENT_TYPE_GUID, $title ]
);
$oldContentId = (int)$gBitDb->getOne(
"SELECT lc.content_id FROM `".BIT_DB_PREFIX."liberty_content` lc
WHERE lc.content_type_guid=? AND lc.title=?",
[ STOCKASSEMBLY_CONTENT_TYPE_GUID, $klid ]
);
if( $contentId && $oldContentId && $oldContentId !== $contentId ) {
// Both exist — expunge the stale col1 record
$stale = new StockAssembly( null, $oldContentId );
$stale->load();
$stale->expunge();
} elseif( !$contentId && $oldContentId ) {
// Only old record exists — rename it to the tidy title
$contentId = $oldContentId;
}
}
if( $contentId ) {
// Update title/description and wipe old kitlocker xrefs
$assembly = new StockAssembly( null, $contentId );
$assembly->load();
$pHash = [ 'content_id' => $contentId, 'title' => $title, 'edit' => $data, 'format_guid' => 'bithtml' ];
$assembly->store( $pHash );
$gBitDb->query(
"DELETE FROM `".BIT_DB_PREFIX."liberty_xref`
WHERE content_id=? AND item IN ('KLID','KLPR','KLSGL','KL3M','KLURL')",
[ $contentId ]
);
$updated++;
} else {
// No existing record — create fresh
$assembly = new StockAssembly();
$pHash = [ 'title' => $title, 'edit' => $data, 'format_guid' => 'bithtml' ];
if( !$assembly->store( $pHash ) ) {
$errors[] = "Row $rowNum: failed to create '$title'";
$skipped++;
continue;
}
$contentId = $assembly->mContentId;
$loaded++;
}
// Ensure parent group link exists
$alreadyLinked = (int)$gBitDb->getOne(
"SELECT COUNT(*) FROM `".BIT_DB_PREFIX."stock_assembly_map`
WHERE assembly_content_id=? AND item_content_id=?",
[ $groupContentId, $contentId ]
);
if( !$alreadyLinked ) {
$gBitDb->query(
"INSERT INTO `".BIT_DB_PREFIX."stock_assembly_map`
(assembly_content_id, item_content_id, item_position) VALUES (?,?,NULL)",
[ $groupContentId, $contentId ]
);
}
// Store kitlocker xrefs
foreach( [ 'KLID' => $klid, 'KLSGL' => $klsgl, 'KL3M' => $kl3m ] as $item => $value ) {
if( $value !== '' ) {
$xrefId = $gBitDb->GenID( 'liberty_xref_seq' );
$gBitDb->associateInsert( BIT_DB_PREFIX.'liberty_xref', [
'xref_id' => $xrefId,
'content_id' => $contentId,
'item' => $item,
'xorder' => 0,
'xkey' => $value,
'last_update_date' => $gBitDb->NOW(),
] );
}
}
// Keep contentId in klidMap for subsequent lookups within this run
$klidMap[$klid] = $contentId;
}
fclose( $fh );
}
$gBitSmarty->assign( 'loaded', $loaded );
$gBitSmarty->assign( 'skipped', $skipped );
$gBitSmarty->assign( 'deleted', $updated );
$gBitSmarty->assign( 'errors', $errors );
$gBitSmarty->assign( 'csvFile', $csvFile );
$gBitSmarty->assign( 'movement', null );
$gBitSystem->display( 'bitpackage:stock/import_results.tpl', 'Import KitLocker Assemblies' );
|
