当前位置：首页 > news >正文

虚拟电商-话费充值业务（六）话费充值业务回调补偿

news 来源：原创 2025/9/7 13:19:07

一、话费充值回调业务补偿

业务需求：供应商对接下单成功后充吧系统将订单状态更改为：等待确认中，此时等待供应商系统进行回调，当供应商系统回调时说明供应商充值成功，供应商回调充吧系统将充吧的订单改为充值成功，如果在这个过程中出现了故障，比如供应商没有回调，或者回调过程中产生了异常，或者回调不通，回调失败，如果我们不对这种情况进行处理的话,那么我们的订单状态永远得不到修改.

解决方案：

1：供应商会提供一个查询订单充值状态的接口，当我们系统对接下单成功后添加一个查询状态的任务，该任务1分钟或者几分钟后去调用供应商查询状态的API，我们根据供应商返回的结果进行充吧订单状态的修改

2：如果供应商系统能够正常回调，则将查询状态的任务取消即可

1.1.状态检查接口开发

步骤1：我们在chongba_recharge_mock工程中模拟的供应商都提供了状态检查接口，同理我需要将供应商状态检查接口api地址配置到对接模块chongba_recharge_supplier中，修改application-dev.yml配置文件如下：

supplier:jisu_url: "http://127.0.0.1:8090/jisuapi/mobilerecharge"juhe_url: "http://127.0.0.1:8090/juheapi"apis: {jisuapi: "${supplier.jisu_url}/recharge",juheapi: "${supplier.juhe_url}/recharge"}maxrepeat: 4checkStateApis: {jisuapi: "${supplier.jisu_url}/orderState",juheapi: "${supplier.juhe_url}/orderState"}stateCheckTime: 1 #状态检查时间

并修改配置类：SupplierConfig

@Data
@Component
@ConfigurationProperties(prefix = "supplier")
public class SupplierConfig {private Map<String,String> apis; //加载供应商api地址private int maxrepeat;//最大重试次数private Map<String,String> checkStateApis;private int stateCheckTime; //订单充值状态检查时间
}

步骤2：在chongba_recharge_supplier模块的对接供应商接口：SupplierService中添加检查充值状态的接口方法

public interface SupplierService {
/*** 对接供应商下单* @param rechargeRequest*/public void recharge(RechargeRequest rechargeRequest);
/*** 对接下单成功后检查充值状态* @param checkStatusRequest */public void checkStatus(CheckStatusRequest checkStatusRequest);
}

在chongba_common工程中的：com.chongba.recharge包下创建实体：
CheckStatusRequest

@Data
@NoArgsConstructor
@AllArgsConstructor
public class CheckStatusRequest {private String supplier;private String orderNo;private String tradeNo;
}

参数说明：

supplier：不同供应商查询订单充值状态API地址不一样，需要根据供应商编号去获取

orderNo：充吧系统生成的订单号，充吧支付成功后通知对接模块下单时已经将充吧订单号传递过来了

tradeNo：供应商系统生成的唯一的交易号，当我们调用供应商对接下单API后由供应商生成的唯一交易号，并返回给了充吧系统

orderNo和tradeNo参数是供应商状态检查接口需要传递的参数！企业开发中看第三方的供应商系统接口需要传递什么参数就传递什么参数。

步骤3：在SupplierServiceImpl类中实现检查状态的方法

@Override
public void checkStatus(CheckStatusRequest checkStatusRequest) {//获取状态检查接口地址String checkStatusApi = supplierConfig.getCheckStateApis().get(checkStatusRequest.getSupplier());//设置请求头HttpHeaders headers = new HttpHeaders();headers.setContentType(MediaType.APPLICATION_FORM_URLENCODED);//封装请求参数---实际业务中看供应商需要传递哪些参数，实际情况中可能要根据不同的供应商传递不同的//参数，那就要在这个逻辑中添加不同的条件分支MultiValueMap<String,String> map = new LinkedMultiValueMap<>();map.add("outorderNo",checkStatusRequest.getOrderNo());map.add("tradeNo",checkStatusRequest.getTradeNo());
HttpEntity<MultiValueMap<String,String>> httpEntity = new HttpEntity<>(map,headers);ResponseEntity<String> responseEntity = restTemplate.postForEntity(checkStatusApi, httpEntity, String.class);Result<RechargeResponse> result = JSON.parseObject(responseEntity.getBody(), new TypeReference<Result<RechargeResponse>>() {});
if(result.getCode() == StatusCode.OK){log.info("订单状态检查,订单成功{}",checkStatusRequest);updateTrade(checkStatusRequest.getOrderNo(),result.getData().getStatus());}else{//订单失败log.info("订单状态检查,订单失败{}",checkStatusRequest);updateTrade(checkStatusRequest.getOrderNo(),OrderStatusEnum.FAIL.getCode());}
}

1.2.添加和消费状态查询任务

有了对接供应商状态查询的接口，下面要做的就是在对接供应商下单成功之后添加一个查询状态的任务，该任务可在1分钟后执行，即1分钟后去查询供应商充值状态

步骤1：在chongba_recharge_supplier模块的任务接口：SupplierTask中新增两个方法，

添加查询状态任务方法：addCheckStatusTask(CheckStatusRequest checkStatusRequest);

消费查询状态任务方法：checkStatus();

/*** 添加状态检查查询任务* @param checkStatusRequest*/
public void addCheckStatusTask(CheckStatusRequest checkStatusRequest);

/*** 状态检查任务*/
public void checkStatus();

参数说明：

添加任务是为了消费任务，消费状态检查任务就是要对接供应商状态检查接口，而该接口需要传递的参数就是CheckStatusRequest ，包含了属性supplier，orderNo，tradeNo，所以添加任务时需要将CheckStatusRequest 作为任务对象Task的parameter属性值。

步骤2：实现添加和消费任务方法

@Autowired
private SupplierConfig supplierConfig;

@Override
public void addCheckStatusTask(CheckStatusRequest checkStatusRequest) {Task task = new Task();TaskTypeEnum taskTypeEnum = TaskTypeEnum.STATECHECK;task.setTaskType(taskTypeEnum.getTaskType());task.setPriority(taskTypeEnum.getPriority());Calendar calendar = Calendar.getInstance();calendar.add(Calendar.MINUTE,supplierConfig.getStateCheckTime());task.setExecuteTime(calendar.getTimeInMillis());
task.setParameters(ProtostuffUtil.serialize(checkStatusRequest));//添加状态检查任务ResponseMessage result = taskServiceClient.push(task);
}

@Override
@Scheduled(fixedRate = 1000)
public void checkStatus() {//消费状态检查任务-----发起状态检查TaskTypeEnum statecheck = TaskTypeEnum.STATECHECK;ResponseMessage poll = taskServiceClient.poll(statecheck.getTaskType(), statecheck.getPriority());if(poll.isFlag()){if(poll.getData()!=null){String taskStr = JSON.toJSONString(poll.getData());Task task = JSON.parseObject(taskStr,new TypeReference<Task>(){});CheckStatusRequest statusRequest = ProtostuffUtil.deserialize(task.getParameters(), CheckStatusRequest.class);log.info("消费任务时从拉取的任务数据{}",statusRequest);//调用状态检查接口进行状态检查supplierService.checkStatus(statusRequest);}}
}

步骤3：对接供应商下单成功后添加状态检查任务，完善SupplierServiceImpl类中的recharge方法

@Override
public void recharge(RechargeRequest rechargeRequest) {if(result !=null){//判断成功还是失败if(result.getCode() == StatusCode.OK){log.info("下单成功,等待充值处理回调！");//特别注意此时订单状态还不能修改为充值成功-----供应商回调之后才能修改为成功updateTrade(rechargeRequest.getOrderNo(),OrderStatusEnum.UNAFFIRM.getCode());//充值处理中等待确认log.info("下单成功，添加状态检查任务，1分钟后进行状态检查");supplierTask.addCheckStatusTask(new CheckStatusRequest(rechargeRequest.getSupply(),result.getData().getOrderNo(),result.getData().getTradeNo()));
return;}else {//.....................后面的代码省略}}
}

步骤3：测试：

现在要测试供应商回调不成功由充吧系统主动发起状态查询的情形，在chongba_recharge_mock工程中的MockJisuRechargeController中注释掉回调的方法

启动所有系统，进行话费充值业务。

1.3.回调成功后取消任务

当供应商成功回调后我们需要取消状态查询任务，取消任务需要任务id，而在供应商的回调方法中，只有供应商返回的订单号和交易号，没有任务id，因此在充吧添加状态查询任务时需要将充吧订单号和任务id进行关联存储，

步骤1：在SupplierTaskImpl类中完善：addCheckStatusTask添加状态检查任务方法

@Autowiredprivate CacheService cacheService;

@Overridepublic void addCheckStatusTask(CheckStatusRequest checkStatusRequest) {Task task = new Task();TaskTypeEnum taskTypeEnum = TaskTypeEnum.STATECHECK;task.setTaskType(taskTypeEnum.getTaskType());task.setPriority(taskTypeEnum.getPriority());Calendar calendar = Calendar.getInstance();calendar.add(Calendar.MINUTE,supplierConfig.getStateCheckTime());task.setExecuteTime(calendar.getTimeInMillis());task.setParameters(ProtostuffUtil.serialize(checkStatusRequest));//添加状态检查任务ResponseMessage result = taskServiceClient.push(task);//供应商系统能够正常回调则需要取消状态检查任务,取消任务需要任务id,回调成功后修改充吧订单状态知道订单号//因此要将订单号和任务id做一个映射存储if(result.getCode() == StatusCode.OK){cacheService.hPut(Constants.order_checked,checkStatusRequest.getOrderNo(),String.valueOf(result.getData()));}}

步骤2：在SupplierTask中添加一个取消状态检查任务的方法，方法参数是订单号

 /*** 取消状态检查任务* @param orderNo*/public void cancelCheckTask(String orderNo);

步骤3：在SupplierTaskImpl类中实现取消状态检查任务的方法

@Override
public void cancelCheckTask(String orderNo) {String taskId = (String) cacheService.hGet(Constants.order_checked, orderNo);if(taskId!=null){taskServiceClient.cancel(Long.valueOf(taskId));cacheService.hDelete(Constants.order_checked,orderNo);}
}

步骤4：在供应商回调成功的方法中调用取消状态检查的任务，在chongba_recharge_supplier模块的：com.chongba.supplier.controller包下的RechargeNotifyController中的notify(@RequestBody String result)方法，调用取消状态检查方法

@Autowiredprivate SupplierTask supplierTask;@RequestMapping(value = "/order/notify")public String notify(@RequestBody String result) {JSONObject jsonObject = (JSONObject) JSON.parse(result);String orderNo= (String) jsonObject.get("orderNo");int status= Integer.parseInt(jsonObject.get("status").toString());log.info("充值回调成功修改订单{}的状态为{}",orderNo,status);updateTrade(orderNo, status);log.info("回调成功后取消状态检查任务");supplierTask.cancelCheckTask(orderNo);return "sucess";}

步骤5：测试，

注意：在chongba_recharge_mock模块中将极速的回调通知方法放开，然后再测试，

启动所有工程，进行话费充值。

虚拟电商-话费充值业务（六）话费充值业务回调补偿

一、话费充值回调业务补偿业务需求：供应商对接下单成功后充吧系统将订单状态更改为：等待确认中，此时等待供应商系统进行回调，当供应商系统回调时说明供应商充值成功，供应商回调充吧系统将充吧的订单改为充值成功&…...

编程日记 2025/9/7 13:19:07

加密解密工具箱 - 专业的在线加密解密工具

加密解密工具箱 - 专业的在线加密解密工具您可以通过以下地址访问该工具： https://toolxq.com/static/hub/secret/index.html 工具简介加密解密工具箱是一个功能强大的在线加密解密工具，支持多种主流加密算法，包括 Base64、AES、RSA、DES…...

编程日记 2025/9/7 13:16:38

印度股票实时数据API接口选型指南：iTick.org如何成为开发者优选

在全球金融数字化浪潮中，印度股票市场因其高速增长潜力备受关注。对于量化交易开发者、金融科技公司而言，稳定可靠的股票报价API接口是获取市场数据的核心基础设施。本文将深度对比主流印度股票API，并揭示iTick在数据服务领域的独特优势。一…...

编程日记 2025/9/7 13:16:37

使用python实现视频播放器（支持拖动播放位置跳转）

使用python实现视频播放器（支持拖动播放位置跳转） Python实现视频播放器，在我早期的博文中介绍或作为资料记录过 Python实现视频播放器 https://blog.csdn.net/cnds123/article/details/145926189 Python实现本地视频/音频播放器https://bl…...

编程日记 2025/9/7 13:15:51

Python星球日记 - 第2天：数据类型与变量

🌟引言： 上一篇：Python星球日记 - 第1天：欢迎来到Python星球名人说：莫听穿林打叶声，何妨吟啸且徐行。—— 苏轼《定风波莫听穿林打叶声》创作者：Code_流苏(CSDN)（一个喜欢古诗词和…...

编程日记 2025/9/2 19:58:23

CyclicBarrier、Semaphore、CountDownLatch的区别，适用场景

CyclicBarrier、Semaphore 和 CountDownLatch 是 Java 并发包中用于线程协作的工具类，它们虽然都与线程同步相关，但设计目的和使用场景有显著差异。以下是它们的核心区别和典型应用场景： 1. CountDownLatch 核心机制一次性计数器&#xf…...

编程日记 2025/9/7 1:29:49

【愚公系列】《高效使用DeepSeek》050-外汇交易辅助

🌟【技术大咖愚公搬代码：全栈专家的成长之路，你关注的宝藏博主在这里！】🌟 📣开发者圈持续输出高质量干货的"愚公精神"践行者——全网百万开发者都在追更的顶级技术博主！ 👉 江湖人称"愚公搬代码"，用七年如一日的精神深耕技术领域，以"…...

编程日记 2025/9/4 14:16:25

java短连接，长连接

在网络通信中，短连接（Short Connection）是指客户端与服务器建立连接后，仅完成一次或几次数据交互就立即断开连接的通信方式。以下是关于短链接的详细说明： 一、短链接的核心特点连接短暂数据传输完成后立即关闭连接…...

编程日记 2025/8/28 18:41:26

从零开始训练Codebook：基于ViT的图像重建实践

完整代码在文末，可以一键运行。 1. 核心原理 Codebook是一种离散表征学习方法，其核心思想是将连续特征空间映射到离散的码本空间。我们的实现方案包含三个关键组件： 1.1 ViT编码器 class ViTEncoder(nn.Module):def __init__(self, codebo…...

编程日记 2025/8/28 18:41:24

每日一题洛谷P8664 [蓝桥杯 2018 省 A] 付账问题c++

P8664 [蓝桥杯 2018 省 A] 付账问题 - 洛谷 (luogu.com.cn) 思路：要使方差小，那么钱不能一下付的太多，可以让钱少的全付玩，剩下还需要的钱再让钱多的付（把钱少的补上）。将钱排序，遍历一遍&…...

编程日记 2025/8/28 18:41:22

蓝桥杯真题——传送阵

原题连接：蓝桥杯2024年第十五届省赛真题-传送阵 - C语言网知识点：并查集题目描述小蓝在环球旅行时来到了一座古代遗迹，里面并排放置了 n 个传送阵，进入第 i 个传送阵会被传送到第 ai 个传送阵前，并且可以随时选择…...

编程日记 2025/9/4 0:42:20

解释回溯算法，如何应用回溯算法解决组合优化问题？

一、回溯算法核心原理回溯算法本质是暴力穷举的优化版本，采用"试错剪枝"策略解决问题。其核心流程如下： 路径构建：记录当前选择路径选择列表：确定可用候选元素终止条件：确定递归结束时机剪枝优化…...

编程日记 2025/8/28 23:28:11

opencv连接vs2015

需要改的地方： 1.debug x64 2.vc目录包含目录：D:\softword\opencv\opencv3416\opencv\build\include 3.vc目录库目录：D:\softword\opencv\opencv3416\opencv\build\x64\vc14\lib 4.链接器——输入：D:\softword\ope…...

编程日记 2025/9/4 20:13:27

用matlab搭建一个简单的图像分类网络

文章目录 1、数据集准备2、网络搭建3、训练网络4、测试神经网络5、进行预测6、完整代码 1、数据集准备首先准备一个包含十个数字文件夹的DigitsData，每个数字文件夹里包含1000张对应这个数字的图片，图片的尺寸都是 28281 像素的，如下图所示…...

编程日记 2025/9/4 16:11:46

移动端六大语言速记：第6部分 - 错误处理与调试

移动端六大语言速记：第6部分 - 错误处理与调试本文将对比Java、Kotlin、Flutter(Dart)、Python、ArkTS和Swift这六种移动端开发语言在错误处理与调试方面的特性，帮助开发者理解和掌握各语言的异常处理机制。 6. 错误处理与调试 6.1 异常处理各语言异常处理的语法对比：…...

编程日记 2025/9/4 3:49:43

【数据库】达梦arm64安装

话不多说，快速开始~ 1.下载进入官网： 产品下载 | 达梦在线服务平台下载安装包。选飞腾、鲲鹏都可以，都是arm架构的。我选择的是： 直接下载地址是https://download.dameng.com/eco/adapter/DM8/202502/dm8_20250117_HWarm920…...

编程日记 2025/9/4 12:58:08

QTableWidget 中insertRow(0)（头插）和 insertRow(rowCount())（尾插）的性能差异

一、目的在 Qt 的 QTableWidget 中，insertRow(0) （头插）和 insertRow(rowCount())（尾插）在性能上存在显著差异。二、QAbstractItemModel:: insertRows 原文解释 QAbstractItemModel Class | Qt Core 5.15.18 AI 解…...

编程日记 2025/9/7 1:29:52

使用MFC ActiveX开发KingScada控件（OCX）

最近有个需求，要在KingScada上面开发一个控件。原来是用的WinCC，WinCC本身是支持调用.net控件，就是winform控件的，winform控件开发简单，相对功能也更丰富。奈何WinCC不是国产的。话说KingScada，国产组态软…...

编程日记 2025/9/7 0:30:17

大模型学习二：DeepSeek R1+蒸馏模型组本地部署与调用

一、说明 DeepSeek R1蒸馏模型组是基于DeepSeek-R1模型体系，通过知识蒸馏技术优化形成的系列模型，旨在平衡性能与效率。 1、技术路径与核心能力基础架构与训练方法‌ ‌DeepSeek-R1-Zero‌：通过强化学习（RL）训练&…...

编程日记 2025/9/5 19:27:40

通过 Markdown 改进 RAG 文档处理

通过 Markdown 改进 RAG 文档处理作者：Tableau 原文地址：https://zhuanlan.zhihu.com/p/29139791931 通过 Markdown 改进 RAG 文档处理https://mp.weixin.qq.com/s/LOBOKNA71dANXHuwxe7yxw 如何将 PDF 转换为 Markdown 以获得更好的 LLM RAG 结果 Mar…...

编程日记 2025/9/3 7:34:33

Java学习总结-IO流

什么IO流？ 以内存为主体。input：磁盘向内存输入内容。output：内存向磁盘输入内容。 IO流的分类：...

编程日记 2025/8/28 23:27:54

python发送qq邮件

1.发送邮件的前提是你的qq邮箱设置能够用程序访问这个服务点打开就在设置->账号中可以找到 # 导入 smtplib 库，用于实现 SMTP 协议，可实现邮件的发送功能 import smtplib # 从 email.mime.multipart 模块导入 MIMEMultipart 类，用…...

编程日记 2025/9/1 21:06:47

使用Deployment运行无状态应用

使用Deployment运行无状态应用文章目录使用Deployment运行无状态应用[toc]一、工作负载资源与控制器二、ReplicationController、ReplicaSet和Deployment1. ReplicationController（已淘汰）2. ReplicaSet（ReplicationController 的增强版&am…...

编程日记 2025/9/6 4:06:59

QT Quick（C++）跨平台应用程序项目实战教程 6 — 弹出框

目录 1. Popup组件介绍 2. 使用上一章内容完成了音乐播放器程序的基本界面框架设计。本小节完成一个简单的功能。单击该播放器顶部菜单栏的“关于”按钮，弹出该程序的相关版本信息。我们将使用Qt Quick的Popup组件来实现。 1. Popup组件介绍 Qt 中的 Popup 组件…...

编程日记 2025/9/5 3:55:42

Design Compiler：库特征分析(ALIB)

相关阅读 Design Compilerhttps://blog.csdn.net/weixin_45791458/category_12738116.html?spm1001.2014.3001.5482 简介在使用Design Compiler时，可以对目标逻辑库进行特征分析，并创建一个称为ALIB的伪库（可以被认为是缓存）&…...

编程日记 2025/8/28 23:27:47

2025高频面试设计模型总结篇

文章目录设计模型概念单例模式工厂模式策略模式责任链模式设计模型概念设计模式是前人总结的软件设计经验和解决问题的最佳方案，它们为我们提供了一套可复用、易维护、可扩展的设计思路。 （1）定义： 设计模式是一套经过验证的…...

编程日记 2025/9/6 17:35:04

41. 评论日记

越复杂的结构越脆弱，你不能因为有智驾有只能，你就全交给它了，手机永久了还发热呢，你全交给它那你要死了也怪不了谁。这年头的手机基本都有防水，但是你天天拿着这个在泳池里玩，哪天炸了我都只能说炸的响炸的…...

编程日记 2025/9/5 19:25:17

Python第七章09：自定义python包.py

# 自定义python包# 从物理上看，包就是一个文件夹，在该文件夹下包含了一个_init_.py文件，该文件夹可用于包含多个模块文件 # 从逻辑上看，包的本质依然是模块 # _init_.py 标识python包，没有就是普通文件夹&#xff0…...

编程日记 2025/9/2 10:58:19

基于大模型预测升主动脉瘤的多维度诊疗研究报告

目录一、引言 1.1 研究背景 1.2 研究目的与意义二、升主动脉瘤概述 2.1 定义与分类 2.2 发病原因与机制 2.3 流行病学现状三、大模型技术原理及应用现状 3.1 大模型基本原理 3.2 在医疗领域的应用进展 3.3 针对升主动脉瘤预测的独特价值四、术前大模型预测方案…...

编程日记 2025/9/2 15:02:39

目录 1. table.concat(list [, sep [, i [, j]]])2. table.insert(list, [pos,] value)3. table.move(src, a, b, dest [, dest_pos]) (Lua 5.3)4. table.pack(...) (Lua 5.2)5. table.remove(list [, pos])6. table.sort(list [, comp])7. table.unpack(list [, i [, j]])总结…...

编程日记 2025/9/2 13:03:52

一、话费充值回调业务补偿

1.1.状态检查接口开发

1.2.添加和消费状态查询任务

1.3.回调成功后取消任务

相关文章：