Merge remote-tracking branch 'origin/jtdev' into jtdev

shenyijian

2024-06-24 7d44d7a2a9ee8f55e911d678d78ff25f047cab4d

 skjcmanager/skjcmanager-service/skjcmanager-alerts/src/main/java/cn/gistack/alerts/notice/service/impl/NoticeStrategyImpl.java

@@ -203,6 +203,7 @@
    */
   public String waterFirstOverHandle(String arg1, String arg2) {
      String adCode = "421303000000";
//      String adCode = null;
      // 查询当前策略对应的告警规则信息
      AlarmRule alarmRule = alarmRuleService.getOne(new QueryWrapper<AlarmRule>().eq("rule_name", arg1));
      // 调用中台服务接口查询数据
@@ -343,7 +344,7 @@
      // 查询当前策略对应的告警规则信息
      AlarmRule alarmRule = alarmRuleService.getOne(new QueryWrapper<AlarmRule>().eq("rule_name", arg1));
      // 调用中台服务接口查询数据
      JSONArray ztData = noticeHandle.getZtData("", ZtApiUrlConstant.over_des_rz_warn_api);
      JSONArray ztData = noticeHandle.getZtData("?is_show=1", ZtApiUrlConstant.over_des_rz_warn_api);
      // 获取告警规则详情，判断告警类型（短信，电话，站内信）
      if (null != alarmRule) {
         // 查询告警详情信息
@@ -377,7 +378,7 @@
      // 查询当前策略对应的告警规则信息
      AlarmRule alarmRule = alarmRuleService.getOne(new QueryWrapper<AlarmRule>().eq("rule_name", arg1));
      // 调用中台服务接口查询数据
      JSONArray ztData = noticeHandle.getZtData("", ZtApiUrlConstant.res_over_chec_api);
      JSONArray ztData = noticeHandle.getZtData("?is_show=1", ZtApiUrlConstant.res_over_chec_api);
      // 获取告警规则详情，判断告警类型（短信，电话，站内信）
      if (null != alarmRule) {
         // 查询告警详情信息
@@ -1126,6 +1127,7 @@
      // 调用中台服务接口查询数据
      JSONArray ztData = noticeHandle.getZtData("", ZtApiUrlConstant.alarm_db_sy_rz_1h_change_api);

      // 处理数据
      JSONArray data = judgeType(ztData);
      //这里需要对数据进行过滤
      JSONArray resultData = filterNoAlertRes(data,arg1);
@@ -1231,7 +1233,7 @@


   /**
    * 近1h变形值大于10cm以上
    * 变形值大于100mm
    *
    * @param arg1
    * @param arg2
@@ -1244,7 +1246,7 @@
      // 查询当前策略对应的告警规则信息
      AlarmRule alarmRule = alarmRuleService.getOne(new QueryWrapper<AlarmRule>().eq("rule_name", arg1));
      // 调用中台服务接口查询数据
      JSONArray ztData = noticeHandle.getZtData("", ZtApiUrlConstant.alarm_db_wy_value_1h_change_over_10_api);
      JSONArray ztData = noticeHandle.getZtData("", ZtApiUrlConstant.alarm_db_wy_value_api);
      JSONArray data = judgeDirection(ztData, "3");


@@ -1472,6 +1474,38 @@
      return "视频信息缺失告警";
   }


   /**
    * 策略42: 水位防洪高水位告警
    *
    * @param arg1
    * @param arg2
    * @return
    */
   public String topLevOfFloAlertHandle(String arg1, String arg2) {
      String adCode = null;
      String uuid = UUID.randomUUID().toString();
      // 查询当前策略对应的告警规则信息
      AlarmRule alarmRule = alarmRuleService.getOne(new QueryWrapper<AlarmRule>().eq("rule_name", arg1));
      // 调用中台服务接口查询数据
      JSONArray ztData = noticeHandle.getZtData("", ZtApiUrlConstant.over_flpr_rz_warn_api);
      // 获取告警规则详情，判断告警类型（短信，电话，站内信）
      if (null != alarmRule) {
         // 查询告警详情信息
         List<AlarmRuleDetail> alarmRuleDetailList = alarmRuleDetailService.list(new QueryWrapper<AlarmRuleDetail>().eq("alarm_rule_id", alarmRule.getId()));
         if (alarmRuleDetailList.size() > 0) {
            // 遍历
            for (AlarmRuleDetail alarmRuleDetail : alarmRuleDetailList) {
               if (alarmRuleDetail.getAlarmMode().equals("站内信")) {
                  asyncNoticeHandle.topLevOfFloAlertHandleStation(alarmRule, alarmRuleDetail, ztData, ZtApiDataColumnConstant.topLevOfFloAlertList, true, adCode, true, uuid,arg2);
               }
            }
         }
      }
      // 返回
      return "水位防洪高水位告警";
   }

   private JSONArray filterData(JSONArray ztData, String level) {

      JSONArray array = new JSONArray();
@@ -1543,7 +1577,7 @@
         //左右岸方向
         Double dnVal = jsonObject.getDouble("dn_val");
         //垂直
         Double duValue = jsonObject.getDouble("du_value");
         Double duValue = jsonObject.getDouble("垂直位移");

         String direction = "";
         String val = "";
@@ -1614,7 +1648,7 @@
         }

         jsonObject.put("type", type);
         jsonObject.put("monitor",jsonObject.getString("diff_val"));
         jsonObject.put("monitorData",jsonObject.getString("sy_val"));
         array.add(jsonObject);
      }
      return array;