|
@@ -9,8 +9,12 @@ import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
|
import com.fasterxml.jackson.core.JsonProcessingException;
|
|
import com.fasterxml.jackson.core.JsonProcessingException;
|
|
import com.fasterxml.jackson.databind.ObjectMapper;
|
|
import com.fasterxml.jackson.databind.ObjectMapper;
|
|
import com.xkcoding.http.util.StringUtil;
|
|
import com.xkcoding.http.util.StringUtil;
|
|
|
|
+
|
|
import jakarta.annotation.Resource;
|
|
import jakarta.annotation.Resource;
|
|
|
|
+
|
|
import lombok.extern.slf4j.Slf4j;
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
|
+
|
|
|
|
+import org.apache.commons.collections4.CollectionUtils;
|
|
import org.apache.commons.lang.StringUtils;
|
|
import org.apache.commons.lang.StringUtils;
|
|
import org.jeecg.common.constant.CacheConstant;
|
|
import org.jeecg.common.constant.CacheConstant;
|
|
import org.jeecg.common.system.vo.DictModel;
|
|
import org.jeecg.common.system.vo.DictModel;
|
|
@@ -79,9 +83,6 @@ public class AdwebEnquiryServiceImpl extends ServiceImpl<AdwebEnquiryMapper, Adw
|
|
private IAdwebPublicEnquiryRuleService AdwebPublicEnquiryRuleService;
|
|
private IAdwebPublicEnquiryRuleService AdwebPublicEnquiryRuleService;
|
|
|
|
|
|
@Resource
|
|
@Resource
|
|
- private GeoIpUtil geoIpService;
|
|
|
|
-
|
|
|
|
- @Resource
|
|
|
|
private ISysDictService dictService;
|
|
private ISysDictService dictService;
|
|
|
|
|
|
@Resource
|
|
@Resource
|
|
@@ -187,7 +188,7 @@ public class AdwebEnquiryServiceImpl extends ServiceImpl<AdwebEnquiryMapper, Adw
|
|
.eq(AdwebPublicEnquiryRule::getIsEnable, 1)
|
|
.eq(AdwebPublicEnquiryRule::getIsEnable, 1)
|
|
.eq(AdwebPublicEnquiryRule::getBlackOrWhiteList, blackOrWhite)
|
|
.eq(AdwebPublicEnquiryRule::getBlackOrWhiteList, blackOrWhite)
|
|
.eq(AdwebPublicEnquiryRule::getUseStatus, useStatus));
|
|
.eq(AdwebPublicEnquiryRule::getUseStatus, useStatus));
|
|
- if (ListUtil.notEmpty(AdwebPublicEnquiryRuleList)) {
|
|
|
|
|
|
+ if (CollectionUtils.isNotEmpty(AdwebPublicEnquiryRuleList)) {
|
|
blackWordList = AdwebPublicEnquiryRuleList.stream().map(AdwebPublicEnquiryRule::getWord).toList();
|
|
blackWordList = AdwebPublicEnquiryRuleList.stream().map(AdwebPublicEnquiryRule::getWord).toList();
|
|
}
|
|
}
|
|
} catch (Exception e) {
|
|
} catch (Exception e) {
|
|
@@ -214,10 +215,10 @@ public class AdwebEnquiryServiceImpl extends ServiceImpl<AdwebEnquiryMapper, Adw
|
|
Map<String, String> principalEmailMap = new HashMap<>();
|
|
Map<String, String> principalEmailMap = new HashMap<>();
|
|
List<String> subAccountIdList = masterSubAccountRelationService.getSubAccountIdByMaster(String.valueOf(adwebSite.getUid()));
|
|
List<String> subAccountIdList = masterSubAccountRelationService.getSubAccountIdByMaster(String.valueOf(adwebSite.getUid()));
|
|
log.info("获取的子账户id:{}", FastJsonUtil.toJSONString(subAccountIdList));
|
|
log.info("获取的子账户id:{}", FastJsonUtil.toJSONString(subAccountIdList));
|
|
- if (ListUtil.notEmpty(subAccountIdList)) {
|
|
|
|
|
|
+ if (CollectionUtils.isNotEmpty(subAccountIdList)) {
|
|
subAccountIdList.add(String.valueOf(adwebSite.getUid()));
|
|
subAccountIdList.add(String.valueOf(adwebSite.getUid()));
|
|
List<SysUser> principalEmailList = sysUserService.list(new QueryWrapper<SysUser>().in("id", subAccountIdList).eq("del_flag", 0).isNotNull("email").ne("email", "").select("id", "email"));
|
|
List<SysUser> principalEmailList = sysUserService.list(new QueryWrapper<SysUser>().in("id", subAccountIdList).eq("del_flag", 0).isNotNull("email").ne("email", "").select("id", "email"));
|
|
- if (ListUtil.notEmpty(principalEmailList)) {
|
|
|
|
|
|
+ if (CollectionUtils.isNotEmpty(principalEmailList)) {
|
|
principalEmailMap = principalEmailList.stream().collect(Collectors.toMap(SysUser::getId, SysUser::getEmail));
|
|
principalEmailMap = principalEmailList.stream().collect(Collectors.toMap(SysUser::getId, SysUser::getEmail));
|
|
|
|
|
|
}
|
|
}
|
|
@@ -275,7 +276,7 @@ public class AdwebEnquiryServiceImpl extends ServiceImpl<AdwebEnquiryMapper, Adw
|
|
* @param principalEmailMap
|
|
* @param principalEmailMap
|
|
*/
|
|
*/
|
|
private void sendValidateEmail(List<AdwebEnquiry> enquiryList, AdwebSite adwebSite, Map<String, String> principalEmailMap) {
|
|
private void sendValidateEmail(List<AdwebEnquiry> enquiryList, AdwebSite adwebSite, Map<String, String> principalEmailMap) {
|
|
- if (ListUtil.isEmpty(enquiryList)) {
|
|
|
|
|
|
+ if (CollectionUtils.isEmpty(enquiryList)) {
|
|
log.info("未获取到需要发送邮件的询盘");
|
|
log.info("未获取到需要发送邮件的询盘");
|
|
return;
|
|
return;
|
|
}
|
|
}
|
|
@@ -283,7 +284,7 @@ public class AdwebEnquiryServiceImpl extends ServiceImpl<AdwebEnquiryMapper, Adw
|
|
|
|
|
|
//特殊站点发送邮件
|
|
//特殊站点发送邮件
|
|
List<DictPropertyModel> siteRes = sysAdwebApiImpl.queryDictInfoByDictCode("turn_inquiry_site_code");
|
|
List<DictPropertyModel> siteRes = sysAdwebApiImpl.queryDictInfoByDictCode("turn_inquiry_site_code");
|
|
- if (ListUtil.notEmpty(siteRes) && siteRes.get(0).getValue().equals(adwebSite.getCode())) {
|
|
|
|
|
|
+ if (CollectionUtils.isNotEmpty(siteRes) && siteRes.get(0).getValue().equals(adwebSite.getCode())) {
|
|
specialSendEmail(enquiryList, adwebSite);
|
|
specialSendEmail(enquiryList, adwebSite);
|
|
} else {
|
|
} else {
|
|
String emailStr = adwebSite.getEnquiryEmailList();
|
|
String emailStr = adwebSite.getEnquiryEmailList();
|
|
@@ -295,7 +296,7 @@ public class AdwebEnquiryServiceImpl extends ServiceImpl<AdwebEnquiryMapper, Adw
|
|
log.info("发送询盘邮件--子账户邮箱:{}", FastJsonUtil.toJSONString(principalEmailMap));
|
|
log.info("发送询盘邮件--子账户邮箱:{}", FastJsonUtil.toJSONString(principalEmailMap));
|
|
|
|
|
|
List<String> emailList = JSON.parseArray(emailStr, String.class);
|
|
List<String> emailList = JSON.parseArray(emailStr, String.class);
|
|
- if (ListUtil.isEmpty(emailList)) {
|
|
|
|
|
|
+ if (CollectionUtils.isEmpty(emailList)) {
|
|
return;
|
|
return;
|
|
}
|
|
}
|
|
|
|
|
|
@@ -462,12 +463,12 @@ public class AdwebEnquiryServiceImpl extends ServiceImpl<AdwebEnquiryMapper, Adw
|
|
log.info("=======发送询盘邮件======");
|
|
log.info("=======发送询盘邮件======");
|
|
enquiryEmailMessageList.forEach(e -> System.out.println(e.getEmail()));
|
|
enquiryEmailMessageList.forEach(e -> System.out.println(e.getEmail()));
|
|
log.info("需要添加的询盘邮件:{}", FastJsonUtil.toJSONString(enquiryEmailMessageList));
|
|
log.info("需要添加的询盘邮件:{}", FastJsonUtil.toJSONString(enquiryEmailMessageList));
|
|
- if (ListUtil.notEmpty(enquiryEmailMessageList)) {
|
|
|
|
|
|
+ if (CollectionUtils.isNotEmpty(enquiryEmailMessageList)) {
|
|
QueryWrapper<EnquiryEmailMessage> enquiryEmailMessageQueryWrapper = new QueryWrapper<>();
|
|
QueryWrapper<EnquiryEmailMessage> enquiryEmailMessageQueryWrapper = new QueryWrapper<>();
|
|
enquiryEmailMessageQueryWrapper.eq("site_code", adwebSite.getCode());
|
|
enquiryEmailMessageQueryWrapper.eq("site_code", adwebSite.getCode());
|
|
List<EnquiryEmailMessage> enquiryEmailMessages = enquiryEmailMessageService.list(enquiryEmailMessageQueryWrapper);
|
|
List<EnquiryEmailMessage> enquiryEmailMessages = enquiryEmailMessageService.list(enquiryEmailMessageQueryWrapper);
|
|
List<EnquiryEmailMessage> sameEnquiryEmailMessageList = new ArrayList<>();
|
|
List<EnquiryEmailMessage> sameEnquiryEmailMessageList = new ArrayList<>();
|
|
- if (ListUtil.notEmpty(enquiryEmailMessages)) {
|
|
|
|
|
|
+ if (CollectionUtils.isNotEmpty(enquiryEmailMessages)) {
|
|
for (EnquiryEmailMessage enquiryEmailMessage : enquiryEmailMessages) {
|
|
for (EnquiryEmailMessage enquiryEmailMessage : enquiryEmailMessages) {
|
|
for (EnquiryEmailMessage enquiryEmailMessage1 : enquiryEmailMessageList) {
|
|
for (EnquiryEmailMessage enquiryEmailMessage1 : enquiryEmailMessageList) {
|
|
if (enquiryEmailMessage.getEnquiryId().equals(enquiryEmailMessage1.getEnquiryId()) && enquiryEmailMessage.getEmail().equals(enquiryEmailMessage1.getEmail())) {
|
|
if (enquiryEmailMessage.getEnquiryId().equals(enquiryEmailMessage1.getEnquiryId()) && enquiryEmailMessage.getEmail().equals(enquiryEmailMessage1.getEmail())) {
|
|
@@ -506,7 +507,7 @@ public class AdwebEnquiryServiceImpl extends ServiceImpl<AdwebEnquiryMapper, Adw
|
|
QueryWrapper<SysUser> sysUserQueryWrapper = new QueryWrapper<>();
|
|
QueryWrapper<SysUser> sysUserQueryWrapper = new QueryWrapper<>();
|
|
sysUserQueryWrapper.eq("is_inquiry", 2);
|
|
sysUserQueryWrapper.eq("is_inquiry", 2);
|
|
sysUserQueryWrapper.eq("status", 1);
|
|
sysUserQueryWrapper.eq("status", 1);
|
|
- if (ListUtil.notEmpty(idList)) {
|
|
|
|
|
|
+ if (CollectionUtils.isNotEmpty(idList)) {
|
|
sysUserQueryWrapper.in("id", idList);
|
|
sysUserQueryWrapper.in("id", idList);
|
|
}
|
|
}
|
|
List<SysUser> sysUsers = sysUserService.list(sysUserQueryWrapper);
|
|
List<SysUser> sysUsers = sysUserService.list(sysUserQueryWrapper);
|
|
@@ -519,7 +520,7 @@ public class AdwebEnquiryServiceImpl extends ServiceImpl<AdwebEnquiryMapper, Adw
|
|
SysUser sysUser = new SysUser();
|
|
SysUser sysUser = new SysUser();
|
|
|
|
|
|
//如果没有子账号,则只给主账号发送邮件
|
|
//如果没有子账号,则只给主账号发送邮件
|
|
- if (ListUtil.isEmpty(sysUsers)) {
|
|
|
|
|
|
+ if (CollectionUtils.isEmpty(sysUsers)) {
|
|
//获取主账号
|
|
//获取主账号
|
|
SysUser mainUser = sysUserService.getById(adwebSite.getUid());
|
|
SysUser mainUser = sysUserService.getById(adwebSite.getUid());
|
|
//主账号邮件信息添加
|
|
//主账号邮件信息添加
|
|
@@ -531,12 +532,12 @@ public class AdwebEnquiryServiceImpl extends ServiceImpl<AdwebEnquiryMapper, Adw
|
|
enquiryEmailMessageList.forEach(e -> System.out.println(e.getEmail()));
|
|
enquiryEmailMessageList.forEach(e -> System.out.println(e.getEmail()));
|
|
|
|
|
|
log.info("需要添加的询盘邮件:{}", FastJsonUtil.toJSONString(enquiryEmailMessageList));
|
|
log.info("需要添加的询盘邮件:{}", FastJsonUtil.toJSONString(enquiryEmailMessageList));
|
|
- if (ListUtil.notEmpty(enquiryEmailMessageList)) {
|
|
|
|
|
|
+ if (CollectionUtils.isNotEmpty(enquiryEmailMessageList)) {
|
|
QueryWrapper<EnquiryEmailMessage> enquiryEmailMessageQueryWrapper = new QueryWrapper<>();
|
|
QueryWrapper<EnquiryEmailMessage> enquiryEmailMessageQueryWrapper = new QueryWrapper<>();
|
|
enquiryEmailMessageQueryWrapper.eq("site_code", adwebSite.getCode());
|
|
enquiryEmailMessageQueryWrapper.eq("site_code", adwebSite.getCode());
|
|
List<EnquiryEmailMessage> enquiryEmailMessages = enquiryEmailMessageService.list(enquiryEmailMessageQueryWrapper);
|
|
List<EnquiryEmailMessage> enquiryEmailMessages = enquiryEmailMessageService.list(enquiryEmailMessageQueryWrapper);
|
|
List<EnquiryEmailMessage> sameEnquiryEmailMessageList = new ArrayList<>();
|
|
List<EnquiryEmailMessage> sameEnquiryEmailMessageList = new ArrayList<>();
|
|
- if (ListUtil.notEmpty(enquiryEmailMessages)) {
|
|
|
|
|
|
+ if (CollectionUtils.isNotEmpty(enquiryEmailMessages)) {
|
|
for (EnquiryEmailMessage enquiryEmailMessage : enquiryEmailMessages) {
|
|
for (EnquiryEmailMessage enquiryEmailMessage : enquiryEmailMessages) {
|
|
for (EnquiryEmailMessage enquiryEmailMessage1 : enquiryEmailMessageList) {
|
|
for (EnquiryEmailMessage enquiryEmailMessage1 : enquiryEmailMessageList) {
|
|
if (enquiryEmailMessage.getEnquiryId().equals(enquiryEmailMessage1.getEnquiryId()) && enquiryEmailMessage.getEmail().equals(enquiryEmailMessage1.getEmail())) {
|
|
if (enquiryEmailMessage.getEnquiryId().equals(enquiryEmailMessage1.getEnquiryId()) && enquiryEmailMessage.getEmail().equals(enquiryEmailMessage1.getEmail())) {
|
|
@@ -635,14 +636,14 @@ public class AdwebEnquiryServiceImpl extends ServiceImpl<AdwebEnquiryMapper, Adw
|
|
adwebEnquiry.setFromEmail(enquiryDto.getFromEmail());
|
|
adwebEnquiry.setFromEmail(enquiryDto.getFromEmail());
|
|
adwebEnquiry.setPluginName(enquiryDto.getPluginName());
|
|
adwebEnquiry.setPluginName(enquiryDto.getPluginName());
|
|
adwebEnquiry.setRecordId(enquiryDto.getRecordId());
|
|
adwebEnquiry.setRecordId(enquiryDto.getRecordId());
|
|
- adwebEnquiry.setModifyRecordCtime(geoIpService.getLocalhostTime(enquiryDto.getFromIp(), enquiryDto.getRecordCtime()));
|
|
|
|
|
|
+ adwebEnquiry.setModifyRecordCtime(geoIpUtil.getLocalhostTime(enquiryDto.getFromIp(), enquiryDto.getRecordCtime()));
|
|
adwebEnquiry.setRecordCtime(enquiryDto.getRecordCtime());
|
|
adwebEnquiry.setRecordCtime(enquiryDto.getRecordCtime());
|
|
adwebEnquiry.setSiteCode(adwebSite.getCode());
|
|
adwebEnquiry.setSiteCode(adwebSite.getCode());
|
|
adwebEnquiry.setModular(enquiryDto.getPluginName());
|
|
adwebEnquiry.setModular(enquiryDto.getPluginName());
|
|
adwebEnquiry.setSysEffective(NumConstant.ONE);
|
|
adwebEnquiry.setSysEffective(NumConstant.ONE);
|
|
adwebEnquiry.setUserEffective(NumConstant.TWO);
|
|
adwebEnquiry.setUserEffective(NumConstant.TWO);
|
|
adwebEnquiry.setSiteHost(enquiryDto.getSiteHost());
|
|
adwebEnquiry.setSiteHost(enquiryDto.getSiteHost());
|
|
- adwebEnquiry.setNo("xp" + DateUtil.dateToString(new Date(), DateUtil.DATE_FORMAT) + adwebOpenApiService.loadNo(adwebSite.getCode()));
|
|
|
|
|
|
+ adwebEnquiry.setNo("xp" + DateUtil.formatDate(new Date(), DateUtil.DATE_FORMAT) + adwebOpenApiService.loadNo(adwebSite.getCode()));
|
|
|
|
|
|
// 外部编号暂无作用,且多查询一次数据库,暂时注释
|
|
// 外部编号暂无作用,且多查询一次数据库,暂时注释
|
|
// adwebEnquiry.setNoOut(DateUtil.dateToString(new Date(), DateUtil.DATE_FORMAT_THREE) + adwebOpenApiService.loadOutNoByUser(adwebSite.getUid()));
|
|
// adwebEnquiry.setNoOut(DateUtil.dateToString(new Date(), DateUtil.DATE_FORMAT_THREE) + adwebOpenApiService.loadOutNoByUser(adwebSite.getUid()));
|
|
@@ -689,7 +690,7 @@ public class AdwebEnquiryServiceImpl extends ServiceImpl<AdwebEnquiryMapper, Adw
|
|
Map<String, JSONObject> formObj = FastJsonUtil.parseObject(form, Map.class);
|
|
Map<String, JSONObject> formObj = FastJsonUtil.parseObject(form, Map.class);
|
|
if (formObj == null || formObj.size() == 0) {
|
|
if (formObj == null || formObj.size() == 0) {
|
|
List<JSONObject> formList = FastJsonUtil.parseObject(form, List.class);
|
|
List<JSONObject> formList = FastJsonUtil.parseObject(form, List.class);
|
|
- if (ListUtil.notEmpty(formList)) {
|
|
|
|
|
|
+ if (CollectionUtils.isNotEmpty(formList)) {
|
|
formItems = formList;
|
|
formItems = formList;
|
|
}
|
|
}
|
|
} else {
|
|
} else {
|
|
@@ -784,7 +785,7 @@ public class AdwebEnquiryServiceImpl extends ServiceImpl<AdwebEnquiryMapper, Adw
|
|
}
|
|
}
|
|
|
|
|
|
private boolean contains(List<String> keys, String key) {
|
|
private boolean contains(List<String> keys, String key) {
|
|
- if (ListUtil.isEmpty(keys) || StringUtil.isEmpty(key)) {
|
|
|
|
|
|
+ if (CollectionUtils.isEmpty(keys) || StringUtil.isEmpty(key)) {
|
|
return false;
|
|
return false;
|
|
}
|
|
}
|
|
key = key.replace(":", "").replace(":", "").replaceAll(" {2,}", " ").toLowerCase().trim();
|
|
key = key.replace(":", "").replace(":", "").replaceAll(" {2,}", " ").toLowerCase().trim();
|
|
@@ -806,7 +807,7 @@ public class AdwebEnquiryServiceImpl extends ServiceImpl<AdwebEnquiryMapper, Adw
|
|
}
|
|
}
|
|
List<SysDictItem> dictItems = sysAdwebApiImpl.selectItemsByDictCode(dictCode);
|
|
List<SysDictItem> dictItems = sysAdwebApiImpl.selectItemsByDictCode(dictCode);
|
|
List<String> keys = new ArrayList<>();
|
|
List<String> keys = new ArrayList<>();
|
|
- if (ListUtil.notEmpty(dictItems)) {
|
|
|
|
|
|
+ if (CollectionUtils.isNotEmpty(dictItems)) {
|
|
for (SysDictItem item : dictItems) {
|
|
for (SysDictItem item : dictItems) {
|
|
String value = item.getItemValue();
|
|
String value = item.getItemValue();
|
|
if (StringUtil.isEmpty(value)) {
|
|
if (StringUtil.isEmpty(value)) {
|
|
@@ -835,17 +836,17 @@ public class AdwebEnquiryServiceImpl extends ServiceImpl<AdwebEnquiryMapper, Adw
|
|
//邮箱 黑名单
|
|
//邮箱 黑名单
|
|
//先获取对应站点的邮箱黑名单
|
|
//先获取对应站点的邮箱黑名单
|
|
List<String> siteBlackEmailList = (List<String>) adwebRedisUtil.get(SiteBlackEmailKey + "::" + adwebSite.getId());
|
|
List<String> siteBlackEmailList = (List<String>) adwebRedisUtil.get(SiteBlackEmailKey + "::" + adwebSite.getId());
|
|
- if (ListUtil.isEmpty(siteBlackEmailList)) {
|
|
|
|
|
|
+ if (CollectionUtils.isEmpty(siteBlackEmailList)) {
|
|
enquirySiteBlackEmailService.saveRedisSiteBlackEmailBySiteId(adwebSite.getId(), 0);
|
|
enquirySiteBlackEmailService.saveRedisSiteBlackEmailBySiteId(adwebSite.getId(), 0);
|
|
siteBlackEmailList = (List<String>) adwebRedisUtil.get(SiteBlackEmailKey + "::" + adwebSite.getId());
|
|
siteBlackEmailList = (List<String>) adwebRedisUtil.get(SiteBlackEmailKey + "::" + adwebSite.getId());
|
|
- if (ListUtil.isEmpty(siteBlackEmailList)) {
|
|
|
|
|
|
+ if (CollectionUtils.isEmpty(siteBlackEmailList)) {
|
|
siteBlackEmailList = new ArrayList<>();
|
|
siteBlackEmailList = new ArrayList<>();
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
//邮箱 公共黑名单
|
|
//邮箱 公共黑名单
|
|
List<String> publicBlackEmailList = (List<String>) adwebRedisUtil.get(BlackEmailKey);
|
|
List<String> publicBlackEmailList = (List<String>) adwebRedisUtil.get(BlackEmailKey);
|
|
- if (ListUtil.isEmpty(publicBlackEmailList)) {
|
|
|
|
|
|
+ if (CollectionUtils.isEmpty(publicBlackEmailList)) {
|
|
List<AdwebPublicBlackEmail> enquiryPublicBlackEmailList = adwebPublicBlackEmailService
|
|
List<AdwebPublicBlackEmail> enquiryPublicBlackEmailList = adwebPublicBlackEmailService
|
|
.list(new LambdaQueryWrapper<AdwebPublicBlackEmail>()
|
|
.list(new LambdaQueryWrapper<AdwebPublicBlackEmail>()
|
|
.ne(AdwebPublicBlackEmail::getStatus, 0)
|
|
.ne(AdwebPublicBlackEmail::getStatus, 0)
|
|
@@ -853,7 +854,7 @@ public class AdwebEnquiryServiceImpl extends ServiceImpl<AdwebEnquiryMapper, Adw
|
|
.isNotNull(AdwebPublicBlackEmail::getEmail)
|
|
.isNotNull(AdwebPublicBlackEmail::getEmail)
|
|
.select(AdwebPublicBlackEmail::getEmail));
|
|
.select(AdwebPublicBlackEmail::getEmail));
|
|
|
|
|
|
- if (ListUtil.notEmpty(enquiryPublicBlackEmailList)) {
|
|
|
|
|
|
+ if (CollectionUtils.isNotEmpty(enquiryPublicBlackEmailList)) {
|
|
publicBlackEmailList = enquiryPublicBlackEmailList.stream().map(AdwebPublicBlackEmail::getEmail).filter(StringUtil::isNotEmpty).collect(Collectors.toList());
|
|
publicBlackEmailList = enquiryPublicBlackEmailList.stream().map(AdwebPublicBlackEmail::getEmail).filter(StringUtil::isNotEmpty).collect(Collectors.toList());
|
|
adwebRedisUtil.set(BlackEmailKey, publicBlackEmailList, 60 * 60 * 24);
|
|
adwebRedisUtil.set(BlackEmailKey, publicBlackEmailList, 60 * 60 * 24);
|
|
} else {
|
|
} else {
|
|
@@ -863,12 +864,12 @@ public class AdwebEnquiryServiceImpl extends ServiceImpl<AdwebEnquiryMapper, Adw
|
|
publicBlackEmailList = publicBlackEmailList.stream().filter(s -> !s.isEmpty()).collect(Collectors.toList());
|
|
publicBlackEmailList = publicBlackEmailList.stream().filter(s -> !s.isEmpty()).collect(Collectors.toList());
|
|
}
|
|
}
|
|
List<String> allBlackEmailList = new ArrayList<>();
|
|
List<String> allBlackEmailList = new ArrayList<>();
|
|
- if (ListUtil.notEmpty(siteBlackEmailList)) {
|
|
|
|
|
|
+ if (CollectionUtils.isNotEmpty(siteBlackEmailList)) {
|
|
allBlackEmailList = new ArrayList<>(siteBlackEmailList);
|
|
allBlackEmailList = new ArrayList<>(siteBlackEmailList);
|
|
}
|
|
}
|
|
allBlackEmailList.addAll(publicBlackEmailList);
|
|
allBlackEmailList.addAll(publicBlackEmailList);
|
|
List<String> blackEmailList = new ArrayList<>();
|
|
List<String> blackEmailList = new ArrayList<>();
|
|
- if (ListUtil.notEmpty(allBlackEmailList)) {
|
|
|
|
|
|
+ if (CollectionUtils.isNotEmpty(allBlackEmailList)) {
|
|
HashSet<String> blackEmailHashSet = new HashSet<String>(allBlackEmailList);
|
|
HashSet<String> blackEmailHashSet = new HashSet<String>(allBlackEmailList);
|
|
blackEmailList = new ArrayList<>(blackEmailHashSet);
|
|
blackEmailList = new ArrayList<>(blackEmailHashSet);
|
|
}
|
|
}
|
|
@@ -878,13 +879,13 @@ public class AdwebEnquiryServiceImpl extends ServiceImpl<AdwebEnquiryMapper, Adw
|
|
//邮箱 白名单
|
|
//邮箱 白名单
|
|
//先获取对应站点的邮箱白名单
|
|
//先获取对应站点的邮箱白名单
|
|
List<String> siteWhiteEmailList = (List<String>) adwebRedisUtil.get(SiteWhiteEmailListKey + "::" + adwebSite.getId());
|
|
List<String> siteWhiteEmailList = (List<String>) adwebRedisUtil.get(SiteWhiteEmailListKey + "::" + adwebSite.getId());
|
|
- if (ListUtil.isEmpty(siteWhiteEmailList)) {
|
|
|
|
|
|
+ if (CollectionUtils.isEmpty(siteWhiteEmailList)) {
|
|
enquirySiteBlackEmailService.saveRedisSiteBlackEmailBySiteId(adwebSite.getId(), 1);
|
|
enquirySiteBlackEmailService.saveRedisSiteBlackEmailBySiteId(adwebSite.getId(), 1);
|
|
siteWhiteEmailList = (List<String>) adwebRedisUtil.get(SiteWhiteEmailListKey + "::" + adwebSite.getId());
|
|
siteWhiteEmailList = (List<String>) adwebRedisUtil.get(SiteWhiteEmailListKey + "::" + adwebSite.getId());
|
|
}
|
|
}
|
|
//公共邮箱白名单数据
|
|
//公共邮箱白名单数据
|
|
List<String> publicWhiteEmailList = (List<String>) adwebRedisUtil.get(WhiteEmailListKey);
|
|
List<String> publicWhiteEmailList = (List<String>) adwebRedisUtil.get(WhiteEmailListKey);
|
|
- if (ListUtil.isEmpty(publicWhiteEmailList)) {
|
|
|
|
|
|
+ if (CollectionUtils.isEmpty(publicWhiteEmailList)) {
|
|
List<AdwebPublicBlackEmail> enquiryPublicWhiteEmailList = adwebPublicBlackEmailService
|
|
List<AdwebPublicBlackEmail> enquiryPublicWhiteEmailList = adwebPublicBlackEmailService
|
|
.list(new LambdaQueryWrapper<AdwebPublicBlackEmail>()
|
|
.list(new LambdaQueryWrapper<AdwebPublicBlackEmail>()
|
|
.ne(AdwebPublicBlackEmail::getStatus, 0)
|
|
.ne(AdwebPublicBlackEmail::getStatus, 0)
|
|
@@ -892,7 +893,7 @@ public class AdwebEnquiryServiceImpl extends ServiceImpl<AdwebEnquiryMapper, Adw
|
|
.isNotNull(AdwebPublicBlackEmail::getEmail)
|
|
.isNotNull(AdwebPublicBlackEmail::getEmail)
|
|
.select(AdwebPublicBlackEmail::getEmail));
|
|
.select(AdwebPublicBlackEmail::getEmail));
|
|
|
|
|
|
- if (ListUtil.notEmpty(enquiryPublicWhiteEmailList)) {
|
|
|
|
|
|
+ if (CollectionUtils.isNotEmpty(enquiryPublicWhiteEmailList)) {
|
|
publicWhiteEmailList = enquiryPublicWhiteEmailList.stream().map(AdwebPublicBlackEmail::getEmail).filter(StringUtil::isNotEmpty).collect(Collectors.toList());
|
|
publicWhiteEmailList = enquiryPublicWhiteEmailList.stream().map(AdwebPublicBlackEmail::getEmail).filter(StringUtil::isNotEmpty).collect(Collectors.toList());
|
|
adwebRedisUtil.set(WhiteEmailListKey, publicWhiteEmailList, 60 * 60 * 24);
|
|
adwebRedisUtil.set(WhiteEmailListKey, publicWhiteEmailList, 60 * 60 * 24);
|
|
} else {
|
|
} else {
|
|
@@ -902,12 +903,12 @@ public class AdwebEnquiryServiceImpl extends ServiceImpl<AdwebEnquiryMapper, Adw
|
|
publicWhiteEmailList = publicWhiteEmailList.stream().filter(s -> !s.isEmpty()).collect(Collectors.toList());
|
|
publicWhiteEmailList = publicWhiteEmailList.stream().filter(s -> !s.isEmpty()).collect(Collectors.toList());
|
|
}
|
|
}
|
|
List<String> allWhiteEmailList = new ArrayList<>();
|
|
List<String> allWhiteEmailList = new ArrayList<>();
|
|
- if (ListUtil.notEmpty(siteWhiteEmailList)) {
|
|
|
|
|
|
+ if (CollectionUtils.isNotEmpty(siteWhiteEmailList)) {
|
|
allWhiteEmailList = new ArrayList<>(siteWhiteEmailList);
|
|
allWhiteEmailList = new ArrayList<>(siteWhiteEmailList);
|
|
}
|
|
}
|
|
allWhiteEmailList.addAll(publicWhiteEmailList);
|
|
allWhiteEmailList.addAll(publicWhiteEmailList);
|
|
List<String> whiteEmailList = new ArrayList<>();
|
|
List<String> whiteEmailList = new ArrayList<>();
|
|
- if (ListUtil.notEmpty(allWhiteEmailList)) {
|
|
|
|
|
|
+ if (CollectionUtils.isNotEmpty(allWhiteEmailList)) {
|
|
HashSet<String> whiteEmailHashSet = new HashSet<String>(allWhiteEmailList);
|
|
HashSet<String> whiteEmailHashSet = new HashSet<String>(allWhiteEmailList);
|
|
whiteEmailList = new ArrayList<>(whiteEmailHashSet);
|
|
whiteEmailList = new ArrayList<>(whiteEmailHashSet);
|
|
}
|
|
}
|
|
@@ -918,13 +919,13 @@ public class AdwebEnquiryServiceImpl extends ServiceImpl<AdwebEnquiryMapper, Adw
|
|
//Ip黑名单
|
|
//Ip黑名单
|
|
//公共ip黑名单
|
|
//公共ip黑名单
|
|
List<String> publicBlackIpList = (List<String>) adwebRedisUtil.get(BlackIpKey);
|
|
List<String> publicBlackIpList = (List<String>) adwebRedisUtil.get(BlackIpKey);
|
|
- if (ListUtil.isEmpty(publicBlackIpList)) {
|
|
|
|
|
|
+ if (CollectionUtils.isEmpty(publicBlackIpList)) {
|
|
List<AdwebPublicBlackIp> enquiryPublicBlackIpList = adwebPublicBlackIpService
|
|
List<AdwebPublicBlackIp> enquiryPublicBlackIpList = adwebPublicBlackIpService
|
|
.list(new LambdaQueryWrapper<AdwebPublicBlackIp>()
|
|
.list(new LambdaQueryWrapper<AdwebPublicBlackIp>()
|
|
.ne(AdwebPublicBlackIp::getStatus, 0)
|
|
.ne(AdwebPublicBlackIp::getStatus, 0)
|
|
.eq(AdwebPublicBlackIp::getBlackOrWhite, 0)
|
|
.eq(AdwebPublicBlackIp::getBlackOrWhite, 0)
|
|
.select(AdwebPublicBlackIp::getIp));
|
|
.select(AdwebPublicBlackIp::getIp));
|
|
- if (ListUtil.notEmpty(enquiryPublicBlackIpList)) {
|
|
|
|
|
|
+ if (CollectionUtils.isNotEmpty(enquiryPublicBlackIpList)) {
|
|
publicBlackIpList = enquiryPublicBlackIpList.stream().map(AdwebPublicBlackIp::getIp).collect(Collectors.toList());
|
|
publicBlackIpList = enquiryPublicBlackIpList.stream().map(AdwebPublicBlackIp::getIp).collect(Collectors.toList());
|
|
adwebRedisUtil.set(BlackIpKey, publicBlackIpList, 60 * 60 * 24);
|
|
adwebRedisUtil.set(BlackIpKey, publicBlackIpList, 60 * 60 * 24);
|
|
} else {
|
|
} else {
|
|
@@ -933,14 +934,14 @@ public class AdwebEnquiryServiceImpl extends ServiceImpl<AdwebEnquiryMapper, Adw
|
|
}
|
|
}
|
|
//站点ip黑名单
|
|
//站点ip黑名单
|
|
List<String> siteBlackIpList = (List<String>) adwebRedisUtil.get(SiteBlackIpKey + "::" + adwebSite.getId());
|
|
List<String> siteBlackIpList = (List<String>) adwebRedisUtil.get(SiteBlackIpKey + "::" + adwebSite.getId());
|
|
- if (ListUtil.isEmpty(siteBlackIpList)) {
|
|
|
|
|
|
+ if (CollectionUtils.isEmpty(siteBlackIpList)) {
|
|
List<AdwebSiteBlackIp> enquirySiteBlackIpList = adwebSiteBlackIpService
|
|
List<AdwebSiteBlackIp> enquirySiteBlackIpList = adwebSiteBlackIpService
|
|
.list(new LambdaQueryWrapper<AdwebSiteBlackIp>()
|
|
.list(new LambdaQueryWrapper<AdwebSiteBlackIp>()
|
|
.ne(AdwebSiteBlackIp::getStatus, 0)
|
|
.ne(AdwebSiteBlackIp::getStatus, 0)
|
|
.eq(AdwebSiteBlackIp::getBlackOrWhite, 0)
|
|
.eq(AdwebSiteBlackIp::getBlackOrWhite, 0)
|
|
.eq(AdwebSiteBlackIp::getSiteId, adwebSite.getId())
|
|
.eq(AdwebSiteBlackIp::getSiteId, adwebSite.getId())
|
|
.select(AdwebSiteBlackIp::getIp));
|
|
.select(AdwebSiteBlackIp::getIp));
|
|
- if (ListUtil.notEmpty(enquirySiteBlackIpList)) {
|
|
|
|
|
|
+ if (CollectionUtils.isNotEmpty(enquirySiteBlackIpList)) {
|
|
siteBlackIpList = enquirySiteBlackIpList.stream().map(AdwebSiteBlackIp::getIp).collect(Collectors.toList());
|
|
siteBlackIpList = enquirySiteBlackIpList.stream().map(AdwebSiteBlackIp::getIp).collect(Collectors.toList());
|
|
adwebRedisUtil.set(SiteBlackIpKey + "::" + adwebSite.getId(), siteBlackIpList, 60 * 60 * 24);
|
|
adwebRedisUtil.set(SiteBlackIpKey + "::" + adwebSite.getId(), siteBlackIpList, 60 * 60 * 24);
|
|
} else {
|
|
} else {
|
|
@@ -948,12 +949,12 @@ public class AdwebEnquiryServiceImpl extends ServiceImpl<AdwebEnquiryMapper, Adw
|
|
}
|
|
}
|
|
}
|
|
}
|
|
List<String> allBlackIpList = new ArrayList<>();
|
|
List<String> allBlackIpList = new ArrayList<>();
|
|
- if (ListUtil.notEmpty(siteBlackIpList)) {
|
|
|
|
|
|
+ if (CollectionUtils.isNotEmpty(siteBlackIpList)) {
|
|
allBlackIpList = new ArrayList<>(siteBlackIpList);
|
|
allBlackIpList = new ArrayList<>(siteBlackIpList);
|
|
}
|
|
}
|
|
allBlackIpList.addAll(publicBlackIpList);
|
|
allBlackIpList.addAll(publicBlackIpList);
|
|
List<String> blackIpList = new ArrayList<>();
|
|
List<String> blackIpList = new ArrayList<>();
|
|
- if (ListUtil.notEmpty(allBlackIpList)) {
|
|
|
|
|
|
+ if (CollectionUtils.isNotEmpty(allBlackIpList)) {
|
|
HashSet<String> blackIpHashSet = new HashSet<String>(allBlackIpList);
|
|
HashSet<String> blackIpHashSet = new HashSet<String>(allBlackIpList);
|
|
blackIpList = new ArrayList<>(blackIpHashSet);
|
|
blackIpList = new ArrayList<>(blackIpHashSet);
|
|
}
|
|
}
|
|
@@ -970,7 +971,7 @@ public class AdwebEnquiryServiceImpl extends ServiceImpl<AdwebEnquiryMapper, Adw
|
|
.ne(AdwebPublicBlackIp::getStatus, 0)
|
|
.ne(AdwebPublicBlackIp::getStatus, 0)
|
|
.eq(AdwebPublicBlackIp::getBlackOrWhite, 1)
|
|
.eq(AdwebPublicBlackIp::getBlackOrWhite, 1)
|
|
.select(AdwebPublicBlackIp::getIp));
|
|
.select(AdwebPublicBlackIp::getIp));
|
|
- if (ListUtil.notEmpty(enquiryPublicWhiteIpList)) {
|
|
|
|
|
|
+ if (CollectionUtils.isNotEmpty(enquiryPublicWhiteIpList)) {
|
|
publicWhiteIpList = enquiryPublicWhiteIpList.stream().map(AdwebPublicBlackIp::getIp).collect(Collectors.toList());
|
|
publicWhiteIpList = enquiryPublicWhiteIpList.stream().map(AdwebPublicBlackIp::getIp).collect(Collectors.toList());
|
|
adwebRedisUtil.set(WhiteIpListKey, publicWhiteIpList, 60 * 60 * 24);
|
|
adwebRedisUtil.set(WhiteIpListKey, publicWhiteIpList, 60 * 60 * 24);
|
|
} else {
|
|
} else {
|
|
@@ -979,14 +980,14 @@ public class AdwebEnquiryServiceImpl extends ServiceImpl<AdwebEnquiryMapper, Adw
|
|
}
|
|
}
|
|
//站点Ip白名单, 基于站点查询
|
|
//站点Ip白名单, 基于站点查询
|
|
List<String> siteWhiteIpList = (List<String>) adwebRedisUtil.get(SiteWhiteIpListKey + "::" + adwebSite.getId());
|
|
List<String> siteWhiteIpList = (List<String>) adwebRedisUtil.get(SiteWhiteIpListKey + "::" + adwebSite.getId());
|
|
- if (ListUtil.isEmpty(siteWhiteIpList)) {
|
|
|
|
|
|
+ if (CollectionUtils.isEmpty(siteWhiteIpList)) {
|
|
List<AdwebSiteBlackIp> enquirySiteWhiteIpList = adwebSiteBlackIpService
|
|
List<AdwebSiteBlackIp> enquirySiteWhiteIpList = adwebSiteBlackIpService
|
|
.list(new LambdaQueryWrapper<AdwebSiteBlackIp>()
|
|
.list(new LambdaQueryWrapper<AdwebSiteBlackIp>()
|
|
.ne(AdwebSiteBlackIp::getStatus, 0)
|
|
.ne(AdwebSiteBlackIp::getStatus, 0)
|
|
.eq(AdwebSiteBlackIp::getBlackOrWhite, 1)
|
|
.eq(AdwebSiteBlackIp::getBlackOrWhite, 1)
|
|
.eq(AdwebSiteBlackIp::getSiteId, adwebSite.getId())
|
|
.eq(AdwebSiteBlackIp::getSiteId, adwebSite.getId())
|
|
.select(AdwebSiteBlackIp::getIp));
|
|
.select(AdwebSiteBlackIp::getIp));
|
|
- if (ListUtil.notEmpty(enquirySiteWhiteIpList)) {
|
|
|
|
|
|
+ if (CollectionUtils.isNotEmpty(enquirySiteWhiteIpList)) {
|
|
siteWhiteIpList = enquirySiteWhiteIpList.stream().map(AdwebSiteBlackIp::getIp).collect(Collectors.toList());
|
|
siteWhiteIpList = enquirySiteWhiteIpList.stream().map(AdwebSiteBlackIp::getIp).collect(Collectors.toList());
|
|
adwebRedisUtil.set(SiteWhiteIpListKey + "::" + adwebSite.getId(), siteWhiteIpList, 60 * 60 * 24);
|
|
adwebRedisUtil.set(SiteWhiteIpListKey + "::" + adwebSite.getId(), siteWhiteIpList, 60 * 60 * 24);
|
|
} else {
|
|
} else {
|
|
@@ -994,12 +995,12 @@ public class AdwebEnquiryServiceImpl extends ServiceImpl<AdwebEnquiryMapper, Adw
|
|
}
|
|
}
|
|
}
|
|
}
|
|
List<String> allWhiteIpList = new ArrayList<>();
|
|
List<String> allWhiteIpList = new ArrayList<>();
|
|
- if (ListUtil.notEmpty(siteWhiteIpList)) {
|
|
|
|
|
|
+ if (CollectionUtils.isNotEmpty(siteWhiteIpList)) {
|
|
allWhiteIpList = new ArrayList<>(siteWhiteIpList);
|
|
allWhiteIpList = new ArrayList<>(siteWhiteIpList);
|
|
}
|
|
}
|
|
allWhiteIpList.addAll(publicWhiteIpList);
|
|
allWhiteIpList.addAll(publicWhiteIpList);
|
|
List<String> whiteIpList = new ArrayList<>();
|
|
List<String> whiteIpList = new ArrayList<>();
|
|
- if (ListUtil.notEmpty(allWhiteIpList)) {
|
|
|
|
|
|
+ if (CollectionUtils.isNotEmpty(allWhiteIpList)) {
|
|
HashSet<String> whiteIpHashSet = new HashSet<String>(allWhiteIpList);
|
|
HashSet<String> whiteIpHashSet = new HashSet<String>(allWhiteIpList);
|
|
whiteIpList = new ArrayList<>(whiteIpHashSet);
|
|
whiteIpList = new ArrayList<>(whiteIpHashSet);
|
|
}
|
|
}
|
|
@@ -1035,7 +1036,7 @@ public class AdwebEnquiryServiceImpl extends ServiceImpl<AdwebEnquiryMapper, Adw
|
|
isJudgeWasteEnquiry = adwebEnquiry;
|
|
isJudgeWasteEnquiry = adwebEnquiry;
|
|
|
|
|
|
// 判断 询盘邮箱黑名单
|
|
// 判断 询盘邮箱黑名单
|
|
- if (ListUtil.notEmpty(blackEmailList) || StringUtils.isNotBlank(adwebEnquiry.getEmail())) {
|
|
|
|
|
|
+ if (CollectionUtils.isNotEmpty(blackEmailList) || StringUtils.isNotBlank(adwebEnquiry.getEmail())) {
|
|
|
|
|
|
String email = adwebEnquiry.getEmail().toLowerCase();
|
|
String email = adwebEnquiry.getEmail().toLowerCase();
|
|
|
|
|
|
@@ -1058,7 +1059,7 @@ public class AdwebEnquiryServiceImpl extends ServiceImpl<AdwebEnquiryMapper, Adw
|
|
//黑名单
|
|
//黑名单
|
|
String containPublicBlackStr = "";
|
|
String containPublicBlackStr = "";
|
|
boolean isContainPublicBlack = false;
|
|
boolean isContainPublicBlack = false;
|
|
- if (ListUtil.notEmpty(publicBlackEmailList)) {
|
|
|
|
|
|
+ if (CollectionUtils.isNotEmpty(publicBlackEmailList)) {
|
|
for (String blackEmail : publicBlackEmailList) {
|
|
for (String blackEmail : publicBlackEmailList) {
|
|
String allBlackEmail = blackEmail;
|
|
String allBlackEmail = blackEmail;
|
|
if (allBlackEmail.contains("*")) {
|
|
if (allBlackEmail.contains("*")) {
|
|
@@ -1084,7 +1085,7 @@ public class AdwebEnquiryServiceImpl extends ServiceImpl<AdwebEnquiryMapper, Adw
|
|
boolean isSiteAllContain = true;
|
|
boolean isSiteAllContain = true;
|
|
String containSiteWhiteStr = "";
|
|
String containSiteWhiteStr = "";
|
|
//白名单
|
|
//白名单
|
|
- if (ListUtil.notEmpty(siteWhiteEmailList)) {
|
|
|
|
|
|
+ if (CollectionUtils.isNotEmpty(siteWhiteEmailList)) {
|
|
for (String whiteEmail : siteWhiteEmailList) {
|
|
for (String whiteEmail : siteWhiteEmailList) {
|
|
String compareWhiteEmail = whiteEmail;
|
|
String compareWhiteEmail = whiteEmail;
|
|
if (compareWhiteEmail.contains("*")) {
|
|
if (compareWhiteEmail.contains("*")) {
|
|
@@ -1112,7 +1113,7 @@ public class AdwebEnquiryServiceImpl extends ServiceImpl<AdwebEnquiryMapper, Adw
|
|
//黑名单
|
|
//黑名单
|
|
boolean isContainSiteBlack = false;
|
|
boolean isContainSiteBlack = false;
|
|
String containSiteBlackStr = "";
|
|
String containSiteBlackStr = "";
|
|
- if (ListUtil.notEmpty(siteBlackEmailList)) {
|
|
|
|
|
|
+ if (CollectionUtils.isNotEmpty(siteBlackEmailList)) {
|
|
for (String blackEmail : siteBlackEmailList) {
|
|
for (String blackEmail : siteBlackEmailList) {
|
|
String allBlackEmail = blackEmail;
|
|
String allBlackEmail = blackEmail;
|
|
if (allBlackEmail.contains("*")) {
|
|
if (allBlackEmail.contains("*")) {
|
|
@@ -1179,7 +1180,7 @@ public class AdwebEnquiryServiceImpl extends ServiceImpl<AdwebEnquiryMapper, Adw
|
|
// @see http://52.83.154.198:8082/browse/ADWEBV2-12
|
|
// @see http://52.83.154.198:8082/browse/ADWEBV2-12
|
|
// 垃圾询盘过滤时IP按照客户IP去使用黑名单过滤而不再使用来源IP
|
|
// 垃圾询盘过滤时IP按照客户IP去使用黑名单过滤而不再使用来源IP
|
|
// 判断是否为ip黑名单
|
|
// 判断是否为ip黑名单
|
|
- if (ListUtil.notEmpty(blackIpList) || StringUtils.isNotBlank(adwebEnquiry.getCustomerIp())) {
|
|
|
|
|
|
+ if (CollectionUtils.isNotEmpty(blackIpList) || StringUtils.isNotBlank(adwebEnquiry.getCustomerIp())) {
|
|
String ip = adwebEnquiry.getCustomerIp();
|
|
String ip = adwebEnquiry.getCustomerIp();
|
|
//公共ip黑名单
|
|
//公共ip黑名单
|
|
boolean isPublicIp = false;
|
|
boolean isPublicIp = false;
|
|
@@ -1233,7 +1234,7 @@ public class AdwebEnquiryServiceImpl extends ServiceImpl<AdwebEnquiryMapper, Adw
|
|
}
|
|
}
|
|
}
|
|
}
|
|
} else {
|
|
} else {
|
|
- if (ListUtil.notEmpty(urlList)) {
|
|
|
|
|
|
+ if (CollectionUtils.isNotEmpty(urlList)) {
|
|
adwebEnquiry.setWasteEnquiry(1);
|
|
adwebEnquiry.setWasteEnquiry(1);
|
|
adwebEnquiry.setUserEffective(0);
|
|
adwebEnquiry.setUserEffective(0);
|
|
adwebEnquiry.setWasteEnquiryType("other");
|
|
adwebEnquiry.setWasteEnquiryType("other");
|
|
@@ -1247,7 +1248,7 @@ public class AdwebEnquiryServiceImpl extends ServiceImpl<AdwebEnquiryMapper, Adw
|
|
// 判断询盘是否包含关键词
|
|
// 判断询盘是否包含关键词
|
|
String message = adwebEnquiry.getMessage().replaceAll("[\\n\\t]",
|
|
String message = adwebEnquiry.getMessage().replaceAll("[\\n\\t]",
|
|
" ").replaceAll(" {2,}", " ").toLowerCase();
|
|
" ").replaceAll(" {2,}", " ").toLowerCase();
|
|
- if (ListUtil.notEmpty(blackWordList) || ListUtil.notEmpty(siteBlackRuleList)) {
|
|
|
|
|
|
+ if (CollectionUtils.isNotEmpty(blackWordList) || CollectionUtils.isNotEmpty(siteBlackRuleList)) {
|
|
//公共关键词黑名单
|
|
//公共关键词黑名单
|
|
boolean isPublicWord = false;
|
|
boolean isPublicWord = false;
|
|
String isBlackWord = "";
|
|
String isBlackWord = "";
|
|
@@ -1328,29 +1329,29 @@ public class AdwebEnquiryServiceImpl extends ServiceImpl<AdwebEnquiryMapper, Adw
|
|
|
|
|
|
//更新redis
|
|
//更新redis
|
|
//站点
|
|
//站点
|
|
- if (ListUtil.notEmpty(siteBlackEmailList)) {
|
|
|
|
|
|
+ if (CollectionUtils.isNotEmpty(siteBlackEmailList)) {
|
|
adwebRedisUtil.set(SiteBlackEmailKey + "::" + adwebSite.getId(), siteBlackEmailList, 86400);
|
|
adwebRedisUtil.set(SiteBlackEmailKey + "::" + adwebSite.getId(), siteBlackEmailList, 86400);
|
|
}
|
|
}
|
|
- if (ListUtil.notEmpty(siteBlackIpList)) {
|
|
|
|
|
|
+ if (CollectionUtils.isNotEmpty(siteBlackIpList)) {
|
|
adwebRedisUtil.set(SiteBlackIpKey + "::" + adwebSite.getId(), siteBlackIpList, 86400);
|
|
adwebRedisUtil.set(SiteBlackIpKey + "::" + adwebSite.getId(), siteBlackIpList, 86400);
|
|
}
|
|
}
|
|
- if (ListUtil.notEmpty(siteWhiteEmailList)) {
|
|
|
|
|
|
+ if (CollectionUtils.isNotEmpty(siteWhiteEmailList)) {
|
|
adwebRedisUtil.set(SiteWhiteEmailListKey + "::" + adwebSite.getId(), siteWhiteEmailList, 86400);
|
|
adwebRedisUtil.set(SiteWhiteEmailListKey + "::" + adwebSite.getId(), siteWhiteEmailList, 86400);
|
|
}
|
|
}
|
|
- if (ListUtil.notEmpty(siteWhiteIpList)) {
|
|
|
|
|
|
+ if (CollectionUtils.isNotEmpty(siteWhiteIpList)) {
|
|
adwebRedisUtil.set(SiteWhiteIpListKey + "::" + adwebSite.getId(), siteWhiteIpList, 86400);
|
|
adwebRedisUtil.set(SiteWhiteIpListKey + "::" + adwebSite.getId(), siteWhiteIpList, 86400);
|
|
}
|
|
}
|
|
//公共
|
|
//公共
|
|
- if (ListUtil.notEmpty(publicBlackEmailList)) {
|
|
|
|
|
|
+ if (CollectionUtils.isNotEmpty(publicBlackEmailList)) {
|
|
adwebRedisUtil.set(BlackEmailKey, publicBlackEmailList, 86400);
|
|
adwebRedisUtil.set(BlackEmailKey, publicBlackEmailList, 86400);
|
|
}
|
|
}
|
|
- if (ListUtil.notEmpty(publicBlackIpList)) {
|
|
|
|
|
|
+ if (CollectionUtils.isNotEmpty(publicBlackIpList)) {
|
|
adwebRedisUtil.set(BlackIpKey, publicBlackIpList, 86400);
|
|
adwebRedisUtil.set(BlackIpKey, publicBlackIpList, 86400);
|
|
}
|
|
}
|
|
- if (ListUtil.notEmpty(publicWhiteEmailList)) {
|
|
|
|
|
|
+ if (CollectionUtils.isNotEmpty(publicWhiteEmailList)) {
|
|
adwebRedisUtil.set(WhiteEmailListKey, publicWhiteEmailList, 86400);
|
|
adwebRedisUtil.set(WhiteEmailListKey, publicWhiteEmailList, 86400);
|
|
}
|
|
}
|
|
- if (ListUtil.notEmpty(publicWhiteIpList)) {
|
|
|
|
|
|
+ if (CollectionUtils.isNotEmpty(publicWhiteIpList)) {
|
|
adwebRedisUtil.set(WhiteIpListKey, publicWhiteIpList, 86400);
|
|
adwebRedisUtil.set(WhiteIpListKey, publicWhiteIpList, 86400);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
@@ -1375,7 +1376,7 @@ public class AdwebEnquiryServiceImpl extends ServiceImpl<AdwebEnquiryMapper, Adw
|
|
Pattern pattern1 = Pattern.compile("(https?|ftp|file)://([-a-zA-Z0-9]+\\.)+[a-zA-Z0-9]+");
|
|
Pattern pattern1 = Pattern.compile("(https?|ftp|file)://([-a-zA-Z0-9]+\\.)+[a-zA-Z0-9]+");
|
|
List<String> domainPatterns = getFormKeys("enquiry_domain_pattern");
|
|
List<String> domainPatterns = getFormKeys("enquiry_domain_pattern");
|
|
String domainPattern = "";
|
|
String domainPattern = "";
|
|
- if (ListUtil.notEmpty(domainPatterns)) {
|
|
|
|
|
|
+ if (CollectionUtils.isNotEmpty(domainPatterns)) {
|
|
domainPattern = domainPatterns.get(0);
|
|
domainPattern = domainPatterns.get(0);
|
|
}
|
|
}
|
|
if (StringUtil.isEmpty(domainPattern)) {
|
|
if (StringUtil.isEmpty(domainPattern)) {
|
|
@@ -1419,7 +1420,7 @@ public class AdwebEnquiryServiceImpl extends ServiceImpl<AdwebEnquiryMapper, Adw
|
|
}
|
|
}
|
|
|
|
|
|
// 如果邮箱和 URL 都存在,并且 URL 中不包含 http 和 https,则从 URL 中删除邮箱
|
|
// 如果邮箱和 URL 都存在,并且 URL 中不包含 http 和 https,则从 URL 中删除邮箱
|
|
- if (ListUtil.notEmpty(emailList)) {
|
|
|
|
|
|
+ if (CollectionUtils.isNotEmpty(emailList)) {
|
|
Set<String> urlSet = new HashSet<>(urls);
|
|
Set<String> urlSet = new HashSet<>(urls);
|
|
urlSet.removeAll(emailList.stream()
|
|
urlSet.removeAll(emailList.stream()
|
|
.filter(email -> urlSet.contains(email) && !email.contains("http") && !email.contains("https"))
|
|
.filter(email -> urlSet.contains(email) && !email.contains("http") && !email.contains("https"))
|
|
@@ -1439,7 +1440,7 @@ public class AdwebEnquiryServiceImpl extends ServiceImpl<AdwebEnquiryMapper, Adw
|
|
log.info("上一封邮件为垃圾询盘,处理中...");
|
|
log.info("上一封邮件为垃圾询盘,处理中...");
|
|
boolean emailFlag = false;
|
|
boolean emailFlag = false;
|
|
String isJudgeWasteEnquiryEmail = isJudgeWasteEnquiry.getEmail().toLowerCase();
|
|
String isJudgeWasteEnquiryEmail = isJudgeWasteEnquiry.getEmail().toLowerCase();
|
|
- if (StringUtils.isNotBlank(isJudgeWasteEnquiryEmail) && ListUtil.notEmpty(blackEmailList)) {
|
|
|
|
|
|
+ if (StringUtils.isNotBlank(isJudgeWasteEnquiryEmail) && CollectionUtils.isNotEmpty(blackEmailList)) {
|
|
for (String blackEmail : blackEmailList) {
|
|
for (String blackEmail : blackEmailList) {
|
|
if (isJudgeWasteEnquiry.getEmail().equals(blackEmail)) {
|
|
if (isJudgeWasteEnquiry.getEmail().equals(blackEmail)) {
|
|
emailFlag = false;
|
|
emailFlag = false;
|
|
@@ -1511,7 +1512,7 @@ public class AdwebEnquiryServiceImpl extends ServiceImpl<AdwebEnquiryMapper, Adw
|
|
log.info("上一封邮件为垃圾询盘,处理中...");
|
|
log.info("上一封邮件为垃圾询盘,处理中...");
|
|
boolean emailFlag = false;
|
|
boolean emailFlag = false;
|
|
String isJudgeWasteEnquiryEmail = isJudgeWasteEnquiry.getEmail().toLowerCase();
|
|
String isJudgeWasteEnquiryEmail = isJudgeWasteEnquiry.getEmail().toLowerCase();
|
|
- if (StringUtils.isNotBlank(isJudgeWasteEnquiryEmail) && ListUtil.notEmpty(siteBlackEmailList)) {
|
|
|
|
|
|
+ if (StringUtils.isNotBlank(isJudgeWasteEnquiryEmail) && CollectionUtils.isNotEmpty(siteBlackEmailList)) {
|
|
for (String blackEmail : siteBlackEmailList) {
|
|
for (String blackEmail : siteBlackEmailList) {
|
|
if (isJudgeWasteEnquiry.getEmail().equals(blackEmail)) {
|
|
if (isJudgeWasteEnquiry.getEmail().equals(blackEmail)) {
|
|
emailFlag = false;
|
|
emailFlag = false;
|
|
@@ -1784,7 +1785,7 @@ public class AdwebEnquiryServiceImpl extends ServiceImpl<AdwebEnquiryMapper, Adw
|
|
}
|
|
}
|
|
|
|
|
|
List<String> idList = Arrays.asList(id.split(","));
|
|
List<String> idList = Arrays.asList(id.split(","));
|
|
- if (ListUtil.isEmpty(idList)) {
|
|
|
|
|
|
+ if (CollectionUtils.isEmpty(idList)) {
|
|
return false;
|
|
return false;
|
|
}
|
|
}
|
|
|
|
|
|
@@ -1829,7 +1830,7 @@ public class AdwebEnquiryServiceImpl extends ServiceImpl<AdwebEnquiryMapper, Adw
|
|
// 有效询盘发送邮件
|
|
// 有效询盘发送邮件
|
|
try {
|
|
try {
|
|
List<AdwebEnquiry> enquiryList = this.list(new LambdaQueryWrapper<AdwebEnquiry>().in(AdwebEnquiry::getId, idList));
|
|
List<AdwebEnquiry> enquiryList = this.list(new LambdaQueryWrapper<AdwebEnquiry>().in(AdwebEnquiry::getId, idList));
|
|
- if (ListUtil.notEmpty(enquiryList)) {
|
|
|
|
|
|
+ if (CollectionUtils.isNotEmpty(enquiryList)) {
|
|
AdwebSite adwebSite = adwebSiteService.getOne(new QueryWrapper<AdwebSite>().eq("code", enquiryList.get(0).getSiteCode()));
|
|
AdwebSite adwebSite = adwebSiteService.getOne(new QueryWrapper<AdwebSite>().eq("code", enquiryList.get(0).getSiteCode()));
|
|
if (adwebSite != null) {
|
|
if (adwebSite != null) {
|
|
|
|
|
|
@@ -1845,7 +1846,7 @@ public class AdwebEnquiryServiceImpl extends ServiceImpl<AdwebEnquiryMapper, Adw
|
|
// 判断是否为联系我们询盘
|
|
// 判断是否为联系我们询盘
|
|
for (AdwebEnquiry adwebEnquiry : enquiryList) {
|
|
for (AdwebEnquiry adwebEnquiry : enquiryList) {
|
|
List<DictModel> contactEnquiryWebsites = dictService.queryDictItemsByCode("send_contact_enquiry_website");
|
|
List<DictModel> contactEnquiryWebsites = dictService.queryDictItemsByCode("send_contact_enquiry_website");
|
|
- List<String> contactEnquiryCodes = contactEnquiryWebsites.stream().map(DictModel::getValue).collect(Collectors.toList());
|
|
|
|
|
|
+ List<String> contactEnquiryCodes = contactEnquiryWebsites.stream().map(DictModel::getValue).toList();
|
|
if (contactEnquiryCodes.contains(adwebSite.getCode())) {
|
|
if (contactEnquiryCodes.contains(adwebSite.getCode())) {
|
|
if (StringUtils.isNotBlank(adwebEnquiry.getFromPage()) && adwebEnquiry.getFromPage().contains("contact")) {
|
|
if (StringUtils.isNotBlank(adwebEnquiry.getFromPage()) && adwebEnquiry.getFromPage().contains("contact")) {
|
|
adwebEnquiry.setExistContactEnquiry(1);
|
|
adwebEnquiry.setExistContactEnquiry(1);
|
|
@@ -1856,10 +1857,10 @@ public class AdwebEnquiryServiceImpl extends ServiceImpl<AdwebEnquiryMapper, Adw
|
|
//获取子账户
|
|
//获取子账户
|
|
List<String> subAccountIdList = masterSubAccountRelationService.getSubAccountIdByMaster(String.valueOf(adwebSite.getUid()));
|
|
List<String> subAccountIdList = masterSubAccountRelationService.getSubAccountIdByMaster(String.valueOf(adwebSite.getUid()));
|
|
log.info("获取的子账户id:{}", FastJsonUtil.toJSONString(subAccountIdList));
|
|
log.info("获取的子账户id:{}", FastJsonUtil.toJSONString(subAccountIdList));
|
|
- if (ListUtil.notEmpty(subAccountIdList)) {
|
|
|
|
|
|
+ if (CollectionUtils.isNotEmpty(subAccountIdList)) {
|
|
subAccountIdList.add(String.valueOf(adwebSite.getUid()));
|
|
subAccountIdList.add(String.valueOf(adwebSite.getUid()));
|
|
List<SysUser> principalEmailList = sysUserService.list(new QueryWrapper<SysUser>().in("id", subAccountIdList).eq("del_flag", 0).isNotNull("email").ne("email","").select("id", "email"));
|
|
List<SysUser> principalEmailList = sysUserService.list(new QueryWrapper<SysUser>().in("id", subAccountIdList).eq("del_flag", 0).isNotNull("email").ne("email","").select("id", "email"));
|
|
- if (ListUtil.notEmpty(principalEmailList)) {
|
|
|
|
|
|
+ if (CollectionUtils.isNotEmpty(principalEmailList)) {
|
|
principalEmailMap = principalEmailList.stream().collect(Collectors.toMap(SysUser::getId, SysUser::getEmail));
|
|
principalEmailMap = principalEmailList.stream().collect(Collectors.toMap(SysUser::getId, SysUser::getEmail));
|
|
|
|
|
|
}
|
|
}
|