package com.gkhy.safePlatform.specialWork.controller;

import com.alibaba.fastjson.JSONObject;
import com.gkhy.safePlatform.commons.co.ContextCacheUser;
import com.gkhy.safePlatform.commons.enums.E;
import com.gkhy.safePlatform.commons.enums.Module;
import com.gkhy.safePlatform.commons.enums.ResultCodes;
import com.gkhy.safePlatform.commons.exception.AusinessException;
import com.gkhy.safePlatform.commons.query.PageQuery;
import com.gkhy.safePlatform.commons.utils.PageUtils;
import com.gkhy.safePlatform.commons.vo.ResultVO;
import com.gkhy.safePlatform.specialWork.enums.WorkTypePathEnum;
import com.gkhy.safePlatform.specialWork.model.annotation.CommonLogEnable;
import com.gkhy.safePlatform.specialWork.model.dto.req.*;
import com.gkhy.safePlatform.specialWork.model.dto.resp.*;
import com.gkhy.safePlatform.specialWork.model.dto.resp.applicant.ApplicantWorkApprovedApplyDetailRespDTO;
import com.gkhy.safePlatform.specialWork.model.dto.resp.approver.ApproverWorkApprovedApplyDetailRespDTO;
import com.gkhy.safePlatform.specialWork.model.dto.resp.approver.ApproverWorkPendingApprovalDataRespDTO;
import com.gkhy.safePlatform.specialWork.model.dto.resp.others.OthersWorkApprovedApplyDetailRespDTO;
import com.gkhy.safePlatform.specialWork.model.query.AllWorkApplyPageQuery;
import com.gkhy.safePlatform.specialWork.model.query.WorkApplyApplyingPageQuery;
import com.gkhy.safePlatform.specialWork.model.query.WorkApplyPendingPageQuery;
import com.gkhy.safePlatform.specialWork.model.query.WorkApplyRecordListQuery;
import com.gkhy.safePlatform.specialWork.service.WorkApplyRecordService;
import com.gkhy.safePlatform.specialWork.service.WorkApplyService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.security.core.Authentication;
import org.springframework.web.bind.annotation.*;

import javax.servlet.http.HttpServletResponse;
import java.util.List;

@RestController
@RequestMapping("/work")
public class WorkApplyController {

    @Autowired
    private WorkApplyService workApplyService;
    @Autowired
    private WorkApplyRecordService workApplyRecordService;


    private void workApplyEightPathCheck(String path, Byte workType) {
        WorkTypePathEnum typePathEnum = WorkTypePathEnum.parse(path);
        if (typePathEnum == null) {
            throw new AusinessException(E.DATA_PARAM_CHECK_INVALID, "申请路径非法");
        }
        if (!typePathEnum.type.equals(workType)) {
            throw new AusinessException(E.DATA_PARAM_CHECK_INVALID, "申请作业与访问路径不匹配");
        }
    }



    /**
    * @Description: 动火作业申请
    */
    @RequestMapping(value = "/apply/hot",method = RequestMethod.POST)
    @CommonLogEnable(module = Module.SPECIAL_WORK,content = "作业申请-动火")
    public ResultVO<String> workApplyHot(Authentication authentication, @RequestBody WorkApplyReqDTO<WorkApplyHotReqDTO> applyReqDTO){
        ContextCacheUser currentUser = (ContextCacheUser) authentication.getPrincipal();
        this.workApplyEightPathCheck(WorkTypePathEnum.WORK_FIRE.path, applyReqDTO.getWorkType());
        workApplyService.workApply(currentUser, applyReqDTO);
        return new ResultVO<>(ResultCodes.OK);
    }

    /**
     * @Description: 受限空间作业申请
     */
    @RequestMapping(value = "/apply/confinedspace",method = RequestMethod.POST)
    @CommonLogEnable(module = Module.SPECIAL_WORK,content = "作业申请-受限空间作业")
    public ResultVO<String> workApplyConfinedSpace(Authentication authentication, @RequestBody WorkApplyReqDTO<WorkApplyConfinedSpaceReqDTO> applyReqDTO){
        ContextCacheUser currentUser = (ContextCacheUser) authentication.getPrincipal();
        this.workApplyEightPathCheck(WorkTypePathEnum.WORK_CLOSE_SPACE.path, applyReqDTO.getWorkType());
        workApplyService.workApply(currentUser, applyReqDTO);
        return new ResultVO<>(ResultCodes.OK);
    }
    /**
     * @Description: 盲板抽堵作业申请
     */
    @RequestMapping(value = "/apply/blindPlatePlugging",method = RequestMethod.POST)
    @CommonLogEnable(module = Module.SPECIAL_WORK,content = "作业申请-盲板抽堵作业")
    public ResultVO<String> workApplyBlindPlatePlugging(Authentication authentication, @RequestBody WorkApplyReqDTO<WorkApplyBlindPlatePluggingReqDTO> applyReqDTO){
        ContextCacheUser currentUser = (ContextCacheUser) authentication.getPrincipal();
        this.workApplyEightPathCheck(WorkTypePathEnum.WORK_BLIND_PLATE.path, applyReqDTO.getWorkType());
        workApplyService.workApply(currentUser, applyReqDTO);
        return new ResultVO<>(ResultCodes.OK);
    }
    /**
     * @Description: 高处安全作业申请
     */
    @RequestMapping(value = "/apply/height",method = RequestMethod.POST)
    @CommonLogEnable(module = Module.SPECIAL_WORK,content = "作业申请-高处安全作业")
    public ResultVO<String> workApplyHeight(Authentication authentication, @RequestBody WorkApplyReqDTO<WorkApplyAtHighReqDTO> applyReqDTO){
        ContextCacheUser currentUser = (ContextCacheUser) authentication.getPrincipal();
        this.workApplyEightPathCheck(WorkTypePathEnum.WORK_HIGH_SPACE.path, applyReqDTO.getWorkType());
        workApplyService.workApply(currentUser, applyReqDTO);
        return new ResultVO<>(ResultCodes.OK);
    }
    /**
     * @Description: 断路作业申请
     */
    @RequestMapping(value = "/apply/brokenCircuit",method = RequestMethod.POST)
    @CommonLogEnable(module = Module.SPECIAL_WORK,content = "作业申请-断路作业")
    public ResultVO<String> workApplyBrokenCircuit(Authentication authentication, @RequestBody WorkApplyReqDTO<WorkApplyBrokenCircuitReqDTO> applyReqDTO){
        ContextCacheUser currentUser = (ContextCacheUser) authentication.getPrincipal();
        this.workApplyEightPathCheck(WorkTypePathEnum.WORK_BROKE_ROAD.path, applyReqDTO.getWorkType());
        workApplyService.workApply(currentUser, applyReqDTO);
        return new ResultVO<>(ResultCodes.OK);
    }
    /**
     * @Description: 吊装作业申请
     */
    @RequestMapping(value = "/apply/hoisting",method = RequestMethod.POST)
    @CommonLogEnable(module = Module.SPECIAL_WORK,content = "作业申请-吊装作业")
    public ResultVO<String> workApplyHoisting(Authentication authentication, @RequestBody WorkApplyReqDTO<WorkApplyHoistingReqDTO> applyReqDTO){
        ContextCacheUser currentUser = (ContextCacheUser) authentication.getPrincipal();
        this.workApplyEightPathCheck(WorkTypePathEnum.WORK_HANG.path, applyReqDTO.getWorkType());
        workApplyService.workApply(currentUser, applyReqDTO);
        return new ResultVO<>(ResultCodes.OK);
    }
    /**
     * @Description: 临时用电作业申请
     */
    @RequestMapping(value = "/apply/temporaryPower",method = RequestMethod.POST)
    @CommonLogEnable(module = Module.SPECIAL_WORK,content = "作业申请-临时用电作业")
    public ResultVO<String> workApplyTemporaryPower(Authentication authentication, @RequestBody WorkApplyReqDTO<WorkApplyTemporaryPowerReqDTO> applyReqDTO){
        ContextCacheUser currentUser = (ContextCacheUser) authentication.getPrincipal();
        this.workApplyEightPathCheck(WorkTypePathEnum.WORK_TEMP_ELECTRIC.path, applyReqDTO.getWorkType());
        workApplyService.workApply(currentUser, applyReqDTO);
        return new ResultVO<>(ResultCodes.OK);
    }
    /**
     * @Description: 动土作业申请
     */
    @RequestMapping(value = "/apply/groundBreaking",method = RequestMethod.POST)
    @CommonLogEnable(module = Module.SPECIAL_WORK,content = "作业申请-动土作业")
    public ResultVO<String> workApplyGroundBreaking(Authentication authentication, @RequestBody WorkApplyReqDTO<WorkApplyGroundBreakingReqDTO> applyReqDTO){
        ContextCacheUser currentUser = (ContextCacheUser) authentication.getPrincipal();
        this.workApplyEightPathCheck(WorkTypePathEnum.WORK_DIF_SOLI.path, applyReqDTO.getWorkType());
        workApplyService.workApply(currentUser, applyReqDTO);
        return new ResultVO<>(ResultCodes.OK);
    }

    /**
    * @Description: 取消申请
    */
    @RequestMapping(value = "/apply/cancel",method = RequestMethod.POST)
    @CommonLogEnable(module = Module.SPECIAL_WORK,content = "作业取消申请")
    public ResultVO<String> workApplyCancel(Authentication authentication, @RequestBody JSONObject json){
        ContextCacheUser currentUser = (ContextCacheUser) authentication.getPrincipal();
        Long workApplyId = json.getLong("workApplyId");
        workApplyService.cancelWorkApply(currentUser, workApplyId);
        return new ResultVO<>(ResultCodes.OK);
    }




    /**
    * @Description: 申请中的作业
    */
    @RequestMapping(value = "/apply/applying/page/list",method = RequestMethod.POST)
    public ResultVO<List<WorkApplyPageRespDTO>> workApplyApplyingPageList(Authentication authentication, @RequestBody PageQuery<WorkApplyApplyingPageQuery> pageQuery){
        ContextCacheUser currentUser = (ContextCacheUser) authentication.getPrincipal();
        PageUtils.checkCheck(pageQuery);
        return workApplyService.listApplyingWorkApplyByPage(currentUser, pageQuery);
    }

    /**
    * @Description: 已经审批的进度（申请人）
    */
    @RequestMapping(value = "/apply/applicant/approved/view",method = RequestMethod.POST)
    public ResultVO<ApplicantWorkApprovedApplyDetailRespDTO> workApplyApplyingViewForApplicant(Authentication authentication, @RequestBody JSONObject json){
        ContextCacheUser currentUser = (ContextCacheUser) authentication.getPrincipal();
        Long workApplyId = json.getLong("workApplyId");
        ApplicantWorkApprovedApplyDetailRespDTO data = workApplyService.getApprovedApplyDetailForApplicant(currentUser, workApplyId);
        return new ResultVO<>(ResultCodes.OK,data);
    }


    /**
     * @Description: 已经审批的进度（审批人）
     */
    @RequestMapping(value = "/apply/approver/approved/view",method = RequestMethod.POST)
    public ResultVO<ApproverWorkApprovedApplyDetailRespDTO> workApplyApplyingViewForApprover(Authentication authentication, @RequestBody JSONObject json){
        ContextCacheUser currentUser = (ContextCacheUser) authentication.getPrincipal();
        Long workApplyId = json.getLong("workApplyId");
        ApproverWorkApprovedApplyDetailRespDTO data = workApplyService.getApprovedApplyDetailForApprover(currentUser, workApplyId);
        return new ResultVO<>(ResultCodes.OK,data);
    }

    /**
    * @Description: 获取当前层级审批数据（审批人）
    */
    @RequestMapping(value = "/approval/pending/data",method = RequestMethod.POST)
    public ResultVO<ApproverWorkPendingApprovalDataRespDTO> getPendingApprovalData(Authentication authentication, @RequestBody JSONObject json){
        ContextCacheUser currentUser = (ContextCacheUser) authentication.getPrincipal();
        Long workApplyId = json.getLong("workApplyId");
        ApproverWorkPendingApprovalDataRespDTO data = workApplyService.getPendingApprovalData(currentUser, workApplyId);
        return new ResultVO<>(ResultCodes.OK,data);
    }


    /**
    * @Description: 待审批的作业(给work所出层级的每个单元)
    */
    @RequestMapping(value = "/apply/pending/page/list",method = RequestMethod.POST)
    public ResultVO<List<WorkApplyPendingPageRespDTO>> workApplyPendingPageList(Authentication authentication, @RequestBody PageQuery<WorkApplyPendingPageQuery> pageQuery){
        ContextCacheUser currentUser = (ContextCacheUser) authentication.getPrincipal();
        PageUtils.checkCheck(pageQuery);
        return workApplyService.listPendingWorkApplyByPage(currentUser, pageQuery);
    }

    /**
    * @Description: 审批
    */

    @RequestMapping(value = "/apply/approve",method = RequestMethod.POST)
    @CommonLogEnable(module = Module.SPECIAL_WORK,content = "作业审批")
    public ResultVO<String> workApplyApprove(Authentication authentication, @RequestBody ApprovalItemDataReqDTO approvalItemData){
        ContextCacheUser currentUser = (ContextCacheUser) authentication.getPrincipal();
        workApplyService.approveItem(currentUser, approvalItemData);
        return new ResultVO<>(ResultCodes.OK);
    }

    /**
     * 终止
     * @param authentication
     * @param abordDataReqDTO
     * @return
     */

    @RequestMapping(value = "/apply/abord",method = RequestMethod.POST)
    @CommonLogEnable(module = Module.SPECIAL_WORK,content = "作业终止")
    public ResultVO<String> workApplyAbord(Authentication authentication, @RequestBody ApprovalItemAbordDataReqDTO abordDataReqDTO){
        ContextCacheUser currentUser = (ContextCacheUser) authentication.getPrincipal();
        workApplyService.abordItem(currentUser, abordDataReqDTO);
        return new ResultVO<>(ResultCodes.OK);
    }

    /**
     *
     * 作业票导出
     * @param authentication
     * @param json
     * @param response
     */
    @RequestMapping(value = "/apply/printing",method = RequestMethod.POST)
    public void workApplyPrinting(Authentication authentication, @RequestBody JSONObject json, HttpServletResponse response){
        Long applyWorkId = json.getLong("applyWorkId");
        ContextCacheUser currentUser = (ContextCacheUser) authentication.getPrincipal();
        workApplyService.printing(currentUser,applyWorkId,response);
    }
    /**
     *
     * 作业票导出
     * @param authentication
     * @param json
     * @param response
     */
    @RequestMapping(value = "/apply/printingPdf",method = RequestMethod.POST)
    public void workApplyExportPdf(Authentication authentication, @RequestBody JSONObject json, HttpServletResponse response){
        Long applyWorkId = json.getLong("applyWorkId");
        ContextCacheUser currentUser = (ContextCacheUser) authentication.getPrincipal();
        workApplyService.printingPdf(currentUser,applyWorkId,response);
    }

    /**
     * @Description: 所有申请记录 非仅对申请人查看
     */
    @RequestMapping(value = "/apply/all/page/list",method = RequestMethod.POST)
    public ResultVO<List<AllWorkApplyPageRespDTO>> workApplyAllPageList(Authentication authentication, @RequestBody PageQuery<AllWorkApplyPageQuery> pageQuery) {
        ContextCacheUser currentUser = (ContextCacheUser) authentication.getPrincipal();
        PageUtils.checkCheck(pageQuery);
        return workApplyService.listAllWorkApply(currentUser, pageQuery);
    }

    /**
     * @Description: 所有申请记录的 单条记录详情查询
     */
    @RequestMapping(value = "/apply/others/view",method = RequestMethod.POST)
    public ResultVO<OthersWorkApprovedApplyDetailRespDTO> workApplyApplyingViewForOthers(Authentication authentication, @RequestBody JSONObject json) {
        ContextCacheUser currentUser = (ContextCacheUser) authentication.getPrincipal();
        Long workApplyId = json.getLong("workApplyId");
        OthersWorkApprovedApplyDetailRespDTO detail = workApplyService.getWorkApplyDetailForOthers(currentUser, workApplyId);
        return new ResultVO<>(ResultCodes.OK, detail);
    }

    @RequestMapping(value = "/apply/log", method = RequestMethod.POST)
    public ResultVO<List<WorkApplyRecordRespDTO>> workApplyLog(Authentication authentication,@RequestBody WorkApplyRecordListQuery query) {
        ContextCacheUser currentUser = (ContextCacheUser) authentication.getPrincipal();
        List<WorkApplyRecordRespDTO> list = workApplyRecordService.list(currentUser, query);
        return new ResultVO<>(ResultCodes.OK,list);
    }
}