|
|
@@ -1,48 +1,21 @@
|
|
|
package shop.alien.storeplatform.service.impl;
|
|
|
|
|
|
-import com.alibaba.fastjson2.JSONObject;
|
|
|
-import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
|
-import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
|
|
|
-import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
|
|
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
|
|
import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
|
|
|
-import com.baomidou.mybatisplus.core.toolkit.StringUtils;
|
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
|
|
import lombok.RequiredArgsConstructor;
|
|
|
-import org.springframework.beans.factory.annotation.Value;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
-import org.springframework.transaction.annotation.Transactional;
|
|
|
import shop.alien.entity.result.R;
|
|
|
import shop.alien.entity.store.*;
|
|
|
-import shop.alien.entity.store.dto.LifeUserOrderDto;
|
|
|
-import shop.alien.entity.store.excelVo.LifeUserOrderExcelVo;
|
|
|
-import shop.alien.entity.store.excelVo.util.ExcelGenerator;
|
|
|
import shop.alien.entity.store.vo.LifeUserOrderVo;
|
|
|
-import shop.alien.entity.store.vo.StoreInfoVo;
|
|
|
-import shop.alien.entity.store.vo.WebSocketVo;
|
|
|
import shop.alien.mapper.*;
|
|
|
-import shop.alien.store.config.GaoDeMapUtil;
|
|
|
-import shop.alien.store.config.WebSocketProcess;
|
|
|
-import shop.alien.store.util.ali.AliApi;
|
|
|
-import shop.alien.util.ali.AliOSSUtil;
|
|
|
-import shop.alien.util.common.UniqueRandomNumGenerator;
|
|
|
-import shop.alien.util.common.constant.CouponStatusEnum;
|
|
|
-import shop.alien.util.common.constant.CouponTypeEnum;
|
|
|
-import shop.alien.util.common.constant.DiscountCouponEnum;
|
|
|
import shop.alien.util.common.constant.OrderStatusEnum;
|
|
|
import shop.alien.storeplatform.service.LifeUserOrderPlatformService;
|
|
|
|
|
|
-import java.io.File;
|
|
|
-import java.io.IOException;
|
|
|
import java.math.BigDecimal;
|
|
|
import java.math.RoundingMode;
|
|
|
-import java.text.DecimalFormat;
|
|
|
-import java.time.Instant;
|
|
|
-import java.time.LocalDateTime;
|
|
|
-import java.time.ZoneId;
|
|
|
-import java.time.format.DateTimeFormatter;
|
|
|
import java.util.*;
|
|
|
import java.util.stream.Collectors;
|
|
|
|
|
|
@@ -60,938 +33,9 @@ public class LifeUserOrderPlatformServiceImpl extends ServiceImpl<LifeUserOrderM
|
|
|
|
|
|
private final LifeUserOrderMapper lifeUserOrderMapper;
|
|
|
|
|
|
- private final LifeCouponMapper lifeCouponMapper;
|
|
|
-
|
|
|
- private final LifeRefundOrderMapper lifeRefundOrderMapper;
|
|
|
-
|
|
|
- private final StoreInfoMapper storeInfoMapper;
|
|
|
-
|
|
|
- private final LifeUserService lifeUserService;
|
|
|
-
|
|
|
- private final GaoDeMapUtil gaoDeMapUtil;
|
|
|
-
|
|
|
- private final LifeFansMapper lifeFansMapper;
|
|
|
-
|
|
|
- private final StoreCommentService storeCommentService;
|
|
|
-
|
|
|
- private final LifeUserMapper lifeUserMapper;
|
|
|
-
|
|
|
- private final LifeNoticeMapper lifeNoticeMapper;
|
|
|
-
|
|
|
- private final StoreImgMapper storeImgMapper;
|
|
|
-
|
|
|
- private final StoreUserMapper storeUserMapper;
|
|
|
-
|
|
|
- private final LifeDiscountCouponUserMapper lifeDiscountCouponUserMapper;
|
|
|
-
|
|
|
- private final OrderCouponMiddleService orderCouponMiddleService;
|
|
|
-
|
|
|
- private final AliOSSUtil aliOSSUtil;
|
|
|
|
|
|
private final OrderCouponMiddleMapper orderCouponMiddleMapper;
|
|
|
|
|
|
- private final LifeGroupBuyMainMapper lifeGroupBuyMainMapper;
|
|
|
-
|
|
|
- private final AliApi aliApi;
|
|
|
-
|
|
|
- private final LifeDiscountCouponMapper lifeDiscountCouponMapper;
|
|
|
-
|
|
|
- private final WebSocketProcess webSocketProcess;
|
|
|
-
|
|
|
- @Value("${spring.web.resources.excel-path}")
|
|
|
- private String excelPath;
|
|
|
-
|
|
|
- @Value("${spring.web.resources.excel-generate-path}")
|
|
|
- private String excelGeneratePath;
|
|
|
-
|
|
|
- /**
|
|
|
- * 根据状态查询订单列表
|
|
|
- * 支持多条件筛选，包括用户、商户、订单状态、保价状态等
|
|
|
- *
|
|
|
- * @param page 页码
|
|
|
- * @param size 每页数量
|
|
|
- * @param userId 用户ID
|
|
|
- * @param status 订单状态
|
|
|
- * @param quanNameSearch 优惠券名称搜索关键字
|
|
|
- * @param storeType 商户类型
|
|
|
- * @param baojiaStatus 保价状态
|
|
|
- * @param orderNo 订单号
|
|
|
- * @param storeId 商户ID
|
|
|
- * @return List<Map<String, Object>> 返回订单列表
|
|
|
- * @author alien-cloud
|
|
|
- * @date 2025-11-18
|
|
|
- */
|
|
|
- public List<Map<String, Object>> getOrderListByStatus(Integer page, Integer size, String userId, String status,
|
|
|
- String quanNameSearch, Integer storeType, String baojiaStatus, String orderNo, Integer storeId) {
|
|
|
- List<Map<String, Object>> returnList = new ArrayList<>();
|
|
|
-
|
|
|
- // 构建基础查询条件
|
|
|
- LambdaQueryWrapper<LifeUserOrder> baseWrapper = new LambdaQueryWrapper<>();
|
|
|
- baseWrapper.eq(StringUtils.isNotEmpty(userId), LifeUserOrder::getUserId, userId);
|
|
|
- baseWrapper.eq(StringUtils.isNotEmpty(status), LifeUserOrder::getStatus, status);
|
|
|
- baseWrapper.like(StringUtils.isNotEmpty(orderNo), LifeUserOrder::getOrderNo, orderNo);
|
|
|
- baseWrapper.like(null != storeId, LifeUserOrder::getStoreId, storeId);
|
|
|
-
|
|
|
- // 先查询符合条件的订单号，并进行分页
|
|
|
- baseWrapper
|
|
|
- .groupBy(LifeUserOrder::getOrderNo)
|
|
|
- .orderByAsc(LifeUserOrder::getStatus)
|
|
|
- .orderByDesc(LifeUserOrder::getUpdatedTime);
|
|
|
-
|
|
|
- List<LifeUserOrder> orderList = lifeUserOrderMapper.selectList(baseWrapper);
|
|
|
- if (orderList.isEmpty()) {
|
|
|
- return new ArrayList<>();
|
|
|
- }
|
|
|
-
|
|
|
- //获取所有订单号
|
|
|
- List<String> orderNos = orderList.stream()
|
|
|
- .map(LifeUserOrder::getOrderNo)
|
|
|
- .collect(Collectors.toList());
|
|
|
-
|
|
|
- // 按订单号分组处理
|
|
|
- Map<String, List<LifeUserOrder>> orderDetailsGrouped = orderList.stream()
|
|
|
- .collect(Collectors.groupingBy(LifeUserOrder::getOrderNo));
|
|
|
-
|
|
|
- //一次性获取所有优惠券id
|
|
|
- List<String> quanIdList = orderList.stream().map(LifeUserOrder::getQuanId).collect(Collectors.toList());
|
|
|
- //查询所有优惠券
|
|
|
- List<LifeCoupon> lifeCoupons = lifeCouponMapper.getList(new LambdaQueryWrapper<LifeCoupon>().in(!quanIdList.isEmpty(), LifeCoupon::getId, quanIdList));
|
|
|
-
|
|
|
- //一次性获取所有店铺id
|
|
|
- List<String> storeIdList = orderList.stream().map(LifeUserOrder::getStoreId).collect(Collectors.toList());
|
|
|
- //查询所有店铺
|
|
|
- List<StoreInfo> storeInfoList = storeInfoMapper.getList(new LambdaQueryWrapper<StoreInfo>().in(!storeIdList.isEmpty(), StoreInfo::getId, storeIdList));
|
|
|
-
|
|
|
- // 查询所有店铺用户
|
|
|
- List<StoreUser> storeUsers = storeUserMapper.selectList(new QueryWrapper<StoreUser>().isNotNull("store_id"));
|
|
|
- Map<Integer, List<StoreUser>> collect1 = storeUsers.stream().collect(Collectors.groupingBy(StoreUser::getStoreId));
|
|
|
- // 遍历每个订单号，处理订单详情
|
|
|
- for (String orderNum : orderNos) {
|
|
|
- List<LifeUserOrder> orderDetails = orderDetailsGrouped.getOrDefault(orderNum, Collections.emptyList());
|
|
|
- if (orderDetails.isEmpty()) {
|
|
|
- continue;
|
|
|
- }
|
|
|
- LifeUserOrder lifeUserOrder = orderDetails.get(0);
|
|
|
- if (StringUtils.isEmpty(lifeUserOrder.getQuanId())) {
|
|
|
- continue;
|
|
|
- }
|
|
|
- LifeCoupon quan = lifeCoupons.stream().filter(a -> a.getId().equals(lifeUserOrder.getQuanId())).collect(Collectors.toList()).get(0);
|
|
|
- if (StringUtils.isEmpty(lifeUserOrder.getStoreId())) {
|
|
|
- continue;
|
|
|
- }
|
|
|
- StoreInfo storeInfo = storeInfoList.stream().filter(a -> lifeUserOrder.getStoreId().equals(a.getId().toString())).collect(Collectors.toList()).get(0);
|
|
|
-
|
|
|
- Map<String, Object> map = new HashMap<>();
|
|
|
- map.put("orderId", lifeUserOrder.getId());
|
|
|
- map.put("orderNo", lifeUserOrder.getOrderNo());
|
|
|
- Integer deleteFlag = 1;
|
|
|
- Integer storeStatus = 0;
|
|
|
- Integer logoutFlag = 0;
|
|
|
- // 店铺用户状态，注销，删除，禁用;
|
|
|
- if (collect1.containsKey(Integer.parseInt(lifeUserOrder.getStoreId()))) {
|
|
|
- List<StoreUser> storeUsers1 = collect1.get(Integer.parseInt(lifeUserOrder.getStoreId()));
|
|
|
- StoreUser storeUser = storeUsers1.get(0);
|
|
|
- deleteFlag = storeUser.getDeleteFlag();
|
|
|
- storeStatus = storeUser.getStatus();
|
|
|
- logoutFlag = storeUser.getLogoutFlag();
|
|
|
- }
|
|
|
- ;
|
|
|
- map.put("abnormalStateFlag", 0);
|
|
|
- if (deleteFlag == 1 || storeStatus == 1 || logoutFlag == 1) {
|
|
|
- map.put("abnormalStateFlag", 1);
|
|
|
- }
|
|
|
- // 营业状态
|
|
|
- map.put("businessStatus", storeInfo.getBusinessStatus());
|
|
|
- // 计算实付金额
|
|
|
- String finalPrice = new BigDecimal(lifeUserOrder.getFinalPrice())
|
|
|
- .multiply(new BigDecimal(orderDetails.size()))
|
|
|
- .toString();
|
|
|
- map.put("price", finalPrice);
|
|
|
- map.put("count", lifeUserOrderMapper.selectCount(new LambdaQueryWrapper<LifeUserOrder>().eq(LifeUserOrder::getOrderNo, lifeUserOrder.getOrderNo())));
|
|
|
-
|
|
|
- if (lifeUserOrder.getStatus() == 0) {
|
|
|
- Calendar calendar = Calendar.getInstance();
|
|
|
- calendar.setTime(lifeUserOrder.getBuyTime());
|
|
|
- calendar.add(Calendar.DAY_OF_MONTH, quan.getExpirationDate());
|
|
|
- Date expirationDate = calendar.getTime();
|
|
|
- if (quan.getEndDate() == null) {
|
|
|
- map.put("youxiaoqiTime", expirationDate);
|
|
|
- } else {
|
|
|
- Date youxiaoqiTime = expirationDate.compareTo(quan.getEndDate()) > 0 ? quan.getEndDate() : expirationDate;
|
|
|
- map.put("youxiaoqiTime", youxiaoqiTime);
|
|
|
- }
|
|
|
- } else {
|
|
|
- map.put("xiadanTime", lifeUserOrder.getPayTime());
|
|
|
- }
|
|
|
- map.put("storeName", storeInfo.getStoreName());
|
|
|
- map.put("storeType", storeInfo.getBusinessSection());
|
|
|
-
|
|
|
- // 计算保价状态
|
|
|
- // 0 未开启 1 生效中 2 已过期
|
|
|
- int priceProtectionStatus = 0;
|
|
|
- if (quan.getOpenPriceProtection() != null && quan.getOpenPriceProtection() != 0) {
|
|
|
- LocalDateTime sevenDaysAgo = LocalDateTime.now().minusDays(7);
|
|
|
- Date createdTime = lifeUserOrder.getCreatedTime();
|
|
|
- LocalDateTime orderCreatedTime = createdTime.toInstant()
|
|
|
- .atZone(ZoneId.systemDefault())
|
|
|
- .toLocalDateTime();
|
|
|
- priceProtectionStatus = orderCreatedTime.isAfter(sevenDaysAgo) ? 1 : 2;
|
|
|
- }
|
|
|
- map.put("baojiaStatus", priceProtectionStatus);
|
|
|
-
|
|
|
- // 只有当baojiaStatus参数存在且筛选结果不包含当前订单时，跳过该订单
|
|
|
- if (baojiaStatus != null && !baojiaStatus.isEmpty()) {
|
|
|
- try {
|
|
|
- int targetStatus = Integer.parseInt(baojiaStatus);
|
|
|
- if (priceProtectionStatus != targetStatus) {
|
|
|
- continue;
|
|
|
- }
|
|
|
- } catch (NumberFormatException e) {
|
|
|
- throw new RuntimeException("保价状态参数格式错误", e);
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- // 继续设置其他订单信息
|
|
|
- map.put("storeName", storeInfo.getStoreName());
|
|
|
- map.put("quanName", quan.getName());
|
|
|
- map.put("quanId", quan.getId());
|
|
|
- map.put("status", lifeUserOrder.getStatus());
|
|
|
-
|
|
|
- //
|
|
|
- String imgs = quan.getImagePath();
|
|
|
- if (imgs != null && !imgs.startsWith("h")) {
|
|
|
- if (StringUtils.isNotEmpty(imgs)) {
|
|
|
- List<String> collect = Arrays.stream(imgs.split(","))
|
|
|
- .map(String::trim)
|
|
|
- .collect(Collectors.toList());
|
|
|
- List<StoreImg> storeImgs = storeImgMapper.selectList(new LambdaQueryWrapper<StoreImg>().in(StoreImg::getId, collect));
|
|
|
- if (storeImgs != null) {
|
|
|
- imgs = storeImgs.stream()
|
|
|
- .map(StoreImg::getImgUrl)
|
|
|
- .collect(Collectors.joining(","));
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- }
|
|
|
-
|
|
|
-
|
|
|
- map.put("image", imgs);
|
|
|
- map.put("quanType", quan.getType());
|
|
|
-
|
|
|
- // 获取全部券码
|
|
|
- String quanCode = orderDetails.stream()
|
|
|
- .filter(o -> o.getStatus() == 0)
|
|
|
- .map(LifeUserOrder::getQuanCode)
|
|
|
- .collect(Collectors.joining(","));
|
|
|
- map.put("quanCode", quanCode);
|
|
|
- map.put("storeId", storeInfo.getId());
|
|
|
-
|
|
|
- // 检查是否已评价
|
|
|
- LambdaQueryWrapper<StoreComment> storeCommentWrapper = new LambdaQueryWrapper<>();
|
|
|
- storeCommentWrapper.eq(StoreComment::getUserId, userId);
|
|
|
- storeCommentWrapper.eq(StoreComment::getStoreId, lifeUserOrder.getStoreId());
|
|
|
- storeCommentWrapper.eq(StoreComment::getBusinessType, 5);
|
|
|
- storeCommentWrapper.eq(StoreComment::getBusinessId, lifeUserOrder.getId());
|
|
|
- int count = storeCommentService.count(storeCommentWrapper);
|
|
|
- map.put("hasComment", count > 0);
|
|
|
-
|
|
|
- returnList.add(map);
|
|
|
- }
|
|
|
-
|
|
|
- List<Map<String, Object>> resultList = returnList;
|
|
|
- if (null != storeType) {
|
|
|
- resultList = resultList.stream().filter(a -> a.get("storeType").equals(storeType)).collect(Collectors.toList());
|
|
|
- }
|
|
|
- if (StringUtils.isNotEmpty(quanNameSearch)) {
|
|
|
- resultList = resultList.stream().filter(a -> a.get("quanName").toString().contains(quanNameSearch) || a.get("storeName").toString().contains(quanNameSearch)).collect(Collectors.toList());
|
|
|
- }
|
|
|
- return resultList;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 根据订单ID查询订单详情
|
|
|
- * 包含订单信息、商户信息、用户关注状态、距离计算等
|
|
|
- *
|
|
|
- * @param orderId 订单ID
|
|
|
- * @param jingdu 经度，用于计算距离
|
|
|
- * @param weidu 纬度，用于计算距离
|
|
|
- * @return Map<String, Object> 返回订单详细信息
|
|
|
- * @author alien-cloud
|
|
|
- * @date 2025-11-18
|
|
|
- */
|
|
|
- public Map<String, Object> getOrderByOrderId(String orderId, String jingdu, String weidu) {
|
|
|
- Map<String, Object> returnMap = new HashMap<>();
|
|
|
- LifeUserOrder order = lifeUserOrderMapper.selectById(orderId);
|
|
|
- if (order == null) {
|
|
|
- return null;
|
|
|
- }
|
|
|
- // 获取该订单编号的所有订单
|
|
|
- LambdaQueryWrapper<LifeUserOrder> allOrderWrapper = new LambdaQueryWrapper<>();
|
|
|
- allOrderWrapper.eq(LifeUserOrder::getOrderNo, order.getOrderNo());
|
|
|
- String quanCodes = lifeUserOrderMapper.selectList(allOrderWrapper).stream().filter(o -> o.getStatus() == 0)
|
|
|
- .map(o -> o.getQuanCode())
|
|
|
- .collect(Collectors.joining(","));
|
|
|
-
|
|
|
- Map<String, Object> orderMap = new HashMap<>();
|
|
|
- String quanPrice = order.getPrice();
|
|
|
- String finalPrice = order.getFinalPrice();
|
|
|
- String unusedDate;
|
|
|
- String useRule;
|
|
|
- String applicableRule;
|
|
|
- int status = order.getStatus();
|
|
|
- String imagePath;
|
|
|
- LifeCoupon quan = lifeCouponMapper.selectById(order.getQuanId());
|
|
|
- if (quan == null) {
|
|
|
- return null;
|
|
|
- }
|
|
|
- unusedDate = quan.getUnusedDate();
|
|
|
- useRule = quan.getUseRule();
|
|
|
- applicableRule = quan.getApplicableRule();
|
|
|
- imagePath = quan.getImagePath();
|
|
|
- orderMap.put("orderId", order.getId());
|
|
|
- orderMap.put("quanName", quan.getName());
|
|
|
- orderMap.put("quanPrice", quanPrice);
|
|
|
- orderMap.put("shifuPrice", finalPrice);
|
|
|
- orderMap.put("unusedDate", unusedDate);
|
|
|
- orderMap.put("useRule", useRule);
|
|
|
- orderMap.put("applicableRule", applicableRule);
|
|
|
- orderMap.put("quanCode", quanCodes);
|
|
|
- orderMap.put("status", status);
|
|
|
- orderMap.put("imagePath", imagePath);
|
|
|
- QueryWrapper<StoreInfoVo> queryWrapper = new QueryWrapper<>();
|
|
|
- queryWrapper.eq("a.id", order.getStoreId());
|
|
|
- StoreInfoVo store = storeInfoMapper.getStoreInfoVoOne(queryWrapper);
|
|
|
- orderMap.put("storeId", store.getId());
|
|
|
- returnMap.put("order", orderMap);
|
|
|
-
|
|
|
- // 添加是否关注逻辑
|
|
|
- String userId = order.getUserId();
|
|
|
- LifeUser userById = lifeUserService.getUserById(userId);
|
|
|
- String s = "user_" + userById.getUserPhone();
|
|
|
-
|
|
|
- String receiverId = "store_" + store.getStorePhone();
|
|
|
-
|
|
|
- //关注我的
|
|
|
- LambdaQueryWrapper<LifeFans> wrapperOne = new LambdaQueryWrapper<>();
|
|
|
- wrapperOne.eq(LifeFans::getFollowedId, s).eq(LifeFans::getFansId, receiverId);
|
|
|
- List<LifeFans> isFollowMeList = lifeFansMapper.selectList(wrapperOne);
|
|
|
-
|
|
|
- //我关注的
|
|
|
- LambdaQueryWrapper<LifeFans> wrapperTwo = new LambdaQueryWrapper<>();
|
|
|
- wrapperTwo.eq(LifeFans::getFollowedId, receiverId).eq(LifeFans::getFansId, s);
|
|
|
- List<LifeFans> isFollowThisList = lifeFansMapper.selectList(wrapperTwo);
|
|
|
-
|
|
|
- Map<String, Object> storeMap = new HashMap<>();
|
|
|
- storeMap.put("storeName", store.getStoreName());
|
|
|
- storeMap.put("openTime", "9:00-22:00");
|
|
|
- if ((jingdu != null && !jingdu.isEmpty()) && (weidu != null && !weidu.isEmpty())) {
|
|
|
- double storeDistance = gaoDeMapUtil.getDistance(jingdu, weidu, store.getStorePosition().split(",")[0], store.getStorePosition().split(",")[1]);
|
|
|
- DecimalFormat df = new DecimalFormat("#.0");
|
|
|
- storeMap.put("distance", Double.parseDouble(df.format(storeDistance / 1000)) + "km");
|
|
|
- } else {
|
|
|
- storeMap.put("distance", "没有位置信息");
|
|
|
- }
|
|
|
- storeMap.put("address", store.getStoreAddress());
|
|
|
- storeMap.put("contactPerson", store.getStoreContact());
|
|
|
- storeMap.put("phoneNum", store.getStorePhone());
|
|
|
- storeMap.put("jingdu", store.getStorePosition().split(",")[0]);
|
|
|
- storeMap.put("weidu", store.getStorePosition().split(",")[1]);
|
|
|
- returnMap.put("store", storeMap);
|
|
|
- Map<String, Object> goumaixuzhiMap = new HashMap<>();
|
|
|
- goumaixuzhiMap.put("expirationDate", "购买后" + quan.getExpirationDate() + "天有效");
|
|
|
- goumaixuzhiMap.put("useTime", "营业时间可用");
|
|
|
- goumaixuzhiMap.put("useRange", quan.getUseRule());
|
|
|
- goumaixuzhiMap.put("applicableRule", quan.getApplicableRule());
|
|
|
- returnMap.put("gouMaiXuZhi", goumaixuzhiMap);
|
|
|
- Map<String, Object> orderInfoMap = new HashMap<>();
|
|
|
- orderInfoMap.put("orderNo", order.getOrderNo());
|
|
|
- orderInfoMap.put("payMethod", order.getPayMethod());
|
|
|
- LifeUser byId = lifeUserService.getById(order.getUserId());
|
|
|
- orderInfoMap.put("phoneNum", byId.getUserPhone());
|
|
|
- orderInfoMap.put("buyTime", order.getBuyTime());
|
|
|
- orderInfoMap.put("payTime", order.getPayTime());
|
|
|
- orderInfoMap.put("isFollowMe", !isFollowMeList.isEmpty() ? 1 : 0);
|
|
|
- orderInfoMap.put("isFollowThis", !isFollowThisList.isEmpty() ? 1 : 0);
|
|
|
-
|
|
|
- // 判断保价状态
|
|
|
- Date currentDate = new Date();
|
|
|
- Calendar payTimeCal = Calendar.getInstance();
|
|
|
- payTimeCal.setTime(order.getPayTime());
|
|
|
- Calendar currentCal = Calendar.getInstance();
|
|
|
- currentCal.setTime(currentDate);
|
|
|
-
|
|
|
- long diffInMillis = currentCal.getTimeInMillis() - payTimeCal.getTimeInMillis();
|
|
|
- long diffInDays = diffInMillis / (24 * 60 * 60 * 1000);
|
|
|
- String priceProtectionStatus = diffInDays < 7 ? "1" : "0";
|
|
|
- orderInfoMap.put("priceProtectionStatus", priceProtectionStatus);
|
|
|
- returnMap.put("orderInfo", orderInfoMap);
|
|
|
- return returnMap;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 根据订单ID删除订单
|
|
|
- *
|
|
|
- * @param orderId 订单ID
|
|
|
- * @return int 删除的记录数
|
|
|
- * @author alien-cloud
|
|
|
- * @date 2025-11-18
|
|
|
- */
|
|
|
- public int deleteOrdersById(String orderId) {
|
|
|
- return lifeUserOrderMapper.deleteById(orderId);
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 根据订单号获取券码列表
|
|
|
- *
|
|
|
- * @param orderNo 订单号
|
|
|
- * @return List<String> 返回券码列表
|
|
|
- * @author alien-cloud
|
|
|
- * @date 2025-11-18
|
|
|
- */
|
|
|
- public List<String> getQuanCodeList(String orderNo) {
|
|
|
- LambdaUpdateWrapper<LifeUserOrder> wrapper = new LambdaUpdateWrapper<>();
|
|
|
- wrapper.eq(LifeUserOrder::getOrderNo, orderNo);
|
|
|
- List<LifeUserOrder> orders = lifeUserOrderMapper.selectList(wrapper);
|
|
|
- return orders.stream().map(LifeUserOrder::getQuanCode).collect(Collectors.toList());
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 申请退款
|
|
|
- * 处理订单退款流程，包括金额校验、调用支付接口、更新订单状态、恢复库存、发送通知等
|
|
|
- *
|
|
|
- * @param refundOrder 退款订单对象，包含订单ID、退款金额、退款原因等信息
|
|
|
- * @return R<String> 返回退款结果信息
|
|
|
- * @author alien-cloud
|
|
|
- * @date 2025-11-18
|
|
|
- */
|
|
|
- @Transactional(rollbackFor = Exception.class)
|
|
|
- public R<String> requestRefund(LifeRefundOrder refundOrder) {
|
|
|
- if (StringUtils.isEmpty(refundOrder.getRefundMoney())) {
|
|
|
- return R.fail("退款金额为null");
|
|
|
- }
|
|
|
- List<OrderCouponMiddle> orderCouponMiddles = orderCouponMiddleMapper.selectList(new QueryWrapper<OrderCouponMiddle>()
|
|
|
- .eq("order_id", refundOrder.getOrderId()).eq("delete_flag", 0));
|
|
|
- // 1.查询订单信息 订单表 + 中间表
|
|
|
- LifeUserOrder order = lifeUserOrderMapper.selectById(refundOrder.getOrderId());
|
|
|
- Integer refundCouponAmount = refundOrder.getRefundCouponAmount();
|
|
|
- // 待使用的券（可退款的券 || 退款失败的券 目前没做失败的券状态更新 暂时不加）
|
|
|
- List<OrderCouponMiddle> orderCouponMiddles1 = orderCouponMiddles.stream().filter(orderCouponMiddle -> orderCouponMiddle.getStatus() == OrderStatusEnum.WAIT_USE.getStatus()).collect(Collectors.toList());
|
|
|
- if (orderCouponMiddles1.size() < refundCouponAmount) {
|
|
|
- return R.fail("退款券数不足");
|
|
|
- }
|
|
|
- // 判断累计退款金额
|
|
|
- BigDecimal totalRefundMoney = new BigDecimal(refundOrder.getRefundMoney());
|
|
|
- // 累计退款个数
|
|
|
- int refundCouponCount = 0;
|
|
|
- List<LifeRefundOrder> lifeRefundOrderList = lifeRefundOrderMapper.selectList(new QueryWrapper<LifeRefundOrder>().eq("order_id", refundOrder.getOrderId())
|
|
|
- .eq("status", 0));
|
|
|
- for (LifeRefundOrder lifeRefundOrder : lifeRefundOrderList) {
|
|
|
- totalRefundMoney = totalRefundMoney.add(new BigDecimal(lifeRefundOrder.getRefundMoney()));
|
|
|
- refundCouponCount += lifeRefundOrder.getRefundCouponAmount();
|
|
|
- }
|
|
|
- if (totalRefundMoney.compareTo(new BigDecimal(order.getFinalPrice())) > 0) {
|
|
|
- return R.fail("退款金额(已退+当前退)不能大于订单金额");
|
|
|
- }
|
|
|
- Date now = new Date();
|
|
|
- boolean ifPartialRefund = false;
|
|
|
- String PartialRefundCode = "";
|
|
|
- // 只要本次退款不是全退都是部分退
|
|
|
- if (refundCouponAmount != orderCouponMiddles.size()) {
|
|
|
- ifPartialRefund = true;
|
|
|
- PartialRefundCode = UniqueRandomNumGenerator.generateUniqueCode(12);
|
|
|
- }
|
|
|
- String result = aliApi.processRefund(order.getOrderNo(), refundOrder.getRefundMoney(), refundOrder.getDescription(), PartialRefundCode);
|
|
|
- String refundMessage = "";
|
|
|
-
|
|
|
- // 更新的中间表id
|
|
|
- List<Integer> updateIds = orderCouponMiddles1.stream().limit(refundCouponAmount).map(x -> x.getId()).collect(Collectors.toList());
|
|
|
- if (!result.equals("调用成功")) {
|
|
|
- refundMessage = "编号为" + order.getOrderNo() + "的订单退款失败，请重新发起申请。";
|
|
|
- // TODO 退款失败目前不做处理
|
|
|
- /*orderCouponMiddleMapper.update(null,new UpdateWrapper<OrderCouponMiddle>().in("id",updateIds)
|
|
|
- .set("status",OrderStatusEnum.REFUND_FAILED.getStatus())
|
|
|
- .set("refund_time",now)
|
|
|
- .set(ifPartialRefund,"refund_code",PartialRefundCode)
|
|
|
- .set("refund_reason",refundOrder.getReason()));
|
|
|
- // 退款记录
|
|
|
- refundOrder.setApplicationTime(now).setRefundTime(now).setStatus(1);*/
|
|
|
- return R.fail(refundMessage);
|
|
|
- } else {
|
|
|
- refundMessage = "编号为" + order.getOrderNo() + "的订单已退款成功，退款金额" + refundOrder.getRefundMoney() + "元，已返还至您的支付渠道，请注意查收";
|
|
|
- orderCouponMiddleMapper.update(null, new UpdateWrapper<OrderCouponMiddle>().in("id", updateIds)
|
|
|
- .set("status", OrderStatusEnum.REFUND.getStatus())
|
|
|
- .set("refund_time", now)
|
|
|
- .set(ifPartialRefund, "partial_refund_code", PartialRefundCode)
|
|
|
- .set("refund_reason", refundOrder.getReason()));
|
|
|
- // 退款记录
|
|
|
- refundOrder.setApplicationTime(now).setRefundTime(now).setStatus(0);
|
|
|
- if (ifPartialRefund) {
|
|
|
- refundOrder.setPartialRefundCode(PartialRefundCode);
|
|
|
- }
|
|
|
- }
|
|
|
- // 更新总订单数据（中间表数据+订单表数据：当已退款个数+当前退款个数=已使用的券数时，订单状态改为已退款）
|
|
|
- if (refundCouponCount + refundCouponAmount == orderCouponMiddles.size()) {
|
|
|
- lifeUserOrderMapper.update(null, new UpdateWrapper<LifeUserOrder>().eq("id", order.getId())
|
|
|
- .set("status", OrderStatusEnum.REFUND.getStatus())
|
|
|
- .set("refund_time", now)
|
|
|
- .set("finish_time", now));
|
|
|
- if (null != order.getQuanId()) {
|
|
|
- lifeDiscountCouponUserMapper.update(null, new UpdateWrapper<LifeDiscountCouponUser>().eq("id", order.getQuanId())
|
|
|
- .set("status", DiscountCouponEnum.WAITING_USED.getValue()).set("use_time", null));
|
|
|
- } else {
|
|
|
- // 处理 quanId 为 null 的情况，例如日志记录
|
|
|
- log.error("更新优惠券状态失败");
|
|
|
- }
|
|
|
- } else if (refundCouponCount + refundCouponAmount != orderCouponMiddles.size() && refundCouponAmount == orderCouponMiddles1.size()) {
|
|
|
- // 累计退券个数+当前退券个数!=总个数 且 当前退券数量 = 可退券数
|
|
|
- lifeUserOrderMapper.update(null, new UpdateWrapper<LifeUserOrder>().eq("id", order.getId())
|
|
|
- .set("status", OrderStatusEnum.COMPLETE.getStatus())
|
|
|
- .set("finish_time", now));
|
|
|
- }
|
|
|
-
|
|
|
- // 将退款记录插入到数据库中
|
|
|
- if (lifeRefundOrderMapper.insert(refundOrder) > 0) {
|
|
|
- // 发送通知
|
|
|
- LifeNotice lifeMessage = new LifeNotice();
|
|
|
- LifeUser lifeUser = lifeUserMapper.selectById(order.getUserId());
|
|
|
- lifeMessage.setReceiverId("user_" + lifeUser.getUserPhone());
|
|
|
- JSONObject jsonObject = new JSONObject();
|
|
|
- jsonObject.put("message", refundMessage);
|
|
|
- lifeMessage.setContext(jsonObject.toJSONString());
|
|
|
- lifeMessage.setSenderId("system");
|
|
|
- lifeMessage.setIsRead(0);
|
|
|
- lifeMessage.setNoticeType(2);
|
|
|
- lifeNoticeMapper.insert(lifeMessage);
|
|
|
-
|
|
|
- WebSocketVo websocketVo = new WebSocketVo();
|
|
|
- websocketVo.setSenderId("system");
|
|
|
- websocketVo.setReceiverId("user_" + lifeUser.getUserPhone());
|
|
|
- websocketVo.setCategory("notice");
|
|
|
- websocketVo.setNoticeType("1");
|
|
|
- websocketVo.setIsRead(0);
|
|
|
- websocketVo.setText(JSONObject.from(lifeMessage).toJSONString());
|
|
|
- try {
|
|
|
- webSocketProcess.sendMessage("user_" + lifeUser.getUserPhone(), JSONObject.from(websocketVo).toJSONString());
|
|
|
- } catch (Exception e) {
|
|
|
- log.error("LifeUserOrderService requestRefund Stack={}", e);
|
|
|
- }
|
|
|
- }
|
|
|
- // 退款后更新库存
|
|
|
- Integer couponType = order.getCouponType();
|
|
|
- OrderCouponMiddle orderCouponMiddle = orderCouponMiddleMapper.selectOne(new QueryWrapper<OrderCouponMiddle>().eq("order_id", refundOrder.getOrderId()).last("limit 1"));
|
|
|
- Integer couponId = orderCouponMiddle.getCouponId();
|
|
|
-
|
|
|
- restoreInventory(couponType, refundCouponAmount, couponId);
|
|
|
- return R.success(refundMessage);
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 退款、取消订单时恢复库存
|
|
|
- * 根据优惠券类型恢复代金券或团购券的库存数量，并更新券的状态
|
|
|
- *
|
|
|
- * @param couponType 类型，1：代金券，2：团购
|
|
|
- * @param refundCouponAmount 团购券/代金券张数
|
|
|
- * @param couponId 团购券/代金券ID
|
|
|
- * @author alien-cloud
|
|
|
- * @date 2025-11-18
|
|
|
- */
|
|
|
- private void restoreInventory(Integer couponType, Integer refundCouponAmount, Integer couponId) {
|
|
|
- try {
|
|
|
- if (CouponTypeEnum.COUPON.getCode() == couponType) {
|
|
|
- // 代金券信息
|
|
|
- lifeCouponMapper.update(null, new LambdaUpdateWrapper<LifeCoupon>()
|
|
|
- .setSql("single_qty=single_qty+" + refundCouponAmount)
|
|
|
- .eq(LifeCoupon::getId, couponId));
|
|
|
-
|
|
|
- //判断当前时间在开始时间start_date和结束时间end_date之间，并且库存single_qty大于0，则修改状态status为5
|
|
|
- lifeCouponMapper.update(null, new LambdaUpdateWrapper<LifeCoupon>()
|
|
|
- .set(LifeCoupon::getStatus, 5)
|
|
|
- .eq(LifeCoupon::getId, couponId)
|
|
|
- .le(LifeCoupon::getStartDate, LocalDateTime.now())
|
|
|
- .ge(LifeCoupon::getEndDate, LocalDateTime.now())
|
|
|
- .gt(LifeCoupon::getSingleQty, 0));
|
|
|
-
|
|
|
-
|
|
|
- } else {
|
|
|
- // 团购信息
|
|
|
- lifeGroupBuyMainMapper.update(null, new LambdaUpdateWrapper<LifeGroupBuyMain>()
|
|
|
- .setSql("inventory_num=inventory_num+" + refundCouponAmount)
|
|
|
- .eq(LifeGroupBuyMain::getId, couponId));
|
|
|
-
|
|
|
- //判断当前时间在开始时间start_date和结束时间end_date之间，并且库存single_qty大于0，则修改状态status为5
|
|
|
- lifeGroupBuyMainMapper.update(null, new LambdaUpdateWrapper<LifeGroupBuyMain>()
|
|
|
- .set(LifeGroupBuyMain::getStatus, 5)
|
|
|
- .eq(LifeGroupBuyMain::getId, couponId)
|
|
|
- .le(LifeGroupBuyMain::getStartTimeValue, LocalDateTime.now())
|
|
|
- .ge(LifeGroupBuyMain::getEndTime, LocalDateTime.now())
|
|
|
- .gt(LifeGroupBuyMain::getInventoryNum, 0));
|
|
|
- }
|
|
|
- } catch (Exception e) {
|
|
|
- log.error("LifeUserOrderService，恢复团购券/代金券数量报错={}", e);
|
|
|
- }
|
|
|
-
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 退款检查
|
|
|
- * 校验订单是否满足退款条件，包括订单状态、退款金额等验证
|
|
|
- *
|
|
|
- * @param refundOrder 退款订单信息，包含订单ID和退款金额
|
|
|
- * @return Map<String, Object> 返回校验结果，包含是否可退款及原因
|
|
|
- * @author alien-cloud
|
|
|
- * @date 2025-11-18
|
|
|
- */
|
|
|
- public Map<String, Object> refundCheck(Map<String, String> refundOrder) {
|
|
|
- Map<String, Object> returnMap = new HashMap<>();
|
|
|
- LifeUserOrder order = lifeUserOrderMapper.selectById(refundOrder.get("orderId"));
|
|
|
- if (null == order) {
|
|
|
- returnMap.put("success", "不可退款");
|
|
|
- returnMap.put("reason", "未查询到订单");
|
|
|
- return returnMap;
|
|
|
- }
|
|
|
- if (order.getStatus() != 1) {
|
|
|
- returnMap.put("success", "不可退款");
|
|
|
- returnMap.put("reason", "当前订单状态不是待消费");
|
|
|
- return returnMap;
|
|
|
- }
|
|
|
- if (Double.parseDouble(order.getFinalPrice()) < Double.parseDouble(refundOrder.get("refundMoney"))) {
|
|
|
- returnMap.put("success", "不可退款");
|
|
|
- returnMap.put("reason", "退款金额大于实付款");
|
|
|
- return returnMap;
|
|
|
- }
|
|
|
- returnMap.put("success", "可以退款");
|
|
|
- return returnMap;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 根据订单号获取可用优惠券数量
|
|
|
- * 统计指定订单号下可用的优惠券数量
|
|
|
- *
|
|
|
- * @param orderNo 订单号
|
|
|
- * @return Integer 返回可用优惠券数量
|
|
|
- * @author alien-cloud
|
|
|
- * @date 2025-11-18
|
|
|
- */
|
|
|
- public Integer getAvailableOrderNumByOrderNo(String orderNo) {
|
|
|
- // 统计可用优惠劵数量
|
|
|
- return orderCouponMiddleMapper.selectCount(new QueryWrapper<OrderCouponMiddle>().inSql("id", "select id from life_user_order where order_no = " + orderNo));
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 导出订单Excel
|
|
|
- * 根据筛选条件查询订单数据并生成Excel文件，上传至OSS后返回文件地址
|
|
|
- *
|
|
|
- * @param orderNo 订单号
|
|
|
- * @param storeId 商户ID
|
|
|
- * @param quanName 优惠券名称
|
|
|
- * @param baojiaStatus 保价状态
|
|
|
- * @param status 订单状态
|
|
|
- * @return String 返回Excel文件的OSS地址
|
|
|
- * @throws IOException IO异常
|
|
|
- * @author alien-cloud
|
|
|
- * @date 2025-11-18
|
|
|
- */
|
|
|
- public String exportExcel(String orderNo, String storeId, String quanName, String baojiaStatus, String status) throws IOException {
|
|
|
- // 定义格式化模式
|
|
|
- DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
|
|
|
- List<LifeUserOrderExcelVo> lifeUserOrderExcelVos = new ArrayList<>();
|
|
|
- LambdaUpdateWrapper<LifeUserOrder> wrapper = new LambdaUpdateWrapper<>();
|
|
|
- wrapper.eq(StringUtils.isNotEmpty(status), LifeUserOrder::getStatus, status);
|
|
|
- wrapper.like(StringUtils.isNotEmpty(orderNo), LifeUserOrder::getOrderNo, orderNo);
|
|
|
- wrapper.like(StringUtils.isNotEmpty(storeId), LifeUserOrder::getStoreId, storeId);
|
|
|
-
|
|
|
- boolean flag = true;
|
|
|
- if (StringUtils.isNotEmpty(quanName)) {
|
|
|
- LambdaUpdateWrapper<LifeCoupon> wrapper1 = new LambdaUpdateWrapper<>();
|
|
|
- wrapper1.like(LifeCoupon::getName, quanName);
|
|
|
- List<LifeCoupon> quanList = lifeCouponMapper.selectList(wrapper1);
|
|
|
- List<String> idList = quanList.stream().map(LifeCoupon::getId).collect(Collectors.toList());
|
|
|
- if (CollectionUtils.isNotEmpty(idList)) {
|
|
|
- wrapper.in(LifeUserOrder::getQuanId, idList);
|
|
|
- } else {
|
|
|
- flag = false;
|
|
|
- }
|
|
|
- }
|
|
|
- if (flag) {
|
|
|
- wrapper.orderByAsc(LifeUserOrder::getStatus).orderByDesc(LifeUserOrder::getUpdatedTime);
|
|
|
- }
|
|
|
- List<Map<String, Object>> orderNoPage = lifeUserOrderMapper.selectMaps(wrapper);
|
|
|
- List<Object> orderNos = orderNoPage.stream()
|
|
|
- .map(record -> record.get("order_no"))
|
|
|
- .collect(Collectors.toList());
|
|
|
- // 根据订单号列表查询所有相关订单明细
|
|
|
- LambdaQueryWrapper<LifeUserOrder> detailWrapper = new LambdaQueryWrapper<>();
|
|
|
- detailWrapper.in(LifeUserOrder::getOrderNo, orderNos);
|
|
|
- List<LifeUserOrder> allOrderDetails = lifeUserOrderMapper.selectList(detailWrapper);
|
|
|
- // 按订单号分组处理
|
|
|
- Map<String, List<LifeUserOrder>> orderDetailsGrouped = allOrderDetails.stream()
|
|
|
- .collect(Collectors.groupingBy(LifeUserOrder::getOrderNo));
|
|
|
- int serialNumber = 0;
|
|
|
- for (Object orderDetails : orderDetailsGrouped.keySet()) {
|
|
|
- String orderNum = orderDetails.toString();
|
|
|
- List<LifeUserOrder> order = orderDetailsGrouped.getOrDefault(orderNum, Collections.emptyList());
|
|
|
- LifeUserOrder lifeUserOrder = order.get(0);
|
|
|
- LifeUserOrderExcelVo lifeUserOrderExcelVo = new LifeUserOrderExcelVo();
|
|
|
- if (lifeUserOrder.getCouponType() == 1) {
|
|
|
- if (null != lifeUserOrder.getQuanId() && !"".equals(lifeUserOrder.getQuanId())) {
|
|
|
- LifeDiscountCouponUser lifeDiscountCouponUser = lifeDiscountCouponUserMapper.selectById(lifeUserOrder.getQuanId());
|
|
|
- LifeCoupon quan = lifeCouponMapper.selectById(lifeDiscountCouponUser.getCouponId());
|
|
|
- if (null != quan) {
|
|
|
- lifeUserOrderExcelVo.setCouponName(quan.getName());
|
|
|
- lifeUserOrderExcelVo.setImage(quan.getImagePath());
|
|
|
- lifeUserOrderExcelVo.setPrice("¥" + quan.getPrice());
|
|
|
- }
|
|
|
- }
|
|
|
- } else {
|
|
|
- OrderCouponMiddle orderCouponMiddle = orderCouponMiddleMapper.selectOne(new LambdaQueryWrapper<OrderCouponMiddle>().eq(OrderCouponMiddle::getOrderId, lifeUserOrder.getId()));
|
|
|
- LifeGroupBuyMain lifeGroupBuyMain = lifeGroupBuyMainMapper.selectOne(new LambdaQueryWrapper<LifeGroupBuyMain>().eq(LifeGroupBuyMain::getId, orderCouponMiddle.getCouponId()));
|
|
|
- lifeUserOrderExcelVo.setCouponName(lifeGroupBuyMain.getGroupName());
|
|
|
- lifeUserOrderExcelVo.setImage(storeImgMapper.selectById(Integer.parseInt(lifeGroupBuyMain.getImageId())).getImgUrl());
|
|
|
- lifeUserOrderExcelVo.setPrice("¥" + lifeGroupBuyMain.getPreferentialPrice());
|
|
|
- }
|
|
|
- QueryWrapper<StoreInfoVo> queryWrapper = new QueryWrapper<>();
|
|
|
- queryWrapper.eq("a.id", lifeUserOrder.getStoreId());
|
|
|
- StoreInfoVo storeInfoVoOne = storeInfoMapper.getStoreInfoVoOne(queryWrapper);
|
|
|
- lifeUserOrderExcelVo.setSerialNumber(++serialNumber);
|
|
|
- lifeUserOrderExcelVo.setOrderNo(lifeUserOrder.getOrderNo());
|
|
|
- lifeUserOrderExcelVo.setStoreId(lifeUserOrder.getStoreId());
|
|
|
-
|
|
|
- lifeUserOrderExcelVo.setStoreContact(storeInfoVoOne.getStoreContact());
|
|
|
- lifeUserOrderExcelVo.setPhone(storeInfoVoOne.getStorePhone());
|
|
|
- if (lifeUserOrder.getStatus() == 4) {
|
|
|
- Instant instant = lifeUserOrder.getCancelTime().toInstant();
|
|
|
- String formattedTime = instant.atZone(ZoneId.systemDefault()).toLocalDateTime().format(formatter);
|
|
|
- lifeUserOrderExcelVo.setCancelTime(formattedTime);
|
|
|
- } else if(lifeUserOrder.getStatus() != 0){
|
|
|
- Instant instant = lifeUserOrder.getPayTime().toInstant();
|
|
|
- // 格式化时间
|
|
|
- String formattedTime = instant.atZone(ZoneId.systemDefault()).toLocalDateTime().format(formatter);
|
|
|
- lifeUserOrderExcelVo.setPayTime(formattedTime);
|
|
|
- lifeUserOrderExcelVo.setFinishTime(formattedTime);
|
|
|
- }
|
|
|
- lifeUserOrderExcelVo.setOrderStatus(String.valueOf(lifeUserOrder.getStatus()));
|
|
|
- // 订单状态转换
|
|
|
- switch (lifeUserOrder.getStatus()) {
|
|
|
- case 0:
|
|
|
- lifeUserOrderExcelVo.setOrderStatus("待使用");
|
|
|
- break;
|
|
|
- case 1:
|
|
|
- lifeUserOrderExcelVo.setOrderStatus("已核销");
|
|
|
- break;
|
|
|
- case 2:
|
|
|
- lifeUserOrderExcelVo.setOrderStatus("已过期");
|
|
|
- break;
|
|
|
- case 3:
|
|
|
- lifeUserOrderExcelVo.setOrderStatus("待退款");
|
|
|
- break;
|
|
|
- case 4:
|
|
|
- lifeUserOrderExcelVo.setOrderStatus("已退款");
|
|
|
- break;
|
|
|
- case 5:
|
|
|
- lifeUserOrderExcelVo.setOrderStatus("退款失败");
|
|
|
- break;
|
|
|
- case 6:
|
|
|
- lifeUserOrderExcelVo.setOrderStatus("已取消");
|
|
|
- break;
|
|
|
- default:
|
|
|
- lifeUserOrderExcelVo.setOrderStatus("未知状态");
|
|
|
- }
|
|
|
- lifeUserOrderExcelVos.add(lifeUserOrderExcelVo);
|
|
|
- }
|
|
|
- String fileName = UUID.randomUUID().toString().replace("-", "");
|
|
|
- String filePath = ExcelGenerator.generateExcel(excelPath + excelGeneratePath + fileName + ".xlsx", lifeUserOrderExcelVos, LifeUserOrderExcelVo.class);
|
|
|
- return aliOSSUtil.uploadFile(new File(filePath), "excel/" + fileName + ".xlsx");
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 创建用户订单
|
|
|
- * 创建订单并处理相关业务，包括订单信息保存、券码生成、优惠券状态更新、库存扣减等
|
|
|
- *
|
|
|
- * @param lifeUserOrderDto 订单数据传输对象，包含订单创建所需的所有信息
|
|
|
- * @return Map<String, Object> 返回创建结果，包含订单号、订单信息等
|
|
|
- * @author alien-cloud
|
|
|
- * @date 2025-11-18
|
|
|
- */
|
|
|
- @Transactional(rollbackFor = Exception.class)
|
|
|
- public Map<String, Object> createUserOrder(LifeUserOrderDto lifeUserOrderDto) {
|
|
|
- Date date = new Date();
|
|
|
- //1.创建订单
|
|
|
- LifeUserOrder lifeUserOrder = new LifeUserOrder();
|
|
|
- // 用户id
|
|
|
- lifeUserOrder.setUserId(lifeUserOrderDto.getUserId());
|
|
|
- // 店铺id
|
|
|
- lifeUserOrder.setStoreId(lifeUserOrderDto.getStoreId());
|
|
|
- // 订单号
|
|
|
- lifeUserOrder.setOrderNo(lifeUserOrderDto.getOrderNo());
|
|
|
- // 订单订单字符串
|
|
|
- lifeUserOrder.setOrderStr(lifeUserOrderDto.getOrderStr());
|
|
|
- // 优惠券id
|
|
|
- lifeUserOrder.setQuanId(lifeUserOrderDto.getYhquanId());
|
|
|
- // 原价金额
|
|
|
- lifeUserOrder.setPrice(lifeUserOrderDto.getPrice());
|
|
|
- // 付款金额
|
|
|
- lifeUserOrder.setFinalPrice(lifeUserOrderDto.getFinalPrice());
|
|
|
- // 订单类型
|
|
|
- lifeUserOrder.setCouponType(null == lifeUserOrderDto.getCouponType() ? 1 : lifeUserOrderDto.getCouponType());
|
|
|
- // 订单状态
|
|
|
- lifeUserOrder.setStatus(null == lifeUserOrderDto.getStatus() ? 0 : lifeUserOrderDto.getStatus());
|
|
|
- // 购买时间
|
|
|
- lifeUserOrder.setBuyTime(date);
|
|
|
- this.saveOrUpdate(lifeUserOrder);
|
|
|
-
|
|
|
- //3.根据购买数量增加中间关系 订单id+券编号 确定一条数据
|
|
|
- int buyCount = lifeUserOrderDto.getCount();
|
|
|
- BigDecimal totalPrice = new BigDecimal(lifeUserOrderDto.getFinalPrice());
|
|
|
- BigDecimal countDecimal = new BigDecimal(buyCount);
|
|
|
- BigDecimal perPrice = totalPrice.divide(countDecimal, 2, RoundingMode.DOWN);
|
|
|
- BigDecimal lastPrice = totalPrice.subtract(perPrice.multiply(countDecimal.subtract(BigDecimal.ONE)));
|
|
|
-
|
|
|
- //2.判断是否使用优惠券
|
|
|
- //查询优惠券信息
|
|
|
- BigDecimal avgDiscountCouponPrice = BigDecimal.ZERO;
|
|
|
- BigDecimal avgDiscountCouponLastPrice = BigDecimal.ZERO;
|
|
|
- LifeDiscountCoupon lifeDiscountCoupon = null;
|
|
|
- if (StringUtils.isNotEmpty(lifeUserOrderDto.getYhquanId())) {
|
|
|
- LifeDiscountCouponUser lifeDiscountCouponUser = lifeDiscountCouponUserMapper.selectById(lifeUserOrderDto.getYhquanId());
|
|
|
- //将优惠券状态变更为已使用
|
|
|
- lifeDiscountCouponUser.setStatus(Integer.parseInt(DiscountCouponEnum.HAVE_BEEN_USED.getValue()));
|
|
|
- //将优惠券使用时间存入
|
|
|
- lifeDiscountCouponUser.setUseTime(date);
|
|
|
- lifeDiscountCouponUserMapper.updateById(lifeDiscountCouponUser);
|
|
|
- lifeDiscountCoupon = lifeDiscountCouponMapper.selectById(lifeDiscountCouponUser.getCouponId());
|
|
|
- avgDiscountCouponPrice = lifeDiscountCoupon.getNominalValue().divide(countDecimal, 2, RoundingMode.DOWN);
|
|
|
- avgDiscountCouponLastPrice = lifeDiscountCoupon.getNominalValue().subtract(avgDiscountCouponPrice.multiply(countDecimal.subtract(BigDecimal.ONE)));
|
|
|
- }
|
|
|
-
|
|
|
- for (int i = 0; i < buyCount; i++) {
|
|
|
- String code = UniqueRandomNumGenerator.generateUniqueCode(12);
|
|
|
- OrderCouponMiddle orderCouponMiddle = new OrderCouponMiddle();
|
|
|
- // 订单id
|
|
|
- orderCouponMiddle.setOrderId(lifeUserOrder.getId());
|
|
|
- // 团购/代金券id
|
|
|
- orderCouponMiddle.setCouponId(lifeUserOrderDto.getCouponId());
|
|
|
- // 团购/代金券 code
|
|
|
- orderCouponMiddle.setCouponCode(code);
|
|
|
- // 团购/代金券价格
|
|
|
- orderCouponMiddle.setPrice(i == buyCount - 1 ? lastPrice : perPrice);
|
|
|
- // 订单状态
|
|
|
- orderCouponMiddle.setStatus(0);
|
|
|
- // 设置平均优惠价
|
|
|
- orderCouponMiddle.setAvgDiscountCouponPrice(i == buyCount - 1 ? avgDiscountCouponLastPrice : avgDiscountCouponPrice);
|
|
|
- orderCouponMiddleService.save(orderCouponMiddle);
|
|
|
- }
|
|
|
- //4. 代金券/团购库存扣除 coupon_type 1 代金券 2团购
|
|
|
- Map<String, Object> returnMap = new HashMap<>();
|
|
|
- int soldOutStatus = CouponStatusEnum.SOLD_OUT.getCode();
|
|
|
- int updateRows = 0;
|
|
|
-
|
|
|
- if (lifeUserOrderDto.getCouponType() == 2) {
|
|
|
- // 团购库存：原子扣减
|
|
|
- updateRows = lifeGroupBuyMainMapper.deductInventoryAtomically(
|
|
|
- lifeUserOrderDto.getCouponId(),
|
|
|
- buyCount,
|
|
|
- soldOutStatus
|
|
|
- );
|
|
|
- } else {
|
|
|
- // 代金券库存：原子扣减
|
|
|
- updateRows = lifeCouponMapper.deductInventoryAtomically(
|
|
|
- lifeUserOrderDto.getCouponId(),
|
|
|
- buyCount,
|
|
|
- soldOutStatus
|
|
|
- );
|
|
|
- }
|
|
|
-// 判断库存扣减结果
|
|
|
- if (updateRows == 0) {
|
|
|
- log.error("couponid:" + lifeUserOrderDto.getCouponId() + " 库存不足，当前购买数量:" + buyCount);
|
|
|
- // 手动抛出异常，触发事务回滚（回滚之前创建的订单和优惠券状态变更）
|
|
|
- throw new RuntimeException("库存不足，下单失败");
|
|
|
- }
|
|
|
- returnMap.put("success", "下单成功");
|
|
|
- returnMap.put("orderNo", lifeUserOrderDto.getOrderNo());
|
|
|
- returnMap.put("lifeUserOrder", lifeUserOrder);
|
|
|
- return returnMap;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 更新用户订单
|
|
|
- * 根据订单状态更新订单信息，包括支付、取消、过期等状态的处理，并更新库存
|
|
|
- *
|
|
|
- * @param lifeUserOrderDto 订单数据传输对象，包含需要更新的订单信息
|
|
|
- * @return boolean 返回更新是否成功
|
|
|
- * @author alien-cloud
|
|
|
- * @date 2025-11-18
|
|
|
- */
|
|
|
- @Transactional
|
|
|
- public boolean updateUserOrder(LifeUserOrderDto lifeUserOrderDto) {
|
|
|
- Date date = new Date();
|
|
|
- LifeUserOrder lifeUserOrder = lifeUserOrderMapper.selectById(lifeUserOrderDto.getId());
|
|
|
- if (null == lifeUserOrder) {
|
|
|
- log.error("updateUserOrder未查询到订单");
|
|
|
- return false;
|
|
|
- }
|
|
|
- UpdateWrapper<OrderCouponMiddle> orderCouponMiddleUpdateWrapper = new UpdateWrapper<>();
|
|
|
- orderCouponMiddleUpdateWrapper.eq("order_id", lifeUserOrderDto.getId());
|
|
|
- // 根据状态判断怎么更新数据 目前只进行已支付，已取消，已过期判断
|
|
|
- switch (lifeUserOrderDto.getStatus()) {
|
|
|
- case 1:
|
|
|
- lifeUserOrder.setPayTime(date);
|
|
|
- lifeUserOrder.setPayMethod(lifeUserOrderDto.getPayMethod());
|
|
|
- lifeUserOrder.setStatus(lifeUserOrderDto.getStatus());
|
|
|
- lifeUserOrder.setOrderNo(lifeUserOrderDto.getOrderNo());
|
|
|
- orderCouponMiddleUpdateWrapper.set("status", lifeUserOrderDto.getStatus());
|
|
|
- break;
|
|
|
- case 3:
|
|
|
- case 4:
|
|
|
- lifeUserOrder.setStatus(lifeUserOrderDto.getStatus());
|
|
|
- lifeUserOrder.setCancelTime(date);
|
|
|
- lifeUserOrder.setFinishTime(date);
|
|
|
- orderCouponMiddleUpdateWrapper.set("status", lifeUserOrderDto.getStatus());
|
|
|
- break;
|
|
|
- }
|
|
|
- // 查询券id->查询一个
|
|
|
- int updateNum = orderCouponMiddleMapper.update(null, orderCouponMiddleUpdateWrapper);
|
|
|
- if (1 != lifeUserOrderDto.getStatus()) {
|
|
|
- List<OrderCouponMiddle> orderCouponMiddles = orderCouponMiddleMapper.selectList(new QueryWrapper<OrderCouponMiddle>().eq("order_id", lifeUserOrderDto.getId()));
|
|
|
- if (0 != updateNum && orderCouponMiddles.size() > 0) {
|
|
|
- Integer couponId = orderCouponMiddles.get(0).getCouponId();
|
|
|
- // 2.过期后更新库存
|
|
|
- Integer couponType = lifeUserOrder.getCouponType();
|
|
|
- restoreInventory(couponType, updateNum, couponId);
|
|
|
- } else {
|
|
|
- log.error("取消失败，未查询到订单");
|
|
|
- throw new RuntimeException("取消失败，未查询到订单");
|
|
|
- }
|
|
|
- }
|
|
|
- return this.saveOrUpdate(lifeUserOrder);
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 删除用户订单
|
|
|
- * 删除订单前需要判断订单状态，只有已完成或已退款的订单才可以删除，同时删除订单中间关系数据
|
|
|
- *
|
|
|
- * @param orderId 订单ID
|
|
|
- * @return boolean 返回删除是否成功
|
|
|
- * @author alien-cloud
|
|
|
- * @date 2025-11-18
|
|
|
- */
|
|
|
- @Transactional
|
|
|
- public boolean deleteUserOrder(String orderId) {
|
|
|
- LifeUserOrder lifeUserOrder = lifeUserOrderMapper.selectById(orderId);
|
|
|
- if (null == lifeUserOrder) {
|
|
|
- log.error("deleteUserOrder未查询到订单");
|
|
|
- return false;
|
|
|
- }
|
|
|
- // 判断订单状态
|
|
|
- // 已核销才可以删除和已退款可以核销
|
|
|
- if (lifeUserOrder.getStatus() == OrderStatusEnum.WAIT_USE.getStatus()) {
|
|
|
- log.error("deleteUserOrder订单状态错误,订单完成才可以删除");
|
|
|
- return false;
|
|
|
- }
|
|
|
- // 删除中间关系
|
|
|
- UpdateWrapper<OrderCouponMiddle> orderCouponMiddleUpdateWrapper = new UpdateWrapper<>();
|
|
|
- orderCouponMiddleUpdateWrapper.eq("order_id", orderId);
|
|
|
- return this.removeById(orderId) && orderCouponMiddleService.remove(orderCouponMiddleUpdateWrapper);
|
|
|
- }
|
|
|
|
|
|
/**
|
|
|
* 查询用户订单列表
|
|
|
@@ -1148,241 +192,5 @@ public class LifeUserOrderPlatformServiceImpl extends ServiceImpl<LifeUserOrderM
|
|
|
expectIncome = expectIncome.subtract(expectIncome.multiply(commissionRate)).setScale(2, RoundingMode.DOWN);
|
|
|
lifeUserOrderVo.setExpectIncome(expectIncome);
|
|
|
}
|
|
|
-
|
|
|
- /**
|
|
|
- * 平台端-查询订单列表
|
|
|
- * 平台管理端使用，支持多维度查询订单信息
|
|
|
- *
|
|
|
- * @param page 页码
|
|
|
- * @param size 每页数量
|
|
|
- * @param orderNo 订单号
|
|
|
- * @param orderStatus 订单状态
|
|
|
- * @param couponName 优惠券名称
|
|
|
- * @param couponType 优惠券类型
|
|
|
- * @param storeName 店铺名称
|
|
|
- * @param buyStartTime 购买时间开始
|
|
|
- * @param buyEndTime 购买时间结束
|
|
|
- * @param payStartTime 支付时间开始
|
|
|
- * @param payEndTime 支付时间结束
|
|
|
- * @param finishStartTime 完成时间开始
|
|
|
- * @param finishEndTime 完成时间结束
|
|
|
- * @return IPage<LifeUserOrderVo> 返回分页订单列表
|
|
|
- * @author alien-cloud
|
|
|
- * @date 2025-11-18
|
|
|
- */
|
|
|
- public IPage<LifeUserOrderVo> queryOrderList(Integer page, Integer size, String orderNo, String orderStatus, String couponName, String couponType, String storeName, String buyStartTime, String buyEndTime, String payStartTime, String payEndTime, String finishStartTime, String finishEndTime) {
|
|
|
- IPage<LifeUserOrderVo> brandedPage = new Page<>(page, size);
|
|
|
- QueryWrapper<LifeUserOrderVo> lifeUserOrderQueryWrapper = new QueryWrapper<>();
|
|
|
- lifeUserOrderQueryWrapper.like(org.apache.commons.lang3.StringUtils.isNotBlank(orderNo), "luo.order_no", orderNo);
|
|
|
- lifeUserOrderQueryWrapper.like(org.apache.commons.lang3.StringUtils.isNotBlank(couponName), "tc.coupon_name", couponName);
|
|
|
- lifeUserOrderQueryWrapper.eq(org.apache.commons.lang3.StringUtils.isNotBlank(couponType), "tc.coupon_type", couponType);
|
|
|
- lifeUserOrderQueryWrapper.like(org.apache.commons.lang3.StringUtils.isNotBlank(storeName), "si.store_name", storeName);
|
|
|
- lifeUserOrderQueryWrapper.gt(org.apache.commons.lang3.StringUtils.isNotBlank(buyStartTime), "luo.buy_time", buyStartTime + " 00:00:00");
|
|
|
- lifeUserOrderQueryWrapper.lt(org.apache.commons.lang3.StringUtils.isNotBlank(buyEndTime), "luo.buy_time", buyEndTime + " 23:59:59");
|
|
|
- lifeUserOrderQueryWrapper.gt(org.apache.commons.lang3.StringUtils.isNotBlank(payStartTime), "luo.pay_time", payStartTime + " 00:00:00");
|
|
|
- lifeUserOrderQueryWrapper.lt(org.apache.commons.lang3.StringUtils.isNotBlank(payEndTime), "luo.pay_time", payEndTime + " 23:59:59");
|
|
|
- lifeUserOrderQueryWrapper.gt(org.apache.commons.lang3.StringUtils.isNotBlank(finishStartTime), "luo.finish_time", finishStartTime + " 00:00:00");
|
|
|
- lifeUserOrderQueryWrapper.lt(org.apache.commons.lang3.StringUtils.isNotBlank(finishEndTime), "luo.finish_time", finishEndTime + " 23:59:59");
|
|
|
-// @ApiImplicitParam(name = "orderStatus", value = "订单状态,-1，全部（可以不传）；0，待支付;1，已支付/待使用;2，已核销；3，已过期;4，已取消;5.已退款，全退款了才算", required = false),
|
|
|
- // 提取SQL基础部分，避免重复定义
|
|
|
-// String baseSql = "select DISTINCT ocm1.order_id from order_coupon_middle ocm1 where 1=1";
|
|
|
-
|
|
|
- if (!"-1".equals(orderStatus)) {
|
|
|
- // 非-1状态：直接添加状态条件
|
|
|
-// String sql = baseSql + " and ocm1.status = " + orderStatus;
|
|
|
-// lifeUserOrderQueryWrapper.inSql("luo.id", sql);
|
|
|
- lifeUserOrderQueryWrapper.eq("luo.status", orderStatus);
|
|
|
- }
|
|
|
- lifeUserOrderQueryWrapper.groupBy("luo.id");
|
|
|
- IPage<LifeUserOrderVo> lifeUserOrderVoIPage = lifeUserOrderMapper.queryUserOrderList(brandedPage, lifeUserOrderQueryWrapper);
|
|
|
-
|
|
|
- if (!"-1".equals(orderStatus)) {
|
|
|
- lifeUserOrderVoIPage.getRecords().forEach(x -> x.setStatus(Integer.parseInt(orderStatus)));
|
|
|
- }
|
|
|
- return lifeUserOrderVoIPage;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 平台-查询订单列表
|
|
|
- * 平台订单查询接口，支持特定状态筛选，用于平台订单管理
|
|
|
- *
|
|
|
- * @param page 页码
|
|
|
- * @param size 每页数量
|
|
|
- * @param orderNo 订单号
|
|
|
- * @param orderStatus 订单状态
|
|
|
- * @param couponName 优惠券名称
|
|
|
- * @param couponType 优惠券类型
|
|
|
- * @param storeName 店铺名称
|
|
|
- * @param buyStartTime 购买时间开始
|
|
|
- * @param buyEndTime 购买时间结束
|
|
|
- * @param payStartTime 支付时间开始
|
|
|
- * @param payEndTime 支付时间结束
|
|
|
- * @param finishStartTime 完成时间开始
|
|
|
- * @param finishEndTime 完成时间结束
|
|
|
- * @return IPage<LifeUserOrderVo> 返回分页订单列表
|
|
|
- * @author alien-cloud
|
|
|
- * @date 2025-11-18
|
|
|
- */
|
|
|
- public IPage<LifeUserOrderVo> queryPlatformOrderList(Integer page, Integer size, String orderNo, String orderStatus, String couponName, String couponType, String storeName, String buyStartTime, String buyEndTime, String payStartTime, String payEndTime, String finishStartTime, String finishEndTime) {
|
|
|
- IPage<LifeUserOrderVo> brandedPage = new Page<>(page, size);
|
|
|
- QueryWrapper<LifeUserOrderVo> lifeUserOrderQueryWrapper = new QueryWrapper<>();
|
|
|
- lifeUserOrderQueryWrapper.like(org.apache.commons.lang3.StringUtils.isNotBlank(orderNo), "luo.order_no", orderNo);
|
|
|
- lifeUserOrderQueryWrapper.like(org.apache.commons.lang3.StringUtils.isNotBlank(couponName), "tc.coupon_name", couponName);
|
|
|
- lifeUserOrderQueryWrapper.eq(org.apache.commons.lang3.StringUtils.isNotBlank(couponType), "tc.coupon_type", couponType);
|
|
|
- lifeUserOrderQueryWrapper.like(org.apache.commons.lang3.StringUtils.isNotBlank(storeName), "si.store_name", storeName);
|
|
|
- lifeUserOrderQueryWrapper.gt(org.apache.commons.lang3.StringUtils.isNotBlank(buyStartTime), "luo.buy_time", buyStartTime + " 00:00:00");
|
|
|
- lifeUserOrderQueryWrapper.lt(org.apache.commons.lang3.StringUtils.isNotBlank(buyEndTime), "luo.buy_time", buyEndTime + " 23:59:59");
|
|
|
- lifeUserOrderQueryWrapper.gt(org.apache.commons.lang3.StringUtils.isNotBlank(payStartTime), "luo.pay_time", payStartTime + " 00:00:00");
|
|
|
- lifeUserOrderQueryWrapper.lt(org.apache.commons.lang3.StringUtils.isNotBlank(payEndTime), "luo.pay_time", payEndTime + " 23:59:59");
|
|
|
- lifeUserOrderQueryWrapper.gt(org.apache.commons.lang3.StringUtils.isNotBlank(finishStartTime), "luo.finish_time", finishStartTime + " 00:00:00");
|
|
|
- lifeUserOrderQueryWrapper.lt(org.apache.commons.lang3.StringUtils.isNotBlank(finishEndTime), "luo.finish_time", finishEndTime + " 23:59:59");
|
|
|
-
|
|
|
-// @ApiImplicitParam(name = "orderStatus", value = "订单状态,-1，全部（可以不传）；0，待支付;1，已支付/待使用;2，已核销；3，已过期;4，已取消;5.已退款，全退款了才算", required = false),
|
|
|
- // 提取SQL基础部分，避免重复定义
|
|
|
-// String baseSql = "select DISTINCT ocm1.order_id from order_coupon_middle ocm1 where 1=1";
|
|
|
-
|
|
|
- if (!"-1".equals(orderStatus)) {
|
|
|
- // 非-1状态：直接添加状态条件
|
|
|
-// String sql = baseSql + " and ocm1.status = " + orderStatus;
|
|
|
-// lifeUserOrderQueryWrapper.inSql("luo.id", sql);
|
|
|
- lifeUserOrderQueryWrapper.eq("luo.status", orderStatus);
|
|
|
- } else {
|
|
|
- lifeUserOrderQueryWrapper.in("luo.status", 0,1,4,5,7);
|
|
|
- }
|
|
|
-
|
|
|
- lifeUserOrderQueryWrapper.groupBy("luo.id");
|
|
|
- IPage<LifeUserOrderVo> lifeUserOrderVoIPage = lifeUserOrderMapper.queryPlatformOrderList(brandedPage, lifeUserOrderQueryWrapper);
|
|
|
-
|
|
|
- if (!"-1".equals(orderStatus)) {
|
|
|
- lifeUserOrderVoIPage.getRecords().forEach(x -> x.setStatus(Integer.parseInt(orderStatus)));
|
|
|
- }
|
|
|
- return lifeUserOrderVoIPage;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 平台端-查询订单详情
|
|
|
- * 平台管理端查询订单详情，包含退款记录、预计收入等信息
|
|
|
- *
|
|
|
- * @param orderId 订单ID
|
|
|
- * @return R 返回订单详情信息
|
|
|
- * @author alien-cloud
|
|
|
- * @date 2025-11-18
|
|
|
- */
|
|
|
- public R queryOrderDetail(String orderId) {
|
|
|
- LifeUserOrderVo lifeUserOrderVo = lifeUserOrderMapper.queryUserOrderDetail(orderId, null);
|
|
|
- if (null == lifeUserOrderVo) {
|
|
|
- log.error("queryUserOrderDetail未查询到订单");
|
|
|
- return R.fail("未查询到订单");
|
|
|
- }
|
|
|
- // 退款记录
|
|
|
- calcExpectIncome(lifeUserOrderVo);
|
|
|
- lifeUserOrderVo.setCouponCount(lifeUserOrderVo.getOrderCouponMiddleList().size());
|
|
|
- return R.data(lifeUserOrderVo);
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 团购/代金券-校验用户是否可以购买
|
|
|
- * 校验购买前的各项条件，包括券状态、库存、限购、活动时间等
|
|
|
- *
|
|
|
- * @param couponId 团购/代金券ID
|
|
|
- * @param couponType 团购/代金券类型，1：代金券，2：团购券
|
|
|
- * @param userId 用户ID
|
|
|
- * @param storeId 商户ID
|
|
|
- * @param count 购买数量
|
|
|
- * @return Map<String, Object> 返回校验结果，包含是否可购买及原因
|
|
|
- * @author alien-cloud
|
|
|
- * @date 2025-11-18
|
|
|
- */
|
|
|
- public Map<String, Object> buyCouponCheck(String couponId, Integer couponType, String userId, String storeId, Integer count) {
|
|
|
- Map<String, Object> returnMap = new HashMap<>();
|
|
|
- // 获取团购/代金券信息
|
|
|
- Integer status = 0;
|
|
|
- // 限购数量， 已购数量
|
|
|
- Integer buyLimit = 0;
|
|
|
- Integer buyCount = 0;
|
|
|
- // 库存
|
|
|
- Integer stockQty = 0;
|
|
|
- // 结束时间
|
|
|
- Date endTime = null;
|
|
|
- if (couponType == CouponTypeEnum.GROUP_BUY.getCode()) {
|
|
|
- // 团购
|
|
|
- LifeGroupBuyMain lifeGroupBuyMain = lifeGroupBuyMainMapper.selectById(couponId);
|
|
|
- status = lifeGroupBuyMain.getStatus();
|
|
|
- // 限购类型
|
|
|
- Integer quotaType = lifeGroupBuyMain.getQuotaType();
|
|
|
- if (0 != quotaType) {
|
|
|
- // 限购数量
|
|
|
- buyLimit = Integer.parseInt(lifeGroupBuyMain.getQuotaValue());
|
|
|
- // 已购数量
|
|
|
- buyCount = orderCouponMiddleMapper.selectCount(new QueryWrapper<OrderCouponMiddle>().eq("coupon_id", couponId).notIn("status", OrderStatusEnum.CANCEL.getStatus(), OrderStatusEnum.REFUND.getStatus())
|
|
|
- .inSql("order_id", "select id from life_user_order where user_id = " + userId + " and store_id = " + storeId));
|
|
|
- }
|
|
|
- // 库存 inventory_num
|
|
|
- stockQty = lifeGroupBuyMain.getInventoryNum();
|
|
|
- endTime = lifeGroupBuyMain.getEndTime();
|
|
|
- } else if (couponType == CouponTypeEnum.COUPON.getCode()) {
|
|
|
- // 代金券
|
|
|
- LifeCoupon lifeCoupon = lifeCouponMapper.selectById(couponId);
|
|
|
- status = lifeCoupon.getStatus();
|
|
|
- // 限购数量
|
|
|
- buyLimit = Integer.parseInt(lifeCoupon.getPurchaseLimitCode());
|
|
|
- // 已购数量
|
|
|
- buyCount = orderCouponMiddleMapper.selectCount(new QueryWrapper<OrderCouponMiddle>().eq("coupon_id", couponId).notIn("status", OrderStatusEnum.CANCEL.getStatus(), OrderStatusEnum.REFUND.getStatus())
|
|
|
- .inSql("order_id", "select id from life_user_order where user_id = " + userId + " and store_id = " + storeId));
|
|
|
- stockQty = lifeCoupon.getSingleQty();
|
|
|
- endTime = lifeCoupon.getEndDate();
|
|
|
- } else {
|
|
|
- log.error("buyCouponCheck-团购/代金券类型错误");
|
|
|
- returnMap.put("success", false);
|
|
|
- returnMap.put("reason", "团购/代金券类型错误");
|
|
|
- return returnMap;
|
|
|
- }
|
|
|
- // 状态(0草稿/1待审核/2未开始/3审核拒绝/4已售罄/5进行中/6已下架/7已结束/8=2+手动下架)
|
|
|
- if (status != CouponStatusEnum.ONGOING.getCode()) {
|
|
|
- returnMap.put("success", false);
|
|
|
- if (status == CouponStatusEnum.SOLD_OUT.getCode()) {
|
|
|
- returnMap.put("reason", "团购/代金券已售罄");
|
|
|
- } else {
|
|
|
- returnMap.put("reason", "团购/代金券未开始");
|
|
|
- }
|
|
|
- return returnMap;
|
|
|
- }
|
|
|
- // 限购
|
|
|
- if (0 != buyLimit) {
|
|
|
- if (buyCount + count > buyLimit) {
|
|
|
- returnMap.put("success", false);
|
|
|
- returnMap.put("reason", "已达限购上限");
|
|
|
- return returnMap;
|
|
|
- }
|
|
|
- }
|
|
|
- // 库存
|
|
|
- if (count > stockQty) {
|
|
|
- returnMap.put("success", false);
|
|
|
- returnMap.put("reason", "购买数量大于库存数量");
|
|
|
- return returnMap;
|
|
|
- }
|
|
|
- // 时间
|
|
|
- Date now = new Date();
|
|
|
- Calendar calendar = Calendar.getInstance();
|
|
|
- calendar.setTime(now);
|
|
|
- calendar.set(Calendar.HOUR_OF_DAY, 0);
|
|
|
- calendar.set(Calendar.MINUTE, 0);
|
|
|
- calendar.set(Calendar.SECOND, 0);
|
|
|
- calendar.set(Calendar.MILLISECOND, 0);
|
|
|
- Date nowDay = calendar.getTime();
|
|
|
- if (nowDay.compareTo(endTime) > 0) {
|
|
|
- if (couponType == CouponTypeEnum.GROUP_BUY.getCode()) {
|
|
|
- lifeGroupBuyMainMapper.update(null, new UpdateWrapper<LifeGroupBuyMain>().set("status", CouponStatusEnum.ENDED.getCode()).eq("id", couponId));
|
|
|
- } else {
|
|
|
- lifeCouponMapper.update(null, new UpdateWrapper<LifeCoupon>().set("status", CouponStatusEnum.ENDED.getCode()).eq("id", couponId));
|
|
|
- }
|
|
|
- returnMap.put("success", false);
|
|
|
- returnMap.put("reason", "活动已结束");
|
|
|
- return returnMap;
|
|
|
- }
|
|
|
- returnMap.put("success", true);
|
|
|
- returnMap.put("reason", "可以支付");
|
|
|
- return returnMap;
|
|
|
- }
|
|
|
}
|
|
|
|
zjy