package com.ruoyi.web.controller.manage;

import com.alibaba.fastjson2.JSONArray;
import com.alibaba.fastjson2.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.ruoyi.common.core.controller.BaseController;
import com.ruoyi.common.core.domain.AjaxResult;
import com.ruoyi.common.core.page.TableDataInfo;
import com.ruoyi.fuzhou.domain.CameraPTZ;
import com.ruoyi.fuzhou.domain.DpEquipment;
import com.ruoyi.fuzhou.domain.HikEvent;
import com.ruoyi.fuzhou.domain.HikEventObj;
import com.ruoyi.fuzhou.service.EquipmentService;
import com.ruoyi.fuzhou.service.HikService;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;

import java.time.OffsetDateTime;
import java.util.Date;

@RestController
@RequestMapping("/dp/hik")
@Tag(name = "大屏--海康视频")
public class HikController extends BaseController {
    @Autowired
    private HikService hikService;
    @Autowired
    private EquipmentService dpEquipmentService;

    @GetMapping("/getCameraPreviewURL/{cameraName}")
    @Operation(summary = "根据name查询视频播放URL")
    public AjaxResult getCameraPreviewURL(@PathVariable("cameraName") String cameraName) throws Exception {
        return AjaxResult.success(hikService.getCameraPreviewURL(cameraName));
    }

    @GetMapping("/getCameraURL/{cameraIndexCode}")
    @Operation(summary = "根据indexcode查询视频播放URL")
    public AjaxResult getCameraURL(@PathVariable("cameraIndexCode") String cameraIndexCode) throws Exception {
        return AjaxResult.success(hikService.getCameraURL(cameraIndexCode));
    }

    @GetMapping("/getCameraOnline/{indexCodes}")
    @Operation(summary = "根据indexCodes数组查询监控状态")
    public AjaxResult getCameraOnline(@PathVariable("indexCodes") String[] indexCodes) throws Exception {
        return AjaxResult.success(hikService.getCameraOnline(indexCodes));
    }

    @Operation(summary = "云台操作")
    @PostMapping("/cameraCommand")
    public AjaxResult cameraCommand(@RequestBody CameraPTZ cameraPTZ) throws Exception{
        return AjaxResult.success(hikService.cameraCommand(cameraPTZ));
    }

    @Operation(summary = "根据事件类型订阅事件")
    @PostMapping("/subByEventTypes")
    public JSONObject subByEventTypes(@RequestBody HikEventObj hikEventObj) throws Exception{
        return hikService.subByEventTypes(hikEventObj);
    }

    @Operation(summary = "根据事件类型取消订阅事件")
    @PostMapping("/unSubByEventTypes")
    public JSONObject unSubByEventTypes(@RequestBody HikEventObj hikEventObj) throws Exception{
        return hikService.unSubByEventTypes(hikEventObj);
    }

    @Operation(summary = "查询订阅事件信息")
    @PostMapping("/eventView")
    public JSONObject eventView() throws Exception{
        return hikService.eventView();
    }

    @Operation(summary = "接收海康事件信息")
    @PostMapping("/eventRcv")
    public JSONObject eventRcv(@RequestBody JSONObject jsonObject) throws Exception{
        String method = null;
        JSONObject params = new JSONObject();
        JSONArray events = new JSONArray();
        JSONObject res = new JSONObject();
        String sendTime = null;
        if(jsonObject.containsKey("method")){
            method = jsonObject.getString("method");
        }
        if (jsonObject.containsKey("params")) {
            params = jsonObject.getJSONObject("params");
            if(params.containsKey("sendTime")){
                sendTime = params.getString("sendTime");
            }
            if (params.containsKey("events")) {
                events = params.getJSONArray("events");
                if(events.size()>0){
                    for (int i=0;i<events.size();i++){
                        JSONObject event = events.getJSONObject(i);

                        HikEvent hikEvent = new HikEvent();
                        hikEvent.setSendTime(convertTime(sendTime));
                        if(event.containsKey("srcIndex")){
                            String srcIndex = event.getString("srcIndex");
                            hikEvent.setSrcIndex(srcIndex);
                        }
                        if(event.containsKey("srcType")){
                            String srcType = event.getString("srcType");
                            hikEvent.setSrcType(srcType);
                        }
                        if(event.containsKey("srcName")){
                            String srcName = event.getString("srcName");
                            hikEvent.setSrcName(srcName);
                        }
                        if(event.containsKey("eventType")){
                            Integer eventType = event.getIntValue("eventType");
                            hikEvent.setEventType(eventType);
                        }
                        if(event.containsKey("happenTime")){
                            String happenTime = event.getString("happenTime");
                            hikEvent.setHappenTime(convertTime(happenTime));
                        }
                        boolean reaIns = hikService.saveInsert(hikEvent);
                        if(reaIns){
                            res.put("code","0");
                            res.put("msg","success");
                        }

                        if(event.containsKey("data")){
                            JSONObject data = event.getJSONObject("data");
                            if(data.containsKey("regionEntrance")){
                                JSONArray regionEntrance = data.getJSONArray("regionEntrance");
                                if(regionEntrance.size()>0){
                                    for (int k=0;k<regionEntrance.size();k++){
                                        JSONObject region = regionEntrance.getJSONObject(k);
                                        if(region.containsKey("targetAttrs")){
                                            JSONObject targetAttrs = region.getJSONObject("targetAttrs");
                                            if(targetAttrs.containsKey("cameraAddress")){
                                                String cameraAddress = targetAttrs.getString("cameraAddress");
                                            }
                                            if(targetAttrs.containsKey("cameraIndexCode")){
                                                String cameraIndexCode = targetAttrs.getString("cameraIndexCode");
                                            }
                                            if(targetAttrs.containsKey("deviceIndexCode")){
                                                String deviceIndexCode = targetAttrs.getString("deviceIndexCode");
                                            }
                                            if(targetAttrs.containsKey("imageServerCode")){
                                                String imageServerCode = targetAttrs.getString("imageServerCode");
                                            }
                                        }
                                    }
                                }
                            }
                        }
                    }
                }
            }
        }
        return res;
    }

    /**
     * 查询海康事件列表
     */
    @PostMapping("/list")
    @Operation(summary = "查询海康事件列表（分页）")
    public TableDataInfo list(@RequestBody HikEvent hikEvent)
    {
        return hikService.getList(hikEvent);
    }

    /**
     * 查询所有海康事件列表
     */
    @GetMapping("/listAll")
    @Operation(summary = "查询所有海康事件列表")
    public AjaxResult listAll()
    {
        return AjaxResult.success(hikService.list());
    }

    /**
     * 获取港口信息详细信息
     */
    @GetMapping("/{id}")
    @Operation(summary = "获取海康事件信息")
    public AjaxResult getInfo(@PathVariable("id") String id)
    {
        return success(hikService.getById(id));
    }

    private Date convertTime(String time){
        OffsetDateTime offsetDateTime = OffsetDateTime.parse(time);
        Date date = Date.from(offsetDateTime.toInstant());
        return date;
    }

}