Explorar o código

修改定时任务超时时间

syh %!s(int64=5) %!d(string=hai) anos
pai
achega
ef074aa55a

+ 1 - 3
jeecg-boot-module-system/src/main/java/org/jeecg/modules/ctop/job/BytedanceCreativeLoadJob.java

@@ -29,7 +29,6 @@ public class BytedanceCreativeLoadJob implements Job {
 
     @Override
     public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
-        Date getDate = DateUtils.addDay(new Date(), -1);
         List<CtopOauthToken> tokens = tokenService.getTokenListByType(CtopAdConstant.PLATFORM_TYPE_BYTEDANCE);
         executorService = Executors.newFixedThreadPool(4);
         countDownLatch = new CountDownLatch(tokens.size());
@@ -38,8 +37,7 @@ public class BytedanceCreativeLoadJob implements Job {
                 @Override
                 public void run() {
                     try {
-                        String getDateString = DateUtils.formatDate(getDate);
-                        //获取全量视频素材数据
+                        String getDateString = DateUtils.formatDate(new Date());
                         advertiserDataService.getAdvertiserCreative(token, getDateString);
                     } catch (Exception e) {
                         e.printStackTrace();

+ 4 - 0
module-common/src/main/java/cn/com/ctop/common/module/utils/HttpUtils.java

@@ -68,6 +68,8 @@ public class HttpUtils {
             client = HttpClientBuilder.create().build();
             httpEntity.setURI(URI.create(url));
             httpEntity.setEntity(new StringEntity(params.toJSONString(), ContentType.APPLICATION_JSON));
+            RequestConfig requestConfig = RequestConfig.custom().setSocketTimeout(12000).setConnectTimeout(12000).build();
+            httpEntity.setConfig(requestConfig);
             response = client.execute(httpEntity);
             if (response != null && response.getStatusLine().getStatusCode() == 200) {
                 BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
@@ -105,6 +107,8 @@ public class HttpUtils {
         try {
             client = HttpClientBuilder.create().build();
             httpEntity.setEntity(new StringEntity(params.toJSONString(), ContentType.APPLICATION_JSON));
+            RequestConfig requestConfig = RequestConfig.custom().setSocketTimeout(12000).setConnectTimeout(12000).build();
+            httpEntity.setConfig(requestConfig);
             response = client.execute(httpEntity);
             if (response != null && response.getStatusLine().getStatusCode() == 200) {
                 BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));