b8edf580c4e415d55824206f416c4c5c89865517
[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        = ();
185   my @values_user   = ();
186
187   if ($params{trans_id}) {
188     $where .= qq| AND EXISTS (SELECT * FROM follow_up_links ful
189                               WHERE (ful.follow_up_id = fu.id) AND (ful.trans_id = ?))|;
190     push @values, conv_i($params{trans_id});
191   }
192
193   if ($params{due_only}) {
194     $where .= qq| AND (fu.follow_up_date <= current_date)|;
195   }
196
197   if ($params{done} ne $params{not_done}) {
198     my $not  = $params{not_done} ? 'NOT' : '';
199     $where  .= qq| AND $not COALESCE(fu.done, FALSE)|;
200   }
201
202   if ($params{not_id}) {
203     $where .= qq| AND (fu.id <> ?)|;
204     push @values, conv_i($params{not_id});
205   }
206
207   foreach my $item (qw(subject body)) {
208     next unless ($params{$item});
209     $where .= qq| AND (n.${item} ILIKE ?)|;
210     push @values, '%' . $params{$item} . '%';
211   }
212
213   if ($params{reference}) {
214     $where .= qq| AND EXISTS (SELECT ful.follow_up_id
215                               FROM follow_up_links ful
216                               WHERE (ful.follow_up_id = fu.id)
217                                 AND (ful.trans_info ILIKE ?)
218                               LIMIT 1)|;
219     push @values, '%' . $params{reference} . '%';
220   }
221
222   if ($params{follow_up_date_from}) {
223     $where .= qq| AND (fu.follow_up_date >= ?)|;
224     push @values, conv_date($params{follow_up_date_from});
225   }
226   if ($params{follow_up_date_to}) {
227     $where .= qq| AND (fu.follow_up_date <= ?)|;
228     push @values, conv_date($params{follow_up_date_to});
229   }
230
231   if ($params{itime_from}) {
232     $where .= qq| AND (date_trunc('DAY', fu.itime) >= ?)|;
233     push @values, conv_date($params{itime_from});
234   }
235   if ($params{itime_to}) {
236     $where .= qq| AND (date_trunc('DAY', fu.itime) <= ?)|;
237     push @values, conv_date($params{itime_to});
238   }
239
240   if ($params{all_users}) {
241     $where_user = qq|OR (fu.created_by IN (SELECT DISTINCT what FROM follow_up_access WHERE who = ?))|;
242     push @values_user, $employee_id;
243   }
244
245   my $order_by = '';
246
247   if ($form->{sort} ne 'title') {
248     my %sort_columns = (
249       'follow_up_date' => [ qw(fu.follow_up_date fu.id) ],
250       'created_on'     => [ qw(created_on fu.id) ],
251       'subject'        => [ qw(lower(n.subject)) ],
252       );
253
254     my $sortdir = !defined $form->{sortdir} ? 'ASC' : $form->{sortdir} ? 'ASC' : 'DESC';
255     my $sortkey = $sort_columns{$form->{sort}} ? $form->{sort} : 'follow_up_date';
256     $order_by   = 'ORDER BY ' . join(', ', map { "$_ $sortdir" } @{ $sort_columns{$sortkey} });
257   }
258
259   $query  = qq|SELECT fu.*, n.subject, n.body, n.created_by,
260                  fu.follow_up_date <= current_date AS due,
261                  fu.itime::DATE                    AS created_on,
262                  COALESCE(eby.name,  eby.login)    AS created_by_name,
263                  COALESCE(efor.name, efor.login)   AS created_for_user_name
264                FROM follow_ups fu
265                LEFT JOIN notes    n    ON (fu.note_id          = n.id)
266                LEFT JOIN employee eby  ON (n.created_by        = eby.id)
267                LEFT JOIN employee efor ON (fu.created_for_user = efor.id)
268                WHERE ((fu.created_by = ?) OR (fu.created_for_user = ?)
269                       $where_user)
270                  $where
271                $order_by|;
272
273   my $follow_ups = selectall_hashref_query($form, $dbh, $query, $employee_id, $employee_id, @values_user, @values);
274
275   if (!scalar @{ $follow_ups }) {
276     $main::lxdebug->leave_sub();
277     return $follow_ups;
278   }
279
280   foreach my $fu (@{ $follow_ups }) {
281     $fu->{LINKS} = $self->retrieve_links(%{ $fu });
282   }
283
284   if ($form->{sort} eq 'title') {
285     my $dir_factor = !defined $form->{sortdir} ? 1 : $form->{sortdir} ? 1 : -1;
286     $follow_ups    = [ map  { $_->[1] }
287                        sort { ($a->[0] cmp $b->[0]) * $dir_factor }
288                        map  { my $fu = $follow_ups->[$_]; [ @{ $fu->{LINKS} } ? lc($fu->{LINKS}->[0]->{title}) : '', $fu ] }
289                        (0 .. scalar(@{ $follow_ups }) - 1) ];
290   }
291
292   $main::lxdebug->leave_sub();
293
294   return $follow_ups;
295 }
296
297 sub link_details {
298   $main::lxdebug->enter_sub();
299
300   my $self     = shift;
301   my %params   = @_;
302
303   Common::check_params(\%params, qw(trans_id trans_type));
304
305   my $myconfig = \%main::myconfig;
306   my $form     = $main::form;
307   my $locale   = $main::locale;
308
309   my $q_id     = $form->quote($params{trans_id});
310   my $link;
311
312   if ($params{trans_type} eq 'customer') {
313     $link = {
314       'url'   => 'ct.pl?action=edit&db=customer&id=' . $form->quote($params{trans_id}) . '&edit_note_id=' . $form->quote($params{note_id}),
315       'title' => $locale->text('Customer') . " '$params{trans_info}'",
316     };
317
318   } elsif ($params{trans_type} eq 'vendor') {
319     $link = {
320       'url'   => 'ct.pl?action=edit&type=sales_quotation&id=' . $params{trans_id} . '&edit_note_id=' . $form->quote($params{note_id}),
321       'title' => $locale->text('Vendor') . " '$params{trans_info}'",
322     };
323
324   } elsif ($params{trans_type} eq 'sales_quotation') {
325     $link = {
326       'url'   => 'oe.pl?action=edit&type=sales_quotation&id=' . $params{trans_id},
327       'title' => $locale->text('Sales quotation') . " $params{trans_info}",
328     };
329
330   } elsif ($params{trans_type} eq 'sales_order') {
331     $link = {
332       'url'   => 'oe.pl?action=edit&type=sales_order&id=' . $params{trans_id},
333       'title' => $locale->text('Sales Order') . " $params{trans_info}",
334     };
335
336   } elsif ($params{trans_type} eq 'sales_invoice') {
337     $link = {
338       'url'   => 'is.pl?action=edit&type=invoice&id=' . $params{trans_id},
339       'title' => $locale->text('Sales Invoice') . " $params{trans_info}",
340     };
341
342   } elsif ($params{trans_type} eq 'credit_note') {
343     $link = {
344       'url'   => 'is.pl?action=edit&type=credit_note&id=' . $params{trans_id},
345       'title' => $locale->text('Credit Note') . " $params{trans_info}",
346     };
347
348   } elsif ($params{trans_type} eq 'dunning') {
349     $link = {
350       'url'   => 'dn.pl?action=print_dunning&format=pdf&media=screen&dunning_id=' . $params{trans_id},
351       'title' => $locale->text('Dunning') . " $params{trans_info}",
352     };
353
354   } elsif ($params{trans_type} eq 'request_quotation') {
355     $link = {
356       'url'   => 'oe.pl?action=edit&type=request_quotation&id=' . $params{trans_id},
357       'title' => $locale->text('Request quotation') . " $params{trans_info}",
358     };
359
360   } elsif ($params{trans_type} eq 'purchase_order') {
361     $link = {
362       'url'   => 'oe.pl?action=edit&type=purchase_order&id=' . $params{trans_id},
363       'title' => $locale->text('Purchase Order') . " $params{trans_info}",
364     };
365
366   } elsif ($params{trans_type} eq 'vendor_invoice') {
367     $link = {
368       'url'   => 'ir.pl?action=edit&type=invoice&id=' . $params{trans_id},
369       'title' => $locale->text('Vendor Invoice') . " $params{trans_info}",
370     };
371
372   } elsif ($params{trans_type} eq 'ar_transaction') {
373     $link = {
374       'url'   => 'ar.pl?action=editid=' . $params{trans_id},
375       'title' => $locale->text('AR Transaction') . " $params{trans_info}",
376     };
377
378   } elsif ($params{trans_type} eq 'ap_transaction') {
379     $link = {
380       'url'   => 'ap.pl?action=editid=' . $params{trans_id},
381       'title' => $locale->text('AP Transaction') . " $params{trans_info}",
382     };
383
384   } elsif ($params{trans_type} eq 'gl_transaction') {
385     $link = {
386       'url'   => 'gl.pl?action=edit&id=' . $params{trans_id},
387       'title' => $locale->text('GL Transaction') . " $params{trans_info}",
388     };
389
390   }
391
392   $main::lxdebug->leave_sub();
393
394   return $link || { };
395 }
396
397 sub save_access_rights {
398   $main::lxdebug->enter_sub();
399
400   my $self     = shift;
401   my %params   = @_;
402
403   Common::check_params(\%params, 'access');
404
405   my $myconfig = \%main::myconfig;
406   my $form     = $main::form;
407
408   my $dbh      = $form->get_standard_dbh($myconfig);
409
410   my ($id)     = selectrow_query($form, $dbh, qq|SELECT id FROM employee WHERE login = ?|, $form->{login});
411
412   my $query    = qq|INSERT INTO follow_up_access (who, what) VALUES (?, ?)|;
413   my $sth      = prepare_query($form, $dbh, $query);
414
415   do_query($form, $dbh, qq|DELETE FROM follow_up_access WHERE what = ?|, $id);
416
417   while (my ($who, $access_allowed) = each %{ $params{access} }) {
418     next unless ($access_allowed);
419
420     do_statement($form, $sth, $query, conv_i($who), $id);
421   }
422
423   $sth->finish();
424
425   $dbh->commit();
426
427   $main::lxdebug->leave_sub();
428 }
429
430 sub retrieve_access_rights {
431   $main::lxdebug->enter_sub();
432
433   my $self     = shift;
434   my %params   = @_;
435
436   my $myconfig = \%main::myconfig;
437   my $form     = $main::form;
438
439   my $dbh      = $form->get_standard_dbh($myconfig);
440
441   my $sth      = prepare_execute_query($form, $dbh, qq|SELECT who FROM follow_up_access WHERE what = (SELECT id FROM employee WHERE login = ?)|, $form->{login});
442   my $access   = {};
443
444   while (my $ref = $sth->fetchrow_hashref()) {
445     $access->{$ref->{who}} = 1;
446   }
447
448   $sth->finish();
449
450   $main::lxdebug->leave_sub();
451
452   return $access;
453 }
454
455 1;