Pārlūkot izejas kodu

修改监测链接

yumeng 4 gadi atpakaļ
vecāks
revīzija
3ad41701e7

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

@@ -80,49 +80,33 @@ public class TestController {
     @Autowired
     private IBatchService batchService;
     static ExecutorService executorService = Executors.newFixedThreadPool(40);
-    static ExecutorService videoService = Executors.newFixedThreadPool(5);
+    static ExecutorService videoService = Executors.newFixedThreadPool(3);
     static ExecutorService suzhaoService = Executors.newFixedThreadPool(5);
 
 
     @GetMapping(value = "/campaignList")
     public void campaignList() {
         List<Long> list = new ArrayList();
-        /*list.add(6409841L);
-        list.add(6433033L);
-        list.add(6433053L);
-        list.add(6789970L);
-        list.add(6791568L);
-        list.add(7025551L);
-        list.add(7025567L);
-        list.add(7087866L);
-        list.add(7087890L);
-        list.add(7421646L);
-        list.add(7421660L);
-        list.add(7421671L);
-        list.add(7607727L);
-        list.add(7607803L);
-        list.add(7607818L);
-        list.add(7607830L);
-        list.add(7607849L);
-        list.add(7783907L);
-        list.add(7882964L);
-        list.add(7882996L);
-        list.add(7883032L);
-        list.add(7922257L);*/
-        list.add(9538319L);
-        list.add(9643738L);
-        list.add(9664230L);
-        list.add(9643754L);
-        list.add(9538300L);
-        list.add(9643726L);
-        //  list.add(9556344L);
-
-
+        list.add(9767343L);
+        list.add(9767340L);
         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);
+            videoService.submit(new Runnable() {
+                @Override
+                public void run() {
+                    try {
+                      /*   kuaishouInterfaceService.getCampaignList(oauthToken, null, null);
+                       kuaishouInterfaceService.getGroupList(oauthToken, null, null);*/
+                        kuaishouInterfaceService.getCreativeList(oauthToken, null, null);
+                        Thread.sleep(1500);
+                    } catch (Exception e) {
+                        e.printStackTrace();
+                    }
+                }
+            });
+
         }
 
     }
@@ -168,6 +152,26 @@ public class TestController {
     public void updateUnit() throws Exception {
         List<Long> list = new ArrayList();
         list.add(9556344L);
+        list.add(9743738L);
+        list.add(9743727L);
+        list.add(9812671L);
+        list.add(9838554L);
+        list.add(9743746L);
+        list.add(9767055L);
+        list.add(9556274L);
+        list.add(9767096L);
+        list.add(9792538L);
+        list.add(9766952L);
+        list.add(9677440L);
+        list.add(9677334L);
+        list.add(9556465L);
+        list.add(9677236L);
+        list.add(9556227L);
+        list.add(9556188L);
+        list.add(9556431L);
+        list.add(9677408L);
+        list.add(9677284L);
+
         for (int i = 0; i < list.size(); i++) {
             Long accountId = list.get(i);
             CtopOauthToken oauthToken = oauthTokenService.getTokenByAccountId(accountId);
@@ -175,7 +179,7 @@ public class TestController {
             groupQueryWrapper.eq("account_id", accountId);
             //      groupQueryWrapper.ne("schedule_time","000000111111111111111111000000111111111111111111000000111111111111111111000000111111111111111111000000111111111111111111000000111111111111111111000000111111111111111111");
             //     groupQueryWrapper.eq("use_app_market", 1);
-        //    groupQueryWrapper.gt("cpa_bid", 20000);
+            //    groupQueryWrapper.gt("cpa_bid", 19000);
 
 
             List<KuaiShouGroup> list1 = groupService.list(groupQueryWrapper);
@@ -188,7 +192,6 @@ public class TestController {
                 batchService.updateUnit(json, oauthToken);
             }*/
 
-
             for (KuaiShouGroup group : list1) {
                 executorService.submit(new Runnable() {
                     @Override
@@ -196,7 +199,7 @@ public class TestController {
                         try {
                             JSONObject json = new JSONObject();
                             json.put("unitId", group.getUnitId());
-                            json.put("cpaBid", 63 * 1000);
+                            json.put("cpaBid", 18 * 1000);
                             //     json.put("gender", "2");
                             batchService.updateUnit(json, oauthToken);
                             Thread.sleep(1500);
@@ -219,94 +222,45 @@ public class TestController {
     @GetMapping(value = "/updateCreative")
     public void updateCreative() {
         List<Long> list = new ArrayList();
-        list.add(9538319L);
-        list.add(9643738L);
-        list.add(9664230L);
-        list.add(9643754L);
-        list.add(9538300L);
-        list.add(9643726L);
+        list.add(9767343L);
+        list.add(9767340L);
 
         for (int i = 0; i < list.size(); i++) {
             Long accountId = list.get(i);
             CtopOauthToken oauthToken = oauthTokenService.getTokenByAccountId(accountId);
 
-            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 == 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__");
-                    }
-                    if (accountId == 9643738L) {
-                        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=c636c67574553c44&ip=__IP__&adgroup_id=__AID__&ad_id=__DID__&cid=__CID__");
-                    }
-                    if (accountId == 9664230L) {
-                        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=46eddff73bc3e02c&ip=__IP__&adgroup_id=__AID__&ad_id=__DID__&cid=__CID__");
-                    }
-                    if (accountId == 9643754L) {
-                        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=c91817d982fee2c5&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 == 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__");
-                    }
-                    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());
+            QueryWrapper<KuaiShouCreative> creativeQueryWrapper = new QueryWrapper<>();
+            creativeQueryWrapper.eq("account_id", accountId);
 
-                                    String url = "";
-                                    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__";
-                                    }
-                                    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 (accountId == 9664230L) {
-                                        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=46eddff73bc3e02c&ip=__IP__&adgroup_id=__AID__&ad_id=__DID__&cid=__CID__";
-                                    }
-                                    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__";
-                                    }
 
-                                    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__";
-                                    }
-                                    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__";
-                                    }
-                                    if (creative.getCreativeMaterialType() == 1) {
-                                        json.put("clickTrackUrl", url);
-                                    } else if (creative.getCreativeMaterialType() == 4) {
-                                        json.put("impressionUrl", url);
-                                        json.put("clickTrackUrl", url);
+            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 = "https://tracking.lingdongxinghe.qianhuanhulian.com/api/v7/kuaishou/preload/com.flex.phone.cleaner.app?adid=__DID__&campaign_id=__AID__&cid=__CID__&imei=__IMEI2__&mac=__MAC2__&oaid=__OAID__&androidid=__ANDROIDID2__&csite=__CSITE__&timestamp=__TS__&callback=__CALLBACK__&ip=__IP__&account_id=__ACCOUNTID__&ua=__UA__";
+
+                            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();
+                        }
                     }
-                }
+                });
             }
         }
-
-
     }
 
     @GetMapping(value = "/getProgramCreative")

+ 1 - 1
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/service/impl/KuaiShouUpdateServiceImpl.java

@@ -596,7 +596,7 @@ public class KuaiShouUpdateServiceImpl implements IKuaiShouUpdateService {
                     log.info("修改成功,accountId:{},unitId:{}", unitJson.getLong("advertiser_id"), unitJson.getLong("unit_id"));
 
                 } else {
-                    log.info("修改失败,accountId:{},unitId:{}", unitJson.getLong("advertiser_id"), unitJson.getLong("unit_id"));
+                    log.info("修改失败,accountId:{},unitId:{},入参:{}", unitJson.getLong("advertiser_id"), unitJson.getLong("unit_id"), unitJson);
                     log.info("失败原因:{}", resultJson);
 
                     returnJson.put("code", -1);

+ 1 - 1
module-kuaishou/src/main/java/cn/com/ctop/kuaishou/modules/batch/service/impl/KuaishouInterfaceServiceImpl.java

@@ -1409,7 +1409,7 @@ public class KuaishouInterfaceServiceImpl implements IKuaishouInterfaceService {
                 param.put("start_date", DateUtils.formatDate(startDate));
                 param.put("end_date", DateUtils.formatDate(endDate));
             }
-            param.put("page_size", 200);
+            param.put("page_size", 500);
             param.put("page", page);
 
             String result = HttpUtils.kuaiShouhttpPostRequest(url, param.toJSONString(), headers);