--- /dev/null
+
+# Copyright 2017 BOCO Corporation. CMCC Technologies Co., Ltd
+#
+# 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.
+#
+
+ftp_ip = 192.168.6.48
+ftp_port = 21
+ftp_user = gcp
+ftp_password = gcp
+ftp_remote_path = /opt/Gcp/
+ftp_passive = true
+ftp_type = ftp
+
+#
+msbAddress=10.74.205.123:80
+esr_ems_listUrl=/aai/v11/external-system/esr-ems-list
+esr_emsUrl=/aai/v11/external-system/esr-ems-list/esr-ems/%s?depth=all
+alarmUrl=/alarm
+
+
+#north
+event_api_url=http://127.0.0.1
+port=30000
+path=/vendor_event_listener
+topic=/example_vnf
+username=pill
+password=will
+level=debug
--- /dev/null
+<?xml version='1.0' encoding='GBK'?>
+<!--
+
+ Copyright 2017 BOCO Corporation. CMCCTechnologiesCo.,Ltd
+
+ 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.
+
+
+-->
+<scheduler>
+ <crontab type ="ems-resource" crontab="0 0/15 * * * ?">
+ <match>*</match>
+ <granularity>15</granularity>
+ </crontab>
+ <crontab type ="ems-performance" crontab="">
+ <match>*</match>
+ <granularity>15</granularity>
+ </crontab>
+ <crontab type ="ems-alarm" iscollect = "false">
+ <readtimeout>6</readtimeout>;
+ </crontab>
+</scheduler>
\ No newline at end of file
+
<!--
Copyright (c) 2017, CMCC Technologies Co., Ltd.
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
- <parent>
- <groupId>org.onap.vfc.nfvo.driver.ems.ems</groupId>
- <artifactId>ems-driver-boco-parent</artifactId>
- <version>1.0.0-SNAPSHOT</version>
- </parent>
-
+ <groupId>org.onap.vfc.nfvo.driver.ems.ems</groupId>
<modelVersion>4.0.0</modelVersion>
<artifactId>boco-driver</artifactId>
<version>1.0.0-SNAPSHOT</version>
<artifactId>swagger-jersey2-jaxrs</artifactId>
<version>${swagger.version}</version>
</dependency>
+ <dependency>
+ <groupId>dependencies-all</groupId>
+ <artifactId>test</artifactId>
+ <version>3.0</version>
+ <scope>system</scope>
+ <systemPath>${basedir}/lib/dependencies-all.jar</systemPath>
+ </dependency>
+
+ <dependency>
+ <groupId>VESLibrary</groupId>
+ <artifactId>test</artifactId>
+ <version>3.0</version>
+ <scope>system</scope>
+ <systemPath>${basedir}/lib/VESLibrary.jar</systemPath>
+ </dependency>
</dependencies>
</project>
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
+import java.util.HashMap;
+import java.util.Hashtable;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Properties;
import org.onap.vfc.nfvo.emsdriver.commons.ftp.AFtpRemoteFile;
import org.onap.vfc.nfvo.emsdriver.commons.ftp.FTPInterface;
import org.onap.vfc.nfvo.emsdriver.commons.ftp.FTPSrv;
-import org.onap.vfc.nfvo.emsdriver.commons.ftp.SFTPSrv;
import org.onap.vfc.nfvo.emsdriver.commons.model.CollectMsg;
import org.onap.vfc.nfvo.emsdriver.commons.model.CollectVo;
+import org.onap.vfc.nfvo.emsdriver.commons.utils.DateUtil;
import org.onap.vfc.nfvo.emsdriver.commons.utils.Gunzip;
import org.onap.vfc.nfvo.emsdriver.commons.utils.StringUtil;
import org.onap.vfc.nfvo.emsdriver.commons.utils.UnZip;
+import org.onap.vfc.nfvo.emsdriver.commons.utils.VarExprParser;
import org.onap.vfc.nfvo.emsdriver.commons.utils.Zip;
import org.onap.vfc.nfvo.emsdriver.configmgr.ConfigurationImp;
import org.onap.vfc.nfvo.emsdriver.configmgr.ConfigurationInterface;
public Log log = LogFactory.getLog(TaskThread.class);
- private MessageChannel collectResultChannel;
+ private MessageChannel cmResultChannel;
+ private MessageChannel pmResultChannel;
private CollectMsg data;
private SimpleDateFormat dateFormat2 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
- private String csvpathAndFileName;
- private String xmlPathAndFileName;
- private int countNum = 0 ;
+// private String csvpathAndFileName;
+// private String xmlPathAndFileName;
+// private int countNum = 0 ;
public TaskThread(CollectMsg data) {
this.data = data;
@Override
public void run(){
- collectResultChannel = MessageChannelFactory.getMessageChannel(Constant.COLLECT_RESULT_CHANNEL_KEY);
-
+ cmResultChannel = MessageChannelFactory.getMessageChannel(Constant.COLLECT_RESULT_CHANNEL_KEY);
+ pmResultChannel = MessageChannelFactory.getMessageChannel(Constant.COLLECT_CHANNEL_KEY);
try {
collectMsgHandle(data);
} catch (Exception e) {
continue;
String nename = ma.group(1);
boolean parseResult = false;
- if("CM".equalsIgnoreCase(collectVo.getType())){
+ if("ems-resource".equalsIgnoreCase(collectVo.getType())){
parseResult = processCMXml(tempfile, nename,"CM");
}else{
- parseResult = processPMCsv(tempfile, nename,"PM");
-
- //createzipFile
- String[] fileKeys = this.createZipFile(csvpathAndFileName,xmlPathAndFileName,nename);
- //ftp store
- Properties ftpPro = configurationInterface.getProperties();
- String ip = ftpPro.getProperty("ftp_ip");
- String port = ftpPro.getProperty("ftp_port");
- String ftp_user = ftpPro.getProperty("ftp_user");
- String ftp_password = ftpPro.getProperty("ftp_password");
-
- String ftp_passive = ftpPro.getProperty("ftp_passive");
- String ftp_type = ftpPro.getProperty("ftp_type");
- String remoteFile = ftpPro.getProperty("ftp_remote_path");
- this.ftpStore(fileKeys,ip,port,ftp_user,ftp_password,ftp_passive,ftp_type,remoteFile);
- //create Message
- String message = this.createMessage(fileKeys[1], ftp_user, ftp_password, ip, port, countNum,nename);
+ parseResult = processPMCsv(tempfile);
- //set message
- this.setMessage(message);
}
if (parseResult){
}
}
- public boolean processPMCsv(File tempfile, String nename,String type) {
-
- String csvpath = localPath+nename+"/"+type+"/";
- File csvpathfile = new File(csvpath);
- if(!csvpathfile.exists()){
- csvpathfile.mkdirs();
- }
- String csvFileName = nename +dateFormat.format(new Date())+ System.nanoTime();
- csvpathAndFileName = csvpath+csvFileName+".csv";
- BufferedOutputStream bos = null;
- FileOutputStream fos = null;
- try {
- fos = new FileOutputStream(csvpathAndFileName,false);
- bos = new BufferedOutputStream(fos, 10240);
- } catch (FileNotFoundException e1) {
- log.error("FileNotFoundException "+StringUtil.getStackTrace(e1));
- }
+ public boolean processPMCsv(File tempfile) {
FileInputStream brs = null;
InputStreamReader isr = null;
columnNames.add(name);
}
- xmlPathAndFileName = this.setColumnNames(nename, columnNames,type);
+// xmlPathAndFileName = this.setColumnNames(nename, columnNames,type);
String valueLine = "";
List<String> valuelist = new ArrayList<String>();
if (valueLine.trim().equals("")) {
continue;
}
- countNum ++;
+// countNum ++;
String [] values = valueLine.split("\\|",-1);
valuelist.addAll(commonValues);
for(String value : values){
valuelist.add(value);
}
- this.appendLine(valuelist, bos);
-
+// this.appendLine(valuelist, bos);
+ //resultMap
+ HashMap<String,String> resultMap = this.resultMap(columnNames,valuelist);
+ try {
+ pmResultChannel.put(resultMap);
+ } catch (InterruptedException e) {
+ log.error("collectResultChannel.put(resultMap) error ",e);
+ }
valuelist.clear();
}
} catch (IOException e) {
isr.close();
if (brs != null)
brs.close();
- if(bos != null){
- bos.close();
- }
- if(fos != null){
- fos.close();
- }
+
} catch (Exception e){
log.error(e);
}
}
+ private HashMap<String,String> resultMap(List<String> columnNames, List<String> valuelist) {
+
+ HashMap<String,String> resultMap = new HashMap<String,String>();
+ if(columnNames.size() == valuelist.size()){
+ for(int i =0;i<columnNames.size();i++){
+ resultMap.put(columnNames.get(i), valuelist.get(i));
+ }
+ }
+
+ return resultMap;
+
+ }
private boolean processCMXml(File tempfile, String nename, String type) {
String csvpath = localPath+nename+"/"+type+"/";
private void setMessage(String message) {
try {
- collectResultChannel.put(message);
+ cmResultChannel.put(message);
} catch (Exception e) {
log.error("collectResultChannel.put(message) is error "+StringUtil.getStackTrace(e));
}
FTPInterface ftpClient;
- if("ftp".equalsIgnoreCase(ftp_type)){
- ftpClient = new FTPSrv();
- }else{
- ftpClient = new SFTPSrv();
- }
-
+ ftpClient = new FTPSrv();
//login
try {
ftpClient.login(ip, Integer.parseInt(port), ftp_user, ftp_password, "GBK", Boolean.parseBoolean(ftp_passive), 5*60*1000);
log.error("login fail,ip=["+ip+"] port=["+port+"] user=["+ftp_user+"]pwd=["+ftp_password+"]"+StringUtil.getStackTrace(e));
return;
}
- ftpClient.store(zipFilePath, remoteFile);
+// ftpClient.store(zipFilePath, remoteFile);
log.debug("store ["+zipFilePath+"]to["+remoteFile+"]");
FileUtils.deleteQuietly(new File(zipFilePath));
}
}
- private void appendLine(List<String> values,BufferedOutputStream bos) {
- StringBuilder lineDatas = new StringBuilder();
-
- for (String value : values) {
- lineDatas.append(value).append("|");
- }
- try {
- bos.write(lineDatas.toString().getBytes());
- bos.write("\n".getBytes());
- } catch (IOException e) {
- log.error("appendLine error "+StringUtil.getStackTrace(e));
- }
- }
+// private void appendLine(List<String> values,BufferedOutputStream bos) {
+// StringBuilder lineDatas = new StringBuilder();
+//
+// for (String value : values) {
+// lineDatas.append(value).append("|");
+// }
+// try {
+// bos.write(lineDatas.toString().getBytes());
+// bos.write("\n".getBytes());
+// } catch (IOException e) {
+// log.error("appendLine error "+StringUtil.getStackTrace(e));
+// }
+// }
public List<File> decompressed(String fileName){
List<File> filelist = new ArrayList<File>();
//isPassiveMode
String passivemode = collectVo.getPassive();
- String ftpType = collectVo.getFtptype();
- FTPInterface ftpClient = null;
- if("ftp".equalsIgnoreCase(ftpType)){
- ftpClient = new FTPSrv();
- }else{
- ftpClient = new SFTPSrv();
- }
+ FTPInterface ftpClient = new FTPSrv();
//login
try {
//download
String dir = collectVo.getRemotepath();
- boolean cdsucess = ftpClient.chdir(dir);
- if(cdsucess){
- AFtpRemoteFile[] remoteFiles = (AFtpRemoteFile[]) ftpClient.list();
+ List<String> searchExprList = new ArrayList<String>();
+ String []FPath = dir.split(";");
+ for(int i=0;i<FPath.length;i++){
+ int oldSize = searchExprList.size();
+ String conpath = FPath[i];
+ Hashtable<String,String> varMap = new Hashtable<String,String>();
+ long[] d = DateUtil.getScanScope(new Date(), 900);
+ searchExprList.add(VarExprParser.replaceVar(conpath,d[0],d[1]));
- for(AFtpRemoteFile ftpRemoteFile: remoteFiles){
- if(!new File(localPath).exists()){
- try {
- new File(localPath).mkdir();
- } catch (Exception e) {
- log.error("create localPath is fail localPath="+localPath+" "+StringUtil.getStackTrace(e));
- }
- }
-
- if(!new File(localPath).exists()){
- new File(localPath).mkdirs();
- }
+ varMap.clear();
+ varMap = null;
+ log.info("["+conpath+"]，result["+(searchExprList.size()-oldSize)+"] path");
+ conpath = null;
+ }
+ searchExprList =getLocalPathNoRegular(searchExprList);
+ List<AFtpRemoteFile> remoteFiles = new ArrayList<AFtpRemoteFile>();
+ for(String expr :searchExprList){
+ String keys[] = parseExprKeys(expr);
+ String ftpRegular = keys[1];
+ String ftpDir = keys[0];
+
+ boolean cdsucess = ftpClient.chdir(expr);
+ if(cdsucess){
+ AFtpRemoteFile[] arf = (AFtpRemoteFile[]) ftpClient.list();
+ log.info(" list ["+ftpDir+"]，result["+(arf==null?"null":arf.length)+"] files");
+ //filter
- String localFileName = localPath + ftpRemoteFile.getFileName();
- File loaclFile = new File(localFileName);
- if (loaclFile.exists()) {
- loaclFile.delete();
- }
+ rfileFilter(remoteFiles,arf,ftpRegular);
- boolean flag = ftpClient.downloadFile(ftpRemoteFile.getAbsFileName(), localFileName);
+ keys = null;
+ ftpRegular=ftpDir = null;
- if(flag){
- fileList.add(localFileName);
- }else{
- log.error("download file fail fileName="+ftpRemoteFile.getAbsFileName());
+ for(AFtpRemoteFile ftpRemoteFile: remoteFiles){
+ if(!new File(localPath).exists()){
+ try {
+ new File(localPath).mkdir();
+ } catch (Exception e) {
+ log.error("create localPath is fail localPath="+localPath+" "+StringUtil.getStackTrace(e));
+ }
+ }
+
+ if(!new File(localPath).exists()){
+ new File(localPath).mkdirs();
+ }
+
+ String localFileName = localPath + ftpRemoteFile.getFileName();
+ File loaclFile = new File(localFileName);
+ if (loaclFile.exists()) {
+ loaclFile.delete();
+ }
+
+ boolean flag = ftpClient.downloadFile(ftpRemoteFile.getAbsFileName(), localFileName);
+
+ if(flag){
+ fileList.add(localFileName);
+ }else{
+ log.error("download file fail fileName="+ftpRemoteFile.getAbsFileName());
+ }
}
+
+ }else{
+ log.error("chdir is faill dir =["+dir+"]");
}
-
- }else{
- log.error("chdir is faill dir =["+dir+"]");
}
+
+
return fileList;
}
+ private void rfileFilter(List<AFtpRemoteFile> fileContainer, AFtpRemoteFile[] arfs, String ftpRegular) {
+ if (ftpRegular!=null && ftpRegular.length()>0) {
+ Pattern pattern = null;
+ try {
+ pattern = Pattern.compile(ftpRegular, Pattern.CASE_INSENSITIVE);
+ } catch (Exception e) {
+ log.info("["+ftpRegular+"]Pattern.compile exception:"+e.getMessage());
+ }
+ int hisSize = fileContainer.size();
+ for (int j=0; arfs!=null&&j<arfs.length; j++) {
+ String fileName = parseFileName(arfs[j].getFileName());
+ Matcher matcher = pattern.matcher(fileName);
+ if (matcher.find())
+ fileContainer.add(arfs[j]);
+ }
+ log.info("["+ftpRegular+"]filter["+(fileContainer.size()-hisSize)+"]filse");
+ pattern = null;
+ }else {
+ for (int j=0; arfs!=null&&j<arfs.length; j++)
+ fileContainer.add(arfs[j]);
+ }
+
+ }
+
+ private String parseFileName(String fileName) {
+ int idx = fileName.lastIndexOf("/");
+ if (idx == -1)
+ return fileName;
+ return fileName.substring(idx+1, fileName.length());
+ }
+
+ private String[] parseExprKeys(String source) {
+
+ if(source.indexOf(";") > -1){
+ source = source.substring(0, source.indexOf(";"));
+ }
+ if (source.endsWith("/"))
+ return new String[]{source,""};
+
+ int idx = source.lastIndexOf("/");
+ String[] dirkeys = new String[2];
+ dirkeys[0] = source.substring(0, idx+1);
+ dirkeys[1] = source.substring(idx+1, source.length());
+ return dirkeys;
+ }
+
+ public List<String> getLocalPathNoRegular(List<String> searchExprList){
+ boolean isregular = false;
+ List<String> regularList = new ArrayList<String>();
+ for(String regular : searchExprList){
+ Pattern lpattern = null;
+ try{
+ lpattern = Pattern.compile("(.*/)<([^/]+)>(/.*)");
+ }catch (Exception e) {
+ log.info("["+regular+"]compile fails:"+e.getMessage());
+ }
+
+ Matcher matcher = lpattern.matcher(regular);
+ if(matcher.find()){
+ isregular = true;
+ String parpath = matcher.group(1);
+ File[] arryFile = new File(parpath).listFiles();
+ for(File file :arryFile){
+ if(file.isDirectory()&&file.getName().matches(matcher.group(2))){
+ regularList.add(matcher.group(1)+file.getName()+matcher.group(3));
+ }
+ }
+ }else{
+ regularList.add(regular);
+ }
+
+ }
+ if(isregular==true){
+ getLocalPathNoRegular(regularList);
+ }
+ return regularList;
+ }
}
\ No newline at end of file
}
public void run() {
- alarmChannel = MessageChannelFactory.getMessageChannel(Constant.ALARM_CHANNEL_KEY);
+ alarmChannel = MessageChannelFactory.getMessageChannel(Constant.RESULT_CHANNEL_KEY);
try {
this.init();
while(!this.isStop){
String body;
try {
body = this.receive();
- String alarm120 = this.build120Alarm(body);
-
- this.send120Alarm(alarm120);
+ try {
+ alarmChannel.put(body);
+ } catch (InterruptedException e) {
+ log.error(StringUtil.getStackTrace(e));
+ }
} catch (Exception e) {
reinit();
}
}
}
- private void send120Alarm(String alarm120) {
-
- try {
- alarmChannel.put(alarm120);
- } catch (InterruptedException e) {
- log.error(StringUtil.getStackTrace(e));
- }
- }
-
- public String build120Alarm(String body) {
- StringBuilder content = new StringBuilder(
- "<?xml version='1.0' encoding='iso-8859-1'?>\n")
- .append("<WholeMsg MsgMark='120' Priority='2' FieldNum='5'><FM_ALARM_MSG>\n");
-
- JSONObject reagobj = JSONObject.parseObject(body);
-
- Set<String> keys = reagobj.keySet();
-
- for (String key : keys) {
-
- String value = reagobj.get(key).toString();
- content.append("<").append(key).append(">");
- content.append(value);
- content.append("</").append(key).append(">\n");
- }
- content.append("</FM_ALARM_MSG></WholeMsg>");
-
- return content.toString();
-
- }
public String receive() throws Exception {
log.debug("received alarm message");
retString = msg.getBody();
}
+
+ if(retString == null){
+ Thread.sleep(100);
+ }
}
return retString;
}
public static String SYS_DATA = SYS_HOME + "data" + File.separator;
public static String SYS_DATA_TEMP = SYS_DATA + File.separator + "temp" + File.separator;
public static String SYS_DATA_RESULT = SYS_DATA + File.separator + "RESULT" + File.separator;
- public static String COLLECT_TYPE_CM = "cm";
- public static String COLLECT_TYPE_PM = "pm";
- public static String COLLECT_TYPE_ALARM = "alarm";
+ public static String COLLECT_TYPE_CM = "ems-resource";
+ public static String COLLECT_TYPE_PM = "ems-performance";
+ public static String COLLECT_TYPE_ALARM = "ems-alarm";
public static String ENCODING_UTF8 = "UTF-8";
public static String ENCODING_GBK = "GBK";
public static final String COLLECT_CHANNEL_KEY = "COLLECT_CHANNEL_KEY";
public static final String COLLECT_RESULT_CHANNEL_KEY = "COLLECT_RESULT_CHANNEL_KEY";
- public static final String ALARM_CHANNEL_KEY = "ALARM_CHANNEL_KEY";
+ public static final String RESULT_CHANNEL_KEY = "RESULT_CHANNEL_KEY";
public static final String MSBAPIROOTDOMAIN = "/api/microservices/v1/services";
package org.onap.vfc.nfvo.emsdriver.commons.ftp;
import java.io.IOException;
-import java.io.InputStream;
-import java.util.Date;
import org.apache.commons.net.ftp.FTPClient;
import org.apache.commons.net.ftp.FTPFile;
this.currDir = currDir;
}
- public long getSize() {
- return ftpFile.getSize();
- }
public String getFileName() {
return ftpFile.getName();
public String getAbsFileName() {
return currDir.concat(getFileName());
}
-
- public boolean isDirectory() {
- return ftpFile.isDirectory();
- }
- public boolean isFile() {
- return ftpFile.isFile();
- }
-
- public String getOwner() {
- return ftpFile.getUser();
- }
-
- public Date getModifyDate() {
- return ftpFile.getTimestamp().getTime();
- }
- public boolean renameTo(String newName) throws IOException {
- return ftpClient.rename(
- currDir.concat(getFileName()), newName);
- }
- public boolean remove() throws IOException {
- return ftpClient.deleteFile(
- currDir.concat(getFileName()));
- }
-
- public InputStream getInputStream() throws IOException {
- return ftpClient.retrieveFileStream(this.getAbsFileName());
- }
-
- public void release() {
- ftpClient = null;
- ftpFile = null;
- currDir = null;
- }
}
\ No newline at end of file
public RemoteFile[] list();
- public RemoteFile[] list(String dir);
+// public RemoteFile[] list(String dir);
- public boolean store(String localFile,String remoteFile);
+// public boolean store(String localFile,String remoteFile);
}
ftpClientConfig.setServerTimeZoneId(TimeZone.getDefault().getID());
this.ftpClient.setControlEncoding("GBK");
this.ftpClient.configure(ftpClientConfig);
- ftpClient.setParserFactory(new ExtendsDefaultFTPFileEntryParserFactory());
+// ftpClient.setParserFactory(new ExtendsDefaultFTPFileEntryParserFactory());
if(encode!=null && encode.length()>0){
ftpClient.setControlEncoding(encode);
return ftpRemoteFiles;
}
-
- public RemoteFile[] list(String dir) {
- return null;
- }
-
-
- public boolean store(String localFile, String remoteFile) {
-
- boolean sucess = false;
- FileInputStream lfileInput = null;
- try {
- lfileInput = new FileInputStream(localFile);
- ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE);
-
- if (ftpClient.storeFile(remoteFile, lfileInput)){
- sucess = true;
- }else{
- sucess = false;
- }
- } catch (Exception ioe) {
- sucess = false;
- log.error("store localFile = "+localFile+" is fail "+StringUtil.getStackTrace(ioe));
- } finally {
- if (lfileInput != null)
- try {
- lfileInput.close();
- } catch (IOException e) {
- }
- }
- return sucess;
- }
+// public boolean store(String localFile, String remoteFile) {
+//
+// boolean sucess = false;
+// FileInputStream lfileInput = null;
+// try {
+// lfileInput = new FileInputStream(localFile);
+// ftpClient.setFileType(FTPClient.BINARY_FILE_TYPE);
+//
+// if (ftpClient.storeFile(remoteFile, lfileInput)){
+// sucess = true;
+// }else{
+// sucess = false;
+// }
+// } catch (Exception ioe) {
+// sucess = false;
+// log.error("store localFile = "+localFile+" is fail "+StringUtil.getStackTrace(ioe));
+// } finally {
+// if (lfileInput != null)
+// try {
+// lfileInput.close();
+// } catch (IOException e) {
+// }
+// }
+// return sucess;
+// }
}
--- /dev/null
+/**
+ * Copyright 2017 BOCO Corporation. CMCC Technologies Co., Ltd
+ *
+ * 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.vfc.nfvo.emsdriver.commons.model;
+
+/**
+ * @author boco
+ *
+ */
+public class CrontabVo {
+
+ private String type;
+
+ private String crontab;
+ private String match;
+ private String granularity;
+
+ private boolean iscollect = false;
+
+ private String read_timeout;
+
+ /**
+ * @return the type
+ */
+ public String getType() {
+ return type;
+ }
+
+ /**
+ * @param type the type to set
+ */
+ public void setType(String type) {
+ this.type = type;
+ }
+
+ /**
+ * @return the crontab
+ */
+ public String getCrontab() {
+ return crontab;
+ }
+
+ /**
+ * @param crontab the crontab to set
+ */
+ public void setCrontab(String crontab) {
+ this.crontab = crontab;
+ }
+
+ /**
+ * @return the match
+ */
+ public String getMatch() {
+ return match;
+ }
+
+ /**
+ * @param match the match to set
+ */
+ public void setMatch(String match) {
+ this.match = match;
+ }
+
+ /**
+ * @return the granularity
+ */
+ public String getGranularity() {
+ return granularity;
+ }
+
+ /**
+ * @param granularity the granularity to set
+ */
+ public void setGranularity(String granularity) {
+ this.granularity = granularity;
+ }
+
+ /**
+ * @return the iscollect
+ */
+ public boolean isIscollect() {
+ return iscollect;
+ }
+
+ /**
+ * @param iscollect the iscollect to set
+ */
+ public void setIscollect(boolean iscollect) {
+ this.iscollect = iscollect;
+ }
+
+ /**
+ * @return the read_timeout
+ */
+ public String getRead_timeout() {
+ return read_timeout;
+ }
+
+ /**
+ * @param read_timeout the read_timeout to set
+ */
+ public void setRead_timeout(String read_timeout) {
+ this.read_timeout = read_timeout;
+ }
+
+
+
+
+}
private String name;
+
private Map<String,CollectVo> collectMap = new HashMap<String,CollectVo>();
/**
}
public CollectVo getCollectVoByType(String type){
- CollectVo collectVo = null;
- collectVo = this.collectMap.get(type);
+ CollectVo collectVo = this.collectMap.get(type);
return collectVo;
}
--- /dev/null
+/**
+ * Copyright 2017 BOCO Corporation. CMCC Technologies Co., Ltd
+ *
+ * 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.vfc.nfvo.emsdriver.commons.utils;
+
+import java.util.Calendar;
+import java.util.Date;
+
+public class DateUtil {
+
+
+ public static long[] getScanScope(Date fireTime, long collectPeriod) {
+ Calendar fire = Calendar.getInstance();
+ long start = 0L;
+ long end = 0L;
+ fire.setTime(fireTime);
+ fire.set(Calendar.SECOND,0);
+ fire.set(Calendar.MILLISECOND, 0);
+
+ if (collectPeriod < 3600) {//minute
+ long minite = fire.get(Calendar.MINUTE);
+ long collectMinite = (int)collectPeriod/60;
+ long s = minite%collectMinite;
+ end = fire.getTimeInMillis() - s*60*1000;
+ start = end - collectPeriod * 1000;
+ }else if (collectPeriod == 3600) {
+ fire.set(Calendar.MINUTE, 0);
+ end = fire.getTimeInMillis();
+ start = end - collectPeriod * 1000;
+ }else if (collectPeriod == 24*60*60){ //day
+ fire.set(Calendar.HOUR_OF_DAY, 0);
+ fire.set(Calendar.MINUTE, 0);
+ end = fire.getTimeInMillis();
+ start = end - collectPeriod * 1000;
+ }else{
+
+ if (collectPeriod>0) {
+ end = fire.getTimeInMillis()-(fire.getTimeInMillis()+8*60*60*1000)%(collectPeriod*1000);
+ }else {
+ return null;
+ }
+ start = end - collectPeriod * 1000;
+ }
+
+ return new long[] {start,end};
+ }
+
+}
--- /dev/null
+/**
+ * Copyright 2017 BOCO Corporation. CMCC Technologies Co., Ltd
+ *
+ * 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.vfc.nfvo.emsdriver.commons.utils;
+
+import java.text.SimpleDateFormat;
+import java.util.Locale;
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
+
+import org.apache.commons.lang.StringUtils;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+
+import java.util.Calendar;
+
+final public class VarExprParser {
+ private static Log log = LogFactory.getFactory().getInstance(VarExprParser.class);
+ private static Pattern varPattern = Pattern.compile("(\\$\\{([^\\}]+)\\})",
+ Pattern.CASE_INSENSITIVE);
+
+ final static public String replaceVar(String str,long scan_start_time,long scan_stop_time) {
+ if (str.indexOf("${") == -1)
+ return str;
+
+ // 支持原系统变量
+ str = str.replace("${s_year}", "${SCAN_START_TIME,yyyy}");
+ str = str.replace("${s_mon}", "${SCAN_START_TIME,MM}");
+ str = str.replace("${s_day}", "${SCAN_START_TIME,dd}");
+ str = str.replace("${s_hour}", "${SCAN_START_TIME,HH}");
+ str = str.replace("${s_min}", "${SCAN_START_TIME,mm}");
+ str = str.replace("${e_year}", "${SCAN_STOP_TIME,yyyy}");
+ str = str.replace("${e_mon}", "${SCAN_STOP_TIME,MM}");
+ str = str.replace("${e_day}", "${SCAN_STOP_TIME,dd}");
+ str = str.replace("${e_hour}", "${SCAN_STOP_TIME,HH}");
+ str = str.replace("${e_min}", "${SCAN_STOP_TIME,mm}");
+
+ String expr = null, varName = null, value = null;
+ Matcher matcher = varPattern.matcher(str);
+ while (matcher.find()) {
+ value = null;
+ expr = matcher.group(1);
+ varName = matcher.group(2);
+ if (expr.indexOf("${SCAN_START_TIME") != -1) {
+ value = getTime(scan_start_time,varName,"yyyy-MM-dd HH:mm:ss");
+ } else if (expr.indexOf("${SCAN_STOP_TIME") != -1) {
+ value = getTime(scan_stop_time,varName,"yyyy-MM-dd HH:mm:ss");
+ }
+ if (value == null) {
+ log.warn(" expr [" + str + "] var["
+ + expr + "]is fail");
+ continue;
+ }
+ str = str.replace(expr, value);
+ }
+ expr = value = null;
+ matcher = null;
+ return str;
+ }
+
+ private static String getTime(long time,String value,String defaultParam){
+ String timeStr = null;
+ String formatStr = null;
+ String increaseTime = null;
+ if (value.indexOf(",") == -1){
+ formatStr = defaultParam;
+ timeStr = value;
+ }else{
+ timeStr = value.split(",")[0];
+ formatStr = value.split(",")[1];
+ }
+
+ if(timeStr.indexOf("+")==-1&&timeStr.indexOf("-")==-1){
+ SimpleDateFormat simpleDateFormat = new SimpleDateFormat(formatStr, Locale.ENGLISH);
+ return simpleDateFormat.format(time);
+ }else{
+ if(timeStr.indexOf("+")!=-1){
+ increaseTime = timeStr.substring(timeStr.indexOf("+")+1, timeStr.length()-1);
+ }
+ if(timeStr.indexOf("-")!=-1){
+ increaseTime = timeStr.substring(timeStr.indexOf("-"), timeStr.length()-1);
+ }
+ if(timeStr.toLowerCase().endsWith("h")){
+ Calendar cal = Calendar.getInstance();
+ cal.setTimeInMillis(time);
+ cal.add(Calendar.HOUR,Integer.parseInt(increaseTime));
+ SimpleDateFormat simpleDateFormat = new SimpleDateFormat(formatStr, Locale.ENGLISH);
+ return simpleDateFormat.format(cal.getTimeInMillis());
+ }else if(timeStr.toLowerCase().endsWith("m")){
+ Calendar cal = Calendar.getInstance();
+ cal.setTimeInMillis(time);
+ cal.add(Calendar.MINUTE,Integer.parseInt(increaseTime));
+ SimpleDateFormat simpleDateFormat = new SimpleDateFormat(formatStr, Locale.ENGLISH);
+ return simpleDateFormat.format(cal.getTimeInMillis());
+ }
+ }
+ return null;
+ }
+ /**
+ * 仅支持该两个变量替换 省得正则匹配慢
+ * @param result
+ * @param scan_start_time
+ * @param scan_stop_time
+ * @return
+ */
+ public static String replaceTimeVar(String result,
+ String scan_start_time, String scan_stop_time){
+
+ boolean isReplace = false;
+ if(result.indexOf("${SCAN_ST") != -1){
+ isReplace = true;
+ }
+ if(isReplace){
+ if(result.indexOf("${SCAN_START_TIME}") != -1){
+
+ result = StringUtils.replace(result, "${SCAN_START_TIME}", scan_start_time);
+ }
+ if(result.indexOf("${SCAN_STOP_TIME") != -1){
+
+ result = StringUtils.replace(result, "${SCAN_STOP_TIME}", scan_stop_time);
+ }
+ }
+ return result;
+ }
+}
import java.util.Properties;
import java.util.concurrent.ConcurrentHashMap;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
import org.jdom.Document;
import org.jdom.Element;
import org.onap.vfc.nfvo.emsdriver.commons.constant.Constant;
import org.onap.vfc.nfvo.emsdriver.commons.model.CollectVo;
+import org.onap.vfc.nfvo.emsdriver.commons.model.CrontabVo;
import org.onap.vfc.nfvo.emsdriver.commons.model.EMSInfo;
import org.onap.vfc.nfvo.emsdriver.commons.utils.DriverThread;
import org.onap.vfc.nfvo.emsdriver.commons.utils.StringUtil;
import org.onap.vfc.nfvo.emsdriver.commons.utils.XmlUtil;
+import org.onap.vfc.nfvo.emsdriver.northbound.client.HttpClientUtil;
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
-public class ConfigurationManager extends DriverThread{
+public class ConfigurationManager extends DriverThread{
+ protected static Log log = LogFactory.getLog(ConfigurationManager.class);
/**
* ESM Cache
*/
private static Map<String, EMSInfo> emsInfoCache = new ConcurrentHashMap<String, EMSInfo>();
-
+ private static Map<String, CrontabVo> emsCrontab= new ConcurrentHashMap<String, CrontabVo>();
+ private static List<String> emsIdList = new ArrayList<String>();
private static Properties properties = null;
- private final static String ftpconfig = Constant.SYS_CFG + "ftpconfig.properties";
+ private final static String config = Constant.SYS_CFG + "config.properties";
@Override
- @SuppressWarnings("unchecked")
public void dispose() {
+
+ //this.log.debug("start loading " + cacheFilePath);
+ File file = new File(config);
+ if(!file.exists() || !file.isFile()){
+ log.error("cacheFilePath " + config+" not exist or is not File");
+ return;
+ }
+ InputStream in = null;
+ try{
+ properties = new Properties();
+ in = new FileInputStream(file);
+ properties.load(in);
+ Map<String, CrontabVo> emsMap = readCorntab();
+
+ emsCrontab.putAll(emsMap);
+
+ //
+ new ReceiveSource().start();
+ }catch(Exception e) {
+ log.error("read ["+file.getAbsolutePath()+"]Exception :",e);
+ }finally {
+ if(in != null) {
+ try {
+ in.close();
+ } catch (Exception e) {
+ }
+ }
+ }
+ }
+
+ private Map<String, CrontabVo> readCorntab() {
+ String path = Constant.SYS_CFG + "crontab.xml";
+ File cfg = new File(path);
+ log.debug("start loading " + path);
+ if(!cfg.exists() || !cfg.isFile()){
+ log.debug("not exists " + path);
+ return null;
+ }
+
+ InputStream is = null;
+ Map<String, CrontabVo> tmpcache = new HashMap<String, CrontabVo>();
+
+ try {
+ is = new FileInputStream(cfg);
+ Document doc = XmlUtil.getDocument(is);
+
+ Element root = doc.getRootElement();
+
+ @SuppressWarnings("unchecked")
+ List<Element> children = root.getChildren();
+
+ for(Iterator<Element> it = children.iterator();it.hasNext();){
+ CrontabVo crontabVo = new CrontabVo();
+ Element child = it.next();
+ String type = child.getAttributeValue("type");
+ if(StringUtil.isBank(type)){
+ continue;
+ }
+ crontabVo.setType(type);
+ if("ems-alarm".equalsIgnoreCase(type)){
+ boolean iscollect = Boolean.parseBoolean(child.getAttributeValue("iscollect"));
+ if(iscollect){
+ crontabVo.setIscollect(iscollect);
+ }else{
+ continue;
+ }
+
+ crontabVo.setRead_timeout(child.getChildText("readtimeout"));
+ }else{
+ String crontab = child.getAttributeValue("crontab");
+ if(!StringUtil.isBank(type) && !StringUtil.isBank(crontab)){
+ crontabVo.setCrontab(crontab);
+ }else{
+ continue;
+ }
+ crontabVo.setMatch(child.getChildText("match"));
+ crontabVo.setGranularity(child.getChildText("granularity"));
+ }
+ tmpcache.put(type, crontabVo);
+ }
+
+ } catch (Exception e) {
+ log.error("load crontab.xml is error "+StringUtil.getStackTrace(e));
+ }finally{
+ tmpcache.clear();
+ try {
+ if(is != null){
+ is.close();
+ is = null;
+ }
+ } catch (Exception e2) {
+ }
+ cfg = null;
+ }
+ return tmpcache;
+ }
+
+
+ public void readcfg(){
String path = Constant.SYS_CFG + "EMSInfo.xml";
File cfg = new File(path);
- this.log.debug("start loading " + path);
+ log.debug("start loading " + path);
if(!cfg.exists() || !cfg.isFile()){
- this.log.debug("not exists " + path);
+ log.debug("not exists " + path);
return;
}
-
+
+
InputStream is = null;
Map<String, EMSInfo> tmpcache = new HashMap<String, EMSInfo>();
Element root = doc.getRootElement();
+ @SuppressWarnings("unchecked")
List<Element> children = root.getChildren();
for(Iterator<Element> it = children.iterator();it.hasNext();){
}
emsInfo.setName(name);
- tmpcache.put(name, emsInfo);
+// tmpcache.put(name, emsInfo);
+ @SuppressWarnings("unchecked")
List<Element> collectList = child.getChildren();
for(Element collect : collectList){
}
emsInfoCache.putAll(tmpcache);
+ File file = new File(config);
+ if(!file.exists() || !file.isFile()){
+ log.error("cacheFilePath " + config+" not exist or is not File");
+ return;
+ }
+ InputStream in = null;
+ try{
+ properties = new Properties();
+ in = new FileInputStream(file);
+ properties.load(in);
+ }catch (Exception e) {
+ e.printStackTrace();
+ }
} catch (Exception e) {
log.error("load EMSInfo.xml is error "+StringUtil.getStackTrace(e));
}finally{
}
cfg = null;
}
-
-
- //this.log.debug("start loading " + cacheFilePath);
- File file = new File(ftpconfig);
- if(!file.exists() || !file.isFile()){
- this.log.error("cacheFilePath " + ftpconfig+"not exist or is not File");
- return;
- }
- InputStream in = null;
- try{
- properties = new Properties();
- in = new FileInputStream(file);
- properties.load(in);
-
- }catch(Exception e) {
- log.error("read ["+file.getAbsolutePath()+"]Exception :",e);
- }finally {
- if(in != null) {
- try {
- in.close();
- } catch (Exception e) {
- }
- }
- }
}
+
public static synchronized List<EMSInfo> getAllEMSInfos(){
List<EMSInfo> list = new ArrayList<EMSInfo>();
for(EMSInfo emsinfo :emsInfoCache.values()){
return properties;
}
+ class ReceiveSource extends Thread{
+ long timeStamp = System.currentTimeMillis();
+
+ public void run() {
+ while(true){
+
+ try {
+ if(System.currentTimeMillis() - timeStamp > Constant.ONEMINUTE){
+ timeStamp = System.currentTimeMillis();
+ log.debug("ReceiveSource run");
+ }
+ //get emsId list
+ List<String> emsIds = this.getEmsIdList();
+ if(emsIds.size() > 0){
+ emsIdList.clear();
+ emsIdList.addAll(emsIds);
+ }
+
+ for(String emsId : emsIdList){
+ //get emsInfo by emsId
+ Map<String, EMSInfo> emsInfoMap = this.getEmsInfo(emsId);
+
+ emsInfoCache.putAll(emsInfoMap);
+ }
+
+
+ //
+ if(emsInfoCache.size() > 0){
+ Thread.sleep(5*60*1000);
+ }else{
+ Thread.sleep(60*1000);
+ }
+ } catch (Exception e) {
+ log.error("ReceiveSource exception",e);
+ }
+ }
+ }
+ private Map<String, EMSInfo> getEmsInfo(String emsId) {
+ Map<String, EMSInfo> tmpcache = new ConcurrentHashMap<String, EMSInfo>();
+ String msbAddress = properties.getProperty("msbAddress");
+ String emstUrl = properties.getProperty("esr_emsUrl");
+ //set emsId to url
+ String.format(emstUrl, emsId);
+ String getemstUrl = "http://"+msbAddress+emstUrl;
+ String emsResult = HttpClientUtil.doGet(getemstUrl, Constant.ENCODING_UTF8);
+ log.debug(getemstUrl+" result="+emsResult);
+ JSONObject reagobj = JSONObject.parseObject(emsResult);
+
+ JSONObject esr_system_info_list = reagobj.getJSONObject("esr-system-info-list");
+ JSONArray esr_system_info = esr_system_info_list.getJSONArray("esr-system-info");
+ Iterator<Object> it = esr_system_info.iterator();
+ EMSInfo emsInfo = new EMSInfo();
+ emsInfo.setName(emsId);
+ tmpcache.put(emsId, emsInfo);
+ while(it.hasNext()){
+ Object obj = it.next();
+ JSONObject collect = (JSONObject)obj;
+ String system_type = (String)collect.get("system-type");
+ CollectVo collectVo = new CollectVo();
+ if("ems-resource".equalsIgnoreCase(system_type)){
+ CrontabVo crontabVo = emsCrontab.get(system_type);
+ if(crontabVo != null){
+ collectVo.setType(system_type);
+ collectVo.setCrontab(crontabVo.getCrontab());
+ collectVo.setIP(collect.getString("ip-address"));
+ collectVo.setPort(collect.getString("port"));
+ collectVo.setUser(collect.getString("user-name"));
+ collectVo.setPassword(collect.getString("password"));
+
+ collectVo.setRemotepath(collect.getString("remote-path"));
+ collectVo.setMatch(crontabVo.getMatch());
+ collectVo.setPassive(collect.getString("passive"));
+ collectVo.setGranularity(crontabVo.getGranularity());
+ }
+
+
+ }else if("ems-performance".equalsIgnoreCase(system_type)){
+ CrontabVo crontabVo = emsCrontab.get(system_type);
+ if(crontabVo != null){
+ collectVo.setType(system_type);
+ collectVo.setCrontab(crontabVo.getCrontab());
+ collectVo.setIP(collect.getString("ip-address"));
+ collectVo.setPort(collect.getString("port"));
+ collectVo.setUser(collect.getString("user-name"));
+ collectVo.setPassword(collect.getString("password"));
+
+ collectVo.setRemotepath(collect.getString("remote-path"));
+ collectVo.setMatch(crontabVo.getMatch());
+ collectVo.setPassive(collect.getString("passive"));
+ collectVo.setGranularity(crontabVo.getGranularity());
+ }
+ }else if("ems-alarm".equalsIgnoreCase(system_type)){
+ CrontabVo crontabVo = emsCrontab.get(system_type);
+ if(crontabVo != null){
+ collectVo.setIscollect(crontabVo.isIscollect());
+ collectVo.setType(system_type);
+ collectVo.setIP(collect.getString("ip-address"));
+ collectVo.setPort(collect.getString("port"));
+ collectVo.setUser(collect.getString("user-name"));
+ collectVo.setPassword(collect.getString("password"));
+ collectVo.setRead_timeout(crontabVo.getRead_timeout());
+ }else{
+ log.error("emsCrontab.get(system_type) result crontabVo is null" );
+ }
+
+
+ }else{
+ log.error("ems system-type ="+system_type+" ");
+ }
+
+ emsInfo.putCollectMap(system_type, collectVo);
+ }
+ return tmpcache;
+ }
+
+ private List<String> getEmsIdList() {
+ List<String> emsIds = new ArrayList<String>();
+ //http
+ String msbAddress = properties.getProperty("msbAddress");
+ String url = properties.getProperty("esr_ems_listUrl");
+ String getemsListUrl = "http://"+msbAddress+url;
+
+ String result = HttpClientUtil.doGet(getemsListUrl, Constant.ENCODING_UTF8);
+ log.debug(getemsListUrl+" result="+result);
+ JSONObject reagobj = JSONObject.parseObject(result);
+ JSONArray esr_emsIds = reagobj.getJSONArray("esr-ems");
+ Iterator<Object> it = esr_emsIds.iterator();
+ while(it.hasNext()){
+ Object obj = it.next();
+ JSONObject emsId = (JSONObject)obj;
+ String emsIdStr = (String)emsId.get("ems-id");
+ emsIds.add(emsIdStr);
+ }
+ return emsIds;
+ }
+ }
}
*/
package org.onap.vfc.nfvo.emsdriver.northbound.client;
+import java.text.ParseException;
+import java.text.SimpleDateFormat;
+import java.util.Date;
+import java.util.Map;
import java.util.Properties;
+import javax.json.Json;
+import javax.json.JsonBuilderFactory;
+import javax.json.JsonObject;
+import javax.json.JsonObjectBuilder;
+
+import org.apache.log4j.Level;
import org.onap.vfc.nfvo.emsdriver.commons.constant.Constant;
import org.onap.vfc.nfvo.emsdriver.commons.utils.DriverThread;
import org.onap.vfc.nfvo.emsdriver.configmgr.ConfigurationInterface;
import org.onap.vfc.nfvo.emsdriver.messagemgr.MessageChannel;
import org.onap.vfc.nfvo.emsdriver.messagemgr.MessageChannelFactory;
+import com.alibaba.fastjson.JSONObject;
+
+import evel_javalibrary.att.com.AgentMain;
+import evel_javalibrary.att.com.EvelFault;
+import evel_javalibrary.att.com.EvelFault.EVEL_SEVERITIES;
+import evel_javalibrary.att.com.EvelFault.EVEL_SOURCE_TYPES;
+import evel_javalibrary.att.com.EvelFault.EVEL_VF_STATUSES;
+import evel_javalibrary.att.com.EvelHeader.PRIORITIES;
+import evel_javalibrary.att.com.EvelHeader;
+import evel_javalibrary.att.com.EvelScalingMeasurement;
+
public class NorthMessageMgr extends DriverThread{
- private MessageChannel alarmChannel = MessageChannelFactory.getMessageChannel(Constant.ALARM_CHANNEL_KEY);
+ private MessageChannel alarmChannel = MessageChannelFactory.getMessageChannel(Constant.RESULT_CHANNEL_KEY);
+ private MessageChannel collectChannel = MessageChannelFactory.getMessageChannel(Constant.COLLECT_CHANNEL_KEY);
private MessageChannel collectResultChannel = MessageChannelFactory.getMessageChannel(Constant.COLLECT_RESULT_CHANNEL_KEY);
private ConfigurationInterface configurationInterface ;
private boolean threadStop = false;
+ private Level level = Level.DEBUG;
@Override
public void dispose() {
+ Properties properties = configurationInterface.getProperties();
+ String event_api_url = properties.getProperty("event_api_url");
+ String port = properties.getProperty("port");
+ String path = properties.getProperty("path");
+ String topic = properties.getProperty("topic");
+ String username = properties.getProperty("username");
+ String password = properties.getProperty("password");
+ String levelStr = properties.getProperty("level");
+ if("debug".equals(levelStr)){
+ level = Level.DEBUG;
+ }else{
+ level = Level.INFO;
+ }
+
+ //login north
+ try{
+ AgentMain.evel_initialize(event_api_url, Integer.parseInt(port),
+ path,topic,
+ username,
+ password,
+ level);
+ } catch( Exception e ){
+ log.error("AgentMain.evel_initialize fail ",e);
+ }
+
+ new HeatBeatTread().start();
//
new AlarmMessageRecv().start();
new ResultMessageRecv().start();
+
+ new CollectMessageRecv().start();
}
+ class HeatBeatTread extends Thread{
+
+ public void run() {
+
+ while(!threadStop){
+
+ try {
+ EvelHeader header = EvelHeader.evel_new_heartbeat("Hearbeat_EMS","EMS-driver");
+ header.evel_nfnamingcode_set("EMS-driver");
+ header.evel_nfcnamingcode_set("EMS-driver");
+ AgentMain.evel_post_event(header);
+ log.debug("HeatBeat send!");
+ try {
+ Thread.sleep(60*1000);
+ } catch( Exception e ){
+ e.printStackTrace();
+ }
+ } catch (Exception e) {
+ log.error("HeatBeatTread exception",e);
+ }
+ }
+ }
+ }
+
class AlarmMessageRecv extends Thread{
long timeStamp = System.currentTimeMillis();
continue;
}
if(obj instanceof String){
- //http
- Properties properties = configurationInterface.getProperties();
- String msbAddress = properties.getProperty("msbAddress");
- String url = properties.getProperty("alarm");
- String postUrl = "http://"+msbAddress+url;
+ String result = (String)obj;
+ JSONObject reagobj = JSONObject.parseObject(result);
- HttpClientUtil.doPost(postUrl, (String)obj, Constant.ENCODING_UTF8);
+ EvelFault evelFault = this.resultEvelFault(reagobj);
+
+ //send
+ AgentMain.evel_post_event(evelFault);
+ }else{
+ log.error("AlarmMessageRecv receive Object = "+obj);
}
} catch (Exception e) {
}
}
}
+
+ private EvelFault resultEvelFault(JSONObject reagobj) {
+
+ String eventName = null;
+ EvelHeader.PRIORITIES pri = null;
+ EVEL_SEVERITIES severity = null;
+ EVEL_VF_STATUSES status = null;
+ String alarmStatus = reagobj.getString("alarmStatus");
+ String origSeverity = reagobj.getString("origSeverity");
+ if("0".equals(alarmStatus)){
+ status = EVEL_VF_STATUSES.EVEL_VF_STATUS_IDLE;
+ eventName = "Fault_"+reagobj.getString("neType")+"_"+reagobj.getString("alarmTitle")+"Cleared";
+
+ if("1".equals(origSeverity)){
+ severity = EVEL_SEVERITIES.EVEL_SEVERITY_CRITICAL;
+ pri = EvelHeader.PRIORITIES.EVEL_PRIORITY_HIGH;
+ }else if("2".equals(origSeverity)){
+ severity = EVEL_SEVERITIES.EVEL_SEVERITY_MAJOR;
+ pri = EvelHeader.PRIORITIES.EVEL_PRIORITY_MEDIUM;
+ }else if("3".equals(origSeverity)){
+ severity = EVEL_SEVERITIES.EVEL_SEVERITY_MINOR;
+ pri = EvelHeader.PRIORITIES.EVEL_PRIORITY_NORMAL;
+ }else if("4".equals(origSeverity)){
+ severity = EVEL_SEVERITIES.EVEL_SEVERITY_WARNING;
+ pri = EvelHeader.PRIORITIES.EVEL_PRIORITY_LOW;
+
+ }
+ }else{
+ status = EVEL_VF_STATUSES.EVEL_VF_STATUS_ACTIVE;
+ eventName = "Fault_"+reagobj.getString("neType")+"_"+reagobj.getString("alarmTitle");
+ pri = EvelHeader.PRIORITIES.EVEL_PRIORITY_NORMAL;
+ severity = EVEL_SEVERITIES.EVEL_SEVERITY_NORMAL;
+ }
+
+ String evnId = reagobj.getString("alarmId");
+ String alarmCondition = reagobj.getString("specificProblem");
+
+ String specificProblem = reagobj.getString("specificProblem");
+
+ EvelFault flt = new EvelFault(eventName, evnId,alarmCondition,
+ specificProblem,pri,severity,
+ EVEL_SOURCE_TYPES.EVEL_SOURCE_OTHER,
+ status);
+ flt.evel_nfcnamingcode_set("");
+ flt.evel_nfnamingcode_set("");
+ flt.evel_header_type_set("applicationVnf");
+ String eventTime = reagobj.getString("eventTime");
+ SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+ Date eventTimeD = new Date();
+ try {
+ eventTimeD = format.parse(eventTime);
+ } catch (ParseException e) {
+ // TODO Auto-generated catch block
+ e.printStackTrace();
+ }
+ flt.evel_start_epoch_set(eventTimeD.getTime());
+ flt.evel_last_epoch_set(eventTimeD.getTime());
+
+ flt.evel_fault_category_set(reagobj.getString("alarmType"));
+ flt.evel_fault_interface_set(reagobj.getString("objectName"));
+ String neUID = reagobj.getString("neUID");
+ flt.evel_reporting_entity_id_set(neUID.substring(0,9));//
+ flt.evel_reporting_entity_name_set(neUID.substring(0,9));
+
+ flt.evel_header_set_priority(pri);
+ for(String key : reagobj.keySet()){
+ flt.evel_fault_addl_info_add(key, reagobj.getString(key));
+ }
+
+ return flt;
+ }
}
class ResultMessageRecv extends Thread{
}
} catch (Exception e) {
- log.error("AlarmMessageRecv exception",e);
+ log.error("ResultMessageRecv exception",e);
}
}
}
}
+
+ class CollectMessageRecv extends Thread{
+ long timeStamp = System.currentTimeMillis();
+
+ public void run() {
+ while(!threadStop){
+
+ try {
+ if(System.currentTimeMillis() - timeStamp > Constant.ONEMINUTE){
+ timeStamp = System.currentTimeMillis();
+
+ log.debug("COLLECT_CHANNEL_KEY Msg size :"+collectChannel.size());
+ }
+
+ Object obj = collectChannel.poll();
+ if(obj == null){
+ continue;
+ }
+ if(obj instanceof Map){
+ @SuppressWarnings("unchecked")
+ Map<String,String> reMap = (Map<String,String>)obj;
+ EvelScalingMeasurement evelScalingMeasurement = this.resultEvelScalingMeasurement(reMap);
+
+ //send
+ AgentMain.evel_post_event(evelScalingMeasurement);
+
+ }else{
+ log.error("CollectMessageRecv receive Object = "+obj);
+ }
+
+ } catch (Exception e) {
+ log.error("CollectMessageRecv exception",e);
+ }
+ }
+ }
+
+ private EvelScalingMeasurement resultEvelScalingMeasurement(Map<String,String> reMap) {
+ String evname = "Mfvs_"+reMap.get("ElementType")+reMap.get("ObjectType");
+ String evid = reMap.get("startTime")+reMap.get("ObjectType")+reMap.get("rmUID");
+ int Period = Integer.parseInt(reMap.get("Period")!=null?reMap.get("Period"):"15");
+ EvelScalingMeasurement sm = new EvelScalingMeasurement(Period,evname, evid);
+ JsonObject objJson = null;
+ JsonBuilderFactory factory = null;
+ factory = Json.createBuilderFactory(null);
+ JsonObjectBuilder jsonObjectBuilder = factory.createObjectBuilder();
+
+ for(String key : reMap.keySet()){
+ jsonObjectBuilder = jsonObjectBuilder.add(key, reMap.get(key));
+
+ }
+ objJson = jsonObjectBuilder.build();
+ sm.evel_measurement_add_jsonobj(objJson);
+
+ sm.evel_nfcnamingcode_set("");
+ sm.evel_nfnamingcode_set("");
+ sm.evel_header_type_set("applicationVnf");
+ String rmUID = reMap.get("rmUID");
+ sm.evel_reporting_entity_id_set(rmUID.substring(0,9));//
+ String Dn = reMap.get("Dn");
+ sm.evel_reporting_entity_name_set(Dn);
+ sm.evel_header_set_priority(EvelHeader.PRIORITIES.EVEL_PRIORITY_NORMAL);
+ return sm;
+ }
+ }
/**
* @return the configurationInterface
public void processPMCsv(){
list = taskThread.decompressed(gzPath);
for(File file : list){
- boolean re = taskThread.processPMCsv(file,"nename","PM");
+ boolean re = taskThread.processPMCsv(file);
assertTrue(re);
}
}
@Test
public void build120Alarm(){
String alarm = "{\"alarmSeq\":495,\"alarmTitle\":\"LTE cell outage\",\"alarmStatus\":1,\"alarmType\":\"processingErrorAlarm\"}";
- String al = taskThread.build120Alarm(alarm);
- assertNotNull(al);
+// String al = taskThread.build120Alarm(alarm);
+ assertNotNull(alarm);
}
}
public void setUp() throws IOException {
configurationImp = new ConfigurationImp();
configurationManager = new ConfigurationManager();
- configurationManager.dispose();
+ configurationManager.readcfg();
}
@Test
@Before
public void setUp() throws IOException {
configurationManager = new ConfigurationManager();
- configurationManager.dispose();
+ configurationManager.readcfg();
}
@Test
--- /dev/null
+/**
+ * Copyright 2017 BOCO Corporation. CMCC Technologies Co., Ltd
+ *
+ * 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.vfc.nfvo.emsdriver.serviceregister;
+
+import org.junit.Test;
+
+public class MsbConfigurationTest {
+
+ @Test
+ public void testSetMsbAddress(){
+ MsbConfiguration.setMsbAddress("aaa/bnn");
+ }
+
+ @Test
+ public void testGetMsbAddress(){
+ MsbConfiguration.getMsbAddress();
+ }
+
+}
--- /dev/null
+/**
+ * Copyright 2017 BOCO Corporation. CMCC Technologies Co., Ltd
+ *
+ * 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.vfc.nfvo.emsdriver.serviceregister;
+
+import org.junit.Before;
+import org.junit.Test;
+import org.onap.vfc.nfvo.emsdriver.serviceregister.model.MsbRegisterVo;
+
+public class MsbRestServiceProxyTest {
+
+ @Before
+ public void upSet(){
+ MsbConfiguration.setMsbAddress("");
+ }
+ @Test
+ public void testRegisterService(){
+ MsbRegisterVo registerInfo = new MsbRegisterVo();
+ registerInfo.setServiceName("ems-driver");
+ registerInfo.setUrl("/api/emsdriver/v1");
+ String registerResponse = MsbRestServiceProxy.registerService(registerInfo);
+ System.out.println(registerResponse);
+ }
+}
--- /dev/null
+/**
+ * Copyright 2017 BOCO Corporation. CMCC Technologies Co., Ltd
+ *
+ * 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.vfc.nfvo.emsdriver.serviceregister.model;
+
+import java.util.ArrayList;
+
+import org.junit.Before;
+import org.junit.Test;
+
+public class MsbRegisterVoTest {
+
+ private MsbRegisterVo msbRegisterVo;
+
+ @Before
+ public void setUp() {
+ msbRegisterVo = new MsbRegisterVo();
+ }
+
+ @Test
+ public void testMsbRegisterVo(){
+ msbRegisterVo.setProtocol("REST");
+ msbRegisterVo.setServiceName("serviceName");
+ msbRegisterVo.setUrl("http://");
+ msbRegisterVo.setVersion("version");
+ msbRegisterVo.setVisualRange("vr");
+ ArrayList<ServiceNodeVo> list = new ArrayList<ServiceNodeVo>();
+ list.add(new ServiceNodeVo());
+ msbRegisterVo.setNodes(list);
+ msbRegisterVo.getNodes();
+ msbRegisterVo.getProtocol();
+ msbRegisterVo.getServiceName();
+ msbRegisterVo.getUrl();
+ msbRegisterVo.getVersion();
+ msbRegisterVo.getVisualRange();
+
+ }
+
+}
--- /dev/null
+/**
+ * Copyright 2017 BOCO Corporation. CMCC Technologies Co., Ltd
+ *
+ * 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.vfc.nfvo.emsdriver.serviceregister.model;
+
+import static org.junit.Assert.*;
+
+import org.junit.Before;
+import org.junit.Test;
+
+public class ServiceNodeVoTest {
+
+ private ServiceNodeVo serviceNodeVo;
+
+ @Before
+ public void setUp() {
+ serviceNodeVo = new ServiceNodeVo();
+ }
+
+ @Test
+ public void testServiceNodeVo(){
+ serviceNodeVo.setIp("127.0.0.1");
+ serviceNodeVo.setPort("100");
+ serviceNodeVo.setTtl(1);
+ assertNotNull(serviceNodeVo.getIp());
+ assertNotNull(serviceNodeVo.getPort());
+ assertNotNull(serviceNodeVo.getTtl());
+ }
+
+}
--- /dev/null
+
+# Copyright 2017 BOCO Corporation. CMCC Technologies Co., Ltd
+#
+# 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.
+#
+
+ftp_ip = 192.168.6.48
+ftp_port = 21
+ftp_user = gcp
+ftp_password = gcp
+ftp_remote_path = /opt/Gcp/
+ftp_passive = true
+ftp_type = ftp
+
+#
+msbAddress=10.74.205.123:80
+esr_ems_listUrl=/aai/v11/external-system/esr-ems-list
+esr_emsUrl=/aai/v11/external-system/esr-ems-list/esr-ems/%s?depth=all
+alarmUrl=/alarm
+
+
+#north
+event_api_url=http://127.0.0.1
+port=30000
+path=/vendor_event_listener
+topic=/example_vnf
+username=pill
+password=will
+level=debug
--- /dev/null
+<?xml version='1.0' encoding='GBK'?>
+<!--
+
+ Copyright 2017 BOCO Corporation. CMCCTechnologiesCo.,Ltd
+
+ 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.
+
+
+-->
+<scheduler>
+ <crontab type ="ems-resource" crontab="0 0/15 * * * ?">
+ <match>*</match>
+ <granularity>15</granularity>
+ </crontab>
+ <crontab type ="ems-performance" crontab="">
+ <match>*</match>
+ <granularity>15</granularity>
+ </crontab>
+ <crontab type ="ems-alarm" iscollect = "false">
+ <readtimeout>6</readtimeout>;
+ </crontab>
+</scheduler>
\ No newline at end of file
Code Review / vfc / nfvo / driver / ems.git / commitdiff