package foundation.alert;
|
|
import foundation.data.entity.Entity;
|
import foundation.data.meta.field.FieldsRuntime;
|
import foundation.data.object.DataObject;
|
import foundation.persist.NamedSQL;
|
import foundation.util.MapList;
|
import foundation.util.Util;
|
|
public class AlertRule {
|
|
private String id;
|
private String code;
|
private String name;
|
private String dataName;
|
private String docIdField;
|
private String sqlName;
|
private String titleTemplate;
|
private String message;
|
private String url;
|
private boolean isUpdateDocument;
|
private MapList<String, AlterNotifier> notifiers;
|
|
final static boolean clearCheckError = false;
|
final static boolean addCheckError = true;
|
|
public void load(Entity entity) throws Exception {
|
id = entity.getString("id");
|
code = entity.getString("code");
|
name = entity.getString("name");
|
dataName = entity.getString("data_name");
|
docIdField = entity.getString("doc_id_field", "id");
|
sqlName = entity.getString("sql_name");
|
titleTemplate = entity.getString("title_template");
|
message = entity.getString("message");
|
url = entity.getString("url");
|
isUpdateDocument = entity.getBoolean("is_update_document", false);
|
notifiers = new MapList<String, AlterNotifier>();
|
}
|
|
|
public void loadOneNotifier(Entity entity) {
|
AlterNotifier notifier = new AlterNotifier();
|
notifier.load(entity);
|
notifiers.add(notifier.getId(), notifier);
|
}
|
|
public void executeOne(String id) throws Exception {
|
//1. 获取目标表的结构，计算出 title
|
String title = calculateTitle();
|
String accountId = getAccountId(dataName);
|
String positionId = getPositionId(dataName);
|
|
//2. 插入 alert表
|
String filterSegment = docIdField + "=" + Util.quotedStr(id);
|
|
NamedSQL namedSQL = NamedSQL.getInstance("insertAlert");
|
namedSQL.setParam("ruleId", this.id);
|
namedSQL.setParam("dataName", dataName);
|
namedSQL.setParam("accountId", accountId);
|
namedSQL.setParam("positionId", positionId);
|
namedSQL.setParam("title", title);
|
namedSQL.setParam("message", message);
|
namedSQL.setParam("filterSegment", filterSegment);
|
|
namedSQL.execute();
|
|
//3. 根据 alert 给业务表增加标识
|
updateDocument(addCheckError,isUpdateDocument);
|
|
}
|
|
public void executeBatch() throws Exception {
|
//1. 获取目标表的结构，计算出 title
|
String title = calculateTitle();
|
String accountId = getAccountId(dataName);
|
String positionId = getPositionId(dataName);
|
String filterSegment = NamedSQL.getInstance(sqlName).toString();
|
|
//2. 更新 alert表
|
updateAlter(filterSegment, title);
|
|
//3. 插入 alert表
|
NamedSQL namedSQL = NamedSQL.getInstance("insertAlert");
|
namedSQL.setParam("ruleId", id);
|
namedSQL.setParam("dataName", dataName);
|
namedSQL.setParam("accountId", accountId);
|
namedSQL.setParam("positionId", positionId);
|
namedSQL.setParam("docId", docIdField);
|
namedSQL.setParam("title", title);
|
namedSQL.setParam("message", message);
|
namedSQL.setParam("filterSegment", filterSegment);
|
|
namedSQL.execute();
|
|
//4. 根据 alert 给业务表增加标识
|
updateDocument(addCheckError, isUpdateDocument);
|
|
//5. 清除 alert表
|
clearAlter(filterSegment);
|
|
//6. 根据 alert 清除业务表的标识
|
updateDocument(clearCheckError, isUpdateDocument);
|
}
|
|
private void updateAlter(String filterSegment, String title) throws Exception {
|
NamedSQL namedSQL = NamedSQL.getInstance("updateAlert");
|
namedSQL.setParam("ruleId", id);
|
namedSQL.setParam("dataName", dataName);
|
namedSQL.setParam("docId", docIdField);
|
namedSQL.setParam("title", title);
|
namedSQL.setParam("filterSegment",filterSegment);
|
|
namedSQL.execute();
|
}
|
|
private void clearAlter(String filterSegment) throws Exception {
|
NamedSQL namedSQL = NamedSQL.getInstance("deleteAlert");
|
namedSQL.setParam("ruleId", id);
|
namedSQL.setParam("dataName", dataName);
|
namedSQL.setParam("docId", docIdField);
|
namedSQL.setParam("filterSegment",filterSegment);
|
|
namedSQL.execute();
|
}
|
|
private void updateDocument(boolean isExistError, boolean isUpdateDocument) throws Exception {
|
if (!isUpdateDocument) {
|
return;
|
}
|
updateDocument(isExistError);
|
}
|
|
private void updateDocument(boolean isExistError) throws Exception {
|
NamedSQL namedSQL = NamedSQL.getInstance("updateDocumentCheckError");
|
namedSQL.setParam("ruleId", id);
|
namedSQL.setParam("dataName", dataName);
|
namedSQL.setParam("docId", docIdField);
|
|
if(isExistError) {
|
namedSQL.setParam("checkError", "T");
|
namedSQL.setParam("isExist", "");
|
}else {
|
namedSQL.setParam("checkError", "");
|
namedSQL.setParam("isExist", "not");
|
}
|
|
namedSQL.execute();
|
}
|
|
public String calculateTitle() {
|
String title = titleTemplate;
|
if(Util.isEmpty(title)) {
|
return "";
|
}
|
title = " concat('" + title +"') ";
|
title = title.replace("@{", "',").replace("}", ",'");
|
return title;
|
}
|
|
private String getPositionId(String dataName) throws Exception {
|
if("md_position".equalsIgnoreCase(dataName)) {
|
return "id";
|
}
|
|
DataObject dataOject = DataObject.getInstance(dataName);
|
FieldsRuntime fieldRuntime = dataOject.getTableFieldMetas();
|
|
if (fieldRuntime.contains("position_id")) {
|
return "position_id";
|
}
|
else {
|
return "null";
|
}
|
}
|
|
private String getAccountId(String dataName) throws Exception {
|
if("md_org_account".equalsIgnoreCase(dataName)) {
|
return "id";
|
}
|
|
DataObject dataOject = DataObject.getInstance(dataName);
|
FieldsRuntime fieldRuntime = dataOject.getTableFieldMetas();
|
|
if (fieldRuntime.contains("account_id")) {
|
return "account_id";
|
}
|
else if(fieldRuntime.contains("customer_id")) {
|
return "customer_id";
|
}
|
else if(fieldRuntime.contains("org_id")) {
|
return "org_id";
|
}
|
else {
|
return "null";
|
}
|
}
|
|
public String getId() {
|
return id;
|
}
|
|
public String getCode() {
|
return code;
|
}
|
|
public String getName() {
|
return name;
|
}
|
|
public String getDataName() {
|
return dataName;
|
}
|
|
public String getDocIdField() {
|
return docIdField;
|
}
|
|
public String getSqlName() {
|
return sqlName;
|
}
|
|
public String getTitleTemplate() {
|
return titleTemplate;
|
}
|
|
public String getUrl() {
|
return url;
|
}
|
|
public MapList<String, AlterNotifier> getNotifiers() {
|
return notifiers;
|
}
|
}
|
