|
|
@@ -55,6 +55,7 @@ public class TradeOrderTask {
|
|
|
|
|
|
@Scheduled(cron = "0 0/5 * * * ?")
|
|
|
public void task() {
|
|
|
+ log.info("定时任务");
|
|
|
List<KwoTradeOrder> kwoTradeOrders = kwoTradeOrderMapper.selectList(new LambdaQueryWrapper<KwoTradeOrder>()
|
|
|
.eq(KwoTradeOrder::getStatus, TradeOrderStatusEnum.DEAL.getCode())
|
|
|
.eq(KwoTradeOrder::getDelFlag, Global.UN_DELETED)
|
|
|
@@ -97,6 +98,9 @@ public class TradeOrderTask {
|
|
|
walletFreeze.setOrderNo(kwoTradeOrder.getTOrderNo());
|
|
|
log.info("结算 {}", JSONObject.toJSONString(walletFreeze));
|
|
|
walletApi.dealMoney(walletFreeze);
|
|
|
+
|
|
|
+ kwoTradeOrder.setStatus(TradeOrderStatusEnum.SUCCESS.getCode());
|
|
|
+ kwoTradeOrderMapper.updateById(kwoTradeOrder);
|
|
|
} catch (Exception ex) {
|
|
|
log.error("更新订单异常{}", ex.getMessage());
|
|
|
}
|