|
|
|
|
@ -1,10 +1,27 @@
|
|
|
|
|
package com.mashibing.strategy.service.strategyfilter.impl;
|
|
|
|
|
|
|
|
|
|
import com.mashibing.common.constant.CacheConstant;
|
|
|
|
|
import com.mashibing.common.constant.RabbitMQConstant;
|
|
|
|
|
import com.mashibing.common.enums.ExceptionEnums;
|
|
|
|
|
import com.mashibing.common.exception.StrategyException;
|
|
|
|
|
import com.mashibing.common.pojo.StandardSubmit;
|
|
|
|
|
import com.mashibing.strategy.feignclient.CacheClient;
|
|
|
|
|
import com.mashibing.strategy.service.strategyfilter.StrategyFilter;
|
|
|
|
|
import com.mashibing.strategy.utils.ChannelTransferUtil;
|
|
|
|
|
import com.mashibing.strategy.utils.StrategyCheckFailedUtil;
|
|
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
|
|
import org.springframework.amqp.AmqpException;
|
|
|
|
|
import org.springframework.amqp.core.AmqpAdmin;
|
|
|
|
|
import org.springframework.amqp.core.QueueBuilder;
|
|
|
|
|
import org.springframework.amqp.rabbit.core.RabbitTemplate;
|
|
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
|
|
import org.springframework.stereotype.Service;
|
|
|
|
|
|
|
|
|
|
import java.util.Comparator;
|
|
|
|
|
import java.util.Map;
|
|
|
|
|
import java.util.Set;
|
|
|
|
|
import java.util.TreeSet;
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* @author heqijun
|
|
|
|
|
* @ClassName: RouteStrategyFilter
|
|
|
|
|
@ -16,8 +33,99 @@ import org.springframework.stereotype.Service;
|
|
|
|
|
@Service(value = "route")
|
|
|
|
|
public class RouteStrategyFilter implements StrategyFilter {
|
|
|
|
|
|
|
|
|
|
@Autowired
|
|
|
|
|
CacheClient cacheClient;
|
|
|
|
|
|
|
|
|
|
@Autowired
|
|
|
|
|
StrategyCheckFailedUtil strategyCheckFailedUtil;
|
|
|
|
|
|
|
|
|
|
@Autowired
|
|
|
|
|
private AmqpAdmin amqpAdmin;
|
|
|
|
|
|
|
|
|
|
@Autowired
|
|
|
|
|
private RabbitTemplate rabbitTemplate;
|
|
|
|
|
|
|
|
|
|
private static final String STRATEGY_NAME = "路由";
|
|
|
|
|
@Override
|
|
|
|
|
public void strategy(StandardSubmit submit) {
|
|
|
|
|
log.info("【策略模块-路由校验】。。。");
|
|
|
|
|
log.info("【策略模块-路由策略】开始====================================");
|
|
|
|
|
//1、拿到客户id
|
|
|
|
|
Long clientId = submit.getClientId();
|
|
|
|
|
|
|
|
|
|
//2、基于redis获取当前客户绑定的所有通道信息
|
|
|
|
|
Set<Map> clientChannels = cacheClient.smember(CacheConstant.CLIENT_CHANNEL + clientId);
|
|
|
|
|
|
|
|
|
|
//3、将获取到的客户通道信息根据权重做好排序
|
|
|
|
|
TreeSet<Map> clientWeightChannels = new TreeSet<>(new Comparator<Map>() {
|
|
|
|
|
@Override
|
|
|
|
|
public int compare(Map o1, Map o2) {
|
|
|
|
|
int o1Weight = Integer.parseInt(o1.get("clientChannelWeight") + "");
|
|
|
|
|
int o2Weight = Integer.parseInt(o2.get("clientChannelWeight") + "");
|
|
|
|
|
return o2Weight - o1Weight;
|
|
|
|
|
}
|
|
|
|
|
});
|
|
|
|
|
clientWeightChannels.addAll(clientChannels);
|
|
|
|
|
|
|
|
|
|
boolean ok = false;
|
|
|
|
|
Map channel = null;
|
|
|
|
|
Map clientChannel = null;
|
|
|
|
|
//4、基于排好序的通道选择，权重更高的
|
|
|
|
|
for (Map clientWeightChannel : clientWeightChannels) {
|
|
|
|
|
//5、如果客户和通道的绑定关系可用，直接去基于Redis查询具体的通道信息
|
|
|
|
|
if ((int) (clientWeightChannel.get("isAvailable")) != 0) {
|
|
|
|
|
// 当前关系不可用，直接进行下次循环，选择权重相对更低一点的
|
|
|
|
|
continue;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
//6、如果通道信息查询后，判断通道睡否可用，其次运营商可以匹配。
|
|
|
|
|
channel = cacheClient.hget(CacheConstant.CHANNEL + clientWeightChannel.get("channelId"));
|
|
|
|
|
if ((int) (channel.get("isAvailable")) != 0) {
|
|
|
|
|
// 当前通道不可用，选择权重更低的通道~
|
|
|
|
|
continue;
|
|
|
|
|
}
|
|
|
|
|
// 获取通道的通讯方式
|
|
|
|
|
Integer channelType = (Integer) channel.get("channelType");
|
|
|
|
|
if (channelType != 0 && submit.getOperatorId() != channelType) {
|
|
|
|
|
// 通道不是全网通，并且和当前手机号运营商不匹配
|
|
|
|
|
continue;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
//7、如果后期涉及到的通道的转换，这里留一个口子
|
|
|
|
|
Map transferChannel = ChannelTransferUtil.transfer(submit, channel);
|
|
|
|
|
|
|
|
|
|
// 找到可以使用的通道了
|
|
|
|
|
ok = true;
|
|
|
|
|
clientChannel = clientWeightChannel;
|
|
|
|
|
break;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if (!ok) {
|
|
|
|
|
log.info("【策略模块-路由策略】没有选择到可用的通道！！");
|
|
|
|
|
submit.setErrorMsg(ExceptionEnums.NO_CHANNEL.getMsg());
|
|
|
|
|
strategyCheckFailedUtil.smsSendLog(submit, STRATEGY_NAME);
|
|
|
|
|
strategyCheckFailedUtil.smsPushReport(submit, STRATEGY_NAME);
|
|
|
|
|
throw new StrategyException(ExceptionEnums.NO_CHANNEL);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
//8、基于选择的通道封装submit的信息
|
|
|
|
|
submit.setChannelId(Long.parseLong(channel.get("id") + ""));
|
|
|
|
|
submit.setSrcNumber("" + channel.get("channelNumber") + clientChannel.get("clientChannelNumber"));
|
|
|
|
|
|
|
|
|
|
try {
|
|
|
|
|
//9、声明好队列名称，并构建队列
|
|
|
|
|
String queueName = RabbitMQConstant.SMS_GATEWAY + submit.getChannelId();
|
|
|
|
|
amqpAdmin.declareQueue(QueueBuilder.durable(queueName).build());
|
|
|
|
|
|
|
|
|
|
//10、发送消息到声明好的队列中
|
|
|
|
|
rabbitTemplate.convertAndSend(queueName, submit);
|
|
|
|
|
} catch (AmqpException e) {
|
|
|
|
|
log.error("【策略模块-路由策略】声明通道对应队列以及发送消息时出现了问题！");
|
|
|
|
|
submit.setErrorMsg(e.getMessage());
|
|
|
|
|
strategyCheckFailedUtil.smsSendLog(submit, STRATEGY_NAME);
|
|
|
|
|
strategyCheckFailedUtil.smsPushReport(submit, STRATEGY_NAME);
|
|
|
|
|
throw new StrategyException(ExceptionEnums.UNKNOWN_ERROR.getCode(), e.getMessage());
|
|
|
|
|
}
|
|
|
|
|
log.info("【策略模块-路由策略】路由完毕！！！");
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
heqijun
3 months ago