购买失败删除

src/main/java/com/edgec/browserbackend/browser/service/Impl/IpResourceServiceImpl.java

@@ -246,6 +246,9 @@ public class IpResourceServiceImpl implements IpResourceService {
                 if (StringUtils.isNotBlank(ipBuyResultDto.getErrorCode())) {
                     IpChargeRequestDto ipChargeRequestDto = buildIpChargeRequestDto(ipResourceRequestDto, 1);
                     accountService.chargeByMoney(username, -newprice*ipChargeRequestDto.getAmount(), ipChargeRequestDto);
+                    for (IpResourceDto ipResourceDto:ipResourceDtos) {
+                        ipResourceRepository.deleteById(ipResourceDto.getId());
+                    }
                     logger.error("fail to buy ip");
                     logger.error(ipBuyResultDto.getErrorCode());
                 }
@@ -266,6 +269,12 @@ public class IpResourceServiceImpl implements IpResourceService {
                     if (ipBuyResultDto.getIplist().size() < ipResourceDtos.size()) {
                         IpChargeRequestDto ipChargeRequestDto = buildIpChargeRequestDto(ipResourceRequestDto, 1);
                         accountService.chargeByMoney(username, -newprice*(ipResourceDtos.size() - ipBuyResultDto.getIplist().size()), ipChargeRequestDto);
+                        for (IpResourceDto ipResourceDto : ipResourceDtos) {
+                            IpResource ipResource = ipResourceRepository.findById(ipResourceDto.getId()).orElse(null);
+                            if (ipResource != null && StringUtils.isBlank(ipResource.getAddr())) {
+                                ipResourceRepository.deleteById(ipResource.getId());
+                            }
+                        }
                     }
                 }
                 ipTransaction.setStatus(1);