PHP: полный мануал с примерами, функциями и ООП

<?php
declare(strict_types=1);
use MongoDB\BSON\{Document,PackedArray};
use MongoDB\Driver\{Manager,BulkWrite};
require __DIR__.'/s136-helper.php';
[$rows,$checks,$runtime,$counts]=s136Lab(static function(Manager $manager,string $db,string $ns): array {
    $written=s136Write($manager,$ns,[s136Manifests()[0]]);
    $shipment=s136Read($manager,$ns,['_id'=>'A'])[0];
    $items=$shipment->get('items');
    $iterator=$items->getIterator();
    $rows=[];
    $total=0;
    foreach ($iterator as $index=>$line) {
        $qty=$line->get('qty');
        $rows[]=['Позиция '.($index+1),$line->get('sku').' × '.$qty];
        $total+=$qty;
    }
    $rows[]=['На склад, единиц',$total];
    $checks=['stored_one'=>$written===1,'raw_document'=>$shipment instanceof Document,'list_container'=>$items instanceof PackedArray,
        'bson_iterator'=>$iterator instanceof MongoDB\BSON\Iterator,'two_positions'=>count($rows)-1===2,
        'second_sku'=>$items->get(1)->get('sku')==='CABLE','unit_total'=>$total===3];
    return [$rows,$checks];
});
s136Report('mongodb136-shape-first-receipt', 'Прочитать первую поставку и напечатать приёмную ведомость', ['Что проверили', 'Результат'], $rows,$checks,$runtime,$counts);
foreach ($rows as [$label,$value]) {echo $label, ' — ', $value, PHP_EOL;}

Позиция 1 — LED × 2
Позиция 2 — CABLE × 1
На склад, единиц — 3

Самостоятельный запуск с реальной MongoDB. Таблица строится по сохранённым и заново прочитанным данным.

<?php
declare(strict_types=1);
use MongoDB\BSON\{Document,PackedArray};
use MongoDB\Driver\{Manager,BulkWrite};
require __DIR__.'/s136-helper.php';
[$rows,$checks,$runtime,$counts]=s136Lab(static function(Manager $manager,string $db,string $ns): array {
    $written=s136Write($manager,$ns,s136Manifests());
    $orders=s136Read($manager,$ns,[]);
    $decisions=['список'=>'проверить строки','пустой список'=>'нет позиций','объект'=>'вернуть формат',
        'поле отсутствует'=>'запросить состав','явный null'=>'уточнить у поставщика'];
    $rows=[];$shapes=[];
    foreach ($orders as $order) {
        $id=$order->get('_id');
        $shape=s136Shape($order);
        $shapes[$id]=$shape;
        $rows[]=[$id,$shape.' → '.$decisions[$shape]];
    }
    $checks=['written'=>$written===5,'read_all'=>count($orders)===5,'correct_list'=>$shapes['A']==='список',
        'empty_list'=>$shapes['B']==='пустой список','object_not_list'=>$shapes['C']==='объект',
        'missing_key'=>$shapes['D']==='поле отсутствует','explicit_null'=>$shapes['E']==='явный null'];
    return [$rows,$checks];
});
s136Report('mongodb136-shape-intake-board', 'Разнести пять входящих накладных по решению приёмщика', ['Что проверили', 'Результат'], $rows,$checks,$runtime,$counts);
foreach ($rows as [$label,$value]) {echo $label, ' — ', $value, PHP_EOL;}

A — список → проверить строки
B — пустой список → нет позиций
C — объект → вернуть формат
D — поле отсутствует → запросить состав
E — явный null → уточнить у поставщика

Самостоятельный запуск с реальной MongoDB. Таблица строится по сохранённым и заново прочитанным данным.

<?php
declare(strict_types=1);
use MongoDB\BSON\{Document,PackedArray};
use MongoDB\Driver\{Manager,BulkWrite};
require __DIR__.'/s136-helper.php';
[$rows,$checks,$runtime,$counts]=s136Lab(static function(Manager $manager,string $db,string $ns): array {
    $written=s136Write($manager,$ns,s136Manifests());
    $lines=s136Aggregate($manager,$db,$ns,[
        ['$unwind'=>['path'=>'$items','includeArrayIndex'=>'pos']],
        ['$sort'=>['_id'=>1,'pos'=>1]],['$project'=>['sku'=>'$items.sku','qty'=>'$items.qty','pos'=>['$toInt'=>'$pos']]],
    ]);
    $rows=[];$total=0;
    foreach ($lines as $line) {
        $position=$line['pos']===null ? 'без индекса' : 'индекс '.$line['pos'];
        $rows[]=[$line['_id'].' · '.$position,$line['sku'].' × '.$line['qty']];
        $total+=$line['qty'];
    }
    $rows[]=['Ошибочный приход',$total];
    $source=s136Read($manager,$ns,['_id'=>'C'])[0];
    $checks=['five_sources'=>$written===5,'unwound_three'=>count($lines)===3,'ids'=>array_column($lines,'_id')===['A','A','C'],
        'positions'=>array_column($lines,'pos')===[0,1,null],'extra_quantity'=>$lines[2]['qty']===2,'sum_five'=>$total===5,
        'source_object'=>$source->get('items') instanceof Document];
    return [$rows,$checks];
});
s136Report('mongodb136-shape-unwind-surplus', 'Найти источник лишних двух единиц после разворачивания списка', ['Что проверили', 'Результат'], $rows,$checks,$runtime,$counts);
foreach ($rows as [$label,$value]) {echo $label, ' — ', $value, PHP_EOL;}

A · индекс 0 — LED × 2
A · индекс 1 — CABLE × 1
C · без индекса — LED × 2
Ошибочный приход — 5

Самостоятельный запуск с реальной MongoDB. Таблица строится по сохранённым и заново прочитанным данным.

<?php
declare(strict_types=1);
use MongoDB\BSON\{Document,PackedArray};
use MongoDB\Driver\{Manager,BulkWrite};
require __DIR__.'/s136-helper.php';
[$rows,$checks,$runtime,$counts]=s136Lab(static function(Manager $manager,string $db,string $ns): array {
    $written=s136Write($manager,$ns,s136Manifests());
    $pipeline=[
        ['$match'=>['$expr'=>['$isArray'=>'$items']]],
        ['$unwind'=>'$items'],
        ['$group'=>['_id'=>'$_id','lines'=>['$sum'=>1],'units'=>['$sum'=>'$items.qty']]],
        ['$sort'=>['_id'=>1]],
    ];
    $report=s136Aggregate($manager,$db,$ns,$pipeline);
    $accepted=$report[0];
    $qualified=s136Aggregate($manager,$db,$ns,[['$match'=>['$expr'=>['$isArray'=>'$items']]],['$sort'=>['_id'=>1]],['$project'=>['_id'=>1]]]);
    $shapeMatch=implode(', ',array_column($qualified,'_id'));
    $rows=[['Список присутствует',$shapeMatch],['Вклад в сумму',$accepted['_id']],['Строк накладной',$accepted['lines']],['Единиц к приёмке',$accepted['units']]];
    $checks=['written'=>$written===5,'two_arrays'=>count($qualified)===2,'right_shapes'=>$shapeMatch==='A, B',
        'one_contributor'=>count($report)===1 && $accepted['_id']==='A','two_lines'=>$accepted['lines']===2,
        'three_units'=>$accepted['units']===3,'no_wrong_object'=>!in_array('C',array_column($report,'_id'),true)];
    return [$rows,$checks];
});
s136Report('mongodb136-shape-guarded-total', 'Получить на сервере 3 единицы и не считать ошибочный контейнер', ['Что проверили', 'Результат'], $rows,$checks,$runtime,$counts);
foreach ($rows as [$label,$value]) {echo $label, ' — ', $value, PHP_EOL;}

Список присутствует — A, B
Вклад в сумму — A
Строк накладной — 2
Единиц к приёмке — 3

Самостоятельный запуск с реальной MongoDB. Таблица строится по сохранённым и заново прочитанным данным.

<?php
declare(strict_types=1);
use MongoDB\BSON\{Document,PackedArray};
use MongoDB\Driver\{Manager,BulkWrite};
require __DIR__.'/s136-helper.php';
[$rows,$checks,$runtime,$counts]=s136Lab(static function(Manager $manager,string $db,string $ns): array {
    $written=s136Write($manager,$ns,s136Manifests());
    $classify=['$set'=>['sourceType'=>['$type'=>'$items'],'sourceCount'=>[
        '$cond'=>[['$isArray'=>'$items'],['$size'=>'$items'],null],
    ]]];
    $before=s136Aggregate($manager,$db,$ns,[$classify,['$unwind'=>'$items'],['$group'=>['_id'=>'$_id']],['$sort'=>['_id'=>1]]]);
    $after=s136Aggregate($manager,$db,$ns,[$classify,['$unwind'=>['path'=>'$items','preserveNullAndEmptyArrays'=>true]],
        ['$group'=>['_id'=>'$_id','inputType'=>['$first'=>'$sourceType'],'itemCount'=>['$first'=>'$sourceCount']]],
        ['$sort'=>['_id'=>1]]]);
    $shown=implode(', ',array_column($before,'_id'));
    $accounted=implode(', ',array_column($after,'_id'));
    $by=array_column($after,null,'_id');
    $rows=[['Номера после обычного unwind',$shown],['В контрольном журнале',$accounted],['B до разворачивания',$by['B']['inputType'].' · '.$by['B']['itemCount'].' позиций'],
        ['D до разворачивания',$by['D']['inputType']],['E до разворачивания',$by['E']['inputType']]];
    $checks=['written'=>$written===5,'normal_ids'=>$shown==='A, C','all_accounted'=>$accounted==='A, B, C, D, E',
        'empty_identified'=>$by['B']['inputType']==='array' && $by['B']['itemCount']===0,'missing_identified'=>$by['D']['inputType']==='missing',
        'null_identified'=>$by['E']['inputType']==='null','object_identified'=>$by['C']['inputType']==='object'];
    return [$rows,$checks];
});
s136Report('mongodb136-shape-preserve-shipments', 'Показать отделу закупок накладные, пропавшие из отчёта', ['Что проверили', 'Результат'], $rows,$checks,$runtime,$counts);
foreach ($rows as [$label,$value]) {echo $label, ' — ', $value, PHP_EOL;}

Номера после обычного unwind — A, C
В контрольном журнале — A, B, C, D, E
B до разворачивания — array · 0 позиций
D до разворачивания — missing
E до разворачивания — null

Самостоятельный запуск с реальной MongoDB. Таблица строится по сохранённым и заново прочитанным данным.

<?php
declare(strict_types=1);
use MongoDB\BSON\{Document,PackedArray};
use MongoDB\Driver\{Manager,BulkWrite};
require __DIR__.'/s136-helper.php';
[$rows,$checks,$runtime,$counts]=s136Lab(static function(Manager $manager,string $db,string $ns): array {
    $bad=Document::fromJSON('{"_id":"F","items":[{"sku":"LED","qty":2},"повреждено",{"sku":"CABLE","qty":-1}]}');
    $stock=Document::fromPHP(['_id'=>'stock','balance'=>['LED'=>10,'CABLE'=>20]]);
    $written=s136Write($manager,$ns,[$bad,$stock]);
    $shipment=s136Read($manager,$ns,['_id'=>'F'])[0];
    $review=s136Validate($shipment);
    if ($review['ok']) {throw new RuntimeException('Damaged shipment was accepted');}
    $balance=s136Stock(s136Read($manager,$ns,['_id'=>'stock'])[0]);
    $rows=[['Проверено строк',iterator_count($shipment->get('items')->getIterator())],['Правило приёмки','вся накладная целиком'],
        ['Замечание 1',$review['errors'][0]],['Замечание 2',$review['errors'][1]],['Начислено единиц',array_sum($review['amounts'])],['Остаток LED',$balance['LED']]];
    $checks=['two_stored'=>$written===2,'real_array'=>s136Shape($shipment)==='список','not_postable'=>!$review['ok'],
        'two_issues'=>count($review['errors'])===2,'first_bad_position'=>str_starts_with($review['errors'][0],'Строка 2'),
        'second_bad_position'=>str_starts_with($review['errors'][1],'Строка 3'),'nothing_posted'=>$review['amounts']===[],
        'stock_untouched'=>$balance===['LED'=>10,'CABLE'=>20]];
    return [$rows,$checks];
});
s136Report('mongodb136-shape-line-rejection', 'Отклонить накладную целиком и показать номера испорченных строк', ['Что проверили', 'Результат'], $rows,$checks,$runtime,$counts);
foreach ($rows as [$label,$value]) {echo $label, ' — ', $value, PHP_EOL;}

Проверено строк — 3
Правило приёмки — вся накладная целиком
Замечание 1 — Строка 2 — требуется документ
Замечание 2 — Строка 3 — нужно целое от 1 до 1000
Начислено единиц — 0
Остаток LED — 10

Самостоятельный запуск с реальной MongoDB. Таблица строится по сохранённым и заново прочитанным данным.

<?php
declare(strict_types=1);
use MongoDB\BSON\{Document,PackedArray};
use MongoDB\Driver\{Manager,BulkWrite};
require __DIR__.'/s136-helper.php';
[$rows,$checks,$runtime,$counts]=s136Lab(static function(Manager $manager,string $db,string $ns): array {
    $receipt=s136Manifests()[0];
    $stock=Document::fromPHP(['_id'=>'before','balance'=>['LED'=>10,'CABLE'=>20]]);
    $physical=Document::fromPHP(['_id'=>'counted','balance'=>['LED'=>11,'CABLE'=>21]]);
    $written=s136Write($manager,$ns,[$receipt,$stock,$physical]);
    $review=s136Validate(s136Read($manager,$ns,['_id'=>'A'])[0]);
    if (!$review['ok']) {throw new RuntimeException('Expected complete receipt');}
    $before=s136Stock(s136Read($manager,$ns,['_id'=>'before'])[0]);
    $counted=s136Stock(s136Read($manager,$ns,['_id'=>'counted'])[0]);
    $rows=[];$diff=[];
    foreach ($before as $sku=>$old) {
        $expected=$old+($review['amounts'][$sku] ?? 0);
        $diff[$sku]=$counted[$sku]-$expected;
        $rows[]=[$sku,'ожидаем '.$expected.' · на полке '.$counted[$sku].' · разница '.$diff[$sku]];
    }
    $checks=['three_inputs'=>$written===3,'accepted'=>$review['ok'],'led_before'=>$before['LED']===10,'cable_before'=>$before['CABLE']===20,
        'receipt_units'=>array_sum($review['amounts'])===3,'short_one'=>$diff['LED']===-1,'cable_balanced'=>$diff['CABLE']===0];
    return [$rows,$checks];
});
s136Report('mongodb136-shape-stock-count', 'Сопоставить накладную с фактически пересчитанной полкой', ['Что проверили', 'Результат'], $rows,$checks,$runtime,$counts);
foreach ($rows as [$label,$value]) {echo $label, ' — ', $value, PHP_EOL;}

LED — ожидаем 12 · на полке 11 · разница -1
CABLE — ожидаем 21 · на полке 21 · разница 0

Самостоятельный запуск с реальной MongoDB. Таблица строится по сохранённым и заново прочитанным данным.

<?php
declare(strict_types=1);
use MongoDB\BSON\{Document,PackedArray};
use MongoDB\Driver\{Manager,BulkWrite};
require __DIR__.'/s136-helper.php';
[$rows,$checks,$runtime,$counts]=s136Lab(static function(Manager $manager,string $db,string $ns): array {
    $stock=Document::fromPHP(['_id'=>'stock','balance'=>['LED'=>10,'CABLE'=>20],'applied'=>[]]);
    $written=s136Write($manager,$ns,[s136Manifests()[0],$stock]);
    $manifest=s136Read($manager,$ns,['_id'=>'A'])[0];
    $review=s136Validate($manifest);
    if (!$review['ok']) {throw new RuntimeException('Invalid shipment');}
    $id=$manifest->get('_id');
    $increments=[];
    foreach ($review['amounts'] as $sku=>$qty) {$increments['balance.'.$sku]=$qty;}
    $post=static function() use ($manager,$ns,$id,$increments): int {
        $bulk=new BulkWrite();
        $bulk->update(['_id'=>'stock','applied'=>['$ne'=>$id]],['$inc'=>$increments,'$addToSet'=>['applied'=>$id]],['upsert'=>false]);
        return $manager->executeBulkWrite($ns,$bulk)->getModifiedCount();
    };
    $first=$post();
    $afterFirst=s136Stock(s136Read($manager,$ns,['_id'=>'stock'])[0]);
    $second=$post();
    $finalStock=s136Read($manager,$ns,['_id'=>'stock'])[0];
    $balance=s136Stock($finalStock);
    $applied=$finalStock->get('applied');
    $rows=[['Изменений при первой приёмке',$first],['Изменений при повторе',$second],['LED на складе',$balance['LED']],
        ['CABLE на складе',$balance['CABLE']],['Учтённая накладная',$applied->get(0)]];
    $checks=['two_sources'=>$written===2,'valid_manifest'=>$review['ok'],'first_changed'=>$first===1,'second_skipped'=>$second===0,
        'balance_after_first'=>$afterFirst===['LED'=>12,'CABLE'=>21],'balance_after_repeat'=>$balance===$afterFirst,
        'one_receipt'=>$applied->has(0) && !$applied->has(1) && $applied->get(0)==='A'];
    return [$rows,$checks];
});
s136Report('mongodb136-shape-post-receipt', 'Начислить поставку один раз и проверить остаток после повтора', ['Что проверили', 'Результат'], $rows,$checks,$runtime,$counts);
foreach ($rows as [$label,$value]) {echo $label, ' — ', $value, PHP_EOL;}

Изменений при первой приёмке — 1
Изменений при повторе — 0
LED на складе — 12
CABLE на складе — 21
Учтённая накладная — A

Самостоятельный запуск с реальной MongoDB. Таблица строится по сохранённым и заново прочитанным данным.