java实现订单未支付失效_未支付订单30分钟后,自动取消
未支付订单30分钟后,自动取消
生成订单时发起延时30分钟的任务
/**
* 取消订单的任务
* @Title: startCancelOrderTask
* @Description: 取消订单的任务
* @param orderInfo
* @throws
*/
private void startCancelOrderTask(OrderInfo orderInfo){
if(orderInfo.getPayStatus().equals(PayStatusEnum.NOPAY.ordinal())){
//SysParam.getOrderDelay() 时间30
OrderSchedule.getInstance().startTask( new OrderFailureJob(orderInfo.getOrderId()), SysParam.getOrderDelay(), TimeUnit.MINUTES);
}
}
OrderSchedule
package com.ghgcn.cigarbox.task.job;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
/**
*
* @ClassName: OrderSchedule
* @Description: 订单取消的预定计划
* @author
* @date 2018年4月10日 下午5:13:34
*
*/
public class OrderSchedule {
private static ScheduledExecutorService Manager;
private static OrderSchedule orderSchedule;
static{
Manager = Executors.newScheduledThreadPool(Runtime.getRuntime().availableProcessors());
}
private OrderSchedule(){
}
public synchronized static OrderSchedule getInstance(){
if(orderSchedule == null){
orderSchedule = new OrderSchedule();
}
return orderSchedule;
}
/**
* 生成订单时调用,一段时间后订单取消
*/
public void startTask(Runnable task,long delay ,TimeUnit time ){
Manager.schedule(task,delay,time);
}
}
OrderFailureJob
package com.ghgcn.cigarbox.task.job;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
import org.jflame.toolkit.util.DateHelper;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.ghgcn.cigarbox.common.enums.OrderEnums.OrderStatusEnum;
import com.ghgcn.cigarbox.common.enums.OrderEnums.PayStatusEnum;
import com.ghgcn.cigarbox.entity.OrderInfo;
import com.ghgcn.cigarbox.service.IOrderInfoService;
import com.ghgcn.cigarbox.support.SpringContextHolder;
/**
*
* @ClassName: OrderFailureJob
* @Description: 定时取消订单
* @author
* @date 2018年4月10日 下午5:13:15
*
*/
public class OrderFailureJob implements Runnable {
private Logger logger = LoggerFactory.getLogger(OrderFailureJob.class);
private Integer orderId;
private static Lock lock = new ReentrantLock();
/**
获取Servcie
*/
private IOrderInfoService orderInfoService = SpringContextHolder.getBean(IOrderInfoService.class);
public OrderFailureJob(Integer orderId) {
super();
this.orderId = orderId;
logger.debug("orderId {} ",orderId);
logger.debug("orderInfoService {} ",orderInfoService.toString());
}
@Override
public void run() {
/**
* 查询订单
*/
OrderInfo info = orderInfoService.selectOrderInfoByOrderId(orderId);
logger.info(" 订单信息 {} ",info.toString());
if (info.getOrderStatus().equals(OrderStatusEnum.NORMAL.ordinal())
&& info.getPayStatus().equals(PayStatusEnum.NOPAY.ordinal())) {
lock.lock();
try{
/**
更改订单状态
*/
info.setOrderStatus(OrderStatusEnum.CANCEL.ordinal());
info.setUpdateDate(DateHelper.nowTimestamp());
orderInfoService.updateOrderInfo(info);
}finally{
lock.unlock();
}
}
}
}
SpringContextHolder
package com.ghgcn.cigarbox.support;
import java.util.Locale;
import org.springframework.beans.BeansException;
import org.springframework.context.ApplicationContext;
import org.springframework.context.ApplicationContextAware;
import org.springframework.context.ApplicationEvent;
/**
* spring ApplicationContext holder
*
*
*/
public final class SpringContextHolder implements ApplicationContextAware {
private static ApplicationContext springContext;
@Override
public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
SpringContextHolder.springContext = applicationContext;
}
/**
* 返回spring上下文环境对象
*
* @return ApplicationContext
*/
public static ApplicationContext getSpringContext() {
return springContext;
}
/**
* 按名称获取spring bean
*
* @param name
* @return
*/
public static Object getBean(String name) {
return springContext.getBean(name);
}
/**
* 按类型获取spring bean
*
* @param requiredType
* @return
*/
public static T getBean(Class requiredType) {
return springContext.getBean(requiredType);
}
/**
* 发布事件到spring
* @param event
*/
public static void pushEvent(ApplicationEvent event) {
springContext.publishEvent(event);
}
}
在xml中声明或者注解
@Component
public final class SpringContextHolder implements ApplicationContextAware {
另外
如果有消息队列可以发送延时消息,来处理
java实现订单未支付失效_未支付订单30分钟后,自动取消相关推荐
- windows 远程 登录无操作30分钟后自动退出登录_【计时优易学车远程教育学习流程】...
重要通知: 1.2020年11月21日之后报名的学员,目前不需要到驾校学习科目一(4小时)及科目四(2小时),可直接用优易学车app远程教育学习,请12月6日之前尽快将科目一及科目四学时学完,如后期有 ...
- java实现订单未支付失效_生成订单后一段时间不支付订单会自动关闭的功能该如何实现?...
业务场景 我们以订单功能为例说明下:生成订单后一段时间不支付订单会自动关闭.最简单的想法是设置定时任务轮询,但是每个订单的创建时间不一样,定时任务的规则无法设定,如果将定时任务执行的间隔设置的过短,太 ...
- java微信web支付开发_微信支付java开发详细第三方支付功能开发之支付宝web端支...
这段时间把支付基本搞完了,因为做的过程中遇到许多问题,特地记录下来,同时方便其他java coder,废话少说,下面开始. 整体思路:在后台,根据参数创建支付宝客户端AlipayClient,发送参数 ...
- 云付认证已通过可以支付吗_云支付常见问题
支付接入流程相关 1. 什么样的应用可以接入支付? 已经签订收益补充协议的应用(详见合同与收益),才能接入支付. 2. non-hosting应用可以接入支付吗? 支付接入已支持non-hosting ...
- php 工商银行公众号支付代码_微信支付PHP SDK —— 公众号支付代码详解
在微信支付 开发者文档页面 下载最新的 php SDK 这里假设你已经申请完微信支付 1. 微信后台配置 如图 我们先进行测试,所以先把测试授权目录和 测试白名单添加上.测试授权目录是你要发起微信请 ...
- jsapi支付签名_微信支付小程序支付全流程
点击蓝色字关注我们! 一个努力中的公众号 长的好看的人都关注了 本文给大家讲解微信小程序支付全流程,以及相关功能源代码,项目不开放,带来不便尽请谅解.小程序支付主要包含如下几步骤,1.预下单-调用微信 ...
- php 工商银行公众号支付代码_微信支付PHP SDK之微信公众号支付代码详解
这里假设你已经申请完微信支付 1. 微信后台配置 如图 我们先进行测试,所以先把测试授权目录和 测试白名单添加上.测试授权目录是你要发起微信请求的哪个文件所在的目录. 例如jsapi 发起请求一般是 ...
- java的开发环境日蚀日_将依赖项添加到后未解析geotools的导入pom.xml文件在日蚀中...
我尝试将地理工具添加到我的pom.xml文件使用以下指南: https://www.baeldung.com/geo-tools http://docs.geotools.org/latest/use ...
- java怎么调用支付接口测试_微信支付中微信红包的接口测试,Java版本
需要有认证的公众号,且开通了微信支付,商户平台且开通了现金红包的权限即可. 商户登陆地址:https://pay.weixin.qq.com选择查看营销中心的现金红包. 现金红包的官网文档说明: ht ...
最新文章
- AI自动设计了“超级马里奥”新关卡,成功晋升游戏设计师(GECCO 2018最佳论文提名)...
- jsp response对象
- hihocoder 1638:多级并查集
- ie浏览器里面无法输入文字:
- java设计模式之简单工厂模式
- windows7 + vs2008 + oracle + iis7 客户端配置成功
- vaOJ10369 - Arctic Network
- java页面要素_Web前端入门技术之网页制作三要素
- Mysql数据恢复有哪几种_MYSQL 数据恢复有哪些
- Java学习路线(转)
- Mac电脑分屏软件——Spectacle
- python爬楼梯问题_python解决上楼梯问题
- python求小于n的最大素数_找出小于n的最大素数,其中n =〜10 ^ 230 - python
- java抽象类和普通类_抽象类和普通类的区别是什么?java类和抽象类的区别
- Camera 图像处理原理分析- 色彩篇 一
- 四种内容付费盈利模式介绍
- 金蝶EAS开发笔记(理论篇)
- go-micro教程
- Fabric基础配置文件解析(一)
- 大环境不确定,高端IT人才独有的大趋势在哪?|猿代码科技
热门文章
- DJYOS驱动开发系列三:基于DJYOS的SPI驱动编写指导手册
- matlab simulink 微分,Matlab/Simulink建模详解:一阶时变偏微分方程的求解
- Nginx部署vue,及后端项目的接口转发
- 2023年全国最新安全员精选真题及答案13
- “战疫杯”大学生程序设计在线邀请赛(6)题解
- 荔枝派Zero(全志V3S)编译Kernel
- 00后专升本男孩入围阿里数学竞赛决赛,为钻研数学曾42天不碰手机,央视认证自律“狠”人...
- python:点击就能玩的超级玛丽小游戏(附有源码)
- 简述神经网络算法的具体流程
- js手撕——bind的模拟实现