Fix exchange documenti
This commit is contained in:
@@ -124,6 +124,12 @@ public class ExchangeDocumentImportService {
|
|||||||
((DtbDoct) x).setUpdProgMaga(false);
|
((DtbDoct) x).setUpdProgMaga(false);
|
||||||
});
|
});
|
||||||
|
|
||||||
|
allRigheData.parallelStream()
|
||||||
|
.filter(x -> x.getOperation() == OperationType.INSERT)
|
||||||
|
.forEach(x -> {
|
||||||
|
x.setOperation(OperationType.INSERT_OR_UPDATE);
|
||||||
|
});
|
||||||
|
|
||||||
allRigheData.stream()
|
allRigheData.stream()
|
||||||
.map(x -> (DtbDocr) x)
|
.map(x -> (DtbDocr) x)
|
||||||
.filter(x -> allTestateData.stream()
|
.filter(x -> allTestateData.stream()
|
||||||
|
|||||||
Reference in New Issue
Block a user