亚马逊广告

datacenter-base/base-sync-amazon-ad/src/main/java/com/bailuntec/job/AmazonAdJob.java

@@ -34,7 +34,7 @@ public class AmazonAdJob {
      * 每天下午1点生成昨天的亚马逊广告报告
      * </p>
      */
-    @Scheduled(cron = "0 0 13 * * ?")
+    @Scheduled(cron = "0 0 12 * * ?")
     public void generateAmazonAdReport() {
         log.info("每天下午1点生成昨天的亚马逊广告报告 任务开始");
         amazonJobService.generateAmazonAdReport();

datacenter-base/base-sync-amazon-ad/src/main/java/com/bailuntec/job/service/AmazonJobService.java

@@ -76,6 +76,7 @@ public class AmazonJobService {
         //需要生成的帐号列表
         List<DcBaseCompanyAccount> dcBaseCompanyAccountList = dcBaseCompanyAccountMapper.selectList(new LambdaQueryWrapper<DcBaseCompanyAccount>()
                 .eq(DcBaseCompanyAccount::getPlatformId, DcBaseCompanyAccount.BLT_PLATFORM_ID)
+                .eq(DcBaseCompanyAccount::getStatus, true)
                 .ne(DcBaseCompanyAccount::getAmazonAdAuthJson, ""))
                 .stream()
                 .filter(dcBaseCompanyAccount -> StringUtils.isNotEmpty(dcBaseCompanyAccount.getAmazonAdAuthJson().trim()))

datacenter-base/base-sync-company/src/main/java/com/bailuntec/job/service/CompanyService.java

@@ -39,7 +39,7 @@ public class CompanyService {
 
     private static final String baseSyncCompany = "base-sync-company";
 
-    @Transactional
+    @Transactional(rollbackFor = Exception.class)
     public void syncCompanyAccount() {
 
         DcJobConfig dcJobConfig = dcJobConfigMapper.selectByName(baseSyncCompany);

datacenter-base/base-sync-sku/src/main/java/com/bailuntec/job/service/SkuService.java

@@ -83,6 +83,7 @@ public class SkuService {
                                 //todo 缓存
                                 String shortSiteEn = dcBaseSkuMappingOnlineMapper.selectShortSiteEn(dcBaseSkuMappingOnline.getSite());
                                 dcBaseSkuMappingOnline.setSite(shortSiteEn);
+                                dcBaseSkuMappingOnline.setPlatformStr(DcBaseSkuMappingOnline.platformMap.get(dcBaseSkuMappingOnline.getPlatform()));
                                 dcBaseSkuMappingOnline.setGmtModified(LocalDateTime.now());
 
                                 return dcBaseSkuMappingOnline;

datacenter-mid/mid-calculate-transit/src/main/java/com/bailuntec/job/service/MidCalculateTransitService.java

@@ -86,8 +86,10 @@ public class MidCalculateTransitService {
     public void midCalculateTransferTransitQuantity() {
         DcJobConfig dcJobConfig = dcJobConfigMapper.selectByName(midCalculateTransferTransitQuantity);
         int pageNum = dcJobConfig.getPageNum();
+        log.info("清空调拨在途数量");
         dcMidTransitMapper.clearTransferTransitQuantity();
         for (; ; ) {
+            log.info("同步调拨在途");
             List<DcMidTransit> dcMidTransitList = dcMidTransitMapper.selectTransferTransitQuantity(BaseJobSqlParam.newInstance(dcJobConfig));
             if (ListUtil.isEmpty(dcMidTransitList)) {
                 break;