| | |
|---|
| | | model.setSubscribeStatus(Constants.TWO); |
|---|
| | | model.setSubscribeInfo(response.getMsg()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | startCheckThirdDest(eventParam); |
|---|
| | | |
|---|
| | | }else{ |
|---|
| | | model.setSubscribeStatus(Constants.ZERO); |
|---|
| | | } |
|---|
| | |
|---|
| | | warningMapper.updateById(model); |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 检查三方是否需要订阅海康事件 |
|---|
| | | * @param eventParam |
|---|
| | | */ |
|---|
| | | |
|---|
| | | private void startCheckThirdDest(EventSubRequest eventParam) { |
|---|
| | | try { |
|---|
| | | String thirdpath =systemDictDataBiz.queryByCode(Constants.HK_PARAM, Constants.HK_PUSH_THIRD_URL).getCode(); |
|---|
| | | if(StringUtils.isNotBlank(thirdpath)){ |
|---|
| | | String[] ss = thirdpath.split(";"); |
|---|
| | | for(String s : ss){ |
|---|
| | | eventParam.setEventDest(s); |
|---|
| | | BaseResponse response = HKService.eventSub(eventParam); |
|---|
| | | if(Objects.nonNull(response)&&StringUtils.equals(response.getCode(), HKConstants.RESPONSE_SUCCEE)){ |
|---|
| | | log.error("========订阅其他三方地址成功:"+s); |
|---|
| | | }else{ |
|---|
| | | log.error("========订阅其他三方地址错误:"+s); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | }catch (Exception e){ |
|---|
| | | log.error("========订阅其他三方地址错误"+e.getMessage()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | } |
|---|
| | | |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 定时获取天气信息执行 |
|---|
