Merge branch 'dev' of http://git.elinkit.com.cn:7070/r/epmet-cloud into develop

epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/feign/EpmetBaseRequestInterceptor.java

@@ -47,6 +47,9 @@ public class EpmetBaseRequestInterceptor implements RequestInterceptor {
         HashMap<String, String> headers = new HashMap<>();
 
         RequestAttributes requestAttributes = RequestContextHolder.getRequestAttributes();
+        if (requestAttributes == null) {
+            return null;
+        }
         HttpServletRequest request = ((ServletRequestAttributes) requestAttributes).getRequest();
         Enumeration<String> headerNames = request.getHeaderNames();
         if (headerNames != null) {

epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/mq/listener/OpenDataProjectChangeEventListener.java

@@ -11,7 +11,6 @@ import com.epmet.commons.tools.redis.RedisUtils;
 import com.epmet.commons.tools.utils.ConvertUtils;
 import com.epmet.commons.tools.utils.SpringContextUtils;
 import com.epmet.dto.basereport.form.EventInfoFormDTO;
-import com.epmet.feign.EpmetMessageOpenFeignClient;
 import com.epmet.opendata.service.BaseDisputeProcessService;
 import org.apache.commons.lang3.StringUtils;
 import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext;
@@ -34,8 +33,6 @@ public class OpenDataProjectChangeEventListener implements MessageListenerConcur
 
     private Logger logger = LoggerFactory.getLogger(getClass());
 
-    private EpmetMessageOpenFeignClient messageOpenFeignClient;
-
     private RedisUtils redisUtils;
 
     private DistributedLock distributedLock;

epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/mq/listener/OpenDataStaffChangeEventListener.java

@@ -10,7 +10,6 @@ import com.epmet.commons.tools.exception.RenException;
 import com.epmet.commons.tools.redis.RedisKeys;
 import com.epmet.commons.tools.redis.RedisUtils;
 import com.epmet.commons.tools.utils.SpringContextUtils;
-import com.epmet.feign.EpmetMessageOpenFeignClient;
 import com.epmet.opendata.dto.form.StaffBaseInfoFormDTO;
 import com.epmet.opendata.service.ExUserService;
 import org.apache.commons.lang3.StringUtils;
@@ -35,16 +34,14 @@ public class OpenDataStaffChangeEventListener implements MessageListenerConcurre
 
     private Logger logger = LoggerFactory.getLogger(getClass());
 
-    private EpmetMessageOpenFeignClient messageOpenFeignClient;
-
     private RedisUtils redisUtils;
 
     private DistributedLock distributedLock;
-    
+
     public OpenDataStaffChangeEventListener(DistributedLock distributedLock) {
         this.distributedLock = distributedLock;
     }
-    
+
     @Override
     public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> msgs, ConsumeConcurrentlyContext context) {