From 92a4c3c35747bf1a043c2ff85650012d4eac9355 Mon Sep 17 00:00:00 2001
From: cloudroam <cloudroam>
Date: 星期二, 10 九月 2024 10:48:47 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master'
---
src/main/java/com/mzl/flower/service/flower/FlowerService.java | 145 +++++++++++++++++++++++++++++++++++++++++++++++-
1 files changed, 141 insertions(+), 4 deletions(-)
diff --git a/src/main/java/com/mzl/flower/service/flower/FlowerService.java b/src/main/java/com/mzl/flower/service/flower/FlowerService.java
index 6e4038e..73ab692 100644
--- a/src/main/java/com/mzl/flower/service/flower/FlowerService.java
+++ b/src/main/java/com/mzl/flower/service/flower/FlowerService.java
@@ -6,8 +6,8 @@
import com.mzl.flower.config.security.SecurityUtils;
import com.mzl.flower.constant.Constants;
import com.mzl.flower.dto.request.flower.*;
-import com.mzl.flower.dto.request.flower.FlowerTagMultipleDTO;
import com.mzl.flower.dto.response.flower.*;
+import com.mzl.flower.entity.FlowerDeleteDO;
import com.mzl.flower.entity.customer.Collect;
import com.mzl.flower.entity.customer.Customer;
import com.mzl.flower.entity.flower.*;
@@ -25,6 +25,7 @@
import com.mzl.flower.mapper.supplier.SupplierTypeMapper;
import com.mzl.flower.service.BaseService;
import com.mzl.flower.service.customer.BrowseService;
+import com.mzl.flower.service.payment.RedisLockService;
import io.micrometer.core.instrument.util.StringUtils;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.BeanUtils;
@@ -32,14 +33,15 @@
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
+import org.springframework.util.CollectionUtils;
import java.math.BigDecimal;
import java.math.RoundingMode;
import java.time.LocalDate;
import java.time.LocalDateTime;
-import java.util.ArrayList;
-import java.util.List;
-import java.util.Map;
+import java.util.*;
+import java.util.concurrent.atomic.AtomicInteger;
+import java.util.stream.Collectors;
@Slf4j
@Service
@@ -82,6 +84,14 @@
@Autowired
private OrderItemMapper orderItemMapper;
+ @Autowired
+ private RedisLockService lockService;
+
+ @Autowired
+ private FlowerDeleteService flowerDeleteService;
+
+ private static final String FLOWER_KEY="com:mzl:flower:service:flower:%s:%s";
+
@Async
public synchronized void updateFlowerSales(Order order){
List<OrderItem> items = orderItemMapper.selectList(new QueryWrapper<OrderItem>()
@@ -97,6 +107,62 @@
public synchronized void updateCategoryInfo(Long category){
flowerMapper.updateFlowerCategoryInfo(category);
}
+
+ @Async
+ public void updateFlowTypeRank(Long id,Long category,String level){
+
+ Flower flower =null;
+ // 如果 id 不为空，则 category 和 level 可以为空
+ if (Objects.nonNull(id)) {
+ flower = flowerMapper.selectById(id);
+ if (flower == null) {
+ throw new IllegalArgumentException("Flower not found for ID: " + id);
+ }
+ category = flower.getCategory(); // 使用从数据库中检索到的 category
+ level = flower.getLevel(); // 使用从数据库中检索到的 level
+ } else {
+ // 如果 id 为空，则 category 和 level 必须提供
+ if (Objects.isNull(category) || StringUtils.isEmpty(level)) {
+ throw new IllegalArgumentException("Category and level must be provided when ID is null");
+ }
+ flower=new Flower();
+ flower.setCategory(category);
+ flower.setLevel(level);
+ }
+
+ String key=String.format(FLOWER_KEY, flower.getCategory(),flower.getLevel());
+
+ boolean lock = lockService.getObjectLock(key, "");
+ if(!lock){
+ return;
+ }
+ try{
+
+ QueryWrapper<Flower> queryWrapper=new QueryWrapper<>();
+ queryWrapper.lambda().eq(Flower::getDeleted,false)
+ .eq(Objects.nonNull(flower.getCategory()),Flower::getCategory,flower.getCategory())
+ .eq(StringUtils.isNotEmpty(flower.getLevel()),Flower::getLevel,flower.getLevel())
+ .orderByAsc(Flower::getPrice);
+ final List<Flower> flowerList = flowerMapper.selectList(queryWrapper);
+
+ AtomicInteger index = new AtomicInteger(1);
+ flowerList.forEach(f -> f.setTypeRank(index.getAndIncrement()));
+
+ if(!CollectionUtils.isEmpty(flowerList)){
+ flowerMapper.updateBatchTypeRank(flowerList);
+ }
+
+
+
+
+ }finally {
+ lockService.releaseObjectLock(key,"");
+ }
+
+ }
+
+
+
/**
* 花农（供应商）提交商品
@@ -128,6 +194,8 @@
paramService.insertTableData(fc.getParamId(), g.getId(), params);
}
+ // 更新商品价格在这里的分类
+ updateFlowTypeRank(null,g.getCategory(),g.getLevel());
return g.getId();
}
@@ -164,6 +232,9 @@
paramService.updateTableData(fc.getParamId(), g.getId(), params);
}
}
+
+ // 更新商品价格在这里的分类
+ updateFlowTypeRank(null,g.getCategory(),g.getLevel());
return g.getId();
}
@@ -386,10 +457,16 @@
}
public void deleteFlower(Long id){
+
+ final Flower flower = flowerMapper.selectById(id);
+
flowerMapper.deleteById(id);
//清除购物车商品
cartMapper.delete(new QueryWrapper<Cart>().eq("flower_id", id));
+ // 更新商品价格在这里的分类
+ updateFlowTypeRank(null,flower.getCategory(),flower.getLevel());
+
}
public void restoreFlower(Long id){
@@ -409,6 +486,8 @@
}
f.setPrice(dto.getPrice());
flowerMapper.updateById(f);
+ // 更新商品价格在这里的分类
+ updateFlowTypeRank(null,f.getCategory(),f.getLevel());
}
public void editFlowerStock(FlowerStockDTO dto){
@@ -712,4 +791,62 @@
}
}
+
+ @Transactional
+ public void deleteFlowerBatch(FlowerBatchDTO dto) {
+ List<Flower> flowerList = flowerMapper.getDeletdFlowByIds(dto.getIds());
+ //物理删除
+ flowerMapper.deleteBatchPhysics(dto.getIds());
+ // 备份
+ if(!CollectionUtils.isEmpty(flowerList)){
+ backupFlower(flowerList);
+ }
+ }
+
+ @Async
+ public void backupFlower(List<Flower> flowerList) {
+ // 备份
+ final List<Long> idList = flowerList.stream().map(flower -> flower.getId()).collect(Collectors.toList());
+ final List<FlowerDeleteDO> flowerDeleteList = flowerDeleteService.getBaseMapper().selectBatchIds(idList);
+ // 遍历flowerList 根据ID查找 ，如果flowerDeleteList 存在，则放入到更新列表里面去，如果flowerDeleteList不存在，则添加到新增列表里面去
+
+ // 将查询到的 flowerDeleteList 的 ID 转为 Set 以便快速查找
+ Set<Long> existingIds = flowerDeleteList.stream()
+ .map(FlowerDeleteDO::getId)
+ .collect(Collectors.toSet());
+ // 使用 Stream 进行更新和插入分类
+ List<FlowerDeleteDO> updateList = flowerList.stream()
+ .filter(flower -> existingIds.contains(flower.getId())) // 过滤出已存在的记录
+ .map(flower -> convertToFlowerDeleteDO(flower)) // 转换为 FlowerDeleteDO 对象
+ .collect(Collectors.toList());
+
+ List<FlowerDeleteDO> insertList = flowerList.stream()
+ .filter(flower -> !existingIds.contains(flower.getId())) // 过滤出不存在的记录
+ .map(flower -> convertToFlowerDeleteDO(flower)) // 转换为 FlowerDeleteDO 对象
+ .collect(Collectors.toList());
+
+ // 批量执行更新和新增操作
+ if (!updateList.isEmpty()) {
+ flowerDeleteService.updateBatchById(updateList); // 批量更新
+ }
+ if (!insertList.isEmpty()) {
+ flowerDeleteService.saveBatch(insertList); // 批量插入
+ }
+
+ }
+
+ @Transactional
+ public void restoreFlowerBatch(FlowerBatchDTO dto) {
+ flowerMapper.restoreFlowerBatch(dto.getIds());
+ }
+
+ // 方法用于将 Flower 转换为 FlowerDeleteDO
+ private FlowerDeleteDO convertToFlowerDeleteDO(Flower flower) {
+ FlowerDeleteDO flowerDeleteDO=new FlowerDeleteDO();
+ BeanUtils.copyProperties(flower,flowerDeleteDO);
+ // 其他需要备份的字段...
+ return flowerDeleteDO;
+ }
+
+
}
--
Gitblit v1.9.3