water/server/tests/water_business_test.php

<?php
/** php tests/water_business_test.php：真实数据库事务回滚，不保留测试业务数据。 */
require dirname(__DIR__) . '/vendor/autoload.php';
\Dotenv\Dotenv::createUnsafeMutable(dirname(__DIR__))->load();
\support\App::loadAllConfig(['route']);
date_default_timezone_set('Asia/Shanghai');
use support\Db;
use plugin\saiadmin\app\model\water\WaterModel;
use plugin\saiadmin\app\service\WaterBusiness;
use plugin\saiadmin\exception\ApiException;
$checks = 0;
function check(bool $condition,string $message): void { global $checks; ++$checks; if (!$condition) throw new RuntimeException($message); }
function rejects(callable $callback,string $message): void { try { $callback(); } catch (ApiException $e) { check(true,$message); return; } throw new RuntimeException($message); }
function record(string $table,int $id): array { return WaterModel::forKind($table)->where('id',$id)->first()?->toArray(); }
$service = new WaterBusiness();
$tag = 'WATER-TEST-'.bin2hex(random_bytes(6));
$before = (int)\plugin\saiadmin\app\model\water\WaterEnterprise::query()->count();
Db::beginTransaction();
try {
    \plugin\saiadmin\app\model\water\WaterAlertSetting::query()->where('id',1)->update(['alert_qty'=>5,'days_per_barrel'=>3,'urgent_qty'=>2]);
 $agentInput = ['name'=>$tag,'contact'=>'测试代理联系人','phone'=>'TEST','region'=>'测试服务区','address'=>'测试地址'];
 $agentId = $service->save('agent',$agentInput + ['user_id'=>1],1)['id'];
 check(record('agent',$agentId)['user_id'] === null,'agent creation cannot bind an arbitrary login account');
 check((int)$service->listing('agents',['keyword'=>$tag])['total'] === 1,'agent directory search uses independent water data');
 $service->save('agent',$agentInput + ['id'=>$agentId,'status'=>2],1);
 check((int)record('agent',$agentId)['status'] === 2,'agent cooperation status can be disabled');
 rejects(fn()=>$service->save('agent',array_merge($agentInput,['phone'=>'']),1),'agent contact phone is required');
 $enterprise = $service->save('enterprise',['name'=>$tag,'contact'=>'测试联系人','phone'=>'TEST','region'=>'测试区','address'=>'事务回滚测试地址'],1)['id'];
 $sku = $service->save('sku',['name'=>$tag,'liters'=>18.9,'safety_stock'=>2],1)['id'];
 $package = $service->save('package',['name'=>$tag,'sku_id'=>$sku,'buckets'=>30,'price_cents'=>69900],1)['id'];
 rejects(fn()=>$service->save('package',['name'=>'invalid','sku_id'=>$sku,'buckets'=>1.5,'price_cents'=>1],1),'fractional buckets rejected');
 rejects(fn()=>$service->save('sku',['name'=>'invalid','liters'=>0],1),'zero capacity rejected');
 $purchase = ['enterprise_id'=>$enterprise,'package_id'=>$package,'reference'=>$tag];
 $order = $service->purchase($purchase,1);
 check($service->purchase($purchase,1)['id'] === $order['id'],'receipt retry idempotent');
 $account = \plugin\saiadmin\app\model\water\WaterAccount::query()->where(['enterprise_id'=>$enterprise,'sku_id'=>$sku])->first()?->toArray();
 check((int)$account['entitlement'] === 30 && (int)$account['full_qty'] === 0,'purchase changes entitlement only');
 $stock = ['sku_id'=>$sku,'mode'=>'inbound','quantity'=>50,'reference'=>$tag,'note'=>'测试入库'];
 $service->stock($stock,1);
 rejects(fn()=>$service->stock($stock,1),'duplicate stock receipt rejected');
 rejects(fn()=>$service->createDelivery(['enterprise_id'=>$enterprise,'sku_id'=>$sku,'quantity'=>31],1),'insufficient entitlement rejected');
 $task = $service->createDelivery(['enterprise_id'=>$enterprise,'sku_id'=>$sku,'quantity'=>10],1)['id'];
 $s = record('sku',$sku); $a = record('account',(int)$account['id']);
 check((int)$s['available'] === 40 && (int)$s['locked'] === 10,'task reserves inventory');
 check((int)$a['entitlement'] === 30 && (int)$a['frozen'] === 10,'task freezes without deducting entitlement');
 rejects(fn()=>$service->createDelivery(['enterprise_id'=>$enterprise,'sku_id'=>$sku,'quantity'=>1],1),'duplicate active task rejected');
 rejects(fn()=>$service->transition(['id'=>$task,'action'=>'complete'],1),'cannot sign before departure');
 $alerts = $service->listing('alerts',['keyword'=>$tag]);
 check($alerts['total'] === 1 && (int)$alerts['data'][0]['delivery_id'] === $task,'alert links active task');
 check($alerts['data'][0]['days_left'] === null,'no fabricated prediction');
 $service->transition(['id'=>$task,'action'=>'assign','driver'=>'测试配送员','driver_phone'=>'TEST'],1);
 $service->transition(['id'=>$task,'action'=>'depart'],1);
 $service->transition(['id'=>$task,'action'=>'depart'],1);
 $s = record('sku',$sku);
 check((int)$s['locked'] === 0 && (int)$s['transit'] === 10,'departure idempotent');
 rejects(fn()=>$service->transition(['id'=>$task,'action'=>'cancel'],1),'in transit cannot silently cancel');
 rejects(fn()=>$service->transition(['id'=>$task,'action'=>'complete','empty_returned'=>1],1),'cannot return nonexistent empties');
 $service->transition(['id'=>$task,'action'=>'complete','empty_returned'=>0],1);
 $service->transition(['id'=>$task,'action'=>'complete','empty_returned'=>0],1);
 $a = record('account',(int)$account['id']); $s = record('sku',$sku);
 check((int)$a['entitlement'] === 20 && (int)$a['frozen'] === 0 && (int)$a['full_qty'] === 10,'sign once settles entitlement and site stock');
 check((int)$s['transit'] === 0 && (int)$s['available'] === 40,'sign clears transit');
 $service->stock(['sku_id'=>$sku,'enterprise_id'=>$enterprise,'mode'=>'exchange','quantity'=>2,'reference'=>$tag.'-exchange','note'=>'测试换桶'],1);
 $a = record('account',(int)$account['id']);
 check((int)$a['full_qty'] === 8 && (int)$a['empty_qty'] === 2 && (int)$a['entitlement'] === 20,'exchange only affects physical stock');
 rejects(fn()=>$service->stock(['sku_id'=>$sku,'enterprise_id'=>$enterprise,'mode'=>'exchange','quantity'=>9,'reference'=>$tag.'-bad','note'=>'不足'],1),'cannot exchange beyond full stock');
 $task2 = $service->createDelivery(['enterprise_id'=>$enterprise,'sku_id'=>$sku,'quantity'=>5],1)['id'];
 $service->transition(['id'=>$task2,'action'=>'cancel'],1);
 $service->transition(['id'=>$task2,'action'=>'cancel'],1);
 check((int)record('sku',$sku)['available'] === 40 && (int)record('account',(int)$account['id'])['frozen'] === 0,'cancel releases both exactly once');
 $task3 = $service->createDelivery(['enterprise_id'=>$enterprise,'sku_id'=>$sku,'quantity'=>5],1)['id'];
 $service->transition(['id'=>$task3,'action'=>'assign','driver'=>'测试配送员','driver_phone'=>'TEST'],1);
 $service->transition(['id'=>$task3,'action'=>'depart'],1);
 $service->transition(['id'=>$task3,'action'=>'complete','empty_returned'=>2],1);
 check((int)record('sku',$sku)['empty_qty'] === 2 && (int)record('account',(int)$account['id'])['empty_qty'] === 0,'empty return moves stock');
 $s = record('sku',$sku); $a = record('account',(int)$account['id']);
 check((int)$s['available']+(int)$s['locked']+(int)$s['transit']+(int)$a['full_qty']+(int)$a['empty_qty']+(int)$s['empty_qty'] === 50,'physical barrels conserved');
 check((int)$a['entitlement'] === 15,'remaining entitlement after two deliveries');
 $accountId = (int)$account['id'];
 $policyBefore = record('account',$accountId);
 rejects(fn()=>$service->saveAlertPolicy(['id'=>$accountId,'threshold_qty'=>13,'entitlement'=>999,'daily_liters'=>999],1),'per-enterprise policy command retired');
 check(record('account',$accountId) === $policyBefore,'retired policy cannot modify account');
 check(\plugin\saiadmin\app\model\water\WaterLedger::query()->where(['kind'=>'alert_policy','reference'=>'account:'.$accountId,'created_by'=>1])->count() === 0,'rejected policy creates no audit');
 check((int)$service->listing('alerts',['keyword'=>$tag])['total'] === 0,'thirteen barrels does not alert');
 $allAccounts = $service->listing('alerts',['keyword'=>$tag,'scope'=>'all']);
 check($allAccounts['total'] === 1 && $allAccounts['data'][0]['severity'] === 'healthy','healthy accounts remain visible');
 $enterprise2 = $service->save('enterprise',['name'=>$tag.'-batch','contact'=>'测试','phone'=>'TEST','address'=>'第二处测试地址'],1)['id'];
 $service->purchase(['enterprise_id'=>$enterprise2,'package_id'=>$package,'reference'=>$tag.'-batch'],1);
 $account2 = (int)\plugin\saiadmin\app\model\water\WaterAccount::query()->where(['enterprise_id'=>$enterprise2,'sku_id'=>$sku])->value('id');
 foreach ([[],array_fill(0,51,['account_id'=>$accountId,'quantity'=>1]),['bad'],[['account_id'=>$accountId,'quantity'=>0]],[['account_id'=>$accountId,'quantity'=>1],['account_id'=>$accountId,'quantity'=>1]]] as $invalid) {
  rejects(fn()=>$service->batchCreateDelivery(['items'=>$invalid],1),'invalid batch rejected');
 }
 $stockBefore = record('sku',$sku);
 $taskCount = \plugin\saiadmin\app\model\water\WaterDelivery::query()->count();
 $ledgerCount = \plugin\saiadmin\app\model\water\WaterLedger::query()->count();
 rejects(fn()=>$service->batchCreateDelivery(['items'=>[['account_id'=>$accountId,'quantity'=>1],['account_id'=>$account2,'quantity'=>31]]],1),'batch rolls back when later entitlement insufficient');
 check(record('sku',$sku) === $stockBefore && (int)record('account',$accountId)['frozen'] === 0,'failed batch restores earlier stock and entitlement');
 check(\plugin\saiadmin\app\model\water\WaterDelivery::query()->count() === $taskCount && \plugin\saiadmin\app\model\water\WaterLedger::query()->count() === $ledgerCount,'failed batch leaves no tasks or ledger entries');
 rejects(fn()=>$service->batchCreateDelivery(['items'=>[['account_id'=>$accountId,'quantity'=>10],['account_id'=>$account2,'quantity'=>30]]],1),'batch checks combined warehouse capacity');
 check(record('sku',$sku) === $stockBefore,'combined stock failure rolls back');
 \plugin\saiadmin\app\model\water\WaterEnterprise::query()->where('id',$enterprise2)->update(['status'=>2]);
 rejects(fn()=>$service->batchCreateDelivery(['items'=>[['account_id'=>$accountId,'quantity'=>1],['account_id'=>$account2,'quantity'=>1]]],1),'disabled enterprise rejects entire batch');
 \plugin\saiadmin\app\model\water\WaterEnterprise::query()->where('id',$enterprise2)->update(['status'=>1]);
 $batchInput = ['items'=>[['account_id'=>$account2,'quantity'=>4,'enterprise_id'=>$enterprise],['account_id'=>$accountId,'quantity'=>3]]];
 $batch = $service->batchCreateDelivery($batchInput,1);
 check($batch['count'] === 2 && (int)record('sku',$sku)['available'] === (int)$stockBefore['available']-7,'batch success reserves aggregate stock');
 check((int)record('account',$accountId)['frozen'] === 3 && (int)record('account',$account2)['frozen'] === 4,'batch resolves enterprise from account rather than client fields');
 rejects(fn()=>$service->batchCreateDelivery($batchInput,1),'repeated batch cannot create duplicate active deliveries');
 check((int)record('sku',$sku)['locked'] === (int)$stockBefore['locked']+7,'retry does not reserve twice');
 foreach ($batch['created'] as $created) $service->transition(['id'=>$created['id'],'action'=>'cancel'],1);
 check((int)record('sku',$sku)['available'] === (int)$stockBefore['available'],'batch tasks use normal cancellation release');
 \plugin\saiadmin\app\model\water\WaterSku::query()->where('id',$sku)->update(['status'=>2]);
 check((int)$service->listing('alerts',['keyword'=>$tag,'scope'=>'all'])['total'] === 0,'disabled SKU excluded from replenishment');
 \plugin\saiadmin\app\model\water\WaterSku::query()->where('id',$sku)->update(['status'=>1]);
 $device = $service->save('device',['name'=>$tag,'sn'=>$tag,'enterprise_id'=>$enterprise,'sku_id'=>$sku],1);
 $devices = $service->listing('devices',['keyword'=>$tag]);
 check($devices['data'][0]['connection_status'] === 'unconnected' && $devices['data'][0]['today_liters'] === null,'new device has no invented telemetry');
 rejects(fn()=>$service->save('content',['title'=>'unsafe','audience'=>'all','target_url'=>'javascript:alert(1)'],1),'unsafe content URL rejected');
 $content = $service->save('content',['title'=>$tag,'audience'=>'new','starts_at'=>'2099-01-01 00:00:00'],1);
 check($service->listing('content',['keyword'=>$tag])['data'][0]['delivery_status'] === 'scheduled','content scheduling');
 $overview = $service->overview();
 check(isset($overview['stock']['available']) && isset($overview['fulfilment']['completed']),'dashboard aggregate query works: '.json_encode($overview['stock']));
 foreach (['enterprises','inventory','packages','dispatch','finance','accounts','ledger'] as $module) {
  check(isset($service->listing($module,['keyword'=>$tag])['data']),'listing works: '.$module);
 }
 $otherUser = Db::table('sa_system_user')->where('id','<>',1)->where('status',1)->whereNull('delete_time')->orderBy('id')->value('id');
 if ($otherUser) {
  $reflection = new ReflectionClass(\plugin\saiadmin\app\controller\water\WaterController::class);
  $controller = $reflection->newInstanceWithoutConstructor();
  $reflection->getProperty('adminId')->setValue($controller,(int)$otherUser);
  $authorize = $reflection->getMethod('authorize');
  // 新业务没有自动授予旧角色；使用现有普通账号验证默认拒绝。
  rejects(fn()=>$authorize->invoke($controller,'inventory','write'),'legacy account cannot access new water business without grant');
  rejects(fn()=>$authorize->invoke($controller,'alerts','write'),'policy requires explicit alerts write permission');
  rejects(fn()=>$authorize->invoke($controller,'dispatch','write'),'batch delivery requires explicit dispatch write permission');
 }
} finally { Db::rollback(); }
check((int)\plugin\saiadmin\app\model\water\WaterEnterprise::query()->count() === $before,'test data rolled back');
echo "PASS: $checks water business checks; all test records rolled back.\n";