1 package fr.ifremer.tutti.service.genericformat.consumer;
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27 import fr.ifremer.tutti.persistence.entities.data.MarineLitterBatch;
28 import fr.ifremer.tutti.service.csv.CsvComsumer;
29 import fr.ifremer.tutti.service.genericformat.GenericFormatContextSupport;
30 import fr.ifremer.tutti.service.genericformat.GenericFormatImportEntityParserFactory;
31 import fr.ifremer.tutti.service.genericformat.GenericFormatImportOperationContext;
32 import fr.ifremer.tutti.service.genericformat.csv.MarineLitterModel;
33 import fr.ifremer.tutti.service.genericformat.csv.MarineLitterRow;
34 import org.nuiton.csv.ImportRow;
35
36 import java.nio.file.Path;
37
38
39
40
41
42
43
44 public class CsvConsumerForMarineLitter extends CsvComsumer<MarineLitterRow, MarineLitterModel> {
45
46 public CsvConsumerForMarineLitter(Path file, char separator, GenericFormatImportEntityParserFactory parserFactory, boolean reportError) {
47 super(file, MarineLitterModel.forImport(separator, parserFactory), reportError);
48 }
49
50 public GenericFormatImportOperationContext validateRow(ImportRow<MarineLitterRow> row, GenericFormatContextSupport importContext) {
51
52 GenericFormatImportOperationContext operationContext = importContext.getValidationHelper().getFishingOperationContext(this, row, importContext);
53
54 if (operationContext != null) {
55
56
57 MarineLitterRow bean = row.getBean();
58
59 }
60
61 reportError(row);
62
63 return operationContext;
64
65 }
66
67 public void prepareRowForPersist(GenericFormatImportOperationContext operationContext, ImportRow<MarineLitterRow> row) {
68
69 MarineLitterRow bean = row.getBean();
70 MarineLitterBatch marineLitterBatch = bean.getMarineLitterBatch();
71 marineLitterBatch.setFishingOperation(operationContext.getFishingOperation());
72 operationContext.addMarineLitterBatch(marineLitterBatch);
73
74 }
75
76 }