1、视频监控配置信息完善;
2、摄像机实体完善;
3、工程模块-视频站管理功能实现;
4、远程模块--视频监控查询;
| | |
| | | @JSONField(serialize = false) |
| | | public Integer queryCount ; |
| | | |
| | | public void copyTo(QueryResultVo to){ |
| | | to.pageSize = this.pageSize ; |
| | | to.itemTotal = this.itemTotal ; |
| | | to.pageCurr = this.pageCurr ; |
| | | to.pageTotal = this.pageTotal ; |
| | | to.obj = this.obj ; |
| | | to.queryStart = this.queryStart ; |
| | | to.queryCount = this.queryCount ; |
| | | } |
| | | |
| | | |
| | | public void calculateAndSet(Long itemTotal, Map<String, Object> params) { |
| | | this.itemTotal = itemTotal ; |
| | |
| | | |
| | | import com.baomidou.mybatisplus.core.mapper.BaseMapper; |
| | | import com.dy.pipIrrGlobal.pojoVi.ViCamera; |
| | | import com.dy.pipIrrGlobal.voVi.VoCamera; |
| | | import org.apache.ibatis.annotations.Mapper; |
| | | |
| | | import java.util.List; |
| | | import java.util.Map; |
| | | |
| | | /** |
| | | * @Author: liurunyu |
| | | * @Date: 2025/6/9 8:49 |
| | | * @Date: 2025/6/9 9:15 |
| | | * @Description |
| | | */ |
| | | @Mapper |
| | | public interface ViCameraMapper extends BaseMapper<ViCamera> { |
| | | int deleteByPrimaryKey(Long id); |
| | | |
| | | /** |
| | | * 逻辑删除 |
| | | * @param id primaryKey |
| | | * @return update count |
| | | */ |
| | | int deleteLogicById(Long id); |
| | | |
| | | |
| | | int insert(ViCamera record); |
| | | |
| | | int insertSelective(ViCamera record); |
| | | |
| | | ViCamera selectByPrimaryKey(Long id); |
| | | /** |
| | | * 查询总数 |
| | | * @param params 查询条件 |
| | | * @return 总数 |
| | | */ |
| | | Long selectTotal(Map<?, ?> params) ; |
| | | |
| | | /** |
| | | * 分页查询一些 |
| | | * @param params 查询条件 |
| | | * @return 实体集合 |
| | | */ |
| | | List<VoCamera> selectSome(Map<?, ?> params) ; |
| | | |
| | | // Update the record in the ViCamera table based on the primary key, but only update the fields that are not null |
| | | int updateByPrimaryKeySelective(ViCamera record); |
| | | |
| | | int updateByPrimaryKey(ViCamera record); |
| | |
| | | |
| | | /** |
| | | * @Author: liurunyu |
| | | * @Date: 2025/6/9 8:49 |
| | | * @Date: 2025/6/9 9:15 |
| | | * @Description |
| | | */ |
| | | |
| | | /** |
| | | * 萤石摄像机(视频站) |
| | | */ |
| | |
| | | */ |
| | | @Schema(description = "备注信息", requiredMode = Schema.RequiredMode.NOT_REQUIRED) |
| | | public String remark; |
| | | |
| | | /** |
| | | * 是否删除(1是,0否) |
| | | */ |
| | | @Schema(description = "是否删除", requiredMode = Schema.RequiredMode.NOT_REQUIRED) |
| | | public Byte deleted; |
| | | |
| | | } |
New file |
| | |
| | | package com.dy.pipIrrGlobal.util; |
| | | |
| | | /** |
| | | * @Author: liurunyu |
| | | * @Date: 2025/6/9 11:31 |
| | | * @Description |
| | | */ |
| | | public enum CameraTypeEnum { |
| | | YINGSHI((byte)1, "萤石"); |
| | | |
| | | private Byte type ; //1萤石 2海康 |
| | | private String name ;//萤石 海康 |
| | | |
| | | CameraTypeEnum(Byte type, String name){ |
| | | this.type = type ; |
| | | this.name = name ; |
| | | } |
| | | public Byte getType() { |
| | | return this.type ; |
| | | } |
| | | public String getName() { |
| | | return this.name ; |
| | | } |
| | | } |
New file |
| | |
| | | package com.dy.pipIrrGlobal.voVi; |
| | | |
| | | import com.alibaba.fastjson2.annotation.JSONField; |
| | | import com.alibaba.fastjson2.writer.ObjectWriterImplToString; |
| | | import io.swagger.v3.oas.annotations.media.Schema; |
| | | import lombok.Data; |
| | | |
| | | /** |
| | | * @Author: liurunyu |
| | | * @Date: 2025/6/9 9:12 |
| | | * @Description |
| | | */ |
| | | @Data |
| | | public class VoCamera { |
| | | private static final long serialVersionUID = 202506090918001L; |
| | | @JSONField(serializeUsing= ObjectWriterImplToString.class) |
| | | public Long id; |
| | | |
| | | /** |
| | | * 类型(1萤石) |
| | | */ |
| | | public Byte type; |
| | | |
| | | /** |
| | | * 摄像机序列号 |
| | | */ |
| | | public String devNo; |
| | | |
| | | /** |
| | | * 视频站名称 |
| | | */ |
| | | public String name; |
| | | |
| | | /** |
| | | * 经度 |
| | | */ |
| | | public Double lng; |
| | | |
| | | /** |
| | | * 纬度 |
| | | */ |
| | | public Double lat; |
| | | |
| | | /** |
| | | * 是否大屏展示(1是,0或null否) |
| | | */ |
| | | public Byte onScreen; |
| | | |
| | | /** |
| | | * 大屏展示排序(大于等于1,数字越小排序越前) |
| | | */ |
| | | public Integer onSort; |
| | | |
| | | /** |
| | | * 备注 |
| | | */ |
| | | public String remark; |
| | | |
| | | } |
| | |
| | | at-all: true |
| | | mobile: 18602657034 |
| | | |
| | | #萤石云开放平台 |
| | | ys: |
| | | accessTokenExpireDay: 7 #AccessToken过期时间,单位天 |
| | | appKey: 93987fd687444c23b427181a108f5253 |
| | | secret: d73a08e4fb3c3d9d0b696630eea8bd4e |
| | | requestAccessTokenUrl: https://open.ys7.com/api/lapp/token/get |
| | | requestVideoCommonUrl: https://open.ys7.com/console/jssdk/pc.html |
| | | requestVideoCameraPreUrl: ezopen://open.ys7.com/ |
| | | requestVideoCameraTailUrl: /1.live&themeId= |
| | | |
| | | #视频监控相关 |
| | | video: |
| | | #萤石云开放平台 |
| | | ys: |
| | | accessTokenExpireDay: 7 #AccessToken过期时间,单位天 |
| | | appKey: 93987fd687444c23b427181a108f5253 |
| | | secret: d73a08e4fb3c3d9d0b696630eea8bd4e |
| | | requestAccessTokenUrl: https://open.ys7.com/api/lapp/token/get |
| | | requestVideoCommonUrl: https://open.ys7.com/console/jssdk/pc.html |
| | | requestVideoCameraPreUrl: ezopen://open.ys7.com/ |
| | | requestVideoCameraTailUrl: /1.live&themeId= |
| | | types: |
| | | - 1,萤石 #1:萤石 |
| | | #- 2,海康 #2:海康 |
| | | #- 3,大华 #3:大华 |
| | | #- 4,天地伟业 #4:天地伟业 |
| | | screen: |
| | | count: 4 #默认显示4个视频 |
| | | #阀控器参数 |
| | | rtu: |
| | | signalIntensity: |
| | |
| | | <result column="on_screen" jdbcType="TINYINT" property="onScreen" /> |
| | | <result column="on_sort" jdbcType="INTEGER" property="onSort" /> |
| | | <result column="remark" jdbcType="VARCHAR" property="remark" /> |
| | | <result column="deleted" jdbcType="TINYINT" property="deleted" /> |
| | | </resultMap> |
| | | <sql id="Base_Column_List"> |
| | | <!--@mbg.generated--> |
| | | id, `type`, dev_no, `name`, lng, lat, on_screen, on_sort, remark, deleted |
| | | </sql> |
| | | <sql id="part_Column_List"> |
| | | <!--@mbg.generated--> |
| | | id, `type`, dev_no, `name`, lng, lat, on_screen, on_sort, remark |
| | | </sql> |
| | |
| | | from vi_camera |
| | | where id = #{id,jdbcType=BIGINT} |
| | | </select> |
| | | |
| | | <select id="selectTotal" parameterType="java.util.Map" resultType="java.lang.Long"> |
| | | select |
| | | count(*) |
| | | from vi_camera tb |
| | | where tb.deleted != 1 |
| | | <trim prefix="and" suffixOverrides="and"> |
| | | <if test="name != null and name != ''"> |
| | | tb.`name` like concat('%', #{name}, '%') and |
| | | </if> |
| | | </trim> |
| | | </select> |
| | | <select id="selectSome" parameterType="java.util.Map" resultType="com.dy.pipIrrGlobal.voVi.VoCamera"> |
| | | <!--@mbg.generated--> |
| | | select |
| | | <include refid="part_Column_List" > |
| | | <property name="alias" value="tb"/> |
| | | </include> |
| | | from vi_camera tb |
| | | where tb.deleted != 1 |
| | | <trim prefix="and" suffixOverrides="and"> |
| | | <if test="name != null"> |
| | | tb.`name` like concat('%', #{name}, '%') and |
| | | </if> |
| | | </trim> |
| | | order by tb.on_sort ASC, tb.id DESC |
| | | <trim prefix="limit " > |
| | | <if test="start != null and count != null"> |
| | | #{start,javaType=Integer,jdbcType=INTEGER}, #{count,javaType=Integer,jdbcType=INTEGER} |
| | | </if> |
| | | </trim> |
| | | </select> |
| | | <delete id="deleteByPrimaryKey" parameterType="java.lang.Long"> |
| | | <!--@mbg.generated--> |
| | | delete from vi_camera |
| | | where id = #{id,jdbcType=BIGINT} |
| | | </delete> |
| | | <delete id="deleteLogicById" parameterType="java.lang.Long"> |
| | | <!--@mbg.generated--> |
| | | update vi_camera set deleted = 1 |
| | | where id = #{id,jdbcType=BIGINT} |
| | | </delete> |
| | | |
| | | <insert id="insert" parameterType="com.dy.pipIrrGlobal.pojoVi.ViCamera"> |
| | | <!--@mbg.generated--> |
| | | insert into vi_camera (id, `type`, dev_no, |
| | | `name`, lng, lat, on_screen, |
| | | on_sort, remark) |
| | | on_sort, remark, deleted |
| | | ) |
| | | values (#{id,jdbcType=BIGINT}, #{type,jdbcType=TINYINT}, #{devNo,jdbcType=VARCHAR}, |
| | | #{name,jdbcType=VARCHAR}, #{lng,jdbcType=DOUBLE}, #{lat,jdbcType=DOUBLE}, #{onScreen,jdbcType=TINYINT}, |
| | | #{onSort,jdbcType=INTEGER}, #{remark,jdbcType=VARCHAR}) |
| | | #{onSort,jdbcType=INTEGER}, #{remark,jdbcType=VARCHAR}, #{deleted,jdbcType=TINYINT} |
| | | ) |
| | | </insert> |
| | | <insert id="insertSelective" parameterType="com.dy.pipIrrGlobal.pojoVi.ViCamera"> |
| | | <!--@mbg.generated--> |
| | |
| | | <if test="remark != null"> |
| | | remark, |
| | | </if> |
| | | <if test="deleted != null"> |
| | | deleted, |
| | | </if> |
| | | </trim> |
| | | <trim prefix="values (" suffix=")" suffixOverrides=","> |
| | | <if test="id != null"> |
| | |
| | | </if> |
| | | <if test="remark != null"> |
| | | #{remark,jdbcType=VARCHAR}, |
| | | </if> |
| | | <if test="deleted != null"> |
| | | #{deleted,jdbcType=TINYINT}, |
| | | </if> |
| | | </trim> |
| | | </insert> |
| | |
| | | <if test="remark != null"> |
| | | remark = #{remark,jdbcType=VARCHAR}, |
| | | </if> |
| | | <if test="deleted != null"> |
| | | deleted = #{deleted,jdbcType=TINYINT}, |
| | | </if> |
| | | </set> |
| | | where id = #{id,jdbcType=BIGINT} |
| | | </update> |
| | |
| | | lat = #{lat,jdbcType=DOUBLE}, |
| | | on_screen = #{onScreen,jdbcType=TINYINT}, |
| | | on_sort = #{onSort,jdbcType=INTEGER}, |
| | | remark = #{remark,jdbcType=VARCHAR} |
| | | remark = #{remark,jdbcType=VARCHAR}, |
| | | deleted = #{deleted,jdbcType=TINYINT} |
| | | where id = #{id,jdbcType=BIGINT} |
| | | </update> |
| | | </mapper> |
| | |
| | | }) |
| | | } |
| | | ) |
| | | @MapperScan({"com.dy.pipIrrGlobal.daoPr", "com.dy.pipIrrGlobal.daoBa","com.dy.pipIrrGlobal.daoFi"}) |
| | | @MapperScan({"com.dy.pipIrrGlobal.daoPr", "com.dy.pipIrrGlobal.daoBa","com.dy.pipIrrGlobal.daoFi","com.dy.pipIrrGlobal.daoVi"}) |
| | | public class PipIrrProjectApplication { |
| | | |
| | | public static void main(String[] args) { |
New file |
| | |
| | | package com.dy.pipIrrProject.video; |
| | | |
| | | import com.dy.common.aop.SsoAop; |
| | | import com.dy.common.webUtil.BaseResponse; |
| | | import com.dy.common.webUtil.BaseResponseUtils; |
| | | import com.dy.common.webUtil.QueryResultVo; |
| | | import com.dy.common.webUtil.ResultCodeMsg; |
| | | import com.dy.pipIrrGlobal.pojoVi.ViCamera; |
| | | import com.dy.pipIrrGlobal.voVi.VoCamera; |
| | | import io.swagger.v3.oas.annotations.Operation; |
| | | import io.swagger.v3.oas.annotations.media.Content; |
| | | import io.swagger.v3.oas.annotations.media.Schema; |
| | | import io.swagger.v3.oas.annotations.responses.ApiResponse; |
| | | import io.swagger.v3.oas.annotations.responses.ApiResponses; |
| | | import io.swagger.v3.oas.annotations.tags.Tag; |
| | | import jakarta.validation.Valid; |
| | | import org.springframework.beans.factory.annotation.Value; |
| | | import lombok.RequiredArgsConstructor; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.http.MediaType; |
| | | import org.springframework.validation.BindingResult; |
| | | import org.springframework.web.bind.annotation.*; |
| | | |
| | | import java.util.ArrayList; |
| | | import java.util.List; |
| | | import java.util.Objects; |
| | | |
| | | /** |
| | | * @Author: liurunyu |
| | | * @Date: 2025/6/9 9:01 |
| | | * @Description |
| | | */ |
| | | @Slf4j |
| | | @Tag(name = "视频站管理", description = "视频站管理") |
| | | @RestController |
| | | @RequestMapping(path = "camera") |
| | | @RequiredArgsConstructor |
| | | public class CameraCtrl { |
| | | private CameraSv sv; |
| | | |
| | | @Autowired |
| | | private void setSv(CameraSv sv){ |
| | | this.sv = sv ; |
| | | } |
| | | |
| | | @Value("${video.types}") |
| | | private String[] types; |
| | | /** |
| | | * 客户端请求得到所有摄像机类型 |
| | | * @return 所有摄像机类型 |
| | | */ |
| | | @Operation(summary = "获得全部摄像机类型", description = "返回全部摄像机类型") |
| | | @ApiResponses(value = { |
| | | @ApiResponse( |
| | | responseCode = ResultCodeMsg.RsCode.SUCCESS_CODE, |
| | | description = "返回全部摄像机类型数据(BaseResponse.content:TypesVo[{}])", |
| | | content = {@Content(mediaType = MediaType.APPLICATION_JSON_VALUE, |
| | | schema = @Schema(implementation = TypesVo.class))} |
| | | ) |
| | | }) |
| | | @GetMapping(path = "types") |
| | | @SsoAop() |
| | | public BaseResponse<QueryResultVo<List<TypesVo>>> types() { |
| | | try { |
| | | List<TypesVo> list = new ArrayList<>() ; |
| | | if(types != null && types.length > 0){ |
| | | for (String type : types) { |
| | | String[] typeGrp = type.split(","); |
| | | if(typeGrp.length == 2){ |
| | | TypesVo vo = new TypesVo() ; |
| | | vo.type = Integer.parseInt(typeGrp[0].trim()) ; |
| | | vo.name = typeGrp[1].trim() ; |
| | | list.add(vo) ; |
| | | } |
| | | } |
| | | } |
| | | QueryResultVo<List<TypesVo>> res = new QueryResultVo() ; |
| | | res.obj = list ; |
| | | return BaseResponseUtils.buildSuccess(res); |
| | | } catch (Exception e) { |
| | | log.error("查询取水口异常", e); |
| | | return BaseResponseUtils.buildException(e.getMessage()); |
| | | } |
| | | } |
| | | |
| | | |
| | | /** |
| | | * 客户端请求得到一些摄像机数据 |
| | | * @return 所有摄像机数据 |
| | | */ |
| | | @Operation(summary = "获得一页摄像机数据", description = "返回一页摄像机数据数据") |
| | | @ApiResponses(value = { |
| | | @ApiResponse( |
| | | responseCode = ResultCodeMsg.RsCode.SUCCESS_CODE, |
| | | description = "返回一页摄像机数据(BaseResponse.content:QueryResultVo[{}])", |
| | | content = {@Content(mediaType = MediaType.APPLICATION_JSON_VALUE, |
| | | schema = @Schema(implementation = VoCamera.class))} |
| | | ) |
| | | }) |
| | | @PostMapping(path = "some", consumes = MediaType.APPLICATION_JSON_VALUE) |
| | | @SsoAop() |
| | | public BaseResponse<QueryResultVo<List<VoCamera>>> some(@RequestBody CameraQo vo){ |
| | | try { |
| | | QueryResultVo<List<VoCamera>> res = this.sv.some(vo) ; |
| | | return BaseResponseUtils.buildSuccess(res); |
| | | } catch (Exception e) { |
| | | log.error("查询摄像机异常", e); |
| | | return BaseResponseUtils.buildException(e.getMessage()) ; |
| | | } |
| | | } |
| | | |
| | | /** |
| | | * 得到一个摄像机数据 |
| | | * @return 一个摄像机数据 |
| | | */ |
| | | @Operation(summary = "一个摄像机", description = "得到一个摄像机数据") |
| | | @ApiResponses(value = { |
| | | @ApiResponse( |
| | | responseCode = ResultCodeMsg.RsCode.SUCCESS_CODE, |
| | | description = "返回一个摄像机数据(BaseResponse.content:{})", |
| | | content = {@Content(mediaType = MediaType.APPLICATION_JSON_VALUE, |
| | | schema = @Schema(implementation = ViCamera.class))} |
| | | ) |
| | | }) |
| | | @GetMapping(path = "one", consumes = MediaType.TEXT_PLAIN_VALUE) |
| | | @SsoAop() |
| | | public BaseResponse<ViCamera> one(Long id){ |
| | | return BaseResponseUtils.buildSuccess(this.sv.selectById(id)); |
| | | } |
| | | |
| | | /** |
| | | * 保存摄像机 |
| | | * @param dto 保存摄像机form表单对象 |
| | | * @return 是否成功 |
| | | */ |
| | | @Operation(summary = "保存摄像机", description = "提交摄像机数据(form表单),进行保存") |
| | | @ApiResponses(value = { |
| | | @ApiResponse( |
| | | responseCode = ResultCodeMsg.RsCode.SUCCESS_CODE, |
| | | description = "操作结果:true:成功,false:失败(BaseResponse.content)", |
| | | content = {@Content(mediaType = MediaType.APPLICATION_JSON_VALUE, |
| | | schema = @Schema(implementation = Boolean.class))} |
| | | ) |
| | | }) |
| | | @PostMapping(path = "save", consumes = MediaType.APPLICATION_JSON_VALUE) |
| | | @SsoAop() |
| | | public BaseResponse<Boolean> save(@RequestBody @Valid CameraDto dto, BindingResult bindingResult){ |
| | | if(bindingResult != null && bindingResult.hasErrors()){ |
| | | return BaseResponseUtils.buildFail(Objects.requireNonNull(bindingResult.getFieldError()).getDefaultMessage()); |
| | | } |
| | | ViCamera po = dto.toNewPo() ; |
| | | int count; |
| | | try { |
| | | count = this.sv.save(po); |
| | | } catch (Exception e) { |
| | | log.error("保存摄像机异常", e); |
| | | return BaseResponseUtils.buildException(e.getMessage()) ; |
| | | } |
| | | if(count <= 0){ |
| | | return BaseResponseUtils.buildFail("数据库存储失败") ; |
| | | }else{ |
| | | return BaseResponseUtils.buildSuccess(true) ; |
| | | } |
| | | } |
| | | |
| | | /** |
| | | * 编辑修改摄像机 |
| | | * @param dto 保存摄像机form表单对象 |
| | | * @return 是否成功 |
| | | */ |
| | | @Operation(summary = "编辑修改摄像机", description = "提交摄像机数据(form表单),进行修改") |
| | | @ApiResponses(value = { |
| | | @ApiResponse( |
| | | responseCode = ResultCodeMsg.RsCode.SUCCESS_CODE, |
| | | description = "操作结果:true:成功,false:失败(BaseResponse.content)", |
| | | content = {@Content(mediaType = MediaType.APPLICATION_JSON_VALUE, |
| | | schema = @Schema(implementation = Boolean.class))} |
| | | ) |
| | | }) |
| | | @PostMapping(path = "update", consumes = MediaType.APPLICATION_JSON_VALUE) |
| | | @SsoAop() |
| | | public BaseResponse<Boolean> update(@RequestBody @Valid CameraDto dto, BindingResult bindingResult){ |
| | | if(bindingResult != null && bindingResult.hasErrors()){ |
| | | return BaseResponseUtils.buildFail(Objects.requireNonNull(bindingResult.getFieldError()).getDefaultMessage()); |
| | | } |
| | | ViCamera po = dto.toPo() ; |
| | | if(po.id == null){ |
| | | return BaseResponseUtils.buildFail("无数据实体ID") ; |
| | | } |
| | | int count; |
| | | try { |
| | | count = this.sv.update(po); |
| | | } catch (Exception e) { |
| | | log.error("保存摄像机异常", e); |
| | | return BaseResponseUtils.buildException(e.getMessage()) ; |
| | | } |
| | | if(count <= 0){ |
| | | return BaseResponseUtils.buildFail("数据库存储失败") ; |
| | | }else{ |
| | | return BaseResponseUtils.buildSuccess(true) ; |
| | | } |
| | | } |
| | | |
| | | |
| | | /** |
| | | * 删除摄像机 |
| | | * @param id 摄像机ID |
| | | * @return 是否成功 |
| | | */ |
| | | @Operation(summary = "删除摄像机", description = "提交摄像机ID,进行逻辑删除") |
| | | @ApiResponses(value = { |
| | | @ApiResponse( |
| | | responseCode = ResultCodeMsg.RsCode.SUCCESS_CODE, |
| | | description = "操作结果:true:成功,false:失败(BaseResponse.content)", |
| | | content = {@Content(mediaType = MediaType.APPLICATION_JSON_VALUE, |
| | | schema = @Schema(implementation = Boolean.class))} |
| | | ) |
| | | }) |
| | | @GetMapping(path = "delete", consumes = MediaType.TEXT_PLAIN_VALUE) |
| | | @SsoAop() |
| | | public BaseResponse<Boolean> delete(Long id){ |
| | | if(id == null){ |
| | | return BaseResponseUtils.buildFail("id不能为空") ; |
| | | } |
| | | int count; |
| | | try { |
| | | count = this.sv.delete(id); |
| | | } catch (Exception e) { |
| | | log.error("保存摄像机异常", e); |
| | | return BaseResponseUtils.buildException(e.getMessage()) ; |
| | | } |
| | | if(count <= 0){ |
| | | return BaseResponseUtils.buildFail("数据库存储失败") ; |
| | | }else{ |
| | | return BaseResponseUtils.buildSuccess(true) ; |
| | | } |
| | | } |
| | | |
| | | |
| | | } |
New file |
| | |
| | | package com.dy.pipIrrProject.video; |
| | | |
| | | import com.dy.pipIrrGlobal.pojoVi.ViCamera; |
| | | import io.swagger.v3.oas.annotations.media.Schema; |
| | | import jakarta.validation.constraints.NotEmpty; |
| | | import lombok.Data; |
| | | |
| | | /** |
| | | * @Author: liurunyu |
| | | * @Date: 2025/6/9 10:18 |
| | | * @Description |
| | | */ |
| | | @Data |
| | | @Schema(name = "摄像机(视频站)") |
| | | public class CameraDto { |
| | | public static final long serialVersionUID = 202506091020001L; |
| | | /** |
| | | * 主键 |
| | | */ |
| | | public String id; |
| | | |
| | | /** |
| | | * 类型(1萤石) |
| | | */ |
| | | @NotEmpty(message = "摄像机类型不能为空") //不能为空也不能为null |
| | | public Byte type; |
| | | |
| | | /** |
| | | * 摄像机序列号 |
| | | */ |
| | | @NotEmpty(message = "摄像机类型不能为空") //不能为空也不能为null |
| | | public String devNo; |
| | | |
| | | /** |
| | | * 视频站名称 |
| | | */ |
| | | @NotEmpty(message = "视频站名称不能为空") //不能为空也不能为null |
| | | public String name; |
| | | |
| | | /** |
| | | * 经度 |
| | | */ |
| | | public Double lng; |
| | | |
| | | /** |
| | | * 纬度 |
| | | */ |
| | | public Double lat; |
| | | |
| | | /** |
| | | * 是否大屏展示(1是,0或null否) |
| | | */ |
| | | public Byte onScreen; |
| | | |
| | | /** |
| | | * 大屏展示排序(大于等于1,数字越小排序越前) |
| | | */ |
| | | public Integer onSort; |
| | | |
| | | /** |
| | | * 备注 |
| | | */ |
| | | public String remark; |
| | | |
| | | public ViCamera toNewPo(){ |
| | | ViCamera po = new ViCamera(); |
| | | po.type = this.type; |
| | | po.devNo = this.devNo; |
| | | po.name = this.name; |
| | | po.lng = this.lng; |
| | | po.lat = this.lat; |
| | | po.onScreen = this.onScreen; |
| | | po.onSort = this.onSort; |
| | | po.remark = this.remark; |
| | | return po; |
| | | } |
| | | public ViCamera toPo(){ |
| | | ViCamera po = this.toNewPo(); |
| | | po.id = Long.parseLong(this.id) ; |
| | | return po; |
| | | } |
| | | } |
New file |
| | |
| | | package com.dy.pipIrrProject.video; |
| | | |
| | | import com.dy.common.webUtil.QueryConditionVo; |
| | | import io.swagger.v3.oas.annotations.media.Schema; |
| | | import lombok.*; |
| | | |
| | | /** |
| | | * @Author: liurunyu |
| | | * @Date: 2025/6/9 9:03 |
| | | * @Description |
| | | */ |
| | | @Data |
| | | @EqualsAndHashCode(callSuper = false) |
| | | @ToString(callSuper = true) |
| | | @NoArgsConstructor |
| | | @AllArgsConstructor |
| | | @Builder |
| | | @Schema(name = "视频监控查询条件") |
| | | public class CameraQo extends QueryConditionVo { |
| | | @Schema(description = "名称(地址)") |
| | | public String name; |
| | | } |
New file |
| | |
| | | package com.dy.pipIrrProject.video; |
| | | |
| | | import com.dy.common.webUtil.QueryResultVo; |
| | | import com.dy.pipIrrGlobal.daoVi.ViCameraMapper; |
| | | import com.dy.pipIrrGlobal.pojoVi.ViCamera; |
| | | import com.dy.pipIrrGlobal.voVi.VoCamera; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.apache.dubbo.common.utils.PojoUtils; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.stereotype.Service; |
| | | import org.springframework.transaction.annotation.Transactional; |
| | | |
| | | import java.util.List; |
| | | import java.util.Map; |
| | | |
| | | /** |
| | | * @Author: liurunyu |
| | | * @Date: 2025/6/9 9:01 |
| | | * @Description |
| | | */ |
| | | @Slf4j |
| | | @Service |
| | | public class CameraSv { |
| | | |
| | | @Autowired |
| | | private ViCameraMapper dao; |
| | | |
| | | /** |
| | | * 根据指定条件获取实体记录 |
| | | * @param queryQo 查询条件值对象 |
| | | * @return 实体记录列表 |
| | | */ |
| | | public QueryResultVo<List<VoCamera>> some(CameraQo queryQo) { |
| | | Map<String, Object> params = (Map<String, Object>) PojoUtils.generalize(queryQo); |
| | | Long itemTotal = dao.selectTotal(params); |
| | | |
| | | QueryResultVo<List<VoCamera>> rsVo = new QueryResultVo<>(); |
| | | rsVo.pageSize = queryQo.pageSize; |
| | | rsVo.pageCurr = queryQo.pageCurr; |
| | | rsVo.calculateAndSet(itemTotal, params); |
| | | rsVo.obj = dao.selectSome(params); |
| | | return rsVo; |
| | | } |
| | | |
| | | |
| | | /** |
| | | * 得到一个实体 |
| | | * @param id 实体ID |
| | | * @return 实体 |
| | | */ |
| | | public ViCamera selectById(Long id){ |
| | | return this.dao.selectById(id) ; |
| | | } |
| | | /** |
| | | * 保存(添加)视频监控点 |
| | | * @param po |
| | | * @return |
| | | */ |
| | | @Transactional |
| | | Integer save(ViCamera po) { |
| | | return dao.insert(po); |
| | | } |
| | | |
| | | /** |
| | | * 修改实体 |
| | | * @param po 实体 |
| | | * @return 数量 |
| | | */ |
| | | @Transactional |
| | | public int update(ViCamera po) { |
| | | return this.dao.updateByPrimaryKeySelective(po); |
| | | } |
| | | |
| | | /** |
| | | * 保存修改实体 |
| | | * @param id 实体ID |
| | | * @return 影响记录数量 |
| | | */ |
| | | @Transactional |
| | | public int delete(Long id){ |
| | | return this.dao.deleteLogicById(id) ; |
| | | } |
| | | |
| | | } |
New file |
| | |
| | | package com.dy.pipIrrProject.video; |
| | | |
| | | import lombok.Data; |
| | | |
| | | /** |
| | | * @Author: liurunyu |
| | | * @Date: 2025/6/9 9:37 |
| | | * @Description |
| | | */ |
| | | @Data |
| | | public class TypesVo { |
| | | public Integer type ; |
| | | public String name ; |
| | | } |
New file |
| | |
| | | package com.dy.pipIrrRemote.video; |
| | | |
| | | import com.dy.common.webUtil.QueryConditionVo; |
| | | import io.swagger.v3.oas.annotations.media.Schema; |
| | | import lombok.*; |
| | | |
| | | /** |
| | | * @Author: liurunyu |
| | | * @Date: 2025/6/9 9:03 |
| | | * @Description |
| | | */ |
| | | @Data |
| | | @EqualsAndHashCode(callSuper = false) |
| | | @ToString(callSuper = true) |
| | | @NoArgsConstructor |
| | | @AllArgsConstructor |
| | | @Builder |
| | | @Schema(name = "视频监控查询条件") |
| | | public class CameraQo extends QueryConditionVo { |
| | | } |
New file |
| | |
| | | package com.dy.pipIrrRemote.video; |
| | | |
| | | import com.dy.common.aop.SsoAop; |
| | | import com.dy.common.webUtil.BaseResponse; |
| | | import com.dy.common.webUtil.BaseResponseUtils; |
| | | import com.dy.common.webUtil.QueryResultVo; |
| | | import com.dy.common.webUtil.ResultCodeMsg; |
| | | import com.dy.pipIrrGlobal.pojoVi.ViYsApp; |
| | | import com.dy.pipIrrGlobal.util.CameraTypeEnum; |
| | | import com.dy.pipIrrGlobal.voVi.VoCamera; |
| | | import io.swagger.v3.oas.annotations.Operation; |
| | | import io.swagger.v3.oas.annotations.media.Content; |
| | | import io.swagger.v3.oas.annotations.media.Schema; |
| | | import io.swagger.v3.oas.annotations.responses.ApiResponse; |
| | | import io.swagger.v3.oas.annotations.responses.ApiResponses; |
| | | import io.swagger.v3.oas.annotations.tags.Tag; |
| | | import lombok.RequiredArgsConstructor; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.beans.factory.annotation.Value; |
| | | import org.springframework.http.MediaType; |
| | | import org.springframework.web.bind.annotation.PostMapping; |
| | | import org.springframework.web.bind.annotation.RequestMapping; |
| | | import org.springframework.web.bind.annotation.RestController; |
| | | |
| | | import java.util.ArrayList; |
| | | import java.util.List; |
| | | |
| | | /** |
| | | * @Author: liurunyu |
| | | * @Date: 2025/6/9 10:34 |
| | | * @Description |
| | | */ |
| | | @Slf4j |
| | | @Tag(name = "视频监控", description = "视频监控") |
| | | @RestController |
| | | @RequestMapping(path = "video") |
| | | @RequiredArgsConstructor |
| | | public class VideoCtrl { |
| | | private VideoSv sv; |
| | | private YsAppSv ysSv; |
| | | |
| | | @Value("${video.screen.count: 4}") |
| | | private Integer pageSize;//每页显示条数 |
| | | |
| | | @Value("${video.ys.requestVideoCommonUrl: https://open.ys7.com/console/jssdk/pc.html}") |
| | | private String requestVideoCommonUrl;// |
| | | @Value("${video.ys.requestVideoCameraPreUrl: ezopen://open.ys7.com/}") |
| | | private String requestVideoCameraPreUrl;// |
| | | @Value("${video.ys.requestVideoCameraTailUrl: /1.live&themeId=}") |
| | | private String requestVideoCameraTailUrl;// |
| | | |
| | | @Autowired |
| | | private void setSv(VideoSv sv, YsAppSv ysSv){ |
| | | this.sv = sv ; |
| | | this.ysSv = ysSv ; |
| | | } |
| | | |
| | | |
| | | /** |
| | | * 客户端请求得到一些摄像机数据 |
| | | * @return 所有摄像机数据 |
| | | */ |
| | | @Operation(summary = "获得一页摄像机数据", description = "返回一页摄像机数据数据") |
| | | @ApiResponses(value = { |
| | | @ApiResponse( |
| | | responseCode = ResultCodeMsg.RsCode.SUCCESS_CODE, |
| | | description = "返回一页摄像机数据(BaseResponse.content:QueryResultVo[{}])", |
| | | content = {@Content(mediaType = MediaType.APPLICATION_JSON_VALUE, |
| | | schema = @Schema(implementation = VoCamera.class))} |
| | | ) |
| | | }) |
| | | @PostMapping(path = "some", consumes = MediaType.APPLICATION_JSON_VALUE) |
| | | @SsoAop() |
| | | public BaseResponse<QueryResultVo<List<VoVideo>>> some(CameraQo queryQo){ |
| | | try { |
| | | ViYsApp ysApp = this.ysSv.selectSingleton() ; |
| | | if(ysApp == null){ |
| | | //remote模块的自动任务可能清空了,所以再查询一次 |
| | | ysApp = this.ysSv.selectSingleton() ; |
| | | } |
| | | List<VoVideo> list = new ArrayList<>() ; |
| | | QueryResultVo<List<VoCamera>> resTmp = this.sv.some(queryQo, pageSize) ; |
| | | if(resTmp != null && resTmp.obj != null){ |
| | | for(VoCamera vo : resTmp.obj){ |
| | | VoVideo vvo = new VoVideo() ; |
| | | vvo.id = vo.id ; |
| | | vvo.name = vo.name ; |
| | | if(ysApp != null && vo.type != null && vo.type.byteValue() == CameraTypeEnum.YINGSHI.getType().byteValue()){ |
| | | //萤石 |
| | | StringBuilder sb = new StringBuilder(); |
| | | sb.append(requestVideoCommonUrl); |
| | | sb.append("?accessToken="); |
| | | sb.append(ysApp.accessToken); |
| | | sb.append("&url="); |
| | | sb.append(requestVideoCameraPreUrl); |
| | | sb.append(vo.devNo); |
| | | sb.append(requestVideoCameraTailUrl); |
| | | vvo.videoUrl4Simple = sb.toString() + "simple"; |
| | | vvo.videoUrl4Standard = sb.toString() + "standard" ; |
| | | vvo.videoUrl4Security = sb.toString() + "security" ; |
| | | }else{ |
| | | vvo.videoUrl4Simple = "" ; |
| | | vvo.videoUrl4Standard = "" ; |
| | | vvo.videoUrl4Security = "" ; |
| | | } |
| | | } |
| | | } |
| | | QueryResultVo<List<VoVideo>> res = new QueryResultVo<>() ; |
| | | resTmp.copyTo(res); |
| | | res.obj = list ; |
| | | return BaseResponseUtils.buildSuccess(res); |
| | | } catch (Exception e) { |
| | | log.error("查询摄像机异常", e); |
| | | return BaseResponseUtils.buildException(e.getMessage()) ; |
| | | } |
| | | } |
| | | } |
New file |
| | |
| | | package com.dy.pipIrrRemote.video; |
| | | |
| | | import com.dy.common.webUtil.QueryResultVo; |
| | | import com.dy.pipIrrGlobal.daoVi.ViCameraMapper; |
| | | import com.dy.pipIrrGlobal.voVi.VoCamera; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.apache.dubbo.common.utils.PojoUtils; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.stereotype.Service; |
| | | |
| | | import java.util.List; |
| | | import java.util.Map; |
| | | |
| | | /** |
| | | * @Author: liurunyu |
| | | * @Date: 2025/6/9 10:42 |
| | | * @Description |
| | | */ |
| | | @Slf4j |
| | | @Service |
| | | public class VideoSv { |
| | | |
| | | @Autowired |
| | | private ViCameraMapper dao; |
| | | |
| | | /** |
| | | * 根据指定条件获取实体记录 |
| | | * @param queryQo 查询条件值对象 |
| | | * @return 实体记录列表 |
| | | */ |
| | | public QueryResultVo<List<VoCamera>> some(CameraQo queryQo, int pageSize) { |
| | | Map<String, Object> params = (Map<String, Object>) PojoUtils.generalize(queryQo); |
| | | Long itemTotal = dao.selectTotal(params); |
| | | |
| | | QueryResultVo<List<VoCamera>> rsVo = new QueryResultVo<>(); |
| | | rsVo.pageSize = pageSize; |
| | | rsVo.pageCurr = queryQo.pageCurr; |
| | | rsVo.calculateAndSet(itemTotal, params); |
| | | rsVo.obj = dao.selectSome(params); |
| | | return rsVo; |
| | | } |
| | | |
| | | |
| | | } |
New file |
| | |
| | | package com.dy.pipIrrRemote.video; |
| | | |
| | | import com.alibaba.fastjson2.annotation.JSONField; |
| | | import com.alibaba.fastjson2.writer.ObjectWriterImplToString; |
| | | import lombok.Data; |
| | | |
| | | /** |
| | | * @Author: liurunyu |
| | | * @Date: 2025/6/9 10:57 |
| | | * @Description |
| | | */ |
| | | @Data |
| | | public class VoVideo { |
| | | @JSONField(serializeUsing= ObjectWriterImplToString.class) |
| | | public Long id ; |
| | | public String name ; |
| | | public String videoUrl4Simple ; |
| | | public String videoUrl4Standard ; |
| | | public String videoUrl4Security ; |
| | | } |
| | |
| | | private static final Integer ThreadPoolPriority = 5 ;//线程优先级 |
| | | private static final boolean quartzJobRunOneTimes = true ;//定时任务只执行一次 |
| | | |
| | | @Value("${ys.accessTokenExpireDay: 7}") |
| | | @Value("${video.ys.accessTokenExpireDay: 7}") |
| | | protected Integer accessTokenExpireDay;//AccessToken过期时间,单位天 |
| | | |
| | | @Value("${ys.appKey}") |
| | | @Value("${video.ys.appKey}") |
| | | protected String appKey; |
| | | |
| | | @Value("${ys.secret}") |
| | | @Value("${video.ys.secret}") |
| | | protected String secret; |
| | | |
| | | @Value("${ys.requestAccessTokenUrl}") |
| | | @Value("${video.ys.requestAccessTokenUrl}") |
| | | protected String requestAccessTokenUrl; |
| | | |
| | | @Autowired |