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

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<Training> trainingForUpdateScore = trainingMapper.findTrainingForUpdateScore();
+//        if(trainingForUpdateScore!=null&&trainingForUpdateScore.size()>0){
+//            //TODO 修改用户收益成绩
+//        }
+
+
         memberService.updateStuRank();
+
     }
 
 }