zm
2024-11-12 2e8250c824a5ed0a0720c50fc3421257ee45073b
src/main/java/com/product/administration/service/EarlyWarningServer.java
@@ -81,11 +81,15 @@
   /**
    * 单个预警,特殊预警已经有预警的数据了,别的业务主动调此方法,去发送预警消息
    *
    * @param fseWarningConfig
    * @param dtService预警的业务数据
    * @param configUuid
    * @param dtService 预警的业务数据,关联设备数据
    */
   public void warningCreate(FieldSetEntity fseWarningConfig,DataTableEntity dtService) {
   public void warningCreate(String configUuid,DataTableEntity dtService) {
      
      FieldSetEntity fseWarningConfig = baseDao.getFieldSetEntity(CmnConst.PRODUCT_SYS_EARLY_WARNING, configUuid, false);
      if (!"1".equals(fseWarningConfig.getString(CmnConst.CONFIG_STATUS))) {
         throw new BaseException(SystemCode.WARN_NO_NORMAL_STATUS_RECORD);
      }
      String mainTableName = fseWarningConfig.getString(CmnConst.SOURCE_TABLE);                //主表名
      String mainTableAlias = mainTableName + "1";                                                //主表别名
//
@@ -163,7 +167,12 @@
//      //查询符合预警的数据
//      DataTableEntity dtService = baseDao.listTable(serviceSQL.toString(), new Object[]{});
      
      if (!BaseUtil.dataTableIsEmpty(dtService)) {
      ///----------------设预警检测的bean方法解发验证是否解发预警,返回true,即发生预警------------------
      boolean b=false;
      //-----反射调bean,要改
      //b=xxxxx.month(dtService);
      ///----------------设预警检测的bean方法解发验证是否解发预警,返回true,即发生预警------------------
      if (b) {
         List<String> collect = dtService.getData().stream().map(item -> item.getString(mainTableAlias + "uuid")).collect(Collectors.toList());
         //预警uuid
         String warnUUID = fseWarningConfig.getUUID();