From f7d714ecc4210b96de9e78eacf6fad394533a082 Mon Sep 17 00:00:00 2001
From: zyy <zyy@email.com>
Date: Wed, 31 Dec 2025 16:28:06 +0800
Subject: [PATCH] ipo
---
trading-order-admin/src/main/java/com/yami/trading/admin/task/NewSharesTask.java | 26 ++++++++++++++++++++------
1 files changed, 20 insertions(+), 6 deletions(-)
diff --git a/trading-order-admin/src/main/java/com/yami/trading/admin/task/NewSharesTask.java b/trading-order-admin/src/main/java/com/yami/trading/admin/task/NewSharesTask.java
index 5b829b3..ae70a8d 100644
--- a/trading-order-admin/src/main/java/com/yami/trading/admin/task/NewSharesTask.java
+++ b/trading-order-admin/src/main/java/com/yami/trading/admin/task/NewSharesTask.java
@@ -1,11 +1,10 @@
package com.yami.trading.admin.task;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
-import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
-import com.yami.trading.bean.etf.domain.EtfMinuteKLine;
-import com.yami.trading.bean.item.domain.Item;
+import com.yami.trading.bean.ipo.UserPromiseRecord;
import com.yami.trading.bean.model.Wallet;
import com.yami.trading.service.WalletService;
+import com.yami.trading.service.ipo.UserPromiseRecordService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
@@ -15,7 +14,6 @@
import java.math.BigDecimal;
import java.util.*;
-import java.util.concurrent.CompletableFuture;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
@@ -32,8 +30,11 @@
@Autowired
WalletService walletService;
+ @Autowired
+ UserPromiseRecordService userPromiseRecordService;
+
/**
- * 同步系统所需要的股票
+ * 待补自动扣费
*/
@Scheduled(cron = "0 0/5 * * * ?")
public void syncINStockData() {
@@ -55,7 +56,20 @@
BigDecimal amountToBeCovered = wallet.getAmountToBeCovered();
if (money.compareTo(amountToBeCovered) >= 0) {
wallet.setMoney(money.subtract(amountToBeCovered));
+ wallet.setAmountToBeCovered(BigDecimal.ZERO);
log.info("用户id{}已补完待补", wallet.getUserId());
+
+ LambdaQueryWrapper<UserPromiseRecord> queryWrapper2 = new LambdaQueryWrapper<>();
+ queryWrapper2.eq(UserPromiseRecord::getUserId, wallet.getUserId());
+ queryWrapper2.eq(UserPromiseRecord::getStatus, 1);
+ List<UserPromiseRecord> userPromiseRecords = userPromiseRecordService.list(queryWrapper2);
+ if (!userPromiseRecords.isEmpty()) {
+ userPromiseRecords.forEach((userPromiseRecord) -> {
+ userPromiseRecord.setStatus(2);
+ log.info("订单{}已确认认缴", userPromiseRecord.getOrderNo());
+ });
+ userPromiseRecordService.updateBatchById(userPromiseRecords);
+ }
} else {
//资金不足
BigDecimal newAmountToBeCovered = amountToBeCovered.subtract(money);
@@ -70,7 +84,7 @@
} catch (Exception e) {
- log.error("同步股票数据出错", e);
+ log.error("待补自动扣费出错", e);
} finally {
syncINStockDataLock.unlock();
syncINStockData.set(false);
--
Gitblit v1.9.3