import org.onap.usecaseui.server.constant.Constant;\r
import org.onap.usecaseui.server.service.AlarmsHeaderService;\r
import org.onap.usecaseui.server.service.AlarmsInformationService;\r
-import org.onap.usecaseui.server.util.CSVUtils;\r
import org.onap.usecaseui.server.util.DateUtils;\r
import org.onap.usecaseui.server.util.Page;\r
import org.onap.usecaseui.server.util.ResponseUtil;\r
import org.onap.usecaseui.server.constant.Constant;
import org.onap.usecaseui.server.service.PerformanceHeaderService;
import org.onap.usecaseui.server.service.PerformanceInformationService;
-import org.onap.usecaseui.server.util.CSVUtils;
import org.onap.usecaseui.server.util.DateUtils;
import org.onap.usecaseui.server.util.Page;
import org.onap.usecaseui.server.util.ResponseUtil;
@PathVariable int pageSize,@PathVariable(required = false) String sourceId,
@PathVariable(required = false) String sourceName,@PathVariable(required = false) String priority,
@PathVariable(required = false) String startTime,@PathVariable(required = false) String endTime) throws JsonProcessingException {
- logger.info("transfer getAlarmData Apis, " +
- "Parameter all follows : [currentPage : {} , pageSize : {} , sourceId : {} , " +
- "sourceName : {} , priority : {} , startTime :{} , endTime : {} ]"
- ,currentPage,pageSize,sourceId,sourceName,priority,startTime,endTime);
+ logger.info("API Parameter: [currentPage:{}, pageSize:{}, sourceId:{}, sourceName:{}, priority:{}, startTime:{}, endTime:{}]" ,currentPage, pageSize, sourceId, sourceName, priority, startTime, endTime);
List<Object> list = new ArrayList<>();
- Page pa = null;
+ Page<PerformanceHeader> pa = new Page<PerformanceHeader>();
if (null != sourceId || null != sourceName || null != priority || null != startTime || null != endTime){
PerformanceHeader performanceHeader = new PerformanceHeader();
performanceHeader.setSourceId(!"null".equals(sourceId)?sourceId:null);
}
}
- @RequestMapping(value = {"/performance/genCsv/{eventId}"}, method = RequestMethod.GET, produces = "application/json")
- public String generateCsvFile(HttpServletResponse response, @PathVariable String[] eventId) throws JsonProcessingException {
- String csvFile = "csvFiles/vnf_performance_"+new SimpleDateFormat("yy-MM-ddHH:mm:ss").format(new Date())+".csv";
- List<PerformanceHeader> performanceHeaders = performanceHeaderService.queryId(eventId);
- if (null == performanceHeaders || performanceHeaders.size() <= 0)
- return new ObjectMapper().writeValueAsString("selected eventId don't exist");
- List<String[]> csvData = new ArrayList<>();
- performanceHeaders.forEach(s ->{
- List<PerformanceInformation> information = performanceInformationService.queryPerformanceInformation(new PerformanceInformation(s.getEventId()),1,100).getList();
- String names = "";
- String values = "";
- if (0 < information.size() && null != information){
- for (PerformanceInformation a : information){
- names += a.getName()+",";
- values += a.getValue()+",";
- }
- names = names.substring(0,names.lastIndexOf(','));
- values = values.substring(0,values.lastIndexOf(','));
- }
- csvData.add(new String[]{
- s.getVersion(),s.getEventName(),s.getDomain(),s.getEventId(),s.getEventType(),s.getNfcNamingCode(),s.getNfNamingCode(),
- s.getSourceId(),s.getSourceName(),s.getReportingEntityId(),s.getReportingEntityName(),s.getPriority(),
- s.getStartEpochMicrosec(),s.getLastEpochMicroSec(),s.getSequence(),s.getMeasurementsForVfScalingVersion(),
- s.getMeasurementInterval(),DateUtils.dateToString(s.getCreateTime()),DateUtils.dateToString(s.getUpdateTime()),
- names,values
- });
- });
- CSVUtils.writeCsv(PerformanceCSVHeaders,csvData,csvFile);
- if (ResponseUtil.responseDownload(csvFile,response)){
- return omPerformance.writeValueAsString("success");
- }else{
- return omPerformance.writeValueAsString("failed");
- }
- }
-
- @RequestMapping(value = {"/performance/genDiaCsv/{dataJson}"}, method = RequestMethod.GET, produces = "application/json")
- public String generateDiaCsvFile(HttpServletResponse response,@PathVariable String dataJson) throws IOException {
- List<Map<String,Object>> dataList = omPerformance.readValue(dataJson,List.class);
- String csvFileName = "csvFiles/"+dataList.get(0).get("name")+"_"+new SimpleDateFormat("yy-MM-ddHH:mm:ss").format(new Date())+".csv";
- try{
- String[] headers = new String[]{"eventId","name","dateUnit","value"};
- List<String[]> csvDatas = new ArrayList<>();
- if (null != dataList){
- dataList.forEach((l)->{
- StringBuffer fileData = new StringBuffer();
- l.forEach((k,v)->{
- logger.info(v.toString());
- fileData.append(v.toString()+",");
- });
- csvDatas.add(fileData.toString().split(","));
- });
- }
- CSVUtils.writeCsv(headers,csvDatas,csvFileName);
- }catch (Exception pe){
- logger.error(pe.getMessage());
- }
- if (ResponseUtil.responseDownload(csvFileName,response)){
- return omPerformance.writeValueAsString("success");
- }else{
- return omPerformance.writeValueAsString("failed");
- }
- }
-
@ResponseBody
@RequestMapping(value = {"/performance/diagram/{unit}/{eventId}"}, method = RequestMethod.GET, produces = "application/json")
public String generateDiagram(@PathVariable String unit,@PathVariable String eventId) throws ParseException, JsonProcessingException {
try(Session session = getSession()){\r
if (null == alarmsHeader) {\r
logger.error("AlarmsHeaderServiceImpl saveAlarmsHeader alarmsHeader is null!");\r
+ return "0";\r
}\r
logger.info("AlarmsHeaderServiceImpl saveAlarmsHeader: alarmsHeader={}", alarmsHeader);\r
Transaction tx = session.beginTransaction(); \r
try(Session session = getSession()){\r
if (null == alarmsHeader){\r
logger.error("AlarmsHeaderServiceImpl updateAlarmsHeader alarmsHeader is null!");\r
+ return "0";\r
}\r
logger.info("AlarmsHeaderServiceImpl updateAlarmsHeader: alarmsHeader={}", alarmsHeader);\r
Transaction tx = session.beginTransaction(); \r
StringBuffer count=new StringBuffer("select count(*) from AlarmsHeader a where 1=1");\r
if (null == alarmsHeader) {\r
logger.error("AlarmsHeaderServiceImpl getAllCount alarmsHeader is null!");\r
+ return -1;\r
}else {\r
if(null!=alarmsHeader.getVersion()) {\r
String ver=alarmsHeader.getVersion();\r
try(Session session = getSession()){\r
StringBuffer hql =new StringBuffer("from AlarmsHeader a where 1=1");\r
if (null == alarmsHeader) {\r
- //logger.error("AlarmsHeaderServiceImpl queryAlarmsHeader alarmsHeader is null!");\r
+ logger.error("AlarmsHeaderServiceImpl queryAlarmsHeader alarmsHeader is null!");\r
+ return null;\r
}else {\r
if(null!=alarmsHeader.getVersion()) {\r
String ver=alarmsHeader.getVersion();\r
@Override\r
public List<AlarmsHeader> queryId(String[] id) {\r
try(Session session = getSession()){\r
+ List<AlarmsHeader> list = new ArrayList<AlarmsHeader>();\r
if(id.length==0) {\r
logger.error("AlarmsHeaderServiceImpl queryId is null!");\r
+ return list;\r
}\r
- List<AlarmsHeader> list = new ArrayList<AlarmsHeader>();\r
Query query = session.createQuery("from AlarmsHeader a where a.eventName IN (:alist)");\r
list = query.setParameterList("alist", id).list();\r
return list;\r
try(Session session = getSession()){\r
if (null == performanceHeder){\r
logger.error("PerformanceHeaderServiceImpl savePerformanceHeader performanceHeder is null!");\r
+ return "0";\r
}\r
logger.info("PerformanceHeaderServiceImpl savePerformanceHeader: performanceHeder={}", performanceHeder);\r
Transaction tx = session.beginTransaction();\r
try(Session session = getSession()){\r
if (null == performanceHeder){\r
logger.error("PerformanceHeaderServiceImpl updatePerformanceHeader performanceHeder is null!");\r
+ return "0";\r
}\r
logger.info("PerformanceHeaderServiceImpl updatePerformanceHeader: performanceHeder={}", performanceHeder);\r
Transaction tx = session.beginTransaction();\r
StringBuffer hql = new StringBuffer("select count(*) from PerformanceHeader a where 1=1");\r
if (null == performanceHeder) {\r
logger.error("PerformanceHeaderServiceImpl getAllCount performanceHeder is null!");\r
+ return 0;\r
}else {\r
if(null!=performanceHeder.getVersion()) {\r
String ver=performanceHeder.getVersion();\r
try(Session session = getSession()){\r
StringBuffer hql =new StringBuffer("from PerformanceHeader a where 1=1");\r
if (null == performanceHeder) {\r
- //logger.error("PerformanceHeaderServiceImpl queryPerformanceHeader performanceHeder is null!");\r
+ logger.error("PerformanceHeaderServiceImpl queryPerformanceHeader performanceHeder is null!");\r
+ return page;\r
}else {\r
if(null!=performanceHeder.getVersion()) {\r
String ver=performanceHeder.getVersion();\r
@Override\r
public List<PerformanceHeader> queryId(String[] id) {\r
try(Session session = getSession()) {\r
+ List<PerformanceHeader> list = new ArrayList<PerformanceHeader>();\r
if(id.length==0) {\r
logger.error("PerformanceHeaderServiceImpl queryId is null!");\r
+ return list;\r
}\r
- List<PerformanceHeader> list = new ArrayList<PerformanceHeader>();\r
Query query = session.createQuery("from PerformanceHeader a where a.eventName IN (:alist)");\r
list = query.setParameterList("alist", id).list();\r
return list;\r
+++ /dev/null
-/*
- * Copyright (C) 2017 CMCC, Inc. and others. All rights reserved.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.onap.usecaseui.server.util;
-
-import org.apache.commons.csv.CSVFormat;
-import org.apache.commons.csv.CSVParser;
-import org.apache.commons.csv.CSVPrinter;
-import org.apache.commons.csv.CSVRecord;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-import java.io.*;
-import java.util.List;
-
-
-public class CSVUtils {
-
- private static Logger logger = LoggerFactory.getLogger(CSVUtils.class);
-
- public static void writeCsv(String[] headers,List<String[]> data,String filePath) {
- try{
- CSVFormat formator = CSVFormat.DEFAULT.withHeader(headers);
- String dir = filePath.substring(0,filePath.lastIndexOf('/'));
- File file = new File(dir);
- if (!file.exists())
- file.mkdirs();
- try(Writer writer = new FileWriter(filePath);
- CSVPrinter printer = new CSVPrinter(writer,formator)){
- for(String[] str : data){
- printer.printRecord(str);
- }
- }
-
- logger.info("CSV File Generate Success,FilePath:"+filePath);
- }catch (IOException e){
- logger.error("CSV File Generate Failure:"+e.getMessage());
- }
- }
-
-
- public static boolean wCsv(){
-
- return false;
- }
-
- public static List<CSVRecord> readCSV(String filePath, String[] headers) throws IOException{
- //创建CSVFormat
- CSVFormat formator = CSVFormat.DEFAULT.withHeader(headers);
- FileReader fileReader=new FileReader(filePath);
- //创建CSVParser对象
- CSVParser parser=new CSVParser(fileReader,formator);
- List<CSVRecord> records=parser.getRecords();
- parser.close();
- fileReader.close();
- return records;
- }
-
-}
subscribe(performanceTopic);
}
} catch (Exception e) {
- try {
- Thread.sleep(10000);
- } catch (InterruptedException e1) {
- e1.printStackTrace();
- }
logger.error("subscribe raise error :" + e.getCause());
}
}
+++ /dev/null
-/*
- * Copyright (C) 2017 CMCC, Inc. and others. All rights reserved.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.onap.usecaseui.server.util;
-
-import org.junit.Test;
-import org.junit.runner.RunWith;
-import org.springframework.boot.test.context.SpringBootTest;
-import org.springframework.test.context.junit4.SpringRunner;
-
-import java.io.IOException;
-import java.util.ArrayList;
-import java.util.List;
-
-public class CSVUtilsTest {
-
- @Test
- public void CSVTest(){
- String[] headers = new String[]{"name","age","birthday"};
- List<String[]> data = new ArrayList<>();
- data.add(new String[]{"Tom","15","2001-1-12"});
- data.add(new String[]{"Jerry","18","2005-1-12"});
- data.add(new String[]{"John","20","2011-1-12"});
- String csvPath = "csvFiles/data.csv";
- CSVUtils.writeCsv(headers,data,csvPath);
- }
-
- @Test
- public void CSVRead(){
- String[] headers = new String[]{"name","age","birthday"};
- String csvPath = "csvFiles/data.csv";
- try {
- CSVUtils.readCSV(csvPath,headers);
- } catch (IOException e) {
- e.printStackTrace();
- }
- }
-}
Code Review / usecase-ui / server.git / commitdiff