Browse Source

分页修改

zhaoxian 9 months ago
parent
commit
147d1b9dde

+ 9 - 9
ruixuan-live/src/main/java/com/ruixuan/isc/service/impl/SupplyChainServiceImpl.java

@@ -1307,7 +1307,7 @@ public class SupplyChainServiceImpl implements ISupplyChainService {
     @Override
     public void addListKuaishouActivityInfo() throws InterruptedException {
         String url = "https://openapi.kwaixiaodian.com";
-        List<KuaishouAccessToken> mgsTokens = accessTokenService.getMgsTokenInfos();
+/*        List<KuaishouAccessToken> mgsTokens = accessTokenService.getMgsTokenInfos();
         for (KuaishouAccessToken mgsToken : mgsTokens) {
             getMgsInfoKuaishouActivityInfo(mgsToken, url);
         }
@@ -1327,7 +1327,7 @@ public class SupplyChainServiceImpl implements ISupplyChainService {
             getYufuInfoKuaishouActivityInfo(accessToken, url);
         }
 
-        Thread.sleep(30000);
+        Thread.sleep(30000);*/
         List<KuaishouAccessToken> yuxiutokens = accessTokenService.getYuxiuTokenInfos();
         for (KuaishouAccessToken accessToken : yuxiutokens) {
             getYuxiuInfoKuaishouActivityInfo(accessToken, url);
@@ -1337,7 +1337,7 @@ public class SupplyChainServiceImpl implements ISupplyChainService {
     @Override
     public void addKuaishouActivityOpenItemList() throws InterruptedException {
         String url = "https://openapi.kwaixiaodian.com";
-        List<Long> mgsActivityIds = supplyChainMapper.getMgsKuaishouActivityInfoList();
+       /* List<Long> mgsActivityIds = supplyChainMapper.getMgsKuaishouActivityInfoList();
         List<KuaishouAccessToken> mgsTokens = accessTokenService.getMgsTokenInfos();
         for (KuaishouAccessToken mgsToken : mgsTokens) {
             for (Long activityId : mgsActivityIds) {
@@ -1372,7 +1372,7 @@ public class SupplyChainServiceImpl implements ISupplyChainService {
             }
         }
 
-        Thread.sleep(30000);
+        Thread.sleep(30000);*/
         List<Long> yuxiuActivityIds = supplyChainMapper.getYuxiuKuaishouActivityInfoList();
         List<KuaishouAccessToken> yuxiutokens = accessTokenService.getYuxiuTokenInfos();
         for (KuaishouAccessToken accessToken : yuxiutokens) {
@@ -1477,7 +1477,7 @@ public class SupplyChainServiceImpl implements ISupplyChainService {
         request.setApiMethodVersion(1L);
 
         //每页活动数量
-        request.setLimit(5000);
+        request.setLimit(200);
         OpenDistributionInvestmentActivityOpenListResponse response = null;
         try {
             response = client.execute(request);
@@ -1668,7 +1668,7 @@ public class SupplyChainServiceImpl implements ISupplyChainService {
         request.setApiMethodVersion(1L);
 
         //每页活动数量
-        request.setLimit(5000);
+        request.setLimit(200);
         OpenDistributionInvestmentActivityOpenListResponse response = null;
         try {
             response = client.execute(request);
@@ -1710,7 +1710,7 @@ public class SupplyChainServiceImpl implements ISupplyChainService {
         request.setApiMethodVersion(1L);
 
         //每页活动数量
-        request.setLimit(5000);
+        request.setLimit(200);
         OpenDistributionInvestmentActivityOpenListResponse response = null;
         try {
             response = client.execute(request);
@@ -1751,7 +1751,7 @@ public class SupplyChainServiceImpl implements ISupplyChainService {
         request.setApiMethodVersion(1L);
 
         //每页活动数量
-        request.setLimit(5000);
+        request.setLimit(200);
         OpenDistributionInvestmentActivityOpenListResponse response = null;
         try {
             response = client.execute(request);
@@ -1792,7 +1792,7 @@ public class SupplyChainServiceImpl implements ISupplyChainService {
         request.setApiMethodVersion(1L);
 
         //每页活动数量
-        request.setLimit(5000);
+        request.setLimit(200);
         OpenDistributionInvestmentActivityOpenListResponse response = null;
         try {
             response = client.execute(request);