package org.jeecg.modules.eam.job;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import org.apache.shiro.SecurityUtils;
import org.jeecg.common.api.dto.message.MessageDTO;
import org.jeecg.common.constant.enums.MessageSplitTypeEnum;
import org.jeecg.common.system.api.ISysBaseAPI;
import org.jeecg.common.system.vo.LoginUser;
import org.jeecg.modules.eam.entity.Equipment;
import org.jeecg.modules.eam.service.IEamEquipmentService;
import org.jeecg.modules.eam.service.IEquipmentUpdateInfoService;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.springframework.beans.factory.annotation.Autowired;

import java.util.Calendar;
import java.util.Date;
import java.util.List;

/**
 * @author lnl
 */
public class EquipmentWarrantyEndDateAlertJob implements Job {
    @Autowired
    private IEamEquipmentService equipmentService;
    @Autowired
    private ISysBaseAPI sysBaseApi;
    @Override
    public void execute(JobExecutionContext context) throws JobExecutionException {
        Calendar currentDate = Calendar.getInstance();
        currentDate.add(Calendar.DATE, 30);
        Date finalDay = currentDate.getTime();
        QueryWrapper<Equipment> queryWrapper = new QueryWrapper<Equipment>()
                .lt("warranty_end",finalDay).gt("warranty_end",new Date()).eq("del_flag",0);
        List<Equipment> equipmentList = equipmentService.list(queryWrapper);
        String title = "设备质保到期提醒!";
        String msg = "统一编码为：";
        for(Equipment equipment:equipmentList){
            msg = msg+"【"+equipment.getNum()+"】";
        }
        msg = msg+"的设备质保结束日期小于30天，请及时处理";
        MessageDTO messageDTO = new MessageDTO();
        messageDTO.setTitle(title);
        messageDTO.setContent(msg);
        messageDTO.setMessageType(MessageSplitTypeEnum.untilMaintenancePeriod.getType());
        messageDTO.setCategory("系统消息");
        messageDTO.setFromUser("到期提醒小助手-小醒");
        messageDTO.setToUser("admin");
        if(equipmentList.size()!=0){
            sysBaseApi.sendSysAnnouncement(messageDTO);
        }
    }
}