Commit 8da9ffec authored by jinliang's avatar jinliang

remove unnecessary delete logic

parent 40fc1409
...@@ -468,8 +468,8 @@ public class IpResourceServiceImpl implements IpResourceService { ...@@ -468,8 +468,8 @@ public class IpResourceServiceImpl implements IpResourceService {
public IpOperationResultDto deleteExpiredIp(String username, IpResourceRequestDto ipResourceRequestDto) { public IpOperationResultDto deleteExpiredIp(String username, IpResourceRequestDto ipResourceRequestDto) {
Account account = accountRepository.findByName(username).orElseThrow(() -> new ClientRequestException(AccountErrorCode.NAMENOTEXIST)); Account account = accountRepository.findByName(username).orElseThrow(() -> new ClientRequestException(AccountErrorCode.NAMENOTEXIST));
String URL = (profiles.equals("dev") || profiles.equals("staging")) ? TESTURL : CLOUDAMURL; //String URL = (profiles.equals("dev") || profiles.equals("staging")) ? TESTURL : CLOUDAMURL;
RestTemplate restTemplate = new RestTemplate(); //RestTemplate restTemplate = new RestTemplate();
HttpHeaders headers = buildGetHeader(); HttpHeaders headers = buildGetHeader();
Map<String, String> params = new HashMap<String, String>(); Map<String, String> params = new HashMap<String, String>();
HttpEntity<Map<String, String>> httpEntity = new HttpEntity<>(params, headers); HttpEntity<Map<String, String>> httpEntity = new HttpEntity<>(params, headers);
...@@ -487,8 +487,9 @@ public class IpResourceServiceImpl implements IpResourceService { ...@@ -487,8 +487,9 @@ public class IpResourceServiceImpl implements IpResourceService {
return; return;
} }
try { // 现在全部都是包月的机器,然后也没有给用户保留7天,所以不需要再执行这个删除逻辑了
/* try {
// 调用 uri删除远程的 IP资源 // 调用 uri删除远程的 IP资源
ResponseEntity<String> result = restTemplate.exchange(URL + "/intelligroup/ipresources?accountId=browser&ip={ip}", HttpMethod.DELETE, httpEntity, String.class, ipAddr); ResponseEntity<String> result = restTemplate.exchange(URL + "/intelligroup/ipresources?accountId=browser&ip={ip}", HttpMethod.DELETE, httpEntity, String.class, ipAddr);
DeleteIpResultDto deleteIpResultDto = JSON.parseObject(result.getBody(), DeleteIpResultDto.class); DeleteIpResultDto deleteIpResultDto = JSON.parseObject(result.getBody(), DeleteIpResultDto.class);
...@@ -501,7 +502,7 @@ public class IpResourceServiceImpl implements IpResourceService { ...@@ -501,7 +502,7 @@ public class IpResourceServiceImpl implements IpResourceService {
} catch (Exception e) { } catch (Exception e) {
logger.error("fail to delete ip", e); logger.error("fail to delete ip", e);
ipOperationResultDto.getFailList().add(ipAddr); ipOperationResultDto.getFailList().add(ipAddr);
} } */
try { try {
// ip资源为未绑定,则直接删除 // ip资源为未绑定,则直接删除
...@@ -534,7 +535,8 @@ public class IpResourceServiceImpl implements IpResourceService { ...@@ -534,7 +535,8 @@ public class IpResourceServiceImpl implements IpResourceService {
if (ipResource.getStatus() == 6) { if (ipResource.getStatus() == 6) {
ipResourceRepository.delete(ipResource); ipResourceRepository.delete(ipResource);
} else if (StringUtils.isNotBlank(ipResource.getAddr()) && ipResource.getIpType() == IpType.VENDOR) { } else if (StringUtils.isNotBlank(ipResource.getAddr()) && ipResource.getIpType() == IpType.VENDOR) {
try { // 现在全部都是包月的机器,然后也没有给用户保留7天,所以不需要再执行这个删除逻辑了
/* try {
ResponseEntity<String> result = restTemplate.exchange(URL + "/intelligroup/ipresources?accountId=browser&ip={ip}", ResponseEntity<String> result = restTemplate.exchange(URL + "/intelligroup/ipresources?accountId=browser&ip={ip}",
HttpMethod.DELETE, httpEntity, String.class, ipResource.getAddr()); HttpMethod.DELETE, httpEntity, String.class, ipResource.getAddr());
DeleteIpResultDto deleteIpResultDto = JSON.parseObject(result.getBody(), DeleteIpResultDto.class); DeleteIpResultDto deleteIpResultDto = JSON.parseObject(result.getBody(), DeleteIpResultDto.class);
...@@ -544,10 +546,9 @@ public class IpResourceServiceImpl implements IpResourceService { ...@@ -544,10 +546,9 @@ public class IpResourceServiceImpl implements IpResourceService {
} }
} catch (Exception t) { } catch (Exception t) {
logger.error("ip " + ipResource.getAddr() + " 删除失败", t); logger.error("ip " + ipResource.getAddr() + " 删除失败", t);
} } */
} }
ipResource.setDeleted(true); ipResource.setDeleted(true);
ipResource.setShopIds(null); ipResource.setShopIds(null);
ipResourceRepository.save(ipResource); ipResourceRepository.save(ipResource);
...@@ -736,14 +737,14 @@ public class IpResourceServiceImpl implements IpResourceService { ...@@ -736,14 +737,14 @@ public class IpResourceServiceImpl implements IpResourceService {
if (x.getLockTimestamp() >= Instant.now().minusSeconds(1 * 60).toEpochMilli() && x.getIpType() == IpType.VENDOR && (x.getStatus() == 0 || x.getStatus() == 2)) { if (x.getLockTimestamp() >= Instant.now().minusSeconds(1 * 60).toEpochMilli() && x.getIpType() == IpType.VENDOR && (x.getStatus() == 0 || x.getStatus() == 2)) {
x.setStatus(3); x.setStatus(3);
// 1.2 ip资源在未来天内到期,且 ip 资源的状态不是 3(正在分配)、5(已失效)、6(未分配),则将 ip 资源设置为 2(即将过期) // 1.2 ip资源在未来3天内到期,且 ip 资源的状态不是 3(正在分配)、5(已失效)、6(未分配),则将 ip 资源设置为 2(即将过期)
} else if (x.getValidTime() <= Instant.now().plusSeconds(60 * 60 * 24 * 7).toEpochMilli() && x.getValidTime() > Instant.now().toEpochMilli()) { } else if (x.getValidTime() <= Instant.now().plusSeconds(60 * 60 * 24 * 3).toEpochMilli() && x.getValidTime() > Instant.now().toEpochMilli()) {
if (x.getStatus() != 5 && x.getStatus() != 3 && x.getStatus() != 6 && x.getStatus() != 9 ) { if (x.getStatus() != 5 && x.getStatus() != 3 && x.getStatus() != 6 && x.getStatus() != 9 ) {
ipResourceRepository.updateStatus(x.getId(), 2); ipResourceRepository.updateStatus(x.getId(), 2);
} }
// 1.3 ip资源在天前到期,且 ip 资源的状态不是 3(正在分配)、6(未分配),则删除 ip 资源 // 1.3 ip资源在1天前到期,且 ip 资源的状态不是 3(正在分配)、6(未分配),则删除 ip 资源
} else if (x.getValidTime() <= Instant.now().minusSeconds(60 * 60 * 24 * 7).toEpochMilli() && x.getStatus() != 3 && x.getStatus() != 6 && x.getStatus() != 9) { } else if (x.getValidTime() <= Instant.now().minusSeconds(60 * 60 * 24).toEpochMilli() && x.getStatus() != 3 && x.getStatus() != 6 && x.getStatus() != 9) {
if (x.getIpType() == IpType.VENDOR) { if (x.getIpType() == IpType.VENDOR) {
IpResourceRequestDto ipResourceRequestDto = new IpResourceRequestDto(); IpResourceRequestDto ipResourceRequestDto = new IpResourceRequestDto();
ipResourceRequestDto.setAddr(Arrays.asList(x.getAddr())); ipResourceRequestDto.setAddr(Arrays.asList(x.getAddr()));
...@@ -919,7 +920,7 @@ public class IpResourceServiceImpl implements IpResourceService { ...@@ -919,7 +920,7 @@ public class IpResourceServiceImpl implements IpResourceService {
if (StringUtils.isNotBlank(ipResource.getAddr())) { if (StringUtils.isNotBlank(ipResource.getAddr())) {
if (ipResource.getValidTime() <= Instant.now().plusSeconds(60 * 60 * 24 * 7).toEpochMilli() && ipResource.getValidTime() > Instant.now().toEpochMilli()) { if (ipResource.getValidTime() <= Instant.now().plusSeconds(60 * 60 * 24 * 7).toEpochMilli() && ipResource.getValidTime() > Instant.now().toEpochMilli()) {
ipResourceRepository.updateStatus(ipResource.getId(), 2); ipResourceRepository.updateStatus(ipResource.getId(), 2);
} else if (ipResource.getValidTime() <= Instant.now().minusSeconds(60 * 60 * 24 * 7).toEpochMilli()) { } else if (ipResource.getValidTime() <= Instant.now().minusSeconds(60 * 60 * 24).toEpochMilli()) {
deleteExpiredIp(username, ipResourceRequestDto); deleteExpiredIp(username, ipResourceRequestDto);
} else if (ipResource.getValidTime() <= Instant.now().toEpochMilli()) { } else if (ipResource.getValidTime() <= Instant.now().toEpochMilli()) {
ipResourceRepository.updateStatus(ipResource.getId(), 1); ipResourceRepository.updateStatus(ipResource.getId(), 1);
......
...@@ -591,16 +591,16 @@ public class ShopServiceImpl implements ShopService { ...@@ -591,16 +591,16 @@ public class ShopServiceImpl implements ShopService {
IpResource ipResource = ipResourceRepository.findFirstByShopIdsIsAndIsDeleted(x.getShopId(), false); IpResource ipResource = ipResourceRepository.findFirstByShopIdsIsAndIsDeleted(x.getShopId(), false);
// 如果 ip资源非空 且 addr 也非空 // 如果 ip资源非空 且 addr 也非空
if (ipResource != null && !StringUtils.isEmpty(ipResource.getAddr())) { if (ipResource != null && !StringUtils.isEmpty(ipResource.getAddr())) {
// 1. ip资源在未来天内到期 且 ip 资源的状态不是 3(正在分配)、5(已失效)、6(未分配),则将 ip 资源设置为 2(即将过期) // 1. ip资源在未来3天内到期 且 ip 资源的状态不是 3(正在分配)、5(已失效)、6(未分配),则将 ip 资源设置为 2(即将过期)
if (ipResource.getValidTime() <= Instant.now().plusSeconds(60 * 60 * 24 * 7).toEpochMilli() && ipResource.getValidTime() > Instant.now().toEpochMilli()) { if (ipResource.getValidTime() <= Instant.now().plusSeconds(60 * 60 * 24 * 3).toEpochMilli() && ipResource.getValidTime() > Instant.now().toEpochMilli()) {
if (ipResource.getStatus() != 5 && ipResource.getStatus() != 3 && ipResource.getStatus() != 6 && ipResource.getStatus() != 9) { if (ipResource.getStatus() != 5 && ipResource.getStatus() != 3 && ipResource.getStatus() != 6 && ipResource.getStatus() != 9) {
ipResource.setStatus(2); ipResource.setStatus(2);
//ipResourceRepository.save(ipResource); //ipResourceRepository.save(ipResource);
pageIpResourceListToSave.add(ipResource); pageIpResourceListToSave.add(ipResource);
} }
// 2. ip资源在天前到期,且 ip 资源的状态不是 3(正在分配)、6(未分配),则删除 ip 资源 // 2. ip资源在1天前到期,且 ip 资源的状态不是 3(正在分配)、6(未分配),则删除 ip 资源
} else if (ipResource.getValidTime() <= Instant.now().minusSeconds(60 * 60 * 24 * 7).toEpochMilli() && ipResource.getStatus() != 3 && ipResource.getStatus() != 6 && ipResource.getStatus() != 9) { } else if (ipResource.getValidTime() <= Instant.now().minusSeconds(60 * 60 * 24).toEpochMilli() && ipResource.getStatus() != 3 && ipResource.getStatus() != 6 && ipResource.getStatus() != 9) {
IpResourceRequestDto ipResourceRequestDto1 = new IpResourceRequestDto(); IpResourceRequestDto ipResourceRequestDto1 = new IpResourceRequestDto();
if (ipResource.getIpType() == IpType.VENDOR) { if (ipResource.getIpType() == IpType.VENDOR) {
ipResourceRequestDto1.setAddr(Arrays.asList(ipResource.getAddr())); ipResourceRequestDto1.setAddr(Arrays.asList(ipResource.getAddr()));
......
...@@ -1120,7 +1120,7 @@ public class BrowserTask { ...@@ -1120,7 +1120,7 @@ public class BrowserTask {
String logs = "【deleteOverdueIps】 "; String logs = "【deleteOverdueIps】 ";
List<IpResource> list = ipResourceRepository List<IpResource> list = ipResourceRepository
.findByValidTimeLessThanAndIsDeleted( .findByValidTimeLessThanAndIsDeleted(
Instant.now().minusSeconds(60 * 60 * 24 * 7).toEpochMilli(), false); Instant.now().minusSeconds(60 * 60 * 24 * 3).toEpochMilli(), false);
log.error("Scheduled {}, list size : {}", logs, list.size()); log.error("Scheduled {}, list size : {}", logs, list.size());
list.forEach(this::deleteOverdueIp); list.forEach(this::deleteOverdueIp);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment