package com.engine.attendance.attendanceanalysis.cmd;

import com.engine.attendance.attendanceanalysis.cmd.item.WorkOvertimeItemCmd;
import com.engine.attendance.attendanceanalysis.service.ShiftService;
import com.engine.attendance.attendanceanalysis.service.impl.ShiftServiceImpl;
import com.engine.attendance.enums.CheckBoxEnum;
import com.engine.attendance.enums.ClassBelongToEnum;
import com.engine.attendance.enums.ClassSegmentTypeEnum;
import com.engine.attendance.enums.WorkForTimeEnum;
import com.engine.common.biz.AbstractCommonCommand;
import com.engine.common.entity.BizLogContext;
import com.engine.common.util.DateUtil;
import com.engine.common.util.DbTools;
import com.engine.common.util.ServiceUtil;
import com.engine.common.util.Utils;
import com.engine.core.interceptor.CommandContext;
import com.google.common.collect.Lists;
import com.google.common.collect.Maps;
import lombok.extern.slf4j.Slf4j;
import weaver.general.Util;

import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;

/**
 * 获得班次结果
 * 这边改了代码，ShiftServiceImpl的getSchedulingInFormation方法打卡匹配班次类也得跟着变，里面有相同逻辑
 */
@Slf4j
public class GetScheduleResultListCmd extends AbstractCommonCommand<Map<String,Object>> {
    private ShiftService basicsetService = ServiceUtil.getService(ShiftServiceImpl.class);

    public GetScheduleResultListCmd(Map<String,Object> params){
        this.params=params;
    }
    @Override
    public BizLogContext getLogContext() {
        return null;
    }

    @Override
    public Map<String, Object> execute(CommandContext commandContext) {
        /** 班次信息*/
        List<Map<String,Object>> attendanceItems = (List<Map<String,Object>>)params.get("attendanceItems");

        Map<String,Object> schedulingResultsMap = (Map<String,Object>)params.get("schedulingResultsMap");
        List<Map<String,Object>> schedulingResultsList = (List<Map<String,Object>>)schedulingResultsMap.get("data");
        schedulingResultsList = Utils.getSchedulingList(schedulingResultsList);
        //去除候选班组
        List<Map<String,Object>> candidateSchedulingResultsList  = schedulingResultsList.stream().filter(e->!"".equals(Util.null2String(e.get("hxbz"))) && "".equals(Util.null2String(e.get("bcxx")))).collect(Collectors.toList());
        schedulingResultsList = schedulingResultsList.stream().filter(e->!"".equals(Util.null2String(e.get("bcxx")))).collect(Collectors.toList());

        Map<String,Object> schedulMap = Maps.newHashMap();
        String glpb = "";
        for (Map<String,Object> schedulingResult:schedulingResultsList){
            glpb = Util.null2String(schedulingResult.get("pbgl"));
        }

        Map<String,List<Map<String,Object>>> schedulingMap = schedulingResultsList.stream().collect(Collectors.groupingBy(e-> Util.null2String(e.get("bcxx")).split("-")[0]));
        Map<String,List<Map<String,Object>>> schedulingMapBydate = schedulingResultsList.stream().collect(Collectors.groupingBy(e-> Util.null2String(e.get("bcrq"))));
        schedulMap.put("schedulingMapBydate",schedulingMapBydate);

        Map<String,List<Map<String,Object>>> resultMap = Maps.newHashMap();
        String sql = "select a.xxbdkzdjb,a.sfxx,a.id bcxx,a.edsc,a.zgzsc,a.bcsdxx,a.sfdx,a.sfkt,b.bdlx,a.btgz,a.fgsjd,a.zddxfz,a.dxhs,b.kssj dtkssj,b.jssj dtjssj,b.ksdk,b.jsdk,b.tqdkfzs,b.thdkfzs,b.edxss,b.sfdx dtsfdx,b.zddxfz dtzddxfz,b.dxhs dtdxhs,b.gsrq from uf_jcl_kq_bcxx a left join uf_jcl_kq_bcxx_dt1 b on a.id=b.mainid where a.id in (";
        String bcxxIds = "";
        for (Map.Entry<String,List<Map<String,Object>>> entry :schedulingMap.entrySet()){
            if (!entry.getKey().equals("")){
                bcxxIds +=entry.getKey() +",";
            }
        }
        List<Map<String,Object>> dataList = Lists.newArrayList();
        if (!"".equals(bcxxIds)){
            bcxxIds = bcxxIds.substring(0,bcxxIds.length()-1);
            sql = sql +bcxxIds+") order by b.gsrq,b.kssj";
            dataList = DbTools.getSqlToList(sql);
            Map<String,List<Map<String,Object>>> dataMap = dataList.stream().collect(Collectors.groupingBy(e->Util.null2String(e.get("bcxx"))));

            List<Map<String, Object>> finalAttendanceItems = attendanceItems;
            dataMap.entrySet().forEach(e -> {
                List<Map<String,Object>> schedulingList = schedulingMap.get(e.getKey());
                List<Map<String,Object>> bcxxs = e.getValue();
                for (Map<String,Object> scheduling :schedulingList){
                    String bcrq = Util.null2String(scheduling.get("bcrq"));
                    String rqlx = Util.null2String(scheduling.get("rqlx"));
                    String sfxx = Util.null2String(scheduling.get("sfxx"));
                    List<Map<String,Object>> classs = Lists.newArrayList();
                    for (Map<String,Object> map:bcxxs){
                        Map<String,Object> newMap = Maps.newHashMap();
                        newMap.putAll(map);
                        newMap.put("rqlx",rqlx);
                        newMap.put("sfxx",sfxx);
                        adjustWorkOverTimeClass(newMap, finalAttendanceItems,commandContext);
                        classs.add(newMap);
                    }
                    resultMap.put(bcrq,classs);
                }
            });
        }
        /**
         * 候选班组
         */
        for (Map<String,Object> candidateSchedulingResult:candidateSchedulingResultsList){
            Map<String, Object> shiftResult = basicsetService.punchMatchShift(params.get("pbdx").toString(),candidateSchedulingResult,(List<Map<String,Object>>)params.get("clockInData"),(Map<String,Map<String,Object>>)params.get("clockInTimeMap"));
            List<Map<String,Object>> bcData = (List<Map<String,Object>>)shiftResult.get("bcData");
            for(Map<String,Object> data:bcData){
                adjustWorkOverTimeClass(data, attendanceItems,commandContext);
            }
            resultMap.put(shiftResult.get("bcrq").toString(),bcData);
        }

        /** 加班计划*/
        sql = "select b.jbry,b.ksrq,b.kssj,a.jblx,b.jsrq,b.jssj,b.jbsc from uf_jcl_kq_jbjh a left join uf_jcl_kq_jbjh_dt1 b on a.id=b.mainid where b.jbry =? and b.ksrq>=? and b.ksrq<=? and (b.jbcx=0 or b.jbcx is null)";
        Map<String,List<Map<String,Object>>> overtimePlanMap = DbTools.getSqlToList(sql,params.get("pbdx"),params.get("startDate"),params.get("endDate")).stream().collect(Collectors.groupingBy(e -> Util.null2String(e.get("ksrq"))));

        //考勤项目


        //日期集合
        Map<String,Object> dateParam = Maps.newHashMap();
        dateParam.put("nd",Util.null2String(params.get("startDate")).split("-")[0]);
        dateParam.put("glpb",glpb);
        List<Map<String,Object>> list = getDate(dateParam);
        Map<String,String> dateMap = list.stream().collect(Collectors.toMap(e->Util.null2String(e.get("rq")),e->Util.null2String(e.get("rqlx"))));

        for (Map.Entry<String,List<Map<String,Object>>> e: overtimePlanMap.entrySet()){
            if (resultMap.get(e.getKey()) == null){
                resultMap.put(e.getKey(),Lists.newArrayList());
            }
            List<Map<String,Object>> resultList = resultMap.get(e.getKey());
            List<Map<String,Object>> schedulingdateMap = schedulingMapBydate.get(e.getKey());
            Map<String,Object> overtimePlan = e.getValue().get(0);


            Map<String,Object> map = Maps.newHashMap();
            if (!overtimePlan.get("ksrq").equals(overtimePlan.get("jsrq"))){
                map.put("sfkt","1");
            }else {
                map.put("sfkt","0");
            }
            //查找对应的考勤项目
            String querySql = "select id keyid,ksjbbxydk,jsjbbxydk,tqdkyxfzs,thdkyxfzs,jbwdhlfzs,jbzzhlfzs,tqdkjrjb,thdkjrjb,jbscbdccsqsc,zdkcjcxxsc,ccclfs,rzdjbxss,yzdjbxss,zzdjbxss,jbzdzjqye,jbqsfzs,ccqszhdhsfzs,hsl,hsdw from uf_jcl_kq_kqxm where id=?";
            attendanceItems = DbTools.getSqlToList(querySql,overtimePlan.get("jblx"));


            map.put("bcxx",schedulingdateMap == null || schedulingdateMap.get(0) ==null ? "0" :schedulingdateMap.get(0).get("bcxx"));
            map.put("bcsdxx",schedulingdateMap == null || schedulingdateMap.get(0) ==null ? "":schedulingdateMap.get(0).get("bcsdxx"));
            if (resultList.size()>0){
                map.put("edsc",Util.null2String(resultList.get(0).get("edsc")));
                map.put("sfdx",Util.null2String(resultList.get(0).get("sfdx")));
                map.put("zddxfz",Util.null2String(resultList.get(0).get("zddxfz")));
                map.put("dxhs",Util.null2String(resultList.get(0).get("dxhs")));
            }else {
                map.put("edsc","0");
            }
            map.put("bdlx", ClassSegmentTypeEnum.OVERTIME_PLAN.getKey());
            map.put("dtkssj",overtimePlan.get("kssj"));
            map.put("dtjssj",overtimePlan.get("jssj"));
            map.put("ksdk","0");
            map.put("jsdk","0");
            if (schedulingdateMap != null && schedulingdateMap.size()>0){
                map.put("sfxx",Util.null2String(schedulingdateMap.get(0).get("sfxx")));
            }
            map.put("tqdkfzs","60");
            map.put("thdkfzs","60");
            map.put("rqlx",dateMap.get(e.getKey()));
            map.put("edxss",overtimePlan.get("jbsc"));
            map.put("jblx",attendanceItems);
            map.put("gsrq", ClassBelongToEnum.NOWDAY.getKey());
            if (attendanceItems.size() >0){
                map.put("ksdk",attendanceItems.get(0).get("ksjbbxydk"));
                map.put("jsdk",attendanceItems.get(0).get("jsjbbxydk"));
                map.put("tqdkfzs",attendanceItems.get(0).get("tqdkyxfzs"));
                map.put("thdkfzs",attendanceItems.get(0).get("thdkyxfzs"));
                map.put("jbwdhlfzs",attendanceItems.get(0).get("jbwdhlfzs"));
                map.put("jbzzhlfzs",attendanceItems.get(0).get("jbzzhlfzs"));
            }
            if (resultList.size() > 1){
                String kssjbegin = Utils.getkssjTime(resultList.get(0),e.getKey());
                String kssjend = Utils.getkssjTime(resultList.get(resultList.size()-1),e.getKey());
                String kssj = overtimePlan.get("ksrq")+" "+overtimePlan.get("kssj");
                if (DateUtil.getTime(kssj).compareTo(DateUtil.getTime(kssjbegin)) <0){
                    //加班计划在开头
                    if (resultList.get(0).get("dtkssj").equals(overtimePlan.get("jssj")) &&
                            resultList.get(0).get("ksdk").equals(CheckBoxEnum.CHECKED.getKey()) &&
                            map.get("ksdk").equals(CheckBoxEnum.CHECKED.getKey()) &&
                            map.get("jsdk").equals(CheckBoxEnum.CHECKED.getKey())){
                        //当加班结束时间和早上打卡时间重合时

                    }
                    resultList.add(0,map);
                }else if (DateUtil.getTime(kssj).compareTo(DateUtil.getTime(kssjend)) >0){
                    //加班计划在末尾
                    if (resultList.get(0).get("dtjssj").equals(overtimePlan.get("kssj")) &&
                            resultList.get(0).get("jsdk").equals(CheckBoxEnum.CHECKED.getKey()) &&
                            map.get("ksdk").equals(CheckBoxEnum.CHECKED.getKey()) &&
                            map.get("jsdk").equals(CheckBoxEnum.CHECKED.getKey())){
                        //当加班结束时间和晚上下班时间重合时1

                    }
                    resultList.add(map);
                }else {
                    //加班计划在中间
                    for (int j=1;j<resultList.size();j++){
                        String kssj1 = Utils.getkssjTime(resultList.get(j),e.getKey());
                        String kssj2 = overtimePlan.get("ksrq")+" "+overtimePlan.get("kssj");
                        String kssj3 = Utils.getkssjTime(resultList.get(j-1),e.getKey());
                        if (DateUtil.getTime(kssj1).compareTo(DateUtil.getTime(kssj2)) >=0 &&  DateUtil.getTime(kssj3).compareTo(DateUtil.getTime(kssj2)) <=0){
                            resultList.add(j,map);
                            break;
                        }
                    }
                }
            }else {
                resultList.add(map);
            }

        }

        schedulMap.put("schedulingResultsMap",resultMap);
        log.info("SchedulingResults : [{}]",resultMap);
        return schedulMap;
    }

    public List<Map<String,Object>> getDate(Map<String,Object> param){
        String nd = Util.null2String(param.get("nd"));
        String glpb = Util.null2String(param.get("glpb"));
        String sql = "select nd,rq,nlrq,rqlx,xq,rlmc from uf_jcl_kq_rlxx a left join uf_jcl_kq_glpb  b on a.rlmc=b.qyrl where b.id=? and a.nd=? ";
        List<Map<String,Object>> dataList=null;
        if ("".equals(glpb)){
            sql = "select a.nd,a.rq,a.nlrq,a.rqlx,a.xq,a.rlmc from uf_jcl_kq_rlxx a left join uf_jcl_kq_rlmc b on a.rlmc=b.id where a.nd=? and b.mrrl=1";
            dataList = DbTools.getSqlToList(sql,nd);
        }else {
            dataList = DbTools.getSqlToList(sql,glpb,nd);
        }
        return dataList;
    }

    /**
     * 1、班次班段上设置的开始结束打卡与考勤项目（加班类）上设置的开始结束大打相冲突时，按标记需要检查打卡的设置为准；
     * 调整加班时段的打卡
     * @param scheduleMap
     */
    public void  adjustWorkOverTimeClass(Map<String,Object> scheduleMap,List<Map<String,Object>> attendanceItems,CommandContext commandContext){
        String bdlx = Util.null2String(scheduleMap.get("bdlx"));
        if (Utils.ifOverTimeClassSegment(scheduleMap.get("bdlx").toString())){
            Map<String,Object> getWorkOverTimeParam = Maps.newHashMap();
            getWorkOverTimeParam.put("attendanceItems",attendanceItems);
            getWorkOverTimeParam.put("rqlx",scheduleMap.get("rqlx"));

            List<Map<String,Object>> workTimeBeItems = Lists.newArrayList();

            if (ClassSegmentTypeEnum.EXTENDED_OVERTIME.getKey().equals(bdlx)){
                getWorkOverTimeParam.put("workfor", WorkForTimeEnum.DELAY_TO_WORK_OVERTIME.getKey());
                Map<String,Object> result = new WorkOvertimeItemCmd(getWorkOverTimeParam).execute(commandContext);
                //加班项目
                workTimeBeItems = (List<Map<String,Object>>)result.get("attendanceItems");
            }else if (ClassSegmentTypeEnum.EARLY_OVERTIME.getKey().equals(bdlx)){
                getWorkOverTimeParam.put("workfor",WorkForTimeEnum.EARLY_TO_WORK_OVERTIME.getKey());
                Map<String,Object> result = new WorkOvertimeItemCmd(getWorkOverTimeParam).execute(commandContext);
                workTimeBeItems = (List<Map<String,Object>>)result.get("attendanceItems");
            }else if (ClassSegmentTypeEnum.OVERTIME_PLAN.getKey().equals(bdlx)){
                workTimeBeItems = (List<Map<String,Object>>)scheduleMap.get("jblx");
            }else if (ClassSegmentTypeEnum.OVERTIME_IN_CLASS.getKey().equals(bdlx)){
                getWorkOverTimeParam.put("workfor",WorkForTimeEnum.OVERTIME_IN_CLASS.getKey());
                Map<String,Object> result = new WorkOvertimeItemCmd(getWorkOverTimeParam).execute(commandContext);
                workTimeBeItems = (List<Map<String,Object>>)result.get("attendanceItems");
            }
            if (workTimeBeItems.size() > 0){
                int tqdkfzs = Integer.valueOf(Util.null2String(scheduleMap.get("tqdkfzs")).equals("")?"0":Util.null2String(scheduleMap.get("tqdkfzs")));
                int thdkfzs = Integer.valueOf(Util.null2String(scheduleMap.get("thdkfzs")).equals("")?"0":Util.null2String(scheduleMap.get("thdkfzs")));
                int tqdkyxfzs = Integer.valueOf(workTimeBeItems.get(0).get("tqdkyxfzs").toString());
                int thdkyxfzs = Integer.valueOf(workTimeBeItems.get(0).get("thdkyxfzs").toString());

                if (tqdkyxfzs > tqdkfzs){
                    //提前打卡分钟数
                    scheduleMap.put("tqdkfzs",workTimeBeItems.get(0).get("tqdkyxfzs"));
                }
                if (thdkyxfzs > thdkfzs){
                    //推后打卡分钟数
                    scheduleMap.put("thdkfzs",workTimeBeItems.get(0).get("thdkyxfzs"));
                }
            }
        }
    }



}