240807 对接海康监控

package com.chery.project.control.service.impl; import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONObject; import com.chery.common.constant.Constants; import com.chery.common.enums.ProtocolType; import com.chery.common.utils.DictUtils; import com.chery.common.utils.StringUtils; import com.chery.framework.redis.RedisCache; import com.chery.project.control.bo.Monitor; import com.chery.project.control.bo.Result; import com.chery.project.control.service.HiKiService; import com.hikvision.artemis.sdk.ArtemisHttpUtil; import com.hikvision.artemis.sdk.config.ArtemisConfig; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Service; import java.util.HashMap; import java.util.Map; /** * 海康服务 */ @Service public class HiKiServiceImpl implements HiKiService { public final static String HI_KI_STATION_VOUCHER = "hiki_station_voucher"; // private static String ARTEMIS_PATH = "/artemis"; private static String contentType = "application/json"; final String previewURLsApi = "/artemis/api/video/v2/cameras/previewURLs"; Map<String, String> path = new HashMap<String, String>(2) { { put("https://", previewURLsApi);//根据现场环境部署确认是http还是https } }; @Value("${hk.host}") private String host; @Value("${hk.appkey}") private String appkey; @Value("${hk.appsecret}") private String appsecret; @Autowired private RedisCache redisCache; /** * 根据监控ip获取码流 * * @param ip * @return */ @Override public Monitor getStreamFlowByIp(String ip) { //获取凭证 final String soundPostId = DictUtils.getDictValue(HI_KI_STATION_VOUCHER, ip); final Result video = getVideo(soundPostId, ProtocolType.HLS, "streamform=ps"); return video.getData(); } /** * 根据监控凭证获取视频码流 * @param soundPostId * @param protocolType * @param expandStr * @return */ public Result getVideo(String soundPostId, ProtocolType protocolType, String expandStr){ ArtemisConfig artemisConfig = new ArtemisConfig(); artemisConfig.setHost(host); artemisConfig.setAppKey(appkey); artemisConfig.setAppSecret(appsecret); JSONObject jsonBody = new JSONObject(); Result result = new Result(); jsonBody.put("streamType", 0); jsonBody.put("protocol", protocolType.value()); jsonBody.put("transmode", 1); jsonBody.put("expand", expandStr); String resultString = null;// post请求application/json类型参数 System.out.println("soundPostId::"+soundPostId); if (StringUtils.isNotEmpty(soundPostId)) { jsonBody.put("cameraIndexCode", soundPostId); String body = jsonBody.toJSONString(); try { resultString = ArtemisHttpUtil.doPostStringArtemis(artemisConfig, path, body, null, null, contentType, null); System.out.println(soundPostId+":调用接口情况:"+resultString); } catch (Exception e) { System.out.println("异常节点.soundPostId="+soundPostId); throw new RuntimeException(e); } JSONObject jsonObject = JSONObject.parseObject(resultString); result = JSON.toJavaObject(jsonObject, Result.class); if (result.getData() != null) { if (StringUtils.isNotEmpty(result.getCode())) { result.getData().setCode(result.getCode()); } if (StringUtils.isNotEmpty(result.getMsg())) { result.getData().setMsg(result.getMsg()); } } } return result; } }