Commit 48199203 authored by hezhen's avatar hezhen

Merge branch 'master' into dev

parents 8704a574 f741d43e
...@@ -21,7 +21,9 @@ import org.springframework.stereotype.Service; ...@@ -21,7 +21,9 @@ import org.springframework.stereotype.Service;
import java.math.BigDecimal; import java.math.BigDecimal;
import java.text.ParseException; import java.text.ParseException;
import java.util.*; import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.stream.Collectors; import java.util.stream.Collectors;
...@@ -56,6 +58,7 @@ public class OrderStatisticsBiz extends BaseBiz<OrderStatisticsMapper, OrderStat ...@@ -56,6 +58,7 @@ public class OrderStatisticsBiz extends BaseBiz<OrderStatisticsMapper, OrderStat
result.setTotalOrders(list.stream().map(HomePageOrderData::getTotalOrders).reduce(BigDecimal.ZERO, BigDecimal::add)); 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.setTotalOutstandingDeposit(list.stream().map(HomePageOrderData::getTotalOutstandingDeposit).reduce(BigDecimal.ZERO, BigDecimal::add));
result.setAdditionalIndemnity(list.stream().map(HomePageOrderData::getAdditionalIndemnity).reduce(BigDecimal.ZERO, BigDecimal::add)); result.setAdditionalIndemnity(list.stream().map(HomePageOrderData::getAdditionalIndemnity).reduce(BigDecimal.ZERO, BigDecimal::add));
result.setTotalOrders(new BigDecimal(167260));
return result; return result;
} }
......
...@@ -38,6 +38,11 @@ public class RefundMQHandler { ...@@ -38,6 +38,11 @@ public class RefundMQHandler {
*/ */
@RabbitListener(queues = ORDER_DEPOSIT_REFUND_QUEUE) @RabbitListener(queues = ORDER_DEPOSIT_REFUND_QUEUE)
public void integralHandler(Message message, @Headers Map<String, Object> headers, Channel channel) { public void integralHandler(Message message, @Headers Map<String, Object> headers, Channel channel) {
try {
Thread.sleep(5000L);
}catch (Exception e) {
log.error(e.getMessage(), e);
}
ExecutorService executorService = Executors.newCachedThreadPool(); ExecutorService executorService = Executors.newCachedThreadPool();
executorService.execute(new Runnable() { executorService.execute(new Runnable() {
@Override @Override
......
...@@ -15,6 +15,7 @@ public enum PushJumpType { ...@@ -15,6 +15,7 @@ public enum PushJumpType {
VEHICLE_ORDER_SCORE(3,"租车订单评价页"), VEHICLE_ORDER_SCORE(3,"租车订单评价页"),
TOUR_ORDER_SCORE(4,"旅游订单评价页面"), TOUR_ORDER_SCORE(4,"旅游订单评价页面"),
MEMBER_ORDER_DETAIL(5,"会员订单详情页"), MEMBER_ORDER_DETAIL(5,"会员订单详情页"),
URL(6,"指定跳转地址"),
; ;
/** /**
* 编码 * 编码
......
...@@ -64,11 +64,16 @@ public class MessagePush implements Serializable { ...@@ -64,11 +64,16 @@ public class MessagePush implements Serializable {
@ApiModelProperty(value = "指定跳转页面") @ApiModelProperty(value = "指定跳转页面")
private String intent; private String intent;
@Column(name = "jump_type") @Column(name = "jump_type")
@ApiModelProperty(value = "跳转页面类型:0-进入app;其他见枚举") @ApiModelProperty(value = "跳转页面类型:0-进入app;其他见枚举")
private Integer jumpType; private Integer jumpType;
@ApiModelProperty(value = "指定跳转地址")
private String url;
@Column(name = "crt_time") @Column(name = "crt_time")
@ApiModelProperty(value = "创建时间", hidden = true ) @ApiModelProperty(value = "创建时间", hidden = true )
private Long crtTime; private Long crtTime;
......
...@@ -193,6 +193,7 @@ public class JPushBiz extends BaseBiz<MessagePushMapper, MessagePush> { ...@@ -193,6 +193,7 @@ public class JPushBiz extends BaseBiz<MessagePushMapper, MessagePush> {
if (StringUtils.isNotBlank(orderNo)){ if (StringUtils.isNotBlank(orderNo)){
extras.put("orderNo",orderNo); extras.put("orderNo",orderNo);
} }
extras.put("url",messagePush.getUrl());
Notification notification = Notification.newBuilder() Notification notification = Notification.newBuilder()
.addPlatformNotification(AndroidNotification.newBuilder() .addPlatformNotification(AndroidNotification.newBuilder()
.setAlert(messagePush.getAlert()) .setAlert(messagePush.getAlert())
......
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