将CMQ替换为rabbitmq

admin

2024-10-14 b9b263043cbb2e028017b9a5626c664b54513749

 fanli/src/main/java/com/yeshi/fanli/controller/client/v1/UserOrderController.java

@@ -13,6 +13,7 @@
import javax.servlet.http.HttpServletRequest;

import com.yeshi.fanli.util.*;
import com.yeshi.fanli.util.mq.rabbit.RabbitmqManager;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
@@ -97,6 +98,9 @@

   @Resource
   private TeamDividentsSourceOrderService teamDividentsSourceOrderService;

   @Resource
   private RabbitmqManager rabbitmqManager;

   /**
    * 订单列表
@@ -660,7 +664,7 @@
                     try {
                        isS = orderService.addOrder(or);
                        if (isS) {
                           CMQManager.getInstance().addTaoBaoOrderMsg(order);
                           rabbitmqManager.addTaoBaoOrderMsg(order);
                           // 加入到LostOrder
                           LostOrder lo = new LostOrder();
                           lo.setCreateTime(System.currentTimeMillis());