From: wangguirong <wangguirong@boco.com.cn>
Date: Wed, 27 Sep 2017 04:19:41 +0000 (+0800)
Subject: EMS Driver add new functions
X-Git-Tag: v1.0.0~9^2
X-Git-Url: https://gerrit.onap.org/r/gitweb?a=commitdiff_plain;h=refs%2Fchanges%2F79%2F15779%2F1;p=vfc%2Fnfvo%2Fdriver%2Fems.git

EMS Driver add new functions

Change-Id: I026918c5d7bff577fdca3f4fa0dbaffd5b27dd45
Issue-Id:VFC-461
Signed-off-by: wangguirong <wangguirong@boco.com.cn>
---

diff --git a/ems/boco/conf/config.properties b/ems/boco/conf/config.properties
new file mode 100644
index 0000000..7a946d0
--- /dev/null
+++ b/ems/boco/conf/config.properties
@@ -0,0 +1,39 @@
+
+# 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
diff --git a/ems/boco/conf/crontab.xml b/ems/boco/conf/crontab.xml
new file mode 100644
index 0000000..0d7f591
--- /dev/null
+++ b/ems/boco/conf/crontab.xml
@@ -0,0 +1,32 @@
+<?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
diff --git a/ems/boco/lib/VESLibrary.jar b/ems/boco/lib/VESLibrary.jar
new file mode 100644
index 0000000..ef9de52
Binary files /dev/null and b/ems/boco/lib/VESLibrary.jar differ
diff --git a/ems/boco/lib/dependencies-all.jar b/ems/boco/lib/dependencies-all.jar
new file mode 100644
index 0000000..725a4be
Binary files /dev/null and b/ems/boco/lib/dependencies-all.jar differ
diff --git a/ems/boco/pom.xml b/ems/boco/pom.xml
index 413cff0..91d4fbf 100644
--- a/ems/boco/pom.xml
+++ b/ems/boco/pom.xml
@@ -1,3 +1,4 @@
+
 <!--
     Copyright (c) 2017, CMCC Technologies Co., Ltd.
 
@@ -16,12 +17,7 @@
 <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>
@@ -209,5 +205,20 @@
         <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>
diff --git a/ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/collector/TaskThread.java b/ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/collector/TaskThread.java
index e2fcf7d..e77db8b 100644
--- a/ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/collector/TaskThread.java
+++ b/ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/collector/TaskThread.java
@@ -28,6 +28,8 @@ import java.io.OutputStreamWriter;
 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;
@@ -45,12 +47,13 @@ import org.onap.vfc.nfvo.emsdriver.commons.constant.Constant;
 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;
@@ -62,7 +65,8 @@ public class TaskThread implements Runnable{
 	
 	public  Log log = LogFactory.getLog(TaskThread.class);
 	
-	private MessageChannel collectResultChannel;
+	private MessageChannel cmResultChannel;
+	private MessageChannel pmResultChannel;
 	
 	private CollectMsg data;
 	
@@ -75,9 +79,9 @@ public class TaskThread implements Runnable{
 	
 	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;
@@ -89,8 +93,8 @@ public class TaskThread implements Runnable{
 	@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) {
@@ -125,29 +129,11 @@ public class TaskThread implements Runnable{
 			  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){
@@ -159,23 +145,7 @@ public class TaskThread implements Runnable{
 		}
 	}
 	
-	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;
@@ -203,7 +173,7 @@ public class TaskThread implements Runnable{
 				columnNames.add(name);
 			}
 			
-			xmlPathAndFileName = this.setColumnNames(nename, columnNames,type);
+//			xmlPathAndFileName = this.setColumnNames(nename, columnNames,type);
 			
 			String valueLine = "";
 			List<String> valuelist = new ArrayList<String>();
@@ -212,15 +182,21 @@ public class TaskThread implements Runnable{
 				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) {
@@ -234,12 +210,7 @@ public class TaskThread implements Runnable{
 					isr.close();
 				if (brs != null)
 					brs.close();
-				if(bos != null){
-					bos.close();
-				}
-				if(fos != null){
-					fos.close();
-				}
+				
 			} catch (Exception e){
 				log.error(e);
 			}
@@ -248,6 +219,18 @@ public class TaskThread implements Runnable{
 		
 	}
 
+	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+"/";
@@ -415,7 +398,7 @@ public class TaskThread implements Runnable{
 	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));
 		}
@@ -482,12 +465,7 @@ public class TaskThread implements Runnable{
 		
 		
 		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);
@@ -495,7 +473,7 @@ public class TaskThread implements Runnable{
 			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));
@@ -601,19 +579,19 @@ public class TaskThread implements Runnable{
 		}
 	}
 	
-	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>();
@@ -683,13 +661,7 @@ public class TaskThread implements Runnable{
 		//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 {
@@ -701,44 +673,152 @@ public class TaskThread implements Runnable{
 		
 		//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
diff --git a/ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/collector/alarm/AlarmTaskThread.java b/ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/collector/alarm/AlarmTaskThread.java
index d03fd4b..3d74045 100644
--- a/ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/collector/alarm/AlarmTaskThread.java
+++ b/ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/collector/alarm/AlarmTaskThread.java
@@ -61,16 +61,18 @@ public class AlarmTaskThread extends Thread{
 	}
 
 	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();
 				}
@@ -80,37 +82,7 @@ public class AlarmTaskThread extends Thread{
 		}
 	}
 	
-	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 {
 
@@ -150,6 +122,10 @@ public class AlarmTaskThread extends Thread{
 				log.debug("received alarm message");
 				retString =  msg.getBody();
 			}
+			
+			if(retString == null){
+				Thread.sleep(100);
+			}
 		}
 		return retString;
 	}
diff --git a/ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/commons/constant/Constant.java b/ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/commons/constant/Constant.java
index c6edaf1..6c08879 100644
--- a/ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/commons/constant/Constant.java
+++ b/ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/commons/constant/Constant.java
@@ -25,16 +25,16 @@ public class Constant {
 	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";
diff --git a/ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/commons/ftp/AFtpRemoteFile.java b/ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/commons/ftp/AFtpRemoteFile.java
index 336c5a3..5f7569d 100644
--- a/ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/commons/ftp/AFtpRemoteFile.java
+++ b/ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/commons/ftp/AFtpRemoteFile.java
@@ -16,8 +16,6 @@
 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;
@@ -34,9 +32,6 @@ public class AFtpRemoteFile implements RemoteFile{
 		this.currDir = currDir;
 	}
 	
-	public long getSize() {
-		return ftpFile.getSize();
-	}
 	
 	public String getFileName() {
 		return ftpFile.getName();
@@ -45,37 +40,4 @@ public class AFtpRemoteFile implements RemoteFile{
 	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
diff --git a/ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/commons/ftp/FTPInterface.java b/ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/commons/ftp/FTPInterface.java
index 6b76fbf..ee9c3fb 100644
--- a/ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/commons/ftp/FTPInterface.java
+++ b/ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/commons/ftp/FTPInterface.java
@@ -38,8 +38,8 @@ public interface FTPInterface {
     
     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);
    
 }
diff --git a/ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/commons/ftp/FTPSrv.java b/ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/commons/ftp/FTPSrv.java
index 514ed60..d008a43 100644
--- a/ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/commons/ftp/FTPSrv.java
+++ b/ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/commons/ftp/FTPSrv.java
@@ -53,7 +53,7 @@ public class FTPSrv implements FTPInterface{
 		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);
@@ -163,37 +163,31 @@ public class FTPSrv implements FTPInterface{
 		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;
+//	}
 	
 }
 
diff --git a/ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/commons/model/CrontabVo.java b/ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/commons/model/CrontabVo.java
new file mode 100644
index 0000000..e76b039
--- /dev/null
+++ b/ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/commons/model/CrontabVo.java
@@ -0,0 +1,121 @@
+/**
+ * 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;
+	}
+	
+	
+
+	
+}
diff --git a/ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/commons/model/EMSInfo.java b/ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/commons/model/EMSInfo.java
index c0a4618..1a2b5d4 100644
--- a/ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/commons/model/EMSInfo.java
+++ b/ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/commons/model/EMSInfo.java
@@ -22,6 +22,7 @@ public class EMSInfo {
 	
 	private String name;
 	
+	
 	private Map<String,CollectVo> collectMap = new HashMap<String,CollectVo>();
 
 	/**
@@ -39,8 +40,7 @@ public class EMSInfo {
 	}
 
 	public CollectVo getCollectVoByType(String type){
-		CollectVo collectVo = null;
-		collectVo = this.collectMap.get(type);
+		CollectVo collectVo = this.collectMap.get(type);
 		return collectVo;
 	}
 	
diff --git a/ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/commons/utils/DateUtil.java b/ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/commons/utils/DateUtil.java
new file mode 100644
index 0000000..c0fddad
--- /dev/null
+++ b/ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/commons/utils/DateUtil.java
@@ -0,0 +1,60 @@
+/**
+ * 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};
+	}
+
+}
diff --git a/ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/commons/utils/VarExprParser.java b/ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/commons/utils/VarExprParser.java
new file mode 100644
index 0000000..309a856
--- /dev/null
+++ b/ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/commons/utils/VarExprParser.java
@@ -0,0 +1,137 @@
+/**
+ * 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;
+    }
+}
diff --git a/ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/configmgr/ConfigurationManager.java b/ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/configmgr/ConfigurationManager.java
index 8e9e0bf..b7346b5 100644
--- a/ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/configmgr/ConfigurationManager.java
+++ b/ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/configmgr/ConfigurationManager.java
@@ -26,38 +26,145 @@ import java.util.Map;
 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>();
 	    
@@ -67,6 +174,7 @@ public class ConfigurationManager extends DriverThread{
 			
 			Element root = doc.getRootElement();
 			
+			@SuppressWarnings("unchecked")
 			List<Element> children = root.getChildren();
 			
 			for(Iterator<Element> it = children.iterator();it.hasNext();){
@@ -78,8 +186,9 @@ public class ConfigurationManager extends DriverThread{
 				}
 				emsInfo.setName(name);
 				
-				tmpcache.put(name, emsInfo);
+//				tmpcache.put(name, emsInfo);
 				
+				@SuppressWarnings("unchecked")
 				List<Element> collectList = child.getChildren();
 				for(Element collect : collectList){
 					
@@ -124,6 +233,19 @@ public class ConfigurationManager extends DriverThread{
 			}
 			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{
@@ -137,32 +259,9 @@ public class ConfigurationManager extends DriverThread{
 			}
 			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()){
@@ -180,5 +279,141 @@ public class ConfigurationManager extends DriverThread{
 		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;
+		}
+	}
 }
diff --git a/ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/northbound/client/NorthMessageMgr.java b/ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/northbound/client/NorthMessageMgr.java
index 79220ec..83a785f 100644
--- a/ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/northbound/client/NorthMessageMgr.java
+++ b/ems/boco/src/main/java/org/onap/vfc/nfvo/emsdriver/northbound/client/NorthMessageMgr.java
@@ -15,31 +15,106 @@
  */
 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();
 		
@@ -58,13 +133,15 @@ public class NorthMessageMgr extends DriverThread{
 						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) {
@@ -72,6 +149,77 @@ public class NorthMessageMgr extends DriverThread{
 				}
 			}
 		}
+
+		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{
@@ -101,11 +249,75 @@ public class NorthMessageMgr extends DriverThread{
 					}
 					
 				} 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
diff --git a/ems/boco/src/test/java/org/onap/vfc/nfvo/emsdriver/collector/TaskThreadTest.java b/ems/boco/src/test/java/org/onap/vfc/nfvo/emsdriver/collector/TaskThreadTest.java
index 59dd737..4fd62b2 100644
--- a/ems/boco/src/test/java/org/onap/vfc/nfvo/emsdriver/collector/TaskThreadTest.java
+++ b/ems/boco/src/test/java/org/onap/vfc/nfvo/emsdriver/collector/TaskThreadTest.java
@@ -45,7 +45,7 @@ public class TaskThreadTest {
 	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);
 		}
 	}
diff --git a/ems/boco/src/test/java/org/onap/vfc/nfvo/emsdriver/collector/alarm/AlarmTaskThreadTest.java b/ems/boco/src/test/java/org/onap/vfc/nfvo/emsdriver/collector/alarm/AlarmTaskThreadTest.java
index fe8a28b..c657c19 100644
--- a/ems/boco/src/test/java/org/onap/vfc/nfvo/emsdriver/collector/alarm/AlarmTaskThreadTest.java
+++ b/ems/boco/src/test/java/org/onap/vfc/nfvo/emsdriver/collector/alarm/AlarmTaskThreadTest.java
@@ -35,8 +35,8 @@ public class AlarmTaskThreadTest {
 	@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);
 	}
 		
 }
diff --git a/ems/boco/src/test/java/org/onap/vfc/nfvo/emsdriver/configmgr/ConfigurationImpTest.java b/ems/boco/src/test/java/org/onap/vfc/nfvo/emsdriver/configmgr/ConfigurationImpTest.java
index 35911cb..9037bde 100644
--- a/ems/boco/src/test/java/org/onap/vfc/nfvo/emsdriver/configmgr/ConfigurationImpTest.java
+++ b/ems/boco/src/test/java/org/onap/vfc/nfvo/emsdriver/configmgr/ConfigurationImpTest.java
@@ -38,7 +38,7 @@ public class ConfigurationImpTest {
     public void setUp() throws IOException {
 		configurationImp = new ConfigurationImp();
 		configurationManager = new ConfigurationManager();
-		configurationManager.dispose();
+		configurationManager.readcfg();
     }
 	
 	@Test
diff --git a/ems/boco/src/test/java/org/onap/vfc/nfvo/emsdriver/configmgr/ConfigurationManagerTest.java b/ems/boco/src/test/java/org/onap/vfc/nfvo/emsdriver/configmgr/ConfigurationManagerTest.java
index e2e5df6..68ff99d 100644
--- a/ems/boco/src/test/java/org/onap/vfc/nfvo/emsdriver/configmgr/ConfigurationManagerTest.java
+++ b/ems/boco/src/test/java/org/onap/vfc/nfvo/emsdriver/configmgr/ConfigurationManagerTest.java
@@ -33,7 +33,7 @@ public class ConfigurationManagerTest {
 	@Before
     public void setUp() throws IOException {
 		configurationManager = new ConfigurationManager();
-		configurationManager.dispose();
+		configurationManager.readcfg();
     }
 	
 	@Test
diff --git a/ems/boco/src/test/java/org/onap/vfc/nfvo/emsdriver/serviceregister/MsbConfigurationTest.java b/ems/boco/src/test/java/org/onap/vfc/nfvo/emsdriver/serviceregister/MsbConfigurationTest.java
new file mode 100644
index 0000000..e3398d7
--- /dev/null
+++ b/ems/boco/src/test/java/org/onap/vfc/nfvo/emsdriver/serviceregister/MsbConfigurationTest.java
@@ -0,0 +1,32 @@
+/**
+ * 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();
+	}
+
+}
diff --git a/ems/boco/src/test/java/org/onap/vfc/nfvo/emsdriver/serviceregister/MsbRestServiceProxyTest.java b/ems/boco/src/test/java/org/onap/vfc/nfvo/emsdriver/serviceregister/MsbRestServiceProxyTest.java
new file mode 100644
index 0000000..672c95d
--- /dev/null
+++ b/ems/boco/src/test/java/org/onap/vfc/nfvo/emsdriver/serviceregister/MsbRestServiceProxyTest.java
@@ -0,0 +1,36 @@
+/**
+ * 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);
+	}
+}
diff --git a/ems/boco/src/test/java/org/onap/vfc/nfvo/emsdriver/serviceregister/model/MsbRegisterVoTest.java b/ems/boco/src/test/java/org/onap/vfc/nfvo/emsdriver/serviceregister/model/MsbRegisterVoTest.java
new file mode 100644
index 0000000..da51a9f
--- /dev/null
+++ b/ems/boco/src/test/java/org/onap/vfc/nfvo/emsdriver/serviceregister/model/MsbRegisterVoTest.java
@@ -0,0 +1,51 @@
+/**
+ * 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();
+    	
+    }
+
+}
diff --git a/ems/boco/src/test/java/org/onap/vfc/nfvo/emsdriver/serviceregister/model/ServiceNodeVoTest.java b/ems/boco/src/test/java/org/onap/vfc/nfvo/emsdriver/serviceregister/model/ServiceNodeVoTest.java
new file mode 100644
index 0000000..6c4b98f
--- /dev/null
+++ b/ems/boco/src/test/java/org/onap/vfc/nfvo/emsdriver/serviceregister/model/ServiceNodeVoTest.java
@@ -0,0 +1,42 @@
+/**
+ * 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());
+    }
+
+}
diff --git a/ems/microservice-standalone/src/main/assembly/conf/config.properties b/ems/microservice-standalone/src/main/assembly/conf/config.properties
new file mode 100644
index 0000000..7a946d0
--- /dev/null
+++ b/ems/microservice-standalone/src/main/assembly/conf/config.properties
@@ -0,0 +1,39 @@
+
+# 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
diff --git a/ems/microservice-standalone/src/main/assembly/conf/crontab.xml b/ems/microservice-standalone/src/main/assembly/conf/crontab.xml
new file mode 100644
index 0000000..0d7f591
--- /dev/null
+++ b/ems/microservice-standalone/src/main/assembly/conf/crontab.xml
@@ -0,0 +1,32 @@
+<?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
diff --git a/ems/microservice-standalone/src/main/assembly/lib/VESLibrary.jar b/ems/microservice-standalone/src/main/assembly/lib/VESLibrary.jar
new file mode 100644
index 0000000..ef9de52
Binary files /dev/null and b/ems/microservice-standalone/src/main/assembly/lib/VESLibrary.jar differ
diff --git a/ems/microservice-standalone/src/main/assembly/lib/dependencies-all.jar b/ems/microservice-standalone/src/main/assembly/lib/dependencies-all.jar
new file mode 100644
index 0000000..725a4be
Binary files /dev/null and b/ems/microservice-standalone/src/main/assembly/lib/dependencies-all.jar differ