diff --git a/mallinkService/src/main/java/com/iformall/service/impl/WxMsgServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/impl/WxMsgServiceImpl.java index cc0c061d2..84353eae2 100644 --- a/mallinkService/src/main/java/com/iformall/service/impl/WxMsgServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/impl/WxMsgServiceImpl.java @@ -1,6 +1,7 @@ package com.iformall.service.impl; import com.alibaba.fastjson.JSON; +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.github.pagehelper.PageHelper; import com.github.pagehelper.PageInfo; import com.iformall.common.ErrorCode; @@ -25,6 +26,7 @@ import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.scheduling.annotation.Async; import org.springframework.stereotype.Service; + import java.util.*; import java.util.stream.Collectors; @@ -303,6 +305,15 @@ public class WxMsgServiceImpl implements WxMsgService { String[] split = phones.split(","); final IdWorker idWorker = IdWorker.get(); for (String phone : split) { + WxMsgCallback queryMsgCallback = new WxMsgCallback(); + queryMsgCallback.setTenantId(wxmsg.getTenantId()); + queryMsgCallback.setPhone(phone); + queryMsgCallback.setBatchNo(batchNo); + Integer count = wxMsgCallbackMapper.selectCount(new QueryWrapper<>(queryMsgCallback)); + if (count > 0) { + logger.info("营销短信回调主动添加-批次" + batchNo + "手机号" + phone + "已存在"); + continue; + } WxMsgCallback wxMsgCallback = new WxMsgCallback(); wxMsgCallback.setId(idWorker.nextId()); wxMsgCallback.setPhone(phone); @@ -315,7 +326,6 @@ public class WxMsgServiceImpl implements WxMsgService { wxMsgCallbackMapper.insert(wxMsgCallback); } logger.info("营销短信发送时主动添加回调记录结束..."); - }