package com.walker.push;

import com.walker.infrastructure.utils.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.util.List;

public abstract class AbstractPushObject<T> implements Pushable<T>{

    protected transient final Logger logger = LoggerFactory.getLogger(getClass());

    @Override
    public String getId() {
        return this.id;
    }

    @Override
    public String getName() {
        return this.name;
    }

    @Override
    public PushResult push(Notification notification) throws PushException {
        if(notification == null){
            throw new IllegalArgumentException("推送消息未提供");
        }
        if(StringUtils.isEmpty(notification.getContent())
                || StringUtils.isEmptyList(notification.getChannelList())){
            throw new IllegalArgumentException("推送消息缺少必要参数");
        }
        if(!notification.getBroadcast() && StringUtils.isEmptyList(notification.getReceiverList())){
            throw new IllegalArgumentException("非广播推送必须指定接收者");
        }

        boolean hasChannel = false;
        for(NotificationChannel channel : notification.getChannelList()){
            if(channel == this.getNotificationChannel()){
                hasChannel = true;
                break;
            }
        }
        if(!hasChannel){
            throw new PushException(notification.getId(), "当前消息不支持该推送者：" + this.name, null);
        }

        // 转换成具体发送的业务特定对象
        List<T> list = this.translateToTarget(notification);
        if(StringUtils.isEmptyList(list)){
//            throw new PushException(notification.getId(), "转换业务通知失败: list = null", null);
            logger.warn("translateToTarget():转换返回空对象");
        }

        // 2023-04-24 异步操作处理
        if(this.supportAsync){
            if(this.pushStatusListener == null){
                throw new IllegalStateException("异步推送，需要先添加：pushStatusListener");
            }
        }

        // 调用发送请求
        PushResult pushResult = this.doPushContent(notification, list);
//        if(!StringUtils.isEmptyList(pushResult.getFailedList())){
//            this.logger.error("推送消息失败，id={}, failed={}", notification.getId(), pushResult.getFailedList());
//            if(!notification.getBroadcast()){
//                // 非广播消息，需要检查是否全部失败，成功的需要保存
//                List<String> successList = new ArrayList<>(8);
//                for(String one : notification.getReceiverList()){
//                    if(!pushResult.getFailedList().contains(one)){
//                        successList.add(one);
//                    }
//                }
//                this.persistent(notification, successList);
//                logger.debug("保存了（部分）成功推送集合");
//            }
//        } else {
//            // 全部成功，保存
//            this.persistent(notification, notification.getReceiverList());
//            logger.debug("保存了（全部）成功推送集合");
//        }
        return pushResult;
    }

    /**
     * 执行具体推送的方法，由子类完成。
     * @param notification
     * @param data 转换成业务通知集合
     * @return 只有同步类型时，返回的才是正确调用结果，异步需要看监听器
     * @throws PushException
     * @date 2023-04-22
     */
    protected abstract PushResult doPushContent(Notification notification, List<T> data) throws PushException;

//    /**
//     * 持久化保存推送数据（到数据库）
//     * @param notification
//     * @param successReceiverList
//     */
//    protected abstract void persistent(Notification notification, List<String> successReceiverList);

//    protected abstract void onException(Notification notification, String error);
//    protected abstract void onSuccess(Notification notification, Object option);

    @Override
    public int hashCode(){
        return this.id.hashCode();
    }

    @Override
    public boolean equals(Object obj){
        if(obj == null){return false;}
        if(obj instanceof Pushable){
            Pushable push = (Pushable) obj;
            if(push.getId().equals(this.id)){
                return true;
            }
        }
        return false;
    }

    public void setId(String id) {
        this.id = id;
    }

    public void setName(String name) {
        this.name = name;
    }

    @Override
    public boolean supportAsync() {
        return supportAsync;
    }

    public void setSupportAsync(boolean supportAsync) {
        this.supportAsync = supportAsync;
    }

    @Override
    public PushStatusListener getPushStatusListener() {
        return pushStatusListener;
    }

    @Override
    public void setPushStatusListener(PushStatusListener pushStatusListener) {
        this.pushStatusListener = pushStatusListener;
    }

    private PushStatusListener pushStatusListener;
    private boolean supportAsync = false;
    private String id;
    private String name;
}