离线包状态

src/main/java/com/fdkankan/manage/aop/PushJm.java

@@ -0,0 +1,12 @@
+package com.fdkankan.manage.aop;
+
+import java.lang.annotation.*;
+
+@Retention(RetentionPolicy.RUNTIME)
+@Documented
+@Target({ElementType.TYPE, ElementType.METHOD})
+public @interface PushJm {
+    String value() default "";
+
+    String desc() default "";
+}

src/main/java/com/fdkankan/manage/aop/PushJmAspect.java

@@ -0,0 +1,44 @@
+package com.fdkankan.manage.aop;
+
+import cn.hutool.core.util.StrUtil;
+import com.fdkankan.common.constant.ErrorCode;
+import com.fdkankan.common.exception.BusinessException;
+import lombok.extern.log4j.Log4j2;
+import lombok.extern.slf4j.Slf4j;
+import org.aspectj.lang.JoinPoint;
+import org.aspectj.lang.annotation.After;
+import org.aspectj.lang.annotation.Aspect;
+import org.aspectj.lang.annotation.Before;
+import org.aspectj.lang.annotation.Pointcut;
+import org.aspectj.lang.reflect.MethodSignature;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.core.annotation.Order;
+import org.springframework.stereotype.Component;
+import org.springframework.web.context.request.RequestContextHolder;
+import org.springframework.web.context.request.ServletRequestAttributes;
+
+import javax.servlet.http.HttpServletRequest;
+import java.io.IOException;
+import java.lang.reflect.Method;
+
+@Slf4j
+@Aspect
+@Component
+public class PushJmAspect {
+
+
+	@Pointcut("@annotation(com.fdkankan.manage.aop.PushJm)")
+	public void servicePush() {
+	}
+	@After("servicePush()")
+	public void doBefore(JoinPoint joinPoint) throws Exception {
+		MethodSignature signature = (MethodSignature)joinPoint.getSignature();
+		Method method = signature.getMethod();
+		PushJm methodAnnotation = method.getAnnotation(PushJm.class);
+
+		String value = methodAnnotation.value();
+		String desc = methodAnnotation.desc();
+
+	}
+
+}

src/main/java/com/fdkankan/manage/config/ManageConfig.java

@@ -18,6 +18,9 @@ public class ManageConfig {
     @Value("${manage.share.scene}")
     private String shareScenes;
 
+    @Value("${manage.push-jm.url}")
+    private String pushJmUrl;
+
     public List<String> getNumList(){
         if(StringUtils.isNotBlank(this.shareScenes)){
             String[] split = shareScenes.split(",");

src/main/java/com/fdkankan/manage/controller/IncrementTypeController.java

@@ -2,6 +2,7 @@ package com.fdkankan.manage.controller;
 
 
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.fdkankan.manage.aop.PushJm;
 import com.fdkankan.manage.common.ResultData;
 import com.fdkankan.manage.entity.IncrementType;
 import com.fdkankan.manage.service.IIncrementTypeService;

src/main/java/com/fdkankan/manage/mq/consumer/PushJMConsumer.java

@@ -0,0 +1,42 @@
+package com.fdkankan.manage.mq.consumer;
+
+import com.alibaba.fastjson.JSONObject;
+import com.rabbitmq.client.Channel;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.amqp.core.Message;
+import org.springframework.amqp.rabbit.annotation.Queue;
+import org.springframework.amqp.rabbit.annotation.RabbitListener;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.nio.charset.StandardCharsets;
+
+/**
+ * 场景封存解封 mq
+ */
+@Slf4j
+@Component
+public class PushJMConsumer {
+
+
+    @RabbitListener(
+            queuesToDeclare = @Queue("${queue.manage.push-jm:push-jm}")
+    )
+    public void consumerQueue(Channel channel, Message message)  {
+        try {
+            String messageId = message.getMessageProperties().getMessageId();
+            String msg = new String(message.getBody(), StandardCharsets.UTF_8);
+            log.info("push-jm-mq--messageId:{},msg:{}",messageId,msg);
+
+            channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
+
+        }catch (Exception e){
+            log.info("push-jm-mq------消费失败",e);
+        }finally {
+
+        }
+
+    }
+
+}