package cn.huge.module.timer;

import cn.huge.base.common.utils.DateUtils;
import cn.huge.base.common.utils.IdUtils;
import cn.huge.module.cases.domain.po.CaseEvaluate;
import cn.huge.module.cases.domain.po.CaseTask;
import cn.huge.module.cases.service.CaseEvaluateService;
import cn.huge.module.cases.service.CaseTaskService;
import cn.huge.module.client.api.impl.SysClientImpl;
import cn.huge.module.flow.consts.FlowNodeEnum;
import cn.huge.module.meet.domain.po.MeetVideo;
import cn.huge.module.meet.service.MeetVideoService;
import cn.huge.module.sys.constant.SyTimeEnum;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import dm.jdbc.internal.convert.Data;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.collections.CollectionUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;
import javax.mail.event.MailEvent;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
import java.util.stream.Collectors;

/**
 * @title: 定时器
 * @description: 定时器方法
 * @company: hugeinfo
 * @author: wangwh
 * @time: 2024-09-26 16:51:48
 * @version: 1.0.0
 */
@Slf4j
@Component
public class scheduledTask {
    @Autowired
    private CaseEvaluateService evaluateService;
    @Autowired
    private CaseTaskService caseTaskService;
    @Autowired
    private SysClientImpl sysClient;
    @Resource
    private MeetVideoService meetVideoService;

    @Scheduled(cron ="0 */1 * * * ?")
    public void autoArchive(){
        Date now = DateUtils.getNowDate();
        QueryWrapper<CaseTask> caseTaskQueryWrapper = new QueryWrapper<>();
        caseTaskQueryWrapper.eq("node_id", FlowNodeEnum.FLOW_NODE_DSRPJ.getIndex())
                .eq("status", 1);
        List<CaseTask> caseTaskList = caseTaskService.list(caseTaskQueryWrapper);
        if(CollectionUtils.isNotEmpty(caseTaskList)){
            List<String> caseIdList = caseTaskList.stream().map(CaseTask::getCaseId).collect(Collectors.toList());
            evaluateService.autoArchive(caseIdList);
        }
    }


    @Scheduled(cron = "0 0 0 * * ?")
    public void downloadVideo() {
        List<MeetVideo> downloadVideo = meetVideoService.getDownloadVideo();
        if (downloadVideo != null && downloadVideo.size() > 0) {
            for (MeetVideo meetVideo : downloadVideo) {
                meetVideoService.saveCloudVideo(meetVideo.getCaseId(), meetVideo.getMeetType(), true);
            }
        }
    }
}