package grand;
|
|
import foundation.action.ActionProvider;
|
import foundation.alert.ActorType;
|
import foundation.alert.AlertRule;
|
import foundation.alert.AlertRuleBucket;
|
import foundation.alert.AlterNotifier;
|
import foundation.dao.DataPackage;
|
import foundation.dao.DataSource;
|
import foundation.data.entity.Entity;
|
import foundation.data.entity.EntitySet;
|
import foundation.data.object.DataObject;
|
import foundation.persist.NamedSQL;
|
import foundation.persist.SQLRunner;
|
import foundation.user.User;
|
import foundation.util.ID;
|
import foundation.util.MapList;
|
import foundation.util.Util;
|
|
public class NotifyHandler extends ActionProvider{
|
|
@Override
|
protected void publishMethod() {
|
//1. 发送通知
|
addMethod("sendNotifyMessage");
|
}
|
|
public void sendNotifyMessage() throws Exception {
|
DataPackage dataPackage = dataReader.getDataPackage();
|
Entity master = dataPackage.getMasterEntity(DataSource.DB);
|
String notifyCode = context.getStepParam();
|
|
//1. 获取提醒配置
|
AlertRuleBucket alertRuleBucket = AlertRuleBucket.getInstance();
|
AlertRule alertRule = alertRuleBucket.getAlertRule(notifyCode);
|
|
//2. 获取客户信息（id，名称）
|
String accountId = master.getString("account_id");
|
|
if ("md_org_account".equalsIgnoreCase(dataPackage.getName())) {
|
accountId = master.getId();
|
}
|
|
if (Util.isEmpty(accountId)){
|
accountId = master.getString("customer_id");
|
}
|
|
if (Util.isEmpty(accountId)){
|
dataWriter.addValue("sendNotify", "未获取到客户信息，不发送提醒");
|
return ;
|
}
|
|
DataObject dataObject = DataObject.getInstance("md_org_account");
|
Entity account = dataObject.getTableEntity(accountId);
|
|
SQLRunner.beginTrans();
|
try {
|
// 3. 保存提醒
|
String tableName = dataPackage.getMasterDataObject().getTableName();
|
|
NamedSQL namedSQL = NamedSQL.getInstance("insertNotifyMesaage");
|
String notifyId = ID.newValue();
|
namedSQL.setParam("id", notifyId);
|
namedSQL.setParam("account_id",account.getString("id"));
|
namedSQL.setParam("remark",account.getString("account_name"));
|
namedSQL.setParam("notify_id",alertRule.getId());
|
namedSQL.setParam("type_code",alertRule.getCode());
|
namedSQL.setParam("tableName", tableName);
|
String title = alertRule.calculateTitle();
|
namedSQL.setParam("title",title);
|
|
String filterSegment = alertRule.getDocIdField() + "=" + Util.quotedStr(dataPackage.getMasterId());
|
namedSQL.setParam("filterSegment", filterSegment);
|
|
namedSQL.execute();
|
|
//4. 设置通知对象
|
MapList<String, AlterNotifier> notifiers = alertRule.getNotifiers();
|
DataObject userDataObject = DataObject.getInstance("sys_notify_message_user");
|
|
EntitySet entitySet = userDataObject.createTableEntitySet();
|
|
for (AlterNotifier notifier: notifiers) {
|
EntitySet notifierSet = getNotifier(notifyId, accountId, master, notifier);
|
entitySet = EntitySet.appendAll(entitySet, notifierSet);
|
}
|
|
userDataObject.batchInsertEntitySet(entitySet);
|
}catch (Exception e) {
|
logger.info("发送通知失败");
|
e.printStackTrace();
|
SQLRunner.rollback();
|
}
|
|
SQLRunner.commit();
|
}
|
|
private EntitySet getNotifier(String notifyId, String accountId, Entity document, AlterNotifier notifier) throws Exception {
|
String actorId = notifier.getActorId();
|
String actorCode = notifier.getActorType().getCode();
|
|
DataObject dataObject = DataObject.getInstance("sys_notify_message_user");
|
EntitySet entityList = dataObject.createTableEntitySet();
|
|
EntitySet entitySet = null;
|
if(ActorType.User == notifier.getActorType()) {
|
entitySet = User.calculateUser(actorCode, actorId, notifier.getUserId());
|
}
|
else if(ActorType.Position == notifier.getActorType()) {
|
//1. 优先取单据内的岗位
|
String positionId = document.getString("position_id");
|
if (!Util.isEmpty(positionId)) {
|
entitySet = User.calculateUser(actorCode, actorId, positionId);
|
}
|
else {
|
EntitySet positionSet = getAccountEntity(accountId);
|
|
for (Entity position: positionSet) {
|
positionId = position.getString("position_id");
|
EntitySet positionEntitySet = User.calculateUser(actorCode, actorId, positionId);
|
entitySet = EntitySet.appendAll(entitySet, positionEntitySet);
|
}
|
}
|
}
|
else if(ActorType.Employee == notifier.getActorType()) {
|
entitySet = User.calculateUser(actorCode, actorId, null);
|
}
|
else if(ActorType.OrgAccount == notifier.getActorType()) {
|
entitySet = User.calculateUser(actorCode, actorId, accountId);
|
}
|
|
Entity entity;
|
|
if (entitySet == null) {
|
return null;
|
}
|
|
for (Entity user: entitySet) {
|
entity = dataObject.createTableEmptyEntity();
|
entity.setId(ID.newValue());
|
entity.set("parent_id", notifyId);
|
entity.set("actor_type", notifier.getActorType().getCode());
|
entity.set("actor_id", notifier.getActorId());
|
entity.set("is_show", "T");
|
entity.set("user_id", user.getString("sys_user__id"));
|
entityList.append(entity);
|
}
|
|
return entityList;
|
}
|
|
private EntitySet getAccountEntity(String accountId) throws Exception {
|
NamedSQL namedSQL = NamedSQL.getInstance("getAccountEntity");
|
namedSQL.setParam("accountId", accountId);
|
return namedSQL.getEntitySet();
|
}
|
}
|
