订单查询

liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/kylin/service/impl/ToolServiceImpl.java

@@ -3,6 +3,7 @@ package com.liquidnet.client.admin.zhengzai.kylin.service.impl;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.liquidnet.client.admin.zhengzai.kylin.service.IToolService;
 import com.liquidnet.client.admin.zhengzai.kylin.utils.DataUtils;
+import com.liquidnet.client.admin.zhengzai.kylin.utils.MongoVoUtils;
 import com.liquidnet.common.cache.redis.util.RedisDataSourceUtil;
 import com.liquidnet.commons.lang.util.DateUtil;
 
@@ -41,6 +42,10 @@ public class ToolServiceImpl implements IToolService {
     private KylinOrderTicketsMapper kylinOrderTicketsMapper;
     @Autowired
     private KylinOrderTicketVoMapper kylinOrderTicketVoMapper;
+    @Autowired
+    private RedisDataSourceUtil redisDataSourceUtil;
+    @Autowired
+    private MongoVoUtils mongoVoUtils;
 
     @Override
     public Boolean supplementEnter(String orderTicketEntitiesId, String enterName, String enterMobile, String enterIdCode, Integer enterType, String orderId) {
@@ -88,21 +93,16 @@ public class ToolServiceImpl implements IToolService {
         List<KylinOrderTickets> KylinOrderTickets = kylinOrderTicketVoMapper.getExpressContactsByOrderCode(orderCode);
         return KylinOrderTickets;
     }
-    @Autowired
-    private RedisDataSourceUtil redisDataSourceUtil;
+
 
     @Override
     public  Integer updOrderExpressPhoneByOrderCode(String orderCode, String expressPhone) {
         int upd = kylinOrderTicketVoMapper.updOrderExpressPhoneByOrderCode(orderCode, expressPhone);
         //存mongo
-        Query query = Query.query(Criteria.where("orderCode").is(orderCode));
-        Update update = Update.update("expressPhone",expressPhone);;
-        mongoTemplate.updateFirst(query,update,KylinOrderTicketVo.class,KylinOrderTicketVo.class.getSimpleName());
+        mongoVoUtils.orderSetMongo(orderCode, expressPhone);
         //存redis
-        String redisK = KylinRedisConst.ORDER + orderCode;
-        KylinOrderTicketVo orderTicketVo = mongoTemplate.findOne(query, KylinOrderTicketVo.class, KylinOrderTicketVo.class.getSimpleName());
-        redisDataSourceUtil.getRedisKylinUtil().set(redisK, orderTicketVo);
-       // Object o = redisDataSourceUtil.getRedisKylinUtil().get(redisK);
+       dataUtils.orderSetRedis(orderCode);
+       Object o = redisDataSourceUtil.getRedisKylinUtil().get("kylin:order:id:201373316981841927358500");
         return upd;
     }
 }

liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/kylin/utils/DataUtils.java

@@ -426,4 +426,12 @@ public class DataUtils {
             return (PageInfo<OrderOutLineVo>) obj;
         }
     }
+    //订单信息存redis
+    public void orderSetRedis(String orderCode){
+        KylinOrderTicketVo orderTicketVo = mongoTemplate.findOne(Query.query(Criteria.where("orderCode").is(orderCode)), KylinOrderTicketVo.class, KylinOrderTicketVo.class.getSimpleName());
+        String orderTicketsId = orderTicketVo.getOrderTicketsId();
+        List<KylinOrderTicketEntitiesVo> kylinOrderTicketEntitiesVoList = mongoTemplate.find(Query.query(Criteria.where("orderId").is(orderTicketsId)), KylinOrderTicketEntitiesVo.class, KylinOrderTicketEntitiesVo.class.getSimpleName());
+        orderTicketVo.setEntitiesVoList(kylinOrderTicketEntitiesVoList);
+        redisDataSourceUtil.getRedisKylinUtil().set(KylinRedisConst.ORDER +orderTicketsId, orderTicketVo);
+    }
 }

liquidnet-bus-client/liquidnet-client-admin/liquidnet-client-admin-zhengzai/src/main/java/com/liquidnet/client/admin/zhengzai/kylin/utils/MongoVoUtils.java

@@ -13,6 +13,10 @@ import com.liquidnet.service.kylin.entity.*;
 import com.liquidnet.service.kylin.mapper.*;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.mongodb.core.MongoTemplate;
+import org.springframework.data.mongodb.core.query.Criteria;
+import org.springframework.data.mongodb.core.query.Query;
+import org.springframework.data.mongodb.core.query.Update;
 import org.springframework.stereotype.Component;
 
 import java.math.BigDecimal;
@@ -42,6 +46,8 @@ public class MongoVoUtils {
     private RedisDataSourceUtil redisDataSourceUtil;
     @Autowired
     private DataUtils dataUtils;
+    @Autowired
+    private MongoTemplate mongoTemplate;
 
     public KylinPerformanceVo combinePerformanceVoData(String performancesId) {
         try {
@@ -220,4 +226,14 @@ public class MongoVoUtils {
                 return false;
         }
     }
+    /**
+     * 修改收货人手机号
+     * @param orderCode  订单编号
+     * @param expressPhone    收货人手机号
+     */
+    public void orderSetMongo(String orderCode, String expressPhone ){
+        Query query = Query.query(Criteria.where("orderCode").is(orderCode));
+        Update update = Update.update("expressPhone",expressPhone);;
+        mongoTemplate.updateFirst(query,update,KylinOrderTicketVo.class,KylinOrderTicketVo.class.getSimpleName());
+    }
 }