yumeng 4 rokov pred
rodič
commit
f21eb0cb90

+ 73 - 74
jeecg-boot-module-system/src/main/java/org/jeecg/modules/ctop/controller/TestController.java

@@ -79,7 +79,7 @@ public class TestController {
 
     @Autowired
     private IBatchService batchService;
-    static ExecutorService executorService = Executors.newFixedThreadPool(15);
+    static ExecutorService executorService = Executors.newFixedThreadPool(10);
     static ExecutorService videoService = Executors.newFixedThreadPool(5);
     static ExecutorService suzhaoService = Executors.newFixedThreadPool(5);
 
@@ -109,19 +109,16 @@ public class TestController {
         list.add(7882996L);
         list.add(7883032L);
         list.add(7922257L);*/
-        list.add(9643754L);
-        list.add(9538300L);
-        list.add(9643726L);
-        list.add(9538319L);
-        list.add(9643738L);
+        list.add(8042807L);
+        list.add(8042794L);
 
         //   list.add(8159827L);
 
         for (int i = 0; i < list.size(); i++) {
             Long accountId = list.get(i);
             CtopOauthToken oauthToken = oauthTokenService.getTokenByAccountId(accountId);
-            kuaishouInterfaceService.getCampaignList(oauthToken, null, null);
-            //  kuaishouInterfaceService.getGroupList(oauthToken, null, null);
+            //    kuaishouInterfaceService.getCampaignList(oauthToken, null, null);
+            kuaishouInterfaceService.getGroupList(oauthToken, null, null);
         }
 
     }
@@ -166,12 +163,14 @@ public class TestController {
     @GetMapping(value = "/updateUnit")
     public void updateUnit() throws Exception {
         List<Long> list = new ArrayList();
-        list.add(8206288L);
+        list.add(8042807L);
+        list.add(8042794L);
         for (int i = 0; i < list.size(); i++) {
             Long accountId = list.get(i);
             CtopOauthToken oauthToken = oauthTokenService.getTokenByAccountId(accountId);
             QueryWrapper<KuaiShouGroup> groupQueryWrapper = new QueryWrapper<>();
             groupQueryWrapper.eq("account_id", accountId);
+            groupQueryWrapper.ne("schedule_time","000000111111111111111111000000111111111111111111000000111111111111111111000000111111111111111111000000111111111111111111000000111111111111111111000000111111111111111111");
             //     groupQueryWrapper.eq("use_app_market", 1);
 
 
@@ -187,21 +186,21 @@ public class TestController {
 
 
             for (KuaiShouGroup group : list1) {
-             /*   executorService.submit(new Runnable() {
+                executorService.submit(new Runnable() {
                     @Override
-                    public void run() {*/
-                try {
-                    JSONObject json = new JSONObject();
-                    json.put("unitId", group.getUnitId());
-                    json.put("cpaBid", 8500);
-                    json.put("deepConversionBid", 21270);
-                    batchService.updateUnit(json, oauthToken);
-                    Thread.sleep(1000);
-                } catch (Exception e) {
-                    e.printStackTrace();
-                }
-                    /*}
-                });*/
+                    public void run() {
+                        try {
+                            JSONObject json = new JSONObject();
+                            json.put("unitId", group.getUnitId());
+                            //    json.put("cpaBid", 8500);
+                            json.put("scheduleTime", "000000111111111111111111000000111111111111111111000000111111111111111111000000111111111111111111000000111111111111111111000000111111111111111111000000111111111111111111");
+                            batchService.updateUnit(json, oauthToken);
+                            Thread.sleep(1000);
+                        } catch (Exception e) {
+                            e.printStackTrace();
+                        }
+                    }
+                });
 
 
             }
@@ -230,59 +229,59 @@ public class TestController {
 
       /*      QueryWrapper<KuaiShouCampaign> campaignQueryWrapper = new QueryWrapper<>();
             campaignQueryWrapper.eq("account_id", accountId);*/
-     //       List<KuaiShouCampaign> campaignList = campaignService.list(campaignQueryWrapper);
-           // if (!Check.isNull(campaignList)) {
-             //   for (KuaiShouCampaign campaign : campaignList) {
-                    QueryWrapper<KuaiShouCreative> creativeQueryWrapper = new QueryWrapper<>();
-                    creativeQueryWrapper.eq("account_id", accountId);
-                //    creativeQueryWrapper.eq("campaign_id", campaign.getCampaignId());
-                    if (accountId == 9643726L) {
-                        creativeQueryWrapper.ne("click_track_url", "https://youku-dsp.youku.com/ksrta/track?evt=clk&biz=RTAKS_NU&oaid=__OAID__&imei=__IMEI2__&idfa=__IDFA2__&mac=__MAC2__&os=__OS__&callback=__CALLBACK__&pid=073067367598206b&ip=__IP__&adgroup_id=__AID__&ad_id=__DID__&cid=__CID__");
-                    }
-                    if (accountId == 9538300L) {
-                        creativeQueryWrapper.ne("click_track_url", "https://youku-dsp.youku.com/ksrta/track?evt=clk&biz=RTAKS_NU&oaid=__OAID__&imei=__IMEI2__&idfa=__IDFA2__&mac=__MAC2__&os=__OS__&callback=__CALLBACK__&pid=1711d4f52f5cac73&ip=__IP__&adgroup_id=__AID__&ad_id=__DID__&cid=__CID__");
-                    }
-                    if (accountId == 9538319L) {
-                        creativeQueryWrapper.ne("click_track_url", "https://youku-dsp.youku.com/ksrta/track?evt=clk&biz=RTAKS_NU&oaid=__OAID__&imei=__IMEI2__&idfa=__IDFA2__&mac=__MAC2__&os=__OS__&callback=__CALLBACK__&pid=97559ba2595ac86b&ip=__IP__&adgroup_id=__AID__&ad_id=__DID__&cid=__CID__");
-                    }
-                    List<KuaiShouCreative> creativeList = creativeService.list(creativeQueryWrapper);
-                    for (KuaiShouCreative creative : creativeList) {
-                        executorService.submit(new Runnable() {
-                            @Override
-                            public void run() {
-                                try {
-                                    JSONObject json = new JSONObject();
-                                    json.put("creativeId", creative.getCreativeId());
-
-                                    String url = "";
-                                    if (accountId == 9643754L) {
-                                        url = "https://youku-dsp.youku.com/ksrta/track?evt=clk&biz=RTAKS_NU&oaid=__OAID__&imei=__IMEI2__&idfa=__IDFA2__&mac=__MAC2__&os=__OS__&callback=__CALLBACK__&pid=c91817d982fee2c5&ip=__IP__&adgroup_id=__AID__&ad_id=__DID__&cid=__CID__";
-                                    } else if (accountId == 9538300L) {
-                                        url = "https://youku-dsp.youku.com/ksrta/track?evt=clk&biz=RTAKS_NU&oaid=__OAID__&imei=__IMEI2__&idfa=__IDFA2__&mac=__MAC2__&os=__OS__&callback=__CALLBACK__&pid=1711d4f52f5cac73&ip=__IP__&adgroup_id=__AID__&ad_id=__DID__&cid=__CID__";
-                                    } else if (accountId == 9643726L) {
-                                        url = "https://youku-dsp.youku.com/ksrta/track?evt=clk&biz=RTAKS_NU&oaid=__OAID__&imei=__IMEI2__&idfa=__IDFA2__&mac=__MAC2__&os=__OS__&callback=__CALLBACK__&pid=073067367598206b&ip=__IP__&adgroup_id=__AID__&ad_id=__DID__&cid=__CID__";
-                                    } else if (accountId == 9538319L) {
-                                        url = "https://youku-dsp.youku.com/ksrta/track?evt=clk&biz=RTAKS_NU&oaid=__OAID__&imei=__IMEI2__&idfa=__IDFA2__&mac=__MAC2__&os=__OS__&callback=__CALLBACK__&pid=97559ba2595ac86b&ip=__IP__&adgroup_id=__AID__&ad_id=__DID__&cid=__CID__";
-                                    } else if (accountId == 9643738L) {
-                                        url = "https://youku-dsp.youku.com/ksrta/track?evt=clk&biz=RTAKS_NU&oaid=__OAID__&imei=__IMEI2__&idfa=__IDFA2__&mac=__MAC2__&os=__OS__&callback=__CALLBACK__&pid=c636c67574553c44&ip=__IP__&adgroup_id=__AID__&ad_id=__DID__&cid=__CID__";
-                                    }
-                                    if (creative.getCreativeMaterialType() == 1) {
-                                        json.put("clickTrackUrl", url);
-                                    } else if (creative.getCreativeMaterialType() == 4) {
-                                        json.put("impressionUrl", url);
-                                        json.put("clickTrackUrl", url);
-
-                                    }
+            //       List<KuaiShouCampaign> campaignList = campaignService.list(campaignQueryWrapper);
+            // if (!Check.isNull(campaignList)) {
+            //   for (KuaiShouCampaign campaign : campaignList) {
+            QueryWrapper<KuaiShouCreative> creativeQueryWrapper = new QueryWrapper<>();
+            creativeQueryWrapper.eq("account_id", accountId);
+            //    creativeQueryWrapper.eq("campaign_id", campaign.getCampaignId());
+            if (accountId == 9643726L) {
+                creativeQueryWrapper.ne("click_track_url", "https://youku-dsp.youku.com/ksrta/track?evt=clk&biz=RTAKS_NU&oaid=__OAID__&imei=__IMEI2__&idfa=__IDFA2__&mac=__MAC2__&os=__OS__&callback=__CALLBACK__&pid=073067367598206b&ip=__IP__&adgroup_id=__AID__&ad_id=__DID__&cid=__CID__");
+            }
+            if (accountId == 9538300L) {
+                creativeQueryWrapper.ne("click_track_url", "https://youku-dsp.youku.com/ksrta/track?evt=clk&biz=RTAKS_NU&oaid=__OAID__&imei=__IMEI2__&idfa=__IDFA2__&mac=__MAC2__&os=__OS__&callback=__CALLBACK__&pid=1711d4f52f5cac73&ip=__IP__&adgroup_id=__AID__&ad_id=__DID__&cid=__CID__");
+            }
+            if (accountId == 9538319L) {
+                creativeQueryWrapper.ne("click_track_url", "https://youku-dsp.youku.com/ksrta/track?evt=clk&biz=RTAKS_NU&oaid=__OAID__&imei=__IMEI2__&idfa=__IDFA2__&mac=__MAC2__&os=__OS__&callback=__CALLBACK__&pid=97559ba2595ac86b&ip=__IP__&adgroup_id=__AID__&ad_id=__DID__&cid=__CID__");
+            }
+            List<KuaiShouCreative> creativeList = creativeService.list(creativeQueryWrapper);
+            for (KuaiShouCreative creative : creativeList) {
+                executorService.submit(new Runnable() {
+                    @Override
+                    public void run() {
+                        try {
+                            JSONObject json = new JSONObject();
+                            json.put("creativeId", creative.getCreativeId());
+
+                            String url = "";
+                            if (accountId == 9643754L) {
+                                url = "https://youku-dsp.youku.com/ksrta/track?evt=clk&biz=RTAKS_NU&oaid=__OAID__&imei=__IMEI2__&idfa=__IDFA2__&mac=__MAC2__&os=__OS__&callback=__CALLBACK__&pid=c91817d982fee2c5&ip=__IP__&adgroup_id=__AID__&ad_id=__DID__&cid=__CID__";
+                            } else if (accountId == 9538300L) {
+                                url = "https://youku-dsp.youku.com/ksrta/track?evt=clk&biz=RTAKS_NU&oaid=__OAID__&imei=__IMEI2__&idfa=__IDFA2__&mac=__MAC2__&os=__OS__&callback=__CALLBACK__&pid=1711d4f52f5cac73&ip=__IP__&adgroup_id=__AID__&ad_id=__DID__&cid=__CID__";
+                            } else if (accountId == 9643726L) {
+                                url = "https://youku-dsp.youku.com/ksrta/track?evt=clk&biz=RTAKS_NU&oaid=__OAID__&imei=__IMEI2__&idfa=__IDFA2__&mac=__MAC2__&os=__OS__&callback=__CALLBACK__&pid=073067367598206b&ip=__IP__&adgroup_id=__AID__&ad_id=__DID__&cid=__CID__";
+                            } else if (accountId == 9538319L) {
+                                url = "https://youku-dsp.youku.com/ksrta/track?evt=clk&biz=RTAKS_NU&oaid=__OAID__&imei=__IMEI2__&idfa=__IDFA2__&mac=__MAC2__&os=__OS__&callback=__CALLBACK__&pid=97559ba2595ac86b&ip=__IP__&adgroup_id=__AID__&ad_id=__DID__&cid=__CID__";
+                            } else if (accountId == 9643738L) {
+                                url = "https://youku-dsp.youku.com/ksrta/track?evt=clk&biz=RTAKS_NU&oaid=__OAID__&imei=__IMEI2__&idfa=__IDFA2__&mac=__MAC2__&os=__OS__&callback=__CALLBACK__&pid=c636c67574553c44&ip=__IP__&adgroup_id=__AID__&ad_id=__DID__&cid=__CID__";
+                            }
+                            if (creative.getCreativeMaterialType() == 1) {
+                                json.put("clickTrackUrl", url);
+                            } else if (creative.getCreativeMaterialType() == 4) {
+                                json.put("impressionUrl", url);
+                                json.put("clickTrackUrl", url);
 
-                                    batchService.updateCreative(json, oauthToken);
-                                    Thread.sleep(500L);
-                                } catch (Exception e) {
-                                    e.printStackTrace();
-                                }
                             }
-                        });
-               //     }
-               // }
+
+                            batchService.updateCreative(json, oauthToken);
+                            Thread.sleep(500L);
+                        } catch (Exception e) {
+                            e.printStackTrace();
+                        }
+                    }
+                });
+                //     }
+                // }
             }
         }