package com.fastbee.common.core.mq.ota;

import com.fasterxml.jackson.annotation.JsonFormat;
import com.fastbee.common.utils.DateUtils;
import lombok.Data;
import org.springframework.lang.NonNull;

import java.lang.reflect.Member;
import java.util.Date;
import java.util.List;
import java.util.concurrent.Delayed;
import java.util.concurrent.TimeUnit;

/**
 * ota升级发送,实现Delayed延时接口
 *
 * @author bill
 */
@Data
public class OtaUpgradeDelayTask implements Delayed {

    /*固件id*/
    private Long firmwareId;
    private List<String> devices;
    /*任务id*/
    private Long taskId;
    /*开始升级时间*/
    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
    private Date startTime;


    /**
     * 设置延迟执行时间 开始升级时间 -当前时间
     *
     * @param unit
     * @return
     */
    @Override
    public long getDelay(TimeUnit unit) {
        return startTime.getTime() - DateUtils.getTimestamp();
    }

    @Override
    public int compareTo(Delayed o) {
        OtaUpgradeDelayTask delayTask = (OtaUpgradeDelayTask) o;
        //比较
        long diff = this.startTime.getTime() - delayTask.startTime.getTime();
        if (diff <= 0) {
            return -1;
        } else {
            return 1;
        }
    }
}