百度离线人脸识别SDK

1，采坑备忘

（1）8.1版本的SDK在spring-boot接口访问第一次正常，第二次之后JVM会奔溃，可能是java gc 处理C++开出的内存有问题。

        换6.1.3版本的SDK。

java+Windows百度离线人脸识别SDK6.1.3-Java文档类资源-CSDN下载java+Windows百度离线人脸识别SDK6.1.3。支持spring-boot集成。更多下载资源、学习资料请访问CSDN下载频道.https://download.csdn.net/download/zj850324/87347677

（2）6.1.3版本SDK无法加载BaiduFaceApi.dll。依赖vc_redist.x64 2013，包里给的是2015。

javaOpenCV320依赖的动态链接库-Java文档类资源-CSDN下载javaOpenCV320依赖的动态链接库更多下载资源、学习资料请访问CSDN下载频道.https://download.csdn.net/download/zj850324/87283565

2，spring-boot项目示例

（1）pom.xml

  

   

    

     

    
    

     

      <?xml version="1.0" encoding="UTF-8"?>
     
    
   

    

     

    
    

     

      <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
     
    
   

    

     

    
    

     
	
      xsi:schemaLocation=
      "http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
     
    
   

    

     

    
    

     
	
      <modelVersion>4.0.0
      </modelVersion>
     
    
   

    

     

    
    

     
	
      <parent>
     
    
   

    

     

    
    

     
		
      <groupId>org.springframework.boot
      </groupId>
     
    
   

    

     

    
    

     
		
      <artifactId>spring-boot-starter-parent
      </artifactId>
     
    
   

    

     

    
    

     
		
      <version>2.3.3.RELEASE
      </version>
     
    
   

    

     

    
    

     
		
      <relativePath/> 
      <!-- lookup parent from repository -->
     
    
   

    

     

    
    

     
	
      </parent>
     
    
   

    

     

    
    

     
	
      <groupId>com.ai
      </groupId>
     
    
   

    

     

    
    

     
	
      <artifactId>risun-ai
      </artifactId>
     
    
   

    

     

    
    

     
	
      <version>0.0.1-SNAPSHOT
      </version>
     
    
   

    

     

    
    

     
	
      <name>risun-ai
      </name>
     
    
   

    

     

    
    

     
	
      <description>Demo project for Spring Boot
      </description>
     
    
   

    

     

    
    

     
	
      <properties>
     
    
   

    

     

    
    

     
		
      <java.version>1.8
      </java.version>
     
    
   

    

     

    
    

     
	
      </properties>
     
    
   

    

     

    
    

     
	
     
    
   

    

     

    
    

     
	
      <repositories>
     
    
   

    

     

    
    

     
        
      <repository>
     
    
   

    

     

    
    

     
            
      <id>huaweicloud
      </id>
     
    
   

    

     

    
    

     
            
      <url>https://repo.huaweicloud.com/repository/maven/
      </url>
     
    
   

    

     

    
    

     
            
      <!--<url>http://maven.aliyun.com/nexus/content/groups/public/</url>-->
     
    
   

    

     

    
    

     
            
      <releases>
     
    
   

    

     

    
    

     
                
      <enabled>true
      </enabled>
     
    
   

    

     

    
    

     
            
      </releases>
     
    
   

    

     

    
    

     
            
      <snapshots>
     
    
   

    

     

    
    

     
                
      <enabled>true
      </enabled>
     
    
   

    

     

    
    

     
                
      <updatePolicy>always
      </updatePolicy>
     
    
   

    

     

    
    

     
                
      <checksumPolicy>fail
      </checksumPolicy>
     
    
   

    

     

    
    

     
            
      </snapshots>
     
    
   

    

     

    
    

     
        
      </repository>
     
    
   

    

     

    
    

     
    
      </repositories>
     
    
   

    

     

    
    

     
    
     
    
   

    

     

    
    

     
	
      <dependencies>
     
    
   

    

     

    
    

     
	    
      <dependency>
     
    
   

    

     

    
    

     
		    
      <groupId>javax.servlet
      </groupId>
     
    
   

    

     

    
    

     
		    
      <artifactId>javax.servlet-api
      </artifactId>
     
    
   

    

     

    
    

     
		    
      <scope>provided
      </scope>
     
    
   

    

     

    
    

     
		
      </dependency>
     
    
   

    

     

    
    

     
		
      <dependency>
     
    
   

    

     

    
    

     
			
      <groupId>org.springframework.boot
      </groupId>
     
    
   

    

     

    
    

     
			
      <artifactId>spring-boot-starter
      </artifactId>
     
    
   

    

     

    
    

     
		
      </dependency>
     
    
   

    

     

    
    

     
		
     
    
   

    

     

    
    

     
		
      <dependency>
     
    
   

    

     

    
    

     
            
      <groupId>org.springframework.boot
      </groupId>
     
    
   

    

     

    
    

     
            
      <artifactId>spring-boot-starter-web
      </artifactId>
     
    
   

    

     

    
    

     
        
      </dependency>
     
    
   

    

     

    
    

     
        
     
    
   

    

     

    
    

     
		
      <dependency>
     
    
   

    

     

    
    

     
			
      <groupId>org.springframework.boot
      </groupId>
     
    
   

    

     

    
    

     
			
      <artifactId>spring-boot-starter-test
      </artifactId>
     
    
   

    

     

    
    

     
			
      <scope>test
      </scope>
     
    
   

    

     

    
    

     
		
      </dependency>
     
    
   

    

     

    
    

     
		
     
    
   

    

     

    
    

     
		
      <dependency>
     
    
   

    

     

    
    

     
		   
      <groupId>io.springfox
      </groupId>
     
    
   

    

     

    
    

     
		   
      <artifactId>springfox-swagger2
      </artifactId>
     
    
   

    

     

    
    

     
		   
      <version>2.9.2
      </version>
     
    
   

    

     

    
    

     
		
      </dependency>
     
    
   

    

     

    
    

     
		
      <dependency>
     
    
   

    

     

    
    

     
		   
      <groupId>io.springfox
      </groupId>
     
    
   

    

     

    
    

     
		   
      <artifactId>springfox-swagger-ui
      </artifactId>
     
    
   

    

     

    
    

     
		   
      <version>2.9.2
      </version>
     
    
   

    

     

    
    

     
		
      </dependency>
     
    
   

    

     

    
    

     
        
     
    
   

    

     

    
    

     
		
      <!-- https://mvnrepository.com/artifact/org.projectlombok/lombok -->
     
    
   

    

     

    
    

     
		
      <dependency>
     
    
   

    

     

    
    

     
		    
      <groupId>org.projectlombok
      </groupId>
     
    
   

    

     

    
    

     
		    
      <artifactId>lombok
      </artifactId>
     
    
   

    

     

    
    

     
		    
      <version>1.18.22
      </version>
     
    
   

    

     

    
    

     
		    
      <scope>provided
      </scope>
     
    
   

    

     

    
    

     
		
      </dependency>
     
    
   

    

     

    
    

     
		
     
    
   

    

     

    
    

     
		
      <dependency>
     
    
   

    

     

    
    

     
		    
      <groupId>com.baidu.aip
      </groupId>
     
    
   

    

     

    
    

     
		    
      <artifactId>java-sdk
      </artifactId>
     
    
   

    

     

    
    

     
		    
      <version>4.15.1
      </version>
     
    
   

    

     

    
    

     
		
      </dependency>
     
    
   

    

     

    
    

     
		
      <dependency>
     
    
   

    

     

    
    

     
			
      <groupId>com.google.code.gson
      </groupId>
     
    
   

    

     

    
    

     
			
      <artifactId>gson
      </artifactId>
     
    
   

    

     

    
    

     
			
      <version>2.8.3
      </version>
     
    
   

    

     

    
    

     
		
      </dependency>
     
    
   

    

     

    
    

     
		
      <dependency>
     
    
   

    

     

    
    

     
		  
      <groupId>com.google.code.gson
      </groupId>
     
    
   

    

     

    
    

     
		  
      <artifactId>gson
      </artifactId>
     
    
   

    

     

    
    

     
		  
      <version>2.8.5
      </version>
     
    
   

    

     

    
    

     
		
      </dependency>
     
    
   

    

     

    
    

     
		
     
    
   

    

     

    
    

     
		 
      <dependency>
     
    
   

    

     

    
    

     
            
      <groupId>org.apache.httpcomponents
      </groupId>
     
    
   

    

     

    
    

     
            
      <artifactId>httpclient
      </artifactId>
     
    
   

    

     

    
    

     
            
      <version>4.5.2
      </version>
     
    
   

    

     

    
    

     
        
      </dependency>
     
    
   

    

     

    
    

     
        
     
    
   

    

     

    
    

     
	
      </dependencies>
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     
	
      <build>
     
    
   

    

     

    
    

     
		
      <plugins>
     
    
   

    

     

    
    

     
			
      <plugin>
     
    
   

    

     

    
    

     
				
      <groupId>org.springframework.boot
      </groupId>
     
    
   

    

     

    
    

     
				
      <artifactId>spring-boot-maven-plugin
      </artifactId>
     
    
   

    

     

    
    

     
			
      </plugin>
     
    
   

    

     

    
    

     
		
      </plugins>
     
    
   

    

     

    
    

     
	
      </build>
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      </project>
     
    
  
 

  
 

（2）启动

  

   

    

     

    
    

     

      package com;
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      import org.springframework.boot.SpringApplication;
     
    
   

    

     

    
    

     

      import org.springframework.boot.autoconfigure.SpringBootApplication;
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      import com.ai.local.FaceLocalFactory;
     
    
   

    

     

    
    

     

      import com.jni.face.Face;
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      @SpringBootApplication
     
    
   

    

     

    
    

     

      public 
      class 
      RisunAiApplication {
     
    
   

    

     

    
    

     
	
      public 
      static 
      void 
      main
      (String[] args) {
     
    
   

    

     

    
    

     
		
      //FaceLocalFactory.sdkInit();
     
    
   

    

     

    
    

     
		
      //Face.loadDbFace();
     
    
   

    

     

    
    

     

      		SpringApplication.run(RisunAiApplication.class, args);
     
    
   

    

     

    
    

     

      		System.out.println(
      ":::主线程启动");
     
    
   

    

     

    
    

     

      	}
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      }
     
    
  
 

  
 

  

   

    

     

    
    

     

      package com;
     
    
   

    

     

    
    

     

      /**
     
    
   

    

     

    
    

     

      *@author created by Jerry
     
    
   

    

     

    
    

     

      *@date 2022年12月23日---下午4:51:37
     
    
   

    

     

    
    

     

      *@problem
     
    
   

    

     

    
    

     

      *@answer
     
    
   

    

     

    
    

     

      *@action
     
    
   

    

     

    
    

     

      */
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      import com.jni.face.Face;
     
    
   

    

     

    
    

     

      import org.springframework.boot.ApplicationArguments;
     
    
   

    

     

    
    

     

      import org.springframework.boot.ApplicationRunner;
     
    
   

    

     

    
    

     

      import org.springframework.stereotype.Component;
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      @Component
     
    
   

    

     

    
    

     

      public 
      class 
      SdkInit 
      implements 
      ApplicationRunner{
     
    
   

    

     

    
    

     
    
      @Override
     
    
   

    

     

    
    

     
    
      public 
      void 
      run
      (ApplicationArguments applicationArguments) 
      throws Exception{
     
    
   

    

     

    
    

     
        
      /* sdk初始化 */
     
    
   

    

     

    
    

     
        
      Face 
      api 
      = 
      new 
      Face();
     
    
   

    

     

    
    

     
        
      // model_path为模型文件夹路径，即models文件夹（里面存的是人脸识别的模型文件）
     
    
   

    

     

    
    

     
        
      // 传空为采用默认路径，若想定置化路径，请填写全局路径如：d:\\face （models模型文件夹目录放置后为d:\\face\\models）
     
    
   

    

     

    
    

     
        
      // 若模型文件夹采用定置化路径，则激活文件(license.ini, license.key)也可采用定制化路径放置到该目录如d:\\face\\license
     
    
   

    

     

    
    

     
        
      // 亦可在激活文件默认生成的路径
     
    
   

    

     

    
    

     
        
      String 
      modelPath 
      =
      "";
     
    
   

    

     

    
    

     
        
      int 
      res 
      = api.sdkInit(modelPath);
     
    
   

    

     

    
    

     
        
      if (res != 
      0) {
     
    
   

    

     

    
    

     

                  System.out.printf(
      "sdk init fail and error =%d\n", res);
     
    
   

    

     

    
    

     

              }
     
    
   

    

     

    
    

     
        
     
    
   

    

     

    
    

     

              Face.loadDbFace();
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     
        
      // 获取设备指纹
     
    
   

    

     

    
    

     
        
      String 
      deviceId 
      = Face.getDeviceId();
     
    
   

    

     

    
    

     

              System.out.printf(
      "device id:" + deviceId);
     
    
   

    

     

    
    

     
        
      // 获取版本号
     
    
   

    

     

    
    

     
        
      String 
      ver 
      = Face.sdkVersion();
     
    
   

    

     

    
    

     

              System.out.printf(
      "sdk version:" + ver);
     
    
   

    

     

    
    

     

          }
     
    
   

    

     

    
    

     

      }
     
    
  
 

  
 

  

   

    

     

    
    

     

      package com;
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      import org.slf4j.Logger;
     
    
   

    

     

    
    

     

      import org.slf4j.LoggerFactory;
     
    
   

    

     

    
    

     

      import org.springframework.beans.factory.annotation.Autowired;
     
    
   

    

     

    
    

     

      import org.springframework.beans.factory.annotation.Value;
     
    
   

    

     

    
    

     

      import org.springframework.boot.CommandLineRunner;
     
    
   

    

     

    
    

     

      import org.springframework.stereotype.Component;
     
    
   

    

     

    
    

     

      import com.task.ClearFilesTask;
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      /**
     
    
   

    

     

    
    

     

       * 
     
    
   

    

     

    
    

     

       * @author jerry
     
    
   

    

     

    
    

     

       * 清理垃圾
     
    
   

    

     

    
    

     

       */
     
    
   

    

     

    
    

     

      @Component
     
    
   

    

     

    
    

     

      public 
      class 
      Branch_02 
      implements 
      CommandLineRunner {
     
    
   

    

     

    
    

     
	
      Logger 
      m_log 
      = LoggerFactory.getLogger(getClass());
     
    
   

    

     

    
    

     
	
      @Value("${cacheTime}")
     
    
   

    

     

    
    

     

      	Long m_cacheTime;
     
    
   

    

     

    
    

     
	
     
    
   

    

     

    
    

     
	
      @Autowired
     
    
   

    

     

    
    

     

      	ClearFilesTask m_clearFilesTask;
     
    
   

    

     

    
    

     
	
     
    
   

    

     

    
    

     
	
      @Override
     
    
   

    

     

    
    

     
	
      public 
      void 
      run
      (String... arg0) 
      throws Exception {
     
    
   

    

     

    
    

     
		
      if (m_cacheTime <= 
      0) {
     
    
   

    

     

    
    

     
			
      return;
     
    
   

    

     

    
    

     

      		}
     
    
   

    

     

    
    

     
		
      this.m_log.info(
      ":::清理线程启动");
     
    
   

    

     

    
    

     
		
      Thread 
      thread 
      = 
      new 
      Thread(
      this.m_clearFilesTask);
     
    
   

    

     

    
    

     

      		thread.start();
     
    
   

    

     

    
    

     

      	}
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      }
     
    
  
 

  
 

  

   

    

     

    
    

     

      package com;
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      import org.slf4j.Logger;
     
    
   

    

     

    
    

     

      import org.slf4j.LoggerFactory;
     
    
   

    

     

    
    

     

      import org.springframework.beans.factory.annotation.Autowired;
     
    
   

    

     

    
    

     

      import org.springframework.beans.factory.annotation.Value;
     
    
   

    

     

    
    

     

      import org.springframework.boot.CommandLineRunner;
     
    
   

    

     

    
    

     

      import org.springframework.stereotype.Component;
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      import com.ai.local.FaceLocalFactory;
     
    
   

    

     

    
    

     

      import com.jni.face.Face;
     
    
   

    

     

    
    

     

      import com.task.CamersLocalTask;
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      /**
     
    
   

    

     

    
    

     

       * 
     
    
   

    

     

    
    

     

       * @author jerry
     
    
   

    

     

    
    

     

       * 截图识别 本地离线
     
    
   

    

     

    
    

     

       */
     
    
   

    

     

    
    

     

      @Component
     
    
   

    

     

    
    

     

      public 
      class 
      Branch_04 
      implements 
      CommandLineRunner {
     
    
   

    

     

    
    

     
	
      Logger 
      m_log 
      = LoggerFactory.getLogger(getClass());
     
    
   

    

     

    
    

     
	
     
    
   

    

     

    
    

     
	
      @Value("${rtspLocalScreenshot}")
     
    
   

    

     

    
    

     

      	String rtspLocalScreenshot;
     
    
   

    

     

    
    

     
	
     
    
   

    

     

    
    

     
	
      @Autowired
     
    
   

    

     

    
    

     

      	CamersLocalTask m_camersLocalTask;
     
    
   

    

     

    
    

     
	
     
    
   

    

     

    
    

     
	
      @Override
     
    
   

    

     

    
    

     
	
      public 
      void 
      run
      (String... arg0) 
      throws Exception {
     
    
   

    

     

    
    

     
		
      if (
      this.rtspLocalScreenshot != 
      null && 
      this.rtspLocalScreenshot.equalsIgnoreCase(
      "false")) {
     
    
   

    

     

    
    

     
			
      return;
     
    
   

    

     

    
    

     

      		}
     
    
   

    

     

    
    

     
		
      this.m_log.info(
      ":::本地离线截图识别线程启动");
     
    
   

    

     

    
    

     
		
      Thread 
      thread 
      = 
      new 
      Thread(
      this.m_camersLocalTask);
     
    
   

    

     

    
    

     

      		thread.start();
     
    
   

    

     

    
    

     

      	}
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      }
     
    
  
 

  
 

（3）人脸库管理

  

   

    

     

    
    

     

      package com.controller;
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      import java.io.File;
     
    
   

    

     

    
    

     

      import java.text.SimpleDateFormat;
     
    
   

    

     

    
    

     

      import java.util.Date;
     
    
   

    

     

    
    

     

      import java.util.HashMap;
     
    
   

    

     

    
    

     

      import java.util.Map;
     
    
   

    

     

    
    

     

      import java.util.UUID;
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      import org.springframework.beans.factory.annotation.Autowired;
     
    
   

    

     

    
    

     

      import org.springframework.beans.factory.annotation.Value;
     
    
   

    

     

    
    

     

      import org.springframework.stereotype.Controller;
     
    
   

    

     

    
    

     

      import org.springframework.web.bind.annotation.GetMapping;
     
    
   

    

     

    
    

     

      import org.springframework.web.bind.annotation.PathVariable;
     
    
   

    

     

    
    

     

      import org.springframework.web.bind.annotation.PostMapping;
     
    
   

    

     

    
    

     

      import org.springframework.web.bind.annotation.RequestBody;
     
    
   

    

     

    
    

     

      import org.springframework.web.bind.annotation.RequestMapping;
     
    
   

    

     

    
    

     

      import org.springframework.web.bind.annotation.RequestMethod;
     
    
   

    

     

    
    

     

      import org.springframework.web.bind.annotation.RequestParam;
     
    
   

    

     

    
    

     

      import org.springframework.web.bind.annotation.ResponseBody;
     
    
   

    

     

    
    

     

      import org.springframework.web.multipart.MultipartFile;
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      import com.ai.local.FaceLibLocal;
     
    
   

    

     

    
    

     

      import com.ai.local.entity.UserFace;
     
    
   

    

     

    
    

     

      import com.util.AjaxResult;
     
    
   

    

     

    
    

     

      import com.util.FileUtil;
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      import io.swagger.annotations.Api;
     
    
   

    

     

    
    

     

      import io.swagger.annotations.ApiImplicitParam;
     
    
   

    

     

    
    

     

      import io.swagger.annotations.ApiImplicitParams;
     
    
   

    

     

    
    

     

      import io.swagger.annotations.ApiModelProperty;
     
    
   

    

     

    
    

     

      import io.swagger.annotations.ApiOperation;
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      @Api(value = "FaceLibController", description = "本地人脸库管理接口")
     
    
   

    

     

    
    

     

      @Controller
     
    
   

    

     

    
    

     

      @RequestMapping(value = "/facelib")
     
    
   

    

     

    
    

     

      @ResponseBody
     
    
   

    

     

    
    

     

      public 
      class 
      FaceLibController 
      extends 
      BasicController 
     
    
   

    

     

    
    

     

      {	
     
    
   

    

     

    
    

     
	
      @Autowired
     
    
   

    

     

    
    

     

      	FaceLibLocal m_FaceLibLocal;
     
    
   

    

     

    
    

     
	
     
    
   

    

     

    
    

     
	
      @Value("${upload_path}")
     
    
   

    

     

    
    

     

          String upload_path;
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     
	
      @ApiOperation(value="获取组列表",notes="获取组列表")
     
    
   

    

     

    
    

     
	
      @GetMapping(value = "/getGroupList")
     
    
   

    

     

    
    

     
	
      @ApiImplicitParams({
     
    
   

    

     

    
    

     

       @ApiImplicitParam(name = "pageStart", value = "起始页码", example="0", required = true ,dataType = "int",paramType = "query"),
     
    
   

    

     

    
    

     

       @ApiImplicitParam(name = "pageSize", value = "每页条数", example="10", required = true ,dataType = "int",paramType = "query")
     
    
   

    

     

    
    

     

       })
     
    
   

    

     

    
    

     
    
      public AjaxResult 
      getGroupList
      (@RequestParam(defaultValue = "pageStart") int pageStart, @RequestParam(defaultValue = "pageSize") int pageSize)  
      throws Exception
     
    
   

    

     

    
    

     

          {
     
    
   

    

     

    
    

     
        
      return AjaxResult.success(m_FaceLibLocal.getGroupList(pageStart, pageSize));
     
    
   

    

     

    
    

     

          }
     
    
   

    

     

    
    

     
	
     
    
   

    

     

    
    

     
	
      @ApiOperation(value="添加组",notes="添加组")
     
    
   

    

     

    
    

     
	
      @GetMapping(value = "/addGroup")
     
    
   

    

     

    
    

     
	
      @ApiImplicitParams({
     
    
   

    

     

    
    

     

       @ApiImplicitParam(name = "groupid", value = "组ID", required = true ,dataType = "string",paramType = "query")
     
    
   

    

     

    
    

     

       })
     
    
   

    

     

    
    

     
	
      public AjaxResult 
      addGroup
      (@RequestParam(defaultValue = "groupid") String groupid)  
      throws Exception
     
    
   

    

     

    
    

     

          {
     
    
   

    

     

    
    

     
        
      return AjaxResult.success(m_FaceLibLocal.addGroup(groupid));
     
    
   

    

     

    
    

     

          }
     
    
   

    

     

    
    

     
	
     
    
   

    

     

    
    

     
	
      @ApiOperation(value="删除组",notes="删除组")
     
    
   

    

     

    
    

     
	
      @GetMapping(value = "/removeGroup")
     
    
   

    

     

    
    

     
	
      @ApiImplicitParams({
     
    
   

    

     

    
    

     

       @ApiImplicitParam(name = "groupid", value = "组ID", required = true ,dataType = "string",paramType = "query")
     
    
   

    

     

    
    

     

       })
     
    
   

    

     

    
    

     
	
      public AjaxResult 
      removeGroup
      (@RequestParam(defaultValue = "groupid") String groupid)  
      throws Exception
     
    
   

    

     

    
    

     

          {
     
    
   

    

     

    
    

     
        
      return AjaxResult.success(m_FaceLibLocal.removeGroup(groupid));
     
    
   

    

     

    
    

     

          }
     
    
   

    

     

    
    

     
	
     
    
   

    

     

    
    

     
	
      @ApiOperation(value="获取某组的用户列表",notes="获取某组的用户列表")
     
    
   

    

     

    
    

     
	
      @GetMapping(value = "/getUserList")
     
    
   

    

     

    
    

     
	
      @ApiImplicitParams({
     
    
   

    

     

    
    

     

       @ApiImplicitParam(name = "groupid", value = "组ID", required = true ,dataType = "string",paramType = "query"),
     
    
   

    

     

    
    

     

       @ApiImplicitParam(name = "pageStart", value = "起始页码", example="0", required = true ,dataType = "int",paramType = "query"),
     
    
   

    

     

    
    

     

       @ApiImplicitParam(name = "pageSize", value = "每页条数", example="10", required = true ,dataType = "int",paramType = "query")
     
    
   

    

     

    
    

     

       })
     
    
   

    

     

    
    

     
	
      public AjaxResult 
      getUserList
      (
     
    
   

    

     

    
    

     
			
      @RequestParam(defaultValue = "groupid") String groupid,
     
    
   

    

     

    
    

     
			
      @RequestParam(defaultValue = "pageStart") 
      int pageStart, 
     
    
   

    

     

    
    

     
			
      @RequestParam(defaultValue = "pageSize") 
      int pageSize)  
      throws Exception
     
    
   

    

     

    
    

     

          {
     
    
   

    

     

    
    

     
        
      return AjaxResult.success(m_FaceLibLocal.getUserList(groupid, pageStart, pageSize));
     
    
   

    

     

    
    

     

          }
     
    
   

    

     

    
    

     
	
     
    
   

    

     

    
    

     
	
      @ApiOperation(value="删除用户",notes="删除用户")
     
    
   

    

     

    
    

     
	
      @GetMapping(value = "/removeUser")
     
    
   

    

     

    
    

     
	
      @ApiImplicitParams({
     
    
   

    

     

    
    

     

       @ApiImplicitParam(name = "userid", value = "用户ID", required = true ,dataType = "string",paramType = "query"),
     
    
   

    

     

    
    

     

       @ApiImplicitParam(name = "groupid", value = "组ID", required = true ,dataType = "string",paramType = "query")
     
    
   

    

     

    
    

     

       })
     
    
   

    

     

    
    

     
	
      public AjaxResult 
      removeUser
      (
     
    
   

    

     

    
    

     
			
      @RequestParam(defaultValue = "userid") String userid,
     
    
   

    

     

    
    

     
			
      @RequestParam(defaultValue = "groupid") String groupid )  
      throws Exception
     
    
   

    

     

    
    

     

          {
     
    
   

    

     

    
    

     
        
      return AjaxResult.success(m_FaceLibLocal.removeUser(userid, groupid));
     
    
   

    

     

    
    

     

          }
     
    
   

    

     

    
    

     
	
     
    
   

    

     

    
    

     
	
      @ApiOperation(value="获取用户详情",notes="获取用户详情")
     
    
   

    

     

    
    

     
	
      @GetMapping(value = "/getUser")
     
    
   

    

     

    
    

     
	
      @ApiImplicitParams({
     
    
   

    

     

    
    

     

       @ApiImplicitParam(name = "userid", value = "用户ID", required = true ,dataType = "string",paramType = "query"),
     
    
   

    

     

    
    

     

       @ApiImplicitParam(name = "groupid", value = "组ID", required = true ,dataType = "string",paramType = "query")
     
    
   

    

     

    
    

     

       })
     
    
   

    

     

    
    

     
	
      public AjaxResult 
      getUser
      (
     
    
   

    

     

    
    

     
			
      @RequestParam(defaultValue = "userid") String userid,
     
    
   

    

     

    
    

     
			
      @RequestParam(defaultValue = "groupid") String groupid)  
      throws Exception
     
    
   

    

     

    
    

     

          {
     
    
   

    

     

    
    

     
        
      return AjaxResult.success(m_FaceLibLocal.getUser(userid, groupid));
     
    
   

    

     

    
    

     

          }
     
    
   

    

     

    
    

     
	
     
    
   

    

     

    
    

     
	
      @ApiOperation(value="获取人脸数量",notes="获取人脸数量")
     
    
   

    

     

    
    

     
	
      @GetMapping(value = "/getDbFaceCount")
     
    
   

    

     

    
    

     
	
      @ApiImplicitParams({
     
    
   

    

     

    
    

     

       @ApiImplicitParam(name = "groupid", value = "组ID", required = true ,dataType = "string",paramType = "query")
     
    
   

    

     

    
    

     

       })
     
    
   

    

     

    
    

     
	
      public AjaxResult 
      getDbFaceCount
      (@RequestParam(defaultValue = "groupid") String groupid)  
      throws Exception
     
    
   

    

     

    
    

     

          {
     
    
   

    

     

    
    

     
        
      return AjaxResult.success(m_FaceLibLocal.getDbFaceCount(groupid));
     
    
   

    

     

    
    

     

          }
     
    
   

    

     

    
    

     
	
     
    
   

    

     

    
    

     
	
      @ApiOperation(value="用户入组",notes="用户入组")
     
    
   

    

     

    
    

     
	
      @PostMapping(value = "/addUser")
     
    
   

    

     

    
    

     
    
      public AjaxResult 
      addUser
      (@RequestBody UserFace face)  
      throws Exception
     
    
   

    

     

    
    

     

          {
     
    
   

    

     

    
    

     
		
      return AjaxResult.success(m_FaceLibLocal.addUser(face));
     
    
   

    

     

    
    

     

          }
     
    
   

    

     

    
    

     
	
     
    
   

    

     

    
    

     
	
      @ApiOperation(value="用户更新",notes="用户更新")
     
    
   

    

     

    
    

     
	
      @PostMapping(value = "/updateUser")
     
    
   

    

     

    
    

     
    
      public AjaxResult 
      updateUser
      (@RequestBody UserFace face) 
      throws Exception
     
    
   

    

     

    
    

     

          {		
     
    
   

    

     

    
    

     
		
      return AjaxResult.success(m_FaceLibLocal.updateUser(face));
     
    
   

    

     

    
    

     

          }
     
    
   

    

     

    
    

     
	
     
    
   

    

     

    
    

     
	
      @ApiOperation(value="上传图像", notes="上传图像")
     
    
   

    

     

    
    

     
	
      @RequestMapping(value="/uploadImage",method = RequestMethod.POST)
     
    
   

    

     

    
    

     
	
      @ResponseBody
     
    
   

    

     

    
    

     
	
      public Map<String,Object> 
      uploadImg
      (@RequestParam(value="filename", required=false) MultipartFile file)  
      throws Exception
     
    
   

    

     

    
    

     

      	{
     
    
   

    

     

    
    

     

      		Map<String,Object> map = 
      new 
      HashMap<String,Object>();
     
    
   

    

     

    
    

     
		
      if (file.isEmpty()) {
     
    
   

    

     

    
    

     

      			map.put(
      "status", 
      0);
     
    
   

    

     

    
    

     

      			map.put(
      "message", 
      "上传失败，请选择文件");
     
    
   

    

     

    
    

     
            
      return map;
     
    
   

    

     

    
    

     

              }
     
    
   

    

     

    
    

     
		
     
    
   

    

     

    
    

     
		
      try {
     
    
   

    

     

    
    

     
			
      // String fileName = file.getOriginalFilename();
     
    
   

    

     

    
    

     
			
      String 
      fileSuffix 
      = file.getOriginalFilename().substring(file.getOriginalFilename().lastIndexOf(
      "."));
     
    
   

    

     

    
    

     
			
      String 
      fileName 
      =  UUID.randomUUID() + fileSuffix;
     
    
   

    

     

    
    

     
	        
     
    
   

    

     

    
    

     
	        
      SimpleDateFormat 
      dateFormat 
      = 
      new 
      SimpleDateFormat(
      "yyyy/MM/dd");
     
    
   

    

     

    
    

     
	        
      String 
      currentDate 
      =   dateFormat.format( 
      new 
      Date() );
     
    
   

    

     

    
    

     
	        
      String 
      filePath 
      = upload_path + 
      "/" + currentDate + 
      "/";
     
    
   

    

     

    
    

     
	        
      if(FileUtil.createDir(filePath)) 
     
    
   

    

     

    
    

     

      	        {
     
    
   

    

     

    
    

     

      	        	filePath += fileName;
     
    
   

    

     

    
    

     
	        	
      File 
      dest 
      = 
      new 
      File(filePath);
     
    
   

    

     

    
    

     

      	        	file.transferTo(dest);
     
    
   

    

     

    
    

     
	        	
     
    
   

    

     

    
    

     

      	        	map.put(
      "status", 
      200);
     
    
   

    

     

    
    

     

      				map.put(
      "message", 
      "上传成功");
     
    
   

    

     

    
    

     

      				map.put(
      "data", filePath);
     
    
   

    

     

    
    

     

      	        }
      else {
     
    
   

    

     

    
    

     

      	        	map.put(
      "status", 
      5001);
     
    
   

    

     

    
    

     

      				map.put(
      "message", 
      "上传失败");
     
    
   

    

     

    
    

     

      				map.put(
      "data", 
      "创建文件夹失败");
     
    
   

    

     

    
    

     

      	        }
     
    
   

    

     

    
    

     
	        
     
    
   

    

     

    
    

     

      		}
      catch(Exception e) {
     
    
   

    

     

    
    

     

      			map.put(
      "status", 
      5002);
     
    
   

    

     

    
    

     

      			map.put(
      "message", 
      "上传失败");
     
    
   

    

     

    
    

     

      			map.put(
      "data", e.getMessage());
     
    
   

    

     

    
    

     

      		}
     
    
   

    

     

    
    

     
		
      return map;
     
    
   

    

     

    
    

     

      	}
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      }
     
    
  
 

  
 

  

   

    

     

    
    

     

      package com.ai.local;
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      import org.opencv.core.Core;
     
    
   

    

     

    
    

     

      import org.opencv.core.Mat;
     
    
   

    

     

    
    

     

      import org.opencv.core.MatOfByte;
     
    
   

    

     

    
    

     

      import org.opencv.imgcodecs.Imgcodecs;
     
    
   

    

     

    
    

     

      import org.springframework.stereotype.Component;
     
    
   

    

     

    
    

     

      import com.ai.local.entity.UserFace;
     
    
   

    

     

    
    

     

      import com.jni.face.Face;
     
    
   

    

     

    
    

     

      import com.util.ImageTools;
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      @Component
     
    
   

    

     

    
    

     

      public 
      class 
      FaceLibLocal {
     
    
   

    

     

    
    

     
	
      /** 获取组列表 */
     
    
   

    

     

    
    

     
	
      public String 
      getGroupList
      (int pageStart, int pageSize) 
      throws Exception {
     
    
   

    

     

    
    

     
        
      return Face.getGroupList(pageStart, pageSize);
     
    
   

    

     

    
    

     

      	}
     
    
   

    

     

    
    

     
	
     
    
   

    

     

    
    

     
	
      /** 添加组 */
     
    
   

    

     

    
    

     
	
      public String 
      addGroup
      (String groupId)  
      throws Exception{
     
    
   

    

     

    
    

     
        
      return Face.groupAdd(groupId);
     
    
   

    

     

    
    

     

      	}
     
    
   

    

     

    
    

     
	
     
    
   

    

     

    
    

     
	
      /** 删除组 */
     
    
   

    

     

    
    

     
	
      public String 
      removeGroup
      (String groupId)  
      throws Exception{
     
    
   

    

     

    
    

     
        
      return Face.groupDelete(groupId);
     
    
   

    

     

    
    

     

      	}
     
    
   

    

     

    
    

     
	
     
    
   

    

     

    
    

     
	
      /** 获取某组的用户列表 */
     
    
   

    

     

    
    

     
	
      public String 
      getUserList
      (String groupId, int pageStart, int pageSize)  
      throws Exception{
     
    
   

    

     

    
    

     
        
      return Face.getUserList(groupId, pageStart, pageSize);
     
    
   

    

     

    
    

     

      	}
     
    
   

    

     

    
    

     
		
     
    
   

    

     

    
    

     
	
      /** 用户入组 */
     
    
   

    

     

    
    

     
	
      public String 
      addUser
      (UserFace uf)  
      throws Exception{
     
    
   

    

     

    
    

     
		
      byte[] bytes = ImageTools.loadNetImage(uf.getImage());
     
    
   

    

     

    
    

     
		
      MatOfByte 
      mb 
      = 
      new 
      MatOfByte(bytes);
     
    
   

    

     

    
    

     
		
      Mat 
      mat 
      = Imgcodecs.imdecode(mb, -
      1);
     
    
   

    

     

    
    

     
		
      // Imgcodecs.imwrite("jerry.png", mat); 
     
    
   

    

     

    
    

     
		
      long 
      matAddr 
      = mat.getNativeObjAddr();
     
    
   

    

     

    
    

     
		
      String 
      res 
      = Face.userAddByMat(matAddr, uf.getUserId(), uf.getGroupId(), uf.getUserInfo());
     
    
   

    

     

    
    

     

      		Face.loadDbFace();
     
    
   

    

     

    
    

     
		
      return res;
     
    
   

    

     

    
    

     

      	}
     
    
   

    

     

    
    

     
	
     
    
   

    

     

    
    

     
	
      /** 用户删除 */
     
    
   

    

     

    
    

     
	
      public String 
      removeUser
      (String userId, String groupId)  
      throws Exception{
     
    
   

    

     

    
    

     
		
      String 
      res 
      = Face.userDelete(userId, groupId);
     
    
   

    

     

    
    

     

      		Face.loadDbFace();
     
    
   

    

     

    
    

     
		
      return res;
     
    
   

    

     

    
    

     

      	}
     
    
   

    

     

    
    

     
	
     
    
   

    

     

    
    

     
	
      /** 用户更新 */
     
    
   

    

     

    
    

     
	
      public String 
      updateUser
      (UserFace uf)  
      throws Exception{
     
    
   

    

     

    
    

     
		
      byte[] bytes = ImageTools.loadNetImage(uf.getImage());
     
    
   

    

     

    
    

     
		
      MatOfByte 
      mb 
      = 
      new 
      MatOfByte(bytes);
     
    
   

    

     

    
    

     
		
      Mat 
      mat 
      = Imgcodecs.imdecode(mb, -
      1);
     
    
   

    

     

    
    

     
		
      // Imgcodecs.imwrite("jerry.png", mat); 
     
    
   

    

     

    
    

     
		
      long 
      matAddr 
      = mat.getNativeObjAddr();
     
    
   

    

     

    
    

     
		
      String 
      res 
      = Face.userUpdate(matAddr, uf.getUserId(), uf.getGroupId(), uf.getUserInfo());
     
    
   

    

     

    
    

     

      		Face.loadDbFace();
     
    
   

    

     

    
    

     
		
      return res;
     
    
   

    

     

    
    

     

      	}
     
    
   

    

     

    
    

     
	
     
    
   

    

     

    
    

     
	
      /** 获取用户详情 */
     
    
   

    

     

    
    

     
	
      public String 
      getUser
      (String userId, String groupId)  
      throws Exception{
     
    
   

    

     

    
    

     
		
      return  Face.getUserInfo(userId, groupId);
     
    
   

    

     

    
    

     

      	}
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     
	
      /** 获取人脸数量 */
     
    
   

    

     

    
    

     
    
      public 
      int 
      getDbFaceCount
      (String groupId)  
      throws Exception{
     
    
   

    

     

    
    

     
        
      return Face.dbFaceCount(groupId);
     
    
   

    

     

    
    

     

          }
     
    
   

    

     

    
    

     
    
     
    
   

    

     

    
    

     

      }
     
    
  
 

  
 

（4）对象实体

  

   

    

     

    
    

     

      package com.ai.local.entity;
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      import com.jni.struct.Attribute;
     
    
   

    

     

    
    

     

      import com.jni.struct.FeatureInfo;
     
    
   

    

     

    
    

     

      import io.swagger.annotations.ApiModel;
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      @ApiModel(value = "FaceAttribute", description = "人脸识别结果")
     
    
   

    

     

    
    

     

      public 
      class 
      FaceAttribute 
      extends 
      FeatureInfo {
     
    
   

    

     

    
    

     
	
      // 人脸属性
     
    
   

    

     

    
    

     

      	Attribute[] attribute;
     
    
   

    

     

    
    

     
	
      // 库搜索结果
     
    
   

    

     

    
    

     

      	String identify;
     
    
   

    

     

    
    

     
	
      // 口罩
     
    
   

    

     

    
    

     
	
      float wearMask;
     
    
   

    

     

    
    

     
	
     
    
   

    

     

    
    

     
	
      public 
      FaceAttribute
      () {
     
    
   

    

     

    
    

     
		
     
    
   

    

     

    
    

     

      	}
     
    
   

    

     

    
    

     
	
     
    
   

    

     

    
    

     
	
      public 
      FaceAttribute
      (FeatureInfo featureInfo) {
     
    
   

    

     

    
    

     
		
      this.box = featureInfo.box;
     
    
   

    

     

    
    

     
		
      this.feature = featureInfo.feature;
     
    
   

    

     

    
    

     

      	}
     
    
   

    

     

    
    

     
	
     
    
   

    

     

    
    

     
	
      public Attribute[] getAttribute() {
     
    
   

    

     

    
    

     
		
      return attribute;
     
    
   

    

     

    
    

     

      	}
     
    
   

    

     

    
    

     
	
      public 
      void 
      setAttribute
      (Attribute[] attribute) {
     
    
   

    

     

    
    

     
		
      this.attribute = attribute;
     
    
   

    

     

    
    

     

      	}
     
    
   

    

     

    
    

     
	
      public String 
      getIdentify
      () {
     
    
   

    

     

    
    

     
		
      return identify;
     
    
   

    

     

    
    

     

      	}
     
    
   

    

     

    
    

     
	
      public 
      void 
      setIdentify
      (String identify) {
     
    
   

    

     

    
    

     
		
      this.identify = identify;
     
    
   

    

     

    
    

     

      	}
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     
	
      public 
      float 
      getWearMask
      () {
     
    
   

    

     

    
    

     
		
      return wearMask;
     
    
   

    

     

    
    

     

      	}
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     
	
      public 
      void 
      setWearMask
      (float wearMask) {
     
    
   

    

     

    
    

     
		
      this.wearMask = wearMask;
     
    
   

    

     

    
    

     

      	}
     
    
   

    

     

    
    

     
	
     
    
   

    

     

    
    

     

      }
     
    
  
 

  
 

  

   

    

     

    
    

     

      package com.ai.local.entity;
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      import io.swagger.annotations.ApiModel;
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      @ApiModel(value = "UserFace", description = "人脸库对象")
     
    
   

    

     

    
    

     

      public 
      class 
      UserFace {
     
    
   

    

     

    
    

     
	
      // 人脸图像
     
    
   

    

     

    
    

     
	
      private String image;
     
    
   

    

     

    
    

     
    
      // 用户id
     
    
   

    

     

    
    

     
	
      private String userId;
     
    
   

    

     

    
    

     
    
      // 组id
     
    
   

    

     

    
    

     
	
      private String groupId;
     
    
   

    

     

    
    

     
    
      // 其它信息
     
    
   

    

     

    
    

     
	
      private String userInfo;
     
    
   

    

     

    
    

     
	
     
    
   

    

     

    
    

     
	
      public String 
      getImage
      () {
     
    
   

    

     

    
    

     
		
      return image;
     
    
   

    

     

    
    

     

      	}
     
    
   

    

     

    
    

     
	
      public 
      void 
      setImage
      (String image) {
     
    
   

    

     

    
    

     
		
      this.image = image;
     
    
   

    

     

    
    

     

      	}
     
    
   

    

     

    
    

     
	
      public String 
      getUserId
      () {
     
    
   

    

     

    
    

     
		
      return userId;
     
    
   

    

     

    
    

     

      	}
     
    
   

    

     

    
    

     
	
      public 
      void 
      setUserId
      (String userId) {
     
    
   

    

     

    
    

     
		
      this.userId = userId;
     
    
   

    

     

    
    

     

      	}
     
    
   

    

     

    
    

     
	
      public String 
      getGroupId
      () {
     
    
   

    

     

    
    

     
		
      return groupId;
     
    
   

    

     

    
    

     

      	}
     
    
   

    

     

    
    

     
	
      public 
      void 
      setGroupId
      (String groupId) {
     
    
   

    

     

    
    

     
		
      this.groupId = groupId;
     
    
   

    

     

    
    

     

      	}
     
    
   

    

     

    
    

     
	
      public String 
      getUserInfo
      () {
     
    
   

    

     

    
    

     
		
      return userInfo;
     
    
   

    

     

    
    

     

      	}
     
    
   

    

     

    
    

     
	
      public 
      void 
      setUserInfo
      (String userInfo) {
     
    
   

    

     

    
    

     
		
      this.userInfo = userInfo;
     
    
   

    

     

    
    

     

      	}
     
    
   

    

     

    
    

     

      }
     
    
  
 

  
 

（5）摄像头切图识别

  

   

    

     

    
    

     

      package com.task;
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      import java.io.IOException;
     
    
   

    

     

    
    

     

      import java.time.LocalDateTime;
     
    
   

    

     

    
    

     

      import java.time.ZoneOffset;
     
    
   

    

     

    
    

     

      import java.util.ArrayList;
     
    
   

    

     

    
    

     

      import java.util.HashMap;
     
    
   

    

     

    
    

     

      import java.util.List;
     
    
   

    

     

    
    

     

      import java.util.Map;
     
    
   

    

     

    
    

     

      import java.util.UUID;
     
    
   

    

     

    
    

     

      import org.opencv.core.Mat;
     
    
   

    

     

    
    

     

      import org.opencv.core.Size;
     
    
   

    

     

    
    

     

      import org.opencv.imgcodecs.Imgcodecs;
     
    
   

    

     

    
    

     

      import org.opencv.imgproc.Imgproc;
     
    
   

    

     

    
    

     

      import org.opencv.videoio.VideoCapture;
     
    
   

    

     

    
    

     

      import org.apache.http.io.EofSensor;
     
    
   

    

     

    
    

     

      import org.json.JSONObject;
     
    
   

    

     

    
    

     

      import org.slf4j.Logger;
     
    
   

    

     

    
    

     

      import org.slf4j.LoggerFactory;
     
    
   

    

     

    
    

     

      import org.springframework.beans.factory.annotation.Autowired;
     
    
   

    

     

    
    

     

      import org.springframework.beans.factory.annotation.Value;
     
    
   

    

     

    
    

     

      import org.springframework.scheduling.annotation.EnableAsync;
     
    
   

    

     

    
    

     

      import org.springframework.stereotype.Component;
     
    
   

    

     

    
    

     

      import com.ai.local.entity.FaceAttribute;
     
    
   

    

     

    
    

     

      import com.jni.face.Face;
     
    
   

    

     

    
    

     

      import com.jni.face.FaceDraw;
     
    
   

    

     

    
    

     

      import com.jni.struct.FeatureInfo;
     
    
   

    

     

    
    

     

      import com.util.GsonUtils;
     
    
   

    

     

    
    

     

      import com.util.HttpUtil;
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      /**
     
    
   

    

     

    
    

     

      *@author created by Jerry
     
    
   

    

     

    
    

     

      *@date 2022年11月15日---上午9:14:56
     
    
   

    

     

    
    

     

      *@problem
     
    
   

    

     

    
    

     

      *@answer
     
    
   

    

     

    
    

     

      *@action
     
    
   

    

     

    
    

     

      */
     
    
   

    

     

    
    

     

      @Component
     
    
   

    

     

    
    

     

      @EnableAsync
     
    
   

    

     

    
    

     

      public 
      class 
      CamersLocalTask 
      implements 
      Runnable{
     
    
   

    

     

    
    

     
	
      private 
      Logger 
      m_log 
      = LoggerFactory.getLogger(CamersLocalTask.class);
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     
	
      @Value("${rtspURL}")
     
    
   

    

     

    
    

     

      	String m_rtspURL;
     
    
   

    

     

    
    

     
	
     
    
   

    

     

    
    

     
	
      @Value("${rtspImage}")
     
    
   

    

     

    
    

     

      	String m_rtspImage;
     
    
   

    

     

    
    

     
	
     
    
   

    

     

    
    

     
	
      @Value("${rtspImage_down}")
     
    
   

    

     

    
    

     

      	String m_rtspImage_down;
     
    
   

    

     

    
    

     
	
     
    
   

    

     

    
    

     
	
      @Value("${samplingRate}")
     
    
   

    

     

    
    

     

      	Long m_samplingRate;
     
    
   

    

     

    
    

     
	
     
    
   

    

     

    
    

     
	
      @Value("${sendURL}")
     
    
   

    

     

    
    

     

      	String m_sendURL;
     
    
   

    

     

    
    

     
	
     
    
   

    

     

    
    

     
	
      @Autowired
     
    
   

    

     

    
    

     

      	HttpUtil m_HttpUtil;
     
    
   

    

     

    
    

     
	
     
    
   

    

     

    
    

     
	
      @Override
     
    
   

    

     

    
    

     
	
      public 
      void 
      run
      () {
     
    
   

    

     

    
    

     
		
      try {
     
    
   

    

     

    
    

     
			
      this.screenshot_ex();
     
    
   

    

     

    
    

     

      		} 
      catch (java.lang.Exception e) {
     
    
   

    

     

    
    

     

      			e.printStackTrace();
     
    
   

    

     

    
    

     

      		}
     
    
   

    

     

    
    

     

      	}
     
    
   

    

     

    
    

     
	
     
    
   

    

     

    
    

     
	
      /** 摄像头截图 */
     
    
   

    

     

    
    

     
	
      public 
      void 
      screenshot_ex
      () 
      throws IOException {
     
    
   

    

     

    
    

     
		
      // 内存不能实时释放，尽量不new
     
    
   

    

     

    
    

     
	  	
      VideoCapture 
      capture 
      = 
      new 
      VideoCapture();
     
    
   

    

     

    
    

     

              capture.open(m_rtspURL);
     
    
   

    

     

    
    

     

              capture.set(
      3, 
      960);
     
    
   

    

     

    
    

     

      	  	capture.set(
      4, 
      540);
     
    
   

    

     

    
    

     
        
      if (!capture.isOpened()) {
     
    
   

    

     

    
    

     

                  m_log.error(
      "ERROR：could not open camera {}", m_rtspURL);
     
    
   

    

     

    
    

     
            
      return;
     
    
   

    

     

    
    

     

              }
     
    
   

    

     

    
    

     
        
      // type 0： 表示rgb 人脸检测 1：表示nir人脸检测
     
    
   

    

     

    
    

     
        
      int 
      type 
      = 
      0;
     
    
   

    

     

    
    

     
        
      Mat 
      frame 
      = 
      new 
      Mat();
     
    
   

    

     

    
    

     
        
      int 
      index 
      = 
      0;
     
    
   

    

     

    
    

     
        
      while (
      true) {
     
    
   

    

     

    
    

     
        	
      boolean 
      have 
      = capture.read(frame);
     
    
   

    

     

    
    

     
        	
      if (!have) {
     
    
   

    

     

    
    

     

                  	m_log.error(
      "切图失败");
     
    
   

    

     

    
    

     

                  	capture.release();
     
    
   

    

     

    
    

     

                  	capture.open(m_rtspURL);
     
    
   

    

     

    
    

     
                
      continue;
     
    
   

    

     

    
    

     

                  }
     
    
   

    

     

    
    

     
        	
     
    
   

    

     

    
    

     
        	
      // 切一下 resize(原矩阵，新矩阵，宽，高)
     
    
   

    

     

    
    

     

                  Imgproc.resize(frame, frame, 
      new 
      Size(
      960,
      540));
     
    
   

    

     

    
    

     
            
      // 截一下 submat(起始行，截止行，起始列，截止列)
     
    
   

    

     

    
    

     
            
      // frame = frame.submat(20, 540 - 88, 96, 960 - 96);
     
    
   

    

     

    
    

     
        	
     
    
   

    

     

    
    

     
        	
      if(index++ < m_samplingRate)
     
    
   

    

     

    
    

     

      			{
     
    
   

    

     

    
    

     
        		
      continue;
     
    
   

    

     

    
    

     

      			}
     
    
   

    

     

    
    

     

                  index = 
      0;
     
    
   

    

     

    
    

     
            
     
    
   

    

     

    
    

     
            
      if (!frame.empty()) {	                
     
    
   

    

     

    
    

     
                
      long 
      matAddr 
      = frame.getNativeObjAddr();
     
    
   

    

     

    
    

     
                
      // 获取特征
     
    
   

    

     

    
    

     

                      FeatureInfo[] featureInfo = Face.faceFeature(matAddr, type);
     
    
   

    

     

    
    

     
                
      if (featureInfo == 
      null || featureInfo.length <= 
      0) {
     
    
   

    

     

    
    

     
                	
      // m_log.info("无人脸");
     
    
   

    

     

    
    

     
                    
      continue;
     
    
   

    

     

    
    

     

                      }
     
    
   

    

     

    
    

     

                      List<FaceAttribute> eatureInfoList = 
      new 
      ArrayList<>();
     
    
   

    

     

    
    

     
                
      for (
      int 
      i 
      = 
      0; i < featureInfo.length; i++) {
     
    
   

    

     

    
    

     
                	
      FeatureInfo 
      fi 
      = featureInfo[i];
     
    
   

    

     

    
    

     
                	
      FaceAttribute 
      faceAttribute 
      = 
      new 
      FaceAttribute(fi);
     
    
   

    

     

    
    

     
                	
      // 抠图
     
    
   

    

     

    
    

     
                	
      Mat 
      mat_sub 
      = 
      new 
      Mat();
     
    
   

    

     

    
    

     
                    
      long 
      outAddr 
      = mat_sub.getNativeObjAddr();
     
    
   

    

     

    
    

     

                          Face.faceCrop(matAddr, outAddr);
     
    
   

    

     

    
    

     
                    
      // 属性
     
    
   

    

     

    
    

     

                          faceAttribute.setAttribute(Face.faceAttr(outAddr));
     
    
   

    

     

    
    

     
                    
      // 口罩
     
    
   

    

     

    
    

     

                          faceAttribute.setWearMask(Face.faceMouthMask(outAddr)[
      0]);
     
    
   

    

     

    
    

     
                	
      // 搜索
     
    
   

    

     

    
    

     

                      	faceAttribute.setIdentify(Face.identifyWithAll(fi.feature, type).replaceAll(
      "\\n|\\t",
      ""));
     
    
   

    

     

    
    

     
                	
      // 绘制
     
    
   

    

     

    
    

     

      	                FaceDraw.drawRects(frame, fi.box);
     
    
   

    

     

    
    

     

      	                eatureInfoList.add(faceAttribute);
     
    
   

    

     

    
    

     
	                
     
    
   

    

     

    
    

     

      	                mat_sub = 
      null;
     
    
   

    

     

    
    

     

      				}
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     
                
      // 保存
     
    
   

    

     

    
    

     
				
      String 
      fname 
      = UUID.randomUUID().toString() + 
      ".jpg";
     
    
   

    

     

    
    

     

                      Imgcodecs.imwrite(m_rtspImage + fname, frame);
     
    
   

    

     

    
    

     
                
     
    
   

    

     

    
    

     
                
      // 发送
     
    
   

    

     

    
    

     
                
      Long 
      timestamp 
      = LocalDateTime.now().toInstant(ZoneOffset.of(
      "+8")).toEpochMilli()/
      1000;
     
    
   

    

     

    
    

     
                
      JSONObject 
      jo 
      = 
      new 
      JSONObject();
     
    
   

    

     

    
    

     

                      jo.put(
      "error_code", 
      0);
     
    
   

    

     

    
    

     

                      jo.put(
      "img_src", m_rtspImage_down + fname);
     
    
   

    

     

    
    

     
                
      String 
      str 
      = GsonUtils.toJson(eatureInfoList);
     
    
   

    

     

    
    

     

                      jo.put(
      "face_list", str);
     
    
   

    

     

    
    

     

                      jo.put(
      "log_id", timestamp);
     
    
   

    

     

    
    

     

                      jo.put(
      "timestamp", timestamp);
     
    
   

    

     

    
    

     
                
     
    
   

    

     

    
    

     

                      Map<String, Object> map = 
      new 
      HashMap<>();
     
    
   

    

     

    
    

     

      		        map.put(
      "JsonData", GsonUtils.toJson(jo));
     
    
   

    

     

    
    

     

      		        map.put(
      "UseState", 
      0);
     
    
   

    

     

    
    

     

      		        map.put(
      "CreateDate", LocalDateTime.now().toString());
     
    
   

    

     

    
    

     
		        
      String 
      param 
      = GsonUtils.toJson(map);
     
    
   

    

     

    
    

     
				
     
    
   

    

     

    
    

     
		        
      try {
     
    
   

    

     

    
    

     

      		        	m_HttpUtil.postAsync(m_sendURL, param);
     
    
   

    

     

    
    

     

      			        m_log.info(
      "INFO：：向{}推发送数据成功{}",m_sendURL, param);
     
    
   

    

     

    
    

     

      				} 
      catch (java.lang.Exception e) {
     
    
   

    

     

    
    

     

      					m_log.error(
      "ERROR：：向{}推送数据失败 ",m_sendURL);
     
    
   

    

     

    
    

     

      				}
     
    
   

    

     

    
    

     
		        
     
    
   

    

     

    
    

     

      		        eatureInfoList = 
      null;
     
    
   

    

     

    
    

     

      		        jo = 
      null;
     
    
   

    

     

    
    

     

      		        map = 
      null;
     
    
   

    

     

    
    

     

      		        System.gc();
     
    
   

    

     

    
    

     

                  }           
     
    
   

    

     

    
    

     

              }
     
    
   

    

     

    
    

     

      	}
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      }
     
    
  
 

  
 

（6）清理临时存储

  

   

    

     

    
    

     

      package com.task;
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      import java.io.File;
     
    
   

    

     

    
    

     

      import java.io.IOException;
     
    
   

    

     

    
    

     

      import java.nio.file.Files;
     
    
   

    

     

    
    

     

      import java.nio.file.Path;
     
    
   

    

     

    
    

     

      import java.nio.file.Paths;
     
    
   

    

     

    
    

     

      import java.nio.file.attribute.BasicFileAttributes;
     
    
   

    

     

    
    

     

      import java.nio.file.attribute.FileTime;
     
    
   

    

     

    
    

     

      import java.time.LocalDateTime;
     
    
   

    

     

    
    

     

      import java.time.ZoneOffset;
     
    
   

    

     

    
    

     

      import java.util.ArrayList;
     
    
   

    

     

    
    

     

      import java.util.List;
     
    
   

    

     

    
    

     

      import org.slf4j.Logger;
     
    
   

    

     

    
    

     

      import org.slf4j.LoggerFactory;
     
    
   

    

     

    
    

     

      import org.springframework.beans.factory.annotation.Value;
     
    
   

    

     

    
    

     

      import org.springframework.scheduling.annotation.EnableAsync;
     
    
   

    

     

    
    

     

      import org.springframework.stereotype.Component;
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      /**
     
    
   

    

     

    
    

     

      *@author created by Jerry
     
    
   

    

     

    
    

     

      *@date 2022年11月15日---上午9:14:56
     
    
   

    

     

    
    

     

      *@problem
     
    
   

    

     

    
    

     

      *@answer
     
    
   

    

     

    
    

     

      *@action
     
    
   

    

     

    
    

     

      */
     
    
   

    

     

    
    

     

      @Component
     
    
   

    

     

    
    

     

      @EnableAsync
     
    
   

    

     

    
    

     

      public 
      class 
      ClearFilesTask 
      implements 
      Runnable{
     
    
   

    

     

    
    

     
	
      Logger 
      m_log 
      = LoggerFactory.getLogger(ClearFilesTask.class);
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     
	
      @Value("${cacheTime}")
     
    
   

    

     

    
    

     

      	Long m_cacheTime;
     
    
   

    

     

    
    

     
	
     
    
   

    

     

    
    

     
	
      @Value("${rtspImage}")
     
    
   

    

     

    
    

     

      	String m_rtspImage;
     
    
   

    

     

    
    

     
	
     
    
   

    

     

    
    

     
	
      @Override
     
    
   

    

     

    
    

     
	
      public 
      void 
      run
      () {
     
    
   

    

     

    
    

     
		
      while (
      true) {
     
    
   

    

     

    
    

     
			
      try {
     
    
   

    

     

    
    

     
				
      File 
      file 
      = 
      new 
      File(m_rtspImage);
     
    
   

    

     

    
    

     

      				List<File> objects = 
      new 
      ArrayList<File>();
     
    
   

    

     

    
    

     

      				getFilesList(file, objects);
     
    
   

    

     

    
    

     

      				Thread.sleep(
      1000L * 
      300);
     
    
   

    

     

    
    

     

      			} 
      catch (IOException | InterruptedException e) {
     
    
   

    

     

    
    

     

      				e.printStackTrace();
     
    
   

    

     

    
    

     

      			}
     
    
   

    

     

    
    

     

      		}
     
    
   

    

     

    
    

     

      	}
     
    
   

    

     

    
    

     
	
     
    
   

    

     

    
    

     
	
      private 
      void 
      getFilesList
      (File file, List<File> temp) 
      throws IOException{
     
    
   

    

     

    
    

     

      		File[] listFiles = file.listFiles();
     
    
   

    

     

    
    

     
		
      if(listFiles == 
      null) {
     
    
   

    

     

    
    

     
			
      return;
     
    
   

    

     

    
    

     

      		}
     
    
   

    

     

    
    

     
		
      for (File file2 : listFiles) {
     
    
   

    

     

    
    

     
		    
      if (file2.isDirectory()) {
     
    
   

    

     

    
    

     

      		        getFilesList(file2, temp);
     
    
   

    

     

    
    

     

      		    } 
      else {
     
    
   

    

     

    
    

     
		       
      if(file2.getAbsolutePath().contains(
      ".jpg")){
     
    
   

    

     

    
    

     
		    	   
      Path 
      path 
      = Paths.get(file2.getAbsolutePath());
     
    
   

    

     

    
    

     
		    	   
      BasicFileAttributes 
      attrs 
      = Files.readAttributes(path, BasicFileAttributes.class);
     
    
   

    

     

    
    

     
		    	   
      FileTime 
      fileTime 
      = attrs.creationTime();
     
    
   

    

     

    
    

     
		    	   
      if(LocalDateTime.now().toEpochSecond(ZoneOffset.UTC)  - 
      28800 - fileTime.toMillis()/
      1000 > m_cacheTime) {
     
    
   

    

     

    
    

     

      		    		   file2.delete();
     
    
   

    

     

    
    

     

      		    	   }
     
    
   

    

     

    
    

     

      		       }
     
    
   

    

     

    
    

     

      		    }
     
    
   

    

     

    
    

     

      		}
     
    
   

    

     

    
    

     

      	}
     
    
   

    

     

    
    

     

      }