parent
8884c75dae
commit
65a938d5bb
2
pom.xml
2
pom.xml
|
@ -17,7 +17,7 @@
|
||||||
</parent>
|
</parent>
|
||||||
<groupId>com.dispose</groupId>
|
<groupId>com.dispose</groupId>
|
||||||
<artifactId>dispose_platform</artifactId>
|
<artifactId>dispose_platform</artifactId>
|
||||||
<version>2.0.8</version>
|
<version>2.0.9</version>
|
||||||
<name>dispose_platform</name>
|
<name>dispose_platform</name>
|
||||||
<description>Dispose Platform</description>
|
<description>Dispose Platform</description>
|
||||||
<dependencies>
|
<dependencies>
|
||||||
|
|
|
@ -14,7 +14,6 @@ import com.dispose.common.NetflowDirection;
|
||||||
import com.dispose.pojo.entity.ServiceInfo;
|
import com.dispose.pojo.entity.ServiceInfo;
|
||||||
import com.dispose.pojo.po.MulReturnType;
|
import com.dispose.pojo.po.MulReturnType;
|
||||||
import com.dispose.pojo.vo.DeviceFirewareInfo;
|
import com.dispose.pojo.vo.DeviceFirewareInfo;
|
||||||
import com.dispose.security.arithmetic.CryptoHelper;
|
|
||||||
import com.dptech.dispose.AbnormalFlowCleaningServicePortType;
|
import com.dptech.dispose.AbnormalFlowCleaningServicePortType;
|
||||||
import com.dptech.dispose.ArrayOfProtectionObjectDataForService;
|
import com.dptech.dispose.ArrayOfProtectionObjectDataForService;
|
||||||
import com.dptech.dispose.NtcRequestResultInfo;
|
import com.dptech.dispose.NtcRequestResultInfo;
|
||||||
|
@ -102,7 +101,7 @@ public class DpTechAbilityImpl implements DisposeAbility {
|
||||||
this.cleanTypePort = (AbnormalFlowCleaningServicePortType) jaxWsProxyFactoryBean.create();
|
this.cleanTypePort = (AbnormalFlowCleaningServicePortType) jaxWsProxyFactoryBean.create();
|
||||||
|
|
||||||
Map<String, Object> ctx = ((BindingProvider) this.cleanTypePort).getRequestContext();
|
Map<String, Object> ctx = ((BindingProvider) this.cleanTypePort).getRequestContext();
|
||||||
ctx.put("password", new String(CryptoHelper.base64Decryption(password)));
|
ctx.put("password", password);
|
||||||
ctx.put("username", username);
|
ctx.put("username", username);
|
||||||
|
|
||||||
// 配置连接,访问超时时间
|
// 配置连接,访问超时时间
|
||||||
|
|
|
@ -10,7 +10,6 @@ import com.dispose.common.NetflowDirection;
|
||||||
import com.dispose.pojo.entity.ServiceInfo;
|
import com.dispose.pojo.entity.ServiceInfo;
|
||||||
import com.dispose.pojo.po.MulReturnType;
|
import com.dispose.pojo.po.MulReturnType;
|
||||||
import com.dispose.pojo.vo.DeviceFirewareInfo;
|
import com.dispose.pojo.vo.DeviceFirewareInfo;
|
||||||
import com.dispose.security.arithmetic.CryptoHelper;
|
|
||||||
import com.fasterxml.jackson.databind.ObjectMapper;
|
import com.fasterxml.jackson.databind.ObjectMapper;
|
||||||
import com.huawei.dispose.common.HuaWeiLoginResp;
|
import com.huawei.dispose.common.HuaWeiLoginResp;
|
||||||
import com.huawei.dispose.protocol.HuaWeiInterface;
|
import com.huawei.dispose.protocol.HuaWeiInterface;
|
||||||
|
@ -86,7 +85,7 @@ public class HuaWeiAbilityImpl implements DisposeAbility {
|
||||||
public void initDeviceEnv(String urlPath, String username, String password) {
|
public void initDeviceEnv(String urlPath, String username, String password) {
|
||||||
this.urlRootPath = urlPath;
|
this.urlRootPath = urlPath;
|
||||||
this.username = username;
|
this.username = username;
|
||||||
this.password = new String(CryptoHelper.base64Decryption(password));
|
this.password = password;
|
||||||
|
|
||||||
upgradeToken();
|
upgradeToken();
|
||||||
}
|
}
|
||||||
|
|
|
@ -85,7 +85,7 @@ public class HuaWeiFireWallAbilityImpl implements DisposeAbility {
|
||||||
public void initDeviceEnv(String urlPath, String username, String password) {
|
public void initDeviceEnv(String urlPath, String username, String password) {
|
||||||
this.urlRootPath = urlPath;
|
this.urlRootPath = urlPath;
|
||||||
this.username = username;
|
this.username = username;
|
||||||
this.password = new String(CryptoHelper.base64Decryption(password));
|
this.password = password;
|
||||||
|
|
||||||
upgradeToken();
|
upgradeToken();
|
||||||
}
|
}
|
||||||
|
|
|
@ -12,7 +12,6 @@ import com.dispose.pojo.dto.protocol.base.ProtocolRespDTO;
|
||||||
import com.dispose.pojo.entity.ServiceInfo;
|
import com.dispose.pojo.entity.ServiceInfo;
|
||||||
import com.dispose.pojo.po.MulReturnType;
|
import com.dispose.pojo.po.MulReturnType;
|
||||||
import com.dispose.pojo.vo.DeviceFirewareInfo;
|
import com.dispose.pojo.vo.DeviceFirewareInfo;
|
||||||
import com.dispose.security.arithmetic.CryptoHelper;
|
|
||||||
import com.pengxin.dispose.common.PengXinDisposeAbilityRsp;
|
import com.pengxin.dispose.common.PengXinDisposeAbilityRsp;
|
||||||
import com.pengxin.dispose.common.PengXinLoginRsp;
|
import com.pengxin.dispose.common.PengXinLoginRsp;
|
||||||
import com.pengxin.dispose.common.PengXinStartTaskItem;
|
import com.pengxin.dispose.common.PengXinStartTaskItem;
|
||||||
|
@ -128,7 +127,7 @@ public class PengXinAbilityImpl implements DisposeAbility {
|
||||||
public void initDeviceEnv(String urlPath, String username, String password) {
|
public void initDeviceEnv(String urlPath, String username, String password) {
|
||||||
this.urlRootPath = urlPath;
|
this.urlRootPath = urlPath;
|
||||||
this.username = username;
|
this.username = username;
|
||||||
this.password = new String(CryptoHelper.base64Decryption(password));
|
this.password = password;
|
||||||
restfulInterface.setParams(1, 0);
|
restfulInterface.setParams(1, 0);
|
||||||
|
|
||||||
upgradeToken();
|
upgradeToken();
|
||||||
|
|
|
@ -8,7 +8,6 @@ import com.dispose.pojo.dto.protocol.base.ProtocolRespDTO;
|
||||||
import com.dispose.pojo.entity.ServiceInfo;
|
import com.dispose.pojo.entity.ServiceInfo;
|
||||||
import com.dispose.pojo.po.MulReturnType;
|
import com.dispose.pojo.po.MulReturnType;
|
||||||
import com.dispose.pojo.vo.DeviceFirewareInfo;
|
import com.dispose.pojo.vo.DeviceFirewareInfo;
|
||||||
import com.dispose.security.arithmetic.CryptoHelper;
|
|
||||||
import com.pengxin.dispose.common.PengXinStartTaskItem;
|
import com.pengxin.dispose.common.PengXinStartTaskItem;
|
||||||
import com.pengxin.dispose.common.PengXinStartTaskRsp;
|
import com.pengxin.dispose.common.PengXinStartTaskRsp;
|
||||||
import com.pengxin.dispose.common.PengXinStopTaskRsp;
|
import com.pengxin.dispose.common.PengXinStopTaskRsp;
|
||||||
|
@ -103,7 +102,7 @@ public class UpfAbilityImpl extends PengXinAbilityImpl {
|
||||||
public void initDeviceEnv(String urlPath, String username, String password) {
|
public void initDeviceEnv(String urlPath, String username, String password) {
|
||||||
this.urlRootPath = urlPath;
|
this.urlRootPath = urlPath;
|
||||||
this.username = username;
|
this.username = username;
|
||||||
this.password = new String(CryptoHelper.base64Decryption(password));
|
this.password = password;
|
||||||
restfulInterface.setParams(1, 0);
|
restfulInterface.setParams(1, 0);
|
||||||
//获取token值
|
//获取token值
|
||||||
upgradeToken();
|
upgradeToken();
|
||||||
|
|
|
@ -57,7 +57,7 @@ public class DisposeDeviceManagerImpl implements DisposeDeviceManager {
|
||||||
@Override
|
@Override
|
||||||
public MulReturnType<ErrorCode, Long> addDisposeDevice(DisposeDevice dev) {
|
public MulReturnType<ErrorCode, Long> addDisposeDevice(DisposeDevice dev) {
|
||||||
List<DisposeDevice> tmpDev = disposeDeviceMapper.getDeviceByIpAndType(dev.getIpAddr(),
|
List<DisposeDevice> tmpDev = disposeDeviceMapper.getDeviceByIpAndType(dev.getIpAddr(),
|
||||||
dev.getDeviceType().getValue());
|
dev.getDeviceType().getValue());
|
||||||
|
|
||||||
for (DisposeDevice v : tmpDev) {
|
for (DisposeDevice v : tmpDev) {
|
||||||
if (dev.getIpPort().equals(HttpType.getDefaultPort(v.getUrlType())) || dev.getIpPort()
|
if (dev.getIpPort().equals(HttpType.getDefaultPort(v.getUrlType())) || dev.getIpPort()
|
||||||
|
@ -112,7 +112,7 @@ public class DisposeDeviceManagerImpl implements DisposeDeviceManager {
|
||||||
fdDest.setAccessible(true);
|
fdDest.setAccessible(true);
|
||||||
if (!obj.equals(fdDest.get(destDev))) {
|
if (!obj.equals(fdDest.get(destDev))) {
|
||||||
log.debug("Upgrade field [{}] value form [{}] to [{}]", fdSrc.getName(), fdDest.get(destDev),
|
log.debug("Upgrade field [{}] value form [{}] to [{}]", fdSrc.getName(), fdDest.get(destDev),
|
||||||
obj);
|
obj);
|
||||||
fdDest.set(destDev, obj);
|
fdDest.set(destDev, obj);
|
||||||
}
|
}
|
||||||
fdDest.setAccessible(false);
|
fdDest.setAccessible(false);
|
||||||
|
@ -135,7 +135,7 @@ public class DisposeDeviceManagerImpl implements DisposeDeviceManager {
|
||||||
DisposeDevice tDev = null;
|
DisposeDevice tDev = null;
|
||||||
// 根据Ip和设备类型获取设备
|
// 根据Ip和设备类型获取设备
|
||||||
List<DisposeDevice> devList = disposeDeviceMapper.getDeviceByIpAndType(dev.getIpAddr(),
|
List<DisposeDevice> devList = disposeDeviceMapper.getDeviceByIpAndType(dev.getIpAddr(),
|
||||||
dev.getDeviceType().getValue());
|
dev.getDeviceType().getValue());
|
||||||
|
|
||||||
if (devList == null || devList.size() == 0) {
|
if (devList == null || devList.size() == 0) {
|
||||||
return new MulReturnType<>(ErrorCode.ERR_NOSUCHDEVICE, -1L);
|
return new MulReturnType<>(ErrorCode.ERR_NOSUCHDEVICE, -1L);
|
||||||
|
|
|
@ -17,6 +17,7 @@ import com.dispose.manager.DisposeDeviceManager;
|
||||||
import com.dispose.mapper.ServiceGroupMapper;
|
import com.dispose.mapper.ServiceGroupMapper;
|
||||||
import com.dispose.pojo.entity.DisposeDevice;
|
import com.dispose.pojo.entity.DisposeDevice;
|
||||||
import com.dispose.pojo.po.AbilityInfo;
|
import com.dispose.pojo.po.AbilityInfo;
|
||||||
|
import com.dispose.security.arithmetic.CryptoHelper;
|
||||||
import com.dispose.service.DisposeAbilityRouterService;
|
import com.dispose.service.DisposeAbilityRouterService;
|
||||||
import lombok.extern.slf4j.Slf4j;
|
import lombok.extern.slf4j.Slf4j;
|
||||||
import org.springframework.scheduling.annotation.Async;
|
import org.springframework.scheduling.annotation.Async;
|
||||||
|
@ -182,6 +183,7 @@ public class DisposeAbilityRouterServiceImpl implements DisposeAbilityRouterServ
|
||||||
}
|
}
|
||||||
|
|
||||||
// 初始化设备
|
// 初始化设备
|
||||||
|
dev.setPassword(new String(CryptoHelper.base64Decryption(dev.getPassword())));
|
||||||
db.initDeviceEnv(url, dev.getUserName(), dev.getPassword());
|
db.initDeviceEnv(url, dev.getUserName(), dev.getPassword());
|
||||||
db.getDisposeDeviceProtectObject();
|
db.getDisposeDeviceProtectObject();
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue