~opt;

liquidnet-bus-service/liquidnet-service-order/liquidnet-service-order-impl/src/main/java/com/liquidnet/service/order/service/impl/GoblinOrderServiceImpl.java

@@ -527,9 +527,11 @@ public class GoblinOrderServiceImpl implements IGoblinOrderService {
         LinkedList<Object[]> sqlDataSku = CollectionUtil.linkedListObjectArr();
         LinkedList<Object[]> sqlDataOrder = CollectionUtil.linkedListObjectArr();
         LinkedList<Object[]> sqlDataAttr = CollectionUtil.linkedListObjectArr();
+        List<GoblinStoreOrderVo> orderVoList = ObjectUtil.getGoblinStoreOrderVoArrayList();
+        List<GoblinOrderSkuVo> skuVoList = ObjectUtil.getGoblinOrderSkuVoArrayList();
         long time3 = System.currentTimeMillis();
         for (GoblinOrderSqlParam item : sqlParams) {
-            List<GoblinOrderSkuVo> skuVoList = ObjectUtil.getGoblinOrderSkuVoArrayList();
+//            List<GoblinOrderSkuVo> skuVoList = ObjectUtil.getGoblinOrderSkuVoArrayList();
             long time2 = System.currentTimeMillis();
             for (GoblinOrderSku orderSku : item.getOrderSkuList()) {
                 sqlDataSku.add(new Object[]{
@@ -544,9 +546,9 @@ public class GoblinOrderServiceImpl implements IGoblinOrderService {
             }
             log.info("生成子订单逻辑:" + (System.currentTimeMillis() - time2) + "ms");
 
-            time2 = System.currentTimeMillis();
-            mongoUtils.insertGoblinOrderSkuVoList(skuVoList);
-            log.info("mongo添加订单:" + (System.currentTimeMillis() - time2) + "ms");
+//            time2 = System.currentTimeMillis();
+//            mongoUtils.insertGoblinOrderSkuVoList(skuVoList);
+//            log.info("mongo添加订单:" + (System.currentTimeMillis() - time2) + "ms");
 
             time2 = System.currentTimeMillis();
             GoblinStoreOrder storeOrder = item.getStoreOrder();
@@ -579,7 +581,9 @@ public class GoblinOrderServiceImpl implements IGoblinOrderService {
             orderVo.setCreatedAt(getNowTime());
             redisUtils.setGoblinOrder(orderVo.getOrderId(), orderVo);
             redisUtils.setMasterCode(preParam.getOrderMasterCode(), preParam.getOrderIdList().substring(1));
-            mongoUtils.insertGoblinStoreOrderVo(orderVo);
+//            mongoUtils.insertGoblinStoreOrderVo(orderVo);
+            orderVoList.add(orderVo);
+
             log.info("保存数据:" + (System.currentTimeMillis() - time2) + "ms");
             time2 = System.currentTimeMillis();
             //redis 订单列表
@@ -593,6 +597,11 @@ public class GoblinOrderServiceImpl implements IGoblinOrderService {
             log.info("判断是否正在下单:" + (System.currentTimeMillis() - time2) + "ms");
         }
         log.info("店铺订单:" + (System.currentTimeMillis() - time3) + "ms");
+        time3 = System.currentTimeMillis();
+        mongoUtils.insertGoblinOrderSkuVoList(skuVoList);
+        mongoUtils.insertGoblinStoreOrderVos(orderVoList);
+        log.info("MDB保存:" + (System.currentTimeMillis() - time3) + "ms");
+
         //mysql  执行sql
         String sqlData = SqlMapping.gets(sqls, sqlDataSku, sqlDataOrder, sqlDataAttr);
         queueUtils.sendMsgByRedis(MQConst.GoblinQueue.GOBLIN_ORDER_CREATE_PAY.getKey(), sqlData);

liquidnet-bus-service/liquidnet-service-order/liquidnet-service-order-impl/src/main/java/com/liquidnet/service/order/utils/GoblinMongoUtils.java

@@ -79,6 +79,9 @@ public class GoblinMongoUtils {
     public GoblinStoreOrderVo insertGoblinStoreOrderVo(GoblinStoreOrderVo vo) {
         return mongoTemplate.insert(vo, GoblinStoreOrderVo.class.getSimpleName());
     }
+    public void insertGoblinStoreOrderVos(List<GoblinStoreOrderVo> vos) {
+        mongoTemplate.insert(vos, GoblinStoreOrderVo.class.getSimpleName());
+    }
 
     public UpdateResult updateGoblinStoreOrderVo(String orderId, GoblinStoreOrderVo data) {
         BasicDBObject object = ObjectUtil.cloneBasicDBObject().append("$set", mongoConverter.convertToMongoType(data));

liquidnet-bus-service/liquidnet-service-order/liquidnet-service-order-impl/src/main/java/com/liquidnet/service/order/utils/ObjectUtil.java

@@ -3,6 +3,7 @@ package com.liquidnet.service.order.utils;
 import com.liquidnet.service.adam.dto.vo.AdamEntersVo;
 import com.liquidnet.service.goblin.dto.vo.GoblinMailVo;
 import com.liquidnet.service.goblin.dto.vo.GoblinOrderSkuVo;
+import com.liquidnet.service.goblin.dto.vo.GoblinStoreOrderVo;
 import com.liquidnet.service.goblin.entity.GoblinOrderSku;
 import com.liquidnet.service.candy.param.BackCouponParam;
 import com.liquidnet.service.goblin.param.GoblinOrderSqlParam;
@@ -45,6 +46,7 @@ public class ObjectUtil {
     private static final ArrayList<GoblinOrderSku> goblinOrderSkuArrayList = new ArrayList<>();
     private static final ArrayList<BackCouponParam> backCouponParam = new ArrayList<>();
     private static final ArrayList<GoblinMailVo> goblinMailVo = new ArrayList<>();
+    private static final ArrayList<GoblinStoreOrderVo> goblinStoreOrderVoArrayList = new ArrayList<>();
     private static final ArrayList<GoblinOrderSkuVo> goblinOrderSkuVoArrayList = new ArrayList<>();
     private static final ArrayList<WriteModel<Document>> writeModelDocumentArrayList = new ArrayList<>();
 
@@ -123,6 +125,10 @@ public class ObjectUtil {
         return (BasicDBObject) basicDBObject.clone();
     }
 
+    public static ArrayList<GoblinStoreOrderVo> getGoblinStoreOrderVoArrayList() {
+        return (ArrayList<GoblinStoreOrderVo>) goblinStoreOrderVoArrayList.clone();
+    }
+
     public static ArrayList<KylinOrderCoupons> getKylinOrderCouponsArrayList() {
         return (ArrayList<KylinOrderCoupons>) kylinOrderCouponsArrayList.clone();
     }