飞天班第12节：SpringBoot开发单体应用（下）

@Configuration
@EnableSwagger2
public class SwaggerConfig {

	// 注册bean Docker，可以注册多个来分组
  @Bean
	public Docket demoDocket(){
		Docket docket = new Docket(DocumentationType.SWAGGER_2).groupName("demo");
		return docket;
	}
  
  @Bean
	public Docket adminDocket(){
		Docket docket = new Docket(DocumentationType.SWAGGER_2).groupName("admin");
		return docket;
	}
}

 public Docket(DocumentationType documentationType) {
        this.apiInfo = ApiInfo.DEFAULT;
        this.groupName = "default";
        this.enabled = true;
        this.genericsNamingStrategy = new DefaultGenericTypeNamingStrategy();
        this.applyDefaultResponseMessages = true;
        this.host = "";
        this.pathMapping = Optional.absent();
        this.apiSelector = ApiSelector.DEFAULT;
        this.enableUrlTemplating = false;
        this.vendorExtensions = Lists.newArrayList();
        this.documentationType = documentationType;
    }

 public static final Contact DEFAULT_CONTACT = new Contact("", "", "");
 public static final ApiInfo DEFAULT = new ApiInfo("Api Documentation", "Api Documentation", "1.0", "urn:tos",
          DEFAULT_CONTACT, "Apache 2.0", "http://www.apache.org/licenses/LICENSE-2.0", new ArrayList<VendorExtension>());

@Bean
public Docket demoDocket(){
  return new Docket(DocumentationType.SWAGGER_2)
    .groupName("demo")
    .apiInfo(demoApiinfo())
    .select()
    .apis(RequestHandlerSelectors.basePackage("com.jude.demo"))// 包路径扫描到文档中
    .build();
}

private ApiInfo demoApiinfo(){
  // 建造者模式
  return new ApiInfoBuilder()
    .contact(new Contact("icoding","https://www.icodingedu.com/","icoding666@qq.com"))   // 作者联系方式
    .version("1.0.0")   // 文档版本号
    .description("测试使用")    // 简介
    .title("艾编程-测试API文档")   // 标题
    .termsOfServiceUrl("https://www.icodingedu.com/my/course/52")   // 服务链接
    .build();
}

any()	// 扫描所有接口
none()	// 不扫描接口
basePackage	// 根据包路径扫描
withMethodAnnotation(final Class<? extends Annotation> annotation)	// 通过方法上的注解扫描，如PostMapping.class,GetMapping.class,ApiOpertion.class
withClassAnnotation(final Class<? extends Annotation> annotation)	// 通过类上的注解扫描，如Api.class

@Bean
	public Docket demoDocket(){
		return new Docket(DocumentationType.SWAGGER_2)
				.groupName("demo")
				.apiInfo(demoApiinfo())
				.select()
				.apis(RequestHandlerSelectors.basePackage("com.jude.demo"))     // 包路径扫描到文档中
				.paths(PathSelectors.ant("/demo/**"))// 只扫描/demo/开头的请求，实现过滤
				.build();
	}

PathSelectors.any()	// 任何请求都会扫描
PathSelectors.regex()	// 以正则表达式匹配

.paths(Predicates.or(PathSelectors.ant("/demo/dept/**"),PathSelectors.ant("/demo/employee/**")))
.paths(Predicates.not(PathSelectors.regex("/error.*")))

@Data
@ApiModel(value = "数据采集爬取的内容字段提交对象")
public class WebCollectContentDTO {
	@ApiModelProperty(value = "采集ID")
	private Long collectId;

	@ApiModelProperty(value = "内容页url地址")
	private String pageUrl;
}

@Api(tags = "部门接口")
public class DepartmentController {
  
    @ApiOperation("测试接口")
    @PostMapping("/test")
    public String hello(@ApiParam(value = "这个名字会返回",required = true) String username){
        return username;
    }
}

@Service
public class AsyncService {

	public void hello(){
		try {
			TimeUnit.SECONDS.sleep(3);
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
	}
}

@Async // 告诉Spring这是一个异步方法，默认使用线程池，效率很好
public void hello(){
  try {
    TimeUnit.SECONDS.sleep(3);
  } catch (InterruptedException e) {
    e.printStackTrace();
  }
  System.out.println("数据处理中");
}

@SpringBootApplication
@EnableAsync
public class SpringBootDataStudyXjwApplication {

	public static void main(String[] args) {
		SpringApplication.run(SpringBootDataStudyXjwApplication.class, args);
	}
}

@Service
class A{
    @Async
    method b(){...}
     
    method a(){    //标记1
        b();
    }
}
//Spring扫描注解后，会创建另外一个代理类，并对添加注解的方法根据切入点创建代理
//调用代理，执行切入点处理器invoke方法，实现异步执行
class proxy$A{
    A objectA = new A();
    method b(){    //标记2
        //MethodInterceptor.invoke
        objectA.b();
    }
  
    method a(){    //标记3
        objectA.a();    //由于a()没有注解，所以不会创建代理，而是直接调用A的实例的a()方法
    }
}

private static final SimpleDateFormat dateFormat =
            new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");

public static void main(String[] args) throws Exception {
  // 创建定时器
  Timer timer = new Timer();

  // 提交计划任务
  timer.schedule(new TimerTask() {
    @Override
    public void run() {
      System.out.println("定时任务执行了...");
    }
  }, dateFormat.parse("2020-12-08 20:30:00"));
}

* 任意时间
? 日/周冲突匹配
- 区间，如6-7
L 最后
W 工作日
# 星期，如4#2，第二个星期三

0 0/2 * * * ?    表示每2分钟 执行任务 
0 15 10 ? * MON-FRI   表示周一到周五每天上午10:15执行作业
0 0/30 9-17 * * ?   朝九晚五工作时间内每半小时 
0 15 10 ? * 6L    每月的最后一个星期五上午10:15触发  
0 15 10 ? * 6#3   每月的第三个星期五上午10:15触发

// 定时任务类
@Service
public class ScheduledService {

	// 每分钟执行一次
	@Scheduled(cron = "0 * * * * ?")
	public void hello(){
		System.out.println("Hello ......");
	}
} 

@SpringBootApplication
@EnableAsync // 开启异步注解的支持
@EnableScheduling // 开启定时任务的支持
public class SpringBootDataStudyXjwApplication {

	public static void main(String[] args) {
		SpringApplication.run(SpringBootDataStudyXjwApplication.class, args);
	}
}

protected void scheduleTasks() {
  if (this.taskScheduler == null) {
  	this.localExecutor = Executors.newSingleThreadScheduledExecutor();
  	this.taskScheduler = new ConcurrentTaskScheduler(this.localExecutor);
  }
}

@SpringBootTest
class SpringBootApplicationTests {
	@Autowired
	JavaMailSenderImpl javaMailSender;

	@Test
	void contextLoads() throws SQLException {
		// 发送简单邮件,万物皆对象，邮件也不例外
		SimpleMailMessage message = new SimpleMailMessage();
		message.setSubject("通知，飞天班第13节作业"); // 主题
		message.setText("给自己的小破站增加邮件发送功能");
		message.setTo("13435410760@163.com","747463168@qq.com");
		message.setFrom("13435410760@163.com");

		javaMailSender.send(message);
	}
}

// 发送复杂邮件，可以结合富文本编辑器开发前端
	@Test
	void sendMail() throws MessagingException {
		MimeMessage message = javaMailSender.createMimeMessage();
		// 复杂邮件，通过辅助类完成
		MimeMessageHelper helper = new MimeMessageHelper(message,true);
		// 基本信息
		helper.setSubject("复杂邮件");  // 主题
		helper.setText("<blockquote style=\"text-align: center;margin-bottom: 10px;\n" +
				"padding: 15px;\n" +
				"line-height: 22px;\n" +
				"border-left: 5px solid #009688;\n" +
				"border-radius: 0 2px 2px 0;\n" +
				"background-color: #f2f2f2;\">\n" +
				"layui 兼容人类正在使用的全部浏览器（IE6/7除外），可作为 PC 端后台系统与前台界面的速成开发方案。\n" +
				"</blockquote>",true);    // html文本
		// 发送附件
		helper.addAttachment("layui.png",new File("/Users/xjw/Pictures/layui.png"));

		// 发送对象
		String[] receiver = {"13435410760@163.com","747463168@qq.com"};
		helper.setTo(receiver);
		helper.setFrom("13435410760@163.com");

		javaMailSender.send(message);
	}

// 给editormd回调
JSONObject res = new JSONObject();
res.put("url","/upload/"+month+"/"+filename);
res.put("success",1);
res.put("message","upload success");

@Configuration
public class ResourceConfig implements WebMvcConfigurer {

	@Override
	public void addResourceHandlers(ResourceHandlerRegistry registry) {
		// 文件保存到当前项目的upload目录下
		// 访问的时候使用/upload/1.png就OK了
		registry.addResourceHandler("/upload/**").addResourceLocations("file:"+System.getProperty("user.dir")+"/upload/");;
	}
}