package com.zy.crm.manager.utils;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.aliyun.auth.credentials.Credential;
import com.aliyun.auth.credentials.provider.StaticCredentialProvider;
import com.aliyun.sdk.service.dysmsapi20170525.AsyncClient;
import com.aliyun.sdk.service.dysmsapi20170525.models.SendSmsRequest;
import com.aliyun.sdk.service.dysmsapi20170525.models.SendSmsResponse;
import com.aliyun.sdk.service.dysmsapi20170525.models.SendSmsResponseBody;
import darabonba.core.client.ClientOverrideConfiguration;

import java.util.*;
import java.util.concurrent.CompletableFuture;
import java.util.regex.Matcher;
import java.util.regex.Pattern;

/**
 * 短信发送工具
 */
public class SmsUtils {

    /**
     * 阿里云市场API
     */
    private static boolean aliyun_1(String phone, String code) {
        ArrayList<Map<String, Object>> list = new ArrayList<>();
        try {
            HashMap<String, Object> headers = new HashMap<>();
            HashMap<String, Object> param = new HashMap<>();

            String APPCODE = "15ce5d8be5e348c7b680dfd7cfb8307e";
            headers.put("Authorization", "APPCODE " + APPCODE);

            param.put("templateId", "MEA92C3A45");
            param.put("receive", phone);
            param.put("tag", code);

            String response = new HttpHandler.Builder()
                    .setUri("https://smkjdxtzjk.market.alicloudapi.com")
                    .setPath("/standard/sms/send")
                    .setHeaders(headers)
                    .setParams(param)
                    .build()
                    .doPost();
            JSONObject jsonObject = JSON.parseObject(response);
            if (Integer.parseInt(jsonObject.get("code").toString()) == 200) {
                return true;
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
        return false;
    }
    /**
     * 阿里云市场API  分配了新的规划申请单任务！请注意查收！
     */
    private static boolean aliyun_2(String phone, String code) {
        try {
            HashMap<String, Object> headers = new HashMap<>();
            HashMap<String, Object> param = new HashMap<>();

            String APPCODE = "15ce5d8be5e348c7b680dfd7cfb8307e";
            headers.put("Authorization", "APPCODE " + APPCODE);

            param.put("templateId", "M6F3C81FE3");
            param.put("receive", phone);
            param.put("tag", code);

            String response = new HttpHandler.Builder()
                    .setUri("https://smkjdxtzjk.market.alicloudapi.com")
                    .setPath("/standard/sms/send")
                    .setHeaders(headers)
                    .setParams(param)
                    .build()
                    .doPost();
            JSONObject jsonObject = JSON.parseObject(response);
            if (Integer.parseInt(jsonObject.get("code").toString()) == 200) {
                return true;
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
        return false;
    }

    private static AsyncClient getClient() {
        StaticCredentialProvider provider = StaticCredentialProvider.create(Credential.builder()
                .accessKeyId("LTAI4GBCtqGZAn5XDEREh1Pp")
                .accessKeySecret("SQQkh2kps3wxfbNXUg5nLZgWS2CMjm")
                .build());

        // Configure the Client
        AsyncClient client = AsyncClient.builder()
                //.httpClient(httpClient) // Use the configured HttpClient, otherwise use the default HttpClient (Apache HttpClient)
                .credentialsProvider(provider)
                //.serviceConfiguration(Configuration.create()) // Service-level configuration
                // Client-level configuration rewrite, can set Endpoint, Http request parameters, etc.
                .overrideConfiguration(
                        ClientOverrideConfiguration.create()
                                // Endpoint 请参考 https://api.aliyun.com/product/Dysmsapi
                                .setEndpointOverride("dysmsapi.aliyuncs.com")
                        //.setConnectTimeout(Duration.ofSeconds(30))
                )
                .build();

        return client;
    }

    /**
     * 发送短信验证码-阿里云原生
     */
    private static boolean aliyun_origin(String phone, String code) {
        AsyncClient client = getClient();
        try {
            HashMap<String, Object> templateParam = new HashMap<>();
            templateParam.put("code", code);

            // Parameter settings for API request
            SendSmsRequest sendSmsRequest = SendSmsRequest.builder()
                    .phoneNumbers(phone)
                    .signName("某某商场")
                    .templateCode("SMS_195220399")
                    .templateParam(JSON.toJSONString(templateParam))
                    // Request-level configuration rewrite, can set Http request parameters, etc.
                    // .requestConfiguration(RequestConfiguration.create().setHttpHeaders(new HttpHeaders()))
                    .build();

            // Asynchronously get the return value of the API request
            CompletableFuture<SendSmsResponse> response = client.sendSms(sendSmsRequest);
            // Synchronously get the return value of the API request
            SendSmsResponse resp = response.get();
            SendSmsResponseBody body = resp.getBody();
//            System.out.println(body.getCode());
//            System.out.println(body.getMessage());
            if (body.getCode().equals("OK")) {
                return true;
            }
            return false;
        } catch (Exception e) {
            return false;
        } finally {
            // Finally, close the client
            client.close();
        }
    }

    /**
     * 发送短信验证码-阿里云原生
     */
    public static boolean sendSmsCode(String phone, String code) {
        return aliyun_1(phone, code);
    }

    /**
     * 发送短信-阿里云原生
     */
    public static boolean sendSmsCodeText(String phone, String code) {
        return aliyun_2(phone, code);
    }

    /**
     * 获取随机数
     * @param length 随机数长度
     */
    public static String getRandomNum(Integer length) {
        Random random = new Random();
        StringBuffer buffer = new StringBuffer();
        for (int i = 0; i < length; i++) {
            buffer.append(random.nextInt(10));
        }
        return buffer.toString();
    }

    /**
     * 正则验证手机号
     */
    public static boolean verifyPhone(String phone) {
        // 定义手机号码的正则表达式
        String regex = "^1[3456789]\\d{9}$";
        // 编译正则表达式
        Pattern pattern = Pattern.compile(regex);
        // 创建 Matcher 对象
        Matcher matcher = pattern.matcher(phone);
        // 进行匹配
        if (!matcher.matches()) {
            return false;
        }
        return true;
    }

    public static void main(String[] args) throws Exception {
        sendSmsCode("17788886666","666666");
    }

}