Przeglądaj źródła

修改定时任务

zhouzeyu@c-top.com.cn 4 lat temu
rodzic
commit
06573a824a

+ 67 - 30
job-bytedance/src/main/java/cn/com/ctop/job/bytedance/data/mapper/xml/BytedanceMaterialReportDailyMapper.xml

@@ -281,7 +281,7 @@
         advanced_creative_counsel_click, advanced_creative_form_click,
         advanced_creative_coupon_addition, advanced_creative_form_submit,
         card_show, `share`, `comment`,
-        `like``, follow, home_visited,
+        `like`, follow, home_visited,
         ies_challenge_click, ies_music_click, location_click,
         message_action, click_landing_page, click_shopwindow,
         click_website, click_download, click_call_dy,
@@ -297,50 +297,87 @@
         commute_first_pay_count)
         values
         <foreach collection="list" item="item" separator=",">
-            (#{item.advertiserId,jdbcType=BIGINT}, #{item.materialId,jdbcType=BIGINT},
+            (#{item.advertiserId,jdbcType=BIGINT},
+            #{item.materialId,jdbcType=BIGINT},
             #{item.imageMode,jdbcType=VARCHAR},
-            #{item.inventory,jdbcType=VARCHAR}, #{item.statDatetime,jdbcType=INTEGER}, #{item.cost,jdbcType=DECIMAL},
-            #{item.show,jdbcType=INTEGER}, #{item.avgShowCost,jdbcType=DECIMAL}, #{item.click,jdbcType=INTEGER},
-            #{item.avgClickCost,jdbcType=DECIMAL}, #{item.ctr,jdbcType=DECIMAL}, #{item.convert,jdbcType=INTEGER},
-            #{item.convertCost,jdbcType=DECIMAL}, #{item.convertRate,jdbcType=DECIMAL},
+            #{item.inventory,jdbcType=VARCHAR},
+            #{item.statDatetime,jdbcType=INTEGER},
+            #{item.cost,jdbcType=DECIMAL},
+            #{item.show,jdbcType=INTEGER},
+            #{item.avgShowCost,jdbcType=DECIMAL},
+            #{item.click,jdbcType=INTEGER},
+            #{item.avgClickCost,jdbcType=DECIMAL},
+            #{item.ctr,jdbcType=DECIMAL},
+            #{item.convert,jdbcType=INTEGER},
+            #{item.convertCost,jdbcType=DECIMAL},
+            #{item.convertRate,jdbcType=DECIMAL},
             #{item.deepConvert,jdbcType=INTEGER},
-            #{item.deepConvertCost,jdbcType=DECIMAL}, #{item.deepConvertRate,jdbcType=DECIMAL},
+            #{item.deepConvertCost,jdbcType=DECIMAL},
+            #{item.deepConvertRate,jdbcType=DECIMAL},
             #{item.attributionConvert,jdbcType=INTEGER},
-            #{item.attributionConvertCost,jdbcType=DECIMAL}, #{item.attributionDeepConvert,jdbcType=INTEGER},
-            #{item.attributionDeepConvertCost,jdbcType=DECIMAL}, #{item.downloadStart,jdbcType=INTEGER},
-            #{item.downloadStartCost,jdbcType=DECIMAL}, #{item.downloadStartRate,jdbcType=DECIMAL},
+            #{item.attributionConvertCost,jdbcType=DECIMAL},
+            #{item.attributionDeepConvert,jdbcType=INTEGER},
+            #{item.attributionDeepConvertCost,jdbcType=DECIMAL},
+            #{item.downloadStart,jdbcType=INTEGER},
+            #{item.downloadStartCost,jdbcType=DECIMAL},
+            #{item.downloadStartRate,jdbcType=DECIMAL},
             #{item.downloadFinish,jdbcType=INTEGER},
-            #{item.downloadFinishCost,jdbcType=DECIMAL}, #{item.downloadFinishRate,jdbcType=DECIMAL},
-            #{item.clickInstall,jdbcType=INTEGER}, #{item.installFinish,jdbcType=INTEGER},
+            #{item.downloadFinishCost,jdbcType=DECIMAL},
+            #{item.downloadFinishRate,jdbcType=DECIMAL},
+            #{item.clickInstall,jdbcType=INTEGER},
+            #{item.installFinish,jdbcType=INTEGER},
             #{item.installFinishCost,jdbcType=DECIMAL},
-            #{item.installFinishRate,jdbcType=DECIMAL}, #{item.active,jdbcType=INTEGER},
+            #{item.installFinishRate,jdbcType=DECIMAL},
+            #{item.active,jdbcType=INTEGER},
             #{item.activeCost,jdbcType=DECIMAL},
-            #{item.activeRate,jdbcType=DECIMAL}, #{item.register,jdbcType=INTEGER},
+            #{item.activeRate,jdbcType=DECIMAL},
+            #{item.register,jdbcType=INTEGER},
             #{item.activeRegisterCost,jdbcType=DECIMAL},
-            #{item.activeRegisterRate,jdbcType=DECIMAL}, #{item.activePayAmount,jdbcType=DECIMAL},
+            #{item.activeRegisterRate,jdbcType=DECIMAL},
+            #{item.activePayAmount,jdbcType=DECIMAL},
             #{item.nextDayOpen,jdbcType=INTEGER},
-            #{item.nextDayOpenCost,jdbcType=DECIMAL}, #{item.nextDayOpenRate,jdbcType=DECIMAL},
+            #{item.nextDayOpenCost,jdbcType=DECIMAL},
+            #{item.nextDayOpenRate,jdbcType=DECIMAL},
             #{item.attributionNextDayOpenCnt,jdbcType=INTEGER},
-            #{item.attributionNextDayOpenCost,jdbcType=DECIMAL}, #{item.attributionNextDayOpenRate,jdbcType=DECIMAL},
-            #{item.gameAddiction,jdbcType=INTEGER}, #{item.gameAddictionCost,jdbcType=DECIMAL},
+            #{item.attributionNextDayOpenCost,jdbcType=DECIMAL},
+            #{item.attributionNextDayOpenRate,jdbcType=DECIMAL},
+            #{item.gameAddiction,jdbcType=INTEGER},
+            #{item.gameAddictionCost,jdbcType=DECIMAL},
             #{item.gameAddictionRate,jdbcType=DECIMAL},
-            #{item.payCount,jdbcType=INTEGER}, #{item.activePayCost,jdbcType=DECIMAL},
+            #{item.payCount,jdbcType=INTEGER},
+            #{item.activePayCost,jdbcType=DECIMAL},
             #{item.activePayRate,jdbcType=DECIMAL},
-            #{item.loanCompletion,jdbcType=INTEGER}, #{item.loanCompletionCost,jdbcType=DECIMAL},
+            #{item.loanCompletion,jdbcType=INTEGER},
+            #{item.loanCompletionCost,jdbcType=DECIMAL},
             #{item.loanCompletionRate,jdbcType=DECIMAL},
-            #{item.preLoanCredit,jdbcType=INTEGER}, #{item.preLoanCreditCost,jdbcType=DECIMAL},
+            #{item.preLoanCredit,jdbcType=INTEGER},
+            #{item.preLoanCreditCost,jdbcType=DECIMAL},
             #{item.loanCredit,jdbcType=INTEGER},
-            #{item.loanCreditCost,jdbcType=DECIMAL}, #{item.loanCreditRate,jdbcType=DECIMAL},
+            #{item.loanCreditCost,jdbcType=DECIMAL},
+            #{item.loanCreditRate,jdbcType=DECIMAL},
             #{item.inAppUv,jdbcType=INTEGER},
-            #{item.inAppDetailUv,jdbcType=INTEGER}, #{item.inAppCart,jdbcType=INTEGER},
+            #{item.inAppDetailUv,jdbcType=INTEGER},
+            #{item.inAppCart,jdbcType=INTEGER},
             #{item.inAppPay,jdbcType=INTEGER},
-            #{item.inAppOrder,jdbcType=INTEGER}, #{item.attributionGamePay7dCount,jdbcType=INTEGER},
-            #{item.attributionGamePay7dCost,jdbcType=DECIMAL}, #{item.attributionActivePay7dPerCount,jdbcType=INTEGER},
-            #{item.gamePayCost,jdbcType=INTEGER}, #{item.gamePayCount,jdbcType=INTEGER}, #{item.phone,jdbcType=INTEGER},
-            #{item.form,jdbcType=INTEGER}, #{item.mapSearch,jdbcType=INTEGER}, #{item.button,jdbcType=INTEGER},
-            #{item.view,jdbcType=INTEGER}, #{item.download,jdbcType=INTEGER}, #{item.qq,jdbcType=INTEGER},
-            #{item.lottery,jdbcType=INTEGER}, #{item.vote,jdbcType=INTEGER}, #{item.message,jdbcType=INTEGER},
-            #{item.redirect,jdbcType=INTEGER}, #{item.shopping,jdbcType=INTEGER}, #{item.consult,jdbcType=INTEGER},
+            #{item.inAppOrder,jdbcType=INTEGER},
+            #{item.attributionGamePay7dCount,jdbcType=INTEGER},
+            #{item.attributionGamePay7dCost,jdbcType=DECIMAL},
+            #{item.attributionActivePay7dPerCount,jdbcType=INTEGER},
+            #{item.gamePayCost,jdbcType=INTEGER},
+            #{item.gamePayCount,jdbcType=INTEGER},
+            #{item.phone,jdbcType=INTEGER},
+            #{item.form,jdbcType=INTEGER},
+            #{item.mapSearch,jdbcType=INTEGER},
+            #{item.button,jdbcType=INTEGER},
+            #{item.view,jdbcType=INTEGER},
+            #{item.download,jdbcType=INTEGER},
+            #{item.qq,jdbcType=INTEGER},
+            #{item.lottery,jdbcType=INTEGER},
+            #{item.vote,jdbcType=INTEGER},
+            #{item.message,jdbcType=INTEGER},
+            #{item.redirect,jdbcType=INTEGER},
+            #{item.shopping,jdbcType=INTEGER},
+            #{item.consult,jdbcType=INTEGER},
             #{item.wechat,jdbcType=INTEGER}, #{item.phoneConfirm,jdbcType=INTEGER},
             #{item.phoneConnect,jdbcType=INTEGER},
             #{item.consultEffective,jdbcType=INTEGER}, #{item.coupon,jdbcType=INTEGER},

+ 8 - 3
job-bytedance/src/main/java/cn/com/ctop/job/bytedance/data/service/impl/BytedanceMaterialReportDailyServiceImpl.java

@@ -38,7 +38,7 @@ public class BytedanceMaterialReportDailyServiceImpl implements IBytedanceMateri
         String url = bytedanceApiUrl + BytedanceConstant.BYTEDANCE_V2_REPORT_INTEGRATED_GET;
         JSONObject param = new JSONObject();
         param.put("advertiser_id", oauthToken.getAccountId());
-        param.put("start_date", yesterda1);
+        param.put("start_date", yesterda);
         param.put("end_date", yesterda1);
         param.put("page", page);
         param.put("page_size", pageSize);
@@ -66,7 +66,7 @@ public class BytedanceMaterialReportDailyServiceImpl implements IBytedanceMateri
                 report.setMaterialId((Long) dimensions.get("material_id"));
                 report.setImageMode((String) dimensions.get("image_mode"));
                 report.setInventory((String) dimensions.get("inventory"));
-                report.setStatDatetime(yesterda.replace("-", ""));
+                report.setStatDatetime(dimensions.getString("stat_datetime")==null?null:dimensions.getString("stat_datetime").substring(0,10).replace("-",""));
                 report.setSubmitCertificationCount(dataObject.get("submit_certification_count") == null ? null : Integer.parseInt((String) dataObject.get("submit_certification_count")));
                 report.setApprovalCount(dataObject.get("approval_count") == null ? null : Integer.parseInt((String) dataObject.get("approval_count")));
                 report.setFirstOrderCount(dataObject.get("first_order_count") == null ? null : Integer.parseInt((String) dataObject.get("first_order_count")));
@@ -77,7 +77,12 @@ public class BytedanceMaterialReportDailyServiceImpl implements IBytedanceMateri
                 log.info("错误:{}", e.toString());
             }
         }
-        bytedanceMaterialReportDailyMapper.insert(list);
+        try {
+            bytedanceMaterialReportDailyMapper.insert(list);
+        }catch (Exception e){
+            log.info(e.toString());
+        }
+
         page++;
         int totalPage = resultObject.getJSONObject("data").getJSONObject("page_info").getInteger("total_page");
         if (page <= totalPage) {

+ 2 - 3
job-bytedance/src/main/java/cn/com/ctop/job/bytedance/handler/BytedanceMaterialReportLoadJob.java

@@ -58,9 +58,8 @@ public class BytedanceMaterialReportLoadJob {
                 new Runnable() {
                     @Override
                     public void run() {
-                        materialReportDailyService.bytedanceDailyMaterialReportJob(oauthToken, yesterda,yesterda,1, 1000);
-                        materialReportDailyService.bytedanceDailyMaterialReportJob(oauthToken, yesterda1,yesterda1,1, 1000);
-
+                        materialReportDailyService.bytedanceDailyMaterialReportJob(oauthToken, yesterda, yesterda, 1, 1000);
+                        materialReportDailyService.bytedanceDailyMaterialReportJob(oauthToken, yesterda1, yesterda1, 1, 1000);
                     }
                 });