package com.walker.push.alidy;

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.walker.infrastructure.utils.JsonUtils;
import com.walker.infrastructure.utils.StringUtils;
import com.walker.push.Notification;
import com.walker.push.PushException;
import com.walker.push.PushResult;
import com.walker.push.SmsMessage;
import com.walker.push.support.AbstractSmsPush;
import com.walker.push.util.PushUtils;
import darabonba.core.client.ClientOverrideConfiguration;

import java.util.List;
import java.util.concurrent.CompletableFuture;

/**
 * 阿里大鱼短信推送实现。
 * @author 时克英
 * @date 2023-04-23
 */
public abstract class DySmsPush extends AbstractSmsPush {

    public DySmsPush(){
        this.setId("alidy_sms_push");
        this.setName("大鱼短信推送");
        this.setSupportAsync(true);
    }

    @Override
    public void startup() {
        if(StringUtils.isEmpty(this.accessKeyId)
                || StringUtils.isEmpty(this.accessKeySecret)
                || StringUtils.isEmpty(this.signName)
                || StringUtils.isEmpty(this.region)){
            throw new IllegalArgumentException("请先设置短信配置：" + this.getName());
        }

        StaticCredentialProvider provider = StaticCredentialProvider.create(Credential.builder()
                .accessKeyId(this.accessKeyId)
                .accessKeySecret(this.accessKeySecret)
                //.securityToken("<your-token>") // use STS token
                .build());

        client = AsyncClient.builder()
                .region(this.region) // Region ID
                //.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().setEndpointOverride("dysmsapi.aliyuncs.com")
                        //.setConnectTimeout(Duration.ofSeconds(30))
                )
                .build();
        logger.info("初始化：大鱼短信推送者");
    }

    @Override
    protected PushResult doPushContent(Notification notification, List<SmsMessage> data) throws PushException {
        if(notification.getBroadcast()){
            throw new IllegalStateException("短信推送，无法设置为广播!");
        }

        PushResult pushResult = PushUtils.acquireSuccessPushResult();

        // 对于短信来说，通常一个提醒只会通知一人，不会群发同一个信息给多人。
        // 因为一个：SmsMessage 中就能放多个手机号，所以其实只有一个对象。
        SmsMessage smsMessage = data.get(0);

        String phoneNumbers = StringUtils.collectionToDelimitedString(smsMessage.getMobileList(), StringUtils.DEFAULT_SPLIT_SEPARATOR);
        String templateParam = null;
        try {
            templateParam = JsonUtils.objectToJsonString(smsMessage.getTemplateParam());
//            int i = 0;
//            StringBuilder sb = new StringBuilder("{");
//            for(Map.Entry<String, String> entry: smsMessage.getTemplateParam().entrySet()){
//                if(i > 0){
//                    sb.append(",");
//                }
//                sb.append("\"").append(entry.getKey()).append("\"");
//                sb.append(":");
//                sb.append("\"").append(entry.getValue()).append("\"");
//                i++;
//            }
//            sb.append("}");
//            templateParam = sb.toString();
//            System.out.println(templateParam);
        } catch (Exception e) {
            throw new PushException(notification.getId(), "短信json转换错误:" + e.getMessage(), e);
        }

        SendSmsRequest sendSmsRequest = SendSmsRequest.builder()
                .phoneNumbers(phoneNumbers)
                .signName(this.signName)
                .templateCode(smsMessage.getTemplateId()).templateParam(templateParam)
                .build();

//        CompletableFuture<SendSmsResponse> response = client.sendSms(sendSmsRequest);
        // 当执行发送完成时，使用发送任务的线程继续执行：回调任务
        CompletableFuture<SendSmsResponse> response = client.sendSms(sendSmsRequest).whenComplete((res, ex) -> {
            if(ex != null){
                this.getPushStatusListener().onException(notification, ex.getMessage(), this.getNotificationChannel());
            } else {
                this.getPushStatusListener().onSuccess(notification, res.getBody().getBizId(), this.getNotificationChannel());
            }
        });

        try {
            // 2023-04-24, 注意：这里get必须调用，否则无法触发远程通信!
            response.get();
        } catch (Exception e) {
            throw new PushException(notification.getId(), e.getMessage(), e);
        }
//        SendSmsResponse resp = response.get();
        return pushResult;
    }

//    @Override
//    public NotificationChannel getNotificationChannel() {
//        return NotificationChannel.Sms;
//    }

//    @Override
//    public List<SmsMessage> translateToTarget(Notification notification) {
//        List<SmsMessage> data = new ArrayList<>(4);
//        SmsMessage smsMessage = new SmsMessage();
//        String userPhoneNum = null;
//        for(String user: notification.getReceiverList()){
//            userPhoneNum = this.getUserMobile(user);
//            if(StringUtils.isEmpty(userPhoneNum)){
//                logger.warn("未查找到用户手机号，user = {}", user);
//                continue;
//            }
//            smsMessage.addMobile(userPhoneNum);
//        }
//
//        try {
//            SmsMessage message = JsonUtils.jsonStringToObject(notification.getContent(), SmsMessage.class);
//            smsMessage.setTemplateId(message.getTemplateId());
//            smsMessage.setTemplateParam(message.getTemplateParam());
//        } catch (Exception e) {
//            throw new RuntimeException("消息内容json转换错误:" + e.getMessage(), e);
//        }
//        data.add(smsMessage);
//        return data;
//    }

    public String getAccessKeyId() {
        return accessKeyId;
    }

    public void setAccessKeyId(String accessKeyId) {
        this.accessKeyId = accessKeyId;
    }

    public String getAccessKeySecret() {
        return accessKeySecret;
    }

    public void setAccessKeySecret(String accessKeySecret) {
        this.accessKeySecret = accessKeySecret;
    }

    public String getSignName() {
        return signName;
    }

    public void setSignName(String signName) {
        this.signName = signName;
    }

    public String getRegion() {
        return region;
    }

    public void setRegion(String region) {
        this.region = region;
    }

    private AsyncClient client = null;
    private String accessKeyId;
    private String accessKeySecret;
    private String signName;
    private String region;
}