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.EventParkRequest; import com.doumee.core.haikang.model.param.request.event.visit.EventVisitRequest; import com.doumee.core.haikang.model.param.respose.AppointmentInfoResponse; 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.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 void syncParkRecords(Date date){ } @Override // @Async public String syncDoors(DoorsListRequest param){ return null; } /** * 同步海康门禁设备数据 * @param param * @return */ @Override // @Async public String syncHkDevices(AcsDeviceListRequest param){ return null; } @Override // @Async public String syncPrivilege(PrivilegeGroupRequest param){ 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(){ } @Override public void syncUserUpdateData(Date start, Date end){ } @Override public void syncVistAppointData(Date date){ } public void syncVehicleData(){ } @Override public void syncVehicleUpdateData(Date date){ } @Override public void syncOrgData( ){ } @Override public void syncOrgUpdateData( Date start, Date end){ } @Override public void syncVisitData() { } @Override public void getOutTimeVisitRecord(){ } @Override public Integer syncEmpowerData(Integer startPage) { return null; } @Override public void syncEmpowerDataNew(int start,int end) { } @Override public void syncParkBookData() { } @Override public void syncParkBookBySingleModel(ParkBook c) { } @Override public void syncEmpowerResultData() { } @Override public void syncEmpowerDetailData() { } public boolean addTaskDataAllDel(String userId, String taskId, List deviceList) { if(StringUtils.isBlank(userId )){ //必填参数校验 return false; } TaskDataAdditionRequest param = new TaskDataAdditionRequest(); param.setTaskId(taskId); List 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 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 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(), "海康创建下载任务失败=================="); } } }