商品 可售时间 处理

src/main/java/com/chaozhanggui/system/cashierservice/service/ProductService.java

@@ -18,6 +18,7 @@ import com.chaozhanggui.system.cashierservice.util.*;
 import com.github.pagehelper.PageHelper;
 import com.github.pagehelper.PageInfo;
 import com.google.common.util.concurrent.AtomicDouble;
+import lombok.Data;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -26,6 +27,10 @@ import org.springframework.util.CollectionUtils;
 
 import javax.annotation.Resource;
 import java.math.BigDecimal;
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+import java.time.LocalTime;
+import java.time.format.DateTimeFormatter;
 import java.util.*;
 import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.ConcurrentHashMap;
@@ -136,32 +141,72 @@ public class ProductService {
         Integer id = ObjectUtil.isNotEmpty(productGroupId) ? Integer.valueOf(productGroupId) : null;
         //招牌菜
         List<TbProduct> tbProducts = tbProductMapper.selectIsSpecialty(Integer.valueOf(shopId));
-        concurrentMap.put("hots", handleDate(tbProducts));
+        concurrentMap.put("hots", handleDate(tbProducts,true));
         List<TbProductGroup> groupList = tbProductGroupMapper.selectByShopId(shopId, id);
         if (ObjectUtil.isNotEmpty(groupList) && groupList.size() > 0) {
             //热销
             TbProductGroup hot = new TbProductGroup();
             hot.setName("热销");
             List<TbProduct> hots = tbProductMapper.selectHot(shopId);
-            hot.setProducts(handleDate(hots));
+            hot.setProducts(handleDate(hots,true));
             //商品
             groupList.parallelStream().forEach(g -> {
+                if (g.getUseTime()==1) g.setIsSale(getIsSale(g.getSaleStartTime(),g.getSaleEndTime()));
                 String in = g.getProductIds().substring(1, g.getProductIds().length() - 1);
                 if (ObjectUtil.isNotEmpty(in) && ObjectUtil.isNotNull(in)) {
 //                    List<TbProduct> products = tbProductMapper.selectByIdIn(in);
                     List<TbProduct> products = tbProductMapper.selectByIdInAndCheck(in);
-                    g.setProducts(handleDate(products));
+                    g.setProducts(handleDate(products,false));
                 } else {
                     g.setProducts(new ArrayList<>());
                 }
             });
             groupList.add(0, hot);
+            groupList.sort(Comparator.comparingInt(TbProductGroup::getIsSale));
             concurrentMap.put("productInfo", groupList);
         }
 
         return Result.success(CodeEnum.SUCCESS, concurrentMap);
     }
 
+    /**
+     * 判断是否在可售时间内
+     * @param startTimeStr  HH:mm
+     * @param endTimeStr    HH:mm
+     * @return 1 可售 0 不可售
+     */
+    public Integer getIsSale(String startTimeStr,String endTimeStr) {
+        // 定义时间格式
+        DateTimeFormatter timeFormatter = DateTimeFormatter.ofPattern("HH:mm");
+        // 解析时间字符串为 LocalTime 对象
+        LocalTime startTime = LocalTime.parse(startTimeStr, timeFormatter);
+        LocalTime endTime = LocalTime.parse(endTimeStr, timeFormatter);
+        // 获取当前日期
+        LocalDate today = LocalDate.now();
+        // 创建 LocalDateTime 对象
+        LocalDateTime startDateTime = LocalDateTime.of(today, startTime);
+        LocalDateTime endDateTime = LocalDateTime.of(today, endTime);
+        // 如果结束时间早于开始时间，说明时间段跨日
+        if (endDateTime.isBefore(startDateTime)) {
+            endDateTime = endDateTime.plusDays(1);
+        }
+        // 获取当前日期时间
+        LocalDateTime now = LocalDateTime.now();
+        if (now.isBefore(startDateTime)) {
+            // 将当前时间加上24小时（一天），进行比较
+            LocalDateTime nowPlus24 = now.plusHours(24);
+            //当前时间 小于开始时间，且结束时间小于开始时间
+            if (nowPlus24.isBefore(endDateTime)) {
+                return 1;
+            }
+        } else {
+            if (now.isBefore(endDateTime)) {
+                return 1;
+            }
+        }
+        return 0;
+    }
+
     public Object querySpec(QuerySpecDTO querySpecDTO) {
         TbProduct tbProduct = tbProductMapper.selectById(querySpecDTO.getProductId());
         if (tbProduct == null) {
@@ -296,9 +341,26 @@ public class ProductService {
         }
     }
 
-    public List<TbProduct> handleDate(List<TbProduct> products){
+    /**
+     * 组装商品
+     * @param products  商品列表
+     * @param check     是否校验可售
+     * @return
+     */
+    public List<TbProduct> handleDate(List<TbProduct> products,boolean check){
         if (!CollectionUtils.isEmpty(products)) {
             products.parallelStream().forEach(it -> {
+                if(check){
+                    List<TbProductGroup> tbProductGroups = tbProductGroupMapper.selectByProductId(it.getShopId(), it.getId().toString());
+                    for (TbProductGroup g : tbProductGroups) {
+                        if (g.getUseTime()==1) {
+                            if (getIsSale(g.getSaleStartTime(), g.getSaleEndTime()) == 0) {
+                                it.setIsSale(0);
+                                return;
+                            }
+                        }
+                    }
+                }
                 TbShopUnit tbShopUnit = unitMapper.selectByPrimaryKey(Integer.valueOf(it.getUnitId()));
                 it.setUnitSnap(tbShopUnit != null ? tbShopUnit.getName() : "");
                 //购物车数量