From bdbb62001dc4c3c63198270269795e54235c0e40 Mon Sep 17 00:00:00 2001
From: jiangping <jp@doumee.com>
Date: 星期四, 21 十二月 2023 15:34:14 +0800
Subject: [PATCH] 海康接口对接开发

---
 server/dmvisit_service/src/main/java/com/doumee/service/business/impl/hksync/HkSyncBaseServiceImpl.java |   69 ++++++++++++++++++++++++++++++++--
 1 files changed, 65 insertions(+), 4 deletions(-)

diff --git a/server/dmvisit_service/src/main/java/com/doumee/service/business/impl/hksync/HkSyncBaseServiceImpl.java b/server/dmvisit_service/src/main/java/com/doumee/service/business/impl/hksync/HkSyncBaseServiceImpl.java
index 9f44dd3..c983ab6 100644
--- a/server/dmvisit_service/src/main/java/com/doumee/service/business/impl/hksync/HkSyncBaseServiceImpl.java
+++ b/server/dmvisit_service/src/main/java/com/doumee/service/business/impl/hksync/HkSyncBaseServiceImpl.java
@@ -1,16 +1,23 @@
 package com.doumee.service.business.impl.hksync;
 
-import com.doumee.core.haikang.model.param.request.AcsDeviceListRequest;
-import com.doumee.core.haikang.model.param.request.DoorsListRequest;
-import com.doumee.core.haikang.model.param.request.ParkListRequest;
-import com.doumee.core.haikang.model.param.request.PrivilegeGroupRequest;
+import com.doumee.core.constants.ResponseStatus;
+import com.doumee.core.exception.BusinessException;
+import com.doumee.core.haikang.model.HKConstants;
+import com.doumee.core.haikang.model.param.BaseResponse;
+import com.doumee.core.haikang.model.param.request.*;
 import com.doumee.core.haikang.model.param.request.event.acs.EventAcsRequest;
 import com.doumee.core.haikang.model.param.request.event.parks.EventParkRequest;
 import com.doumee.core.haikang.model.param.request.event.visit.EventVisitRequest;
+import com.doumee.core.haikang.model.param.respose.TaskAdditionResponse;
+import com.doumee.core.haikang.service.HKService;
+import com.doumee.dao.business.model.Device;
 import com.doumee.service.business.HkSyncService;
+import org.apache.commons.lang3.StringUtils;
 import org.springframework.stereotype.Service;
 
 import javax.servlet.http.HttpServletResponse;
+import java.util.ArrayList;
+import java.util.List;
 
 /**
  * 璁惧淇℃伅琛⊿ervice瀹炵幇
@@ -94,5 +101,59 @@
     @Override
     public     void syncEmpowerDetailData() {
     }
+    public boolean addTaskDataAllDel(String userId, String taskId, List<Device> deviceList) {
+        if(StringUtils.isBlank(userId )){
+            //蹇呭~鍙傛暟鏍¢獙
+            return  false;
+        }
+        TaskDataAdditionRequest param = new TaskDataAdditionRequest();
+        param.setTaskId(taskId);
+        List<TaskDataAdditionResourceRequest> resourceInfos = new ArrayList<>();//	object[]	True	璧勬簮瀵硅薄
+        for(Device d:deviceList){
+            TaskDataAdditionResourceRequest res = new TaskDataAdditionResourceRequest();
+            res.setChannelNos(d.getChannelNo().split(","));
+            res.setResourceType(d.getResourceType());
+            res.setResourceIndexCode(d.getHkId());
+            resourceInfos.add(res);
+        }
+        List<TaskDataAdditionPersonRequest> personInfos = new ArrayList<>();
+        TaskDataAdditionPersonRequest pinfo = new TaskDataAdditionPersonRequest();
+        pinfo.setOperatorType(HKConstants.OPERA_TYPE.DEL.getKey());
+        pinfo.setPersonId(userId);
+        param.setResourceInfos(resourceInfos);
+        param.setPersonInfos(personInfos);
+        BaseResponse response =  HKService.taskDataAddition(param);
+        if(response!=null
+                && StringUtils.equals(response.getCode(),HKConstants.RESPONSE_SUCCEE)){
+            return true;
+        }else{
+            return  false;
+        }
+    }
+    public boolean startTask(String taskId) {
+        TaskProgressRequest param = new TaskProgressRequest();
+        param.setTaskId(taskId);
+        BaseResponse response =  HKService.taskStart(param);
+        if(response!=null
+                && StringUtils.equals(response.getCode(), HKConstants.RESPONSE_SUCCEE)){
+            return true;
+        }else{
+            return  false;
+        }
+    }
+
+    public  String hkTaskAddtion() {
+        TaskAdditionRequest param = new TaskAdditionRequest();
+        param.setTaskType(HKConstants.TASK_TYPE.FACE.getKey());
+        BaseResponse<TaskAdditionResponse> response = HKService.taskAddition(param);
+        if(response!=null
+                && StringUtils.equals(response.getCode(),HKConstants.RESPONSE_SUCCEE)
+                && response.getData()!=null
+                && StringUtils.isNotBlank(response.getData().getTaskId())){
+            return  response.getData().getTaskId();
+        }else{
+            throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "娴峰悍鍒涘缓涓嬭浇浠诲姟澶辫触==================");
+        }
+    }
 
 }

--
Gitblit v1.9.3