package com.gkhy.safePlatform.safeCheck.controller;

import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.gkhy.safePlatform.commons.co.ContextCacheUser;
import com.gkhy.safePlatform.commons.enums.E;
import com.gkhy.safePlatform.commons.enums.ResultCodes;
import com.gkhy.safePlatform.commons.exception.AusinessException;
import com.gkhy.safePlatform.commons.vo.ResultVO;
import com.gkhy.safePlatform.safeCheck.entity.SafeCheckTask;
import com.gkhy.safePlatform.safeCheck.entity.SafeCheckWork;
import com.gkhy.safePlatform.safeCheck.model.dto.req.*;
import com.gkhy.safePlatform.safeCheck.model.dto.resp.SafeCheckPointPageRespDTO;
import com.gkhy.safePlatform.safeCheck.model.dto.resp.SafeCheckPointRespDTO;
import com.gkhy.safePlatform.safeCheck.model.dto.resp.SafeCheckTaskUnitPageRespDTO;
import com.gkhy.safePlatform.safeCheck.model.dto.resp.SafeCheckTaskUnitRespDTO;
import com.gkhy.safePlatform.safeCheck.service.SafeCheckTaskManagerService;
import com.gkhy.safePlatform.safeCheck.service.baseService.SafeCheckWorkService;
import org.omg.CORBA.PUBLIC_MEMBER;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.security.core.Authentication;
import org.springframework.web.bind.annotation.*;

import java.util.HashMap;

@RestController
@RequestMapping("/SafeCheckTaskUnit")
public class SafeCheckTaskUnitController {

    @Autowired
    private SafeCheckTaskManagerService safeCheckTaskManagerService;

    @Autowired
    private SafeCheckWorkService safeCheckWorkService;

    /**
     * @description 新建一个任务单元
     */
    @RequestMapping("/insert/saveTaskUnit")
    public ResultVO<String> saveTaskUnit(Authentication authentication, @RequestBody SafeCheckTaskUnitReqDTO safeCheckTaskUnitReqDTO){
        ContextCacheUser currentUser = (ContextCacheUser)authentication.getPrincipal();
        safeCheckTaskManagerService.saveTaskUnit(currentUser,safeCheckTaskUnitReqDTO);
        return new ResultVO<>("200","巡检任务单元新建成功");
    }

    /***
     * @description 根据任务单元id删除任务单元
     */
    @PostMapping("/delete/deleteTaskUnit")
    public ResultVO<String> deleteTaskUnit(Authentication authentication,@RequestBody SafeCheckTaskUnitReqDTO safeCheckTaskUnitReqDTO){
        Long id = safeCheckTaskUnitReqDTO.getId();
        ContextCacheUser currentUser = (ContextCacheUser)authentication.getPrincipal();
        safeCheckTaskManagerService.deleteTaskUnit(currentUser, id);
        ResultVO resultVO = new ResultVO<>("200","删除巡检任务单元成功");
        return resultVO;
    }

    /**
     * @description 根据巡检点的id和任务单元id删除巡检链中的巡检点
     */
    @PostMapping("/delete/deleteTaskUnitPoint")
    public ResultVO<String> deleteTaskUnitPoint(Authentication authentication,@RequestBody SafeCheckUnitAndQuotaReqDTO safeCheckUnitAndQuotaReqDTO){
        HashMap<String, Object> taskUnitAndPointId = new HashMap<>();
        taskUnitAndPointId.put("taskUnitId",safeCheckUnitAndQuotaReqDTO.getUnitId());
        taskUnitAndPointId.put("id",safeCheckUnitAndQuotaReqDTO.getId());
        ContextCacheUser currentUser = (ContextCacheUser)authentication.getPrincipal();
        safeCheckTaskManagerService.deleteTaskUnitPoint(currentUser, taskUnitAndPointId);
        ResultVO resultVO = new ResultVO<>("200","删除巡检点成功");
        return resultVO;
    }

    /**
     * @description 根据巡检任务单元的id及巡检单元与巡检指标关联表的id对巡检点信息内容进行修改
     */
    @PostMapping("/update/updateTaskUnitPointById")
    public ResultVO<String> updateTaskUnitPointById(Authentication authentication, @RequestBody SafeCheckUnitAndQuotaReqDTO safeCheckUnitAndQuotaReqDTO){
        ContextCacheUser currentUser = (ContextCacheUser)authentication.getPrincipal();
        safeCheckTaskManagerService.updateTaskUnitPointById(currentUser,safeCheckUnitAndQuotaReqDTO);
        ResultVO resultVO = new ResultVO<>("200","修改巡检点信息成功");
        return resultVO;
    }


    /**
     * @description 往巡检链中新增一个巡检点
     */
    @RequestMapping("/insert/saveTaskUnitPoint")
    public ResultVO<String> saveTaskUnitPoint(Authentication authentication, @RequestBody SafeCheckUnitAndQuotaReqDTO safeCheckUnitAndQuotaReqDTO){
        ContextCacheUser currentUser = (ContextCacheUser)authentication.getPrincipal();
        safeCheckTaskManagerService.saveTaskUnitPoint(currentUser,safeCheckUnitAndQuotaReqDTO);
        return new ResultVO<>("200","巡检点新增成功");
    }



    /**
     * @description 根据id更新巡检任务单元状态
     */
    @PostMapping("/update/updateTaskUnitStatusById")
    public ResultVO<String> updateTaskUnitStatusById(Authentication authentication, @RequestBody SafeCheckTaskUnitReqDTO safeCheckTaskUnitReqDTO){
        ContextCacheUser currentUser = (ContextCacheUser)authentication.getPrincipal();
        String TaskUnitStatus = safeCheckTaskManagerService.updateTaskUnitStatusById(currentUser, safeCheckTaskUnitReqDTO);
        ResultVO resultVO = new ResultVO<>("200",TaskUnitStatus+"巡检任务单元成功");
        return resultVO;
    }


    /**
     * @description 根据id更新巡检任务单元信息
     */
    @PostMapping("/update/updateTaskUnitMainById")
    public ResultVO<String> updateTaskUnitMainById(Authentication authentication, @RequestBody SafeCheckTaskUnitReqDTO safeCheckTaskUnitReqDTO){
        ContextCacheUser currentUser = (ContextCacheUser)authentication.getPrincipal();
        safeCheckTaskManagerService.updateTaskUnitMainById(currentUser, safeCheckTaskUnitReqDTO);
        ResultVO resultVO = new ResultVO<>("200","更新巡检任务单元成功");
        return resultVO;
    }




    /**
     * @description 根据任务单元id查询任务单元
     */
    @PostMapping("/select/getTaskUnitById")
    public ResultVO<SafeCheckTaskUnitRespDTO> getTaskUnitById(@RequestBody SafeCheckTaskUnitReqDTO safeCheckTaskUnitReqDTO){
        Long id = safeCheckTaskUnitReqDTO.getId();
        SafeCheckTaskUnitRespDTO taskUnitRespDTO = safeCheckTaskManagerService.getTaskUnitById(id);
        ResultVO resultVO = new ResultVO<>(ResultCodes.OK,taskUnitRespDTO);
        return resultVO;
    }

    /**
     * @description 查询所有巡检任务单元数据并进行分页(包含条件查询)
     */
    @PostMapping("/select/listTaskUnitByPage")
    public ResultVO<IPage<SafeCheckTaskUnitPageRespDTO>> listTaskUnitByPage(Authentication authentication,@RequestBody SafeCheckTaskUnitPageReqDTO safeCheckTaskUnitPageReqDTO){
        ContextCacheUser currentUser = (ContextCacheUser)authentication.getPrincipal();
        Integer pageIndex = safeCheckTaskUnitPageReqDTO.getPageIndex();
        Integer pageSize = safeCheckTaskUnitPageReqDTO.getPageSize();
        if (pageIndex == 0 || pageSize == 0){
            throw new AusinessException(E.DATA_PARAM_NULL,"当前页码或当前页显示数不能为0");
        }
        Page pageInfo = new Page(pageIndex, pageSize);
        //连表查询后再统计总数
        pageInfo.setOptimizeCountSql(false);
        IPage iPage = safeCheckTaskManagerService.listTaskUnitByPage(pageInfo, safeCheckTaskUnitPageReqDTO,currentUser);
        return new ResultVO<>(ResultCodes.OK,iPage);
    }
}