阿里face

.idea/libraries/Maven__com_alibaba_fastjson_1_2_56.xml

@@ -1,13 +0,0 @@
-<component name="libraryTable">
-  <library name="Maven: com.alibaba:fastjson:1.2.56">
-    <CLASSES>
-      <root url="jar://D:/REPO/com/alibaba/fastjson/1.2.56/fastjson-1.2.56.jar!/" />
-    </CLASSES>
-    <JAVADOC>
-      <root url="jar://D:/REPO/com/alibaba/fastjson/1.2.56/fastjson-1.2.56-javadoc.jar!/" />
-    </JAVADOC>
-    <SOURCES>
-      <root url="jar://D:/REPO/com/alibaba/fastjson/1.2.56/fastjson-1.2.56-sources.jar!/" />
-    </SOURCES>
-  </library>
-</component>

src/main/java/com.huiju.welcome/utils/AliFaceUtils.java

@@ -1,18 +1,41 @@
 package com.huiju.welcome.utils;
 
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
 import com.aliyuncs.CommonRequest;
 import com.aliyuncs.CommonResponse;
 import com.aliyuncs.DefaultAcsClient;
+import com.aliyuncs.IAcsClient;
+import com.aliyuncs.exceptions.ClientException;
+import com.aliyuncs.exceptions.ServerException;
+import com.aliyuncs.green.model.v20180509.AddFacesRequest;
+import com.aliyuncs.green.model.v20180509.AddPersonRequest;
+import com.aliyuncs.green.model.v20180509.GetPersonRequest;
+import com.aliyuncs.green.model.v20180509.ImageSyncScanRequest;
+import com.aliyuncs.http.FormatType;
+import com.aliyuncs.http.HttpResponse;
 import com.aliyuncs.http.MethodType;
 import com.aliyuncs.profile.DefaultProfile;
 import com.huiju.welcome.config.AliProperties;
+import com.tencentcloudapi.common.exception.TencentCloudSDKException;
+import com.tencentcloudapi.iai.v20180301.models.GetPersonBaseInfoResponse;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.http.HttpStatus;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.context.properties.EnableConfigurationProperties;
 import org.springframework.context.annotation.Configuration;
 
+import java.io.UnsupportedEncodingException;
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.Date;
+import java.util.HashMap;
+import java.util.LinkedHashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.UUID;
+
 @Slf4j
 @Configuration
 @EnableConfigurationProperties(AliProperties.class)
@@ -23,11 +46,253 @@ public class AliFaceUtils {
 
     DefaultProfile profile;
     DefaultAcsClient client;
-
+    IAcsClient recognitionClient;
+    
+    
     @Autowired
     public AliFaceUtils(AliProperties p) {
         profile = DefaultProfile.getProfile(AliProperties.face.getRegionId(), AliProperties.accessKeyId, AliProperties.accessKeySecret);
         client = new DefaultAcsClient(profile);
+        recognitionClient = new DefaultAcsClient(profile);
+    }
+    
+    public JSONObject getPersonBaseInfo(String personId) throws UnsupportedEncodingException {
+        GetPersonRequest getPersonRequest = new GetPersonRequest();
+        getPersonRequest.setAcceptFormat(FormatType.JSON); // 指定api返回格式
+        getPersonRequest.setMethod(com.aliyuncs.http.MethodType.POST); // 指定请求方法
+        getPersonRequest.setEncoding("utf-8");
+    
+        JSONObject data = new JSONObject();
+        /**
+         * personId: 用户自定义个体Id，必填
+         */
+        data.put("personId", "personId_test_3");
+    
+    
+        getPersonRequest.setHttpContent(data.toJSONString().getBytes("UTF-8"), "UTF-8", FormatType.JSON);
+    
+        /**
+         * 请务必设置超时时间
+         */
+        getPersonRequest.setConnectTimeout(3000);
+        getPersonRequest.setReadTimeout(6000);
+    
+        try {
+            HttpResponse httpResponse = recognitionClient.doAction(getPersonRequest);
+        
+            if (httpResponse.isSuccess()) {
+                JSONObject scrResponse = JSON.parseObject(new String(httpResponse.getHttpContent(), "UTF-8"));
+                System.out.println(JSON.toJSONString(scrResponse, true));
+                if (200 == scrResponse.getInteger("code")) {
+                    JSONObject resultObject = scrResponse.getJSONObject("data");
+                    if (200 == resultObject.getInteger("code")) {
+                        System.out.println(resultObject.getString("personId"));
+                    } else {
+                        System.out.println("task process fail:" + resultObject.getInteger("code"));
+                    }
+                } else {
+                    System.out.println("detect not success. code:" + scrResponse.getInteger("code"));
+                }
+            } else {
+                System.out.println("response not success. status:" + httpResponse.getStatus());
+            }
+        } catch (ServerException e) {
+            e.printStackTrace();
+        } catch (ClientException e) {
+            e.printStackTrace();
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return data;
+    }
+    
+    public void createPerson(String personId, String personName, String url, String ...images) throws TencentCloudSDKException, UnsupportedEncodingException {
+        // 已经存在的人员, 不重复创建
+        try {
+            getPersonBaseInfo(personId);
+            return;
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        AddPersonRequest addPersonRequest = new AddPersonRequest();
+        addPersonRequest.setAcceptFormat(FormatType.JSON); // 指定api返回格式
+        addPersonRequest.setMethod(com.aliyuncs.http.MethodType.POST); // 指定请求方法
+        addPersonRequest.setEncoding("utf-8");
+    
+        JSONObject data = new JSONObject();
+        /**
+         * personId: 用户自定义个体Id，必填
+         * groupIds: 用户自定义组Id列表，必填
+         * name: 用户名称，非必填
+         * note: 备注信息，非必填
+         */
+        data.put("personId", "personId_test_3");
+        data.put("groupIds", Arrays.asList("java_sdk_test_group"));
+        data.put("name", "测试");
+        data.put("note", "备注信息");
+    
+        addPersonRequest.setHttpContent(data.toJSONString().getBytes("UTF-8"), "UTF-8", FormatType.JSON);
+    
+        /**
+         * 请务必设置超时时间
+         */
+        addPersonRequest.setConnectTimeout(3000);
+        addPersonRequest.setReadTimeout(6000);
+    
+        try {
+            HttpResponse httpResponse = recognitionClient.doAction(addPersonRequest);
+        
+            if (httpResponse.isSuccess()) {
+                JSONObject scrResponse = JSON.parseObject(new String(httpResponse.getHttpContent(), "UTF-8"));
+                System.out.println(JSON.toJSONString(scrResponse, true));
+                if (200 == scrResponse.getInteger("code")) {
+                    JSONObject resultObject = scrResponse.getJSONObject("data");
+                    if (200 == resultObject.getInteger("code")) {
+                        System.out.println(resultObject.getString("personId"));
+                    } else {
+                        System.out.println("task process fail:" + resultObject.getInteger("code"));
+                    }
+                } else {
+                    System.out.println("detect not success. code:" + scrResponse.getInteger("code"));
+                }
+            } else {
+                System.out.println("response not success. status:" + httpResponse.getStatus());
+            }
+        } catch (ServerException e) {
+            e.printStackTrace();
+        } catch (ClientException e) {
+            e.printStackTrace();
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+    }
+    
+    public void createFace(String personId, String url, String ...images) throws Exception {
+        
+        try {
+            createPerson(personId, personId, url);
+        } catch (Exception e) {
+            log.error(e.toString());
+        }
+    
+        AddFacesRequest addFacesRequest = new AddFacesRequest();
+        addFacesRequest.setAcceptFormat(FormatType.JSON); // 指定api返回格式
+        addFacesRequest.setMethod(com.aliyuncs.http.MethodType.POST); // 指定请求方法
+        addFacesRequest.setEncoding("utf-8");
+    
+        JSONObject data = new JSONObject();
+        /**
+         * personId: 用户自定义个体Id，必填
+         * urls: 图片url
+         */
+        data.put("personId", "personId_test_3");
+        data.put("urls", Arrays.asList("https://img.alicdn.com/tfs/xxx-550-407.jpg"));
+    
+        addFacesRequest.setHttpContent(data.toJSONString().getBytes("UTF-8"), "UTF-8", FormatType.JSON);
+    
+        /**
+         * 请务必设置超时时间
+         */
+        addFacesRequest.setConnectTimeout(3000);
+        addFacesRequest.setReadTimeout(6000);
+    
+        try {
+            HttpResponse httpResponse = recognitionClient.doAction(addFacesRequest);
+        
+            if (httpResponse.isSuccess()) {
+                JSONObject scrResponse = JSON.parseObject(new String(httpResponse.getHttpContent(), "UTF-8"));
+                System.out.println(JSON.toJSONString(scrResponse, true));
+                if (200 == scrResponse.getInteger("code")) {
+                    JSONObject resultObject = scrResponse.getJSONObject("data");
+                    if (200 == resultObject.getInteger("code")) {
+                        System.out.println(resultObject.getString("personId"));
+                    } else {
+                        System.out.println("task process fail:" + resultObject.getInteger("code"));
+                    }
+                } else {
+                    System.out.println("detect not success. code:" + scrResponse.getInteger("code"));
+                }
+            } else {
+                System.out.println("response not success. status:" + httpResponse.getStatus());
+            }
+        } catch (ServerException e) {
+            e.printStackTrace();
+        } catch (ClientException e) {
+            e.printStackTrace();
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+    }
+    
+    public void searchFace(String url, String ...images) throws Exception {
+        ImageSyncScanRequest imageSyncScanRequest = new ImageSyncScanRequest();
+        imageSyncScanRequest.setAcceptFormat(FormatType.JSON); // 指定api返回格式
+        imageSyncScanRequest.setMethod(com.aliyuncs.http.MethodType.POST); // 指定请求方法
+        imageSyncScanRequest.setEncoding("utf-8");
+        imageSyncScanRequest.setRegionId(AliProperties.face.getRegionId());
+    
+    
+        List<Map<String, Object>> tasks = new ArrayList<Map<String, Object>>();
+        Map<String, Object> task = new LinkedHashMap<String, Object>();
+        task.put("dataId", UUID.randomUUID().toString());
+        task.put("url", "https://img.alicdn.com/tfs/xxx-550-407.jpg");
+        task.put("time", new Date());
+        Map<String, String> extras = new HashMap<String, String>();
+        extras.put("groupId", "java_sdk_test_group");
+        task.put("extras", extras);
+    
+        tasks.add(task);
+        JSONObject data = new JSONObject();
+        /**
+         * sface-n: 人脸1-N
+         */
+        data.put("scenes", Arrays.asList("sface-n"));
+        data.put("tasks", tasks);
+    
+        imageSyncScanRequest.setHttpContent(data.toJSONString().getBytes("UTF-8"), "UTF-8", FormatType.JSON);
+    
+        /**
+         * 请务必设置超时时间
+         */
+        imageSyncScanRequest.setConnectTimeout(3000);
+        imageSyncScanRequest.setReadTimeout(6000);
+    
+        try {
+            HttpResponse httpResponse = client.doAction(imageSyncScanRequest);
+        
+            if (httpResponse.isSuccess()) {
+                JSONObject scrResponse = JSON.parseObject(new String(httpResponse.getHttpContent(), "UTF-8"));
+                System.out.println(JSON.toJSONString(scrResponse, true));
+                if (200 == scrResponse.getInteger("code")) {
+                    JSONArray taskResults = scrResponse.getJSONArray("data");
+                    for (Object taskResult : taskResults) {
+                        if(200 == ((JSONObject)taskResult).getInteger("code")){
+                            JSONArray sceneResults = ((JSONObject)taskResult).getJSONArray("results");
+                            for (Object sceneResult : sceneResults) {
+                                String scene = ((JSONObject)sceneResult).getString("scene");
+                                String suggestion = ((JSONObject)sceneResult).getString("suggestion");
+                                //根据scene和suggetion做相关的处理
+                                //do something
+                                System.out.println("args = [" + scene + "]");
+                                System.out.println("args = [" + suggestion + "]");
+                            }
+                        }else{
+                            System.out.println("task process fail:" + ((JSONObject)taskResult).getInteger("code"));
+                        }
+                    }
+                } else {
+                    System.out.println("detect not success. code:" + scrResponse.getInteger("code"));
+                }
+            } else {
+                System.out.println("response not success. status:" + httpResponse.getStatus());
+            }
+        } catch (ServerException e) {
+            e.printStackTrace();
+        } catch (ClientException e) {
+            e.printStackTrace();
+        } catch (Exception e){
+            e.printStackTrace();
+        }
     }
 
     /**