MQ

cash-api/order-server/src/main/java/com/czg/controller/admin/EntryManagerController.java

@@ -3,6 +3,7 @@ package com.czg.controller.admin;
 import com.alibaba.fastjson2.JSONObject;
 import com.czg.EntryManager;
 import com.czg.annotation.Debounce;
+import com.czg.config.RabbitPublisher;
 import com.czg.dto.req.AggregateMerchantDto;
 import com.czg.dto.resp.BankBranchDto;
 import com.czg.order.entity.ShopDirectMerchant;
@@ -33,6 +34,8 @@ public class EntryManagerController {
     @Resource
     private EntryManagerTask entryManagerTask;
 
+    @Resource
+    private RabbitPublisher rabbitPublisher;
     /**
      * ocr识别填充
      * 阿里 ocr识别图片
@@ -64,6 +67,12 @@ public class EntryManagerController {
         return CzgResult.success(EntryManager.queryBankBranchList(province, city, instId));
     }
 
+    @GetMapping("test")
+    public CzgResult<Void> test(String shopId) {
+        rabbitPublisher.sendEntryManagerMsg(shopId);
+        return CzgResult.success();
+    }
+
     /**
      * 获取进件列表
      */

cash-service/order-service/src/main/java/com/czg/service/order/mapper/ShopDirectMerchantMapper.java

@@ -3,6 +3,7 @@ package com.czg.service.order.mapper;
 import com.czg.service.order.dto.MerchantQueryDTO;
 import com.mybatisflex.core.BaseMapper;
 import com.czg.order.entity.ShopDirectMerchant;
+import org.apache.ibatis.annotations.Param;
 
 import java.util.List;
 
@@ -14,5 +15,5 @@ import java.util.List;
  */
 public interface ShopDirectMerchantMapper extends BaseMapper<ShopDirectMerchant> {
 
-    List<ShopDirectMerchant> getEntryList(MerchantQueryDTO queryParam);
+    List<ShopDirectMerchant> getEntryList(@Param("queryParam") MerchantQueryDTO queryParam);
 }