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