package com.product.data.center.service;
|
|
import java.io.IOException;
|
import java.net.InetAddress;
|
import java.net.UnknownHostException;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
import com.product.core.dao.BaseDao;
|
import com.product.core.entity.DataTableEntity;
|
import com.product.core.entity.FieldSetEntity;
|
import com.product.core.exception.BaseException;
|
import com.product.core.service.support.AbstractBaseService;
|
import com.product.core.spring.context.SpringMVCContextHolder;
|
import com.product.data.center.config.CmnConst;
|
import com.product.data.center.config.ErrorCode;
|
import com.product.util.BaseUtil;
|
|
import net.minidev.json.JSONObject;
|
|
/**
|
* 网络监测
|
*
|
* @author 86151
|
*
|
*/
|
@Component
|
public class NetWorkMonitorService extends AbstractBaseService {
|
|
@Autowired
|
BaseDao baseDao;
|
|
/**
|
* 监测IP列表（左侧树）
|
* @return
|
*/
|
public DataTableEntity listNetWork() {
|
DataTableEntity dtIp = baseDao.listTable("product_sys_network_monitor");
|
return dtIp;
|
}
|
|
/**
|
* 监测IP视图（右侧模块）
|
* @return
|
* @throws IOException
|
* @throws UnknownHostException
|
*/
|
public List<JSONObject> monitorIp(FieldSetEntity fse) throws UnknownHostException, IOException {
|
List<JSONObject> listData=new ArrayList<>();
|
String queryIp=fse.getString("ip_address");
|
if (!BaseUtil.strIsNull(queryIp)) {
|
JSONObject jsonResult=new JSONObject();
|
jsonResult.put("ip", queryIp);
|
jsonResult.put("status", pingHost(queryIp));
|
listData.add(jsonResult);
|
}else {
|
DataTableEntity dtIp=listNetWork();
|
if (!BaseUtil.dataTableIsEmpty(dtIp)) {
|
for (int i = 0; i < dtIp.getRows(); i++) {
|
FieldSetEntity fseIp=dtIp.getFieldSetEntity(i);
|
JSONObject jsonResult=new JSONObject();
|
jsonResult.put("ip", fseIp.getString("ip_address"));
|
jsonResult.put("status", pingHost(fseIp.getString("ip_address")));
|
listData.add(jsonResult);
|
}
|
}
|
}
|
return listData;
|
}
|
|
/**
|
* java ping
|
* @param ipAddress
|
* @return
|
* @throws IOException
|
* @throws UnknownHostException
|
*/
|
public String pingHost(String ipAddress) throws UnknownHostException, IOException {
|
int timeOut = 3000 ; //超时应该在3钞以上
|
boolean status = InetAddress.getByName(ipAddress).isReachable(timeOut); // 当返回值是true时，说明host是可用的，false则不可。
|
if (status) {
|
return "成功";
|
}
|
return "失败";
|
}
|
|
/**
|
* 监测IP新增
|
* @param fseNetWork
|
* @return
|
*/
|
public String addNetWork(FieldSetEntity fseNetWork) {
|
FieldSetEntity fseExist=baseDao.getFieldSetEntityByFilter("product_sys_network_monitor", "ip_address=?", new Object[] {fseNetWork.getString("ip_address")}, false);
|
if (fseExist!=null) {
|
throw new BaseException(ErrorCode.NERWORK_HAS_EXIST.getValue(), ErrorCode.NERWORK_HAS_EXIST.getText());
|
}
|
fseNetWork.setValue(CmnConst.CREATED_UTC_DATETIME, new Date());
|
fseNetWork.setValue(CmnConst.CREATED_BY, SpringMVCContextHolder.getCurrentUser().getUser_id());
|
return baseDao.add(fseNetWork);
|
}
|
|
/**
|
* 监测IP删除
|
* @param fseNetWork
|
* @return
|
*/
|
public boolean deleteNetWork(String ipAddress) {
|
return baseDao.delete("product_sys_network_monitor", "ip_address=?", new Object[] {ipAddress});
|
}
|
}
|
