停车场订单正向逻辑

call-back-service/src/main/java/cn/freemud/amp/service/OrderCallBackMQService.java

@@ -91,8 +91,12 @@ public class OrderCallBackMQService {
         sendWechatReportMQ(body);
         //上报发票信息
         sendInvoiceReportMQ(body);
-        //未支付超时关单，发送队列冲正积分、券码等
-        revert(body);
+        //未支付超时关单，发送队列冲正积分、券码等,停车场订单走单独逻辑
+        if (checkParkingOrders(orderInfoReqs)) {
+            revertParkingOrders(body);
+        }else{
+            revert(body);
+        }
     }
 
     /**
@@ -161,6 +165,10 @@ public class OrderCallBackMQService {
         if (ObjectUtils.equals(1, orderInfoReqs.getPayState()) || ObjectUtils.equals(NewOrderStatus.PENDING_PAYMENT.getIndex(), orderInfoReqs.getOrderState())) {
             return null;
         }
+        //停车场订单关闭状态不通知开放平台
+        if (checkParkingOrders(orderInfoReqs)) {
+            return null;
+        }
         return orderInfoReqs;
     }
 
@@ -285,4 +293,37 @@ public class OrderCallBackMQService {
             log.error("callback set invoice mq orderCode={},exception={}",orderInfoReqs.getOrderCode(),e.toString());
         }
     }
+
+    /**
+     * 冲正库存、券码等
+     * @param body
+     */
+    public void revertParkingOrders(OrderCallBackRequestVo body){
+        String orderCode=body.getOrderCode();
+        ApiLog.info("parkingOrderBackOrdersStatusChange", orderCode);
+        OrderStatusChangeRequestDto requestDto = new OrderStatusChangeRequestDto();
+        requestDto.setOid(orderCode);
+        //2：未支付
+        requestDto.setOrderStatus(2);
+        try {
+            Header header = new Header(MQAction.INSERT.getAction(), "parkingOrderBackOrdersStatusChange", orderCode, backOrdersChangeOrderStatusConsumerQueue);
+            MQMessage<OrderStatusChangeRequestDto> message = new MQMessage<>(header, requestDto);
+            mqService.convertAndSend(backOrdersNotifyActivityExchange, backOrdersChangeOrderStatusConsumerQueue, message);
+        } catch (Exception e) {
+            ErrorLog.errorConvertJson(this.getClass(),"parkingOrderBackOrdersStatusChange:"+orderCode,e);
+        }
+    }
+
+    /**
+     * 检查是否符合停车场订单
+     * @param orderInfoReqs
+     * @return
+     */
+    private boolean checkParkingOrders(OrderInfoReqs orderInfoReqs){
+        if (orderInfoReqs.getOrderClient().equals(OrderClientType.PARKING.getIndex()) && orderInfoReqs.getBizType() == 99 && orderInfoReqs.getPayState() ==3 && orderInfoReqs.getOrderState() == 7) {
+            return true;
+        }
+        return false;
+    }
+
 }