package org.jeecg.modules.eam.job;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import lombok.extern.slf4j.Slf4j;
import org.apache.shiro.SecurityUtils;
import org.jeecg.common.api.dto.message.MessageDTO;
import org.jeecg.common.system.api.ISysBaseAPI;
import org.jeecg.common.system.vo.LoginUser;
import org.jeecg.common.util.DateUtils;
import org.jeecg.modules.eam.entity.*;
import org.jeecg.modules.eam.service.*;
import org.jeecg.modules.system.entity.*;
import org.jeecg.modules.system.service.*;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.format.annotation.DateTimeFormat;
import org.springframework.transaction.annotation.Transactional;

import javax.annotation.Resource;
import java.text.SimpleDateFormat;
import java.time.DayOfWeek;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.time.ZoneId;
import java.util.Calendar;
import java.util.Date;
import java.util.List;

/**
 * 三级保养工单  到期未执行  技术状态修改为 禁用（状态鉴定未按期完成）
 */
@Slf4j
public class ThirdMaintenanceOrderOverdueJob implements Job {

    @Autowired
    private IDailyMaintenanceOrderService dailyMaintenanceOrderService;

    @Autowired
    private IEamEquipmentService equipmentService;
    @Autowired
    private IMaintenanceCycleService maintenanceCycleService;

    @Autowired
    private ISysBaseAPI sysBaseApi;

    @Resource
    private ISysRoleService sysRoleService;
    @Resource
    private ISysDictService sysDictService;
    @Resource
    private ISysDictItemService sysDictItemService;
    @Resource
    private ISysUserRoleService sysUserRoleService;
    @Resource
    private ISysUserService sysUserService;

    @Override
    @Transactional(rollbackFor = { Exception.class })
    public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {

        LocalDateTime currentDateTime = LocalDateTime.now();
        Date result = Date.from(currentDateTime.atZone(ZoneId.systemDefault()).toInstant());
        List<DailyMaintenanceOrder> maintenanceOrders = dailyMaintenanceOrderService.list(new QueryWrapper<DailyMaintenanceOrder>().lt("plan_start_time", result).eq("status",1).eq("del_flag",0));
        for (DailyMaintenanceOrder dailyMaintenanceOrder : maintenanceOrders) {
            String maintenanceCycleId = dailyMaintenanceOrder.getMaintenanceCycleId();
            MaintenanceCycle maintenanceCycle = maintenanceCycleService.getById(maintenanceCycleId);
            String maintenanceType = maintenanceCycle.getMaintenanceType();
            if("3".equals(maintenanceType)){
                String equipmentId = dailyMaintenanceOrder.getEquipmentId();

                Equipment equipment = equipmentService.getById(equipmentId);
                equipment.setTechnologyStatus("disableNoExe");
                equipmentService.updateById(equipment);
                this.equipmentTechnologyStatuAlart(equipment.getNum(),equipment.getTechnologyStatus());
            }
        }
    }

    void equipmentTechnologyStatuAlart(String equipmentNum,String technologyStatus){

        SysDict sysDictT = sysDictService.getOne(new QueryWrapper<SysDict>().eq("dict_code","technology_status"),false);
        SysDictItem sysDictItemt = sysDictItemService.getOne(new QueryWrapper<SysDictItem>().eq("item_value",technologyStatus)
                .eq("dict_id",sysDictT.getId()),false);

        SysDict sysDict = sysDictService.getOne(new QueryWrapper<SysDict>().eq("dict_code","info_type"),false);
        SysDictItem sysDictItem = sysDictItemService.getOne(new QueryWrapper<SysDictItem>().eq("item_text","运保设备管理员")
                .eq("dict_id",sysDict.getId()),false);
        String roleCode = sysDictItem.getItemValue();
        SysRole sysRole = sysRoleService.getOne(new QueryWrapper<SysRole>().eq("role_code",roleCode),false);
        List<SysUserRole> sysUserRoles = sysUserRoleService.list(new QueryWrapper<SysUserRole>().eq("role_id",sysRole.getId()));
        for(SysUserRole sysUserRole:sysUserRoles){
            SysUser user = sysUserService.getById(sysUserRole.getUserId());
            String msg = "统一编号为【"+equipmentNum+"】的三级保养工单未执行，系统自动将该设备技术状态改为【"+sysDictItemt.getItemText()+"】，请知晓！！！";
            MessageDTO messageDTO = new MessageDTO();
            messageDTO.setTitle("设备台账技术状态修改");
            messageDTO.setContent(msg);
            messageDTO.setCategory("运保设备管理员");
            messageDTO.setFromUser("设备台账技术状态修改提醒小助手");
            messageDTO.setToUser(user.getUsername());
            sysBaseApi.sendSysAnnouncement(messageDTO);
        }
    }
}