| | |
| | | package org.springblade.jfpt.nettyServer; |
| | | |
| | | import com.alibaba.fastjson.JSONObject; |
| | | import io.netty.buffer.ByteBuf; |
| | | import io.netty.buffer.Unpooled; |
| | | import io.netty.channel.Channel; |
| | |
| | | import org.springblade.jfpt.message.service.IMessageService; |
| | | import org.springblade.jfpt.operation.service.IOperationService; |
| | | import org.springblade.jfpt.operation.vo.OperationVO; |
| | | import org.springblade.jfpt.parcel.util.HttpClientUtils; |
| | | import org.springblade.jfpt.webscoket.service.IPushMsgService; |
| | | import org.springblade.system.user.entity.User; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | |
| | | |
| | | import javax.annotation.PostConstruct; |
| | | import java.text.SimpleDateFormat; |
| | | import java.util.ArrayList; |
| | | import java.util.Date; |
| | | import java.util.List; |
| | | import java.util.Map; |
| | | import java.util.*; |
| | | import java.util.concurrent.ConcurrentHashMap; |
| | | |
| | | @Component |
| | |
| | | |
| | | //通过websocket给前端接警员发送信息 |
| | | serverHandler.pushMsgService.pushMsg(alarm.getAlarmId(), alarm.getId().toString()); |
| | | |
| | | Map<String, String> map = new HashMap<>(); |
| | | map.put("deviceCode", (String) list.get(0).get("serialNumber")); |
| | | map.put("chl", (String) list.get(0).get("channelNumber")); |
| | | |
| | | //请求视频播放地址 |
| | | String params = HttpClientUtils.doGet("https://web.byisf.com:18000/GetPlayUrl", map); |
| | | |
| | | Map<String, Object> data = (Map<String, Object>) JSONObject.parse(params); |
| | | Map<String, Object> datas = (Map<String, Object>) JSONObject.parse(data.get("data").toString()); |
| | | String m3u8 = datas.get("m3u8").toString(); |
| | | |
| | | Map<String, String> rmap = new HashMap<>(); |
| | | rmap.put("url", m3u8); |
| | | |
| | | //请求视频录制 |
| | | String rvideo = HttpClientUtils.doPost("https://web.byisf.com/api/blade-jfpts/rvideo/rVoids", rmap); |
| | | } |
| | | |
| | | outData.add("LEOK#@"); |