Pārlūkot izejas kodu

添加项目列表

zhaoxian 2 gadi atpakaļ
vecāks
revīzija
fdf81eea60

+ 13 - 1
job-bytedance/src/main/java/cn/com/ctop/job/bytedance/data/service/impl/BytedanceProjectServiceImpl.java

@@ -47,6 +47,7 @@ public class BytedanceProjectServiceImpl implements IBytedanceProjectService {
             param.put("page_size", 100);
             JSONObject filtering = new JSONObject();
             filtering.put("project_modify_time", startDate);
+            filtering.put("project_create_time", startDate);
             param.put("filtering", filtering);
             JSONObject resultObject = HttpUtils.bytedanceGetRequest(oauthToken.getAccessToken(), url, param);
             if (Check.isNull(resultObject)) {
@@ -80,5 +81,16 @@ public class BytedanceProjectServiceImpl implements IBytedanceProjectService {
         }
     }
 
-
+    public void updProjectStatus(OauthToken token, Long projectId, String disable) {
+        JSONObject params = new JSONObject();
+        params.put("advertiser_id", token.getAccountId());
+        JSONObject data = new JSONObject();
+        data.put("project_id", projectId);
+        data.put("opt_status", disable);
+        List<JSONObject> list = new ArrayList<>();
+        list.add(data);
+        params.put("data", list);
+        String url = bytedanceApiUrl + "/v3.0/project/status/update/";
+        JSONObject object = HttpUtils.bytedancePostRequest(token.getAccessToken(), url, params);
+    }
 }

+ 40 - 0
job-bytedance/src/main/java/cn/com/ctop/job/bytedance/data/utils/HttpUtils.java

@@ -230,4 +230,44 @@ public class HttpUtils {
         }
         return result;
     }
+
+
+    public static JSONObject bytedancePostRequest(String accessToken, String url, JSONObject params) {
+        // 构造请求
+        HttpPost httpEntity = new HttpPost(url);
+        httpEntity.setHeader("Access-Token", accessToken);
+        CloseableHttpResponse response = null;
+        CloseableHttpClient client = null;
+        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()));
+                StringBuilder result = new StringBuilder();
+                String line = "";
+                while ((line = bufferedReader.readLine()) != null) {
+                    result.append(line);
+                }
+                bufferedReader.close();
+                return JSONObject.parseObject(result.toString());
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+        } finally {
+            try {
+                if (response != null) {
+                    response.close();
+                }
+                if (client != null) {
+                    client.close();
+                }
+            } catch (IOException e) {
+                e.printStackTrace();
+            }
+        }
+        return null;
+    }
 }