直播佣金

game-admin/src/main/java/com/game/RuoYiApplication.java

@@ -3,6 +3,7 @@ package com.game;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
+import org.springframework.scheduling.annotation.EnableScheduling;
 
 /**
  * 启动程序
@@ -10,6 +11,7 @@ import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
  * @author recruit
  */
 @SpringBootApplication(exclude = { DataSourceAutoConfiguration.class })
+@EnableScheduling
 public class RuoYiApplication
 {
     public static void main(String[] args)

game-business/src/main/java/com/game/business/config/GameOneConfig.java

@@ -16,7 +16,7 @@ public class GameOneConfig implements CommandLineRunner {
     @Override
     @Async
     public void run(String... args) throws Exception {
-        webSocketConnent = new WebSocketConnent(Common.WS_GAME_ONE_URL, Common.GANME_ONE_NAME);
-        webSocketConnent.connect();
+//        webSocketConnent = new WebSocketConnent(Common.WS_GAME_ONE_URL, Common.GANME_ONE_NAME);
+//        webSocketConnent.connect();
     }
 }

game-business/src/main/java/com/game/business/config/GameTwoConfig.java

@@ -16,7 +16,7 @@ public class GameTwoConfig implements CommandLineRunner {
     @Override
     @Async
     public void run(String... args) throws Exception {
-        webSocketConnent = new WebSocketConnent(Common.WS_GAME_TWO_URL, Common.GANME_TWO_NAME);
-        webSocketConnent.connect();
+//        webSocketConnent = new WebSocketConnent(Common.WS_GAME_TWO_URL, Common.GANME_TWO_NAME);
+//        webSocketConnent.connect();
     }
 }

game-business/src/main/java/com/game/business/task/AppUserCountTask.java

@@ -15,7 +15,7 @@ import java.util.ArrayList;
 import java.util.Date;
 import java.util.List;
 
-@Component("appUserCountTask")
+@Component
 public class AppUserCountTask {
 
     @Autowired

game-business/src/main/java/com/game/business/task/AppUserLiveDividedTask.java

@@ -7,7 +7,7 @@ import com.game.common.constant.finance.FinTranType2;
 import com.game.common.constant.finance.FinTranType3;
 import com.game.common.core.redis.RedisCache;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.scheduling.annotation.Async;
+import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 import org.springframework.transaction.annotation.Transactional;
 
@@ -15,7 +15,7 @@ import java.math.BigDecimal;
 import java.math.RoundingMode;
 import java.util.*;
 
-@Component("appUserLiveDividedTask")
+@Component
 public class AppUserLiveDividedTask {
 
     @Autowired
@@ -36,8 +36,8 @@ public class AppUserLiveDividedTask {
     @Autowired
     private RedisCache redisCache;
 
-
-    public void gameDataTask(){
+    @Scheduled(cron = "0 0/5 * * * ? ")
+    public void liveDividedTask(){
 
         AppUserLiveDivided appUserLiveDivided = new AppUserLiveDivided();
         appUserLiveDivided.setStatus(0);