Browse Source

消费数量限制

lyhzzz 1 year ago
parent
commit
b5c6c2e065

+ 1 - 0
src/main/java/com/fdkankan/ucenter/mq/consumer/AutoOrderConsumer.java

@@ -42,6 +42,7 @@ public class AutoOrderConsumer {
 
     @RabbitListener(
             queuesToDeclare = @Queue("${queue.pay.auto-paypal:pay-auto-paypal}")
+            , priority = "10"
     )
     public void consumerQueue(Channel channel, Message message)  {
         try {

+ 1 - 0
src/main/java/com/fdkankan/ucenter/mq/consumer/LaserSceneStatusConsumer.java

@@ -28,6 +28,7 @@ public class LaserSceneStatusConsumer {
 
     @RabbitListener(
             queuesToDeclare = @Queue("${queue.scene.laser.status:update-scene-status-ucent}")
+            , priority = "10"
     )
     public void consumerQueue(Channel channel, Message message)  {
         try {

+ 1 - 0
src/main/java/com/fdkankan/ucenter/mq/consumer/OrderDownConsumer.java

@@ -44,6 +44,7 @@ public class OrderDownConsumer {
 
     @RabbitListener(
             queuesToDeclare = @Queue("${queue.orderPay.order-payResult:order-payResult}")
+            , priority = "10"
     )
     public void consumerQueue(Channel channel, Message message)  {
         try {

+ 1 - 0
src/main/java/com/fdkankan/ucenter/mq/consumer/ScenePayStatusConsumer.java

@@ -32,6 +32,7 @@ public class ScenePayStatusConsumer {
 
     @RabbitListener(
             queuesToDeclare = @Queue("${queue.scene.pay-status:scene-pay-status}")
+            , priority = "10"
     )
     public void consumerQueue(Channel channel, Message message)  {
         try {

+ 2 - 1
src/main/java/com/fdkankan/ucenter/util/DateUserUtil.java

@@ -2,6 +2,7 @@ package com.fdkankan.ucenter.util;
 
 import cn.hutool.core.date.DateUnit;
 import cn.hutool.core.date.DateUtil;
+import com.fdkankan.common.util.SecurityUtil;
 import com.fdkankan.ucenter.common.MailUtil;
 import com.fdkankan.ucenter.entity.IncrementType;
 import com.fdkankan.ucenter.entity.ScenePro;
@@ -135,7 +136,7 @@ public class DateUserUtil {
     }
 
     public static void main(String[] args) {
-        System.out.println(getLastZeroTime("2023-03-01 00:00:00"));
+        System.out.println(SecurityUtil.MD5(":\u0011\u001B\u0018\u0015\u0007\u0011\u00064DGFE"));
     }
 
     public static Date getHoursTime(Date date){