Lines 17-119
Link Here
|
17 |
# along with Koha; if not, see <http://www.gnu.org/licenses>. |
17 |
# along with Koha; if not, see <http://www.gnu.org/licenses>. |
18 |
|
18 |
|
19 |
use Modern::Perl; |
19 |
use Modern::Perl; |
|
|
20 |
use CGI qw ( -utf8 ); |
20 |
use MARC::File::XML; |
21 |
use MARC::File::XML; |
21 |
use List::MoreUtils qw(uniq); |
22 |
use List::MoreUtils qw(uniq); |
22 |
use Getopt::Long; |
|
|
23 |
use CGI qw ( -utf8 ); |
24 |
use C4::Auth; |
23 |
use C4::Auth; |
25 |
use C4::AuthoritiesMarc; # GetAuthority |
|
|
26 |
use C4::Biblio; # GetMarcBiblio |
27 |
use C4::Branch; # GetBranches |
24 |
use C4::Branch; # GetBranches |
28 |
use C4::Csv; |
25 |
use C4::Csv; |
29 |
use C4::Koha; # GetItemTypes |
26 |
use C4::Koha; # GetItemTypes |
30 |
use C4::Output; |
27 |
use C4::Output; |
31 |
use C4::Record; |
|
|
32 |
|
33 |
my $query = new CGI; |
34 |
|
35 |
my $clean; |
36 |
my $dont_export_items; |
37 |
my $deleted_barcodes; |
38 |
my $timestamp; |
39 |
my $record_type; |
40 |
my $id_list_file; |
41 |
my $help; |
42 |
my $op = $query->param("op") || ''; |
43 |
my $filename = $query->param("filename") || 'koha.mrc'; |
44 |
my $dbh = C4::Context->dbh; |
45 |
my $marcflavour = C4::Context->preference("marcflavour"); |
46 |
my $output_format = $query->param("format") || $query->param("output_format") || 'iso2709'; |
47 |
|
48 |
# Checks if the script is called from commandline |
49 |
my $commandline = not defined $ENV{GATEWAY_INTERFACE}; |
50 |
|
51 |
|
52 |
# @biblionumbers is only use for csv export from circulation.pl |
53 |
my @biblionumbers = uniq $query->param("biblionumbers"); |
54 |
|
55 |
if ( $commandline ) { |
56 |
|
57 |
# Getting parameters |
58 |
$op = 'export'; |
59 |
GetOptions( |
60 |
'format=s' => \$output_format, |
61 |
'date=s' => \$timestamp, |
62 |
'dont_export_items' => \$dont_export_items, |
63 |
'deleted_barcodes' => \$deleted_barcodes, |
64 |
'clean' => \$clean, |
65 |
'filename=s' => \$filename, |
66 |
'record-type=s' => \$record_type, |
67 |
'id_list_file=s' => \$id_list_file, |
68 |
'help|?' => \$help |
69 |
); |
70 |
|
71 |
if ($help) { |
72 |
print <<_USAGE_; |
73 |
export.pl [--format=format] [--date=date] [--record-type=TYPE] [--dont_export_items] [--deleted_barcodes] [--clean] [--id_list_file=PATH] --filename=outputfile |
74 |
|
28 |
|
|
|
29 |
use Koha::Biblioitems; |
30 |
use Koha::Database; |
31 |
use Koha::DateUtils qw( dt_from_string output_pref ); |
32 |
use Koha::Exporter::Record; |
75 |
|
33 |
|
76 |
--format=FORMAT FORMAT is either 'xml' or 'marc' (default) |
34 |
my $query = new CGI; |
77 |
|
|
|
78 |
--date=DATE DATE should be entered as the 'dateformat' syspref is |
79 |
set (dd/mm/yyyy for metric, yyyy-mm-dd for iso, |
80 |
mm/dd/yyyy for us) records exported are the ones that |
81 |
have been modified since DATE |
82 |
|
83 |
--record-type=TYPE TYPE is 'bibs' or 'auths' |
84 |
|
85 |
--deleted_barcodes If used, a list of barcodes of items deleted since DATE |
86 |
is produced (or from all deleted items if no date is |
87 |
specified). Used only if TYPE is 'bibs' |
88 |
|
89 |
--clean removes NSE/NSB |
90 |
|
91 |
--id_list_file=PATH PATH is a path to a file containing a list of |
92 |
IDs (biblionumber or authid) with one ID per line. |
93 |
This list works as a filter; it is compatible with |
94 |
other parameters for selecting records |
95 |
_USAGE_ |
96 |
exit; |
97 |
} |
98 |
|
99 |
# Default parameters values : |
100 |
$timestamp ||= ''; |
101 |
$dont_export_items ||= 0; |
102 |
$deleted_barcodes ||= 0; |
103 |
$clean ||= 0; |
104 |
$record_type ||= "bibs"; |
105 |
$id_list_file ||= 0; |
106 |
|
107 |
# Redirect stdout |
108 |
open STDOUT, '>', $filename if $filename; |
109 |
|
110 |
} |
111 |
else { |
112 |
|
113 |
$op = $query->param("op") || ''; |
114 |
$filename = $query->param("filename") || 'koha.mrc'; |
115 |
$filename =~ s/(\r|\n)//; |
116 |
|
35 |
|
|
|
36 |
my $dont_export_items = $query->param("dont_export_item") || 0; |
37 |
my $record_type = $query->param("record_type"); |
38 |
my $op = $query->param("op") || ''; |
39 |
my $output_format = $query->param("format") || $query->param("output_format") || 'iso2709'; |
40 |
my $backupdir = C4::Context->config('backupdir'); |
41 |
my $filename = $query->param("filename") || 'koha.mrc'; |
42 |
$filename =~ s/(\r|\n)//; |
43 |
|
44 |
my $dbh = C4::Context->dbh; |
45 |
|
46 |
my @record_ids; |
47 |
# biblionumbers is sent from circulation.pl only |
48 |
if ( $query->param("biblionumbers") ) { |
49 |
$record_type = 'bibs'; |
50 |
@record_ids = $query->param("biblionumbers"); |
117 |
} |
51 |
} |
118 |
|
52 |
|
119 |
# Default value for output_format is 'iso2709' |
53 |
# Default value for output_format is 'iso2709' |
Lines 126-480
my ( $template, $loggedinuser, $cookie, $flags ) = get_template_and_user(
Link Here
|
126 |
template_name => "tools/export.tt", |
60 |
template_name => "tools/export.tt", |
127 |
query => $query, |
61 |
query => $query, |
128 |
type => "intranet", |
62 |
type => "intranet", |
129 |
authnotrequired => $commandline, |
63 |
authnotrequired => 0, |
130 |
flagsrequired => { tools => 'export_catalog' }, |
64 |
flagsrequired => { tools => 'export_catalog' }, |
131 |
debug => 1, |
65 |
debug => 1, |
132 |
} |
66 |
} |
133 |
); |
67 |
); |
134 |
|
68 |
|
135 |
my $limit_ind_branch = |
|
|
136 |
( C4::Context->preference('IndependentBranches') |
137 |
&& C4::Context->userenv |
138 |
&& !C4::Context->IsSuperLibrarian() |
139 |
&& C4::Context->userenv->{branch} ) ? 1 : 0; |
140 |
|
141 |
my @branch = $query->param("branch"); |
69 |
my @branch = $query->param("branch"); |
142 |
if ( C4::Context->preference("IndependentBranches") |
70 |
my $only_my_branch; |
143 |
&& C4::Context->userenv |
71 |
# Limit to local branch if IndependentBranches and not superlibrarian |
144 |
&& !C4::Context->IsSuperLibrarian() ) |
72 |
if ( |
145 |
{ |
73 |
( |
|
|
74 |
C4::Context->preference('IndependentBranches') |
75 |
&& C4::Context->userenv |
76 |
&& !C4::Context->IsSuperLibrarian() |
77 |
&& C4::Context->userenv->{branch} |
78 |
) |
79 |
# Limit result to local branch strip_nonlocal_items |
80 |
or $query->param('strip_nonlocal_items') |
81 |
) { |
82 |
$only_my_branch = 1; |
146 |
@branch = ( C4::Context->userenv->{'branch'} ); |
83 |
@branch = ( C4::Context->userenv->{'branch'} ); |
147 |
} |
84 |
} |
148 |
# if stripping nonlocal items, use loggedinuser's branch |
|
|
149 |
my $localbranch = C4::Context->userenv ? C4::Context->userenv->{'branch'} : undef; |
150 |
|
85 |
|
151 |
my %branchmap = map { $_ => 1 } @branch; # for quick lookups |
86 |
my %branchmap = map { $_ => 1 } @branch; # for quick lookups |
152 |
|
87 |
|
153 |
my $backupdir = C4::Context->config('backupdir'); |
|
|
154 |
|
155 |
if ( $op eq "export" ) { |
88 |
if ( $op eq "export" ) { |
156 |
if ( |
|
|
157 |
$output_format eq "iso2709" |
158 |
or $output_format eq "xml" |
159 |
or ( |
160 |
$output_format eq 'csv' |
161 |
and not @biblionumbers |
162 |
) |
163 |
) { |
164 |
my $charset = 'utf-8'; |
165 |
my $mimetype = 'application/octet-stream'; |
166 |
|
167 |
binmode STDOUT, ':encoding(UTF-8)' |
168 |
if $filename =~ m/\.gz$/ |
169 |
or $filename =~ m/\.bz2$/ |
170 |
or $output_format ne 'csv'; |
171 |
|
172 |
if ( $filename =~ m/\.gz$/ ) { |
173 |
$mimetype = 'application/x-gzip'; |
174 |
$charset = ''; |
175 |
binmode STDOUT; |
176 |
} |
177 |
elsif ( $filename =~ m/\.bz2$/ ) { |
178 |
$mimetype = 'application/x-bzip2'; |
179 |
binmode STDOUT; |
180 |
$charset = ''; |
181 |
} |
182 |
print $query->header( |
183 |
-type => $mimetype, |
184 |
-charset => $charset, |
185 |
-attachment => $filename, |
186 |
) unless ($commandline); |
187 |
|
188 |
$record_type = $query->param("record_type") unless ($commandline); |
189 |
my $export_remove_fields = $query->param("export_remove_fields"); |
190 |
my @biblionumbers = $query->param("biblionumbers"); |
191 |
my @itemnumbers = $query->param("itemnumbers"); |
192 |
my @sql_params; |
193 |
my $sql_query; |
194 |
my @recordids; |
195 |
|
196 |
my $StartingBiblionumber = $query->param("StartingBiblionumber"); |
197 |
my $EndingBiblionumber = $query->param("EndingBiblionumber"); |
198 |
my $itemtype = $query->param("itemtype"); |
199 |
my $start_callnumber = $query->param("start_callnumber"); |
200 |
my $end_callnumber = $query->param("end_callnumber"); |
201 |
$timestamp = ($timestamp) ? C4::Dates->new($timestamp) : '' |
202 |
if ($commandline); |
203 |
my $start_accession = |
204 |
( $query->param("start_accession") ) |
205 |
? C4::Dates->new( $query->param("start_accession") ) |
206 |
: ''; |
207 |
my $end_accession = |
208 |
( $query->param("end_accession") ) |
209 |
? C4::Dates->new( $query->param("end_accession") ) |
210 |
: ''; |
211 |
$dont_export_items = $query->param("dont_export_item") |
212 |
unless ($commandline); |
213 |
|
214 |
my $strip_nonlocal_items = $query->param("strip_nonlocal_items"); |
215 |
|
216 |
my $biblioitemstable = |
217 |
( $commandline and $deleted_barcodes ) |
218 |
? 'deletedbiblioitems' |
219 |
: 'biblioitems'; |
220 |
my $itemstable = |
221 |
( $commandline and $deleted_barcodes ) |
222 |
? 'deleteditems' |
223 |
: 'items'; |
224 |
|
225 |
my $starting_authid = $query->param('starting_authid'); |
226 |
my $ending_authid = $query->param('ending_authid'); |
227 |
my $authtype = $query->param('authtype'); |
228 |
my $filefh; |
229 |
if ($commandline) { |
230 |
open $filefh,"<", $id_list_file or die "cannot open $id_list_file: $!" if $id_list_file; |
231 |
} else { |
232 |
$filefh = $query->upload("id_list_file"); |
233 |
} |
234 |
my %id_filter; |
235 |
if ($filefh) { |
236 |
while (my $number=<$filefh>){ |
237 |
$number=~s/[\r\n]*$//; |
238 |
$id_filter{$number}=1 if $number=~/^\d+$/; |
239 |
} |
240 |
} |
241 |
|
242 |
if ( $record_type eq 'bibs' and not @biblionumbers ) { |
243 |
if ($timestamp) { |
244 |
|
245 |
# Specific query when timestamp is used |
246 |
# Actually it's used only with CLI and so all previous filters |
247 |
# are not used. |
248 |
# If one day timestamp is used via the web interface, this part will |
249 |
# certainly have to be rewrited |
250 |
my ( $query, $params ) = construct_query( |
251 |
{ |
252 |
recordtype => $record_type, |
253 |
timestamp => $timestamp, |
254 |
biblioitemstable => $biblioitemstable, |
255 |
} |
256 |
); |
257 |
$sql_query = $query; |
258 |
@sql_params = @$params; |
259 |
|
89 |
|
|
|
90 |
my $export_remove_fields = $query->param("export_remove_fields") || q||; |
91 |
my @biblionumbers = $query->param("biblionumbers"); |
92 |
my @itemnumbers = $query->param("itemnumbers"); |
93 |
my @sql_params; |
94 |
my $sql_query; |
95 |
|
96 |
if ( $record_type eq 'bibs' or $record_type eq 'auths' ) { |
97 |
# No need to retrieve the record_ids if we already get them |
98 |
unless ( @record_ids ) { |
99 |
if ( $record_type eq 'bibs' ) { |
100 |
my $starting_biblionumber = $query->param("StartingBiblionumber"); |
101 |
my $ending_biblionumber = $query->param("EndingBiblionumber"); |
102 |
my $itemtype = $query->param("itemtype"); |
103 |
my $start_callnumber = $query->param("start_callnumber"); |
104 |
my $end_callnumber = $query->param("end_callnumber"); |
105 |
my $start_accession = |
106 |
( $query->param("start_accession") ) |
107 |
? dt_from_string( $query->param("start_accession") ) |
108 |
: ''; |
109 |
my $end_accession = |
110 |
( $query->param("end_accession") ) |
111 |
? dt_from_string( $query->param("end_accession") ) |
112 |
: ''; |
113 |
|
114 |
|
115 |
my $conditions = { |
116 |
( $starting_biblionumber or $ending_biblionumber ) |
117 |
? ( |
118 |
"me.biblionumber" => { |
119 |
( $starting_biblionumber ? ( '>=' => $starting_biblionumber ) : () ), |
120 |
( $ending_biblionumber ? ( '<=' => $ending_biblionumber ) : () ), |
121 |
} |
122 |
) |
123 |
: (), |
124 |
( $start_callnumber or $end_callnumber ) |
125 |
? ( |
126 |
callnumber => { |
127 |
( $start_callnumber ? ( '>=' => $start_callnumber ) : () ), |
128 |
( $end_callnumber ? ( '<=' => $end_callnumber ) : () ), |
129 |
} |
130 |
) |
131 |
: (), |
132 |
( $start_accession or $end_accession ) |
133 |
? ( |
134 |
dateaccessioned => { |
135 |
( $start_accession ? ( '>=' => $start_accession ) : () ), |
136 |
( $end_accession ? ( '<=' => $end_accession ) : () ), |
137 |
} |
138 |
) |
139 |
: (), |
140 |
( @branch ? ( 'items.homebranch' => { in => \@branch } ) : () ), |
141 |
( $itemtype |
142 |
? |
143 |
C4::Context->preference('item-level_itypes') |
144 |
? ( 'items.itype' => $itemtype ) |
145 |
: ( 'biblioitems.itemtype' => $itemtype ) |
146 |
: () |
147 |
), |
148 |
|
149 |
}; |
150 |
my $biblioitems = Koha::Biblioitems->search( $conditions, { join => 'items' } ); |
151 |
while ( my $biblioitem = $biblioitems->next ) { |
152 |
push @record_ids, $biblioitem->biblionumber; |
153 |
} |
260 |
} |
154 |
} |
261 |
else { |
155 |
elsif ( $record_type eq 'auths' ) { |
262 |
my ( $query, $params ) = construct_query( |
156 |
my $starting_authid = $query->param('starting_authid'); |
263 |
{ |
157 |
my $ending_authid = $query->param('ending_authid'); |
264 |
recordtype => $record_type, |
158 |
my $authtype = $query->param('authtype'); |
265 |
biblioitemstable => $biblioitemstable, |
159 |
|
266 |
itemstable => $itemstable, |
160 |
my $conditions = { |
267 |
StartingBiblionumber => $StartingBiblionumber, |
161 |
( $starting_authid or $ending_authid ) |
268 |
EndingBiblionumber => $EndingBiblionumber, |
162 |
? ( |
269 |
branch => \@branch, |
163 |
authid => { |
270 |
start_callnumber => $start_callnumber, |
164 |
( $starting_authid ? ( '>=' => $starting_authid ) : () ), |
271 |
end_callnumber => $end_callnumber, |
165 |
( $ending_authid ? ( '<=' => $ending_authid ) : () ), |
272 |
start_accession => $start_accession, |
166 |
} |
273 |
end_accession => $end_accession, |
167 |
) |
274 |
itemtype => $itemtype, |
168 |
: (), |
275 |
} |
169 |
( $authtype ? ( authtypecode => $authtype ) : () ), |
276 |
); |
170 |
}; |
277 |
$sql_query = $query; |
171 |
# Koha::Authority is not a Koha::Object... |
278 |
@sql_params = @$params; |
172 |
my $authorities = Koha::Database->new->schema->resultset('AuthHeader')->search( $conditions ); |
|
|
173 |
@record_ids = map { $_->authid } $authorities->all; |
279 |
} |
174 |
} |
280 |
} |
175 |
} |
281 |
elsif ( $record_type eq 'auths' ) { |
|
|
282 |
my ( $query, $params ) = construct_query( |
283 |
{ |
284 |
recordtype => $record_type, |
285 |
starting_authid => $starting_authid, |
286 |
ending_authid => $ending_authid, |
287 |
authtype => $authtype, |
288 |
} |
289 |
); |
290 |
$sql_query = $query; |
291 |
@sql_params = @$params; |
292 |
|
176 |
|
|
|
177 |
@record_ids = uniq @record_ids; |
178 |
if ( @record_ids and my $filefh = $query->upload("id_list_file") ) { |
179 |
my @filter_record_ids = <$filefh>; |
180 |
@filter_record_ids = map { my $id = $_; $id =~ s/[\r\n]*$// } @filter_record_ids; |
181 |
# intersection |
182 |
my %record_ids = map { $_ => 1 } @record_ids; |
183 |
@record_ids = grep $record_ids{$_}, @filter_record_ids; |
293 |
} |
184 |
} |
294 |
elsif ( $record_type eq 'db' ) { |
185 |
|
295 |
my $successful_export; |
186 |
print CGI->new->header( |
296 |
if ( $flags->{superlibrarian} |
187 |
-type => 'application/octet-stream', |
297 |
&& C4::Context->config('backup_db_via_tools') ) |
188 |
-charset => 'utf-8', |
298 |
{ |
189 |
-attachment => $filename, |
299 |
$successful_export = download_backup( |
190 |
); |
300 |
{ |
191 |
|
301 |
directory => "$backupdir", |
192 |
Koha::Exporter::Record::export( |
302 |
extension => 'sql', |
193 |
{ record_type => $record_type, |
303 |
filename => "$filename" |
194 |
record_ids => \@record_ids, |
304 |
} |
195 |
format => $output_format, |
305 |
); |
196 |
filename => $filename, |
|
|
197 |
itemnumbers => \@itemnumbers, |
198 |
dont_export_fields => $export_remove_fields, |
199 |
csv_profile_id => ( $query->param('csv_profile_id') || GetCsvProfileId( C4::Context->preference('ExportWithCsvProfile') ) || undef ), |
200 |
export_items => (not $dont_export_items), |
306 |
} |
201 |
} |
307 |
unless ($successful_export) { |
202 |
); |
308 |
my $remotehost = $query->remote_host(); |
203 |
} |
309 |
$remotehost =~ s/(\n|\r)//; |
204 |
elsif ( $record_type eq 'db' or $record_type eq 'conf' ) { |
310 |
warn |
205 |
my $successful_export; |
311 |
"A suspicious attempt was made to download the db at '$filename' by someone at " |
206 |
|
312 |
. $remotehost . "\n"; |
207 |
if ( $flags->{superlibrarian} |
|
|
208 |
and ( |
209 |
$record_type eq 'db' and C4::Context->config('backup_db_via_tools') |
210 |
or |
211 |
$record_type eq 'conf' and C4::Context->config('backup_conf_via_tools') |
212 |
) |
213 |
) { |
214 |
binmode STDOUT, ':encoding(UTF-8)'; |
215 |
|
216 |
my $charset = 'utf-8'; |
217 |
my $mimetype = 'application/octet-stream'; |
218 |
if ( $filename =~ m/\.gz$/ ) { |
219 |
$mimetype = 'application/x-gzip'; |
220 |
$charset = ''; |
221 |
binmode STDOUT; |
313 |
} |
222 |
} |
314 |
exit; |
223 |
elsif ( $filename =~ m/\.bz2$/ ) { |
315 |
} |
224 |
$mimetype = 'application/x-bzip2'; |
316 |
elsif ( $record_type eq 'conf' ) { |
225 |
binmode STDOUT; |
317 |
my $successful_export; |
226 |
$charset = ''; |
318 |
if ( $flags->{superlibrarian} |
|
|
319 |
&& C4::Context->config('backup_conf_via_tools') ) |
320 |
{ |
321 |
$successful_export = download_backup( |
322 |
{ |
323 |
directory => "$backupdir", |
324 |
extension => 'tar', |
325 |
filename => "$filename" |
326 |
} |
327 |
); |
328 |
} |
227 |
} |
|
|
228 |
print $query->header( |
229 |
-type => $mimetype, |
230 |
-charset => $charset, |
231 |
-attachment => $filename, |
232 |
); |
233 |
|
234 |
my $extension = $record_type eq 'db' ? 'sql' : 'tar'; |
235 |
|
236 |
$successful_export = download_backup( |
237 |
{ |
238 |
directory => $backupdir, |
239 |
extension => $extension, |
240 |
filename => $filename, |
241 |
} |
242 |
); |
329 |
unless ($successful_export) { |
243 |
unless ($successful_export) { |
330 |
my $remotehost = $query->remote_host(); |
244 |
my $remotehost = $query->remote_host(); |
331 |
$remotehost =~ s/(\n|\r)//; |
245 |
$remotehost =~ s/(\n|\r)//; |
332 |
warn |
246 |
warn |
333 |
"A suspicious attempt was made to download the configuration at '$filename' by someone at " |
247 |
"A suspicious attempt was made to download the " . ( $record_type eq 'db' ? 'db' : 'configuration' ) . "at '$filename' by someone at " |
334 |
. $remotehost . "\n"; |
248 |
. $remotehost . "\n"; |
335 |
} |
249 |
} |
336 |
exit; |
|
|
337 |
} |
338 |
elsif (@biblionumbers) { |
339 |
push @recordids, (@biblionumbers); |
340 |
} |
341 |
else { |
342 |
|
343 |
# Someone is trying to mess us up |
344 |
exit; |
345 |
} |
346 |
unless (@biblionumbers) { |
347 |
my $sth = $dbh->prepare($sql_query); |
348 |
$sth->execute(@sql_params); |
349 |
push @recordids, map { |
350 |
map { $$_[0] } $_ |
351 |
} @{ $sth->fetchall_arrayref }; |
352 |
@recordids = grep { exists($id_filter{$_}) } @recordids if scalar(%id_filter); |
353 |
} |
250 |
} |
354 |
|
|
|
355 |
my $xml_header_written = 0; |
356 |
for my $recordid ( uniq @recordids ) { |
357 |
if ($deleted_barcodes) { |
358 |
my $q = " |
359 |
SELECT DISTINCT barcode |
360 |
FROM deleteditems |
361 |
WHERE deleteditems.biblionumber = ? |
362 |
"; |
363 |
my $sth = $dbh->prepare($q); |
364 |
$sth->execute($recordid); |
365 |
while ( my $row = $sth->fetchrow_array ) { |
366 |
print "$row\n"; |
367 |
} |
368 |
} |
369 |
else { |
370 |
my $record; |
371 |
if ( $record_type eq 'bibs' ) { |
372 |
$record = eval { GetMarcBiblio($recordid); }; |
373 |
|
374 |
next if $@; |
375 |
next if not defined $record; |
376 |
C4::Biblio::EmbedItemsInMarcBiblio( $record, $recordid, |
377 |
\@itemnumbers ) |
378 |
unless $dont_export_items; |
379 |
if ( $strip_nonlocal_items |
380 |
|| $limit_ind_branch |
381 |
|| $dont_export_items ) |
382 |
{ |
383 |
my ( $homebranchfield, $homebranchsubfield ) = |
384 |
GetMarcFromKohaField( 'items.homebranch', '' ); |
385 |
for my $itemfield ( $record->field($homebranchfield) ) { |
386 |
$record->delete_field($itemfield) |
387 |
if ( $dont_export_items |
388 |
|| $localbranch ne $itemfield->subfield( |
389 |
$homebranchsubfield) ); |
390 |
} |
391 |
} |
392 |
} |
393 |
elsif ( $record_type eq 'auths' ) { |
394 |
$record = C4::AuthoritiesMarc::GetAuthority($recordid); |
395 |
next if not defined $record; |
396 |
} |
397 |
|
398 |
if ($export_remove_fields) { |
399 |
for my $f ( split / /, $export_remove_fields ) { |
400 |
if ( $f =~ m/^(\d{3})(.)?$/ ) { |
401 |
my ( $field, $subfield ) = ( $1, $2 ); |
402 |
|
403 |
# skip if this record doesn't have this field |
404 |
if ( defined $record->field($field) ) { |
405 |
if ( defined $subfield ) { |
406 |
my @tags = $record->field($field); |
407 |
foreach my $t (@tags) { |
408 |
$t->delete_subfields($subfield); |
409 |
} |
410 |
} |
411 |
else { |
412 |
$record->delete_fields($record->field($field)); |
413 |
} |
414 |
} |
415 |
} |
416 |
} |
417 |
} |
418 |
RemoveAllNsb($record) if ($clean); |
419 |
if ( $output_format eq "xml" ) { |
420 |
unless ($xml_header_written) { |
421 |
MARC::File::XML->default_record_format( |
422 |
( |
423 |
$marcflavour eq 'UNIMARC' |
424 |
&& $record_type eq 'auths' |
425 |
) ? 'UNIMARCAUTH' : $marcflavour |
426 |
); |
427 |
print MARC::File::XML::header(); |
428 |
print "\n"; |
429 |
$xml_header_written = 1; |
430 |
} |
431 |
print MARC::File::XML::record($record); |
432 |
print "\n"; |
433 |
} |
434 |
elsif ( $output_format eq 'iso2709' ) { |
435 |
my $errorcount_on_decode = eval { scalar(MARC::File::USMARC->decode( $record->as_usmarc )->warnings()) }; |
436 |
if ($errorcount_on_decode or $@){ |
437 |
warn $@ if $@; |
438 |
warn "record (number $recordid) is invalid and therefore not exported because its reopening generates warnings above"; |
439 |
next; |
440 |
} |
441 |
print $record->as_usmarc(); |
442 |
} |
443 |
} |
444 |
} |
445 |
if ($xml_header_written) { |
446 |
print MARC::File::XML::footer(); |
447 |
print "\n"; |
448 |
} |
449 |
if ( $output_format eq 'csv' ) { |
450 |
my $csv_profile_id = $query->param('csv_profile') |
451 |
|| GetCsvProfileId( C4::Context->preference('ExportWithCsvProfile') ); |
452 |
my $output = |
453 |
marc2csv( \@recordids, |
454 |
$csv_profile_id ); |
455 |
|
456 |
print $output; |
457 |
} |
458 |
|
459 |
exit; |
460 |
} |
461 |
elsif ( $output_format eq "csv" ) { |
462 |
my @biblionumbers = uniq $query->param("biblionumbers"); |
463 |
my @itemnumbers = $query->param("itemnumbers"); |
464 |
my $csv_profile_id = $query->param('csv_profile') || GetCsvProfileId( C4::Context->preference('ExportWithCsvProfile') ); |
465 |
my $output = |
466 |
marc2csv( \@biblionumbers, |
467 |
$csv_profile_id, |
468 |
\@itemnumbers, ); |
469 |
print $query->header( |
470 |
-type => 'application/octet-stream', |
471 |
-'Content-Transfer-Encoding' => 'binary', |
472 |
-attachment => "export.csv" |
473 |
); |
474 |
print $output; |
475 |
exit; |
476 |
} |
251 |
} |
477 |
} # if export |
252 |
|
|
|
253 |
exit; |
254 |
} |
478 |
|
255 |
|
479 |
else { |
256 |
else { |
480 |
|
257 |
|
Lines 487-493
else {
Link Here
|
487 |
); |
264 |
); |
488 |
push @itemtypesloop, \%row; |
265 |
push @itemtypesloop, \%row; |
489 |
} |
266 |
} |
490 |
my $branches = GetBranches($limit_ind_branch); |
267 |
my $branches = GetBranches($only_my_branch); |
491 |
my @branchloop; |
268 |
my @branchloop; |
492 |
for my $thisbranch ( |
269 |
for my $thisbranch ( |
493 |
sort { $branches->{$a}->{branchname} cmp $branches->{$b}->{branchname} } |
270 |
sort { $branches->{$a}->{branchname} cmp $branches->{$b}->{branchname} } |
Lines 544-671
else {
Link Here
|
544 |
output_html_with_http_headers $query, $cookie, $template->output; |
321 |
output_html_with_http_headers $query, $cookie, $template->output; |
545 |
} |
322 |
} |
546 |
|
323 |
|
547 |
sub construct_query { |
|
|
548 |
my ($params) = @_; |
549 |
|
550 |
my ( $sql_query, @sql_params ); |
551 |
|
552 |
if ( $params->{recordtype} eq "bibs" ) { |
553 |
if ( $params->{timestamp} ) { |
554 |
my $biblioitemstable = $params->{biblioitemstable}; |
555 |
$sql_query = " ( |
556 |
SELECT biblionumber |
557 |
FROM $biblioitemstable |
558 |
LEFT JOIN items USING(biblionumber) |
559 |
WHERE $biblioitemstable.timestamp >= ? |
560 |
OR items.timestamp >= ? |
561 |
) UNION ( |
562 |
SELECT biblionumber |
563 |
FROM $biblioitemstable |
564 |
LEFT JOIN deleteditems USING(biblionumber) |
565 |
WHERE $biblioitemstable.timestamp >= ? |
566 |
OR deleteditems.timestamp >= ? |
567 |
) "; |
568 |
my $ts = $timestamp->output('iso'); |
569 |
@sql_params = ( $ts, $ts, $ts, $ts ); |
570 |
} |
571 |
else { |
572 |
my $biblioitemstable = $params->{biblioitemstable}; |
573 |
my $itemstable = $params->{itemstable}; |
574 |
my $StartingBiblionumber = $params->{StartingBiblionumber}; |
575 |
my $EndingBiblionumber = $params->{EndingBiblionumber}; |
576 |
my @branch = @{ $params->{branch} }; |
577 |
my $start_callnumber = $params->{start_callnumber}; |
578 |
my $end_callnumber = $params->{end_callnumber}; |
579 |
my $start_accession = $params->{start_accession}; |
580 |
my $end_accession = $params->{end_accession}; |
581 |
my $itemtype = $params->{itemtype}; |
582 |
my $items_filter = |
583 |
@branch |
584 |
|| $start_callnumber |
585 |
|| $end_callnumber |
586 |
|| $start_accession |
587 |
|| $end_accession |
588 |
|| ( $itemtype && C4::Context->preference('item-level_itypes') ); |
589 |
$sql_query = $items_filter |
590 |
? "SELECT DISTINCT $biblioitemstable.biblionumber |
591 |
FROM $biblioitemstable JOIN $itemstable |
592 |
USING (biblionumber) WHERE 1" |
593 |
: "SELECT $biblioitemstable.biblionumber FROM $biblioitemstable WHERE biblionumber >0 "; |
594 |
|
595 |
if ($StartingBiblionumber) { |
596 |
$sql_query .= " AND $biblioitemstable.biblionumber >= ? "; |
597 |
push @sql_params, $StartingBiblionumber; |
598 |
} |
599 |
|
600 |
if ($EndingBiblionumber) { |
601 |
$sql_query .= " AND $biblioitemstable.biblionumber <= ? "; |
602 |
push @sql_params, $EndingBiblionumber; |
603 |
} |
604 |
|
605 |
if (@branch) { |
606 |
$sql_query .= " AND homebranch IN (".join(',',map({'?'} @branch)).")"; |
607 |
push @sql_params, @branch; |
608 |
} |
609 |
|
610 |
if ($start_callnumber) { |
611 |
$sql_query .= " AND itemcallnumber >= ? "; |
612 |
push @sql_params, $start_callnumber; |
613 |
} |
614 |
|
615 |
if ($end_callnumber) { |
616 |
$sql_query .= " AND itemcallnumber <= ? "; |
617 |
push @sql_params, $end_callnumber; |
618 |
} |
619 |
if ($start_accession) { |
620 |
$sql_query .= " AND dateaccessioned >= ? "; |
621 |
push @sql_params, $start_accession->output('iso'); |
622 |
} |
623 |
|
624 |
if ($end_accession) { |
625 |
$sql_query .= " AND dateaccessioned <= ? "; |
626 |
push @sql_params, $end_accession->output('iso'); |
627 |
} |
628 |
|
629 |
if ($itemtype) { |
630 |
$sql_query .= |
631 |
( C4::Context->preference('item-level_itypes') ) |
632 |
? " AND items.itype = ? " |
633 |
: " AND biblioitems.itemtype = ?"; |
634 |
push @sql_params, $itemtype; |
635 |
} |
636 |
} |
637 |
} |
638 |
elsif ( $params->{recordtype} eq "auths" ) { |
639 |
if ( $params->{timestamp} ) { |
640 |
|
641 |
#TODO |
642 |
} |
643 |
else { |
644 |
my $starting_authid = $params->{starting_authid}; |
645 |
my $ending_authid = $params->{ending_authid}; |
646 |
my $authtype = $params->{authtype}; |
647 |
$sql_query = |
648 |
"SELECT DISTINCT auth_header.authid FROM auth_header WHERE 1"; |
649 |
|
650 |
if ($starting_authid) { |
651 |
$sql_query .= " AND auth_header.authid >= ? "; |
652 |
push @sql_params, $starting_authid; |
653 |
} |
654 |
|
655 |
if ($ending_authid) { |
656 |
$sql_query .= " AND auth_header.authid <= ? "; |
657 |
push @sql_params, $ending_authid; |
658 |
} |
659 |
|
660 |
if ($authtype) { |
661 |
$sql_query .= " AND auth_header.authtypecode = ? "; |
662 |
push @sql_params, $authtype; |
663 |
} |
664 |
} |
665 |
} |
666 |
return ( $sql_query, \@sql_params ); |
667 |
} |
668 |
|
669 |
sub getbackupfilelist { |
324 |
sub getbackupfilelist { |
670 |
my $args = shift; |
325 |
my $args = shift; |
671 |
my $directory = $args->{directory}; |
326 |
my $directory = $args->{directory}; |
672 |
- |
|
|