From e3bf70ab9edff58786121e50a0e72a81e1d82a3d Mon Sep 17 00:00:00 2001
From: wangw <1594593906@qq.com>
Date: Fri, 9 Jan 2026 16:10:04 +0800
Subject: [PATCH] MQ

---
 .../com/czg/controller/admin/EntryManagerController.java | 9 +++++++++
 .../service/order/mapper/ShopDirectMerchantMapper.java   | 3 ++-
 2 files changed, 11 insertions(+), 1 deletion(-)

diff --git a/cash-api/order-server/src/main/java/com/czg/controller/admin/EntryManagerController.java b/cash-api/order-server/src/main/java/com/czg/controller/admin/EntryManagerController.java
index 500d9bf1e..53fd4b3ec 100644
--- a/cash-api/order-server/src/main/java/com/czg/controller/admin/EntryManagerController.java
+++ b/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();
+    }
+
     /**
      * 获取进件列表
      */
diff --git a/cash-service/order-service/src/main/java/com/czg/service/order/mapper/ShopDirectMerchantMapper.java b/cash-service/order-service/src/main/java/com/czg/service/order/mapper/ShopDirectMerchantMapper.java
index 36b91db54..a56042505 100644
--- a/cash-service/order-service/src/main/java/com/czg/service/order/mapper/ShopDirectMerchantMapper.java
+++ b/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);
 }