package com.java110.job.task.maintainance;

import com.java110.core.factory.GenerateCodeFactory;
import com.java110.dto.community.CommunityDto;
import com.java110.dto.maintainancePlan.MaintainancePlanDto;
import com.java110.dto.maintainancePlanMachine.MaintainancePlanMachineDto;
import com.java110.dto.maintainancePlanStaff.MaintainancePlanStaffDto;
import com.java110.dto.maintainanceTask.MaintainanceTaskDto;
import com.java110.dto.maintainanceTaskDetail.MaintainanceTaskDetailDto;
import com.java110.dto.scheduleClassesStaff.ScheduleClassesStaffDto;
import com.java110.dto.task.TaskDto;
import com.java110.intf.community.*;
import com.java110.intf.store.IScheduleClassesStaffV1InnerServiceSMO;
import com.java110.job.quartz.TaskSystemQuartz;
import com.java110.po.maintainanceTask.MaintainanceTaskPo;
import com.java110.po.maintainanceTaskDetail.MaintainanceTaskDetailPo;
import com.java110.utils.util.DateUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.util.ArrayList;
import java.util.Arrays;
import java.util.Calendar;
import java.util.List;

/**
 * 保养任务生成 任务
 */
@Component
public class GeneratorMaintainanceTaskTemplate extends TaskSystemQuartz {

    @Autowired
    private IMaintainancePlanV1InnerServiceSMO maintainancePlanV1InnerServiceSMOImpl;

    @Autowired
    private IMaintainancePlanStaffV1InnerServiceSMO maintainancePlanStaffV1InnerServiceSMOImpl;

    @Autowired
    private IMaintainancePlanMachineV1InnerServiceSMO maintainancePlanMachineV1InnerServiceSMOImpl;


    @Autowired
    private IMaintainanceTaskV1InnerServiceSMO maintainanceTaskV1InnerServiceSMOImpl;

    @Autowired
    private IMaintainanceTaskDetailV1InnerServiceSMO maintainanceTaskDetailV1InnerServiceSMOImpl;

    @Autowired
    private IScheduleClassesStaffV1InnerServiceSMO scheduleClassesStaffV1InnerServiceSMOImpl;

    @Override
    protected void process(TaskDto taskDto) throws Exception {
        logger.debug("开始执行巡检任务生成" + taskDto.toString());

        // 获取小区
        List<CommunityDto> communityDtos = getAllCommunity();

        for (CommunityDto communityDto : communityDtos) {
            try {
                generatorTask(taskDto, communityDto);
            } catch (Exception e) {
                logger.error("推送消息失败", e);
            }
        }
    }

    /**
     * 巡检任务
     *
     * @param taskDto
     * @param communityDto
     */
    private void generatorTask(TaskDto taskDto, CommunityDto communityDto) {
        MaintainancePlanDto maintainancePlanDto = new MaintainancePlanDto();
        maintainancePlanDto.setCommunityId(communityDto.getCommunityId());
        maintainancePlanDto.setState(MaintainancePlanDto.STATE_RUN);
        maintainancePlanDto.setCurTime(DateUtil.getNow(DateUtil.DATE_FORMATE_STRING_A));
        List<MaintainancePlanDto> maintainancePlanDtos = maintainancePlanV1InnerServiceSMOImpl.queryMaintainancePlans(maintainancePlanDto);

        for (MaintainancePlanDto tmpMaintainancePlanDto : maintainancePlanDtos) {
            dealMaintainancePlan(tmpMaintainancePlanDto, taskDto, communityDto);
        }
    }

    /**
     * 处理巡检计划
     *
     * @param tmpMaintainancePlanDto
     * @param taskDto
     * @param communityDto
     */
    private void dealMaintainancePlan(MaintainancePlanDto tmpMaintainancePlanDto, TaskDto taskDto, CommunityDto communityDto) {

        MaintainancePlanStaffDto maintainancePlanStaffDto = new MaintainancePlanStaffDto();
        maintainancePlanStaffDto.setCommunityId(tmpMaintainancePlanDto.getCommunityId());
        maintainancePlanStaffDto.setPlanId(tmpMaintainancePlanDto.getPlanId());
        List<MaintainancePlanStaffDto> maintainancePlanStaffDtos = maintainancePlanStaffV1InnerServiceSMOImpl.queryMaintainancePlanStaffs(maintainancePlanStaffDto);

        List<MaintainanceTaskPo> maintainanceTaskPos = new ArrayList<>();
        List<MaintainanceTaskDetailPo> maintainanceTaskDetailPos = new ArrayList<>();

        for (MaintainancePlanStaffDto tmpMaintainancePlanStaffDto : maintainancePlanStaffDtos) {
            generatorStaffTask(tmpMaintainancePlanDto, taskDto, communityDto, tmpMaintainancePlanStaffDto, maintainanceTaskPos, maintainanceTaskDetailPos);
        }

        if (maintainanceTaskPos.size() < 1) {
            return;
        }

        if (maintainanceTaskDetailPos.size() < 1) {
            return;
        }
        maintainanceTaskV1InnerServiceSMOImpl.saveMaintainanceTasks(maintainanceTaskPos);

        maintainanceTaskV1InnerServiceSMOImpl.saveMaintainanceTaskDetail(maintainanceTaskDetailPos);

    }


    private void generatorStaffTask(MaintainancePlanDto tmpMaintainancePlanDto, TaskDto taskDto, CommunityDto communityDto,
                                    MaintainancePlanStaffDto tmpMaintainancePlanStaffDto, List<MaintainanceTaskPo> maintainanceTaskPos,
                                    List<MaintainanceTaskDetailPo> maintainanceTaskDetailPos) {

        //巡检方式
        String maintainancePlanPeriod = tmpMaintainancePlanDto.getPlanPeriod();

        boolean hasCondition = false;
        switch (maintainancePlanPeriod) {
            case MaintainancePlanDto.INSPECTION_PLAN_PERIOD_DAY:
                hasCondition = hasGeneratorTaskConditionByDay(tmpMaintainancePlanDto, taskDto, communityDto, tmpMaintainancePlanStaffDto, maintainanceTaskPos, maintainanceTaskDetailPos);
                break;
            case MaintainancePlanDto.INSPECTION_PLAN_PERIOD_NEXT_DAY:
                hasCondition = hasGeneratorTaskConditionByWeek(tmpMaintainancePlanDto, taskDto, communityDto, tmpMaintainancePlanStaffDto, maintainanceTaskPos, maintainanceTaskDetailPos);
                break;
        }
        if (!hasCondition) {
            return;
        }


        String nowTime = DateUtil.getNow(DateUtil.DATE_FORMATE_STRING_B) + " ";

        MaintainanceTaskPo maintainanceTaskPo = new MaintainanceTaskPo();
        maintainanceTaskPo.setPlanId(tmpMaintainancePlanDto.getPlanId());
        maintainanceTaskPo.setCommunityId(tmpMaintainancePlanDto.getCommunityId());
        maintainanceTaskPo.setMpsId(tmpMaintainancePlanStaffDto.getMpsId());
        maintainanceTaskPo.setPlanInsTime(nowTime + "09:00:00");
        maintainanceTaskPo.setPlanEndTime(nowTime + "18:00:00");
        maintainanceTaskPo.setPlanUserId(tmpMaintainancePlanStaffDto.getStaffId());
        maintainanceTaskPo.setPlanUserName(tmpMaintainancePlanStaffDto.getStaffName());
        maintainanceTaskPo.setTaskId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_taskId));
        maintainanceTaskPo.setOriginalPlanUserId(tmpMaintainancePlanStaffDto.getStaffId());
        maintainanceTaskPo.setOriginalPlanUserName(tmpMaintainancePlanStaffDto.getStaffName());
        maintainanceTaskPo.setTaskType("1000");
        maintainanceTaskPo.setState(MaintainanceTaskDto.STATE_WAIT);

        MaintainancePlanMachineDto maintainancePlanMachineDto = new MaintainancePlanMachineDto();
        maintainancePlanMachineDto.setCommunityId(tmpMaintainancePlanDto.getCommunityId());
        maintainancePlanMachineDto.setPlanId(tmpMaintainancePlanDto.getPlanId());
        List<MaintainancePlanMachineDto> maintainancePlanMachineDtos = maintainancePlanMachineV1InnerServiceSMOImpl.queryMaintainancePlanMachines(maintainancePlanMachineDto);
        if (maintainancePlanMachineDtos == null || maintainancePlanMachineDtos.size() < 1) {
            return;//巡检点为空时不生成 巡检任务
        }
        MaintainanceTaskDetailPo maintainanceTaskDetailPo = null;
        for (MaintainancePlanMachineDto tmpMaintainanceRoutePointRelDto : maintainancePlanMachineDtos) {
            maintainanceTaskDetailPo = new MaintainanceTaskDetailPo();
            maintainanceTaskDetailPo.setCommunityId(tmpMaintainancePlanDto.getCommunityId());
            maintainanceTaskDetailPo.setMachineId(tmpMaintainanceRoutePointRelDto.getMachineId());
            maintainanceTaskDetailPo.setMachineName(tmpMaintainanceRoutePointRelDto.getMachineName());
            maintainanceTaskDetailPo.setTaskId(maintainanceTaskPo.getTaskId());
            maintainanceTaskDetailPo.setPointStartTime(nowTime + "09:00:00");
            maintainanceTaskDetailPo.setPointEndTime(nowTime + "18:00:00");
            maintainanceTaskDetailPo.setSortNumber("1");
            maintainanceTaskDetailPo.setTaskDetailId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_taskDetailId));
            maintainanceTaskDetailPo.setState(MaintainanceTaskDetailDto.STATE_WAIT);
            maintainanceTaskDetailPos.add(maintainanceTaskDetailPo);
        }
        maintainanceTaskPos.add(maintainanceTaskPo);
    }


    /**
     * 每日
     *
     * @param tmpMaintainancePlanDto
     * @param taskDto
     * @param communityDto
     */
    private boolean hasGeneratorTaskConditionByDay(MaintainancePlanDto tmpMaintainancePlanDto, TaskDto taskDto, CommunityDto communityDto,
                                                   MaintainancePlanStaffDto tmpMaintainancePlanStaffDto, List<MaintainanceTaskPo> maintainanceTaskPos,
                                                   List<MaintainanceTaskDetailPo> maintainanceTaskDetailPos) {

        // 检查 今日是否 需要 生成巡检任务
        String[] months = tmpMaintainancePlanDto.getMaintainanceMonth().split(",");

        Calendar today = Calendar.getInstance();
        int month = today.get(Calendar.MONTH) + 1;
        if (!Arrays.asList(months).contains(month + "")) {
            return false;
        }
        String[] days = tmpMaintainancePlanDto.getMaintainanceDay().split(",");
        int day = today.get(Calendar.DAY_OF_MONTH);
        if (!Arrays.asList(days).contains(day + "")) {
            return false;
        }

        //当前时间是否 到了 巡检任务前30分钟

        int beforeTime = 30;

        String planTime = DateUtil.getNow(DateUtil.DATE_FORMATE_STRING_B) + " 09:00:00";

        Calendar calendar = Calendar.getInstance();
        calendar.setTime(DateUtil.getDateFromStringA(planTime));
        calendar.add(Calendar.MINUTE, beforeTime * (-1));
        if (DateUtil.getCurrentDate().before(calendar.getTime())) { // 还没到生成任务时间
            return false;
        }

        // 判断 员工是否上班

        ScheduleClassesStaffDto scheduleClassesStaffDto = new ScheduleClassesStaffDto();
        scheduleClassesStaffDto.setStaffId(tmpMaintainancePlanStaffDto.getStaffId());
        scheduleClassesStaffDto.setToday(DateUtil.getDateFromStringA(planTime));
        scheduleClassesStaffDto = scheduleClassesStaffV1InnerServiceSMOImpl.staffIsWork(scheduleClassesStaffDto);

        if (!scheduleClassesStaffDto.isWork()) {//根据排班员工 休息
            return false;

        }

        MaintainanceTaskDto maintainanceTaskDto = new MaintainanceTaskDto();
        maintainanceTaskDto.setCommunityId(tmpMaintainancePlanDto.getCommunityId());
        //maintainanceTaskDto.setPlanId(tmpMaintainancePlanDto.getPlanId());
        //这里修改为用原始 巡检人查 以防 做了 转单
        maintainanceTaskDto.setPlanId(tmpMaintainancePlanDto.getPlanId());
        maintainanceTaskDto.setOriginalPlanUserId(tmpMaintainancePlanStaffDto.getStaffId());
        maintainanceTaskDto.setPlanInsTime(DateUtil.getNow(DateUtil.DATE_FORMATE_STRING_B));

        //目前逻辑修改 一个巡检 计划 对于一个员工只能生成一次巡检任务，所以 传 员工 巡检计划ID 时间即可
        List<MaintainanceTaskDto> maintainanceTaskDtos = maintainanceTaskV1InnerServiceSMOImpl.queryMaintainanceTasks(maintainanceTaskDto);
        if (maintainanceTaskDtos != null && maintainanceTaskDtos.size() > 0) { // 已经生成过
            return false;
        }

        return true;

    }

    /**
     * 每周
     *
     * @param tmpMaintainancePlanDto
     * @param taskDto
     * @param communityDto
     */
    private boolean hasGeneratorTaskConditionByWeek(MaintainancePlanDto tmpMaintainancePlanDto, TaskDto taskDto, CommunityDto communityDto,
                                                    MaintainancePlanStaffDto tmpMaintainancePlanStaffDto, List<MaintainanceTaskPo> maintainanceTaskPos,
                                                    List<MaintainanceTaskDetailPo> maintainanceTaskDetailPos) {

        // 检查 今日是否 需要 生成巡检任务
        int day = Integer.parseInt(tmpMaintainancePlanDto.getMaintainanceEveryday());


        int subDay = DateUtil.daysBetween(DateUtil.getCurrentDate(), DateUtil.getDateFromStringB(tmpMaintainancePlanDto.getStartDate()));

        if (subDay % day != 0) {
            return false;
        }


        //当前时间是否 到了 巡检任务前30分钟
        int beforeTime = 30;

        String planTime = DateUtil.getNow(DateUtil.DATE_FORMATE_STRING_B) + " " + "09:00:00";

        Calendar calendar = Calendar.getInstance();
        calendar.setTime(DateUtil.getDateFromStringA(planTime));
        calendar.add(Calendar.MINUTE, beforeTime * (-1));
        if (DateUtil.getCurrentDate().before(calendar.getTime())) { // 还没到生成任务时间
            return false;
        }


        ScheduleClassesStaffDto scheduleClassesStaffDto = new ScheduleClassesStaffDto();
        scheduleClassesStaffDto.setStaffId(tmpMaintainancePlanStaffDto.getStaffId());
        scheduleClassesStaffDto.setToday(DateUtil.getDateFromStringA(planTime));
        scheduleClassesStaffDto = scheduleClassesStaffV1InnerServiceSMOImpl.staffIsWork(scheduleClassesStaffDto);

        if (!scheduleClassesStaffDto.isWork()) {//根据排班员工 休息
            return false;

        }

        MaintainanceTaskDto maintainanceTaskDto = new MaintainanceTaskDto();
        maintainanceTaskDto.setCommunityId(tmpMaintainancePlanDto.getCommunityId());
        //maintainanceTaskDto.setPlanId(tmpMaintainancePlanDto.getPlanId());
        //这里修改为用原始 巡检人查 以防 做了 转单
        maintainanceTaskDto.setPlanId(tmpMaintainancePlanDto.getPlanId());
        maintainanceTaskDto.setOriginalPlanUserId(tmpMaintainancePlanStaffDto.getStaffId());
        maintainanceTaskDto.setPlanInsTime(DateUtil.getNow(DateUtil.DATE_FORMATE_STRING_B));

        //目前逻辑修改 一个巡检 计划 对于一个员工只能生成一次巡检任务，所以 传 员工 巡检计划ID 时间即可
        List<MaintainanceTaskDto> maintainanceTaskDtos = maintainanceTaskV1InnerServiceSMOImpl.queryMaintainanceTasks(maintainanceTaskDto);
        if (maintainanceTaskDtos != null && maintainanceTaskDtos.size() > 0) { // 已经生成过
            return false;
        }

        return true;

    }


}