/*** 订单监控类
* 定时扫描所有待付款订单，超时自动取消
* Created by huangbaidong
* 2017/3/29.*/@Componentpublic classOrderMonitorJob {
@ResourceprivateRedisUtil redisUtil;
@ResourceprivateBsdOrderService bsdOrderService;
@ResourceprivateBsdDFKOrderCacheManager bsdDFKOrderCacheManager;private boolean isLock = false;/*** 待付款订单定时扫描类
* 定时扫描所有待付款订单，超时自动取消*/
public voidpaymentTimeoutScan() {if(!isLock) {//加锁，防止定时器重复执行，
isLock = true;try{
List orders =bsdDFKOrderCacheManager.getAll();if(BlankUtil.isNotEmpty(orders)) {
List removeIds = new ArrayList<>();//需要移除的订单
for(BsdDFKOrderCacheEntity order : orders) {if (Dictionary.ORDER_STATUS_DFK ==order.getOrderStatus()) {boolean isExpire = false;if (order.isHasPromotion() == 1) {//如果是有促销规则的订单，1小时未支付，自动取消订单
if (System.currentTimeMillis() - order.getOrderTime().getTime() >CommonConstants.hasRulePayTimeout) {
isExpire= true;
}
}else{//如果是没有促销规则的订单，24小时未支付，自动取消订单
if (System.currentTimeMillis() - order.getOrderTime().getTime() >CommonConstants.hasNotRulePayTimeout) {
isExpire= true;
}
}if(isExpire) {//1、自动取消订单(操作人ID传0)
bsdOrderService.cancel(order.getId(), 0l);//2、记录过期的订单，将订单从缓存中清除
removeIds.add(order.getId().toString());
System.out.println("------>订单[" + order.getCode() + "]超时未付款自动取消订单");
}
}else{//不是待付款状态的订单，记录从缓存中清除
removeIds.add(order.getId().toString());
}
}//将不是待支付状态的订单，以及过期的未支付的订单从缓存中删除
if(BlankUtil.isNotEmpty(removeIds)) {
bsdDFKOrderCacheManager.removeFromCache(removeIds);
}
}
}finally{//运行完后释放锁
isLock = false;
}
}
}
}
