修改 回调mongo

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

@@ -102,12 +102,12 @@ public class MixOrderServiceImpl implements IMixOrderService {
             if (limitCount != 0) {
                 int buyCount = redisUtils.incrMixLimit(mixId, uid);
                 isUseLimit = true;
-                log.debug("limit = "+buyCount);
+                log.debug("limit = " + buyCount);
                 if (buyCount > limitCount) {
                     redisUtils.decrMixLimit(mixId, uid);
                     return ResponseDto.failure("超出限购数量");
                 }
-            }else{
+            } else {
                 int buyCount = redisUtils.incrMixLimit(mixId, uid);
             }
             //构建 各个商品信息
@@ -629,7 +629,7 @@ public class MixOrderServiceImpl implements IMixOrderService {
                 //redis
                 redisUtils.setGoblinOrderSku(orderSkuVo.getOrderSkuId(), orderSkuVo);
                 //mongo
-                mongoUtils.updateGoblinOrderSkuVo(orderSkuVo.getOrderSkuId(), orderSkuVo);
+                queueUtils.setMongoList(GoblinOrderSkuVo.class.getSimpleName(), "orderSkuId", orderSkuVo.getOrderSkuId(), GoblinRedisConst.REDIS_GOBLIN_ORDER_SKU, 2);
                 //mongo 添加操作日志
                 GoblinOrderLogVo logVo = GoblinOrderLogVo.getNew();
                 logVo.setOrderId(orderVo.getOrderId());
@@ -647,6 +647,7 @@ public class MixOrderServiceImpl implements IMixOrderService {
                 logVo.setOperationType(GoblinStatusConst.Type.OPERATION_TYPE_1.getValue());
                 logVo.setCreatedAt(LocalDateTime.now());
                 mongoUtils.insertGoblinOrderLogVo(logVo);
+
                 //mysql
                 sqlDataSku.add(new Object[]{
                         GoblinStatusConst.Status.ORDER_STATUS_2.getValue(), now,
@@ -662,9 +663,7 @@ public class MixOrderServiceImpl implements IMixOrderService {
             orderVo.setPaymentType(paymentType);
             orderVo.setOrderSkuVoIds(skuList);
             redisUtils.setGoblinOrder(orderId, orderVo);
-            redisUtils.setOffCode(orderVo.getWriteOffCode(), orderVo.getMasterOrderCode());
-            //mongo
-            mongoUtils.updateGoblinStoreOrderVo(orderId, orderVo);
+            queueUtils.setMongoList(GoblinStoreOrderVo.class.getSimpleName(), "orderId", orderVo.getOrderId(), GoblinRedisConst.REDIS_GOBLIN_ORDER, 2);
             //mysql
             queueUtils.sendMsgByRedis(MQConst.GoblinQueue.GOBLIN_ORDER_CREATE_PAY.getKey(),
                     SqlMapping.gets(sqls, sqlDataOrder, sqlDataSku));