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
|
<?php
/**
* Kitlocker assemblies/components CSV importer.
*
* CSV column layout (0-based, header row skipped by loader):
* 0 Title MERG product code / designation (used as lc.title)
* 1 KLID Kitlocker numeric ID code (stored as KLID xref on both types)
* 2 Description Long description (stored as content body)
* 3 KLSGL Kitlocker single-unit stock count (stored as KLSGL xref on both types)
* 4 KL3M 3-month sales count (stored as KL3M xref on both types)
* 5 Group Group number 1–99 → KLG01–KLG99 stgrp xref (both types)
* 6 Type 'A' = StockAssembly, 'C' = StockComponent
*
* On reload, existing records are not re-created but their kitlocker xrefs are upserted,
* so a fresh import run will tag components that were previously missing KLID etc.
*
* @package stock
*/
use Bitweaver\Stock\StockAssembly;
use Bitweaver\Stock\StockComponent;
function stockKitlockerXrefUpsert( int $contentId, string $item, string $value ): void {
global $gBitDb;
$existingId = $gBitDb->getOne(
"SELECT `xref_id` FROM `".BIT_DB_PREFIX."liberty_xref`
WHERE `content_id` = ? AND `item` = ?",
[ $contentId, $item ]
);
if( $existingId ) {
$gBitDb->associateUpdate(
BIT_DB_PREFIX.'liberty_xref',
[ 'xkey' => substr( $value, 0, 32 ), 'last_update_date' => $gBitDb->NOW() ],
[ 'xref_id' => $existingId ]
);
} else {
$gBitDb->associateInsert( BIT_DB_PREFIX.'liberty_xref', [
'xref_id' => $gBitDb->GenID( 'liberty_xref_seq' ),
'content_id' => $contentId,
'item' => $item,
'xkey' => substr( $value, 0, 32 ),
'xorder' => 0,
'last_update_date' => $gBitDb->NOW(),
] );
}
}
function stockExpungeKitlockerItemByTitle( string $title, string $type ): bool {
global $gBitDb;
$guid = ( $type === 'A' ) ? 'stockassembly' : 'stockcomponent';
$contentId = $gBitDb->getOne(
"SELECT lc.`content_id` FROM `".BIT_DB_PREFIX."liberty_content` lc
WHERE lc.`content_type_guid` = ? AND lc.`title` = ?",
[ $guid, $title ]
);
if( !$contentId ) {
return false;
}
$obj = ( $type === 'A' ) ? new StockAssembly( (int)$contentId ) : new StockComponent( (int)$contentId );
$obj->expunge();
return true;
}
function stockImportKitlockerItem( array $data, int $rowNum ): array {
global $gBitDb;
$result = [ 'loaded' => 0, 'skipped' => 0, 'errors' => [] ];
$title = trim( $data[0] ?? '' );
if( empty( $title ) ) {
$result['skipped']++;
return $result;
}
$type = strtoupper( trim( $data[6] ?? '' ) );
if( !in_array( $type, [ 'A', 'C' ] ) ) {
$result['skipped']++;
$result['errors'][] = "Row $rowNum: '$title' — unknown type '$type', skipped.";
return $result;
}
$guid = ( $type === 'A' ) ? 'stockassembly' : 'stockcomponent';
$klid = trim( $data[1] ?? '' );
$desc = trim( $data[2] ?? '' );
$klsgl = trim( $data[3] ?? '' );
$kl3m = trim( $data[4] ?? '' );
$group = (int)( $data[5] ?? 0 );
$contentId = (int)$gBitDb->getOne(
"SELECT lc.`content_id` FROM `".BIT_DB_PREFIX."liberty_content` lc
WHERE lc.`content_type_guid` = ? AND lc.`title` = ?",
[ $guid, $title ]
);
if( !$contentId ) {
$obj = ( $type === 'A' ) ? new StockAssembly() : new StockComponent();
$pHash = [
'title' => $title,
'edit' => $desc,
'format_guid' => 'bithtml',
];
if( !$obj->store( $pHash ) ) {
$result['skipped']++;
$result['errors'][] = "Row $rowNum: failed to store '$title'.";
return $result;
}
$contentId = $obj->mContentId;
}
// Group tag — both types
if( $group >= 1 && $group <= 99 ) {
stockKitlockerXrefUpsert( $contentId, sprintf( 'KLG%02d', $group ), '' );
}
// Kitlocker xrefs — same set for assemblies and components
foreach( [ 'KLID' => $klid, 'KLSGL' => $klsgl, 'KL3M' => $kl3m ] as $item => $value ) {
if( $value !== '' ) {
stockKitlockerXrefUpsert( $contentId, $item, $value );
}
}
$result['loaded']++;
return $result;
}
|
