SpringBoot 定时任务统一处理微信提现、订单状态同步（无人饺子机后台实战） 文章标题SpringBoot Scheduled 5 秒轮询定时任务实战微信企业付款提现异步对账 自助机订单状态自动同步含 Redis 队列、分表、微信转账回调处理文章标签#SpringBoot #定时任务 Scheduled #微信企业付款对账 #Redis 队列 #分表 #自助售卖机后端 #工控饺子机文章目录业务场景说明核心定时任务完整源码代码分层逻辑拆解 3.1 Redis 提现队列异步对账微信企业付款查询、超时自动撤销 3.2 年度分表订单状态同步Redis 订单缓存落库代码存在的风险与隐患生产环境优化改造方案适用项目场景一、业务场景说明本代码是无人值守 AI 饺子机自助项目后端定时调度核心类使用Scheduled(fixedRate 5000)每 5 秒执行一次承载两大核心异步业务微信企业付款提现对账Redis 缓冲队列用户发起提现后存入 Rediswithdraw数组队列定时轮询逐个调用微信转账查询接口转账成功更新年度分表tb_user_withdraw_yyyy提现记录状态移除队列转账失败 / 已撤销直接移出队列用户待确认超过 300 秒自动调用撤销转账接口冲减平台收益台账自助机订单状态同步落库设备端取餐操作写入 RedisOrderStatus_订单ID临时缓存定时读取批量更新年度分表tb_pay_form_yyyy订单核销状态、取餐数量清理过期 Redis 缓存。配套能力自动创建年度分表、读取系统全局超时配置、JdbcTemplate 批量更新 SQL。技术栈SpringBoot Spring Scheduled RedisTemplate JdbcTemplate 微信企业付款 API 年度分表设计。二、完整核心定时任务源码package com.jbossjf.bootproject.service; import com.jbossjf.bootproject.common.weixin.WXPayUtility; import com.jbossjf.bootproject.common.CommonHelp; import com.jbossjf.bootproject.common.JsonGenericUtil; import com.jbossjf.bootproject.model.*; import com.jbossjf.bootproject.service.weixin.CancelTransferService; import com.jbossjf.bootproject.service.weixin.GetTransferBillByOutNoService; import com.jbossjf.bootproject.service.weixin.QueryByOutTradeNoService; import org.json.JSONObject; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Qualifier; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component; import java.text.SimpleDateFormat; import java.util.Date; import java.util.List; import java.util.Locale; import java.util.Map; Component public class ScheduledTasks { Autowired private JdbcTemplate jdbcTemplate; Autowired private PayFormNaticeService payFormNaticeService; Autowired private CancelTransferService cancelTransferService; Autowired QueryByOutTradeNoService queryByOutTradeNoService; Autowired GetTransferBillByOutNoService getTransferBillByOutNoService; Autowired UserWithdrawNaticeService userWithdrawNaticeService; Autowired private RedisTemplate redisTemplate; Autowired private DeviceService deviceService; Autowired private SystemParametersService systemParametersService; /** * 每5秒执行一次定时调度 * 1. 处理Redis提现队列微信企业付款对账、超时撤销 * 2. 读取系统配置取餐超时时间 * 3. 年度分表自动建表同步Redis订单取餐状态至数据库 */ Scheduled(fixedRate 1000 * 5) public void performTask() { try { // 第一块处理Redis提现队列 withdraw if(redisTemplate.hasKey(withdraw)) { MapString, String map null; String json redisTemplate.opsForValue().get(withdraw).toString(); if (!json.trim().equals([])) { ListWithdrawalNumberModel withdrawalNumberModelList JsonGenericUtil.jsonToList(json, WithdrawalNumberModel.class); SimpleDateFormat formatter1 new SimpleDateFormat(yyyy-MM-ddTHH:mm:ss, Locale.ENGLISH); // 倒序遍历避免remove导致数组下标错乱 for (int i withdrawalNumberModelList.size() - 1; i 0; i--) try{ Thread.sleep(10); map (MapString, String) withdrawalNumberModelList.get(i); // 调用微信查询转账单接口 GetTransferBillByOutNoService.GetTransferBillByOutNoRequest request new GetTransferBillByOutNoService.GetTransferBillByOutNoRequest(); request.outBillNo map.get(out_trade_no); GetTransferBillByOutNoService.TransferBillEntity response getTransferBillByOutNoService.run(request); // 场景1转账成功 SUCCESS if (response.state.name().equals(SUCCESS)) { SimpleDateFormat yearFormat new SimpleDateFormat(yyyy); Date date new Date(); String tableName tb_user_withdraw_ yearFormat.format(date); // 不存在分表则自动创建 if (userWithdrawNaticeService.tableExists(tableName) false) { userWithdrawNaticeService.createTable(tableName); } ListUserWithdraw userWithdrawList userWithdrawNaticeService.getUserWithdrawByIDTarget(tableName, response.outBillNo); // 更新提现记录状态与转账单号 String sql update tableName as tpl set tpl.transfer_bill_no response.transferBillNo , tpl.status 启用 where tpl.id userWithdrawList.get(0).getId() ;; int u jdbcTemplate.update(sql); if (u 0) { // 处理完成移出队列刷新Redis withdrawalNumberModelList.remove(i); String jsonStr JsonGenericUtil.toJson(withdrawalNumberModelList); redisTemplate.opsForValue().set(withdraw, jsonStr); } } // 场景2转账失败直接移除队列 if (response.state.name().equals(FAIL)) { withdrawalNumberModelList.remove(i); String jsonStr JsonGenericUtil.toJson(withdrawalNumberModelList); redisTemplate.opsForValue().set(withdraw, jsonStr); } // 场景3转账已撤销直接移除队列 if (response.state.name().equals(CANCELLED)) { withdrawalNumberModelList.remove(i); String jsonStr JsonGenericUtil.toJson(withdrawalNumberModelList); redisTemplate.opsForValue().set(withdraw, jsonStr); } // 场景4待用户确认超过300秒自动撤销转账 if (response.state.name().equals(WAIT_USER_CONFIRM)) { Date temp_date formatter1.parse(response.createTime); int def CommonHelp.getDistanceDateTime(temp_date, new Date()); if (def (300)) { // 调用微信撤销转账接口 CancelTransferService.CancelTransferRequest request1 new CancelTransferService.CancelTransferRequest(); request1.outBillNo response.outBillNo; CancelTransferService.CancelTransferResponse response1 cancelTransferService.run(request1); if (response1.state.equals(CANCELING)) { SimpleDateFormat yearFormat new SimpleDateFormat(yyyy); Date date new Date(); String tableName tb_user_withdraw_ yearFormat.format(date); if (userWithdrawNaticeService.tableExists(tableName) false) { userWithdrawNaticeService.createTable(tableName); } ListUserWithdraw userWithdrawList userWithdrawNaticeService.getUserWithdrawByIDTarget(tableName, response.outBillNo); // 撤销后冲减平台收益台账 String sql INSERT INTO tb_tota_userl_profit (id,name,user_id,in_amount,out_amount) VALUES ( userWithdrawList.get(0).getUser_id() , 用户提现, userWithdrawList.get(0).getUser_id() ,0, userWithdrawList.get(0).getAmount() ) ON DUPLICATE KEY UPDATE out_amount out_amount - VALUES(out_amount); ; int u jdbcTemplate.update(sql); if (u 0) { withdrawalNumberModelList.remove(i); String jsonStr JsonGenericUtil.toJson(withdrawalNumberModelList); redisTemplate.opsForValue().set(withdraw, jsonStr); } } } } }catch (Exception ex){ // 单条转账处理异常不阻断整体队列循环 ex.printStackTrace(); } } } // 第二块读取系统配置获取取餐超时阈值 ListSystemParameters systemParametersList systemParametersService.GetList(); int client_expired_time 15000; for(int i 0;isystemParametersList.size();i) { if(systemParametersList.get(i).getParam_name().equals(client_expired_time)) { client_expired_time Integer.parseInt(systemParametersList.get(i).getParam_value()); } } // 第三块订单年度分表自动创建 SimpleDateFormat yearFormat new SimpleDateFormat(yyyy); Date date new Date(); String tableName tb_pay_form_ yearFormat.format(date); if (payFormNaticeService.tableExists(tableName) false) { payFormNaticeService.createPayFormTable(tableName); } String tableItemName tb_pay_form_item_ yearFormat.format(date); if (payFormNaticeService.tableExists(tableItemName) false) { payFormNaticeService.createPayFormItemTable(tableItemName); } // 第四块同步Redis订单取餐状态到数据库 ListPayForm payFormList payFormNaticeService.getPayFormUncollectedMealStatusDataTarget(tableName,tableItemName,client_expired_time); StringBuilder sqlSb new StringBuilder(); String status ; int pick_up_quantity 0; for(int i 0;ipayFormList.size();i) { String redisKey OrderStatus payFormList.get(i).getId(); if(redisTemplate.hasKey(redisKey)) { try { String raw redisTemplate.opsForValue().get(redisKey).toString(); JSONObject rootJson new JSONObject(raw); pick_up_quantity Integer.parseInt(rootJson.get(pick_up_quantity).toString()); String orderStatus rootJson.get(status).toString(); String orderId rootJson.get(id).toString(); if (1.equals(orderStatus)) { status 取餐; sqlSb.append(UPDATE ).append(tableName) .append( SET write_off_status ).append(status).append( ) .append( WHERE id ).append(orderId).append(;); } else if (0.equals(orderStatus)) { status 未取餐; sqlSb.append(UPDATE ).append(tableName) .append( SET write_off_status ).append(status).append(,pick_up_food_quantity pick_up_food_quantity ).append(pick_up_quantity) .append( WHERE id ).append(orderId).append(;); } // 更新完成删除Redis临时缓存 redisTemplate.delete(redisKey); }catch (Exception ex) { System.out.println(订单同步异常 ex.getMessage()); } } } // 批量执行所有更新SQL String batchSql sqlSb.toString(); if(!batchSql.equals()) { jdbcTemplate.update(batchSql); } }catch (Exception ex) { // 顶层捕获所有异常防止定时任务直接终止 ex.printStackTrace(); } } }三、代码分层逻辑拆解3.1 Redis 提现队列withdraw处理逻辑存储结构Redis String 存储 JSON 数组保存待对账提现单据遍历优化倒序for (i size -1; i 0)避免list.remove(i)导致下标错位、漏处理数据四种微信转账状态分支表格转账状态业务处理逻辑SUCCESS 转账成功更新年度提现分表状态移出 Redis 队列FAIL 转账失败直接移除队列放弃重试CANCELLED 已撤销直接移除队列WAIT_USER_CONFIRM 待用户确认超过 300 秒自动调用撤销转账接口冲减平台收益台账分表兼容按年份动态拼接tb_user_withdraw_yyyy不存在则自动建表异常隔离单条提现单据捕获 Exception单条失败不阻塞整条队列循环3.2 自助机订单状态同步逻辑缓存设计设备安卓端取餐操作写入临时 RedisOrderStatus_订单ID定时任务统一落库减少频繁直接操作数据库年度分表订单主表tb_pay_form_yyyy、订单明细表tb_pay_form_item_yyyy启动时自动检查表不存在自动创建批量 SQL 优化循环拼接 UPDATE 语句单次jdbcTemplate.update()批量执行减少数据库 IO缓存清理同步完成后立即删除 Redis 订单状态 key避免重复更新动态配置从system_parameters读取全局client_expired_time取餐超时阈值无需硬编码3.3 定时任务基础配置说明java运行Scheduled(fixedRate 1000 * 5)fixedRate固定 5 秒间隔执行从上一次任务开始计时如果任务执行耗时超过 5 秒会出现任务重叠并发执行区别于fixedDelay从上一次任务结束后再等待 5 秒无并发风险。四、现有代码存在的风险与隐患4.1 定时任务并发重叠风险使用fixedRate5000如果微信接口、数据库查询阻塞超过 5 秒会同时启动多个定时线程重复操作 Redis 提现队列同一单据多次调用微信转账查询接口重复更新订单数据库引发数据脏写、重复扣减收益4.2 Redis 无分布式锁集群环境数据错乱多实例部署项目时多台服务器同时读取withdraw队列重复处理同一条提现记录造成重复更新数据库、重复调用微信撤销接口。4.3 SQL 拼接字符串存在 SQL 注入漏洞直接拼接userWithdrawList.get(0).getId()、订单 ID 等参数到 SQL 中恶意字符可实现注入攻击。4.4 Thread.sleep 阻塞定时线程循环内手动Thread.sleep(10)拉长单次任务执行时长加剧任务重叠问题无业务意义。4.5 异常捕获粒度不合理微信 API 异常仅打印堆栈无日志入库、无告警通知线上故障无法及时发现顶层大 try-catch 吞掉全部异常无法定位任务完全不执行的问题。4.6 Redis 序列化 / 并发修改风险直接读取 JSON 字符串转 List循环中修改 List 后全量覆盖 Redis value高并发下会出现数据丢失多线程同时读取数组后写入覆盖先写入的处理结果。4.7 硬编码魔法值过多300 秒超时、5 秒定时、表前缀、状态文本启用/取餐/未取餐全部硬编码后期维护修改成本极高。4.8 批量 SQL 无事务批量 UPDATE 订单时部分 SQL 执行成功、部分失败会出现订单状态不一致无事务回滚机制。五、生产环境优化改造方案5.1 替换 fixedRate 为 fixedDelay杜绝任务并发java运行// 任务执行完成后等待5秒再执行下一次不会并发重叠 Scheduled(fixedDelay 5000)5.2 增加分布式锁Redis Lock支持多实例部署使用 Redisson 锁定时任务执行前抢占锁未抢到直接退出避免多实例重复处理java运行RLock lock redissonClient.getLock(scheduled_task_lock); try { boolean acquire lock.tryLock(0, 30, TimeUnit.SECONDS); if (!acquire) return; // 原有业务逻辑 } finally { if(lock.isHeldByCurrentThread()) lock.unlock(); }5.3 预编译 SQL杜绝 SQL 注入使用JdbcTemplate.update(String sql, Object[] args)传参禁止字符串拼接 ID、金额、状态等变量。5.4 移除无用 Thread.sleep增加日志分级打印删除循环内Thread.sleep(10)替换 SLF4J 日志区分 info/warn/error异常打印完整堆栈并接入告警邮件 / 钉钉。5.5 Redis 队列优化改用 List LPOP/RPOP 原子出队当前方案是全量读取数组、内存修改后覆盖写入并发极易丢数据优化为 Redis List 队列每条提现记录单独一条数据原子弹出避免覆盖java运行// 弹出队尾一条单据原子操作多实例安全 String itemJson redisTemplate.opsForList().rightPop(withdraw_queue);5.6 批量更新增加事务控制批量更新订单、提现记录时开启事务任意一条更新失败全部回滚保证数据一致性。5.7 抽取常量类统一管理魔法值新建ScheduleConstant.java统一管理定时周期、超时秒数、Redis Key 前缀、数据库表前缀、状态码文本。5.8 拆分超大定时任务当前一个方法承载提现对账 订单同步两大重业务建议拆分为两个独立Scheduled方法职责单一故障互不影响。六、适用项目场景校园 / 社区无人 AI 饺子机、自助售货机、自助取餐柜后端服务微信企业付款商家转账到零钱批量对账、异步提现系统分表架构下定时同步缓存数据落库的后台调度服务工控 Android 设备配套后端设备端状态缓存统一持久化场景中小型支付、提现类后台定时对账系统文末结语这套定时任务是自助餐饮设备后端真实落地代码兼顾了 Redis 异步缓冲、微信支付对账、年度分表三大核心需求但原生代码存在并发、安全、稳定性隐患。上线生产环境建议按照第五部分优化方案改造增加分布式锁、预编译 SQL、事务、日志告警保证多实例集群部署下的数据一致性与服务稳定性。