去掉没用的

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) {