逾期和还款查询sql优化，增加xyqb_i_repayment_plan_bak和xyqb_i_loan_a_m_history_bak临时表

src/main/java/cn/quantgroup/report/config/datasource/history/XyqbHistoryDataSourceConfig.java

+package cn.quantgroup.report.config.datasource.history;
+
+
+import com.zaxxer.hikari.HikariConfig;
+import com.zaxxer.hikari.HikariDataSource;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.ibatis.session.SqlSessionFactory;
+import org.mybatis.spring.SqlSessionFactoryBean;
+import org.mybatis.spring.SqlSessionTemplate;
+import org.mybatis.spring.annotation.MapperScan;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Import;
+import org.springframework.context.annotation.Primary;
+import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.jdbc.datasource.DataSourceTransactionManager;
+
+import javax.sql.DataSource;
+
+@Import(XyqbHistoryDataSourcePreperties.class)
+@Configuration
+@Slf4j
+@MapperScan(basePackages = XyqbHistoryDataSourceConfig.PACKAGE, sqlSessionFactoryRef = "xyqbHistorySqlSessionFactory")
+public class XyqbHistoryDataSourceConfig {
+
+
+    static final String PACKAGE = "cn.quantgroup.report.mapper.baihang";
+
+    @Value("${baihang.mapper-locations}")
+    private String mapperLocations;
+
+    @Value("${baihang.type-aliases-package}")
+    private String typeAliasesPackage;
+    
+    @Value("${config-location}")
+    private String configLocation;
+
+    @Autowired
+    private XyqbHistoryDataSourcePreperties xyqbHistoryDataSourcePreperties;
+
+    @Bean(name = "xyqbHistoryDataSource")
+    public DataSource xyqbHistoryDataSource() {
+        HikariConfig config = new HikariConfig();
+        config.setJdbcUrl(xyqbHistoryDataSourcePreperties.getJdbcUrl());
+        log.info("xyqb历史数据库地址:{}", xyqbHistoryDataSourcePreperties.getJdbcUrl());
+        config.setPassword(xyqbHistoryDataSourcePreperties.getPassword());
+        config.setUsername(xyqbHistoryDataSourcePreperties.getUsername());
+        config.setMaximumPoolSize(xyqbHistoryDataSourcePreperties.getMaxPoolSize());
+        config.setMinimumIdle(xyqbHistoryDataSourcePreperties.getMinPoolSize());
+        config.addDataSourceProperty("cachePrepStmts", "true");
+        config.addDataSourceProperty("prepStmtCacheSize", "250");
+        config.addDataSourceProperty("prepStmtCacheSqlLimit", "2048");
+        return new HikariDataSource(config);
+    }
+
+    @Bean(name = "xyqbHistoryTransactionManager")
+    public DataSourceTransactionManager xyqbHistoryTransactionManager(@Qualifier("xyqbHistoryDataSource") DataSource xyqbHistoryDataSource) {
+        return new DataSourceTransactionManager(xyqbHistoryDataSource);
+    }
+
+    @Bean(name = "xyqbHistorySqlSessionFactory")
+    public SqlSessionFactory xyqbHistorySqlSessionFactory(@Qualifier("xyqbHistoryDataSource") DataSource xyqbHistoryDataSource) throws Exception {
+        final SqlSessionFactoryBean sessionFactory = new SqlSessionFactoryBean();
+        sessionFactory.setDataSource(xyqbHistoryDataSource);
+        sessionFactory.setMapperLocations(new PathMatchingResourcePatternResolver()
+                .getResources(mapperLocations));
+        sessionFactory.setTypeAliasesPackage(typeAliasesPackage);
+        sessionFactory.setConfigLocation(new PathMatchingResourcePatternResolver()
+                .getResource(configLocation));
+        return sessionFactory.getObject();
+    }
+
+    @Bean(name = "xyqbHistorySqlSessionTemplate")
+    public SqlSessionTemplate xyqbHistorySqlSessionTemplate(@Qualifier("xyqbHistorySqlSessionFactory") SqlSessionFactory xyqbHistorySqlSessionFactory) throws Exception {
+        return new SqlSessionTemplate(xyqbHistorySqlSessionFactory);
+    }
+
+    @Bean(name = "xyqbHistoryJdbcTemplate")
+    public JdbcTemplate primaryJdbcTemplate(@Qualifier("xyqbHistoryDataSource") DataSource dataSource) {
+        return new JdbcTemplate(dataSource);
+    }
+
+}

src/main/java/cn/quantgroup/report/config/datasource/history/XyqbHistoryDataSourcePreperties.java

+package cn.quantgroup.report.config.datasource.history;
+
+import lombok.Getter;
+import lombok.Setter;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Configuration;
+
+@Setter
+@Getter
+@Configuration
+public class XyqbHistoryDataSourcePreperties {
+
+    @Value("${db.driver}")
+    private String driverClass;
+    @Value("${baihang.db.minPoolSize}")
+    private int minPoolSize;
+    @Value("${baihang.db.maxPoolSize}")
+    private int maxPoolSize;
+
+    @Value("${data.source.baihang.jdbcUrl}")
+    private String jdbcUrl;
+
+    //@Value("${data.source.baihang.username}")
+    private String username="xyqb_history_w";
+
+    //@Value("${data.source.baihang.password}")
+    private String password="KDb18asPu6iEz5lg";
+
+}

src/main/java/cn/quantgroup/report/job/LoanApplicationManifestHistoryTask.java

+package cn.quantgroup.report.job;
+
+import cn.quantgroup.report.service.baihang.constant.Constant;
+import com.google.common.base.Stopwatch;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.scheduling.annotation.Async;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
+import java.util.concurrent.TimeUnit;
+import java.util.concurrent.atomic.AtomicBoolean;
+
+
+/**
+ * -----------------------------------------------------------------------------<br>
+ * 描述: 量化派助贷模式(非循环贷) -
+ *      (贷款申请/放款/还款(逾期)三类实时批量数据)-To百行报送<br>
+ *     每日凌晨5点报送 <br>
+ * 作者：yanhui.Hao <br>
+ * 时间：2019.10.25 <br>
+ * 授权: (C) Copyright (c) 2017 <br>
+ * 公司: 北京众信利民信息技术有限公司 <br>
+ * -----------------------------------------------------------------------------
+ */
+@Component
+public class LoanApplicationManifestHistoryTask {
+
+    private static final Logger log = LoggerFactory.getLogger(LoanApplicationManifestHistoryTask.class);
+
+    @Autowired
+    private RedisTemplate<String,String> redisTemplate;
+
+
+    @Autowired
+    private JdbcTemplate xyqbHistoryJdbcTemplate;
+
+    private static AtomicBoolean SYN_Stop = new AtomicBoolean(false);
+
+    private static String SQL_COMMONE_TEMPLATE = "INSERT xyqb_i_loan_a_m_history_bak " +
+            " select * from xyqb_i_loan_application_manifest_history b " +
+            " where b.funding_corp_id in (420,520,580,650,670,810,240,640,700) " +
+            " and b.created_at >= '##STARTTIME##'  and b.created_at < '##ENDTIME##'; ";
+
+    private static String SQL_COMMONE_TEMPLATE_PLAN = " INSERT xyqb_i_repayment_plan_bak " +
+            "select a.* from xyqb_i_repayment_plan a " +
+            " join xyqb_i_loan_a_m_history_bak b " +
+            " on a.loan_application_history_id = b.loan_application_history_id " +
+            "where b.created_at >= '##STARTTIME##'  and b.created_at < '##ENDTIME##'; ";
+
+
+    @Async
+    /*@Scheduled(cron = "0 06 16 * * ?")*/
+    public void startHistoryDateCopy(){
+        if(increment()){
+            redisTemplate.expire(Constant.XYQB_HISTORY_DAI_REPORT_LOCK_KEY, 10, TimeUnit.SECONDS);
+
+            //将xyqb_i_loan_application_manifest_history表的数据，同步到xyqb_i_loan_a_m_history_bak
+            Stopwatch stopwatch = Stopwatch.createStarted();
+            //yyyy-MM-dd
+            //String startnyr = LocalDateTime.now().plusDays(-1).format(DateTimeFormatter.ISO_DATE);
+            //String endnyr = LocalDateTime.now().format(DateTimeFormatter.ISO_DATE);
+
+            log.info("量化派-同步表xyqb_i_loan_application_manifest_history数据开始, newTime: {} ", LocalDateTime.now());
+            //table_xyqb_i_loan_a_m_history_bak();
+            table_xyqb_i_repayment_plan_bak();
+            log.info("量化派-同步表xyqb_i_loan_application_manifest_history数据结束, endTime: {}, 耗时: {} ", LocalDateTime.now(), stopwatch.stop().elapsed(TimeUnit.MILLISECONDS));
+        }
+    }
+
+
+    public Boolean increment(){
+        Long increment = redisTemplate.opsForValue().increment(Constant.XYQB_HISTORY_DAI_REPORT_LOCK_KEY, 1);
+        return increment <= 1;
+    }
+
+    public void table_xyqb_i_loan_a_m_history_bak(){
+        LocalDateTime erlyDate = LocalDateTime.parse("2016-08-23T00:00:00");//2016-08-23T16:29:10
+        LocalDateTime endDate = LocalDateTime.parse("2019-11-01T00:00:00");//2019-11-11 12:32:08
+        int counter = 0;
+        while (true) {
+            Stopwatch startwatch = Stopwatch.createStarted();
+
+            if (SYN_Stop.get()) {
+                log.error("同步xyqb_i_loan_application_manifest_history数据查询STOP, D3_Stop: {} , endTime: {} ", SYN_Stop.get(), erlyDate.plusDays(counter).format(DateTimeFormatter.ISO_DATE));
+                break;
+            }
+            counter++;
+            if (erlyDate.plusDays(counter).compareTo(endDate) > 0) {
+                break;
+            }
+
+            String starTime = erlyDate.plusDays(counter - 1).format(DateTimeFormatter.ISO_DATE);
+            String endTime = erlyDate.plusDays(counter).format(DateTimeFormatter.ISO_DATE);
+            try {
+                String tmp_sql = SQL_COMMONE_TEMPLATE.replace("##STARTTIME##",starTime);
+                tmp_sql = tmp_sql.replace("##ENDTIME##",endTime);
+
+                int upCount = xyqbHistoryJdbcTemplate.update(tmp_sql);
+                log.info("同步xyqb_i_loan_application_manifest_history数据结束,startTime: {} , 耗时:{} , updateCount: {} ", starTime, startwatch.stop().elapsed(TimeUnit.MILLISECONDS), upCount);
+
+            }catch (Exception e){
+                log.error("同步xyqb_i_loan_application_manifest_history数据异常, startTime: {} , endTime: {} , counter: {} ", starTime, endTime,counter, e);
+            }
+        }
+    }
+
+    public void table_xyqb_i_repayment_plan_bak(){
+        LocalDateTime erlyDate = LocalDateTime.parse("2016-08-23T00:00:00");//2016-08-23T16:29:10
+        LocalDateTime endDate = LocalDateTime.parse("2019-11-01T00:00:00");//2019-11-11 12:32:08
+        int counter = 0;
+        while (true) {
+            Stopwatch startwatch = Stopwatch.createStarted();
+
+            if (SYN_Stop.get()) {
+                log.error("同步xyqb_i_repayment_plan数据查询STOP, D3_Stop: {} , endTime: {} ", SYN_Stop.get(), erlyDate.plusDays(counter).format(DateTimeFormatter.ISO_DATE));
+                break;
+            }
+            counter++;
+            if (erlyDate.plusDays(counter).compareTo(endDate) > 0) {
+                break;
+            }
+
+            String starTime = erlyDate.plusDays(counter - 1).format(DateTimeFormatter.ISO_DATE);
+            String endTime = erlyDate.plusDays(counter).format(DateTimeFormatter.ISO_DATE);
+            try {
+                String tmp_sql = SQL_COMMONE_TEMPLATE_PLAN.replace("##STARTTIME##",starTime);
+                tmp_sql = tmp_sql.replace("##ENDTIME##",endTime);
+
+                int upCount = xyqbHistoryJdbcTemplate.update(tmp_sql);
+                log.info("同步xyqb_i_repayment_plan数据结束,startTime: {} , 耗时:{} , updateCount: {} ", starTime, startwatch.stop().elapsed(TimeUnit.MILLISECONDS), upCount);
+
+            }catch (Exception e){
+                log.error("同步xyqb_i_repayment_plan数据异常, startTime: {} , endTime: {} , counter: {} ", starTime, endTime,counter, e);
+            }
+        }
+    }
+
+
+
+}

src/main/java/cn/quantgroup/report/service/baihang/constant/Constant.java

@@ -2,9 +2,10 @@ package cn.quantgroup.report.service.baihang.constant;
 
 public class Constant {
 
-    public static final String QG_LOAN_INFO_REPORT_LOCK_KEY = "QG_LOAN_INFO_REPORT_LOCK_KEY_UHBVGY";
-
     /** 量化派助贷模式-(贷款申请/放款/还款(逾期)三类实时数据)-To百行报送 */
     public static final String QG_ZHU_DAI_REPORT_LOCK_KEY = "QG_ZHU_DAI_REPORT_LOCK_KEY";
 
+
+    public static final String XYQB_HISTORY_DAI_REPORT_LOCK_KEY = "XYQB_HISTORY_DAI_REPORT_LOCK_KEY";
+
 }

src/main/resources/cn/quantgroup/report/mapper/baihang/RepaymentLoanInfoMapper.xml

@@ -334,7 +334,7 @@
     <!--3.1百行助贷-非联合贷  实时还款 2019.10.28-->
     <select id="findRealTimeRepayMentInfo" parameterType="cn.quantgroup.report.domain.baihang.BaiHangTimeRecord"
             resultType="cn.quantgroup.report.domain.baihang.RepaymentInfoZhuDai">
-       select
+       /*select
         a.id reqID
         ,'A' opCode
         ,DATE_FORMAT(now(),'%Y-%m-%dT%H:%i:%S') uploadTs
@@ -430,6 +430,108 @@
         and if(DATEDIFF(a.next_deadline,a.repaid_at)>1,a.term_no,h.max_term)=j.term_no
         group by if(d.order_no is null,a.loan_application_history_id,d.order_no),
         if(DATEDIFF(a.next_deadline,a.repaid_at)>1,a.term_no,h.max_term);
+        */
+
+        select
+        a.id reqID
+        ,'A' opCode
+        ,DATE_FORMAT(now(),'%Y-%m-%dT%H:%i:%S') uploadTs
+        ,if(d.order_no is null,a.loan_application_history_id,d.order_no) loanId
+        ,b.name name
+        ,b.id_no pid
+        ,b.phone_no mobile
+        ,if(DATEDIFF(a.next_deadline,a.repaid_at)>1,a.term_no,h.max_term) termNo
+        ,date(DATE_sub(if(DATEDIFF(a.next_deadline,a.repaid_at)>1,a.deadline,h.max_deadline),INTERVAL 1 second)) targetRepaymentDate
+        ,DATE_FORMAT(a.repaid_at,'%Y-%m-%dT%H:%i:%S') realRepaymentDate
+        ,j.required_repayment plannedPayment
+        ,f.yqze+sum(a.required_repayment) targetRepayment
+        ,sum(a.required_repayment) realRepayment
+        ,case when f.yqze=0 then ''
+        else concat('D',DATEDIFF( #{endTime,jdbcType=VARCHAR},f.min_deadline)+1) end overdueStatus
+        ,DATE_FORMAT( #{endTime,jdbcType=VARCHAR},'%Y-%m-%dT%H:%i:%S') statusConfirmAt
+        ,f.yqze overdueAmount
+        ,min(if(a.loan_paid_at>='2018-01-01',i.dkye,i2.dkye)) remainingAmount
+        ,case when f.yqze>0 then '2'
+        when min(if(a.loan_paid_at>='2018-01-01',i.dkye,i2.dkye))=0 and if(DATEDIFF(a.next_deadline,a.repaid_at)>1,a.term_no,h.max_term) &lt; f.max_term_no then '2'
+        when min(if(a.loan_paid_at>='2018-01-01',i.dkye,i2.dkye))=0 and if(DATEDIFF(a.next_deadline,a.repaid_at)>1,a.term_no,h.max_term)= f.max_term_no then '3'
+        when f.yqze=0 and min(if(a.loan_paid_at>='2018-01-01',i.dkye,i2.dkye))>0 then '1'
+        end as loanStatus
+        ,if(f.yqze>0,'overdue','normal') termStatus
+        from (
+        select
+        a.id,a.user_id,a.loan_application_history_id,a.term_no,a.deadline,a.required_repayment,a.repayment_status,a.repaid_at,a.created_at,
+        if(c.term_no is null,a.term_no,c.term_no) next_term
+        ,if(c.deadline is null,a.deadline,c.deadline) next_deadline
+        ,b.loan_paid_at
+        from xyqb_i_repayment_plan_bak a
+        left join xyqb_i_loan_a_m_history_bak b
+        on a.loan_application_history_id=b.loan_application_history_id and b.loan_paid_at &lt; #{endTime,jdbcType=VARCHAR}
+        left join xyqb_i_repayment_plan_bak c on a.loan_application_history_id=c.loan_application_history_id
+        and a.term_no=c.term_no-1
+        where a.repaid_at>= #{startTime,jdbcType=VARCHAR} and a.repaid_at &lt;  #{endTime,jdbcType=VARCHAR} and a.repayment_status=3
+        -- and b.funding_corp_id in (420,520,580,650,670,810,240,640,700)
+        and b.contract_term not in (2,3)
+        ) a
+        left join xyqb_user_i_user_detail b on a.user_id=b.user_id
+        left join xyqb_i_loan_account_ext c on a.loan_application_history_id=c.loan_id
+        left join xyqb_i_apply_quota_record d on c.order_no=d.order_no
+        left join (
+        select a.loan_application_history_id
+        ,sum(if((a.repayment_status !=3 or (a.repayment_status =3 and a.repaid_at>= #{endTime,jdbcType=VARCHAR})) and a.deadline &lt;=  #{endTime,jdbcType=VARCHAR},a.required_repayment,0)) yqze
+        ,sum(if(a.repayment_status !=3 or (a.repayment_status =3 and a.repaid_at>= #{endTime,jdbcType=VARCHAR}),if(b.loan_paid_at>='2018-01-01',g.principal,h.principle),0)) dkye
+        ,min(if((a.repayment_status !=3 or (a.repayment_status =3 and a.repaid_at>= #{endTime,jdbcType=VARCHAR})) and a.deadline &lt;=  #{endTime,jdbcType=VARCHAR},a.deadline,null)) min_deadline
+        ,max(a.term_no) max_term_no
+        from xyqb_i_repayment_plan_bak a
+        left join xyqb_i_loan_a_m_history_bak b on a.loan_application_history_id=b.loan_application_history_id
+        left join xyqb_i_repayment_record g on a.id=g.repayment_plan_id
+        left join xyqb_i_plan_amount_detail h on a.id=h.plan_id
+        -- where b.funding_corp_id in (420,520,580,650,670,810,240,640,700)
+        group by a.loan_application_history_id
+        ) f on a.loan_application_history_id=f.loan_application_history_id
+        left join xyqb_i_repayment_record g on a.id=g.repayment_plan_id
+        left join (
+        select a.loan_application_history_id,a.repaid_at,a.deadline,a.term_no
+        ,max(c.term_no) max_term
+        ,max(c.deadline) max_deadline
+        from xyqb_i_repayment_plan_bak a
+        left join xyqb_i_loan_a_m_history_bak b
+        on a.loan_application_history_id=b.loan_application_history_id and b.loan_paid_at &lt; #{endTime,jdbcType=VARCHAR}
+        left join xyqb_i_repayment_plan_bak c on a.loan_application_history_id=c.loan_application_history_id
+        where DATEDIFF(a.repaid_at,c.deadline)>=-1
+        -- and b.funding_corp_id in (420,520,580,650,670,810,240,640,700)
+        group by a.loan_application_history_id,a.term_no
+        ) h
+        on a.loan_application_history_id=h.loan_application_history_id and a.term_no=h.term_no
+        left join (
+        select a.loan_application_history_id
+        ,a.term_no
+        ,sum(if(d.term_no>a.term_no,d.principal,0)) dkye
+        from xyqb_i_repayment_plan_bak a
+        left join xyqb_i_loan_a_m_history_bak b
+        on a.loan_application_history_id=b.loan_application_history_id and b.loan_paid_at &lt; #{endTime,jdbcType=VARCHAR}
+        left join xyqb_i_repayment_record d on a.loan_application_history_id=d.loan_application_history_id
+        -- where b.funding_corp_id in (420,520,580,650,670,810,240,640,700)
+        group by a.loan_application_history_id,a.term_no
+        ) i
+        on a.loan_application_history_id=i.loan_application_history_id and a.term_no=i.term_no
+        left join (
+        select a.loan_application_history_id
+        ,a.term_no
+        ,sum(if(e.term_no>a.term_no,h.principle,0)) dkye
+        from xyqb_i_repayment_plan_bak a
+        left join xyqb_i_loan_a_m_history_bak b
+        on a.loan_application_history_id=b.loan_application_history_id and b.loan_paid_at &lt; #{endTime,jdbcType=VARCHAR}
+        left join xyqb_i_repayment_plan_bak e on a.loan_application_history_id=e.loan_application_history_id
+        left join xyqb_i_plan_amount_detail h on e.id=h.plan_id
+        -- where b.funding_corp_id in (420,520,580,650,670,810,240,640,700)
+        group by a.loan_application_history_id,a.term_no
+        ) i2
+        on a.loan_application_history_id=i2.loan_application_history_id and a.term_no=i2.term_no
+        left join xyqb_i_repayment_plan_bak j on a.loan_application_history_id=j.loan_application_history_id
+        and if(DATEDIFF(a.next_deadline,a.repaid_at)>1,a.term_no,h.max_term)=j.term_no
+        group by if(d.order_no is null,a.loan_application_history_id,d.order_no),
+        if(DATEDIFF(a.next_deadline,a.repaid_at)>1,a.term_no,h.max_term);
+
     </select>
 
     <!--3.2百行助贷-联合贷  实时还款 2019.10.28-->
@@ -445,6 +547,7 @@
     <!--4.1百行助贷-非联合贷  实时逾期还款 2019.10.28-->
     <select id="findRealTimeRepayMentOverdue" parameterType="cn.quantgroup.report.domain.baihang.BaiHangTimeRecord"
             resultType="cn.quantgroup.report.domain.baihang.RepaymentInfoZhuDai">
+/*
         select
         a.id reqID
         ,'A' opCode
@@ -497,6 +600,61 @@
         where b.funding_corp_id in (420,520,580,650,670,810,240,640,700)
         group by a.loan_application_history_id) f on a.loan_application_history_id=f.loan_application_history_id
         left join xyqb_i_repayment_record g on a.id=g.repayment_plan_id;
+        */
+
+        select
+        a.id reqID
+        ,'A' opCode
+        ,DATE_FORMAT(now(),'%Y-%m-%dT%H:%i:%S') uploadTs
+        ,if(d.order_no is null,a.loan_application_history_id,d.order_no) loanId
+        ,b.name name
+        ,b.id_no pid
+        ,b.phone_no mobile
+        ,a.term_no termNo
+        ,date(DATE_sub(a.deadline,INTERVAL 1 second)) targetRepaymentDate
+        ,'' realRepaymentDate
+        ,a.required_repayment plannedPayment
+        ,f.yqze targetRepayment
+        ,0 realRepayment
+        ,case when f.yqze=0 then ''
+        else concat('D',DATEDIFF( #{endTime,jdbcType=VARCHAR},f.min_deadline)+1) end overdueStatus
+        ,DATE_FORMAT( #{endTime,jdbcType=VARCHAR},'%Y-%m-%dT%H:%i:%S') statusConfirmAt
+        ,f.yqze overdueAmount
+        ,f.dkye remainingAmount
+        ,case when f.yqze>0 then '2'
+        when f.dkye=0 then '3'
+        when f.yqze=0 and f.dkye>0 then '1'
+        end as loanStatus
+        ,'overdue' termStatus
+        from (
+        select -- a.*
+        a.id,a.user_id,a.loan_application_history_id,a.term_no,a.deadline,a.required_repayment,a.repayment_status,a.repaid_at,a.repayment_received_at
+        from xyqb_i_repayment_plan_bak a
+        left join xyqb_i_loan_a_m_history_bak b -- xyqb_i_loan_application_manifest_history
+        on a.loan_application_history_id=b.loan_application_history_id and b.loan_paid_at &lt; #{endTime,jdbcType=VARCHAR}
+        where (a.repayment_status !=3 or (a.repayment_status =3 and a.repaid_at>= #{endTime,jdbcType=VARCHAR})) and
+        if(b.contract_term>a.term_no,DATEDIFF( #{endTime,jdbcType=VARCHAR},a.deadline)=0,DATEDIFF( #{endTime,jdbcType=VARCHAR},a.deadline)>=0)
+        and floor(DATEDIFF( #{endTime,jdbcType=VARCHAR},a.deadline)/30)=DATEDIFF( #{endTime,jdbcType=VARCHAR},a.deadline)/30
+        -- and b.funding_corp_id in (420,520,580,650,670,810,240,640,700)
+        and b.transaction_status in (2,5)
+        and b.contract_term not in (2,3)
+        ) a
+        left join xyqb_user_i_user_detail b on a.user_id=b.user_id
+        left join xyqb_i_loan_account_ext c on a.loan_application_history_id=c.loan_id
+        left join xyqb_i_apply_quota_record d on c.order_no=d.order_no
+        left join (
+        select a.loan_application_history_id
+        ,sum(if((a.repayment_status !=3 or (a.repayment_status =3 and a.repaid_at>= #{endTime,jdbcType=VARCHAR})) and a.deadline &lt;=  #{endTime,jdbcType=VARCHAR},if(b.loan_paid_at>='2018-01-01',g.principal+g.interest+g.service_fee,h.principle+h.interest+h.service_fee_per_term),0)) yqze
+        ,sum(if(a.repayment_status !=3 or (a.repayment_status =3 and a.repaid_at>= #{endTime,jdbcType=VARCHAR}),if(b.loan_paid_at>='2018-01-01',g.principal,h.principle),0)) dkye
+        ,min(if((a.repayment_status !=3 or (a.repayment_status =3 and a.repaid_at>= #{endTime,jdbcType=VARCHAR})) and a.deadline &lt;=  #{endTime,jdbcType=VARCHAR},a.deadline,null)) min_deadline
+        from xyqb_i_repayment_plan_bak a
+        left join xyqb_i_loan_a_m_history_bak b on a.loan_application_history_id=b.loan_application_history_id
+        left join xyqb_i_repayment_record g on a.id=g.repayment_plan_id
+        left join xyqb_i_plan_amount_detail h on a.id=h.plan_id
+        -- where b.funding_corp_id in (420,520,580,650,670,810,240,640,700)
+        group by a.loan_application_history_id
+        ) f on a.loan_application_history_id=f.loan_application_history_id
+        left join xyqb_i_repayment_record g on a.id=g.repayment_plan_id;
     </select>
 
     <!--4.2百行助贷-联合贷  实时逾期还款 2019.10.28-->