...
|
...
|
@@ -88,25 +88,18 @@ public class BigDataOrderInfoTask { |
|
|
//获取trackingCode
|
|
|
orderInfo.setTrackingCode(userOrders.getTrackingCode());
|
|
|
orderInfo.setMbrName(userOrders.getMbrName());
|
|
|
String clientId = orderInfo.getClientId();
|
|
|
if(clientId.startsWith("800")){
|
|
|
clientId = clientId.substring(3);
|
|
|
}
|
|
|
//组装分类
|
|
|
if (!orderInfoMap.containsKey(clientId)) {
|
|
|
if (!orderInfoMap.containsKey(orderInfo.getClientId())) {
|
|
|
orderInfoMap.put(orderInfo.getClientId(), Lists.newArrayList(orderInfo));
|
|
|
continue;
|
|
|
}
|
|
|
orderInfoMap.get(clientId).add(orderInfo);
|
|
|
orderInfoMap.get(orderInfo.getClientId()).add(orderInfo);
|
|
|
}
|
|
|
|
|
|
//应该推送的clientId
|
|
|
List<UnionTypeManage> unionTypeManageList = unionTypeManageDAO.selectAll();
|
|
|
//按source分类推送
|
|
|
for (String clientId : orderInfoMap.keySet()) {
|
|
|
if(clientId.startsWith("800")){
|
|
|
clientId = clientId.substring(3);
|
|
|
}
|
|
|
if(!checkIsPush(clientId,unionTypeManageList))
|
|
|
continue;
|
|
|
IOrderPushService orderPushService = orderPushServiceMap.get(clientId);
|
...
|
...
|
|