修改订单统计

xx-order/xx-order-api/src/main/java/com/xxfc/platform/order/contant/enumerate/TimeMinimumSubdivisionEnum.java

+package com.xxfc.platform.order.contant.enumerate;
+
+/**
+ * 查询时间段最小细分(时间段内又划分的片段)
+ */
+public enum TimeMinimumSubdivisionEnum {
+    nothing(0,"无细分"),day(1,"最小细分到天")
+    ;
+    private int code;
+    private String msg;
+
+    public String getMsg() {
+        return msg;
+    }
+
+    TimeMinimumSubdivisionEnum(int code, String msg) {
+        this.code=code;
+        this.msg=msg;
+    }
+
+    public Integer getCode() {
+        return code;
+    }
+}

xx-order/xx-order-api/src/main/java/com/xxfc/platform/order/entity/OrderStatistics.java

@@ -64,6 +64,6 @@ public class OrderStatistics {
     /**
      * 订单补偿总额
      */
-    @ApiModelProperty(value = "订单补偿总额")
-    private BigDecimal orderCompensation;
+    @ApiModelProperty(value = "历史订单补偿总额")
+    private BigDecimal totalOrderCompensation;
 }

xx-order/xx-order-api/src/main/java/com/xxfc/platform/order/pojo/HomePageOrderData.java

@@ -9,15 +9,15 @@ public class HomePageOrderData {
     /**
      * 订单总额
      */
-    private BigDecimal totalOrders;
+    private BigDecimal totalOrders=BigDecimal.ZERO;
     /**
      * 为退还押金总额
      */
-    private BigDecimal totalOutstandingDeposit;
+    private BigDecimal totalOutstandingDeposit=BigDecimal.ZERO;
 
     /**
      * 额外赔款
      */
-    private BigDecimal additionalIndemnity;
+    private BigDecimal additionalIndemnity=BigDecimal.ZERO;
 
 }

xx-order/xx-order-api/src/main/java/com/xxfc/platform/order/pojo/Term.java

+package com.xxfc.platform.order.pojo;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.util.List;
+
+@Data
+@NoArgsConstructor
+@AllArgsConstructor
+public class Term {
+
+    /**
+     * 订单类型
+     */
+    private Integer orderType;
+
+    /**
+     * 几天前(用于判断计算几天前的数据) subdivide=2的实际存在
+     */
+    private Integer day;
+
+    /**
+     * 时间最小细分类型(最小细分到天,无细分)
+     */
+    private int subdivide;
+
+    /**
+     * 开始时间
+     */
+    private Long startTime;
+
+    /**
+     *  结束时间
+     */
+    private Long endTime;
+
+    /**
+     * 分公司id 数组
+     */
+    private List<Integer>  companyIds;
+
+
+
+}

xx-order/xx-order-server/src/main/java/com/xxfc/platform/order/biz/DailyMembersOrderStatisticsBiz.java

@@ -10,6 +10,7 @@ import com.xxfc.platform.order.entity.OrderAccount;
 import com.xxfc.platform.order.entity.OrderStatistics;
 import com.xxfc.platform.order.mapper.DailyMembersOrderStatisticsMapper;
 import com.xxfc.platform.order.pojo.OrderQuery;
+import com.xxfc.platform.order.pojo.Term;
 import com.xxfc.platform.order.pojo.account.OrderAccountDTO;
 import com.xxfc.platform.order.pojo.account.OrderAccountDetail;
 import lombok.extern.slf4j.Slf4j;
@@ -43,50 +44,61 @@ public class DailyMembersOrderStatisticsBiz extends BaseBiz<DailyMembersOrderSta
     /**
      * 总公司id默认为1
      */
-    private final Integer OMPANY_ID=1;
+    private final Integer OMPANY_ID = 1;
     @Autowired
     private OrderAccountBiz accountBiz;
 
     @Transactional(rollbackFor = Exception.class)
-    public boolean saveDailyMembersOrderRecord(Integer day) {
+    public boolean dailyMembersOrderRecord(Integer day) {
         try {
-            List<OrderAccountDTO> accountList = accountBiz.getOrderAccountByOrderType(OrderTypeEnum.MEMBER.getCode(), day);
-
-            if (CollectionUtils.isNotEmpty(accountList)) {
-                DailyMembersOrderStatistics orderStatistics = new DailyMembersOrderStatistics();
-                ArrayList<OrderAccountDetail> orderAccountDetails = getOrderAccountDetail(accountList);
-                if (CollectionUtils.isNotEmpty(orderAccountDetails)) {
-                    //获取订单总额
-                    BigDecimal gmv = getOrderAmountTotal(orderAccountDetails);
-                    orderStatistics.setGmv(gmv);
-                    orderStatistics.setBranchCompanyId(OMPANY_ID);
-                    orderStatistics.setOneDay(accountList.get(0).getOneDay());
-                }
-                log.info("Members:统计完成");
-                if (JudgmentOfExistence(orderStatistics)) {
-                insertSelectiveRe(orderStatistics);
-                } else {
-                    mapper.updateByExampleSelective(orderStatistics, Example.builder(DailyMembersOrderStatistics.class)
-                            .where(WeekendSqls.<DailyMembersOrderStatistics>custom()
-                                    .andEqualTo(DailyMembersOrderStatistics::getOneDay, orderStatistics.getOneDay())
-                                    .andEqualTo(DailyMembersOrderStatistics::getBranchCompanyId, orderStatistics.getBranchCompanyId()))
-                            .build());
-
-                }
-                log.info("Members:保存成功");
-            }
-
+            DailyMembersOrderStatistics orderStatistics = statistics(new Term(OrderTypeEnum.MEMBER.getCode(), day, 1, null, null, null));
+            log.info("Members:统计完成");
+            save(orderStatistics);
+            log.info("Members:保存成功");
             return true;
         } catch (Exception e) {
             TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
-            log.error("Members:"+ e.getMessage());
+            log.error("Members:" + e.getMessage());
 
             return false;
         }
     }
 
+    public void save(DailyMembersOrderStatistics orderStatistics) {
+        if (orderStatistics != null) {
+            if (JudgmentOfExistence(orderStatistics)) {
+                insertSelectiveRe(orderStatistics);
+            } else {
+                mapper.updateByExampleSelective(orderStatistics, Example.builder(DailyMembersOrderStatistics.class)
+                        .where(WeekendSqls.<DailyMembersOrderStatistics>custom()
+                                .andEqualTo(DailyMembersOrderStatistics::getOneDay, orderStatistics.getOneDay())
+                                .andEqualTo(DailyMembersOrderStatistics::getBranchCompanyId, orderStatistics.getBranchCompanyId()))
+                        .build());
+            }
+        }
+    }
+
+    public DailyMembersOrderStatistics statistics(Term term) {
+        List<OrderAccountDTO> accountList = accountBiz.getOrderAccountByOrderType(term);
+
+        if (CollectionUtils.isNotEmpty(accountList)) {
+            DailyMembersOrderStatistics orderStatistics = new DailyMembersOrderStatistics();
+            ArrayList<OrderAccountDetail> orderAccountDetails = getOrderAccountDetail(accountList);
+            if (CollectionUtils.isNotEmpty(orderAccountDetails)) {
+                //获取订单总额
+                BigDecimal gmv = getOrderAmountTotal(orderAccountDetails);
+                orderStatistics.setGmv(gmv);
+                orderStatistics.setBranchCompanyId(OMPANY_ID);
+                orderStatistics.setOneDay(accountList.get(0).getOneDay());
+            }
+            return orderStatistics;
+        }
+        return null;
+    }
+
     /**
      * 添加前查询是否存在这条数据
+     *
      * @param orderStatistic
      * @return
      */
@@ -101,6 +113,7 @@ public class DailyMembersOrderStatisticsBiz extends BaseBiz<DailyMembersOrderSta
         }
         return true;
     }
+
     /**
      * 获取押金和
      *
@@ -143,16 +156,17 @@ public class DailyMembersOrderStatisticsBiz extends BaseBiz<DailyMembersOrderSta
         return mapper.insertSelective(entity);
     }
 
-    public OrderStatistics findAll(Integer companyId) {
-        return mapper.monthOrderTotal(companyId);
+    public OrderStatistics findAll(List<Integer> companyIds) {
+        return mapper.monthOrderTotal(companyIds);
     }
 
     /**
      * 根据时间按年月日分组
+     *
      * @param query
      * @return
      */
     public List<MembersOrder> getMemberOrderStatistics(OrderQuery query) {
-       return mapper.getMemberOrderStatistics(query);
+        return mapper.getMemberOrderStatistics(query);
     }
 }

xx-order/xx-order-server/src/main/java/com/xxfc/platform/order/biz/DailyOrderStatisticsBiz.java

@@ -26,9 +26,9 @@ public class DailyOrderStatisticsBiz extends BaseBiz<DailyOrderStatisticsMapper,
     private DailyMembersOrderStatisticsBiz membersStatisticsBiz;
 
     public boolean statisticalOrder(Integer day){
-        boolean vehicleFlag = vehicleStatisticsBiz.saveDailyVehicleOrderRecord(day);
-        boolean travelFlag = travelStatisticsBiz.saveDailyTravelOrderRecord(day);
-        boolean membersFlag= membersStatisticsBiz.saveDailyMembersOrderRecord(day);
+        boolean vehicleFlag = vehicleStatisticsBiz.dailyVehicleOrderRecord(day);
+        boolean travelFlag = travelStatisticsBiz.dailyTravelOrderRecord(day);
+        boolean membersFlag= membersStatisticsBiz.dailyMembersOrderRecord(day);
         if (vehicleFlag&&travelFlag&&membersFlag){
 
             log.info("----statisticalOrder:成功-----");

xx-order/xx-order-server/src/main/java/com/xxfc/platform/order/biz/DailyTravelOrderStatisticsBiz.java

@@ -12,6 +12,7 @@ import com.xxfc.platform.order.contant.enumerate.DeductionTypeEnum;
 import com.xxfc.platform.order.contant.enumerate.OrderTypeEnum;
 import com.xxfc.platform.order.entity.*;
 import com.xxfc.platform.order.mapper.DailyTravelOrderStatisticsMapper;
+import com.xxfc.platform.order.pojo.Term;
 import com.xxfc.platform.order.pojo.account.OrderAccountDTO;
 import com.xxfc.platform.order.pojo.account.OrderAccountDeduction;
 import com.xxfc.platform.order.pojo.account.OrderAccountDetail;
@@ -43,89 +44,18 @@ public class DailyTravelOrderStatisticsBiz extends BaseBiz<DailyTravelOrderStati
 
     @Autowired
     private OrderAccountBiz accountBiz;
-//     @Transactional(rollbackFor = Exception.class)
-//    public boolean StatisticsOfTravelOrders() {
-//        try {
-//
-//            ArrayList<DailyTravelOrderStatistics> objects = new ArrayList<>();
-//            List<DailyTravelOrderStatistics> travelGmv = mapper.getTravelGmv(day);
-//            objects.addAll(travelGmv);
-//            List<DailyTravelOrderStatistics> travelPenalSum = mapper.getTravelPenalSum(day);
-//            objects.addAll(travelPenalSum);
-//            insertByList(objects);
-//
-//            return true;
-//        } catch (Exception e) {
-//            e.printStackTrace();
-//            TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
-//            return false;
-//        }
-//    }
-//
-//    private void insertByList(ArrayList<DailyTravelOrderStatistics> objects) throws Exception {
-//
-//        if (CollectionUtils.isNotEmpty(objects)) {
-//            HashMap<Integer, DailyTravelOrderStatistics> map = new HashMap<>();
-//            for (DailyTravelOrderStatistics object : objects) {
-//
-//                DailyTravelOrderStatistics statistics = map.get(object.getBranchCompanyId());
-//                if (statistics == null) {
-//                    statistics = new DailyTravelOrderStatistics();
-//                    map.put(object.getBranchCompanyId(), statistics);
-//                }
-//
-//                BeanUtil.copyProperties(object, statistics, CopyOptions.create().setIgnoreNullValue(true).setIgnoreError(true));
-//
-//            }
-//            String oneDay = map.entrySet().parallelStream().map(Map.Entry::getValue).collect(Collectors.toList()).get(0).getOneDay();
-//
-//            if (StringUtils.isBlank(oneDay)) {
-//                throw new BaseException();
-//            }
-//            Example exa= new Example(DailyTravelOrderStatistics.class);
-//            exa.createCriteria().andEqualTo("oneDay",oneDay);
-//            List<DailyTravelOrderStatistics> statistics= selectByExample(exa);
-//            if (CollectionUtils.isEmpty(statistics)){
-//                for (Map.Entry<Integer, DailyTravelOrderStatistics> entry : map.entrySet()) {
-//                    insertSelectiveRe(entry.getValue());
-//                }
-//            }else {
-//                log.error("今日已统计车辆订单,请不要重复统计!");
-//            }
-//
-////
-////            for (Map.Entry<Integer, DailyTravelOrderStatistics> e : map.entrySet()) {
-////                insertSelectiveRe(e.getValue());
-////            }
-//        }
-//    }
-/******************************************************************************************************************************/
 
     /**
      * 统计订单并保存到数据库当中
      * @return
      */
     @Transactional(rollbackFor = Exception.class)
-    public boolean saveDailyTravelOrderRecord(Integer day) {
+    public boolean dailyTravelOrderRecord(Integer day) {
         try {
             //获取每日订单统计
-            List<DailyTravelOrderStatistics> orderStatistics = getDailyTravelOrderStatistics(day);
+            List<DailyTravelOrderStatistics> orderStatistics = getDailyTravelOrderStatistics(new Term(OrderTypeEnum.TOUR.getCode(),day,1,null,null,null));
             log.info("Travel:统计完成");
-            if (CollectionUtils.isNotEmpty(orderStatistics)) {
-                for (DailyTravelOrderStatistics orderStatistic : orderStatistics) {
-                    if (JudgmentOfExistence(orderStatistic)) {
-
-                        insertSelectiveRe(orderStatistic);
-                    } else {
-                        mapper.updateByExampleSelective(orderStatistic, Example.builder(DailyTravelOrderStatistics.class)
-                                .where(WeekendSqls.<DailyTravelOrderStatistics>custom()
-                                        .andEqualTo(DailyTravelOrderStatistics::getOneDay, orderStatistic.getOneDay())
-                                        .andEqualTo(DailyTravelOrderStatistics::getBranchCompanyId, orderStatistic.getBranchCompanyId()))
-                                .build());
-
-                    }
-                }
-            }
+            seve(orderStatistics);
             log.info("Travel:保存成功");
             return true;
         } catch (Exception e) {
@@ -135,6 +65,23 @@ public class DailyTravelOrderStatisticsBiz extends BaseBiz<DailyTravelOrderStati
         }
     }
 
+    public void seve(List<DailyTravelOrderStatistics> orderStatistics) {
+        if (CollectionUtils.isNotEmpty(orderStatistics)) {
+            for (DailyTravelOrderStatistics orderStatistic : orderStatistics) {
+                if (JudgmentOfExistence(orderStatistic)) {
+
+                    insertSelectiveRe(orderStatistic);
+                } else {
+                    mapper.updateByExampleSelective(orderStatistic, Example.builder(DailyTravelOrderStatistics.class)
+                            .where(WeekendSqls.<DailyTravelOrderStatistics>custom()
+                                    .andEqualTo(DailyTravelOrderStatistics::getOneDay, orderStatistic.getOneDay())
+                                    .andEqualTo(DailyTravelOrderStatistics::getBranchCompanyId, orderStatistic.getBranchCompanyId()))
+                            .build());
+                }
+            }
+        }
+    }
+
     /**
      * 添加前查询是否存在这条数据
      * @param orderStatistic
@@ -151,9 +98,9 @@ public class DailyTravelOrderStatisticsBiz extends BaseBiz<DailyTravelOrderStati
         }
         return true;
     }
-    private List<DailyTravelOrderStatistics> getDailyTravelOrderStatistics(Integer day) {
+    public List<DailyTravelOrderStatistics> getDailyTravelOrderStatistics(Term term) {
         //获取当天所有订单账目
-        List<OrderAccountDTO> accountList = accountBiz.getOrderAccountByOrderType(OrderTypeEnum.TOUR.getCode(), day);
+        List<OrderAccountDTO> accountList = accountBiz.getOrderAccountByOrderType(term);
         if (CollectionUtils.isEmpty(accountList)) {
             return null;
         }
@@ -225,19 +172,27 @@ public class DailyTravelOrderStatisticsBiz extends BaseBiz<DailyTravelOrderStati
         }
         if (CollectionUtils.isNotEmpty(arrayList)) {
             ArrayList<OrderAccountDetail> orderAccountDetail = getOrderAccountDetail(arrayList);
+
+
             if (CollectionUtils.isNotEmpty(orderAccountDetail)) {
+                //订单退还总额
+                BigDecimal depositAmountTotal = getOrderAmountTotal(orderAccountDetail);
+                orderStatistics.setReturnGmv(depositAmountTotal);
                 List<OrderAccountDeduction> OrderAccountDeductions = gettDeductions(orderAccountDetail);
                 //获取违约总额
                 BigDecimal bigDecimal = get(OrderAccountDeductions, new ArrayList<Integer>() {{
                     add(DeductionTypeEnum.VIOLATE_CANCEL.getCode());
+                    add(DeductionTypeEnum.VIOLATE_ADVANCE.getCode());
+                    add(DeductionTypeEnum.VIOLATE_DELAY.getCode());
                 }});
                 orderStatistics.setDefaultMoney(bigDecimal);
-                //订单退还总额
-                orderStatistics.setReturnGmv(orderStatistics.getGmv().subtract(bigDecimal));
+
             }
         }
     }
-   
+
+
+
 
     
     private DailyTravelOrderStatistics getGmvAndSecurityDeposit(Map<Integer, List<OrderAccountDTO>> map) {
@@ -256,6 +211,7 @@ public class DailyTravelOrderStatisticsBiz extends BaseBiz<DailyTravelOrderStati
         return orderStatistics;
     }
 
+
     /**
      * 获取金额详情
      *
@@ -322,7 +278,7 @@ public class DailyTravelOrderStatisticsBiz extends BaseBiz<DailyTravelOrderStati
         return mapper.insertSelective(entity);
     }
 
-    public OrderStatistics findAll(Integer branchCompanyId) {
-        return mapper.monthOrderTotal(branchCompanyId);
+    public OrderStatistics findAll(List<Integer> companyIds) {
+        return mapper.monthOrderTotal(companyIds);
     }
 }

xx-order/xx-order-server/src/main/java/com/xxfc/platform/order/biz/OrderAccountBiz.java

@@ -18,6 +18,7 @@ import com.xxfc.platform.order.contant.enumerate.*;
 import com.xxfc.platform.order.entity.*;
 import com.xxfc.platform.order.mapper.OrderAccountMapper;
 import com.xxfc.platform.order.pojo.DedDetailDTO;
+import com.xxfc.platform.order.pojo.Term;
 import com.xxfc.platform.order.pojo.account.OrderAccountDTO;
 import com.xxfc.platform.order.pojo.account.OrderAccountDeduction;
 import com.xxfc.platform.order.pojo.account.OrderAccountDetail;
@@ -511,12 +512,11 @@ public class OrderAccountBiz extends BaseBiz<OrderAccountMapper,OrderAccount> {
 
     /**
      * 获取每日订单账目,用于统计
-     * @param code
-     * @param day
+     * @param term
      * @return
      */
-    public List<OrderAccountDTO> getOrderAccountByOrderType(Integer code, Integer day) {
-        return mapper.getOrderAccountByOrderType(code,day);
+    public List<OrderAccountDTO> getOrderAccountByOrderType(Term term) {
+        return mapper.getOrderAccountByOrderType(term);
     }
 
 

xx-order/xx-order-server/src/main/java/com/xxfc/platform/order/biz/OrderStatisticsBiz.java

@@ -8,15 +8,13 @@ import com.github.wxiaoqi.security.common.msg.auth.PageResult;
 import com.google.common.collect.Maps;
 import com.xxfc.platform.order.Utils.OrderDateUtils;
 import com.xxfc.platform.order.contant.enumerate.OrderInquiryType;
-import com.xxfc.platform.order.entity.MembersOrder;
-import com.xxfc.platform.order.entity.OrderStatistics;
+import com.xxfc.platform.order.contant.enumerate.OrderTypeEnum;
+import com.xxfc.platform.order.entity.*;
 import com.xxfc.platform.order.mapper.OrderStatisticsMapper;
-import com.xxfc.platform.order.pojo.HomePageOrderData;
-import com.xxfc.platform.order.pojo.Member;
-import com.xxfc.platform.order.pojo.MembersOrderDto;
-import com.xxfc.platform.order.pojo.OrderQuery;
+import com.xxfc.platform.order.pojo.*;
 import org.apache.commons.collections.CollectionUtils;
 import org.apache.commons.lang3.StringUtils;
+import org.aspectj.weaver.ast.Var;
 import org.assertj.core.util.Lists;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
@@ -34,61 +32,111 @@ import java.util.stream.Collectors;
 public class OrderStatisticsBiz extends BaseBiz<OrderStatisticsMapper, OrderStatistics> {
     @Autowired
     private DailyVehicleOrderStatisticsBiz vehicleBiz;
-
-
     @Autowired
     private DailyTravelOrderStatisticsBiz TravelBiz;
-
     @Autowired
     private DailyMembersOrderStatisticsBiz membersBiz;
 
-    public HomePageOrderData getTotalOrder(Integer companyId) {
+    @Autowired
+    private DailyVehicleOrderStatisticsBiz vehicleStatisticsBiz;
+    @Autowired
+    private DailyTravelOrderStatisticsBiz travelStatisticsBiz;
+    @Autowired
+    private DailyMembersOrderStatisticsBiz membersStatisticsBiz;
+
+    public HomePageOrderData getTotalOrder(List<Integer> companyIds) {
         HomePageOrderData result = new HomePageOrderData();
-        ArrayList<HomePageOrderData> orderStatistics = new ArrayList<>();
+        ArrayList<HomePageOrderData> list = new ArrayList<>();
+        list.add(getVehicleHomePageOrderData(companyIds)) ;
+        list.add(getTourHomePageOrderData(companyIds));
+        list.add(getMemberHomePageOrderData(companyIds));
+        result.setTotalOrders(list.stream().map(HomePageOrderData::getTotalOrders).reduce(BigDecimal.ZERO, BigDecimal::add));
+        result.setTotalOutstandingDeposit(list.stream().map(HomePageOrderData::getTotalOutstandingDeposit).reduce(BigDecimal.ZERO, BigDecimal::add));
+        result.setAdditionalIndemnity(list.stream().map(HomePageOrderData::getAdditionalIndemnity).reduce(BigDecimal.ZERO, BigDecimal::add));
+        return result;
+    }
 
-        OrderStatistics vehicle = vehicleBiz.findAll(companyId);
-        if (vehicle != null) {
+    /**
+     * 会员数据
+     * @param companyIds
+     * @return
+     */
+    public HomePageOrderData getMemberHomePageOrderData(List<Integer> companyIds ) {
+        //今天之前的数据
+        OrderStatistics member = membersBiz.findAll(companyIds);
+        //当天的数据
+        DailyMembersOrderStatistics statistics = membersStatisticsBiz.statistics(new Term(OrderTypeEnum.MEMBER.getCode(), 0, 1, null, null, companyIds));
+        member.setTotalGmv(member.getTotalGmv().add(statistics.getGmv()));
+
+        if (member != null) {
             HomePageOrderData data = new HomePageOrderData() {{
-                setTotalOrders(vehicle.getTotalGmv().subtract(vehicle.getTotalReturnGmv()));
-                setAdditionalIndemnity(vehicle.getTotalCompensation()
-                        .add(vehicle.getTotalForfeit())
-                        .add(vehicle.getTotalDefaultMoney())
-                        .add(vehicle.getOrderCompensation()));
-                setTotalOutstandingDeposit(vehicle.getTotalSecurityDeposit()
-                        .subtract(vehicle.getTotalRefundSecurityDeposit())
-                        .subtract(getAdditionalIndemnity()));
+                setTotalOrders(member.getTotalGmv());
             }};
-            orderStatistics.add(data);
+            return data;
         }
-        OrderStatistics tour = TravelBiz.findAll(companyId);
+        return new HomePageOrderData();
+    }
 
-        if (vehicle != null) {
+
+    /**
+     * 旅游数据
+     * @param companyIds
+     * @return
+     */
+    public HomePageOrderData getTourHomePageOrderData(List<Integer> companyIds) {
+        //今天之前的数据
+        OrderStatistics tour = TravelBiz.findAll(companyIds);
+        //当天的数据
+        List<DailyTravelOrderStatistics> travelOrderStatistics = travelStatisticsBiz.getDailyTravelOrderStatistics(new Term(OrderTypeEnum.TOUR.getCode(), 0, 1, null, null, companyIds));
+        tour.setTotalGmv(tour.getTotalGmv().add(travelOrderStatistics.parallelStream().map(DailyOrderStatistics::getGmv).reduce(BigDecimal.ZERO,BigDecimal::add)));
+        tour.setTotalReturnGmv(tour.getTotalReturnGmv().add(travelOrderStatistics.parallelStream().map(DailyTravelOrderStatistics::getReturnGmv).reduce(BigDecimal.ZERO,BigDecimal::add)));
+//        tour.
+        if (tour != null) {
             HomePageOrderData data = new HomePageOrderData() {{
                 setTotalOrders(tour.getTotalGmv().subtract(tour.getTotalReturnGmv()));
                 setAdditionalIndemnity(tour.getTotalDefaultMoney());
             }};
-            orderStatistics.add(data);
-
+            return data;
         }
+        return new HomePageOrderData();
+    }
+
+    /**
+     * 车辆数据
+     * @param companyIds
+     * @return
+     */
+    public HomePageOrderData getVehicleHomePageOrderData(List<Integer> companyIds) {
+         //今天之前的数据
+        OrderStatistics vehicle = vehicleBiz.findAll(companyIds);
+        //当天的数据
+        List<DailyVehicleOrderStatistics> vehicleOrderRecord = vehicleStatisticsBiz.getDailyVehicleOrderRecord(new Term(OrderTypeEnum.RENT_VEHICLE.getCode(),0,1,null,null,companyIds));
+
 
-        OrderStatistics member = membersBiz.findAll(companyId);
         if (vehicle != null) {
             HomePageOrderData data = new HomePageOrderData() {{
-                setTotalOrders(member.getTotalGmv());
+                setTotalOrders(vehicle.getTotalGmv().subtract(vehicle.getTotalReturnGmv()));
+                setAdditionalIndemnity(vehicle.getTotalCompensation()
+                        .add(vehicle.getTotalForfeit())
+                        .add(vehicle.getTotalDefaultMoney())
+                        .add(vehicle.getTotalOrderCompensation()));
+                setTotalOutstandingDeposit(vehicle.getTotalSecurityDeposit()
+                        .subtract(vehicle.getTotalRefundSecurityDeposit())
+                        .subtract(getAdditionalIndemnity()));
             }};
-            orderStatistics.add(data);
+            return data;
         }
-
-
-        result.setTotalOrders(orderStatistics.stream().map(HomePageOrderData::getTotalOrders).filter(o -> Objects.nonNull(o)).reduce(BigDecimal.ZERO, BigDecimal::add));
-
-        result.setTotalOutstandingDeposit(orderStatistics.stream().map(HomePageOrderData::getTotalOutstandingDeposit).filter(o -> Objects.nonNull(o)).reduce(BigDecimal.ZERO, BigDecimal::add));
-
-        result.setAdditionalIndemnity(orderStatistics.stream().map(HomePageOrderData::getAdditionalIndemnity).filter(o -> Objects.nonNull(o)).reduce(BigDecimal.ZERO, BigDecimal::add));
-
-        return result;
+        return  new HomePageOrderData();
     }
 
+
+    /**
+     * 会员统计列表
+     * @param memberLevels
+     * @param query
+     * @return
+     * @throws ParseException
+     */
     public PageResult getMemberOrderStatistics(List<BaseUserMemberLevel> memberLevels, OrderQuery query) throws ParseException {
 
         List<MembersOrder> membersOrderList = membersBiz.getMemberOrderStatistics(query);
@@ -176,16 +224,11 @@ public class OrderStatisticsBiz extends BaseBiz<OrderStatisticsMapper, OrderStat
         //进行分页处理
 
      return   PageResult.nowPageResult(query.getPage(),query.getLimit(),arrayList);
-
-
-//        return pagingProcessing(query, arrayList);
-
     }
 
 
 
     private void TotalPaymentAndMemberName(HashMap<Integer, String> map, MembersOrder mb, MembersOrderDto mbdto) {
-
         BigDecimal totalPayment = BigDecimal.ZERO;
         List<Member> members = mb.getMembers();
         //设置时间段购买会员总金额和不同的会员名称

xx-order/xx-order-server/src/main/java/com/xxfc/platform/order/mapper/DailyMembersOrderStatisticsMapper.java

@@ -18,7 +18,7 @@ public interface DailyMembersOrderStatisticsMapper extends Mapper<DailyMembersOr
 
     Map<String, Object> getTravelGmv(@Param("day") Integer day);
 
-    OrderStatistics monthOrderTotal(@Param("companyId") Integer companyId);
+    OrderStatistics monthOrderTotal(List<Integer> companyIds);
 
 
 

xx-order/xx-order-server/src/main/java/com/xxfc/platform/order/mapper/DailyTravelOrderStatisticsMapper.java

@@ -19,5 +19,5 @@ public interface DailyTravelOrderStatisticsMapper extends Mapper<DailyTravelOrde
 
     List<DailyTravelOrderStatistics> getTravelPenalSum(@Param("day") Integer day);
 
-    OrderStatistics monthOrderTotal(@Param("companyId")Integer companyId);
+    OrderStatistics monthOrderTotal(List<Integer> companyIds);
 }

xx-order/xx-order-server/src/main/java/com/xxfc/platform/order/mapper/DailyVehicleOrderStatisticsMapper.java

@@ -25,5 +25,5 @@ public interface DailyVehicleOrderStatisticsMapper extends Mapper<DailyVehicleOr
 
     List<DailyVehicleOrderStatistics> getViolationMoney(@Param("day") Integer day);
 
-    OrderStatistics monthOrderTotal(@Param("companyId")Integer companyId);
+    OrderStatistics monthOrderTotal(List<Integer> companyIds);
 }

xx-order/xx-order-server/src/main/java/com/xxfc/platform/order/mapper/OrderAccountMapper.java

 package com.xxfc.platform.order.mapper;
 
 import com.xxfc.platform.order.entity.OrderAccount;
+import com.xxfc.platform.order.pojo.Term;
 import com.xxfc.platform.order.pojo.account.OrderAccountDTO;
 import org.apache.ibatis.annotations.Param;
 import tk.mybatis.mapper.common.Mapper;
@@ -17,5 +18,5 @@ import java.util.List;
  */
 public interface OrderAccountMapper extends Mapper<OrderAccount> {
 
-    List<OrderAccountDTO> getOrderAccountByOrderType(@Param("type") Integer type, @Param("day") Integer day);
+    List<OrderAccountDTO> getOrderAccountByOrderType(Term term);
 }

xx-order/xx-order-server/src/main/java/com/xxfc/platform/order/rest/background/OrderStatisticsController.java

 package com.xxfc.platform.order.rest.background;
 
-import cn.hutool.core.collection.CollUtil;
 import cn.hutool.core.io.IoUtil;
 import cn.hutool.poi.excel.ExcelUtil;
 import cn.hutool.poi.excel.ExcelWriter;
 import com.github.wxiaoqi.security.admin.entity.BaseUserMemberLevel;
 import com.github.wxiaoqi.security.admin.feign.UserFeign;
 import com.github.wxiaoqi.security.admin.feign.dto.UserDTO;
+import com.github.wxiaoqi.security.admin.feign.rest.UserRestInterface;
 import com.github.wxiaoqi.security.auth.client.config.UserAuthConfig;
 import com.github.wxiaoqi.security.common.exception.BaseException;
 import com.github.wxiaoqi.security.common.msg.ObjectRestResponse;
 import com.github.wxiaoqi.security.common.rest.BaseController;
-import com.github.wxiaoqi.security.common.util.Query;
 import com.github.wxiaoqi.security.common.util.process.ResultCode;
-import com.google.common.collect.Lists;
 import com.xxfc.platform.order.biz.DailyMembersOrderStatisticsBiz;
 import com.xxfc.platform.order.biz.DailyTravelOrderStatisticsBiz;
 import com.xxfc.platform.order.biz.DailyVehicleOrderStatisticsBiz;
@@ -22,23 +20,18 @@ import com.xxfc.platform.order.entity.OrderStatistics;
 import com.xxfc.platform.order.pojo.HomePageOrderData;
 import com.xxfc.platform.order.pojo.MembersOrderDto;
 import com.xxfc.platform.order.pojo.OrderQuery;
+import com.xxfc.platform.vehicle.common.RestResponse;
+import com.xxfc.platform.vehicle.feign.VehicleFeign;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
-import org.apache.commons.collections.CollectionUtils;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.beans.factory.annotation.Value;
 import org.springframework.web.bind.annotation.*;
 
 import javax.servlet.ServletOutputStream;
 import javax.servlet.http.HttpServletResponse;
-import java.io.IOException;
-import java.lang.reflect.Array;
-import java.text.DateFormat;
 import java.text.ParseException;
-import java.util.Date;
 import java.util.HashMap;
 import java.util.List;
-import java.util.stream.Collectors;
 
 /**
  * @author Administrator
@@ -90,62 +83,40 @@ public class OrderStatisticsController extends BaseController<OrderStatisticsBiz
     @Autowired
     private DailyMembersOrderStatisticsBiz membersBiz;
 
+    @Autowired
+    private VehicleFeign vehicleFeign;
+
 
     @ApiOperation("获取订单统计数据")
     @GetMapping("/findAll/{type}")
     public ObjectRestResponse findAll(@PathVariable Integer type) {
 
-
         try {
             ObjectRestResponse<UserDTO> userDTOObjectRestResponse
                     = userFeign.userinfoByToken(userAuthConfig.getToken(getRequest()));
-
             if (userDTOObjectRestResponse == null || userDTOObjectRestResponse.getData() == null) {
-                throw new BaseException("请登录!");
+                throw new BaseException("token失效!");
             }
             UserDTO user = userDTOObjectRestResponse.getData();
-
-            Integer companyId = user.getCompanyId();
-            if (DATA_AUTHORITY.equals(user.getDataAll())) {
-                companyId = null;
+            List<Integer> companyIds = null;
+            if (!DATA_AUTHORITY.equals(user.getDataAll())) {
+                companyIds = vehicleFeign.getCompanyIds().getData();
             }
-
             //只统计租车订单
             if (TYPE_VEHICLE.equals(type)) {
-                OrderStatistics vehicle = vehicleBiz.findAll(companyId);
-                return ObjectRestResponse.succ(new HomePageOrderData() {{
-                    setTotalOrders(vehicle.getTotalGmv().subtract(vehicle.getTotalReturnGmv()));
-                    setAdditionalIndemnity(vehicle.getTotalCompensation()
-                            .add(vehicle.getTotalForfeit())
-                            .add(vehicle.getTotalDefaultMoney())
-                            .add(vehicle.getOrderCompensation())
-                    );
-                    setTotalOutstandingDeposit(vehicle.getTotalSecurityDeposit()
-                            .subtract(vehicle.getTotalRefundSecurityDeposit())
-                            .subtract(getAdditionalIndemnity()));
-                }});
+                return ObjectRestResponse.succ(baseBiz.getVehicleHomePageOrderData(companyIds));
             }
-            //只统计会租车订单
+            //只统计旅游订单
             if (TYPE_TOUR.equals(type)) {
-                OrderStatistics tour = TravelBiz.findAll(companyId);
-                return ObjectRestResponse.succ(new HomePageOrderData() {{
-                    setTotalOrders(tour.getTotalGmv().subtract(tour.getTotalReturnGmv()));
-                    setAdditionalIndemnity(tour.getTotalDefaultMoney());
-                }});
-
+                return ObjectRestResponse.succ(baseBiz.getTourHomePageOrderData(companyIds));
             }
-            //只统计会员定案
+            //只统计会员订单
             if (TYPE_MEMBER.equals(type)) {
-                OrderStatistics member = membersBiz.findAll(companyId);
-                return ObjectRestResponse.succ(new HomePageOrderData() {{
-                    setTotalOrders(member.getTotalGmv());
-
-                }});
+                return ObjectRestResponse.succ(baseBiz.getMemberHomePageOrderData(companyIds));
             }
-
             //所有订单
             if (TYPE_TOTAL.equals(type)) {
-                return ObjectRestResponse.succ(baseBiz.getTotalOrder(companyId));
+                return ObjectRestResponse.succ(baseBiz.getTotalOrder(companyIds));
             }
             return ObjectRestResponse.createFailedResult(ResultCode.FAILED_CODE, "参数错误!");
         } catch (Exception e) {
@@ -154,12 +125,11 @@ public class OrderStatisticsController extends BaseController<OrderStatisticsBiz
         }
 
     }
-
     @PostMapping("/order")
     @ApiOperation(value = "会员统计")
     public ObjectRestResponse<List<MembersOrderDto>> getMemberOrderStatisticsData(@RequestBody OrderQuery query) throws ParseException {
-        if (query.getEndTime()!=null) {
-            query.setEndTime(query.getEndTime()+(24*60*60*1000));
+        if (query.getEndTime() != null) {
+            query.setEndTime(query.getEndTime() + (24 * 60 * 60 * 1000));
         }
         //获取会员等级信息
         List<BaseUserMemberLevel> memberLevels = userFeign.levels();
@@ -171,8 +141,8 @@ public class OrderStatisticsController extends BaseController<OrderStatisticsBiz
     @PostMapping("/excel")
     @ApiOperation(value = "下载excel表")
     public void downloadExcel(@RequestBody OrderQuery query) throws Exception {
-        if (query.getEndTime()!=null) {
-            query.setEndTime(query.getEndTime()+(24*60*60*1000));
+        if (query.getEndTime() != null) {
+            query.setEndTime(query.getEndTime() + (24 * 60 * 60 * 1000));
         }
         // 通过工具类创建writer，默认创建xls格式
         ExcelWriter writer = ExcelUtil.getWriter(true);

xx-order/xx-order-server/src/main/resources/mapper/DailyMembersOrderStatisticsMapper.xml

@@ -22,10 +22,12 @@
         daily_members_order_statistics
         WHERE
         1=1
-        <if test="companyId != null">
-            and branch_company_id = #{companyId}
+        <if test="companyIds != null and companyIds.size()!=0">
+            and branch_company_id  in
+            <foreach collection="companyIds" index="index" item="companyId" open="(" separator="," close=")" >
+                #{companyId}
+            </foreach>
         </if>
-
     </select>
     <!--    <select id="updateByExampleSelective">-->
     <!--                SELECT-->

xx-order/xx-order-server/src/main/resources/mapper/DailyTravelOrderStatisticsMapper.xml

@@ -58,8 +58,11 @@
         daily_travel_order_statistics
         WHERE
         1=1
-        <if test="companyId != null">
-            and branch_company_id = #{companyId}
+        <if test="companyIds != null and companyIds.size()!=0">
+            and branch_company_id  in
+            <foreach collection="companyIds" index="index" item="companyId" open="(" separator="," close=")" >
+                #{companyId}
+            </foreach>
         </if>
     </select>
 

xx-order/xx-order-server/src/main/resources/mapper/DailyVehicleOrderStatisticsMapper.xml

@@ -89,13 +89,16 @@
         IFNULL( sum( compensation ), 0 ) AS totalCompensation,
         IFNULL( sum( return_gmv ), 0 ) AS totalReturnGmv,
         IFNULL( sum( default_money ), 0 ) AS totalDefaultMoney,
-        IFNULL( sum( order_compensation ), 0 ) AS orderCompensation
+        IFNULL( sum( order_compensation ), 0 ) AS totalOrderCompensation
         FROM
         daily_vehicle_order_statistics
         WHERE
         1=1
-        <if test="companyId != null">
-           and branch_company_id = #{companyId}
+        <if test="companyIds != null and companyIds.size()!=0">
+           and branch_company_id  in
+           <foreach collection="companyIds" index="index" item="companyId" open="(" separator="," close=")" >
+               #{companyId}
+           </foreach>
         </if>
     </select>
 

xx-order/xx-order-server/src/main/resources/mapper/OrderAccountMapper.xml

@@ -3,27 +3,52 @@
 <mapper namespace="com.xxfc.platform.order.mapper.OrderAccountMapper">
     <select id="getOrderAccountByOrderType" resultType="com.xxfc.platform.order.pojo.account.OrderAccountDTO">
         SELECT
-        date(DATE_SUB(now(),interval #{day} day)) as oneDay,
+        <if test="subdivide !=null and subdivide ==1">
+            date( FROM_UNIXTIME( a.crt_time / 1000 ) ) as oneDay,
+        </if>
         a.*
-        <if test="type != null and type == 1">
+        <if test="orderType != null and orderType == 1">
             , v.start_company_id as companyId
         </if>
-        <if test="type != null and type == 2">
+        <if test="orderType != null and orderType == 2">
             , t.start_company_id as companyId
         </if>
         FROM
         order_account a
         LEFT JOIN base_order b ON a.order_id = b.id
-        <if test="type != null and type==1">
+        <if test="orderType != null and orderType==1">
             LEFT JOIN order_rent_vehicle_detail v ON b.id = v.order_id
         </if>
-        <if test="type != null and type==2">
+        <if test="orderType != null and orderType==2">
             LEFT JOIN order_tour_detail t ON b.id = t.order_id
         </if>
         WHERE
         a.account_status=1
         AND
-        b.type = #{type}
-        AND date( FROM_UNIXTIME( a.crt_time / 1000 ) ) = date( DATE_SUB( now( ), INTERVAL #{day} DAY ) )
+        b.type = #{orderType}
+        <if test="startTime != null">
+            AND  a.crt_time <![CDATA[>= ]]>  #{startTime}
+        </if>
+        <if test="endTime != null">
+            AND a.crt_time &gt; endTime
+        </if>
+        <if test="companyIds != null and  companyIds.size() != 0 ">
+            <if test="orderType != null and orderType == 1">
+                AND v.start_company_id in
+                <foreach collection="companyIds" index="index" item="companyId" open="(" separator="," close=")">
+                    #{companyId}
+                </foreach>
+            </if>
+            <if test="orderType != null and orderType == 2">
+                AND t.start_company_id in
+                <foreach collection="companyIds" index="index" item="companyId" open="(" separator="," close=")">
+                    #{companyId}
+                </foreach>
+            </if>
+        </if>
+        <if test="subdivide !=null and subdivide ==1">
+            AND date( FROM_UNIXTIME( a.crt_time / 1000 ) ) = date( DATE_SUB( now( ), INTERVAL #{day} DAY ) )
+        </if>
+
     </select>
 </mapper>
\ No newline at end of file

xx-order/xx-order-server/src/test/java/ServiceTest.java

@@ -61,10 +61,9 @@ public class ServiceTest {
     }
 
 
-
     @Test
     public void handlerTeset()  {
-        handler.execute("2019-08-01");
+        handler.execute("2019-08-16");
     }
 
 

xx-universal/xx-universal-server/src/main/java/com/xxfc/platform/universal/service/authenticationInterface/impl/XCFQAuthentication.java

@@ -70,6 +70,7 @@ public class XCFQAuthentication implements UserAuthentication {
             /**
              * 状态码: 200 正常；400 URL无效；401 appCode错误； 403 次数用完； 500 API网管错误
              */
+            log.info("外部接口响应状态码:"+statusCode);
             //获取response的body
             if (statusCode == 200) {
                 String result = EntityUtils.toString(response.getEntity());

xx-vehicle/xx-vehicle-api/src/main/java/com/xxfc/platform/vehicle/feign/VehicleFeign.java

@@ -163,4 +163,7 @@ public interface VehicleFeign {
 
     @GetMapping("/vehicleInfo/findVehicleIds")
     List<String> findbyPlateNumberAndVehicleCod(@RequestParam(value = "plateNumber") String plateNumber,@RequestParam(value = "vehicleCode") String vehicleCode);
+
+    @RequestMapping(value ="/branchCompany/app/unauth/getCompanyIds",method = RequestMethod.GET)
+    RestResponse<List<Integer>> getCompanyIds();
 }

xx-vehicle/xx-vehicle-server/src/main/java/com/xxfc/platform/vehicle/biz/BranchCompanyBiz.java

@@ -411,4 +411,8 @@ public class BranchCompanyBiz extends BaseBiz<BranchCompanyMapper, BranchCompany
         return  ObjectRestResponse.succ(list);
     }
 
+    public List<Integer> getCompanyIds() {
+        UserDTO userDTO = getAdminUserInfo();
+       return vehicleBiz.dataCompany(userDTO.getDataZone(), userDTO.getDataCompany());
+    }
 }

xx-vehicle/xx-vehicle-server/src/main/java/com/xxfc/platform/vehicle/rest/BranchCompanyController.java

@@ -25,7 +25,9 @@ import com.xxfc.platform.vehicle.pojo.vo.BranchCompanyListVO;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.collections.CollectionUtils;
 import org.apache.commons.lang3.StringUtils;
+import org.assertj.core.util.Lists;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.*;
@@ -35,6 +37,7 @@ import javax.servlet.http.HttpServletRequest;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
+import java.util.stream.Collectors;
 
 @RestController
 @RequestMapping("/branchCompany")
@@ -217,4 +220,11 @@ public class BranchCompanyController extends BaseController<BranchCompanyBiz> {
     public ObjectRestResponse<List<BranchCompany>> companys() {
         return baseBiz.branchCompans();
     }
+
+    @RequestMapping(value ="/app/unauth/getCompanyIds",method = RequestMethod.GET)
+    public RestResponse<List<Integer>> getCompanyIds() {
+            return RestResponse.suc(baseBiz.getCompanyIds());
+
+    }
+
 }