From 8efa44bde7337adba0247b4e58c37db90adc420b Mon Sep 17 00:00:00 2001 From: czc Date: Mon, 10 Jul 2023 18:04:16 +0800 Subject: [PATCH] =?UTF-8?q?H5=E5=8F=96=E6=B6=88=E8=AE=A2=E5=8D=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../cyl/h5/controller/H5OrderController.java | 28 +++++++++++ .../h5/pojo/request/CancelOrderRequest.java | 14 ++++++ .../com/cyl/h5/service/H5OrderService.java | 49 +++++++++++++++++++ .../cyl/manager/oms/mapper/OrderMapper.java | 2 + .../service/OrderOperateHistoryService.java | 3 +- .../main/resources/mapper/oms/OrderMapper.xml | 11 +++++ 6 files changed, 106 insertions(+), 1 deletion(-) create mode 100644 ruoyi-mall/src/main/java/com/cyl/h5/pojo/request/CancelOrderRequest.java diff --git a/ruoyi-mall/src/main/java/com/cyl/h5/controller/H5OrderController.java b/ruoyi-mall/src/main/java/com/cyl/h5/controller/H5OrderController.java index 50094ab..213e0e4 100644 --- a/ruoyi-mall/src/main/java/com/cyl/h5/controller/H5OrderController.java +++ b/ruoyi-mall/src/main/java/com/cyl/h5/controller/H5OrderController.java @@ -1,13 +1,18 @@ package com.cyl.h5.controller; +import cn.hutool.core.collection.CollectionUtil; +import com.alibaba.fastjson.JSONObject; import com.cyl.h5.pojo.dto.OrderCreateDTO; +import com.cyl.h5.pojo.request.CancelOrderRequest; import com.cyl.h5.pojo.vo.CountOrderVO; import com.cyl.h5.pojo.vo.H5OrderVO; import com.cyl.h5.pojo.vo.OrderCalcVO; import com.cyl.h5.pojo.vo.form.OrderSubmitForm; import com.cyl.h5.service.H5OrderService; +import com.cyl.manager.oms.domain.Order; import com.cyl.manager.ums.domain.Member; import com.ruoyi.common.constant.Constants; +import com.ruoyi.common.core.domain.AjaxResult; import com.ruoyi.common.core.redis.RedisService; import com.ruoyi.framework.config.LocalDataUtil; import io.swagger.annotations.ApiOperation; @@ -18,6 +23,8 @@ import org.springframework.data.domain.Pageable; import org.springframework.http.ResponseEntity; import org.springframework.web.bind.annotation.*; +import java.util.List; + @RestController @RequestMapping("/h5/order") @Slf4j @@ -103,4 +110,25 @@ public class H5OrderController { Long memberId = member.getId(); return ResponseEntity.ok(service.orderNumCount(memberId)); } + + @ApiOperation("取消订单") + @PostMapping("/orderCancel") + public ResponseEntity orderCancel(@RequestBody CancelOrderRequest request){ + Member member = (Member) LocalDataUtil.getVar(Constants.MEMBER_INFO); + String redisKey = "h5_oms_order_cancel_"+ request.getIdList().get(0); + String redisValue = request.getIdList().get(0)+"_"+System.currentTimeMillis(); + try{ + redisService.lock(redisKey,redisValue,60); + return ResponseEntity.ok(service.orderBatchCancel(request, member.getId())); + }catch (Exception e){ + log.error("订单取消方法异常",e); + throw new RuntimeException("订单取消失败"); + }finally { + try { + redisService.unLock(redisKey,redisValue); + }catch (Exception e){ + log.error("",e); + } + } + } } diff --git a/ruoyi-mall/src/main/java/com/cyl/h5/pojo/request/CancelOrderRequest.java b/ruoyi-mall/src/main/java/com/cyl/h5/pojo/request/CancelOrderRequest.java new file mode 100644 index 0000000..79a52c4 --- /dev/null +++ b/ruoyi-mall/src/main/java/com/cyl/h5/pojo/request/CancelOrderRequest.java @@ -0,0 +1,14 @@ +package com.cyl.h5.pojo.request; + +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; + +import java.util.List; + +@Data +@ApiModel("取消订单请求") +public class CancelOrderRequest { + @ApiModelProperty("要取消的订单id集合") + private List idList; +} diff --git a/ruoyi-mall/src/main/java/com/cyl/h5/service/H5OrderService.java b/ruoyi-mall/src/main/java/com/cyl/h5/service/H5OrderService.java index d8f0b8e..3b48865 100644 --- a/ruoyi-mall/src/main/java/com/cyl/h5/service/H5OrderService.java +++ b/ruoyi-mall/src/main/java/com/cyl/h5/service/H5OrderService.java @@ -7,6 +7,7 @@ import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.cyl.h5.pojo.dto.OrderCreateDTO; import com.cyl.h5.pojo.dto.OrderProductListDTO; +import com.cyl.h5.pojo.request.CancelOrderRequest; import com.cyl.h5.pojo.vo.CountOrderVO; import com.cyl.h5.pojo.vo.H5OrderVO; import com.cyl.h5.pojo.vo.OrderCalcVO; @@ -19,6 +20,7 @@ import com.cyl.manager.oms.mapper.OrderItemMapper; import com.cyl.manager.oms.mapper.OrderMapper; import com.cyl.manager.oms.mapper.OrderOperateHistoryMapper; import com.cyl.manager.oms.service.OrderItemService; +import com.cyl.manager.oms.service.OrderOperateHistoryService; import com.cyl.manager.pms.domain.Product; import com.cyl.manager.pms.domain.Sku; import com.cyl.manager.pms.mapper.ProductMapper; @@ -72,6 +74,9 @@ public class H5OrderService { @Autowired private OrderItemService orderItemService; + @Autowired + private OrderOperateHistoryService orderOperateHistoryService; + @Transactional public Long submit(OrderSubmitForm form) { Member member = (Member) LocalDataUtil.getVar(Constants.MEMBER_INFO); @@ -349,4 +354,48 @@ public class H5OrderService { public CountOrderVO orderNumCount(Long memberId) { return orderMapper.countByStatusAndMemberId(memberId); } + + @Transactional + public String orderBatchCancel(CancelOrderRequest request, Long userId) { + LocalDateTime optDate = LocalDateTime.now(); + if (CollectionUtil.isEmpty(request.getIdList())){ + throw new RuntimeException("未指定需要取消的订单号"); + } + QueryWrapper orderQw = new QueryWrapper<>(); + orderQw.in("id", request.getIdList()); + List orderList = orderMapper.selectList(orderQw); + if (orderList.size() < request.getIdList().size()){ + throw new RuntimeException("未查询到订单信息"); + } + long count = orderList.stream().filter(it -> !Constants.H5OrderStatus.UN_PAY.equals(it.getStatus())).count(); + if (count > 0){ + throw new RuntimeException("订单状态已更新，请刷新页面"); + } + List addHistoryList = new ArrayList<>(); + orderList.forEach(item -> { + item.setStatus(Constants.H5OrderStatus.CLOSED); + item.setUpdateTime(optDate); + item.setUpdateBy(userId); + OrderOperateHistory history = new OrderOperateHistory(); + history.setOrderId(item.getId()); + history.setOperateMan("用户"); + history.setOrderStatus(Constants.H5OrderStatus.CLOSED); + history.setCreateTime(optDate); + history.setCreateBy(userId); + history.setUpdateBy(userId); + history.setUpdateTime(optDate); + addHistoryList.add(history); + }); + //取消订单 + int rows = orderMapper.cancelBatch(orderList); + if (rows < 1){ + throw new RuntimeException("更改订单状态失败"); + } + //创建订单操作记录 + boolean flag = orderOperateHistoryService.saveBatch(addHistoryList); + if (!flag){ + throw new RuntimeException("创建订单操作记录失败"); + } + return "取消订单成功"; + } } diff --git a/ruoyi-mall/src/main/java/com/cyl/manager/oms/mapper/OrderMapper.java b/ruoyi-mall/src/main/java/com/cyl/manager/oms/mapper/OrderMapper.java index cf0faaf..ee4e354 100644 --- a/ruoyi-mall/src/main/java/com/cyl/manager/oms/mapper/OrderMapper.java +++ b/ruoyi-mall/src/main/java/com/cyl/manager/oms/mapper/OrderMapper.java @@ -30,4 +30,6 @@ public interface OrderMapper extends BaseMapper { H5OrderVO selectOrderDetail(Long orderId); CountOrderVO countByStatusAndMemberId(Long memberId); + + Integer cancelBatch(@Param("list") List orderList); } diff --git a/ruoyi-mall/src/main/java/com/cyl/manager/oms/service/OrderOperateHistoryService.java b/ruoyi-mall/src/main/java/com/cyl/manager/oms/service/OrderOperateHistoryService.java index 575cb14..038b861 100644 --- a/ruoyi-mall/src/main/java/com/cyl/manager/oms/service/OrderOperateHistoryService.java +++ b/ruoyi-mall/src/main/java/com/cyl/manager/oms/service/OrderOperateHistoryService.java @@ -3,6 +3,7 @@ package com.cyl.manager.oms.service; import java.util.List; import java.time.LocalDateTime; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.github.pagehelper.PageHelper; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.domain.Pageable; @@ -19,7 +20,7 @@ import com.cyl.manager.oms.pojo.query.OrderOperateHistoryQuery; * @author zcc */ @Service -public class OrderOperateHistoryService { +public class OrderOperateHistoryService extends ServiceImpl { @Autowired private OrderOperateHistoryMapper orderOperateHistoryMapper; diff --git a/ruoyi-mall/src/main/resources/mapper/oms/OrderMapper.xml b/ruoyi-mall/src/main/resources/mapper/oms/OrderMapper.xml index 9c04574..64d1d0d 100644 --- a/ruoyi-mall/src/main/resources/mapper/oms/OrderMapper.xml +++ b/ruoyi-mall/src/main/resources/mapper/oms/OrderMapper.xml @@ -47,6 +47,17 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" select id, member_id, member_username, total_amount, purchase_price, pay_amount, freight_amount, pay_type, status, aftersale_status, delivery_company, delivery_sn, auto_confirm_day, receiver_name, receiver_phone, receiver_post_code, receiver_province, receiver_city, receiver_district, receiver_province_id, receiver_city_id, receiver_district_id, receiver_detail_address, note, confirm_status, delete_status, payment_time, delivery_time, receive_time, create_by, create_time, update_by, update_time from oms_order + + + update oms_order + + status=#{item.status}, + update_by=#{item.updateBy}, + update_time=#{item.updateTime} + + where id=#{item.id} + +