yuanqu/ruoyi-admin/src/main/java/com/ruoyi/web/controller/camera/CameraController.java

package com.ruoyi.web.controller.camera;

import com.alibaba.fastjson2.JSONObject;
import com.ruoyi.alarm.Alarm;
import com.ruoyi.common.annotation.Log;
import com.ruoyi.common.core.controller.BaseController;
import com.ruoyi.common.core.domain.AjaxResult;
import com.ruoyi.common.core.page.TableDataInfo;
import com.ruoyi.common.core.redis.RedisCache;
import com.ruoyi.common.enums.BusinessType;
import com.ruoyi.common.exception.ServiceException;
import com.ruoyi.common.utils.StringUtils;
import com.ruoyi.common.utils.poi.ExcelUtil;
import com.ruoyi.hksdk.HCNetSDK;
import com.ruoyi.system.domain.EquipmentConfiguration;
import com.ruoyi.system.domain.OpeningDoorRecord;
import com.ruoyi.system.domain.PersonnelManagement;
import com.ruoyi.system.domain.vo.CameraInfoVo;
import com.ruoyi.system.service.CameraService;
import com.ruoyi.system.service.IEquipmentConfigurationService;
import com.ruoyi.system.service.IOpeningDoorRecordService;
import com.ruoyi.system.service.IPersonnelManagementService;
import com.sun.jna.Pointer;
import org.apache.commons.lang3.ObjectUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.security.access.prepost.PreAuthorize;
import org.springframework.web.bind.annotation.*;

import javax.servlet.http.HttpServletResponse;
import java.util.List;

import static com.ruoyi.common.constant.CommonConstants.LOGIN_USER_SMS;
import static com.ruoyi.common.constant.CommonConstants.OPEN_DOOR;

/**
 * 安防管理Controller
 *
 * @author ruoyi
 * @date 2024-02-28
 */
@RestController
@RequestMapping("/camera")
public class CameraController extends BaseController {

    @Autowired
    private CameraService cameraService;
    @Autowired
    private IEquipmentConfigurationService equipmentConfigurationService;
    @Autowired
    private IOpeningDoorRecordService openingDoorRecordService;
    @Autowired
    private RedisCache redisCache;

    /**
     * 查询安防设备列表
     */
    @PreAuthorize("@ss.hasPermi('system:camera:list')")
    @GetMapping("/list")
    public AjaxResult list(CameraInfoVo cameraInfoVo) {
        return cameraService.selectCameraList(cameraInfoVo);
    }


    /**
     * 获取设备视频地址（放开）
     */
    @PreAuthorize("@ss.hasPermi('system:camera:video')")
    @GetMapping("/video/{cameraIndexCode}")
    public AjaxResult video(@PathVariable String cameraIndexCode) {
        return cameraService.video(cameraIndexCode);
    }


    /**
     * 查询安防设备列表(放开)
     */
    @GetMapping("/open/list")
    public AjaxResult listOpen(CameraInfoVo cameraInfoVo) {
        return cameraService.selectCameraList(cameraInfoVo);
    }


    /**
     * 获取设备视频地址(放开)
     */
    @GetMapping("/open/video/{cameraIndexCode}")
    public AjaxResult videoOpen(@PathVariable String cameraIndexCode) {
        return cameraService.video(cameraIndexCode);
    }

    /**
     * 设备关闭
     */
    @GetMapping("/video/closeDz")
    @PreAuthorize("@ss.hasPermi('system:camera:closeDz')")
    public AjaxResult closeDz(EquipmentConfiguration equipmentConfiguration) {
        equipmentConfiguration = equipmentConfigurationService.selectEquipmentConfigurationByEquipmentName(equipmentConfiguration.getEquipmentName());
        if(StringUtils.isEmpty(equipmentConfiguration.getEquipmentName())){
            return AjaxResult.error("设备列表暂无当前设备");
        }
        String ip = equipmentConfiguration.getEquipmentIp();
        short prot = (short) Short.parseShort(equipmentConfiguration.getEquipmentPort());
        String login = equipmentConfiguration.getLoginName();
        String pwd = equipmentConfiguration.getLoginPwd();

        int tdh = Alarm.login_V40( ip, prot, login, pwd);;  //登录设备
        String ret="落竿失败!";
        try {
            HCNetSDK.NET_DVR_BARRIERGATE_CFG cfg = new HCNetSDK.NET_DVR_BARRIERGATE_CFG();
            // cfg.read();
            cfg.dwChannel=tdh;  //通道号
            cfg.dwSize=cfg.size(); //结构体大小
            cfg.byLaneNo=1; //道闸号：0-表示无效值(设备需要做有效值判断)，1-道闸1
            cfg.byBarrierGateCtrl=0; // 控制参数：0-关闭道闸，1-开启道闸，2-停止道闸，3-锁定道闸
            cfg.byRes[0]=0; //保留，置为0
            //起竿操作
            Pointer name = cfg.getPointer();
            cfg.write();
            boolean a=Alarm.controlsDz(tdh, 3128,  name, cfg.size());
            if(a) {
                ret="落竿成功!";
            }else {
                ret="落竿失败!"+Alarm.controlsDzError();
                //失败重新布防, 可以不布防
                //new HikVisionService().run();
            }
            System.out.println("关闸结果--"+a+"-- 提示内容:"+ret);
            //保存记录
            OpeningDoorRecord openingDoorRecord = new OpeningDoorRecord();
            openingDoorRecord.setEntranceGuardName(equipmentConfiguration.getEquipmentName());
            openingDoorRecord.setType("2");
            openingDoorRecordService.insertOpeningDoorRecord(openingDoorRecord);
            //注销用户
            boolean b=Alarm.logout(tdh);
        } catch (Exception e) {
            e.printStackTrace();
        }
        return AjaxResult.success(ret);
    }

    /**
     * 设备打开
     */
    @GetMapping("/video/openDz")
    @PreAuthorize("@ss.hasPermi('system:camera:openDz')")
    public AjaxResult openDz(EquipmentConfiguration equipmentConfiguration) {
        equipmentConfiguration = equipmentConfigurationService.selectEquipmentConfigurationByEquipmentName(equipmentConfiguration.getEquipmentName());
        if(StringUtils.isEmpty(equipmentConfiguration.getEquipmentName())){
            return AjaxResult.error("设备列表暂无当前设备");
        }

        String ip = equipmentConfiguration.getEquipmentIp();
        short prot = (short) Short.parseShort(equipmentConfiguration.getEquipmentPort());
        String login = equipmentConfiguration.getLoginName();
        String pwd = equipmentConfiguration.getLoginPwd();

        int tdh = Alarm.login_V40( ip, prot, login, pwd);;  //登录设备
        //Alarm.setAlarm();
        String ret="起竿失败!";
        try {
            HCNetSDK.NET_DVR_BARRIERGATE_CFG cfg = new HCNetSDK.NET_DVR_BARRIERGATE_CFG();
            // cfg.read();
            cfg.dwChannel=tdh;  //通道号
            cfg.dwSize=cfg.size(); //结构体大小
            cfg.byLaneNo=1; //道闸号：0-表示无效值(设备需要做有效值判断)，1-道闸1
            cfg.byBarrierGateCtrl=1; // 控制参数：0-关闭道闸，1-开启道闸，2-停止道闸，3-锁定道闸
            cfg.byRes[0]=0; //保留，置为0
            //起竿操作
            Pointer name = cfg.getPointer();
            cfg.write();
            boolean a=Alarm.controlsDz(tdh, 3128,  name, cfg.size());
            if(a) {
                ret="起竿成功!";
            }else {
                ret="起竿失败!"+Alarm.controlsDzError();
                //失败重新布防, 可以不布防
                //new HikVisionService().run();
            }
            System.out.println("开闸结果--"+a+"-- 提示内容:"+ret);
            //保存记录
            OpeningDoorRecord openingDoorRecord = new OpeningDoorRecord();
            openingDoorRecord.setEntranceGuardName(equipmentConfiguration.getEquipmentName());
            openingDoorRecord.setType("1");
            openingDoorRecordService.insertOpeningDoorRecord(openingDoorRecord);
            //注销用户
            boolean b=Alarm.logout(tdh);
        } catch (Exception e) {
            e.printStackTrace();
        }
        return AjaxResult.success(ret);
    }


    /**
     * 设备打开
     */
    @GetMapping("/yzm/openDz")
    public AjaxResult yzmOpenDz(EquipmentConfiguration equipmentConfiguration) {
        //验证码校验
        Object cacheObject = redisCache.getCacheObject(OPEN_DOOR + equipmentConfiguration.getPhoneNumber());
        if(ObjectUtils.isEmpty(cacheObject) || !equipmentConfiguration.getCode().equals(cacheObject)){
            throw new ServiceException("验证码错误");
        }
        redisCache.deleteObject(LOGIN_USER_SMS + equipmentConfiguration.getPhoneNumber());
        equipmentConfiguration = equipmentConfigurationService.selectEquipmentConfigurationByEquipmentName(equipmentConfiguration.getEquipmentName());
        if(StringUtils.isEmpty(equipmentConfiguration.getEquipmentName())){
            return AjaxResult.error("设备列表暂无当前设备");
        }

        String ip = equipmentConfiguration.getEquipmentIp();
        short prot = (short) Short.parseShort(equipmentConfiguration.getEquipmentPort());
        String login = equipmentConfiguration.getLoginName();
        String pwd = equipmentConfiguration.getLoginPwd();

        int tdh = Alarm.login_V40( ip, prot, login, pwd);;  //登录设备
        //Alarm.setAlarm();
        String ret="起竿失败!";
        try {
            HCNetSDK.NET_DVR_BARRIERGATE_CFG cfg = new HCNetSDK.NET_DVR_BARRIERGATE_CFG();
            // cfg.read();
            cfg.dwChannel=tdh;  //通道号
            cfg.dwSize=cfg.size(); //结构体大小
            cfg.byLaneNo=1; //道闸号：0-表示无效值(设备需要做有效值判断)，1-道闸1
            cfg.byBarrierGateCtrl=1; // 控制参数：0-关闭道闸，1-开启道闸，2-停止道闸，3-锁定道闸
            cfg.byRes[0]=0; //保留，置为0
            //起竿操作
            Pointer name = cfg.getPointer();
            cfg.write();
            boolean a=Alarm.controlsDz(tdh, 3128,  name, cfg.size());
            if(a) {
                ret="起竿成功!";
            }else {
                ret="起竿失败!"+Alarm.controlsDzError();
                //失败重新布防, 可以不布防
                //new HikVisionService().run();
            }
            System.out.println("开闸结果--"+a+"-- 提示内容:"+ret);
            //保存记录
            OpeningDoorRecord openingDoorRecord = new OpeningDoorRecord();
            openingDoorRecord.setEntranceGuardName(equipmentConfiguration.getEquipmentName());
            openingDoorRecord.setType("1");
            openingDoorRecordService.insertOpeningDoorRecord(openingDoorRecord);
            //注销用户
            boolean b=Alarm.logout(tdh);
        } catch (Exception e) {
            e.printStackTrace();
        }
        return AjaxResult.success(ret);
    }

}