import java.util.*;
import javax.annotation.Resource;
+import com.alibaba.fastjson.JSONArray;
import org.apache.commons.collections.MapUtils;
import org.onap.usecaseui.server.bean.HttpResponseResult;
import org.onap.usecaseui.server.bean.intent.IntentInstance;
public class IntentController {
private final Logger logger = LoggerFactory.getLogger(IntentController.class);
private final static String UPLOADPATH = "/home/uui/upload/";
- private final static String NLPLOADPATH = "/home/run/bert-master/upload/";
+ private final static String NLPLOADPATH = "/home/uuihome/uui/bert-master/upload/";
+ private final static String[] QUESTIONS_CCVPN = {"bandwidth", "access point", "cloud point"};
+ private final static String[] QUESTIONS_5GS = {"Communication Service Name", "Max Number of UEs", "Data Rate Downlink", "Latency", "Data Rate Uplink", "Resource Sharing Level", "Mobility", "Area"};
+
+ private final static String MODEL_TYPE_CCVPN = "ccvpn";
+ private final static String MODEL_TYPE_5GS = "5gs";
+
@Resource(name = "IntentService")
private IntentService intentService;
if (modelType == null || !modelType.equals(activeModelType)) {
throw new RuntimeException("The active model file does not support parsing the current text");
}
+ String[] questions = getQuestions(modelType);
String url = "http://uui-nlp:33011/api/online/predict";
HashMap<String, String> headers = new HashMap<>();
String bodyStr = "{\"title\": \"predict\", \"text\": \"" + text
- + "\"}";
+ + "\", \"questions\":" + new JSONArray(Arrays.asList(questions)).toJSONString() + "}";
logger.info("request body: " + bodyStr);
HttpResponseResult result = HttpUtil.sendPostRequestByJson(url, headers, bodyStr);
JSONObject map2 = new JSONObject();
- for (Map.Entry<String, Object> entry:map.entrySet()) {
- logger.debug(entry.getKey()+","+entry.getValue());
- String key = tranlateFieldName(entry.getKey());
- String valueStr = (String) entry.getValue();
- String value = intentService.calcFieldValue(key, valueStr);
- map2.put(key, value);
+ if (MODEL_TYPE_CCVPN.equals(modelType)) {
+
+ String bandWidth = map.getString("bandwidth");
+ String accessPoint = map.getString("access point");
+ String cloudPoint = map.getString("cloud point");
+ String instanceId = getUUID();
+ String accessPointAlias = intentInstanceService.formatAccessPoint(accessPoint);
+ String bandwidthAlias = intentInstanceService.formatBandwidth(bandWidth);
+ String cloudPointAlias = intentInstanceService.formatCloudPoint(cloudPoint);
+
+ Map<String, Object> accessPointOne = new HashMap<>();
+ accessPointOne.put("name", accessPointAlias);
+ accessPointOne.put("bandwidth", bandwidthAlias);
+ map2.put("name", "");
+ map2.put("instanceId", instanceId);
+ map2.put("accessPointOne", accessPointOne);
+ map2.put("cloudPointName", cloudPointAlias);
+ }
+ else {
+ for (Map.Entry<String, Object> entry:map.entrySet()) {
+ logger.debug(entry.getKey()+","+entry.getValue());
+ String key = tranlateFieldName(entry.getKey());
+ String valueStr = (String) entry.getValue();
+ String value = intentService.calcFieldValue(key, valueStr);
+ map2.put(key, value);
+ }
}
logger.info("translate result: " + map2.toJSONString());
return map2.toJSONString();
}
+ private String[] getQuestions(String modelType) {
+ if (MODEL_TYPE_CCVPN.equals(modelType)) {
+ return QUESTIONS_CCVPN;
+ } else {
+ return QUESTIONS_5GS;
+ }
+ }
private static String tranlateFieldName(String key){
return ret;
HashMap<String, String> map = new HashMap<>();
- map.put("Communication service","name");
- map.put("Maximum user devices","maxNumberofUEs");
- map.put("Downlink data rate","expDataRateDL");
- map.put("Time delay","latency");
- map.put("Uplink data rate","expDataRateUL");
- map.put("Resource","resourceSharingLevel");
+ map.put("Communication Service Name","name");
+ map.put("Max Number of UEs","maxNumberofUEs");
+ map.put("Data Rate Downlink","expDataRateDL");
+ map.put("Latency","latency");
+ map.put("Data Rate Uplink","expDataRateUL");
+ map.put("Resource Sharing Level","resourceSharingLevel");
map.put("Mobility","uEMobilityLevel");
- map.put("Region","coverageArea");
+ map.put("Area","coverageArea");
ret = map.get(key.trim());
return ret;
@GetMapping(value = {"/getInstanceId"},
produces = "application/json")
public JSONObject getInstanceId() {
+ String instanceId = getUUID();
+ JSONObject result = new JSONObject();
+ result.put("instanceId", instanceId);
+ return result;
+ }
+
+ private String getUUID() {
int first = new Random(10).nextInt(8) + 1;
int hashCodeV = UUID.randomUUID().toString().hashCode();
- if (hashCodeV < 0) {//有可能是负数
+ if (hashCodeV < 0) {
hashCodeV = -hashCodeV;
}
String instanceId = first + String.format("%015d", hashCodeV);
- JSONObject result = new JSONObject();
- result.put("instanceId", instanceId);
- return result;
+ return instanceId;
}
+
@IntentResponseBody
@ResponseBody
@PostMapping (value = {"/getInstanceList"},consumes = MediaType.APPLICATION_JSON_VALUE,
intentInstance.setCloudPointName(cloudPointName);
intentInstance.setAccessPointOneName(accessPointOneName);
intentInstance.setAccessPointOneBandWidth(accessPointOneBandWidth);
+ intentInstance.setStatus("0");
int flag = intentInstanceService.createIntentInstance(intentInstance);
}
@IntentResponseBody
- @ResponseBody
- @PostMapping(value = {"/deleteIntentInstance"}, consumes = MediaType.APPLICATION_JSON_VALUE,
- produces = "application/json; charset=utf-8")
- public Object deleteIntentInstance(@RequestBody Object body) {
- String instanceId= (String) ((Map)body).get("instanceId");
+ @DeleteMapping(value = {"/deleteIntentInstance"}, produces = "application/json; charset=utf-8")
+ public Object deleteIntentInstance(@RequestParam String instanceId) {
intentInstanceService.deleteIntentInstance(instanceId);
return "ok";
}
public Object queryAccessNodeInfo() throws IOException{
return intentInstanceService.queryAccessNodeInfo();
}
+
+
+ @IntentResponseBody
+ @ResponseBody
+ @PostMapping(value = {"/getInstanceStatus"}, consumes = MediaType.APPLICATION_JSON_VALUE,
+ produces = "application/json; charset=utf-8")
+ public Object getInstanceStatus(@RequestBody Object body) {
+ JSONArray ids= new JSONObject((Map)body).getJSONArray("ids");
+ return intentInstanceService.getInstanceStatus(ids);
+ }
}
import java.io.IOException;
import java.text.SimpleDateFormat;
import java.util.*;
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
@Service("IntentInstanceService")
@Transactional
private SOService soService;
+ private final static int MAX_BANDWIDTH = 6000;
+ private final static int MIN_BANDWIDTH = 100;
+
+ private final static List<String> GB_COMPANY = Arrays.asList(new String[] {"gbps", "gb"});
+ private final static List<String> MB_COMPANY = Arrays.asList(new String[] {"mbps", "mb"});
+
public IntentInstanceServiceImpl() {
this(RestfulServices.create(IntentApiService.class),RestfulServices.create(SOService.class));
}
} catch (Exception e) {
logger.error("exception occurred while performing AlarmsHeaderServiceImpl queryAlarmsHeader. Details:" + e.getMessage());
return null;
+ } finally {
+ session.close();
}
}
} catch (Exception e) {
logger.error("exception occurred while performing IntentInstanceServiceImpl getAllCount. Details:" + e.getMessage());
return -1;
+ } finally {
+ session.close();
}
}
@Override
public int createIntentInstance(IntentInstance intentInstance) {
+ Session session = getSession();
+ Transaction tx = null;
try{
if (null == intentInstance){
return 0;
}
String jobId = createIntentInstanceToSO(intentInstance);
+ if (null == jobId){
+ logger.error("create Instance error：jobId is null");
+ return 0;
+ }
intentInstance.setJobId(jobId);
intentInstance.setResourceInstanceId("cll-"+intentInstance.getInstanceId());
- Session session = getSession();
- Transaction tx = session.beginTransaction();
+
+ tx = session.beginTransaction();
session.save(intentInstance);
tx.commit();
-// session.flush();
return 1;
} catch (Exception e) {
+ if (tx != null) {
+ tx.rollback();
+ }
logger.error("Details:" + e.getMessage());
return 0;
+ } finally {
+ session.close();
}
}
if (progress >=100) {
instance.setStatus("1");
}
- instance.setProgress(progress);
+ }
+ catch (Exception e) {
+ logger.info("get progress exception:"+e);
+ }
+ }
+ saveProgress(instanceList);
+
+ }
+ @Override
+ public void getIntentInstanceCreateStatus() {
+ List<IntentInstance> instanceList = getInstanceByFinishedFlag("0");
+ for (IntentInstance instance: instanceList) {
+ try {
+
+ int flag = getCreateStatusByJobId(instance);
+ if (flag > 0) {
+ instance.setStatus(flag + "");
+ }
}
catch (Exception e) {
logger.info("get progress exception:"+e);
}
private void saveProgress(List<IntentInstance> instanceList) {
- Transaction tx = null;
if(instanceList == null || instanceList.isEmpty()) {
return;
}
- try(Session session = getSession()) {
+ Session session = getSession();
+ Transaction tx = null;
+ try {
tx = session.beginTransaction();
for (IntentInstance instance : instanceList) {
- session.save(instance);
+ session.update(instance);
+ session.flush();
}
tx.commit();
logger.info("update progress ok");
}
logger.error("update progress exception:"+e);
+ } finally {
+ session.close();
}
}
private int getProgressByJobId(IntentInstance instance) throws IOException {
Response<OperationProgressInformation> response = soService.queryOperationProgress(instance.getResourceInstanceId(), instance.getJobId()).execute();
- return response.body().getOperationStatus().getProgress();
+ logger.debug(response.toString());
+ if (response.isSuccessful()) {
+ return response.body().getOperationStatus().getProgress();
+ }
+ return -1;
+ }
+
+ private int getCreateStatusByJobId(IntentInstance instance) throws IOException {
+ if (instance == null || instance.getResourceInstanceId() == null) {
+ return -1;
+ }
+ Response<JSONObject> response = intentApiService.getInstanceInfo(instance.getResourceInstanceId()).execute();
+ logger.debug(response.toString());
+ if (response.isSuccessful()) {
+ String status = response.body().getString("orchestration-status");
+ if ("created".equals(status)) {
+ return 1;
+ }
+ return 0;
+ }
+ logger.error("getIntentInstance Create Statue Error:" + response.toString());
+ return -1;
}
private List<IntentInstance> getInstanceByFinishedFlag(String flag) {
} catch (Exception e) {
logger.error("exception occurred while performing IntentInstanceServiceImpl getNotFinishedJobId. Details:" + e.getMessage());
return null;
+ } finally {
+ session.close();
}
}
} catch (Exception e) {
logger.error("exception occurred while performing IntentInstanceServiceImpl getNotFinishedJobId. Details:" + e.getMessage());
return null;
+ } finally {
+ session.close();
}
}
for (IntentInstance instance : instanceList) {
String serviceInstanceId = instance.getResourceInstanceId();
Response<JSONObject> response = intentApiService.getInstanceNetworkInfo(serviceInstanceId).execute();
+ if (!response.isSuccessful()) {
+ logger.error("get Intent-Instance Bandwidth error:" + response.toString());
+ continue;
+ }
JSONObject responseBody = response.body();
JSONObject allottedResource = responseBody.getJSONObject("allotted-resources").getJSONArray("allotted-resource").getJSONObject(0);
JSONArray relationshipList = allottedResource.getJSONObject("relationship-list").getJSONArray("relationship");
logger.error("get network Policy Id exception. serviceInstanceId:" + instance.getResourceInstanceId());
continue;
}
- JSONObject networkPolicyInfo = intentApiService.getInstanceNetworkPolicyInfo(networkPolicyId).execute().body();
- String maxBandwidth = networkPolicyInfo.getString("max-bandwidth");
+
+ Response<JSONObject> networkPolicyInfoResponse = intentApiService.getInstanceNetworkPolicyInfo(networkPolicyId).execute();
+ if (!networkPolicyInfoResponse.isSuccessful()) {
+ logger.error("get Intent-Instance networkPolicyInfo error:" + networkPolicyInfoResponse.toString());
+ continue;
+ }
+ JSONObject networkPolicyInfo = networkPolicyInfoResponse.body();
+ int maxBandwidth = networkPolicyInfo.getIntValue("max-bandwidth");
InstancePerformance instancePerformance = new InstancePerformance();
instancePerformance.setMaxBandwidth(maxBandwidth);
instancePerformance.setResourceInstanceId(instance.getResourceInstanceId());
instancePerformance.setJobId(instance.getJobId());
instancePerformance.setDate(new Date());
- JSONObject metadatum = intentApiService.getInstanceBandwidth(serviceInstanceId).execute().body();
- String metaval = metadatum.getJSONArray("metadatum").getJSONObject(0).getString("metaval");
+ Response<JSONObject> metadatumResponse = intentApiService.getInstanceBandwidth(serviceInstanceId).execute();
+ if (!metadatumResponse.isSuccessful()) {
+ logger.error("get Intent-Instance metadatum error:" + metadatumResponse.toString());
+ continue;
+ }
+ JSONObject metadatum = metadatumResponse.body();
+ int metaval = metadatum.getJSONArray("metadatum").getJSONObject(0).getIntValue("metaval");
instancePerformance.setBandwidth(metaval);
+ Session session = getSession();
+ Transaction tx = null;
try{
- Session session = getSession();
- Transaction tx = session.beginTransaction();
+ tx = session.beginTransaction();
session.save(instancePerformance);
tx.commit();
} catch (Exception e) {
+ if(tx!=null){
+ tx.rollback();
+ }
logger.error("Details:" + e.getMessage());
+ } finally {
+ session.close();
}
@Override
public void deleteIntentInstance(String instanceId) {
IntentInstance result = null;
-
- try(Session session = getSession()) {
+ Session session = getSession();
+ try {
result = (IntentInstance)session.createQuery("from IntentInstance where deleteState = 0 and instanceId = :instanceId")
.setParameter("instanceId", instanceId).uniqueResult();
} catch (Exception e) {
logger.error("getodel occur exception:"+e);
+ } finally {
+ session.close();
}
try {
String serviceInstanceId = result.getResourceInstanceId();
deleteInstanceToSO(serviceInstanceId);
- deleteInstance(serviceInstanceId);
+ deleteInstance(result);
}catch (Exception e) {
logger.error("delete instance to SO error :" + e);
}
okhttp3.RequestBody requestBody = okhttp3.RequestBody.create(okhttp3.MediaType.parse("application/json"), JSON.toJSONString(params));
intentApiService.deleteIntentInstance(requestBody).execute();
}
- private String deleteInstance(String serviceInstanceId) {
+ private String deleteInstance(IntentInstance instance) {
Transaction tx = null;
String result="0";
- if(serviceInstanceId==null || serviceInstanceId.trim().equals(""))
- return result;
-
- try(Session session = getSession()) {
+ Session session = getSession();
+ try {
tx = session.beginTransaction();
- IntentInstance instance = new IntentInstance();
- instance.setInstanceId(serviceInstanceId);
session.delete(instance);
tx.commit();
- logger.info("delete instance OK, id=" + serviceInstanceId);
+ logger.info("delete instance OK, id=" + instance.getInstanceId());
result="1";
} catch (Exception e) {
}
logger.error("delete instance occur exception:"+e);
+ } finally {
+ session.close();
}
return result;
}
@Override
public void activeIntentInstance(String instanceId) {
IntentInstance instance = null;
-
- try(Session session = getSession()) {
+ Session session = getSession();
+ Transaction tx = null;
+ try {
instance = (IntentInstance)session.createQuery("from IntentInstance where deleteState = 0 and instanceId = :instanceId and status = :status")
.setParameter("instanceId", instanceId).setParameter("status", "3").uniqueResult();
logger.info("get instance OK, id=" + instanceId);
- } catch (Exception e) {
- logger.error("getodel occur exception:"+e);
+ if (null == instance) {
+ logger.error("intentInstance is null!");
+ return;
+ }
- }
- if (null == instance) {
- logger.error("intentInstance is null!");
- return;
- }
- try {
String jobId = createIntentInstanceToSO(instance);
instance.setStatus("0");
instance.setJobId(jobId);
- Session session = getSession();
- Transaction tx = session.beginTransaction();
+ tx = session.beginTransaction();
session.save(instance);
tx.commit();
}catch (Exception e) {
+ if(tx!=null){
+ tx.rollback();
+ }
logger.error("active instance to SO error :" + e);
+ } finally {
+ session.close();
}
}
public void invalidIntentInstance(String instanceId) {
IntentInstance instance = null;
-
- try(Session session = getSession()) {
+ Session session = getSession();
+ Transaction tx = null;
+ try {
instance = (IntentInstance)session.createQuery("from IntentInstance where deleteState = 0 and instanceId = :instanceId")
.setParameter("instanceId", instanceId).uniqueResult();
logger.info("get instance OK, id=" + instanceId);
- } catch (Exception e) {
- logger.error("get instance occur exception:"+e);
-
- }
- if (null == instance) {
- logger.error("intentInstance is null!");
- return;
- }
- try {
+ if (null == instance) {
+ logger.error("intentInstance is null!");
+ return;
+ }
deleteInstanceToSO(instance.getInstanceId());
instance.setStatus("3");
- Session session = getSession();
- Transaction tx = session.beginTransaction();
+ tx = session.beginTransaction();
session.save(instance);
+ session.flush();
tx.commit();
}catch (Exception e) {
+ if(tx!=null){
+ tx.rollback();
+ }
logger.error("invalid instance to SO error :" + e);
+ } finally {
+ session.close();
}
}
@Override
public Map<String, Object> queryInstancePerformanceData(String instanceId) {
- try(Session session = getSession()) {
+ Session session = getSession();
+ try {
String hql = "from IntentInstance i, InstancePerformance p where i.resourceInstanceId = p.resourceInstanceId and i.instanceId = :instanceId and i.deleteState = 0 order by p.date";
Query query = session.createQuery(hql).setParameter("instanceId", instanceId);
List<Object[]> queryResult= query.list();
List<String> date = new ArrayList<>();
- List<String> bandwidth = new ArrayList<>();
- List<String> maxBandwidth = new ArrayList<>();
- SimpleDateFormat ft = new SimpleDateFormat("yyyy-MM-dd");
- for (Object[] o : queryResult) {
+ List<Integer> bandwidth = new ArrayList<>();
+ List<Integer> maxBandwidth = new ArrayList<>();
+ SimpleDateFormat ft = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+ for (int i = queryResult.size() > 50? queryResult.size() - 50 : 0; i < queryResult.size(); i++) {
+ Object[] o = queryResult.get(i);
InstancePerformance performance = (InstancePerformance) o[1];
date.add(ft.format(performance.getDate()));
bandwidth.add(performance.getBandwidth());
}catch (Exception e) {
logger.error("invalid instance to SO error :" + e);
throw e;
+ } finally {
+ session.close();
}
}
List<String> accessNodeList = new ArrayList<>();
List<String> cloudAccessNodeList = new ArrayList<>();
Response<JSONObject> response = intentApiService.queryNetworkRoute().execute();
+ if (!response.isSuccessful()) {
+ logger.error(response.toString());
+ throw new RuntimeException("Query Access Node Info Error");
+ }
JSONObject body = response.body();
JSONArray data = body.getJSONArray("network-route");
for (int i = 0; i<data.size(); i++) {
result.put("cloudAccessNodeList",cloudAccessNodeList);
return result;
}
+
+ @Override
+ public JSONObject getInstanceStatus(JSONArray ids) {
+ Session session = getSession();
+ try {
+ JSONObject result = new JSONObject();
+ JSONArray instanceInfos = new JSONArray();
+ String hql = "from IntentInstance i where i.instanceId in (:ids)";
+ Query query = session.createQuery(hql).setParameter("ids", ids);
+ List<IntentInstance> queryResult= query.list();
+ if (queryResult != null && queryResult.size() > 0) {
+ for (IntentInstance instance : queryResult) {
+ JSONObject instanceInfo = new JSONObject();
+ instanceInfo.put("id", instance.getInstanceId());
+ instanceInfo.put("status", instance.getStatus());
+ instanceInfos.add(instanceInfo);
+ }
+ }
+ result.put("IntentInstances",instanceInfos);
+ return result;
+
+ } catch (Exception e) {
+ logger.error("get Instance status error : " + e.getMessage());
+ throw e;
+ } finally {
+ session.close();
+ }
+ }
+
+
+ public String formatBandwidth(String strValue) {
+ String ret;
+ Pattern pattern = Pattern.compile("(\\d+)([\\w ]*)");
+ Matcher matcher = pattern.matcher(strValue);
+
+
+ int dataRate = 100;
+ if (matcher.matches()) {
+ dataRate = Integer.parseInt(matcher.group(1));
+ String company = matcher.group(2).trim().toLowerCase();
+ if (GB_COMPANY.contains(company)) {
+ dataRate = dataRate * 1000;
+ }
+ else if (!MB_COMPANY.contains(company)) {
+ dataRate = 100;
+ }
+ dataRate = dataRate < MIN_BANDWIDTH ? MIN_BANDWIDTH : (dataRate > MAX_BANDWIDTH ? MAX_BANDWIDTH : dataRate);
+ }
+ ret = dataRate + "";
+ return ret;
+ }
+
+
+ public String formatCloudPoint(String cloudPoint) {
+ String cloudPointAlias = "";
+ switch (cloudPoint) {
+ case "Cloud one" :
+ cloudPointAlias = "tranportEp_dst_ID_212_1";
+ break;
+ }
+ return cloudPointAlias;
+ }
+
+ public String formatAccessPoint(String accessPoint) {
+ String accessPointAlias = "";
+ switch (accessPoint) {
+ case "Access one" :
+ accessPointAlias = "tranportEp_src_ID_111_1";
+ break;
+ case "Access two" :
+ accessPointAlias = "tranportEp_src_ID_111_2";
+ break;
+ case "Access three" :
+ accessPointAlias = "tranportEp_src_ID_113_1";
+ break;
+ }
+ return accessPointAlias;
+ }
}
Code Review / usecase-ui / server.git / commitdiff