瀏覽代碼

下载文件设置延长超时时间

yumeng 5 年之前
父節點
當前提交
435e8b6c4b

+ 4 - 0
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/service/impl/KuaiShouDailyReportTaskServiceImpl.java

@@ -20,6 +20,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 
+import java.util.Date;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
@@ -88,6 +89,7 @@ public class KuaiShouDailyReportTaskServiceImpl extends ServiceImpl<KuaiShouDail
                                             loadFile(token, task);
                                         } else if (taskStatus == 3) {
                                             task.setTaskStatus(3);
+                                            task.setUpdateTime(new Date());
                                             this.updateById(task);
                                         }
                                     }
@@ -124,11 +126,13 @@ public class KuaiShouDailyReportTaskServiceImpl extends ServiceImpl<KuaiShouDail
                     reportDailyCreativeMapper.loadCreativeDailyReport(task.getAccountId(), localPath);
                 }
             }
+
             task.setTaskStatus(4);
         } catch (Exception e) {
             e.printStackTrace();
             task.setTaskStatus(5);
         }
+        task.setUpdateTime(new Date());
         this.updateById(task);
     }
 

+ 1 - 2
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/utils/DownloadUtils.java

@@ -32,7 +32,7 @@ public class DownloadUtils {
             URL url = new URL(urlStr + "?" + postBody);
             HttpURLConnection conn = (HttpURLConnection) url.openConnection();
             //设置超时间为3秒
-            conn.setConnectTimeout(10 * 1000);
+            conn.setConnectTimeout(120 * 1000);
             //防止屏蔽程序抓取而返回403错误
             conn.setRequestProperty("User-Agent", "Mozilla/4.0 (compatible; MSIE 5.0; Windows NT; DigExt)");
             conn.setRequestProperty("Access-Token", token);
@@ -45,7 +45,6 @@ public class DownloadUtils {
             byte[] getData = readInputStream(inputStream);
 
             //文件保存位置
-            System.err.println(downloadPath);
             File saveDir = new File(downloadPath);
             if (!saveDir.exists()) {
                 saveDir.mkdirs();