From bfcbef7a6bf2eb73bbf7ae84dac49a8f49db1e1c Mon Sep 17 00:00:00 2001
From: zyy <zyy@email.com>
Date: Tue, 08 Jul 2025 14:49:45 +0800
Subject: [PATCH] 修改股票类型

---
 src/main/java/com/nq/utils/task/stock/CarryPositionTask.java |    6 +++---
 1 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/src/main/java/com/nq/utils/task/stock/CarryPositionTask.java b/src/main/java/com/nq/utils/task/stock/CarryPositionTask.java
index 9791e1a..bad2a99 100644
--- a/src/main/java/com/nq/utils/task/stock/CarryPositionTask.java
+++ b/src/main/java/com/nq/utils/task/stock/CarryPositionTask.java
@@ -102,7 +102,7 @@
     private final AtomicBoolean subscription = new AtomicBoolean(false);
 
 //    @Scheduled(cron = "0 0/1 * * * ?")
-    public void subscription() {
+    /*public void subscription() {
         if (subscription.get()) { // 判断任务是否在处理中
             return;
         }
@@ -113,7 +113,7 @@
                 List<UserStockSubscribe> userStockSubscribes = userStockSubscribeMapper.selectList(new LambdaQueryWrapper<UserStockSubscribe>()
                         .eq(UserStockSubscribe::getStatus, 3));
                 userStockSubscribes.forEach(f->{
-                    UserAssets userAssets = userAssetsServices.assetsByTypeAndUserId("IN",f.getUserId());
+                    UserAssets userAssets = userAssetsServices.assetsByTypeAndUserId(EStockType.MX.getCode(), f.getUserId());
                     if(null != userAssets && userAssets.getAmountToBeCovered().compareTo(BigDecimal.ZERO) == 0){
                         f.setStatus(4);
                         userStockSubscribeMapper.updateById(f);
@@ -129,6 +129,6 @@
         } else {
             log.info("自动转已认缴定时任务--------->上次任务还未执行完成,本次任务忽略");
         }
-    }
+    }*/
 
 }

--
Gitblit v1.9.3