Browse Source

add receivers and receiversCc in SqlParameter and SqlTask

pull/2/head
ligang 6 years ago
parent
commit
586755d821
  1. 7
      escheduler-server/src/main/java/cn/escheduler/server/worker/task/sql/SqlTask.java

7
escheduler-server/src/main/java/cn/escheduler/server/worker/task/sql/SqlTask.java

@ -305,7 +305,7 @@ public class SqlTask extends AbstractTask {
receviersList.add(user.getEmail()); receviersList.add(user.getEmail());
} }
// custom receiver // custom receiver
String receivers = processDefine.getReceivers(); String receivers = StringUtils.isNotEmpty(sqlParameters.getReceivers()) ? sqlParameters.getReceivers() : processDefine.getReceivers();
if (StringUtils.isNotEmpty(receivers)){ if (StringUtils.isNotEmpty(receivers)){
String[] splits = receivers.split(Constants.COMMA); String[] splits = receivers.split(Constants.COMMA);
for (String receiver : splits){ for (String receiver : splits){
@ -315,11 +315,8 @@ public class SqlTask extends AbstractTask {
// copy list // copy list
List<String> receviersCcList = new ArrayList<String>(); List<String> receviersCcList = new ArrayList<String>();
// Custom Copier // Custom Copier
String receiversCc = processDefine.getReceiversCc(); String receiversCc = StringUtils.isNotEmpty(sqlParameters.getReceiversCc()) ? sqlParameters.getReceiversCc() : processDefine.getReceiversCc();
if (StringUtils.isNotEmpty(receiversCc)){ if (StringUtils.isNotEmpty(receiversCc)){
String[] splits = receiversCc.split(Constants.COMMA); String[] splits = receiversCc.split(Constants.COMMA);
for (String receiverCc : splits){ for (String receiverCc : splits){

Loading…
Cancel
Save