diff options
| author | caohui <[email protected]> | 2020-04-29 14:32:05 +0800 |
|---|---|---|
| committer | caohui <[email protected]> | 2020-04-29 14:32:05 +0800 |
| commit | d15d7536f385ec4a1250ed15ed52fd6c05eb7431 (patch) | |
| tree | 737ec8462ef62ac70caeee1533cbee4e76ceef98 /src/main/java/cn/ac/iie/bean | |
Diffstat (limited to 'src/main/java/cn/ac/iie/bean')
14 files changed, 1831 insertions, 0 deletions
diff --git a/src/main/java/cn/ac/iie/bean/CommonLog.java b/src/main/java/cn/ac/iie/bean/CommonLog.java new file mode 100644 index 0000000..ead6e8c --- /dev/null +++ b/src/main/java/cn/ac/iie/bean/CommonLog.java @@ -0,0 +1,400 @@ +package cn.ac.iie.bean; + +/** + * 公共字段类 + * + * @author Administrator + */ +public class CommonLog { + + private int cfg_id;//建表,需要,即配置ID,但数据中没有 + + private int found_time;//建表,必需 + private int recv_time;//建表,必需 + + private String trans_proto;//建表,必需,即PROTOCOL + + private String d_ip;//建表,必需,即SERVER_IP,服务端IP + private String s_ip;//建表,必需,即CLIENT_IP,客户端IP + private int d_port;//建表,必需,即SERVER_PORT,服务端端口 + private int s_port;//建表,必需,即CLIENT_PORT,客户端端口 + + private int entrance_id;//建表,必需 + private String cap_ip;//建表,必需 + + private String server_locate;//建表,方法获取 + private String client_locate;//建表,方法获取 + + //以下为无法接收到的字段或者可以直接置空的字段(即非必要字段) + private long over_id;//建表 + private String nest_protocol;//建表 + private String nest_server_ip;//建表 + private String nest_client_ip;//建表 + private int nest_server_port;//建表 + private int nest_client_port;//建表 + private int service;//建表,已有 + private String scene_file;//建表 + private String injected_pkt_file;//建表 + private String nest_addr_list;//建表 + private int action;//建表 + + private String user_region;//20190507,需要建表,获取reset标记字段 + private int stream_dir;//20190507,需要建表,获取reset标记字段 + private String addr_list;//20190507,需要建表,获取reset标记字段 + + //表中没有,即未加入建表的,但数据中有;//20190507旧表新增字段 + private int addr_type;//未建表,目前数据中ipv6特有;//20190507,需要建表,获取reset标记字段 + + + //user_region内含字段 + private String killed;//20190507新增,killed=0表示未rst;killed=1表示rst过了; + private String thread;//20190507新增 + private String index;//20190507新增 + private String hash;//20190507新增 + + +// private int device_id; +// private int link_id; +// private int encap_type; +// private int direction; +// private String inner_smac; +// private String inner_dmac; + +// private String s_asn; +// private String d_asn; +// private String s_subscribe_id; +// private String d_subscribe_id; + + + public int getCfg_id() { + return cfg_id; + } + + public void setCfg_id(int cfg_id) { + this.cfg_id = cfg_id; + } + + public int getFound_time() { + return found_time; + } + + public void setFound_time(int found_time) { + this.found_time = found_time; + } + + public int getRecv_time() { + return recv_time; + } + + public void setRecv_time(int recv_time) { + this.recv_time = recv_time; + } + + public String getTrans_proto() { + return trans_proto; + } + + public void setTrans_proto(String trans_proto) { + this.trans_proto = trans_proto; + } + + public String getD_ip() { + return d_ip; + } + + public void setD_ip(String d_ip) { + this.d_ip = d_ip; + } + + public String getS_ip() { + return s_ip; + } + + public void setS_ip(String s_ip) { + this.s_ip = s_ip; + } + + public int getD_port() { + return d_port; + } + + public void setD_port(int d_port) { + this.d_port = d_port; + } + + public int getS_port() { + return s_port; + } + + public void setS_port(int s_port) { + this.s_port = s_port; + } + + public int getEntrance_id() { + return entrance_id; + } + + public void setEntrance_id(int entrance_id) { + this.entrance_id = entrance_id; + } + + public String getCap_ip() { + return cap_ip; + } + + public void setCap_ip(String cap_ip) { + this.cap_ip = cap_ip; + } + + public String getServer_locate() { + return server_locate; + } + + public void setServer_locate(String server_locate) { + this.server_locate = server_locate; + } + + public String getClient_locate() { + return client_locate; + } + + public void setClient_locate(String client_locate) { + this.client_locate = client_locate; + } + + public long getOver_id() { + return over_id; + } + + public void setOver_id(long over_id) { + this.over_id = over_id; + } + + public String getNest_protocol() { + return nest_protocol; + } + + public void setNest_protocol(String nest_protocol) { + this.nest_protocol = nest_protocol; + } + + public String getNest_server_ip() { + return nest_server_ip; + } + + public void setNest_server_ip(String nest_server_ip) { + this.nest_server_ip = nest_server_ip; + } + + public String getNest_client_ip() { + return nest_client_ip; + } + + public void setNest_client_ip(String nest_client_ip) { + this.nest_client_ip = nest_client_ip; + } + + public int getNest_server_port() { + return nest_server_port; + } + + public void setNest_server_port(int nest_server_port) { + this.nest_server_port = nest_server_port; + } + + public int getNest_client_port() { + return nest_client_port; + } + + public void setNest_client_port(int nest_client_port) { + this.nest_client_port = nest_client_port; + } + + public int getService() { + return service; + } + + public void setService(int service) { + this.service = service; + } + + public String getScene_file() { + return scene_file; + } + + public void setScene_file(String scene_file) { + this.scene_file = scene_file; + } + + public String getInjected_pkt_file() { + return injected_pkt_file; + } + + public void setInjected_pkt_file(String injected_pkt_file) { + this.injected_pkt_file = injected_pkt_file; + } + + public String getNest_addr_list() { + return nest_addr_list; + } + + public void setNest_addr_list(String nest_addr_list) { + this.nest_addr_list = nest_addr_list; + } + + public int getAction() { + return action; + } + + public void setAction(int action) { + this.action = action; + } + + public int getAddr_type() { + return addr_type; + } + + public void setAddr_type(int addr_type) { + this.addr_type = addr_type; + } + + public int getStream_dir() { + return stream_dir; + } + + public void setStream_dir(int stream_dir) { + this.stream_dir = stream_dir; + } + + public String getAddr_list() { + return addr_list; + } + + public void setAddr_list(String addr_list) { + this.addr_list = addr_list; + } + + public String getUser_region() { + return user_region; + } + + public void setUser_region(String user_region) { + this.user_region = user_region; + } + + public String getKilled() { + return killed; + } + + public void setKilled(String killed) { + this.killed = killed; + } + + public String getThread() { + return thread; + } + + public void setThread(String thread) { + this.thread = thread; + } + + public String getIndex() { + return index; + } + + public void setIndex(String index) { + this.index = index; + } + + public String getHash() { + return hash; + } + + public void setHash(String hash) { + this.hash = hash; + } + + @Override + public String toString() { + return cfg_id + "#" + + found_time + "#" + + recv_time + "#" + + trans_proto + "#" + + d_ip + "#" + + s_ip + "#" + + d_port + "#" + + s_port + "#" + + entrance_id + "#" + + cap_ip + "#" + + server_locate + "#" + + client_locate + "#" + + over_id + "#" + + nest_protocol + "#" + + nest_server_ip + "#" + + nest_client_ip + "#" + + nest_server_port + "#" + + nest_client_port + "#" + + service + "#" + + scene_file + "#" + + injected_pkt_file + "#" + + nest_addr_list + "#" + + action + "##" + + addr_type + "##" + + stream_dir + "##" + + addr_list + "##" + + user_region +// device_id + "#" + +// link_id + "#" + +// encap_type + "#" + +// direction + "#" + +// inner_smac + "#" + +// inner_dmac + "#" + +// s_asn + "#" + +// d_asn + "#" + +// s_subscribe_id + "#" + +// d_subscribe_id + "#" + + ; + } + + //获取字段打印 + public String field() { + return cfg_id + "#" + + found_time + "#" + + recv_time + "#" + + trans_proto + "#" + + d_ip + "#" + + s_ip + "#" + + d_port + "#" + + s_port + "#" + + entrance_id + "#" + + cap_ip + "#" + + server_locate + "#" + + client_locate + "#" + + over_id + "#" + + nest_protocol + "#" + + nest_server_ip + "#" + + nest_client_ip + "#" + + nest_server_port + "#" + + nest_client_port + "#" + + service + "#" + + scene_file + "#" + + injected_pkt_file + "#" + + nest_addr_list + "#" + + action + "##" + + addr_type + "##" + + stream_dir + "##" + + addr_list + "##" + + user_region +// device_id + "#" + +// link_id + "#" + +// encap_type + "#" + +// direction + "#" + +// inner_smac + "#" + +// inner_dmac + "#" + +// s_asn + "#" + +// d_asn + "#" + +// s_subscribe_id + "#" + +// d_subscribe_id + "#" + + ; + } +} diff --git a/src/main/java/cn/ac/iie/bean/ConfigCompile.java b/src/main/java/cn/ac/iie/bean/ConfigCompile.java new file mode 100644 index 0000000..80d3a87 --- /dev/null +++ b/src/main/java/cn/ac/iie/bean/ConfigCompile.java @@ -0,0 +1,173 @@ +package cn.ac.iie.bean; + +import java.io.Serializable; +import java.util.ArrayList; + +import cn.ac.iie.common.RealtimeCountConfig; + +public class ConfigCompile implements Serializable{ + + private static final long serialVersionUID = 2492616231566889401L; + private String COMPILE_ID; + private String CONT_TYPE; + private String ATTR_TYPE; + private String CONT_LABEL; + private String TASK_ID; + private String GUARANTEE_ID; + private String AFFAIR_ID; + private String TOPIC_ID; + private String IS_VALID; + private String SERVICE; + private String LWHH; + private ArrayList<String> TAG; + + + public ConfigCompile(String[] config){ + this.COMPILE_ID = config[0]; + this.CONT_TYPE = config[1]; + this.ATTR_TYPE = config[2]; + this.CONT_LABEL = config[3]; + this.TASK_ID = config[4]; + this.GUARANTEE_ID = config[5]; + this.AFFAIR_ID = config[6]; + this.TOPIC_ID = config[7]; + this.IS_VALID = config[8]; + String[] tagList = config[3].split(","); + this.SERVICE = makeService(tagList); + this.LWHH = makeLwhh(tagList); + this.TAG = makeTag(tagList); + } + + private String makeService(String[] tagList){ + for(int i=0; i<tagList.length; i++){ + int aTag = Integer.parseInt(tagList[i].trim()); + if(aTag>0 && aTag<=10000){ + return tagList[i].trim(); + } + } + return RealtimeCountConfig.EMPTY_OPTION_CHARACTER; + } + + private String makeLwhh(String[] tagList){ + for(int i=0; i<tagList.length; i++){ + int aTag = Integer.parseInt(tagList[i].trim()); + if(aTag>=1000000){ + return tagList[i].trim(); + } + } + return RealtimeCountConfig.EMPTY_OPTION_CHARACTER; + } + + private ArrayList<String> makeTag(String[] tagList){ + ArrayList<String> al = new ArrayList<String>(); + for(int i=0; i<tagList.length; i++){ + int aTag = Integer.parseInt(tagList[i].trim()); + if(aTag>10000 && aTag<1000000){ + al.add(tagList[i].trim()); + } + } + return al; + } + + public String getCOMPILE_ID() { + return COMPILE_ID; + } + + public void setCOMPILE_ID(String cOMPILE_ID) { + COMPILE_ID = cOMPILE_ID; + } + + public String getCONT_TYPE() { + return CONT_TYPE; + } + + public void setCONT_TYPE(String cONT_TYPE) { + CONT_TYPE = cONT_TYPE; + } + + public String getATTR_TYPE() { + return ATTR_TYPE; + } + + public void setATTR_TYPE(String aTTR_TYPE) { + ATTR_TYPE = aTTR_TYPE; + } + + public String getCONT_LABEL() { + return CONT_LABEL; + } + + public void setCONT_LABEL(String cONT_LABEL) { + CONT_LABEL = cONT_LABEL; + } + + public String getTASK_ID() { + return TASK_ID; + } + + public void setTASK_ID(String tASK_ID) { + TASK_ID = tASK_ID; + } + + public String getGUARANTEE_ID() { + return GUARANTEE_ID; + } + + public void setGUARANTEE_ID(String gUARANTEE_ID) { + GUARANTEE_ID = gUARANTEE_ID; + } + + public String getAFFAIR_ID() { + return AFFAIR_ID; + } + + public void setAFFAIR_ID(String aFFAIR_ID) { + AFFAIR_ID = aFFAIR_ID; + } + + public String getTOPIC_ID() { + return TOPIC_ID; + } + + public void setTOPIC_ID(String tOPIC_ID) { + TOPIC_ID = tOPIC_ID; + } + + + public String getIS_VALID() { + return IS_VALID; + } + + + public void setIS_VALID(String iS_VALID) { + IS_VALID = iS_VALID; + } + + + public String getSERVICE() { + return SERVICE; + } + + + public void setSERVICE(String sERVICE) { + SERVICE = sERVICE; + } + + public String getLWHH() { + return LWHH; + } + + public void setLWHH(String lWHH) { + LWHH = lWHH; + } + + public ArrayList<String> getTAG() { + return TAG; + } + + public void setTAG(ArrayList<String> tAG) { + TAG = tAG; + } + + +} diff --git a/src/main/java/cn/ac/iie/bean/PzTable.java b/src/main/java/cn/ac/iie/bean/PzTable.java new file mode 100644 index 0000000..abfaef5 --- /dev/null +++ b/src/main/java/cn/ac/iie/bean/PzTable.java @@ -0,0 +1,33 @@ +package cn.ac.iie.bean; +import java.util.HashMap; +import java.util.concurrent.locks.Lock; +import java.util.concurrent.locks.ReentrantLock; + +import cn.ac.iie.dao.DataBasePzBusiness; +import org.apache.log4j.Logger; + +public class PzTable { + public static HashMap<String, String> pzMap = new HashMap<String, String>(); + public static Lock trylock = new ReentrantLock(); + private static final Logger logger = Logger.getLogger(PzTable.class); + public static long lastUpdateTime = 0L; + public static long seq = 0L; + + public static void updatePzMap(){ + if (trylock.tryLock()) { + try { + long timeNow = System.currentTimeMillis(); + if(((timeNow-lastUpdateTime)/1000) > 240){ + //update pzMap and lastUpdateTime + new DataBasePzBusiness().getPzToMap(seq); + lastUpdateTime = timeNow; + logger.info("pzMap.size: "+pzMap.size()); + } + } catch (Exception e) { + e.printStackTrace(); + } finally { + trylock.unlock(); + } + } + } +} diff --git a/src/main/java/cn/ac/iie/bean/ntc/NTC_CONN_RECORD_LOG.java b/src/main/java/cn/ac/iie/bean/ntc/NTC_CONN_RECORD_LOG.java new file mode 100644 index 0000000..61d731d --- /dev/null +++ b/src/main/java/cn/ac/iie/bean/ntc/NTC_CONN_RECORD_LOG.java @@ -0,0 +1,142 @@ +package cn.ac.iie.bean.ntc; + +import cn.ac.iie.bean.CommonLog; + +public class NTC_CONN_RECORD_LOG extends CommonLog { + + private String app_label; + private int proto_id; + private int app_id; + private int os_id; + private int bs_id; + private int web_id; + private int behav_id; + private long c2s_pkt_num; + private long s2c_pkt_num; + private long c2s_byte_num; + private long s2c_byte_num; + + private int create_time; + private int lastmtime; + +// private int c2s_pkt_num; +// private int s2c_pkt_num; +// private int c2s_byte_num; +// private int s2c_byte_num; + + public String getApp_label() { + return app_label; + } + + public void setApp_label(String app_label) { + this.app_label = app_label; + } + + public int getProto_id() { + return proto_id; + } + + public void setProto_id(int proto_id) { + this.proto_id = proto_id; + } + + public int getApp_id() { + return app_id; + } + + public void setApp_id(int app_id) { + this.app_id = app_id; + } + + public int getOs_id() { + return os_id; + } + + public void setOs_id(int os_id) { + this.os_id = os_id; + } + + public int getBs_id() { + return bs_id; + } + + public void setBs_id(int bs_id) { + this.bs_id = bs_id; + } + + public int getWeb_id() { + return web_id; + } + + public void setWeb_id(int web_id) { + this.web_id = web_id; + } + + public int getBehav_id() { + return behav_id; + } + + public void setBehav_id(int behav_id) { + this.behav_id = behav_id; + } + + public long getC2s_pkt_num() { + return c2s_pkt_num; + } + + public void setC2s_pkt_num(long c2s_pkt_num) { + this.c2s_pkt_num = c2s_pkt_num; + } + + public long getS2c_pkt_num() { + return s2c_pkt_num; + } + + public void setS2c_pkt_num(long s2c_pkt_num) { + this.s2c_pkt_num = s2c_pkt_num; + } + + public long getC2s_byte_num() { + return c2s_byte_num; + } + + public void setC2s_byte_num(long c2s_byte_num) { + this.c2s_byte_num = c2s_byte_num; + } + + public long getS2c_byte_num() { + return s2c_byte_num; + } + + public void setS2c_byte_num(long s2c_byte_num) { + this.s2c_byte_num = s2c_byte_num; + } + + public int getCreate_time() { + return create_time; + } + + public void setCreate_time(int create_time) { + this.create_time = create_time; + } + + public int getLastmtime() { + return lastmtime; + } + + public void setLastmtime(int lastmtime) { + this.lastmtime = lastmtime; + } + + @Override + public String toString() { + return field() + + app_label + "\t" + + c2s_pkt_num + "\t" + + s2c_pkt_num + "\t" + + c2s_byte_num + "\t" + + s2c_byte_num + "\t" + + create_time + "\t" + + lastmtime + "\n"; + } +} diff --git a/src/main/java/cn/ac/iie/bean/voipSipCount/VoipCoding.java b/src/main/java/cn/ac/iie/bean/voipSipCount/VoipCoding.java new file mode 100644 index 0000000..a54120c --- /dev/null +++ b/src/main/java/cn/ac/iie/bean/voipSipCount/VoipCoding.java @@ -0,0 +1,31 @@ +package cn.ac.iie.bean.voipSipCount; + +public class VoipCoding { + private String coding; + private long count; + private String interval_time; + + public String getCoding() { + return coding; + } + + public void setCoding(String coding) { + this.coding = coding; + } + + public long getCount() { + return count; + } + + public void setCount(long count) { + this.count = count; + } + + public String getInterval_time() { + return interval_time; + } + + public void setInterval_time(String interval_time) { + this.interval_time = interval_time; + } +} diff --git a/src/main/java/cn/ac/iie/bean/voipSipCount/VoipIpLocation.java b/src/main/java/cn/ac/iie/bean/voipSipCount/VoipIpLocation.java new file mode 100644 index 0000000..128af68 --- /dev/null +++ b/src/main/java/cn/ac/iie/bean/voipSipCount/VoipIpLocation.java @@ -0,0 +1,52 @@ +package cn.ac.iie.bean.voipSipCount; + +public class VoipIpLocation { + private String country; + private String region; + private String nationCode; + private long count; + private String interval_time; + + + public String getCountry() { + return country; + } + + public void setCountry(String country) { + this.country = country; + } + + public String getRegion() { + return region; + } + + public void setRegion(String region) { + this.region = region; + } + + public String getNationCode() { + return nationCode; + } + + public void setNationCode(String nationCode) { + this.nationCode = nationCode; + } + + public long getCount() { + return count; + } + + public void setCount(long count) { + this.count = count; + } + + public String getInterval_time() { + return interval_time; + } + + public void setInterval_time(String interval_time) { + this.interval_time = interval_time; + } + + +} diff --git a/src/main/java/cn/ac/iie/bean/voipSipCount/VoipIpType.java b/src/main/java/cn/ac/iie/bean/voipSipCount/VoipIpType.java new file mode 100644 index 0000000..d3f946b --- /dev/null +++ b/src/main/java/cn/ac/iie/bean/voipSipCount/VoipIpType.java @@ -0,0 +1,31 @@ +package cn.ac.iie.bean.voipSipCount; + +public class VoipIpType { + private String type; + private long count; + private String interval_time; + + public String getType() { + return type; + } + + public void setType(String type) { + this.type = type; + } + + public long getCount() { + return count; + } + + public void setCount(long count) { + this.count = count; + } + + public String getInterval_time() { + return interval_time; + } + + public void setInterval_time(String interval_time) { + this.interval_time = interval_time; + } +} diff --git a/src/main/java/cn/ac/iie/bean/voipSipCount/VoipMethod.java b/src/main/java/cn/ac/iie/bean/voipSipCount/VoipMethod.java new file mode 100644 index 0000000..7cbefd3 --- /dev/null +++ b/src/main/java/cn/ac/iie/bean/voipSipCount/VoipMethod.java @@ -0,0 +1,31 @@ +package cn.ac.iie.bean.voipSipCount; + +public class VoipMethod { + private String method; + private long count; + private String interval_time; + + public String getMethod() { + return method; + } + + public void setMethod(String method) { + this.method = method; + } + + public long getCount() { + return count; + } + + public void setCount(long count) { + this.count = count; + } + + public String getInterval_time() { + return interval_time; + } + + public void setInterval_time(String interval_time) { + this.interval_time = interval_time; + } +} diff --git a/src/main/java/cn/ac/iie/bean/voipSipCount/VoipResStat.java b/src/main/java/cn/ac/iie/bean/voipSipCount/VoipResStat.java new file mode 100644 index 0000000..9611272 --- /dev/null +++ b/src/main/java/cn/ac/iie/bean/voipSipCount/VoipResStat.java @@ -0,0 +1,40 @@ +package cn.ac.iie.bean.voipSipCount; + +public class VoipResStat { + private String res_stat; + private String cseq; + private long count; + private String interval_time; + + public String getCseq() { + return cseq; + } + + public void setCseq(String cseq) { + this.cseq = cseq; + } + + public long getCount() { + return count; + } + + public void setCount(long count) { + this.count = count; + } + + public String getInterval_time() { + return interval_time; + } + + public void setInterval_time(String interval_time) { + this.interval_time = interval_time; + } + + public String getRes_stat() { + return res_stat; + } + + public void setRes_stat(String res_stat) { + this.res_stat = res_stat; + } +} diff --git a/src/main/java/cn/ac/iie/bean/voipSipCount/VoipServer.java b/src/main/java/cn/ac/iie/bean/voipSipCount/VoipServer.java new file mode 100644 index 0000000..fe4dd96 --- /dev/null +++ b/src/main/java/cn/ac/iie/bean/voipSipCount/VoipServer.java @@ -0,0 +1,31 @@ +package cn.ac.iie.bean.voipSipCount; + +public class VoipServer { + private String server; + private long count; + private String interval_time; + + public String getServer() { + return server; + } + + public void setServer(String server) { + this.server = server; + } + + public long getCount() { + return count; + } + + public void setCount(long count) { + this.count = count; + } + + public String getInterval_time() { + return interval_time; + } + + public void setInterval_time(String interval_time) { + this.interval_time = interval_time; + } +} diff --git a/src/main/java/cn/ac/iie/bean/voipSipCount/VoipServiceDomain.java b/src/main/java/cn/ac/iie/bean/voipSipCount/VoipServiceDomain.java new file mode 100644 index 0000000..5d675c2 --- /dev/null +++ b/src/main/java/cn/ac/iie/bean/voipSipCount/VoipServiceDomain.java @@ -0,0 +1,40 @@ +package cn.ac.iie.bean.voipSipCount; + +public class VoipServiceDomain { + private String service; + private String type; + private Long count; + private String interval_time; + + public String getService() { + return service; + } + + public void setService(String service) { + this.service = service; + } + + public String getType() { + return type; + } + + public void setType(String type) { + this.type = type; + } + + public Long getCount() { + return count; + } + + public void setCount(Long count) { + this.count = count; + } + + public String getInterval_time() { + return interval_time; + } + + public void setInterval_time(String interval_time) { + this.interval_time = interval_time; + } +} diff --git a/src/main/java/cn/ac/iie/bean/voipSipCount/VoipUa.java b/src/main/java/cn/ac/iie/bean/voipSipCount/VoipUa.java new file mode 100644 index 0000000..a57bb67 --- /dev/null +++ b/src/main/java/cn/ac/iie/bean/voipSipCount/VoipUa.java @@ -0,0 +1,31 @@ +package cn.ac.iie.bean.voipSipCount; + +public class VoipUa { + private String ua; + private long count; + private String interval_time; + + public String getUa() { + return ua; + } + + public void setUa(String ua) { + this.ua = ua; + } + + public long getCount() { + return count; + } + + public void setCount(long count) { + this.count = count; + } + + public String getInterval_time() { + return interval_time; + } + + public void setInterval_time(String interval_time) { + this.interval_time = interval_time; + } +} diff --git a/src/main/java/cn/ac/iie/bean/voipSipFromToLog/RouteRelationLog.java b/src/main/java/cn/ac/iie/bean/voipSipFromToLog/RouteRelationLog.java new file mode 100644 index 0000000..9b46ae0 --- /dev/null +++ b/src/main/java/cn/ac/iie/bean/voipSipFromToLog/RouteRelationLog.java @@ -0,0 +1,34 @@ +package cn.ac.iie.bean.voipSipFromToLog; + +/** + * voip路由关系表 + */ +public class RouteRelationLog { + private long timestamp; + private String from_domain; + private String to_domain; + + public long getTimestamp() { + return timestamp; + } + + public void setTimestamp(long timestamp) { + this.timestamp = timestamp; + } + + public String getFrom_domain() { + return from_domain; + } + + public void setFrom_domain(String from_domain) { + this.from_domain = from_domain; + } + + public String getTo_domain() { + return to_domain; + } + + public void setTo_domain(String to_domain) { + this.to_domain = to_domain; + } +} diff --git a/src/main/java/cn/ac/iie/bean/voipSipOrigin/SipOriginALL.java b/src/main/java/cn/ac/iie/bean/voipSipOrigin/SipOriginALL.java new file mode 100644 index 0000000..dd0ba42 --- /dev/null +++ b/src/main/java/cn/ac/iie/bean/voipSipOrigin/SipOriginALL.java @@ -0,0 +1,762 @@ +package cn.ac.iie.bean.voipSipOrigin; + +import com.alibaba.fastjson.annotation.JSONField; + +/** + * SIP的原始日志扩展表 + */ +public class SipOriginALL { + + @JSONField(name = "Call_ID") + private String Call_ID;//Call-ID + @JSONField(name = "CLJ_IP") + private String CLJ_IP; + @JSONField(name = "Found_Time") + private long Found_Time; + @JSONField(name = "SRC_IP") + private String SRC_IP; + @JSONField(name = "SRC_LOCATION_NATION") + private String SRC_LOCATION_NATION; + @JSONField(name = "SRC_LOCATION_NATION_CODE") + private String SRC_LOCATION_NATION_CODE; + @JSONField(name = "SRC_LOCATION_REGION") + private String SRC_LOCATION_REGION; + @JSONField(name = "SRC_PORT") + private int SRC_PORT; + @JSONField(name = "DST_IP") + private String DST_IP; + @JSONField(name = "IP_TYPE") + private String IP_TYPE; + @JSONField(name = "DST_LOCATION_NATION") + private String DST_LOCATION_NATION; + @JSONField(name = "DST_LOCATION_NATION_CODE") + private String DST_LOCATION_NATION_CODE; + @JSONField(name = "DST_LOCATION_REGION") + private String DST_LOCATION_REGION; + @JSONField(name = "DST_PORT") + private int DST_PORT; + @JSONField(name = "Method") + private String Method; + @JSONField(name = "Request_URI") + private String Request_URI; + @JSONField(name = "User_name") + private String User_name; + @JSONField(name = "Service_domain") + private String Service_domain; + @JSONField(name = "Service_domain_valid") + private String Service_domain_valid; + @JSONField(name = "Res_stat") + private String Res_stat; + @JSONField(name = "Res_stat_format") + private String Res_stat_format; + @JSONField(name = "From") + private String From; + @JSONField(name = "From_Nickname") + private String From_Nickname; + @JSONField(name = "From_usr_name") + private String From_usr_name; + @JSONField(name = "From_ser_domain") + private String From_ser_domain; + + @JSONField(name = "From_ser_domain_valid") + private String From_ser_domain_valid;//新增是否替换 + + @JSONField(name = "From_tag") + private String From_tag; + @JSONField(name = "To") + private String To; + @JSONField(name = "To_Nickname") + private String To_Nickname; + @JSONField(name = "To_usr_name") + private String To_usr_name; + @JSONField(name = "To_ser_domain") + private String To_ser_domain; + + @JSONField(name = "To_ser_domain_valid") + private String To_ser_domain_valid;//新增是否替换 + + @JSONField(name = "To_tag") + private String To_tag; + @JSONField(name = "Cseq") + private String Cseq; + @JSONField(name = "Cseq_method") + private String Cseq_method; + @JSONField(name = "User_Agent") + private String User_Agent;//User-Agent + @JSONField(name = "Device_type") + private String Device_type; + @JSONField(name = "Max_Forwards") + private String Max_Forwards;//Max-Forwards + @JSONField(name = "Server") + private String Server; + @JSONField(name = "Server_type") + private String Server_type; + @JSONField(name = "Req_Via") + private String[] Req_Via; + + @JSONField(name = "Req_Via_Json") + private String Req_Via_Json;//新增字段 + + @JSONField(name = "Req_Contact") + private String Req_Contact; + @JSONField(name = "Req_Contact_Nickname") + private String Req_Contact_Nickname; + @JSONField(name = "Req_Contact_usr_name") + private String Req_Contact_usr_name; + @JSONField(name = "Req_Contact_ser_domain") + private String Req_Contact_ser_domain; + + @JSONField(name = "Req_ser_domain_valid") + private String Req_ser_domain_valid;//新增是否替换 + + @JSONField(name = "Req_Record_Route") + private String[] Req_Record_Route;//Req_Record-Route + + @JSONField(name = "Req_Record_Route_Json") + private String Req_Record_Route_Json;//新增字段 + + @JSONField(name = "Req_Route") + private String[] Req_Route; + + @JSONField(name = "Req_Route_Json") + private String Req_Route_Json;//新增字段 + + @JSONField(name = "Req_Expires") + private String Req_Expires; + @JSONField(name = "Req_Others") + private String Req_Others; + @JSONField(name = "Req_Content_Type") + private String Req_Content_Type;//Req_Content-Type + @JSONField(name = "Req_Content") + private String Req_Content; + @JSONField(name = "Res_Via") + private String[] Res_Via; + + @JSONField(name = "Res_Via_Json") + private String Res_Via_Json;//新增字段 + + @JSONField(name = "Res_Contact") + private String Res_Contact; + @JSONField(name = "Res_Contact_Nickname") + private String Res_Contact_Nickname; + @JSONField(name = "Res_Contact_usr_name") + private String Res_Contact_usr_name; + @JSONField(name = "Res_Contact_ser_domain") + private String Res_Contact_ser_domain; + + @JSONField(name = "Res_ser_domain_valid") + private String Res_ser_domain_valid;//新增是否替换 + + @JSONField(name = "Res_Record_Route") + private String[] Res_Record_Route;//Res_Record-Route + + @JSONField(name = "Res_Record_Route_Json") + private String Res_Record_Route_Json;//新增字段 + + @JSONField(name = "Res_Route") + private String[] Res_Route; + + @JSONField(name = "Res_Route_Json") + private String Res_Route_Json;//新增字段 + + @JSONField(name = "Res_Expires") + private String Res_Expires; + @JSONField(name = "Res_Others") + private String Res_Others; + @JSONField(name = "Res_Content_Type") + private String Res_Content_Type;//Res_Content-Type + @JSONField(name = "Res_Content") + private String Res_Content; + + @JSONField(name = "Req_coding") + private String Req_coding; + @JSONField(name = "Res_coding") + private String Res_coding; + + private long stat_time;//新增时间字段 + + + public String getCall_ID() { + return Call_ID; + } + + public void setCall_ID(String call_ID) { + Call_ID = call_ID; + } + + public String getCLJ_IP() { + return CLJ_IP; + } + + public void setCLJ_IP(String CLJ_IP) { + this.CLJ_IP = CLJ_IP; + } + + public long getFound_Time() { + return Found_Time; + } + + public void setFound_Time(long found_Time) { + Found_Time = found_Time; + } + + public String getSRC_IP() { + return SRC_IP; + } + + public void setSRC_IP(String SRC_IP) { + this.SRC_IP = SRC_IP; + } + + public String getSRC_LOCATION_NATION() { + return SRC_LOCATION_NATION; + } + + public void setSRC_LOCATION_NATION(String SRC_LOCATION_NATION) { + this.SRC_LOCATION_NATION = SRC_LOCATION_NATION; + } + + public String getSRC_LOCATION_NATION_CODE() { + return SRC_LOCATION_NATION_CODE; + } + + public void setSRC_LOCATION_NATION_CODE(String SRC_LOCATION_NATION_CODE) { + this.SRC_LOCATION_NATION_CODE = SRC_LOCATION_NATION_CODE; + } + + public String getSRC_LOCATION_REGION() { + return SRC_LOCATION_REGION; + } + + public void setSRC_LOCATION_REGION(String SRC_LOCATION_REGION) { + this.SRC_LOCATION_REGION = SRC_LOCATION_REGION; + } + + public int getSRC_PORT() { + return SRC_PORT; + } + + public void setSRC_PORT(int SRC_PORT) { + this.SRC_PORT = SRC_PORT; + } + + public String getDST_IP() { + return DST_IP; + } + + public void setDST_IP(String DST_IP) { + this.DST_IP = DST_IP; + } + + public String getIP_TYPE() { + return IP_TYPE; + } + + public void setIP_TYPE(String IP_TYPE) { + this.IP_TYPE = IP_TYPE; + } + + public String getDST_LOCATION_NATION() { + return DST_LOCATION_NATION; + } + + public void setDST_LOCATION_NATION(String DST_LOCATION_NATION) { + this.DST_LOCATION_NATION = DST_LOCATION_NATION; + } + + public String getDST_LOCATION_NATION_CODE() { + return DST_LOCATION_NATION_CODE; + } + + public void setDST_LOCATION_NATION_CODE(String DST_LOCATION_NATION_CODE) { + this.DST_LOCATION_NATION_CODE = DST_LOCATION_NATION_CODE; + } + + public String getDST_LOCATION_REGION() { + return DST_LOCATION_REGION; + } + + public void setDST_LOCATION_REGION(String DST_LOCATION_REGION) { + this.DST_LOCATION_REGION = DST_LOCATION_REGION; + } + + public int getDST_PORT() { + return DST_PORT; + } + + public void setDST_PORT(int DST_PORT) { + this.DST_PORT = DST_PORT; + } + + public String getMethod() { + return Method; + } + + public void setMethod(String method) { + Method = method; + } + + public String getRequest_URI() { + return Request_URI; + } + + public void setRequest_URI(String request_URI) { + Request_URI = request_URI; + } + + public String getUser_name() { + return User_name; + } + + public void setUser_name(String user_name) { + User_name = user_name; + } + + public String getService_domain() { + return Service_domain; + } + + public void setService_domain(String service_domain) { + Service_domain = service_domain; + } + + public String getService_domain_valid() { + return Service_domain_valid; + } + + public void setService_domain_valid(String service_domain_valid) { + Service_domain_valid = service_domain_valid; + } + + public String getRes_stat() { + return Res_stat; + } + + public void setRes_stat(String res_stat) { + Res_stat = res_stat; + } + + public String getRes_stat_format() { + return Res_stat_format; + } + + public void setRes_stat_format(String res_stat_format) { + Res_stat_format = res_stat_format; + } + + public String getFrom() { + return From; + } + + public void setFrom(String from) { + From = from; + } + + public String getFrom_Nickname() { + return From_Nickname; + } + + public void setFrom_Nickname(String from_Nickname) { + From_Nickname = from_Nickname; + } + + public String getFrom_usr_name() { + return From_usr_name; + } + + public void setFrom_usr_name(String from_usr_name) { + From_usr_name = from_usr_name; + } + + public String getFrom_ser_domain() { + return From_ser_domain; + } + + public void setFrom_ser_domain(String from_ser_domain) { + From_ser_domain = from_ser_domain; + } + + public String getFrom_ser_domain_valid() { + return From_ser_domain_valid; + } + + public void setFrom_ser_domain_valid(String from_ser_domain_valid) { + From_ser_domain_valid = from_ser_domain_valid; + } + + public String getFrom_tag() { + return From_tag; + } + + public void setFrom_tag(String from_tag) { + From_tag = from_tag; + } + + public String getTo() { + return To; + } + + public void setTo(String to) { + To = to; + } + + public String getTo_Nickname() { + return To_Nickname; + } + + public void setTo_Nickname(String to_Nickname) { + To_Nickname = to_Nickname; + } + + public String getTo_usr_name() { + return To_usr_name; + } + + public void setTo_usr_name(String to_usr_name) { + To_usr_name = to_usr_name; + } + + public String getTo_ser_domain() { + return To_ser_domain; + } + + public void setTo_ser_domain(String to_ser_domain) { + To_ser_domain = to_ser_domain; + } + + public String getTo_ser_domain_valid() { + return To_ser_domain_valid; + } + + public void setTo_ser_domain_valid(String to_ser_domain_valid) { + To_ser_domain_valid = to_ser_domain_valid; + } + + public String getTo_tag() { + return To_tag; + } + + public void setTo_tag(String to_tag) { + To_tag = to_tag; + } + + public String getCseq() { + return Cseq; + } + + public void setCseq(String cseq) { + Cseq = cseq; + } + + public String getCseq_method() { + return Cseq_method; + } + + public void setCseq_method(String cseq_method) { + Cseq_method = cseq_method; + } + + public String getUser_Agent() { + return User_Agent; + } + + public void setUser_Agent(String user_Agent) { + User_Agent = user_Agent; + } + + public String getDevice_type() { + return Device_type; + } + + public void setDevice_type(String device_type) { + Device_type = device_type; + } + + public String getMax_Forwards() { + return Max_Forwards; + } + + public void setMax_Forwards(String max_Forwards) { + Max_Forwards = max_Forwards; + } + + public String getServer() { + return Server; + } + + public void setServer(String server) { + Server = server; + } + + public String getServer_type() { + return Server_type; + } + + public void setServer_type(String server_type) { + Server_type = server_type; + } + + public String[] getReq_Via() { + return Req_Via; + } + + public void setReq_Via(String[] req_Via) { + Req_Via = req_Via; + } + + public String getReq_Via_Json() { + return Req_Via_Json; + } + + public void setReq_Via_Json(String req_Via_Json) { + Req_Via_Json = req_Via_Json; + } + + public String getReq_Contact() { + return Req_Contact; + } + + public void setReq_Contact(String req_Contact) { + Req_Contact = req_Contact; + } + + public String getReq_Contact_Nickname() { + return Req_Contact_Nickname; + } + + public void setReq_Contact_Nickname(String req_Contact_Nickname) { + Req_Contact_Nickname = req_Contact_Nickname; + } + + public String getReq_Contact_usr_name() { + return Req_Contact_usr_name; + } + + public void setReq_Contact_usr_name(String req_Contact_usr_name) { + Req_Contact_usr_name = req_Contact_usr_name; + } + + public String getReq_Contact_ser_domain() { + return Req_Contact_ser_domain; + } + + public void setReq_Contact_ser_domain(String req_Contact_ser_domain) { + Req_Contact_ser_domain = req_Contact_ser_domain; + } + + public String getReq_ser_domain_valid() { + return Req_ser_domain_valid; + } + + public void setReq_ser_domain_valid(String req_ser_domain_valid) { + Req_ser_domain_valid = req_ser_domain_valid; + } + + public String[] getReq_Record_Route() { + return Req_Record_Route; + } + + public void setReq_Record_Route(String[] req_Record_Route) { + Req_Record_Route = req_Record_Route; + } + + public String getReq_Record_Route_Json() { + return Req_Record_Route_Json; + } + + public void setReq_Record_Route_Json(String req_Record_Route_Json) { + Req_Record_Route_Json = req_Record_Route_Json; + } + + public String[] getReq_Route() { + return Req_Route; + } + + public void setReq_Route(String[] req_Route) { + Req_Route = req_Route; + } + + public String getReq_Route_Json() { + return Req_Route_Json; + } + + public void setReq_Route_Json(String req_Route_Json) { + Req_Route_Json = req_Route_Json; + } + + public String getReq_Expires() { + return Req_Expires; + } + + public void setReq_Expires(String req_Expires) { + Req_Expires = req_Expires; + } + + public String getReq_Others() { + return Req_Others; + } + + public void setReq_Others(String req_Others) { + Req_Others = req_Others; + } + + public String getReq_Content_Type() { + return Req_Content_Type; + } + + public void setReq_Content_Type(String req_Content_Type) { + Req_Content_Type = req_Content_Type; + } + + public String getReq_Content() { + return Req_Content; + } + + public void setReq_Content(String req_Content) { + Req_Content = req_Content; + } + + public String[] getRes_Via() { + return Res_Via; + } + + public void setRes_Via(String[] res_Via) { + Res_Via = res_Via; + } + + public String getRes_Via_Json() { + return Res_Via_Json; + } + + public void setRes_Via_Json(String res_Via_Json) { + Res_Via_Json = res_Via_Json; + } + + public String getRes_Contact() { + return Res_Contact; + } + + public void setRes_Contact(String res_Contact) { + Res_Contact = res_Contact; + } + + public String getRes_Contact_Nickname() { + return Res_Contact_Nickname; + } + + public void setRes_Contact_Nickname(String res_Contact_Nickname) { + Res_Contact_Nickname = res_Contact_Nickname; + } + + public String getRes_Contact_usr_name() { + return Res_Contact_usr_name; + } + + public void setRes_Contact_usr_name(String res_Contact_usr_name) { + Res_Contact_usr_name = res_Contact_usr_name; + } + + public String getRes_Contact_ser_domain() { + return Res_Contact_ser_domain; + } + + public void setRes_Contact_ser_domain(String res_Contact_ser_domain) { + Res_Contact_ser_domain = res_Contact_ser_domain; + } + + public String getRes_ser_domain_valid() { + return Res_ser_domain_valid; + } + + public void setRes_ser_domain_valid(String res_ser_domain_valid) { + Res_ser_domain_valid = res_ser_domain_valid; + } + + public String[] getRes_Record_Route() { + return Res_Record_Route; + } + + public void setRes_Record_Route(String[] res_Record_Route) { + Res_Record_Route = res_Record_Route; + } + + public String getRes_Record_Route_Json() { + return Res_Record_Route_Json; + } + + public void setRes_Record_Route_Json(String res_Record_Route_Json) { + Res_Record_Route_Json = res_Record_Route_Json; + } + + public String[] getRes_Route() { + return Res_Route; + } + + public void setRes_Route(String[] res_Route) { + Res_Route = res_Route; + } + + public String getRes_Route_Json() { + return Res_Route_Json; + } + + public void setRes_Route_Json(String res_Route_Json) { + Res_Route_Json = res_Route_Json; + } + + public String getRes_Expires() { + return Res_Expires; + } + + public void setRes_Expires(String res_Expires) { + Res_Expires = res_Expires; + } + + public String getRes_Others() { + return Res_Others; + } + + public void setRes_Others(String res_Others) { + Res_Others = res_Others; + } + + public String getRes_Content_Type() { + return Res_Content_Type; + } + + public void setRes_Content_Type(String res_Content_Type) { + Res_Content_Type = res_Content_Type; + } + + public String getRes_Content() { + return Res_Content; + } + + public void setRes_Content(String res_Content) { + Res_Content = res_Content; + } + + public String getReq_coding() { + return Req_coding; + } + + public void setReq_coding(String req_coding) { + Req_coding = req_coding; + } + + public String getRes_coding() { + return Res_coding; + } + + public void setRes_coding(String res_coding) { + Res_coding = res_coding; + } + + public long getStat_time() { + return stat_time; + } + + public void setStat_time(long stat_time) { + this.stat_time = stat_time; + } +} |
