文件删除

服务修改

web/src/main/java/com/leaper/web/controller/TestController.java

@@ -1,5 +1,11 @@
 package com.leaper.web.controller;
 
+import com.leaper.web.lib.CameraConnMap;
+import com.leaper.web.lib.hik.HCNetSDK;
+import com.leaper.web.lib.hik.HikLoginModuleImpl;
+import com.sun.jna.Memory;
+import com.sun.jna.Pointer;
+import com.sun.jna.ptr.IntByReference;
 import com.zhehekeji.core.pojo.Result;
 import com.leaper.web.service.TestService;
 import io.swagger.annotations.Api;
@@ -8,6 +14,8 @@ import org.springframework.web.bind.annotation.*;
 
 import javax.annotation.Resource;
 
+import static com.leaper.web.lib.hik.HCNetSDK.NET_DVR_GET_PTZPOS;
+
 @Api(value = "TestController",tags = "扫码测试")
 @RequestMapping("/test")
 @RestController
@@ -29,6 +37,33 @@ public class TestController {
 
         return Result.success();
     }
+    @GetMapping("getCremareInfo")
+    public Result getCremareInfo(){
+        HCNetSDK.NET_DVR_PTZPOS ptzpos = new HCNetSDK.NET_DVR_PTZPOS();
+        Pointer pointer =  ptzpos.getPointer();
+        IntByReference pInt = new IntByReference(1);
+        int lUserId = CameraConnMap.getConnId(1).intValue();
+        Boolean ok =  HikLoginModuleImpl.hcNetsdk.NET_DVR_GetDVRConfig(lUserId,293,1,pointer,ptzpos.size(),pInt);
+        if (ok == false) {
+            System.out.println("获取参数失败  错误码：" + HikLoginModuleImpl.hcNetsdk.NET_DVR_GetLastError());
+        }
+        ptzpos.read();
+        return Result.success(ptzpos.toString());
+    }
 
+    @GetMapping("setCremareInfo")
+    public Result setCremareInfo(){
+        HCNetSDK.NET_DVR_PTZPOS ptzpos = new HCNetSDK.NET_DVR_PTZPOS();
+        ptzpos.wAction = 1;
+        ptzpos.wPanPos=16;
+        ptzpos.wTiltPos = 0;
+        ptzpos.wZoomPos = 0x1100;
+        ptzpos.write();
+        Boolean ok =  HikLoginModuleImpl.hcNetsdk.NET_DVR_SetDVRConfig(CameraConnMap.getConnId(1).intValue(),292,1,ptzpos.getPointer(),ptzpos.size());
+        if (ok == false) {
+            System.out.println("获取参数失败  错误码：" + HikLoginModuleImpl.hcNetsdk.NET_DVR_GetLastError());
+        }
+        return Result.success(ptzpos.toString());
+    }
 
-}
+}

web/src/main/java/com/leaper/web/lib/hik/HCNetSDK.java

@@ -3134,6 +3134,10 @@ DVR实现巡航数据结构
         public  short wPanPos;//水平参数
         public  short wTiltPos;//垂直参数
         public  short wZoomPos;//变倍参数
+        protected List getFieldOrder() {
+// TODO Auto-generated method stub
+            return Arrays.asList("wAction","wPanPos","wTiltPos","wZoomPos"); //这里参数顺序和SDK开发包的C++定义必须完全一致
+        }
     }
 
     //球机范围信息

web/src/main/java/com/leaper/web/service/FtpsUtils.java

@@ -98,6 +98,7 @@ public class FtpsUtils {
             picData.setUrl(targetFilePath);
             picData.setCreateTime(LocalDateTime.now());
             picDataMapper.insert(picData);
+            file.delete();
             //deleteFileSrc(file);
             //create a folder
             //sftpClient.mkdir("/data");
@@ -149,41 +150,5 @@ public class FtpsUtils {
             dir.delete();
         }
     }
-//    }
-//    public void deleteFile(){
-//        SSHClient ssh = new SSHClient();
-//        SFTPClient sftpClient = null;
-//        try {
-//            //ssh.loadKnownHosts(); to skip host verification
-//            ssh.addHostKeyVerifier(new PromiscuousVerifier());
-//            ssh.connect(this.hostName);
-//            ssh.authPassword(username, password);
-//            sftpClient = ssh.newSFTPClient();
-//
-//            sftpClient.mkdirs(targetFilePath.substring(0,targetFilePath.lastIndexOf("/")));//创建多级文件夹
-//            sftpClient.rm( targetFilePath);
-//            //create a folder
-//            //sftpClient.mkdir("/data");
-//            //sftpClient.rmdir("");重命名文件夹
-//            //List<RemoteResourceInfo>  s = sftpClient.ls("/"); //列出当前目录
-//            //System.out.println(s);
-//        } catch (IOException e) {
-//            log.error(e.getMessage(), e);
-//        } finally {
-//            if (null != sftpClient) {
-//                try {
-//                    sftpClient.close();
-//                } catch (IOException e) {
-//                    log.error(e.getMessage(), e);
-//                }
-//            }
-//            try {
-//                ssh.disconnect();
-//            } catch (IOException e) {
-//                log.error(e.getMessage(), e);
-//            }
-//        }
-//    }
-
 
 }

web/src/main/java/com/leaper/web/service/sftp/SftpHelper.java

@@ -186,5 +186,4 @@ public class SftpHelper {
             pool.returnObject(sftp);
         }
     }
-}
+}
-

web/src/main/java/com/leaper/web/service/test/MyServerHandler.java

@@ -0,0 +1,33 @@
+package com.leaper.web.service.test;
+
+import io.netty.buffer.ByteBuf;
+import io.netty.buffer.Unpooled;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.channel.ChannelInboundHandlerAdapter;
+import io.netty.util.CharsetUtil;
+
+/**
+ * 自定义的Handler需要继承Netty规定好的HandlerAdapter
+ * 才能被Netty框架所关联，有点类似SpringMVC的适配器模式
+ **/
+public class MyServerHandler extends ChannelInboundHandlerAdapter {
+
+    @Override
+    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
+        //获取客户端发送过来的消息
+        ByteBuf byteBuf = (ByteBuf) msg;
+        System.out.println("收到客户端" + ctx.channel().remoteAddress() + "发送的消息：" + byteBuf.toString(CharsetUtil.UTF_8));
+    }
+
+    @Override
+    public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
+        //发送消息给客户端
+        ctx.writeAndFlush(Unpooled.copiedBuffer("服务端已收到消息，并给你发送一个问号?", CharsetUtil.UTF_8));
+    }
+
+    @Override
+    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
+        //发生异常，关闭通道
+        ctx.close();
+    }
+}

web/src/main/java/com/leaper/web/service/test/MyService.java

@@ -0,0 +1,46 @@
+package com.leaper.web.service.test;
+
+import io.netty.bootstrap.ServerBootstrap;
+import io.netty.channel.ChannelFuture;
+import io.netty.channel.ChannelInitializer;
+import io.netty.channel.ChannelOption;
+import io.netty.channel.EventLoopGroup;
+import io.netty.channel.nio.NioEventLoopGroup;
+import io.netty.channel.socket.SocketChannel;
+import io.netty.channel.socket.nio.NioServerSocketChannel;
+
+public class MyService {
+    public static void main(String[] args) throws Exception {
+        //创建两个线程组 boosGroup、workerGroup
+        EventLoopGroup bossGroup = new NioEventLoopGroup();
+        EventLoopGroup workerGroup = new NioEventLoopGroup();
+        try {
+            //创建服务端的启动对象，设置参数
+            ServerBootstrap bootstrap = new ServerBootstrap();
+            //设置两个线程组boosGroup和workerGroup
+            bootstrap.group(bossGroup, workerGroup)
+                    //设置服务端通道实现类型
+                    .channel(NioServerSocketChannel.class)
+                    //设置线程队列得到连接个数
+                    .option(ChannelOption.SO_BACKLOG, 128)
+                    //设置保持活动连接状态
+                    .childOption(ChannelOption.SO_KEEPALIVE, true)
+                    //使用匿名内部类的形式初始化通道对象
+                    .childHandler(new ChannelInitializer<SocketChannel>() {
+                        @Override
+                        protected void initChannel(SocketChannel socketChannel) throws Exception {
+                            //给pipeline管道设置处理器
+                            socketChannel.pipeline().addLast(new MyServerHandler());
+                        }
+                    });//给workerGroup的EventLoop对应的管道设置处理器
+            System.out.println("java技术爱好者的服务端已经准备就绪...");
+            //绑定端口号，启动服务端
+            ChannelFuture channelFuture = bootstrap.bind(6666).sync();
+            //对关闭通道进行监听
+            channelFuture.channel().closeFuture().sync();
+        } finally {
+            bossGroup.shutdownGracefully();
+            workerGroup.shutdownGracefully();
+        }
+    }
+}

web/src/main/resources/application-test.yml

@@ -7,14 +7,14 @@ spring:
     maxWait: 60000
     minEvictableIdleTimeMillis: 300000
     minIdle: 15
-    password: Leaper@123
+    password: root
     poolPreparedStatements: true
     testOnBorrow: true
     testOnReturn: false
     testWhileIdle: false
     timeBetweenEvictionRunsMillis: 60000
     type: com.alibaba.druid.pool.DruidDataSource
-    url: jdbc:mysql://121.37.95.190:3306/lia_duoji?useUnicode=true&characterEncoding=utf8&useSSL=false&serverTimezone=GMT%2B8
+    url: jdbc:mysql://127.0.0.1:3306/lia_duoji?useUnicode=true&characterEncoding=utf8&useSSL=false&serverTimezone=GMT%2B8
     username: root
     validationQuery: SELECT 1 FROM DUAL
 #--------------