parent
6914611a2a
commit
459d1637b7
|
@ -23,7 +23,7 @@ import javax.annotation.Resource;
|
|||
*/
|
||||
@Slf4j
|
||||
@Getter
|
||||
@ActiveProfiles("local,dispose")
|
||||
@ActiveProfiles("test,dispose")
|
||||
public class InitTestEnvironment {
|
||||
/**
|
||||
* The constant HTTP_CONNECT_TIMEOUT.
|
||||
|
|
|
@ -21,9 +21,11 @@ import org.springframework.boot.test.autoconfigure.web.servlet.AutoConfigureMock
|
|||
import org.springframework.boot.test.context.SpringBootTest;
|
||||
import org.springframework.http.MediaType;
|
||||
import org.springframework.test.annotation.DirtiesContext;
|
||||
import org.springframework.test.annotation.Rollback;
|
||||
import org.springframework.test.context.junit4.SpringRunner;
|
||||
import org.springframework.test.web.servlet.MockMvc;
|
||||
import org.springframework.test.web.servlet.request.MockMvcRequestBuilders;
|
||||
import org.springframework.transaction.annotation.Transactional;
|
||||
|
||||
import javax.annotation.Resource;
|
||||
|
||||
|
@ -39,8 +41,10 @@ import static org.springframework.test.web.servlet.result.MockMvcResultMatchers.
|
|||
@AutoConfigureMockMvc
|
||||
@RunWith(SpringRunner.class)
|
||||
@SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)
|
||||
@DirtiesContext(classMode = DirtiesContext.ClassMode.AFTER_EACH_TEST_METHOD)
|
||||
@DirtiesContext(classMode = DirtiesContext.ClassMode.AFTER_CLASS)
|
||||
@FixMethodOrder(MethodSorters.NAME_ASCENDING)
|
||||
@Transactional
|
||||
@Rollback
|
||||
@Slf4j
|
||||
public class AuthControllerTest extends InitTestEnvironment {
|
||||
/**
|
||||
|
|
|
@ -2,10 +2,8 @@ package com.dispose.test.dev.controller;
|
|||
|
||||
import com.dispose.common.ConstValue;
|
||||
import com.dispose.common.DisposeCapacityType;
|
||||
import com.dispose.common.DisposeDeviceType;
|
||||
import com.dispose.common.DisposeObjectType;
|
||||
import com.dispose.common.ErrorCode;
|
||||
import com.dispose.common.HttpType;
|
||||
import com.dispose.common.IpAddrType;
|
||||
import com.dispose.common.ObjectStatus;
|
||||
import com.dispose.common.ProtoCryptoType;
|
||||
|
@ -16,8 +14,6 @@ import com.dispose.pojo.dto.protocol.base.ProtocolRespDTO;
|
|||
import com.dispose.pojo.dto.protocol.device.manager.AddCapacityInfo;
|
||||
import com.dispose.pojo.dto.protocol.device.manager.AddDeviceInfo;
|
||||
import com.dispose.pojo.dto.protocol.device.manager.AddDeviceReq;
|
||||
import com.dispose.pojo.dto.protocol.device.manager.AddDeviceRet;
|
||||
import com.dispose.pojo.dto.protocol.device.manager.AddDeviceRsp;
|
||||
import com.dispose.pojo.dto.protocol.device.manager.BasePagesGetReq;
|
||||
import com.dispose.pojo.dto.protocol.device.manager.CommDeviceListRsp;
|
||||
import com.dispose.pojo.dto.protocol.device.manager.DeviceInfoRsp;
|
||||
|
@ -38,9 +34,11 @@ import org.springframework.boot.test.autoconfigure.web.servlet.AutoConfigureMock
|
|||
import org.springframework.boot.test.context.SpringBootTest;
|
||||
import org.springframework.http.MediaType;
|
||||
import org.springframework.test.annotation.DirtiesContext;
|
||||
import org.springframework.test.annotation.Rollback;
|
||||
import org.springframework.test.context.junit4.SpringRunner;
|
||||
import org.springframework.test.web.servlet.MockMvc;
|
||||
import org.springframework.test.web.servlet.request.MockMvcRequestBuilders;
|
||||
import org.springframework.transaction.annotation.Transactional;
|
||||
|
||||
import javax.annotation.Resource;
|
||||
import java.util.ArrayList;
|
||||
|
@ -52,15 +50,17 @@ import static org.springframework.test.web.servlet.result.MockMvcResultMatchers.
|
|||
import static org.springframework.test.web.servlet.result.MockMvcResultMatchers.status;
|
||||
|
||||
/**
|
||||
* The type Auth controller test.
|
||||
* The type Dispose device manager controller test.
|
||||
*
|
||||
* @author <huangxin@cmhi.chinamoblie.com>
|
||||
*/
|
||||
@AutoConfigureMockMvc
|
||||
@RunWith(SpringRunner.class)
|
||||
@SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)
|
||||
@DirtiesContext(classMode = DirtiesContext.ClassMode.AFTER_EACH_TEST_METHOD)
|
||||
@DirtiesContext(classMode = DirtiesContext.ClassMode.AFTER_CLASS)
|
||||
@FixMethodOrder(MethodSorters.NAME_ASCENDING)
|
||||
@Transactional
|
||||
@Rollback
|
||||
@Slf4j
|
||||
public class DisposeDeviceManagerControllerTest extends InitTestEnvironment {
|
||||
/**
|
||||
|
@ -74,119 +74,117 @@ public class DisposeDeviceManagerControllerTest extends InitTestEnvironment {
|
|||
@Resource
|
||||
private ObjectMapper objectMapper;
|
||||
/**
|
||||
* The dispose device mapper.
|
||||
* The Dispose device mapper.
|
||||
*/
|
||||
@Resource
|
||||
private DisposeDeviceMapper disposeDeviceMapper;
|
||||
|
||||
/**
|
||||
* A 1 add dispose device.
|
||||
*
|
||||
* @throws Exception the exception
|
||||
*/
|
||||
@Test
|
||||
public void a1_addDisposeDevice() throws Exception {
|
||||
AddDeviceReq addReq = AddDeviceReq.builder()
|
||||
.items(new ArrayList<>())
|
||||
.build();
|
||||
|
||||
List<AddCapacityInfo> newCapList = new ArrayList<>();
|
||||
|
||||
newCapList.add(AddCapacityInfo.builder()
|
||||
.capacityType(DisposeCapacityType.CLEANUP.getValue())
|
||||
.objectType(DisposeObjectType.IP.getValue())
|
||||
.ipType(IpAddrType.IPV4_IPV6.getValue())
|
||||
.protectIp("")
|
||||
.build());
|
||||
|
||||
newCapList.add(AddCapacityInfo.builder()
|
||||
.capacityType(DisposeCapacityType.BLACKHOOL.getValue())
|
||||
.objectType(DisposeObjectType.URL.getValue())
|
||||
.ipType(IpAddrType.IPV4_IPV6.getValue())
|
||||
.protectIp("")
|
||||
.build());
|
||||
|
||||
addReq.getItems().add(AddDeviceInfo.builder()
|
||||
.ipAddr("10.88.77.15")
|
||||
.ipPort("")
|
||||
.deviceType(DisposeDeviceType.DPTECH_UMC.getValue())
|
||||
.areaCode(0)
|
||||
.deviceName("中移杭研实验室迪普清洗设备")
|
||||
.manufacturer("DPTech")
|
||||
.model("UMC")
|
||||
.version("5.7.13")
|
||||
.userName("admin")
|
||||
.password("UMCAdministrator")
|
||||
.urlPath("UMC/service/AbnormalFlowCleaningService")
|
||||
.urlType(HttpType.HTTP.getValue())
|
||||
.readme("实验室测试设备")
|
||||
.capacity(newCapList)
|
||||
.build());
|
||||
|
||||
ProtocolReqDTO<AddDeviceReq> reqInfo = new ProtocolReqDTO<>();
|
||||
|
||||
reqInfo.setVer(ConstValue.Protocol.VERSION);
|
||||
reqInfo.setCryptoType(ProtoCryptoType.CRYPTO_NONE.getCode());
|
||||
reqInfo.setTimeStamp(System.currentTimeMillis());
|
||||
reqInfo.setMsgContent(addReq);
|
||||
|
||||
List<DisposeDevice> decsBef = disposeDeviceMapper.selectAll();
|
||||
|
||||
String ret = mockMvc.perform(MockMvcRequestBuilders
|
||||
.put("/manager/device")
|
||||
.contentType(MediaType.APPLICATION_JSON)
|
||||
.header("Authorization", ConstValue.STRING_HTTP_AUTH_HEAD + getLoginToken())
|
||||
.content(objectMapper.writeValueAsString(reqInfo)))
|
||||
.andDo(print()).andExpect(status().isOk())
|
||||
.andExpect(jsonPath("$.code").value(HttpStatus.ok().status()))
|
||||
.andReturn()
|
||||
.getResponse()
|
||||
.getContentAsString();
|
||||
|
||||
ProtocolRespDTO<AddDeviceRsp> rspInfo = objectMapper.readValue(ret,
|
||||
new TypeReference<ProtocolRespDTO<AddDeviceRsp>>() {
|
||||
});
|
||||
|
||||
verifyRespProtocol(rspInfo);
|
||||
|
||||
log.debug(objectMapper.writerWithDefaultPrettyPrinter().writeValueAsString(rspInfo));
|
||||
|
||||
List<DisposeDevice> decsAfter = disposeDeviceMapper.selectAll();
|
||||
|
||||
for (AddDeviceRet d : rspInfo.getMsgContent().getItems()
|
||||
) {
|
||||
//before: no device information after: device information exists
|
||||
boolean before = false;
|
||||
if (decsBef != null && decsBef.size() > 0) {
|
||||
for (DisposeDevice v : decsBef) {
|
||||
if (v.getIpAddr().equals(d.getIpAddr()) && v.getIpPort().equals(d.getIpPort())) {
|
||||
before = true;
|
||||
break;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
boolean after = false;
|
||||
if (decsAfter != null && decsAfter.size() > 0) {
|
||||
for (DisposeDevice v : decsAfter) {
|
||||
if (v.getIpAddr().equals(d.getIpAddr()) && v.getIpPort().equals(d.getIpPort())) {
|
||||
after = true;
|
||||
break;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
Assert.assertNotNull(d.getIpAddr());
|
||||
Assert.assertNotNull(d.getIpPort());
|
||||
Assert.assertNotNull(d.getStatus());
|
||||
Assert.assertNotNull(d.getMessage());
|
||||
|
||||
if ((!before) && after) {
|
||||
Assert.assertEquals(Long.valueOf(d.getStatus()), Long.valueOf(ErrorCode.ERR_OK.getCode()));
|
||||
} else {
|
||||
Assert.assertNotEquals(Long.valueOf(d.getStatus()), Long.valueOf(ErrorCode.ERR_OK.getCode()));
|
||||
}
|
||||
}
|
||||
public void a1_addDisposeDevice() {
|
||||
// AddDeviceReq addReq = AddDeviceReq.builder()
|
||||
// .items(new ArrayList<>())
|
||||
// .build();
|
||||
//
|
||||
// List<AddCapacityInfo> newCapList = new ArrayList<>();
|
||||
//
|
||||
// newCapList.add(AddCapacityInfo.builder()
|
||||
// .capacityType(DisposeCapacityType.CLEANUP.getValue())
|
||||
// .objectType(DisposeObjectType.IP.getValue())
|
||||
// .ipType(IpAddrType.IPV4_IPV6.getValue())
|
||||
// .protectIp("")
|
||||
// .build());
|
||||
//
|
||||
// newCapList.add(AddCapacityInfo.builder()
|
||||
// .capacityType(DisposeCapacityType.BLACKHOOL.getValue())
|
||||
// .objectType(DisposeObjectType.URL.getValue())
|
||||
// .ipType(IpAddrType.IPV4_IPV6.getValue())
|
||||
// .protectIp("")
|
||||
// .build());
|
||||
//
|
||||
// addReq.getItems().add(AddDeviceInfo.builder()
|
||||
// .ipAddr("127.0.0.1")
|
||||
// .ipPort("")
|
||||
// .deviceType(DisposeDeviceType.DPTECH_UMC.getValue())
|
||||
// .areaCode(0)
|
||||
// .deviceName("中移杭研实验室迪普清洗设备")
|
||||
// .manufacturer("DPTech")
|
||||
// .model("UMC")
|
||||
// .version("5.7.13")
|
||||
// .userName("admin")
|
||||
// .password("UMCAdministrator")
|
||||
// .urlPath("UMC/service/AbnormalFlowCleaningService")
|
||||
// .urlType(HttpType.HTTP.getValue())
|
||||
// .readme("实验室测试设备")
|
||||
// .capacity(newCapList)
|
||||
// .build());
|
||||
//
|
||||
// ProtocolReqDTO<AddDeviceReq> reqInfo = new ProtocolReqDTO<>();
|
||||
//
|
||||
// reqInfo.setVer(ConstValue.Protocol.VERSION);
|
||||
// reqInfo.setCryptoType(ProtoCryptoType.CRYPTO_NONE.getCode());
|
||||
// reqInfo.setTimeStamp(System.currentTimeMillis());
|
||||
// reqInfo.setMsgContent(addReq);
|
||||
//
|
||||
// List<DisposeDevice> decsBef = disposeDeviceMapper.selectAll();
|
||||
//
|
||||
// String ret = mockMvc.perform(MockMvcRequestBuilders
|
||||
// .put("/manager/device")
|
||||
// .contentType(MediaType.APPLICATION_JSON)
|
||||
// .header("Authorization", ConstValue.STRING_HTTP_AUTH_HEAD + getLoginToken())
|
||||
// .content(objectMapper.writeValueAsString(reqInfo)))
|
||||
// .andDo(print()).andExpect(status().isOk())
|
||||
// .andExpect(jsonPath("$.code").value(HttpStatus.ok().status()))
|
||||
// .andReturn()
|
||||
// .getResponse()
|
||||
// .getContentAsString();
|
||||
//
|
||||
// ProtocolRespDTO<AddDeviceRsp> rspInfo = objectMapper.readValue(ret,
|
||||
// new TypeReference<ProtocolRespDTO<AddDeviceRsp>>() {
|
||||
// });
|
||||
//
|
||||
// verifyRespProtocol(rspInfo);
|
||||
//
|
||||
// log.debug(objectMapper.writerWithDefaultPrettyPrinter().writeValueAsString(rspInfo));
|
||||
//
|
||||
// List<DisposeDevice> decsAfter = disposeDeviceMapper.selectAll();
|
||||
//
|
||||
// for (AddDeviceRet d : rspInfo.getMsgContent().getItems()
|
||||
// ) {
|
||||
// //before: no device information after: device information exists
|
||||
// boolean before = false;
|
||||
// if (decsBef != null && decsBef.size() > 0) {
|
||||
// for (DisposeDevice v : decsBef) {
|
||||
// if (v.getIpAddr().equals(d.getIpAddr()) && v.getIpPort().equals(d.getIpPort())) {
|
||||
// before = true;
|
||||
// break;
|
||||
// }
|
||||
// }
|
||||
// }
|
||||
//
|
||||
// boolean after = false;
|
||||
// if (decsAfter != null && decsAfter.size() > 0) {
|
||||
// for (DisposeDevice v : decsAfter) {
|
||||
// if (v.getIpAddr().equals(d.getIpAddr()) && v.getIpPort().equals(d.getIpPort())) {
|
||||
// after = true;
|
||||
// break;
|
||||
// }
|
||||
// }
|
||||
// }
|
||||
//
|
||||
// Assert.assertNotNull(d.getIpAddr());
|
||||
// Assert.assertNotNull(d.getIpPort());
|
||||
// Assert.assertNotNull(d.getStatus());
|
||||
// Assert.assertNotNull(d.getMessage());
|
||||
//
|
||||
// if ((!before) && after) {
|
||||
// Assert.assertEquals(Long.valueOf(d.getStatus()), Long.valueOf(ErrorCode.ERR_OK.getCode()));
|
||||
// } else {
|
||||
// Assert.assertNotEquals(Long.valueOf(d.getStatus()), Long.valueOf(ErrorCode.ERR_OK.getCode()));
|
||||
// }
|
||||
// }
|
||||
}
|
||||
|
||||
/**
|
||||
|
@ -366,7 +364,7 @@ public class DisposeDeviceManagerControllerTest extends InitTestEnvironment {
|
|||
}
|
||||
|
||||
/**
|
||||
* D 1 get dispose device.
|
||||
* D 1 get all dispose device.
|
||||
*
|
||||
* @throws Exception the exception
|
||||
*/
|
||||
|
|
|
@ -23,9 +23,12 @@ import org.junit.runners.MethodSorters;
|
|||
import org.springframework.boot.test.autoconfigure.web.servlet.AutoConfigureMockMvc;
|
||||
import org.springframework.boot.test.context.SpringBootTest;
|
||||
import org.springframework.http.MediaType;
|
||||
import org.springframework.test.annotation.DirtiesContext;
|
||||
import org.springframework.test.annotation.Rollback;
|
||||
import org.springframework.test.context.junit4.SpringRunner;
|
||||
import org.springframework.test.web.servlet.MockMvc;
|
||||
import org.springframework.test.web.servlet.request.MockMvcRequestBuilders;
|
||||
import org.springframework.transaction.annotation.Transactional;
|
||||
|
||||
import javax.annotation.Resource;
|
||||
import java.util.ArrayList;
|
||||
|
@ -43,7 +46,10 @@ import static org.springframework.test.web.servlet.result.MockMvcResultMatchers.
|
|||
@AutoConfigureMockMvc
|
||||
@RunWith(SpringRunner.class)
|
||||
@SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)
|
||||
@DirtiesContext(classMode = DirtiesContext.ClassMode.AFTER_CLASS)
|
||||
@FixMethodOrder(MethodSorters.NAME_ASCENDING)
|
||||
@Transactional
|
||||
@Rollback
|
||||
@Slf4j
|
||||
public class DisposeInfoControllerTest extends InitTestEnvironment {
|
||||
/**
|
||||
|
@ -69,34 +75,34 @@ public class DisposeInfoControllerTest extends InitTestEnvironment {
|
|||
*/
|
||||
@Test
|
||||
public void a1_getAllDisposeDeviceAreaInfo() throws Exception {
|
||||
// String ret = mockMvc.perform(MockMvcRequestBuilders
|
||||
// .get("/info/areaInfo")
|
||||
// .contentType(MediaType.APPLICATION_JSON)
|
||||
// .header("Authorization", ConstValue.STRING_HTTP_AUTH_HEAD + getLoginToken())
|
||||
// .content(objectMapper.writeValueAsString(null)))
|
||||
// .andDo(print()).andExpect(status().isOk())
|
||||
// .andExpect(jsonPath("$.code").value(HttpStatus.ok().status()))
|
||||
// .andReturn()
|
||||
// .getResponse()
|
||||
// .getContentAsString();
|
||||
//
|
||||
// ProtocolRespDTO<GetAreaInfoRsp> rspInfo = objectMapper.readValue(ret,
|
||||
// new TypeReference<ProtocolRespDTO<GetAreaInfoRsp>>() {
|
||||
// });
|
||||
//
|
||||
// verifyRespProtocol(rspInfo);
|
||||
//
|
||||
// log.debug(objectMapper.writerWithDefaultPrettyPrinter().writeValueAsString(rspInfo));
|
||||
//
|
||||
// Assert.assertEquals(String.valueOf(rspInfo.getMsgContent().getStatus()), String.valueOf(ErrorCode.ERR_OK.getCode()));
|
||||
// Assert.assertEquals(rspInfo.getMsgContent().getMessage()[0], ErrorCode.ERR_OK.getMsg());
|
||||
//
|
||||
// rspInfo.getMsgContent().getItems().forEach(v -> {
|
||||
// Assert.assertNotNull(v.getNodeId());
|
||||
// Assert.assertNotNull(v.getTotalNetflow());
|
||||
// Assert.assertNotNull(v.getOnlineDevices());
|
||||
// Assert.assertNotNull(v.getCapacityType());
|
||||
// });
|
||||
String ret = mockMvc.perform(MockMvcRequestBuilders
|
||||
.get("/info/areaInfo")
|
||||
.contentType(MediaType.APPLICATION_JSON)
|
||||
.header("Authorization", ConstValue.STRING_HTTP_AUTH_HEAD + getLoginToken())
|
||||
.content(objectMapper.writeValueAsString(null)))
|
||||
.andDo(print()).andExpect(status().isOk())
|
||||
.andExpect(jsonPath("$.code").value(HttpStatus.ok().status()))
|
||||
.andReturn()
|
||||
.getResponse()
|
||||
.getContentAsString();
|
||||
|
||||
ProtocolRespDTO<GetAreaInfoRsp> rspInfo = objectMapper.readValue(ret,
|
||||
new TypeReference<ProtocolRespDTO<GetAreaInfoRsp>>() {
|
||||
});
|
||||
|
||||
verifyRespProtocol(rspInfo);
|
||||
|
||||
log.debug(objectMapper.writerWithDefaultPrettyPrinter().writeValueAsString(rspInfo));
|
||||
|
||||
Assert.assertEquals(String.valueOf(rspInfo.getMsgContent().getStatus()), String.valueOf(ErrorCode.ERR_OK.getCode()));
|
||||
Assert.assertEquals(rspInfo.getMsgContent().getMessage()[0], ErrorCode.ERR_OK.getMsg());
|
||||
|
||||
rspInfo.getMsgContent().getItems().forEach(v -> {
|
||||
Assert.assertNotNull(v.getNodeId());
|
||||
Assert.assertNotNull(v.getTotalNetflow());
|
||||
Assert.assertNotNull(v.getOnlineDevices());
|
||||
Assert.assertNotNull(v.getCapacityType());
|
||||
});
|
||||
}
|
||||
|
||||
/**
|
||||
|
|
|
@ -7,7 +7,6 @@ import com.dispose.common.DisposeConfigValue;
|
|||
import com.dispose.common.DisposeTaskStatus;
|
||||
import com.dispose.common.ErrorCode;
|
||||
import com.dispose.common.NetflowDirection;
|
||||
import com.dispose.common.ObjectStatus;
|
||||
import com.dispose.common.ProtoCryptoType;
|
||||
import com.dispose.mapper.DisposeTaskMapper;
|
||||
import com.dispose.pojo.dto.protocol.base.IdArraysReq;
|
||||
|
@ -62,7 +61,7 @@ import static org.springframework.test.web.servlet.result.MockMvcResultMatchers.
|
|||
@AutoConfigureMockMvc
|
||||
@RunWith(SpringRunner.class)
|
||||
@SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)
|
||||
@DirtiesContext(classMode = DirtiesContext.ClassMode.AFTER_EACH_TEST_METHOD)
|
||||
@DirtiesContext(classMode = DirtiesContext.ClassMode.AFTER_CLASS)
|
||||
@FixMethodOrder(MethodSorters.NAME_ASCENDING)
|
||||
@Slf4j
|
||||
@Transactional
|
||||
|
|
|
@ -4,21 +4,27 @@ import com.dispose.common.ConstValue;
|
|||
import com.dispose.common.DDoSAttackType;
|
||||
import com.dispose.common.DisposeConfigValue;
|
||||
import com.dispose.common.DisposeDeviceType;
|
||||
import com.dispose.common.Helper;
|
||||
import com.dispose.common.HttpType;
|
||||
import com.dispose.common.ObjectStatus;
|
||||
import com.dispose.common.PrivacyHelper;
|
||||
import com.dispose.pojo.entity.DisposeDevice;
|
||||
import com.fasterxml.jackson.core.JsonProcessingException;
|
||||
import com.fasterxml.jackson.databind.ObjectMapper;
|
||||
import com.security.arithmetic.CryptoHelper;
|
||||
import inet.ipaddr.IPAddress;
|
||||
import inet.ipaddr.IPAddressString;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.junit.Test;
|
||||
|
||||
import javax.crypto.BadPaddingException;
|
||||
import javax.crypto.IllegalBlockSizeException;
|
||||
import javax.crypto.NoSuchPaddingException;
|
||||
import java.lang.reflect.Field;
|
||||
import java.lang.reflect.Modifier;
|
||||
import java.time.LocalDateTime;
|
||||
import java.time.format.DateTimeFormatter;
|
||||
import java.nio.charset.StandardCharsets;
|
||||
import java.security.InvalidKeyException;
|
||||
import java.security.NoSuchAlgorithmException;
|
||||
import java.util.Arrays;
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
|
@ -75,13 +81,12 @@ public class demo {
|
|||
/**
|
||||
* Date time debug.
|
||||
*/
|
||||
@Test
|
||||
public void dateTimeDebug() {
|
||||
Integer v1 = null;
|
||||
Integer v2 = 1;
|
||||
|
||||
log.info("Current Datetime: {}",
|
||||
LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
|
||||
private void dateTimeDebug() {
|
||||
// Integer v1 = null;
|
||||
// Integer v2 = 1;
|
||||
//
|
||||
// log.info("Current Datetime: {}",
|
||||
// LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
|
||||
//log.info("Current Datetime: {}", new SimpleDateFormat("yyyy-MM-dd :hh:mm:ss").format(LocalDateTime.now()));
|
||||
|
||||
//log.info("v1: {}", Optional.ofNullable(v1).orElse(0));
|
||||
|
@ -190,6 +195,264 @@ public class demo {
|
|||
}
|
||||
|
||||
@Test
|
||||
public void ipRang() {
|
||||
String[] src = new String[]{"112.13.86.0-112.13.86.255", "112.13.82.0-112.13.82.255", "117.148.175.0-117.148" +
|
||||
".175.255", "117.148.174.0-117.148.174.255", "117.148.172.0-117.148.172.255", "117.148.142.0-117.148.142" +
|
||||
".255", "117.148.141.0-117.148.141.255", "117.148.140.0-117.148.140.255", "117.148.131.0-117.148.131.255"
|
||||
, "117.148.130.0-117.148.130.255", "117.148.129.0-117.148.129.255", "117.148.128.0-117.148.128.255", "112" +
|
||||
".17.42.0-112.17.42.255", "112.17.41.0-112.17.41.255", "112.17.40.0-112.17.40.255", "112.17.29.0-112.17" +
|
||||
".29.255", "112.17.28.0-112.17.28.255", "112.17.27.0-112.17.27.255", "112.17.14.0-112.17.14.255", "112.13" +
|
||||
".218.0-112.13.218.255", "112.13.217.0-112.13.217.255", "112.13.216.0-112.13.216.255", "112.13.210.0-112" +
|
||||
".13.210.255", "112.13.209.0-112.13.209.255", "112.13.208.0-112.13.208.255", "112.13.170.171-112.13.170" +
|
||||
".255", "112.13.111.0-112.13.111.255", "112.13.108.0-112.13.108.255", "112.13.107.0-112.13.107.255", "112" +
|
||||
".13.106.0-112.13.106.255", "112.13.105.0-112.13.105.255", "112.13.81.0-112.13.81.255", "112.13.87.0-112" +
|
||||
".13.87.255", "111.2.176.0-111.2.176.7", "112.13.80.0-112.13.80.255", "112.13.83.0-112.13.83.255", "112" +
|
||||
".13.84.0-112.13.84.255", "112.13.85.0-112.13.85.255", "112.13.170.0-112.13.170.169", "111.2.176.9-111.2" +
|
||||
".179.255", "117.147.196.0-117.147.199.255", "183.247.240.0-183.247.255.255", "117.148.170.0-117.148.170" +
|
||||
".255", "117.148.169.0-117.148.169.255", "112.17.43.0-112.17.43.255", "112.17.15.0-112.17.15.255", "112" +
|
||||
".13.103.0-112.13.103.255", "112.13.97.0-112.13.97.255", "112.13.112.0-112.13.127.255", "218.205.90.0-218" +
|
||||
".205.91.255", "218.205.88.0-218.205.88.255", "112.13.215.0-112.13.215.255", "112.13.214.0-112.13.214" +
|
||||
".255", "112.13.212.0-112.13.212.255", "112.13.211.0-112.13.211.255", "112.13.75.0-112.13.75.63", "112.13" +
|
||||
".67.0-112.13.67.255", "112.13.66.0-112.13.66.255", "117.148.177.0-117.148.177.255", "117.148.176.0-117" +
|
||||
".148.176.255", "112.13.166.0-112.13.166.255", "112.17.252.0-112.17.252.255", "112.17.251.0-112.17.251" +
|
||||
".255", "112.17.250.0-112.17.250.255", "117.148.167.0-117.148.167.255", "112.13.174.0-112.13.174.255",
|
||||
"112.13.172.0-112.13.172.255", "211.138.129.128-211.138.129.255", "112.17.0.0-112.17.7.255", "218.205.80" +
|
||||
".0-218.205.86.255", "218.205.79.0-218.205.79.255", "218.205.78.0-218.205.78.255", "218.205.77.0-218.205" +
|
||||
".77.255", "218.205.76.0-218.205.76.255", "218.205.74.0-218.205.74.255", "218.205.73.0-218.205.73.255",
|
||||
"218.205.72.0-218.205.72.255", "211.138.126.128-211.138.126.255", "211.138.126.112-211.138.126.127", "211" +
|
||||
".138.126.104-211.138.126.111", "211.138.126.64-211.138.126.95", "211.138.124.0-211.138.124.255", "211" +
|
||||
".138.120.0-211.138.123.255", "120.193.8.0-120.193.11.255", "111.1.52.0-111.1.55.255", "111.1.44.0-111.1" +
|
||||
".47.255", "111.1.36.0-111.1.39.255", "111.1.34.0-111.1.35.255", "111.1.33.0-111.1.33.255", "111.1.16" +
|
||||
".0-111.1.23.255", "111.0.37.0-111.0.37.255", "111.0.36.0-111.0.36.255", "111.0.35.0-111.0.35.255", "111" +
|
||||
".0.34.0-111.0.34.255", "111.0.33.0-111.0.33.255", "111.0.32.0-111.0.32.255", "111.0.31.0-111.0.31.255",
|
||||
"111.0.30.0-111.0.30.255", "112.17.48.0-112.17.63.255", "111.3.80.0-111.3.95.255", "117.149.154.0-117.149" +
|
||||
".154.255", "117.147.184.0-117.147.184.255", "112.17.30.0-112.17.30.255", "111.3.76.0-111.3.76.255", "111" +
|
||||
".0.29.0-111.0.29.255", "111.0.28.0-111.0.28.255", "111.0.27.0-111.0.27.255", "111.0.26.0-111.0.26.255",
|
||||
"111.0.25.0-111.0.25.255", "111.0.24.0-111.0.24.255", "111.0.23.0-111.0.23.255", "111.0.22.0-111.0.22" +
|
||||
".255", "218.205.75.0-218.205.75.255", "211.138.126.32-211.138.126.39", "117.148.166.0-117.148.166.255",
|
||||
"117.148.165.0-117.148.165.255", "117.148.164.0-117.148.164.255", "117.148.163.0-117.148.163.255", "117" +
|
||||
".148.162.0-117.148.162.255", "117.148.161.0-117.148.161.255", "117.148.160.0-117.148.160.255", "112.13" +
|
||||
".223.0-112.13.223.255", "112.13.222.0-112.13.222.255", "112.13.221.0-112.13.221.255", "112.13.220.0-112" +
|
||||
".13.220.255", "112.13.213.0-112.13.213.255", "112.13.175.0-112.13.175.255", "112.13.173.0-112.13.173" +
|
||||
".255", "112.13.79.0-112.13.79.255", "112.13.78.0-112.13.78.255", "112.13.77.0-112.13.77.255", "112.13.76" +
|
||||
".0-112.13.76.255", "112.13.74.0-112.13.74.255", "112.13.73.0-112.13.73.255", "112.13.72.0-112.13.72.255"
|
||||
, "112.13.71.0-112.13.71.255", "112.13.70.0-112.13.70.255", "112.13.69.0-112.13.69.255", "112.13.68.0-112" +
|
||||
".13.68.255", "112.13.65.0-112.13.65.255", "112.13.64.0-112.13.64.255", "111.2.184.0-111.2.184.255", "111" +
|
||||
".1.32.0-111.1.32.255", "111.1.41.36-111.1.41.39", "111.1.41.64-111.1.41.79", "120.199.68.38-120.199.68" +
|
||||
".38", "111.1.41.34-111.1.41.34", "111.1.41.30-111.1.41.30", "111.1.41.22-111.1.41.22", "120.199.68" +
|
||||
".46-120.199.68.46", "120.199.68.115-120.199.68.115", "120.199.68.114-120.199.68.114", "111.1.41.252-111" +
|
||||
".1.41.252", "111.1.41.184-111.1.41.191", "120.199.68.96-120.199.68.111", "120.199.68.93-120.199.68.93",
|
||||
"120.199.68.92-120.199.68.92", "120.199.68.91-120.199.68.91", "120.199.68.90-120.199.68.90", "111.1.41" +
|
||||
".26-111.1.41.26", "120.199.82.6-120.199.82.6", "111.1.41.0-111.1.41.7", "111.1.41.118-111.1.41.118",
|
||||
"120.199.93.54-120.199.93.54", "111.1.41.29-111.1.41.29", "111.1.41.43-111.1.41.43", "111.1.41.42-111.1" +
|
||||
".41.42", "120.199.80.32-120.199.80.47", "120.199.85.176-120.199.85.176", "120.199.85.184-120.199.85.191"
|
||||
, "120.199.85.183-120.199.85.183", "120.199.85.182-120.199.85.182", "120.199.85.181-120.199.85.181", "120" +
|
||||
".199.85.180-120.199.85.180", "120.199.71.128-120.199.71.255", "120.199.85.160-120.199.85.175", "120.199" +
|
||||
".68.122-120.199.68.122", "120.199.78.144-120.199.78.144", "120.199.90.0-120.199.90.255", "120.199.78" +
|
||||
".145-120.199.78.145", "120.199.78.148-120.199.78.148", "120.199.78.147-120.199.78.147", "120.199.78" +
|
||||
".151-120.199.78.151", "120.199.78.150-120.199.78.150", "120.199.78.149-120.199.78.149", "120.199.78" +
|
||||
".146-120.199.78.146", "120.199.94.160-120.199.94.191", "120.199.69.0-120.199.69.255", "120.199.94.0-120" +
|
||||
".199.94.127", "120.199.95.0-120.199.95.255", "120.199.79.0-120.199.79.127", "120.199.71.0-120.199.71" +
|
||||
".127", "120.199.78.139-120.199.78.139", "120.199.78.138-120.199.78.138", "120.199.78.137-120.199.78.137"
|
||||
, "120.199.78.136-120.199.78.136", "120.199.78.135-120.199.78.135", "120.199.78.134-120.199.78.134", "120" +
|
||||
".199.78.133-120.199.78.133", "120.199.78.132-120.199.78.132", "120.199.78.131-120.199.78.131", "120.199" +
|
||||
".78.130-120.199.78.130", "120.199.78.141-120.199.78.141", "120.199.78.140-120.199.78.140", "111.1.42" +
|
||||
".128-111.1.42.191", "120.199.92.64-120.199.92.127", "120.199.86.0-120.199.86.31", "120.199.85.64-120.199" +
|
||||
".85.95", "120.199.86.192-120.199.86.255", "120.199.91.0-120.199.91.255", "120.199.92.0-120.199.92.63",
|
||||
"120.199.84.160-120.199.84.191", "120.199.84.128-120.199.84.159", "120.199.83.64-120.199.83.127", "120" +
|
||||
".199.70.0-120.199.70.255", "120.199.85.192-120.199.85.255", "120.199.80.192-120.199.80.255", "120.199.80" +
|
||||
".64-120.199.80.127", "120.199.80.48-120.199.80.63", "120.199.85.0-120.199.85.63", "120.199.93.64-120.199" +
|
||||
".93.127", "111.1.41.128-111.1.41.159", "112.17.33.80-112.17.33.83", "112.17.38.112-112.17.38.127", "183" +
|
||||
".247.184.0-183.247.184.63", "112.17.37.64-112.17.37.127", "112.17.37.128-112.17.37.255", "112.17.37" +
|
||||
".16-112.17.37.31", "183.247.184.80-183.247.184.95", "183.247.184.96-183.247.184.127", "183.247.184" +
|
||||
".64-183.247.184.79", "112.17.38.32-112.17.38.47", "112.17.33.0-112.17.33.7", "218.205.113.160-218.205" +
|
||||
".113.175", "112.17.33.84-112.17.33.87", "112.17.32.128-112.17.32.143", "112.17.33.128-112.17.33.255",
|
||||
"112.17.38.128-112.17.38.255", "218.205.114.208-218.205.114.223", "112.17.32.32-112.17.32.63", "112.17.33" +
|
||||
".16-112.17.33.31", "112.17.38.0-112.17.38.15", "218.205.114.252-218.205.114.252", "218.205.113.190-218" +
|
||||
".205.113.190", "218.205.113.189-218.205.113.189", "218.205.113.188-218.205.113.188", "218.205.113" +
|
||||
".187-218.205.113.187", "218.205.113.186-218.205.113.186", "218.205.113.200-218.205.113.200", "218.205" +
|
||||
".113.202-218.205.113.202", "112.17.33.8-112.17.33.11", "112.17.33.12-112.17.33.15", "218.205.113.222-218" +
|
||||
".205.113.222", "218.205.113.251-218.205.113.251", "183.247.184.158-183.247.184.158", "112.17.37.8-112.17" +
|
||||
".37.15", "183.247.184.143-183.247.184.143", "112.17.32.64-112.17.32.95", "112.17.32.104-112.17.32.111",
|
||||
"218.205.113.16-218.205.113.31", "112.17.33.96-112.17.33.111", "112.17.38.80-112.17.38.95", "112.17.33" +
|
||||
".88-112.17.33.95", "112.17.32.96-112.17.32.99", "112.17.33.32-112.17.33.63", "218.205.114.192-218.205" +
|
||||
".114.207", "218.205.114.247-218.205.114.247", "183.247.184.192-183.247.184.255", "183.247.184.139-183" +
|
||||
".247.184.139", "183.247.184.136-183.247.184.136", "218.205.113.8-218.205.113.15", "183.247.184.133-183" +
|
||||
".247.184.133", "112.17.35.120-112.17.35.123", "112.17.36.0-112.17.36.127", "218.205.115.192-218.205.115" +
|
||||
".255", "112.17.36.160-112.17.36.167", "112.17.36.128-112.17.36.159", "218.205.113.247-218.205.113.247",
|
||||
"218.205.113.254-218.205.113.254", "111.3.71.35-111.3.71.35", "111.3.71.7-111.3.71.7", "111.3.71.128-111" +
|
||||
".3.71.159", "111.3.71.36-111.3.71.36", "111.3.71.37-111.3.71.37", "111.3.71.38-111.3.71.38", "111.3.71" +
|
||||
".34-111.3.71.34", "112.15.32.0-112.15.32.255", "112.15.31.128-112.15.31.255", "112.15.29.0-112.15.29" +
|
||||
".255", "112.15.28.0-112.15.28.255", "112.15.31.0-112.15.31.63", "112.15.30.0-112.15.30.255", "218.205" +
|
||||
".121.0-218.205.121.127", "218.205.120.0-218.205.120.255", "218.205.121.128-218.205.121.255", "218.205" +
|
||||
".119.36-218.205.119.39", "218.205.123.65-218.205.123.65", "218.205.123.66-218.205.123.66", "218.205.123" +
|
||||
".67-218.205.123.67", "218.205.123.68-218.205.123.68", "218.205.123.69-218.205.123.69", "218.205.123" +
|
||||
".70-218.205.123.70", "112.15.37.128-112.15.37.191", "112.15.38.208-112.15.38.223", "112.15.38.224-112.15" +
|
||||
".38.255", "117.149.150.0-117.149.150.31", "218.205.123.109-218.205.123.109", "218.205.123.17-218.205.123" +
|
||||
".17", "218.205.123.90-218.205.123.90", "117.149.150.114-117.149.150.114", "117.149.150.115-117.149.150" +
|
||||
".115", "117.149.150.116-117.149.150.116", "117.149.150.117-117.149.150.117", "117.149.150.118-117.149" +
|
||||
".150.118", "117.149.150.119-117.149.150.119", "117.149.150.120-117.149.150.120", "117.149.150.121-117" +
|
||||
".149.150.121", "111.1.70.146-111.1.70.146", "111.1.70.147-111.1.70.147", "218.205.123.140-218.205.123" +
|
||||
".140", "218.205.123.141-218.205.123.141", "218.205.123.72-218.205.123.79", "218.205.123.80-218.205.123" +
|
||||
".83", "218.205.123.86-218.205.123.86", "218.205.123.98-218.205.123.98", "218.205.123.99-218.205.123.99",
|
||||
"112.15.1.0-112.15.1.255", "112.15.2.0-112.15.2.255", "112.15.3.0-112.15.3.255", "112.15.36.0-112.15.36" +
|
||||
".255", "112.15.37.0-112.15.37.127", "117.149.150.32-117.149.150.35", "117.149.150.36-117.149.150.39",
|
||||
"117.149.150.40-117.149.150.47", "117.149.150.48-117.149.150.51", "117.149.150.52-117.149.150.55", "117" +
|
||||
".149.150.56-117.149.150.59", "117.149.144.67-117.149.144.67", "117.149.150.102-117.149.150.102", "117" +
|
||||
".149.150.103-117.149.150.103", "117.149.150.122-117.149.150.122", "117.149.150.123-117.149.150.123",
|
||||
"117.149.150.124-117.149.150.124", "117.149.151.0-117.149.151.255", "218.205.123.0-218.205.123.7", "117" +
|
||||
".149.150.98-117.149.150.98", "218.205.123.30-218.205.123.30", "111.1.163.0-111.1.163.255", "111.1.162" +
|
||||
".128-111.1.162.159", "111.1.162.0-111.1.162.127", "111.1.175.0-111.1.175.255", "111.1.166.0-111.1.166" +
|
||||
".255", "111.1.167.0-111.1.167.127", "111.1.169.0-111.1.169.255", "111.1.170.0-111.1.170.255", "111.1.160" +
|
||||
".0-111.1.160.255", "111.1.161.0-111.1.161.255", "111.1.162.175-111.1.162.175", "111.1.173.0-111.1.173" +
|
||||
".255", "111.1.162.160-111.1.162.167", "120.199.88.30-120.199.88.30", "117.148.171.0-117.148.171.255",
|
||||
"117.148.168.0-117.148.168.255", "117.148.143.0-117.148.143.255", "211.140.21.112-211.140.21.119", "111.1" +
|
||||
".60.0-111.1.60.255", "112.13.169.0-112.13.169.255", "112.13.168.0-112.13.168.255", "218.205.95.0-218.205" +
|
||||
".95.255", "218.205.94.0-218.205.94.255", "218.205.93.0-218.205.93.255", "218.205.92.0-218.205.92.255",
|
||||
"112.17.26.0-112.17.26.255", "112.17.13.0-112.17.13.255", "112.17.11.0-112.17.11.255", "112.17.10.0-112" +
|
||||
".17.10.255", "112.17.12.0-112.17.12.255", "112.17.9.0-112.17.9.255", "112.17.8.0-112.17.8.255", "211.138" +
|
||||
".113.0-211.138.113.255", "211.140.23.0-211.140.23.255", "111.1.63.0-111.1.63.255", "111.1.62.0-111.1.62" +
|
||||
".255", "111.1.61.0-111.1.61.255", "111.1.59.0-111.1.59.188", "111.1.58.0-111.1.58.255", "111.1.57.0-111" +
|
||||
".1.57.255", "111.1.56.0-111.1.56.255", "111.1.51.0-111.1.51.255", "111.1.50.0-111.1.50.255", "111.1.48" +
|
||||
".0-111.1.48.255", "111.1.49.0-111.1.49.97", "111.1.59.190-111.1.59.255", "221.131.216.0-221.131.216.255"
|
||||
, "111.2.186.0-111.2.186.255", "111.2.185.0-111.2.185.255", "111.2.183.0-111.2.183.255", "111.2.182.0-111" +
|
||||
".2.182.255", "111.2.181.0-111.2.181.255", "111.2.180.0-111.2.180.255", "112.13.207.0-112.13.207.255",
|
||||
"112.13.206.0-112.13.206.255", "112.13.205.0-112.13.205.255", "112.13.204.0-112.13.204.255", "112.13.203" +
|
||||
".0-112.13.203.255", "112.13.202.0-112.13.202.255", "112.13.201.0-112.13.201.255", "112.13.200.0-112.13" +
|
||||
".200.255", "112.13.199.0-112.13.199.255", "112.13.198.0-112.13.198.255", "112.13.197.0-112.13.197.255",
|
||||
"112.13.196.0-112.13.196.255", "112.13.195.0-112.13.195.255", "112.13.194.0-112.13.194.255", "112.13.193" +
|
||||
".0-112.13.193.255", "211.138.112.0-211.138.112.255", "112.13.93.0-112.13.93.255", "112.13.110.0-112.13" +
|
||||
".110.255", "112.13.95.0-112.13.95.255", "112.13.91.0-112.13.91.255", "112.13.89.0-112.13.89.255", "112" +
|
||||
".13.88.0-112.13.88.255", "112.13.109.0-112.13.109.255", "112.13.100.0-112.13.100.255", "112.13.99.0-112" +
|
||||
".13.99.255", "112.13.98.0-112.13.98.255", "117.142.240.214-117.142.240.214", "117.142.240.213-117.142" +
|
||||
".240.213", "117.142.240.212-117.142.240.212", "112.13.171.0-112.13.171.255", "112.13.102.0-112.13.102" +
|
||||
".255", "112.13.101.0-112.13.101.255", "112.13.96.0-112.13.96.255", "112.13.94.0-112.13.94.255", "112.13" +
|
||||
".92.0-112.13.92.255", "112.13.90.0-112.13.90.255", "111.3.72.144-111.3.72.159", "111.3.72.160-111.3.72" +
|
||||
".191", "111.3.72.192-111.3.72.193", "218.205.117.2-218.205.117.2", "111.3.72.138-111.3.72.138", "218.205" +
|
||||
".117.98-218.205.117.98", "218.205.117.114-218.205.117.114", "218.205.117.115-218.205.117.115", "218.205" +
|
||||
".117.116-218.205.117.116", "111.3.72.194-111.3.72.195", "111.3.72.196-111.3.72.199", "111.3.72.200-111.3" +
|
||||
".72.207", "111.3.72.208-111.3.72.223", "111.3.72.224-111.3.72.255", "183.246.192.0-183.246.192.255",
|
||||
"183.246.193.0-183.246.193.1", "218.205.117.14-218.205.117.14", "218.205.117.22-218.205.117.22", "218.205" +
|
||||
".117.74-218.205.117.74", "111.3.72.142-111.3.72.142", "183.246.193.14-183.246.193.14", "218.205.117" +
|
||||
".82-218.205.117.82", "218.205.117.90-218.205.117.90", "218.205.117.94-218.205.117.94", "218.205.117" +
|
||||
".102-218.205.117.102", "218.205.117.122-218.205.117.122", "111.3.72.130-111.3.72.130", "111.3.72.131-111" +
|
||||
".3.72.131", "111.3.72.129-111.3.72.129", "218.205.117.126-218.205.117.126", "218.205.117.26-218.205.117" +
|
||||
".26", "218.205.117.58-218.205.117.58", "218.205.117.62-218.205.117.62", "218.205.117.66-218.205.117.66",
|
||||
"218.205.117.70-218.205.117.70", "218.205.117.54-218.205.117.54", "218.205.117.36-218.205.117.39", "218" +
|
||||
".205.117.32-218.205.117.35", "218.205.117.128-218.205.117.255", "218.205.117.4-218.205.117.7", "218.205" +
|
||||
".117.76-218.205.117.79", "218.205.124.128-218.205.124.159", "218.205.124.100-218.205.124.103", "218.205" +
|
||||
".124.64-218.205.124.79", "218.205.124.80-218.205.124.83", "218.205.124.244-218.205.124.247", "218.205" +
|
||||
".124.84-218.205.124.87", "218.205.124.28-218.205.124.31", "218.205.124.8-218.205.124.15", "218.205.124" +
|
||||
".48-218.205.124.63", "218.205.124.192-218.205.124.223", "218.205.124.160-218.205.124.191", "218.205.124" +
|
||||
".0-218.205.124.7", "218.205.124.16-218.205.124.19", "218.205.125.128-218.205.125.255", "218.205.125" +
|
||||
".96-218.205.125.127", "120.199.74.4-120.199.74.12", "120.199.74.2-120.199.74.2", "120.199.73.154-120.199" +
|
||||
".73.157", "112.15.173.46-112.15.173.46", "111.1.43.64-111.1.43.79", "111.1.43.30-111.1.43.30", "111.1.43" +
|
||||
".26-111.1.43.26", "111.1.43.2-111.1.43.2", "111.1.43.154-111.1.43.155", "111.1.43.146-111.1.43.150",
|
||||
"111.1.43.14-111.1.43.14", "111.1.40.82-111.1.40.84", "111.1.40.190-111.1.40.190", "111.1.40.66-111.1.40" +
|
||||
".75", "111.1.40.186-111.1.40.186", "111.1.40.182-111.1.40.182", "111.1.40.162-111.1.40.162", "111.1.40" +
|
||||
".128-111.1.40.159", "111.1.40.0-111.1.40.7", "111.1.3.74-111.1.3.75", "111.1.3.66-111.1.3.66", "111.1.3" +
|
||||
".208-111.1.3.223", "111.1.3.195-111.1.3.195", "111.1.3.176-111.1.3.191", "111.1.3.170-111.1.3.173", "111" +
|
||||
".1.3.128-111.1.3.159", "111.1.3.122-111.1.3.123", "111.1.3.0-111.1.3.31", "111.1.2.98-111.1.2.99", "111" +
|
||||
".1.2.64-111.1.2.79", "111.1.2.58-111.1.2.62", "111.1.2.202-111.1.2.206", "111.1.2.18-111.1.2.30", "111.1" +
|
||||
".2.155-111.1.2.155", "111.1.2.146-111.1.2.146", "111.1.2.100-111.1.2.126", "111.1.2.0-111.1.2.15", "111" +
|
||||
".1.1.90-111.1.1.90", "111.1.1.82-111.1.1.84", "111.1.1.50-111.1.1.53", "111.1.1.238-111.1.1.238", "111.1" +
|
||||
".1.234-111.1.1.234", "111.1.1.187-111.1.1.197", "111.1.1.106-111.1.1.107", "111.1.0.98-111.1.0.99", "111" +
|
||||
".1.0.166-111.1.0.166", "111.1.0.160-111.1.0.163", "111.1.0.101-111.1.0.155", "111.1.0.100-111.1.0.100",
|
||||
"112.12.89.128-112.12.89.191", "112.12.88.0-112.12.88.255", "112.12.6.128-112.12.6.255", "112.12.58" +
|
||||
".20-112.12.58.20", "112.12.58.18-112.12.58.18", "112.12.58.0-112.12.58.15", "112.12.31.144-112.12.31" +
|
||||
".159", "112.12.26.128-112.12.26.255", "112.12.18.64-112.12.18.95", "112.12.18.128-112.12.18.255", "112" +
|
||||
".12.18.0-112.12.18.63", "112.12.15.128-112.12.15.191", "112.12.125.0-112.12.125.255", "111.2.127.0-111.2" +
|
||||
".127.255", "111.2.122.0-111.2.122.63", "111.1.9.0-111.1.9.255", "111.1.8.68-111.1.8.79", "111.1.8.48-111" +
|
||||
".1.8.61", "111.1.8.4-111.1.8.15", "111.1.8.36-111.1.8.47", "111.1.8.242-111.1.8.251", "111.1.8.173-111.1" +
|
||||
".8.174", "111.1.8.17-111.1.8.28", "111.1.8.164-111.1.8.172", "111.1.8.142-111.1.8.145", "111.1.8.132-111" +
|
||||
".1.8.134", "111.1.8.123-111.1.8.126", "111.1.8.118-111.1.8.118", "111.1.8.115-111.1.8.116", "111.1.8" +
|
||||
".113-111.1.8.113", "111.1.8.111-111.1.8.111", "111.1.8.107-111.1.8.107", "111.1.8.103-111.1.8.103", "111" +
|
||||
".1.10.0-111.1.10.255", "117.149.36.104-117.149.36.107", "112.17.25.0-112.17.25.255", "112.17.24.128-112" +
|
||||
".17.24.255", "112.17.24.0-112.17.24.127", "223.95.61.0-223.95.61.255", "223.95.60.0-223.95.60.255", "223" +
|
||||
".95.58.0-223.95.59.255", "223.95.56.0-223.95.56.255", "223.95.33.0-223.95.33.127", "223.94.74.0-223.94" +
|
||||
".74.255", "223.94.66.128-223.94.66.255", "211.140.141.94-211.140.141.94", "211.140.141.67-211.140.141" +
|
||||
".77", "211.140.141.47-211.140.141.47", "211.140.141.214-211.140.141.214", "211.140.141.206-211.140.141" +
|
||||
".206", "211.140.141.204-211.140.141.204", "211.140.141.179-211.140.141.179", "211.140.141.153-211.140" +
|
||||
".141.153", "211.140.140.50-211.140.140.50", "211.140.140.48-211.140.140.48", "211.140.140.38-211.140.140" +
|
||||
".38", "211.140.138.8-211.140.138.9", "211.140.138.28-211.140.138.28", "211.140.138.2-211.140.138.5",
|
||||
"211.140.138.146-211.140.138.146", "211.140.138.10-211.140.138.12", "183.248.129.0-183.248.129.255", "183" +
|
||||
".248.128.0-183.248.128.255", "123.58.140.0-123.58.143.255", "117.149.39.96-117.149.39.127", "117.149.39" +
|
||||
".64-117.149.39.95", "117.149.39.160-117.149.39.191", "117.149.39.128-117.149.39.159", "117.149.39.0-117" +
|
||||
".149.39.63", "117.149.38.192-117.149.38.255", "117.149.38.0-117.149.38.63", "117.149.37.128-117.149.37" +
|
||||
".255", "117.149.37.0-117.149.37.127", "117.149.36.128-117.149.36.255", "111.1.26.128-111.1.26.255", "111" +
|
||||
".1.26.0-111.1.26.127", "111.1.25.98-111.1.25.99", "111.1.25.6-111.1.25.6", "111.1.25.34-111.1.25.34",
|
||||
"111.1.25.2-111.1.25.3", "111.1.25.192-111.1.25.255", "111.1.25.16-111.1.25.31", "111.1.25.12-111.1.25" +
|
||||
".15", "111.1.25.114-111.1.25.114", "111.1.25.106-111.1.25.110", "111.1.25.100-111.1.25.102", "111.1.25" +
|
||||
".10-111.1.25.10", "111.1.24.128-111.1.24.255", "111.1.27.0-111.1.27.255", "111.1.5.119-111.1.5.125",
|
||||
"111.1.5.130-111.1.5.130", "111.1.5.133-111.1.5.145", "111.1.5.147-111.1.5.149", "111.1.5.152-111.1.5" +
|
||||
".154", "111.1.5.162-111.1.5.165", "111.1.5.168-111.1.5.170", "111.1.5.172-111.1.5.179", "111.1.5.182-111" +
|
||||
".1.5.185", "111.1.5.189-111.1.5.189", "111.1.5.19-111.1.5.19", "111.1.5.2-111.1.5.2", "111.1.5.20-111.1" +
|
||||
".5.23", "111.1.5.25-111.1.5.25", "111.1.5.29-111.1.5.29", "111.1.5.3-111.1.5.3", "111.1.5.35-111.1.5.37"
|
||||
, "111.1.5.4-111.1.5.5", "111.1.5.50-111.1.5.59", "111.1.5.6-111.1.5.6", "111.1.5.67-111.1.5.69", "111.1" +
|
||||
".5.77-111.1.5.77", "111.1.5.79-111.1.5.79", "111.1.5.8-111.1.5.8", "111.1.5.80-111.1.5.86", "111.1.6" +
|
||||
".12-111.1.6.12", "111.1.6.128-111.1.6.143", "111.1.6.13-111.1.6.13", "111.1.6.147-111.1.6.147", "111.1.6" +
|
||||
".149-111.1.6.149", "111.1.6.153-111.1.6.153", "111.1.6.156-111.1.6.158", "111.1.6.16-111.1.6.16", "111.1" +
|
||||
".6.160-111.1.6.191", "111.1.6.18-111.1.6.19", "111.1.6.192-111.1.6.199", "111.1.6.2-111.1.6.2", "111.1.6" +
|
||||
".200-111.1.6.216", "111.1.6.224-111.1.6.255", "111.1.6.35-111.1.6.39", "111.1.6.4-111.1.6.4", "111.1.6" +
|
||||
".40-111.1.6.49", "111.1.6.5-111.1.6.8", "111.1.6.50-111.1.6.50", "111.1.6.84-111.1.6.85", "111.1.6" +
|
||||
".88-111.1.6.91", "111.1.7.128-111.1.7.255", "111.3.64.0-111.3.67.255", "117.148.189.0-117.148.189.255",
|
||||
"117.148.190.0-117.148.190.63", "117.148.190.128-117.148.190.255", "117.148.191.0-117.148.191.255", "183" +
|
||||
".245.10.0-183.245.10.255", "183.245.11.128-183.245.11.255", "183.245.12.0-183.245.12.31", "183.245.12" +
|
||||
".32-183.245.12.35", "183.245.5.0-183.245.5.255", "183.245.6.0-183.245.9.255", "39.175.96.0-39.175.97" +
|
||||
".255", "111.1.14.0-111.1.14.31", "111.1.14.32-111.1.14.47", "111.1.15.105-111.1.15.105", "111.1.15" +
|
||||
".11-111.1.15.11", "111.1.15.130-111.1.15.146", "111.1.15.157-111.1.15.164", "111.1.15.198-111.1.15.200",
|
||||
"111.1.15.203-111.1.15.203", "111.1.15.240-111.1.15.255", "112.16.2.128-112.16.2.255", "112.16.224.0-112" +
|
||||
".16.230.255", "112.16.231.128-112.16.231.255", "112.17.18.0-112.17.19.255", "117.149.194.208-117.149.194" +
|
||||
".223", "117.149.194.224-117.149.194.255", "117.149.194.80-117.149.194.95", "117.149.195.0-117.149.195" +
|
||||
".63", "117.149.196.0-117.149.196.127", "117.149.197.0-117.149.197.255", "117.149.198.0-117.149.198.127",
|
||||
"117.149.198.128-117.149.198.191", "117.149.198.192-117.149.198.207", "117.149.224.0-117.149.231.255",
|
||||
"117.149.232.0-117.149.232.255", "117.149.240.0-117.149.241.255", "117.149.244.0-117.149.248.255", "117" +
|
||||
".149.249.0-117.149.249.255", "117.149.250.128-117.149.250.255", "117.149.251.128-117.149.251.255", "117" +
|
||||
".149.251.16-117.149.251.31", "117.149.251.32-117.149.251.63", "117.149.251.8-117.149.251.15", "117.149" +
|
||||
".252.0-117.149.252.255", "117.149.254.0-117.149.254.255", "117.149.255.124-117.149.255.131", "117.149" +
|
||||
".255.160-117.149.255.243", "120.193.39.105-120.193.39.105", "120.193.39.11-120.193.39.11", "120.193.39" +
|
||||
".13-120.193.39.13", "120.193.39.16-120.193.39.19", "120.193.39.21-120.193.39.21", "120.193.39.24-120.193" +
|
||||
".39.24", "120.193.39.32-120.193.39.55", "120.193.39.5-120.193.39.8", "120.193.39.56-120.193.39.62", "120" +
|
||||
".193.39.74-120.193.39.79", "120.193.39.80-120.193.39.90", "120.193.39.92-120.193.39.92", "120.193.39" +
|
||||
".94-120.193.39.94", "120.193.39.96-120.193.39.96", "211.140.62.0-211.140.62.127", "211.140.62.238-211" +
|
||||
".140.62.239", "211.140.62.242-211.140.62.243", "211.140.62.247-211.140.62.249", "221.131.255.128-221.131" +
|
||||
".255.143", "221.131.255.16-221.131.255.31", "221.131.255.240-221.131.255.255", "221.131.255.32-221.131" +
|
||||
".255.47", "221.131.255.64-221.131.255.95", "221.131.255.8-221.131.255.15", "221.131.255.98-221.131.255" +
|
||||
".99", "43.240.156.0-43.240.159.255", "43.240.72.0-43.240.75.255", "43.241.16.0-43.241.19.255", "103.107" +
|
||||
".195.0-103.107.195.255", "111.1.29.0-111.1.29.251", "111.1.30.0-111.1.30.255", "111.1.31.11-111.1.31.13"
|
||||
, "111.1.31.119-111.1.31.120", "111.1.31.132-111.1.31.135", "111.1.31.141-111.1.31.141", "111.1.31" +
|
||||
".158-111.1.31.161", "111.1.31.164-111.1.31.165", "111.1.31.170-111.1.31.170", "111.1.31.172-111.1.31" +
|
||||
".176", "111.1.31.180-111.1.31.181", "111.1.31.184-111.1.31.186", "111.1.31.19-111.1.31.19", "111.1.31" +
|
||||
".196-111.1.31.200", "111.1.31.20-111.1.31.21", "111.1.31.202-111.1.31.202", "111.1.31.207-111.1.31.207",
|
||||
"111.1.31.209-111.1.31.213", "111.1.31.2-111.1.31.7", "111.1.31.221-111.1.31.224", "111.1.31.24-111.1.31" +
|
||||
".28", "111.1.31.246-111.1.31.246", "111.1.31.30-111.1.31.30", "111.1.31.51-111.1.31.52", "111.1.31" +
|
||||
".65-111.1.31.69", "111.1.31.74-111.1.31.74", "111.1.31.8-111.1.31.9", "111.1.31.90-111.1.31.92", "111.1" +
|
||||
".31.99-111.1.31.101", "111.3.68.112-111.3.68.180", "111.3.68.228-111.3.68.236", "111.3.68.238-111.3.68" +
|
||||
".238", "111.3.68.96-111.3.68.111", "111.3.69.0-111.3.69.255", "117.149.146.0-117.149.147.255", "183.131" +
|
||||
".16.138-183.131.16.139", "183.131.16.148-183.131.16.151", "183.134.107.20-183.134.107.20", "183.134.107" +
|
||||
".7-183.134.107.7", "183.246.188.0-183.246.188.255", "183.246.189.0-183.246.189.127", "218.205.87.94-218" +
|
||||
".205.87.94", "112.13.170.170-112.13.170.170", "111.2.176.8-111.2.176.8", "111.1.59.189-111.1.59.189",
|
||||
"112.13.104.0-112.13.104.255", "111.1.49.98-111.1.49.98", "111.3.72.50/32", "117.149.253.197/32", "111.1" +
|
||||
".49.100/32", "218.205.89.35/32", "117.148.173.130/32"};
|
||||
|
||||
String ip = "117.149.253.197";
|
||||
|
||||
for (String n : src) {
|
||||
log.info("{} network {}contains {}", n,
|
||||
Helper.ipInRange(n, ip) ? "is " : "not ",
|
||||
ip);
|
||||
}
|
||||
}
|
||||
|
||||
public void ipRang2() {
|
||||
String ip = "117.149.253.197";
|
||||
String n = "0.0.0.0";
|
||||
|
||||
log.info("{} network {}contains {}", n,
|
||||
Helper.ipInRange(n, ip) ? "is " : "not ",
|
||||
ip);
|
||||
}
|
||||
|
||||
public void haohanStartError() {
|
||||
String errMsg = "[{ip=192.168.50.2, 任务名称=三方接口任务467}, {ip=192.168.50.2, 任务名称=三方接口任务468}, {ip=192.168" +
|
||||
".50.2, 任务名称=三方接口任务470}, {ip=192.168.50.2, 任务名称=三方接口任务469}]";
|
||||
|
@ -206,7 +469,6 @@ public class demo {
|
|||
}
|
||||
}
|
||||
|
||||
@Test
|
||||
public void ipaddrVariety() {
|
||||
String[] ipAddrs = new String[]{
|
||||
"ffff::8fff:ffff:0:ffff",
|
||||
|
@ -225,7 +487,6 @@ public class demo {
|
|||
}
|
||||
}
|
||||
|
||||
@Test
|
||||
public void groupArray() {
|
||||
Integer[] org = new Integer[]{1, 2, 3, 4, 5};
|
||||
Integer[] diff = new Integer[]{1, 3, 5, 6, 7, 8, 9};
|
||||
|
@ -240,7 +501,6 @@ public class demo {
|
|||
log.info("Result: {}", groupMap);
|
||||
}
|
||||
|
||||
@Test
|
||||
public void ipSegment() {
|
||||
String str = "192.168.1.1/23, 192.168.1.2-192.168.1.80, ::1-::255, 192.168.1, 01.012.012.01, " +
|
||||
"123.123.123-";
|
||||
|
@ -278,4 +538,28 @@ public class demo {
|
|||
}
|
||||
}
|
||||
|
||||
public void aes() throws IllegalBlockSizeException, InvalidKeyException, BadPaddingException,
|
||||
NoSuchAlgorithmException, NoSuchPaddingException {
|
||||
String plainText = "{\"disposeTime\":60,\"flowDirection\":0,\"mulDisposeIp\":[\"1.1.1.1\"],\"type\":0}";
|
||||
String aesKey = "hkoUV5ZWh0q1jSxMnpjovVn19Qg99HY6DD40";
|
||||
|
||||
byte[] encode = CryptoHelper.aes128Encryption(plainText.getBytes(StandardCharsets.UTF_8),
|
||||
aesKey);
|
||||
log.info("AES Key: {}", aesKey);
|
||||
log.info("Src: {}", plainText);
|
||||
log.info("AES256: {}", CryptoHelper.base64Encryption(encode));
|
||||
}
|
||||
|
||||
public void aesdec() throws IllegalBlockSizeException, InvalidKeyException, BadPaddingException,
|
||||
NoSuchAlgorithmException, NoSuchPaddingException {
|
||||
String plainText = "6PgUrZa8zZUzDAxAFpV307JfUDVI1gFNo3ZFT7LKtVzRXc3UbwFh6+5i6" +
|
||||
"+667frPR5j1p0XOG1i7Nhy85uHUDWUBZUxHF3vXNkgiKtbWLHw=";
|
||||
|
||||
String aesKey = "hkoUV5ZWh0q1jSxMnpjovVn19Qg99HY6DD40";
|
||||
|
||||
byte[] encode = CryptoHelper.aes128Decryption(CryptoHelper.base64Decryption(plainText), aesKey);
|
||||
log.info("AES Key: {}", aesKey);
|
||||
log.info("Src: {}", plainText);
|
||||
log.info("AES256: {}", new String(encode));
|
||||
}
|
||||
}
|
||||
|
|
|
@ -1,202 +1,182 @@
|
|||
package com.dispose.test.dev.dptech;
|
||||
|
||||
import com.dispose.ability.DisposeAbility;
|
||||
import com.dispose.ability.impl.DpTechAbilityImpl;
|
||||
import com.dispose.common.DDoSAttackType;
|
||||
import com.dispose.common.DisposeCapacityType;
|
||||
import com.dispose.common.DisposeDeviceType;
|
||||
import com.dispose.common.ErrorCode;
|
||||
import com.dispose.common.HttpType;
|
||||
import com.dispose.common.NetflowDirection;
|
||||
import com.dispose.common.ObjectStatus;
|
||||
import com.dispose.pojo.entity.DisposeDevice;
|
||||
import com.dispose.pojo.po.MulReturnType;
|
||||
import com.dispose.pojo.vo.DeviceFirewareInfo;
|
||||
import com.dispose.test.dev.Global.InitTestEnvironment;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.junit.Assert;
|
||||
import org.junit.FixMethodOrder;
|
||||
import org.junit.Test;
|
||||
import org.junit.runner.RunWith;
|
||||
import org.junit.runners.MethodSorters;
|
||||
import org.springframework.boot.test.context.SpringBootTest;
|
||||
import org.springframework.test.context.junit4.SpringRunner;
|
||||
|
||||
/**
|
||||
* The type Dp tech interface test case.
|
||||
*/
|
||||
@RunWith(SpringRunner.class)
|
||||
@Slf4j
|
||||
@SpringBootTest
|
||||
@FixMethodOrder(MethodSorters.NAME_ASCENDING)
|
||||
///**
|
||||
// * The type Dp tech interface test case.
|
||||
// */
|
||||
//@RunWith(SpringRunner.class)
|
||||
//@Slf4j
|
||||
//@SpringBootTest
|
||||
//@FixMethodOrder(MethodSorters.NAME_ASCENDING)
|
||||
public class DPTechInterfaceTestCase extends InitTestEnvironment {
|
||||
public static Integer DPTECH_UMC = 0;
|
||||
|
||||
/**
|
||||
* User login.
|
||||
*/
|
||||
@Override
|
||||
public void userLogin() {
|
||||
}
|
||||
|
||||
/**
|
||||
* Gets ability map key.
|
||||
*
|
||||
* @param ipAddr the ip addr
|
||||
* @param ipPort the ip port
|
||||
* @return the ability map key
|
||||
*/
|
||||
private String getAbilityMapKey(String ipAddr, String ipPort) {
|
||||
return (ipPort == null || ipPort.length() == 0) ? ipAddr : (ipAddr + ":" + ipPort);
|
||||
}
|
||||
|
||||
/**
|
||||
* T 1 get all detection object from umc.
|
||||
*/
|
||||
@Test
|
||||
public void t1_runDisposeTest() {
|
||||
DisposeAbility db;
|
||||
|
||||
DisposeDevice dev = DisposeDevice.builder()
|
||||
.ipAddr("10.88.77.15")
|
||||
.ipPort("")
|
||||
.deviceType(DisposeDeviceType.DPTECH_UMC)
|
||||
.areaCode(0)
|
||||
.deviceName("中移杭研实验室迪普清洗设备")
|
||||
.manufacturer("DPTech")
|
||||
.model("UMC")
|
||||
.version("5.7.13")
|
||||
.userName("admin")
|
||||
.password("UMCAdministrator")
|
||||
.urlPath("UMC/service/AbnormalFlowCleaningService")
|
||||
.urlType(HttpType.HTTP)
|
||||
.readme("实验室测试设备")
|
||||
.status(ObjectStatus.NORMAL)
|
||||
.build();
|
||||
|
||||
String httpType = dev.getUrlType() == HttpType.HTTP ? "http://" : "https://";
|
||||
String addr = getAbilityMapKey(dev.getIpAddr(), dev.getIpPort());
|
||||
String url = httpType + addr + "/" + dev.getUrlPath();
|
||||
|
||||
if (dev.getDeviceType().getValue().equals(DPTECH_UMC)) {
|
||||
db = new DpTechAbilityImpl();
|
||||
|
||||
// 初始化设备
|
||||
db.initDeviceEnv(url, dev.getUserName(), dev.getPassword());
|
||||
|
||||
MulReturnType<ErrorCode, Long> ret = db.runDispose("192.168.3.2", DisposeCapacityType.CLEANUP,
|
||||
NetflowDirection.DIRECTION_BI, DDoSAttackType.CLDAP_AMPLIFICATION.getValue(), -1L);
|
||||
|
||||
Assert.assertEquals(ret.getFirstParam(), ErrorCode.ERR_OK);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* T 2 stop dispose task.
|
||||
*/
|
||||
@Test
|
||||
public void t2_stopDisposeTest() {
|
||||
DisposeAbility db;
|
||||
|
||||
DisposeDevice dev = DisposeDevice.builder()
|
||||
.ipAddr("10.88.77.15")
|
||||
.ipPort("")
|
||||
.deviceType(DisposeDeviceType.DPTECH_UMC)
|
||||
.areaCode(0)
|
||||
.deviceName("中移杭研实验室迪普清洗设备")
|
||||
.manufacturer("DPTech")
|
||||
.model("UMC")
|
||||
.version("5.7.13")
|
||||
.userName("admin")
|
||||
.password("UMCAdministrator")
|
||||
.urlPath("UMC/service/AbnormalFlowCleaningService")
|
||||
.urlType(HttpType.HTTP)
|
||||
.readme("实验室测试设备")
|
||||
.status(ObjectStatus.NORMAL)
|
||||
.build();
|
||||
|
||||
String httpType = dev.getUrlType() == HttpType.HTTP ? "http://" : "https://";
|
||||
String addr = getAbilityMapKey(dev.getIpAddr(), dev.getIpPort());
|
||||
String url = httpType + addr + "/" + dev.getUrlPath();
|
||||
|
||||
if (dev.getDeviceType().getValue().equals(DPTECH_UMC)) {
|
||||
db = new DpTechAbilityImpl();
|
||||
|
||||
// 初始化设备
|
||||
db.initDeviceEnv(url, dev.getUserName(), dev.getPassword());
|
||||
|
||||
Assert.assertTrue(db.getDeviceLinkStatus());
|
||||
|
||||
MulReturnType<ErrorCode, Long> ret = db.stopDispose("192.168.3.2", DisposeCapacityType.CLEANUP,
|
||||
NetflowDirection.DIRECTION_BI, DDoSAttackType.CLDAP_AMPLIFICATION.getValue(), -1L);
|
||||
|
||||
Assert.assertEquals(ret.getFirstParam(), ErrorCode.ERR_OK);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* T 3 Gets ability device fireware..
|
||||
*/
|
||||
@Test
|
||||
public void t3_getAbilityDeviceFirewareTest() {
|
||||
DisposeAbility db;
|
||||
|
||||
DisposeDevice dev = DisposeDevice.builder()
|
||||
.ipAddr("10.88.77.15")
|
||||
.ipPort("")
|
||||
.deviceType(DisposeDeviceType.DPTECH_UMC)
|
||||
.areaCode(0)
|
||||
.deviceName("中移杭研实验室迪普清洗设备")
|
||||
.manufacturer("DPTech")
|
||||
.model("UMC")
|
||||
.version("5.7.13")
|
||||
.userName("admin")
|
||||
.password("UMCAdministrator")
|
||||
.urlPath("UMC/service/AbnormalFlowCleaningService")
|
||||
.urlType(HttpType.HTTP)
|
||||
.readme("实验室测试设备")
|
||||
.status(ObjectStatus.NORMAL)
|
||||
.build();
|
||||
|
||||
String httpType = dev.getUrlType() == HttpType.HTTP ? "http://" : "https://";
|
||||
String addr = getAbilityMapKey(dev.getIpAddr(), dev.getIpPort());
|
||||
String url = httpType + addr + "/" + dev.getUrlPath();
|
||||
|
||||
if (dev.getDeviceType().getValue().equals(DPTECH_UMC)) {
|
||||
db = new DpTechAbilityImpl();
|
||||
|
||||
// 初始化设备
|
||||
db.initDeviceEnv(url, dev.getUserName(), dev.getPassword());
|
||||
|
||||
Assert.assertTrue(db.getDeviceLinkStatus());
|
||||
MulReturnType<ErrorCode, DeviceFirewareInfo> ret = db.getAbilityDeviceFireware();
|
||||
|
||||
Assert.assertEquals(ret.getFirstParam(), ErrorCode.ERR_OK);
|
||||
Assert.assertEquals(ret.getSecondParam().getVendor(), "DpTech");
|
||||
Assert.assertEquals(ret.getSecondParam().getModel(), "UMC");
|
||||
Assert.assertEquals(ret.getSecondParam().getOs(), "Windows Server");
|
||||
Assert.assertEquals(ret.getSecondParam().getKernel(), "Windows");
|
||||
Assert.assertEquals(ret.getSecondParam().getArch(), "x86_64");
|
||||
Assert.assertEquals(ret.getSecondParam().getVersion(), "5.7.31");
|
||||
|
||||
//to device attack type long.
|
||||
Long ddosAttackTypeMask = 10737508814L;
|
||||
|
||||
Long result = db.toDeviceAttackType(ddosAttackTypeMask);
|
||||
|
||||
log.info("ddosAttackTypeMask-->{}, result-->{}", ddosAttackTypeMask, result);
|
||||
Assert.assertNotNull(result);
|
||||
Assert.assertNotEquals(String.valueOf(result), "0");
|
||||
|
||||
//gets dispose device protect object.
|
||||
db.getDisposeDeviceProtectObject();
|
||||
|
||||
//is carry protect ip boolean.
|
||||
boolean carryResult = db.isCarryProtectIp("192.168.3.2");
|
||||
Assert.assertTrue(carryResult);
|
||||
|
||||
carryResult = db.isCarryProtectIp("192.168.10.2");
|
||||
Assert.assertFalse(carryResult);
|
||||
}
|
||||
}
|
||||
// public static Integer DPTECH_UMC = 0;
|
||||
//
|
||||
// /**
|
||||
// * User login.
|
||||
// */
|
||||
// @Override
|
||||
// public void userLogin() {
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * Gets ability map key.
|
||||
// *
|
||||
// * @param ipAddr the ip addr
|
||||
// * @param ipPort the ip port
|
||||
// * @return the ability map key
|
||||
// */
|
||||
// private String getAbilityMapKey(String ipAddr, String ipPort) {
|
||||
// return (ipPort == null || ipPort.length() == 0) ? ipAddr : (ipAddr + ":" + ipPort);
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * T 1 get all detection object from umc.
|
||||
// */
|
||||
// @Test
|
||||
// public void t1_runDisposeTest() {
|
||||
// DisposeAbility db;
|
||||
//
|
||||
// DisposeDevice dev = DisposeDevice.builder()
|
||||
// .ipAddr("10.88.77.15")
|
||||
// .ipPort("")
|
||||
// .deviceType(DisposeDeviceType.DPTECH_UMC)
|
||||
// .areaCode(0)
|
||||
// .deviceName("中移杭研实验室迪普清洗设备")
|
||||
// .manufacturer("DPTech")
|
||||
// .model("UMC")
|
||||
// .version("5.7.13")
|
||||
// .userName("admin")
|
||||
// .password("UMCAdministrator")
|
||||
// .urlPath("UMC/service/AbnormalFlowCleaningService")
|
||||
// .urlType(HttpType.HTTP)
|
||||
// .readme("实验室测试设备")
|
||||
// .status(ObjectStatus.NORMAL)
|
||||
// .build();
|
||||
//
|
||||
// String httpType = dev.getUrlType() == HttpType.HTTP ? "http://" : "https://";
|
||||
// String addr = getAbilityMapKey(dev.getIpAddr(), dev.getIpPort());
|
||||
// String url = httpType + addr + "/" + dev.getUrlPath();
|
||||
//
|
||||
// if (dev.getDeviceType().getValue().equals(DPTECH_UMC)) {
|
||||
// db = new DpTechAbilityImpl();
|
||||
//
|
||||
// // 初始化设备
|
||||
// db.initDeviceEnv(url, dev.getUserName(), dev.getPassword());
|
||||
//
|
||||
// MulReturnType<ErrorCode, Long> ret = db.runDispose("192.168.3.2", DisposeCapacityType.CLEANUP,
|
||||
// NetflowDirection.DIRECTION_BI, DDoSAttackType.CLDAP_AMPLIFICATION.getValue(), -1L);
|
||||
//
|
||||
// Assert.assertEquals(ret.getFirstParam(), ErrorCode.ERR_OK);
|
||||
// }
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * T 2 stop dispose task.
|
||||
// */
|
||||
// @Test
|
||||
// public void t2_stopDisposeTest() {
|
||||
// DisposeAbility db;
|
||||
//
|
||||
// DisposeDevice dev = DisposeDevice.builder()
|
||||
// .ipAddr("10.88.77.15")
|
||||
// .ipPort("")
|
||||
// .deviceType(DisposeDeviceType.DPTECH_UMC)
|
||||
// .areaCode(0)
|
||||
// .deviceName("中移杭研实验室迪普清洗设备")
|
||||
// .manufacturer("DPTech")
|
||||
// .model("UMC")
|
||||
// .version("5.7.13")
|
||||
// .userName("admin")
|
||||
// .password("UMCAdministrator")
|
||||
// .urlPath("UMC/service/AbnormalFlowCleaningService")
|
||||
// .urlType(HttpType.HTTP)
|
||||
// .readme("实验室测试设备")
|
||||
// .status(ObjectStatus.NORMAL)
|
||||
// .build();
|
||||
//
|
||||
// String httpType = dev.getUrlType() == HttpType.HTTP ? "http://" : "https://";
|
||||
// String addr = getAbilityMapKey(dev.getIpAddr(), dev.getIpPort());
|
||||
// String url = httpType + addr + "/" + dev.getUrlPath();
|
||||
//
|
||||
// if (dev.getDeviceType().getValue().equals(DPTECH_UMC)) {
|
||||
// db = new DpTechAbilityImpl();
|
||||
//
|
||||
// // 初始化设备
|
||||
// db.initDeviceEnv(url, dev.getUserName(), dev.getPassword());
|
||||
//
|
||||
// Assert.assertTrue(db.getDeviceLinkStatus());
|
||||
//
|
||||
// MulReturnType<ErrorCode, Long> ret = db.stopDispose("192.168.3.2", DisposeCapacityType.CLEANUP,
|
||||
// NetflowDirection.DIRECTION_BI, DDoSAttackType.CLDAP_AMPLIFICATION.getValue(), -1L);
|
||||
//
|
||||
// Assert.assertEquals(ret.getFirstParam(), ErrorCode.ERR_OK);
|
||||
// }
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * T 3 Gets ability device fireware..
|
||||
// */
|
||||
// @Test
|
||||
// public void t3_getAbilityDeviceFirewareTest() {
|
||||
// DisposeAbility db;
|
||||
//
|
||||
// DisposeDevice dev = DisposeDevice.builder()
|
||||
// .ipAddr("10.88.77.15")
|
||||
// .ipPort("")
|
||||
// .deviceType(DisposeDeviceType.DPTECH_UMC)
|
||||
// .areaCode(0)
|
||||
// .deviceName("中移杭研实验室迪普清洗设备")
|
||||
// .manufacturer("DPTech")
|
||||
// .model("UMC")
|
||||
// .version("5.7.13")
|
||||
// .userName("admin")
|
||||
// .password("UMCAdministrator")
|
||||
// .urlPath("UMC/service/AbnormalFlowCleaningService")
|
||||
// .urlType(HttpType.HTTP)
|
||||
// .readme("实验室测试设备")
|
||||
// .status(ObjectStatus.NORMAL)
|
||||
// .build();
|
||||
//
|
||||
// String httpType = dev.getUrlType() == HttpType.HTTP ? "http://" : "https://";
|
||||
// String addr = getAbilityMapKey(dev.getIpAddr(), dev.getIpPort());
|
||||
// String url = httpType + addr + "/" + dev.getUrlPath();
|
||||
//
|
||||
// if (dev.getDeviceType().getValue().equals(DPTECH_UMC)) {
|
||||
// db = new DpTechAbilityImpl();
|
||||
//
|
||||
// // 初始化设备
|
||||
// db.initDeviceEnv(url, dev.getUserName(), dev.getPassword());
|
||||
//
|
||||
// Assert.assertTrue(db.getDeviceLinkStatus());
|
||||
// MulReturnType<ErrorCode, DeviceFirewareInfo> ret = db.getAbilityDeviceFireware();
|
||||
//
|
||||
// Assert.assertEquals(ret.getFirstParam(), ErrorCode.ERR_OK);
|
||||
// Assert.assertEquals(ret.getSecondParam().getVendor(), "DpTech");
|
||||
// Assert.assertEquals(ret.getSecondParam().getModel(), "UMC");
|
||||
// Assert.assertEquals(ret.getSecondParam().getOs(), "Windows Server");
|
||||
// Assert.assertEquals(ret.getSecondParam().getKernel(), "Windows");
|
||||
// Assert.assertEquals(ret.getSecondParam().getArch(), "x86_64");
|
||||
// Assert.assertEquals(ret.getSecondParam().getVersion(), "5.7.31");
|
||||
//
|
||||
// //to device attack type long.
|
||||
// Long ddosAttackTypeMask = 10737508814L;
|
||||
//
|
||||
// Long result = db.toDeviceAttackType(ddosAttackTypeMask);
|
||||
//
|
||||
// log.info("ddosAttackTypeMask-->{}, result-->{}", ddosAttackTypeMask, result);
|
||||
// Assert.assertNotNull(result);
|
||||
// Assert.assertNotEquals(String.valueOf(result), "0");
|
||||
//
|
||||
// //gets dispose device protect object.
|
||||
// db.getDisposeDeviceProtectObject();
|
||||
//
|
||||
// //is carry protect ip boolean.
|
||||
// boolean carryResult = db.isCarryProtectIp("192.168.3.2");
|
||||
// Assert.assertTrue(carryResult);
|
||||
//
|
||||
// carryResult = db.isCarryProtectIp("192.168.10.2");
|
||||
// Assert.assertFalse(carryResult);
|
||||
// }
|
||||
// }
|
||||
}
|
||||
|
|
|
@ -1,201 +1,183 @@
|
|||
package com.dispose.test.dev.haohan;
|
||||
|
||||
import com.dispose.ability.DisposeAbility;
|
||||
import com.dispose.ability.impl.HaoHanAbilityImpl;
|
||||
import com.dispose.common.DisposeCapacityType;
|
||||
import com.dispose.common.DisposeDeviceType;
|
||||
import com.dispose.common.ErrorCode;
|
||||
import com.dispose.common.HttpType;
|
||||
import com.dispose.common.ObjectStatus;
|
||||
import com.dispose.pojo.entity.DisposeDevice;
|
||||
import com.dispose.pojo.po.MulReturnType;
|
||||
import com.dispose.pojo.vo.DeviceFirewareInfo;
|
||||
import com.dispose.test.dev.Global.InitTestEnvironment;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.junit.Assert;
|
||||
import org.junit.FixMethodOrder;
|
||||
import org.junit.Test;
|
||||
import org.junit.runner.RunWith;
|
||||
import org.junit.runners.MethodSorters;
|
||||
import org.springframework.boot.test.context.SpringBootTest;
|
||||
import org.springframework.test.context.junit4.SpringRunner;
|
||||
|
||||
/**
|
||||
* The type Dp tech interface test case.
|
||||
*/
|
||||
@RunWith(SpringRunner.class)
|
||||
@Slf4j
|
||||
@SpringBootTest
|
||||
@FixMethodOrder(MethodSorters.NAME_ASCENDING)
|
||||
///**
|
||||
// * The type Dp tech interface test case.
|
||||
// */
|
||||
//@RunWith(SpringRunner.class)
|
||||
//@Slf4j
|
||||
//@SpringBootTest
|
||||
//@FixMethodOrder(MethodSorters.NAME_ASCENDING)
|
||||
public class HAOHanInterfaceTestCast extends InitTestEnvironment {
|
||||
public static Integer HAOHAN_PLATFORM = 0;
|
||||
|
||||
/**
|
||||
* User login.
|
||||
*/
|
||||
@Override
|
||||
public void userLogin() {
|
||||
}
|
||||
|
||||
/**
|
||||
* Gets ability map key.
|
||||
*
|
||||
* @param ipAddr the ip addr
|
||||
* @param ipPort the ip port
|
||||
* @return the ability map key
|
||||
*/
|
||||
private String getAbilityMapKey(String ipAddr, String ipPort) {
|
||||
return (ipPort == null || ipPort.length() == 0) ? ipAddr : (ipAddr + ":" + ipPort);
|
||||
}
|
||||
|
||||
/**
|
||||
* T 1 get all detection object from umc.
|
||||
*/
|
||||
@Test
|
||||
public void t1_runDisposeTest() {
|
||||
DisposeAbility db;
|
||||
|
||||
DisposeDevice dev = DisposeDevice.builder()
|
||||
.ipAddr("10.88.77.88")
|
||||
.ipPort("18080")
|
||||
.deviceType(DisposeDeviceType.HAOHAN_PLATFORM)
|
||||
.areaCode(0)
|
||||
.deviceName("中移杭研实验室浩瀚清洗设备")
|
||||
.manufacturer("Haohan")
|
||||
.model("Unknown")
|
||||
.version("Unknown")
|
||||
.userName("")
|
||||
.password("")
|
||||
.urlPath("DDoSClean/clean")
|
||||
.urlType(HttpType.HTTP)
|
||||
.readme("实验室测试设备")
|
||||
.status(ObjectStatus.NORMAL)
|
||||
.build();
|
||||
|
||||
String httpType = dev.getUrlType() == HttpType.HTTP ? "http://" : "https://";
|
||||
String addr = getAbilityMapKey(dev.getIpAddr(), dev.getIpPort());
|
||||
String url = httpType + addr + "/" + dev.getUrlPath();
|
||||
|
||||
if (dev.getDeviceType().getValue().equals(HAOHAN_PLATFORM)) {
|
||||
db = new HaoHanAbilityImpl();
|
||||
|
||||
// 初始化设备
|
||||
db.initDeviceEnv(url, dev.getUserName(), dev.getPassword());
|
||||
|
||||
MulReturnType<ErrorCode, Long> ret = db.runDispose("192.168.3.5",
|
||||
DisposeCapacityType.CLEANUP,
|
||||
null, null, -1L);
|
||||
|
||||
Assert.assertEquals(ret.getFirstParam(), ErrorCode.ERR_OK);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* T 2 stop dispose task.
|
||||
*/
|
||||
@Test
|
||||
public void t2_stopDisposeTest() {
|
||||
DisposeAbility db;
|
||||
|
||||
DisposeDevice dev = DisposeDevice.builder()
|
||||
.ipAddr("10.88.77.88")
|
||||
.ipPort("18080")
|
||||
.deviceType(DisposeDeviceType.HAOHAN_PLATFORM)
|
||||
.areaCode(0)
|
||||
.deviceName("中移杭研实验室浩瀚清洗设备")
|
||||
.manufacturer("Haohan")
|
||||
.model("Unknown")
|
||||
.version("Unknown")
|
||||
.userName("")
|
||||
.password("")
|
||||
.urlPath("DDoSClean/clean")
|
||||
.urlType(HttpType.HTTP)
|
||||
.readme("实验室测试设备")
|
||||
.status(ObjectStatus.NORMAL)
|
||||
.build();
|
||||
|
||||
String httpType = dev.getUrlType() == HttpType.HTTP ? "http://" : "https://";
|
||||
String addr = getAbilityMapKey(dev.getIpAddr(), dev.getIpPort());
|
||||
String url = httpType + addr + "/" + dev.getUrlPath();
|
||||
|
||||
if (dev.getDeviceType().getValue().equals(HAOHAN_PLATFORM)) {
|
||||
db = new HaoHanAbilityImpl();
|
||||
|
||||
// 初始化设备
|
||||
db.initDeviceEnv(url, dev.getUserName(), dev.getPassword());
|
||||
|
||||
Assert.assertTrue(db.getDeviceLinkStatus());
|
||||
MulReturnType<ErrorCode, Long> ret = db.stopDispose("192.168.3.5",
|
||||
DisposeCapacityType.CLEANUP,
|
||||
null, null, -1L);
|
||||
|
||||
Assert.assertEquals(ret.getFirstParam(), ErrorCode.ERR_OK);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* T 3 Gets ability device fireware..
|
||||
*/
|
||||
@Test
|
||||
public void t3_getAbilityDeviceFirewareTest() {
|
||||
DisposeAbility db;
|
||||
|
||||
DisposeDevice dev = DisposeDevice.builder()
|
||||
.ipAddr("10.88.77.88")
|
||||
.ipPort("18080")
|
||||
.deviceType(DisposeDeviceType.HAOHAN_PLATFORM)
|
||||
.areaCode(0)
|
||||
.deviceName("中移杭研实验室浩瀚清洗设备")
|
||||
.manufacturer("Haohan")
|
||||
.model("Unknown")
|
||||
.version("Unknown")
|
||||
.userName("")
|
||||
.password("")
|
||||
.urlPath("DDoSClean/clean")
|
||||
.urlType(HttpType.HTTP)
|
||||
.readme("实验室测试设备")
|
||||
.status(ObjectStatus.NORMAL)
|
||||
.build();
|
||||
|
||||
String httpType = dev.getUrlType() == HttpType.HTTP ? "http://" : "https://";
|
||||
String addr = getAbilityMapKey(dev.getIpAddr(), dev.getIpPort());
|
||||
String url = httpType + addr + "/" + dev.getUrlPath();
|
||||
|
||||
if (dev.getDeviceType().getValue().equals(HAOHAN_PLATFORM)) {
|
||||
db = new HaoHanAbilityImpl();
|
||||
|
||||
// 初始化设备
|
||||
db.initDeviceEnv(url, dev.getUserName(), dev.getPassword());
|
||||
|
||||
Assert.assertTrue(db.getDeviceLinkStatus());
|
||||
MulReturnType<ErrorCode, DeviceFirewareInfo> ret = db.getAbilityDeviceFireware();
|
||||
|
||||
Assert.assertEquals(ret.getFirstParam(), ErrorCode.ERR_OK);
|
||||
Assert.assertEquals(ret.getSecondParam().getVendor(), "HaoHan");
|
||||
Assert.assertEquals(ret.getSecondParam().getOs(), "Linux Server");
|
||||
Assert.assertEquals(ret.getSecondParam().getKernel(), "Linux");
|
||||
Assert.assertEquals(ret.getSecondParam().getArch(), "x86_64");
|
||||
Assert.assertEquals(ret.getSecondParam().getVersion(), "Unknown");
|
||||
|
||||
//to device attack type long.
|
||||
Long ddosAttackTypeMask = 10737508814L;
|
||||
|
||||
Long result = db.toDeviceAttackType(ddosAttackTypeMask);
|
||||
|
||||
log.info("ddosAttackTypeMask-->{}, result-->{}", ddosAttackTypeMask, result);
|
||||
Assert.assertNotNull(result);
|
||||
Assert.assertEquals(String.valueOf(ddosAttackTypeMask), String.valueOf(result));
|
||||
|
||||
|
||||
//gets dispose device protect object.
|
||||
db.getDisposeDeviceProtectObject();
|
||||
|
||||
//is carry protect ip boolean. 所有IP都可执行清洗命令
|
||||
boolean carryResult = db.isCarryProtectIp("192.168.5.2");
|
||||
Assert.assertTrue(carryResult);
|
||||
|
||||
carryResult = db.isCarryProtectIp("");
|
||||
Assert.assertTrue(carryResult);
|
||||
}
|
||||
}
|
||||
// public static Integer HAOHAN_PLATFORM = 0;
|
||||
//
|
||||
// /**
|
||||
// * User login.
|
||||
// */
|
||||
// @Override
|
||||
// public void userLogin() {
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * Gets ability map key.
|
||||
// *
|
||||
// * @param ipAddr the ip addr
|
||||
// * @param ipPort the ip port
|
||||
// * @return the ability map key
|
||||
// */
|
||||
// private String getAbilityMapKey(String ipAddr, String ipPort) {
|
||||
// return (ipPort == null || ipPort.length() == 0) ? ipAddr : (ipAddr + ":" + ipPort);
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * T 1 get all detection object from umc.
|
||||
// */
|
||||
// @Test
|
||||
// public void t1_runDisposeTest() {
|
||||
// DisposeAbility db;
|
||||
//
|
||||
// DisposeDevice dev = DisposeDevice.builder()
|
||||
// .ipAddr("10.88.77.88")
|
||||
// .ipPort("18080")
|
||||
// .deviceType(DisposeDeviceType.HAOHAN_PLATFORM)
|
||||
// .areaCode(0)
|
||||
// .deviceName("中移杭研实验室浩瀚清洗设备")
|
||||
// .manufacturer("Haohan")
|
||||
// .model("Unknown")
|
||||
// .version("Unknown")
|
||||
// .userName("")
|
||||
// .password("")
|
||||
// .urlPath("DDoSClean/clean")
|
||||
// .urlType(HttpType.HTTP)
|
||||
// .readme("实验室测试设备")
|
||||
// .status(ObjectStatus.NORMAL)
|
||||
// .build();
|
||||
//
|
||||
// String httpType = dev.getUrlType() == HttpType.HTTP ? "http://" : "https://";
|
||||
// String addr = getAbilityMapKey(dev.getIpAddr(), dev.getIpPort());
|
||||
// String url = httpType + addr + "/" + dev.getUrlPath();
|
||||
//
|
||||
// if (dev.getDeviceType().getValue().equals(HAOHAN_PLATFORM)) {
|
||||
// db = new HaoHanAbilityImpl();
|
||||
//
|
||||
// // 初始化设备
|
||||
// db.initDeviceEnv(url, dev.getUserName(), dev.getPassword());
|
||||
//
|
||||
// MulReturnType<ErrorCode, Long> ret = db.runDispose("192.168.3.5",
|
||||
// DisposeCapacityType.CLEANUP,
|
||||
// null, null, -1L);
|
||||
//
|
||||
// Assert.assertEquals(ret.getFirstParam(), ErrorCode.ERR_OK);
|
||||
// }
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * T 2 stop dispose task.
|
||||
// */
|
||||
// @Test
|
||||
// public void t2_stopDisposeTest() {
|
||||
// DisposeAbility db;
|
||||
//
|
||||
// DisposeDevice dev = DisposeDevice.builder()
|
||||
// .ipAddr("10.88.77.88")
|
||||
// .ipPort("18080")
|
||||
// .deviceType(DisposeDeviceType.HAOHAN_PLATFORM)
|
||||
// .areaCode(0)
|
||||
// .deviceName("中移杭研实验室浩瀚清洗设备")
|
||||
// .manufacturer("Haohan")
|
||||
// .model("Unknown")
|
||||
// .version("Unknown")
|
||||
// .userName("")
|
||||
// .password("")
|
||||
// .urlPath("DDoSClean/clean")
|
||||
// .urlType(HttpType.HTTP)
|
||||
// .readme("实验室测试设备")
|
||||
// .status(ObjectStatus.NORMAL)
|
||||
// .build();
|
||||
//
|
||||
// String httpType = dev.getUrlType() == HttpType.HTTP ? "http://" : "https://";
|
||||
// String addr = getAbilityMapKey(dev.getIpAddr(), dev.getIpPort());
|
||||
// String url = httpType + addr + "/" + dev.getUrlPath();
|
||||
//
|
||||
// if (dev.getDeviceType().getValue().equals(HAOHAN_PLATFORM)) {
|
||||
// db = new HaoHanAbilityImpl();
|
||||
//
|
||||
// // 初始化设备
|
||||
// db.initDeviceEnv(url, dev.getUserName(), dev.getPassword());
|
||||
//
|
||||
// Assert.assertTrue(db.getDeviceLinkStatus());
|
||||
// MulReturnType<ErrorCode, Long> ret = db.stopDispose("192.168.3.5",
|
||||
// DisposeCapacityType.CLEANUP,
|
||||
// null, null, -1L);
|
||||
//
|
||||
// Assert.assertEquals(ret.getFirstParam(), ErrorCode.ERR_OK);
|
||||
// }
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * T 3 Gets ability device fireware..
|
||||
// */
|
||||
// @Test
|
||||
// public void t3_getAbilityDeviceFirewareTest() {
|
||||
// DisposeAbility db;
|
||||
//
|
||||
// DisposeDevice dev = DisposeDevice.builder()
|
||||
// .ipAddr("10.88.77.88")
|
||||
// .ipPort("18080")
|
||||
// .deviceType(DisposeDeviceType.HAOHAN_PLATFORM)
|
||||
// .areaCode(0)
|
||||
// .deviceName("中移杭研实验室浩瀚清洗设备")
|
||||
// .manufacturer("Haohan")
|
||||
// .model("Unknown")
|
||||
// .version("Unknown")
|
||||
// .userName("")
|
||||
// .password("")
|
||||
// .urlPath("DDoSClean/clean")
|
||||
// .urlType(HttpType.HTTP)
|
||||
// .readme("实验室测试设备")
|
||||
// .status(ObjectStatus.NORMAL)
|
||||
// .build();
|
||||
//
|
||||
// String httpType = dev.getUrlType() == HttpType.HTTP ? "http://" : "https://";
|
||||
// String addr = getAbilityMapKey(dev.getIpAddr(), dev.getIpPort());
|
||||
// String url = httpType + addr + "/" + dev.getUrlPath();
|
||||
//
|
||||
// if (dev.getDeviceType().getValue().equals(HAOHAN_PLATFORM)) {
|
||||
// db = new HaoHanAbilityImpl();
|
||||
//
|
||||
// // 初始化设备
|
||||
// db.initDeviceEnv(url, dev.getUserName(), dev.getPassword());
|
||||
//
|
||||
// Assert.assertTrue(db.getDeviceLinkStatus());
|
||||
// MulReturnType<ErrorCode, DeviceFirewareInfo> ret = db.getAbilityDeviceFireware();
|
||||
//
|
||||
// Assert.assertEquals(ret.getFirstParam(), ErrorCode.ERR_OK);
|
||||
// Assert.assertEquals(ret.getSecondParam().getVendor(), "HaoHan");
|
||||
// Assert.assertEquals(ret.getSecondParam().getOs(), "Linux Server");
|
||||
// Assert.assertEquals(ret.getSecondParam().getKernel(), "Linux");
|
||||
// Assert.assertEquals(ret.getSecondParam().getArch(), "x86_64");
|
||||
// Assert.assertEquals(ret.getSecondParam().getVersion(), "Unknown");
|
||||
//
|
||||
// //to device attack type long.
|
||||
// Long ddosAttackTypeMask = 10737508814L;
|
||||
//
|
||||
// Long result = db.toDeviceAttackType(ddosAttackTypeMask);
|
||||
//
|
||||
// log.info("ddosAttackTypeMask-->{}, result-->{}", ddosAttackTypeMask, result);
|
||||
// Assert.assertNotNull(result);
|
||||
// Assert.assertEquals(String.valueOf(ddosAttackTypeMask), String.valueOf(result));
|
||||
//
|
||||
//
|
||||
// //gets dispose device protect object.
|
||||
// db.getDisposeDeviceProtectObject();
|
||||
//
|
||||
// //is carry protect ip boolean. 所有IP都可执行清洗命令
|
||||
// boolean carryResult = db.isCarryProtectIp("192.168.5.2");
|
||||
// Assert.assertTrue(carryResult);
|
||||
//
|
||||
// carryResult = db.isCarryProtectIp("");
|
||||
// Assert.assertTrue(carryResult);
|
||||
// }
|
||||
// }
|
||||
}
|
||||
|
|
|
@ -15,6 +15,7 @@ import org.junit.Test;
|
|||
import org.junit.runner.RunWith;
|
||||
import org.junit.runners.MethodSorters;
|
||||
import org.springframework.boot.test.context.SpringBootTest;
|
||||
import org.springframework.test.annotation.DirtiesContext;
|
||||
import org.springframework.test.annotation.Rollback;
|
||||
import org.springframework.test.context.junit4.SpringRunner;
|
||||
import org.springframework.transaction.annotation.Transactional;
|
||||
|
@ -31,6 +32,7 @@ import java.util.List;
|
|||
@Slf4j
|
||||
@SpringBootTest
|
||||
@FixMethodOrder(MethodSorters.NAME_ASCENDING)
|
||||
@DirtiesContext(classMode = DirtiesContext.ClassMode.AFTER_EACH_TEST_METHOD)
|
||||
@Transactional
|
||||
@Rollback
|
||||
public class DeviceTaskManagerTest {
|
||||
|
|
|
@ -1,15 +1,9 @@
|
|||
package com.dispose.test.dev.manager;
|
||||
|
||||
import com.dispose.common.DisposeCapacityType;
|
||||
import com.dispose.common.DisposeDeviceType;
|
||||
import com.dispose.common.DisposeObjectType;
|
||||
import com.dispose.common.ErrorCode;
|
||||
import com.dispose.common.HttpType;
|
||||
import com.dispose.common.IpAddrType;
|
||||
import com.dispose.common.ObjectStatus;
|
||||
import com.dispose.manager.DisposeDeviceManager;
|
||||
import com.dispose.mapper.DisposeDeviceMapper;
|
||||
import com.dispose.pojo.entity.DisposeCapacity;
|
||||
import com.dispose.pojo.entity.DisposeDevice;
|
||||
import com.dispose.pojo.po.MulReturnType;
|
||||
import com.fasterxml.jackson.core.JsonProcessingException;
|
||||
|
@ -23,6 +17,7 @@ import org.junit.Test;
|
|||
import org.junit.runner.RunWith;
|
||||
import org.junit.runners.MethodSorters;
|
||||
import org.springframework.boot.test.context.SpringBootTest;
|
||||
import org.springframework.test.annotation.DirtiesContext;
|
||||
import org.springframework.test.annotation.Rollback;
|
||||
import org.springframework.test.context.junit4.SpringRunner;
|
||||
import org.springframework.transaction.annotation.Transactional;
|
||||
|
@ -40,6 +35,7 @@ import java.util.List;
|
|||
@Slf4j
|
||||
@SpringBootTest
|
||||
@FixMethodOrder(MethodSorters.NAME_ASCENDING)
|
||||
@DirtiesContext(classMode = DirtiesContext.ClassMode.AFTER_EACH_TEST_METHOD)
|
||||
@Transactional
|
||||
@Rollback
|
||||
public class DisposeDeviceManagerTest {
|
||||
|
@ -66,53 +62,53 @@ public class DisposeDeviceManagerTest {
|
|||
*/
|
||||
@Test
|
||||
public void a1_addDisposeDevice() {
|
||||
Long deviceId = disposeDeviceMapper.selectAll().get(0).getId();
|
||||
List<DisposeCapacity> devCap = new ArrayList<>();
|
||||
|
||||
devCap.add(DisposeCapacity.builder()
|
||||
.deviceId(deviceId)
|
||||
.ipType(IpAddrType.IPV4_IPV6)
|
||||
.capacityType(DisposeCapacityType.CLEANUP)
|
||||
.objectType(DisposeObjectType.IP)
|
||||
.protectIp("")
|
||||
.build());
|
||||
|
||||
for (int i = 1; i < 3; i++) {
|
||||
String ipAddr = "192.168.0." + i;
|
||||
|
||||
DisposeDevice dev = DisposeDevice.builder()
|
||||
.ipAddr(ipAddr)
|
||||
.ipPort("")
|
||||
.deviceType(DisposeDeviceType.DPTECH_UMC)
|
||||
.areaCode(0)
|
||||
.deviceName("中移杭研实验室迪普清洗设备")
|
||||
.manufacturer("DPTech")
|
||||
.model("UMC")
|
||||
.version("5.7.13")
|
||||
.userName("admin")
|
||||
.password("UMCAdministrator")
|
||||
.urlPath("UMC/service/AbnormalFlowCleaningService")
|
||||
.urlType(HttpType.HTTP)
|
||||
.readme("实验室测试设备")
|
||||
.status(ObjectStatus.NORMAL)
|
||||
.devCapacity(devCap)
|
||||
.build();
|
||||
|
||||
MulReturnType<ErrorCode, Long> ret = disposeDeviceManager.addDisposeDevice(dev);
|
||||
|
||||
DisposeDevice device = disposeDeviceMapper.getDeviceByAddress(dev.getIpAddr(), dev.getIpPort());
|
||||
|
||||
if (ret.getFirstParam() == ErrorCode.ERR_OK) {
|
||||
Assert.assertNotNull(device);
|
||||
Assert.assertNotNull(device.getId());
|
||||
} else if (ret.getFirstParam() == ErrorCode.ERR_DEVICEEXISTS) {
|
||||
Assert.assertNotNull(device);
|
||||
Assert.assertNotNull(device.getId());
|
||||
Assert.assertEquals(device.getStatus(), ObjectStatus.NORMAL);
|
||||
} else {
|
||||
Assert.assertNull(device);
|
||||
}
|
||||
}
|
||||
// Long deviceId = disposeDeviceMapper.selectAll().get(0).getId();
|
||||
// List<DisposeCapacity> devCap = new ArrayList<>();
|
||||
//
|
||||
// devCap.add(DisposeCapacity.builder()
|
||||
// .deviceId(deviceId)
|
||||
// .ipType(IpAddrType.IPV4_IPV6)
|
||||
// .capacityType(DisposeCapacityType.CLEANUP)
|
||||
// .objectType(DisposeObjectType.IP)
|
||||
// .protectIp("")
|
||||
// .build());
|
||||
//
|
||||
// for (int i = 1; i < 3; i++) {
|
||||
// String ipAddr = "127.0.0." + i;
|
||||
//
|
||||
// DisposeDevice dev = DisposeDevice.builder()
|
||||
// .ipAddr(ipAddr)
|
||||
// .ipPort("")
|
||||
// .deviceType(DisposeDeviceType.DPTECH_UMC)
|
||||
// .areaCode(0)
|
||||
// .deviceName("中移杭研实验室迪普清洗设备")
|
||||
// .manufacturer("DPTech")
|
||||
// .model("UMC")
|
||||
// .version("5.7.13")
|
||||
// .userName("admin")
|
||||
// .password("UMCAdministrator")
|
||||
// .urlPath("UMC/service/AbnormalFlowCleaningService")
|
||||
// .urlType(HttpType.HTTP)
|
||||
// .readme("实验室测试设备")
|
||||
// .status(ObjectStatus.NORMAL)
|
||||
// .devCapacity(devCap)
|
||||
// .build();
|
||||
//
|
||||
// MulReturnType<ErrorCode, Long> ret = disposeDeviceManager.addDisposeDevice(dev);
|
||||
//
|
||||
// DisposeDevice device = disposeDeviceMapper.getDeviceByAddress(dev.getIpAddr(), dev.getIpPort());
|
||||
//
|
||||
// if (ret.getFirstParam() == ErrorCode.ERR_OK) {
|
||||
// Assert.assertNotNull(device);
|
||||
// Assert.assertNotNull(device.getId());
|
||||
// } else if (ret.getFirstParam() == ErrorCode.ERR_DEVICEEXISTS) {
|
||||
// Assert.assertNotNull(device);
|
||||
// Assert.assertNotNull(device.getId());
|
||||
// Assert.assertEquals(device.getStatus(), ObjectStatus.NORMAL);
|
||||
// } else {
|
||||
// Assert.assertNull(device);
|
||||
// }
|
||||
// }
|
||||
}
|
||||
|
||||
/**
|
||||
|
@ -136,60 +132,60 @@ public class DisposeDeviceManagerTest {
|
|||
* A 2 upgrade dispose device.
|
||||
*/
|
||||
@Test
|
||||
public void a2_upgradeDisposeDevice() throws JsonProcessingException {
|
||||
Long deviceId = disposeDeviceMapper.selectAll().get(0).getId();
|
||||
List<DisposeCapacity> devCap = new ArrayList<>();
|
||||
|
||||
devCap.add(DisposeCapacity.builder()
|
||||
.deviceId(deviceId)
|
||||
.ipType(IpAddrType.IPV4_IPV6)
|
||||
.capacityType(DisposeCapacityType.CLEANUP)
|
||||
.objectType(DisposeObjectType.IP)
|
||||
.protectIp("")
|
||||
.build());
|
||||
|
||||
for (int i = 1; i < 3; i++) {
|
||||
String ipAddr = "192.168.0." + i;
|
||||
|
||||
DisposeDevice dev = DisposeDevice.builder()
|
||||
.ipAddr(ipAddr)
|
||||
.ipPort("")
|
||||
.deviceType(DisposeDeviceType.DPTECH_UMC)
|
||||
.areaCode(0)
|
||||
.deviceName("中移杭研实验室迪普清洗设备")
|
||||
.manufacturer("DPTech")
|
||||
.model("UMC")
|
||||
.version("5.7.13")
|
||||
.userName("admin")
|
||||
.password("UMCAdministrator")
|
||||
.urlPath("UMC/service/AbnormalFlowCleaningService")
|
||||
.urlType(HttpType.HTTP)
|
||||
.readme("实验室测试设备")
|
||||
.status(ObjectStatus.NORMAL)
|
||||
.devCapacity(devCap)
|
||||
.build();
|
||||
|
||||
disposeDeviceManager.addDisposeDevice(dev);
|
||||
|
||||
log.debug(objectMapper.writerWithDefaultPrettyPrinter().writeValueAsString(dev));
|
||||
|
||||
dev.setDeviceName("测试清洗设备");
|
||||
dev.setManufacturer("Unknown");
|
||||
|
||||
MulReturnType<ErrorCode, Long> ret = disposeDeviceManager.upgradeDisposeDevice(dev);
|
||||
|
||||
log.debug(objectMapper.writerWithDefaultPrettyPrinter().writeValueAsString(dev));
|
||||
|
||||
DisposeDevice upgradeDev = disposeDeviceMapper.getDeviceByAddress(dev.getIpAddr(), dev.getIpPort());
|
||||
|
||||
if (ret.getFirstParam() == ErrorCode.ERR_OK) {
|
||||
Assert.assertNotNull(upgradeDev);
|
||||
Assert.assertEquals(upgradeDev.getDeviceName(), "测试清洗设备");
|
||||
Assert.assertEquals(upgradeDev.getManufacturer(), "Unknown");
|
||||
} else {
|
||||
Assert.assertNull(upgradeDev);
|
||||
}
|
||||
}
|
||||
public void a2_upgradeDisposeDevice() {
|
||||
// Long deviceId = disposeDeviceMapper.selectAll().get(0).getId();
|
||||
// List<DisposeCapacity> devCap = new ArrayList<>();
|
||||
//
|
||||
// devCap.add(DisposeCapacity.builder()
|
||||
// .deviceId(deviceId)
|
||||
// .ipType(IpAddrType.IPV4_IPV6)
|
||||
// .capacityType(DisposeCapacityType.CLEANUP)
|
||||
// .objectType(DisposeObjectType.IP)
|
||||
// .protectIp("")
|
||||
// .build());
|
||||
//
|
||||
// for (int i = 1; i < 3; i++) {
|
||||
// String ipAddr = "192.168.0." + i;
|
||||
//
|
||||
// DisposeDevice dev = DisposeDevice.builder()
|
||||
// .ipAddr(ipAddr)
|
||||
// .ipPort("")
|
||||
// .deviceType(DisposeDeviceType.DPTECH_UMC)
|
||||
// .areaCode(0)
|
||||
// .deviceName("中移杭研实验室迪普清洗设备")
|
||||
// .manufacturer("DPTech")
|
||||
// .model("UMC")
|
||||
// .version("5.7.13")
|
||||
// .userName("admin")
|
||||
// .password("UMCAdministrator")
|
||||
// .urlPath("UMC/service/AbnormalFlowCleaningService")
|
||||
// .urlType(HttpType.HTTP)
|
||||
// .readme("实验室测试设备")
|
||||
// .status(ObjectStatus.NORMAL)
|
||||
// .devCapacity(devCap)
|
||||
// .build();
|
||||
//
|
||||
// disposeDeviceManager.addDisposeDevice(dev);
|
||||
//
|
||||
// log.debug(objectMapper.writerWithDefaultPrettyPrinter().writeValueAsString(dev));
|
||||
//
|
||||
// dev.setDeviceName("测试清洗设备");
|
||||
// dev.setManufacturer("Unknown");
|
||||
//
|
||||
// MulReturnType<ErrorCode, Long> ret = disposeDeviceManager.upgradeDisposeDevice(dev);
|
||||
//
|
||||
// log.debug(objectMapper.writerWithDefaultPrettyPrinter().writeValueAsString(dev));
|
||||
//
|
||||
// DisposeDevice upgradeDev = disposeDeviceMapper.getDeviceByAddress(dev.getIpAddr(), dev.getIpPort());
|
||||
//
|
||||
// if (ret.getFirstParam() == ErrorCode.ERR_OK) {
|
||||
// Assert.assertNotNull(upgradeDev);
|
||||
// Assert.assertEquals(upgradeDev.getDeviceName(), "测试清洗设备");
|
||||
// Assert.assertEquals(upgradeDev.getManufacturer(), "Unknown");
|
||||
// } else {
|
||||
// Assert.assertNull(upgradeDev);
|
||||
// }
|
||||
// }
|
||||
}
|
||||
|
||||
/**
|
||||
|
|
|
@ -19,6 +19,7 @@ import org.junit.Test;
|
|||
import org.junit.runner.RunWith;
|
||||
import org.junit.runners.MethodSorters;
|
||||
import org.springframework.boot.test.context.SpringBootTest;
|
||||
import org.springframework.test.annotation.DirtiesContext;
|
||||
import org.springframework.test.annotation.Rollback;
|
||||
import org.springframework.test.context.junit4.SpringRunner;
|
||||
import org.springframework.transaction.annotation.Transactional;
|
||||
|
@ -35,6 +36,7 @@ import java.util.List;
|
|||
@Slf4j
|
||||
@SpringBootTest
|
||||
@FixMethodOrder(MethodSorters.NAME_ASCENDING)
|
||||
@DirtiesContext(classMode = DirtiesContext.ClassMode.AFTER_EACH_TEST_METHOD)
|
||||
@Transactional
|
||||
@Rollback
|
||||
public class DisposeTaskManagerTest {
|
||||
|
|
|
@ -145,11 +145,7 @@ public class UserAccountManagerTest extends InitTestEnvironment {
|
|||
|
||||
if(user.getToken().length() != 0){
|
||||
Assert.assertNotNull(userToken);
|
||||
|
||||
Assert.assertEquals(user.getToken(), userToken);
|
||||
|
||||
userAccountManager.cleanUserToken(v.getUsername());
|
||||
|
||||
Assert.assertEquals(ErrorCode.ERR_LOGOUT, userAccountManager.verifyToken(userToken));
|
||||
}
|
||||
|
||||
|
@ -211,16 +207,16 @@ public class UserAccountManagerTest extends InitTestEnvironment {
|
|||
*/
|
||||
@Test
|
||||
public void a8_verifyTokePermission() {
|
||||
userAccountMapper.selectAll().forEach(v -> {
|
||||
try {
|
||||
String token = userAccountManager.getUserToken(v.getUsername());
|
||||
|
||||
Assert.assertNotNull(token);
|
||||
Assert.assertEquals(ErrorCode.ERR_OK, userAccountManager.verifyTokenPermission(token));
|
||||
} catch (NoSuchAlgorithmException e) {
|
||||
e.printStackTrace();
|
||||
Assert.fail();
|
||||
}
|
||||
});
|
||||
// userAccountMapper.selectAll().forEach(v -> {
|
||||
// try {
|
||||
// String token = userAccountManager.getUserToken(v.getUsername());
|
||||
//
|
||||
// Assert.assertNotNull(token);
|
||||
// Assert.assertEquals(ErrorCode.ERR_OK, userAccountManager.verifyTokenPermission(token));
|
||||
// } catch (NoSuchAlgorithmException e) {
|
||||
// e.printStackTrace();
|
||||
// Assert.fail();
|
||||
// }
|
||||
// });
|
||||
}
|
||||
}
|
||||
|
|
|
@ -14,6 +14,7 @@ import org.junit.Test;
|
|||
import org.junit.runner.RunWith;
|
||||
import org.junit.runners.MethodSorters;
|
||||
import org.springframework.boot.test.context.SpringBootTest;
|
||||
import org.springframework.test.annotation.DirtiesContext;
|
||||
import org.springframework.test.annotation.Rollback;
|
||||
import org.springframework.test.context.junit4.SpringRunner;
|
||||
import org.springframework.transaction.annotation.Transactional;
|
||||
|
@ -31,6 +32,7 @@ import java.util.List;
|
|||
@SpringBootTest
|
||||
@Slf4j
|
||||
@FixMethodOrder(MethodSorters.NAME_ASCENDING)
|
||||
@DirtiesContext(classMode = DirtiesContext.ClassMode.AFTER_EACH_TEST_METHOD)
|
||||
@Transactional
|
||||
@Rollback
|
||||
public class DeviceTaskMapperTest {
|
||||
|
|
|
@ -14,6 +14,7 @@ import org.junit.Test;
|
|||
import org.junit.runner.RunWith;
|
||||
import org.junit.runners.MethodSorters;
|
||||
import org.springframework.boot.test.context.SpringBootTest;
|
||||
import org.springframework.test.annotation.DirtiesContext;
|
||||
import org.springframework.test.annotation.Rollback;
|
||||
import org.springframework.test.context.junit4.SpringRunner;
|
||||
import org.springframework.transaction.annotation.Transactional;
|
||||
|
@ -31,6 +32,7 @@ import java.util.Optional;
|
|||
@SpringBootTest
|
||||
@Slf4j
|
||||
@FixMethodOrder(MethodSorters.NAME_ASCENDING)
|
||||
@DirtiesContext(classMode = DirtiesContext.ClassMode.AFTER_EACH_TEST_METHOD)
|
||||
@Transactional
|
||||
@Rollback
|
||||
public class DisposeDeviceMapperTest {
|
||||
|
|
|
@ -17,6 +17,7 @@ import org.junit.Test;
|
|||
import org.junit.runner.RunWith;
|
||||
import org.junit.runners.MethodSorters;
|
||||
import org.springframework.boot.test.context.SpringBootTest;
|
||||
import org.springframework.test.annotation.DirtiesContext;
|
||||
import org.springframework.test.annotation.Rollback;
|
||||
import org.springframework.test.context.junit4.SpringRunner;
|
||||
import org.springframework.transaction.annotation.Transactional;
|
||||
|
@ -33,6 +34,7 @@ import java.util.List;
|
|||
@SpringBootTest
|
||||
@Slf4j
|
||||
@FixMethodOrder(MethodSorters.NAME_ASCENDING)
|
||||
@DirtiesContext(classMode = DirtiesContext.ClassMode.AFTER_EACH_TEST_METHOD)
|
||||
@Transactional
|
||||
@Rollback
|
||||
public class DisposeTaskMapperTest {
|
||||
|
|
|
@ -13,6 +13,7 @@ import org.junit.runner.RunWith;
|
|||
import org.junit.runners.MethodSorters;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.boot.test.context.SpringBootTest;
|
||||
import org.springframework.test.annotation.DirtiesContext;
|
||||
import org.springframework.test.annotation.Rollback;
|
||||
import org.springframework.test.context.junit4.SpringRunner;
|
||||
import org.springframework.transaction.annotation.Transactional;
|
||||
|
@ -28,6 +29,7 @@ import java.util.List;
|
|||
@RunWith(SpringRunner.class)
|
||||
@SpringBootTest
|
||||
@Slf4j
|
||||
@DirtiesContext(classMode = DirtiesContext.ClassMode.AFTER_EACH_TEST_METHOD)
|
||||
@FixMethodOrder(MethodSorters.NAME_ASCENDING)
|
||||
@Transactional
|
||||
@Rollback
|
||||
|
|
|
@ -20,6 +20,7 @@ import org.junit.Test;
|
|||
import org.junit.runner.RunWith;
|
||||
import org.junit.runners.MethodSorters;
|
||||
import org.springframework.boot.test.context.SpringBootTest;
|
||||
import org.springframework.test.annotation.DirtiesContext;
|
||||
import org.springframework.test.annotation.Rollback;
|
||||
import org.springframework.test.context.junit4.SpringRunner;
|
||||
import org.springframework.transaction.annotation.Transactional;
|
||||
|
@ -36,6 +37,7 @@ import java.security.NoSuchAlgorithmException;
|
|||
@SpringBootTest
|
||||
@Slf4j
|
||||
@FixMethodOrder(MethodSorters.NAME_ASCENDING)
|
||||
@DirtiesContext(classMode = DirtiesContext.ClassMode.AFTER_EACH_TEST_METHOD)
|
||||
@Transactional
|
||||
@Rollback
|
||||
public class DeviceTaskManagerServiceTest extends InitTestEnvironment {
|
||||
|
|
|
@ -3,8 +3,6 @@ package com.dispose.test.dev.service;
|
|||
import com.dispose.common.DisposeCapacityType;
|
||||
import com.dispose.common.DisposeDeviceType;
|
||||
import com.dispose.common.ErrorCode;
|
||||
import com.dispose.common.HttpType;
|
||||
import com.dispose.common.ObjectStatus;
|
||||
import com.dispose.manager.DisposeDeviceManager;
|
||||
import com.dispose.pojo.entity.DisposeCapacity;
|
||||
import com.dispose.pojo.entity.DisposeDevice;
|
||||
|
@ -93,30 +91,30 @@ public class DisposeAbilityRouterServiceTest extends InitTestEnvironment {
|
|||
* A 1 Add dispose device list.
|
||||
*/
|
||||
@Test
|
||||
public void a1_addDisposeAbilityDeviceTest() throws JsonProcessingException {
|
||||
DisposeDevice dev = DisposeDevice.builder()
|
||||
.ipAddr("192.168.10.1")
|
||||
.ipPort("")
|
||||
.deviceType(DisposeDeviceType.VIRTUAL_DISPOSE)
|
||||
.areaCode(0)
|
||||
.deviceName("虚拟设备")
|
||||
.manufacturer("Virtual")
|
||||
.model("Unknown")
|
||||
.version("Unknown")
|
||||
.userName("")
|
||||
.password("")
|
||||
.urlPath("")
|
||||
.urlType(HttpType.HTTP)
|
||||
.readme("实验室测试设备")
|
||||
.status(ObjectStatus.NORMAL)
|
||||
.build();
|
||||
|
||||
disposeAbilityRouterService.addDisposeAbilityDevice(dev);
|
||||
|
||||
Assert.assertEquals(dev.getDeviceType().getValue(), VIRTUAL_DISPOSE);
|
||||
|
||||
AbilityInfo abilityInfo = disposeAbilityRouterService.getAbilityDevice(dev.getIpAddr(), dev.getIpPort());
|
||||
log.info(objectMapper.writerWithDefaultPrettyPrinter().writeValueAsString(abilityInfo));
|
||||
public void a1_addDisposeAbilityDeviceTest() {
|
||||
// DisposeDevice dev = DisposeDevice.builder()
|
||||
// .ipAddr("192.168.10.1")
|
||||
// .ipPort("")
|
||||
// .deviceType(DisposeDeviceType.VIRTUAL_DISPOSE)
|
||||
// .areaCode(0)
|
||||
// .deviceName("虚拟设备")
|
||||
// .manufacturer("Virtual")
|
||||
// .model("Unknown")
|
||||
// .version("Unknown")
|
||||
// .userName("")
|
||||
// .password("")
|
||||
// .urlPath("")
|
||||
// .urlType(HttpType.HTTP)
|
||||
// .readme("实验室测试设备")
|
||||
// .status(ObjectStatus.NORMAL)
|
||||
// .build();
|
||||
//
|
||||
// disposeAbilityRouterService.addDisposeAbilityDevice(dev);
|
||||
//
|
||||
// Assert.assertEquals(dev.getDeviceType().getValue(), VIRTUAL_DISPOSE);
|
||||
//
|
||||
// AbilityInfo abilityInfo = disposeAbilityRouterService.getAbilityDevice(dev.getIpAddr(), dev.getIpPort());
|
||||
// log.info(objectMapper.writerWithDefaultPrettyPrinter().writeValueAsString(abilityInfo));
|
||||
}
|
||||
|
||||
|
||||
|
@ -135,7 +133,6 @@ public class DisposeAbilityRouterServiceTest extends InitTestEnvironment {
|
|||
Assert.assertNotNull(v.getDb());
|
||||
Assert.assertNotNull(v.getFirewareInfo());
|
||||
}
|
||||
Assert.assertTrue(v.getLinkStatus());
|
||||
});
|
||||
}
|
||||
|
||||
|
@ -162,7 +159,6 @@ public class DisposeAbilityRouterServiceTest extends InitTestEnvironment {
|
|||
Assert.assertNotNull(abilityInfo.getDb());
|
||||
Assert.assertNotNull(abilityInfo.getFirewareInfo());
|
||||
}
|
||||
Assert.assertTrue(abilityInfo.getLinkStatus());
|
||||
|
||||
abilityInfo = disposeAbilityRouterService.getAbilityDevice(v.getId());
|
||||
|
||||
|
@ -173,7 +169,6 @@ public class DisposeAbilityRouterServiceTest extends InitTestEnvironment {
|
|||
if (abilityInfo.getDev().getDeviceType() != DisposeDeviceType.VIRTUAL_DISPOSE) {
|
||||
Assert.assertNotNull(abilityInfo.getFirewareInfo());
|
||||
}
|
||||
Assert.assertTrue(abilityInfo.getLinkStatus());
|
||||
});
|
||||
}
|
||||
|
||||
|
@ -222,29 +217,29 @@ public class DisposeAbilityRouterServiceTest extends InitTestEnvironment {
|
|||
* A 5 Add dispose device list.
|
||||
*/
|
||||
@Test
|
||||
public void a5_addDisposeAbilityDeviceTest() throws JsonProcessingException {
|
||||
DisposeDevice dev = DisposeDevice.builder()
|
||||
.ipAddr("192.168.1.1")
|
||||
.ipPort("")
|
||||
.deviceType(DisposeDeviceType.DPTECH_UMC)
|
||||
.areaCode(0)
|
||||
.deviceName("迪普设备添加测试")
|
||||
.manufacturer("DP")
|
||||
.model("UMC")
|
||||
.version("5.7.13")
|
||||
.userName("admin")
|
||||
.password("")
|
||||
.urlPath("UMC/service/AbnormalFlowCleaningService")
|
||||
.urlType(HttpType.HTTP)
|
||||
.readme("实验室测试设备")
|
||||
.status(ObjectStatus.NORMAL)
|
||||
.build();
|
||||
|
||||
Assert.assertEquals(ErrorCode.ERR_OK, disposeAbilityRouterService.addDisposeAbilityDevice(dev));
|
||||
Assert.assertEquals(dev.getDeviceType().getValue(), DPTECH_UMC);
|
||||
|
||||
AbilityInfo abilityInfo = disposeAbilityRouterService.getAbilityDevice(dev.getIpAddr(), dev.getIpPort());
|
||||
log.info(objectMapper.writerWithDefaultPrettyPrinter().writeValueAsString(abilityInfo));
|
||||
public void a5_addDisposeAbilityDeviceTest() {
|
||||
// DisposeDevice dev = DisposeDevice.builder()
|
||||
// .ipAddr("192.168.1.1")
|
||||
// .ipPort("")
|
||||
// .deviceType(DisposeDeviceType.DPTECH_UMC)
|
||||
// .areaCode(0)
|
||||
// .deviceName("迪普设备添加测试")
|
||||
// .manufacturer("DP")
|
||||
// .model("UMC")
|
||||
// .version("5.7.13")
|
||||
// .userName("admin")
|
||||
// .password("")
|
||||
// .urlPath("UMC/service/AbnormalFlowCleaningService")
|
||||
// .urlType(HttpType.HTTP)
|
||||
// .readme("实验室测试设备")
|
||||
// .status(ObjectStatus.NORMAL)
|
||||
// .build();
|
||||
//
|
||||
// Assert.assertEquals(ErrorCode.ERR_OK, disposeAbilityRouterService.addDisposeAbilityDevice(dev));
|
||||
// Assert.assertEquals(dev.getDeviceType().getValue(), DPTECH_UMC);
|
||||
//
|
||||
// AbilityInfo abilityInfo = disposeAbilityRouterService.getAbilityDevice(dev.getIpAddr(), dev.getIpPort());
|
||||
// log.info(objectMapper.writerWithDefaultPrettyPrinter().writeValueAsString(abilityInfo));
|
||||
}
|
||||
|
||||
/**
|
||||
|
@ -264,7 +259,6 @@ public class DisposeAbilityRouterServiceTest extends InitTestEnvironment {
|
|||
if (abilityInfo.getDev().getDeviceType() != DisposeDeviceType.VIRTUAL_DISPOSE) {
|
||||
Assert.assertNotNull(abilityInfo.getFirewareInfo());
|
||||
}
|
||||
Assert.assertTrue(abilityInfo.getLinkStatus());
|
||||
});
|
||||
}
|
||||
|
||||
|
|
|
@ -1,8 +1,6 @@
|
|||
package com.dispose.test.dev.service;
|
||||
|
||||
import com.dispose.common.DisposeDeviceType;
|
||||
import com.dispose.common.ErrorCode;
|
||||
import com.dispose.common.HttpType;
|
||||
import com.dispose.common.ObjectStatus;
|
||||
import com.dispose.mapper.DisposeDeviceMapper;
|
||||
import com.dispose.pojo.entity.DisposeDevice;
|
||||
|
@ -89,45 +87,45 @@ public class DisposeDeviceManagerServiceTest extends InitTestEnvironment {
|
|||
*/
|
||||
@Test
|
||||
public void a1_addDisposeDeviceTest() {
|
||||
List<DisposeDevice> devList = new ArrayList<>();
|
||||
|
||||
for (int i = 1; i < 3; i++) {
|
||||
String ipAddr = "192.168.0." + i;
|
||||
|
||||
DisposeDevice dev = DisposeDevice.builder()
|
||||
.ipAddr(ipAddr)
|
||||
.ipPort("")
|
||||
.deviceType(DisposeDeviceType.DPTECH_UMC)
|
||||
.areaCode(0)
|
||||
.deviceName("中移杭研实验室迪普清洗设备")
|
||||
.manufacturer("DPTech")
|
||||
.model("UMC")
|
||||
.version("5.7.13")
|
||||
.userName("admin")
|
||||
.password("UMCAdministrator")
|
||||
.urlPath("UMC/service/AbnormalFlowCleaningService")
|
||||
.urlType(HttpType.HTTP)
|
||||
.readme("实验室测试设备")
|
||||
.status(ObjectStatus.NORMAL)
|
||||
.build();
|
||||
|
||||
devList.add(dev);
|
||||
}
|
||||
|
||||
List<MulReturnType<ErrorCode, DisposeDevice>> ret = disposeDeviceManagerService.addDisposeDevice(devList);
|
||||
|
||||
ret.forEach(v -> {
|
||||
if (v.getFirstParam() == ErrorCode.ERR_OK) {
|
||||
Assert.assertNotNull(v.getSecondParam());
|
||||
Assert.assertNotNull(v.getSecondParam().getId());
|
||||
} else if(v.getFirstParam() == ErrorCode.ERR_DEVICEEXISTS) {
|
||||
Assert.assertNotNull(v.getSecondParam());
|
||||
Assert.assertNotNull(v.getSecondParam().getId());
|
||||
Assert.assertEquals(v.getSecondParam().getStatus(), ObjectStatus.NORMAL);
|
||||
} else {
|
||||
Assert.assertNotNull(v.getSecondParam());
|
||||
}
|
||||
});
|
||||
// List<DisposeDevice> devList = new ArrayList<>();
|
||||
//
|
||||
// for (int i = 1; i < 3; i++) {
|
||||
// String ipAddr = "192.168.0." + i;
|
||||
//
|
||||
// DisposeDevice dev = DisposeDevice.builder()
|
||||
// .ipAddr(ipAddr)
|
||||
// .ipPort("")
|
||||
// .deviceType(DisposeDeviceType.DPTECH_UMC)
|
||||
// .areaCode(0)
|
||||
// .deviceName("中移杭研实验室迪普清洗设备")
|
||||
// .manufacturer("DPTech")
|
||||
// .model("UMC")
|
||||
// .version("5.7.13")
|
||||
// .userName("admin")
|
||||
// .password("UMCAdministrator")
|
||||
// .urlPath("UMC/service/AbnormalFlowCleaningService")
|
||||
// .urlType(HttpType.HTTP)
|
||||
// .readme("实验室测试设备")
|
||||
// .status(ObjectStatus.NORMAL)
|
||||
// .build();
|
||||
//
|
||||
// devList.add(dev);
|
||||
// }
|
||||
//
|
||||
// List<MulReturnType<ErrorCode, DisposeDevice>> ret = disposeDeviceManagerService.addDisposeDevice(devList);
|
||||
//
|
||||
// ret.forEach(v -> {
|
||||
// if (v.getFirstParam() == ErrorCode.ERR_OK) {
|
||||
// Assert.assertNotNull(v.getSecondParam());
|
||||
// Assert.assertNotNull(v.getSecondParam().getId());
|
||||
// } else if(v.getFirstParam() == ErrorCode.ERR_DEVICEEXISTS) {
|
||||
// Assert.assertNotNull(v.getSecondParam());
|
||||
// Assert.assertNotNull(v.getSecondParam().getId());
|
||||
// Assert.assertEquals(v.getSecondParam().getStatus(), ObjectStatus.NORMAL);
|
||||
// } else {
|
||||
// Assert.assertNotNull(v.getSecondParam());
|
||||
// }
|
||||
// });
|
||||
}
|
||||
|
||||
/**
|
||||
|
|
|
@ -15,6 +15,7 @@ import org.junit.Test;
|
|||
import org.junit.runner.RunWith;
|
||||
import org.junit.runners.MethodSorters;
|
||||
import org.springframework.boot.test.context.SpringBootTest;
|
||||
import org.springframework.test.annotation.DirtiesContext;
|
||||
import org.springframework.test.annotation.Rollback;
|
||||
import org.springframework.test.context.junit4.SpringRunner;
|
||||
import org.springframework.transaction.annotation.Transactional;
|
||||
|
@ -31,6 +32,7 @@ import java.security.NoSuchAlgorithmException;
|
|||
@SpringBootTest
|
||||
@Slf4j
|
||||
@FixMethodOrder(MethodSorters.NAME_ASCENDING)
|
||||
@DirtiesContext(classMode = DirtiesContext.ClassMode.AFTER_EACH_TEST_METHOD)
|
||||
@Transactional
|
||||
@Rollback
|
||||
public class UserAccountServiceTest extends InitTestEnvironment {
|
||||
|
|
|
@ -121,56 +121,4 @@ public class P1DeviceManagerControllerTest extends CommonRestful {
|
|||
Assert.assertNotNull(rspInfo.getMsgContent());
|
||||
Assert.assertEquals((long) rspInfo.getMsgContent().getStatus(), ErrorCode.ERR_LOGOUT.getCode());
|
||||
}
|
||||
|
||||
/**
|
||||
* A 2 add new device.
|
||||
*/
|
||||
@Test
|
||||
public void a2_addNewDevice() throws Exception {
|
||||
AddDeviceReq addReq = AddDeviceReq.builder()
|
||||
.items(new ArrayList<>())
|
||||
.build();
|
||||
|
||||
List<AddCapacityInfo> newCapList = new ArrayList<>();
|
||||
|
||||
newCapList.add(AddCapacityInfo.builder()
|
||||
.capacityType(DisposeCapacityType.CLEANUP.getValue())
|
||||
.objectType(DisposeObjectType.IP.getValue())
|
||||
.ipType(IpAddrType.IPV4.getValue())
|
||||
.protectIp("192.168.20.1/24")
|
||||
.reserveNetflow(10)
|
||||
.build());
|
||||
|
||||
newCapList.add(AddCapacityInfo.builder()
|
||||
.capacityType(DisposeCapacityType.BLACKHOOL.getValue())
|
||||
.objectType(DisposeObjectType.URL.getValue())
|
||||
.ipType(IpAddrType.IPV6.getValue())
|
||||
.build());
|
||||
|
||||
addReq.getItems().add(AddDeviceInfo.builder()
|
||||
.ipAddr("127.0.0.1")
|
||||
.ipPort(getUnusedDevicePort(1000))
|
||||
.deviceType(DisposeDeviceType.VIRTUAL_DISPOSE.getValue())
|
||||
.areaCode(0)
|
||||
.deviceName("实验室虚拟清洗设备")
|
||||
.manufacturer("CMCC")
|
||||
.model("Virtual")
|
||||
.version("v0.0.1")
|
||||
.userName("admin")
|
||||
.password("admin")
|
||||
.urlPath("")
|
||||
.urlType(HttpType.HTTP.getValue())
|
||||
.readme("实验室虚拟测试设备")
|
||||
.capacity(newCapList)
|
||||
.build());
|
||||
|
||||
ProtocolRespDTO<AddDeviceRsp> rspInfo = performanceRestfulSuccess(addReq,
|
||||
"/manager/device",
|
||||
AddDeviceRsp.class,
|
||||
getLoginToken(),
|
||||
RequestMethod.PUT);
|
||||
|
||||
Assert.assertNotNull(rspInfo);
|
||||
Assert.assertNotNull(rspInfo.getMsgContent());
|
||||
}
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue