From 420ffbe89b93e92d9c896be7dd22ab60e803ea77 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=99=88=E6=B2=85?= <907037276@qq.com> Date: Fri, 11 Aug 2023 15:26:10 +0800 Subject: [PATCH] =?UTF-8?q?=E4=B8=BB=E5=88=86=E6=94=AF=E4=BB=A3=E7=A0=81?= =?UTF-8?q?=E5=90=88=E5=B9=B6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../forex/trading_trading/mappers/TrainingMapper.java | 5 +++++ .../forex/trading_trading/service/ScheduledTask.java | 8 ++++++++ 2 files changed, 13 insertions(+) diff --git a/src/main/java/com/sztzjy/forex/trading_trading/mappers/TrainingMapper.java b/src/main/java/com/sztzjy/forex/trading_trading/mappers/TrainingMapper.java index ab9de39..1e546b4 100644 --- a/src/main/java/com/sztzjy/forex/trading_trading/mappers/TrainingMapper.java +++ b/src/main/java/com/sztzjy/forex/trading_trading/mappers/TrainingMapper.java @@ -143,4 +143,9 @@ public interface TrainingMapper { @Update("update sys_training set people_num=people_num-1 where training_id=#{trainingId}") void deletePeopleNum(@Param("trainingId") String trainingId); + @Select("SELECT * " + + "FROM sys_training " + + "WHERE end_time >= NOW() - INTERVAL 5 MINUTE AND end_time <= NOW() AND status = 'FINISHED'") + List findTrainingForUpdateScore(); + } \ No newline at end of file diff --git a/src/main/java/com/sztzjy/forex/trading_trading/service/ScheduledTask.java b/src/main/java/com/sztzjy/forex/trading_trading/service/ScheduledTask.java index a949f40..93153fa 100644 --- a/src/main/java/com/sztzjy/forex/trading_trading/service/ScheduledTask.java +++ b/src/main/java/com/sztzjy/forex/trading_trading/service/ScheduledTask.java @@ -12,6 +12,7 @@ import com.sztzjy.forex.trading_trading.controller.TradingController; import com.sztzjy.forex.trading_trading.entity.ForexMarketData; import com.sztzjy.forex.trading_trading.entity.Member; import com.sztzjy.forex.trading_trading.entity.TakeStash; +import com.sztzjy.forex.trading_trading.entity.Training; import com.sztzjy.forex.trading_trading.entity.mql5Entity.ForexData; import com.sztzjy.forex.trading_trading.mappers.TrainingMapper; import com.sztzjy.forex.trading_trading.util.BigDecimalUtils; @@ -348,7 +349,14 @@ public class ScheduledTask { @Scheduled(cron = "0 */5 * * * ?") public void updateStuRank() { +// List trainingForUpdateScore = trainingMapper.findTrainingForUpdateScore(); +// if(trainingForUpdateScore!=null&&trainingForUpdateScore.size()>0){ +// //TODO 修改用户收益成绩 +// } + + memberService.updateStuRank(); + } }