czg_team/cashier_server
7
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

接口名称问题

Browse Source
This commit is contained in:
wangw
2026-01-08 10:57:07 +08:00
parent e5be277941
commit 0a86cdc769
2 changed files with 4 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -56,7 +56,7 @@ public class EntryManagerController {
* 进件状态是INIT 待处理 AUDIT 审核中 SIGN 待签约 * 进件状态是INIT 待处理 AUDIT 审核中 SIGN 待签约
* 3分钟内只能查一次 * 3分钟内只能查一次
*/ */
@GetMapping @GetMapping("queryEntry")
@Debounce(value = "#shopId", interval = 1000 * 60 * 3) @Debounce(value = "#shopId", interval = 1000 * 60 * 3)
public CzgResult<Boolean> queryEntry(Long shopId) { public CzgResult<Boolean> queryEntry(Long shopId) {
entryManagerTask.entryManager(shopId); entryManagerTask.entryManager(shopId);

7
cash-api/order-server/src/main/java/com/czg/mq/PrintMqListener.java
View File

@@ -6,13 +6,12 @@ import com.czg.config.RabbitConstants;
import com.czg.config.RedisCst; import com.czg.config.RedisCst;
import com.czg.order.entity.MqLog; import com.czg.order.entity.MqLog;
import com.czg.order.service.MqLogService; import com.czg.order.service.MqLogService;
import com.czg.service.RedisService;
import com.czg.service.order.print.PrinterHandler; import com.czg.service.order.print.PrinterHandler;
import com.czg.service.order.utils.FunUtil;
import jakarta.annotation.Resource; import jakarta.annotation.Resource;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.rabbit.annotation.RabbitListener; import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.context.annotation.Lazy; import org.springframework.context.annotation.Lazy;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import java.util.function.Consumer; import java.util.function.Consumer;
@@ -28,7 +27,7 @@ public class PrintMqListener {
@Resource @Resource
private MqLogService mqLogService; private MqLogService mqLogService;
@Resource @Resource
private FunUtil funUtil; private RedisService redisService;
@Lazy @Lazy
@Resource @Resource
private PrinterHandler printerHandler; private PrinterHandler printerHandler;
@@ -59,7 +58,7 @@ public class PrintMqListener {
throw new RuntimeException("订单打印失败，未传递orderId"); throw new RuntimeException("订单打印失败，未传递orderId");
} }
Boolean printOrder = jsonObject.getBoolean("printOrder"); Boolean printOrder = jsonObject.getBoolean("printOrder");
funUtil.runFunAndCheckKey(() -> { redisService.runFunAndCheckKey(() -> {
printerHandler.handler(orderId, printOrder != null && !printOrder ? PrinterHandler.PrintTypeEnum.ONE : PrinterHandler.PrintTypeEnum.ONE_AND_ORDER); printerHandler.handler(orderId, printOrder != null && !printOrder ? PrinterHandler.PrintTypeEnum.ONE : PrinterHandler.PrintTypeEnum.ONE_AND_ORDER);
return null; return null;
}, RedisCst.getLockKey("orderPrint", orderId)); }, RedisCst.getLockKey("orderPrint", orderId));