| | |
| | | private BigDecimal settleMent;// 确认收货金额
|
| | | private Long sourceUid;// 产生该订单的用户
|
| | | private Date createTime;// 创建时间
|
| | | private Date placeOrderTime;// 下单时间
|
| | |
|
| | | public OrderConfirmMQMsg(String orderNo, int sourceType, BigDecimal settleMent, Long sourceUid, Date createTime) {
|
| | | public OrderConfirmMQMsg(String orderNo, int sourceType, BigDecimal settleMent, Long sourceUid, Date placeOrderTime,
|
| | | Date createTime) {
|
| | | super();
|
| | | this.orderNo = orderNo;
|
| | | this.sourceType = sourceType;
|
| | | this.settleMent = settleMent;
|
| | | this.sourceUid = sourceUid;
|
| | | this.createTime = createTime;
|
| | | this.placeOrderTime = placeOrderTime;
|
| | | }
|
| | |
|
| | | public String getOrderNo() {
|
| | |
| | | this.createTime = createTime;
|
| | | }
|
| | |
|
| | | public Date getPlaceOrderTime() {
|
| | | return placeOrderTime;
|
| | | }
|
| | |
|
| | | public void setPlaceOrderTime(Date placeOrderTime) {
|
| | | this.placeOrderTime = placeOrderTime;
|
| | | }
|
| | |
|
| | | }
|
| | |
| | | if (!Constant.IS_TEST) { |
| | | // 统计结算金额 |
| | | BigDecimal settlement = new BigDecimal("0"); |
| | | CommonOrder firstOrder = null; |
| | | for (CommonOrderAddResultDTO dto : resultList) |
| | | if (dto.getCommonOrder().getSettlement() != null) |
| | | if (dto.getCommonOrder().getSettlement() != null) { |
| | | settlement = settlement.add(dto.getCommonOrder().getSettlement()); |
| | | CommonOrder firstOrder=resultList.get(0).getCommonOrder(); |
| | | OrderConfirmMQMsg mqMsg = new OrderConfirmMQMsg(firstOrder.getOrderNo(), |
| | | firstOrder.getSourceType(), settlement, firstOrder.getUserInfo().getId(), |
| | | new Date()); |
| | | Message msg = MQMsgBodyFactory.create(MQTopicName.TOPIC_ORDER, OrderTopicTagEnum.orderConfirm, mqMsg); |
| | | orderProducer.send(msg); |
| | | if (firstOrder == null) |
| | | firstOrder = dto.getCommonOrder(); |
| | | } |
| | | if (firstOrder != null) { |
| | | Date placeDate = firstOrder.getThirdCreateTime(); |
| | | OrderConfirmMQMsg mqMsg = new OrderConfirmMQMsg(firstOrder.getOrderNo(), firstOrder.getSourceType(), |
| | | settlement, firstOrder.getUserInfo().getId(), placeDate, new Date()); |
| | | Message msg = MQMsgBodyFactory.create(MQTopicName.TOPIC_ORDER, OrderTopicTagEnum.orderConfirm, |
| | | mqMsg); |
| | | orderProducer.send(msg); |
| | | } |
| | | } |
| | | } |
| | | |