Authored by zhengyouwei

add mobile to

... ... @@ -89,7 +89,7 @@ public class AlarmMsgServiceImpl implements AlarmMsgService {
}
try {
monitorAlarmMapper.insertAlarmMsg(InfluxDBContants.AWS, type, content, alarmInfo, sendStatus ? "successed" : "faild", result);
monitorAlarmMapper.insertAlarmMsg(InfluxDBContants.AWS, type, content, alarmInfo, sendStatus ? "successed" : "faild", result,mobile);
} catch (Exception e) {
logger.error("insert sms into influxdb failed", e);
}
... ...
... ... @@ -9,7 +9,7 @@ public interface MonitorAlarmMapper {
* @param influxDBName
* @param snsContent
*/
void insertAlarmMsg(String influxDBName, String alarmType, String snsContent, String alarmInfo, String sendStatus,String result);
void insertAlarmMsg(String influxDBName, String alarmType, String snsContent, String alarmInfo, String sendStatus,String result,String mobile);
/**
* 查询type的tag-value
... ...
... ... @@ -26,7 +26,7 @@ public class MonitorAlarmMapperImpl extends InfluxDBQuery implements MonitorAlar
* @param alarmInfo
*/
@Override
public void insertAlarmMsg(String influxDBName, String alarmType, String snsContent, String alarmInfo, String sendStatus,String result) {
public void insertAlarmMsg(String influxDBName, String alarmType, String snsContent, String alarmInfo, String sendStatus,String result,String mobile) {
BatchPoints batchPoints = BatchPoints
.database(InfluxDBContants.YOMO_MONITOR).tag("event", "alarm").retentionPolicy("default")
.build();
... ... @@ -35,6 +35,7 @@ public class MonitorAlarmMapperImpl extends InfluxDBQuery implements MonitorAlar
.tag("send_status", sendStatus)
.addField("sms_content", snsContent)
.addField("result", result)
.addField("mobile", mobile)
.addField("alarm_info", alarmInfo).build();
batchPoints.point(point);
inluxDBSingle.getInfluxDBByName(influxDBName).getInfluxDB()
... ...