订单支付成功发送更新mq
This commit is contained in:
@@ -1,12 +1,14 @@
|
|||||||
package com.czg.service.order.service.impl;
|
package com.czg.service.order.service.impl;
|
||||||
|
|
||||||
import cn.hutool.core.date.DateUtil;
|
import cn.hutool.core.date.DateUtil;
|
||||||
|
import com.czg.config.RabbitPublisher;
|
||||||
import com.czg.order.entity.OrderDetail;
|
import com.czg.order.entity.OrderDetail;
|
||||||
import com.czg.order.service.OrderDetailService;
|
import com.czg.order.service.OrderDetailService;
|
||||||
import com.czg.order.vo.OrderDetailPrintVo;
|
import com.czg.order.vo.OrderDetailPrintVo;
|
||||||
import com.czg.service.order.mapper.OrderDetailMapper;
|
import com.czg.service.order.mapper.OrderDetailMapper;
|
||||||
import com.mybatisflex.core.query.QueryWrapper;
|
import com.mybatisflex.core.query.QueryWrapper;
|
||||||
import com.mybatisflex.spring.service.impl.ServiceImpl;
|
import com.mybatisflex.spring.service.impl.ServiceImpl;
|
||||||
|
import jakarta.annotation.Resource;
|
||||||
import org.apache.dubbo.config.annotation.DubboService;
|
import org.apache.dubbo.config.annotation.DubboService;
|
||||||
|
|
||||||
import java.time.LocalDateTime;
|
import java.time.LocalDateTime;
|
||||||
@@ -33,6 +35,7 @@ public class OrderDetailServiceImpl extends ServiceImpl<OrderDetailMapper, Order
|
|||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void updateOrderDetailStatus(Long orderId,String status) {
|
public void updateOrderDetailStatus(Long orderId,String status) {
|
||||||
|
|
||||||
OrderDetail orderDetail = new OrderDetail();
|
OrderDetail orderDetail = new OrderDetail();
|
||||||
orderDetail.setStatus(status);
|
orderDetail.setStatus(status);
|
||||||
orderDetail.setOrderTime(LocalDateTime.now());
|
orderDetail.setOrderTime(LocalDateTime.now());
|
||||||
|
|||||||
@@ -1340,7 +1340,7 @@ public class OrderInfoCustomServiceImpl implements OrderInfoCustomService {
|
|||||||
rabbitPublisher.sendOrderPrintMsg(printParam, isPrint);
|
rabbitPublisher.sendOrderPrintMsg(printParam, isPrint);
|
||||||
// log.info("非事务环境下,直接发送订单{}打印消息", orderId);
|
// log.info("非事务环境下,直接发送订单{}打印消息", orderId);
|
||||||
}
|
}
|
||||||
|
rabbitPublisher.sendOrderDetailStatusMsg(orderInfo.getShopId().toString());
|
||||||
redisService.del(RedisCst.classKeyExpired.EXPIRED_ORDER + orderInfo.getId());
|
redisService.del(RedisCst.classKeyExpired.EXPIRED_ORDER + orderInfo.getId());
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user