package com.skyline.electricity.controller;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import org.springframework.stereotype.*;
import org.springframework.beans.factory.annotation.*;
import com.skyline.electricity.service.*;
import com.skyline.electricity.entity.*;
import com.skyline.electricity.utils.*;
import org.springframework.web.client.*;
import org.springframework.http.client.*;
import java.nio.charset.*;
import org.springframework.http.converter.*;
import cn.hutool.json.*;
import org.springframework.util.*;
import org.springframework.http.*;
import io.swagger.annotations.*;
import org.springframework.web.bind.annotation.*;
import com.alibaba.fastjson.*;
import com.skyline.electricity.pojo.*;
import java.util.*;
import org.slf4j.*;

@Controller
@RequestMapping({ "/device" })
@Api("基于Swagger的电力区域报警系统")
@CrossOrigin
public class DeviceController
{
    private static Logger log;
    @Autowired
    private DetectService detectService;
    @Autowired
    OutService outService;
    @Autowired
    private ConfigInfo configInfo;

    @RequestMapping(value = { "/getCameraEntity" }, method = { RequestMethod.POST })
    @ApiOperation("获取摄像头实体列表")
    @ResponseBody
    public Object getCameraEntity(final String modId, final String modKey, final Integer pageNum, final Integer pageSize) {
        final RestTemplate restTemplate = new RestTemplate((ClientHttpRequestFactory)new HttpsClientRequestFactory());
        restTemplate.getMessageConverters().set(1, new StringHttpMessageConverter(StandardCharsets.UTF_8));
        final Map<Object, Object> params = new HashMap<Object, Object>();
        final HttpHeaders headers = new HttpHeaders();
        headers.setContentType(MediaType.APPLICATION_JSON);
        params.put("modId", modId);
        params.put("modKey", modKey);
        params.put("pageNum", pageNum);
        params.put("pageSize", pageSize);
        final cn.hutool.json.JSONObject jsonObject = JSONUtil.parseFromMap((Map)params);
        final HttpEntity<cn.hutool.json.JSONObject> httpEntity = (HttpEntity<cn.hutool.json.JSONObject>)new HttpEntity((Object)jsonObject, (MultiValueMap)headers);
        final ResponseEntity<String> responseEntity = (ResponseEntity<String>)restTemplate.postForEntity(this.configInfo.getDevice_ip()+   "/restapi/iot/iotinfomgr/entityList?apikey="  + this.configInfo.getApikey(), (Object)httpEntity, (Class)String.class, new Object[0]);
        final String body = (String)responseEntity.getBody();
        final JSONObject jsonObjectResult = JSONObject.parseObject(body);
        return jsonObjectResult.get((Object)"data");
    }

    @RequestMapping(value = { "/getCloudplatformInfo" }, method = { RequestMethod.POST })
    @ApiOperation("获取摄像头云台操作信息")
    @ResponseBody
    public Object getCloudplatformInfo(final String modId, final String modKey, final String cameraIndex, final Integer action, final String command, final String speed) {
        final RestTemplate restTemplate = new RestTemplate((ClientHttpRequestFactory)new HttpsClientRequestFactory());
        restTemplate.getMessageConverters().set(1, new StringHttpMessageConverter(StandardCharsets.UTF_8));
        final Map<Object, Object> params = new HashMap<Object, Object>();
        final HttpHeaders headers = new HttpHeaders();
        headers.setContentType(MediaType.APPLICATION_JSON);
        params.put("modId", modId);
        params.put("modKey", modKey);
        params.put("cameraIndex", cameraIndex);
        params.put("action", action);
        params.put("command", command);
        params.put("speed", speed);
        final cn.hutool.json.JSONObject jsonObject = JSONUtil.parseFromMap((Map)params);
        final HttpEntity<cn.hutool.json.JSONObject> httpEntity = (HttpEntity<cn.hutool.json.JSONObject>)new HttpEntity((Object)jsonObject, (MultiValueMap)headers);
        final ResponseEntity<String> responseEntity = (ResponseEntity<String>)restTemplate.postForEntity(this.configInfo.getDevice_ip()+   "/restapi/iot/iotinfomgr/service/invoke/cameras/ptzControl?apikey="  + this.configInfo.getApikey(), (Object)httpEntity, (Class)String.class, new Object[0]);
        return responseEntity.getBody();
    }

    @RequestMapping(value = { "/getPreviewUrls" }, method = { RequestMethod.POST })
    @ApiOperation("获取摄像头获取预览流url")
    @ResponseBody
    public Object getPreviewUrls(final String modId, final String modKey, final String cameraIndex, final Integer streamType, final Integer transmode, final String protocol, final String expand) {
        final RestTemplate restTemplate = new RestTemplate((ClientHttpRequestFactory)new HttpsClientRequestFactory());
        restTemplate.getMessageConverters().set(1, new StringHttpMessageConverter(StandardCharsets.UTF_8));
        final Map<Object, Object> params = new HashMap<Object, Object>();
        final HttpHeaders headers = new HttpHeaders();
        headers.setContentType(MediaType.APPLICATION_JSON);
        params.put("modId", modId);
        params.put("modKey", modKey);
        params.put("cameraIndex", cameraIndex);
        params.put("transmode", transmode);
        params.put("streamType", streamType);
        params.put("protocol", protocol);
        if (expand != null) {
            params.put("expand", expand);
        }
        final cn.hutool.json.JSONObject jsonObject = JSONUtil.parseFromMap((Map)params);
        final HttpEntity<cn.hutool.json.JSONObject> httpEntity = (HttpEntity<cn.hutool.json.JSONObject>)new HttpEntity((Object)jsonObject, (MultiValueMap)headers);
        final ResponseEntity<String> responseEntity = (ResponseEntity<String>)restTemplate.postForEntity(this.configInfo.getDevice_ip() +  "/restapi/iot/iotinfomgr/service/invoke/cameras/previewURLs?apikey=" +  this.configInfo.getApikey(), (Object)httpEntity, (Class)String.class, new Object[0]);
        final JSON json = (JSON)JSON.parse((String)responseEntity.getBody());

        return json;
    }

    @RequestMapping(value = { "/getDoorAccessEntity" }, method = { RequestMethod.POST })
    @ApiOperation("获取门禁实体列表")
    @ResponseBody
    public Object getDoorAccessEntity(final String modId, final String modKey, final Integer pageNum, final Integer pageSize) {
        final RestTemplate restTemplate = new RestTemplate((ClientHttpRequestFactory)new HttpsClientRequestFactory());
        restTemplate.getMessageConverters().set(1, new StringHttpMessageConverter(StandardCharsets.UTF_8));
        final Map<Object, Object> params = new HashMap<Object, Object>();
        final HttpHeaders headers = new HttpHeaders();
        headers.setContentType(MediaType.APPLICATION_JSON);
        params.put("modId", modId);
        params.put("modKey", modKey);
        params.put("pageNum", pageNum);
        params.put("pageSize", pageSize);
        final cn.hutool.json.JSONObject jsonObject = JSONUtil.parseFromMap((Map)params);
        final HttpEntity<cn.hutool.json.JSONObject> httpEntity = (HttpEntity<cn.hutool.json.JSONObject>)new HttpEntity((Object)jsonObject, (MultiValueMap)headers);
        final ResponseEntity<String> responseEntity = (ResponseEntity<String>)restTemplate.postForEntity(this.configInfo.getDevice_ip()+   "/restapi/iot/iotinfomgr/entityList?apikey=" +  this.configInfo.getApikey(), (Object)httpEntity, (Class)String.class, new Object[0]);
        final String body = (String)responseEntity.getBody();
        final JSONObject jsonObjectResult = JSONObject.parseObject(body);
        return jsonObjectResult.get((Object)"data");
    }

    @RequestMapping(value = { "/getPlaybackURLs" }, method = { RequestMethod.POST })
    @ApiOperation("摄像头获取回放流url")
    @ResponseBody
    public Object getPlaybackURLs(final String modId, final String modKey, final String expand, final String cameraIndex, final String protocol, final String beginTime, final String endTime) {
        final RestTemplate restTemplate = new RestTemplate((ClientHttpRequestFactory)new HttpsClientRequestFactory());
        restTemplate.getMessageConverters().set(1, new StringHttpMessageConverter(StandardCharsets.UTF_8));
        final Map<Object, Object> params = new HashMap<Object, Object>();
        final HttpHeaders headers = new HttpHeaders();
        headers.setContentType(MediaType.APPLICATION_JSON);
        params.put("modId", modId);
        params.put("modKey", modKey);
        params.put("expand", expand);
        params.put("cameraIndex", cameraIndex);
        params.put("beginTime", beginTime);
        params.put("endTime", endTime);
        params.put("protocol", protocol);
        final cn.hutool.json.JSONObject jsonObject = JSONUtil.parseFromMap((Map)params);
        final HttpEntity<cn.hutool.json.JSONObject> httpEntity = (HttpEntity<cn.hutool.json.JSONObject>)new HttpEntity((Object)jsonObject, (MultiValueMap)headers);
        final ResponseEntity<String> responseEntity = (ResponseEntity<String>)restTemplate.postForEntity(this.configInfo.getDevice_ip()+   "/restapi/iot/iotinfomgr/service/invoke/cameras/playbackURLs?apikey="  + this.configInfo.getApikey(), (Object)httpEntity, (Class)String.class, new Object[0]);
        final JSON json = (JSON)JSON.parse((String)responseEntity.getBody());
        return json;
    }

    @RequestMapping(value = { "/getHistoryDoorAccess" }, method = { RequestMethod.POST })
    @ApiOperation("获取历史门禁信息")
    @ResponseBody
    public Object getHistoryDoorAccess(final String modId, final String modKey, final Integer pageNo, final Integer pageSize, final String doorIndex, final String startTime, final String endTime) {
        final RestTemplate restTemplate = new RestTemplate((ClientHttpRequestFactory)new HttpsClientRequestFactory());
        restTemplate.getMessageConverters().set(1, new StringHttpMessageConverter(StandardCharsets.UTF_8));
        final Map<Object, Object> params = new HashMap<Object, Object>();
        final HttpHeaders headers = new HttpHeaders();
        headers.setContentType(MediaType.APPLICATION_JSON);
        params.put("modId", modId);
        params.put("modKey", modKey);
        params.put("pageNo", pageNo);
        params.put("pageSize", pageSize);
        params.put("startTime", startTime);
        params.put("endTime", endTime);
        params.put("doorIndex", doorIndex);
        final cn.hutool.json.JSONObject jsonObject = JSONUtil.parseFromMap((Map)params);
        final HttpEntity<cn.hutool.json.JSONObject> httpEntity = (HttpEntity<cn.hutool.json.JSONObject>)new HttpEntity((Object)jsonObject, (MultiValueMap)headers);
        final ResponseEntity<String> responseEntity = (ResponseEntity<String>)restTemplate.postForEntity(this.configInfo.getDevice_ip()  + "/restapi/iot/iotinfomgr/service/invoke/door/events?apikey="  + this.configInfo.getApikey(), (Object)httpEntity, (Class)String.class, new Object[0]);
        final JSON json = (JSON)JSON.parse((String)responseEntity.getBody());
        return json;
    }

    @RequestMapping(value = { "/getEquipmentInfo" }, method = { RequestMethod.POST })
    @ApiOperation("设备信息获取")
    @ResponseBody
    public Object getEquipmentInfo(final String id) {
        final RestTemplate restTemplate = new RestTemplate();
        restTemplate.getMessageConverters().set(1, new StringHttpMessageConverter(StandardCharsets.UTF_8));
        final Map<String, Object> map = new HashMap<String, Object>();
        map.put("id", id);
        final ResponseEntity<String> responseEntity = (ResponseEntity<String>)restTemplate.getForEntity(this.configInfo.getSafeSystem_ip() +  "/a/in/inGetByKks/equipLogicData?id={id}", (Class)String.class, (Map)map);
        final JSON json = (JSON)JSON.parse((String)responseEntity.getBody());
        return json;
    }

    @RequestMapping(value = { "/getReconditionInfo" }, method = { RequestMethod.POST })
    @ApiOperation("获取设备的检修历史")
    @ResponseBody
    public Object getReconditionInfo(final String id) {
        final RestTemplate restTemplate = new RestTemplate();
        restTemplate.getMessageConverters().set(1, new StringHttpMessageConverter(StandardCharsets.UTF_8));
        final Map<String, String> map = new HashMap<String, String>();
        map.put("id", id);
        final ResponseEntity<String> responseEntity = (ResponseEntity<String>)restTemplate.getForEntity(this.configInfo.getSafeSystem_ip() +  "/a/in/inGetByKks/equipPiData?id={id}", (Class)String.class, (Map)map);
        final JSON json = (JSON)JSON.parse((String)responseEntity.getBody());
        return json;
    }

    @RequestMapping(value = { "/getDeviceKKSInfo" }, method = { RequestMethod.POST })
    @ApiOperation("获取设备的KKS信息")
    @ResponseBody
    public Object getDeviceKKSInfo() {
        final List<String> deviceIdList = (List<String>)this.detectService.getDeviceId();
        final Map<Object, Object> map = new HashMap<Object, Object>();
        final List<DeviceKKSDto> deviceList = new ArrayList<DeviceKKSDto>();
        for (final String device_id : deviceIdList) {
            final List<DeviceKKS> list = (List<DeviceKKS>)this.detectService.getDeviceKKSInfo(device_id);
            final DeviceKKSDto dto = new DeviceKKSDto();
            final List<KKSInfo> kksInfo = new ArrayList<KKSInfo>();
            for (int i = 0; i < list.size();   ++i) {
                final KKSInfo kks = new KKSInfo();
                dto.setDevice_id(list.get(0).getDevice_id());
                dto.setDevice_name(list.get(0).getDevice_name());
                dto.setAccount(list.get(0).getAccount());
                kks.setCode(list.get(i).getCode());
                kks.setTest_point(list.get(i).getTest_point());
                kks.setKkstype(list.get(i).getKkstype());
                kksInfo.add(kks);
            }
            dto.setMsg((List)kksInfo);
            deviceList.add(dto);
        }
        map.put("list", deviceList);
        return map;
    }

    @RequestMapping(value = { "/getDuty" }, method = { RequestMethod.POST })
    @ApiOperation("获取当值值长")
    @ResponseBody
    public Object getDuty() {
        final RestTemplate template = new RestTemplate();
        template.getMessageConverters().add(new StringHttpMessageConverter(StandardCharsets.UTF_8));
        final Map<String, Object> map = new HashMap<String, Object>();
        final String dzzzresponse = (String)template.getForObject(this.configInfo.getDzzzUrl(), (Class)String.class, new Object[0]);
        final JSONObject json = JSONObject.parseObject(dzzzresponse);
        //System.out.println(json.getJSONObject("data").getString("id"));
        DeviceController.log.warn(dzzzresponse.toString());
        return dzzzresponse;
    }

    @RequestMapping(value = { "/getOutPeople" }, method = { RequestMethod.GET })
    @ApiOperation("获取外包人员")
    @ResponseBody
    public Object getOutPeople(final String id) {
        final List<Map> list = (List<Map>)this.outService.selectExternPeople(id);
        DeviceController.log.warn(list.toString());
        return list;
    }

    static {
        DeviceController.log = LoggerFactory.getLogger((Class)DeviceController.class);
    }
}