product-server-administration
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
杜洪波
2025-05-14 9db1c6c261049fbdcb104e6c0e07fa544bb42013 
 src/main/java/com/product/administration/service/EarlyWarningServer.java


@@ -1,18 +1,18 @@


package com.product.administration.service;




import java.lang.reflect.InvocationTargetException;


import java.lang.reflect.Method;


import java.util.*;


import java.util.regex.Matcher;


import java.util.regex.Pattern;


import java.util.stream.Collectors;




import cn.hutool.core.collection.CollectionUtil;


import cn.hutool.cron.CronUtil;


import com.google.common.collect.Sets;


import com.product.administration.config.SystemCode;


import com.product.common.collect.SetUtils;


import com.product.quartz.util.CronUtils;


import com.product.util.SystemParamReplace;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.context.ApplicationContext;


import org.springframework.stereotype.Service;




import com.product.administration.config.CmnConst;


@@ -34,6 +34,9 @@




   @Autowired


   BaseDao baseDao;


	


   @Autowired


   private ApplicationContext applicationContext;




   @Autowired


   FlowService flowService;


@@ -75,10 +78,201 @@


         }


         singleWarningTask(fseWarningConfig);


      } catch (Exception e) {


         e.printStackTrace();


         SpringMVCContextHolder.getSystemLogger().error(e);


      }


   }


	


   /**


    * 特殊预警


    * 预警数据来源于其它业务（对象方法调用），验证条件来源于其它业务（bean调用）


    * 数据替换依然来源于配置表


    *


    * @param configUuid


    * @param dtService 预警的业务数据，关联设备数据


    */


   public void warningCreate(String configUuid, DataTableEntity dtServiceData, Map<String, String> mapFields) {


		


      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 warnContent = fseWarningConfig.getString(CmnConst.WARNING_CONTENT_HIDE);        //提醒内容


      String warnMethod = fseWarningConfig.getString(CmnConst.WARNING_METHOD);               //预警方式




      String serviceReceiver = fseWarningConfig.getString(CmnConst.BUSINESS_RELATED_PERSON); //业务相关人员(表名.字段名)


      String fixedReceiver = fseWarningConfig.getString(CmnConst.FIXED_RECEIVER);            //固定接收人


		


      //获取发送消息频率


      Double cronExpression = fseWarningConfig.getDouble("reminder_frequency");




      //发送消息的频率 1.23 小数点前面代表天 小数点后面代表小时


      double seconds = 0;


      if (cronExpression != null && cronExpression > 0) {


         //将发送消息频率转换为小时


         double hours = cronExpression * 24;


         //将发送消息频率转换为分钟


         double minutes = hours * 60;


         //将发送消息频率转换为秒


         seconds = minutes * 60;


      }




      Map<String, String> tableNameAndAlias = new HashMap<>();//相关表名-->表别名,tableName-->tableName1


      Map<String, String> fieldAndAlias = new HashMap<>();    //相关字段-->字段别名,tableName.fieldName-->tableName1fieldName


      Map<String, String> fieldReference = new HashMap<>();   //组合相关字段的参照,tableName1fieldName-->referenceName


      StringBuilder concatField = new StringBuilder();        //组合相关字段,tableName1.fieldName tableName1fieldName


      //解析业务相关人员


      if (!StringUtils.isEmpty(serviceReceiver)) {


         parseWarningContent(serviceReceiver, concatField, tableNameAndAlias, fieldAndAlias, fieldReference);


      }


      //解析预警内容


      if (!StringUtils.isEmpty(warnContent)) {


         parseWarningContent(warnContent, concatField, tableNameAndAlias, fieldAndAlias, fieldReference);


      }


		


      DataTableEntity dtParmFault = null;


      String beanAndMehtod = fseWarningConfig.getString("bean");


      Object bean = applicationContext.getBean(beanAndMehtod.split("\\.")[0]);


      try {


         Method method = bean.getClass().getMethod(beanAndMehtod.split("\\.")[1], DataTableEntity.class, Map.class);


         dtParmFault = (DataTableEntity)method.invoke(bean, dtServiceData, mapFields);


      } catch (IllegalAccessException | IllegalArgumentException | InvocationTargetException e) {


         e.printStackTrace();


      } catch (NoSuchMethodException e) {


         e.printStackTrace();


      } catch (SecurityException e) {


         e.printStackTrace();


      }


      if (!BaseUtil.dataTableIsEmpty(dtParmFault)) {


         // 获取相关设备历史最新预警


         Object[] limitParam = dtParmFault.getFieldAllValues("unique_key");


         StringBuilder sqlWarnHistory = new StringBuilder();


         sqlWarnHistory.append("SELECT e.* \n");


         sqlWarnHistory.append("FROM product_sys_early_warning_info e \n");


         sqlWarnHistory.append("JOIN ( \n");


         sqlWarnHistory.append(" SELECT data_uuid, MAX(early_warning_datetime) AS latest_datetime \n");


         sqlWarnHistory.append(" FROM product_sys_early_warning_info ");


         sqlWarnHistory.append(" WHERE early_warning_uuid=? and (").append(BaseUtil.buildQuestionMarkFilter("data_uuid", limitParam, true)).append(") \n");


         sqlWarnHistory.append(" GROUP BY data_uuid \n");


         sqlWarnHistory.append(") AS latest ON e.data_uuid = latest.data_uuid AND e.early_warning_datetime = latest.latest_datetime");


         DataTableEntity dtLastWarn = baseDao.listTable(sqlWarnHistory.toString(), new Object[] {configUuid});


         Map<String, FieldSetEntity> mapLastWarn = new HashMap<>();


         if (!DataTableEntity.isEmpty(dtLastWarn)) {


            for (int j = 0; j < dtLastWarn.getRows(); j++) {


               FieldSetEntity fse = dtLastWarn.getFieldSetEntity(j);


               mapLastWarn.put(fse.getString("data_uuid"), fse);


            }


         }


         // 遍历预警数据


         for (int j = 0; j < dtParmFault.getRows(); j++) {


            FieldSetEntity fseParamFault = dtParmFault.getFieldSetEntity(j);


            String deviceUUID = fseParamFault.getString(mapFields.get("device_code_field"));


            String paramType = fseParamFault.getString(mapFields.get("param_type_field"));


            String faultGrade = fseParamFault.getString("fault_grade_uuid");




            // 业务uuid（该数据特指：设备,参数）


            String uniqueKey = fseParamFault.getString("unique_key");




            // 判断是否预警


            if (mapLastWarn.containsKey(uniqueKey) && !StringUtils.isEmpty(cronExpression)) {


               //如果已经存在预警信息 根据cron表达式判断是否需要再次预警


               Date lastWarnTime = mapLastWarn.get(uniqueKey).getDate("early_warning_datetime");


               if (lastWarnTime != null) {


                  long time = new Date().getTime() - lastWarnTime.getTime();


                  if (time < seconds * 1000) {


                     continue;


                  }


               }


            }


				


            // 获取视图数据


            StringBuilder sqlData = new StringBuilder();


            sqlData.append("SELECT ").append(concatField.subSequence(1, concatField.length())).append(" \n");


            sqlData.append("FROM ").append(mainTableName).append(" " + tableNameAndAlias.get(mainTableName)).append(" \n");


            sqlData.append("WHERE ").append("device_number = ? AND param_config_uuid = ? AND uuid = ?");


            FieldSetEntity fseService = baseDao.getFieldSetEntityBySQL(sqlData.toString(),


                  new Object[] {deviceUUID, paramType, faultGrade}, false);


				


            //信息接收人


            Set<String> receiverSet = Sets.newTreeSet();




            //装载业务接收人


            String tempStr;


            if (!StringUtils.isEmpty(serviceReceiver)) {


               String[] splitReceiver = serviceReceiver.replace("{#", "").replace("#}", "").split(",");


               for (int k = 0; k < splitReceiver.length; k++) {


                  tempStr = fseService.getString(fieldAndAlias.get(splitReceiver[k]));


                  if (!StringUtils.isEmpty(tempStr)) {


                     for (String singlePerson : tempStr.split(",")) {


                        receiverSet.add(singlePerson);


                     }


                  }


               }


            }




            // 若是勾选了直属领导，那么一并添加上 6c 2022年3月22日 09:25:43


            if ("1".equals(fseWarningConfig.getString(CmnConst.DIRECT_LEADER_FLAG)) && !receiverSet.isEmpty()) {


               StringBuilder directLeaderSql = new StringBuilder(256);


               directLeaderSql.append("SELECT l.user_id,l.show_name,l.direct_leader_code,l.tricode \n");


               directLeaderSql.append("FROM product_sys_staffs l \n");


               directLeaderSql.append("INNER JOIN ( \n");


               directLeaderSql.append(" SELECT user_id,show_name,direct_leader_code,tricode \n");


               directLeaderSql.append(" FROM product_sys_staffs \n");


               directLeaderSql.append(" WHERE ").append(BaseUtil.buildQuestionMarkFilter("user_id", receiverSet.size(), true));


               directLeaderSql.append("\n) p ON l.tricode=p.direct_leader_code");


               DataTableEntity directLeaderDte = baseDao.listTable(directLeaderSql.toString(), receiverSet.toArray());


               FieldSetEntity directLeaderFse;


               for (int k = 0; k < directLeaderDte.getRows(); k++) {


                  directLeaderFse = directLeaderDte.getFieldSetEntity(k);


                  receiverSet.add(directLeaderFse.getString(CmnConst.USER_ID));


               }


            }




            //装载固定接收人


            if (!StringUtils.isEmpty(fixedReceiver)) {


               String[] splitReceiver = fixedReceiver.split(",");


               for (int k = 0; k < splitReceiver.length; k++) {


                  FieldSetEntity fseStaff = baseDao.getFieldSetEntityByFilter("product_sys_users", "user_id=?", new Object[]{splitReceiver[k]}, false);


                  receiverSet.add(fseStaff.getString(CmnConst.USER_ID));


               }


            }




            //暂时替换提醒内容


            warnContent = SystemParamReplace.replaceParams(warnContent, fseService);


            String content = getContentByTableSource(fseService, warnContent, fieldReference);


//            content = content.replace("【参数值】", fseParamFault.getString(fseParamFault.getString("target_value_field")));


				


            String allReceiver = SetUtils.set2String(receiverSet, ",");


				


            //自动生成预警日志信息


            FieldSetEntity fseWarnLog = new FieldSetEntity(CmnConst.PRODUCT_SYS_EARLY_WARNING_INFO);


            fseWarnLog.setValue(CmnConst.EARLY_WARNING_DATETIME, new Date());


            fseWarnLog.setValue(CmnConst.EARLY_WARNING_UUID, configUuid);


            fseWarnLog.setValue(CmnConst.DATA_UUID, uniqueKey);


//            fse.setValue(CmnConst.DATA_UUID, serviceId);


            fseWarnLog.setValue(CmnConst.WARNING_CONTENT, content);


            fseWarnLog.setValue(CmnConst.RECEIVER, allReceiver);


            fseWarnLog.setValue(CmnConst.WARNING_METHOD, warnMethod);


            baseDao.add(fseWarnLog);


				


            //发送信息


            if (!StringUtils.isEmpty(warnMethod)) {


               String[] send_method = warnMethod.split(",");


               for (int k = 0; k < send_method.length; k++) {


                  if ("1".equals(send_method[k])) {    //系统消息


                     WebsocketMesssageServiceThread.getInstance().appendMessage(allReceiver, content, "预警消息", 1, "31", CmnConst.BUTTON_URL_WARN_MESSAGE_INFO + "?uuid=" + fseWarnLog.getUUID(), CmnConst.PRODUCT_SYS_EARLY_WARNING_INFO, fseWarnLog.getUUID(), 1, 0, 0);


                  } else if ("2".equals(send_method[k])) {    //电子邮件


                     parseMail(content, allReceiver);


                  } else if ("3".equals(send_method[k])) {    //短信消息


                     parseSMS(content, allReceiver);


                  }


               }


            }


         }


      }


   }


   /**


    * 单个预警


    *


@@ -162,46 +356,36 @@


      //查询符合预警的数据


      DataTableEntity dtService = baseDao.listTable(serviceSQL.toString(), new Object[]{});


      if (!BaseUtil.dataTableIsEmpty(dtService)) {


         List<String> collect = dtService.getData().stream().map(item -> item.getString(mainTableAlias + "uuid")).collect(Collectors.toList());


         //预警uuid


         String warnUUID = fseWarningConfig.getUUID();


         //将预警uuid放到collect 的第一个




         collect.add(0, warnUUID);


         Object[] serviceCollect = dtService.getFieldAllValues(mainTableAlias + "uuid");


			


         StringBuilder sql = new StringBuilder();


         //查询是否已经存在预警如有相同data_uuid的数据查询出最近的一条根据预警时间字段 early_warning_datetime


//         SELECT e.*


//         FROM product_sys_early_warning_info e


//         JOIN (


//               SELECT data_uuid, MAX(early_warning_datetime) AS latest_datetime


//               FROM product_sys_early_warning_info


//               GROUP BY data_uuid


//         ) AS latest


//         ON e.data_uuid = latest.data_uuid AND e.early_warning_datetime = latest.latest_datetime;


         sql.append("SELECT e.* FROM product_sys_early_warning_info e JOIN (");


         sql.append("SELECT data_uuid, MAX(early_warning_datetime) AS latest_datetime FROM product_sys_early_warning_info ");


         sql.append(" where early_warning_uuid=? and (").append(BaseUtil.buildQuestionMarkFilter("data_uuid", collect.size(), true)).append(") ");


         sql.append("GROUP BY data_uuid) AS latest ON e.data_uuid = latest.data_uuid AND e.early_warning_datetime = latest.latest_datetime");


         DataTableEntity dt = baseDao.listTable(sql.toString(), collect.toArray());


         sql.append("SELECT e.* \n");


         sql.append("FROM product_sys_early_warning_info e \n");


         sql.append("JOIN ( \n");


         sql.append(" SELECT data_uuid, MAX(early_warning_datetime) AS latest_datetime \n");


         sql.append(" FROM product_sys_early_warning_info \n");


         sql.append(" WHERE early_warning_uuid=? and (").append(BaseUtil.buildQuestionMarkFilter("data_uuid", serviceCollect, true)).append(") \n");


         sql.append(" GROUP BY data_uuid \n");


         sql.append(") AS latest ON e.data_uuid = latest.data_uuid AND e.early_warning_datetime = latest.latest_datetime");


         DataTableEntity dtLastWarn = baseDao.listTable(sql.toString(), new Object[] {fseWarningConfig.getUUID()});




         Map<String, FieldSetEntity> ff = new HashMap<>();


         if (!DataTableEntity.isEmpty(dt)) {


            for (int j = 0; j < dt.getRows(); j++) {


               FieldSetEntity fse = dt.getFieldSetEntity(j);


               ff.put(fse.getString("data_uuid"), fse);


         Map<String, FieldSetEntity> mapListWarn = new HashMap<>();


         if (!DataTableEntity.isEmpty(dtLastWarn)) {


            for (int j = 0; j < dtLastWarn.getRows(); j++) {


               FieldSetEntity fse = dtLastWarn.getFieldSetEntity(j);


               mapListWarn.put(fse.getString("data_uuid"), fse);


            }


         }




         //以data_uuid 进行分组


         for (int j = 0; j < dtService.getRows(); j++) {


            FieldSetEntity fseService = dtService.getFieldSetEntity(j);




            //业务uuid


            String serviceId = fseService.getString(mainTableAlias + "uuid");




            if (ff.containsKey(serviceId) && StringUtils.isEmpty(cronExpression)) {


            if (mapListWarn.containsKey(serviceId) && !StringUtils.isEmpty(cronExpression)) {


               //如果已经存在预警信息 根据cron表达式判断是否需要再次预警


               Date preTime = ff.get(serviceId).getDate("early_warning_datetime");


               Date preTime = mapListWarn.get(serviceId).getDate("early_warning_datetime");


               if (preTime != null) {


                  long time = new Date().getTime() - preTime.getTime();


                  if (time < seconds * 1000) {


@@ -247,14 +431,16 @@




            //装载固定接收人


            if (!StringUtils.isEmpty(fixedReceiver)) {


               FieldSetEntity fseOrgnaiztion = baseDao.getFieldSetEntity("product_sys_organizational_structure_storage", fixedReceiver, false);


               if (!StringUtils.isEmpty(fseOrgnaiztion.getString("staff_ids"))) {


                  String[] splitReceiver = fseOrgnaiztion.getString("staff_ids").split(",");


//               FieldSetEntity fseOrgnaiztion = baseDao.getFieldSetEntity("product_sys_organizational_structure_storage", fixedReceiver, false);


//               if (!StringUtils.isEmpty(fseOrgnaiztion.getString("staff_ids"))) {


//                  String[] splitReceiver = fseOrgnaiztion.getString("staff_ids").split(",");


                  String[] splitReceiver = fixedReceiver.split(",");


                  for (int k = 0; k < splitReceiver.length; k++) {


                     FieldSetEntity fseStaff = baseDao.getFieldSetEntityByFilter("product_sys_staffs", "staff_id=?", new Object[]{splitReceiver[k]}, false);


                     receiverSet.add(fseStaff.getString(CmnConst.USER_ID));


//                     FieldSetEntity fseStaff = baseDao.getFieldSetEntityByFilter("product_sys_staffs", "staff_id=?", new Object[]{splitReceiver[k]}, false);


//                     receiverSet.add(fseStaff.getString(CmnConst.USER_ID));


                     receiverSet.add(splitReceiver[k]);


                  }


               }


//               }


            }




            //装载流程相关人


@@ -271,7 +457,7 @@


            FieldSetEntity fse = new FieldSetEntity();


            fse.setTableName(CmnConst.PRODUCT_SYS_EARLY_WARNING_INFO);


            fse.setValue(CmnConst.EARLY_WARNING_DATETIME, new Date());


            fse.setValue(CmnConst.EARLY_WARNING_UUID, warnUUID);


            fse.setValue(CmnConst.EARLY_WARNING_UUID, fseWarningConfig.getUUID());


            fse.setValue(CmnConst.DATA_UUID, serviceId);


            fse.setValue(CmnConst.WARNING_CONTENT, content);


            fse.setValue(CmnConst.RECEIVER, allReceiver);


@@ -538,7 +724,7 @@


            return fseUser.getString(CmnConst.USER_NAME);


         }


      } else if (referenceName.indexOf("》") > -1) {    //数据字典


         referenceName.replace("《", "").replace("》", "");


         referenceName = referenceName.replace("《", "").replace("》", "");


         FieldSetEntity fseDict = baseDao.getFieldSetEntityByFilter(CmnConst.PRODUCT_SYS_DICT, "dict_name=? AND dict_value=?", new Object[]{referenceName, originValue}, false);


         if (fseDict == null) {


            throw new BaseException("", "", this.getClass(), "");