Переглянути джерело

Revert "缓存"

This reverts commit ec06bf04
wangqifan 2 роки тому
батько
коміт
e18cd97b51
1 змінених файлів з 15 додано та 71 видалено
  1. 15 71
      src/main/java/com/izouma/nineth/service/AssetService.java

+ 15 - 71
src/main/java/com/izouma/nineth/service/AssetService.java

@@ -53,9 +53,6 @@ import java.util.concurrent.atomic.AtomicInteger;
 import java.util.regex.Matcher;
 import java.util.regex.Pattern;
 import java.util.stream.Collectors;
-import java.util.stream.Stream;
-
-import static java.util.stream.Collectors.toList;
 
 @Service
 @AllArgsConstructor
@@ -129,7 +126,7 @@ public class AssetService {
         List<Asset> blindBoxClosedAssets = assets.stream()
                                                  .filter(asset -> !asset.isOpened() && CollectionType.BLIND_BOX
                                                          .equals(asset.getType()))
-                                                 .collect(toList());
+                                                 .collect(Collectors.toList());
         if (CollectionUtils.isNotEmpty(blindBoxClosedAssets)) {
             blindBoxClosedAssets.forEach(asset -> {
                 assetDTOs.add(AssetDTO.create(Lists.newArrayList(asset)));
@@ -140,7 +137,7 @@ public class AssetService {
         // 取出资产中所有未设置prefixName的值
         List<Asset> prefixNameIsNullAssets = assets.stream()
                                                    .filter(asset -> StringUtils.isBlank(asset.getPrefixName()))
-                                                   .collect(toList());
+                                                   .collect(Collectors.toList());
         if (CollectionUtils.isNotEmpty(prefixNameIsNullAssets)) {
             prefixNameIsNullAssets.forEach(asset -> {
                 assetDTOs.add(AssetDTO.create(Lists.newArrayList(asset)));
@@ -152,12 +149,12 @@ public class AssetService {
             List<String> prefixNames = assets.stream()
                                              .map(Asset::getPrefixName)
                                              .distinct()
-                                             .collect(toList());
+                                             .collect(Collectors.toList());
             // 将资产中相同prefixName归类(除未开启盲盒和未设置prefixName)
             prefixNames.forEach(str -> {
                 List<Asset> collect = assets.stream()
                                             .filter(asset -> str.equals(asset.getPrefixName()))
-                                            .collect(toList());
+                                            .collect(Collectors.toList());
                 assetDTOs.add(AssetDTO.create(collect));
             });
         }
@@ -374,7 +371,7 @@ public class AssetService {
             numberSeq.setNumbers(map.entrySet().stream()
                                     .sorted(Map.Entry.comparingByValue())
                                     .map(Map.Entry::getKey)
-                                    .collect(toList()));
+                                    .collect(Collectors.toList()));
             numberSeqRepo.save(numberSeq);
         }
         return numberSeq.getNumbers().get(number);
@@ -733,32 +730,7 @@ public class AssetService {
                               collectionRepo.save(collection);
                           });
         }
-
-        Stream<DomainOrder> allDomainOrders = domainOrderRepo.findAll().stream();
-        List<DomainOrder> filteredDomainOrders = allDomainOrders
-                .filter(domainOrder -> domainOrder.getHyperLinkType() == HyperLinkType.COLLECTION)
-                .collect(toList());
-        for (DomainOrder filteredDomainOrder : filteredDomainOrders) {
-            String url = filteredDomainOrder.getAddress();
-            int secondSlashIndex = url.indexOf('/', url.indexOf('/') + 1);
-            if (url.length() > secondSlashIndex + 1) {
-                String secondNumber = url.substring(secondSlashIndex + 1);
-                if (!secondNumber.isEmpty()) {
-                    if (asset.getPublicCollectionId() != null && asset.getPublicCollectionId().equals(Long.parseLong(secondNumber))) {
-                        filteredDomainOrder.setOpenHyperLink(false);
-                        filteredDomainOrder.setHyperLinkType(null);
-                        filteredDomainOrder.setAddress(null);
-                        filteredDomainOrder.setCurrentOwnerId(null);
-                        domainOrderRepo.save(filteredDomainOrder);
-                    }
-                }
-            }
-        }
-
-
         asset.setConsignment(false);
-
-
         assetRepo.saveAndFlush(asset);
     }
 
@@ -786,35 +758,8 @@ public class AssetService {
         // 如果展厅有此藏品
         showCollectionRepo.deleteAllByCollectionId(asset.getPublicCollectionId());
 
-
-        Stream<DomainOrder> allDomainOrders = domainOrderRepo.findAll().stream();
-        List<DomainOrder> filteredDomainOrders = allDomainOrders
-                .filter(domainOrder -> domainOrder.getHyperLinkType() == HyperLinkType.COLLECTION)
-                .collect(toList());
-        for (DomainOrder filteredDomainOrder : filteredDomainOrders) {
-            String url = filteredDomainOrder.getAddress();
-            int secondSlashIndex = url.indexOf('/', url.indexOf('/') + 1);
-            if (url.length() > secondSlashIndex + 1) {
-                String secondNumber = url.substring(secondSlashIndex + 1);
-                if (!secondNumber.isBlank()) {
-                    if (asset.getPublicCollectionId() != null && asset.getPublicCollectionId().equals(Long.parseLong(secondNumber))) {
-                        filteredDomainOrder.setOpenHyperLink(false);
-                        filteredDomainOrder.setHyperLinkType(null);
-                        filteredDomainOrder.setAddress(null);
-                        filteredDomainOrder.setCurrentOwnerId(null);
-                        domainOrderRepo.save(filteredDomainOrder);
-                    }
-                }
-            }
-        }
-
-
         asset.setPublicShow(false);
         asset.setPublicCollectionId(null);
-
-
-
-
         assetRepo.saveAndFlush(asset);
     }
 
@@ -849,16 +794,15 @@ public class AssetService {
         Objects.requireNonNull(toUser, "转让人不能为空");
         Objects.requireNonNull(reason, "转让原因不能为空");
 
-//        if (asset.getType() == CollectionType.DOMAIN) {
-//            DomainOrder domainOrder = domainOrderRepo.findByAssetCollectionId(asset.getCollectionId());
-//            if (ObjectUtils.isNotEmpty(domainOrder)) {
-//                domainOrder.setOpenHyperLink(false);
-//                domainOrder.setHyperLinkType(null);
-//                domainOrder.setAddress(null);
-//                domainOrder.setCurrentOwnerId(null);
-//
-//            }
-//        }
+        if (asset.getType() == CollectionType.DOMAIN) {
+            Optional<DomainOrder> domainOrder = domainOrderRepo.findById(asset.getCollectionId());
+            domainOrder.ifPresent(domainOrder1 -> {
+                domainOrder1.setOpenHyperLink(false);
+                domainOrder1.setHyperLinkType(null);
+                domainOrder1.setAddress(null);
+                domainOrder1.setCurrentOwnerId(null);
+            });
+        }
 
 
         User newOwner = toUser;
@@ -1375,7 +1319,7 @@ public class AssetService {
         String discountCollection = sysConfigService.getString("domain_discount");
         JSONObject json = JSONObject.parseObject(discountCollection);
         Set<String> keys = json.keySet();
-        List<Long> collectionIds = keys.stream().map(Long::parseLong).collect(toList());
+        List<Long> collectionIds = keys.stream().map(Long::parseLong).collect(Collectors.toList());
         Set<Long> holdCollections = assetRepo.findDiscounts(userId, collectionIds);
         double result = sysConfigService.getBigDecimal("domain_service_charge").doubleValue();
         if (holdCollections.size() > 0) {