package com.doumee.service.business.impl.hksync;
|
|
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.*;
|
import com.doumee.core.haikang.model.param.request.event.visit.EventVisitIccmRequest;
|
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.core.model.LoginUserInfo;
|
import com.doumee.dao.business.model.Device;
|
import com.doumee.dao.business.model.ParkBook;
|
import com.doumee.service.business.ext.HkSyncService;
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.stereotype.Service;
|
|
import javax.servlet.http.HttpServletResponse;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
|
/**
|
* 设备信息表Service实现
|
* @author 江蹄蹄
|
* @date 2023/11/30 15:33
|
*/
|
@Service
|
public class HkSyncBaseServiceImpl implements HkSyncService {
|
|
/**
|
* 同步海康停车库数据
|
* @param param
|
* @return
|
*/
|
@Override
|
// @Async
|
public String syncHkParks(ParkListRequest param){
|
return null;
|
}
|
@Override
|
// @Async
|
public String getServiceUrl(HKGetServiceLoginUrlRequest param){
|
return null;
|
}
|
@Override
|
// @Async
|
public void syncParkRecords(Date date){
|
}
|
|
@Override
|
// @Async
|
public String syncDoors(DoorsListRequest param){
|
return null;
|
}
|
/**
|
* 同步海康门禁设备数据
|
* @param param
|
* @return
|
*/
|
@Override
|
public String syncHkDevices(Device param){
|
|
return null;
|
}
|
@Override
|
public String syncHkLed(Device param){
|
|
return null;
|
}
|
@Override
|
public String syncHkBroadcast(Device param){
|
|
return null;
|
}
|
@Override
|
// @Async
|
public String syncPrivilege(PrivilegeGroupRequest param){
|
|
return null;
|
}
|
@Override
|
public String dealVisitEventIccm(EventVisitIccmRequest param, HttpServletResponse response){
|
return null;
|
}
|
|
@Override
|
public String dealPlatformStatusEvent(EventPlatformRequest param, HttpServletResponse response){
|
return null;
|
}
|
@Override
|
public String dealPlatformCarsEvent(EventPlatformCarsRequest param, HttpServletResponse response){
|
return null;
|
}
|
@Override
|
public String dealAcsEvent(EventAcsRequest param, HttpServletResponse response){
|
return null;
|
}
|
|
@Override
|
public String dealVisitEvent(EventVisitRequest param, HttpServletResponse response){
|
return null;
|
}
|
|
@Override
|
public String dealParkEvent(EventParkRequest param, HttpServletResponse response){
|
return null;
|
}
|
@Override
|
public void cancelEventSub(){ }
|
@Override
|
public String downHKImgs(int type){
|
return null;
|
}
|
@Override
|
public void syncUserData(LoginUserInfo user){
|
}
|
@Override
|
public void syncUserUpdateData(Date start, Date end){
|
}
|
@Override
|
public void syncVistAppointData(Date date){
|
}
|
public void syncVehicleData(){
|
}
|
public String syncPlatforms(PlatformsListRequest param){
|
return null;
|
}
|
public String getPlatformStatus(PlatformStatusRequest param){
|
return null;
|
}
|
@Override
|
public void syncVehicleUpdateData(Date date){
|
}
|
@Override
|
public void syncOrgData( LoginUserInfo user){
|
}
|
@Override
|
public void syncOrgUpdateData( Date start, Date end){
|
}
|
|
@Override
|
public void syncVisitData() {
|
}
|
@Override
|
public void getOutTimeVisitRecord(){
|
}
|
@Override
|
public void getOutTimeVisitRecordIccm(){
|
}
|
@Override
|
public Integer syncEmpowerData(Integer startPage) {
|
return null;
|
}
|
@Override
|
public Integer syncEmpowerFailData(Integer startPage) {
|
return null;
|
}
|
@Override
|
public void syncMemberFailData() {
|
}
|
@Override
|
public void syncMemberDelData(){
|
}
|
@Override
|
public void syncEmpowerDataNew(int start,int end) {
|
}
|
@Override
|
public void syncParkBookData() {
|
}
|
@Override
|
public void syncParkBookBySingleModel(ParkBook c) {
|
}
|
@Override
|
public Integer syncEmpowerResultData(Integer endId) {return null;
|
}
|
@Override
|
public Integer syncEmpowerDetailData(Integer endId) {return null;
|
}
|
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.CARD_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(), "海康创建下载任务失败==================");
|
}
|
}
|
|
@Override
|
public void getAscDeviceStatus() {
|
}
|
}
|
