提交 326ae873 authored 作者: liuhaiquan's avatar liuhaiquan

修改消息队列中获取token失败的问题

上级 9d318857
...@@ -694,19 +694,17 @@ public class OrderCancelServiceImpl implements OrderCancelService { ...@@ -694,19 +694,17 @@ public class OrderCancelServiceImpl implements OrderCancelService {
orderGoodsService.batchUpdateResidueWeight(orderGoodsList); orderGoodsService.batchUpdateResidueWeight(orderGoodsList);
//触发自动冻结的mq消费逻辑 //触发自动冻结的mq消费逻辑
triggerAutoFreeze(orderNo); triggerAutoFreeze(orderInfoFeign.getOwnerUserNo(),orderNo);
} }
//订单取消增加自动冻结的消息触发 //订单取消增加自动冻结的消息触发
private void triggerAutoFreeze(String orderNo){ private void triggerAutoFreeze(Long ownerUserNo,String orderNo){
try{ try{
UserSessionData loginUserInfo = TokenUtil.getLoginUserInfo();
Long ownerUserNo = loginUserInfo.getUserNo();
OwnerInfoFeignVO ownerInfo = ownerInfoService.getOwnerInfo(ownerUserNo); OwnerInfoFeignVO ownerInfo = ownerInfoService.getOwnerInfo(ownerUserNo);
//充值成功并且当前货主是冻结方式是自动冻结,则触发自动冻结的mq监听 //充值成功并且当前货主是冻结方式是自动冻结,则触发自动冻结的mq监听
if(Objects.equals(ownerInfo.getFreezeSetting(), FreezeSettingEnum.AUTO.getCode())){ if(Objects.equals(ownerInfo.getFreezeSetting(), FreezeSettingEnum.AUTO.getCode())){
log.info("货主取消订单,发送自动冻结的mq消息,货主编号:{},货主姓名:{},订单编号:{}",ownerUserNo,loginUserInfo.getUserName(),orderNo); log.info("货主取消订单,发送自动冻结的mq消息,货主编号:{},订单编号:{}",ownerUserNo,orderNo);
FreezeTriggerMqParam mq = new FreezeTriggerMqParam(); FreezeTriggerMqParam mq = new FreezeTriggerMqParam();
mq.setUserNo(ownerUserNo); mq.setUserNo(ownerUserNo);
Message message = MessageBuilder.withBody(JSON.toJSONString(new MqWrapper<>(mq)).getBytes()).build(); Message message = MessageBuilder.withBody(JSON.toJSONString(new MqWrapper<>(mq)).getBytes()).build();
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论