package com.java110.job.adapt.market;
|
|
import com.java110.core.factory.GenerateCodeFactory;
|
import com.java110.dto.market.MarketBlacklistDto;
|
import com.java110.dto.market.MarketLogDto;
|
import com.java110.dto.market.MarketSmsValueDto;
|
import com.java110.dto.market.MarketTextDto;
|
import com.java110.dto.owner.OwnerAppUserDto;
|
import com.java110.dto.user.UserDto;
|
import com.java110.intf.common.IMarketBlacklistV1InnerServiceSMO;
|
import com.java110.intf.common.IMarketLogV1InnerServiceSMO;
|
import com.java110.intf.user.IOwnerAppUserInnerServiceSMO;
|
import com.java110.intf.user.IUserV1InnerServiceSMO;
|
import com.java110.po.market.MarketLogPo;
|
import com.java110.utils.util.DateUtil;
|
import com.java110.utils.util.StringUtil;
|
import com.java110.vo.ResultVo;
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import java.util.Date;
|
import java.util.List;
|
|
public abstract class DefaultSendExecutor implements ISendExecutor {
|
|
@Autowired
|
private IMarketLogV1InnerServiceSMO marketLogV1InnerServiceSMOImpl;
|
|
|
@Autowired
|
private IOwnerAppUserInnerServiceSMO ownerAppUserInnerServiceSMOImpl;
|
|
@Autowired
|
private IUserV1InnerServiceSMO userV1InnerServiceSMOImpl;
|
|
@Autowired
|
private IMarketBlacklistV1InnerServiceSMO marketBlacklistV1InnerServiceSMOImpl;
|
|
|
@Override
|
public void send(MarketTextDto marketTextDto,String tel,String communityId,String communityName) {
|
|
MarketLogDto marketLogDto = new MarketLogDto();
|
marketLogDto.setPersonTel(tel);
|
marketLogDto.setCommunityId(communityId);
|
long count = 0;
|
if(MarketTextDto.SEND_RATE_DAY.equals(marketTextDto.getSendRate())){
|
marketLogDto.setStartTime(DateUtil.getAddDayStringA(new Date(),-1));
|
marketLogDto.setEndTime(DateUtil.getNow(DateUtil.DATE_FORMATE_STRING_A));
|
count = marketLogV1InnerServiceSMOImpl.queryMarketLogsCount(marketLogDto);
|
}else if(MarketTextDto.SEND_RATE_MONTH.equals(marketTextDto.getSendRate())){
|
marketLogDto.setStartTime(DateUtil.getAddMonthStringA(new Date(),-1));
|
marketLogDto.setEndTime(DateUtil.getNow(DateUtil.DATE_FORMATE_STRING_A));
|
count = marketLogV1InnerServiceSMOImpl.queryMarketLogsCount(marketLogDto);
|
}
|
|
if(count > 0){
|
return ;
|
}
|
|
|
String openId = getOpenId(marketTextDto ,tel, communityId);
|
if(StringUtil.isEmpty(openId)){
|
return;
|
}
|
|
//判断是否为黑名单
|
|
if(validateBlacklist(tel,openId)){
|
return ;
|
}
|
|
|
|
ResultVo resultVo = doSend(marketTextDto,tel,communityId,openId);
|
|
String userName = "未知";
|
|
UserDto userDto = new UserDto();
|
userDto.setTel(tel);
|
List<UserDto> userDtos = userV1InnerServiceSMOImpl.queryUsers(userDto);
|
if(userDtos != null && userDtos.size()> 0){
|
userName = userDtos.get(0).getName();
|
}
|
|
String sendWay = "1001";
|
|
if(StringUtil.isNullOrNone(resultVo.getData())){
|
sendWay = resultVo.getData().toString();
|
}
|
|
MarketLogPo marketLogPo = new MarketLogPo();
|
marketLogPo.setBusinessType("1001");
|
marketLogPo.setCommunityId(communityId);
|
marketLogPo.setCommunityName(communityName);
|
marketLogPo.setLogId(GenerateCodeFactory.getGeneratorId("11"));
|
marketLogPo.setOpenId(openId);
|
marketLogPo.setPersonName(userName);
|
marketLogPo.setPersonTel(tel);
|
marketLogPo.setRemark(resultVo.getMsg());
|
marketLogPo.setRuleId(marketTextDto.getRuleId());
|
marketLogPo.setSendContent(marketTextDto.getTextContent());
|
marketLogPo.setSendWay(sendWay);
|
marketLogV1InnerServiceSMOImpl.saveMarketLog(marketLogPo);
|
}
|
|
private boolean validateBlacklist(String tel, String openId) {
|
|
MarketBlacklistDto marketBlacklistDto = new MarketBlacklistDto();
|
marketBlacklistDto.setFilters(new String[]{tel,openId});
|
int count = marketBlacklistV1InnerServiceSMOImpl.queryMarketBlacklistsCount(marketBlacklistDto);
|
|
if(count> 0){
|
return true;
|
}
|
|
return false;
|
}
|
|
/**
|
* 发送消息
|
* @param marketTextDto
|
* @param tel
|
* @param communityId
|
*/
|
public abstract ResultVo doSend(MarketTextDto marketTextDto, String tel, String communityId,String openId);
|
|
|
private String getOpenId(MarketTextDto marketTextDto,String tel, String communityId) {
|
OwnerAppUserDto ownerAppUserDto = new OwnerAppUserDto();
|
ownerAppUserDto.setLink(tel);
|
ownerAppUserDto.setCommunityId(communityId);
|
ownerAppUserDto.setAppType(OwnerAppUserDto.APP_TYPE_WECHAT);
|
List<OwnerAppUserDto> ownerAppUserDtos = ownerAppUserInnerServiceSMOImpl.queryOwnerAppUsers(ownerAppUserDto);
|
|
if(ownerAppUserDtos == null || ownerAppUserDtos.size()<1){
|
return "-1";
|
}
|
|
String openId = ownerAppUserDtos.get(0).getOpenId();
|
|
if(StringUtil.isEmpty(openId)){
|
return "-1";
|
}
|
|
MarketLogDto marketLogDto = new MarketLogDto();
|
marketLogDto.setOpenId(openId);
|
marketLogDto.setCommunityId(communityId);
|
long count = 0;
|
if(MarketTextDto.SEND_RATE_DAY.equals(marketTextDto.getSendRate())){
|
marketLogDto.setStartTime(DateUtil.getAddDayStringA(new Date(),-1));
|
marketLogDto.setEndTime(DateUtil.getNow(DateUtil.DATE_FORMATE_STRING_A));
|
count = marketLogV1InnerServiceSMOImpl.queryMarketLogsCount(marketLogDto);
|
}else if(MarketTextDto.SEND_RATE_MONTH.equals(marketTextDto.getSendRate())){
|
marketLogDto.setStartTime(DateUtil.getAddMonthStringA(new Date(),-1));
|
marketLogDto.setEndTime(DateUtil.getNow(DateUtil.DATE_FORMATE_STRING_A));
|
count = marketLogV1InnerServiceSMOImpl.queryMarketLogsCount(marketLogDto);
|
}
|
|
if(count > 0){
|
return "";
|
}
|
|
return openId;
|
}
|
|
protected String getMarketValue(List<MarketSmsValueDto> marketSmsValueDtos,String specCd){
|
for(MarketSmsValueDto marketSmsValueDto : marketSmsValueDtos){
|
if(marketSmsValueDto.getSmsKey().equals(specCd)){
|
return marketSmsValueDto.getSmsValue();
|
}
|
}
|
|
return "";
|
}
|
}
|
