...
|
...
|
@@ -56,11 +56,12 @@ public class BuyerOrderCancelShamDeliveryMsgConsumer implements YhConsumer { |
|
|
List<ExpressInfo> ls = expressInfoMapper.selectByOrderCodeAndExpressType(orderCode, EnumExpressType.EXPRESS_TYPE_1.getCode());
|
|
|
ls = ls.stream().filter(info->(EnumExpressDataType.erp_logistics.getCode()==info.getDataType())).collect(Collectors.toList());
|
|
|
if(CollectionUtils.isNotEmpty(ls)){
|
|
|
logger.info("BuyerOrderCancelShamDeliveryMsgConsumer topic {}, msg {} ,not cancel order because exist express info ", getMessageTopic(), o);
|
|
|
logger.info("BuyerOrderCancelShamDeliveryMsgConsumer return because exists express info, so order cancel fail topic {}, msg {} ", getMessageTopic(), o);
|
|
|
return ;
|
|
|
}
|
|
|
logger.info("BuyerOrderCancelShamDeliveryMsgConsumer begin ExpressInfoList {} topic {}, msg {}",ls, getMessageTopic(), event);
|
|
|
buyerOrderCancelService.cancelForSellerShamSendOut(buyerUid,orderCode, OrderStatus.SELLER_SHAM_SEND_OUT_AUTO);
|
|
|
logger.info("BuyerOrderCancelShamDeliveryMsgConsumer topic {}, msg {} finish", getMessageTopic(), event);
|
|
|
logger.info("BuyerOrderCancelShamDeliveryMsgConsumer finish topic {}, msg {} ", getMessageTopic(), event);
|
|
|
|
|
|
//TODO 记录操作日志
|
|
|
orderOperateRecordService.addRecord(orderCode,"系统取消", OperateTypeEnum.OPERATE_TYPE_QUALITY_SHAM_CANCEL_OUT_TIME);
|
...
|
...
|
|