OpenConcerto

Dépôt officiel du code source de l'ERP OpenConcerto
sonarqube

svn://code.openconcerto.org/openconcerto

Rev

Rev 174 | Show entire file | Regard whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 174 Rev 177
Line 70... Line 70...
70
        final DBSystemRoot sysRoot = root.getDBSystemRoot();
70
        final DBSystemRoot sysRoot = root.getDBSystemRoot();
71
        final List<SQLInsert> insertsPiece = new ArrayList<>();
71
        final List<SQLInsert> insertsPiece = new ArrayList<>();
72
        LOGGER.log(Level.INFO, "insertion de {0} pièces comptables", pieces.size());
72
        LOGGER.log(Level.INFO, "insertion de {0} pièces comptables", pieces.size());
73
        for (Piece p : pieces) {
73
        for (Piece p : pieces) {
74
            // Pièces
74
            // Pièces
75
            insertsPiece.add(p.createInsert(root));
75
            insertsPiece.add(p.createInsert(root, user));
76
 
76
 
77
            // Vérification des mouvements
77
            // Vérification des mouvements
78
            final List<Mouvement> mouvements = p.getMouvements();
78
            final List<Mouvement> mouvements = p.getMouvements();
79
            if (mouvements.isEmpty()) {
79
            if (mouvements.isEmpty()) {
80
                throw new IllegalStateException("Piece vide : " + p);
80
                throw new IllegalStateException("Piece vide : " + p);
Line 154... Line 154...
154
                    final List<Journal> list = new ArrayList<>();
154
                    final List<Journal> list = new ArrayList<>();
155
                    for (Journal journal : journauxACreerOuFetcher) {
155
                    for (Journal journal : journauxACreerOuFetcher) {
156
                        // journal non déjà existant
156
                        // journal non déjà existant
157
                        if (codesDesJournauxExistants.get(journal.getCode().toLowerCase()) == null) {
157
                        if (codesDesJournauxExistants.get(journal.getCode().toLowerCase()) == null) {
158
                            list.add(journal);
158
                            list.add(journal);
159
                            insertsJournaux.add(journal.createInsert(root));
159
                            insertsJournaux.add(journal.createInsert(root, user));
160
                        }
160
                        }
161
                    }
161
                    }
162
                    final List<Number> journauxIds = new ArrayList<>();
162
                    final List<Number> journauxIds = new ArrayList<>();
163
                    if (!insertsJournaux.isEmpty()) {
163
                    if (!insertsJournaux.isEmpty()) {
164
                        journauxIds.addAll(SQLInsert.executeSimilarInserts(sysRoot, insertsJournaux, true));
164
                        journauxIds.addAll(SQLInsert.executeSimilarInserts(sysRoot, insertsJournaux, true));
Line 205... Line 205...
205
                        if (numerosDesComptesExistants.get(c.getNumero().toLowerCase()) == null) {
205
                        if (numerosDesComptesExistants.get(c.getNumero().toLowerCase()) == null) {
206
                            if (LOGGER.isLoggable(Level.FINE)) {
206
                            if (LOGGER.isLoggable(Level.FINE)) {
207
                                LOGGER.fine("création du compte : " + c.getNumero().toLowerCase());
207
                                LOGGER.fine("création du compte : " + c.getNumero().toLowerCase());
208
                            }
208
                            }
209
                            list.add(c);
209
                            list.add(c);
210
                            insertsComptes.add(c.createInsert(root));
210
                            insertsComptes.add(c.createInsert(root, user));
211
                        }
211
                        }
212
                    }
212
                    }
213
                    List<Number> comptesIds = new ArrayList<>();
213
                    List<Number> comptesIds = new ArrayList<>();
214
                    if (!insertsComptes.isEmpty()) {
214
                    if (!insertsComptes.isEmpty()) {
215
 
215
 
Line 350... Line 350...
350
                for (int i = 0; i < pieces.size(); i++) {
350
                for (int i = 0; i < pieces.size(); i++) {
351
                    Piece piece = pieces.get(i);
351
                    Piece piece = pieces.get(i);
352
                    piece.setId(idsPieces.get(i));
352
                    piece.setId(idsPieces.get(i));
353
                    for (Mouvement m : piece.getMouvements()) {
353
                    for (Mouvement m : piece.getMouvements()) {
354
                        listMvtWithoutIDs.add(m);
354
                        listMvtWithoutIDs.add(m);
355
                        insertsMouvement.add(m.createInsert(root));
355
                        insertsMouvement.add(m.createInsert(root, user));
356
                    }
356
                    }
357
                }
357
                }
358
 
358
 
359
                // Insertion des mouvements
359
                // Insertion des mouvements
360
                final List<Number> idsMouvements = SQLInsert.executeSimilarInserts(sysRoot, insertsMouvement, true);
360
                final List<Number> idsMouvements = SQLInsert.executeSimilarInserts(sysRoot, insertsMouvement, true);
Line 368... Line 368...
368
                if (maxMvtNumber != null) {
368
                if (maxMvtNumber != null) {
369
                    maxMvt = maxMvtNumber.intValue();
369
                    maxMvt = maxMvtNumber.intValue();
370
                }
370
                }
371
                List<SQLUpdate> mvtUpdate = new ArrayList<>();
371
                List<SQLUpdate> mvtUpdate = new ArrayList<>();
372
                for (int i = 0; i < idsMouvements.size(); i++) {
372
                for (int i = 0; i < idsMouvements.size(); i++) {
-
 
373
                    maxMvt++;
373
                    Number mvtId = idsMouvements.get(i);
374
                    Number mvtId = idsMouvements.get(i);
374
                    SQLUpdate update = new SQLUpdate(new Where(tableMvt.getKey(), "=", mvtId));
375
                    SQLUpdate update = new SQLUpdate(new Where(tableMvt.getKey(), "=", mvtId));
375
                    update.add(tableMvt.getField("NUMERO"), maxMvt);
376
                    update.add(tableMvt.getField("NUMERO"), maxMvt);
376
                    mvtUpdate.add(update);
377
                    mvtUpdate.add(update);
377
                    maxMvt++;
-
 
378
                    listMvtWithoutIDs.get(i).setId(mvtId);
378
                    listMvtWithoutIDs.get(i).setId(mvtId);
379
                }
379
                }
380
 
380
 
381
                SQLUpdate.executeMultipleWithBatch(sysRoot, mvtUpdate);
381
                SQLUpdate.executeMultipleWithBatch(sysRoot, mvtUpdate);
382
 
382