diff --git a/src/main/java/io/github/ehlxr/cache/TestFutureCahe.java b/src/main/java/io/github/ehlxr/cache/TestFutureCahe.java index 5e4be9c..7ab36ec 100644 --- a/src/main/java/io/github/ehlxr/cache/TestFutureCahe.java +++ b/src/main/java/io/github/ehlxr/cache/TestFutureCahe.java @@ -33,7 +33,7 @@ import java.util.concurrent.FutureTask; * Created by ehlxr on 2017/4/11. */ public class TestFutureCahe { - private final ConcurrentHashMap> cacheMap = new ConcurrentHashMap>(); + private final ConcurrentHashMap> cacheMap = new ConcurrentHashMap<>(); public static void main(String[] args) { final TestFutureCahe TestGuaVA = new TestFutureCahe(); diff --git a/src/main/java/io/github/ehlxr/DidSdkTest.java b/src/main/java/io/github/ehlxr/test/DidSdkTest.java similarity index 98% rename from src/main/java/io/github/ehlxr/DidSdkTest.java rename to src/main/java/io/github/ehlxr/test/DidSdkTest.java index 57212cd..d8ff9d1 100644 --- a/src/main/java/io/github/ehlxr/DidSdkTest.java +++ b/src/main/java/io/github/ehlxr/test/DidSdkTest.java @@ -22,7 +22,7 @@ * THE SOFTWARE. */ -package io.github.ehlxr; +package io.github.ehlxr.test; // // import cn.ceres.did.client.SdkClient; // import cn.ceres.did.sdk.SdkProto; diff --git a/src/main/java/io/github/ehlxr/LambdaTest.java b/src/main/java/io/github/ehlxr/test/LambdaTest.java similarity index 98% rename from src/main/java/io/github/ehlxr/LambdaTest.java rename to src/main/java/io/github/ehlxr/test/LambdaTest.java index 6e7da06..92a2032 100644 --- a/src/main/java/io/github/ehlxr/LambdaTest.java +++ b/src/main/java/io/github/ehlxr/test/LambdaTest.java @@ -22,7 +22,7 @@ * THE SOFTWARE. */ -package io.github.ehlxr; +package io.github.ehlxr.test; import java.util.Arrays; import java.util.List; diff --git a/src/main/java/io/github/ehlxr/test/TestCompletableFuture.java b/src/main/java/io/github/ehlxr/test/TestCompletableFuture.java new file mode 100644 index 0000000..39753ee --- /dev/null +++ b/src/main/java/io/github/ehlxr/test/TestCompletableFuture.java @@ -0,0 +1,142 @@ +/* + * The MIT License (MIT) + * + * Copyright © 2020 xrv + * + * Permission is hereby granted, free of charge, to any person obtaining a copy + * of this software and associated documentation files (the "Software"), to deal + * in the Software without restriction, including without limitation the rights + * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell + * copies of the Software, and to permit persons to whom the Software is + * furnished to do so, subject to the following conditions: + * + * The above copyright notice and this permission notice shall be included in + * all copies or substantial portions of the Software. + * + * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR + * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, + * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE + * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER + * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, + * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN + * THE SOFTWARE. + */ + +package io.github.ehlxr.test; + +import java.util.Random; +import java.util.concurrent.CompletableFuture; +import java.util.concurrent.Future; + +/** + * https://colobu.com/2016/02/29/Java-CompletableFuture/ + * + * @author ehlxr + * @since 2020-12-18 10:12. + */ +public class TestCompletableFuture { + // public static void main(String[] args) throws ExecutionException, InterruptedException { + // ExecutorService es = Executors.newFixedThreadPool(10); + // Future f = es.submit(() -> { + // // 长时间的异步计算 + // Thread.sleep(3000); + // // 然后返回结果 + // return 100; + // }); + // // while (!f.isDone()); + // System.out.println(f.get()); + // } + + // public static CompletableFuture compute() { + // return new CompletableFuture<>(); + // } + // + // public static void main(String[] args) throws Exception { + // final CompletableFuture f = compute(); + // class Client extends Thread { + // final CompletableFuture f; + // + // Client(String threadName, CompletableFuture f) { + // super(threadName); + // this.f = f; + // } + // + // @Override + // public void run() { + // try { + // System.out.println(this.getName() + ": " + f.get()); + // } catch (InterruptedException | ExecutionException e) { + // e.printStackTrace(); + // } + // } + // } + // new Client("Client1", f).start(); + // new Client("Client2", f).start(); + // System.out.println("waiting"); + // // 完成，客户端 get() 阻塞通过 + // f.complete(100); + // //f.completeExceptionally(new Exception()); + // } + + + private static final long t = System.currentTimeMillis(); + + static int getMoreData() { + System.out.println("begin to start compute"); + try { + Thread.sleep(2000); + } catch (InterruptedException e) { + throw new RuntimeException(e); + } + System.out.println("end to start compute. passed " + (System.currentTimeMillis() - t) / 1000 + " seconds"); + return 1000; + } + + public static void main(String[] args) throws Exception { + CompletableFuture future = CompletableFuture.supplyAsync(TestCompletableFuture::getMoreData); + Future f = future.whenComplete((v, e) -> { + System.out.println("the result is " + v); + e.printStackTrace(); + }); + // System.out.println(f.get()); + + System.out.println("wait for result....."); + + + CompletableFuture f1 = future.thenAccept((x) -> System.out.println("thenAccept " + x)); + // System.out.println(f1.get()); + + + CompletableFuture f2 = future.thenAcceptBoth(CompletableFuture.completedFuture(5), (x, y) -> System.out.println("thenAcceptBoth " + x * y)); + // System.out.println(f2.get()); + + Random rand = new Random(); + CompletableFuture future2 = CompletableFuture.supplyAsync(() -> { + try { + Thread.sleep(1000 + rand.nextInt(1000)); + } catch (InterruptedException e) { + e.printStackTrace(); + } + return 200; + }); + CompletableFuture f3 = future.applyToEither(future2, Object::toString); + System.out.println("applyToEither " + f3.get()); + + + CompletableFuture future3 = CompletableFuture.supplyAsync(() -> { + try { + Thread.sleep(1000 + rand.nextInt(1000)); + } catch (InterruptedException e) { + e.printStackTrace(); + } + return "abc"; + }); + CompletableFuture f4 = CompletableFuture.allOf(future, future2, future3); + // CompletableFuture f4 = CompletableFuture.anyOf(future, future2, future3); + // System.out.println("anyOf " + f4.get()); + + System.in.read(); + } + + +} diff --git a/src/main/java/io/github/ehlxr/test/TestCountDownLatch.java b/src/main/java/io/github/ehlxr/test/TestCountDownLatch.java index 6ad7ff6..ca4c7bb 100644 --- a/src/main/java/io/github/ehlxr/test/TestCountDownLatch.java +++ b/src/main/java/io/github/ehlxr/test/TestCountDownLatch.java @@ -32,7 +32,7 @@ import java.util.concurrent.CountDownLatch; public class TestCountDownLatch { private static final int N = 10; - private static final Map cache = new ConcurrentHashMap(); + private static final Map cache = new ConcurrentHashMap<>(); public static void main(String[] args) throws InterruptedException { CountDownLatch doneSignal = new CountDownLatch(N); diff --git a/src/main/java/io/github/ehlxr/thread/TestSingleThreadExecutor.java b/src/main/java/io/github/ehlxr/test/TestSingleThreadExecutor.java similarity index 98% rename from src/main/java/io/github/ehlxr/thread/TestSingleThreadExecutor.java rename to src/main/java/io/github/ehlxr/test/TestSingleThreadExecutor.java index 63c8fc0..d7376e6 100644 --- a/src/main/java/io/github/ehlxr/thread/TestSingleThreadExecutor.java +++ b/src/main/java/io/github/ehlxr/test/TestSingleThreadExecutor.java @@ -22,7 +22,7 @@ * THE SOFTWARE. */ -package io.github.ehlxr.thread; +package io.github.ehlxr.test; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; diff --git a/src/main/java/io/github/ehlxr/thread/ThreadPoolExecutorTest.java b/src/main/java/io/github/ehlxr/test/ThreadPoolExecutorTest.java similarity index 98% rename from src/main/java/io/github/ehlxr/thread/ThreadPoolExecutorTest.java rename to src/main/java/io/github/ehlxr/test/ThreadPoolExecutorTest.java index 9032000..dff9573 100644 --- a/src/main/java/io/github/ehlxr/thread/ThreadPoolExecutorTest.java +++ b/src/main/java/io/github/ehlxr/test/ThreadPoolExecutorTest.java @@ -22,7 +22,7 @@ * THE SOFTWARE. */ -package io.github.ehlxr.thread; +package io.github.ehlxr.test; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; diff --git a/src/main/java/io/github/ehlxr/VarArgsTest.java b/src/main/java/io/github/ehlxr/test/VarArgsTest.java similarity index 98% rename from src/main/java/io/github/ehlxr/VarArgsTest.java rename to src/main/java/io/github/ehlxr/test/VarArgsTest.java index 5840e53..0054e00 100644 --- a/src/main/java/io/github/ehlxr/VarArgsTest.java +++ b/src/main/java/io/github/ehlxr/test/VarArgsTest.java @@ -22,7 +22,7 @@ * THE SOFTWARE. */ -package io.github.ehlxr; +package io.github.ehlxr.test; /** * Created by ehlxr on 2018/1/16. diff --git a/src/main/java/io/github/ehlxr/testminisite/TestMinisite.java b/src/main/java/io/github/ehlxr/testminisite/TestMinisite.java deleted file mode 100644 index 4d5dc0a..0000000 --- a/src/main/java/io/github/ehlxr/testminisite/TestMinisite.java +++ /dev/null @@ -1,58 +0,0 @@ -/* - * The MIT License (MIT) - * - * Copyright © 2020 xrv - * - * Permission is hereby granted, free of charge, to any person obtaining a copy - * of this software and associated documentation files (the "Software"), to deal - * in the Software without restriction, including without limitation the rights - * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell - * copies of the Software, and to permit persons to whom the Software is - * furnished to do so, subject to the following conditions: - * - * The above copyright notice and this permission notice shall be included in - * all copies or substantial portions of the Software. - * - * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR - * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, - * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE - * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER - * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, - * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN - * THE SOFTWARE. - */ - -package io.github.ehlxr.testminisite; - -import io.github.ehlxr.utils.HttpClientUtil; - -import java.util.HashMap; -import java.util.Map; - -public class TestMinisite { - public static String URL = "http://127.0.0.1:8080/dsp-minisite/Audi2016Q2/getProvinces"; - - public static void main(String[] args) throws Exception { - Map params = new HashMap<>(); - params.put("project", "1"); - params.put("bid","1"); - params.put("mapid","1"); - params.put("name","1"); - params.put("gender","1"); - params.put("tel","1"); - params.put("favoriteModel","1"); - params.put("province","1"); - params.put("city","1"); - params.put("dealerName","1"); - params.put("dealerCode","1"); - params.put("scheduledTime","1"); - params.put("budget","1"); - - params.put("provinceName","北京"); - params.put("cityName","北京"); - - // System.out.println(HttpClientUtil.sendPostParam(URL, params)); - System.out.println(HttpClientUtil.sendGet(URL)); - } - -} diff --git a/src/main/java/io/github/ehlxr/testopen/SignatureUtil.java b/src/main/java/io/github/ehlxr/testopen/SignatureUtil.java deleted file mode 100644 index 6b86a6f..0000000 --- a/src/main/java/io/github/ehlxr/testopen/SignatureUtil.java +++ /dev/null @@ -1,164 +0,0 @@ -/* - * The MIT License (MIT) - * - * Copyright © 2020 xrv - * - * Permission is hereby granted, free of charge, to any person obtaining a copy - * of this software and associated documentation files (the "Software"), to deal - * in the Software without restriction, including without limitation the rights - * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell - * copies of the Software, and to permit persons to whom the Software is - * furnished to do so, subject to the following conditions: - * - * The above copyright notice and this permission notice shall be included in - * all copies or substantial portions of the Software. - * - * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR - * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, - * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE - * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER - * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, - * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN - * THE SOFTWARE. - */ - -package io.github.ehlxr.testopen; - - -import org.apache.commons.lang.StringUtils; - -import java.security.MessageDigest; -import java.security.NoSuchAlgorithmException; -import java.util.ArrayList; -import java.util.Collections; -import java.util.List; - -/** - * 签名工具类 - */ -public class SignatureUtil { - - - private static final char[] hexArray = "0123456789ABCDEF".toCharArray(); - - private static final String encryptionAlgorithm = "SHA-1"; - - public static String bytesToHexString(byte[] bytes) { - char[] hexChars = new char[bytes.length * 2]; - for (int j = 0; j < bytes.length; j++) { - int v = bytes[j] & 0xFF; - hexChars[j * 2] = hexArray[v >>> 4]; - hexChars[j * 2 + 1] = hexArray[v & 0x0F]; - } - return new String(hexChars); - } - - public static byte[] hexStringToBytes(String s) { - int len = s.length(); - byte[] data = new byte[len / 2]; - for (int i = 0; i < len; i += 2) { - data[i / 2] = (byte) ((Character.digit(s.charAt(i), 16) << 4) + Character.digit(s.charAt(i + 1), 16)); - } - return data; - } - - /** - * 使用指定算法生成消息摘要，默认是md5 - * - * @param strSrc - * , a string will be encrypted;
- * @param encName - * , the algorithm name will be used, dafault to "MD5";
- * @return - */ - public static String digest(String strSrc, String encName) { - MessageDigest md = null; - String strDes = null; - byte[] bt = strSrc.getBytes(); - try { - if (encName == null || encName.equals("")) { - encName = "MD5"; - } - md = MessageDigest.getInstance(encName); - md.update(bt); - strDes = bytesToHexString(md.digest()); // to HexString - } catch (NoSuchAlgorithmException e) { - return null; - } - return strDes; - } - - /** - * 根据appid、token、lol以及时间戳来生成签名 - * - * @param appid - * @param token - * @param lol - * @param millis - * @return - */ - public static String generateSignature(String appid, String token, String lol, long millis) { - String timestamp = String.valueOf(millis); - String signature = null; - if (StringUtils.isNotBlank(token) && StringUtils.isNotBlank(timestamp) && StringUtils.isNotBlank(appid)) { - List srcList = new ArrayList(); - srcList.add(timestamp); - srcList.add(appid); - srcList.add(token); - srcList.add(lol); - // 按照字典序逆序拼接参数 - Collections.sort(srcList); - Collections.reverse(srcList); - StringBuilder sb = new StringBuilder(); - for (int i = 0; i < srcList.size(); i++) { - sb.append(srcList.get(i)); - } - signature = digest(sb.toString(), encryptionAlgorithm); - srcList.clear(); - srcList = null; - } - return signature; - } - - /** - * 验证签名:
- * 1.根据appid获取该渠道的token;
- * 2.根据appid、token、lol以及时间戳计算一次签名;
- * 3.比较传过来的签名以及计算出的签名是否一致; - * - * @param signature - * @param appid - * @param lol - * @param millis - * @return - */ - public static boolean isValid(String signature, String appid,String token, String lol, long millis) { - String calculatedSignature = generateSignature(appid, token, lol, millis); - return StringUtils.equals(calculatedSignature, signature); - } - - - public static void main(String[] args) { - String xmlString = "testtesttesttesttesttesttesttesttesttesttesttesttesttesttesttesttesttesttesttesttesttesttesttesttesttesttesttesttest"; - System.out.println(xmlString.getBytes().length); - - //消息 - String digest = SignatureUtil.digest(xmlString, "MD5"); - System.out.println("----" + digest); - System.out.println(digest.getBytes().length); - - - String appid = "canairport001"; - String token = "111ddff"; - long millis = System.currentTimeMillis(); - - //生成签名 - String signature = SignatureUtil.generateSignature(appid, token, digest, millis); - - System.out.println(signature); - - //验证签名 - boolean isValid = SignatureUtil.isValid(signature, appid,token, digest, millis); - System.out.println(isValid); - } -} diff --git a/src/main/java/io/github/ehlxr/testopen/TestOpenPuton.java b/src/main/java/io/github/ehlxr/testopen/TestOpenPuton.java deleted file mode 100644 index 7b2e3d6..0000000 --- a/src/main/java/io/github/ehlxr/testopen/TestOpenPuton.java +++ /dev/null @@ -1,297 +0,0 @@ -/* - * The MIT License (MIT) - * - * Copyright © 2020 xrv - * - * Permission is hereby granted, free of charge, to any person obtaining a copy - * of this software and associated documentation files (the "Software"), to deal - * in the Software without restriction, including without limitation the rights - * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell - * copies of the Software, and to permit persons to whom the Software is - * furnished to do so, subject to the following conditions: - * - * The above copyright notice and this permission notice shall be included in - * all copies or substantial portions of the Software. - * - * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR - * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, - * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE - * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER - * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, - * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN - * THE SOFTWARE. - */ - -package io.github.ehlxr.testopen; - -import io.github.ehlxr.utils.AESTool; -import io.github.ehlxr.utils.Base64; -import io.github.ehlxr.utils.HttpClientUtil; -import net.sf.json.JSONArray; -import net.sf.json.JSONObject; - -import java.nio.charset.StandardCharsets; -import java.util.HashMap; -import java.util.Map; - -public class TestOpenPuton { - private static final String URL = "http://127.0.0.1:8080/dsp-open/pxene/dsp.do"; - private static final String key = "adjdjfjfjfjdkdkd";// - private static final String appid = "t123456";// 用户 - private static final String token = "cst123456";// 令牌 - - public static void main(String[] args) throws Exception { - - // String sendPostParam = HttpClientUtil.sendPostParam(URL, getPostParam("setAdxProp"));// 获得数据并且发送请求 - // String data = getData(sendPostParam); - // System.out.println(JSONObject.fromObject(data)); - - - JSONObject json = new JSONObject(); - json.put("param", "中午"); - String str = "{\"order_info\":{\"put_time\":[],\"cost_type\":1,\"order_budget\":{\"budget_all\":100.0},\"cost_single\":100.0,\"type\":1,\"order_id\":14575,\"landing_page\":\"www.baidu.com\",\"order_name\":\"tony-test-31\",\"brand_en\":null,\"plat\":1,\"end_time\":\"2016-05-03\",\"creative_group\":[{\"group_name\":\"test_五一\",\"plat\":1,\"ratio\":\"-\",\"group_id\":405,\"click_code\":null,\"impression_code\":null,\"landing_page\":\"www.baidu.com\"}],\"buy_type\":1,\"order_freq\":{\"imp_day_req\":5,\"click_total_freq\":5,\"imp_total_req\":10,\"click_day_freq\":1},\"ad_owner\":{\"owner_qualification\":[],\"owner_name\":\"ABI\",\"organization_code\":null,\"owner_id\":107,\"owner_category\":\"食品饮料>健康饮料，运动饮料，功能性饮料\",\"website_url\":\"http://sedrin.reloadbuzz.com/food2/xueJin/index.php/home/user/index\"},\"start_time\":\"2016-05-03\",\"order_goal\":{\"order_total_show\":1},\"brand_zh\":\"Sedrin\",\"industry\":\"食品饮料>健康饮料，运动饮料，功能性饮料\",\"note\":\"媒体类型定向：\\nnull\\n\\n关键词定向：\\n123\\n\\n广告素材轮播：\\n平均\\n\\n备注：\\n备注1(资源设置)：\\n321\\n\\n\\n\"}}"; - - System.out.println(HttpClientUtil.sendPostJSONData(URL, str)); - } - - public static String getData(String encryptString) throws Exception { - byte[] decode = Base64.decode(encryptString.getBytes()); - String aString = new String(decode, StandardCharsets.UTF_8); - String decrypt = AESTool.decrypt(aString, key); - return decrypt; - } - - public static Map getPostParam(String content) throws Exception { - Map postParam = new HashMap(); - content = getContent(content); - - // 业务数据 - long millis = System.currentTimeMillis();// 时间戳j - content = AESTool.encrypt(content, key);// 使用aes加密 - String lol = SignatureUtil.digest(content, "MD5");// 摘要 - String signature = SignatureUtil.generateSignature(appid, token, lol, millis);// 签名 - - // 准备提交数据 - postParam.put("appid", appid); - postParam.put("content", content); - postParam.put("lol", lol); - postParam.put("signature", signature); - postParam.put("millis", millis + ""); - - return postParam; - } - - // 在这里写请求数据 - public static String getContent(String contentName) { - JSONObject content = new JSONObject(); - JSONObject param = new JSONObject(); - content.put("servicename", "putonServiceCall"); - - switch (contentName) { - case "putOnByCreative": - param.put("campaignid", "26861f62-5cd7-4073-9186-676f8f5d7b24"); - param.put("groupid", "022ea1a5-3f21-40dd-9c24-c0edfa82bfda"); - param.put("adxid", "1fed4171-9925-4834-aa7b-9b4d3a58841b"); - - JSONArray mapIds = new JSONArray(); - mapIds.add("28f13909-dbbe-42e4-b9fd-edd97a31d6ce"); - mapIds.add("8b7b1b4a-eb3a-4be0-809b-b497c58a14f6"); - mapIds.add("b7f39e0c-3025-4fa3-8e83-ef1f492fe358"); - param.put("mapids", mapIds); - - content.put("funcname", "putOnByCreative"); - content.put("methodparam", param); - break; - case "pauseByCreative": - param.put("groupid", "022ea1a5-3f21-40dd-9c24-c0edfa82bfda"); - param.put("adxid", "1fed4171-9925-4834-aa7b-9b4d3a58841b"); - - mapIds = new JSONArray(); - mapIds.add("28f13909-dbbe-42e4-b9fd-edd97a31d6ce"); - mapIds.add("8b7b1b4a-eb3a-4be0-809b-b497c58a14f6"); - mapIds.add("b7f39e0c-3025-4fa3-8e83-ef1f492fe358"); - param.put("mapids", mapIds); - - content.put("funcname", "pauseByCreative"); - content.put("methodparam", param); - break; - case "putOnByAdx": - param.put("campaignid", "26861f62-5cd7-4073-9186-676f8f5d7b24"); - - JSONArray groupAdxs = new JSONArray(); - JSONObject groupAdx = new JSONObject(); - groupAdx.put("groupid", "022ea1a5-3f21-40dd-9c24-c0edfa82bfda"); - groupAdx.put("adxid", "1fed4171-9925-4834-aa7b-9b4d3a58841b"); - groupAdxs.add(groupAdx); - groupAdx = new JSONObject(); - groupAdx.put("groupid", "022ea1a5-3f21-40dd-9c24-c0edfa82bfda"); - groupAdx.put("adxid", "6246ae47-d24b-4afa-88ba-57417ccab6aa"); - groupAdxs.add(groupAdx); - groupAdx = new JSONObject(); - groupAdx.put("groupid", "022ea1a5-3f21-40dd-9c24-c0edfa82bfda"); - groupAdx.put("adxid", "ce579246-e707-4cb9-b982-88cad7944b92"); - groupAdxs.add(groupAdx); - - param.put("groupadxs", groupAdxs); - - content.put("funcname", "putOnByAdx"); - content.put("methodparam", param); - break; - case "pauseByAdx": - groupAdxs = new JSONArray(); - groupAdx = new JSONObject(); - groupAdx.put("groupid", "022ea1a5-3f21-40dd-9c24-c0edfa82bfda"); - groupAdx.put("adxid", "1fed4171-9925-4834-aa7b-9b4d3a58841b"); - groupAdxs.add(groupAdx); - groupAdx = new JSONObject(); - groupAdx.put("groupid", "022ea1a5-3f21-40dd-9c24-c0edfa82bfda"); - groupAdx.put("adxid", "6246ae47-d24b-4afa-88ba-57417ccab6aa"); - groupAdxs.add(groupAdx); - groupAdx = new JSONObject(); - groupAdx.put("groupid", "022ea1a5-3f21-40dd-9c24-c0edfa82bfda"); - groupAdx.put("adxid", "ce579246-e707-4cb9-b982-88cad7944b92"); - groupAdxs.add(groupAdx); - - param.put("groupadxs", groupAdxs); - - content.put("funcname", "pauseByAdx"); - content.put("methodparam", param); - break; - case "putOnByGroup": - param.put("campaignid", "26861f62-5cd7-4073-9186-676f8f5d7b24"); - - JSONArray groupids = new JSONArray(); - groupids.add("022ea1a5-3f21-40dd-9c24-c0edfa82bfda"); - param.put("groupids", groupids); - - content.put("funcname", "putOnByGroup"); - content.put("methodparam", param); - break; - case "pauseByGroup": - groupids = new JSONArray(); - groupids.add("022ea1a5-3f21-40dd-9c24-c0edfa82bfda"); - param.put("groupids", groupids); - - content.put("funcname", "pauseByGroup"); - content.put("methodparam", param); - break; - case "putOnByCampaign": - JSONArray campaignids = new JSONArray(); - campaignids.add("26861f62-5cd7-4073-9186-676f8f5d7b24"); - param.put("campaignids", campaignids); - - content.put("funcname", "putOnByCampaign"); - content.put("methodparam", param); - break; - case "pauseByCampaign": - campaignids = new JSONArray(); - campaignids.add("26861f62-5cd7-4073-9186-676f8f5d7b24"); - param.put("campaignids", campaignids); - - content.put("funcname", "pauseByCampaign"); - content.put("methodparam", param); - break; - case "setAdxProp": - JSONArray propdatas = new JSONArray(); - JSONObject propdata = new JSONObject(); - JSONObject adxprop = new JSONObject(); - JSONArray adxprops = new JSONArray(); - - adxprop.put("adxid", "1fed4171-9925-4834-aa7b-9b4d3a58841b"); - adxprop.put("prop", 20); - adxprops.add(adxprop); - - adxprop = new JSONObject(); - adxprop.put("adxid", "6246ae47-d24b-4afa-88ba-57417ccab6aa"); - adxprop.put("prop", 15.5); - adxprops.add(adxprop); - - adxprop = new JSONObject(); - adxprop.put("adxid", "ce579246-e707-4cb9-b982-88cad7944b92"); - adxprop.put("prop", 26.5); - adxprops.add(adxprop); - - propdata.put("groupid", "022ea1a5-3f21-40dd-9c24-c0edfa82bfda"); - propdata.put("adxprops", adxprops); - - propdatas.add(propdata); - - param.put("propdatas", propdatas); - content.put("funcname", "setAdxProp"); - content.put("methodparam", param); - break; - case "setCreateivePrice": - JSONArray createiveprices = new JSONArray(); - - JSONObject createiveprice = new JSONObject(); - createiveprice.put("mapid", "28f13909-dbbe-42e4-b9fd-edd97a31d6ce"); - createiveprice.put("price", 10); - createiveprices.add(createiveprice); - - createiveprice = new JSONObject(); - createiveprice.put("mapid", "8b7b1b4a-eb3a-4be0-809b-b497c58a14f6"); - createiveprice.put("price", 6); - createiveprices.add(createiveprice); - - createiveprice = new JSONObject(); - createiveprice.put("mapid", "b7f39e0c-3025-4fa3-8e83-ef1f492fe358"); - createiveprice.put("price", 8); - createiveprices.add(createiveprice); - - param.put("groupid", "022ea1a5-3f21-40dd-9c24-c0edfa82bfda"); - param.put("adxid", "1fed4171-9925-4834-aa7b-9b4d3a58841b"); - param.put("createiveprices", createiveprices); - - content.put("funcname", "setCreateivePrice"); - content.put("methodparam", param); - break; - case "getKpiByCampaignIds": - campaignids = new JSONArray(); - campaignids.add("26861f62-5cd7-4073-9186-676f8f5d7b24"); - - param.put("campaignids", campaignids); - - content.put("funcname", "getKpiByCampaignIds"); - content.put("methodparam", param); - break; - case "getKpiByGroupIds": - groupids = new JSONArray(); - groupids.add("022ea1a5-3f21-40dd-9c24-c0edfa82bfda"); - - param.put("groupids", groupids); - - content.put("funcname", "getKpiByGroupIds"); - content.put("methodparam", param); - break; - case "getKpiByAdxIds": - JSONArray adxids = new JSONArray(); - adxids.add("1fed4171-9925-4834-aa7b-9b4d3a58841b"); - adxids.add("6246ae47-d24b-4afa-88ba-57417ccab6aa"); - adxids.add("ce579246-e707-4cb9-b982-88cad7944b92"); - - param.put("groupid", "022ea1a5-3f21-40dd-9c24-c0edfa82bfda"); - param.put("adxids", adxids); - - content.put("funcname", "getKpiByAdxIds"); - content.put("methodparam", param); - break; - case "getKpiByMapIds": - JSONArray mapids = new JSONArray(); - mapids.add("28f13909-dbbe-42e4-b9fd-edd97a31d6ce"); - mapids.add("8b7b1b4a-eb3a-4be0-809b-b497c58a14f6"); - mapids.add("b7f39e0c-3025-4fa3-8e83-ef1f492fe358"); - - param.put("groupid", "022ea1a5-3f21-40dd-9c24-c0edfa82bfda"); - param.put("adxid", "1fed4171-9925-4834-aa7b-9b4d3a58841b"); - param.put("mapids", mapids); - - content.put("funcname", "getKpiByMapIds"); - content.put("methodparam", param); - break; - default: - break; - } - System.out.println(content.toString()); - return content.toString(); - } -}