package com.gk.hotwork.Controller;

import com.alibaba.fastjson.JSONObject;
import com.gk.hotwork.Controller.Base.BaseController;
import com.gk.hotwork.Domain.Enum.ErrorCode;
import com.gk.hotwork.Domain.EquipmentInfo;
import com.gk.hotwork.Domain.GasWarnInfo;
import com.gk.hotwork.Domain.Utils.Msg;
import com.gk.hotwork.Domain.Utils.PageInfo;
import com.gk.hotwork.Domain.Utils.StringUtils;
import com.gk.hotwork.Service.EquipmentService;
import com.gk.hotwork.Service.GasWarnService;
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.web.bind.annotation.*;

import java.util.Date;
import java.util.HashMap;

@Api(tags = "设备数据接口")
@RestController
public class EquipmentController extends BaseController {
    @Autowired
    EquipmentService equipmentService;
    @Autowired
    GasWarnService gasWarnService;

    @GetMapping("/gasWarn")
    @ApiOperation(value = "获取气体阈值信息",response = Msg.class)
    @ApiImplicitParams({
            @ApiImplicitParam(name = "pageIndex",value = "当前页码"),
            @ApiImplicitParam(name = "pageSize",value = "每页行数"),
            @ApiImplicitParam(name = "sort",value = "排序规则"),
            @ApiImplicitParam(name = "order",value = "排序字段"),
            @ApiImplicitParam(name = "gastype",value = "气体类型"),
            @ApiImplicitParam(name = "warntype",value = "报警类型")
    })
    public Msg getGasWarn(@RequestParam(defaultValue = "0") Integer pageIndex, @RequestParam(defaultValue = "10") Integer pageSize, String sort, String order,
                                 String gastype, String warntype){
        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(gastype)) {
            condition.put("gastype", gastype.trim());
        }

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

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

    @PostMapping("/addGasWarn")
    @ApiOperation(value = "添加气体阈值信息",response = Msg.class)
    @ApiImplicitParams({
            @ApiImplicitParam(name = "gastype",value = "气体类型"),
            @ApiImplicitParam(name = "warntype",value = "报警类型"),
            @ApiImplicitParam(name = "max",value = "最大值"),
            @ApiImplicitParam(name = "min",value = "最小值"),
            @ApiImplicitParam(name = "gasunit",value = "气体单位"),
    })
    public Msg addGasWarn(@RequestBody GasWarnInfo gasWarnInfo){
        Msg msg = new Msg();
        msg.setCode("200");
        msg.setMessage("success");
        if (StringUtils.isBlank(gasWarnInfo.getGastype())||StringUtils.isBlank(gasWarnInfo.getWarntype())){
            msg.setCode(ErrorCode.ERROR_10004.getCode());
            msg.setMessage("气体类型、报警类型不能为空");
            return msg;
        }
        GasWarnInfo gasWarnInfoExist = gasWarnService.selectExistByType(null,gasWarnInfo.getWarntype(),gasWarnInfo.getGastype());
        if (gasWarnInfoExist != null){
            msg.setCode(ErrorCode.ERROR_10004.getCode());
            msg.setMessage("存在相同气体类型、报警类型的配置");
            return msg;
        }
        gasWarnInfo.setUpdateby(getUser().getRealname());
        gasWarnInfo.setUpdatetime(new Date());
        gasWarnService.save(gasWarnInfo);
        return msg;
    }

    @PostMapping("/putGasWarn")
    @ApiOperation(value = "修改气体阈值信息",response = Msg.class)
    @ApiImplicitParams({
            @ApiImplicitParam(name = "gastype",value = "气体类型"),
            @ApiImplicitParam(name = "warntype",value = "报警类型"),
            @ApiImplicitParam(name = "max",value = "最大值"),
            @ApiImplicitParam(name = "min",value = "最小值"),
            @ApiImplicitParam(name = "gasunit",value = "气体单位"),
    })
    public Msg putGasWarn(@RequestBody GasWarnInfo gasWarnInfo){
        Msg msg = new Msg();
        msg.setCode("200");
        msg.setMessage("success");
        if (StringUtils.isBlank(gasWarnInfo.getGastype())||StringUtils.isBlank(gasWarnInfo.getWarntype())){
            msg.setCode(ErrorCode.ERROR_10004.getCode());
            msg.setMessage("气体类型、报警类型不能为空");
            return msg;
        }
        GasWarnInfo gasWarnInfoExist = gasWarnService.selectExistByType(gasWarnInfo.getId(),gasWarnInfo.getWarntype(),gasWarnInfo.getGastype());
        if (gasWarnInfoExist != null){
            msg.setCode(ErrorCode.ERROR_10004.getCode());
            msg.setMessage("存在相同气体类型、报警类型的配置");
            return msg;
        }
        gasWarnInfo.setUpdateby(getUser().getRealname());
        gasWarnInfo.setUpdatetime(new Date());
        gasWarnService.updateById(gasWarnInfo);
        return msg;
    }

    @PostMapping("/delGasWarn")
    @ApiOperation(value = "删除气体阈值信息",response = Msg.class)
    @ApiImplicitParams({
            @ApiImplicitParam(name = "id",value = "id"),
    })
    public Msg delGasWarn(@RequestBody JSONObject jsonObject){
        Msg msg = new Msg();
        msg.setCode("200");
        msg.setMessage("success");
        Long id = jsonObject.getLong("id");

        if (id == null){
            msg.setCode(ErrorCode.ERROR_10004.getCode());
            msg.setMessage("id不能为空");
            return msg;
        }
        gasWarnService.removeById(id);
        return msg;
    }

    @GetMapping("/equipment")
    @ApiOperation(value = "获取设备信息",response = Msg.class)
    @ApiImplicitParams({
            @ApiImplicitParam(name = "pageIndex",value = "当前页码"),
            @ApiImplicitParam(name = "pageSize",value = "每页行数"),
            @ApiImplicitParam(name = "sort",value = "排序规则"),
            @ApiImplicitParam(name = "order",value = "排序字段"),
            @ApiImplicitParam(name = "name",value = "设备名称"),
            @ApiImplicitParam(name = "number",value = "设备条码")
    })
    public Msg equipmentService(@RequestParam(defaultValue = "0") Integer pageIndex, @RequestParam(defaultValue = "10") Integer pageSize, String sort, String order,
                                 String name, String number){
        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(name)) {
            condition.put("name", name.trim());
        }

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

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

    @PostMapping("/addEquipment")
    @ApiOperation(value = "添加设备信息",response = Msg.class)
    @ApiImplicitParams({
            @ApiImplicitParam(name = "name",value = "设备名称"),
            @ApiImplicitParam(name = "number",value = "设备条码"),
            @ApiImplicitParam(name = "isphoto",value = "是否有摄像头 1是 0否"),
            @ApiImplicitParam(name = "photoname",value = "摄像头名称"),
            @ApiImplicitParam(name = "photoaddress",value = "摄像头地址"),
    })
    public Msg addEquipment(@RequestBody EquipmentInfo equipmentInfo){
        Msg msg = new Msg();
        msg.setCode("200");
        msg.setMessage("success");
        if (StringUtils.isBlank(equipmentInfo.getName())||StringUtils.isBlank(equipmentInfo.getNumber())){
            msg.setCode(ErrorCode.ERROR_10004.getCode());
            msg.setMessage("设备名称、设备条码不能为空");
            return msg;
        }
        EquipmentInfo equipmentInfoExist = equipmentService.selectExistByNumber(null,equipmentInfo.getNumber());
        if (equipmentInfoExist != null){
            msg.setCode(ErrorCode.ERROR_10004.getCode());
            msg.setMessage("存在相同设备条码");
            return msg;
        }
        if (equipmentInfo.getIsphoto() == 1 && (StringUtils.isBlank(equipmentInfo.getPhotoname())
        || StringUtils.isBlank(equipmentInfo.getPhotoaddress()))){
            msg.setCode(ErrorCode.ERROR_10004.getCode());
            msg.setMessage("摄像头名称、地址不能为空");
            return msg;
        }
        equipmentInfo.setUpdateby(getUser().getRealname());
        equipmentInfo.setUpdatetime(new Date());
        equipmentService.save(equipmentInfo);
        return msg;
    }

    @PostMapping("/putEquipment")
    @ApiOperation(value = "修改设备信息",response = Msg.class)
    @ApiImplicitParams({
            @ApiImplicitParam(name = "id",value = "id"),
            @ApiImplicitParam(name = "name",value = "设备名称"),
            @ApiImplicitParam(name = "number",value = "设备条码"),
            @ApiImplicitParam(name = "isphoto",value = "是否有摄像头 1是 0否"),
            @ApiImplicitParam(name = "photoname",value = "摄像头名称"),
            @ApiImplicitParam(name = "photoaddress",value = "摄像头地址"),
    })
    public Msg putEquipment(@RequestBody EquipmentInfo equipmentInfo){
        Msg msg = new Msg();
        msg.setCode("200");
        msg.setMessage("success");
        if (StringUtils.isBlank(equipmentInfo.getName())||StringUtils.isBlank(equipmentInfo.getNumber())){
            msg.setCode(ErrorCode.ERROR_10004.getCode());
            msg.setMessage("设备名称、设备条码不能为空");
            return msg;
        }
        EquipmentInfo equipmentInfoExist = equipmentService.selectExistByNumber(equipmentInfo.getId(),equipmentInfo.getNumber());
        if (equipmentInfoExist != null){
            msg.setCode(ErrorCode.ERROR_10004.getCode());
            msg.setMessage("存在相同设备条码");
            return msg;
        }
        if (equipmentInfo.getIsphoto() == 1 && (StringUtils.isBlank(equipmentInfo.getPhotoname())
                || StringUtils.isBlank(equipmentInfo.getPhotoaddress()))){
            msg.setCode(ErrorCode.ERROR_10004.getCode());
            msg.setMessage("摄像头名称、地址不能为空");
            return msg;
        }
        equipmentInfo.setUpdateby(getUser().getRealname());
        equipmentInfo.setUpdatetime(new Date());
        equipmentService.updateById(equipmentInfo);
        return msg;
    }

    @PostMapping("/delEquipment")
    @ApiOperation(value = "删除设备信息",response = Msg.class)
    @ApiImplicitParams({
            @ApiImplicitParam(name = "id",value = "id"),
    })
    public Msg delEquipment(@RequestBody JSONObject jsonObject){
        Msg msg = new Msg();
        msg.setCode("200");
        msg.setMessage("success");
        Long id = jsonObject.getLong("id");

        if (id == null){
            msg.setCode(ErrorCode.ERROR_10004.getCode());
            msg.setMessage("id不能为空");
            return msg;
        }
        equipmentService.removeById(id);
        return msg;
    }

}