数据中心--费用信息每日借支单

data-base/base-sync-finance-fee/src/main/java/com/bailuntec/Application.java

 package com.bailuntec;
 
 import com.alibaba.druid.pool.DruidDataSource;
+import com.bailuntec.job.DailyFeeJob;
 import com.bailuntec.job.FeeJob;
 import com.bailuntec.job.LogisticsJob;
 import com.bailuntec.job.ManageCostJob;
@@ -28,6 +29,7 @@ public class Application {
         new JobScheduler(createRegistryCenter(), createJobConfiguration(),createJobEventConfiguration()).init();
         new JobScheduler(createRegistryCenter(), createJobConfiguration1(),createJobEventConfiguration()).init();
         new JobScheduler(createRegistryCenter(), createJobConfiguration2(), createJobEventConfiguration()).init();
+        new JobScheduler(createRegistryCenter(), createJobConfiguration3(), createJobEventConfiguration()).init();
     }
 
     private static CoordinatorRegistryCenter createRegistryCenter() {
@@ -57,6 +59,13 @@ public class Application {
         return simpleJobRootConfig;
     }
 
+    private static LiteJobConfiguration createJobConfiguration3() {
+        JobCoreConfiguration simpleCoreConfig = JobCoreConfiguration.newBuilder(propertiesUtil.getPropertyAsString("DAILY_FEE_JOB_NAME"), propertiesUtil.getPropertyAsString("DAILY_FEE_JOB_CRON"), propertiesUtil.getPropertyAsInt("SHARDING_TOTAL_COUNT")).build();
+        SimpleJobConfiguration simpleJobConfig = new SimpleJobConfiguration(simpleCoreConfig, DailyFeeJob.class.getCanonicalName());
+        LiteJobConfiguration simpleJobRootConfig = LiteJobConfiguration.newBuilder(simpleJobConfig).build();
+        return simpleJobRootConfig;
+    }
+
     private static JobEventConfiguration createJobEventConfiguration() {
         JobEventConfiguration jobEventRdbConfig = new JobEventRdbConfiguration(setUpEventTraceDataSource());
         return jobEventRdbConfig;

data-base/base-sync-finance-fee/src/main/java/com/bailuntec/job/DailyFeeJob.java

+package com.bailuntec.job;
+
+import com.bailuntec.domain.entity.JobPointLog;
+import com.bailuntec.mapper.DcBaseFinanceFeeMapper;
+import com.bailuntec.support.PointJob;
+import com.bailuntec.utils.SessionUtil;
+import com.dangdang.ddframe.job.api.ShardingContext;
+
+import java.time.LocalDate;
+
+public class DailyFeeJob extends PointJob {
+
+    @Override
+    public void executeJob(ShardingContext shardingContext, JobPointLog jobPointLog) {
+        DcBaseFinanceFeeMapper dcBaseFinanceFeeMapper = SessionUtil.getSession().getMapper(DcBaseFinanceFeeMapper.class);
+        dcBaseFinanceFeeMapper.insertDailyFee(LocalDate.now());
+    }
+}

data-base/base-sync-finance-fee/src/main/resources/job.properties

@@ -15,4 +15,6 @@ LOGISTICS_JOB_NAME=base-sync-logistics
 LOGISTICS_JOB_CRON=0 0 0 1,15 * ? *
 MANAGECOST_JOB_NAME=base-sync-managecost
 MANAGECOST_JOB_CRON=0 0 0 1,15 * ? *
+DAILY_FEE_JOB_NAME=base-daily-fee
+DAILY_FEE_JOB_CRON=0 0 0 * * ? *
 SHARDING_TOTAL_COUNT=1
\ No newline at end of file

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

@@ -4,6 +4,7 @@ import com.bailuntec.domain.entity.DcBaseFinanceFee;
 import com.bailuntec.domain.example.DcBaseFinanceFeeExample;
 import org.apache.ibatis.annotations.Param;
 
+import java.time.LocalDate;
 import java.util.List;
 
 public interface DcBaseFinanceFeeMapper {
@@ -121,4 +122,6 @@ public interface DcBaseFinanceFeeMapper {
      * @project https://github.com/itfsw/mybatis-generator-plugin
      */
     int upsertSelective(DcBaseFinanceFee record);
+
+    int insertDailyFee(@Param("localDate") LocalDate localDate);
 }
\ No newline at end of file

data-common/src/main/java/com/bailuntec/mapper/DcBaseFinanceFeeMapper.xml

@@ -1663,4 +1663,24 @@
     </if>
     limit 1
   </select>
+  <insert id="insertDailyFee">
+    insert dc_daily_fee(cost_plan_no, cost_no, cost_reason, cost_form, company_no, company_name, type_no,
+      type_name, kind_no, kind_name, create_userid, create_usercode, create_username,
+      cost_remark, create_time, cost_status, file_path, mor_file_path, amount, bank_name,
+      bank_card, bank_card_user, bank_company, mor_remark, son_cost_no, sup_cost_no,
+      is_lend, had_pay, lend_status, compensate, counteract, lend_balance, reject_reason,
+      dic, pay_counteract, pay_lend_balance, pay_plan_amount, pay_dic, pay_cur, is_tax,
+      detail_key, pay_user_id, pay_time, amount_rmb, to_rmb_rate, sub_logistics_supplier_id,
+      logistics_supplier_id, subject_code, company_value, audit_time, last_modify_date,
+      bj_create, bj_modified, recoed_time)
+      select cost_plan_no, cost_no, cost_reason, cost_form, company_no, company_name, type_no,
+      type_name, kind_no, kind_name, create_userid, create_usercode, create_username,
+      cost_remark, create_time, cost_status, file_path, mor_file_path, amount, bank_name,
+      bank_card, bank_card_user, bank_company, mor_remark, son_cost_no, sup_cost_no,
+      is_lend, had_pay, lend_status, compensate, counteract, lend_balance, reject_reason,
+      dic, pay_counteract, pay_lend_balance, pay_plan_amount, pay_dic, pay_cur, is_tax,
+      detail_key, pay_user_id, pay_time, amount_rmb, to_rmb_rate, sub_logistics_supplier_id,
+      logistics_supplier_id, subject_code, company_value, audit_time, last_modify_date,
+      bj_create, bj_modified, #{localDate} from dc_base_finance_fee where is_lend = 1 and cost_form = 3 and lend_status in (1, 2)
+  </insert>
 </mapper>
\ No newline at end of file