修改 消费 先改mongo在改redis

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

@@ -233,8 +233,18 @@ public abstract class AbstractOrderCloseReceiver implements StreamListener<Strin
         try {
             KylinOrderTicketVo kylinOrderTicketVo = kylinOrderUtils.getOrderTicketVo(orderId);
             if (kylinOrderTicketVo.getStatus().equals(KylinTableStatusConst.ORDER_STATUS0)) {//待支付
+                //改mongo
+                HashMap<String, Object> mapMongo = CollectionUtil.mapStringObject();
+                mapMongo.put("status", KylinTableStatusConst.ORDER_STATUS2);
+                mapMongo.put("updatedAt", DateUtil.Formatter.yyyyMMddHHmmssSSS.format(now));
+                mapMongo.put("changeDate", now);
+                mongoTemplate.getCollection(KylinOrderTicketVo.class.getSimpleName()).updateMany(
+                        Query.query(Criteria.where("orderTicketsId").in(kylinOrderTicketVo.getOrderTicketsId())).getQueryObject(),
+                        new BasicDBObject("$set", mongoConverter.convertToMongoType(mapMongo))
+                );
                 //改redis
                 kylinOrderTicketVo.setStatus(2);
+                kylinOrderUtils.setOrderTicketVo(kylinOrderTicketVo.getOrderTicketsId(), kylinOrderTicketVo);
                 kylinOrderUtils.resetOrderListVo(kylinOrderTicketVo.getUserId(), 2, kylinOrderTicketVo.getOrderTicketsId(), kylinOrderTicketVo);
                 // redis 改限购
                 for (int i = 0; i < kylinOrderTicketVo.getEntitiesVoList().size(); i++) {
@@ -243,15 +253,7 @@ public abstract class AbstractOrderCloseReceiver implements StreamListener<Strin
                 }
                 //改库存
                 kylinOrderUtils.changeSurplusGeneral(kylinOrderTicketVo.getTicketId(), kylinOrderTicketVo.getNumber());
-                //改mongo
-                HashMap<String, Object> mapMongo = CollectionUtil.mapStringObject();
-                mapMongo.put("status", KylinTableStatusConst.ORDER_STATUS2);
-                mapMongo.put("updatedAt", DateUtil.Formatter.yyyyMMddHHmmssSSS.format(now));
-                mapMongo.put("changeDate", now);
-                mongoTemplate.getCollection(KylinOrderTicketVo.class.getSimpleName()).updateMany(
-                        Query.query(Criteria.where("orderTicketsId").in(kylinOrderTicketVo.getOrderTicketsId())).getQueryObject(),
-                        new BasicDBObject("$set", mongoConverter.convertToMongoType(mapMongo))
-                );
+
 //                //处理券
                 ArrayList<KylinOrderCoupons> orderCoupons = kylinOrderUtils.getOrderCoupon(kylinOrderTicketVo.getOrderTicketsId());
                 if (orderCoupons.size() > 0) {
@@ -285,13 +287,13 @@ public abstract class AbstractOrderCloseReceiver implements StreamListener<Strin
                         now, kylinOrderTicketVo.getOrderTicketsId(),
                 });
                 sqlDataOrderStatus.add(new Object[]{
-                        2,now, kylinOrderTicketVo.getOrderTicketsId(),
+                        2, now, kylinOrderTicketVo.getOrderTicketsId(),
                 });
                 sqlDataOrderRelation.add(new Object[]{
                         now, kylinOrderTicketVo.getOrderTicketsId(),
                 });
                 sendMsgByRedis(MQConst.KylinQueue.SQL_ORDER_PAY.getKey(),
-                        SqlMapping.gets(sqls, sqlDataOrder,sqlDataOrderStatus,sqlDataOrderRelation));
+                        SqlMapping.gets(sqls, sqlDataOrder, sqlDataOrderStatus, sqlDataOrderRelation));
             }
             return true;
         } catch (Exception e) {

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-order/src/main/java/com/liquidnet/service/consumer/order/utils/KylinOrderUtils.java

@@ -64,6 +64,11 @@ public class KylinOrderUtils {
         }
     }
 
+    public void setOrderTicketVo(String orderId, KylinOrderTicketVo vo) {
+        String redisKey = KylinRedisConst.ORDER + orderId;
+        redisUtil.set(redisKey, vo);
+    }
+
     /**
      * @param userId  用户id
      * @param type    1新增 2修改