diff --git a/src/main/java/com/dispose/ability/impl/DpTechBypassAbilityImpl.java b/src/main/java/com/dispose/ability/impl/DpTechBypassAbilityImpl.java index ae64b203..a3b85483 100644 --- a/src/main/java/com/dispose/ability/impl/DpTechBypassAbilityImpl.java +++ b/src/main/java/com/dispose/ability/impl/DpTechBypassAbilityImpl.java @@ -347,6 +347,12 @@ public class DpTechBypassAbilityImpl extends DpTechAbilityImpl { return ErrorCode.ERR_CALLDEVICE; } + // 更新缓存状态 + if (dpBypassManager.getTractionStrategyName().containsKey(policyName)) { + DpTractionStrategy ts = dpBypassManager.getTractionStrategyName().get(policyName); + ts.setRunning(false); + } + return ErrorCode.ERR_OK; } @@ -373,6 +379,8 @@ public class DpTechBypassAbilityImpl extends DpTechAbilityImpl { if (ret.getResultRetVal() == 0) { log.debug("Remove Traction Strategy {} Succeed", tractionName); + //移除缓存信息 + dpBypassManager.getTractionStrategyName().remove(tractionName); return ErrorCode.ERR_OK; } else { log.error("!!!!Remove Traction Strategy {} Error: {}", tractionName, @@ -934,12 +942,6 @@ public class DpTechBypassAbilityImpl extends DpTechAbilityImpl { String policyName = getTractionStrategyName(disposeObject); - // 更新缓存状态 - if (dpBypassManager.getTractionStrategyName().containsKey(policyName)) { - DpTractionStrategy ts = dpBypassManager.getTractionStrategyName().get(policyName); - ts.setRunning(false); - } - err = removeTractionStrategy(policyName); if (err != ErrorCode.ERR_OK) { @@ -948,10 +950,6 @@ public class DpTechBypassAbilityImpl extends DpTechAbilityImpl { } } - //移除缓存信息 - String policyName = getTractionStrategyName(disposeObject); - dpBypassManager.getTractionStrategyName().remove(policyName); - log.info("----Finish DPTech Stop Cleanup Task Succeed: {}", disposeObject); return new MulReturnType<>(ErrorCode.ERR_OK, null); } catch (Exception ex) {