Wiedervorlagenbericht sortierbar gemacht.
[kivitendo-erp.git] / SL / FU.pm
1 # Follow-Ups
2
3 package FU;
4
5 use List::Util qw(first);
6
7 use SL::Common;
8 use SL::DBUtils;
9 use SL::Notes;
10
11 sub save {
12   $main::lxdebug->enter_sub();
13
14   my $self     = shift;
15   my %params   = @_;
16
17   my $myconfig = \%main::myconfig;
18   my $form     = $main::form;
19
20   my $dbh      = $params{dbh} || $form->get_standard_dbh($myconfig);
21   my ($query, @values);
22
23   if (!$params{id}) {
24     ($params{id}) = selectrow_query($form, $dbh, qq|SELECT nextval('follow_up_id')|);
25
26     $query = qq|INSERT INTO follow_ups (created_by, done, note_id, follow_up_date, created_for_user, id)
27                 VALUES ((SELECT id FROM employee WHERE login = ?), ?, ?, ?, ?, ?)|;
28
29     push @values, $form->{login};
30
31   } else {
32     $query = qq|UPDATE follow_ups SET done = ?, note_id = ?, follow_up_date = ?, created_for_user = ? WHERE id = ?|;
33   }
34
35   $params{note_id} = Notes->save('id'           => $params{note_id},
36                                  'trans_id'     => $params{id},
37                                  'trans_module' => 'fu',
38                                  'subject'      => $params{subject},
39                                  'body'         => $params{body});
40
41   $params{done} = 1 if (!defined $params{done});
42
43   do_query($form, $dbh, $query, @values, $params{done} ? 't' : 'f', conv_i($params{note_id}), $params{follow_up_date}, conv_i($params{created_for_user}), conv_i($params{id}));
44
45   do_query($form, $dbh, qq|DELETE FROM follow_up_links WHERE follow_up_id = ?|, conv_i($params{id}));
46
47   my $query = qq|INSERT INTO follow_up_links (follow_up_id, trans_id, trans_type, trans_info) VALUES (?, ?, ?, ?)|;
48   my $sth   = prepare_query($form, $dbh, $query);
49
50   foreach my $link (@{ $params{LINKS} }) {
51     do_statement($form, $sth, $query, conv_i($params{id}), conv_i($link->{trans_id}), $link->{trans_type}, $link->{trans_info});
52   }
53
54   $sth->finish();
55
56   $dbh->commit() unless ($params{dbh});
57
58   $main::lxdebug->leave_sub();
59 }
60
61 sub finish {
62   $main::lxdebug->enter_sub();
63
64   my $self     = shift;
65   my %params   = @_;
66
67   Common::check_params(\%params, 'id');
68
69   my $myconfig = \%main::myconfig;
70   my $form     = $main::form;
71
72   my $dbh      = $form->get_standard_dbh($myconfig);
73
74   do_query($form, $dbh, qq|UPDATE follow_ups SET done = TRUE WHERE id = ?|, conv_i($params{id}));
75
76   $dbh->commit();
77
78   $main::lxdebug->leave_sub();
79 }
80
81 sub delete {
82   $main::lxdebug->enter_sub();
83
84   my $self     = shift;
85   my %params   = @_;
86
87   Common::check_params(\%params, 'id');
88
89   my $myconfig = \%main::myconfig;
90   my $form     = $main::form;
91
92   my $dbh      = $form->get_standard_dbh($myconfig);
93
94   my $id       = conv_i($params{id});
95
96   do_query($form, $dbh, qq|DELETE FROM follow_up_links WHERE follow_up_id = ?|,                         $id);
97   do_query($form, $dbh, qq|DELETE FROM follow_ups      WHERE id = ?|,                                   $id);
98   do_query($form, $dbh, qq|DELETE FROM notes           WHERE (trans_id = ?) AND (trans_module = 'fu')|, $id);
99
100   $dbh->commit();
101
102   $main::lxdebug->leave_sub();
103 }
104
105 sub retrieve {
106   $main::lxdebug->enter_sub();
107
108   my $self     = shift;
109   my %params   = @_;
110
111   Common::check_params(\%params, 'id');
112
113   my $myconfig = \%main::myconfig;
114   my $form     = $main::form;
115
116   my $dbh      = $form->get_standard_dbh($myconfig);
117   my ($query, @values);
118
119   my ($employee_id) = selectrow_query($form, $dbh, qq|SELECT id FROM employee WHERE login = ?|, $form->{login});
120   $query            = qq|SELECT fu.*, n.subject, n.body, n.created_by
121                          FROM follow_ups fu
122                          LEFT JOIN notes n ON (fu.note_id = n.id)
123                          WHERE (fu.id = ?)
124                            AND (   (fu.created_by = ?) OR (fu.created_for_user = ?)
125                                 OR (fu.created_by IN (SELECT DISTINCT what FROM follow_up_access WHERE who = ?)))|;
126   my $ref           = selectfirst_hashref_query($form, $dbh, $query, conv_i($params{id}), $employee_id, $employee_id, $employee_id);
127
128   if (!$ref) {
129     $main::lxdebug->leave_sub();
130     return undef;
131   }
132
133   $ref->{LINKS} = $self->retrieve_links(%{ $ref });
134
135   $main::lxdebug->leave_sub();
136
137   return $ref;
138 }
139
140 sub retrieve_links {
141   $main::lxdebug->enter_sub();
142
143   my $self     = shift;
144   my %params   = @_;
145
146   Common::check_params(\%params, qw(id));
147
148   my $myconfig = \%main::myconfig;
149   my $form     = $main::form;
150
151   my $dbh      = $form->get_standard_dbh($myconfig);
152
153   my $query    = qq|SELECT ful.trans_id, ful.trans_type, ful.trans_info, fu.note_id
154                     FROM follow_up_links ful
155                     LEFT JOIN follow_ups fu ON (ful.follow_up_id = fu.id)
156                     WHERE ful.follow_up_id = ?
157                     ORDER BY ful.itime|;
158
159   my $links    = selectall_hashref_query($form, $dbh, $query, conv_i($params{id}));
160
161   foreach my $link_ref (@{ $links }) {
162     my $link_details = FU->link_details(%{ $link_ref });
163     map { $link_ref->{$_} = $link_details->{$_} } keys %{ $link_details} if ($link_details);
164   }
165
166   $main::lxdebug->leave_sub();
167
168   return $links;
169 }
170
171 sub follow_ups {
172   $main::lxdebug->enter_sub();
173
174   my $self     = shift;
175   my %params   = @_;
176
177   my $myconfig = \%main::myconfig;
178   my $form     = $main::form;
179
180   my $dbh      = $form->get_standard_dbh($myconfig);
181   my ($query, $where, $where_user);
182
183   my ($employee_id) = selectrow_query($form, $dbh, qq|SELECT id FROM employee WHERE login = ?|, $form->{login});
184   my @values        = ($employee_id, $employee_id);
185
186   if ($params{trans_id}) {
187     $where .= qq| AND EXISTS (SELECT * FROM follow_up_links ful
188                               WHERE (ful.follow_up_id = fu.id) AND (ful.trans_id = ?))|;
189     push @values, conv_i($params{trans_id});
190   }
191
192   if ($params{due_only}) {
193     $where .= qq| AND (fu.follow_up_date <= current_date)|;
194   }
195
196   if ($params{done} ne $params{not_done}) {
197     my $not  = $params{not_done} ? 'NOT' : '';
198     $where  .= qq| AND $not COALESCE(fu.done, FALSE)|;
199   }
200
201   if ($params{not_id}) {
202     $where .= qq| AND (fu.id <> ?)|;
203     push @values, conv_i($params{not_id});
204   }
205
206   foreach my $item (qw(subject body)) {
207     next unless ($params{$item});
208     $where .= qq| AND (n.${item} ILIKE ?)|;
209     push @values, '%' . $params{$item} . '%';
210   }
211
212   if ($params{reference}) {
213     $where .= qq| AND EXISTS (SELECT ful.follow_up_id
214                               FROM follow_up_links ful
215                               WHERE (ful.follow_up_id = fu.id)
216                                 AND (ful.trans_info ILIKE ?)
217                               LIMIT 1)|;
218     push @values, '%' . $params{reference} . '%';
219   }
220
221   if ($params{follow_up_date_from}) {
222     $where .= qq| AND (fu.follow_up_date >= ?)|;
223     push @values, conv_date($params{follow_up_date_from});
224   }
225   if ($params{follow_up_date_to}) {
226     $where .= qq| AND (fu.follow_up_date <= ?)|;
227     push @values, conv_date($params{follow_up_date_to});
228   }
229
230   if ($params{itime_from}) {
231     $where .= qq| AND (date_trunc('DAY', fu.itime) >= ?)|;
232     push @values, conv_date($params{itime_from});
233   }
234   if ($params{itime_to}) {
235     $where .= qq| AND (date_trunc('DAY', fu.itime) <= ?)|;
236     push @values, conv_date($params{itime_to});
237   }
238
239   if ($params{all_users}) {
240     $where_user = qq|OR (fu.created_by IN (SELECT DISTINCT what FROM follow_up_access WHERE who = ?))|;
241     push @values, $employee_id;
242   }
243
244   my $order_by = '';
245
246   if ($form->{sort} ne 'title') {
247     my %sort_columns = (
248       'follow_up_date' => [ qw(fu.follow_up_date fu.id) ],
249       'created_on'     => [ qw(created_on fu.id) ],
250       'subject'        => [ qw(lower(n.subject)) ],
251       );
252
253     my $sortdir = !defined $form->{sortdir} ? 'ASC' : $form->{sortdir} ? 'ASC' : 'DESC';
254     my $sortkey = $sort_columns{$form->{sort}} ? $form->{sort} : 'follow_up_date';
255     $order_by   = 'ORDER BY ' . join(', ', map { "$_ $sortdir" } @{ $sort_columns{$sortkey} });
256   }
257
258   $query  = qq|SELECT fu.*, n.subject, n.body, n.created_by,
259                  fu.follow_up_date <= current_date AS due,
260                  fu.itime::DATE                    AS created_on,
261                  COALESCE(eby.name,  eby.login)    AS created_by_name,
262                  COALESCE(efor.name, efor.login)   AS created_for_user_name
263                FROM follow_ups fu
264                LEFT JOIN notes    n    ON (fu.note_id          = n.id)
265                LEFT JOIN employee eby  ON (n.created_by        = eby.id)
266                LEFT JOIN employee efor ON (fu.created_for_user = efor.id)
267                WHERE ((fu.created_by = ?) OR (fu.created_for_user = ?)
268                       $where_user)
269                  $where
270                $order_by|;
271
272   my $follow_ups = selectall_hashref_query($form, $dbh, $query, @values);
273
274   if (!scalar @{ $follow_ups }) {
275     $main::lxdebug->leave_sub();
276     return $follow_ups;
277   }
278
279   foreach my $fu (@{ $follow_ups }) {
280     $fu->{LINKS} = $self->retrieve_links(%{ $fu });
281   }
282
283   if ($form->{sort} eq 'title') {
284     my $dir_factor = !defined $form->{sortdir} ? 1 : $form->{sortdir} ? 1 : -1;
285     $follow_ups    = [ map  { $_->[1] }
286                        sort { ($a->[0] cmp $b->[0]) * $dir_factor }
287                        map  { my $fu = $follow_ups->[$_]; [ @{ $fu->{LINKS} } ? lc($fu->{LINKS}->[0]->{title}) : '', $fu ] }
288                        (0 .. scalar(@{ $follow_ups }) - 1) ];
289   }
290
291   $main::lxdebug->leave_sub();
292
293   return $follow_ups;
294 }
295
296 sub link_details {
297   $main::lxdebug->enter_sub();
298
299   my $self     = shift;
300   my %params   = @_;
301
302   Common::check_params(\%params, qw(trans_id trans_type));
303
304   my $myconfig = \%main::myconfig;
305   my $form     = $main::form;
306   my $locale   = $main::locale;
307
308   my $q_id     = $form->quote($params{trans_id});
309   my $link;
310
311   if ($params{trans_type} eq 'customer') {
312     $link = {
313       'url'   => 'ct.pl?action=edit&db=customer&id=' . $form->quote($params{trans_id}) . '&edit_note_id=' . $form->quote($params{note_id}),
314       'title' => $locale->text('Customer') . " '$params{trans_info}'",
315     };
316
317   } elsif ($params{trans_type} eq 'vendor') {
318     $link = {
319       'url'   => 'ct.pl?action=edit&type=sales_quotation&id=' . $params{trans_id} . '&edit_note_id=' . $form->quote($params{note_id}),
320       'title' => $locale->text('Vendor') . " '$params{trans_info}'",
321     };
322
323   } elsif ($params{trans_type} eq 'sales_quotation') {
324     $link = {
325       'url'   => 'oe.pl?action=edit&type=sales_quotation&id=' . $params{trans_id},
326       'title' => $locale->text('Sales quotation') . " $params{trans_info}",
327     };
328
329   } elsif ($params{trans_type} eq 'sales_order') {
330     $link = {
331       'url'   => 'oe.pl?action=edit&type=sales_order&id=' . $params{trans_id},
332       'title' => $locale->text('Sales Order') . " $params{trans_info}",
333     };
334
335   } elsif ($params{trans_type} eq 'sales_invoice') {
336     $link = {
337       'url'   => 'is.pl?action=edit&type=invoice&id=' . $params{trans_id},
338       'title' => $locale->text('Sales Invoice') . " $params{trans_info}",
339     };
340
341   } elsif ($params{trans_type} eq 'credit_note') {
342     $link = {
343       'url'   => 'is.pl?action=edit&type=credit_note&id=' . $params{trans_id},
344       'title' => $locale->text('Credit Note') . " $params{trans_info}",
345     };
346
347   } elsif ($params{trans_type} eq 'dunning') {
348     $link = {
349       'url'   => 'dn.pl?action=print_dunning&format=pdf&media=screen&dunning_id=' . $params{trans_id},
350       'title' => $locale->text('Dunning') . " $params{trans_info}",
351     };
352
353   } elsif ($params{trans_type} eq 'request_quotation') {
354     $link = {
355       'url'   => 'oe.pl?action=edit&type=request_quotation&id=' . $params{trans_id},
356       'title' => $locale->text('Request quotation') . " $params{trans_info}",
357     };
358
359   } elsif ($params{trans_type} eq 'purchase_order') {
360     $link = {
361       'url'   => 'oe.pl?action=edit&type=purchase_order&id=' . $params{trans_id},
362       'title' => $locale->text('Purchase Order') . " $params{trans_info}",
363     };
364
365   } elsif ($params{trans_type} eq 'vendor_invoice') {
366     $link = {
367       'url'   => 'ir.pl?action=edit&type=invoice&id=' . $params{trans_id},
368       'title' => $locale->text('Vendor Invoice') . " $params{trans_info}",
369     };
370
371   } elsif ($params{trans_type} eq 'ar_transaction') {
372     $link = {
373       'url'   => 'ar.pl?action=editid=' . $params{trans_id},
374       'title' => $locale->text('AR Transaction') . " $params{trans_info}",
375     };
376
377   } elsif ($params{trans_type} eq 'ap_transaction') {
378     $link = {
379       'url'   => 'ap.pl?action=editid=' . $params{trans_id},
380       'title' => $locale->text('AP Transaction') . " $params{trans_info}",
381     };
382
383   } elsif ($params{trans_type} eq 'gl_transaction') {
384     $link = {
385       'url'   => 'gl.pl?action=edit&id=' . $params{trans_id},
386       'title' => $locale->text('GL Transaction') . " $params{trans_info}",
387     };
388
389   }
390
391   $main::lxdebug->leave_sub();
392
393   return $link || { };
394 }
395
396 sub save_access_rights {
397   $main::lxdebug->enter_sub();
398
399   my $self     = shift;
400   my %params   = @_;
401
402   Common::check_params(\%params, 'access');
403
404   my $myconfig = \%main::myconfig;
405   my $form     = $main::form;
406
407   my $dbh      = $form->get_standard_dbh($myconfig);
408
409   my ($id)     = selectrow_query($form, $dbh, qq|SELECT id FROM employee WHERE login = ?|, $form->{login});
410
411   my $query    = qq|INSERT INTO follow_up_access (who, what) VALUES (?, ?)|;
412   my $sth      = prepare_query($form, $dbh, $query);
413
414   do_query($form, $dbh, qq|DELETE FROM follow_up_access WHERE what = ?|, $id);
415
416   while (my ($who, $access_allowed) = each %{ $params{access} }) {
417     next unless ($access_allowed);
418
419     do_statement($form, $sth, $query, conv_i($who), $id);
420   }
421
422   $sth->finish();
423
424   $dbh->commit();
425
426   $main::lxdebug->leave_sub();
427 }
428
429 sub retrieve_access_rights {
430   $main::lxdebug->enter_sub();
431
432   my $self     = shift;
433   my %params   = @_;
434
435   my $myconfig = \%main::myconfig;
436   my $form     = $main::form;
437
438   my $dbh      = $form->get_standard_dbh($myconfig);
439
440   my $sth      = prepare_execute_query($form, $dbh, qq|SELECT who FROM follow_up_access WHERE what = (SELECT id FROM employee WHERE login = ?)|, $form->{login});
441   my $access   = {};
442
443   while (my $ref = $sth->fetchrow_hashref()) {
444     $access->{$ref->{who}} = 1;
445   }
446
447   $sth->finish();
448
449   $main::lxdebug->leave_sub();
450
451   return $access;
452 }
453
454 1;