Browse Source

计划任务解决BUG

zhouzeyu@c-top.com.cn 4 years ago
parent
commit
2f0ce44bc0

+ 48 - 48
job-bytedance/src/main/java/cn/com/ctop/job/bytedance/data/service/impl/ByteDanceAdvertiserDataServiceImpl.java

@@ -4,7 +4,9 @@ import cn.com.ctop.job.bytedance.data.constant.BytedanceConstant;
 import cn.com.ctop.job.bytedance.data.constant.CtopAdConstant;
 import cn.com.ctop.job.bytedance.data.entity.*;
 import cn.com.ctop.job.bytedance.data.mapper.*;
-import cn.com.ctop.job.bytedance.data.service.*;
+import cn.com.ctop.job.bytedance.data.service.IByteDanceAdvertiserDataService;
+import cn.com.ctop.job.bytedance.data.service.IBytedanceAgentReportDailyService;
+import cn.com.ctop.job.bytedance.data.service.IBytedanceAgentReportHourlyService;
 import cn.com.ctop.job.bytedance.data.utils.DateUtils;
 import cn.com.ctop.job.bytedance.data.utils.HttpUtils;
 import com.alibaba.fastjson.JSON;
@@ -21,7 +23,6 @@ import org.springframework.context.annotation.Primary;
 import org.springframework.stereotype.Service;
 
 import javax.annotation.Resource;
-import java.math.BigDecimal;
 import java.text.SimpleDateFormat;
 import java.util.*;
 
@@ -38,7 +39,6 @@ public class ByteDanceAdvertiserDataServiceImpl implements IByteDanceAdvertiserD
 
     private String urlPath = "http://192.168.0.202:8765/webhook/bytedance_account_report";
 
-  
 
     @Autowired
     private IBytedanceAgentReportDailyService agentDailyService;
@@ -114,53 +114,53 @@ public class ByteDanceAdvertiserDataServiceImpl implements IByteDanceAdvertiserD
             for (int i = 0; i < data.size(); i++) {
                 JSONObject dataObject = data.getJSONObject(i);
                 BytedanceAdGet advertisePlan = new BytedanceAdGet();
-                advertisePlan.setId((Long) dataObject.get("id"));
-                advertisePlan.setAccountId((Long) dataObject.get("account_id"));
-                advertisePlan.setName((String) dataObject.get("name"));
-                advertisePlan.setCampaignId((Long) dataObject.get("campaign_id"));
-                advertisePlan.setOperation(dataObject.get("operation") == null ? null : (String) dataObject.get("operation"));
-                advertisePlan.setPlanModifyTime(dataObject.get("plan_modify_time") == null ? null : (String) dataObject.get("plan_modify_time"));
-                advertisePlan.setDeliveryRange(dataObject.get("delivery_range") == null ? null : (String) dataObject.get("delivery_range"));
-                advertisePlan.setUnionVideoType(dataObject.get("union_video_type") == null ? null : (String) dataObject.get("union_video_type"));
-                advertisePlan.setDeepBidType(dataObject.get("deep_bid_type") == null ? null : (String) dataObject.get("deep_bid_type"));
-                advertisePlan.setDeepCpaBid(dataObject.get("deep_cpa_bid") == null ? null : (BigDecimal) dataObject.get("deep_cpa_bid"));
-                advertisePlan.setAdModifyTime(dataObject.get("ad_modify_time") == null ? null : (String) dataObject.get("ad_modify_time"));
-                advertisePlan.setAdCreateTime(dataObject.get("ad_create_time") == null ? null : (String) dataObject.get("ad_create_time"));
-                advertisePlan.setBudgetMode(dataObject.get("budget_mode") == null ? null : (String) dataObject.get("budget_mode"));
-                advertisePlan.setBudget(dataObject.get("budget") == null ? null : (BigDecimal) dataObject.get("budget"));
-                advertisePlan.setToutiaoStatus(dataObject.get("toutiao_status") == null ? null : (String) dataObject.get("toutiao_status"));
-                advertisePlan.setOptStatus(dataObject.get("opt_status") == null ? null : (String) dataObject.get("opt_status"));
-                advertisePlan.setStartTime(dataObject.get("start_time") == null ? null : (String) dataObject.get("start_time"));
-                advertisePlan.setEndTime(dataObject.get("end_time") == null ? null : (String) dataObject.get("end_time"));
-                advertisePlan.setBid(dataObject.get("bid") == null ? null : (BigDecimal) dataObject.get("bid"));
-                advertisePlan.setPricing(dataObject.get("pricing") == null ? null : (String) dataObject.get("pricing"));
-                advertisePlan.setScheduleType(dataObject.get("schedule_type") == null ? null : (String) dataObject.get("schedule_type"));
-                advertisePlan.setScheduleTime(dataObject.get("schedule_time") == null ? null : (String) dataObject.get("schedule_time"));
-                advertisePlan.setFlowControlMode(dataObject.get("flow_control_mode") == null ? null : (String) dataObject.get("flow_control_mode"));
-                advertisePlan.setOpenUrl(dataObject.get("open_url") == null ? null : (String) dataObject.get("open_url"));
-                advertisePlan.setDownloadType(dataObject.get("download_type") == null ? null : (String) dataObject.get("download_type"));
-                advertisePlan.setExternalUrl(dataObject.get("external_url") == null ? null : (String) dataObject.get("external_url"));
-                advertisePlan.setToutiaoPackage(dataObject.get("toutiao_package") == null ? null : (String) dataObject.get("toutiao_package"));
-                advertisePlan.setAppType(dataObject.get("app_type") == null ? null : (String) dataObject.get("app_type"));
-                advertisePlan.setAuditRejectReason(dataObject.get("audit_reject_reason") == null ? null : (String) dataObject.get("audit_reject_reason"));
-                advertisePlan.setCpaBid(dataObject.get("cpa_bid") == null ? null : (BigDecimal) dataObject.get("cpa_bid"));
-                advertisePlan.setCpaSkipFirstPhrase(dataObject.get("cpa_skip_first_phrase") == null ? null : (Integer) dataObject.get("cpa_skip_first_phrase"));
-                advertisePlan.setConvertId(dataObject.get("convert_id") == null ? null : (Long) dataObject.get("convert_id"));
-                advertisePlan.setHideIfConverted(dataObject.get("hide_if_converted") == null ? null : (String) dataObject.get("hide_if_converted"));
-                advertisePlan.setHideIfExists(dataObject.get("hide_if_exists") == null ? null : (Integer) dataObject.get("hide_if_exists"));
+                advertisePlan.setId(dataObject.getLong("id"));
+                advertisePlan.setAccountId(token.getAccountId());
+                advertisePlan.setName(dataObject.getString("name"));
+                advertisePlan.setCampaignId(dataObject.getLong("campaign_id"));
+                advertisePlan.setOperation(dataObject.get("operation") == null ? null : dataObject.getString("operation"));
+                advertisePlan.setPlanModifyTime(dataObject.get("plan_modify_time") == null ? null : dataObject.getString("plan_modify_time"));
+                advertisePlan.setDeliveryRange(dataObject.get("delivery_range") == null ? null : dataObject.getString("delivery_range"));
+                advertisePlan.setUnionVideoType(dataObject.get("union_video_type") == null ? null : dataObject.getString("union_video_type"));
+                advertisePlan.setDeepBidType(dataObject.get("deep_bid_type") == null ? null : dataObject.getString("deep_bid_type"));
+                advertisePlan.setDeepCpaBid(dataObject.get("deep_cpa_bid") == null ? null : dataObject.getBigDecimal("deep_cpa_bid"));
+                advertisePlan.setAdModifyTime(dataObject.get("ad_modify_time") == null ? null : dataObject.getString("ad_modify_time"));
+                advertisePlan.setAdCreateTime(dataObject.get("ad_create_time") == null ? null : dataObject.getString("ad_create_time"));
+                advertisePlan.setBudgetMode(dataObject.get("budget_mode") == null ? null : dataObject.getString("budget_mode"));
+                advertisePlan.setBudget(dataObject.get("budget") == null ? null : dataObject.getBigDecimal("budget"));
+                advertisePlan.setToutiaoStatus(dataObject.get("toutiao_status") == null ? null : dataObject.getString("toutiao_status"));
+                advertisePlan.setOptStatus(dataObject.get("opt_status") == null ? null : dataObject.getString("opt_status"));
+                advertisePlan.setStartTime(dataObject.get("start_time") == null ? null : dataObject.getString("start_time"));
+                advertisePlan.setEndTime(dataObject.get("end_time") == null ? null : dataObject.getString("end_time"));
+                advertisePlan.setBid(dataObject.get("bid") == null ? null : dataObject.getBigDecimal("bid"));
+                advertisePlan.setPricing(dataObject.get("pricing") == null ? null : dataObject.getString("pricing"));
+                advertisePlan.setScheduleType(dataObject.get("schedule_type") == null ? null : dataObject.getString("schedule_type"));
+                advertisePlan.setScheduleTime(dataObject.get("schedule_time") == null ? null : dataObject.getString("schedule_time"));
+                advertisePlan.setFlowControlMode(dataObject.get("flow_control_mode") == null ? null : dataObject.getString("flow_control_mode"));
+                advertisePlan.setOpenUrl(dataObject.get("open_url") == null ? null : dataObject.getString("open_url"));
+                advertisePlan.setDownloadType(dataObject.get("download_type") == null ? null : dataObject.getString("download_type"));
+                advertisePlan.setExternalUrl(dataObject.get("external_url") == null ? null : dataObject.getString("external_url"));
+                advertisePlan.setToutiaoPackage(dataObject.get("toutiao_package") == null ? null : dataObject.getString("toutiao_package"));
+                advertisePlan.setAppType(dataObject.get("app_type") == null ? null : dataObject.getString("app_type"));
+                advertisePlan.setAuditRejectReason(dataObject.get("audit_reject_reason") == null ? null : dataObject.getString("audit_reject_reason"));
+                advertisePlan.setCpaBid(dataObject.get("cpa_bid") == null ? null : dataObject.getBigDecimal("cpa_bid"));
+                advertisePlan.setCpaSkipFirstPhrase(dataObject.get("cpa_skip_first_phrase") == null ? null : dataObject.getInteger("cpa_skip_first_phrase"));
+                advertisePlan.setConvertId(dataObject.get("convert_id") == null ? null : dataObject.getLong("convert_id"));
+                advertisePlan.setHideIfConverted(dataObject.get("hide_if_converted") == null ? null : dataObject.getString("hide_if_converted"));
+                advertisePlan.setHideIfExists(dataObject.get("hide_if_exists") == null ? null : dataObject.getInteger("hide_if_exists"));
                 advertisePlan.setAudience(dataObject.get("audience") == null ? null : ((JSONObject) dataObject.get("audience")).toJSONString());
-                advertisePlan.setModifyTime(dataObject.get("modify_time") == null ? null : (String) dataObject.get("modify_time"));
-                advertisePlan.setGender(dataObject.get("gender") == null ? null : (String) dataObject.get("gender"));
-                advertisePlan.setPlatform(dataObject.get("platform") == null ? null : (String) dataObject.get("platform"));
-                advertisePlan.setCreateTime(dataObject.get("create_time") == null ? null : (Date) dataObject.get("create_time"));
-                advertisePlan.setUpdateTime(dataObject.get("update_time") == null ? null : (Date) dataObject.get("update_time"));
-                advertisePlan.setPlanStatus(dataObject.get("plan_status") == null ? null : (Integer) dataObject.get("plan_status"));
-                advertisePlan.setConvertedTimeDuration(dataObject.get("converted_time_duration") == null ? null : (String) dataObject.get("converted_time_duration"));
-                advertisePlan.setDownloadUrl(dataObject.get("download_url") == null ? null : (String) dataObject.get("download_url"));
-                advertisePlan.setLubanRoiGoal(dataObject.get("luban_roi_goal") == null ? null : (BigDecimal) dataObject.get("luban_roi_goal"));
-                advertisePlan.setRoiGoal(dataObject.get("roi_goal") == null ? null : (BigDecimal) dataObject.get("roi_goal"));
+                advertisePlan.setModifyTime(dataObject.get("modify_time") == null ? null : dataObject.getString("modify_time"));
+                advertisePlan.setGender(dataObject.get("gender") == null ? null : dataObject.getString("gender"));
+                advertisePlan.setPlatform(dataObject.get("platform") == null ? null : dataObject.getString("platform"));
+                advertisePlan.setCreateTime(dataObject.get("create_time") == null ? null : dataObject.getDate("create_time"));
+                advertisePlan.setUpdateTime(dataObject.get("update_time") == null ? null : dataObject.getDate("update_time"));
+                advertisePlan.setPlanStatus(dataObject.get("plan_status") == null ? null : dataObject.getInteger("plan_status"));
+                advertisePlan.setConvertedTimeDuration(dataObject.get("converted_time_duration") == null ? null : dataObject.getString("converted_time_duration"));
+                advertisePlan.setDownloadUrl(dataObject.get("download_url") == null ? null : dataObject.getString("download_url"));
+                advertisePlan.setLubanRoiGoal(dataObject.get("luban_roi_goal") == null ? null : dataObject.getBigDecimal("luban_roi_goal"));
+                advertisePlan.setRoiGoal(dataObject.get("roi_goal") == null ? null : dataObject.getBigDecimal("roi_goal"));
                 advertisePlan.setInventoryType(dataObject.get("inventory_type") == null ? null : ((JSONArray) dataObject.get("inventory_type")).toString());
-                advertisePlan.setAudiencePackageId(dataObject.get("audience_package_id") == null ? null : (Long) dataObject.get("audience_package_id"));
+                advertisePlan.setAudiencePackageId(dataObject.get("audience_package_id") == null ? null : dataObject.getLong("audience_package_id"));
                 list.add(advertisePlan);
             }
             bytedanceAdGetMapper.insert(list);