|
|
|
@@ -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("营销短信发送时主动添加回调记录结束..."); |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|