Pārlūkot izejas kodu

Merge remote-tracking branch 'origin/master'

yumeng 1 gadu atpakaļ
vecāks
revīzija
ba990e2ab1

+ 0 - 3
ruixuan-live/src/main/java/com/ruixuan/isc/service/impl/KuaishouItemListServiceImpl.java

@@ -239,9 +239,6 @@ public class KuaishouItemListServiceImpl implements IKuaishouItemListService {
         if (targetOwnershipId.equals("yuxiu")) {
             kuaishouItemListMapper.insertYuXiuItem(kuaishouItemList);
         }
-        if (targetOwnershipId.equals("yuxiu")) {
-            kuaishouItemListMapper.insertYuxiuItem(kuaishouItemList);
-        }
         JSONObject mongoVo = new JSONObject();
         mongoVo.put("_id", kuaishouItemList.getItemId());
         mongoVo.put("ownership", targetOwnershipId);

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

@@ -704,25 +704,25 @@ public class SupplyChainServiceImpl implements ISupplyChainService {
         for (KuaishouAccessToken accessToken : tokens) {
             getInfo(accessToken, beginTime, endTime, url, pcursor, 1);
         }
-        Thread.sleep(30000);
+        Thread.sleep(3000);
         List<KuaishouAccessToken> mgsTokens = accessTokenService.getMgsTokenInfos();
         for (KuaishouAccessToken accessToken : mgsTokens) {
             getMgsInfo(accessToken, beginTime, endTime, url, pcursor, 1);
         }
 
-        Thread.sleep(30000);
+        Thread.sleep(3000);
         List<KuaishouAccessToken> rocketTokens = accessTokenService.getRocketTokenInfos();
         for (KuaishouAccessToken accessToken : rocketTokens) {
             getRocketInfo(accessToken, beginTime, endTime, url, pcursor, 1);
         }
 
-        Thread.sleep(30000);
+        Thread.sleep(3000);
         List<KuaishouAccessToken> yufuTokens = accessTokenService.getYufuTokenInfos();
         for (KuaishouAccessToken accessToken : yufuTokens) {
             getYufuInfo(accessToken, beginTime, endTime, url, pcursor, 1);
         }
 
-        Thread.sleep(30000);
+        Thread.sleep(3000);
         List<KuaishouAccessToken> yuxiuTokens = accessTokenService.getYuxiuTokenInfos();
         for (KuaishouAccessToken accessToken : yuxiuTokens) {
             getYuxiuInfo(accessToken, beginTime, endTime, url, pcursor, 1);
@@ -1311,23 +1311,23 @@ public class SupplyChainServiceImpl implements ISupplyChainService {
         for (KuaishouAccessToken mgsToken : mgsTokens) {
             getMgsInfoKuaishouActivityInfo(mgsToken, url);
         }
-        Thread.sleep(30000);
+        Thread.sleep(3000);
         List<KuaishouAccessToken> rocketTokens = accessTokenService.getRocketTokenInfos();
         for (KuaishouAccessToken token : rocketTokens) {
             getRocketInfoKuaishouActivityInfo(token, url);
         }
-        Thread.sleep(30000);
+        Thread.sleep(3000);
         List<KuaishouAccessToken> tokens = accessTokenService.getTokenInfos();
         for (KuaishouAccessToken accessToken : tokens) {
             getInfoKuaishouActivityInfo(accessToken, url);
         }
-        Thread.sleep(30000);
+        Thread.sleep(3000);
         List<KuaishouAccessToken> yufutokens = accessTokenService.getYufuTokenInfos();
         for (KuaishouAccessToken accessToken : yufutokens) {
             getYufuInfoKuaishouActivityInfo(accessToken, url);
         }
 
-        Thread.sleep(30000);
+        Thread.sleep(3000);
         List<KuaishouAccessToken> yuxiutokens = accessTokenService.getYuxiuTokenInfos();
         for (KuaishouAccessToken accessToken : yuxiutokens) {
             getYuxiuInfoKuaishouActivityInfo(accessToken, url);
@@ -1345,7 +1345,7 @@ public class SupplyChainServiceImpl implements ISupplyChainService {
             }
         }
 
-        Thread.sleep(30000);
+        Thread.sleep(3000);
         List<Long> rocketActivityIds = supplyChainMapper.getRocketKuaishouActivityInfoList();
         List<KuaishouAccessToken> rocketTokens = accessTokenService.getRocketTokenInfos();
         for (KuaishouAccessToken token : rocketTokens) {
@@ -1354,7 +1354,7 @@ public class SupplyChainServiceImpl implements ISupplyChainService {
             }
         }
 
-        Thread.sleep(30000);
+        Thread.sleep(3000);
         List<Long> activityIds = supplyChainMapper.getKuaishouActivityInfoList();
         List<KuaishouAccessToken> tokens = accessTokenService.getTokenInfos();
         for (KuaishouAccessToken accessToken : tokens) {
@@ -1363,7 +1363,7 @@ public class SupplyChainServiceImpl implements ISupplyChainService {
             }
         }
 
-        Thread.sleep(30000);
+        Thread.sleep(3000);
         List<Long> yufuActivityIds = supplyChainMapper.getYufuKuaishouActivityInfoList();
         List<KuaishouAccessToken> yufutokens = accessTokenService.getYufuTokenInfos();
         for (KuaishouAccessToken accessToken : yufutokens) {
@@ -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);