数据中心--亚马逊费用抓取获取任务属性值

data-base/base-sync-amazon-ad/src/main/java/com/bailuntec/job/AmazonAdDownloadReportJob.java

@@ -48,15 +48,16 @@ public class AmazonAdDownloadReportJob implements SimpleJob {
         int pageSize = totalPage % shardingContext.getShardingTotalCount() == 0 ? totalPage / shardingContext.getShardingTotalCount() : totalPage / shardingContext.getShardingTotalCount() + 1;
         if (totalPage > 0) {
             List<JobAmazonAdLog> jobAmazonAdLogList = findJobAmazonAdLogList(shardingContext, pageSize);
+            String shardParam = shardingContext.getJobParameter();
             if (jobAmazonAdLogList != null && !jobAmazonAdLogList.isEmpty()) {
                 for (JobAmazonAdLog jobAmazonAdLog : jobAmazonAdLogList) {
-                    downloadReport(jobAmazonAdLog);
+                    downloadReport(jobAmazonAdLog, shardParam);
                 }
             }
         }
     }
 
-    private void handleReport(JobAmazonAdLog jobAmazonAdLog, AmazonAdAuth amazonAdAuth) {
+    private void handleReport(JobAmazonAdLog jobAmazonAdLog, AmazonAdAuth amazonAdAuth, String shardParam) {
         Response response = null;
         GZIPInputStream gzin = null;
         Request request = new Request.Builder()
@@ -92,9 +93,9 @@ public class AmazonAdDownloadReportJob implements SimpleJob {
                                 dcBaseFinanceAmazonAdProduct.setExchangeRateUsd(CallBailunSystem.getExchangeRate(dcBaseFinanceAmazonAdProduct.getCurrency(), CurrencyType.USD.value(), jobAmazonAdLog.getReportDate().atStartOfDay()));
                                 dcBaseFinanceAmazonAdProduct.setBjModifyTime(LocalDateTime.now());
                                 DcBaseFinanceAmazonAdProductExample example = DcBaseFinanceAmazonAdProductExample.newAndCreateCriteria().andCompanyIdEqualTo(dcBaseFinanceAmazonAdProduct.getCompanyId()).andAccountIdEqualTo(dcBaseFinanceAmazonAdProduct.getAccountId()).andCampaignIdEqualTo(dcBaseFinanceAmazonAdProduct.getCampaignId()).andAdGroupIdEqualTo(dcBaseFinanceAmazonAdProduct.getAdGroupId()).andSkuEqualTo(dcBaseFinanceAmazonAdProduct.getSku()).andReportDateEqualTo(dcBaseFinanceAmazonAdProduct.getReportDate()).example();
-                                int update = mapper.updateByExampleSelective(dcBaseFinanceAmazonAdProduct, example);
+                                int update = mapper.updateByExampleSelective(dcBaseFinanceAmazonAdProduct, example, shardParam);
                                 if (update == 0) {
-                                    mapper.insertSelective(dcBaseFinanceAmazonAdProduct);
+                                    mapper.insertSelective(dcBaseFinanceAmazonAdProduct, shardParam);
                                 }
                             }
                         }
@@ -126,10 +127,10 @@ public class AmazonAdDownloadReportJob implements SimpleJob {
         }
     }
 
-    private void downloadReport(JobAmazonAdLog jobAmazonAdLog) {
+    private void downloadReport(JobAmazonAdLog jobAmazonAdLog, String shardParam) {
         DcBaseCompanyAccount dcBaseCompanyAccount = getToken(jobAmazonAdLog);
         AmazonAdAuth amazonAdAuth = JSON.parseObject(dcBaseCompanyAccount.getAmazonAdAuthJson(), AmazonAdAuth.class);
-        handleReport(jobAmazonAdLog, amazonAdAuth);
+        handleReport(jobAmazonAdLog, amazonAdAuth, shardParam);
     }
 
     private DcBaseCompanyAccount getToken(JobAmazonAdLog jobAmazonAdLog) {

data-common/src/main/java/com/bailuntec/mapper/DcBaseFinanceAmazonAdProductMapper.java

@@ -45,7 +45,7 @@ public interface DcBaseFinanceAmazonAdProductMapper {
      *
      * @mbg.generated
      */
-    int insertSelective(DcBaseFinanceAmazonAdProduct record);
+    int insertSelective(@Param("record") DcBaseFinanceAmazonAdProduct record, @Param("shardParam") String shardParam);
 
     /**
      * This method was generated by MyBatis Generator.
@@ -78,7 +78,7 @@ public interface DcBaseFinanceAmazonAdProductMapper {
      *
      * @mbg.generated
      */
-    int updateByExampleSelective(@Param("record") DcBaseFinanceAmazonAdProduct record, @Param("example") DcBaseFinanceAmazonAdProductExample example);
+    int updateByExampleSelective(@Param("record") DcBaseFinanceAmazonAdProduct record, @Param("example") DcBaseFinanceAmazonAdProductExample example, @Param("shardParam") String shardParam);
 
     /**
      * This method was generated by MyBatis Generator.