虚拟电商-话费充值业务（四）供应商轮转逻辑

一、供应商轮转逻辑编写


1.1.供应商轮转


　　测试对接重试是手动的将对接的返回业务状态码设置称为：StatusCode.ORDER_REQ_FAILED，真实情况下,我们必要根据对接供应商返回的错误信息码来决定充吧系统添加什么类型的任务，所以必要判断对接返回的业务状态码，
　　步骤1：默认对接聚合，聚合返回的状态码是:StatusCode.BALANCE_NOT_ENOUGH 余额不敷，我们必要轮转下一个供应商：极速
 

1. @Override
2. public void recharge(RechargeRequest rechargeRequest) {
3.     //限制最大重试次数 如果超过了最大次数，停止供应商对接，订单失败---实际业务中是对接订单服务
4.     if(rechargeRequest.getRepeat() > supplierConfig.getMaxrepeat()){
5.         updateTrade(rechargeRequest.getOrderNo(), OrderStatusEnum.FAIL.getCode());
6.         return;
7.     }
8.     Result<RechargeResponse> result = doDispatchSupplier(rechargeRequest);
9.     if(result !=null){
10.         //需要根据对接返回的业务状态码来确定后续任务的类型及操作逻辑
11.         if(result.getCode() == StatusCode.BALANCE_NOT_ENOUGH){
12.             //模拟余额不足 轮转--到极速
13.             rechargeRequest.setSupply(Constants.jisuapi);
14.             rechargeRequest.setRepeat(0);
15.             rechargeRequest.setErrorCode(StatusCode.BALANCE_NOT_ENOUGH);
16. ​
17.         }else if(result.getCode() == StatusCode.ORDER_REQ_FAILED) {
18.             //重试逻辑的编写---添加重试任务
19.             rechargeRequest.setErrorCode(StatusCode.ORDER_REQ_FAILED);
20.         }
21.         supplierTask.addRetryTask(rechargeRequest);
22.         
23.     }
24. }

复制代码

 
 
　　步骤2：添加完轮转任务后，必要去消费轮转任务，在SupplierTaskImpl类中再次添加一个方法用于消费轮转任务，
　　必要进行方法的改造：在SupplierTaskImpl类中已有一个消费对接重试的任务，消费轮转的任务和重试任务二者之间就是任务的类型取值差别，消费逻辑一样，可抽取
　　在SupplierTask接口中新增轮转方法

1. /**
2.      * 供应商轮转
3.      */
4. public void roundRecharge();
5. @Override
6. @Scheduled(fixedRate = 1000)
7. public void retryRecharge() {
8.     retry(TaskTypeEnum.ORDER_REQ_FAILED);
9. }

复制代码

 
 

1. @Override
2. @Scheduled(fixedRate = 1000)
3. public void roundRecharge() {
4.     retry(TaskTypeEnum.BALANCE_NOT_ENOUGH);
5. }
6. ​
7. private void retry(TaskTypeEnum taskTypeEnum){
8.     ResponseMessage responseMessage = taskServiceClient.poll(taskTypeEnum.getTaskType(), taskTypeEnum.getPriority());
9.     if(responseMessage.isFlag()){
10.         if(responseMessage.getData() !=null){
11.             String taskStr = JSON.toJSONString(responseMessage.getData());
12.             Task task = JSON.parseObject(taskStr,Task.class);
13.             RechargeRequest rechargeRequest = ProtostuffUtil.deserialize(task.getParameters(), RechargeRequest.class);
14.             rechargeRequest.setRepeat(rechargeRequest.getRepeat()+1);
15.             System.out.println("消费了"+taskTypeEnum.getDesc()+"任务,"+rechargeRequest);
16.             supplierService.recharge(rechargeRequest);
17.         }
18.     }
19. }

复制代码

 
 
　　步骤3：轮转任务消费后就会去对接极速的接口，我们必要在对接供应商接口实现类：SupplierServiceImpl中完成和极速的对接
　　对接极速和聚合不一样，聚合要求传递的是JSON格式的数据，而极速要求传递的就是普通表单的key/value数据，并且我们模拟一下请求极速返回错误的情形
 
 

1. private Result<RechargeResponse> doPostJisu(RechargeRequest rechargeRequest) {
2.     log.info("doPostJisu,{}",rechargeRequest);
3.     HttpHeaders headers = new HttpHeaders();
4.     headers.setContentType(MediaType.APPLICATION_FORM_URLENCODED);
5.     //设置表单参数
6.     MultiValueMap<String, String> map= new LinkedMultiValueMap<String, String>();
7.     map.add("mobile",rechargeRequest.getMobile());
8.     map.add("amount",rechargeRequest.getPamt()+"");
9.     map.add("outorderNo", rechargeRequest.getOrderNo());
10.     map.add("repeat", ""+rechargeRequest.getRepeat());
11. ​
12.     //模拟请求失败
13.     map.add("req_status", ""+StatusCode.ERROR);
14.     HttpEntity<MultiValueMap<String, String>> requestEntity = new HttpEntity<MultiValueMap<String, String>>(map, headers);
15.     ResponseEntity<String> responseEntity = restTemplate.postForEntity(rechargeRequest.getRechargeUrl(), requestEntity , String.class);
16.     //转换成统一对象
17.     Result<RechargeResponse> result= JSON.parseObject(responseEntity.getBody(), new TypeReference<Result<RechargeResponse>>(){});
18.     return result;
19. }

复制代码

 
　　步骤4：测试：
　　依次启动：chongba_schedule_service，chongba_schedule_job，chongba_recharge_web，chongba_recharge_mock，chongba_recharge_supplier
　　访问：http://localhost:191/，进行话费充值
　　1.2.供应商排除


　　默认供应商聚合我们因为余额不敷无法调用，我们是手动编写轮转到极速，在现实业务中，我们系统可能会接许多个供应商，当我们在默认供应商处余额不敷时要从剩下的供应商中选出一个供应商进行对接的调用。此外还需将余额不敷的供应商做一个排除，下次调用时跳过这些供应商
　　1：轮转时：缓存集成，将那些因为我们系统在对方平台余额不敷的供应商编号缓存到redis中，使用Set集合存储，轮转时获取下一个供应商则直接从供应商配置类中读取所有的供应商所在列表，找出一个作为新的供应商，但得包管不是被排除的
　　2：与供应商对接前先判断RechargeRequest对象中默认传递过来的供应商是否可用，如果不可用则自动更换供应商。
 

1. @Autowired
2. private CacheService cacheService;
3. @Override
4. public void recharge(RechargeRequest rechargeRequest) {
5.     //限制最大重试次数 如果超过了最大次数，停止供应商对接，订单失败---实际业务中是对接订单服务
6.     if(rechargeRequest.getRepeat() > supplierConfig.getMaxrepeat()){
7.         updateTrade(rechargeRequest.getOrderNo(), OrderStatusEnum.FAIL.getCode());
8.         return;
9.     }
10.     String checkSupply = checkSupply(rechargeRequest.getSupply());
11.     if(checkSupply!=null){
12.         rechargeRequest.setSupply(checkSupply);
13.     }else {
14.         updateTrade(rechargeRequest.getOrderNo(),OrderStatusEnum.FAIL.getCode());
15.         return;
16.     }
17.     Result<RechargeResponse> result = doDispatchSupplier(rechargeRequest);
18.     if(result !=null){
19. ​
20.         if(result.getCode() == StatusCode.BALANCE_NOT_ENOUGH){
21.             //模拟余额不足 轮转--到极速
22.             /* rechargeRequest.setSupply(Constants.jisuapi);
23.                 rechargeRequest.setRepeat(0);
24.                 rechargeRequest.setErrorCode(StatusCode.BALANCE_NOT_ENOUGH);*/
25.             //将我们余额不足的供应商放入reids 排除集合中
26.             cacheService.sAdd(Constants.exclude_supplier,rechargeRequest.getSupply());
27.             String nextSupply = nextSupply();
28.             System.out.println("轮转到新的供应商为:"+nextSupply);
29.             if(nextSupply !=null){
30.                 rechargeRequest.setSupply(nextSupply);
31.                 rechargeRequest.setRepeat(0);
32.                 rechargeRequest.setErrorCode(StatusCode.BALANCE_NOT_ENOUGH);
33.             }else {
34.                 //没有供应商了---实际业务中是对接订单服务
35.                 updateTrade(rechargeRequest.getOrderNo(),OrderStatusEnum.FAIL.getCode());
36.                 return;
37.             }
38.         }else if(result.getCode() == StatusCode.ORDER_REQ_FAILED) {
39.             //重试逻辑的编写---添加重试任务
40.             rechargeRequest.setErrorCode(StatusCode.ORDER_REQ_FAILED);
41.         }
42.         supplierTask.addRetryTask(rechargeRequest);
43.     }
44. }
45. private String  checkSupply(String supply) {
46.     Set<String> excludes = cacheService.setMembers(Constants.exclude_supplier);
47.     if(excludes.contains(supply)){
48.         return nextSupply();
49.     }else {
50.         return supply;
51.     }
52. }
53. private String nextSupply() {
54.     Set<String> excludes = cacheService.setMembers(Constants.exclude_supplier);
55.     Map<String, String> allApis = supplierConfig.getApis();
56.     for (String supply : allApis.keySet()) {
57.         if(!excludes.contains(supply)){
58.             return supply;
59.         }
60.     }
61.     return null;
62. }

复制代码

 
 
　　再次启动相干工程进行测似
　　1.3.供应商恢复


　　如果我们平台在某些供应商处余额不敷，我们做了供应商排除，每次对接时都会过滤掉该供应商，一般供应商平台会关照我们进行充值，一旦充值成功，该供应商的接口应该恢复调用，因此我们必要提供一个接口用于恢复供应商，即将该供应商编号从缓存redis中的排除名单中删掉即可。
　　步骤1：在chongba_recharge_supplier模块下创建一个包：com.chongba.supplier.controller，在该包下创建RechargeNotifyController，提供一个供应商恢复的web层接口


 

1. @Slf4j
2. @RestController
3. public class RechargeNotifyController {
4. ​
5.     @Autowired
6.     private CacheService cacheService;
7. ​
8.     @RequestMapping("/recovery")
9.     public String recovery(String supply){
10.         Set<String> excluedes = cacheService.setMembers(Constants.exclude_supplier);
11.         if(excluedes.contains(supply)){
12.             cacheService.sRemove(Constants.exclude_supplier,supply);
13.             return "恢复成功!";
14.         }else {
15.             return "供应商编号不存在!";
16.         }
17.     }
18. }

复制代码

 

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。