| New file | 
 |  |  | 
 |  |  | package com.dy.rtuMw; | 
 |  |  |  | 
 |  |  | import org.mybatis.spring.annotation.MapperScan; | 
 |  |  | import org.springframework.beans.factory.annotation.Autowired; | 
 |  |  | import org.springframework.boot.CommandLineRunner; | 
 |  |  | import org.springframework.boot.SpringApplication; | 
 |  |  | import org.springframework.boot.autoconfigure.SpringBootApplication; | 
 |  |  | import org.springframework.context.annotation.ComponentScan; | 
 |  |  | import org.springframework.context.annotation.EnableAspectJAutoProxy; | 
 |  |  | import org.springframework.context.annotation.FilterType; | 
 |  |  | import org.springframework.scheduling.annotation.EnableScheduling; | 
 |  |  |  | 
 |  |  | @EnableScheduling | 
 |  |  | @SpringBootApplication | 
 |  |  | @EnableAspectJAutoProxy | 
 |  |  | @ComponentScan(basePackages = {"com.dy.common", "com.dy.pipIrrGlobal", "com.dy.rtuMw"}, | 
 |  |  |     excludeFilters = { | 
 |  |  |         @ComponentScan.Filter(type = FilterType.ASSIGNABLE_TYPE, classes = { | 
 |  |  |             com.dy.common.apiDoc.SpringApiConfig.class | 
 |  |  |         }), | 
 |  |  |         @ComponentScan.Filter(type = FilterType.REGEX, pattern = { | 
 |  |  |             //以下写正则表达式,需要对目标类的完全限定名完全匹配,否则不生效 | 
 |  |  |             "com.dy.common.multiDataSource..*" | 
 |  |  |         }) | 
 |  |  |     } | 
 |  |  | ) | 
 |  |  | @MapperScan(basePackages={"com.dy.pipIrrGlobal"}) | 
 |  |  | public class PipIrrMwRtuApplication implements CommandLineRunner { | 
 |  |  |  | 
 |  |  |     public static void main(String[] args) { | 
 |  |  |         SpringApplication.run(PipIrrMwRtuApplication.class, args); | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     /** | 
 |  |  |      * Spring容器启动完成后,执行下面方法 | 
 |  |  |      * @param args 参数 | 
 |  |  |      * @throws Exception 异常 | 
 |  |  |      */ | 
 |  |  |     @Override | 
 |  |  |     public void run(String... args) throws Exception { | 
 |  |  |         try{ | 
 |  |  |             //等待数据库初始化完成 | 
 |  |  |             Thread.sleep(1000L); | 
 |  |  |         }catch (Exception e){ | 
 |  |  |             e.printStackTrace(); | 
 |  |  |         } | 
 |  |  |         finally { | 
 |  |  |             this.startMwSv() ; | 
 |  |  |         } | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     private void startMwSv(){ | 
 |  |  |         if(sv != null){ | 
 |  |  |             sv.startServer(); | 
 |  |  |         } | 
 |  |  |     } | 
 |  |  |     private Server sv ; | 
 |  |  |  | 
 |  |  |     @Autowired | 
 |  |  |     public void setSv(Server sv){ | 
 |  |  |         this.sv = sv ; | 
 |  |  |     } | 
 |  |  | } |