X-Git-Url: http://wagnertech.de/gitweb/gitweb.cgi/mfinanz.git/blobdiff_plain/4440782f0737cd715dbd96851ecc2dbd8cd639f2..82515b2d93dc5632f24d6e0b6f8f05f3fd19fbb0:/SL/DB/Manager/Part.pm

diff --git a/SL/DB/Manager/Part.pm b/SL/DB/Manager/Part.pm
new file mode 100644
index 000000000..1564b9b79
--- /dev/null
+++ b/SL/DB/Manager/Part.pm
@@ -0,0 +1,63 @@
+package SL::DB::Manager::Part;
+
+use strict;
+
+use SL::DB::Helpers::Manager;
+use base qw(SL::DB::Helpers::Manager);
+
+use Carp;
+use SL::DBUtils;
+
+sub object_class { 'SL::DB::Part' }
+
+__PACKAGE__->make_manager_methods;
+
+sub type_filter {
+  my $class = shift;
+  my $type  = lc(shift || '');
+
+  if ($type =~ m/^part/) {
+    return (and => [ or                    => [ assembly => 0, assembly => undef ],
+                     '!inventory_accno_id' => 0,
+                     '!inventory_accno_id' => undef,
+                   ]);
+
+  } elsif ($type =~ m/^service/) {
+    return (and => [ or => [ assembly           => 0, assembly           => undef ],
+                     or => [ inventory_accno_id => 0, inventory_accno_id => undef ],
+                   ]);
+
+  } elsif ($type =~ m/^assembl/) {
+    return (assembly => 1);
+
+  }
+
+  return ();
+}
+
+sub get_ordered_qty {
+  my $class    = shift;
+  my @part_ids = @_;
+
+  return () unless @part_ids;
+
+  my $placeholders = join ',', ('?') x @part_ids;
+  my $query        = <<SQL;
+    SELECT oi.parts_id, SUM(oi.base_qty) AS qty
+    FROM orderitems oi
+    LEFT JOIN oe ON (oi.trans_id = oe.id)
+    WHERE (oi.parts_id IN ($placeholders))
+      AND (NOT COALESCE(oe.quotation, FALSE))
+      AND (NOT COALESCE(oe.closed,    FALSE))
+      AND (NOT COALESCE(oe.delivered, FALSE))
+      AND (COALESCE(oe.vendor_id, 0) <> 0)
+    GROUP BY oi.parts_id
+SQL
+
+  my %qty_by_id = map { $_->{parts_id} => $_->{qty} * 1 } @{ selectall_hashref_query($::form, $class->object_class->init_db->dbh, $query, @part_ids) };
+  map { $qty_by_id{$_} ||= 0 } @part_ids;
+
+  return %qty_by_id;
+}
+
+1;