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(); + } }