| | |
|---|
| | | .eq(Device::getIsdeleted,Constants.ZERO) |
|---|
| | | .last("limit 1" )); |
|---|
| | | delRetentionLis.add(member.getId()); |
|---|
| | | if(!(Constants.equalsInteger(d.getIsEntrance(),Constants.ONE) && Constants.formatIntegerNum(request.getData().getExtEventInOut()) != Constants.ONE)){ |
|---|
| | | if(d!=null && !(Constants.equalsInteger(d.getIsEntrance(),Constants.ONE) && Constants.formatIntegerNum(request.getData().getExtEventInOut()) != Constants.ONE)){ |
|---|
| | | //如果是进门，录入人员的在场数据记录 |
|---|
| | | retentionList.add(getRetentionModelByRequest(member,request)); |
|---|
| | | } |
|---|
| | |
|---|
| | | List<EventPlatformInfoRequest> events = param.getParams().getEvents(); |
|---|
| | | List<Platform> list = new ArrayList<>(); |
|---|
| | | for(EventPlatformInfoRequest request : events){ |
|---|
| | | List<EventPlatformDataRequest> dataList = request.getData(); |
|---|
| | | if(dataList ==null || dataList.size()==0){ |
|---|
| | | EventPlatformDataRequest data = request.getData(); |
|---|
| | | if(data ==null ){ |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | Integer workStatus = 0; |
|---|
| | | for(EventPlatformDataRequest data : dataList){ |
|---|
| | | if( data.getHPWorkingStatus() ==null || data.getHPWorkingStatus().size() ==0){ |
|---|
| | | continue;//如何推送状态集合为空，不处理跳过 |
|---|
| | | } |
|---|
| | |
|---|
| | | .last("limit 1")); |
|---|
| | | if(model ==null){ |
|---|
| | | continue;//监控点未同步，跳过处理 |
|---|
| | | |
|---|
| | | } |
|---|
| | | //各车道车辆状态 |
|---|
| | | for(EventPlatformStatusInfoRequest status : data.getHPWorkingStatus()){ |
|---|
| | | |
|---|
| | | |
|---|
| | | } |
|---|
| | | break;//只处理第一个数据状态 |
|---|
| | | } |
|---|
| | | } |
|---|
| | | result = "成功"; |
|---|
| | | log.error("【海康月台工作状态事件推送】========成功======="); |
|---|
