package com.gk.hotwork.Controller;


import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.fasterxml.jackson.annotation.JsonFormat;
import com.gk.hotwork.Controller.Base.BaseController;
import com.gk.hotwork.Domain.Enum.HiddenDangerApplyStatus;
import com.gk.hotwork.Domain.Enum.HiddenDangerLevel;
import com.gk.hotwork.Domain.Enum.HiddenDangerReportSource;
import com.gk.hotwork.Domain.Enum.SourceType;
import com.gk.hotwork.Domain.HiddenDanger;
import com.gk.hotwork.Domain.Log.HiddenDangerLogAnno;
import com.gk.hotwork.Domain.TaskInfo;
import com.gk.hotwork.Domain.UserInfo;
import com.gk.hotwork.Domain.Utils.*;
import com.gk.hotwork.Domain.Vo.HiddenDangerAppVo;
import com.gk.hotwork.Domain.Vo.HiddenDangerVo;
import com.gk.hotwork.Domain.Vo.PageInfoExtension;
import com.gk.hotwork.Service.CompanyService;
import com.gk.hotwork.Service.HiddenDangerService;
import com.gk.hotwork.Service.TaskService;
import com.gk.hotwork.Service.UserService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.util.MultiValueMap;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;
import org.springframework.web.multipart.support.StandardMultipartHttpServletRequest;

import java.util.HashMap;
import java.util.List;
import java.util.Map;

@Api(tags = "隐患")
@RestController
@RequestMapping("hiddenDanger")
public class HiddenDangerController extends BaseController {


    @Autowired
    private HiddenDangerService hiddenDangerService;
    @Autowired
    private TaskService taskService;
    @Autowired
    private UserService userService;
    @Autowired
    private CompanyService companyService;

    /**
     * @Description: 通用查询
     * @date 2021/10/9 15:47
     */
    @ApiOperation(value = "查询分页",notes = "上报页")
    @ResponseBody
    @PostMapping(value = "/reportPage")
    @ApiImplicitParams({
            @ApiImplicitParam(name = "code",value = "隐患等级"),
            @ApiImplicitParam(name = "status",value = "应还状态"),
            @ApiImplicitParam(name = "rectifymeasure",value = "整改措施"),
            @ApiImplicitParam(name = "rectifier",value = "整改人"),
            @ApiImplicitParam(name = "rectifierid",value = "整改人id"),
            @ApiImplicitParam(name = "note",value = "上报说明"),
            @ApiImplicitParam(name = "files",value = "文件"),
    })
    public Object hiddenDangerReportPage(@RequestBody FilterObject filterObject) {
        Integer pageIndex = filterObject.getPageIndex();
        Integer pageSize = filterObject.getPageSize();
        IPage page = hiddenDangerService.selectReportPages(new Page<>(pageIndex, pageSize), filterObject.getFilter(), getUser());
        return success(page);
    }


    @ApiOperation(value = "查询分页",notes = "整改页")
    @ResponseBody
    @PostMapping("/rectifyPage")
    public Object hiddenDangerRectifyPage(@RequestBody FilterObject filterObject) {
        Integer pageIndex = filterObject.getPageIndex();
        Integer pageSize = filterObject.getPageSize();
        IPage page = hiddenDangerService.selectRectifyPages(new Page<>(pageIndex, pageSize), filterObject.getFilter(), getUser());
        return success(page);
    }

    @ApiOperation(value = "查询分页",notes = "验收页")
    @ResponseBody
    @PostMapping("/acceptPage")
    public Object hiddenDangerAcceptPage(@RequestBody FilterObject filterObject) {
        Integer pageIndex = filterObject.getPageIndex();
        Integer pageSize = filterObject.getPageSize();
        IPage page = hiddenDangerService.selectAcceptPages(new Page<>(pageIndex, pageSize), filterObject.getFilter(), getUser());
        return success(page);
    }


    @ApiOperation(value = "整改统计")
    @ResponseBody
    @PostMapping("/rectifyStatisticsPage")
    public Object hiddenDangerRectifyStatistics(@RequestBody FilterObject filterObject) {
        Integer pageIndex = filterObject.getPageIndex();
        Integer pageSize = filterObject.getPageSize();
        PageInfoExtension<Map> page = hiddenDangerService.selectRectifyStatisticsPages(new Page<>(pageIndex, pageSize), filterObject.getFilter(), getUser());
        return success(page);
    }
    /**
    * @Description: 最近一周的作业
    * @date 2021/10/11 15:07
    */
    @ApiOperation(value = "查询最近的作业")
    @ResponseBody
    @PostMapping("/taskInfo")
    public Object hiddenDangerPage(@RequestBody FilterObject filterObject) {
        Integer pageIndex = filterObject.getPageIndex();
        Integer pageSize = filterObject.getPageSize();
        IPage page = taskService.selectTaskInPeriod(new Page<>(pageIndex,pageSize),filterObject.getFilter(),getUser());
        return success(page);
    }

    /**
     * @Description: web
     */


    @ApiOperation(value = "web新增隐患")
    @ResponseBody
    @PostMapping("/report")
    @HiddenDangerLogAnno(operation = "上报", detail = "上报隐患")
    @ApiImplicitParams({
            @ApiImplicitParam(name = "level",value = "隐患等级"),
            @ApiImplicitParam(name = "rectifydeadline",value = "整改截止时间(yyyy-MM-dd HH:mm)"),
            @ApiImplicitParam(name = "rectifymeasure",value = "整改措施"),
            @ApiImplicitParam(name = "rectifier",value = "整改人"),
            @ApiImplicitParam(name = "rectifierid",value = "整改人id"),
            @ApiImplicitParam(name = "note",value = "上报说明"),
            @ApiImplicitParam(name = "files",value = "文件"),
    })
    public Object hiddenDangerReport(HiddenDangerVo hiddenDangerVo) {
        HiddenDanger hiddenDanger = hiddenDangerService.addReport(hiddenDangerVo, getUser(), HiddenDangerReportSource.NORMAL);
        return success(hiddenDanger);
    }



    @ApiOperation(value = "web隐患整改")
    @ResponseBody
    @PostMapping("/rectify")
    @HiddenDangerLogAnno(operation = "整改", detail = "整改隐患")
    @ApiImplicitParams({
            @ApiImplicitParam(name = "id",value = "id"),
            @ApiImplicitParam(name = "note",value = "整改说明"),
            @ApiImplicitParam(name = "files",value = "文件"),
    })
    public Object hiddenDangerRectify(HiddenDangerVo hiddenDangerVo) {
        HiddenDanger hiddenDanger = hiddenDangerService.hiddenDangerRectify(hiddenDangerVo);
        return success(hiddenDanger);
    }



    @ApiOperation(value = "web/app验收整改")
    @ResponseBody
    @PostMapping("/accept")
    @HiddenDangerLogAnno(operation = "验收", detail = "验收整改")
    @ApiImplicitParam(name = "id",value = "id")
    public Object hiddenDangerAccept(@RequestBody JSONObject jsonObject) {
        Long id = jsonObject.getLong("id");
        HiddenDanger hiddenDanger = hiddenDangerService.acceptHiddenDanger(id, getUser());
        return success(hiddenDanger);
    }



    @ApiOperation(value = "web/app驳回整改")
    @ResponseBody
    @PostMapping("/reject")
    @HiddenDangerLogAnno(operation = "驳回整改", detail = "驳回整改")
    @ApiImplicitParams({
            @ApiImplicitParam(name = "id",value = "id"),
            @ApiImplicitParam(name = "rejectnote",value = "驳回说明"),
    })
    public Object hiddenDangerReject(@RequestBody JSONObject jsonObject) {
        Long id = jsonObject.getLong("id");
        String rejectNote = jsonObject.getString("rejectnote");
        HiddenDanger hiddenDanger = hiddenDangerService.rejectHiddenDanger(id, rejectNote,getUser());
        return success(hiddenDanger);
    }




    /**
    * @Description: app
    */


    @ApiOperation(value = "上传图片",notes = "上传图片")
    @PostMapping("/uploadPic")
    @ResponseBody
    public Msg uploadPic(StandardMultipartHttpServletRequest req){
        Msg msg = new Msg();
        msg.setCode("200");
        msg.setMessage("success");

        MultiValueMap<String, MultipartFile> multipartFiles = req.getMultiFileMap();
        MultipartFile  picFile = multipartFiles.get("files").get(0);
        if (null == picFile){
            msg.setCode("404");
            msg.setMessage("上传文件为空");
        }else {
            try {
                String picmame = UploadUtil.uploadFile(picFile, Properties.hiddenDangerPath);
                msg.setResult(Properties.hiddenDanger+picmame);
            }catch (Exception e){
                e.printStackTrace();
                msg.setCode("500");
                msg.setMessage("上传失败");
            }
        }
        return msg;
    }


    @ApiOperation(value = "app隐患上报")
    @ResponseBody
    @PostMapping("/app/report")
    @HiddenDangerLogAnno(operation = "上报", detail = "上报隐患",source = SourceType.APP)
    @ApiImplicitParams({
            @ApiImplicitParam(name = "level",value = "隐患等级"),
            @ApiImplicitParam(name = "rectifydeadline",value = "整改截止时间(yyyy-MM-dd HH:mm)"),
            @ApiImplicitParam(name = "rectifymeasure",value = "整改措施"),
            @ApiImplicitParam(name = "rectifier",value = "整改人"),
            @ApiImplicitParam(name = "rectifierid",value = "整改人id"),
            @ApiImplicitParam(name = "note",value = "上报说明"),
            @ApiImplicitParam(name = "urls",value = "文件"),
    })
    public Object hiddenDangerAppReport(@RequestBody HiddenDangerAppVo hiddenDangerAppVo) {
        HiddenDanger hiddenDanger = hiddenDangerService.addReportByApp(hiddenDangerAppVo, getUser());
        return success(hiddenDanger);
    }



    @ApiOperation(value = "app隐患整改")
    @ResponseBody
    @PostMapping("/app/rectify")
    @ApiImplicitParams({
            @ApiImplicitParam(name = "id",value = "id"),
            @ApiImplicitParam(name = "note",value = "整改说明"),
            @ApiImplicitParam(name = "files",value = "文件"),
    })
    @HiddenDangerLogAnno(operation = "整改", detail = "整改隐患",source = SourceType.APP)
    public Object hiddenDangerAppRectify(@RequestBody HiddenDangerAppVo hiddenDangerAppVo) {
        HiddenDanger hiddenDanger = hiddenDangerService.rectifyHiddenDangerByApp(hiddenDangerAppVo, getUser());
        return success(hiddenDanger);
    }


    @GetMapping("/statistics")
    @ApiOperation(value = "统计隐患数据",response = Msg.class)
    @ApiImplicitParams({
            @ApiImplicitParam(name = "pageIndex",value = "当前页码"),
            @ApiImplicitParam(name = "pageSize",value = "每页行数"),
            @ApiImplicitParam(name = "sort",value = "排序规则"),
            @ApiImplicitParam(name = "order",value = "排序字段"),
            @ApiImplicitParam(name = "starttime",value = "开始时间"),
            @ApiImplicitParam(name = "endtime",value = "结束时间"),
            @ApiImplicitParam(name = "company",value = "单位"),
    })
    public Msg getStatisticsInfo(@RequestParam(defaultValue = "0") Integer pageIndex, @RequestParam(defaultValue = "10") Integer pageSize, String sort,String order,
                           String company, String starttime,String endtime){

        PageInfo pageInfo = new PageInfo(pageIndex, pageSize,sort,order);
        HashMap<String, Object> condition = new HashMap<>();

        if (StringUtils.isNotBlank(company)) {
            condition.put("company", company.trim());
        }

        if (StringUtils.isNotBlank(starttime)) {
            condition.put("starttime", starttime.trim());
        }

        if (StringUtils.isNotBlank(endtime)) {
            condition.put("endtime", endtime.trim());
        }

        UserInfo userInfo = userService.selectByUser(getUser().getUsername());

        if (!companyService.isMain(userInfo.getCompany())){
            condition.put("company", userInfo.getCompany());
        }

        pageInfo.setCondition(condition);
        hiddenDangerService.selectStatisticsData(pageInfo);
        return success(pageInfo);
    }

    @GetMapping("/info")
    @ApiOperation(value = "隐患数据详情",response = Msg.class)
    public Msg getHiddenDangerData(@RequestParam(defaultValue = "0") Integer pageIndex, @RequestParam(defaultValue = "10") Integer pageSize, String sort,String order,
                                   String company, String starttime,String endtime){

        PageInfo pageInfo = new PageInfo(pageIndex, pageSize,sort,order);
        HashMap<String, Object> condition = new HashMap<>();

        if (StringUtils.isNotBlank(company)) {
            condition.put("company", company.trim());
        }

        if (StringUtils.isNotBlank(starttime)) {
            condition.put("starttime", starttime.trim());
        }

        if (StringUtils.isNotBlank(endtime)) {
            condition.put("endtime", endtime.trim());
        }

        UserInfo userInfo = userService.selectByUser(getUser().getUsername());

        if (!companyService.isMain(userInfo.getCompany())){
            condition.put("company", userInfo.getCompany());
        }

        pageInfo.setCondition(condition);
        hiddenDangerService.selectDataGrid(pageInfo);
        return success(pageInfo);
    }


    @GetMapping("/app/analysis")
    public Msg getAnalysis() {
        Map result = hiddenDangerService.getAppAnalysis(getUser());
        return success(result);
    }
}