package com.gk.hotwork.Controller;

import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.gk.hotwork.Controller.Base.BaseController;
import com.gk.hotwork.Domain.*;
import com.gk.hotwork.Domain.Utils.*;
import com.gk.hotwork.Domain.Vo.SelfCheckVo;
import com.gk.hotwork.Service.*;
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.beans.factory.annotation.Value;
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.io.File;
import java.io.FileInputStream;
import java.io.InputStream;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.List;


@Api(tags = "巡检接口")
@RestController
public class PatrolController extends BaseController{
    @Value("${patrolPath}")
    private String patrolPath; //配置文件配置的物理保存地址
    @Value("${patrolUrl}")
    private String patrolUrl; //配置文件配置的url

    @Autowired
    SelfCheckService selfCheckService;
    @Autowired
    UserService userService;
    @Autowired
    ExcelExportService excelExportService;

    @GetMapping("/getSelfCheck")
    @ApiOperation(value = "根据类型获取检查内容",response = Msg.class)
    public Msg getSelfCheck(SelfCheckInfo selfCheck){
        Msg msg = new Msg();
        msg.setCode("200");
        msg.setMessage("success");

        List<SelfCheckVo> selfChecks = selfCheckService.selectByType(selfCheck.getType());
        if (selfChecks.size() > 0) {
            msg.setResult(selfChecks);
            return msg;
        }else {
            msg.setCode("999");
            msg.setMessage("未找到该检查内容");
            return msg;
        }
    }

    @ApiOperation(value = "上传图片",notes = "上传图片")
    @ApiImplicitParams({
            @ApiImplicitParam(paramType="query",name = "files",value = "文件"),
    })
    @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,patrolPath);
                msg.setResult(patrolUrl+picmame);
            }catch (Exception e){
                e.printStackTrace();
                msg.setCode("500");
                msg.setMessage("上传失败");
            }
        }
        return msg;
    }

    @GetMapping("/selfCheck")
    @ApiOperation(value = "获取自定义检查内容",response = Msg.class)
    @ApiImplicitParams({
            @ApiImplicitParam(name = "pageIndex",value = "当前页码"),
            @ApiImplicitParam(name = "pageSize",value = "每页行数"),
            @ApiImplicitParam(name = "sort",value = "排序规则"),
            @ApiImplicitParam(name = "order",value = "排序字段"),
            @ApiImplicitParam(name = "type",value = "检查类型"),
            @ApiImplicitParam(name = "tasktype",value = "作业类型"),
            @ApiImplicitParam(name = "content",value = "检查内容"),
    })
    public Msg getSelfCheckList(@RequestParam(defaultValue = "0") Integer pageIndex, @RequestParam(defaultValue = "10") Integer pageSize, String sort, String order,
                            String tasktype, String type,String content){
        Msg msg = new Msg();
        msg.setCode("200");
        msg.setMessage("success");

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

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

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

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

        pageInfo.setCondition(condition);
        selfCheckService.selectDataGrid(pageInfo);
        msg.setResult(pageInfo);
        return msg;
    }

    @PostMapping("/addselfCheck")
    @ApiOperation(value = "添加自定义检查内容",response = Msg.class)
    public Msg addSelfCheckList(@RequestBody SelfCheckInfo selfCheckInfo){
        Msg msg = new Msg();
        msg.setCode("200");
        msg.setMessage("success");

        if (StringUtils.isBlank(selfCheckInfo.getTasktype())){
            msg.setCode("999");
            msg.setMessage("作业类型不能为空");
            return msg;
        }else if (StringUtils.isBlank(selfCheckInfo.getType())){
            msg.setCode("999");
            msg.setMessage("检查类型不能为空");
            return msg;
        }else if (StringUtils.isBlank(selfCheckInfo.getContent())){
            msg.setCode("999");
            msg.setMessage("检查内容不能为空");
            return msg;
        }else if (StringUtils.isBlank(selfCheckInfo.getStandard())){
            msg.setCode("999");
            msg.setMessage("参考判断不能为空");
            return msg;
        }
        selfCheckInfo.setCreatedby(getUser().getRealname());
        selfCheckInfo.setModifiedby(getUser().getRealname());
        selfCheckInfo.setCreateddate(new Date());
        selfCheckInfo.setModifieddate(new Date());
        selfCheckInfo.setIsdel((byte)0);
        selfCheckService.save(selfCheckInfo);
        return msg;
    }

    @PostMapping("/putselfCheck")
    @ApiOperation(value = "修改自定义检查内容",response = Msg.class)
    public Msg editSelfCheckList(@RequestBody SelfCheckInfo selfCheckInfo){
        Msg msg = new Msg();
        msg.setCode("200");
        msg.setMessage("success");

        if (StringUtils.isBlank(selfCheckInfo.getTasktype())){
            msg.setCode("999");
            msg.setMessage("作业类型不能为空");
            return msg;
        }else if (StringUtils.isBlank(selfCheckInfo.getType())){
            msg.setCode("999");
            msg.setMessage("检查类型不能为空");
            return msg;
        }else if (StringUtils.isBlank(selfCheckInfo.getContent())){
            msg.setCode("999");
            msg.setMessage("检查内容不能为空");
            return msg;
        }else if (StringUtils.isBlank(selfCheckInfo.getStandard())){
            msg.setCode("999");
            msg.setMessage("参考判断不能为空");
            return msg;
        }
        selfCheckInfo.setModifiedby(getUser().getRealname());
        selfCheckInfo.setModifieddate(new Date());
        selfCheckService.updateById(selfCheckInfo);
        return msg;
    }

    @PostMapping("/delselfCheck")
    @ApiOperation(value = "删除自定义检查内容",response = Msg.class)
    public Msg delSelfCheckList(@RequestBody JSONObject jsonObject){
        Msg msg = new Msg();
        msg.setCode("200");
        msg.setMessage("success");
        Long id = jsonObject.getLong("id");
        SelfCheckInfo selfCheckInfo = selfCheckService.getById(id);
        if (selfCheckInfo != null){
            selfCheckInfo.setIsdel((byte)1);
            selfCheckInfo.setModifiedby(getUser().getRealname());
            selfCheckInfo.setModifieddate(new Date());
            selfCheckService.updateById(selfCheckInfo);
            return msg;
        }else {
            msg.setCode("999");
            msg.setMessage("未找到检查内容");
            return msg;
        }
    }

    @PostMapping("/selfChecks")
    @ApiOperation(value = "删除自定义检查内容",response = Msg.class)
    public Msg bashDelSelfCheckList(@RequestBody JSONObject jsonObject){
        Msg msg = new Msg();
        msg.setCode("200");
        msg.setMessage("success");
        JSONArray ids = jsonObject.getJSONArray("ids");
        List<Long> idList = ids.toJavaList(Long.class);
        List<SelfCheckInfo> selfCheckInfoList = selfCheckService.selectByIds(idList);
        if (selfCheckInfoList != null && selfCheckInfoList.size() > 0){
            for (SelfCheckInfo selfCheckInfo : selfCheckInfoList) {
                selfCheckInfo.setIsdel((byte)1);
                selfCheckInfo.setModifiedby(getUser().getRealname());
                selfCheckInfo.setModifieddate(new Date());
                selfCheckService.updateById(selfCheckInfo);
            }
            return msg;
        }else {
            msg.setCode("999");
            msg.setMessage("未找到检查内容");
            return msg;
        }
    }

    @PostMapping("/importSelfCheck")
    @ApiOperation(value = "导入自定义检查内容",response = Msg.class)
    @ApiImplicitParams({
            @ApiImplicitParam(name = "file",value = "文件",required = true),
    })
    public Msg addSelfCheckList(MultipartFile file){
        Msg msg = new Msg();
        msg.setCode("200");
        msg.setMessage("success");

        String filesave ="";
        try {
            SimpleDateFormat sdf = new SimpleDateFormat( "yyyyMMddHHmmssSSS" );
            if (file == null)
            {
                msg.setCode("404");
                msg.setMessage("未找到上传文件");
                return msg;
            }

            long size = file.getSize();
            if(0 == size)
            {
                msg.setCode("404");
                msg.setMessage("上传文件大小为空");
                return msg;
            }

            if(!FileOptUtils.isDirExists(patrolPath)){
                msg.setCode("500");
                msg.setMessage("发生错误或不为目录");
                return msg;
            }

            filesave = patrolPath + getUser().getRealname() + "_" + sdf.format(new Date()) +".xlsx";

            file.transferTo(new File(filesave));
            InputStream in = new FileInputStream(filesave);
            String name = file.getOriginalFilename();
            Boolean isExcel2007 = name.substring(name.lastIndexOf(".") + 1).endsWith("xlsx")? true:false;
            BooleanReason blret = excelExportService.imporSelfCheckExcel(in,getUser().getRealname(),isExcel2007);
            if(blret.getValue().equals(false))
            {
                msg.setCode("500");
                msg.setMessage(blret.getResultmsg());
                return msg;
            }
        } catch (Exception e) {
            e.printStackTrace();
            msg.setCode("500");
            msg.setMessage("导入发生错误");
            return msg;
        }

        return msg;
    }

}