Skip to content

Commit

Permalink
Fix : merge de develop suite à correction bug accesCbs et changement …
Browse files Browse the repository at this point in the history 
…de version
  • Loading branch information
@pierre-maraval
pierre-maraval committed Apr 18, 2024
1 parent e5f5719 commit e896fe1
Show file tree
Hide file tree
Showing 7 changed files with 20 additions and 46 deletions.
Empty file removed batch/src/main/java/fr/abes/item/BatchConfiguration.java
View file
Empty file.
Empty file removed core/src/main/java/fr/abes/item/service/ITraitementService.java
View file
Empty file.
20 changes: 3 additions & 17 deletions core/src/main/java/fr/abes/item/service/TraitementService.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,6 @@
import fr.abes.item.repository.item.ITraitementDao;
import fr.abes.item.utilitaire.Utilitaires;
import lombok.Getter;
import lombok.NoArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
Expand All @@ -24,7 +23,6 @@

@Slf4j
@Service
@NoArgsConstructor
public class TraitementService {
private final ITraitementDao traitementDao;

Expand All @@ -33,8 +31,7 @@ public class TraitementService {

@Value("${sudoc.port}")
private String portSudoc;

private String datePattern = "dd-MM-yyyy HH:mm";


@Getter
private ProcessCBS cbs;
Expand All @@ -45,7 +42,6 @@ public TraitementService(ITraitementDao traitementDao) {
cbs = new ProcessCBS();
}

@Override
public void authenticate(String login) throws CBSException, IOException {
this.cbs = new ProcessCBS();
this.cbs.authenticate(serveurSudoc, portSudoc, login, Constant.PASSSUDOC);
Expand All @@ -59,7 +55,6 @@ public void authenticate(String login) throws CBSException, IOException {
* @throws CBSException : Erreur CBS
* @throws IOException : erreur de communication avec le CBS
*/
@Override
public String getNoticeFromEPN(String epn) throws CBSException, IOException {
cbs.search("che EPN " + epn);
if (cbs.getNbNotices() == 1) {
Expand All @@ -81,7 +76,6 @@ public String getNoticeFromEPN(String epn) throws CBSException, IOException {
* @param exemp notice à modifier
* @return notice avec nouvelle zone / sous zone préfixée de STR_1F
*/
@Override
public Exemplaire creerNouvelleZone(String exemp, String tag, String subTag, String valeur) throws ZoneException {
Exemplaire exemplaire = new Exemplaire(exemp);
exemplaire.addZone(tag, subTag, valeur);
Expand All @@ -96,7 +90,6 @@ public Exemplaire creerNouvelleZone(String exemp, String tag, String subTag, Str
* @param tag zone à supprimer
* @return chaine de l'exemplaire modifié préfixé par STR_1F
*/
@Override
public Exemplaire supprimerZone(String exemp, String tag) throws ZoneException {
Exemplaire exemplaire = new Exemplaire(exemp);
exemplaire.deleteZone(tag);
Expand All @@ -112,7 +105,6 @@ public Exemplaire supprimerZone(String exemp, String tag) throws ZoneException {
* @param subTag zone à supprimer
* @return chaine de l'exemplaire modifié préfixé par STR_1F
*/
@Override
public Exemplaire supprimerSousZone(String exemp, String tag, String subTag) throws ZoneException {
Exemplaire exemplaire = new Exemplaire(exemp);
exemplaire.deleteSousZone(tag, subTag);
Expand All @@ -130,7 +122,6 @@ public Exemplaire supprimerSousZone(String exemp, String tag, String subTag) thr
* @param valeur valeur associée à la sous zone (la sous-zone est la clé)
* @return l'exemplaire modifié
*/
@Override
public Exemplaire creerSousZone(String exemp, String tag, String subTag, String valeur) throws ZoneException {
Exemplaire exemplaire = new Exemplaire(exemp);
exemplaire.addSousZone(tag, subTag, valeur);
Expand All @@ -147,7 +138,6 @@ public Exemplaire creerSousZone(String exemp, String tag, String subTag, String
* @param valeur valeur associée à la sous zone (la sous-zone est la clé)
* @return l'exemplaire modifié
*/
@Override
public Exemplaire remplacerSousZone(String exemp, String tag, String subTag, String valeur) throws ZoneException {
Exemplaire exemplaire = new Exemplaire(exemp);
try {
Expand Down Expand Up @@ -190,7 +180,6 @@ public Exemplaire ajout991(Exemplaire exemp) throws ZoneException {
* @throws CBSException : erreur CBS
* @throws IOException : erreur de communication CBS
*/
@Override
public String saveExemplaire(String noticeModifiee, String epn) throws CBSException, IOException {
String numEx = Utilitaires.getNumExFromExemp(noticeModifiee);
log.debug(epn + " sauvegarde exemplaire");
Expand All @@ -201,7 +190,6 @@ public String saveExemplaire(String noticeModifiee, String epn) throws CBSExcept
/**
* Deconnexion du client CBS (sudoc)
*/
@Override
public void disconnect() throws CBSException {
cbs.getClientCBS().disconnect();
}
Expand All @@ -212,14 +200,12 @@ public void disconnect() throws CBSException {
*
* @return liste de tous les traitements
*/
@Override
public List<Traitement> findAll() {
return dao.getTraitement().findAll();
return traitementDao.findAll();
}

@Override
public Integer findTraitementByDemandeId(Integer id) {
return dao.getTraitement().findTraitementByDemandeModifId(id);
return traitementDao.findTraitementByDemandeModifId(id);
}


Expand Down
6 changes: 2 additions & 4 deletions core/src/main/java/fr/abes/item/service/impl/DemandeExempService.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -414,7 +414,7 @@ public String launchQueryToSudoc(DemandeExemp demande, String valeurs) throws CB
try {
traitementService.getCbs().search(query);
nbReponses = traitementService.getCbs().getNbNotices();
} catch (CBSException e) {
} catch (IOException e) {
nbReponses = 0;
}
switch (nbReponses) {
Expand Down Expand Up @@ -625,16 +625,14 @@ public String creerExemplaireFromHeaderEtValeur(String header, String valeurZone
* Méthode d'ajout d'une zone 991 prédéfinie dans l'exemplaire
*
* @param exemp : exemplaire sur lequel rajouter la 991
* @return : l'exemplaire modifié
*/
private Exemplaire ajout991(Exemplaire exemp) throws ZoneException {
private void ajout991(Exemplaire exemp) throws ZoneException {
String datePattern = "dd-MM-yyyy HH:mm";
SimpleDateFormat simpleDateFormat = new SimpleDateFormat(datePattern);
String date = simpleDateFormat.format(new Date());
String valeur991 = Constant.TEXTE_991_CREA + " le " + date;
char[] indicateurs = {'#', '#'};
exemp.addZone("991", "$a", valeur991, indicateurs);
return exemp;
}

/**
Expand Down
9 changes: 2 additions & 7 deletions core/src/main/java/fr/abes/item/service/impl/DemandeModifService.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -2,13 +2,8 @@

import fr.abes.cbs.exception.CBSException;
import fr.abes.cbs.exception.ZoneException;
import fr.abes.item.components.*;
import fr.abes.cbs.notices.Exemplaire;
import fr.abes.item.components.Fichier;
import fr.abes.item.components.FichierEnrichiModif;
import fr.abes.item.components.FichierInitial;
import fr.abes.item.components.FichierPrepare;
import fr.abes.item.components.basexml.Ppntoepn;
import fr.abes.item.components.*;
import fr.abes.item.constant.Constant;
import fr.abes.item.constant.TYPE_DEMANDE;
import fr.abes.item.entities.item.*;
Expand Down Expand Up @@ -301,7 +296,7 @@ public DemandeModif creerDemande(String rcr, Date dateCreation, Date dateModific
* @throws CBSException : erreur CBS
*/
@Override
public String getNoticeInitiale(DemandeModif demandeModif, String epn) throws CBSException, IOException, ZoneException {
public String getNoticeInitiale(DemandeModif demandeModif, String epn) throws CBSException, IOException {
try {
traitementService.authenticate('M' + demandeModif.getRcr());
// appel getNoticeFromEPN sur EPN récupéré
Expand Down
6 changes: 3 additions & 3 deletions core/src/main/java/fr/abes/item/utilitaire/Utilitaires.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -96,9 +96,9 @@ public static String getExempFromNotice(String notice, String epn) {
for (String listExemp : listExemps) {
if (listExemp.contains("A99 " + epn)) {
//la fin de la chaine est différente en fonction de si l'exemplaire trouvé est le dernier ou non, on adapte le retour en fonction
return (listExemps[i].contains(Constants.STR_1E + Constants.VMC))
? listExemps[i].substring(listExemps[i].indexOf(Constants.STR_1F) + 1, listExemps[i].indexOf(Constants.STR_1E + Constants.VMC)) + Constants.STR_1E
: listExemps[i].substring(listExemps[i].indexOf(Constants.STR_1F) + 1);
return (listExemp.contains(Constants.STR_1E + Constants.VMC))
? listExemp.substring(listExemp.indexOf(Constants.STR_1F) + 1, listExemp.indexOf(Constants.STR_1E + Constants.VMC)) + Constants.STR_1E
: listExemp.substring(listExemp.indexOf(Constants.STR_1F) + 1);
}
}
return "";
Expand Down
25 changes: 10 additions & 15 deletions web/src/main/java/fr/abes/item/web/DemandeRestService.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -2,8 +2,7 @@

import fr.abes.cbs.exception.CBSException;
import fr.abes.cbs.exception.ZoneException;
import fr.abes.cbs.utilitaire.Constants;
import fr.abes.cbs.utilitaire.Utilitaire;
import fr.abes.cbs.notices.Exemplaire;
import fr.abes.item.constant.Constant;
import fr.abes.item.constant.TYPE_DEMANDE;
import fr.abes.item.entities.item.*;
Expand All @@ -14,7 +13,6 @@
import fr.abes.item.service.TraitementService;
import fr.abes.item.service.UtilisateurService;
import fr.abes.item.service.impl.*;
import fr.abes.item.utilitaire.Utilitaires;
import io.swagger.v3.oas.annotations.Operation;
import jakarta.servlet.http.HttpServletRequest;
import lombok.extern.slf4j.Slf4j;
Expand Down Expand Up @@ -332,27 +330,24 @@ public String[] simulerLigne(TYPE_DEMANDE type, @RequestParam Integer numDemande
LigneFichierModif ligneFichierModif = (LigneFichierModif) ligneFichierModifService.getLigneFichierbyDemandeEtPos(demandeModifService.findById(numDemande), numLigne);
/*Notice init := notice avant traitement*/
String noticeInit = demandeModifService.getNoticeInitiale(demandeModifService.findById(numDemande), ligneFichierModif.getEpn());
noticeInit = demandeModifService.getSeparationBetweenBlocks(noticeInit); /*Gestion des espaces zones locales zones système*/

String noticeInitStr = noticeInit.replace("\r", "\r\n");
/*Notice traitée := notice après traitement*/
String noticeTraitee = demandeModifService.getNoticeTraitee(demandeModifService.findById(numDemande), noticeInit, ligneFichierModif);
noticeTraitee = demandeModifService.getSeparationBetweenBlocks((noticeTraitee));
Exemplaire noticeTraitee = demandeModifService.getNoticeTraitee(demandeModifService.findById(numDemande), noticeInit, ligneFichierModif);

String numEx = Utilitaires.getNumExFromExemp(noticeInit);
return new String[]{
traitementService.getCbs().getPpnEncours(),
Utilitaire.recupEntre(Utilitaire.recupEntre(noticeInit, Constants.STR_1F, Constants.STR_0D + Constants.STR_1E), 'e' + numEx, "").replace("\r", "\r\n"),
Utilitaire.recupEntre(Utilitaire.recupEntre(noticeTraitee, Constants.STR_1F, Constants.STR_0D + Constants.STR_1E), 'e' + numEx, "").replace("\r", "\r\n")
noticeInitStr,
noticeTraitee.toString().replace("\r", "\r\n")
};
} catch (NullPointerException ex) {
} catch (NullPointerException | IOException ex) {
throw new NullPointerException(Constant.FILE_END);
}
case EXEMP:
try {
DemandeExemp demande = demandeExempService.findById(numDemande);
LigneFichierExemp ligneFichierExemp = (LigneFichierExemp) ligneFichierExempService.getLigneFichierbyDemandeEtPos(demande, numLigne);
return demandeExempService.getNoticeExemplaireAvantApres(demande, ligneFichierExemp);
} catch (NullPointerException ex) {
} catch (NullPointerException | IOException ex) {
throw new NullPointerException(Constant.FILE_END);
}
default:
Expand Down Expand Up @@ -384,7 +379,7 @@ public Demande passerEnAttente(TYPE_DEMANDE type, Integer numDemande, HttpServle
yield demandeExempService.changeState(demandeExemp, Constant.ETATDEM_ATTENTE);
}
default -> {
DemandeRecouv demandeRecouv = (DemandeRecouv) demandeRecouvService.findById(numDemande);
DemandeRecouv demandeRecouv = demandeRecouvService.findById(numDemande);
yield demandeRecouvService.changeState(demandeRecouv, Constant.ETATDEM_ATTENTE);
}
};
Expand Down Expand Up @@ -417,7 +412,7 @@ public Demande archiverDemande(TYPE_DEMANDE type, Integer numDemande, HttpServle
yield demandeExempService.archiverDemande(demandeExemp);
}
default -> {
DemandeRecouv demandeRecouv = (DemandeRecouv) demandeRecouvService.findById(numDemande);
DemandeRecouv demandeRecouv = demandeRecouvService.findById(numDemande);
yield demandeRecouvService.archiverDemande(demandeRecouv);
}
};
Expand Down Expand Up @@ -450,7 +445,7 @@ public Demande previousStep(TYPE_DEMANDE type, @PathVariable Integer id, HttpSer
yield demandeExempService.previousState(demandeExemp);
}
default -> {
DemandeRecouv demandeRecouv = (DemandeRecouv) demandeRecouvService.findById(id);
DemandeRecouv demandeRecouv = demandeRecouvService.findById(id);
yield demandeRecouvService.previousState(demandeRecouv);
}
};
Expand Down

0 comments on commit e896fe1

Please sign in to comment.