9
9
10
10
import com .fasterxml .jackson .core .JsonProcessingException ;
11
11
import com .fasterxml .jackson .databind .ObjectMapper ;
12
- import com .powsybl .shortcircuit .ShortCircuitParameters ;
13
12
import org .apache .commons .lang3 .StringUtils ;
14
13
import org .apache .logging .log4j .util .Strings ;
15
14
import org .gridsuite .study .server .dto .*;
@@ -67,6 +66,7 @@ public class ConsumerService {
67
66
private final UserAdminService userAdminService ;
68
67
private final NetworkModificationTreeService networkModificationTreeService ;
69
68
private final StudyRepository studyRepository ;
69
+ private final ShortCircuitService shortCircuitService ;
70
70
71
71
@ Autowired
72
72
public ConsumerService (ObjectMapper objectMapper ,
@@ -75,6 +75,7 @@ public ConsumerService(ObjectMapper objectMapper,
75
75
SecurityAnalysisService securityAnalysisService ,
76
76
CaseService caseService ,
77
77
LoadFlowService loadFlowService ,
78
+ ShortCircuitService shortCircuitService ,
78
79
UserAdminService userAdminService ,
79
80
NetworkModificationTreeService networkModificationTreeService ,
80
81
SensitivityAnalysisService sensitivityAnalysisService ,
@@ -89,6 +90,7 @@ public ConsumerService(ObjectMapper objectMapper,
89
90
this .networkModificationTreeService = networkModificationTreeService ;
90
91
this .sensitivityAnalysisService = sensitivityAnalysisService ;
91
92
this .studyRepository = studyRepository ;
93
+ this .shortCircuitService = shortCircuitService ;
92
94
}
93
95
94
96
@ Bean
@@ -183,10 +185,9 @@ public Consumer<Message<String>> consumeCaseImportSucceeded() {
183
185
if (receiverString != null ) {
184
186
CaseImportReceiver receiver ;
185
187
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 );
188
189
} catch (JsonProcessingException e ) {
189
- LOGGER .error (e . toString () );
190
+ LOGGER .error ("Error while parsing CaseImportReceiver data" , e );
190
191
return ;
191
192
}
192
193
@@ -198,23 +199,21 @@ public Consumer<Message<String>> consumeCaseImportSucceeded() {
198
199
199
200
StudyEntity studyEntity = studyRepository .findById (studyUuid ).orElse (null );
200
201
try {
201
- ShortCircuitParameters shortCircuitParameters = ShortCircuitService .getDefaultShortCircuitParameters ();
202
- DynamicSimulationParametersInfos dynamicSimulationParameters = DynamicSimulationService .getDefaultDynamicSimulationParameters ();
203
202
if (studyEntity != null ) {
204
203
// if studyEntity is not null, it means we are recreating network for existing study
205
204
// we only update network infos sent by network conversion server
206
205
studyService .updateStudyNetwork (studyEntity , userId , networkInfos );
207
206
} 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 ();
210
210
UUID securityAnalysisParametersUuid = createDefaultSecurityAnalysisParameters ();
211
211
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 );
213
213
}
214
-
215
214
caseService .disableCaseExpiration (caseUuid );
216
215
} catch (Exception e ) {
217
- LOGGER .error (e . toString () , e );
216
+ LOGGER .error ("Error while importing case" , e );
218
217
} finally {
219
218
// if studyEntity is already existing, we don't delete anything in the end of the process
220
219
if (studyEntity == null ) {
@@ -250,19 +249,37 @@ private UUID createDefaultLoadFlowParameters(String userId, UserProfileInfos use
250
249
// no profile, or no/bad LF parameters in profile => use default values
251
250
try {
252
251
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 ;
255
264
}
256
- return null ;
257
265
}
258
266
259
267
private UUID createDefaultSensitivityAnalysisParameters () {
260
268
try {
261
269
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 ;
264
282
}
265
- return null ;
266
283
}
267
284
268
285
@ Bean
@@ -499,15 +516,6 @@ public Consumer<Message<String>> consumeVoltageInitFailed() {
499
516
return message -> consumeCalculationFailed (message , VOLTAGE_INITIALIZATION );
500
517
}
501
518
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
- }
510
-
511
519
@ Bean
512
520
public Consumer <Message <String >> consumeStateEstimationResult () {
513
521
return message -> consumeCalculationResult (message , STATE_ESTIMATION );
0 commit comments