压测提交

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/receiver/AbstractOrderCloseReceiver.java

@@ -94,44 +94,48 @@ public abstract class AbstractOrderCloseReceiver implements StreamListener<Strin
 
     public boolean checkOrderTime(String valueData, String type) {
         LocalDateTime now = LocalDateTime.now();
-        if (type.equals("GOBLIN")) {
-            String[] orderIds = getMasterCode(valueData);
-            for (String orderId : orderIds) {
-                GoblinStoreOrderVo orderVo = getGoblinOrder(orderId);
-                if (orderVo.getStatus().equals(GoblinStatusConst.Status.ORDER_STATUS_0.getValue())) {//订单回滚
-                    LinkedList<String> sqls = CollectionUtil.linkedListString();
-                    LinkedList<Object[]> sqlDataOrder = CollectionUtil.linkedListObjectArr();
-                    LinkedList<Object[]> sqlDataSku = CollectionUtil.linkedListObjectArr();
-                    sqls.add(SqlMapping.get("goblin_order.close.order"));
-                    sqls.add(SqlMapping.get("goblin_order.close.sku"));
-                    for (String orderSkuId : orderVo.getOrderSkuVoIds()) {
-                        GoblinOrderSkuVo skuVo = getGoblinOrderSkuVo(orderSkuId);
-                        //订单详情
-                        skuVo.setStatus(GoblinStatusConst.Status.ORDER_STATUS_5.getValue());
-                        updateGoblinOrderSkuVo(skuVo.getOrderSkuId(), skuVo);
-                        setGoblinOrderSku(skuVo.getOrderSkuId(), skuVo);
-                        //库存&限购&&待支付订单
-                        String pre = GoblinStatusConst.MarketPreStatus.getPre(skuVo.getSkuId());
-                        incrSkuStock(pre, skuVo.getSkuId(), skuVo.getNum());
-                        decrSkuCountByUid(orderVo.getUserId(), skuVo.getSkuId(), skuVo.getNum());
+        try {
+            if (type.equals("GOBLIN")) {
+                String[] orderIds = getMasterCode(valueData);
+                for (String orderId : orderIds) {
+                    GoblinStoreOrderVo orderVo = getGoblinOrder(orderId);
+                    if (orderVo.getStatus().equals(GoblinStatusConst.Status.ORDER_STATUS_0.getValue())) {//订单回滚
+                        LinkedList<String> sqls = CollectionUtil.linkedListString();
+                        LinkedList<Object[]> sqlDataOrder = CollectionUtil.linkedListObjectArr();
+                        LinkedList<Object[]> sqlDataSku = CollectionUtil.linkedListObjectArr();
+                        sqls.add(SqlMapping.get("goblin_order.close.order"));
+                        sqls.add(SqlMapping.get("goblin_order.close.sku"));
+                        for (String orderSkuId : orderVo.getOrderSkuVoIds()) {
+                            GoblinOrderSkuVo skuVo = getGoblinOrderSkuVo(orderSkuId);
+                            //订单详情
+                            skuVo.setStatus(GoblinStatusConst.Status.ORDER_STATUS_5.getValue());
+                            updateGoblinOrderSkuVo(skuVo.getOrderSkuId(), skuVo);
+                            setGoblinOrderSku(skuVo.getOrderSkuId(), skuVo);
+                            //库存&限购&&待支付订单
+                            String pre = GoblinStatusConst.MarketPreStatus.getPre(skuVo.getSkuId());
+                            incrSkuStock(pre, skuVo.getSkuId(), skuVo.getNum());
+                            decrSkuCountByUid(orderVo.getUserId(), skuVo.getSkuId(), skuVo.getNum());
+                            //mysql
+                            sqlDataSku.add(new Object[]{
+                                    skuVo.getStatus(), now, orderVo.getOrderId(), now, now
+                            });
+                        }
+                        //订单
+                        orderVo.setStatus(GoblinStatusConst.Status.ORDER_STATUS_5.getValue());
+                        updateGoblinStoreOrderVo(orderVo.getOrderId(), orderVo);
+                        setGoblinOrder(orderVo.getOrderId(), orderVo);
                         //mysql
-                        sqlDataSku.add(new Object[]{
-                                skuVo.getStatus(), now, orderVo.getOrderId(), now, now
+                        sqlDataOrder.add(new Object[]{
+                                orderVo.getStatus(), now, now, "超时关闭", orderVo.getOrderId(), now, now
                         });
+                        //执行sql
+                        sendMsgByRedis(MQConst.GoblinQueue.GOBLIN_ORDER_CLOSE.getKey(),
+                                SqlMapping.gets(sqls, sqlDataOrder, sqlDataSku));
                     }
-                    //订单
-                    orderVo.setStatus(GoblinStatusConst.Status.ORDER_STATUS_5.getValue());
-                    updateGoblinStoreOrderVo(orderVo.getOrderId(), orderVo);
-                    setGoblinOrder(orderVo.getOrderId(), orderVo);
-                    //mysql
-                    sqlDataOrder.add(new Object[]{
-                            orderVo.getStatus(), now, now, "超时关闭", orderVo.getOrderId(), now, now
-                    });
-                    //执行sql
-                    sendMsgByRedis(MQConst.GoblinQueue.GOBLIN_ORDER_CLOSE.getKey(),
-                            SqlMapping.gets(sqls, sqlDataOrder, sqlDataSku));
                 }
             }
+        }catch (Exception e){
+            log.error("库存回滚异常valueData={}",valueData, e);
         }
         return true;
     }