Merge branch 'refs/heads/v16.3_line_warn_20240528' into test

performance-web/src/main/java/com/clx/performance/listener/RabbitOrderGoodsStatusOnHandler.java

@@ -5,6 +5,7 @@ import com.clx.performance.dao.OrderGoodsDao;
 import com.clx.performance.enums.OrderGoodsStatusEnum;
 import com.clx.performance.model.OrderGoods;
 import com.clx.performance.service.IntegralMqService;
+import com.clx.performance.service.linewarn.LineWarnMqService;
 import com.msl.common.base.Optional;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang.exception.ExceptionUtils;
@@ -25,6 +26,8 @@ public class RabbitOrderGoodsStatusOnHandler {
 
     @Autowired
     private IntegralMqService integralMqService;
+    @Autowired
+    private LineWarnMqService lineWarnMqService;
 
     @RabbitListener(queues = RabbitKeyConstants.ORDER_GOODS_ON_DEAD_QUEUE)
     public void onMessage(String message) {
@@ -42,6 +45,9 @@ public class RabbitOrderGoodsStatusOnHandler {
             log.info("处理货单状态由已挂单变为挂单中监听器执行,从状态{}-----变更为{}", orderGoods.getOrderGoodsStatus(), OrderGoodsStatusEnum.Status.PAYING.getName());
             orderGoodsDao.updateOrderGoodsStatusByOrderGoodsNo(orderGoods.getOrderGoodsNo(), OrderGoodsStatusEnum.Status.PAYING.getCode());
 
+            // 发送mq
+            lineWarnMqService.orderGoodsAdd(orderGoods.getOrderGoodsNo());
+
             // 添加积分货单
             try {
                 integralMqService.orderGoodsAdd(orderGoods.getOrderGoodsNo(),