优惠券 出入

cash-api/order-server/src/main/java/com/czg/controller/user/UserOrderController.java

@@ -1,9 +1,12 @@
 package com.czg.controller.user;
 
 import com.czg.order.dto.OrderInfoQueryDTO;
+import com.czg.order.entity.OrderInfo;
 import com.czg.order.service.OrderInfoService;
 import com.czg.order.vo.OrderInfoVo;
 import com.czg.resp.CzgResult;
+import com.czg.sa.StpKit;
+import com.czg.utils.AssertUtil;
 import com.mybatisflex.core.paginate.Page;
 import jakarta.annotation.Resource;
 import org.springframework.web.bind.annotation.*;
@@ -11,6 +14,7 @@ import org.springframework.web.bind.annotation.*;
 
 /**
  * 订单管理
+ *
  * @author ww
  * @description
  */
@@ -25,7 +29,27 @@ public class UserOrderController {
      * 订单列表
      */
     @PostMapping
-    public CzgResult<Page<OrderInfoVo>> get(@RequestBody OrderInfoQueryDTO queryDTO) {
+    public CzgResult<Page<OrderInfoVo>> getOrderPage(@RequestBody OrderInfoQueryDTO queryDTO) {
+        queryDTO.setIsDel(1);
+        queryDTO.setUserId(StpKit.USER.getLoginIdAsLong());
         return CzgResult.success(orderInfoService.getOrderByPage(queryDTO));
     }
+
+    @PostMapping
+    public CzgResult<Void> createOrder(@RequestBody OrderInfoQueryDTO queryDTO) {
+        queryDTO.setIsDel(1);
+        queryDTO.setUserId(StpKit.USER.getLoginIdAsLong());
+        return CzgResult.success();
+    }
+
+    @PutMapping("{id}")
+    public CzgResult<Void> upOrderIsDel(@PathVariable("id") Long id) {
+        //效验数据
+        AssertUtil.isNull(id, "{}不能为空", "订单Id");
+        orderInfoService.updateChain()
+                .set(OrderInfo::getIsDel, 1)
+                .eq(OrderInfoVo::getId, id)
+                .update();
+        return CzgResult.success();
+    }
 }

cash-api/order-server/src/main/java/com/czg/mq/RabbitmqReceiver.java

@@ -18,6 +18,7 @@ public class RabbitmqReceiver {
 
     /**
      * 消费者监听，绑定队列
+     * Queue RabbitConfig类的 orderPrintQueue
      */
     @RabbitListener(
             bindings = @QueueBinding(value = @Queue(value = "#{orderPrintQueue.name}", durable = "true",
@@ -26,11 +27,9 @@ public class RabbitmqReceiver {
             concurrency = "10"
     )
     @RabbitHandler
-    public void receiveOrderPrintQueue(Channel channel, String payload, Message message) throws IOException {
+    public void receiveOrderPrintQueue(Channel channel, String orderId, Message message) throws IOException {
         try {
-            System.out.println("Topic模式(orderPrintQueue)消费者收到消息: " + message);
-            System.out.println(payload);
-
+            log.info("订单监听 消息体：{},消息内容：{}", message, orderId);
             // 手动确认消息，multiple 参数表示是否批量确认
             channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
         } catch (Exception e) {