最新版本541200007最新版本541200007

doum

8 小时以前 0a5d2206db1e39e18e393847f766678e3f9528d4

最新版本541200007最新版本541200007

 server/system_service/src/main/java/com/doumee/core/utils/Constants.java

@@ -59,6 +59,7 @@
    public static final String SIGN_IN_QRCODE_PREFIX ="SIGN_IN_QRCODE_PREFIX" ;
    public static final String JK_PLAN_MAX_CLUSTER ="JK_PLAN_MAX_CLUSTER" ;
    public static final String JK_PLAN_DISTANCE_CLUSTER ="JK_PLAN_DISTANCE_CLUSTER" ;
    public static final String HK_PUSH_THIRD_URL ="HK_PUSH_THIRD_URL" ;

    /**
     * 操作类型，用于做接口验证分组

 server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/WarningServiceImpl.java

@@ -315,6 +315,9 @@
                    model.setSubscribeStatus(Constants.TWO);
                    model.setSubscribeInfo(response.getMsg());
                }

               startCheckThirdDest(eventParam);

            }else{
                model.setSubscribeStatus(Constants.ZERO);
            }
@@ -325,6 +328,32 @@
        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());
        }

    }


    /**
     * 定时获取天气信息执行