1

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

@@ -1,12 +0,0 @@
-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

@@ -1,44 +0,0 @@
-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,9 +18,6 @@ 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

@@ -1,18 +1,11 @@
 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;
-import com.fdkankan.manage.vo.request.OrderParam;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.beans.factory.annotation.Value;
 import org.springframework.web.bind.annotation.*;
 
-import java.util.WeakHashMap;
-
 /**
  * <p>
  * 会员权益类型 前端控制器

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

@@ -1,42 +0,0 @@
-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 {
-
-        }
-
-    }
-
-}