Commit f4ad7dd6 authored by hanfeng's avatar hanfeng

修改统计

parent 5c239dbf
...@@ -14,11 +14,7 @@ import java.math.BigDecimal; ...@@ -14,11 +14,7 @@ import java.math.BigDecimal;
@Data @Data
@ApiModel(value = "月订单统计实体") @ApiModel(value = "月订单统计实体")
public class OrderStatistics { public class OrderStatistics {
/**
* 公司id
*/
@ApiModelProperty(value = "公司id")
private Integer branchCompanyId;
/** /**
* 月成交总金额 * 月成交总金额
*/ */
......
...@@ -11,6 +11,7 @@ import org.apache.commons.beanutils.BeanUtils; ...@@ -11,6 +11,7 @@ import org.apache.commons.beanutils.BeanUtils;
import org.apache.commons.collections.CollectionUtils; import org.apache.commons.collections.CollectionUtils;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.annotation.Transactional;
import org.springframework.transaction.interceptor.TransactionAspectSupport;
import java.math.BigDecimal; import java.math.BigDecimal;
import java.util.Date; import java.util.Date;
...@@ -43,6 +44,7 @@ public class DailyMembersOrderStatisticsBiz extends BaseBiz<DailyMembersOrderSta ...@@ -43,6 +44,7 @@ public class DailyMembersOrderStatisticsBiz extends BaseBiz<DailyMembersOrderSta
} }
return true; return true;
} catch (Exception e) { } catch (Exception e) {
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
e.printStackTrace(); e.printStackTrace();
return false; return false;
} }
......
...@@ -3,10 +3,51 @@ package com.xxfc.platform.order.biz; ...@@ -3,10 +3,51 @@ package com.xxfc.platform.order.biz;
import com.github.wxiaoqi.security.common.biz.BaseBiz; import com.github.wxiaoqi.security.common.biz.BaseBiz;
import com.xxfc.platform.order.entity.OrderStatistics; import com.xxfc.platform.order.entity.OrderStatistics;
import com.xxfc.platform.order.mapper.OrderStatisticsMapper; import com.xxfc.platform.order.mapper.OrderStatisticsMapper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import java.math.BigDecimal;
import java.util.ArrayList;
import static io.lettuce.core.ZStoreArgs.Builder.sum;
import static java.util.stream.Collectors.groupingBy;
/** /**
* @author Administrator * @author Administrator
*/ */
@Service @Service
public class OrderStatisticsBiz extends BaseBiz<OrderStatisticsMapper,OrderStatistics> { public class OrderStatisticsBiz extends BaseBiz<OrderStatisticsMapper,OrderStatistics> {
@Autowired
private DailyVehicleOrderStatisticsBiz vehicleBiz;
@Autowired
private DailyTravelOrderStatisticsBiz TravelBiz;
@Autowired
private DailyMembersOrderStatisticsBiz membersBiz;
public OrderStatistics getToalOrder(Integer companyId) {
OrderStatistics result = new OrderStatistics();
ArrayList<OrderStatistics> orderStatistics = new ArrayList<>();
OrderStatistics vehicle = vehicleBiz.findAll(companyId);
if (vehicle!=null) {orderStatistics.add(vehicle);}
OrderStatistics tour = TravelBiz.findAll(companyId);
if (vehicle!=null) {orderStatistics.add(tour);}
OrderStatistics member = membersBiz.findAll(companyId);
if (vehicle!=null) {orderStatistics.add(member);}
result.setTotalGmv(orderStatistics.stream().map(OrderStatistics::getTotalGmv).reduce(BigDecimal.ZERO,BigDecimal::add));
result.setTotalForfeit(orderStatistics.stream().map(OrderStatistics::getTotalForfeit).reduce(BigDecimal.ZERO,BigDecimal::add));
result.setTotalCompensation(orderStatistics.stream().map(OrderStatistics::getTotalCompensation).reduce(BigDecimal.ZERO,BigDecimal::add));
result.setTotalRefundSecurityDeposit(orderStatistics.stream().map(OrderStatistics::getTotalRefundSecurityDeposit).reduce(BigDecimal.ZERO,BigDecimal::add));
result.setTotalSecurityDeposit(orderStatistics.stream().map(OrderStatistics::getTotalSecurityDeposit).reduce(BigDecimal.ZERO,BigDecimal::add));
result.setTotalPenalSum(orderStatistics.stream().map(OrderStatistics::getTotalPenalSum).reduce(BigDecimal.ZERO,BigDecimal::add));
result.setTotalPostpone(orderStatistics.stream().map(OrderStatistics::getTotalPostpone).reduce(BigDecimal.ZERO,BigDecimal::add));
return result;
}
} }
...@@ -70,6 +70,7 @@ public class OrderStatisticsController extends BaseController<OrderStatisticsBiz ...@@ -70,6 +70,7 @@ public class OrderStatisticsController extends BaseController<OrderStatisticsBiz
throw new BaseException("请登录!"); throw new BaseException("请登录!");
} }
UserDTO user = userDTOObjectRestResponse.getData(); UserDTO user = userDTOObjectRestResponse.getData();
Integer companyId = user.getCompanyId(); Integer companyId = user.getCompanyId();
if (TYEP_VEHICLE.equals(type)) { if (TYEP_VEHICLE.equals(type)) {
OrderStatistics vehicle = vehicleBiz.findAll(companyId); OrderStatistics vehicle = vehicleBiz.findAll(companyId);
...@@ -84,7 +85,9 @@ public class OrderStatisticsController extends BaseController<OrderStatisticsBiz ...@@ -84,7 +85,9 @@ public class OrderStatisticsController extends BaseController<OrderStatisticsBiz
return ObjectRestResponse.succ(member); return ObjectRestResponse.succ(member);
} }
if (TYEP_TOTAL.equals(type)){
baseBiz.getToalOrder(companyId);
}
return ObjectRestResponse.createFailedResult(ResultCode.FAILED_CODE,"参数为空!"); return ObjectRestResponse.createFailedResult(ResultCode.FAILED_CODE,"参数为空!");
} }
} }
...@@ -17,7 +17,7 @@ ...@@ -17,7 +17,7 @@
<select id="monthOrderTotal" resultType="com.xxfc.platform.order.entity.OrderStatistics"> <select id="monthOrderTotal" resultType="com.xxfc.platform.order.entity.OrderStatistics">
SELECT SELECT
branch_company_id as branchCompanyId,
IFNULL(sum(gmv),0) as totalGmv IFNULL(sum(gmv),0) as totalGmv
FROM FROM
daily_travel_order_statistics daily_travel_order_statistics
......
...@@ -51,7 +51,7 @@ ...@@ -51,7 +51,7 @@
<select id="monthOrderTotal" resultType="com.xxfc.platform.order.entity.OrderStatistics"> <select id="monthOrderTotal" resultType="com.xxfc.platform.order.entity.OrderStatistics">
SELECT SELECT
branch_company_id as branchCompanyId,
IFNULL(sum(gmv),0) as totalGmv, IFNULL(sum(gmv),0) as totalGmv,
IFNULL(sum(penal_sum) ,0) as totalPenalSum IFNULL(sum(penal_sum) ,0) as totalPenalSum
FROM FROM
......
...@@ -139,7 +139,7 @@ ...@@ -139,7 +139,7 @@
<select id="monthOrderTotal" resultType="com.xxfc.platform.order.entity.OrderStatistics"> <select id="monthOrderTotal" resultType="com.xxfc.platform.order.entity.OrderStatistics">
SELECT SELECT
branch_company_id as branchCompanyId,
IFNULL(sum(gmv),0) as totalGmv, IFNULL(sum(gmv),0) as totalGmv,
IFNULL(sum(security_deposit),0) as totalSecurityDeposit, IFNULL(sum(security_deposit),0) as totalSecurityDeposit,
IFNULL(sum(refund_security_deposit) ,0) as totalRefundSecurityDeposit, IFNULL(sum(refund_security_deposit) ,0) as totalRefundSecurityDeposit,
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment