diff --git a/src/main/java/com/xujie/sys/modules/ecss/service/impl/CoDelServiceImpl.java b/src/main/java/com/xujie/sys/modules/ecss/service/impl/CoDelServiceImpl.java
index 47fef94c..ff7039cd 100644
--- a/src/main/java/com/xujie/sys/modules/ecss/service/impl/CoDelServiceImpl.java
+++ b/src/main/java/com/xujie/sys/modules/ecss/service/impl/CoDelServiceImpl.java
@@ -137,7 +137,8 @@ public class CoDelServiceImpl implements CoDelService {
String text = "" + "
发货通知单" +data.getDelNo()+"【发票:"+
data.getCmcInvoice()+"】订单取消" + "
";
String textHead = data.getCmcInvoice()+"【发票:"+ data.getCmcInvoice()+"】订单取消";
- String[] mailAddress = coDelMapper.queryUsersByRoleName("关务仓库",data.getSite()).stream().map(SysUserEntity::getEmail).toArray(String[]::new);
+ String[] mailAddress = coDelMapper.queryUsersByRoleName("关务仓库",data.getSite()).stream()
+ .filter(Objects::nonNull).map(SysUserEntity::getEmail).toArray(String[]::new);
// 安全获取创建人邮箱,防止用户不存在或邮箱为空的空指针异常
SysUserEntity creator = coDelMapper.queryByUserName(data.getCreateBy());
@@ -161,7 +162,8 @@ public class CoDelServiceImpl implements CoDelService {
String text = "" + "发货通知单" +data.getDelNo()+"【发票:"+
data.getCmcInvoice()+"】取消废弃,恢复正常" + "
";
String textHead = data.getCmcInvoice()+"【发票:"+ data.getCmcInvoice()+"】取消废弃";
- String[] mailAddress = coDelMapper.queryUsersByRoleName("关务仓库",data.getSite()).stream().map(SysUserEntity::getEmail).toArray(String[]::new);
+ String[] mailAddress = coDelMapper.queryUsersByRoleName("关务仓库",data.getSite()).stream()
+ .filter(Objects::nonNull).map(SysUserEntity::getEmail).toArray(String[]::new);
// 安全获取创建人邮箱,防止用户不存在或邮箱为空的空指针异常
SysUserEntity creator = coDelMapper.queryByUserName(data.getCreateBy());
@@ -185,7 +187,13 @@ public class CoDelServiceImpl implements CoDelService {
String text = "" + "发货通知单" +data.getDelNo()+"【发票:"+
data.getCmcInvoice()+"】已下达" + "
";
String textHead = "发货通知单"+data.getDelNo()+"【发票:"+ data.getCmcInvoice()+"】下达";
- String[] mailAddress = coDelMapper.queryUsersByRoleName("关务仓库",data.getSite()).stream().map(SysUserEntity::getEmail).toArray(String[]::new);
+ String[] mailAddress = coDelMapper
+ .queryUsersByRoleName("关务仓库", data.getSite())
+ .stream()
+ .filter(Objects::nonNull)
+ .map(SysUserEntity::getEmail)
+ .filter(email -> email != null && !email.trim().isEmpty())
+ .toArray(String[]::new);
if (mailAddress.length>0) {
sendMailUtil(textHead, text,mailAddress, data);
}
@@ -230,7 +238,8 @@ public class CoDelServiceImpl implements CoDelService {
ecssCoDelNotifyDetail.get(0).getQty().setScale(0, RoundingMode.HALF_UP)+""
+" 变更后数量:"+data.getQty()+"";
String textHead = data.getDelNo()+"【发票:"+ data.getCmcInvoice()+"】改单[发货数量变更]";
- String[] mailAddress = coDelMapper.queryUsersByRoleName("关务仓库",data.getSite()).stream().map(SysUserEntity::getEmail).toArray(String[]::new);
+ String[] mailAddress = coDelMapper.queryUsersByRoleName("关务仓库",data.getSite()).stream()
+ .filter(Objects::nonNull).map(SysUserEntity::getEmail).toArray(String[]::new);
// 安全获取创建人邮箱,防止用户不存在或邮箱为空的空指针异常
SysUserEntity creator = coDelMapper.queryByUserName(checkHeader.get(0).getCreateBy());
@@ -257,7 +266,8 @@ public class CoDelServiceImpl implements CoDelService {
"PN:" + data.getPn() +" 数量:"+data.getQty()+
" 新增发货
";
String textHead = data.getDelNo()+"【发票:"+ data.getCmcInvoice()+"】改单[新增发货]";
- String[] mailAddress = coDelMapper.queryUsersByRoleName("关务仓库",data.getSite()).stream().map(SysUserEntity::getEmail).toArray(String[]::new);
+ String[] mailAddress = coDelMapper.queryUsersByRoleName("关务仓库",data.getSite()).stream()
+ .filter(Objects::nonNull).map(SysUserEntity::getEmail).toArray(String[]::new);
// 安全获取创建人邮箱,防止用户不存在或邮箱为空的空指针异常
SysUserEntity creator = coDelMapper.queryByUserName(checkHeader.get(0).getCreateBy());
@@ -307,7 +317,8 @@ public class CoDelServiceImpl implements CoDelService {
"PN:" + data.getPn() +" 数量:"+qty+
" 取消发货
";
String textHead = data.getDelNo()+"【发票:"+ data.getCmcInvoice()+"】改单[取消发货]";
- String[] mailAddress = coDelMapper.queryUsersByRoleName("关务仓库",data.getSite()).stream().map(SysUserEntity::getEmail).toArray(String[]::new);
+ String[] mailAddress = coDelMapper.queryUsersByRoleName("关务仓库",data.getSite()).stream()
+ .filter(Objects::nonNull).map(SysUserEntity::getEmail).toArray(String[]::new);
// 安全获取创建人邮箱,防止用户不存在或邮箱为空的空指针异常
SysUserEntity creator = coDelMapper.queryByUserName(checkHeader.get(0).getCreateBy());