application:
  message:
    app-id: 1111
    app-key: 111
    register-template: 111
    homework-tip-template:111

    @Bean
    public HttpClient httpClient(){
        return HttpClients.createDefault();
    }

/**
 * @author Echo
 * @version 1.0
 * @date 2019-02-22 01:17
 */
@Component
@Slf4j
public class SubMailUtils {

    private final HttpClient httpClient;
    private final MessageConfig messageConfig;
    private static final String X_SEND = "https://api.mysubmail.com/message/xsend";

    @Autowired
    public SubMailUtils(HttpClient httpClient, MessageConfig messageConfig) {
        this.httpClient = httpClient;
        this.messageConfig = messageConfig;
    }

    /**
     * 发送一条信息
     *
     * @param to   接收人
     * @param vars 模板变量
     */
    public boolean sendOneMessage(String to, String project, JSONObject vars) {
        HttpPost httpPost = new HttpPost(X_SEND);
        JSONObject jsonParam = new JSONObject();
        jsonParam.put("appid", messageConfig.getAppId());
        jsonParam.put("signature", messageConfig.getAppKey());
        jsonParam.put("project", project);
        jsonParam.put("to", to);
        jsonParam.put("vars", vars);
        StringEntity entity = new StringEntity(jsonParam.toJSONString(), "UTF-8");
        entity.setContentEncoding("UTF-8");
        entity.setContentType("application/json");
        httpPost.setEntity(entity);
        HttpResponse resp;
        try {
            resp = httpClient.execute(httpPost);
            HttpEntity he = resp.getEntity();
            log.info(EntityUtils.toString(he, "UTF-8"));
            return resp.getStatusLine().getStatusCode() == 200;
        } catch (IOException e) {
            e.printStackTrace();
            return false;
        }

    }
}

    @GetMapping("/mobile/{phone}")
    public HttpEntity<?> mobileCode(@PathVariable String phone) {
        // 当前手机号是否已被注册
        SysUser sysUser = new SysUser();
        sysUser.setPhone(phone);
        String result = sysUserService.existUser(sysUser);
        if (result != null) {
            throw new ResourceExistException(result);
        }
        // 生成 key 和 code
        String key = MOBILE + phone;
        String code = RandomStringUtils.randomNumeric(
                applicationProperties.getValidate().getMobileCodeMinLength(),
                applicationProperties.getValidate().getMobileCodeMaxLength());
        // 存放
        oauth2Service.saveValidateCode(key, code,
                applicationProperties.getValidate().getMobileCodeValidityPeriod(),
                TimeUnit.MINUTES);
        // 创建模板变量
        JSONObject vars = new JSONObject();
        vars.put("code", code);
        vars.put("time", applicationProperties.getValidate().getMobileCodeValidityPeriod());
        // 发送短信
        if (!subMailUtils.sendOneMessage(phone, messageConfig.getRegisterTemplate(), vars)) {
            throw new RuntimeException("message send failed!");
        }
        log.info("{} 短信验证码已经发送：{}", phone, code);
        return ResponseEntity.ok().build();
    }