Merge branch 'master' of http://git.yoho.cn/ops/monitor-service

+package com.monitor.common.config;
+
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Component;
+
+@Component("sendsmsConfig")
+public class SendsmsConfig {
+
+	@Value("${sendsms.url}")
+	private String sendsmsUrl;// url
+
+	@Value("${sendsms.username}")
+	private String userName;// 用户名
+
+	@Value("${sendsms.pwd}")
+	private String pwd;// 密码
+
+	@Value("${sendsms.notice.productid}")
+	private String noticeProductid;// 产品id
+
+	public String getSendsmsUrl() {
+		return sendsmsUrl;
+	}
+
+	public String getUserName() {
+		return userName;
+	}
+
+	public String getPwd() {
+		return pwd;
+	}
+
+	public String getNoticeProductid() {
+		return noticeProductid;
+	}
+}

+package com.monitor.common.config;
+
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Component;
+
+/**
+ * 告警任务的短信号码 Created by yoho on 2016/5/4.
+ */
+@Component("snsMobileConfig")
+public class SnsMobileConfig {
+
+	/********************** 支付回调手机号 **********************/
+
+	@Value("${sendsms.alarm.paycallback}")
+	private String payCallBack;
+
+	/********************** 支付回调手机号 ********************/
+
+	/********************* 订单异常手机号 ***********************/
+
+	@Value("${sendsms.alarm.mobile.orderexception}")
+	private String orderException;
+
+	/********************* 订单异常手机号 ***********************/
+
+	/******************* 用户行为异常手机号 ***************/
+
+	@Value("${sendsms.alarm.mobile.userbehaviour}")
+	private String userBehaviour;
+
+	/******************** 用户行为异常手机号 **************/
+
+	/******************** 数据库异常手机号 *************/
+	@Value("${sendsms.alarm.mobile.dbexception}")
+	private String dbException;
+
+	/******************* 数据库异常手机号 **************/
+
+	/****************** 服务异常告警手机号 ***************/
+	@Value("${sendsms.alarm.mobile.serviceexception.product}")
+	private String serviceExcptnProduct;
+
+	@Value("${sendsms.alarm.mobile.serviceexception.search}")
+	private String serviceExcptnSearch;
+
+	@Value("${sendsms.alarm.mobile.serviceexception.guang}")
+	private String serviceExcptnGuang;
+
+	@Value("${sendsms.alarm.mobile.serviceexception.users}")
+	private String serviceExcptnUsers;
+
+	@Value("${sendsms.alarm.mobile.serviceexception.order}")
+	private String serviceExcptnOrder;
+
+	@Value("${sendsms.alarm.mobile.serviceexception.sns}")
+	private String serviceExcptnSns;
+
+	@Value("${sendsms.alarm.mobile.serviceexception.promotion}")
+	private String serviceExcptnPromotion;
+
+	@Value("${sendsms.alarm.mobile.serviceexception.message}")
+	private String serviceExcptnMessage;
+
+	@Value("${sendsms.alarm.mobile.serviceexception.resources}")
+	private String serviceExcptnResources;
+
+	/******************** 服务异常告警手机号 ******************/
+
+	/********************Monitor模块告警手机号************************/
+	@Value("${sendsms.alarm.mobile.monitor.exception}")
+	private String monitorException;
+	/********************Monitor模块告警手机号************************/
+
+	/*******************Logs模块告警手机号************************/
+	@Value("${sendsms.alarm.mobile.logs.sns_send_failed}")
+	private String logsSnsSendFailed;
+	/*******************Logs模块告警手机号************************/
+
+	/*********************OpsManager开发程序员 手机号***************************/
+	@Value("${sendsms.alarm.mobile.ops_manager.developer}")
+	private String opsManagerDeveloper;
+	/*********************OpsManager开发程序员 手机号***************************/
+
+
+	/**
+	 * dnspod sms
+	 */
+	@Value("${dnspod.mobile}")
+	private String dnspodMobile;
+	
+	/**
+	 * switch nginxConfig sms
+	 */
+	@Value("${nginx.config.switch.mobile}")
+	private String switchNginxConfigMobile;
+	
+	/**
+	 * jmxtrans sms
+	 */
+	@Value("${jmxtrans.mobile}")
+	private String jmxtransMobile;
+
+	@Value("${orderinfocheck.mobile}")
+	private String orderinfocheckMobile;
+
+	@Value("${base_mobile}")
+	private String baseMobile;
+
+	public String getOrderinfocheckMobile() {
+		return orderinfocheckMobile;
+	}
+
+	public String getPayCallBack() {
+		return payCallBack;
+	}
+
+	public String getOrderException() {
+		return orderException;
+	}
+
+	public String getUserBehaviour() {
+		return userBehaviour;
+	}
+
+	public String getDbException() {
+		return dbException;
+	}
+
+	public String getServiceExcptnProduct() {
+		return serviceExcptnProduct;
+	}
+
+	public String getServiceExcptnSearch() {
+		return serviceExcptnSearch;
+	}
+
+	public String getServiceExcptnGuang() {
+		return serviceExcptnGuang;
+	}
+
+	public String getServiceExcptnUsers() {
+		return serviceExcptnUsers;
+	}
+
+	public String getServiceExcptnOrder() {
+		return serviceExcptnOrder;
+	}
+
+	public String getServiceExcptnSns() {
+		return serviceExcptnSns;
+	}
+
+	public String getServiceExcptnPromotion() {
+		return serviceExcptnPromotion;
+	}
+
+	public String getServiceExcptnMessage() {
+		return serviceExcptnMessage;
+	}
+
+	public String getServiceExcptnResources() {
+		return serviceExcptnResources;
+	}
+
+	public String getDnspodMobile() {
+		return dnspodMobile;
+	}
+
+	public void setDnspodMobile(String dnspodMobile) {
+		this.dnspodMobile = dnspodMobile;
+	}
+
+	public String getJmxtransMobile() {
+		return jmxtransMobile;
+	}
+
+	public void setJmxtransMobile(String jmxtransMobile) {
+		this.jmxtransMobile = jmxtransMobile;
+	}
+
+	public String getSwitchNginxConfigMobile() {
+		return switchNginxConfigMobile;
+	}
+
+	public void setSwitchNginxConfigMobile(String switchNginxConfigMobile) {
+		this.switchNginxConfigMobile = switchNginxConfigMobile;
+	}
+
+	public String getOpsManagerDeveloper() {
+		return opsManagerDeveloper;
+	}
+
+	public String getMonitorException() {
+		return monitorException;
+	}
+
+	public String getLogsSnsSendFailed() {
+		return logsSnsSendFailed;
+	}
+
+	public String getBaseMobile() {
+		return baseMobile;
+	}
+
+	public void setBaseMobile(String baseMobile) {
+		this.baseMobile = baseMobile;
+	}
+}

+package com.monitor.common.service;
+
+/**
+ * Created by zhengyouwei on 2016/5/26.
+ */
+public interface AlarmMsgService {
+
+    public boolean sendSms(String content, String mobile);
+}

+package com.monitor.common.service;
+
+import java.util.Map;
+
+public interface HttpRestClientService {
+	
+	public String doPostStringJson(String url, String string);
+	
+	public String doGet(final String uri, final Map<String, String> content);
+
+	public <T> T postForObject(String url, Object request, Class<T> responseType);
+
+
+	}

+package com.monitor.common.service.impl;
+
+import com.alibaba.fastjson.JSONArray;
+import com.monitor.common.config.SendsmsConfig;
+import com.monitor.common.config.SnsMobileConfig;
+import com.monitor.common.service.AlarmMsgService;
+import com.monitor.common.service.HttpRestClientService;
+
+
+import com.monitor.common.util.DateFormatUtil;
+import com.monitor.common.util.MD5Util;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.io.UnsupportedEncodingException;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.concurrent.atomic.AtomicInteger;
+
+/**
+ * Created by yoho on 2016/5/3.
+ */
+@Service("alarmMsgService")
+public class AlarmMsgServiceImpl implements AlarmMsgService {
+
+    @Autowired
+    private HttpRestClientService httpRestClientService;
+
+    @Autowired
+    private SendsmsConfig sendsmsConfig;
+
+    @Autowired
+    private SnsMobileConfig snsMobileConfig;
+
+    private Logger logger = LoggerFactory.getLogger(AlarmMsgServiceImpl.class);
+
+    private static final int CONTENT_SUB_LENGTH = 250;
+
+    private static AtomicInteger atomicInteger = new AtomicInteger(1);
+
+    /**
+     * 发送短信
+     *
+     * @throws UnsupportedEncodingException
+     */
+    @Override
+    public boolean sendSms(String content, String mobile) {
+        Integer smsid = atomicInteger.getAndIncrement();// 短信ID
+
+        Map<String, String> contentMap = new HashMap<String, String>();
+        contentMap.put("username", sendsmsConfig.getUserName());
+        contentMap.put("password", MD5Util.encryption(sendsmsConfig.getPwd()));
+        contentMap.put("mobile", mobile);
+        contentMap.put("productid", sendsmsConfig.getNoticeProductid());
+
+        boolean sendStatus = true;
+
+        // 如果短信内容不超过指定字符字符，则单条发送，如果超过，则分割多条发送
+        while (content.length() > CONTENT_SUB_LENGTH) {
+            String contentSubStr = content.substring(0, CONTENT_SUB_LENGTH);
+            content = content.substring(CONTENT_SUB_LENGTH);
+
+            // 发送被切割的字符串
+            contentMap.put("content", contentSubStr);
+            boolean sendSingleSmsStatus = sendSingleSms(contentMap, smsid);
+
+            if (sendSingleSmsStatus == false) {
+                sendStatus = false;
+            }
+        }
+
+        contentMap.put("content", content);
+        boolean sendSingleSmsStatus = sendSingleSms(contentMap, smsid);
+        if (sendSingleSmsStatus == false) {
+            sendStatus = false;
+        }
+        return sendStatus;
+    }
+
+    /**
+     * 发送单条短信
+     *
+     * @param smsMap
+     * @return
+     */
+    private boolean sendSingleSms(Map<String, String> smsMap, Integer smsid) {
+        smsMap.put("content", "【有货运维】" + smsMap.get("content") + " | time:" + DateFormatUtil.getYYYY_MM_DD_HH_MM_SS() + ",id:" + smsid.intValue());
+        String result = httpRestClientService.doGet(sendsmsConfig.getSendsmsUrl(), smsMap);
+
+        if (result == null || !"1".equals(result.split(",")[0])) {
+            logger.error("发送短信失败,短信内容|" + JSONArray.toJSONString(smsMap));
+
+            smsMap.put("content", "【有货运维】发送短信告警失败！！！");
+            smsMap.put("mobile", snsMobileConfig.getOpsManagerDeveloper());
+            // 短信发送失败 发送短信给开发回来改bug
+            httpRestClientService.doGet(sendsmsConfig.getSendsmsUrl(), smsMap);
+            return false;
+        }
+        return true;
+    }
+}

+package com.monitor.common.service.impl;
+
+
+import com.monitor.common.service.HttpRestClientService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.HttpEntity;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.MediaType;
+import org.springframework.stereotype.Service;
+import org.springframework.web.client.RestTemplate;
+
+import java.util.Map;
+
+@Service("httpRestClientService")
+public class HttpRestClientServiceImpl implements HttpRestClientService {
+
+    private static final Logger logger = LoggerFactory
+            .getLogger(HttpRestClientServiceImpl.class);
+
+    @Autowired
+    private RestTemplate restTemplate;
+
+    private final static String ASK = "?";
+
+    private final static String AND = "&";
+
+    @Override
+    public String doPostStringJson(String url, String args) {
+        try {
+            HttpHeaders headers = new HttpHeaders();
+            headers.setContentType(MediaType.APPLICATION_JSON);
+            HttpEntity<String> entity = new HttpEntity<String>(args, headers);
+            String result = restTemplate.postForObject(url, entity,
+                    String.class);
+            return result;
+        } catch (Exception e) {
+            logger.error("doPostStringJson failed!", e);
+            return null;
+        }
+    }
+
+    @Override
+    public String doGet(final String uri, final Map<String, String> content) {
+        String result = null;
+        try {
+            if (content != null) {
+                StringBuilder url = new StringBuilder(uri);
+                url.append(ASK);
+                for (Map.Entry<String, String> entry : content.entrySet()) {
+                    url.append(entry.getKey() + "=" + entry.getValue() + AND);
+                }
+                result = restTemplate.getForObject(url.toString().substring(0, url.length() - 1), String.class);
+            } else {
+                result = restTemplate.getForObject(uri, String.class);
+            }
+        } catch (Exception e) {
+            logger.error("doGet failed!", e);
+        }
+        return result;
+    }
+
+    @Override
+    public <T> T postForObject(String url, Object request, Class<T> responseType) {
+        try {
+            return restTemplate.postForObject(url, request,
+                    responseType);
+        } catch (Exception e) {
+            logger.error("doPostStringJson failed!url:" + url, e);
+            return null;
+        }
+    }
+
+}

+package com.monitor.common.util;
+
+/**
+ * Created by zhengyouwei on 2016/6/21.
+ */
+public class ClientReportUtil {
+
+    public static String getTableName(String et,String uid){
+        return "client_error_" + et + "_" + uid.charAt(uid.length() - 1);
+    }
+
+}

+package com.monitor.common.util;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.text.ParseException;
+import java.text.SimpleDateFormat;
+import java.util.Calendar;
+import java.util.Date;
+import java.util.Locale;
+import java.util.TimeZone;
+
+/**
+ * 负责时间格式转换
+ * @author yoho
+ *
+ */
+public class DateFormatUtil {
+
+	private static final String YYYYMMDD = "yyyyMMdd";
+
+	private static final String HHMMSS = "HHmmss";
+	
+	private static final String YYYYMMDDHHMMSS = "yyyyMMddHHmmss";
+	
+	private static final String YYYY_MM_DD_HH_MM_SS = "yyyy-MM-dd HH:mm:ss";
+	
+	private static final String INFLUXDB_TIME_PATTEN = "yyyy-MM-dd'T'HH:mm:ss.SSS'Z'";
+
+	private static final String INFLUXDB_TIME_NANO_PATTEN = "yyyy-MM-dd'T'HH:mm:ss'Z'";
+	
+	private static final Logger logger = LoggerFactory.getLogger(DateFormatUtil.class);
+	
+
+	public static String getYYYYMMDD() {
+		return new SimpleDateFormat(YYYYMMDD).format(new Date());
+	}
+
+	public static String getHHmmss() {
+		return new SimpleDateFormat(HHMMSS).format(new Date());
+	}
+
+	public static String getYYYYMMDDByCalendar(Calendar ca) {
+		return new SimpleDateFormat(YYYYMMDD).format(ca.getTime());
+	}
+	
+	public static String getYYYYMMDDHHMMSS() {
+		return new SimpleDateFormat(YYYYMMDDHHMMSS).format(new Date());
+	}
+	public static String getYYYY_MM_DD_HH_MM_SS() {
+		return new SimpleDateFormat(YYYY_MM_DD_HH_MM_SS).format(new Date());
+	}
+
+	/**
+	 * 将influxDB中的时间格式转换为格式yyyy-MM-dd HH:mm:ss
+	 * @param date
+	 * @return
+	 */
+	public static String displayFormat(String date) {
+		return displayFormatWithDateTail(date);
+	}
+
+	public static String displayFormatWithDateTail(String date) {
+		String dateWithoutTail = date.substring(0, 19) + "Z";
+		SimpleDateFormat simpleDateFormat = new SimpleDateFormat(INFLUXDB_TIME_NANO_PATTEN);
+		simpleDateFormat.setTimeZone(TimeZone.getTimeZone("UTC"));
+		try {
+			Date d = simpleDateFormat.parse(dateWithoutTail);
+			Calendar calendar = Calendar.getInstance(TimeZone.getTimeZone("Asia/Shanghai"));
+			calendar.setTime(d);
+
+			SimpleDateFormat s = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+			return s.format(calendar.getTime());
+		} catch (ParseException e) {
+			logger.debug("method:displayFormat args:"+date + "  "+ e.toString());
+			return "";
+		}
+	}
+	
+	/**
+	 * 将毫秒数格式化为influxDB时间格式的字符串 yyyy-MM-dd'T'HH:mm:ss.SSS'Z'
+	 * @param timeMsec
+	 * @return
+	 */
+	public static String influxDBTimeFormat(String timeMsec) {
+		SimpleDateFormat simpleDateFormat = new SimpleDateFormat(INFLUXDB_TIME_PATTEN, Locale.GERMAN);
+		simpleDateFormat.setTimeZone(TimeZone.getTimeZone("UTC"));
+		try{
+			Date date = new Date(Long.parseLong(timeMsec));	
+			return simpleDateFormat.format(date);
+		}catch (Exception e) {
+			logger.debug("method:displayFormat timeMsec:"+timeMsec + "  "+ e.toString());
+			return "";
+		}
+	}
+	
+	public static String influxDBTimeFormat(long timeMsec) {
+		SimpleDateFormat simpleDateFormat = new SimpleDateFormat(INFLUXDB_TIME_PATTEN, Locale.GERMAN);
+		simpleDateFormat.setTimeZone(TimeZone.getTimeZone("UTC"));
+		try{
+			Date date = new Date(timeMsec);	
+			return simpleDateFormat.format(date);
+		}catch (Exception e) {
+			logger.debug("method:displayFormat timeMsec:"+timeMsec + "  "+ e.toString());
+			return null;
+		}
+	}
+	
+	public static String parseLongTo14(long time){
+		SimpleDateFormat simpleDateFormat = new SimpleDateFormat(YYYYMMDDHHMMSS);
+		return simpleDateFormat.format(new Date(time));
+	}
+}

+package com.monitor.common.util;
+
+import org.apache.http.client.config.RequestConfig;
+import org.apache.http.client.methods.CloseableHttpResponse;
+import org.apache.http.client.methods.HttpGet;
+import org.apache.http.client.methods.HttpPost;
+import org.apache.http.entity.StringEntity;
+import org.apache.http.impl.client.CloseableHttpClient;
+import org.apache.http.impl.client.HttpClients;
+import org.apache.http.message.BasicHeader;
+import org.apache.http.protocol.HTTP;
+import org.apache.http.util.EntityUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import javax.servlet.http.HttpServletRequest;
+import java.io.IOException;
+import java.util.Base64;
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * 发送短信
+ * 
+ * @author yoho
+ *
+ */
+public class HttpClientUtil {
+	
+	private static final Logger logger = LoggerFactory.getLogger(HttpClientUtil.class);
+
+	private final static Integer CONNECT_TIME_OUT = 10 * 1000;
+
+	private final static Integer CONNECT_REQUEST_TIME_OUT = 5 * 1000;
+
+	private final static Integer SOCKET_TIME_OUT = 30 * 1000;
+
+	private final static String ASK = "?";
+	
+	private final static String AND = "&";
+	
+	  private final static String UTF8 = "UTF-8";
+
+	    private final static String APPLICATION_JSON = "application/json; charset=UTF-8";
+
+	public static String doget(final String uri, final Map<String, String> content,final Map<String, String> header) {
+		String strResult = "";
+		RequestConfig defaultRequestConfig = RequestConfig
+				.custom()
+				.setSocketTimeout(SOCKET_TIME_OUT.intValue())
+				.setConnectTimeout(CONNECT_TIME_OUT.intValue())
+				.setConnectionRequestTimeout(CONNECT_REQUEST_TIME_OUT.intValue()).build();
+		CloseableHttpClient client = HttpClients.custom().setDefaultRequestConfig(defaultRequestConfig).build();
+		HttpGet get = null;
+		try {
+			StringBuilder url = new StringBuilder(uri);
+			if(content != null){
+				url.append(ASK);
+				for (Map.Entry<String, String> entry : content.entrySet()) {
+					url.append(entry.getKey()+"="+entry.getValue()+AND);
+				}
+	            get = new HttpGet(url.toString().substring(0, url.length()-1));
+			}else{
+	            get = new HttpGet(url.toString());
+			}
+			if (header != null) {
+				for (Map.Entry<String, String> entry : header.entrySet()) {
+					get.setHeader(entry.getKey(), entry.getValue());
+				}
+			}
+			CloseableHttpResponse response = client.execute(get);
+			int statusCode = response.getStatusLine().getStatusCode();
+			if (200 == statusCode) {
+				strResult = EntityUtils.toString(response.getEntity()).trim();
+			} else {
+				logger.error("|HttpClientUtil|doGet|error status|", statusCode);
+			}
+		} catch (IOException e) {
+			logger.error("|HttpClientUtil|doGet|", e);
+		} finally {
+			if (get != null) {
+				get.releaseConnection();
+			}
+			if (client != null) {
+				try {
+					client.close();
+				} catch (IOException e) {
+					logger.error("|HttpClientUtil|doGet|", e);
+				}
+			}
+		}
+		return strResult;
+	}
+
+	 public static String doPost(final String uri, final String args, Map<String, String> header) {
+	        String strResult = "";
+	        RequestConfig defaultRequestConfig = RequestConfig.custom()
+	                .setSocketTimeout(SOCKET_TIME_OUT.intValue())
+	                .setConnectTimeout(CONNECT_TIME_OUT.intValue())
+	                .setConnectionRequestTimeout(CONNECT_REQUEST_TIME_OUT.intValue())
+	                .build();
+	        CloseableHttpClient client = HttpClients.custom().setDefaultRequestConfig(defaultRequestConfig).build();
+	        HttpPost post = new HttpPost(uri);
+	        if (header != null) {
+	            for (Map.Entry<String, String> entry : header.entrySet()) {
+	                post.setHeader(entry.getKey(), entry.getValue());
+	            }
+	        }
+
+	        StringEntity se = null;
+	        try {
+	            se = new StringEntity(args, UTF8);
+	        } catch (Exception e) {
+	            logger.error("|HttpClientUtil|doPost|", e);
+	        }
+	        //se.setContentEncoding(new BasicHeader(HTTP.CONTENT_TYPE, APPLICATION_JSON));
+	        //se.setContentType(APPLICATION_JSON);
+	        post.setEntity(se);
+	        CloseableHttpResponse response = null;
+	        try {
+	            response = client.execute(post);
+	            int statusCode = response.getStatusLine().getStatusCode();
+	            if (200 == statusCode) {
+	                strResult = new String(EntityUtils.toByteArray(response.getEntity()), UTF8);
+	            } else {
+	                logger.error("|HttpClientUtil|doPost|error status|", statusCode);
+	            }
+	        } catch (IOException e) {
+	            logger.error("|HttpClientUtil|doPost|", e);
+	        } finally {
+	            if (post != null) {
+	                post.releaseConnection();
+	            }
+	            if (client != null) {
+	            	try {
+						client.close();
+					} catch (IOException e) {
+						logger.error("|HttpClientUtil|doPost|", e);
+					}
+	            }
+	        }
+	        return strResult;
+	    }
+	 
+	 public static String opentsdbPut(final String uri, final String args) {
+	        String strResult = "";
+	        RequestConfig defaultRequestConfig = RequestConfig.custom()
+	                .setSocketTimeout(SOCKET_TIME_OUT.intValue())
+	                .setConnectTimeout(CONNECT_TIME_OUT.intValue())
+	                .setConnectionRequestTimeout(CONNECT_REQUEST_TIME_OUT.intValue())
+	                .build();
+	        CloseableHttpClient client = HttpClients.custom().setDefaultRequestConfig(defaultRequestConfig).build();
+	        HttpPost post = new HttpPost(uri);	       
+
+	        StringEntity se = null;
+	        try {
+	            se = new StringEntity(args, UTF8);
+	        } catch (Exception e) {
+	            logger.error("|HttpClientUtil|opentsdbPut|", e);
+	        }
+	        se.setContentEncoding(new BasicHeader(HTTP.CONTENT_TYPE, APPLICATION_JSON));
+	        se.setContentType(APPLICATION_JSON);
+	        post.setEntity(se);
+	        CloseableHttpResponse response = null;
+	        try {
+	            response = client.execute(post);
+	            int statusCode = response.getStatusLine().getStatusCode();
+	            if (204 != statusCode) {
+	                logger.error("|HttpClientUtil|opentsdbPut|error status|", statusCode);
+	            }
+	        } catch (IOException e) {
+	            logger.error("|HttpClientUtil|opentsdbPut|", e);
+	        } finally {
+	            if (post != null) {
+	                post.releaseConnection();
+	            }
+	            if (client != null) {
+	            	try {
+						client.close();
+					} catch (IOException e) {
+						logger.error("|HttpClientUtil|opentsdbPut|", e);
+					}
+	            }
+	        }
+	        return strResult;
+	    }
+	 
+	 /**
+     * main函数.
+     * @param args
+     *            启动参数
+     * @throws Exception
+     *             Exception
+     */
+    public static void main(String... args) throws Exception {
+    	final String plainCreds = "yoho:yoho";
+    	final byte[] plainCredsBytes = plainCreds.getBytes();
+    	final byte[] base64CredsBytes = Base64.getEncoder().encode(plainCredsBytes);
+    	final String base64Creds = new String(base64CredsBytes);
+    	Map<String,String> map = new HashMap<String,String>();
+    	map.put("Authorization", "Basic "+ base64Creds);
+    	
+    	String result = doget("http://192.168.102.211:15672/api/vhosts", null, map);	
+    	System.out.println(result);
+    }
+	
+    public static String getRemortIP(HttpServletRequest request) {
+		if (request.getHeader("x-forwarded-for") == null) {
+			return request.getRemoteAddr();
+		}
+		return request.getHeader("x-forwarded-for");
+	}
+}

+package com.monitor.common.util;
+
+import java.security.MessageDigest;
+import java.security.NoSuchAlgorithmException;
+
+public class MD5Util {
+	 /** 
+     *  
+     * @param plain  明文 
+     * @return 32位小写密文 
+     */ 
+    public static String encryption(String plain) { 
+        String re_md5 = new String(); 
+        try { 
+            MessageDigest md = MessageDigest.getInstance("MD5"); 
+            md.update(plain.getBytes()); 
+            byte b[] = md.digest(); 
+ 
+            int i; 
+ 
+            StringBuffer buf = new StringBuffer(""); 
+            for (int offset = 0; offset < b.length; offset++) { 
+                i = b[offset]; 
+                if (i < 0) 
+                    i += 256; 
+                if (i < 16) 
+                    buf.append("0"); 
+                buf.append(Integer.toHexString(i)); 
+            } 
+ 
+            re_md5 = buf.toString(); 
+ 
+        } catch (NoSuchAlgorithmException e) { 
+            e.printStackTrace(); 
+        } 
+        return re_md5; 
+    } 
+ 
+} 

+package com.monitor.common.util;
+
+/**
+ * Created by yoho on 2016/6/2.
+ */
+public class PaginationUtil{
+
+    /**
+     * 根据数据量跟每个分页的数量 计算分页数
+     *
+     * @param count
+     * @param countOfEachPage
+     * @return
+     */
+    public static int getPageCount(int count, int countOfEachPage) {
+
+        //判断是否有余数，有余数则需要增加一页
+        int hasReminder = count % countOfEachPage == 0 ? 0 : 1;
+        return count / countOfEachPage + hasReminder;
+    }
+}

+package com.monitor.common.util;
+
+import org.influxdb.dto.QueryResult;
+import org.influxdb.dto.QueryResult.Series;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.util.List;
+
+public class QueryResultUtil {
+	
+	private static Logger logger = LoggerFactory.getLogger(QueryResultUtil.class);
+	
+	/**
+	 * 从查询结果中取values
+	 * @param queryResult
+	 * @return
+	 */
+	public static List<List<Object>> getValues(QueryResult queryResult) {
+				
+		try {
+			Series series = getSeries(queryResult).get(0);
+			List<List<Object>> values = series.getValues();
+			return values;
+		} catch (Exception e) {
+			return null;
+		}
+	}
+	
+	/**
+	 * 从查询结果中取Series
+	 * @param queryResult
+	 * @return
+	 */
+	public static List<Series> getSeries(QueryResult queryResult) {
+		try {   
+			List<Series> seriesList = queryResult.getResults().get(0).getSeries();
+			return seriesList;
+		} catch (Exception e) {
+			return null;
+		}
+	}
+
+	/**
+	 * 从QueryResult中取出count字段
+	 * @return
+	 */
+	public static int getCount(QueryResult queryResult) {
+		List<Series> series = getSeries(queryResult);
+		if (series == null) {
+			return 0;
+		}
+		return (int)(double)series.get(0).getValues().get(0).get(1);
+	}
+}

+package com.monitor.common.util;
+
+import java.util.concurrent.atomic.AtomicInteger;
+
+/**
+ * Created by zhengyouwei on 2016/6/22.
+ */
+public class ReportCount {
+
+    private static final AtomicInteger atomicInteger = new AtomicInteger(1);
+
+    private static int last = 0;
+
+    public static int getAndIncrement() {
+        return atomicInteger.getAndIncrement();
+    }
+
+    public static int getIncrement() {
+        int count = atomicInteger.get();
+        if (count == 0) {
+            return 0;
+        }
+        int increate = count - last;
+        last = count;
+        return increate;
+    }
+
+}

+package com.monitor.common.util;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+/**
+ * Created by yoho on 2016/6/2.
+ */
+public class ValueFormatUtil {
+
+    private static Logger logger = LoggerFactory.getLogger(ValueFormatUtil.class);
+
+    /**
+     * 将String转换成int
+     *
+     * @param intStr
+     * @param className
+     * @param methodName
+     * @return
+     */
+    public static int parseStringToInt(String intStr, String className, String methodName) {
+        try {
+            return Integer.valueOf(intStr);
+        } catch (Exception e) {
+            logger.error("parse page int from page string failure Class: " +
+                    className + "  method: " + methodName +
+                    " | error:" + e.toString());
+            return 0;
+        }
+    }
+}

@@ -2,10 +2,9 @@ package com.monitor.influxdb.mapper;
 
 import com.alibaba.fastjson.JSONObject;
 import com.monitor.model.domain.JavaApiStaticsModel;
-import com.monitor.model.response.JavaApiStatusRep;
+import com.monitor.model.request.JavaApiStatusReq;
 
 import java.util.List;
-import java.util.Map;
 
 /**
  * Created by fruwei on 2016/6/21.
@@ -15,8 +14,8 @@ public interface IJavaApiStaticsMapper {
     public void insertJavaApiStatics(String influxDBName, JSONObject statics);
 
 
-    public JavaApiStaticsModel selectlatestJavaApiStatics(String influxDBName, Map<String, Integer> query);
+    public JavaApiStaticsModel selectlatestJavaApiStatics(String influxDBName, JavaApiStatusReq query);
 
-    public List<JavaApiStaticsModel> selectlatestJavaApiStaticsList(String influxDBName, List<Map<String, Integer>> query);
+    public List<JavaApiStaticsModel> selectlatestJavaApiStaticsList(String influxDBName, List<JavaApiStatusReq> query);
 
 }

@@ -2,9 +2,11 @@ package com.monitor.influxdb.mapper.impl;
 
 import com.alibaba.fastjson.JSONObject;
 import com.monitor.common.contants.InfluxDBContants;
+import com.monitor.common.util.DateFormatUtil;
 import com.monitor.influxdb.InluxDBSingle;
 import com.monitor.influxdb.mapper.IJavaApiStaticsMapper;
 import com.monitor.model.domain.JavaApiStaticsModel;
+import com.monitor.model.request.JavaApiStatusReq;
 import org.influxdb.dto.BatchPoints;
 import org.influxdb.dto.Point;
 import org.influxdb.dto.Query;
@@ -68,12 +70,12 @@ public class JavaApiStaticsMapper implements IJavaApiStaticsMapper {
     }
 
     @Override
-    public JavaApiStaticsModel selectlatestJavaApiStatics(String influxDBName, Map<String, Integer> param) {
-        int api_id = param.get("api_id");
-        int mobj_id = param.get("mobj_id");
+    public JavaApiStaticsModel selectlatestJavaApiStatics(String influxDBName, JavaApiStatusReq param) {
+        int api_id = param.getServiceId();
+        int mobj_id = param.getMObjectId();
         String sql = "select * from " + InfluxDBContants.YOMO_TB_JAVAAPI + " where time > now() - 1h ";
-        sql += " and api_id=" + param.get("api_id");
-        sql += " and mobj_id=" + param.get("mobj_id");
+        sql += " and api_id=" + api_id;
+        sql += " and mobj_id=" + mobj_id;
         sql += " order by time desc limit 1";
         Query query = new Query(sql, InfluxDBContants.APP_ALARM);
 
@@ -89,14 +91,25 @@ public class JavaApiStaticsMapper implements IJavaApiStaticsMapper {
         try {
             QueryResult.Series series = rel.getSeries().get(0);
 
-            Boolean status = (Boolean) series.getValues().get(0).get(series.getColumns().indexOf("is_exception"));
+            Boolean is_exception = (Boolean) series.getValues().get(0).get(series.getColumns().indexOf("is_exception"));
+            long startTime = Math.round((Double) series.getValues().get(0).get(series.getColumns().indexOf("start")));
+            long endTime = Math.round((Double) series.getValues().get(0).get(series.getColumns().indexOf("end")));
+            long costTime = (endTime - startTime);
 
-            if (status == true) {
-                javaApiStaticsModel.setStatus(1);
-            } else
+            String exception = (String) series.getValues().get(0).get(series.getColumns().indexOf("exception"));
+
+            javaApiStaticsModel.setStartTime(DateFormatUtil.parseLongTo14(startTime));
+            javaApiStaticsModel.setEndTime(DateFormatUtil.parseLongTo14(endTime));
+
+            javaApiStaticsModel.setCostTime((int) costTime);
+
+            if (is_exception == true) {
                 javaApiStaticsModel.setStatus(0);
+                javaApiStaticsModel.setException(exception);
+            } else
+                javaApiStaticsModel.setStatus(1);
 
-        }catch (Exception e){
+        } catch (Exception e) {
             e.printStackTrace();
         }
         return javaApiStaticsModel;
@@ -104,15 +117,14 @@ public class JavaApiStaticsMapper implements IJavaApiStaticsMapper {
     }
 
 
-
     @Override
-    public List<JavaApiStaticsModel> selectlatestJavaApiStaticsList(String influxDBName, List<Map<String, Integer>> paramList) {
+    public List<JavaApiStaticsModel> selectlatestJavaApiStaticsList(String influxDBName, List<JavaApiStatusReq> paramList) {
 
         //TODO 后期改批量查询
 
         List<JavaApiStaticsModel> javaApiStaticsModels = new ArrayList<>();
 
-        for (Map<String, Integer> param : paramList) {
+        for (JavaApiStatusReq param : paramList) {
             JavaApiStaticsModel model = selectlatestJavaApiStatics(influxDBName, param);
             javaApiStaticsModels.add(model);
         }

@@ -38,10 +38,14 @@ public class JavaApiClient {
     @Autowired
     @Qualifier("javaapiRestTemplate")
     private RestTemplate restTemplate;
+//
+//    @Autowired
+//    @Qualifier("influxDBJavaApiHandler")
+//    private IJavaApiHadnler javaApiHadnler;
 
     @Autowired
-    @Qualifier("influxDBJavaApiHandler")
-    private IJavaApiHadnler javaApiHadnler;
+    private List<IJavaApiHadnler> javaApiHadnlerList;
+
 
     //TODO 需要 线程安全 处理
     private Map<String, JavaApiInfo> javaApimap;
@@ -56,7 +60,6 @@ public class JavaApiClient {
     private long endTime;
 
 
-
     public void initClient() {
         executorService = new ThreadPoolExecutor(10, 30, 60, TimeUnit.SECONDS, new LinkedBlockingDeque<>(),
                 new JavaApiThreadFactory());
@@ -85,7 +88,7 @@ public class JavaApiClient {
 
 
     public void run() {
-        startTime=System.currentTimeMillis();
+        startTime = System.currentTimeMillis();
         int tastNum = 0;
         for (JavaApiInfo javaApiInfo : javaApimap.values()) {
 
@@ -114,12 +117,14 @@ public class JavaApiClient {
 
         //close 线程池
         executorService.shutdownNow();
-        endTime=System.currentTimeMillis();
+        endTime = System.currentTimeMillis();
     }
 
 
     public void handleResult(JavaApiStatics rep) {
-        javaApiHadnler.handler(rep);
+        for (IJavaApiHadnler javaApiHadnler : javaApiHadnlerList) {
+            javaApiHadnler.handler(rep);
+        }
     }
 
 
@@ -153,7 +158,7 @@ public class JavaApiClient {
 //
 //        mObjInfoMap.add(1, mObj2);
 
-                MObjectInfo mObj2 = new MObjectInfo();
+        MObjectInfo mObj2 = new MObjectInfo();
         mObj2.setMoId(0);
         mObj2.setMoHostIp("localhost");
         mObj2.setMoTags("10080");

+package com.monitor.javaserver.handle.impl;
+
+import com.model.JavaApiInfo;
+import com.model.MObjectInfo;
+import com.monitor.common.config.SnsMobileConfig;
+import com.monitor.common.service.AlarmMsgService;
+import com.monitor.javaserver.common.JavaApiStatics;
+import com.monitor.javaserver.handle.IJavaApiHadnler;
+import org.apache.commons.collections.map.MultiKeyMap;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+import org.springframework.util.MultiValueMap;
+
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+import java.util.concurrent.ConcurrentMap;
+import java.util.concurrent.atomic.AtomicInteger;
+
+/**
+ * Created by fruwei on 2016/6/22.
+ */
+@Component("msgJavaApiHandler")
+public class MsgJavaApiHandler implements IJavaApiHadnler {
+
+    Logger log = LoggerFactory.getLogger(InfluxDBJavaApiHandler.class);
+
+    @Autowired
+    public AlarmMsgService alarmMsgService;
+    @Autowired
+    private SnsMobileConfig snsMobileConfig;
+
+    private ConcurrentHashMap<String, AtomicInteger> mapStatics = new ConcurrentHashMap<String, AtomicInteger>();
+
+
+    @Override
+    public void handler(JavaApiStatics javaApiStatics) {
+        String key = buildKey(javaApiStatics);
+        //无错
+        if (javaApiStatics.isHasException() == false) {
+            if (mapStatics.containsKey(key)) {
+                mapStatics.remove(key);
+            }
+            return;
+        }
+
+        int num = 0;
+        if (mapStatics.containsKey(key)) {
+            AtomicInteger errNums = mapStatics.get(key);
+            num = errNums.incrementAndGet();
+        } else {
+            mapStatics.put(key, new AtomicInteger(1));
+            num = 1;
+        }
+
+        JavaApiInfo javaApiInfo = javaApiStatics.getJavaApiInfo();
+        if (javaApiInfo.getApiWarnTrigger() > 0 &&
+                num >= javaApiInfo.getApiWarnTrigger() &&
+                javaApiInfo.getApiToggle() == 1) {
+            //告警
+            String msg = buildErrMsg(num, javaApiStatics);
+            log.info("send error msg : {} .", msg);
+            alarmMsgService.sendSms(msg, snsMobileConfig.getOpsManagerDeveloper());
+        }
+
+    }
+
+
+    public String buildKey(JavaApiStatics javaApiStatics) {
+        String key;
+        key = javaApiStatics.getJavaApiInfo().getServiceId() + "_" + javaApiStatics.getMObjectInfo().getMoId();
+        return key;
+    }
+
+
+    public String buildErrMsg(int num, JavaApiStatics javaApiStatics) {
+        JavaApiInfo javaApiInfo = javaApiStatics.getJavaApiInfo();
+        MObjectInfo mObjectInfo = javaApiStatics.getMObjectInfo();
+
+        StringBuilder msgBuilder = new StringBuilder();
+        msgBuilder.append("Java API Error ")
+                .append("最近出错次数:" + num).append(" , ")
+                .append("NAME:" + javaApiInfo.getApiName()).append(" , ")
+                .append("URL:" + javaApiInfo.getApiUrl()).append(" , ")
+                .append("IP:" + mObjectInfo.getMoHostIp()).append(" , ")
+                .append("TYPE:" + javaApiInfo.getServiceType()).append(" , ")
+                .append(".");
+
+        return msgBuilder.toString();
+    }
+
+}

 package com.monitor.javaserver.status.impl;
 
+import com.fasterxml.jackson.databind.util.BeanUtil;
+import com.monitor.influxdb.mapper.impl.JavaApiStaticsMapper;
 import com.monitor.javaserver.status.IJavaApiStatusService;
+import com.monitor.model.domain.JavaApiStaticsModel;
 import com.monitor.model.request.JavaApiStatusReq;
 import com.monitor.model.response.JavaApiStatusRep;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
 import java.util.ArrayList;
@@ -14,6 +18,10 @@ import java.util.Random;
  */
 @Component
 public class JavaAppiStatusServiceImpl implements IJavaApiStatusService {
+
+    @Autowired
+    JavaApiStaticsMapper javaApiStaticsMapper;
+
     @Override
     public JavaApiStatusRep getJavaApiStatus(JavaApiStatusReq req) {
         JavaApiStatusRep rep = new JavaApiStatusRep();
@@ -34,17 +42,36 @@ public class JavaAppiStatusServiceImpl implements IJavaApiStatusService {
     public List<JavaApiStatusRep> getJavaApiStatusList(List<JavaApiStatusReq> reqList) {
         List<JavaApiStatusRep> repList = new ArrayList<JavaApiStatusRep>();
 
-        //模拟
-        for (JavaApiStatusReq req : reqList) {
+
+        List<JavaApiStaticsModel> modelList = javaApiStaticsMapper.selectlatestJavaApiStaticsList(null, reqList);
+
+        for (JavaApiStaticsModel req : modelList) {
             JavaApiStatusRep rep = new JavaApiStatusRep();
             rep.setServiceId(req.getServiceId());
             rep.setMObjectId(req.getMObjectId());
+            rep.setStatus(req.getStatus());
+
+            rep.setEndTime(req.getEndTime());
+            rep.setStartTime(req.getStartTime());
+            rep.setCostTime(req.getCostTime());
+            rep.setException(req.getException());
+
 
-            Random rd = new Random();
-            rep.setStatus((100 + rd.nextInt(100)) % 2);
             repList.add(rep);
         }
 
+
+//        //模拟
+//        for (JavaApiStatusReq req : reqList) {
+//            JavaApiStatusRep rep = new JavaApiStatusRep();
+//            rep.setServiceId(req.getServiceId());
+//            rep.setMObjectId(req.getMObjectId());
+//
+//            Random rd = new Random();
+//            rep.setStatus((100 + rd.nextInt(100)) % 2);
+//            repList.add(rep);
+//        }
+
         return repList;
     }
 

@@ -3,7 +3,6 @@ package com.monitor.middleware.zookeeper.service.iml;
 import com.monitor.influxdb.mapper.IZkMapper;
 import com.monitor.influxdb.model.ZkInfo;
 import com.monitor.middleware.zookeeper.service.IZkMonitorService;
-import org.apache.zookeeper.KeeperException;
 import org.apache.zookeeper.ZooKeeper;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -11,7 +10,6 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.scheduling.annotation.EnableScheduling;
 import org.springframework.stereotype.Service;
 
-import java.io.IOException;
 import java.util.ArrayList;
 import java.util.List;
 
@@ -57,7 +55,7 @@ public class ZkMonitorServiceImpl implements IZkMonitorService {
     }
 
 
-    private int checkConnection(String ip) throws IOException, KeeperException, InterruptedException {
+    private int checkConnection(String ip) throws Exception{
         ZooKeeper zk = new ZooKeeper("192.168.102.205:2181", 2000,null);
         // 获取某路径下所有节点
         List<String> children = zk.getChildren("/", false);

@@ -4,14 +4,12 @@ import com.monitor.middleware.zookeeper.service.IZkMonitorService;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.scheduling.annotation.EnableScheduling;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 
 /**
  * Created by yoho on 2016/6/21.
  */
-@EnableScheduling
 @Component
 public class ZookeeperMonitorTask {
 
@@ -20,7 +18,7 @@ public class ZookeeperMonitorTask {
     @Autowired
     IZkMonitorService zkMonitorService;
 
-    @Scheduled(fixedRate = 5000)
+    @Scheduled(fixedRate=20000)
     public void zookeeperMonitor() {
         zkMonitorService.zookeeperMonitor();
     }

 package com.monitor.model.domain;
 
 import lombok.Data;
+import wiremock.org.apache.commons.lang.builder.ReflectionToStringBuilder;
 
 /**
  * Created by fruwei on 2016/6/22.
@@ -11,15 +12,13 @@ public class JavaApiStaticsModel {
     private Integer serviceType;
     private Integer mObjectId;
     private Integer status;
-
+    private String exception;
+    private String startTime;
+    private String endTime;
+    private int costTime;
 
     @Override
     public String toString() {
-        return "JavaApiStaticsModel{" +
-                "mObjectId=" + mObjectId +
-                ", serviceId=" + serviceId +
-                ", serviceType=" + serviceType +
-                ", status=" + status +
-                '}';
+        return ReflectionToStringBuilder.toString(this);
     }
 }

@@ -12,6 +12,9 @@ public class JavaApiStatusRep {
     private Integer serviceType;
     private Integer mObjectId;
     private Integer status;
-
+    private String exception;
+    private String startTime;
+    private String endTime;
+    private int costTime;
 
 }

+# ********************  send sms common configs ********************
+sendsms.url=http://www.ztsms.cn/sendSms.do
+sendsms.username=youhuo
+sendsms.pwd=I8vX4MtK
+sendsms.notice.productid=333333
+
+base_mobile=15905144483,18751986615,18652008443
+
+#------------------------------------------支付回调手机号------------------------------------------------
+sendsms.alarm.paycallback=15905144483,18751986615,18652008443
+#------------------------------------------支付回调手机号------------------------------------------------
+
+#------------------------------------------订单异常手机号------------------------------------------------
+sendsms.alarm.mobile.orderexception=15905144483,13585196262,18652008443
+#------------------------------------------订单异常手机号------------------------------------------------
+
+#------------------------------------------用户行为异常手机号------------------------------------------------
+sendsms.alarm.mobile.userbehaviour=15905144483,18001582955
+#------------------------------------------用户行为异常手机号------------------------------------------------
+
+#------------------------------------------数据库异常手机号------------------------------------------------
+sendsms.alarm.mobile.dbexception=15905144483,18652008443,18751986615,13811102093
+#------------------------------------------数据库异常手机号------------------------------------------------
+
+#-------------------------------------------服务异常告警手机号----------------------------------------------------
+
+sendsms.alarm.mobile.serviceexception.product=15905144483,18652925653,13451938602,18751986615,18652008443
+sendsms.alarm.mobile.serviceexception.search=15905144483,18551640215,18652925653,18751986615,18652008443
+sendsms.alarm.mobile.serviceexception.guang=15905144483,18001582955,18652925653,18751986615,18652008443,18551607734,15651035157,13951882433
+sendsms.alarm.mobile.serviceexception.users=15905144483,18001582955,18652925653,18751986615,18652008443,13951882433,15651035157,18551607734
+sendsms.alarm.mobile.serviceexception.order=15905144483,15950561359,13951634768,18652925653,18751986615,18652008443
+sendsms.alarm.mobile.serviceexception.sns=15905144483,13451938602,18652925653,18751986615,18652008443
+sendsms.alarm.mobile.serviceexception.promotion=15905144483,18652925653,13451938602,18751986615,18652008443
+sendsms.alarm.mobile.serviceexception.message=15905144483,18001582955,18652925653,18751986615,18652008443
+sendsms.alarm.mobile.serviceexception.resources=15905144483,15950561359,18652925653,18751986615,18652008443
+
+#-------------服务异常告警手机号-------------------
+
+#---------------------Monitor异常数据告警手机号------------------
+sendsms.alarm.mobile.monitor.exception=15905144483,18751986615
+#---------------------Monitor异常数据告警手机号------------------
+
+#-----------------------------Logs告警模块---------------------------
+#短信发送失败量超过阀值 告警手机号
+sendsms.alarm.mobile.logs.sns_send_failed=15905144483,18751986615,18652008443,18001582955
+#-----------------------------Logs告警模块--------------------------
+
+#-----------------------------监控系统开发人员--------------------------
+sendsms.alarm.mobile.ops_manager.developer=13914772123,15150551036
+#-----------------------------监控系统开发人员--------------------------
+
+dnspod.mobile=15905144483,18652008443,18751986615
+
+jmxtrans.mobile=15905144483,18751986615
+
+nginx.config.switch.mobile=15905144483,18652008443,18751986615
+#订单校验失败
+orderinfocheck.mobile=15905144483,18652008443,15950561359,13902496867,18511020499
+

@@ -3,6 +3,8 @@ package com.monitor;
 import com.monitor.influxdb.mapper.impl.JavaApiStaticsMapper;
 import com.monitor.javaserver.common.JavaApiStatics;
 import com.monitor.model.domain.JavaApiStaticsModel;
+import com.monitor.model.request.JavaApiStatusReq;
+import com.monitor.model.response.JavaApiStatusRep;
 import org.junit.Test;
 import org.junit.runner.RunWith;
 import org.slf4j.Logger;
@@ -34,9 +36,10 @@ public class JavaApiInfluxDBTest {
     @Test
     public void testQuery() {
 
-        Map<String, Integer> param = new HashMap<>();
-        param.put("api_id", 21);
-        param.put("mobj_id", 43);
+        JavaApiStatusReq param = new JavaApiStatusReq();
+        param.setServiceId(21);
+        param.setServiceId(43);
+
         JavaApiStaticsModel rel = javaApiStaticsMapper.selectlatestJavaApiStatics(null, param);
 
         logger.info(rel.toString());
@@ -47,14 +50,14 @@ public class JavaApiInfluxDBTest {
     @Test
     public void testBatchQuery() {
 
-        List<Map<String, Integer> >  listParam=new ArrayList<>();
-        Map<String, Integer> param1 = new HashMap<>();
-        param1.put("api_id", 21);
-        param1.put("mobj_id", 43);
+        List<JavaApiStatusReq> listParam = new ArrayList<>();
+        JavaApiStatusReq param1 = new JavaApiStatusReq();
+        param1.setServiceId(21);
+        param1.setServiceId(43);
         listParam.add(param1);
-        Map<String, Integer> param2 = new HashMap<>();
-        param2.put("api_id", 19);
-        param2.put("mobj_id", 134);
+        JavaApiStatusReq param2 = new JavaApiStatusReq();
+        param2.setServiceId(19);
+        param2.setServiceId(134);
 
 
         listParam.add(param2);

+package com.monitor;
+
+import com.monitor.common.config.SnsMobileConfig;
+import com.monitor.common.service.AlarmMsgService;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.PropertySource;
+import org.springframework.test.context.ContextConfiguration;
+import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
+
+/**
+ * Created by fruwei on 2016/6/22.
+ */
+@RunWith(SpringJUnit4ClassRunner.class)
+@ContextConfiguration(locations = {
+        "classpath*:META-INF/spring/spring*.xml"})
+@PropertySource({"classpath:jdbc.properties",
+        "classpath:*.properties"})
+public class MessageTest {
+
+
+    @Autowired
+    public AlarmMsgService alarmMsgService;
+    @Autowired
+    private SnsMobileConfig snsMobileConfig;
+    @Test
+    public  void testSendMsg(){
+
+        alarmMsgService.sendSms("test", snsMobileConfig.getOpsManagerDeveloper());
+
+    }
+}