|
Lines 182-187
sub sftp_download {
Link Here
|
| 182 |
sub ingest { |
182 |
sub ingest { |
| 183 |
my ( $self, $msg_hash, @downloaded_files ) = @_; |
183 |
my ( $self, $msg_hash, @downloaded_files ) = @_; |
| 184 |
foreach my $f (@downloaded_files) { |
184 |
foreach my $f (@downloaded_files) { |
|
|
185 |
|
| 186 |
# Check file has not been downloaded already |
| 187 |
my $existing_file = $self->{schema}->resultset('EdifactMessage') |
| 188 |
->find( { filename => $f, } ); |
| 189 |
if ($existing_file) { |
| 190 |
carp "skipping ingest of $f : filename exists"; |
| 191 |
next; |
| 192 |
} |
| 193 |
|
| 185 |
$msg_hash->{filename} = $f; |
194 |
$msg_hash->{filename} = $f; |
| 186 |
my $file_content = |
195 |
my $file_content = |
| 187 |
read_file( "$self->{working_dir}/$f", binmode => ':raw' ); |
196 |
read_file( "$self->{working_dir}/$f", binmode => ':raw' ); |
| 188 |
- |
|
|