package com.cloudroam.task;

import cn.hutool.core.date.DateUtil;
import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.cloudroam.common.enumeration.EmailTaskTagEnum;
import com.cloudroam.common.enumeration.GroupLevel2Enum;
import com.cloudroam.model.EmailSmtpSettingDO;
import com.cloudroam.model.EmailTaskSettingDO;
import com.cloudroam.model.UserDO;
import com.cloudroam.service.*;
import com.cloudroam.util.DateUtils;
import com.cloudroam.util.MailUtils;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;

import javax.annotation.PostConstruct;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.util.*;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;

/**
 * @author  taojie
 *
 * 1.根据数据库配置的邮箱地址来发送邮件
 * 2.根据数据库任务配置时间来发送邮件
 * 当天未填写计划，就发邮件通知个人和项目经理；
 */
//@Component
@Slf4j
public class PmsNoDailyTaskExecutors {

    private final static ScheduledExecutorService scheduler= Executors.newScheduledThreadPool(5);

    @Autowired
    private ProjectDailyService projectDailyService;

    @Autowired
    private EmailSmtpSettingService emailSmtpSettingService;

    @Autowired
    private EmailTaskSettingService emailTaskSettingService;

    @Autowired
    private UserService userService;

    @Autowired
    private AdminService adminService;

    private static final int INITIAL_TIME=1*60*1000;

    @PostConstruct
    public void init() {
        scheduler.scheduleAtFixedRate(() -> {
            try {

                EmailTaskSettingDO setting = emailTaskSettingService.getEmailTaskSettingByTag(EmailTaskTagEnum.TODAY_NO_DAILY);
                if(null==setting){
                    log.warn("未填写日志定时任务时间未配置！");
                    return;
                }
                Integer taskHour = setting.getTaskHour();
                LocalDateTime todayPointHourTime = DateUtils.getTodayPointHourTime(taskHour);
                LocalDateTime now = LocalDateTime.now();

                //还需要记录当天邮件是否已经发送过
                String emailSendDate = setting.getEmailSendDate();
                String today= DateUtil.today();
                if(now.isAfter(todayPointHourTime) && !today.equals(emailSendDate) && !DateUtils.isWeekend(LocalDate.now())){


                    // 获取邮件服务器配置
                    List<EmailSmtpSettingDO> settingDOList=emailSmtpSettingService.getEmailSmtpSettingList();

                    EmailSmtpSettingDO emailSmtpSettingDO = settingDOList.get(0);

                    List<UserDO> noDailyPeoples = projectDailyService.getTodayNoDailyPeoples();



                    for(UserDO userDO:noDailyPeoples){


                        String subject="（"+DateUtils.formattedTodayDate()+"）日志未填写提醒";

                        // 格式化邮件内容
                        String content = formatDateDaily(subject);

                        if(StrUtil.isNotBlank(userDO.getEmail())){
                            //发送个人邮件
                            MailUtils.sendEmailHtml(emailSmtpSettingDO.getSmtpHost(),emailSmtpSettingDO.getSmtpPort(),emailSmtpSettingDO.getSmtpFrom(),emailSmtpSettingDO.getSmtpUsername(),emailSmtpSettingDO.getSmtpPassword(),
                                    userDO.getEmail(), subject,content);
                        }


                    }

                    // 构造经理邮件提醒
                    String subject="（"+DateUtils.formattedTodayDate()+"）汇总日志未填写提醒";

                    String content=formatDateDailyToManager(subject,noDailyPeoples);

                    // 获取项目经理的邮箱，并发送邮件

                    // 获取项目经理角色的用户
                    IPage<UserDO> managerUserPage = adminService.getUserPageByGroupId(GroupLevel2Enum.MANAGER.getValue(), 1000, 0);
                    List<UserDO> managers = managerUserPage.getRecords() ;
                    for(UserDO manager:managers){
                        if(StrUtil.isNotBlank(manager.getEmail())){
                            MailUtils.sendEmailHtml(emailSmtpSettingDO.getSmtpHost(),emailSmtpSettingDO.getSmtpPort(),emailSmtpSettingDO.getSmtpFrom(),emailSmtpSettingDO.getSmtpUsername(),emailSmtpSettingDO.getSmtpPassword(),
                                    manager.getEmail(), subject,content);
                        }

                    }



//                    将今日邮件发送的标志标为已经发送

                    EmailTaskSettingDO sendedEmailTaskSetting=new EmailTaskSettingDO();
                    sendedEmailTaskSetting.setId(setting.getId());
                    sendedEmailTaskSetting.setEmailSendDate(DateUtils.formattedTodayDate());
                    sendedEmailTaskSetting.setEmailSendTime(new Date());

                    emailTaskSettingService.updateById(sendedEmailTaskSetting);

                }


            } catch (Exception e) {
                e.printStackTrace();
            }
        }, 0, 1, TimeUnit.MINUTES); // 每隔一分钟检查一次数据库
    }

    private String formatDateDailyToManager(String subject,List<UserDO> userDOList) {


        StringBuilder sb=new StringBuilder();
        sb.append("<div>"+subject+"</div>");
        sb.append("(");
        for(UserDO userDO:userDOList){
            sb.append(userDO.getNickname()+"&nbsp;");
        }
        sb.append(")");
        sb.append("还未填写今日计划！");
        return sb.toString();
    }


    private String formatDateDaily(String title){

        StringBuilder sb=new StringBuilder();
        sb.append("<div>"+title+"</div>");
        sb.append("请尽快填写今日计划！");
        return sb.toString();
    }

}