Commit 97673e0b authored by huangjiamin's avatar huangjiamin

七天过期清除改为三天过期清除

parent a2eea814
...@@ -675,14 +675,14 @@ public class IpResourceServiceImpl implements IpResourceService { ...@@ -675,14 +675,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) { if (x.getStatus() != 5 && x.getStatus() != 3 && x.getStatus() != 6) {
ipResourceRepository.updateStatus(x.getId(), 2); ipResourceRepository.updateStatus(x.getId(), 2);
} }
// 1.3 ip资源在天前到期,且 ip 资源的状态不是 3(正在分配)、6(未分配),则删除 ip 资源 // 1.3 ip资源在3天前到期,且 ip 资源的状态不是 3(正在分配)、6(未分配),则删除 ip 资源
} else if (x.getValidTime() <= Instant.now().minusSeconds(60 * 60 * 24 * 7).toEpochMilli() && x.getStatus() != 3 && x.getStatus() != 6) { } else if (x.getValidTime() <= Instant.now().minusSeconds(60 * 60 * 24 * 3).toEpochMilli() && x.getStatus() != 3 && x.getStatus() != 6) {
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()));
...@@ -856,9 +856,9 @@ public class IpResourceServiceImpl implements IpResourceService { ...@@ -856,9 +856,9 @@ 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 * 3).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 * 3).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);
......
...@@ -577,16 +577,16 @@ public class ShopServiceImpl implements ShopService { ...@@ -577,16 +577,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) { if (ipResource.getStatus() != 5 && ipResource.getStatus() != 3 && ipResource.getStatus() != 6) {
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资源在3天前到期,且 ip 资源的状态不是 3(正在分配)、6(未分配),则删除 ip 资源
} else if (ipResource.getValidTime() <= Instant.now().minusSeconds(60 * 60 * 24 * 7).toEpochMilli() && ipResource.getStatus() != 3 && ipResource.getStatus() != 6) { } else if (ipResource.getValidTime() <= Instant.now().minusSeconds(60 * 60 * 24 * 3).toEpochMilli() && ipResource.getStatus() != 3 && ipResource.getStatus() != 6) {
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()));
......
...@@ -347,11 +347,11 @@ public class BrowserTask { ...@@ -347,11 +347,11 @@ public class BrowserTask {
* 每天凌晨1点查询 {@code validTime}早于7天前,并且未被删除的ip。 * 每天凌晨1点查询 {@code validTime}早于7天前,并且未被删除的ip。
* 调用{@code deleteOverdueIp}删除IP资源 * 调用{@code deleteOverdueIp}删除IP资源
*/ */
@Scheduled(cron = "0 0/1 * * * ?") @Scheduled(cron = "0 0 * * * ? *")
public void deleteOverdueIps() { public void deleteOverdueIps() {
String logs = "【deleteOverdueIps】 "; String logs = "【deleteOverdueIps】 ";
List<IpResource> list = ipResourceRepository List<IpResource> list = ipResourceRepository
.findByValidTimeLessThanAndIsDeleted(Instant.now().minusSeconds(60 * 60 * 24 * 7).toEpochMilli(), false); .findByValidTimeLessThanAndIsDeleted(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