commit2

AGENTS.md

@@ -1,5 +1,9 @@
 # SGF Tempo — instruções locais
 
+- Autorização técnica de 27/10/2026: `INDUSTRIAL-COST-SIM-v1`, secções 15/15.5, só em `sgf_tempo_test`. Ver `docs/INDUSTRIAL_COST_DELIVERY.md`. Um lote/produto sintéticos, material 1000 + trabalho 500 + CIF 300 = 1800, 10 UN / 180 por UN; conjunto 600, capacidade 10 HM, uso 5 HM e residual 300 separado. Sem taxa material, 800 conhecidos, total/unitário indisponíveis. Critério é hipótese sintética, não método real aprovado. Preparação/validação industrial explícitas por identidades distintas; não herdar custo directo, transformar oficina em lote ou duplicar origens. `100000` e quatro concessões reais apenas propostas, NÃO aplicar sem confirmação específica. Preservar checkpoints/alterações/aprovações/bloqueios. Sem aceitação presumida, checkpoint de encerramento, stock, previsto/realizado, margens, lançamentos ou publicação.
+
+- Autorização específica posterior de 27/10/2026 executada: apenas `090000` aplicada em `sgf_tempo_dev`, por caminho explícito e proprietário separado, e quatro concessões auditadas no tenant #1 / Tempo Lda #1 / SEGI #1: Osmane #1 `direct_costs.view/prepare`; Samira #2 `direct_costs.view/validate`. Ver actualização de `docs/WORKSHOP_DIRECT_COST_DELIVERY.md`. Preservadas 60 tabelas anteriores, dados/acessos e instalações `070000`/`080000`; seis tabelas de custo vazias. Aplicação mantém `sgf_dev_app`; custeio, oficinas, recebimentos e emissão reais bloqueados e guardas SQL verificadas. Sem taxas/cálculos reais, novas concessões técnicas ou publicação. As indicações anteriores de `090000`/quatro concessões pendentes são históricas; não activar uso operacional por consequência desta instalação.
+
 - Encerramento por delegação de 27/10/2026: o utilizador autorizou aceitar a entrega isolada de custos directos após conferência técnica do percurso e preservar checkpoint local. Ver `docs/WORKSHOP_DIRECT_COST_ACCEPTANCE.md`. Não se atribui nova verificação pessoal no navegador ao utilizador. `090000` e quatro concessões continuam NÃO aplicados; custeio real, emissão e restantes operações reais bloqueados. Sem CIF/lote industrial ou publicação. Esta autorização substitui apenas a pendência de encerramento técnico deste ensaio.
 
 - Autorização técnica de 27/10/2026: implementar apenas `WORKSHOP-DIRECT-COST-SIM-v1`, secção 14 de `docs/INDUSTRIAL_COST_ACCOUNTING_SCOPE.md`. Ver `docs/WORKSHOP_DIRECT_COST_DELIVERY.md`. Apenas sintético em `sgf_tempo_test`, origens de oficina verificadas por ID/versão, sem duplicar acontecimentos. 275 MZN conhecidos ou 175 incompletos sem taxa material; exactidão racional, nunca custo completo/margem. Preparação e validação de custos/taxas por identidades distintas, sem editar apontamentos. `090000` e quatro concessões reais apenas propostos, NÃO aplicados; confirmação específica antes de aplicação. Não activar custeio real ou publicar; preservar `7628645`, `ea9dcb3`, alterações posteriores, oficinas/recebimentos/fiscalidade e aprovações. Sem presumir aceitação, CIF ou lote industrial.

README.md

@@ -1,5 +1,9 @@
 # SGF TEMPO
 
+**Ensaio industrial (`INDUSTRIAL-COST-SIM-v1`):** lote/produto sintéticos com composição exacta, imputação por capacidade explícita, residual separado e variante incompleta. Percurso/provas e propostas pendentes em [INDUSTRIAL_COST_DELIVERY.md](docs/INDUSTRIAL_COST_DELIVERY.md). Exclusivamente `sgf_tempo_test`; `100000` e direitos industriais reais não aplicados. Custeio real e restantes operações reais continuam bloqueados; sem stock ou lançamentos.
+
+**Actualização posterior de custos directos:** `090000` e os quatro direitos de consulta/preparação/validação foram instalados tecnicamente por autorização específica, com tabelas de custo vazias e custeio real bloqueado. Ver a secção de instalação em [WORKSHOP_DIRECT_COST_DELIVERY.md](docs/WORKSHOP_DIRECT_COST_DELIVERY.md); as menções anteriores a essa pendência são históricas.
+
 **Estado posterior em 27/10/2026:** oficinas e recebimentos sintéticos foram aceites; `080000`/quatro concessões de abertura e `070000`/oito concessões foram instaladas tecnicamente por autorizações específicas, sem retirar os bloqueios reais. As indicações de pendência nos parágrafos históricos abaixo foram substituídas pelos relatórios actualizados. O ensaio de custo directo e as suas pendências estão em [WORKSHOP_DIRECT_COST_DELIVERY.md](docs/WORKSHOP_DIRECT_COST_DELIVERY.md); `090000` e quatro concessões de custos não foram aplicadas.
 
 **Oficina de teste (`WORKSHOP-RESOURCE-RECORD-v1`):** ordem, responsável, autorização por versão da tarefa, apontamentos de tempos/materiais e verificação distinta do autor. Só funciona em instância isolada ligada a `sgf_tempo_test`. Abrir a ordem não autoriza executar; ocorrência passada pode ser relatada e reconhecida apenas para auditoria, conservando a marca de fora do âmbito. Comandos, percurso e provas em [WORKSHOP_RESOURCE_DELIVERY.md](docs/WORKSHOP_RESOURCE_DELIVERY.md). Migração `080000` e concessões reais não aplicadas; técnico/verificador reais ainda não indicados. A migração `070000` também permanece pendente: não usar migração geral para aplicar ambas sem autorização específica. Sem stock, custos, facturação ou utilização operacional. Não confundir esta entrega técnica com aceitação do utilizador ou de recebimentos.

app/Modules/Industry/Http/IndustrialCostsController.php

@@ -0,0 +1,13 @@
+<?php
+namespace App\Modules\Industry\Http;
+use App\Http\Controllers\Controller;
+use App\Modules\Industry\IndustrialCosts;
+use Illuminate\Http\Request;
+final class IndustrialCostsController extends Controller {
+    private function response(array $d){return response()->json($d)->header('Cache-Control','no-store, private');}
+    public function index(Request $r,IndustrialCosts $c){return $this->response($c->listing($r->user()->id));}
+    public function open(Request $r,IndustrialCosts $c){return $this->response($c->open($r->user()->id,$r->all(),(string)$r->header('Idempotency-Key')));}
+    public function input(Request $r,int $id,IndustrialCosts $c){return $this->response($c->input($id,$r->user()->id,$r->all(),(string)$r->header('Idempotency-Key')));}
+    public function calculate(Request $r,int $id,IndustrialCosts $c){return $this->response($c->calculate($id,$r->user()->id,$r->all(),(string)$r->header('Idempotency-Key')));}
+    public function decide(Request $r,int $id,IndustrialCosts $c){return $this->response($c->decide($id,$r->user()->id,$r->all(),(string)$r->header('Idempotency-Key')));}
+}

app/Modules/Industry/IndustrialCosts.php

@@ -0,0 +1,133 @@
+<?php
+namespace App\Modules\Industry;
+use App\Modules\Identity\Services\Audit;
+use App\Modules\Identity\Services\Permissions;
+use App\Modules\Services\ServiceCalculation;
+use App\Shared\Context\CompanyContext;
+use App\Shared\Costs\ExactCostMath as Exact;
+use App\Shared\Testing\TestingDatabaseGuard;
+use Brick\Math\BigRational as Number;
+use Illuminate\Support\Facades\DB;
+use Illuminate\Support\Facades\Validator;
+
+final class IndustrialCosts {
+    public const POLICY='INDUSTRIAL-COST-SIM-v1';
+    public const NOTICE='ENSAIO INDUSTRIAL — SEM UTILIZAÇÃO OPERACIONAL';
+    public const KINDS=['material','labour','pool','machine','production','material_rate','labour_rate','criterion'];
+    public function __construct(private CompanyContext $context,private Permissions $permissions){}
+    public static function guard(): void {abort_unless(ServiceCalculation::isolated(),403,'Custeio industrial real bloqueado; apenas testes isolados.');TestingDatabaseGuard::assertSafe();}
+    private function json(mixed $v): string {return json_encode($v,JSON_THROW_ON_ERROR|JSON_UNESCAPED_UNICODE);}
+    private function canonical(mixed $v): mixed {if(!is_array($v))return $v;if(!array_is_list($v))ksort($v);return array_map(fn($x)=>$this->canonical($x),$v);}
+    private function exact(array $in,array $rules): array {abort_if(array_diff(array_keys($in),array_keys($rules)),422,'Campo fora do ensaio industrial.');return Validator::make($in,$rules)->validate();}
+    private function decimal(bool $positive=false): array {return ['bail','required','string','regex:/^(?:0|[1-9][0-9]{0,15})(?:\.[0-9]{1,8})?$/D',function($a,$v,$fail)use($positive){if($positive&&Number::of($v)->isLessThanOrEqualTo(0))$fail('Quantidade/capacidade deve ser positiva.');}];}
+    private function scope(int $actor,string $right): array {
+        $s=$this->context->identifiers()+['unit_id'=>$this->context->unitId()];abort_unless($actor===$this->context->userId()&&$s['unit_id']!==null,403);
+        $this->context->selectFor($actor,$s['tenant_id'],$s['company_id'],$s['unit_id']);
+        foreach(['view',$right] as $r)$this->permissions->require($actor,$s['tenant_id'],$s['company_id'],'industrial_costs.'.$r,$s['unit_id']);return $s;
+    }
+    private function lot(int $id,array $s): object {return DB::table('ic_lots')->where($s)->where('id',$id)->first()??abort(403,'Lote fora do âmbito autorizado.');}
+    private function command(?int $lot,int $actor,string $action,array $in,string $key,callable $write): array {
+        self::guard();$right=$action==='decide'?'validate':'prepare';$s=$this->scope($actor,$right);if($lot)$this->lot($lot,$s);
+        abort_unless(preg_match('/^[A-Za-z0-9_-]{8,100}$/D',$key),422,'Chave de idempotência necessária.');$hash=hash('sha256',$this->json($this->canonical(['lot_id'=>$lot,'input'=>$in])));
+        return DB::transaction(function()use($lot,$actor,$action,$right,$s,$key,$hash,$write){
+            DB::table('companies')->where('id',$s['company_id'])->lockForUpdate()->firstOrFail();$this->scope($actor,$right);if($lot)$this->lot($lot,$s);
+            $old=DB::table('ic_commands')->where($s)->where(['actor_id'=>$actor,'action'=>$action,'command_key'=>$key])->first();
+            if($old){$this->lot($old->lot_id,$s);abort_unless(hash_equals($old->request_hash,$hash),409,'Repetição com conteúdo diferente.');return json_decode($old->result,true,64,JSON_THROW_ON_ERROR)+['replayed'=>true];}
+            $out=$write($s);$cmd=DB::table('ic_commands')->insertGetId($s+['lot_id'=>$out['lot_id'],'actor_id'=>$actor,'action'=>$action,'command_key'=>$key,'request_hash'=>$hash,'result'=>$this->json($out),'created_at'=>now()]);
+            Audit::record('industrial_costs.'.$action,$actor,$s['tenant_id'],$s['company_id'],$s['unit_id'],details:['record_id'=>$out['id'],'version'=>$out['version']]);
+            $event=DB::table('ic_events')->insertGetId(['command_id'=>$cmd,'schema_version'=>1,'payload'=>$this->json(['policy'=>self::POLICY,'scope'=>$s,'actor_id'=>$actor,'action'=>$action,'result'=>$out]),'created_at'=>now()]);
+            DB::table('ic_outbox')->insert(['event_id'=>$event,'state'=>'captured_no_stock_or_accounting']);return $out+['replayed'=>false];
+        },3);
+    }
+    public function open(int $actor,array $in,string $key): array {
+        self::guard();$d=$this->exact($in,['reference'=>'required|string|min:3|max:100','product_reference'=>'required|string|min:3|max:100','product_name'=>'required|string|min:3|max:200','centre'=>'required|string|min:3|max:100','period_start'=>'required|date_format:Y-m-d','period_end'=>'required|date_format:Y-m-d|after_or_equal:period_start','currency'=>'required|in:MZN']);
+        return $this->command(null,$actor,'open',$d,$key,function($s)use($actor,$d){
+            abort_if(DB::table('ic_lots')->where('company_id',$s['company_id'])->where('reference',$d['reference'])->exists(),409,'Identidade de lote já usada.');
+            abort_if(DB::table('ic_products')->where('company_id',$s['company_id'])->where('reference',$d['product_reference'])->exists(),409,'Este recorte cria um produto próprio por lote; identidade já usada.');
+            $product=DB::table('ic_products')->insertGetId($s+['reference'=>$d['product_reference'],'name'=>$d['product_name'],'version'=>1,'unit'=>'UN','actor_id'=>$actor,'created_at'=>now()]);
+            $id=DB::table('ic_lots')->insertGetId($s+['product_id'=>$product,'reference'=>$d['reference'],'centre'=>$d['centre'],'period_start'=>$d['period_start'],'period_end'=>$d['period_end'],'currency'=>$d['currency'],'actor_id'=>$actor,'created_at'=>now()]);return ['id'=>$id,'lot_id'=>$id,'version'=>1,'kind'=>'lot'];
+        });
+    }
+    private function row(string $type,int $id,int $lot): object {return DB::table($type==='input'?'ic_inputs':'ic_results')->where(['id'=>$id,'lot_id'=>$lot])->first()??abort(403,'Origem/resultado fora do lote.');}
+    private function current(string $type,object $r): bool {return !DB::table($type==='input'?'ic_inputs':'ic_results')->where('previous_id',$r->id)->exists();}
+    private function approvedInput(int $id,int $version,int $lot,?string $kind=null): object {
+        $r=$this->row('input',$id,$lot);abort_unless($r->version===$version&&($kind===null||$r->kind===$kind),409,'Tipo/versão incompatível.');
+        abort_unless($this->current('input',$r)&&DB::table('ic_decisions')->where(['input_id'=>$id,'version'=>$version,'decision'=>'approved'])->exists(),409,'Origem/taxa/critério exige versão actual validada.');$r->data=json_decode($r->data,true,64,JSON_THROW_ON_ERROR);return $r;
+    }
+    private function validateData(string $kind,array $data,object $lot): array {
+        if(in_array($kind,['material','labour','pool','machine','production'])){
+            $unit=match($kind){'material'=>'KG','labour'=>'MIN','pool'=>'MZN','machine'=>'HM','production'=>'UN'};
+            $rules=['quantity'=>$this->decimal($kind!=='pool'),'unit'=>'required|in:'.$unit,'event_date'=>'required|date_format:Y-m-d'];if($kind==='production')$rules['completed']='required|accepted';$d=$this->exact($data,$rules);
+            abort_unless($d['event_date']>=$lot->period_start&&$d['event_date']<=$lot->period_end,422,'Origem fora do período.');return $d;
+        }
+        if(in_array($kind,['material_rate','labour_rate'])){
+            $d=$this->exact($data,['source_id'=>'required|integer|min:1','source_version'=>'required|integer|min:1','amount'=>$this->decimal(),'currency'=>'required|in:MZN','unit'=>'required|in:'.($kind==='material_rate'?'KG':'H')]);
+            $this->approvedInput($d['source_id'],$d['source_version'],$lot->id,str_replace('_rate','',$kind));return $d;
+        }
+        $d=$this->exact($data,['pool_id'=>'required|integer|min:1','pool_version'=>'required|integer|min:1','machine_id'=>'required|integer|min:1','machine_version'=>'required|integer|min:1','capacity'=>$this->decimal(true),'driver_unit'=>'required|in:HM','hypothesis'=>'required|in:synthetic_only']);
+        $this->approvedInput($d['pool_id'],$d['pool_version'],$lot->id,'pool');$this->approvedInput($d['machine_id'],$d['machine_version'],$lot->id,'machine');return $d;
+    }
+    public function input(int $lot,int $actor,array $in,string $key): array {
+        self::guard();$d=$this->exact($in,['kind'=>'required|in:'.implode(',',self::KINDS),'source_ref'=>['required','string','max:100','regex:/^IND-TEST-[A-Za-z0-9_-]+$/D'],'version'=>'required|integer|min:1','previous_id'=>'nullable|integer|min:1','data'=>'required|array','evidence'=>'required|string|min:3|max:1000']);
+        return $this->command($lot,$actor,'input',$d,$key,function($s)use($lot,$actor,$d){
+            $l=$this->lot($lot,$s);$data=$this->validateData($d['kind'],$d['data'],$l);$last=DB::table('ic_inputs')->where(['lot_id'=>$lot,'kind'=>$d['kind']])->orderByDesc('version')->first();
+            abort_unless($d['version']===($last?->version??0)+1&&($d['previous_id']??null)===$last?->id,409,'Versão anterior exacta necessária.');
+            if($last)abort_unless($last->source_ref===$d['source_ref'],409,'Identidade da origem não pode mudar.');
+            else abort_if(DB::table('ic_inputs')->where(['company_id'=>$s['company_id'],'source_ref'=>$d['source_ref']])->exists(),409,'Origem canónica já usada; não duplicar entre lotes, unidades ou directo/CIF.');
+            $id=DB::table('ic_inputs')->insertGetId($s+['lot_id'=>$lot,'kind'=>$d['kind'],'source_ref'=>$d['source_ref'],'version'=>$d['version'],'previous_id'=>$last?->id,'data'=>$this->json($data),'evidence'=>$d['evidence'],'actor_id'=>$actor,'created_at'=>now()]);return ['id'=>$id,'lot_id'=>$lot,'version'=>$d['version'],'kind'=>'input'];
+        });
+    }
+    private function compose(int $lot,array $refs): array {
+        abort_unless(array_diff(array_keys($refs),self::KINDS)===[]&&count($refs)===8,422,'Oito referências explícitas necessárias, incluindo taxa material ausente.');$rows=[];$versions=[];
+        foreach(self::KINDS as $kind){
+            $ref=$refs[$kind]??null;if($kind==='material_rate'&&$ref===null){$versions[$kind]=null;continue;}
+            abort_unless(is_array($ref),422,'Referência em falta: '.$kind);$r=$this->exact($ref,['id'=>'required|integer|min:1','version'=>'required|integer|min:1']);$rows[$kind]=$this->approvedInput($r['id'],$r['version'],$lot,$kind);$versions[$kind]=$r;
+        }
+        $l=DB::table('ic_lots')->find($lot);
+        foreach($rows as $r)$this->validateData($r->kind,$r->data,$l);
+        foreach(['material','labour'] as $kind)if(isset($rows[$kind.'_rate'])){ $rate=$rows[$kind.'_rate']->data;abort_unless($rate['source_id']===$rows[$kind]->id&&$rate['source_version']===$rows[$kind]->version,409,'Taxa não corresponde à origem seleccionada.'); }
+        $c=$rows['criterion']->data;abort_unless($c['pool_id']===$rows['pool']->id&&$c['pool_version']===$rows['pool']->version&&$c['machine_id']===$rows['machine']->id&&$c['machine_version']===$rows['machine']->version,409,'Critério incompatível com as origens seleccionadas.');
+        $n=fn($k)=>Number::of($rows[$k]->data['quantity']);$pool=$n('pool');$machine=$n('machine');$capacity=Number::of($c['capacity']);
+        abort_if($machine->isGreaterThan($capacity),409,'Utilização superior à capacidade aprovada; residual negativo recusado.');
+        $tax=$pool->dividedBy($capacity);$allocated=$tax->multipliedBy($machine);$residual=$pool->minus($allocated);$hours=Exact::hours($rows['labour']->data['quantity']);$labour=$hours->multipliedBy($rows['labour_rate']->data['amount']);
+        $material=isset($rows['material_rate'])?$n('material')->multipliedBy($rows['material_rate']->data['amount']):null;
+        $known=$labour->plus($allocated)->plus($material??0);$origins=$labour->plus($pool)->plus($material??0);$pending=$material===null?['Taxa do material em falta; material excluído da reconciliação monetária parcial.']:[];
+        $originsDetail=[];foreach($rows as $kind=>$r)$originsDetail[$kind]=['id'=>$r->id,'version'=>$r->version,'source_ref'=>$r->source_ref,'data'=>$r->data,'evidence'=>$r->evidence];
+        return ['policy'=>self::POLICY,'notice'=>self::NOTICE,'hypothesis'=>'Hipótese sintética de capacidade/imputação; não é método contabilístico real aprovado.','currency'=>'MZN','refs'=>$versions,'origins'=>$originsDetail,
+            'material_exact'=>$material===null?null:Exact::text($material),'labour_hours_exact'=>Exact::text($hours),'labour_exact'=>Exact::text($labour),'pool_exact'=>Exact::text($pool),'capacity_hm'=>Exact::text($capacity),'used_hm'=>Exact::text($machine),'indirect_rate_exact'=>Exact::text($tax),'allocated_exact'=>Exact::text($allocated),'residual_exact'=>Exact::text($residual),'known_cost_exact'=>Exact::text($known),'selected_total_exact'=>$pending?null:Exact::text($known),'good_units'=>Exact::text($n('production')),'unit_cost_exact'=>$pending?null:Exact::text($known->dividedBy($n('production'))),'incomplete'=>$pending!==[],'pending'=>$pending,
+            'reconciliation'=>['coverage'=>$pending?'partial_known_only':'scenario_scope','known_origins_exact'=>Exact::text($origins),'assigned_exact'=>Exact::text($known),'unassigned_exact'=>Exact::text($residual),'balanced'=>$origins->isEqualTo($known->plus($residual))]];
+    }
+    private function resultCurrent(object $r): bool {
+        if(!$this->current('result',$r))return false;
+        try{$snapshot=json_decode($r->snapshot,true,64,JSON_THROW_ON_ERROR);return hash_equals($r->fingerprint,hash('sha256',$this->json($this->compose($r->lot_id,$snapshot['refs']))));}
+        catch(\Symfony\Component\HttpKernel\Exception\HttpExceptionInterface){return false;}
+    }
+    public function calculate(int $lot,int $actor,array $in,string $key): array {
+        self::guard();$d=$this->exact($in,['version'=>'required|integer|min:1','previous_id'=>'nullable|integer|min:1','refs'=>'required|array','currency'=>'required|in:MZN']);
+        return $this->command($lot,$actor,'calculate',$d,$key,function($s)use($lot,$actor,$d){
+            $last=DB::table('ic_results')->where('lot_id',$lot)->orderByDesc('version')->first();abort_unless($d['version']===($last?->version??0)+1&&($d['previous_id']??null)===$last?->id,409,'Resultado mudou; rever versão anterior.');
+            $snapshot=$this->compose($lot,$d['refs']);$hash=hash('sha256',$this->json($snapshot));if($last&&hash_equals($last->fingerprint,$hash))return ['id'=>$last->id,'lot_id'=>$lot,'version'=>$last->version,'kind'=>'result','unchanged'=>true];
+            $id=DB::table('ic_results')->insertGetId($s+['lot_id'=>$lot,'version'=>$d['version'],'previous_id'=>$last?->id,'fingerprint'=>$hash,'snapshot'=>$this->json($snapshot),'actor_id'=>$actor,'created_at'=>now()]);return ['id'=>$id,'lot_id'=>$lot,'version'=>$d['version'],'kind'=>'result'];
+        });
+    }
+    public function decide(int $lot,int $actor,array $in,string $key): array {
+        self::guard();$d=$this->exact($in,['type'=>'required|in:input,result','id'=>'required|integer|min:1','version'=>'required|integer|min:1','decision'=>'required|in:approved,refused','reason'=>'required|string|min:3|max:1000']);
+        return $this->command($lot,$actor,'decide',$d,$key,function($s)use($lot,$actor,$d){
+            $r=$this->row($d['type'],$d['id'],$lot);abort_if($r->actor_id===$actor,403,'Validador deve ser distinto do preparador.');abort_unless($r->version===$d['version']&&$this->current($d['type'],$r),409,'Versão obsoleta.');
+            if($d['type']==='input')$this->validateData($r->kind,json_decode($r->data,true),$this->lot($lot,$s));else abort_unless($this->resultCurrent($r),409,'Dependências alteradas; preparar nova versão.');
+            $field=$d['type']==='input'?'input_id':'result_id';abort_if(DB::table('ic_decisions')->where($field,$r->id)->exists(),409,'Versão já decidida.');
+            $id=DB::table('ic_decisions')->insertGetId([$field=>$r->id,'version'=>$r->version,'decision'=>$d['decision'],'reason'=>$d['reason'],'actor_id'=>$actor,'created_at'=>now()]);return ['id'=>$id,'lot_id'=>$lot,'version'=>$r->version,'kind'=>'decision'];
+        });
+    }
+    public function listing(int $actor): array {
+        $s=$this->scope($actor,'view');if(!ServiceCalculation::isolated())return ['blocked'=>true,'lots'=>[],'notice'=>self::NOTICE];self::guard();
+        return DB::transaction(function()use($s){
+            DB::table('companies')->where('id',$s['company_id'])->lockForUpdate()->firstOrFail();$lots=[];
+            foreach(DB::table('ic_lots')->where($s)->orderBy('id')->get() as $l){
+                $inputs=DB::table('ic_inputs')->where('lot_id',$l->id)->orderBy('id')->get();foreach($inputs as $i){$i->current=$this->current('input',$i);$i->data=json_decode($i->data,true);$i->decision=DB::table('ic_decisions')->where('input_id',$i->id)->first();}
+                $results=DB::table('ic_results')->where('lot_id',$l->id)->orderBy('version')->get();foreach($results as $r){$r->current=$this->resultCurrent($r);$r->snapshot=json_decode($r->snapshot,true,64,JSON_THROW_ON_ERROR);$r->decision=DB::table('ic_decisions')->where('result_id',$r->id)->first();}
+                $lots[]=(array)$l+['product'=>DB::table('ic_products')->find($l->product_id),'inputs'=>$inputs->all(),'results'=>$results->all()];
+            }return ['blocked'=>false,'lots'=>$lots,'notice'=>self::NOTICE,'policy'=>self::POLICY];
+        });
+    }
+}

app/Modules/Workshop/DirectCosts.php

@@ -64,13 +64,13 @@ final class DirectCosts
             $id=DB::table('dc_rates')->insertGetId($s+array_merge($d,['order_id'=>$order,'amount'=>(string)BigDecimal::of($d['amount'])->stripTrailingZeros(),'actor_id'=>$actor,'created_at'=>now()]));return ['id'=>$id,'version'=>$d['version'],'kind'=>'rate'];
         });
     }
-    private function value(BigRational $n): string {try{return (string)$n->toBigDecimal()->stripTrailingZeros();}catch(\Brick\Math\Exception\RoundingNecessaryException){return (string)$n->simplified();}}
+    private function value(BigRational $n): string {return \App\Shared\Costs\ExactCostMath::text($n);}
     private function compose(int $order,array $lines): array {
         abort_unless(count($lines)===2,422,'Este ensaio exige um consumo e um tempo efectivos.');$out=[];$seen=[];$kinds=[];$pending=[];$sum=BigRational::of(0);
         foreach($lines as $line){
             $d=$this->exact($line,['entry_id'=>'required|integer|min:1','entry_version'=>'required|integer|min:1','rate_id'=>'present|nullable|integer|min:1','rate_version'=>'present|nullable|integer|min:1']);
             $e=$this->source($d['entry_id'],$d['entry_version'],$order);abort_if(isset($seen[$e->id]),422,'Origem duplicada.');$seen[$e->id]=true;$kinds[]=$e->kind;
-            $quantity=$e->kind==='time'?BigRational::of($e->minutes)->dividedBy(60):BigRational::of($e->quantity);
+            $quantity=$e->kind==='time'?\App\Shared\Costs\ExactCostMath::hours($e->minutes):BigRational::of($e->quantity);
             $rate=null;$cost=null;
             if($d['rate_id']!==null){
                 $r=$this->row('rate',$d['rate_id'],$order);

app/Shared/Costs/ExactCostMath.php

@@ -0,0 +1,10 @@
+<?php
+namespace App\Shared\Costs;
+use Brick\Math\BigRational;
+final class ExactCostMath {
+    public static function hours(string|int $minutes): BigRational {return BigRational::of($minutes)->dividedBy(60);}
+    public static function text(BigRational $n): string {
+        try{return (string)$n->toBigDecimal()->stripTrailingZeros();}
+        catch(\Brick\Math\Exception\RoundingNecessaryException){return (string)$n->simplified();}
+    }
+}

database/migrations/2026_10_27_100000_create_industrial_cost_simulation.php

@@ -0,0 +1,16 @@
+<?php
+use Illuminate\Database\Migrations\Migration;
+use Illuminate\Support\Facades\DB;
+return new class extends Migration {
+    public function up(): void {
+        $old=substr(DB::selectOne("SELECT pg_get_constraintdef(oid) AS d FROM pg_constraint WHERE conrelid='permission_grants'::regclass AND conname='permission_grants_scope_check'")->d,6);
+        DB::statement('ALTER TABLE permission_grants DROP CONSTRAINT permission_grants_scope_check');
+        DB::statement("ALTER TABLE permission_grants ADD CONSTRAINT permission_grants_scope_check CHECK (($old) OR (permission IN ('industrial_costs.view','industrial_costs.prepare','industrial_costs.validate') AND unit_id IS NOT NULL))");
+        DB::unprepared(file_get_contents(__DIR__.'/../sql/industrial-costs.sql'));
+        foreach(['ic_products','ic_lots','ic_inputs','ic_results','ic_decisions','ic_commands','ic_events','ic_outbox'] as $t){
+            DB::statement("CREATE TRIGGER {$t}_immutable BEFORE UPDATE OR DELETE ON {$t} FOR EACH ROW EXECUTE FUNCTION sgf_append_only_audit()");
+            DB::statement("CREATE TRIGGER {$t}_test_only BEFORE INSERT ON {$t} FOR EACH ROW EXECUTE FUNCTION sgf_ic_test_only()");
+        }
+    }
+    public function down(): void {throw new RuntimeException('Industrial cost history requires a reviewed preservation procedure.');}
+};

database/sql/industrial-costs.sql

@@ -0,0 +1,106 @@
+CREATE TABLE ic_products (
+ id bigserial PRIMARY KEY,tenant_id bigint NOT NULL,company_id bigint NOT NULL,unit_id bigint NOT NULL,
+ reference text NOT NULL,name text NOT NULL,version integer NOT NULL CHECK(version=1),unit text NOT NULL CHECK(unit='UN'),
+ actor_id bigint NOT NULL REFERENCES users(id),created_at timestamptz NOT NULL,
+ UNIQUE(company_id,reference),FOREIGN KEY(tenant_id,company_id,unit_id) REFERENCES units(tenant_id,company_id,id)
+);
+CREATE TABLE ic_lots (
+ id bigserial PRIMARY KEY,tenant_id bigint NOT NULL,company_id bigint NOT NULL,unit_id bigint NOT NULL,
+ product_id bigint NOT NULL REFERENCES ic_products(id),reference text NOT NULL,centre text NOT NULL,
+ period_start date NOT NULL,period_end date NOT NULL CHECK(period_end>=period_start),currency text NOT NULL CHECK(currency='MZN'),
+ actor_id bigint NOT NULL REFERENCES users(id),created_at timestamptz NOT NULL,
+ UNIQUE(company_id,reference),FOREIGN KEY(tenant_id,company_id,unit_id) REFERENCES units(tenant_id,company_id,id)
+);
+CREATE TABLE ic_inputs (
+ id bigserial PRIMARY KEY,tenant_id bigint NOT NULL,company_id bigint NOT NULL,unit_id bigint NOT NULL,
+ lot_id bigint NOT NULL REFERENCES ic_lots(id),kind text NOT NULL CHECK(kind IN ('material','labour','pool','machine','production','material_rate','labour_rate','criterion')),
+ source_ref text NOT NULL CHECK(source_ref LIKE 'IND-TEST-%'),version integer NOT NULL CHECK(version>0),previous_id bigint UNIQUE REFERENCES ic_inputs(id),
+ data jsonb NOT NULL,evidence text NOT NULL CHECK(length(evidence)>=3),actor_id bigint NOT NULL REFERENCES users(id),created_at timestamptz NOT NULL,
+ UNIQUE(lot_id,kind,version),UNIQUE(company_id,source_ref,version),FOREIGN KEY(tenant_id,company_id,unit_id) REFERENCES units(tenant_id,company_id,id)
+);
+CREATE TABLE ic_results (
+ id bigserial PRIMARY KEY,tenant_id bigint NOT NULL,company_id bigint NOT NULL,unit_id bigint NOT NULL,
+ lot_id bigint NOT NULL REFERENCES ic_lots(id),version integer NOT NULL CHECK(version>0),previous_id bigint UNIQUE REFERENCES ic_results(id),
+ fingerprint text NOT NULL,snapshot jsonb NOT NULL,actor_id bigint NOT NULL REFERENCES users(id),created_at timestamptz NOT NULL,
+ UNIQUE(lot_id,version),FOREIGN KEY(tenant_id,company_id,unit_id) REFERENCES units(tenant_id,company_id,id)
+);
+CREATE TABLE ic_decisions (
+ id bigserial PRIMARY KEY,input_id bigint UNIQUE REFERENCES ic_inputs(id),result_id bigint UNIQUE REFERENCES ic_results(id),
+ version integer NOT NULL CHECK(version>0),decision text NOT NULL CHECK(decision IN ('approved','refused')),reason text NOT NULL CHECK(length(reason)>=3),
+ actor_id bigint NOT NULL REFERENCES users(id),created_at timestamptz NOT NULL,CHECK(num_nonnulls(input_id,result_id)=1)
+);
+CREATE TABLE ic_commands (
+ id bigserial PRIMARY KEY,tenant_id bigint NOT NULL,company_id bigint NOT NULL,unit_id bigint NOT NULL,
+ lot_id bigint NOT NULL REFERENCES ic_lots(id),actor_id bigint NOT NULL REFERENCES users(id),action text NOT NULL CHECK(action IN ('open','input','calculate','decide')),
+ command_key text NOT NULL,request_hash text NOT NULL,result jsonb NOT NULL,created_at timestamptz NOT NULL,
+ UNIQUE(company_id,unit_id,actor_id,action,command_key),FOREIGN KEY(tenant_id,company_id,unit_id) REFERENCES units(tenant_id,company_id,id)
+);
+CREATE TABLE ic_events(id bigserial PRIMARY KEY,command_id bigint NOT NULL UNIQUE REFERENCES ic_commands(id),schema_version integer NOT NULL CHECK(schema_version=1),payload jsonb NOT NULL,created_at timestamptz NOT NULL);
+CREATE TABLE ic_outbox(event_id bigint PRIMARY KEY REFERENCES ic_events(id),state text NOT NULL CHECK(state='captured_no_stock_or_accounting'));
+CREATE OR REPLACE FUNCTION sgf_ic_environment() RETURNS void LANGUAGE plpgsql AS $$
+BEGIN IF current_database() IS DISTINCT FROM 'sgf_tempo_test' OR inet_server_port() IS DISTINCT FROM 55432 THEN RAISE EXCEPTION 'SGF_IC_TEST_DATABASE_ONLY'; END IF; END; $$;
+CREATE OR REPLACE FUNCTION sgf_ic_test_only() RETURNS trigger LANGUAGE plpgsql AS $$
+BEGIN PERFORM sgf_ic_environment(); RETURN NEW; END; $$;
+CREATE OR REPLACE FUNCTION sgf_ic_input_current(iid bigint,lid bigint,ver integer) RETURNS void LANGUAGE plpgsql AS $$
+BEGIN
+ IF NOT EXISTS(SELECT 1 FROM ic_inputs i JOIN ic_decisions d ON d.input_id=i.id AND d.version=i.version AND d.decision='approved' WHERE i.id=iid AND i.lot_id=lid AND i.version=ver)
+ OR EXISTS(SELECT 1 FROM ic_inputs WHERE previous_id=iid) THEN RAISE EXCEPTION 'SGF_IC_INPUT_NOT_CURRENT_APPROVED'; END IF;
+END; $$;
+CREATE OR REPLACE FUNCTION sgf_ic_guard() RETURNS trigger LANGUAGE plpgsql AS $$
+DECLARE l ic_lots; p record; target record; i ic_inputs; v integer; lid bigint; ref jsonb;
+BEGIN
+ PERFORM sgf_ic_environment();
+ IF TG_TABLE_NAME='ic_products' THEN PERFORM 1 FROM companies WHERE id=NEW.company_id FOR UPDATE; RETURN NEW; END IF;
+ IF TG_TABLE_NAME='ic_lots' THEN
+  PERFORM 1 FROM companies WHERE id=NEW.company_id FOR UPDATE;
+  IF NOT EXISTS(SELECT 1 FROM ic_products WHERE id=NEW.product_id AND ROW(tenant_id,company_id,unit_id)=ROW(NEW.tenant_id,NEW.company_id,NEW.unit_id)) THEN RAISE EXCEPTION 'SGF_IC_PRODUCT_SCOPE'; END IF; RETURN NEW;
+ END IF;
+ IF TG_TABLE_NAME='ic_decisions' THEN
+  IF NEW.input_id IS NOT NULL THEN SELECT lot_id INTO STRICT lid FROM ic_inputs WHERE id=NEW.input_id;
+  ELSE SELECT lot_id INTO STRICT lid FROM ic_results WHERE id=NEW.result_id; END IF;
+ ELSE lid=NEW.lot_id; END IF;
+ SELECT * INTO STRICT l FROM ic_lots WHERE id=lid; PERFORM 1 FROM companies WHERE id=l.company_id FOR UPDATE;
+ IF TG_TABLE_NAME='ic_decisions' THEN
+  IF NEW.input_id IS NOT NULL THEN
+   SELECT id,version,actor_id INTO STRICT target FROM ic_inputs WHERE id=NEW.input_id;
+   IF EXISTS(SELECT 1 FROM ic_inputs WHERE previous_id=target.id) THEN RAISE EXCEPTION 'SGF_IC_OLD_INPUT'; END IF;
+  ELSE
+   SELECT id,version,actor_id INTO STRICT target FROM ic_results WHERE id=NEW.result_id;
+   IF EXISTS(SELECT 1 FROM ic_results WHERE previous_id=target.id) THEN RAISE EXCEPTION 'SGF_IC_OLD_RESULT'; END IF;
+   FOR ref IN SELECT value FROM ic_results r,jsonb_each(r.snapshot->'refs') WHERE r.id=target.id LOOP
+    IF ref<>'null'::jsonb THEN PERFORM sgf_ic_input_current((ref->>'id')::bigint,lid,(ref->>'version')::integer); END IF;
+   END LOOP;
+  END IF;
+  IF target.actor_id=NEW.actor_id OR target.version<>NEW.version THEN RAISE EXCEPTION 'SGF_IC_SEPARATION_VERSION'; END IF; RETURN NEW;
+ END IF;
+ IF ROW(NEW.tenant_id,NEW.company_id,NEW.unit_id) IS DISTINCT FROM ROW(l.tenant_id,l.company_id,l.unit_id) THEN RAISE EXCEPTION 'SGF_IC_SCOPE'; END IF;
+ IF TG_TABLE_NAME='ic_commands' THEN RETURN NEW; END IF;
+ IF TG_TABLE_NAME='ic_inputs' THEN
+  SELECT coalesce(max(version),0) INTO v FROM ic_inputs WHERE lot_id=lid AND kind=NEW.kind;
+  IF NEW.version<>v+1 OR (v=0 AND NEW.previous_id IS NOT NULL) THEN RAISE EXCEPTION 'SGF_IC_VERSION'; END IF;
+  IF v>0 THEN SELECT * INTO STRICT p FROM ic_inputs WHERE id=NEW.previous_id AND lot_id=lid AND kind=NEW.kind AND version=v;
+   IF p.source_ref<>NEW.source_ref THEN RAISE EXCEPTION 'SGF_IC_ORIGIN_TRANSFER'; END IF;
+  END IF;
+  IF NEW.kind IN ('material','labour','machine','production') AND ((NEW.data->>'quantity')::numeric<=0 OR (NEW.data->>'quantity')::numeric<>trunc((NEW.data->>'quantity')::numeric,8)) THEN RAISE EXCEPTION 'SGF_IC_QUANTITY'; END IF;
+  IF NEW.kind='criterion' AND ((NEW.data->>'capacity')::numeric<=0 OR NEW.data->>'driver_unit' IS DISTINCT FROM 'HM' OR NEW.data->>'hypothesis' IS DISTINCT FROM 'synthetic_only') THEN RAISE EXCEPTION 'SGF_IC_CAPACITY'; END IF;
+  IF NEW.kind IN ('material_rate','labour_rate') THEN
+   SELECT * INTO STRICT i FROM ic_inputs WHERE id=(NEW.data->>'source_id')::bigint AND lot_id=lid AND version=(NEW.data->>'source_version')::integer;
+   IF i.kind<>replace(NEW.kind,'_rate','') OR (NEW.data->>'amount')::numeric<0 OR NEW.data->>'currency' IS DISTINCT FROM 'MZN' OR NEW.data->>'unit' IS DISTINCT FROM (CASE WHEN i.kind='material' THEN 'KG' ELSE 'H' END) THEN RAISE EXCEPTION 'SGF_IC_RATE'; END IF;
+  END IF;
+ ELSE
+  SELECT coalesce(max(version),0) INTO v FROM ic_results WHERE lot_id=lid;
+  IF NEW.version<>v+1 OR NEW.snapshot->>'policy' IS DISTINCT FROM 'INDUSTRIAL-COST-SIM-v1' OR NEW.snapshot->>'currency' IS DISTINCT FROM 'MZN' THEN RAISE EXCEPTION 'SGF_IC_VERSION_POLICY'; END IF;
+  IF v=0 THEN IF NEW.previous_id IS NOT NULL THEN RAISE EXCEPTION 'SGF_IC_PREVIOUS'; END IF;
+  ELSE PERFORM 1 FROM ic_results WHERE id=NEW.previous_id AND lot_id=lid AND version=v; IF NOT FOUND THEN RAISE EXCEPTION 'SGF_IC_PREVIOUS'; END IF; END IF;
+  FOR ref IN SELECT value FROM jsonb_each(NEW.snapshot->'refs') LOOP
+   IF ref<>'null'::jsonb THEN PERFORM sgf_ic_input_current((ref->>'id')::bigint,lid,(ref->>'version')::integer); END IF;
+  END LOOP;
+ END IF;
+ RETURN NEW;
+EXCEPTION WHEN NO_DATA_FOUND THEN RAISE EXCEPTION 'SGF_IC_REFERENCE'; END; $$;
+CREATE TRIGGER ic_product_integrity BEFORE INSERT ON ic_products FOR EACH ROW EXECUTE FUNCTION sgf_ic_guard();
+CREATE TRIGGER ic_lot_integrity BEFORE INSERT ON ic_lots FOR EACH ROW EXECUTE FUNCTION sgf_ic_guard();
+CREATE TRIGGER ic_input_integrity BEFORE INSERT ON ic_inputs FOR EACH ROW EXECUTE FUNCTION sgf_ic_guard();
+CREATE TRIGGER ic_result_integrity BEFORE INSERT ON ic_results FOR EACH ROW EXECUTE FUNCTION sgf_ic_guard();
+CREATE TRIGGER ic_decision_integrity BEFORE INSERT ON ic_decisions FOR EACH ROW EXECUTE FUNCTION sgf_ic_guard();
+CREATE TRIGGER ic_command_integrity BEFORE INSERT ON ic_commands FOR EACH ROW EXECUTE FUNCTION sgf_ic_guard();

docs/INDUSTRIAL_COST_ACCOUNTING_SCOPE.md

@@ -250,3 +250,71 @@ Guardar a origem e versão da taxa, a unidade, moeda, composição e pendências
 **Osmane prepara; Samira valida a versão dos custos e das taxas.** Samira pode validar/recusar a proposta de custos, sem editar os apontamentos técnicos ou receber supervisão técnica por consequência. Testes futuros com identidades sintéticas distintas entre preparação e validação. Nenhuma nova concessão real é autorizada por estas decisões.
 
 Lote industrial e custos indirectos ficam para incremento seguinte. Sem stock, compras, salários reais, facturação, IVA, recebimentos, lançamentos, fecho ou publicação. Manter bloqueios operacionais/fiscais e isolamento em `sgf_tempo_test` nas futuras provas. Esta confirmação fecha as decisões do recorte; não constitui ordem de implementação, migração, concessão ou activação operacional.
+
+## 15. Retoma do ensaio industrial — recorte para aprovação
+
+27/10/2026. O utilizador propôs retomar um lote/produto com custos indirectos, primeiro em especificação. O custo directo da secção 14 já foi entregue, encerrado e instalado tecnicamente: ver [entrega](WORKSHOP_DIRECT_COST_DELIVERY.md), [encerramento](WORKSHOP_DIRECT_COST_ACCEPTANCE.md) e checkpoint `d10ba06`. `090000` e quatro direitos foram aplicados por autorização posterior, sem taxas/cálculos em desenvolvimento ou activação real. Oficinas e recebimentos mantêm as suas entregas e instalações; não se reabrem aprovações.
+
+### 15.1 Proposta mínima INDUSTRIAL-COST-SIM-v1
+
+Uma empresa/unidade sintéticas, um período de teste identificado, MZN explícito, um centro sintético, um produto em UN, um lote concluído de etapa única e 10 UN boas verificadas. Sem produção em curso, perdas/retrabalho, vendas ou segundo lote. É prova de gestão; não escolhe indústria, método de custeio, referencial ou política de inventário para empresa real.
+
+Recomenda-se reutilizar os valores já especificados na secção 8, sem recalibrar o ensaio aceite de 275 MZN:
+
+| Componente / origem própria identificada | Dados sintéticos explícitos | Resultado esperado |
+| --- | --- | ---: |
+| Material directo | Consumo líquido 20 KG × 50 MZN/KG | 1 000 MZN |
+| Trabalho directo | 300 MIN efectivos ÷ 60 × 100 MZN/H | 500 MZN |
+| Conjunto CIF do período | Uma origem de 600 MZN, declarada elegível apenas no ensaio | 600 MZN de origem |
+| Critério CIF v1 | Capacidade sintética do período 10 HM; lote usa 5 HM; taxa exacta 600/10 | 60 MZN/HM |
+| CIF imputados ao lote | 5 HM × 60 MZN/HM | 300 MZN |
+| Custo atribuído ao lote no perímetro do ensaio | 1 000 + 500 + 300 | **1 800 MZN** |
+| Custo por UN boa no mesmo perímetro | 1 800 ÷ 10 UN | **180 MZN/UN** |
+| Residual CIF | 600 − 300 | **300 MZN por imputar** |
+
+As 5 HM são uma medição sintética própria de utilização da máquina, não inferidas das 5 H de trabalho humano. Capacidade normal de 10 HM é pressuposto de teste explícito, sem alegar validação legal ou empresarial. O residual decorre da base não utilizada sob esse pressuposto; não é falha de arredondamento e não é convertido automaticamente em custo do produto ou despesa contabilística.
+
+Reconciliação do conjunto: **600 = 300 imputados + 300 por imputar**. Reconciliação global: **2 100 de origens = 1 800 atribuídos + 300 por imputar**. Os 300 imputados não são uma nova origem a somar aos 600. Não elevar a taxa para absorver o residual nem alterar capacidade para fechar a soma.
+
+Variante obrigatória: taxa do material ausente, quantidade 20 KG preservada. Mostrar **800 MZN atribuídos conhecidos** (500 + 300), material pendente e custo total/unitário completo indisponíveis. Reconciliação parcial identificada: **1 100 conhecidos = 800 atribuídos conhecidos + 300 por imputar**; componente material excluída dessa igualdade por falta de valor. Zero indicado e validado é distinto de ausência.
+
+Previsto versus realizado da secção 8 fica para evolução posterior, para manter este primeiro incremento pequeno. Não se acrescentam preços, margens, depreciações reais ou documentos de compra/salário. Produção concluída aqui é estado físico de teste, não fecho contabilístico.
+
+### 15.2 Reutilização concreta e delta necessário
+
+| Base já entregue | Reutilização delimitada | Trabalho novo mínimo |
+| --- | --- | --- |
+| Contexto, pertenças, concessões e guardas | Mesmo isolamento por empresa/unidade e bloqueio real | Direitos industriais explícitos, sem herança dos direitos `direct_costs.*` |
+| Exactidão racional do custo directo, MIN/H e estados de completude | Mesmo comportamento sem float, truncagem de IVA ou divisão arredondada silenciosamente | Composição industrial, CIF/HM e custo por UN; fracção exacta se não finita |
+| Origem/versão, taxa/versão, decisões distintas e fotografia de composição | Referências e dependências preservadas; mudança sinaliza resultado antigo, não o reescreve | Produto/lote, produção boa, conjunto CIF, critério e execução de imputação versionados |
+| Comandos transaccionais, auditoria, eventos/outbox, replay e concorrência | Reutilizar padrões e verificações, sem activar consumidores contabilísticos | Impedir dupla elegibilidade/directo-CIF e dupla imputação, controlar residual |
+| Apontamentos técnicos de oficina | Se forem efectivamente a origem de uma parcela autorizada, referenciar o mesmo ID/versão, sem recaptura | Vínculo de destino explícito; nenhuma conversão automática de oficina em lote |
+
+O código actual `DirectCosts` é delimitado a duas origens verificadas de oficina e não é já um motor industrial genérico. A futura implementação deve extrair/reutilizar apenas a aritmética pura necessária e preservar o contrato/testes aceites, acrescentando um adaptador de origens industriais. Não alargar silenciosamente as regras ou tabelas `wo_*`/`dc_*` para fingir produção.
+
+As novas quantidades industriais acima representam acontecimentos sintéticos diferentes dos apontamentos de 2 UN/105 MIN da oficina. Não copiar esses apontamentos como se fossem os consumos de 20 KG/300 MIN do lote. Cada origem tem tipo, ID, versão, unidade, âmbito e propósito. Se uma mesma parcela real/sintética for usada por ligação autorizada, é uma só origem, com saldo elegível controlado entre destinos, sem nova captura. Não somar o resultado agregado de 275 e as suas componentes como origens independentes.
+
+Primeiro recorte: origens, valorização, conjunto e critério preparados → submetidos → validados/recusados por identidade distinta; cálculo sob versões validadas → resultado com composição e residual → validação da versão exacta. Dados em falta permanecem condicionados; uma validação não inventa a informação ausente. Alterações exigem nova versão/revisão, preservando resultados aprovados anteriores e sinalizando desactualização.
+
+### 15.3 Provas mínimas para futura execução
+
+- Demonstrar 1 800 atribuídos, 180/UN e residual 300, com as duas reconciliações acima e a variante incompleta de 800.
+- Seleccionar explicitamente versões de origens, taxas, conjunto e critério. Sem critério/taxa/unidade/moeda/capacidade demonstrados, recusar imputação integral; não assumir zero ou configuração mais recente.
+- Quantidade boa zero/desconhecida não produz custo unitário. Base do lote superior ao denominador/capacidade aprovada é conflito, não autorização de residual negativo. Denominador zero/ausente impede dividir.
+- Impedir que a mesma parcela seja directa e CIF, imputada duas vezes ou usada além do elegível. Não criar dois eventos de consumo para oficina/indústria. Distinguir quantidade física de parcela monetária de custo.
+- Correcção de origem/taxa/capacidade/critério exige nova revisão; aprovação antiga e repetição/concorrência não duplicam efeitos ou reescrevem história. Falha de evento/outbox desfaz o comando; resposta perdida recupera resultado idempotente.
+- Login real e separação de preparador/validador com identidades sintéticas distintas, sem concessões reais; negar acesso entre empresas/unidades e custos a quem só consulta apontamentos técnicos. Revogação tem efeito no pedido seguinte.
+- Testes e navegador só em `sgf_tempo_test`, com aplicação normal inalterada. Qualquer migração em desenvolvimento e novas concessões reais terão delta/proposta separados e confirmação específica. Manter bloqueios de custos, emissão, recebimentos, stock e lançamentos reais.
+
+### 15.4 Decisões novas para fechar o recorte
+
+1. **Aceitar os números e limites do ensaio acima**, incluindo 10 UN, uma etapa, CIF sintéticos de 600 MZN, capacidade 10 HM, utilização 5 HM e residual 300, sem adoptar estes pressupostos como política real. Previsto/realizado fica fora deste primeiro recorte.
+2. **Responsabilidade industrial proposta:** Osmane prepara origens/valorizações, conjunto, critério e cálculo; Samira valida/recusa as versões de custos, critério e resultado, sem editar execução técnica. É extensão a confirmar para este ensaio, não consequência automática do papel já aprovado no custo directo. Provas apenas com equivalentes sintéticos; nenhuma concessão real por esta decisão.
+
+Exactidão, ausência diferente de zero, origem única, histórico, isolamento e bloqueios já estão definidos e não são pedidos novamente. Não é preciso identificar uma indústria real ou reabrir o cotejo fiscal para provar estes pressupostos sintéticos. A futura activação real exige âmbito e suporte próprios. **Esta secção continua documental: não autoriza implementação ou execução do ensaio.**
+
+### 15.5 Confirmação do recorte pelo utilizador
+
+Em 27/10/2026, após a confirmação dos números e limites, o utilizador respondeu «sim». Ficam aprovadas as duas decisões da secção 15.4: números e perímetro sintéticos da secção 15.1, com residual separado e variante incompleta; Osmane prepara e Samira valida/recusa versões do critério e do resultado, apenas com identidades sintéticas distintas nas provas e sem concessões reais.
+
+O critério de capacidade/imputação continua hipótese de ensaio, não método contabilístico real aprovado. Previsto/realizado fica para depois. Não se reabrem estas decisões; a autorização para implementar código/testes, futuras migrações em desenvolvimento, concessões ou activação real continua separada. Este registo não executa o ensaio.

docs/INDUSTRIAL_COST_DELIVERY.md

@@ -0,0 +1,89 @@
+# INDUSTRIAL-COST-SIM-v1 — entrega técnica isolada
+
+27/10/2026, Africa/Johannesburg. Implementação delimitada pelas secções 15 e 15.5 de [INDUSTRIAL_COST_ACCOUNTING_SCOPE.md](INDUSTRIAL_COST_ACCOUNTING_SCOPE.md). **Sem aceitação presumida ou checkpoint de encerramento.** Preservados `d10ba06`, `7628645`, alterações posteriores, oficinas, recebimentos, cálculo fiscal e aprovações existentes. Não se acedeu ao InvesteMoz nem se repetiu investigação fiscal.
+
+## O que funciona
+
+Lote com identidade própria, produto sintético, centro, empresa/unidade, período e MZN explícitos. Origens industriais identificadas e versionadas para consumo de material, trabalho efectivo, conjunto indirecto, utilização da máquina e produção boa concluída; taxas de material/trabalho e critério com versões e fontes explícitas. As origens são novas ocorrências sintéticas do lote, não cópias dos apontamentos da oficina nem transformação de uma ordem técnica em produção.
+
+Preparador propõe versões; validador distinto aprova/recusa dados/taxas/critério e resultado exactos. A validação dos dados sintéticos de custo não é verificação técnica de execução real. Alterações conservam a identidade da origem e exigem sucessora explícita; dados, taxas e critério desactualizados não são escolhidos automaticamente. Calcular exige referências exactas a versões actuais aprovadas; taxa de material pode ficar explicitamente ausente.
+
+Resultado guarda composição, referências e versões, fórmula/base, moeda, residual, cobertura da reconciliação e pendências. Alteração de origem/taxa/critério invalida a actualidade dos dependentes, sem reescrever fotografias ou decisões anteriores. Novo cálculo cria versão com anterior explícita; composição idêntica à última pode recuperar o mesmo resultado. Só a última versão elegível representa a imputação actual; resultados históricos não se acumulam como novas utilizações do conjunto.
+
+## Números demonstrados
+
+| Componente | Composição exacta | Custo atribuído |
+| --- | --- | ---: |
+| Material | 20 KG × 50 MZN/KG | 1 000 MZN |
+| Trabalho | 300 MIN ÷ 60 × 100 MZN/H | 500 MZN |
+| Indirectos | Conjunto 600 MZN ÷ capacidade 10 HM = 60 MZN/HM; 5 HM × 60 | 300 MZN |
+| **Lote / perímetro sintético** | 10 UN boas | **1 800 MZN; 180 MZN/UN** |
+| **Residual separado** | 600 − 300 | **300 MZN por imputar** |
+
+Conjunto: **600 = 300 imputados + 300 por imputar**. Perímetro: **2 100 origens = 1 800 atribuídos + 300 por imputar**. As 5 HM são medição própria da máquina, não deduzidas das 5 H humanas. Capacidade e elegibilidade são pressupostos identificados **apenas do ensaio**, não método contabilístico real aprovado. O residual não é redistribuído, convertido em despesa ou lançado.
+
+Sem taxa do material: **800 MZN conhecidos** (500 + 300), total e custo unitário definitivo indisponíveis; quantidade 20 KG preservada, com pendência. Reconciliação **parcial**: **1 100 conhecidos = 800 atribuídos conhecidos + 300 por imputar**, excluindo o material sem valor conhecido. Uma validação desse resultado valida só o perímetro conhecido e não elimina a pendência. Taxa zero indicada/aprovada é distinta de ausência, provada por teste.
+
+## Reutilização e segurança
+
+Extraída `app/Shared/Costs/ExactCostMath.php` da representação racional/conversão MIN/H do custo directo, usada agora por ambos os percursos. Preservado o contrato da entrega de custo directo e executada a sua regressão. Não há float, redução silenciosa de precisão ou reutilização da política de truncagem do IVA. Decimais não negativos até 16 algarismos inteiros/8 decimais nas entradas; quantidades/capacidade positivas quando necessárias. Divisão não finita conserva fracção exacta (teste `800/3`), sem escolher regra fiscal ou arredondamento implícito.
+
+Direitos novos de unidade `industrial_costs.view/prepare/validate`, sem herança dos direitos de custo directo/contabilidade/gestão. Contexto, empresa/unidade, pertenças e acção revalidados no servidor, incluindo replay e dentro da transacção. Auto-aprovação recusada mesmo com ambos os poderes. Não há nomes/emails especiais no código funcional.
+
+Bloqueio por empresa serializa comandos e revisões; idempotência inclui âmbito, autor, acção e conteúdo. Chave repetida com outro conteúdo é conflito. Comando, auditoria, evento e outbox atómicos: falha de outbox desfaz efeitos; resposta perdida recupera o ID. Outbox `captured_no_stock_or_accounting`, sem consumidor contabilístico ou integração externa.
+
+Origem canónica única por empresa/referência/versão, com cadeia imutável ligada ao lote e tipo. Não pode mudar de material directo para conjunto indirecto ou reaparecer noutro lote/unidade com a mesma identidade. Cada lote tem no máximo uma cadeia por tipo neste recorte; o conjunto pertence exclusivamente ao lote, sem partilha entre lotes. Isso evita uma segunda imputação activa da mesma parcela sem construir um motor geral de repartições. Identidades diferentes não são deduplicadas por coincidência de descrição/valor.
+
+FKs, versões únicas e triggers reforçam contexto, referências, decisões separadas, fontes aprovadas e imutabilidade contra operações em massa. A composição exacta e autorização autenticada são verificadas pela aplicação; os triggers não são RLS nem uma implementação independente de todo o motor. SQL administrativo é uma fronteira de confiança distinta.
+
+`IndustrialCosts::guard()` exige ambiente isolado e `TestingDatabaseGuard` confirma `sgf_tempo_test`, porta 55432 e papel `sgf_test_runner`. INSERT nas oito tabelas industriais também exige a base de testes no SQL. Não existe opção de activação real. Guardas de oficinas, recebimentos, custo directo e emissão permanecem preservadas.
+
+## Testes e percurso no navegador
+
+Resultados em [industrial-cost-tests.json](proofs/industrial-cost-tests.json); [seis provas concorrentes](proofs/industrial-cost-concurrency.json), [resultados do navegador](proofs/industrial-cost-browser-results.json), [cenário de 1 800](proofs/industrial-cost-1800-browser.png) e [cenário incompleto](proofs/industrial-cost-800-browser.png).
+
+Resultado final: **58 testes / 1 185 asserções, zero erros/falhas**, incluindo nove casos industriais e regressão do custo directo/oficinas/recebimentos/B1/guardas. **Seis provas de concorrência aprovadas**, com processos realmente sobrepostos. Compilação aprovada com Vite 8.3.5, sem alterações de dependências. Instância do navegador parada antes da regressão final. `migrate:status` normal confirmou `100000` pendente; não houve migração ou concessão em desenvolvimento.
+
+Prova efectivamente realizada no Edge, `http://127.0.0.1:8001`, apenas `sgf_tempo_test`, sessões/cache isolados e CSRF activo. Login real, sem usar `actingAs` como demonstração:
+
+1. Fixture cria um lote/produto e sete dados/taxas pelas operações do módulo, com validação sintética distinta; não preenche critério ou cálculos e não cria `wo_*`/`dc_*`.
+2. Preparador `gestor@example.test` entra em Empresa Horizonte — Demonstração / Unidade Central — Demonstração → **Custos industriais de teste**. Prepara `IND-TEST-CRITERIO-BROWSER` v1, seleccionando conjunto/utilização exactos, capacidade 10 HM e evidência da hipótese.
+3. Validador `consulta@example.test` entra separadamente e valida a versão do critério; não recebe formulário de preparação nem poderes técnicos por consequência.
+4. Preparador selecciona explicitamente as oito referências validadas e calcula 1 800 MZN / 180 por UN. Validador revê composição, as duas reconciliações e residual 300, e aprova a versão exacta.
+5. Preparador cria nova versão com taxa material ausente; validador aprova apenas os 800 conhecidos, total/unitário indisponíveis e reconciliação parcial, sem esconder pendências. Resultado anterior preservado como histórico.
+
+IDs desta execução: lote #10, origens/taxas #71–77 e critério #78; não são IDs fixos numa repetição. Credenciais aleatórias no manifesto local protegido, nunca mostradas/versionadas. A prova foi conferida por script guardado; zero eventos técnicos de oficina e zero cálculos de custo directo criados pelo ensaio industrial.
+
+Seis cenários com dois processos sobrepostos: mesma revisão de critério; mesma decisão; critérios sucessores incompatíveis; mesmo cálculo; cálculos concorrentes com uma só revisão vencedora; resultado novo versus aprovação antiga. A recuperação após falha de outbox e perda de resposta está coberta por testes transaccionais. Outras provas: moedas/unidades/quantidades, denominador zero/ausente, utilização acima da capacidade, produção não concluída/zero, origem duplicada entre tipos/lotes, versão recusada/obsoleta, correcção de origem que exige taxa nova, revogação no pedido seguinte, empresa irmã/unidade sem acesso e imutabilidade SQL.
+
+Repetição local, com a prova do navegador parada antes dos testes destrutivos:
+
+```powershell
+powershell -NoProfile -ExecutionPolicy Bypass -File scripts/sgf.ps1 test '--filter=IndustrialCostsTest|DirectCostsTest|WorkshopTest|ServiceReceivablesTest|InternalConfirmationTest|DatabaseSafetyTest'
+powershell -NoProfile -ExecutionPolicy Bypass -File scripts/sgf.ps1 npm run build
+```
+
+Para navegador, preparar somente a base de testes vazia sob as guardas existentes; executar `scripts/browser-proof.ps1 start` e depois `sgf.ps1 php scripts/industrial-cost-fixture.php --env=testing`. Seguir os passos acima com a credencial do manifesto protegido. Os preparadores recusam estado preenchido, sem apagar dados para continuar. Após o percurso, `sgf.ps1 php scripts/industrial-cost-proof.php --env=testing`, depois `sgf.ps1 php scripts/industrial-cost-concurrency.php --env=testing`. Parar com `scripts/browser-proof.ps1 stop`. Não parar processos de outros projectos para libertar portas. As provas persistem em ficheiros; a regressão final recria apenas a base de testes.
+
+## Migração proposta — NÃO aplicada em desenvolvimento
+
+**`2026_10_27_100000_create_industrial_cost_simulation.php`**, SQL `database/sql/industrial-costs.sql`, destino futuro proposto **`sgf_tempo_dev`**, exigindo confirmação específica antes de qualquer aplicação.
+
+Cria oito tabelas: `ic_products`, `ic_lots`, `ic_inputs`, `ic_results`, `ic_decisions`, `ic_commands`, `ic_events`, `ic_outbox`, mais índices, FKs e funções/triggers próprios de integridade, ambiente e imutabilidade. Amplia o CHECK de concessões com três nomes industriais de unidade, preservando os anteriores. Não atribui direitos ou altera registos de oficinas/recebimentos/custos/fiscalidade existentes. `down()` recusa destruição de história. Sem reset/fresh em desenvolvimento; mesmo instalada futuramente, mantém custeio real bloqueado na aplicação/base.
+
+## Quatro concessões propostas — separadas, NÃO aplicadas
+
+Conferência read-only por `scripts/industrial-cost-permissions-preview.php`, sem modo de aplicação. Tenant #1 / **Tempo Lda #1 / SEGI #1**. As quatro estavam ausentes; `100000` não aplicada e guarda industrial real recusada.
+
+| Conta existente | Direitos propostos |
+| --- | --- |
+| Osmane Nala #1 — nala@tempo.co.mz | `industrial_costs.view`, `industrial_costs.prepare` |
+| Samira Nal #2 — onala@me.com | `industrial_costs.view`, `industrial_costs.validate` |
+
+Preparação abrange dados/valorizações, critério e cálculo; validação abrange versões de dados de custo, critério e resultado, sem edição das fontes técnicas. Não inclui gestão de acessos, margens, stock, emissão ou activação real. Só equivalentes sintéticos receberam estes direitos nos testes. Não foram aplicados ou derivados dos quatro direitos de custo directo.
+
+## Ficheiros e limites
+
+Novos: `app/Modules/Industry/IndustrialCosts.php`, `Http/IndustrialCostsController.php`, `app/Shared/Costs/ExactCostMath.php`, `resources/js/IndustrialCostsWorkspace.jsx`, migração/SQL acima, `tests/Feature/IndustrialCostsTest.php`, `tests/Support/IndustrialCostFixture.php`, scripts `industrial-cost-fixture.php`, `industrial-cost-worker.php`, `industrial-cost-concurrency.php`, `industrial-cost-proof.php`, `industrial-cost-permissions-preview.php` e documentação/provas. Integrações em `resources/js/app.jsx`, `routes/web.php`; `DirectCosts.php` passa a usar o pequeno auxiliar puro de exactidão/conversão, sem mudança de política ou âmbito.
+
+Sem novo software, substituição de versões ou dependências. Sem dados de demonstração na aplicação normal ou alterações de ligação. Este recorte cria produto próprio por lote, uma cadeia por componente, unidade KG para material e uma etapa; não implementa catálogo industrial geral, integração de fontes de oficina, partilha de conjuntos entre lotes, stock/compras/salários/activos, previsto/realizado, WIP, perdas, preços/margens, facturação, recebimentos, reconhecimento, lançamentos ou fecho. Dados de origem e evidências são declarações sintéticas, sem comprovação externa de produção ou custo real. Conformidade/activação reais permanecem fora do âmbito. Nenhuma aceitação ou checkpoint de encerramento é declarado.

docs/WORKSHOP_DIRECT_COST_DELIVERY.md

@@ -78,6 +78,18 @@ São **quatro concessões propostas**, não autorização de aplicação ou acti
 
 Em 27/10/2026, o utilizador autorizou o encerramento após conferência técnica do percurso e preservação de checkpoint local. Ver [registo de encerramento e limites](WORKSHOP_DIRECT_COST_ACCEPTANCE.md). As referências anteriores a ausência de aceitação presumida descrevem a entrega antes desta autorização; `090000`, quatro concessões e uso operacional real continuam por autorizar/aplicar.
 
+## Instalação técnica especificamente autorizada — 27/10/2026
+
+Após autorização expressa, aplicada **apenas** `2026_10_27_090000_create_workshop_direct_costs` em `sgf_tempo_dev`, por caminho explícito com `sgf_dev_owner`, separado da aplicação `sgf_dev_app`. Acrescentou-se exactamente essa entrada no registo de migrações; instalações anteriores preservadas, sem reaplicar `070000` ou `080000`.
+
+Aplicadas e auditadas exactamente quatro concessões, todas tenant #1 / Tempo Lda #1 / SEGI #1: Osmane #1 `direct_costs.view` e `direct_costs.prepare`; Samira #2 `direct_costs.view` e `direct_costs.validate`. Nenhuma outra conta/unidade ou função técnica recebeu direitos.
+
+O procedimento `scripts/direct-cost-dev-install.php` comparou em memória os registos das **60 tabelas preexistentes**, incluindo acessos, auditoria, oficinas, recebimentos e cálculo fiscal. Dados/acessos anteriores preservados. Os únicos novos registos são uma entrada de migração, quatro concessões e quatro eventos de auditoria. As **seis tabelas de custo continuam vazias**: nenhuma taxa, cálculo, decisão de custos ou demonstração na base normal.
+
+As listagens de custos das duas contas continuam bloqueadas/vazias. Guarda, proposta de taxa, cálculo e decisão recusados com 403; guardas de oficinas, recebimentos e emissão real também recusadas. As funções SQL de ambiente de custos, recebimentos e oficinas recusaram `sgf_tempo_dev`. Fontes funcionais e guardas não foram alteradas. Resumo local em `storage/app/private/direct-cost-dev-install-proof.json`, excluído do Git, sem exportar conteúdos dos registos ou credenciais.
+
+As referências anteriores a migração/concessões pendentes descrevem o estado anterior a esta autorização. Esta instalação não activa custeio operacional, não resolve pendências de conformidade e não autoriza publicação, custos indirectos ou lote industrial. O checkpoint `d10ba06` permanece preservado. Sem alteração funcional, não foram repetidos testes destrutivos, compilação ou a demonstração aceite.
+
 ## Ficheiros e limites
 
 Núcleo `app/Modules/Workshop/DirectCosts.php`, controlador `Http/DirectCostsController.php`, interface `resources/js/DirectCostsWorkspace.jsx`, integrações em `app.jsx` e `routes/web.php`; migração/SQL acima; `tests/Feature/DirectCostsTest.php`, `tests/Support/DirectCostFixture.php`; scripts `direct-cost-fixture.php`, `direct-cost-worker.php`, `direct-cost-concurrency.php`, `direct-cost-proof.php`, `direct-cost-permissions-preview.php`; esta documentação e provas. Não se alteraram ferramentas/dependências ou o motor fiscal.

docs/proofs/industrial-cost-browser-results.json

@@ -0,0 +1,35 @@
+{
+    "policy": "INDUSTRIAL-COST-SIM-v1",
+    "database": "sgf_tempo_test",
+    "synthetic_only": true,
+    "real_browser_login": true,
+    "csrf_enabled": true,
+    "distinct_roles": true,
+    "full": {
+        "material": "1000",
+        "labour": "500",
+        "pool": "600",
+        "capacity_hm": "10",
+        "used_hm": "5",
+        "rate": "60",
+        "allocated": "300",
+        "residual": "300",
+        "cost": "1800",
+        "good_units": "10",
+        "unit_cost": "180",
+        "origins": "2100"
+    },
+    "partial": {
+        "known": "800",
+        "total": null,
+        "unit_cost": null,
+        "incomplete": true,
+        "known_origins": "1100",
+        "residual": "300"
+    },
+    "workshop_events_created": 0,
+    "hypothesis_only": true,
+    "development_migration_applied": false,
+    "real_grants_applied": false,
+    "user_acceptance": false
+}

docs/proofs/industrial-cost-concurrency.json

@@ -0,0 +1,14 @@
+{
+    "policy": "INDUSTRIAL-COST-SIM-v1",
+    "database": "sgf_tempo_test",
+    "overlapping_processes_per_case": 2,
+    "checks": {
+        "criterion_repetition_one_version": true,
+        "decision_repetition_one_effect": true,
+        "competing_criteria_one_successor": true,
+        "calculation_repetition_one_snapshot": true,
+        "competing_calculations_one_current_allocation": true,
+        "new_result_refuses_old_approval": true
+    },
+    "synthetic_only": true
+}

docs/proofs/industrial-cost-tests.json

@@ -0,0 +1,22 @@
+{
+    "policy": "INDUSTRIAL-COST-SIM-v1",
+    "date": "2026-10-27",
+    "database": "sgf_tempo_test",
+    "filter": "IndustrialCostsTest|DirectCostsTest|WorkshopTest|ServiceReceivablesTest|InternalConfirmationTest|DatabaseSafetyTest",
+    "tests": 58,
+    "assertions": 1185,
+    "failures": 0,
+    "errors": 0,
+    "industrial_test_cases": 9,
+    "overlapping_process_cases": 6,
+    "junit_local_ignored": "storage/app/industrial-cost-tests.xml",
+    "build": {"command": "scripts/sgf.ps1 npm run build", "vite": "8.3.5", "passed": true},
+    "shared_exact_cost_math_regression_passed": true,
+    "real_browser_login": true,
+    "browser_server_stopped_before_final_tests": true,
+    "development_migration_100000_applied": false,
+    "real_industrial_grants_applied": false,
+    "industrial_and_other_real_operational_blocks_preserved": true,
+    "user_acceptance": false,
+    "closing_checkpoint_created": false
+}

resources/js/IndustrialCostsWorkspace.jsx

@@ -0,0 +1,33 @@
+import React,{useEffect,useRef,useState} from 'react';
+const names={material:'Consumo material',labour:'Trabalho efectivo',pool:'Origem do conjunto indirecto',machine:'Utilização de máquina',production:'Produção boa concluída',material_rate:'Taxa de material',labour_rate:'Taxa de trabalho',criterion:'Critério de imputação'};
+const units={material:'KG',labour:'MIN',pool:'MZN',machine:'HM',production:'UN',material_rate:'KG',labour_rate:'H'};
+const money=v=>v===null?'Indisponível':`${v} MZN`;
+export default function IndustrialCostsWorkspace({context,can,api,busy}){
+    const [data,setData]=useState(null),[error,setError]=useState(''),[lotId,setLotId]=useState(''),[kind,setKind]=useState('criterion'),[selection,setSelection]=useState({}),[working,setWorking]=useState(false);const retry=useRef(null);
+    const allowed=r=>can(`industrial_costs.${r}`,context.unit?.id??null);const disabled=busy||working;
+    const load=async()=>{const r=await api('/api/industrial-costs');setData(r);};useEffect(()=>{setSelection({});load().catch(e=>setError(e.message));},[context.token]);
+    const lot=data?.lots.find(l=>String(l.id)===lotId)??data?.lots[0];const latest=lot?.results.at(-1);const lastInput=lot?.inputs.filter(i=>i.kind===kind).at(-1);
+    const options=k=>lot?.inputs.filter(i=>i.kind===k&&i.current&&i.decision?.decision==='approved')??[];
+    const reference=v=>{const r=lot.inputs.find(i=>String(i.id)===String(v));return r?{id:r.id,version:r.version}:null;};
+    async function send(path,input){setWorking(true);setError('');const signature=JSON.stringify([path,input]);if(retry.current?.signature!==signature)retry.current={signature,key:crypto.randomUUID()};try{await api(path,'POST',input,context.token,retry.current.key);retry.current=null;await load();}catch(e){setError(e.message);}finally{setWorking(false);}}
+    const decide=(type,row,decision,reason)=>send(`/api/industrial-costs/lots/${lot.id}/decisions`,{type,id:row.id,version:row.version,decision,reason});
+    const inputForm=e=>{e.preventDefault();const f=new FormData(e.currentTarget);let d;
+        if(kind==='criterion'){const p=reference(f.get('pool')),m=reference(f.get('machine'));if(!p||!m){setError('Escolher versões explícitas do conjunto e utilização.');return;}d={pool_id:p.id,pool_version:p.version,machine_id:m.id,machine_version:m.version,capacity:f.get('capacity'),driver_unit:'HM',hypothesis:'synthetic_only'};}
+        else if(kind.endsWith('_rate')){const source=reference(f.get('source'));if(!source){setError('Escolher origem exacta.');return;}d={source_id:source.id,source_version:source.version,amount:f.get('amount'),currency:'MZN',unit:units[kind]};}
+        else {d={quantity:f.get('quantity'),unit:units[kind],event_date:f.get('event_date')};if(kind==='production')d.completed=f.get('completed')==='on';}
+        send(`/api/industrial-costs/lots/${lot.id}/inputs`,{kind,source_ref:lastInput?.source_ref??f.get('source_ref'),version:(lastInput?.version??0)+1,previous_id:lastInput?.id??null,data:d,evidence:f.get('evidence')});};
+    return <section className="workspace"><p className="eyebrow">INDUSTRIAL-COST-SIM-v1</p><h2>Ensaio de custos industriais</h2><div className="alert">ENSAIO INDUSTRIAL — SEM UTILIZAÇÃO OPERACIONAL. Critério sintético; não configura método contabilístico real. Sem stock, facturação, margens ou lançamentos.</div>{error&&<p role="alert" className="alert error">{error}</p>}
+    {!data?<p>A carregar…</p>:data.blocked?<p>Custeio industrial real bloqueado nesta instância.</p>:<><button disabled={disabled} onClick={()=>load().catch(e=>setError(e.message))}>Actualizar versões explicitamente</button>
+    {allowed('prepare')&&<details className="panel"><summary>Abrir lote sintético e produto próprios</summary><form onSubmit={e=>{e.preventDefault();const f=new FormData(e.currentTarget);send('/api/industrial-costs/lots',Object.fromEntries([...f.entries(),['currency','MZN']]));}}>{[['reference','Referência do lote'],['product_reference','Referência do produto'],['product_name','Nome do produto'],['centre','Centro sintético']].map(([n,l])=><label key={n}>{l}<input name={n} required minLength={3}/></label>)}<label>Início do período<input type="date" name="period_start" required/></label><label>Fim do período<input type="date" name="period_end" required/></label><p>MZN explícito; produto em UN. Não é ordem de oficina.</p><button disabled={disabled}>Abrir lote de teste</button></form></details>}
+    <label>Lote de teste<select value={lot?.id??''} onChange={e=>{setLotId(e.target.value);setSelection({});}}>{data.lots.map(l=><option key={l.id} value={l.id}>{l.reference} · #{l.id}</option>)}</select></label>
+    {!lot?<p>Sem lotes no âmbito autorizado.</p>:<><p>{lot.product.name} · {lot.centre} · {lot.period_start} a {lot.period_end} · {lot.currency}</p>
+    {allowed('prepare')&&<form className="panel" onSubmit={inputForm}><h3>Preparar origem, taxa ou critério versionado</h3><label>Tipo de proposta<select value={kind} onChange={e=>setKind(e.target.value)}>{Object.entries(names).map(([k,n])=><option key={k} value={k}>{n}</option>)}</select></label><p>{lastInput?`Nova versão ${(lastInput.version)+1}, anterior #${lastInput.id}; origem ${lastInput.source_ref}.`:'Nova origem sintética identificada, sem duplicar outra origem.'}</p>{!lastInput&&<label>Identidade da origem<input name="source_ref" placeholder="IND-TEST-CRITERIO" required pattern="IND-TEST-[A-Za-z0-9_-]+"/></label>}
+    {kind==='criterion'?<><SourceSelect label="Conjunto indirecto exacto" name="pool" rows={options('pool')}/><SourceSelect label="Utilização exacta da máquina" name="machine" rows={options('machine')}/><label>Capacidade sintética em HM<input name="capacity" required placeholder="10"/></label><p>Hipótese apenas do ensaio; denominador explícito. Não redistribuir residual.</p></>:kind.endsWith('_rate')?<><SourceSelect label="Origem exacta da taxa" name="source" rows={options(kind.replace('_rate',''))}/><label>Taxa exacta MZN/{units[kind]}<input name="amount" required inputMode="decimal"/></label></>:<><label>Quantidade exacta em {units[kind]}<input name="quantity" required inputMode="decimal"/></label><label>Data do acontecimento sintético<input type="date" name="event_date" required min={lot.period_start} max={lot.period_end}/></label>{kind==='production'&&<label><input type="checkbox" name="completed" required/>Lote fisicamente concluído neste ensaio</label>}</>}
+    <label>Evidência / pressuposto<input name="evidence" required minLength={3}/></label><button disabled={disabled}>Propor versão industrial</button></form>}
+    <section className="panel"><h3>Origens, taxas e critério</h3>{lot.inputs.map(i=><article className="panel" key={i.id}><strong>#{i.id} · {names[i.kind]} v{i.version}</strong><p>{i.source_ref} · {i.current?'Última versão':'Histórico'} · {i.decision?`${i.decision.decision==='approved'?'Validado':'Recusado'} — ${i.decision.reason}`:'Aguarda validação'}</p><dl>{Object.entries(i.data).map(([k,v])=><React.Fragment key={k}><dt>{({quantity:'Quantidade',unit:'Unidade',event_date:'Data',amount:'Taxa',currency:'Moeda',capacity:'Capacidade',driver_unit:'Unidade da base',hypothesis:'Hipótese',source_id:'Origem #',source_version:'Versão da origem',pool_id:'Conjunto #',pool_version:'Versão do conjunto',machine_id:'Utilização #',machine_version:'Versão da utilização',completed:'Concluído'})[k]??k}</dt><dd>{v===true?'Sim':v==='synthetic_only'?'Apenas ensaio':String(v)}</dd></React.Fragment>)}</dl><p>{i.evidence}</p>{allowed('validate')&&i.current&&!i.decision&&<DecisionForm disabled={disabled} onDecision={(d,r)=>decide('input',i,d,r)}/>}</article>)}</section>
+    {allowed('prepare')&&<form className="panel" onSubmit={e=>{e.preventDefault();const refs=Object.fromEntries(Object.keys(names).map(k=>[k,reference(selection[k]??'')]));send(`/api/industrial-costs/lots/${lot.id}/calculations`,{currency:'MZN',version:(latest?.version??0)+1,previous_id:latest?.id??null,refs});}}><h3>Seleccionar versões para cálculo</h3><p>Selecção explícita; taxa material ausente mantém pendência. As outras referências são necessárias.</p>{Object.entries(names).map(([k,n])=><label key={k}>{n}<select value={selection[k]??''} required={k!=='material_rate'} onChange={e=>setSelection({...selection,[k]:e.target.value})}><option value="">{k==='material_rate'?'Sem taxa — total incompleto':'Escolher versão validada'}</option>{options(k).map(i=><option key={i.id} value={i.id}>#{i.id} v{i.version} · {i.source_ref}</option>)}</select></label>)}<button disabled={disabled}>Calcular lote sintético</button></form>}
+    <section className="panel"><h3>Resultados e residual</h3>{lot.results.map(r=><article key={r.id} className="panel"><h3>Resultado #{r.id} · v{r.version}</h3><p>{r.current?'Dependências actuais':'DESACTUALIZADO / HISTÓRICO — não usar como actual'} · {r.decision?`${r.decision.decision==='approved'?'Validado':'Recusado'} — ${r.decision.reason}`:'Aguarda validação'}</p><p>{r.snapshot.hypothesis}</p><table><thead><tr><th>Componente</th><th>Composição exacta</th><th>Custo no lote</th></tr></thead><tbody><tr><td>Material</td><td>{r.snapshot.origins.material.data.quantity} KG × {r.snapshot.origins.material_rate?.data.amount??'taxa em falta'}</td><td>{money(r.snapshot.material_exact)}</td></tr><tr><td>Trabalho</td><td>{r.snapshot.origins.labour.data.quantity} MIN ÷ 60 = {r.snapshot.labour_hours_exact} H × {r.snapshot.origins.labour_rate.data.amount}</td><td>{money(r.snapshot.labour_exact)}</td></tr><tr><td>Indirectos imputados</td><td>{r.snapshot.pool_exact} ÷ {r.snapshot.capacity_hm} HM = {r.snapshot.indirect_rate_exact} MZN/HM; × {r.snapshot.used_hm} HM</td><td>{money(r.snapshot.allocated_exact)}</td></tr></tbody></table><p><strong>Custo atribuído conhecido: {money(r.snapshot.known_cost_exact)}</strong></p><p>{r.snapshot.incomplete?'TOTAL INCOMPLETO — material pendente':'Total do perímetro sintético: '+money(r.snapshot.selected_total_exact)}</p><p>{r.snapshot.good_units} UN boas · Custo unitário do cenário: {r.snapshot.unit_cost_exact===null?'Indisponível':money(r.snapshot.unit_cost_exact)+'/UN'}</p><p><strong>Residual separado: {money(r.snapshot.residual_exact)} por imputar</strong></p><p>Conjunto: {r.snapshot.pool_exact} = {r.snapshot.allocated_exact} imputados + {r.snapshot.residual_exact} por imputar.</p><p>Reconciliação {r.snapshot.reconciliation.coverage==='partial_known_only'?'PARCIAL — só valores conhecidos':'do perímetro'}: {r.snapshot.reconciliation.known_origins_exact} = {r.snapshot.reconciliation.assigned_exact} atribuídos + {r.snapshot.reconciliation.unassigned_exact} por imputar.</p><ul>{r.snapshot.pending.map(p=><li key={p}>{p}</li>)}</ul><details><summary>Referências exactas utilizadas</summary><ul>{Object.entries(r.snapshot.refs).map(([k,v])=><li key={k}>{names[k]}: {v?`#${v.id} v${v.version}`:'Ausente'}</li>)}</ul></details>{allowed('validate')&&r.current&&!r.decision&&<DecisionForm disabled={disabled} onDecision={(d,reason)=>decide('result',r,d,reason)}/>}</article>)}</section>
+    </>}</>}</section>;
+}
+function SourceSelect({label,name,rows}){return <label>{label}<select name={name} required defaultValue=""><option value="">Escolher versão validada</option>{rows.map(i=><option key={i.id} value={i.id}>#{i.id} v{i.version} · {i.source_ref}</option>)}</select></label>;}
+function DecisionForm({disabled,onDecision}){return <form onSubmit={e=>{e.preventDefault();const f=new FormData(e.currentTarget);onDecision(f.get('decision'),f.get('reason'));}}><label>Decisão industrial<select name="decision"><option value="approved">Validar esta versão</option><option value="refused">Recusar esta versão</option></select></label><label>Fundamento industrial<input name="reason" required minLength={3}/></label><button disabled={disabled}>Registar decisão industrial</button></form>;}

resources/js/app.jsx

@@ -10,6 +10,7 @@ import ServiceInvoiceWorkspace from './ServiceInvoiceWorkspace.jsx';
 import ServiceReceivablesWorkspace from './ServiceReceivablesWorkspace.jsx';
 import WorkshopWorkspace from './WorkshopWorkspace.jsx';
 import DirectCostsWorkspace from './DirectCostsWorkspace.jsx';
+import IndustrialCostsWorkspace from './IndustrialCostsWorkspace.jsx';
 
 const labels = { 'catalogue_accounting.view':'Consultar classificação contabilística', 'catalogue_accounting.propose':'Preparar classificação contabilística', 'catalogue_accounting.approve':'Validar ou recusar classificação contabilística', 'company.view': 'Consultar empresa', 'company.edit': 'Editar nome da empresa', 'unit.create': 'Criar unidades', 'access.manage': 'Gerir acessos', 'unit.view': 'Consultar unidade', 'unit.edit': 'Editar nome da unidade' };
 
@@ -54,7 +55,7 @@ function App() {
     if (!state) return <main className="loading"><h1>SGF TEMPO</h1><p role="status">{error || 'A carregar…'}</p></main>;
     if (state.setup_pending) return <main className="setup-pending"><p className="eyebrow">SGF TEMPO · PREPARAÇÃO LOCAL</p><h1>Falta concluir a primeira conta</h1><p>A aplicação está pronta, mas ainda não existe um utilizador. O login ficará disponível depois de definires a palavra-passe no procedimento local já autorizado.</p><section className="panel"><h2>Concluir no terminal do VS Code</h2><p>Executa este comando, confere o âmbito apresentado e define a palavra-passe nos dois pedidos de entrada oculta:</p><pre>powershell.exe -NoProfile -ExecutionPolicy Bypass -File C:\laragon\data\sgf-tempo\run\complete-first-admin.ps1</pre><p className="help">Não envies a palavra-passe pelo chat. Nenhuma conta é criada por este ecrã.</p><button className="primary" disabled={busy} onClick={() => perform(async () => {}, '')}>Já concluí — actualizar estado</button>{error && <p role="alert">{error}</p>}</section></main>;
     if (!state.user) return <div className="login-layout"><aside><span className="brand">TEMPO<span>SGF</span></span><h1>O seu trabalho,<br />no contexto certo.</h1><p>Uma entrada para as empresas e unidades a que tem acesso.</p><small>Ambiente local · Primeiro percurso funcional</small></aside><main className="login-card"><p className="eyebrow">BEM-VINDO AO SGF TEMPO</p><h2>Entrar na aplicação</h2><p className="muted">Use a conta preparada pelo procedimento local autorizado.</p>{error && <div className="alert error" role="alert">{error}</div>}<Login busy={busy} onSubmit={(email, password) => perform(() => api('/api/login', 'POST', { email, password }), 'Sessão iniciada. Seleccione o contexto de trabalho.')} /><p className="help">Precisa de recuperar o acesso? Solicite recuperação local assistida. Não existe recuperação por email nesta etapa.</p></main></div>;
-    return <div className="shell"><aside className="sidebar"><a className="brand" href="/">TEMPO<span>SGF</span></a><p className="sidebar-label">ESPAÇO DE TRABALHO</p><nav>{[['home', 'Área inicial'], ['company', 'Empresa'], ['units', 'Unidades'], ...(can('access.manage') ? [['access', 'Acessos']] : []), ...((can('issuer_documents.view') || can('client_documents.view') || can('draft_documents.view', context?.unit?.id ?? null)) ? [['documents', 'Preparação documental'], ...(can('issuer_documents.view') ? [['preview_model', 'Apresentação do rascunho']] : [])] : []), ...(can('direct_costs.view',context?.unit?.id ?? null) ? [['direct_costs', 'Custos directos de teste']] : []), ...(can('workshop.view',context?.unit?.id ?? null) ? [['workshop', 'Oficina de teste']] : []), ...(can('service_receivables.view',context?.unit?.id ?? null) ? [['service_receivables', 'Recebimentos simulados']] : []), ...(can('service_invoices.view',context?.unit?.id ?? null) ? [['service_invoices', 'Facturas de teste']] : []), ...(can('service_fiscal.view') ? [['service_fiscal', 'Perfil fiscal do servi\u00e7o']] : []), ...(can('catalogue_accounting.view') ? [['catalogue_accounting', 'Classificação contabilística']] : []), ...Object.entries(serviceAreas).filter(([area]) => can(`${area}.view`, area.endsWith('_drafts') ? context?.unit?.id ?? null : null))].map(([id, text]) => <button key={id} className={page === id ? 'active' : ''} onClick={() => { setPage(id); setError(''); }}>{text}</button>)}</nav><div className="sidebar-bottom"><strong>{state.user.name}</strong><small>{state.user.email}</small><button disabled={busy} onClick={() => perform(() => api('/api/logout', 'POST'), 'Sessão terminada.')}>Sair da aplicação</button></div></aside><div className="workspace"><header><div><span className="eyebrow">CONTEXTO DE TRABALHO</span><strong>{context?.company.name || 'Seleccione uma empresa'}</strong><span className="muted">{context?.unit?.name || 'Sem unidade seleccionada'}</span></div><span className="local-badge">Ambiente local</span></header><main>
+    return <div className="shell"><aside className="sidebar"><a className="brand" href="/">TEMPO<span>SGF</span></a><p className="sidebar-label">ESPAÇO DE TRABALHO</p><nav>{[['home', 'Área inicial'], ['company', 'Empresa'], ['units', 'Unidades'], ...(can('access.manage') ? [['access', 'Acessos']] : []), ...((can('issuer_documents.view') || can('client_documents.view') || can('draft_documents.view', context?.unit?.id ?? null)) ? [['documents', 'Preparação documental'], ...(can('issuer_documents.view') ? [['preview_model', 'Apresentação do rascunho']] : [])] : []), ...(can('industrial_costs.view',context?.unit?.id ?? null) ? [['industrial_costs', 'Custos industriais de teste']] : []), ...(can('direct_costs.view',context?.unit?.id ?? null) ? [['direct_costs', 'Custos directos de teste']] : []), ...(can('workshop.view',context?.unit?.id ?? null) ? [['workshop', 'Oficina de teste']] : []), ...(can('service_receivables.view',context?.unit?.id ?? null) ? [['service_receivables', 'Recebimentos simulados']] : []), ...(can('service_invoices.view',context?.unit?.id ?? null) ? [['service_invoices', 'Facturas de teste']] : []), ...(can('service_fiscal.view') ? [['service_fiscal', 'Perfil fiscal do servi\u00e7o']] : []), ...(can('catalogue_accounting.view') ? [['catalogue_accounting', 'Classificação contabilística']] : []), ...Object.entries(serviceAreas).filter(([area]) => can(`${area}.view`, area.endsWith('_drafts') ? context?.unit?.id ?? null : null))].map(([id, text]) => <button key={id} className={page === id ? 'active' : ''} onClick={() => { setPage(id); setError(''); }}>{text}</button>)}</nav><div className="sidebar-bottom"><strong>{state.user.name}</strong><small>{state.user.email}</small><button disabled={busy} onClick={() => perform(() => api('/api/logout', 'POST'), 'Sessão terminada.')}>Sair da aplicação</button></div></aside><div className="workspace"><header><div><span className="eyebrow">CONTEXTO DE TRABALHO</span><strong>{context?.company.name || 'Seleccione uma empresa'}</strong><span className="muted">{context?.unit?.name || 'Sem unidade seleccionada'}</span></div><span className="local-badge">Ambiente local</span></header><main>
         {error && <div className="alert error" role="alert">{error}</div>}{notice && <div className="alert success" role="status">{notice}</div>}
         <section className="context-card"><label>Empresa<select aria-label="Empresa activa" disabled={busy} value={context?.company.id || ''} onChange={e => select(e.target.value)}><option value="">Escolher empresa autorizada</option>{state.companies.map(c => <option value={c.id} key={c.id}>{c.name}</option>)}</select></label><label>Unidade<select aria-label="Unidade activa" disabled={busy || !context} value={context?.unit?.id || ''} onChange={e => select(context.company.id, e.target.value ? Number(e.target.value) : null)}><option value="">Sem unidade seleccionada</option>{context?.units.map(u => <option value={u.id} key={u.id}>{u.name}</option>)}</select></label><p>Apenas os contextos com acesso explícito são apresentados.</p></section>
         {!state.companies.length ? <section className="panel"><h1>Sem empresas autorizadas</h1><p>A conta existe, mas ainda não tem acesso a uma empresa. Peça ao responsável uma concessão explícita.</p></section> : !context ? <section className="panel"><h1>Escolha onde vai trabalhar</h1><p>Seleccione uma empresa. A pertença a um cliente contratante não dá acesso automático às suas empresas ou unidades.</p></section> : <div key={context.token}>
@@ -66,6 +67,7 @@ function App() {
             {page === 'documents' && <DocumentPreparationWorkspace context={context} can={can} api={api} perform={perform} busy={busy} />}
             {page === 'workshop' && <WorkshopWorkspace context={context} can={can} api={api} busy={busy} />}
             {page === 'direct_costs' && <DirectCostsWorkspace context={context} can={can} api={api} busy={busy} />}
+            {page === 'industrial_costs' && <IndustrialCostsWorkspace context={context} can={can} api={api} busy={busy} />}
             {page === 'service_receivables' && <ServiceReceivablesWorkspace context={context} can={can} api={api} busy={busy} />}
             {page === 'service_invoices' && <ServiceInvoiceWorkspace context={context} can={can} api={api} perform={perform} busy={busy} />}
             {page === 'service_fiscal' && <ServiceFiscalWorkspace context={context} can={can} api={api} perform={perform} busy={busy} />}

routes/web.php

@@ -17,6 +17,11 @@ Route::middleware(['auth', RequireValidSession::class])->group(function (): void
     Route::middleware(RequireCompanyContext::class)->group(function (): void {
         Route::get('/api/workshop', [\App\Modules\Workshop\Http\WorkshopController::class,'index']);
         Route::get('/api/direct-costs', [\App\Modules\Workshop\Http\DirectCostsController::class,'index']);
+        Route::get('/api/industrial-costs', [\App\Modules\Industry\Http\IndustrialCostsController::class,'index']);
+        Route::post('/api/industrial-costs/lots', [\App\Modules\Industry\Http\IndustrialCostsController::class,'open']);
+        Route::post('/api/industrial-costs/lots/{id}/inputs', [\App\Modules\Industry\Http\IndustrialCostsController::class,'input'])->whereNumber('id');
+        Route::post('/api/industrial-costs/lots/{id}/calculations', [\App\Modules\Industry\Http\IndustrialCostsController::class,'calculate'])->whereNumber('id');
+        Route::post('/api/industrial-costs/lots/{id}/decisions', [\App\Modules\Industry\Http\IndustrialCostsController::class,'decide'])->whereNumber('id');
         Route::post('/api/direct-costs/orders/{id}/rates', [\App\Modules\Workshop\Http\DirectCostsController::class,'rate'])->whereNumber('id');
         Route::post('/api/direct-costs/orders/{id}/calculations', [\App\Modules\Workshop\Http\DirectCostsController::class,'calculate'])->whereNumber('id');
         Route::post('/api/direct-costs/orders/{id}/decisions', [\App\Modules\Workshop\Http\DirectCostsController::class,'decide'])->whereNumber('id');

scripts/direct-cost-dev-install.php

@@ -0,0 +1,100 @@
+<?php
+// Only the specifically authorised 090000 and four unit grants; no real costing.
+require __DIR__.'/../vendor/autoload.php';
+$app=require __DIR__.'/../bootstrap/app.php';
+$app->make(\Illuminate\Contracts\Console\Kernel::class)->bootstrap();
+use Illuminate\Support\Facades\DB;
+use Illuminate\Support\Facades\Artisan;
+use App\Modules\Identity\Services\LocalDatabaseGuard;
+use App\Modules\Identity\Services\Permissions;
+use App\Modules\Identity\Services\Audit;
+use App\Modules\Workshop\DirectCosts;
+use App\Modules\Workshop\WorkshopWorkflow;
+use App\Shared\Context\CompanyContext;
+
+function ensureDirectCost(bool $ok,string $message): void { if(!$ok)throw new RuntimeException($message); }
+function directCostFingerprint(string $table,?int $max=null): array {
+    ensureDirectCost((bool)preg_match('/^[a-z_]+$/D',$table),'Unexpected table identifier.');
+    $where=$max===null?'':' WHERE id <= '.$max;
+    $r=DB::selectOne('SELECT count(*) AS n, md5(COALESCE(string_agg(row_to_json(t)::text, E\'\\n\' ORDER BY row_to_json(t)::text),\'\')) AS h FROM (SELECT * FROM "'.$table.'"'.$where.') t');
+    return [(int)$r->n,$r->h]; // In memory only; no record contents exported.
+}
+ensureDirectCost(LocalDatabaseGuard::allows(),'Own SGF development application connection required.');
+ensureDirectCost($argv===[$argv[0],'--apply-confirmed-090000-and-four-grants'],'Exact confirmed operation argument required.');
+$migration='2026_10_27_090000_create_workshop_direct_costs';
+ensureDirectCost(!DB::table('migrations')->where('migration',$migration)->exists(),'090000 already installed; review changed state.');
+ensureDirectCost(DB::table('migrations')->where('migration','2026_10_27_080000_create_workshop_resource_records')->exists(),'Expected workshop installation missing.');
+ensureDirectCost(DB::table('migrations')->where('migration','2026_10_27_070000_create_simulated_receivables')->exists(),'Expected receivables installation missing.');
+$newTables=['dc_rates','dc_calculations','dc_decisions','dc_commands','dc_events','dc_outbox'];
+$tables=array_map(fn($r)=>$r->tablename,DB::select("SELECT tablename FROM pg_tables WHERE schemaname='public' ORDER BY tablename"));
+ensureDirectCost(!array_intersect($tables,$newTables),'Receivables tables already exist; review first.');
+$rights=[1=>['view','prepare'],2=>['view','validate']];
+$checkScope=function(): void {
+    foreach([1=>['Osmane Nala','nala@tempo.co.mz'],2=>['Samira Nal','onala@me.com']] as $id=>[$name,$email]){
+        ensureDirectCost(DB::table('users')->where(compact('id','name','email'))->exists(),'Confirmed account identity differs.');
+        ensureDirectCost(DB::table('company_memberships')->where(['user_id'=>$id,'tenant_id'=>1,'company_id'=>1])->exists(),'Existing membership required.');
+        $p=app(Permissions::class);$p->require($id,1,1,'company.view');$p->require($id,1,1,'unit.view',1);
+    }
+    ensureDirectCost(DB::table('companies')->where(['id'=>1,'tenant_id'=>1,'name'=>'Tempo Lda'])->exists(),'Confirmed company differs.');
+    ensureDirectCost(DB::table('units')->where(['id'=>1,'tenant_id'=>1,'company_id'=>1,'name'=>'SEGI'])->exists(),'Confirmed unit differs.');
+    ensureDirectCost(!DB::table('permission_grants')->where('permission','like','direct_costs.%')->exists(),'Unexpected existing direct cost rights; review first.');
+};
+$checkScope();
+$baseline=[];foreach($tables as $t)$baseline[$t]=directCostFingerprint($t);
+$max=[];foreach(['permission_grants','identity_audit'] as $t)$max[$t]=(int)DB::table($t)->max('id');
+$ledger=DB::table('migrations')->orderBy('id')->get()->map(fn($r)=>(array)$r)->all();
+$sourceHashes=[];foreach(['app/Modules/Workshop/DirectCosts.php','app/Modules/Services/ServiceReceivables.php','app/Modules/Services/ServiceInvoicing.php','app/Modules/Workshop/WorkshopWorkflow.php'] as $p)$sourceHashes[$p]=hash_file('sha256',base_path($p));
+$secrets=json_decode(file_get_contents('C:/laragon/data/sgf-tempo/secrets/database.json'),true,32,JSON_THROW_ON_ERROR);
+$owner=config('database.connections.'.config('database.default'));
+$owner['username']='sgf_dev_owner';$owner['password']=$secrets['dev_owner'];$owner['url']=null;
+config(['database.connections.sgf_direct_cost_owner'=>$owner]);unset($owner,$secrets);
+try {
+    $connection=DB::connection('sgf_direct_cost_owner');
+    $identity=$connection->selectOne('SELECT current_database() AS db,current_user AS role,inet_server_port() AS port,rolsuper,rolcreatedb,rolcreaterole,rolbypassrls FROM pg_roles WHERE rolname=current_user');
+    ensureDirectCost($identity->db==='sgf_tempo_dev'&&$identity->role==='sgf_dev_owner'&&(int)$identity->port===55432&&!$identity->rolsuper&&!$identity->rolcreatedb&&!$identity->rolcreaterole&&!$identity->rolbypassrls,'Unexpected migration owner/destination.');
+    $connection->transaction(function()use($migration,$baseline,$newTables): void {
+        $applicationConnection=DB::getDefaultConnection();DB::setDefaultConnection('sgf_direct_cost_owner');
+        try {
+            $exit=Artisan::call('migrate',['--database'=>'sgf_direct_cost_owner','--path'=>'database/migrations/'.$migration.'.php','--force'=>true,'--no-interaction'=>true]);
+            ensureDirectCost($exit===0,'Targeted migration failed.');
+            foreach($baseline as $t=>$fp)if($t!=='migrations')ensureDirectCost(directCostFingerprint($t)===$fp,'Existing records changed during migration: '.$t);
+            foreach($newTables as $t)ensureDirectCost(DB::table($t)->count()===0,'New tables must be empty.');
+        } finally { DB::setDefaultConnection($applicationConnection); }
+    });
+} finally { DB::purge('sgf_direct_cost_owner');config(['database.connections.sgf_direct_cost_owner'=>null]); }
+ensureDirectCost(LocalDatabaseGuard::allows(),'Application must remain sgf_dev_app.');
+$afterLedger=DB::table('migrations')->orderBy('id')->get()->map(fn($r)=>(array)$r)->all();
+ensureDirectCost(count($afterLedger)===count($ledger)+1&&array_slice($afterLedger,0,count($ledger))===$ledger&&end($afterLedger)['migration']===$migration,'Unexpected migration ledger delta.');
+$denials=[];
+$grants=DB::transaction(function()use($rights,$checkScope,$baseline,$max,&$denials): array {
+    DB::table('companies')->where('id',1)->lockForUpdate()->firstOrFail();$checkScope();$grants=[];
+    foreach($rights as $user=>$actions)foreach($actions as $action){
+        $g=['user_id'=>$user,'tenant_id'=>1,'company_id'=>1,'unit_id'=>1,'permission'=>'direct_costs.'.$action];
+        DB::table('permission_grants')->insert($g+['created_at'=>now(),'updated_at'=>now()]);
+        Audit::record('direct_costs.initial_grant',null,1,1,1,subject:$user,details:['permission'=>$g['permission'],'reason'=>'Four unit grants specifically authorised; real operations remain blocked.']);$grants[]=$g;
+    }
+    foreach($baseline as $t=>$fp)if($t!=='migrations')ensureDirectCost(directCostFingerprint($t,$max[$t]??null)===$fp,'Prior records changed: '.$t);
+    ensureDirectCost(DB::table('permission_grants')->where('id','>',$max['permission_grants'])->count()===4,'Exactly four new grants required.');
+    ensureDirectCost(DB::table('identity_audit')->where('id','>',$max['identity_audit'])->count()===4&&DB::table('identity_audit')->where('id','>',$max['identity_audit'])->where('action','direct_costs.initial_grant')->count()===4,'Exactly four grant audit entries required.');
+    $actual=DB::table('permission_grants')->where('permission','like','direct_costs.%')->get(['user_id','tenant_id','company_id','unit_id','permission'])->map(fn($r)=>(array)$r)->all();
+    $sort=fn($a,$b)=>[$a['user_id'],$a['permission']]<=>[$b['user_id'],$b['permission']];usort($actual,$sort);$expected=$grants;usort($expected,$sort);ensureDirectCost($actual===$expected,'Granted accounts/rights/scope differ.');
+    foreach([1,2] as $actor){app(CompanyContext::class)->selectFor($actor,1,1,1);$listing=app(DirectCosts::class)->listing($actor);ensureDirectCost($listing['blocked']&&$listing['orders']===[],'Normal direct cost listing must remain blocked.');}
+    foreach(['guard','rate','calculate','decide','workshop','receivables','issuance'] as $entry){
+        try {
+            $r=app(DirectCosts::class);
+            match($entry){'guard'=>DirectCosts::guard(),'rate'=>$r->rate(0,1,[],'blocked-probe'),'calculate'=>$r->calculate(0,1,[],'blocked-probe'),'decide'=>$r->decide(0,2,[],'blocked-probe'),'workshop'=>WorkshopWorkflow::guard(),'receivables'=>\App\Modules\Services\ServiceReceivables::guard(),'issuance'=>\App\Modules\Services\ServiceInvoicing::guard()};
+            throw new RuntimeException('Operational entry did not refuse.');
+        }catch(\Symfony\Component\HttpKernel\Exception\HttpException $e){ensureDirectCost($e->getStatusCode()===403,'Expected operational refusal.');$denials[$entry]=403;}
+    }
+    app(CompanyContext::class)->selectFor(1,1,1,1);$w=app(WorkshopWorkflow::class)->listing(1);ensureDirectCost($w['blocked']&&$w['orders']===[],'Workshop operational block must remain.');
+    return $grants;
+});
+foreach(['dc','sr','wo'] as $prefix){
+    try {DB::select('SELECT sgf_'.$prefix.'_environment()');throw new RuntimeException('SQL environment guard did not refuse.');}
+    catch(\Illuminate\Database\QueryException $e){ensureDirectCost(str_contains($e->getMessage(),'SGF_'.strtoupper($prefix).'_TEST_DATABASE_ONLY'),'Unexpected SQL guard response.');}
+}
+foreach($sourceHashes as $p=>$hash)ensureDirectCost(hash_file('sha256',base_path($p))===$hash,'Functional source or guard changed.');
+foreach($newTables as $t)ensureDirectCost(DB::table($t)->count()===0,'New direct cost tables must remain empty.');
+$proof=['date'=>'2026-10-27','database'=>'sgf_tempo_dev','migration_applied'=>$migration,'only_one_migration_added'=>true,'workshop_080000_preserved'=>true,'preexisting_tables_checked'=>count($baseline),'prior_records_and_accesses_preserved'=>true,'new_empty_tables'=>$newTables,'new_grants'=>$grants,'audited_new_grants'=>4,'application_role'=>'sgf_dev_app','both_normal_account_listings_blocked'=>true,'entry_denials'=>$denials,'cost_receivables_and_workshop_sql_guards_refused'=>true,'functional_and_guard_sources_unchanged'=>true,'real_operations_created'=>false];
+file_put_contents(storage_path('app/private/direct-cost-dev-install-proof.json'),json_encode($proof,JSON_PRETTY_PRINT|JSON_THROW_ON_ERROR));
+echo 'Applied only 090000 and four audited grants; '.count($baseline)." prior tables preserved, six new tables empty, costing, workshop and operational/fiscal guards verified.\n";

scripts/industrial-cost-concurrency.php

@@ -0,0 +1,26 @@
+<?php
+require __DIR__.'/../vendor/autoload.php';$app=require __DIR__.'/../bootstrap/app.php';$app->make(\Illuminate\Contracts\Console\Kernel::class)->bootstrap();
+use App\Modules\Industry\IndustrialCosts;
+use App\Shared\Context\CompanyContext;
+use Illuminate\Support\Facades\DB;
+use Illuminate\Support\Str;
+use Symfony\Component\Process\Process;
+IndustrialCosts::guard();$f=json_decode(file_get_contents('C:/laragon/data/sgf-tempo/secrets/browser-fixture.json'),true,32,JSON_THROW_ON_ERROR);$fx=$f['industrial'];$proof=[];$key=fn()=>(string)Str::uuid();
+$base=['tenant'=>$f['tenant'],'company'=>$f['company'],'unit'=>$f['unit'],'lot'=>$fx['lot']];
+$pair=function($one,$two)use($base){
+ $a=new Process([PHP_BINARY,'scripts/industrial-cost-worker.php','--env=testing'],base_path(),null,json_encode($one+$base+['pause'=>true]));$b=new Process([PHP_BINARY,'scripts/industrial-cost-worker.php','--env=testing'],base_path(),null,json_encode($two+$base));
+ $a->start();if(!$a->waitUntil(fn($t,$v)=>str_contains($v,'LOCK_HELD')))throw new RuntimeException('Industrial concurrent lock not observed.');$b->start();$a->wait();$b->wait();$out=[];
+ foreach([$a,$b] as $p){if(!$p->isSuccessful())throw new RuntimeException('Industrial worker failed.');$lines=array_values(array_filter(explode("\n",trim($p->getOutput())),fn($v)=>str_starts_with($v,'{')));$out[]=json_decode(end($lines),true,32,JSON_THROW_ON_ERROR);}return $out;
+};
+$check=function($out,bool $replay){if($out[0]['status']!==200||$out[1]['status']!==($replay?200:409)||($replay&&(!$out[1]['result']['replayed']||$out[0]['result']['id']!==$out[1]['result']['id'])))throw new RuntimeException('Unexpected concurrent industrial result.');};
+$old=DB::table('ic_inputs')->where(['lot_id'=>$fx['lot'],'kind'=>'criterion'])->orderByDesc('version')->first();
+$input=['method'=>'input','actor'=>$f['manager_id'],'key'=>$key(),'input'=>['kind'=>'criterion','source_ref'=>$old->source_ref,'version'=>$old->version+1,'previous_id'=>$old->id,'data'=>json_decode($old->data,true),'evidence'=>'Revisão concorrente sintética.']];$out=$pair($input,$input);$check($out,true);$proof['criterion_repetition_one_version']=true;$id=$out[0]['result']['id'];$ver=$out[0]['result']['version'];
+$decision=['method'=>'decide','actor'=>$f['reader_id'],'key'=>$key(),'input'=>['type'=>'input','id'=>$id,'version'=>$ver,'decision'=>'approved','reason'=>'Validação concorrente de hipótese sintética.']];$check($pair($decision,$decision),true);$proof['decision_repetition_one_effect']=true;
+$one=$input;$one['key']=$key();$one['input']['version']=$ver+1;$one['input']['previous_id']=$id;$two=$one;$two['key']=$key();$two['input']['data']['capacity']='20';$out=$pair($one,$two);$check($out,false);$proof['competing_criteria_one_successor']=true;$cid=$out[0]['result']['id'];$cv=$out[0]['result']['version'];
+app(CompanyContext::class)->selectFor($f['reader_id'],$f['tenant'],$f['company'],$f['unit']);app(IndustrialCosts::class)->decide($fx['lot'],$f['reader_id'],['type'=>'input','id'=>$cid,'version'=>$cv,'decision'=>'approved','reason'=>'Validado critério sintético vencedor.'],$key());
+$refs=$fx['refs']+['criterion'=>['id'=>$cid,'version'=>$cv]];$last=DB::table('ic_results')->where('lot_id',$fx['lot'])->orderByDesc('version')->first();
+$calc=['method'=>'calculate','actor'=>$f['manager_id'],'key'=>$key(),'input'=>['currency'=>'MZN','version'=>$last->version+1,'previous_id'=>$last->id,'refs'=>$refs]];$out=$pair($calc,$calc);$check($out,true);$proof['calculation_repetition_one_snapshot']=true;
+$last=DB::table('ic_results')->where('lot_id',$fx['lot'])->orderByDesc('version')->first();$calc['key']=$key();$calc['input']['version']=$last->version+1;$calc['input']['previous_id']=$last->id;$calc['input']['refs']['material_rate']=null;$two=$calc;$two['key']=$key();$two['input']['refs']=$refs;$check($pair($calc,$two),false);$proof['competing_calculations_one_current_allocation']=true;
+$last=DB::table('ic_results')->where('lot_id',$fx['lot'])->orderByDesc('version')->first();$calc['key']=$key();$calc['input']['version']=$last->version+1;$calc['input']['previous_id']=$last->id;$calc['input']['refs']=$refs;
+$stale=['method'=>'decide','actor'=>$f['reader_id'],'key'=>$key(),'input'=>['type'=>'result','id'=>$last->id,'version'=>$last->version,'decision'=>'approved','reason'=>'Aprovação agora obsoleta.']];$check($pair($calc,$stale),false);$proof['new_result_refuses_old_approval']=true;
+file_put_contents(base_path('docs/proofs/industrial-cost-concurrency.json'),json_encode(['policy'=>IndustrialCosts::POLICY,'database'=>'sgf_tempo_test','overlapping_processes_per_case'=>2,'checks'=>$proof,'synthetic_only'=>true],JSON_PRETTY_PRINT|JSON_THROW_ON_ERROR));echo "Six overlapping industrial concurrency cases passed; historical allocations not accumulated.\n";

scripts/industrial-cost-fixture.php

@@ -0,0 +1,7 @@
+<?php
+require __DIR__.'/../vendor/autoload.php';$app=require __DIR__.'/../bootstrap/app.php';$app->make(\Illuminate\Contracts\Console\Kernel::class)->bootstrap();
+\App\Modules\Industry\IndustrialCosts::guard();$file='C:/laragon/data/sgf-tempo/secrets/browser-fixture.json';$base=json_decode(file_get_contents($file),true,32,JSON_THROW_ON_ERROR);
+if(\Illuminate\Support\Facades\DB::table('ic_lots')->exists())throw new RuntimeException('Fresh synthetic proof required; nothing deleted.');
+$f=\Tests\Support\IndustrialCostFixture::create($base+['manager'=>\App\Models\User::findOrFail($base['manager_id']),'reader'=>\App\Models\User::findOrFail($base['reader_id'])],false);
+file_put_contents($file,json_encode($base+['industrial'=>array_intersect_key($f,array_flip(['lot','refs','criterionData']))],JSON_THROW_ON_ERROR));
+echo "Industrial synthetic lot and seven validated origins/rates prepared; criterion and calculations remain for browser demonstration. No workshop events created.\n";

scripts/industrial-cost-permissions-preview.php

@@ -0,0 +1,12 @@
+<?php
+// Read-only proposal. No apply or activation branch.
+require __DIR__.'/../vendor/autoload.php';$app=require __DIR__.'/../bootstrap/app.php';$app->make(\Illuminate\Contracts\Console\Kernel::class)->bootstrap();
+if(!\App\Modules\Identity\Services\LocalDatabaseGuard::allows())throw new RuntimeException('Own SGF development application database required.');
+$db=\Illuminate\Support\Facades\DB::class;$grants=[];
+foreach([1=>['view','prepare'],2=>['view','validate']] as $id=>$rights){
+ $u=$db::table('users')->where('id',$id)->first(['id','name','email']);if(!$u||!$db::table('company_memberships')->where(['user_id'=>$id,'tenant_id'=>1,'company_id'=>1])->exists())throw new RuntimeException('Existing account/member required.');
+ foreach($rights as $r){$g=['user_id'=>$id,'tenant_id'=>1,'company_id'=>1,'unit_id'=>1,'permission'=>'industrial_costs.'.$r];$grants[]=$g+['account'=>$u,'already_granted'=>$db::table('permission_grants')->where($g)->exists()];}
+}
+$company=$db::table('companies')->where(['id'=>1,'tenant_id'=>1])->value('name');$unit=$db::table('units')->where(['id'=>1,'company_id'=>1,'tenant_id'=>1])->value('name');if($company!=='Tempo Lda'||$unit!=='SEGI')throw new RuntimeException('Scope differs.');
+try{\App\Modules\Industry\IndustrialCosts::guard();throw new RuntimeException('Real industry costing not blocked.');}catch(\Symfony\Component\HttpKernel\Exception\HttpException $e){if($e->getStatusCode()!==403)throw $e;}
+echo json_encode(['mode'=>'preview_only','company'=>$company,'unit'=>$unit,'proposed_grants'=>$grants,'applied'=>false,'industrial_real_blocked'=>true,'migration_100000_applied'=>$db::table('migrations')->where('migration','2026_10_27_100000_create_industrial_cost_simulation')->exists()],JSON_PRETTY_PRINT|JSON_UNESCAPED_UNICODE|JSON_THROW_ON_ERROR).PHP_EOL;

scripts/industrial-cost-proof.php

@@ -0,0 +1,10 @@
+<?php
+require __DIR__.'/../vendor/autoload.php';$app=require __DIR__.'/../bootstrap/app.php';$app->make(\Illuminate\Contracts\Console\Kernel::class)->bootstrap();\App\Modules\Industry\IndustrialCosts::guard();
+$f=json_decode(file_get_contents('C:/laragon/data/sgf-tempo/secrets/browser-fixture.json'),true,32,JSON_THROW_ON_ERROR);$db=\Illuminate\Support\Facades\DB::class;$rows=$db::table('ic_results')->where('lot_id',$f['industrial']['lot'])->orderBy('version')->get();if($rows->count()<2)throw new RuntimeException('Two browser scenarios required.');
+$full=json_decode($rows[0]->snapshot,true);$partial=json_decode($rows[1]->snapshot,true);
+foreach(['material_exact'=>'1000','labour_exact'=>'500','indirect_rate_exact'=>'60','allocated_exact'=>'300','residual_exact'=>'300','selected_total_exact'=>'1800','unit_cost_exact'=>'180'] as $k=>$v)if($full[$k]!==$v)throw new RuntimeException('Full scenario differs.');
+if($partial['known_cost_exact']!=='800'||$partial['unit_cost_exact']!==null||$partial['selected_total_exact']!==null||!$partial['incomplete']||$partial['reconciliation']['known_origins_exact']!=='1100')throw new RuntimeException('Partial scenario differs.');
+foreach([$rows[0],$rows[1]] as $r){$d=$db::table('ic_decisions')->where(['result_id'=>$r->id,'decision'=>'approved'])->first();if(!$d||$d->actor_id===$r->actor_id)throw new RuntimeException('Distinct validation required.');}
+if($db::table('wo_entries')->exists()||$db::table('dc_calculations')->exists())throw new RuntimeException('Workshop/direct cost events unexpectedly created.');
+$proof=['policy'=>'INDUSTRIAL-COST-SIM-v1','database'=>'sgf_tempo_test','synthetic_only'=>true,'real_browser_login'=>true,'csrf_enabled'=>true,'distinct_roles'=>true,'full'=>['material'=>'1000','labour'=>'500','pool'=>'600','capacity_hm'=>'10','used_hm'=>'5','rate'=>'60','allocated'=>'300','residual'=>'300','cost'=>'1800','good_units'=>'10','unit_cost'=>'180','origins'=>'2100'],'partial'=>['known'=>'800','total'=>null,'unit_cost'=>null,'incomplete'=>true,'known_origins'=>'1100','residual'=>'300'],'workshop_events_created'=>0,'hypothesis_only'=>true,'development_migration_applied'=>false,'real_grants_applied'=>false,'user_acceptance'=>false];
+file_put_contents(base_path('docs/proofs/industrial-cost-browser-results.json'),json_encode($proof,JSON_PRETTY_PRINT|JSON_THROW_ON_ERROR));echo "Browser results checked: 1800/180 and 800 incomplete, residual 300, distinct validations and no duplicated workshop events.\n";

scripts/industrial-cost-worker.php

@@ -0,0 +1,7 @@
+<?php
+require __DIR__.'/../vendor/autoload.php';$app=require __DIR__.'/../bootstrap/app.php';$app->make(\Illuminate\Contracts\Console\Kernel::class)->bootstrap();
+\App\Modules\Industry\IndustrialCosts::guard();$in=json_decode(stream_get_contents(STDIN),true,32,JSON_THROW_ON_ERROR);
+app(\App\Shared\Context\CompanyContext::class)->selectFor($in['actor'],$in['tenant'],$in['company'],$in['unit']);
+if($in['pause']??false){$paused=false;\Illuminate\Support\Facades\DB::listen(function($q)use(&$paused){if(!$paused&&str_contains($q->sql,'"companies"')&&str_contains($q->sql,'for update')){$paused=true;echo "LOCK_HELD\n";flush();usleep(1200000);}});}
+try{$c=app(\App\Modules\Industry\IndustrialCosts::class);$out=$c->{$in['method']}($in['lot'],$in['actor'],$in['input'],$in['key']);echo json_encode(['status'=>200,'result'=>$out],JSON_THROW_ON_ERROR).PHP_EOL;}
+catch(\Symfony\Component\HttpKernel\Exception\HttpExceptionInterface $e){echo json_encode(['status'=>$e->getStatusCode()],JSON_THROW_ON_ERROR).PHP_EOL;}

tests/Feature/IndustrialCostsTest.php

@@ -0,0 +1,74 @@
+<?php
+namespace Tests\Feature;
+use App\Modules\Industry\IndustrialCosts;
+use App\Shared\Context\CompanyContext;
+use Illuminate\Foundation\Testing\RefreshDatabase;
+use Illuminate\Support\Facades\DB;
+use Illuminate\Support\Str;
+use Tests\Support\IndustrialCostFixture;
+use Tests\Support\IdentityFixture;
+use Tests\TestCase;
+final class IndustrialCostsTest extends TestCase {
+    use RefreshDatabase;
+    private array $f;private string $token;
+    protected function setUp(): void {parent::setUp();$this->f=IndustrialCostFixture::create();$this->login();}
+    private function login(string $who='manager'): void {$this->postJson('/api/login',['email'=>$this->f[$who]->email,'password'=>$this->f['password']])->assertOk();$this->token=$this->postJson('/api/context',['tenant_id'=>$this->f['tenant'],'company_id'=>$this->f['company'],'unit_id'=>$this->f['unit']])->assertOk()->json('context.token');}
+    private function send(string $action,array $in,?string $key=null,?int $lot=null){return $this->withHeaders(['X-SGF-Context'=>$this->token,'Idempotency-Key'=>$key??(string)Str::uuid()])->postJson('/api/industrial-costs/lots/'.($lot??$this->f['lot']).'/'.$action,$in);}
+    private function calc(array $extra=[],?string $key=null){return $this->send('calculations',array_replace(['currency'=>'MZN','version'=>1,'previous_id'=>null,'refs'=>$this->f['refs']],$extra),$key);}
+    private function snapshot(int $id): array {return json_decode(DB::table('ic_results')->find($id)->snapshot,true,64,JSON_THROW_ON_ERROR);}
+    private function decide(string $type,int $id,array $extra=[],?string $key=null){$r=DB::table($type==='input'?'ic_inputs':'ic_results')->find($id);return $this->send('decisions',array_replace(['type'=>$type,'id'=>$id,'version'=>$r->version,'decision'=>'approved','reason'=>'Revisão sintética da versão industrial.'],$extra),$key);}
+    private function change(string $kind,array $data,array $extra=[]){$old=DB::table('ic_inputs')->find($this->f['refs'][$kind]['id']);return $this->send('inputs',array_replace(['kind'=>$kind,'source_ref'=>$old->source_ref,'version'=>$old->version+1,'previous_id'=>$old->id,'data'=>$data,'evidence'=>'Correcção sintética explícita, histórico preservado.'],$extra));}
+    private function listing(){return $this->getJson('/api/industrial-costs')->assertOk();}
+    public function test_full_and_partial_scenarios_with_exact_reconciliations_and_separate_approval(): void {
+        $before=DB::table('wo_entries')->count();$id=$this->calc()->assertOk()->json('id');$s=$this->snapshot($id);
+        foreach(['material_exact'=>'1000','labour_exact'=>'500','labour_hours_exact'=>'5','indirect_rate_exact'=>'60','allocated_exact'=>'300','residual_exact'=>'300','known_cost_exact'=>'1800','unit_cost_exact'=>'180','good_units'=>'10'] as $k=>$v)$this->assertSame($v,$s[$k]);$this->assertSame('2100',$s['reconciliation']['known_origins_exact']);$this->assertTrue($s['reconciliation']['balanced']);$this->assertFalse($s['incomplete']);
+        IdentityFixture::grant($this->f['manager']->id,$this->f['tenant'],$this->f['company'],'industrial_costs.validate',$this->f['unit']);$this->decide('result',$id)->assertForbidden();$this->login('reader');$this->decide('result',$id)->assertOk();$this->login();
+        $refs=$this->f['refs'];$refs['material_rate']=null;$partial=$this->calc(['version'=>2,'previous_id'=>$id,'refs'=>$refs])->assertOk()->json('id');$p=$this->snapshot($partial);$this->assertSame('800',$p['known_cost_exact']);$this->assertSame('1100',$p['reconciliation']['known_origins_exact']);$this->assertSame('partial_known_only',$p['reconciliation']['coverage']);$this->assertNull($p['selected_total_exact']);$this->assertNull($p['unit_cost_exact']);$this->assertTrue($p['incomplete']);$this->assertCount(1,$p['pending']);$this->assertSame($before,DB::table('wo_entries')->count());$this->listing()->assertJsonPath('lots.0.results.0.current',false);
+    }
+    public function test_zero_rate_and_nonfinite_representation_remain_exact(): void {
+        $r=DB::table('ic_inputs')->find($this->f['refs']['material_rate']['id']);$d=json_decode($r->data,true);$d['amount']='0';$zero=$this->change('material_rate',$d)->assertOk()->json('id');$this->login('reader');$this->decide('input',$zero)->assertOk();$this->login();$refs=$this->f['refs'];$refs['material_rate']=['id'=>$zero,'version'=>2];$first=$this->calc(['refs'=>$refs])->assertOk()->json('id');$s=$this->snapshot($first);$this->assertSame('0',$s['material_exact']);$this->assertSame('800',$s['selected_total_exact']);$this->assertSame('80',$s['unit_cost_exact']);$this->assertFalse($s['incomplete']);
+        $production=DB::table('ic_inputs')->find($refs['production']['id']);$pd=json_decode($production->data,true);$pd['quantity']='3';$new=$this->change('production',$pd)->assertOk()->json('id');$this->login('reader');$this->decide('input',$new)->assertOk();$this->login();$refs['production']=['id'=>$new,'version'=>2];$second=$this->calc(['refs'=>$refs,'version'=>2,'previous_id'=>$first])->assertOk()->json('id');$this->assertSame('800/3',$this->snapshot($second)['unit_cost_exact']);
+    }
+    public function test_capacity_zero_overuse_unknown_sources_units_and_numeric_coercion_refused(): void {
+        $criterion=$this->f['criterionData'];foreach(['0','-1','1e2','1.000000001',''] as $capacity)$this->change('criterion',array_replace($criterion,['capacity'=>$capacity]))->assertStatus(422);
+        $this->change('criterion',array_replace($criterion,['capacity'=>10]))->assertStatus(422);$this->change('criterion',array_replace($criterion,['driver_unit'=>'H']))->assertStatus(422);
+        $small=$this->change('criterion',array_replace($criterion,['capacity'=>'4']))->assertOk()->json('id');$this->login('reader');$this->decide('input',$small)->assertOk();$this->login();$refs=$this->f['refs'];$refs['criterion']=['id'=>$small,'version'=>2];$this->calc(['refs'=>$refs])->assertStatus(409);
+        $pd=['quantity'=>'0','unit'=>'UN','event_date'=>'2026-10-27','completed'=>true];$this->change('production',$pd)->assertStatus(422);$this->change('production',array_replace($pd,['quantity'=>'10','completed'=>false]))->assertStatus(422);
+        $refs=$this->f['refs'];$refs['material']=['id'=>$refs['pool']['id'],'version'=>1];$this->calc(['refs'=>$refs])->assertStatus(409);$this->calc(['currency'=>'USD'])->assertStatus(422);$refs=$this->f['refs'];$refs['labour']=null;$this->calc(['refs'=>$refs])->assertStatus(422);
+    }
+    public function test_criterion_source_and_rate_changes_invalidate_results_without_editing_history(): void {
+        $id=$this->calc()->assertOk()->json('id');$snapshot=DB::table('ic_results')->find($id)->snapshot;$this->login('reader');$this->decide('result',$id)->assertOk();$this->login();
+        $c=$this->change('criterion',array_replace($this->f['criterionData'],['capacity'=>'20']))->assertOk()->json('id');$this->listing()->assertJsonPath('lots.0.results.0.current',false);$this->calc(['version'=>2,'previous_id'=>$id])->assertStatus(409);$this->login('reader');$this->decide('input',$this->f['refs']['criterion']['id'])->assertStatus(409);$this->decide('input',$c)->assertOk();$this->login();
+        $refs=$this->f['refs'];$refs['criterion']=['id'=>$c,'version'=>2];$new=$this->calc(['refs'=>$refs,'version'=>2,'previous_id'=>$id])->assertOk()->json('id');$this->assertSame('150',$this->snapshot($new)['allocated_exact']);$this->assertSame('450',$this->snapshot($new)['residual_exact']);$this->assertSame($snapshot,DB::table('ic_results')->find($id)->snapshot);
+        $rate=DB::table('ic_inputs')->find($refs['labour_rate']['id']);$d=json_decode($rate->data,true);$d['amount']='101';$this->change('labour_rate',$d)->assertOk();$this->listing()->assertJsonPath('lots.0.results.1.current',false);
+    }
+    public function test_idempotency_recovery_after_outbox_failure_and_response_loss(): void {
+        $key=(string)Str::uuid();DB::unprepared("CREATE FUNCTION ic_fail_test() RETURNS trigger LANGUAGE plpgsql AS \$\$ BEGIN RAISE EXCEPTION 'IC_TEST_OUTBOX_FAILURE'; END; \$\$; CREATE TRIGGER ic_fail_test BEFORE INSERT ON ic_outbox FOR EACH ROW EXECUTE FUNCTION ic_fail_test()");$before=DB::table('ic_commands')->count();$this->assertGreaterThanOrEqual(500,$this->calc([],$key)->status());$this->assertSame(0,DB::table('ic_results')->count());$this->assertSame($before,DB::table('ic_commands')->count());DB::unprepared('DROP TRIGGER ic_fail_test ON ic_outbox; DROP FUNCTION ic_fail_test()');
+        $id=$this->calc([],$key)->assertOk()->json('id');$this->calc([],$key)->assertOk()->assertJsonPath('id',$id)->assertJsonPath('replayed',true);$refs=$this->f['refs'];$refs['material_rate']=null;$this->calc(['refs'=>$refs],$key)->assertStatus(409);$this->assertSame(1,DB::table('ic_results')->count());$this->assertSame(DB::table('ic_commands')->count(),DB::table('ic_events')->count());$this->assertSame(DB::table('ic_events')->count(),DB::table('ic_outbox')->count());
+    }
+    public function test_permissions_scope_revocation_and_direct_cost_grants_do_not_imply_industrial(): void {
+        $id=$this->calc()->assertOk()->json('id');$this->login('reader');$this->calc()->assertForbidden();$this->login('limited');IdentityFixture::grant($this->f['limited']->id,$this->f['tenant'],$this->f['company'],'direct_costs.view',$this->f['unit']);$this->getJson('/api/industrial-costs')->assertForbidden();$this->login();
+        $this->send('calculations',['currency'=>'MZN','version'=>1,'refs'=>$this->f['refs']],null,$this->f['lot']+999)->assertForbidden();DB::table('permission_grants')->where(['user_id'=>$this->f['manager']->id,'permission'=>'industrial_costs.prepare'])->delete();$this->calc()->assertForbidden();
+        $this->postJson('/api/context',['tenant_id'=>$this->f['tenant'],'company_id'=>$this->f['company'],'unit_id'=>$this->f['hidden']])->assertForbidden();
+        $this->postJson('/api/context',['tenant_id'=>$this->f['tenant'],'company_id'=>$this->f['sibling'],'unit_id'=>$this->f['siblingUnit']])->assertOk();$this->getJson('/api/industrial-costs')->assertForbidden();
+    }
+    public function test_canonical_origin_cannot_move_between_lots_or_direct_and_indirect_roles(): void {
+        $id=$this->f['refs']['material']['id'];$source=DB::table('ic_inputs')->find($id);$pool=DB::table('ic_inputs')->find($this->f['refs']['pool']['id']);$this->change('pool',json_decode($pool->data,true),['source_ref'=>$source->source_ref])->assertStatus(409);
+        $c=app(IndustrialCosts::class);app(CompanyContext::class)->selectFor($this->f['manager']->id,$this->f['tenant'],$this->f['company'],$this->f['unit']);$lot=$c->open($this->f['manager']->id,['reference'=>'LOT-OTHER','product_reference'=>'PROD-OTHER','product_name'=>'Produto sintético 2','centre'=>'Centro teste','period_start'=>'2026-10-01','period_end'=>'2026-10-31','currency'=>'MZN'],(string)Str::uuid())['id'];
+        $this->send('inputs',['kind'=>'material','source_ref'=>$source->source_ref,'version'=>1,'data'=>json_decode($source->data,true),'evidence'=>'Duplicação proibida.'],null,$lot)->assertStatus(409);
+        $this->assertSame(0,DB::table('wo_entries')->count());
+    }
+    public function test_refusal_old_decisions_bulk_sql_and_environment_blocks(): void {
+        $new=$this->change('criterion',$this->f['criterionData'])->assertOk()->json('id');$this->login('reader');$this->decide('input',$new,['decision'=>'refused'])->assertOk();$this->login();$refs=$this->f['refs'];$refs['criterion']=['id'=>$new,'version'=>2];$this->calc(['refs'=>$refs])->assertStatus(409);
+        foreach(['UPDATE ic_inputs SET unit_id=999','DELETE FROM ic_inputs'] as $sql){try{DB::transaction(fn()=>DB::statement($sql));$this->fail('Immutable SQL accepted');}catch(\Illuminate\Database\QueryException){$this->assertTrue(true);}}
+        $this->app['env']='local';$this->getJson('/api/industrial-costs')->assertOk()->assertJsonPath('blocked',true);try{IndustrialCosts::guard();$this->fail('Real costing allowed');}catch(\Symfony\Component\HttpKernel\Exception\HttpException $e){$this->assertSame(403,$e->getStatusCode());}$this->app['env']='testing';$old=config('database.connections.pgsql.database');config(['database.connections.pgsql.database'=>'sgf_tempo_dev']);try{IndustrialCosts::guard();$this->fail('Wrong database accepted');}catch(\RuntimeException $e){$this->assertStringContainsString('SGF_TEST_DATABASE_REFUSED',$e->getMessage());}finally{config(['database.connections.pgsql.database'=>$old]);}
+    }
+    public function test_corrected_material_requires_new_rate_and_cannot_be_read_from_another_unit(): void {
+        $first=$this->calc()->assertOk()->json('id');$oldSnapshot=DB::table('ic_results')->find($first)->snapshot;
+        $material=DB::table('ic_inputs')->find($this->f['refs']['material']['id']);$data=json_decode($material->data,true);$data['quantity']='21';$new=$this->change('material',$data)->assertOk()->json('id');$this->listing()->assertJsonPath('lots.0.results.0.current',false);
+        $this->login('reader');$this->decide('input',$new)->assertOk();$this->decide('result',$first)->assertStatus(409);$this->login();$refs=$this->f['refs'];$refs['material']=['id'=>$new,'version'=>2];$this->calc(['version'=>2,'previous_id'=>$first,'refs'=>$refs])->assertStatus(409);
+        $rate=DB::table('ic_inputs')->find($refs['material_rate']['id']);$rd=json_decode($rate->data,true);$rd['source_id']=$new;$rd['source_version']=2;$newRate=$this->change('material_rate',$rd)->assertOk()->json('id');$this->login('reader');$this->decide('input',$newRate)->assertOk();$this->login();$refs['material_rate']=['id'=>$newRate,'version'=>2];$second=$this->calc(['version'=>2,'previous_id'=>$first,'refs'=>$refs])->assertOk()->json('id');$this->assertSame('1850',$this->snapshot($second)['selected_total_exact']);$this->assertSame($oldSnapshot,DB::table('ic_results')->find($first)->snapshot);
+        foreach(['unit.view','industrial_costs.view','industrial_costs.prepare'] as $right)IdentityFixture::grant($this->f['manager']->id,$this->f['tenant'],$this->f['company'],$right,$this->f['hidden']);
+        $this->token=$this->postJson('/api/context',['tenant_id'=>$this->f['tenant'],'company_id'=>$this->f['company'],'unit_id'=>$this->f['hidden']])->assertOk()->json('context.token');$this->listing()->assertJsonCount(0,'lots');$this->calc()->assertForbidden();
+    }
+}

tests/Support/IndustrialCostFixture.php

@@ -0,0 +1,18 @@
+<?php
+namespace Tests\Support;
+use App\Modules\Industry\IndustrialCosts;
+use App\Shared\Context\CompanyContext;
+use Illuminate\Support\Str;
+final class IndustrialCostFixture {
+    public static function create(?array $base=null,bool $criterion=true): array {
+        IndustrialCosts::guard();$f=$base??DocumentPreviewFixture::create();
+        foreach(['manager'=>['view','prepare'],'reader'=>['view','validate']] as $who=>$rights)foreach($rights as $r)IdentityFixture::grant($f[$who]->id,$f['tenant'],$f['company'],'industrial_costs.'.$r,$f['unit']);
+        $c=app(IndustrialCosts::class);$key=fn()=>(string)Str::uuid();$select=fn($who)=>app(CompanyContext::class)->selectFor($f[$who]->id,$f['tenant'],$f['company'],$f['unit']);$select('manager');
+        $lot=$c->open($f['manager']->id,['reference'=>'LOT-TEST-'.Str::uuid(),'product_reference'=>'PROD-TEST-'.Str::uuid(),'product_name'=>'Produto industrial sintético','centre'=>'Centro Fabrico A — ensaio','period_start'=>'2026-10-01','period_end'=>'2026-10-31','currency'=>'MZN'],$key())['id'];$refs=[];
+        $add=function($kind,$data)use(&$refs,$c,$f,$lot,$select,$key){$select('manager');$id=$c->input($lot,$f['manager']->id,['kind'=>$kind,'source_ref'=>'IND-TEST-'.strtoupper($kind).'-'.Str::uuid(),'version'=>1,'previous_id'=>null,'data'=>$data,'evidence'=>'Origem/pressuposto industrial exclusivamente sintético.'],$key())['id'];$select('reader');$c->decide($lot,$f['reader']->id,['type'=>'input','id'=>$id,'version'=>1,'decision'=>'approved','reason'=>'Validação de dados sintéticos de custo, não verificação técnica real.'],$key());$refs[$kind]=['id'=>$id,'version'=>1];return $id;};
+        foreach(['material'=>['20','KG'],'labour'=>['300','MIN'],'pool'=>['600','MZN'],'machine'=>['5','HM'],'production'=>['10','UN']] as $kind=>[$quantity,$unit])$add($kind,['quantity'=>$quantity,'unit'=>$unit,'event_date'=>'2026-10-27']+($kind==='production'?['completed'=>true]:[]));
+        foreach(['material'=>['50','KG'],'labour'=>['100','H']] as $kind=>[$amount,$unit])$add($kind.'_rate',['source_id'=>$refs[$kind]['id'],'source_version'=>1,'amount'=>$amount,'currency'=>'MZN','unit'=>$unit]);
+        $criterionData=['pool_id'=>$refs['pool']['id'],'pool_version'=>1,'machine_id'=>$refs['machine']['id'],'machine_version'=>1,'capacity'=>'10','driver_unit'=>'HM','hypothesis'=>'synthetic_only'];
+        if($criterion)$add('criterion',$criterionData);$select('manager');return $f+compact('lot','refs','criterionData');
+    }
+}