package com.xjrsoft.module.attendance.controller;

import cn.dev33.satoken.annotation.SaCheckPermission;
import cn.hutool.core.util.ObjectUtil;
import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.github.yulichang.wrapper.MPJLambdaWrapper;
import com.xjrsoft.common.enums.OutInStatusEnum;
import com.xjrsoft.common.model.result.RT;
import com.xjrsoft.common.page.ConventPage;
import com.xjrsoft.common.page.PageOutput;
import com.xjrsoft.common.utils.VoToColumnUtil;
import com.xjrsoft.module.attendance.dto.TeacherDetailsDto;
import com.xjrsoft.module.attendance.entity.AttendanceRuleDetails;
import com.xjrsoft.module.attendance.entity.AttendanceUserRelation;
import com.xjrsoft.module.attendance.service.IAttendanceRuleCategoryService;
import com.xjrsoft.module.attendance.service.ITeacherAttendanceRecordService;
import com.xjrsoft.module.attendance.vo.AttendanceRuleDetailsUserVo;
import com.xjrsoft.module.attendance.vo.TeacherStatisticsPageVo;
import com.xjrsoft.module.holiday.entity.HolidayDate;
import com.xjrsoft.module.holiday.service.IHolidayDateService;
import com.xjrsoft.module.organization.entity.User;
import com.xjrsoft.module.organization.entity.UserDeptRelation;
import com.xjrsoft.module.organization.service.IUserService;
import com.xjrsoft.module.outint.dto.TeacherOutInRecordDto;
import com.xjrsoft.module.outint.entity.CarOutInRecord;
import com.xjrsoft.module.outint.entity.TeacherOutInRecord;
import com.xjrsoft.module.outint.service.ICarOutInRecordService;
import com.xjrsoft.module.outint.service.ITeacherOutInRecordService;
import com.xjrsoft.module.personnel.entity.CarMessageApply;
import com.xjrsoft.module.teacher.entity.BaseTeacher;
import com.xjrsoft.module.teacher.entity.WfTeacherleave;
import com.xjrsoft.module.teacher.service.IWfHeadTeacherLeaveService;
import com.xjrsoft.module.teacher.service.IWfTeacherleaveService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.AllArgsConstructor;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.validation.Valid;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.Arrays;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;

/**
* @title: 教师考勤
* @Author dzx
* @Date: 2024-05-29
* @Version 1.0
*/
@RestController
@RequestMapping("/teacherStatistics")
@Api(value = "/teacherStatistics" ,tags = "教师考勤统计")
@AllArgsConstructor
public class TeacherStatisticsController {

    private final ITeacherAttendanceRecordService attendanceRecordService;

    private final IUserService xjrUserService;
    private final ITeacherOutInRecordService teacherOutInRecordService;
    private final IWfTeacherleaveService wfTeacherleaveService;
    private final IHolidayDateService holidayDateService;
    private final IWfHeadTeacherLeaveService headTeacherLeaveService;
    private final IAttendanceRuleCategoryService attendanceRuleCategoryService;
    private final ICarOutInRecordService carOutInRecordService;

    @GetMapping(value = "/teacher-details")
    @ApiOperation(value="教师考勤")
    @SaCheckPermission("statistics:detail")
    public RT<PageOutput<TeacherStatisticsPageVo>> teacherDetails(@Valid TeacherDetailsDto dto){
        DateTimeFormatter dtf = DateTimeFormatter.ofPattern("yyyy-MM-dd");
        String today = LocalDate.now().format(dtf);
        Page<TeacherStatisticsPageVo> voIPage2 = attendanceRecordService.getPage(new Page<>(dto.getLimit(), dto.getSize()), dto);
        if(!today.equals(dto.getDate()) && !voIPage2.getRecords().isEmpty()){
            PageOutput<TeacherStatisticsPageVo> pageOutput = ConventPage.getPageOutput(voIPage2, TeacherStatisticsPageVo.class);
            return RT.ok(pageOutput);
        }else{
            MPJLambdaWrapper<User> queryUser = new MPJLambdaWrapper<>();
            queryUser.disableSubLogicDel().distinct()
                    .select(" (SELECT GROUP_CONCAT(t1.name) FROM xjr_department t1" +
                            " INNER JOIN xjr_user_dept_relation t2 ON t1.id = t2.dept_id" +
                            " WHERE t1.delete_mark = 0 AND t2.user_id = t.id) as dept_name")
                    .eq(ObjectUtil.isNotNull(dto.getDeptId()), UserDeptRelation::getDeptId, dto.getDeptId())
                    .eq(StrUtil.isNotEmpty(dto.getAttendanceMode()), AttendanceUserRelation::getAttendanceMode, dto.getAttendanceMode())
                    .like(StrUtil.isNotEmpty(dto.getCarNumber()), AttendanceUserRelation::getCarNumber, dto.getCarNumber())
                    .like(StrUtil.isNotEmpty(dto.getName()), User::getName, dto.getName())
                    .selectAs(User::getName, TeacherStatisticsPageVo::getTeacherName)
                    .selectAs(User::getId, TeacherStatisticsPageVo::getUserId)
                    .selectAs(User::getMobile, TeacherStatisticsPageVo::getMobile)
                    .innerJoin(BaseTeacher.class, BaseTeacher::getUserId, User::getId)
                    .innerJoin(UserDeptRelation.class, UserDeptRelation::getUserId, User::getId)
                    .leftJoin(AttendanceUserRelation.class, AttendanceUserRelation::getUserId, User::getId);
            IPage<TeacherStatisticsPageVo> voIPage = xjrUserService.selectJoinListPage(ConventPage.getPage(dto), TeacherStatisticsPageVo.class, queryUser);

            if(dto.getDate() != null && !"".equals(dto.getDate())){
                DateTimeFormatter formatter = DateTimeFormatter.ISO_DATE;
                LocalDate queryDate = LocalDate.parse(dto.getDate(), formatter);

                HolidayDate holidayDate = holidayDateService.getOne(
                        new QueryWrapper<HolidayDate>().lambda()
                                .eq(HolidayDate::getDate, queryDate)
                );
                if(holidayDate != null && holidayDate.getWay() != null && holidayDate.getWay() != 0){
                    return RT.ok(ConventPage.getPageOutput(voIPage, TeacherStatisticsPageVo.class));
                }

                List<Long> userIds = voIPage.getRecords().stream().map(TeacherStatisticsPageVo::getUserId).collect(Collectors.toList());
                Map<Long, AttendanceRuleDetailsUserVo> teacherTodyRuleByUserId = attendanceRuleCategoryService.getTeacherTodyRuleByUserId(userIds);
                List<String> weekList = Arrays.asList("SUNDAY", "SATURDAY");

                List<HolidayDate> workHolidayDates = holidayDateService.list(
                        new QueryWrapper<HolidayDate>().lambda()
                                .eq(HolidayDate::getStatus, 2)
                );
                List<String> workHolidayDateListg = workHolidayDates.stream().map(HolidayDate::getDate).collect(Collectors.toList());

                List<Integer> holidayTypes = Arrays.asList(1, 3);
                List<HolidayDate> holidayDates = holidayDateService.list(
                        new QueryWrapper<HolidayDate>().lambda()
                                .in(HolidayDate::getStatus, holidayTypes)
                );
                List<String> holidayDateList = holidayDates.stream().map(HolidayDate::getDate).collect(Collectors.toList());

                for (TeacherStatisticsPageVo record : voIPage.getRecords()) {
                    LocalDateTime startTime, endTime, amEndTime = null;
                    AttendanceRuleDetailsUserVo detailsUserVo = teacherTodyRuleByUserId.get(record.getUserId());
                    if(detailsUserVo == null){
                        record.setStatus("不考勤");
                        continue;
                    }
                    AttendanceRuleDetails holidayRule = attendanceRuleCategoryService.getHolidayRuleByParam(record.getUserId());
                    if(((!workHolidayDateListg.contains(queryDate.format(formatter)) && weekList.contains(queryDate.getDayOfWeek().name()))
                            || holidayDateList.contains(queryDate.format(formatter))) && (holidayRule.getIsAttendance() == null || holidayRule.getIsAttendance() == 0)){
                        record.setStatus("不考勤");
                        continue;
                    }
                    if(dto.getTimePeriod() != null && dto.getTimePeriod() == 1){
                        startTime = queryDate.atTime(5, 0, 0);
                        if(detailsUserVo.getAmStartTime() != null){
                            startTime = queryDate.atTime(detailsUserVo.getAmStartTime());
                        }
                        endTime = queryDate.atTime(12, 0, 0);
                        if(detailsUserVo.getAmEndTime() != null){
                            endTime = queryDate.atTime(detailsUserVo.getAmEndTime());
                        }
                    }else if(dto.getTimePeriod() != null && dto.getTimePeriod() == 2){
                        startTime = queryDate.atTime(12, 0, 0);
                        if(detailsUserVo.getPmStartTime() != null){
                            startTime = queryDate.atTime(detailsUserVo.getPmStartTime());
                        }
                        endTime = queryDate.atTime(18, 0, 0);
                        if(detailsUserVo.getPmEndTime() != null){
                            endTime = queryDate.atTime(detailsUserVo.getPmEndTime());
                        }
                        amEndTime  = queryDate.atTime(12, 0, 0);
                        if(detailsUserVo.getAmEndTime() != null){
                            amEndTime = queryDate.atTime(detailsUserVo.getAmEndTime());
                        }
                    }else{
                        startTime = queryDate.atTime(0, 0, 0);
                        if(detailsUserVo.getEveningStartTime() != null){
                            startTime = queryDate.atTime(detailsUserVo.getEveningStartTime());
                        }
                        endTime = queryDate.atTime(23, 59, 59);
                        if(detailsUserVo.getEveningEndTime() != null){
                            endTime = queryDate.atTime(detailsUserVo.getEveningEndTime());
                        }
                    }

                    WfTeacherleave studentLeave = wfTeacherleaveService.getLeaveByUserId(startTime, endTime, record.getUserId());
                    if(studentLeave != null){
                        record.setStatus(studentLeave.getLeaveType());
                        continue;
                    }

                    TeacherOutInRecordDto outInDto = new TeacherOutInRecordDto();
                    outInDto.setQueryDate(startTime.toLocalDate());
                    outInDto.setStartTime(startTime);
                    outInDto.setEndTime(endTime);
                    outInDto.setStatus(OutInStatusEnum.enter.getCode());
                    outInDto.setUserId(record.getUserId());
                    outInDto.setTimePeriod(dto.getTimePeriod());
                    outInDto.setAmEndTime(amEndTime);
                    List<TeacherOutInRecord> outInRecords = teacherOutInRecordService.getListByParam(outInDto);
                    //查询该教师是否通过车辆进入
                    List<CarOutInRecord> list = carOutInRecordService.list(
                            new MPJLambdaWrapper<CarOutInRecord>()
                                    .select(CarOutInRecord.class, x -> VoToColumnUtil.fieldsToColumns(CarOutInRecord.class).contains(x.getProperty()))
                                    .leftJoin(CarMessageApply.class, CarMessageApply::getId, CarOutInRecord::getCarMessageApplyId)
                                    .le(CarOutInRecord::getRecordTime, endTime)
                                    .eq("DATE_FORMAT(record_time, '%Y-%m-%d')", endTime.toLocalDate())
                                    .eq(CarMessageApply::getUserId, record.getUserId())
                                    .ge(dto.getTimePeriod() == 2, CarOutInRecord::getRecordTime, amEndTime)
                                    .eq(CarOutInRecord::getStatus, OutInStatusEnum.enter.getCode())
                                    .orderByAsc(CarOutInRecord::getRecordTime)
                    );
                    //最早进入方式：1人脸 2车辆
                    Integer inStatus = 0;
                    if(!outInRecords.isEmpty() && !list.isEmpty()){
                        TeacherOutInRecord teacherOutInRecord = outInRecords.get(0);
                        CarOutInRecord carOutInRecord = list.get(0);
                        int result = teacherOutInRecord.getRecordTime().compareTo(carOutInRecord.getRecordTime());
                        if(result < 0){//人脸进入
                            inStatus = 1;
                        }else if(result == 0){//同时
                            inStatus = 0;
                        }else{//车辆进入
                            inStatus = 2;
                        }
                    }else if(!outInRecords.isEmpty()){
                        inStatus = 1;
                    }else if(!list.isEmpty()){
                        inStatus = 2;
                    }

                    if(inStatus == 1){
                        TeacherOutInRecord outInRecord = outInRecords.get(0);
                        if(outInRecord != null && outInRecord.getRecordTime().isBefore(startTime)){
                            record.setRecordTime(outInRecord.getRecordTime());
                            record.setStatus("到校");
                        }else if(outInRecord != null && outInRecord.getRecordTime().isAfter(startTime)){
                            record.setRecordTime(outInRecord.getRecordTime());
                            record.setStatus("迟到");
                        }
                    }else if(inStatus == 2){
                        CarOutInRecord outInRecord = list.get(0);
                        if(outInRecord != null && outInRecord.getRecordTime().isBefore(startTime)){
                            record.setRecordTime(outInRecord.getRecordTime());
                            record.setStatus("到校");
                            record.setCarNumber(outInRecord.getPlanNo());
                        }else if(outInRecord != null && outInRecord.getRecordTime().isAfter(startTime)){
                            record.setRecordTime(outInRecord.getRecordTime());
                            record.setStatus("迟到");
                            record.setCarNumber(outInRecord.getPlanNo());
                        }
                    }

                    if(record.getStatus() == null){
                        record.setStatus("缺勤");
                    }
                }
            }
            PageOutput<TeacherStatisticsPageVo> pageOutput = ConventPage.getPageOutput(voIPage, TeacherStatisticsPageVo.class);
            return RT.ok(pageOutput);
        }

    }

}