package project.c2c.job;
|
|
import java.util.Date;
|
import java.util.Map;
|
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
|
import kernel.exception.BusinessException;
|
import kernel.util.ThreadUtils;
|
import project.RedisKeys;
|
import project.c2c.C2cOrder;
|
import project.c2c.C2cOrderLock;
|
import project.c2c.C2cOrderService;
|
import project.redis.RedisHandler;
|
import project.tip.TipService;
|
|
/**
|
* C2C订单支付时效 1分钟执行一次
|
*/
|
public class C2cExpire1MinuteJob {
|
|
private static Logger logger = LoggerFactory.getLogger(C2cExpire1MinuteJob.class);
|
|
private RedisHandler redisHandler;
|
private C2cOrderService c2cOrderService;
|
private TipService tipService;
|
|
public void taskJob() {
|
|
try {
|
|
Map<String, Long> map = (Map<String, Long>) this.redisHandler.get(RedisKeys.C2C_ORDER_NO_EXPIRE_TIME);
|
if (null != map) {
|
|
for (String orderNo : map.keySet()) {
|
|
long now = (new Date()).getTime();
|
|
// 订单自动取消
|
if (orderNo.contains("_auto_cancel")) {
|
long expireAutoCancel = map.get(orderNo);
|
if (now > expireAutoCancel) {
|
|
C2cOrder order = this.c2cOrderService.get(orderNo.replace("_auto_cancel", ""));
|
if (null != order && "0".equals(order.getState())) {
|
|
boolean lock = false;
|
|
try {
|
|
if (!C2cOrderLock.add(order.getOrderNo())) {
|
throw new BusinessException(1, "订单自动取消：获取订单锁失败！");
|
}
|
|
lock = true;
|
|
order.setRemark("订单号:"+order.getOrderNo()+"定时器自动取消订单：下单后未付款超时取消");
|
|
this.c2cOrderService.saveOrderCancel(order, "timer");
|
|
} catch (Throwable t) {
|
logger.error("error:", t);
|
} finally {
|
if (lock) {
|
ThreadUtils.sleep(100);
|
C2cOrderLock.remove(order.getOrderNo());
|
}
|
}
|
}
|
}
|
}
|
|
// 确认收款超时
|
if (orderNo.contains("_expire")) {
|
long expire = map.get(orderNo);
|
if (now > expire) {
|
|
C2cOrder order = this.c2cOrderService.get(orderNo.replace("_expire", ""));
|
if (null != order && "1".equals(order.getState())) {
|
|
order.setState("5");
|
this.c2cOrderService.update(order);
|
this.tipService.deleteTip(order.getId().toString());
|
}
|
}
|
}
|
}
|
}
|
|
} catch (Throwable t) {
|
logger.error("C2cExpire1MinuteJob run fail t:", t);
|
}
|
}
|
|
public void setRedisHandler(RedisHandler redisHandler) {
|
this.redisHandler = redisHandler;
|
}
|
|
public void setC2cOrderService(C2cOrderService c2cOrderService) {
|
this.c2cOrderService = c2cOrderService;
|
}
|
|
public void setTipService(TipService tipService) {
|
this.tipService = tipService;
|
}
|
|
}
|
