1、业务汇总对象调整

sckw-common/sckw-common-mongo/src/main/java/com/sckw/mongo/model/SckwLogisticsOrder.java

@@ -27,6 +27,11 @@ public class SckwLogisticsOrder {
      * 主键
      */
     @Id
+    private Long _id;
+
+    /**
+     * 物流订单ID
+     */
     private Long lOrderId;
 
     /**

sckw-common/sckw-common-mongo/src/main/java/com/sckw/mongo/model/SckwTradeOrder.java

@@ -22,9 +22,14 @@ import java.util.Date;
 public class SckwTradeOrder{
 
     /**
-     * 订单主键
+     * 主键
      */
     @Id
+    private Long _id;
+
+    /**
+     * 订单主键
+     */
     private Long tOrderId;
 
     /**

sckw-common/sckw-common-mongo/src/main/java/com/sckw/mongo/model/SckwWaybillOrder.java

@@ -25,6 +25,11 @@ public class SckwWaybillOrder{
      * 主键
      */
     @Id
+    private Long _id;
+
+    /**
+     * 主键
+     */
     private Long wOrderId;
 
     /**

sckw-modules/sckw-report/src/main/java/com/sckw/report/consumer/SckwBusSumConsumer.java

@@ -64,6 +64,7 @@ public class SckwBusSumConsumer {
         /**业务存储**/
         if (busSum.getBusSumType().equals("tradeOrder")) {
             SckwTradeOrder order = JSONObject.parseObject(JSON.toJSONString(busSum.getObject()), SckwTradeOrder.class);
+            order.set_id(order.getTOrderId());
             if (busSum.getMethod() == 1) {
                 tradeOrderRepository.insert(order);
             } else {
@@ -73,6 +74,7 @@ public class SckwBusSumConsumer {
 
         if (busSum.getBusSumType().equals("logisticsOrder")) {
             SckwLogisticsOrder order = JSONObject.parseObject(JSON.toJSONString(busSum.getObject()), SckwLogisticsOrder.class);
+            order.set_id(order.getLOrderId());
             if (busSum.getMethod() == 1) {
                 logisticsOrderRepository.insert(order);
             } else {
@@ -82,6 +84,7 @@ public class SckwBusSumConsumer {
 
         if (busSum.getBusSumType().equals("waybillOrder")) {
             SckwWaybillOrder order = JSONObject.parseObject(JSON.toJSONString(busSum.getObject()), SckwWaybillOrder.class);
+            order.set_id(order.getWOrderId());
             if (busSum.getMethod() == 1) {
                 waybillOrderRepository.insert(order);
             } else {