| | |
|---|
| | | return;
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | // 查询该订单之前是否有到账
|
|---|
| | | List<HongBaoOrder> list = hongBaoOrderMapper.listByOrderIdAndSourceType(
|
|---|
| | | hongBaoOrder.getCommonOrder().getOrderNo(), hongBaoOrder.getCommonOrder().getSourceType());
|
|---|
| | | List<Long> hongBaoIdList = new ArrayList<>();
|
|---|
| | | if (list != null) {
|
|---|
| | | for (HongBaoOrder ho : list) {
|
|---|
| | | hongBaoIdList.add(ho.getHongBaoV2().getId());
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | List<HongBaoV2> allHongBaoList = hongBaoV2Mapper.listByIds(hongBaoIdList);
|
|---|
| | | boolean first = true;
|
|---|
| | | for (HongBaoV2 v2 : allHongBaoList)
|
|---|
| | | if (v2.getState() == HongBaoV2.STATE_YILINGQU) {
|
|---|
| | | first = false;
|
|---|
| | | break;
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | // 自购到账事务消息
|
|---|
| | | OrderMoneyRecievedMQMsgDTO mqMsg = new OrderMoneyRecievedMQMsgDTO(OrderMoneyRecievedMQMsgDTO.TYPE_ZIGOU,
|
|---|
| | | mainUser.getId(), hongBaoOrder.getCommonOrder().getSourceType(),
|
|---|
| | | hongBaoOrder.getCommonOrder().getOrderNo(), null, new Date());
|
|---|
| | | mqMsg.setOrderFirst(first);
|
|---|
| | | Message msg = new Message(MQTopicName.TOPIC_FANLI.name(), "actual", new Gson().toJson(mqMsg).getBytes());
|
|---|
| | | String key = mainUser.getId() + "-" + UUID.randomUUID().toString();
|
|---|
| | | msg.setKey(key);
|
|---|
