99
1010import com .fasterxml .jackson .core .JsonProcessingException ;
1111import com .fasterxml .jackson .databind .ObjectMapper ;
12- import com .powsybl .shortcircuit .ShortCircuitParameters ;
1312import org .apache .commons .lang3 .StringUtils ;
1413import org .apache .logging .log4j .util .Strings ;
1514import org .gridsuite .study .server .dto .*;
@@ -67,6 +66,7 @@ public class ConsumerService {
6766 private final UserAdminService userAdminService ;
6867 private final NetworkModificationTreeService networkModificationTreeService ;
6968 private final StudyRepository studyRepository ;
69+ private final ShortCircuitService shortCircuitService ;
7070
7171 @ Autowired
7272 public ConsumerService (ObjectMapper objectMapper ,
@@ -75,6 +75,7 @@ public ConsumerService(ObjectMapper objectMapper,
7575 SecurityAnalysisService securityAnalysisService ,
7676 CaseService caseService ,
7777 LoadFlowService loadFlowService ,
78+ ShortCircuitService shortCircuitService ,
7879 UserAdminService userAdminService ,
7980 NetworkModificationTreeService networkModificationTreeService ,
8081 SensitivityAnalysisService sensitivityAnalysisService ,
@@ -89,6 +90,7 @@ public ConsumerService(ObjectMapper objectMapper,
8990 this .networkModificationTreeService = networkModificationTreeService ;
9091 this .sensitivityAnalysisService = sensitivityAnalysisService ;
9192 this .studyRepository = studyRepository ;
93+ this .shortCircuitService = shortCircuitService ;
9294 }
9395
9496 @ Bean
@@ -183,10 +185,9 @@ public Consumer<Message<String>> consumeCaseImportSucceeded() {
183185 if (receiverString != null ) {
184186 CaseImportReceiver receiver ;
185187 try {
186- receiver = objectMapper .readValue (URLDecoder .decode (receiverString , StandardCharsets .UTF_8 ),
187- CaseImportReceiver .class );
188+ receiver = objectMapper .readValue (URLDecoder .decode (receiverString , StandardCharsets .UTF_8 ), CaseImportReceiver .class );
188189 } catch (JsonProcessingException e ) {
189- LOGGER .error (e . toString () );
190+ LOGGER .error ("Error while parsing CaseImportReceiver data" , e );
190191 return ;
191192 }
192193
@@ -198,23 +199,21 @@ public Consumer<Message<String>> consumeCaseImportSucceeded() {
198199
199200 StudyEntity studyEntity = studyRepository .findById (studyUuid ).orElse (null );
200201 try {
201- ShortCircuitParameters shortCircuitParameters = ShortCircuitService .getDefaultShortCircuitParameters ();
202- DynamicSimulationParametersInfos dynamicSimulationParameters = DynamicSimulationService .getDefaultDynamicSimulationParameters ();
203202 if (studyEntity != null ) {
204203 // if studyEntity is not null, it means we are recreating network for existing study
205204 // we only update network infos sent by network conversion server
206205 studyService .updateStudyNetwork (studyEntity , userId , networkInfos );
207206 } else {
208- UserProfileInfos userProfileInfos = getUserProfile (userId );
209- UUID loadFlowParametersUuid = createDefaultLoadFlowParameters (userId , userProfileInfos );
207+ DynamicSimulationParametersInfos dynamicSimulationParameters = DynamicSimulationService .getDefaultDynamicSimulationParameters ();
208+ UUID loadFlowParametersUuid = createDefaultLoadFlowParameters (userId , getUserProfile (userId ));
209+ UUID shortCircuitParametersUuid = createDefaultShortCircuitAnalysisParameters ();
210210 UUID securityAnalysisParametersUuid = createDefaultSecurityAnalysisParameters ();
211211 UUID sensitivityAnalysisParametersUuid = createDefaultSensitivityAnalysisParameters ();
212- studyService .insertStudy (studyUuid , userId , networkInfos , caseFormat , caseUuid , caseName , loadFlowParametersUuid , ShortCircuitService . toEntity ( shortCircuitParameters , ShortCircuitPredefinedConfiguration . ICC_MAX_WITH_NOMINAL_VOLTAGE_MAP ) , DynamicSimulationService .toEntity (dynamicSimulationParameters , objectMapper ), null , securityAnalysisParametersUuid , sensitivityAnalysisParametersUuid , importParameters , importReportUuid );
212+ studyService .insertStudy (studyUuid , userId , networkInfos , caseFormat , caseUuid , caseName , loadFlowParametersUuid , shortCircuitParametersUuid , DynamicSimulationService .toEntity (dynamicSimulationParameters , objectMapper ), null , securityAnalysisParametersUuid , sensitivityAnalysisParametersUuid , importParameters , importReportUuid );
213213 }
214-
215214 caseService .disableCaseExpiration (caseUuid );
216215 } catch (Exception e ) {
217- LOGGER .error (e . toString () , e );
216+ LOGGER .error ("Error while importing case" , e );
218217 } finally {
219218 // if studyEntity is already existing, we don't delete anything in the end of the process
220219 if (studyEntity == null ) {
@@ -250,19 +249,37 @@ private UUID createDefaultLoadFlowParameters(String userId, UserProfileInfos use
250249 // no profile, or no/bad LF parameters in profile => use default values
251250 try {
252251 return loadFlowService .createDefaultLoadFlowParameters ();
253- } catch (Exception e ) {
254- LOGGER .error (e .toString (), e );
252+ } catch (final Exception e ) {
253+ LOGGER .error ("Error while creating default parameters for LoadFlow analysis" , e );
254+ return null ;
255+ }
256+ }
257+
258+ private UUID createDefaultShortCircuitAnalysisParameters () {
259+ try {
260+ return shortCircuitService .createParameters (null );
261+ } catch (final Exception e ) {
262+ LOGGER .error ("Error while creating default parameters for ShortCircuit analysis" , e );
263+ return null ;
255264 }
256- return null ;
257265 }
258266
259267 private UUID createDefaultSensitivityAnalysisParameters () {
260268 try {
261269 return sensitivityAnalysisService .createDefaultSensitivityAnalysisParameters ();
262- } catch (Exception e ) {
263- LOGGER .error (e .toString (), e );
270+ } catch (final Exception e ) {
271+ LOGGER .error ("Error while creating default parameters for Sensitivity analysis" , e );
272+ return null ;
273+ }
274+ }
275+
276+ private UUID createDefaultSecurityAnalysisParameters () {
277+ try {
278+ return securityAnalysisService .createDefaultSecurityAnalysisParameters ();
279+ } catch (final Exception e ) {
280+ LOGGER .error ("Error while creating default parameters for Security analysis" , e );
281+ return null ;
264282 }
265- return null ;
266283 }
267284
268285 @ Bean
@@ -498,13 +515,4 @@ public Consumer<Message<String>> consumeVoltageInitStopped() {
498515 public Consumer <Message <String >> consumeVoltageInitFailed () {
499516 return message -> consumeCalculationFailed (message , VOLTAGE_INITIALIZATION );
500517 }
501-
502- private UUID createDefaultSecurityAnalysisParameters () {
503- try {
504- return securityAnalysisService .createDefaultSecurityAnalysisParameters ();
505- } catch (Exception e ) {
506- LOGGER .error (e .toString (), e );
507- }
508- return null ;
509- }
510518}
0 commit comments