其他应收款

datacenter-base/base-sync-fee/src/main/java/com/bailuntec/job/FeeJob.java

@@ -15,7 +15,7 @@ public class FeeJob {
     @Resource
     SyncFeeService syncFeeService;
 
-    @Scheduled(cron = "0 0/1 * * * ?")
+    @Scheduled(cron = "0/10 * * * * ?")
     public void baseSyncFinanceFee() {
         try {
             log.info("每分钟同步费用单 开始");
@@ -27,7 +27,7 @@ public class FeeJob {
     }
 
 
-    @Scheduled(cron = "0/1 * * * * ?")
+    @Scheduled(cron = "0/10 * * * * ?")
     public void syncLogistics() {
         try {
             log.info("每分钟同步物流费用 开始");
@@ -38,7 +38,7 @@ public class FeeJob {
         }
     }
 
-    @Scheduled(cron = "0/1 * * * * ?")
+    @Scheduled(cron = "0/10 * * * * ?")
     public void syncManageCost() {
         try {
             log.info("每分钟同步管理成本 开始");
@@ -50,7 +50,7 @@ public class FeeJob {
     }
 
 
-    @Scheduled(cron = "0 0/1 * * * ?")
+    @Scheduled(cron = "0/10 * * * * ?")
     public void syncDailyFee() {
         try {
             log.info("每分钟同步当天费用单 开始");

datacenter-base/base-sync-fee/src/main/java/com/bailuntec/job/service/SyncFeeService.java

@@ -72,11 +72,13 @@ public class SyncFeeService {
                 DcBaseFinanceFee dcBaseFinanceFee = new DcBaseFinanceFee();
                 BeanUtils.copyProperties(costDto, dcBaseFinanceFee, "id");
                 dcBaseFinanceFee.setCreateTime(LocalDateTime.ofInstant(costDto.getCreateTime().toInstant(), ZoneId.systemDefault()));
+                dcBaseFinanceFee.setBjModified(LocalDateTime.now());
                 //更新
                 int update = dcBaseFinanceFeeMapper.update(dcBaseFinanceFee, new LambdaQueryWrapper<DcBaseFinanceFee>()
                         .eq(DcBaseFinanceFee::getCostNo, dcBaseFinanceFee.getCostNo()));
                 //插入
                 if (update == 0) {
+                    dcBaseFinanceFee.setBjCreate(LocalDateTime.now());
                     dcBaseFinanceFeeMapper.insert(dcBaseFinanceFee);
                 }
                 log.info("同步一条费用单,costNo:{}", costDto.getCostNo());

datacenter-base/base-sync-fee/src/main/resources/application-test.yml

 spring:
   # 服务名称
   application:
-    name: base-sync-fee
+    name: base-sync-amazon-ad
   # 数据配置
   datasource:
     url: jdbc:mysql://gz-cdb-kp7s5i79.sql.tencentcdb.com:61691/bailun_datacenter?serverTimezone=GMT%2B8&characterEncoding=utf-8
@@ -10,8 +10,14 @@ spring:
     driver-class-name: com.mysql.jdbc.Driver
   main:
     allow-bean-definition-overriding: true
-  profiles:
-    active: test
+
+#mybatis plus 配置
+mybatis-plus:
+  mapper-locations:
+    - classpath*:com/bailuntec/mapper/*.xml
+#  configuration:
+#    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
+
 
 
 feign:

datacenter-finance/finance-balance-sheet/src/main/java/com/bailuntec/job/BalanceSheetJob.java

@@ -16,7 +16,7 @@ public class BalanceSheetJob {
     @Resource
     BalanceSheetService balanceSheetService;
 
-    @Scheduled(cron = "0 0/2 * * * ?")
+    @Scheduled(cron = "0/10 * * * * ?")
     public void syncBankAccount() {
         try {
             log.info("每分钟同步 银行帐号信息 开始");
@@ -30,7 +30,7 @@ public class BalanceSheetJob {
     /**
      * 同步提现在途
      */
-    @Scheduled(cron = "0 0/2 * * * ?")
+    @Scheduled(cron = "0/10 * * * * ?")
     public void syncWithdrawOnWaySummary() {
         try {
             log.info("每分钟 同步提现在途 开始");
@@ -44,7 +44,7 @@ public class BalanceSheetJob {
     /**
      * 同步第三方帐号余额
      */
-    @Scheduled(cron = "0 0/2 * * * ?")
+    @Scheduled(cron = "0/10 * * * * ?")
     public void syncPayPal() {
         try {
             log.info("每分钟 同步第三方余额 开始");
@@ -59,7 +59,7 @@ public class BalanceSheetJob {
     /**
      * 同步短期借款余额
      */
-    @Scheduled(cron = "0 0/2 * * * ?")
+    @Scheduled(cron = "0/10 * * * * ?")
     @Transactional(rollbackFor = Exception.class)
     public void syncShortBorrowBalance() {
         try {
@@ -74,7 +74,7 @@ public class BalanceSheetJob {
     /**
      * 同步数据中心需要的费用单
      */
-    @Scheduled(cron = "0 0/2 * * * ?")
+    @Scheduled(cron = "0/10 * * * * ?")
     public void syncCost() {
         try {
             log.info("每分钟 同步数据中心需要的费用单 开始");
@@ -89,7 +89,7 @@ public class BalanceSheetJob {
     /**
      * 同步费用系统采购单：固定资产
      */
-    @Scheduled(cron = "0 0/2 * * * ?")
+    @Scheduled(cron = "0/10 * * * * ?")
     public void syncBuy() {
         try {
             log.info("每分钟 同步费用系统采购单 开始");
@@ -109,7 +109,7 @@ public class BalanceSheetJob {
      * </p>
      * 数据来源
      */
-    @Scheduled(cron = "0/1 * * * * ?")
+    @Scheduled(cron = "0/10 * * * * ?")
     public void generateBalanceSheet() {
         try {
             log.info("每分钟 生成资产负债表 开始");
@@ -129,7 +129,7 @@ public class BalanceSheetJob {
      * </p>
      * 数据来源
      */
-    @Scheduled(cron = "0/1 * * * * ?")
+    @Scheduled(cron = "0/10 * * * * ?")
     public void generateBalanceSheetNewResult() {
         try {
             log.info("每分钟 生成新资产负债结果表 开始");