WebSVN - OpenConcerto - Diff - Rev 174 and 177 - /trunk/OpenConcerto/src/org/openconcerto/erp/generationEcritures/Exercice.java



        final DBSystemRoot sysRoot = root.getDBSystemRoot();
        final List<SQLInsert> insertsPiece = new ArrayList<>();
        LOGGER.log(Level.INFO, "insertion de {0} pièces comptables", pieces.size());
        for (Piece p : pieces) {
            // Pièces
            insertsPiece.add(p.createInsert(root, user));
 
            // Vérification des mouvements
            final List<Mouvement> mouvements = p.getMouvements();
            if (mouvements.isEmpty()) {
                throw new IllegalStateException("Piece vide : " + p);

                    final List<Journal> list = new ArrayList<>();
                    for (Journal journal : journauxACreerOuFetcher) {
                        // journal non déjà existant
                        if (codesDesJournauxExistants.get(journal.getCode().toLowerCase()) == null) {
                            list.add(journal);
                            insertsJournaux.add(journal.createInsert(root, user));
                        }
                    }
                    final List<Number> journauxIds = new ArrayList<>();
                    if (!insertsJournaux.isEmpty()) {
                        journauxIds.addAll(SQLInsert.executeSimilarInserts(sysRoot, insertsJournaux, true));

                        if (numerosDesComptesExistants.get(c.getNumero().toLowerCase()) == null) {
                            if (LOGGER.isLoggable(Level.FINE)) {
                                LOGGER.fine("création du compte : " + c.getNumero().toLowerCase());
                            }
                            list.add(c);
                            insertsComptes.add(c.createInsert(root, user));
                        }
                    }
                    List<Number> comptesIds = new ArrayList<>();
                    if (!insertsComptes.isEmpty()) {
 

                for (int i = 0; i < pieces.size(); i++) {
                    Piece piece = pieces.get(i);
                    piece.setId(idsPieces.get(i));
                    for (Mouvement m : piece.getMouvements()) {
                        listMvtWithoutIDs.add(m);
                        insertsMouvement.add(m.createInsert(root, user));
                    }
                }
 
                // Insertion des mouvements
                final List<Number> idsMouvements = SQLInsert.executeSimilarInserts(sysRoot, insertsMouvement, true);

                if (maxMvtNumber != null) {
                    maxMvt = maxMvtNumber.intValue();
                }
                List<SQLUpdate> mvtUpdate = new ArrayList<>();
                for (int i = 0; i < idsMouvements.size(); i++) {
                    maxMvt++;
                    Number mvtId = idsMouvements.get(i);
                    SQLUpdate update = new SQLUpdate(new Where(tableMvt.getKey(), "=", mvtId));
                    update.add(tableMvt.getField("NUMERO"), maxMvt);
                    mvtUpdate.add(update);
 
                    listMvtWithoutIDs.get(i).setId(mvtId);
                }
 
                SQLUpdate.executeMultipleWithBatch(sysRoot, mvtUpdate);
 

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

svn://code.openconcerto.org/openconcerto

(root)/trunk/OpenConcerto/src/org/openconcerto/erp/generationEcritures/Exercice.java - Rev 174 → 177

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