| | |
| | | import com.doumee.dao.business.join.VisitsJoinMapper; |
| | | import com.doumee.dao.business.model.*; |
| | | import com.doumee.dao.system.model.SystemUser; |
| | | import com.doumee.dao.web.reqeust.SavePlatformWarnEventDTO; |
| | | import com.doumee.service.business.DeviceEventService; |
| | | import com.doumee.service.business.InterfaceLogService; |
| | | import com.doumee.service.business.MemberService; |
| | | import com.doumee.service.business.impl.PlatformWarnEventServiceImpl; |
| | | import com.github.yulichang.interfaces.MPJBaseJoin; |
| | | import com.github.yulichang.wrapper.MPJLambdaWrapper; |
| | | import com.hikvision.artemis.sdk.config.ArtemisConfig; |
| | |
| | | private PlatformEventMapper platformEventMapper; |
| | | @Autowired |
| | | private PlatformLogMapper platformLogMapper; |
| | | @Autowired |
| | | private PlatformWarnEventServiceImpl platformWarnEventService; |
| | | /** |
| | | * 海康门禁事件推送 |
| | | * @param param |
| | |
| | | .orderByDesc(PlatformLog::getCreateDate) |
| | | .last(" limit 1")); |
| | | String v = Long.toString(job.getDoneDate().getTime() - lastBeginPlatform.getCreateDate().getTime() / 1000) ; |
| | | lastBeginPlatform.setRemark(job.getPlatformId().toString()); |
| | | lastBeginPlatform.setParam3(v); |
| | | lastBeginPlatform.setParam2(DateUtil.getDate(lastBeginPlatform.getCreateDate(),"yyyy-MM-dd HH:mm:ss")); |
| | | platformLogMapper.updateById(lastBeginPlatform);//更新上一次作业的完成时间和作业时长 |
| | |
| | | * @param status |
| | | */ |
| | | private void dealCarsInErrorPlatformBiz( PlatformJob model,EventPlatformCarsStatusInfoRequest status) { |
| | | //TODO-----------------处理车辆进入错误月台业务逻辑 |
| | | //处理车辆进入错误月台业务逻辑 |
| | | SavePlatformWarnEventDTO savePlatformWarnEventDTO = new SavePlatformWarnEventDTO(); |
| | | savePlatformWarnEventDTO.setPlatformJobId(model.getId()); |
| | | savePlatformWarnEventDTO.setPlatformId(model.getPlatformId()); |
| | | savePlatformWarnEventDTO.setCarCode(model.getCarCodeFront()); |
| | | savePlatformWarnEventDTO.setEventType(Constants.PlatformWarnEvent.STOP_ERROR.getKey()); |
| | | platformWarnEventService.savePlatformWarnEvent(savePlatformWarnEventDTO); |
| | | |
| | | List<PlatformDevice> deviceList = platformDeviceMapper.selectList(new QueryWrapper<PlatformDevice>().lambda() |
| | | .eq(PlatformDevice::getPlatformId,model.getPlatformId()) |
| | |
| | | continue; |
| | | } |
| | | if(Constants.equalsInteger(device.getType(),Constants.ZERO)){ |
| | | |
| | | //如果是LED |
| | | TransparentChannelBodyRequest body = new TransparentChannelBodyRequest(); |
| | | TransparentChannelHeadRequest head = new TransparentChannelHeadRequest(); |
| | |
| | | body.setMethod("ControlLedGereral");//固定值 |
| | | request.setIndexCode(device.getHkId()); |
| | | request.setOperationType(219);//固定值 |
| | | regions.setActionType(0); |
| | | regions.setActionType(32); |
| | | regions.setContent(content); |
| | | regions.setRegionNo(1); |
| | | regions.setRegionType(14); |
| | | regions.setFontColor(2); |
| | | regions.setFontColor(1); |
| | | regions.setCircleTimes(1);//循环次数 |
| | | regions.setFontSize(31);// |
| | | regions.setFontSize(32);// |
| | | regions.setStayTime(1);//单位?? |
| | | regions.setRegionLeftTopXPos(0); |
| | | regions.setRegionLeftTopYPos(0); |
| | | regions.setRegionRightBottomXPos(255); |
| | | regions.setRegionRightBottomYPos(31); |
| | | request.setRegions(new ArrayList<>()); |
| | | request.getRegions().add(regions); |
| | | regions.setSpeed(13); |
| | | body.setParams(request); |
| | | HKService.transparentchannel(head,body); |
| | | }else if(Constants.equalsInteger(device.getType(),Constants.ZERO)){ |
| | |
| | | if(broadcastList.size()>0){ |
| | | CustomBroadcastRequest request = new CustomBroadcastRequest(); |
| | | request.setAudioPointIndexCode(broadcastList); |
| | | request.setPlayDuration(60);//单位秒 |
| | | request.setPlayDuration(15);//单位秒 |
| | | request.setBroadCastMode("tts"); |
| | | request.setPriority(15); |
| | | request.setPriority(1); |
| | | request.setState(1);//播放/停止标识 1-播放,0-停止 |
| | | request.setPlayTtsContent(content); |
| | | HKService.customBroadcast(request); |