Skip to content
Snippets Groups Projects
Commit 48a69c95 authored by George Tziavas's avatar George Tziavas
Browse files

added ACKNOWLEDGED as initial MCJ state

parent 14eb039d
No related branches found
No related tags found
1 merge request!26Resolve "Initialize the Execution State of a Measurement Collection Job during its creation"
Pipeline #14309 passed
<?xml version="1.0" encoding="ASCII"?>
<pi:Diagram xmi:version="2.0" xmlns:xmi="http://www.omg.org/XMI" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:al="http://eclipse.org/graphiti/mm/algorithms" xmlns:pi="http://eclipse.org/graphiti/mm/pictograms" visible="true" gridUnit="10" diagramTypeId="BPMNdiagram" name="MetricoDeploymentReq" snapToGrid="true" version="0.13.0">
<graphicsAlgorithm xsi:type="al:Rectangle" background="//@colors.1" foreground="//@colors.0" lineWidth="1" transparency="0.0" width="1000" height="1000"/>
<colors red="227" green="238" blue="249"/>
<colors red="255" green="255" blue="255"/>
</pi:Diagram>
<?xml version="1.0" encoding="ASCII"?>
<pi:Diagram xmi:version="2.0" xmlns:xmi="http://www.omg.org/XMI" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:al="http://eclipse.org/graphiti/mm/algorithms" xmlns:pi="http://eclipse.org/graphiti/mm/pictograms" visible="true" gridUnit="10" diagramTypeId="BPMNdiagram" name="ServiceCreationProcess" snapToGrid="true" version="0.13.0">
<graphicsAlgorithm xsi:type="al:Rectangle" background="//@colors.1" foreground="//@colors.0" lineWidth="1" transparency="0.0" width="1000" height="1000"/>
<colors red="227" green="238" blue="249"/>
<colors red="255" green="255" blue="255"/>
</pi:Diagram>
<?xml version="1.0" encoding="ASCII"?>
<pi:Diagram xmi:version="2.0" xmlns:xmi="http://www.omg.org/XMI" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:al="http://eclipse.org/graphiti/mm/algorithms" xmlns:pi="http://eclipse.org/graphiti/mm/pictograms" visible="true" gridUnit="10" diagramTypeId="BPMNdiagram" name="StartOrderProcessProcess" snapToGrid="true" version="0.13.0">
<graphicsAlgorithm xsi:type="al:Rectangle" background="//@colors.1" foreground="//@colors.0" lineWidth="1" transparency="0.0" width="1000" height="1000"/>
<colors red="227" green="238" blue="249"/>
<colors red="255" green="255" blue="255"/>
</pi:Diagram>
...@@ -161,7 +161,7 @@ public class MetricoOrchestrationService implements JavaDelegate { ...@@ -161,7 +161,7 @@ public class MetricoOrchestrationService implements JavaDelegate {
su = new ServiceUpdate();// the object to update the service su = new ServiceUpdate();// the object to update the service
MeasurementCollectionJob mcj = serviceOrderManager.addMeasurementCollectionJob(mcjFVO); MeasurementCollectionJob mcj = serviceOrderManager.addMeasurementCollectionJob(mcjFVO);
if (mcj != null){ if (mcj != null){
logger.info("Measurement Collection Job was not created."); logger.info("Measurement Collection Job was created.");
serviceCharacteristic = new Characteristic(); serviceCharacteristic = new Characteristic();
serviceCharacteristic.setName( "_MT_MCJ_REFID" ); serviceCharacteristic.setName( "_MT_MCJ_REFID" );
...@@ -171,7 +171,15 @@ public class MetricoOrchestrationService implements JavaDelegate { ...@@ -171,7 +171,15 @@ public class MetricoOrchestrationService implements JavaDelegate {
val.setAlias( "" ); val.setAlias( "" );
serviceCharacteristic.setValue(val); serviceCharacteristic.setValue(val);
su.addServiceCharacteristicItem(serviceCharacteristic); su.addServiceCharacteristicItem(serviceCharacteristic);
MeasurementCollectionJobMVO mcjMVO = new MeasurementCollectionJobMVO();
mcjMVO.setExecutionState(ExecutionStateType.ACKNOWLEDGED);
try {
serviceOrderManager.updateMeasurementCollectionJobById(mcj.getUuid(), mcjMVO);
} catch (IOException e) {
throw new RuntimeException(e);
}
} else { } else {
logger.error("Measurement Collection Job was not created."); logger.error("Measurement Collection Job was not created.");
su.setState(ServiceStateType.TERMINATED); su.setState(ServiceStateType.TERMINATED);
......
...@@ -37,6 +37,7 @@ import org.etsi.osl.model.nfv.ScaleDescriptor; ...@@ -37,6 +37,7 @@ import org.etsi.osl.model.nfv.ScaleDescriptor;
import org.etsi.osl.osom.serviceactions.NSActionRequestPayload; import org.etsi.osl.osom.serviceactions.NSActionRequestPayload;
import org.etsi.osl.tmf.pm628.model.MeasurementCollectionJob; import org.etsi.osl.tmf.pm628.model.MeasurementCollectionJob;
import org.etsi.osl.tmf.pm628.model.MeasurementCollectionJobFVO; import org.etsi.osl.tmf.pm628.model.MeasurementCollectionJobFVO;
import org.etsi.osl.tmf.pm628.model.MeasurementCollectionJobMVO;
import org.etsi.osl.tmf.pm632.model.Organization; import org.etsi.osl.tmf.pm632.model.Organization;
import org.etsi.osl.tmf.rcm634.model.LogicalResourceSpecification; import org.etsi.osl.tmf.rcm634.model.LogicalResourceSpecification;
import org.etsi.osl.tmf.rcm634.model.ResourceSpecification; import org.etsi.osl.tmf.rcm634.model.ResourceSpecification;
...@@ -200,6 +201,9 @@ public class ServiceOrderManager { ...@@ -200,6 +201,9 @@ public class ServiceOrderManager {
@Value("${PM_MEASUREMENT_COLLECTION_JOB_ADD}") @Value("${PM_MEASUREMENT_COLLECTION_JOB_ADD}")
private String PM_MEASUREMENT_COLLECTION_JOB_ADD = ""; private String PM_MEASUREMENT_COLLECTION_JOB_ADD = "";
@Value("${PM_MEASUREMENT_COLLECTION_JOB_UPDATE}")
private String PM_MEASUREMENT_COLLECTION_JOB_UPDATE;
@Transactional @Transactional
public void processOrder(ServiceOrder serviceOrder) { public void processOrder(ServiceOrder serviceOrder) {
...@@ -1167,6 +1171,36 @@ public class ServiceOrderManager { ...@@ -1167,6 +1171,36 @@ public class ServiceOrderManager {
return null; return null;
} }
/**
* Updates a Measurement Collection Job in the database using the given Measurement Collection Job ID and update information.
*
* @param mcjId the ID of the Measurement Collection Job to update
* @param mcjMVO the update information for the Measurement Collection Job
* @return the updated Measurement Collection Job, or null if the job could not be updated
*/
public MeasurementCollectionJob updateMeasurementCollectionJobById(String mcjId, MeasurementCollectionJobMVO mcjMVO) throws IOException {
MeasurementCollectionJob measurementCollectionJob;
logger.debug("will update MeasurementCollectionJob with id "+ mcjId+" and \nMeasurementCollectionJob.toString():\n"+ toJsonString(mcjMVO));
try {
Map<String, Object> map = new HashMap<>();
map.put("mcjid", mcjId);
Object response = template.requestBodyAndHeaders(PM_MEASUREMENT_COLLECTION_JOB_UPDATE, toJsonString(mcjMVO), map);
logger.info("JsonUtil.toJsonString(mcjMVO): \n" + toJsonString(mcjMVO));
assert response instanceof String : "MeasurementCollectionJob object is wrong.";
measurementCollectionJob = toJsonObj((String) response, MeasurementCollectionJob.class);
logger.info("response from PM_MEASUREMENT_COLLECTION_JOB_UPDATE: " + response);
return measurementCollectionJob;
} catch (Exception e) {
e.printStackTrace();
logger.error("Cannot update MeasurementCollectionJob with id " + mcjId + ":\n" + e.toString());
}
return null;
}
......
...@@ -127,4 +127,5 @@ CRD_DELETE_CR_REQ: "jms:queue:CRD.DELETE.CR_REQ" ...@@ -127,4 +127,5 @@ CRD_DELETE_CR_REQ: "jms:queue:CRD.DELETE.CR_REQ"
CRD_PATCH_CR_REQ: "jms:queue:CRD.PATCH.CR_REQ" CRD_PATCH_CR_REQ: "jms:queue:CRD.PATCH.CR_REQ"
#TMF628 ACTIONS #TMF628 ACTIONS
PM_MEASUREMENT_COLLECTION_JOB_ADD: "jms:queue:PM.MEASUREMENTCOLLECTIONJOB.ADD" PM_MEASUREMENT_COLLECTION_JOB_ADD: "jms:queue:PM.MEASUREMENTCOLLECTIONJOB.ADD"
\ No newline at end of file PM_MEASUREMENT_COLLECTION_JOB_UPDATE: "jms:queue:PM.MEASUREMENTCOLLECTIONJOB.UPDATE"
\ No newline at end of file
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment