|
@@ -52,23 +52,23 @@ public class QueryOrderStateTask {
|
|
|
|
|
|
@Scheduled(fixedRate = 180 * 1000)
|
|
|
public void queryOrderState() {
|
|
|
- if (canScheduleRun && production) {
|
|
|
- List<TradeNo> tradeNos = dao.selectTradeNosForScheduleTask();
|
|
|
- log.info("定时查询订单支付状态:{}", tradeNos);
|
|
|
- for (TradeNo trade : tradeNos) {
|
|
|
- if (trade.getQueryStateTimes() >= 20 || overOneHour(trade.getOffset())) {
|
|
|
- WxPayOrder order = new WxPayOrder();
|
|
|
- order.setTradeNo(trade.getTradeNo());
|
|
|
- service.closeWxOrder(order);
|
|
|
- } else {
|
|
|
- if (trade.getTradeState() == Transaction.TradeStateEnum.SUCCESS) {
|
|
|
- service.notifyCytj(trade.getTradeNo());
|
|
|
- } else {
|
|
|
- service.queryOrderState(trade.getTradeNo());
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
+// if (canScheduleRun && production) {
|
|
|
+// List<TradeNo> tradeNos = dao.selectTradeNosForScheduleTask();
|
|
|
+// log.info("定时查询订单支付状态:{}", tradeNos);
|
|
|
+// for (TradeNo trade : tradeNos) {
|
|
|
+// if (trade.getQueryStateTimes() >= 20 || overOneHour(trade.getOffset())) {
|
|
|
+// WxPayOrder order = new WxPayOrder();
|
|
|
+// order.setTradeNo(trade.getTradeNo());
|
|
|
+// service.closeWxOrder(order);
|
|
|
+// } else {
|
|
|
+// if (trade.getTradeState() == Transaction.TradeStateEnum.SUCCESS) {
|
|
|
+// service.notifyCytj(trade.getTradeNo());
|
|
|
+// } else {
|
|
|
+// service.queryOrderState(trade.getTradeNo());
|
|
|
+// }
|
|
|
+// }
|
|
|
+// }
|
|
|
+// }
|
|
|
}
|
|
|
|
|
|
private boolean overOneHour(Integer offset) {
|